feat: add delete topic subscription functionality to inbox controller and use cases

Author: djabarovgeorge

apps/api/src/app/inbox/inbox.controller.ts

@@ -69,6 +69,8 @@ import { DeleteAllNotificationsCommand } from './usecases/delete-all-notificatio
 import { DeleteAllNotifications } from './usecases/delete-all-notifications/delete-all-notifications.usecase';
 import { DeleteNotificationCommand } from './usecases/delete-notification/delete-notification.command';
 import { DeleteNotification } from './usecases/delete-notification/delete-notification.usecase';
+import { DeleteTopicSubscriptionCommand } from './usecases/delete-topic-subscription/delete-topic-subscription.command';
+import { DeleteTopicSubscription } from './usecases/delete-topic-subscription/delete-topic-subscription.usecase';
 import { GetInboxPreferencesCommand } from './usecases/get-inbox-preferences/get-inbox-preferences.command';
 import { GetInboxPreferences } from './usecases/get-inbox-preferences/get-inbox-preferences.usecase';
 import { GetNotificationsCommand } from './usecases/get-notifications/get-notifications.command';
@@ -122,7 +124,8 @@ export class InboxController {
     private getTopicSubscriptionsUsecase: GetTopicSubscriptions,
     private getTopicSubscriptionUsecase: GetTopicSubscription,
     private createTopicSubscriptionsUsecase: CreateTopicSubscriptionsUsecase,
-    private updateTopicSubscriptionUsecase: UpdateTopicSubscriptionUsecase
+    private updateTopicSubscriptionUsecase: UpdateTopicSubscriptionUsecase,
+    private deleteTopicSubscriptionUsecase: DeleteTopicSubscription
   ) {}
 
   @KeylessAccessible()
@@ -648,6 +651,22 @@ export class InboxController {
     );
   }
 
+  @UseGuards(AuthGuard('subscriberJwt'))
+  @Delete('/subscription/:subscriptionId')
+  async deleteTopicSubscription(
+    @SubscriberSession() subscriberSession: SubscriberSession,
+    @Param('subscriptionId') subscriptionId: string
+  ): Promise<{ success: boolean }> {
+    return await this.deleteTopicSubscriptionUsecase.execute(
+      DeleteTopicSubscriptionCommand.create({
+        environmentId: subscriberSession._environmentId,
+        organizationId: subscriberSession._organizationId,
+        subscriberId: subscriberSession.subscriberId,
+        subscriptionId,
+      })
+    );
+  }
+
   private convertPreferencesToGroupFilters(
     preferences: Array<string | WorkflowPreferenceRequestDto | GroupPreferenceFilterDto>
   ): Array<GroupPreferenceFilterDto> {

apps/api/src/app/inbox/usecases/delete-topic-subscription/delete-topic-subscription.command.ts

@@ -0,0 +1,8 @@
+import { IsDefined, IsString } from 'class-validator';
+import { EnvironmentWithSubscriber } from '../../../shared/commands/project.command';
+
+export class DeleteTopicSubscriptionCommand extends EnvironmentWithSubscriber {
+  @IsString()
+  @IsDefined()
+  subscriptionId: string;
+}

apps/api/src/app/inbox/usecases/delete-topic-subscription/delete-topic-subscription.usecase.ts

@@ -0,0 +1,44 @@
+import { Injectable, NotFoundException } from '@nestjs/common';
+import { InstrumentUsecase } from '@novu/application-generic';
+import { PreferencesRepository, TopicSubscribersRepository } from '@novu/dal';
+import { PreferencesTypeEnum } from '@novu/shared';
+import { DeleteTopicSubscriptionCommand } from './delete-topic-subscription.command';
+
+@Injectable()
+export class DeleteTopicSubscription {
+  constructor(
+    private topicSubscribersRepository: TopicSubscribersRepository,
+    private preferencesRepository: PreferencesRepository
+  ) {}
+
+  @InstrumentUsecase()
+  async execute(command: DeleteTopicSubscriptionCommand): Promise<{ success: boolean }> {
+    const subscription = await this.topicSubscribersRepository.findOne({
+      _environmentId: command.environmentId,
+      _organizationId: command.organizationId,
+      _id: command.subscriptionId,
+    });
+
+    if (!subscription) {
+      throw new NotFoundException(`Subscription with ID ${command.subscriptionId} not found`);
+    }
+
+    await this.topicSubscribersRepository.withTransaction(async () => {
+      await this.preferencesRepository.delete({
+        _environmentId: command.environmentId,
+        _organizationId: command.organizationId,
+        _topicSubscriptionId: subscription._id,
+        _subscriberId: subscription._subscriberId,
+        type: PreferencesTypeEnum.SUBSCRIPTION_SUBSCRIBER_WORKFLOW,
+      });
+
+      await this.topicSubscribersRepository.delete({
+        _environmentId: command.environmentId,
+        _organizationId: command.organizationId,
+        _id: command.subscriptionId,
+      });
+    });
+
+    return { success: true };
+  }
+}

apps/api/src/app/inbox/usecases/index.ts

@@ -16,6 +16,7 @@ import { BulkUpdatePreferences } from './bulk-update-preferences/bulk-update-pre
 import { DeleteAllNotifications } from './delete-all-notifications/delete-all-notifications.usecase';
 import { DeleteManyNotifications } from './delete-many-notifications/delete-many-notifications.usecase';
 import { DeleteNotification } from './delete-notification/delete-notification.usecase';
+import { DeleteTopicSubscription } from './delete-topic-subscription/delete-topic-subscription.usecase';
 import { GetInboxPreferences } from './get-inbox-preferences/get-inbox-preferences.usecase';
 import { GetNotifications } from './get-notifications/get-notifications.usecase';
 import { GetTopicSubscription } from './get-topic-subscription/get-topic-subscription.usecase';
@@ -51,6 +52,7 @@ export const USE_CASES = [
   DeleteNotification,
   DeleteManyNotifications,
   DeleteAllNotifications,
+  DeleteTopicSubscription,
   GetTopicSubscription,
   GetTopicSubscriptions,
   GenerateUniqueApiKey,