expressServer/controllers/userController.js

const { body, validationResult } = require('express-validator')
const logger = require('morgan')
const userService = require('../services/userService')
const FetchResult = require('../common/web/fetchResult')
const messages = require('../config/messages')
const { HTTP_STATUS } = require('../common/constant/httpStatus')
const { SearchQuery } = require('../models/search')

exports.getAllUsers = async (res) => {
  try {
    const users = await userService.getUserList()
    return FetchResult.formatResult(res, HTTP_STATUS.ACCEPTED, 'success', users)
  } catch (err) {
    return FetchResult.formatResult(res, HTTP_STATUS.INTERNAL_SERVER_ERROR, 'Internal server error')
  }
}

exports.findUserList = async (req, res) => {
  try {
    const { page, size, sort } = req.query
    const search = new SearchQuery({ page: page, size: size, sort: sort })
    const result = await userService.getUserList(search)
    return FetchResult.formatResult(res, HTTP_STATUS.ACCEPTED, 'success', result)
  } catch (err) {
    console.log(err)

    return FetchResult.formatResult(res, HTTP_STATUS.INTERNAL_SERVER_ERROR, 'Internal server error')
  }
}

exports.createUser = [
  body('account').isLength({ min: 3 }).withMessage('Account must be at least 3 characters long'),
  body('account').isEmpty().withMessage('Account is required'),
  body('password').isLength({ min: 6 }).withMessage('Password must be at least 6 characters long'),
  body('password').isEmpty().withMessage('Password is required'),
  async (req, res, next) => {
    const errors = validationResult(req)
    if (!errors.isEmpty()) {
      return FetchResult.formatResult(
        res,
        HTTP_STATUS.BAD_REQUEST,
        errors
          .array()
          .map((err) => err.msg)
          .join(', ')
      )
    }

    next()
  },
  async (req, res) => {
    try {
      const user = req.body
      await userService.createUser(user)
      return FetchResult.formatResult(res, HTTP_STATUS.CREATED, messages.user.created)
    } catch (err) {
      logger('Error creating user: ', err)
      if (err.message === messages.user.alreadyExists) {
        return FetchResult.formatResult(res, HTTP_STATUS.CONFLICT, messages.user.alreadyExists)
      }
      return FetchResult.formatResult(res, HTTP_STATUS.INTERNAL_SERVER_ERROR, 'Internal server error')
    }
  }
]

exports.login = [
  body('account').notEmpty().withMessage('Account is required'),
  body('password').notEmpty().withMessage('Password is required'),
  async (req, res, next) => {
    const errors = validationResult(req)
    if (!errors.isEmpty()) {
      console.log(errors)
      return FetchResult.formatResult(
        res,
        400,
        errors
          .array()
          .map((err) => err.msg)
          .join(', ')
      )
    }

    next()
  },
  async (req, res) => {
    try {
      const { account, password } = req.body
      req.session.user = await userService.login(account, password)
      return FetchResult.formatResult(res, HTTP_STATUS.ACCEPTED, messages.user.login)
    } catch (err) {
      if (err.message === messages.user.not_found) {
        return FetchResult.formatResult(res, HTTP_STATUS.NOT_FOUND, messages.user.accountPasswordNotMatch)
      }

      logger('Error logging in: ', err)

      return FetchResult.formatResult(res, HTTP_STATUS.INTERNAL_SERVER_ERROR, 'Internal server error')
    }
  }
]

exports.logout = async (req, res) => {
  try {
    req.session.destroy()
    return FetchResult.formatResult(res, HTTP_STATUS.OK, messages.user.logout)
  } catch (err) {
    logger('Error logging out: ', err)
    return FetchResult.formatResult(res, HTTP_STATUS.INTERNAL_SERVER_ERROR, 'Internal server error')
  }
}

exports.getUserExist = async (req, res) => {
  try {
    const { account } = req.query

    const exist = await userService.getUserExists(account)

    if (!exist) {
      return FetchResult.formatResult(res, HTTP_STATUS.NOT_FOUND, messages.user.not_found)
    }
    return FetchResult.formatResult(res, HTTP_STATUS.ACCEPTED, messages.user.exist)
  } catch (err) {
    logger('Error checking user existence: ', err)
    return FetchResult.formatResult(res, HTTP_STATUS.INTERNAL_SERVER_ERROR, 'Internal server error')
  }
}