{"version":3,"sources":["../../src/types.ts","../../src/base-adapter.ts","../../src/adapters/express.ts"],"names":["express"],"mappings":";;;;;;;;;AAoSO,IAAM,gBAAA,GAAN,cAA+B,KAAA,CAAM;AAAA,EAC1C,YACE,OAAA,EACO,UAAA,GAAqB,GAAA,EACrB,IAAA,GAAe,kBACf,OAAA,EACP;AACA,IAAA,KAAA,CAAM,OAAO,CAAA;AAJN,IAAA,IAAA,CAAA,UAAA,GAAA,UAAA;AACA,IAAA,IAAA,CAAA,IAAA,GAAA,IAAA;AACA,IAAA,IAAA,CAAA,OAAA,GAAA,OAAA;AAGP,IAAA,IAAA,CAAK,IAAA,GAAO,kBAAA;AAAA,EACd;AACF,CAAA;AAEO,IAAM,eAAA,GAAN,cAA8B,gBAAA,CAAiB;AAAA,EACpD,WAAA,CAAY,SAAiB,OAAA,EAAe;AAC1C,IAAA,KAAA,CAAM,OAAA,EAAS,GAAA,EAAK,kBAAA,EAAoB,OAAO,CAAA;AAC/C,IAAA,IAAA,CAAK,IAAA,GAAO,iBAAA;AAAA,EACd;AACF,CAAA;AAEO,IAAM,mBAAA,GAAN,cAAkC,gBAAA,CAAiB;AAAA,EACxD,WAAA,CAAY,SAAiB,OAAA,EAAe;AAC1C,IAAA,KAAA,CAAM,OAAA,EAAS,GAAA,EAAK,sBAAA,EAAwB,OAAO,CAAA;AACnD,IAAA,IAAA,CAAK,IAAA,GAAO,qBAAA;AAAA,EACd;AACF,CAAA;AASO,IAAM,aAAA,GAAN,cAA4B,gBAAA,CAAiB;AAAA,EAClD,WAAA,CAAY,SAAiB,OAAA,EAAe;AAC1C,IAAA,KAAA,CAAM,OAAA,EAAS,GAAA,EAAK,WAAA,EAAa,OAAO,CAAA;AACxC,IAAA,IAAA,CAAK,IAAA,GAAO,eAAA;AAAA,EACd;AACF,CAAA;;;AClTO,IAAM,oBAAN,MAAwB;AAAA,EACrB,MAAA;AAAA,EACE,MAAA;AAAA,EACF,SAAA,uBAA6C,GAAA,EAAI;AAAA,EACjD,MAAA;AAAA,EAER,WAAA,CAAY,QAA2B,MAAA,EAAyB;AAC9D,IAAA,IAAA,CAAK,SAAS,MAAA,CAAO,MAAA;AACrB,IAAA,IAAA,CAAK,MAAA,GAAS,MAAA;AACd,IAAA,IAAA,CAAK,MAAA,GAAS,MAAA;AACd,IAAA,IAAA,CAAK,cAAA,EAAe;AAAA,EACtB;AAAA;AAAA;AAAA;AAAA,EAKA,SAAA,GAA+B;AAC7B,IAAA,OAAO,IAAA,CAAK,MAAA;AAAA,EACd;AAAA;AAAA;AAAA;AAAA,EAKQ,cAAA,GAAuB;AAC7B,IAAA,MAAM,OAAA,GAAU,IAAA,CAAK,MAAA,CAAO,aAAA,EAAc;AAE1C,IAAA,KAAA,MAAW,UAAU,OAAA,EAAS;AAC5B,MAAA,IAAI,CAAC,OAAO,KAAA,EAAO;AAEnB,MAAA,KAAA,MAAW,IAAA,IAAQ,OAAO,KAAA,EAAO;AAC/B,QAAA,MAAM,QAAA,GAA2B;AAAA,UAC/B,YAAY,MAAA,CAAO,IAAA;AAAA,UACnB,UAAU,IAAA,CAAK,IAAA;AAAA,UACf,IAAA,EAAM,CAAA,EAAG,IAAA,CAAK,MAAA,CAAO,QAAA,IAAY,EAAE,CAAA,CAAA,EAAI,MAAA,CAAO,IAAI,CAAA,CAAA,EAAI,IAAA,CAAK,IAAI,CAAA,CAAA;AAAA,UAC/D,MAAA,EAAQ,IAAA,CAAK,QAAA,EAAU,IAAA,EAAM,MAAA,IAAU,MAAA;AAAA,UACvC,YAAA,EAAc,OAAA,CAAQ,IAAA,CAAK,QAAA,EAAU,MAAM,IAAI,CAAA;AAAA,UAC/C,aAAa,IAAA,CAAK,WAAA;AAAA,UAClB,aAAa,IAAA,CAAK,gBAAA;AAAA,UAClB,cAAc,IAAA,CAAK;AAAA,SACrB;AAEA,QAAA,MAAM,MAAM,CAAA,EAAG,MAAA,CAAO,IAAI,CAAA,CAAA,EAAI,KAAK,IAAI,CAAA,CAAA;AACvC,QAAA,IAAA,CAAK,SAAA,CAAU,GAAA,CAAI,GAAA,EAAK,QAAQ,CAAA;AAAA,MAClC;AAAA,IACF;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,YAAA,GAAiC;AAC/B,IAAA,OAAO,KAAA,CAAM,IAAA,CAAK,IAAA,CAAK,SAAA,CAAU,QAAQ,CAAA;AAAA,EAC3C;AAAA;AAAA;AAAA;AAAA,EAKA,WAAA,CACE,YACA,QAAA,EAC4B;AAC5B,IAAA,OAAO,KAAK,SAAA,CAAU,GAAA,CAAI,GAAG,UAAU,CAAA,CAAA,EAAI,QAAQ,CAAA,CAAE,CAAA;AAAA,EACvD;AAAA;AAAA;AAAA;AAAA,EAKA,MAAM,eAAA,CACJ,GAAA,EACA,UAAA,EAC2B;AAC3B,IAAA,MAAM,QAAA,GAAW,KAAK,WAAA,CAAY,GAAA,CAAI,OAAO,IAAA,EAAM,GAAA,CAAI,OAAO,IAAI,CAAA;AAClE,IAAA,IAAI,CAAC,QAAA,EAAU;AACb,MAAA,MAAM,IAAI,aAAA;AAAA,QACR,uBAAuB,GAAA,CAAI,MAAA,CAAO,IAAI,CAAA,CAAA,EAAI,GAAA,CAAI,OAAO,IAAI,CAAA;AAAA,OAC3D;AAAA,IACF;AAGA,IAAA,IAAI,SAAS,YAAA,EAAc;AACzB,MAAA,MAAM,IAAA,CAAK,qBAAA,CAAsB,GAAA,EAAK,UAAU,CAAA;AAAA,IAClD,CAAA,MAAO;AAEL,MAAA,MAAM,IAAA,CAAK,cAAA,CAAe,GAAA,EAAK,UAAU,CAAA;AAAA,IAC3C;AAGA,IAAA,MAAM,KAAA,GAAQ,IAAA,CAAK,gBAAA,CAAiB,GAAA,EAAK,UAAU,UAAU,CAAA;AAE7D,IAAA,IAAI;AAEF,MAAA,MAAM,MAAA,GAAS,MAAM,IAAA,CAAK,MAAA,CAAO,WAAA;AAAA,QAC/B,QAAA,CAAS,UAAA;AAAA,QACT,QAAA,CAAS,QAAA;AAAA,QACT;AAAA,OACF;AAGA,MAAA,MAAM,EAAA,GAAK,IAAA,CAAK,MAAA,CAAO,SAAA,CAAU,SAAS,UAAU,CAAA;AACpD,MAAA,MAAM,IAAA,GAAO,IAAI,KAAA,EAAO,IAAA,CAAK,CAAC,CAAA,KAAM,CAAA,CAAE,IAAA,KAAS,QAAA,CAAS,QAAQ,CAAA;AAEhE,MAAA,MAAM,SAAS,IAAA,EAAM,QAAA,EAAU,MAAM,KAAA,GAAQ,MAAA,CAAO,MAAM,CAAA,IAAK,GAAA;AAE/D,MAAA,OAAO;AAAA,QACL,OAAA,EAAS,IAAA;AAAA,QACT,IAAA,EAAM;AAAA,UACJ,GAAG,MAAA;AAAA,UACH,cAAc,MAAA,CAAO;AAAA,SACvB;AAAA,QACA,IAAA,EAAM;AAAA,UACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY,SACpC;AAAA,QACA,MAAA;AAAA,QACA,UAAU,MAAA,CAAO,QAAA;AAAA;AAAA,QACjB,QAAQ,MAAA,CAAO;AAAA;AAAA,OACjB;AAAA,IACF,SAAS,KAAA,EAAO;AACd,MAAA,MAAM,IAAI,gBAAA;AAAA,QACR,0BAA0B,KAAA,YAAiB,KAAA,GAAQ,MAAM,OAAA,GAAU,MAAA,CAAO,KAAK,CAAC,CAAA,CAAA;AAAA,QAChF,GAAA;AAAA,QACA,sBAAA;AAAA,QACA,EAAE,UAAA,EAAY,QAAA,CAAS,YAAY,QAAA,EAAU,QAAA,CAAS,UAAU,KAAA;AAAM,OACxE;AAAA,IACF;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,MAAM,aAAA,CACJ,GAAA,EACA,UAAA,EAC0B;AAC1B,IAAA,MAAM,EAAE,WAAA,EAAa,SAAA,EAAW,YAAW,GAAI,GAAA,CAAI,QAAQ,EAAC;AAE5D,IAAA,IAAI,CAAC,WAAA,IAAe,CAAC,SAAA,EAAW;AAC9B,MAAA,MAAM,IAAI,gBAAgB,wCAAwC,CAAA;AAAA,IACpE;AAEA,IAAA,IAAI;AACF,MAAA,MAAM,KAAA,GAAQ,MAAM,IAAA,CAAK,MAAA,CAAO,gBAAA;AAAA,QAC9B,WAAA;AAAA,QACA,SAAA;AAAA,QACA,UAAA;AAAA,QACA;AAAA,OACF;AAEA,MAAA,OAAO;AAAA,QACL,OAAA,EAAS,IAAA;AAAA,QACT,IAAA,EAAM;AAAA,UACJ,KAAA,EAAO,IAAA;AAAA,UACP,KAAA;AAAA,UACA,SAAA,EAAW,UAAA,GACP,IAAI,IAAA,CAAK,IAAA,CAAK,GAAA,EAAI,GAAI,UAAA,GAAa,GAAI,CAAA,CAAE,WAAA,EAAY,GACrD,KAAA;AAAA,SACN;AAAA,QACA,IAAA,EAAM;AAAA,UACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY;AACpC,OACF;AAAA,IACF,SAAS,KAAA,EAAO;AACd,MAAA,MAAM,IAAI,gBAAA;AAAA,QACR,4BAA4B,KAAA,YAAiB,KAAA,GAAQ,MAAM,OAAA,GAAU,MAAA,CAAO,KAAK,CAAC,CAAA,CAAA;AAAA,QAClF,GAAA;AAAA,QACA;AAAA,OACF;AAAA,IACF;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,MAAM,YAAA,CACJ,GAAA,EACA,UAAA,EAC0B;AAC1B,IAAA,MAAM,KAAA,GAAQ,IAAA,CAAK,mBAAA,CAAoB,GAAG,CAAA;AAE1C,IAAA,IAAI,CAAC,KAAA,EAAO;AACV,MAAA,OAAO;AAAA,QACL,OAAA,EAAS,KAAA;AAAA,QACT,IAAA,EAAM;AAAA,UACJ,KAAA,EAAO;AAAA,SACT;AAAA,QACA,IAAA,EAAM;AAAA,UACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY;AACpC,OACF;AAAA,IACF;AAEA,IAAA,IAAI;AACF,MAAA,MAAM,SAAS,MAAM,IAAA,CAAK,MAAA,CAAO,YAAA,CAAa,OAAO,UAAU,CAAA;AAE/D,MAAA,IAAI,CAAC,OAAO,OAAA,EAAS;AACnB,QAAA,OAAO;AAAA,UACL,OAAA,EAAS,KAAA;AAAA,UACT,IAAA,EAAM;AAAA,YACJ,KAAA,EAAO;AAAA,WACT;AAAA,UACA,IAAA,EAAM;AAAA,YACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY;AACpC,SACF;AAAA,MACF;AAEA,MAAA,OAAO;AAAA,QACL,OAAA,EAAS,IAAA;AAAA,QACT,IAAA,EAAM;AAAA,UACJ,OAAO,MAAA,CAAO,KAAA;AAAA,UACd,SAAS,MAAA,CAAO,OAAA;AAAA,UAChB,OAAO,MAAA,CAAO,KAAA;AAAA,UACd,QAAA,EAAU;AAAA,YACR,SAAS,MAAA,CAAO,OAAA;AAAA,YAChB,MAAM,MAAA,CAAO;AAAA;AACf,SACF;AAAA,QACA,IAAA,EAAM;AAAA,UACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY;AACpC,OACF;AAAA,IACF,SAAS,KAAA,EAAO;AACd,MAAA,OAAO;AAAA,QACL,OAAA,EAAS,KAAA;AAAA,QACT,IAAA,EAAM;AAAA,UACJ,KAAA,EAAO;AAAA,SACT;AAAA,QACA,IAAA,EAAM;AAAA,UACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY;AACpC,OACF;AAAA,IACF;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,MAAM,eAAe,GAAA,EAA2C;AAC9D,IAAA,MAAM,KAAA,GAAQ,IAAA,CAAK,mBAAA,CAAoB,GAAG,CAAA;AAE1C,IAAA,IAAI,CAAC,KAAA,EAAO;AACV,MAAA,MAAM,IAAI,gBAAgB,2BAA2B,CAAA;AAAA,IACvD;AAEA,IAAA,IAAI;AACF,MAAA,MAAM,IAAA,CAAK,MAAA,CAAO,iBAAA,EAAkB,CAAE,eAAe,KAAK,CAAA;AAE1D,MAAA,OAAO;AAAA,QACL,OAAA,EAAS,IAAA;AAAA,QACT,IAAA,EAAM;AAAA,UACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY;AACpC,OACF;AAAA,IACF,SAAS,KAAA,EAAO;AACd,MAAA,MAAM,IAAI,gBAAA;AAAA,QACR,+BAA+B,KAAA,YAAiB,KAAA,GAAQ,MAAM,OAAA,GAAU,MAAA,CAAO,KAAK,CAAC,CAAA,CAAA;AAAA,QACrF,GAAA;AAAA,QACA;AAAA,OACF;AAAA,IACF;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,MAAM,WAAA,GAA2C;AAC/C,IAAA,MAAM,OAAA,GAAU,IAAA,CAAK,MAAA,CAAO,aAAA,EAAc;AAE1C,IAAA,MAAM,IAAA,GAAO,OAAA,CAAQ,GAAA,CAAI,CAAC,MAAA,MAAY;AAAA,MACpC,MAAM,MAAA,CAAO,IAAA;AAAA,MACb,WAAA,EAAa,CAAA,EAAG,MAAA,CAAO,IAAI,CAAA,sBAAA,CAAA;AAAA,MAC3B,QAAQ,MAAA,CAAO,KAAA,IAAS,EAAC,EAAG,GAAA,CAAI,CAAC,IAAA,MAAU;AAAA,QACzC,MAAM,IAAA,CAAK,IAAA;AAAA,QACX,aAAa,IAAA,CAAK,WAAA;AAAA,QAClB,MAAA,EAAQ,IAAA,CAAK,QAAA,EAAU,IAAA,EAAM,MAAA,IAAU,MAAA;AAAA,QACvC,IAAA,EAAM,CAAA,EAAG,IAAA,CAAK,MAAA,CAAO,QAAA,IAAY,EAAE,CAAA,MAAA,EAAS,MAAA,CAAO,IAAI,CAAA,CAAA,EAAI,IAAA,CAAK,IAAI,CAAA,CAAA;AAAA,QACpE,YAAA,EAAc,OAAA,CAAQ,IAAA,CAAK,QAAA,EAAU,MAAM,IAAI;AAAA,OACjD,CAAE;AAAA,KACJ,CAAE,CAAA;AAEF,IAAA,OAAO;AAAA,MACL,OAAA,EAAS,IAAA;AAAA,MACT,IAAA;AAAA,MACA,IAAA,EAAM;AAAA,QACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY;AACpC,KACF;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,MAAM,UAAU,UAAA,EAA0C;AACxD,IAAA,MAAM,MAAA,GAAS,IAAA,CAAK,MAAA,CAAO,SAAA,CAAU,UAAU,CAAA;AAE/C,IAAA,IAAI,CAAC,MAAA,EAAQ;AACX,MAAA,MAAM,IAAI,aAAA,CAAc,CAAA,kBAAA,EAAqB,UAAU,CAAA,CAAE,CAAA;AAAA,IAC3D;AAEA,IAAA,MAAM,IAAA,GAAO;AAAA,MACX,MAAM,MAAA,CAAO,IAAA;AAAA,MACb,WAAA,EAAa,CAAA,EAAG,MAAA,CAAO,IAAI,CAAA,sBAAA,CAAA;AAAA,MAC3B,QAAQ,MAAA,CAAO,KAAA,IAAS,EAAC,EAAG,GAAA,CAAI,CAAC,IAAA,MAAU;AAAA,QACzC,MAAM,IAAA,CAAK,IAAA;AAAA,QACX,aAAa,IAAA,CAAK,WAAA;AAAA,QAClB,MAAA,EAAQ,IAAA,CAAK,QAAA,EAAU,IAAA,EAAM,MAAA,IAAU,MAAA;AAAA,QACvC,IAAA,EAAM,CAAA,EAAG,IAAA,CAAK,MAAA,CAAO,QAAA,IAAY,EAAE,CAAA,MAAA,EAAS,MAAA,CAAO,IAAI,CAAA,CAAA,EAAI,IAAA,CAAK,IAAI,CAAA,CAAA;AAAA,QACpE,YAAA,EAAc,OAAA,CAAQ,IAAA,CAAK,QAAA,EAAU,MAAM,IAAI,CAAA;AAAA,QAC/C,MAAA,EAAQ,IAAA,CAAK,MAAA,IAAU,EAAC;AAAA,QACxB,WAAA,EAAa,IAAA,CAAK,gBAAA,EAAkB,YAAA,QAAoB,EAAC;AAAA,QACzD,YAAA,EAAc,IAAA,CAAK,OAAA,EAAS,YAAA,QAAoB;AAAC,OACnD,CAAE;AAAA,KACJ;AAEA,IAAA,OAAO;AAAA,MACL,OAAA,EAAS,IAAA;AAAA,MACT,IAAA;AAAA,MACA,IAAA,EAAM;AAAA,QACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY;AACpC,KACF;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,MAAM,gBAAA,GAAyC;AAC7C,IAAA,MAAM,iBAAA,GAAoB,IAAA,CAAK,MAAA,CAAO,oBAAA,EAAqB;AAG3D,IAAA,MAAM,UAAA,GAAa;AAAA,MACjB,QAAA,EAAU,IAAA,CAAK,MAAA,CAAO,QAAA,IAAY,EAAA;AAAA,MAClC,WAAA,EAAa;AAAA,QACX,MAAA,EAAQ;AAAA,UACN,iBAAA,EACE,IAAA,CAAK,MAAA,CAAO,WAAA,EAAa,kBAAA,IAAsB,eAAA;AAAA,UACjD,kBAAA,EACE,IAAA,CAAK,MAAA,CAAO,WAAA,EAAa,kBAAA,IAAsB,iBAAA;AAAA,UACjD,SAAA,EAAW;AAAA;AAAA,SACb;AAAA,QACA,MAAA,EAAQ;AAAA,UACN,eAAA,EAAiB,IAAA,CAAK,MAAA,CAAO,MAAA,EAAQ,IAAA,IAAQ,gBAAA;AAAA,UAC7C,gBAAA,EACE,IAAA,CAAK,MAAA,CAAO,MAAA,EAAQ,gBAAA,IAAoB,gBAAA;AAAA,UAC1C,OAAA,EAAS,CAAC,CAAC,IAAA,CAAK,MAAA,CAAO;AAAA;AACzB;AACF,KACF;AAEA,IAAA,OAAO;AAAA,MACL,OAAA,EAAS,IAAA;AAAA,MACT,IAAA,EAAM;AAAA,QACJ,GAAG,iBAAA;AAAA,QACH;AAAA,OACF;AAAA,MACA,IAAA,EAAM;AAAA,QACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY;AACpC,KACF;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,MAAM,WAAA,GAAoC;AACxC,IAAA,OAAO;AAAA,MACL,OAAA,EAAS,IAAA;AAAA,MACT,IAAA,EAAM;AAAA,QACJ,MAAA,EAAQ,SAAA;AAAA,QACR,OAAA,EAAS,OAAA;AAAA,QACT,OAAA,EAAS,IAAA,CAAK,MAAA,CAAO,aAAA,EAAc,CAAE,MAAA;AAAA,QACrC,SAAA,EAAW,KAAK,SAAA,CAAU;AAAA,OAC5B;AAAA,MACA,IAAA,EAAM;AAAA,QACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY;AACpC,KACF;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKQ,oBAAoB,GAAA,EAAyB;AACnD,IAAA,IAAI,WAAA,GAA6B,IAAA;AACjC,IAAA,IAAI,YAAA,GAA8B,IAAA;AAGlC,IAAA,MAAM,UAAA,GAAa,IAAI,OAAA,CAAQ,aAAA;AAC/B,IAAA,IAAI,UAAA,EAAY,UAAA,CAAW,SAAS,CAAA,EAAG;AACrC,MAAA,WAAA,GAAc,UAAA,CAAW,UAAU,CAAC,CAAA;AAAA,IACtC;AAGA,IAAA,IACE,CAAC,eACD,GAAA,CAAI,OAAA,CACF,KAAK,MAAA,CAAO,WAAA,EAAa,kBAAA,IAAsB,gBACjD,CAAA,EACA;AACA,MAAA,WAAA,GACE,IAAI,OAAA,CACF,IAAA,CAAK,MAAA,CAAO,WAAA,EAAa,sBAAsB,gBACjD,CAAA;AAAA,IACJ;AACA,IAAA,IACE,CAAC,gBACD,GAAA,CAAI,OAAA,CACF,KAAK,MAAA,CAAO,WAAA,EAAa,kBAAA,IAAsB,iBACjD,CAAA,EACA;AACA,MAAA,YAAA,GACE,IAAI,OAAA,CACF,IAAA,CAAK,MAAA,CAAO,WAAA,EAAa,sBAAsB,iBACjD,CAAA;AAAA,IACJ;AAGA,IAAA,IACE,CAAC,eACD,GAAA,CAAI,OAAA,GAAU,KAAK,MAAA,CAAO,MAAA,EAAQ,IAAA,IAAQ,gBAAgB,CAAA,EAC1D;AACA,MAAA,WAAA,GAAc,IAAI,OAAA,CAAQ,IAAA,CAAK,MAAA,CAAO,MAAA,EAAQ,QAAQ,gBAAgB,CAAA;AAAA,IACxE;AAEA,IAAA,IACE,CAAC,gBACD,GAAA,CAAI,OAAA,GAAU,KAAK,MAAA,CAAO,MAAA,EAAQ,gBAAA,IAAoB,gBAAgB,CAAA,EACtE;AACA,MAAA,YAAA,GACE,IAAI,OAAA,CAAQ,IAAA,CAAK,MAAA,CAAO,MAAA,EAAQ,oBAAoB,gBAAgB,CAAA;AAAA,IACxE;AAEA,IAAA,IAAI,CAAC,WAAA,EAAa;AAChB,MAAA,IAAA,CAAK,MAAA,CAAO,IAAA,CAAK,MAAA,EAAQ,kCAAA,EAAoC;AAAA,QAC3D,MAAM,GAAA,CAAI,IAAA;AAAA,QACV,UAAA,EAAY,CAAC,CAAC,GAAA,CAAI;AAAA,OACnB,CAAA;AACD,MAAA,OAAO,IAAA;AAAA,IACT;AAEA,IAAA,IAAI,eAAe,YAAA,EAAc;AAC/B,MAAA,IAAA,CAAK,MAAA,CAAO,IAAA,CAAK,MAAA,EAAQ,sCAAA,EAAwC;AAAA,QAC/D,MAAM,GAAA,CAAI,IAAA;AAAA,QACV,UAAA,EAAY,CAAC,CAAC,GAAA,CAAI;AAAA,OACnB,CAAA;AACD,MAAA,OAAO,EAAE,aAAa,YAAA,EAAa;AAAA,IACrC;AAEA,IAAA,IAAI,WAAA,IAAe,CAAC,YAAA,EAAc;AAChC,MAAA,IAAA,CAAK,MAAA,CAAO,IAAA,CAAK,MAAA,EAAQ,0CAAA,EAA4C;AAAA,QACnE,MAAM,GAAA,CAAI,IAAA;AAAA,QACV,UAAA,EAAY,CAAC,CAAC,GAAA,CAAI;AAAA,OACnB,CAAA;AACD,MAAA,OAAO,WAAA;AAAA,IACT;AAEA,IAAA,IAAA,CAAK,MAAA,CAAO,IAAA,CAAK,MAAA,EAAQ,wCAAA,EAA0C;AAAA,MACjE,MAAM,GAAA,CAAI,IAAA;AAAA,MACV,UAAA,EAAY,CAAC,CAAC,GAAA,CAAI;AAAA,KACnB,CAAA;AACD,IAAA,OAAO,IAAA;AAAA,EACT;AAAA;AAAA;AAAA;AAAA,EAKQ,gBAAA,CACN,GAAA,EACA,QAAA,EACA,UAAA,EACW;AACX,IAAA,MAAM,KAAA,GAAmB;AAAA,MACvB,GAAG,GAAA,CAAI,IAAA;AAAA,MACP,GAAG,GAAA,CAAI,KAAA;AAAA,MACP,GAAG,GAAA,CAAI,MAAA;AAAA,MACP,GAAG,GAAA,CAAI;AAAA;AAAA,KACT;AAGA,IAAA,MAAM,KAAA,GAAQ,IAAA,CAAK,mBAAA,CAAoB,GAAG,CAAA;AAC1C,IAAA,IAAI,KAAA,EAAO;AACT,MAAA,KAAA,CAAM,KAAA,GAAQ,KAAA;AAAA,IAChB;AAGA,IAAA,IAAI,UAAA,EAAY;AACd,MAAA,KAAA,CAAM,UAAA,GAAa,UAAA;AAAA,IACrB;AAGA,IAAA,IAAI,IAAI,EAAA,EAAI;AACV,MAAA,KAAA,CAAM,KAAK,GAAA,CAAI,EAAA;AAAA,IACjB;AACA,IAAA,IAAI,IAAI,SAAA,EAAW;AACjB,MAAA,KAAA,CAAM,YAAY,GAAA,CAAI,SAAA;AAAA,IACxB;AAEA,IAAA,OAAO,KAAA;AAAA,EACT;AAAA;AAAA;AAAA;AAAA,EAKA,MAAM,cAAA,CACJ,GAAA,EACA,UAAA,EACmC;AACnC,IAAA,MAAM,KAAA,GAAQ,IAAA,CAAK,mBAAA,CAAoB,GAAG,CAAA;AAE1C,IAAA,IAAI,CAAC,KAAA,EAAO;AACV,MAAA,IAAA,CAAK,MAAA,CAAO,IAAA,CAAK,MAAA,EAAQ,kCAAA,EAAoC;AAAA,QAC3D,MAAM,GAAA,CAAI,IAAA;AAAA,QACV,UAAA,EAAY,CAAC,CAAC,GAAA,CAAI;AAAA,OACnB,CAAA;AACD,MAAA,OAAO,IAAA;AAAA,IACT;AAEA,IAAA,IAAI;AACF,MAAA,MAAM,UAAU,MAAM,IAAA,CAAK,MAAA,CAAO,YAAA,CAAa,OAAO,UAAU,CAAA;AAEhE,MAAA,IAAI,CAAC,OAAA,CAAQ,KAAA,IAAS,CAAC,QAAQ,OAAA,EAAS;AACtC,QAAA,IAAA,CAAK,MAAA,CAAO,IAAA,CAAK,MAAA,EAAQ,2CAAA,EAA6C;AAAA,UACpE,UAAA,EAAY,CAAC,CAAC,GAAA,CAAI;AAAA,SACnB,CAAA;AACD,QAAA,OAAO,IAAA;AAAA,MACT;AAEA,MAAA,OAAO;AAAA,QACL,SAAS,OAAA,CAAQ,OAAA;AAAA,QACjB,KAAA,EAAO,QAAQ,KAAA,IAAS,KAAA;AAAA,QACxB,OAAO,OAAA,CAAQ,KAAA;AAAA,QACf,QAAA,EAAU;AAAA,UACR,SAAS,OAAA,CAAQ,OAAA;AAAA,UACjB,MAAM,OAAA,CAAQ;AAAA;AAChB,OACF;AAAA,IACF,SAAS,KAAA,EAAO;AAEd,MAAA,IAAA,CAAK,MAAA,CAAO,KAAA,CAAM,MAAA,EAAQ,sBAAA,EAAwB;AAAA,QAChD,UAAA,EAAY,CAAC,CAAC,GAAA,CAAI,OAAA;AAAA,QAClB;AAAA,OACD,CAAA;AACD,MAAA,OAAO,IAAA;AAAA,IACT;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,MAAM,qBAAA,CACJ,GAAA,EACA,UAAA,EAC4B;AAC5B,IAAA,MAAM,IAAA,GAAO,MAAM,IAAA,CAAK,cAAA,CAAe,KAAK,UAAU,CAAA;AAEtD,IAAA,IAAI,CAAC,IAAA,EAAM;AACT,MAAA,IAAA,CAAK,MAAA,CAAO,IAAA,CAAK,MAAA,EAAQ,2CAAA,EAA6C;AAAA,QACpE,MAAM,GAAA,CAAI,IAAA;AAAA,QACV,UAAA,EAAY,CAAC,CAAC,GAAA,CAAI;AAAA,OACnB,CAAA;AACD,MAAA,MAAM,IAAI,oBAAoB,yBAAyB,CAAA;AAAA,IACzD;AAEA,IAAA,OAAO,IAAA;AAAA,EACT;AAAA;AAAA;AAAA;AAAA,EAKA,cACE,OAAA,EAC8C;AAC9C,IAAA,OAAO,OAAA;AAAA,EACT;AAAA;AAAA;AAAA;AAAA,EAKA,mBAAmB,OAAA,EAAuB;AACxC,IAAA,OAAO,OAAO,KAAkB,GAAA,KAAqC;AACnE,MAAA,IAAI;AACF,QAAA,MAAM,MAAA,GAAS,MAAM,OAAA,CAAQ,GAAA,EAAK,GAAG,CAAA;AACrC,QAAA,IAAI,MAAA,EAAQ;AACV,UAAA,GAAA,CAAI,MAAA,CAAO,GAAG,CAAA,CAAE,IAAA,CAAK,MAAM,CAAA;AAAA,QAC7B;AAAA,MACF,SAAS,KAAA,EAAO;AACd,QAAA,IAAA,CAAK,WAAA,CAAY,OAAO,GAAG,CAAA;AAAA,MAC7B;AAAA,IACF,CAAA;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKQ,WAAA,CAAY,OAAgB,GAAA,EAAyB;AAC3D,IAAA,IAAI,iBAAiB,gBAAA,EAAkB;AACrC,MAAA,GAAA,CAAI,MAAA,CAAO,KAAA,CAAM,UAAU,CAAA,CAAE,IAAA,CAAK;AAAA,QAChC,OAAA,EAAS,KAAA;AAAA,QACT,KAAA,EAAO;AAAA,UACL,MAAM,KAAA,CAAM,IAAA;AAAA,UACZ,SAAS,KAAA,CAAM,OAAA;AAAA,UACf,SAAS,KAAA,CAAM;AAAA,SACjB;AAAA,QACA,IAAA,EAAM;AAAA,UACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY;AACpC,OACD,CAAA;AAAA,IACH,CAAA,MAAO;AACL,MAAA,GAAA,CAAI,MAAA,CAAO,GAAG,CAAA,CAAE,IAAA,CAAK;AAAA,QACnB,OAAA,EAAS,KAAA;AAAA,QACT,KAAA,EAAO;AAAA,UACL,IAAA,EAAM,gBAAA;AAAA,UACN,OAAA,EAAS;AAAA,SACX;AAAA,QACA,IAAA,EAAM;AAAA,UACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY;AACpC,OACD,CAAA;AAAA,IACH;AAAA,EACF;AACF,CAAA;;;ACtnBO,IAAM,iBAAN,MAEP;AAAA,EAOE,WAAA,CACE,MAAA,EACQ,mBAAA,EACR,kBAAA,EACA,MAAA,EACA;AAHQ,IAAA,IAAA,CAAA,mBAAA,GAAA,mBAAA;AAIR,IAAA,MAAM,aAAA,GAAiC;AAAA,MACrC,MAAM,MAAM;AAAA,MAAC,CAAA;AAAA,MACb,MAAM,MAAM;AAAA,MAAC,CAAA;AAAA,MACb,OAAO,MAAM;AAAA,MAAC,CAAA;AAAA,MACd,SAAS,MAAM;AAAA,MAAC,CAAA;AAAA,MAChB,gBAAgB,MAAM;AAAA,MAAC,CAAA;AAAA,MACvB,SAAS,MAAM;AAAA,MAAC;AAAA,KAClB;AACA,IAAA,IAAA,CAAK,OAAA,GAAU,IAAI,iBAAA,CAAkB,MAAA,EAAQ,UAAU,aAAa,CAAA;AACpE,IAAA,IAAA,CAAK,kBAAA,GAAqB,kBAAA;AAAA,EAC5B;AAAA,EAtBgB,IAAA,GAAO,SAAA;AAAA,EACf,OAAA;AAAA,EACA,kBAAA;AAAA;AAAA;AAAA;AAAA,EAyBR,MAAM,2BACJ,OAAA,EAC8B;AAC9B,IAAA,IAAI,CAAC,KAAK,kBAAA,EAAoB;AAC5B,MAAA,OAAO,EAAC;AAAA,IACV;AAEA,IAAA,MAAM,UAAA,GAAa,MAAM,IAAA,CAAK,kBAAA,CAAmB,OAAO,CAAA;AACxD,IAAA,OAAO,UAAA;AAAA,EACT;AAAA;AAAA;AAAA;AAAA,EAKA,oBAAA,GAImB;AACjB,IAAA,OAAO,OACL,GAAA,EACA,GAAA,EACA,IAAA,KACkB;AAClB,MAAA,IAAI;AACF,QAAA,MAAM,OAAA,GAAU,IAAA,CAAK,cAAA,CAAe,GAAG,CAAA;AACvC,QAAA,MAAM,UAAA,GAAa,MAAM,IAAA,CAAK,0BAAA,CAA2B,GAAG,CAAA;AAC5D,QAAC,GAAA,CAAY,IAAA,GAAO,MAAM,IAAA,CAAK,OAAA,CAAQ,cAAA;AAAA,UACrC,OAAA;AAAA,UACA;AAAA,SACF;AACA,QAAA,IAAA,EAAK;AAAA,MACP,SAAS,KAAA,EAAO;AAEd,QAAC,IAAY,IAAA,GAAO,IAAA;AACpB,QAAA,IAAA,EAAK;AAAA,MACP;AAAA,IACF,CAAA;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,gBAAA,GAImB;AACjB,IAAA,OAAO,OACL,GAAA,EACA,GAAA,EACA,IAAA,KACkB;AAElB,MAAC,GAAA,CAAY,SAAS,IAAA,CAAK,OAAA;AAC3B,MAAA,IAAA,EAAK;AAAA,IACP,CAAA;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,eAAe,GAAA,EAA2B;AACxC,IAAA,OAAO;AAAA,MACL,QAAQ,GAAA,CAAI,MAAA;AAAA,MACZ,KAAK,GAAA,CAAI,GAAA;AAAA,MACT,MAAM,GAAA,CAAI,IAAA;AAAA,MACV,OAAO,GAAA,CAAI,KAAA;AAAA,MACX,QAAQ,GAAA,CAAI,MAAA;AAAA,MACZ,MAAM,GAAA,CAAI,IAAA;AAAA,MACV,SAAS,GAAA,CAAI,OAAA;AAAA,MACb,SAAS,GAAA,CAAI,OAAA;AAAA,MACb,IAAI,GAAA,CAAI,EAAA;AAAA,MACR,SAAA,EAAW,GAAA,CAAI,GAAA,CAAI,YAAY;AAAA,KACjC;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,YAAA,CAAa,GAAA,EAAe,IAAA,EAAW,UAAA,GAAqB,GAAA,EAAW;AACrE,IAAA,GAAA,CAAI,MAAA,CAAO,UAAU,CAAA,CAAE,IAAA,CAAK,IAAI,CAAA;AAAA,EAClC;AAAA;AAAA;AAAA;AAAA,EAKA,WAAA,CAAY,GAAA,EAAe,KAAA,EAAc,UAAA,GAAqB,GAAA,EAAW;AACvE,IAAA,GAAA,CAAI,MAAA,CAAO,UAAU,CAAA,CAAE,IAAA,CAAK;AAAA,MAC1B,OAAA,EAAS,KAAA;AAAA,MACT,KAAA,EAAO;AAAA,QACL,IAAA,EAAM,OAAA;AAAA,QACN,SAAS,KAAA,CAAM;AAAA,OACjB;AAAA,MACA,IAAA,EAAM;AAAA,QACJ,SAAA,EAAA,iBAAW,IAAI,IAAA,EAAK,EAAE,WAAA;AAAY;AACpC,KACD,CAAA;AAAA,EACH;AAAA;AAAA;AAAA;AAAA,EAKA,YAAA,CAAa,MAAA,EAAiB,QAAA,GAAmB,EAAA,EAAY;AAE3D,IAAA,MAAA,GAAS,MAAA,IAAUA,yBAAQ,MAAA,EAAO;AAGlC,IAAA,MAAA,CAAO,GAAA,CAAI,IAAA,CAAK,gBAAA,EAAkB,CAAA;AAGlC,IAAA,MAAA,CAAO,IAAI,CAAA,EAAG,QAAQ,CAAA,QAAA,CAAA,EAAY,IAAA,CAAK,2BAA2B,CAAA;AAKlE,IAAA,IAAI,KAAK,mBAAA,EAAqB;AAC5B,MAAA,MAAA,CAAO,GAAA;AAAA,QACL,GAAG,QAAQ,CAAA,cAAA,CAAA;AAAA,QACX,KAAK,0BAAA;AAA2B,OAClC;AACA,MAAA,MAAA,CAAO,IAAI,CAAA,EAAG,QAAQ,CAAA,QAAA,CAAA,EAAY,IAAA,CAAK,yBAAyB,CAAA;AAChE,MAAA,MAAA,CAAO,GAAA;AAAA,QACL,GAAG,QAAQ,CAAA,gBAAA,CAAA;AAAA,QACX,KAAK,0BAAA;AAA2B,OAClC;AAAA,IACF;AAEA,IAAA,MAAA,CAAO,IAAI,CAAA,EAAG,QAAQ,CAAA,OAAA,CAAA,EAAW,IAAA,CAAK,qBAAqB,CAAA;AAG3D,IAAA,MAAM,SAAA,GAAY,IAAA,CAAK,OAAA,CAAQ,YAAA,EAAa;AAC5C,IAAA,KAAA,MAAW,YAAY,SAAA,EAAW;AAChC,MAAA,IAAI,QAAA,CAAS,WAAW,MAAA,EAAQ;AAC9B,QAAA,MAAA,CAAO,IAAA;AAAA,UAAK,QAAA,CAAS,IAAA;AAAA,UAAM,CAAC,GAAA,EAAc,GAAA,KACxC,IAAA,CAAK,iBAAA,CAAkB;AAAA,YACrB,MAAM,QAAA,CAAS,UAAA;AAAA,YACf,MAAM,QAAA,CAAS;AAAA,WAChB;AAAA,SACH;AAAA,MACF,CAAA,MAAA,IAAW,QAAA,CAAS,MAAA,KAAW,KAAA,EAAO;AACpC,QAAA,MAAA,CAAO,GAAA;AAAA,UACL,QAAA,CAAS,IAAA;AAAA,UACT,KAAK,iBAAA,CAAkB;AAAA,YACrB,MAAM,QAAA,CAAS,UAAA;AAAA,YACf,MAAM,QAAA,CAAS;AAAA,WAChB;AAAA,SACH;AAAA,MACF,CAAA,MAAA,IAAW,QAAA,CAAS,MAAA,KAAW,KAAA,EAAO;AACpC,QAAA,MAAA,CAAO,GAAA;AAAA,UACL,QAAA,CAAS,IAAA;AAAA,UACT,KAAK,iBAAA,CAAkB;AAAA,YACrB,MAAM,QAAA,CAAS,UAAA;AAAA,YACf,MAAM,QAAA,CAAS;AAAA,WAChB;AAAA,SACH;AAAA,MACF,CAAA,MAAA,IAAW,QAAA,CAAS,MAAA,KAAW,OAAA,EAAS;AACtC,QAAA,MAAA,CAAO,KAAA;AAAA,UACL,QAAA,CAAS,IAAA;AAAA,UACT,KAAK,iBAAA,CAAkB;AAAA,YACrB,MAAM,QAAA,CAAS,UAAA;AAAA,YACf,MAAM,QAAA,CAAS;AAAA,WAChB;AAAA,SACH;AAAA,MACF,CAAA,MAAA,IAAW,QAAA,CAAS,MAAA,KAAW,QAAA,EAAU;AACvC,QAAA,MAAA,CAAO,MAAA;AAAA,UACL,QAAA,CAAS,IAAA;AAAA,UACT,KAAK,iBAAA,CAAkB;AAAA,YACrB,MAAM,QAAA,CAAS,UAAA;AAAA,YACf,MAAM,QAAA,CAAS;AAAA,WAChB;AAAA,SACH;AAAA,MACF;AAAA,IACF;AAEA,IAAA,OAAO,MAAA;AAAA,EACT;AAAA;AAAA;AAAA;AAAA,EAKQ,kBAAkB,MAAA,EAGyB;AACjD,IAAA,OAAO,OAAO,KAAc,GAAA,KAAiC;AAC3D,MAAA,IAAI;AACF,QAAA,MAAM,OAAA,GAAU,IAAA,CAAK,cAAA,CAAe,GAAG,CAAA;AAEvC,QAAA,MAAM,OAAA,GAA2B;AAAA,UAC/B,GAAG,OAAA;AAAA,UACH,MAAA,EAAQ;AAAA,YACN,MAAM,MAAA,CAAO,IAAA;AAAA,YACb,MAAM,MAAA,CAAO;AAAA;AACf,SACF;AAEA,QAAA,MAAM,UAAA,GAAa,MAAM,IAAA,CAAK,0BAAA,CAA2B,GAAG,CAAA;AAE5D,QAAA,MAAM,SAAS,MAAM,IAAA,CAAK,OAAA,CAAQ,eAAA,CAAgB,SAAS,UAAU,CAAA;AAGrE,QAAA,IAAI,MAAA,CAAO,MAAA,IAAU,OAAO,MAAA,CAAO,WAAW,QAAA,EAAU;AACtD,UAAA,KAAA,MAAW,CAAC,KAAK,KAAK,CAAA,IAAK,OAAO,OAAA,CAAQ,MAAA,CAAO,MAAM,CAAA,EAAG;AACxD,YAAA,GAAA,CAAI,MAAA,CAAO,KAAK,KAAA,EAAO;AAAA,cACrB,QAAA,EAAU,IAAA;AAAA,cACV,MAAA,EAAQ,IAAA;AAAA,cACR,IAAA,EAAM,GAAA;AAAA,cACN,QAAA,EAAU,KAAA;AAAA,cACV,MAAA,EAAQ;AAAA;AAAA,aACT,CAAA;AAAA,UACH;AAAA,QACF;AAGA,QAAA,IAAI,KAAK,OAAA,CAAQ,SAAA,GAAY,MAAA,IAAU,MAAA,CAAO,MAAM,KAAA,EAAO;AACzD,UAAA,MAAM,MAAA,GAAS,IAAA,CAAK,OAAA,CAAQ,SAAA,EAAU,CAAE,MAAA;AACxC,UAAA,MAAM,UAAU,MAAA,CAAO,OAAA;AACvB,UAAA,MAAM,KAAA,GAAQ,OAAO,IAAA,CAAK,KAAA;AAE1B,UAAA,IAAI,OAAO,UAAU,QAAA,EAAU;AAC7B,YAAA,GAAA,CAAI,MAAA,CAAO,MAAA,CAAO,IAAA,EAAM,KAAA,EAAO;AAAA,cAC7B,QAAQ,OAAA,CAAQ,MAAA;AAAA,cAChB,UAAU,OAAA,CAAQ,QAAA;AAAA,cAClB,QAAQ,OAAA,CAAQ,MAAA;AAAA,cAChB,IAAA,EAAM,QAAQ,IAAA,IAAQ,GAAA;AAAA,cACtB,QAAA,EAAU,QAAQ,QAAA,IAAY,KAAA;AAAA,cAC9B,MAAA,EAAQ,OAAA,CAAQ,MAAA,GAAS,OAAA,CAAQ,SAAS,GAAA,GAAO,KAAA,CAAA;AAAA,cACjD,SAAS,OAAA,CAAQ;AAAA,aAClB,CAAA;AAAA,UACH,CAAA,MAAO;AACL,YAAA,GAAA,CAAI,MAAA,CAAO,MAAA,CAAO,IAAA,EAAM,KAAA,CAAM,WAAA,EAAa;AAAA,cACzC,QAAQ,OAAA,CAAQ,MAAA;AAAA,cAChB,UAAU,OAAA,CAAQ,QAAA;AAAA,cAClB,QAAQ,OAAA,CAAQ,MAAA;AAAA,cAChB,IAAA,EAAM,QAAQ,IAAA,IAAQ,GAAA;AAAA,cACtB,QAAA,EAAU,QAAQ,QAAA,IAAY,KAAA;AAAA,cAC9B,MAAA,EAAQ,OAAA,CAAQ,MAAA,GAAS,OAAA,CAAQ,SAAS,GAAA,GAAO,KAAA,CAAA;AAAA,cACjD,SAAS,OAAA,CAAQ;AAAA,aAClB,CAAA;AAED,YAAA,IAAI,MAAA,CAAO,cAAA,IAAkB,KAAA,CAAM,YAAA,EAAc;AAC/C,cAAA,MAAM,iBAAiB,MAAA,CAAO,cAAA;AAC9B,cAAA,GAAA,CAAI,MAAA;AAAA,gBACF,OAAO,gBAAA,IAAoB,cAAA;AAAA,gBAC3B,KAAA,CAAM,YAAA;AAAA,gBACN;AAAA,kBACE,QAAQ,cAAA,CAAe,MAAA;AAAA,kBACvB,UAAU,cAAA,CAAe,QAAA;AAAA,kBACzB,QAAQ,cAAA,CAAe,MAAA;AAAA,kBACvB,IAAA,EAAM,eAAe,IAAA,IAAQ,GAAA;AAAA,kBAC7B,QAAA,EAAU,eAAe,QAAA,IAAY,KAAA;AAAA,kBACrC,MAAA,EAAQ,cAAA,CAAe,MAAA,GACnB,cAAA,CAAe,SAAS,GAAA,GACxB,KAAA,CAAA;AAAA,kBACJ,SAAS,cAAA,CAAe;AAAA;AAC1B,eACF;AAAA,YACF;AAAA,UACF;AAAA,QACF;AAGA,QAAA,IAAI,OAAO,QAAA,EAAU;AACnB,UAAA,GAAA,CAAI,QAAA,CAAS,MAAA,CAAO,MAAA,EAAQ,MAAA,CAAO,QAAQ,CAAA;AAC3C,UAAA;AAAA,QACF;AAEA,QAAA,IAAA,CAAK,YAAA,CAAa,GAAA,EAAK,MAAA,EAAQ,MAAA,CAAO,MAAM,CAAA;AAAA,MAC9C,SAAS,KAAA,EAAO;AACd,QAAA,IAAA,CAAK,WAAA,CAAY,KAAK,KAAc,CAAA;AAAA,MACtC;AAAA,IACF,CAAA;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKQ,yBAAA,GAGW;AACjB,IAAA,OAAO,OAAO,KAAc,GAAA,KAAiC;AAC3D,MAAA,IAAI;AACF,QAAA,MAAM,OAAA,GAAU,IAAA,CAAK,cAAA,CAAe,GAAG,CAAA;AACvC,QAAA,MAAM,UAAA,GAAa,MAAM,IAAA,CAAK,0BAAA,CAA2B,GAAG,CAAA;AAC5D,QAAA,MAAM,MAAA,GAAS,MAAM,IAAA,CAAK,OAAA,CAAQ,YAAA;AAAA,UAChC,OAAA;AAAA,UACA;AAAA,SACF;AACA,QAAA,IAAA,CAAK,YAAA,CAAa,KAAK,MAAM,CAAA;AAAA,MAC/B,SAAS,KAAA,EAAO;AACd,QAAA,IAAA,CAAK,WAAA,CAAY,KAAK,KAAc,CAAA;AAAA,MACtC;AAAA,IACF,CAAA;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKQ,uBAAA,GAGW;AACjB,IAAA,OAAO,OAAO,KAAc,GAAA,KAAiC;AAC3D,MAAA,IAAI;AACF,QAAA,MAAM,MAAA,GAAS,MAAM,IAAA,CAAK,OAAA,CAAQ,WAAA,EAAY;AAC9C,QAAA,IAAA,CAAK,YAAA,CAAa,KAAK,MAAM,CAAA;AAAA,MAC/B,SAAS,KAAA,EAAO;AACd,QAAA,IAAA,CAAK,WAAA,CAAY,KAAK,KAAc,CAAA;AAAA,MACtC;AAAA,IACF,CAAA;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKQ,0BAAA,GAGW;AACjB,IAAA,OAAO,OAAO,KAAc,GAAA,KAAiC;AAC3D,MAAA,IAAI;AACF,QAAA,MAAM,EAAE,MAAA,EAAO,GAAI,GAAA,CAAI,MAAA;AACvB,QAAA,IAAI,CAAC,MAAA,EAAQ;AACX,UAAA,IAAA,CAAK,YAAY,GAAA,EAAK,IAAI,KAAA,CAAM,8BAA8B,GAAG,GAAG,CAAA;AACpE,UAAA;AAAA,QACF;AACA,QAAA,MAAM,MAAA,GAAS,MAAM,IAAA,CAAK,OAAA,CAAQ,UAAU,MAAM,CAAA;AAClD,QAAA,IAAA,CAAK,YAAA,CAAa,KAAK,MAAM,CAAA;AAAA,MAC/B,SAAS,KAAA,EAAO;AACd,QAAA,IAAA,CAAK,WAAA,CAAY,KAAK,KAAc,CAAA;AAAA,MACtC;AAAA,IACF,CAAA;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKQ,0BAAA,GAGW;AACjB,IAAA,OAAO,OAAO,KAAc,GAAA,KAAiC;AAC3D,MAAA,IAAI;AACF,QAAA,MAAM,MAAA,GAAS,MAAM,IAAA,CAAK,OAAA,CAAQ,gBAAA,EAAiB;AACnD,QAAA,IAAA,CAAK,YAAA,CAAa,KAAK,MAAM,CAAA;AAAA,MAC/B,SAAS,KAAA,EAAO;AACd,QAAA,IAAA,CAAK,WAAA,CAAY,KAAK,KAAc,CAAA;AAAA,MACtC;AAAA,IACF,CAAA;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKQ,mBAAA,GAGW;AACjB,IAAA,OAAO,OAAO,KAAc,GAAA,KAAiC;AAC3D,MAAA,IAAI;AACF,QAAA,MAAM,MAAA,GAAS,MAAM,IAAA,CAAK,OAAA,CAAQ,WAAA,EAAY;AAC9C,QAAA,IAAA,CAAK,YAAA,CAAa,KAAK,MAAM,CAAA;AAAA,MAC/B,SAAS,KAAA,EAAO;AACd,QAAA,IAAA,CAAK,WAAA,CAAY,KAAK,KAAc,CAAA;AAAA,MACtC;AAAA,IACF,CAAA;AAAA,EACF;AAAA;AAAA;AAAA;AAAA,EAKA,MAAM,eAAe,GAAA,EAAiD;AAEpE,IAAA,IAAK,GAAA,CAAY,SAAS,MAAA,EAAW;AACnC,MAAA,OAAQ,GAAA,CAAY,IAAA;AAAA,IACtB;AAGA,IAAA,MAAM,OAAA,GAAU,IAAA,CAAK,cAAA,CAAe,GAAG,CAAA;AACvC,IAAA,MAAM,UAAA,GAAa,MAAM,IAAA,CAAK,0BAAA,CAA2B,GAAG,CAAA;AAC5D,IAAA,OAAO,MAAM,IAAA,CAAK,OAAA,CAAQ,cAAA,CAAe,SAAS,UAAU,CAAA;AAAA,EAC9D;AAAA;AAAA;AAAA;AAAA,EAKA,UAAA,GAAgC;AAC9B,IAAA,OAAO,IAAA,CAAK,OAAA;AAAA,EACd;AACF;AAKO,SAAS,oBAAA,CACd,MAAA,EACA,mBAAA,GAA+B,KAAA,EAC/B,oBACA,MAAA,EACgB;AAChB,EAAA,OAAO,IAAI,cAAA;AAAA,IACT,MAAA;AAAA,IACA,mBAAA;AAAA,IACA,kBAAA;AAAA,IACA;AAAA,GACF;AACF;AAKO,SAAS,aAAA,CACd,MAAA,EACA,mBAAA,GAA+B,KAAA,EAC/B,oBACA,MAAA,EACqD;AACrD,EAAA,MAAM,UAAU,IAAI,cAAA;AAAA,IAClB,MAAA;AAAA,IACA,mBAAA;AAAA,IACA,kBAAA;AAAA,IACA;AAAA,GACF;AACA,EAAA,OAAO,QAAQ,gBAAA,EAAiB;AAClC","file":"express.cjs","sourcesContent":["import { AuthOutput, ReAuthEngine, Token } from '@re-auth/reauth';\nimport { ReAuthJWTPayload } from '@re-auth/reauth/services';\nimport { CookiePrefixOptions } from 'hono/utils/cookie';\n\n// Base HTTP adapter configuration\nexport interface HttpAdapterConfig {\n engine: ReAuthEngine;\n basePath?: string;\n cors?: CorsConfig;\n rateLimit?: RateLimitConfig;\n security?: SecurityConfig;\n validation?: ValidationConfig;\n cookie?: {\n name: string;\n refreshTokenName?: string;\n options: {\n httpOnly?: boolean;\n secure?: boolean;\n sameSite?: 'lax' | 'strict' | 'none';\n path?: string;\n domain?: string;\n maxAge?: number; // in seconds\n expires?: Date;\n partitioned?: boolean;\n prefix?: CookiePrefixOptions;\n priority?: 'low' | 'medium' | 'high';\n };\n refreshOptions?: {\n httpOnly?: boolean;\n secure?: boolean;\n sameSite?: 'lax' | 'strict' | 'none';\n path?: string;\n domain?: string;\n maxAge?: number; // in seconds\n expires?: Date;\n partitioned?: boolean;\n prefix?: CookiePrefixOptions;\n priority?: 'low' | 'medium' | 'high';\n };\n };\n headerToken?: {\n accesssTokenHeader: string;\n refreshTokenHeader?: string;\n };\n}\n\n// CORS configuration\nexport interface CorsConfig {\n origin?:\n | string\n | string[]\n | boolean\n | ((\n origin: string | undefined,\n callback: (err: Error | null, allow?: boolean) => void,\n ) => void);\n credentials?: boolean;\n allowedHeaders?: string[];\n exposedHeaders?: string[];\n methods?: string[];\n preflightContinue?: boolean;\n optionsSuccessStatus?: number;\n}\n\n// Rate limiting configuration\nexport interface RateLimitConfig {\n windowMs?: number;\n max?: number;\n message?: string;\n standardHeaders?: boolean;\n legacyHeaders?: boolean;\n skipSuccessfulRequests?: boolean;\n skipFailedRequests?: boolean;\n keyGenerator?: (request: any) => string;\n}\n\n// Security configuration\nexport interface SecurityConfig {\n helmet?: boolean | HelmetConfig;\n csrf?: boolean | CsrfConfig;\n sanitizeInput?: boolean;\n sanitizeOutput?: boolean;\n}\n\nexport interface HelmetConfig {\n contentSecurityPolicy?: boolean | object;\n crossOriginEmbedderPolicy?: boolean;\n crossOriginOpenerPolicy?: boolean;\n crossOriginResourcePolicy?: boolean;\n dnsPrefetchControl?: boolean;\n frameguard?: boolean | object;\n hidePoweredBy?: boolean;\n hsts?: boolean | object;\n ieNoOpen?: boolean;\n noSniff?: boolean;\n originAgentCluster?: boolean;\n permittedCrossDomainPolicies?: boolean;\n referrerPolicy?: boolean | object;\n xssFilter?: boolean;\n}\n\nexport interface CsrfConfig {\n secret?: string;\n cookie?: boolean | object;\n sessionKey?: string;\n value?: (req: any) => string;\n}\n\n// Input validation configuration\nexport interface ValidationConfig {\n validateInput?: boolean;\n validateOutput?: boolean;\n maxPayloadSize?: number;\n allowedFields?: string[];\n sanitizeFields?: string[];\n}\n\n// HTTP request/response types for framework abstraction\nexport interface HttpRequest {\n method: string;\n url: string;\n path: string;\n query: Record;\n params: Record;\n body: any;\n headers: Record;\n cookies?: Record;\n ip?: string;\n userAgent?: string;\n // Current authenticated user information\n user?: AuthenticatedUser | null;\n}\n\n// Authenticated user information from session\nexport interface AuthenticatedUser {\n /** The authenticated subject from the session */\n subject: any;\n /** The session token */\n token: Token;\n /** Whether the session is valid */\n valid: boolean;\n /** Session metadata */\n metadata?: {\n payload?: ReAuthJWTPayload;\n type?: 'jwt' | 'legacy' | undefined;\n // Add any other metadata fields as needed\n [key: string]: any;\n };\n}\n\nexport interface HttpResponse {\n status(code: number): this;\n json(data: any): this;\n send(data: any): this;\n header(name: string, value: string): this;\n cookie(name: string, value: string, options?: any): this;\n clearCookie(name: string, options?: any): this;\n}\n\n// Framework adapter interface\nexport interface FrameworkAdapter<\n TRequest = any,\n TResponse = any,\n TNext = any,\n> {\n name: string;\n createMiddleware(): (\n req: TRequest,\n res: TResponse,\n next: TNext,\n ) => Promise | void;\n createUserMiddleware(): (\n req: TRequest,\n res: TResponse,\n next: TNext,\n ) => Promise | void;\n extractRequest(req: TRequest): HttpRequest;\n sendResponse(res: TResponse, data: any, statusCode?: number): void;\n handleError(res: TResponse, error: Error, statusCode?: number): void;\n getCurrentUser(req: TRequest): Promise;\n}\n\n// Route handler types\nexport interface RouteHandler {\n (req: HttpRequest, res: HttpResponse): Promise | any;\n}\n\nexport interface AuthStepRequest extends HttpRequest {\n params: Record;\n plugin: {\n name: string;\n step: string;\n };\n}\n\nexport interface SessionRequest extends HttpRequest {\n headers: Record & {\n authorization?: string;\n };\n}\n\n// Plugin endpoint metadata\nexport interface PluginEndpoint {\n pluginName: string;\n stepName: string;\n path: string;\n method: 'GET' | 'POST' | 'PUT' | 'DELETE' | 'PATCH';\n requiresAuth: boolean;\n description?: string;\n inputSchema?: any;\n outputSchema?: any;\n}\n\n// HTTP adapter response types\nexport interface ApiResponse {\n success: boolean;\n data?: T;\n error?: {\n code: string;\n message: string;\n details?: any;\n };\n meta?: {\n timestamp: string;\n requestId?: string;\n pagination?: {\n page: number;\n limit: number;\n total: number;\n };\n };\n}\n\nexport interface AuthStepResponse extends ApiResponse {\n data?: AuthOutput & {\n nextStep?: string;\n requiresRedirect?: boolean;\n sessionToken?: Token;\n };\n status: number;\n /** Redirect URL for OAuth flows */\n redirect?: string;\n /** Secret data (cookies) to set for OAuth flows */\n secret?: Record;\n}\n\nexport interface SessionResponse extends ApiResponse {\n data?: {\n valid: boolean;\n subject?: any;\n token?: Token;\n expiresAt?: string;\n metadata?: {\n payload?: ReAuthJWTPayload;\n type?: 'jwt' | 'legacy' | undefined;\n // Add any other metadata fields as needed\n [key: string]: any;\n };\n };\n}\n\nexport interface PluginListResponse extends ApiResponse {\n data?: Array<{\n name: string;\n description: string;\n steps: Array<{\n name: string;\n description?: string;\n method: string;\n path: string;\n requiresAuth: boolean;\n }>;\n }>;\n}\n\n// Middleware types\nexport interface MiddlewareFunction<\n TRequest = any,\n TResponse = any,\n TNext = any,\n> {\n (req: TRequest, res: TResponse, next: TNext): Promise | void;\n}\n\nexport interface SecurityMiddleware {\n cors(): MiddlewareFunction;\n rateLimit(): MiddlewareFunction;\n helmet(): MiddlewareFunction;\n validation(): MiddlewareFunction;\n}\n\n// Error types\nexport class HttpAdapterError extends Error {\n constructor(\n message: string,\n public statusCode: number = 500,\n public code: string = 'INTERNAL_ERROR',\n public details?: any,\n ) {\n super(message);\n this.name = 'HttpAdapterError';\n }\n}\n\nexport class ValidationError extends HttpAdapterError {\n constructor(message: string, details?: any) {\n super(message, 400, 'VALIDATION_ERROR', details);\n this.name = 'ValidationError';\n }\n}\n\nexport class AuthenticationError extends HttpAdapterError {\n constructor(message: string, details?: any) {\n super(message, 401, 'AUTHENTICATION_ERROR', details);\n this.name = 'AuthenticationError';\n }\n}\n\nexport class AuthorizationError extends HttpAdapterError {\n constructor(message: string, details?: any) {\n super(message, 403, 'AUTHORIZATION_ERROR', details);\n this.name = 'AuthorizationError';\n }\n}\n\nexport class NotFoundError extends HttpAdapterError {\n constructor(message: string, details?: any) {\n super(message, 404, 'NOT_FOUND', details);\n this.name = 'NotFoundError';\n }\n}\n\nexport class RateLimitError extends HttpAdapterError {\n constructor(message: string, details?: any) {\n super(message, 429, 'RATE_LIMIT_EXCEEDED', details);\n this.name = 'RateLimitError';\n }\n}\n","import { AuthInput, ReAuthEngine, Token } from '@re-auth/reauth';\nimport type { LoggerInterface } from '@re-auth/logger';\nimport type {\n HttpAdapterConfig,\n HttpRequest,\n HttpResponse,\n FrameworkAdapter,\n RouteHandler,\n AuthStepRequest,\n SessionRequest,\n PluginEndpoint,\n ApiResponse,\n AuthStepResponse,\n SessionResponse,\n PluginListResponse,\n AuthenticatedUser,\n} from './types';\nimport {\n HttpAdapterError,\n ValidationError,\n AuthenticationError,\n NotFoundError,\n} from './types';\n\nexport class ReAuthHttpAdapter {\n private engine: ReAuthEngine;\n protected config: HttpAdapterConfig;\n private endpoints: Map = new Map();\n private logger: LoggerInterface;\n\n constructor(config: HttpAdapterConfig, logger: LoggerInterface) {\n this.engine = config.engine;\n this.config = config;\n this.logger = logger;\n this.buildEndpoints();\n }\n\n /**\n * Get adapter configuration\n */\n getConfig(): HttpAdapterConfig {\n return this.config;\n }\n\n /**\n * Build endpoint map from registered plugins\n */\n private buildEndpoints(): void {\n const plugins = this.engine.getAllPlugins();\n\n for (const plugin of plugins) {\n if (!plugin.steps) continue;\n\n for (const step of plugin.steps) {\n const endpoint: PluginEndpoint = {\n pluginName: plugin.name,\n stepName: step.name,\n path: `${this.config.basePath || ''}/${plugin.name}/${step.name}`,\n method: step.protocol?.http?.method || 'POST',\n requiresAuth: Boolean(step.protocol?.http?.auth),\n description: step.description,\n inputSchema: step.validationSchema,\n outputSchema: step.outputs,\n };\n\n const key = `${plugin.name}:${step.name}`;\n this.endpoints.set(key, endpoint);\n }\n }\n }\n\n /**\n * Get all available endpoints\n */\n getEndpoints(): PluginEndpoint[] {\n return Array.from(this.endpoints.values());\n }\n\n /**\n * Get endpoint by plugin and step name\n */\n getEndpoint(\n pluginName: string,\n stepName: string,\n ): PluginEndpoint | undefined {\n return this.endpoints.get(`${pluginName}:${stepName}`);\n }\n\n /**\n * Execute authentication step\n */\n async executeAuthStep(\n req: AuthStepRequest,\n deviceInfo: Record,\n ): Promise {\n const endpoint = this.getEndpoint(req.plugin.name, req.plugin.step);\n if (!endpoint) {\n throw new NotFoundError(\n `Endpoint not found: ${req.plugin.name}/${req.plugin.step}`,\n );\n }\n\n // Check authentication if required\n if (endpoint.requiresAuth) {\n await this.requireAuthentication(req, deviceInfo);\n } else {\n //NOTE: this is to ensure token will be auto refresh if needed when a token is availabe\n await this.getCurrentUser(req, deviceInfo);\n }\n\n // Extract input from request\n const input = this.extractStepInput(req, endpoint, deviceInfo);\n\n try {\n // Execute the step\n const output = await this.engine.executeStep(\n endpoint.pluginName,\n endpoint.stepName,\n input,\n );\n\n // Return standardized response\n const pl = this.engine.getPlugin(endpoint.pluginName);\n const step = pl?.steps?.find((s) => s.name === endpoint.stepName);\n\n const status = step?.protocol?.http?.codes?.[output.status] || 200;\n\n return {\n success: true,\n data: {\n ...output,\n sessionToken: output.token,\n },\n meta: {\n timestamp: new Date().toISOString(),\n },\n status,\n redirect: output.redirect, // Include redirect URL for OAuth flow\n secret: output.secret, // Include cookies to set for OAuth flow\n };\n } catch (error) {\n throw new HttpAdapterError(\n `Step execution failed: ${error instanceof Error ? error.message : String(error)}`,\n 500,\n 'STEP_EXECUTION_ERROR',\n { pluginName: endpoint.pluginName, stepName: endpoint.stepName, error },\n );\n }\n }\n\n /**\n * Create a new session\n */\n async createSession(\n req: SessionRequest,\n deviceInfo: Record,\n ): Promise {\n const { subjectType, subjectId, ttlSeconds } = req.body || {};\n\n if (!subjectType || !subjectId) {\n throw new ValidationError('subjectType and subjectId are required');\n }\n\n try {\n const token = await this.engine.createSessionFor(\n subjectType,\n subjectId,\n ttlSeconds,\n deviceInfo,\n );\n\n return {\n success: true,\n data: {\n valid: true,\n token,\n expiresAt: ttlSeconds\n ? new Date(Date.now() + ttlSeconds * 1000).toISOString()\n : undefined,\n },\n meta: {\n timestamp: new Date().toISOString(),\n },\n };\n } catch (error) {\n throw new HttpAdapterError(\n `Session creation failed: ${error instanceof Error ? error.message : String(error)}`,\n 500,\n 'SESSION_CREATION_ERROR',\n );\n }\n }\n\n /**\n * Check session validity\n */\n async checkSession(\n req: SessionRequest,\n deviceInfo: Record,\n ): Promise {\n const token = this.extractSessionToken(req);\n\n if (!token) {\n return {\n success: false,\n data: {\n valid: false,\n },\n meta: {\n timestamp: new Date().toISOString(),\n },\n };\n }\n\n try {\n const result = await this.engine.checkSession(token, deviceInfo);\n\n if (!result.subject) {\n return {\n success: false,\n data: {\n valid: false,\n },\n meta: {\n timestamp: new Date().toISOString(),\n },\n };\n }\n\n return {\n success: true,\n data: {\n valid: result.valid,\n subject: result.subject,\n token: result.token,\n metadata: {\n payload: result.payload,\n type: result.type,\n },\n },\n meta: {\n timestamp: new Date().toISOString(),\n },\n };\n } catch (error) {\n return {\n success: false,\n data: {\n valid: false,\n },\n meta: {\n timestamp: new Date().toISOString(),\n },\n };\n }\n }\n\n /**\n * Destroy current session\n */\n async destroySession(req: SessionRequest): Promise {\n const token = this.extractSessionToken(req);\n\n if (!token) {\n throw new ValidationError('No session token provided');\n }\n\n try {\n await this.engine.getSessionService().destroySession(token);\n\n return {\n success: true,\n meta: {\n timestamp: new Date().toISOString(),\n },\n };\n } catch (error) {\n throw new HttpAdapterError(\n `Session destruction failed: ${error instanceof Error ? error.message : String(error)}`,\n 500,\n 'SESSION_DESTRUCTION_ERROR',\n );\n }\n }\n\n /**\n * List all available plugins\n */\n async listPlugins(): Promise {\n const plugins = this.engine.getAllPlugins();\n\n const data = plugins.map((plugin) => ({\n name: plugin.name,\n description: `${plugin.name} authentication plugin`,\n steps: (plugin.steps || []).map((step) => ({\n name: step.name,\n description: step.description,\n method: step.protocol?.http?.method || 'POST',\n path: `${this.config.basePath || ''}/auth/${plugin.name}/${step.name}`,\n requiresAuth: Boolean(step.protocol?.http?.auth),\n })),\n }));\n\n return {\n success: true,\n data,\n meta: {\n timestamp: new Date().toISOString(),\n },\n };\n }\n\n /**\n * Get specific plugin details\n */\n async getPlugin(pluginName: string): Promise {\n const plugin = this.engine.getPlugin(pluginName);\n\n if (!plugin) {\n throw new NotFoundError(`Plugin not found: ${pluginName}`);\n }\n\n const data = {\n name: plugin.name,\n description: `${plugin.name} authentication plugin`,\n steps: (plugin.steps || []).map((step) => ({\n name: step.name,\n description: step.description,\n method: step.protocol?.http?.method || 'POST',\n path: `${this.config.basePath || ''}/auth/${plugin.name}/${step.name}`,\n requiresAuth: Boolean(step.protocol?.http?.auth),\n inputs: step.inputs || [],\n inputSchema: step.validationSchema?.toJsonSchema?.() || {},\n outputSchema: step.outputs?.toJsonSchema?.() || {},\n })),\n };\n\n return {\n success: true,\n data,\n meta: {\n timestamp: new Date().toISOString(),\n },\n };\n }\n\n /**\n * Get full introspection data\n */\n async getIntrospection(): Promise {\n const introspectionData = this.engine.getIntrospectionData();\n\n // Add HTTP adapter configuration to introspection\n const httpConfig = {\n basePath: this.config.basePath || '',\n tokenConfig: {\n header: {\n accessTokenHeader:\n this.config.headerToken?.accesssTokenHeader || 'authorization',\n refreshTokenHeader:\n this.config.headerToken?.refreshTokenHeader || 'x-refresh-token',\n useBearer: true, // Default to Bearer token in Authorization header\n },\n cookie: {\n accessTokenName: this.config.cookie?.name || 'reauth-session',\n refreshTokenName:\n this.config.cookie?.refreshTokenName || 'reauth-refresh',\n enabled: !!this.config.cookie,\n },\n },\n };\n\n return {\n success: true,\n data: {\n ...introspectionData,\n httpConfig,\n },\n meta: {\n timestamp: new Date().toISOString(),\n },\n };\n }\n\n /**\n * Health check endpoint\n */\n async healthCheck(): Promise {\n return {\n success: true,\n data: {\n status: 'healthy',\n version: '2.0.0',\n plugins: this.engine.getAllPlugins().length,\n endpoints: this.endpoints.size,\n },\n meta: {\n timestamp: new Date().toISOString(),\n },\n };\n }\n\n /**\n * Extract session token from request\n */\n private extractSessionToken(req: HttpRequest): Token {\n let accessToken: string | null = null;\n let refreshToken: string | null = null;\n\n // Try Authorization header first\n const authHeader = req.headers.authorization;\n if (authHeader?.startsWith('Bearer ')) {\n accessToken = authHeader.substring(7);\n }\n\n // check custom headers\n if (\n !accessToken &&\n req.headers[\n this.config.headerToken?.accesssTokenHeader || 'x-access-token'\n ]\n ) {\n accessToken =\n req.headers[\n this.config.headerToken?.accesssTokenHeader || 'x-access-token'\n ]!;\n }\n if (\n !refreshToken &&\n req.headers[\n this.config.headerToken?.refreshTokenHeader || 'x-refresh-token'\n ]\n ) {\n refreshToken =\n req.headers[\n this.config.headerToken?.refreshTokenHeader || 'x-refresh-token'\n ]!;\n }\n\n // Try cookie\n if (\n !accessToken &&\n req.cookies?.[this.config.cookie?.name || 'reauth-session']\n ) {\n accessToken = req.cookies[this.config.cookie?.name || 'reauth-session']!;\n }\n\n if (\n !refreshToken &&\n req.cookies?.[this.config.cookie?.refreshTokenName || 'reauth-refresh']\n ) {\n refreshToken =\n req.cookies[this.config.cookie?.refreshTokenName || 'reauth-refresh']!;\n }\n\n if (!accessToken) {\n this.logger.info('http', 'No access token found in request', {\n path: req.path,\n hasHeaders: !!req.headers,\n });\n return null;\n }\n\n if (accessToken && refreshToken) {\n this.logger.info('http', 'Access token and refresh token found', {\n path: req.path,\n hasHeaders: !!req.headers,\n });\n return { accessToken, refreshToken };\n }\n\n if (accessToken && !refreshToken) {\n this.logger.info('http', 'Access token found without refresh token', {\n path: req.path,\n hasHeaders: !!req.headers,\n });\n return accessToken;\n }\n\n this.logger.info('http', 'No access token or refresh token found', {\n path: req.path,\n hasHeaders: !!req.headers,\n });\n return null;\n }\n\n /**\n * Extract step input from request\n */\n private extractStepInput(\n req: HttpRequest,\n endpoint: PluginEndpoint,\n deviceInfo: Record,\n ): AuthInput {\n const input: AuthInput = {\n ...req.body,\n ...req.query,\n ...req.params,\n ...req.cookies, // Add cookies so OAuth flow can read oauth_state, etc.\n };\n\n // Add session token if available\n const token = this.extractSessionToken(req);\n if (token) {\n input.token = token;\n }\n\n // Add device info if provided\n if (deviceInfo) {\n input.deviceInfo = deviceInfo;\n }\n\n // Add request metadata for backward compatibility\n if (req.ip) {\n input.ip = req.ip;\n }\n if (req.userAgent) {\n input.userAgent = req.userAgent;\n }\n\n return input;\n }\n\n /**\n * Get current authenticated user from request\n */\n async getCurrentUser(\n req: HttpRequest,\n deviceInfo: Record,\n ): Promise {\n const token = this.extractSessionToken(req);\n\n if (!token) {\n this.logger.info('http', 'No token found in getCurrentUser', {\n path: req.path,\n hasHeaders: !!req.headers,\n });\n return null;\n }\n\n try {\n const session = await this.engine.checkSession(token, deviceInfo);\n\n if (!session.valid || !session.subject) {\n this.logger.warn('http', 'Session is not valid or subject not found', {\n hasHeaders: !!req.headers,\n });\n return null;\n }\n\n return {\n subject: session.subject,\n token: session.token || token,\n valid: session.valid,\n metadata: {\n payload: session.payload,\n type: session.type,\n },\n };\n } catch (error) {\n // Silently return null if session check fails\n this.logger.error('http', 'Session check failed', {\n hasHeaders: !!req.headers,\n error,\n });\n return null;\n }\n }\n\n /**\n * Authenticate request and return user or throw error\n */\n async requireAuthentication(\n req: HttpRequest,\n deviceInfo: Record,\n ): Promise {\n const user = await this.getCurrentUser(req, deviceInfo);\n\n if (!user) {\n this.logger.warn('http', 'Authentication required but no user found', {\n path: req.path,\n hasHeaders: !!req.headers,\n });\n throw new AuthenticationError('Authentication required');\n }\n\n return user;\n }\n\n /**\n * Create framework-specific adapter\n */\n createAdapter(\n adapter: FrameworkAdapter,\n ): FrameworkAdapter {\n return adapter;\n }\n\n /**\n * Generic route handler factory\n */\n createRouteHandler(handler: RouteHandler) {\n return async (req: HttpRequest, res: HttpResponse): Promise => {\n try {\n const result = await handler(req, res);\n if (result) {\n res.status(200).json(result);\n }\n } catch (error) {\n this.handleError(error, res);\n }\n };\n }\n\n /**\n * Error handler\n */\n private handleError(error: unknown, res: HttpResponse): void {\n if (error instanceof HttpAdapterError) {\n res.status(error.statusCode).json({\n success: false,\n error: {\n code: error.code,\n message: error.message,\n details: error.details,\n },\n meta: {\n timestamp: new Date().toISOString(),\n },\n });\n } else {\n res.status(500).json({\n success: false,\n error: {\n code: 'INTERNAL_ERROR',\n message: 'An unexpected error occurred',\n },\n meta: {\n timestamp: new Date().toISOString(),\n },\n });\n }\n }\n}\n","import type { Request, Response, NextFunction, Router } from 'express';\nimport express from 'express';\nimport type {\n HttpAdapterConfig,\n FrameworkAdapter,\n HttpRequest,\n MiddlewareFunction,\n AuthenticatedUser,\n AuthStepRequest,\n} from '../types';\nimport { ReAuthHttpAdapter } from '../base-adapter';\nimport type { LoggerInterface } from '@re-auth/logger';\n\nexport class ExpressAdapter\n implements FrameworkAdapter\n{\n public readonly name = 'express';\n private adapter: ReAuthHttpAdapter;\n private generateDeviceInfo?: (\n request: Request,\n ) => Promise>;\n\n constructor(\n config: HttpAdapterConfig,\n private exposeIntrospection: boolean,\n generateDeviceInfo?: (request: Request) => Promise>,\n logger?: LoggerInterface,\n ) {\n const defaultLogger: LoggerInterface = {\n info: () => {},\n warn: () => {},\n error: () => {},\n success: () => {},\n setEnabledTags: () => {},\n destroy: () => {},\n };\n this.adapter = new ReAuthHttpAdapter(config, logger || defaultLogger);\n this.generateDeviceInfo = generateDeviceInfo;\n }\n\n /**\n * Generate device info from request\n */\n async generateDeviceInfoInternal(\n request: Request,\n ): Promise> {\n if (!this.generateDeviceInfo) {\n return {};\n }\n\n const deviceInfo = await this.generateDeviceInfo(request);\n return deviceInfo;\n }\n\n /**\n * Create Express middleware that populates req.user\n */\n createUserMiddleware(): (\n req: Request,\n res: Response,\n next: NextFunction,\n ) => Promise {\n return async (\n req: Request,\n res: Response,\n next: NextFunction,\n ): Promise => {\n try {\n const httpReq = this.extractRequest(req);\n const deviceInfo = await this.generateDeviceInfoInternal(req);\n (req as any).user = await this.adapter.getCurrentUser(\n httpReq,\n deviceInfo,\n );\n next();\n } catch (error) {\n // Don't fail the request if user lookup fails, just continue with req.user = null\n (req as any).user = null;\n next();\n }\n };\n }\n\n /**\n * Create Express middleware that adds adapter to request\n */\n createMiddleware(): (\n req: Request,\n res: Response,\n next: NextFunction,\n ) => Promise {\n return async (\n req: Request,\n res: Response,\n next: NextFunction,\n ): Promise => {\n // Add adapter to request for access in route handlers\n (req as any).reauth = this.adapter;\n next();\n };\n }\n\n /**\n * Extract HTTP request from Express request\n */\n extractRequest(req: Request): HttpRequest {\n return {\n method: req.method,\n url: req.url,\n path: req.path,\n query: req.query as Record,\n params: req.params,\n body: req.body,\n headers: req.headers as Record,\n cookies: req.cookies,\n ip: req.ip,\n userAgent: req.get('User-Agent'),\n };\n }\n\n /**\n * Send response using Express response object\n */\n sendResponse(res: Response, data: any, statusCode: number = 200): void {\n res.status(statusCode).json(data);\n }\n\n /**\n * Handle error using Express response object\n */\n handleError(res: Response, error: Error, statusCode: number = 500): void {\n res.status(statusCode).json({\n success: false,\n error: {\n code: 'ERROR',\n message: error.message,\n },\n meta: {\n timestamp: new Date().toISOString(),\n },\n });\n }\n\n /**\n * Create Express router with all ReAuth routes\n */\n createRouter(router?: Router, basePath: string = ''): Router {\n // Create a new router if not provided\n router = router || express.Router();\n\n // Add middleware\n router.use(this.createMiddleware());\n\n // Session management routes\n router.get(`${basePath}/session`, this.createSessionCheckHandler());\n\n // Plugin introspection routes\n\n // Introspection and health\n if (this.exposeIntrospection) {\n router.get(\n `${basePath}/introspection`,\n this.createIntrospectionHandler(),\n );\n router.get(`${basePath}/plugins`, this.createPluginListHandler());\n router.get(\n `${basePath}/plugins/:plugin`,\n this.createPluginDetailsHandler(),\n );\n }\n\n router.get(`${basePath}/health`, this.createHealthHandler());\n\n // Authentication step routes\n const endpoints = this.adapter.getEndpoints();\n for (const endpoint of endpoints) {\n if (endpoint.method === 'POST') {\n router.post(endpoint.path, (req: Request, res: Response) =>\n this.createStepHandler({\n name: endpoint.pluginName,\n step: endpoint.stepName,\n }),\n );\n } else if (endpoint.method === 'GET') {\n router.get(\n endpoint.path,\n this.createStepHandler({\n name: endpoint.pluginName,\n step: endpoint.stepName,\n }),\n );\n } else if (endpoint.method === 'PUT') {\n router.put(\n endpoint.path,\n this.createStepHandler({\n name: endpoint.pluginName,\n step: endpoint.stepName,\n }),\n );\n } else if (endpoint.method === 'PATCH') {\n router.patch(\n endpoint.path,\n this.createStepHandler({\n name: endpoint.pluginName,\n step: endpoint.stepName,\n }),\n );\n } else if (endpoint.method === 'DELETE') {\n router.delete(\n endpoint.path,\n this.createStepHandler({\n name: endpoint.pluginName,\n step: endpoint.stepName,\n }),\n );\n }\n }\n\n return router;\n }\n\n /**\n * Create step execution handler\n */\n private createStepHandler(plugin: {\n name: string;\n step: string;\n }): (req: Request, res: Response) => Promise {\n return async (req: Request, res: Response): Promise => {\n try {\n const httpReq = this.extractRequest(req);\n\n const request: AuthStepRequest = {\n ...httpReq,\n plugin: {\n name: plugin.name,\n step: plugin.step,\n },\n };\n\n const deviceInfo = await this.generateDeviceInfoInternal(req);\n\n const result = await this.adapter.executeAuthStep(request, deviceInfo);\n\n // Set cookies from secret field (OAuth flow)\n if (result.secret && typeof result.secret === 'object') {\n for (const [key, value] of Object.entries(result.secret)) {\n res.cookie(key, value, {\n httpOnly: true,\n secure: true,\n path: '/',\n sameSite: 'lax',\n maxAge: 600000, // 10 minutes for OAuth state/verifier\n });\n }\n }\n\n // Set session cookies if configured\n if (this.adapter.getConfig().cookie && result.data?.token) {\n const cookie = this.adapter.getConfig().cookie!;\n const options = cookie.options;\n const token = result.data.token;\n\n if (typeof token === 'string') {\n res.cookie(cookie.name, token, {\n domain: options.domain,\n httpOnly: options.httpOnly,\n secure: options.secure,\n path: options.path || '/',\n sameSite: options.sameSite || 'lax',\n maxAge: options.maxAge ? options.maxAge * 1000 : undefined,\n expires: options.expires,\n });\n } else {\n res.cookie(cookie.name, token.accessToken, {\n domain: options.domain,\n httpOnly: options.httpOnly,\n secure: options.secure,\n path: options.path || '/',\n sameSite: options.sameSite || 'lax',\n maxAge: options.maxAge ? options.maxAge * 1000 : undefined,\n expires: options.expires,\n });\n\n if (cookie.refreshOptions && token.refreshToken) {\n const refreshOptions = cookie.refreshOptions;\n res.cookie(\n cookie.refreshTokenName || 'refreshToken',\n token.refreshToken,\n {\n domain: refreshOptions.domain,\n httpOnly: refreshOptions.httpOnly,\n secure: refreshOptions.secure,\n path: refreshOptions.path || '/',\n sameSite: refreshOptions.sameSite || 'lax',\n maxAge: refreshOptions.maxAge\n ? refreshOptions.maxAge * 1000\n : undefined,\n expires: refreshOptions.expires,\n },\n );\n }\n }\n }\n\n // Handle redirect responses (OAuth flow)\n if (result.redirect) {\n res.redirect(result.status, result.redirect);\n return;\n }\n\n this.sendResponse(res, result, result.status);\n } catch (error) {\n this.handleError(res, error as Error);\n }\n };\n }\n\n /**\n * Create session check handler\n */\n private createSessionCheckHandler(): (\n req: Request,\n res: Response,\n ) => Promise {\n return async (req: Request, res: Response): Promise => {\n try {\n const httpReq = this.extractRequest(req);\n const deviceInfo = await this.generateDeviceInfoInternal(req);\n const result = await this.adapter.checkSession(\n httpReq as any,\n deviceInfo,\n );\n this.sendResponse(res, result);\n } catch (error) {\n this.handleError(res, error as Error);\n }\n };\n }\n\n /**\n * Create plugin list handler\n */\n private createPluginListHandler(): (\n req: Request,\n res: Response,\n ) => Promise {\n return async (req: Request, res: Response): Promise => {\n try {\n const result = await this.adapter.listPlugins();\n this.sendResponse(res, result);\n } catch (error) {\n this.handleError(res, error as Error);\n }\n };\n }\n\n /**\n * Create plugin details handler\n */\n private createPluginDetailsHandler(): (\n req: Request,\n res: Response,\n ) => Promise {\n return async (req: Request, res: Response): Promise => {\n try {\n const { plugin } = req.params;\n if (!plugin) {\n this.handleError(res, new Error('Plugin parameter is required'), 400);\n return;\n }\n const result = await this.adapter.getPlugin(plugin);\n this.sendResponse(res, result);\n } catch (error) {\n this.handleError(res, error as Error);\n }\n };\n }\n\n /**\n * Create introspection handler\n */\n private createIntrospectionHandler(): (\n req: Request,\n res: Response,\n ) => Promise {\n return async (req: Request, res: Response): Promise => {\n try {\n const result = await this.adapter.getIntrospection();\n this.sendResponse(res, result);\n } catch (error) {\n this.handleError(res, error as Error);\n }\n };\n }\n\n /**\n * Create health check handler\n */\n private createHealthHandler(): (\n req: Request,\n res: Response,\n ) => Promise {\n return async (req: Request, res: Response): Promise => {\n try {\n const result = await this.adapter.healthCheck();\n this.sendResponse(res, result);\n } catch (error) {\n this.handleError(res, error as Error);\n }\n };\n }\n\n /**\n * Get current user from Express request\n */\n async getCurrentUser(req: Request): Promise {\n // If user is already populated by middleware, return it\n if ((req as any).user !== undefined) {\n return (req as any).user;\n }\n\n // Otherwise, check session\n const httpReq = this.extractRequest(req);\n const deviceInfo = await this.generateDeviceInfoInternal(req);\n return await this.adapter.getCurrentUser(httpReq, deviceInfo);\n }\n\n /**\n * Get the base adapter instance\n */\n getAdapter(): ReAuthHttpAdapter {\n return this.adapter;\n }\n}\n\n/**\n * Factory function to create Express adapter\n */\nexport function createExpressAdapter(\n config: HttpAdapterConfig,\n exposeIntrospection: boolean = false,\n generateDeviceInfo?: (request: Request) => Promise>,\n logger?: LoggerInterface,\n): ExpressAdapter {\n return new ExpressAdapter(\n config,\n exposeIntrospection,\n generateDeviceInfo,\n logger,\n );\n}\n\n/**\n * Express middleware factory function\n */\nexport function expressReAuth(\n config: HttpAdapterConfig,\n exposeIntrospection: boolean = false,\n generateDeviceInfo?: (request: Request) => Promise>,\n logger?: LoggerInterface,\n): MiddlewareFunction {\n const adapter = new ExpressAdapter(\n config,\n exposeIntrospection,\n generateDeviceInfo,\n logger,\n );\n return adapter.createMiddleware();\n}\n"]}