1 line
33 KiB
JavaScript
1 line
33 KiB
JavaScript
try{!function(){var e="undefined"!=typeof window?window:"undefined"!=typeof global?global:"undefined"!=typeof globalThis?globalThis:"undefined"!=typeof self?self:{},t=(new e.Error).stack;t&&(e._sentryDebugIds=e._sentryDebugIds||{},e._sentryDebugIds[t]="b9637577-87b0-44f6-a133-738313d8bb2a",e._sentryDebugIdIdentifier="sentry-dbid-b9637577-87b0-44f6-a133-738313d8bb2a")}()}catch(e){}"use strict";(self.webpackChunk_N_E=self.webpackChunk_N_E||[]).push([[8897],{38897:(e,t,r)=>{let n,s;r.d(t,{KB:()=>r_});let a=function(e,t){if("function"==typeof e)return function(){return e(arguments)?t.apply(this,arguments):e=>t(e,...arguments)};switch(e){case 0:case 1:throw RangeError("Invalid arity ".concat(e));case 2:return function(e,r){return arguments.length>=2?t(e,r):function(r){return t(r,e)}};case 3:return function(e,r,n){return arguments.length>=3?t(e,r,n):function(n){return t(n,e,r)}};case 4:return function(e,r,n,s){return arguments.length>=4?t(e,r,n,s):function(s){return t(s,e,r,n)}};case 5:return function(e,r,n,s,a){return arguments.length>=5?t(e,r,n,s,a):function(a){return t(a,e,r,n,s)}};default:return function(){if(arguments.length>=e)return t.apply(this,arguments);let r=arguments;return function(e){return t(e,...r)}}}},i=e=>e,o=(s=void 0,()=>s),l="effect/GlobalValue/globalStoreId/".concat("3.16.12"),u=(e,t)=>{if(!n){var r;null!=(r=globalThis)[l]||(r[l]=new Map),n=globalThis[l]}return n.has(e)||n.set(e,t()),n.get(e)},c=e=>"object"==typeof e&&null!==e,f=a(2,(e,t)=>(e=>c(e)||"function"==typeof e)(e)&&t in e),d=a(2,(e,t)=>f(e,"_tag")&&e._tag===t),h=e=>c(e)&&!Array.isArray(e);var p,g=r(94971),y=r(95920),b=r(86266);Symbol.iterator;class v{next(e){return this.called?{value:e,done:!0}:(this.called=!0,{value:this.self,done:!1})}return(e){return{value:e,done:!0}}throw(e){throw e}[Symbol.iterator](){return new v(this.self)}constructor(e){this.called=!1,this.self=e}}let _=Symbol.for("effect/Utils/YieldWrap");var m=new WeakMap;class E{[_](){return(0,g._)(this,m)}constructor(e){(0,y._)(this,m,{writable:!0,value:void 0}),(0,b._)(this,m,e)}}let w=u("effect/Utils/isStructuralRegion",()=>({enabled:!1,tester:void 0})),S={effect_internal_function:e=>e()};(null==(p=S.effect_internal_function(()=>Error().stack))?void 0:p.includes("effect_internal_function"))===!0&&S.effect_internal_function;let O=u(Symbol.for("effect/Hash/randomHashCache"),()=>new WeakMap),k=Symbol.for("effect/Hash"),R=e=>{if(!0===w.enabled)return 0;switch(typeof e){case"number":return U(e);case"bigint":return x(e.toString(10));case"boolean":case"symbol":return x(String(e));case"string":return x(e);case"undefined":return x("undefined");case"function":case"object":if(null===e)return x("null");if(e instanceof Date)return R(e.toISOString());if(e instanceof URL)return R(e.href);else if(M(e))return e[k]();else return T(e);default:throw Error("BUG: unhandled typeof ".concat(typeof e," - please report an issue at https://github.com/Effect-TS/effect/issues"))}},T=e=>(O.has(e)||O.set(e,U(Math.floor(Math.random()*Number.MAX_SAFE_INTEGER))),O.get(e)),I=e=>t=>53*t^e,N=e=>0xbfffffff&e|e>>>1&0x40000000,M=e=>f(e,k),U=e=>{if(e!=e||e===1/0)return 0;let t=0|e;for(t!==e&&(t^=0xffffffff*e);e>0xffffffff;)t^=e/=0xffffffff;return N(t)},x=e=>{let t=5381,r=e.length;for(;r;)t=33*t^e.charCodeAt(--r);return N(t)},A=function(){if(1==arguments.length){let e=arguments[0];return function(t){return Object.defineProperty(e,k,{value:()=>t,enumerable:!1}),t}}let e=arguments[0],t=arguments[1];return Object.defineProperty(e,k,{value:()=>t,enumerable:!1}),t},L=Symbol.for("effect/Equal");function j(){return 1==arguments.length?e=>C(e,arguments[0]):C(arguments[0],arguments[1])}function C(e,t){if(e===t)return!0;let r=typeof e;if(r!==typeof t)return!1;if("object"===r||"function"===r){if(null!==e&&null!==t){if(P(e)&&P(t))if(R(e)===R(t)&&e[L](t))return!0;else return!!w.enabled&&!!w.tester&&w.tester(e,t);else if(e instanceof Date&&t instanceof Date)return e.toISOString()===t.toISOString();else if(e instanceof URL&&t instanceof URL)return e.href===t.href}if(w.enabled){if(Array.isArray(e)&&Array.isArray(t))return e.length===t.length&&e.every((e,r)=>C(e,t[r]));if(Object.getPrototypeOf(e)===Object.prototype&&Object.getPrototypeOf(e)===Object.prototype){let r=Object.keys(e),n=Object.keys(t);if(r.length===n.length){for(let n of r)if(!(n in t&&C(e[n],t[n])))return!!w.tester&&w.tester(e,t);return!0}}return!!w.tester&&w.tester(e,t)}}return!!w.enabled&&!!w.tester&&w.tester(e,t)}let P=e=>f(e,L),F=Symbol.for("nodejs.util.inspect.custom"),D=e=>{try{let t;if(f(e,"toJSON")&&(t=e.toJSON,"function"==typeof t)&&0===e.toJSON.length)return e.toJSON();if(Array.isArray(e))return e.map(D)}catch(e){return{}}return B(e)},J=e=>JSON.stringify(e,null,2),$=function(e){let t=arguments.length>1&&void 0!==arguments[1]?arguments[1]:2;if("string"==typeof e)return e;try{return"object"==typeof e?H(e,t):String(e)}catch(t){return String(e)}},H=(e,t)=>{let r=[],n=JSON.stringify(e,(e,t)=>"object"==typeof t&&null!==t?r.includes(t)?void 0:r.push(t)&&(void 0!==q.fiberRefs&&z(t)?t[V](q.fiberRefs):t):t,t);return r=void 0,n},V=Symbol.for("effect/Inspectable/Redactable"),z=e=>"object"==typeof e&&null!==e&&V in e,q=u("effect/Inspectable/redactableState",()=>({fiberRefs:void 0})),B=e=>z(e)&&void 0!==q.fiberRefs?e[V](q.fiberRefs):e,G=(e,t)=>{switch(t.length){case 0:return e;case 1:return t[0](e);case 2:return t[1](t[0](e));case 3:return t[2](t[1](t[0](e)));case 4:return t[3](t[2](t[1](t[0](e))));case 5:return t[4](t[3](t[2](t[1](t[0](e)))));case 6:return t[5](t[4](t[3](t[2](t[1](t[0](e))))));case 7:return t[6](t[5](t[4](t[3](t[2](t[1](t[0](e)))))));case 8:return t[7](t[6](t[5](t[4](t[3](t[2](t[1](t[0](e))))))));case 9:return t[8](t[7](t[6](t[5](t[4](t[3](t[2](t[1](t[0](e)))))))));default:{let r=e;for(let e=0,n=t.length;e<n;e++)r=t[e](r);return r}}},W=Symbol.for("effect/Effect"),Y=Symbol.for("effect/Stream"),X=Symbol.for("effect/Sink"),K=Symbol.for("effect/Channel"),Q={_R:e=>e,_E:e=>e,_A:e=>e,_V:"3.16.12"},Z={[W]:Q,[Y]:Q,[X]:{_A:e=>e,_In:e=>e,_L:e=>e,_E:e=>e,_R:e=>e},[K]:{_Env:e=>e,_InErr:e=>e,_InElem:e=>e,_InDone:e=>e,_OutErr:e=>e,_OutElem:e=>e,_OutDone:e=>e},[L](e){return this===e},[k](){return A(this,T(this))},[Symbol.iterator](){return new v(new E(this))},pipe(){return G(this,arguments)}},ee={[k](){return A(this,((e,t)=>{let r=12289;for(let n=0;n<t.length;n++)r^=function(e,t,r,n,s,a,i,o,l){switch(arguments.length){case 1:return e;case 2:return t(e);case 3:return r(t(e));case 4:return n(r(t(e)));case 5:return s(n(r(t(e))));case 6:return a(s(n(r(t(e)))));case 7:return i(a(s(n(r(t(e))))));case 8:return o(i(a(s(n(r(t(e)))))));case 9:return l(o(i(a(s(n(r(t(e))))))));default:{let e=arguments[0];for(let t=1;t<arguments.length;t++)e=arguments[t](e);return e}}}(x(t[n]),I(R(e[t[n]])));return N(r)})(this,Object.keys(this)))},[L](e){let t=Object.keys(this),r=Object.keys(e);if(t.length!==r.length)return!1;for(let r of t)if(!(r in e&&j(this[r],e[r])))return!1;return!0}},et=Symbol.for("effect/Option"),er={...Z,[et]:{_A:e=>e},[F](){return this.toJSON()},toString(){return J(this.toJSON())}},en=Object.assign(Object.create(er),{_tag:"Some",_op:"Some",[L](e){return ei(e)&&el(e)&&j(this.value,e.value)},[k](){return A(this,I(R(this._tag))(R(this.value)))},toJSON(){return{_id:"Option",_tag:this._tag,value:D(this.value)}}}),es=R("None"),ea=Object.assign(Object.create(er),{_tag:"None",_op:"None",[L]:e=>ei(e)&&eo(e),[k]:()=>es,toJSON(){return{_id:"Option",_tag:this._tag}}}),ei=e=>f(e,et),eo=e=>"None"===e._tag,el=e=>"Some"===e._tag;Symbol.iterator,()=>eu;let eu={next:()=>({done:!0,value:void 0})};Object.fromEntries,(e,t)=>{let r=[];for(let n of ec(e))r.push(t(n,e[n]));return r};let ec=e=>Object.keys(e),ef=e=>Array.isArray(e)?e:[e],ed=Symbol.for("effect/Context/Tag"),eh=Symbol.for("effect/Context/Reference"),ep=Symbol.for("effect/STM"),eg={...Z,_op:"Tag",[ep]:Q,[ed]:{_Service:e=>e,_Identifier:e=>e},toString(){return J(this.toJSON())},toJSON(){return{_id:"Tag",key:this.key,stack:this.stack}},[F](){return this.toJSON()},of:e=>e,context(e){return eE(this,e)}},ey={...eg,[eh]:eh},eb=Symbol.for("effect/Context"),ev={[eb]:{_Services:e=>e},[L](e){if(em(e)&&this.unsafeMap.size===e.unsafeMap.size){for(let t of this.unsafeMap.keys())if(!e.unsafeMap.has(t)||!j(this.unsafeMap.get(t),e.unsafeMap.get(t)))return!1;return!0}return!1},[k](){return A(this,U(this.unsafeMap.size))},pipe(){return G(this,arguments)},toString(){return J(this.toJSON())},toJSON(){return{_id:"Context",services:Array.from(this.unsafeMap).map(D)}},[F](){return this.toJSON()}},e_=e=>{let t=Object.create(ev);return t.unsafeMap=e,t},em=e=>f(e,eb),eE=(e,t)=>e_(new Map([[e.key,t]])),ew=a(3,(e,t,r)=>{let n=new Map(e.unsafeMap);return n.set(t.key,r),e_(n)}),eS=u("effect/Context/defaultValueCache",()=>new Map),eO=e=>{if(eS.has(e.key))return eS.get(e.key);let t=e.defaultValue();return eS.set(e.key,t),t},ek=a(2,(e,t)=>{if(!e.unsafeMap.has(t.key)){if(eh in t)return eO(t);throw(e=>{let t=Error("Service not found".concat(e.key?": ".concat(String(e.key)):""));if(e.stack){let r=e.stack.split("\n");if(r.length>2){let e=r[2].match(/at (.*)/);e&&(t.message=t.message+" (defined at ".concat(e[1],")"))}}if(t.stack){let e=t.stack.split("\n");e.splice(1,3),t.stack=e.join("\n")}return t})(t)}return e.unsafeMap.get(t.key)}),eR=e=>()=>{let t=Error.stackTraceLimit;Error.stackTraceLimit=2;let r=Error();function n(){}return Error.stackTraceLimit=t,Object.setPrototypeOf(n,eg),n.key=e,Object.defineProperty(n,"stack",{get:()=>r.stack}),n},eT=()=>(e,t)=>{let r=Error.stackTraceLimit;Error.stackTraceLimit=2;let n=Error();function s(){}return Error.stackTraceLimit=r,Object.setPrototypeOf(s,ey),s.key=e,s.defaultValue=t.defaultValue,Object.defineProperty(s,"stack",{get:()=>n.stack}),s},eI=Symbol.for("effect/Micro"),eN=Symbol.for("effect/Micro/MicroExit"),eM=e=>"object"==typeof e&&null!==e&&eI in e,eU=Symbol.for("effect/Micro/MicroCause"),ex={_E:i};class eA extends globalThis.Error{pipe(){return G(this,arguments)}toString(){return this.stack}[F](){return this.stack}constructor(e,t,r){let n,s,a,i="MicroCause.".concat(e);if(t instanceof globalThis.Error){n="(".concat(i,") ").concat(t.name);let e=(s=t.message).split("\n").length;a=t.stack?"(".concat(i,") ").concat(t.stack.split("\n").slice(0,e+3).join("\n")):"".concat(n,": ").concat(s)}else n=i,s=$(t,0),a="".concat(n,": ").concat(s);r.length>0&&(a+="\n ".concat(r.join("\n "))),super(s),this._tag=e,this.traces=r,this[eU]=ex,this.name=n,this.stack=a}}class eL extends eA{constructor(e,t=[]){super("Fail",e,t),this.error=e}}let ej=function(e){let t=arguments.length>1&&void 0!==arguments[1]?arguments[1]:[];return new eL(e,t)};class eC extends eA{constructor(e,t=[]){super("Die",e,t),this.defect=e}}let eP=function(e){let t=arguments.length>1&&void 0!==arguments[1]?arguments[1]:[];return new eC(e,t)};class eF extends eA{constructor(e=[]){super("Interrupt","interrupted",e)}}let eD=function(){let e=arguments.length>0&&void 0!==arguments[0]?arguments[0]:[];return new eF(e)},eJ=e=>"Fail"===e._tag,e$=e=>"Interrupt"===e._tag,eH=e=>"Fail"===e._tag?e.error:"Die"===e._tag?e.defect:e,eV=a(2,(e,t)=>{let r=[...e.traces,t];switch(e._tag){case"Die":return eP(e.defect,r);case"Interrupt":return eD(r);case"Fail":return ej(e.error,r)}}),ez=Symbol.for("effect/Micro/MicroFiber"),eq={_A:i,_E:i};class eB{getRef(e){let t;return t=this.context,t.unsafeMap.has(e.key)?t.unsafeMap.get(e.key):eO(e)}addObserver(e){return this._exit?(e(this._exit),o):(this._observers.push(e),()=>{let t=this._observers.indexOf(e);t>=0&&this._observers.splice(t,1)})}unsafeInterrupt(){!this._exit&&(this._interrupted=!0,this.interruptible&&this.evaluate(tv))}unsafePoll(){return this._exit}evaluate(e){if(this._exit)return;if(void 0!==this._yielded){let e=this._yielded;this._yielded=void 0,e()}let t=this.runLoop(e);if(t===e0)return;let r=eG.interruptChildren&&eG.interruptChildren(this);if(void 0!==r)return this.evaluate(th(r,()=>t));this._exit=t;for(let e=0;e<this._observers.length;e++)this._observers[e](t);this._observers.length=0}runLoop(e){let t=!1,r=e;this.currentOpCount=0;try{for(;;){if(this.currentOpCount++,!t&&this.getRef(tI).shouldYield(this)){t=!0;let e=r;r=th(tt,()=>e)}if((r=r[eX](this))===e0){let e=this._yielded;if(eN in e)return this._yielded=void 0,e;return e0}}}catch(e){if(!f(r,eX))return t_("MicroFiber.runLoop: Not a valid effect: ".concat(String(r)));return t_(e)}}getCont(e){for(;;){let t=this._stack.pop();if(!t)return;let r=t[eZ]&&t[eZ](this);if(r)return{[e]:r};if(t[e])return t}}yieldWith(e){return this._yielded=e,e0}children(){var e;return null!=(e=this._children)?e:this._children=new Set}constructor(e,t=!0){this._stack=[],this._observers=[],this.currentOpCount=0,this._interrupted=!1,this._yielded=void 0,this.context=e,this.interruptible=t,this[ez]=eq}}let eG=u("effect/Micro/fiberMiddleware",()=>({interruptChildren:void 0})),eW=Symbol.for("effect/Micro/identifier"),eY=Symbol.for("effect/Micro/args"),eX=Symbol.for("effect/Micro/evaluate"),eK=Symbol.for("effect/Micro/successCont"),eQ=Symbol.for("effect/Micro/failureCont"),eZ=Symbol.for("effect/Micro/ensureCont"),e0=Symbol.for("effect/Micro/Yield"),e1={...Z,_op:"Micro",[eI]:{_A:i,_E:i,_R:i},pipe(){return G(this,arguments)},[Symbol.iterator](){return new v(new E(this))},toJSON(){return{_id:"Micro",op:this[eW],...eY in this?{args:this[eY]}:void 0}},toString(){return J(this)},[F](){return J(this)}};function e3(e){return t_("Micro.evaluate: Not implemented")}let e2=e=>{var t;return{...e1,[eW]:e.op,[eX]:null!=(t=e.eval)?t:e3,[eK]:e.contA,[eQ]:e.contE,[eZ]:e.ensure}},e4=e=>{let t=e2(e);return function(){let r=Object.create(t);return r[eY]=!1===e.single?arguments:arguments[0],r}},e9=e=>{let t={...e2(e),[eN]:eN,_tag:e.op,get[e.prop](){return this[eY]},toJSON(){return{_id:"MicroExit",_tag:e.op,[e.prop]:this[eY]}},[L](t){return ty(t)&&t._tag===e.op&&j(this[eY],t[eY])},[k](){return A(this,I(x(e.op))(R(this[eY])))}};return function(e){let r=Object.create(t);return r[eY]=e,r[eK]=void 0,r[eQ]=void 0,r[eZ]=void 0,r}},e5=e9({op:"Success",prop:"value",eval(e){let t=e.getCont(eK);return t?t[eK](this[eY],e):e.yieldWith(this)}}),e6=e9({op:"Failure",prop:"cause",eval(e){let t=e.getCont(eQ);for(;e$(this[eY])&&t&&e.interruptible;)t=e.getCont(eQ);return t?t[eQ](this[eY],e):e.yieldWith(this)}}),e7=e=>e6(ej(e)),e8=e4({op:"Sync",eval(e){let t=this[eY](),r=e.getCont(eK);return r?r[eK](t,e):e.yieldWith(tb(t))}}),te=e4({op:"Suspend",eval(e){return this[eY]()}}),tt=e4({op:"Yield",eval(e){var t;let r=!1;return e.getRef(tI).scheduleTask(()=>{r||e.evaluate(tE)},null!=(t=this[eY])?t:0),e.yieldWith(()=>{r=!0})}})(0),tr=e5(void 0),tn=e=>ta(function(t,r){try{e.try(r).then(e=>t(e5(e)),r=>t(e7(e.catch(r))))}catch(r){t(e7(e.catch(r)))}},0!==e.try.length),ts=e4({op:"WithMicroFiber",eval(e){return this[eY](e)}}),ta=e4({op:"Async",single:!1,eval(e){let t=this[eY][0],r=!1,n=!1,s=this[eY][1]?new AbortController:void 0,a=t(t=>{r||(r=!0,n?e.evaluate(t):n=t)},null==s?void 0:s.signal);return!1!==n?n:(n=!0,e._yielded=()=>{r=!0},void 0===s&&void 0===a||e._stack.push(ti(()=>(r=!0,null==s||s.abort(),null!=a?a:tE))),e0)}}),ti=e4({op:"AsyncFinalizer",ensure(e){e.interruptible&&(e.interruptible=!1,e._stack.push(tV(!0)))},contE(e,t){return e$(e)?th(this[eY](),()=>e6(e)):e6(e)}}),to=e=>ta(e,e.length>=2),tl=function(){for(var e=arguments.length,t=Array(e),r=0;r<e;r++)t[r]=arguments[r];return te(()=>tu(1===t.length?t[0]():t[1].call(t[0])))},tu=e4({op:"Iterator",contA(e,t){let r=this[eY].next(e);if(r.done)return e5(r.value);t._stack.push(this);var n=r.value;if("object"==typeof n&&null!==n&&_ in n)return n[_]();throw Error("BUG: ".concat("yieldWrapGet"," - please report an issue at https://github.com/Effect-TS/effect/issues"))},eval(e){return this[eK](void 0,e)}}),tc=a(2,(e,t)=>tg(e,e=>t)),tf=a(2,(e,t)=>th(e,e=>{let r=eM(t)?t:"function"==typeof t?t(e):t;return eM(r)?r:e5(r)})),td=a(2,(e,t)=>th(e,e=>{let r=eM(t)?t:"function"==typeof t?t(e):t;return eM(r)?tc(r,e):e5(e)})),th=a(2,(e,t)=>{let r=Object.create(tp);return r[eY]=e,r[eK]=t,r}),tp=e2({op:"OnSuccess",eval(e){return e._stack.push(this),this[eY]}}),tg=a(2,(e,t)=>th(e,e=>e5(t(e)))),ty=e=>f(e,eN),tb=e5,tv=e6(eD()),t_=e=>e6(eP(e)),tm=e=>"Failure"===e._tag,tE=tb(void 0),tw="setImmediate"in globalThis?globalThis.setImmediate:e=>setTimeout(e,0);class tS{scheduleTask(e,t){this.tasks.push(e),this.running||(this.running=!0,tw(this.afterScheduled))}runTasks(){let e=this.tasks;this.tasks=[];for(let t=0,r=e.length;t<r;t++)e[t]()}shouldYield(e){return e.currentOpCount>=e.getRef(tR)}flush(){for(;this.tasks.length>0;)this.runTasks()}constructor(){this.tasks=[],this.running=!1,this.afterScheduled=()=>{this.running=!1,this.runTasks()}}}let tO=a(2,(e,t)=>ts(r=>{let n=r.context;return r.context=t(n),tJ(e,()=>(r.context=n,tr))})),tk=a(3,(e,t,r)=>tO(e,ew(t,r)));class tR extends eT()("effect/Micro/currentMaxOpsBeforeYield",{defaultValue:()=>2048}){}class tT extends eT()("effect/Micro/currentConcurrency",{defaultValue:()=>"unbounded"}){}class tI extends eT()("effect/Micro/currentScheduler",{defaultValue:()=>new tS}){}let tN=a(e=>eM(e[0]),(e,t,r)=>th(e,e=>t(e)?e5(e):e7(r(e)))),tM=a(2,(e,t)=>{let r=Object.create(tU);return r[eY]=e,r[eQ]=t,r}),tU=e2({op:"OnFailure",eval(e){return e._stack.push(this),this[eY]}}),tx=a(3,(e,t,r)=>tM(e,e=>t(e)?r(e):e6(e))),tA=a(3,(e,t,r)=>tx(e,t,e=>tf(r(e),e6(e)))),tL=a(2,(e,t)=>tA(e,eJ,e=>t(e.error))),tj=a(3,(e,t,r)=>tx(e,e=>eJ(e)&&t(e.error),e=>r(e.error))),tC=a(3,(e,t,r)=>tj(e,d(t),r)),tP=function(){let e=globalThis.Error.stackTraceLimit;globalThis.Error.stackTraceLimit=2;let t=new globalThis.Error;globalThis.Error.stackTraceLimit=e;let r=e=>r=>tH(r,r=>e6(function(e,r){var n;let s=t.stack;if(!s)return r;let a=null==(n=s.split("\n")[2])?void 0:n.trim().replace(/^at /,"");if(!a)return r;let i=a.match(/\((.*)\)$/);return eV(r,"at ".concat(e," (").concat(i?i[1]:a,")"))}(e,r)));return 2==arguments.length?r(arguments[1])(arguments[0]):r(arguments[0])},tF=a(2,(e,t)=>{let r=Object.create(tD);return r[eY]=e,r[eK]=t.onSuccess,r[eQ]=t.onFailure,r}),tD=e2({op:"OnSuccessAndFailure",eval(e){return e._stack.push(this),this[eY]}}),tJ=a(2,(e,t)=>tq(r=>tF(r(e),{onFailure:e=>th(t(e6(e)),()=>e6(e)),onSuccess:e=>th(t(tb(e)),()=>e5(e))}))),t$=a(3,(e,t,r)=>tJ(e,e=>t(e)?r(e):tE)),tH=a(2,(e,t)=>t$(e,tm,e=>t(e.cause))),tV=e4({op:"SetInterruptible",ensure(e){if(e.interruptible=this[eY],e._interrupted&&e.interruptible)return()=>tv}}),tz=e=>ts(t=>t.interruptible?e:(t.interruptible=!0,t._stack.push(tV(!1)),t._interrupted)?tv:e),tq=e=>ts(t=>t.interruptible?(t.interruptible=!1,t._stack.push(tV(!0)),e(tz)):e(i)),tB=e4({op:"While",contA(e,t){return(this[eY].step(e),this[eY].while())?(t._stack.push(this),this[eY].body()):tE},eval(e){return this[eY].while()?(e._stack.push(this),this[eY].body()):tE}}),tG=function(e,t){let r=arguments.length>2&&void 0!==arguments[2]&&arguments[2],n=arguments.length>3&&void 0!==arguments[3]&&arguments[3],s=new eB(e.context,e.interruptible);return n||(e.children().add(s),s.addObserver(()=>e.children().delete(s))),r?s.evaluate(t):e.getRef(tI).scheduleTask(()=>s.evaluate(t),0),s},tW=(e,t)=>{var r;let n=new eB(tI.context(null!=(r=null==t?void 0:t.scheduler)?r:new tS));if(n.evaluate(e),null==t?void 0:t.signal)if(t.signal.aborted)n.unsafeInterrupt();else{let e=()=>n.unsafeInterrupt();t.signal.addEventListener("abort",e,{once:!0}),n.addObserver(()=>t.signal.removeEventListener("abort",e))}return n},tY=(e,t)=>new Promise((r,n)=>{tW(e,t).addObserver(r)}),tX=function(){class e extends globalThis.Error{}return Object.assign(e.prototype,e1,ee,{[eW]:"Failure",[eX](){return e7(this)},toString(){return this.message?"".concat(this.name,": ").concat(this.message):this.name},toJSON(){return{...this}},[F](){let e=this.stack;return e?"".concat(this.toString(),"\n").concat(e.split("\n").slice(1).join("\n")):this.toString()}}),e}(),tK=class extends tX{constructor(e){super(),e&&Object.assign(this,e)}},tQ=e=>{class t extends tK{constructor(...t){super(...t),this._tag=e}}return t.prototype.name=e,t};var tZ=r(49509);tQ("InvalidRouteConfig"),tQ("UnknownFileType"),tQ("InvalidFileType"),tQ("InvalidFileSize");var t0=class extends tQ("InvalidURL"){constructor(e){super({reason:`Failed to parse '${e}' as a URL.`})}};tQ("RetryError");var t1=class extends tQ("FetchError"){},t3=class extends tQ("InvalidJson"){},t2=class extends tQ("BadRequestError"){getMessage(){return h(this.json)&&"string"==typeof this.json.message?this.json.message:this.message}},t4=class extends tQ("UploadAborted"){},t9=class extends tQ("UploadAborted"){};async function t5(e){let t=await e.text();try{return JSON.parse(t)}catch(e){return console.error(`Error parsing JSON, got '${t}'`,e),Error(`Error parsing JSON, got '${t}'`)}}let t6=e=>e instanceof URL?e:(e=>{let t=(e=>{var t;let r=new tS,n=tW(e,{scheduler:r});return r.flush(),null!=(t=n._exit)?t:t_(n)})(e);if("Failure"===t._tag)throw t.cause;return t.value})((e=>tl(function*(){let t,r="undefined"!=typeof window?window.location.origin:tZ.env.VERCEL_URL?`https://${tZ.env.VERCEL_URL}`:"http://localhost:3000",n=yield*(t={try:()=>new URL(e??"/api/uploadthing",r),catch:()=>new t0(e??"/api/uploadthing")},te(()=>{try{return e5(t.try())}catch(e){return e7(t.catch(e))}}));return"/"===n.pathname&&(n.pathname="/api/uploadthing"),n}))(e));function t7(){}function t8(e,...t){return"function"==typeof e?e(...t):e}let re={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 rt=class e extends tK{_tag="UploadThingError";name="UploadThingError";cause;code;data;constructor(e){let t="string"==typeof e?{code:"INTERNAL_SERVER_ERROR",message:e}:e;(super({message:t.message??function(e,t){return"string"==typeof e?e:e instanceof Error||e&&"object"==typeof e&&"message"in e&&"string"==typeof e.message?e.message:t??"An unknown error occurred"}(t.cause,t.code)}),this.code=t.code,this.data=t.data,t.cause instanceof Error)?this.cause=t.cause:h(t.cause)&&"number"==typeof t.cause.status&&"string"==typeof t.cause.statusText?this.cause=Error(`Response ${t.cause.status} ${t.cause.statusText}`):"string"==typeof t.cause?this.cause=Error(t.cause):this.cause=t.cause}static toObject(e){return{code:e.code,message:e.message,data:e.data}}static serialize(t){return JSON.stringify(e.toObject(t))}},rr=class extends eR("uploadthing/Fetch")(){};let rn=(e,t)=>th(ts(e=>e5(ek(e.context,rr))),r=>{let n=new Headers(t?.headers??[]),s={url:e.toString(),method:t?.method,body:t?.body,headers:Object.fromEntries(n)};return tn({try:s=>r(e,{...t,headers:n,signal:s}),catch:e=>new t1({error:e instanceof Error?{...e,name:e.name,message:e.message,stack:e.stack}:e,input:s})}).pipe(tL(e=>e8(()=>console.error(e.input))),tg(e=>Object.assign(e,{requestUrl:s.url})),tP("fetch"))}),rs=e=>tn({try:async()=>({json:await e.json(),ok:e.ok,status:e.status}),catch:t=>new t3({error:t,input:e.requestUrl})}).pipe(tN(({ok:e})=>e,({json:t,status:r})=>new t2({status:r,message:`Request to ${e.requestUrl} failed with status ${r}`,json:t})),tg(({json:e})=>e),tP("parseJson"));new TextEncoder;var ra="7.7.3";let ri=()=>{let e,t,r=new AbortController;return{promise:new Promise((r,n)=>{e=r,t=n}),ac:r,resolve:e,reject:t}},ro=function(){let e="abcdef0123456789",t=e.length;return function(r){let n="";for(let s=0;s<r;s++)n+=e.charAt(Math.floor(Math.random()*t));return n}}(),rl=()=>{let e=ro(32),t=ro(16);return{b3:`${e}-${t}-01`,traceparent:`00-${e}-${t}-01`}},ru=e=>(t,r)=>tl(function*(){let n,s=(e=>{let t=new URL(e.url),r=new URLSearchParams(t.search);return r.set("actionType",e.actionType),r.set("slug",e.slug),t.search=r.toString(),t})({url:e.url,slug:e.endpoint,actionType:t}),a=new Headers((yield*ta(function(e,t){n(t).then(t=>e(e5(t)),t=>e(t_(t)))},0!==(n=async()=>"function"==typeof e.headers?await e.headers():e.headers).length)));return e.package&&a.set("x-uploadthing-package",e.package),a.set("x-uploadthing-version",ra),a.set("Content-Type","application/json"),a.set("b3",e.traceHeaders.b3),a.set("traceparent",e.traceHeaders.traceparent),yield*rn(s,{method:"POST",body:JSON.stringify(r),headers:a}).pipe(tf(rs),tg(i),tC("FetchError",e=>e7(new rt({code:"INTERNAL_CLIENT_ERROR",message:`Failed to report event "${t}" to UploadThing server`,cause:e}))),tC("BadRequestError",e=>e7(new rt({code:function(e){for(let[t,r]of Object.entries(re))if(r===e)return t;return"INTERNAL_SERVER_ERROR"}(e.status),message:e.getMessage(),cause:e.json}))),tC("InvalidJson",e=>e7(new rt({code:"INTERNAL_CLIENT_ERROR",message:"Failed to parse response from UploadThing server",cause:e}))))}),rc=e=>{console.warn(`⚠️ [uploadthing][deprecated] ${e}`)},rf=(e,t,r)=>rn(t.url,{method:"HEAD",headers:r.traceHeaders}).pipe(tg(({headers:e})=>parseInt(e.get("x-ut-range-start")??"0",10)),td(e=>r.onUploadProgress?.({delta:e,loaded:e})),th(n=>((e,t,r,n)=>to(s=>{let a=new XMLHttpRequest;a.open("PUT",r.url,!0),a.setRequestHeader("Range",`bytes=${t}-`),a.setRequestHeader("x-uploadthing-version",ra),a.setRequestHeader("b3",n.traceHeaders.b3),a.setRequestHeader("traceparent",n.traceHeaders.traceparent),a.responseType="json";let i=0;a.upload.addEventListener("progress",({loaded:e})=>{let t=e-i;n.onUploadProgress?.({loaded:e,delta:t}),i=e}),a.addEventListener("load",()=>{a.status>=200&&a.status<300&&h(a.response)?f(a.response,"error")?s(new rt({code:"UPLOAD_FAILED",message:String(a.response.error),data:a.response})):s(e5(a.response)):s(new rt({code:"UPLOAD_FAILED",message:`XHR failed ${a.status} ${a.statusText}`,data:a.response}))}),a.addEventListener("error",()=>{s(new rt({code:"UPLOAD_FAILED"}))});let o=new FormData;return"uri"in e?o.append("file",{uri:e.uri,type:e.type,name:e.name,...t>0&&{range:t}}):o.append("file",t>0?e.slice(t):e),a.send(o),e8(()=>a.abort())}))(e,n,t,{traceHeaders:r.traceHeaders,onUploadProgress:e=>r.onUploadProgress?.({delta:e.delta,loaded:e.loaded+n})})),tg(i),tg(r=>({name:e.name,size:e.size,key:t.key,lastModified:e.lastModified,serverData:r.serverData,get url(){return rc("`file.url` is deprecated and will be removed in uploadthing v9. Use `file.ufsUrl` instead."),r.url},get appUrl(){return rc("`file.appUrl` is deprecated and will be removed in uploadthing v9. Use `file.ufsUrl` instead."),r.appUrl},ufsUrl:r.ufsUrl,customId:t.customId,type:e.type,fileHash:r.fileHash}))),rd=e=>{let t=new Proxy(t7,{get:(e,t)=>t});return{uploadFiles:(r,n)=>{let s="function"==typeof r?r(t):r,a=e?.fetch??window.fetch;return((e,t)=>{let r=rl(),n=ru({endpoint:String(e),package:t.package,url:t.url,headers:t.headers,traceHeaders:r}),s=t.files.reduce((e,t)=>e+t.size,0),a=0;return th(n("upload",{input:"input"in t?t.input:null,files:t.files.map(e=>({name:e.name,size:e.size,type:e.type,lastModified:e.lastModified}))}),e=>((e,t,r)=>ts(n=>{var s;let a=(null==r?void 0:r.concurrency)==="inherit"?n.getRef(tT):null!=(s=null==r?void 0:r.concurrency)?s:1,i="unbounded"===a?1/0:Math.max(1,a),o=(e=>Array.isArray(e)?e:Array.from(e))(e),l=o.length;if(0===l)return(null==r?void 0:r.discard)?tr:e5([]);let u=(null==r?void 0:r.discard)?void 0:Array(l),c=0;return 1===i?tc(tB({while:()=>c<o.length,body:()=>t(o[c],c),step:u?e=>u[c++]=e:e=>c++}),u):to(e=>{let r,s=new Set,a=0,f=0,d=!1,h=!1;return!function p(){for(d=!0;a<i&&c<l;){let g=c,y=o[g];c++,a++;try{let o=tG(n,t(y,g),!0,!0);s.add(o),o.addObserver(t=>{s.delete(o),h||("Failure"===t._tag?void 0===r&&(r=t,l=c,s.forEach(e=>e.unsafeInterrupt())):void 0!==u&&(u[g]=t.value),f++,a--,f===l?e(null!=r?r:e5(u)):!d&&a<i&&p())})}catch(e){r=t_(e),l=c,s.forEach(e=>e.unsafeInterrupt())}}d=!1}(),te(()=>(h=!0,c=l,(e=>te(()=>{for(let t of e)t.unsafeInterrupt();let t=e[Symbol.iterator](),r=te(()=>{let e=t.next();for(;!e.done;){if(e.value.unsafePoll()){e=t.next();continue}let n=e.value;return to(e=>{n.addObserver(t=>{e(r)})})}return tE});return r}))(s)))})}))(e,(e,n)=>th(e8(()=>t.onUploadBegin?.({file:t.files[n].name})),()=>rf(t.files[n],e,{traceHeaders:r,onUploadProgress:e=>{a+=e.delta,t.onUploadProgress?.({file:t.files[n],progress:e.loaded/t.files[n].size*100,loaded:e.loaded,delta:e.delta,totalLoaded:a,totalProgress:a/s})}})),{concurrency:6}))})(s,{...n,skipPolling:{},url:t6(e?.url),package:e?.package??"uploadthing/client",input:n.input}).pipe(tk(rr,a),e=>tY(e,n.signal&&{signal:n.signal})).then(e=>{if("Success"===e._tag)return e.value;if("Interrupt"===e.cause._tag)throw new t9;throw eH(e.cause)})},createUpload:async(r,n)=>{let s,a=new Map,i="function"==typeof r?r(t):r,o=rl(),l=ru({endpoint:String(i),package:e?.package??"uploadthing/client",url:t6(e?.url),headers:n.headers,traceHeaders:o}),u=e?.fetch??window.fetch,c=await tY(l("upload",{input:"input"in n?n.input:null,files:n.files.map(e=>({name:e.name,size:e.size,type:e.type,lastModified:e.lastModified}))}).pipe(tk(rr,u)),s).then(e=>{if("Failure"===e._tag)throw e.cause;return e.value}),f=n.files.reduce((e,t)=>e+t.size,0),d=0,h=(e,t)=>rf(e,t,{traceHeaders:o,onUploadProgress:t=>{d+=t.delta,n.onUploadProgress?.({...t,file:e,progress:Math.round(t.loaded/e.size*100),totalLoaded:d,totalProgress:Math.round(d/f*100)})}}).pipe(tk(rr,u));for(let[e,t]of c.entries()){let r=n.files[e];if(!r)continue;let s=ri();a.set(r,{deferred:s,presigned:t}),tY(h(r,t),{signal:s.ac.signal}).then(e=>{if("Success"===e._tag)return s.resolve(e.value);if("Interrupt"===e.cause._tag)throw new t4;throw eH(e.cause)}).catch(e=>{e instanceof t4||s.reject(e)})}return{pauseUpload:e=>{for(let t of ef(e??n.files)){let e=a.get(t);if(!e)return;if(e.deferred.ac.signal.aborted)throw new t9;e.deferred.ac.abort()}},resumeUpload:e=>{for(let t of ef(e??n.files)){let e=a.get(t);if(!e)throw"No upload found";e.deferred.ac=new AbortController,tY(h(t,e.presigned),{signal:e.deferred.ac.signal}).then(t=>{if("Success"===t._tag)return e.deferred.resolve(t.value);if("Interrupt"===t.cause._tag)throw new t4;throw eH(t.cause)}).catch(t=>{t instanceof t4||e.deferred.reject(t)})}},done:async e=>{let t=[];for(let r of ef(e??n.files)){let e=a.get(r);if(!e)throw"No upload found";t.push(e.deferred.promise)}let r=await Promise.all(t);return e?r[0]:r}}},routeRegistry:t}};var rh=r(12115),rp={uploadthing:"^7.2.0"};let rg="undefined"!=typeof window?rh.useInsertionEffect:()=>void 0;function ry(){throw Error("INVALID_USEEVENT_INVOCATION: the callback from useEvent cannot be invoked before the component has mounted.")}var rb=function(e,t,r){let n=(0,rh.useRef)({}),s=(0,rh.useRef)(!1),a={error:void 0,data:void 0},[i,o]=(0,rh.useReducer)((e,t)=>{switch(t.type){case"loading":return{...a};case"fetched":return{...a,data:t.payload};case"error":return{...a,error:t.payload};default:return e}},a);return(0,rh.useEffect)(()=>{if(t)return s.current=!1,(async()=>{if(o({type:"loading"}),n.current[t])return o({type:"fetched",payload:n.current[t]});try{let a=await e(t,r);if(!a.ok)throw Error(a.statusText);let i=await t5(a);if(i instanceof Error)throw i;if(n.current[t]=i,s.current)return;o({type:"fetched",payload:i})}catch(e){if(s.current)return;o({type:"error",payload:e})}})(),()=>{s.current=!0}},[t]),i};let rv=function(e,t,r,n){let s=n?.uploadProgressGranularity??"coarse",{uploadFiles:a,routeRegistry:i}=rd({fetch:r,url:e,package:"@uploadthing/react"}),[o,l]=(0,rh.useState)(!1),u=(0,rh.useRef)(0),c=(0,rh.useRef)(new Map);return{startUpload:function(e){let t=rh.useRef(ry);rg(()=>{t.current=e},[e]);let r=rh.useRef(null);return r.current??=function(){return t.current.apply(this,arguments)},r.current}(async(...e)=>{let r=await n?.onBeforeUploadBegin?.(e[0])??e[0],i=e[1];l(!0),r.forEach(e=>c.current.set(e,0)),n?.onUploadProgress?.(0);try{let e=await a(t,{signal:n?.signal,headers:n?.headers,files:r,onUploadProgress:e=>{var t;if(!n?.onUploadProgress)return;c.current.set(e.file,e.progress);let r=0;c.current.forEach(e=>{r+=e});let a=(t=Math.min(100,r/c.current.size),"all"===s?t:"fine"===s?Math.round(t):10*Math.floor(t/10));a!==u.current&&(n.onUploadProgress(a),u.current=a)},onUploadBegin({file:e}){n?.onUploadBegin&&n.onUploadBegin(e)},input:i});return await n?.onClientUploadComplete?.(e),e}catch(t){let e;if(t instanceof t9)throw t;t instanceof rt?e=t:console.error("Something went wrong. Please contact UploadThing and provide the following cause:",(e=new rt({code:"INTERNAL_CLIENT_ERROR",message:"Something went wrong. Please report this to UploadThing.",cause:t})).cause instanceof Error?e.cause.toString():e.cause),await n?.onUploadError?.(e)}finally{l(!1),c.current=new Map,u.current=0}}),isUploading:o,routeConfig:((e,t,r)=>{let n=globalThis.__UPLOADTHING,{data:s}=rb(e,n?void 0:t.href);return(n??s)?.find(e=>e.slug===r)?.config})(r,e,t8(t,i))}},r_=e=>{!function(e,t,r){!function(e,t){let r=/(\d+)\.?(\d+)?\.?(\d+)?/,n=r.exec(e);if(!n?.[0])throw Error(`Invalid semver requirement: ${e}`);let s=r.exec(t);if(!s?.[0])throw Error(`Invalid semver to check: ${t}`);let[a,i,o,l]=n,[u,c,f,d]=s;return e.startsWith("^")?i===c&&(!o||!f||!(o>f)):e.startsWith("~")?i===c&&o===f:i===c&&o===f&&l===d}(t,r)&&console.warn(`!!!WARNING::: ${e} requires "uploadthing@${t}", but version "${r}" is installed`)}("@uploadthing/react",rp.uploadthing,ra);let t=e?.fetch??globalThis.fetch,r=t6(e?.url),n=rd({fetch:t,url:r,package:"@uploadthing/react"});return{useUploadThing:function(e,n){return rv(r,e,t,n)},...n,getRouteConfig:function(e){let t=globalThis.__UPLOADTHING,r=t8(e,n.routeRegistry),s=t?.find(e=>e.slug===r)?.config;if(!s)throw Error(`No config found for endpoint "${r.toString()}". Please make sure to use the NextSSRPlugin in your Next.js app.`);return s}}}},43969:(e,t,r)=>{r.d(t,{_:()=>n});function n(e,t,r){if(!t.has(e))throw TypeError("attempted to "+r+" private field on non-instance");return t.get(e)}},86266:(e,t,r)=>{r.d(t,{_:()=>s});var n=r(43969);function s(e,t,r){var s=(0,n._)(e,t,"set");if(s.set)s.set.call(e,r);else{if(!s.writable)throw TypeError("attempted to set read only private field");s.value=r}return r}},94971:(e,t,r)=>{r.d(t,{_:()=>s});var n=r(43969);function s(e,t){var r=(0,n._)(e,t,"get");return r.get?r.get.call(e):r.value}},95920:(e,t,r)=>{r.d(t,{_:()=>n});function n(e,t,r){if(t.has(e))throw TypeError("Cannot initialize the same private elements twice on an object");t.set(e,r)}}}]); |