add synchronisation tests

Author: drinking-code

package-lock.json

@@ -24,8 +24,10 @@
   },
   "devDependencies": {
     "@types/jest": "^29.0.3",
+    "@types/lodash": "^4.14.185",
     "@types/node": "^18.7.18",
     "jest": "^29.0.3",
+    "lodash": "^4.17.21",
     "typescript": "^4.8.3"
   },
   "jest": {

package.json

@@ -30,9 +30,9 @@ describe('Initialising IPOS', () => {
 
     it('Connect subprocess after it has initialised', async () => {
         const sub_process = new subProcessIPCLoopback()
-        let sub_ipos: Promise<IPOS> = IPOS.new() as Promise<IPOS>,
-            main_ipos: IPOS
 
+        const sub_ipos: Promise<IPOS> = IPOS.new() as Promise<IPOS>
+        let main_ipos: IPOS
         withoutProcessSendSync(() => {
             main_ipos = IPOS.new() as IPOS
         })
@@ -48,22 +48,36 @@ describe('Initialising IPOS', () => {
 
         await Promise.all([
             expect(addProcessPromise).resolves,
-            await expect(sub_ipos).resolves.toBeInstanceOf(IPOS)
+            expect(sub_ipos).resolves.toBeInstanceOf(IPOS)
         ])
+
         sub_process.destroy()
     })
 
-    /*it('Connect subprocess before it has initialised', async () => {
+    it('Connect subprocess before it has initialised', async () => {
         const sub_process = new subProcessIPCLoopback()
+
+        let main_ipos: IPOS
         withoutProcessSendSync(() => {
-            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)
+            main_ipos = IPOS.new() as IPOS
         })
+
+        let addProcessPromise
+        expect(() =>
+            // @ts-ignore Argument of type 'subProcessIPCLoopback' is not assignable to parameter of type 'ChildProcess'
+            addProcessPromise = main_ipos.addProcess(sub_process)
+        ).not.toThrow()
+
         const sub_ipos = IPOS.new()
-        expect(sub_ipos).resolves.toBeInstanceOf(IPOS)
+
+        expect(addProcessPromise).toBeInstanceOf(Promise)
+        expect(sub_ipos).toBeInstanceOf(Promise)
+
+        await Promise.all([
+            expect(addProcessPromise).resolves,
+            expect(sub_ipos).resolves.toBeInstanceOf(IPOS)
+        ])
+
         sub_process.destroy()
-    })*/
+    })
 })

src/__test__/initialize.test.ts

@@ -1,30 +1,31 @@
+import _ from 'lodash'
+
 import IPOS from '../main'
+
 import subProcessIPCLoopback from './subProcessIPCLoopback'
-import {withoutProcessSend} from './withoutProcessSendSync'
+import {withoutProcessSend, withoutProcessSendSync} from './withoutProcessSendSync'
 
 async function initWith(setValue: (main_ipos: IPOS) => void, probeValue: (sub_ipos: IPOS) => void) {
     const sub_process = new subProcessIPCLoopback()
-    let main_ipos: IPOS
-    await withoutProcessSend(async () => {
+    let main_ipos: IPOS, sub_ipos: IPOS
+    await withoutProcessSendSync(() => {
         main_ipos = IPOS.new() as IPOS
         setValue(main_ipos)
     })
-    console.log('sub_ipos')
-    let sub_ipos = IPOS.new()
-    console.log('withoutProcessSend')
-    await withoutProcessSend(async () => {
-        console.log('main_ipos.addProcess')
+
+    await Promise.all([
         // @ts-ignore Argument of type 'subProcessIPCLoopback' is not assignable to parameter of type 'ChildProcess'
-        await main_ipos.addProcess(sub_process)
-        console.log('done main_ipos.addProcess')
-    })
-    console.log('await sub_ipos')
-    sub_ipos = await sub_ipos
+        main_ipos.addProcess(sub_process),
+        (async () => sub_ipos = await IPOS.new())()
+    ])
+
+    // @ts-ignore Variable 'sub_ipos' is used before being assigned.
     probeValue(sub_ipos)
+
     sub_process.destroy()
 }
 
-/*describe('Synchronising fields between processes', () => {
+describe('Synchronisation of fields between processes (transferring existing fields)', () => {
     const examples: { [key: string]: unknown } = {
         'string': 'myString',
         'number': 42,
@@ -33,7 +34,19 @@ async function initWith(setValue: (main_ipos: IPOS) => void, probeValue: (sub_ip
             mySecondValue: 42
         },
         'array': ['myItem', 42],
+        'map': new Map(Object.entries({
+            myKey: 'myValue',
+            mySecondValue: 42
+        })),
         'set': new Set(['myItem', 42]),
+        'function': (a: number, b: number) => a + b,
+    }
+
+    function customizer(a: any, b: any) {
+        // compare function contents
+        if ([typeof a, typeof b].every(a => a === 'function')) {
+            return a.toString() === b.toString();
+        }
     }
 
     for (const exampleKey in examples) {
@@ -45,12 +58,11 @@ async function initWith(setValue: (main_ipos: IPOS) => void, probeValue: (sub_ip
                     main_ipos.create('myField', value)
                 },
                 (sub_ipos) => {
-                    console.log(value)
-                    console.log(sub_ipos.myField)
-                    // expect(sub_ipos.get('myField')).toEqual(value)
-                    // expect(sub_ipos.myField).toEqual(value)
+                    // lodash equal to compare maps and sets
+                    expect(_.isEqualWith(sub_ipos.myField, value, customizer)).toEqual(true)
+                    expect(_.isEqualWith(sub_ipos.get('myField'), value, customizer)).toEqual(true)
                 }
             )
         })
     }
-})*/
+})