Once we have database query done, we'll add a new method called loginUser and use it in our authService. Notice here that we throw and exception if we do not find any users in the database. This would mean that the client's request has failed.
File: src/domain/services/authService.js
/**
* @returns user
*/
const loginUser = async (user) => {
const loginUser = await userRepository.findUserByEmailAndPassword(user)
if (!loginUser) {
throw new ApiException({
status: 'error',
code: 400,
message: `Invalid credentials, please try a different email and password combination.`,
data: null,
errors: [
`Invalid credentials, please try a different email and password combination.`
]
})
}
return loginUser
}
6 - Events
None.
7 - Response
Now to put everything all together. We'll reuse our userResponseDto from last section and log the user into our session with a simple req.session.user.
/**
* Logs the user in and set a session for it.
*/
const logUserIn = catchExceptions(async (req, res) => {
const loginUserRequest = loginUserRequestDto(req.body)
loginUserValidator(loginUserRequest)
// if the user's email and password match in our database
// then set the current session to that user
const loggedInUser = await authService.loginUser(loginUserRequest)
// If there we find a user with authService.loginUser, then
// we'll set the current session to that user
req.session.user = loggedInUser
const userDto = userResponseDto(loggedInUser)
res.status(200).json(
globalResponseDto({
status: 'success',
code: 200,
message: `The user has successfully logged in.`,
data: userDto,
errors: null
})
)
})
module.exports = logUserIn