add updating field values

Author: drinking-code

example/main-process.js

@@ -9,7 +9,7 @@ const subProcess = child_process.spawn('node', ['sub-process.js'], {
     stdio: ['inherit', 'inherit', 'inherit', 'ipc']
 })
 
-sharedObject.addProcess(subProcess)
+await sharedObject.addProcess(subProcess)
 sharedObject.create('exampleObject', {})
 sharedObject.exampleObject.from = 'the other side'
 

src/init-child.ts

@@ -6,21 +6,22 @@ export default function initChild(this: IPOS) {
     const promise = new Promise(res => resolve = res)
 
     this.messaging = new IPOSMessaging(process)
-    this.messaging?.listenForType('sync', message => {
+    this.messaging.listenForType('sync', message => {
         if (!message.fields) return
         Object.entries(
             IPOS.deserialize(JSON.parse(message.fields))
         )
             .map(([key, value]: [string, any]) => {
-                this.create(key, value.constructor())
-                if (Array.isArray(value)) {
-                    this.get(key)?.push(...value)
-                }
+                this.createStealthy(key, value)
             })
         resolve()
     })
     // register with parent process
     this.messaging.send('register')
+    this.messaging.listenForType('update', message => {
+        if (!message.do || !message.on) return
+        this.get(message.on)[message.do](...(message.with ?? []))
+    })
 
     return promise
 }

src/intercept.ts

@@ -2,7 +2,7 @@ import InterceptedArray from './intercept/array.js'
 
 export default function intercept(value: object, interceptCallback: (object: object, method: string, ...args: any) => void): object {
     if (Array.isArray(value)) {
-        value = new InterceptedArray(interceptCallback)
+        value = InterceptedArray.new(value, interceptCallback)
     }
     /*Object.getOwnPropertyNames(Object.getPrototypeOf(value))
         .filter(methodName => !(methodName.startsWith('__') && methodName.endsWith('__')))

src/intercept/array.ts

@@ -7,6 +7,15 @@ export default class InterceptedArray<T> extends Array {
         this.callback = callback
     }
 
+    static new<T>(arrayLike: ArrayLike<T>, callback: (object: object, method: string, ...args: any) => void): InterceptedArray<T> {
+        const interceptedArray: InterceptedArray<T> =
+            new InterceptedArray(callback)
+        for (let i = 0; i < arrayLike.length; i++) {
+            interceptedArray[i] = arrayLike[i]
+        }
+        return interceptedArray
+    }
+
     copyWithin(target: number, start: number, end?: number): this {
         this.callback(this, 'copyWithin', target, start, end)
         return super.copyWithin(target, start, end)

src/main.ts

@@ -45,8 +45,13 @@ export default class IPOS {
         return this.fields.get(key)
     }
 
-    // todo: also accept and update non object values
+    // todo: also accept and update non-object values
     public create(key: string, value: object): void {
+        this.createStealthy(key, value)
+        // todo: send update message
+    }
+
+    protected createStealthy(key: string, value: object): void {
         // console.log('create', key)
         if (typeof value === 'object')
             value = intercept(value, (object, method, ...args) =>
@@ -63,19 +68,22 @@ export default class IPOS {
         // todo: send update message
     }
 
-    public addProcess(process: ChildProcess) {
+    public addProcess(process: ChildProcess): Promise<void> {
         if (!process.send)
             throw new Error(`Process must have an ipc channel. Activate by passing "stdio: [<stdin>, <stdout>, <stderr>, 'ipc']" as an option.`)
         const messaging = new IPOSMessaging(process)
 
-        let registered = false
+        let registered = false, resolve: Function
+        const promise: Promise<void> = new Promise(res => resolve = res)
         messaging.listenForType('register', () => {
             if (registered) return
             registered = true
 
             this.processMessagingMap.set(process, messaging)
             this.syncProcess(process)
+            resolve()
         })
+        return promise
     }
 
     private syncProcess(process: ChildProcess) {

src/messaging.ts

@@ -5,7 +5,10 @@ type iposMessagingCallback = (message: iposMessagingMessage) => (any | void)
 type iposMessagingMessage = {
     protocol: 'ipos',
     type: iposMessagingType,
-    fields?: string
+    fields?: string,
+    do?: string,
+    on?: string,
+    with?: Array<any>,
 }
 
 const mustHaveSendError = new Error(`Process must have a \`.send()\` method.`)