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 { + 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); + } }