diff --git a/packages/backend/src/server/ServerService.ts b/packages/backend/src/server/ServerService.ts index 23c085ee27..00e1ae3c49 100644 --- a/packages/backend/src/server/ServerService.ts +++ b/packages/backend/src/server/ServerService.ts @@ -305,8 +305,11 @@ export class ServerService implements OnApplicationShutdown { @bindThis public async dispose(): Promise { + console.log('Disposing ServerService...'); await this.streamingApiServerService.detach(); + this.logger.info('Streaming API server detached.'); await this.#fastify.close(); + this.logger.info('Fastify server closed.'); } /** diff --git a/packages/backend/src/server/api/StreamingApiServerService.ts b/packages/backend/src/server/api/StreamingApiServerService.ts index 2a4e1fc574..7c80f015b1 100644 --- a/packages/backend/src/server/api/StreamingApiServerService.ts +++ b/packages/backend/src/server/api/StreamingApiServerService.ts @@ -174,9 +174,11 @@ export class StreamingApiServerService { if (this.#cleanConnectionsIntervalId) { clearInterval(this.#cleanConnectionsIntervalId); this.#cleanConnectionsIntervalId = null; + console.log('Clean connections interval cleared.'); } return new Promise((resolve) => { this.#wss.close(() => resolve()); + console.log('WebSocket server closed.'); }); } }