diff options
author | Sam Wilkins <samwilkins333@gmail.com> | 2020-01-11 13:47:20 -0500 |
---|---|---|
committer | Sam Wilkins <samwilkins333@gmail.com> | 2020-01-11 13:47:20 -0500 |
commit | e5f1e28f44808b6f23ad6b43a72ce32b781b6562 (patch) | |
tree | c1474a97324ec7b28b0171aac10cca22b9a936fb /src | |
parent | 86f1e0f58940904b8c55284f6787e7422a6665ff (diff) |
rename
Diffstat (limited to 'src')
-rw-r--r-- | src/server/session/utilities/ipc.ts | 18 |
1 files changed, 8 insertions, 10 deletions
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<void>; export const suffix = isMaster ? Utils.GenerateGuid() : process.env.ipc_suffix; +type InternalMessage<T = any> = Message<T> & { metadata: any }; + export interface Message<T = any> { name: string; args: T; } -type InternalMessage<T = any> = Message<T> & { metadata: any }; + export type MessageHandler<T = any> = (message: T) => any | Promise<any>; 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 |