adding clean thread api

Signed-off-by: James <namnh0122@gmail.com>

Author: namchuai

cortex-js/src/infrastructure/controllers/threads.controller.ts

@@ -215,6 +215,24 @@ export class ThreadsController {
     );
   }
 
+  @ApiOperation({
+    summary: 'Clean thread',
+    description: 'Deletes all messages in a thread.',
+    tags: ['Threads'],
+    parameters: [
+      {
+        in: 'path',
+        name: 'thread_id',
+        required: true,
+        description: 'The ID of the thread to clean.',
+      },
+    ],
+  })
+  @Post(':thread_id/clean')
+  async cleanThread(@Param('thread_id') threadId: string) {
+    return this.threadsUsecases.clean(threadId);
+  }
+
   @ApiOperation({
     summary: 'Delete message',
     description: 'Deletes a message.',

cortex-js/src/usecases/threads/threads.usecases.ts

@@ -215,4 +215,9 @@ export class ThreadsUsecases {
     // we still allow user to delete message even if the thread is not there
     return this.getMessageOrThrow(messageId);
   }
+
+  async clean(threadId: string) {
+    await this.getThreadOrThrow(threadId);
+    await this.messageRepository.delete({ thread_id: threadId });
+  }
 }