@fireproof/core-protocols-cloud - npm Package Compare versions

Comparing version 0.23.0 to 0.23.1-dev-issue-1057

http-connection.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"http-connection.js","sourceRoot":"","sources":["http-connection.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,UAAU,EAAU,MAAM,EAAO,gBAAgB,EAAE,MAAM,iBAAiB,CAAC;AAEpF,OAAO,EAAgE,YAAY,EAAE,OAAO,EAAS,MAAM,YAAY,CAAC;AACxH,OAAO,EAAE,oBAAoB,EAAE,MAAM,8BAA8B,CAAC;AACpE,OAAO,EAAE,YAAY,EAAE,MAAM,yBAAyB,CAAC;AACvD,OAAO,EAIL,UAAU,EAEV,aAAa,GACd,MAAM,uCAAuC,CAAC;AAE/C,SAAS,cAAc,CAAC,GAAQ,EAAO;IACrC,MAAM,QAAQ,GAAG,CAAC,GAAG,CAAC,QAAQ,CAAC,UAAU,CAAC,IAAI,GAAG,CAAC,QAAQ,CAAC,CAAC,OAAO,CAAC,IAAI,EAAE,EAAE,CAAC,CAAC;IAC9E,MAAM,KAAK,GAAG,GAAG,CAAC,KAAK,EAAE,CAAC;IAC1B,QAAQ,QAAQ,EAAE,CAAC;QACjB,KAAK,IAAI,CAAC;QACV,KAAK,MAAM;YACT,KAAK,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC;YACvB,MAAM;QACR,KAAK,OAAO,CAAC;QACb,KAAK,KAAK,CAAC;QACX;YACE,KAAK,CAAC,QAAQ,CAAC,OAAO,CAAC,CAAC;YACxB,MAAM;IACV,CAAC;IACD,OAAO,KAAK,CAAC,GAAG,EAAE,CAAC;AAAA,CACpB;AAED,MAAM,UAAU,UAAU,CAAC,GAAQ,EAAE,EAAU,EAAU;IACvD,MAAM,IAAI,GAAG,GAAG,CAAC,QAAQ,CAAC,OAAO,CAAC,KAAK,EAAE,EAAE,CAAC,CAAC,OAAO,CAAC,KAAK,EAAE,EAAE,CAAC,CAAC;IAChE,MAAM,IAAI,GAAG,GAAG,CAAC,KAAK,EAAE,CAAC;IACzB,IAAI,IAAI,KAAK,EAAE,EAAE,CAAC;QAChB,IAAI,CAAC,cAAc,CAAC,EAAE,CAAC,CAAC;IAC1B,CAAC;IACD,OAAO,IAAI,CAAC,QAAQ,EAAE,CAAC;AAAA,CACxB;AAED,MAAM,OAAO,cAAe,SAAQ,oBAAoB;IAC7C,MAAM,CAAS;IACf,IAAI,CAAsB;IAE1B,QAAQ,CAA8B;IAEtC,MAAM,GAAG,IAAI,GAAG,EAAmB,CAAC;IAEpC,OAAO,GAAG,IAAI,CAAC;IAExB,YAAY,KAAgB,EAAE,IAAW,EAAE,IAAyB,EAAE,SAA2B,EAAE;QACjG,KAAK,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;QACxB,IAAI,CAAC,MAAM,GAAG,YAAY,CAAC,KAAK,EAAE,gBAAgB,CAAC,CAAC;QAEpD,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,CAAC;YACjC,EAAE,EAAE,GAAG;YACP,OAAO,EAAE,cAAc,CAAC,GAAG,CAAC;SAC7B,CAAC,CAAC,CAAC;QACJ,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;IAAA,CAClB;IAED,IAAI,CAAuC,IAAO,EAA4B;QAC5E,MAAM,IAAI,KAAK,CAAC,yBAAyB,CAAC,CAAC;IAAA,CAC5C;IAED,KAAK,CAAC,KAAK,GAA0B;QAQnC,OAAO,MAAM,CAAC,EAAE,CAAC,SAAS,CAAC,CAAC;IAAA,CAC7B;IAED,KAAK,CAAC,KAAK,GAA0B;QACnC,MAAM,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,WAAW,CAAC,MAAM,EAAE,CAAC,CAAC,GAAG,CAAC,CAAC,KAAK,EAAE,EAAE,CAAC,KAAK,CAAC,UAAU,EAAE,KAAK,EAAE,CAAC,CAAC,CAAC;QACnG,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC;QACpB,OAAO,MAAM,CAAC,EAAE,CAAC,SAAS,CAAC,CAAC;IAAA,CAC7B;IAED,KAAK,CAAoB,GAAoB,EAAmB;QAC9D,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,EAAE,EAAE,EAAE,CAAC,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC;QACrC,OAAO,GAAG,CAAC;IAAA,CACZ;IAED,KAAK,CAAC,EAAW,EAAS;QACxB,MAAM,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QACpC,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,GAAG,EAAE,EAAE,CAAC,CAAC;QACzB,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;IAAA,CACtC;IAED,KAAK,CAAC,KAAmB,EAAQ;QAC/B,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,IAAI,CAAC,GAAG,EAAE,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC;aAC1C,IAAI,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC;YACb,IAAI,CAAC;gBACH,KAAK,CAAC,UAAU,EAAE,OAAO,CAAC,GAAG,CAAC,CAAC;gBAC/B,IAAI,UAAU,CAAC,GAAG,CAAC,EAAE,CAAC;oBACpB,KAAK,CAAC,UAAU,EAAE,KAAK,EAAE,CAAC;gBAC5B,CAAC;qBAAM,CAAC;oBACN,KAAK,CAAC,OAAO,GAAG,UAAU,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,EAAE,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,YAAY,IAAI,IAAI,CAAC,CAAC;gBAC5F,CAAC;YACH,CAAC;YAAC,OAAO,GAAG,EAAE,CAAC;gBACb,KAAK,CAAC,UAAU,EAAE,KAAK,CAAC,GAAG,CAAC,CAAC;gBAC7B,KAAK,CAAC,UAAU,EAAE,KAAK,EAAE,CAAC;YAC5B,CAAC;QAAA,CACF,CAAC;aACD,KAAK,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC;YACd,KAAK,CAAC,UAAU,EAAE,KAAK,CAAC,GAAG,CAAC,CAAC;QAAA,CAE9B,CAAC,CAAC;IAAA,CACN;IAEQ,WAAW,GAAG,IAAI,GAAG,EAAwB,CAAC;IACvD,IAAI,CAAuC,GAAM,EAAE,IAAiB,EAAmC;QACrG,MAAM,KAAK,GAAiB;YAC1B,EAAE,EAAE,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG;YAC3B,IAAI,EAAE;gBACJ,GAAG,EAAE,GAAG;gBACR,IAAI;aACL;SACqB,CAAC;QACzB,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,KAAK,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC;QACtC,OAAO,IAAI,cAAc,CAAkB;YACzC,MAAM,EAAE,GAAG,EAAE,CAAC;gBACZ,YAAY,CAAC,KAAK,CAAC,OAAiB,CAAC,CAAC;gBACtC,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;YAAA,CACnC;YACD,KAAK,EAAE,CAAC,UAAU,EAAE,EAAE,CAAC;gBACrB,KAAK,CAAC,UAAU,GAAG,UAAU,CAAC;gBAC9B,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;YAAA,CACnB;SACF,CAAC,CAAC;IAAA,CACJ;IAED,KAAK,CAAC,OAAO,CAAuC,GAAM,EAAE,KAAkB,EAA4B;QACxG,MAAM,OAAO,GAAG,UAAU,CAAC,IAAI,EAAE,CAAC;QAClC,OAAO,CAAC,GAAG,CAAC,cAAc,EAAE,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;QAC5C,OAAO,CAAC,GAAG,CAAC,QAAQ,EAAE,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;QAEtC,MAAM,QAAQ,GAAG,gBAAgB,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC;QACpE,IAAI,QAAQ,CAAC,KAAK,EAAE,EAAE,CAAC;YACrB,OAAO,IAAI,CAAC,KAAK,CACf,aAAa,CAAC,IAAI,EAAE,GAAG,EAAE,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,QAAQ,CAAC,GAAG,EAAE,CAAC,CAAC,GAAG,CAAC,KAAK,EAAE,GAAG,CAAC,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC,OAAO,EAAE,CAAC,CAChH,CAAC;QACJ,CAAC;QACD,OAAO,CAAC,GAAG,CAAC,gBAAgB,EAAE,QAAQ,CAAC,EAAE,EAAE,CAAC,UAAU,CAAC,QAAQ,EAAE,CAAC,CAAC;QACnE,MAAM,GAAG,GAAG,YAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;QAExC,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,GAAG,CAAC,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;QAC7D,MAAM,IAAI,GAAG,MAAM,gBAAgB,CAAC,GAAG,EAAE,CACvC,OAAO,CACL,IAAI,CAAC,IAAI,CAAC,OAAO,EACjB,KAAK,CAAC,UAAU,CAAC,GAAG,CAAC,OAAO,EAAE,IAAI,CAAC,EAAE;YACnC,MAAM,EAAE,KAAK;YACb,OAAO,EAAE,OAAO,CAAC,YAAY,EAAE;YAC/B,IAAI,EAAE,QAAQ,CAAC,EAAE,EAAE;SACpB,CAAC,CACH,CACF,CAAC;QACF,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,IAAI,CAAC,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC;QAC/D,IAAI,IAAI,CAAC,KAAK,EAAE,EAAE,CAAC;YACjB,OAAO,IAAI,CAAC,KAAK,CAAC,aAAa,CAAC,IAAI,EAAE,GAAG,EAAE,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,aAAa,CAAC,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;QACnH,CAAC;QACD,MAAM,GAAG,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACtB,IAAI,CAAC,GAAG,CAAC,EAAE,EAAE,CAAC;YACZ,MAAM,IAAI,GAAG,IAAI,UAAU,CAAC,MAAM,GAAG,CAAC,WAAW,EAAE,CAAC,CAAC;YACrD,MAAM,GAAG,GAAG,MAAM,gBAAgB,CAAC,KAAK,IAAI,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAM,CAAC,CAAC;YACjF,IAAI,GAAG,CAAC,KAAK,EAAE,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,EAAE,EAAE,CAAC,EAAE,CAAC;gBACzC,OAAO,IAAI,CAAC,KAAK,CACf,aAAa,CACX,IAAI,EACJ,GAAG,EACH,IAAI,CAAC,MAAM;qBACR,KAAK,EAAE;qBACP,GAAG,CAAC,GAAG,CAAC;qBACR,GAAG,CAAC,QAAQ,EAAE,GAAG,CAAC,MAAM,CAAC,QAAQ,EAAE,CAAC;qBACpC,GAAG,CAAC,YAAY,EAAE,GAAG,CAAC,UAAU,CAAC;qBACjC,GAAG,CAAC,YAAY,CAAC;qBACjB,OAAO,EAAE,EACZ,MAAM,GAAG,CAAC,IAAI,EAAE,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,SAAS,CAAC,CACxC,CACF,CAAC;YACJ,CAAC;YACD,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,EAAE,EAAE,CAAC,CAAC;QAC9B,CAAC;QACD,MAAM,IAAI,GAAG,IAAI,UAAU,CAAC,MAAM,GAAG,CAAC,WAAW,EAAE,CAAC,CAAC;QACrD,MAAM,GAAG,GAAG,MAAM,gBAAgB,CAAC,KAAK,IAAI,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAM,CAAC,CAAC;QACjF,IAAI,GAAG,CAAC,KAAK,EAAE,EAAE,CAAC;YAChB,OAAO,IAAI,CAAC,KAAK,CACf,aAAa,CAAC,IAAI,EAAE,GAAG,EAAE,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC,OAAO,EAAE,EAAE,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CACxH,CAAC;QACJ,CAAC;QACD,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,EAAE,EAAE,CAAC,CAAC;IAAA,CAC7B;CAMF"}
+{"version":3,"file":"http-connection.js","sourceRoot":"","sources":["../jsr/http-connection.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,UAAU,EAAU,MAAM,EAAO,gBAAgB,EAAE,MAAM,iBAAiB,CAAC;AAEpF,OAAO,EAAgE,YAAY,EAAE,OAAO,EAAS,MAAM,YAAY,CAAC;AACxH,OAAO,EAAE,oBAAoB,EAAE,MAAM,8BAA8B,CAAC;AACpE,OAAO,EAAE,YAAY,EAAE,MAAM,yBAAyB,CAAC;AACvD,OAAO,EAIL,UAAU,EAEV,aAAa,GACd,MAAM,uCAAuC,CAAC;AAE/C,SAAS,cAAc,CAAC,GAAQ,EAAO;IACrC,MAAM,QAAQ,GAAG,CAAC,GAAG,CAAC,QAAQ,CAAC,UAAU,CAAC,IAAI,GAAG,CAAC,QAAQ,CAAC,CAAC,OAAO,CAAC,IAAI,EAAE,EAAE,CAAC,CAAC;IAC9E,MAAM,KAAK,GAAG,GAAG,CAAC,KAAK,EAAE,CAAC;IAC1B,QAAQ,QAAQ,EAAE,CAAC;QACjB,KAAK,IAAI,CAAC;QACV,KAAK,MAAM;YACT,KAAK,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC;YACvB,MAAM;QACR,KAAK,OAAO,CAAC;QACb,KAAK,KAAK,CAAC;QACX;YACE,KAAK,CAAC,QAAQ,CAAC,OAAO,CAAC,CAAC;YACxB,MAAM;IACV,CAAC;IACD,OAAO,KAAK,CAAC,GAAG,EAAE,CAAC;AAAA,CACpB;AAED,MAAM,UAAU,UAAU,CAAC,GAAQ,EAAE,EAAU,EAAU;IACvD,MAAM,IAAI,GAAG,GAAG,CAAC,QAAQ,CAAC,OAAO,CAAC,KAAK,EAAE,EAAE,CAAC,CAAC,OAAO,CAAC,KAAK,EAAE,EAAE,CAAC,CAAC;IAChE,MAAM,IAAI,GAAG,GAAG,CAAC,KAAK,EAAE,CAAC;IACzB,IAAI,IAAI,KAAK,EAAE,EAAE,CAAC;QAChB,IAAI,CAAC,cAAc,CAAC,EAAE,CAAC,CAAC;IAC1B,CAAC;IACD,OAAO,IAAI,CAAC,QAAQ,EAAE,CAAC;AAAA,CACxB;AAED,MAAM,OAAO,cAAe,SAAQ,oBAAoB;IAC7C,MAAM,CAAS;IACf,IAAI,CAAsB;IAE1B,QAAQ,CAA8B;IAEtC,MAAM,GAAG,IAAI,GAAG,EAAmB,CAAC;IAEpC,OAAO,GAAG,IAAI,CAAC;IAExB,YAAY,KAAgB,EAAE,IAAW,EAAE,IAAyB,EAAE,SAA2B,EAAE;QACjG,KAAK,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;QACxB,IAAI,CAAC,MAAM,GAAG,YAAY,CAAC,KAAK,EAAE,gBAAgB,CAAC,CAAC;QAEpD,IAAI,CAAC,QAAQ,GAAG,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,CAAC;YACjC,EAAE,EAAE,GAAG;YACP,OAAO,EAAE,cAAc,CAAC,GAAG,CAAC;SAC7B,CAAC,CAAC,CAAC;QACJ,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;IAAA,CAClB;IAED,IAAI,CAAuC,IAAO,EAA4B;QAC5E,MAAM,IAAI,KAAK,CAAC,yBAAyB,CAAC,CAAC;IAAA,CAC5C;IAED,KAAK,CAAC,KAAK,GAA0B;QAQnC,OAAO,MAAM,CAAC,EAAE,CAAC,SAAS,CAAC,CAAC;IAAA,CAC7B;IAED,KAAK,CAAC,KAAK,GAA0B;QACnC,MAAM,OAAO,CAAC,GAAG,CAAC,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,WAAW,CAAC,MAAM,EAAE,CAAC,CAAC,GAAG,CAAC,CAAC,KAAK,EAAE,EAAE,CAAC,KAAK,CAAC,UAAU,EAAE,KAAK,EAAE,CAAC,CAAC,CAAC;QACnG,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC;QACpB,OAAO,MAAM,CAAC,EAAE,CAAC,SAAS,CAAC,CAAC;IAAA,CAC7B;IAED,KAAK,CAAoB,GAAoB,EAAmB;QAC9D,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,EAAE,EAAE,EAAE,CAAC,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC;QACrC,OAAO,GAAG,CAAC;IAAA,CACZ;IAED,KAAK,CAAC,EAAW,EAAS;QACxB,MAAM,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QACpC,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,GAAG,EAAE,EAAE,CAAC,CAAC;QACzB,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;IAAA,CACtC;IAED,KAAK,CAAC,KAAmB,EAAQ;QAC/B,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,IAAI,CAAC,GAAG,EAAE,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC;aAC1C,IAAI,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC;YACb,IAAI,CAAC;gBACH,KAAK,CAAC,UAAU,EAAE,OAAO,CAAC,GAAG,CAAC,CAAC;gBAC/B,IAAI,UAAU,CAAC,GAAG,CAAC,EAAE,CAAC;oBACpB,KAAK,CAAC,UAAU,EAAE,KAAK,EAAE,CAAC;gBAC5B,CAAC;qBAAM,CAAC;oBACN,KAAK,CAAC,OAAO,GAAG,UAAU,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,EAAE,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,YAAY,IAAI,IAAI,CAAC,CAAC;gBAC5F,CAAC;YACH,CAAC;YAAC,OAAO,GAAG,EAAE,CAAC;gBACb,KAAK,CAAC,UAAU,EAAE,KAAK,CAAC,GAAG,CAAC,CAAC;gBAC7B,KAAK,CAAC,UAAU,EAAE,KAAK,EAAE,CAAC;YAC5B,CAAC;QAAA,CACF,CAAC;aACD,KAAK,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC;YACd,KAAK,CAAC,UAAU,EAAE,KAAK,CAAC,GAAG,CAAC,CAAC;QAAA,CAE9B,CAAC,CAAC;IAAA,CACN;IAEQ,WAAW,GAAG,IAAI,GAAG,EAAwB,CAAC;IACvD,IAAI,CAAuC,GAAM,EAAE,IAAiB,EAAmC;QACrG,MAAM,KAAK,GAAiB;YAC1B,EAAE,EAAE,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG;YAC3B,IAAI,EAAE;gBACJ,GAAG,EAAE,GAAG;gBACR,IAAI;aACL;SACqB,CAAC;QACzB,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,KAAK,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC;QACtC,OAAO,IAAI,cAAc,CAAkB;YACzC,MAAM,EAAE,GAAG,EAAE,CAAC;gBACZ,YAAY,CAAC,KAAK,CAAC,OAAiB,CAAC,CAAC;gBACtC,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;YAAA,CACnC;YACD,KAAK,EAAE,CAAC,UAAU,EAAE,EAAE,CAAC;gBACrB,KAAK,CAAC,UAAU,GAAG,UAAU,CAAC;gBAC9B,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;YAAA,CACnB;SACF,CAAC,CAAC;IAAA,CACJ;IAED,KAAK,CAAC,OAAO,CAAuC,GAAM,EAAE,KAAkB,EAA4B;QACxG,MAAM,OAAO,GAAG,UAAU,CAAC,IAAI,EAAE,CAAC;QAClC,OAAO,CAAC,GAAG,CAAC,cAAc,EAAE,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;QAC5C,OAAO,CAAC,GAAG,CAAC,QAAQ,EAAE,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;QAEtC,MAAM,QAAQ,GAAG,gBAAgB,CAAC,GAAG,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC;QACpE,IAAI,QAAQ,CAAC,KAAK,EAAE,EAAE,CAAC;YACrB,OAAO,IAAI,CAAC,KAAK,CACf,aAAa,CAAC,IAAI,EAAE,GAAG,EAAE,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,QAAQ,CAAC,GAAG,EAAE,CAAC,CAAC,GAAG,CAAC,KAAK,EAAE,GAAG,CAAC,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC,OAAO,EAAE,CAAC,CAChH,CAAC;QACJ,CAAC;QACD,OAAO,CAAC,GAAG,CAAC,gBAAgB,EAAE,QAAQ,CAAC,EAAE,EAAE,CAAC,UAAU,CAAC,QAAQ,EAAE,CAAC,CAAC;QACnE,MAAM,GAAG,GAAG,YAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;QAExC,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,GAAG,CAAC,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC;QAC7D,MAAM,IAAI,GAAG,MAAM,gBAAgB,CAAC,GAAG,EAAE,CACvC,OAAO,CACL,IAAI,CAAC,IAAI,CAAC,OAAO,EACjB,KAAK,CAAC,UAAU,CAAC,GAAG,CAAC,OAAO,EAAE,IAAI,CAAC,EAAE;YACnC,MAAM,EAAE,KAAK;YACb,OAAO,EAAE,OAAO,CAAC,YAAY,EAAE;YAC/B,IAAI,EAAE,QAAQ,CAAC,EAAE,EAAE;SACpB,CAAC,CACH,CACF,CAAC;QACF,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,IAAI,CAAC,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC;QAC/D,IAAI,IAAI,CAAC,KAAK,EAAE,EAAE,CAAC;YACjB,OAAO,IAAI,CAAC,KAAK,CAAC,aAAa,CAAC,IAAI,EAAE,GAAG,EAAE,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,aAAa,CAAC,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;QACnH,CAAC;QACD,MAAM,GAAG,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QACtB,IAAI,CAAC,GAAG,CAAC,EAAE,EAAE,CAAC;YACZ,MAAM,IAAI,GAAG,IAAI,UAAU,CAAC,MAAM,GAAG,CAAC,WAAW,EAAE,CAAC,CAAC;YACrD,MAAM,GAAG,GAAG,MAAM,gBAAgB,CAAC,KAAK,IAAI,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAM,CAAC,CAAC;YACjF,IAAI,GAAG,CAAC,KAAK,EAAE,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,EAAE,EAAE,CAAC,EAAE,CAAC;gBACzC,OAAO,IAAI,CAAC,KAAK,CACf,aAAa,CACX,IAAI,EACJ,GAAG,EACH,IAAI,CAAC,MAAM;qBACR,KAAK,EAAE;qBACP,GAAG,CAAC,GAAG,CAAC;qBACR,GAAG,CAAC,QAAQ,EAAE,GAAG,CAAC,MAAM,CAAC,QAAQ,EAAE,CAAC;qBACpC,GAAG,CAAC,YAAY,EAAE,GAAG,CAAC,UAAU,CAAC;qBACjC,GAAG,CAAC,YAAY,CAAC;qBACjB,OAAO,EAAE,EACZ,MAAM,GAAG,CAAC,IAAI,EAAE,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC,SAAS,CAAC,CACxC,CACF,CAAC;YACJ,CAAC;YACD,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,EAAE,EAAE,CAAC,CAAC;QAC9B,CAAC;QACD,MAAM,IAAI,GAAG,IAAI,UAAU,CAAC,MAAM,GAAG,CAAC,WAAW,EAAE,CAAC,CAAC;QACrD,MAAM,GAAG,GAAG,MAAM,gBAAgB,CAAC,KAAK,IAAI,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAM,CAAC,CAAC;QACjF,IAAI,GAAG,CAAC,KAAK,EAAE,EAAE,CAAC;YAChB,OAAO,IAAI,CAAC,KAAK,CACf,aAAa,CAAC,IAAI,EAAE,GAAG,EAAE,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,GAAG,EAAE,CAAC,CAAC,GAAG,CAAC,cAAc,CAAC,CAAC,OAAO,EAAE,EAAE,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC,CACxH,CAAC;QACJ,CAAC;QACD,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,EAAE,EAAE,CAAC,CAAC;IAAA,CAC7B;CAMF"}

index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["index.ts"],"names":[],"mappings":"AAAA,cAAc,sBAAsB,CAAC;AACrC,cAAc,8BAA8B,CAAC;AAC7C,cAAc,YAAY,CAAC;AAC3B,cAAc,oBAAoB,CAAC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../jsr/index.ts"],"names":[],"mappings":"AAAA,cAAc,sBAAsB,CAAC;AACrC,cAAc,8BAA8B,CAAC;AAC7C,cAAc,YAAY,CAAC;AAC3B,cAAc,oBAAoB,CAAC"}

msg-raw-connection-base.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"msg-raw-connection-base.js","sourceRoot":"","sources":["msg-raw-connection-base.ts"],"names":[],"mappings":"AACA,OAAO,EAAqB,aAAa,EAAE,MAAM,uCAAuC,CAAC;AAIzF,MAAM,OAAO,oBAAoB;IACtB,KAAK,CAAY;IACjB,gBAAgB,CAAmB;IAE5C,YAAY,KAAgB,EAAE,SAA2B,EAAE;QACzD,IAAI,CAAC,KAAK,GAAG,KAAK,CAAC;QACnB,IAAI,CAAC,gBAAgB,GAAG,SAAS,CAAC;IAAA,CACnC;IAEQ,UAAU,GAAG,IAAI,GAAG,EAAqB,CAAC;IACnD,OAAO,CAAC,EAAa,EAAS;QAC5B,MAAM,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QACpC,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,GAAG,EAAE,EAAE,CAAC,CAAC;QAC7B,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,UAAU,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;IAAA,CAC1C;IAED,aAAa,CACX,MAGC,EACD,GAAqB,EACrB,GAAU,EACA;QAEV,MAAM,IAAI,GAAG,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,UAAU,CAAC,MAAM,EAAE,CAAC,CAAC,MAAM,CAAC,CAAC,GAAG,EAAE,EAAE,EAAE,EAAE,CAAC;YACpE,OAAO,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAC;QAAA,CACrB,EAAE,GAAG,CAAC,CAAC;QACR,MAAM,IAAI,GAAG,aAAa,CAAC,MAAM,EAAE,IAAI,EAAE,GAAG,CAAC,CAAC;QAC9C,MAAM,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,KAAK,EAAE,IAAI,CAAC,CAAC,GAAG,CAAC,kBAAkB,CAAC,CAAC;QACxE,OAAO,IAAI,CAAC;IAAA,CACb;CACF"}
+{"version":3,"file":"msg-raw-connection-base.js","sourceRoot":"","sources":["../jsr/msg-raw-connection-base.ts"],"names":[],"mappings":"AACA,OAAO,EAAqB,aAAa,EAAE,MAAM,uCAAuC,CAAC;AAIzF,MAAM,OAAO,oBAAoB;IACtB,KAAK,CAAY;IACjB,gBAAgB,CAAmB;IAE5C,YAAY,KAAgB,EAAE,SAA2B,EAAE;QACzD,IAAI,CAAC,KAAK,GAAG,KAAK,CAAC;QACnB,IAAI,CAAC,gBAAgB,GAAG,SAAS,CAAC;IAAA,CACnC;IAEQ,UAAU,GAAG,IAAI,GAAG,EAAqB,CAAC;IACnD,OAAO,CAAC,EAAa,EAAS;QAC5B,MAAM,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QACpC,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,GAAG,EAAE,EAAE,CAAC,CAAC;QAC7B,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,UAAU,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;IAAA,CAC1C;IAED,aAAa,CACX,MAGC,EACD,GAAqB,EACrB,GAAU,EACA;QAEV,MAAM,IAAI,GAAG,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,UAAU,CAAC,MAAM,EAAE,CAAC,CAAC,MAAM,CAAC,CAAC,GAAG,EAAE,EAAE,EAAE,EAAE,CAAC;YACpE,OAAO,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC,CAAC;QAAA,CACrB,EAAE,GAAG,CAAC,CAAC;QACR,MAAM,IAAI,GAAG,aAAa,CAAC,MAAM,EAAE,IAAI,EAAE,GAAG,CAAC,CAAC;QAC9C,MAAM,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,KAAK,EAAE,IAAI,CAAC,CAAC,GAAG,CAAC,kBAAkB,CAAC,CAAC;QACxE,OAAO,IAAI,CAAC;IAAA,CACb;CACF"}

msger.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"msger.js","sourceRoot":"","sources":["msger.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,QAAQ,EAAqB,MAAM,EAAE,SAAS,EAAE,GAAG,EAAE,MAAM,iBAAiB,CAAC;AACtF,OAAO,EACL,eAAe,EACf,cAAc,EAKd,eAAe,EAIf,UAAU,EASV,YAAY,EACZ,YAAY,EAGZ,cAAc,EACd,aAAa,GAEd,MAAM,uCAAuC,CAAC;AAC/C,OAAO,EAAE,UAAU,EAAE,cAAc,EAAE,MAAM,sBAAsB,CAAC;AAClE,OAAO,EAAE,YAAY,EAAE,MAAM,oBAAoB,CAAC;AAElD,OAAO,EAAE,YAAY,EAAE,KAAK,EAAE,MAAM,yBAAyB,CAAC;AAC9D,OAAO,MAAM,MAAM,2BAA2B,CAAC;AAO/C,MAAM,UAAU,YAAY,CAAI,GAAQ,EAAK;IAC3C,OAAO,GAAG,CAAC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,MAAM,EAAE,GAAG,GAAG,CAAC,MAAM,CAAC,CAAC,CAAC;AAAA,CACpD;AAED,MAAM,UAAU,OAAO,CAAI,EAAU,EAAE,OAAmB,EAAc;IACtE,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE,CAAC;QACtC,MAAM,KAAK,GAAG,UAAU,CAAC,GAAG,EAAE,CAAC;YAC7B,MAAM,CAAC,IAAI,KAAK,CAAC,iBAAiB,EAAE,IAAI,CAAC,CAAC,CAAC;QAAA,CAC5C,EAAE,EAAE,CAAC,CAAC;QACP,OAAO;aACJ,IAAI,CAAC,OAAO,CAAC;aACb,KAAK,CAAC,MAAM,CAAC;aACb,OAAO,CAAC,GAAG,EAAE,CAAC,YAAY,CAAC,KAAK,CAAC,CAAC,CAAC;IAAA,CACvC,CAAC,CAAC;AAAA,CACJ;AAsBD,MAAM,UAAU,QAAQ,CAAC,KAAgB,EAAa;IACpD,OAAO;QACL,MAAM,EAAE,CAAC,IAAa,EAAE,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,CAAC;QACjE,MAAM,EAAE,CAAC,IAAgB,EAAE,EAAE,CAAC,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;KACjE,CAAC;AAAA,CACH;AAID,MAAM,UAAU,gBAAgB,CAAC,KAAgB,EAAE,GAAiC,EAAuB;IACzG,OAAO;QACL,IAAI,EAAE,kBAAkB;QACxB,IAAI,EAAE,QAAQ,CAAC,KAAK,CAAC;QACrB,OAAO,EAAE,IAAI;QACb,oBAAoB,EAAE,CAAC,QAAQ,EAAE,QAAQ,CAAC;QAC1C,GAAG,GAAG;KACuB,CAAC;AAAA,CACjC;AAMD,MAAM,CAAC,KAAK,UAAU,UAAU,CAAC,GAAsC,EAAqC;IAC1G,MAAM,EAAE,GAAG,MAAM,GAAG,CAAC;IACrB,IAAI,EAAE,CAAC,KAAK,EAAE,EAAE,CAAC;QACf,OAAO,EAAE,CAAC;IACZ,CAAC;IACD,MAAM,CAAC,GAAG,EAAE,CAAC,EAAE,EAAE,CAAC;IAClB,MAAM,CAAC,GAAG,MAAM,CAAC,CAAC,KAAK,EAAE,CAAC;IAC1B,IAAI,CAAC,CAAC,KAAK,EAAE,EAAE,CAAC;QACd,OAAO,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC,GAAG,EAAE,CAAC,CAAC;IAC7B,CAAC;IACD,OAAO,EAAE,CAAC;AAAA,CACX;AAED,MAAM,CAAC,KAAK,UAAU,eAAe,CAAC,MAAc,EAAE,IAAe,EAAuC;IAC1G,MAAM,GAAG,GAAG,GAAG,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;IAC3B,MAAM,OAAO,GAAG,GAAG,CAAC,QAAQ,CAAC,SAAS,CAAC,CAAC;IACxC,IAAI,CAAC,OAAO,EAAE,CAAC;QACb,OAAO,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,qBAAqB,CAAC,CAAC,WAAW,EAAE,CAAC;IAC1E,CAAC;IAMD,OAAO,MAAM,CAAC,EAAE,CAAC;QACf,IAAI,EAAE,cAAc;QACpB,MAAM,EAAE;YAEN,GAAG,EAAE,OAAO;SACb;KAC2B,CAAC,CAAC;AAAA,CACjC;AAED,SAAS,YAAY,CAAC,IAAe,EAAO;IAC1C,IAAI,UAAU,GAAG,GAAG,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;IAChC,IAAI,CAAC,EAAE,EAAE,GAAG,CAAC,CAAC,QAAQ,CAAC,UAAU,CAAC,QAAQ,CAAC,EAAE,CAAC;QAC5C,UAAU,GAAG,UAAU,CAAC,KAAK,EAAE,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC,GAAG,EAAE,CAAC;IAC9D,CAAC;IACD,OAAO,UAAU,CAAC;AAAA,CACnB;AASD,MAAM,OAAO,KAAK;IAChB,MAAM,CAAC,OAAO,CAAC,KAAgB,EAAE,IAAe,EAAE,MAAmC,EAAqC;QACxH,MAAM,EAAE,GAAG,IAAI,gBAAgB,CAAC,KAAK,EAAE;YACrC,IAAI;YACJ,IAAI,EAAE,MAAM,CAAC,IAAI;YACjB,YAAY,EAAE,MAAM,CAAC,IAAI;YACzB,WAAW,EAAE,MAAM,CAAC,UAAU,IAAI,EAAE;SACrC,CAAC,CAAC;QAEH,OAAO,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,CAAC;IAAA,CAEvC;IACD,cAAsB;IAAC,CAEtB;CACF;AAED,MAAM,OAAO,gBAAgB;IAC3B,KAAK,CAAC,QAAQ,CACZ,EAAa,EACb,IAAW,EACX,IAAyB,EACzB,SAA2B,EACQ;QACnC,OAAO,MAAM,CAAC,EAAE,CAAC,IAAI,cAAc,CAAC,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,SAAS,CAAC,CAAC,CAAC;IAAA,CACjE;IAED,KAAK,CAAC,MAAM,CACV,EAAa,EAEb,GAAQ,EACR,IAAyB,EACzB,SAA2B,EACQ;QAEnC,GAAG,GAAG,GAAG,CAAC,KAAK,EAAE,CAAC,QAAQ,CAAC,QAAQ,EAAE,EAAE,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,CAAC;QAG5D,MAAM,KAAK,GAAG,UAAU,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QACpC,IAAI,SAA0B,CAAC;QAC/B,IAAI,SAAS,EAAE,CAAC,SAAS,EAAE,CAAC;YAC1B,MAAM,EAAE,SAAS,EAAE,GAAG,MAAM,MAAM,CAAC,IAAI,CAAC,CAAC;YACzC,SAAS,GAAG,GAAG,EAAE,CAAC,IAAI,SAAS,CAAC,KAAK,CAAyB,CAAC;QACjE,CAAC;aAAM,CAAC;YACN,SAAS,GAAG,GAAG,EAAE,CAAC,IAAI,SAAS,CAAC,KAAK,CAAC,CAAC;QACzC,CAAC;QACD,MAAM,GAAG,GAAG,IAAI,YAAY,CAAC,EAAE,EAAE,SAAS,EAAE,EAAE,IAAI,EAAE,SAAS,CAAC,CAAC;QAC/D,OAAO,MAAM,CAAC,EAAE,CAAC,GAAG,CAAC,CAAC;IAAA,CACvB;CACF;AAyBD,MAAM,OAAO,gBAAgB;IAClB,KAAK,CAAY;IAEjB,IAAI,CAAuD;IAC3D,IAAI,CAAmB;IACvB,MAAM,CAAS;IACf,EAAE,CAAS;IACpB,gBAAgB,CAAoB;IAGpC,QAAQ,CAAoB;IAC5B,OAAO,GAAgB,EAAE,CAAC;IAC1B,WAAW,CAAQ;IAEnB,YAAY,KAAgB,EAAE,IAA0B,EAAE;QACxD,IAAI,CAAC,KAAK,GAAG,KAAK,CAAC;QACnB,IAAI,CAAC,EAAE,GAAG,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QAC7B,IAAI,CAAC,MAAM,GAAG,YAAY,CAAC,KAAK,EAAE,kBAAkB,CAAC,CAAC;QACtD,IAAI,CAAC,IAAI,GAAG;YACV,GAAG,IAAI;YACP,YAAY,EAAE,IAAI,CAAC,YAAY,IAAI,IAAI,gBAAgB,EAAE;YACzD,UAAU,EAAE,IAAI,CAAC,UAAU,IAAI,CAAC;YAChC,UAAU,EAAE,IAAI,CAAC,UAAU,IAAI,GAAG;YAClC,IAAI,EAAE,EAAE,KAAK,EAAE,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,EAAE,GAAG,IAAI,CAAC,IAAI,EAAE;SACnB,CAAC;QACjC,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,IAAI,CAAC,YAAY,CAAC;IAAA,CACpC;IAED,IAAI,IAAI,GAAS;QACf,IAAI,CAAC,IAAI,CAAC,WAAW,EAAE,CAAC;YACtB,MAAM,GAAG,GAAG,IAAI,KAAK,CAAC,iBAAiB,CAAC,CAAC;YACzC,MAAM,GAAG,CAAC;QACZ,CAAC;QACD,OAAO,IAAI,CAAC,WAAW,CAAC;IAAA,CACzB;IAEQ,WAAW,GAAG,IAAI,GAAG,EAAwB,CAAC;IAE/C,KAAK,CAAC,kBAAkB,CAAC,QAA0B,EAAE,GAAwB,EAAE,EAAgB,EAAiB;QACtH,MAAM,IAAI,GAAG,EAAE,GAAG,IAAI,CAAC,IAAI,EAAE,GAAG,GAAG,CAAC,IAAI,EAAiB,CAAC;QAC1D,MAAM,MAAM,GAAG,QAAQ,CAAC,IAAI,CAAuB,EAAE,GAAG,EAAE,CAAC,IAAI,CAAC,GAAG,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;QAC3G,MAAM,OAAO,GAAG,MAAM,CAAC,SAAS,EAAE,CAAC;QACnC,OAAO,IAAI,EAAE,CAAC;YACZ,MAAM,EAAE,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,GAAG,MAAM,OAAO,CAAC,IAAI,EAAE,CAAC;YAClD,IAAI,IAAI,EAAE,CAAC;gBACT,OAAO;YACT,CAAC;YACD,IAAI,CAAC;gBACH,IAAI,cAAc,CAAC,GAAG,EAAE,IAAI,CAAC,IAAI,CAAC,IAAI,cAAc,CAAC,GAAG,EAAE,IAAI,CAAC,EAAE,CAAC;oBAChE,EAAE,CAAC,UAAU,EAAE,OAAO,CAAC,GAAG,CAAC,CAAC;gBAC9B,CAAC;YACH,CAAC;YAAC,OAAO,GAAG,EAAE,CAAC;gBACb,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,EAAE,GAAG,EAAE,CAAC,CAAC,GAAG,CAAC,+CAA+C,CAAC,CAAC;YACvG,CAAC;QACH,CAAC;IAAA,CACF;IAEO,UAAU,CAAC,IAAiB,EAAe;QACjD,OAAO;YACL,GAAG,IAAI;YACP,OAAO,EAAE,IAAI,CAAC,OAAO,IAAI,IAAI,CAAC,IAAI,CAAC,WAAW,CAAC,OAAO,IAAI,IAAI;SAC/D,CAAC;IAAA,CACH;IAED,IAAI,CAAuD,GAAM,EAAE,KAAkB,EAAmC;QACtH,MAAM,IAAI,GAAG,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QACpC,MAAM,EAAE,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QACnC,OAAO,IAAI,cAAc,CAAkB;YACzC,MAAM,EAAE,CAAC,GAAG,EAAE,EAAE,CAAC;gBACf,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,gBAAgB,EAAE,EAAE,EAAE,GAAG,CAAC,CAAC;gBACzD,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YAAA,CAC7B;YACD,KAAK,EAAE,CAAC,GAAG,EAAE,EAAE,CAAC;gBACd,IAAI,CAAC,WAAW,CAAC,GAAG,EAAE,IAAI,EAAE,KAAK,EAAE,QAA0B,EAAE,EAAE,CAAC;oBAChE,MAAM,EAAE,GAAG;wBACT,EAAE;wBACF,IAAI,EAAE;4BACJ,GAAG,EAAE,GAAG;4BACR,IAAI;yBACL;wBACD,UAAU,EAAE,GAAG;qBAChB,CAAC;oBACF,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC;oBAC7B,IAAI,CAAC,kBAAkB,CAAC,QAAQ,EAAE,GAAG,EAAE,EAAE,CAAC,CAAC;oBAC3C,OAAO,MAAM,CAAC,EAAE,CAAC,SAAS,CAAC,CAAC;gBAAA,CAC7B,CAAC,CAAC,KAAK,CAAC,CAAC,GAAU,EAAE,EAAE,CAAC;oBACvB,GAAG,CAAC,KAAK,CAAC;wBACR,IAAI,EAAE,OAAO;wBACb,GAAG,EAAE,wBAAwB;wBAC7B,OAAO,EAAE,GAAG,CAAC,OAAO;wBACpB,GAAG,EAAE,GAAG,CAAC,GAAG;wBACZ,OAAO,EAAE,GAAG,CAAC,OAAO;wBACpB,IAAI,EAAE,GAAG,CAAC,IAAI;wBACd,KAAK,EAAE,EAAE;qBACS,CAAC,CAAC;gBAAA,CACvB,CAAC,CAAC;YAAA,CACJ;SACF,CAAC,CAAC;IAAA,CACJ;IAED,OAAO,CAAuD,GAAM,EAAE,KAAkB,EAA4B;QAClH,MAAM,IAAI,GAAG,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QACpC,MAAM,MAAM,GAAG,CAAC,QAA0B,EAAE,EAAE,CAC5C,QAAQ,CAAC,OAAO,CACd;YACE,GAAG,GAAG;YACN,IAAI,EAAE,EAAE,GAAG,IAAI,CAAC,WAAW,EAAE,GAAG,GAAG,CAAC,IAAI,EAAE;SAC3C,EACD,IAAI,CACL,CAAC;QACJ,IAAI,IAAI,CAAC,OAAO,EAAE,CAAC;YAEjB,OAAO,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;QAC9B,CAAC;QACD,OAAO,IAAI,CAAC,WAAW,CAAC,GAAG,EAAE,IAAI,EAAE,MAAM,CAAC,CAAC;IAAA,CAC5C;IAED,IAAI,CAAuD,GAAM,EAA4B;QAC3F,OAAO,IAAI,CAAC,WAAW,CACrB,GAAG,EACH;YACE,OAAO,EAAE,GAAG,EAAE,CAAC,IAAI;SACpB,EACD,KAAK,EAAE,QAA0B,EAAE,EAAE,CAAC;YACpC,MAAM,KAAK,GAAG;gBACZ,GAAG,GAAG;gBACN,IAAI,EAAE,EAAE,GAAG,IAAI,CAAC,IAAI,EAAE,GAAG,GAAG,CAAC,IAAI,EAAE;aACpC,CAAC;YAEF,MAAM,GAAG,GAAG,MAAM,QAAQ,CAAC,IAAI,CAAO,KAAK,CAAC,CAAC;YAC7C,OAAO,GAAG,CAAC;QAAA,CACZ,CACF,CAAC;IAAA,CACH;IAED,KAAK,CAAC,CAAsB,EAAyB;QACnD,OAAO,IAAI,CAAC,WAAW,CACrB,CAAC,EACD;YACE,OAAO,EAAE,GAAG,EAAE,CAAC,IAAI;YACnB,OAAO,EAAE,IAAI;SACd,EACD,CAAC,QAA0B,EAAE,EAAE,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAC,CAAC,CAClD,CAAC;IAAA,CACH;IAGD,KAAK,CAAC,KAA2B,EAAS;QACxC,MAAM,IAAI,KAAK,CAAC,yBAAyB,CAAC,CAAC;IAAA,CAC5C;IAEO,KAAK,CAAC,OAAO,CACnB,IAAc,EACd,IAAe,EACf,KAAK,GAAiC,EAAE,EACL;QAEnC,MAAM,MAAM,GAAG,gBAAgB,CAAC,IAAI,CAAC,KAAK,EAAE,EAAE,GAAG,KAAK,EAAE,IAAI,EAAE,kBAAkB,EAAE,IAAI,EAAE,QAAQ,CAAC,IAAI,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;QAChH,MAAM,UAAU,GAAG,YAAY,CAAC,IAAI,CAAC,CAAC;QACtC,MAAM,EAAE,GAAG,cAAc,CAAC,gBAAgB,CAAC,IAAI,CAAC,KAAK,EAAE,KAAK,CAAC,EAAE,EAAE,EAAE,EAAE,qBAAqB,EAAE,CAAC,CAAC;QAI9F,MAAM,GAAG,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,KAAK,EAAE,CAAC,UAAU,CAAC,EAAE,MAAM,EAAE,EAAE,EAAE,EAAE,EAAE,EAAE,MAAM,EAAE,EAAE,EAAE,CAAC,CAAC;QAC/F,IAAI,GAAG,CAAC,KAAK,EAAE,EAAE,CAAC;YAChB,OAAO,GAAG,CAAC;QACb,CAAC;QACD,MAAM,EAAE,GAAG,GAAG,CAAC,EAAE,EAAE,CAAC;QAKpB,MAAM,UAAU,GAAG,MAAM,EAAE,CAAC,OAAO,CAAyB,eAAe,CAAC,IAAI,CAAC,KAAK,EAAE,IAAI,EAAE,EAAE,CAAC,EAAE;YACjG,OAAO,EAAE,eAAe;YACxB,MAAM,EAAE,IAAI;SACb,CAAC,CAAC;QACH,IAAI,CAAC,eAAe,CAAC,UAAU,CAAC,EAAE,CAAC;YACjC,OAAO,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,EAAE,UAAU,EAAE,CAAC,CAAC,GAAG,CAAC,sBAAsB,CAAC,CAAC,WAAW,EAAE,CAAC;QAC3F,CAAC;QACD,MAAM,EAAE,CAAC,KAAK,CAAC,UAAU,CAA0B,CAAC;QACpD,MAAM,IAAI,GAAG,EAAE,EAAE,EAAE,EAAE,EAAE,MAAM,EAAE,UAAU,CAAC,OAAO,EAA6B,CAAC;QAC/E,MAAM,IAAI,GAAG,gBAAgB,CAAC,IAAI,CAAC,KAAK,EAAE,KAAK,CAAC,CAAC;QAEjD,IAAI,CAAC,gBAAgB,GAAG,IAAI,CAAC;QAE7B,IAAI,SAAmC,CAAC;QACxC,IAAI,IAAI,CAAC,MAAM,CAAC,oBAAoB,CAAC,QAAQ,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,oBAAoB,CAAC,QAAQ,CAAC,QAAQ,CAAC,EAAE,CAAC;YAEhH,SAAS,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,QAAQ,CAClC,IAAI,CAAC,KAAK,EACV,IAAI,CAAC,MAAM,CAAC,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,GAAG,EAAE,CAAC,EAC1E,IAAI,EACJ,IAAI,CACL,CAAC;QACJ,CAAC;aAAM,CAAC;YACN,MAAM,KAAK,GAAG,QAAQ,CAAC,IAAI,CAAC,UAAU,CAAC,CAAC,OAAO,CAAC,YAAY,CAAC,IAAI,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC,GAAG,EAAE,CAAC;YAE7F,SAAS,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,KAAK,EAAE,KAAK,EAAE,IAAI,EAAE,IAAI,CAAC,CAAC;QACpE,CAAC;QACD,IAAI,SAAS,CAAC,KAAK,EAAE,EAAE,CAAC;YACtB,OAAO,SAAS,CAAC;QACnB,CAAC;QACD,MAAM,QAAQ,GAAG,SAAS,CAAC,EAAE,EAAE,CAAC;QAChC,MAAM,MAAM,GAAG,MAAM,QAAQ,CAAC,KAAK,EAAE,CAAC;QACtC,IAAI,MAAM,CAAC,KAAK,EAAE,EAAE,CAAC;YACnB,OAAO,MAAM,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC;QAC5B,CAAC;QACD,OAAO,SAAS,CAAC;IAAA,CAClB;IAEO,KAAK,CAAC,qBAAqB,CAAC,OAAyB,EAAE,GAAY,EAAE,IAAiB,EAAkC;QAC9H,MAAM,KAAK,GAAG,MAAM,IAAI,CAAC,OAAO,CAAmB,YAAY,CAAC,IAAI,CAAC,KAAK,EAAE,GAAG,CAAC,IAAI,EAAE,IAAI,CAAC,EAAE;YAC3F,OAAO,EAAE,YAAY;YACrB,MAAM,EAAE,IAAI;YACZ,OAAO;SACR,CAAC,CAAC;QACH,IAAI,UAAU,CAAC,KAAK,CAAC,EAAE,CAAC;YACtB,OAAO,KAAK,CAAC;QACf,CAAC;QACD,IAAI,CAAC,WAAW,GAAG,KAAK,CAAC,IAAI,CAAC;QAC9B,OAAO,KAAK,CAAC;IAAA,CACd;IAEO,KAAK,GAAG,MAAM,CAAC,CAAC,CAAC,CAAC;IAElB,KAAK,CAAC,WAAW,CACvB,GAAM,EACN,KAAkB,EAClB,MAAkD,EACtC;QACZ,MAAM,IAAI,GAAG,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAEpC,MAAM,QAAQ,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,KAAK,IAAmC,EAAE,CAAC;YAC3E,IAAI,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC;gBACnB,IAAI,IAAI,CAAC,OAAO,CAAC,MAAM,IAAI,IAAI,CAAC,IAAI,CAAC,UAAU,EAAE,CAAC;oBAChD,OAAO;wBACL,QAAQ,EAAE,QAAQ;wBAClB,KAAK,EAAE;4BACL,IAAI,EAAE,OAAO;4BACb,GAAG,EAAE,+BAA+B;4BACpC,OAAO,EAAE,sBAAsB;4BAC/B,GAAG,EAAE,GAAG,CAAC,GAAG;4BACZ,OAAO,EAAE,GAAG,CAAC,OAAO;4BACpB,IAAI,EAAE,GAAG,CAAC,IAAI;4BACd,KAAK,EAAE,EAAE;yBACyB;qBACrC,CAAC;gBACJ,CAAC;gBAED,MAAM,KAAK,GAAG,MAAM,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,IAAI,EAAE,IAAI,CAAC,IAAI,CAAC,IAAI,EAAE,IAAI,CAAC,IAAI,CAAC,WAAW,CAAC,CAAC;gBAClF,IAAI,KAAK,CAAC,KAAK,EAAE,EAAE,CAAC;oBAClB,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE,UAAU,EAAE,IAAI,CAAC,OAAO,CAAC,MAAM,GAAG,CAAC,EAAE,CAAC,CAAC;oBAC3D,MAAM,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,UAAU,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,CAAC;oBACxD,OAAO;wBACL,QAAQ,EAAE,SAAS;qBAEpB,CAAC;gBACJ,CAAC;gBACD,IAAI,CAAC,QAAQ,GAAG,KAAK,CAAC,EAAE,EAAE,CAAC;gBAC3B,MAAM,KAAK,GAAG,MAAM,IAAI,CAAC,qBAAqB,CAAC,IAAI,CAAC,QAAQ,EAAE,GAAG,EAAE;oBACjE,KAAK,EAAE,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG;oBAC9B,GAAG,IAAI,CAAC,WAAW;oBACnB,GAAG,IAAI,CAAC,IAAI,CAAC,IAAI;iBAClB,CAAC,CAAC;gBACH,IAAI,UAAU,CAAC,KAAK,CAAC,EAAE,CAAC;oBACtB,OAAO;wBACL,QAAQ,EAAE,QAAQ;wBAClB,KAAK,EAAE;4BACL,GAAG,KAAK;4BACR,GAAG,EAAE,GAAG,CAAC,GAAG;yBAEG;qBAClB,CAAC;gBACJ,CAAC;gBACD,KAAK,MAAM,EAAE,IAAI,IAAI,CAAC,WAAW,CAAC,MAAM,EAAE,EAAE,CAAC;oBAE3C,KAAK,IAAI,CAAC,kBAAkB,CAAC,IAAI,CAAC,QAAQ,EAAE,GAAG,EAAE,EAAE,CAAC,CAAC;gBACvD,CAAC;gBACD,OAAO;oBACL,QAAQ,EAAE,SAAS;iBACpB,CAAC;gBACF,yDAAyD;gBACzD,cAAc;YAChB,CAAC;iBAAM,CAAC;gBACN,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,OAAO,EAAE,CAAC;oBAC3B,MAAM,IAAI,CAAC,QAAQ,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;oBAC/B,IAAI,CAAC,QAAQ,GAAG,SAAS,CAAC;oBAC1B,IAAI,CAAC,OAAO,GAAG,EAAE,CAAC;oBAClB,OAAO,EAAE,QAAQ,EAAE,SAAS,EAAE,CAAC;oBAC/B,8CAA8C;gBAChD,CAAC;gBACD,IAAI,CAAC,IAAI,CAAC,MAAM,IAAI,CAAC,IAAI,CAAC,WAAW,EAAE,CAAC;oBACtC,MAAM,IAAI,GAAG,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;oBAC1D,OAAO;wBACL,QAAQ,EAAE,QAAQ;wBAClB,KAAK,EAAE;4BACL,IAAI,EAAE,OAAO;4BACb,GAAG,EAAE,GAAG;4BACR,OAAO,EAAE,wBAAwB;4BACjC,GAAG,EAAE,GAAG,CAAC,GAAG;4BACZ,GAAG,IAAI;4BACP,OAAO,EAAE,GAAG,CAAC,OAAO;4BACpB,IAAI,EAAE,GAAG,CAAC,IAAI;4BACd,KAAK,EAAE,EAAE;yBACyB;qBACrC,CAAC;gBACJ,CAAC;gBACD,OAAO;oBACL,QAAQ,EAAE,QAAQ;iBACnB,CAAC;gBACF,0CAA0C;gBAC1C,aAAa;YACf,CAAC;QAAA,CACF,CAAC,CAAC;QAEH,QAAQ,QAAQ,CAAC,QAAQ,EAAE,CAAC;YAC1B,KAAK,SAAS;gBACZ,OAAO,IAAI,CAAC,WAAW,CAAC,GAAG,EAAE,IAAI,EAAE,MAAM,CAAC,CAAC;YAC7C,KAAK,QAAQ;gBACX,OAAO,QAAQ,CAAC,KAAU,CAAC;YAC7B,KAAK,QAAQ;gBACX,IAAI,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC;oBACnB,MAAM,IAAI,KAAK,CAAC,6CAA6C,CAAC,CAAC;gBACjE,CAAC;gBACD,OAAO,MAAM,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;YAC/B;gBACE,MAAM,IAAI,KAAK,CAAC,mBAAmB,QAAQ,CAAC,QAAQ,aAAa,GAAG,CAAC,IAAI,aAAa,IAAI,CAAC,EAAE,EAAE,CAAC,CAAC;QACrG,CAAC;IAAA,CACF;CACF"}
+{"version":3,"file":"msger.js","sourceRoot":"","sources":["../jsr/msger.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,QAAQ,EAAqB,MAAM,EAAE,SAAS,EAAE,GAAG,EAAE,MAAM,iBAAiB,CAAC;AACtF,OAAO,EACL,eAAe,EACf,cAAc,EAKd,eAAe,EAIf,UAAU,EASV,YAAY,EACZ,YAAY,EAGZ,cAAc,EACd,aAAa,GAEd,MAAM,uCAAuC,CAAC;AAC/C,OAAO,EAAE,UAAU,EAAE,cAAc,EAAE,MAAM,sBAAsB,CAAC;AAClE,OAAO,EAAE,YAAY,EAAE,MAAM,oBAAoB,CAAC;AAElD,OAAO,EAAE,YAAY,EAAE,KAAK,EAAE,MAAM,yBAAyB,CAAC;AAC9D,OAAO,MAAM,MAAM,2BAA2B,CAAC;AAO/C,MAAM,UAAU,YAAY,CAAI,GAAQ,EAAK;IAC3C,OAAO,GAAG,CAAC,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,MAAM,EAAE,GAAG,GAAG,CAAC,MAAM,CAAC,CAAC,CAAC;AAAA,CACpD;AAED,MAAM,UAAU,OAAO,CAAI,EAAU,EAAE,OAAmB,EAAc;IACtE,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE,CAAC;QACtC,MAAM,KAAK,GAAG,UAAU,CAAC,GAAG,EAAE,CAAC;YAC7B,MAAM,CAAC,IAAI,KAAK,CAAC,iBAAiB,EAAE,IAAI,CAAC,CAAC,CAAC;QAAA,CAC5C,EAAE,EAAE,CAAC,CAAC;QACP,OAAO;aACJ,IAAI,CAAC,OAAO,CAAC;aACb,KAAK,CAAC,MAAM,CAAC;aACb,OAAO,CAAC,GAAG,EAAE,CAAC,YAAY,CAAC,KAAK,CAAC,CAAC,CAAC;IAAA,CACvC,CAAC,CAAC;AAAA,CACJ;AAsBD,MAAM,UAAU,QAAQ,CAAC,KAAgB,EAAa;IACpD,OAAO;QACL,MAAM,EAAE,CAAC,IAAa,EAAE,EAAE,CAAC,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,CAAC;QACjE,MAAM,EAAE,CAAC,IAAgB,EAAE,EAAE,CAAC,IAAI,CAAC,KAAK,CAAC,KAAK,CAAC,GAAG,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;KACjE,CAAC;AAAA,CACH;AAID,MAAM,UAAU,gBAAgB,CAAC,KAAgB,EAAE,GAAiC,EAAuB;IACzG,OAAO;QACL,IAAI,EAAE,kBAAkB;QACxB,IAAI,EAAE,QAAQ,CAAC,KAAK,CAAC;QACrB,OAAO,EAAE,IAAI;QACb,oBAAoB,EAAE,CAAC,QAAQ,EAAE,QAAQ,CAAC;QAC1C,GAAG,GAAG;KACuB,CAAC;AAAA,CACjC;AAMD,MAAM,CAAC,KAAK,UAAU,UAAU,CAAC,GAAsC,EAAqC;IAC1G,MAAM,EAAE,GAAG,MAAM,GAAG,CAAC;IACrB,IAAI,EAAE,CAAC,KAAK,EAAE,EAAE,CAAC;QACf,OAAO,EAAE,CAAC;IACZ,CAAC;IACD,MAAM,CAAC,GAAG,EAAE,CAAC,EAAE,EAAE,CAAC;IAClB,MAAM,CAAC,GAAG,MAAM,CAAC,CAAC,KAAK,EAAE,CAAC;IAC1B,IAAI,CAAC,CAAC,KAAK,EAAE,EAAE,CAAC;QACd,OAAO,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC,GAAG,EAAE,CAAC,CAAC;IAC7B,CAAC;IACD,OAAO,EAAE,CAAC;AAAA,CACX;AAED,MAAM,CAAC,KAAK,UAAU,eAAe,CAAC,MAAc,EAAE,IAAe,EAAuC;IAC1G,MAAM,GAAG,GAAG,GAAG,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;IAC3B,MAAM,OAAO,GAAG,GAAG,CAAC,QAAQ,CAAC,SAAS,CAAC,CAAC;IACxC,IAAI,CAAC,OAAO,EAAE,CAAC;QACb,OAAO,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,qBAAqB,CAAC,CAAC,WAAW,EAAE,CAAC;IAC1E,CAAC;IAMD,OAAO,MAAM,CAAC,EAAE,CAAC;QACf,IAAI,EAAE,cAAc;QACpB,MAAM,EAAE;YAEN,GAAG,EAAE,OAAO;SACb;KAC2B,CAAC,CAAC;AAAA,CACjC;AAED,SAAS,YAAY,CAAC,IAAe,EAAO;IAC1C,IAAI,UAAU,GAAG,GAAG,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;IAChC,IAAI,CAAC,EAAE,EAAE,GAAG,CAAC,CAAC,QAAQ,CAAC,UAAU,CAAC,QAAQ,CAAC,EAAE,CAAC;QAC5C,UAAU,GAAG,UAAU,CAAC,KAAK,EAAE,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC,GAAG,EAAE,CAAC;IAC9D,CAAC;IACD,OAAO,UAAU,CAAC;AAAA,CACnB;AASD,MAAM,OAAO,KAAK;IAChB,MAAM,CAAC,OAAO,CAAC,KAAgB,EAAE,IAAe,EAAE,MAAmC,EAAqC;QACxH,MAAM,EAAE,GAAG,IAAI,gBAAgB,CAAC,KAAK,EAAE;YACrC,IAAI;YACJ,IAAI,EAAE,MAAM,CAAC,IAAI;YACjB,YAAY,EAAE,MAAM,CAAC,IAAI;YACzB,WAAW,EAAE,MAAM,CAAC,UAAU,IAAI,EAAE;SACrC,CAAC,CAAC;QAEH,OAAO,OAAO,CAAC,OAAO,CAAC,MAAM,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC,CAAC;IAAA,CAEvC;IACD,cAAsB;IAAC,CAEtB;CACF;AAED,MAAM,OAAO,gBAAgB;IAC3B,KAAK,CAAC,QAAQ,CACZ,EAAa,EACb,IAAW,EACX,IAAyB,EACzB,SAA2B,EACQ;QACnC,OAAO,MAAM,CAAC,EAAE,CAAC,IAAI,cAAc,CAAC,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,SAAS,CAAC,CAAC,CAAC;IAAA,CACjE;IAED,KAAK,CAAC,MAAM,CACV,EAAa,EAEb,GAAQ,EACR,IAAyB,EACzB,SAA2B,EACQ;QAEnC,GAAG,GAAG,GAAG,CAAC,KAAK,EAAE,CAAC,QAAQ,CAAC,QAAQ,EAAE,EAAE,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,CAAC;QAG5D,MAAM,KAAK,GAAG,UAAU,CAAC,GAAG,EAAE,IAAI,CAAC,CAAC;QACpC,IAAI,SAA0B,CAAC;QAC/B,IAAI,SAAS,EAAE,CAAC,SAAS,EAAE,CAAC;YAC1B,MAAM,EAAE,SAAS,EAAE,GAAG,MAAM,MAAM,CAAC,IAAI,CAAC,CAAC;YACzC,SAAS,GAAG,GAAG,EAAE,CAAC,IAAI,SAAS,CAAC,KAAK,CAAyB,CAAC;QACjE,CAAC;aAAM,CAAC;YACN,SAAS,GAAG,GAAG,EAAE,CAAC,IAAI,SAAS,CAAC,KAAK,CAAC,CAAC;QACzC,CAAC;QACD,MAAM,GAAG,GAAG,IAAI,YAAY,CAAC,EAAE,EAAE,SAAS,EAAE,EAAE,IAAI,EAAE,SAAS,CAAC,CAAC;QAC/D,OAAO,MAAM,CAAC,EAAE,CAAC,GAAG,CAAC,CAAC;IAAA,CACvB;CACF;AAyBD,MAAM,OAAO,gBAAgB;IAClB,KAAK,CAAY;IAEjB,IAAI,CAAuD;IAC3D,IAAI,CAAmB;IACvB,MAAM,CAAS;IACf,EAAE,CAAS;IACpB,gBAAgB,CAAoB;IAGpC,QAAQ,CAAoB;IAC5B,OAAO,GAAgB,EAAE,CAAC;IAC1B,WAAW,CAAQ;IAEnB,YAAY,KAAgB,EAAE,IAA0B,EAAE;QACxD,IAAI,CAAC,KAAK,GAAG,KAAK,CAAC;QACnB,IAAI,CAAC,EAAE,GAAG,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QAC7B,IAAI,CAAC,MAAM,GAAG,YAAY,CAAC,KAAK,EAAE,kBAAkB,CAAC,CAAC;QACtD,IAAI,CAAC,IAAI,GAAG;YACV,GAAG,IAAI;YACP,YAAY,EAAE,IAAI,CAAC,YAAY,IAAI,IAAI,gBAAgB,EAAE;YACzD,UAAU,EAAE,IAAI,CAAC,UAAU,IAAI,CAAC;YAChC,UAAU,EAAE,IAAI,CAAC,UAAU,IAAI,GAAG;YAClC,IAAI,EAAE,EAAE,KAAK,EAAE,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,EAAE,GAAG,IAAI,CAAC,IAAI,EAAE;SACnB,CAAC;QACjC,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC,IAAI,CAAC,YAAY,CAAC;IAAA,CACpC;IAED,IAAI,IAAI,GAAS;QACf,IAAI,CAAC,IAAI,CAAC,WAAW,EAAE,CAAC;YACtB,MAAM,GAAG,GAAG,IAAI,KAAK,CAAC,iBAAiB,CAAC,CAAC;YACzC,MAAM,GAAG,CAAC;QACZ,CAAC;QACD,OAAO,IAAI,CAAC,WAAW,CAAC;IAAA,CACzB;IAEQ,WAAW,GAAG,IAAI,GAAG,EAAwB,CAAC;IAE/C,KAAK,CAAC,kBAAkB,CAAC,QAA0B,EAAE,GAAwB,EAAE,EAAgB,EAAiB;QACtH,MAAM,IAAI,GAAG,EAAE,GAAG,IAAI,CAAC,IAAI,EAAE,GAAG,GAAG,CAAC,IAAI,EAAiB,CAAC;QAC1D,MAAM,MAAM,GAAG,QAAQ,CAAC,IAAI,CAAuB,EAAE,GAAG,EAAE,CAAC,IAAI,CAAC,GAAG,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,EAAE,IAAI,EAAE,EAAE,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;QAC3G,MAAM,OAAO,GAAG,MAAM,CAAC,SAAS,EAAE,CAAC;QACnC,OAAO,IAAI,EAAE,CAAC;YACZ,MAAM,EAAE,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,GAAG,MAAM,OAAO,CAAC,IAAI,EAAE,CAAC;YAClD,IAAI,IAAI,EAAE,CAAC;gBACT,OAAO;YACT,CAAC;YACD,IAAI,CAAC;gBACH,IAAI,cAAc,CAAC,GAAG,EAAE,IAAI,CAAC,IAAI,CAAC,IAAI,cAAc,CAAC,GAAG,EAAE,IAAI,CAAC,EAAE,CAAC;oBAChE,EAAE,CAAC,UAAU,EAAE,OAAO,CAAC,GAAG,CAAC,CAAC;gBAC9B,CAAC;YACH,CAAC;YAAC,OAAO,GAAG,EAAE,CAAC;gBACb,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,EAAE,GAAG,EAAE,CAAC,CAAC,GAAG,CAAC,+CAA+C,CAAC,CAAC;YACvG,CAAC;QACH,CAAC;IAAA,CACF;IAEO,UAAU,CAAC,IAAiB,EAAe;QACjD,OAAO;YACL,GAAG,IAAI;YACP,OAAO,EAAE,IAAI,CAAC,OAAO,IAAI,IAAI,CAAC,IAAI,CAAC,WAAW,CAAC,OAAO,IAAI,IAAI;SAC/D,CAAC;IAAA,CACH;IAED,IAAI,CAAuD,GAAM,EAAE,KAAkB,EAAmC;QACtH,MAAM,IAAI,GAAG,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QACpC,MAAM,EAAE,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QACnC,OAAO,IAAI,cAAc,CAAkB;YACzC,MAAM,EAAE,CAAC,GAAG,EAAE,EAAE,CAAC;gBACf,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,gBAAgB,EAAE,EAAE,EAAE,GAAG,CAAC,CAAC;gBACzD,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;YAAA,CAC7B;YACD,KAAK,EAAE,CAAC,GAAG,EAAE,EAAE,CAAC;gBACd,IAAI,CAAC,WAAW,CAAC,GAAG,EAAE,IAAI,EAAE,KAAK,EAAE,QAA0B,EAAE,EAAE,CAAC;oBAChE,MAAM,EAAE,GAAG;wBACT,EAAE;wBACF,IAAI,EAAE;4BACJ,GAAG,EAAE,GAAG;4BACR,IAAI;yBACL;wBACD,UAAU,EAAE,GAAG;qBAChB,CAAC;oBACF,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,EAAE,EAAE,EAAE,CAAC,CAAC;oBAC7B,IAAI,CAAC,kBAAkB,CAAC,QAAQ,EAAE,GAAG,EAAE,EAAE,CAAC,CAAC;oBAC3C,OAAO,MAAM,CAAC,EAAE,CAAC,SAAS,CAAC,CAAC;gBAAA,CAC7B,CAAC,CAAC,KAAK,CAAC,CAAC,GAAU,EAAE,EAAE,CAAC;oBACvB,GAAG,CAAC,KAAK,CAAC;wBACR,IAAI,EAAE,OAAO;wBACb,GAAG,EAAE,wBAAwB;wBAC7B,OAAO,EAAE,GAAG,CAAC,OAAO;wBACpB,GAAG,EAAE,GAAG,CAAC,GAAG;wBACZ,OAAO,EAAE,GAAG,CAAC,OAAO;wBACpB,IAAI,EAAE,GAAG,CAAC,IAAI;wBACd,KAAK,EAAE,EAAE;qBACS,CAAC,CAAC;gBAAA,CACvB,CAAC,CAAC;YAAA,CACJ;SACF,CAAC,CAAC;IAAA,CACJ;IAED,OAAO,CAAuD,GAAM,EAAE,KAAkB,EAA4B;QAClH,MAAM,IAAI,GAAG,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QACpC,MAAM,MAAM,GAAG,CAAC,QAA0B,EAAE,EAAE,CAC5C,QAAQ,CAAC,OAAO,CACd;YACE,GAAG,GAAG;YACN,IAAI,EAAE,EAAE,GAAG,IAAI,CAAC,WAAW,EAAE,GAAG,GAAG,CAAC,IAAI,EAAE;SAC3C,EACD,IAAI,CACL,CAAC;QACJ,IAAI,IAAI,CAAC,OAAO,EAAE,CAAC;YAEjB,OAAO,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;QAC9B,CAAC;QACD,OAAO,IAAI,CAAC,WAAW,CAAC,GAAG,EAAE,IAAI,EAAE,MAAM,CAAC,CAAC;IAAA,CAC5C;IAED,IAAI,CAAuD,GAAM,EAA4B;QAC3F,OAAO,IAAI,CAAC,WAAW,CACrB,GAAG,EACH;YACE,OAAO,EAAE,GAAG,EAAE,CAAC,IAAI;SACpB,EACD,KAAK,EAAE,QAA0B,EAAE,EAAE,CAAC;YACpC,MAAM,KAAK,GAAG;gBACZ,GAAG,GAAG;gBACN,IAAI,EAAE,EAAE,GAAG,IAAI,CAAC,IAAI,EAAE,GAAG,GAAG,CAAC,IAAI,EAAE;aACpC,CAAC;YAEF,MAAM,GAAG,GAAG,MAAM,QAAQ,CAAC,IAAI,CAAO,KAAK,CAAC,CAAC;YAC7C,OAAO,GAAG,CAAC;QAAA,CACZ,CACF,CAAC;IAAA,CACH;IAED,KAAK,CAAC,CAAsB,EAAyB;QACnD,OAAO,IAAI,CAAC,WAAW,CACrB,CAAC,EACD;YACE,OAAO,EAAE,GAAG,EAAE,CAAC,IAAI;YACnB,OAAO,EAAE,IAAI;SACd,EACD,CAAC,QAA0B,EAAE,EAAE,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAC,CAAC,CAClD,CAAC;IAAA,CACH;IAGD,KAAK,CAAC,KAA2B,EAAS;QACxC,MAAM,IAAI,KAAK,CAAC,yBAAyB,CAAC,CAAC;IAAA,CAC5C;IAEO,KAAK,CAAC,OAAO,CACnB,IAAc,EACd,IAAe,EACf,KAAK,GAAiC,EAAE,EACL;QAEnC,MAAM,MAAM,GAAG,gBAAgB,CAAC,IAAI,CAAC,KAAK,EAAE,EAAE,GAAG,KAAK,EAAE,IAAI,EAAE,kBAAkB,EAAE,IAAI,EAAE,QAAQ,CAAC,IAAI,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;QAChH,MAAM,UAAU,GAAG,YAAY,CAAC,IAAI,CAAC,CAAC;QACtC,MAAM,EAAE,GAAG,cAAc,CAAC,gBAAgB,CAAC,IAAI,CAAC,KAAK,EAAE,KAAK,CAAC,EAAE,EAAE,EAAE,EAAE,qBAAqB,EAAE,CAAC,CAAC;QAI9F,MAAM,GAAG,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,KAAK,EAAE,CAAC,UAAU,CAAC,EAAE,MAAM,EAAE,EAAE,EAAE,EAAE,EAAE,EAAE,MAAM,EAAE,EAAE,EAAE,CAAC,CAAC;QAC/F,IAAI,GAAG,CAAC,KAAK,EAAE,EAAE,CAAC;YAChB,OAAO,GAAG,CAAC;QACb,CAAC;QACD,MAAM,EAAE,GAAG,GAAG,CAAC,EAAE,EAAE,CAAC;QAKpB,MAAM,UAAU,GAAG,MAAM,EAAE,CAAC,OAAO,CAAyB,eAAe,CAAC,IAAI,CAAC,KAAK,EAAE,IAAI,EAAE,EAAE,CAAC,EAAE;YACjG,OAAO,EAAE,eAAe;YACxB,MAAM,EAAE,IAAI;SACb,CAAC,CAAC;QACH,IAAI,CAAC,eAAe,CAAC,UAAU,CAAC,EAAE,CAAC;YACjC,OAAO,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,EAAE,UAAU,EAAE,CAAC,CAAC,GAAG,CAAC,sBAAsB,CAAC,CAAC,WAAW,EAAE,CAAC;QAC3F,CAAC;QACD,MAAM,EAAE,CAAC,KAAK,CAAC,UAAU,CAA0B,CAAC;QACpD,MAAM,IAAI,GAAG,EAAE,EAAE,EAAE,EAAE,EAAE,MAAM,EAAE,UAAU,CAAC,OAAO,EAA6B,CAAC;QAC/E,MAAM,IAAI,GAAG,gBAAgB,CAAC,IAAI,CAAC,KAAK,EAAE,KAAK,CAAC,CAAC;QAEjD,IAAI,CAAC,gBAAgB,GAAG,IAAI,CAAC;QAE7B,IAAI,SAAmC,CAAC;QACxC,IAAI,IAAI,CAAC,MAAM,CAAC,oBAAoB,CAAC,QAAQ,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,oBAAoB,CAAC,QAAQ,CAAC,QAAQ,CAAC,EAAE,CAAC;YAEhH,SAAS,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,QAAQ,CAClC,IAAI,CAAC,KAAK,EACV,IAAI,CAAC,MAAM,CAAC,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,GAAG,EAAE,CAAC,EAC1E,IAAI,EACJ,IAAI,CACL,CAAC;QACJ,CAAC;aAAM,CAAC;YACN,MAAM,KAAK,GAAG,QAAQ,CAAC,IAAI,CAAC,UAAU,CAAC,CAAC,OAAO,CAAC,YAAY,CAAC,IAAI,CAAC,MAAM,CAAC,WAAW,CAAC,CAAC,CAAC,GAAG,EAAE,CAAC;YAE7F,SAAS,GAAG,MAAM,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,IAAI,CAAC,KAAK,EAAE,KAAK,EAAE,IAAI,EAAE,IAAI,CAAC,CAAC;QACpE,CAAC;QACD,IAAI,SAAS,CAAC,KAAK,EAAE,EAAE,CAAC;YACtB,OAAO,SAAS,CAAC;QACnB,CAAC;QACD,MAAM,QAAQ,GAAG,SAAS,CAAC,EAAE,EAAE,CAAC;QAChC,MAAM,MAAM,GAAG,MAAM,QAAQ,CAAC,KAAK,EAAE,CAAC;QACtC,IAAI,MAAM,CAAC,KAAK,EAAE,EAAE,CAAC;YACnB,OAAO,MAAM,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC;QAC5B,CAAC;QACD,OAAO,SAAS,CAAC;IAAA,CAClB;IAEO,KAAK,CAAC,qBAAqB,CAAC,OAAyB,EAAE,GAAY,EAAE,IAAiB,EAAkC;QAC9H,MAAM,KAAK,GAAG,MAAM,IAAI,CAAC,OAAO,CAAmB,YAAY,CAAC,IAAI,CAAC,KAAK,EAAE,GAAG,CAAC,IAAI,EAAE,IAAI,CAAC,EAAE;YAC3F,OAAO,EAAE,YAAY;YACrB,MAAM,EAAE,IAAI;YACZ,OAAO;SACR,CAAC,CAAC;QACH,IAAI,UAAU,CAAC,KAAK,CAAC,EAAE,CAAC;YACtB,OAAO,KAAK,CAAC;QACf,CAAC;QACD,IAAI,CAAC,WAAW,GAAG,KAAK,CAAC,IAAI,CAAC;QAC9B,OAAO,KAAK,CAAC;IAAA,CACd;IAEO,KAAK,GAAG,MAAM,CAAC,CAAC,CAAC,CAAC;IAElB,KAAK,CAAC,WAAW,CACvB,GAAM,EACN,KAAkB,EAClB,MAAkD,EACtC;QACZ,MAAM,IAAI,GAAG,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,CAAC;QAEpC,MAAM,QAAQ,GAAG,MAAM,IAAI,CAAC,KAAK,CAAC,KAAK,IAAmC,EAAE,CAAC;YAC3E,IAAI,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC;gBACnB,IAAI,IAAI,CAAC,OAAO,CAAC,MAAM,IAAI,IAAI,CAAC,IAAI,CAAC,UAAU,EAAE,CAAC;oBAChD,OAAO;wBACL,QAAQ,EAAE,QAAQ;wBAClB,KAAK,EAAE;4BACL,IAAI,EAAE,OAAO;4BACb,GAAG,EAAE,+BAA+B;4BACpC,OAAO,EAAE,sBAAsB;4BAC/B,GAAG,EAAE,GAAG,CAAC,GAAG;4BACZ,OAAO,EAAE,GAAG,CAAC,OAAO;4BACpB,IAAI,EAAE,GAAG,CAAC,IAAI;4BACd,KAAK,EAAE,EAAE;yBACyB;qBACrC,CAAC;gBACJ,CAAC;gBAED,MAAM,KAAK,GAAG,MAAM,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,IAAI,EAAE,IAAI,CAAC,IAAI,CAAC,IAAI,EAAE,IAAI,CAAC,IAAI,CAAC,WAAW,CAAC,CAAC;gBAClF,IAAI,KAAK,CAAC,KAAK,EAAE,EAAE,CAAC;oBAClB,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE,UAAU,EAAE,IAAI,CAAC,OAAO,CAAC,MAAM,GAAG,CAAC,EAAE,CAAC,CAAC;oBAC3D,MAAM,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,UAAU,GAAG,IAAI,CAAC,OAAO,CAAC,MAAM,CAAC,CAAC;oBACxD,OAAO;wBACL,QAAQ,EAAE,SAAS;qBAEpB,CAAC;gBACJ,CAAC;gBACD,IAAI,CAAC,QAAQ,GAAG,KAAK,CAAC,EAAE,EAAE,CAAC;gBAC3B,MAAM,KAAK,GAAG,MAAM,IAAI,CAAC,qBAAqB,CAAC,IAAI,CAAC,QAAQ,EAAE,GAAG,EAAE;oBACjE,KAAK,EAAE,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG;oBAC9B,GAAG,IAAI,CAAC,WAAW;oBACnB,GAAG,IAAI,CAAC,IAAI,CAAC,IAAI;iBAClB,CAAC,CAAC;gBACH,IAAI,UAAU,CAAC,KAAK,CAAC,EAAE,CAAC;oBACtB,OAAO;wBACL,QAAQ,EAAE,QAAQ;wBAClB,KAAK,EAAE;4BACL,GAAG,KAAK;4BACR,GAAG,EAAE,GAAG,CAAC,GAAG;yBAEG;qBAClB,CAAC;gBACJ,CAAC;gBACD,KAAK,MAAM,EAAE,IAAI,IAAI,CAAC,WAAW,CAAC,MAAM,EAAE,EAAE,CAAC;oBAE3C,KAAK,IAAI,CAAC,kBAAkB,CAAC,IAAI,CAAC,QAAQ,EAAE,GAAG,EAAE,EAAE,CAAC,CAAC;gBACvD,CAAC;gBACD,OAAO;oBACL,QAAQ,EAAE,SAAS;iBACpB,CAAC;gBACF,yDAAyD;gBACzD,cAAc;YAChB,CAAC;iBAAM,CAAC;gBACN,IAAI,CAAC,IAAI,CAAC,QAAQ,CAAC,OAAO,EAAE,CAAC;oBAC3B,MAAM,IAAI,CAAC,QAAQ,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;oBAC/B,IAAI,CAAC,QAAQ,GAAG,SAAS,CAAC;oBAC1B,IAAI,CAAC,OAAO,GAAG,EAAE,CAAC;oBAClB,OAAO,EAAE,QAAQ,EAAE,SAAS,EAAE,CAAC;oBAC/B,8CAA8C;gBAChD,CAAC;gBACD,IAAI,CAAC,IAAI,CAAC,MAAM,IAAI,CAAC,IAAI,CAAC,WAAW,EAAE,CAAC;oBACtC,MAAM,IAAI,GAAG,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,EAAE,CAAC,CAAC,CAAC,EAAE,CAAC;oBAC1D,OAAO;wBACL,QAAQ,EAAE,QAAQ;wBAClB,KAAK,EAAE;4BACL,IAAI,EAAE,OAAO;4BACb,GAAG,EAAE,GAAG;4BACR,OAAO,EAAE,wBAAwB;4BACjC,GAAG,EAAE,GAAG,CAAC,GAAG;4BACZ,GAAG,IAAI;4BACP,OAAO,EAAE,GAAG,CAAC,OAAO;4BACpB,IAAI,EAAE,GAAG,CAAC,IAAI;4BACd,KAAK,EAAE,EAAE;yBACyB;qBACrC,CAAC;gBACJ,CAAC;gBACD,OAAO;oBACL,QAAQ,EAAE,QAAQ;iBACnB,CAAC;gBACF,0CAA0C;gBAC1C,aAAa;YACf,CAAC;QAAA,CACF,CAAC,CAAC;QAEH,QAAQ,QAAQ,CAAC,QAAQ,EAAE,CAAC;YAC1B,KAAK,SAAS;gBACZ,OAAO,IAAI,CAAC,WAAW,CAAC,GAAG,EAAE,IAAI,EAAE,MAAM,CAAC,CAAC;YAC7C,KAAK,QAAQ;gBACX,OAAO,QAAQ,CAAC,KAAU,CAAC;YAC7B,KAAK,QAAQ;gBACX,IAAI,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC;oBACnB,MAAM,IAAI,KAAK,CAAC,6CAA6C,CAAC,CAAC;gBACjE,CAAC;gBACD,OAAO,MAAM,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;YAC/B;gBACE,MAAM,IAAI,KAAK,CAAC,mBAAmB,QAAQ,CAAC,QAAQ,aAAa,GAAG,CAAC,IAAI,aAAa,IAAI,CAAC,EAAE,EAAE,CAAC,CAAC;QACrG,CAAC;IAAA,CACF;CACF"}

package.json

 {
   "name": "@fireproof/core-protocols-cloud",
-  "version": "0.23.0",
+  "version": "0.23.1-dev-issue-1057",
   "description": "Live ledger for the web.",
@@ -34,7 +34,7 @@ "type": "module",
   "dependencies": {
-    "@adviser/cement": "^0.4.21",
-    "@fireproof/core-runtime": "0.23.0",
-    "@fireproof/core-types-base": "0.23.0",
-    "@fireproof/core-types-protocols-cloud": "0.23.0",
-    "@fireproof/vendor": "0.23.0",
+    "@adviser/cement": "^0.4.23",
+    "@fireproof/core-runtime": "0.23.1-dev-issue-1057",
+    "@fireproof/core-types-base": "0.23.1-dev-issue-1057",
+    "@fireproof/core-types-protocols-cloud": "0.23.1-dev-issue-1057",
+    "@fireproof/vendor": "0.23.1-dev-issue-1057",
     "@types/ws": "^8.18.1",
@@ -41,0 +41,0 @@ "ws": "^8.18.3"

ws-connection.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"ws-connection.js","sourceRoot":"","sources":["ws-connection.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,gBAAgB,EAAE,MAAM,EAAU,MAAM,EAAE,SAAS,EAAE,MAAM,iBAAiB,CAAC;AACtF,OAAO,EAEL,UAAU,EACV,aAAa,GAMd,MAAM,uCAAuC,CAAC;AAE/C,OAAO,EAAE,oBAAoB,EAAE,MAAM,8BAA8B,CAAC;AAEpE,OAAO,EAAE,YAAY,EAAE,MAAM,yBAAyB,CAAC;AAYvD,MAAM,WAAW;IACN,WAAW,GAAG,IAAI,GAAG,EAA0B,CAAC;IAEzD,KAAK,CAAC,KAAgB,EAAE,MAAc,EAAE,OAAmB,EAAE;QAC3D,IAAI,OAAO,GAA8C,SAAS,CAAC;QACnE,IAAI,OAAO,OAAO,CAAC,OAAO,KAAK,QAAQ,IAAI,OAAO,CAAC,OAAO,GAAG,CAAC,EAAE,CAAC;YAC/D,OAAO,GAAG,UAAU,CAAC,GAAG,EAAE,CAAC;gBACzB,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;gBACrC,OAAO,CAAC,MAAM,CAAC,OAAO,CACpB,aAAa,CACX,EAAE,MAAM,EAAE,KAAK,EAAE,EACjB;oBACE,GAAG,EAAE,OAAO,CAAC,GAAG;iBACN,EACZ,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,EAAE,GAAG,EAAE,OAAO,EAAE,CAAC,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC,OAAO,EAAE,CAC9D,CACF,CAAC;YAAA,CACH,EAAE,OAAO,CAAC,OAAO,CAAC,CAAC;QACtB,CAAC;QAED,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,OAAO,CAAC,GAAG,EAAE;YAChC,IAAI,EAAE,OAAO;YACb,OAAO;SACR,CAAC,CAAC;IAAA,CACJ;IAED,IAAI,CAAC,GAAW,EAAE;QAChB,MAAM,IAAI,GAAG,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;QACvC,IAAI,CAAC,IAAI,EAAE,CAAC;YACV,OAAO;QACT,CAAC;QACD,IAAI,IAAI,CAAC,OAAO,EAAE,CAAC;YACjB,YAAY,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;QAC7B,CAAC;QACD,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;IAAA,CAC9B;IAED,OAAO,CAAC,GAAY,EAA8B;QAChD,MAAM,IAAI,GAAG,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;QAC3C,IAAI,CAAC,IAAI,EAAE,CAAC;YACV,OAAO,SAAS,CAAC;QACnB,CAAC;QACD,IAAI,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,CAAC;YAC3B,IAAI,IAAI,CAAC,OAAO,EAAE,CAAC;gBACjB,YAAY,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;YAC7B,CAAC;YACD,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;QAChC,CAAC;QACD,OAAO,IAAI,CAAC;IAAA,CACb;CACF;AAED,MAAM,oBAAoB,GAAG,IAAI,CAAC;AAElC,MAAM,OAAO,YAAa,SAAQ,oBAAoB;IAC3C,MAAM,CAAS;IACf,IAAI,CAAsB;IAC1B,EAAE,CAAY;IAGd,MAAM,GAAG,IAAI,GAAG,EAAmB,CAAC;IACpC,QAAQ,GAAG,IAAI,GAAG,EAAiB,CAAC;IAEpC,UAAU,GAAG,IAAI,WAAW,EAAE,CAAC;IAE/B,EAAE,CAAS;IAEpB,OAAO,GAAG,KAAK,CAAC;IAEhB,YAAY,KAAgB,EAAE,EAAa,EAAE,IAAyB,EAAE,SAA2B,EAAE;QACnG,KAAK,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;QACxB,IAAI,CAAC,EAAE,GAAG,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QAC7B,IAAI,CAAC,MAAM,GAAG,YAAY,CAAC,KAAK,EAAE,cAAc,CAAC,CAAC;QAClD,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,EAAE,GAAG,EAAE,CAAC;IAAA,CAEd;IAED,KAAK,CAAC,KAAK,GAA0B;QACnC,MAAM,YAAY,GAA4B,IAAI,MAAM,EAAmB,CAAC;QAC5E,MAAM,KAAK,GAAG,UAAU,CAAC,GAAG,EAAE,CAAC;YAC7B,MAAM,GAAG,GAAG,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,SAAS,EAAE,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC,OAAO,EAAE,CAAC;YAC3F,IAAI,CAAC,KAAK,CAAC,aAAa,CAAC,IAAI,EAAE,EAAa,EAAE,GAAG,CAAC,CAAC,CAAC;YACpD,YAAY,CAAC,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,CAAC;QAAA,CACvC,EAAE,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;QAEtB,IAAI,CAAC,EAAE,CAAC,MAAM,GAAG,GAAG,EAAE,CAAC;YACrB,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC;YACpB,YAAY,CAAC,OAAO,CAAC,MAAM,CAAC,EAAE,CAAC,SAAS,CAAC,CAAC,CAAC;QAAA,CAC5C,CAAC;QACF,IAAI,CAAC,EAAE,CAAC,OAAO,GAAG,CAAC,IAAI,EAAE,EAAE,CAAC;YAE1B,MAAM,GAAG,GAAG,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC,OAAO,EAAE,CAAC;YACpE,YAAY,CAAC,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,CAAC;YACtC,MAAM,GAAG,GAAG,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,EAAE,EAAE,GAAG,CAAC,CAAC;YAC9C,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;QAAA,CACjB,CAAC;QACF,IAAI,CAAC,EAAE,CAAC,SAAS,GAAG,CAAC,GAAG,EAAE,EAAE,CAAC;YAC3B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,CAAC;gBAClB,IAAI,CAAC,KAAK,CAAC,aAAa,CAAC,IAAI,EAAE,EAAa,EAAE,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,gCAAgC,CAAC,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;YACtH,CAAC;YACD,IAAI,CAAC,YAAY,CAAC,GAAG,CAAC,CAAC;QAAA,CACxB,CAAC;QACF,IAAI,CAAC,EAAE,CAAC,OAAO,GAAG,GAAG,EAAE,CAAC;YACtB,IAAI,CAAC,OAAO,GAAG,KAAK,CAAC;YAErB,IAAI,CAAC,KAAK,EAAE,CAAC,KAAK,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC;gBAC3B,MAAM,GAAG,GAAG,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,aAAa,CAAC,CAAC,OAAO,EAAE,CAAC;gBACvE,YAAY,CAAC,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,CAAC;gBACtC,IAAI,CAAC,KAAK,CAAC,aAAa,CAAC,IAAI,EAAE,EAAE,GAAG,EAAE,UAAU,EAAa,EAAE,GAAG,CAAC,CAAC,CAAC;YAAA,CACtE,CAAC,CAAC;QAAA,CACJ,CAAC;QAEF,MAAM,KAAK,GAAG,MAAM,YAAY,CAAC,SAAS,EAAE,CAAC,OAAO,CAAC,GAAG,EAAE,CAAC;YACzD,YAAY,CAAC,KAAK,CAAC,CAAC;QAAA,CACrB,CAAC,CAAC;QACH,IAAI,KAAK,CAAC,KAAK,EAAE,EAAE,CAAC;YAClB,OAAO,KAAK,CAAC;QACf,CAAC;QAMD,OAAO,MAAM,CAAC,EAAE,CAAC,SAAS,CAAC,CAAC;IAAA,CAC7B;IAEQ,YAAY,GAAG,KAAK,EAAE,KAAmB,EAAE,EAAE,CAAC;QACrD,MAAM,IAAI,GAAG,MAAM,gBAAgB,CAAC,KAAK,IAAI,EAAE,CAAC;YAC9C,MAAM,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,SAAS,CAAC,KAAK,CAAC,IAAI,CAAC,CAAY,CAAC;YAC1E,OAAO,GAAG,CAAC;QAAA,CACZ,CAAC,CAAC;QACH,IAAI,IAAI,CAAC,KAAK,EAAE,EAAE,CAAC;YACjB,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,GAAG,CAAC,iBAAiB,CAAC,CAAC;YACpE,OAAO;QACT,CAAC;QACD,MAAM,GAAG,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QAEtB,IAAI,CAAC,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;QAE7B,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC,CAAC,OAAO,CAAC,CAAC,EAAE,EAAE,EAAE,CAAC;YAE/C,EAAE,CAAC,GAAG,CAAC,CAAC;QAAA,CACT,CAAC,CAAC;IAAA,CACJ,CAAC;IAEF,KAAK,CAAC,KAAK,GAA0B;QACnC,IAAI,CAAC,QAAQ,CAAC,OAAO,CAAC,CAAC,EAAE,EAAE,EAAE,CAAC,EAAE,EAAE,CAAC,CAAC;QACpC,IAAI,CAAC,QAAQ,CAAC,KAAK,EAAE,CAAC;QACtB,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC;QAEpB,IAAI,CAAC,EAAE,CAAC,KAAK,EAAE,CAAC;QAChB,OAAO,MAAM,CAAC,EAAE,CAAC,SAAS,CAAC,CAAC;IAAA,CAC7B;IAED,KAAK,CAAoB,GAAoB,EAAmB;QAC9D,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,EAAE,EAAE,EAAE,CAAC,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC;QACrC,OAAO,GAAG,CAAC;IAAA,CACZ;IAED,IAAI,CAAuC,GAAM,EAAc;QAE7D,IAAI,CAAC,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC;QACzC,OAAO,OAAO,CAAC,OAAO,CAAC,GAAmB,CAAC,CAAC;IAAA,CAC7C;IAED,KAAK,CAAoB,EAAc,EAAS;QAC9C,MAAM,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QACpC,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,GAAG,EAAE,EAAa,CAAC,CAAC;QACpC,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;IAAA,CACtC;IAED,OAAO,CAAC,EAAS,EAAS;QACxB,MAAM,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QACpC,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,GAAG,EAAE,EAAE,CAAC,CAAC;QAC3B,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,QAAQ,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;IAAA,CACxC;IAEQ,WAAW,GAAG,IAAI,GAAG,EAAwB,CAAC;IACvD,IAAI,CAAuC,GAAM,EAAE,IAAiB,EAAmC;QACrG,MAAM,KAAK,GAAiB;YAC1B,EAAE,EAAE,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG;YAC3B,IAAI,EAAE;gBACJ,GAAG,EAAE,GAAG;gBACR,IAAI;aACL;YAED,UAAU,EAAE,SAAS;SACC,CAAC;QACzB,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,KAAK,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC;QACtC,MAAM,GAAG,GAAG,IAAI,cAAc,CAAkB;YAC9C,MAAM,EAAE,GAAG,EAAE,CAAC;gBAEZ,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;YAAA,CACnC;YACD,KAAK,EAAE,CAAC,UAAU,EAAE,EAAE,CAAC;gBACrB,KAAK,CAAC,UAAU,GAAG,UAAU,CAAC;gBAC9B,IAAI,CAAC,KAAK,CAAI,CAAC,GAAG,EAAE,EAAE,CAAC;oBACrB,IAAI,CAAC;wBACH,IAAI,UAAU,CAAC,GAAG,CAAC,EAAE,CAAC;4BACpB,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;4BACxB,OAAO;wBACT,CAAC;wBACD,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,CAAC;4BAClB,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;wBAC1B,CAAC;6BAAM,IAAI,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,CAAC;4BAC7B,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;wBAC1B,CAAC;oBACH,CAAC;oBAAC,OAAO,GAAG,EAAE,CAAC;wBACb,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,EAAE,GAAG,EAAE,CAAC,CAAC,GAAG,CAAC,kCAAkC,CAAC,CAAC;oBACpF,CAAC;gBAAA,CACF,CAAC,CAAC;gBACH,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;gBACf,MAAM,MAAM,GAAG,IAAI,MAAM,EAAK,CAAC;gBAC/B,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,IAAI,CAAC,KAAK,EAAE,IAAI,CAAC,MAAM,EAAE,EAAE,GAAG,EAAE,GAAG,CAAC,GAAG,EAAE,MAAM,EAAE,OAAO,EAAE,IAAI,CAAC,OAAO,EAAE,CAAC,CAAC;gBAChG,MAAM,CAAC,SAAS,EAAE,CAAC,IAAI,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC;oBAC/B,IAAI,UAAU,CAAC,GAAG,CAAC,EAAE,CAAC;wBAEpB,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;wBACxB,UAAU,CAAC,KAAK,EAAE,CAAC;oBACrB,CAAC;gBAAA,CACF,CAAC,CAAC;YAAA,CACJ;SACF,CAAC,CAAC;QACH,OAAO,GAAG,CAAC;IAAA,CACZ;IAED,KAAK,CAAC,OAAO,CAAuC,GAAM,EAAE,IAAiB,EAA4B;QACvG,MAAM,MAAM,GAAG,IAAI,MAAM,EAAK,CAAC;QAC/B,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,IAAI,CAAC,KAAK,EAAE,IAAI,CAAC,MAAM,EAAE;YAC7C,GAAG,EAAE,GAAG,CAAC,GAAG;YACZ,MAAM;YACN,OAAO,EAAE,IAAI,CAAC,OAAO;YACrB,OAAO,EAAE,IAAI,CAAC,OAAO,IAAI,oBAAoB;SAC9C,CAAC,CAAC;QACH,MAAM,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QACrB,OAAO,MAAM,CAAC,SAAS,EAAE,CAAC;IAAA,CAC3B;CAMF"}
+{"version":3,"file":"ws-connection.js","sourceRoot":"","sources":["../jsr/ws-connection.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,gBAAgB,EAAE,MAAM,EAAU,MAAM,EAAE,SAAS,EAAE,MAAM,iBAAiB,CAAC;AACtF,OAAO,EAEL,UAAU,EACV,aAAa,GAMd,MAAM,uCAAuC,CAAC;AAE/C,OAAO,EAAE,oBAAoB,EAAE,MAAM,8BAA8B,CAAC;AAEpE,OAAO,EAAE,YAAY,EAAE,MAAM,yBAAyB,CAAC;AAYvD,MAAM,WAAW;IACN,WAAW,GAAG,IAAI,GAAG,EAA0B,CAAC;IAEzD,KAAK,CAAC,KAAgB,EAAE,MAAc,EAAE,OAAmB,EAAE;QAC3D,IAAI,OAAO,GAA8C,SAAS,CAAC;QACnE,IAAI,OAAO,OAAO,CAAC,OAAO,KAAK,QAAQ,IAAI,OAAO,CAAC,OAAO,GAAG,CAAC,EAAE,CAAC;YAC/D,OAAO,GAAG,UAAU,CAAC,GAAG,EAAE,CAAC;gBACzB,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;gBACrC,OAAO,CAAC,MAAM,CAAC,OAAO,CACpB,aAAa,CACX,EAAE,MAAM,EAAE,KAAK,EAAE,EACjB;oBACE,GAAG,EAAE,OAAO,CAAC,GAAG;iBACN,EACZ,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,EAAE,GAAG,EAAE,OAAO,EAAE,CAAC,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC,OAAO,EAAE,CAC9D,CACF,CAAC;YAAA,CACH,EAAE,OAAO,CAAC,OAAO,CAAC,CAAC;QACtB,CAAC;QAED,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,OAAO,CAAC,GAAG,EAAE;YAChC,IAAI,EAAE,OAAO;YACb,OAAO;SACR,CAAC,CAAC;IAAA,CACJ;IAED,IAAI,CAAC,GAAW,EAAE;QAChB,MAAM,IAAI,GAAG,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;QACvC,IAAI,CAAC,IAAI,EAAE,CAAC;YACV,OAAO;QACT,CAAC;QACD,IAAI,IAAI,CAAC,OAAO,EAAE,CAAC;YACjB,YAAY,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;QAC7B,CAAC;QACD,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;IAAA,CAC9B;IAED,OAAO,CAAC,GAAY,EAA8B;QAChD,MAAM,IAAI,GAAG,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;QAC3C,IAAI,CAAC,IAAI,EAAE,CAAC;YACV,OAAO,SAAS,CAAC;QACnB,CAAC;QACD,IAAI,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,CAAC;YAC3B,IAAI,IAAI,CAAC,OAAO,EAAE,CAAC;gBACjB,YAAY,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;YAC7B,CAAC;YACD,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;QAChC,CAAC;QACD,OAAO,IAAI,CAAC;IAAA,CACb;CACF;AAED,MAAM,oBAAoB,GAAG,IAAI,CAAC;AAElC,MAAM,OAAO,YAAa,SAAQ,oBAAoB;IAC3C,MAAM,CAAS;IACf,IAAI,CAAsB;IAC1B,EAAE,CAAY;IAGd,MAAM,GAAG,IAAI,GAAG,EAAmB,CAAC;IACpC,QAAQ,GAAG,IAAI,GAAG,EAAiB,CAAC;IAEpC,UAAU,GAAG,IAAI,WAAW,EAAE,CAAC;IAE/B,EAAE,CAAS;IAEpB,OAAO,GAAG,KAAK,CAAC;IAEhB,YAAY,KAAgB,EAAE,EAAa,EAAE,IAAyB,EAAE,SAA2B,EAAE;QACnG,KAAK,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;QACxB,IAAI,CAAC,EAAE,GAAG,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QAC7B,IAAI,CAAC,MAAM,GAAG,YAAY,CAAC,KAAK,EAAE,cAAc,CAAC,CAAC;QAClD,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,EAAE,GAAG,EAAE,CAAC;IAAA,CAEd;IAED,KAAK,CAAC,KAAK,GAA0B;QACnC,MAAM,YAAY,GAA4B,IAAI,MAAM,EAAmB,CAAC;QAC5E,MAAM,KAAK,GAAG,UAAU,CAAC,GAAG,EAAE,CAAC;YAC7B,MAAM,GAAG,GAAG,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,SAAS,EAAE,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC,GAAG,CAAC,SAAS,CAAC,CAAC,OAAO,EAAE,CAAC;YAC3F,IAAI,CAAC,KAAK,CAAC,aAAa,CAAC,IAAI,EAAE,EAAa,EAAE,GAAG,CAAC,CAAC,CAAC;YACpD,YAAY,CAAC,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,CAAC;QAAA,CACvC,EAAE,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,CAAC;QAEtB,IAAI,CAAC,EAAE,CAAC,MAAM,GAAG,GAAG,EAAE,CAAC;YACrB,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC;YACpB,YAAY,CAAC,OAAO,CAAC,MAAM,CAAC,EAAE,CAAC,SAAS,CAAC,CAAC,CAAC;QAAA,CAC5C,CAAC;QACF,IAAI,CAAC,EAAE,CAAC,OAAO,GAAG,CAAC,IAAI,EAAE,EAAE,CAAC;YAE1B,MAAM,GAAG,GAAG,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC,OAAO,EAAE,CAAC;YACpE,YAAY,CAAC,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,CAAC;YACtC,MAAM,GAAG,GAAG,IAAI,CAAC,aAAa,CAAC,IAAI,EAAE,EAAE,EAAE,GAAG,CAAC,CAAC;YAC9C,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;QAAA,CACjB,CAAC;QACF,IAAI,CAAC,EAAE,CAAC,SAAS,GAAG,CAAC,GAAG,EAAE,EAAE,CAAC;YAC3B,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,CAAC;gBAClB,IAAI,CAAC,KAAK,CAAC,aAAa,CAAC,IAAI,EAAE,EAAa,EAAE,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,gCAAgC,CAAC,CAAC,OAAO,EAAE,CAAC,CAAC,CAAC;YACtH,CAAC;YACD,IAAI,CAAC,YAAY,CAAC,GAAG,CAAC,CAAC;QAAA,CACxB,CAAC;QACF,IAAI,CAAC,EAAE,CAAC,OAAO,GAAG,GAAG,EAAE,CAAC;YACtB,IAAI,CAAC,OAAO,GAAG,KAAK,CAAC;YAErB,IAAI,CAAC,KAAK,EAAE,CAAC,KAAK,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC;gBAC3B,MAAM,GAAG,GAAG,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,aAAa,CAAC,CAAC,OAAO,EAAE,CAAC;gBACvE,YAAY,CAAC,OAAO,CAAC,MAAM,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,CAAC;gBACtC,IAAI,CAAC,KAAK,CAAC,aAAa,CAAC,IAAI,EAAE,EAAE,GAAG,EAAE,UAAU,EAAa,EAAE,GAAG,CAAC,CAAC,CAAC;YAAA,CACtE,CAAC,CAAC;QAAA,CACJ,CAAC;QAEF,MAAM,KAAK,GAAG,MAAM,YAAY,CAAC,SAAS,EAAE,CAAC,OAAO,CAAC,GAAG,EAAE,CAAC;YACzD,YAAY,CAAC,KAAK,CAAC,CAAC;QAAA,CACrB,CAAC,CAAC;QACH,IAAI,KAAK,CAAC,KAAK,EAAE,EAAE,CAAC;YAClB,OAAO,KAAK,CAAC;QACf,CAAC;QAMD,OAAO,MAAM,CAAC,EAAE,CAAC,SAAS,CAAC,CAAC;IAAA,CAC7B;IAEQ,YAAY,GAAG,KAAK,EAAE,KAAmB,EAAE,EAAE,CAAC;QACrD,MAAM,IAAI,GAAG,MAAM,gBAAgB,CAAC,KAAK,IAAI,EAAE,CAAC;YAC9C,MAAM,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,SAAS,CAAC,KAAK,CAAC,IAAI,CAAC,CAAY,CAAC;YAC1E,OAAO,GAAG,CAAC;QAAA,CACZ,CAAC,CAAC;QACH,IAAI,IAAI,CAAC,KAAK,EAAE,EAAE,CAAC;YACjB,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,GAAG,CAAC,iBAAiB,CAAC,CAAC;YACpE,OAAO;QACT,CAAC;QACD,MAAM,GAAG,GAAG,IAAI,CAAC,EAAE,EAAE,CAAC;QAEtB,IAAI,CAAC,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;QAE7B,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC,CAAC,OAAO,CAAC,CAAC,EAAE,EAAE,EAAE,CAAC;YAE/C,EAAE,CAAC,GAAG,CAAC,CAAC;QAAA,CACT,CAAC,CAAC;IAAA,CACJ,CAAC;IAEF,KAAK,CAAC,KAAK,GAA0B;QACnC,IAAI,CAAC,QAAQ,CAAC,OAAO,CAAC,CAAC,EAAE,EAAE,EAAE,CAAC,EAAE,EAAE,CAAC,CAAC;QACpC,IAAI,CAAC,QAAQ,CAAC,KAAK,EAAE,CAAC;QACtB,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC;QAEpB,IAAI,CAAC,EAAE,CAAC,KAAK,EAAE,CAAC;QAChB,OAAO,MAAM,CAAC,EAAE,CAAC,SAAS,CAAC,CAAC;IAAA,CAC7B;IAED,KAAK,CAAoB,GAAoB,EAAmB;QAC9D,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,EAAE,EAAE,EAAE,CAAC,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC;QACrC,OAAO,GAAG,CAAC;IAAA,CACZ;IAED,IAAI,CAAuC,GAAM,EAAc;QAE7D,IAAI,CAAC,EAAE,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,CAAC;QACzC,OAAO,OAAO,CAAC,OAAO,CAAC,GAAmB,CAAC,CAAC;IAAA,CAC7C;IAED,KAAK,CAAoB,EAAc,EAAS;QAC9C,MAAM,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QACpC,IAAI,CAAC,MAAM,CAAC,GAAG,CAAC,GAAG,EAAE,EAAa,CAAC,CAAC;QACpC,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,MAAM,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;IAAA,CACtC;IAED,OAAO,CAAC,EAAS,EAAS;QACxB,MAAM,GAAG,GAAG,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG,CAAC;QACpC,IAAI,CAAC,QAAQ,CAAC,GAAG,CAAC,GAAG,EAAE,EAAE,CAAC,CAAC;QAC3B,OAAO,GAAG,EAAE,CAAC,IAAI,CAAC,QAAQ,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;IAAA,CACxC;IAEQ,WAAW,GAAG,IAAI,GAAG,EAAwB,CAAC;IACvD,IAAI,CAAuC,GAAM,EAAE,IAAiB,EAAmC;QACrG,MAAM,KAAK,GAAiB;YAC1B,EAAE,EAAE,IAAI,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,GAAG;YAC3B,IAAI,EAAE;gBACJ,GAAG,EAAE,GAAG;gBACR,IAAI;aACL;YAED,UAAU,EAAE,SAAS;SACC,CAAC;QACzB,IAAI,CAAC,WAAW,CAAC,GAAG,CAAC,KAAK,CAAC,EAAE,EAAE,KAAK,CAAC,CAAC;QACtC,MAAM,GAAG,GAAG,IAAI,cAAc,CAAkB;YAC9C,MAAM,EAAE,GAAG,EAAE,CAAC;gBAEZ,IAAI,CAAC,WAAW,CAAC,MAAM,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC;YAAA,CACnC;YACD,KAAK,EAAE,CAAC,UAAU,EAAE,EAAE,CAAC;gBACrB,KAAK,CAAC,UAAU,GAAG,UAAU,CAAC;gBAC9B,IAAI,CAAC,KAAK,CAAI,CAAC,GAAG,EAAE,EAAE,CAAC;oBACrB,IAAI,CAAC;wBACH,IAAI,UAAU,CAAC,GAAG,CAAC,EAAE,CAAC;4BACpB,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;4BACxB,OAAO;wBACT,CAAC;wBACD,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,CAAC;4BAClB,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;wBAC1B,CAAC;6BAAM,IAAI,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,CAAC;4BAC7B,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;wBAC1B,CAAC;oBACH,CAAC;oBAAC,OAAO,GAAG,EAAE,CAAC;wBACb,IAAI,CAAC,MAAM,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC,GAAG,CAAC,EAAE,GAAG,EAAE,CAAC,CAAC,GAAG,CAAC,kCAAkC,CAAC,CAAC;oBACpF,CAAC;gBAAA,CACF,CAAC,CAAC;gBACH,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;gBACf,MAAM,MAAM,GAAG,IAAI,MAAM,EAAK,CAAC;gBAC/B,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,IAAI,CAAC,KAAK,EAAE,IAAI,CAAC,MAAM,EAAE,EAAE,GAAG,EAAE,GAAG,CAAC,GAAG,EAAE,MAAM,EAAE,OAAO,EAAE,IAAI,CAAC,OAAO,EAAE,CAAC,CAAC;gBAChG,MAAM,CAAC,SAAS,EAAE,CAAC,IAAI,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC;oBAC/B,IAAI,UAAU,CAAC,GAAG,CAAC,EAAE,CAAC;wBAEpB,UAAU,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;wBACxB,UAAU,CAAC,KAAK,EAAE,CAAC;oBACrB,CAAC;gBAAA,CACF,CAAC,CAAC;YAAA,CACJ;SACF,CAAC,CAAC;QACH,OAAO,GAAG,CAAC;IAAA,CACZ;IAED,KAAK,CAAC,OAAO,CAAuC,GAAM,EAAE,IAAiB,EAA4B;QACvG,MAAM,MAAM,GAAG,IAAI,MAAM,EAAK,CAAC;QAC/B,IAAI,CAAC,UAAU,CAAC,KAAK,CAAC,IAAI,CAAC,KAAK,EAAE,IAAI,CAAC,MAAM,EAAE;YAC7C,GAAG,EAAE,GAAG,CAAC,GAAG;YACZ,MAAM;YACN,OAAO,EAAE,IAAI,CAAC,OAAO;YACrB,OAAO,EAAE,IAAI,CAAC,OAAO,IAAI,oBAAoB;SAC9C,CAAC,CAAC;QACH,MAAM,IAAI,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;QACrB,OAAO,MAAM,CAAC,SAAS,EAAE,CAAC;IAAA,CAC3B;CAMF"}

http-connection.ts

-import { HttpHeader, Logger, Result, URI, exception2Result } from "@adviser/cement";
-import { SuperThis } from "@fireproof/core-types-base";
-import { ActiveStream, ExchangedGestalt, MsgerParamsWithEnDe, OnMsgFn, selectRandom, timeout, UnReg } from "./msger.js";
-import { MsgRawConnectionBase } from "./msg-raw-connection-base.js";
-import { ensureLogger } from "@fireproof/core-runtime";
-import {
-  MsgRawConnection,
-  MsgBase,
-  MsgWithError,
-  MsgIsError,
-  RequestOpts,
-  buildErrorMsg,
-} from "@fireproof/core-types-protocols-cloud";
-
-function toHttpProtocol(uri: URI): URI {
-  const protocol = (uri.getParam("protocol") ?? uri.protocol).replace(/:$/, "");
-  const toFix = uri.build();
-  switch (protocol) {
-    case "ws":
-    case "http":
-      toFix.protocol("http");
-      break;
-    case "https":
-    case "wss":
-    default:
-      toFix.protocol("https");
-      break;
-  }
-  return toFix.URI();
-}
-
-export function ensurePath(uri: URI, fp: string): string {
-  const path = uri.pathname.replace(/\/$/, "").replace(/^\//, "");
-  const buri = uri.build();
-  if (path === "") {
-    buri.appendRelative(fp);
-  }
-  return buri.toString();
-}
-
-export class HttpConnection extends MsgRawConnectionBase implements MsgRawConnection {
-  readonly logger: Logger;
-  readonly msgP: MsgerParamsWithEnDe;
-
-  readonly baseURIs: { in: URI; cleaned: URI }[];
-
-  readonly #onMsg = new Map<string, OnMsgFn>();
-
-  readonly isReady = true;
-
-  constructor(sthis: SuperThis, uris: URI[], msgP: MsgerParamsWithEnDe, exGestalt: ExchangedGestalt) {
-    super(sthis, exGestalt);
-    this.logger = ensureLogger(sthis, "HttpConnection");
-    // this.msgParam = msgP;
-    this.baseURIs = uris.map((uri) => ({
-      in: uri,
-      cleaned: toHttpProtocol(uri),
-    }));
-    this.msgP = msgP;
-  }
-
-  send<S extends MsgBase, Q extends MsgBase>(_msg: Q): Promise<MsgWithError<S>> {
-    throw new Error("Method not implemented.");
-  }
-
-  async start(): Promise<Result<void>> {
-    // if (this._qsOpen.req) {
-    //   const sOpen = await this.request(this._qsOpen.req, { waitFor: MsgIsResOpen });
-    //   if (!MsgIsResOpen(sOpen)) {
-    //     return Result.Err(this.logger.Error().Any("Err", sOpen).Msg("unexpected response").AsError());
-    //   }
-    //   this._qsOpen.res = sOpen;
-    // }
-    return Result.Ok(undefined);
-  }
-
-  async close(): Promise<Result<void>> {
-    await Promise.all(Array.from(this.activeBinds.values()).map((state) => state.controller?.close()));
-    this.#onMsg.clear();
-    return Result.Ok(undefined);
-  }
-
-  toMsg<S extends MsgBase>(msg: MsgWithError<S>): MsgWithError<S> {
-    this.#onMsg.forEach((fn) => fn(msg));
-    return msg;
-  }
-
-  onMsg(fn: OnMsgFn): UnReg {
-    const key = this.sthis.nextId().str;
-    this.#onMsg.set(key, fn);
-    return () => this.#onMsg.delete(key);
-  }
-
-  #poll(state: ActiveStream): void {
-    this.request(state.bind.msg, state.bind.opts)
-      .then((msg) => {
-        try {
-          state.controller?.enqueue(msg);
-          if (MsgIsError(msg)) {
-            state.controller?.close();
-          } else {
-            state.timeout = setTimeout(() => this.#poll(state), state.bind.opts.pollInterval ?? 1000);
-          }
-        } catch (err) {
-          state.controller?.error(err);
-          state.controller?.close();
-        }
-      })
-      .catch((err) => {
-        state.controller?.error(err);
-        // state.controller?.close();
-      });
-  }
-
-  readonly activeBinds = new Map<string, ActiveStream>();
-  bind<Q extends MsgBase, S extends MsgBase>(req: Q, opts: RequestOpts): ReadableStream<MsgWithError<S>> {
-    const state: ActiveStream = {
-      id: this.sthis.nextId().str,
-      bind: {
-        msg: req,
-        opts,
-      },
-    } satisfies ActiveStream;
-    this.activeBinds.set(state.id, state);
-    return new ReadableStream<MsgWithError<S>>({
-      cancel: () => {
-        clearTimeout(state.timeout as number);
-        this.activeBinds.delete(state.id);
-      },
-      start: (controller) => {
-        state.controller = controller;
-        this.#poll(state);
-      },
-    });
-  }
-
-  async request<Q extends MsgBase, S extends MsgBase>(req: Q, _opts: RequestOpts): Promise<MsgWithError<S>> {
-    const headers = HttpHeader.from();
-    headers.Set("Content-Type", this.msgP.mime);
-    headers.Set("Accept", this.msgP.mime);
-
-    const rReqBody = exception2Result(() => this.msgP.ende.encode(req));
-    if (rReqBody.isErr()) {
-      return this.toMsg(
-        buildErrorMsg(this, req, this.logger.Error().Err(rReqBody.Err()).Any("req", req).Msg("encode error").AsError()),
-      );
-    }
-    headers.Set("Content-Length", rReqBody.Ok().byteLength.toString());
-    const url = selectRandom(this.baseURIs);
-    // console.log("request", url.cleaned.toString(), url.in.toString(), req);
-    this.logger.Debug().Any(url).Any("body", req).Msg("request");
-    const rRes = await exception2Result(() =>
-      timeout(
-        this.msgP.timeout,
-        fetch(ensurePath(url.cleaned, "fp"), {
-          method: "PUT",
-          headers: headers.AsHeaderInit(),
-          body: rReqBody.Ok(),
-        }),
-      ),
-    );
-    this.logger.Debug().Any(url).Any("body", rRes).Msg("response");
-    if (rRes.isErr()) {
-      return this.toMsg(buildErrorMsg(this, req, this.logger.Error().Err(rRes).Any(url).Msg("fetch error").AsError()));
-    }
-    const res = rRes.Ok();
-    if (!res.ok) {
-      const data = new Uint8Array(await res.arrayBuffer());
-      const ret = await exception2Result(async () => this.msgP.ende.decode(data) as S);
-      if (ret.isErr() || !MsgIsError(ret.Ok())) {
-        return this.toMsg(
-          buildErrorMsg(
-            this,
-            req,
-            this.logger
-              .Error()
-              .Any(url)
-              .Str("status", res.status.toString())
-              .Str("statusText", res.statusText)
-              .Msg("HTTP Error")
-              .AsError(),
-            await res.text().catch(() => "no body"),
-          ),
-        );
-      }
-      return this.toMsg(ret.Ok());
-    }
-    const data = new Uint8Array(await res.arrayBuffer());
-    const ret = await exception2Result(async () => this.msgP.ende.decode(data) as S);
-    if (ret.isErr()) {
-      return this.toMsg(
-        buildErrorMsg(this, req, this.logger.Error().Err(ret.Err()).Msg("decode error").AsError(), this.sthis.txt.decode(data)),
-      );
-    }
-    return this.toMsg(ret.Ok());
-  }
-
-  // toOnMessage<T extends MsgBase>(msg: WithErrorMsg<T>): Result<WithErrorMsg<T>> {
-  //   this.mec.msgFn?.(msg as unknown as MessageEvent<MsgBase>);
-  //   return Result.Ok(msg);
-  // }
-}

index.ts

-export * from "./http-connection.js";
-export * from "./msg-raw-connection-base.js";
-export * from "./msger.js";
-export * from "./ws-connection.js";

msg-raw-connection-base.ts

-import { SuperThis } from "@fireproof/core-types-base";
-import { MsgBase, ErrorMsg, buildErrorMsg } from "@fireproof/core-types-protocols-cloud";
-import { ExchangedGestalt, OnErrorFn, UnReg } from "./msger.js";
-import { Logger } from "@adviser/cement";
-
-export class MsgRawConnectionBase {
-  readonly sthis: SuperThis;
-  readonly exchangedGestalt: ExchangedGestalt;
-
-  constructor(sthis: SuperThis, exGestalt: ExchangedGestalt) {
-    this.sthis = sthis;
-    this.exchangedGestalt = exGestalt;
-  }
-
-  readonly onErrorFns = new Map<string, OnErrorFn>();
-  onError(fn: OnErrorFn): UnReg {
-    const key = this.sthis.nextId().str;
-    this.onErrorFns.set(key, fn);
-    return () => this.onErrorFns.delete(key);
-  }
-
-  buildErrorMsg(
-    msgCtx: {
-      readonly logger: Logger;
-      readonly sthis: SuperThis;
-    },
-    msg: Partial<MsgBase>,
-    err: Error,
-  ): ErrorMsg {
-    // const logLine = this.sthis.logger.Error().Err(err).Any("msg", msg);
-    const rmsg = Array.from(this.onErrorFns.values()).reduce((msg, fn) => {
-      return fn(msg, err);
-    }, msg);
-    const emsg = buildErrorMsg(msgCtx, rmsg, err);
-    msgCtx.logger.Error().Err(err).Any("msg", rmsg).Msg("connection error");
-    return emsg;
-  }
-}

msger.ts

-import { BuildURI, CoerceURI, Logger, Result, runtimeFn, URI } from "@adviser/cement";
-import {
-  buildReqGestalt,
-  defaultGestalt,
-  EnDeCoder,
-  Gestalt,
-  MsgBase,
-  MsgerParams,
-  MsgIsResGestalt,
-  RequestOpts,
-  ResGestalt,
-  MsgWithError,
-  MsgIsError,
-  QSId,
-  ReqGestalt,
-  AuthType,
-  FPJWKCloudAuthType,
-  MsgWithConn,
-  ReqOpen,
-  ErrorMsg,
-  ReqOpenConn,
-  buildReqOpen,
-  MsgIsResOpen,
-  ResOpen,
-  MsgWithOptionalConn,
-  MsgIsConnected,
-  MsgIsWithConn,
-  MsgRawConnection,
-} from "@fireproof/core-types-protocols-cloud";
-import { ensurePath, HttpConnection } from "./http-connection.js";
-import { WSConnection } from "./ws-connection.js";
-import { SuperThis } from "@fireproof/core-types-base";
-import { ensureLogger, sleep } from "@fireproof/core-runtime";
-import pLimit from "@fireproof/vendor/p-limit";
-
-// const headers = {
-//     "Content-Type": "application/json",
-//     "Accept": "application/json",
-// };
-
-export function selectRandom<T>(arr: T[]): T {
-  return arr[Math.floor(Math.random() * arr.length)];
-}
-
-export function timeout<T>(ms: number, promise: Promise<T>): Promise<T> {
-  return new Promise((resolve, reject) => {
-    const timer = setTimeout(() => {
-      reject(new Error(`TIMEOUT after ${ms}ms`));
-    }, ms);
-    promise
-      .then(resolve)
-      .catch(reject)
-      .finally(() => clearTimeout(timer));
-  });
-}
-
-export type OnMsgFn<T extends MsgBase = MsgBase> = (msg: MsgWithError<T>) => void;
-export type UnReg = () => void;
-
-export interface ExchangedGestalt {
-  readonly my: Gestalt;
-  readonly remote: Gestalt;
-}
-
-export type OnErrorFn = (msg: Partial<MsgBase>, err: Error) => Partial<MsgBase>;
-
-export interface ActiveStream {
-  readonly id: string;
-  readonly bind: {
-    readonly msg: MsgBase;
-    readonly opts: RequestOpts;
-  };
-  timeout?: unknown;
-  controller?: ReadableStreamDefaultController<MsgWithError<MsgBase>>;
-}
-
-export function jsonEnDe(sthis: SuperThis): EnDeCoder {
-  return {
-    encode: (node: unknown) => sthis.txt.encode(JSON.stringify(node)),
-    decode: (data: Uint8Array) => JSON.parse(sthis.txt.decode(data)),
-  };
-}
-
-export type MsgerParamsWithEnDe = MsgerParams & { readonly ende: EnDeCoder };
-
-export function defaultMsgParams(sthis: SuperThis, igs: Partial<MsgerParamsWithEnDe>): MsgerParamsWithEnDe {
-  return {
-    mime: "application/json",
-    ende: jsonEnDe(sthis),
-    timeout: 3000,
-    protocolCapabilities: ["reqRes", "stream"],
-    ...igs,
-  } satisfies MsgerParamsWithEnDe;
-}
-
-export interface OpenParams {
-  readonly timeout: number;
-}
-
-export async function applyStart(prC: Promise<Result<MsgRawConnection>>): Promise<Result<MsgRawConnection>> {
-  const rC = await prC;
-  if (rC.isErr()) {
-    return rC;
-  }
-  const c = rC.Ok();
-  const r = await c.start();
-  if (r.isErr()) {
-    return Result.Err(r.Err());
-  }
-  return rC;
-}
-
-export async function authTypeFromUri(logger: Logger, curi: CoerceURI): Promise<Result<FPJWKCloudAuthType>> {
-  const uri = URI.from(curi);
-  const authJWK = uri.getParam("authJWK");
-  if (!authJWK) {
-    return logger.Error().Url(uri).Msg("authJWK is required").ResultError();
-  }
-  // const sts = await SessionTokenService.createFromEnv();
-  // const fpc = await sts.validate(authJWK);
-  // if (fpc.isErr()) {
-  //   return logger.Error().Err(fpc).Msg("Invalid authJWK").ResultError();
-  // }
-  return Result.Ok({
-    type: "fp-cloud-jwk",
-    params: {
-      // claim: fpc.Ok().payload,
-      jwk: authJWK,
-    },
-  } satisfies FPJWKCloudAuthType);
-}
-
-function initialFPUri(curl: CoerceURI): URI {
-  let gestaltUrl = URI.from(curl);
-  if (["", "/"].includes(gestaltUrl.pathname)) {
-    gestaltUrl = gestaltUrl.build().appendRelative("/fp").URI();
-  }
-  return gestaltUrl;
-}
-
-export interface MsgerConnectParams {
-  readonly msgerParam: Partial<MsgerParamsWithEnDe>;
-  readonly conn: Partial<ReqOpenConn>;
-  readonly mowh: MsgOpenWSAndHttp;
-}
-
-// eslint-disable-next-line @typescript-eslint/no-extraneous-class
-export class Msger {
-  static connect(sthis: SuperThis, curl: CoerceURI, mParam: Partial<MsgerConnectParams>): Promise<Result<VirtualConnected>> {
-    const vc = new VirtualConnected(sthis, {
-      curl,
-      conn: mParam.conn,
-      openWSorHttp: mParam.mowh,
-      msgerParams: mParam.msgerParam ?? {},
-    });
-
-    return Promise.resolve(Result.Ok(vc));
-    // return vc.connect();
-  }
-  private constructor() {
-    /* */
-  }
-}
-
-export class MsgOpenWSAndHttp {
-  async openHttp(
-    vc: SuperThis,
-    urls: URI[],
-    msgP: MsgerParamsWithEnDe,
-    exGestalt: ExchangedGestalt,
-  ): Promise<Result<MsgRawConnection>> {
-    return Result.Ok(new HttpConnection(vc, urls, msgP, exGestalt));
-  }
-
-  async openWS(
-    vc: SuperThis,
-    // qOpen: ReqOpen,
-    url: URI,
-    msgP: MsgerParamsWithEnDe,
-    exGestalt: ExchangedGestalt,
-  ): Promise<Result<MsgRawConnection>> {
-    // const { encode } = jsonEnDe(sthis);
-    url = url.build().defParam("random", vc.nextId().str).URI();
-    // console.log("openWS", url.toString());
-    // .setParam("reqOpen", sthis.txt.decode(encode(qOpen)))
-    const wsUrl = ensurePath(url, "ws");
-    let wsFactory: () => WebSocket;
-    if (runtimeFn().isNodeIsh) {
-      const { WebSocket } = await import("ws");
-      wsFactory = () => new WebSocket(wsUrl) as unknown as WebSocket;
-    } else {
-      wsFactory = () => new WebSocket(wsUrl);
-    }
-    const wsc = new WSConnection(vc, wsFactory(), msgP, exGestalt);
-    return Result.Ok(wsc);
-  }
-}
-
-interface RetryItem {
-  readonly retryCount: number;
-}
-
-export interface VirtualConnectedOptionals {
-  readonly retryCount: number; // default 3
-  readonly retryDelay: number; // default 500ms
-  readonly openWSorHttp: MsgOpenWSAndHttp;
-  readonly conn: Partial<ReqOpenConn>;
-}
-export interface VirtualConnectedRequired {
-  // readonly auth: AuthType;
-  readonly curl: CoerceURI;
-  readonly msgerParams: Partial<MsgerParamsWithEnDe>;
-}
-
-export type VirtualConnectedOpts = Partial<VirtualConnectedOptionals> & Required<VirtualConnectedRequired>;
-
-interface ActionWhatToDo<S extends MsgBase, X extends MsgWithError<S> | Result<void>> {
-  readonly whatToDo: "recurse" | "return" | "action";
-  readonly value?: X;
-}
-
-export class VirtualConnected {
-  readonly sthis: SuperThis;
-  // readonly actionQueue: ActionsQueue;
-  readonly opts: VirtualConnectedOptionals & VirtualConnectedRequired;
-  readonly mowh: MsgOpenWSAndHttp;
-  readonly logger: Logger;
-  readonly id: string;
-  exchangedGestalt?: ExchangedGestalt;
-  // readonly actionQueue: ActionsQueue;
-
-  realConn?: MsgRawConnection;
-  retries: RetryItem[] = [];
-  virtualConn?: QSId;
-
-  constructor(sthis: SuperThis, opts: VirtualConnectedOpts) {
-    this.sthis = sthis;
-    this.id = sthis.nextId().str;
-    this.logger = ensureLogger(sthis, "VirtualConnected");
-    this.opts = {
-      ...opts,
-      openWSorHttp: opts.openWSorHttp || new MsgOpenWSAndHttp(),
-      retryCount: opts.retryCount || 3,
-      retryDelay: opts.retryDelay || 500,
-      conn: { reqId: sthis.nextId().str, ...opts.conn }, // ensure conn has reqId
-    } satisfies VirtualConnectedOpts;
-    this.mowh = this.opts.openWSorHttp; // simplify the code
-  }
-
-  get conn(): QSId {
-    if (!this.virtualConn) {
-      const err = new Error("conn is not set");
-      throw err;
-    }
-    return this.virtualConn;
-  }
-
-  readonly activeBinds = new Map<string, ActiveStream>();
-
-  private async handleBindRealConn(realConn: MsgRawConnection, req: MsgWithOptionalConn, as: ActiveStream): Promise<void> {
-    const conn = { ...this.conn, ...req.conn } satisfies QSId;
-    const stream = realConn.bind<MsgBase, MsgWithConn>({ ...as.bind.msg, auth: req.auth, conn }, as.bind.opts);
-    const sreader = stream.getReader();
-    while (true) {
-      const { done, value: msg } = await sreader.read();
-      if (done) {
-        return;
-      }
-      try {
-        if (MsgIsConnected(msg, this.conn) || MsgIsConnected(msg, conn)) {
-          as.controller?.enqueue(msg);
-        }
-      } catch (err) {
-        this.sthis.logger.Error().Err(err).Any({ msg }).Msg("Error in handleBindRealConn callback[ignored]");
-      }
-    }
-  }
-
-  private ensureOpts(opts: RequestOpts): RequestOpts {
-    return {
-      ...opts,
-      timeout: opts.timeout ?? this.opts.msgerParams.timeout ?? 3000,
-    };
-  }
-
-  bind<S extends MsgWithConn, Q extends MsgWithOptionalConn>(req: Q, iopts: RequestOpts): ReadableStream<MsgWithError<S>> {
-    const opts = this.ensureOpts(iopts);
-    const id = this.sthis.nextId().str;
-    return new ReadableStream<MsgWithError<S>>({
-      cancel: (err) => {
-        this.sthis.logger.Debug().Msg("vc-bind-cancel", id, err);
-        this.activeBinds.delete(id);
-      },
-      start: (ctl) => {
-        this.getRealConn(req, opts, async (realConn: MsgRawConnection) => {
-          const as = {
-            id,
-            bind: {
-              msg: req,
-              opts,
-            },
-            controller: ctl,
-          };
-          this.activeBinds.set(id, as);
-          this.handleBindRealConn(realConn, req, as);
-          return Result.Ok(undefined);
-        }).catch((err: Error) => {
-          ctl.error({
-            type: "error",
-            src: "VirtualConnection:bind",
-            message: err.message,
-            tid: req.tid,
-            version: req.version,
-            auth: req.auth,
-            stack: [],
-          } satisfies ErrorMsg);
-        });
-      },
-    });
-  }
-
-  request<S extends MsgWithConn, Q extends MsgWithOptionalConn>(req: Q, iopts: RequestOpts): Promise<MsgWithError<S>> {
-    const opts = this.ensureOpts(iopts);
-    const realFn = (realConn: MsgRawConnection) =>
-      realConn.request<S, Q>(
-        {
-          ...req,
-          conn: { ...this.virtualConn, ...req.conn },
-        },
-        opts,
-      );
-    if (opts.rawConn) {
-      // if rawConn is provided, use it directly
-      return realFn(opts.rawConn);
-    }
-    return this.getRealConn(req, opts, realFn);
-  }
-
-  send<S extends MsgWithConn, Q extends MsgWithOptionalConn>(msg: Q): Promise<MsgWithError<S>> {
-    return this.getRealConn(
-      msg,
-      {
-        waitFor: () => true,
-      },
-      async (realConn: MsgRawConnection) => {
-        const myMsg = {
-          ...msg,
-          conn: { ...this.conn, ...msg.conn },
-        };
-        // console.log("VirtualConnected:send", this.id, myMsg);
-        const ret = await realConn.send<S, Q>(myMsg);
-        return ret;
-      },
-    );
-  }
-
-  close(t: MsgWithOptionalConn): Promise<Result<void>> {
-    return this.getRealConn(
-      t,
-      {
-        waitFor: () => true,
-        noRetry: true,
-      },
-      (realConn: MsgRawConnection) => realConn.close(t),
-    );
-  }
-
-  // eslint-disable-next-line @typescript-eslint/no-unused-vars
-  onMsg(msgFn: OnMsgFn<MsgWithConn>): UnReg {
-    throw new Error("Method not implemented.");
-  }
-
-  private async connect(
-    auth: AuthType,
-    curl: CoerceURI,
-    imsgP: Partial<MsgerParamsWithEnDe> = {},
-  ): Promise<Result<MsgRawConnection>> {
-    // initial exchange with JSON encoding
-    const jsMsgP = defaultMsgParams(this.sthis, { ...imsgP, mime: "application/json", ende: jsonEnDe(this.sthis) });
-    const gestaltUrl = initialFPUri(curl);
-    const gs = defaultGestalt(defaultMsgParams(this.sthis, imsgP), { id: "FP-Universal-Client" });
-    /*
-     * request Gestalt with Http
-     */
-    const rHC = await this.mowh.openHttp(this.sthis, [gestaltUrl], jsMsgP, { my: gs, remote: gs });
-    if (rHC.isErr()) {
-      return rHC;
-    }
-    const hc = rHC.Ok();
-    // const rAuth = await authTypeFromUri(sthis.logger, url);
-    // if (rAuth.isErr()) {
-    //   return Result.Err(rAuth)
-    // }
-    const resGestalt = await hc.request<ResGestalt, ReqGestalt>(buildReqGestalt(this.sthis, auth, gs), {
-      waitFor: MsgIsResGestalt,
-      noConn: true,
-    });
-    if (!MsgIsResGestalt(resGestalt)) {
-      return this.logger.Error().Any({ resGestalt }).Msg("should be ResGestalt").ResultError();
-    }
-    await hc.close(resGestalt /* as MsgWithConnAuth */);
-    const exGt = { my: gs, remote: resGestalt.gestalt } satisfies ExchangedGestalt;
-    const msgP = defaultMsgParams(this.sthis, imsgP);
-
-    this.exchangedGestalt = exGt;
-
-    let rRealConn: Result<MsgRawConnection>;
-    if (exGt.remote.protocolCapabilities.includes("reqRes") && !exGt.remote.protocolCapabilities.includes("stream")) {
-      // console.log("openHttp---", exGt.remote.httpEndpoints, curl?.toString(), exGt.remote.httpEndpoints.map((i) => BuildURI.from(curl).resolve(i).URI().toString()));
-      rRealConn = await this.mowh.openHttp(
-        this.sthis,
-        exGt.remote.httpEndpoints.map((i) => BuildURI.from(curl).resolve(i).URI()),
-        msgP,
-        exGt,
-      );
-    } else {
-      const wsUrl = BuildURI.from(gestaltUrl).resolve(selectRandom(exGt.remote.wsEndpoints)).URI();
-      // console.log("openWS---", wsUrl.toString(), "=====", exGt.remote.wsEndpoints);
-      rRealConn = await this.mowh.openWS(this.sthis, wsUrl, msgP, exGt);
-    }
-    if (rRealConn.isErr()) {
-      return rRealConn;
-    }
-    const realConn = rRealConn.Ok();
-    const rStart = await realConn.start();
-    if (rStart.isErr()) {
-      return Result.Err(rStart);
-    }
-    return rRealConn;
-  }
-
-  private async getQSIdWithSideEffect(rawConn: MsgRawConnection, msg: MsgBase, conn: ReqOpenConn): Promise<MsgWithError<ResOpen>> {
-    const mOpen = await this.request<ResOpen, ReqOpen>(buildReqOpen(this.sthis, msg.auth, conn), {
-      waitFor: MsgIsResOpen,
-      noConn: true,
-      rawConn,
-    });
-    if (MsgIsError(mOpen)) {
-      return mOpen;
-    }
-    this.virtualConn = mOpen.conn;
-    return mOpen;
-  }
-
-  private mutex = pLimit(1);
-
-  private async getRealConn<S extends MsgBase, Q extends MsgBase, X extends MsgWithError<S> | Result<void>>(
-    msg: Q,
-    iopts: RequestOpts,
-    action: (realConn: MsgRawConnection) => Promise<X>,
-  ): Promise<X> {
-    const opts = this.ensureOpts(iopts);
-    // const id = this.sthis.nextId().str;
-    const whatToDo = await this.mutex(async (): Promise<ActionWhatToDo<S, X>> => {
-      if (!this.realConn) {
-        if (this.retries.length >= this.opts.retryCount) {
-          return {
-            whatToDo: "return",
-            value: {
-              type: "error",
-              src: "VirtualConnection:getRealConn",
-              message: "retry count exceeded",
-              tid: msg.tid,
-              version: msg.version,
-              auth: msg.auth,
-              stack: [],
-            } satisfies ErrorMsg as unknown as X,
-          };
-        }
-        // needs to connected
-        const rConn = await this.connect(msg.auth, this.opts.curl, this.opts.msgerParams);
-        if (rConn.isErr()) {
-          this.retries.push({ retryCount: this.retries.length + 1 });
-          await sleep(this.opts.retryDelay * this.retries.length);
-          return {
-            whatToDo: "recurse",
-            // this.getRealConn(msg, opts, action);
-          };
-        }
-        this.realConn = rConn.Ok();
-        const mQSid = await this.getQSIdWithSideEffect(this.realConn, msg, {
-          reqId: this.sthis.nextId().str,
-          ...this.virtualConn,
-          ...this.opts.conn,
-        });
-        if (MsgIsError(mQSid)) {
-          return {
-            whatToDo: "return",
-            value: {
-              ...mQSid,
-              tid: msg.tid,
-              // type: msg.type,
-            } as unknown as X,
-          };
-        }
-        for (const as of this.activeBinds.values()) {
-          // async
-          void this.handleBindRealConn(this.realConn, msg, as);
-        }
-        return {
-          whatToDo: "recurse",
-        };
-        // const ret = await this.getRealConn(msg, opts, action);
-        // return ret;
-      } else {
-        if (!this.realConn.isReady) {
-          await this.realConn.close(msg);
-          this.realConn = undefined; // trigger reconnect
-          this.retries = [];
-          return { whatToDo: "recurse" };
-          // return this.getRealConn(msg, opts, action);
-        }
-        if (!opts.noConn && !this.virtualConn) {
-          const conn = MsgIsWithConn(msg) ? { conn: msg.conn } : {};
-          return {
-            whatToDo: "return",
-            value: {
-              type: "error",
-              src: msg,
-              message: "virtualConn is not set",
-              tid: msg.tid,
-              ...conn,
-              version: msg.version,
-              auth: msg.auth,
-              stack: [],
-            } satisfies ErrorMsg as unknown as X,
-          };
-        }
-        return {
-          whatToDo: "action",
-        };
-        //const ret = await action(this.realConn);
-        //return ret;
-      }
-    });
-    // need to not stuck in the mutex
-    switch (whatToDo.whatToDo) {
-      case "recurse":
-        return this.getRealConn(msg, opts, action);
-      case "return":
-        return whatToDo.value as X;
-      case "action":
-        if (!this.realConn) {
-          throw new Error("realConn is not set, this should not happen");
-        }
-        return action(this.realConn);
-      default:
-        throw new Error(`Unknown action: ${whatToDo.whatToDo} for msg: ${msg.type} with id: ${this.id}`);
-    }
-  }
-}

tsconfig.json

-{
-  "extends": [
-    "/home/runner/work/fireproof/fireproof/tsconfig.dist.json"
-  ],
-  "compilerOptions": {
-    "noEmit": false,
-    "outDir": "./"
-  },
-  "include": [
-    "**/*"
-  ],
-  "exclude": [
-    "node_modules",
-    "dist",
-    ".git",
-    ".vscode"
-  ]
-}

ws-connection.ts

-import { exception2Result, Future, Logger, Result, top_uint8 } from "@adviser/cement";
-import {
-  MsgBase,
-  MsgIsError,
-  buildErrorMsg,
-  ReqOpen,
-  WaitForTid,
-  MsgWithError,
-  RequestOpts,
-  MsgRawConnection,
-} from "@fireproof/core-types-protocols-cloud";
-import { ActiveStream, ExchangedGestalt, MsgerParamsWithEnDe, OnMsgFn, UnReg } from "./msger.js";
-import { MsgRawConnectionBase } from "./msg-raw-connection-base.js";
-import { SuperThis } from "@fireproof/core-types-base";
-import { ensureLogger } from "@fireproof/core-runtime";
-
-export interface WSReqOpen {
-  readonly reqOpen: ReqOpen;
-  readonly ws: WebSocket; // this WS is opened with a specific URL-Param
-}
-
-interface WaitForTidItem {
-  readonly opts: WaitForTid;
-  readonly timeout?: ReturnType<typeof setTimeout>;
-}
-
-class WaitForTids {
-  readonly waitForTids = new Map<string, WaitForTidItem>();
-
-  start(sthis: SuperThis, logger: Logger, waitFor: WaitForTid) {
-    let timeout: ReturnType<typeof setTimeout> | undefined = undefined;
-    if (typeof waitFor.timeout === "number" && waitFor.timeout > 0) {
-      timeout = setTimeout(() => {
-        this.waitForTids.delete(waitFor.tid);
-        waitFor.future.resolve(
-          buildErrorMsg(
-            { logger, sthis },
-            {
-              tid: waitFor.tid,
-            } as MsgBase,
-            logger.Error().Any({ tid: waitFor }).Msg("Timeout").AsError(),
-          ),
-        );
-      }, waitFor.timeout);
-    }
-    // console.log("waitForTids", waitFor.tid, waitFor.timeout);
-    this.waitForTids.set(waitFor.tid, {
-      opts: waitFor,
-      timeout,
-    });
-  }
-
-  stop(tid: string) {
-    const item = this.waitForTids.get(tid);
-    if (!item) {
-      return;
-    }
-    if (item.timeout) {
-      clearTimeout(item.timeout);
-    }
-    this.waitForTids.delete(tid);
-  }
-
-  resolve(msg: MsgBase): WaitForTidItem | undefined {
-    const item = this.waitForTids.get(msg.tid);
-    if (!item) {
-      return undefined;
-    }
-    if (item.opts.waitFor(msg)) {
-      if (item.timeout) {
-        clearTimeout(item.timeout);
-      }
-      item.opts.future.resolve(msg);
-    }
-    return item;
-  }
-}
-
-const DefaultRoundTripTime = 1000;
-
-export class WSConnection extends MsgRawConnectionBase implements MsgRawConnection {
-  readonly logger: Logger;
-  readonly msgP: MsgerParamsWithEnDe;
-  readonly ws: WebSocket;
-  // readonly baseURI: URI;
-
-  readonly #onMsg = new Map<string, OnMsgFn>();
-  readonly #onClose = new Map<string, UnReg>();
-
-  readonly waitForTid = new WaitForTids();
-
-  readonly id: string;
-
-  isReady = false;
-
-  constructor(sthis: SuperThis, ws: WebSocket, msgP: MsgerParamsWithEnDe, exGestalt: ExchangedGestalt) {
-    super(sthis, exGestalt);
-    this.id = sthis.nextId().str;
-    this.logger = ensureLogger(sthis, "WSConnection");
-    this.msgP = msgP;
-    this.ws = ws;
-    // this.wqs = { ...wsq };
-  }
-
-  async start(): Promise<Result<void>> {
-    const onOpenFuture: Future<Result<unknown>> = new Future<Result<unknown>>();
-    const timer = setTimeout(() => {
-      const err = this.logger.Error().Dur("timeout", this.msgP.timeout).Msg("Timeout").AsError();
-      this.toMsg(buildErrorMsg(this, {} as MsgBase, err));
-      onOpenFuture.resolve(Result.Err(err));
-    }, this.msgP.timeout);
-
-    this.ws.onopen = () => {
-      this.isReady = true;
-      onOpenFuture.resolve(Result.Ok(undefined));
-    };
-    this.ws.onerror = (ierr) => {
-      // console.log("onerror", this.id, ierr);
-      const err = this.logger.Error().Err(ierr).Msg("WS Error").AsError();
-      onOpenFuture.resolve(Result.Err(err));
-      const res = this.buildErrorMsg(this, {}, err);
-      this.toMsg(res);
-    };
-    this.ws.onmessage = (evt) => {
-      if (!this.isReady) {
-        this.toMsg(buildErrorMsg(this, {} as MsgBase, this.logger.Error().Msg("Received message before onOpen").AsError()));
-      }
-      this.#wsOnMessage(evt);
-    };
-    this.ws.onclose = () => {
-      this.isReady = false;
-      // console.log("onclose", this.id);
-      this.close().catch((ierr) => {
-        const err = this.logger.Error().Err(ierr).Msg("close error").AsError();
-        onOpenFuture.resolve(Result.Err(err));
-        this.toMsg(buildErrorMsg(this, { tid: "internal" } as MsgBase, err));
-      });
-    };
-    /* wait for onOpen */
-    const rOpen = await onOpenFuture.asPromise().finally(() => {
-      clearTimeout(timer);
-    });
-    if (rOpen.isErr()) {
-      return rOpen;
-    }
-    // const resOpen = await this.request(this.wqs.reqOpen, { waitFor: MsgIsResOpen });
-    // if (!MsgIsResOpen(resOpen)) {
-    //   return Result.Err(this.logger.Error().Any("ErrMsg", resOpen).Msg("Invalid response").AsError());
-    // }
-    // this.wqs.resOpen = resOpen;
-    return Result.Ok(undefined);
-  }
-
-  readonly #wsOnMessage = async (event: MessageEvent) => {
-    const rMsg = await exception2Result(async () => {
-      const msg = this.msgP.ende.decode(await top_uint8(event.data)) as MsgBase;
-      return msg;
-    });
-    if (rMsg.isErr()) {
-      this.logger.Error().Err(rMsg).Any({ event }).Msg("Invalid message");
-      return;
-    }
-    const msg = rMsg.Ok();
-    // console.log("wsOnMessage", this.id, msg);
-    this.waitForTid.resolve(msg);
-    // console.log("wsOnMessage", msg, this.#onMsg.size);
-    Array.from(this.#onMsg.values()).forEach((cb) => {
-      // console.log("cb-onmessage", this.id, msg, cb.toString());
-      cb(msg);
-    });
-  };
-
-  async close(): Promise<Result<void>> {
-    this.#onClose.forEach((fn) => fn());
-    this.#onClose.clear();
-    this.#onMsg.clear();
-    // console.lows.id, ion", this.id, new Error().stack);
-    this.ws.close();
-    return Result.Ok(undefined);
-  }
-
-  toMsg<S extends MsgBase>(msg: MsgWithError<S>): MsgWithError<S> {
-    this.#onMsg.forEach((fn) => fn(msg));
-    return msg;
-  }
-
-  send<Q extends MsgBase, S extends MsgBase>(msg: Q): Promise<S> {
-    // console.log("send", msg);
-    this.ws.send(this.msgP.ende.encode(msg));
-    return Promise.resolve(msg as unknown as S);
-  }
-
-  onMsg<S extends MsgBase>(fn: OnMsgFn<S>): UnReg {
-    const key = this.sthis.nextId().str;
-    this.#onMsg.set(key, fn as OnMsgFn);
-    return () => this.#onMsg.delete(key);
-  }
-
-  onClose(fn: UnReg): UnReg {
-    const key = this.sthis.nextId().str;
-    this.#onClose.set(key, fn);
-    return () => this.#onClose.delete(key);
-  }
-
-  readonly activeBinds = new Map<string, ActiveStream>();
-  bind<Q extends MsgBase, S extends MsgBase>(req: Q, opts: RequestOpts): ReadableStream<MsgWithError<S>> {
-    const state: ActiveStream = {
-      id: this.sthis.nextId().str,
-      bind: {
-        msg: req,
-        opts,
-      },
-      // timeout: undefined,
-      controller: undefined,
-    } satisfies ActiveStream;
-    this.activeBinds.set(state.id, state);
-    const ret = new ReadableStream<MsgWithError<S>>({
-      cancel: () => {
-        // clearTimeout(state.timeout as number);
-        this.activeBinds.delete(state.id);
-      },
-      start: (controller) => {
-        state.controller = controller; // set controller in ActiveStream
-        this.onMsg<S>((msg) => {
-          try {
-            if (MsgIsError(msg)) {
-              controller.enqueue(msg);
-              return;
-            }
-            if (!opts.waitFor) {
-              controller.enqueue(msg);
-            } else if (opts.waitFor(msg)) {
-              controller.enqueue(msg);
-            }
-          } catch (err) {
-            this.logger.Error().Err(err).Any({ msg }).Msg("Error in onMsg callback[ignored]");
-          }
-        });
-        this.send(req);
-        const future = new Future<S>();
-        this.waitForTid.start(this.sthis, this.logger, { tid: req.tid, future, waitFor: opts.waitFor });
-        future.asPromise().then((msg) => {
-          if (MsgIsError(msg)) {
-            // double err emitting
-            controller.enqueue(msg);
-            controller.close();
-          }
-        });
-      },
-    });
-    return ret;
-  }
-
-  async request<Q extends MsgBase, S extends MsgBase>(req: Q, opts: RequestOpts): Promise<MsgWithError<S>> {
-    const future = new Future<S>();
-    this.waitForTid.start(this.sthis, this.logger, {
-      tid: req.tid,
-      future,
-      waitFor: opts.waitFor,
-      timeout: opts.timeout ?? DefaultRoundTripTime,
-    });
-    await this.send(req);
-    return future.asPromise();
-  }
-
-  // toOnMessage<T extends MsgBase>(msg: WithErrorMsg<T>): Result<WithErrorMsg<T>> {
-  //   this.mec.msgFn?.(msg as unknown as MessageEvent<MsgBase>);
-  //   return Result.Ok(msg);
-  // }
-}

New alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Fixed alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Long strings

Supply chain risk

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

Found 1 instance in 1 package

Improved metrics

Number of low supply chain risk alerts

0

-100%

Number of medium supply chain risk alerts

2

-50%

Worsened metrics

Total package byte prevSize

85963

-28.1%

Number of package files

18

-25%

Lines of code

912

-52.23%

Dependency changes

• + Added

  @fireproof/core-runtime@0.23.1-dev-issue-1057
  (transitive)

• + Added

  @fireproof/core-types-base@0.23.1-dev-issue-1057
  (transitive)

• + Added

  @fireproof/core-types-blockstore@0.23.1-dev-issue-1057
  (transitive)

• + Added

  @fireproof/core-types-protocols-cloud@0.23.1-dev-issue-1057
  (transitive)

• + Added

  @fireproof/core-types-runtime@0.23.1-dev-issue-1057
  (transitive)

• + Added

  @fireproof/vendor@0.23.1-dev-issue-1057
  (transitive)

• - Removed

  @fireproof/core-runtime@0.23.0
  (transitive)

• - Removed

  @fireproof/core-types-base@0.23.0
  (transitive)

• - Removed

  @fireproof/core-types-blockstore@0.23.0
  (transitive)

• - Removed

  @fireproof/core-types-protocols-cloud@0.23.0
  (transitive)

• - Removed

  @fireproof/core-types-runtime@0.23.0
  (transitive)

• - Removed

  @fireproof/vendor@0.23.0
  (transitive)

• Updated

  @adviser/cement@^0.4.23

• Updated

  @fireproof/core-runtime@0.23.1-dev-issue-1057

• Updated

  @fireproof/core-types-base@0.23.1-dev-issue-1057

• Updated

  @fireproof/core-types-protocols-cloud@0.23.1-dev-issue-1057

• Updated

  @fireproof/vendor@0.23.1-dev-issue-1057