From 04e7992c01df2598de14306028bf4e22808a0094 Mon Sep 17 00:00:00 2001 From: Richard Rodger Date: Thu, 25 Jan 2024 23:49:48 +0000 Subject: [PATCH] v1.2.0 --- dist/gateway.d.ts | 2 +- dist/gateway.js | 4 ++++ dist/gateway.js.map | 2 +- package.json | 6 +++--- src/gateway.ts | 7 ++++++- 5 files changed, 15 insertions(+), 6 deletions(-) diff --git a/dist/gateway.d.ts b/dist/gateway.d.ts index 51bcdd5..d0b455e 100644 --- a/dist/gateway.d.ts +++ b/dist/gateway.d.ts @@ -33,7 +33,7 @@ type GatewayOptions = { declare function gateway(this: any, options: GatewayOptions): { exports: { prepare: (json: any, ctx: any) => Promise; - handler: (json: any, ctx: any) => Promise; + handler: (json: any, ctx?: any) => Promise; parseJSON: (data: any) => any; }; }; diff --git a/dist/gateway.js b/dist/gateway.js index b9a7a3f..4bdbb3a 100644 --- a/dist/gateway.js +++ b/dist/gateway.js @@ -80,6 +80,7 @@ function gateway(options) { if (options.debug.log) { root.log.debug('gateway-handler-json', { json }); } + const gateway$ = (ctx === null || ctx === void 0 ? void 0 : ctx.gateway$) || {}; const seneca = await prepare(json, ctx); const rawmsg = tu.internalize_msg(seneca, json); const msg = seneca.util.clean(rawmsg); @@ -163,6 +164,9 @@ function gateway(options) { if (options.debug.log) { seneca.log.debug('handler-act', { msg }); } + if (gateway$.local) { + msg.local$ = true; + } seneca.act(msg, async function (err, out, meta) { for (var i = 0; i < hooks.result.length; i++) { await hooks.result[i].call(seneca, out, msg, err, meta, ctx); diff --git a/dist/gateway.js.map b/dist/gateway.js.map index c32ad83..b3741e0 100644 --- a/dist/gateway.js.map +++ b/dist/gateway.js.map @@ -1 +1 @@ -{"version":3,"file":"gateway.js","sourceRoot":"","sources":["../src/gateway.ts"],"names":[],"mappings":";AAAA,wDAAwD;;;;;AAGxD,oDAA2B;AAE3B,MAAM,EAAE,IAAI,EAAE,IAAI,EAAE,GAAG,gBAAM,CAAC,KAAK,CAAA;AAuDnC,SAAS,OAAO,CAAY,OAAuB;IACjD,IAAI,MAAM,GAAQ,IAAI,CAAA;IACtB,MAAM,IAAI,GAAQ,MAAM,CAAC,IAAI,CAAA;IAC7B,MAAM,EAAE,GAAQ,MAAM,CAAC,MAAM,CAAC,iBAAiB,CAAC,CAAA;IAEhD,MAAM,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,MAAM,CAAA;IACjC,MAAM,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,MAAM,CAAA;IACjC,MAAM,OAAO,GAAG,IAAI,MAAM,CAAC,EAAE,GAAG,EAAE,IAAI,EAAE,CAAC,CAAA;IACzC,MAAM,KAAK,GAAG,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,EAAE,MAAM,EAAE,CAAC,EAAE,CAAC,CAAA;IAE5C,MAAM,YAAY,GAAG,IAAI,IAAI,OAAO,CAAC,KAAK,CAAA;IAE1C,IAAI,YAAY,EAAE,CAAC;QACjB,KAAK,IAAI,QAAQ,IAAI,OAAO,CAAC,KAAK,EAAE,CAAC;YACnC,IAAI,WAAW,GAAG,MAAM,CAAC,QAAQ,CAAC,CAAA;YAClC,IAAI,SAAS,GAAG,OAAO,CAAC,KAAK,CAAC,QAAQ,CAAC,CAAA;YACvC,IAAI,YAAY,CAAA;YAEhB,IAAI,YAAY,GAAG,KAAK,CAAA;YAExB,IAAI,IAAI,KAAK,SAAS,EAAE,CAAC;gBACvB,YAAY,GAAG,IAAI,CAAA;YACrB,CAAC;iBACI,IAAI,KAAK,CAAC,OAAO,CAAC,SAAS,CAAC,EAAE,CAAC;gBAClC,YAAY,GAAG,SAAS,CAAC,GAAG,CAAC,EAAE,CAAC,EAAE,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC,CAAA;gBAC9C,YAAY,GAAG,CAAC,GAAG,YAAY,CAAC,MAAM,CAAC,CAAC;oBACtC,YAAY,CAAC,MAAM,CAAC,CAAC,MAAqB,EAAE,EAAU,EAAE,EAAE,CACxD,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE,EAAE,IAAI,CAAC,SAAS,CAAC,EAAE,CAAC,CAAC,OAAO,CAAC,IAAI,EAAE,EAAE,CAAC,CAAC,CAAC,EAAE,IAAI,MAAM,CAAC,EAAE,GAAG,EAAE,IAAI,EAAE,CAAC,CAAC,CAAC,CAAC;oBACtF,IAAI,CAAA;YACR,CAAC;YAED,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;gBACtB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,uBAAuB,EAAE,WAAW,EAAE,YAAY,CAAC,CAAA;YACpE,CAAC;YAED,OAAO,CAAC,GAAG,CAAC,WAAW,EAAE,YAAY,CAAC,CAAA;QACxC,CAAC;QAED,6CAA6C;IAC/C,CAAC;IAGD,MAAM,SAAS,GAAG;QAEhB,6EAA6E;QAC7E,QAAQ;QAER,6DAA6D;QAC7D,OAAO;QAEP,kDAAkD;QAClD,UAAU;QAEV,uBAAuB;QACvB,4CAA4C;QAC5C,QAAQ;QAER,sBAAsB;QACtB,iCAAiC;QACjC,QAAQ;KACT,CAAA;IAED,MAAM,KAAK,GAAQ,SAAS,CAAC,MAAM,CAAC,CAAC,CAAM,EAAE,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,CAAC,EAAE,EAAE,CAAC,CAAA;IAEtE,MAAM,GAAG,GAAG,MAAM,CAAC,MAAM,CAAC,GAAG,CAAA;IAC7B,IAAI,IAAI,IAAI,GAAG,IAAI,GAAG,KAAK,GAAG,EAAE,CAAC;QAC/B,MAAM,GAAG,MAAM,CAAC,GAAG,CAAC,EAAE,GAAG,EAAE,CAAC,CAAA;IAC9B,CAAC;IAGD,MAAM,CAAC,OAAO,CAAC,sBAAsB,EAAE,KAAK,UAAU,QAAQ,CAAC,GAAQ;QACrE,IAAI,IAAI,GAAW,GAAG,CAAC,IAAI,CAAA;QAC3B,IAAI,MAAM,GAA8B,GAAG,CAAC,MAAM,CAAA;QAElD,IAAI,IAAI,IAAI,MAAM,EAAE,CAAC;YACnB,IAAI,WAAW,GAAG,KAAK,CAAC,IAAI,CAAC,CAAA;YAC7B,WAAW,CAAC,IAAI,CAAC,MAAM,CAAC,CAAA;YACxB,OAAO,EAAE,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,KAAK,EAAE,WAAW,CAAC,MAAM,EAAE,CAAA;QACtD,CAAC;aACI,CAAC;YACJ,sDAAsD;YACtD,kCAAkC;YAClC,OAAO,EAAE,EAAE,EAAE,KAAK,EAAE,GAAG,EAAE,WAAW,EAAE,CAAA;QACxC,CAAC;IACH,CAAC,CAAC,CAAA;IAGF,MAAM,CAAC,OAAO,CAAC,uBAAuB,EAAE,KAAK,UAAU,QAAQ,CAAC,GAAQ;QACtE,IAAI,IAAI,GAAW,GAAG,CAAC,IAAI,CAAA;QAC3B,IAAI,WAAW,GAAG,KAAK,CAAC,IAAI,CAAC,CAAA;QAC7B,OAAO,EAAE,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,KAAK,EAAE,WAAW,CAAC,MAAM,EAAE,KAAK,EAAE,WAAW,EAAE,CAAA;IAC1E,CAAC,CAAC,CAAA;IAGF,+EAA+E;IAC/E,KAAK,UAAU,OAAO,CAAC,IAAS,EAAE,GAAQ;QACxC,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;YACtB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,sBAAsB,EAAE,EAAE,IAAI,EAAE,CAAC,CAAA;QAClD,CAAC;QAED,MAAM,MAAM,GAAG,MAAM,OAAO,CAAC,IAAI,EAAE,GAAG,CAAC,CAAA;QACvC,MAAM,MAAM,GAAG,EAAE,CAAC,eAAe,CAAC,MAAM,EAAE,IAAI,CAAC,CAAA;QAC/C,MAAM,GAAG,GAAG,MAAM,CAAC,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,CAAA;QAErC,qDAAqD;QACrD,IAAI,OAAO,CAAC,OAAO,CAAC,MAAM,IAAI,IAAI,IAAI,MAAM,CAAC,QAAQ,EAAE,CAAC;YACtD,IAAI,aAAa,GAAG,CAAC,MAAM,CAAC,QAAQ,CAAA;YACpC,IAAI,UAAU,GAAG,OAAO,CAAC,OAAO,CAAC,GAAG,CAAA;YACpC,UAAU,GAAG,CAAC,GAAG,UAAU,CAAC,CAAC,CAAC,UAAU,CAAC,CAAC,CAAC,MAAM,CAAC,OAAO,EAAE,CAAC,OAAO,CAAA;YACnE,IAAI,aAAa,IAAI,UAAU,EAAE,CAAC;gBAChC,GAAG,CAAC,QAAQ,GAAG,aAAa,CAAA;YAC9B,CAAC;QACH,CAAC;QAED,OAAO,MAAM,IAAI,OAAO,CAAC,KAAK,EAAE,OAAO,EAAE,EAAE;YACzC,IAAI,YAAY,EAAE,CAAC;gBACjB,IAAI,QAAQ,GAAG,KAAK,CAAA;gBACpB,IAAI,WAAW,GAAG,IAAI,CAAA;gBAGtB,sCAAsC;gBACtC,IAAI,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;gBAE7B,IAAI,MAAM,EAAE,CAAC;oBACX,mDAAmD;oBACnD,mEAAmE;oBACnE,0EAA0E;oBAC1E,mEAAmE;oBACnE,mFAAmF;oBACnF,WAAW,GAAG,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAA;gBAC7C,CAAC;qBACI,CAAC;oBACJ,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,eAAe,EAAE,EAAE,GAAG,EAAE,CAAC,CAAA;gBAC5C,CAAC;gBAGD,IAAI,IAAI,KAAK,WAAW,EAAE,CAAC;oBACzB,QAAQ,GAAG,IAAI,CAAA;gBACjB,CAAC;qBACI,IAAI,WAAW,aAAX,WAAW,uBAAX,WAAW,CAAE,IAAI,EAAE,CAAC;oBAC3B,QAAQ,GAAG,WAAW,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;gBAClC,CAAC;gBAGD,IAAI,CAAC,QAAQ,EAAE,CAAC;oBACd,IAAI,OAAO,GAAQ;wBACjB,IAAI,EAAE,OAAO;wBACb,EAAE,EAAE,KAAK,EAAE;wBACX,IAAI,EAAE,aAAa;wBACnB,OAAO,EAAE,qBAAqB;wBAC9B,OAAO,EAAE,SAAS;qBACnB,CAAA;oBAED,IAAI,OAAO,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;wBAC3B,OAAO,CAAC,OAAO,GAAG,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,SAAS,CAAA;wBACrD,OAAO,CAAC,OAAO,GAAG,MAAM,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,CAAC,SAAS,CAAA;oBACjD,CAAC;oBAED,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;wBACtB,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,qBAAqB,EACpC,EAAE,QAAQ,EAAE,OAAO,EAAE,MAAM,aAAN,MAAM,uBAAN,MAAM,CAAE,OAAO,EAAE,OAAO,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,CAAA;oBACjE,CAAC;oBAED,OAAO,OAAO,CAAC;wBACb,KAAK,EAAE,IAAI;wBAEX,oCAAoC;wBACpC,GAAG,EAAE;4BACH,GAAG,MAAM,CAAC,OAAO,CAAC;4BAElB,KAAK,EAAE;gCACL,EAAE,EAAE,MAAM,CAAC,GAAG;gCACd,KAAK,EAAE,IAAI;6BACZ;4BAED,+BAA+B;4BAC/B,MAAM,EAAE,MAAM,CAAC,OAAO,CAAC;yBACxB;qBACF,CAAC,CAAA;gBACJ,CAAC;qBACI,CAAC;oBACJ,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;wBACtB,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,iBAAiB,EAAE,EAAE,OAAO,EAAE,MAAM,CAAC,OAAO,EAAE,MAAM,EAAE,QAAQ,EAAE,CAAC,CAAA;oBACpF,CAAC;gBACH,CAAC;YACH,CAAC;YAED,IAAI,GAAG,GAAG,IAAI,CAAA;YACd,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,KAAK,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;gBAC7C,GAAG,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,MAAM,EAAE,GAAG,EAAE,GAAG,CAAC,CAAA;gBAClD,IAAI,GAAG,EAAE,CAAC;oBACR,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;wBACtB,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,qBAAqB,EAAE,EAAE,GAAG,EAAE,GAAG,EAAE,CAAC,CAAA;oBACvD,CAAC;oBACD,OAAO,OAAO,CAAC,GAAG,CAAC,CAAA;gBACrB,CAAC;YACH,CAAC;YAED,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;gBACtB,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,aAAa,EAAE,EAAE,GAAG,EAAE,CAAC,CAAA;YAC1C,CAAC;YAED,MAAM,CAAC,GAAG,CAAC,GAAG,EAAE,KAAK,WAAqB,GAAQ,EAAE,GAAQ,EAAE,IAAS;gBACrE,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,KAAK,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;oBAC7C,MAAM,KAAK,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,MAAM,EAAE,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,IAAI,EAAE,GAAG,CAAC,CAAA;gBAC9D,CAAC;gBAED,IAAI,GAAG,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;oBACnC,GAAG,CAAC,KAAK,GAAG,IAAI,CAAA;gBAClB,CAAC;gBAED,GAAG,GAAG,EAAE,CAAC,iBAAiB,CAAC,IAAI,EAAE,GAAG,EAAE,GAAG,EAAE,IAAI,CAAC,CAAA;gBAEhD,kDAAkD;gBAClD,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;oBAC5B,IAAI,GAAG,CAAC,KAAK,EAAE,CAAC;wBACd,GAAG,CAAC,KAAK,GAAG;4BACV,EAAE,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE;yBACjB,CAAA;oBACH,CAAC;gBACH,CAAC;gBAED,IAAI,MAAM,GAAkB;oBAC1B,KAAK,EAAE,KAAK;oBACZ,GAAG;oBACH,IAAI;oBACJ,QAAQ,EAAE,GAAG,CAAC,QAAQ,IAAI,EAAE;iBAC7B,CAAA;gBAED,yCAAyC;gBACzC,OAAO,GAAG,CAAC,QAAQ,CAAA;gBAEnB,IAAI,GAAG,EAAE,CAAC;oBACR,MAAM,CAAC,KAAK,GAAG,IAAI,CAAA;oBACnB,GAAG,CAAC,KAAK,CAAC,KAAK,GAAG,IAAI,CAAA;oBAEtB,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC;wBAClB,KAAK,EAAE,GAAG,CAAC,KAAK;wBAChB,IAAI,EAAE,GAAG,CAAC,IAAI;wBACd,EAAE,EAAG,GAAW,CAAC,EAAE,IAAI,KAAK,EAAE;wBAC9B,IAAI,EAAG,GAAW,CAAC,IAAI;wBACvB,OAAO,EAAE,OAAO,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,GAAG,CAAC,OAAO,CAAC,CAAC,CAAC,SAAS;wBACxD,OAAO,EAAE,OAAO,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,GAAG,CAAC,OAAO,CAAC,CAAC,CAAC,SAAS;qBACzD,CAAC,CAAA;gBACJ,CAAC;gBAED,OAAO,CAAC,MAAM,CAAC,CAAA;YACjB,CAAC,CAAC,CAAA;QACJ,CAAC,CAAC,CAAA;IACJ,CAAC;IAGD,KAAK,UAAU,OAAO,CAAC,IAAS,EAAE,GAAQ;QACxC,IAAI,CAAC,EAAE,UAAU,CAAA;QAEjB,IAAI,MAAM,GAAQ,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,EAAE,OAAO,CAAC,MAAM,CAAC,CAAA;QACtD,KAAK,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,KAAK,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;YACzC,UAAU,GAAG,KAAK,CAAC,MAAM,CAAC,CAAC,CAAC,CAAA;YAC5B,IAAI,QAAQ,KAAK,OAAO,CAAC,UAAU,CAAC,EAAE,CAAC;gBACrC,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,EAAE,UAAU,CAAC,CAAA;YAC/C,CAAC;iBACI,CAAC;gBACJ,MAAM,UAAU,CAAC,MAAM,EAAE,IAAI,EAAE,GAAG,CAAC,CAAA;YACrC,CAAC;QACH,CAAC;QAGD,IAAI,KAAK,GAAQ,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,EAAE,OAAO,CAAC,KAAK,CAAC,CAAA;QACpD,KAAK,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,KAAK,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;YACxC,UAAU,GAAG,KAAK,CAAC,KAAK,CAAC,CAAC,CAAC,CAAA;YAC3B,IAAI,QAAQ,KAAK,OAAO,CAAC,UAAU,CAAC,EAAE,CAAC;gBACrC,KAAK,GAAG,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,KAAK,EAAE,UAAU,CAAC,CAAA;YAC7C,CAAC;iBACI,CAAC;gBACJ,MAAM,UAAU,CAAC,KAAK,EAAE,IAAI,EAAE,GAAG,CAAC,CAAA;YACpC,CAAC;QACH,CAAC;QAED,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;YACtB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,yBAAyB,EAAE,EAAE,KAAK,EAAE,MAAM,EAAE,CAAC,CAAA;QAC9D,CAAC;QAED,wEAAwE;QACxE,MAAM,QAAQ,GAAG,IAAI,CAAC,QAAQ,CAAC,KAAK,EAAE,EAAE,MAAM,EAAE,MAAM,EAAE,CAAC,CAAA;QAEzD,KAAK,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,KAAK,CAAC,QAAQ,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;YAC3C,MAAM,KAAK,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,QAAQ,EAAE,IAAI,EAAE,GAAG,CAAC,CAAA;QACnD,CAAC;QAED,OAAO,QAAQ,CAAA;IACjB,CAAC;IAGD,SAAS,SAAS,CAAC,IAAS;QAC1B,IAAI,IAAI,IAAI,IAAI;YAAE,OAAO,EAAE,CAAA;QAE3B,IAAI,GAAG,GAAG,MAAM,CAAC,IAAI,CAAC,CAAA;QAEtB,IAAI,CAAC;YACH,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;QACxB,CAAC;QAAC,OAAO,CAAM,EAAE,CAAC;YAChB,CAAC,CAAC,QAAQ,GAAG;gBACX,MAAM,EAAE,CAAC,CAAC,OAAO;gBACjB,MAAM,EAAE,GAAG;aACZ,CAAA;YACD,OAAO,CAAC,CAAA;QACV,CAAC;IACH,CAAC;IAED,OAAO;QACL,OAAO,EAAE;YACP,OAAO;YACP,OAAO;YACP,SAAS;SACV;KACF,CAAA;AACH,CAAC;AAGD,SAAS,MAAM,CAAC,CAAM;IACpB,KAAK,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC;QAChB,IAAI,SAAS,KAAK,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;YACvB,OAAO,CAAC,CAAC,CAAC,CAAC,CAAA;QACb,CAAC;IACH,CAAC;IACD,OAAO,CAAC,CAAA;AACV,CAAC;AAGD,mBAAmB;AACnB,OAAO,CAAC,QAAQ,GAAI;IAElB,4BAA4B;IAC5B,KAAK,EAAE,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,CAAC;IAErB,+BAA+B;IAC/B,MAAM,EAAE,IAAI,CAAC;QAEX,sDAAsD;QACtD,IAAI,EAAE,KAAK;KACZ,CAAC;IAEF,qCAAqC;IACrC,KAAK,EAAE,IAAI,CAAC,EAAE,CAAC;IAEf,wEAAwE;IACxE,OAAO,EAAE;QAEP,oCAAoC;QACpC,MAAM,EAAE,KAAK;QAEb,uCAAuC;QACvC,sCAAsC;QACtC,GAAG,EAAE,CAAC,CAAC;KACR;IAED,KAAK,EAAE;QACL,yDAAyD;QACzD,OAAO,EAAE,KAAK;QAEd,yDAAyD;QACzD,OAAO,EAAE,KAAK;KACf;IAGD,wBAAwB;IACxB,KAAK,EAAE;QAEL,kEAAkE;QAClE,QAAQ,EAAE,KAAK;QAEf,kCAAkC;QAClC,GAAG,EAAE,KAAK;KACX;CACiB,CAAA;AAQpB,kBAAe,OAAO,CAAA;AAEtB,IAAI,WAAW,KAAK,OAAO,CAAC,MAAM,CAAC,EAAE,CAAC;IACpC,MAAM,CAAC,OAAO,GAAG,OAAO,CAAA;AAC1B,CAAC"} \ No newline at end of file +{"version":3,"file":"gateway.js","sourceRoot":"","sources":["../src/gateway.ts"],"names":[],"mappings":";AAAA,wDAAwD;;;;;AAGxD,oDAA2B;AAE3B,MAAM,EAAE,IAAI,EAAE,IAAI,EAAE,GAAG,gBAAM,CAAC,KAAK,CAAA;AAuDnC,SAAS,OAAO,CAAY,OAAuB;IACjD,IAAI,MAAM,GAAQ,IAAI,CAAA;IACtB,MAAM,IAAI,GAAQ,MAAM,CAAC,IAAI,CAAA;IAC7B,MAAM,EAAE,GAAQ,MAAM,CAAC,MAAM,CAAC,iBAAiB,CAAC,CAAA;IAEhD,MAAM,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,MAAM,CAAA;IACjC,MAAM,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,MAAM,CAAA;IACjC,MAAM,OAAO,GAAG,IAAI,MAAM,CAAC,EAAE,GAAG,EAAE,IAAI,EAAE,CAAC,CAAA;IACzC,MAAM,KAAK,GAAG,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,EAAE,MAAM,EAAE,CAAC,EAAE,CAAC,CAAA;IAE5C,MAAM,YAAY,GAAG,IAAI,IAAI,OAAO,CAAC,KAAK,CAAA;IAE1C,IAAI,YAAY,EAAE,CAAC;QACjB,KAAK,IAAI,QAAQ,IAAI,OAAO,CAAC,KAAK,EAAE,CAAC;YACnC,IAAI,WAAW,GAAG,MAAM,CAAC,QAAQ,CAAC,CAAA;YAClC,IAAI,SAAS,GAAG,OAAO,CAAC,KAAK,CAAC,QAAQ,CAAC,CAAA;YACvC,IAAI,YAAY,CAAA;YAEhB,IAAI,YAAY,GAAG,KAAK,CAAA;YAExB,IAAI,IAAI,KAAK,SAAS,EAAE,CAAC;gBACvB,YAAY,GAAG,IAAI,CAAA;YACrB,CAAC;iBACI,IAAI,KAAK,CAAC,OAAO,CAAC,SAAS,CAAC,EAAE,CAAC;gBAClC,YAAY,GAAG,SAAS,CAAC,GAAG,CAAC,EAAE,CAAC,EAAE,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC,CAAA;gBAC9C,YAAY,GAAG,CAAC,GAAG,YAAY,CAAC,MAAM,CAAC,CAAC;oBACtC,YAAY,CAAC,MAAM,CAAC,CAAC,MAAqB,EAAE,EAAU,EAAE,EAAE,CACxD,CAAC,MAAM,CAAC,GAAG,CAAC,EAAE,EAAE,IAAI,CAAC,SAAS,CAAC,EAAE,CAAC,CAAC,OAAO,CAAC,IAAI,EAAE,EAAE,CAAC,CAAC,CAAC,EAAE,IAAI,MAAM,CAAC,EAAE,GAAG,EAAE,IAAI,EAAE,CAAC,CAAC,CAAC,CAAC;oBACtF,IAAI,CAAA;YACR,CAAC;YAED,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;gBACtB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,uBAAuB,EAAE,WAAW,EAAE,YAAY,CAAC,CAAA;YACpE,CAAC;YAED,OAAO,CAAC,GAAG,CAAC,WAAW,EAAE,YAAY,CAAC,CAAA;QACxC,CAAC;QAED,6CAA6C;IAC/C,CAAC;IAGD,MAAM,SAAS,GAAG;QAEhB,6EAA6E;QAC7E,QAAQ;QAER,6DAA6D;QAC7D,OAAO;QAEP,kDAAkD;QAClD,UAAU;QAEV,uBAAuB;QACvB,4CAA4C;QAC5C,QAAQ;QAER,sBAAsB;QACtB,iCAAiC;QACjC,QAAQ;KACT,CAAA;IAED,MAAM,KAAK,GAAQ,SAAS,CAAC,MAAM,CAAC,CAAC,CAAM,EAAE,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,CAAC,EAAE,EAAE,CAAC,CAAA;IAEtE,MAAM,GAAG,GAAG,MAAM,CAAC,MAAM,CAAC,GAAG,CAAA;IAC7B,IAAI,IAAI,IAAI,GAAG,IAAI,GAAG,KAAK,GAAG,EAAE,CAAC;QAC/B,MAAM,GAAG,MAAM,CAAC,GAAG,CAAC,EAAE,GAAG,EAAE,CAAC,CAAA;IAC9B,CAAC;IAGD,MAAM,CAAC,OAAO,CAAC,sBAAsB,EAAE,KAAK,UAAU,QAAQ,CAAC,GAAQ;QACrE,IAAI,IAAI,GAAW,GAAG,CAAC,IAAI,CAAA;QAC3B,IAAI,MAAM,GAA8B,GAAG,CAAC,MAAM,CAAA;QAElD,IAAI,IAAI,IAAI,MAAM,EAAE,CAAC;YACnB,IAAI,WAAW,GAAG,KAAK,CAAC,IAAI,CAAC,CAAA;YAC7B,WAAW,CAAC,IAAI,CAAC,MAAM,CAAC,CAAA;YACxB,OAAO,EAAE,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,KAAK,EAAE,WAAW,CAAC,MAAM,EAAE,CAAA;QACtD,CAAC;aACI,CAAC;YACJ,sDAAsD;YACtD,kCAAkC;YAClC,OAAO,EAAE,EAAE,EAAE,KAAK,EAAE,GAAG,EAAE,WAAW,EAAE,CAAA;QACxC,CAAC;IACH,CAAC,CAAC,CAAA;IAGF,MAAM,CAAC,OAAO,CAAC,uBAAuB,EAAE,KAAK,UAAU,QAAQ,CAAC,GAAQ;QACtE,IAAI,IAAI,GAAW,GAAG,CAAC,IAAI,CAAA;QAC3B,IAAI,WAAW,GAAG,KAAK,CAAC,IAAI,CAAC,CAAA;QAC7B,OAAO,EAAE,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,KAAK,EAAE,WAAW,CAAC,MAAM,EAAE,KAAK,EAAE,WAAW,EAAE,CAAA;IAC1E,CAAC,CAAC,CAAA;IAGF,+EAA+E;IAC/E,KAAK,UAAU,OAAO,CAAC,IAAS,EAAE,GAAS;QACzC,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;YACtB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,sBAAsB,EAAE,EAAE,IAAI,EAAE,CAAC,CAAA;QAClD,CAAC;QAED,MAAM,QAAQ,GAAG,CAAA,GAAG,aAAH,GAAG,uBAAH,GAAG,CAAE,QAAQ,KAAI,EAAE,CAAA;QACpC,MAAM,MAAM,GAAG,MAAM,OAAO,CAAC,IAAI,EAAE,GAAG,CAAC,CAAA;QACvC,MAAM,MAAM,GAAG,EAAE,CAAC,eAAe,CAAC,MAAM,EAAE,IAAI,CAAC,CAAA;QAC/C,MAAM,GAAG,GAAG,MAAM,CAAC,IAAI,CAAC,KAAK,CAAC,MAAM,CAAC,CAAA;QAErC,qDAAqD;QACrD,IAAI,OAAO,CAAC,OAAO,CAAC,MAAM,IAAI,IAAI,IAAI,MAAM,CAAC,QAAQ,EAAE,CAAC;YACtD,IAAI,aAAa,GAAG,CAAC,MAAM,CAAC,QAAQ,CAAA;YACpC,IAAI,UAAU,GAAG,OAAO,CAAC,OAAO,CAAC,GAAG,CAAA;YACpC,UAAU,GAAG,CAAC,GAAG,UAAU,CAAC,CAAC,CAAC,UAAU,CAAC,CAAC,CAAC,MAAM,CAAC,OAAO,EAAE,CAAC,OAAO,CAAA;YACnE,IAAI,aAAa,IAAI,UAAU,EAAE,CAAC;gBAChC,GAAG,CAAC,QAAQ,GAAG,aAAa,CAAA;YAC9B,CAAC;QACH,CAAC;QAED,OAAO,MAAM,IAAI,OAAO,CAAC,KAAK,EAAE,OAAO,EAAE,EAAE;YACzC,IAAI,YAAY,EAAE,CAAC;gBACjB,IAAI,QAAQ,GAAG,KAAK,CAAA;gBACpB,IAAI,WAAW,GAAG,IAAI,CAAA;gBAGtB,sCAAsC;gBACtC,IAAI,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;gBAE7B,IAAI,MAAM,EAAE,CAAC;oBACX,mDAAmD;oBACnD,mEAAmE;oBACnE,0EAA0E;oBAC1E,mEAAmE;oBACnE,mFAAmF;oBACnF,WAAW,GAAG,OAAO,CAAC,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAA;gBAC7C,CAAC;qBACI,CAAC;oBACJ,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,eAAe,EAAE,EAAE,GAAG,EAAE,CAAC,CAAA;gBAC5C,CAAC;gBAGD,IAAI,IAAI,KAAK,WAAW,EAAE,CAAC;oBACzB,QAAQ,GAAG,IAAI,CAAA;gBACjB,CAAC;qBACI,IAAI,WAAW,aAAX,WAAW,uBAAX,WAAW,CAAE,IAAI,EAAE,CAAC;oBAC3B,QAAQ,GAAG,WAAW,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;gBAClC,CAAC;gBAGD,IAAI,CAAC,QAAQ,EAAE,CAAC;oBACd,IAAI,OAAO,GAAQ;wBACjB,IAAI,EAAE,OAAO;wBACb,EAAE,EAAE,KAAK,EAAE;wBACX,IAAI,EAAE,aAAa;wBACnB,OAAO,EAAE,qBAAqB;wBAC9B,OAAO,EAAE,SAAS;qBACnB,CAAA;oBAED,IAAI,OAAO,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;wBAC3B,OAAO,CAAC,OAAO,GAAG,MAAM,CAAC,CAAC,CAAC,MAAM,CAAC,OAAO,CAAC,CAAC,CAAC,SAAS,CAAA;wBACrD,OAAO,CAAC,OAAO,GAAG,MAAM,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,CAAC,SAAS,CAAA;oBACjD,CAAC;oBAED,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;wBACtB,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,qBAAqB,EACpC,EAAE,QAAQ,EAAE,OAAO,EAAE,MAAM,aAAN,MAAM,uBAAN,MAAM,CAAE,OAAO,EAAE,OAAO,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,CAAA;oBACjE,CAAC;oBAED,OAAO,OAAO,CAAC;wBACb,KAAK,EAAE,IAAI;wBAEX,oCAAoC;wBACpC,GAAG,EAAE;4BACH,GAAG,MAAM,CAAC,OAAO,CAAC;4BAElB,KAAK,EAAE;gCACL,EAAE,EAAE,MAAM,CAAC,GAAG;gCACd,KAAK,EAAE,IAAI;6BACZ;4BAED,+BAA+B;4BAC/B,MAAM,EAAE,MAAM,CAAC,OAAO,CAAC;yBACxB;qBACF,CAAC,CAAA;gBACJ,CAAC;qBACI,CAAC;oBACJ,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;wBACtB,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,iBAAiB,EAAE,EAAE,OAAO,EAAE,MAAM,CAAC,OAAO,EAAE,MAAM,EAAE,QAAQ,EAAE,CAAC,CAAA;oBACpF,CAAC;gBACH,CAAC;YACH,CAAC;YAED,IAAI,GAAG,GAAG,IAAI,CAAA;YACd,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,KAAK,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;gBAC7C,GAAG,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,MAAM,EAAE,GAAG,EAAE,GAAG,CAAC,CAAA;gBAClD,IAAI,GAAG,EAAE,CAAC;oBACR,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;wBACtB,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,qBAAqB,EAAE,EAAE,GAAG,EAAE,GAAG,EAAE,CAAC,CAAA;oBACvD,CAAC;oBACD,OAAO,OAAO,CAAC,GAAG,CAAC,CAAA;gBACrB,CAAC;YACH,CAAC;YAED,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;gBACtB,MAAM,CAAC,GAAG,CAAC,KAAK,CAAC,aAAa,EAAE,EAAE,GAAG,EAAE,CAAC,CAAA;YAC1C,CAAC;YAED,IAAI,QAAQ,CAAC,KAAK,EAAE,CAAC;gBACnB,GAAG,CAAC,MAAM,GAAG,IAAI,CAAA;YACnB,CAAC;YAED,MAAM,CAAC,GAAG,CAAC,GAAG,EAAE,KAAK,WAAqB,GAAQ,EAAE,GAAQ,EAAE,IAAS;gBACrE,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,KAAK,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;oBAC7C,MAAM,KAAK,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,MAAM,EAAE,GAAG,EAAE,GAAG,EAAE,GAAG,EAAE,IAAI,EAAE,GAAG,CAAC,CAAA;gBAC9D,CAAC;gBAED,IAAI,GAAG,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;oBACnC,GAAG,CAAC,KAAK,GAAG,IAAI,CAAA;gBAClB,CAAC;gBAED,GAAG,GAAG,EAAE,CAAC,iBAAiB,CAAC,IAAI,EAAE,GAAG,EAAE,GAAG,EAAE,IAAI,CAAC,CAAA;gBAEhD,kDAAkD;gBAClD,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,QAAQ,EAAE,CAAC;oBAC5B,IAAI,GAAG,CAAC,KAAK,EAAE,CAAC;wBACd,GAAG,CAAC,KAAK,GAAG;4BACV,EAAE,EAAE,GAAG,CAAC,KAAK,CAAC,EAAE;yBACjB,CAAA;oBACH,CAAC;gBACH,CAAC;gBAED,IAAI,MAAM,GAAkB;oBAC1B,KAAK,EAAE,KAAK;oBACZ,GAAG;oBACH,IAAI;oBACJ,QAAQ,EAAE,GAAG,CAAC,QAAQ,IAAI,EAAE;iBAC7B,CAAA;gBAED,yCAAyC;gBACzC,OAAO,GAAG,CAAC,QAAQ,CAAA;gBAEnB,IAAI,GAAG,EAAE,CAAC;oBACR,MAAM,CAAC,KAAK,GAAG,IAAI,CAAA;oBACnB,GAAG,CAAC,KAAK,CAAC,KAAK,GAAG,IAAI,CAAA;oBAEtB,MAAM,CAAC,GAAG,GAAG,MAAM,CAAC;wBAClB,KAAK,EAAE,GAAG,CAAC,KAAK;wBAChB,IAAI,EAAE,GAAG,CAAC,IAAI;wBACd,EAAE,EAAG,GAAW,CAAC,EAAE,IAAI,KAAK,EAAE;wBAC9B,IAAI,EAAG,GAAW,CAAC,IAAI;wBACvB,OAAO,EAAE,OAAO,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,GAAG,CAAC,OAAO,CAAC,CAAC,CAAC,SAAS;wBACxD,OAAO,EAAE,OAAO,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,GAAG,CAAC,OAAO,CAAC,CAAC,CAAC,SAAS;qBACzD,CAAC,CAAA;gBACJ,CAAC;gBAED,OAAO,CAAC,MAAM,CAAC,CAAA;YACjB,CAAC,CAAC,CAAA;QACJ,CAAC,CAAC,CAAA;IACJ,CAAC;IAGD,KAAK,UAAU,OAAO,CAAC,IAAS,EAAE,GAAQ;QACxC,IAAI,CAAC,EAAE,UAAU,CAAA;QAEjB,IAAI,MAAM,GAAQ,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,EAAE,OAAO,CAAC,MAAM,CAAC,CAAA;QACtD,KAAK,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,KAAK,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;YACzC,UAAU,GAAG,KAAK,CAAC,MAAM,CAAC,CAAC,CAAC,CAAA;YAC5B,IAAI,QAAQ,KAAK,OAAO,CAAC,UAAU,CAAC,EAAE,CAAC;gBACrC,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,EAAE,UAAU,CAAC,CAAA;YAC/C,CAAC;iBACI,CAAC;gBACJ,MAAM,UAAU,CAAC,MAAM,EAAE,IAAI,EAAE,GAAG,CAAC,CAAA;YACrC,CAAC;QACH,CAAC;QAGD,IAAI,KAAK,GAAQ,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,EAAE,OAAO,CAAC,KAAK,CAAC,CAAA;QACpD,KAAK,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,KAAK,CAAC,KAAK,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;YACxC,UAAU,GAAG,KAAK,CAAC,KAAK,CAAC,CAAC,CAAC,CAAA;YAC3B,IAAI,QAAQ,KAAK,OAAO,CAAC,UAAU,CAAC,EAAE,CAAC;gBACrC,KAAK,GAAG,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,KAAK,EAAE,UAAU,CAAC,CAAA;YAC7C,CAAC;iBACI,CAAC;gBACJ,MAAM,UAAU,CAAC,KAAK,EAAE,IAAI,EAAE,GAAG,CAAC,CAAA;YACpC,CAAC;QACH,CAAC;QAED,IAAI,OAAO,CAAC,KAAK,CAAC,GAAG,EAAE,CAAC;YACtB,IAAI,CAAC,GAAG,CAAC,KAAK,CAAC,yBAAyB,EAAE,EAAE,KAAK,EAAE,MAAM,EAAE,CAAC,CAAA;QAC9D,CAAC;QAED,wEAAwE;QACxE,MAAM,QAAQ,GAAG,IAAI,CAAC,QAAQ,CAAC,KAAK,EAAE,EAAE,MAAM,EAAE,MAAM,EAAE,CAAC,CAAA;QAEzD,KAAK,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,KAAK,CAAC,QAAQ,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE,CAAC;YAC3C,MAAM,KAAK,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,QAAQ,EAAE,IAAI,EAAE,GAAG,CAAC,CAAA;QACnD,CAAC;QAED,OAAO,QAAQ,CAAA;IACjB,CAAC;IAGD,SAAS,SAAS,CAAC,IAAS;QAC1B,IAAI,IAAI,IAAI,IAAI;YAAE,OAAO,EAAE,CAAA;QAE3B,IAAI,GAAG,GAAG,MAAM,CAAC,IAAI,CAAC,CAAA;QAEtB,IAAI,CAAC;YACH,OAAO,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;QACxB,CAAC;QAAC,OAAO,CAAM,EAAE,CAAC;YAChB,CAAC,CAAC,QAAQ,GAAG;gBACX,MAAM,EAAE,CAAC,CAAC,OAAO;gBACjB,MAAM,EAAE,GAAG;aACZ,CAAA;YACD,OAAO,CAAC,CAAA;QACV,CAAC;IACH,CAAC;IAED,OAAO;QACL,OAAO,EAAE;YACP,OAAO;YACP,OAAO;YACP,SAAS;SACV;KACF,CAAA;AACH,CAAC;AAGD,SAAS,MAAM,CAAC,CAAM;IACpB,KAAK,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC;QAChB,IAAI,SAAS,KAAK,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;YACvB,OAAO,CAAC,CAAC,CAAC,CAAC,CAAA;QACb,CAAC;IACH,CAAC;IACD,OAAO,CAAC,CAAA;AACV,CAAC;AAGD,mBAAmB;AACnB,OAAO,CAAC,QAAQ,GAAI;IAElB,4BAA4B;IAC5B,KAAK,EAAE,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC,CAAC;IAErB,+BAA+B;IAC/B,MAAM,EAAE,IAAI,CAAC;QAEX,sDAAsD;QACtD,IAAI,EAAE,KAAK;KACZ,CAAC;IAEF,qCAAqC;IACrC,KAAK,EAAE,IAAI,CAAC,EAAE,CAAC;IAEf,wEAAwE;IACxE,OAAO,EAAE;QAEP,oCAAoC;QACpC,MAAM,EAAE,KAAK;QAEb,uCAAuC;QACvC,sCAAsC;QACtC,GAAG,EAAE,CAAC,CAAC;KACR;IAED,KAAK,EAAE;QACL,yDAAyD;QACzD,OAAO,EAAE,KAAK;QAEd,yDAAyD;QACzD,OAAO,EAAE,KAAK;KACf;IAGD,wBAAwB;IACxB,KAAK,EAAE;QAEL,kEAAkE;QAClE,QAAQ,EAAE,KAAK;QAEf,kCAAkC;QAClC,GAAG,EAAE,KAAK;KACX;CACiB,CAAA;AAQpB,kBAAe,OAAO,CAAA;AAEtB,IAAI,WAAW,KAAK,OAAO,CAAC,MAAM,CAAC,EAAE,CAAC;IACpC,MAAM,CAAC,OAAO,GAAG,OAAO,CAAA;AAC1B,CAAC"} \ No newline at end of file diff --git a/package.json b/package.json index df406c7..8f18e8c 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "@seneca/gateway", - "version": "1.1.0", + "version": "1.2.0", "main": "dist/gateway.js", "type": "commonjs", "types": "dist/gateway.d.ts", @@ -39,8 +39,8 @@ "devDependencies": { "@seneca/maintain": "^0.1.0", "@types/jest": "^29.5.11", - "@types/node": "^20.11.5", - "esbuild": "^0.19.11", + "@types/node": "^20.11.6", + "esbuild": "^0.19.12", "esbuild-jest": "^0.5.0", "jest": "^29.7.0", "seneca-msg-test": "^4.1.0", diff --git a/src/gateway.ts b/src/gateway.ts index 747a831..7979c40 100644 --- a/src/gateway.ts +++ b/src/gateway.ts @@ -153,11 +153,12 @@ function gateway(this: any, options: GatewayOptions) { // Handle inbound JSON, converting it into a message, and submitting to Seneca. - async function handler(json: any, ctx: any) { + async function handler(json: any, ctx?: any) { if (options.debug.log) { root.log.debug('gateway-handler-json', { json }) } + const gateway$ = ctx?.gateway$ || {} const seneca = await prepare(json, ctx) const rawmsg = tu.internalize_msg(seneca, json) const msg = seneca.util.clean(rawmsg) @@ -260,6 +261,10 @@ function gateway(this: any, options: GatewayOptions) { seneca.log.debug('handler-act', { msg }) } + if (gateway$.local) { + msg.local$ = true + } + seneca.act(msg, async function(this: any, err: any, out: any, meta: any) { for (var i = 0; i < hooks.result.length; i++) { await hooks.result[i].call(seneca, out, msg, err, meta, ctx)