Merge pull request #627 from johanbook/delete-current-profile

feat(api): add endpoint to delete current profile

Author: johanbook

services/api/src/core/profiles/application/contracts/commands/delete-current-profile.command.ts

@@ -0,0 +1 @@
+export class DeleteCurrentProfileCommand {}

services/api/src/core/profiles/application/handlers/command-handlers/delete-current-profile.handler.spec.ts

@@ -0,0 +1,50 @@
+import { EventBus } from "@nestjs/cqrs";
+import { Repository } from "typeorm";
+
+import { UserIdService } from "src/core/authentication";
+import { createEventBusMock } from "src/test/mocks";
+import { createMockRepository } from "src/test/mocks/repository.mock";
+import { createUserIdServiceMock } from "src/test/mocks/user-id.service.mock";
+
+import { CurrentProfileService } from "../../../domain/services/current-profile.service";
+import { ProfileService } from "../../../domain/services/profile.service";
+import { Profile } from "../../../infrastructure/entities/profile.entity";
+import { DeleteCurrentProfileHandler } from "./delete-current-profile.handler";
+
+describe(DeleteCurrentProfileHandler.name, () => {
+  let commandHandler: DeleteCurrentProfileHandler;
+  let currentProfileService: CurrentProfileService;
+  let eventBus: EventBus;
+  let profiles: Repository<Profile>;
+  let profileService: ProfileService;
+  let userIdService: UserIdService;
+
+  beforeEach(() => {
+    eventBus = createEventBusMock();
+    profiles = createMockRepository<Profile>();
+    userIdService = createUserIdServiceMock();
+
+    profileService = new ProfileService(eventBus, profiles);
+
+    currentProfileService = new CurrentProfileService(profiles, userIdService);
+
+    commandHandler = new DeleteCurrentProfileHandler(
+      currentProfileService,
+      profileService,
+    );
+  });
+
+  describe("execute", () => {
+    it("should delete current profile", async () => {
+      const profile = new Profile();
+      profiles.save(profile);
+
+      expect(profiles.find()).not.toEqual([]);
+
+      await commandHandler.execute();
+
+      expect(profiles.find()).toEqual([]);
+      expect(eventBus.publish).toHaveBeenCalledTimes(1);
+    });
+  });
+});

services/api/src/core/profiles/application/handlers/command-handlers/delete-current-profile.handler.ts

@@ -0,0 +1,22 @@
+import { CommandHandler, ICommandHandler } from "@nestjs/cqrs";
+
+import { CurrentProfileService } from "../../../domain/services/current-profile.service";
+import { ProfileService } from "../../../domain/services/profile.service";
+import { DeleteCurrentProfileCommand } from "../../contracts/commands/delete-current-profile.command";
+
+@CommandHandler(DeleteCurrentProfileCommand)
+export class DeleteCurrentProfileHandler
+  implements ICommandHandler<DeleteCurrentProfileHandler, void>
+{
+  constructor(
+    private readonly currentProfileService: CurrentProfileService,
+    private readonly profileService: ProfileService,
+  ) {}
+
+  async execute() {
+    const currentProfile =
+      await this.currentProfileService.fetchCurrentProfile();
+
+    await this.profileService.deleteProfile(currentProfile);
+  }
+}

services/api/src/core/profiles/client/controllers/current-profile.controller.ts

@@ -1,10 +1,20 @@
-import { Body, Controller, Get, Patch, Post, Put, Query } from "@nestjs/common";
+import {
+  Body,
+  Controller,
+  Delete,
+  Get,
+  Patch,
+  Post,
+  Put,
+  Query,
+} from "@nestjs/common";
 import { CommandBus, QueryBus } from "@nestjs/cqrs";
 import { ApiTags } from "@nestjs/swagger";
 
 import { Multipart } from "src/core/multipart";
 
 import { CreateProfileCommand } from "../../application/contracts/commands/create-profile.command";
+import { DeleteCurrentProfileCommand } from "../../application/contracts/commands/delete-current-profile.command";
 import { UpdateProfilePhotoCommand } from "../../application/contracts/commands/update-profile-photo.command";
 import { UpdateProfileCommand } from "../../application/contracts/commands/update-profile.command";
 import { ProfileDetails } from "../../application/contracts/dtos/profile.dto";
@@ -23,6 +33,13 @@ export class CurrentProfileController {
     return await this.queryBus.execute(query);
   }
 
+  @Delete()
+  async deleteCurrentProfile(
+    @Query() query: DeleteCurrentProfileCommand,
+  ): Promise<null> {
+    return await this.queryBus.execute(query);
+  }
+
   @Get("/exists")
   async checkIfProfileExists(
     @Query() query: CheckIfProfileExistsQuery,

services/api/src/core/profiles/domain/events/profile-deleted.event.ts

@@ -0,0 +1,3 @@
+export class ProfileDeletedEvent {
+  public readonly id!: number;
+}

services/api/src/core/profiles/domain/services/profile.service.ts

@@ -7,6 +7,7 @@ import { map } from "src/core/mapper";
 
 import { Profile } from "../../infrastructure/entities/profile.entity";
 import { ProfileCreatedEvent } from "../events/profile-created.event";
+import { ProfileDeletedEvent } from "../events/profile-deleted.event";
 import { ProfileUpdatedEvent } from "../events/profile-updated.event";
 
 @Injectable()
@@ -29,6 +30,16 @@ export class ProfileService {
     this.eventBus.publish(event);
   }
 
+  async deleteProfile(profile: { id: number }): Promise<void> {
+    await this.profiles.delete(profile.id);
+
+    const event = map(ProfileDeletedEvent, {
+      id: profile.id,
+    });
+
+    this.eventBus.publish(event);
+  }
+
   async updateProfile(profile: Profile): Promise<void> {
     const updatedProfile = await this.profiles.save(profile);
 

services/api/src/core/profiles/profile.module.ts

@@ -8,6 +8,7 @@ import { OrganizationModule } from "src/core/organizations/organization.module";
 import { PhotosModule } from "src/core/photos/photos.module";
 
 import { CreateProfileHandler } from "./application/handlers/command-handlers/create-profile.handler";
+import { DeleteCurrentProfileHandler } from "./application/handlers/command-handlers/delete-current-profile.handler";
 import { UpdateProfilePhotoHandler } from "./application/handlers/command-handlers/update-profile-photo.handler";
 import { UpdateProfileHandler } from "./application/handlers/command-handlers/update-profile.handler";
 import { CheckIfProfileExistsHandler } from "./application/handlers/query-handlers/check-if-profile-exists.handler";
@@ -35,6 +36,7 @@ import { Profile } from "./infrastructure/entities/profile.entity";
     CurrentProfileService,
     CheckIfProfileExistsHandler,
     CreateProfileHandler,
+    DeleteCurrentProfileHandler,
     GetCurrentProfileHandler,
     GetProfileHandler,
     ProfileService,

services/api/src/test/mocks/repository.mock.ts

@@ -7,6 +7,16 @@ class MockRepository<T extends ObjectLiteral> {
 
   constructor(private data: T[] = []) {}
 
+  delete = jest.fn((id: string | number) => {
+    const index = this.data.findIndex((item) => item.id === id);
+
+    if (index < 0) {
+      throw new Error("Item not found");
+    }
+
+    this.data.splice(index, 1);
+  });
+
   exist = jest.fn((element: T) =>
     this.data.find((item) => item.id === element.where.id),
   );
@@ -18,13 +28,7 @@ class MockRepository<T extends ObjectLiteral> {
   findOne = jest.fn(() => this.data[0]);
 
   remove = jest.fn((element: T) => {
-    const index = this.data.findIndex((item) => item.id === element.id);
-
-    if (index < 0) {
-      throw new Error("Item not found");
-    }
-
-    this.data.splice(index, 1);
+    this.delete(element.id);
   });
 
   save = jest.fn((element: T) => {