make the example work fully

Author: drinking-code

example/main-process.js

@@ -12,5 +12,3 @@ const subProcess = child_process.spawn('node', ['sub-process.js'], {
 await sharedObject.addProcess(subProcess)
 sharedObject.create('exampleObject', {})
 sharedObject.exampleObject.from = 'the other side'
-
-console.log(sharedObject.exampleArray, sharedObject.exampleObject)

example/sub-process.js

@@ -1,7 +1,7 @@
 import IPOS from '../lib/main.js'
 
 const sharedObject = await IPOS.new()
-console.log('sharedObject.exampleArray', sharedObject.exampleArray)
+// wait for the main process to set the values for "exampleObject"
 setTimeout(() =>
-        console.log(sharedObject.exampleArray[0], /*...*/sharedObject.exampleObject/*.entries()*/),
+        console.log(sharedObject.exampleArray[0], ...Object.entries(sharedObject.exampleObject)[0]),
     10)

src/intercept.ts

@@ -1,4 +1,4 @@
-export default function intercept(value: object, interceptCallback: (object: object, method: string, ...args: any) => void): object {
+export default function intercept(value: object, key: string, interceptCallback: (key: string, method: string, ...args: any) => void): object {
     const arrayMutatingMethods = ['copyWithin', 'fill', 'pop', 'push', 'reverse', 'shift', 'sort', 'splice', 'unshift']
     const objectMutatingMethods: string[] = []
     const mapMutatingMethods = ['clear', 'delete', 'set']
@@ -18,12 +18,18 @@ export default function intercept(value: object, interceptCallback: (object: obj
             if (Reflect.has(target, name) && mutatingMethods.get(value.constructor).includes(name)) {
                 const method = Reflect.get(target, name)
                 return (...args: any) => {
-                    interceptCallback(value, name, ...args)
+                    interceptCallback(key, name, ...args)
                     method.call(value, ...args)
                 }
             } else {
                 return Reflect.get(target, name)
             }
-        }
+        },
+        set(target, name: string, value: any): boolean {
+            // @ts-ignore
+            const result = (target[name] = value)
+            interceptCallback(key, '$$iposDefine', name, value)
+            return !!result
+        },
     })
 }

src/main.ts

@@ -4,8 +4,9 @@ import IPOSMessaging, {iposMessagingMessage, iposMessagingType} from './messagin
 import intercept from './intercept.js'
 
 export default class IPOS {
-    private readonly fields: Map<string, object>
-    private fieldsReverseMap: Map<object, string>
+    private readonly fields: Map<string, ProxyHandler<any>>
+    private readonly fieldsRaw: Map<string, any>
+    private fieldsReverseMap: Map<ProxyHandler<any>, string>
     private processMessagingMap: Map<ChildProcess, IPOSMessaging>
     private readonly proxy
     protected messaging?: IPOSMessaging
@@ -24,6 +25,7 @@ export default class IPOS {
 
     constructor() {
         this.fields = new Map()
+        this.fieldsRaw = new Map()
         this.fieldsReverseMap = new Map()
         this.processMessagingMap = new Map()
 
@@ -72,16 +74,21 @@ export default class IPOS {
         return this.fields.get(key)
     }
 
+    private getRaw(key: string): any {
+        return this.fields.get(key)
+    }
+
     /******************** CREATE ********************/
     public create(key: string, value: any): void {
         this.createStealthy(key, value)
         this.sendToAll('set', {key, value})
     }
 
     protected createStealthy(key: string, value: object): void {
+        this.fieldsRaw.set(key, value)
         if (typeof value === 'object')
-            value = intercept(value, (object, method, ...args) =>
-                this.sendMethodCall(object, method, ...args)
+            value = intercept(value, key, (key, method, ...args) =>
+                this.sendMethodCall(key, method, ...args)
             )
 
         this.fields.set(key, value)
@@ -96,13 +103,18 @@ export default class IPOS {
     /******************** UPDATE ********************/
     protected performUpdate(message: iposMessagingMessage) {
         if (!message.do || !message.on) return
-        this.get(message.on)[message.do](...(message.with ?? []))
+        if (message.do === '$$iposDefine') {
+            if (!message.with) return
+            this.fieldsRaw.get(message.on)[message.with[0]] = message.with[1]
+        } else {
+            this.fieldsRaw.get(message.on)[message.do](...(message.with ?? []))
+        }
     }
 
-    private sendMethodCall(object: object, method: string, ...args: any) {
+    private sendMethodCall(key: string, method: string, ...args: any) {
         this.sendToAll('update', {
             do: method,
-            on: this.fieldsReverseMap.get(object),
+            on: key,
             with: Array.from(args)
         })
     }

src/serialize.ts

@@ -1,6 +1,6 @@
 export function serialize(value: any): any | void {
     // todo: handle other builtins
-    if (['string', 'number'].includes(typeof value)) {
+    if (['string', 'number', 'boolean'].includes(typeof value) || !value) {
         return value
     } else if (typeof value === 'function') {
         return {