add initialising tests #1

Author: drinking-code

.npmignore

@@ -1,5 +1,6 @@
 .idea/
 example
 src
+__test__
 tsconfig.json
 ipos-*.tgz

src/__test__/initialize.test.ts

@@ -0,0 +1,64 @@
+import IPOS from '../main'
+import subProcessIPCLoopback from './subProcessIPCLoopback'
+
+function withoutProcessSend(callback: Function) {
+    const processSend = process.send
+    process.send = undefined
+    callback()
+    process.send = processSend
+}
+
+describe('Initialising IPOS', () => {
+    it('Create new instance in a main process', () => {
+        // this is a subprocess anyway
+        // just simulate main process by setting process.send to undefined (jamming the subprocess detection)
+        withoutProcessSend(() => {
+            let ipos
+            expect(() => ipos = IPOS.new()).not.toThrow()
+            expect(ipos).toBeInstanceOf(IPOS)
+        })
+    })
+
+    it('Create new instance in a sub process', () => {
+        let ipos
+        expect(() => ipos = IPOS.new()).not.toThrow()
+        expect(ipos).toBeInstanceOf(Promise)
+        expect(ipos).resolves.toBeInstanceOf(IPOS)
+    })
+
+    /* The child IPOS doesn't actually have to be in the child process.
+     * Instead, the child process' ".on("message", handler)" and ".send()" are simulated.
+     * The main IPOS instance will send over the simulated "sub_process.send()",
+     * and listen over the simulated "sub_process.on("message", handler)".
+     * The child IPOS instance will send over the native (intercepted) "process.send()",
+     * and listen over the native (intercepted) "process.on("message", handler)".
+     */
+
+    it('Connect subprocess after it has initialised', async () => {
+        const sub_process = new subProcessIPCLoopback()
+        const sub_ipos = IPOS.new()
+        withoutProcessSend(() => {
+            const main_ipos = IPOS.new() as IPOS
+            let addProcessPromise
+            // @ts-ignore Argument of type 'subProcessIPCLoopback' is not assignable to parameter of type 'ChildProcess'
+            expect(() => addProcessPromise = main_ipos.addProcess(sub_process)).not.toThrow()
+            expect(addProcessPromise).toBeInstanceOf(Promise)
+        })
+        expect(sub_ipos).resolves.toBeInstanceOf(IPOS)
+        sub_process.destroy()
+    })
+
+    it('Connect subprocess before it has initialised', async () => {
+        const sub_process = new subProcessIPCLoopback()
+        withoutProcessSend(() => {
+            const main_ipos = IPOS.new() as IPOS
+            let addProcessPromise
+            // @ts-ignore Argument of type 'subProcessIPCLoopback' is not assignable to parameter of type 'ChildProcess'
+            expect(() => addProcessPromise = main_ipos.addProcess(sub_process)).not.toThrow()
+            expect(addProcessPromise).toBeInstanceOf(Promise)
+        })
+        const sub_ipos = IPOS.new()
+        expect(sub_ipos).resolves.toBeInstanceOf(IPOS)
+        sub_process.destroy()
+    })
+})

src/__test__/subProcessIPCLoopback.ts

@@ -0,0 +1,41 @@
+export default class subProcessIPCLoopback {
+    private originalProcessSend;
+    private readonly originalProcessOn;
+    private subProcessListener?: NodeJS.MessageListener;
+    private mainProcessListener?: NodeJS.MessageListener;
+
+    constructor() {
+        this.originalProcessSend = process.send
+        this.originalProcessOn = process.on
+        process.send = (message: any) => {
+            if (this.subProcessListener)
+                this.subProcessListener(message, this.send)
+            return true
+        }
+        process.on = (event: string, listener: (...args: any[]) => void) => {
+            if (event === 'message') {
+                this.mainProcessListener = listener
+                return process
+            } else {
+                return this.originalProcessOn(event, listener)
+            }
+        }
+    }
+
+    public send(message: any) {
+        if (this.mainProcessListener)
+            this.mainProcessListener(message, process.send)
+    }
+
+    public on(event: 'message', listener: NodeJS.MessageListener): this {
+        this.subProcessListener = listener
+        return this
+    }
+
+    public destroy() {
+        process.send = this.originalProcessSend
+        process.on = this.originalProcessOn
+        this.mainProcessListener = undefined
+        this.subProcessListener = undefined
+    }
+}

tsconfig.json

@@ -3,6 +3,7 @@
     "lib": ["ESNext"],
     "module": "esnext",
     "target": "esnext",
+    "moduleResolution": "node",
 
     "declaration": true,