@testring/transport - npm Package Compare versions

Comparing version 0.7.6 to 0.8.0

dist/broadcast-transport.d.ts

+import { TransportMessageHandler } from '@testring/types';
+declare class BroadcastTransport {
+    private triggerListeners;
+    private rootProcess;
+    constructor(triggerListeners: TransportMessageHandler, rootProcess: NodeJS.Process);
+    /**
+     * Sending message to all connected processes
+     */
+    broadcast(type: string, payload: any): void;
+    broadcastLocal(type: string, payload: any): void;
+    private registerRootProcess;
+    private handleRootProcessMessage;
+    private sendMessage;
+}
+export { BroadcastTransport };
+//# sourceMappingURL=broadcast-transport.d.ts.map

dist/broadcast-transport.d.ts.map

+{"version":3,"file":"broadcast-transport.d.ts","sourceRoot":"","sources":["../src/broadcast-transport.ts"],"names":[],"mappings":"AAAA,OAAO,EAEH,uBAAuB,EAG1B,MAAM,iBAAiB,CAAC;AAGzB,cAAM,kBAAkB;IAEhB,OAAO,CAAC,gBAAgB;IACxB,OAAO,CAAC,WAAW;gBADX,gBAAgB,EAAE,uBAAuB,EACzC,WAAW,EAAE,MAAM,CAAC,OAAO;IAKvC;;OAEG;IACI,SAAS,CAAC,IAAI,EAAE,MAAM,EAAE,OAAO,EAAE,GAAG,GAAG,IAAI;IAO3C,cAAc,CAAC,IAAI,EAAE,MAAM,EAAE,OAAO,EAAE,GAAG;IAOhD,OAAO,CAAC,mBAAmB;IAM3B,OAAO,CAAC,wBAAwB;IAuBhC,OAAO,CAAC,WAAW;CAKtB;AAED,OAAO,EAAC,kBAAkB,EAAC,CAAC"}

dist/direct-transport.d.ts

+import { IWorkerEmitter, TransportMessageHandler } from '@testring/types';
+declare class DirectTransport {
+    private triggerListeners;
+    private static createMessageUID;
+    private static isMessageFromProcess;
+    private childRegistry;
+    private responseHandlers;
+    constructor(triggerListeners: TransportMessageHandler);
+    getProcessesList(): Array<string>;
+    /**
+     * Sending direct message to child process. Returns promise,
+     * that resolves, when child process answers to message (like in TCP)
+     */
+    send(processID: string, type: string, payload: any): Promise<void>;
+    registerChild(processID: string, child: IWorkerEmitter): void;
+    private handleChildClose;
+    private handleChildMessage;
+    private handleMessageResponse;
+}
+export { DirectTransport };
+//# sourceMappingURL=direct-transport.d.ts.map

dist/direct-transport.d.ts.map

+{"version":3,"file":"direct-transport.d.ts","sourceRoot":"","sources":["../src/direct-transport.ts"],"names":[],"mappings":"AAAA,OAAO,EACH,cAAc,EAEd,uBAAuB,EAG1B,MAAM,iBAAiB,CAAC;AAIzB,cAAM,eAAe;IAaL,OAAO,CAAC,gBAAgB;IAZpC,OAAO,CAAC,MAAM,CAAC,gBAAgB;IAI/B,OAAO,CAAC,MAAM,CAAC,oBAAoB;IAInC,OAAO,CAAC,aAAa,CAA0C;IAE/D,OAAO,CAAC,gBAAgB,CAAoC;gBAExC,gBAAgB,EAAE,uBAAuB;IAEtD,gBAAgB,IAAI,KAAK,CAAC,MAAM,CAAC;IAIxC;;;OAGG;IACI,IAAI,CAAC,SAAS,EAAE,MAAM,EAAE,IAAI,EAAE,MAAM,EAAE,OAAO,EAAE,GAAG,GAAG,OAAO,CAAC,IAAI,CAAC;IAgClE,aAAa,CAAC,SAAS,EAAE,MAAM,EAAE,KAAK,EAAE,cAAc;IAe7D,OAAO,CAAC,gBAAgB;IAexB,OAAO,CAAC,kBAAkB;IA4B1B,OAAO,CAAC,qBAAqB;CAQhC;AAED,OAAO,EAAC,eAAe,EAAC,CAAC"}

dist/index.d.ts

+import { Transport } from './transport';
+import { serialize, deserialize } from './serialize';
+declare const transport: Transport;
+export { Transport, transport, serialize, deserialize };
+//# sourceMappingURL=index.d.ts.map

dist/index.d.ts.map

+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AACA,OAAO,EAAC,SAAS,EAAC,MAAM,aAAa,CAAC;AACtC,OAAO,EAAC,SAAS,EAAE,WAAW,EAAC,MAAM,aAAa,CAAC;AAEnD,QAAA,MAAM,SAAS,WAAyB,CAAC;AAEzC,OAAO,EAAC,SAAS,EAAE,SAAS,EAAE,SAAS,EAAE,WAAW,EAAC,CAAC"}

dist/serialize/array.d.ts

+import { ITransportSerializedStruct, TransportSerializer, TransportDeserializer } from '@testring/types';
+export interface ISerializedArray extends ITransportSerializedStruct {
+    $key: string;
+    values: Array<ITransportSerializedStruct>;
+}
+export declare const ARRAY_KEY = "Array";
+export declare function serializeArray(array: Array<any>, serialize: TransportSerializer): ISerializedArray;
+export declare function deserializeArray(serializedArray: ISerializedArray, deserialize: TransportDeserializer): Array<any>;
+//# sourceMappingURL=array.d.ts.map

dist/serialize/array.d.ts.map

+{"version":3,"file":"array.d.ts","sourceRoot":"","sources":["../../src/serialize/array.ts"],"names":[],"mappings":"AAAA,OAAO,EACH,0BAA0B,EAC1B,mBAAmB,EACnB,qBAAqB,EACxB,MAAM,iBAAiB,CAAC;AAEzB,MAAM,WAAW,gBAAiB,SAAQ,0BAA0B;IAChE,IAAI,EAAE,MAAM,CAAC;IACb,MAAM,EAAE,KAAK,CAAC,0BAA0B,CAAC,CAAC;CAC7C;AAED,eAAO,MAAM,SAAS,UAAU,CAAC;AAEjC,wBAAgB,cAAc,CAC1B,KAAK,EAAE,KAAK,CAAC,GAAG,CAAC,EACjB,SAAS,EAAE,mBAAmB,GAC/B,gBAAgB,CAKlB;AAED,wBAAgB,gBAAgB,CAC5B,eAAe,EAAE,gBAAgB,EACjC,WAAW,EAAE,qBAAqB,GACnC,KAAK,CAAC,GAAG,CAAC,CAEZ"}

dist/serialize/buffer.d.ts

+import { ITransportSerializedStruct } from '@testring/types';
+export interface ISerializedBuffer extends ITransportSerializedStruct {
+    $key: string;
+    data: string;
+}
+export declare const BUFFER_KEY = "Buffer";
+export declare function serializeBuffer(buffer: Buffer): ISerializedBuffer;
+export declare function deserializeBuffer(serializedBuffer: ISerializedBuffer): Buffer;
+//# sourceMappingURL=buffer.d.ts.map

dist/serialize/buffer.d.ts.map

+{"version":3,"file":"buffer.d.ts","sourceRoot":"","sources":["../../src/serialize/buffer.ts"],"names":[],"mappings":"AAAA,OAAO,EAAC,0BAA0B,EAAC,MAAM,iBAAiB,CAAC;AAE3D,MAAM,WAAW,iBAAkB,SAAQ,0BAA0B;IACjE,IAAI,EAAE,MAAM,CAAC;IACb,IAAI,EAAE,MAAM,CAAC;CAChB;AAED,eAAO,MAAM,UAAU,WAAW,CAAC;AAEnC,wBAAgB,eAAe,CAAC,MAAM,EAAE,MAAM,GAAG,iBAAiB,CAKjE;AAED,wBAAgB,iBAAiB,CAAC,gBAAgB,EAAE,iBAAiB,GAAG,MAAM,CAE7E"}

dist/serialize/date.d.ts

+import { ITransportSerializedStruct } from '@testring/types';
+export interface ISerializedDate extends ITransportSerializedStruct {
+    $key: string;
+    data: number;
+}
+export declare const DATE_KEY = "Date";
+export declare function serializeDate(date: Date): ISerializedDate;
+export declare function deserializeDate(serializedDate: ISerializedDate): Date;
+//# sourceMappingURL=date.d.ts.map

dist/serialize/date.d.ts.map

+{"version":3,"file":"date.d.ts","sourceRoot":"","sources":["../../src/serialize/date.ts"],"names":[],"mappings":"AAAA,OAAO,EAAC,0BAA0B,EAAC,MAAM,iBAAiB,CAAC;AAE3D,MAAM,WAAW,eAAgB,SAAQ,0BAA0B;IAC/D,IAAI,EAAE,MAAM,CAAC;IACb,IAAI,EAAE,MAAM,CAAC;CAChB;AAED,eAAO,MAAM,QAAQ,SAAS,CAAC;AAE/B,wBAAgB,aAAa,CAAC,IAAI,EAAE,IAAI,GAAG,eAAe,CAKzD;AAED,wBAAgB,eAAe,CAAC,cAAc,EAAE,eAAe,GAAG,IAAI,CAErE"}

dist/serialize/error.d.ts

+import { ITransportSerializedStruct } from '@testring/types';
+export interface ISerializedError extends ITransportSerializedStruct {
+    $key: string;
+    type: string;
+    message: string;
+    stack: string | void;
+}
+export declare const ERROR_KEY = "Error";
+export declare function serializeError(error: Error | EvalError): ISerializedError;
+export declare function deserializeError(serializedError: ISerializedError): Error;
+//# sourceMappingURL=error.d.ts.map

dist/serialize/error.d.ts.map

+{"version":3,"file":"error.d.ts","sourceRoot":"","sources":["../../src/serialize/error.ts"],"names":[],"mappings":"AAAA,OAAO,EAAC,0BAA0B,EAAC,MAAM,iBAAiB,CAAC;AAE3D,MAAM,WAAW,gBAAiB,SAAQ,0BAA0B;IAChE,IAAI,EAAE,MAAM,CAAC;IACb,IAAI,EAAE,MAAM,CAAC;IACb,OAAO,EAAE,MAAM,CAAC;IAChB,KAAK,EAAE,MAAM,GAAG,IAAI,CAAC;CACxB;AAED,eAAO,MAAM,SAAS,UAAU,CAAC;AAEjC,wBAAgB,cAAc,CAAC,KAAK,EAAE,KAAK,GAAG,SAAS,GAAG,gBAAgB,CAOzE;AAED,wBAAgB,gBAAgB,CAAC,eAAe,EAAE,gBAAgB,GAAG,KAAK,CAuCzE"}

dist/serialize/function.d.ts

+import { ITransportSerializedStruct } from '@testring/types';
+export interface ISerializedFunction extends ITransportSerializedStruct {
+    $key: string;
+    body: string;
+    arguments: Array<string>;
+}
+export declare const FUNCTION_KEY = "Function";
+export declare function serializeFunction(func: Function): ISerializedFunction;
+export declare function deserializeFunction(serializedFunction: ISerializedFunction): Function;
+//# sourceMappingURL=function.d.ts.map

dist/serialize/function.d.ts.map

+{"version":3,"file":"function.d.ts","sourceRoot":"","sources":["../../src/serialize/function.ts"],"names":[],"mappings":"AAAA,OAAO,EAAC,0BAA0B,EAAC,MAAM,iBAAiB,CAAC;AAE3D,MAAM,WAAW,mBAAoB,SAAQ,0BAA0B;IACnE,IAAI,EAAE,MAAM,CAAC;IACb,IAAI,EAAE,MAAM,CAAC;IACb,SAAS,EAAE,KAAK,CAAC,MAAM,CAAC,CAAC;CAC5B;AAED,eAAO,MAAM,YAAY,aAAa,CAAC;AAuCvC,wBAAgB,iBAAiB,CAAC,IAAI,EAAE,QAAQ,GAAG,mBAAmB,CAUrE;AAED,wBAAgB,mBAAmB,CAC/B,kBAAkB,EAAE,mBAAmB,GACxC,QAAQ,CAMV"}

dist/serialize/index.d.ts

+import { TransportSerializer, TransportDeserializer } from '@testring/types';
+export declare const serialize: TransportSerializer;
+export declare const deserialize: TransportDeserializer;
+//# sourceMappingURL=index.d.ts.map

dist/serialize/index.d.ts.map

+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/serialize/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAEH,mBAAmB,EACnB,qBAAqB,EACxB,MAAM,iBAAiB,CAAC;AA6CzB,eAAO,MAAM,SAAS,EAAE,mBAwCvB,CAAC;AAEF,eAAO,MAAM,WAAW,EAAE,qBA4BzB,CAAC"}

dist/serialize/object.d.ts

+import { ITransportSerializedStruct, TransportSerializer, TransportDeserializer } from '@testring/types';
+export interface ISerializedObject extends ITransportSerializedStruct {
+    $key: string;
+    dictionary: Record<string, unknown>;
+}
+export declare const OBJECT_KEY = "Object";
+export declare function serializeObject(object: Record<string, unknown>, serialize: TransportSerializer): ISerializedObject;
+export declare function deserializeObject(serializedObject: ISerializedObject, deserialize: TransportDeserializer): Record<string, unknown>;
+//# sourceMappingURL=object.d.ts.map

dist/serialize/object.d.ts.map

+{"version":3,"file":"object.d.ts","sourceRoot":"","sources":["../../src/serialize/object.ts"],"names":[],"mappings":"AAAA,OAAO,EACH,0BAA0B,EAC1B,mBAAmB,EACnB,qBAAqB,EACxB,MAAM,iBAAiB,CAAC;AAEzB,MAAM,WAAW,iBAAkB,SAAQ,0BAA0B;IACjE,IAAI,EAAE,MAAM,CAAC;IACb,UAAU,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC;CACvC;AAED,eAAO,MAAM,UAAU,WAAW,CAAC;AAEnC,wBAAgB,eAAe,CAC3B,MAAM,EAAE,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,EAC/B,SAAS,EAAE,mBAAmB,GAC/B,iBAAiB,CAanB;AAED,wBAAgB,iBAAiB,CAC7B,gBAAgB,EAAE,iBAAiB,EACnC,WAAW,EAAE,qBAAqB,GACnC,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAazB"}

dist/transport.d.ts

+import { ITransport, IWorkerEmitter, TransportMessageHandler } from '@testring/types';
+import { EventEmitter } from 'events';
+export declare class Transport implements ITransport {
+    private broadcastToLocal;
+    private emitter;
+    private directTransport;
+    private broadcastTransport;
+    constructor(rootProcess?: NodeJS.Process, broadcastToLocal?: boolean);
+    getProcessesList(): Array<string>;
+    send<T = any>(processID: string, messageType: string, payload: T): Promise<void>;
+    broadcast<T = any>(messageType: string, payload: T): void;
+    broadcastLocal<T = any>(messageType: string, payload: T): void;
+    broadcastUniversally<T = any>(messageType: string, payload: T): void;
+    isChildProcess(): boolean;
+    registerChild(processID: string, child: IWorkerEmitter): void;
+    on<T = any>(messageType: string, callback: TransportMessageHandler<T>): () => EventEmitter<{}>;
+    once<T = any>(messageType: string, callback: TransportMessageHandler<T>): () => EventEmitter<{}>;
+    onceFrom<T = any>(processID: string, messageType: string, callback: TransportMessageHandler<T>): () => EventEmitter<{}>;
+    private triggerListeners;
+}
+//# sourceMappingURL=transport.d.ts.map

dist/transport.d.ts.map

+{"version":3,"file":"transport.d.ts","sourceRoot":"","sources":["../src/transport.ts"],"names":[],"mappings":"AAGA,OAAO,EACH,UAAU,EACV,cAAc,EACd,uBAAuB,EAE1B,MAAM,iBAAiB,CAAC;AAGzB,OAAO,EAAC,YAAY,EAAC,MAAM,QAAQ,CAAC;AAIpC,qBAAa,SAAU,YAAW,UAAU;IASpC,OAAO,CAAC,gBAAgB;IAR5B,OAAO,CAAC,OAAO,CAAoC;IAEnD,OAAO,CAAC,eAAe,CAAkB;IAEzC,OAAO,CAAC,kBAAkB,CAAqB;gBAG3C,WAAW,GAAE,MAAM,CAAC,OAAiB,EAC7B,gBAAgB,GAAE,OAA0B;IASjD,gBAAgB,IAAI,KAAK,CAAC,MAAM,CAAC;IAIjC,IAAI,CAAC,CAAC,GAAG,GAAG,EACf,SAAS,EAAE,MAAM,EACjB,WAAW,EAAE,MAAM,EACnB,OAAO,EAAE,CAAC,GACX,OAAO,CAAC,IAAI,CAAC;IAIT,SAAS,CAAC,CAAC,GAAG,GAAG,EAAE,WAAW,EAAE,MAAM,EAAE,OAAO,EAAE,CAAC,GAAG,IAAI;IAIzD,cAAc,CAAC,CAAC,GAAG,GAAG,EAAE,WAAW,EAAE,MAAM,EAAE,OAAO,EAAE,CAAC,GAAG,IAAI;IAI9D,oBAAoB,CAAC,CAAC,GAAG,GAAG,EAC/B,WAAW,EAAE,MAAM,EACnB,OAAO,EAAE,CAAC,GACX,IAAI;IAQA,cAAc;IAId,aAAa,CAAC,SAAS,EAAE,MAAM,EAAE,KAAK,EAAE,cAAc;IAItD,EAAE,CAAC,CAAC,GAAG,GAAG,EACb,WAAW,EAAE,MAAM,EACnB,QAAQ,EAAE,uBAAuB,CAAC,CAAC,CAAC;IAOjC,IAAI,CAAC,CAAC,GAAG,GAAG,EACf,WAAW,EAAE,MAAM,EACnB,QAAQ,EAAE,uBAAuB,CAAC,CAAC,CAAC;IAOjC,QAAQ,CAAC,CAAC,GAAG,GAAG,EACnB,SAAS,EAAE,MAAM,EACjB,WAAW,EAAE,MAAM,EACnB,QAAQ,EAAE,uBAAuB,CAAC,CAAC,CAAC;IAcxC,OAAO,CAAC,gBAAgB;CAM3B"}

tsconfig.build.json

+{
+    "extends": "./tsconfig.json",
+    "compilerOptions": {
+      "outDir": "dist",
+      "rootDir": "src",
+      "noEmit": false,
+      "composite": true
+    },
+    "exclude": ["test"]
+  }

dist/broadcast-transport.js

@@ -36,3 +36,6 @@ "use strict";
         if (message.payload && typeof message.payload.$key === 'string') {
-            normalizedMessage = Object.assign(Object.assign({}, message), { payload: (0, serialize_1.deserialize)(message.payload) });
+            normalizedMessage = {
+                ...message,
+                payload: (0, serialize_1.deserialize)(message.payload),
+            };
         }
@@ -39,0 +42,0 @@ this.triggerListeners(normalizedMessage);

dist/broadcast-transport.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"broadcast-transport.js","sourceRoot":"","sources":["../src/broadcast-transport.ts"],"names":[],"mappings":";;;AAMA,2CAAmD;AAEnD,MAAM,kBAAkB;IACpB,YACY,gBAAyC,EACzC,WAA2B;QAD3B,qBAAgB,GAAhB,gBAAgB,CAAyB;QACzC,gBAAW,GAAX,WAAW,CAAgB;QAEnC,IAAI,CAAC,mBAAmB,EAAE,CAAC;IAC/B,CAAC;IAED;;OAEG;IACI,SAAS,CAAC,IAAY,EAAE,OAAY;QACvC,IAAI,CAAC,WAAW,CAAC;YACb,IAAI;YACJ,OAAO,EAAE,IAAA,qBAAS,EAAC,OAAO,CAAC;SAC9B,CAAC,CAAC;IACP,CAAC;IAEM,cAAc,CAAC,IAAY,EAAE,OAAY;QAC5C,IAAI,CAAC,gBAAgB,CAAC;YAClB,IAAI;YACJ,OAAO;SACV,CAAC,CAAC;IACP,CAAC;IAEO,mBAAmB;QACvB,IAAI,CAAC,WAAW,CAAC,EAAE,CAAC,SAAS,EAAE,CAAC,OAAO,EAAE,EAAE,CACvC,IAAI,CAAC,wBAAwB,CAAC,OAAc,CAAC,CAChD,CAAC;IACN,CAAC;IAEO,wBAAwB,CAAC,OAAgC;QAC7D,8BAA8B;QAC9B,IAAI,CAAC,OAAO,IAAI,OAAO,OAAO,CAAC,IAAI,KAAK,QAAQ,EAAE,CAAC;YAC/C,OAAO;QACX,CAAC;QAED,IAAI,iBAAiB,GAAG,OAAO,CAAC;QAEhC,IAAI,OAAO,CAAC,OAAO,IAAI,OAAO,OAAO,CAAC,OAAO,CAAC,IAAI,KAAK,QAAQ,EAAE,CAAC;YAC9D,iBAAiB,mCACV,OAAO,KACV,OAAO,EAAE,IAAA,uBAAW,EAAC,OAAO,CAAC,OAAO,CAAC,GACxC,CAAC;QACN,CAAC;QAED,IAAI,CAAC,gBAAgB,CAAC,iBAAiB,CAAC,CAAC;QAEzC,IAAI,CAAC,WAAW,CAAC;YACb,IAAI,wEAA8C;YAClD,OAAO,EAAE,iBAAiB,CAAC,GAAG;SACjC,CAAC,CAAC;IACP,CAAC;IAEO,WAAW,CAAC,OAAmC;QACnD,IAAI,OAAO,IAAI,CAAC,WAAW,CAAC,IAAI,KAAK,UAAU,EAAE,CAAC;YAC9C,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;QACnC,CAAC;IACL,CAAC;CACJ;AAEO,gDAAkB"}
+{"version":3,"file":"broadcast-transport.js","sourceRoot":"","sources":["../src/broadcast-transport.ts"],"names":[],"mappings":";;;AAMA,2CAAmD;AAEnD,MAAM,kBAAkB;IACpB,YACY,gBAAyC,EACzC,WAA2B;QAD3B,qBAAgB,GAAhB,gBAAgB,CAAyB;QACzC,gBAAW,GAAX,WAAW,CAAgB;QAEnC,IAAI,CAAC,mBAAmB,EAAE,CAAC;IAC/B,CAAC;IAED;;OAEG;IACI,SAAS,CAAC,IAAY,EAAE,OAAY;QACvC,IAAI,CAAC,WAAW,CAAC;YACb,IAAI;YACJ,OAAO,EAAE,IAAA,qBAAS,EAAC,OAAO,CAAC;SAC9B,CAAC,CAAC;IACP,CAAC;IAEM,cAAc,CAAC,IAAY,EAAE,OAAY;QAC5C,IAAI,CAAC,gBAAgB,CAAC;YAClB,IAAI;YACJ,OAAO;SACV,CAAC,CAAC;IACP,CAAC;IAEO,mBAAmB;QACvB,IAAI,CAAC,WAAW,CAAC,EAAE,CAAC,SAAS,EAAE,CAAC,OAAO,EAAE,EAAE,CACvC,IAAI,CAAC,wBAAwB,CAAC,OAAc,CAAC,CAChD,CAAC;IACN,CAAC;IAEO,wBAAwB,CAAC,OAAgC;QAC7D,8BAA8B;QAC9B,IAAI,CAAC,OAAO,IAAI,OAAO,OAAO,CAAC,IAAI,KAAK,QAAQ,EAAE,CAAC;YAC/C,OAAO;QACX,CAAC;QAED,IAAI,iBAAiB,GAAG,OAAO,CAAC;QAEhC,IAAI,OAAO,CAAC,OAAO,IAAI,OAAO,OAAO,CAAC,OAAO,CAAC,IAAI,KAAK,QAAQ,EAAE,CAAC;YAC9D,iBAAiB,GAAG;gBAChB,GAAG,OAAO;gBACV,OAAO,EAAE,IAAA,uBAAW,EAAC,OAAO,CAAC,OAAO,CAAC;aACxC,CAAC;QACN,CAAC;QAED,IAAI,CAAC,gBAAgB,CAAC,iBAAiB,CAAC,CAAC;QAEzC,IAAI,CAAC,WAAW,CAAC;YACb,IAAI,wEAA8C;YAClD,OAAO,EAAE,iBAAiB,CAAC,GAAG;SACjC,CAAC,CAAC;IACP,CAAC;IAEO,WAAW,CAAC,OAAmC;QACnD,IAAI,OAAO,IAAI,CAAC,WAAW,CAAC,IAAI,KAAK,UAAU,EAAE,CAAC;YAC9C,IAAI,CAAC,WAAW,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;QACnC,CAAC;IACL,CAAC;CACJ;AAEO,gDAAkB"}

dist/direct-transport.js

@@ -75,3 +75,6 @@ "use strict";
         if (message.payload && typeof message.payload.$key === 'string') {
-            normalizedMessage = Object.assign(Object.assign({}, message), { payload: (0, serialize_1.deserialize)(message.payload) });
+            normalizedMessage = {
+                ...message,
+                payload: (0, serialize_1.deserialize)(message.payload),
+            };
         }
@@ -78,0 +81,0 @@ switch (message.type) {

dist/direct-transport.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"direct-transport.js","sourceRoot":"","sources":["../src/direct-transport.ts"],"names":[],"mappings":";;;AAOA,2CAA+C;AAC/C,2CAAmD;AAEnD,MAAM,eAAe;IACT,MAAM,CAAC,gBAAgB,CAAC,SAAiB;QAC7C,OAAO,GAAG,SAAS,IAAI,IAAA,sBAAc,GAAE,EAAE,CAAC;IAC9C,CAAC;IAEO,MAAM,CAAC,oBAAoB,CAAC,SAAiB,EAAE,UAAkB;QACrE,OAAO,UAAU,CAAC,UAAU,CAAC,SAAS,CAAC,CAAC;IAC5C,CAAC;IAMD,YAAoB,gBAAyC;QAAzC,qBAAgB,GAAhB,gBAAgB,CAAyB;QAJrD,kBAAa,GAAgC,IAAI,GAAG,EAAE,CAAC;QAEvD,qBAAgB,GAA0B,IAAI,GAAG,EAAE,CAAC;IAEI,CAAC;IAE1D,gBAAgB;QACnB,OAAO,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,CAAC,CAAC;IACjD,CAAC;IAED;;;OAGG;IACI,IAAI,CAAC,SAAiB,EAAE,IAAY,EAAE,OAAY;QACrD,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,MAAM,KAAK,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;YAEhD,IAAI,KAAK,KAAK,SAAS,EAAE,CAAC;gBACtB,OAAO,MAAM,CACT,IAAI,cAAc,CAAC,WAAW,SAAS,iBAAiB,CAAC,CAC5D,CAAC;YACN,CAAC;YAED,MAAM,GAAG,GAAG,eAAe,CAAC,gBAAgB,CAAC,SAAS,CAAC,CAAC;YACxD,MAAM,OAAO,GAA4B;gBACrC,IAAI;gBACJ,OAAO,EAAE,IAAA,qBAAS,EAAC,OAAO,CAAC;gBAC3B,GAAG;aACN,CAAC;YAEF,IAAI,CAAC,gBAAgB,CAAC,GAAG,CAAC,GAAG,EAAE,GAAG,EAAE;gBAChC,IAAI,CAAC,gBAAgB,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;gBAClC,OAAO,EAAE,CAAC;YACd,CAAC,CAAC,CAAC;YAEH,KAAK,CAAC,IAAI,CAAC,OAAO,EAAE,CAAC,KAAK,EAAE,EAAE;gBAC1B,IAAI,KAAK,EAAE,CAAC;oBACR,IAAI,CAAC,gBAAgB,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;oBAElC,MAAM,CAAC,KAAK,CAAC,CAAC;gBAClB,CAAC;YACL,CAAC,CAAC,CAAC;QACP,CAAC,CAAC,CAAC;IACP,CAAC;IAEM,aAAa,CAAC,SAAiB,EAAE,KAAqB;QACzD,IAAI,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,SAAS,CAAC,EAAE,CAAC;YACpC,MAAM,IAAI,cAAc,CACpB,WAAW,SAAS,uCAAuC,CAC9D,CAAC;QACN,CAAC;QAED,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,SAAS,EAAE,KAAK,CAAC,CAAC;QAEzC,KAAK,CAAC,EAAE,CAAC,MAAM,EAAE,GAAG,EAAE,CAAC,IAAI,CAAC,gBAAgB,CAAC,SAAS,CAAC,CAAC,CAAC;QACzD,KAAK,CAAC,EAAE,CAAC,SAAS,EAAE,CAAC,OAAO,EAAE,EAAE,CAC5B,IAAI,CAAC,kBAAkB,CAAC,OAAO,EAAE,SAAS,CAAC,CAC9C,CAAC;IACN,CAAC;IAEO,gBAAgB,CAAC,SAAS;QAC9B,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,SAAS,CAAC,CAAC;QAErC,iDAAiD;QACjD,MAAM,gBAAgB,GAAG,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,gBAAgB,CAAC,CAAC;QAE3D,KAAK,MAAM,CAAC,UAAU,EAAE,eAAe,CAAC,IAAI,gBAAgB,EAAE,CAAC;YAC3D,IAAI,eAAe,CAAC,oBAAoB,CAAC,SAAS,EAAE,UAAU,CAAC,EAAE,CAAC;gBAC9D,IAAI,CAAC,gBAAgB,CAAC,MAAM,CAAC,UAAU,CAAC,CAAC;gBAEzC,eAAe,EAAE,CAAC;YACtB,CAAC;QACL,CAAC;IACL,CAAC;IAEO,kBAAkB,CACtB,OAAgC,EAChC,SAAiB;QAEjB,8BAA8B;QAC9B,IAAI,CAAC,OAAO,IAAI,OAAO,OAAO,CAAC,IAAI,KAAK,QAAQ,EAAE,CAAC;YAC/C,OAAO;QACX,CAAC;QAED,IAAI,iBAAiB,GAAG,OAAO,CAAC;QAEhC,IAAI,OAAO,CAAC,OAAO,IAAI,OAAO,OAAO,CAAC,OAAO,CAAC,IAAI,KAAK,QAAQ,EAAE,CAAC;YAC9D,iBAAiB,mCACV,OAAO,KACV,OAAO,EAAE,IAAA,uBAAW,EAAC,OAAO,CAAC,OAAO,CAAC,GACxC,CAAC;QACN,CAAC;QAED,QAAQ,OAAO,CAAC,IAAI,EAAE,CAAC;YACnB;gBACI,IAAI,CAAC,qBAAqB,CAAC,iBAAiB,CAAC,CAAC;gBAC9C,MAAM;YAEV;gBACI,IAAI,CAAC,gBAAgB,CAAC,iBAAiB,EAAE,SAAS,CAAC,CAAC;QAC5D,CAAC;IACL,CAAC;IAEO,qBAAqB,CAAC,OAAkC;QAC5D,MAAM,UAAU,GAAG,OAAO,CAAC,OAAO,CAAC;QACnC,MAAM,eAAe,GAAG,IAAI,CAAC,gBAAgB,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC;QAE9D,IAAI,OAAO,eAAe,KAAK,UAAU,EAAE,CAAC;YACxC,eAAe,EAAE,CAAC;QACtB,CAAC;IACL,CAAC;CACJ;AAEO,0CAAe"}
+{"version":3,"file":"direct-transport.js","sourceRoot":"","sources":["../src/direct-transport.ts"],"names":[],"mappings":";;;AAOA,2CAA+C;AAC/C,2CAAmD;AAEnD,MAAM,eAAe;IACT,MAAM,CAAC,gBAAgB,CAAC,SAAiB;QAC7C,OAAO,GAAG,SAAS,IAAI,IAAA,sBAAc,GAAE,EAAE,CAAC;IAC9C,CAAC;IAEO,MAAM,CAAC,oBAAoB,CAAC,SAAiB,EAAE,UAAkB;QACrE,OAAO,UAAU,CAAC,UAAU,CAAC,SAAS,CAAC,CAAC;IAC5C,CAAC;IAMD,YAAoB,gBAAyC;QAAzC,qBAAgB,GAAhB,gBAAgB,CAAyB;QAJrD,kBAAa,GAAgC,IAAI,GAAG,EAAE,CAAC;QAEvD,qBAAgB,GAA0B,IAAI,GAAG,EAAE,CAAC;IAEI,CAAC;IAE1D,gBAAgB;QACnB,OAAO,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,CAAC,CAAC;IACjD,CAAC;IAED;;;OAGG;IACI,IAAI,CAAC,SAAiB,EAAE,IAAY,EAAE,OAAY;QACrD,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,MAAM,KAAK,GAAG,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;YAEhD,IAAI,KAAK,KAAK,SAAS,EAAE,CAAC;gBACtB,OAAO,MAAM,CACT,IAAI,cAAc,CAAC,WAAW,SAAS,iBAAiB,CAAC,CAC5D,CAAC;YACN,CAAC;YAED,MAAM,GAAG,GAAG,eAAe,CAAC,gBAAgB,CAAC,SAAS,CAAC,CAAC;YACxD,MAAM,OAAO,GAA4B;gBACrC,IAAI;gBACJ,OAAO,EAAE,IAAA,qBAAS,EAAC,OAAO,CAAC;gBAC3B,GAAG;aACN,CAAC;YAEF,IAAI,CAAC,gBAAgB,CAAC,GAAG,CAAC,GAAG,EAAE,GAAG,EAAE;gBAChC,IAAI,CAAC,gBAAgB,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;gBAClC,OAAO,EAAE,CAAC;YACd,CAAC,CAAC,CAAC;YAEH,KAAK,CAAC,IAAI,CAAC,OAAO,EAAE,CAAC,KAAK,EAAE,EAAE;gBAC1B,IAAI,KAAK,EAAE,CAAC;oBACR,IAAI,CAAC,gBAAgB,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;oBAElC,MAAM,CAAC,KAAK,CAAC,CAAC;gBAClB,CAAC;YACL,CAAC,CAAC,CAAC;QACP,CAAC,CAAC,CAAC;IACP,CAAC;IAEM,aAAa,CAAC,SAAiB,EAAE,KAAqB;QACzD,IAAI,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,SAAS,CAAC,EAAE,CAAC;YACpC,MAAM,IAAI,cAAc,CACpB,WAAW,SAAS,uCAAuC,CAC9D,CAAC;QACN,CAAC;QAED,IAAI,CAAC,aAAa,CAAC,GAAG,CAAC,SAAS,EAAE,KAAK,CAAC,CAAC;QAEzC,KAAK,CAAC,EAAE,CAAC,MAAM,EAAE,GAAG,EAAE,CAAC,IAAI,CAAC,gBAAgB,CAAC,SAAS,CAAC,CAAC,CAAC;QACzD,KAAK,CAAC,EAAE,CAAC,SAAS,EAAE,CAAC,OAAO,EAAE,EAAE,CAC5B,IAAI,CAAC,kBAAkB,CAAC,OAAO,EAAE,SAAS,CAAC,CAC9C,CAAC;IACN,CAAC;IAEO,gBAAgB,CAAC,SAAiB;QACtC,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,SAAS,CAAC,CAAC;QAErC,iDAAiD;QACjD,MAAM,gBAAgB,GAAG,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,gBAAgB,CAAC,CAAC;QAE3D,KAAK,MAAM,CAAC,UAAU,EAAE,eAAe,CAAC,IAAI,gBAAgB,EAAE,CAAC;YAC3D,IAAI,eAAe,CAAC,oBAAoB,CAAC,SAAS,EAAE,UAAU,CAAC,EAAE,CAAC;gBAC9D,IAAI,CAAC,gBAAgB,CAAC,MAAM,CAAC,UAAU,CAAC,CAAC;gBAEzC,eAAe,EAAE,CAAC;YACtB,CAAC;QACL,CAAC;IACL,CAAC;IAEO,kBAAkB,CACtB,OAAgC,EAChC,SAAiB;QAEjB,8BAA8B;QAC9B,IAAI,CAAC,OAAO,IAAI,OAAO,OAAO,CAAC,IAAI,KAAK,QAAQ,EAAE,CAAC;YAC/C,OAAO;QACX,CAAC;QAED,IAAI,iBAAiB,GAAG,OAAO,CAAC;QAEhC,IAAI,OAAO,CAAC,OAAO,IAAI,OAAO,OAAO,CAAC,OAAO,CAAC,IAAI,KAAK,QAAQ,EAAE,CAAC;YAC9D,iBAAiB,GAAG;gBAChB,GAAG,OAAO;gBACV,OAAO,EAAE,IAAA,uBAAW,EAAC,OAAO,CAAC,OAAO,CAAC;aACxC,CAAC;QACN,CAAC;QAED,QAAQ,OAAO,CAAC,IAAI,EAAE,CAAC;YACnB;gBACI,IAAI,CAAC,qBAAqB,CAAC,iBAAiB,CAAC,CAAC;gBAC9C,MAAM;YAEV;gBACI,IAAI,CAAC,gBAAgB,CAAC,iBAAiB,EAAE,SAAS,CAAC,CAAC;QAC5D,CAAC;IACL,CAAC;IAEO,qBAAqB,CAAC,OAAkC;QAC5D,MAAM,UAAU,GAAG,OAAO,CAAC,OAAO,CAAC;QACnC,MAAM,eAAe,GAAG,IAAI,CAAC,gBAAgB,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC;QAE9D,IAAI,OAAO,eAAe,KAAK,UAAU,EAAE,CAAC;YACxC,eAAe,EAAE,CAAC;QACtB,CAAC;IACL,CAAC;CACJ;AAEO,0CAAe"}

dist/index.js

 "use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.deserialize = exports.serialize = exports.transport = exports.Transport = void 0;
-const process = require("process");
+const node_process_1 = __importDefault(require("node:process"));
 const transport_1 = require("./transport");
@@ -10,4 +13,4 @@ Object.defineProperty(exports, "Transport", { enumerable: true, get: function () { return transport_1.Transport; } });
 Object.defineProperty(exports, "deserialize", { enumerable: true, get: function () { return serialize_1.deserialize; } });
-const transport = new transport_1.Transport(process);
+const transport = new transport_1.Transport(node_process_1.default);
 exports.transport = transport;
 //# sourceMappingURL=index.js.map

dist/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;;AAAA,mCAAmC;AACnC,2CAAsC;AAK9B,0FALA,qBAAS,OAKA;AAJjB,2CAAmD;AAIrB,0FAJtB,qBAAS,OAIsB;AAAE,4FAJtB,uBAAW,OAIsB;AAFpD,MAAM,SAAS,GAAG,IAAI,qBAAS,CAAC,OAAO,CAAC,CAAC;AAEtB,8BAAS"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";;;;;;AAAA,gEAAmC;AACnC,2CAAsC;AAK9B,0FALA,qBAAS,OAKA;AAJjB,2CAAmD;AAIrB,0FAJtB,qBAAS,OAIsB;AAAE,4FAJtB,uBAAW,OAIsB;AAFpD,MAAM,SAAS,GAAG,IAAI,qBAAS,CAAC,sBAAO,CAAC,CAAC;AAEtB,8BAAS"}

dist/serialize/error.js

@@ -40,5 +40,7 @@ "use strict";
     const error = new Constructor(serializedError.message);
-    error.stack = serializedError.stack;
+    if (typeof serializedError.stack === 'string') {
+        error.stack = serializedError.stack;
+    }
     return error;
 }
 //# sourceMappingURL=error.js.map

dist/serialize/error.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"error.js","sourceRoot":"","sources":["../../src/serialize/error.ts"],"names":[],"mappings":";;;AAWA,wCAOC;AAED,4CAqCC;AAhDY,QAAA,SAAS,GAAG,OAAO,CAAC;AAEjC,SAAgB,cAAc,CAAC,KAAwB;IACnD,OAAO;QACH,IAAI,EAAE,iBAAS;QACf,IAAI,EAAE,KAAK,CAAC,IAAI;QAChB,OAAO,EAAE,KAAK,CAAC,OAAO;QACtB,KAAK,EAAE,KAAK,CAAC,KAAK;KACrB,CAAC;AACN,CAAC;AAED,SAAgB,gBAAgB,CAAC,eAAiC;IAC9D,IAAI,WAAW,CAAC;IAEhB,QAAQ,eAAe,CAAC,IAAI,EAAE,CAAC;QAC3B,KAAK,WAAW;YACZ,WAAW,GAAG,SAAS,CAAC;YACxB,MAAM;QAEV,KAAK,YAAY;YACb,WAAW,GAAG,UAAU,CAAC;YACzB,MAAM;QAEV,KAAK,gBAAgB;YACjB,WAAW,GAAG,cAAc,CAAC;YAC7B,MAAM;QAEV,KAAK,aAAa;YACd,WAAW,GAAG,WAAW,CAAC;YAC1B,MAAM;QAEV,KAAK,WAAW;YACZ,WAAW,GAAG,SAAS,CAAC;YACxB,MAAM;QAEV,KAAK,UAAU;YACX,WAAW,GAAG,QAAQ,CAAC;YACvB,MAAM;QAEV;YACI,WAAW,GAAG,KAAK,CAAC;IAC5B,CAAC;IAED,MAAM,KAAK,GAAG,IAAI,WAAW,CAAC,eAAe,CAAC,OAAO,CAAC,CAAC;IAEvD,KAAK,CAAC,KAAK,GAAG,eAAe,CAAC,KAAK,CAAC;IAEpC,OAAO,KAAK,CAAC;AACjB,CAAC"}
+{"version":3,"file":"error.js","sourceRoot":"","sources":["../../src/serialize/error.ts"],"names":[],"mappings":";;;AAWA,wCAOC;AAED,4CAuCC;AAlDY,QAAA,SAAS,GAAG,OAAO,CAAC;AAEjC,SAAgB,cAAc,CAAC,KAAwB;IACnD,OAAO;QACH,IAAI,EAAE,iBAAS;QACf,IAAI,EAAE,KAAK,CAAC,IAAI;QAChB,OAAO,EAAE,KAAK,CAAC,OAAO;QACtB,KAAK,EAAE,KAAK,CAAC,KAAK;KACrB,CAAC;AACN,CAAC;AAED,SAAgB,gBAAgB,CAAC,eAAiC;IAC9D,IAAI,WAAW,CAAC;IAEhB,QAAQ,eAAe,CAAC,IAAI,EAAE,CAAC;QAC3B,KAAK,WAAW;YACZ,WAAW,GAAG,SAAS,CAAC;YACxB,MAAM;QAEV,KAAK,YAAY;YACb,WAAW,GAAG,UAAU,CAAC;YACzB,MAAM;QAEV,KAAK,gBAAgB;YACjB,WAAW,GAAG,cAAc,CAAC;YAC7B,MAAM;QAEV,KAAK,aAAa;YACd,WAAW,GAAG,WAAW,CAAC;YAC1B,MAAM;QAEV,KAAK,WAAW;YACZ,WAAW,GAAG,SAAS,CAAC;YACxB,MAAM;QAEV,KAAK,UAAU;YACX,WAAW,GAAG,QAAQ,CAAC;YACvB,MAAM;QAEV;YACI,WAAW,GAAG,KAAK,CAAC;IAC5B,CAAC;IAED,MAAM,KAAK,GAAG,IAAI,WAAW,CAAC,eAAe,CAAC,OAAO,CAAC,CAAC;IAEvD,IAAI,OAAO,eAAe,CAAC,KAAK,KAAK,QAAQ,EAAE,CAAC;QAC5C,KAAK,CAAC,KAAK,GAAG,eAAe,CAAC,KAAK,CAAC;IACxC,CAAC;IAED,OAAO,KAAK,CAAC;AACjB,CAAC"}

dist/serialize/function.js

@@ -16,3 +16,3 @@ "use strict";
         let normalizedBody = blockBody ? blockBody[1] : '';
-        if (normalizedBody.includes('[native code]')) {
+        if (normalizedBody && normalizedBody.includes('[native code]')) {
             normalizedBody = '';
@@ -28,3 +28,3 @@ }
     const args = fn.match(argumentsRegExp);
-    const matchedArgs = args ? args[3] || args[2] : '';
+    const matchedArgs = (args ? args[3] || args[2] : '') || '';
     if (matchedArgs.includes('()')) {
@@ -37,3 +37,3 @@ return [];
     const content = func.toString();
-    const body = getBody(content);
+    const body = getBody(content) || '';
     const args = getArguments(content);
@@ -40,0 +40,0 @@ return {

dist/serialize/function.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"function.js","sourceRoot":"","sources":["../../src/serialize/function.ts"],"names":[],"mappings":";;;AA+CA,8CAUC;AAED,kDAQC;AA3DY,QAAA,YAAY,GAAG,UAAU,CAAC;AAEvC,MAAM,UAAU,GAAG,CAAC,GAAG,EAAE,EAAE,CAAC,GAAG,CAAC,IAAI,EAAE,CAAC;AAEvC,SAAS,OAAO,CAAC,EAAU;IACvB,MAAM,eAAe,GAAG,WAAW,CAAC;IACpC,MAAM,gBAAgB,GAAG,YAAY,CAAC;IAEtC,wCAAwC;IACxC,mCAAmC;IACnC,IAAI,EAAE,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAE,CAAC;QACnB,MAAM,SAAS,GAAG,EAAE,CAAC,KAAK,CAAC,eAAe,CAAC,CAAC;QAE5C,IAAI,cAAc,GAAG,SAAS,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;QAEnD,IAAI,cAAc,CAAC,QAAQ,CAAC,eAAe,CAAC,EAAE,CAAC;YAC3C,cAAc,GAAG,EAAE,CAAC;QACxB,CAAC;QAED,OAAO,cAAc,CAAC;IAC1B,CAAC;IACD,MAAM,UAAU,GAAG,EAAE,CAAC,KAAK,CAAC,gBAAgB,CAAC,CAAC;IAE9C,OAAO,UAAU,CAAC,CAAC,CAAC,UAAU,UAAU,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;AACvD,CAAC;AAED,SAAS,YAAY,CAAC,EAAU;IAC5B,MAAM,eAAe,GAAG,uCAAuC,CAAC;IAChE,MAAM,IAAI,GAAG,EAAE,CAAC,KAAK,CAAC,eAAe,CAAC,CAAC;IAEvC,MAAM,WAAW,GAAG,IAAI,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,IAAI,IAAI,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;IAEnD,IAAI,WAAW,CAAC,QAAQ,CAAC,IAAI,CAAC,EAAE,CAAC;QAC7B,OAAO,EAAE,CAAC;IACd,CAAC;IAED,OAAO,WAAW,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC;AAClD,CAAC;AAED,SAAgB,iBAAiB,CAAC,IAAc;IAC5C,MAAM,OAAO,GAAG,IAAI,CAAC,QAAQ,EAAE,CAAC;IAChC,MAAM,IAAI,GAAG,OAAO,CAAC,OAAO,CAAC,CAAC;IAC9B,MAAM,IAAI,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;IAEnC,OAAO;QACH,IAAI,EAAE,oBAAY;QAClB,IAAI;QACJ,SAAS,EAAE,IAAI;KAClB,CAAC;AACN,CAAC;AAED,SAAgB,mBAAmB,CAC/B,kBAAuC;IAEvC,uCAAuC;IACvC,OAAO,IAAI,QAAQ,CACf,GAAG,kBAAkB,CAAC,SAAS,EAC/B,kBAAkB,CAAC,IAAI,CAC1B,CAAC;AACN,CAAC"}
+{"version":3,"file":"function.js","sourceRoot":"","sources":["../../src/serialize/function.ts"],"names":[],"mappings":";;;AA+CA,8CAUC;AAED,kDAQC;AA3DY,QAAA,YAAY,GAAG,UAAU,CAAC;AAEvC,MAAM,UAAU,GAAG,CAAC,GAAW,EAAE,EAAE,CAAC,GAAG,CAAC,IAAI,EAAE,CAAC;AAE/C,SAAS,OAAO,CAAC,EAAU;IACvB,MAAM,eAAe,GAAG,WAAW,CAAC;IACpC,MAAM,gBAAgB,GAAG,YAAY,CAAC;IAEtC,wCAAwC;IACxC,mCAAmC;IACnC,IAAI,EAAE,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAE,CAAC;QACnB,MAAM,SAAS,GAAG,EAAE,CAAC,KAAK,CAAC,eAAe,CAAC,CAAC;QAE5C,IAAI,cAAc,GAAG,SAAS,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;QAEnD,IAAI,cAAc,IAAI,cAAc,CAAC,QAAQ,CAAC,eAAe,CAAC,EAAE,CAAC;YAC7D,cAAc,GAAG,EAAE,CAAC;QACxB,CAAC;QAED,OAAO,cAAc,CAAC;IAC1B,CAAC;IACD,MAAM,UAAU,GAAG,EAAE,CAAC,KAAK,CAAC,gBAAgB,CAAC,CAAC;IAE9C,OAAO,UAAU,CAAC,CAAC,CAAC,UAAU,UAAU,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;AACvD,CAAC;AAED,SAAS,YAAY,CAAC,EAAU;IAC5B,MAAM,eAAe,GAAG,uCAAuC,CAAC;IAChE,MAAM,IAAI,GAAG,EAAE,CAAC,KAAK,CAAC,eAAe,CAAC,CAAC;IAEvC,MAAM,WAAW,GAAG,CAAC,IAAI,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC,IAAI,IAAI,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC,IAAI,EAAE,CAAC;IAE3D,IAAI,WAAW,CAAC,QAAQ,CAAC,IAAI,CAAC,EAAE,CAAC;QAC7B,OAAO,EAAE,CAAC;IACd,CAAC;IAED,OAAO,WAAW,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC;AAClD,CAAC;AAED,SAAgB,iBAAiB,CAAC,IAAc;IAC5C,MAAM,OAAO,GAAG,IAAI,CAAC,QAAQ,EAAE,CAAC;IAChC,MAAM,IAAI,GAAG,OAAO,CAAC,OAAO,CAAC,IAAI,EAAE,CAAC;IACpC,MAAM,IAAI,GAAG,YAAY,CAAC,OAAO,CAAC,CAAC;IAEnC,OAAO;QACH,IAAI,EAAE,oBAAY;QAClB,IAAI;QACJ,SAAS,EAAE,IAAI;KAClB,CAAC;AACN,CAAC;AAED,SAAgB,mBAAmB,CAC/B,kBAAuC;IAEvC,uCAAuC;IACvC,OAAO,IAAI,QAAQ,CACf,GAAG,kBAAkB,CAAC,SAAS,EAC/B,kBAAkB,CAAC,IAAI,CAC1B,CAAC;AACN,CAAC"}

dist/serialize/index.js

@@ -64,2 +64,4 @@ "use strict";
             return (0, date_1.deserializeDate)(struct);
+        default:
+            return struct;
     }
@@ -66,0 +68,0 @@ };

dist/serialize/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/serialize/index.ts"],"names":[],"mappings":";;;AAKA,mCAKiB;AACjB,mCAKiB;AACjB,qCAKkB;AAClB,qCAKkB;AAClB,yCAKoB;AACpB,iCAKgB;AAEhB,MAAM,YAAY,GAAG,CAAC,MAAW,EAAE,EAAE,CACjC,OAAO,MAAM,KAAK,QAAQ;IAC1B,OAAO,MAAM,KAAK,QAAQ;IAC1B,OAAO,MAAM,KAAK,SAAS;IAC3B,OAAO,MAAM,KAAK,WAAW;IAC7B,MAAM,KAAK,IAAI,CAAC;AAEb,MAAM,SAAS,GAAwB,CAAC,UAAe,EAAE,EAAE;IAC9D,MAAM,gBAAgB,GAAa,IAAI,GAAG,EAAE,CAAC;IAE7C,MAAM,cAAc,GAAG,CAAC,MAAW,EAAE,EAAE;QACnC,IAAI,YAAY,CAAC,MAAM,CAAC,EAAE,CAAC;YACvB,OAAO,MAAM,CAAC;QAClB,CAAC;QAED,IAAI,gBAAgB,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,CAAC;YAC/B,OAAO,YAAY,CAAC;QACxB,CAAC;QAED,gBAAgB,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC;QAE7B,IAAI,MAAM,YAAY,KAAK,EAAE,CAAC;YAC1B,OAAO,IAAA,sBAAc,EAAC,MAAM,CAAC,CAAC;QAClC,CAAC;QAED,IAAI,MAAM,YAAY,MAAM,EAAE,CAAC;YAC3B,OAAO,IAAA,wBAAe,EAAC,MAAM,CAAC,CAAC;QACnC,CAAC;QAED,IAAI,MAAM,YAAY,IAAI,EAAE,CAAC;YACzB,OAAO,IAAA,oBAAa,EAAC,MAAM,CAAC,CAAC;QACjC,CAAC;QAED,IAAI,KAAK,CAAC,OAAO,CAAC,MAAM,CAAC,EAAE,CAAC;YACxB,OAAO,IAAA,sBAAc,EAAC,MAAM,EAAE,cAAc,CAAC,CAAC;QAClD,CAAC;QAED,IAAI,OAAO,MAAM,KAAK,QAAQ,EAAE,CAAC;YAC7B,OAAO,IAAA,wBAAe,EAAC,MAAM,EAAE,cAAc,CAAC,CAAC;QACnD,CAAC;QAED,IAAI,OAAO,MAAM,KAAK,UAAU,EAAE,CAAC;YAC/B,OAAO,IAAA,4BAAiB,EAAC,MAAM,CAAC,CAAC;QACrC,CAAC;IACL,CAAC,CAAC;IAEF,OAAO,cAAc,CAAC,UAAU,CAAC,CAAC;AACtC,CAAC,CAAC;AAxCW,QAAA,SAAS,aAwCpB;AAEK,MAAM,WAAW,GAA0B,CAC9C,MAAkC,EACpC,EAAE;IACA,IAAI,YAAY,CAAC,MAAM,CAAC,EAAE,CAAC;QACvB,OAAO,MAAM,CAAC;IAClB,CAAC;IAED,QAAQ,MAAM,CAAC,IAAI,EAAE,CAAC;QAClB,KAAK,mBAAU;YACX,OAAO,IAAA,0BAAiB,EAAC,MAA2B,EAAE,mBAAW,CAAC,CAAC;QAEvE,KAAK,iBAAS;YACV,OAAO,IAAA,wBAAgB,EAAC,MAA0B,EAAE,mBAAW,CAAC,CAAC;QAErE,KAAK,iBAAS;YACV,OAAO,IAAA,wBAAgB,EAAC,MAA0B,CAAC,CAAC;QAExD,KAAK,uBAAY;YACb,OAAO,IAAA,8BAAmB,EAAC,MAA6B,CAAC,CAAC;QAE9D,KAAK,mBAAU;YACX,OAAO,IAAA,0BAAiB,EAAC,MAA2B,CAAC,CAAC;QAE1D,KAAK,eAAQ;YACT,OAAO,IAAA,sBAAe,EAAC,MAAyB,CAAC,CAAC;IAC1D,CAAC;AACL,CAAC,CAAC;AA1BW,QAAA,WAAW,eA0BtB"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/serialize/index.ts"],"names":[],"mappings":";;;AAKA,mCAKiB;AACjB,mCAKiB;AACjB,qCAKkB;AAClB,qCAKkB;AAClB,yCAKoB;AACpB,iCAKgB;AAEhB,MAAM,YAAY,GAAG,CAAC,MAAW,EAAE,EAAE,CACjC,OAAO,MAAM,KAAK,QAAQ;IAC1B,OAAO,MAAM,KAAK,QAAQ;IAC1B,OAAO,MAAM,KAAK,SAAS;IAC3B,OAAO,MAAM,KAAK,WAAW;IAC7B,MAAM,KAAK,IAAI,CAAC;AAEb,MAAM,SAAS,GAAwB,CAAC,UAAe,EAAE,EAAE;IAC9D,MAAM,gBAAgB,GAAa,IAAI,GAAG,EAAE,CAAC;IAE7C,MAAM,cAAc,GAAG,CAAC,MAAW,EAAE,EAAE;QACnC,IAAI,YAAY,CAAC,MAAM,CAAC,EAAE,CAAC;YACvB,OAAO,MAAM,CAAC;QAClB,CAAC;QAED,IAAI,gBAAgB,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,CAAC;YAC/B,OAAO,YAAY,CAAC;QACxB,CAAC;QAED,gBAAgB,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC;QAE7B,IAAI,MAAM,YAAY,KAAK,EAAE,CAAC;YAC1B,OAAO,IAAA,sBAAc,EAAC,MAAM,CAAC,CAAC;QAClC,CAAC;QAED,IAAI,MAAM,YAAY,MAAM,EAAE,CAAC;YAC3B,OAAO,IAAA,wBAAe,EAAC,MAAM,CAAC,CAAC;QACnC,CAAC;QAED,IAAI,MAAM,YAAY,IAAI,EAAE,CAAC;YACzB,OAAO,IAAA,oBAAa,EAAC,MAAM,CAAC,CAAC;QACjC,CAAC;QAED,IAAI,KAAK,CAAC,OAAO,CAAC,MAAM,CAAC,EAAE,CAAC;YACxB,OAAO,IAAA,sBAAc,EAAC,MAAM,EAAE,cAAc,CAAC,CAAC;QAClD,CAAC;QAED,IAAI,OAAO,MAAM,KAAK,QAAQ,EAAE,CAAC;YAC7B,OAAO,IAAA,wBAAe,EAAC,MAAM,EAAE,cAAc,CAAC,CAAC;QACnD,CAAC;QAED,IAAI,OAAO,MAAM,KAAK,UAAU,EAAE,CAAC;YAC/B,OAAO,IAAA,4BAAiB,EAAC,MAAM,CAAC,CAAC;QACrC,CAAC;IACL,CAAC,CAAC;IAEF,OAAO,cAAc,CAAC,UAAU,CAAC,CAAC;AACtC,CAAC,CAAC;AAxCW,QAAA,SAAS,aAwCpB;AAEK,MAAM,WAAW,GAA0B,CAC9C,MAAkC,EACpC,EAAE;IACA,IAAI,YAAY,CAAC,MAAM,CAAC,EAAE,CAAC;QACvB,OAAO,MAAM,CAAC;IAClB,CAAC;IAED,QAAQ,MAAM,CAAC,IAAI,EAAE,CAAC;QAClB,KAAK,mBAAU;YACX,OAAO,IAAA,0BAAiB,EAAC,MAA2B,EAAE,mBAAW,CAAC,CAAC;QAEvE,KAAK,iBAAS;YACV,OAAO,IAAA,wBAAgB,EAAC,MAA0B,EAAE,mBAAW,CAAC,CAAC;QAErE,KAAK,iBAAS;YACV,OAAO,IAAA,wBAAgB,EAAC,MAA0B,CAAC,CAAC;QAExD,KAAK,uBAAY;YACb,OAAO,IAAA,8BAAmB,EAAC,MAA6B,CAAC,CAAC;QAE9D,KAAK,mBAAU;YACX,OAAO,IAAA,0BAAiB,EAAC,MAA2B,CAAC,CAAC;QAE1D,KAAK,eAAQ;YACT,OAAO,IAAA,sBAAe,EAAC,MAAyB,CAAC,CAAC;QACtD;YACI,OAAO,MAAM,CAAC;IACtB,CAAC;AACL,CAAC,CAAC;AA5BW,QAAA,WAAW,eA4BtB"}

dist/serialize/object.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"object.js","sourceRoot":"","sources":["../../src/serialize/object.ts"],"names":[],"mappings":";;;AAaA,0CAgBC;AAED,8CAgBC;AApCY,QAAA,UAAU,GAAG,QAAQ,CAAC;AAEnC,SAAgB,eAAe,CAC3B,MAAc,EACd,SAA8B;IAE9B,MAAM,UAAU,GAAG,EAAE,CAAC;IAEtB,KAAK,MAAM,GAAG,IAAI,MAAM,EAAE,CAAC;QACvB,IAAI,GAAG,IAAI,MAAM,EAAE,CAAC;YAChB,UAAU,CAAC,GAAG,CAAC,GAAG,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC;QAC7C,CAAC;IACL,CAAC;IAED,OAAO;QACH,IAAI,EAAE,kBAAU;QAChB,UAAU;KACb,CAAC;AACN,CAAC;AAED,SAAgB,iBAAiB,CAC7B,gBAAmC,EACnC,WAAkC;IAElC,MAAM,UAAU,GAAG,gBAAgB,CAAC,UAAU,CAAC;IAC/C,MAAM,MAAM,GAAG,EAAE,CAAC;IAElB,KAAK,MAAM,GAAG,IAAI,UAAU,EAAE,CAAC;QAC3B,IAAI,CAAC,MAAM,CAAC,SAAS,CAAC,cAAc,CAAC,IAAI,CAAC,UAAU,EAAE,GAAG,CAAC,EAAE,CAAC;YACzD,SAAS;QACb,CAAC;QAED,MAAM,CAAC,GAAG,CAAC,GAAG,WAAW,CAAC,UAAU,CAAC,GAAG,CAAC,CAAC,CAAC;IAC/C,CAAC;IAED,OAAO,MAAM,CAAC;AAClB,CAAC"}
+{"version":3,"file":"object.js","sourceRoot":"","sources":["../../src/serialize/object.ts"],"names":[],"mappings":";;;AAaA,0CAgBC;AAED,8CAgBC;AApCY,QAAA,UAAU,GAAG,QAAQ,CAAC;AAEnC,SAAgB,eAAe,CAC3B,MAA+B,EAC/B,SAA8B;IAE9B,MAAM,UAAU,GAA4B,EAAE,CAAC;IAE/C,KAAK,MAAM,GAAG,IAAI,MAAM,EAAE,CAAC;QACvB,IAAI,GAAG,IAAI,MAAM,EAAE,CAAC;YAChB,UAAU,CAAC,GAAG,CAAC,GAAG,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC;QAC7C,CAAC;IACL,CAAC;IAED,OAAO;QACH,IAAI,EAAE,kBAAU;QAChB,UAAU;KACb,CAAC;AACN,CAAC;AAED,SAAgB,iBAAiB,CAC7B,gBAAmC,EACnC,WAAkC;IAElC,MAAM,UAAU,GAAG,gBAAgB,CAAC,UAAU,CAAC;IAC/C,MAAM,MAAM,GAA4B,EAAE,CAAC;IAE3C,KAAK,MAAM,GAAG,IAAI,UAAU,EAAE,CAAC;QAC3B,IAAI,CAAC,MAAM,CAAC,SAAS,CAAC,cAAc,CAAC,IAAI,CAAC,UAAU,EAAE,GAAG,CAAC,EAAE,CAAC;YACzD,SAAS;QACb,CAAC;QAED,MAAM,CAAC,GAAG,CAAC,GAAG,WAAW,CAAC,UAAU,CAAC,GAAG,CAA+B,CAAC,CAAC;IAC7E,CAAC;IAED,OAAO,MAAM,CAAC;AAClB,CAAC"}

dist/transport.js

 "use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.Transport = void 0;
-const process = require("process");
+const node_process_1 = __importDefault(require("node:process"));
 const child_process_1 = require("@testring/child-process");
@@ -11,3 +14,3 @@ const direct_transport_1 = require("./direct-transport");
 class Transport {
-    constructor(rootProcess = process, broadcastToLocal = IS_CHILD_PROCESS) {
+    constructor(rootProcess = node_process_1.default, broadcastToLocal = IS_CHILD_PROCESS) {
         this.broadcastToLocal = broadcastToLocal;
@@ -14,0 +17,0 @@ this.emitter = new events_1.EventEmitter();

dist/transport.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"transport.js","sourceRoot":"","sources":["../src/transport.ts"],"names":[],"mappings":";;;AAAA,mCAAmC;AAEnC,2DAAuD;AAOvD,yDAAmD;AACnD,+DAAyD;AACzD,mCAAoC;AAEpC,MAAM,gBAAgB,GAAG,IAAA,8BAAc,GAAE,CAAC;AAE1C,MAAa,SAAS;IAOlB,YACI,cAA8B,OAAO,EAC7B,mBAA4B,gBAAgB;QAA5C,qBAAgB,GAAhB,gBAAgB,CAA4B;QARhD,YAAO,GAAiB,IAAI,qBAAY,EAAE,CAAC;QAU/C,MAAM,OAAO,GAAG,IAAI,CAAC,gBAAgB,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;QAEjD,IAAI,CAAC,eAAe,GAAG,IAAI,kCAAe,CAAC,OAAO,CAAC,CAAC;QAEpD,IAAI,CAAC,kBAAkB,GAAG,IAAI,wCAAkB,CAAC,OAAO,EAAE,WAAW,CAAC,CAAC;IAC3E,CAAC;IAEM,gBAAgB;QACnB,OAAO,IAAI,CAAC,eAAe,CAAC,gBAAgB,EAAE,CAAC;IACnD,CAAC;IAEM,IAAI,CACP,SAAiB,EACjB,WAAmB,EACnB,OAAU;QAEV,OAAO,IAAI,CAAC,eAAe,CAAC,IAAI,CAAC,SAAS,EAAE,WAAW,EAAE,OAAO,CAAC,CAAC;IACtE,CAAC;IAEM,SAAS,CAAU,WAAmB,EAAE,OAAU;QACrD,IAAI,CAAC,kBAAkB,CAAC,SAAS,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;IAC5D,CAAC;IAEM,cAAc,CAAU,WAAmB,EAAE,OAAU;QAC1D,IAAI,CAAC,kBAAkB,CAAC,cAAc,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;IACjE,CAAC;IAEM,oBAAoB,CACvB,WAAmB,EACnB,OAAU;QAEV,IAAI,IAAI,CAAC,cAAc,EAAE,EAAE,CAAC;YACxB,IAAI,CAAC,SAAS,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QACzC,CAAC;aAAM,CAAC;YACJ,IAAI,CAAC,cAAc,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QAC9C,CAAC;IACL,CAAC;IAEM,cAAc;QACjB,OAAO,IAAI,CAAC,gBAAgB,CAAC;IACjC,CAAC;IAEM,aAAa,CAAC,SAAiB,EAAE,KAAqB;QACzD,IAAI,CAAC,eAAe,CAAC,aAAa,CAAC,SAAS,EAAE,KAAK,CAAC,CAAC;IACzD,CAAC;IAEM,EAAE,CACL,WAAmB,EACnB,QAAoC;QAEpC,IAAI,CAAC,OAAO,CAAC,EAAE,CAAC,WAAW,EAAE,QAAQ,CAAC,CAAC;QAEvC,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,cAAc,CAAC,WAAW,EAAE,QAAQ,CAAC,CAAC;IACpE,CAAC;IAEM,IAAI,CACP,WAAmB,EACnB,QAAoC;QAEpC,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,WAAW,EAAE,QAAQ,CAAC,CAAC;QAEzC,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,cAAc,CAAC,WAAW,EAAE,QAAQ,CAAC,CAAC;IACpE,CAAC;IAEM,QAAQ,CACX,SAAiB,EACjB,WAAmB,EACnB,QAAoC;QAEpC,MAAM,OAAO,GAAG,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YAChC,IAAI,SAAS,KAAK,MAAM,EAAE,CAAC;gBACvB,QAAQ,CAAC,OAAO,CAAC,CAAC;gBAClB,IAAI,CAAC,OAAO,CAAC,cAAc,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;YACtD,CAAC;QACL,CAAC,CAAC;QAEF,IAAI,CAAC,OAAO,CAAC,EAAE,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QAEtC,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,cAAc,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;IACnE,CAAC;IAEO,gBAAgB,CACpB,OAAgC,EAChC,SAAkB;QAElB,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,OAAO,CAAC,IAAI,EAAE,OAAO,CAAC,OAAO,EAAE,SAAS,CAAC,CAAC;IAChE,CAAC;CACJ;AAlGD,8BAkGC"}
+{"version":3,"file":"transport.js","sourceRoot":"","sources":["../src/transport.ts"],"names":[],"mappings":";;;;;;AAAA,gEAAmC;AAEnC,2DAAuD;AAOvD,yDAAmD;AACnD,+DAAyD;AACzD,mCAAoC;AAEpC,MAAM,gBAAgB,GAAG,IAAA,8BAAc,GAAE,CAAC;AAE1C,MAAa,SAAS;IAOlB,YACI,cAA8B,sBAAO,EAC7B,mBAA4B,gBAAgB;QAA5C,qBAAgB,GAAhB,gBAAgB,CAA4B;QARhD,YAAO,GAAiB,IAAI,qBAAY,EAAE,CAAC;QAU/C,MAAM,OAAO,GAAG,IAAI,CAAC,gBAAgB,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;QAEjD,IAAI,CAAC,eAAe,GAAG,IAAI,kCAAe,CAAC,OAAO,CAAC,CAAC;QAEpD,IAAI,CAAC,kBAAkB,GAAG,IAAI,wCAAkB,CAAC,OAAO,EAAE,WAAW,CAAC,CAAC;IAC3E,CAAC;IAEM,gBAAgB;QACnB,OAAO,IAAI,CAAC,eAAe,CAAC,gBAAgB,EAAE,CAAC;IACnD,CAAC;IAEM,IAAI,CACP,SAAiB,EACjB,WAAmB,EACnB,OAAU;QAEV,OAAO,IAAI,CAAC,eAAe,CAAC,IAAI,CAAC,SAAS,EAAE,WAAW,EAAE,OAAO,CAAC,CAAC;IACtE,CAAC;IAEM,SAAS,CAAU,WAAmB,EAAE,OAAU;QACrD,IAAI,CAAC,kBAAkB,CAAC,SAAS,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;IAC5D,CAAC;IAEM,cAAc,CAAU,WAAmB,EAAE,OAAU;QAC1D,IAAI,CAAC,kBAAkB,CAAC,cAAc,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;IACjE,CAAC;IAEM,oBAAoB,CACvB,WAAmB,EACnB,OAAU;QAEV,IAAI,IAAI,CAAC,cAAc,EAAE,EAAE,CAAC;YACxB,IAAI,CAAC,SAAS,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QACzC,CAAC;aAAM,CAAC;YACJ,IAAI,CAAC,cAAc,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QAC9C,CAAC;IACL,CAAC;IAEM,cAAc;QACjB,OAAO,IAAI,CAAC,gBAAgB,CAAC;IACjC,CAAC;IAEM,aAAa,CAAC,SAAiB,EAAE,KAAqB;QACzD,IAAI,CAAC,eAAe,CAAC,aAAa,CAAC,SAAS,EAAE,KAAK,CAAC,CAAC;IACzD,CAAC;IAEM,EAAE,CACL,WAAmB,EACnB,QAAoC;QAEpC,IAAI,CAAC,OAAO,CAAC,EAAE,CAAC,WAAW,EAAE,QAAQ,CAAC,CAAC;QAEvC,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,cAAc,CAAC,WAAW,EAAE,QAAQ,CAAC,CAAC;IACpE,CAAC;IAEM,IAAI,CACP,WAAmB,EACnB,QAAoC;QAEpC,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,WAAW,EAAE,QAAQ,CAAC,CAAC;QAEzC,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,cAAc,CAAC,WAAW,EAAE,QAAQ,CAAC,CAAC;IACpE,CAAC;IAEM,QAAQ,CACX,SAAiB,EACjB,WAAmB,EACnB,QAAoC;QAEpC,MAAM,OAAO,GAAG,CAAC,OAAU,EAAE,MAAc,EAAE,EAAE;YAC3C,IAAI,SAAS,KAAK,MAAM,EAAE,CAAC;gBACvB,QAAQ,CAAC,OAAO,CAAC,CAAC;gBAClB,IAAI,CAAC,OAAO,CAAC,cAAc,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;YACtD,CAAC;QACL,CAAC,CAAC;QAEF,IAAI,CAAC,OAAO,CAAC,EAAE,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QAEtC,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,cAAc,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;IACnE,CAAC;IAEO,gBAAgB,CACpB,OAAgC,EAChC,SAAkB;QAElB,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,OAAO,CAAC,IAAI,EAAE,OAAO,CAAC,OAAO,EAAE,SAAS,CAAC,CAAC;IAChE,CAAC;CACJ;AAlGD,8BAkGC"}

package.json

 {
   "name": "@testring/transport",
-  "version": "0.7.6",
+  "version": "0.8.0",
   "main": "./dist/index.js",
@@ -13,7 +13,7 @@ "types": "./src/index.ts",
   "dependencies": {
-    "@testring/child-process": "0.7.6",
-    "@testring/types": "0.7.6",
-    "@testring/utils": "0.7.6",
+    "@testring/child-process": "0.8.0",
+    "@testring/types": "0.8.0",
+    "@testring/utils": "0.8.0",
     "@types/node": "22.8.5"
   }
 }

src/direct-transport.ts

@@ -81,3 +81,3 @@ import {
 
-    private handleChildClose(processID) {
+    private handleChildClose(processID: string) {
         this.childRegistry.delete(processID);
@@ -84,0 +84,0 @@

src/index.ts

@@ -1,2 +0,2 @@
-import * as process from 'process';
+import process from 'node:process';
 import {Transport} from './transport';
@@ -3,0 +3,0 @@ import {serialize, deserialize} from './serialize';

src/serialize/error.ts

@@ -55,5 +55,7 @@ import {ITransportSerializedStruct} from '@testring/types';
 
-    error.stack = serializedError.stack;
+    if (typeof serializedError.stack === 'string') {
+        error.stack = serializedError.stack;
+    }
 
     return error;
 }

src/serialize/function.ts

@@ -11,3 +11,3 @@ import {ITransportSerializedStruct} from '@testring/types';
 
-const trimString = (str) => str.trim();
+const trimString = (str: string) => str.trim();
 
@@ -25,3 +25,3 @@ function getBody(fn: string) {
 
-        if (normalizedBody.includes('[native code]')) {
+        if (normalizedBody && normalizedBody.includes('[native code]')) {
             normalizedBody = '';
@@ -41,3 +41,3 @@ }
 
-    const matchedArgs = args ? args[3] || args[2] : '';
+    const matchedArgs = (args ? args[3] || args[2] : '') || '';
 
@@ -53,3 +53,3 @@ if (matchedArgs.includes('()')) {
     const content = func.toString();
-    const body = getBody(content);
+    const body = getBody(content) || '';
     const args = getArguments(content);
@@ -56,0 +56,0 @@

src/serialize/index.ts

@@ -117,3 +117,5 @@ import {
             return deserializeDate(struct as ISerializedDate);
+        default:
+            return struct;
     }
 };

src/serialize/object.ts

@@ -9,3 +9,3 @@ import {
     $key: string;
-    dictionary: object;
+    dictionary: Record<string, unknown>;
 }
@@ -16,6 +16,6 @@
 export function serializeObject(
-    object: object,
+    object: Record<string, unknown>,
     serialize: TransportSerializer,
 ): ISerializedObject {
-    const dictionary = {};
+    const dictionary: Record<string, unknown> = {};
 
@@ -37,5 +37,5 @@ for (const key in object) {
     deserialize: TransportDeserializer,
-): object {
+): Record<string, unknown> {
     const dictionary = serializedObject.dictionary;
-    const object = {};
+    const object: Record<string, unknown> = {};
 
@@ -47,3 +47,3 @@ for (const key in dictionary) {
 
-        object[key] = deserialize(dictionary[key]);
+        object[key] = deserialize(dictionary[key] as ITransportSerializedStruct);
     }
@@ -50,0 +50,0 @@

src/transport.ts

@@ -1,2 +0,2 @@
-import * as process from 'process';
+import process from 'node:process';
 
@@ -96,3 +96,3 @@ import {isChildProcess} from '@testring/child-process';
     ) {
-        const handler = (message, source) => {
+        const handler = (message: T, source: string) => {
             if (processID === source) {
@@ -99,0 +99,0 @@ callback(message);

No alert changes

Improved metrics

Total package byte prevSize

61241

26.46%

Number of package files

59

63.89%

Lines of code

1147

14.13%

Dependency changes

• + Added

  @testring/child-process@0.8.0
  (transitive)

• + Added

  @testring/types@0.8.0
  (transitive)

• + Added

  @testring/utils@0.8.0
  (transitive)

• - Removed

  @testring/child-process@0.7.6
  (transitive)

• - Removed

  @testring/types@0.7.6
  (transitive)

• - Removed

  @testring/utils@0.7.6
  (transitive)

• Updated

  @testring/child-process@0.8.0

• Updated

  @testring/types@0.8.0

• Updated

  @testring/utils@0.8.0