ftx-api - npm Package Compare versions

Comparing version 0.0.4 to 0.0.5

lib/util/wsMessages.d.ts

+export declare function getWsAuthMessage(key: string, signature: string, timestamp: number, subAccountName?: string): any;
+export declare function getWsPingMessage(): {
+    op: string;
+};
+export declare function isWsPong(message: any): boolean;

lib/util/wsMessages.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.isWsPong = exports.getWsPingMessage = exports.getWsAuthMessage = void 0;
+function getWsAuthMessage(key, signature, timestamp, subAccountName) {
+    const msg = {
+        op: 'login',
+        args: {
+            key: key,
+            sign: signature,
+            time: timestamp
+        }
+    };
+    if (subAccountName) {
+        msg.args.subaccount = subAccountName;
+    }
+    return msg;
+}
+exports.getWsAuthMessage = getWsAuthMessage;
+;
+function getWsPingMessage() {
+    return { op: 'ping' };
+}
+exports.getWsPingMessage = getWsPingMessage;
+;
+function isWsPong(message) {
+    return (message === null || message === void 0 ? void 0 : message.type) === 'pong';
+}
+exports.isWsPong = isWsPong;
+;
+//# sourceMappingURL=wsMessages.js.map

lib/util/wsMessages.js.map

+{"version":3,"file":"wsMessages.js","sourceRoot":"","sources":["../../src/util/wsMessages.ts"],"names":[],"mappings":";;;AAAA,SAAgB,gBAAgB,CAAC,GAAW,EAAE,SAAiB,EAAE,SAAiB,EAAE,cAAuB;IACzG,MAAM,GAAG,GAAQ;QACf,EAAE,EAAE,OAAO;QACX,IAAI,EAAE;YACJ,GAAG,EAAE,GAAG;YACR,IAAI,EAAE,SAAS;YACf,IAAI,EAAE,SAAS;SAChB;KACF,CAAA;IAED,IAAI,cAAc,EAAE;QAClB,GAAG,CAAC,IAAI,CAAC,UAAU,GAAG,cAAc,CAAC;KACtC;IACD,OAAO,GAAG,CAAC;AACb,CAAC;AAdD,4CAcC;AAAA,CAAC;AAEF,SAAgB,gBAAgB;IAC9B,OAAO,EAAE,EAAE,EAAE,MAAM,EAAE,CAAA;AACvB,CAAC;AAFD,4CAEC;AAAA,CAAC;AAEF,SAAgB,QAAQ,CAAC,OAAY;IACnC,OAAO,CAAA,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,IAAI,MAAK,MAAM,CAAC;AAClC,CAAC;AAFD,4BAEC;AAAA,CAAC"}

lib/rest-client.d.ts

@@ -91,3 +91,3 @@ import { AxiosRequestConfig } from 'axios';
     getPositions(showAveragePrice?: boolean): GenericAPIResponse;
-    setAccountLeverage(leverage: any): GenericAPIResponse;
+    setAccountLeverage(leverage: number): GenericAPIResponse;
     /**
@@ -129,5 +129,3 @@ *
     }): GenericAPIResponse;
-    getSavedAddresses(params?: {
-        coin?: string;
-    }): GenericAPIResponse;
+    getSavedAddresses(coin?: string): GenericAPIResponse;
     createSavedAddress(params: {
@@ -158,5 +156,3 @@ coin: string;
     }): GenericAPIResponse;
-    getTriggerOrderTriggers(params: {
-        conditionalOrderId: string;
-    }): GenericAPIResponse;
+    getTriggerOrderTriggers(conditionalOrderId: string): GenericAPIResponse;
     getTriggerOrderHistory(params?: {
@@ -174,3 +170,3 @@ market?: string;
         side: OrderSide;
-        price: number;
+        price: number | null;
         type: OrderType;
@@ -177,0 +173,0 @@ size: number;

lib/rest-client.js

@@ -151,4 +151,4 @@ "use strict";
     }
-    getSavedAddresses(params) {
-        return this.requestWrapper.get('wallet/saved_addresses', params);
+    getSavedAddresses(coin) {
+        return this.requestWrapper.get('wallet/saved_addresses', { coin });
     }
@@ -177,4 +177,4 @@ createSavedAddress(params) {
     }
-    getTriggerOrderTriggers(params) {
-        return this.requestWrapper.get(`conditional_orders/${params.conditionalOrderId}/triggers`);
+    getTriggerOrderTriggers(conditionalOrderId) {
+        return this.requestWrapper.get(`conditional_orders/${conditionalOrderId}/triggers`);
     }
@@ -181,0 +181,0 @@ getTriggerOrderHistory(params) {

lib/rest-client.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"rest-client.js","sourceRoot":"","sources":["../src/rest-client.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;AACA,sDAA4F;AAC5F,2EAAmD;AAOnD,MAAa,UAAU;IAGrB;;;;;;;OAOG;IACH,YACE,GAAwB,EACxB,MAA2B,EAC3B,oBAAuC,EAAE,EACzC,iBAAqC,EAAE;QAEvC,IAAI,CAAC,cAAc,GAAG,IAAI,wBAAc,CACtC,GAAG,EACH,MAAM,EACN,6BAAc,CAAC,iBAAiB,CAAC,EACjC,iBAAiB,EACjB,cAAc,CACf,CAAC;QACF,OAAO,IAAI,CAAC;IACd,CAAC;IAED;;;;;OAKG;IAEH,cAAc;QACZ,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,aAAa,CAAC,CAAC;IAChD,CAAC;IAED,gBAAgB,CAAC,QAAgB;QAC/B,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,aAAa,EAAE,EAAE,QAAQ,EAAE,CAAC,CAAC;IAC/D,CAAC;IAED,oBAAoB,CAAC,MAGpB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,yBAAyB,EAAE,MAAM,CAAC,CAAC;IACrE,CAAC;IAED,gBAAgB,CAAC,QAAgB;QAC/B,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,aAAa,EAAE,EAAE,QAAQ,EAAE,CAAC,CAAC;IACjE,CAAC;IAED,qBAAqB,CAAC,QAAgB;QACpC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,eAAe,QAAQ,WAAW,CAAC,CAAC;IACrE,CAAC;IAED,0BAA0B,CAAC,MAK1B;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,sBAAsB,EAAE,MAAM,CAAC,CAAC;IAClE,CAAC;IAED;;;;;OAKG;IAEH,UAAU;QACR,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;IAC5C,CAAC;IAED,SAAS,CAAC,UAAkB;QAC1B,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,UAAU,EAAE,CAAC,CAAC;IAC1D,CAAC;IAED,YAAY,CAAC,MAGZ;QACC,MAAM,MAAM,GAAG,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,SAAS,MAAM,CAAC,KAAK,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;QAC3D,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,MAAM,CAAC,UAAU,cAAc,MAAM,EAAE,CAAC,CAAC;IACrF,CAAC;IAED,SAAS,CAAC,MAKT;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,MAAM,CAAC,WAAW,SAAS,EAAE,MAAM,CAAC,CAAC;IACjF,CAAC;IAED,mBAAmB,CAAC,MAMnB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,MAAM,CAAC,WAAW,UAAU,EAAE,MAAM,CAAC,CAAC;IAClF,CAAC;IAED;;;;;OAKG;IAEH,cAAc;QACZ,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;IAC5C,CAAC;IAED,SAAS,CAAC,UAAkB;QAC1B,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,UAAU,EAAE,CAAC,CAAC;IAC1D,CAAC;IAED,cAAc,CAAC,UAAkB;QAC/B,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,UAAU,QAAQ,CAAC,CAAC;IAChE,CAAC;IAED,eAAe;QACb,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,eAAe,CAAC,CAAC;IAClD,CAAC;IAED,eAAe,CAAC,gBAAwB;QACtC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,gBAAgB,UAAU,CAAC,CAAC;IACxE,CAAC;IAED,iBAAiB;QACf,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,iBAAiB,CAAC,CAAC;IACpD,CAAC;IAED,kBAAkB,CAAC,MAMlB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,MAAM,CAAC,UAAU,UAAU,EAAE,MAAM,CAAC,CAAC;IACjF,CAAC;IAED;;;;;OAKG;IAEH,UAAU;QACR,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;IAC5C,CAAC;IAED,YAAY,CAAC,gBAA0B;QACrC,MAAM,MAAM,GAAG,gBAAgB,CAAC,CAAC,CAAC,mBAAmB,CAAC,CAAC,CAAC,EAAE,CAAC;QAC3D,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,aAAa,MAAM,EAAE,CAAC,CAAC;IACxD,CAAC;IAED,kBAAkB,CAAC,QAAQ;QACzB,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,kBAAkB,EAAE,EAAE,QAAQ,EAAE,CAAC,CAAC;IACpE,CAAC;IAED;;;;;OAKG;IAEH,QAAQ;QACN,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC;IACjD,CAAC;IAED,WAAW;QACT,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,iBAAiB,CAAC,CAAC;IACpD,CAAC;IAED,sBAAsB;QACpB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,qBAAqB,CAAC,CAAC;IACxD,CAAC;IAED,iBAAiB,CAAC,MAGjB;QACC,MAAM,MAAM,GAAG,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC,UAAU,MAAM,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;QAC9D,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,0BAA0B,MAAM,CAAC,IAAI,IAAI,MAAM,EAAE,CAAC,CAAC;IACpF,CAAC;IAED,iBAAiB,CAAC,MAIjB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,iBAAiB,EAAE,MAAM,CAAC,CAAC;IAC5D,CAAC;IAED,oBAAoB,CAAC,MAIpB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,oBAAoB,EAAE,MAAM,CAAC,CAAC;IAC/D,CAAC;IAED,iBAAiB,CAAC,MAOjB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,oBAAoB,EAAE,MAAM,CAAC,CAAC;IAChE,CAAC;IAED,WAAW,CAAC,MAIX;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,iBAAiB,EAAE,MAAM,CAAC,CAAC;IAC5D,CAAC;IAED,iBAAiB,CAAC,MAEjB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,wBAAwB,EAAE,MAAM,CAAC,CAAC;IACnE,CAAC;IAED,kBAAkB,CAAC,MAMlB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,wBAAwB,EAAE,MAAM,CAAC,CAAC;IACpE,CAAC;IAED,kBAAkB,CAAC,cAAsB;QACvC,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,0BAA0B,cAAc,EAAE,CAAC,CAAC;IAChF,CAAC;IAED;;;;;OAKG;IAEH,aAAa,CAAC,MAAe;QAC3B,MAAM,MAAM,GAAG,MAAM,CAAC,CAAC,CAAC,UAAU,MAAM,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;QAChD,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,UAAU,MAAM,EAAE,CAAC,CAAC;IACrD,CAAC;IAED,eAAe,CAAC,MAKf;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gBAAgB,EAAE,MAAM,CAAC,CAAC;IAC3D,CAAC;IAED,oBAAoB,CAAC,MAGpB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,oBAAoB,EAAE,MAAM,CAAC,CAAC;IAC/D,CAAC;IAED,uBAAuB,CAAC,MAEvB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,sBAAsB,MAAM,CAAC,kBAAkB,WAAW,CAAC,CAAC;IAC7F,CAAC;IAED,sBAAsB,CAAC,MAQtB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,QAAQ,EAAE,MAAM,CAAC,CAAC;IACnD,CAAC;IAED,UAAU,CAAC,MAUV;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,QAAQ,EAAE,MAAM,CAAC,CAAC;IACpD,CAAC;IAED,iBAAiB,CAAC,MAcjB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,oBAAoB,EAAE,MAAM,CAAC,CAAC;IAChE,CAAC;IAED,WAAW,CAAC,MAKX;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,UAAU,MAAM,CAAC,OAAO,SAAS,EAAE;YACjE,IAAI,EAAE,MAAM,CAAC,IAAI;YACjB,KAAK,EAAE,MAAM,CAAC,KAAK;YACnB,QAAQ,EAAE,MAAM,CAAC,QAAQ;SAC1B,CAAC,CAAC;IACL,CAAC;IAED,qBAAqB,CAAC,aAAqB,EAAE,MAI5C;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,uBAAuB,aAAa,SAAS,EAAE,MAAM,CAAC,CAAC;IACzF,CAAC;IAED,kBAAkB,CAAC,OAAe,EAAE,MAKnC;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,sBAAsB,OAAO,SAAS,EAAE,MAAM,CAAC,CAAC;IAClF,CAAC;IAED,cAAc,CAAC,OAAe;QAC5B,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,UAAU,OAAO,EAAE,CAAC,CAAC;IACtD,CAAC;IAED,wBAAwB,CAAC,aAAqB;QAC5C,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,uBAAuB,aAAa,EAAE,CAAC,CAAC;IACzE,CAAC;IAED,WAAW,CAAC,OAAe;QACzB,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,UAAU,OAAO,EAAE,CAAC,CAAC;IACzD,CAAC;IAED,qBAAqB,CAAC,aAAqB;QACzC,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,uBAAuB,aAAa,EAAE,CAAC,CAAC;IAC5E,CAAC;IAED,sBAAsB,CAAC,kBAA0B;QAC/C,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,sBAAsB,kBAAkB,EAAE,CAAC,CAAC;IAChF,CAAC;IAED,eAAe,CAAC,MAIf;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,QAAQ,EAAE,MAAM,CAAC,CAAC;IACtD,CAAC;IAED;;;;;OAKG;IAEH,YAAY,CAAC,MAIZ;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,YAAY,EAAE,MAAM,CAAC,CAAC;IACxD,CAAC;IAED,cAAc,CAAC,OAAe,EAAE,MAAe;QAC7C,MAAM,MAAM,GAAG,MAAM,CAAC,CAAC,CAAC,UAAU,MAAM,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;QAChD,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,cAAc,OAAO,IAAI,MAAM,EAAE,CAAC,CAAC;IACpE,CAAC;IAED,WAAW,CAAC,OAAe;QACzB,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,cAAc,OAAO,SAAS,CAAC,CAAC;IAClE,CAAC;IAED;;;;;OAKG;IAEH,cAAc;QACZ,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,0BAA0B,CAAC,CAAC;IAC7D,CAAC;IAED,eAAe;QACb,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,2BAA2B,CAAC,CAAC;IAC9D,CAAC;IAED,uBAAuB;QACrB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,4BAA4B,CAAC,CAAC;IAC/D,CAAC;IAED,aAAa,CAAC,MAAe;QAC3B,MAAM,MAAM,GAAG,MAAM,CAAC,CAAC,CAAC,UAAU,MAAM,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;QAChD,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,2BAA2B,MAAM,EAAE,CAAC,CAAC;IACtE,CAAC;IAED,gBAAgB;QACd,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,4BAA4B,CAAC,CAAC;IAC/D,CAAC;IAED,iBAAiB;QACf,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,6BAA6B,CAAC,CAAC;IAChE,CAAC;IAED,gBAAgB;QACd,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,oBAAoB,CAAC,CAAC;IACvD,CAAC;IAED,cAAc;QACZ,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,0BAA0B,CAAC,CAAC;IAC7D,CAAC;IAED,kBAAkB,CAAC,MAIlB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,oBAAoB,EAAE,MAAM,CAAC,CAAC;IAChE,CAAC;IAED;;;;;OAKG;IAEH,QAAQ,CAAC,MAOR;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,OAAO,EAAE,MAAM,CAAC,CAAC;IAClD,CAAC;IAED,kBAAkB,CAAC,MAIlB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,kBAAkB,EAAE,MAAM,CAAC,CAAC;IAC7D,CAAC;IAED;;;;;OAKG;IAEH,mBAAmB;QACjB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,CAAC,CAAC;IAC9C,CAAC;IAED,qBAAqB,CAAC,SAAiB;QACrC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,MAAM,SAAS,EAAE,CAAC,CAAC;IACpD,CAAC;IAED,yBAAyB;QACvB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,aAAa,CAAC,CAAC;IAChD,CAAC;IAED,kCAAkC;QAChC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC;IACjD,CAAC;IAED,6BAA6B,CAAC,SAAiB,EAAE,IAAY;QAC3D,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,MAAM,SAAS,EAAE,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC;IAC/D,CAAC;IAED,oCAAoC;QAClC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gBAAgB,CAAC,CAAC;IACnD,CAAC;IAED,+BAA+B,CAAC,SAAiB,EAAE,IAAY;QAC7D,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,MAAM,SAAS,SAAS,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC;IACtE,CAAC;IAED;;;;;OAKG;IAEH,iBAAiB;QACf,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,kBAAkB,CAAC,CAAC;IACrD,CAAC;IAED,kBAAkB;QAChB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,qBAAqB,CAAC,CAAC;IACxD,CAAC;IAED,kBAAkB,CAAC,MAWlB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,kBAAkB,EAAE,MAAM,CAAC,CAAC;IAC9D,CAAC;IAED,kBAAkB,CAAC,cAAsB;QACvC,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,oBAAoB,cAAc,EAAE,CAAC,CAAC;IAC1E,CAAC;IAED,wBAAwB,CAAC,cAAsB;QAC7C,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,oBAAoB,cAAc,SAAS,CAAC,CAAC;IAC9E,CAAC;IAED,WAAW,CAAC,cAAsB,EAAE,KAAa;QAC/C,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,oBAAoB,cAAc,EAAE,EAAE,EAAE,KAAK,EAAE,CAAC,CAAC;IACnF,CAAC;IAED,WAAW;QACT,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,mBAAmB,CAAC,CAAC;IACtD,CAAC;IAED,WAAW,CAAC,OAAe;QACzB,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,kBAAkB,OAAO,EAAE,CAAC,CAAC;IACjE,CAAC;IAED,kBAAkB,CAAC,OAAe;QAChC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,kBAAkB,OAAO,SAAS,CAAC,CAAC;IACtE,CAAC;IAED,qBAAqB;QACnB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,sBAAsB,CAAC,CAAC;IACzD,CAAC;IAED,mBAAmB;QACjB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,mBAAmB,CAAC,CAAC;IACtD,CAAC;IAED,sBAAsB,CAAC,MAItB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gBAAgB,EAAE,MAAM,CAAC,CAAC;IAC3D,CAAC;IAED,eAAe,CAAC,MAIf;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,eAAe,EAAE,MAAM,CAAC,CAAC;IAC1D,CAAC;IAED,kBAAkB;QAChB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,4BAA4B,CAAC,CAAC;IAC/D,CAAC;IAED,2BAA2B,CAAC,MAI3B;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gCAAgC,EAAE,MAAM,CAAC,CAAC;IAC3E,CAAC;IAED,sBAAsB;QACpB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,2BAA2B,CAAC,CAAC;IAC9D,CAAC;IAED,gCAAgC,CAAC,MAIhC;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,sCAAsC,EAAE,MAAM,CAAC,CAAC;IACjF,CAAC;IAED;;;;;OAKG;IAEH,SAAS;QACP,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gBAAgB,CAAC,CAAC;IACnD,CAAC;IAED,kBAAkB;QAChB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,0BAA0B,CAAC,CAAC;IAC7D,CAAC;IAED,gBAAgB;QACd,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,kBAAkB,CAAC,CAAC;IACrD,CAAC;IAED,oBAAoB,CAAC,IAAY,EAAE,IAAY;QAC7C,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,0BAA0B,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;IAC9E,CAAC;IAED,oBAAoB,CAAC,gBAAwB;QAC3C,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,4BAA4B,gBAAgB,EAAE,CAAC,CAAC;IACpF,CAAC;IAED,iBAAiB;QACf,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,yBAAyB,CAAC,CAAC;IAC5D,CAAC;IAED,kBAAkB,CAAC,IAAY,EAAE,IAAY;QAC3C,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,gBAAgB,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;IACpE,CAAC;IAED,aAAa;QACX,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,8BAA8B,CAAC,CAAC;IACjE,CAAC;IAED,aAAa;QACX,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gBAAgB,CAAC,CAAC;IACnD,CAAC;IAED;;OAEG;IACG,aAAa;;YACjB,MAAM,KAAK,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;YACzB,IAAI;gBACF,MAAM,QAAQ,GAAG,MAAM,IAAI,CAAC,aAAa,EAAE,CAAC;gBAC5C,MAAM,MAAM,GAAG,IAAI,IAAI,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC,OAAO,EAAE,CAAC;gBACnD,MAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;gBAEvB,OAAO,IAAI,CAAC,IAAI,CAAC,MAAM,GAAG,GAAG,GAAG,CAAC,CAAC,GAAG,GAAG,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC;aACtD;YAAC,OAAO,CAAC,EAAE;gBACV,OAAO,CAAC,CAAC;aACV;QACH,CAAC;KAAA;CACF;AAxqBD,gCAwqBC;AAAA,CAAC"}
+{"version":3,"file":"rest-client.js","sourceRoot":"","sources":["../src/rest-client.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;AACA,sDAA4F;AAC5F,2EAAmD;AAOnD,MAAa,UAAU;IAGrB;;;;;;;OAOG;IACH,YACE,GAAwB,EACxB,MAA2B,EAC3B,oBAAuC,EAAE,EACzC,iBAAqC,EAAE;QAEvC,IAAI,CAAC,cAAc,GAAG,IAAI,wBAAc,CACtC,GAAG,EACH,MAAM,EACN,6BAAc,CAAC,iBAAiB,CAAC,EACjC,iBAAiB,EACjB,cAAc,CACf,CAAC;QACF,OAAO,IAAI,CAAC;IACd,CAAC;IAED;;;;;OAKG;IAEH,cAAc;QACZ,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,aAAa,CAAC,CAAC;IAChD,CAAC;IAED,gBAAgB,CAAC,QAAgB;QAC/B,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,aAAa,EAAE,EAAE,QAAQ,EAAE,CAAC,CAAC;IAC/D,CAAC;IAED,oBAAoB,CAAC,MAGpB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,yBAAyB,EAAE,MAAM,CAAC,CAAC;IACrE,CAAC;IAED,gBAAgB,CAAC,QAAgB;QAC/B,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,aAAa,EAAE,EAAE,QAAQ,EAAE,CAAC,CAAC;IACjE,CAAC;IAED,qBAAqB,CAAC,QAAgB;QACpC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,eAAe,QAAQ,WAAW,CAAC,CAAC;IACrE,CAAC;IAED,0BAA0B,CAAC,MAK1B;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,sBAAsB,EAAE,MAAM,CAAC,CAAC;IAClE,CAAC;IAED;;;;;OAKG;IAEH,UAAU;QACR,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;IAC5C,CAAC;IAED,SAAS,CAAC,UAAkB;QAC1B,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,UAAU,EAAE,CAAC,CAAC;IAC1D,CAAC;IAED,YAAY,CAAC,MAGZ;QACC,MAAM,MAAM,GAAG,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,SAAS,MAAM,CAAC,KAAK,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;QAC3D,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,MAAM,CAAC,UAAU,cAAc,MAAM,EAAE,CAAC,CAAC;IACrF,CAAC;IAED,SAAS,CAAC,MAKT;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,MAAM,CAAC,WAAW,SAAS,EAAE,MAAM,CAAC,CAAC;IACjF,CAAC;IAED,mBAAmB,CAAC,MAMnB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,MAAM,CAAC,WAAW,UAAU,EAAE,MAAM,CAAC,CAAC;IAClF,CAAC;IAED;;;;;OAKG;IAEH,cAAc;QACZ,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;IAC5C,CAAC;IAED,SAAS,CAAC,UAAkB;QAC1B,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,UAAU,EAAE,CAAC,CAAC;IAC1D,CAAC;IAED,cAAc,CAAC,UAAkB;QAC/B,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,UAAU,QAAQ,CAAC,CAAC;IAChE,CAAC;IAED,eAAe;QACb,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,eAAe,CAAC,CAAC;IAClD,CAAC;IAED,eAAe,CAAC,gBAAwB;QACtC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,gBAAgB,UAAU,CAAC,CAAC;IACxE,CAAC;IAED,iBAAiB;QACf,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,iBAAiB,CAAC,CAAC;IACpD,CAAC;IAED,kBAAkB,CAAC,MAMlB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,MAAM,CAAC,UAAU,UAAU,EAAE,MAAM,CAAC,CAAC;IACjF,CAAC;IAED;;;;;OAKG;IAEH,UAAU;QACR,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;IAC5C,CAAC;IAED,YAAY,CAAC,gBAA0B;QACrC,MAAM,MAAM,GAAG,gBAAgB,CAAC,CAAC,CAAC,mBAAmB,CAAC,CAAC,CAAC,EAAE,CAAC;QAC3D,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,aAAa,MAAM,EAAE,CAAC,CAAC;IACxD,CAAC;IAED,kBAAkB,CAAC,QAAgB;QACjC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,kBAAkB,EAAE,EAAE,QAAQ,EAAE,CAAC,CAAC;IACpE,CAAC;IAED;;;;;OAKG;IAEH,QAAQ;QACN,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC;IACjD,CAAC;IAED,WAAW;QACT,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,iBAAiB,CAAC,CAAC;IACpD,CAAC;IAED,sBAAsB;QACpB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,qBAAqB,CAAC,CAAC;IACxD,CAAC;IAED,iBAAiB,CAAC,MAGjB;QACC,MAAM,MAAM,GAAG,MAAM,CAAC,MAAM,CAAC,CAAC,CAAC,UAAU,MAAM,CAAC,MAAM,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;QAC9D,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,0BAA0B,MAAM,CAAC,IAAI,IAAI,MAAM,EAAE,CAAC,CAAC;IACpF,CAAC;IAED,iBAAiB,CAAC,MAIjB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,iBAAiB,EAAE,MAAM,CAAC,CAAC;IAC5D,CAAC;IAED,oBAAoB,CAAC,MAIpB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,oBAAoB,EAAE,MAAM,CAAC,CAAC;IAC/D,CAAC;IAED,iBAAiB,CAAC,MAOjB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,oBAAoB,EAAE,MAAM,CAAC,CAAC;IAChE,CAAC;IAED,WAAW,CAAC,MAIX;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,iBAAiB,EAAE,MAAM,CAAC,CAAC;IAC5D,CAAC;IAED,iBAAiB,CAAC,IAAa;QAC7B,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,wBAAwB,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC;IACrE,CAAC;IAED,kBAAkB,CAAC,MAMlB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,wBAAwB,EAAE,MAAM,CAAC,CAAC;IACpE,CAAC;IAED,kBAAkB,CAAC,cAAsB;QACvC,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,0BAA0B,cAAc,EAAE,CAAC,CAAC;IAChF,CAAC;IAED;;;;;OAKG;IAEH,aAAa,CAAC,MAAe;QAC3B,MAAM,MAAM,GAAG,MAAM,CAAC,CAAC,CAAC,UAAU,MAAM,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;QAChD,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,UAAU,MAAM,EAAE,CAAC,CAAC;IACrD,CAAC;IAED,eAAe,CAAC,MAKf;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gBAAgB,EAAE,MAAM,CAAC,CAAC;IAC3D,CAAC;IAED,oBAAoB,CAAC,MAGpB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,oBAAoB,EAAE,MAAM,CAAC,CAAC;IAC/D,CAAC;IAED,uBAAuB,CAAC,kBAA0B;QAChD,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,sBAAsB,kBAAkB,WAAW,CAAC,CAAC;IACtF,CAAC;IAED,sBAAsB,CAAC,MAQtB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,QAAQ,EAAE,MAAM,CAAC,CAAC;IACnD,CAAC;IAED,UAAU,CAAC,MAUV;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,QAAQ,EAAE,MAAM,CAAC,CAAC;IACpD,CAAC;IAED,iBAAiB,CAAC,MAcjB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,oBAAoB,EAAE,MAAM,CAAC,CAAC;IAChE,CAAC;IAED,WAAW,CAAC,MAKX;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,UAAU,MAAM,CAAC,OAAO,SAAS,EAAE;YACjE,IAAI,EAAE,MAAM,CAAC,IAAI;YACjB,KAAK,EAAE,MAAM,CAAC,KAAK;YACnB,QAAQ,EAAE,MAAM,CAAC,QAAQ;SAC1B,CAAC,CAAC;IACL,CAAC;IAED,qBAAqB,CAAC,aAAqB,EAAE,MAI5C;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,uBAAuB,aAAa,SAAS,EAAE,MAAM,CAAC,CAAC;IACzF,CAAC;IAED,kBAAkB,CAAC,OAAe,EAAE,MAKnC;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,sBAAsB,OAAO,SAAS,EAAE,MAAM,CAAC,CAAC;IAClF,CAAC;IAED,cAAc,CAAC,OAAe;QAC5B,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,UAAU,OAAO,EAAE,CAAC,CAAC;IACtD,CAAC;IAED,wBAAwB,CAAC,aAAqB;QAC5C,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,uBAAuB,aAAa,EAAE,CAAC,CAAC;IACzE,CAAC;IAED,WAAW,CAAC,OAAe;QACzB,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,UAAU,OAAO,EAAE,CAAC,CAAC;IACzD,CAAC;IAED,qBAAqB,CAAC,aAAqB;QACzC,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,uBAAuB,aAAa,EAAE,CAAC,CAAC;IAC5E,CAAC;IAED,sBAAsB,CAAC,kBAA0B;QAC/C,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,sBAAsB,kBAAkB,EAAE,CAAC,CAAC;IAChF,CAAC;IAED,eAAe,CAAC,MAIf;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,QAAQ,EAAE,MAAM,CAAC,CAAC;IACtD,CAAC;IAED;;;;;OAKG;IAEH,YAAY,CAAC,MAIZ;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,YAAY,EAAE,MAAM,CAAC,CAAC;IACxD,CAAC;IAED,cAAc,CAAC,OAAe,EAAE,MAAe;QAC7C,MAAM,MAAM,GAAG,MAAM,CAAC,CAAC,CAAC,UAAU,MAAM,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;QAChD,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,cAAc,OAAO,IAAI,MAAM,EAAE,CAAC,CAAC;IACpE,CAAC;IAED,WAAW,CAAC,OAAe;QACzB,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,cAAc,OAAO,SAAS,CAAC,CAAC;IAClE,CAAC;IAED;;;;;OAKG;IAEH,cAAc;QACZ,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,0BAA0B,CAAC,CAAC;IAC7D,CAAC;IAED,eAAe;QACb,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,2BAA2B,CAAC,CAAC;IAC9D,CAAC;IAED,uBAAuB;QACrB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,4BAA4B,CAAC,CAAC;IAC/D,CAAC;IAED,aAAa,CAAC,MAAe;QAC3B,MAAM,MAAM,GAAG,MAAM,CAAC,CAAC,CAAC,UAAU,MAAM,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;QAChD,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,2BAA2B,MAAM,EAAE,CAAC,CAAC;IACtE,CAAC;IAED,gBAAgB;QACd,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,4BAA4B,CAAC,CAAC;IAC/D,CAAC;IAED,iBAAiB;QACf,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,6BAA6B,CAAC,CAAC;IAChE,CAAC;IAED,gBAAgB;QACd,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,oBAAoB,CAAC,CAAC;IACvD,CAAC;IAED,cAAc;QACZ,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,0BAA0B,CAAC,CAAC;IAC7D,CAAC;IAED,kBAAkB,CAAC,MAIlB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,oBAAoB,EAAE,MAAM,CAAC,CAAC;IAChE,CAAC;IAED;;;;;OAKG;IAEH,QAAQ,CAAC,MAOR;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,OAAO,EAAE,MAAM,CAAC,CAAC;IAClD,CAAC;IAED,kBAAkB,CAAC,MAIlB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,kBAAkB,EAAE,MAAM,CAAC,CAAC;IAC7D,CAAC;IAED;;;;;OAKG;IAEH,mBAAmB;QACjB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,WAAW,CAAC,CAAC;IAC9C,CAAC;IAED,qBAAqB,CAAC,SAAiB;QACrC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,MAAM,SAAS,EAAE,CAAC,CAAC;IACpD,CAAC;IAED,yBAAyB;QACvB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,aAAa,CAAC,CAAC;IAChD,CAAC;IAED,kCAAkC;QAChC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC;IACjD,CAAC;IAED,6BAA6B,CAAC,SAAiB,EAAE,IAAY;QAC3D,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,MAAM,SAAS,EAAE,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC;IAC/D,CAAC;IAED,oCAAoC;QAClC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gBAAgB,CAAC,CAAC;IACnD,CAAC;IAED,+BAA+B,CAAC,SAAiB,EAAE,IAAY;QAC7D,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,MAAM,SAAS,SAAS,EAAE,EAAE,IAAI,EAAE,CAAC,CAAC;IACtE,CAAC;IAED;;;;;OAKG;IAEH,iBAAiB;QACf,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,kBAAkB,CAAC,CAAC;IACrD,CAAC;IAED,kBAAkB;QAChB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,qBAAqB,CAAC,CAAC;IACxD,CAAC;IAED,kBAAkB,CAAC,MAWlB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,kBAAkB,EAAE,MAAM,CAAC,CAAC;IAC9D,CAAC;IAED,kBAAkB,CAAC,cAAsB;QACvC,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,oBAAoB,cAAc,EAAE,CAAC,CAAC;IAC1E,CAAC;IAED,wBAAwB,CAAC,cAAsB;QAC7C,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,oBAAoB,cAAc,SAAS,CAAC,CAAC;IAC9E,CAAC;IAED,WAAW,CAAC,cAAsB,EAAE,KAAa;QAC/C,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,oBAAoB,cAAc,EAAE,EAAE,EAAE,KAAK,EAAE,CAAC,CAAC;IACnF,CAAC;IAED,WAAW;QACT,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,mBAAmB,CAAC,CAAC;IACtD,CAAC;IAED,WAAW,CAAC,OAAe;QACzB,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,kBAAkB,OAAO,EAAE,CAAC,CAAC;IACjE,CAAC;IAED,kBAAkB,CAAC,OAAe;QAChC,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,kBAAkB,OAAO,SAAS,CAAC,CAAC;IACtE,CAAC;IAED,qBAAqB;QACnB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,sBAAsB,CAAC,CAAC;IACzD,CAAC;IAED,mBAAmB;QACjB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,mBAAmB,CAAC,CAAC;IACtD,CAAC;IAED,sBAAsB,CAAC,MAItB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gBAAgB,EAAE,MAAM,CAAC,CAAC;IAC3D,CAAC;IAED,eAAe,CAAC,MAIf;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,eAAe,EAAE,MAAM,CAAC,CAAC;IAC1D,CAAC;IAED,kBAAkB;QAChB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,4BAA4B,CAAC,CAAC;IAC/D,CAAC;IAED,2BAA2B,CAAC,MAI3B;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gCAAgC,EAAE,MAAM,CAAC,CAAC;IAC3E,CAAC;IAED,sBAAsB;QACpB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,2BAA2B,CAAC,CAAC;IAC9D,CAAC;IAED,gCAAgC,CAAC,MAIhC;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,sCAAsC,EAAE,MAAM,CAAC,CAAC;IACjF,CAAC;IAED;;;;;OAKG;IAEH,SAAS;QACP,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gBAAgB,CAAC,CAAC;IACnD,CAAC;IAED,kBAAkB;QAChB,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,0BAA0B,CAAC,CAAC;IAC7D,CAAC;IAED,gBAAgB;QACd,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,kBAAkB,CAAC,CAAC;IACrD,CAAC;IAED,oBAAoB,CAAC,IAAY,EAAE,IAAY;QAC7C,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,0BAA0B,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;IAC9E,CAAC;IAED,oBAAoB,CAAC,gBAAwB;QAC3C,OAAO,IAAI,CAAC,cAAc,CAAC,MAAM,CAAC,4BAA4B,gBAAgB,EAAE,CAAC,CAAC;IACpF,CAAC;IAED,iBAAiB;QACf,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,yBAAyB,CAAC,CAAC;IAC5D,CAAC;IAED,kBAAkB,CAAC,IAAY,EAAE,IAAY;QAC3C,OAAO,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,gBAAgB,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;IACpE,CAAC;IAED,aAAa;QACX,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,8BAA8B,CAAC,CAAC;IACjE,CAAC;IAED,aAAa;QACX,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gBAAgB,CAAC,CAAC;IACnD,CAAC;IAED;;OAEG;IACG,aAAa;;YACjB,MAAM,KAAK,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;YACzB,IAAI;gBACF,MAAM,QAAQ,GAAG,MAAM,IAAI,CAAC,aAAa,EAAE,CAAC;gBAC5C,MAAM,MAAM,GAAG,IAAI,IAAI,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC,OAAO,EAAE,CAAC;gBACnD,MAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;gBAEvB,OAAO,IAAI,CAAC,IAAI,CAAC,MAAM,GAAG,GAAG,GAAG,CAAC,CAAC,GAAG,GAAG,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC;aACtD;YAAC,OAAO,CAAC,EAAE;gBACV,OAAO,CAAC,CAAC;aACV;QACH,CAAC;KAAA;CACF;AApqBD,gCAoqBC;AAAA,CAAC"}

lib/shared-endpoints.d.ts

 import { GenericAPIResponse } from './util/requestUtils';
 import RequestWrapper from './util/requestWrapper';
-export default class SharedEndpoints {
+export default abstract class SharedEndpoints {
     protected requestWrapper: RequestWrapper;
@@ -5,0 +5,0 @@ /**

lib/shared-endpoints.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"shared-endpoints.js","sourceRoot":"","sources":["../src/shared-endpoints.ts"],"names":[],"mappings":";;AAGA,MAAqB,eAAe;IAIlC;;;;OAIG;IAEH,YAAY,CAAC,MAEZ;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,wBAAwB,EAAE,MAAM,CAAC,CAAC;IACnE,CAAC;IAED;;OAEG;IACH,UAAU,CAAC,MAEV;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,mBAAmB,EAAE,MAAM,CAAC,CAAC;IAC9D,CAAC;IAED,UAAU;QACR,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,mBAAmB,CAAC,CAAC;IACtD,CAAC;IAED;;OAEG;IACH,eAAe,CAAC,MAMf;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,uBAAuB,EAAE,MAAM,CAAC,CAAC;IAClE,CAAC;IAED;;;;OAIG;IAEH,eAAe,CAAC,MAIf;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,yBAAyB,EAAE,MAAM,CAAC,CAAC;IACpE,CAAC;IAED,gBAAgB,CAAC,MAGhB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,oBAAoB,EAAE,MAAM,CAAC,CAAC;IAC/D,CAAC;IAED,iBAAiB,CAAC,MAIjB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,yBAAyB,EAAE,MAAM,CAAC,CAAC;IACpE,CAAC;IAED;;;;OAIG;IAEH,aAAa;QACX,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,4BAA4B,CAAC,CAAC;IAC/D,CAAC;IAED;;;;OAIG;IAEH,gBAAgB,CAAC,MAEhB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,2BAA2B,EAAE,MAAM,CAAC,CAAA;IACrE,CAAC;IAED,oBAAoB,CAAC,MAQpB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gCAAgC,EAAE,MAAM,CAAC,CAAC;IAC3E,CAAC;IAED,kBAAkB,CAAC,MAOlB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,iCAAiC,EAAE,MAAM,CAAC,CAAC;IAC5E,CAAC;IAED,uBAAuB,CAAC,MAIvB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gCAAgC,EAAE,MAAM,CAAC,CAAC;IAC3E,CAAC;CAQF;AAlID,kCAkIC"}
+{"version":3,"file":"shared-endpoints.js","sourceRoot":"","sources":["../src/shared-endpoints.ts"],"names":[],"mappings":";;AAGA,MAA8B,eAAe;IAG3C;;;;OAIG;IAEH,YAAY,CAAC,MAEZ;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,wBAAwB,EAAE,MAAM,CAAC,CAAC;IACnE,CAAC;IAED;;OAEG;IACH,UAAU,CAAC,MAEV;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,mBAAmB,EAAE,MAAM,CAAC,CAAC;IAC9D,CAAC;IAED,UAAU;QACR,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,mBAAmB,CAAC,CAAC;IACtD,CAAC;IAED;;OAEG;IACH,eAAe,CAAC,MAMf;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,uBAAuB,EAAE,MAAM,CAAC,CAAC;IAClE,CAAC;IAED;;;;OAIG;IAEH,eAAe,CAAC,MAIf;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,yBAAyB,EAAE,MAAM,CAAC,CAAC;IACpE,CAAC;IAED,gBAAgB,CAAC,MAGhB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,oBAAoB,EAAE,MAAM,CAAC,CAAC;IAC/D,CAAC;IAED,iBAAiB,CAAC,MAIjB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,yBAAyB,EAAE,MAAM,CAAC,CAAC;IACpE,CAAC;IAED;;;;OAIG;IAEH,aAAa;QACX,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,4BAA4B,CAAC,CAAC;IAC/D,CAAC;IAED;;;;OAIG;IAEH,gBAAgB,CAAC,MAEhB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,2BAA2B,EAAE,MAAM,CAAC,CAAA;IACrE,CAAC;IAED,oBAAoB,CAAC,MAQpB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gCAAgC,EAAE,MAAM,CAAC,CAAC;IAC3E,CAAC;IAED,kBAAkB,CAAC,MAOlB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,iCAAiC,EAAE,MAAM,CAAC,CAAC;IAC5E,CAAC;IAED,uBAAuB,CAAC,MAIvB;QACC,OAAO,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,gCAAgC,EAAE,MAAM,CAAC,CAAC;IAC3E,CAAC;CAQF;AAjID,kCAiIC"}

lib/util/requestUtils.d.ts

@@ -10,7 +10,18 @@ export interface RestClientOptions {
 }
+export interface WSClientConfigurableOptions {
+    key?: string;
+    secret?: string;
+    subAccountName?: string;
+    pongTimeout?: number;
+    pingInterval?: number;
+    reconnectTimeout?: number;
+    restOptions?: any;
+    requestOptions?: any;
+    wsUrl?: string;
+}
 export declare type GenericAPIResponse = Promise<any>;
 export declare function signMessage(message: string, secret: string): string;
+export declare function signWsAuthenticate(timestamp: number, secret: string): string;
 export declare function serializeParams(params?: object, strict_validation?: boolean): string;
 export declare function getRestBaseUrl(restClientOptions: RestClientOptions): string;
 export declare function isPublicEndpoint(endpoint: string): boolean;
-export declare function isWsPong(response: any): any;

lib/util/requestUtils.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.isWsPong = exports.isPublicEndpoint = exports.getRestBaseUrl = exports.serializeParams = exports.signMessage = void 0;
+exports.isPublicEndpoint = exports.getRestBaseUrl = exports.serializeParams = exports.signWsAuthenticate = exports.signMessage = void 0;
 const crypto_1 = require("crypto");
+;
 function signMessage(message, secret) {
@@ -12,2 +13,9 @@ return crypto_1.createHmac('sha256', secret)
 ;
+function signWsAuthenticate(timestamp, secret) {
+    return crypto_1.createHmac('sha256', secret)
+        .update(timestamp + 'websocket_login')
+        .digest('hex');
+}
+exports.signWsAuthenticate = signWsAuthenticate;
+;
 function serializeParams(params = {}, strict_validation = false) {
@@ -34,2 +42,3 @@ return Object.keys(params)
 exports.getRestBaseUrl = getRestBaseUrl;
+;
 function isPublicEndpoint(endpoint) {
@@ -48,9 +57,3 @@ if (endpoint.startsWith('https')) {
 exports.isPublicEndpoint = isPublicEndpoint;
-function isWsPong(response) {
-    return (response.request &&
-        response.request.op === 'ping' &&
-        response.ret_msg === 'pong' &&
-        response.success === true);
-}
-exports.isWsPong = isWsPong;
+;
 //# sourceMappingURL=requestUtils.js.map

lib/util/requestUtils.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"requestUtils.js","sourceRoot":"","sources":["../../src/util/requestUtils.ts"],"names":[],"mappings":";;;AAAA,mCAAoC;AA4BpC,SAAgB,WAAW,CAAC,OAAe,EAAE,MAAc;IACzD,OAAO,mBAAU,CAAC,QAAQ,EAAE,MAAM,CAAC;SAChC,MAAM,CAAC,OAAO,CAAC;SACf,MAAM,CAAC,KAAK,CAAC,CAAC;AACnB,CAAC;AAJD,kCAIC;AAAA,CAAC;AAEF,SAAgB,eAAe,CAAC,SAAiB,EAAE,EAAE,iBAAiB,GAAG,KAAK;IAC5E,OAAO,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC;SACvB,IAAI,EAAE;SACN,GAAG,CAAC,GAAG,CAAC,EAAE;QACT,MAAM,KAAK,GAAG,MAAM,CAAC,GAAG,CAAC,CAAC;QAC1B,IAAI,iBAAiB,KAAK,IAAI,IAAI,OAAO,KAAK,KAAK,WAAW,EAAE;YAC9D,MAAM,IAAI,KAAK,CAAC,uDAAuD,CAAC,CAAC;SAC1E;QACD,OAAO,GAAG,GAAG,IAAI,KAAK,EAAE,CAAC;IAC3B,CAAC,CAAC;SACD,IAAI,CAAC,GAAG,CAAC,CAAC;AACf,CAAC;AAXD,0CAWC;AAAA,CAAC;AAEF,SAAgB,cAAc,CAAC,iBAAoC;IACjE,IAAI,iBAAiB,CAAC,OAAO,EAAE;QAC7B,OAAO,iBAAiB,CAAC,OAAO,CAAC;KAClC;IAED,OAAO,qBAAqB,CAAC;AAC/B,CAAC;AAND,wCAMC;AAED,SAAgB,gBAAgB,CAAE,QAAgB;IAChD,IAAI,QAAQ,CAAC,UAAU,CAAC,OAAO,CAAC,EAAE;QAChC,OAAO,IAAI,CAAC;KACb;IACD,IAAI,QAAQ,CAAC,UAAU,CAAC,WAAW,CAAC,EAAE;QACpC,OAAO,IAAI,CAAC;KACb;IACD,IAAI,QAAQ,CAAC,UAAU,CAAC,eAAe,CAAC,EAAE;QACxC,OAAO,IAAI,CAAC;KACb;IACD,OAAO,KAAK,CAAC;AACf,CAAC;AAXD,4CAWC;AAED,SAAgB,QAAQ,CAAC,QAAa;IACpC,OAAO,CACL,QAAQ,CAAC,OAAO;QAChB,QAAQ,CAAC,OAAO,CAAC,EAAE,KAAK,MAAM;QAC9B,QAAQ,CAAC,OAAO,KAAK,MAAM;QAC3B,QAAQ,CAAC,OAAO,KAAK,IAAI,CAC1B,CAAC;AACJ,CAAC;AAPD,4BAOC"}
+{"version":3,"file":"requestUtils.js","sourceRoot":"","sources":["../../src/util/requestUtils.ts"],"names":[],"mappings":";;;AAAA,mCAAoC;AAyCnC,CAAC;AAIF,SAAgB,WAAW,CAAC,OAAe,EAAE,MAAc;IACzD,OAAO,mBAAU,CAAC,QAAQ,EAAE,MAAM,CAAC;SAChC,MAAM,CAAC,OAAO,CAAC;SACf,MAAM,CAAC,KAAK,CAAC,CAAC;AACnB,CAAC;AAJD,kCAIC;AAAA,CAAC;AAEF,SAAgB,kBAAkB,CAAC,SAAiB,EAAE,MAAc;IAClE,OAAO,mBAAU,CAAC,QAAQ,EAAE,MAAM,CAAC;SAClC,MAAM,CAAC,SAAS,GAAG,iBAAiB,CAAC;SACrC,MAAM,CAAC,KAAK,CAAC,CAAC;AACjB,CAAC;AAJD,gDAIC;AAAA,CAAC;AAEF,SAAgB,eAAe,CAAC,SAAiB,EAAE,EAAE,iBAAiB,GAAG,KAAK;IAC5E,OAAO,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC;SACvB,IAAI,EAAE;SACN,GAAG,CAAC,GAAG,CAAC,EAAE;QACT,MAAM,KAAK,GAAG,MAAM,CAAC,GAAG,CAAC,CAAC;QAC1B,IAAI,iBAAiB,KAAK,IAAI,IAAI,OAAO,KAAK,KAAK,WAAW,EAAE;YAC9D,MAAM,IAAI,KAAK,CAAC,uDAAuD,CAAC,CAAC;SAC1E;QACD,OAAO,GAAG,GAAG,IAAI,KAAK,EAAE,CAAC;IAC3B,CAAC,CAAC;SACD,IAAI,CAAC,GAAG,CAAC,CAAC;AACf,CAAC;AAXD,0CAWC;AAAA,CAAC;AAEF,SAAgB,cAAc,CAAC,iBAAoC;IACjE,IAAI,iBAAiB,CAAC,OAAO,EAAE;QAC7B,OAAO,iBAAiB,CAAC,OAAO,CAAC;KAClC;IAED,OAAO,qBAAqB,CAAC;AAC/B,CAAC;AAND,wCAMC;AAAA,CAAC;AAEF,SAAgB,gBAAgB,CAAE,QAAgB;IAChD,IAAI,QAAQ,CAAC,UAAU,CAAC,OAAO,CAAC,EAAE;QAChC,OAAO,IAAI,CAAC;KACb;IACD,IAAI,QAAQ,CAAC,UAAU,CAAC,WAAW,CAAC,EAAE;QACpC,OAAO,IAAI,CAAC;KACb;IACD,IAAI,QAAQ,CAAC,UAAU,CAAC,eAAe,CAAC,EAAE;QACxC,OAAO,IAAI,CAAC;KACb;IACD,OAAO,KAAK,CAAC;AACf,CAAC;AAXD,4CAWC;AAAA,CAAC"}

lib/util/requestWrapper.js

@@ -29,3 +29,5 @@ "use strict";
             // in ms == 5 minutes by default
-            timeout: 1000 * 60 * 5 }, requestOptions), { headers: {
+            timeout: 1000 * 60 * 5 }, requestOptions), { 
+            // FTX requirements
+            headers: {
                 'FTX-KEY': key,
@@ -32,0 +34,0 @@ } });

lib/util/requestWrapper.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"requestWrapper.js","sourceRoot":"","sources":["../../src/util/requestWrapper.ts"],"names":[],"mappings":";;;;;;;;;;;;;;AAAA,kDAAyE;AAEzE,iDAAuH;AAEvH,MAAqB,WAAW;IAU9B,YACE,GAAuB,EACvB,MAA0B,EAC1B,OAAe,EACf,UAA6B,EAAE,EAC/B,iBAAqC,EAAE;QAEvC,IAAI,CAAC,UAAU,GAAG,IAAI,CAAC;QACvB,IAAI,CAAC,eAAe,GAAG,IAAI,CAAC;QAE5B,IAAI,CAAC,SAAS,GAAG,YAAY,CAAC;QAC9B,IAAI,CAAC,OAAO,mBACV,WAAW,EAAE,IAAI;YACjB,qDAAqD;YACrD,gBAAgB,EAAE,OAAO;YACzB,0DAA0D;YAC1D,uBAAuB,EAAE,KAAK,IAC3B,OAAO,CACX,CAAC;QAEF,IAAI,CAAC,oBAAoB;YACvB,gCAAgC;YAChC,OAAO,EAAE,IAAI,GAAG,EAAE,GAAG,CAAC,IAEnB,cAAc,KACjB,OAAO,EAAE;gBACP,SAAS,EAAE,GAAG;aACf,GACF,CAAC;QAEF,IAAI,OAAO,IAAI,CAAC,OAAO,CAAC,cAAc,KAAK,QAAQ,EAAE;YACnD,IAAI,CAAC,oBAAoB,CAAC,OAAO,CAAC,gBAAgB,CAAC,GAAG,IAAI,CAAC,OAAO,CAAC,cAAc,CAAC;SACnF;QAED,IAAI,CAAC,OAAO,GAAG,OAAO,CAAC;QAEvB,IAAI,GAAG,IAAI,CAAC,MAAM,EAAE;YAClB,MAAM,IAAI,KAAK,CAAC,yDAAyD,CAAC,CAAA;SAC3E;QAED,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,KAAK,IAAI,EAAE;YAC3C,IAAI,CAAC,QAAQ,EAAE,CAAC;YAChB,WAAW,CAAC,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,gBAAiB,CAAC,CAAC;SACxE;QAED,IAAI,CAAC,GAAG,GAAG,GAAG,CAAC;QACf,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC;IACvB,CAAC;IAED,GAAG,CAAC,QAAgB,EAAE,MAAY;QAChC,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,QAAQ,EAAE,MAAM,CAAC,CAAC;IAC7C,CAAC;IAED,IAAI,CAAC,QAAgB,EAAE,MAAY;QACjC,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,QAAQ,kCAAO,MAAM,KAAE,uBAAuB,EAAE,IAAI,CAAC,SAAS,IAAG,CAAC;IAC9F,CAAC;IAED,MAAM,CAAC,QAAgB,EAAE,MAAY;QACnC,OAAO,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,QAAQ,EAAE,MAAM,CAAC,CAAC;IAChD,CAAC;IAED;;OAEG;IACG,KAAK,CAAC,MAAc,EAAE,QAAgB,EAAE,MAAwB;;YACpE,MAAM,OAAO,mCACR,IAAI,CAAC,oBAAoB,KAC5B,MAAM,EAAE,MAAM,EACd,IAAI,EAAE,IAAI,GACX,CAAC;YAEF,OAAO,CAAC,GAAG,GAAG,QAAQ,CAAC,UAAU,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;YAE3F,mBAAmB;YACnB,IAAI,IAAI,CAAC,GAAG,IAAI,IAAI,CAAC,MAAM,EAAE;gBAC3B,IAAI,IAAI,CAAC,UAAU,KAAK,IAAI,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,iBAAiB,EAAE;oBAC/D,MAAM,IAAI,CAAC,QAAQ,EAAE,CAAC;iBACvB;gBAED,MAAM,EAAE,SAAS,EAAE,IAAI,EAAE,GAAG,IAAI,CAAC,mBAAmB,CAAC,MAAM,EAAE,QAAQ,EAAE,IAAI,CAAC,MAAM,EAAE,MAAM,CAAC,CAAC;gBAC5F,OAAO,CAAC,OAAO,CAAC,QAAQ,CAAC,GAAG,MAAM,CAAC,SAAS,CAAC,CAAC;gBAC9C,OAAO,CAAC,OAAO,CAAC,UAAU,CAAC,GAAG,IAAI,CAAC;aACpC;YAED,IAAI,MAAM,KAAK,KAAK,EAAE;gBACpB,OAAO,CAAC,MAAM,GAAG,MAAM,CAAC;aACzB;iBAAM;gBACL,OAAO,CAAC,IAAI,GAAG,MAAM,CAAC;aACvB;YAED,OAAO,eAAK,CAAC,OAAO,CAAC,CAAC,IAAI,CAAC,QAAQ,CAAC,EAAE;gBACpC,IAAI,QAAQ,CAAC,MAAM,IAAI,GAAG,EAAE;oBAC1B,OAAO,QAAQ,CAAC,IAAI,CAAC;iBACtB;gBAED,MAAM,QAAQ,CAAC;YACjB,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,cAAc,CAAC,CAAC,CAAC,CAAC,CAAC;QACxC,CAAC;KAAA;IAED;;OAEG;IACH,cAAc,CAAC,CAAM;QACnB,IAAI,IAAI,CAAC,OAAO,CAAC,gBAAgB,KAAK,KAAK,EAAE;YAC3C,MAAM,CAAC,CAAC;SACT;QAED,uEAAuE;QACvE,IAAI,CAAC,CAAC,CAAC,QAAQ,EAAE;YACf,IAAI,CAAC,CAAC,CAAC,OAAO,EAAE;gBACd,MAAM,CAAC,CAAC,OAAO,CAAC;aACjB;YAED,wCAAwC;YACxC,MAAM,CAAC,CAAC;SACT;QAED,mEAAmE;QACnE,qCAAqC;QACrC,MAAM,QAAQ,GAAkB,CAAC,CAAC,QAAQ,CAAC;QAC3C,MAAM;YACJ,IAAI,EAAE,QAAQ,CAAC,MAAM;YACrB,OAAO,EAAE,QAAQ,CAAC,UAAU;YAC5B,IAAI,EAAE,QAAQ,CAAC,IAAI;YACnB,OAAO,EAAE,QAAQ,CAAC,OAAO;YACzB,cAAc,EAAE,IAAI,CAAC,OAAO;SAC7B,CAAC;IACJ,CAAC;IAED,mBAAmB,CACjB,MAAc,EACd,QAAgB,EAChB,MAA0B,EAC1B,SAA0B,EAAE;QAE5B,MAAM,SAAS,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,CAAC,IAAI,CAAC,UAAU,IAAI,CAAC,CAAC,CAAC;QACtD,IAAI,CAAC,MAAM,EAAE;YACX,OAAO;gBACL,SAAS;gBACT,IAAI,EAAE,EAAE;aACT,CAAC;SACH;QAED,MAAM,aAAa,GAAG,MAAM,IAAI,KAAK,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC;QACxE,MAAM,iBAAiB,GAAG,GAAG,SAAS,GAAG,MAAM,QAAQ,QAAQ,GAAG,aAAa,EAAE,CAAC;QAClF,OAAO;YACL,SAAS;YACT,IAAI,EAAE,0BAAW,CAAC,iBAAiB,EAAE,MAAM,CAAC;SAC7C,CAAC;IACJ,CAAC;IAED;;OAEG;IACH,WAAW,CAAC,IAAS;QACnB,MAAM,MAAM,mCACP,IAAI,KACP,OAAO,EAAE,IAAI,CAAC,GAAG,EACjB,SAAS,EAAE,IAAI,CAAC,GAAG,EAAE,GAAG,CAAC,IAAI,CAAC,UAAU,IAAI,CAAC,CAAC,GAC/C,CAAC;QAEF,uFAAuF;QACvF,IAAI,IAAI,CAAC,OAAO,CAAC,WAAW,IAAI,CAAC,MAAM,CAAC,WAAW,EAAE;YACnD,MAAM,CAAC,WAAW,GAAG,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC;SAC/C;QAED,IAAI,IAAI,CAAC,GAAG,IAAI,IAAI,CAAC,MAAM,EAAE;YAC3B,MAAM,gBAAgB,GAAG,8BAAe,CAAC,MAAM,EAAE,IAAI,CAAC,OAAO,CAAC,uBAAuB,CAAC,CAAC;YACvF,MAAM,CAAC,IAAI,GAAG,0BAAW,CAAC,gBAAgB,EAAE,IAAI,CAAC,MAAM,CAAC,CAAC;SAC1D;QAED,OAAO,MAAM,CAAC;IAChB,CAAC;IAED;;OAEG;IACH,QAAQ;QACN,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,KAAK,IAAI,EAAE;YAC3C,OAAO,OAAO,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;SAC/B;QAED,IAAI,IAAI,CAAC,eAAe,KAAK,IAAI,EAAE;YACjC,OAAO,IAAI,CAAC,eAAe,CAAC;SAC7B;QAED,IAAI,CAAC,eAAe,GAAG,IAAI,CAAC,aAAa,EAAE,CAAC,IAAI,CAAC,MAAM,CAAC,EAAE;YACxD,IAAI,CAAC,UAAU,GAAG,MAAM,CAAC;YACzB,IAAI,CAAC,eAAe,GAAG,IAAI,CAAC;QAC9B,CAAC,CAAC,CAAC;QAEH,OAAO,IAAI,CAAC,eAAe,CAAC;IAC9B,CAAC;IAED;;OAEG;IACG,aAAa;;YACjB,MAAM,KAAK,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;YACzB,IAAI;gBACF,MAAM,QAAQ,GAAG,MAAM,IAAI,CAAC,GAAG,CAAC,8BAA8B,CAAC,CAAC;gBAChE,MAAM,MAAM,GAAG,IAAI,IAAI,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC,OAAO,EAAE,CAAC;gBACnD,MAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;gBAEvB,OAAO,IAAI,CAAC,IAAI,CAAC,MAAM,GAAG,GAAG,GAAG,CAAC,CAAC,GAAG,GAAG,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC;aACtD;YAAC,OAAO,CAAC,EAAE;gBACV,OAAO,CAAC,CAAC;aACV;QACH,CAAC;KAAA;CAEF;AA5ND,8BA4NC;AAAA,CAAC"}
+{"version":3,"file":"requestWrapper.js","sourceRoot":"","sources":["../../src/util/requestWrapper.ts"],"names":[],"mappings":";;;;;;;;;;;;;;AAAA,kDAAyE;AAEzE,iDAAuH;AAEvH,MAAqB,WAAW;IAU9B,YACE,GAAuB,EACvB,MAA0B,EAC1B,OAAe,EACf,UAA6B,EAAE,EAC/B,iBAAqC,EAAE;QAEvC,IAAI,CAAC,UAAU,GAAG,IAAI,CAAC;QACvB,IAAI,CAAC,eAAe,GAAG,IAAI,CAAC;QAC5B,IAAI,CAAC,SAAS,GAAG,YAAY,CAAC;QAC9B,IAAI,CAAC,OAAO,mBACV,WAAW,EAAE,IAAI;YACjB,qDAAqD;YACrD,gBAAgB,EAAE,OAAO;YACzB,0DAA0D;YAC1D,uBAAuB,EAAE,KAAK,IAC3B,OAAO,CACX,CAAC;QAEF,IAAI,CAAC,oBAAoB;YACvB,gCAAgC;YAChC,OAAO,EAAE,IAAI,GAAG,EAAE,GAAG,CAAC,IAEnB,cAAc;YACjB,mBAAmB;YACnB,OAAO,EAAE;gBACP,SAAS,EAAE,GAAG;aACf,GACF,CAAC;QAEF,IAAI,OAAO,IAAI,CAAC,OAAO,CAAC,cAAc,KAAK,QAAQ,EAAE;YACnD,IAAI,CAAC,oBAAoB,CAAC,OAAO,CAAC,gBAAgB,CAAC,GAAG,IAAI,CAAC,OAAO,CAAC,cAAc,CAAC;SACnF;QAED,IAAI,CAAC,OAAO,GAAG,OAAO,CAAC;QAEvB,IAAI,GAAG,IAAI,CAAC,MAAM,EAAE;YAClB,MAAM,IAAI,KAAK,CAAC,yDAAyD,CAAC,CAAA;SAC3E;QAED,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,KAAK,IAAI,EAAE;YAC3C,IAAI,CAAC,QAAQ,EAAE,CAAC;YAChB,WAAW,CAAC,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,gBAAiB,CAAC,CAAC;SACxE;QAED,IAAI,CAAC,GAAG,GAAG,GAAG,CAAC;QACf,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC;IACvB,CAAC;IAED,GAAG,CAAC,QAAgB,EAAE,MAAY;QAChC,OAAO,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,QAAQ,EAAE,MAAM,CAAC,CAAC;IAC7C,CAAC;IAED,IAAI,CAAC,QAAgB,EAAE,MAAY;QACjC,OAAO,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,QAAQ,kCAAO,MAAM,KAAE,uBAAuB,EAAE,IAAI,CAAC,SAAS,IAAG,CAAC;IAC9F,CAAC;IAED,MAAM,CAAC,QAAgB,EAAE,MAAY;QACnC,OAAO,IAAI,CAAC,KAAK,CAAC,QAAQ,EAAE,QAAQ,EAAE,MAAM,CAAC,CAAC;IAChD,CAAC;IAED;;OAEG;IACG,KAAK,CAAC,MAAc,EAAE,QAAgB,EAAE,MAAwB;;YACpE,MAAM,OAAO,mCACR,IAAI,CAAC,oBAAoB,KAC5B,MAAM,EAAE,MAAM,EACd,IAAI,EAAE,IAAI,GACX,CAAC;YAEF,OAAO,CAAC,GAAG,GAAG,QAAQ,CAAC,UAAU,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;YAE3F,mBAAmB;YACnB,IAAI,IAAI,CAAC,GAAG,IAAI,IAAI,CAAC,MAAM,EAAE;gBAC3B,IAAI,IAAI,CAAC,UAAU,KAAK,IAAI,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,iBAAiB,EAAE;oBAC/D,MAAM,IAAI,CAAC,QAAQ,EAAE,CAAC;iBACvB;gBAED,MAAM,EAAE,SAAS,EAAE,IAAI,EAAE,GAAG,IAAI,CAAC,mBAAmB,CAAC,MAAM,EAAE,QAAQ,EAAE,IAAI,CAAC,MAAM,EAAE,MAAM,CAAC,CAAC;gBAC5F,OAAO,CAAC,OAAO,CAAC,QAAQ,CAAC,GAAG,MAAM,CAAC,SAAS,CAAC,CAAC;gBAC9C,OAAO,CAAC,OAAO,CAAC,UAAU,CAAC,GAAG,IAAI,CAAC;aACpC;YAED,IAAI,MAAM,KAAK,KAAK,EAAE;gBACpB,OAAO,CAAC,MAAM,GAAG,MAAM,CAAC;aACzB;iBAAM;gBACL,OAAO,CAAC,IAAI,GAAG,MAAM,CAAC;aACvB;YAED,OAAO,eAAK,CAAC,OAAO,CAAC,CAAC,IAAI,CAAC,QAAQ,CAAC,EAAE;gBACpC,IAAI,QAAQ,CAAC,MAAM,IAAI,GAAG,EAAE;oBAC1B,OAAO,QAAQ,CAAC,IAAI,CAAC;iBACtB;gBAED,MAAM,QAAQ,CAAC;YACjB,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,cAAc,CAAC,CAAC,CAAC,CAAC,CAAC;QACxC,CAAC;KAAA;IAED;;OAEG;IACH,cAAc,CAAC,CAAM;QACnB,IAAI,IAAI,CAAC,OAAO,CAAC,gBAAgB,KAAK,KAAK,EAAE;YAC3C,MAAM,CAAC,CAAC;SACT;QAED,uEAAuE;QACvE,IAAI,CAAC,CAAC,CAAC,QAAQ,EAAE;YACf,IAAI,CAAC,CAAC,CAAC,OAAO,EAAE;gBACd,MAAM,CAAC,CAAC,OAAO,CAAC;aACjB;YAED,wCAAwC;YACxC,MAAM,CAAC,CAAC;SACT;QAED,mEAAmE;QACnE,qCAAqC;QACrC,MAAM,QAAQ,GAAkB,CAAC,CAAC,QAAQ,CAAC;QAC3C,MAAM;YACJ,IAAI,EAAE,QAAQ,CAAC,MAAM;YACrB,OAAO,EAAE,QAAQ,CAAC,UAAU;YAC5B,IAAI,EAAE,QAAQ,CAAC,IAAI;YACnB,OAAO,EAAE,QAAQ,CAAC,OAAO;YACzB,cAAc,EAAE,IAAI,CAAC,OAAO;SAC7B,CAAC;IACJ,CAAC;IAED,mBAAmB,CACjB,MAAc,EACd,QAAgB,EAChB,MAA0B,EAC1B,SAA0B,EAAE;QAE5B,MAAM,SAAS,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,CAAC,IAAI,CAAC,UAAU,IAAI,CAAC,CAAC,CAAC;QACtD,IAAI,CAAC,MAAM,EAAE;YACX,OAAO;gBACL,SAAS;gBACT,IAAI,EAAE,EAAE;aACT,CAAC;SACH;QAED,MAAM,aAAa,GAAG,MAAM,IAAI,KAAK,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC;QACxE,MAAM,iBAAiB,GAAG,GAAG,SAAS,GAAG,MAAM,QAAQ,QAAQ,GAAG,aAAa,EAAE,CAAC;QAClF,OAAO;YACL,SAAS;YACT,IAAI,EAAE,0BAAW,CAAC,iBAAiB,EAAE,MAAM,CAAC;SAC7C,CAAC;IACJ,CAAC;IAED;;OAEG;IACH,WAAW,CAAC,IAAS;QACnB,MAAM,MAAM,mCACP,IAAI,KACP,OAAO,EAAE,IAAI,CAAC,GAAG,EACjB,SAAS,EAAE,IAAI,CAAC,GAAG,EAAE,GAAG,CAAC,IAAI,CAAC,UAAU,IAAI,CAAC,CAAC,GAC/C,CAAC;QAEF,uFAAuF;QACvF,IAAI,IAAI,CAAC,OAAO,CAAC,WAAW,IAAI,CAAC,MAAM,CAAC,WAAW,EAAE;YACnD,MAAM,CAAC,WAAW,GAAG,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC;SAC/C;QAED,IAAI,IAAI,CAAC,GAAG,IAAI,IAAI,CAAC,MAAM,EAAE;YAC3B,MAAM,gBAAgB,GAAG,8BAAe,CAAC,MAAM,EAAE,IAAI,CAAC,OAAO,CAAC,uBAAuB,CAAC,CAAC;YACvF,MAAM,CAAC,IAAI,GAAG,0BAAW,CAAC,gBAAgB,EAAE,IAAI,CAAC,MAAM,CAAC,CAAC;SAC1D;QAED,OAAO,MAAM,CAAC;IAChB,CAAC;IAED;;OAEG;IACH,QAAQ;QACN,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,KAAK,IAAI,EAAE;YAC3C,OAAO,OAAO,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;SAC/B;QAED,IAAI,IAAI,CAAC,eAAe,KAAK,IAAI,EAAE;YACjC,OAAO,IAAI,CAAC,eAAe,CAAC;SAC7B;QAED,IAAI,CAAC,eAAe,GAAG,IAAI,CAAC,aAAa,EAAE,CAAC,IAAI,CAAC,MAAM,CAAC,EAAE;YACxD,IAAI,CAAC,UAAU,GAAG,MAAM,CAAC;YACzB,IAAI,CAAC,eAAe,GAAG,IAAI,CAAC;QAC9B,CAAC,CAAC,CAAC;QAEH,OAAO,IAAI,CAAC,eAAe,CAAC;IAC9B,CAAC;IAED;;OAEG;IACG,aAAa;;YACjB,MAAM,KAAK,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;YACzB,IAAI;gBACF,MAAM,QAAQ,GAAG,MAAM,IAAI,CAAC,GAAG,CAAC,8BAA8B,CAAC,CAAC;gBAChE,MAAM,MAAM,GAAG,IAAI,IAAI,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC,OAAO,EAAE,CAAC;gBACnD,MAAM,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAC;gBAEvB,OAAO,IAAI,CAAC,IAAI,CAAC,MAAM,GAAG,GAAG,GAAG,CAAC,CAAC,GAAG,GAAG,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC;aACtD;YAAC,OAAO,CAAC,EAAE;gBACV,OAAO,CAAC,CAAC;aACV;QACH,CAAC;KAAA;CACF;AA3ND,8BA2NC;AAAA,CAAC"}

lib/util/WsStore.d.ts

 /// <reference types="node" />
-import { WsConnectionState } from '../websocket-client';
+import { WsConnectionState, WsTopic } from '../websocket-client';
 import { DefaultLogger } from '../logger';
 import WebSocket from 'isomorphic-ws';
-declare type WsTopicList = Set<string>;
+declare type WsTopicList = Set<WsTopic>;
 declare type KeyedWsTopicLists = {
@@ -33,5 +33,5 @@ [key: string]: WsTopicList;
     getTopicsByKey(): KeyedWsTopicLists;
-    addTopic(key: string, topic: string): WsTopicList;
-    deleteTopic(key: string, topic: string): boolean;
+    addTopic(key: string, topic: WsTopic | string): any;
+    deleteTopic(key: string, topic: WsTopic | string): any;
 }
 export {};

lib/util/WsStore.js

@@ -82,5 +82,11 @@ "use strict";
     addTopic(key, topic) {
+        if (typeof topic === 'string') {
+            return this.addTopic(key, { channel: topic });
+        }
         return this.getTopics(key).add(topic);
     }
     deleteTopic(key, topic) {
+        if (typeof topic === 'string') {
+            return this.addTopic(key, { channel: topic });
+        }
         return this.getTopics(key).delete(topic);
@@ -87,0 +93,0 @@ }

lib/util/WsStore.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"WsStore.js","sourceRoot":"","sources":["../../src/util/WsStore.ts"],"names":[],"mappings":";;AAAA,0DAAwD;AACxD,sCAA0C;AAezC,CAAC;AAEF,MAAqB,OAAO;IAM1B,YAAY,MAA4B;QACtC,IAAI,CAAC,MAAM,GAAG,MAAM,IAAI,sBAAa,CAAC;QACtC,IAAI,CAAC,OAAO,GAAG,EAAE,CAAC;IACpB,CAAC;IAED,GAAG,CAAC,GAAW,EAAE,eAAyB;QACxC,IAAI,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE;YACrB,OAAO,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;SAC1B;QAED,IAAI,eAAe,EAAE;YACnB,OAAO,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;SACzB;QAED,OAAO,SAAS,CAAC;IACnB,CAAC;IAED,OAAO;QACL,OAAO,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;IACnC,CAAC;IAED,MAAM,CAAC,GAAW;QAChB,IAAI,IAAI,CAAC,2BAA2B,CAAC,GAAG,CAAC,EAAE;YACzC,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,gEAAgE,EAAE,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC;SACxG;QACD,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,GAAG;YAClB,gBAAgB,EAAE,IAAI,GAAG,EAAE;YAC3B,eAAe,EAAE,oCAAiB,CAAC,mBAAmB;SACvD,CAAC;QACF,OAAO,IAAI,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;IACvB,CAAC;IAED,MAAM,CAAC,GAAW;QAChB,IAAI,IAAI,CAAC,2BAA2B,CAAC,GAAG,CAAC,EAAE;YACzC,MAAM,EAAE,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;YAC3B,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,oDAAoD,EAAE,EAAE,CAAC,CAAC;YAC9E,EAAE,aAAF,EAAE,uBAAF,EAAE,CAAE,KAAK,GAAG;SACb;QACD,OAAO,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;IAC3B,CAAC;IAED,0BAA0B;IAE1B,2BAA2B,CAAC,GAAG;QAC7B,OAAO,IAAI,CAAC,GAAG,CAAC,GAAG,CAAC,IAAI,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,CAAC;IAC7C,CAAC;IAED,KAAK,CAAC,GAAW;;QACf,aAAO,IAAI,CAAC,GAAG,CAAC,GAAG,CAAC,0CAAE,EAAE,CAAC;IAC3B,CAAC;IAED,KAAK,CAAC,GAAW,EAAE,YAAuB;QACxC,IAAI,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAE;YACtB,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,gEAAgE,EAAE,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC;SACxG;QACD,IAAI,CAAC,GAAG,CAAC,GAAG,EAAE,IAAI,CAAE,CAAC,EAAE,GAAG,YAAY,CAAC;QACvC,OAAO,YAAY,CAAC;IACtB,CAAC;IAED,sBAAsB;IAEtB,QAAQ,CAAC,GAAW;QAClB,MAAM,kBAAkB,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;QAC3C,OAAO,CAAC,CAAC,kBAAkB,IAAI,kBAAkB,CAAC,UAAU,KAAK,kBAAkB,CAAC,IAAI,CAAC;IAC3F,CAAC;IAED,kBAAkB,CAAC,GAAW;QAC5B,OAAO,IAAI,CAAC,GAAG,CAAC,GAAG,EAAE,IAAI,CAAE,CAAC,eAAgB,CAAC;IAC/C,CAAC;IAED,kBAAkB,CAAC,GAAW,EAAE,KAAwB;QACtD,IAAI,CAAC,GAAG,CAAC,GAAG,EAAE,IAAI,CAAE,CAAC,eAAe,GAAG,KAAK,CAAC;IAC/C,CAAC;IAED,iBAAiB,CAAC,GAAW,EAAE,KAAwB;QACrD,OAAO,IAAI,CAAC,kBAAkB,CAAC,GAAG,CAAC,KAAK,KAAK,CAAC;IAChD,CAAC;IAED,uBAAuB;IAEvB,SAAS,CAAC,GAAW;QACnB,OAAO,IAAI,CAAC,GAAG,CAAC,GAAG,EAAE,IAAI,CAAE,CAAC,gBAAgB,CAAC;IAC/C,CAAC;IAED,cAAc;QACZ,MAAM,MAAM,GAAG,EAAE,CAAC;QAClB,KAAK,MAAM,MAAM,IAAI,IAAI,CAAC,OAAO,EAAE;YACjC,MAAM,CAAC,MAAM,CAAC,GAAG,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC;SACzC;QACD,OAAO,MAAM,CAAC;IAChB,CAAC;IAED,QAAQ,CAAC,GAAW,EAAE,KAAa;QACjC,OAAO,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;IACxC,CAAC;IAED,WAAW,CAAC,GAAW,EAAE,KAAa;QACpC,OAAO,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC;IAC3C,CAAC;CACF;AAzGD,0BAyGC"}
+{"version":3,"file":"WsStore.js","sourceRoot":"","sources":["../../src/util/WsStore.ts"],"names":[],"mappings":";;AAAA,0DAAiE;AACjE,sCAA0C;AAezC,CAAC;AAEF,MAAqB,OAAO;IAM1B,YAAY,MAA4B;QACtC,IAAI,CAAC,MAAM,GAAG,MAAM,IAAI,sBAAa,CAAC;QACtC,IAAI,CAAC,OAAO,GAAG,EAAE,CAAC;IACpB,CAAC;IAED,GAAG,CAAC,GAAW,EAAE,eAAyB;QACxC,IAAI,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE;YACrB,OAAO,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;SAC1B;QAED,IAAI,eAAe,EAAE;YACnB,OAAO,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;SACzB;QAED,OAAO,SAAS,CAAC;IACnB,CAAC;IAED,OAAO;QACL,OAAO,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;IACnC,CAAC;IAED,MAAM,CAAC,GAAW;QAChB,IAAI,IAAI,CAAC,2BAA2B,CAAC,GAAG,CAAC,EAAE;YACzC,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,gEAAgE,EAAE,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC;SACxG;QACD,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,GAAG;YAClB,gBAAgB,EAAE,IAAI,GAAG,EAAE;YAC3B,eAAe,EAAE,oCAAiB,CAAC,mBAAmB;SACvD,CAAC;QACF,OAAO,IAAI,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;IACvB,CAAC;IAED,MAAM,CAAC,GAAW;QAChB,IAAI,IAAI,CAAC,2BAA2B,CAAC,GAAG,CAAC,EAAE;YACzC,MAAM,EAAE,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;YAC3B,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,oDAAoD,EAAE,EAAE,CAAC,CAAC;YAC9E,EAAE,aAAF,EAAE,uBAAF,EAAE,CAAE,KAAK,EAAE,CAAC;SACb;QACD,OAAO,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;IAC3B,CAAC;IAED,0BAA0B;IAE1B,2BAA2B,CAAC,GAAG;QAC7B,OAAO,IAAI,CAAC,GAAG,CAAC,GAAG,CAAC,IAAI,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,CAAC;IAC7C,CAAC;IAED,KAAK,CAAC,GAAW;;QACf,OAAO,MAAA,IAAI,CAAC,GAAG,CAAC,GAAG,CAAC,0CAAE,EAAE,CAAC;IAC3B,CAAC;IAED,KAAK,CAAC,GAAW,EAAE,YAAuB;QACxC,IAAI,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAE;YACtB,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,gEAAgE,EAAE,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,CAAC;SACxG;QACD,IAAI,CAAC,GAAG,CAAC,GAAG,EAAE,IAAI,CAAE,CAAC,EAAE,GAAG,YAAY,CAAC;QACvC,OAAO,YAAY,CAAC;IACtB,CAAC;IAED,sBAAsB;IAEtB,QAAQ,CAAC,GAAW;QAClB,MAAM,kBAAkB,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;QAC3C,OAAO,CAAC,CAAC,kBAAkB,IAAI,kBAAkB,CAAC,UAAU,KAAK,kBAAkB,CAAC,IAAI,CAAC;IAC3F,CAAC;IAED,kBAAkB,CAAC,GAAW;QAC5B,OAAO,IAAI,CAAC,GAAG,CAAC,GAAG,EAAE,IAAI,CAAE,CAAC,eAAgB,CAAC;IAC/C,CAAC;IAED,kBAAkB,CAAC,GAAW,EAAE,KAAwB;QACtD,IAAI,CAAC,GAAG,CAAC,GAAG,EAAE,IAAI,CAAE,CAAC,eAAe,GAAG,KAAK,CAAC;IAC/C,CAAC;IAED,iBAAiB,CAAC,GAAW,EAAE,KAAwB;QACrD,OAAO,IAAI,CAAC,kBAAkB,CAAC,GAAG,CAAC,KAAK,KAAK,CAAC;IAChD,CAAC;IAED,uBAAuB;IAEvB,SAAS,CAAC,GAAW;QACnB,OAAO,IAAI,CAAC,GAAG,CAAC,GAAG,EAAE,IAAI,CAAE,CAAC,gBAAgB,CAAC;IAC/C,CAAC;IAED,cAAc;QACZ,MAAM,MAAM,GAAG,EAAE,CAAC;QAClB,KAAK,MAAM,MAAM,IAAI,IAAI,CAAC,OAAO,EAAE;YACjC,MAAM,CAAC,MAAM,CAAC,GAAG,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC;SACzC;QACD,OAAO,MAAM,CAAC;IAChB,CAAC;IAED,QAAQ,CAAC,GAAW,EAAE,KAAuB;QAC3C,IAAI,OAAO,KAAK,KAAK,QAAQ,EAAE;YAC7B,OAAO,IAAI,CAAC,QAAQ,CAAC,GAAG,EAAE,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC;SAC/C;QACD,OAAO,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;IACxC,CAAC;IAED,WAAW,CAAC,GAAW,EAAE,KAAuB;QAC9C,IAAI,OAAO,KAAK,KAAK,QAAQ,EAAE;YAC7B,OAAO,IAAI,CAAC,QAAQ,CAAC,GAAG,EAAE,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC;SAC/C;QACD,OAAO,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC;IAC3C,CAAC;CACF;AA/GD,0BA+GC"}

lib/websocket-client.d.ts

 /// <reference types="node" />
 import { EventEmitter } from 'events';
 import { DefaultLogger } from './logger';
+import { WSClientConfigurableOptions } from './util/requestUtils';
 import WebSocket from 'isomorphic-ws';
@@ -12,17 +13,3 @@ export declare enum WsConnectionState {
 }
-export interface WSClientConfigurableOptions {
-    key?: string;
-    secret?: string;
-    livenet?: boolean;
-    linear?: boolean;
-    pongTimeout?: number;
-    pingInterval?: number;
-    reconnectTimeout?: number;
-    restOptions?: any;
-    requestOptions?: any;
-    wsUrl?: string;
-}
 export interface WebsocketClientOptions extends WSClientConfigurableOptions {
-    livenet: boolean;
-    linear: boolean;
     pongTimeout: number;
@@ -32,5 +19,4 @@ pingInterval: number;
 }
-export declare const wsKeyInverse = "inverse";
-export declare const wsKeyLinearPrivate = "linearPrivate";
-export declare const wsKeyLinearPublic = "linearPublic";
+export declare const wsKeyGeneral = "ftx";
+export declare const wsBaseUrl = "wss://ftx.com/ws/";
 export declare interface WebsocketClient {
@@ -44,2 +30,7 @@ on(event: 'open' | 'reconnected', listener: ({ wsKey: string, event: any }: {
 }
+export interface WsTopic {
+    channel: string;
+    grouping?: number;
+    market?: string;
+}
 export declare class WebsocketClient extends EventEmitter {
@@ -52,12 +43,10 @@ private logger;
     isLivenet(): boolean;
-    isLinear(): boolean;
-    isInverse(): boolean;
     /**
      * Add topic/topics to WS subscription list
      */
-    subscribe(wsTopics: string[] | string): void;
+    subscribe(wsTopics: WsTopic[] | WsTopic | string[] | string): void;
     /**
      * Remove topic/topics from WS subscription list
      */
-    unsubscribe(wsTopics: string[] | string): void;
+    unsubscribe(wsTopics: WsTopic[] | WsTopic | string[] | string): void;
     close(wsKey: string): void;
@@ -69,2 +58,3 @@ /**
     private connect;
+    private requestTryAuthenticate;
     private parseWsError;
@@ -71,0 +61,0 @@ /**

lib/websocket-client.js

@@ -15,3 +15,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.WebsocketClient = exports.wsKeyLinearPublic = exports.wsKeyLinearPrivate = exports.wsKeyInverse = exports.WsConnectionState = void 0;
+exports.WebsocketClient = exports.wsBaseUrl = exports.wsKeyGeneral = exports.WsConnectionState = void 0;
 const events_1 = require("events");
@@ -23,19 +23,4 @@ const rest_client_1 = require("./rest-client");
 const WsStore_1 = __importDefault(require("./util/WsStore"));
-const inverseEndpoints = {
-    livenet: 'wss://stream.bybit.com/realtime',
-    testnet: 'wss://stream-testnet.bybit.com/realtime'
-};
-const linearEndpoints = {
-    private: {
-        livenet: 'wss://stream.bybit.com/realtime_private',
-        livenet2: 'wss://stream.bytick.com/realtime_public',
-        testnet: 'wss://stream-testnet.bybit.com/realtime_private'
-    },
-    public: {
-        livenet: 'wss://stream.bybit.com/realtime_public',
-        livenet2: 'wss://stream.bytick.com/realtime_private',
-        testnet: 'wss://stream-testnet.bybit.com/realtime_public'
-    }
-};
-const loggerCategory = { category: 'bybit-ws' };
+const wsMessages_1 = require("./util/wsMessages");
+const loggerCategory = { category: 'ftx-ws' };
 const READY_STATE_INITIAL = 0;
@@ -56,13 +41,6 @@ const READY_STATE_CONNECTING = 1;
 ;
+exports.wsKeyGeneral = 'ftx';
+exports.wsBaseUrl = 'wss://ftx.com/ws/';
 ;
-exports.wsKeyInverse = 'inverse';
-exports.wsKeyLinearPrivate = 'linearPrivate';
-exports.wsKeyLinearPublic = 'linearPublic';
-const getLinearWsKeyForTopic = (topic) => {
-    const privateLinearTopics = ['position', 'execution', 'order', 'stop_order', 'wallet'];
-    if (privateLinearTopics.includes(topic)) {
-        return exports.wsKeyLinearPrivate;
-    }
-    return exports.wsKeyLinearPublic;
-};
+;
 class WebsocketClient extends events_1.EventEmitter {
@@ -73,14 +51,8 @@ constructor(options, logger) {
         this.wsStore = new WsStore_1.default(this.logger);
-        this.options = Object.assign({ livenet: false, linear: false, pongTimeout: 1000, pingInterval: 10000, reconnectTimeout: 500 }, options);
+        this.options = Object.assign({ pongTimeout: 1000, pingInterval: 10000, reconnectTimeout: 500 }, options);
         this.restClient = new rest_client_1.RestClient(undefined, undefined, this.options.restOptions, this.options.requestOptions);
     }
     isLivenet() {
-        return this.options.livenet === true;
+        return true;
     }
-    isLinear() {
-        return this.options.linear === true;
-    }
-    isInverse() {
-        return !this.isLinear();
-    }
     /**
@@ -129,8 +101,3 @@ * Add topic/topics to WS subscription list
     connectAll() {
-        if (this.isInverse()) {
-            return [this.connect(exports.wsKeyInverse)];
-        }
-        if (this.isLinear()) {
-            return [this.connect(exports.wsKeyLinearPublic), this.connect(exports.wsKeyLinearPrivate)];
-        }
+        return [this.connect(exports.wsKeyGeneral)];
     }
@@ -152,4 +119,3 @@ connect(wsKey) {
                 }
-                const authParams = yield this.getAuthParams(wsKey);
-                const url = this.getWsUrl(wsKey) + authParams;
+                const url = this.getWsUrl(wsKey);
                 const ws = this.connectToWsUrl(url, wsKey);
@@ -164,2 +130,12 @@ return this.wsStore.setWs(wsKey, ws);
     }
+    requestTryAuthenticate(wsKey) {
+        const { key, secret } = this.options;
+        if (!key || !secret) {
+            this.logger.debug(`Connection "${wsKey}" will remain unauthenticated due to missing key/secret`);
+            return;
+        }
+        const timestamp = new Date().getTime();
+        const authMsg = wsMessages_1.getWsAuthMessage(key, requestUtils_1.signWsAuthenticate(timestamp, secret), timestamp);
+        this.tryWsSend(wsKey, JSON.stringify(authMsg));
+    }
     parseWsError(context, error, wsKey) {
@@ -185,3 +161,3 @@ if (!error.message) {
             const { key, secret } = this.options;
-            if (key && secret && wsKey !== exports.wsKeyLinearPublic) {
+            if (key && secret) {
                 this.logger.debug('Getting auth\'d request params', Object.assign(Object.assign({}, loggerCategory), { wsKey }));
@@ -194,3 +170,3 @@ const timeOffset = yield this.restClient.getTimeOffset();
                 params.signature = requestUtils_1.signMessage('GET/realtime' + params.expires, secret);
-                return '?' + requestUtils_1.serializeParams(params);
+                return params;
             }
@@ -250,7 +226,7 @@ else if (!key || !secret) {
     requestSubscribeTopics(wsKey, topics) {
-        const wsMessage = JSON.stringify({
-            op: 'subscribe',
-            args: topics
+        const market = '';
+        topics.forEach(topic => {
+            const wsMessage = JSON.stringify(Object.assign({ op: 'subscribe' }, topic));
+            this.tryWsSend(wsKey, wsMessage);
         });
-        this.tryWsSend(wsKey, wsMessage);
     }
@@ -261,7 +237,6 @@ /**
     requestUnsubscribeTopics(wsKey, topics) {
-        const wsMessage = JSON.stringify({
-            op: 'unsubscribe',
-            args: topics
+        topics.forEach(topic => {
+            const wsMessage = JSON.stringify(Object.assign({ op: 'unsubscribe' }, topic));
+            this.tryWsSend(wsKey, wsMessage);
         });
-        this.tryWsSend(wsKey, wsMessage);
     }
@@ -292,3 +267,3 @@ tryWsSend(wsKey, wsMessage) {
         if (this.wsStore.isConnectionState(wsKey, READY_STATE_CONNECTING)) {
-            this.logger.info('Websocket connected', Object.assign(Object.assign({}, loggerCategory), { wsKey, livenet: this.isLivenet(), linear: this.isLinear() }));
+            this.logger.info('Websocket connected', Object.assign(Object.assign({}, loggerCategory), { wsKey, livenet: this.isLivenet() }));
             this.emit('open', { wsKey, event });
@@ -301,2 +276,3 @@ }
         this.setWsState(wsKey, READY_STATE_CONNECTED);
+        this.requestTryAuthenticate(wsKey);
         this.requestSubscribeTopics(wsKey, [...this.wsStore.getTopics(wsKey)]);
@@ -307,10 +283,8 @@ this.wsStore.get(wsKey, true).activePingTimer = setInterval(() => this.ping(wsKey), this.options.pingInterval);
         const msg = JSON.parse(event && event.data || event);
-        if ('success' in msg) {
-            this.onWsMessageResponse(msg, wsKey);
-        }
-        else if (msg.topic) {
+        if (msg.channel) {
             this.onWsMessageUpdate(msg);
         }
         else {
-            this.logger.warning('Got unhandled ws message', Object.assign(Object.assign({}, loggerCategory), { message: msg, event, wsKey }));
+            this.logger.debug('Websocket event: ', event.data || event);
+            this.onWsMessageResponse(msg, wsKey);
         }
@@ -336,3 +310,3 @@ }
     onWsMessageResponse(response, wsKey) {
-        if (requestUtils_1.isWsPong(response)) {
+        if (wsMessages_1.isWsPong(response)) {
             this.logger.silly('Received pong', Object.assign(Object.assign({}, loggerCategory), { wsKey }));
@@ -358,6 +332,6 @@ this.clearPongTimer(wsKey);
         }
-        return 'wss://ftx.com/ws/';
+        return exports.wsBaseUrl;
     }
     getWsKeyForTopic(topic) {
-        return this.isInverse() ? exports.wsKeyInverse : getLinearWsKeyForTopic(topic);
+        return exports.wsKeyGeneral;
     }
@@ -364,0 +338,0 @@ }

lib/websocket-client.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"websocket-client.js","sourceRoot":"","sources":["../src/websocket-client.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;AAAA,mCAAsC;AACtC,+CAA2C;AAC3C,qCAAyC;AACzC,sDAA6E;AAE7E,kEAAsC;AACtC,6DAAqC;AAErC,MAAM,gBAAgB,GAAG;IACvB,OAAO,EAAE,iCAAiC;IAC1C,OAAO,EAAE,yCAAyC;CACnD,CAAC;AAEF,MAAM,eAAe,GAAG;IACtB,OAAO,EAAE;QACP,OAAO,EAAE,yCAAyC;QAClD,QAAQ,EAAE,yCAAyC;QACnD,OAAO,EAAE,iDAAiD;KAC3D;IACD,MAAM,EAAE;QACN,OAAO,EAAE,wCAAwC;QACjD,QAAQ,EAAE,0CAA0C;QACpD,OAAO,EAAE,gDAAgD;KAC1D;CACF,CAAC;AAEF,MAAM,cAAc,GAAG,EAAE,QAAQ,EAAE,UAAU,EAAE,CAAC;AAEhD,MAAM,mBAAmB,GAAG,CAAC,CAAC;AAC9B,MAAM,sBAAsB,GAAG,CAAC,CAAC;AACjC,MAAM,qBAAqB,GAAG,CAAC,CAAC;AAChC,MAAM,mBAAmB,GAAG,CAAC,CAAC;AAC9B,MAAM,wBAAwB,GAAG,CAAC,CAAC;AAEnC,IAAY,iBAMX;AAND,WAAY,iBAAiB;IAC3B,uFAAmB,CAAA;IACnB,6FAAsB,CAAA;IACtB,2FAAqB,CAAA;IACrB,uFAAmB,CAAA;IACnB,iGAAwB,CAAA;AAC1B,CAAC,EANW,iBAAiB,GAAjB,yBAAiB,KAAjB,yBAAiB,QAM5B;AAAA,CAAC;AAaD,CAAC;AAQD,CAAC;AAEW,QAAA,YAAY,GAAG,SAAS,CAAC;AACzB,QAAA,kBAAkB,GAAG,eAAe,CAAC;AACrC,QAAA,iBAAiB,GAAG,cAAc,CAAC;AAEhD,MAAM,sBAAsB,GAAG,CAAC,KAAa,EAAE,EAAE;IAC/C,MAAM,mBAAmB,GAAG,CAAC,UAAU,EAAE,WAAW,EAAE,OAAO,EAAE,YAAY,EAAE,QAAQ,CAAC,CAAC;IACvF,IAAI,mBAAmB,CAAC,QAAQ,CAAC,KAAK,CAAC,EAAE;QACvC,OAAO,0BAAkB,CAAC;KAC3B;IAED,OAAO,yBAAiB,CAAC;AAC3B,CAAC,CAAA;AAQD,MAAa,eAAgB,SAAQ,qBAAY;IAM/C,YAAY,OAAoC,EAAE,MAA6B;QAC7E,KAAK,EAAE,CAAC;QAER,IAAI,CAAC,MAAM,GAAG,MAAM,IAAI,sBAAa,CAAC;QACtC,IAAI,CAAC,OAAO,GAAG,IAAI,iBAAO,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC;QAExC,IAAI,CAAC,OAAO,mBACV,OAAO,EAAE,KAAK,EACd,MAAM,EAAE,KAAK,EACb,WAAW,EAAE,IAAI,EACjB,YAAY,EAAE,KAAK,EACnB,gBAAgB,EAAE,GAAG,IAClB,OAAO,CACX,CAAC;QAEF,IAAI,CAAC,UAAU,GAAG,IAAI,wBAAU,CAAC,SAAS,EAAE,SAAS,EAAE,IAAI,CAAC,OAAO,CAAC,WAAW,EAAE,IAAI,CAAC,OAAO,CAAC,cAAc,CAAC,CAAC;IAChH,CAAC;IAEM,SAAS;QACd,OAAO,IAAI,CAAC,OAAO,CAAC,OAAO,KAAK,IAAI,CAAC;IACvC,CAAC;IAEM,QAAQ;QACb,OAAO,IAAI,CAAC,OAAO,CAAC,MAAM,KAAK,IAAI,CAAC;IACtC,CAAC;IAEM,SAAS;QACd,OAAO,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC;IAC1B,CAAC;IAED;;OAEG;IACI,SAAS,CAAC,QAA2B;QAC1C,MAAM,MAAM,GAAG,KAAK,CAAC,OAAO,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC;QAC/D,MAAM,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,QAAQ,CAC3C,IAAI,CAAC,gBAAgB,CAAC,KAAK,CAAC,EAC5B,KAAK,CACN,CAAC,CAAC;QAEH,mDAAmD;QACnD,IAAI,CAAC,OAAO,CAAC,OAAO,EAAE,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE;YACrC,0CAA0C;YAC1C,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,qBAAqB,CAAC,EAAE;gBAChE,OAAO,IAAI,CAAC,sBAAsB,CAAC,KAAK,EAAE,CAAC,GAAG,IAAI,CAAC,OAAO,CAAC,SAAS,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;aAC/E;YAED,qGAAqG;YACrG,IACE,CAAC,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,sBAAsB,CAAC;gBAC9D,CAAC,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,wBAAwB,CAAC,EAChE;gBACA,OAAO,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;aAC5B;QACH,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;OAEG;IACI,WAAW,CAAC,QAA2B;QAC5C,MAAM,MAAM,GAAG,KAAK,CAAC,OAAO,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC;QAC/D,MAAM,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,WAAW,CAC9C,IAAI,CAAC,gBAAgB,CAAC,KAAK,CAAC,EAC5B,KAAK,CACN,CAAC,CAAC;QAEH,IAAI,CAAC,OAAO,CAAC,OAAO,EAAE,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE;YACrC,iEAAiE;YACjE,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,qBAAqB,CAAC,EAAE;gBAChE,IAAI,CAAC,wBAAwB,CAAC,KAAK,EAAE,CAAC,GAAG,IAAI,CAAC,OAAO,CAAC,SAAS,CAAC,KAAK,CAAC,CAAC,CAAC,CAAA;aACzE;QACH,CAAC,CAAC,CAAC;IACL,CAAC;IAEM,KAAK,CAAC,KAAa;;QACxB,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,oBAAoB,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;QACrE,IAAI,CAAC,UAAU,CAAC,KAAK,EAAE,mBAAmB,CAAC,CAAC;QAC5C,IAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;QAExB,MAAA,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,0CAAE,KAAK,GAAG;IAC7B,CAAC;IAED;;OAEG;IACI,UAAU;QACf,IAAI,IAAI,CAAC,SAAS,EAAE,EAAE;YACpB,OAAO,CAAC,IAAI,CAAC,OAAO,CAAC,oBAAY,CAAC,CAAC,CAAC;SACrC;QAED,IAAI,IAAI,CAAC,QAAQ,EAAE,EAAE;YACnB,OAAO,CAAC,IAAI,CAAC,OAAO,CAAC,yBAAiB,CAAC,EAAE,IAAI,CAAC,OAAO,CAAC,0BAAkB,CAAC,CAAC,CAAC;SAC5E;IACH,CAAC;IAEa,OAAO,CAAC,KAAa;;YACjC,IAAI;gBACF,IAAI,IAAI,CAAC,OAAO,CAAC,QAAQ,CAAC,KAAK,CAAC,EAAE;oBAChC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,0DAA0D,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAA;oBAC3G,OAAO,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;iBAClC;gBAED,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,sBAAsB,CAAC,EAAE;oBACjE,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,6DAA6D,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAA;oBAC9G,OAAO;iBACR;gBAED,IACE,CAAC,IAAI,CAAC,OAAO,CAAC,kBAAkB,CAAC,KAAK,CAAC;oBACvC,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,mBAAmB,CAAC,EAC1D;oBACA,IAAI,CAAC,UAAU,CAAC,KAAK,EAAE,sBAAsB,CAAC,CAAC;iBAChD;gBAED,MAAM,UAAU,GAAG,MAAM,IAAI,CAAC,aAAa,CAAC,KAAK,CAAC,CAAC;gBACnD,MAAM,GAAG,GAAG,IAAI,CAAC,QAAQ,CAAC,KAAK,CAAC,GAAG,UAAU,CAAC;gBAC9C,MAAM,EAAE,GAAG,IAAI,CAAC,cAAc,CAAC,GAAG,EAAE,KAAK,CAAC,CAAC;gBAE3C,OAAO,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,KAAK,EAAE,EAAE,CAAC,CAAC;aACtC;YAAC,OAAO,GAAG,EAAE;gBACZ,IAAI,CAAC,YAAY,CAAC,mBAAmB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAC;gBACnD,IAAI,CAAC,kBAAkB,CAAC,KAAK,EAAE,IAAI,CAAC,OAAO,CAAC,gBAAiB,CAAC,CAAC;aAChE;QACH,CAAC;KAAA;IAEO,YAAY,CAAC,OAAe,EAAE,KAAK,EAAE,KAAa;QACxD,IAAI,CAAC,KAAK,CAAC,OAAO,EAAE;YAClB,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,GAAG,OAAO,4BAA4B,EAAE,KAAK,CAAC,CAAC;YACjE,OAAO;SACR;QAED,QAAQ,KAAK,CAAC,OAAO,EAAE;YACrB,KAAK,iCAAiC;gBACpC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,GAAG,OAAO,oCAAoC,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;gBAChG,MAAM;YAER;gBACE,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,+CAA+C,KAAK,CAAC,GAAG,EAAE,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;gBAC5G,MAAM;SACT;IACH,CAAC;IAED;;OAEG;IACW,aAAa,CAAC,KAAa;;YACvC,MAAM,EAAE,GAAG,EAAE,MAAM,EAAE,GAAG,IAAI,CAAC,OAAO,CAAC;YAErC,IAAI,GAAG,IAAI,MAAM,IAAI,KAAK,KAAK,yBAAiB,EAAE;gBAChD,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,gCAAgC,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;gBAElF,MAAM,UAAU,GAAG,MAAM,IAAI,CAAC,UAAU,CAAC,aAAa,EAAE,CAAC;gBAEzD,MAAM,MAAM,GAAQ;oBAClB,OAAO,EAAE,IAAI,CAAC,OAAO,CAAC,GAAG;oBACzB,OAAO,EAAE,CAAC,IAAI,CAAC,GAAG,EAAE,GAAG,UAAU,GAAG,IAAI,CAAC;iBAC1C,CAAC;gBAEF,MAAM,CAAC,SAAS,GAAG,0BAAW,CAAC,cAAc,GAAG,MAAM,CAAC,OAAO,EAAE,MAAM,CAAC,CAAC;gBACxE,OAAO,GAAG,GAAG,8BAAe,CAAC,MAAM,CAAC,CAAC;aAEtC;iBAAM,IAAI,CAAC,GAAG,IAAI,CAAC,MAAM,EAAE;gBAC1B,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,oEAAoE,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;aACzH;iBAAM;gBACL,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,wCAAwC,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;aAC3F;YAED,OAAO,EAAE,CAAC;QACZ,CAAC;KAAA;IAEO,kBAAkB,CAAC,KAAa,EAAE,iBAAyB;QACjE,IAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;QACxB,IAAI,IAAI,CAAC,OAAO,CAAC,kBAAkB,CAAC,KAAK,CAAC,KAAK,sBAAsB,EAAE;YACrE,IAAI,CAAC,UAAU,CAAC,KAAK,EAAE,wBAAwB,CAAC,CAAC;SAClD;QAED,UAAU,CAAC,GAAG,EAAE;YACd,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,2BAA2B,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;YAC5E,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;QACtB,CAAC,EAAE,iBAAiB,CAAC,CAAC;IACxB,CAAC;IAEO,IAAI,CAAC,KAAa;QACxB,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC;QAE3B,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,cAAc,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;QAChE,IAAI,CAAC,SAAS,CAAC,KAAK,EAAE,IAAI,CAAC,SAAS,CAAC,EAAE,EAAE,EAAE,MAAM,EAAE,CAAC,CAAC,CAAC;QAEtD,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,EAAE,IAAI,CAAE,CAAC,eAAe,GAAG,UAAU,CAAC,GAAG,EAAE;;YAC/D,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,4CAA4C,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;YAC7F,MAAA,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,0CAAE,KAAK,GAAG;QAC7B,CAAC,EAAE,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC,CAAC;IAC/B,CAAC;IAEO,WAAW,CAAC,KAAa;QAC/B,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC;QAC3B,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC;IAC7B,CAAC;IAED,2BAA2B;IACnB,cAAc,CAAC,KAAa;QAClC,MAAM,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;QACxC,IAAI,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,eAAe,EAAE;YAC5B,aAAa,CAAC,OAAO,CAAC,eAAe,CAAC,CAAC;YACvC,OAAO,CAAC,eAAe,GAAG,SAAS,CAAC;SACrC;IACH,CAAC;IAED,oCAAoC;IAC5B,cAAc,CAAC,KAAa;QAClC,MAAM,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;QACxC,IAAI,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,eAAe,EAAE;YAC5B,YAAY,CAAC,OAAO,CAAC,eAAe,CAAC,CAAC;YACtC,OAAO,CAAC,eAAe,GAAG,SAAS,CAAC;SACrC;IACH,CAAC;IAED;;OAEG;IACK,sBAAsB,CAAC,KAAa,EAAE,MAAgB;QAC5D,MAAM,SAAS,GAAG,IAAI,CAAC,SAAS,CAAC;YAC/B,EAAE,EAAE,WAAW;YACf,IAAI,EAAE,MAAM;SACb,CAAC,CAAC;QAEH,IAAI,CAAC,SAAS,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;IACnC,CAAC;IAED;;OAEG;IACK,wBAAwB,CAAC,KAAa,EAAE,MAAgB;QAC9D,MAAM,SAAS,GAAG,IAAI,CAAC,SAAS,CAAC;YAC/B,EAAE,EAAE,aAAa;YACjB,IAAI,EAAE,MAAM;SACb,CAAC,CAAC;QAEH,IAAI,CAAC,SAAS,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;IACnC,CAAC;IAEO,SAAS,CAAC,KAAa,EAAE,SAAiB;;QAChD,IAAI;YACF,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,+BAA+B,kCAAO,cAAc,KAAE,SAAS,EAAE,KAAK,IAAG,CAAC;YAC5F,IAAI,CAAC,KAAK,EAAE;gBACV,MAAM,IAAI,KAAK,CAAC,8DAA8D,CAAC,CAAC;aACjF;YACD,MAAA,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,0CAAE,IAAI,CAAC,SAAS,EAAE;SACpC;QAAC,OAAO,CAAC,EAAE;YACV,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,2BAA2B,kCAAO,cAAc,KAAE,SAAS,EAAE,KAAK,EAAE,SAAS,EAAE,CAAC,IAAG,CAAC;SACvG;IACH,CAAC;IAEO,cAAc,CAAC,GAAW,EAAE,KAAa;QAC/C,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,iCAAiC,GAAG,EAAE,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAA;QAEvF,MAAM,EAAE,GAAG,IAAI,uBAAS,CAAC,GAAG,CAAC,CAAC;QAC9B,EAAE,CAAC,MAAM,GAAG,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,QAAQ,CAAC,KAAK,EAAE,KAAK,CAAC,CAAC;QACjD,EAAE,CAAC,SAAS,GAAG,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,WAAW,CAAC,KAAK,EAAE,KAAK,CAAC,CAAC;QACvD,EAAE,CAAC,OAAO,GAAG,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,SAAS,CAAC,KAAK,EAAE,KAAK,CAAC,CAAC;QACnD,EAAE,CAAC,OAAO,GAAG,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,SAAS,CAAC,KAAK,EAAE,KAAK,CAAC,CAAC;QAEnD,OAAO,EAAE,CAAC;IACZ,CAAC;IAEO,QAAQ,CAAC,KAAK,EAAE,KAAa;QACnC,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,sBAAsB,CAAC,EAAE;YACjE,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,qBAAqB,kCAAO,cAAc,KAAE,KAAK,EAAE,OAAO,EAAE,IAAI,CAAC,SAAS,EAAE,EAAE,MAAM,EAAE,IAAI,CAAC,QAAQ,EAAE,IAAG,CAAC;YAC1H,IAAI,CAAC,IAAI,CAAC,MAAM,EAAE,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC;SACrC;aAAM,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,wBAAwB,CAAC,EAAE;YAC1E,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,uBAAuB,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;YACxE,IAAI,CAAC,IAAI,CAAC,aAAa,EAAE,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC;SAC5C;QAED,IAAI,CAAC,UAAU,CAAC,KAAK,EAAE,qBAAqB,CAAC,CAAC;QAE9C,IAAI,CAAC,sBAAsB,CAAC,KAAK,EAAE,CAAC,GAAG,IAAI,CAAC,OAAO,CAAC,SAAS,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;QAEvE,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,EAAE,IAAI,CAAE,CAAC,eAAe,GAAG,WAAW,CAC1D,GAAG,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,KAAK,CAAC,EACtB,IAAI,CAAC,OAAO,CAAC,YAAY,CAC1B,CAAC;IACJ,CAAC;IAEO,WAAW,CAAC,KAAK,EAAE,KAAa;QACtC,MAAM,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,KAAK,IAAI,KAAK,CAAC,IAAI,IAAI,KAAK,CAAC,CAAC;QAErD,IAAI,SAAS,IAAI,GAAG,EAAE;YACpB,IAAI,CAAC,mBAAmB,CAAC,GAAG,EAAE,KAAK,CAAC,CAAC;SACtC;aAAM,IAAI,GAAG,CAAC,KAAK,EAAE;YACpB,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,CAAC;SAC7B;aAAM;YACL,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,0BAA0B,kCAAO,cAAc,KAAE,OAAO,EAAE,GAAG,EAAE,KAAK,EAAE,KAAK,IAAE,CAAC;SACnG;IACH,CAAC;IAEO,SAAS,CAAC,GAAG,EAAE,KAAa;QAClC,IAAI,CAAC,YAAY,CAAC,iBAAiB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAC;QACjD,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,qBAAqB,CAAC,EAAE;YAChE,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,CAAC,CAAC;SACzB;IACH,CAAC;IAEO,SAAS,CAAC,KAAK,EAAE,KAAa;QACpC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,6BAA6B,kCAAO,cAAc,KAAE,KAAK,IAAE,CAAC;QAE7E,IAAI,IAAI,CAAC,OAAO,CAAC,kBAAkB,CAAC,KAAK,CAAC,KAAK,mBAAmB,EAAE;YAClE,IAAI,CAAC,kBAAkB,CAAC,KAAK,EAAE,IAAI,CAAC,OAAO,CAAC,gBAAiB,CAAC,CAAC;YAC/D,IAAI,CAAC,IAAI,CAAC,WAAW,CAAC,CAAC;SACxB;aAAM;YACL,IAAI,CAAC,UAAU,CAAC,KAAK,EAAE,mBAAmB,CAAC,CAAC;YAC5C,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;SACpB;IACH,CAAC;IAEO,mBAAmB,CAAC,QAAa,EAAE,KAAa;QACtD,IAAI,uBAAQ,CAAC,QAAQ,CAAC,EAAE;YACtB,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,eAAe,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;YACjE,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC;SAC5B;aAAM;YACL,IAAI,CAAC,IAAI,CAAC,UAAU,EAAE,QAAQ,CAAC,CAAC;SACjC;IACH,CAAC;IAEO,iBAAiB,CAAC,OAAY;QACpC,IAAI,CAAC,IAAI,CAAC,QAAQ,EAAE,OAAO,CAAC,CAAC;IAC/B,CAAC;IAEO,KAAK,CAAC,KAAa;QACzB,OAAO,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;IACnC,CAAC;IAEO,UAAU,CAAC,KAAa,EAAE,KAAwB;QACxD,IAAI,CAAC,OAAO,CAAC,kBAAkB,CAAC,KAAK,EAAE,KAAK,CAAC,CAAC;IAChD,CAAC;IAEO,QAAQ,CAAC,KAAa;QAC5B,IAAI,IAAI,CAAC,OAAO,CAAC,KAAK,EAAE;YACtB,OAAO,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC;SAC3B;QAED,OAAO,mBAAmB,CAAC;IAC7B,CAAC;IAEO,gBAAgB,CAAC,KAAa;QACpC,OAAO,IAAI,CAAC,SAAS,EAAE,CAAC,CAAC,CAAC,oBAAY,CAAC,CAAC,CAAC,sBAAsB,CAAC,KAAK,CAAC,CAAC;IACzE,CAAC;CACF;AAlWD,0CAkWC;AAAA,CAAC"}
+{"version":3,"file":"websocket-client.js","sourceRoot":"","sources":["../src/websocket-client.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;AAAA,mCAAsC;AACtC,+CAA2C;AAC3C,qCAAyC;AACzC,sDAAoH;AAEpH,kEAAsC;AACtC,6DAAqC;AACrC,kDAA+D;AAE/D,MAAM,cAAc,GAAG,EAAE,QAAQ,EAAE,QAAQ,EAAE,CAAC;AAE9C,MAAM,mBAAmB,GAAG,CAAC,CAAC;AAC9B,MAAM,sBAAsB,GAAG,CAAC,CAAC;AACjC,MAAM,qBAAqB,GAAG,CAAC,CAAC;AAChC,MAAM,mBAAmB,GAAG,CAAC,CAAC;AAC9B,MAAM,wBAAwB,GAAG,CAAC,CAAC;AAEnC,IAAY,iBAMX;AAND,WAAY,iBAAiB;IAC3B,uFAAmB,CAAA;IACnB,6FAAsB,CAAA;IACtB,2FAAqB,CAAA;IACrB,uFAAmB,CAAA;IACnB,iGAAwB,CAAA;AAC1B,CAAC,EANW,iBAAiB,GAAjB,yBAAiB,KAAjB,yBAAiB,QAM5B;AAAA,CAAC;AAMD,CAAC;AAEW,QAAA,YAAY,GAAG,KAAK,CAAC;AACrB,QAAA,SAAS,GAAG,mBAAmB,CAAC;AAM5C,CAAC;AAMD,CAAC;AAEF,MAAa,eAAgB,SAAQ,qBAAY;IAM/C,YAAY,OAAoC,EAAE,MAA6B;QAC7E,KAAK,EAAE,CAAC;QAER,IAAI,CAAC,MAAM,GAAG,MAAM,IAAI,sBAAa,CAAC;QACtC,IAAI,CAAC,OAAO,GAAG,IAAI,iBAAO,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC;QAExC,IAAI,CAAC,OAAO,mBACV,WAAW,EAAE,IAAI,EACjB,YAAY,EAAE,KAAK,EACnB,gBAAgB,EAAE,GAAG,IAClB,OAAO,CACX,CAAC;QAEF,IAAI,CAAC,UAAU,GAAG,IAAI,wBAAU,CAAC,SAAS,EAAE,SAAS,EAAE,IAAI,CAAC,OAAO,CAAC,WAAW,EAAE,IAAI,CAAC,OAAO,CAAC,cAAc,CAAC,CAAC;IAChH,CAAC;IAEM,SAAS;QACd,OAAO,IAAI,CAAC;IACd,CAAC;IAED;;OAEG;IACI,SAAS,CAAC,QAAiD;QAChE,MAAM,MAAM,GAAG,KAAK,CAAC,OAAO,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC;QAC/D,MAAM,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,QAAQ,CAC3C,IAAI,CAAC,gBAAgB,CAAC,KAAK,CAAC,EAC5B,KAAK,CACN,CAAC,CAAC;QAEH,mDAAmD;QACnD,IAAI,CAAC,OAAO,CAAC,OAAO,EAAE,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE;YACrC,0CAA0C;YAC1C,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,qBAAqB,CAAC,EAAE;gBAChE,OAAO,IAAI,CAAC,sBAAsB,CAAC,KAAK,EAAE,CAAC,GAAG,IAAI,CAAC,OAAO,CAAC,SAAS,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;aAC/E;YAED,qGAAqG;YACrG,IACE,CAAC,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,sBAAsB,CAAC;gBAC9D,CAAC,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,wBAAwB,CAAC,EAChE;gBACA,OAAO,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;aAC5B;QACH,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;OAEG;IACI,WAAW,CAAC,QAAiD;QAClE,MAAM,MAAM,GAAG,KAAK,CAAC,OAAO,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC;QAC/D,MAAM,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,WAAW,CAC9C,IAAI,CAAC,gBAAgB,CAAC,KAAK,CAAC,EAC5B,KAAK,CACN,CAAC,CAAC;QAEH,IAAI,CAAC,OAAO,CAAC,OAAO,EAAE,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE;YACrC,iEAAiE;YACjE,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,qBAAqB,CAAC,EAAE;gBAChE,IAAI,CAAC,wBAAwB,CAAC,KAAK,EAAE,CAAC,GAAG,IAAI,CAAC,OAAO,CAAC,SAAS,CAAC,KAAK,CAAC,CAAC,CAAC,CAAA;aACzE;QACH,CAAC,CAAC,CAAC;IACL,CAAC;IAEM,KAAK,CAAC,KAAa;;QACxB,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,oBAAoB,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;QACrE,IAAI,CAAC,UAAU,CAAC,KAAK,EAAE,mBAAmB,CAAC,CAAC;QAC5C,IAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;QAExB,MAAA,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,0CAAE,KAAK,EAAE,CAAC;IAC7B,CAAC;IAED;;OAEG;IACI,UAAU;QACf,OAAO,CAAC,IAAI,CAAC,OAAO,CAAC,oBAAY,CAAC,CAAC,CAAC;IACtC,CAAC;IAEa,OAAO,CAAC,KAAa;;YACjC,IAAI;gBACF,IAAI,IAAI,CAAC,OAAO,CAAC,QAAQ,CAAC,KAAK,CAAC,EAAE;oBAChC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,0DAA0D,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAA;oBAC3G,OAAO,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;iBAClC;gBAED,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,sBAAsB,CAAC,EAAE;oBACjE,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,6DAA6D,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAA;oBAC9G,OAAO;iBACR;gBAED,IACE,CAAC,IAAI,CAAC,OAAO,CAAC,kBAAkB,CAAC,KAAK,CAAC;oBACvC,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,mBAAmB,CAAC,EAC1D;oBACA,IAAI,CAAC,UAAU,CAAC,KAAK,EAAE,sBAAsB,CAAC,CAAC;iBAChD;gBAED,MAAM,GAAG,GAAG,IAAI,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAC;gBACjC,MAAM,EAAE,GAAG,IAAI,CAAC,cAAc,CAAC,GAAG,EAAE,KAAK,CAAC,CAAC;gBAE3C,OAAO,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,KAAK,EAAE,EAAE,CAAC,CAAC;aACtC;YAAC,OAAO,GAAG,EAAE;gBACZ,IAAI,CAAC,YAAY,CAAC,mBAAmB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAC;gBACnD,IAAI,CAAC,kBAAkB,CAAC,KAAK,EAAE,IAAI,CAAC,OAAO,CAAC,gBAAiB,CAAC,CAAC;aAChE;QACH,CAAC;KAAA;IAEO,sBAAsB,CAAC,KAAa;QAC1C,MAAM,EAAE,GAAG,EAAE,MAAM,EAAE,GAAG,IAAI,CAAC,OAAO,CAAC;QACrC,IAAI,CAAC,GAAG,IAAI,CAAC,MAAM,EAAE;YACnB,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,eAAe,KAAK,yDAAyD,CAAC,CAAC;YACjG,OAAO;SACR;QAED,MAAM,SAAS,GAAG,IAAI,IAAI,EAAE,CAAC,OAAO,EAAE,CAAC;QACvC,MAAM,OAAO,GAAG,6BAAgB,CAC9B,GAAG,EACH,iCAAkB,CAAC,SAAS,EAAE,MAAM,CAAC,EACrC,SAAS,CACV,CAAC;QACF,IAAI,CAAC,SAAS,CAAC,KAAK,EAAE,IAAI,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC,CAAC;IACjD,CAAC;IAEO,YAAY,CAAC,OAAe,EAAE,KAAK,EAAE,KAAa;QACxD,IAAI,CAAC,KAAK,CAAC,OAAO,EAAE;YAClB,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,GAAG,OAAO,4BAA4B,EAAE,KAAK,CAAC,CAAC;YACjE,OAAO;SACR;QAED,QAAQ,KAAK,CAAC,OAAO,EAAE;YACrB,KAAK,iCAAiC;gBACpC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,GAAG,OAAO,oCAAoC,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;gBAChG,MAAM;YAER;gBACE,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,+CAA+C,KAAK,CAAC,GAAG,EAAE,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;gBAC5G,MAAM;SACT;IACH,CAAC;IAED;;OAEG;IACW,aAAa,CAAC,KAAa;;YACvC,MAAM,EAAE,GAAG,EAAE,MAAM,EAAE,GAAG,IAAI,CAAC,OAAO,CAAC;YAErC,IAAI,GAAG,IAAI,MAAM,EAAE;gBACjB,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,gCAAgC,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;gBAElF,MAAM,UAAU,GAAG,MAAM,IAAI,CAAC,UAAU,CAAC,aAAa,EAAE,CAAC;gBAEzD,MAAM,MAAM,GAAQ;oBAClB,OAAO,EAAE,IAAI,CAAC,OAAO,CAAC,GAAG;oBACzB,OAAO,EAAE,CAAC,IAAI,CAAC,GAAG,EAAE,GAAG,UAAU,GAAG,IAAI,CAAC;iBAC1C,CAAC;gBAEF,MAAM,CAAC,SAAS,GAAG,0BAAW,CAAC,cAAc,GAAG,MAAM,CAAC,OAAO,EAAE,MAAM,CAAC,CAAC;gBACxE,OAAO,MAAM,CAAC;aAEf;iBAAM,IAAI,CAAC,GAAG,IAAI,CAAC,MAAM,EAAE;gBAC1B,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,oEAAoE,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;aACzH;iBAAM;gBACL,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,wCAAwC,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;aAC3F;YAED,OAAO,EAAE,CAAC;QACZ,CAAC;KAAA;IAEO,kBAAkB,CAAC,KAAa,EAAE,iBAAyB;QACjE,IAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC;QACxB,IAAI,IAAI,CAAC,OAAO,CAAC,kBAAkB,CAAC,KAAK,CAAC,KAAK,sBAAsB,EAAE;YACrE,IAAI,CAAC,UAAU,CAAC,KAAK,EAAE,wBAAwB,CAAC,CAAC;SAClD;QAED,UAAU,CAAC,GAAG,EAAE;YACd,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,2BAA2B,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;YAC5E,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;QACtB,CAAC,EAAE,iBAAiB,CAAC,CAAC;IACxB,CAAC;IAEO,IAAI,CAAC,KAAa;QACxB,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC;QAE3B,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,cAAc,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;QAChE,IAAI,CAAC,SAAS,CAAC,KAAK,EAAE,IAAI,CAAC,SAAS,CAAC,EAAE,EAAE,EAAE,MAAM,EAAE,CAAC,CAAC,CAAC;QAEtD,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,EAAE,IAAI,CAAE,CAAC,eAAe,GAAG,UAAU,CAAC,GAAG,EAAE;;YAC/D,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,4CAA4C,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;YAC7F,MAAA,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,0CAAE,KAAK,EAAE,CAAC;QAC7B,CAAC,EAAE,IAAI,CAAC,OAAO,CAAC,WAAW,CAAC,CAAC;IAC/B,CAAC;IAEO,WAAW,CAAC,KAAa;QAC/B,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC;QAC3B,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC;IAC7B,CAAC;IAED,2BAA2B;IACnB,cAAc,CAAC,KAAa;QAClC,MAAM,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;QACxC,IAAI,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,eAAe,EAAE;YAC5B,aAAa,CAAC,OAAO,CAAC,eAAe,CAAC,CAAC;YACvC,OAAO,CAAC,eAAe,GAAG,SAAS,CAAC;SACrC;IACH,CAAC;IAED,oCAAoC;IAC5B,cAAc,CAAC,KAAa;QAClC,MAAM,OAAO,GAAG,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,CAAC;QACxC,IAAI,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,eAAe,EAAE;YAC5B,YAAY,CAAC,OAAO,CAAC,eAAe,CAAC,CAAC;YACtC,OAAO,CAAC,eAAe,GAAG,SAAS,CAAC;SACrC;IACH,CAAC;IAED;;OAEG;IACK,sBAAsB,CAAC,KAAa,EAAE,MAAiB;QAC7D,MAAM,MAAM,GAAG,EAAE,CAAC;QAElB,MAAM,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE;YACrB,MAAM,SAAS,GAAG,IAAI,CAAC,SAAS,iBAC9B,EAAE,EAAE,WAAW,IACZ,KAAK,EACR,CAAC;YACH,IAAI,CAAC,SAAS,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;QACnC,CAAC,CAAC,CAAC;IACL,CAAC;IAED;;OAEG;IACK,wBAAwB,CAAC,KAAa,EAAE,MAAiB;QAC/D,MAAM,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE;YACrB,MAAM,SAAS,GAAG,IAAI,CAAC,SAAS,iBAC9B,EAAE,EAAE,aAAa,IACd,KAAK,EACR,CAAC;YACH,IAAI,CAAC,SAAS,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;QACnC,CAAC,CAAC,CAAC;IACL,CAAC;IAEO,SAAS,CAAC,KAAa,EAAE,SAAiB;;QAChD,IAAI;YACF,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,+BAA+B,kCAAO,cAAc,KAAE,SAAS,EAAE,KAAK,IAAG,CAAC;YAC5F,IAAI,CAAC,KAAK,EAAE;gBACV,MAAM,IAAI,KAAK,CAAC,8DAA8D,CAAC,CAAC;aACjF;YACD,MAAA,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,0CAAE,IAAI,CAAC,SAAS,CAAC,CAAC;SACpC;QAAC,OAAO,CAAC,EAAE;YACV,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,2BAA2B,kCAAO,cAAc,KAAE,SAAS,EAAE,KAAK,EAAE,SAAS,EAAE,CAAC,IAAG,CAAC;SACvG;IACH,CAAC;IAEO,cAAc,CAAC,GAAW,EAAE,KAAa;QAC/C,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,iCAAiC,GAAG,EAAE,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAA;QAEvF,MAAM,EAAE,GAAG,IAAI,uBAAS,CAAC,GAAG,CAAC,CAAC;QAC9B,EAAE,CAAC,MAAM,GAAG,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,QAAQ,CAAC,KAAK,EAAE,KAAK,CAAC,CAAC;QACjD,EAAE,CAAC,SAAS,GAAG,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,WAAW,CAAC,KAAK,EAAE,KAAK,CAAC,CAAC;QACvD,EAAE,CAAC,OAAO,GAAG,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,SAAS,CAAC,KAAK,EAAE,KAAK,CAAC,CAAC;QACnD,EAAE,CAAC,OAAO,GAAG,KAAK,CAAC,EAAE,CAAC,IAAI,CAAC,SAAS,CAAC,KAAK,EAAE,KAAK,CAAC,CAAC;QAEnD,OAAO,EAAE,CAAC;IACZ,CAAC;IAEO,QAAQ,CAAC,KAAK,EAAE,KAAa;QACnC,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,sBAAsB,CAAC,EAAE;YACjE,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,qBAAqB,kCAAO,cAAc,KAAE,KAAK,EAAE,OAAO,EAAE,IAAI,CAAC,SAAS,EAAE,IAAG,CAAC;YACjG,IAAI,CAAC,IAAI,CAAC,MAAM,EAAE,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC;SACrC;aAAM,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,wBAAwB,CAAC,EAAE;YAC1E,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,uBAAuB,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;YACxE,IAAI,CAAC,IAAI,CAAC,aAAa,EAAE,EAAE,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC;SAC5C;QAED,IAAI,CAAC,UAAU,CAAC,KAAK,EAAE,qBAAqB,CAAC,CAAC;QAE9C,IAAI,CAAC,sBAAsB,CAAC,KAAK,CAAC,CAAC;QACnC,IAAI,CAAC,sBAAsB,CAAC,KAAK,EAAE,CAAC,GAAG,IAAI,CAAC,OAAO,CAAC,SAAS,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;QAEvE,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,KAAK,EAAE,IAAI,CAAE,CAAC,eAAe,GAAG,WAAW,CAC1D,GAAG,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,KAAK,CAAC,EACtB,IAAI,CAAC,OAAO,CAAC,YAAY,CAC1B,CAAC;IACJ,CAAC;IAEO,WAAW,CAAC,KAAK,EAAE,KAAa;QACtC,MAAM,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,KAAK,IAAI,KAAK,CAAC,IAAI,IAAI,KAAK,CAAC,CAAC;QAErD,IAAI,GAAG,CAAC,OAAO,EAAE;YACf,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,CAAC;SAC7B;aAAM;YACL,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,mBAAmB,EAAE,KAAK,CAAC,IAAI,IAAI,KAAK,CAAC,CAAC;YAC5D,IAAI,CAAC,mBAAmB,CAAC,GAAG,EAAE,KAAK,CAAC,CAAC;SACtC;IACH,CAAC;IAEO,SAAS,CAAC,GAAG,EAAE,KAAa;QAClC,IAAI,CAAC,YAAY,CAAC,iBAAiB,EAAE,GAAG,EAAE,KAAK,CAAC,CAAC;QACjD,IAAI,IAAI,CAAC,OAAO,CAAC,iBAAiB,CAAC,KAAK,EAAE,qBAAqB,CAAC,EAAE;YAChE,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,GAAG,CAAC,CAAC;SACzB;IACH,CAAC;IAEO,SAAS,CAAC,KAAK,EAAE,KAAa;QACpC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,6BAA6B,kCAAO,cAAc,KAAE,KAAK,IAAE,CAAC;QAE7E,IAAI,IAAI,CAAC,OAAO,CAAC,kBAAkB,CAAC,KAAK,CAAC,KAAK,mBAAmB,EAAE;YAClE,IAAI,CAAC,kBAAkB,CAAC,KAAK,EAAE,IAAI,CAAC,OAAO,CAAC,gBAAiB,CAAC,CAAC;YAC/D,IAAI,CAAC,IAAI,CAAC,WAAW,CAAC,CAAC;SACxB;aAAM;YACL,IAAI,CAAC,UAAU,CAAC,KAAK,EAAE,mBAAmB,CAAC,CAAC;YAC5C,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;SACpB;IACH,CAAC;IAEO,mBAAmB,CAAC,QAAa,EAAE,KAAa;QACtD,IAAI,qBAAQ,CAAC,QAAQ,CAAC,EAAE;YACtB,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,eAAe,kCAAO,cAAc,KAAE,KAAK,IAAG,CAAC;YACjE,IAAI,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC;SAC5B;aAAM;YACL,IAAI,CAAC,IAAI,CAAC,UAAU,EAAE,QAAQ,CAAC,CAAC;SACjC;IACH,CAAC;IAEO,iBAAiB,CAAC,OAAY;QACpC,IAAI,CAAC,IAAI,CAAC,QAAQ,EAAE,OAAO,CAAC,CAAC;IAC/B,CAAC;IAEO,KAAK,CAAC,KAAa;QACzB,OAAO,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;IACnC,CAAC;IAEO,UAAU,CAAC,KAAa,EAAE,KAAwB;QACxD,IAAI,CAAC,OAAO,CAAC,kBAAkB,CAAC,KAAK,EAAE,KAAK,CAAC,CAAC;IAChD,CAAC;IAEO,QAAQ,CAAC,KAAc;QAC7B,IAAI,IAAI,CAAC,OAAO,CAAC,KAAK,EAAE;YACtB,OAAO,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC;SAC3B;QAED,OAAO,iBAAS,CAAC;IACnB,CAAC;IAEO,gBAAgB,CAAC,KAAU;QACjC,OAAO,oBAAY,CAAC;IACtB,CAAC;CACF;AArWD,0CAqWC;AAAA,CAAC"}

package.json

 {
   "name": "ftx-api",
-  "version": "0.0.4",
+  "version": "0.0.5",
   "description": "Node.js connector for FTX's REST APIs and WebSockets",
@@ -22,4 +22,3 @@ "main": "lib/index.js",
   "author": "Tiago Siebler (https://github.com/tiagosiebler)",
-  "contributors": [
-  ],
+  "contributors": [],
   "dependencies": {
@@ -26,0 +25,0 @@ "axios": "^0.21.0",

README.md

@@ -8,4 +8,2 @@ # ftx-api
 
-Warning: this connector is still in early beta. REST APIs should be fully functional but websockets still need work.
-
 Node.js connector for the FTX APIs and WebSockets, with TypeScript & browser support.
@@ -30,2 +28,3 @@
 - [dist](./dist) - the packed bundle of the project for use in browser environments.
+- [examples](./examples) - demonstrations on various workflows using this library
 
@@ -40,3 +39,5 @@ ---
 
-Import and instance the `RestClient` to access all REST API methods. All methods return promises.
+Import and instance the `RestClient` to access all REST API methods.
+- All methods return promises.
+- Supports subaccounts.
 
@@ -106,4 +107,9 @@ ### Example
 ## WebSockets
-<details><summary>Inverse & linear WebSockets can be used via a shared `WebsocketClient`. Click here to expand and see full sample:</summary>
+- Automatically connect to FTX websockets
+- Automatically authenticate, if key & secret are provided.
+- Automatically checks connection integrity. If connection stale (no response to pings), automatically reconnects, re-authenticates and resubscribes to previous topics.
+- Supports subaccounts.
 
+<details><summary>WebSocket channels can be subscribed to via the `WebsocketClient`. Click here to expand and see full sample:</summary>
+
 ```javascript
@@ -123,2 +129,5 @@ const { WebsocketClient } = require('ftx-api');
 
+  // Subaccount nickname
+  // subAccountName: 'sub1',
+
   // how long to wait (in ms) before deciding the connection should be terminated & reconnected
@@ -146,7 +155,26 @@ // pongTimeout: 1000,
 // subscribe to multiple topics at once
-ws.subscribe(['ticker', 'markets']);
+ws.subscribe(['fills', 'orders']);
 
 // and/or subscribe to individual topics on demand
-ws.subscribe('trades');
+ws.subscribe('fills');
 
+// and/or subscribe to complex topics on demand, one at a time
+ws.subscribe({
+  channel: 'trades',
+  market: 'BTC-PERP'
+});
+
+// or as a list of complex topics
+ws.subscribe([
+  {
+    channel: 'trades',
+    market: 'BTC-PERP'
+  },
+  {
+    channel: 'orderbookGrouped',
+    market: 'BTC-PERP',
+    grouping: 500
+  }
+]);
+
 // Listen to events coming from websockets. This is the primary data source
@@ -158,4 +186,4 @@ ws.on('update', data => {
 // Optional: Listen to websocket connection open event (automatic after subscribing to one or more topics)
-ws.on('open', ({ wsKey, event }) => {
-  console.log('connection open for websocket with ID: ' + wsKey);
+ws.on('open', ({ event }) => {
+  console.log('connection opened');
 });
@@ -162,0 +190,0 @@

New alerts

Long strings

Supply chain risk

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

Found 1 instance in 1 package

URL strings

Supply chain risk

Package contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.

Found 1 instance in 1 package

Fixed alerts

Long strings

Supply chain risk

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

Found 1 instance in 1 package

URL strings

Supply chain risk

Package contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

110127

1.29%

Number of package files

31

10.71%

Lines of code

1834

0.88%

Number of lines in readme file

250

12.61%

No dependency changes