🎩 You're Invited:Meet the Socket team at Black Hat in Las Vegas, August 3-6.RSVP →
@subsquid/rpc-client
Advanced tools
@subsquid/rpc-client - npm Package Compare versions
+9
-6
@@ -55,2 +55,9 @@ import { Logger } from '@subsquid/logger'; | ||
| } | ||
| export interface RpcMetrics { | ||
| url: string; | ||
| requestsServed: number; | ||
| connectionErrors: number; | ||
| notificationsReceived: number; | ||
| avgResponseTime: number; | ||
| } | ||
| export interface CallOptions<R = any> { | ||
@@ -90,2 +97,3 @@ priority?: number; | ||
| private notificationsReceived; | ||
| private totalResponseTime; | ||
| private backoffEpoch; | ||
@@ -99,8 +107,3 @@ private backoffTime?; | ||
| getConcurrency(): number; | ||
| getMetrics(): { | ||
| url: string; | ||
| requestsServed: number; | ||
| connectionErrors: number; | ||
| notificationsReceived: number; | ||
| }; | ||
| getMetrics(): RpcMetrics; | ||
| private onNotification; | ||
@@ -107,0 +110,0 @@ private safeCallback; |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"client.d.ts","sourceRoot":"","sources":["../src/client.ts"],"names":[],"mappings":"AACA,OAAO,EAAe,MAAM,EAAC,MAAM,kBAAkB,CAAA;AAIrD,OAAO,EAAa,kBAAkB,EAAW,MAAM,UAAU,CAAA;AACjE,OAAO,EAAa,WAAW,EAAE,OAAO,EAAE,YAAY,EAAE,eAAe,EAAE,UAAU,EAAc,MAAM,cAAc,CAAA;AAErH,OAAO,EAAC,YAAY,EAAE,kBAAkB,EAAgB,MAAM,iBAAiB,CAAA;AAK/E,MAAM,WAAW,gBAAgB;IAC7B;;OAEG;IACH,GAAG,EAAE,MAAM,CAAA;IACX;;;;OAIG;IACH,QAAQ,CAAC,EAAE,MAAM,CAAA;IACjB;;;;OAIG;IACH,SAAS,CAAC,EAAE,MAAM,CAAA;IAClB;;OAEG;IACH,cAAc,CAAC,EAAE,MAAM,CAAA;IACvB;;OAEG;IACH,aAAa,CAAC,EAAE,MAAM,CAAA;IACtB;;;;;;;;;OASG;IACH,aAAa,CAAC,EAAE,MAAM,EAAE,CAAA;IACxB;;OAEG;IACH,gBAAgB,CAAC,EAAE,MAAM,CAAA;IACzB;;OAEG;IACH,iBAAiB,CAAC,EAAE,OAAO,CAAA;IAC3B;;OAEG;IACH,OAAO,CAAC,EAAE,WAAW,CAAA;IACrB,GAAG,CAAC,EAAE,MAAM,GAAG,IAAI,CAAA;CACtB;AAGD,MAAM,WAAW,WAAW,CAAC,CAAC,GAAC,GAAG;IAC9B,QAAQ,CAAC,EAAE,MAAM,CAAA;IACjB,aAAa,CAAC,EAAE,MAAM,CAAA;IACtB,OAAO,CAAC,EAAE,MAAM,CAAA;IAChB;;;;;OAKG;IACH,cAAc,CAAC,EAAE,eAAe,CAAC,CAAC,CAAC,CAAA;IACnC,aAAa,CAAC,EAAE,cAAc,CAAC,CAAC,CAAC,CAAA;CACpC;AAGD,KAAK,eAAe,CAAC,CAAC,GAAC,GAAG,IAAI,CAAC,MAAM,EAAE,GAAG,EAAE,GAAG,EAAE,UAAU,KAAK,CAAC,CAAA;AACjE,KAAK,cAAc,CAAC,CAAC,GAAC,GAAG,IAAI,CAAC,IAAI,EAAE,YAAY,EAAE,GAAG,EAAE,UAAU,KAAK,CAAC,CAAA;AAevE,qBAAa,SAAS;IAClB,OAAO,CAAC,OAAO,CAAI;IACnB,OAAO,CAAC,KAAK,CAA4B;IACzC,SAAgB,GAAG,EAAE,MAAM,CAAA;IAC3B,OAAO,CAAC,GAAG,CAAY;IACvB,OAAO,CAAC,gBAAgB,CAAQ;IAChC,OAAO,CAAC,cAAc,CAAQ;IAC9B,OAAO,CAAC,aAAa,CAAU;IAC/B,OAAO,CAAC,aAAa,CAAQ;IAC7B,OAAO,CAAC,QAAQ,CAAQ;IACxB,OAAO,CAAC,WAAW,CAAQ;IAC3B,OAAO,CAAC,GAAG,CAAC,CAAQ;IACpB,OAAO,CAAC,IAAI,CAAC,CAAW;IACxB,OAAO,CAAC,SAAS,CAAkC;IACnD,OAAO,CAAC,mBAAmB,CAAQ;IACnC,OAAO,CAAC,qBAAqB,CAAI;IACjC,OAAO,CAAC,gBAAgB,CAAI;IAC5B,OAAO,CAAC,cAAc,CAAI;IAC1B,OAAO,CAAC,qBAAqB,CAAI;IACjC,OAAO,CAAC,YAAY,CAAI;IACxB,OAAO,CAAC,WAAW,CAAC,CAAQ;IAC5B,OAAO,CAAC,qBAAqB,CAAyC;IACtE,OAAO,CAAC,cAAc,CAAkC;IACxD,OAAO,CAAC,MAAM,CAAQ;gBAEV,OAAO,EAAE,gBAAgB;IA0BrC,OAAO,CAAC,gBAAgB;IA8BxB,cAAc,IAAI,MAAM;IAIxB,UAAU;;;;;;IASV,OAAO,CAAC,cAAc;IAQtB,OAAO,CAAC,YAAY;IAQpB,uBAAuB,CAAC,EAAE,EAAE,CAAC,GAAG,EAAE,eAAe,KAAK,IAAI,GAAG,IAAI;IAIjE,0BAA0B,CAAC,EAAE,EAAE,CAAC,GAAG,EAAE,eAAe,KAAK,IAAI,GAAG,IAAI;IAIpE,gBAAgB,CAAC,EAAE,EAAE,CAAC,MAAM,EAAE,KAAK,KAAK,IAAI,GAAG,IAAI;IAInD,mBAAmB,CAAC,EAAE,EAAE,CAAC,MAAM,EAAE,KAAK,KAAK,IAAI,GAAG,IAAI;IAItD,SAAS,CAAC,CAAC,EAAE,GAAG,EAAE,YAAY,CAAC,CAAC,CAAC,GAAG,kBAAkB;IAKtD,OAAO,CAAC,aAAa;IAKrB,qBAAqB,IAAI,OAAO;IAIhC,IAAI,CAAC,CAAC,GAAC,GAAG,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,CAAC,EAAE,GAAG,EAAE,EAAE,OAAO,CAAC,EAAE,WAAW,CAAC,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,CAAC;IA8BjF,SAAS,CAAC,CAAC,GAAC,GAAG,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE,OAAO,CAAC,EAAE,WAAW,CAAC,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC;IAQ1E,OAAO,CAAC,iBAAiB;IAqCzB,OAAO,CAAC,OAAO;IAMf,OAAO,CAAC,QAAQ;IAOhB,OAAO,CAAC,iBAAiB;IAgBzB,OAAO,CAAC,4BAA4B;IAsBpC,OAAO,CAAC,IAAI;YAgDE,iBAAiB;IAuB/B,OAAO,CAAC,OAAO;IA4Bf,OAAO,CAAC,aAAa;IAqCrB,iBAAiB,CAAC,GAAG,EAAE,KAAK,GAAG,OAAO;IAsBtC,KAAK,CAAC,MAAM,CAAC,EAAE,kBAAkB,GAAG,IAAI;IAOxC,KAAK,CAAC,GAAG,CAAC,EAAE,KAAK;IAUjB,OAAO,CAAC,eAAe;CAK1B"} | ||
| {"version":3,"file":"client.d.ts","sourceRoot":"","sources":["../src/client.ts"],"names":[],"mappings":"AACA,OAAO,EAAe,MAAM,EAAC,MAAM,kBAAkB,CAAA;AAIrD,OAAO,EAAa,kBAAkB,EAAW,MAAM,UAAU,CAAA;AACjE,OAAO,EAAa,WAAW,EAAE,OAAO,EAAE,YAAY,EAAE,eAAe,EAAE,UAAU,EAAc,MAAM,cAAc,CAAA;AAErH,OAAO,EAAC,YAAY,EAAE,kBAAkB,EAAgB,MAAM,iBAAiB,CAAA;AAK/E,MAAM,WAAW,gBAAgB;IAC7B;;OAEG;IACH,GAAG,EAAE,MAAM,CAAA;IACX;;;;OAIG;IACH,QAAQ,CAAC,EAAE,MAAM,CAAA;IACjB;;;;OAIG;IACH,SAAS,CAAC,EAAE,MAAM,CAAA;IAClB;;OAEG;IACH,cAAc,CAAC,EAAE,MAAM,CAAA;IACvB;;OAEG;IACH,aAAa,CAAC,EAAE,MAAM,CAAA;IACtB;;;;;;;;;OASG;IACH,aAAa,CAAC,EAAE,MAAM,EAAE,CAAA;IACxB;;OAEG;IACH,gBAAgB,CAAC,EAAE,MAAM,CAAA;IACzB;;OAEG;IACH,iBAAiB,CAAC,EAAE,OAAO,CAAA;IAC3B;;OAEG;IACH,OAAO,CAAC,EAAE,WAAW,CAAA;IACrB,GAAG,CAAC,EAAE,MAAM,GAAG,IAAI,CAAA;CACtB;AAGD,MAAM,WAAW,UAAU;IACvB,GAAG,EAAE,MAAM,CAAA;IACX,cAAc,EAAE,MAAM,CAAA;IACtB,gBAAgB,EAAE,MAAM,CAAA;IACxB,qBAAqB,EAAE,MAAM,CAAA;IAC7B,eAAe,EAAE,MAAM,CAAA;CAC1B;AAGD,MAAM,WAAW,WAAW,CAAC,CAAC,GAAC,GAAG;IAC9B,QAAQ,CAAC,EAAE,MAAM,CAAA;IACjB,aAAa,CAAC,EAAE,MAAM,CAAA;IACtB,OAAO,CAAC,EAAE,MAAM,CAAA;IAChB;;;;;OAKG;IACH,cAAc,CAAC,EAAE,eAAe,CAAC,CAAC,CAAC,CAAA;IACnC,aAAa,CAAC,EAAE,cAAc,CAAC,CAAC,CAAC,CAAA;CACpC;AAGD,KAAK,eAAe,CAAC,CAAC,GAAC,GAAG,IAAI,CAAC,MAAM,EAAE,GAAG,EAAE,GAAG,EAAE,UAAU,KAAK,CAAC,CAAA;AACjE,KAAK,cAAc,CAAC,CAAC,GAAC,GAAG,IAAI,CAAC,IAAI,EAAE,YAAY,EAAE,GAAG,EAAE,UAAU,KAAK,CAAC,CAAA;AAevE,qBAAa,SAAS;IAClB,OAAO,CAAC,OAAO,CAAI;IACnB,OAAO,CAAC,KAAK,CAA4B;IACzC,SAAgB,GAAG,EAAE,MAAM,CAAA;IAC3B,OAAO,CAAC,GAAG,CAAY;IACvB,OAAO,CAAC,gBAAgB,CAAQ;IAChC,OAAO,CAAC,cAAc,CAAQ;IAC9B,OAAO,CAAC,aAAa,CAAU;IAC/B,OAAO,CAAC,aAAa,CAAQ;IAC7B,OAAO,CAAC,QAAQ,CAAQ;IACxB,OAAO,CAAC,WAAW,CAAQ;IAC3B,OAAO,CAAC,GAAG,CAAC,CAAQ;IACpB,OAAO,CAAC,IAAI,CAAC,CAAW;IACxB,OAAO,CAAC,SAAS,CAAkC;IACnD,OAAO,CAAC,mBAAmB,CAAQ;IACnC,OAAO,CAAC,qBAAqB,CAAI;IACjC,OAAO,CAAC,gBAAgB,CAAI;IAC5B,OAAO,CAAC,cAAc,CAAI;IAC1B,OAAO,CAAC,qBAAqB,CAAI;IACjC,OAAO,CAAC,iBAAiB,CAAI;IAC7B,OAAO,CAAC,YAAY,CAAI;IACxB,OAAO,CAAC,WAAW,CAAC,CAAQ;IAC5B,OAAO,CAAC,qBAAqB,CAAyC;IACtE,OAAO,CAAC,cAAc,CAAkC;IACxD,OAAO,CAAC,MAAM,CAAQ;gBAEV,OAAO,EAAE,gBAAgB;IA0BrC,OAAO,CAAC,gBAAgB;IA8BxB,cAAc,IAAI,MAAM;IAIxB,UAAU,IAAI,UAAU;IAUxB,OAAO,CAAC,cAAc;IAQtB,OAAO,CAAC,YAAY;IAQpB,uBAAuB,CAAC,EAAE,EAAE,CAAC,GAAG,EAAE,eAAe,KAAK,IAAI,GAAG,IAAI;IAIjE,0BAA0B,CAAC,EAAE,EAAE,CAAC,GAAG,EAAE,eAAe,KAAK,IAAI,GAAG,IAAI;IAIpE,gBAAgB,CAAC,EAAE,EAAE,CAAC,MAAM,EAAE,KAAK,KAAK,IAAI,GAAG,IAAI;IAInD,mBAAmB,CAAC,EAAE,EAAE,CAAC,MAAM,EAAE,KAAK,KAAK,IAAI,GAAG,IAAI;IAItD,SAAS,CAAC,CAAC,EAAE,GAAG,EAAE,YAAY,CAAC,CAAC,CAAC,GAAG,kBAAkB;IAKtD,OAAO,CAAC,aAAa;IAKrB,qBAAqB,IAAI,OAAO;IAIhC,IAAI,CAAC,CAAC,GAAC,GAAG,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,CAAC,EAAE,GAAG,EAAE,EAAE,OAAO,CAAC,EAAE,WAAW,CAAC,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,CAAC;IA8BjF,SAAS,CAAC,CAAC,GAAC,GAAG,EAAE,KAAK,EAAE,OAAO,EAAE,EAAE,OAAO,CAAC,EAAE,WAAW,CAAC,CAAC,CAAC,GAAG,OAAO,CAAC,CAAC,EAAE,CAAC;IAQ1E,OAAO,CAAC,iBAAiB;IAqCzB,OAAO,CAAC,OAAO;IAMf,OAAO,CAAC,QAAQ;IAOhB,OAAO,CAAC,iBAAiB;IAgBzB,OAAO,CAAC,4BAA4B;IAsBpC,OAAO,CAAC,IAAI;YAoDE,iBAAiB;IAuB/B,OAAO,CAAC,OAAO;IA4Bf,OAAO,CAAC,aAAa;IAqCrB,iBAAiB,CAAC,GAAG,EAAE,KAAK,GAAG,OAAO;IAsBtC,KAAK,CAAC,MAAM,CAAC,EAAE,kBAAkB,GAAG,IAAI;IAOxC,KAAK,CAAC,GAAG,CAAC,EAAE,KAAK;IAUjB,OAAO,CAAC,eAAe;CAK1B"} |
+14
-3
@@ -36,2 +36,3 @@ "use strict"; | ||
| this.notificationsReceived = 0; | ||
| this.totalResponseTime = 0; | ||
| this.backoffEpoch = 0; | ||
@@ -101,3 +102,4 @@ this.notificationListeners = []; | ||
| connectionErrors: this.connectionErrors, | ||
| notificationsReceived: this.notificationsReceived | ||
| notificationsReceived: this.notificationsReceived, | ||
| avgResponseTime: this.requestsServed > 0 ? this.totalResponseTime / this.requestsServed : 0 | ||
| }; | ||
@@ -124,3 +126,3 @@ } | ||
| removeNotificationListener(cb) { | ||
| (0, util_internal_1.removeArrayItem)(this.notificationListeners, cb); | ||
| removeItem(this.notificationListeners, cb); | ||
| } | ||
@@ -131,3 +133,3 @@ addResetListener(cb) { | ||
| removeResetListener(cb) { | ||
| (0, util_internal_1.removeArrayItem)(this.resetListeners, cb); | ||
| removeItem(this.resetListeners, cb); | ||
| } | ||
@@ -264,2 +266,3 @@ subscribe(sub) { | ||
| let promise; | ||
| const startTime = Date.now(); | ||
| if (Array.isArray(req.call)) { | ||
@@ -284,2 +287,4 @@ let call = req.call; | ||
| promise.then(result => { | ||
| const responseTimeSeconds = (Date.now() - startTime) / 1000; | ||
| this.totalResponseTime += responseTimeSeconds; | ||
| this.requestsServed += 1; | ||
@@ -482,2 +487,8 @@ if (this.backoffEpoch == backoffEpoch) { | ||
| } | ||
| function removeItem(arr, item) { | ||
| let index = arr.indexOf(item); | ||
| if (index < 0) | ||
| return; | ||
| arr.splice(index, 1); | ||
| } | ||
| //# sourceMappingURL=client.js.map |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"client.js","sourceRoot":"","sources":["../src/client.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;AAAA,uDAAwF;AACxF,6CAAqD;AACrD,2DAA4G;AAC5G,mFAAwD;AACxD,oDAA2B;AAC3B,qCAAiE;AAEjE,iCAAgC;AAChC,mDAA+E;AAC/E,2CAA+C;AAC/C,uCAA2C;AAsF3C,MAAa,SAAS;IAyBlB,YAAY,OAAyB;QAxB7B,YAAO,GAAG,CAAC,CAAA;QACX,UAAK,GAAG,IAAI,gCAAI,CAAM,UAAU,CAAC,CAAA;QAWjC,cAAS,GAAW,MAAM,CAAC,gBAAgB,CAAA;QAC3C,wBAAmB,GAAG,KAAK,CAAA;QAC3B,0BAAqB,GAAG,CAAC,CAAA;QACzB,qBAAgB,GAAG,CAAC,CAAA;QACpB,mBAAc,GAAG,CAAC,CAAA;QAClB,0BAAqB,GAAG,CAAC,CAAA;QACzB,iBAAY,GAAG,CAAC,CAAA;QAEhB,0BAAqB,GAAuC,EAAE,CAAA;QAC9D,mBAAc,GAAgC,EAAE,CAAA;QAChD,WAAM,GAAG,KAAK,CAAA;QAGlB,IAAI,CAAC,GAAG,GAAG,eAAe,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;QACvC,IAAI,CAAC,GAAG,GAAG,IAAI,CAAC,gBAAgB,CAAC,OAAO,CAAC,GAAG,EAAE,OAAO,CAAC,iBAAiB,IAAI,KAAK,EAAE,OAAO,CAAC,OAAO,CAAC,CAAA;QAClG,IAAI,CAAC,gBAAgB,GAAG,OAAO,CAAC,gBAAgB,IAAI,MAAM,CAAC,gBAAgB,CAAA;QAC3E,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC,WAAW,GAAG,OAAO,CAAC,QAAQ,IAAI,EAAE,CAAA;QACzD,IAAI,CAAC,cAAc,GAAG,OAAO,CAAC,cAAc,IAAI,CAAC,CAAA;QACjD,IAAI,CAAC,aAAa,GAAG,OAAO,CAAC,aAAa,IAAI,CAAC,CAAA;QAC/C,IAAI,CAAC,aAAa,GAAG,OAAO,CAAC,aAAa,IAAI,CAAC,EAAE,EAAE,GAAG,EAAE,GAAG,EAAE,IAAI,EAAE,KAAK,EAAE,KAAK,CAAC,CAAA;QAEhF,IAAI,CAAC,GAAG,GAAG,OAAO,CAAC,GAAG,KAAK,IAAI;YAC3B,CAAC,CAAC,SAAS;YACX,CAAC,CAAC,OAAO,CAAC,GAAG,IAAI,IAAA,qBAAY,EAAC,gBAAgB,EAAE,EAAC,MAAM,EAAE,IAAI,CAAC,GAAG,EAAC,CAAC,CAAA;QAEvE,IAAI,OAAO,CAAC,SAAS,EAAE,CAAC;YACpB,IAAA,gBAAM,EAAC,OAAO,CAAC,SAAS,GAAG,CAAC,CAAC,CAAA;YAC7B,IAAI,MAAM,GAAG,EAAE,CAAA;YACf,IAAI,QAAQ,GAAG,GAAG,CAAA;YAClB,IAAI,OAAO,CAAC,SAAS,GAAG,CAAC,EAAE,CAAC;gBACxB,QAAQ,GAAG,IAAI,CAAC,IAAI,CAAC,IAAI,GAAG,CAAC,OAAO,CAAC,SAAS,GAAG,MAAM,CAAC,CAAC,CAAA;YAC7D,CAAC;YACD,IAAI,CAAC,IAAI,GAAG,IAAI,gBAAS,CAAC,MAAM,EAAE,QAAQ,CAAC,CAAA;YAC3C,IAAI,CAAC,SAAS,GAAG,OAAO,CAAC,SAAS,CAAA;YAClC,IAAI,CAAC,gBAAgB,GAAG,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,gBAAgB,EAAE,IAAI,CAAC,GAAG,CAAC,CAAC,EAAE,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,GAAG,CAAC,CAAC,CAAC,CAAC,CAAA;QACxG,CAAC;IACL,CAAC;IAEO,gBAAgB,CAAC,GAAW,EAAE,iBAA0B,EAAE,OAAqB;QACnF,IAAI,QAAQ,GAAG,IAAI,GAAG,CAAC,GAAG,CAAC,CAAC,QAAQ,CAAA;QACpC,QAAO,QAAQ,EAAE,CAAC;YACd,KAAK,KAAK,CAAC;YACX,KAAK,MAAM;gBACP,OAAO,IAAI,iBAAY,CAAC;oBACpB,GAAG;oBACH,OAAO;oBACP,qBAAqB,EAAE,GAAG,CAAC,EAAE,CAAC,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC;oBACtD,OAAO,EAAE,MAAM,CAAC,EAAE;wBACd,IAAI,IAAI,CAAC,MAAM;4BAAE,OAAM;wBACvB,KAAK,IAAI,EAAE,IAAI,IAAI,CAAC,cAAc,EAAE,CAAC;4BACjC,IAAI,CAAC,YAAY,CAAC,EAAE,EAAE,MAAM,CAAC,CAAA;wBACjC,CAAC;oBACL,CAAC;oBACD,iBAAiB;iBACpB,CAAC,CAAA;YACN,KAAK,OAAO,CAAC;YACb,KAAK,QAAQ;gBACT,OAAO,IAAI,qBAAc,CAAC;oBACtB,GAAG;oBACH,OAAO;oBACP,GAAG,EAAE,IAAI,CAAC,GAAG;oBACb,iBAAiB;iBACpB,CAAC,CAAA;YACN;gBACI,MAAM,IAAI,SAAS,CAAC,yBAAyB,QAAQ,EAAE,CAAC,CAAA;QAChE,CAAC;IACL,CAAC;IAED,cAAc;QACV,OAAO,IAAI,CAAC,WAAW,CAAA;IAC3B,CAAC;IAED,UAAU;QACN,OAAO;YACH,GAAG,EAAE,IAAI,CAAC,GAAG;YACb,cAAc,EAAE,IAAI,CAAC,cAAc;YACnC,gBAAgB,EAAE,IAAI,CAAC,gBAAgB;YACvC,qBAAqB,EAAE,IAAI,CAAC,qBAAqB;SACpD,CAAA;IACL,CAAC;IAEO,cAAc,CAAC,GAAoB;QACvC,IAAI,CAAC,qBAAqB,IAAI,CAAC,CAAA;QAC/B,IAAI,CAAC,GAAG,EAAE,KAAK,CAAC,EAAC,MAAM,EAAE,GAAG,EAAC,EAAE,kBAAkB,CAAC,CAAA;QAClD,KAAK,IAAI,EAAE,IAAI,IAAI,CAAC,qBAAqB,EAAE,CAAC;YACxC,IAAI,CAAC,YAAY,CAAC,EAAE,EAAE,GAAG,CAAC,CAAA;QAC9B,CAAC;IACL,CAAC;IAEO,YAAY,CAAI,EAAoB,EAAE,GAAM;QAChD,IAAI,CAAC;YACD,EAAE,CAAC,GAAG,CAAC,CAAA;QACX,CAAC;QAAC,OAAM,GAAQ,EAAE,CAAC;YACf,IAAI,CAAC,GAAG,EAAE,KAAK,CAAC,GAAG,EAAE,gBAAgB,CAAC,CAAA;QAC1C,CAAC;IACL,CAAC;IAED,uBAAuB,CAAC,EAAkC;QACtD,IAAI,CAAC,qBAAqB,CAAC,IAAI,CAAC,EAAE,CAAC,CAAA;IACvC,CAAC;IAED,0BAA0B,CAAC,EAAkC;QACzD,IAAA,+BAAe,EAAC,IAAI,CAAC,qBAAqB,EAAE,EAAE,CAAC,CAAA;IACnD,CAAC;IAED,gBAAgB,CAAC,EAA2B;QACxC,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,EAAE,CAAC,CAAA;IAChC,CAAC;IAED,mBAAmB,CAAC,EAA2B;QAC3C,IAAA,+BAAe,EAAC,IAAI,CAAC,cAAc,EAAE,EAAE,CAAC,CAAA;IAC5C,CAAC;IAED,SAAS,CAAI,GAAoB;QAC7B,OAAO,IAAI,CAAC,aAAa,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAA;IACxC,CAAC;IAGO,aAAa;QACjB,IAAA,gBAAM,EAAC,IAAI,CAAC,qBAAqB,EAAE,EAAE,2DAA2D,CAAC,CAAA;QACjG,OAAO,IAAI,6BAAa,CAAC,IAAI,CAAC,CAAA;IAClC,CAAC;IAED,qBAAqB;QACjB,OAAO,IAAI,CAAC,GAAG,YAAY,iBAAY,CAAA;IAC3C,CAAC;IAED,IAAI,CAAQ,MAAc,EAAE,MAAc,EAAE,OAAwB;QAChE,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,IAAI,IAAI,GAAe;gBACnB,EAAE,EAAE,IAAI,CAAC,OAAO,IAAI,CAAC;gBACrB,OAAO,EAAE,KAAK;gBACd,MAAM;gBACN,MAAM;aACT,CAAA;YAED,IAAI,IAAI,CAAC,GAAG,EAAE,OAAO,EAAE,EAAE,CAAC;gBACtB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC;oBACX,KAAK,EAAE,IAAI,CAAC,EAAE;oBACd,SAAS,EAAE,IAAI,CAAC,MAAM;oBACtB,SAAS,EAAE,IAAI,CAAC,MAAM;iBACzB,EAAE,UAAU,CAAC,CAAA;YAClB,CAAC;YAED,IAAI,CAAC,OAAO,CAAC;gBACT,IAAI;gBACJ,QAAQ,EAAE,OAAO,EAAE,QAAQ,IAAI,CAAC;gBAChC,OAAO,EAAE,OAAO,EAAE,OAAO,IAAI,IAAI,CAAC,cAAc;gBAChD,aAAa,EAAE,OAAO,EAAE,aAAa,IAAI,IAAI,CAAC,aAAa;gBAC3D,OAAO;gBACP,MAAM;gBACN,cAAc,EAAE,OAAO,EAAE,cAAc;gBACvC,aAAa,EAAE,OAAO,EAAE,aAAa;aACxC,CAAC,CAAA;QACN,CAAC,CAAC,CAAA;IACN,CAAC;IAED,SAAS,CAAQ,KAAgB,EAAE,OAAwB;QACvD,OAAO,IAAA,iCAAiB,EACpB,IAAI,CAAC,gBAAgB,EACrB,KAAK,EACL,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,iBAAiB,CAAC,CAAC,EAAE,OAAO,CAAC,CAC1C,CAAA;IACL,CAAC;IAEO,iBAAiB,CAAC,KAAgB,EAAE,OAAqB;QAC7D,IAAI,KAAK,CAAC,MAAM,IAAI,CAAC;YAAE,OAAO,OAAO,CAAC,OAAO,CAAC,EAAE,CAAC,CAAA;QACjD,IAAI,KAAK,CAAC,MAAM,IAAI,CAAC;YAAE,OAAO,IAAI,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,MAAM,EAAE,KAAK,CAAC,CAAC,CAAC,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC,GAAG,CAAC,CAAC,CAAA;QACrG,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,IAAI,KAAK,CAAC,MAAM,IAAI,CAAC;gBAAE,OAAO,OAAO,CAAC,EAAE,CAAC,CAAA;YAEzC,IAAI,KAAK,GAAiB,KAAK,CAAC,GAAG,CAAC,EAAE,CAAC,EAAE;gBACrC,OAAO;oBACH,GAAG,EAAE;oBACL,EAAE,EAAE,IAAI,CAAC,OAAO,IAAI,CAAC;oBACrB,OAAO,EAAE,KAAK;iBACjB,CAAA;YACL,CAAC,CAAC,CAAA;YAEF,IAAI,IAAI,CAAC,GAAG,EAAE,OAAO,EAAE,EAAE,CAAC;gBACtB,KAAK,IAAI,IAAI,IAAI,KAAK,EAAE,CAAC;oBACrB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC;wBACX,KAAK,EAAE,IAAI,CAAC,EAAE;wBACd,SAAS,EAAE,IAAI,CAAC,MAAM;wBACtB,SAAS,EAAE,IAAI,CAAC,MAAM;qBACzB,EAAE,UAAU,CAAC,CAAA;gBAClB,CAAC;YACL,CAAC;YAED,IAAI,CAAC,OAAO,CAAC;gBACT,IAAI,EAAE,KAAK;gBACX,QAAQ,EAAE,OAAO,EAAE,QAAQ,IAAI,CAAC;gBAChC,OAAO,EAAE,OAAO,EAAE,OAAO,IAAI,IAAI,CAAC,cAAc;gBAChD,aAAa,EAAE,OAAO,EAAE,aAAa,IAAI,IAAI,CAAC,aAAa;gBAC3D,OAAO;gBACP,MAAM;gBACN,cAAc,EAAE,OAAO,EAAE,cAAc;gBACvC,aAAa,EAAE,OAAO,EAAE,aAAa;aACxC,CAAC,CAAA;QACN,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,OAAO,CAAC,GAAQ;QACpB,IAAI,CAAC,eAAe,EAAE,CAAA;QACtB,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;QACpB,IAAI,CAAC,QAAQ,EAAE,CAAA;IACnB,CAAC;IAEO,QAAQ;QACZ,IAAI,IAAI,CAAC,mBAAmB,IAAI,IAAI,CAAC,MAAM;YAAE,OAAM;QACnD,IAAI,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,IAAI,IAAI,IAAI,IAAI,CAAC,QAAQ,IAAI,CAAC;YAAE,OAAM;QAC3D,IAAI,CAAC,mBAAmB,GAAG,IAAI,CAAA;QAC/B,OAAO,CAAC,OAAO,EAAE,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC,iBAAiB,EAAE,CAAC,CAAA;IAC1D,CAAC;IAEO,iBAAiB;QACrB,IAAI,CAAC,iBAAiB,EAAE,CAAC,IAAI,CAAC,GAAG,EAAE;YAC/B,IAAI,IAAI,CAAC,IAAI,EAAE,CAAC;gBACZ,IAAI,CAAC,4BAA4B,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;YAChD,CAAC;iBAAM,CAAC;gBACJ,IAAI,IAAI,CAAC,MAAM;oBAAE,OAAM;gBACvB,IAAI,CAAC,mBAAmB,GAAG,KAAK,CAAA;gBAChC,OAAO,IAAI,CAAC,QAAQ,GAAG,CAAC,IAAI,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,EAAE,CAAC;oBAC5C,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,KAAK,CAAC,GAAG,EAAG,CAAC,CAAA;gBAChC,CAAC;YACL,CAAC;QACL,CAAC,EAAE,GAAG,CAAC,EAAE;YACL,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;QACnB,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,4BAA4B,CAAC,SAAoB;QACrD,IAAI,IAAI,CAAC,MAAM;YAAE,OAAM;QACvB,IAAI,CAAC,mBAAmB,GAAG,KAAK,CAAA;QAEhC,IAAI,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;QACpB,IAAI,IAAI,GAAG,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;QACjC,IAAI,YAAY,GAAG,IAAI,CAAC,SAAS,GAAG,IAAI,CAAA;QAExC,OAAO,IAAI,CAAC,QAAQ,GAAG,CAAC,IAAI,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,EAAE,CAAC;YAC5C,IAAI,YAAY,IAAI,CAAC,EAAE,CAAC;gBACpB,IAAI,CAAC,mBAAmB,GAAG,IAAI,CAAA;gBAC/B,UAAU,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC,iBAAiB,EAAE,EAAE,SAAS,CAAC,QAAQ,CAAC,CAAA;gBAC9D,OAAM;YACV,CAAC;YACD,IAAI,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,EAAG,CAAA;YAC3B,IAAI,IAAI,GAAG,KAAK,CAAC,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,CAAA;YACxD,YAAY,IAAI,IAAI,CAAA;YACpB,SAAS,CAAC,GAAG,CAAC,IAAI,EAAE,GAAG,CAAC,CAAA;YACxB,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;QAClB,CAAC;IACL,CAAC;IAEO,IAAI,CAAC,GAAQ;QACjB,IAAI,CAAC,QAAQ,IAAI,CAAC,CAAA;QAClB,IAAI,YAAY,GAAG,IAAI,CAAC,YAAY,CAAA;QACpC,IAAI,OAAqB,CAAA;QACzB,IAAI,KAAK,CAAC,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;YAC1B,IAAI,IAAI,GAAG,GAAG,CAAC,IAAI,CAAA;YACnB,IAAI,CAAC,GAAG,EAAE,KAAK,CAAC,EAAC,UAAU,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,EAAE,EAAE,IAAA,oBAAI,EAAC,IAAI,CAAC,CAAC,EAAE,CAAC,EAAC,EAAE,UAAU,CAAC,CAAA;YACtE,OAAO,GAAG,IAAI,CAAC,GAAG,CAAC,SAAS,CAAC,IAAI,EAAE,GAAG,CAAC,OAAO,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,EAAE;gBACvD,IAAI,MAAM,GAAG,IAAI,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,CAAA;gBAClC,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,GAAG,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;oBAClC,MAAM,CAAC,CAAC,CAAC,GAAG,IAAI,CAAC,aAAa,CAAC,IAAI,CAAC,CAAC,CAAC,EAAE,GAAG,CAAC,CAAC,CAAC,EAAE,GAAG,CAAC,cAAc,EAAE,GAAG,CAAC,aAAa,CAAC,CAAA;gBAC1F,CAAC;gBACD,OAAO,MAAM,CAAA;YACjB,CAAC,CAAC,CAAA;QACN,CAAC;aAAM,CAAC;YACJ,IAAI,IAAI,GAAG,GAAG,CAAC,IAAI,CAAA;YACnB,IAAI,CAAC,GAAG,EAAE,KAAK,CAAC,EAAC,KAAK,EAAE,IAAI,CAAC,EAAE,EAAC,EAAE,UAAU,CAAC,CAAA;YAC7C,OAAO,GAAG,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,IAAI,EAAE,GAAG,CAAC,OAAO,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,EAAE;gBAClD,OAAO,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,GAAG,EAAE,GAAG,CAAC,cAAc,EAAE,GAAG,CAAC,aAAa,CAAC,CAAA;YAC/E,CAAC,CAAC,CAAA;QACN,CAAC;QACD,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,EAAE;YAClB,IAAI,CAAC,cAAc,IAAI,CAAC,CAAA;YACxB,IAAI,IAAI,CAAC,YAAY,IAAI,YAAY,EAAE,CAAC;gBACpC,IAAI,CAAC,qBAAqB,GAAG,CAAC,CAAA;YAClC,CAAC;YACD,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,CAAA;QACvB,CAAC,EAAE,GAAG,CAAC,EAAE;YACL,IAAI,IAAI,CAAC,MAAM;gBAAE,OAAO,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;YACvC,IAAI,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,EAAE,CAAC;gBAC9B,IAAI,GAAG,CAAC,aAAa,GAAG,CAAC,EAAE,CAAC;oBACxB,GAAG,CAAC,aAAa,IAAI,CAAC,CAAA;oBACtB,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;gBACrB,CAAC;qBAAM,CAAC;oBACJ,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;gBACnB,CAAC;gBACD,IAAI,IAAI,CAAC,YAAY,IAAI,YAAY,EAAE,CAAC;oBACpC,IAAI,CAAC,OAAO,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;gBAC1B,CAAC;YACL,CAAC;iBAAM,CAAC;gBACJ,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;YACnB,CAAC;QACL,CAAC,CAAC,CAAC,OAAO,CAAC,GAAG,EAAE;YACZ,IAAI,CAAC,QAAQ,IAAI,CAAC,CAAA;YAClB,IAAI,CAAC,QAAQ,EAAE,CAAA;QACnB,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,KAAK,CAAC,iBAAiB;QAC3B,OAAO,IAAI,EAAE,CAAC;YACV,IAAI,IAAI,CAAC,WAAW,IAAI,IAAI,EAAE,CAAC;gBAC3B,IAAI,KAAK,GAAG,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,WAAW,GAAG,IAAI,CAAC,GAAG,EAAE,EAAE,CAAC,CAAC,CAAA;gBACtD,IAAI,CAAC,WAAW,GAAG,SAAS,CAAA;gBAC5B,IAAI,KAAK,GAAG,CAAC,EAAE,CAAC;oBACZ,MAAM,IAAA,oBAAI,EAAC,KAAK,CAAC,CAAA;gBACrB,CAAC;YACL,CAAC;YACD,IAAI,IAAI,CAAC,MAAM;gBAAE,OAAM;YACvB,IAAI,CAAC;gBACD,OAAO,MAAM,IAAI,CAAC,GAAG,CAAC,OAAO,EAAE,CAAA;YACnC,CAAC;YAAC,OAAM,GAAQ,EAAE,CAAC;gBACf,IAAI,IAAI,CAAC,MAAM;oBAAE,OAAM;gBACvB,IAAI,GAAG,YAAY,2BAAkB,EAAE,CAAC;oBACpC,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;gBACrB,CAAC;qBAAM,CAAC;oBACJ,MAAM,GAAG,CAAA;gBACb,CAAC;YACL,CAAC;QACL,CAAC;IACL,CAAC;IAEO,OAAO,CAAC,MAAa,EAAE,GAAS;QACpC,IAAI,CAAC,YAAY,IAAI,CAAC,CAAA;QACtB,IAAI,CAAC,qBAAqB,IAAI,CAAC,CAAA;QAC/B,IAAI,CAAC,gBAAgB,IAAI,CAAC,CAAA;QAE1B,IAAI,YAAY,GAAG,IAAI,CAAC,aAAa,CACjC,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,qBAAqB,EAAE,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,GAAG,CAAC,CACtE,CAAA;QAED,IAAI,CAAC,WAAW,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,YAAY,CAAA;QAE5C,IAAI,IAAI,CAAC,GAAG,EAAE,MAAM,EAAE,EAAE,CAAC;YACrB,IAAI,gBAAgB,GAAG,SAAS,CAAA;YAChC,IAAI,MAAM,YAAY,uBAAS;gBAC3B,MAAM,CAAC,QAAQ,CAAC,IAAI;gBACpB,CAAC,MAAM,CAAC,QAAQ,CAAC,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,EAAE,QAAQ,CAAC,WAAW,CAAC,EACrE,CAAC;gBACC,gBAAgB,GAAG,MAAM,CAAC,QAAQ,CAAC,IAAI,CAAA;YAC3C,CAAC;YACD,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC;gBACV,MAAM,EAAE,MAAM,CAAC,QAAQ,EAAE;gBACzB,gBAAgB;gBAChB,OAAO,EAAE,GAAG,EAAE,IAAI;aACrB,EAAE,oBAAoB,CAAC,CAAA;YACxB,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,+BAA+B,YAAY,IAAI,CAAC,CAAA;QAClE,CAAC;IACL,CAAC;IAEO,aAAa,CACjB,IAAgB,EAChB,GAAgB,EAChB,cAA2C,EAC3C,aAAyC;QAEzC,IAAI,IAAI,CAAC,GAAG,EAAE,OAAO,EAAE,EAAE,CAAC;YACtB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC;gBACX,KAAK,EAAE,IAAI,CAAC,EAAE;gBACd,SAAS,EAAE,IAAI,CAAC,MAAM;gBACtB,SAAS,EAAE,IAAI,CAAC,MAAM;gBACtB,WAAW,EAAE,GAAG;aACnB,EAAE,cAAc,CAAC,CAAA;QACtB,CAAC;QACD,IAAI,CAAC;YACD,IAAI,GAAG,CAAC,KAAK,EAAE,CAAC;gBACZ,IAAI,aAAa,EAAE,CAAC;oBAChB,OAAO,aAAa,CAAC,GAAG,CAAC,KAAK,EAAE,IAAI,CAAC,CAAA;gBACzC,CAAC;qBAAM,CAAC;oBACJ,MAAM,IAAI,iBAAQ,CAAC,GAAG,CAAC,KAAK,CAAC,CAAA;gBACjC,CAAC;YACL,CAAC;iBAAM,IAAI,cAAc,EAAE,CAAC;gBACxB,OAAO,cAAc,CAAC,GAAG,CAAC,MAAM,EAAE,IAAI,CAAC,CAAA;YAC3C,CAAC;iBAAM,CAAC;gBACJ,OAAO,GAAG,CAAC,MAAM,CAAA;YACrB,CAAC;QACL,CAAC;QAAC,OAAM,GAAQ,EAAE,CAAC;YACf,MAAM,IAAA,+BAAe,EAAC,GAAG,EAAE;gBACvB,MAAM,EAAE,IAAI,CAAC,GAAG;gBAChB,KAAK,EAAE,IAAI,CAAC,EAAE;gBACd,SAAS,EAAE,IAAI,CAAC,MAAM;gBACtB,SAAS,EAAE,IAAI,CAAC,MAAM;gBACtB,WAAW,EAAE,GAAG;aACnB,CAAC,CAAA;QACN,CAAC;IACL,CAAC;IAED,iBAAiB,CAAC,GAAU;QACxB,IAAI,GAAG,YAAY,mBAAU;YAAE,OAAO,IAAI,CAAA;QAC1C,IAAI,gBAAgB,CAAC,GAAG,CAAC;YAAE,OAAO,IAAI,CAAA;QACtC,IAAI,uBAAuB,CAAC,GAAG,CAAC;YAAE,OAAO,IAAI,CAAA;QAC7C,IAAI,sBAAsB,CAAC,GAAG,CAAC;YAAE,OAAO,IAAI,CAAA;QAC5C,IAAI,GAAG,YAAY,2BAAkB;YAAE,OAAO,IAAI,CAAA;QAClD,IAAI,IAAA,mCAAqB,EAAC,GAAG,CAAC;YAAE,OAAO,IAAI,CAAA;QAC3C,IAAI,GAAG,YAAY,8BAAgB;YAAE,OAAO,IAAI,CAAA;QAChD,IAAI,GAAG,YAAY,uBAAS,EAAE,CAAC;YAC3B,QAAO,GAAG,CAAC,QAAQ,CAAC,MAAM,EAAE,CAAC;gBACzB,KAAK,GAAG,CAAC;gBACT,KAAK,GAAG,CAAC;gBACT,KAAK,GAAG,CAAC;gBACT,KAAK,GAAG;oBACJ,OAAO,IAAI,CAAA;gBACf;oBACI,OAAO,KAAK,CAAA;YACpB,CAAC;QACL,CAAC;QACD,OAAO,KAAK,CAAA;IAChB,CAAC;IAED,KAAK,CAAC,MAA2B;QAC7B,IAAI,IAAI,CAAC,MAAM;YAAE,OAAM;QACvB,IAAI,IAAI,CAAC,GAAG,YAAY,iBAAY,EAAE,CAAC;YACnC,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,MAAM,IAAI,IAAI,2BAAkB,CAAC,kBAAkB,CAAC,CAAC,CAAA;QACxE,CAAC;IACL,CAAC;IAED,KAAK,CAAC,GAAW;QACb,IAAI,IAAI,CAAC,MAAM;YAAE,OAAM;QACvB,IAAI,CAAC,MAAM,GAAG,IAAI,CAAA;QAClB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;QACnB,OAAO,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,EAAE,CAAC,CAAC,cAAc;YACtC,IAAI,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,EAAG,CAAA;YAC3B,GAAG,CAAC,MAAM,CAAC,GAAG,IAAI,IAAI,KAAK,CAAC,sBAAsB,CAAC,CAAC,CAAA;QACxD,CAAC;IACL,CAAC;IAEO,eAAe;QACnB,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;YACd,MAAM,IAAI,KAAK,CAAC,sBAAsB,CAAC,CAAA;QAC3C,CAAC;IACL,CAAC;CACJ;AA9bD,8BA8bC;AA3TW;IADP,mBAAG;;;oCACqB,6BAAa;8CAGrC;AA2TL,SAAS,UAAU,CAAC,CAAM,EAAE,CAAM;IAC9B,IAAI,CAAC,GAAG,CAAC,CAAC,QAAQ,GAAG,CAAC,CAAC,QAAQ,CAAA;IAC/B,IAAI,CAAC,IAAI,CAAC;QAAE,OAAO,CAAC,CAAA;IACpB,OAAO,eAAe,CAAC,CAAC,CAAC,GAAG,eAAe,CAAC,CAAC,CAAC,CAAA;AAClD,CAAC;AAGD,SAAS,eAAe,CAAC,GAAQ;IAC7B,IAAI,KAAK,CAAC,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;QAC1B,OAAO,GAAG,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,EAAE,CAAA;IACzB,CAAC;SAAM,CAAC;QACJ,OAAO,GAAG,CAAC,IAAI,CAAC,EAAE,CAAA;IACtB,CAAC;AACL,CAAC;AAGD,SAAS,eAAe,CAAC,GAAW;IAChC,IAAI,CAAC,GAAG,IAAI,GAAG,CAAC,GAAG,CAAC,CAAA;IACpB,CAAC,CAAC,QAAQ,GAAG,EAAE,CAAA;IACf,CAAC,CAAC,QAAQ,GAAG,EAAE,CAAA;IACf,OAAO,CAAC,CAAC,QAAQ,EAAE,CAAA;AACvB,CAAC;AAGD,SAAS,gBAAgB,CAAC,GAAY;IAClC,OAAO,GAAG,YAAY,iBAAQ,IAAI,aAAa,CAAC,IAAI,CAAC,GAAG,CAAC,OAAO,CAAC,CAAA;AACrE,CAAC;AAGD,SAAS,uBAAuB,CAAC,GAAY;IACzC,OAAO,GAAG,YAAY,iBAAQ,IAAI,oBAAoB,CAAC,IAAI,CAAC,GAAG,CAAC,OAAO,CAAC,CAAA;AAC5E,CAAC;AAED,SAAS,sBAAsB,CAAC,GAAY;IACxC,OAAO,GAAG,YAAY,iBAAQ,IAAI,qBAAqB,CAAC,IAAI,CAAC,GAAG,CAAC,OAAO,CAAC,CAAA;AAC7E,CAAC"} | ||
| {"version":3,"file":"client.js","sourceRoot":"","sources":["../src/client.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;AAAA,uDAAwF;AACxF,6CAAqD;AACrD,2DAA2F;AAC3F,mFAAwD;AACxD,oDAA2B;AAC3B,qCAAiE;AAEjE,iCAAgC;AAChC,mDAA+E;AAC/E,2CAA+C;AAC/C,uCAA2C;AA+F3C,MAAa,SAAS;IA0BlB,YAAY,OAAyB;QAzB7B,YAAO,GAAG,CAAC,CAAA;QACX,UAAK,GAAG,IAAI,gCAAI,CAAM,UAAU,CAAC,CAAA;QAWjC,cAAS,GAAW,MAAM,CAAC,gBAAgB,CAAA;QAC3C,wBAAmB,GAAG,KAAK,CAAA;QAC3B,0BAAqB,GAAG,CAAC,CAAA;QACzB,qBAAgB,GAAG,CAAC,CAAA;QACpB,mBAAc,GAAG,CAAC,CAAA;QAClB,0BAAqB,GAAG,CAAC,CAAA;QACzB,sBAAiB,GAAG,CAAC,CAAA;QACrB,iBAAY,GAAG,CAAC,CAAA;QAEhB,0BAAqB,GAAuC,EAAE,CAAA;QAC9D,mBAAc,GAAgC,EAAE,CAAA;QAChD,WAAM,GAAG,KAAK,CAAA;QAGlB,IAAI,CAAC,GAAG,GAAG,eAAe,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;QACvC,IAAI,CAAC,GAAG,GAAG,IAAI,CAAC,gBAAgB,CAAC,OAAO,CAAC,GAAG,EAAE,OAAO,CAAC,iBAAiB,IAAI,KAAK,EAAE,OAAO,CAAC,OAAO,CAAC,CAAA;QAClG,IAAI,CAAC,gBAAgB,GAAG,OAAO,CAAC,gBAAgB,IAAI,MAAM,CAAC,gBAAgB,CAAA;QAC3E,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC,WAAW,GAAG,OAAO,CAAC,QAAQ,IAAI,EAAE,CAAA;QACzD,IAAI,CAAC,cAAc,GAAG,OAAO,CAAC,cAAc,IAAI,CAAC,CAAA;QACjD,IAAI,CAAC,aAAa,GAAG,OAAO,CAAC,aAAa,IAAI,CAAC,CAAA;QAC/C,IAAI,CAAC,aAAa,GAAG,OAAO,CAAC,aAAa,IAAI,CAAC,EAAE,EAAE,GAAG,EAAE,GAAG,EAAE,IAAI,EAAE,KAAK,EAAE,KAAK,CAAC,CAAA;QAEhF,IAAI,CAAC,GAAG,GAAG,OAAO,CAAC,GAAG,KAAK,IAAI;YAC3B,CAAC,CAAC,SAAS;YACX,CAAC,CAAC,OAAO,CAAC,GAAG,IAAI,IAAA,qBAAY,EAAC,gBAAgB,EAAE,EAAC,MAAM,EAAE,IAAI,CAAC,GAAG,EAAC,CAAC,CAAA;QAEvE,IAAI,OAAO,CAAC,SAAS,EAAE,CAAC;YACpB,IAAA,gBAAM,EAAC,OAAO,CAAC,SAAS,GAAG,CAAC,CAAC,CAAA;YAC7B,IAAI,MAAM,GAAG,EAAE,CAAA;YACf,IAAI,QAAQ,GAAG,GAAG,CAAA;YAClB,IAAI,OAAO,CAAC,SAAS,GAAG,CAAC,EAAE,CAAC;gBACxB,QAAQ,GAAG,IAAI,CAAC,IAAI,CAAC,IAAI,GAAG,CAAC,OAAO,CAAC,SAAS,GAAG,MAAM,CAAC,CAAC,CAAA;YAC7D,CAAC;YACD,IAAI,CAAC,IAAI,GAAG,IAAI,gBAAS,CAAC,MAAM,EAAE,QAAQ,CAAC,CAAA;YAC3C,IAAI,CAAC,SAAS,GAAG,OAAO,CAAC,SAAS,CAAA;YAClC,IAAI,CAAC,gBAAgB,GAAG,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,gBAAgB,EAAE,IAAI,CAAC,GAAG,CAAC,CAAC,EAAE,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,GAAG,CAAC,CAAC,CAAC,CAAC,CAAA;QACxG,CAAC;IACL,CAAC;IAEO,gBAAgB,CAAC,GAAW,EAAE,iBAA0B,EAAE,OAAqB;QACnF,IAAI,QAAQ,GAAG,IAAI,GAAG,CAAC,GAAG,CAAC,CAAC,QAAQ,CAAA;QACpC,QAAO,QAAQ,EAAE,CAAC;YACd,KAAK,KAAK,CAAC;YACX,KAAK,MAAM;gBACP,OAAO,IAAI,iBAAY,CAAC;oBACpB,GAAG;oBACH,OAAO;oBACP,qBAAqB,EAAE,GAAG,CAAC,EAAE,CAAC,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC;oBACtD,OAAO,EAAE,MAAM,CAAC,EAAE;wBACd,IAAI,IAAI,CAAC,MAAM;4BAAE,OAAM;wBACvB,KAAK,IAAI,EAAE,IAAI,IAAI,CAAC,cAAc,EAAE,CAAC;4BACjC,IAAI,CAAC,YAAY,CAAC,EAAE,EAAE,MAAM,CAAC,CAAA;wBACjC,CAAC;oBACL,CAAC;oBACD,iBAAiB;iBACpB,CAAC,CAAA;YACN,KAAK,OAAO,CAAC;YACb,KAAK,QAAQ;gBACT,OAAO,IAAI,qBAAc,CAAC;oBACtB,GAAG;oBACH,OAAO;oBACP,GAAG,EAAE,IAAI,CAAC,GAAG;oBACb,iBAAiB;iBACpB,CAAC,CAAA;YACN;gBACI,MAAM,IAAI,SAAS,CAAC,yBAAyB,QAAQ,EAAE,CAAC,CAAA;QAChE,CAAC;IACL,CAAC;IAED,cAAc;QACV,OAAO,IAAI,CAAC,WAAW,CAAA;IAC3B,CAAC;IAED,UAAU;QACN,OAAO;YACH,GAAG,EAAE,IAAI,CAAC,GAAG;YACb,cAAc,EAAE,IAAI,CAAC,cAAc;YACnC,gBAAgB,EAAE,IAAI,CAAC,gBAAgB;YACvC,qBAAqB,EAAE,IAAI,CAAC,qBAAqB;YACjD,eAAe,EAAE,IAAI,CAAC,cAAc,GAAG,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,iBAAiB,GAAG,IAAI,CAAC,cAAc,CAAC,CAAC,CAAC,CAAC;SAC9F,CAAA;IACL,CAAC;IAEO,cAAc,CAAC,GAAoB;QACvC,IAAI,CAAC,qBAAqB,IAAI,CAAC,CAAA;QAC/B,IAAI,CAAC,GAAG,EAAE,KAAK,CAAC,EAAC,MAAM,EAAE,GAAG,EAAC,EAAE,kBAAkB,CAAC,CAAA;QAClD,KAAK,IAAI,EAAE,IAAI,IAAI,CAAC,qBAAqB,EAAE,CAAC;YACxC,IAAI,CAAC,YAAY,CAAC,EAAE,EAAE,GAAG,CAAC,CAAA;QAC9B,CAAC;IACL,CAAC;IAEO,YAAY,CAAI,EAAoB,EAAE,GAAM;QAChD,IAAI,CAAC;YACD,EAAE,CAAC,GAAG,CAAC,CAAA;QACX,CAAC;QAAC,OAAM,GAAQ,EAAE,CAAC;YACf,IAAI,CAAC,GAAG,EAAE,KAAK,CAAC,GAAG,EAAE,gBAAgB,CAAC,CAAA;QAC1C,CAAC;IACL,CAAC;IAED,uBAAuB,CAAC,EAAkC;QACtD,IAAI,CAAC,qBAAqB,CAAC,IAAI,CAAC,EAAE,CAAC,CAAA;IACvC,CAAC;IAED,0BAA0B,CAAC,EAAkC;QACzD,UAAU,CAAC,IAAI,CAAC,qBAAqB,EAAE,EAAE,CAAC,CAAA;IAC9C,CAAC;IAED,gBAAgB,CAAC,EAA2B;QACxC,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,EAAE,CAAC,CAAA;IAChC,CAAC;IAED,mBAAmB,CAAC,EAA2B;QAC3C,UAAU,CAAC,IAAI,CAAC,cAAc,EAAE,EAAE,CAAC,CAAA;IACvC,CAAC;IAED,SAAS,CAAI,GAAoB;QAC7B,OAAO,IAAI,CAAC,aAAa,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAA;IACxC,CAAC;IAGO,aAAa;QACjB,IAAA,gBAAM,EAAC,IAAI,CAAC,qBAAqB,EAAE,EAAE,2DAA2D,CAAC,CAAA;QACjG,OAAO,IAAI,6BAAa,CAAC,IAAI,CAAC,CAAA;IAClC,CAAC;IAED,qBAAqB;QACjB,OAAO,IAAI,CAAC,GAAG,YAAY,iBAAY,CAAA;IAC3C,CAAC;IAED,IAAI,CAAQ,MAAc,EAAE,MAAc,EAAE,OAAwB;QAChE,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,IAAI,IAAI,GAAe;gBACnB,EAAE,EAAE,IAAI,CAAC,OAAO,IAAI,CAAC;gBACrB,OAAO,EAAE,KAAK;gBACd,MAAM;gBACN,MAAM;aACT,CAAA;YAED,IAAI,IAAI,CAAC,GAAG,EAAE,OAAO,EAAE,EAAE,CAAC;gBACtB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC;oBACX,KAAK,EAAE,IAAI,CAAC,EAAE;oBACd,SAAS,EAAE,IAAI,CAAC,MAAM;oBACtB,SAAS,EAAE,IAAI,CAAC,MAAM;iBACzB,EAAE,UAAU,CAAC,CAAA;YAClB,CAAC;YAED,IAAI,CAAC,OAAO,CAAC;gBACT,IAAI;gBACJ,QAAQ,EAAE,OAAO,EAAE,QAAQ,IAAI,CAAC;gBAChC,OAAO,EAAE,OAAO,EAAE,OAAO,IAAI,IAAI,CAAC,cAAc;gBAChD,aAAa,EAAE,OAAO,EAAE,aAAa,IAAI,IAAI,CAAC,aAAa;gBAC3D,OAAO;gBACP,MAAM;gBACN,cAAc,EAAE,OAAO,EAAE,cAAc;gBACvC,aAAa,EAAE,OAAO,EAAE,aAAa;aACxC,CAAC,CAAA;QACN,CAAC,CAAC,CAAA;IACN,CAAC;IAED,SAAS,CAAQ,KAAgB,EAAE,OAAwB;QACvD,OAAO,IAAA,iCAAiB,EACpB,IAAI,CAAC,gBAAgB,EACrB,KAAK,EACL,CAAC,CAAC,EAAE,CAAC,IAAI,CAAC,iBAAiB,CAAC,CAAC,EAAE,OAAO,CAAC,CAC1C,CAAA;IACL,CAAC;IAEO,iBAAiB,CAAC,KAAgB,EAAE,OAAqB;QAC7D,IAAI,KAAK,CAAC,MAAM,IAAI,CAAC;YAAE,OAAO,OAAO,CAAC,OAAO,CAAC,EAAE,CAAC,CAAA;QACjD,IAAI,KAAK,CAAC,MAAM,IAAI,CAAC;YAAE,OAAO,IAAI,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC,MAAM,EAAE,KAAK,CAAC,CAAC,CAAC,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC,GAAG,CAAC,CAAC,CAAA;QACrG,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;YACnC,IAAI,KAAK,CAAC,MAAM,IAAI,CAAC;gBAAE,OAAO,OAAO,CAAC,EAAE,CAAC,CAAA;YAEzC,IAAI,KAAK,GAAiB,KAAK,CAAC,GAAG,CAAC,EAAE,CAAC,EAAE;gBACrC,OAAO;oBACH,GAAG,EAAE;oBACL,EAAE,EAAE,IAAI,CAAC,OAAO,IAAI,CAAC;oBACrB,OAAO,EAAE,KAAK;iBACjB,CAAA;YACL,CAAC,CAAC,CAAA;YAEF,IAAI,IAAI,CAAC,GAAG,EAAE,OAAO,EAAE,EAAE,CAAC;gBACtB,KAAK,IAAI,IAAI,IAAI,KAAK,EAAE,CAAC;oBACrB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC;wBACX,KAAK,EAAE,IAAI,CAAC,EAAE;wBACd,SAAS,EAAE,IAAI,CAAC,MAAM;wBACtB,SAAS,EAAE,IAAI,CAAC,MAAM;qBACzB,EAAE,UAAU,CAAC,CAAA;gBAClB,CAAC;YACL,CAAC;YAED,IAAI,CAAC,OAAO,CAAC;gBACT,IAAI,EAAE,KAAK;gBACX,QAAQ,EAAE,OAAO,EAAE,QAAQ,IAAI,CAAC;gBAChC,OAAO,EAAE,OAAO,EAAE,OAAO,IAAI,IAAI,CAAC,cAAc;gBAChD,aAAa,EAAE,OAAO,EAAE,aAAa,IAAI,IAAI,CAAC,aAAa;gBAC3D,OAAO;gBACP,MAAM;gBACN,cAAc,EAAE,OAAO,EAAE,cAAc;gBACvC,aAAa,EAAE,OAAO,EAAE,aAAa;aACxC,CAAC,CAAA;QACN,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,OAAO,CAAC,GAAQ;QACpB,IAAI,CAAC,eAAe,EAAE,CAAA;QACtB,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;QACpB,IAAI,CAAC,QAAQ,EAAE,CAAA;IACnB,CAAC;IAEO,QAAQ;QACZ,IAAI,IAAI,CAAC,mBAAmB,IAAI,IAAI,CAAC,MAAM;YAAE,OAAM;QACnD,IAAI,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,IAAI,IAAI,IAAI,IAAI,CAAC,QAAQ,IAAI,CAAC;YAAE,OAAM;QAC3D,IAAI,CAAC,mBAAmB,GAAG,IAAI,CAAA;QAC/B,OAAO,CAAC,OAAO,EAAE,CAAC,IAAI,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC,iBAAiB,EAAE,CAAC,CAAA;IAC1D,CAAC;IAEO,iBAAiB;QACrB,IAAI,CAAC,iBAAiB,EAAE,CAAC,IAAI,CAAC,GAAG,EAAE;YAC/B,IAAI,IAAI,CAAC,IAAI,EAAE,CAAC;gBACZ,IAAI,CAAC,4BAA4B,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;YAChD,CAAC;iBAAM,CAAC;gBACJ,IAAI,IAAI,CAAC,MAAM;oBAAE,OAAM;gBACvB,IAAI,CAAC,mBAAmB,GAAG,KAAK,CAAA;gBAChC,OAAO,IAAI,CAAC,QAAQ,GAAG,CAAC,IAAI,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,EAAE,CAAC;oBAC5C,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,KAAK,CAAC,GAAG,EAAG,CAAC,CAAA;gBAChC,CAAC;YACL,CAAC;QACL,CAAC,EAAE,GAAG,CAAC,EAAE;YACL,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;QACnB,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,4BAA4B,CAAC,SAAoB;QACrD,IAAI,IAAI,CAAC,MAAM;YAAE,OAAM;QACvB,IAAI,CAAC,mBAAmB,GAAG,KAAK,CAAA;QAEhC,IAAI,GAAG,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;QACpB,IAAI,IAAI,GAAG,SAAS,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;QACjC,IAAI,YAAY,GAAG,IAAI,CAAC,SAAS,GAAG,IAAI,CAAA;QAExC,OAAO,IAAI,CAAC,QAAQ,GAAG,CAAC,IAAI,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,EAAE,CAAC;YAC5C,IAAI,YAAY,IAAI,CAAC,EAAE,CAAC;gBACpB,IAAI,CAAC,mBAAmB,GAAG,IAAI,CAAA;gBAC/B,UAAU,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC,iBAAiB,EAAE,EAAE,SAAS,CAAC,QAAQ,CAAC,CAAA;gBAC9D,OAAM;YACV,CAAC;YACD,IAAI,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,EAAG,CAAA;YAC3B,IAAI,IAAI,GAAG,KAAK,CAAC,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,CAAA;YACxD,YAAY,IAAI,IAAI,CAAA;YACpB,SAAS,CAAC,GAAG,CAAC,IAAI,EAAE,GAAG,CAAC,CAAA;YACxB,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;QAClB,CAAC;IACL,CAAC;IAEO,IAAI,CAAC,GAAQ;QACjB,IAAI,CAAC,QAAQ,IAAI,CAAC,CAAA;QAClB,IAAI,YAAY,GAAG,IAAI,CAAC,YAAY,CAAA;QACpC,IAAI,OAAqB,CAAA;QACzB,MAAM,SAAS,GAAG,IAAI,CAAC,GAAG,EAAE,CAAA;QAC5B,IAAI,KAAK,CAAC,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;YAC1B,IAAI,IAAI,GAAG,GAAG,CAAC,IAAI,CAAA;YACnB,IAAI,CAAC,GAAG,EAAE,KAAK,CAAC,EAAC,UAAU,EAAE,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,EAAE,EAAE,IAAA,oBAAI,EAAC,IAAI,CAAC,CAAC,EAAE,CAAC,EAAC,EAAE,UAAU,CAAC,CAAA;YACtE,OAAO,GAAG,IAAI,CAAC,GAAG,CAAC,SAAS,CAAC,IAAI,EAAE,GAAG,CAAC,OAAO,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,EAAE;gBACvD,IAAI,MAAM,GAAG,IAAI,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,CAAA;gBAClC,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,GAAG,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;oBAClC,MAAM,CAAC,CAAC,CAAC,GAAG,IAAI,CAAC,aAAa,CAAC,IAAI,CAAC,CAAC,CAAC,EAAE,GAAG,CAAC,CAAC,CAAC,EAAE,GAAG,CAAC,cAAc,EAAE,GAAG,CAAC,aAAa,CAAC,CAAA;gBAC1F,CAAC;gBACD,OAAO,MAAM,CAAA;YACjB,CAAC,CAAC,CAAA;QACN,CAAC;aAAM,CAAC;YACJ,IAAI,IAAI,GAAG,GAAG,CAAC,IAAI,CAAA;YACnB,IAAI,CAAC,GAAG,EAAE,KAAK,CAAC,EAAC,KAAK,EAAE,IAAI,CAAC,EAAE,EAAC,EAAE,UAAU,CAAC,CAAA;YAC7C,OAAO,GAAG,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,IAAI,EAAE,GAAG,CAAC,OAAO,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,EAAE;gBAClD,OAAO,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,GAAG,EAAE,GAAG,CAAC,cAAc,EAAE,GAAG,CAAC,aAAa,CAAC,CAAA;YAC/E,CAAC,CAAC,CAAA;QACN,CAAC;QACD,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,EAAE;YAClB,MAAM,mBAAmB,GAAG,CAAC,IAAI,CAAC,GAAG,EAAE,GAAG,SAAS,CAAC,GAAG,IAAI,CAAA;YAC3D,IAAI,CAAC,iBAAiB,IAAI,mBAAmB,CAAA;YAE7C,IAAI,CAAC,cAAc,IAAI,CAAC,CAAA;YACxB,IAAI,IAAI,CAAC,YAAY,IAAI,YAAY,EAAE,CAAC;gBACpC,IAAI,CAAC,qBAAqB,GAAG,CAAC,CAAA;YAClC,CAAC;YACD,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,CAAA;QACvB,CAAC,EAAE,GAAG,CAAC,EAAE;YACL,IAAI,IAAI,CAAC,MAAM;gBAAE,OAAO,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;YACvC,IAAI,IAAI,CAAC,iBAAiB,CAAC,GAAG,CAAC,EAAE,CAAC;gBAC9B,IAAI,GAAG,CAAC,aAAa,GAAG,CAAC,EAAE,CAAC;oBACxB,GAAG,CAAC,aAAa,IAAI,CAAC,CAAA;oBACtB,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;gBACrB,CAAC;qBAAM,CAAC;oBACJ,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;gBACnB,CAAC;gBACD,IAAI,IAAI,CAAC,YAAY,IAAI,YAAY,EAAE,CAAC;oBACpC,IAAI,CAAC,OAAO,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;gBAC1B,CAAC;YACL,CAAC;iBAAM,CAAC;gBACJ,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;YACnB,CAAC;QACL,CAAC,CAAC,CAAC,OAAO,CAAC,GAAG,EAAE;YACZ,IAAI,CAAC,QAAQ,IAAI,CAAC,CAAA;YAClB,IAAI,CAAC,QAAQ,EAAE,CAAA;QACnB,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,KAAK,CAAC,iBAAiB;QAC3B,OAAO,IAAI,EAAE,CAAC;YACV,IAAI,IAAI,CAAC,WAAW,IAAI,IAAI,EAAE,CAAC;gBAC3B,IAAI,KAAK,GAAG,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,WAAW,GAAG,IAAI,CAAC,GAAG,EAAE,EAAE,CAAC,CAAC,CAAA;gBACtD,IAAI,CAAC,WAAW,GAAG,SAAS,CAAA;gBAC5B,IAAI,KAAK,GAAG,CAAC,EAAE,CAAC;oBACZ,MAAM,IAAA,oBAAI,EAAC,KAAK,CAAC,CAAA;gBACrB,CAAC;YACL,CAAC;YACD,IAAI,IAAI,CAAC,MAAM;gBAAE,OAAM;YACvB,IAAI,CAAC;gBACD,OAAO,MAAM,IAAI,CAAC,GAAG,CAAC,OAAO,EAAE,CAAA;YACnC,CAAC;YAAC,OAAM,GAAQ,EAAE,CAAC;gBACf,IAAI,IAAI,CAAC,MAAM;oBAAE,OAAM;gBACvB,IAAI,GAAG,YAAY,2BAAkB,EAAE,CAAC;oBACpC,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;gBACrB,CAAC;qBAAM,CAAC;oBACJ,MAAM,GAAG,CAAA;gBACb,CAAC;YACL,CAAC;QACL,CAAC;IACL,CAAC;IAEO,OAAO,CAAC,MAAa,EAAE,GAAS;QACpC,IAAI,CAAC,YAAY,IAAI,CAAC,CAAA;QACtB,IAAI,CAAC,qBAAqB,IAAI,CAAC,CAAA;QAC/B,IAAI,CAAC,gBAAgB,IAAI,CAAC,CAAA;QAE1B,IAAI,YAAY,GAAG,IAAI,CAAC,aAAa,CACjC,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,qBAAqB,EAAE,IAAI,CAAC,aAAa,CAAC,MAAM,CAAC,GAAG,CAAC,CACtE,CAAA;QAED,IAAI,CAAC,WAAW,GAAG,IAAI,CAAC,GAAG,EAAE,GAAG,YAAY,CAAA;QAE5C,IAAI,IAAI,CAAC,GAAG,EAAE,MAAM,EAAE,EAAE,CAAC;YACrB,IAAI,gBAAgB,GAAG,SAAS,CAAA;YAChC,IAAI,MAAM,YAAY,uBAAS;gBAC3B,MAAM,CAAC,QAAQ,CAAC,IAAI;gBACpB,CAAC,MAAM,CAAC,QAAQ,CAAC,OAAO,CAAC,GAAG,CAAC,cAAc,CAAC,EAAE,QAAQ,CAAC,WAAW,CAAC,EACrE,CAAC;gBACC,gBAAgB,GAAG,MAAM,CAAC,QAAQ,CAAC,IAAI,CAAA;YAC3C,CAAC;YACD,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC;gBACV,MAAM,EAAE,MAAM,CAAC,QAAQ,EAAE;gBACzB,gBAAgB;gBAChB,OAAO,EAAE,GAAG,EAAE,IAAI;aACrB,EAAE,oBAAoB,CAAC,CAAA;YACxB,IAAI,CAAC,GAAG,CAAC,IAAI,CAAC,+BAA+B,YAAY,IAAI,CAAC,CAAA;QAClE,CAAC;IACL,CAAC;IAEO,aAAa,CACjB,IAAgB,EAChB,GAAgB,EAChB,cAA2C,EAC3C,aAAyC;QAEzC,IAAI,IAAI,CAAC,GAAG,EAAE,OAAO,EAAE,EAAE,CAAC;YACtB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC;gBACX,KAAK,EAAE,IAAI,CAAC,EAAE;gBACd,SAAS,EAAE,IAAI,CAAC,MAAM;gBACtB,SAAS,EAAE,IAAI,CAAC,MAAM;gBACtB,WAAW,EAAE,GAAG;aACnB,EAAE,cAAc,CAAC,CAAA;QACtB,CAAC;QACD,IAAI,CAAC;YACD,IAAI,GAAG,CAAC,KAAK,EAAE,CAAC;gBACZ,IAAI,aAAa,EAAE,CAAC;oBAChB,OAAO,aAAa,CAAC,GAAG,CAAC,KAAK,EAAE,IAAI,CAAC,CAAA;gBACzC,CAAC;qBAAM,CAAC;oBACJ,MAAM,IAAI,iBAAQ,CAAC,GAAG,CAAC,KAAK,CAAC,CAAA;gBACjC,CAAC;YACL,CAAC;iBAAM,IAAI,cAAc,EAAE,CAAC;gBACxB,OAAO,cAAc,CAAC,GAAG,CAAC,MAAM,EAAE,IAAI,CAAC,CAAA;YAC3C,CAAC;iBAAM,CAAC;gBACJ,OAAO,GAAG,CAAC,MAAM,CAAA;YACrB,CAAC;QACL,CAAC;QAAC,OAAM,GAAQ,EAAE,CAAC;YACf,MAAM,IAAA,+BAAe,EAAC,GAAG,EAAE;gBACvB,MAAM,EAAE,IAAI,CAAC,GAAG;gBAChB,KAAK,EAAE,IAAI,CAAC,EAAE;gBACd,SAAS,EAAE,IAAI,CAAC,MAAM;gBACtB,SAAS,EAAE,IAAI,CAAC,MAAM;gBACtB,WAAW,EAAE,GAAG;aACnB,CAAC,CAAA;QACN,CAAC;IACL,CAAC;IAED,iBAAiB,CAAC,GAAU;QACxB,IAAI,GAAG,YAAY,mBAAU;YAAE,OAAO,IAAI,CAAA;QAC1C,IAAI,gBAAgB,CAAC,GAAG,CAAC;YAAE,OAAO,IAAI,CAAA;QACtC,IAAI,uBAAuB,CAAC,GAAG,CAAC;YAAE,OAAO,IAAI,CAAA;QAC7C,IAAI,sBAAsB,CAAC,GAAG,CAAC;YAAE,OAAO,IAAI,CAAA;QAC5C,IAAI,GAAG,YAAY,2BAAkB;YAAE,OAAO,IAAI,CAAA;QAClD,IAAI,IAAA,mCAAqB,EAAC,GAAG,CAAC;YAAE,OAAO,IAAI,CAAA;QAC3C,IAAI,GAAG,YAAY,8BAAgB;YAAE,OAAO,IAAI,CAAA;QAChD,IAAI,GAAG,YAAY,uBAAS,EAAE,CAAC;YAC3B,QAAO,GAAG,CAAC,QAAQ,CAAC,MAAM,EAAE,CAAC;gBACzB,KAAK,GAAG,CAAC;gBACT,KAAK,GAAG,CAAC;gBACT,KAAK,GAAG,CAAC;gBACT,KAAK,GAAG;oBACJ,OAAO,IAAI,CAAA;gBACf;oBACI,OAAO,KAAK,CAAA;YACpB,CAAC;QACL,CAAC;QACD,OAAO,KAAK,CAAA;IAChB,CAAC;IAED,KAAK,CAAC,MAA2B;QAC7B,IAAI,IAAI,CAAC,MAAM;YAAE,OAAM;QACvB,IAAI,IAAI,CAAC,GAAG,YAAY,iBAAY,EAAE,CAAC;YACnC,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,MAAM,IAAI,IAAI,2BAAkB,CAAC,kBAAkB,CAAC,CAAC,CAAA;QACxE,CAAC;IACL,CAAC;IAED,KAAK,CAAC,GAAW;QACb,IAAI,IAAI,CAAC,MAAM;YAAE,OAAM;QACvB,IAAI,CAAC,MAAM,GAAG,IAAI,CAAA;QAClB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;QACnB,OAAO,IAAI,CAAC,KAAK,CAAC,IAAI,EAAE,EAAE,CAAC,CAAC,cAAc;YACtC,IAAI,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,EAAG,CAAA;YAC3B,GAAG,CAAC,MAAM,CAAC,GAAG,IAAI,IAAI,KAAK,CAAC,sBAAsB,CAAC,CAAC,CAAA;QACxD,CAAC;IACL,CAAC;IAEO,eAAe;QACnB,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;YACd,MAAM,IAAI,KAAK,CAAC,sBAAsB,CAAC,CAAA;QAC3C,CAAC;IACL,CAAC;CACJ;AApcD,8BAocC;AA/TW;IADP,mBAAG;;;oCACqB,6BAAa;8CAGrC;AA+TL,SAAS,UAAU,CAAC,CAAM,EAAE,CAAM;IAC9B,IAAI,CAAC,GAAG,CAAC,CAAC,QAAQ,GAAG,CAAC,CAAC,QAAQ,CAAA;IAC/B,IAAI,CAAC,IAAI,CAAC;QAAE,OAAO,CAAC,CAAA;IACpB,OAAO,eAAe,CAAC,CAAC,CAAC,GAAG,eAAe,CAAC,CAAC,CAAC,CAAA;AAClD,CAAC;AAGD,SAAS,eAAe,CAAC,GAAQ;IAC7B,IAAI,KAAK,CAAC,OAAO,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,CAAC;QAC1B,OAAO,GAAG,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC,EAAE,CAAA;IACzB,CAAC;SAAM,CAAC;QACJ,OAAO,GAAG,CAAC,IAAI,CAAC,EAAE,CAAA;IACtB,CAAC;AACL,CAAC;AAGD,SAAS,eAAe,CAAC,GAAW;IAChC,IAAI,CAAC,GAAG,IAAI,GAAG,CAAC,GAAG,CAAC,CAAA;IACpB,CAAC,CAAC,QAAQ,GAAG,EAAE,CAAA;IACf,CAAC,CAAC,QAAQ,GAAG,EAAE,CAAA;IACf,OAAO,CAAC,CAAC,QAAQ,EAAE,CAAA;AACvB,CAAC;AAGD,SAAS,gBAAgB,CAAC,GAAY;IAClC,OAAO,GAAG,YAAY,iBAAQ,IAAI,aAAa,CAAC,IAAI,CAAC,GAAG,CAAC,OAAO,CAAC,CAAA;AACrE,CAAC;AAGD,SAAS,uBAAuB,CAAC,GAAY;IACzC,OAAO,GAAG,YAAY,iBAAQ,IAAI,oBAAoB,CAAC,IAAI,CAAC,GAAG,CAAC,OAAO,CAAC,CAAA;AAC5E,CAAC;AAED,SAAS,sBAAsB,CAAC,GAAY;IACxC,OAAO,GAAG,YAAY,iBAAQ,IAAI,qBAAqB,CAAC,IAAI,CAAC,GAAG,CAAC,OAAO,CAAC,CAAA;AAC7E,CAAC;AAED,SAAS,UAAU,CAAI,GAAQ,EAAE,IAAO;IACpC,IAAI,KAAK,GAAG,GAAG,CAAC,OAAO,CAAC,IAAI,CAAC,CAAA;IAC7B,IAAI,KAAK,GAAG,CAAC;QAAE,OAAM;IACrB,GAAG,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,CAAC,CAAA;AACxB,CAAC"} |
@@ -13,6 +13,5 @@ import type { RpcClient } from './client'; | ||
| export interface SubscriptionHandle { | ||
| readonly isOpen: boolean; | ||
| readonly isActive: boolean; | ||
| readonly isClosed: boolean; | ||
| close(): void; | ||
| reset(): void; | ||
| } | ||
@@ -19,0 +18,0 @@ export declare class Subscriptions { |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"subscriptions.d.ts","sourceRoot":"","sources":["../src/subscriptions.ts"],"names":[],"mappings":"AAEA,OAAO,KAAK,EAAC,SAAS,EAAC,MAAM,UAAU,CAAA;AAKvC,MAAM,WAAW,YAAY,CAAC,CAAC;IAC3B,MAAM,EAAE,MAAM,CAAA;IACd,MAAM,CAAC,EAAE,OAAO,EAAE,CAAA;IAClB,YAAY,EAAE,MAAM,CAAA;IACpB,WAAW,EAAE,MAAM,CAAA;IACnB,SAAS,EAAE,CAAC,GAAG,EAAE,CAAC,KAAK,IAAI,CAAA;IAC3B,OAAO,EAAE,CAAC,GAAG,EAAE,KAAK,KAAK,IAAI,CAAA;IAC7B,2BAA2B,CAAC,EAAE,OAAO,CAAA;IACrC,aAAa,CAAC,EAAE,MAAM,CAAA;CACzB;AAGD,MAAM,WAAW,kBAAkB;IAC/B,QAAQ,CAAC,MAAM,EAAE,OAAO,CAAA;IACxB,QAAQ,CAAC,QAAQ,EAAE,OAAO,CAAA;IAC1B,KAAK,IAAI,IAAI,CAAA;IACb,KAAK,IAAI,IAAI,CAAA;CAChB;AAOD,qBAAa,aAAa;IAGV,OAAO,CAAC,MAAM;IAF1B,OAAO,CAAC,MAAM,CAA4B;gBAEtB,MAAM,EAAE,SAAS;IAKrC,GAAG,CAAC,CAAC,EAAE,GAAG,EAAE,YAAY,CAAC,CAAC,CAAC,GAAG,kBAAkB;IAIhD,OAAO,CAAC,cAAc;IA6BtB,OAAO,CAAC,OAAO;CAKlB"} | ||
| {"version":3,"file":"subscriptions.d.ts","sourceRoot":"","sources":["../src/subscriptions.ts"],"names":[],"mappings":"AACA,OAAO,KAAK,EAAC,SAAS,EAAC,MAAM,UAAU,CAAA;AAKvC,MAAM,WAAW,YAAY,CAAC,CAAC;IAC3B,MAAM,EAAE,MAAM,CAAA;IACd,MAAM,CAAC,EAAE,OAAO,EAAE,CAAA;IAClB,YAAY,EAAE,MAAM,CAAA;IACpB,WAAW,EAAE,MAAM,CAAA;IACnB,SAAS,EAAE,CAAC,GAAG,EAAE,CAAC,KAAK,IAAI,CAAA;IAC3B,OAAO,EAAE,CAAC,GAAG,EAAE,KAAK,KAAK,IAAI,CAAA;IAC7B,2BAA2B,CAAC,EAAE,OAAO,CAAA;IACrC,aAAa,CAAC,EAAE,MAAM,CAAA;CACzB;AAGD,MAAM,WAAW,kBAAkB;IAC/B,QAAQ,CAAC,QAAQ,EAAE,OAAO,CAAA;IAC1B,QAAQ,CAAC,QAAQ,EAAE,OAAO,CAAA;IAC1B,KAAK,IAAI,IAAI,CAAA;CAChB;AAMD,qBAAa,aAAa;IAGV,OAAO,CAAC,MAAM;IAF1B,OAAO,CAAC,MAAM,CAA2B;gBAErB,MAAM,EAAE,SAAS;IAKrC,GAAG,CAAC,CAAC,EAAE,GAAG,EAAE,YAAY,CAAC,CAAC,CAAC,GAAG,kBAAkB;IAIhD,OAAO,CAAC,cAAc;IA6BtB,OAAO,CAAC,OAAO;CAKlB"} |
+13
-40
| "use strict"; | ||
| var __importDefault = (this && this.__importDefault) || function (mod) { | ||
| return (mod && mod.__esModule) ? mod : { "default": mod }; | ||
| }; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| exports.Subscriptions = void 0; | ||
| const util_internal_1 = require("@subsquid/util-internal"); | ||
| const assert_1 = __importDefault(require("assert")); | ||
| const errors_1 = require("./errors"); | ||
@@ -29,4 +25,4 @@ class Subscriptions { | ||
| } | ||
| let key = `${msg.method}::${subscription}`; | ||
| let handle = this.active.get(key); | ||
| let id = `${msg.method}::${subscription}`; | ||
| let handle = this.active.get(id); | ||
| if (handle == null) | ||
@@ -58,3 +54,3 @@ return; | ||
| } | ||
| get isOpen() { | ||
| get isActive() { | ||
| return !this.closed; | ||
@@ -65,6 +61,2 @@ } | ||
| } | ||
| getSubKey() { | ||
| (0, assert_1.default)(this.id != null); | ||
| return `${this.sub.notification}::${this.id}`; | ||
| } | ||
| close() { | ||
@@ -79,3 +71,3 @@ if (this.closed) | ||
| return; | ||
| this.active.delete(this.getSubKey()); | ||
| this.active.delete(this.id); | ||
| this.id = undefined; | ||
@@ -96,4 +88,4 @@ if (reason instanceof errors_1.RpcConnectionError && this.sub.resubscribeOnConnectionLoss) { | ||
| this.id = id; | ||
| if (this.isOpen) { | ||
| this.active.set(this.getSubKey(), this); | ||
| if (this.isActive) { | ||
| this.active.set(this.id, this); | ||
| } | ||
@@ -106,9 +98,4 @@ else { | ||
| return; | ||
| if (err instanceof errors_1.RpcConnectionError && this.sub.resubscribeOnConnectionLoss) { | ||
| this.subscribe(); | ||
| } | ||
| else { | ||
| this.closed = true; | ||
| this.sub.onError(err); | ||
| } | ||
| this.closed = true; | ||
| this.sub.onError(err); | ||
| }); | ||
@@ -119,9 +106,4 @@ } | ||
| return; | ||
| this.doUnsubscribe().then(); | ||
| } | ||
| doUnsubscribe() { | ||
| this.active.delete(this.getSubKey()); | ||
| let id = this.id; | ||
| this.id = undefined; | ||
| return this.client.call(this.sub.unsubscribe, [id], { retryAttempts: 0 }).catch(err => { | ||
| this.active.delete(this.id); | ||
| this.client.call(this.sub.unsubscribe, [this.id], { retryAttempts: 0 }).catch(err => { | ||
| if (err instanceof errors_1.RpcConnectionError) | ||
@@ -132,11 +114,2 @@ return; | ||
| } | ||
| reset() { | ||
| if (this.id == null) | ||
| return; | ||
| this.doUnsubscribe().then(() => { | ||
| if (this.closed) | ||
| return; | ||
| this.subscribe(); | ||
| }); | ||
| } | ||
| validateSubscriptionResult(result, req) { | ||
@@ -154,10 +127,10 @@ switch (typeof result) { | ||
| } | ||
| let key = `${this.sub.notification}::${result}`; | ||
| if (this.active.has(key)) { | ||
| let id = `${this.sub.notification}::${result}`; | ||
| if (this.active.has(id)) { | ||
| this.client.reset(); | ||
| throw new Error(`got duplicate subscription: ${result}`); | ||
| } | ||
| return result; | ||
| return id; | ||
| } | ||
| } | ||
| //# sourceMappingURL=subscriptions.js.map |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"subscriptions.js","sourceRoot":"","sources":["../src/subscriptions.ts"],"names":[],"mappings":";;;;;;AAAA,2DAAuD;AACvD,oDAA2B;AAE3B,qCAAqD;AA4BrD,MAAa,aAAa;IAGtB,YAAoB,MAAiB;QAAjB,WAAM,GAAN,MAAM,CAAW;QAF7B,WAAM,GAAG,IAAI,GAAG,EAAkB,CAAA;QAGtC,IAAI,CAAC,MAAM,CAAC,uBAAuB,CAAC,GAAG,CAAC,EAAE,CAAC,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,CAAC,CAAA;QACpE,IAAI,CAAC,MAAM,CAAC,gBAAgB,CAAC,GAAG,CAAC,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;IAC1D,CAAC;IAED,GAAG,CAAI,GAAoB;QACvB,OAAO,IAAI,MAAM,CAAC,GAAG,EAAE,IAAI,CAAC,MAAM,EAAE,IAAI,CAAC,MAAM,CAAC,CAAA;IACpD,CAAC;IAEO,cAAc,CAAC,GAAoB;QACvC,IAAI,YAAY,GAAY,GAAG,CAAC,MAAM,EAAE,YAAY,CAAA;QACpD,QAAO,OAAO,YAAY,EAAE,CAAC;YACzB,KAAK,QAAQ,CAAC;YACd,KAAK,QAAQ;gBACT,MAAK;YACT;gBACI,OAAM;QACd,CAAC;QACD,IAAI,GAAG,GAAG,GAAG,GAAG,CAAC,MAAM,KAAK,YAAY,EAAE,CAAA;QAC1C,IAAI,MAAM,GAAG,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,GAAG,CAAC,CAAA;QACjC,IAAI,MAAM,IAAI,IAAI;YAAE,OAAM;QAE1B,IAAI,MAAM,GAAG,GAAG,CAAC,MAMhB,CAAA;QAED,IAAI,MAAM,CAAC,KAAK,EAAE,CAAC;YACf,IAAI,GAAG,GAAG,IAAI,iBAAQ,CAAC,MAAM,CAAC,KAAK,CAAC,CAAA;YACpC,MAAM,CAAC,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;QAC3B,CAAC;aAAM,CAAC;YACJ,MAAM,CAAC,GAAG,CAAC,SAAS,CAAC,MAAM,CAAC,MAAM,CAAC,CAAA;QACvC,CAAC;IACL,CAAC;IAEO,OAAO,CAAC,GAAU;QACtB,KAAK,IAAI,MAAM,IAAI,IAAI,CAAC,MAAM,CAAC,MAAM,EAAE,EAAE,CAAC;YACtC,MAAM,CAAC,iBAAiB,CAAC,GAAG,CAAC,CAAA;QACjC,CAAC;IACL,CAAC;CACJ;AA9CD,sCA8CC;AAGD,MAAM,MAAM;IAIR,YACoB,GAAsB,EAC9B,MAAiB,EACjB,MAA2B;QAFnB,QAAG,GAAH,GAAG,CAAmB;QAC9B,WAAM,GAAN,MAAM,CAAW;QACjB,WAAM,GAAN,MAAM,CAAqB;QAN/B,WAAM,GAAG,KAAK,CAAA;QAQlB,IAAI,CAAC,SAAS,EAAE,CAAA;IACpB,CAAC;IAED,IAAI,MAAM;QACN,OAAO,CAAC,IAAI,CAAC,MAAM,CAAA;IACvB,CAAC;IAED,IAAI,QAAQ;QACR,OAAO,IAAI,CAAC,MAAM,CAAA;IACtB,CAAC;IAED,SAAS;QACL,IAAA,gBAAM,EAAC,IAAI,CAAC,EAAE,IAAI,IAAI,CAAC,CAAA;QACvB,OAAO,GAAG,IAAI,CAAC,GAAG,CAAC,YAAY,KAAK,IAAI,CAAC,EAAE,EAAE,CAAA;IACjD,CAAC;IAED,KAAK;QACD,IAAI,IAAI,CAAC,MAAM;YAAE,OAAM;QACvB,IAAI,CAAC,MAAM,GAAG,IAAI,CAAA;QAClB,IAAI,CAAC,WAAW,EAAE,CAAA;IACtB,CAAC;IAED,iBAAiB,CAAC,MAAa;QAC3B,IAAI,IAAI,CAAC,MAAM;YAAE,OAAM;QACvB,IAAI,CAAC,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,EAAE,CAAC,CAAA;QACpC,IAAI,CAAC,EAAE,GAAG,SAAS,CAAA;QACnB,IAAI,MAAM,YAAY,2BAAkB,IAAI,IAAI,CAAC,GAAG,CAAC,2BAA2B,EAAE,CAAC;YAC/E,IAAI,CAAC,SAAS,EAAE,CAAA;QACpB,CAAC;aAAM,CAAC;YACJ,IAAI,CAAC,MAAM,GAAG,IAAI,CAAA;YAClB,IAAI,CAAC,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,CAAA;QAC5B,CAAC;IACL,CAAC;IAEO,SAAS;QACb,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,MAAM,EAAE,IAAI,CAAC,GAAG,CAAC,MAAM,EAAE;YAC/C,aAAa,EAAE,IAAI,CAAC,GAAG,CAAC,aAAa;YACrC,cAAc,EAAE,CAAC,MAAM,EAAE,GAAG,EAAE,EAAE,CAAC,IAAI,CAAC,0BAA0B,CAAC,MAAM,EAAE,GAAG,CAAC;SAChF,CAAC,CAAC,IAAI,CAAC,EAAE,CAAC,EAAE;YACT,IAAI,CAAC,EAAE,GAAG,EAAE,CAAA;YACZ,IAAI,IAAI,CAAC,MAAM,EAAE,CAAC;gBACd,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,IAAI,CAAC,SAAS,EAAE,EAAE,IAAI,CAAC,CAAA;YAC3C,CAAC;iBAAM,CAAC;gBACJ,IAAI,CAAC,WAAW,EAAE,CAAA;YACtB,CAAC;QACL,CAAC,EAAE,GAAG,CAAC,EAAE;YACL,IAAI,IAAI,CAAC,MAAM;gBAAE,OAAM;YACvB,IAAI,GAAG,YAAY,2BAAkB,IAAI,IAAI,CAAC,GAAG,CAAC,2BAA2B,EAAE,CAAC;gBAC5E,IAAI,CAAC,SAAS,EAAE,CAAA;YACpB,CAAC;iBAAM,CAAC;gBACJ,IAAI,CAAC,MAAM,GAAG,IAAI,CAAA;gBAClB,IAAI,CAAC,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;YACzB,CAAC;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,WAAW;QACf,IAAI,IAAI,CAAC,EAAE,IAAI,IAAI;YAAE,OAAM;QAC3B,IAAI,CAAC,aAAa,EAAE,CAAC,IAAI,EAAE,CAAA;IAC/B,CAAC;IAEO,aAAa;QACjB,IAAI,CAAC,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,EAAE,CAAC,CAAA;QACpC,IAAI,EAAE,GAAG,IAAI,CAAC,EAAE,CAAA;QAChB,IAAI,CAAC,EAAE,GAAG,SAAS,CAAA;QACnB,OAAO,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,WAAW,EAAE,CAAC,EAAE,CAAC,EAAE,EAAC,aAAa,EAAE,CAAC,EAAC,CAAC,CAAC,KAAK,CAAC,GAAG,CAAC,EAAE;YAChF,IAAI,GAAG,YAAY,2BAAkB;gBAAE,OAAM;YAC7C,IAAI,CAAC,MAAM,CAAC,KAAK,CACb,IAAA,+BAAe,EACX,IAAI,2BAAkB,CAAC,6DAA6D,CAAC,EACrF,EAAC,gCAAgC,EAAE,GAAG,EAAC,CAC1C,CACJ,CAAA;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAED,KAAK;QACD,IAAI,IAAI,CAAC,EAAE,IAAI,IAAI;YAAE,OAAM;QAC3B,IAAI,CAAC,aAAa,EAAE,CAAC,IAAI,CAAC,GAAG,EAAE;YAC3B,IAAI,IAAI,CAAC,MAAM;gBAAE,OAAM;YACvB,IAAI,CAAC,SAAS,EAAE,CAAA;QACpB,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,0BAA0B,CAAC,MAAe,EAAE,GAAe;QAC/D,QAAO,OAAO,MAAM,EAAE,CAAC;YACnB,KAAK,QAAQ,CAAC;YACd,KAAK,QAAQ;gBACT,MAAK;YACT;gBACI,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAA;gBACnB,MAAM,IAAA,+BAAe,EACjB,IAAI,KAAK,CACL,kCAAkC;oBAClC,2DAA2D,CAC9D,EAAE;oBACC,SAAS,EAAE,MAAM;iBACpB,CACJ,CAAA;QACT,CAAC;QACD,IAAI,GAAG,GAAG,GAAG,IAAI,CAAC,GAAG,CAAC,YAAY,KAAK,MAAM,EAAE,CAAA;QAC/C,IAAI,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,GAAG,CAAC,EAAE,CAAC;YACvB,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAA;YACnB,MAAM,IAAI,KAAK,CAAC,+BAA+B,MAAM,EAAE,CAAC,CAAA;QAC5D,CAAC;QACD,OAAO,MAAM,CAAA;IACjB,CAAC;CACJ"} | ||
| {"version":3,"file":"subscriptions.js","sourceRoot":"","sources":["../src/subscriptions.ts"],"names":[],"mappings":";;;AAAA,2DAAuD;AAEvD,qCAAqD;AA0BrD,MAAa,aAAa;IAGtB,YAAoB,MAAiB;QAAjB,WAAM,GAAN,MAAM,CAAW;QAF7B,WAAM,GAAG,IAAI,GAAG,EAAiB,CAAA;QAGrC,IAAI,CAAC,MAAM,CAAC,uBAAuB,CAAC,GAAG,CAAC,EAAE,CAAC,IAAI,CAAC,cAAc,CAAC,GAAG,CAAC,CAAC,CAAA;QACpE,IAAI,CAAC,MAAM,CAAC,gBAAgB,CAAC,GAAG,CAAC,EAAE,CAAC,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC,CAAA;IAC1D,CAAC;IAED,GAAG,CAAI,GAAoB;QACvB,OAAO,IAAI,MAAM,CAAC,GAAG,EAAE,IAAI,CAAC,MAAM,EAAE,IAAI,CAAC,MAAM,CAAC,CAAA;IACpD,CAAC;IAEO,cAAc,CAAC,GAAoB;QACvC,IAAI,YAAY,GAAY,GAAG,CAAC,MAAM,EAAE,YAAY,CAAA;QACpD,QAAO,OAAO,YAAY,EAAE,CAAC;YACzB,KAAK,QAAQ,CAAC;YACd,KAAK,QAAQ;gBACT,MAAK;YACT;gBACI,OAAM;QACd,CAAC;QACD,IAAI,EAAE,GAAG,GAAG,GAAG,CAAC,MAAM,KAAK,YAAY,EAAE,CAAA;QACzC,IAAI,MAAM,GAAG,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE,CAAC,CAAA;QAChC,IAAI,MAAM,IAAI,IAAI;YAAE,OAAM;QAE1B,IAAI,MAAM,GAAG,GAAG,CAAC,MAMhB,CAAA;QAED,IAAI,MAAM,CAAC,KAAK,EAAE,CAAC;YACf,IAAI,GAAG,GAAG,IAAI,iBAAQ,CAAC,MAAM,CAAC,KAAK,CAAC,CAAA;YACpC,MAAM,CAAC,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;QAC3B,CAAC;aAAM,CAAC;YACJ,MAAM,CAAC,GAAG,CAAC,SAAS,CAAC,MAAM,CAAC,MAAM,CAAC,CAAA;QACvC,CAAC;IACL,CAAC;IAEO,OAAO,CAAC,GAAU;QACtB,KAAK,IAAI,MAAM,IAAI,IAAI,CAAC,MAAM,CAAC,MAAM,EAAE,EAAE,CAAC;YACtC,MAAM,CAAC,iBAAiB,CAAC,GAAG,CAAC,CAAA;QACjC,CAAC;IACL,CAAC;CACJ;AA9CD,sCA8CC;AAGD,MAAM,MAAM;IAIR,YACoB,GAAsB,EAC9B,MAAiB,EACjB,MAA0B;QAFlB,QAAG,GAAH,GAAG,CAAmB;QAC9B,WAAM,GAAN,MAAM,CAAW;QACjB,WAAM,GAAN,MAAM,CAAoB;QAN9B,WAAM,GAAG,KAAK,CAAA;QAQlB,IAAI,CAAC,SAAS,EAAE,CAAA;IACpB,CAAC;IAED,IAAI,QAAQ;QACR,OAAO,CAAC,IAAI,CAAC,MAAM,CAAA;IACvB,CAAC;IAED,IAAI,QAAQ;QACR,OAAO,IAAI,CAAC,MAAM,CAAA;IACtB,CAAC;IAED,KAAK;QACD,IAAI,IAAI,CAAC,MAAM;YAAE,OAAM;QACvB,IAAI,CAAC,MAAM,GAAG,IAAI,CAAA;QAClB,IAAI,CAAC,WAAW,EAAE,CAAA;IACtB,CAAC;IAED,iBAAiB,CAAC,MAAa;QAC3B,IAAI,IAAI,CAAC,MAAM;YAAE,OAAM;QACvB,IAAI,CAAC,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,EAAG,CAAC,CAAA;QAC5B,IAAI,CAAC,EAAE,GAAG,SAAS,CAAA;QACnB,IAAI,MAAM,YAAY,2BAAkB,IAAI,IAAI,CAAC,GAAG,CAAC,2BAA2B,EAAE,CAAC;YAC/E,IAAI,CAAC,SAAS,EAAE,CAAA;QACpB,CAAC;aAAM,CAAC;YACJ,IAAI,CAAC,MAAM,GAAG,IAAI,CAAA;YAClB,IAAI,CAAC,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,CAAA;QAC5B,CAAC;IACL,CAAC;IAEO,SAAS;QACb,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,MAAM,EAAE,IAAI,CAAC,GAAG,CAAC,MAAM,EAAE;YAC/C,aAAa,EAAE,IAAI,CAAC,GAAG,CAAC,aAAa;YACrC,cAAc,EAAE,CAAC,MAAM,EAAE,GAAG,EAAE,EAAE,CAAC,IAAI,CAAC,0BAA0B,CAAC,MAAM,EAAE,GAAG,CAAC;SAChF,CAAC,CAAC,IAAI,CAAC,EAAE,CAAC,EAAE;YACT,IAAI,CAAC,EAAE,GAAG,EAAE,CAAA;YACZ,IAAI,IAAI,CAAC,QAAQ,EAAE,CAAC;gBAChB,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,IAAI,CAAC,EAAE,EAAE,IAAI,CAAC,CAAA;YAClC,CAAC;iBAAM,CAAC;gBACJ,IAAI,CAAC,WAAW,EAAE,CAAA;YACtB,CAAC;QACL,CAAC,EAAE,GAAG,CAAC,EAAE;YACL,IAAI,IAAI,CAAC,MAAM;gBAAE,OAAM;YACvB,IAAI,CAAC,MAAM,GAAG,IAAI,CAAA;YAClB,IAAI,CAAC,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,CAAA;QACzB,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,WAAW;QACf,IAAI,IAAI,CAAC,EAAE,IAAI,IAAI;YAAE,OAAM;QAC3B,IAAI,CAAC,MAAM,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE,CAAC,CAAA;QAC3B,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,WAAW,EAAE,CAAC,IAAI,CAAC,EAAE,CAAC,EAAE,EAAC,aAAa,EAAE,CAAC,EAAC,CAAC,CAAC,KAAK,CAAC,GAAG,CAAC,EAAE;YAC9E,IAAI,GAAG,YAAY,2BAAkB;gBAAE,OAAM;YAC7C,IAAI,CAAC,MAAM,CAAC,KAAK,CACb,IAAA,+BAAe,EACX,IAAI,2BAAkB,CAAC,6DAA6D,CAAC,EACrF,EAAC,gCAAgC,EAAE,GAAG,EAAC,CAC1C,CACJ,CAAA;QACL,CAAC,CAAC,CAAA;IACN,CAAC;IAEO,0BAA0B,CAAC,MAAe,EAAE,GAAe;QAC/D,QAAO,OAAO,MAAM,EAAE,CAAC;YACnB,KAAK,QAAQ,CAAC;YACd,KAAK,QAAQ;gBACT,MAAK;YACT;gBACI,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAA;gBACnB,MAAM,IAAA,+BAAe,EACjB,IAAI,KAAK,CACL,kCAAkC;oBAClC,2DAA2D,CAC9D,EAAE;oBACC,SAAS,EAAE,MAAM;iBACpB,CACJ,CAAA;QACT,CAAC;QACD,IAAI,EAAE,GAAG,GAAG,IAAI,CAAC,GAAG,CAAC,YAAY,KAAK,MAAM,EAAE,CAAA;QAC9C,IAAI,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE,CAAC,EAAE,CAAC;YACtB,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAA;YACnB,MAAM,IAAI,KAAK,CAAC,+BAA+B,MAAM,EAAE,CAAC,CAAA;QAC5D,CAAC;QACD,OAAO,EAAE,CAAA;IACb,CAAC;CACJ"} |
+5
-5
| { | ||
| "name": "@subsquid/rpc-client", | ||
| "version": "4.11.1-portal-api.da1f68", | ||
| "version": "4.12.0", | ||
| "description": "Lightweight JSON-RPC client library", | ||
@@ -16,5 +16,5 @@ "license": "GPL-3.0-or-later", | ||
| "dependencies": { | ||
| "@subsquid/http-client": "1.7.0-portal-api.da1f68", | ||
| "@subsquid/logger": "1.5.0-portal-api.da1f68", | ||
| "@subsquid/util-internal": "3.3.0-portal-api.da1f68", | ||
| "@subsquid/http-client": "^1.6.0", | ||
| "@subsquid/logger": "^1.4.0", | ||
| "@subsquid/util-internal": "^3.2.0", | ||
| "@subsquid/util-internal-binary-heap": "^1.0.0", | ||
@@ -28,3 +28,3 @@ "@subsquid/util-internal-counters": "^1.3.2", | ||
| "@types/websocket": "^1.0.10", | ||
| "typescript": "5.5.4" | ||
| "typescript": "~5.5.4" | ||
| }, | ||
@@ -31,0 +31,0 @@ "scripts": { |
+26
-5
| import {HttpError, HttpTimeoutError, isHttpConnectionError} from '@subsquid/http-client' | ||
| import {createLogger, Logger} from '@subsquid/logger' | ||
| import {addErrorContext, def, last, removeArrayItem, splitParallelWork, wait} from '@subsquid/util-internal' | ||
| import {addErrorContext, def, last, splitParallelWork, wait} from '@subsquid/util-internal' | ||
| import {Heap} from '@subsquid/util-internal-binary-heap' | ||
@@ -66,2 +66,11 @@ import assert from 'assert' | ||
| export interface RpcMetrics { | ||
| url: string | ||
| requestsServed: number | ||
| connectionErrors: number | ||
| notificationsReceived: number | ||
| avgResponseTime: number | ||
| } | ||
| export interface CallOptions<R=any> { | ||
@@ -117,2 +126,3 @@ priority?: number | ||
| private notificationsReceived = 0 | ||
| private totalResponseTime = 0 | ||
| private backoffEpoch = 0 | ||
@@ -184,3 +194,3 @@ private backoffTime?: number | ||
| getMetrics() { | ||
| getMetrics(): RpcMetrics { | ||
| return { | ||
@@ -190,3 +200,4 @@ url: this.url, | ||
| connectionErrors: this.connectionErrors, | ||
| notificationsReceived: this.notificationsReceived | ||
| notificationsReceived: this.notificationsReceived, | ||
| avgResponseTime: this.requestsServed > 0 ? this.totalResponseTime / this.requestsServed : 0 | ||
| } | ||
@@ -216,3 +227,3 @@ } | ||
| removeNotificationListener(cb: (msg: RpcNotification) => void): void { | ||
| removeArrayItem(this.notificationListeners, cb) | ||
| removeItem(this.notificationListeners, cb) | ||
| } | ||
@@ -225,3 +236,3 @@ | ||
| removeResetListener(cb: (reason: Error) => void): void { | ||
| removeArrayItem(this.resetListeners, cb) | ||
| removeItem(this.resetListeners, cb) | ||
| } | ||
@@ -373,2 +384,3 @@ | ||
| let promise: Promise<any> | ||
| const startTime = Date.now() | ||
| if (Array.isArray(req.call)) { | ||
@@ -392,2 +404,5 @@ let call = req.call | ||
| promise.then(result => { | ||
| const responseTimeSeconds = (Date.now() - startTime) / 1000 | ||
| this.totalResponseTime += responseTimeSeconds | ||
| this.requestsServed += 1 | ||
@@ -590,1 +605,7 @@ if (this.backoffEpoch == backoffEpoch) { | ||
| } | ||
| function removeItem<T>(arr: T[], item: T): void { | ||
| let index = arr.indexOf(item) | ||
| if (index < 0) return | ||
| arr.splice(index, 1) | ||
| } |
+18
-44
| import {addErrorContext} from '@subsquid/util-internal' | ||
| import assert from 'assert' | ||
| import type {RpcClient} from './client' | ||
@@ -21,15 +20,13 @@ import {RpcConnectionError, RpcError} from './errors' | ||
| export interface SubscriptionHandle { | ||
| readonly isOpen: boolean | ||
| readonly isActive: boolean | ||
| readonly isClosed: boolean | ||
| close(): void | ||
| reset(): void | ||
| } | ||
| type SubKey = string // "{notification}::{id}" | ||
| type SubId = number | string | ||
| type SubId = string | ||
| export class Subscriptions { | ||
| private active = new Map<SubKey, Handle>() | ||
| private active = new Map<SubId, Handle>() | ||
@@ -54,4 +51,4 @@ constructor(private client: RpcClient) { | ||
| } | ||
| let key = `${msg.method}::${subscription}` | ||
| let handle = this.active.get(key) | ||
| let id = `${msg.method}::${subscription}` | ||
| let handle = this.active.get(id) | ||
| if (handle == null) return | ||
@@ -90,3 +87,3 @@ | ||
| private client: RpcClient, | ||
| private active: Map<SubKey, Handle> | ||
| private active: Map<SubId, Handle> | ||
| ) { | ||
@@ -96,3 +93,3 @@ this.subscribe() | ||
| get isOpen(): boolean { | ||
| get isActive(): boolean { | ||
| return !this.closed | ||
@@ -105,7 +102,2 @@ } | ||
| getSubKey(): string { | ||
| assert(this.id != null) | ||
| return `${this.sub.notification}::${this.id}` | ||
| } | ||
| close(): void { | ||
@@ -119,3 +111,3 @@ if (this.closed) return | ||
| if (this.closed) return | ||
| this.active.delete(this.getSubKey()) | ||
| this.active.delete(this.id!) | ||
| this.id = undefined | ||
@@ -136,4 +128,4 @@ if (reason instanceof RpcConnectionError && this.sub.resubscribeOnConnectionLoss) { | ||
| this.id = id | ||
| if (this.isOpen) { | ||
| this.active.set(this.getSubKey(), this) | ||
| if (this.isActive) { | ||
| this.active.set(this.id, this) | ||
| } else { | ||
@@ -144,21 +136,11 @@ this.unsubscribe() | ||
| if (this.closed) return | ||
| if (err instanceof RpcConnectionError && this.sub.resubscribeOnConnectionLoss) { | ||
| this.subscribe() | ||
| } else { | ||
| this.closed = true | ||
| this.sub.onError(err) | ||
| } | ||
| this.closed = true | ||
| this.sub.onError(err) | ||
| }) | ||
| } | ||
| private unsubscribe() { | ||
| private unsubscribe(): void { | ||
| if (this.id == null) return | ||
| this.doUnsubscribe().then() | ||
| } | ||
| private doUnsubscribe(): Promise<void> { | ||
| this.active.delete(this.getSubKey()) | ||
| let id = this.id | ||
| this.id = undefined | ||
| return this.client.call(this.sub.unsubscribe, [id], {retryAttempts: 0}).catch(err => { | ||
| this.active.delete(this.id) | ||
| this.client.call(this.sub.unsubscribe, [this.id], {retryAttempts: 0}).catch(err => { | ||
| if (err instanceof RpcConnectionError) return | ||
@@ -174,10 +156,2 @@ this.client.reset( | ||
| reset(): void { | ||
| if (this.id == null) return | ||
| this.doUnsubscribe().then(() => { | ||
| if (this.closed) return | ||
| this.subscribe() | ||
| }) | ||
| } | ||
| private validateSubscriptionResult(result: unknown, req: RpcRequest): SubId { | ||
@@ -199,9 +173,9 @@ switch(typeof result) { | ||
| } | ||
| let key = `${this.sub.notification}::${result}` | ||
| if (this.active.has(key)) { | ||
| let id = `${this.sub.notification}::${result}` | ||
| if (this.active.has(id)) { | ||
| this.client.reset() | ||
| throw new Error(`got duplicate subscription: ${result}`) | ||
| } | ||
| return result | ||
| return id | ||
| } | ||
| } |
Fixed alerts
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Improved metrics
- Number of low quality alerts
1
-50%Worsened metrics
- Total package byte prevSize
121775
-0.51%- Lines of code
2385
-0.83%Dependency changes
+ Added
@subsquid/http-client@1.8.1(transitive)+ Added
@subsquid/logger@1.6.0(transitive)+ Added
@subsquid/util-internal@3.3.1(transitive)- Removed
@subsquid/http-client@1.7.0-portal-api.da1f68(transitive)- Removed
@subsquid/logger@1.5.0-portal-api.da1f68(transitive)- Removed
@subsquid/util-internal@3.3.0-portal-api.da1f68(transitive)Updated
@subsquid/http-client@^1.6.0Updated
@subsquid/logger@^1.4.0