From 60f7c7d474fe3416e5af00a523f86ee5d09ba729 Mon Sep 17 00:00:00 2001 From: yang Date: Wed, 20 Nov 2024 22:53:15 +0900 Subject: [PATCH] =?UTF-8?q?refactor:=20title=20=ED=8E=B8=EC=A7=91=20?= =?UTF-8?q?=EC=98=88=EC=99=B8=20=EC=B2=98=EB=A6=AC=20=EB=B0=8F=20Polling?= =?UTF-8?q?=2010=EC=B4=88=20Timeout=20=EC=84=A4=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/server/src/task/service/broadcast.service.ts | 1 + apps/server/src/task/service/task.service.ts | 6 +++++- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/apps/server/src/task/service/broadcast.service.ts b/apps/server/src/task/service/broadcast.service.ts index f1a5091..7e82ac8 100644 --- a/apps/server/src/task/service/broadcast.service.ts +++ b/apps/server/src/task/service/broadcast.service.ts @@ -7,6 +7,7 @@ export class BroadcastService { private connections: Map = new Map(); addConnection(projectId: number, res: CustomResponse) { + res.setTimeout(10000); if (!this.connections.has(projectId)) { this.connections.set(projectId, [res]); } else { diff --git a/apps/server/src/task/service/task.service.ts b/apps/server/src/task/service/task.service.ts index 788aff8..f89b782 100644 --- a/apps/server/src/task/service/task.service.ts +++ b/apps/server/src/task/service/task.service.ts @@ -43,7 +43,11 @@ export class TaskService { this.eventEmitter.on( 'operationAdded', async (userId: number, projectId: number, taskId: number) => { - await this.dequeue(userId, projectId, taskId); + try { + await this.dequeue(userId, projectId, taskId); + } catch (e) { + throw new BadRequestException(e.message); + } } ); }