Nicholai 7ed45d15da
Some checks failed
Build and Push to Docker Hub / Push Docker image to Docker Hub (push) Has been cancelled
Build and Push Docker Image / build-and-push (push) Has been cancelled
Dockerized baby
2025-08-19 05:35:01 -06:00

3 lines
31 KiB
JavaScript

"use strict";exports.id=946,exports.ids=[946],exports.modules={2946:(a,b,c)=>{let d,e;c.d(b,{KB:()=>cl});let f=function(a,b){if("function"==typeof a)return function(){return a(arguments)?b.apply(this,arguments):a=>b(a,...arguments)};switch(a){case 0:case 1:throw RangeError(`Invalid arity ${a}`);case 2:return function(a,c){return arguments.length>=2?b(a,c):function(c){return b(c,a)}};case 3:return function(a,c,d){return arguments.length>=3?b(a,c,d):function(d){return b(d,a,c)}};case 4:return function(a,c,d,e){return arguments.length>=4?b(a,c,d,e):function(e){return b(e,a,c,d)}};case 5:return function(a,c,d,e,f){return arguments.length>=5?b(a,c,d,e,f):function(f){return b(f,a,c,d,e)}};default:return function(){if(arguments.length>=a)return b.apply(this,arguments);let c=arguments;return function(a){return b(a,...c)}}}},g=a=>a,h=(e=void 0,()=>e),i="effect/GlobalValue/globalStoreId/3.16.12",j=(a,b)=>(d||(globalThis[i]??=new Map,d=globalThis[i]),d.has(a)||d.set(a,b()),d.get(a)),k=a=>"object"==typeof a&&null!==a,l=f(2,(a,b)=>(a=>k(a)||"function"==typeof a)(a)&&b in a),m=f(2,(a,b)=>l(a,"_tag")&&a._tag===b),n=a=>k(a)&&!Array.isArray(a);Symbol.iterator;class o{constructor(a){this.called=!1,this.self=a}next(a){return this.called?{value:a,done:!0}:(this.called=!0,{value:this.self,done:!1})}return(a){return{value:a,done:!0}}throw(a){throw a}[Symbol.iterator](){return new o(this.self)}}let p=Symbol.for("effect/Utils/YieldWrap");class q{#a;constructor(a){this.#a=a}[p](){return this.#a}}let r=j("effect/Utils/isStructuralRegion",()=>({enabled:!1,tester:void 0})),s={effect_internal_function:a=>a()};s.effect_internal_function(()=>Error().stack)?.includes("effect_internal_function")===!0&&s.effect_internal_function;let t=j(Symbol.for("effect/Hash/randomHashCache"),()=>new WeakMap),u=Symbol.for("effect/Hash"),v=a=>{if(!0===r.enabled)return 0;switch(typeof a){case"number":return A(a);case"bigint":return B(a.toString(10));case"boolean":case"symbol":return B(String(a));case"string":return B(a);case"undefined":return B("undefined");case"function":case"object":if(null===a)return B("null");if(a instanceof Date)return v(a.toISOString());if(a instanceof URL)return v(a.href);else if(z(a))return a[u]();else return w(a);default:throw Error(`BUG: unhandled typeof ${typeof a} - please report an issue at https://github.com/Effect-TS/effect/issues`)}},w=a=>(t.has(a)||t.set(a,A(Math.floor(Math.random()*Number.MAX_SAFE_INTEGER))),t.get(a)),x=a=>b=>53*b^a,y=a=>0xbfffffff&a|a>>>1&0x40000000,z=a=>l(a,u),A=a=>{if(a!=a||a===1/0)return 0;let b=0|a;for(b!==a&&(b^=0xffffffff*a);a>0xffffffff;)b^=a/=0xffffffff;return y(b)},B=a=>{let b=5381,c=a.length;for(;c;)b=33*b^a.charCodeAt(--c);return y(b)},C=function(){if(1==arguments.length){let a=arguments[0];return function(b){return Object.defineProperty(a,u,{value:()=>b,enumerable:!1}),b}}let a=arguments[0],b=arguments[1];return Object.defineProperty(a,u,{value:()=>b,enumerable:!1}),b},D=Symbol.for("effect/Equal");function E(){return 1==arguments.length?a=>F(a,arguments[0]):F(arguments[0],arguments[1])}function F(a,b){if(a===b)return!0;let c=typeof a;if(c!==typeof b)return!1;if("object"===c||"function"===c){if(null!==a&&null!==b){if(G(a)&&G(b))if(v(a)===v(b)&&a[D](b))return!0;else return!!r.enabled&&!!r.tester&&r.tester(a,b);else if(a instanceof Date&&b instanceof Date)return a.toISOString()===b.toISOString();else if(a instanceof URL&&b instanceof URL)return a.href===b.href}if(r.enabled){if(Array.isArray(a)&&Array.isArray(b))return a.length===b.length&&a.every((a,c)=>F(a,b[c]));if(Object.getPrototypeOf(a)===Object.prototype&&Object.getPrototypeOf(a)===Object.prototype){let c=Object.keys(a),d=Object.keys(b);if(c.length===d.length){for(let d of c)if(!(d in b&&F(a[d],b[d])))return!!r.tester&&r.tester(a,b);return!0}}return!!r.tester&&r.tester(a,b)}}return!!r.enabled&&!!r.tester&&r.tester(a,b)}let G=a=>l(a,D),H=Symbol.for("nodejs.util.inspect.custom"),I=a=>{try{let b;if(l(a,"toJSON")&&(b=a.toJSON,"function"==typeof b)&&0===a.toJSON.length)return a.toJSON();if(Array.isArray(a))return a.map(I)}catch{return{}}return N(a)},J=a=>JSON.stringify(a,null,2),K=Symbol.for("effect/Inspectable/Redactable"),L=a=>"object"==typeof a&&null!==a&&K in a,M=j("effect/Inspectable/redactableState",()=>({fiberRefs:void 0})),N=a=>L(a)&&void 0!==M.fiberRefs?a[K](M.fiberRefs):a,O=(a,b)=>{switch(b.length){case 0:return a;case 1:return b[0](a);case 2:return b[1](b[0](a));case 3:return b[2](b[1](b[0](a)));case 4:return b[3](b[2](b[1](b[0](a))));case 5:return b[4](b[3](b[2](b[1](b[0](a)))));case 6:return b[5](b[4](b[3](b[2](b[1](b[0](a))))));case 7:return b[6](b[5](b[4](b[3](b[2](b[1](b[0](a)))))));case 8:return b[7](b[6](b[5](b[4](b[3](b[2](b[1](b[0](a))))))));case 9:return b[8](b[7](b[6](b[5](b[4](b[3](b[2](b[1](b[0](a)))))))));default:{let c=a;for(let a=0,d=b.length;a<d;a++)c=b[a](c);return c}}},P=Symbol.for("effect/Effect"),Q=Symbol.for("effect/Stream"),R=Symbol.for("effect/Sink"),S=Symbol.for("effect/Channel"),T={_R:a=>a,_E:a=>a,_A:a=>a,_V:"3.16.12"},U={[P]:T,[Q]:T,[R]:{_A:a=>a,_In:a=>a,_L:a=>a,_E:a=>a,_R:a=>a},[S]:{_Env:a=>a,_InErr:a=>a,_InElem:a=>a,_InDone:a=>a,_OutErr:a=>a,_OutElem:a=>a,_OutDone:a=>a},[D](a){return this===a},[u](){return C(this,w(this))},[Symbol.iterator](){return new o(new q(this))},pipe(){return O(this,arguments)}},V={[u](){return C(this,((a,b)=>{let c=12289;for(let d=0;d<b.length;d++)c^=function(a,b,c,d,e,f,g,h,i){switch(arguments.length){case 1:return a;case 2:return b(a);case 3:return c(b(a));case 4:return d(c(b(a)));case 5:return e(d(c(b(a))));case 6:return f(e(d(c(b(a)))));case 7:return g(f(e(d(c(b(a))))));case 8:return h(g(f(e(d(c(b(a)))))));case 9:return i(h(g(f(e(d(c(b(a))))))));default:{let a=arguments[0];for(let b=1;b<arguments.length;b++)a=arguments[b](a);return a}}}(B(b[d]),x(v(a[b[d]])));return y(c)})(this,Object.keys(this)))},[D](a){let b=Object.keys(this),c=Object.keys(a);if(b.length!==c.length)return!1;for(let c of b)if(!(c in a&&E(this[c],a[c])))return!1;return!0}},W=Symbol.for("effect/Option"),X={...U,[W]:{_A:a=>a},[H](){return this.toJSON()},toString(){return J(this.toJSON())}},Y=Object.assign(Object.create(X),{_tag:"Some",_op:"Some",[D](a){return _(a)&&ab(a)&&E(this.value,a.value)},[u](){return C(this,x(v(this._tag))(v(this.value)))},toJSON(){return{_id:"Option",_tag:this._tag,value:I(this.value)}}}),Z=v("None"),$=Object.assign(Object.create(X),{_tag:"None",_op:"None",[D]:a=>_(a)&&aa(a),[u]:()=>Z,toJSON(){return{_id:"Option",_tag:this._tag}}}),_=a=>l(a,W),aa=a=>"None"===a._tag,ab=a=>"Some"===a._tag;Symbol.iterator,()=>ac;let ac={next:()=>({done:!0,value:void 0})};Object.fromEntries,(a,b)=>{let c=[];for(let d of ad(a))c.push(b(d,a[d]));return c};let ad=a=>Object.keys(a),ae=a=>Array.isArray(a)?a:[a],af=Symbol.for("effect/Context/Tag"),ag=Symbol.for("effect/Context/Reference"),ah=Symbol.for("effect/STM"),ai={...U,_op:"Tag",[ah]:T,[af]:{_Service:a=>a,_Identifier:a=>a},toString(){return J(this.toJSON())},toJSON(){return{_id:"Tag",key:this.key,stack:this.stack}},[H](){return this.toJSON()},of:a=>a,context(a){return ao(this,a)}},aj={...ai,[ag]:ag},ak=Symbol.for("effect/Context"),al={[ak]:{_Services:a=>a},[D](a){if(an(a)&&this.unsafeMap.size===a.unsafeMap.size){for(let b of this.unsafeMap.keys())if(!a.unsafeMap.has(b)||!E(this.unsafeMap.get(b),a.unsafeMap.get(b)))return!1;return!0}return!1},[u](){return C(this,A(this.unsafeMap.size))},pipe(){return O(this,arguments)},toString(){return J(this.toJSON())},toJSON(){return{_id:"Context",services:Array.from(this.unsafeMap).map(I)}},[H](){return this.toJSON()}},am=a=>{let b=Object.create(al);return b.unsafeMap=a,b},an=a=>l(a,ak),ao=(a,b)=>am(new Map([[a.key,b]])),ap=f(3,(a,b,c)=>{let d=new Map(a.unsafeMap);return d.set(b.key,c),am(d)}),aq=j("effect/Context/defaultValueCache",()=>new Map),ar=a=>{if(aq.has(a.key))return aq.get(a.key);let b=a.defaultValue();return aq.set(a.key,b),b},as=f(2,(a,b)=>{if(!a.unsafeMap.has(b.key)){if(ag in b)return ar(b);throw(a=>{let b=Error(`Service not found${a.key?`: ${String(a.key)}`:""}`);if(a.stack){let c=a.stack.split("\n");if(c.length>2){let a=c[2].match(/at (.*)/);a&&(b.message=b.message+` (defined at ${a[1]})`)}}if(b.stack){let a=b.stack.split("\n");a.splice(1,3),b.stack=a.join("\n")}return b})(b)}return a.unsafeMap.get(b.key)}),at=a=>()=>{let b=Error.stackTraceLimit;Error.stackTraceLimit=2;let c=Error();function d(){}return Error.stackTraceLimit=b,Object.setPrototypeOf(d,ai),d.key=a,Object.defineProperty(d,"stack",{get:()=>c.stack}),d},au=()=>(a,b)=>{let c=Error.stackTraceLimit;Error.stackTraceLimit=2;let d=Error();function e(){}return Error.stackTraceLimit=c,Object.setPrototypeOf(e,aj),e.key=a,e.defaultValue=b.defaultValue,Object.defineProperty(e,"stack",{get:()=>d.stack}),e},av=Symbol.for("effect/Micro"),aw=Symbol.for("effect/Micro/MicroExit"),ax=a=>"object"==typeof a&&null!==a&&av in a,ay=Symbol.for("effect/Micro/MicroCause"),az={_E:g};class aA extends globalThis.Error{constructor(a,b,c){let d,e,f,g=`MicroCause.${a}`;if(b instanceof globalThis.Error){d=`(${g}) ${b.name}`;let a=(e=b.message).split("\n").length;f=b.stack?`(${g}) ${b.stack.split("\n").slice(0,a+3).join("\n")}`:`${d}: ${e}`}else d=g,e=((a,b=2)=>{if("string"==typeof a)return a;try{return"object"==typeof a?((a,b)=>{let c=[],d=JSON.stringify(a,(a,b)=>"object"==typeof b&&null!==b?c.includes(b)?void 0:c.push(b)&&(void 0!==M.fiberRefs&&L(b)?b[K](M.fiberRefs):b):b,b);return c=void 0,d})(a,b):String(a)}catch{return String(a)}})(b,0),f=`${d}: ${e}`;c.length>0&&(f+=`
${c.join("\n ")}`),super(e),this._tag=a,this.traces=c,this[ay]=az,this.name=d,this.stack=f}pipe(){return O(this,arguments)}toString(){return this.stack}[H](){return this.stack}}class aB extends aA{constructor(a,b=[]){super("Fail",a,b),this.error=a}}let aC=(a,b=[])=>new aB(a,b);class aD extends aA{constructor(a,b=[]){super("Die",a,b),this.defect=a}}let aE=(a,b=[])=>new aD(a,b);class aF extends aA{constructor(a=[]){super("Interrupt","interrupted",a)}}let aG=(a=[])=>new aF(a),aH=a=>"Fail"===a._tag,aI=a=>"Interrupt"===a._tag,aJ=a=>"Fail"===a._tag?a.error:"Die"===a._tag?a.defect:a,aK=f(2,(a,b)=>{let c=[...a.traces,b];switch(a._tag){case"Die":return aE(a.defect,c);case"Interrupt":return aG(c);case"Fail":return aC(a.error,c)}}),aL=Symbol.for("effect/Micro/MicroFiber"),aM={_A:g,_E:g};class aN{constructor(a,b=!0){this._stack=[],this._observers=[],this.currentOpCount=0,this._interrupted=!1,this._yielded=void 0,this.context=a,this.interruptible=b,this[aL]=aM}getRef(a){let b;return b=this.context,b.unsafeMap.has(a.key)?b.unsafeMap.get(a.key):ar(a)}addObserver(a){return this._exit?(a(this._exit),h):(this._observers.push(a),()=>{let b=this._observers.indexOf(a);b>=0&&this._observers.splice(b,1)})}unsafeInterrupt(){!this._exit&&(this._interrupted=!0,this.interruptible&&this.evaluate(bl))}unsafePoll(){return this._exit}evaluate(a){if(this._exit)return;if(void 0!==this._yielded){let a=this._yielded;this._yielded=void 0,a()}let b=this.runLoop(a);if(b===aV)return;let c=aO.interruptChildren&&aO.interruptChildren(this);if(void 0!==c)return this.evaluate(bg(c,()=>b));this._exit=b;for(let a=0;a<this._observers.length;a++)this._observers[a](b);this._observers.length=0}runLoop(a){let b=!1,c=a;this.currentOpCount=0;try{for(;;){if(this.currentOpCount++,!b&&this.getRef(bv).shouldYield(this)){b=!0;let a=c;c=bg(a4,()=>a)}if((c=c[aR](this))===aV){let a=this._yielded;if(aw in a)return this._yielded=void 0,a;return aV}}}catch(a){if(!l(c,aR))return bm(`MicroFiber.runLoop: Not a valid effect: ${String(c)}`);return bm(a)}}getCont(a){for(;;){let b=this._stack.pop();if(!b)return;let c=b[aU]&&b[aU](this);if(c)return{[a]:c};if(b[a])return b}}yieldWith(a){return this._yielded=a,aV}children(){return this._children??=new Set}}let aO=j("effect/Micro/fiberMiddleware",()=>({interruptChildren:void 0})),aP=Symbol.for("effect/Micro/identifier"),aQ=Symbol.for("effect/Micro/args"),aR=Symbol.for("effect/Micro/evaluate"),aS=Symbol.for("effect/Micro/successCont"),aT=Symbol.for("effect/Micro/failureCont"),aU=Symbol.for("effect/Micro/ensureCont"),aV=Symbol.for("effect/Micro/Yield"),aW={...U,_op:"Micro",[av]:{_A:g,_E:g,_R:g},pipe(){return O(this,arguments)},[Symbol.iterator](){return new o(new q(this))},toJSON(){return{_id:"Micro",op:this[aP],...aQ in this?{args:this[aQ]}:void 0}},toString(){return J(this)},[H](){return J(this)}};function aX(a){return bm("Micro.evaluate: Not implemented")}let aY=a=>({...aW,[aP]:a.op,[aR]:a.eval??aX,[aS]:a.contA,[aT]:a.contE,[aU]:a.ensure}),aZ=a=>{let b=aY(a);return function(){let c=Object.create(b);return c[aQ]=!1===a.single?arguments:arguments[0],c}},a$=a=>{let b={...aY(a),[aw]:aw,_tag:a.op,get[a.prop](){return this[aQ]},toJSON(){return{_id:"MicroExit",_tag:a.op,[a.prop]:this[aQ]}},[D](b){return bj(b)&&b._tag===a.op&&E(this[aQ],b[aQ])},[u](){return C(this,x(B(a.op))(v(this[aQ])))}};return function(a){let c=Object.create(b);return c[aQ]=a,c[aS]=void 0,c[aT]=void 0,c[aU]=void 0,c}},a_=a$({op:"Success",prop:"value",eval(a){let b=a.getCont(aS);return b?b[aS](this[aQ],a):a.yieldWith(this)}}),a0=a$({op:"Failure",prop:"cause",eval(a){let b=a.getCont(aT);for(;aI(this[aQ])&&b&&a.interruptible;)b=a.getCont(aT);return b?b[aT](this[aQ],a):a.yieldWith(this)}}),a1=a=>a0(aC(a)),a2=aZ({op:"Sync",eval(a){let b=this[aQ](),c=a.getCont(aS);return c?c[aS](b,a):a.yieldWith(bk(b))}}),a3=aZ({op:"Suspend",eval(a){return this[aQ]()}}),a4=aZ({op:"Yield",eval(a){let b=!1;return a.getRef(bv).scheduleTask(()=>{b||a.evaluate(bo)},this[aQ]??0),a.yieldWith(()=>{b=!0})}})(0),a5=a_(void 0),a6=a=>a8(function(b,c){try{a.try(c).then(a=>b(a_(a)),c=>b(a1(a.catch(c))))}catch(c){b(a1(a.catch(c)))}},0!==a.try.length),a7=aZ({op:"WithMicroFiber",eval(a){return this[aQ](a)}}),a8=aZ({op:"Async",single:!1,eval(a){let b=this[aQ][0],c=!1,d=!1,e=this[aQ][1]?new AbortController:void 0,f=b(b=>{c||(c=!0,d?a.evaluate(b):d=b)},e?.signal);return!1!==d?d:(d=!0,a._yielded=()=>{c=!0},void 0===e&&void 0===f||a._stack.push(a9(()=>(c=!0,e?.abort(),f??bo))),aV)}}),a9=aZ({op:"AsyncFinalizer",ensure(a){a.interruptible&&(a.interruptible=!1,a._stack.push(bK(!0)))},contE(a,b){return aI(a)?bg(this[aQ](),()=>a0(a)):a0(a)}}),ba=a=>a8(a,a.length>=2),bb=(...a)=>a3(()=>bc(1===a.length?a[0]():a[1].call(a[0]))),bc=aZ({op:"Iterator",contA(a,b){let c=this[aQ].next(a);if(c.done)return a_(c.value);b._stack.push(this);var d=c.value;if("object"==typeof d&&null!==d&&p in d)return d[p]();throw Error("BUG: yieldWrapGet - please report an issue at https://github.com/Effect-TS/effect/issues")},eval(a){return this[aS](void 0,a)}}),bd=f(2,(a,b)=>bi(a,a=>b)),be=f(2,(a,b)=>bg(a,a=>{let c=ax(b)?b:"function"==typeof b?b(a):b;return ax(c)?c:a_(c)})),bf=f(2,(a,b)=>bg(a,a=>{let c=ax(b)?b:"function"==typeof b?b(a):b;return ax(c)?bd(c,a):a_(a)})),bg=f(2,(a,b)=>{let c=Object.create(bh);return c[aQ]=a,c[aS]=b,c}),bh=aY({op:"OnSuccess",eval(a){return a._stack.push(this),this[aQ]}}),bi=f(2,(a,b)=>bg(a,a=>a_(b(a)))),bj=a=>l(a,aw),bk=a_,bl=a0(aG()),bm=a=>a0(aE(a)),bn=a=>"Failure"===a._tag,bo=bk(void 0),bp="setImmediate"in globalThis?globalThis.setImmediate:a=>setTimeout(a,0);class bq{scheduleTask(a,b){this.tasks.push(a),this.running||(this.running=!0,bp(this.afterScheduled))}runTasks(){let a=this.tasks;this.tasks=[];for(let b=0,c=a.length;b<c;b++)a[b]()}shouldYield(a){return a.currentOpCount>=a.getRef(bt)}flush(){for(;this.tasks.length>0;)this.runTasks()}constructor(){this.tasks=[],this.running=!1,this.afterScheduled=()=>{this.running=!1,this.runTasks()}}}let br=f(2,(a,b)=>a7(c=>{let d=c.context;return c.context=b(d),bH(a,()=>(c.context=d,a5))})),bs=f(3,(a,b,c)=>br(a,ap(b,c)));class bt extends au()("effect/Micro/currentMaxOpsBeforeYield",{defaultValue:()=>2048}){}class bu extends au()("effect/Micro/currentConcurrency",{defaultValue:()=>"unbounded"}){}class bv extends au()("effect/Micro/currentScheduler",{defaultValue:()=>new bq}){}let bw=f(a=>ax(a[0]),(a,b,c)=>bg(a,a=>b(a)?a_(a):a1(c(a)))),bx=f(2,(a,b)=>{let c=Object.create(by);return c[aQ]=a,c[aT]=b,c}),by=aY({op:"OnFailure",eval(a){return a._stack.push(this),this[aQ]}}),bz=f(3,(a,b,c)=>bx(a,a=>b(a)?c(a):a0(a))),bA=f(3,(a,b,c)=>bz(a,b,a=>be(c(a),a0(a)))),bB=f(2,(a,b)=>bA(a,aH,a=>b(a.error))),bC=f(3,(a,b,c)=>bz(a,a=>aH(a)&&b(a.error),a=>c(a.error))),bD=f(3,(a,b,c)=>bC(a,m(b),c)),bE=function(){let a=globalThis.Error.stackTraceLimit;globalThis.Error.stackTraceLimit=2;let b=new globalThis.Error;globalThis.Error.stackTraceLimit=a;let c=a=>c=>bJ(c,c=>a0(function(a,c){let d=b.stack;if(!d)return c;let e=d.split("\n")[2]?.trim().replace(/^at /,"");if(!e)return c;let f=e.match(/\((.*)\)$/);return aK(c,`at ${a} (${f?f[1]:e})`)}(a,c)));return 2==arguments.length?c(arguments[1])(arguments[0]):c(arguments[0])},bF=f(2,(a,b)=>{let c=Object.create(bG);return c[aQ]=a,c[aS]=b.onSuccess,c[aT]=b.onFailure,c}),bG=aY({op:"OnSuccessAndFailure",eval(a){return a._stack.push(this),this[aQ]}}),bH=f(2,(a,b)=>bM(c=>bF(c(a),{onFailure:a=>bg(b(a0(a)),()=>a0(a)),onSuccess:a=>bg(b(bk(a)),()=>a_(a))}))),bI=f(3,(a,b,c)=>bH(a,a=>b(a)?c(a):bo)),bJ=f(2,(a,b)=>bI(a,bn,a=>b(a.cause))),bK=aZ({op:"SetInterruptible",ensure(a){if(a.interruptible=this[aQ],a._interrupted&&a.interruptible)return()=>bl}}),bL=a=>a7(b=>b.interruptible?a:(b.interruptible=!0,b._stack.push(bK(!1)),b._interrupted)?bl:a),bM=a=>a7(b=>b.interruptible?(b.interruptible=!1,b._stack.push(bK(!0)),a(bL)):a(g)),bN=aZ({op:"While",contA(a,b){return(this[aQ].step(a),this[aQ].while())?(b._stack.push(this),this[aQ].body()):bo},eval(a){return this[aQ].while()?(a._stack.push(this),this[aQ].body()):bo}}),bO=(a,b,c=!1,d=!1)=>{let e=new aN(a.context,a.interruptible);return d||(a.children().add(e),e.addObserver(()=>a.children().delete(e))),c?e.evaluate(b):a.getRef(bv).scheduleTask(()=>e.evaluate(b),0),e},bP=(a,b)=>{let c=new aN(bv.context(b?.scheduler??new bq));if(c.evaluate(a),b?.signal)if(b.signal.aborted)c.unsafeInterrupt();else{let a=()=>c.unsafeInterrupt();b.signal.addEventListener("abort",a,{once:!0}),c.addObserver(()=>b.signal.removeEventListener("abort",a))}return c},bQ=(a,b)=>new Promise((c,d)=>{bP(a,b).addObserver(c)}),bR=function(){class a extends globalThis.Error{}return Object.assign(a.prototype,aW,V,{[aP]:"Failure",[aR](){return a1(this)},toString(){return this.message?`${this.name}: ${this.message}`:this.name},toJSON(){return{...this}},[H](){let a=this.stack;return a?`${this.toString()}
${a.split("\n").slice(1).join("\n")}`:this.toString()}}),a}(),bS=class extends bR{constructor(a){super(),a&&Object.assign(this,a)}},bT=a=>{class b extends bS{constructor(...b){super(...b),this._tag=a}}return b.prototype.name=a,b};bT("InvalidRouteConfig"),bT("UnknownFileType"),bT("InvalidFileType"),bT("InvalidFileSize");var bU=class extends bT("InvalidURL"){constructor(a){super({reason:`Failed to parse '${a}' as a URL.`})}};bT("RetryError");var bV=class extends bT("FetchError"){},bW=class extends bT("InvalidJson"){},bX=class extends bT("BadRequestError"){getMessage(){return n(this.json)&&"string"==typeof this.json.message?this.json.message:this.message}},bY=class extends bT("UploadAborted"){},bZ=class extends bT("UploadAborted"){};async function b$(a){let b=await a.text();try{return JSON.parse(b)}catch(a){return console.error(`Error parsing JSON, got '${b}'`,a),Error(`Error parsing JSON, got '${b}'`)}}let b_=a=>a instanceof URL?a:(a=>{let b=(a=>{let b=new bq,c=bP(a,{scheduler:b});return b.flush(),c._exit??bm(c)})(a);if("Failure"===b._tag)throw b.cause;return b.value})((a=>bb(function*(){let b,c="undefined"!=typeof window?window.location.origin:process.env.VERCEL_URL?`https://${process.env.VERCEL_URL}`:"http://localhost:3000",d=yield*(b={try:()=>new URL(a??"/api/uploadthing",c),catch:()=>new bU(a??"/api/uploadthing")},a3(()=>{try{return a_(b.try())}catch(a){return a1(b.catch(a))}}));return"/"===d.pathname&&(d.pathname="/api/uploadthing"),d}))(a));function b0(){}function b1(a,...b){return"function"==typeof a?a(...b):a}let b2={BAD_REQUEST:400,NOT_FOUND:404,FORBIDDEN:403,INTERNAL_SERVER_ERROR:500,INTERNAL_CLIENT_ERROR:500,TOO_LARGE:413,TOO_SMALL:400,TOO_MANY_FILES:400,KEY_TOO_LONG:400,URL_GENERATION_FAILED:500,UPLOAD_FAILED:500,MISSING_ENV:500,INVALID_SERVER_CONFIG:500,FILE_LIMIT_EXCEEDED:500};var b3=class a extends bS{_tag="UploadThingError";name="UploadThingError";cause;code;data;constructor(a){let b="string"==typeof a?{code:"INTERNAL_SERVER_ERROR",message:a}:a;(super({message:b.message??function(a,b){return"string"==typeof a?a:a instanceof Error||a&&"object"==typeof a&&"message"in a&&"string"==typeof a.message?a.message:b??"An unknown error occurred"}(b.cause,b.code)}),this.code=b.code,this.data=b.data,b.cause instanceof Error)?this.cause=b.cause:n(b.cause)&&"number"==typeof b.cause.status&&"string"==typeof b.cause.statusText?this.cause=Error(`Response ${b.cause.status} ${b.cause.statusText}`):"string"==typeof b.cause?this.cause=Error(b.cause):this.cause=b.cause}static toObject(a){return{code:a.code,message:a.message,data:a.data}}static serialize(b){return JSON.stringify(a.toObject(b))}},b4=class extends at("uploadthing/Fetch")(){};let b5=(a,b)=>bg(a7(a=>a_(as(a.context,b4))),c=>{let d=new Headers(b?.headers??[]),e={url:a.toString(),method:b?.method,body:b?.body,headers:Object.fromEntries(d)};return a6({try:e=>c(a,{...b,headers:d,signal:e}),catch:a=>new bV({error:a instanceof Error?{...a,name:a.name,message:a.message,stack:a.stack}:a,input:e})}).pipe(bB(a=>a2(()=>console.error(a.input))),bi(a=>Object.assign(a,{requestUrl:e.url})),bE("fetch"))}),b6=a=>a6({try:async()=>({json:await a.json(),ok:a.ok,status:a.status}),catch:b=>new bW({error:b,input:a.requestUrl})}).pipe(bw(({ok:a})=>a,({json:b,status:c})=>new bX({status:c,message:`Request to ${a.requestUrl} failed with status ${c}`,json:b})),bi(({json:a})=>a),bE("parseJson"));new TextEncoder;var b7="7.7.3";let b8=()=>{let a,b,c=new AbortController;return{promise:new Promise((c,d)=>{a=c,b=d}),ac:c,resolve:a,reject:b}},b9=function(){let a="abcdef0123456789",b=a.length;return function(c){let d="";for(let e=0;e<c;e++)d+=a.charAt(Math.floor(Math.random()*b));return d}}(),ca=()=>{let a=b9(32),b=b9(16);return{b3:`${a}-${b}-01`,traceparent:`00-${a}-${b}-01`}},cb=a=>(b,c)=>bb(function*(){let d,e=(a=>{let b=new URL(a.url),c=new URLSearchParams(b.search);return c.set("actionType",a.actionType),c.set("slug",a.slug),b.search=c.toString(),b})({url:a.url,slug:a.endpoint,actionType:b}),f=new Headers((yield*a8(function(a,b){d(b).then(b=>a(a_(b)),b=>a(bm(b)))},0!==(d=async()=>"function"==typeof a.headers?await a.headers():a.headers).length)));return a.package&&f.set("x-uploadthing-package",a.package),f.set("x-uploadthing-version",b7),f.set("Content-Type","application/json"),f.set("b3",a.traceHeaders.b3),f.set("traceparent",a.traceHeaders.traceparent),yield*b5(e,{method:"POST",body:JSON.stringify(c),headers:f}).pipe(be(b6),bi(g),bD("FetchError",a=>a1(new b3({code:"INTERNAL_CLIENT_ERROR",message:`Failed to report event "${b}" to UploadThing server`,cause:a}))),bD("BadRequestError",a=>a1(new b3({code:function(a){for(let[b,c]of Object.entries(b2))if(c===a)return b;return"INTERNAL_SERVER_ERROR"}(a.status),message:a.getMessage(),cause:a.json}))),bD("InvalidJson",a=>a1(new b3({code:"INTERNAL_CLIENT_ERROR",message:"Failed to parse response from UploadThing server",cause:a}))))}),cc=a=>{console.warn(`⚠️ [uploadthing][deprecated] ${a}`)},cd=(a,b,c)=>b5(b.url,{method:"HEAD",headers:c.traceHeaders}).pipe(bi(({headers:a})=>parseInt(a.get("x-ut-range-start")??"0",10)),bf(a=>c.onUploadProgress?.({delta:a,loaded:a})),bg(d=>((a,b,c,d)=>ba(e=>{let f=new XMLHttpRequest;f.open("PUT",c.url,!0),f.setRequestHeader("Range",`bytes=${b}-`),f.setRequestHeader("x-uploadthing-version",b7),f.setRequestHeader("b3",d.traceHeaders.b3),f.setRequestHeader("traceparent",d.traceHeaders.traceparent),f.responseType="json";let g=0;f.upload.addEventListener("progress",({loaded:a})=>{let b=a-g;d.onUploadProgress?.({loaded:a,delta:b}),g=a}),f.addEventListener("load",()=>{f.status>=200&&f.status<300&&n(f.response)?l(f.response,"error")?e(new b3({code:"UPLOAD_FAILED",message:String(f.response.error),data:f.response})):e(a_(f.response)):e(new b3({code:"UPLOAD_FAILED",message:`XHR failed ${f.status} ${f.statusText}`,data:f.response}))}),f.addEventListener("error",()=>{e(new b3({code:"UPLOAD_FAILED"}))});let h=new FormData;return"uri"in a?h.append("file",{uri:a.uri,type:a.type,name:a.name,...b>0&&{range:b}}):h.append("file",b>0?a.slice(b):a),f.send(h),a2(()=>f.abort())}))(a,d,b,{traceHeaders:c.traceHeaders,onUploadProgress:a=>c.onUploadProgress?.({delta:a.delta,loaded:a.loaded+d})})),bi(g),bi(c=>({name:a.name,size:a.size,key:b.key,lastModified:a.lastModified,serverData:c.serverData,get url(){return cc("`file.url` is deprecated and will be removed in uploadthing v9. Use `file.ufsUrl` instead."),c.url},get appUrl(){return cc("`file.appUrl` is deprecated and will be removed in uploadthing v9. Use `file.ufsUrl` instead."),c.appUrl},ufsUrl:c.ufsUrl,customId:b.customId,type:a.type,fileHash:c.fileHash}))),ce=a=>{let b=new Proxy(b0,{get:(a,b)=>b});return{uploadFiles:(c,d)=>{let e="function"==typeof c?c(b):c,f=a?.fetch??window.fetch;return((a,b)=>{let c=ca(),d=cb({endpoint:String(a),package:b.package,url:b.url,headers:b.headers,traceHeaders:c}),e=b.files.reduce((a,b)=>a+b.size,0),f=0;return bg(d("upload",{input:"input"in b?b.input:null,files:b.files.map(a=>({name:a.name,size:a.size,type:a.type,lastModified:a.lastModified}))}),a=>((a,b,c)=>a7(d=>{let e=c?.concurrency==="inherit"?d.getRef(bu):c?.concurrency??1,f="unbounded"===e?1/0:Math.max(1,e),g=(a=>Array.isArray(a)?a:Array.from(a))(a),h=g.length;if(0===h)return c?.discard?a5:a_([]);let i=c?.discard?void 0:Array(h),j=0;return 1===f?bd(bN({while:()=>j<g.length,body:()=>b(g[j],j),step:i?a=>i[j++]=a:a=>j++}),i):ba(a=>{let c,e=new Set,k=0,l=0,m=!1,n=!1;return!function o(){for(m=!0;k<f&&j<h;){let p=j,q=g[p];j++,k++;try{let g=bO(d,b(q,p),!0,!0);e.add(g),g.addObserver(b=>{e.delete(g),n||("Failure"===b._tag?void 0===c&&(c=b,h=j,e.forEach(a=>a.unsafeInterrupt())):void 0!==i&&(i[p]=b.value),l++,k--,l===h?a(c??a_(i)):!m&&k<f&&o())})}catch(a){c=bm(a),h=j,e.forEach(a=>a.unsafeInterrupt())}}m=!1}(),a3(()=>(n=!0,j=h,(a=>a3(()=>{for(let b of a)b.unsafeInterrupt();let b=a[Symbol.iterator](),c=a3(()=>{let a=b.next();for(;!a.done;){if(a.value.unsafePoll()){a=b.next();continue}let d=a.value;return ba(a=>{d.addObserver(b=>{a(c)})})}return bo});return c}))(e)))})}))(a,(a,d)=>bg(a2(()=>b.onUploadBegin?.({file:b.files[d].name})),()=>cd(b.files[d],a,{traceHeaders:c,onUploadProgress:a=>{f+=a.delta,b.onUploadProgress?.({file:b.files[d],progress:a.loaded/b.files[d].size*100,loaded:a.loaded,delta:a.delta,totalLoaded:f,totalProgress:f/e})}})),{concurrency:6}))})(e,{...d,skipPolling:{},url:b_(a?.url),package:a?.package??"uploadthing/client",input:d.input}).pipe(bs(b4,f),a=>bQ(a,d.signal&&{signal:d.signal})).then(a=>{if("Success"===a._tag)return a.value;if("Interrupt"===a.cause._tag)throw new bZ;throw aJ(a.cause)})},createUpload:async(c,d)=>{let e,f=new Map,g="function"==typeof c?c(b):c,h=ca(),i=cb({endpoint:String(g),package:a?.package??"uploadthing/client",url:b_(a?.url),headers:d.headers,traceHeaders:h}),j=a?.fetch??window.fetch,k=await bQ(i("upload",{input:"input"in d?d.input:null,files:d.files.map(a=>({name:a.name,size:a.size,type:a.type,lastModified:a.lastModified}))}).pipe(bs(b4,j)),e).then(a=>{if("Failure"===a._tag)throw a.cause;return a.value}),l=d.files.reduce((a,b)=>a+b.size,0),m=0,n=(a,b)=>cd(a,b,{traceHeaders:h,onUploadProgress:b=>{m+=b.delta,d.onUploadProgress?.({...b,file:a,progress:Math.round(b.loaded/a.size*100),totalLoaded:m,totalProgress:Math.round(m/l*100)})}}).pipe(bs(b4,j));for(let[a,b]of k.entries()){let c=d.files[a];if(!c)continue;let e=b8();f.set(c,{deferred:e,presigned:b}),bQ(n(c,b),{signal:e.ac.signal}).then(a=>{if("Success"===a._tag)return e.resolve(a.value);if("Interrupt"===a.cause._tag)throw new bY;throw aJ(a.cause)}).catch(a=>{a instanceof bY||e.reject(a)})}return{pauseUpload:a=>{for(let b of ae(a??d.files)){let a=f.get(b);if(!a)return;if(a.deferred.ac.signal.aborted)throw new bZ;a.deferred.ac.abort()}},resumeUpload:a=>{for(let b of ae(a??d.files)){let a=f.get(b);if(!a)throw"No upload found";a.deferred.ac=new AbortController,bQ(n(b,a.presigned),{signal:a.deferred.ac.signal}).then(b=>{if("Success"===b._tag)return a.deferred.resolve(b.value);if("Interrupt"===b.cause._tag)throw new bY;throw aJ(b.cause)}).catch(b=>{b instanceof bY||a.deferred.reject(b)})}},done:async a=>{let b=[];for(let c of ae(a??d.files)){let a=f.get(c);if(!a)throw"No upload found";b.push(a.deferred.promise)}let c=await Promise.all(b);return a?c[0]:c}}},routeRegistry:b}};var cf=c(43210),cg={uploadthing:"^7.2.0"};let ch="undefined"!=typeof window?cf.useInsertionEffect:()=>void 0;function ci(){throw Error("INVALID_USEEVENT_INVOCATION: the callback from useEvent cannot be invoked before the component has mounted.")}var cj=function(a,b,c){let d=(0,cf.useRef)({}),e=(0,cf.useRef)(!1),f={error:void 0,data:void 0},[g,h]=(0,cf.useReducer)((a,b)=>{switch(b.type){case"loading":return{...f};case"fetched":return{...f,data:b.payload};case"error":return{...f,error:b.payload};default:return a}},f);return(0,cf.useEffect)(()=>{if(b)return e.current=!1,(async()=>{if(h({type:"loading"}),d.current[b])return h({type:"fetched",payload:d.current[b]});try{let f=await a(b,c);if(!f.ok)throw Error(f.statusText);let g=await b$(f);if(g instanceof Error)throw g;if(d.current[b]=g,e.current)return;h({type:"fetched",payload:g})}catch(a){if(e.current)return;h({type:"error",payload:a})}})(),()=>{e.current=!0}},[b]),g};let ck=function(a,b,c,d){let e=d?.uploadProgressGranularity??"coarse",{uploadFiles:f,routeRegistry:g}=ce({fetch:c,url:a,package:"@uploadthing/react"}),[h,i]=(0,cf.useState)(!1),j=(0,cf.useRef)(0),k=(0,cf.useRef)(new Map);return{startUpload:function(a){let b=cf.useRef(ci);ch(()=>{b.current=a},[a]);let c=cf.useRef(null);return c.current??=function(){return b.current.apply(this,arguments)},c.current}(async(...a)=>{let c=await d?.onBeforeUploadBegin?.(a[0])??a[0],g=a[1];i(!0),c.forEach(a=>k.current.set(a,0)),d?.onUploadProgress?.(0);try{let a=await f(b,{signal:d?.signal,headers:d?.headers,files:c,onUploadProgress:a=>{var b;if(!d?.onUploadProgress)return;k.current.set(a.file,a.progress);let c=0;k.current.forEach(a=>{c+=a});let f=(b=Math.min(100,c/k.current.size),"all"===e?b:"fine"===e?Math.round(b):10*Math.floor(b/10));f!==j.current&&(d.onUploadProgress(f),j.current=f)},onUploadBegin({file:a}){d?.onUploadBegin&&d.onUploadBegin(a)},input:g});return await d?.onClientUploadComplete?.(a),a}catch(b){let a;if(b instanceof bZ)throw b;b instanceof b3?a=b:console.error("Something went wrong. Please contact UploadThing and provide the following cause:",(a=new b3({code:"INTERNAL_CLIENT_ERROR",message:"Something went wrong. Please report this to UploadThing.",cause:b})).cause instanceof Error?a.cause.toString():a.cause),await d?.onUploadError?.(a)}finally{i(!1),k.current=new Map,j.current=0}}),isUploading:h,routeConfig:((a,b,c)=>{let d=globalThis.__UPLOADTHING,{data:e}=cj(a,d?void 0:b.href);return(d??e)?.find(a=>a.slug===c)?.config})(c,a,b1(b,g))}},cl=a=>{!function(a,b,c){!function(a,b){let c=/(\d+)\.?(\d+)?\.?(\d+)?/,d=c.exec(a);if(!d?.[0])throw Error(`Invalid semver requirement: ${a}`);let e=c.exec(b);if(!e?.[0])throw Error(`Invalid semver to check: ${b}`);let[f,g,h,i]=d,[j,k,l,m]=e;return a.startsWith("^")?g===k&&(!h||!l||!(h>l)):a.startsWith("~")?g===k&&h===l:g===k&&h===l&&i===m}(b,c)&&console.warn(`!!!WARNING::: ${a} requires "uploadthing@${b}", but version "${c}" is installed`)}("@uploadthing/react",cg.uploadthing,b7);let b=a?.fetch??globalThis.fetch,c=b_(a?.url),d=ce({fetch:b,url:c,package:"@uploadthing/react"});return{useUploadThing:function(a,d){return ck(c,a,b,d)},...d,getRouteConfig:function(a){let b=globalThis.__UPLOADTHING,c=b1(a,d.routeRegistry),e=b?.find(a=>a.slug===c)?.config;if(!e)throw Error(`No config found for endpoint "${c.toString()}". Please make sure to use the NextSSRPlugin in your Next.js app.`);return e}}}}};