1 files changed, 28 insertions, 28 deletions

diff --git a/src/server/DashSession/Session/agents/promisified_ipc_manager.ts b/src/server/DashSession/Session/agents/promisified_ipc_manager.ts
index 76e218977..fc870d003 100644
--- a/src/server/DashSession/Session/agents/promisified_ipc_manager.ts
+++ b/src/server/DashSession/Session/agents/promisified_ipc_manager.ts
@@ -1,13 +1,14 @@
-import { Utilities } from '../utilities/utilities';
 import { ChildProcess } from 'child_process';
+import { Utilities } from '../utilities/utilities';
 
 /**
- * Convenience constructor
- * @param target the process / worker to which to attach the specialized listeners
+ * Specifies a general message format for this API
  */
-export function manage(target: IPCTarget, handlers?: HandlerMap) {
-    return new PromisifiedIPCManager(target, handlers);
-}
+export type Message<T = any> = {
+    name: string;
+    args?: T;
+};
+export type MessageHandler<T = any> = (args: T) => any | Promise<any>;
 
 /**
  * Captures the logic to execute upon receiving a message
@@ -22,15 +23,10 @@ export type HandlerMap = { [name: string]: MessageHandler[] };
  */
 export type IPCTarget = NodeJS.Process | ChildProcess;
 
-/**
- * Specifies a general message format for this API
- */
-export type Message<T = any> = {
-    name: string;
-    args?: T;
-};
-export type MessageHandler<T = any> = (args: T) => any | Promise<any>;
-
+interface Metadata {
+    isResponse: boolean;
+    id: string;
+}
 /**
  * When a message is emitted, it is embedded with private metadata
  * to facilitate the resolution of promises, etc.
@@ -38,10 +34,6 @@ export type MessageHandler<T = any> = (args: T) => any | Promise<any>;
 interface InternalMessage extends Message {
     metadata: Metadata;
 }
-interface Metadata {
-    isResponse: boolean;
-    id: string;
-}
 
 /**
  * Allows for the transmission of the error's key features over IPC.
@@ -95,11 +87,11 @@ export class PromisifiedIPCManager {
         }
         return new Promise<Response<T>>(resolve => {
             const messageId = Utilities.guid();
-            type InternalMessageHandler = (message: any /* MessageListener*/) => any | Promise<any>;
-            const responseHandler: InternalMessageHandler = ({ metadata: { id, isResponse }, args }) => {
+            type InternalMessageHandler = (message: any /* MessageListener */) => any | Promise<any>;
+            const responseHandler: InternalMessageHandler = ({ metadata: { id, isResponse }, args: hargs }) => {
                 if (isResponse && id === messageId) {
                     this.target.removeListener('message', responseHandler);
-                    resolve(args);
+                    resolve(hargs);
                 }
             };
             this.target.addListener('message', responseHandler);
@@ -118,8 +110,9 @@ export class PromisifiedIPCManager {
      * completion response for each of the pending messages, allowing their
      * promises in the caller to resolve.
      */
-    public destroy = () => {
-        return new Promise<void>(async resolve => {
+    public destroy = () =>
+        // eslint-disable-next-line no-async-promise-executor
+        new Promise<void>(async resolve => {
             if (this.callerIsTarget) {
                 this.destroyHelper();
             } else {
@@ -127,7 +120,6 @@ export class PromisifiedIPCManager {
             }
             resolve();
         });
-    };
 
     /**
      * Dispatches the dummy responses and sets the isDestroyed flag to true.
@@ -168,12 +160,20 @@ export class PromisifiedIPCManager {
                     error = e;
                 }
                 if (!this.isDestroyed && this.target.send) {
-                    const metadata = { id, isResponse: true };
+                    const metadataRes = { id, isResponse: true };
                     const response: Response = { results, error };
-                    const message = { name, args: response, metadata };
+                    const messageRes = { name, args: response, metadata: metadataRes };
                     delete this.pendingMessages[id];
-                    this.target.send(message);
+                    this.target.send(messageRes);
                 }
             }
         };
 }
+
+/**
+ * Convenience constructor
+ * @param target the process / worker to which to attach the specialized listeners
+ */
+export function manage(target: IPCTarget, handlers?: HandlerMap) {
+    return new PromisifiedIPCManager(target, handlers);
+}