From a8cc3f5312f6fa9a9675be4c68e209f45621c4a2 Mon Sep 17 00:00:00 2001 From: Elizabeth Hunt Date: Sun, 7 Dec 2025 14:51:20 -0800 Subject: Update ci --- .ci/ci.js | 4 ++-- .ci/package-lock.json | 16 ++++++++-------- .ci/package.json | 2 +- 3 files changed, 11 insertions(+), 11 deletions(-) diff --git a/.ci/ci.js b/.ci/ci.js index aff5c11..c29990d 100755 --- a/.ci/ci.js +++ b/.ci/ci.js @@ -1,3 +1,3 @@ #!/usr/bin/env node -"use strict";var Br=Object.create;var yt=Object.defineProperty;var Hr=Object.getOwnPropertyDescriptor;var xr=Object.getOwnPropertyNames;var Wr=Object.getPrototypeOf,Fr=Object.prototype.hasOwnProperty;var s=(r,e)=>()=>(e||r((e={exports:{}}).exports,e),e.exports);var Jr=(r,e,t,i)=>{if(e&&typeof e=="object"||typeof e=="function")for(let n of xr(e))!Fr.call(r,n)&&n!==t&&yt(r,n,{get:()=>e[n],enumerable:!(i=Hr(e,n))||i.enumerable});return r};var We=(r,e,t)=>(t=r!=null?Br(Wr(r)):{},Jr(e||!r||!r.__esModule?yt(t,"default",{value:r,enumerable:!0}):t,r));var Mt=s(be=>{"use strict";Object.defineProperty(be,"__esModule",{value:!0});be.prependWith=void 0;var Vr=(r,e)=>Array(r.length*2).fill(0).map((t,i)=>i%2===0).map((t,i)=>t?e:r[Math.floor(i/2)]);be.prependWith=Vr});var wt=s(F=>{"use strict";Object.defineProperty(F,"__esModule",{value:!0});F.isDebug=F.isProd=void 0;var Tt=!0,$r=Tt&&(process.env.ENVIRONMENT??"").toLowerCase().includes("prod")?"production":"development",Gr=()=>$r==="production";F.isProd=Gr;var Yr=!(0,F.isProd)()||Tt&&["y","t"].some((process.env.DEBUG??"").toLowerCase().startsWith),Kr=()=>Yr;F.isDebug=Kr});var St=s(me=>{"use strict";Object.defineProperty(me,"__esModule",{value:!0});me.memoize=void 0;var zr=r=>{let e=new Map;return(...t)=>{let i=JSON.stringify(t);if(e.has(i))return e.get(i);let n=r(...t);return e.set(i,n),n}};me.memoize=zr});var Et=s(L=>{"use strict";var Qr=L&&L.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),Fe=L&&L.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&Qr(e,r,t)};Object.defineProperty(L,"__esModule",{value:!0});Fe(Mt(),L);Fe(wt(),L);Fe(St(),L)});var Rt=s(Pt=>{"use strict";Object.defineProperty(Pt,"__esModule",{value:!0})});var jt=s(_e=>{"use strict";Object.defineProperty(_e,"__esModule",{value:!0});_e.isObject=void 0;var Zr=r=>typeof r=="object"&&!Array.isArray(r)&&!!r;_e.isObject=Zr});var Lt=s(Oe=>{"use strict";Object.defineProperty(Oe,"__esModule",{value:!0});Oe.isTagged=void 0;var Xr=Je(),kr=(r,e)=>!!((0,Xr.isObject)(r)&&"_tag"in r&&r._tag===e);Oe.isTagged=kr});var Nt=s(qt=>{"use strict";Object.defineProperty(qt,"__esModule",{value:!0})});var Dt=s(b=>{"use strict";Object.defineProperty(b,"__esModule",{value:!0});b.Optional=b.IOptionalEmptyError=b.isOptional=b.IOptionalTag=void 0;var Ge=u();b.IOptionalTag="IOptional";var ei=r=>(0,Ge.isTagged)(r,b.IOptionalTag);b.isOptional=ei;var ye=class extends Error{};b.IOptionalEmptyError=ye;var It="O.Some",Ut="O.None",ie=r=>(0,Ge.isTagged)(r,Ut),At=r=>(0,Ge.isTagged)(r,It),Ve=class{_tag;constructor(e=b.IOptionalTag){this._tag=e}},$e=class r extends Ve{self;constructor(e){super(),this.self=e}move(e){return this.map(()=>e)}orSome(e){return ie(this.self)?r.from(e()):this}get(){if(ie(this.self))throw new ye("called get() on None optional");return this.self.value}filter(e){return ie(this.self)||!e(this.self.value)?r.none():r.some(this.self.value)}map(e){return ie(this.self)?r.none():r.from(e(this.self.value))}flatMap(e){return ie(this.self)?r.none():r.from(e(this.self.value)).orSome(()=>r.none()).get()}present(){return At(this.self)}*[Symbol.iterator](){At(this.self)&&(yield this.self.value)}static some(e){return new r({value:e,_tag:It})}static _none=new r({_tag:Ut});static none(){return this._none}static from(e){return e==null?r.none():r.some(e)}};b.Optional=$e});var Ht=s(c=>{"use strict";Object.defineProperty(c,"__esModule",{value:!0});c.Either=c.isRight=c.isLeft=c.isEither=c.IEitherTag=void 0;var J=u();c.IEitherTag="IEither";var ti=r=>(0,J.isTagged)(r,c.IEitherTag);c.isEither=ti;var Ct="E.Left",ri=r=>(0,J.isTagged)(r,Ct);c.isLeft=ri;var Bt="E.Right",ii=r=>(0,J.isTagged)(r,Bt);c.isRight=ii;var Ye=class{_tag;constructor(e=c.IEitherTag){this._tag=e}},Ke=class r extends Ye{self;constructor(e){super(),this.self=e}moveRight(e){return this.mapRight(()=>e)}mapBoth(e,t){return(0,c.isLeft)(this.self)?r.left(e(this.self.err)):r.right(t(this.self.ok))}mapRight(e){return(0,c.isRight)(this.self)?r.right(e(this.self.ok)):r.left(this.self.err)}mapLeft(e){return(0,c.isLeft)(this.self)?r.left(e(this.self.err)):r.right(this.self.ok)}flatMap(e){return(0,c.isRight)(this.self)?e(this.self.ok):r.left(this.self.err)}filter(e){return(0,c.isLeft)(this.self)?r.left(this.self.err):r.fromFailable(()=>this.right().filter(e).get())}async flatMapAsync(e){return(0,c.isLeft)(this.self)?Promise.resolve(r.left(this.self.err)):await e(this.self.ok).catch(t=>r.left(t))}fold(e,t){return(0,c.isLeft)(this.self)?e(this.self.err):t(this.self.ok)}left(){return(0,c.isLeft)(this.self)?J.Optional.from(this.self.err):J.Optional.none()}right(){return(0,c.isRight)(this.self)?J.Optional.from(this.self.ok):J.Optional.none()}joinRight(e,t){return this.flatMap(i=>e.mapRight(n=>t(n,i)))}joinRightAsync(e,t){return this.flatMapAsync(async i=>await(typeof e=="function"?e():e).then(a=>a.mapRight(o=>t(o,i))))}static left(e){return new r({err:e,_tag:Ct})}static right(e){return new r({ok:e,_tag:Bt})}static fromFailable(e){try{return r.right(e())}catch(t){return r.left(t)}}static async fromFailableAsync(e){return await(typeof e=="function"?e():e).then(t=>r.right(t)).catch(t=>r.left(t))}};c.Either=Ke});var xt=s(q=>{"use strict";var ni=q&&q.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),ze=q&&q.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&ni(e,r,t)};Object.defineProperty(q,"__esModule",{value:!0});ze(Nt(),q);ze(Dt(),q);ze(Ht(),q)});var Wt=s(ee=>{"use strict";Object.defineProperty(ee,"__esModule",{value:!0});ee.ListZipper=ee.Cons=void 0;var V=u(),ne=class r{value;next;constructor(e,t=V.Optional.none()){this.value=e,this.next=t}before(e){return new r(this.value,e)}replace(e){return new r(e,this.next)}*[Symbol.iterator](){for(let e=V.Optional.some(this);e.present();e=e.flatMap(t=>t.next))yield e.get().value}static addOnto(e,t){return Array.from(e).reverse().reduce((i,n)=>V.Optional.from(new r(n,i)),t)}static from(e){return r.addOnto(e,V.Optional.none())}};ee.Cons=ne;var Qe=class r{reversedPathToHead;currentHead;constructor(e,t){this.reversedPathToHead=e,this.currentHead=t}read(){return this.currentHead.map(({value:e})=>e)}next(){return this.currentHead.map(e=>new r(V.Optional.some(e.before(this.reversedPathToHead)),e.next))}previous(){return this.reversedPathToHead.map(e=>new r(e.next,V.Optional.some(e.before(this.currentHead))))}prependChunk(e){return new r(ne.addOnto(Array.from(e).reverse(),this.reversedPathToHead),this.currentHead)}prepend(e){return this.prependChunk([e])}remove(){let e=this.currentHead.flatMap(t=>t.next);return new r(this.reversedPathToHead,e)}replace(e){let t=this.currentHead.map(i=>i.replace(e));return new r(this.reversedPathToHead,t)}*[Symbol.iterator](){let e=this;for(let t=e.previous();t.present();t=t.flatMap(i=>i.previous()))e=t.get();e.currentHead.present()&&(yield*e.currentHead.get())}collection(){return Array.from(this)}static from(e){return new r(V.Optional.none(),ne.from(e))}};ee.ListZipper=Qe});var Ft=s($=>{"use strict";var si=$&&$.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),oi=$&&$.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&si(e,r,t)};Object.defineProperty($,"__esModule",{value:!0});oi(Wt(),$)});var Je=s(_=>{"use strict";var ai=_&&_.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),se=_&&_.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&ai(e,r,t)};Object.defineProperty(_,"__esModule",{value:!0});se(Rt(),_);se(jt(),_);se(Lt(),_);se(xt(),_);se(Ft(),_)});var Jt=s(Me=>{"use strict";Object.defineProperty(Me,"__esModule",{value:!0});Me.TraceableImpl=void 0;var Ze=class r{item;trace;constructor(e,t){this.item=e,this.trace=t}map(e){let t=e(this);return new r(t,this.trace)}coExtend(e){let t=e(this);return Array.from(t).map(i=>this.move(i))}flatMap(e){return e(this)}flatMapAsync(e){return new r(e(this).then(t=>t.get()),this.trace)}traceScope(e){return new r(this.get(),this.trace.traceScope(e(this)))}peek(e){return e(this),this}move(e){return this.map(()=>e)}bimap(e){let{item:t,trace:i}=e(this);return this.move(t).traceScope(()=>i)}get(){return this.item}};Me.TraceableImpl=Ze});var Vt=s(Te=>{"use strict";Object.defineProperty(Te,"__esModule",{value:!0});Te.EmittableMetric=void 0;var ci=we(),Xe=class{name;unit;constructor(e,t){this.name=e,this.unit=t}withValue(e){return{name:this.name,unit:this.unit,emissionTimestamp:Date.now(),value:e,_tag:ci.MetricValueTag}}};Te.EmittableMetric=Xe});var $t=s(te=>{"use strict";Object.defineProperty(te,"__esModule",{value:!0});te.ResultMetric=te.Metric=void 0;var oe=we(),ke=class{_tag;constructor(e=oe.IMetricTag){this._tag=e}},Se=class r extends ke{name;parent;count;time;static DELIM=".";constructor(e,t=void 0,i=new oe.EmittableMetric(r.join(e,"count"),oe.Unit.COUNT),n=new oe.EmittableMetric(r.join(e,"time"),oe.Unit.MILLISECONDS)){super(),this.name=e,this.parent=t,this.count=i,this.time=n}child(e){let t=r.join(this.name,e);return new r(t,this)}asResult(){return Ee.from(this)}static join(...e){return e.join(r.DELIM)}static fromName(e){return new r(e)}};te.Metric=Se;var Ee=class r extends Se{name;parent;failure;success;warn;constructor(e,t=void 0,i,n,a){super(e,t),this.name=e,this.parent=t,this.failure=i,this.success=n,this.warn=a}static from(e){let t=e.child("failure"),i=e.child("success"),n=e.child("warn");return new r(e.name,e.parent,t,i,n)}};te.ResultMetric=Ee});var Gt=s(re=>{"use strict";Object.defineProperty(re,"__esModule",{value:!0});re.MetricsTrace=re.isMetricsTraceSupplier=void 0;var G=u(),ui=r=>(0,G.isMetricValue)(r)||(0,G.isIMetric)(r)||Array.isArray(r)&&r.every(e=>(0,G.isMetricValue)(e)||(0,G.isIMetric)(e));re.isMetricsTraceSupplier=ui;var et=class r{metricConsumer;activeTraces;completedTraces;constructor(e,t=new Map,i=new Set){this.metricConsumer=e,this.activeTraces=t,this.completedTraces=i}traceScope(e){let t=Date.now(),i=(Array.isArray(e)?e:[e]).filter(G.isIMetric),n=new Map(i.map(a=>[a,t]));return new r(this.metricConsumer,n)}trace(e){if(!e||typeof e=="string")return this;let t=Date.now(),i=Array.isArray(e)?e:[e],n=i.filter(G.isMetricValue),a=i.filter(G.isIMetric),o=a.filter(f=>!this.activeTraces.has(f)),d=a.filter(f=>this.activeTraces.has(f)&&!this.completedTraces.has(f)),v=d.flatMap(f=>[f.count.withValue(1),f.time.withValue(t-this.activeTraces.get(f))]),h=[...n,...v];h.length>0&&this.metricConsumer(h);let k=new Map([...this.activeTraces,...o.map(f=>[f,t])]),B=new Set([...this.completedTraces,...d]);return new r(this.metricConsumer,k,B)}};re.MetricsTrace=et});var we=s(l=>{"use strict";var li=l&&l.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),tt=l&&l.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&li(e,r,t)};Object.defineProperty(l,"__esModule",{value:!0});l.isIMetric=l.IMetricTag=l.isMetricValue=l.MetricValueTag=l.Unit=void 0;var Kt=u(),Yt;(function(r){r.COUNT="COUNT",r.MILLISECONDS="MILLISECONDS"})(Yt||(l.Unit=Yt={}));l.MetricValueTag="MetricValue";var di=r=>(0,Kt.isTagged)(r,l.MetricValueTag);l.isMetricValue=di;l.IMetricTag="IMetric";var fi=r=>(0,Kt.isTagged)(r,l.IMetricTag);l.isIMetric=fi;tt(Vt(),l);tt($t(),l);tt(Gt(),l)});var zt=s(Pe=>{"use strict";Object.defineProperty(Pe,"__esModule",{value:!0});Pe.ANSI=void 0;Pe.ANSI={RESET:"\x1B[0m",BOLD:"\x1B[1m",DIM:"\x1B[2m",RED:"\x1B[31m",GREEN:"\x1B[32m",YELLOW:"\x1B[33m",BLUE:"\x1B[34m",MAGENTA:"\x1B[35m",CYAN:"\x1B[36m",WHITE:"\x1B[37m",BRIGHT_RED:"\x1B[91m",BRIGHT_YELLOW:"\x1B[93m",GRAY:"\x1B[90m"}});var Qt=s(N=>{"use strict";Object.defineProperty(N,"__esModule",{value:!0});N.isLogLevel=N.logLevelOrder=N.LogLevel=void 0;var Y;(function(r){r.UNKNOWN="UNKNOWN",r.INFO="INFO",r.WARN="WARN",r.DEBUG="DEBUG",r.ERROR="ERROR",r.SYS="SYS"})(Y||(N.LogLevel=Y={}));N.logLevelOrder=[Y.DEBUG,Y.INFO,Y.WARN,Y.ERROR,Y.SYS];var hi=r=>typeof r=="string"&&N.logLevelOrder.some(e=>e===r);N.isLogLevel=hi});var Xt=s(Zt=>{"use strict";Object.defineProperty(Zt,"__esModule",{value:!0})});var kt=s(Re=>{"use strict";Object.defineProperty(Re,"__esModule",{value:!0});Re.PrettyJsonConsoleLogger=void 0;var g=je(),rt=class{log(e,...t){let i=JSON.stringify({level:e,trace:t},null,4),n=`${this.getStyle(e)}${i}${g.ANSI.RESET} -`;this.getStream(e)(n)}getStream(e){return e===g.LogLevel.ERROR?console.error:console.log}getStyle(e){switch(e){case g.LogLevel.UNKNOWN:case g.LogLevel.INFO:return`${g.ANSI.MAGENTA}`;case g.LogLevel.DEBUG:return`${g.ANSI.CYAN}`;case g.LogLevel.WARN:return`${g.ANSI.BRIGHT_YELLOW}`;case g.LogLevel.ERROR:return`${g.ANSI.BRIGHT_RED}`;case g.LogLevel.SYS:return`${g.ANSI.DIM}${g.ANSI.BLUE}`}}};Re.PrettyJsonConsoleLogger=rt});var tr=s(Le=>{"use strict";Object.defineProperty(Le,"__esModule",{value:!0});Le.LogTrace=void 0;var er=u(),p=je(),it=class r{logger;traces;defaultLevel;allowedLevels;constructor(e=new p.PrettyJsonConsoleLogger,t=[gi],i=p.LogLevel.INFO,n=vi){this.logger=e,this.traces=t,this.defaultLevel=i,this.allowedLevels=n}traceScope(e){return new r(this.logger,this.traces.concat(e),this.defaultLevel,this.allowedLevels)}trace(e){let{traces:t,level:i}=this.foldTraces(this.traces.concat(e));if(!this.allowedLevels().has(i))return;let n=i===p.LogLevel.UNKNOWN?this.defaultLevel:i;this.logger.log(n,...t)}foldTraces(e){let t=e.map(o=>typeof o=="function"?o():o),i=t.filter(o=>(0,p.isLogLevel)(o)).reduce((o,d)=>Math.max(p.logLevelOrder.indexOf(d),o),-1),n=p.logLevelOrder[i]??p.LogLevel.UNKNOWN,a=t.filter(o=>!(0,p.isLogLevel)(o)).map(o=>typeof o=="object"?`TracedException.Name = ${o.name}, TracedException.Message = ${o.message}, TracedException.Stack = ${o.stack}`:o);return{level:n,traces:a}}};Le.LogTrace=it;var gi=()=>`TimeStamp = ${new Date().toISOString()}`,pi=(0,er.memoize)(r=>new Set([p.LogLevel.UNKNOWN,...r?[p.LogLevel.DEBUG]:[],p.LogLevel.INFO,p.LogLevel.WARN,p.LogLevel.ERROR,p.LogLevel.SYS])),vi=()=>pi((0,er.isDebug)())});var je=s(O=>{"use strict";var bi=O&&O.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),ae=O&&O.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&bi(e,r,t)};Object.defineProperty(O,"__esModule",{value:!0});ae(zt(),O);ae(Qt(),O);ae(Xt(),O);ae(kt(),O);ae(tr(),O)});var ir=s(P=>{"use strict";Object.defineProperty(P,"__esModule",{value:!0});P.LogMetricTraceable=P.LogMetricTrace=P.EmbeddedMetricsTraceable=P.LogTraceable=void 0;var A=ot(),ce=class r extends A.TraceableImpl{static LogTrace=new A.LogTrace;static of(e){return new r(e,r.LogTrace)}};P.LogTraceable=ce;var rr=r=>e=>{e.length!==0&&r.traceScope(A.LogLevel.SYS).trace(`Metrics = ${JSON.stringify(e)}`)},nt=class r extends A.TraceableImpl{static MetricsTrace=new A.MetricsTrace(rr(ce.LogTrace));static of(e,t=r.MetricsTrace){return new r(e,t)}};P.EmbeddedMetricsTraceable=nt;var qe=class r{logTrace;metricsTrace;constructor(e,t){this.logTrace=e,this.metricsTrace=t}traceScope(e){return(0,A.isMetricsTraceSupplier)(e)?new r(this.logTrace,this.metricsTrace.traceScope(e)):new r(this.logTrace.traceScope(e),this.metricsTrace)}trace(e){return(0,A.isMetricsTraceSupplier)(e)?(this.metricsTrace.trace(e),this):(this.logTrace.trace(e),this)}};P.LogMetricTrace=qe;var st=class r extends A.TraceableImpl{static ofLogTraceable(e){let t=new A.MetricsTrace(rr(e.trace));return new r(e.get(),new qe(e.trace,t))}static of(e){let t=ce.of(e);return r.ofLogTraceable(t)}};P.LogMetricTraceable=st});var nr=s(Ne=>{"use strict";Object.defineProperty(Ne,"__esModule",{value:!0});Ne.TraceUtil=void 0;var at=u(),ct=class r{static promiseify(e){return t=>t.flatMapAsync(async i=>i.move(await i.get()).map(e)).get()}static traceResultingEither(e,t=!1){return i=>(e&&i.trace.trace(i.get().fold(n=>t?e.warn:e.failure,n=>e.success)),i.traceScope(n=>n.get().fold(a=>t?at.LogLevel.WARN:at.LogLevel.ERROR,a=>at.LogLevel.INFO)))}static withTrace(e){return t=>t.traceScope(()=>e)}static withMetricTrace(e){return r.withTrace(e)}static withFunctionTrace(e){return r.withTrace(`fn.${e.name}`)}static withClassTrace(e){return r.withTrace(`class.${e.constructor.name}`)}};Ne.TraceUtil=ct});var ot=s(y=>{"use strict";var mi=y&&y.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),ue=y&&y.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&mi(e,r,t)};Object.defineProperty(y,"__esModule",{value:!0});ue(Jt(),y);ue(we(),y);ue(je(),y);ue(ir(),y);ue(nr(),y)});var sr=s(M=>{"use strict";Object.defineProperty(M,"__esModule",{value:!0});M.getStdoutMany=M.getStdout=M.CmdMetric=void 0;var H=u(),_i=require("node:child_process");M.CmdMetric=H.Metric.fromName("Exec").asResult();var Oi=(r,e={streamTraceable:[]})=>r.flatMap(H.TraceUtil.withFunctionTrace(M.getStdout)).flatMap(t=>t.traceScope(()=>`Command = ${t.get()}`)).map(t=>{let i=t.get(),n=typeof i=="string"?i:i.join(" "),a=e.clearEnv?e.env:{...process.env,...e.env};return H.Either.fromFailableAsync(new Promise((o,d)=>{let v=(0,_i.exec)(n,{env:a}),h="";v.stdout?.on("data",B=>{let f=B.toString();h+=f,e.streamTraceable?.includes("stdout")&&t.trace.trace(f)});let k="";v.stderr?.on("data",B=>{let f=B.toString();h+=f,e.streamTraceable?.includes("stderr")&&t.trace.trace(f)}),v.on("exit",B=>{B===0?o({stdout:h,stderr:k}):d(new Error(`exited with non-zero code: ${B}. ${k}`))})}))}).map(H.TraceUtil.promiseify(t=>t.get().mapRight(({stderr:i,stdout:n})=>(i&&t.trace.traceScope(H.LogLevel.DEBUG).trace(`StdErr = ${i}`),n)))).peek(H.TraceUtil.promiseify(H.TraceUtil.traceResultingEither(M.CmdMetric))).get();M.getStdout=Oi;var yi=(r,e={streamTraceable:[]})=>r.coExtend(t=>t.get()).reduce(async(t,i)=>(await t).joinRightAsync(()=>i.map(a=>(0,M.getStdout)(a,e)).get(),(a,o)=>o.concat(a)),Promise.resolve(H.Either.right([])));M.getStdoutMany=yi});var or=s(R=>{"use strict";Object.defineProperty(R,"__esModule",{value:!0});R.getRequiredEnvVars=R.getRequiredEnv=R.getEnv=void 0;var ut=u(),Mi=r=>ut.Optional.from(process.env[r]);R.getEnv=Mi;var Ti=r=>ut.Either.fromFailable(()=>(0,R.getEnv)(r).get()).mapLeft(()=>new Error(`environment variable "${r}" is required D:`));R.getRequiredEnv=Ti;var wi=r=>{let e=ut.Either.right({}),t=(i,n,a)=>({...i,[n]:a});return r.reduce((i,n)=>i.joinRight((0,R.getRequiredEnv)(n),(a,o)=>t(o,n,a)),e)};R.getRequiredEnvVars=wi});var cr=s(K=>{"use strict";Object.defineProperty(K,"__esModule",{value:!0});K.validateExecutionEntries=K.validateIdentifier=void 0;var ar=u(),Si=r=>/^[a-zA-Z0-9_\-:. \/]+$/.test(r)&&!r.includes("..");K.validateIdentifier=Si;var Ei=r=>{let e=Object.entries(r).filter(t=>!t.every(i=>typeof i=="string"&&(0,K.validateIdentifier)(i)));return e.length>0?ar.Either.left(e):ar.Either.right(r)};K.validateExecutionEntries=Ei});var ur=s(T=>{"use strict";Object.defineProperty(T,"__esModule",{value:!0});T.argv=T.getArg=T.isArgKey=void 0;var z=u(),Pi=r=>r.startsWith("--");T.isArgKey=Pi;var Ri=(r,e,t)=>{let i=z.Optional.from(e.findIndex(n=>(0,T.isArgKey)(n)&&n.split("=")[0]===r)).filter(n=>n>=0&&nz.Optional.from(e.at(n)).map(a=>a.includes("=")?a.split("=")[1]:e.at(n+1))).filter(n=>!(0,T.isArgKey)(n)).map(n=>t.present(n)).orSome(()=>t.unspecified).map(n=>z.Either.right(n)).get():z.Optional.from(t.absent).map(n=>z.Either.right(n)).orSome(()=>z.Either.left(new Error(`arg ${r} is not present in arguments list and does not have an 'absent' value`))).get()};T.getArg=Ri;var ji=(r,e,t=process.argv.slice(2))=>{let i={present:o=>o},n=o=>{let d=e?.[o]??i;return(0,T.getArg)(o,t,d).mapRight(v=>[o,v])};return r.map(n).reduce((o,d)=>o.flatMap(v=>d.mapRight(([h,k])=>({...v,[h]:k}))),z.Either.right({})).mapRight(o=>o)};T.argv=ji});var lr=s(j=>{"use strict";Object.defineProperty(j,"__esModule",{value:!0});j.Signals=j.SigTermMetric=j.SigIntMetric=void 0;var I=u();j.SigIntMetric=I.Metric.fromName("SigInt").asResult();j.SigTermMetric=I.Metric.fromName("SigTerm").asResult();var lt=class{static async awaitClose(e){let t=I.Either.right(void 0);return new Promise(i=>{let n=d=>v=>e.flatMap(I.TraceUtil.withMetricTrace(d)).peek(h=>h.trace.trace("closing")).move(I.Optional.from(v).map(h=>I.Either.left(h)).orSome(()=>t).get()).flatMap(I.TraceUtil.traceResultingEither(d)).map(h=>i(h.get())).peek(h=>h.trace.trace("finished")).get(),a=n(j.SigIntMetric),o=n(j.SigTermMetric);process.on("SIGINT",()=>e.flatMap(I.TraceUtil.withTrace("SIGINT")).get().close(a)),process.on("SIGTERM",()=>e.flatMap(I.TraceUtil.withTrace("SIGTERM")).get().close(o))})}};j.Signals=lt});var dr=s(w=>{"use strict";var Li=w&&w.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),le=w&&w.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&Li(e,r,t)};Object.defineProperty(w,"__esModule",{value:!0});le(sr(),w);le(or(),w);le(cr(),w);le(ur(),w);le(lr(),w)});var hr=s(fr=>{"use strict";Object.defineProperty(fr,"__esModule",{value:!0})});var gr=s(Ae=>{"use strict";Object.defineProperty(Ae,"__esModule",{value:!0});Ae.HttpStatusCodes=void 0;Ae.HttpStatusCodes={100:"Continue",101:"Switching Protocols",102:"Processing (WebDAV)",200:"OK",201:"Created",202:"Accepted",203:"Non-Authoritative Information",204:"No Content",205:"Reset Content",206:"Partial Content",207:"Multi-Status (WebDAV)",208:"Already Reported (WebDAV)",226:"IM Used",300:"Multiple Choices",301:"Moved Permanently",302:"Found",303:"See Other",304:"Not Modified",305:"Use Proxy",306:"(Unused)",307:"Temporary Redirect",308:"Permanent Redirect (experimental)",400:"Bad Request",401:"Unauthorized",402:"Payment Required",403:"Forbidden",404:"Not Found",405:"Method Not Allowed",406:"Not Acceptable",407:"Proxy Authentication Required",408:"Request Timeout",409:"Conflict",410:"Gone",411:"Length Required",412:"Precondition Failed",413:"Request Entity Too Large",414:"Request-URI Too Long",415:"Unsupported Media Type",416:"Requested Range Not Satisfiable",417:"Expectation Failed",418:"I'm a teapot (RFC 2324)",420:"Enhance Your Calm (Twitter)",422:"Unprocessable Entity (WebDAV)",423:"Locked (WebDAV)",424:"Failed Dependency (WebDAV)",425:"Reserved for WebDAV",426:"Upgrade Required",428:"Precondition Required",429:"Too Many Requests",431:"Request Header Fields Too Large",444:"No Response (Nginx)",449:"Retry With (Microsoft)",450:"Blocked by Windows Parental Controls (Microsoft)",451:"Unavailable For Legal Reasons",499:"Client Closed Request (Nginx)",500:"Internal Server Error",501:"Not Implemented",502:"Bad Gateway",503:"Service Unavailable",504:"Gateway Timeout",505:"HTTP Version Not Supported",506:"Variant Also Negotiates (Experimental)",507:"Insufficient Storage (WebDAV)",508:"Loop Detected (WebDAV)",509:"Bandwidth Limit Exceeded (Apache)",510:"Not Extended",511:"Network Authentication Required",598:"Network read timeout error",599:"Network connect timeout error"}});var vr=s(pr=>{"use strict";Object.defineProperty(pr,"__esModule",{value:!0})});var br=s(U=>{"use strict";var qi=U&&U.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),dt=U&&U.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&qi(e,r,t)};Object.defineProperty(U,"__esModule",{value:!0});dt(hr(),U);dt(gr(),U);dt(vr(),U)});var mr=s(D=>{"use strict";Object.defineProperty(D,"__esModule",{value:!0});D.JsonResponse=D.PenguenoResponse=D.getResponseMetrics=void 0;var de=u(),Ni=(r,e)=>{let t={...r.getResponseHeaders(),...e};return t["Content-Type"]=(t["Content-Type"]??"text/plain")+"; charset=utf-8",t},Ai=[0,1,2,3,4,5].map(r=>de.Metric.fromName(`response.${r}xx`).asResult()),Ii=(r,e)=>{let t=Math.floor(r/100);return Ai.flatMap((i,n)=>de.Optional.from(n).filter(a=>a===t).map(()=>[i.count.withValue(1)]).flatMap(a=>de.Optional.from(e).map(o=>a.concat(i.time.withValue(o))).orSome(()=>a)).orSome(()=>[i.count.withValue(0)]).get())};D.getResponseMetrics=Ii;var Ie=class{_body;statusText;status;headers;constructor(e,t,i){this._body=t,this.headers=Ni(e.get(),i?.headers??{}),this.status=i.status,this.statusText=i.statusText??de.HttpStatusCodes[this.status],e.trace.trace((0,D.getResponseMetrics)(i.status,e.get().elapsedTimeMs()))}body(){return this._body}};D.PenguenoResponse=Ie;var ft=class extends Ie{constructor(e,t,i){let n={...i,headers:{...i.headers,"Content-Type":"application/json"}};if((0,de.isEither)(t)){super(e,JSON.stringify(t.fold(a=>({error:a,ok:void 0}),a=>({ok:a}))),n);return}super(e,JSON.stringify(Math.floor(n.status/100)>4?{error:t}:{ok:t}),n)}};D.JsonResponse=ft});var _r=s(Q=>{"use strict";var Ui=Q&&Q.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),Di=Q&&Q.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&Ui(e,r,t)};Object.defineProperty(Q,"__esModule",{value:!0});Di(mr(),Q)});var yr=s(Ue=>{"use strict";Object.defineProperty(Ue,"__esModule",{value:!0});Ue.PenguenoRequest=void 0;var Or=["hewwo :D","hiya cutie","boop!","sending virtual hugs!","stay pawsitive"],Ci=()=>Or[Math.floor(Math.random()*Or.length)],ht=class r{req;id;at;constructor(e,t,i){this.req=e,this.id=t,this.at=i}elapsedTimeMs(e=()=>Date.now()){return e()-this.at.getTime()}getResponseHeaders(){let e=this.id,t=this.at.getTime(),i=Date.now(),n=this.elapsedTimeMs(()=>i),a=Ci();return Object.entries({RequestId:e,RequestReceivedUnix:t,RequestHandleUnix:i,DeltaUnix:n,Hai:a}).reduce((o,[d,v])=>({...o,[d]:v.toString()}),{})}static from(e){let t=crypto.randomUUID();return e.bimap(i=>{let n=i.get(),a=new URL(n.url),{pathname:o}=a,d=`RequestId = ${t}, Method = ${n.method}, Path = ${o}`;return{item:new r(n,t,new Date),trace:d}})}};Ue.PenguenoRequest=ht});var Mr=s(Z=>{"use strict";var Bi=Z&&Z.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),Hi=Z&&Z.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&Bi(e,r,t)};Object.defineProperty(Z,"__esModule",{value:!0});Hi(yr(),Z)});var Sr=s(x=>{"use strict";Object.defineProperty(x,"__esModule",{value:!0});x.HealthCheckActivityImpl=x.HealthCheckOutput=x.HealthCheckInput=void 0;var X=u(),gt;(function(r){r[r.CHECK=0]="CHECK"})(gt||(x.HealthCheckInput=gt={}));var Tr;(function(r){r[r.YAASSSLAYQUEEN=0]="YAASSSLAYQUEEN"})(Tr||(x.HealthCheckOutput=Tr={}));var wr=X.Metric.fromName("Health").asResult(),pt=class{check;constructor(e){this.check=e}checkHealth(e){return e.flatMap(X.TraceUtil.withFunctionTrace(this.checkHealth)).flatMap(X.TraceUtil.withMetricTrace(wr)).flatMap(t=>t.move(gt.CHECK).map(i=>this.check(i))).peek(X.TraceUtil.promiseify(X.TraceUtil.traceResultingEither(wr))).map(X.TraceUtil.promiseify(t=>{let{status:i,message:n}=t.get().fold(()=>({status:500,message:"err"}),()=>({status:200,message:"ok"}));return new X.JsonResponse(e,n,{status:i})})).get()}};x.HealthCheckActivityImpl=pt});var Pr=s(De=>{"use strict";Object.defineProperty(De,"__esModule",{value:!0});De.FourOhFourActivityImpl=void 0;var xi=u(),Er=["D: meow-t found! your api call ran away!","404-bidden! but like...in a cute way >:3 !",":< your data went on a paw-sible vacation!","uwu~ not found, but found our hearts instead!"],Wi=()=>Er[Math.floor(Math.random()*Er.length)],vt=class{fourOhFour(e){return e.move(new xi.JsonResponse(e,Wi(),{status:404})).map(t=>Promise.resolve(t.get())).get()}};De.FourOhFourActivityImpl=vt});var jr=s(W=>{"use strict";var Fi=W&&W.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),Rr=W&&W.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&Fi(e,r,t)};Object.defineProperty(W,"__esModule",{value:!0});Rr(Sr(),W);Rr(Pr(),W)});var Lr=s(he=>{"use strict";Object.defineProperty(he,"__esModule",{value:!0});he.requireMethod=void 0;var fe=u(),Ji=r=>e=>e.flatMap(fe.TraceUtil.withFunctionTrace(he.requireMethod)).map(t=>{let{req:{method:i}}=t.get();if(!r.includes(i)){let n="that's not how you pet me (\u22DF\uFE4F\u22DE)~";return t.trace.traceScope(fe.LogLevel.WARN).trace(n),fe.Either.left(new fe.PenguenoError(n,405))}return fe.Either.right(i)}).get();he.requireMethod=Ji});var Nr=s(ge=>{"use strict";Object.defineProperty(ge,"__esModule",{value:!0});ge.jsonModel=void 0;var C=u(),qr=C.Metric.fromName("JsonParse").asResult(),Vi=r=>e=>e.flatMap(C.TraceUtil.withFunctionTrace(ge.jsonModel)).flatMap(C.TraceUtil.withMetricTrace(qr)).map(t=>C.Either.fromFailableAsync(t.get().req.json()).then(i=>i.mapLeft(n=>(t.trace.traceScope(C.LogLevel.WARN).trace(n),new C.PenguenoError("seems to be invalid JSON (>//<) can you fix?",400))))).flatMapAsync(C.TraceUtil.promiseify(C.TraceUtil.traceResultingEither(qr))).map(C.TraceUtil.promiseify(t=>t.get().mapRight(i=>t.move(i)).flatMap(r))).get();ge.jsonModel=Vi});var Ir=s(m=>{"use strict";var $i=m&&m.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),Ar=m&&m.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&$i(e,r,t)};Object.defineProperty(m,"__esModule",{value:!0});m.PenguenoError=m.ErrorSource=void 0;var Kn=u(),Ce;(function(r){r.USER="WARN",r.SYSTEM="ERROR"})(Ce||(m.ErrorSource=Ce={}));var bt=class extends Error{message;status;source;constructor(e,t){super(e),this.message=e,this.status=t,this.source=Math.floor(t/100)===4?Ce.USER:Ce.SYSTEM}};m.PenguenoError=bt;Ar(Lr(),m);Ar(Nr(),m)});var Ur=s(S=>{"use strict";var Gi=S&&S.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),pe=S&&S.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&Gi(e,r,t)};Object.defineProperty(S,"__esModule",{value:!0});pe(br(),S);pe(_r(),S);pe(Mr(),S);pe(jr(),S);pe(Ir(),S)});var u=s(E=>{"use strict";var Yi=E&&E.__createBinding||(Object.create?function(r,e,t,i){i===void 0&&(i=t);var n=Object.getOwnPropertyDescriptor(e,t);(!n||("get"in n?!e.__esModule:n.writable||n.configurable))&&(n={enumerable:!0,get:function(){return e[t]}}),Object.defineProperty(r,i,n)}:function(r,e,t,i){i===void 0&&(i=t),r[i]=e[t]}),ve=E&&E.__exportStar||function(r,e){for(var t in r)t!=="default"&&!Object.prototype.hasOwnProperty.call(e,t)&&Yi(e,r,t)};Object.defineProperty(E,"__esModule",{value:!0});ve(Et(),E);ve(Je(),E);ve(ot(),E);ve(dr(),E);ve(Ur(),E)});var mt=We(u(),1),Ki=["fetch_code","ci_pipeline","build_docker_image.js","ansible_playbook.js","checkout_ci.js","npm_publish.js"],zi=r=>typeof r=="string"&&Ki.includes(r),Dr=r=>!!((0,mt.isObject)(r)&&"arguments"in r&&(0,mt.isObject)(r.arguments)&&"type"in r&&zi(r.type)&&r);var Ot=We(u(),1);var _t=class{stages=[];addStage(e){return this.stages.push(e),this}build(){return new He(this.stages)}},Be=class extends _t{remoteUrl;refname;constructor(e=process.env.remote,t=process.env.rev,i=process.env.refname){super(),this.remoteUrl=e,this.refname=i,this.addStage({parallelJobs:[{type:"fetch_code",arguments:{remoteUrl:e,checkout:t,path:this.getSourceDestination()}}]})}getSourceDestination(){return this.remoteUrl.replace(".git","").split("/").at(-1)??"src"}getBranch(){return this.refname.split("refs/heads/").at(1)}};var xe=We(u(),1);var He=class r{serialJobs;constructor(e){this.serialJobs=e}serialize(){return JSON.stringify({serialJobs:this.serialJobs})}static from(e){return xe.Either.fromFailable(()=>JSON.parse(e)).flatMap(t=>Cr(t)?xe.Either.right(t):xe.Either.left(new Error("oh noes D: its a bad pipewine :(("))).mapRight(t=>new r(t.serialJobs))}};var Qi=r=>(0,Ot.isObject)(r)&&"parallelJobs"in r&&Array.isArray(r.parallelJobs)&&r.parallelJobs.every(e=>Dr(e)),Cr=r=>(0,Ot.isObject)(r)&&"serialJobs"in r&&Array.isArray(r.serialJobs)&&r.serialJobs.every(e=>Qi(e));var Zi=()=>{let r=new Be,e=r.getBranch();if(!e||e!=="release")return r.build();let t={type:"npm_publish.js",arguments:{source:"pengueno",registry:"registry.npmjs.org"}};return r.addStage({parallelJobs:[t]}),r.build()},Xi=()=>{let r=Zi().serialize();process.stdout.write(r)};Xi(); +"use strict";var li=Object.create;var Zr=Object.defineProperty;var pi=Object.getOwnPropertyDescriptor;var fi=Object.getOwnPropertyNames;var hi=Object.getPrototypeOf,di=Object.prototype.hasOwnProperty;var p=(t,e)=>()=>(e||t((e={exports:{}}).exports,e),e.exports);var _i=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of fi(e))!di.call(t,s)&&s!==r&&Zr(t,s,{get:()=>e[s],enumerable:!(n=pi(e,s))||n.enumerable});return t};var Mt=(t,e,r)=>(r=t!=null?li(hi(t)):{},_i(e||!t||!t.__esModule?Zr(r,"default",{value:t,enumerable:!0}):r,t));var es=p(Ke=>{"use strict";Object.defineProperty(Ke,"__esModule",{value:!0});Ke.prependWith=void 0;var gi=(t,e)=>Array(t.length*2).fill(0).map((r,n)=>n%2===0).map((r,n)=>r?e:t[Math.floor(n/2)]);Ke.prependWith=gi});var rs=p(te=>{"use strict";Object.defineProperty(te,"__esModule",{value:!0});te.isDebug=te.isProd=void 0;var ts=!0,vi=ts&&(process.env.ENVIRONMENT??"").toLowerCase().includes("prod")?"production":"development",yi=()=>vi==="production";te.isProd=yi;var bi=!(0,te.isProd)()||ts&&["y","t"].some((process.env.DEBUG??"").toLowerCase().startsWith),Oi=()=>bi;te.isDebug=Oi});var ss=p(Ye=>{"use strict";Object.defineProperty(Ye,"__esModule",{value:!0});Ye.memoize=void 0;var mi=t=>{let e=new Map;return(...r)=>{let n=JSON.stringify(r);if(e.has(n))return e.get(n);let s=t(...r);return e.set(n,s),s}};Ye.memoize=mi});var ns=p(B=>{"use strict";var wi=B&&B.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),Rt=B&&B.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&wi(e,t,r)};Object.defineProperty(B,"__esModule",{value:!0});Rt(es(),B);Rt(rs(),B);Rt(ss(),B)});var is=p(os=>{"use strict";Object.defineProperty(os,"__esModule",{value:!0})});var as=p(ze=>{"use strict";Object.defineProperty(ze,"__esModule",{value:!0});ze.isObject=void 0;var Pi=t=>typeof t=="object"&&!Array.isArray(t)&&!!t;ze.isObject=Pi});var cs=p(ke=>{"use strict";Object.defineProperty(ke,"__esModule",{value:!0});ke.isTagged=void 0;var Ei=jt(),Mi=(t,e)=>!!((0,Ei.isObject)(t)&&"_tag"in t&&t._tag===e);ke.isTagged=Mi});var ls=p(us=>{"use strict";Object.defineProperty(us,"__esModule",{value:!0})});var ds=p(M=>{"use strict";Object.defineProperty(M,"__esModule",{value:!0});M.Optional=M.IOptionalEmptyError=M.isOptional=M.IOptionalTag=void 0;var At=v();M.IOptionalTag="IOptional";var Ri=t=>(0,At.isTagged)(t,M.IOptionalTag);M.isOptional=Ri;var Qe=class extends Error{};M.IOptionalEmptyError=Qe;var fs="O.Some",hs="O.None",Re=t=>(0,At.isTagged)(t,hs),ps=t=>(0,At.isTagged)(t,fs),St=class{_tag;constructor(e=M.IOptionalTag){this._tag=e}},Tt=class t extends St{self;constructor(e){super(),this.self=e}move(e){return this.map(()=>e)}orSome(e){return Re(this.self)?t.from(e()):this}get(){if(Re(this.self))throw new Qe("called get() on None optional");return this.self.value}filter(e){return Re(this.self)||!e(this.self.value)?t.none():t.some(this.self.value)}map(e){return Re(this.self)?t.none():t.from(e(this.self.value))}flatMap(e){return Re(this.self)?t.none():t.from(e(this.self.value)).orSome(()=>t.none()).get()}present(){return ps(this.self)}*[Symbol.iterator](){ps(this.self)&&(yield this.self.value)}static some(e){return new t({value:e,_tag:fs})}static _none=new t({_tag:hs});static none(){return this._none}static from(e){return e==null?t.none():t.some(e)}};M.Optional=Tt});var vs=p(g=>{"use strict";Object.defineProperty(g,"__esModule",{value:!0});g.Either=g.isRight=g.isLeft=g.isEither=g.IEitherTag=void 0;var re=v();g.IEitherTag="IEither";var ji=t=>(0,re.isTagged)(t,g.IEitherTag);g.isEither=ji;var _s="E.Left",Si=t=>(0,re.isTagged)(t,_s);g.isLeft=Si;var gs="E.Right",Ti=t=>(0,re.isTagged)(t,gs);g.isRight=Ti;var Lt=class{_tag;constructor(e=g.IEitherTag){this._tag=e}},xt=class t extends Lt{self;constructor(e){super(),this.self=e}moveRight(e){return this.mapRight(()=>e)}mapBoth(e,r){return(0,g.isLeft)(this.self)?t.left(e(this.self.err)):t.right(r(this.self.ok))}mapRight(e){return(0,g.isRight)(this.self)?t.right(e(this.self.ok)):t.left(this.self.err)}mapLeft(e){return(0,g.isLeft)(this.self)?t.left(e(this.self.err)):t.right(this.self.ok)}flatMap(e){return(0,g.isRight)(this.self)?e(this.self.ok):t.left(this.self.err)}filter(e){return(0,g.isLeft)(this.self)?t.left(this.self.err):t.fromFailable(()=>this.right().filter(e).get())}async flatMapAsync(e){return(0,g.isLeft)(this.self)?Promise.resolve(t.left(this.self.err)):await e(this.self.ok).catch(r=>t.left(r))}fold(e,r){return(0,g.isLeft)(this.self)?e(this.self.err):r(this.self.ok)}left(){return(0,g.isLeft)(this.self)?re.Optional.from(this.self.err):re.Optional.none()}right(){return(0,g.isRight)(this.self)?re.Optional.from(this.self.ok):re.Optional.none()}joinRight(e,r){return this.flatMap(n=>e.mapRight(s=>r(s,n)))}joinRightAsync(e,r){return this.flatMapAsync(async n=>await(typeof e=="function"?e():e).then(o=>o.mapRight(i=>r(i,n))))}swap(){return(0,g.isRight)(this.self)?t.left(this.self.ok):t.right(this.self.err)}static left(e){return new t({err:e,_tag:_s})}static right(e){return new t({ok:e,_tag:gs})}static fromFailable(e){try{return t.right(e())}catch(r){return t.left(r)}}static async fromFailableAsync(e){return await(typeof e=="function"?e():e).then(r=>t.right(r)).catch(r=>t.left(r))}static async retrying(e,r=3,n=s=>t.attemptWait(s)){let s=t.right(new Error("No attempts made"));for(let o=0;oa.swap());s=await s.joinRightAsync(()=>Promise.resolve(i),(a,u)=>a)}return s.swap()}static attemptWait(e,r=500,n=300,s=1.3){if(e===0)return Promise.resolve();let o=Math.pow(s,e)*r+n*Math.random()*Math.pow(s,e);return new Promise(i=>setTimeout(i,o))}};g.Either=xt});var ys=p($=>{"use strict";var Ai=$&&$.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),Nt=$&&$.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&Ai(e,t,r)};Object.defineProperty($,"__esModule",{value:!0});Nt(ls(),$);Nt(ds(),$);Nt(vs(),$)});var bs=p(de=>{"use strict";Object.defineProperty(de,"__esModule",{value:!0});de.ListZipper=de.Cons=void 0;var se=v(),je=class t{value;next;constructor(e,r=se.Optional.none()){this.value=e,this.next=r}before(e){return new t(this.value,e)}replace(e){return new t(e,this.next)}*[Symbol.iterator](){for(let e=se.Optional.some(this);e.present();e=e.flatMap(r=>r.next))yield e.get().value}static addOnto(e,r){return Array.from(e).reverse().reduce((n,s)=>se.Optional.from(new t(s,n)),r)}static from(e){return t.addOnto(e,se.Optional.none())}};de.Cons=je;var qt=class t{reversedPathToHead;currentHead;constructor(e,r){this.reversedPathToHead=e,this.currentHead=r}read(){return this.currentHead.map(({value:e})=>e)}next(){return this.currentHead.map(e=>new t(se.Optional.some(e.before(this.reversedPathToHead)),e.next))}previous(){return this.reversedPathToHead.map(e=>new t(e.next,se.Optional.some(e.before(this.currentHead))))}prependChunk(e){return new t(je.addOnto(Array.from(e).reverse(),this.reversedPathToHead),this.currentHead)}prepend(e){return this.prependChunk([e])}remove(){let e=this.currentHead.flatMap(r=>r.next);return new t(this.reversedPathToHead,e)}replace(e){let r=this.currentHead.map(n=>n.replace(e));return new t(this.reversedPathToHead,r)}*[Symbol.iterator](){let e=this;for(let r=e.previous();r.present();r=r.flatMap(n=>n.previous()))e=r.get();e.currentHead.present()&&(yield*e.currentHead.get())}collection(){return Array.from(this)}static from(e){return new t(se.Optional.none(),je.from(e))}};de.ListZipper=qt});var Os=p(_e=>{"use strict";Object.defineProperty(_e,"__esModule",{value:!0});_e.JSONHashMap=_e.JSONSet=void 0;var Dt=class{items;constructor(e=new Set){this.items=e}add(e){let r=JSON.stringify(e,Object.keys(e).sort());this.items.add(r)}has(e){let r=JSON.stringify(e,Object.keys(e).sort());return this.items.has(r)}delete(e){let r=JSON.stringify(e,Object.keys(e).sort());return this.items.delete(r)}clear(){this.items.clear()}size(){return this.items.size}};_e.JSONSet=Dt;var Ct=class{map;constructor(e=new Map){this.map=e}set(e,r){let n=JSON.stringify(e,Object.keys(e).sort());this.map.set(n,r)}get(e){let r=JSON.stringify(e,Object.keys(e).sort());return this.map.get(r)}has(e){let r=JSON.stringify(e,Object.keys(e).sort());return this.map.has(r)}keys(){return Array.from(this.map.keys()).map(e=>JSON.parse(e))}delete(e){let r=JSON.stringify(e,Object.keys(e).sort());return this.map.delete(r)}clear(){this.map.clear()}size(){return this.map.size}};_e.JSONHashMap=Ct});var ws=p(k=>{"use strict";var Li=k&&k.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),ms=k&&k.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&Li(e,t,r)};Object.defineProperty(k,"__esModule",{value:!0});ms(bs(),k);ms(Os(),k)});var jt=p(S=>{"use strict";var xi=S&&S.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),Se=S&&S.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&xi(e,t,r)};Object.defineProperty(S,"__esModule",{value:!0});Se(is(),S);Se(as(),S);Se(cs(),S);Se(ys(),S);Se(ws(),S)});var Ps=p(Xe=>{"use strict";Object.defineProperty(Xe,"__esModule",{value:!0});Xe.TraceableImpl=void 0;var Ht=class t{item;trace;constructor(e,r){this.item=e,this.trace=r}map(e){let r=e(this);return new t(r,this.trace)}coExtend(e){let r=e(this);return Array.from(r).map(n=>this.move(n))}flatMap(e){return e(this)}flatMapAsync(e){return new t(e(this).then(r=>r.get()),this.trace)}traceScope(e){return new t(this.get(),this.trace.traceScope(e(this)))}peek(e){return e(this),this}move(e){return this.map(()=>e)}bimap(e){let{item:r,trace:n}=e(this);return this.move(r).traceScope(()=>n)}get(){return this.item}};Xe.TraceableImpl=Ht});var Es=p(Ze=>{"use strict";Object.defineProperty(Ze,"__esModule",{value:!0});Ze.EmittableMetric=void 0;var Ni=et(),It=class{name;unit;constructor(e,r){this.name=e,this.unit=r}withValue(e){return{name:this.name,unit:this.unit,emissionTimestamp:Date.now(),value:e,_tag:Ni.MetricValueTag}}};Ze.EmittableMetric=It});var Ms=p(ge=>{"use strict";Object.defineProperty(ge,"__esModule",{value:!0});ge.ResultMetric=ge.Metric=void 0;var Te=et(),Ut=class{_tag;constructor(e=Te.IMetricTag){this._tag=e}},tt=class t extends Ut{name;parent;count;time;static DELIM=".";constructor(e,r=void 0,n=new Te.EmittableMetric(t.join(e,"count"),Te.Unit.COUNT),s=new Te.EmittableMetric(t.join(e,"time"),Te.Unit.MILLISECONDS)){super(),this.name=e,this.parent=r,this.count=n,this.time=s}child(e){let r=t.join(this.name,e);return new t(r,this)}asResult(){return rt.from(this)}static join(...e){return e.join(t.DELIM)}static fromName(e){return new t(e)}};ge.Metric=tt;var rt=class t extends tt{name;parent;failure;success;warn;constructor(e,r=void 0,n,s,o){super(e,r),this.name=e,this.parent=r,this.failure=n,this.success=s,this.warn=o}static from(e){let r=e.child("failure"),n=e.child("success"),s=e.child("warn");return new t(e.name,e.parent,r,n,s)}};ge.ResultMetric=rt});var Rs=p(ve=>{"use strict";Object.defineProperty(ve,"__esModule",{value:!0});ve.MetricsTrace=ve.isMetricsTraceSupplier=void 0;var ne=v(),qi=t=>(0,ne.isMetricValue)(t)||(0,ne.isIMetric)(t)||Array.isArray(t)&&t.every(e=>(0,ne.isMetricValue)(e)||(0,ne.isIMetric)(e));ve.isMetricsTraceSupplier=qi;var Bt=class t{metricConsumer;activeTraces;completedTraces;constructor(e,r=new Map,n=new Set){this.metricConsumer=e,this.activeTraces=r,this.completedTraces=n}traceScope(e){let r=Date.now(),n=(Array.isArray(e)?e:[e]).filter(ne.isIMetric),s=new Map(n.map(o=>[o.name,r]));return new t(this.metricConsumer,s,this.completedTraces)}trace(e){if(!e||typeof e=="string")return this;let r=Date.now(),n=Array.isArray(e)?e:[e],s=n.filter(ne.isMetricValue),o=n.filter(ne.isIMetric),i=o.filter(d=>!this.activeTraces.has(d.name)),a=o.filter(d=>this.activeTraces.has(d.name)&&!this.completedTraces.has(d.name)),u=a.flatMap(d=>[d.count.withValue(1),d.time.withValue(r-this.activeTraces.get(d.name))]),c=i.filter(d=>{let _=d.parent;return _&&this.activeTraces.has(_.name)}),l=c.flatMap(d=>{let _=this.activeTraces.get(d.parent.name);return[d.count.withValue(1),d.time.withValue(r-_)]}),f=[...s,...u,...l];f.length>0&&this.metricConsumer(f);let h=new Map([...this.activeTraces,...i.map(d=>[d.name,r])]),b=new Set([...this.completedTraces,...a.map(d=>d.name),...c.map(d=>d.name)]);return new t(this.metricConsumer,h,b)}};ve.MetricsTrace=Bt});var et=p(y=>{"use strict";var Di=y&&y.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),$t=y&&y.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&Di(e,t,r)};Object.defineProperty(y,"__esModule",{value:!0});y.isIMetric=y.IMetricTag=y.isMetricValue=y.MetricValueTag=y.Unit=void 0;var Ss=v(),js;(function(t){t.COUNT="COUNT",t.MILLISECONDS="MILLISECONDS"})(js||(y.Unit=js={}));y.MetricValueTag="MetricValue";var Ci=t=>(0,Ss.isTagged)(t,y.MetricValueTag);y.isMetricValue=Ci;y.IMetricTag="IMetric";var Hi=t=>(0,Ss.isTagged)(t,y.IMetricTag);y.isIMetric=Hi;$t(Es(),y);$t(Ms(),y);$t(Rs(),y)});var Ts=p(st=>{"use strict";Object.defineProperty(st,"__esModule",{value:!0});st.ANSI=void 0;st.ANSI={RESET:"\x1B[0m",BOLD:"\x1B[1m",DIM:"\x1B[2m",RED:"\x1B[31m",GREEN:"\x1B[32m",YELLOW:"\x1B[33m",BLUE:"\x1B[34m",MAGENTA:"\x1B[35m",CYAN:"\x1B[36m",WHITE:"\x1B[37m",BRIGHT_RED:"\x1B[91m",BRIGHT_YELLOW:"\x1B[93m",GRAY:"\x1B[90m"}});var As=p(J=>{"use strict";Object.defineProperty(J,"__esModule",{value:!0});J.isLogLevel=J.logLevelOrder=J.LogLevel=void 0;var oe;(function(t){t.UNKNOWN="UNKNOWN",t.INFO="INFO",t.WARN="WARN",t.DEBUG="DEBUG",t.ERROR="ERROR",t.SYS="SYS"})(oe||(J.LogLevel=oe={}));J.logLevelOrder=[oe.DEBUG,oe.INFO,oe.WARN,oe.ERROR,oe.SYS];var Ii=t=>typeof t=="string"&&J.logLevelOrder.some(e=>e===t);J.isLogLevel=Ii});var xs=p(Ls=>{"use strict";Object.defineProperty(Ls,"__esModule",{value:!0})});var Ns=p(nt=>{"use strict";Object.defineProperty(nt,"__esModule",{value:!0});nt.PrettyJsonConsoleLogger=void 0;var w=ot(),Jt=class{log(e,...r){let n=JSON.stringify({level:e,trace:r},null,4),s=`${this.getStyle(e)}${n}${w.ANSI.RESET} +`;this.getStream(e)(s)}getStream(e){return e===w.LogLevel.ERROR?console.error:console.log}getStyle(e){switch(e){case w.LogLevel.UNKNOWN:case w.LogLevel.INFO:return`${w.ANSI.MAGENTA}`;case w.LogLevel.DEBUG:return`${w.ANSI.CYAN}`;case w.LogLevel.WARN:return`${w.ANSI.BRIGHT_YELLOW}`;case w.LogLevel.ERROR:return`${w.ANSI.BRIGHT_RED}`;case w.LogLevel.SYS:return`${w.ANSI.DIM}${w.ANSI.BLUE}`}}};nt.PrettyJsonConsoleLogger=Jt});var Ds=p(it=>{"use strict";Object.defineProperty(it,"__esModule",{value:!0});it.LogTrace=void 0;var qs=v(),P=ot(),Ft=class t{logger;traces;defaultLevel;allowedLevels;constructor(e=new P.PrettyJsonConsoleLogger,r=[Ui],n=P.LogLevel.INFO,s=$i){this.logger=e,this.traces=r,this.defaultLevel=n,this.allowedLevels=s}traceScope(e){return new t(this.logger,this.traces.concat(e),this.defaultLevel,this.allowedLevels)}trace(e){let{traces:r,level:n}=this.foldTraces(this.traces.concat(e));if(!this.allowedLevels().has(n))return;let s=n===P.LogLevel.UNKNOWN?this.defaultLevel:n;this.logger.log(s,...r)}foldTraces(e){let r=e.map(i=>typeof i=="function"?i():i),n=r.filter(i=>(0,P.isLogLevel)(i)).reduce((i,a)=>Math.max(P.logLevelOrder.indexOf(a),i),-1),s=P.logLevelOrder[n]??P.LogLevel.UNKNOWN,o=r.filter(i=>!(0,P.isLogLevel)(i)).map(i=>typeof i=="object"?`TracedException.Name = ${i.name}, TracedException.Message = ${i.message}, TracedException.Stack = ${i.stack}`:i);return{level:s,traces:o}}};it.LogTrace=Ft;var Ui=()=>`TimeStamp = ${new Date().toISOString()}`,Bi=(0,qs.memoize)(t=>new Set([P.LogLevel.UNKNOWN,...t?[P.LogLevel.DEBUG]:[],P.LogLevel.INFO,P.LogLevel.WARN,P.LogLevel.ERROR,P.LogLevel.SYS])),$i=()=>Bi((0,qs.isDebug)())});var ot=p(T=>{"use strict";var Ji=T&&T.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),Ae=T&&T.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&Ji(e,t,r)};Object.defineProperty(T,"__esModule",{value:!0});Ae(Ts(),T);Ae(As(),T);Ae(xs(),T);Ae(Ns(),T);Ae(Ds(),T)});var Hs=p(C=>{"use strict";Object.defineProperty(C,"__esModule",{value:!0});C.LogMetricTraceable=C.LogMetricTrace=C.EmbeddedMetricsTraceable=C.LogTraceable=void 0;var F=Vt(),Le=class t extends F.TraceableImpl{static LogTrace=new F.LogTrace;static of(e){return new t(e,t.LogTrace)}};C.LogTraceable=Le;var Cs=t=>e=>{e.length!==0&&t.traceScope(F.LogLevel.SYS).trace(`Metrics = ${JSON.stringify(e)}`)},Wt=class t extends F.TraceableImpl{static MetricsTrace=new F.MetricsTrace(Cs(Le.LogTrace));static of(e,r=t.MetricsTrace){return new t(e,r)}};C.EmbeddedMetricsTraceable=Wt;var at=class t{logTrace;metricsTrace;constructor(e,r){this.logTrace=e,this.metricsTrace=r}traceScope(e){return(0,F.isMetricsTraceSupplier)(e)?new t(this.logTrace,this.metricsTrace.traceScope(e)):new t(this.logTrace.traceScope(e),this.metricsTrace)}trace(e){return(0,F.isMetricsTraceSupplier)(e)?(this.metricsTrace.trace(e),this):(this.logTrace.trace(e),this)}};C.LogMetricTrace=at;var Gt=class t extends F.TraceableImpl{static ofLogTraceable(e){let r=new F.MetricsTrace(Cs(e.trace));return new t(e.get(),new at(e.trace,r))}static of(e){let r=Le.of(e);return t.ofLogTraceable(r)}};C.LogMetricTraceable=Gt});var Is=p(ct=>{"use strict";Object.defineProperty(ct,"__esModule",{value:!0});ct.TraceUtil=void 0;var Kt=v(),Yt=class t{static promiseify(e){return r=>r.flatMapAsync(async n=>n.move(await n.get()).map(e)).get()}static traceResultingEither(e,r=!1){return n=>(e&&n.trace.trace(n.get().fold(s=>r?e.warn:e.failure,s=>e.success)),n.traceScope(s=>s.get().fold(o=>r?Kt.LogLevel.WARN:Kt.LogLevel.ERROR,o=>Kt.LogLevel.INFO)))}static withTrace(e){return r=>r.traceScope(()=>e)}static withMetricTrace(e){return t.withTrace(e)}static withFunctionTrace(e){return t.withTrace(`fn.${e.name}`)}static withClassTrace(e){return t.withTrace(`class.${e.constructor.name}`)}};ct.TraceUtil=Yt});var Vt=p(A=>{"use strict";var Fi=A&&A.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),xe=A&&A.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&Fi(e,t,r)};Object.defineProperty(A,"__esModule",{value:!0});xe(Ps(),A);xe(et(),A);xe(ot(),A);xe(Hs(),A);xe(Is(),A)});var Us=p(L=>{"use strict";Object.defineProperty(L,"__esModule",{value:!0});L.getStdoutMany=L.getStdout=L.CmdMetric=void 0;var Q=v(),Wi=require("node:child_process");L.CmdMetric=Q.Metric.fromName("Exec").asResult();var Gi=(t,e={streamTraceable:[]})=>t.flatMap(Q.TraceUtil.withFunctionTrace(L.getStdout)).flatMap(r=>r.traceScope(()=>`Command = ${r.get()}`)).map(r=>{let n=r.get(),s=typeof n=="string"?n:n.join(" "),o=e.clearEnv?e.env:{...process.env,...e.env};return Q.Either.fromFailableAsync(new Promise((i,a)=>{let u=(0,Wi.exec)(s,{env:o}),c="";u.stdout?.on("data",f=>{let h=f.toString();c+=h,e.streamTraceable?.includes("stdout")&&r.trace.trace(h)});let l="";u.stderr?.on("data",f=>{let h=f.toString();c+=h,e.streamTraceable?.includes("stderr")&&r.trace.trace(h)}),u.on("exit",f=>{f===0?i({stdout:c,stderr:l}):a(new Error(`exited with non-zero code: ${f}. ${l}`))})}))}).map(Q.TraceUtil.promiseify(r=>r.get().mapRight(({stderr:n,stdout:s})=>(n&&r.trace.traceScope(Q.LogLevel.DEBUG).trace(`StdErr = ${n}`),s)))).peek(Q.TraceUtil.promiseify(Q.TraceUtil.traceResultingEither(L.CmdMetric))).get();L.getStdout=Gi;var Vi=(t,e={streamTraceable:[]})=>t.coExtend(r=>r.get()).reduce(async(r,n)=>(await r).joinRightAsync(()=>n.map(o=>(0,L.getStdout)(o,e)).get(),(o,i)=>i.concat(o)),Promise.resolve(Q.Either.right([])));L.getStdoutMany=Vi});var Bs=p(H=>{"use strict";Object.defineProperty(H,"__esModule",{value:!0});H.getRequiredEnvVars=H.getRequiredEnv=H.getEnv=void 0;var zt=v(),Ki=t=>zt.Optional.from(process.env[t]);H.getEnv=Ki;var Yi=t=>zt.Either.fromFailable(()=>(0,H.getEnv)(t).get()).mapLeft(()=>new Error(`environment variable "${t}" is required D:`));H.getRequiredEnv=Yi;var zi=t=>{let e=zt.Either.right({}),r=(n,s,o)=>({...n,[s]:o});return t.reduce((n,s)=>n.joinRight((0,H.getRequiredEnv)(s),(o,i)=>r(i,s,o)),e)};H.getRequiredEnvVars=zi});var Js=p(ie=>{"use strict";Object.defineProperty(ie,"__esModule",{value:!0});ie.validateExecutionEntries=ie.validateIdentifier=void 0;var $s=v(),ki=t=>/^[a-zA-Z0-9_\-:. \/]+$/.test(t)&&!t.includes("..");ie.validateIdentifier=ki;var Qi=t=>{let e=Object.entries(t).filter(r=>!r.every(n=>typeof n=="string"&&(0,ie.validateIdentifier)(n)));return e.length>0?$s.Either.left(e):$s.Either.right(t)};ie.validateExecutionEntries=Qi});var Fs=p(x=>{"use strict";Object.defineProperty(x,"__esModule",{value:!0});x.argv=x.getArg=x.isArgKey=void 0;var ae=v(),Xi=t=>t.startsWith("--");x.isArgKey=Xi;var Zi=(t,e,r)=>{let n=ae.Optional.from(e.findIndex(s=>(0,x.isArgKey)(s)&&s.split("=")[0]===t)).filter(s=>s>=0&&sae.Optional.from(e.at(s)).map(o=>o.includes("=")?o.split("=")[1]:e.at(s+1))).filter(s=>!(0,x.isArgKey)(s)).map(s=>r.present(s)).orSome(()=>r.unspecified).map(s=>ae.Either.right(s)).get():ae.Optional.from(r.absent).map(s=>ae.Either.right(s)).orSome(()=>ae.Either.left(new Error(`arg ${t} is not present in arguments list and does not have an 'absent' value`))).get()};x.getArg=Zi;var ea=(t,e,r=process.argv.slice(2))=>{let n={present:i=>i},s=i=>{let a=e?.[i]??n;return(0,x.getArg)(i,r,a).mapRight(u=>[i,u])};return t.map(s).reduce((i,a)=>i.flatMap(u=>a.mapRight(([c,l])=>({...u,[c]:l}))),ae.Either.right({})).mapRight(i=>i)};x.argv=ea});var Ws=p(I=>{"use strict";Object.defineProperty(I,"__esModule",{value:!0});I.Signals=I.SigTermMetric=I.SigIntMetric=void 0;var W=v();I.SigIntMetric=W.Metric.fromName("SigInt").asResult();I.SigTermMetric=W.Metric.fromName("SigTerm").asResult();var kt=class{static async awaitClose(e){let r=W.Either.right(void 0);return new Promise(n=>{let s=a=>u=>e.flatMap(W.TraceUtil.withMetricTrace(a)).peek(c=>c.trace.trace("closing")).move(W.Optional.from(u).map(c=>W.Either.left(c)).orSome(()=>r).get()).flatMap(W.TraceUtil.traceResultingEither(a)).map(c=>n(c.get())).peek(c=>c.trace.trace("finished")).get(),o=s(I.SigIntMetric),i=s(I.SigTermMetric);process.on("SIGINT",()=>e.flatMap(W.TraceUtil.withTrace("SIGINT")).get().close(o)),process.on("SIGTERM",()=>e.flatMap(W.TraceUtil.withTrace("SIGTERM")).get().close(i))})}};I.Signals=kt});var Gs=p(N=>{"use strict";var ta=N&&N.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),Ne=N&&N.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&ta(e,t,r)};Object.defineProperty(N,"__esModule",{value:!0});Ne(Us(),N);Ne(Bs(),N);Ne(Js(),N);Ne(Fs(),N);Ne(Ws(),N)});var Ks=p(Vs=>{"use strict";Object.defineProperty(Vs,"__esModule",{value:!0})});var Ys=p(ut=>{"use strict";Object.defineProperty(ut,"__esModule",{value:!0});ut.HttpStatusCodes=void 0;ut.HttpStatusCodes={100:"Continue",101:"Switching Protocols",102:"Processing (WebDAV)",200:"OK",201:"Created",202:"Accepted",203:"Non-Authoritative Information",204:"No Content",205:"Reset Content",206:"Partial Content",207:"Multi-Status (WebDAV)",208:"Already Reported (WebDAV)",226:"IM Used",300:"Multiple Choices",301:"Moved Permanently",302:"Found",303:"See Other",304:"Not Modified",305:"Use Proxy",306:"(Unused)",307:"Temporary Redirect",308:"Permanent Redirect (experimental)",400:"Bad Request",401:"Unauthorized",402:"Payment Required",403:"Forbidden",404:"Not Found",405:"Method Not Allowed",406:"Not Acceptable",407:"Proxy Authentication Required",408:"Request Timeout",409:"Conflict",410:"Gone",411:"Length Required",412:"Precondition Failed",413:"Request Entity Too Large",414:"Request-URI Too Long",415:"Unsupported Media Type",416:"Requested Range Not Satisfiable",417:"Expectation Failed",418:"I'm a teapot (RFC 2324)",420:"Enhance Your Calm (Twitter)",422:"Unprocessable Entity (WebDAV)",423:"Locked (WebDAV)",424:"Failed Dependency (WebDAV)",425:"Reserved for WebDAV",426:"Upgrade Required",428:"Precondition Required",429:"Too Many Requests",431:"Request Header Fields Too Large",444:"No Response (Nginx)",449:"Retry With (Microsoft)",450:"Blocked by Windows Parental Controls (Microsoft)",451:"Unavailable For Legal Reasons",499:"Client Closed Request (Nginx)",500:"Internal Server Error",501:"Not Implemented",502:"Bad Gateway",503:"Service Unavailable",504:"Gateway Timeout",505:"HTTP Version Not Supported",506:"Variant Also Negotiates (Experimental)",507:"Insufficient Storage (WebDAV)",508:"Loop Detected (WebDAV)",509:"Bandwidth Limit Exceeded (Apache)",510:"Not Extended",511:"Network Authentication Required",598:"Network read timeout error",599:"Network connect timeout error"}});var ks=p(zs=>{"use strict";Object.defineProperty(zs,"__esModule",{value:!0})});var Qs=p(G=>{"use strict";var ra=G&&G.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),Qt=G&&G.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&ra(e,t,r)};Object.defineProperty(G,"__esModule",{value:!0});Qt(Ks(),G);Qt(Ys(),G);Qt(ks(),G)});var Xs=p(V=>{"use strict";Object.defineProperty(V,"__esModule",{value:!0});V.JsonResponse=V.PenguenoResponse=V.getResponseMetrics=void 0;var qe=v(),sa=(t,e)=>{let r={...t.getResponseHeaders(),...e};return r["Content-Type"]=(r["Content-Type"]??"text/plain")+"; charset=utf-8",r},na=[0,1,2,3,4,5].map(t=>qe.Metric.fromName(`response.${t}xx`).asResult()),oa=(t,e)=>{let r=Math.floor(t/100);return na.flatMap((n,s)=>qe.Optional.from(s).filter(o=>o===r).map(()=>[n.count.withValue(1)]).flatMap(o=>qe.Optional.from(e).map(i=>o.concat(n.time.withValue(i))).orSome(()=>o)).orSome(()=>[n.count.withValue(0)]).get())};V.getResponseMetrics=oa;var lt=class{_body;statusText;status;headers;constructor(e,r,n){this._body=r,this.headers=sa(e.get(),n?.headers??{}),this.status=n.status,this.statusText=n.statusText??qe.HttpStatusCodes[this.status],e.trace.trace((0,V.getResponseMetrics)(n.status,e.get().elapsedTimeMs()))}body(){return this._body}};V.PenguenoResponse=lt;var Xt=class extends lt{constructor(e,r,n){let s={...n,headers:{...n.headers,"Content-Type":"application/json"}};if((0,qe.isEither)(r)){super(e,JSON.stringify(r.fold(o=>({error:o,ok:void 0}),o=>({ok:o}))),s);return}super(e,JSON.stringify(Math.floor(s.status/100)>4?{error:r}:{ok:r}),s)}};V.JsonResponse=Xt});var Zs=p(ce=>{"use strict";var ia=ce&&ce.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),aa=ce&&ce.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&ia(e,t,r)};Object.defineProperty(ce,"__esModule",{value:!0});aa(Xs(),ce)});var tn=p(pt=>{"use strict";Object.defineProperty(pt,"__esModule",{value:!0});pt.PenguenoRequest=void 0;var en=["hewwo :D","hiya cutie","boop!","sending virtual hugs!","stay pawsitive"],ca=()=>en[Math.floor(Math.random()*en.length)],Zt=class t{req;id;at;constructor(e,r,n){this.req=e,this.id=r,this.at=n}elapsedTimeMs(e=()=>Date.now()){return e()-this.at.getTime()}getResponseHeaders(){let e=this.id,r=this.at.getTime(),n=Date.now(),s=this.elapsedTimeMs(()=>n),o=ca();return Object.entries({RequestId:e,RequestReceivedUnix:r,RequestHandleUnix:n,DeltaUnix:s,Hai:o}).reduce((i,[a,u])=>({...i,[a]:u.toString()}),{})}static from(e){let r=crypto.randomUUID();return e.bimap(n=>{let s=n.get(),o=new URL(s.url),{pathname:i}=o,a=`RequestId = ${r}, Method = ${s.method}, Path = ${i}`;return{item:new t(s,r,new Date),trace:a}})}};pt.PenguenoRequest=Zt});var rn=p(ue=>{"use strict";var ua=ue&&ue.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),la=ue&&ue.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&ua(e,t,r)};Object.defineProperty(ue,"__esModule",{value:!0});la(tn(),ue)});var on=p(X=>{"use strict";Object.defineProperty(X,"__esModule",{value:!0});X.HealthCheckActivityImpl=X.HealthCheckOutput=X.HealthCheckInput=void 0;var le=v(),er;(function(t){t[t.CHECK=0]="CHECK"})(er||(X.HealthCheckInput=er={}));var sn;(function(t){t[t.YAASSSLAYQUEEN=0]="YAASSSLAYQUEEN"})(sn||(X.HealthCheckOutput=sn={}));var nn=le.Metric.fromName("Health").asResult(),tr=class{check;constructor(e){this.check=e}checkHealth(e){return e.flatMap(le.TraceUtil.withFunctionTrace(this.checkHealth)).flatMap(le.TraceUtil.withMetricTrace(nn)).flatMap(r=>r.move(er.CHECK).map(n=>this.check(n))).peek(le.TraceUtil.promiseify(le.TraceUtil.traceResultingEither(nn))).map(le.TraceUtil.promiseify(r=>{let{status:n,message:s}=r.get().fold(()=>({status:500,message:"err"}),()=>({status:200,message:"ok"}));return new le.JsonResponse(e,s,{status:n})})).get()}};X.HealthCheckActivityImpl=tr});var cn=p(ft=>{"use strict";Object.defineProperty(ft,"__esModule",{value:!0});ft.FourOhFourActivityImpl=void 0;var pa=v(),an=["D: meow-t found! your api call ran away!","404-bidden! but like...in a cute way >:3 !",":< your data went on a paw-sible vacation!","uwu~ not found, but found our hearts instead!"],fa=()=>an[Math.floor(Math.random()*an.length)],rr=class{fourOhFour(e){return e.move(new pa.JsonResponse(e,fa(),{status:404})).map(r=>Promise.resolve(r.get())).get()}};ft.FourOhFourActivityImpl=rr});var ln=p(Z=>{"use strict";var ha=Z&&Z.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),un=Z&&Z.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&ha(e,t,r)};Object.defineProperty(Z,"__esModule",{value:!0});un(on(),Z);un(cn(),Z)});var pn=p(Ce=>{"use strict";Object.defineProperty(Ce,"__esModule",{value:!0});Ce.requireMethod=void 0;var De=v(),da=t=>e=>e.flatMap(De.TraceUtil.withFunctionTrace(Ce.requireMethod)).map(r=>{let{req:{method:n}}=r.get();if(!t.includes(n)){let s="that's not how you pet me (\u22DF\uFE4F\u22DE)~";return r.trace.traceScope(De.LogLevel.WARN).trace(s),De.Either.left(new De.PenguenoError(s,405))}return De.Either.right(n)}).get();Ce.requireMethod=da});var hn=p(He=>{"use strict";Object.defineProperty(He,"__esModule",{value:!0});He.jsonModel=void 0;var K=v(),fn=K.Metric.fromName("JsonParse").asResult(),_a=t=>e=>e.flatMap(K.TraceUtil.withFunctionTrace(He.jsonModel)).flatMap(K.TraceUtil.withMetricTrace(fn)).map(r=>K.Either.fromFailableAsync(r.get().req.json()).then(n=>n.mapLeft(s=>(r.trace.traceScope(K.LogLevel.WARN).trace(s),new K.PenguenoError("seems to be invalid JSON (>//<) can you fix?",400))))).flatMapAsync(K.TraceUtil.promiseify(K.TraceUtil.traceResultingEither(fn))).map(K.TraceUtil.promiseify(r=>r.get().mapRight(n=>r.move(n)).flatMap(t))).get();He.jsonModel=_a});var _n=p(R=>{"use strict";var ga=R&&R.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),dn=R&&R.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&ga(e,t,r)};Object.defineProperty(R,"__esModule",{value:!0});R.PenguenoError=R.ErrorSource=void 0;var pf=v(),ht;(function(t){t.USER="WARN",t.SYSTEM="ERROR"})(ht||(R.ErrorSource=ht={}));var sr=class extends Error{message;status;source;constructor(e,r){super(e),this.message=e,this.status=r,this.source=Math.floor(r/100)===4?ht.USER:ht.SYSTEM}};R.PenguenoError=sr;dn(pn(),R);dn(hn(),R)});var An=p((hf,Tn)=>{"use strict";var va=Object.create,_t=Object.defineProperty,ya=Object.getOwnPropertyDescriptor,ba=Object.getOwnPropertyNames,Oa=Object.getPrototypeOf,ma=Object.prototype.hasOwnProperty,wa=(t,e)=>{for(var r in e)_t(t,r,{get:e[r],enumerable:!0})},yn=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of ba(e))!ma.call(t,s)&&s!==r&&_t(t,s,{get:()=>e[s],enumerable:!(n=ya(e,s))||n.enumerable});return t},Pa=(t,e,r)=>(r=t!=null?va(Oa(t)):{},yn(e||!t||!t.__esModule?_t(r,"default",{value:t,enumerable:!0}):r,t)),Ea=t=>yn(_t({},"__esModule",{value:!0}),t),bn={};wa(bn,{RequestError:()=>ee,createAdaptorServer:()=>Sn,getRequestListener:()=>jn,serve:()=>Ba});Tn.exports=Ea(bn);var Ma=require("http"),Ra=require("http2"),nr=require("http2"),gn=require("stream"),ee=class extends Error{constructor(t,e){super(t,e),this.name="RequestError"}},ja=t=>t instanceof ee?t:new ee(t.message,{cause:t}),Sa=global.Request,Ie=class extends Sa{constructor(t,e){typeof t=="object"&&Oe in t&&(t=t[Oe]()),typeof e?.body?.getReader<"u"&&(e.duplex??="half"),super(t,e)}},On=Symbol("wrapBodyStream"),Ta=(t,e,r,n)=>{let s=[],o=r.rawHeaders;for(let a=0;a{Object.defineProperty(gt,t,{get(){return this[Oe]()[t]}})});["arrayBuffer","blob","clone","formData","json","text"].forEach(t=>{Object.defineProperty(gt,t,{value:function(){return this[Oe]()[t]()}})});Object.setPrototypeOf(gt,Ie.prototype);var xa=(t,e)=>{let r=Object.create(gt);r[or]=t;let n=t.url||"";if(n[0]!=="/"&&(n.startsWith("http://")||n.startsWith("https://"))){if(t instanceof nr.Http2ServerRequest)throw new ee("Absolute URL for :path is not allowed in HTTP/2");try{let a=new URL(n);r[dt]=a.href}catch(a){throw new ee("Invalid absolute URL",{cause:a})}return r}let s=(t instanceof nr.Http2ServerRequest?t.authority:t.headers.host)||e;if(!s)throw new ee("Missing host header");let o;if(t instanceof nr.Http2ServerRequest){if(o=t.scheme,!(o==="http"||o==="https"))throw new ee("Unsupported scheme")}else o=t.socket&&t.socket.encrypted?"https":"http";let i=new URL(`${o}://${s}${n}`);if(i.hostname.length!==s.length&&i.hostname!==s.replace(/:\d+$/,""))throw new ee("Invalid host header");return r[dt]=i.href,r},vn=Symbol("responseCache"),ye=Symbol("getResponseCache"),pe=Symbol("cache"),ar=global.Response,Ue=class mn{#t;#e;[ye](){return delete this[pe],this[vn]||=new ar(this.#t,this.#e)}constructor(e,r){let n;if(this.#t=e,r instanceof mn){let s=r[vn];if(s){this.#e=s,this[ye]();return}else this.#e=r.#e,n=new Headers(r.#e.headers)}else this.#e=r;(typeof e=="string"||typeof e?.getReader<"u"||e instanceof Blob||e instanceof Uint8Array)&&(n||=r?.headers||{"content-type":"text/plain; charset=UTF-8"},this[pe]=[r?.status||200,e,n])}get headers(){let e=this[pe];return e?(e[2]instanceof Headers||(e[2]=new Headers(e[2])),e[2]):this[ye]().headers}get status(){return this[pe]?.[0]??this[ye]().status}get ok(){let e=this.status;return e>=200&&e<300}};["body","bodyUsed","redirected","statusText","trailers","type","url"].forEach(t=>{Object.defineProperty(Ue.prototype,t,{get(){return this[ye]()[t]}})});["arrayBuffer","blob","clone","formData","json","text"].forEach(t=>{Object.defineProperty(Ue.prototype,t,{value:function(){return this[ye]()[t]()}})});Object.setPrototypeOf(Ue,ar);Object.setPrototypeOf(Ue.prototype,ar.prototype);async function Na(t){return Promise.race([t,Promise.resolve().then(()=>Promise.resolve(void 0))])}function wn(t,e,r){let n=()=>{};return e.on("error",n),(r??t.read()).then(i,s),t.closed.finally(()=>{e.off("error",n)});function s(a){a&&e.destroy(a)}function o(){t.read().then(i,s)}function i({done:a,value:u}){try{if(a)e.end();else if(!e.write(u))e.once("drain",o);else return t.read().then(i,s)}catch(c){s(c)}}}function qa(t,e){if(t.locked)throw new TypeError("ReadableStream is locked.");return e.destroyed?void 0:wn(t.getReader(),e)}var Pn=t=>{let e={};t instanceof Headers||(t=new Headers(t??void 0));let r=[];for(let[n,s]of t)n==="set-cookie"?r.push(s):e[n]=s;return r.length>0&&(e["set-cookie"]=r),e["content-type"]??="text/plain; charset=UTF-8",e},Da="x-hono-already-sent",Ca=Pa(require("crypto")),Ha=global.fetch;typeof global.crypto>"u"&&(global.crypto=Ca.default);global.fetch=(t,e)=>(e={compress:!1,...e},Ha(t,e));var cr=Symbol("outgoingEnded"),Ia=()=>new Response(null,{status:400}),En=t=>new Response(null,{status:t instanceof Error&&(t.name==="TimeoutError"||t.constructor.name==="TimeoutError")?504:500}),ir=(t,e)=>{let r=t instanceof Error?t:new Error("unknown error",{cause:t});r.code==="ERR_STREAM_PREMATURE_CLOSE"?console.info("The user aborted a request."):(console.error(t),e.headersSent||e.writeHead(500,{"Content-Type":"text/plain"}),e.end(`Error: ${r.message}`),e.destroy(r))},Mn=t=>{"flushHeaders"in t&&t.writable&&t.flushHeaders()},Rn=async(t,e)=>{let[r,n,s]=t[pe];s instanceof Headers&&(s=Pn(s)),typeof n=="string"?s["Content-Length"]=Buffer.byteLength(n):n instanceof Uint8Array?s["Content-Length"]=n.byteLength:n instanceof Blob&&(s["Content-Length"]=n.size),e.writeHead(r,s),typeof n=="string"||n instanceof Uint8Array?e.end(n):n instanceof Blob?e.end(new Uint8Array(await n.arrayBuffer())):(Mn(e),await qa(n,e)?.catch(o=>ir(o,e))),e[cr]?.()},Ua=async(t,e,r={})=>{if(t instanceof Promise)if(r.errorHandler)try{t=await t}catch(s){let o=await r.errorHandler(s);if(!o)return;t=o}else t=await t.catch(En);if(pe in t)return Rn(t,e);let n=Pn(t.headers);if(t.body){let s=t.body.getReader(),o=[],i=!1,a;if(n["transfer-encoding"]!=="chunked"){let u=2;for(let c=0;c{console.error(f),i=!0});if(!l){if(c===1){await new Promise(f=>setTimeout(f)),u=3;continue}break}if(a=void 0,l.value&&o.push(l.value),l.done){i=!0;break}}i&&!("content-length"in n)&&(n["content-length"]=o.reduce((c,l)=>c+l.length,0))}e.writeHead(t.status,n),o.forEach(u=>{e.write(u)}),i?e.end():(o.length===0&&Mn(e),await wn(s,e,a))}else n[Da]||(e.writeHead(t.status,n),e.end());e[cr]?.()},jn=(t,e={})=>{let r=e.autoCleanupIncoming??!0;return e.overrideGlobalObjects!==!1&&global.Request!==Ie&&(Object.defineProperty(global,"Request",{value:Ie}),Object.defineProperty(global,"Response",{value:Ue})),async(n,s)=>{let o,i;try{i=xa(n,e.hostname);let a=!r||n.method==="GET"||n.method==="HEAD";if(a||(n[On]=!0,n.on("end",()=>{a=!0}),n instanceof Ra.Http2ServerRequest&&(s[cr]=()=>{a||setTimeout(()=>{a||setTimeout(()=>{n.destroy(),s.destroy()})})})),s.on("close",()=>{i[be]&&(n.errored?i[be].abort(n.errored.toString()):s.writableFinished||i[be].abort("Client connection prematurely closed.")),a||setTimeout(()=>{a||setTimeout(()=>{n.destroy()})})}),o=t(i,{incoming:n,outgoing:s}),pe in o)return Rn(o,s)}catch(a){if(o)return ir(a,s);if(e.errorHandler){if(o=await e.errorHandler(i?a:ja(a)),!o)return}else i?o=En(a):o=Ia()}try{return await Ua(o,s,e)}catch(a){return ir(a,s)}}},Sn=t=>{let e=t.fetch,r=jn(e,{hostname:t.hostname,overrideGlobalObjects:t.overrideGlobalObjects,autoCleanupIncoming:t.autoCleanupIncoming});return(t.createServer||Ma.createServer)(t.serverOptions||{},r)},Ba=(t,e)=>{let r=Sn(t);return r.listen(t?.port??3e3,t.hostname,()=>{let n=r.address();e&&e(n)}),r}});var Nn=p((gf,xn)=>{"use strict";var ur=Object.defineProperty,$a=Object.getOwnPropertyDescriptor,Ja=Object.getOwnPropertyNames,Fa=Object.prototype.hasOwnProperty,Wa=(t,e)=>{for(var r in e)ur(t,r,{get:e[r],enumerable:!0})},Ga=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of Ja(e))!Fa.call(t,s)&&s!==r&&ur(t,s,{get:()=>e[s],enumerable:!(n=$a(e,s))||n.enumerable});return t},Va=t=>Ga(ur({},"__esModule",{value:!0}),t),Ln={};Wa(Ln,{compose:()=>Ka});xn.exports=Va(Ln);var Ka=(t,e,r)=>(n,s)=>{let o=-1;return i(0);async function i(a){if(a<=o)throw new Error("next() called multiple times");o=a;let u,c=!1,l;if(t[a]?(l=t[a][0][0],n.req.routeIndex=a):l=a===t.length&&s||void 0,l)try{u=await l(n,()=>i(a+1))}catch(f){if(f instanceof Error&&e)n.error=f,u=await e(f,n),c=!0;else throw f}else n.finalized===!1&&r&&(u=await r(n));return u&&(n.finalized===!1||c)&&(n.res=u),n}}});var Cn=p((vf,Dn)=>{"use strict";var lr=Object.defineProperty,Ya=Object.getOwnPropertyDescriptor,za=Object.getOwnPropertyNames,ka=Object.prototype.hasOwnProperty,Qa=(t,e)=>{for(var r in e)lr(t,r,{get:e[r],enumerable:!0})},Xa=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of za(e))!ka.call(t,s)&&s!==r&&lr(t,s,{get:()=>e[s],enumerable:!(n=Ya(e,s))||n.enumerable});return t},Za=t=>Xa(lr({},"__esModule",{value:!0}),t),qn={};Qa(qn,{GET_MATCH_RESULT:()=>ec});Dn.exports=Za(qn);var ec=Symbol()});var Un=p((yf,In)=>{"use strict";var pr=Object.defineProperty,tc=Object.getOwnPropertyDescriptor,rc=Object.getOwnPropertyNames,sc=Object.prototype.hasOwnProperty,nc=(t,e)=>{for(var r in e)pr(t,r,{get:e[r],enumerable:!0})},oc=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of rc(e))!sc.call(t,s)&&s!==r&&pr(t,s,{get:()=>e[s],enumerable:!(n=tc(e,s))||n.enumerable});return t},ic=t=>oc(pr({},"__esModule",{value:!0}),t),Hn={};nc(Hn,{parseBody:()=>cc});In.exports=ic(Hn);var ac=fr(),cc=async(t,e=Object.create(null))=>{let{all:r=!1,dot:n=!1}=e,o=(t instanceof ac.HonoRequest?t.raw.headers:t.headers).get("Content-Type");return o?.startsWith("multipart/form-data")||o?.startsWith("application/x-www-form-urlencoded")?uc(t,{all:r,dot:n}):{}};async function uc(t,e){let r=await t.formData();return r?lc(r,e):{}}function lc(t,e){let r=Object.create(null);return t.forEach((n,s)=>{e.all||s.endsWith("[]")?pc(r,s,n):r[s]=n}),e.dot&&Object.entries(r).forEach(([n,s])=>{n.includes(".")&&(fc(r,n,s),delete r[n])}),r}var pc=(t,e,r)=>{t[e]!==void 0?Array.isArray(t[e])?t[e].push(r):t[e]=[t[e],r]:e.endsWith("[]")?t[e]=[r]:t[e]=r},fc=(t,e,r)=>{let n=t,s=e.split(".");s.forEach((o,i)=>{i===s.length-1?n[o]=r:((!n[o]||typeof n[o]!="object"||Array.isArray(n[o])||n[o]instanceof File)&&(n[o]=Object.create(null)),n=n[o])})}});var me=p((bf,Vn)=>{"use strict";var dr=Object.defineProperty,hc=Object.getOwnPropertyDescriptor,dc=Object.getOwnPropertyNames,_c=Object.prototype.hasOwnProperty,gc=(t,e)=>{for(var r in e)dr(t,r,{get:e[r],enumerable:!0})},vc=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of dc(e))!_c.call(t,s)&&s!==r&&dr(t,s,{get:()=>e[s],enumerable:!(n=hc(e,s))||n.enumerable});return t},yc=t=>vc(dr({},"__esModule",{value:!0}),t),Bn={};gc(Bn,{checkOptionalParameter:()=>Rc,decodeURIComponent_:()=>Gn,getPath:()=>Jn,getPathNoStrict:()=>Mc,getPattern:()=>wc,getQueryParam:()=>jc,getQueryParams:()=>Sc,getQueryStrings:()=>Ec,mergePath:()=>Fn,splitPath:()=>$n,splitRoutingPath:()=>bc,tryDecode:()=>_r});Vn.exports=yc(Bn);var $n=t=>{let e=t.split("/");return e[0]===""&&e.shift(),e},bc=t=>{let{groups:e,path:r}=Oc(t),n=$n(r);return mc(n,e)},Oc=t=>{let e=[];return t=t.replace(/\{[^}]+\}/g,(r,n)=>{let s=`@${n}`;return e.push([s,r]),s}),{groups:e,path:t}},mc=(t,e)=>{for(let r=e.length-1;r>=0;r--){let[n]=e[r];for(let s=t.length-1;s>=0;s--)if(t[s].includes(n)){t[s]=t[s].replace(n,e[r][1]);break}}return t},vt={},wc=(t,e)=>{if(t==="*")return"*";let r=t.match(/^\:([^\{\}]+)(?:\{(.+)\})?$/);if(r){let n=`${t}#${e}`;return vt[n]||(r[2]?vt[n]=e&&e[0]!==":"&&e[0]!=="*"?[n,r[1],new RegExp(`^${r[2]}(?=/${e})`)]:[t,r[1],new RegExp(`^${r[2]}$`)]:vt[n]=[t,r[1],!0]),vt[n]}return null},_r=(t,e)=>{try{return e(t)}catch{return t.replace(/(?:%[0-9A-Fa-f]{2})+/g,r=>{try{return e(r)}catch{return r}})}},Pc=t=>_r(t,decodeURI),Jn=t=>{let e=t.url,r=e.indexOf("/",e.indexOf(":")+4),n=r;for(;n{let e=t.indexOf("?",8);return e===-1?"":"?"+t.slice(e+1)},Mc=t=>{let e=Jn(t);return e.length>1&&e.at(-1)==="/"?e.slice(0,-1):e},Fn=(t,e,...r)=>(r.length&&(e=Fn(e,...r)),`${t?.[0]==="/"?"":"/"}${t}${e==="/"?"":`${t?.at(-1)==="/"?"":"/"}${e?.[0]==="/"?e.slice(1):e}`}`),Rc=t=>{if(t.charCodeAt(t.length-1)!==63||!t.includes(":"))return null;let e=t.split("/"),r=[],n="";return e.forEach(s=>{if(s!==""&&!/\:/.test(s))n+="/"+s;else if(/\:/.test(s))if(/\?/.test(s)){r.length===0&&n===""?r.push("/"):r.push(n);let o=s.replace("?","");n+="/"+o,r.push(n)}else n+="/"+s}),r.filter((s,o,i)=>i.indexOf(s)===o)},hr=t=>/[%+]/.test(t)?(t.indexOf("+")!==-1&&(t=t.replace(/\+/g," ")),t.indexOf("%")!==-1?_r(t,Gn):t):t,Wn=(t,e,r)=>{let n;if(!r&&e&&!/[%+]/.test(e)){let i=t.indexOf(`?${e}`,8);for(i===-1&&(i=t.indexOf(`&${e}`,8));i!==-1;){let a=t.charCodeAt(i+e.length+1);if(a===61){let u=i+e.length+2,c=t.indexOf("&",u);return hr(t.slice(u,c===-1?void 0:c))}else if(a==38||isNaN(a))return"";i=t.indexOf(`&${e}`,i+1)}if(n=/[%+]/.test(t),!n)return}let s={};n??=/[%+]/.test(t);let o=t.indexOf("?",8);for(;o!==-1;){let i=t.indexOf("&",o+1),a=t.indexOf("=",o);a>i&&i!==-1&&(a=-1);let u=t.slice(o+1,a===-1?i===-1?void 0:i:a);if(n&&(u=hr(u)),o=i,u==="")continue;let c;a===-1?c="":(c=t.slice(a+1,i===-1?void 0:i),n&&(c=hr(c))),r?(s[u]&&Array.isArray(s[u])||(s[u]=[]),s[u].push(c)):s[u]??=c}return e?s[e]:s},jc=Wn,Sc=(t,e)=>Wn(t,e,!0),Gn=decodeURIComponent});var fr=p((Of,zn)=>{"use strict";var vr=Object.defineProperty,Tc=Object.getOwnPropertyDescriptor,Ac=Object.getOwnPropertyNames,Lc=Object.prototype.hasOwnProperty,xc=(t,e)=>{for(var r in e)vr(t,r,{get:e[r],enumerable:!0})},Nc=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of Ac(e))!Lc.call(t,s)&&s!==r&&vr(t,s,{get:()=>e[s],enumerable:!(n=Tc(e,s))||n.enumerable});return t},qc=t=>Nc(vr({},"__esModule",{value:!0}),t),Yn={};xc(Yn,{HonoRequest:()=>gr});zn.exports=qc(Yn);var Dc=Cn(),Cc=Un(),yt=me(),Kn=t=>(0,yt.tryDecode)(t,yt.decodeURIComponent_),gr=class{raw;#t;#e;routeIndex=0;path;bodyCache={};constructor(e,r="/",n=[[]]){this.raw=e,this.path=r,this.#e=n,this.#t={}}param(e){return e?this.#r(e):this.#o()}#r(e){let r=this.#e[0][this.routeIndex][1][e],n=this.#n(r);return n&&/\%/.test(n)?Kn(n):n}#o(){let e={},r=Object.keys(this.#e[0][this.routeIndex][1]);for(let n of r){let s=this.#n(this.#e[0][this.routeIndex][1][n]);s!==void 0&&(e[n]=/\%/.test(s)?Kn(s):s)}return e}#n(e){return this.#e[1]?this.#e[1][e]:e}query(e){return(0,yt.getQueryParam)(this.url,e)}queries(e){return(0,yt.getQueryParams)(this.url,e)}header(e){if(e)return this.raw.headers.get(e)??void 0;let r={};return this.raw.headers.forEach((n,s)=>{r[s]=n}),r}async parseBody(e){return this.bodyCache.parsedBody??=await(0,Cc.parseBody)(this,e)}#s=e=>{let{bodyCache:r,raw:n}=this,s=r[e];if(s)return s;let o=Object.keys(r)[0];return o?r[o].then(i=>(o==="json"&&(i=JSON.stringify(i)),new Response(i)[e]())):r[e]=n[e]()};json(){return this.#s("text").then(e=>JSON.parse(e))}text(){return this.#s("text")}arrayBuffer(){return this.#s("arrayBuffer")}blob(){return this.#s("blob")}formData(){return this.#s("formData")}addValidatedData(e,r){this.#t[e]=r}valid(e){return this.#t[e]}get url(){return this.raw.url}get method(){return this.raw.method}get[Dc.GET_MATCH_RESULT](){return this.#e}get matchedRoutes(){return this.#e[0].map(([[,e]])=>e)}get routePath(){return this.#e[0].map(([[,e]])=>e)[this.routeIndex].path}}});var to=p((mf,eo)=>{"use strict";var yr=Object.defineProperty,Hc=Object.getOwnPropertyDescriptor,Ic=Object.getOwnPropertyNames,Uc=Object.prototype.hasOwnProperty,Bc=(t,e)=>{for(var r in e)yr(t,r,{get:e[r],enumerable:!0})},$c=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of Ic(e))!Uc.call(t,s)&&s!==r&&yr(t,s,{get:()=>e[s],enumerable:!(n=Hc(e,s))||n.enumerable});return t},Jc=t=>$c(yr({},"__esModule",{value:!0}),t),kn={};Bc(kn,{HtmlEscapedCallbackPhase:()=>Qn,escapeToBuffer:()=>Xn,raw:()=>br,resolveCallback:()=>Zn,resolveCallbackSync:()=>Gc,stringBufferToString:()=>Wc});eo.exports=Jc(kn);var Qn={Stringify:1,BeforeStream:2,Stream:3},br=(t,e)=>{let r=new String(t);return r.isEscaped=!0,r.callbacks=e,r},Fc=/[&<>'"]/,Wc=async(t,e)=>{let r="";e||=[];let n=await Promise.all(t);for(let s=n.length-1;r+=n[s],s--,!(s<0);s--){let o=n[s];typeof o=="object"&&e.push(...o.callbacks||[]);let i=o.isEscaped;if(o=await(typeof o=="object"?o.toString():o),typeof o=="object"&&e.push(...o.callbacks||[]),o.isEscaped??i)r+=o;else{let a=[r];Xn(o,a),r=a[0]}}return br(r,e)},Xn=(t,e)=>{let r=t.search(Fc);if(r===-1){e[0]+=t;return}let n,s,o=0;for(s=r;s{let e=t.callbacks;if(!e?.length)return t;let r=[t],n={};return e.forEach(s=>s({phase:Qn.Stringify,buffer:r,context:n})),r[0]},Zn=async(t,e,r,n,s)=>{typeof t=="object"&&!(t instanceof String)&&(t instanceof Promise||(t=t.toString()),t instanceof Promise&&(t=await t));let o=t.callbacks;if(!o?.length)return Promise.resolve(t);s?s[0]+=t:s=[t];let i=Promise.all(o.map(a=>a({phase:e,buffer:s,context:n}))).then(a=>Promise.all(a.filter(Boolean).map(u=>Zn(u,e,!1,n,s))).then(()=>s[0]));return r?br(await i,o):i}});var io=p((wf,oo)=>{"use strict";var wr=Object.defineProperty,Vc=Object.getOwnPropertyDescriptor,Kc=Object.getOwnPropertyNames,Yc=Object.prototype.hasOwnProperty,zc=(t,e)=>{for(var r in e)wr(t,r,{get:e[r],enumerable:!0})},kc=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of Kc(e))!Yc.call(t,s)&&s!==r&&wr(t,s,{get:()=>e[s],enumerable:!(n=Vc(e,s))||n.enumerable});return t},Qc=t=>kc(wr({},"__esModule",{value:!0}),t),so={};zc(so,{Context:()=>mr,TEXT_PLAIN:()=>no});oo.exports=Qc(so);var Xc=fr(),ro=to(),no="text/plain; charset=UTF-8",Or=(t,e)=>({"Content-Type":t,...e}),mr=class{#t;#e;env={};#r;finalized=!1;error;#o;#n;#s;#l;#c;#u;#a;#p;#f;constructor(e,r){this.#t=e,r&&(this.#n=r.executionCtx,this.env=r.env,this.#u=r.notFoundHandler,this.#f=r.path,this.#p=r.matchResult)}get req(){return this.#e??=new Xc.HonoRequest(this.#t,this.#f,this.#p),this.#e}get event(){if(this.#n&&"respondWith"in this.#n)return this.#n;throw Error("This context has no FetchEvent")}get executionCtx(){if(this.#n)return this.#n;throw Error("This context has no ExecutionContext")}get res(){return this.#s||=new Response(null,{headers:this.#a??=new Headers})}set res(e){if(this.#s&&e){e=new Response(e.body,e);for(let[r,n]of this.#s.headers.entries())if(r!=="content-type")if(r==="set-cookie"){let s=this.#s.headers.getSetCookie();e.headers.delete("set-cookie");for(let o of s)e.headers.append("set-cookie",o)}else e.headers.set(r,n)}this.#s=e,this.finalized=!0}render=(...e)=>(this.#c??=r=>this.html(r),this.#c(...e));setLayout=e=>this.#l=e;getLayout=()=>this.#l;setRenderer=e=>{this.#c=e};header=(e,r,n)=>{this.finalized&&(this.#s=new Response(this.#s.body,this.#s));let s=this.#s?this.#s.headers:this.#a??=new Headers;r===void 0?s.delete(e):n?.append?s.append(e,r):s.set(e,r)};status=e=>{this.#o=e};set=(e,r)=>{this.#r??=new Map,this.#r.set(e,r)};get=e=>this.#r?this.#r.get(e):void 0;get var(){return this.#r?Object.fromEntries(this.#r):{}}#i(e,r,n){let s=this.#s?new Headers(this.#s.headers):this.#a??new Headers;if(typeof r=="object"&&"headers"in r){let i=r.headers instanceof Headers?r.headers:new Headers(r.headers);for(let[a,u]of i)a.toLowerCase()==="set-cookie"?s.append(a,u):s.set(a,u)}if(n)for(let[i,a]of Object.entries(n))if(typeof a=="string")s.set(i,a);else{s.delete(i);for(let u of a)s.append(i,u)}let o=typeof r=="number"?r:r?.status??this.#o;return new Response(e,{status:o,headers:s})}newResponse=(...e)=>this.#i(...e);body=(e,r,n)=>this.#i(e,r,n);text=(e,r,n)=>!this.#a&&!this.#o&&!r&&!n&&!this.finalized?new Response(e):this.#i(e,r,Or(no,n));json=(e,r,n)=>this.#i(JSON.stringify(e),r,Or("application/json",n));html=(e,r,n)=>{let s=o=>this.#i(o,r,Or("text/html; charset=UTF-8",n));return typeof e=="object"?(0,ro.resolveCallback)(e,ro.HtmlEscapedCallbackPhase.Stringify,!1,{}).then(s):s(e)};redirect=(e,r)=>{let n=String(e);return this.header("Location",/[^\x00-\xFF]/.test(n)?encodeURI(n):n),this.newResponse(null,r??302)};notFound=()=>(this.#u??=()=>new Response,this.#u(this))}});var Be=p((Pf,co)=>{"use strict";var Er=Object.defineProperty,Zc=Object.getOwnPropertyDescriptor,eu=Object.getOwnPropertyNames,tu=Object.prototype.hasOwnProperty,ru=(t,e)=>{for(var r in e)Er(t,r,{get:e[r],enumerable:!0})},su=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of eu(e))!tu.call(t,s)&&s!==r&&Er(t,s,{get:()=>e[s],enumerable:!(n=Zc(e,s))||n.enumerable});return t},nu=t=>su(Er({},"__esModule",{value:!0}),t),ao={};ru(ao,{MESSAGE_MATCHER_IS_ALREADY_BUILT:()=>cu,METHODS:()=>au,METHOD_NAME_ALL:()=>ou,METHOD_NAME_ALL_LOWERCASE:()=>iu,UnsupportedPathError:()=>Pr});co.exports=nu(ao);var ou="ALL",iu="all",au=["get","post","put","delete","options","patch"],cu="Can not add a route since the matcher is already built.",Pr=class extends Error{}});var po=p((Ef,lo)=>{"use strict";var Mr=Object.defineProperty,uu=Object.getOwnPropertyDescriptor,lu=Object.getOwnPropertyNames,pu=Object.prototype.hasOwnProperty,fu=(t,e)=>{for(var r in e)Mr(t,r,{get:e[r],enumerable:!0})},hu=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of lu(e))!pu.call(t,s)&&s!==r&&Mr(t,s,{get:()=>e[s],enumerable:!(n=uu(e,s))||n.enumerable});return t},du=t=>hu(Mr({},"__esModule",{value:!0}),t),uo={};fu(uo,{COMPOSED_HANDLER:()=>_u});lo.exports=du(uo);var _u="__COMPOSED_HANDLER"});var vo=p((Mf,go)=>{"use strict";var jr=Object.defineProperty,gu=Object.getOwnPropertyDescriptor,vu=Object.getOwnPropertyNames,yu=Object.prototype.hasOwnProperty,bu=(t,e)=>{for(var r in e)jr(t,r,{get:e[r],enumerable:!0})},Ou=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of vu(e))!yu.call(t,s)&&s!==r&&jr(t,s,{get:()=>e[s],enumerable:!(n=gu(e,s))||n.enumerable});return t},mu=t=>Ou(jr({},"__esModule",{value:!0}),t),_o={};bu(_o,{HonoBase:()=>Rr});go.exports=mu(_o);var fo=Nn(),wu=io(),bt=Be(),Pu=po(),fe=me(),Eu=t=>t.text("404 Not Found",404),ho=(t,e)=>{if("getResponse"in t){let r=t.getResponse();return e.newResponse(r.body,r)}return console.error(t),e.text("Internal Server Error",500)},Rr=class t{get;post;put;delete;options;patch;all;on;use;router;getPath;_basePath="/";#t="/";routes=[];constructor(e={}){[...bt.METHODS,bt.METHOD_NAME_ALL_LOWERCASE].forEach(o=>{this[o]=(i,...a)=>(typeof i=="string"?this.#t=i:this.#o(o,this.#t,i),a.forEach(u=>{this.#o(o,this.#t,u)}),this)}),this.on=(o,i,...a)=>{for(let u of[i].flat()){this.#t=u;for(let c of[o].flat())a.map(l=>{this.#o(c.toUpperCase(),this.#t,l)})}return this},this.use=(o,...i)=>(typeof o=="string"?this.#t=o:(this.#t="*",i.unshift(o)),i.forEach(a=>{this.#o(bt.METHOD_NAME_ALL,this.#t,a)}),this);let{strict:n,...s}=e;Object.assign(this,s),this.getPath=n??!0?e.getPath??fe.getPath:fe.getPathNoStrict}#e(){let e=new t({router:this.router,getPath:this.getPath});return e.errorHandler=this.errorHandler,e.#r=this.#r,e.routes=this.routes,e}#r=Eu;errorHandler=ho;route(e,r){let n=this.basePath(e);return r.routes.map(s=>{let o;r.errorHandler===ho?o=s.handler:(o=async(i,a)=>(await(0,fo.compose)([],r.errorHandler)(i,()=>s.handler(i,a))).res,o[Pu.COMPOSED_HANDLER]=s.handler),n.#o(s.method,s.path,o)}),this}basePath(e){let r=this.#e();return r._basePath=(0,fe.mergePath)(this._basePath,e),r}onError=e=>(this.errorHandler=e,this);notFound=e=>(this.#r=e,this);mount(e,r,n){let s,o;n&&(typeof n=="function"?o=n:(o=n.optionHandler,n.replaceRequest===!1?s=u=>u:s=n.replaceRequest));let i=o?u=>{let c=o(u);return Array.isArray(c)?c:[c]}:u=>{let c;try{c=u.executionCtx}catch{}return[u.env,c]};s||=(()=>{let u=(0,fe.mergePath)(this._basePath,e),c=u==="/"?0:u.length;return l=>{let f=new URL(l.url);return f.pathname=f.pathname.slice(c)||"/",new Request(f,l)}})();let a=async(u,c)=>{let l=await r(s(u.req.raw),...i(u));if(l)return l;await c()};return this.#o(bt.METHOD_NAME_ALL,(0,fe.mergePath)(e,"*"),a),this}#o(e,r,n){e=e.toUpperCase(),r=(0,fe.mergePath)(this._basePath,r);let s={basePath:this._basePath,path:r,method:e,handler:n};this.router.add(e,r,[n,s]),this.routes.push(s)}#n(e,r){if(e instanceof Error)return this.errorHandler(e,r);throw e}#s(e,r,n,s){if(s==="HEAD")return(async()=>new Response(null,await this.#s(e,r,n,"GET")))();let o=this.getPath(e,{env:n}),i=this.router.match(s,o),a=new wu.Context(e,{path:o,matchResult:i,env:n,executionCtx:r,notFoundHandler:this.#r});if(i[0].length===1){let c;try{c=i[0][0][0][0](a,async()=>{a.res=await this.#r(a)})}catch(l){return this.#n(l,a)}return c instanceof Promise?c.then(l=>l||(a.finalized?a.res:this.#r(a))).catch(l=>this.#n(l,a)):c??this.#r(a)}let u=(0,fo.compose)(i[0],this.errorHandler,this.#r);return(async()=>{try{let c=await u(a);if(!c.finalized)throw new Error("Context is not finalized. Did you forget to return a Response object or `await next()`?");return c.res}catch(c){return this.#n(c,a)}})()}fetch=(e,...r)=>this.#s(e,r[1],r[0],e.method);request=(e,r,n,s)=>e instanceof Request?this.fetch(r?new Request(e,r):e,n,s):(e=e.toString(),this.fetch(new Request(/^https?:\/\//.test(e)?e:`http://localhost${(0,fe.mergePath)("/",e)}`,r),n,s));fire=()=>{addEventListener("fetch",e=>{e.respondWith(this.#s(e.request,e,void 0,e.request.method))})}}});var Ar=p((Rf,bo)=>{"use strict";var Tr=Object.defineProperty,Mu=Object.getOwnPropertyDescriptor,Ru=Object.getOwnPropertyNames,ju=Object.prototype.hasOwnProperty,Su=(t,e)=>{for(var r in e)Tr(t,r,{get:e[r],enumerable:!0})},Tu=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of Ru(e))!ju.call(t,s)&&s!==r&&Tr(t,s,{get:()=>e[s],enumerable:!(n=Mu(e,s))||n.enumerable});return t},Au=t=>Tu(Tr({},"__esModule",{value:!0}),t),yo={};Su(yo,{Node:()=>Sr,PATH_ERROR:()=>we});bo.exports=Au(yo);var Ot="[^/]+",$e=".*",Je="(?:|/.*)",we=Symbol(),Lu=new Set(".\\+*[^]$()");function xu(t,e){return t.length===1?e.length===1?th!==$e&&h!==Je))throw we;if(o)return;c=this.#r[f]=new t,l!==""&&(c.#e=s.varIndex++)}!o&&l!==""&&n.push([l,c.#e])}else if(c=this.#r[i],!c){if(Object.keys(this.#r).some(l=>l.length>1&&l!==$e&&l!==Je))throw we;if(o)return;c=this.#r[i]=new t}c.insert(a,r,n,s,o)}buildRegExpStr(){let r=Object.keys(this.#r).sort(xu).map(n=>{let s=this.#r[n];return(typeof s.#e=="number"?`(${n})@${s.#e}`:Lu.has(n)?`\\${n}`:n)+s.buildRegExpStr()});return typeof this.#t=="number"&&r.unshift(`#${this.#t}`),r.length===0?"":r.length===1?r[0]:"(?:"+r.join("|")+")"}}});var wo=p((jf,mo)=>{"use strict";var xr=Object.defineProperty,Nu=Object.getOwnPropertyDescriptor,qu=Object.getOwnPropertyNames,Du=Object.prototype.hasOwnProperty,Cu=(t,e)=>{for(var r in e)xr(t,r,{get:e[r],enumerable:!0})},Hu=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of qu(e))!Du.call(t,s)&&s!==r&&xr(t,s,{get:()=>e[s],enumerable:!(n=Nu(e,s))||n.enumerable});return t},Iu=t=>Hu(xr({},"__esModule",{value:!0}),t),Oo={};Cu(Oo,{Trie:()=>Lr});mo.exports=Iu(Oo);var Uu=Ar(),Lr=class{#t={varIndex:0};#e=new Uu.Node;insert(e,r,n){let s=[],o=[];for(let a=0;;){let u=!1;if(e=e.replace(/\{[^}]+\}/g,c=>{let l=`@\\${a}`;return o[a]=[l,c],a++,u=!0,l}),!u)break}let i=e.match(/(?::[^\/]+)|(?:\/\*$)|./g)||[];for(let a=o.length-1;a>=0;a--){let[u]=o[a];for(let c=i.length-1;c>=0;c--)if(i[c].indexOf(u)!==-1){i[c]=i[c].replace(u,o[a][1]);break}}return this.#e.insert(i,r,s,this.#t,n),s}buildRegExp(){let e=this.#e.buildRegExpStr();if(e==="")return[/^$/,[],[]];let r=0,n=[],s=[];return e=e.replace(/#(\d+)|@(\d+)|\.\*\$/g,(o,i,a)=>i!==void 0?(n[++r]=Number(i),"$()"):(a!==void 0&&(s[Number(a)]=++r),"")),[new RegExp(`^${e}`),n,s]}}});var So=p((Sf,jo)=>{"use strict";var qr=Object.defineProperty,Bu=Object.getOwnPropertyDescriptor,$u=Object.getOwnPropertyNames,Ju=Object.prototype.hasOwnProperty,Fu=(t,e)=>{for(var r in e)qr(t,r,{get:e[r],enumerable:!0})},Wu=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of $u(e))!Ju.call(t,s)&&s!==r&&qr(t,s,{get:()=>e[s],enumerable:!(n=Bu(e,s))||n.enumerable});return t},Gu=t=>Wu(qr({},"__esModule",{value:!0}),t),Po={};Fu(Po,{RegExpRouter:()=>Nr});jo.exports=Gu(Po);var O=Be(),Vu=me(),Ku=Ar(),Yu=wo(),Eo=[],zu=[/^$/,[],Object.create(null)],Mo=Object.create(null);function Ro(t){return Mo[t]??=new RegExp(t==="*"?"":`^${t.replace(/\/\*$|([.\\+*[^\]$()])/g,(e,r)=>r?`\\${r}`:"(?:|/.*)")}$`)}function ku(){Mo=Object.create(null)}function Qu(t){let e=new Yu.Trie,r=[];if(t.length===0)return zu;let n=t.map(c=>[!/\*|\/:/.test(c[0]),...c]).sort(([c,l],[f,h])=>c?1:f?-1:l.length-h.length),s=Object.create(null);for(let c=0,l=-1,f=n.length;c[m,Object.create(null)]),Eo]:l++;let _;try{_=e.insert(b,l,h)}catch(m){throw m===Ku.PATH_ERROR?new O.UnsupportedPathError(b):m}h||(r[l]=d.map(([m,Y])=>{let Ge=Object.create(null);for(Y-=1;Y>=0;Y--){let[Ve,D]=_[Y];Ge[Ve]=D}return[m,Ge]}))}let[o,i,a]=e.buildRegExp();for(let c=0,l=r.length;cs.length-n.length))if(Ro(r).test(e))return[...t[r]]}}var Nr=class{name="RegExpRouter";#t;#e;constructor(){this.#t={[O.METHOD_NAME_ALL]:Object.create(null)},this.#e={[O.METHOD_NAME_ALL]:Object.create(null)}}add(e,r,n){let s=this.#t,o=this.#e;if(!s||!o)throw new Error(O.MESSAGE_MATCHER_IS_ALREADY_BUILT);s[e]||[s,o].forEach(u=>{u[e]=Object.create(null),Object.keys(u[O.METHOD_NAME_ALL]).forEach(c=>{u[e][c]=[...u[O.METHOD_NAME_ALL][c]]})}),r==="/*"&&(r="*");let i=(r.match(/\/:/g)||[]).length;if(/\*$/.test(r)){let u=Ro(r);e===O.METHOD_NAME_ALL?Object.keys(s).forEach(c=>{s[c][r]||=Pe(s[c],r)||Pe(s[O.METHOD_NAME_ALL],r)||[]}):s[e][r]||=Pe(s[e],r)||Pe(s[O.METHOD_NAME_ALL],r)||[],Object.keys(s).forEach(c=>{(e===O.METHOD_NAME_ALL||e===c)&&Object.keys(s[c]).forEach(l=>{u.test(l)&&s[c][l].push([n,i])})}),Object.keys(o).forEach(c=>{(e===O.METHOD_NAME_ALL||e===c)&&Object.keys(o[c]).forEach(l=>u.test(l)&&o[c][l].push([n,i]))});return}let a=(0,Vu.checkOptionalParameter)(r)||[r];for(let u=0,c=a.length;u{(e===O.METHOD_NAME_ALL||e===f)&&(o[f][l]||=[...Pe(s[f],l)||Pe(s[O.METHOD_NAME_ALL],l)||[]],o[f][l].push([n,i-c+u+1]))})}}match(e,r){ku();let n=this.#r();return this.match=(s,o)=>{let i=n[s]||n[O.METHOD_NAME_ALL],a=i[2][o];if(a)return a;let u=o.match(i[0]);if(!u)return[[],Eo];let c=u.indexOf("",1);return[i[1][c],u]},this.match(e,r)}#r(){let e=Object.create(null);return Object.keys(this.#e).concat(Object.keys(this.#t)).forEach(r=>{e[r]||=this.#o(r)}),this.#t=this.#e=void 0,e}#o(e){let r=[],n=e===O.METHOD_NAME_ALL;return[this.#t,this.#e].forEach(s=>{let o=s[e]?Object.keys(s[e]).map(i=>[i,s[e][i]]):[];o.length!==0?(n||=!0,r.push(...o)):e!==O.METHOD_NAME_ALL&&r.push(...Object.keys(s[O.METHOD_NAME_ALL]).map(i=>[i,s[O.METHOD_NAME_ALL][i]]))}),n?Qu(r):null}}});var Lo=p((Tf,Ao)=>{"use strict";var Dr=Object.defineProperty,Xu=Object.getOwnPropertyDescriptor,Zu=Object.getOwnPropertyNames,el=Object.prototype.hasOwnProperty,tl=(t,e)=>{for(var r in e)Dr(t,r,{get:e[r],enumerable:!0})},rl=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of Zu(e))!el.call(t,s)&&s!==r&&Dr(t,s,{get:()=>e[s],enumerable:!(n=Xu(e,s))||n.enumerable});return t},sl=t=>rl(Dr({},"__esModule",{value:!0}),t),To={};tl(To,{RegExpRouter:()=>nl.RegExpRouter});Ao.exports=sl(To);var nl=So()});var Do=p((Af,qo)=>{"use strict";var Hr=Object.defineProperty,ol=Object.getOwnPropertyDescriptor,il=Object.getOwnPropertyNames,al=Object.prototype.hasOwnProperty,cl=(t,e)=>{for(var r in e)Hr(t,r,{get:e[r],enumerable:!0})},ul=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of il(e))!al.call(t,s)&&s!==r&&Hr(t,s,{get:()=>e[s],enumerable:!(n=ol(e,s))||n.enumerable});return t},ll=t=>ul(Hr({},"__esModule",{value:!0}),t),No={};cl(No,{SmartRouter:()=>Cr});qo.exports=ll(No);var xo=Be(),Cr=class{name="SmartRouter";#t=[];#e=[];constructor(e){this.#t=e.routers}add(e,r,n){if(!this.#e)throw new Error(xo.MESSAGE_MATCHER_IS_ALREADY_BUILT);this.#e.push([e,r,n])}match(e,r){if(!this.#e)throw new Error("Fatal error");let n=this.#t,s=this.#e,o=n.length,i=0,a;for(;i{"use strict";var Ir=Object.defineProperty,pl=Object.getOwnPropertyDescriptor,fl=Object.getOwnPropertyNames,hl=Object.prototype.hasOwnProperty,dl=(t,e)=>{for(var r in e)Ir(t,r,{get:e[r],enumerable:!0})},_l=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of fl(e))!hl.call(t,s)&&s!==r&&Ir(t,s,{get:()=>e[s],enumerable:!(n=pl(e,s))||n.enumerable});return t},gl=t=>_l(Ir({},"__esModule",{value:!0}),t),Co={};dl(Co,{SmartRouter:()=>vl.SmartRouter});Ho.exports=gl(Co);var vl=Do()});var $o=p((xf,Bo)=>{"use strict";var $r=Object.defineProperty,yl=Object.getOwnPropertyDescriptor,bl=Object.getOwnPropertyNames,Ol=Object.prototype.hasOwnProperty,ml=(t,e)=>{for(var r in e)$r(t,r,{get:e[r],enumerable:!0})},wl=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of bl(e))!Ol.call(t,s)&&s!==r&&$r(t,s,{get:()=>e[s],enumerable:!(n=yl(e,s))||n.enumerable});return t},Pl=t=>wl($r({},"__esModule",{value:!0}),t),Uo={};ml(Uo,{Node:()=>Br});Bo.exports=Pl(Uo);var El=Be(),Ur=me(),Fe=Object.create(null),Br=class t{#t;#e;#r;#o=0;#n=Fe;constructor(e,r,n){if(this.#e=n||Object.create(null),this.#t=[],e&&r){let s=Object.create(null);s[e]={handler:r,possibleKeys:[],score:0},this.#t=[s]}this.#r=[]}insert(e,r,n){this.#o=++this.#o;let s=this,o=(0,Ur.splitRoutingPath)(r),i=[];for(let a=0,u=o.length;ac.indexOf(a)===u),score:this.#o}}),s}#s(e,r,n,s){let o=[];for(let i=0,a=e.#t.length;i1&&n.sort((u,c)=>u.score-c.score),[n.map(({handler:u,params:c})=>[u,c])]}}});var Wo=p((Nf,Fo)=>{"use strict";var Fr=Object.defineProperty,Ml=Object.getOwnPropertyDescriptor,Rl=Object.getOwnPropertyNames,jl=Object.prototype.hasOwnProperty,Sl=(t,e)=>{for(var r in e)Fr(t,r,{get:e[r],enumerable:!0})},Tl=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of Rl(e))!jl.call(t,s)&&s!==r&&Fr(t,s,{get:()=>e[s],enumerable:!(n=Ml(e,s))||n.enumerable});return t},Al=t=>Tl(Fr({},"__esModule",{value:!0}),t),Jo={};Sl(Jo,{TrieRouter:()=>Jr});Fo.exports=Al(Jo);var Ll=me(),xl=$o(),Jr=class{name="TrieRouter";#t;constructor(){this.#t=new xl.Node}add(e,r,n){let s=(0,Ll.checkOptionalParameter)(r);if(s){for(let o=0,i=s.length;o{"use strict";var Wr=Object.defineProperty,Nl=Object.getOwnPropertyDescriptor,ql=Object.getOwnPropertyNames,Dl=Object.prototype.hasOwnProperty,Cl=(t,e)=>{for(var r in e)Wr(t,r,{get:e[r],enumerable:!0})},Hl=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of ql(e))!Dl.call(t,s)&&s!==r&&Wr(t,s,{get:()=>e[s],enumerable:!(n=Nl(e,s))||n.enumerable});return t},Il=t=>Hl(Wr({},"__esModule",{value:!0}),t),Go={};Cl(Go,{TrieRouter:()=>Ul.TrieRouter});Vo.exports=Il(Go);var Ul=Wo()});var ko=p((Df,zo)=>{"use strict";var Vr=Object.defineProperty,Bl=Object.getOwnPropertyDescriptor,$l=Object.getOwnPropertyNames,Jl=Object.prototype.hasOwnProperty,Fl=(t,e)=>{for(var r in e)Vr(t,r,{get:e[r],enumerable:!0})},Wl=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of $l(e))!Jl.call(t,s)&&s!==r&&Vr(t,s,{get:()=>e[s],enumerable:!(n=Bl(e,s))||n.enumerable});return t},Gl=t=>Wl(Vr({},"__esModule",{value:!0}),t),Yo={};Fl(Yo,{Hono:()=>Gr});zo.exports=Gl(Yo);var Vl=vo(),Kl=Lo(),Yl=Io(),zl=Ko(),Gr=class extends Vl.HonoBase{constructor(e={}){super(e),this.router=e.router??new Yl.SmartRouter({routers:[new Kl.RegExpRouter,new zl.TrieRouter]})}}});var Zo=p((Cf,Xo)=>{"use strict";var Kr=Object.defineProperty,kl=Object.getOwnPropertyDescriptor,Ql=Object.getOwnPropertyNames,Xl=Object.prototype.hasOwnProperty,Zl=(t,e)=>{for(var r in e)Kr(t,r,{get:e[r],enumerable:!0})},ep=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let s of Ql(e))!Xl.call(t,s)&&s!==r&&Kr(t,s,{get:()=>e[s],enumerable:!(n=kl(e,s))||n.enumerable});return t},tp=t=>ep(Kr({},"__esModule",{value:!0}),t),Qo={};Zl(Qo,{Hono:()=>rp.Hono});Xo.exports=tp(Qo);var rp=ko()});var ri=p(mt=>{"use strict";Object.defineProperty(mt,"__esModule",{value:!0});mt.HonoProxy=void 0;var E=v(),sp=An(),np=Zo(),ei=E.Metric.fromName("HonoAppLifetime").asResult(),ti=E.Metric.fromName("HonoAppRequest"),Yr=class{server;app=E.LogMetricTraceable.of(new np.Hono).flatMap(E.TraceUtil.withTrace(`AppId = ${crypto.randomUUID()}`)).flatMap(E.TraceUtil.withMetricTrace(ei));constructor(e){this.server=e}async serve(e,r){return this.app.map(n=>E.Either.fromFailable(()=>{let s=n.get();return s.all("*",async o=>n.flatMap(E.TraceUtil.withMetricTrace(ti)).move(o.req).flatMap(i=>E.PenguenoRequest.from(i)).map(i=>this.server.serve(i)).map(E.TraceUtil.promiseify(i=>(i.trace.trace(ti.count.withValue(1)),new Response(i.get().body(),i.get())))).get()),(0,sp.serve)({fetch:o=>s.fetch(o),port:e,hostname:r})})).peek(E.TraceUtil.traceResultingEither()).peek(n=>n.get().mapRight(()=>n.trace.trace(`haii im still listening at http://${r}:${e} ~uwu dont think i forgot`))).map(n=>n.get().mapRight(s=>n.move(s)).flatMapAsync(s=>E.Signals.awaitClose(s))).peek(E.TraceUtil.promiseify(E.TraceUtil.traceResultingEither(ei))).get()}};mt.HonoProxy=Yr});var si=p(he=>{"use strict";var op=he&&he.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),ip=he&&he.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&op(e,t,r)};Object.defineProperty(he,"__esModule",{value:!0});ip(ri(),he)});var ni=p(j=>{"use strict";var ap=j&&j.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),Ee=j&&j.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&ap(e,t,r)};Object.defineProperty(j,"__esModule",{value:!0});Ee(Qs(),j);Ee(Zs(),j);Ee(rn(),j);Ee(ln(),j);Ee(_n(),j);Ee(si(),j)});var v=p(q=>{"use strict";var cp=q&&q.__createBinding||(Object.create?function(t,e,r,n){n===void 0&&(n=r);var s=Object.getOwnPropertyDescriptor(e,r);(!s||("get"in s?!e.__esModule:s.writable||s.configurable))&&(s={enumerable:!0,get:function(){return e[r]}}),Object.defineProperty(t,n,s)}:function(t,e,r,n){n===void 0&&(n=r),t[n]=e[r]}),We=q&&q.__exportStar||function(t,e){for(var r in t)r!=="default"&&!Object.prototype.hasOwnProperty.call(e,r)&&cp(e,t,r)};Object.defineProperty(q,"__esModule",{value:!0});We(ns(),q);We(jt(),q);We(Vt(),q);We(Gs(),q);We(ni(),q)});var zr=Mt(v(),1),up=["fetch_code","ci_pipeline","build_docker_image.js","ansible_playbook.js","checkout_ci.js","npm_publish.js","coolify_webhook.js"],lp=t=>typeof t=="string"&&up.includes(t),oi=t=>!!((0,zr.isObject)(t)&&"arguments"in t&&(0,zr.isObject)(t.arguments)&&"type"in t&&lp(t.type)&&t);var Qr=Mt(v(),1);var kr=class{stages=[];addStage(e){return this.stages.push(e),this}build(){return new Pt(this.stages)}},wt=class extends kr{remoteUrl;refname;constructor(e=process.env.remote,r=process.env.rev,n=process.env.refname){super(),this.remoteUrl=e,this.refname=n,this.addStage({parallelJobs:[{type:"fetch_code",arguments:{remoteUrl:e,checkout:r,path:this.getSourceDestination()}}]})}getSourceDestination(){return this.remoteUrl.replace(".git","").split("/").at(-1)??"src"}getBranch(){return this.refname.split("refs/heads/").at(1)}};var Et=Mt(v(),1);var Pt=class t{serialJobs;constructor(e){this.serialJobs=e}serialize(){return JSON.stringify({serialJobs:this.serialJobs})}static from(e){return Et.Either.fromFailable(()=>JSON.parse(e)).flatMap(r=>ii(r)?Et.Either.right(r):Et.Either.left(new Error("oh noes D: its a bad pipewine :(("))).mapRight(r=>new t(r.serialJobs))}};var pp=t=>(0,Qr.isObject)(t)&&"parallelJobs"in t&&Array.isArray(t.parallelJobs)&&t.parallelJobs.every(e=>oi(e)),ii=t=>(0,Qr.isObject)(t)&&"serialJobs"in t&&Array.isArray(t.serialJobs)&&t.serialJobs.every(e=>pp(e));var fp=()=>{let t=new wt,e=t.getBranch();if(!e||e!=="release")return t.build();let r={type:"npm_publish.js",arguments:{source:"pengueno",registry:"registry.npmjs.org"}};return t.addStage({parallelJobs:[r]}),t.build()},hp=()=>{let t=fp().serialize();process.stdout.write(t)};hp(); diff --git a/.ci/package-lock.json b/.ci/package-lock.json index 050e353..2d35d3e 100644 --- a/.ci/package-lock.json +++ b/.ci/package-lock.json @@ -5,7 +5,7 @@ "packages": { "": { "dependencies": { - "@emprespresso/ci_model": "^0.1.0" + "@emprespresso/ci_model": "^0.2.0" }, "devDependencies": { "esbuild": "0.25.5", @@ -13,17 +13,17 @@ } }, "node_modules/@emprespresso/ci_model": { - "version": "0.1.0", - "resolved": "https://registry.npmjs.org/@emprespresso/ci_model/-/ci_model-0.1.0.tgz", - "integrity": "sha512-Ig1F61q+KiMUBAiAP/rp8a2+WM3RKuz1+qWunHljS2KP28du4kCidHH+8Z/I9RHEi/5gPBTppIL2ZmXlccsRPg==", + "version": "0.2.0", + "resolved": "https://registry.npmjs.org/@emprespresso/ci_model/-/ci_model-0.2.0.tgz", + "integrity": "sha512-yFr0WdAPxf0jhLwdjUUv8KikXVRuT7n81vWt+Km8w6FeKqFtf6h8+ZSIm301X/lEB9x77+CnAN+29NkpyQbPHA==", "dependencies": { - "@emprespresso/pengueno": "^0.0.6" + "@emprespresso/pengueno": "^0.0.13" } }, "node_modules/@emprespresso/pengueno": { - "version": "0.0.6", - "resolved": "https://registry.npmjs.org/@emprespresso/pengueno/-/pengueno-0.0.6.tgz", - "integrity": "sha512-QjyNXJPFp6OlOuk6cH/0yzdFznItofqhB1wF75k/Len5A0BsqvuE1QGU9aZ7AkujGkIpbv21Vm6K21/bmk0S2A==", + "version": "0.0.13", + "resolved": "https://registry.npmjs.org/@emprespresso/pengueno/-/pengueno-0.0.13.tgz", + "integrity": "sha512-eEMwbuF1hJsWNmVp8I5zCmWnIVlgTV+9w6wrkfcX6SMvEliotZ4ROZ/njndbFqzLRSID/+RptfYXLGYw2ZbswQ==", "license": "MIT", "engines": { "node": ">=22.16.0", diff --git a/.ci/package.json b/.ci/package.json index d4ef12a..e50743f 100644 --- a/.ci/package.json +++ b/.ci/package.json @@ -4,7 +4,7 @@ "clean": "rm -rf dist ci.cjs" }, "dependencies": { - "@emprespresso/ci_model": "^0.1.0" + "@emprespresso/ci_model": "^0.2.0" }, "devDependencies": { "esbuild": "0.25.5", -- cgit v1.2.3-70-g09d2