fix: handle errors correctly

Co-authored-by: KagChi <[email protected]> Co-authored-by: Vann <[email protected]>
NezuChan · Feb 20, 2024 · 2d99ee4 · 2d99ee4
1 parent c12d2ec
commit 2d99ee4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/services/kanao-gateway/src/Utilities/WebSockets/ProcessBootstrapper.ts b/services/kanao-gateway/src/Utilities/WebSockets/ProcessBootstrapper.ts
@@ -50,6 +50,7 @@ export class ProcessBootstrapper {
      * Bootstraps the child process with the provided options
      */
     public async bootstrap(options: Readonly<BootstrapOptions> = {}): Promise<void> {
+        this.pgClient.on("error", e => this.logger.error(e, "Postgres emitted error"));
         await this.pgClient.connect();
         this.setupAmqp(); await this.stores.load();
 

diff --git a/services/kanao-gateway/src/Utilities/WebSockets/ProcessShardingStrategy.ts b/services/kanao-gateway/src/Utilities/WebSockets/ProcessShardingStrategy.ts
@@ -218,6 +218,7 @@ export class ProcessShardingStrategy implements IShardingStrategy {
                     setTimeout(async () => Result.fromAsync(() => worker.send(payload)), 2_000);
                 }
             }
+            worker.on("error", error => this.logger.error({ error, shardIds: workerData.shardIds }, "process emitted error !"));
         }).catch(error => setTimeout(() => {
             this.logger.error(error, "Error when starting worker !");
             const worker = this.#workerByShardId.get(workerData.shardIds[0])!;