diff --git a/src/util/util/extensions/Array.ts b/src/util/util/extensions/Array.ts index e3e6478..c95328b 100644 --- a/src/util/util/extensions/Array.ts +++ b/src/util/util/extensions/Array.ts @@ -74,3 +74,9 @@ return groups; } + +//region Numerics +export function arraySum(array: number[]) { + return array.reduce((prev, curr) => prev + curr, 0); +} +//endregion diff --git a/src/util/util/ipc/Event.ts b/src/util/util/ipc/Event.ts index e836c26..af7c832 100644 --- a/src/util/util/ipc/Event.ts +++ b/src/util/util/ipc/Event.ts @@ -125,7 +125,7 @@ } if (!listener) { - listener = listener = new UnixSocketListener(path.join(process.env.EVENT_SOCKET_PATH, `${process.pid}.sock`)); + listener = new UnixSocketListener(path.join(process.env.EVENT_SOCKET_PATH, `${process.pid}.sock`)); await listener.init(); } return await listener.listen(event, callback); diff --git a/src/util/util/ipc/listener/UnixSocketListener.ts b/src/util/util/ipc/listener/UnixSocketListener.ts index 274b8ae..03f58ab 100644 --- a/src/util/util/ipc/listener/UnixSocketListener.ts +++ b/src/util/util/ipc/listener/UnixSocketListener.ts @@ -35,7 +35,6 @@ isInitialized = false; openConnectionsMetric: Gauge.Internal; openListenersMetric: Gauge.Internal; - isInitialized = false; constructor(socketPath: string) { super(); @@ -101,12 +100,12 @@ }); socket.on("close", () => { console.log("[UnixSocketListener] Unix socket client disconnected"); - this.openConnectionsMetric.set(this.server.connections ?? 0); + this.openConnectionsMetric.set(this.server.connections); }); }); this.server.listen(this.socketPath, () => { - console.log(`[UnixSocketListener] listening on ${this.socketPath}`); + console.log(`[UnixSocketListener] Listening on ${this.socketPath}`); }); ProcessLifecycle.eventEmitter.on("stopped", async () => await this.close());