diff --git a/server/package-lock.json b/server/package-lock.json index 10c459434..a915e7c1c 100644 --- a/server/package-lock.json +++ b/server/package-lock.json @@ -1,12 +1,12 @@ { "name": "@scrypted/server", - "version": "0.7.54", + "version": "0.7.55", "lockfileVersion": 3, "requires": true, "packages": { "": { "name": "@scrypted/server", - "version": "0.7.54", + "version": "0.7.55", "license": "ISC", "dependencies": { "@mapbox/node-pre-gyp": "^1.0.10", diff --git a/server/src/plugin/runtime/node-fork-worker.ts b/server/src/plugin/runtime/node-fork-worker.ts index 52caeceb3..645f09c11 100644 --- a/server/src/plugin/runtime/node-fork-worker.ts +++ b/server/src/plugin/runtime/node-fork-worker.ts @@ -46,6 +46,7 @@ export class NodeForkWorker extends ChildProcessWorker { } }); peer.transportSafeArgumentTypes.add(Buffer.name); + peer.transportSafeArgumentTypes.add(Uint8Array.name); peer.addSerializer(net.Socket, net.Socket.name, new SidebandSocketSerializer()); } diff --git a/server/src/scrypted-plugin-main.ts b/server/src/scrypted-plugin-main.ts index 7929a9053..11a42a364 100644 --- a/server/src/scrypted-plugin-main.ts +++ b/server/src/scrypted-plugin-main.ts @@ -16,6 +16,7 @@ function start(mainFilename: string) { } }); peer.transportSafeArgumentTypes.add(Buffer.name); + peer.transportSafeArgumentTypes.add(Uint8Array.name); worker_threads.parentPort.on('message', message => peer.handleMessage(v8.deserialize(message))); } else { @@ -27,6 +28,7 @@ function start(mainFilename: string) { })); peer.transportSafeArgumentTypes.add(Buffer.name); + peer.transportSafeArgumentTypes.add(Uint8Array.name); peer.addSerializer(net.Socket, net.Socket.name, new SidebandSocketSerializer()); process.on('message', message => peer.handleMessage(message as RpcMessage)); process.on('disconnect', () => { diff --git a/server/src/threading.ts b/server/src/threading.ts index 17caa0580..efa74d33a 100644 --- a/server/src/threading.ts +++ b/server/src/threading.ts @@ -43,6 +43,7 @@ export async function newThread(...args: any[]): Promise { } }); mainPeer.transportSafeArgumentTypes.add(Buffer.name); + mainPeer.transportSafeArgumentTypes.add(Uint8Array.name); thread_worker_threads.parentPort.on('message', (message: any) => mainPeer.handleMessage(thread_v8.deserialize(message))); mainPeer.params.eval = async (script: string, moduleNames: string[], paramNames: string[], ...paramValues: any[]) => { @@ -82,6 +83,7 @@ export async function newThread(...args: any[]): Promise { } }); threadPeer.transportSafeArgumentTypes.add(Buffer.name); + threadPeer.transportSafeArgumentTypes.add(Uint8Array.name); worker.on('message', (message: any) => threadPeer.handleMessage(v8.deserialize(message))); const e = await threadPeer.getParam('eval');