summary refs log tree commit diff
path: root/src/util
diff options
context:
space:
mode:
authorRory& <root@rory.gay>2026-03-14 03:26:26 +0100
committerRory& <root@rory.gay>2026-03-14 03:26:26 +0100
commitb5e63c06b684e00f63c70e3e8347e9c49da6c02e (patch)
tree9d79d2f3fba3af08846b2286e6bb3e149aabca2c /src/util
parentUpdate nix locks for nuget deps (diff)
downloadserver-ts-b5e63c06b684e00f63c70e3e8347e9c49da6c02e.tar.xz
Qodana: fix async warnings
Diffstat (limited to 'src/util')
-rw-r--r--src/util/connections/ConnectionLoader.ts6
-rw-r--r--src/util/util/RabbitMQ.ts2
2 files changed, 4 insertions, 4 deletions
diff --git a/src/util/connections/ConnectionLoader.ts b/src/util/connections/ConnectionLoader.ts

index 609c53b0..f75b430f 100644 --- a/src/util/connections/ConnectionLoader.ts +++ b/src/util/connections/ConnectionLoader.ts
@@ -28,7 +28,7 @@ const connectionsLoaded = false; export class ConnectionLoader { public static async loadConnections() { if (connectionsLoaded) return; - ConnectionConfig.init(); + await ConnectionConfig.init(); const dirs = fs.readdirSync(root).filter((x) => { try { fs.readdirSync(path.join(root, x)); @@ -38,7 +38,7 @@ export class ConnectionLoader { } }); - dirs.forEach(async (x) => { + dirs.forEach((x) => { const modPath = path.resolve(path.join(root, x)); const mod = new (require(modPath).default)() as Connection; ConnectionStore.connections.set(mod.id, mod); @@ -54,7 +54,7 @@ export class ConnectionLoader { if (cfg) cfg = Object.assign({}, defaults, cfg); else { cfg = defaults; - this.setConnectionConfig(id, cfg); + this.setConnectionConfig(id, cfg).catch((e) => console.error(`[Connections/ERROR] Failed to set default config for '${id}'!`, e)); } } diff --git a/src/util/util/RabbitMQ.ts b/src/util/util/RabbitMQ.ts
index 288a7fa9..7969bb8b 100644 --- a/src/util/util/RabbitMQ.ts +++ b/src/util/util/RabbitMQ.ts
@@ -102,7 +102,7 @@ export class RabbitMQ { this.events.emit("disconnected"); // Schedule reconnection - this.scheduleReconnect(host); + this.scheduleReconnect(host).catch((e) => console.error("[RabbitMQ] Failed to schedule reconnection:", e)); }); }