New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@therms/rpc-client

Package Overview
Dependencies
Maintainers
5
Versions
84
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@therms/rpc-client - npm Package Compare versions

Comparing version 2.5.4 to 2.6.0

8

CHANGELOG.md

@@ -0,1 +1,9 @@

# [2.6.0](https://bitbucket.org/thermsio/rpc-client-ts/compare/v2.5.4...v2.6.0) (2022-06-11)
### Features
* add RPCClient.setIdentityMetadata() ([2f083f4](https://bitbucket.org/thermsio/rpc-client-ts/commits/2f083f46d063d201f326ab95f06ff20610e5e4f6))
* update deps ([782c0c0](https://bitbucket.org/thermsio/rpc-client-ts/commits/782c0c00a3223d29e7bda3f135917009bc28994d))
## [2.5.4](https://bitbucket.org/thermsio/rpc-client-ts/compare/v2.5.3...v2.5.4) (2022-05-22)

@@ -2,0 +10,0 @@

6

dist/cache/BrowserStorageCache.js

@@ -1,2 +0,2 @@

export class BrowserCache {
class BrowserCache {
constructor(cacheOptions) {

@@ -15,2 +15,4 @@ this.cacheOptions = cacheOptions;

BrowserCache.DEFAULT_CACHE_MAX_SIZE = 100;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiQnJvd3NlclN0b3JhZ2VDYWNoZS5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3NyYy9jYWNoZS9Ccm93c2VyU3RvcmFnZUNhY2hlLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQWFBLE1BQU0sT0FBTyxZQUFZO0lBSXZCLFlBQXFCLFlBQWtDO1FBQWxDLGlCQUFZLEdBQVosWUFBWSxDQUFzQjtJQUFHLENBQUM7SUFFM0QsVUFBVTtJQUVWLENBQUM7SUFFRCxpQkFBaUIsQ0FBQyxPQUF1QjtRQUV2QyxPQUFPLFNBQVMsQ0FBQTtJQUNsQixDQUFDO0lBRUQsaUJBQWlCLENBQUMsT0FBdUIsRUFBRSxRQUF5QjtJQUVwRSxDQUFDOztBQWhCTSxxQ0FBd0IsR0FBRyxJQUFJLEdBQUcsRUFBRSxHQUFHLENBQUMsQ0FBQTtBQUN4QyxtQ0FBc0IsR0FBRyxHQUFHLENBQUEifQ==
export { BrowserCache };
//# sourceMappingURL=BrowserStorageCache.js.map
import LRU from 'lru-cache';
import { makeCallRequestKey } from '../utils/cache-utils';
import { GetDebugLogger } from '../utils/debug-logger';
import { makeCallRequestKey } from '../utils/cache-utils.js';
import { GetDebugLogger } from '../utils/debug-logger.js';
const debug = GetDebugLogger('rpc:InMemoryCache');
export class InMemoryCache {
class InMemoryCache {
constructor(cacheOptions) {

@@ -40,2 +41,4 @@ this.clearCache = () => {

InMemoryCache.DEFAULT_CACHE_MAX_SIZE = 100;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiSW5NZW1vcnlDYWNoZS5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3NyYy9jYWNoZS9Jbk1lbW9yeUNhY2hlLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBLE9BQU8sR0FBRyxNQUFNLFdBQVcsQ0FBQTtBQUkzQixPQUFPLEVBQUUsa0JBQWtCLEVBQUUsTUFBTSxzQkFBc0IsQ0FBQTtBQUN6RCxPQUFPLEVBQUUsY0FBYyxFQUFFLE1BQU0sdUJBQXVCLENBQUE7QUFFdEQsTUFBTSxLQUFLLEdBQUcsY0FBYyxDQUFDLG1CQUFtQixDQUFDLENBQUE7QUFPakQsTUFBTSxPQUFPLGFBQWE7SUFNeEIsWUFBWSxZQUFtQztRQVEvQyxlQUFVLEdBQUcsR0FBUyxFQUFFOztZQUN0QixLQUFLLENBQUMsWUFBWSxDQUFDLENBQUE7WUFDbkIsTUFBQSxJQUFJLENBQUMsc0JBQXNCLDBDQUFFLEtBQUssRUFBRSxDQUFBO1FBQ3RDLENBQUMsQ0FBQTtRQUVELHNCQUFpQixHQUFHLENBQ2xCLE9BQXVCLEVBQ00sRUFBRTs7WUFDL0IsS0FBSyxDQUFDLDBCQUEwQixFQUFFLE9BQU8sQ0FBQyxDQUFBO1lBRTFDLElBQUksY0FBYyxHQUFHLE1BQUEsSUFBSSxDQUFDLHNCQUFzQiwwQ0FBRSxHQUFHLENBQ25ELGtCQUFrQixDQUFDLE9BQU8sQ0FBQyxDQUM1QixDQUFBO1lBRUQsSUFBSSxPQUFPLGNBQWMsS0FBSyxRQUFRLEVBQUU7Z0JBQ3RDLGNBQWMsR0FBRyxJQUFJLENBQUMsS0FBSyxDQUFDLGNBQWMsQ0FBQyxDQUFBO2FBQzVDO1lBRUQsT0FBTyxjQUFjLENBQUE7UUFDdkIsQ0FBQyxDQUFBO1FBRUQsc0JBQWlCLEdBQUcsQ0FBQyxPQUF1QixFQUFFLFFBQXlCLEVBQUUsRUFBRTs7WUFDekUsS0FBSyxDQUFDLG1CQUFtQixFQUFFLE9BQU8sRUFBRSxRQUFRLENBQUMsQ0FBQTtZQUU3QyxNQUFNLFVBQVUsR0FBRyxrQkFBa0IsQ0FBQyxPQUFPLENBQUMsQ0FBQTtZQUU5QyxJQUFJLENBQUMsUUFBUSxFQUFFO2dCQUNiLE9BQU8sTUFBQSxJQUFJLENBQUMsc0JBQXNCLDBDQUFFLEdBQUcsQ0FBQyxVQUFVLENBQUMsQ0FBQTthQUNwRDtZQUVELE1BQU0sY0FBYyxxQkFBUSxRQUFRLENBQUUsQ0FBQTtZQUN0QyxPQUFPLGNBQWMsQ0FBQyxhQUFhLENBQUE7WUFFbkMsTUFBQSxJQUFJLENBQUMsc0JBQXNCLDBDQUFFLEdBQUcsQ0FDOUIsVUFBVSxFQUNWLGNBQWMsQ0FBQyxDQUFDLENBQUMsSUFBSSxDQUFDLFNBQVMsQ0FBQyxjQUFjLENBQUMsQ0FBQyxDQUFDLENBQUMsU0FBUyxDQUM1RCxDQUFBO1FBQ0gsQ0FBQyxDQUFBO1FBNUNDLElBQUksQ0FBQyxzQkFBc0IsR0FBRyxJQUFJLEdBQUcsQ0FBQztZQUNwQyxHQUFHLEVBQUUsQ0FBQSxZQUFZLGFBQVosWUFBWSx1QkFBWixZQUFZLENBQUUsWUFBWSxLQUFJLGFBQWEsQ0FBQyxzQkFBc0I7WUFDdkUsR0FBRyxFQUNELENBQUEsWUFBWSxhQUFaLFlBQVksdUJBQVosWUFBWSxDQUFFLGFBQWEsS0FBSSxhQUFhLENBQUMsd0JBQXdCO1NBQ3hFLENBQUMsQ0FBQTtJQUNKLENBQUM7O0FBWE0sc0NBQXdCLEdBQUcsSUFBSSxHQUFHLEVBQUUsR0FBRyxDQUFDLENBQUE7QUFDeEMsb0NBQXNCLEdBQUcsR0FBRyxDQUFBIn0=
export { InMemoryCache };
//# sourceMappingURL=InMemoryCache.js.map

@@ -1,4 +0,4 @@

export const DEFAULT_REQUEST_SCOPE = 'global';
export const DEFAULT_REQUEST_VERSION = '1';
export class CallRequestDTO {
const DEFAULT_REQUEST_SCOPE = 'global';
const DEFAULT_REQUEST_VERSION = '1';
class CallRequestDTO {
constructor(call) {

@@ -32,2 +32,4 @@ const { args, correlationId, identity, procedure, scope, version } = call;

}
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiQ2FsbFJlcXVlc3REVE8uanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi9zcmMvQ2FsbFJlcXVlc3REVE8udHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IkFBQUEsTUFBTSxDQUFDLE1BQU0scUJBQXFCLEdBQUcsUUFBUSxDQUFBO0FBQzdDLE1BQU0sQ0FBQyxNQUFNLHVCQUF1QixHQUFHLEdBQUcsQ0FBQTtBQWUxQyxNQUFNLE9BQU8sY0FBYztJQVl6QixZQUFZLElBQTBCO1FBQ3BDLE1BQU0sRUFBRSxJQUFJLEVBQUUsYUFBYSxFQUFFLFFBQVEsRUFBRSxTQUFTLEVBQUUsS0FBSyxFQUFFLE9BQU8sRUFBRSxHQUFHLElBQUksQ0FBQTtRQUV6RSxJQUFJLENBQUMsSUFBSSxHQUFHLElBQUksQ0FBQTtRQUVoQixJQUFJLGFBQWEsSUFBSSxPQUFPLGFBQWEsS0FBSyxRQUFRO1lBQ3BELE1BQU0sSUFBSSxLQUFLLENBQUMsZ0NBQWdDLENBQUMsQ0FBQTtRQUVuRCxJQUFJLENBQUMsYUFBYSxHQUFHLGFBQWEsSUFBSSxJQUFJLENBQUMsTUFBTSxFQUFFLENBQUMsUUFBUSxFQUFFLENBQUE7UUFFOUQsSUFBSSxRQUFRLEVBQUU7WUFDWixJQUFJLE9BQU8sUUFBUSxLQUFLLFFBQVE7Z0JBQzlCLE1BQU0sSUFBSSxLQUFLLENBQUMsNEJBQTRCLENBQUMsQ0FBQTtZQUMvQyxJQUFJLFFBQVEsQ0FBQyxhQUFhLElBQUksT0FBTyxRQUFRLENBQUMsYUFBYSxLQUFLLFFBQVE7Z0JBQ3RFLE1BQU0sSUFBSSxLQUFLLENBQUMseUNBQXlDLENBQUMsQ0FBQTtZQUM1RCxJQUFJLFFBQVEsQ0FBQyxVQUFVLElBQUksT0FBTyxRQUFRLENBQUMsVUFBVSxLQUFLLFFBQVE7Z0JBQ2hFLE1BQU0sSUFBSSxLQUFLLENBQUMsc0NBQXNDLENBQUMsQ0FBQTtZQUN6RCxJQUFJLFFBQVEsQ0FBQyxRQUFRLElBQUksT0FBTyxRQUFRLENBQUMsUUFBUSxLQUFLLFFBQVE7Z0JBQzVELE1BQU0sSUFBSSxLQUFLLENBQUMsb0NBQW9DLENBQUMsQ0FBQTtZQUV2RCxJQUFJLENBQUMsUUFBUSxHQUFHLFFBQVEsQ0FBQTtTQUN6QjtRQUVELElBQUksU0FBUyxJQUFJLE9BQU8sU0FBUyxLQUFLLFFBQVE7WUFDNUMsTUFBTSxJQUFJLEtBQUssQ0FBQywwQkFBMEIsQ0FBQyxDQUFBO1FBQzdDLElBQUksQ0FBQyxTQUFTLEdBQUcsU0FBUyxDQUFBO1FBRTFCLElBQUksS0FBSyxJQUFJLE9BQU8sS0FBSyxLQUFLLFFBQVE7WUFDcEMsTUFBTSxJQUFJLEtBQUssQ0FBQyxzQkFBc0IsQ0FBQyxDQUFBO1FBRXpDLElBQUksQ0FBQyxLQUFLLEdBQUcsS0FBSyxDQUFBO1FBQ2xCLElBQUksT0FBTyxJQUFJLE9BQU8sT0FBTyxLQUFLLFFBQVE7WUFDeEMsTUFBTSxJQUFJLEtBQUssQ0FBQyx3QkFBd0IsQ0FBQyxDQUFBO1FBRTNDLElBQUksQ0FBQyxPQUFPLEdBQUcsT0FBTyxDQUFBO0lBQ3hCLENBQUM7Q0FDRiJ9
export { CallRequestDTO, DEFAULT_REQUEST_SCOPE, DEFAULT_REQUEST_VERSION };
//# sourceMappingURL=CallRequestDTO.js.map

@@ -1,2 +0,2 @@

export class CallResponseDTO {
class CallResponseDTO {
constructor(response) {

@@ -19,2 +19,4 @@ const { code, correlationId, data, message, success } = response;

}
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiQ2FsbFJlc3BvbnNlRFRPLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vc3JjL0NhbGxSZXNwb25zZURUTy50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiQUFRQSxNQUFNLE9BQU8sZUFBZTtJQU8xQixZQUFZLFFBQStCO1FBQ3pDLE1BQU0sRUFBRSxJQUFJLEVBQUUsYUFBYSxFQUFFLElBQUksRUFBRSxPQUFPLEVBQUUsT0FBTyxFQUFFLEdBQUcsUUFBUSxDQUFBO1FBRWhFLElBQUksT0FBTyxJQUFJLEtBQUssUUFBUTtZQUFFLE1BQU0sSUFBSSxLQUFLLENBQUMsdUJBQXVCLENBQUMsQ0FBQTtRQUN0RSxJQUFJLENBQUMsSUFBSSxHQUFHLElBQUksQ0FBQTtRQUVoQixJQUFJLGFBQWEsSUFBSSxPQUFPLGFBQWEsS0FBSyxRQUFRO1lBQ3BELE1BQU0sSUFBSSxLQUFLLENBQUMsZ0NBQWdDLENBQUMsQ0FBQTtRQUNuRCxJQUFJLENBQUMsYUFBYSxHQUFHLGFBQWEsQ0FBQTtRQUVsQyxJQUFJLENBQUMsSUFBSSxHQUFHLElBQUksQ0FBQTtRQUVoQixJQUFJLE9BQU8sSUFBSSxPQUFPLE9BQU8sS0FBSyxRQUFRO1lBQ3hDLE1BQU0sSUFBSSxLQUFLLENBQUMsMEJBQTBCLENBQUMsQ0FBQTtRQUM3QyxJQUFJLENBQUMsT0FBTyxHQUFHLE9BQU8sQ0FBQTtRQUV0QixJQUFJLE9BQU8sT0FBTyxLQUFLLFNBQVM7WUFDOUIsTUFBTSxJQUFJLEtBQUssQ0FBQywyQkFBMkIsQ0FBQyxDQUFBO1FBQzlDLElBQUksQ0FBQyxPQUFPLEdBQUcsT0FBTyxDQUFBO0lBQ3hCLENBQUM7Q0FDRiJ9
export { CallResponseDTO };
//# sourceMappingURL=CallResponseDTO.js.map

@@ -14,3 +14,3 @@ 'use strict';

/*! *****************************************************************************
/******************************************************************************
Copyright (c) Microsoft Corporation.

@@ -489,7 +489,7 @@

});
this.setIdentity = (identity) => {
this.setIdentity = (identity) => __awaiter(this, void 0, void 0, function* () {
debug('setIdentity', identity);
if (!identity) {
this.identity = undefined;
this.resetConnection();
yield this.resetConnection();
return;

@@ -504,2 +504,6 @@ }

}
else if (this.isWaitingForIdentityConfirmation) {
debug('setIdentity returning early because "this.isWaitingForIdentityConfirmation=true"');
return;
}
this.isWaitingForIdentityConfirmation = true;

@@ -516,3 +520,3 @@ this.send({ identity })

});
};
});
this.connect = () => {

@@ -528,7 +532,4 @@ debug('connect', this.host);

ws.onopen = () => {
console.log('WebSocket connected:');
console.info('WebSocket connected');
this.setConnectedToRemote(true);
if (this.identity) {
this.setIdentity(this.identity);
}
};

@@ -540,3 +541,3 @@ ws.onmessage = (msg) => {

if (this.connectedToRemote) {
console.log('WebSocket closed', e.reason);
console.info('WebSocket closed', e.reason);
}

@@ -561,3 +562,3 @@ else {

if (this.connectedToRemote) {
console.error('Socket encountered error: ', err);
console.error('WebSocket encountered error: ', err);
}

@@ -570,3 +571,3 @@ else {

};
this.disconnect = () => {
this.disconnect = (reason) => {
var _a;

@@ -576,3 +577,3 @@ debug('disconnect');

this.isWaitingForIdentityConfirmation = false;
(_a = this.websocket) === null || _a === void 0 ? void 0 : _a.close();
(_a = this.websocket) === null || _a === void 0 ? void 0 : _a.close(1000, reason);
this.websocket = undefined;

@@ -603,7 +604,8 @@ this.websocketId = undefined;

};
this.resetConnection = () => {
this.resetConnection = () => __awaiter(this, void 0, void 0, function* () {
debug('resetConnection');
this.disconnect();
this.disconnect('WebSocketTransport#resetConnection');
yield sleep(100);
this.connect();
};
});
this.send = (call) => __awaiter(this, void 0, void 0, function* () {

@@ -622,2 +624,3 @@ var _a;

this.setConnectedToRemote = (connected) => {
debug(`setConnectedToRemote: ${connected}`);
this.connectedToRemote = connected;

@@ -627,2 +630,5 @@ if (this.options.onConnectionStatusChange) {

}
if (connected && this.identity) {
this.setIdentity(this.identity);
}
};

@@ -759,5 +765,14 @@ debug('new WebSocketTransport()');

this.setIdentity = (identity) => {
let newIdentity = lodashEs.cloneDeep(identity);
this.identity = identity;
this.callManager.setIdentity(identity);
this.callManager.setIdentity(newIdentity);
};
this.setIdentityMetadata = (metadata) => {
var _a;
(_a = this.identity) !== null && _a !== void 0 ? _a : (this.identity = {});
const newIdentity = lodashEs.cloneDeep(this.identity);
newIdentity.metadata = metadata;
this.identity.metadata = metadata;
this.callManager.setIdentity(newIdentity);
};
if (!((_a = options === null || options === void 0 ? void 0 : options.hosts) === null || _a === void 0 ? void 0 : _a.http) && !((_b = options === null || options === void 0 ? void 0 : options.transports) === null || _b === void 0 ? void 0 : _b.http)) {

@@ -764,0 +779,0 @@ throw new Error(ERRORS.HTTP_HOST_OR_TRANSPORT_REQUIRED);

@@ -1,3 +0,5 @@

export class CallRequestError extends Error {
class CallRequestError extends Error {
}
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiQ2FsbFJlcXVlc3RFcnJvci5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3NyYy9lcnJvcnMvQ2FsbFJlcXVlc3RFcnJvci50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiQUFBQSxNQUFNLE9BQU8sZ0JBQWlCLFNBQVEsS0FBSztDQUFHIn0=
export { CallRequestError };
//# sourceMappingURL=CallRequestError.js.map

@@ -1,3 +0,3 @@

export { RPCClient } from './RPCClient';
export { CallResponseDTO as RPCResponse } from './CallResponseDTO';
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi9zcmMvaW5kZXgudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IkFBQUEsT0FBTyxFQUFFLFNBQVMsRUFBb0IsTUFBTSxhQUFhLENBQUE7QUFLekQsT0FBTyxFQUFFLGVBQWUsSUFBSSxXQUFXLEVBQUUsTUFBTSxtQkFBbUIsQ0FBQSJ9
export { RPCClient } from './RPCClient.js';
export { CallResponseDTO as RPCResponse } from './CallResponseDTO.js';
//# sourceMappingURL=index.js.map

@@ -1,18 +0,11 @@

var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
import { CallRequestError } from '../errors/CallRequestError';
import { CallRequestTransportError } from '../transports/errors/CallRequestTransportError';
import { ManagerCallRequestTimeoutError } from './errors/ManagerCallRequestTimeoutError';
import { makeCallRequestKey } from '../utils/cache-utils';
import { __awaiter } from '../node_modules/tslib/tslib.es6.js';
import { CallRequestError } from '../errors/CallRequestError.js';
import { CallRequestTransportError } from '../transports/errors/CallRequestTransportError.js';
import { ManagerCallRequestTimeoutError } from './errors/ManagerCallRequestTimeoutError.js';
import { makeCallRequestKey } from '../utils/cache-utils.js';
import { cloneDeep } from 'lodash-es';
import { GetDebugLogger } from '../utils/debug-logger';
import { GetDebugLogger } from '../utils/debug-logger.js';
const debug = GetDebugLogger('rpc:ClientManager');
export class ClientManager {
class ClientManager {
constructor(options) {

@@ -174,2 +167,4 @@ this.options = options;

}
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiQ2xpZW50TWFuYWdlci5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3NyYy9tYW5hZ2VyL0NsaWVudE1hbmFnZXIudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7Ozs7Ozs7O0FBSUEsT0FBTyxFQUFFLGdCQUFnQixFQUFFLE1BQU0sNEJBQTRCLENBQUE7QUFDN0QsT0FBTyxFQUFFLHlCQUF5QixFQUFFLE1BQU0sZ0RBQWdELENBQUE7QUFDMUYsT0FBTyxFQUFFLDhCQUE4QixFQUFFLE1BQU0seUNBQXlDLENBQUE7QUFHeEYsT0FBTyxFQUFFLGtCQUFrQixFQUFFLE1BQU0sc0JBQXNCLENBQUE7QUFFekQsT0FBTyxFQUFFLFNBQVMsRUFBRSxNQUFNLFdBQVcsQ0FBQTtBQUNyQyxPQUFPLEVBQUUsY0FBYyxFQUFFLE1BQU0sdUJBQXVCLENBQUE7QUFFdEQsTUFBTSxLQUFLLEdBQUcsY0FBYyxDQUFDLG1CQUFtQixDQUFDLENBQUE7QUFvQmpELE1BQU0sT0FBTyxhQUFhO0lBWXhCLFlBQXFCLE9BQTZCO1FBQTdCLFlBQU8sR0FBUCxPQUFPLENBQXNCO1FBVjFDLHVCQUFrQixHQUFnRCxFQUFFLENBQUE7UUFDcEUsaUJBQVksR0FHaEI7WUFDRixPQUFPLEVBQUUsRUFBRTtZQUNYLFFBQVEsRUFBRSxFQUFFO1NBQ2IsQ0FBQTtRQWlCTSwyQkFBc0IsR0FBRyxDQUFDLFdBQW9DLEVBQUUsRUFBRTtZQUN2RSxJQUFJLE9BQU8sV0FBVyxLQUFLLFVBQVU7Z0JBQ25DLE1BQU0sSUFBSSxLQUFLLENBQUMsK0NBQStDLENBQUMsQ0FBQTtZQUNsRSxJQUFJLENBQUMsWUFBWSxDQUFDLFFBQVEsQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUE7UUFDOUMsQ0FBQyxDQUFBO1FBRU0sMEJBQXFCLEdBQUcsQ0FBQyxXQUFtQyxFQUFFLEVBQUU7WUFDckUsSUFBSSxPQUFPLFdBQVcsS0FBSyxVQUFVO2dCQUNuQyxNQUFNLElBQUksS0FBSyxDQUFDLCtDQUErQyxDQUFDLENBQUE7WUFDbEUsSUFBSSxDQUFDLFlBQVksQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLFdBQVcsQ0FBQyxDQUFBO1FBQzdDLENBQUMsQ0FBQTtRQUVNLGVBQVUsR0FBRyxDQUFDLE9BQXdCLEVBQUUsRUFBRTtZQUMvQyxLQUFLLENBQUMsWUFBWSxDQUFDLENBQUE7WUFFbkIsSUFBSSxDQUFDLElBQUksQ0FBQyxLQUFLO2dCQUFFLE9BQU07WUFFdkIsSUFBSSxPQUFPLEVBQUU7Z0JBQ1gsSUFBSSxDQUFDLEtBQUssQ0FBQyxpQkFBaUIsQ0FBQyxPQUFPLEVBQUUsU0FBUyxDQUFDLENBQUE7YUFDakQ7aUJBQU07Z0JBQ0wsSUFBSSxDQUFDLEtBQUssQ0FBQyxVQUFVLEVBQUUsQ0FBQTthQUN4QjtRQUNILENBQUMsQ0FBQTtRQUVNLHNCQUFpQixHQUFHLENBQUMsT0FBdUIsRUFBRSxFQUFFOztZQUNyRCxLQUFLLENBQUMsbUJBQW1CLEVBQUUsT0FBTyxDQUFDLENBQUE7WUFFbkMsT0FBTyxNQUFBLElBQUksYUFBSixJQUFJLHVCQUFKLElBQUksQ0FBRSxLQUFLLDBDQUFFLGlCQUFpQixDQUFDLE9BQU8sQ0FBQyxDQUFBO1FBQ2hELENBQUMsQ0FBQTtRQUVNLHlCQUFvQixHQUFHLEdBQUcsRUFBRTtZQUNqQyxLQUFLLENBQUMsc0JBQXNCLENBQUMsQ0FBQTtZQUU3QixPQUFPLE1BQU0sQ0FBQyxJQUFJLENBQUMsSUFBSSxDQUFDLGtCQUFrQixDQUFDLENBQUMsTUFBTSxDQUFBO1FBQ3BELENBQUMsQ0FBQTtRQUVNLHdCQUFtQixHQUFHLENBQU8sZUFBK0IsRUFBRSxFQUFFO1lBQ3JFLEtBQUssQ0FBQyxxQkFBcUIsRUFBRSxlQUFlLENBQUMsQ0FBQTtZQUc3QyxNQUFNLE9BQU8sR0FBRyxNQUFNLElBQUksQ0FBQyx1QkFBdUIsQ0FBQyxlQUFlLENBQUMsQ0FBQTtZQUVuRSxNQUFNLEdBQUcsR0FBRyxrQkFBa0IsQ0FBQyxPQUFPLENBQUMsQ0FBQTtZQUV2QyxJQUFJLElBQUksQ0FBQyxrQkFBa0IsQ0FBQyxjQUFjLENBQUMsR0FBRyxDQUFDLEVBQUU7Z0JBQy9DLEtBQUssQ0FBQyxzREFBc0QsRUFBRSxHQUFHLENBQUMsQ0FBQTtnQkFFbEUsT0FBTyxJQUFJLENBQUMsa0JBQWtCLENBQUMsR0FBRyxDQUFDLENBQUMsSUFBSSxDQUFDLENBQUMsR0FBb0IsRUFBRSxFQUFFO29CQUNoRSxNQUFNLFFBQVEsR0FBRyxTQUFTLENBQUMsR0FBRyxDQUFDLENBQUE7b0JBRS9CLElBQUksZUFBZSxDQUFDLGFBQWEsRUFBRTt3QkFDakMsUUFBUSxDQUFDLGFBQWEsR0FBRyxlQUFlLENBQUMsYUFBYSxDQUFBO3FCQUN2RDtvQkFFRCxPQUFPLFFBQVEsQ0FBQTtnQkFDakIsQ0FBQyxDQUFDLENBQUE7YUFDSDtZQUVELE1BQU0scUJBQXFCLEdBQUcsR0FBUyxFQUFFO2dCQUN2QyxNQUFNLGlCQUFpQixHQUFHLE1BQU0sSUFBSSxDQUFDLHdCQUF3QixDQUFDLE9BQU8sQ0FBQyxDQUFBO2dCQUd0RSxNQUFNLFFBQVEsR0FBRyxNQUFNLElBQUksQ0FBQyx3QkFBd0IsQ0FDbEQsaUJBQWlCLEVBQ2pCLE9BQU8sQ0FDUixDQUFBO2dCQUVELElBQUksSUFBSSxDQUFDLEtBQUssSUFBSSxRQUFRLEVBQUU7b0JBQzFCLElBQUksQ0FBQyxLQUFLLENBQUMsaUJBQWlCLENBQUMsT0FBTyxFQUFFLFFBQVEsQ0FBQyxDQUFBO2lCQUNoRDtnQkFFRCxPQUFPLFFBQVEsQ0FBQTtZQUNqQixDQUFDLENBQUEsQ0FBQTtZQUVELE1BQU0sY0FBYyxHQUFHLHFCQUFxQixFQUFFO2lCQUMzQyxJQUFJLENBQUMsQ0FBQyxRQUFRLEVBQUUsRUFBRTtnQkFDakIsT0FBTyxJQUFJLENBQUMsa0JBQWtCLENBQUMsR0FBRyxDQUFDLENBQUE7Z0JBRW5DLE9BQU8sUUFBUSxDQUFBO1lBQ2pCLENBQUMsQ0FBQztpQkFDRCxLQUFLLENBQUMsQ0FBQyxHQUFHLEVBQUUsRUFBRTtnQkFDYixPQUFPLElBQUksQ0FBQyxrQkFBa0IsQ0FBQyxHQUFHLENBQUMsQ0FBQTtnQkFFbkMsTUFBTSxHQUFHLENBQUE7WUFDWCxDQUFDLENBQUMsQ0FBQTtZQUVKLElBQUksQ0FBQyxrQkFBa0IsQ0FBQyxHQUFHLENBQUMsR0FBRyxjQUFjLENBQUE7WUFFN0MsT0FBTyxNQUFNLGNBQWMsQ0FBQTtRQUM3QixDQUFDLENBQUEsQ0FBQTtRQUVNLGdCQUFXLEdBQUcsQ0FBQyxRQUE0QixFQUFFLEVBQUU7WUFDcEQsS0FBSyxDQUFDLGFBQWEsRUFBRSxRQUFRLENBQUMsQ0FBQTtZQUU5QixJQUFJLENBQUMsVUFBVSxDQUFDLE9BQU8sQ0FBQyxDQUFDLFNBQVMsRUFBRSxFQUFFLENBQUMsU0FBUyxDQUFDLFdBQVcsQ0FBQyxRQUFRLENBQUMsQ0FBQyxDQUFBO1FBQ3pFLENBQUMsQ0FBQTtRQUVPLDRCQUF1QixHQUFHLENBQ2hDLGVBQStCLEVBQ04sRUFBRTtZQUMzQixJQUFJLE9BQU8sR0FBRyxlQUFlLENBQUE7WUFFN0IsSUFBSSxJQUFJLENBQUMsWUFBWSxDQUFDLE9BQU8sQ0FBQyxNQUFNLEVBQUU7Z0JBQ3BDLEtBQUssQ0FBQyw4Q0FBOEMsRUFBRSxlQUFlLENBQUMsQ0FBQTtnQkFFdEUsS0FBSyxNQUFNLFdBQVcsSUFBSSxJQUFJLENBQUMsWUFBWSxDQUFDLE9BQU8sRUFBRTtvQkFDbkQsT0FBTyxHQUFHLE1BQU0sV0FBVyxDQUFDLE9BQU8sQ0FBQyxDQUFBO2lCQUNyQzthQUNGO1lBRUQsT0FBTyxPQUFPLENBQUE7UUFDaEIsQ0FBQyxDQUFBLENBQUE7UUFFTyw2QkFBd0IsR0FBRyxDQUNqQyxnQkFBaUMsRUFDakMsT0FBdUIsRUFDRyxFQUFFO1lBQzVCLElBQUksUUFBUSxHQUFHLGdCQUFnQixDQUFBO1lBRS9CLElBQUksSUFBSSxDQUFDLFlBQVksQ0FBQyxRQUFRLENBQUMsTUFBTSxFQUFFO2dCQUNyQyxLQUFLLENBQUMsMEJBQTBCLEVBQUUsT0FBTyxFQUFFLGdCQUFnQixDQUFDLENBQUE7Z0JBRTVELEtBQUssTUFBTSxXQUFXLElBQUksSUFBSSxDQUFDLFlBQVksQ0FBQyxRQUFRLEVBQUU7b0JBQ3BELElBQUk7d0JBQ0YsUUFBUSxHQUFHLE1BQU0sV0FBVyxDQUFDLFFBQVEsRUFBRSxPQUFPLENBQUMsQ0FBQTtxQkFDaEQ7b0JBQUMsT0FBTyxDQUFDLEVBQUU7d0JBQ1YsS0FBSyxDQUNILHVDQUF1QyxFQUN2QyxPQUFPLEVBQ1Asb0JBQW9CLEVBQ3BCLGdCQUFnQixFQUNoQixtQkFBbUIsRUFDbkIsUUFBUSxDQUNULENBQUE7d0JBRUQsTUFBTSxDQUFDLENBQUE7cUJBQ1I7aUJBQ0Y7YUFDRjtZQUVELE9BQU8sUUFBUSxDQUFBO1FBQ2pCLENBQUMsQ0FBQSxDQUFBO1FBRU8sNkJBQXdCLEdBQUcsQ0FBTyxPQUF1QixFQUFFLEVBQUU7WUFDbkUsS0FBSyxDQUFDLDBCQUEwQixFQUFFLE9BQU8sQ0FBQyxDQUFBO1lBRTFDLElBQUksUUFBUSxDQUFBO1lBQ1osSUFBSSxlQUFlLEdBQUcsQ0FBQyxDQUFBO1lBRXZCLE9BQU8sQ0FBQyxRQUFRLElBQUksSUFBSSxDQUFDLFVBQVUsQ0FBQyxlQUFlLENBQUMsRUFBRTtnQkFDcEQsTUFBTSxTQUFTLEdBQUcsSUFBSSxDQUFDLFVBQVUsQ0FBQyxlQUFlLENBQUMsQ0FBQTtnQkFFbEQsSUFBSSxDQUFDLFNBQVMsQ0FBQyxXQUFXLEVBQUUsRUFBRTtvQkFDNUIsZUFBZSxFQUFFLENBQUE7b0JBQ2pCLFNBQVE7aUJBQ1Q7Z0JBRUQsS0FBSyxDQUNILG1DQUFtQyxJQUFJLENBQUMsVUFBVSxDQUFDLGVBQWUsQ0FBQyxDQUFDLElBQUksRUFBRSxFQUMxRSxPQUFPLENBQ1IsQ0FBQTtnQkFFRCxJQUFJO29CQUNGLElBQUksT0FBWSxDQUFBO29CQUVoQixNQUFNLGVBQWUsR0FBRyxJQUFJLE9BQU8sQ0FBQyxDQUFDLENBQUMsRUFBRSxNQUFNLEVBQUUsRUFBRTt3QkFDaEQsT0FBTyxHQUFHLFVBQVUsQ0FBQyxHQUFHLEVBQUU7NEJBQ3hCLE1BQU0sQ0FDSixJQUFJLDhCQUE4QixDQUNoQyxhQUFhLE9BQU8sQ0FBQyxTQUFTLEVBQUUsQ0FDakMsQ0FDRixDQUFBO3dCQUNILENBQUMsRUFBRSxJQUFJLENBQUMsT0FBTyxDQUFDLFVBQVUsQ0FBQyxDQUFBO29CQUM3QixDQUFDLENBQUMsQ0FBQTtvQkFFRixRQUFRLEdBQUcsTUFBTSxPQUFPLENBQUMsSUFBSSxDQUFDO3dCQUM1QixlQUFlO3dCQUNmLFNBQVMsQ0FBQyxXQUFXLENBQUMsT0FBTyxDQUFDO3FCQUMvQixDQUFDLENBQUMsSUFBSSxDQUFDLENBQUMsUUFBUSxFQUFFLEVBQUU7d0JBQ25CLFlBQVksQ0FBQyxPQUFPLENBQUMsQ0FBQTt3QkFHckIsT0FBTyxRQUEyQixDQUFBO29CQUNwQyxDQUFDLENBQUMsQ0FBQTtpQkFDSDtnQkFBQyxPQUFPLENBQU0sRUFBRTtvQkFDZixJQUNFLENBQUMsWUFBWSw4QkFBOEI7d0JBQzNDLENBQUMsWUFBWSx5QkFBeUIsRUFDdEM7d0JBQ0EsS0FBSyxDQUNILHdCQUF3QixJQUFJLENBQUMsVUFBVSxDQUFDLGVBQWUsQ0FBQyxDQUFDLElBQUksZ0NBQWdDLENBQzlGLENBQUE7d0JBQ0QsZUFBZSxFQUFFLENBQUE7cUJBQ2xCO3lCQUFNO3dCQUNMLE1BQU0sQ0FBQyxDQUFBO3FCQUNSO2lCQUNGO2FBQ0Y7WUFFRCxJQUFJLENBQUMsUUFBUSxJQUFJLENBQUMsSUFBSSxDQUFDLFVBQVUsQ0FBQyxlQUFlLENBQUMsRUFBRTtnQkFDbEQsTUFBTSxJQUFJLGdCQUFnQixDQUN4QixhQUFhLE9BQU8sQ0FBQyxTQUFTLDZDQUE2QyxDQUM1RSxDQUFBO2FBQ0Y7aUJBQU0sSUFBSSxDQUFDLFFBQVEsRUFBRTtnQkFDcEIsTUFBTSxJQUFJLGdCQUFnQixDQUN4QixhQUFhLE9BQU8sQ0FBQyxTQUFTLHlDQUF5QyxDQUN4RSxDQUFBO2FBQ0Y7WUFFRCxPQUFPLFFBQVEsQ0FBQTtRQUNqQixDQUFDLENBQUEsQ0FBQTtRQS9OQyxJQUFJLENBQUMsS0FBSyxHQUFHLE9BQU8sQ0FBQyxLQUFLLENBQUE7UUFFMUIsSUFBSSxPQUFPLENBQUMsa0JBQWtCLEVBQUU7WUFDOUIsSUFBSSxDQUFDLFlBQVksQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxrQkFBa0IsQ0FBQyxDQUFBO1NBQzNEO1FBRUQsSUFBSSxPQUFPLENBQUMsbUJBQW1CLEVBQUU7WUFDL0IsSUFBSSxDQUFDLFlBQVksQ0FBQyxRQUFRLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxtQkFBbUIsQ0FBQyxDQUFBO1NBQzdEO1FBRUQsSUFBSSxDQUFDLFVBQVUsR0FBRyxPQUFPLENBQUMsVUFBVSxDQUFBO0lBQ3RDLENBQUM7Q0FxTkYifQ==
export { ClientManager };
//# sourceMappingURL=ClientManager.js.map

@@ -1,3 +0,5 @@

export class ManagerCallRequestTimeoutError extends Error {
class ManagerCallRequestTimeoutError extends Error {
}
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiTWFuYWdlckNhbGxSZXF1ZXN0VGltZW91dEVycm9yLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vLi4vc3JjL21hbmFnZXIvZXJyb3JzL01hbmFnZXJDYWxsUmVxdWVzdFRpbWVvdXRFcnJvci50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiQUFBQSxNQUFNLE9BQU8sOEJBQStCLFNBQVEsS0FBSztDQUFHIn0=
export { ManagerCallRequestTimeoutError };
//# sourceMappingURL=ManagerCallRequestTimeoutError.js.map

@@ -1,2 +0,2 @@

/*! *****************************************************************************
/******************************************************************************
Copyright (c) Microsoft Corporation.

@@ -3,0 +3,0 @@

@@ -19,2 +19,3 @@ import { CallRequestDTO } from './CallRequestDTO';

setIdentity(identity?: RPCClientIdentity): void;
setIdentityMetadata(metadata?: Record<string, any>): void;
subscribe(filter: {

@@ -67,3 +68,4 @@ request: CallRequestDTO | string;

setIdentity: (identity?: RPCClientIdentity | undefined) => void;
setIdentityMetadata: (metadata?: Record<string, any> | undefined) => void;
}
//# sourceMappingURL=RPCClient.d.ts.map

@@ -1,20 +0,13 @@

var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
import { CallRequestDTO } from './CallRequestDTO';
import { ClientManager } from './manager/ClientManager';
import { BrowserCache } from './cache/BrowserStorageCache';
import { InMemoryCache } from './cache/InMemoryCache';
import { HTTPTransport } from './transports/HTTPTransport';
import { WebSocketTransport } from './transports/WebSocketTransport';
import { __awaiter } from './node_modules/tslib/tslib.es6.js';
import { CallRequestDTO } from './CallRequestDTO.js';
import { ClientManager } from './manager/ClientManager.js';
import { BrowserCache } from './cache/BrowserStorageCache.js';
import { InMemoryCache } from './cache/InMemoryCache.js';
import { HTTPTransport } from './transports/HTTPTransport.js';
import { WebSocketTransport } from './transports/WebSocketTransport.js';
import { cloneDeep, merge } from 'lodash-es';
import { parseRequestShorthand } from './utils/request';
import { Vent } from './utils/vent';
import { makeCallRequestKey } from './utils/cache-utils';
import { parseRequestShorthand } from './utils/request.js';
import { Vent } from './utils/vent.js';
import { makeCallRequestKey } from './utils/cache-utils.js';
const ERRORS = {

@@ -24,3 +17,3 @@ HTTP_HOST_OR_TRANSPORT_REQUIRED: `http host or tansport is required`,

};
export class RPCClient {
class RPCClient {
constructor(options) {

@@ -109,5 +102,14 @@ var _a, _b, _c, _d, _e, _f;

this.setIdentity = (identity) => {
let newIdentity = cloneDeep(identity);
this.identity = identity;
this.callManager.setIdentity(identity);
this.callManager.setIdentity(newIdentity);
};
this.setIdentityMetadata = (metadata) => {
var _a;
(_a = this.identity) !== null && _a !== void 0 ? _a : (this.identity = {});
const newIdentity = cloneDeep(this.identity);
newIdentity.metadata = metadata;
this.identity.metadata = metadata;
this.callManager.setIdentity(newIdentity);
};
if (!((_a = options === null || options === void 0 ? void 0 : options.hosts) === null || _a === void 0 ? void 0 : _a.http) && !((_b = options === null || options === void 0 ? void 0 : options.transports) === null || _b === void 0 ? void 0 : _b.http)) {

@@ -174,2 +176,4 @@ throw new Error(ERRORS.HTTP_HOST_OR_TRANSPORT_REQUIRED);

RPCClient.DEFAULT_DEADLINE_MS = 10000;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiUlBDQ2xpZW50LmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vc3JjL1JQQ0NsaWVudC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7Ozs7Ozs7QUFBQSxPQUFPLEVBQUUsY0FBYyxFQUFFLE1BQU0sa0JBQWtCLENBQUE7QUFFakQsT0FBTyxFQUFFLGFBQWEsRUFBRSxNQUFNLHlCQUF5QixDQUFBO0FBQ3ZELE9BQU8sRUFBRSxZQUFZLEVBQUUsTUFBTSw2QkFBNkIsQ0FBQTtBQUMxRCxPQUFPLEVBQUUsYUFBYSxFQUFFLE1BQU0sdUJBQXVCLENBQUE7QUFDckQsT0FBTyxFQUFFLGFBQWEsRUFBRSxNQUFNLDRCQUE0QixDQUFBO0FBQzFELE9BQU8sRUFBRSxrQkFBa0IsRUFBRSxNQUFNLGlDQUFpQyxDQUFBO0FBS3BFLE9BQU8sRUFBRSxTQUFTLEVBQUUsS0FBSyxFQUFFLE1BQU0sV0FBVyxDQUFBO0FBQzVDLE9BQU8sRUFBRSxxQkFBcUIsRUFBRSxNQUFNLGlCQUFpQixDQUFBO0FBQ3ZELE9BQU8sRUFBRSxJQUFJLEVBQUUsTUFBTSxjQUFjLENBQUE7QUFDbkMsT0FBTyxFQUFFLGtCQUFrQixFQUFFLE1BQU0scUJBQXFCLENBQUE7QUFFeEQsTUFBTSxNQUFNLEdBQUc7SUFDYiwrQkFBK0IsRUFBRSxtQ0FBbUM7SUFDcEUsdUJBQXVCLEVBQUUsaUNBQWlDO0NBQzNELENBQUE7QUFxRUQsTUFBTSxPQUFPLFNBQVM7SUFXcEIsWUFBcUIsT0FBeUI7O1FBQXpCLFlBQU8sR0FBUCxPQUFPLENBQWtCO1FBSnRDLHVDQUFrQyxHQUN4QyxFQUFFLENBQUE7UUFDSSxTQUFJLEdBQUcsSUFBSSxJQUFJLEVBQUUsQ0FBQTtRQTZEakIsc0NBQWlDLEdBQUcsQ0FBQyxTQUFrQixFQUFFLEVBQUU7WUFDakUsSUFBSSxJQUFJLENBQUMsT0FBTyxDQUFDLGlDQUFpQyxFQUFFO2dCQUNsRCxJQUFJLENBQUMsT0FBTyxDQUFDLGlDQUFpQyxDQUFDLFNBQVMsQ0FBQyxDQUFBO2FBQzFEO1lBRUQsSUFBSSxDQUFDLGtDQUFrQyxDQUFDLE9BQU8sQ0FBQyxDQUFDLEVBQUUsRUFBRSxFQUFFLENBQUMsRUFBRSxDQUFDLFNBQVMsQ0FBQyxDQUFDLENBQUE7UUFDeEUsQ0FBQyxDQUFBO1FBRU0sU0FBSSxHQUFHLENBQ1osT0FBc0MsRUFDdEMsSUFBVyxFQUNxQixFQUFFO1lBQ2xDLElBQUksQ0FBQyxPQUFPO2dCQUNWLE1BQU0sSUFBSSxLQUFLLENBQUMsb0RBQW9ELENBQUMsQ0FBQTtZQUV2RSxJQUFJLEdBQXlCLENBQUE7WUFFN0IsSUFBSSxPQUFPLE9BQU8sS0FBSyxRQUFRO2dCQUFFLEdBQUcsR0FBRyxxQkFBcUIsQ0FBQyxPQUFPLENBQUMsQ0FBQTs7Z0JBQ2hFLEdBQUcsR0FBRyxPQUErQixDQUFBO1lBRTFDLElBQUksSUFBSSxFQUFFO2dCQUNSLEdBQUcsQ0FBQyxJQUFJLEdBQUcsSUFBSSxDQUFBO2FBQ2hCO1lBRUQsTUFBTSxVQUFVLEdBQUcsSUFBSSxjQUFjLENBQU8sR0FBRyxDQUFDLENBQUE7WUFFaEQsSUFBSSxDQUFDLFVBQVUsQ0FBQyxTQUFTLElBQUksQ0FBQyxVQUFVLENBQUMsUUFBUSxFQUFFO2dCQUNqRCxNQUFNLElBQUksU0FBUyxDQUNqQiwrRUFBK0UsQ0FDaEYsQ0FBQTthQUNGO1lBRUQsSUFBSSxDQUFDLFVBQVUsQ0FBQyxRQUFRO2dCQUFFLFVBQVUsQ0FBQyxRQUFRLEdBQUcsRUFBRSxDQUFBO1lBR2xELFVBQVUsQ0FBQyxRQUFRLEdBQUcsS0FBSyxtQkFBTSxJQUFJLENBQUMsUUFBUSxHQUFJLFVBQVUsQ0FBQyxRQUFRLENBQUMsQ0FBQTtZQUV0RSxNQUFNLFlBQVksR0FBRyxNQUFNLElBQUksQ0FBQyxXQUFXLENBQUMsbUJBQW1CLENBQUMsVUFBVSxDQUFDLENBQUE7WUFFM0UsSUFBSSxDQUFDLFlBQVksQ0FBQyxPQUFPLEVBQUU7Z0JBQ3pCLE1BQU0sWUFBWSxDQUFBO2FBQ25CO1lBRUQsTUFBTSxjQUFjLEdBQUcsa0JBQWtCLENBQUMsR0FBRyxDQUFDLENBQUE7WUFDOUMsSUFBSSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsY0FBYyxFQUFFLFlBQVksYUFBWixZQUFZLHVCQUFaLFlBQVksQ0FBRSxJQUFJLENBQUMsQ0FBQTtZQUVyRCxPQUFPLFlBQXFDLENBQUE7UUFDOUMsQ0FBQyxDQUFBLENBQUE7UUFNTSxlQUFVLEdBQUcsQ0FBQyxPQUF3QixFQUFFLEVBQUU7WUFDL0MsSUFBSSxDQUFDLFdBQVcsQ0FBQyxVQUFVLENBQUMsT0FBTyxDQUFDLENBQUE7UUFDdEMsQ0FBQyxDQUFBO1FBRU0saUJBQVksR0FBRyxDQUNwQixPQUFzQyxFQUN0QyxJQUFXLEVBQ1gsRUFBRTtZQUNGLElBQUksR0FBeUIsQ0FBQTtZQUU3QixJQUFJLE9BQU8sT0FBTyxLQUFLLFFBQVE7Z0JBQUUsR0FBRyxHQUFHLHFCQUFxQixDQUFDLE9BQU8sQ0FBQyxDQUFBOztnQkFDaEUsR0FBRyxHQUFHLE9BQStCLENBQUE7WUFFMUMsSUFBSSxJQUFJLEVBQUU7Z0JBQ1IsR0FBRyxDQUFDLElBQUksR0FBRyxJQUFJLENBQUE7YUFDaEI7WUFFRCxNQUFNLGNBQWMsR0FBRyxJQUFJLENBQUMsV0FBVyxDQUFDLGlCQUFpQixDQUN2RCxHQUFHLENBQ3FCLENBQUE7WUFFMUIsSUFBSSxjQUFjO2dCQUFFLE9BQU8sY0FBYyxDQUFBO1lBRXpDLE9BQU8sU0FBUyxDQUFBO1FBQ2xCLENBQUMsQ0FBQTtRQUVNLGdCQUFXLEdBQUcsR0FBRyxFQUFFLENBQ3hCLElBQUksQ0FBQyxRQUFRLENBQUMsQ0FBQyxDQUFDLFNBQVMsQ0FBQyxJQUFJLENBQUMsUUFBUSxDQUFDLENBQUMsQ0FBQyxDQUFDLElBQUksQ0FBQyxRQUFRLENBQUE7UUFFbkQseUJBQW9CLEdBQUcsR0FBRyxFQUFFO1lBQ2pDLE9BQU8sSUFBSSxDQUFDLFdBQVcsQ0FBQyxvQkFBb0IsRUFBRSxDQUFBO1FBQ2hELENBQUMsQ0FBQTtRQUVNLDBCQUFxQixHQUFHLEdBQUcsRUFBRTs7WUFDbEMsT0FBTyxDQUFDLENBQUMsQ0FBQSxNQUFBLElBQUksYUFBSixJQUFJLHVCQUFKLElBQUksQ0FBRSxrQkFBa0IsMENBQUUsV0FBVyxFQUFFLENBQUEsQ0FBQTtRQUNsRCxDQUFDLENBQUE7UUFFTSxrQkFBYSxHQUFHLENBQ3JCLE9BQXNDLEVBQ1ksRUFBRTtZQUNwRCxNQUFNLElBQUksR0FBRyxJQUFJLENBQUE7WUFFakIsSUFBSSxHQUF5QixDQUFBO1lBRTdCLElBQUksT0FBTyxPQUFPLEtBQUssUUFBUTtnQkFBRSxHQUFHLEdBQUcscUJBQXFCLENBQUMsT0FBTyxDQUFDLENBQUE7O2dCQUNoRSxHQUFHLEdBQUcsT0FBK0IsQ0FBQTtZQUUxQyxPQUFPLFNBQVMsZ0JBQWdCLENBQUMsSUFBVTtnQkFDekMsT0FBTyxJQUFJLENBQUMsSUFBSSxpQ0FBTSxHQUFHLEtBQUUsSUFBSSxJQUFHLENBQUE7WUFDcEMsQ0FBQyxDQUFBO1FBQ0gsQ0FBQyxDQUFBO1FBRU0sZ0NBQTJCLEdBQUcsQ0FDbkMsbUJBQTRDLEVBQzVDLEVBQUU7WUFDRixJQUFJLENBQUMsV0FBVyxDQUFDLHNCQUFzQixDQUFDLG1CQUFtQixDQUFDLENBQUE7UUFDOUQsQ0FBQyxDQUFBO1FBRU0sK0JBQTBCLEdBQUcsQ0FDbEMsa0JBQTBDLEVBQzFDLEVBQUU7WUFDRixJQUFJLENBQUMsV0FBVyxDQUFDLHFCQUFxQixDQUFDLGtCQUFrQixDQUFDLENBQUE7UUFDNUQsQ0FBQyxDQUFBO1FBRU0sb0RBQStDLEdBQUcsQ0FDdkQsRUFBZ0MsRUFDaEMsRUFBRTtZQUNGLElBQUksQ0FBQyxrQ0FBa0MsQ0FBQyxJQUFJLENBQUMsRUFBRSxDQUFDLENBQUE7UUFDbEQsQ0FBQyxDQUFBO1FBRU0sZ0JBQVcsR0FBRyxDQUFDLFFBQTRCLEVBQUUsRUFBRTtZQUNwRCxJQUFJLENBQUMsUUFBUSxHQUFHLFFBQVEsQ0FBQTtZQUN4QixJQUFJLENBQUMsV0FBVyxDQUFDLFdBQVcsQ0FBQyxRQUFRLENBQUMsQ0FBQTtRQUN4QyxDQUFDLENBQUE7UUF4TEMsSUFBSSxDQUFDLENBQUEsTUFBQSxPQUFPLGFBQVAsT0FBTyx1QkFBUCxPQUFPLENBQUUsS0FBSywwQ0FBRSxJQUFJLENBQUEsSUFBSSxDQUFDLENBQUEsTUFBQSxPQUFPLGFBQVAsT0FBTyx1QkFBUCxPQUFPLENBQUUsVUFBVSwwQ0FBRSxJQUFJLENBQUEsRUFBRTtZQUN2RCxNQUFNLElBQUksS0FBSyxDQUFDLE1BQU0sQ0FBQywrQkFBK0IsQ0FBQyxDQUFBO1NBQ3hEO1FBRUQsSUFDRSxPQUFPLENBQUMsa0JBQWtCO1lBQzFCLE9BQU8sT0FBTyxDQUFDLGtCQUFrQixLQUFLLFVBQVUsRUFDaEQ7WUFDQSxNQUFNLElBQUksS0FBSyxDQUFDLE1BQU0sQ0FBQyx1QkFBdUIsQ0FBQyxDQUFBO1NBQ2hEO1FBRUQsSUFDRSxPQUFPLENBQUMsbUJBQW1CO1lBQzNCLE9BQU8sT0FBTyxDQUFDLG1CQUFtQixLQUFLLFVBQVUsRUFDakQ7WUFDQSxNQUFNLElBQUksS0FBSyxDQUFDLE1BQU0sQ0FBQyx1QkFBdUIsQ0FBQyxDQUFBO1NBQ2hEO1FBRUQsSUFBSSxLQUFLLENBQUE7UUFDVCxNQUFNLFlBQVksR0FBRyxFQUFFLGFBQWEsRUFBRSxPQUFPLGFBQVAsT0FBTyx1QkFBUCxPQUFPLENBQUUsYUFBYSxFQUFFLENBQUE7UUFFOUQsSUFBSSxPQUFPLENBQUMsU0FBUyxJQUFJLFNBQVMsRUFBRTtZQUNsQyxLQUFLLEdBQUcsSUFBSSxZQUFZLENBQUMsWUFBWSxDQUFDLENBQUE7U0FDdkM7YUFBTTtZQUNMLEtBQUssR0FBRyxJQUFJLGFBQWEsQ0FBQyxZQUFZLENBQUMsQ0FBQTtTQUN4QztRQUVELE1BQU0sVUFBVSxHQUFHLEVBQUUsQ0FBQTtRQUVyQixJQUFJLE1BQUEsT0FBTyxDQUFDLFVBQVUsMENBQUUsU0FBUyxFQUFFO1lBQ2pDLFVBQVUsQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLFVBQVUsQ0FBQyxTQUFTLENBQUMsQ0FBQTtTQUM5QzthQUFNLElBQUksTUFBQSxPQUFPLGFBQVAsT0FBTyx1QkFBUCxPQUFPLENBQUUsS0FBSywwQ0FBRSxTQUFTLEVBQUU7WUFDcEMsSUFBSSxDQUFDLGtCQUFrQixHQUFHLElBQUksa0JBQWtCLENBQUM7Z0JBQy9DLElBQUksRUFBRSxPQUFPLENBQUMsS0FBSyxDQUFDLFNBQVM7Z0JBQzdCLHdCQUF3QixFQUFFLElBQUksQ0FBQyxpQ0FBaUM7YUFDakUsQ0FBQyxDQUFBO1lBRUYsVUFBVSxDQUFDLElBQUksQ0FBQyxJQUFJLENBQUMsa0JBQWtCLENBQUMsQ0FBQTtTQUN6QztRQUdELElBQUksTUFBQSxPQUFPLENBQUMsVUFBVSwwQ0FBRSxJQUFJLEVBQUU7WUFDNUIsVUFBVSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsVUFBVSxDQUFDLElBQUksQ0FBQyxDQUFBO1NBQ3pDO2FBQU0sSUFBSSxNQUFBLE9BQU8sYUFBUCxPQUFPLHVCQUFQLE9BQU8sQ0FBRSxLQUFLLDBDQUFFLElBQUksRUFBRTtZQUMvQixJQUFJLENBQUMsYUFBYSxHQUFHLElBQUksYUFBYSxDQUFDLEVBQUUsSUFBSSxFQUFFLE9BQU8sQ0FBQyxLQUFLLENBQUMsSUFBSSxFQUFFLENBQUMsQ0FBQTtZQUVwRSxVQUFVLENBQUMsSUFBSSxDQUFDLElBQUksQ0FBQyxhQUFhLENBQUMsQ0FBQTtTQUNwQztRQUVELElBQUksQ0FBQyxXQUFXLEdBQUcsSUFBSSxhQUFhLENBQUM7WUFDbkMsS0FBSztZQUNMLFVBQVUsRUFBRSxPQUFPLENBQUMsVUFBVSxJQUFJLFNBQVMsQ0FBQyxtQkFBbUI7WUFDL0Qsa0JBQWtCLEVBQUUsT0FBTyxDQUFDLGtCQUFrQjtZQUM5QyxtQkFBbUIsRUFBRSxPQUFPLENBQUMsbUJBQW1CO1lBQ2hELFVBQVU7U0FDWCxDQUFDLENBQUE7SUFDSixDQUFDO0lBa0lNLFNBQVMsQ0FDZCxNQUF3RCxFQUN4RCxPQUE0QztRQUU1QyxNQUFNLE9BQU8sR0FDWCxPQUFPLE1BQU0sQ0FBQyxPQUFPLEtBQUssUUFBUTtZQUNoQyxDQUFDLENBQUMscUJBQXFCLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FBQztZQUN2QyxDQUFDLENBQUMsTUFBTSxDQUFDLE9BQU8sQ0FBQTtRQUVwQixNQUFNLGNBQWMsR0FBRyxrQkFBa0IsaUNBQU0sT0FBTyxLQUFFLElBQUksRUFBRSxNQUFNLENBQUMsSUFBSSxJQUFHLENBQUE7UUFFNUUsSUFBSSxDQUFDLElBQUksQ0FBQyxTQUFTLENBQUMsY0FBYyxFQUFFLE9BQU8sQ0FBQyxDQUFBO0lBQzlDLENBQUM7SUFFTSxXQUFXLENBQ2hCLE1BQXdELEVBQ3hELE9BQTRDO1FBRTVDLE1BQU0sT0FBTyxHQUNYLE9BQU8sTUFBTSxDQUFDLE9BQU8sS0FBSyxRQUFRO1lBQ2hDLENBQUMsQ0FBQyxxQkFBcUIsQ0FBQyxNQUFNLENBQUMsT0FBTyxDQUFDO1lBQ3ZDLENBQUMsQ0FBQyxNQUFNLENBQUMsT0FBTyxDQUFBO1FBRXBCLE1BQU0sY0FBYyxHQUFHLGtCQUFrQixpQ0FBTSxPQUFPLEtBQUUsSUFBSSxFQUFFLE1BQU0sQ0FBQyxJQUFJLElBQUcsQ0FBQTtRQUU1RSxJQUFJLENBQUMsSUFBSSxDQUFDLFdBQVcsQ0FBQyxjQUFjLEVBQUUsT0FBTyxDQUFDLENBQUE7SUFDaEQsQ0FBQzs7QUEvTk0sNkJBQW1CLEdBQUcsS0FBSyxDQUFBIn0=
export { RPCClient };
//# sourceMappingURL=RPCClient.js.map

@@ -1,3 +0,5 @@

export class CallRequestTransportError extends Error {
class CallRequestTransportError extends Error {
}
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiQ2FsbFJlcXVlc3RUcmFuc3BvcnRFcnJvci5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uLy4uL3NyYy90cmFuc3BvcnRzL2Vycm9ycy9DYWxsUmVxdWVzdFRyYW5zcG9ydEVycm9yLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBLE1BQU0sT0FBTyx5QkFBMEIsU0FBUSxLQUFLO0NBQUcifQ==
export { CallRequestTransportError };
//# sourceMappingURL=CallRequestTransportError.js.map

@@ -17,5 +17,5 @@ import { Transport } from './Transport';

sendRequest: (call: CallRequestDTO) => Promise<CallResponseDTO>;
setIdentity: (identity?: RPCClientIdentity | undefined) => void;
setIdentity: (identity?: RPCClientIdentity) => void;
}
export {};
//# sourceMappingURL=HTTPTransport.d.ts.map

@@ -1,14 +0,7 @@

var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
import { CallResponseDTO } from '../CallResponseDTO';
import { GetDebugLogger } from '../utils/debug-logger';
import { __awaiter } from '../node_modules/tslib/tslib.es6.js';
import { CallResponseDTO } from '../CallResponseDTO.js';
import { GetDebugLogger } from '../utils/debug-logger.js';
const debug = GetDebugLogger('rpc:HTTPTransport');
export class HTTPTransport {
class HTTPTransport {
constructor(options) {

@@ -53,2 +46,4 @@ this.options = options;

}
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiSFRUUFRyYW5zcG9ydC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3NyYy90cmFuc3BvcnRzL0hUVFBUcmFuc3BvcnQudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7Ozs7Ozs7O0FBRUEsT0FBTyxFQUFFLGVBQWUsRUFBRSxNQUFNLG9CQUFvQixDQUFBO0FBRXBELE9BQU8sRUFBRSxjQUFjLEVBQUUsTUFBTSx1QkFBdUIsQ0FBQTtBQUV0RCxNQUFNLEtBQUssR0FBRyxjQUFjLENBQUMsbUJBQW1CLENBQUMsQ0FBQTtBQU1qRCxNQUFNLE9BQU8sYUFBYTtJQVF4QixZQUFxQixPQUE2QjtRQUE3QixZQUFPLEdBQVAsT0FBTyxDQUFzQjtRQUoxQyx1QkFBa0IsR0FBWSxLQUFLLENBQUE7UUFFbEMsU0FBSSxHQUFHLGVBQWUsQ0FBQTtRQU14QixnQkFBVyxHQUFHLEdBQVksRUFBRTs7WUFDakMsSUFBSSxPQUFPLE1BQU0sS0FBSyxXQUFXLEVBQUU7Z0JBQ2pDLE9BQU8sQ0FBQyxDQUFDLENBQUEsTUFBQSxNQUFNLGFBQU4sTUFBTSx1QkFBTixNQUFNLENBQUUsU0FBUywwQ0FBRSxNQUFNLENBQUEsQ0FBQTthQUNuQztZQUVELE9BQU8sSUFBSSxDQUFDLGtCQUFrQixDQUFBO1FBQ2hDLENBQUMsQ0FBQTtRQUVNLGdCQUFXLEdBQUcsQ0FDbkIsSUFBb0IsRUFDTSxFQUFFO1lBQzVCLEtBQUssQ0FBQyxhQUFhLEVBQUUsSUFBSSxDQUFDLENBQUE7WUFFMUIsTUFBTSxJQUFJLEdBQUcsSUFBSSxDQUFDLFNBQVMsaUJBQ3pCLFFBQVEsRUFBRSxJQUFJLENBQUMsUUFBUSxJQUNwQixJQUFJLEVBQ1AsQ0FBQTtZQUVGLE1BQU0sR0FBRyxHQUFHLE1BQU0sQ0FBQSxNQUFNLGFBQU4sTUFBTSx1QkFBTixNQUFNLENBQUUsS0FBSyxDQUFDLElBQUksQ0FBQyxJQUFJLEVBQUU7Z0JBQ3pDLElBQUk7Z0JBQ0osS0FBSyxFQUFFLFNBQVM7Z0JBQ2hCLFdBQVcsRUFBRSxNQUFNO2dCQUNuQixPQUFPLEVBQUU7b0JBQ1AsY0FBYyxFQUFFLGtCQUFrQjtpQkFDbkM7Z0JBQ0QsTUFBTSxFQUFFLE1BQU07Z0JBQ2QsSUFBSSxFQUFFLE1BQU07Z0JBQ1osUUFBUSxFQUFFLFFBQVE7Z0JBQ2xCLGNBQWMsRUFBRSxRQUFRO2FBQ3pCLENBQUMsQ0FBQSxDQUFBO1lBRUYsTUFBTSxNQUFNLEdBQUcsTUFBTSxHQUFHLENBQUMsSUFBSSxFQUFFLENBQUE7WUFFL0IsSUFBSSxDQUFDLE1BQU07Z0JBQUUsTUFBTSxJQUFJLEtBQUssQ0FBQyxrQ0FBa0MsQ0FBQyxDQUFBO1lBRWhFLE1BQU0sUUFBUSxHQUFHLElBQUksQ0FBQyxLQUFLLENBQUMsTUFBTSxDQUFDLENBQUE7WUFFbkMsT0FBTyxJQUFJLGVBQWUsQ0FBQyxRQUFRLENBQUMsQ0FBQTtRQUN0QyxDQUFDLENBQUEsQ0FBQTtRQUVNLGdCQUFXLEdBQUcsQ0FBQyxRQUE0QixFQUFFLEVBQUU7WUFDcEQsS0FBSyxDQUFDLGFBQWEsRUFBRSxRQUFRLENBQUMsQ0FBQTtZQUU5QixJQUFJLENBQUMsUUFBUSxHQUFHLFFBQVEsQ0FBQTtRQUMxQixDQUFDLENBQUE7UUEvQ0MsSUFBSSxDQUFDLElBQUksR0FBRyxPQUFPLENBQUMsSUFBSSxDQUFBO0lBQzFCLENBQUM7Q0ErQ0YifQ==
export { HTTPTransport };
//# sourceMappingURL=HTTPTransport.js.map

@@ -24,3 +24,3 @@ import { Transport } from './Transport';

sendRequest: (call: CallRequestDTO) => Promise<CallResponseDTO>;
setIdentity: (identity?: RPCClientIdentity | undefined) => Promise<void>;
setIdentity: (identity?: RPCClientIdentity) => Promise<void>;
private connect;

@@ -27,0 +27,0 @@ private disconnect;

@@ -1,17 +0,10 @@

var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
import { CallResponseDTO } from '../CallResponseDTO';
import { PromiseWrapper } from '../utils/PromiseWrapper';
import { sleep } from '../utils/sleep';
import { GetDebugLogger } from '../utils/debug-logger';
import { CallRequestTransportError } from './errors/CallRequestTransportError';
import { __awaiter } from '../node_modules/tslib/tslib.es6.js';
import { CallResponseDTO } from '../CallResponseDTO.js';
import { PromiseWrapper } from '../utils/PromiseWrapper.js';
import { sleep } from '../utils/sleep.js';
import { GetDebugLogger } from '../utils/debug-logger.js';
import { CallRequestTransportError } from './errors/CallRequestTransportError.js';
const debug = GetDebugLogger('rpc:WebSocketTransport');
export class WebSocketTransport {
class WebSocketTransport {
constructor(options) {

@@ -116,3 +109,3 @@ this.options = options;

this.isWaitingForIdentityConfirmation = false;
(_a = this.websocket) === null || _a === void 0 ? void 0 : _a.close(0, reason);
(_a = this.websocket) === null || _a === void 0 ? void 0 : _a.close(1000, reason);
this.websocket = undefined;

@@ -162,2 +155,3 @@ this.websocketId = undefined;

this.setConnectedToRemote = (connected) => {
debug(`setConnectedToRemote: ${connected}`);
this.connectedToRemote = connected;

@@ -177,2 +171,4 @@ if (this.options.onConnectionStatusChange) {

WebSocketTransport.DEFAULT_TIMEOUT_MS = 10000;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiV2ViU29ja2V0VHJhbnNwb3J0LmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vc3JjL3RyYW5zcG9ydHMvV2ViU29ja2V0VHJhbnNwb3J0LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7Ozs7OztBQUVBLE9BQU8sRUFBRSxlQUFlLEVBQUUsTUFBTSxvQkFBb0IsQ0FBQTtBQUVwRCxPQUFPLEVBQUUsY0FBYyxFQUFFLE1BQU0seUJBQXlCLENBQUE7QUFDeEQsT0FBTyxFQUFFLEtBQUssRUFBRSxNQUFNLGdCQUFnQixDQUFBO0FBQ3RDLE9BQU8sRUFBRSxjQUFjLEVBQUUsTUFBTSx1QkFBdUIsQ0FBQTtBQUN0RCxPQUFPLEVBQUUseUJBQXlCLEVBQUUsTUFBTSxvQ0FBb0MsQ0FBQTtBQUU5RSxNQUFNLEtBQUssR0FBRyxjQUFjLENBQUMsd0JBQXdCLENBQUMsQ0FBQTtBQVF0RCxNQUFNLE9BQU8sa0JBQWtCO0lBb0I3QixZQUFxQixPQUFrQztRQUFsQyxZQUFPLEdBQVAsT0FBTyxDQUEyQjtRQWpCL0Msc0JBQWlCLEdBQVksS0FBSyxDQUFBO1FBR2xDLHFDQUFnQyxHQUFZLEtBQUssQ0FBQTtRQUVqRCwrQkFBMEIsR0FLOUIsRUFBRSxDQUFBO1FBR0UsZ0JBQVcsR0FBWSxTQUFTLENBQUE7UUFFL0IsU0FBSSxHQUFHLG9CQUFvQixDQUFBO1FBUzdCLGdCQUFXLEdBQUcsR0FBRyxFQUFFO1lBQ3hCLE9BQU8sSUFBSSxDQUFDLGlCQUFpQixJQUFJLENBQUMsQ0FBQyxJQUFJLENBQUMsU0FBUyxDQUFBO1FBQ25ELENBQUMsQ0FBQTtRQUVNLGdCQUFXLEdBQUcsQ0FDbkIsSUFBb0IsRUFDTSxFQUFFO1lBQzVCLEtBQUssQ0FBQyxhQUFhLEVBQUUsSUFBSSxDQUFDLENBQUE7WUFFMUIsT0FBTyxJQUFJLENBQUMsZ0NBQWdDLEVBQUU7Z0JBQzVDLEtBQUssQ0FBQyxtQ0FBbUMsQ0FBQyxDQUFBO2dCQUUxQyxNQUFNLEtBQUssQ0FBQyxHQUFHLENBQUMsQ0FBQTthQUNqQjtZQUVELE9BQU8sSUFBSSxDQUFDLElBQUksQ0FBQyxJQUFJLENBQUMsQ0FBQTtRQUN4QixDQUFDLENBQUEsQ0FBQTtRQU1NLGdCQUFXLEdBQUcsQ0FBTyxRQUE0QixFQUFFLEVBQUU7WUFDMUQsS0FBSyxDQUFDLGFBQWEsRUFBRSxRQUFRLENBQUMsQ0FBQTtZQUU5QixJQUFJLENBQUMsUUFBUSxFQUFFO2dCQUNiLElBQUksQ0FBQyxRQUFRLEdBQUcsU0FBUyxDQUFBO2dCQUN6QixNQUFNLElBQUksQ0FBQyxlQUFlLEVBQUUsQ0FBQTtnQkFFNUIsT0FBTTthQUNQO2lCQUFNO2dCQUNMLElBQUksQ0FBQyxRQUFRLEdBQUcsUUFBUSxDQUFBO2FBQ3pCO1lBRUQsSUFBSSxDQUFDLElBQUksQ0FBQyxpQkFBaUIsRUFBRTtnQkFDM0IsS0FBSyxDQUFDLHdDQUF3QyxDQUFDLENBQUE7Z0JBQy9DLE9BQU07YUFDUDtpQkFBTSxJQUFJLElBQUksQ0FBQyxnQ0FBZ0MsRUFBRTtnQkFDaEQsS0FBSyxDQUNILGtGQUFrRixDQUNuRixDQUFBO2dCQUNELE9BQU07YUFDUDtZQUVELElBQUksQ0FBQyxnQ0FBZ0MsR0FBRyxJQUFJLENBQUE7WUFFNUMsSUFBSSxDQUFDLElBQUksQ0FBQyxFQUFFLFFBQVEsRUFBRSxDQUFDO2lCQUNwQixJQUFJLENBQUMsR0FBRyxFQUFFO2dCQUNULEtBQUssQ0FBQyxrQ0FBa0MsQ0FBQyxDQUFBO1lBQzNDLENBQUMsQ0FBQztpQkFDRCxLQUFLLENBQUMsQ0FBQyxDQUFDLEVBQUUsRUFBRTtnQkFDWCxLQUFLLENBQUMsK0JBQStCLEVBQUUsQ0FBQyxDQUFDLENBQUE7WUFDM0MsQ0FBQyxDQUFDO2lCQUNELE9BQU8sQ0FBQyxHQUFHLEVBQUU7Z0JBQ1osSUFBSSxDQUFDLGdDQUFnQyxHQUFHLEtBQUssQ0FBQTtZQUMvQyxDQUFDLENBQUMsQ0FBQTtRQUNOLENBQUMsQ0FBQSxDQUFBO1FBRU8sWUFBTyxHQUFHLEdBQUcsRUFBRTtZQUNyQixLQUFLLENBQUMsU0FBUyxFQUFFLElBQUksQ0FBQyxJQUFJLENBQUMsQ0FBQTtZQUUzQixJQUFJLElBQUksQ0FBQyxTQUFTLEVBQUU7Z0JBQ2xCLEtBQUssQ0FBQyxxREFBcUQsQ0FBQyxDQUFBO2dCQUM1RCxPQUFNO2FBQ1A7WUFFRCxJQUFJLENBQUMsV0FBVyxHQUFHLElBQUksQ0FBQyxNQUFNLEVBQUUsQ0FBQTtZQUNoQyxJQUFJLENBQUMsU0FBUyxHQUFHLElBQUksU0FBUyxDQUFDLElBQUksQ0FBQyxJQUFJLENBQUMsQ0FBQTtZQUV6QyxNQUFNLEVBQUUsR0FBRyxJQUFJLENBQUMsU0FBUyxDQUFBO1lBRXpCLEVBQUUsQ0FBQyxNQUFNLEdBQUcsR0FBRyxFQUFFO2dCQUNmLE9BQU8sQ0FBQyxJQUFJLENBQUMscUJBQXFCLENBQUMsQ0FBQTtnQkFFbkMsSUFBSSxDQUFDLG9CQUFvQixDQUFDLElBQUksQ0FBQyxDQUFBO1lBQ2pDLENBQUMsQ0FBQTtZQUVELEVBQUUsQ0FBQyxTQUFTLEdBQUcsQ0FBQyxHQUFHLEVBQUUsRUFBRTtnQkFDckIsSUFBSSxDQUFDLGtCQUFrQixDQUFDLEdBQUcsQ0FBQyxDQUFBO1lBQzlCLENBQUMsQ0FBQTtZQUVELEVBQUUsQ0FBQyxPQUFPLEdBQUcsQ0FBQyxDQUFDLEVBQUUsRUFBRTtnQkFDakIsSUFBSSxJQUFJLENBQUMsaUJBQWlCLEVBQUU7b0JBQzFCLE9BQU8sQ0FBQyxJQUFJLENBQUMsa0JBQWtCLEVBQUUsQ0FBQyxDQUFDLE1BQU0sQ0FBQyxDQUFBO2lCQUMzQztxQkFBTTtvQkFDTCxLQUFLLENBQUMsc0RBQXNELENBQUMsQ0FBQTtpQkFDOUQ7Z0JBRUQsSUFBSSxDQUFDLG9CQUFvQixDQUFDLEtBQUssQ0FBQyxDQUFBO2dCQUNoQyxJQUFJLENBQUMsZ0NBQWdDLEdBQUcsS0FBSyxDQUFBO2dCQUM3QyxJQUFJLENBQUMsU0FBUyxHQUFHLFNBQVMsQ0FBQTtnQkFDMUIsSUFBSSxDQUFDLFdBQVcsR0FBRyxTQUFTLENBQUE7Z0JBRTVCLE1BQU0sQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLDBCQUEwQixDQUFDLENBQUMsT0FBTyxDQUNyRCxDQUFDLENBQUMsYUFBYSxFQUFFLGNBQWMsQ0FBQyxFQUFFLEVBQUU7b0JBQ2xDLGNBQWMsQ0FBQyxNQUFNLENBQ25CLElBQUkseUJBQXlCLENBQUMsd0JBQXdCLENBQUMsQ0FDeEQsQ0FBQTtnQkFDSCxDQUFDLENBQ0YsQ0FBQTtnQkFFRCxJQUFJLENBQUMsQ0FBQyxDQUFDLFFBQVEsRUFBRTtvQkFDZixVQUFVLENBQUMsR0FBRyxFQUFFO3dCQUNkLElBQUksQ0FBQyxPQUFPLEVBQUUsQ0FBQTtvQkFDaEIsQ0FBQyxFQUFFLElBQUksQ0FBQyxDQUFBO2lCQUNUO1lBQ0gsQ0FBQyxDQUFBO1lBRUQsRUFBRSxDQUFDLE9BQU8sR0FBRyxDQUFDLEdBQUcsRUFBRSxFQUFFO2dCQUNuQixJQUFJLElBQUksQ0FBQyxpQkFBaUIsRUFBRTtvQkFDMUIsT0FBTyxDQUFDLEtBQUssQ0FBQywrQkFBK0IsRUFBRSxHQUFHLENBQUMsQ0FBQTtpQkFDcEQ7cUJBQU07b0JBQ0wsS0FBSyxDQUFDLHVEQUF1RCxDQUFDLENBQUE7aUJBQy9EO2dCQUVELEVBQUUsQ0FBQyxLQUFLLEVBQUUsQ0FBQTtZQUNaLENBQUMsQ0FBQTtRQUNILENBQUMsQ0FBQTtRQUVPLGVBQVUsR0FBRyxDQUFDLE1BQWUsRUFBRSxFQUFFOztZQUN2QyxLQUFLLENBQUMsWUFBWSxDQUFDLENBQUE7WUFDbkIsSUFBSSxDQUFDLG9CQUFvQixDQUFDLEtBQUssQ0FBQyxDQUFBO1lBQ2hDLElBQUksQ0FBQyxnQ0FBZ0MsR0FBRyxLQUFLLENBQUE7WUFDN0MsTUFBQSxJQUFJLENBQUMsU0FBUywwQ0FBRSxLQUFLLENBQUMsQ0FBQyxFQUFFLE1BQU0sQ0FBQyxDQUFBO1lBQ2hDLElBQUksQ0FBQyxTQUFTLEdBQUcsU0FBUyxDQUFBO1lBQzFCLElBQUksQ0FBQyxXQUFXLEdBQUcsU0FBUyxDQUFBO1FBQzlCLENBQUMsQ0FBQTtRQUVPLHVCQUFrQixHQUFHLENBQUMsR0FBaUIsRUFBRSxFQUFFO1lBQ2pELEtBQUssQ0FBQyxvQkFBb0IsRUFBRSxHQUFHLENBQUMsQ0FBQTtZQUVoQyxJQUFJLElBQUksQ0FBQTtZQUVSLElBQUk7Z0JBQ0YsSUFBSSxHQUFHLElBQUksQ0FBQyxLQUFLLENBQUMsR0FBRyxDQUFDLElBQUksQ0FBQyxDQUFBO2FBQzVCO1lBQUMsT0FBTyxDQUFNLEVBQUU7Z0JBQ2YsT0FBTyxDQUFDLEtBQUssQ0FBQyxzQkFBc0IsRUFBRSxDQUFDLENBQUMsQ0FBQTthQUN6QztZQUVELE1BQU0sZUFBZSxHQUFHLElBQUksZUFBZSxDQUFDLElBQUksQ0FBQyxDQUFBO1lBRWpELElBQUksQ0FBQyxlQUFlLENBQUMsYUFBYSxFQUFFO2dCQUNsQyxPQUFPLENBQUMsS0FBSyxDQUNYLDRHQUE0RyxFQUM1RyxJQUFJLENBQ0wsQ0FBQTtnQkFFRCxPQUFNO2FBQ1A7WUFFRCxNQUFNLHFCQUFxQixHQUN6QixJQUFJLENBQUMsMEJBQTBCLENBQUMsZUFBZSxDQUFDLGFBQWEsQ0FBQyxDQUFBO1lBRWhFLElBQUkscUJBQXFCLEVBQUU7Z0JBQ3pCLHFCQUFxQixDQUFDLE9BQU8sQ0FBQyxlQUFlLENBQUMsQ0FBQTthQUMvQztpQkFBTTtnQkFDTCxPQUFPLENBQUMsSUFBSSxDQUNWLDJEQUEyRCxFQUMzRCxJQUFJLENBQ0wsQ0FBQTthQUNGO1FBQ0gsQ0FBQyxDQUFBO1FBRU8sb0JBQWUsR0FBRyxHQUFTLEVBQUU7WUFDbkMsS0FBSyxDQUFDLGlCQUFpQixDQUFDLENBQUE7WUFFeEIsSUFBSSxDQUFDLFVBQVUsQ0FBQyxvQ0FBb0MsQ0FBQyxDQUFBO1lBQ3JELE1BQU0sS0FBSyxDQUFDLEdBQUcsQ0FBQyxDQUFBO1lBQ2hCLElBQUksQ0FBQyxPQUFPLEVBQUUsQ0FBQTtRQUNoQixDQUFDLENBQUEsQ0FBQTtRQUVPLFNBQUksR0FBRyxDQUFPLElBQW9CLEVBQTRCLEVBQUU7O1lBQ3RFLEtBQUssQ0FBQyxNQUFNLEVBQUUsSUFBSSxDQUFDLENBQUE7WUFFbkIsTUFBTSxhQUFhLEdBQUcsSUFBSSxDQUFDLE1BQU0sRUFBRSxDQUFDLFFBQVEsRUFBRSxDQUFBO1lBRTlDLElBQUksQ0FBQyxhQUFhLEdBQUcsSUFBSSxDQUFDLGFBQWEsSUFBSSxhQUFhLENBQUE7WUFFeEQsSUFBSSxjQUFjLEdBQUcsSUFBSSxjQUFjLENBR3JDLGtCQUFrQixDQUFDLGtCQUFrQixDQUFDLENBQUE7WUFFeEMsTUFBQSxJQUFJLENBQUMsU0FBUywwQ0FBRSxJQUFJLENBQUMsSUFBSSxDQUFDLFNBQVMsQ0FBQyxJQUFJLENBQUMsQ0FBQyxDQUFBO1lBRTFDLElBQUksQ0FBQywwQkFBMEIsQ0FBQyxJQUFJLENBQUMsYUFBYSxDQUFDLEdBQUcsY0FBYyxDQUFBO1lBRXBFLE9BQU8sTUFBTSxjQUFjLENBQUMsT0FBTyxDQUFDLE9BQU8sQ0FBQyxHQUFHLEVBQUU7Z0JBQy9DLE9BQU8sSUFBSSxDQUFDLDBCQUEwQixDQUFDLElBQUksQ0FBQyxhQUFjLENBQUMsQ0FBQTtZQUM3RCxDQUFDLENBQUMsQ0FBQTtRQUNKLENBQUMsQ0FBQSxDQUFBO1FBRU8seUJBQW9CLEdBQUcsQ0FBQyxTQUFrQixFQUFFLEVBQUU7WUFDcEQsSUFBSSxDQUFDLGlCQUFpQixHQUFHLFNBQVMsQ0FBQTtZQUVsQyxJQUFJLElBQUksQ0FBQyxPQUFPLENBQUMsd0JBQXdCLEVBQUU7Z0JBQ3pDLElBQUksQ0FBQyxPQUFPLENBQUMsd0JBQXdCLENBQUMsU0FBUyxDQUFDLENBQUE7YUFDakQ7WUFFRCxJQUFJLFNBQVMsSUFBSSxJQUFJLENBQUMsUUFBUSxFQUFFO2dCQUM5QixJQUFJLENBQUMsV0FBVyxDQUFDLElBQUksQ0FBQyxRQUFRLENBQUMsQ0FBQTthQUNoQztRQUNILENBQUMsQ0FBQTtRQWhOQyxLQUFLLENBQUMsMEJBQTBCLENBQUMsQ0FBQTtRQUNqQyxJQUFJLENBQUMsSUFBSSxHQUFHLE9BQU8sQ0FBQyxJQUFJLENBQUE7UUFFeEIsSUFBSSxDQUFDLE9BQU8sRUFBRSxDQUFBO0lBQ2hCLENBQUM7O0FBeEJNLHFDQUFrQixHQUFHLEtBQUssQ0FBQSJ9
export { WebSocketTransport };
//# sourceMappingURL=WebSocketTransport.js.map

@@ -1,16 +0,2 @@

!function(t,e){"object"==typeof exports&&"undefined"!=typeof module?e(exports):"function"==typeof define&&define.amd?define(["exports"],e):e((t="undefined"!=typeof globalThis?globalThis:t||self).RPCClient={})}(this,(function(t){"use strict";
/*! *****************************************************************************
Copyright (c) Microsoft Corporation.
Permission to use, copy, modify, and/or distribute this software for any
purpose with or without fee is hereby granted.
THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
PERFORMANCE OF THIS SOFTWARE.
***************************************************************************** */function e(t,e,i,s){return new(i||(i=Promise))((function(n,r){function o(t){try{c(s.next(t))}catch(t){r(t)}}function a(t){try{c(s.throw(t))}catch(t){r(t)}}function c(t){var e;t.done?n(t.value):(e=t.value,e instanceof i?e:new i((function(t){t(e)}))).then(o,a)}c((s=s.apply(t,e||[])).next())}))}class i{constructor(t){const{args:e,correlationId:i,identity:s,procedure:n,scope:r,version:o}=t;if(this.args=e,i&&"string"!=typeof i)throw new Error("correlationId must be a string");if(this.correlationId=i||Math.random().toString(),s){if("object"!=typeof s)throw new Error("identity must be an object");if(s.authorization&&"string"!=typeof s.authorization)throw new Error("identity.authorization must be a string");if(s.deviceName&&"string"!=typeof s.deviceName)throw new Error("identity.deviceName must be a string");if(s.metadata&&"object"!=typeof s.metadata)throw new Error("identity.metadata must be a object");this.identity=s}if(n&&"string"!=typeof n)throw new Error("procedure must be string");if(this.procedure=n,r&&"string"!=typeof r)throw new Error("scope must be string");if(this.scope=r,o&&"string"!=typeof o)throw new Error("version must be string");this.version=o}}class s extends Error{}class n extends Error{}class r extends Error{}function o(t){if("[object Object]"!==Object.prototype.toString.call(t))return!1;const e=Object.getPrototypeOf(t);return null===e||e===Object.prototype}const a=t=>t.args?`${t.scope}${t.procedure}${t.version}${function(t,e){e||(e={}),"function"==typeof e&&(e={cmp:e});var i,s="boolean"==typeof e.cycles&&e.cycles,n=e.cmp&&(i=e.cmp,function(t){return function(e,s){var n={key:e,value:t[e]},r={key:s,value:t[s]};return i(n,r)}}),r=[];return function t(e){if(e&&e.toJSON&&"function"==typeof e.toJSON&&(e=e.toJSON()),void 0!==e){if("number"==typeof e)return isFinite(e)?""+e:"null";if("object"!=typeof e)return JSON.stringify(e);var i,o;if(Array.isArray(e)){for(o="[",i=0;i<e.length;i++)i&&(o+=","),o+=t(e[i])||"null";return o+"]"}if(null===e)return"null";if(-1!==r.indexOf(e)){if(s)return JSON.stringify("__cycle__");throw new TypeError("Converting circular structure to JSON")}var a=r.push(e)-1,c=Object.keys(e).sort(n&&n(e));for(o="",i=0;i<c.length;i++){var h=c[i],l=t(e[h]);l&&(o&&(o+=","),o+=JSON.stringify(h)+":"+l)}return r.splice(a,1),"{"+o+"}"}}(t)}(function(t,e={}){if(!o(t)&&!Array.isArray(t))throw new TypeError("Expected a plain object or array");const{deep:i,compare:s}=e,n=[],r=[],a=t=>{const e=n.indexOf(t);if(-1!==e)return r[e];const i=[];return n.push(t),r.push(i),i.push(...t.map((t=>Array.isArray(t)?a(t):o(t)?c(t):t))),i},c=t=>{const e=n.indexOf(t);if(-1!==e)return r[e];const h={},l=Object.keys(t).sort(s);n.push(t),r.push(h);for(const e of l){const s=t[e];let n;n=i&&Array.isArray(s)?a(s):i&&o(s)?c(s):s,Object.defineProperty(h,e,Object.assign(Object.assign({},Object.getOwnPropertyDescriptor(t,e)),{value:n}))}return h};return Array.isArray(t)?i?a(t):t.slice():c(t)}(t.args||{},{deep:!0}))}`:`${t.scope}${t.procedure}${t.version}`;var c="object"==typeof global&&global&&global.Object===Object&&global,h="object"==typeof self&&self&&self.Object===Object&&self,l=c||h||Function("return this")(),u=l.Symbol,d=Object.prototype,p=d.hasOwnProperty,f=d.toString,y=u?u.toStringTag:void 0;var v=Object.prototype.toString;var g=u?u.toStringTag:void 0;function b(t){return null==t?void 0===t?"[object Undefined]":"[object Null]":g&&g in Object(t)?function(t){var e=p.call(t,y),i=t[y];try{t[y]=void 0;var s=!0}catch(t){}var n=f.call(t);return s&&(e?t[y]=i:delete t[y]),n}(t):function(t){return v.call(t)}(t)}function w(t){return null!=t&&"object"==typeof t}var m=Array.isArray;function _(t){var e=typeof t;return null!=t&&("object"==e||"function"==e)}function j(t){return t}function S(t){if(!_(t))return!1;var e=b(t);return"[object Function]"==e||"[object GeneratorFunction]"==e||"[object AsyncFunction]"==e||"[object Proxy]"==e}var C,T=l["__core-js_shared__"],O=(C=/[^.]+$/.exec(T&&T.keys&&T.keys.IE_PROTO||""))?"Symbol(src)_1."+C:"";var A=Function.prototype.toString;function I(t){if(null!=t){try{return A.call(t)}catch(t){}try{return t+""}catch(t){}}return""}var k=/^\[object .+?Constructor\]$/,E=Function.prototype,z=Object.prototype,x=E.toString,R=z.hasOwnProperty,M=RegExp("^"+x.call(R).replace(/[\\^$.*+?()[\]{}|]/g,"\\$&").replace(/hasOwnProperty|(function).*?(?=\\\()| for .+?(?=\\\])/g,"$1.*?")+"$");function L(t){return!(!_(t)||(e=t,O&&O in e))&&(S(t)?M:k).test(I(t));var e}function P(t,e){var i=function(t,e){return null==t?void 0:t[e]}(t,e);return L(i)?i:void 0}var F=P(l,"WeakMap"),U=Object.create,q=function(){function t(){}return function(e){if(!_(e))return{};if(U)return U(e);t.prototype=e;var i=new t;return t.prototype=void 0,i}}();function W(t,e,i){switch(i.length){case 0:return t.call(e);case 1:return t.call(e,i[0]);case 2:return t.call(e,i[0],i[1]);case 3:return t.call(e,i[0],i[1],i[2])}return t.apply(e,i)}function D(t,e){var i=-1,s=t.length;for(e||(e=Array(s));++i<s;)e[i]=t[i];return e}var N=Date.now;var B,$,H,G=function(){try{var t=P(Object,"defineProperty");return t({},"",{}),t}catch(t){}}(),J=G,V=J?function(t,e){return J(t,"toString",{configurable:!0,enumerable:!1,value:(i=e,function(){return i}),writable:!0});var i}:j,K=(B=V,$=0,H=0,function(){var t=N(),e=16-(t-H);if(H=t,e>0){if(++$>=800)return arguments[0]}else $=0;return B.apply(void 0,arguments)}),X=K;var Z=/^(?:0|[1-9]\d*)$/;function Q(t,e){var i=typeof t;return!!(e=null==e?9007199254740991:e)&&("number"==i||"symbol"!=i&&Z.test(t))&&t>-1&&t%1==0&&t<e}function Y(t,e,i){"__proto__"==e&&J?J(t,e,{configurable:!0,enumerable:!0,value:i,writable:!0}):t[e]=i}function tt(t,e){return t===e||t!=t&&e!=e}var et=Object.prototype.hasOwnProperty;function it(t,e,i){var s=t[e];et.call(t,e)&&tt(s,i)&&(void 0!==i||e in t)||Y(t,e,i)}function st(t,e,i,s){var n=!i;i||(i={});for(var r=-1,o=e.length;++r<o;){var a=e[r],c=s?s(i[a],t[a],a,i,t):void 0;void 0===c&&(c=t[a]),n?Y(i,a,c):it(i,a,c)}return i}var nt=Math.max;function rt(t,e){return X(function(t,e,i){return e=nt(void 0===e?t.length-1:e,0),function(){for(var s=arguments,n=-1,r=nt(s.length-e,0),o=Array(r);++n<r;)o[n]=s[e+n];n=-1;for(var a=Array(e+1);++n<e;)a[n]=s[n];return a[e]=i(o),W(t,this,a)}}(t,e,j),t+"")}function ot(t){return"number"==typeof t&&t>-1&&t%1==0&&t<=9007199254740991}function at(t){return null!=t&&ot(t.length)&&!S(t)}var ct=Object.prototype;function ht(t){var e=t&&t.constructor;return t===("function"==typeof e&&e.prototype||ct)}function lt(t){return w(t)&&"[object Arguments]"==b(t)}var ut=Object.prototype,dt=ut.hasOwnProperty,pt=ut.propertyIsEnumerable,ft=lt(function(){return arguments}())?lt:function(t){return w(t)&&dt.call(t,"callee")&&!pt.call(t,"callee")},yt=ft;var vt="object"==typeof t&&t&&!t.nodeType&&t,gt=vt&&"object"==typeof module&&module&&!module.nodeType&&module,bt=gt&&gt.exports===vt?l.Buffer:void 0,wt=(bt?bt.isBuffer:void 0)||function(){return!1},mt={};function _t(t){return function(e){return t(e)}}mt["[object Float32Array]"]=mt["[object Float64Array]"]=mt["[object Int8Array]"]=mt["[object Int16Array]"]=mt["[object Int32Array]"]=mt["[object Uint8Array]"]=mt["[object Uint8ClampedArray]"]=mt["[object Uint16Array]"]=mt["[object Uint32Array]"]=!0,mt["[object Arguments]"]=mt["[object Array]"]=mt["[object ArrayBuffer]"]=mt["[object Boolean]"]=mt["[object DataView]"]=mt["[object Date]"]=mt["[object Error]"]=mt["[object Function]"]=mt["[object Map]"]=mt["[object Number]"]=mt["[object Object]"]=mt["[object RegExp]"]=mt["[object Set]"]=mt["[object String]"]=mt["[object WeakMap]"]=!1;var jt="object"==typeof t&&t&&!t.nodeType&&t,St=jt&&"object"==typeof module&&module&&!module.nodeType&&module,Ct=St&&St.exports===jt&&c.process,Tt=function(){try{var t=St&&St.require&&St.require("util").types;return t||Ct&&Ct.binding&&Ct.binding("util")}catch(t){}}(),Ot=Tt&&Tt.isTypedArray,At=Ot?_t(Ot):function(t){return w(t)&&ot(t.length)&&!!mt[b(t)]},It=Object.prototype.hasOwnProperty;function kt(t,e){var i=m(t),s=!i&&yt(t),n=!i&&!s&&wt(t),r=!i&&!s&&!n&&At(t),o=i||s||n||r,a=o?function(t,e){for(var i=-1,s=Array(t);++i<t;)s[i]=e(i);return s}(t.length,String):[],c=a.length;for(var h in t)!e&&!It.call(t,h)||o&&("length"==h||n&&("offset"==h||"parent"==h)||r&&("buffer"==h||"byteLength"==h||"byteOffset"==h)||Q(h,c))||a.push(h);return a}function Et(t,e){return function(i){return t(e(i))}}var zt=Et(Object.keys,Object),xt=Object.prototype.hasOwnProperty;function Rt(t){return at(t)?kt(t):function(t){if(!ht(t))return zt(t);var e=[];for(var i in Object(t))xt.call(t,i)&&"constructor"!=i&&e.push(i);return e}(t)}var Mt=Object.prototype.hasOwnProperty;function Lt(t){if(!_(t))return function(t){var e=[];if(null!=t)for(var i in Object(t))e.push(i);return e}(t);var e=ht(t),i=[];for(var s in t)("constructor"!=s||!e&&Mt.call(t,s))&&i.push(s);return i}function Pt(t){return at(t)?kt(t,!0):Lt(t)}var Ft=P(Object,"create");var Ut=Object.prototype.hasOwnProperty;var qt=Object.prototype.hasOwnProperty;function Wt(t){var e=-1,i=null==t?0:t.length;for(this.clear();++e<i;){var s=t[e];this.set(s[0],s[1])}}function Dt(t,e){for(var i=t.length;i--;)if(tt(t[i][0],e))return i;return-1}Wt.prototype.clear=function(){this.__data__=Ft?Ft(null):{},this.size=0},Wt.prototype.delete=function(t){var e=this.has(t)&&delete this.__data__[t];return this.size-=e?1:0,e},Wt.prototype.get=function(t){var e=this.__data__;if(Ft){var i=e[t];return"__lodash_hash_undefined__"===i?void 0:i}return Ut.call(e,t)?e[t]:void 0},Wt.prototype.has=function(t){var e=this.__data__;return Ft?void 0!==e[t]:qt.call(e,t)},Wt.prototype.set=function(t,e){var i=this.__data__;return this.size+=this.has(t)?0:1,i[t]=Ft&&void 0===e?"__lodash_hash_undefined__":e,this};var Nt=Array.prototype.splice;function Bt(t){var e=-1,i=null==t?0:t.length;for(this.clear();++e<i;){var s=t[e];this.set(s[0],s[1])}}Bt.prototype.clear=function(){this.__data__=[],this.size=0},Bt.prototype.delete=function(t){var e=this.__data__,i=Dt(e,t);return!(i<0)&&(i==e.length-1?e.pop():Nt.call(e,i,1),--this.size,!0)},Bt.prototype.get=function(t){var e=this.__data__,i=Dt(e,t);return i<0?void 0:e[i][1]},Bt.prototype.has=function(t){return Dt(this.__data__,t)>-1},Bt.prototype.set=function(t,e){var i=this.__data__,s=Dt(i,t);return s<0?(++this.size,i.push([t,e])):i[s][1]=e,this};var $t=P(l,"Map");function Ht(t,e){var i,s,n=t.__data__;return("string"==(s=typeof(i=e))||"number"==s||"symbol"==s||"boolean"==s?"__proto__"!==i:null===i)?n["string"==typeof e?"string":"hash"]:n.map}function Gt(t){var e=-1,i=null==t?0:t.length;for(this.clear();++e<i;){var s=t[e];this.set(s[0],s[1])}}function Jt(t,e){for(var i=-1,s=e.length,n=t.length;++i<s;)t[n+i]=e[i];return t}Gt.prototype.clear=function(){this.size=0,this.__data__={hash:new Wt,map:new($t||Bt),string:new Wt}},Gt.prototype.delete=function(t){var e=Ht(this,t).delete(t);return this.size-=e?1:0,e},Gt.prototype.get=function(t){return Ht(this,t).get(t)},Gt.prototype.has=function(t){return Ht(this,t).has(t)},Gt.prototype.set=function(t,e){var i=Ht(this,t),s=i.size;return i.set(t,e),this.size+=i.size==s?0:1,this};var Vt=Et(Object.getPrototypeOf,Object),Kt=Function.prototype,Xt=Object.prototype,Zt=Kt.toString,Qt=Xt.hasOwnProperty,Yt=Zt.call(Object);function te(t){var e=this.__data__=new Bt(t);this.size=e.size}te.prototype.clear=function(){this.__data__=new Bt,this.size=0},te.prototype.delete=function(t){var e=this.__data__,i=e.delete(t);return this.size=e.size,i},te.prototype.get=function(t){return this.__data__.get(t)},te.prototype.has=function(t){return this.__data__.has(t)},te.prototype.set=function(t,e){var i=this.__data__;if(i instanceof Bt){var s=i.__data__;if(!$t||s.length<199)return s.push([t,e]),this.size=++i.size,this;i=this.__data__=new Gt(s)}return i.set(t,e),this.size=i.size,this};var ee="object"==typeof t&&t&&!t.nodeType&&t,ie=ee&&"object"==typeof module&&module&&!module.nodeType&&module,se=ie&&ie.exports===ee?l.Buffer:void 0,ne=se?se.allocUnsafe:void 0;function re(t,e){if(e)return t.slice();var i=t.length,s=ne?ne(i):new t.constructor(i);return t.copy(s),s}function oe(){return[]}var ae=Object.prototype.propertyIsEnumerable,ce=Object.getOwnPropertySymbols,he=ce?function(t){return null==t?[]:(t=Object(t),function(t,e){for(var i=-1,s=null==t?0:t.length,n=0,r=[];++i<s;){var o=t[i];e(o,i,t)&&(r[n++]=o)}return r}(ce(t),(function(e){return ae.call(t,e)})))}:oe;var le=Object.getOwnPropertySymbols?function(t){for(var e=[];t;)Jt(e,he(t)),t=Vt(t);return e}:oe;function ue(t,e,i){var s=e(t);return m(t)?s:Jt(s,i(t))}function de(t){return ue(t,Rt,he)}function pe(t){return ue(t,Pt,le)}var fe=P(l,"DataView"),ye=P(l,"Promise"),ve=P(l,"Set"),ge="[object Map]",be="[object Promise]",we="[object Set]",me="[object WeakMap]",_e="[object DataView]",je=I(fe),Se=I($t),Ce=I(ye),Te=I(ve),Oe=I(F),Ae=b;(fe&&Ae(new fe(new ArrayBuffer(1)))!=_e||$t&&Ae(new $t)!=ge||ye&&Ae(ye.resolve())!=be||ve&&Ae(new ve)!=we||F&&Ae(new F)!=me)&&(Ae=function(t){var e=b(t),i="[object Object]"==e?t.constructor:void 0,s=i?I(i):"";if(s)switch(s){case je:return _e;case Se:return ge;case Ce:return be;case Te:return we;case Oe:return me}return e});var Ie=Ae,ke=Object.prototype.hasOwnProperty;var Ee=l.Uint8Array;function ze(t){var e=new t.constructor(t.byteLength);return new Ee(e).set(new Ee(t)),e}var xe=/\w*$/;var Re=u?u.prototype:void 0,Me=Re?Re.valueOf:void 0;function Le(t,e){var i=e?ze(t.buffer):t.buffer;return new t.constructor(i,t.byteOffset,t.length)}function Pe(t,e,i){var s,n,r,o=t.constructor;switch(e){case"[object ArrayBuffer]":return ze(t);case"[object Boolean]":case"[object Date]":return new o(+t);case"[object DataView]":return function(t,e){var i=e?ze(t.buffer):t.buffer;return new t.constructor(i,t.byteOffset,t.byteLength)}(t,i);case"[object Float32Array]":case"[object Float64Array]":case"[object Int8Array]":case"[object Int16Array]":case"[object Int32Array]":case"[object Uint8Array]":case"[object Uint8ClampedArray]":case"[object Uint16Array]":case"[object Uint32Array]":return Le(t,i);case"[object Map]":case"[object Set]":return new o;case"[object Number]":case"[object String]":return new o(t);case"[object RegExp]":return(r=new(n=t).constructor(n.source,xe.exec(n))).lastIndex=n.lastIndex,r;case"[object Symbol]":return s=t,Me?Object(Me.call(s)):{}}}function Fe(t){return"function"!=typeof t.constructor||ht(t)?{}:q(Vt(t))}var Ue=Tt&&Tt.isMap,qe=Ue?_t(Ue):function(t){return w(t)&&"[object Map]"==Ie(t)};var We=Tt&&Tt.isSet,De=We?_t(We):function(t){return w(t)&&"[object Set]"==Ie(t)},Ne="[object Arguments]",Be="[object Function]",$e="[object Object]",He={};function Ge(t,e,i,s,n,r){var o,a=1&e,c=2&e,h=4&e;if(i&&(o=n?i(t,s,n,r):i(t)),void 0!==o)return o;if(!_(t))return t;var l=m(t);if(l){if(o=function(t){var e=t.length,i=new t.constructor(e);return e&&"string"==typeof t[0]&&ke.call(t,"index")&&(i.index=t.index,i.input=t.input),i}(t),!a)return D(t,o)}else{var u=Ie(t),d=u==Be||"[object GeneratorFunction]"==u;if(wt(t))return re(t,a);if(u==$e||u==Ne||d&&!n){if(o=c||d?{}:Fe(t),!a)return c?function(t,e){return st(t,le(t),e)}(t,function(t,e){return t&&st(e,Pt(e),t)}(o,t)):function(t,e){return st(t,he(t),e)}(t,function(t,e){return t&&st(e,Rt(e),t)}(o,t))}else{if(!He[u])return n?t:{};o=Pe(t,u,a)}}r||(r=new te);var p=r.get(t);if(p)return p;r.set(t,o),De(t)?t.forEach((function(s){o.add(Ge(s,e,i,s,t,r))})):qe(t)&&t.forEach((function(s,n){o.set(n,Ge(s,e,i,n,t,r))}));var f=l?void 0:(h?c?pe:de:c?Pt:Rt)(t);return function(t,e){for(var i=-1,s=null==t?0:t.length;++i<s&&!1!==e(t[i],i,t););}(f||t,(function(s,n){f&&(s=t[n=s]),it(o,n,Ge(s,e,i,n,t,r))})),o}He[Ne]=He["[object Array]"]=He["[object ArrayBuffer]"]=He["[object DataView]"]=He["[object Boolean]"]=He["[object Date]"]=He["[object Float32Array]"]=He["[object Float64Array]"]=He["[object Int8Array]"]=He["[object Int16Array]"]=He["[object Int32Array]"]=He["[object Map]"]=He["[object Number]"]=He[$e]=He["[object RegExp]"]=He["[object Set]"]=He["[object String]"]=He["[object Symbol]"]=He["[object Uint8Array]"]=He["[object Uint8ClampedArray]"]=He["[object Uint16Array]"]=He["[object Uint32Array]"]=!0,He["[object Error]"]=He[Be]=He["[object WeakMap]"]=!1;function Je(t){return Ge(t,5)}var Ve,Ke=function(t,e,i){for(var s=-1,n=Object(t),r=i(t),o=r.length;o--;){var a=r[Ve?o:++s];if(!1===e(n[a],a,n))break}return t};function Xe(t,e,i){(void 0!==i&&!tt(t[e],i)||void 0===i&&!(e in t))&&Y(t,e,i)}function Ze(t,e){if(("constructor"!==e||"function"!=typeof t[e])&&"__proto__"!=e)return t[e]}function Qe(t,e,i,s,n,r,o){var a=Ze(t,i),c=Ze(e,i),h=o.get(c);if(h)Xe(t,i,h);else{var l,u=r?r(a,c,i+"",t,e,o):void 0,d=void 0===u;if(d){var p=m(c),f=!p&&wt(c),y=!p&&!f&&At(c);u=c,p||f||y?m(a)?u=a:w(l=a)&&at(l)?u=D(a):f?(d=!1,u=re(c,!0)):y?(d=!1,u=Le(c,!0)):u=[]:function(t){if(!w(t)||"[object Object]"!=b(t))return!1;var e=Vt(t);if(null===e)return!0;var i=Qt.call(e,"constructor")&&e.constructor;return"function"==typeof i&&i instanceof i&&Zt.call(i)==Yt}(c)||yt(c)?(u=a,yt(a)?u=function(t){return st(t,Pt(t))}(a):_(a)&&!S(a)||(u=Fe(c))):d=!1}d&&(o.set(c,u),n(u,c,s,r,o),o.delete(c)),Xe(t,i,u)}}function Ye(t,e,i,s,n){t!==e&&Ke(e,(function(r,o){if(n||(n=new te),_(r))Qe(t,e,o,i,Ye,s,n);else{var a=s?s(Ze(t,o),r,o+"",t,e,n):void 0;void 0===a&&(a=r),Xe(t,o,a)}}),Pt)}var ti,ei=(ti=function(t,e,i){Ye(t,e,i)},rt((function(t,e){var i=-1,s=e.length,n=s>1?e[s-1]:void 0,r=s>2?e[2]:void 0;for(n=ti.length>3&&"function"==typeof n?(s--,n):void 0,r&&function(t,e,i){if(!_(i))return!1;var s=typeof e;return!!("number"==s?at(i)&&Q(e,i.length):"string"==s&&e in i)&&tt(i[e],t)}(e[0],e[1],r)&&(n=s<3?void 0:n,s=1),t=Object(t);++i<s;){var o=e[i];o&&ti(t,o,i,n)}return t})));let ii=null;try{ii=localStorage.getItem("debug")||""}catch(t){"undefined"!=typeof window&&"undefined"!=typeof localStorage&&console.warn("Error checking window.debug")}const si=t=>ii&&new RegExp(ii).test(t)?(...e)=>console.log(t,...e):()=>{},ni=si("rpc:ClientManager");class ri{constructor(t){this.options=t,this.inflightCallsByKey={},this.interceptors={request:[],response:[]},this.addResponseInterceptor=t=>{if("function"!=typeof t)throw new Error("cannot add interceptor that is not a function");this.interceptors.response.push(t)},this.addRequestInterceptor=t=>{if("function"!=typeof t)throw new Error("cannot add interceptor that is not a function");this.interceptors.request.push(t)},this.clearCache=t=>{ni("clearCache"),this.cache&&(t?this.cache.setCachedResponse(t,void 0):this.cache.clearCache())},this.getCachedResponse=t=>{var e;return ni("getCachedResponse",t),null===(e=null==this?void 0:this.cache)||void 0===e?void 0:e.getCachedResponse(t)},this.getInFlightCallCount=()=>(ni("getInFlightCallCount"),Object.keys(this.inflightCallsByKey).length),this.manageClientRequest=t=>e(this,void 0,void 0,(function*(){ni("manageClientRequest",t);const i=yield this.interceptRequestMutator(t),s=a(i);if(this.inflightCallsByKey.hasOwnProperty(s))return ni("manageClientRequest using an existing in-flight call",s),this.inflightCallsByKey[s].then((e=>{const i=Je(e);return t.correlationId&&(i.correlationId=t.correlationId),i}));const n=(()=>e(this,void 0,void 0,(function*(){const t=yield this.sendRequestWithTransport(i),e=yield this.interceptResponseMutator(t,i);return this.cache&&e&&this.cache.setCachedResponse(i,e),e})))().then((t=>(delete this.inflightCallsByKey[s],t))).catch((t=>{throw delete this.inflightCallsByKey[s],t}));return this.inflightCallsByKey[s]=n,yield n})),this.setIdentity=t=>{ni("setIdentity",t),this.transports.forEach((e=>e.setIdentity(t)))},this.interceptRequestMutator=t=>e(this,void 0,void 0,(function*(){let e=t;if(this.interceptors.request.length){ni("interceptRequestMutator(), original request:",t);for(const t of this.interceptors.request)e=yield t(e)}return e})),this.interceptResponseMutator=(t,i)=>e(this,void 0,void 0,(function*(){let e=t;if(this.interceptors.response.length){ni("interceptResponseMutator",i,t);for(const s of this.interceptors.response)try{e=yield s(e,i)}catch(s){throw ni("caught response interceptor, request:",i,"original response:",t,"mutated response:",e),s}}return e})),this.sendRequestWithTransport=t=>e(this,void 0,void 0,(function*(){let e;ni("sendRequestWithTransport",t);let i=0;for(;!e&&this.transports[i];){const s=this.transports[i];if(s.isConnected()){ni(`sendRequestWithTransport trying ${this.transports[i].name}`,t);try{let i;const n=new Promise(((e,s)=>{i=setTimeout((()=>{s(new r(`Procedure ${t.procedure}`))}),this.options.deadlineMs)}));e=yield Promise.race([n,s.sendRequest(t)]).then((t=>(clearTimeout(i),t)))}catch(t){if(!(t instanceof r||t instanceof n))throw t;ni(`sending request with ${this.transports[i].name} failed, trying next transport`),i++}}else i++}if(!e&&!this.transports[i])throw new s(`Procedure ${t.procedure} did not get a response from any transports`);if(!e)throw new s(`Procedure ${t.procedure} did not get a response from the remote`);return e})),this.cache=t.cache,t.requestInterceptor&&this.interceptors.request.push(t.requestInterceptor),t.responseInterceptor&&this.interceptors.response.push(t.responseInterceptor),this.transports=t.transports}}class oi{constructor(t){this.cacheOptions=t}clearCache(){}getCachedResponse(t){}setCachedResponse(t,e){}}oi.DEFAULT_CACHE_MAX_AGE_MS=3e5,oi.DEFAULT_CACHE_MAX_SIZE=100;const ai="object"==typeof performance&&performance&&"function"==typeof performance.now?performance:Date,ci="undefined"!=typeof AbortController?AbortController:Object.assign(class{constructor(){this.signal=new ci.AbortSignal}abort(){this.signal.aborted=!0}},{AbortSignal:class{constructor(){this.aborted=!1}}}),hi=new Set,li=(t,e)=>{const i=`LRU_CACHE_OPTION_${t}`;pi(i)&&fi(i,`${t} option`,`options.${e}`,wi)},ui=(t,e)=>{const i=`LRU_CACHE_METHOD_${t}`;if(pi(i)){const{prototype:s}=wi,{get:n}=Object.getOwnPropertyDescriptor(s,t);fi(i,`${t} method`,`cache.${e}()`,n)}},di=(...t)=>{"object"==typeof process&&process&&"function"==typeof process.emitWarning?process.emitWarning(...t):console.error(...t)},pi=t=>!hi.has(t),fi=(t,e,i,s)=>{hi.add(t);di(`The ${e} is deprecated. Please use ${i} instead.`,"DeprecationWarning",t,s)},yi=t=>t&&t===Math.floor(t)&&t>0&&isFinite(t),vi=t=>yi(t)?t<=Math.pow(2,8)?Uint8Array:t<=Math.pow(2,16)?Uint16Array:t<=Math.pow(2,32)?Uint32Array:t<=Number.MAX_SAFE_INTEGER?gi:null:null;class gi extends Array{constructor(t){super(t),this.fill(0)}}class bi{constructor(t){if(0===t)return[];const e=vi(t);this.heap=new e(t),this.length=0}push(t){this.heap[this.length++]=t}pop(){return this.heap[--this.length]}}class wi{constructor(t={}){const{max:e=0,ttl:i,ttlResolution:s=1,ttlAutopurge:n,updateAgeOnGet:r,updateAgeOnHas:o,allowStale:a,dispose:c,disposeAfter:h,noDisposeOnSet:l,noUpdateTTL:u,maxSize:d=0,sizeCalculation:p,fetchMethod:f}=t,{length:y,maxAge:v,stale:g}=t instanceof wi?{}:t;if(0!==e&&!yi(e))throw new TypeError("max option must be a nonnegative integer");const b=e?vi(e):Array;if(!b)throw new Error("invalid max value: "+e);if(this.max=e,this.maxSize=d,this.sizeCalculation=p||y,this.sizeCalculation){if(!this.maxSize)throw new TypeError("cannot set sizeCalculation without setting maxSize");if("function"!=typeof this.sizeCalculation)throw new TypeError("sizeCalculation set to non-function")}if(this.fetchMethod=f||null,this.fetchMethod&&"function"!=typeof this.fetchMethod)throw new TypeError("fetchMethod must be a function if specified");if(this.keyMap=new Map,this.keyList=new Array(e).fill(null),this.valList=new Array(e).fill(null),this.next=new b(e),this.prev=new b(e),this.head=0,this.tail=0,this.free=new bi(e),this.initialFill=1,this.size=0,"function"==typeof c&&(this.dispose=c),"function"==typeof h?(this.disposeAfter=h,this.disposed=[]):(this.disposeAfter=null,this.disposed=null),this.noDisposeOnSet=!!l,this.noUpdateTTL=!!u,0!==this.maxSize){if(!yi(this.maxSize))throw new TypeError("maxSize must be a positive integer if specified");this.initializeSizeTracking()}if(this.allowStale=!!a||!!g,this.updateAgeOnGet=!!r,this.updateAgeOnHas=!!o,this.ttlResolution=yi(s)||0===s?s:1,this.ttlAutopurge=!!n,this.ttl=i||v||0,this.ttl){if(!yi(this.ttl))throw new TypeError("ttl must be a positive integer if specified");this.initializeTTLTracking()}if(0===this.max&&0===this.ttl&&0===this.maxSize)throw new TypeError("At least one of max, maxSize, or ttl is required");if(!this.ttlAutopurge&&!this.max&&!this.maxSize){const t="LRU_CACHE_UNBOUNDED";if(pi(t)){hi.add(t);di("TTL caching without ttlAutopurge, max, or maxSize can result in unbounded memory consumption.","UnboundedCacheWarning",t,wi)}}g&&li("stale","allowStale"),v&&li("maxAge","ttl"),y&&li("length","sizeCalculation")}getRemainingTTL(t){return this.has(t,{updateAgeOnHas:!1})?1/0:0}initializeTTLTracking(){this.ttls=new gi(this.max),this.starts=new gi(this.max),this.setItemTTL=(t,e)=>{if(this.starts[t]=0!==e?ai.now():0,this.ttls[t]=e,0!==e&&this.ttlAutopurge){const i=setTimeout((()=>{this.isStale(t)&&this.delete(this.keyList[t])}),e+1);i.unref&&i.unref()}},this.updateItemAge=t=>{this.starts[t]=0!==this.ttls[t]?ai.now():0};let t=0;const e=()=>{const e=ai.now();if(this.ttlResolution>0){t=e;const i=setTimeout((()=>t=0),this.ttlResolution);i.unref&&i.unref()}return e};this.getRemainingTTL=i=>{const s=this.keyMap.get(i);return void 0===s?0:0===this.ttls[s]||0===this.starts[s]?1/0:this.starts[s]+this.ttls[s]-(t||e())},this.isStale=i=>0!==this.ttls[i]&&0!==this.starts[i]&&(t||e())-this.starts[i]>this.ttls[i]}updateItemAge(t){}setItemTTL(t,e){}isStale(t){return!1}initializeSizeTracking(){this.calculatedSize=0,this.sizes=new gi(this.max),this.removeItemSize=t=>this.calculatedSize-=this.sizes[t],this.requireSize=(t,e,i,s)=>{if(!yi(i)){if(!s)throw new TypeError("invalid size value (must be positive integer)");if("function"!=typeof s)throw new TypeError("sizeCalculation must be a function");if(i=s(e,t),!yi(i))throw new TypeError("sizeCalculation return invalid (expect positive integer)")}return i},this.addItemSize=(t,e,i,s)=>{this.sizes[t]=s;const n=this.maxSize-this.sizes[t];for(;this.calculatedSize>n;)this.evict(!0);this.calculatedSize+=this.sizes[t]},this.delete=t=>{if(0!==this.size){const e=this.keyMap.get(t);void 0!==e&&(this.calculatedSize-=this.sizes[e])}return wi.prototype.delete.call(this,t)}}removeItemSize(t){}addItemSize(t,e,i,s){}requireSize(t,e,i,s){if(i||s)throw new TypeError("cannot set size without setting maxSize on cache")}*indexes({allowStale:t=this.allowStale}={}){if(this.size)for(let e=this.tail;this.isValidIndex(e)&&(!t&&this.isStale(e)||(yield e),e!==this.head);)e=this.prev[e]}*rindexes({allowStale:t=this.allowStale}={}){if(this.size)for(let e=this.head;this.isValidIndex(e)&&(!t&&this.isStale(e)||(yield e),e!==this.tail);)e=this.next[e]}isValidIndex(t){return this.keyMap.get(this.keyList[t])===t}*entries(){for(const t of this.indexes())yield[this.keyList[t],this.valList[t]]}*rentries(){for(const t of this.rindexes())yield[this.keyList[t],this.valList[t]]}*keys(){for(const t of this.indexes())yield this.keyList[t]}*rkeys(){for(const t of this.rindexes())yield this.keyList[t]}*values(){for(const t of this.indexes())yield this.valList[t]}*rvalues(){for(const t of this.rindexes())yield this.valList[t]}[Symbol.iterator](){return this.entries()}find(t,e={}){for(const i of this.indexes())if(t(this.valList[i],this.keyList[i],this))return this.get(this.keyList[i],e)}forEach(t,e=this){for(const i of this.indexes())t.call(e,this.valList[i],this.keyList[i],this)}rforEach(t,e=this){for(const i of this.rindexes())t.call(e,this.valList[i],this.keyList[i],this)}get prune(){return ui("prune","purgeStale"),this.purgeStale}purgeStale(){let t=!1;for(const e of this.rindexes({allowStale:!0}))this.isStale(e)&&(this.delete(this.keyList[e]),t=!0);return t}dump(){const t=[];for(const e of this.indexes()){const i=this.keyList[e],s={value:this.valList[e]};this.ttls&&(s.ttl=this.ttls[e]),this.sizes&&(s.size=this.sizes[e]),t.unshift([i,s])}return t}load(t){this.clear();for(const[e,i]of t)this.set(e,i.value,i)}dispose(t,e,i){}set(t,e,{ttl:i=this.ttl,noDisposeOnSet:s=this.noDisposeOnSet,size:n=0,sizeCalculation:r=this.sizeCalculation,noUpdateTTL:o=this.noUpdateTTL}={}){n=this.requireSize(t,e,n,r);let a=0===this.size?void 0:this.keyMap.get(t);if(void 0===a)a=this.newIndex(),this.keyList[a]=t,this.valList[a]=e,this.keyMap.set(t,a),this.next[this.tail]=a,this.prev[a]=this.tail,this.tail=a,this.size++,this.addItemSize(a,e,t,n),o=!1;else{const i=this.valList[a];e!==i&&(this.isBackgroundFetch(i)?i.__abortController.abort():s||(this.dispose(i,t,"set"),this.disposeAfter&&this.disposed.push([i,t,"set"])),this.removeItemSize(a),this.valList[a]=e,this.addItemSize(a,e,t,n)),this.moveToTail(a)}if(0===i||0!==this.ttl||this.ttls||this.initializeTTLTracking(),o||this.setItemTTL(a,i),this.disposeAfter)for(;this.disposed.length;)this.disposeAfter(...this.disposed.shift());return this}newIndex(){return 0===this.size?this.tail:this.size===this.max&&0!==this.max?this.evict(!1):0!==this.free.length?this.free.pop():this.initialFill++}pop(){if(this.size){const t=this.valList[this.head];return this.evict(!0),t}}evict(t){const e=this.head,i=this.keyList[e],s=this.valList[e];return this.isBackgroundFetch(s)?s.__abortController.abort():(this.dispose(s,i,"evict"),this.disposeAfter&&this.disposed.push([s,i,"evict"])),this.removeItemSize(e),t&&(this.keyList[e]=null,this.valList[e]=null,this.free.push(e)),this.head=this.next[e],this.keyMap.delete(i),this.size--,e}has(t,{updateAgeOnHas:e=this.updateAgeOnHas}={}){const i=this.keyMap.get(t);return void 0!==i&&!this.isStale(i)&&(e&&this.updateItemAge(i),!0)}peek(t,{allowStale:e=this.allowStale}={}){const i=this.keyMap.get(t);if(void 0!==i&&(e||!this.isStale(i)))return this.valList[i]}backgroundFetch(t,e,i){const s=void 0===e?void 0:this.valList[e];if(this.isBackgroundFetch(s))return s;const n=new ci,r={signal:n.signal,options:i},o=Promise.resolve(this.fetchMethod(t,s,r)).then((e=>(n.signal.aborted||this.set(t,e,r.options),e)));return o.__abortController=n,o.__staleWhileFetching=s,void 0===e?(this.set(t,o,r.options),e=this.keyMap.get(t)):this.valList[e]=o,o}isBackgroundFetch(t){return t&&"object"==typeof t&&"function"==typeof t.then&&Object.prototype.hasOwnProperty.call(t,"__staleWhileFetching")}async fetch(t,{allowStale:e=this.allowStale,updateAgeOnGet:i=this.updateAgeOnGet,ttl:s=this.ttl,noDisposeOnSet:n=this.noDisposeOnSet,size:r=0,sizeCalculation:o=this.sizeCalculation,noUpdateTTL:a=this.noUpdateTTL}={}){if(!this.fetchMethod)return this.get(t,{allowStale:e,updateAgeOnGet:i});const c={allowStale:e,updateAgeOnGet:i,ttl:s,noDisposeOnSet:n,size:r,sizeCalculation:o,noUpdateTTL:a};let h=this.keyMap.get(t);if(void 0===h)return this.backgroundFetch(t,h,c);{const s=this.valList[h];if(this.isBackgroundFetch(s))return e&&void 0!==s.__staleWhileFetching?s.__staleWhileFetching:s;if(!this.isStale(h))return this.moveToTail(h),i&&this.updateItemAge(h),s;const n=this.backgroundFetch(t,h,c);return e&&void 0!==n.__staleWhileFetching?n.__staleWhileFetching:n}}get(t,{allowStale:e=this.allowStale,updateAgeOnGet:i=this.updateAgeOnGet}={}){const s=this.keyMap.get(t);if(void 0!==s){const n=this.valList[s],r=this.isBackgroundFetch(n);if(this.isStale(s))return r?e?n.__staleWhileFetching:void 0:(this.delete(t),e?n:void 0);if(r)return;return this.moveToTail(s),i&&this.updateItemAge(s),n}}connect(t,e){this.prev[e]=t,this.next[t]=e}moveToTail(t){t!==this.tail&&(t===this.head?this.head=this.next[t]:this.connect(this.prev[t],this.next[t]),this.connect(this.tail,t),this.tail=t)}get del(){return ui("del","delete"),this.delete}delete(t){let e=!1;if(0!==this.size){const i=this.keyMap.get(t);if(void 0!==i)if(e=!0,1===this.size)this.clear();else{this.removeItemSize(i);const e=this.valList[i];this.isBackgroundFetch(e)?e.__abortController.abort():(this.dispose(e,t,"delete"),this.disposeAfter&&this.disposed.push([e,t,"delete"])),this.keyMap.delete(t),this.keyList[i]=null,this.valList[i]=null,i===this.tail?this.tail=this.prev[i]:i===this.head?this.head=this.next[i]:(this.next[this.prev[i]]=this.next[i],this.prev[this.next[i]]=this.prev[i]),this.size--,this.free.push(i)}}if(this.disposed)for(;this.disposed.length;)this.disposeAfter(...this.disposed.shift());return e}clear(){for(const t of this.rindexes({allowStale:!0})){const e=this.valList[t];if(this.isBackgroundFetch(e))e.__abortController.abort();else{const i=this.keyList[t];this.dispose(e,i,"delete"),this.disposeAfter&&this.disposed.push([e,i,"delete"])}}if(this.keyMap.clear(),this.valList.fill(null),this.keyList.fill(null),this.ttls&&(this.ttls.fill(0),this.starts.fill(0)),this.sizes&&this.sizes.fill(0),this.head=0,this.tail=0,this.initialFill=1,this.free.length=0,this.calculatedSize=0,this.size=0,this.disposed)for(;this.disposed.length;)this.disposeAfter(...this.disposed.shift())}get reset(){return ui("reset","clear"),this.clear}get length(){return((t,e)=>{const i=`LRU_CACHE_PROPERTY_${t}`;if(pi(i)){const{prototype:s}=wi,{get:n}=Object.getOwnPropertyDescriptor(s,t);fi(i,`${t} property`,`cache.${e}`,n)}})("length","size"),this.size}}var mi=wi;const _i=si("rpc:InMemoryCache");class ji{constructor(t){this.clearCache=()=>{var t;_i("clearCache"),null===(t=this.cachedResponseByParams)||void 0===t||t.reset()},this.getCachedResponse=t=>{var e;_i("getCachedResponse, key: ",t);let i=null===(e=this.cachedResponseByParams)||void 0===e?void 0:e.get(a(t));return"string"==typeof i&&(i=JSON.parse(i)),i},this.setCachedResponse=(t,e)=>{var i,s;_i("setCachedResponse",t,e);const n=a(t);if(!e)return null===(i=this.cachedResponseByParams)||void 0===i?void 0:i.del(n);const r=Object.assign({},e);delete r.correlationId,null===(s=this.cachedResponseByParams)||void 0===s||s.set(n,r?JSON.stringify(r):void 0)},this.cachedResponseByParams=new mi({max:(null==t?void 0:t.cacheMaxSize)||ji.DEFAULT_CACHE_MAX_SIZE,ttl:(null==t?void 0:t.cacheMaxAgeMs)||ji.DEFAULT_CACHE_MAX_AGE_MS})}}ji.DEFAULT_CACHE_MAX_AGE_MS=3e5,ji.DEFAULT_CACHE_MAX_SIZE=100;class Si{constructor(t){const{code:e,correlationId:i,data:s,message:n,success:r}=t;if("number"!=typeof e)throw new Error("code must be a number");if(this.code=e,i&&"string"!=typeof i)throw new Error("correlationId must be a string");if(this.correlationId=i,this.data=s,n&&"string"!=typeof n)throw new Error("message must be a string");if(this.message=n,"boolean"!=typeof r)throw new Error("success must be a boolean");this.success=r}}const Ci=si("rpc:HTTPTransport");class Ti{constructor(t){this.options=t,this.networkIsConnected=!1,this.name="HttpTransport",this.isConnected=()=>{var t;return"undefined"!=typeof window?!!(null===(t=null===window||void 0===window?void 0:window.navigator)||void 0===t?void 0:t.onLine):this.networkIsConnected},this.sendRequest=t=>e(this,void 0,void 0,(function*(){Ci("sendRequest",t);const e=JSON.stringify(Object.assign({identity:this.identity},t)),i=yield null===window||void 0===window?void 0:window.fetch(this.host,{body:e,cache:"default",credentials:"omit",headers:{"Content-Type":"application/json"},method:"POST",mode:"cors",redirect:"follow",referrerPolicy:"origin"}),s=yield i.text();if(!s)throw new Error("No response received from remote");const n=JSON.parse(s);return new Si(n)})),this.setIdentity=t=>{Ci("setIdentity",t),this.identity=t},this.host=t.host}}class Oi{constructor(t){this.reject=t=>{this.rejectPromise&&this.rejectPromise(t)},this.resolve=t=>{this.resolvePromise&&this.resolvePromise(t)},this.promise=new Promise(((i,s)=>e(this,void 0,void 0,(function*(){const e=setTimeout((()=>{s(new Error("PromiseWraper timeout"))}),t||3e4);this.rejectPromise=t=>{clearTimeout(e),s(t)},this.resolvePromise=t=>{clearTimeout(e),i(t)}}))))}}const Ai=t=>new Promise((e=>setTimeout(e,t))),Ii=si("rpc:WebSocketTransport");class ki{constructor(t){this.options=t,this.connectedToRemote=!1,this.isWaitingForIdentityConfirmation=!1,this.pendingPromisesForResponse={},this.websocketId=void 0,this.name="WebSocketTransport",this.isConnected=()=>this.connectedToRemote&&!!this.websocket,this.sendRequest=t=>e(this,void 0,void 0,(function*(){for(Ii("sendRequest",t);this.isWaitingForIdentityConfirmation;)Ii("waiting for identity confirmation"),yield Ai(100);return this.send(t)})),this.setIdentity=t=>{if(Ii("setIdentity",t),!t)return this.identity=void 0,void this.resetConnection();this.identity=t,this.connectedToRemote?(this.isWaitingForIdentityConfirmation=!0,this.send({identity:t}).then((()=>{Ii("setIdentity with remote complete")})).catch((t=>{Ii("setIdentity with remote error",t)})).finally((()=>{this.isWaitingForIdentityConfirmation=!1}))):Ii("setIdentity is not connected to remote")},this.connect=()=>{if(Ii("connect",this.host),this.websocket)return void Ii("connect() returning early, websocket already exists");this.websocketId=Math.random(),this.websocket=new WebSocket(this.host);const t=this.websocket;t.onopen=()=>{console.log("WebSocket connected:"),this.setConnectedToRemote(!0),this.identity&&this.setIdentity(this.identity)},t.onmessage=t=>{this.handleWebSocketMsg(t)},t.onclose=t=>{this.connectedToRemote?console.log("WebSocket closed",t.reason):Ii("WebSocket closed, it was not connected to the remote"),this.setConnectedToRemote(!1),this.isWaitingForIdentityConfirmation=!1,this.websocket=void 0,this.websocketId=void 0,Object.entries(this.pendingPromisesForResponse).forEach((([t,e])=>{e.reject(new n("Websocket disconnected"))})),t.wasClean||setTimeout((()=>{this.connect()}),1e3)},t.onerror=e=>{this.connectedToRemote?console.error("Socket encountered error: ",e):Ii("WebSocket errored, it was not connected to the remote"),t.close()}},this.disconnect=()=>{var t;Ii("disconnect"),this.setConnectedToRemote(!1),this.isWaitingForIdentityConfirmation=!1,null===(t=this.websocket)||void 0===t||t.close(),this.websocket=void 0,this.websocketId=void 0},this.handleWebSocketMsg=t=>{let e;Ii("handleWebSocketMsg",t);try{e=JSON.parse(t.data)}catch(t){console.error("error parsing WS msg",t)}const i=new Si(e);if(!i.correlationId)return void console.error("RPCClient WebSocketTransport received unexpected msg from the server, not correlationId found in response.",e);const s=this.pendingPromisesForResponse[i.correlationId];s?s.resolve(i):console.warn("rcvd WS msg/response that doesn't match any pending RPC's",e)},this.resetConnection=()=>{Ii("resetConnection"),this.disconnect(),this.connect()},this.send=t=>e(this,void 0,void 0,(function*(){var e;Ii("send",t);const i=Math.random().toString();t.correlationId=t.correlationId||i;let s=new Oi(ki.DEFAULT_TIMEOUT_MS);return null===(e=this.websocket)||void 0===e||e.send(JSON.stringify(t)),this.pendingPromisesForResponse[t.correlationId]=s,yield s.promise.finally((()=>{delete this.pendingPromisesForResponse[t.correlationId]}))})),this.setConnectedToRemote=t=>{this.connectedToRemote=t,this.options.onConnectionStatusChange&&this.options.onConnectionStatusChange(t)},Ii("new WebSocketTransport()"),this.host=t.host,this.connect()}}ki.DEFAULT_TIMEOUT_MS=1e4;const Ei=t=>{const e=t.split("::");return{procedure:e[1],scope:e[0]||"global",version:e[2]||"1"}};class zi{constructor(){this.events={},this.publish=(t,i)=>e(this,void 0,void 0,(function*(){const e=this.events[t];e&&e.forEach((function(t){t.call(t,i)}))})),this.subscribe=(t,e)=>{this.events[t]||(this.events[t]=[]),this.events[t].push(e)},this.unsubscribe=(t,e)=>{if(!this.events[t])return;let i=this.events[t].indexOf(e);this.events[t].splice(i)}}}const xi={HTTP_HOST_OR_TRANSPORT_REQUIRED:"http host or tansport is required",INTERCEPTOR_MUSTBE_FUNC:"interceptors must be a function"};class Ri{constructor(t){var s,n,r,o,c,h;if(this.options=t,this.webSocketConnectionChangeListeners=[],this.vent=new zi,this.onWebSocketConnectionStatusChange=t=>{this.options.onWebSocketConnectionStatusChange&&this.options.onWebSocketConnectionStatusChange(t),this.webSocketConnectionChangeListeners.forEach((e=>e(t)))},this.call=(t,s)=>e(this,void 0,void 0,(function*(){if(!t)throw new Error('RPCClient.call(request) requires a "request" param');let e;e="string"==typeof t?Ei(t):t,s&&(e.args=s);const n=new i(e);if(!n.procedure&&!n.identity)throw new TypeError('RPCClient#call requires a "identity" or "procedure" prop and received neither');n.identity||(n.identity={}),n.identity=ei(Object.assign({},this.identity),n.identity);const r=yield this.callManager.manageClientRequest(n);if(!r.success)throw r;const o=a(e);return this.vent.publish(o,null==r?void 0:r.data),r})),this.clearCache=t=>{this.callManager.clearCache(t)},this.getCallCache=(t,e)=>{let i;i="string"==typeof t?Ei(t):t,e&&(i.args=e);const s=this.callManager.getCachedResponse(i);if(s)return s},this.getIdentity=()=>this.identity?Je(this.identity):this.identity,this.getInFlightCallCount=()=>this.callManager.getInFlightCallCount(),this.getWebSocketConnected=()=>{var t;return!!(null===(t=null==this?void 0:this.webSocketTransport)||void 0===t?void 0:t.isConnected())},this.makeProcedure=t=>{const e=this;let i;return i="string"==typeof t?Ei(t):t,function(t){return e.call(Object.assign(Object.assign({},i),{args:t}))}},this.registerResponseInterceptor=t=>{this.callManager.addResponseInterceptor(t)},this.registerRequestInterceptor=t=>{this.callManager.addRequestInterceptor(t)},this.registerWebSocketConnectionStatusChangeListener=t=>{this.webSocketConnectionChangeListeners.push(t)},this.setIdentity=t=>{this.identity=t,this.callManager.setIdentity(t)},!(null===(s=null==t?void 0:t.hosts)||void 0===s?void 0:s.http)&&!(null===(n=null==t?void 0:t.transports)||void 0===n?void 0:n.http))throw new Error(xi.HTTP_HOST_OR_TRANSPORT_REQUIRED);if(t.requestInterceptor&&"function"!=typeof t.requestInterceptor)throw new Error(xi.INTERCEPTOR_MUSTBE_FUNC);if(t.responseInterceptor&&"function"!=typeof t.responseInterceptor)throw new Error(xi.INTERCEPTOR_MUSTBE_FUNC);let l;const u={cacheMaxAgeMs:null==t?void 0:t.cacheMaxAgeMs};l="browser"==t.cacheType?new oi(u):new ji(u);const d=[];(null===(r=t.transports)||void 0===r?void 0:r.websocket)?d.push(t.transports.websocket):(null===(o=null==t?void 0:t.hosts)||void 0===o?void 0:o.websocket)&&(this.webSocketTransport=new ki({host:t.hosts.websocket,onConnectionStatusChange:this.onWebSocketConnectionStatusChange}),d.push(this.webSocketTransport)),(null===(c=t.transports)||void 0===c?void 0:c.http)?d.push(t.transports.http):(null===(h=null==t?void 0:t.hosts)||void 0===h?void 0:h.http)&&(this.httpTransport=new Ti({host:t.hosts.http}),d.push(this.httpTransport)),this.callManager=new ri({cache:l,deadlineMs:t.deadlineMs||Ri.DEFAULT_DEADLINE_MS,requestInterceptor:t.requestInterceptor,responseInterceptor:t.responseInterceptor,transports:d})}subscribe(t,e){const i="string"==typeof t.request?Ei(t.request):t.request,s=a(Object.assign(Object.assign({},i),{args:t.args}));this.vent.subscribe(s,e)}unsubscribe(t,e){const i="string"==typeof t.request?Ei(t.request):t.request,s=a(Object.assign(Object.assign({},i),{args:t.args}));this.vent.unsubscribe(s,e)}}Ri.DEFAULT_DEADLINE_MS=1e4,t.RPCClient=Ri,t.RPCResponse=Si,Object.defineProperty(t,"__esModule",{value:!0})}));
!function(t,e){"object"==typeof exports&&"undefined"!=typeof module?e(exports):"function"==typeof define&&define.amd?define(["exports"],e):e((t="undefined"!=typeof globalThis?globalThis:t||self).RPCClient={})}(this,(function(t){"use strict";function e(t,e,i,n){return new(i||(i=Promise))((function(s,r){function o(t){try{c(n.next(t))}catch(t){r(t)}}function a(t){try{c(n.throw(t))}catch(t){r(t)}}function c(t){var e;t.done?s(t.value):(e=t.value,e instanceof i?e:new i((function(t){t(e)}))).then(o,a)}c((n=n.apply(t,e||[])).next())}))}class i{constructor(t){const{args:e,correlationId:i,identity:n,procedure:s,scope:r,version:o}=t;if(this.args=e,i&&"string"!=typeof i)throw new Error("correlationId must be a string");if(this.correlationId=i||Math.random().toString(),n){if("object"!=typeof n)throw new Error("identity must be an object");if(n.authorization&&"string"!=typeof n.authorization)throw new Error("identity.authorization must be a string");if(n.deviceName&&"string"!=typeof n.deviceName)throw new Error("identity.deviceName must be a string");if(n.metadata&&"object"!=typeof n.metadata)throw new Error("identity.metadata must be a object");this.identity=n}if(s&&"string"!=typeof s)throw new Error("procedure must be string");if(this.procedure=s,r&&"string"!=typeof r)throw new Error("scope must be string");if(this.scope=r,o&&"string"!=typeof o)throw new Error("version must be string");this.version=o}}class n extends Error{}class s extends Error{}class r extends Error{}function o(t){if("[object Object]"!==Object.prototype.toString.call(t))return!1;const e=Object.getPrototypeOf(t);return null===e||e===Object.prototype}const a=t=>t.args?`${t.scope}${t.procedure}${t.version}${function(t,e){e||(e={}),"function"==typeof e&&(e={cmp:e});var i,n="boolean"==typeof e.cycles&&e.cycles,s=e.cmp&&(i=e.cmp,function(t){return function(e,n){var s={key:e,value:t[e]},r={key:n,value:t[n]};return i(s,r)}}),r=[];return function t(e){if(e&&e.toJSON&&"function"==typeof e.toJSON&&(e=e.toJSON()),void 0!==e){if("number"==typeof e)return isFinite(e)?""+e:"null";if("object"!=typeof e)return JSON.stringify(e);var i,o;if(Array.isArray(e)){for(o="[",i=0;i<e.length;i++)i&&(o+=","),o+=t(e[i])||"null";return o+"]"}if(null===e)return"null";if(-1!==r.indexOf(e)){if(n)return JSON.stringify("__cycle__");throw new TypeError("Converting circular structure to JSON")}var a=r.push(e)-1,c=Object.keys(e).sort(s&&s(e));for(o="",i=0;i<c.length;i++){var h=c[i],l=t(e[h]);l&&(o&&(o+=","),o+=JSON.stringify(h)+":"+l)}return r.splice(a,1),"{"+o+"}"}}(t)}(function(t,e={}){if(!o(t)&&!Array.isArray(t))throw new TypeError("Expected a plain object or array");const{deep:i,compare:n}=e,s=[],r=[],a=t=>{const e=s.indexOf(t);if(-1!==e)return r[e];const i=[];return s.push(t),r.push(i),i.push(...t.map((t=>Array.isArray(t)?a(t):o(t)?c(t):t))),i},c=t=>{const e=s.indexOf(t);if(-1!==e)return r[e];const h={},l=Object.keys(t).sort(n);s.push(t),r.push(h);for(const e of l){const n=t[e];let s;s=i&&Array.isArray(n)?a(n):i&&o(n)?c(n):n,Object.defineProperty(h,e,Object.assign(Object.assign({},Object.getOwnPropertyDescriptor(t,e)),{value:s}))}return h};return Array.isArray(t)?i?a(t):t.slice():c(t)}(t.args||{},{deep:!0}))}`:`${t.scope}${t.procedure}${t.version}`;var c="object"==typeof global&&global&&global.Object===Object&&global,h="object"==typeof self&&self&&self.Object===Object&&self,l=c||h||Function("return this")(),u=l.Symbol,d=Object.prototype,p=d.hasOwnProperty,f=d.toString,y=u?u.toStringTag:void 0;var v=Object.prototype.toString;var g=u?u.toStringTag:void 0;function b(t){return null==t?void 0===t?"[object Undefined]":"[object Null]":g&&g in Object(t)?function(t){var e=p.call(t,y),i=t[y];try{t[y]=void 0;var n=!0}catch(t){}var s=f.call(t);return n&&(e?t[y]=i:delete t[y]),s}(t):function(t){return v.call(t)}(t)}function w(t){return null!=t&&"object"==typeof t}var m=Array.isArray;function _(t){var e=typeof t;return null!=t&&("object"==e||"function"==e)}function j(t){return t}function S(t){if(!_(t))return!1;var e=b(t);return"[object Function]"==e||"[object GeneratorFunction]"==e||"[object AsyncFunction]"==e||"[object Proxy]"==e}var C,O=l["__core-js_shared__"],T=(C=/[^.]+$/.exec(O&&O.keys&&O.keys.IE_PROTO||""))?"Symbol(src)_1."+C:"";var A=Function.prototype.toString;function I(t){if(null!=t){try{return A.call(t)}catch(t){}try{return t+""}catch(t){}}return""}var k=/^\[object .+?Constructor\]$/,E=Function.prototype,R=Object.prototype,z=E.toString,x=R.hasOwnProperty,M=RegExp("^"+z.call(x).replace(/[\\^$.*+?()[\]{}|]/g,"\\$&").replace(/hasOwnProperty|(function).*?(?=\\\()| for .+?(?=\\\])/g,"$1.*?")+"$");function L(t){return!(!_(t)||(e=t,T&&T in e))&&(S(t)?M:k).test(I(t));var e}function F(t,e){var i=function(t,e){return null==t?void 0:t[e]}(t,e);return L(i)?i:void 0}var P=F(l,"WeakMap"),W=Object.create,U=function(){function t(){}return function(e){if(!_(e))return{};if(W)return W(e);t.prototype=e;var i=new t;return t.prototype=void 0,i}}();function q(t,e,i){switch(i.length){case 0:return t.call(e);case 1:return t.call(e,i[0]);case 2:return t.call(e,i[0],i[1]);case 3:return t.call(e,i[0],i[1],i[2])}return t.apply(e,i)}function D(t,e){var i=-1,n=t.length;for(e||(e=Array(n));++i<n;)e[i]=t[i];return e}var N=Date.now;var B,$,H,G=function(){try{var t=F(Object,"defineProperty");return t({},"",{}),t}catch(t){}}(),J=G,V=J?function(t,e){return J(t,"toString",{configurable:!0,enumerable:!1,value:(i=e,function(){return i}),writable:!0});var i}:j,K=(B=V,$=0,H=0,function(){var t=N(),e=16-(t-H);if(H=t,e>0){if(++$>=800)return arguments[0]}else $=0;return B.apply(void 0,arguments)}),X=K;var Z=/^(?:0|[1-9]\d*)$/;function Q(t,e){var i=typeof t;return!!(e=null==e?9007199254740991:e)&&("number"==i||"symbol"!=i&&Z.test(t))&&t>-1&&t%1==0&&t<e}function Y(t,e,i){"__proto__"==e&&J?J(t,e,{configurable:!0,enumerable:!0,value:i,writable:!0}):t[e]=i}function tt(t,e){return t===e||t!=t&&e!=e}var et=Object.prototype.hasOwnProperty;function it(t,e,i){var n=t[e];et.call(t,e)&&tt(n,i)&&(void 0!==i||e in t)||Y(t,e,i)}function nt(t,e,i,n){var s=!i;i||(i={});for(var r=-1,o=e.length;++r<o;){var a=e[r],c=n?n(i[a],t[a],a,i,t):void 0;void 0===c&&(c=t[a]),s?Y(i,a,c):it(i,a,c)}return i}var st=Math.max;function rt(t,e){return X(function(t,e,i){return e=st(void 0===e?t.length-1:e,0),function(){for(var n=arguments,s=-1,r=st(n.length-e,0),o=Array(r);++s<r;)o[s]=n[e+s];s=-1;for(var a=Array(e+1);++s<e;)a[s]=n[s];return a[e]=i(o),q(t,this,a)}}(t,e,j),t+"")}function ot(t){return"number"==typeof t&&t>-1&&t%1==0&&t<=9007199254740991}function at(t){return null!=t&&ot(t.length)&&!S(t)}var ct=Object.prototype;function ht(t){var e=t&&t.constructor;return t===("function"==typeof e&&e.prototype||ct)}function lt(t){return w(t)&&"[object Arguments]"==b(t)}var ut=Object.prototype,dt=ut.hasOwnProperty,pt=ut.propertyIsEnumerable,ft=lt(function(){return arguments}())?lt:function(t){return w(t)&&dt.call(t,"callee")&&!pt.call(t,"callee")},yt=ft;var vt="object"==typeof t&&t&&!t.nodeType&&t,gt=vt&&"object"==typeof module&&module&&!module.nodeType&&module,bt=gt&&gt.exports===vt?l.Buffer:void 0,wt=(bt?bt.isBuffer:void 0)||function(){return!1},mt={};function _t(t){return function(e){return t(e)}}mt["[object Float32Array]"]=mt["[object Float64Array]"]=mt["[object Int8Array]"]=mt["[object Int16Array]"]=mt["[object Int32Array]"]=mt["[object Uint8Array]"]=mt["[object Uint8ClampedArray]"]=mt["[object Uint16Array]"]=mt["[object Uint32Array]"]=!0,mt["[object Arguments]"]=mt["[object Array]"]=mt["[object ArrayBuffer]"]=mt["[object Boolean]"]=mt["[object DataView]"]=mt["[object Date]"]=mt["[object Error]"]=mt["[object Function]"]=mt["[object Map]"]=mt["[object Number]"]=mt["[object Object]"]=mt["[object RegExp]"]=mt["[object Set]"]=mt["[object String]"]=mt["[object WeakMap]"]=!1;var jt="object"==typeof t&&t&&!t.nodeType&&t,St=jt&&"object"==typeof module&&module&&!module.nodeType&&module,Ct=St&&St.exports===jt&&c.process,Ot=function(){try{var t=St&&St.require&&St.require("util").types;return t||Ct&&Ct.binding&&Ct.binding("util")}catch(t){}}(),Tt=Ot&&Ot.isTypedArray,At=Tt?_t(Tt):function(t){return w(t)&&ot(t.length)&&!!mt[b(t)]},It=Object.prototype.hasOwnProperty;function kt(t,e){var i=m(t),n=!i&&yt(t),s=!i&&!n&&wt(t),r=!i&&!n&&!s&&At(t),o=i||n||s||r,a=o?function(t,e){for(var i=-1,n=Array(t);++i<t;)n[i]=e(i);return n}(t.length,String):[],c=a.length;for(var h in t)!e&&!It.call(t,h)||o&&("length"==h||s&&("offset"==h||"parent"==h)||r&&("buffer"==h||"byteLength"==h||"byteOffset"==h)||Q(h,c))||a.push(h);return a}function Et(t,e){return function(i){return t(e(i))}}var Rt=Et(Object.keys,Object),zt=Object.prototype.hasOwnProperty;function xt(t){return at(t)?kt(t):function(t){if(!ht(t))return Rt(t);var e=[];for(var i in Object(t))zt.call(t,i)&&"constructor"!=i&&e.push(i);return e}(t)}var Mt=Object.prototype.hasOwnProperty;function Lt(t){if(!_(t))return function(t){var e=[];if(null!=t)for(var i in Object(t))e.push(i);return e}(t);var e=ht(t),i=[];for(var n in t)("constructor"!=n||!e&&Mt.call(t,n))&&i.push(n);return i}function Ft(t){return at(t)?kt(t,!0):Lt(t)}var Pt=F(Object,"create");var Wt=Object.prototype.hasOwnProperty;var Ut=Object.prototype.hasOwnProperty;function qt(t){var e=-1,i=null==t?0:t.length;for(this.clear();++e<i;){var n=t[e];this.set(n[0],n[1])}}function Dt(t,e){for(var i=t.length;i--;)if(tt(t[i][0],e))return i;return-1}qt.prototype.clear=function(){this.__data__=Pt?Pt(null):{},this.size=0},qt.prototype.delete=function(t){var e=this.has(t)&&delete this.__data__[t];return this.size-=e?1:0,e},qt.prototype.get=function(t){var e=this.__data__;if(Pt){var i=e[t];return"__lodash_hash_undefined__"===i?void 0:i}return Wt.call(e,t)?e[t]:void 0},qt.prototype.has=function(t){var e=this.__data__;return Pt?void 0!==e[t]:Ut.call(e,t)},qt.prototype.set=function(t,e){var i=this.__data__;return this.size+=this.has(t)?0:1,i[t]=Pt&&void 0===e?"__lodash_hash_undefined__":e,this};var Nt=Array.prototype.splice;function Bt(t){var e=-1,i=null==t?0:t.length;for(this.clear();++e<i;){var n=t[e];this.set(n[0],n[1])}}Bt.prototype.clear=function(){this.__data__=[],this.size=0},Bt.prototype.delete=function(t){var e=this.__data__,i=Dt(e,t);return!(i<0)&&(i==e.length-1?e.pop():Nt.call(e,i,1),--this.size,!0)},Bt.prototype.get=function(t){var e=this.__data__,i=Dt(e,t);return i<0?void 0:e[i][1]},Bt.prototype.has=function(t){return Dt(this.__data__,t)>-1},Bt.prototype.set=function(t,e){var i=this.__data__,n=Dt(i,t);return n<0?(++this.size,i.push([t,e])):i[n][1]=e,this};var $t=F(l,"Map");function Ht(t,e){var i,n,s=t.__data__;return("string"==(n=typeof(i=e))||"number"==n||"symbol"==n||"boolean"==n?"__proto__"!==i:null===i)?s["string"==typeof e?"string":"hash"]:s.map}function Gt(t){var e=-1,i=null==t?0:t.length;for(this.clear();++e<i;){var n=t[e];this.set(n[0],n[1])}}function Jt(t,e){for(var i=-1,n=e.length,s=t.length;++i<n;)t[s+i]=e[i];return t}Gt.prototype.clear=function(){this.size=0,this.__data__={hash:new qt,map:new($t||Bt),string:new qt}},Gt.prototype.delete=function(t){var e=Ht(this,t).delete(t);return this.size-=e?1:0,e},Gt.prototype.get=function(t){return Ht(this,t).get(t)},Gt.prototype.has=function(t){return Ht(this,t).has(t)},Gt.prototype.set=function(t,e){var i=Ht(this,t),n=i.size;return i.set(t,e),this.size+=i.size==n?0:1,this};var Vt=Et(Object.getPrototypeOf,Object),Kt=Function.prototype,Xt=Object.prototype,Zt=Kt.toString,Qt=Xt.hasOwnProperty,Yt=Zt.call(Object);function te(t){var e=this.__data__=new Bt(t);this.size=e.size}te.prototype.clear=function(){this.__data__=new Bt,this.size=0},te.prototype.delete=function(t){var e=this.__data__,i=e.delete(t);return this.size=e.size,i},te.prototype.get=function(t){return this.__data__.get(t)},te.prototype.has=function(t){return this.__data__.has(t)},te.prototype.set=function(t,e){var i=this.__data__;if(i instanceof Bt){var n=i.__data__;if(!$t||n.length<199)return n.push([t,e]),this.size=++i.size,this;i=this.__data__=new Gt(n)}return i.set(t,e),this.size=i.size,this};var ee="object"==typeof t&&t&&!t.nodeType&&t,ie=ee&&"object"==typeof module&&module&&!module.nodeType&&module,ne=ie&&ie.exports===ee?l.Buffer:void 0,se=ne?ne.allocUnsafe:void 0;function re(t,e){if(e)return t.slice();var i=t.length,n=se?se(i):new t.constructor(i);return t.copy(n),n}function oe(){return[]}var ae=Object.prototype.propertyIsEnumerable,ce=Object.getOwnPropertySymbols,he=ce?function(t){return null==t?[]:(t=Object(t),function(t,e){for(var i=-1,n=null==t?0:t.length,s=0,r=[];++i<n;){var o=t[i];e(o,i,t)&&(r[s++]=o)}return r}(ce(t),(function(e){return ae.call(t,e)})))}:oe;var le=Object.getOwnPropertySymbols?function(t){for(var e=[];t;)Jt(e,he(t)),t=Vt(t);return e}:oe;function ue(t,e,i){var n=e(t);return m(t)?n:Jt(n,i(t))}function de(t){return ue(t,xt,he)}function pe(t){return ue(t,Ft,le)}var fe=F(l,"DataView"),ye=F(l,"Promise"),ve=F(l,"Set"),ge="[object Map]",be="[object Promise]",we="[object Set]",me="[object WeakMap]",_e="[object DataView]",je=I(fe),Se=I($t),Ce=I(ye),Oe=I(ve),Te=I(P),Ae=b;(fe&&Ae(new fe(new ArrayBuffer(1)))!=_e||$t&&Ae(new $t)!=ge||ye&&Ae(ye.resolve())!=be||ve&&Ae(new ve)!=we||P&&Ae(new P)!=me)&&(Ae=function(t){var e=b(t),i="[object Object]"==e?t.constructor:void 0,n=i?I(i):"";if(n)switch(n){case je:return _e;case Se:return ge;case Ce:return be;case Oe:return we;case Te:return me}return e});var Ie=Ae,ke=Object.prototype.hasOwnProperty;var Ee=l.Uint8Array;function Re(t){var e=new t.constructor(t.byteLength);return new Ee(e).set(new Ee(t)),e}var ze=/\w*$/;var xe=u?u.prototype:void 0,Me=xe?xe.valueOf:void 0;function Le(t,e){var i=e?Re(t.buffer):t.buffer;return new t.constructor(i,t.byteOffset,t.length)}function Fe(t,e,i){var n,s,r,o=t.constructor;switch(e){case"[object ArrayBuffer]":return Re(t);case"[object Boolean]":case"[object Date]":return new o(+t);case"[object DataView]":return function(t,e){var i=e?Re(t.buffer):t.buffer;return new t.constructor(i,t.byteOffset,t.byteLength)}(t,i);case"[object Float32Array]":case"[object Float64Array]":case"[object Int8Array]":case"[object Int16Array]":case"[object Int32Array]":case"[object Uint8Array]":case"[object Uint8ClampedArray]":case"[object Uint16Array]":case"[object Uint32Array]":return Le(t,i);case"[object Map]":case"[object Set]":return new o;case"[object Number]":case"[object String]":return new o(t);case"[object RegExp]":return(r=new(s=t).constructor(s.source,ze.exec(s))).lastIndex=s.lastIndex,r;case"[object Symbol]":return n=t,Me?Object(Me.call(n)):{}}}function Pe(t){return"function"!=typeof t.constructor||ht(t)?{}:U(Vt(t))}var We=Ot&&Ot.isMap,Ue=We?_t(We):function(t){return w(t)&&"[object Map]"==Ie(t)};var qe=Ot&&Ot.isSet,De=qe?_t(qe):function(t){return w(t)&&"[object Set]"==Ie(t)},Ne="[object Arguments]",Be="[object Function]",$e="[object Object]",He={};function Ge(t,e,i,n,s,r){var o,a=1&e,c=2&e,h=4&e;if(i&&(o=s?i(t,n,s,r):i(t)),void 0!==o)return o;if(!_(t))return t;var l=m(t);if(l){if(o=function(t){var e=t.length,i=new t.constructor(e);return e&&"string"==typeof t[0]&&ke.call(t,"index")&&(i.index=t.index,i.input=t.input),i}(t),!a)return D(t,o)}else{var u=Ie(t),d=u==Be||"[object GeneratorFunction]"==u;if(wt(t))return re(t,a);if(u==$e||u==Ne||d&&!s){if(o=c||d?{}:Pe(t),!a)return c?function(t,e){return nt(t,le(t),e)}(t,function(t,e){return t&&nt(e,Ft(e),t)}(o,t)):function(t,e){return nt(t,he(t),e)}(t,function(t,e){return t&&nt(e,xt(e),t)}(o,t))}else{if(!He[u])return s?t:{};o=Fe(t,u,a)}}r||(r=new te);var p=r.get(t);if(p)return p;r.set(t,o),De(t)?t.forEach((function(n){o.add(Ge(n,e,i,n,t,r))})):Ue(t)&&t.forEach((function(n,s){o.set(s,Ge(n,e,i,s,t,r))}));var f=l?void 0:(h?c?pe:de:c?Ft:xt)(t);return function(t,e){for(var i=-1,n=null==t?0:t.length;++i<n&&!1!==e(t[i],i,t););}(f||t,(function(n,s){f&&(n=t[s=n]),it(o,s,Ge(n,e,i,s,t,r))})),o}He[Ne]=He["[object Array]"]=He["[object ArrayBuffer]"]=He["[object DataView]"]=He["[object Boolean]"]=He["[object Date]"]=He["[object Float32Array]"]=He["[object Float64Array]"]=He["[object Int8Array]"]=He["[object Int16Array]"]=He["[object Int32Array]"]=He["[object Map]"]=He["[object Number]"]=He[$e]=He["[object RegExp]"]=He["[object Set]"]=He["[object String]"]=He["[object Symbol]"]=He["[object Uint8Array]"]=He["[object Uint8ClampedArray]"]=He["[object Uint16Array]"]=He["[object Uint32Array]"]=!0,He["[object Error]"]=He[Be]=He["[object WeakMap]"]=!1;function Je(t){return Ge(t,5)}var Ve,Ke=function(t,e,i){for(var n=-1,s=Object(t),r=i(t),o=r.length;o--;){var a=r[Ve?o:++n];if(!1===e(s[a],a,s))break}return t};function Xe(t,e,i){(void 0!==i&&!tt(t[e],i)||void 0===i&&!(e in t))&&Y(t,e,i)}function Ze(t,e){if(("constructor"!==e||"function"!=typeof t[e])&&"__proto__"!=e)return t[e]}function Qe(t,e,i,n,s,r,o){var a=Ze(t,i),c=Ze(e,i),h=o.get(c);if(h)Xe(t,i,h);else{var l,u=r?r(a,c,i+"",t,e,o):void 0,d=void 0===u;if(d){var p=m(c),f=!p&&wt(c),y=!p&&!f&&At(c);u=c,p||f||y?m(a)?u=a:w(l=a)&&at(l)?u=D(a):f?(d=!1,u=re(c,!0)):y?(d=!1,u=Le(c,!0)):u=[]:function(t){if(!w(t)||"[object Object]"!=b(t))return!1;var e=Vt(t);if(null===e)return!0;var i=Qt.call(e,"constructor")&&e.constructor;return"function"==typeof i&&i instanceof i&&Zt.call(i)==Yt}(c)||yt(c)?(u=a,yt(a)?u=function(t){return nt(t,Ft(t))}(a):_(a)&&!S(a)||(u=Pe(c))):d=!1}d&&(o.set(c,u),s(u,c,n,r,o),o.delete(c)),Xe(t,i,u)}}function Ye(t,e,i,n,s){t!==e&&Ke(e,(function(r,o){if(s||(s=new te),_(r))Qe(t,e,o,i,Ye,n,s);else{var a=n?n(Ze(t,o),r,o+"",t,e,s):void 0;void 0===a&&(a=r),Xe(t,o,a)}}),Ft)}var ti,ei=(ti=function(t,e,i){Ye(t,e,i)},rt((function(t,e){var i=-1,n=e.length,s=n>1?e[n-1]:void 0,r=n>2?e[2]:void 0;for(s=ti.length>3&&"function"==typeof s?(n--,s):void 0,r&&function(t,e,i){if(!_(i))return!1;var n=typeof e;return!!("number"==n?at(i)&&Q(e,i.length):"string"==n&&e in i)&&tt(i[e],t)}(e[0],e[1],r)&&(s=n<3?void 0:s,n=1),t=Object(t);++i<n;){var o=e[i];o&&ti(t,o,i,s)}return t})));let ii=null;try{ii=localStorage.getItem("debug")||""}catch(t){"undefined"!=typeof window&&"undefined"!=typeof localStorage&&console.warn("Error checking window.debug")}const ni=t=>ii&&new RegExp(ii).test(t)?(...e)=>console.log(t,...e):()=>{},si=ni("rpc:ClientManager");class ri{constructor(t){this.options=t,this.inflightCallsByKey={},this.interceptors={request:[],response:[]},this.addResponseInterceptor=t=>{if("function"!=typeof t)throw new Error("cannot add interceptor that is not a function");this.interceptors.response.push(t)},this.addRequestInterceptor=t=>{if("function"!=typeof t)throw new Error("cannot add interceptor that is not a function");this.interceptors.request.push(t)},this.clearCache=t=>{si("clearCache"),this.cache&&(t?this.cache.setCachedResponse(t,void 0):this.cache.clearCache())},this.getCachedResponse=t=>{var e;return si("getCachedResponse",t),null===(e=null==this?void 0:this.cache)||void 0===e?void 0:e.getCachedResponse(t)},this.getInFlightCallCount=()=>(si("getInFlightCallCount"),Object.keys(this.inflightCallsByKey).length),this.manageClientRequest=t=>e(this,void 0,void 0,(function*(){si("manageClientRequest",t);const i=yield this.interceptRequestMutator(t),n=a(i);if(this.inflightCallsByKey.hasOwnProperty(n))return si("manageClientRequest using an existing in-flight call",n),this.inflightCallsByKey[n].then((e=>{const i=Je(e);return t.correlationId&&(i.correlationId=t.correlationId),i}));const s=(()=>e(this,void 0,void 0,(function*(){const t=yield this.sendRequestWithTransport(i),e=yield this.interceptResponseMutator(t,i);return this.cache&&e&&this.cache.setCachedResponse(i,e),e})))().then((t=>(delete this.inflightCallsByKey[n],t))).catch((t=>{throw delete this.inflightCallsByKey[n],t}));return this.inflightCallsByKey[n]=s,yield s})),this.setIdentity=t=>{si("setIdentity",t),this.transports.forEach((e=>e.setIdentity(t)))},this.interceptRequestMutator=t=>e(this,void 0,void 0,(function*(){let e=t;if(this.interceptors.request.length){si("interceptRequestMutator(), original request:",t);for(const t of this.interceptors.request)e=yield t(e)}return e})),this.interceptResponseMutator=(t,i)=>e(this,void 0,void 0,(function*(){let e=t;if(this.interceptors.response.length){si("interceptResponseMutator",i,t);for(const n of this.interceptors.response)try{e=yield n(e,i)}catch(n){throw si("caught response interceptor, request:",i,"original response:",t,"mutated response:",e),n}}return e})),this.sendRequestWithTransport=t=>e(this,void 0,void 0,(function*(){let e;si("sendRequestWithTransport",t);let i=0;for(;!e&&this.transports[i];){const n=this.transports[i];if(n.isConnected()){si(`sendRequestWithTransport trying ${this.transports[i].name}`,t);try{let i;const s=new Promise(((e,n)=>{i=setTimeout((()=>{n(new r(`Procedure ${t.procedure}`))}),this.options.deadlineMs)}));e=yield Promise.race([s,n.sendRequest(t)]).then((t=>(clearTimeout(i),t)))}catch(t){if(!(t instanceof r||t instanceof s))throw t;si(`sending request with ${this.transports[i].name} failed, trying next transport`),i++}}else i++}if(!e&&!this.transports[i])throw new n(`Procedure ${t.procedure} did not get a response from any transports`);if(!e)throw new n(`Procedure ${t.procedure} did not get a response from the remote`);return e})),this.cache=t.cache,t.requestInterceptor&&this.interceptors.request.push(t.requestInterceptor),t.responseInterceptor&&this.interceptors.response.push(t.responseInterceptor),this.transports=t.transports}}class oi{constructor(t){this.cacheOptions=t}clearCache(){}getCachedResponse(t){}setCachedResponse(t,e){}}oi.DEFAULT_CACHE_MAX_AGE_MS=3e5,oi.DEFAULT_CACHE_MAX_SIZE=100;const ai="object"==typeof performance&&performance&&"function"==typeof performance.now?performance:Date,ci="function"==typeof AbortController,hi=ci?AbortController:class{constructor(){this.signal=new li}abort(){this.signal.dispatchEvent("abort")}},li=ci?AbortSignal:class{constructor(){this.aborted=!1,this._listeners=[]}dispatchEvent(t){if("abort"===t){this.aborted=!0;const e={type:t,target:this};this.onabort(e),this._listeners.forEach((t=>t(e)),this)}}onabort(){}addEventListener(t,e){"abort"===t&&this._listeners.push(e)}removeEventListener(t,e){"abort"===t&&(this._listeners=this._listeners.filter((t=>t!==e)))}},ui=new Set,di=(t,e)=>{const i=`LRU_CACHE_OPTION_${t}`;yi(i)&&vi(i,`${t} option`,`options.${e}`,_i)},pi=(t,e)=>{const i=`LRU_CACHE_METHOD_${t}`;if(yi(i)){const{prototype:n}=_i,{get:s}=Object.getOwnPropertyDescriptor(n,t);vi(i,`${t} method`,`cache.${e}()`,s)}},fi=(...t)=>{"object"==typeof process&&process&&"function"==typeof process.emitWarning?process.emitWarning(...t):console.error(...t)},yi=t=>!ui.has(t),vi=(t,e,i,n)=>{ui.add(t);fi(`The ${e} is deprecated. Please use ${i} instead.`,"DeprecationWarning",t,n)},gi=t=>t&&t===Math.floor(t)&&t>0&&isFinite(t),bi=t=>gi(t)?t<=Math.pow(2,8)?Uint8Array:t<=Math.pow(2,16)?Uint16Array:t<=Math.pow(2,32)?Uint32Array:t<=Number.MAX_SAFE_INTEGER?wi:null:null;class wi extends Array{constructor(t){super(t),this.fill(0)}}class mi{constructor(t){if(0===t)return[];const e=bi(t);this.heap=new e(t),this.length=0}push(t){this.heap[this.length++]=t}pop(){return this.heap[--this.length]}}class _i{constructor(t={}){const{max:e=0,ttl:i,ttlResolution:n=1,ttlAutopurge:s,updateAgeOnGet:r,updateAgeOnHas:o,allowStale:a,dispose:c,disposeAfter:h,noDisposeOnSet:l,noUpdateTTL:u,maxSize:d=0,sizeCalculation:p,fetchMethod:f,noDeleteOnFetchRejection:y}=t,{length:v,maxAge:g,stale:b}=t instanceof _i?{}:t;if(0!==e&&!gi(e))throw new TypeError("max option must be a nonnegative integer");const w=e?bi(e):Array;if(!w)throw new Error("invalid max value: "+e);if(this.max=e,this.maxSize=d,this.sizeCalculation=p||v,this.sizeCalculation){if(!this.maxSize)throw new TypeError("cannot set sizeCalculation without setting maxSize");if("function"!=typeof this.sizeCalculation)throw new TypeError("sizeCalculation set to non-function")}if(this.fetchMethod=f||null,this.fetchMethod&&"function"!=typeof this.fetchMethod)throw new TypeError("fetchMethod must be a function if specified");if(this.keyMap=new Map,this.keyList=new Array(e).fill(null),this.valList=new Array(e).fill(null),this.next=new w(e),this.prev=new w(e),this.head=0,this.tail=0,this.free=new mi(e),this.initialFill=1,this.size=0,"function"==typeof c&&(this.dispose=c),"function"==typeof h?(this.disposeAfter=h,this.disposed=[]):(this.disposeAfter=null,this.disposed=null),this.noDisposeOnSet=!!l,this.noUpdateTTL=!!u,this.noDeleteOnFetchRejection=!!y,0!==this.maxSize){if(!gi(this.maxSize))throw new TypeError("maxSize must be a positive integer if specified");this.initializeSizeTracking()}if(this.allowStale=!!a||!!b,this.updateAgeOnGet=!!r,this.updateAgeOnHas=!!o,this.ttlResolution=gi(n)||0===n?n:1,this.ttlAutopurge=!!s,this.ttl=i||g||0,this.ttl){if(!gi(this.ttl))throw new TypeError("ttl must be a positive integer if specified");this.initializeTTLTracking()}if(0===this.max&&0===this.ttl&&0===this.maxSize)throw new TypeError("At least one of max, maxSize, or ttl is required");if(!this.ttlAutopurge&&!this.max&&!this.maxSize){const t="LRU_CACHE_UNBOUNDED";if(yi(t)){ui.add(t);fi("TTL caching without ttlAutopurge, max, or maxSize can result in unbounded memory consumption.","UnboundedCacheWarning",t,_i)}}b&&di("stale","allowStale"),g&&di("maxAge","ttl"),v&&di("length","sizeCalculation")}getRemainingTTL(t){return this.has(t,{updateAgeOnHas:!1})?1/0:0}initializeTTLTracking(){this.ttls=new wi(this.max),this.starts=new wi(this.max),this.setItemTTL=(t,e)=>{if(this.starts[t]=0!==e?ai.now():0,this.ttls[t]=e,0!==e&&this.ttlAutopurge){const i=setTimeout((()=>{this.isStale(t)&&this.delete(this.keyList[t])}),e+1);i.unref&&i.unref()}},this.updateItemAge=t=>{this.starts[t]=0!==this.ttls[t]?ai.now():0};let t=0;const e=()=>{const e=ai.now();if(this.ttlResolution>0){t=e;const i=setTimeout((()=>t=0),this.ttlResolution);i.unref&&i.unref()}return e};this.getRemainingTTL=i=>{const n=this.keyMap.get(i);return void 0===n?0:0===this.ttls[n]||0===this.starts[n]?1/0:this.starts[n]+this.ttls[n]-(t||e())},this.isStale=i=>0!==this.ttls[i]&&0!==this.starts[i]&&(t||e())-this.starts[i]>this.ttls[i]}updateItemAge(t){}setItemTTL(t,e){}isStale(t){return!1}initializeSizeTracking(){this.calculatedSize=0,this.sizes=new wi(this.max),this.removeItemSize=t=>this.calculatedSize-=this.sizes[t],this.requireSize=(t,e,i,n)=>{if(!gi(i)){if(!n)throw new TypeError("invalid size value (must be positive integer)");if("function"!=typeof n)throw new TypeError("sizeCalculation must be a function");if(i=n(e,t),!gi(i))throw new TypeError("sizeCalculation return invalid (expect positive integer)")}return i},this.addItemSize=(t,e,i,n)=>{this.sizes[t]=n;const s=this.maxSize-this.sizes[t];for(;this.calculatedSize>s;)this.evict(!0);this.calculatedSize+=this.sizes[t]}}removeItemSize(t){}addItemSize(t,e,i,n){}requireSize(t,e,i,n){if(i||n)throw new TypeError("cannot set size without setting maxSize on cache")}*indexes({allowStale:t=this.allowStale}={}){if(this.size)for(let e=this.tail;this.isValidIndex(e)&&(!t&&this.isStale(e)||(yield e),e!==this.head);)e=this.prev[e]}*rindexes({allowStale:t=this.allowStale}={}){if(this.size)for(let e=this.head;this.isValidIndex(e)&&(!t&&this.isStale(e)||(yield e),e!==this.tail);)e=this.next[e]}isValidIndex(t){return this.keyMap.get(this.keyList[t])===t}*entries(){for(const t of this.indexes())yield[this.keyList[t],this.valList[t]]}*rentries(){for(const t of this.rindexes())yield[this.keyList[t],this.valList[t]]}*keys(){for(const t of this.indexes())yield this.keyList[t]}*rkeys(){for(const t of this.rindexes())yield this.keyList[t]}*values(){for(const t of this.indexes())yield this.valList[t]}*rvalues(){for(const t of this.rindexes())yield this.valList[t]}[Symbol.iterator](){return this.entries()}find(t,e={}){for(const i of this.indexes())if(t(this.valList[i],this.keyList[i],this))return this.get(this.keyList[i],e)}forEach(t,e=this){for(const i of this.indexes())t.call(e,this.valList[i],this.keyList[i],this)}rforEach(t,e=this){for(const i of this.rindexes())t.call(e,this.valList[i],this.keyList[i],this)}get prune(){return pi("prune","purgeStale"),this.purgeStale}purgeStale(){let t=!1;for(const e of this.rindexes({allowStale:!0}))this.isStale(e)&&(this.delete(this.keyList[e]),t=!0);return t}dump(){const t=[];for(const e of this.indexes()){const i=this.keyList[e],n={value:this.valList[e]};this.ttls&&(n.ttl=this.ttls[e]),this.sizes&&(n.size=this.sizes[e]),t.unshift([i,n])}return t}load(t){this.clear();for(const[e,i]of t)this.set(e,i.value,i)}dispose(t,e,i){}set(t,e,{ttl:i=this.ttl,noDisposeOnSet:n=this.noDisposeOnSet,size:s=0,sizeCalculation:r=this.sizeCalculation,noUpdateTTL:o=this.noUpdateTTL}={}){s=this.requireSize(t,e,s,r);let a=0===this.size?void 0:this.keyMap.get(t);if(void 0===a)a=this.newIndex(),this.keyList[a]=t,this.valList[a]=e,this.keyMap.set(t,a),this.next[this.tail]=a,this.prev[a]=this.tail,this.tail=a,this.size++,this.addItemSize(a,e,t,s),o=!1;else{const i=this.valList[a];e!==i&&(this.isBackgroundFetch(i)?i.__abortController.abort():n||(this.dispose(i,t,"set"),this.disposeAfter&&this.disposed.push([i,t,"set"])),this.removeItemSize(a),this.valList[a]=e,this.addItemSize(a,e,t,s)),this.moveToTail(a)}if(0===i||0!==this.ttl||this.ttls||this.initializeTTLTracking(),o||this.setItemTTL(a,i),this.disposeAfter)for(;this.disposed.length;)this.disposeAfter(...this.disposed.shift());return this}newIndex(){return 0===this.size?this.tail:this.size===this.max&&0!==this.max?this.evict(!1):0!==this.free.length?this.free.pop():this.initialFill++}pop(){if(this.size){const t=this.valList[this.head];return this.evict(!0),t}}evict(t){const e=this.head,i=this.keyList[e],n=this.valList[e];return this.isBackgroundFetch(n)?n.__abortController.abort():(this.dispose(n,i,"evict"),this.disposeAfter&&this.disposed.push([n,i,"evict"])),this.removeItemSize(e),t&&(this.keyList[e]=null,this.valList[e]=null,this.free.push(e)),this.head=this.next[e],this.keyMap.delete(i),this.size--,e}has(t,{updateAgeOnHas:e=this.updateAgeOnHas}={}){const i=this.keyMap.get(t);return void 0!==i&&!this.isStale(i)&&(e&&this.updateItemAge(i),!0)}peek(t,{allowStale:e=this.allowStale}={}){const i=this.keyMap.get(t);if(void 0!==i&&(e||!this.isStale(i)))return this.valList[i]}backgroundFetch(t,e,i){const n=void 0===e?void 0:this.valList[e];if(this.isBackgroundFetch(n))return n;const s=new hi,r={signal:s.signal,options:i},o=new Promise((e=>e(this.fetchMethod(t,n,r)))).then((e=>(s.signal.aborted||this.set(t,e,r.options),e)),(n=>{if(this.valList[e]===o){!i.noDeleteOnFetchRejection||void 0===o.__staleWhileFetching?this.delete(t):this.valList[e]=o.__staleWhileFetching}if(o.__returned===o)throw n}));return o.__abortController=s,o.__staleWhileFetching=n,o.__returned=null,void 0===e?(this.set(t,o,r.options),e=this.keyMap.get(t)):this.valList[e]=o,o}isBackgroundFetch(t){return t&&"object"==typeof t&&"function"==typeof t.then&&Object.prototype.hasOwnProperty.call(t,"__staleWhileFetching")&&Object.prototype.hasOwnProperty.call(t,"__returned")&&(t.__returned===t||null===t.__returned)}async fetch(t,{allowStale:e=this.allowStale,updateAgeOnGet:i=this.updateAgeOnGet,ttl:n=this.ttl,noDisposeOnSet:s=this.noDisposeOnSet,size:r=0,sizeCalculation:o=this.sizeCalculation,noUpdateTTL:a=this.noUpdateTTL,noDeleteOnFetchRejection:c=this.noDeleteOnFetchRejection}={}){if(!this.fetchMethod)return this.get(t,{allowStale:e,updateAgeOnGet:i});const h={allowStale:e,updateAgeOnGet:i,ttl:n,noDisposeOnSet:s,size:r,sizeCalculation:o,noUpdateTTL:a,noDeleteOnFetchRejection:c};let l=this.keyMap.get(t);if(void 0===l){const e=this.backgroundFetch(t,l,h);return e.__returned=e}{const n=this.valList[l];if(this.isBackgroundFetch(n))return e&&void 0!==n.__staleWhileFetching?n.__staleWhileFetching:n.__returned=n;if(!this.isStale(l))return this.moveToTail(l),i&&this.updateItemAge(l),n;const s=this.backgroundFetch(t,l,h);return e&&void 0!==s.__staleWhileFetching?s.__staleWhileFetching:s.__returned=s}}get(t,{allowStale:e=this.allowStale,updateAgeOnGet:i=this.updateAgeOnGet}={}){const n=this.keyMap.get(t);if(void 0!==n){const s=this.valList[n],r=this.isBackgroundFetch(s);if(this.isStale(n))return r?e?s.__staleWhileFetching:void 0:(this.delete(t),e?s:void 0);if(r)return;return this.moveToTail(n),i&&this.updateItemAge(n),s}}connect(t,e){this.prev[e]=t,this.next[t]=e}moveToTail(t){t!==this.tail&&(t===this.head?this.head=this.next[t]:this.connect(this.prev[t],this.next[t]),this.connect(this.tail,t),this.tail=t)}get del(){return pi("del","delete"),this.delete}delete(t){let e=!1;if(0!==this.size){const i=this.keyMap.get(t);if(void 0!==i)if(e=!0,1===this.size)this.clear();else{this.removeItemSize(i);const e=this.valList[i];this.isBackgroundFetch(e)?e.__abortController.abort():(this.dispose(e,t,"delete"),this.disposeAfter&&this.disposed.push([e,t,"delete"])),this.keyMap.delete(t),this.keyList[i]=null,this.valList[i]=null,i===this.tail?this.tail=this.prev[i]:i===this.head?this.head=this.next[i]:(this.next[this.prev[i]]=this.next[i],this.prev[this.next[i]]=this.prev[i]),this.size--,this.free.push(i)}}if(this.disposed)for(;this.disposed.length;)this.disposeAfter(...this.disposed.shift());return e}clear(){for(const t of this.rindexes({allowStale:!0})){const e=this.valList[t];if(this.isBackgroundFetch(e))e.__abortController.abort();else{const i=this.keyList[t];this.dispose(e,i,"delete"),this.disposeAfter&&this.disposed.push([e,i,"delete"])}}if(this.keyMap.clear(),this.valList.fill(null),this.keyList.fill(null),this.ttls&&(this.ttls.fill(0),this.starts.fill(0)),this.sizes&&this.sizes.fill(0),this.head=0,this.tail=0,this.initialFill=1,this.free.length=0,this.calculatedSize=0,this.size=0,this.disposed)for(;this.disposed.length;)this.disposeAfter(...this.disposed.shift())}get reset(){return pi("reset","clear"),this.clear}get length(){return((t,e)=>{const i=`LRU_CACHE_PROPERTY_${t}`;if(yi(i)){const{prototype:n}=_i,{get:s}=Object.getOwnPropertyDescriptor(n,t);vi(i,`${t} property`,`cache.${e}`,s)}})("length","size"),this.size}static get AbortController(){return hi}static get AbortSignal(){return li}}var ji=_i;const Si=ni("rpc:InMemoryCache");class Ci{constructor(t){this.clearCache=()=>{var t;Si("clearCache"),null===(t=this.cachedResponseByParams)||void 0===t||t.reset()},this.getCachedResponse=t=>{var e;Si("getCachedResponse, key: ",t);let i=null===(e=this.cachedResponseByParams)||void 0===e?void 0:e.get(a(t));return"string"==typeof i&&(i=JSON.parse(i)),i},this.setCachedResponse=(t,e)=>{var i,n;Si("setCachedResponse",t,e);const s=a(t);if(!e)return null===(i=this.cachedResponseByParams)||void 0===i?void 0:i.del(s);const r=Object.assign({},e);delete r.correlationId,null===(n=this.cachedResponseByParams)||void 0===n||n.set(s,r?JSON.stringify(r):void 0)},this.cachedResponseByParams=new ji({max:(null==t?void 0:t.cacheMaxSize)||Ci.DEFAULT_CACHE_MAX_SIZE,ttl:(null==t?void 0:t.cacheMaxAgeMs)||Ci.DEFAULT_CACHE_MAX_AGE_MS})}}Ci.DEFAULT_CACHE_MAX_AGE_MS=3e5,Ci.DEFAULT_CACHE_MAX_SIZE=100;class Oi{constructor(t){const{code:e,correlationId:i,data:n,message:s,success:r}=t;if("number"!=typeof e)throw new Error("code must be a number");if(this.code=e,i&&"string"!=typeof i)throw new Error("correlationId must be a string");if(this.correlationId=i,this.data=n,s&&"string"!=typeof s)throw new Error("message must be a string");if(this.message=s,"boolean"!=typeof r)throw new Error("success must be a boolean");this.success=r}}const Ti=ni("rpc:HTTPTransport");class Ai{constructor(t){this.options=t,this.networkIsConnected=!1,this.name="HttpTransport",this.isConnected=()=>{var t;return"undefined"!=typeof window?!!(null===(t=null===window||void 0===window?void 0:window.navigator)||void 0===t?void 0:t.onLine):this.networkIsConnected},this.sendRequest=t=>e(this,void 0,void 0,(function*(){Ti("sendRequest",t);const e=JSON.stringify(Object.assign({identity:this.identity},t)),i=yield null===window||void 0===window?void 0:window.fetch(this.host,{body:e,cache:"default",credentials:"omit",headers:{"Content-Type":"application/json"},method:"POST",mode:"cors",redirect:"follow",referrerPolicy:"origin"}),n=yield i.text();if(!n)throw new Error("No response received from remote");const s=JSON.parse(n);return new Oi(s)})),this.setIdentity=t=>{Ti("setIdentity",t),this.identity=t},this.host=t.host}}class Ii{constructor(t){this.reject=t=>{this.rejectPromise&&this.rejectPromise(t)},this.resolve=t=>{this.resolvePromise&&this.resolvePromise(t)},this.promise=new Promise(((i,n)=>e(this,void 0,void 0,(function*(){const e=setTimeout((()=>{n(new Error("PromiseWraper timeout"))}),t||3e4);this.rejectPromise=t=>{clearTimeout(e),n(t)},this.resolvePromise=t=>{clearTimeout(e),i(t)}}))))}}const ki=t=>new Promise((e=>setTimeout(e,t))),Ei=ni("rpc:WebSocketTransport");class Ri{constructor(t){this.options=t,this.connectedToRemote=!1,this.isWaitingForIdentityConfirmation=!1,this.pendingPromisesForResponse={},this.websocketId=void 0,this.name="WebSocketTransport",this.isConnected=()=>this.connectedToRemote&&!!this.websocket,this.sendRequest=t=>e(this,void 0,void 0,(function*(){for(Ei("sendRequest",t);this.isWaitingForIdentityConfirmation;)Ei("waiting for identity confirmation"),yield ki(100);return this.send(t)})),this.setIdentity=t=>e(this,void 0,void 0,(function*(){if(Ei("setIdentity",t),!t)return this.identity=void 0,void(yield this.resetConnection());this.identity=t,this.connectedToRemote?this.isWaitingForIdentityConfirmation?Ei('setIdentity returning early because "this.isWaitingForIdentityConfirmation=true"'):(this.isWaitingForIdentityConfirmation=!0,this.send({identity:t}).then((()=>{Ei("setIdentity with remote complete")})).catch((t=>{Ei("setIdentity with remote error",t)})).finally((()=>{this.isWaitingForIdentityConfirmation=!1}))):Ei("setIdentity is not connected to remote")})),this.connect=()=>{if(Ei("connect",this.host),this.websocket)return void Ei("connect() returning early, websocket already exists");this.websocketId=Math.random(),this.websocket=new WebSocket(this.host);const t=this.websocket;t.onopen=()=>{console.info("WebSocket connected"),this.setConnectedToRemote(!0)},t.onmessage=t=>{this.handleWebSocketMsg(t)},t.onclose=t=>{this.connectedToRemote?console.info("WebSocket closed",t.reason):Ei("WebSocket closed, it was not connected to the remote"),this.setConnectedToRemote(!1),this.isWaitingForIdentityConfirmation=!1,this.websocket=void 0,this.websocketId=void 0,Object.entries(this.pendingPromisesForResponse).forEach((([t,e])=>{e.reject(new s("Websocket disconnected"))})),t.wasClean||setTimeout((()=>{this.connect()}),1e3)},t.onerror=e=>{this.connectedToRemote?console.error("WebSocket encountered error: ",e):Ei("WebSocket errored, it was not connected to the remote"),t.close()}},this.disconnect=t=>{var e;Ei("disconnect"),this.setConnectedToRemote(!1),this.isWaitingForIdentityConfirmation=!1,null===(e=this.websocket)||void 0===e||e.close(1e3,t),this.websocket=void 0,this.websocketId=void 0},this.handleWebSocketMsg=t=>{let e;Ei("handleWebSocketMsg",t);try{e=JSON.parse(t.data)}catch(t){console.error("error parsing WS msg",t)}const i=new Oi(e);if(!i.correlationId)return void console.error("RPCClient WebSocketTransport received unexpected msg from the server, not correlationId found in response.",e);const n=this.pendingPromisesForResponse[i.correlationId];n?n.resolve(i):console.warn("rcvd WS msg/response that doesn't match any pending RPC's",e)},this.resetConnection=()=>e(this,void 0,void 0,(function*(){Ei("resetConnection"),this.disconnect("WebSocketTransport#resetConnection"),yield ki(100),this.connect()})),this.send=t=>e(this,void 0,void 0,(function*(){var e;Ei("send",t);const i=Math.random().toString();t.correlationId=t.correlationId||i;let n=new Ii(Ri.DEFAULT_TIMEOUT_MS);return null===(e=this.websocket)||void 0===e||e.send(JSON.stringify(t)),this.pendingPromisesForResponse[t.correlationId]=n,yield n.promise.finally((()=>{delete this.pendingPromisesForResponse[t.correlationId]}))})),this.setConnectedToRemote=t=>{Ei(`setConnectedToRemote: ${t}`),this.connectedToRemote=t,this.options.onConnectionStatusChange&&this.options.onConnectionStatusChange(t),t&&this.identity&&this.setIdentity(this.identity)},Ei("new WebSocketTransport()"),this.host=t.host,this.connect()}}Ri.DEFAULT_TIMEOUT_MS=1e4;const zi=t=>{const e=t.split("::");return{procedure:e[1],scope:e[0]||"global",version:e[2]||"1"}};class xi{constructor(){this.events={},this.publish=(t,i)=>e(this,void 0,void 0,(function*(){const e=this.events[t];e&&e.forEach((function(t){t.call(t,i)}))})),this.subscribe=(t,e)=>{this.events[t]||(this.events[t]=[]),this.events[t].push(e)},this.unsubscribe=(t,e)=>{if(!this.events[t])return;let i=this.events[t].indexOf(e);this.events[t].splice(i)}}}const Mi={HTTP_HOST_OR_TRANSPORT_REQUIRED:"http host or tansport is required",INTERCEPTOR_MUSTBE_FUNC:"interceptors must be a function"};class Li{constructor(t){var n,s,r,o,c,h;if(this.options=t,this.webSocketConnectionChangeListeners=[],this.vent=new xi,this.onWebSocketConnectionStatusChange=t=>{this.options.onWebSocketConnectionStatusChange&&this.options.onWebSocketConnectionStatusChange(t),this.webSocketConnectionChangeListeners.forEach((e=>e(t)))},this.call=(t,n)=>e(this,void 0,void 0,(function*(){if(!t)throw new Error('RPCClient.call(request) requires a "request" param');let e;e="string"==typeof t?zi(t):t,n&&(e.args=n);const s=new i(e);if(!s.procedure&&!s.identity)throw new TypeError('RPCClient#call requires a "identity" or "procedure" prop and received neither');s.identity||(s.identity={}),s.identity=ei(Object.assign({},this.identity),s.identity);const r=yield this.callManager.manageClientRequest(s);if(!r.success)throw r;const o=a(e);return this.vent.publish(o,null==r?void 0:r.data),r})),this.clearCache=t=>{this.callManager.clearCache(t)},this.getCallCache=(t,e)=>{let i;i="string"==typeof t?zi(t):t,e&&(i.args=e);const n=this.callManager.getCachedResponse(i);if(n)return n},this.getIdentity=()=>this.identity?Je(this.identity):this.identity,this.getInFlightCallCount=()=>this.callManager.getInFlightCallCount(),this.getWebSocketConnected=()=>{var t;return!!(null===(t=null==this?void 0:this.webSocketTransport)||void 0===t?void 0:t.isConnected())},this.makeProcedure=t=>{const e=this;let i;return i="string"==typeof t?zi(t):t,function(t){return e.call(Object.assign(Object.assign({},i),{args:t}))}},this.registerResponseInterceptor=t=>{this.callManager.addResponseInterceptor(t)},this.registerRequestInterceptor=t=>{this.callManager.addRequestInterceptor(t)},this.registerWebSocketConnectionStatusChangeListener=t=>{this.webSocketConnectionChangeListeners.push(t)},this.setIdentity=t=>{let e=Je(t);this.identity=t,this.callManager.setIdentity(e)},this.setIdentityMetadata=t=>{var e;null!==(e=this.identity)&&void 0!==e||(this.identity={});const i=Je(this.identity);i.metadata=t,this.identity.metadata=t,this.callManager.setIdentity(i)},!(null===(n=null==t?void 0:t.hosts)||void 0===n?void 0:n.http)&&!(null===(s=null==t?void 0:t.transports)||void 0===s?void 0:s.http))throw new Error(Mi.HTTP_HOST_OR_TRANSPORT_REQUIRED);if(t.requestInterceptor&&"function"!=typeof t.requestInterceptor)throw new Error(Mi.INTERCEPTOR_MUSTBE_FUNC);if(t.responseInterceptor&&"function"!=typeof t.responseInterceptor)throw new Error(Mi.INTERCEPTOR_MUSTBE_FUNC);let l;const u={cacheMaxAgeMs:null==t?void 0:t.cacheMaxAgeMs};l="browser"==t.cacheType?new oi(u):new Ci(u);const d=[];(null===(r=t.transports)||void 0===r?void 0:r.websocket)?d.push(t.transports.websocket):(null===(o=null==t?void 0:t.hosts)||void 0===o?void 0:o.websocket)&&(this.webSocketTransport=new Ri({host:t.hosts.websocket,onConnectionStatusChange:this.onWebSocketConnectionStatusChange}),d.push(this.webSocketTransport)),(null===(c=t.transports)||void 0===c?void 0:c.http)?d.push(t.transports.http):(null===(h=null==t?void 0:t.hosts)||void 0===h?void 0:h.http)&&(this.httpTransport=new Ai({host:t.hosts.http}),d.push(this.httpTransport)),this.callManager=new ri({cache:l,deadlineMs:t.deadlineMs||Li.DEFAULT_DEADLINE_MS,requestInterceptor:t.requestInterceptor,responseInterceptor:t.responseInterceptor,transports:d})}subscribe(t,e){const i="string"==typeof t.request?zi(t.request):t.request,n=a(Object.assign(Object.assign({},i),{args:t.args}));this.vent.subscribe(n,e)}unsubscribe(t,e){const i="string"==typeof t.request?zi(t.request):t.request,n=a(Object.assign(Object.assign({},i),{args:t.args}));this.vent.unsubscribe(n,e)}}Li.DEFAULT_DEADLINE_MS=1e4,t.RPCClient=Li,t.RPCResponse=Oi,Object.defineProperty(t,"__esModule",{value:!0})}));
//# sourceMappingURL=umd.js.map
import stringify from 'fast-json-stable-stringify';
import sortKeys from './sort-keys';
export const makeCallRequestKey = (request) => {
import sortKeys from './sort-keys.js';
const makeCallRequestKey = (request) => {
if (!request.args)

@@ -8,2 +9,4 @@ return `${request.scope}${request.procedure}${request.version}`;

};
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiY2FjaGUtdXRpbHMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi9zcmMvdXRpbHMvY2FjaGUtdXRpbHMudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IkFBQ0EsT0FBTyxTQUFTLE1BQU0sNEJBQTRCLENBQUE7QUFDbEQsT0FBTyxRQUFRLE1BQU0sYUFBYSxDQUFBO0FBRWxDLE1BQU0sQ0FBQyxNQUFNLGtCQUFrQixHQUFHLENBQUMsT0FBdUIsRUFBVSxFQUFFO0lBQ3BFLElBQUksQ0FBQyxPQUFPLENBQUMsSUFBSTtRQUNmLE9BQU8sR0FBRyxPQUFPLENBQUMsS0FBSyxHQUFHLE9BQU8sQ0FBQyxTQUFTLEdBQUcsT0FBTyxDQUFDLE9BQU8sRUFBRSxDQUFBO0lBRWpFLE9BQU8sR0FBRyxPQUFPLENBQUMsS0FBSyxHQUFHLE9BQU8sQ0FBQyxTQUFTLEdBQUcsT0FBTyxDQUFDLE9BQU8sR0FBRyxTQUFTLENBQ3ZFLFFBQVEsQ0FBQyxPQUFPLENBQUMsSUFBSSxJQUFJLEVBQUUsRUFBRSxFQUFFLElBQUksRUFBRSxJQUFJLEVBQUUsQ0FBQyxDQUM3QyxFQUFFLENBQUE7QUFDTCxDQUFDLENBQUEifQ==
export { makeCallRequestKey };
//# sourceMappingURL=cache-utils.js.map

@@ -10,3 +10,3 @@ let lsDebug = null;

}
export const GetDebugLogger = (prefix) => {
const GetDebugLogger = (prefix) => {
if (lsDebug) {

@@ -19,2 +19,4 @@ if (new RegExp(lsDebug).test(prefix)) {

};
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZGVidWctbG9nZ2VyLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vc3JjL3V0aWxzL2RlYnVnLWxvZ2dlci50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiQUFBQSxJQUFJLE9BQU8sR0FBOEIsSUFBSSxDQUFBO0FBRTdDLElBQUk7SUFDRixPQUFPLEdBQUcsWUFBWSxDQUFDLE9BQU8sQ0FBQyxPQUFPLENBQUMsSUFBSSxFQUFFLENBQUE7Q0FDOUM7QUFBQyxPQUFPLENBQU0sRUFBRTtJQUNmLElBQUksT0FBTyxNQUFNLEtBQUssV0FBVyxJQUFJLE9BQU8sWUFBWSxLQUFLLFdBQVcsRUFBRTtRQUN4RSxPQUFPLENBQUMsSUFBSSxDQUFDLDZCQUE2QixDQUFDLENBQUE7S0FDNUM7Q0FDRjtBQUNELE1BQU0sQ0FBQyxNQUFNLGNBQWMsR0FBRyxDQUFDLE1BQWMsRUFBRSxFQUFFO0lBQy9DLElBQUksT0FBTyxFQUFFO1FBQ1gsSUFBSSxJQUFJLE1BQU0sQ0FBQyxPQUFPLENBQUMsQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLEVBQUU7WUFDcEMsT0FBTyxDQUFDLEdBQUcsSUFBUyxFQUFFLEVBQUUsQ0FBQyxPQUFPLENBQUMsR0FBRyxDQUFDLE1BQU0sRUFBRSxHQUFHLElBQUksQ0FBQyxDQUFBO1NBQ3REO0tBQ0Y7SUFFRCxPQUFPLENBQUMsR0FBRyxFQUFFLENBQUMsU0FBUyxDQUEyQixDQUFBO0FBQ3BELENBQUMsQ0FBQSJ9
export { GetDebugLogger };
//# sourceMappingURL=debug-logger.js.map

@@ -6,5 +6,5 @@ export declare class PromiseWrapper<T, E> {

constructor(timeout?: number);
reject: (rejectReturnValue?: E | undefined) => any;
reject: (rejectReturnValue?: E) => any;
resolve: (resolveReturnValue: T) => void;
}
//# sourceMappingURL=PromiseWrapper.d.ts.map

@@ -1,12 +0,5 @@

var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
import { __awaiter } from '../node_modules/tslib/tslib.es6.js';
const DEFAULT_TIMEOUT = 30000;
export class PromiseWrapper {
class PromiseWrapper {
constructor(timeout) {

@@ -38,2 +31,4 @@ this.reject = (rejectReturnValue) => {

}
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiUHJvbWlzZVdyYXBwZXIuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi9zcmMvdXRpbHMvUHJvbWlzZVdyYXBwZXIudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7Ozs7Ozs7O0FBQUEsTUFBTSxlQUFlLEdBQUcsS0FBSyxDQUFBO0FBRTdCLE1BQU0sT0FBTyxjQUFjO0lBTXpCLFlBQVksT0FBZ0I7UUFvQjVCLFdBQU0sR0FBRyxDQUFDLGlCQUFxQixFQUFPLEVBQUU7WUFDdEMsSUFBSSxJQUFJLENBQUMsYUFBYSxFQUFFO2dCQUN0QixJQUFJLENBQUMsYUFBYSxDQUFDLGlCQUFpQixDQUFDLENBQUE7YUFDdEM7UUFDSCxDQUFDLENBQUE7UUFFRCxZQUFPLEdBQUcsQ0FBQyxrQkFBcUIsRUFBUSxFQUFFO1lBQ3hDLElBQUksSUFBSSxDQUFDLGNBQWMsRUFBRTtnQkFDdkIsSUFBSSxDQUFDLGNBQWMsQ0FBQyxrQkFBa0IsQ0FBQyxDQUFBO2FBQ3hDO1FBQ0gsQ0FBQyxDQUFBO1FBN0JDLElBQUksQ0FBQyxPQUFPLEdBQUcsSUFBSSxPQUFPLENBQUMsQ0FBTyxPQUFPLEVBQUUsTUFBTSxFQUFFLEVBQUU7WUFDbkQsTUFBTSxLQUFLLEdBQUcsVUFBVSxDQUFDLEdBQUcsRUFBRTtnQkFDNUIsTUFBTSxDQUFDLElBQUksS0FBSyxDQUFDLHVCQUF1QixDQUFDLENBQUMsQ0FBQTtZQUM1QyxDQUFDLEVBQUUsT0FBTyxJQUFJLGVBQWUsQ0FBQyxDQUFBO1lBRTlCLElBQUksQ0FBQyxhQUFhLEdBQUcsQ0FBQyxHQUFPLEVBQUUsRUFBRTtnQkFDL0IsWUFBWSxDQUFDLEtBQUssQ0FBQyxDQUFBO2dCQUVuQixNQUFNLENBQUMsR0FBRyxDQUFDLENBQUE7WUFDYixDQUFDLENBQUE7WUFFRCxJQUFJLENBQUMsY0FBYyxHQUFHLENBQUMsR0FBTSxFQUFFLEVBQUU7Z0JBQy9CLFlBQVksQ0FBQyxLQUFLLENBQUMsQ0FBQTtnQkFFbkIsT0FBTyxDQUFDLEdBQUcsQ0FBQyxDQUFBO1lBQ2QsQ0FBQyxDQUFBO1FBQ0gsQ0FBQyxDQUFBLENBQUMsQ0FBQTtJQUNKLENBQUM7Q0FhRiJ9
export { PromiseWrapper };
//# sourceMappingURL=PromiseWrapper.js.map

@@ -1,3 +0,4 @@

import { DEFAULT_REQUEST_SCOPE, DEFAULT_REQUEST_VERSION, } from '../CallRequestDTO';
export const parseRequestShorthand = (requestString) => {
import { DEFAULT_REQUEST_SCOPE, DEFAULT_REQUEST_VERSION } from '../CallRequestDTO.js';
const parseRequestShorthand = (requestString) => {
const parsed = requestString.split('::');

@@ -10,2 +11,4 @@ return {

};
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoicmVxdWVzdC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3NyYy91dGlscy9yZXF1ZXN0LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBLE9BQU8sRUFDTCxxQkFBcUIsRUFDckIsdUJBQXVCLEdBRXhCLE1BQU0sbUJBQW1CLENBQUE7QUFFMUIsTUFBTSxDQUFDLE1BQU0scUJBQXFCLEdBQUcsQ0FDbkMsYUFBcUIsRUFDTCxFQUFFO0lBQ2xCLE1BQU0sTUFBTSxHQUFHLGFBQWEsQ0FBQyxLQUFLLENBQUMsSUFBSSxDQUFDLENBQUE7SUFFeEMsT0FBTztRQUNMLFNBQVMsRUFBRSxNQUFNLENBQUMsQ0FBQyxDQUFDO1FBQ3BCLEtBQUssRUFBRSxNQUFNLENBQUMsQ0FBQyxDQUFDLElBQUkscUJBQXFCO1FBQ3pDLE9BQU8sRUFBRSxNQUFNLENBQUMsQ0FBQyxDQUFDLElBQUksdUJBQXVCO0tBQzlDLENBQUE7QUFDSCxDQUFDLENBQUEifQ==
export { parseRequestShorthand };
//# sourceMappingURL=request.js.map

@@ -1,2 +0,4 @@

export const sleep = (ms) => new Promise((r) => setTimeout(r, ms));
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic2xlZXAuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi9zcmMvdXRpbHMvc2xlZXAudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IkFBQUEsTUFBTSxDQUFDLE1BQU0sS0FBSyxHQUFHLENBQUMsRUFBVSxFQUFFLEVBQUUsQ0FBQyxJQUFJLE9BQU8sQ0FBQyxDQUFDLENBQUMsRUFBRSxFQUFFLENBQUMsVUFBVSxDQUFDLENBQUMsRUFBRSxFQUFFLENBQUMsQ0FBQyxDQUFBIn0=
const sleep = (ms) => new Promise((r) => setTimeout(r, ms));
export { sleep };
//# sourceMappingURL=sleep.js.map

@@ -8,3 +8,3 @@ function isPlainObject(value) {

}
export default function sortKeys(object, options = {}) {
function sortKeys(object, options = {}) {
if (!isPlainObject(object) && !Array.isArray(object)) {

@@ -62,2 +62,4 @@ throw new TypeError('Expected a plain object or array');

}
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic29ydC1rZXlzLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vc3JjL3V0aWxzL3NvcnQta2V5cy50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiQUFDQSxTQUFTLGFBQWEsQ0FBQyxLQUFVO0lBQy9CLElBQUksTUFBTSxDQUFDLFNBQVMsQ0FBQyxRQUFRLENBQUMsSUFBSSxDQUFDLEtBQUssQ0FBQyxLQUFLLGlCQUFpQixFQUFFO1FBQy9ELE9BQU8sS0FBSyxDQUFBO0tBQ2I7SUFFRCxNQUFNLFNBQVMsR0FBRyxNQUFNLENBQUMsY0FBYyxDQUFDLEtBQUssQ0FBQyxDQUFBO0lBQzlDLE9BQU8sU0FBUyxLQUFLLElBQUksSUFBSSxTQUFTLEtBQUssTUFBTSxDQUFDLFNBQVMsQ0FBQTtBQUM3RCxDQUFDO0FBRUQsTUFBTSxDQUFDLE9BQU8sVUFBVSxRQUFRLENBQUMsTUFBYyxFQUFFLFVBQWUsRUFBRTtJQUNoRSxJQUFJLENBQUMsYUFBYSxDQUFDLE1BQU0sQ0FBQyxJQUFJLENBQUMsS0FBSyxDQUFDLE9BQU8sQ0FBQyxNQUFNLENBQUMsRUFBRTtRQUNwRCxNQUFNLElBQUksU0FBUyxDQUFDLGtDQUFrQyxDQUFDLENBQUE7S0FDeEQ7SUFFRCxNQUFNLEVBQUUsSUFBSSxFQUFFLE9BQU8sRUFBRSxHQUFHLE9BQU8sQ0FBQTtJQUNqQyxNQUFNLFNBQVMsR0FBUSxFQUFFLENBQUE7SUFDekIsTUFBTSxVQUFVLEdBQVEsRUFBRSxDQUFBO0lBRTFCLE1BQU0sYUFBYSxHQUFHLENBQUMsS0FBVSxFQUFFLEVBQUU7UUFDbkMsTUFBTSxTQUFTLEdBQUcsU0FBUyxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQTtRQUMxQyxJQUFJLFNBQVMsS0FBSyxDQUFDLENBQUMsRUFBRTtZQUNwQixPQUFPLFVBQVUsQ0FBQyxTQUFTLENBQUMsQ0FBQTtTQUM3QjtRQUVELE1BQU0sTUFBTSxHQUFRLEVBQUUsQ0FBQTtRQUN0QixTQUFTLENBQUMsSUFBSSxDQUFDLEtBQUssQ0FBQyxDQUFBO1FBQ3JCLFVBQVUsQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLENBQUE7UUFFdkIsTUFBTSxDQUFDLElBQUksQ0FDVCxHQUFHLEtBQUssQ0FBQyxHQUFHLENBQUMsQ0FBQyxJQUFTLEVBQUUsRUFBRTtZQUN6QixJQUFJLEtBQUssQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLEVBQUU7Z0JBQ3ZCLE9BQU8sYUFBYSxDQUFDLElBQUksQ0FBQyxDQUFBO2FBQzNCO1lBRUQsSUFBSSxhQUFhLENBQUMsSUFBSSxDQUFDLEVBQUU7Z0JBQ3ZCLE9BQU8sU0FBUyxDQUFDLElBQUksQ0FBQyxDQUFBO2FBQ3ZCO1lBRUQsT0FBTyxJQUFJLENBQUE7UUFDYixDQUFDLENBQUMsQ0FDSCxDQUFBO1FBRUQsT0FBTyxNQUFNLENBQUE7SUFDZixDQUFDLENBQUE7SUFFRCxNQUFNLFNBQVMsR0FBRyxDQUFDLE1BQVcsRUFBRSxFQUFFO1FBQ2hDLE1BQU0sU0FBUyxHQUFHLFNBQVMsQ0FBQyxPQUFPLENBQUMsTUFBTSxDQUFDLENBQUE7UUFDM0MsSUFBSSxTQUFTLEtBQUssQ0FBQyxDQUFDLEVBQUU7WUFDcEIsT0FBTyxVQUFVLENBQUMsU0FBUyxDQUFDLENBQUE7U0FDN0I7UUFFRCxNQUFNLE1BQU0sR0FBRyxFQUFFLENBQUE7UUFDakIsTUFBTSxJQUFJLEdBQUcsTUFBTSxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUMsQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLENBQUE7UUFFOUMsU0FBUyxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUMsQ0FBQTtRQUN0QixVQUFVLENBQUMsSUFBSSxDQUFDLE1BQU0sQ0FBQyxDQUFBO1FBRXZCLEtBQUssTUFBTSxHQUFHLElBQUksSUFBSSxFQUFFO1lBQ3RCLE1BQU0sS0FBSyxHQUFHLE1BQU0sQ0FBQyxHQUFHLENBQUMsQ0FBQTtZQUN6QixJQUFJLFFBQVEsQ0FBQTtZQUVaLElBQUksSUFBSSxJQUFJLEtBQUssQ0FBQyxPQUFPLENBQUMsS0FBSyxDQUFDLEVBQUU7Z0JBQ2hDLFFBQVEsR0FBRyxhQUFhLENBQUMsS0FBSyxDQUFDLENBQUE7YUFDaEM7aUJBQU07Z0JBQ0wsUUFBUSxHQUFHLElBQUksSUFBSSxhQUFhLENBQUMsS0FBSyxDQUFDLENBQUMsQ0FBQyxDQUFDLFNBQVMsQ0FBQyxLQUFLLENBQUMsQ0FBQyxDQUFDLENBQUMsS0FBSyxDQUFBO2FBQ25FO1lBRUQsTUFBTSxDQUFDLGNBQWMsQ0FBQyxNQUFNLEVBQUUsR0FBRyxrQ0FDNUIsTUFBTSxDQUFDLHdCQUF3QixDQUFDLE1BQU0sRUFBRSxHQUFHLENBQUMsS0FDL0MsS0FBSyxFQUFFLFFBQVEsSUFDZixDQUFBO1NBQ0g7UUFFRCxPQUFPLE1BQU0sQ0FBQTtJQUNmLENBQUMsQ0FBQTtJQUVELElBQUksS0FBSyxDQUFDLE9BQU8sQ0FBQyxNQUFNLENBQUMsRUFBRTtRQUN6QixPQUFPLElBQUksQ0FBQyxDQUFDLENBQUMsYUFBYSxDQUFDLE1BQU0sQ0FBQyxDQUFDLENBQUMsQ0FBQyxNQUFNLENBQUMsS0FBSyxFQUFFLENBQUE7S0FDckQ7SUFFRCxPQUFPLFNBQVMsQ0FBQyxNQUFNLENBQUMsQ0FBQTtBQUMxQixDQUFDIn0=
export { sortKeys as default };
//# sourceMappingURL=sort-keys.js.map

@@ -1,11 +0,4 @@

var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
export class Vent {
import { __awaiter } from '../node_modules/tslib/tslib.es6.js';
class Vent {
constructor() {

@@ -35,2 +28,4 @@ this.events = {};

}
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidmVudC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3NyYy91dGlscy92ZW50LnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7Ozs7OztBQUFBLE1BQU0sT0FBTyxJQUFJO0lBQWpCO1FBQ1UsV0FBTSxHQUF3QixFQUFFLENBQUE7UUFFeEMsWUFBTyxHQUFHLENBQU8sS0FBYSxFQUFFLElBQVMsRUFBRSxFQUFFO1lBQzNDLE1BQU0sUUFBUSxHQUFHLElBQUksQ0FBQyxNQUFNLENBQUMsS0FBSyxDQUFDLENBQUE7WUFFbkMsSUFBSSxDQUFDLFFBQVE7Z0JBQUUsT0FBTTtZQUVyQixRQUFRLENBQUMsT0FBTyxDQUFDLFVBQVUsT0FBNEI7Z0JBQ3JELE9BQU8sQ0FBQyxJQUFJLENBQUMsT0FBTyxFQUFFLElBQUksQ0FBQyxDQUFBO1lBQzdCLENBQUMsQ0FBQyxDQUFBO1FBQ0osQ0FBQyxDQUFBLENBQUE7UUFFRCxjQUFTLEdBQUcsQ0FBQyxLQUFhLEVBQUUsT0FBNEIsRUFBRSxFQUFFO1lBQzFELElBQUksQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLEtBQUssQ0FBQyxFQUFFO2dCQUN2QixJQUFJLENBQUMsTUFBTSxDQUFDLEtBQUssQ0FBQyxHQUFHLEVBQUUsQ0FBQTthQUN4QjtZQUdELElBQUksQ0FBQyxNQUFNLENBQUMsS0FBSyxDQUFDLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxDQUFBO1FBQ2xDLENBQUMsQ0FBQTtRQUVELGdCQUFXLEdBQUcsQ0FBQyxLQUFhLEVBQUUsT0FBNEIsRUFBRSxFQUFFO1lBQzVELElBQUksQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLEtBQUssQ0FBQztnQkFBRSxPQUFNO1lBRS9CLElBQUksVUFBVSxHQUFHLElBQUksQ0FBQyxNQUFNLENBQUMsS0FBSyxDQUFDLENBQUMsT0FBTyxDQUFDLE9BQU8sQ0FBQyxDQUFBO1lBRXBELElBQUksQ0FBQyxNQUFNLENBQUMsS0FBSyxDQUFDLENBQUMsTUFBTSxDQUFDLFVBQVUsQ0FBQyxDQUFBO1FBQ3ZDLENBQUMsQ0FBQTtJQUNILENBQUM7Q0FBQSJ9
export { Vent };
//# sourceMappingURL=vent.js.map
{
"name": "@therms/rpc-client",
"version": "2.5.4",
"version": "2.6.0",
"description": "RPC framework, browser client lib",

@@ -5,0 +5,0 @@ "private": false,

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc