chore: cleanup

src/common/interceptors/idempotence.interceptor.ts

@@ -1,5 +1,5 @@
 import { FastifyRequest } from 'fastify'
-import { catchError, tap } from 'rxjs'
+import { catchError } from 'rxjs'
 
 import {
   CallHandler,
@@ -99,15 +99,12 @@ export class IdempotenceInterceptor implements NestInterceptor {
           return await errorHandler(request)
         }
         throw new ConflictException(errorMessage)
+      } else {
+        await redis.set(idempotenceKey, '1')
+        await redis.expire(idempotenceKey, expired)
       }
     }
     return next.handle().pipe(
-      tap(async () => {
-        if (idempotenceKey) {
-          await redis.set(idempotenceKey, '1')
-          await redis.expire(idempotenceKey, expired)
-        }
-      }),
       catchError(async (err) => {
         if (idempotenceKey) {
           await redis.del(idempotenceKey)
@@ -135,8 +132,6 @@ export class IdempotenceInterceptor implements NestInterceptor {
       Object.assign(obj, { ua, ip })
     }
 
-    console.log('-----', JSON.stringify(obj))
-
     return hashString(JSON.stringify(obj))
   }
 }

src/modules/debug/debug.controller.ts

@@ -1,7 +1,6 @@
 import {
   Body,
   Controller,
-  Get,
   Post,
   Query,
   Request,
@@ -12,7 +11,6 @@ import { HTTPDecorators } from '~/common/decorator/http.decorator'
 import { ApiName } from '~/common/decorator/openapi.decorator'
 import { BusinessEvents, EventScope } from '~/constants/business-event.constant'
 import { EventManagerService } from '~/processors/helper/helper.event.service'
-import { PagerDto } from '~/shared/dto/pager.dto'
 
 import { createMockedContextResponse } from '../serverless/mock-response.util'
 import { ServerlessService } from '../serverless/serverless.service'
@@ -25,17 +23,6 @@ export class DebugController {
     private readonly serverlessService: ServerlessService,
     private readonly eventManager: EventManagerService,
   ) {}
-  @Get('qs')
-  async qs(@Query() query: PagerDto) {
-    return query
-  }
-
-  @Post('ide')
-  @HTTPDecorators.Idempotence({})
-  async post(@Body() body: any) {
-    // throw new BadRequestException('test')
-    return { a: 1 }
-  }
 
   @Post('/events')
   async sendEvent(