server: add rpc support for shallow serialized arrays

koush · Dec 22, 2024 · 9098426 · 9098426
1 parent 0d9d425
commit 9098426
Show file tree

Hide file tree

Showing 2 changed files with 34 additions and 1 deletion.
diff --git a/server/python/rpc.py b/server/python/rpc.py
@@ -292,6 +292,14 @@ def serialize(self, value, serializationContext: Dict):
                 ret[key] = self.serialize(val, serializationContext)
             return ret
 
+        if getattr(value, RpcPeer.PROPERTY_JSON_COPY_SERIALIZE_CHILDREN, None) == True:
+            array = []
+            for key, val in value.items():
+                array[key] = self.serialize(val, serializationContext)
+            return {
+                RpcPeer.PROPERTY_JSON_COPY_SERIALIZE_CHILDREN: array
+            }
+
         if RpcPeer.isTransportSafe(value):
             return value
 
@@ -427,6 +435,12 @@ def deserialize(self, value, deserializationContext: Dict):
             RpcPeer.PROPERTY_JSON_COPY_SERIALIZE_CHILDREN, None
         )
         if copySerializeChildren:
+            if type(copySerializeChildren) == list:
+                array = []
+                for val in copySerializeChildren:
+                    array.append(self.deserialize(val, deserializationContext))
+                return array
+
             ret = {}
             for key, val in value.items():
                 ret[key] = self.deserialize(val, deserializationContext)

diff --git a/server/src/rpc.ts b/server/src/rpc.ts
@@ -396,7 +396,7 @@ export class RpcPeer {
         this.killed = new Promise<string>((resolve, reject) => {
             this.killedDeferred = { resolve, reject, method: undefined };
         }).catch(e => e.message || 'Unknown Error');
-        this.killedSafe = this.killed.then(() => {}).catch(() => { });
+        this.killedSafe = this.killed.then(() => { }).catch(() => { });
     }
 
     static isTransportSafe(value: any) {
@@ -497,6 +497,14 @@ export class RpcPeer {
 
         const copySerializeChildren = value[RpcPeer.PROPERTY_JSON_COPY_SERIALIZE_CHILDREN];
         if (copySerializeChildren) {
+            if (Array.isArray(copySerializeChildren)) {
+                const array = [];
+                for (const val of copySerializeChildren) {
+                    array.push(this.deserialize(val, deserializationContext));
+                }
+                return array;
+            }
+
             const ret: any = {};
             for (const [key, val] of Object.entries(value)) {
                 ret[key] = this.deserialize(val, deserializationContext);
@@ -561,6 +569,17 @@ export class RpcPeer {
 
     serialize(value: any, serializationContext: any): any {
         if (value?.[RpcPeer.PROPERTY_JSON_COPY_SERIALIZE_CHILDREN] === true) {
+            if (Array.isArray(value)) {
+                const array = [];
+                for (const val of value) {
+                    array.push(this.serialize(val, serializationContext));
+                }
+
+                return {
+                    [RpcPeer.PROPERTY_JSON_COPY_SERIALIZE_CHILDREN]: array,
+                };
+            }
+
             const ret: any = {};
             for (const [key, val] of Object.entries(value)) {
                 ret[key] = this.serialize(val, serializationContext);