feat: add delete for subscription

src/modules/subscriptions/subscriptions.controller.ts

@@ -1,6 +1,6 @@
 import * as crypto from 'node:crypto';
 
-import { Body, Controller, Headers, Param, Patch, Post, UnauthorizedException } from '@nestjs/common';
+import { Body, Controller, Delete, Headers, Param, Patch, Post, UnauthorizedException } from '@nestjs/common';
 import { ApiTags } from '@nestjs/swagger';
 
 import { ApiConfigService } from '../../../src/shared/services/api-config.service';
@@ -89,4 +89,9 @@ export class SubscriptionsController {
   updateSubscription(@Param('id') id: string, @Body() props: UpdateSubscriptionDto) {
     return this.subscriptionService.updateSubscription(id, props);
   }
+
+  @Delete(':id')
+  deleteSubscription(@Param('id') id: string) {
+    return this.subscriptionService.deleteSubscription(id);
+  }
 }

src/modules/subscriptions/subscriptions.repository.ts

@@ -27,4 +27,8 @@ export class SubscriptionRepository {
   create(entityLike: DeepPartial<SubscriptionEntity>) {
     return this.repository.create(entityLike);
   }
+
+  delete(id: string) {
+    return this.repository.delete(id);
+  }
 }

src/modules/subscriptions/subscriptions.service.ts

@@ -133,4 +133,16 @@ export class SubscriptionsService {
 
     await this.subscriptionRepository.save(s);
   }
+
+  async deleteSubscription(id: string) {
+    const s = await this.subscriptionRepository.findOne({ where: { _id: new ObjectId(id) } });
+
+    if (!s) {
+      throw new NotFoundException('subscription not found');
+    }
+
+    await this.subscriptionRepository.delete(id);
+
+    await this.redis.call('CF.DEL', 'SUBSCRIPTIONS', s.subscriber);
+  }
 }