add tests for errors

Author: drinking-code

src/__test__/createConnectedInstances.ts

@@ -1,11 +1,11 @@
-import subProcessIPCLoopback from './subProcessIPCLoopback'
+import SubProcessIPCLoopback from './subProcessIPCLoopback'
 import IPOS from '../main'
 import {withoutProcessSend} from './withoutProcessSend'
 
-export default async function createConnectedInstances(): Promise<{ main_ipos: IPOS, sub_ipos: IPOS, sub_process: subProcessIPCLoopback }> {
-    const sub_process = new subProcessIPCLoopback()
+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 withoutProcessSend(() => {
+    withoutProcessSend(() => {
         main_ipos = IPOS.new() as IPOS
     })
 

src/__test__/error.test.ts

@@ -0,0 +1,82 @@
+import child_process from 'child_process'
+
+import IPOS from '../main'
+import {withoutProcessSend} from './withoutProcessSend'
+import IPOSMessaging from '../messaging'
+import createConnectedInstances from "./createConnectedInstances";
+import {examples} from "./testData";
+
+describe('Probing errors', () => {
+    it('Changing inherent property', () => {
+        let ipos: IPOS
+        withoutProcessSend(() => ipos = IPOS.new() as IPOS)
+        expect(() => ipos.get = (key) => 'myValue').toThrow()
+    })
+
+    it('Set uncreated field', () => {
+        let ipos: IPOS
+        withoutProcessSend(() => ipos = IPOS.new() as IPOS)
+        expect(() => ipos.myKey = 'myValue').toThrow()
+    })
+
+    it('Add process without ipc channel', () => {
+        withoutProcessSend(() => {
+            const ipos = IPOS.new() as IPOS
+            const sub_process = child_process.spawn('node', ['../../example/sub-process.js'])
+            expect(() => ipos.addProcess(sub_process)).toThrow()
+        })
+    })
+
+    it('Create IPOSMessaging instance with process without ipc channel', () => {
+        withoutProcessSend(() => {
+            expect(() => new IPOSMessaging(process)).toThrow()
+        })
+    })
+
+    it('Serialise unknown native object', async () => {
+        const {main_ipos} = await createConnectedInstances()
+        const buffer = new ArrayBuffer(2)
+        expect(() => main_ipos.create('myKey', new DataView(buffer))).toThrow()
+    })
+
+    it('Serialise unregistered class', async () => {
+        const {main_ipos, sub_ipos, sub_process} = await createConnectedInstances()
+
+        class Unregistered {
+        }
+
+        const unregisteredInstance = new Unregistered()
+        expect(() => main_ipos.create('myKey', unregisteredInstance))
+            .toThrowError(`Class: \`${unregisteredInstance.constructor.name}\` must have methods to serialize and deserialize objects. (\`.stringify()\`, \`.serialize()\`)`)
+    })
+
+    it('Deserialise unregistered class', async () => {
+        const {main_ipos, sub_ipos, sub_process} = await createConnectedInstances()
+
+        class Unregistered {
+            serialize() {
+                return 'unregisteredClass'
+            }
+        }
+
+        const unregisteredInstance = new Unregistered()
+        expect(() => main_ipos.create('myKey', unregisteredInstance))
+            .toThrowError(`Did not recognize type \`${unregisteredInstance.constructor.name}\`. Did you register it in the child process?`)
+    })
+
+    it('Deserialise registered class without deserialisation method', async () => {
+        const {main_ipos, sub_ipos, sub_process} = await createConnectedInstances()
+
+        class Registered {
+            serialize() {
+                return 'unregisteredClass'
+            }
+        }
+
+        IPOS.registerClass(Registered)
+
+        const registeredInstance = new Registered()
+        expect(() => main_ipos.create('myKey', registeredInstance))
+            .toThrowError(`Did not recognize type \`${registeredInstance.constructor.name}\`. Did you register it in the child process?`)
+    })
+})

src/__test__/initialize.test.ts

@@ -1,5 +1,5 @@
 import IPOS from '../main'
-import subProcessIPCLoopback from './subProcessIPCLoopback'
+import SubProcessIPCLoopback from './subProcessIPCLoopback'
 import {withoutProcessSend} from './withoutProcessSend'
 
 describe('Initialising IPOS', () => {
@@ -29,7 +29,7 @@ describe('Initialising IPOS', () => {
      */
 
     it('Connect subprocess after it has initialised', async () => {
-        const sub_process = new subProcessIPCLoopback()
+        const sub_process = new SubProcessIPCLoopback()
 
         const sub_ipos: Promise<IPOS> = IPOS.new() as Promise<IPOS>
         let main_ipos: IPOS
@@ -55,7 +55,7 @@ describe('Initialising IPOS', () => {
     })
 
     it('Connect subprocess before it has initialised', async () => {
-        const sub_process = new subProcessIPCLoopback()
+        const sub_process = new SubProcessIPCLoopback()
 
         let main_ipos: IPOS
         withoutProcessSend(() => {

src/__test__/subProcessIPCLoopback.ts

@@ -1,4 +1,4 @@
-export default class subProcessIPCLoopback {
+export default class SubProcessIPCLoopback {
     private readonly originalProcessSend;
     private readonly originalProcessOn;
     private subProcessListener?: NodeJS.MessageListener;

src/__test__/synchronize.test.ts

@@ -1,15 +1,15 @@
 import IPOS from '../main'
 
-import subProcessIPCLoopback from './subProcessIPCLoopback'
+import SubProcessIPCLoopback from './subProcessIPCLoopback'
 import {withoutProcessSend} from './withoutProcessSend'
 import createFieldsTest from './runCreateFieldsTest'
 
 describe('Synchronising fields', () =>
     createFieldsTest(
         async (setValue: (ipos_for_setting: IPOS) => void, probeValue: (ipos_for_probing: IPOS) => void) => {
-            const sub_process = new subProcessIPCLoopback()
+            const sub_process = new SubProcessIPCLoopback()
             let main_ipos: IPOS, sub_ipos: IPOS
-            await withoutProcessSend(() => {
+            withoutProcessSend(() => {
                 main_ipos = IPOS.new() as IPOS
                 setValue(main_ipos)
             })

src/main.ts

@@ -186,9 +186,8 @@ export default class IPOS {
     private syncProcess(process: ChildProcess): Promise<void> {
         let resolve: Function
         const promise: Promise<void> = new Promise(res => resolve = res)
-        this.processMessagingMap.get(process)?.listenOnceForType('sync_ok', () => {
-            resolve()
-        })
+        this.processMessagingMap.get(process)
+            ?.listenOnceForType('sync_ok', () => resolve())
         this.processMessagingMap.get(process)?.send('sync', {fields: this.fields})
         return promise
     }