libzap - npm Package Compare versions

Comparing version 0.0.14 to 0.0.15

lib/remote/ot.d.ts

+import { RequestType } from "vscode-jsonrpc";
+import { Client as OTClient } from "../ot/client";
+import { WorkspaceOp } from "../ot/workspace";
+import { Client } from "./client";
+import { IConnection } from "./connection";
+export interface RefIdentifier {
+    repo: string;
+    ref: string;
+}
+export interface RefBaseInfo {
+    gitBase: string;
+    gitBranch: string;
+}
+export interface RefPointer extends RefBaseInfo {
+    rev: number;
+}
+export interface RefState extends RefBaseInfo {
+    history?: WorkspaceOp[];
+}
+export interface RefInfo extends RefIdentifier, RefBaseInfo {
+    rev: number;
+    target?: string;
+    watchers: string[];
+}
+export declare namespace RefListRequest {
+    const type: RequestType<void, RefInfo[], void, void>;
+}
+export interface RepoWatchParams {
+    repo: string;
+    refspec: string;
+}
+export declare namespace RepoWatchRequest {
+    const type: RequestType<RepoWatchParams, void, void, void>;
+}
+export interface RefInfoResult {
+    state?: RefState;
+    target?: string;
+}
+export declare namespace RefInfoRequest {
+    const type: RequestType<RefIdentifier, RefInfoResult, void, void>;
+}
+export interface RefUpdateDownstreamParams extends RefIdentifier {
+    current?: RefBaseInfo;
+    state?: RefState;
+    op?: WorkspaceOp;
+    ack?: boolean;
+    delete?: boolean;
+}
+export interface RefUpdateDownstreamResult {
+}
+export declare namespace RefUpdateDownstreamRequest {
+    const type: RequestType<RefUpdateDownstreamParams, RefUpdateDownstreamResult, void, void>;
+}
+export interface RefUpdateUpstreamParams extends RefIdentifier {
+    current?: RefPointer;
+    state?: RefState;
+    force?: boolean;
+    op?: WorkspaceOp;
+    delete?: boolean;
+}
+export interface RefUpdateUpstreamResult {
+}
+export declare namespace RefUpdateUpstreamRequest {
+    const type: RequestType<RefUpdateUpstreamParams, RefUpdateUpstreamResult, void, void>;
+}
+export declare class OperationalTransformationHandler {
+    private remoteClient;
+    private otClient;
+    static readonly id: string;
+    private toDispose;
+    refIdentifier?: RefIdentifier;
+    refState?: RefState;
+    refTarget?: string;
+    constructor(remoteClient: Client, otClient: OTClient);
+    register(connection: IConnection): void;
+    private onUpdateRequest(params);
+    dispose(): void;
+}

lib/remote/ot.js

+"use strict";
+const vscode_jsonrpc_1 = require("vscode-jsonrpc");
+var RefListRequest;
+(function (RefListRequest) {
+    RefListRequest.type = new vscode_jsonrpc_1.RequestType("ref/list");
+})(RefListRequest = exports.RefListRequest || (exports.RefListRequest = {}));
+var RepoWatchRequest;
+(function (RepoWatchRequest) {
+    RepoWatchRequest.type = new vscode_jsonrpc_1.RequestType("repo/watch");
+})(RepoWatchRequest = exports.RepoWatchRequest || (exports.RepoWatchRequest = {}));
+var RefInfoRequest;
+(function (RefInfoRequest) {
+    RefInfoRequest.type = new vscode_jsonrpc_1.RequestType("ref/info");
+})(RefInfoRequest = exports.RefInfoRequest || (exports.RefInfoRequest = {}));
+var RefUpdateDownstreamRequest;
+(function (RefUpdateDownstreamRequest) {
+    RefUpdateDownstreamRequest.type = new vscode_jsonrpc_1.RequestType("ref/update");
+})(RefUpdateDownstreamRequest = exports.RefUpdateDownstreamRequest || (exports.RefUpdateDownstreamRequest = {}));
+var RefUpdateUpstreamRequest;
+(function (RefUpdateUpstreamRequest) {
+    RefUpdateUpstreamRequest.type = new vscode_jsonrpc_1.RequestType("ref/update");
+})(RefUpdateUpstreamRequest = exports.RefUpdateUpstreamRequest || (exports.RefUpdateUpstreamRequest = {}));
+class OperationalTransformationHandler {
+    constructor(remoteClient, otClient) {
+        this.remoteClient = remoteClient;
+        this.otClient = otClient;
+        this.toDispose = [];
+        this.otClient.send = (rev, op) => {
+            this.remoteClient.onReady().then(() => {
+                if (!this.refIdentifier) {
+                    throw new Error("OperationalTransformHandler has no refIdentifier");
+                }
+                if (!this.refState) {
+                    throw new Error("OperationalTransformHandler has no refState");
+                }
+                this.remoteClient.sendRequest(RefUpdateUpstreamRequest.type, {
+                    repo: this.refIdentifier.repo,
+                    ref: this.refIdentifier.ref,
+                    current: {
+                        gitBase: this.refState.gitBase,
+                        gitBranch: this.refState.gitBranch,
+                        rev,
+                    },
+                    op,
+                });
+            }).then(() => { }, (err) => {
+                console.error(`ERROR: op ${JSON.stringify(op)} sending failed: ${err}`);
+            });
+        };
+    }
+    register(connection) {
+        connection.onRequest(RefUpdateDownstreamRequest.type, params => this.onUpdateRequest(params));
+        connection.onNotification(RefUpdateDownstreamRequest.type, params => this.onUpdateRequest(params));
+    }
+    onUpdateRequest(params) {
+        if (params.ack) {
+            if (params.op) {
+                this.otClient.ack();
+            }
+        }
+        else if (params.state) {
+            this.refState = params.state;
+            throw new Error(`reset not yet implemented: ${JSON.stringify(params)}`);
+        }
+        else if (params.op) {
+            this.otClient.recv(params.op);
+        }
+        else if (params.delete) {
+            if (global.location) {
+                global.location.reload();
+            }
+        }
+        else {
+            throw new Error(`unhandled ref update: ${JSON.stringify(params)}`);
+        }
+        return {};
+    }
+    dispose() {
+        this.toDispose.forEach((disposable) => disposable.dispose());
+    }
+}
+OperationalTransformationHandler.id = "ot";
+exports.OperationalTransformationHandler = OperationalTransformationHandler;
+//# sourceMappingURL=ot.js.map

lib/remote/ot.js.map

+{"version":3,"file":"ot.js","sourceRoot":"","sources":["../../src/remote/ot.ts"],"names":[],"mappings":";AAAA,mDAAyD;AA+BzD,IAAiB,cAAc,CAE9B;AAFD,WAAiB,cAAc;IACjB,mBAAI,GAAG,IAAI,4BAAW,CAA8B,UAAU,CAAC,CAAC;AAC9E,CAAC,EAFgB,cAAc,GAAd,sBAAc,KAAd,sBAAc,QAE9B;AAOD,IAAiB,gBAAgB,CAEhC;AAFD,WAAiB,gBAAgB;IACnB,qBAAI,GAAG,IAAI,4BAAW,CAAoC,YAAY,CAAC,CAAC;AACtF,CAAC,EAFgB,gBAAgB,GAAhB,wBAAgB,KAAhB,wBAAgB,QAEhC;AAOD,IAAiB,cAAc,CAE9B;AAFD,WAAiB,cAAc;IACjB,mBAAI,GAAG,IAAI,4BAAW,CAA2C,UAAU,CAAC,CAAC;AAC3F,CAAC,EAFgB,cAAc,GAAd,sBAAc,KAAd,sBAAc,QAE9B;AAYD,IAAiB,0BAA0B,CAE1C;AAFD,WAAiB,0BAA0B;IAC7B,+BAAI,GAAG,IAAI,4BAAW,CAAmE,YAAY,CAAC,CAAC;AACrH,CAAC,EAFgB,0BAA0B,GAA1B,kCAA0B,KAA1B,kCAA0B,QAE1C;AAYD,IAAiB,wBAAwB,CAExC;AAFD,WAAiB,wBAAwB;IAC3B,6BAAI,GAAG,IAAI,4BAAW,CAA+D,YAAY,CAAC,CAAC;AACjH,CAAC,EAFgB,wBAAwB,GAAxB,gCAAwB,KAAxB,gCAAwB,QAExC;AAED;IASC,YACS,YAAoB,EACpB,QAAkB;QADlB,iBAAY,GAAZ,YAAY,CAAQ;QACpB,aAAQ,GAAR,QAAQ,CAAU;QARnB,cAAS,GAAiB,EAAE,CAAC;QAUpC,IAAI,CAAC,QAAQ,CAAC,IAAI,GAAG,CAAC,GAAW,EAAE,EAAe;YACjD,IAAI,CAAC,YAAY,CAAC,OAAO,EAAE,CAAC,IAAI,CAAC;gBAChC,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,aAAa,CAAC,CAAC,CAAC;oBACzB,MAAM,IAAI,KAAK,CAAC,kDAAkD,CAAC,CAAC;gBACrE,CAAC;gBACD,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC;oBACpB,MAAM,IAAI,KAAK,CAAC,6CAA6C,CAAC,CAAC;gBAChE,CAAC;gBACD,IAAI,CAAC,YAAY,CAAC,WAAW,CAAC,wBAAwB,CAAC,IAAI,EAAE;oBAC5D,IAAI,EAAE,IAAI,CAAC,aAAa,CAAC,IAAI;oBAC7B,GAAG,EAAE,IAAI,CAAC,aAAa,CAAC,GAAG;oBAC3B,OAAO,EAAE;wBACR,OAAO,EAAE,IAAI,CAAC,QAAQ,CAAC,OAAO;wBAC9B,SAAS,EAAE,IAAI,CAAC,QAAQ,CAAC,SAAS;wBAClC,GAAG;qBACH;oBACD,EAAE;iBACF,CAAC,CAAC;YACJ,CAAC,CAAC,CAAC,IAAI,CAAC,QAAmB,CAAC,EAAE,CAAC,GAAG;gBAEjC,OAAO,CAAC,KAAK,CAAC,aAAa,IAAI,CAAC,SAAS,CAAC,EAAE,CAAC,oBAAoB,GAAG,EAAE,CAAC,CAAC;YACzE,CAAC,CAAC,CAAC;QACJ,CAAC,CAAC;IACH,CAAC;IAEM,QAAQ,CAAC,UAAuB;QACtC,UAAU,CAAC,SAAS,CAAC,0BAA0B,CAAC,IAAI,EAAE,MAAM,IAAI,IAAI,CAAC,eAAe,CAAC,MAAM,CAAC,CAAC,CAAC;QAC9F,UAAU,CAAC,cAAc,CAAC,0BAA0B,CAAC,IAAI,EAAE,MAAM,IAAI,IAAI,CAAC,eAAe,CAAC,MAAM,CAAC,CAAC,CAAC;IACpG,CAAC;IAEO,eAAe,CAAC,MAAiC;QACxD,EAAE,CAAC,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC;YAChB,EAAE,CAAC,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC,CAAC;gBACf,IAAI,CAAC,QAAQ,CAAC,GAAG,EAAE,CAAC;YACrB,CAAC;QACF,CAAC;QAAC,IAAI,CAAC,EAAE,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC;YAEzB,IAAI,CAAC,QAAQ,GAAG,MAAM,CAAC,KAAK,CAAC;YAC7B,MAAM,IAAI,KAAK,CAAC,8BAA8B,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;QAOzE,CAAC;QAAC,IAAI,CAAC,EAAE,CAAC,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC,CAAC;YACtB,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;QAC/B,CAAC;QAAC,IAAI,CAAC,EAAE,CAAC,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC;YAE1B,EAAE,CAAC,CAAE,MAAc,CAAC,QAAQ,CAAC,CAAC,CAAC;gBAC7B,MAAc,CAAC,QAAQ,CAAC,MAAM,EAAE,CAAC;YACnC,CAAC;QACF,CAAC;QAAC,IAAI,CAAC,CAAC;YACP,MAAM,IAAI,KAAK,CAAC,yBAAyB,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;QACpE,CAAC;QACD,MAAM,CAAC,EAAE,CAAC;IACX,CAAC;IAEM,OAAO;QACb,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC,UAAU,KAAK,UAAU,CAAC,OAAO,EAAE,CAAC,CAAC;IAC9D,CAAC;;AAxEe,mCAAE,GAAW,IAAI,CAAC;AADnC,4EA0EC"}

lib/remote/handler.d.ts

@@ -19,3 +19,3 @@ import { WorkspaceOp } from "../ot/workspace";
     register(connection: IConnection): void;
-    attachWorkspace(refID: RefIdentifier, workspace: Workspace | null): void;
+    attachWorkspace(refID: RefIdentifier, workspace: Workspace | null): Promise<void>;
     repoWatch(params: RepoWatchParams): Thenable<void>;
@@ -22,0 +22,0 @@ private onRefUpdate(params);

lib/remote/handler.js

@@ -22,3 +22,5 @@ "use strict";
     attachWorkspace(refID, workspace) {
-        this.getRepo(refID.repo).getRef(refID.ref).setWorkspace(workspace);
+        return __awaiter(this, void 0, void 0, function* () {
+            yield this.getRepo(refID.repo).getRef(refID.ref).setWorkspace(workspace);
+        });
     }
@@ -99,20 +101,20 @@ repoWatch(params) {
     setWorkspace(newWorkspace) {
-        if (newWorkspace && this.ot.rev !== 0) {
-            console.log("buffering history is not yet implemented (workspace attached when the ref already has history); proceeding, but the results might be incorrect");
-        }
-        if (this.workspace) {
-            this.workspace.onOp(undefined);
-            this.workspace.onReset(undefined);
-        }
-        this.workspace = newWorkspace;
-        if (this.workspace) {
-            this.ot.apply = (op) => this.workspace.apply(op);
-            this.workspace.reset([]);
-            this.workspace.onOp(op => this.onWorkspaceOp(op));
-            this.workspace.onReset(newOp => this.onWorkspaceReset(newOp));
-            this.workspace.onWillSaveFile(params => this.onWorkspaceWillSaveFile(params));
-        }
-        else {
-            this.ot.apply = undefined;
-        }
+        return __awaiter(this, void 0, void 0, function* () {
+            if (this.workspace) {
+                this.workspace.onOp(undefined);
+                this.workspace.onReset(undefined);
+            }
+            this.workspace = newWorkspace;
+            if (this.workspace) {
+                this.ot.apply = (op) => this.workspace.apply(op);
+                this.ot.reset(this.state && this.state.history ? this.state.history : []);
+                this.workspace.reset(this.state && this.state.history ? this.state.history : []);
+                this.workspace.onOp(op => this.onWorkspaceOp(op));
+                this.workspace.onReset(newOp => this.onWorkspaceReset(newOp));
+                this.workspace.onWillSaveFile(params => this.onWorkspaceWillSaveFile(params));
+            }
+            else {
+                this.ot.apply = undefined;
+            }
+        });
     }
@@ -126,3 +128,3 @@ onWorkspaceOp(op) {
             if (!this.state) {
-                throw new Error(`attempt to send ref/update request from ref with uninitialized state: ${JSON.stringify(this.refID)}`);
+                throw new Error(`attempt to send ref/ update request from ref with uninitialized state: ${JSON.stringify(this.refID)} `);
             }
@@ -140,3 +142,3 @@ this.remoteClient.sendRequest(protocol_1.RefUpdateUpstreamRequest.type, {
         }).then(() => { }, (err) => {
-            console.error(`ERROR: ref ${JSON.stringify(this.refID)} reset failed: ${err}`);
+            console.error(`ERROR: ref ${JSON.stringify(this.refID)} reset failed: ${err} `);
         });
@@ -148,3 +150,3 @@ }
         }).then(() => { }, (err) => {
-            console.error(`ERROR: ref ${JSON.stringify(this.refID)} workspace/willSaveFile ${JSON.stringify(params)} failed: ${err}`);
+            console.error(`ERROR: ref ${JSON.stringify(this.refID)} workspace / willSaveFile ${JSON.stringify(params)} failed: ${err} `);
         });
@@ -154,3 +156,3 @@ }
         return __awaiter(this, void 0, void 0, function* () {
-            console.log(`client=${process.env.ZAP_E2E_NAME}: UPDATE: ${JSON.stringify(params)}`);
+            console.log(`client= ${process.env.ZAP_E2E_NAME}: UPDATE: ${JSON.stringify(params)} `);
             if (params.ack) {
@@ -175,3 +177,3 @@ if (params.op) {
             else {
-                throw new Error(`unhandled ref update: ${JSON.stringify(params)}`);
+                throw new Error(`unhandled ref update: ${JSON.stringify(params)} `);
             }
@@ -178,0 +180,0 @@ return Promise.resolve({});

lib/remote/handler.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"handler.js","sourceRoot":"","sources":["../../src/remote/handler.ts"],"names":[],"mappings":";;;;;;;;;AAAA,yCAAkD;AAIlD,yCAAoO;AAqBpO;IAKC,YACS,YAAoB;QAApB,iBAAY,GAAZ,YAAY,CAAQ;QAHrB,UAAK,GAA6B,IAAI,GAAG,EAAE,CAAC;IAKpD,CAAC;IAEM,QAAQ,CAAC,UAAuB;QACtC,UAAU,CAAC,SAAS,CAAC,qCAA0B,CAAC,IAAI,EAAE,MAAM,IAAI,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC,CAAC;QAC1F,UAAU,CAAC,cAAc,CAAC,qCAA0B,CAAC,IAAI,EAAE,MAAM,IAAI,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC,CAAC;IAChG,CAAC;IAEM,eAAe,CAAC,KAAoB,EAAE,SAA2B;QACvE,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,YAAY,CAAC,SAAS,CAAC,CAAC;IACpE,CAAC;IAIM,SAAS,CAAC,MAAuB;QACvC,MAAM,CAAC,IAAI,CAAC,YAAY,CAAC,OAAO,EAAE,CAAC,IAAI,CAAC;YACvC,MAAM,CAAC,IAAI,CAAC,YAAY,CAAC,WAAW,CAAC,2BAAgB,CAAC,IAAI,EAAE,MAAM,CAAC,CAAC;QACrE,CAAC,CAAC,CAAC;IACJ,CAAC;IAEO,WAAW,CAAC,MAAiC;QACpD,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,uBAAuB,CAAC,MAAM,CAAC,CAAC;IAClE,CAAC;IAEO,OAAO,CAAC,QAAgB;QAC/B,IAAI,IAAI,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QACpC,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC;YACX,IAAI,GAAG,IAAI,WAAW,CAAC,QAAQ,EAAE,IAAI,CAAC,YAAY,CAAC,CAAC;YACpD,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,QAAQ,EAAE,IAAI,CAAC,CAAC;QAChC,CAAC;QACD,MAAM,CAAC,IAAI,CAAC;IACb,CAAC;IAEM,OAAO,KAAsB,CAAC;;AAvCrB,UAAE,GAAW,IAAI,CAAC;AADnC,0BAyCC;AAED;IAGC,YACS,QAAgB,EAChB,YAAoB;QADpB,aAAQ,GAAR,QAAQ,CAAQ;QAChB,iBAAY,GAAZ,YAAY,CAAQ;QAJrB,SAAI,GAAG,IAAI,GAAG,EAAsB,CAAC;IAKzC,CAAC;IAEE,MAAM,CAAC,OAAe;QAC5B,IAAI,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,OAAO,CAAC,CAAC;QACjC,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC;YACV,GAAG,GAAG,IAAI,UAAU,CAAC,EAAE,IAAI,EAAE,IAAI,CAAC,QAAQ,EAAE,GAAG,EAAE,OAAO,EAAE,EAAE,IAAI,CAAC,YAAY,EAAE,IAAI,CAAC,CAAC;YACrF,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,OAAO,EAAE,GAAG,CAAC,CAAC;QAC7B,CAAC;QACD,MAAM,CAAC,GAAG,CAAC;IACZ,CAAC;IAEM,uBAAuB,CAAC,MAAiC;QAC/D,IAAI,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;QACpC,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC;YACV,EAAE,CAAC,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC;gBACnB,MAAM,IAAI,KAAK,CAAC,2CAA2C,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,KAAK,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACrH,CAAC;YACD,GAAG,GAAG,IAAI,UAAU,CAAC,EAAE,IAAI,EAAE,IAAI,CAAC,QAAQ,EAAE,GAAG,EAAE,MAAM,CAAC,GAAG,EAAE,EAAE,IAAI,CAAC,YAAY,EAAE,MAAM,CAAC,KAAK,IAAI,IAAI,CAAC,CAAC;YACxG,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,GAAG,EAAE,GAAG,CAAC,CAAC;QAChC,CAAC;QACD,MAAM,CAAC,GAAG,CAAC,oBAAoB,CAAC,MAAM,CAAC,CAAC;IACzC,CAAC;CACD;AAED;IAIC,YACS,KAAoB,EACpB,YAAoB,EACpB,KAAsB;QAFtB,UAAK,GAAL,KAAK,CAAe;QACpB,iBAAY,GAAZ,YAAY,CAAQ;QACpB,UAAK,GAAL,KAAK,CAAiB;QANvB,OAAE,GAAG,IAAI,eAAQ,EAAE,CAAC;QACpB,cAAS,GAAqB,IAAI,CAAC;QAO1C,IAAI,CAAC,EAAE,CAAC,IAAI,GAAG,CAAC,GAAW,EAAE,EAAe;YAC3C,IAAI,CAAC,YAAY,CAAC,OAAO,EAAE,CAAC,IAAI,CAAC;gBAChC,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC;oBACjB,MAAM,IAAI,KAAK,CAAC,yEAAyE,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;gBACxH,CAAC;gBACD,IAAI,CAAC,YAAY,CAAC,WAAW,CAAC,mCAAwB,CAAC,IAAI,EAAE;oBAC5D,IAAI,EAAE,IAAI,CAAC,KAAK,CAAC,IAAI;oBACrB,GAAG,EAAE,IAAI,CAAC,KAAK,CAAC,GAAG;oBACnB,OAAO,EAAE;wBACR,OAAO,EAAE,IAAI,CAAC,KAAK,CAAC,OAAO;wBAC3B,SAAS,EAAE,IAAI,CAAC,KAAK,CAAC,SAAS;wBAC/B,GAAG;qBACH;oBACD,EAAE;iBACF,CAAC,CAAC;YACJ,CAAC,CAAC,CAAC,IAAI,CAAC,QAAmB,CAAC,EAAE,CAAC,GAAG;gBAEjC,OAAO,CAAC,KAAK,CAAC,aAAa,IAAI,CAAC,SAAS,CAAC,EAAE,CAAC,oBAAoB,GAAG,EAAE,CAAC,CAAC;YACzE,CAAC,CAAC,CAAC;QACJ,CAAC,CAAC;IACH,CAAC;IAEM,YAAY,CAAC,YAA8B;QACjD,EAAE,CAAC,CAAC,YAAY,IAAI,IAAI,CAAC,EAAE,CAAC,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC;YACvC,OAAO,CAAC,GAAG,CAAC,gJAAgJ,CAAC,CAAC;QAC/J,CAAC;QAGD,EAAE,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC;YACpB,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;YAC/B,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC;QACnC,CAAC;QAED,IAAI,CAAC,SAAS,GAAG,YAAY,CAAC;QAC9B,EAAE,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC;YAEpB,IAAI,CAAC,EAAE,CAAC,KAAK,GAAG,CAAC,EAAE,KAAK,IAAI,CAAC,SAAU,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;YAClD,IAAI,CAAC,SAAS,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;YACzB,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,EAAE,IAAI,IAAI,CAAC,aAAa,CAAC,EAAE,CAAC,CAAC,CAAC;YAClD,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,KAAK,IAAI,IAAI,CAAC,gBAAgB,CAAC,KAAK,CAAC,CAAC,CAAC;YAC9D,IAAI,CAAC,SAAS,CAAC,cAAc,CAAC,MAAM,IAAI,IAAI,CAAC,uBAAuB,CAAC,MAAM,CAAC,CAAC,CAAC;QAC/E,CAAC;QAAC,IAAI,CAAC,CAAC;YACP,IAAI,CAAC,EAAE,CAAC,KAAK,GAAG,SAAS,CAAC;QAC3B,CAAC;IACF,CAAC;IAEO,aAAa,CAAC,EAAe;QACpC,IAAI,CAAC,EAAE,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;IACpB,CAAC;IAEO,gBAAgB,CAAC,KAAmB;QAC3C,IAAI,CAAC,EAAE,CAAC,KAAK,CAAC,KAAK,GAAG,CAAC,KAAK,CAAC,GAAG,SAAS,CAAC,CAAC;QAC3C,IAAI,CAAC,YAAY,CAAC,OAAO,EAAE,CAAC,IAAI,CAAC;YAChC,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC;gBACjB,MAAM,IAAI,KAAK,CAAC,yEAAyE,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;YACxH,CAAC;YACD,IAAI,CAAC,YAAY,CAAC,WAAW,CAAC,mCAAwB,CAAC,IAAI,EAAE;gBAC5D,IAAI,EAAE,IAAI,CAAC,KAAK,CAAC,IAAI;gBACrB,GAAG,EAAE,IAAI,CAAC,KAAK,CAAC,GAAG;gBACnB,KAAK,EAAE,IAAI;gBACX,KAAK,EAAE;oBACN,OAAO,EAAE,IAAI,CAAC,KAAK,CAAC,OAAO;oBAC3B,SAAS,EAAE,IAAI,CAAC,KAAK,CAAC,SAAS;oBAC/B,OAAO,EAAE,KAAK,GAAG,CAAC,KAAK,CAAC,GAAG,EAAE;iBAC7B;aACD,CAAC,CAAC;QACJ,CAAC,CAAC,CAAC,IAAI,CAAC,QAAmB,CAAC,EAAE,CAAC,GAAG;YAEjC,OAAO,CAAC,KAAK,CAAC,cAAc,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,KAAK,CAAC,kBAAkB,GAAG,EAAE,CAAC,CAAC;QAChF,CAAC,CAAC,CAAC;IACJ,CAAC;IAEO,uBAAuB,CAAC,MAAmC;QAClE,MAAM,CAAC,IAAI,CAAC,YAAY,CAAC,OAAO,EAAE,CAAC,IAAI,CAAC;YACvC,MAAM,CAAC,IAAI,CAAC,YAAY,CAAC,WAAW,CAAC,uCAA4B,CAAC,IAAI,EAAE,MAAM,CAAC,CAAC;QACjF,CAAC,CAAC,CAAC,IAAI,CAAC,QAAmB,CAAC,EAAE,CAAC,GAAG;YAEjC,OAAO,CAAC,KAAK,CAAC,cAAc,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,KAAK,CAAC,2BAA2B,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,YAAY,GAAG,EAAE,CAAC,CAAC;QAC3H,CAAC,CAAC,CAAC;IACJ,CAAC;IAEY,oBAAoB,CAAC,MAAiC;;YAClE,OAAO,CAAC,GAAG,CAAC,UAAU,OAAO,CAAC,GAAG,CAAC,YAAY,aAAa,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACrF,EAAE,CAAC,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC;gBAChB,EAAE,CAAC,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC,CAAC;oBACf,IAAI,CAAC,EAAE,CAAC,GAAG,EAAE,CAAC;gBACf,CAAC;YACF,CAAC;YAAC,IAAI,CAAC,EAAE,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC;gBACzB,IAAI,CAAC,KAAK,GAAG,MAAM,CAAC,KAAK,CAAC;gBAC1B,IAAI,CAAC,EAAE,CAAC,KAAK,CAAC,MAAM,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC;gBACpC,EAAE,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC;oBACpB,MAAM,IAAI,CAAC,SAAS,CAAC,KAAK,CAAC,MAAM,CAAC,KAAK,CAAC,OAAQ,CAAC,CAAC;gBACnD,CAAC;YACF,CAAC;YAAC,IAAI,CAAC,EAAE,CAAC,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC,CAAC;gBACtB,MAAM,IAAI,CAAC,EAAE,CAAC,IAAI,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YAC/B,CAAC;YAAC,IAAI,CAAC,EAAE,CAAC,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC;gBAC1B,MAAM,IAAI,KAAK,CAAC,mCAAmC,CAAC,CAAC;YACtD,CAAC;YAAC,IAAI,CAAC,CAAC;gBACP,MAAM,IAAI,KAAK,CAAC,yBAAyB,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACpE,CAAC;YACD,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,CAAC,CAAC;QAC5B,CAAC;KAAA;CACD"}
+{"version":3,"file":"handler.js","sourceRoot":"","sources":["../../src/remote/handler.ts"],"names":[],"mappings":";;;;;;;;;AAAA,yCAAkD;AAIlD,yCAAoO;AAqBpO;IAKC,YACS,YAAoB;QAApB,iBAAY,GAAZ,YAAY,CAAQ;QAHrB,UAAK,GAA6B,IAAI,GAAG,EAAE,CAAC;IAKpD,CAAC;IAEM,QAAQ,CAAC,UAAuB;QACtC,UAAU,CAAC,SAAS,CAAC,qCAA0B,CAAC,IAAI,EAAE,MAAM,IAAI,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC,CAAC;QAC1F,UAAU,CAAC,cAAc,CAAC,qCAA0B,CAAC,IAAI,EAAE,MAAM,IAAI,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC,CAAC;IAChG,CAAC;IAEY,eAAe,CAAC,KAAoB,EAAE,SAA2B;;YAC7E,MAAM,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,YAAY,CAAC,SAAS,CAAC,CAAC;QAC1E,CAAC;KAAA;IAIM,SAAS,CAAC,MAAuB;QACvC,MAAM,CAAC,IAAI,CAAC,YAAY,CAAC,OAAO,EAAE,CAAC,IAAI,CAAC;YACvC,MAAM,CAAC,IAAI,CAAC,YAAY,CAAC,WAAW,CAAC,2BAAgB,CAAC,IAAI,EAAE,MAAM,CAAC,CAAC;QACrE,CAAC,CAAC,CAAC;IACJ,CAAC;IAEO,WAAW,CAAC,MAAiC;QACpD,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,uBAAuB,CAAC,MAAM,CAAC,CAAC;IAClE,CAAC;IAEO,OAAO,CAAC,QAAgB;QAC/B,IAAI,IAAI,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QACpC,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,CAAC;YACX,IAAI,GAAG,IAAI,WAAW,CAAC,QAAQ,EAAE,IAAI,CAAC,YAAY,CAAC,CAAC;YACpD,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,QAAQ,EAAE,IAAI,CAAC,CAAC;QAChC,CAAC;QACD,MAAM,CAAC,IAAI,CAAC;IACb,CAAC;IAEM,OAAO,KAAsB,CAAC;;AAvCrB,UAAE,GAAW,IAAI,CAAC;AADnC,0BAyCC;AAED;IAGC,YACS,QAAgB,EAChB,YAAoB;QADpB,aAAQ,GAAR,QAAQ,CAAQ;QAChB,iBAAY,GAAZ,YAAY,CAAQ;QAJrB,SAAI,GAAG,IAAI,GAAG,EAAsB,CAAC;IAKzC,CAAC;IAEE,MAAM,CAAC,OAAe;QAC5B,IAAI,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,OAAO,CAAC,CAAC;QACjC,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC;YACV,GAAG,GAAG,IAAI,UAAU,CAAC,EAAE,IAAI,EAAE,IAAI,CAAC,QAAQ,EAAE,GAAG,EAAE,OAAO,EAAE,EAAE,IAAI,CAAC,YAAY,EAAE,IAAI,CAAC,CAAC;YACrF,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,OAAO,EAAE,GAAG,CAAC,CAAC;QAC7B,CAAC;QACD,MAAM,CAAC,GAAG,CAAC;IACZ,CAAC;IAEM,uBAAuB,CAAC,MAAiC;QAC/D,IAAI,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;QACpC,EAAE,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC;YACV,EAAE,CAAC,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC;gBACnB,MAAM,IAAI,KAAK,CAAC,2CAA2C,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,KAAK,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YACrH,CAAC;YACD,GAAG,GAAG,IAAI,UAAU,CAAC,EAAE,IAAI,EAAE,IAAI,CAAC,QAAQ,EAAE,GAAG,EAAE,MAAM,CAAC,GAAG,EAAE,EAAE,IAAI,CAAC,YAAY,EAAE,MAAM,CAAC,KAAK,IAAI,IAAI,CAAC,CAAC;YACxG,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,GAAG,EAAE,GAAG,CAAC,CAAC;QAChC,CAAC;QACD,MAAM,CAAC,GAAG,CAAC,oBAAoB,CAAC,MAAM,CAAC,CAAC;IACzC,CAAC;CACD;AAED;IAIC,YACS,KAAoB,EACpB,YAAoB,EACpB,KAAsB;QAFtB,UAAK,GAAL,KAAK,CAAe;QACpB,iBAAY,GAAZ,YAAY,CAAQ;QACpB,UAAK,GAAL,KAAK,CAAiB;QANvB,OAAE,GAAG,IAAI,eAAQ,EAAE,CAAC;QACpB,cAAS,GAAqB,IAAI,CAAC;QAO1C,IAAI,CAAC,EAAE,CAAC,IAAI,GAAG,CAAC,GAAW,EAAE,EAAe;YAC3C,IAAI,CAAC,YAAY,CAAC,OAAO,EAAE,CAAC,IAAI,CAAC;gBAChC,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC;oBACjB,MAAM,IAAI,KAAK,CAAC,yEAAyE,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;gBACxH,CAAC;gBACD,IAAI,CAAC,YAAY,CAAC,WAAW,CAAC,mCAAwB,CAAC,IAAI,EAAE;oBAC5D,IAAI,EAAE,IAAI,CAAC,KAAK,CAAC,IAAI;oBACrB,GAAG,EAAE,IAAI,CAAC,KAAK,CAAC,GAAG;oBACnB,OAAO,EAAE;wBACR,OAAO,EAAE,IAAI,CAAC,KAAK,CAAC,OAAO;wBAC3B,SAAS,EAAE,IAAI,CAAC,KAAK,CAAC,SAAS;wBAC/B,GAAG;qBACH;oBACD,EAAE;iBACF,CAAC,CAAC;YACJ,CAAC,CAAC,CAAC,IAAI,CAAC,QAAmB,CAAC,EAAE,CAAC,GAAG;gBAEjC,OAAO,CAAC,KAAK,CAAC,aAAa,IAAI,CAAC,SAAS,CAAC,EAAE,CAAC,oBAAoB,GAAG,EAAE,CAAC,CAAC;YACzE,CAAC,CAAC,CAAC;QACJ,CAAC,CAAC;IACH,CAAC;IAEY,YAAY,CAAC,YAA8B;;YAEvD,EAAE,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC;gBACpB,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;gBAC/B,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC;YACnC,CAAC;YAED,IAAI,CAAC,SAAS,GAAG,YAAY,CAAC;YAC9B,EAAE,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC;gBAEpB,IAAI,CAAC,EAAE,CAAC,KAAK,GAAG,CAAC,EAAE,KAAK,IAAI,CAAC,SAAU,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;gBAClD,IAAI,CAAC,EAAE,CAAC,KAAK,CAAC,IAAI,CAAC,KAAK,IAAI,IAAI,CAAC,KAAK,CAAC,OAAO,GAAG,IAAI,CAAC,KAAK,CAAC,OAAO,GAAG,EAAE,CAAC,CAAC;gBAC1E,IAAI,CAAC,SAAS,CAAC,KAAK,CAAC,IAAI,CAAC,KAAK,IAAI,IAAI,CAAC,KAAK,CAAC,OAAO,GAAG,IAAI,CAAC,KAAK,CAAC,OAAO,GAAG,EAAE,CAAC,CAAC;gBACjF,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,EAAE,IAAI,IAAI,CAAC,aAAa,CAAC,EAAE,CAAC,CAAC,CAAC;gBAClD,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,KAAK,IAAI,IAAI,CAAC,gBAAgB,CAAC,KAAK,CAAC,CAAC,CAAC;gBAC9D,IAAI,CAAC,SAAS,CAAC,cAAc,CAAC,MAAM,IAAI,IAAI,CAAC,uBAAuB,CAAC,MAAM,CAAC,CAAC,CAAC;YAC/E,CAAC;YAAC,IAAI,CAAC,CAAC;gBACP,IAAI,CAAC,EAAE,CAAC,KAAK,GAAG,SAAS,CAAC;YAC3B,CAAC;QACF,CAAC;KAAA;IAEO,aAAa,CAAC,EAAe;QACpC,IAAI,CAAC,EAAE,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;IACpB,CAAC;IAEO,gBAAgB,CAAC,KAAmB;QAC3C,IAAI,CAAC,EAAE,CAAC,KAAK,CAAC,KAAK,GAAG,CAAC,KAAK,CAAC,GAAG,SAAS,CAAC,CAAC;QAC3C,IAAI,CAAC,YAAY,CAAC,OAAO,EAAE,CAAC,IAAI,CAAC;YAChC,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC;gBACjB,MAAM,IAAI,KAAK,CAAC,0EAA0E,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;YAC1H,CAAC;YACD,IAAI,CAAC,YAAY,CAAC,WAAW,CAAC,mCAAwB,CAAC,IAAI,EAAE;gBAC5D,IAAI,EAAE,IAAI,CAAC,KAAK,CAAC,IAAI;gBACrB,GAAG,EAAE,IAAI,CAAC,KAAK,CAAC,GAAG;gBACnB,KAAK,EAAE,IAAI;gBACX,KAAK,EAAE;oBACN,OAAO,EAAE,IAAI,CAAC,KAAK,CAAC,OAAO;oBAC3B,SAAS,EAAE,IAAI,CAAC,KAAK,CAAC,SAAS;oBAC/B,OAAO,EAAE,KAAK,GAAG,CAAC,KAAK,CAAC,GAAG,EAAE;iBAC7B;aACD,CAAC,CAAC;QACJ,CAAC,CAAC,CAAC,IAAI,CAAC,QAAmB,CAAC,EAAE,CAAC,GAAG;YAEjC,OAAO,CAAC,KAAK,CAAC,cAAc,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,KAAK,CAAC,kBAAkB,GAAG,GAAG,CAAC,CAAC;QACjF,CAAC,CAAC,CAAC;IACJ,CAAC;IAEO,uBAAuB,CAAC,MAAmC;QAClE,MAAM,CAAC,IAAI,CAAC,YAAY,CAAC,OAAO,EAAE,CAAC,IAAI,CAAC;YACvC,MAAM,CAAC,IAAI,CAAC,YAAY,CAAC,WAAW,CAAC,uCAA4B,CAAC,IAAI,EAAE,MAAM,CAAC,CAAC;QACjF,CAAC,CAAC,CAAC,IAAI,CAAC,QAAmB,CAAC,EAAE,CAAC,GAAG;YAEjC,OAAO,CAAC,KAAK,CAAC,cAAc,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,KAAK,CAAC,6BAA6B,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,YAAY,GAAG,GAAG,CAAC,CAAC;QAC9H,CAAC,CAAC,CAAC;IACJ,CAAC;IAEY,oBAAoB,CAAC,MAAiC;;YAClE,OAAO,CAAC,GAAG,CAAC,WAAW,OAAO,CAAC,GAAG,CAAC,YAAY,aAAa,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;YACvF,EAAE,CAAC,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC;gBAChB,EAAE,CAAC,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC,CAAC;oBACf,IAAI,CAAC,EAAE,CAAC,GAAG,EAAE,CAAC;gBACf,CAAC;YACF,CAAC;YAAC,IAAI,CAAC,EAAE,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC;gBACzB,IAAI,CAAC,KAAK,GAAG,MAAM,CAAC,KAAK,CAAC;gBAC1B,IAAI,CAAC,EAAE,CAAC,KAAK,CAAC,MAAM,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC;gBACpC,EAAE,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC,CAAC;oBACpB,MAAM,IAAI,CAAC,SAAS,CAAC,KAAK,CAAC,MAAM,CAAC,KAAK,CAAC,OAAQ,CAAC,CAAC;gBACnD,CAAC;YACF,CAAC;YAAC,IAAI,CAAC,EAAE,CAAC,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC,CAAC;gBACtB,MAAM,IAAI,CAAC,EAAE,CAAC,IAAI,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YAC/B,CAAC;YAAC,IAAI,CAAC,EAAE,CAAC,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC;gBAC1B,MAAM,IAAI,KAAK,CAAC,mCAAmC,CAAC,CAAC;YACtD,CAAC;YAAC,IAAI,CAAC,CAAC;gBACP,MAAM,IAAI,KAAK,CAAC,yBAAyB,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;YACrE,CAAC;YACD,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,CAAC,CAAC;QAC5B,CAAC;KAAA;CACD"}

package.json

 {
   "name": "libzap",
-  "version": "0.0.14",
+  "version": "0.0.15",
   "description": "JavaScript library for Zap",
@@ -5,0 +5,0 @@ "license": "none",

src/remote/handler.ts

@@ -41,4 +41,4 @@ import { Client as OTClient } from "../ot/client";
 
-	public attachWorkspace(refID: RefIdentifier, workspace: Workspace | null): void {
-		this.getRepo(refID.repo).getRef(refID.ref).setWorkspace(workspace);
+	public async attachWorkspace(refID: RefIdentifier, workspace: Workspace | null): Promise<void> {
+		await this.getRepo(refID.repo).getRef(refID.ref).setWorkspace(workspace);
 	}
@@ -131,7 +131,3 @@
 
-	public setWorkspace(newWorkspace: Workspace | null): void {
-		if (newWorkspace && this.ot.rev !== 0) {
-			console.log("buffering history is not yet implemented (workspace attached when the ref already has history); proceeding, but the results might be incorrect");
-		}
-
+	public async setWorkspace(newWorkspace: Workspace | null): Promise<void> {
 		// Remove listeners from old workspace.
@@ -147,3 +143,4 @@ if (this.workspace) {
 			this.ot.apply = (op) => this.workspace!.apply(op);
-			this.workspace.reset([]);
+			this.ot.reset(this.state && this.state.history ? this.state.history : []);
+			this.workspace.reset(this.state && this.state.history ? this.state.history : []);
 			this.workspace.onOp(op => this.onWorkspaceOp(op));
@@ -165,3 +162,3 @@ this.workspace.onReset(newOp => this.onWorkspaceReset(newOp));
 			if (!this.state) {
-				throw new Error(`attempt to send ref/update request from ref with uninitialized state: ${JSON.stringify(this.refID)}`);
+				throw new Error(`attempt to send ref/ update request from ref with uninitialized state: ${JSON.stringify(this.refID)} `);
 			}
@@ -180,3 +177,3 @@ this.remoteClient.sendRequest(RefUpdateUpstreamRequest.type, {
 			// TODO@ handle ops that didn't send properly
-			console.error(`ERROR: ref ${JSON.stringify(this.refID)} reset failed: ${err}`);
+			console.error(`ERROR: ref ${JSON.stringify(this.refID)} reset failed: ${err} `);
 		});
@@ -190,3 +187,3 @@ }
 			// TODO@ handle ops that didn't send properly
-			console.error(`ERROR: ref ${JSON.stringify(this.refID)} workspace/willSaveFile ${JSON.stringify(params)} failed: ${err}`);
+			console.error(`ERROR: ref ${JSON.stringify(this.refID)} workspace / willSaveFile ${JSON.stringify(params)} failed: ${err} `);
 		});
@@ -196,3 +193,3 @@ }
 	public async onUpdateFromUpstream(params: RefUpdateDownstreamParams): Promise<any> {
-		console.log(`client=${process.env.ZAP_E2E_NAME}: UPDATE: ${JSON.stringify(params)}`);
+		console.log(`client= ${process.env.ZAP_E2E_NAME}: UPDATE: ${JSON.stringify(params)} `);
 		if (params.ack) {
@@ -213,3 +210,3 @@ if (params.op) {
 		} else {
-			throw new Error(`unhandled ref update: ${JSON.stringify(params)}`);
+			throw new Error(`unhandled ref update: ${JSON.stringify(params)} `);
 		}
@@ -216,0 +213,0 @@ return Promise.resolve({});

New alerts

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 2 instances in 1 package

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Fixed alerts

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 2 instances in 1 package

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

235443

3.97%

Number of package files

63

5%

Lines of code

4578

3.65%

No dependency changes