🎩 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
+7
-0
@@ -60,2 +60,9 @@ import { Logger } from '@subsquid/logger'; | ||
| notificationsReceived: number; | ||
| avg_response_time: number; | ||
| } | ||
| export interface RpcMetrics { | ||
| url: string; | ||
| requestsServed: number; | ||
| connectionErrors: number; | ||
| notificationsReceived: number; | ||
| avgResponseTime: number; | ||
@@ -62,0 +69,0 @@ } |
@@ -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,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"} | ||
| {"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,iBAAiB,EAAE,MAAM,CAAA;CAC5B;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;IAYxB,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;YAmDE,iBAAiB;IAuB/B,OAAO,CAAC,OAAO;IA4Bf,OAAO,CAAC,aAAa;IAqCrB,iBAAiB,CAAC,GAAG,EAAE,KAAK,GAAG,OAAO;IAuBtC,KAAK,CAAC,MAAM,CAAC,EAAE,kBAAkB,GAAG,IAAI;IAOxC,KAAK,CAAC,GAAG,CAAC,EAAE,KAAK;IAUjB,OAAO,CAAC,eAAe;CAK1B"} |
+6
-9
@@ -102,3 +102,5 @@ "use strict"; | ||
| notificationsReceived: this.notificationsReceived, | ||
| avgResponseTime: this.requestsServed > 0 ? this.totalResponseTime / this.requestsServed : 0 | ||
| // FIXME: only one of these metrics should remain; decide which to keep | ||
| avg_response_time: this.requestsServed > 0 ? this.totalResponseTime / this.requestsServed : 0, | ||
| avgResponseTime: this.requestsServed > 0 ? this.totalResponseTime / this.requestsServed : 0, | ||
| }; | ||
@@ -125,3 +127,3 @@ } | ||
| removeNotificationListener(cb) { | ||
| removeItem(this.notificationListeners, cb); | ||
| (0, util_internal_1.removeArrayItem)(this.notificationListeners, cb); | ||
| } | ||
@@ -132,3 +134,3 @@ addResetListener(cb) { | ||
| removeResetListener(cb) { | ||
| removeItem(this.resetListeners, cb); | ||
| (0, util_internal_1.removeArrayItem)(this.resetListeners, cb); | ||
| } | ||
@@ -414,2 +416,3 @@ subscribe(sub) { | ||
| switch (err.response.status) { | ||
| case 408: | ||
| case 429: | ||
@@ -485,8 +488,2 @@ case 502: | ||
| } | ||
| 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,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"} | ||
| {"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;AAwG3C,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,uEAAuE;YACvE,iBAAiB,EAAE,IAAI,CAAC,cAAc,GAAG,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,iBAAiB,GAAG,IAAI,CAAC,cAAc,CAAC,CAAC,CAAC,CAAC;YAC7F,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,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,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;YAC7C,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,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;AAtcD,8BAscC;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;AAGD,SAAS,sBAAsB,CAAC,GAAY;IACxC,OAAO,GAAG,YAAY,iBAAQ,IAAI,qBAAqB,CAAC,IAAI,CAAC,GAAG,CAAC,OAAO,CAAC,CAAA;AAC7E,CAAC"} |
@@ -13,3 +13,3 @@ import type { RpcClient } from './client'; | ||
| export interface SubscriptionHandle { | ||
| readonly isActive: boolean; | ||
| readonly isOpen: boolean; | ||
| readonly isClosed: boolean; | ||
@@ -16,0 +16,0 @@ close(): void; |
@@ -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,QAAQ,EAAE,OAAO,CAAA;IAC1B,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":"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"} |
@@ -57,3 +57,3 @@ "use strict"; | ||
| } | ||
| get isActive() { | ||
| get isOpen() { | ||
| return !this.closed; | ||
@@ -93,3 +93,3 @@ } | ||
| this.id = id; | ||
| if (this.isActive) { | ||
| if (this.isOpen) { | ||
| this.active.set(this.getSubKey(), this); | ||
@@ -96,0 +96,0 @@ } |
@@ -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,QAAQ;QACR,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,QAAQ,EAAE,CAAC;gBAChB,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;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"} |
+7
-7
| { | ||
| "name": "@subsquid/rpc-client", | ||
| "version": "4.14.0", | ||
| "version": "4.15.0", | ||
| "description": "Lightweight JSON-RPC client library", | ||
| "license": "GPL-3.0-or-later", | ||
| "repository": "git@github.com:subsquid/squid.git", | ||
| "repository": "git@github.com:subsquid/squid-sdk.git", | ||
| "publishConfig": { | ||
@@ -16,5 +16,5 @@ "access": "public" | ||
| "dependencies": { | ||
| "@subsquid/http-client": "^1.8.0", | ||
| "@subsquid/logger": "^1.4.0", | ||
| "@subsquid/util-internal": "^3.2.0", | ||
| "@subsquid/http-client": "^1.8.1", | ||
| "@subsquid/logger": "^1.6.0", | ||
| "@subsquid/util-internal": "^3.3.0", | ||
| "@subsquid/util-internal-binary-heap": "^1.0.0", | ||
@@ -26,5 +26,5 @@ "@subsquid/util-internal-counters": "^1.3.2", | ||
| "devDependencies": { | ||
| "@types/node": "^18.18.14", | ||
| "@types/node": "^24.0.0", | ||
| "@types/websocket": "^1.0.10", | ||
| "typescript": "~5.5.4" | ||
| "typescript": "5.5.4" | ||
| }, | ||
@@ -31,0 +31,0 @@ "scripts": { |
+18
-10
| import {HttpError, HttpTimeoutError, isHttpConnectionError} from '@subsquid/http-client' | ||
| import {createLogger, Logger} from '@subsquid/logger' | ||
| import {addErrorContext, def, last, splitParallelWork, wait} from '@subsquid/util-internal' | ||
| import {addErrorContext, def, last, removeArrayItem, splitParallelWork, wait} from '@subsquid/util-internal' | ||
| import {Heap} from '@subsquid/util-internal-binary-heap' | ||
@@ -65,3 +65,12 @@ import assert from 'assert' | ||
| // Add interface for RPC metrics | ||
| export interface RpcMetrics { | ||
| url: string | ||
| requestsServed: number | ||
| connectionErrors: number | ||
| notificationsReceived: number | ||
| avg_response_time: number | ||
| } | ||
| export interface RpcMetrics { | ||
@@ -199,3 +208,5 @@ url: string | ||
| notificationsReceived: this.notificationsReceived, | ||
| avgResponseTime: this.requestsServed > 0 ? this.totalResponseTime / this.requestsServed : 0 | ||
| // FIXME: only one of these metrics should remain; decide which to keep | ||
| avg_response_time: this.requestsServed > 0 ? this.totalResponseTime / this.requestsServed : 0, | ||
| avgResponseTime: this.requestsServed > 0 ? this.totalResponseTime / this.requestsServed : 0, | ||
| } | ||
@@ -225,3 +236,3 @@ } | ||
| removeNotificationListener(cb: (msg: RpcNotification) => void): void { | ||
| removeItem(this.notificationListeners, cb) | ||
| removeArrayItem(this.notificationListeners, cb) | ||
| } | ||
@@ -234,3 +245,3 @@ | ||
| removeResetListener(cb: (reason: Error) => void): void { | ||
| removeItem(this.resetListeners, cb) | ||
| removeArrayItem(this.resetListeners, cb) | ||
| } | ||
@@ -403,3 +414,2 @@ | ||
| this.totalResponseTime += responseTimeSeconds | ||
| this.requestsServed += 1 | ||
@@ -529,2 +539,3 @@ if (this.backoffEpoch == backoffEpoch) { | ||
| switch(err.response.status) { | ||
| case 408: | ||
| case 429: | ||
@@ -600,2 +611,3 @@ case 502: | ||
| function isRequestTimedOutError(err: unknown): boolean { | ||
@@ -605,6 +617,2 @@ return err instanceof RpcError && /request.*timed out/i.test(err.message) | ||
| function removeItem<T>(arr: T[], item: T): void { | ||
| let index = arr.indexOf(item) | ||
| if (index < 0) return | ||
| arr.splice(index, 1) | ||
| } | ||
@@ -21,3 +21,3 @@ import {addErrorContext} from '@subsquid/util-internal' | ||
| export interface SubscriptionHandle { | ||
| readonly isActive: boolean | ||
| readonly isOpen: boolean | ||
| readonly isClosed: boolean | ||
@@ -94,3 +94,3 @@ close(): void | ||
| get isActive(): boolean { | ||
| get isOpen(): boolean { | ||
| return !this.closed | ||
@@ -132,3 +132,3 @@ } | ||
| this.id = id | ||
| if (this.isActive) { | ||
| if (this.isOpen) { | ||
| this.active.set(this.getSubKey(), this) | ||
@@ -135,0 +135,0 @@ } else { |
New alerts
No repository
Supply chain riskPackage does not have a linked source code repository. Without this field, a package will have no reference to the location of the source code use to generate the package.
Fixed alerts
No repository
Supply chain riskPackage does not have a linked source code repository. Without this field, a package will have no reference to the location of the source code use to generate the package.
Improved metrics
- Total package byte prevSize
125475
0.59%- Lines of code
2455
0.41%Dependency changes
Updated
@subsquid/http-client@^1.8.1Updated
@subsquid/logger@^1.6.0