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