From 9eacb7dca5bcd721a8a11624b32fd897c6e4b681 Mon Sep 17 00:00:00 2001
From: shancheas <irfan.zaelani13@gmail.com>
Date: Tue, 19 Nov 2024 13:16:52 +0700
Subject: [PATCH] feat: add done status queue

---
 src/modules/queue/domain/queue-admin.orchestrator.ts       | 7 +++++++
 .../infrastructure/controllers/queue-admin.controller.ts   | 5 +++++
 2 files changed, 12 insertions(+)

diff --git a/src/modules/queue/domain/queue-admin.orchestrator.ts b/src/modules/queue/domain/queue-admin.orchestrator.ts
index 21876c8..36be553 100644
--- a/src/modules/queue/domain/queue-admin.orchestrator.ts
+++ b/src/modules/queue/domain/queue-admin.orchestrator.ts
@@ -32,4 +32,11 @@ export class QueueAdminOrchestrator {
     await this.callManager.execute();
     return this.callManager.getResult();
   }
+
+  async done(dataId): Promise<string> {
+    this.callManager.setData(dataId, QUEUE_STATUS.DONE);
+    this.callManager.setService(this.service, TABLE_NAME.QUEUE);
+    await this.callManager.execute();
+    return this.callManager.getResult();
+  }
 }
diff --git a/src/modules/queue/infrastructure/controllers/queue-admin.controller.ts b/src/modules/queue/infrastructure/controllers/queue-admin.controller.ts
index 3916154..0ba3e4a 100644
--- a/src/modules/queue/infrastructure/controllers/queue-admin.controller.ts
+++ b/src/modules/queue/infrastructure/controllers/queue-admin.controller.ts
@@ -56,4 +56,9 @@ export class QueueAdminController {
   async call(@Param('id') id: string) {
     return await this.orchestrator.call(id);
   }
+
+  @Post('queues/:id/done')
+  async done(@Param('id') id: string) {
+    return await this.orchestrator.done(id);
+  }
 }