diff --git a/src/util/util/extensions/Array.ts b/src/util/util/extensions/Array.ts index e3e6478c2..c95328b5a 100644 --- a/src/util/util/extensions/Array.ts +++ b/src/util/util/extensions/Array.ts @@ -74,3 +74,9 @@ export function arrayDistributeSequentially(array: T[], count: number): T[][] 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 e836c269e..af7c832df 100644 --- a/src/util/util/ipc/Event.ts +++ b/src/util/util/ipc/Event.ts @@ -125,7 +125,7 @@ export async function listenEvent(event: string, callback: (event: EventOpts) => } 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 274b8ae12..03f58ab78 100644 --- a/src/util/util/ipc/listener/UnixSocketListener.ts +++ b/src/util/util/ipc/listener/UnixSocketListener.ts @@ -35,7 +35,6 @@ export class UnixSocketListener extends BaseEventListener { isInitialized = false; openConnectionsMetric: Gauge.Internal; openListenersMetric: Gauge.Internal; - isInitialized = false; constructor(socketPath: string) { super(); @@ -101,12 +100,12 @@ export class UnixSocketListener extends BaseEventListener { }); 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());