add tests for creating and resetting fields in the subprocess #1

Author: drinking-code

.npmignore

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

src/__test__/createFields.test.ts

@@ -3,9 +3,9 @@ import IPOS from '../main'
 import createFieldsTest from './runCreateFieldsTest'
 import createConnectedInstances from './createConnectedInstances'
 
-describe('Updating fields between processes (transferring newly created fields)', () =>
+describe('Creating fields in the main process', () =>
     createFieldsTest(
-        async (setValue: (main_ipos: IPOS) => void, probeValue: (sub_ipos: IPOS) => void) => {
+        async (setValue: (ipos_for_setting: IPOS) => void, probeValue: (ipos_for_probing: IPOS) => void) => {
             const {main_ipos, sub_ipos, sub_process} = await createConnectedInstances()
 
             // @ts-ignore Variable 'main_ipos' is used before being assigned.
@@ -25,3 +25,26 @@ describe('Updating fields between processes (transferring newly created fields)'
                 : `Create a ${key}`
     )
 )
+
+describe('Creating fields in the subprocess', () =>
+    createFieldsTest(
+        async (setValue: (ipos_for_setting: IPOS) => void, probeValue: (ipos_for_probing: IPOS) => void) => {
+            const {main_ipos, sub_ipos, sub_process} = await createConnectedInstances()
+
+            // @ts-ignore Variable 'main_ipos' is used before being assigned.
+            setValue(sub_ipos)
+
+            // make sure value is transmitted
+            await new Promise(res => setTimeout(res, 1))
+
+            // @ts-ignore Variable 'sub_ipos' is used before being assigned.
+            probeValue(main_ipos)
+
+            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

@@ -3,9 +3,9 @@ import IPOS from '../main'
 import createFieldsTest from './runCreateFieldsTest'
 import createConnectedInstances from './createConnectedInstances'
 
-describe('Updating fields between processes (transferring newly created fields)', () =>
+describe('Resetting fields in the main process', () =>
     createFieldsTest(
-        async (setValue: (main_ipos: IPOS, reset: boolean) => void, probeValue: (sub_ipos: IPOS) => void) => {
+        async (setValue: (ipos_for_setting: IPOS, reset: boolean) => void, probeValue: (ipos_for_probing: IPOS) => void) => {
             const {main_ipos, sub_ipos, sub_process} = await createConnectedInstances()
 
             main_ipos.create('myField', 'myValue')
@@ -18,3 +18,19 @@ describe('Updating fields between processes (transferring newly created fields)'
         (key) => `Reset ${key}`
     )
 )
+
+describe('Resetting fields in the sub process', () =>
+    createFieldsTest(
+        async (setValue: (ipos_for_setting: IPOS, reset: boolean) => void, probeValue: (ipos_for_probing: IPOS) => void) => {
+            const {main_ipos, sub_ipos, sub_process} = await createConnectedInstances()
+
+            main_ipos.create('myField', 'myValue')
+            setValue(sub_ipos, true)
+
+            probeValue(main_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, reset?: boolean) => void, probeValue: (sub_ipos: IPOS) => void) => void,
+    initWith: (setValue: (ipos_for_setting: IPOS, reset?: boolean) => void, probeValue: (ipos_for_probing: IPOS) => void) => void,
     createLabel: (key: string) => string
 ) {
     function customizer(a: any, b: any) {
@@ -18,17 +18,17 @@ export default function createFieldsTest(
         it(createLabel(exampleKey), async () => {
             const value: unknown = examples[exampleKey]
             await initWith(
-                (main_ipos, reset = false) => {
+                (ipos_for_setting, reset = false) => {
                     if (!reset) {
-                        main_ipos.create('myField', value)
+                        ipos_for_setting.create('myField', value)
                     } else {
-                        main_ipos.myField = value
+                        ipos_for_setting.myField = value
                     }
                 },
-                (sub_ipos) => {
+                (ipos_for_probing) => {
                     // 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)
+                    expect(_.isEqualWith(ipos_for_probing.myField, value, customizer)).toEqual(true)
+                    expect(_.isEqualWith(ipos_for_probing.get('myField'), value, customizer)).toEqual(true)
                 }
             )
         })

src/__test__/synchronize.test.ts

@@ -4,9 +4,9 @@ import subProcessIPCLoopback from './subProcessIPCLoopback'
 import {withoutProcessSendSync} from './withoutProcessSendSync'
 import createFieldsTest from './runCreateFieldsTest'
 
-describe('Synchronisation of fields between processes (transferring existing fields)', () =>
+describe('Synchronising fields', () =>
     createFieldsTest(
-        async (setValue: (main_ipos: IPOS) => void, probeValue: (sub_ipos: IPOS) => void) => {
+        async (setValue: (ipos_for_setting: IPOS) => void, probeValue: (ipos_for_probing: IPOS) => void) => {
             const sub_process = new subProcessIPCLoopback()
             let main_ipos: IPOS, sub_ipos: IPOS
             await withoutProcessSendSync(() => {