add timeout to new() #9

Author: drinking-code

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ipos",
-  "version": "0.2.5",
+  "version": "0.2.6",
   "description": "Share objects across different Node.js processes. Write and read on both sides.",
   "license": "MIT",
   "main": "lib/main.js",

src/__test__/initialize.test.ts

@@ -80,4 +80,8 @@ describe('Initialising IPOS', () => {
 
         sub_process.destroy()
     })
+
+    it('Connect subprocess without main process', async () => {
+        await expect(IPOS.new({syncTimeout: 200})).resolves.not.toThrow()
+    })
 })

src/init-child.ts

@@ -1,8 +1,11 @@
 import IPOS from './main.js'
 
-export default function initChild(this: IPOS) {
+export default function initChild(this: IPOS, timeout: number) {
     let resolve: Function
-    const promise = new Promise(res => resolve = res)
+    const promise = new Promise((res, reject) => {
+        resolve = res
+        setTimeout(reject, timeout)
+    })
 
     // @ts-ignore Object is possibly 'undefined'
     this.messaging.listenForType('sync', message => {

src/main.ts

@@ -14,12 +14,13 @@ export default class IPOS {
 
     [field: string]: unknown;
 
-    static new(): IPOS | Promise<IPOS> {
+    static new(config?: { syncTimeout: number }): IPOS | Promise<IPOS> {
         const ipos = new IPOS()
         // was called on child process
         if (process.send) {
             return new Promise(async resolve => {
-                await initChild.call(ipos)
+                await initChild.call(ipos, config?.syncTimeout || 100)
+                    .catch(() => 0)
                 resolve(ipos)
             })
         }