add reset field tests

Author: drinking-code

src/__test__/createConnectedInstances.ts

@@ -0,0 +1,20 @@
+import subProcessIPCLoopback from './subProcessIPCLoopback'
+import IPOS from '../main'
+import {withoutProcessSendSync} from './withoutProcessSendSync'
+
+export default async function createConnectedInstances(): Promise<{ main_ipos: IPOS, sub_ipos: IPOS, sub_process: subProcessIPCLoopback }> {
+    const sub_process = new subProcessIPCLoopback()
+    let main_ipos: IPOS, sub_ipos: IPOS
+    await withoutProcessSendSync(() => {
+        main_ipos = IPOS.new() as IPOS
+    })
+
+    await Promise.all([
+        // @ts-ignore Argument of type 'subProcessIPCLoopback' is not assignable to parameter of type 'ChildProcess'
+        main_ipos.addProcess(sub_process),
+        (async () => sub_ipos = await IPOS.new())()
+    ])
+
+    // @ts-ignore Variable 'main_ipos', 'sub_ipos' is used before being assigned.
+    return {main_ipos, sub_ipos, sub_process}
+}

src/__test__/createFields.test.ts

@@ -1,35 +1,27 @@
 import IPOS from '../main'
 
-import subProcessIPCLoopback from './subProcessIPCLoopback'
-import {withoutProcessSendSync} from './withoutProcessSendSync'
 import createFieldsTest from './runCreateFieldsTest'
+import createConnectedInstances from './createConnectedInstances'
 
-async function initWith(setValue: (main_ipos: IPOS) => void, probeValue: (sub_ipos: IPOS) => void) {
-    const sub_process = new subProcessIPCLoopback()
-    let main_ipos: IPOS, sub_ipos: IPOS
-    await withoutProcessSendSync(() => {
-        main_ipos = IPOS.new() as IPOS
-    })
-
-    await Promise.all([
-        // @ts-ignore Argument of type 'subProcessIPCLoopback' is not assignable to parameter of type 'ChildProcess'
-        main_ipos.addProcess(sub_process),
-        (async () => sub_ipos = await IPOS.new())()
-    ])
+describe('Updating fields between processes (transferring newly created fields)', () =>
+    createFieldsTest(
+        async (setValue: (main_ipos: IPOS) => void, probeValue: (sub_ipos: IPOS) => void) => {
+            const {main_ipos, sub_ipos, sub_process} = await createConnectedInstances()
 
-    // @ts-ignore Variable 'main_ipos' is used before being assigned.
-    setValue(main_ipos)
+            // @ts-ignore Variable 'main_ipos' is used before being assigned.
+            setValue(main_ipos)
 
-    // @ts-ignore Variable 'sub_ipos' is used before being assigned.
-    probeValue(sub_ipos)
+            // make sure value is transmitted
+            await new Promise(res => setTimeout(res, 1))
 
-    sub_process.destroy()
-}
+            // @ts-ignore Variable 'sub_ipos' is used before being assigned.
+            probeValue(sub_ipos)
 
-describe('Updating fields between processes (transferring newly created fields)', () =>
-    createFieldsTest(initWith, (key) =>
-        ['a', 'e', 'i', 'o', 'u'].some(vowel => key.startsWith(vowel))
-            ? `Create an ${key}`
-            : `Create a ${key}`
+            sub_process.destroy()
+        },
+        (key) =>
+            ['a', 'e', 'i', 'o', 'u'].some(vowel => key.startsWith(vowel))
+                ? `Create an ${key}`
+                : `Create a ${key}`
     )
 )

src/__test__/resetFields.test.ts

@@ -0,0 +1,20 @@
+import IPOS from '../main'
+
+import createFieldsTest from './runCreateFieldsTest'
+import createConnectedInstances from './createConnectedInstances'
+
+describe('Updating fields between processes (transferring newly created fields)', () =>
+    createFieldsTest(
+        async (setValue: (main_ipos: IPOS, reset: boolean) => void, probeValue: (sub_ipos: IPOS) => void) => {
+            const {main_ipos, sub_ipos, sub_process} = await createConnectedInstances()
+
+            main_ipos.create('myField', 'myValue')
+            setValue(main_ipos, true)
+
+            probeValue(sub_ipos)
+
+            sub_process.destroy()
+        },
+        (key) => `Reset ${key}`
+    )
+)

src/__test__/runCreateFieldsTest.ts

@@ -3,7 +3,7 @@ import IPOS from '../main'
 import {examples} from './testData'
 
 export default function createFieldsTest(
-    initWith: (setValue: (main_ipos: IPOS) => void, probeValue: (sub_ipos: IPOS) => void) => void,
+    initWith: (setValue: (main_ipos: IPOS, reset?: boolean) => void, probeValue: (sub_ipos: IPOS) => void) => void,
     createLabel: (key: string) => string
 ) {
     function customizer(a: any, b: any) {
@@ -18,8 +18,12 @@ export default function createFieldsTest(
         it(createLabel(exampleKey), async () => {
             const value: unknown = examples[exampleKey]
             await initWith(
-                (main_ipos) => {
-                    main_ipos.create('myField', value)
+                (main_ipos, reset = false) => {
+                    if (!reset) {
+                        main_ipos.create('myField', value)
+                    } else {
+                        main_ipos.myField = value
+                    }
                 },
                 (sub_ipos) => {
                     // lodash equal to compare maps and sets

src/__test__/synchronize.test.ts

@@ -4,26 +4,26 @@ import subProcessIPCLoopback from './subProcessIPCLoopback'
 import {withoutProcessSendSync} from './withoutProcessSendSync'
 import createFieldsTest from './runCreateFieldsTest'
 
-async function initWith(setValue: (main_ipos: IPOS) => void, probeValue: (sub_ipos: IPOS) => void) {
-    const sub_process = new subProcessIPCLoopback()
-    let main_ipos: IPOS, sub_ipos: IPOS
-    await withoutProcessSendSync(() => {
-        main_ipos = IPOS.new() as IPOS
-        setValue(main_ipos)
-    })
-
-    await Promise.all([
-        // @ts-ignore Argument of type 'subProcessIPCLoopback' is not assignable to parameter of type 'ChildProcess'
-        main_ipos.addProcess(sub_process),
-        (async () => sub_ipos = await IPOS.new())()
-    ])
+describe('Synchronisation of fields between processes (transferring existing fields)', () =>
+    createFieldsTest(
+        async (setValue: (main_ipos: IPOS) => void, probeValue: (sub_ipos: IPOS) => void) => {
+            const sub_process = new subProcessIPCLoopback()
+            let main_ipos: IPOS, sub_ipos: IPOS
+            await withoutProcessSendSync(() => {
+                main_ipos = IPOS.new() as IPOS
+                setValue(main_ipos)
+            })
 
-    // @ts-ignore Variable 'sub_ipos' is used before being assigned.
-    probeValue(sub_ipos)
+            await Promise.all([
+                // @ts-ignore Argument of type 'subProcessIPCLoopback' is not assignable to parameter of type 'ChildProcess'
+                main_ipos.addProcess(sub_process),
+                (async () => sub_ipos = await IPOS.new())()
+            ])
 
-    sub_process.destroy()
-}
+            // @ts-ignore Variable 'sub_ipos' is used before being assigned.
+            probeValue(sub_ipos)
 
-describe('Synchronisation of fields between processes (transferring existing fields)', () =>
-    createFieldsTest(initWith, (key) => `Synchronise ${key}`)
+            sub_process.destroy()
+        },
+        (key) => `Synchronise ${key}`)
 )

src/intercept.ts

@@ -1,4 +1,4 @@
-export default function intercept(value: object, key: string, interceptCallback: (key: string, method: string, ...args: any) => void): object {
+export default function intercept<V>(value: V, key: string, interceptCallback: (key: string, method: string, ...args: any) => void): V {
     const arrayMutatingMethods = ['copyWithin', 'fill', 'pop', 'push', 'reverse', 'shift', 'sort', 'splice', 'unshift']
     const objectMutatingMethods: string[] = []
     const mapMutatingMethods = ['clear', 'delete', 'set']
@@ -11,8 +11,9 @@ export default function intercept(value: object, key: string, interceptCallback:
     mutatingMethods.set(Set, setMutatingMethods)
     mutatingMethods.set(Function, functionMutatingMethods)
 
-    if (!mutatingMethods.has(value.constructor))
+    if (!value || typeof value !== 'object' || !mutatingMethods.has(value.constructor))
         return value
+
     return new Proxy(value, {
         get(target, name: string) {
             if (Reflect.has(target, name) && mutatingMethods.get(value.constructor).includes(name)) {

src/main.ts

@@ -4,12 +4,13 @@ import IPOSMessaging, {iposMessagingMessage, iposMessagingType} from './messagin
 import intercept from './intercept.js'
 
 export default class IPOS {
-    private readonly fields: Map<string, ProxyHandler<any>>
+    private readonly fields: Map<string, any>
     private readonly fieldsRaw: Map<string, any>
-    private fieldsReverseMap: Map<ProxyHandler<any>, string>
+    private fieldsReverseMap: Map<any, string>
     private processMessagingMap: Map<ChildProcess, IPOSMessaging>
     private readonly proxy
     protected messaging?: IPOSMessaging
+
     [field: string]: unknown;
 
     static new(): IPOS | Promise<IPOS> {