From e5f1e28f44808b6f23ad6b43a72ce32b781b6562 Mon Sep 17 00:00:00 2001 From: Sam Wilkins Date: Sat, 11 Jan 2020 13:47:20 -0500 Subject: rename --- src/server/session/utilities/ipc.ts | 18 ++++++++---------- 1 file changed, 8 insertions(+), 10 deletions(-) (limited to 'src') diff --git a/src/server/session/utilities/ipc.ts b/src/server/session/utilities/ipc.ts index db4c23180..c90b15907 100644 --- a/src/server/session/utilities/ipc.ts +++ b/src/server/session/utilities/ipc.ts @@ -1,16 +1,22 @@ import { isMaster } from "cluster"; import { Utils } from "../../../Utils"; +export function IPC(target: IPCTarget) { + return new PromisifiedIPCManager(target); +} + export type IPCTarget = NodeJS.EventEmitter & { send?: Function }; export type Router = (message: Message) => void | Promise; export const suffix = isMaster ? Utils.GenerateGuid() : process.env.ipc_suffix; +type InternalMessage = Message & { metadata: any }; + export interface Message { name: string; args: T; } -type InternalMessage = Message & { metadata: any }; + export type MessageHandler = (message: T) => any | Promise; export class PromisifiedIPCManager { @@ -51,18 +57,10 @@ export class PromisifiedIPCManager { } if (metadata && this.target.send) { metadata[this.is_response] = true; - this.target.send({ - name, - args: { error }, - metadata - }); + this.target.send({ name, args: { error }, metadata }); } } }); } -} - -export function IPC(target: IPCTarget) { - return new PromisifiedIPCManager(target); } \ No newline at end of file -- cgit v1.2.3-70-g09d2