x

Author: martiendt

src/modules/users/controllers/index.ts

@@ -10,6 +10,7 @@ export { retrieveAllUserController } from './retrieve-all.controller'
 export { signinController } from './signin.controller'
 export { signupController } from './signup.controller'
 export { updateUserController } from './update.controller'
+export { updatePasswordUserController } from './update-password.controller'
 // export { updateManyUserController } from './update-many.controller'
 export { verifyEmailController } from './verify-email.controller'
 export { verifyTokenController } from './verify-token.controller'

src/modules/users/controllers/update-password.controller.ts

@@ -0,0 +1,42 @@
+import { objClean } from '@point-hub/express-utils'
+import type { IController, IControllerInput } from '@point-hub/papi'
+
+import { UniqueValidation } from '@/utils/unique-validation'
+import { schemaValidation } from '@/utils/validation'
+
+import { UpdatePasswordUserRepository } from '../repositories/update-password.repository'
+import { UpdatePasswordUserUseCase } from '../use-cases/update-password.use-case'
+
+export const updatePasswordUserController: IController = async (controllerInput: IControllerInput) => {
+  let session
+  try {
+    // 1. start session for transactional
+    session = controllerInput.dbConnection.startSession()
+    session.startTransaction()
+    // 2. define repository
+    const updatePasswordUserRepository = new UpdatePasswordUserRepository(controllerInput.dbConnection, { session })
+    const uniqueValidation = new UniqueValidation(controllerInput.dbConnection, { session })
+    // 3. handle business rules
+    const response = await UpdatePasswordUserUseCase.handle(
+      {
+        _id: controllerInput.httpRequest['params'].id,
+        data: controllerInput.httpRequest['body'],
+      },
+      { schemaValidation, updatePasswordUserRepository, uniqueValidation, objClean, hashPassword: Bun.password.hash },
+    )
+    await session.commitTransaction()
+    // 4. return response to client
+    return {
+      status: 200,
+      json: {
+        matched_count: response.matched_count,
+        modified_count: response.modified_count,
+      },
+    }
+  } catch (error) {
+    await session?.abortTransaction()
+    throw error
+  } finally {
+    await session?.endSession()
+  }
+}

src/modules/users/repositories/index.repository.ts

@@ -7,3 +7,4 @@ export { RetrieveAllUserRepository } from './retrieve-all.repository'
 export { SignupRepository } from './signup.repository'
 export { UpdateUserRepository } from './update.repository'
 export { UpdateManyUserRepository } from './update-many.repository'
+export { UpdatePasswordUserRepository } from './update-password.repository'

src/modules/users/repositories/update-password.repository.ts

@@ -0,0 +1,26 @@
+import type { IDatabase, IDocument } from '@point-hub/papi'
+
+import { collectionName } from '../entity'
+
+export interface IUpdatePasswordUserRepository {
+  handle(_id: string, document: IDocument): Promise<IUpdatePasswordUserOutput>
+}
+
+export interface IUpdatePasswordUserOutput {
+  matched_count: number
+  modified_count: number
+}
+
+export class UpdatePasswordUserRepository implements IUpdatePasswordUserRepository {
+  constructor(
+    public database: IDatabase,
+    public options?: Record<string, unknown>,
+  ) {}
+
+  async handle(_id: string, document: IDocument): Promise<IUpdatePasswordUserOutput> {
+    console.log(document)
+    return await this.database
+      .collection(collectionName)
+      .update(_id, { $set: document }, { ignoreUndefined: true, ...this.options })
+  }
+}

src/modules/users/router.ts

@@ -36,6 +36,13 @@ const makeRouter = async (routerInput: IBaseAppInput) => {
       dbConnection: routerInput.dbConnection,
     }),
   )
+  router.post(
+    '/:id/update-password',
+    await makeController({
+      controller: controller.updatePasswordUserController,
+      dbConnection: routerInput.dbConnection,
+    }),
+  )
   router.delete(
     '/:id',
     await makeController({

src/modules/users/use-cases/update-password.use-case.ts

@@ -0,0 +1,46 @@
+import type { IObjClean } from '@point-hub/express-utils'
+import type { ISchemaValidation } from '@point-hub/papi'
+
+import type { IUniqueValidation } from '@/utils/unique-validation'
+
+import type { IUpdatePasswordUserRepository } from '../repositories/update-password.repository'
+import { updatePasswordValidation } from '../validations/update-password.validation'
+
+export interface IInput {
+  _id: string
+  data: {
+    password?: string
+  }
+}
+
+export interface IDeps {
+  schemaValidation: ISchemaValidation
+  updatePasswordUserRepository: IUpdatePasswordUserRepository
+  uniqueValidation: IUniqueValidation
+  hashPassword(password: string): Promise<string>
+  objClean: IObjClean
+}
+
+export interface IOutput {
+  matched_count: number
+  modified_count: number
+}
+
+export class UpdatePasswordUserUseCase {
+  static async handle(input: IInput, deps: IDeps): Promise<IOutput> {
+    // 2. validate schema
+
+    await deps.schemaValidation(input.data, updatePasswordValidation)
+    // 3. define entity
+
+    // 4. database operation
+    const response = await deps.updatePasswordUserRepository.handle(input._id, {
+      password: await deps.hashPassword(input.data.password as string),
+    })
+    // 5. output
+    return {
+      matched_count: response.matched_count,
+      modified_count: response.modified_count,
+    }
+  }
+}

src/modules/users/use-cases/update.use-case.ts

@@ -32,6 +32,7 @@ export interface IOutput {
 export class UpdateUserUseCase {
   static async handle(input: IInput, deps: IDeps): Promise<IOutput> {
     // 1. validate unique
+    await deps.uniqueValidation.handle(collectionName, { username: input.data.username }, input._id)
     await deps.uniqueValidation.handle(collectionName, { name: input.data.name }, input._id)
     // 2. validate schema
     await deps.schemaValidation(input.data, updateValidation)

src/modules/users/validations/update-password.validation.ts

@@ -0,0 +1,3 @@
+export const updatePasswordValidation = {
+  password: ['required', 'string'],
+}