schemas/libraries/effect/download_compiled/minified.jscontent_copy
Copy to clipboardCopy to clipboard
const e=e=>typeof e==`function`,t=function(e,t){if(typeof e==`function`)return function(){return e(arguments)?t.apply(this,arguments):e=>t(e,...arguments)};switch(e){case 0:case 1:throw RangeError(`Invalid arity ${e}`);case 2:return function(e,n){return arguments.length>=2?t(e,n):function(n){return t(n,e)}};case 3:return function(e,n,r){return arguments.length>=3?t(e,n,r):function(r){return t(r,e,n)}};case 4:return function(e,n,r,i){return arguments.length>=4?t(e,n,r,i):function(i){return t(i,e,n,r)}};case 5:return function(e,n,r,i,a){return arguments.length>=5?t(e,n,r,i,a):function(a){return t(a,e,n,r,i)}};default:return function(){if(arguments.length>=e)return t.apply(this,arguments);let n=arguments;return function(e){return t(e,...n)}}}},n=e=>e,r=e=>()=>e,i=r(!0),a=r(!1),o=r(void 0),s=o;function c(e,t,n,r,i,a,o,s,c){switch(arguments.length){case 1:return e;case 2:return t(e);case 3:return n(t(e));case 4:return r(n(t(e)));case 5:return i(r(n(t(e))));case 6:return a(i(r(n(t(e)))));case 7:return o(a(i(r(n(t(e))))));case 8:return s(o(a(i(r(n(t(e)))))));case 9:return c(s(o(a(i(r(n(t(e))))))));default:{let e=arguments[0];for(let t=1;t<arguments.length;t++)e=arguments[t](e);return e}}}const l=e=>(t,n)=>t===n||e(t,n),u=(e,t)=>e===t,d=t(2,(e,t)=>l((n,r)=>e(t(n),t(r)))),f=d(u,e=>e.getTime()),p=e=>l((t,n)=>{if(t.length!==n.length)return!1;for(let r=0;r<t.length;r++)if(!e(t[r],n[r]))return!1;return!0}),m=`effect/GlobalValue`;let h;const g=(e,t)=>(h||=(globalThis[m]??=new Map,globalThis[m]),h.has(e)||h.set(e,t()),h.get(e)),ee=e=>!!e,_=e=>typeof e==`string`,te=e=>typeof e==`number`,ne=e=>typeof e==`boolean`,re=e=>typeof e==`bigint`,ie=e=>typeof e==`symbol`,ae=e,oe=e=>e===void 0,se=e=>!1,ce=e=>typeof e==`object`&&!!e,le=e=>ce(e)||ae(e),v=t(2,(e,t)=>le(e)&&t in e),ue=t(2,(e,t)=>v(e,`_tag`)&&e._tag===t),de=e=>e==null,fe=e=>e!=null,pe=e=>e instanceof Uint8Array,me=e=>e instanceof Date,he=e=>typeof e==`string`||v(e,Symbol.iterator),ge=e=>ce(e)&&!Array.isArray(e),_e=e=>v(e,`then`)&&ae(e.then),ve=e=>`BUG: ${e} - please report an issue at https://github.com/Effect-TS/effect/issues`;var ye=class e{self;called=!1;constructor(e){this.self=e}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 e(this.self)}},be=class{_state;constructor(e,t,n,r){return de(t)&&de(e)?(t=Math.random()*4294967295>>>0,e=0):de(t)&&(t=e,e=0),de(r)&&de(n)?(r=this._state?this._state[3]:4150755663,n=this._state?this._state[2]:335903614):de(r)&&(r=n,n=0),this._state=new Int32Array([0,0,n>>>0,((r||0)|1)>>>0]),this._next(),Se(this._state,this._state[0],this._state[1],e>>>0,t>>>0),this._next(),this}getState(){return[this._state[0],this._state[1],this._state[2],this._state[3]]}setState(e){this._state[0]=e[0],this._state[1]=e[1],this._state[2]=e[2],this._state[3]=e[3]|1}integer(e){return Math.round(this.number()*(2**53-1))%e}number(){let e=(this._next()&67108863)*1,t=(this._next()&134217727)*1;return(e*134217728+t)/9007199254740992}_next(){let e=this._state[0]>>>0,t=this._state[1]>>>0;xe(this._state,e,t,1481765933,1284865837),Se(this._state,this._state[0],this._state[1],this._state[2],this._state[3]);let n=e>>>18,r=(t>>>18|e<<14)>>>0;n=(n^e)>>>0,r=(r^t)>>>0;let i=(r>>>27|n<<5)>>>0,a=e>>>27,o=(-a>>>0&31)>>>0;return(i>>>a|i<<o)>>>0}};function xe(e,t,n,r,i){let a=(n>>>16)*(i&65535)>>>0,o=(n&65535)*(i>>>16)>>>0,s=(n&65535)*(i&65535)>>>0,c=(n>>>16)*(i>>>16)+((o>>>16)+(a>>>16))>>>0;o=o<<16>>>0,s=s+o>>>0,s>>>0<o>>>0&&(c=c+1>>>0),a=a<<16>>>0,s=s+a>>>0,s>>>0<a>>>0&&(c=c+1>>>0),c=c+Math.imul(n,r)>>>0,c=c+Math.imul(t,i)>>>0,e[0]=c,e[1]=s}function Se(e,t,n,r,i){let a=t+r>>>0,o=n+i>>>0;o>>>0<n>>>0&&(a=a+1|0),e[0]=a,e[1]=o}const Ce=Symbol.for(`effect/Utils/YieldWrap`);var we=class{#e;constructor(e){this.#e=e}[Ce](){return this.#e}};function Te(e){if(typeof e==`object`&&e&&Ce in e)return e[Ce]();throw Error(ve(`yieldWrapGet`))}const Ee=g(`effect/Utils/isStructuralRegion`,()=>({enabled:!1,tester:void 0})),De={effect_internal_function:e=>e()},Oe=De.effect_internal_function(()=>Error().stack)?.includes(`effect_internal_function`)===!0?De.effect_internal_function:{effect_internal_function:e=>{try{return e()}finally{}}}.effect_internal_function;(function*(){}).constructor;const ke=g(Symbol.for(`effect/Hash/randomHashCache`),()=>new WeakMap),y=Symbol.for(`effect/Hash`),b=e=>{if(Ee.enabled===!0)return 0;switch(typeof e){case`number`:return Ne(e);case`bigint`:return S(e.toString(10));case`boolean`:return S(String(e));case`symbol`:return S(String(e));case`string`:return S(e);case`undefined`:return S(`undefined`);case`function`:case`object`:return e===null?S(`null`):e instanceof Date?Number.isNaN(e.getTime())?S(`Invalid Date`):b(e.toISOString()):e instanceof URL?b(e.href):Me(e)?e[y]():Ae(e);default:throw Error(`BUG: unhandled typeof ${typeof e} - please report an issue at https://github.com/Effect-TS/effect/issues`)}},Ae=e=>(ke.has(e)||ke.set(e,Ne(Math.floor(Math.random()*(2**53-1)))),ke.get(e)),x=e=>t=>t*53^e,je=e=>e&3221225471|e>>>1&1073741824,Me=e=>v(e,y),Ne=e=>{if(e!==e||e===1/0)return 0;let t=e|0;for(t!==e&&(t^=e*4294967295);e>4294967295;)t^=e/=4294967295;return je(t)},S=e=>{let t=5381,n=e.length;for(;n;)t=t*33^e.charCodeAt(--n);return je(t)},Pe=(e,t)=>{let n=12289;for(let r=0;r<t.length;r++)n^=c(S(t[r]),x(b(e[t[r]])));return je(n)},Fe=e=>Pe(e,Object.keys(e)),Ie=e=>{let t=6151;for(let n=0;n<e.length;n++)t=c(t,x(b(e[n])));return je(t)},C=function(){if(arguments.length===1){let e=arguments[0];return function(t){return Object.defineProperty(e,y,{value(){return t},enumerable:!1}),t}}let e=arguments[0],t=arguments[1];return Object.defineProperty(e,y,{value(){return t},enumerable:!1}),t},w=Symbol.for(`effect/Equal`);function T(){return arguments.length===1?e=>Le(e,arguments[0]):Le(arguments[0],arguments[1])}function Le(e,t){if(e===t)return!0;let n=typeof e;if(n!==typeof t)return!1;if(n===`object`||n===`function`){if(e!==null&&t!==null){if(Re(e)&&Re(t))return b(e)===b(t)&&e[w](t)?!0:Ee.enabled&&Ee.tester?Ee.tester(e,t):!1;if(e instanceof Date&&t instanceof Date){let n=e.getTime(),r=t.getTime();return n===r||Number.isNaN(n)&&Number.isNaN(r)}else if(e instanceof URL&&t instanceof URL)return e.href===t.href}if(Ee.enabled){if(e===null||t===null)return!1;if(Array.isArray(e)&&Array.isArray(t))return e.length===t.length&&e.every((e,n)=>Le(e,t[n]));if(Object.getPrototypeOf(e)===Object.prototype&&Object.getPrototypeOf(t)===Object.prototype){let n=Object.keys(e),r=Object.keys(t);if(n.length===r.length){for(let r of n)if(!(r in t&&Le(e[r],t[r])))return Ee.tester?Ee.tester(e,t):!1;return!0}}return Ee.tester?Ee.tester(e,t):!1}}return Ee.enabled&&Ee.tester?Ee.tester(e,t):!1}const Re=e=>v(e,w),ze=()=>T,E=Symbol.for(`nodejs.util.inspect.custom`),D=e=>{try{if(v(e,`toJSON`)&&ae(e.toJSON)&&e.toJSON.length===0)return e.toJSON();if(Array.isArray(e))return e.map(D)}catch{return{}}return Qe(e)},Be=`[Circular]`;function Ve(e){try{return e.toISOString()}catch{return`Invalid Date`}}function He(e){try{let t=e.toString();return typeof t==`string`?t:String(t)}catch{return`[toString threw]`}}function Ue(e){return _(e)?JSON.stringify(e):String(e)}function We(e,t){let n=t?.space??0,r=new WeakSet,i=n?te(n)?` `.repeat(n):n:``,a=e=>i.repeat(e),o=(e,t)=>{let n=e?.constructor;return n&&n!==Object.prototype.constructor&&n.name?`${n.name}(${t})`:t},s=e=>{try{return Reflect.ownKeys(e)}catch{return[`[ownKeys threw]`]}};function c(e,n=0){if(Array.isArray(e)){if(r.has(e))return Be;if(r.add(e),!i||e.length<=1)return`[${e.map(e=>c(e,n)).join(`,`)}]`;let t=e.map(e=>c(e,n+1)).join(`,
`+a(n+1));return`[\n${a(n+1)}${t}\n${a(n)}]`}if(me(e))return Ve(e);if(!t?.ignoreToString&&v(e,`toString`)&&ae(e.toString)&&e.toString!==Object.prototype.toString&&e.toString!==Array.prototype.toString){let t=He(e);return e instanceof Error&&e.cause?`${t} (cause: ${c(e.cause,n)})`:t}if(_(e))return JSON.stringify(e);if(te(e)||e==null||ne(e)||ie(e))return String(e);if(re(e))return String(e)+`n`;if(e instanceof Set||e instanceof Map)return r.has(e)?Be:(r.add(e),`${e.constructor.name}(${c(Array.from(e),n)})`);if(le(e)){if(r.has(e))return Be;r.add(e);let t=s(e);return!i||t.length<=1?o(e,`{${t.map(t=>`${Ue(t)}:${c(e[t],n)}`).join(`,`)}}`):o(e,`{\n${t.map(t=>`${a(n+1)}${Ue(t)}: ${c(e[t],n+1)}`).join(`,
`)}\n${a(n)}}`)}return String(e)}return c(e,0)}const Ge=e=>JSON.stringify(e,null,2),Ke=(e,t=2)=>{if(typeof e==`string`)return e;try{return typeof e==`object`?qe(e,t):String(e)}catch{return String(e)}},qe=(e,t)=>{let n=[],r=JSON.stringify(e,(e,t)=>typeof t==`object`&&t?n.includes(t)?void 0:n.push(t)&&(Xe.fiberRefs!==void 0&&Ye(t)?t[Je](Xe.fiberRefs):t):t,t);return n=void 0,r},Je=Symbol.for(`effect/Inspectable/Redactable`),Ye=e=>typeof e==`object`&&!!e&&Je in e,Xe=g(`effect/Inspectable/redactableState`,()=>({fiberRefs:void 0})),Ze=(e,t)=>{let n=Xe.fiberRefs;Xe.fiberRefs=e;try{return t()}finally{Xe.fiberRefs=n}},Qe=e=>Ye(e)&&Xe.fiberRefs!==void 0?e[Je](Xe.fiberRefs):e,O=(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 n=e;for(let e=0,r=t.length;e<r;e++)n=t[e](n);return n}}},$e=`Async`,et=`Commit`,tt=`Failure`,nt=`OnFailure`,rt=`OnSuccess`,it=`OnSuccessAndFailure`,at=`Success`,ot=`Sync`,st=`UpdateRuntimeFlags`,ct=`While`,lt=`Iterator`,ut=`WithRuntime`,dt=`Yield`,ft=`RevertFlags`,pt=()=>`3.21.0`,mt=Symbol.for(`effect/Effect`),ht=Symbol.for(`effect/Stream`),gt=Symbol.for(`effect/Sink`),_t=Symbol.for(`effect/Channel`),vt={_R:e=>e,_E:e=>e,_A:e=>e,_V:pt()},yt={_A:e=>e,_In:e=>e,_L:e=>e,_E:e=>e,_R:e=>e},bt={_Env:e=>e,_InErr:e=>e,_InElem:e=>e,_InDone:e=>e,_OutErr:e=>e,_OutElem:e=>e,_OutDone:e=>e},xt={[mt]:vt,[ht]:vt,[gt]:yt,[_t]:bt,[w](e){return this===e},[y](){return C(this,Ae(this))},[Symbol.iterator](){return new ye(new we(this))},pipe(){return O(this,arguments)}},St={[y](){return C(this,Fe(this))},[w](e){let t=Object.keys(this),n=Object.keys(e);if(t.length!==n.length)return!1;for(let n of t)if(!(n in e&&T(this[n],e[n])))return!1;return!0}},Ct={...xt,_op:et},wt={...Ct,...St},Tt=function(){function e(){}return e.prototype=Ct,e}(),Et=Symbol.for(`effect/Option`),Dt={...xt,[Et]:{_A:e=>e},[E](){return this.toJSON()},toString(){return Ge(this.toJSON())}},Ot=Object.assign(Object.create(Dt),{_tag:`Some`,_op:`Some`,[w](e){return jt(e)&&Nt(e)&&T(this.value,e.value)},[y](){return C(this,x(b(this._tag))(b(this.value)))},toJSON(){return{_id:`Option`,_tag:this._tag,value:D(this.value)}}}),kt=b(`None`),At=Object.assign(Object.create(Dt),{_tag:`None`,_op:`None`,[w](e){return jt(e)&&Mt(e)},[y](){return kt},toJSON(){return{_id:`Option`,_tag:this._tag}}}),jt=e=>v(e,Et),Mt=e=>e._tag===`None`,Nt=e=>e._tag===`Some`,Pt=Object.create(At),Ft=e=>{let t=Object.create(Ot);return t.value=e,t},It=Symbol.for(`effect/Either`),Lt={...xt,[It]:{_R:e=>e},[E](){return this.toJSON()},toString(){return Ge(this.toJSON())}},Rt=Object.assign(Object.create(Lt),{_tag:`Right`,_op:`Right`,[w](e){return Bt(e)&&Ht(e)&&T(this.right,e.right)},[y](){return x(b(this._tag))(b(this.right))},toJSON(){return{_id:`Either`,_tag:this._tag,right:D(this.right)}}}),zt=Object.assign(Object.create(Lt),{_tag:`Left`,_op:`Left`,[w](e){return Bt(e)&&Vt(e)&&T(this.left,e.left)},[y](){return x(b(this._tag))(b(this.left))},toJSON(){return{_id:`Either`,_tag:this._tag,left:D(this.left)}}}),Bt=e=>v(e,It),Vt=e=>e._tag===`Left`,Ht=e=>e._tag===`Right`,Ut=e=>{let t=Object.create(zt);return t.left=e,t},Wt=e=>{let t=Object.create(Rt);return t.right=e,t},Gt=t(2,(e,t)=>Mt(e)?Ut(t()):Wt(e.value)),k=Wt,A=Ut,Kt=Gt,qt=e=>{if(ae(e))try{return k(e())}catch(e){return A(e)}else try{return k(e.try())}catch(t){return A(e.catch(t))}},Jt=Bt,Yt=Vt,Xt=Ht,Zt=t(2,(e,{onLeft:t,onRight:n})=>Yt(e)?A(t(e.left)):k(n(e.right))),Qt=t(2,(e,t)=>Yt(e)?A(t(e.left)):k(e.right)),$t=t(2,(e,t)=>Xt(e)?k(t(e.right)):A(e.left)),en=t(2,(e,{onLeft:t,onRight:n})=>Yt(e)?t(e.left):n(e.right)),tn=en({onLeft:n,onRight:n}),nn=t(2,(e,t)=>{if(Xt(e))return e.right;throw t(e.left)}),rn=nn(()=>Error(`getOrThrow called on a Left`)),an=e=>e.length>0,on=e=>(t,n)=>t===n?0:e(t,n),sn=on((e,t)=>e<t?-1:1),cn=t(2,(e,t)=>on((n,r)=>e(t(n),t(r)))),ln=e=>t(2,(t,n)=>e(t,n)===1),j=()=>Pt,M=Ft,un=jt,N=Mt,P=Nt,dn=t(2,(e,{onNone:t,onSome:n})=>N(e)?t():n(e.value)),F=t(2,(e,t)=>N(e)?t():e.value),fn=t(2,(e,t)=>N(e)?t():e),pn=t(2,(e,t)=>N(e)?M(t()):e),mn=e=>e==null?j():M(e),hn=F(o),gn=e=>(...t)=>{try{return M(e(...t))}catch{return j()}},_n=t(2,(e,t)=>{if(P(e))return e.value;throw t()}),vn=_n(()=>Error(`getOrThrow called on a None`)),yn=t(2,(e,t)=>N(e)?j():M(t(e.value))),bn=t(2,(e,t)=>N(e)?j():t(e.value)),xn=t(2,(e,t)=>N(e)?j():mn(t(e.value))),Sn=bn,Cn=t(2,(e,t)=>Sn(e,e=>t(e)?Ft(e):Pt)),wn=e=>l((t,n)=>N(t)?N(n):N(n)?!1:e(t.value,n.value)),Tn=(e=>t(2,(t,n)=>N(t)?!1:e(t.value,n)))(ze()),En=t(2,(e,t)=>N(e)?!1:t(e.value)),Dn=e=>(t,n)=>N(t)?n:N(n)?t:M(e(t.value,n.value)),On=(...e)=>e,kn=e=>Array(e),An=t(2,(e,t)=>{let n=Math.max(1,Math.floor(e)),r=Array(n);for(let e=0;e<n;e++)r[e]=t(e);return r}),I=e=>Array.isArray(e)?e:Array.from(e),jn=e=>Array.isArray(e)?e:[e],Mn=t(2,(e,{onEmpty:t,onNonEmpty:n})=>L(e)?n(Wn(e),qn(e)):t()),Nn=t(2,(e,t)=>[t,...e]),Pn=t(2,(e,t)=>[...e,t]),Fn=t(2,(e,t)=>I(e).concat(I(t))),In=Array.isArray,Ln=e=>e.length===0,Rn=an,L=an,zn=(e,t)=>e<0||e>=t.length,Bn=(e,t)=>Math.floor(Math.min(Math.max(0,e),t.length)),Vn=t(2,(e,t)=>{let n=Math.floor(t);return zn(n,e)?j():M(e[n])}),Hn=t(2,(e,t)=>{let n=Math.floor(t);if(zn(n,e))throw Error(`Index ${n} out of bounds`);return e[n]}),Un=Vn(0),Wn=Hn(0),Gn=e=>L(e)?M(Kn(e)):j(),Kn=e=>e[e.length-1],qn=e=>e.slice(1),Jn=(e,t)=>{let n=0;for(let r of e){if(!t(r,n))break;n++}return n},Yn=t(2,(e,t)=>nr(e,Jn(e,t))),Xn=t(2,(e,t)=>{let n=I(e);return n.slice(Bn(t,n),n.length)}),Zn=e=>Array.from(e).reverse(),Qn=t(2,(e,t)=>{let n=Array.from(e);return n.sort(t),n}),$n=t(2,(e,t)=>er(e,t,On)),er=t(3,(e,t,n)=>{let r=I(e),i=I(t);if(L(r)&&L(i)){let e=[n(Wn(r),Wn(i))],t=Math.min(r.length,i.length);for(let a=1;a<t;a++)e[a]=n(r[a],i[a]);return e}return[]}),tr=ze(),nr=t(2,(e,t)=>{let n=Array.from(e),r=Math.floor(t);return L(n)?r>=1?rr(n,r):[[],n]:[n,[]]}),rr=t(2,(e,t)=>{let n=Math.max(1,Math.floor(t));return n>=e.length?[ir(e),[]]:[Nn(e.slice(1,n),Wn(e)),e.slice(n)]}),ir=e=>e.slice(),ar=t(3,(e,t,n)=>{let r=I(e),i=I(t);return L(r)?L(i)?gr(n)(Fn(r,i)):r:i}),or=t(2,(e,t)=>ar(e,t,tr)),sr=()=>[],cr=e=>[e],lr=t(2,(e,t)=>e.map(t)),ur=t(2,(e,t)=>{if(Ln(e))return[];let n=[];for(let r=0;r<e.length;r++){let i=t(e[r],r);for(let e=0;e<i.length;e++)n.push(i[e])}return n}),dr=ur(n),fr=t(2,(e,t)=>{let n=I(e),r=[];for(let e=0;e<n.length;e++){let i=t(n[e],e);P(i)&&r.push(i.value)}return r}),pr=t(3,(e,t,n)=>I(e).reduce((e,t,r)=>n(e,t,r),t)),mr=(e,t)=>{let n=[],r=e,i;for(;P(i=t(r));){let[e,t]=i.value;n.push(e),r=t}return n},hr=p,gr=t(2,(e,t)=>{let n=I(e);if(L(n)){let e=[Wn(n)],r=qn(n);for(let n of r)e.every(e=>!t(n,e))&&e.push(n);return e}return[]}),_r=e=>gr(e,ze()),vr=t(2,(e,t)=>I(e).join(t)),yr=/^[+-]?\d+$/,br=Symbol.for(`effect/BigDecimal`),xr={[br]:br,[y](){let e=Or(this);return c(b(e.value),x(Ne(e.scale)),C(this))},[w](e){return Sr(e)&&Mr(this,e)},toString(){return`BigDecimal(${Ir(this)})`},toJSON(){return{_id:`BigDecimal`,value:String(this.value),scale:this.scale}},[E](){return this.toJSON()},pipe(){return O(this,arguments)}},Sr=e=>v(e,br),Cr=(e,t)=>{let n=Object.create(xr);return n.value=e,n.scale=t,n},wr=(e,t)=>{if(e!==Tr&&e%Er===Tr)throw RangeError(`Value must be normalized`);let n=Cr(e,t);return n.normalized=n,n},Tr=BigInt(0),Er=BigInt(10),Dr=wr(Tr,0),Or=e=>{if(e.normalized===void 0)if(e.value===Tr)e.normalized=Dr;else{let t=`${e.value}`,n=0;for(let e=t.length-1;e>=0&&t[e]===`0`;e--)n++;n===0&&(e.normalized=e),e.normalized=wr(BigInt(t.substring(0,t.length-n)),e.scale-n)}return e.normalized},kr=t(2,(e,t)=>t>e.scale?Cr(e.value*Er**BigInt(t-e.scale),t):t<e.scale?Cr(e.value/Er**BigInt(e.scale-t),t):e),Ar=e=>e.value<Tr?Cr(-e.value,e.scale):e,jr=l((e,t)=>e.scale>t.scale?kr(t,e.scale).value===e.value:e.scale<t.scale?kr(e,t.scale).value===t.value:e.value===t.value),Mr=t(2,(e,t)=>jr(e,t)),Nr=e=>_n(Pr(e),()=>RangeError(`Number must be finite, got ${e}`)),Pr=e=>{if(!Number.isFinite(e))return j();let t=`${e}`;if(t.includes(`e`))return Fr(t);let[n,r=``]=t.split(`.`);return M(Cr(BigInt(`${n}${r}`),r.length))},Fr=e=>{if(e===``)return M(Dr);let t,n,r=e.search(/[eE]/);if(r!==-1){let i=e.slice(r+1);if(t=e.slice(0,r),n=Number(i),t===``||!Number.isSafeInteger(n)||!yr.test(i))return j()}else t=e,n=0;let i,a,o=t.search(/\./);if(o!==-1){let e=t.slice(0,o),n=t.slice(o+1);i=`${e}${n}`,a=n.length}else i=t,a=0;if(!yr.test(i))return j();let s=a-n;return Number.isSafeInteger(s)?M(Cr(BigInt(i),s)):j()},Ir=e=>{let t=Or(e);if(Math.abs(t.scale)>=16)return Lr(t);let n=t.value<Tr,r=n?`${t.value}`.substring(1):`${t.value}`,i,a;if(t.scale>=r.length)i=`0`,a=`0`.repeat(t.scale-r.length)+r;else{let e=r.length-t.scale;if(e>r.length){let t=e-r.length;i=`${r}${`0`.repeat(t)}`,a=``}else a=r.slice(e),i=r.slice(0,e)}let o=a===``?i:`${i}.${a}`;return n?`-${o}`:o},Lr=e=>{if(zr(e))return`0e+0`;let t=Or(e),n=`${Ar(t).value}`,r=n.slice(0,1),i=n.slice(1),a=`${Br(t)?`-`:``}${r}`;i!==``&&(a+=`.${i}`);let o=i.length-t.scale;return`${a}e${o>=0?`+`:``}${o}`},Rr=e=>Number(Ir(e)),zr=e=>e.value===Tr,Br=e=>e.value<Tr,Vr=e=>e>BigInt(2**53-1)||e<BigInt(-(2**53-1))?j():M(Number(e)),Hr=e=>{try{return e.trim()===``?j():M(BigInt(e))}catch{return j()}},Ur=e=>{if(e>2**53-1||e<-(2**53-1))return j();try{return M(BigInt(e))}catch{return j()}},Wr=e=>!e,Gr=Symbol.for(`effect/Chunk`);function Kr(e,t,n,r,i){for(let a=t;a<Math.min(e.length,t+i);a++)n[r+a-t]=e[a];return n}const qr=[],Jr=(e=>l((t,n)=>t.length===n.length&&ii(t).every((t,r)=>e(t,li(n,r)))))(T),Yr={[Gr]:{_A:e=>e},toString(){return Ge(this.toJSON())},toJSON(){return{_id:`Chunk`,values:ii(this).map(D)}},[E](){return this.toJSON()},[w](e){return Zr(e)&&Jr(this,e)},[y](){return C(this,Ie(ii(this)))},[Symbol.iterator](){switch(this.backing._tag){case`IArray`:return this.backing.array[Symbol.iterator]();case`IEmpty`:return qr[Symbol.iterator]();default:return ii(this)[Symbol.iterator]()}},pipe(){return O(this,arguments)}},Xr=e=>{let t=Object.create(Yr);switch(t.backing=e,e._tag){case`IEmpty`:t.length=0,t.depth=0,t.left=t,t.right=t;break;case`IConcat`:t.length=e.left.length+e.right.length,t.depth=1+Math.max(e.left.depth,e.right.depth),t.left=e.left,t.right=e.right;break;case`IArray`:t.length=e.array.length,t.depth=0,t.left=Qr,t.right=Qr;break;case`ISingleton`:t.length=1,t.depth=0,t.left=Qr,t.right=Qr;break;case`ISlice`:t.length=e.length,t.depth=e.chunk.depth+1,t.left=Qr,t.right=Qr;break}return t},Zr=e=>v(e,Gr),Qr=Xr({_tag:`IEmpty`}),$r=()=>Qr,ei=(...e)=>ci(e),ti=e=>Xr({_tag:`ISingleton`,a:e}),ni=e=>Zr(e)?e:si(I(e)),ri=(e,t,n)=>{switch(e.backing._tag){case`IArray`:Kr(e.backing.array,0,t,n,e.length);break;case`IConcat`:ri(e.left,t,n),ri(e.right,t,n+e.left.length);break;case`ISingleton`:t[n]=e.backing.a;break;case`ISlice`:{let r=0,i=n;for(;r<e.length;)t[i]=li(e,r),r+=1,i+=1;break}}},ii=e=>{switch(e.backing._tag){case`IEmpty`:return qr;case`IArray`:return e.backing.array;default:{let t=Array(e.length);return ri(e,t,0),e.backing={_tag:`IArray`,array:t},e.left=Qr,e.right=Qr,e.depth=0,t}}},ai=e=>{switch(e.backing._tag){case`IEmpty`:case`ISingleton`:return e;case`IArray`:return Xr({_tag:`IArray`,array:Zn(e.backing.array)});case`IConcat`:return Xr({_tag:`IConcat`,left:ai(e.backing.right),right:ai(e.backing.left)});case`ISlice`:return si(Zn(ii(e)))}},oi=t(2,(e,t)=>t<0||t>=e.length?j():M(li(e,t))),si=e=>e.length===0?$r():e.length===1?ti(e[0]):Xr({_tag:`IArray`,array:e}),ci=e=>si(e),li=t(2,(e,t)=>{switch(e.backing._tag){case`IEmpty`:throw Error(`Index out of bounds`);case`ISingleton`:if(t!==0)throw Error(`Index out of bounds`);return e.backing.a;case`IArray`:if(t>=e.length||t<0)throw Error(`Index out of bounds`);return e.backing.array[t];case`IConcat`:return t<e.left.length?li(e.left,t):li(e.right,t-e.left.length);case`ISlice`:return li(e.backing.chunk,t+e.backing.offset)}}),ui=t(2,(e,t)=>pi(e,ti(t))),di=t(2,(e,t)=>pi(ti(t),e)),fi=t(2,(e,t)=>{if(t<=0)return e;if(t>=e.length)return Qr;switch(e.backing._tag){case`ISlice`:return Xr({_tag:`ISlice`,chunk:e.backing.chunk,offset:e.backing.offset+t,length:e.backing.length-t});case`IConcat`:return t>e.left.length?fi(e.right,t-e.left.length):Xr({_tag:`IConcat`,left:fi(e.left,t),right:e.right});default:return Xr({_tag:`ISlice`,chunk:e,offset:t,length:e.length-t})}}),pi=t(2,(e,t)=>{if(e.backing._tag===`IEmpty`)return t;if(t.backing._tag===`IEmpty`)return e;let n=t.depth-e.depth;if(Math.abs(n)<=1)return Xr({_tag:`IConcat`,left:e,right:t});if(n<-1)if(e.left.depth>=e.right.depth){let n=pi(e.right,t);return Xr({_tag:`IConcat`,left:e.left,right:n})}else{let n=pi(e.right.right,t);if(n.depth===e.depth-3){let t=Xr({_tag:`IConcat`,left:e.right.left,right:n});return Xr({_tag:`IConcat`,left:e.left,right:t})}else return Xr({_tag:`IConcat`,left:Xr({_tag:`IConcat`,left:e.left,right:e.right.left}),right:n})}else if(t.right.depth>=t.left.depth)return Xr({_tag:`IConcat`,left:pi(e,t.left),right:t.right});else{let n=pi(e,t.left.left);return n.depth===t.depth-3?Xr({_tag:`IConcat`,left:Xr({_tag:`IConcat`,left:n,right:t.left.right}),right:t.right}):Xr({_tag:`IConcat`,left:n,right:Xr({_tag:`IConcat`,left:t.left.right,right:t.right})})}}),mi=e=>e.length===0,hi=e=>e.length>0,gi=oi(0),_i=e=>li(e,0),vi=_i,yi=e=>fi(e,1);function bi(e){return e-=e>>1&1431655765,e=(e&858993459)+(e>>2&858993459),e=e+(e>>4)&252645135,e+=e>>8,e+=e>>16,e&127}function xi(e,t){return t>>>e&31}function Si(e){return 1<<e}function Ci(e,t){return bi(e&t-1)}const wi=(e,t)=>({value:e,previous:t});function Ti(e,t,n,r){let i=r;if(!e){let e=r.length;i=Array(e);for(let t=0;t<e;++t)i[t]=r[t]}return i[t]=n,i}function Ei(e,t,n){let r=n.length-1,i=0,a=0,o=n;if(e)i=a=t;else for(o=Array(r);i<t;)o[a++]=n[i++];for(++i;i<=r;)o[a++]=n[i++];return e&&(o.length=r),o}function Di(e,t,n,r){let i=r.length;if(e){let e=i;for(;e>=t;)r[e--]=r[e];return r[t]=n,r}let a=0,o=0,s=Array(i+1);for(;a<t;)s[o++]=r[a++];for(s[t]=n;a<i;)s[++o]=r[a++];return s}var Oi=class e{_tag=`EmptyNode`;modify(t,n,r,i,a,o){let s=r(j());return N(s)?new e:(++o.value,new Mi(t,i,a,s))}};function ki(e){return ue(e,`EmptyNode`)}function Ai(e){return ki(e)||e._tag===`LeafNode`||e._tag===`CollisionNode`}function ji(e,t){return ki(e)?!1:t===e.edit}var Mi=class e{edit;hash;key;value;_tag=`LeafNode`;constructor(e,t,n,r){this.edit=e,this.hash=t,this.key=n,this.value=r}modify(t,n,r,i,a,o){if(T(a,this.key)){let n=r(this.value);return n===this.value?this:N(n)?(--o.value,new Oi):ji(this,t)?(this.value=n,this):new e(t,i,a,n)}let s=r(j());return N(s)?this:(++o.value,zi(t,n,this.hash,this,i,new e(t,i,a,s)))}},Ni=class e{edit;hash;children;_tag=`CollisionNode`;constructor(e,t,n){this.edit=e,this.hash=t,this.children=n}modify(t,n,r,i,a,o){if(i===this.hash){let n=ji(this,t),i=this.updateCollisionList(n,t,this.hash,this.children,r,a,o);return i===this.children?this:i.length>1?new e(t,this.hash,i):i[0]}let s=r(j());return N(s)?this:(++o.value,zi(t,n,this.hash,this,i,new Mi(t,i,a,s)))}updateCollisionList(e,t,n,r,i,a,o){let s=r.length;for(let c=0;c<s;++c){let s=r[c];if(`key`in s&&T(a,s.key)){let l=s.value,u=i(l);return u===l?r:N(u)?(--o.value,Ei(e,c,r)):Ti(e,c,new Mi(t,n,a,u),r)}}let c=i(j());return N(c)?r:(++o.value,Ti(e,s,new Mi(t,n,a,c),r))}},Pi=class e{edit;mask;children;_tag=`IndexedNode`;constructor(e,t,n){this.edit=e,this.mask=t,this.children=n}modify(t,n,r,i,a,o){let s=this.mask,c=this.children,l=xi(n,i),u=Si(l),d=Ci(s,u),f=s&u,p=ji(this,t);if(!f){let f=new Oi().modify(t,n+5,r,i,a,o);return f?c.length>=16?Li(t,l,f,s,c):new e(t,s|u,Di(p,d,f,c)):this}let m=c[d],h=m.modify(t,n+5,r,i,a,o);if(m===h)return this;let g=s,ee;if(ki(h)){if(g&=~u,!g)return new Oi;if(c.length<=2&&Ai(c[d^1]))return c[d^1];ee=Ei(p,d,c)}else ee=Ti(p,d,h,c);return p?(this.mask=g,this.children=ee,this):new e(t,g,ee)}},Fi=class e{edit;size;children;_tag=`ArrayNode`;constructor(e,t,n){this.edit=e,this.size=t,this.children=n}modify(t,n,r,i,a,o){let s=this.size,c=this.children,l=xi(n,i),u=c[l],d=(u||new Oi).modify(t,n+5,r,i,a,o);if(u===d)return this;let f=ji(this,t),p;if(ki(u)&&!ki(d))++s,p=Ti(f,l,d,c);else if(!ki(u)&&ki(d)){if(--s,s<=8)return Ii(t,s,l,c);p=Ti(f,l,new Oi,c)}else p=Ti(f,l,d,c);return f?(this.size=s,this.children=p,this):new e(t,s,p)}};function Ii(e,t,n,r){let i=Array(t-1),a=0,o=0;for(let e=0,t=r.length;e<t;++e)if(e!==n){let t=r[e];t&&!ki(t)&&(i[a++]=t,o|=1<<e)}return new Pi(e,o,i)}function Li(e,t,n,r,i){let a=[],o=r,s=0;for(let e=0;o;++e)o&1&&(a[e]=i[s++]),o>>>=1;return a[t]=n,new Fi(e,s+1,a)}function Ri(e,t,n,r,i,a){if(n===i)return new Ni(e,n,[a,r]);let o=xi(t,n),s=xi(t,i);if(o===s)return t=>new Pi(e,Si(o)|Si(s),[t]);{let t=o<s?[r,a]:[a,r];return new Pi(e,Si(o)|Si(s),t)}}function zi(e,t,n,r,i,a){let o,s=t;for(;;){let t=Ri(e,s,n,r,i,a);if(typeof t==`function`)o=wi(t,o),s+=5;else{let e=t;for(;o!=null;)e=o.value(e),o=o.previous;return e}}}const Bi=`effect/HashMap`,Vi=Symbol.for(Bi),Hi={[Vi]:Vi,[Symbol.iterator](){return new Wi(this,(e,t)=>[e,t])},[y](){let e=b(Bi);for(let t of this)e^=c(b(t[0]),x(b(t[1])));return C(this,e)},[w](e){if(Zi(e)){if(e._size!==this._size)return!1;for(let t of this){let n=c(e,ea(t[0],b(t[0])));if(N(n)||!T(t[1],n.value))return!1}return!0}return!1},toString(){return Ge(this.toJSON())},toJSON(){return{_id:`HashMap`,values:Array.from(this).map(D)}},[E](){return this.toJSON()},pipe(){return O(this,arguments)}},Ui=(e,t,n,r)=>{let i=Object.create(Hi);return i._editable=e,i._edit=t,i._root=n,i._size=r,i};var Wi=class e{map;f;v;constructor(e,t){this.map=e,this.f=t,this.v=Ki(this.map._root,this.f,void 0)}next(){if(N(this.v))return{done:!0,value:void 0};let e=this.v.value;return this.v=Gi(e.cont),{done:!1,value:e.value}}[Symbol.iterator](){return new e(this.map,this.f)}};const Gi=e=>e?qi(e[0],e[1],e[2],e[3],e[4]):j(),Ki=(e,t,n=void 0)=>{switch(e._tag){case`LeafNode`:return P(e.value)?M({value:t(e.key,e.value.value),cont:n}):Gi(n);case`CollisionNode`:case`ArrayNode`:case`IndexedNode`:{let r=e.children;return qi(r.length,r,0,t,n)}default:return Gi(n)}},qi=(e,t,n,r,i)=>{for(;n<e;){let a=t[n++];if(a&&!ki(a))return Ki(a,r,[e,t,n,r,i])}return Gi(i)},Ji=Ui(!1,0,new Oi,0),Yi=()=>Ji,Xi=e=>{let t=oa(Yi());for(let n of e)na(t,n[0],n[1]);return sa(t)},Zi=e=>v(e,Vi),Qi=e=>e&&ki(e._root),$i=t(2,(e,t)=>ea(e,t,b(t))),ea=t(3,(e,t,n)=>{let r=e._root,i=0;for(;;)switch(r._tag){case`LeafNode`:return T(t,r.key)?r.value:j();case`CollisionNode`:if(n===r.hash){let e=r.children;for(let n=0,r=e.length;n<r;++n){let r=e[n];if(`key`in r&&T(t,r.key))return r.value}}return j();case`IndexedNode`:{let e=Si(xi(i,n));if(r.mask&e){r=r.children[Ci(r.mask,e)],i+=5;break}return j()}case`ArrayNode`:if(r=r.children[xi(i,n)],r){i+=5;break}return j();default:return j()}}),ta=t(2,(e,t)=>P(ea(e,t,b(t)))),na=t(3,(e,t,n)=>ca(e,t,()=>M(n))),ra=t(3,(e,t,n)=>e._editable?(e._root=t,e._size=n,e):t===e._root?e:Ui(e._editable,e._edit,t,n)),ia=e=>new Wi(e,e=>e),aa=e=>e._size,oa=e=>Ui(!0,e._edit+1,e._root,e._size),sa=e=>(e._editable=!1,e),ca=t(3,(e,t,n)=>la(e,t,b(t),n)),la=t(4,(e,t,n,r)=>{let i={value:e._size};return c(e,ra(e._root.modify(e._editable?e._edit:NaN,0,r,n,t,i),i.value))}),ua=t(2,(e,t)=>ca(e,t,j)),da=t(2,(e,t)=>pa(e,Yi(),(e,n,r)=>na(e,r,t(n,r)))),fa=t(2,(e,t)=>pa(e,void 0,(e,n,r)=>t(n,r))),pa=t(3,(e,t,n)=>{let r=e._root;if(r._tag===`LeafNode`)return P(r.value)?n(t,r.value.value,r.key):t;if(r._tag===`EmptyNode`)return t;let i=[r.children],a;for(;a=i.pop();)for(let e=0,r=a.length;e<r;){let r=a[e++];r&&!ki(r)&&(r._tag===`LeafNode`?P(r.value)&&(t=n(t,r.value.value,r.key)):i.push(r.children))}return t}),ma=`effect/HashSet`,ha=Symbol.for(ma),ga={[ha]:ha,[Symbol.iterator](){return ia(this._keyMap)},[y](){return C(this,x(b(this._keyMap))(b(ma)))},[w](e){return va(e)?aa(this._keyMap)===aa(e._keyMap)&&T(this._keyMap,e._keyMap):!1},toString(){return Ge(this.toJSON())},toJSON(){return{_id:`HashSet`,values:Array.from(this).map(D)}},[E](){return this.toJSON()},pipe(){return O(this,arguments)}},_a=e=>{let t=Object.create(ga);return t._keyMap=e,t},va=e=>v(e,ha),ya=_a(Yi()),ba=()=>ya,xa=e=>{let t=Da(ba());for(let n of e)Aa(t,n);return Oa(t)},Sa=(...e)=>{let t=Da(ba());for(let n of e)Aa(t,n);return Oa(t)},Ca=t(2,(e,t)=>ta(e._keyMap,t)),wa=t(2,(e,t)=>{let n=!1;for(let r of e)if(n=t(r),n)break;return n}),Ta=t(2,(e,t)=>!wa(e,e=>!t(e))),Ea=e=>aa(e._keyMap),Da=e=>_a(oa(e._keyMap)),Oa=e=>(e._keyMap._editable=!1,e),ka=t(2,(e,t)=>{let n=Da(e);return t(n),Oa(n)}),Aa=t(2,(e,t)=>e._keyMap._editable?(na(t,!0)(e._keyMap),e):_a(na(t,!0)(e._keyMap))),ja=t(2,(e,t)=>e._keyMap._editable?(ua(t)(e._keyMap),e):_a(ua(t)(e._keyMap))),Ma=t(2,(e,t)=>ka(e,e=>{for(let n of t)ja(e,n)})),Na=t(2,(e,t)=>ka(ba(),n=>{Pa(e,e=>Aa(n,e));for(let e of t)Aa(n,e)})),Pa=t(2,(e,t)=>fa(e._keyMap,(e,n)=>t(n))),Fa=t(3,(e,t,n)=>pa(e._keyMap,t,(e,t,r)=>n(e,r))),Ia=ba,La=xa,Ra=Sa,za=Ca,Ba=Ta,Va=Ea,Ha=Aa,Ua=ja,Wa=Ma,Ga=Na,Ka=Fa,qa=`Empty`,Ja=`Fail`,Ya=`Interrupt`,Xa=`Parallel`,Za=`Sequential`,Qa=`effect/Cause`,$a=Symbol.for(Qa),eo={_E:e=>e},to={[$a]:eo,[y](){return c(b(Qa),x(b(To(this))),C(this))},[w](e){return co(e)&&wo(this,e)},pipe(){return O(this,arguments)},toJSON(){switch(this._tag){case`Empty`:return{_id:`Cause`,_tag:this._tag};case`Die`:return{_id:`Cause`,_tag:this._tag,defect:D(this.defect)};case`Interrupt`:return{_id:`Cause`,_tag:this._tag,fiberId:this.fiberId.toJSON()};case`Fail`:return{_id:`Cause`,_tag:this._tag,failure:D(this.error)};case`Sequential`:case`Parallel`:return{_id:`Cause`,_tag:this._tag,left:D(this.left),right:D(this.right)}}},toString(){return Fo(this)},[E](){return this.toJSON()}},no=(()=>{let e=Object.create(to);return e._tag=qa,e})(),ro=e=>{let t=Object.create(to);return t._tag=Ja,t.error=e,t},io=e=>{let t=Object.create(to);return t._tag=`Die`,t.defect=e,t},ao=e=>{let t=Object.create(to);return t._tag=Ya,t.fiberId=e,t},oo=(e,t)=>{let n=Object.create(to);return n._tag=Xa,n.left=e,n.right=t,n},so=(e,t)=>{let n=Object.create(to);return n._tag=Za,n.left=e,n.right=t,n},co=e=>v(e,$a),lo=e=>e._tag===qa,uo=e=>e._tag===Ja,fo=e=>e._tag===`Empty`?!0:No(e,!0,(e,t)=>{switch(t._tag){case qa:return M(e);case`Die`:case Ja:case Ya:return M(!1);default:return j()}}),po=e=>P(bo(e)),mo=e=>Po(void 0,ko)(e),ho=e=>ai(No(e,$r(),(e,t)=>t._tag===`Fail`?M(c(e,di(t.error))):j())),go=e=>ai(No(e,$r(),(e,t)=>t._tag===`Die`?M(c(e,di(t.defect))):j())),_o=e=>No(e,Ia(),(e,t)=>t._tag===`Interrupt`?M(c(e,Ha(t.fiberId))):j()),vo=e=>Do(e,e=>e._tag===`Fail`?M(e.error):j()),yo=e=>{let t=vo(e);switch(t._tag){case`None`:return k(e);case`Some`:return A(t.value)}},bo=e=>Do(e,e=>e._tag===`Interrupt`?M(e.fiberId):j()),xo=e=>Mo(e,{onEmpty:j(),onFail:e=>M(io(e)),onDie:e=>M(io(e)),onInterrupt:()=>j(),onSequential:Dn(so),onParallel:Dn(oo)}),So=e=>Mo(e,{onEmpty:no,onFail:()=>no,onDie:io,onInterrupt:ao,onSequential:so,onParallel:oo}),Co=e=>Mo(e,{onEmpty:no,onFail:io,onDie:io,onInterrupt:ao,onSequential:so,onParallel:oo}),wo=(e,t)=>{let n=ti(e),r=ti(t);for(;hi(n)&&hi(r);){let[e,t]=c(vi(n),No([Ia(),$r()],([e,t],n)=>{let[r,i]=Oo(n);return M([c(e,Ga(r)),c(t,pi(i))])})),[i,a]=c(vi(r),No([Ia(),$r()],([e,t],n)=>{let[r,i]=Oo(n);return M([c(e,Ga(r)),c(t,pi(i))])}));if(!T(e,i))return!1;n=t,r=a}return!0},To=e=>Eo(ti(e),$r()),Eo=(e,t)=>{for(;;){let[n,r]=c(e,pr([Ia(),$r()],([e,t],n)=>{let[r,i]=Oo(n);return[c(e,Ga(r)),c(t,pi(i))]})),i=Va(n)>0?c(t,di(n)):t;if(mi(r))return ai(i);e=r,t=i}throw Error(ve(`Cause.flattenCauseLoop`))},Do=t(2,(e,t)=>{let n=[e];for(;n.length>0;){let e=n.pop(),r=t(e);switch(r._tag){case`None`:switch(e._tag){case Za:case Xa:n.push(e.right),n.push(e.left);break}break;case`Some`:return r}}return j()}),Oo=e=>{let t=e,n=[],r=Ia(),i=$r();for(;t!==void 0;)switch(t._tag){case qa:if(n.length===0)return[r,i];t=n.pop();break;case Ja:if(r=Ha(r,ei(t._tag,t.error)),n.length===0)return[r,i];t=n.pop();break;case`Die`:if(r=Ha(r,ei(t._tag,t.defect)),n.length===0)return[r,i];t=n.pop();break;case Ya:if(r=Ha(r,ei(t._tag,t.fiberId)),n.length===0)return[r,i];t=n.pop();break;case Za:switch(t.left._tag){case qa:t=t.right;break;case Za:t=so(t.left.left,so(t.left.right,t.right));break;case Xa:t=oo(so(t.left.left,t.right),so(t.left.right,t.right));break;default:i=di(i,t.right),t=t.left;break}break;case Xa:n.push(t.right),t=t.left;break}throw Error(ve(`Cause.evaluateCauseLoop`))},ko={emptyCase:i,failCase:a,dieCase:a,interruptCase:i,sequentialCase:(e,t,n)=>t&&n,parallelCase:(e,t,n)=>t&&n},Ao=`SequentialCase`,jo=`ParallelCase`,Mo=t(2,(e,{onDie:t,onEmpty:n,onFail:r,onInterrupt:i,onParallel:a,onSequential:o})=>Po(e,void 0,{emptyCase:()=>n,failCase:(e,t)=>r(t),dieCase:(e,n)=>t(n),interruptCase:(e,t)=>i(t),sequentialCase:(e,t,n)=>o(t,n),parallelCase:(e,t,n)=>a(t,n)})),No=t(3,(e,t,n)=>{let r=t,i=e,a=[];for(;i!==void 0;){let e=n(r,i);switch(r=P(e)?e.value:r,i._tag){case Za:a.push(i.right),i=i.left;break;case Xa:a.push(i.right),i=i.left;break;default:i=void 0;break}i===void 0&&a.length>0&&(i=a.pop())}return r}),Po=t(3,(e,t,n)=>{let r=[e],i=[];for(;r.length>0;){let e=r.pop();switch(e._tag){case qa:i.push(k(n.emptyCase(t)));break;case Ja:i.push(k(n.failCase(t,e.error)));break;case`Die`:i.push(k(n.dieCase(t,e.defect)));break;case Ya:i.push(k(n.interruptCase(t,e.fiberId)));break;case Za:r.push(e.right),r.push(e.left),i.push(A({_tag:Ao}));break;case Xa:r.push(e.right),r.push(e.left),i.push(A({_tag:jo}));break}}let a=[];for(;i.length>0;){let e=i.pop();switch(e._tag){case`Left`:switch(e.left._tag){case Ao:{let e=a.pop(),r=a.pop(),i=n.sequentialCase(t,e,r);a.push(i);break}case jo:{let e=a.pop(),r=a.pop(),i=n.parallelCase(t,e,r);a.push(i);break}}break;case`Right`:a.push(e.right);break}}if(a.length===0)throw Error(`BUG: Cause.reduceWithContext - please report an issue at https://github.com/Effect-TS/effect/issues`);return a.pop()}),Fo=(e,t)=>mo(e)?`All fibers interrupted without errors.`:Uo(e).map(function(e){return t?.renderErrorCause!==!0||e.cause===void 0?e.stack:`${e.stack} {\n${Io(e.cause,`  `)}\n}`}).join(`
`),Io=(e,t)=>{let n=e.stack.split(`
`),r=`${t}[cause]: ${n[0]}`;for(let e=1,i=n.length;e<i;e++)r+=`\n${t}${n[e]}`;return e.cause&&(r+=` {\n${Io(e.cause,`${t}  `)}\n${t}}`),r},Lo=e=>{let t=typeof e==`object`&&!!e,n=Error.stackTraceLimit;Error.stackTraceLimit=1;let r=Error(Ro(e),t&&`cause`in e&&e.cause!==void 0?{cause:Lo(e.cause)}:void 0);return Error.stackTraceLimit=n,r.message===``&&(r.message=`An error has occurred`),Error.stackTraceLimit=n,r.name=e instanceof Error?e.name:`Error`,t&&(Ho in e&&(r.span=e[Ho]),Object.keys(e).forEach(t=>{t in r||(r[t]=e[t])})),r.stack=Vo(`${r.name}: ${r.message}`,e instanceof Error&&e.stack?e.stack:``,r.span),r},Ro=e=>{if(typeof e==`string`)return e;if(typeof e==`object`&&e&&e instanceof Error)return e.message;try{if(v(e,`toString`)&&ae(e.toString)&&e.toString!==Object.prototype.toString&&e.toString!==globalThis.Array.prototype.toString)return e.toString()}catch{}return qe(e)},zo=/\((.*)\)/g,Bo=g(`effect/Tracer/spanToTrace`,()=>new WeakMap),Vo=(e,t,n)=>{let r=[e],i=t.startsWith(e)?t.slice(e.length).split(`
`):t.split(`
`);for(let e=1;e<i.length;e++){if(i[e].includes(` at new BaseEffectError`)||i[e].includes(` at new YieldableError`)){e++;continue}if(i[e].includes(`Generator.next`)||i[e].includes(`effect_internal_function`))break;r.push(i[e].replace(/at .*effect_instruction_i.*\((.*)\)/,`at $1`).replace(/EffectPrimitive\.\w+/,`<anonymous>`))}if(n){let e=n,t=0;for(;e&&e._tag===`Span`&&t<10;){let n=Bo.get(e);if(typeof n==`function`){let t=n();if(typeof t==`string`){let n=t.matchAll(zo),i=!1;for(let[,t]of n)i=!0,r.push(`    at ${e.name} (${t})`);i||r.push(`    at ${e.name} (${t.replace(/^at /,``)})`)}else r.push(`    at ${e.name}`)}else r.push(`    at ${e.name}`);e=hn(e.parent),t++}}return r.join(`
`)},Ho=Symbol.for(`effect/SpanAnnotation`),Uo=e=>Po(e,void 0,{emptyCase:()=>[],dieCase:(e,t)=>[Lo(t)],failCase:(e,t)=>[Lo(t)],interruptCase:()=>[],parallelCase:(e,t,n)=>[...t,...n],sequentialCase:(e,t,n)=>[...t,...n]}),Wo=Symbol.for(`effect/Context/Tag`),Go=Symbol.for(`effect/Context/Reference`),Ko=Symbol.for(`effect/STM`),qo={...xt,_op:`Tag`,[Ko]:vt,[Wo]:{_Service:e=>e,_Identifier:e=>e},toString(){return Ge(this.toJSON())},toJSON(){return{_id:`Tag`,key:this.key,stack:this.stack}},[E](){return this.toJSON()},of(e){return e},context(e){return os(this,e)}},Jo={...qo,[Go]:Go},Yo=e=>{let t=Error.stackTraceLimit;Error.stackTraceLimit=2;let n=Error();Error.stackTraceLimit=t;let r=Object.create(qo);return Object.defineProperty(r,`stack`,{get(){return n.stack}}),r.key=e,r},Xo=e=>()=>{let t=Error.stackTraceLimit;Error.stackTraceLimit=2;let n=Error();Error.stackTraceLimit=t;function r(){}return Object.setPrototypeOf(r,qo),r.key=e,Object.defineProperty(r,`stack`,{get(){return n.stack}}),r},Zo=()=>(e,t)=>{let n=Error.stackTraceLimit;Error.stackTraceLimit=2;let r=Error();Error.stackTraceLimit=n;function i(){}return Object.setPrototypeOf(i,Jo),i.key=e,i.defaultValue=t.defaultValue,Object.defineProperty(i,`stack`,{get(){return r.stack}}),i},Qo=Symbol.for(`effect/Context`),$o={[Qo]:{_Services:e=>e},[w](e){if(ns(e)&&this.unsafeMap.size===e.unsafeMap.size){for(let t of this.unsafeMap.keys())if(!e.unsafeMap.has(t)||!T(this.unsafeMap.get(t),e.unsafeMap.get(t)))return!1;return!0}return!1},[y](){return C(this,Ne(this.unsafeMap.size))},pipe(){return O(this,arguments)},toString(){return Ge(this.toJSON())},toJSON(){return{_id:`Context`,services:Array.from(this.unsafeMap).map(D)}},[E](){return this.toJSON()}},es=e=>{let t=Object.create($o);return t.unsafeMap=e,t},ts=e=>{let t=Error(`Service not found${e.key?`: ${String(e.key)}`:``}`);if(e.stack){let n=e.stack.split(`
`);if(n.length>2){let e=n[2].match(/at (.*)/);e&&(t.message+=` (defined at ${e[1]})`)}}if(t.stack){let e=t.stack.split(`
`);e.splice(1,3),t.stack=e.join(`
`)}return t},ns=e=>v(e,Qo),rs=e=>v(e,Go),is=es(new Map),as=()=>is,os=(e,t)=>es(new Map([[e.key,t]])),ss=t(3,(e,t,n)=>{let r=new Map(e.unsafeMap);return r.set(t.key,n),es(r)}),cs=g(`effect/Context/defaultValueCache`,()=>new Map),ls=e=>{if(cs.has(e.key))return cs.get(e.key);let t=e.defaultValue();return cs.set(e.key,t),t},us=(e,t)=>e.unsafeMap.has(t.key)?e.unsafeMap.get(t.key):ls(t),ds=t(2,(e,t)=>{if(!e.unsafeMap.has(t.key)){if(Go in t)return ls(t);throw ts(t)}return e.unsafeMap.get(t.key)}),fs=ds,ps=t(2,(e,t)=>e.unsafeMap.has(t.key)?Ft(e.unsafeMap.get(t.key)):rs(t)?Ft(ls(t)):Pt),ms=t(2,(e,t)=>{let n=new Map(e.unsafeMap);for(let[e,r]of t.unsafeMap)n.set(e,r);return es(n)}),hs=(...e)=>{let t=new Map;for(let n=0;n<e.length;n++)e[n].unsafeMap.forEach((e,n)=>{t.set(n,e)});return es(t)},gs=Yo,_s=as,vs=os,ys=ss,bs=fs,xs=ds,Ss=ps,Cs=ms,ws=hs,Ts=Xo,Es=Zo,Ds=Symbol.for(`effect/Duration`),Os=BigInt(0),ks=BigInt(24),As=BigInt(60),js=BigInt(1e3),Ms=BigInt(1e6),Ns=BigInt(1e9),Ps=/^(-?\d+(?:\.\d+)?)\s+(nanos?|micros?|millis?|seconds?|minutes?|hours?|days?|weeks?)$/,Fs=e=>{if(Bs(e))return e;if(te(e))return qs(e);if(re(e))return Gs(e);if(Array.isArray(e)&&e.length===2&&e.every(te))return e[0]===-1/0||e[1]===-1/0||Number.isNaN(e[0])||Number.isNaN(e[1])?Us:e[0]===1/0||e[1]===1/0?Ws:Gs(BigInt(Math.round(e[0]*1e9))+BigInt(Math.round(e[1])));if(_(e)){let t=Ps.exec(e);if(t){let[e,n,r]=t,i=Number(n);switch(r){case`nano`:case`nanos`:return Gs(BigInt(n));case`micro`:case`micros`:return Ks(BigInt(n));case`milli`:case`millis`:return qs(i);case`second`:case`seconds`:return Js(i);case`minute`:case`minutes`:return Ys(i);case`hour`:case`hours`:return Xs(i);case`day`:case`days`:return Zs(i);case`week`:case`weeks`:return Qs(i)}}}throw Error(`Invalid DurationInput`)},Is={_tag:`Millis`,millis:0},Ls={_tag:`Infinity`},Rs={[Ds]:Ds,[y](){return C(this,Fe(this.value))},[w](e){return Bs(e)&&cc(this,e)},toString(){return`Duration(${uc(this)})`},toJSON(){switch(this.value._tag){case`Millis`:return{_id:`Duration`,_tag:`Millis`,millis:this.value.millis};case`Nanos`:return{_id:`Duration`,_tag:`Nanos`,hrtime:nc(this)};case`Infinity`:return{_id:`Duration`,_tag:`Infinity`}}},[E](){return this.toJSON()},pipe(){return O(this,arguments)}},zs=e=>{let t=Object.create(Rs);return te(e)?isNaN(e)||e<=0?t.value=Is:Number.isFinite(e)?Number.isInteger(e)?t.value={_tag:`Millis`,millis:e}:t.value={_tag:`Nanos`,nanos:BigInt(Math.round(e*1e6))}:t.value=Ls:e<=Os?t.value=Is:t.value={_tag:`Nanos`,nanos:e},t},Bs=e=>v(e,Ds),Vs=e=>e.value._tag!==`Infinity`,Hs=e=>{switch(e.value._tag){case`Millis`:return e.value.millis===0;case`Nanos`:return e.value.nanos===Os;case`Infinity`:return!1}},Us=zs(0),Ws=zs(1/0),Gs=e=>zs(e),Ks=e=>zs(e*js),qs=e=>zs(e),Js=e=>zs(e*1e3),Ys=e=>zs(e*6e4),Xs=e=>zs(e*36e5),Zs=e=>zs(e*864e5),Qs=e=>zs(e*6048e5),$s=e=>rc(e,{onMillis:e=>e,onNanos:e=>Number(e)/1e6}),ec=e=>{let t=Fs(e);switch(t.value._tag){case`Infinity`:return j();case`Nanos`:return M(t.value.nanos);case`Millis`:return M(BigInt(Math.round(t.value.millis*1e6)))}},tc=e=>{let t=Fs(e);switch(t.value._tag){case`Infinity`:throw Error(`Cannot convert infinite duration to nanos`);case`Nanos`:return t.value.nanos;case`Millis`:return BigInt(Math.round(t.value.millis*1e6))}},nc=e=>{let t=Fs(e);switch(t.value._tag){case`Infinity`:return[1/0,0];case`Nanos`:return[Number(t.value.nanos/Ns),Number(t.value.nanos%Ns)];case`Millis`:return[Math.floor(t.value.millis/1e3),Math.round(t.value.millis%1e3*1e6)]}},rc=t(2,(e,t)=>{let n=Fs(e);switch(n.value._tag){case`Nanos`:return t.onNanos(n.value.nanos);case`Infinity`:return t.onMillis(1/0);case`Millis`:return t.onMillis(n.value.millis)}}),ic=t(3,(e,t,n)=>{let r=Fs(e),i=Fs(t);if(r.value._tag===`Infinity`||i.value._tag===`Infinity`)return n.onMillis($s(r),$s(i));if(r.value._tag===`Nanos`||i.value._tag===`Nanos`){let e=r.value._tag===`Nanos`?r.value.nanos:BigInt(Math.round(r.value.millis*1e6)),t=i.value._tag===`Nanos`?i.value.nanos:BigInt(Math.round(i.value.millis*1e6));return n.onNanos(e,t)}return n.onMillis(r.value.millis,i.value.millis)}),ac=(e,t)=>ic(e,t,{onMillis:(e,t)=>e===t,onNanos:(e,t)=>e===t}),oc=t(2,(e,t)=>ic(e,t,{onMillis:(e,t)=>e<=t,onNanos:(e,t)=>e<=t})),sc=t(2,(e,t)=>ic(e,t,{onMillis:(e,t)=>e>=t,onNanos:(e,t)=>e>=t})),cc=t(2,(e,t)=>ac(Fs(e),Fs(t))),lc=e=>{let t=Fs(e);if(t.value._tag===`Infinity`)return{days:1/0,hours:1/0,minutes:1/0,seconds:1/0,millis:1/0,nanos:1/0};let n=tc(t),r=n/Ms,i=r/js,a=i/As,o=a/As,s=o/ks;return{days:Number(s),hours:Number(o%ks),minutes:Number(a%As),seconds:Number(i%As),millis:Number(r%js),nanos:Number(n%Ms)}},uc=e=>{let t=Fs(e);if(t.value._tag===`Infinity`)return`Infinity`;if(Hs(t))return`0`;let n=lc(t),r=[];return n.days!==0&&r.push(`${n.days}d`),n.hours!==0&&r.push(`${n.hours}h`),n.minutes!==0&&r.push(`${n.minutes}m`),n.seconds!==0&&r.push(`${n.seconds}s`),n.millis!==0&&r.push(`${n.millis}ms`),n.nanos!==0&&r.push(`${n.nanos}ns`),r.join(` `)},dc=Symbol.for(`effect/MutableRef`),fc={[dc]:dc,toString(){return Ge(this.toJSON())},toJSON(){return{_id:`MutableRef`,current:D(this.current)}},[E](){return this.toJSON()},pipe(){return O(this,arguments)}},pc=e=>{let t=Object.create(fc);return t.current=e,t},mc=e=>e.current,hc=t(2,(e,t)=>(e.current=t,e)),gc=`effect/FiberId`,_c=Symbol.for(gc),vc=`None`,yc=`Runtime`,bc=`Composite`,xc=S(`${gc}-${vc}`);var Sc=class{[_c]=_c;_tag=vc;id=-1;startTimeMillis=-1;[y](){return xc}[w](e){return Oc(e)&&e._tag===vc}toString(){return Ge(this.toJSON())}toJSON(){return{_id:`FiberId`,_tag:this._tag}}[E](){return this.toJSON()}},Cc=class{id;startTimeMillis;[_c]=_c;_tag=yc;constructor(e,t){this.id=e,this.startTimeMillis=t}[y](){return C(this,S(`${gc}-${this._tag}-${this.id}-${this.startTimeMillis}`))}[w](e){return Oc(e)&&e._tag===yc&&this.id===e.id&&this.startTimeMillis===e.startTimeMillis}toString(){return Ge(this.toJSON())}toJSON(){return{_id:`FiberId`,_tag:this._tag,id:this.id,startTimeMillis:this.startTimeMillis}}[E](){return this.toJSON()}},wc=class{left;right;[_c]=_c;_tag=bc;constructor(e,t){this.left=e,this.right=t}_hash;[y](){return c(S(`${gc}-${this._tag}`),x(b(this.left)),x(b(this.right)),C(this))}[w](e){return Oc(e)&&e._tag===bc&&T(this.left,e.left)&&T(this.right,e.right)}toString(){return Ge(this.toJSON())}toJSON(){return{_id:`FiberId`,_tag:this._tag,left:D(this.left),right:D(this.right)}}[E](){return this.toJSON()}};const Tc=new Sc,Ec=(e,t)=>new Cc(e,t),Dc=(e,t)=>new wc(e,t),Oc=e=>v(e,_c),kc=e=>e._tag===vc||c(Nc(e),Ba(e=>kc(e))),Ac=e=>{switch(e._tag){case vc:return Ia();case yc:return Ra(e.id);case bc:return c(Ac(e.left),Ga(Ac(e.right)))}},jc=g(Symbol.for(`effect/Fiber/Id/_fiberCounter`),()=>pc(0)),Mc=e=>Array.from(Ac(e)).map(e=>`#${e}`).join(`,`),Nc=e=>{switch(e._tag){case vc:return Ia();case yc:return Ra(e);case bc:return c(Nc(e.left),Ga(Nc(e.right)))}},Pc=()=>{let e=mc(jc);return c(jc,hc(e+1)),new Cc(e,Date.now())},Fc=Tc,Ic=Ec,Lc=Dc,Rc=Oc,zc=Mc,Bc=Pc,Vc=Yi,Hc=Xi,Uc=Qi,Wc=$i,Gc=na,Kc=ia,qc=ca,Jc=da,Yc=pa,Xc=Symbol.for(`effect/List`),Zc=e=>I(e),Qc=(e=>d(hr(e),Zc))(T),$c={[Xc]:Xc,_tag:`Cons`,toString(){return Ge(this.toJSON())},toJSON(){return{_id:`List`,_tag:`Cons`,values:Zc(this).map(D)}},[E](){return this.toJSON()},[w](e){return rl(e)&&this._tag===e._tag&&Qc(this,e)},[y](){return C(this,Ie(Zc(this)))},[Symbol.iterator](){let e=!1,t=this;return{next(){if(e)return this.return();if(t._tag===`Nil`)return e=!0,this.return();let n=t.head;return t=t.tail,{done:e,value:n}},return(t){return e||=!0,{done:!0,value:t}}}},pipe(){return O(this,arguments)}},el=(e,t)=>{let n=Object.create($c);return n.head=e,n.tail=t,n},tl=S(`Nil`),nl=Object.create({[Xc]:Xc,_tag:`Nil`,toString(){return Ge(this.toJSON())},toJSON(){return{_id:`List`,_tag:`Nil`}},[E](){return this.toJSON()},[y](){return tl},[w](e){return rl(e)&&this._tag===e._tag},[Symbol.iterator](){return{next(){return{done:!0,value:void 0}}}},pipe(){return O(this,arguments)}}),rl=e=>v(e,Xc),il=e=>e._tag===`Nil`,al=e=>e._tag===`Cons`,ol=()=>nl,sl=(e,t)=>el(e,t),cl=ol,ll=e=>el(e,nl),ul=t(2,(e,t)=>fl(t,e)),dl=t(2,(e,t)=>sl(t,e)),fl=t(2,(e,t)=>{if(il(e))return t;if(il(t))return e;{let n=el(t.head,e),r=n,i=t.tail;for(;!il(i);){let t=el(i.head,e);r.tail=t,r=t,i=i.tail}return n}}),pl=t(3,(e,t,n)=>{let r=t,i=e;for(;!il(i);)r=n(r,i.head),i=i.tail;return r}),ml=e=>{let t=cl(),n=e;for(;!il(n);)t=dl(t,n.head),n=n.tail;return t};Array.prototype;const hl=function(){function e(e){e&&Object.assign(this,e)}return e.prototype=St,e}();({...hl.prototype});const gl=Symbol.for(`effect/DifferContextPatch`);function _l(e){return e}const vl={...hl.prototype,[gl]:{_Value:_l,_Patch:_l}},yl=Object.create(Object.assign(Object.create(vl),{_tag:`Empty`})),bl=()=>yl,xl=Object.assign(Object.create(vl),{_tag:`AndThen`}),Sl=(e,t)=>{let n=Object.create(xl);return n.first=e,n.second=t,n},Cl=Object.assign(Object.create(vl),{_tag:`AddService`}),wl=(e,t)=>{let n=Object.create(Cl);return n.key=e,n.service=t,n},Tl=Object.assign(Object.create(vl),{_tag:`RemoveService`}),El=e=>{let t=Object.create(Tl);return t.key=e,t},Dl=Object.assign(Object.create(vl),{_tag:`UpdateService`}),Ol=(e,t)=>{let n=Object.create(Dl);return n.key=e,n.update=t,n},kl=(e,t)=>{let n=new Map(e.unsafeMap),r=bl();for(let[e,i]of t.unsafeMap.entries())if(n.has(e)){let t=n.get(e);n.delete(e),T(t,i)||(r=Al(Ol(e,()=>i))(r))}else n.delete(e),r=Al(wl(e,i))(r);for(let[e]of n.entries())r=Al(El(e))(r);return r},Al=t(2,(e,t)=>Sl(e,t)),jl=t(2,(e,t)=>{if(e._tag===`Empty`)return t;let n=!1,r=ti(e),i=new Map(t.unsafeMap);for(;hi(r);){let e=vi(r),t=yi(r);switch(e._tag){case`Empty`:r=t;break;case`AddService`:i.set(e.key,e.service),r=t;break;case`AndThen`:r=di(di(t,e.second),e.first);break;case`RemoveService`:i.delete(e.key),r=t;break;case`UpdateService`:i.set(e.key,e.update(i.get(e.key))),n=!0,r=t;break}}if(!n)return es(i);let a=new Map;for(let[e]of t.unsafeMap)i.has(e)&&(a.set(e,i.get(e)),i.delete(e));for(let[e,t]of i)a.set(e,t);return es(a)});({...hl.prototype});const Ml=Symbol.for(`effect/DifferHashSetPatch`);function Nl(e){return e}const Pl={...hl.prototype,[Ml]:{_Value:Nl,_Key:Nl,_Patch:Nl}},Fl=Object.create(Object.assign(Object.create(Pl),{_tag:`Empty`})),Il=()=>Fl,Ll=Object.assign(Object.create(Pl),{_tag:`AndThen`}),Rl=(e,t)=>{let n=Object.create(Ll);return n.first=e,n.second=t,n},zl=Object.assign(Object.create(Pl),{_tag:`Add`}),Bl=e=>{let t=Object.create(zl);return t.value=e,t},Vl=Object.assign(Object.create(Pl),{_tag:`Remove`}),Hl=e=>{let t=Object.create(Vl);return t.value=e,t},Ul=(e,t)=>{let[n,r]=Ka([e,Il()],([e,t],n)=>za(n)(e)?[Ua(n)(e),t]:[e,Wl(Bl(n))(t)])(t);return Ka(r,(e,t)=>Wl(Hl(t))(e))(n)},Wl=t(2,(e,t)=>Rl(e,t)),Gl=t(2,(e,t)=>{if(e._tag===`Empty`)return t;let n=t,r=ti(e);for(;hi(r);){let e=vi(r),t=yi(r);switch(e._tag){case`Empty`:r=t;break;case`AndThen`:r=di(e.first)(di(e.second)(t));break;case`Add`:n=Ha(e.value)(n),r=t;break;case`Remove`:n=Ua(e.value)(n),r=t}}return n});({...hl.prototype});const Kl=Symbol.for(`effect/DifferReadonlyArrayPatch`);function ql(e){return e}const Jl={...hl.prototype,[Kl]:{_Value:ql,_Patch:ql}},Yl=Object.create(Object.assign(Object.create(Jl),{_tag:`Empty`})),Xl=()=>Yl,Zl=Object.assign(Object.create(Jl),{_tag:`AndThen`}),Ql=(e,t)=>{let n=Object.create(Zl);return n.first=e,n.second=t,n},$l=Object.assign(Object.create(Jl),{_tag:`Append`}),eu=e=>{let t=Object.create($l);return t.values=e,t},tu=Object.assign(Object.create(Jl),{_tag:`Slice`}),nu=(e,t)=>{let n=Object.create(tu);return n.from=e,n.until=t,n},ru=Object.assign(Object.create(Jl),{_tag:`Update`}),iu=(e,t)=>{let n=Object.create(ru);return n.index=e,n.patch=t,n},au=e=>{let t=0,n=Xl();for(;t<e.oldValue.length&&t<e.newValue.length;){let r=e.oldValue[t],i=e.newValue[t],a=e.differ.diff(r,i);T(a,e.differ.empty)||(n=ou(n,iu(t,a))),t+=1}return t<e.oldValue.length&&(n=ou(n,nu(0,t))),t<e.newValue.length&&(n=ou(n,eu(Xn(t)(e.newValue)))),n},ou=t(2,(e,t)=>Ql(e,t)),su=t(3,(e,t,n)=>{if(e._tag===`Empty`)return t;let r=t.slice(),i=cr(e);for(;Rn(i);){let e=Wn(i),t=qn(i);switch(e._tag){case`Empty`:i=t;break;case`AndThen`:t.unshift(e.first,e.second),i=t;break;case`Append`:for(let t of e.values)r.push(t);i=t;break;case`Slice`:r=r.slice(e.from,e.until),i=t;break;case`Update`:r[e.index]=n.patch(e.patch,r[e.index]),i=t;break}}return r}),cu={[Symbol.for(`effect/Differ`)]:{_P:n,_V:n},pipe(){return O(this,arguments)}},lu=e=>{let t=Object.create(cu);return t.empty=e.empty,t.diff=e.diff,t.combine=e.combine,t.patch=e.patch,t},uu=()=>lu({empty:bl(),combine:(e,t)=>Al(t)(e),diff:(e,t)=>kl(e,t),patch:(e,t)=>jl(t)(e)}),du=()=>lu({empty:Il(),combine:(e,t)=>Wl(t)(e),diff:(e,t)=>Ul(e,t),patch:(e,t)=>Gl(t)(e)}),fu=e=>lu({empty:Xl(),combine:(e,t)=>ou(e,t),diff:(t,n)=>au({oldValue:t,newValue:n,differ:e}),patch:(t,n)=>su(t,n,e)}),pu=()=>mu((e,t)=>t),mu=e=>lu({empty:n,combine:(e,t)=>e===n?t:t===n?e:n=>t(e(n)),diff:(e,t)=>T(e,t)?n:r(t),patch:(t,n)=>e(n,t(n))}),hu=e=>e&255,gu=e=>e>>8&255,_u=(e,t)=>(e&255)+((t&e&255)<<8),vu=_u(0,0),yu=e=>_u(e,e),bu=e=>_u(e,0),xu=t(2,(e,t)=>_u(hu(e)&~t,gu(e))),Su=t(2,(e,t)=>e|t),Cu=e=>~e>>>0&255,wu=e=>Ou(e,32),Tu=t(2,(e,t)=>e|t),Eu=e=>Du(e)&&!Mu(e),Du=e=>Ou(e,1),Ou=t(2,(e,t)=>(e&t)!==0),ku=(...e)=>e.reduce((e,t)=>e|t,0),Au=ku(0),ju=e=>Ou(e,4),Mu=e=>Ou(e,16),Nu=t(2,(e,t)=>_u(e^t,t)),Pu=t(2,(e,t)=>e&(Cu(hu(t))|gu(t))|hu(t)&gu(t)),Fu=lu({empty:vu,diff:(e,t)=>Nu(e,t),combine:(e,t)=>Su(t)(e),patch:(e,t)=>Pu(t,e)}),Iu=yu,Lu=bu,Ru=xu,zu=(e,t)=>({_tag:`Par`,left:e,right:t}),Bu=(e,t)=>({_tag:`Seq`,left:e,right:t}),Vu=e=>{let t=ll(e),n=cl();for(;;){let[e,r]=pl(t,[qu(),cl()],([e,t],n)=>{let[r,i]=Hu(n);return[Yu(e,r),ul(t,i)]});if(n=Uu(n,e),il(r))return ml(n);t=r}throw Error(`BUG: BlockedRequests.flatten - please report an issue at https://github.com/Effect-TS/effect/issues`)},Hu=e=>{let t=e,n=qu(),r=cl(),i=cl();for(;;)switch(t._tag){case`Empty`:if(il(r))return[n,i];t=r.head,r=r.tail;break;case`Par`:r=sl(t.right,r),t=t.left;break;case`Seq`:{let e=t.left,n=t.right;switch(e._tag){case`Empty`:t=n;break;case`Par`:{let r=e.left,i=e.right;t=zu(Bu(r,n),Bu(i,n));break}case`Seq`:{let r=e.left,i=e.right;t=Bu(r,Bu(i,n));break}case`Single`:t=e,i=sl(n,i);break}break}case`Single`:if(n=Ju(n,t),il(r))return[n,i];t=r.head,r=r.tail;break}throw Error(`BUG: BlockedRequests.step - please report an issue at https://github.com/Effect-TS/effect/issues`)},Uu=(e,t)=>{if(il(e))return ll(Qu(t));if(Xu(t))return e;let n=id(e.head),r=Zu(t);return n.length===1&&r.length===1&&T(n[0],r[0])?sl(rd(e.head,Qu(t)),e.tail):sl(Qu(t),e)},Wu=Symbol.for(`effect/RequestBlock/RequestBlockParallel`),Gu={_R:e=>e};var Ku=class{map;[Wu]=Gu;constructor(e){this.map=e}};const qu=()=>new Ku(Vc()),Ju=(e,t)=>new Ku(qc(e.map,t.dataSource,e=>pn(yn(e,ui(t.blockedRequest)),()=>ti(t.blockedRequest)))),Yu=(e,t)=>new Ku(Yc(e.map,t.map,(e,t,n)=>Gc(e,n,dn(Wc(e,n),{onNone:()=>t,onSome:e=>pi(t,e)})))),Xu=e=>Uc(e.map),Zu=e=>Array.from(Kc(e.map)),Qu=e=>nd(Jc(e.map,e=>ti(e))),$u=Symbol.for(`effect/RequestBlock/RequestBlockSequential`),ed={_R:e=>e};var td=class{map;[$u]=ed;constructor(e){this.map=e}};const nd=e=>new td(e),rd=(e,t)=>new td(Yc(t.map,e.map,(e,t,n)=>Gc(e,n,dn(Wc(e,n),{onNone:()=>$r(),onSome:e=>pi(e,t)})))),id=e=>Array.from(Kc(e.map)),ad=e=>Array.from(e.map),od=`Pending`,sd=`Done`,cd=Symbol.for(`effect/Deferred`),ld={_E:e=>e,_A:e=>e},ud=e=>({_tag:od,joiners:e}),dd=e=>({_tag:sd,effect:e});var fd=class e{self;called=!1;constructor(e){this.self=e}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 e(this.self)}};const pd=(e,t)=>{let n=new _d(`Blocked`);return n.effect_instruction_i0=e,n.effect_instruction_i1=t,n},md=e=>{let t=new _d(`RunBlocked`);return t.effect_instruction_i0=e,t},hd=Symbol.for(`effect/Effect`);var gd=class{patch;op;_op=ft;constructor(e,t){this.patch=e,this.op=t}},_d=class{_op;effect_instruction_i0=void 0;effect_instruction_i1=void 0;effect_instruction_i2=void 0;trace=void 0;[hd]=vt;constructor(e){this._op=e}[w](e){return this===e}[y](){return C(this,Ae(this))}pipe(){return O(this,arguments)}toJSON(){return{_id:`Effect`,_op:this._op,effect_instruction_i0:D(this.effect_instruction_i0),effect_instruction_i1:D(this.effect_instruction_i1),effect_instruction_i2:D(this.effect_instruction_i2)}}toString(){return Ge(this.toJSON())}[E](){return this.toJSON()}[Symbol.iterator](){return new fd(new we(this))}},vd=class{_op;effect_instruction_i0=void 0;effect_instruction_i1=void 0;effect_instruction_i2=void 0;trace=void 0;[hd]=vt;constructor(e){this._op=e,this._tag=e}[w](e){return xp(e)&&e._op===`Failure`&&T(this.effect_instruction_i0,e.effect_instruction_i0)}[y](){return c(S(this._tag),x(b(this.effect_instruction_i0)),C(this))}get cause(){return this.effect_instruction_i0}pipe(){return O(this,arguments)}toJSON(){return{_id:`Exit`,_tag:this._op,cause:this.cause.toJSON()}}toString(){return Ge(this.toJSON())}[E](){return this.toJSON()}[Symbol.iterator](){return new fd(new we(this))}},yd=class{_op;effect_instruction_i0=void 0;effect_instruction_i1=void 0;effect_instruction_i2=void 0;trace=void 0;[hd]=vt;constructor(e){this._op=e,this._tag=e}[w](e){return xp(e)&&e._op===`Success`&&T(this.effect_instruction_i0,e.effect_instruction_i0)}[y](){return c(S(this._tag),x(b(this.effect_instruction_i0)),C(this))}get value(){return this.effect_instruction_i0}pipe(){return O(this,arguments)}toJSON(){return{_id:`Exit`,_tag:this._op,value:D(this.value)}}toString(){return Ge(this.toJSON())}[E](){return this.toJSON()}[Symbol.iterator](){return new fd(new we(this))}};const bd=e=>v(e,hd),xd=e=>{let t=new _d(ut);return t.effect_instruction_i0=e,t},Sd=t(3,(e,t,n)=>cf(r=>R(e,e=>R(Fd(V(()=>r(t(e)))),t=>V(()=>n(e,t)).pipe(Gd({onFailure:e=>{switch(t._tag){case tt:return Rd(so(t.effect_instruction_i0,e));case at:return Rd(e)}},onSuccess:()=>t})))))),Cd=t(2,(e,t)=>R(e,()=>B(t))),wd=e=>Cd(e,void 0),Td=function(){let e=new _d(et);switch(arguments.length){case 2:e.effect_instruction_i0=arguments[0],e.commit=arguments[1];break;case 3:e.effect_instruction_i0=arguments[0],e.effect_instruction_i1=arguments[1],e.commit=arguments[2];break;case 4:e.effect_instruction_i0=arguments[0],e.effect_instruction_i1=arguments[1],e.effect_instruction_i2=arguments[2],e.commit=arguments[3];break;default:throw Error(ve(`you're not supposed to end up here`))}return e},Ed=(e,t=Fc)=>{let n=new _d($e),r;return n.effect_instruction_i0=t=>{r=e(t)},n.effect_instruction_i1=t,$d(n,e=>bd(r)?r:U)},Dd=(e,t=Fc)=>V(()=>Ed(e,t)),Od=(e,t=Fc)=>Td(e,function(){let e,n;function r(t){e?e(t):n===void 0&&(n=t)}let i=new _d($e);i.effect_instruction_i0=t=>{e=t,n&&t(n)},i.effect_instruction_i1=t;let a,o;return this.effect_instruction_i0.length===1?a=Oe(()=>this.effect_instruction_i0(r)):(o=new AbortController,a=Oe(()=>this.effect_instruction_i0(r,o.signal))),a||o?$d(i,e=>(o&&o.abort(),a??U)):i}),kd=t(2,(e,t)=>Kd(e,{onFailure:t,onSuccess:B})),Ad=Symbol.for(`effect/OriginalAnnotation`),jd=(e,t)=>P(t)?new Proxy(e,{has(e,t){return t===Ho||t===Ad||t in e},get(n,r){return r===Ho?t.value:r===Ad?e:n[r]}}):e,Md=e=>le(e)&&!(Ho in e)?xd(t=>Rd(io(jd(e,Zp(t))))):Rd(io(e)),Nd=e=>zd(()=>io(new fp(e))),Pd=e=>Kd(e,{onFailure:e=>B(A(e)),onSuccess:e=>B(k(e))}),Fd=e=>Wd(e,{onFailure:W,onSuccess:G}),Id=e=>le(e)&&!(Ho in e)?xd(t=>Rd(ro(jd(e,Zp(t))))):Rd(ro(e)),Ld=e=>R(H(e),Id),Rd=e=>{let t=new vd(tt);return t.effect_instruction_i0=e,t},zd=e=>R(H(e),Rd),Bd=xd(e=>B(e.id())),Vd=e=>xd(t=>e(t.id())),R=t(2,(e,t)=>{let n=new _d(rt);return n.effect_instruction_i0=e,n.effect_instruction_i1=t,n}),Hd=e=>{let t=new _d(`OnStep`);return t.effect_instruction_i0=e,t},Ud=e=>R(e,n),Wd=t(2,(e,t)=>Gd(e,{onFailure:e=>B(t.onFailure(e)),onSuccess:e=>B(t.onSuccess(e))})),Gd=t(2,(e,t)=>{let n=new _d(it);return n.effect_instruction_i0=e,n.effect_instruction_i1=t.onFailure,n.effect_instruction_i2=t.onSuccess,n}),Kd=t(2,(e,t)=>Gd(e,{onFailure:e=>{if(go(e).length>0)return Rd(Co(e));let n=ho(e);return n.length>0?t.onFailure(_i(n)):Rd(e)},onSuccess:t.onSuccess})),qd=t(2,(e,t)=>V(()=>{let n=I(e),r=kn(n.length),i=0;return Cd(df({while:()=>i<n.length,body:()=>t(n[i],i),step:e=>{r[i++]=e}}),r)})),Jd=t(2,(e,t)=>V(()=>{let n=I(e),r=0;return df({while:()=>r<n.length,body:()=>t(n[r],r),step:()=>{r++}})})),Yd=e=>{let t=new _d(st);return t.effect_instruction_i0=Iu(1),t.effect_instruction_i1=()=>e,t},z=t(2,(e,t)=>R(e,e=>H(()=>t(e)))),Xd=t(2,(e,t)=>Kd(e,{onFailure:e=>Ld(()=>t.onFailure(e)),onSuccess:e=>H(()=>t.onSuccess(e))})),Zd=t(2,(e,t)=>Gd(e,{onFailure:e=>{let n=yo(e);switch(n._tag){case`Left`:return Ld(()=>t(n.left));case`Right`:return Rd(n.right)}},onSuccess:B})),Qd=t(2,(e,t)=>cf(n=>Gd(n(e),{onFailure:e=>{let n=W(e);return Gd(t(n),{onFailure:t=>W(so(e,t)),onSuccess:()=>n})},onSuccess:e=>{let n=G(e);return vf(t(n),n)}}))),$d=t(2,(e,t)=>Qd(e,Mp({onFailure:e=>mo(e)?wd(t(_o(e))):U,onSuccess:()=>U}))),ef=t(2,(e,t)=>of(e,t,B)),tf=e=>nf(e,n),nf=t(2,(e,t)=>Kd(e,{onFailure:e=>Md(t(e)),onSuccess:B})),B=e=>{let t=new yd(at);return t.effect_instruction_i0=e,t},V=e=>{let t=new _d(et);return t.commit=e,t},H=e=>{let t=new _d(ot);return t.effect_instruction_i0=e,t},rf=t(e=>e.length===3||e.length===2&&!(le(e[1])&&`onlyEffect`in e[1]),(e,t)=>R(e,e=>{let n=typeof t==`function`?t(e):t;return bd(n)?Cd(n,e):_e(n)?Ed(t=>{n.then(n=>t(B(e)),e=>t(Id(new bp(e,`An unknown error occurred in Effect.tap`))))}):B(e)})),af=e=>xd(t=>e(If(tp,M(c(t.getFiberRef(tp),F(()=>t.scope())))))),of=t(3,(e,t,n)=>Gd(e,{onFailure:e=>go(e).length>0?Rd(vn(xo(e))):t(),onSuccess:n})),sf=e=>{let t=new _d(st);return t.effect_instruction_i0=Lu(1),t.effect_instruction_i1=()=>e,t},cf=e=>Td(e,function(){let e=new _d(st);return e.effect_instruction_i0=Lu(1),e.effect_instruction_i1=e=>Du(e)?Oe(()=>this.effect_instruction_i0(Yd)):Oe(()=>this.effect_instruction_i0(sf)),e}),U=B(void 0),lf=e=>{let t=new _d(st);return t.effect_instruction_i0=e,t.effect_instruction_i1=void 0,t},uf=t(2,(e,t)=>R(t,t=>t?c(e,z(M)):B(j()))),df=e=>{let t=new _d(ct);return t.effect_instruction_i0=e.while,t.effect_instruction_i1=e.body,t.effect_instruction_i2=e.step,t},ff=e=>V(()=>{let t=new _d(lt);return t.effect_instruction_i0=e(),t}),pf=function(){let e=arguments.length===1?arguments[0]:arguments[1].bind(arguments[0]);return ff(()=>e(c))},mf=(e,...t)=>Object.defineProperty(t.length===0?function(...t){return ff(()=>e.apply(this,t))}:function(...n){let r=ff(()=>e.apply(this,n));for(let e of t)r=e(r,...n);return r},`length`,{value:e.length,configurable:!0}),hf=e=>{let t=new _d(dt);return e?.priority===void 0?t:Yf(t,e.priority)},gf=t(2,(e,t)=>R(e,e=>z(t,t=>[e,t]))),_f=t(2,(e,t)=>R(e,e=>Cd(t,e))),vf=t(2,(e,t)=>R(e,()=>t)),yf=t(3,(e,t,n)=>R(e,e=>z(t,t=>n(e,t)))),bf=e=>R(Bd,t=>c(e,xf(t))),xf=t(2,(e,t)=>R(e.interruptAsFork(t),()=>e.await)),Sf={_tag:`All`,syslog:0,label:`ALL`,ordinal:-(2**53-1),pipe(){return O(this,arguments)}},Cf={_tag:`Fatal`,syslog:2,label:`FATAL`,ordinal:5e4,pipe(){return O(this,arguments)}},wf={_tag:`Error`,syslog:3,label:`ERROR`,ordinal:4e4,pipe(){return O(this,arguments)}},Tf={_tag:`Warning`,syslog:4,label:`WARN`,ordinal:3e4,pipe(){return O(this,arguments)}},Ef={_tag:`Info`,syslog:6,label:`INFO`,ordinal:2e4,pipe(){return O(this,arguments)}},Df={_tag:`Debug`,syslog:7,label:`DEBUG`,ordinal:1e4,pipe(){return O(this,arguments)}},Of={_tag:`Trace`,syslog:7,label:`TRACE`,ordinal:0,pipe(){return O(this,arguments)}},kf={_tag:`None`,syslog:7,label:`OFF`,ordinal:2**53-1,pipe(){return O(this,arguments)}},Af=Symbol.for(`effect/FiberRef`),jf={_A:e=>e},Mf=e=>xd(t=>G(t.getFiberRef(e))),Nf=t(2,(e,t)=>R(Mf(e),t)),Pf=t(2,(e,t)=>Ff(e,()=>[void 0,t])),Ff=t(2,(e,t)=>xd(n=>{let[r,i]=t(n.getFiberRef(e));return n.setFiberRef(e,i),B(r)})),If=t(3,(e,t,n)=>Sd(_f(Mf(t),Pf(t,n)),()=>e,e=>Pf(t,e))),Lf=(e,t)=>Vf(e,{differ:pu(),fork:t?.fork??n,join:t?.join}),Rf=e=>{let t=du();return Vf(e,{differ:t,fork:t.empty})},zf=e=>{let t=fu(pu());return Vf(e,{differ:t,fork:t.empty})},Bf=e=>{let t=uu();return Vf(e,{differ:t,fork:t.empty})},Vf=(e,t)=>({...Ct,[Af]:jf,initial:e,commit(){return Mf(this)},diff:(e,n)=>t.differ.diff(e,n),combine:(e,n)=>t.differ.combine(e,n),patch:e=>n=>t.differ.patch(e,n),fork:t.fork,join:t.join??((e,t)=>t)}),Hf=e=>Vf(e,{differ:Fu,fork:Fu.empty}),Uf=g(Symbol.for(`effect/FiberRef/currentContext`),()=>Bf(_s())),Wf=g(Symbol.for(`effect/FiberRef/currentSchedulingPriority`),()=>Lf(0)),Gf=g(Symbol.for(`effect/FiberRef/currentMaxOpsBeforeYield`),()=>Lf(2048)),Kf=g(Symbol.for(`effect/FiberRef/currentLogAnnotation`),()=>Lf(Vc())),qf=g(Symbol.for(`effect/FiberRef/currentLogLevel`),()=>Lf(Ef)),Jf=g(Symbol.for(`effect/FiberRef/currentLogSpan`),()=>Lf(cl())),Yf=t(2,(e,t)=>If(e,Wf,t)),Xf=g(Symbol.for(`effect/FiberRef/currentConcurrency`),()=>Lf(`unbounded`)),Zf=g(Symbol.for(`effect/FiberRef/currentRequestBatching`),()=>Lf(!0)),Qf=g(Symbol.for(`effect/FiberRef/currentUnhandledErrorLogLevel`),()=>Lf(M(Df))),$f=g(Symbol.for(`effect/FiberRef/versionMismatchErrorLogLevel`),()=>Lf(M(Tf))),ep=g(Symbol.for(`effect/FiberRef/currentMetricLabels`),()=>zf(sr())),tp=g(Symbol.for(`effect/FiberRef/currentForkScopeOverride`),()=>Lf(j(),{fork:()=>j(),join:(e,t)=>e})),np=g(Symbol.for(`effect/FiberRef/currentInterruptedCause`),()=>Lf(no,{fork:()=>no,join:(e,t)=>e})),rp=Symbol.for(`effect/Scope`),ip=Symbol.for(`effect/CloseableScope`),ap=(e,t)=>e.addFinalizer(()=>wd(t)),op=(e,t)=>e.addFinalizer(t),sp=(e,t)=>e.close(t),cp=(e,t)=>e.fork(t),lp=function(){class e extends globalThis.Error{commit(){return Id(this)}toJSON(){let e={...this};return this.message&&(e.message=this.message),this.cause&&(e.cause=this.cause),e}[E](){return this.toString===globalThis.Error.prototype.toString?`Bun`in globalThis?Fo(ro(this),{renderErrorCause:!0}):this:this.stack?`${this.toString()}\n${this.stack.split(`
`).slice(1).join(`
`)}`:this.toString()}}return Object.assign(e.prototype,wt),e}(),up=(e,t)=>{class n extends lp{_tag=t}return Object.assign(n.prototype,e),n.prototype.name=t,n},dp=Symbol.for(`effect/Cause/errors/RuntimeException`),fp=up({[dp]:dp},`RuntimeException`),pp=Symbol.for(`effect/Cause/errors/InterruptedException`),mp=e=>v(e,pp),hp=Symbol.for(`effect/Cause/errors/IllegalArgument`),gp=up({[hp]:hp},`IllegalArgumentException`),_p=Symbol.for(`effect/Cause/errors/NoSuchElement`),vp=up({[_p]:_p},`NoSuchElementException`),yp=Symbol.for(`effect/Cause/errors/UnknownException`),bp=function(){class e extends lp{_tag=`UnknownException`;error;constructor(e,t){super(t??`An unknown error occurred`,{cause:e}),this.error=e}}return Object.assign(e.prototype,{[yp]:yp,name:`UnknownException`}),e}(),xp=e=>bd(e)&&`_tag`in e&&(e._tag===`Success`||e._tag===`Failure`),Sp=e=>e._tag===`Success`,Cp=t(2,(e,t)=>{switch(e._tag){case tt:return W(e.effect_instruction_i0);case at:return G(t)}}),wp=e=>Cp(e,void 0),Tp=(e,t)=>Ip(e,t?.parallel?oo:so),Ep=e=>W(io(e)),Dp=e=>W(ro(e)),W=e=>{let t=new vd(tt);return t.effect_instruction_i0=e,t},Op=t(2,(e,t)=>{switch(e._tag){case tt:return W(e.effect_instruction_i0);case at:return t(e.effect_instruction_i0)}}),kp=e=>c(e,Op(n)),Ap=e=>W(ao(e)),jp=t(2,(e,t)=>{switch(e._tag){case tt:return W(e.effect_instruction_i0);case at:return G(t(e.effect_instruction_i0))}}),Mp=t(2,(e,{onFailure:t,onSuccess:n})=>{switch(e._tag){case tt:return t(e.effect_instruction_i0);case at:return n(e.effect_instruction_i0)}}),Np=t(2,(e,{onFailure:t,onSuccess:n})=>{switch(e._tag){case tt:return t(e.effect_instruction_i0);case at:return n(e.effect_instruction_i0)}}),G=e=>{let t=new yd(at);return t.effect_instruction_i0=e,t},Pp=G(void 0),Fp=t(3,(e,t,{onFailure:n,onSuccess:r})=>{switch(e._tag){case tt:switch(t._tag){case at:return W(e.effect_instruction_i0);case tt:return W(n(e.effect_instruction_i0,t.effect_instruction_i0))}case at:switch(t._tag){case at:return G(r(e.effect_instruction_i0,t.effect_instruction_i0));case tt:return W(t.effect_instruction_i0)}}}),Ip=(e,t)=>{let n=ni(e);return hi(n)?c(yi(n),pr(c(vi(n),jp(ti)),(e,n)=>c(e,Fp(n,{onSuccess:(e,t)=>c(e,di(t)),onFailure:t}))),jp(ai),jp(e=>ii(e)),M):j()},Lp=e=>({...Ct,[cd]:ld,state:pc(ud([])),commit(){return Bp(this)},blockingOn:e}),Rp=()=>R(Bd,e=>zp(e)),zp=e=>H(()=>Lp(e)),Bp=e=>Dd(t=>{let n=mc(e.state);switch(n._tag){case sd:return t(n.effect);case od:return n.joiners.push(t),Gp(e,t)}},e.blockingOn),Vp=t(2,(e,t)=>H(()=>{let n=mc(e.state);switch(n._tag){case sd:return!1;case od:hc(e.state,dd(t));for(let e=0,r=n.joiners.length;e<r;e++)n.joiners[e](t);return!0}})),Hp=t(2,(e,t)=>Vp(e,Rd(t))),Up=t(2,(e,t)=>Vp(e,B(t))),Wp=(e,t)=>{let n=mc(e.state);if(n._tag===`Pending`){hc(e.state,dd(t));for(let e=0,r=n.joiners.length;e<r;e++)n.joiners[e](t)}},Gp=(e,t)=>H(()=>{let n=mc(e.state);if(n._tag===`Pending`){let e=n.joiners.indexOf(t);e>=0&&n.joiners.splice(e,1)}}),Kp=xd(e=>G(e.currentContext)),qp=()=>Kp,Jp=e=>R(qp(),e),Yp=t(2,(e,t)=>If(Uf,t)(e)),Xp=t(2,(e,t)=>Jp(n=>Yp(e,t(n)))),Zp=e=>{let t=e.currentSpan;return t!==void 0&&t._tag===`Span`?M(t):j()},Qp=uo,$p=gp,em=Fo,tm=`InvalidData`,nm=`MissingData`,rm=`SourceUnavailable`,im=`Unsupported`,am=Symbol.for(`effect/ConfigError`),om={_tag:`ConfigError`,[am]:am},sm=(e,t)=>{let n=Object.create(om);return n._op=`And`,n.left=e,n.right=t,Object.defineProperty(n,`toString`,{enumerable:!1,value(){return`${this.left} and ${this.right}`}}),Object.defineProperty(n,`message`,{enumerable:!1,get(){return this.toString()}}),n},cm=(e,t)=>{let n=Object.create(om);return n._op=`Or`,n.left=e,n.right=t,Object.defineProperty(n,`toString`,{enumerable:!1,value(){return`${this.left} or ${this.right}`}}),Object.defineProperty(n,`message`,{enumerable:!1,get(){return this.toString()}}),n},lm=(e,t,n={pathDelim:`.`})=>{let r=Object.create(om);return r._op=tm,r.path=e,r.message=t,Object.defineProperty(r,`toString`,{enumerable:!1,value(){return`(Invalid data at ${c(this.path,vr(n.pathDelim))}: "${this.message}")`}}),r},um=(e,t,n={pathDelim:`.`})=>{let r=Object.create(om);return r._op=nm,r.path=e,r.message=t,Object.defineProperty(r,`toString`,{enumerable:!1,value(){return`(Missing data at ${c(this.path,vr(n.pathDelim))}: "${this.message}")`}}),r},dm=(e,t,n,r={pathDelim:`.`})=>{let i=Object.create(om);return i._op=rm,i.path=e,i.message=t,i.cause=n,Object.defineProperty(i,`toString`,{enumerable:!1,value(){return`(Source unavailable at ${c(this.path,vr(r.pathDelim))}: "${this.message}")`}}),i},fm=(e,t,n={pathDelim:`.`})=>{let r=Object.create(om);return r._op=im,r.path=e,r.message=t,Object.defineProperty(r,`toString`,{enumerable:!1,value(){return`(Unsupported operation at ${c(this.path,vr(n.pathDelim))}: "${this.message}")`}}),r},pm=t(2,(e,t)=>{switch(e._op){case`And`:return sm(pm(e.left,t),pm(e.right,t));case`Or`:return cm(pm(e.left,t),pm(e.right,t));case tm:return lm([...t,...e.path],e.message);case nm:return um([...t,...e.path],e.message);case rm:return dm([...t,...e.path],e.message,e.cause);case im:return fm([...t,...e.path],e.message)}}),mm=Symbol.for(`effect/Clock`),hm=gs(`effect/Clock`),gm=2**31-1,_m={unsafeSchedule(e,t){let n=$s(t);if(n>gm)return a;let r=!1,i=setTimeout(()=>{r=!0,e()},n);return()=>(clearTimeout(i),!r)}},vm=function(){let e=BigInt(1e6);if(typeof performance>`u`||typeof performance.now!=`function`)return()=>BigInt(Date.now())*e;let t;return()=>(t===void 0&&(t=BigInt(Date.now())*e-BigInt(Math.round(performance.now()*1e6))),t+BigInt(Math.round(performance.now()*1e6)))}(),ym=function(){let e=typeof process==`object`&&`hrtime`in process&&typeof process.hrtime.bigint==`function`?process.hrtime:void 0;if(!e)return vm;let t=vm()-e.bigint();return()=>t+e.bigint()}();var bm=class{[mm]=mm;unsafeCurrentTimeMillis(){return Date.now()}unsafeCurrentTimeNanos(){return ym()}currentTimeMillis=H(()=>this.unsafeCurrentTimeMillis());currentTimeNanos=H(()=>this.unsafeCurrentTimeNanos());scheduler(){return B(_m)}sleep(e){return Od(t=>wd(H(_m.unsafeSchedule(()=>t(U),e))))}};const xm=()=>new bm,Sm=sn,Cm=e=>{if(e===`NaN`)return Ft(NaN);if(e===`Infinity`)return Ft(1/0);if(e===`-Infinity`)return Ft(-1/0);if(e.trim()===``)return Pt;let t=Number(e);return Number.isNaN(t)?Pt:Ft(t)},wm=e=>e.replace(/[/\\^$*+?.()|[\]{}]/g,`\\$&`),Tm={_tag:`Empty`},Em=t(2,(e,t)=>{let n=ll(t),r=e;for(;al(n);){let e=n.head;switch(e._tag){case`Empty`:n=n.tail;break;case`AndThen`:n=sl(e.first,sl(e.second,n.tail));break;case`MapName`:r=lr(r,e.f),n=n.tail;break;case`Nested`:r=Nn(r,e.name),n=n.tail;break;case`Unnested`:if(c(Un(r),Tn(e.name)))r=qn(r),n=n.tail;else return A(um(r,`Expected ${e.name} to be in path in ConfigProvider#unnested`));break}}return k(r)}),Dm=(e,t)=>[...e,...t],Om=Symbol.for(`effect/ConfigProvider`),km=gs(`effect/ConfigProvider`),Am=Symbol.for(`effect/ConfigProviderFlat`),jm=e=>({[Om]:Om,pipe(){return O(this,arguments)},...e}),Mm=e=>({[Am]:Am,patch:e.patch,load:(t,n,r=!0)=>e.load(t,n,r),enumerateChildren:e.enumerateChildren}),Nm=e=>jm({load:t=>R(Lm(e,sr(),t,!1),e=>dn(Un(e),{onNone:()=>Id(um(sr(),`Expected a single value having structure: ${t}`)),onSome:B})),flattened:e}),Pm=e=>{let{pathDelim:t,seqDelim:n}=Object.assign({},{pathDelim:`_`,seqDelim:`,`},e),r=e=>c(e,vr(t)),i=e=>e.split(t),a=()=>typeof process<`u`&&`env`in process&&typeof process.env==`object`?process.env:{};return Nm(Mm({load:(e,t,i=!0)=>{let o=r(e),s=a();return c(o in s?M(s[o]):j(),Zd(()=>um(e,`Expected ${o} to exist in the process context`)),R(r=>Bm(r,e,t,n,i)))},enumerateChildren:e=>H(()=>{let t=a();return La(Object.keys(t).map(e=>i(e.toUpperCase())).filter(t=>{for(let n=0;n<e.length;n++){let r=c(e,Hn(n)),i=t[n];if(i===void 0||r!==i)return!1}return!0}).flatMap(t=>t.slice(e.length,e.length+1)))}),patch:Tm}))},Fm=(e,t,n,r)=>{let i=mr(n.length,t=>t>=r.length?j():M([e(t),t+1])),a=mr(r.length,e=>e>=n.length?j():M([t(e),e+1]));return[Dm(n,i),Dm(r,a)]},Im=(e,t)=>{let n=t;if(n._tag===`Nested`){let t=e.slice();for(;n._tag===`Nested`;)t.push(n.name),n=n.config;return t}return e},Lm=(e,t,n,r)=>{let i=n;switch(i._tag){case`Constant`:return B(cr(i.value));case`Described`:return V(()=>Lm(e,t,i.config,r));case`Fail`:return Id(um(t,i.message));case`Fallback`:return c(V(()=>Lm(e,t,i.first,r)),kd(n=>i.condition(n)?c(Lm(e,t,i.second,r),kd(e=>Id(cm(n,e)))):Id(n)));case`Lazy`:return V(()=>Lm(e,t,i.config(),r));case`MapOrFail`:return V(()=>c(Lm(e,t,i.original,r),R(qd(e=>c(i.mapOrFail(e),Zd(pm(Im(t,i.original))))))));case`Nested`:return V(()=>Lm(e,Dm(t,cr(i.name)),i.config,r));case`Primitive`:return c(Em(t,e.patch),R(t=>c(e.load(t,i,r),R(e=>{if(e.length===0){let e=c(Gn(t),F(()=>`<n/a>`));return Id(um([],`Expected ${i.description} with name ${e}`))}return B(e)}))));case`Sequence`:return c(Em(t,e.patch),R(n=>c(e.enumerateChildren(n),R(Hm),R(n=>n.length===0?V(()=>z(Lm(e,t,i.config,!0),cr)):c(qd(n,n=>Lm(e,Pn(t,`[${n}]`),i.config,!0)),z(e=>{let t=dr(e);return t.length===0?cr(sr()):cr(t)}))))));case`HashMap`:return V(()=>c(Em(t,e.patch),R(t=>c(e.enumerateChildren(t),R(n=>c(n,qd(n=>Lm(e,Dm(t,cr(n)),i.valueConfig,r)),z(e=>e.length===0?cr(Vc()):c(Vm(e),lr(e=>Hc($n(I(n),e)))))))))));case`ZipWith`:return V(()=>c(Lm(e,t,i.left,r),Pd,R(n=>c(Lm(e,t,i.right,r),Pd,R(e=>{if(Yt(n)&&Yt(e))return Id(sm(n.left,e.left));if(Yt(n)&&Xt(e))return Id(n.left);if(Xt(n)&&Yt(e))return Id(e.left);if(Xt(n)&&Xt(e)){let r=Rm(t,c(t,vr(`.`))),[a,o]=Fm(r,r,c(n.right,lr(k)),c(e.right,lr(k)));return c(a,$n(o),qd(([e,t])=>c(gf(e,t),z(([e,t])=>i.zip(e,t)))))}throw Error(`BUG: ConfigProvider.fromFlatLoop - please report an issue at https://github.com/Effect-TS/effect/issues`)})))))}},Rm=(e,t)=>n=>A(um(e,`The element at index ${n} in a sequence at path "${t}" was missing`)),zm=(e,t)=>e.split(RegExp(`\\s*${wm(t)}\\s*`)),Bm=(e,t,n,r,i)=>i?c(zm(e,r),qd(e=>n.parse(e.trim())),Zd(pm(t))):c(n.parse(e),Xd({onFailure:pm(t),onSuccess:cr})),Vm=e=>Object.keys(e[0]).map(t=>e.map(e=>e[t])),Hm=e=>c(qd(e,Wm),Xd({onFailure:()=>sr(),onSuccess:Qn(Sm)}),Pd,z(tn)),Um=/^(\[(\d+)\])$/,Wm=e=>{let t=e.match(Um);if(t!==null){let e=t[2];return c(e!==void 0&&e.length>0?M(e):j(),bn(Gm))}return j()},Gm=e=>{let t=Number.parseInt(e);return Number.isNaN(t)?j():M(t)},Km=Symbol.for(`effect/Console`),qm=gs(`effect/Console`),Jm={[Km]:Km,assert(e,...t){return H(()=>{console.assert(e,...t)})},clear:H(()=>{console.clear()}),count(e){return H(()=>{console.count(e)})},countReset(e){return H(()=>{console.countReset(e)})},debug(...e){return H(()=>{console.debug(...e)})},dir(e,t){return H(()=>{console.dir(e,t)})},dirxml(...e){return H(()=>{console.dirxml(...e)})},error(...e){return H(()=>{console.error(...e)})},group(e){return e?.collapsed?H(()=>console.groupCollapsed(e?.label)):H(()=>console.group(e?.label))},groupEnd:H(()=>{console.groupEnd()}),info(...e){return H(()=>{console.info(...e)})},log(...e){return H(()=>{console.log(...e)})},table(e,t){return H(()=>{console.table(e,t)})},time(e){return H(()=>console.time(e))},timeEnd(e){return H(()=>console.timeEnd(e))},timeLog(e,...t){return H(()=>{console.timeLog(e,...t)})},trace(...e){return H(()=>{console.trace(...e)})},warn(...e){return H(()=>{console.warn(...e)})},unsafe:console},Ym=Symbol.for(`effect/Random`),Xm=gs(`effect/Random`);var Zm=class{seed;[Ym]=Ym;PRNG;constructor(e){this.seed=e,this.PRNG=new be(e)}get next(){return H(()=>this.PRNG.number())}get nextBoolean(){return z(this.next,e=>e>.5)}get nextInt(){return H(()=>this.PRNG.integer(2**53-1))}nextRange(e,t){return z(this.next,n=>(t-e)*n+e)}nextIntBetween(e,t){return H(()=>this.PRNG.integer(t-e)+e)}shuffle(e){return Qm(e,e=>this.nextIntBetween(0,e))}};const Qm=(e,t)=>V(()=>c(H(()=>Array.from(e)),R(e=>{let n=[];for(let t=e.length;t>=2;--t)n.push(t);return c(n,Jd(n=>c(t(n),z(t=>$m(e,n-1,t)))),Cd(ni(e)))}))),$m=(e,t,n)=>{let r=e[t];return e[t]=e[n],e[n]=r,e},eh=e=>new Zm(b(e)),th=Symbol.for(`effect/Tracer`),nh=e=>({[th]:th,...e}),rh=gs(`effect/Tracer`),ih=gs(`effect/ParentSpan`),ah=function(){return function(e){let t=``;for(let n=0;n<e;n++)t+=`abcdef0123456789`.charAt(Math.floor(Math.random()*16));return t}}();var oh=class{name;parent;context;startTime;kind;_tag=`Span`;spanId;traceId=`native`;sampled=!0;status;attributes;events=[];links;constructor(e,t,n,r,i,a){this.name=e,this.parent=t,this.context=n,this.startTime=i,this.kind=a,this.status={_tag:`Started`,startTime:i},this.attributes=new Map,this.traceId=t._tag===`Some`?t.value.traceId:ah(32),this.spanId=ah(16),this.links=Array.from(r)}end(e,t){this.status={_tag:`Ended`,endTime:e,exit:t,startTime:this.status.startTime}}attribute(e,t){this.attributes.set(e,t)}event(e,t,n){this.events.push([e,t,n??{}])}addLinks(e){this.links.push(...e)}};const sh=nh({span:(e,t,n,r,i,a)=>new oh(e,t,n,r,i,a),context:e=>e()}),ch=Es()(`effect/Tracer/DisablePropagation`,{defaultValue:a}),lh=c(_s(),ys(hm,xm()),ys(qm,Jm),ys(Xm,eh(Math.random())),ys(km,Pm()),ys(rh,sh)),uh=g(Symbol.for(`effect/DefaultServices/currentServices`),()=>Bf(lh)),dh=function(){let e=Symbol.for(`effect/Data/Error/plainArgs`);return{BaseEffectError:class extends lp{constructor(t){super(t?.message,t?.cause?{cause:t.cause}:void 0),t&&(Object.assign(this,t),Object.defineProperty(this,e,{value:t,enumerable:!1}))}toJSON(){return{...this[e],...this}}}}.BaseEffectError}(),fh=e=>{let t={BaseEffectError:class extends dh{_tag=e}};return t.BaseEffectError.prototype.name=e,t.BaseEffectError},ph=xt,mh=Tt;var hh=class extends mh{};const gh=`Sequential`,_h=`Parallel`,vh={_tag:gh},yh={_tag:_h},bh=e=>({_tag:`ParallelN`,parallelism:e}),xh=e=>e._tag===gh,Sh=e=>e._tag===_h,Ch=vh,wh=yh,Th=bh;function Eh(e){return new kh(e)}function Dh(){return Eh(new Map)}const Oh=Symbol.for(`effect/FiberRefs`);var kh=class{locals;[Oh]=Oh;constructor(e){this.locals=e}pipe(){return O(this,arguments)}};const Ah=(e,t,n,r=!1)=>{let i=e,a=t,o=n,s=r,c;for(;c===void 0;)if(L(a)&&L(o)){let e=Wn(a)[0],t=qn(a),n=Wn(o)[0],r=Wn(o)[1],i=qn(o);e.startTimeMillis<n.startTimeMillis?(o=i,s=!0):e.startTimeMillis>n.startTimeMillis?a=t:e.id<n.id?(o=i,s=!0):e.id>n.id?a=t:c=[r,s]}else c=[i.initial,!0];return c},jh=t(3,(e,t,n)=>{let r=new Map(e.locals);return n.locals.forEach((e,n)=>{let i=e[0][1];if(!e[0][0][w](t)){if(!r.has(n)){if(T(i,n.initial))return;r.set(n,[[t,n.join(n.initial,i)]]);return}let a=r.get(n),[o,s]=Ah(n,a,e);if(s){let e=n.diff(o,i),s=a[0][1],c=n.join(s,n.patch(e)(s));if(!T(s,c)){let e,i=a[0][0];e=i[w](t)?[[i,c],...a.slice(1)]:[[t,c],...a],r.set(n,e)}}}}),new kh(r)}),Mh=t(2,(e,t)=>{let n=new Map;return Nh(e,n,t),new kh(n)}),Nh=(e,t,n)=>{e.locals.forEach((e,r)=>{let i=e[0][1],a=r.patch(r.fork)(i);T(i,a)?t.set(r,e):t.set(r,[[n,a],...e])})},Ph=t(2,(e,t)=>{let n=new Map(e.locals);return n.delete(t),new kh(n)}),Fh=t(2,(e,t)=>e.locals.has(t)?M(Wn(e.locals.get(t))[1]):j()),Ih=t(2,(e,t)=>c(Fh(e,t),F(()=>t.initial))),Lh=t(2,(e,{fiberId:t,fiberRef:n,value:r})=>{if(e.locals.size===0)return new kh(new Map([[n,[[t,r]]]]));let i=new Map(e.locals);return Rh(i,t,n,r),new kh(i)}),Rh=(e,t,n,r)=>{let i=e.get(n)??[],a;if(L(i)){let[e,n]=Wn(i);if(e[w](t)){if(T(n,r))return;a=[[t,r],...i.slice(1)]}else a=[[t,r],...i]}else a=[[t,r]];e.set(n,a)},zh=t(2,(e,{entries:t,forkAs:n})=>{if(e.locals.size===0)return new kh(new Map(t));let r=new Map(e.locals);return n!==void 0&&Nh(e,r,n),t.forEach(([e,t])=>{t.length===1?Rh(r,t[0][0],e,t[0][1]):t.forEach(([t,n])=>{Rh(r,t,e,n)})}),new kh(r)}),Bh=Ih,Vh=zh,Hh=Dh,Uh=`Empty`,Wh=`Remove`,Gh=`Update`,Kh=`AndThen`,qh={_tag:Uh},Jh=(e,t)=>{let n=new Map(e.locals),r=qh;for(let[e,i]of t.locals.entries()){let t=Wn(i)[1],a=n.get(e);if(a!==void 0){let n=Wn(a)[1];T(n,t)||(r=Yh({_tag:Gh,fiberRef:e,patch:e.diff(n,t)})(r))}else r=Yh({_tag:`Add`,fiberRef:e,value:t})(r);n.delete(e)}for(let[e]of n.entries())r=Yh({_tag:Wh,fiberRef:e})(r);return r},Yh=t(2,(e,t)=>({_tag:Kh,first:e,second:t})),Xh=t(3,(e,t,n)=>{let r=n,i=cr(e);for(;L(i);){let e=Wn(i),n=qn(i);switch(e._tag){case Uh:i=n;break;case`Add`:r=Lh(r,{fiberId:t,fiberRef:e.fiberRef,value:e.value}),i=n;break;case Wh:r=Ph(r,e.fiberRef),i=n;break;case Gh:{let a=Ih(r,e.fiberRef);r=Lh(r,{fiberId:t,fiberRef:e.fiberRef,value:e.fiberRef.patch(e.patch)(a)}),i=n;break}case Kh:i=Nn(e.first)(Nn(e.second)(n));break}}return r}),Zh=Jh,Qh=Xh,$h=`effect/FiberStatus`,eg=Symbol.for($h),tg=`Done`,ng=S(`${$h}-${tg}`);var rg=class{[eg]=eg;_tag=tg;[y](){return ng}[w](e){return lg(e)&&e._tag===`Done`}},ig=class{runtimeFlags;[eg]=eg;_tag=`Running`;constructor(e){this.runtimeFlags=e}[y](){return c(b($h),x(b(this._tag)),x(b(this.runtimeFlags)),C(this))}[w](e){return lg(e)&&e._tag===`Running`&&this.runtimeFlags===e.runtimeFlags}},ag=class{runtimeFlags;blockingOn;[eg]=eg;_tag=`Suspended`;constructor(e,t){this.runtimeFlags=e,this.blockingOn=t}[y](){return c(b($h),x(b(this._tag)),x(b(this.runtimeFlags)),x(b(this.blockingOn)),C(this))}[w](e){return lg(e)&&e._tag===`Suspended`&&this.runtimeFlags===e.runtimeFlags&&T(this.blockingOn,e.blockingOn)}};const og=new rg,sg=e=>new ig(e),cg=(e,t)=>new ag(e,t),lg=e=>v(e,eg),ug=e=>e._tag===tg,dg=og,fg=sg,pg=cg,mg=ug,hg=Sf,gg=Cf,_g=wf,vg=Tf,yg=Ef,bg=Df,xg=Of,Sg=kf,Cg=ln(c(Sm,cn(e=>e.ordinal))),wg=e=>{switch(e){case`All`:return hg;case`Debug`:return bg;case`Error`:return _g;case`Fatal`:return gg;case`Info`:return yg;case`Trace`:return xg;case`None`:return Sg;case`Warning`:return vg}},Tg=Symbol.for(`effect/Micro`),Eg=Symbol.for(`effect/Micro/MicroExit`),Dg=Symbol.for(`effect/Micro/MicroCause`),Og={_E:n};var kg=class extends globalThis.Error{_tag;traces;[Dg];constructor(e,t,n){let r=`MicroCause.${e}`,i,a,o;if(t instanceof globalThis.Error){i=`(${r}) ${t.name}`,a=t.message;let e=a.split(`
`).length;o=t.stack?`(${r}) ${t.stack.split(`
`).slice(0,e+3).join(`
`)}`:`${i}: ${a}`}else i=r,a=Ke(t,0),o=`${i}: ${a}`;n.length>0&&(o+=`\n    ${n.join(`
    `)}`),super(a),this._tag=e,this.traces=n,this[Dg]=Og,this.name=i,this.stack=o}pipe(){return O(this,arguments)}toString(){return this.stack}[E](){return this.stack}},Ag=class extends kg{error;constructor(e,t=[]){super(`Fail`,e,t),this.error=e}};const jg=(e,t=[])=>new Ag(e,t);var Mg=class extends kg{defect;constructor(e,t=[]){super(`Die`,e,t),this.defect=e}};const Ng=(e,t=[])=>new Mg(e,t);var Pg=class extends kg{constructor(e=[]){super(`Interrupt`,`interrupted`,e)}};const Fg=(e=[])=>new Pg(e),Ig=e=>e._tag===`Interrupt`,Lg=Symbol.for(`effect/Micro/MicroFiber`),Rg={_A:n,_E:n};var zg=class{context;interruptible;[Lg];_stack=[];_observers=[];_exit;_children;currentOpCount=0;constructor(e,t=!0){this.context=e,this.interruptible=t,this[Lg]=Rg}getRef(e){return us(this.context,e)}addObserver(e){return this._exit?(e(this._exit),s):(this._observers.push(e),()=>{let t=this._observers.indexOf(e);t>=0&&this._observers.splice(t,1)})}_interrupted=!1;unsafeInterrupt(){this._exit||(this._interrupted=!0,this.interruptible&&this.evaluate(d_))}unsafePoll(){return this._exit}evaluate(e){if(this._exit)return;if(this._yielded!==void 0){let e=this._yielded;this._yielded=void 0,e()}let t=this.runLoop(e);if(t===qg)return;let n=Bg.interruptChildren&&Bg.interruptChildren(this);if(n!==void 0)return this.evaluate(o_(n,()=>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,n=e;this.currentOpCount=0;try{for(;;){if(this.currentOpCount++,!t&&this.getRef(y_).shouldYield(this)){t=!0;let e=n;n=o_(r_,()=>e)}if(n=n[Ug](this),n===qg){let e=this._yielded;return Eg in e?(this._yielded=void 0,e):qg}}}catch(e){return v(n,Ug)?f_(e):f_(`MicroFiber.runLoop: Not a valid effect: ${String(n)}`)}}getCont(e){for(;;){let t=this._stack.pop();if(!t)return;let n=t[Kg]&&t[Kg](this);if(n)return{[e]:n};if(t[e])return t}}_yielded=void 0;yieldWith(e){return this._yielded=e,qg}children(){return this._children??=new Set}};const Bg=g(`effect/Micro/fiberMiddleware`,()=>({interruptChildren:void 0})),Vg=Symbol.for(`effect/Micro/identifier`),Hg=Symbol.for(`effect/Micro/args`),Ug=Symbol.for(`effect/Micro/evaluate`),Wg=Symbol.for(`effect/Micro/successCont`),Gg=Symbol.for(`effect/Micro/failureCont`),Kg=Symbol.for(`effect/Micro/ensureCont`),qg=Symbol.for(`effect/Micro/Yield`),Jg={_A:n,_E:n,_R:n},Yg={...ph,_op:`Micro`,[Tg]:Jg,pipe(){return O(this,arguments)},[Symbol.iterator](){return new ye(new we(this))},toJSON(){return{_id:`Micro`,op:this[Vg],...Hg in this?{args:this[Hg]}:void 0}},toString(){return Ge(this)},[E](){return Ge(this)}};function Xg(e){return f_(`Micro.evaluate: Not implemented`)}const Zg=e=>({...Yg,[Vg]:e.op,[Ug]:e.eval??Xg,[Wg]:e.contA,[Gg]:e.contE,[Kg]:e.ensure}),Qg=e=>{let t=Zg(e);return function(){let n=Object.create(t);return n[Hg]=e.single===!1?arguments:arguments[0],n}},$g=e=>{let t={...Zg(e),[Eg]:Eg,_tag:e.op,get[e.prop](){return this[Hg]},toJSON(){return{_id:`MicroExit`,_tag:e.op,[e.prop]:this[Hg]}},[w](t){return c_(t)&&t._tag===e.op&&T(this[Hg],t[Hg])},[y](){return C(this,x(S(e.op))(b(this[Hg])))}};return function(e){let n=Object.create(t);return n[Hg]=e,n[Wg]=void 0,n[Gg]=void 0,n[Kg]=void 0,n}},e_=$g({op:`Success`,prop:`value`,eval(e){let t=e.getCont(Wg);return t?t[Wg](this[Hg],e):e.yieldWith(this)}}),t_=$g({op:`Failure`,prop:`cause`,eval(e){let t=e.getCont(Gg);for(;Ig(this[Hg])&&t&&e.interruptible;)t=e.getCont(Gg);return t?t[Gg](this[Hg],e):e.yieldWith(this)}}),n_=e=>t_(jg(e)),r_=Qg({op:`Yield`,eval(e){let t=!1;return e.getRef(y_).scheduleTask(()=>{t||e.evaluate(p_)},this[Hg]??0),e.yieldWith(()=>{t=!0})}})(0),i_=e_(void 0),a_=Qg({op:`WithMicroFiber`,eval(e){return this[Hg](e)}}),o_=t(2,(e,t)=>{let n=Object.create(s_);return n[Hg]=e,n[Wg]=t,n}),s_=Zg({op:`OnSuccess`,eval(e){return e._stack.push(this),this[Hg]}}),c_=e=>v(e,Eg),l_=e_,u_=t_,d_=u_(Fg()),f_=e=>u_(Ng(e)),p_=l_(void 0),m_=`setImmediate`in globalThis?globalThis.setImmediate:e=>setTimeout(e,0);var h_=class{tasks=[];running=!1;scheduleTask(e,t){this.tasks.push(e),this.running||(this.running=!0,m_(this.afterScheduled))}afterScheduled=()=>{this.running=!1,this.runTasks()};runTasks(){let e=this.tasks;this.tasks=[];for(let t=0,n=e.length;t<n;t++)e[t]()}shouldYield(e){return e.currentOpCount>=e.getRef(v_)}flush(){for(;this.tasks.length>0;)this.runTasks()}};const g_=t(2,(e,t)=>a_(n=>{let r=n.context;return n.context=t(r),S_(e,()=>(n.context=r,i_))})),__=t(2,(e,t)=>g_(e,Cs(t)));var v_=class extends Es()(`effect/Micro/currentMaxOpsBeforeYield`,{defaultValue:()=>2048}){};Es()(`effect/Micro/currentConcurrency`,{defaultValue:()=>`unbounded`});var y_=class extends Es()(`effect/Micro/currentScheduler`,{defaultValue:()=>new h_}){};const b_=t(2,(e,t)=>{let n=Object.create(x_);return n[Hg]=e,n[Wg]=t.onSuccess,n[Gg]=t.onFailure,n}),x_=Zg({op:`OnSuccessAndFailure`,eval(e){return e._stack.push(this),this[Hg]}}),S_=t(2,(e,t)=>T_(n=>b_(n(e),{onFailure:e=>o_(t(u_(e)),()=>t_(e)),onSuccess:e=>o_(t(l_(e)),()=>e_(e))}))),C_=Qg({op:`SetInterruptible`,ensure(e){if(e.interruptible=this[Hg],e._interrupted&&e.interruptible)return()=>d_}}),w_=e=>a_(t=>t.interruptible?e:(t.interruptible=!0,t._stack.push(C_(!1)),t._interrupted?d_:e)),T_=e=>a_(t=>t.interruptible?(t.interruptible=!1,t._stack.push(C_(!0)),e(w_)):e(n)),E_=(e,t)=>{let n=new zg(y_.context(t?.scheduler??new h_));if(n.evaluate(e),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},D_=function(){class e extends globalThis.Error{}return Object.assign(e.prototype,Yg,St,{[Vg]:`Failure`,[Ug](){return n_(this)},toString(){return this.message?`${this.name}: ${this.message}`:this.name},toJSON(){return{...this}},[E](){let e=this.stack;return e?`${this.toString()}\n${e.split(`
`).slice(1).join(`
`)}`:this.toString()}}),e}(),O_=function(){return class extends D_{constructor(e){super(),e&&Object.assign(this,e)}}}(),k_=e=>{class t extends O_{_tag=e}return t.prototype.name=e,t};k_(`NoSuchElementException`),k_(`TimeoutException`);const A_=Symbol.for(`effect/Readable`),j_=Symbol.for(`effect/Ref`),M_={_A:e=>e};var N_=class extends hh{ref;commit(){return this.get}[j_]=M_;[A_]=A_;constructor(e){super(),this.ref=e,this.get=H(()=>mc(this.ref))}get;modify(e){return H(()=>{let t=mc(this.ref),[n,r]=e(t);return t!==r&&hc(r)(this.ref),n})}};const P_=e=>new N_(pc(e)),F_=e=>H(()=>P_(e)),I_=e=>e.get,L_=t(2,(e,t)=>e.modify(()=>[void 0,t])),R_=t(2,(e,t)=>e.modify(t)),z_=t(2,(e,t)=>e.modify(e=>[void 0,t(e)]));var B_=class e{scheduleDrain;running=!1;tasks=new V_;constructor(e){this.scheduleDrain=e}starveInternal=e=>{let t=this.tasks.buckets;this.tasks.buckets=[];for(let[e,n]of t)for(let e=0;e<n.length;e++)n[e]();this.tasks.buckets.length===0?this.running=!1:this.starve(e)};starve(e=0){this.scheduleDrain(e,this.starveInternal)}scheduleTask(e,t){this.tasks.scheduleTask(e,t),this.running||(this.running=!0,this.starve())}static cached(t){let n=new e(t),r=new WeakMap;return i=>{if(i===void 0)return n;let a=r.get(i);return a===void 0&&(a=new e(t),r.set(i,a)),a}}},V_=class{buckets=[];scheduleTask(e,t){let n=this.buckets.length,r,i=0;for(;i<n&&this.buckets[i][0]<=t;i++)r=this.buckets[i];r&&r[0]===t?r[1].push(e):i===n?this.buckets.push([t,[e]]):this.buckets.splice(i,0,[t,[e]])}},H_=class{maxNextTickBeforeTimer;getRunner=B_.cached((e,t)=>{e>=this.maxNextTickBeforeTimer?setTimeout(()=>t(0),0):Promise.resolve(void 0).then(()=>t(e+1))});constructor(e){this.maxNextTickBeforeTimer=e}shouldYield(e){return e.currentOpCount>e.getFiberRef(Gf)?e.getFiberRef(Wf):!1}scheduleTask(e,t,n){this.getRunner(n).scheduleTask(e,t)}};const U_=g(Symbol.for(`effect/Scheduler/defaultScheduler`),()=>new H_(2048));var W_=class{tasks=new V_;deferred=!1;scheduleTask(e,t,n){this.deferred?U_.scheduleTask(e,t,n):this.tasks.scheduleTask(e,t)}shouldYield(e){return e.currentOpCount>e.getFiberRef(Gf)?e.getFiberRef(Wf):!1}flush(){for(;this.tasks.buckets.length>0;){let e=this.tasks.buckets;this.tasks.buckets=[];for(let[t,n]of e)for(let e=0;e<n.length;e++)n[e]()}this.deferred=!0}};const G_=g(Symbol.for(`effect/FiberRef/currentScheduler`),()=>Lf(U_)),K_=g(Symbol.for(`effect/FiberRef/currentRequestMap`),()=>Lf(new Map)),q_=(e,t,n,r)=>{switch(e){case void 0:return t();case`unbounded`:return n();case`inherit`:return Nf(Xf,e=>e===`unbounded`?n():e>1?r(e):t());default:return e>1?r(e):t()}},J_=e=>e.replace(/[\s="]/g,`_`),Y_=e=>t=>`${J_(t.label)}=${e-t.startTime}ms`,X_=`effect/MetricLabel`,Z_=Symbol.for(X_);var Q_=class{key;value;[Z_]=Z_;_hash;constructor(e,t){this.key=e,this.value=t,this._hash=S(X_+this.key+this.value)}[y](){return this._hash}[w](e){return ev(e)&&this.key===e.key&&this.value===e.value}pipe(){return O(this,arguments)}};const $_=(e,t)=>new Q_(e,t),ev=e=>v(e,Z_),tv=e=>z(e,M),nv=e=>hv(e,ov,Jh),rv=e=>ef(e,()=>R(hf(),()=>rv(e))),iv=(e,t,n,r)=>R(n(r,t),i=>{if(i)return B(M(r));let a=e.next();return a.done?B(j()):iv(e,t+1,n,a.value)}),av=(e,t,n)=>{let r=e.next();return r.done?B(!0):R(n(r.value,t),r=>r?av(e,t+1,n):B(r))},ov=xd(e=>B(e.getFiberRefs())),sv=(e,t)=>V(()=>t.while(e)?R(t.body(e),e=>sv(e,t)):B(e)),cv=(e,t,n,r)=>V(()=>t(e)?R(r(e),i=>z(cv(n(e),t,n,r),dl(i))):H(()=>cl())),lv=(e,t,n,r)=>V(()=>t(e)?R(r(e),()=>lv(n(e),t,n,r)):U),uv=e=>gv((t,n)=>c(e,Xh(t,n))),dv=t(3,(e,t,n)=>Jp(r=>Yp(e,ys(r,t,n)))),fv=(e,t,n,r,i)=>{let a=e.next();return!a.done&&r(n)?R(i(n,a.value,t),n=>fv(e,t+1,n,r,i)):B(n)},pv=(e,t)=>R(e,n=>t<=0?B(n):vf(hf(),pv(e,t-1))),mv=B(j()),hv=t(3,(e,t,n)=>R(t,r=>R(e,e=>z(t,t=>[n(r,t),e])))),gv=e=>xd(t=>(t.setFiberRefs(e(t.id(),t.getFiberRefs())),U)),_v=bn(e=>bs(e.context,ch)?e._tag===`Span`?_v(e.parent):j():M(e)),vv=Sp,yv=kp,bv=`InterruptSignal`,xv=`Stateful`,Sv=`Resume`,Cv=`YieldNow`,wv=e=>({_tag:bv,cause:e}),Tv=e=>({_tag:xv,onFiber:e}),Ev=e=>({_tag:Sv,effect:e}),Dv=()=>({_tag:Cv}),Ov=Symbol.for(`effect/FiberScope`);var kv=class{[Ov]=Ov;fiberId=Fc;roots=new Set;add(e,t){this.roots.add(t),t.addObserver(()=>{this.roots.delete(t)})}},Av=class{fiberId;parent;[Ov]=Ov;constructor(e,t){this.fiberId=e,this.parent=t}add(e,t){this.parent.tell(Tv(e=>{e.addChild(t),t.addObserver(()=>{e.removeChild(t)})}))}};const jv=e=>new Av(e.id(),e),Mv=g(Symbol.for(`effect/FiberScope/Global`),()=>new kv),Nv=Symbol.for(`effect/Fiber`),Pv={_E:e=>e,_A:e=>e},Fv={[Nv]:Pv,pipe(){return O(this,arguments)}},Iv=Symbol.for(`effect/Fiber`),Lv=e=>_f(Ud(e.await),e.inheritAll);({...Ct}),{...Fv};const Rv=`effect/FiberCurrent`,zv=Symbol.for(`effect/Logger`),Bv={_Message:e=>e,_Output:e=>e},Vv=e=>({[zv]:Bv,log:e,pipe(){return O(this,arguments)}}),Hv=/^[^\s"=]*$/,Uv=Vv(((e,t)=>({annotations:n,cause:r,date:i,fiberId:a,logLevel:o,message:s,spans:c})=>{let l=t=>t.match(Hv)?t:e(t),u=(e,t)=>`${J_(e)}=${l(t)}`,d=(e,t)=>` `+u(e,t),f=u(`timestamp`,i.toISOString());f+=d(`level`,o.label),f+=d(`fiber`,Mc(a));let p=jn(s);for(let e=0;e<p.length;e++)f+=d(`message`,Ke(p[e],t));lo(r)||(f+=d(`cause`,Fo(r,{renderErrorCause:!0})));for(let e of c)f+=` `+Y_(i.getTime())(e);for(let[e,r]of n)f+=d(e,Ke(r,t));return f})(e=>`"${e.replace(/\\([\s\S])|(")/g,`\\$1$2`)}"`)),Wv={bold:`1`,red:`31`,green:`32`,yellow:`33`,blue:`34`,cyan:`36`,white:`37`,gray:`90`,black:`30`,bgBrightRed:`101`};Wv.gray,Wv.blue,Wv.green,Wv.yellow,Wv.red,Wv.bgBrightRed,Wv.black;const Gv=typeof process==`object`&&process!==null&&typeof process.stdout==`object`&&process.stdout!==null;Gv&&process.stdout.isTTY,Gv||`Deno`in globalThis;const Kv=`effect/MetricBoundaries`,qv=Symbol.for(Kv);var Jv=class{values;[qv]=qv;constructor(e){this.values=e,this._hash=c(S(Kv),x(Ie(this.values)))}_hash;[y](){return this._hash}[w](e){return Yv(e)&&T(this.values,e.values)}pipe(){return O(this,arguments)}};const Yv=e=>v(e,qv),Xv=e=>new Jv(c(e,Fn(ti(1/0)),_r)),Zv=e=>c(An(e.count-1,t=>e.start*e.factor**+t),si,Xv),Qv=Symbol.for(`effect/MetricKeyType`),$v=`effect/MetricKeyType/Counter`,ey=Symbol.for($v),ty=Symbol.for(`effect/MetricKeyType/Frequency`),ny=Symbol.for(`effect/MetricKeyType/Gauge`),ry=`effect/MetricKeyType/Histogram`,iy=Symbol.for(ry),ay=Symbol.for(`effect/MetricKeyType/Summary`),oy={_In:e=>e,_Out:e=>e};var sy=class{incremental;bigint;[Qv]=oy;[ey]=ey;constructor(e,t){this.incremental=e,this.bigint=t,this._hash=S($v)}_hash;[y](){return this._hash}[w](e){return dy(e)}pipe(){return O(this,arguments)}},cy=class{boundaries;[Qv]=oy;[iy]=iy;constructor(e){this.boundaries=e,this._hash=c(S(ry),x(b(this.boundaries)))}_hash;[y](){return this._hash}[w](e){return my(e)&&T(this.boundaries,e.boundaries)}pipe(){return O(this,arguments)}};const ly=e=>new sy(e?.incremental??!1,e?.bigint??!1),uy=e=>new cy(e),dy=e=>v(e,ey),fy=e=>v(e,ty),py=e=>v(e,ny),my=e=>v(e,iy),hy=e=>v(e,ay),gy=Symbol.for(`effect/MetricKey`),_y={_Type:e=>e},vy=hr(T);var yy=class{name;keyType;description;tags;[gy]=_y;constructor(e,t,n,r=[]){this.name=e,this.keyType=t,this.description=n,this.tags=r,this._hash=c(S(this.name+this.description),x(b(this.keyType)),x(Ie(this.tags)))}_hash;[y](){return this._hash}[w](e){return by(e)&&this.name===e.name&&T(this.keyType,e.keyType)&&T(this.description,e.description)&&vy(this.tags,e.tags)}pipe(){return O(this,arguments)}};const by=e=>v(e,gy),xy=(e,t)=>new yy(e,ly(t),mn(t?.description)),Sy=(e,t,n)=>new yy(e,uy(t),mn(n)),Cy=t(2,(e,t)=>t.length===0?e:new yy(e.name,e.keyType,e.description,or(e.tags,t))),wy=Symbol.for(`effect/MutableHashMap`),Ty={[wy]:wy,[Symbol.iterator](){return new Ey(this)},toString(){return Ge(this.toJSON())},toJSON(){return{_id:`MutableHashMap`,values:Array.from(this).map(D)}},[E](){return this.toJSON()},pipe(){return O(this,arguments)}};var Ey=class e{self;referentialIterator;bucketIterator;constructor(e){this.self=e,this.referentialIterator=e.referential[Symbol.iterator]()}next(){if(this.bucketIterator!==void 0)return this.bucketIterator.next();let e=this.referentialIterator.next();return e.done?(this.bucketIterator=new Dy(this.self.buckets.values()),this.next()):e}[Symbol.iterator](){return new e(this.self)}},Dy=class{backing;constructor(e){this.backing=e}currentBucket;next(){if(this.currentBucket===void 0){let e=this.backing.next();if(e.done)return e;this.currentBucket=e.value[Symbol.iterator]()}let e=this.currentBucket.next();return e.done?(this.currentBucket=void 0,this.next()):e}};const Oy=()=>{let e=Object.create(Ty);return e.referential=new Map,e.buckets=new Map,e.bucketsSize=0,e},ky=t(2,(e,t)=>{if(Re(t)===!1)return e.referential.has(t)?M(e.referential.get(t)):j();let n=t[y](),r=e.buckets.get(n);return r===void 0?j():Ay(e,r,t)}),Ay=(e,t,n,r=!1)=>{for(let i=0,a=t.length;i<a;i++)if(n[w](t[i][0])){let n=t[i][1];return r&&(t.splice(i,1),e.bucketsSize--),M(n)}return j()},jy=t(2,(e,t)=>P(ky(e,t))),My=t(3,(e,t,n)=>{if(Re(t)===!1)return e.referential.set(t,n),e;let r=t[y](),i=e.buckets.get(r);return i===void 0?(e.buckets.set(r,[[t,n]]),e.bucketsSize++,e):(Ny(e,i,t),i.push([t,n]),e.bucketsSize++,e)}),Ny=(e,t,n)=>{for(let r=0,i=t.length;r<i;r++)if(n[w](t[r][0])){t.splice(r,1),e.bucketsSize--;return}},Py=Symbol.for(`effect/MetricState`),Fy=`effect/MetricState/Counter`,Iy=Symbol.for(Fy),Ly=`effect/MetricState/Frequency`,Ry=Symbol.for(Ly),zy=`effect/MetricState/Gauge`,By=Symbol.for(zy),Vy=`effect/MetricState/Histogram`,Hy=Symbol.for(Vy),Uy=`effect/MetricState/Summary`,Wy=Symbol.for(Uy),Gy={_A:e=>e};var Ky=class{count;[Py]=Gy;[Iy]=Iy;constructor(e){this.count=e}[y](){return c(b(Fy),x(b(this.count)),C(this))}[w](e){return rb(e)&&this.count===e.count}pipe(){return O(this,arguments)}};const qy=hr(T);var Jy=class{occurrences;[Py]=Gy;[Ry]=Ry;constructor(e){this.occurrences=e}_hash;[y](){return c(S(Ly),x(Ie(I(this.occurrences.entries()))),C(this))}[w](e){return ib(e)&&qy(I(this.occurrences.entries()),I(e.occurrences.entries()))}pipe(){return O(this,arguments)}},Yy=class{value;[Py]=Gy;[By]=By;constructor(e){this.value=e}[y](){return c(b(zy),x(b(this.value)),C(this))}[w](e){return ab(e)&&this.value===e.value}pipe(){return O(this,arguments)}},Xy=class{buckets;count;min;max;sum;[Py]=Gy;[Hy]=Hy;constructor(e,t,n,r,i){this.buckets=e,this.count=t,this.min=n,this.max=r,this.sum=i}[y](){return c(b(Vy),x(b(this.buckets)),x(b(this.count)),x(b(this.min)),x(b(this.max)),x(b(this.sum)),C(this))}[w](e){return ob(e)&&T(this.buckets,e.buckets)&&this.count===e.count&&this.min===e.min&&this.max===e.max&&this.sum===e.sum}pipe(){return O(this,arguments)}},Zy=class{error;quantiles;count;min;max;sum;[Py]=Gy;[Wy]=Wy;constructor(e,t,n,r,i,a){this.error=e,this.quantiles=t,this.count=n,this.min=r,this.max=i,this.sum=a}[y](){return c(b(Uy),x(b(this.error)),x(b(this.quantiles)),x(b(this.count)),x(b(this.min)),x(b(this.max)),x(b(this.sum)),C(this))}[w](e){return sb(e)&&this.error===e.error&&T(this.quantiles,e.quantiles)&&this.count===e.count&&this.min===e.min&&this.max===e.max&&this.sum===e.sum}pipe(){return O(this,arguments)}};const Qy=e=>new Ky(e),$y=e=>new Jy(e),eb=e=>new Yy(e),tb=e=>new Xy(e.buckets,e.count,e.min,e.max,e.sum),nb=e=>new Zy(e.error,e.quantiles,e.count,e.min,e.max,e.sum),rb=e=>v(e,Iy),ib=e=>v(e,Ry),ab=e=>v(e,By),ob=e=>v(e,Hy),sb=e=>v(e,Wy),cb=Symbol.for(`effect/MetricHook`),lb={_In:e=>e,_Out:e=>e},ub=e=>({[cb]:lb,pipe(){return O(this,arguments)},...e}),db=BigInt(0),fb=e=>{let t=e.keyType.bigint?db:0,n=e.keyType.incremental?e.keyType.bigint?e=>e>=db:e=>e>=0:e=>!0,r=e=>{n(e)&&(t+=e)};return ub({get:()=>Qy(t),update:r,modify:r})},pb=e=>{let t=new Map;for(let n of e.keyType.preregisteredWords)t.set(n,0);let n=e=>{let n=t.get(e)??0;t.set(e,n+1)};return ub({get:()=>$y(t),update:n,modify:n})},mb=(e,t)=>{let n=t;return ub({get:()=>eb(n),update:e=>{n=e},modify:e=>{n+=e}})},hb=e=>{let t=e.keyType.boundaries.values,n=t.length,r=new Uint32Array(n+1),i=new Float64Array(n),a=0,o=0,s=Number.MAX_VALUE,l=Number.MIN_VALUE;c(t,Qn(Sm),lr((e,t)=>{i[t]=e}));let u=e=>{let t=0,c=n;for(;t!==c;){let n=Math.floor(t+(c-t)/2);e<=i[n]?c=n:t=n,c===t+1&&(e<=i[t]?c=t:t=c)}r[t]=r[t]+1,a+=1,o+=e,e<s&&(s=e),e>l&&(l=e)},d=()=>{let e=kn(n),t=0;for(let a=0;a<n;a++){let n=i[a],o=r[a];t+=o,e[a]=[n,t]}return e};return ub({get:()=>tb({buckets:d(),count:a,min:s,max:l,sum:o}),update:u,modify:u})},gb=e=>{let{error:t,maxAge:n,maxSize:r,quantiles:i}=e.keyType,a=c(i,Qn(Sm)),o=kn(r),s=0,l=0,u=0,d=0,f=0,p=e=>{let i=[],s=0;for(;s!==r-1;){let t=o[s];if(t!=null){let[r,a]=t,o=qs(e-r);sc(o,Us)&&oc(o,n)&&i.push(a)}s+=1}return _b(t,a,Qn(i,Sm))},m=(e,t)=>{if(r>0){s+=1;let n=s%r;o[n]=[t,e]}d=l===0?e:Math.min(d,e),f=l===0?e:Math.max(f,e),l+=1,u+=e};return ub({get:()=>nb({error:t,quantiles:p(Date.now()),count:l,min:d,max:f,sum:u}),update:([e,t])=>m(e,t),modify:([e,t])=>m(e,t)})},_b=(e,t,n)=>{let r=n.length;if(!L(t))return sr();let i=t[0],a=t.slice(1),o=vb(e,r,j(),0,i,n),s=cr(o);return a.forEach(t=>{s.push(vb(e,r,o.value,o.consumed,t,o.rest))}),lr(s,e=>[e.quantile,e.value])},vb=(e,t,n,r,i,a)=>{let o=e,s=t,c=n,l=r,u=i,d=a,f=e,p=t,m=n,h=r,g=i,ee=a;for(;;){if(!L(d))return{quantile:u,value:j(),consumed:l,rest:[]};if(u===1)return{quantile:u,value:M(Kn(d)),consumed:l+d.length,rest:[]};let e=Wn(d),t=Yn(d,t=>t===e),n=u*s,r=o/2*n,i=l+t[0].length,a=Math.abs(i-n);if(i<n-r){f=o,p=s,m=Un(d),h=i,g=u,ee=t[1],o=f,s=p,c=m,l=h,u=g,d=ee;continue}if(i>n+r){let t=N(c)?M(e):c;return{quantile:u,value:t,consumed:l,rest:d}}switch(c._tag){case`None`:f=o,p=s,m=Un(d),h=i,g=u,ee=t[1],o=f,s=p,c=m,l=h,u=g,d=ee;continue;case`Some`:if(a<Math.abs(n-c.value)){f=o,p=s,m=Un(d),h=i,g=u,ee=t[1],o=f,s=p,c=m,l=h,u=g,d=ee;continue}return{quantile:u,value:M(c.value),consumed:l,rest:d}}}throw Error(`BUG: MetricHook.resolveQuantiles - please report an issue at https://github.com/Effect-TS/effect/issues`)},yb=Symbol.for(`effect/MetricPair`),bb={_Type:e=>e},xb=(e,t)=>({[yb]:bb,metricKey:e,metricState:t,pipe(){return O(this,arguments)}}),Sb=Symbol.for(`effect/MetricRegistry`);var Cb=class{[Sb]=Sb;map=Oy();snapshot(){let e=[];for(let[t,n]of this.map)e.push(xb(t,n.get()));return e}get(e){let t=c(this.map,ky(e),hn);if(t==null){if(dy(e.keyType))return this.getCounter(e);if(py(e.keyType))return this.getGauge(e);if(fy(e.keyType))return this.getFrequency(e);if(my(e.keyType))return this.getHistogram(e);if(hy(e.keyType))return this.getSummary(e);throw Error(`BUG: MetricRegistry.get - unknown MetricKeyType - please report an issue at https://github.com/Effect-TS/effect/issues`)}else return t}getCounter(e){let t=c(this.map,ky(e),hn);if(t==null){let n=fb(e);c(this.map,jy(e))||c(this.map,My(e,n)),t=n}return t}getFrequency(e){let t=c(this.map,ky(e),hn);if(t==null){let n=pb(e);c(this.map,jy(e))||c(this.map,My(e,n)),t=n}return t}getGauge(e){let t=c(this.map,ky(e),hn);if(t==null){let n=mb(e,e.keyType.bigint?BigInt(0):0);c(this.map,jy(e))||c(this.map,My(e,n)),t=n}return t}getHistogram(e){let t=c(this.map,ky(e),hn);if(t==null){let n=hb(e);c(this.map,jy(e))||c(this.map,My(e,n)),t=n}return t}getSummary(e){let t=c(this.map,ky(e),hn);if(t==null){let n=gb(e);c(this.map,jy(e))||c(this.map,My(e,n)),t=n}return t}};const wb=()=>new Cb,Tb=Symbol.for(`effect/Metric`),Eb={_Type:e=>e,_In:e=>e,_Out:e=>e},Db=g(Symbol.for(`effect/Metric/globalMetricRegistry`),()=>wb()),Ob=function(e,t,n,r){let i=Object.assign(e=>rf(e,e=>Pb(i,e)),{[Tb]:Eb,keyType:e,unsafeUpdate:t,unsafeValue:n,unsafeModify:r,register(){return this.unsafeValue([]),this},pipe(){return O(this,arguments)}});return i},kb=(e,t)=>Ab(xy(e,t)),Ab=e=>{let t,n=new WeakMap,r=r=>{if(r.length===0)return t===void 0&&(t=Db.get(e)),t;let i=n.get(r);return i===void 0?(i=Db.get(Cy(e,r)),n.set(r,i),i):i};return Ob(e.keyType,(e,t)=>r(t).update(e),e=>r(e).get(),(e,t)=>r(t).modify(e))},jb=(e,t,n)=>Ab(Sy(e,t,n)),Mb=t(3,(e,t,n)=>Nb(e,[$_(t,n)])),Nb=t(2,(e,t)=>Ob(e.keyType,(n,r)=>e.unsafeUpdate(n,or(t,r)),n=>e.unsafeValue(or(t,n)),(n,r)=>e.unsafeModify(n,or(t,r)))),Pb=t(2,(e,t)=>Nf(ep,n=>H(()=>e.unsafeUpdate(t,n))));({...St});const Fb=t(2,(e,t)=>Nf(K_,n=>H(()=>{if(n.has(e)){let r=n.get(e);r.state.completed||(r.state.completed=!0,Wp(r.result,t))}}))),Ib=Symbol.for(`effect/Supervisor`),Lb={_T:e=>e};var Rb=class e{underlying;value0;[Ib]=Lb;constructor(e,t){this.underlying=e,this.value0=t}get value(){return this.value0}onStart(e,t,n,r){this.underlying.onStart(e,t,n,r)}onEnd(e,t){this.underlying.onEnd(e,t)}onEffect(e,t){this.underlying.onEffect(e,t)}onSuspend(e){this.underlying.onSuspend(e)}onResume(e){this.underlying.onResume(e)}map(t){return new e(this,c(this.value,z(t)))}zip(e){return new zb(this,e)}},zb=class e{left;right;_tag=`Zip`;[Ib]=Lb;constructor(e,t){this.left=e,this.right=t}get value(){return gf(this.left.value,this.right.value)}onStart(e,t,n,r){this.left.onStart(e,t,n,r),this.right.onStart(e,t,n,r)}onEnd(e,t){this.left.onEnd(e,t),this.right.onEnd(e,t)}onEffect(e,t){this.left.onEffect(e,t),this.right.onEffect(e,t)}onSuspend(e){this.left.onSuspend(e),this.right.onSuspend(e)}onResume(e){this.left.onResume(e),this.right.onResume(e)}map(e){return new Rb(this,c(this.value,z(e)))}zip(t){return new e(this,t)}};const Bb=e=>v(e,Ib)&&ue(e,`Zip`);var Vb=class{effect;[Ib]=Lb;constructor(e){this.effect=e}get value(){return this.effect}onStart(e,t,n,r){}onEnd(e,t){}onEffect(e,t){}onSuspend(e){}onResume(e){}map(e){return new Rb(this,c(this.value,z(e)))}zip(e){return new zb(this,e)}onRun(e,t){return e()}};const Hb=e=>new Vb(e),Ub=g(`effect/Supervisor/none`,()=>Hb(U)),Wb=lu,Gb=`Empty`,Kb=`AddSupervisor`,qb=`RemoveSupervisor`,Jb=`AndThen`,Yb={_tag:Gb},Xb=(e,t)=>({_tag:Jb,first:e,second:t}),Zb=(e,t)=>Qb(t,ti(e)),Qb=(e,t)=>{let n=e,r=t;for(;hi(r);){let e=vi(r);switch(e._tag){case Gb:r=yi(r);break;case Kb:n=n.zip(e.supervisor),r=yi(r);break;case qb:n=$b(n,e.supervisor),r=yi(r);break;case Jb:r=di(e.first)(di(e.second)(yi(r)));break}}return n},$b=(e,t)=>T(e,t)?Ub:Bb(e)?$b(e.left,t).zip($b(e.right,t)):e,ex=e=>T(e,Ub)?Ia():Bb(e)?c(ex(e.left),Ga(ex(e.right))):Ra(e),tx=Wb({empty:Yb,patch:Zb,combine:Xb,diff:(e,t)=>{if(T(e,t))return Yb;let n=ex(e),r=ex(t);return Xb(c(r,Wa(n),Ka(Yb,(e,t)=>Xb(e,{_tag:Kb,supervisor:t}))),c(n,Wa(r),Ka(Yb,(e,t)=>Xb(e,{_tag:qb,supervisor:t}))))}}),nx=kb(`effect_fiber_started`,{incremental:!0}),rx=kb(`effect_fiber_active`),ix=kb(`effect_fiber_successes`,{incremental:!0}),ax=kb(`effect_fiber_failures`,{incremental:!0}),ox=Mb(jb(`effect_fiber_lifetimes`,Zv({start:.5,factor:2,count:35})),`time_unit`,`milliseconds`),sx=`Continue`,cx=`Yield`,lx={_E:e=>e,_A:e=>e},ux=e=>{throw Error(`BUG: FiberRuntime - ${Ke(e)} - please report an issue at https://github.com/Effect-TS/effect/issues`)},dx=Symbol.for(`effect/internal/fiberRuntime/YieldedOp`),fx=g(`effect/internal/fiberRuntime/yieldedOpChannel`,()=>({currentOp:null})),px={[rt]:(e,t,n)=>Oe(()=>t.effect_instruction_i1(n)),OnStep:(e,t,n)=>G(G(n)),[it]:(e,t,n)=>Oe(()=>t.effect_instruction_i2(n)),[ft]:(e,t,n)=>(e.patchRuntimeFlags(e.currentRuntimeFlags,t.patch),Eu(e.currentRuntimeFlags)&&e.isInterrupted()?W(e.getInterruptedCause()):G(n)),[ct]:(e,t,n)=>(Oe(()=>t.effect_instruction_i2(n)),Oe(()=>t.effect_instruction_i0())?(e.pushStack(t),Oe(()=>t.effect_instruction_i1())):U),[lt]:(e,t,n)=>{for(;;){let r=Oe(()=>t.effect_instruction_i0.next(n));if(r.done)return G(r.value);let i=Te(r.value);if(!xp(i))return e.pushStack(t),i;if(i._tag===`Failure`)return i;n=i.value}}},mx={[bv]:(e,t,n,r)=>(e.processNewInterruptSignal(r.cause),Eu(t)?W(r.cause):n),[Sv]:(e,t,n,r)=>{throw Error(`It is illegal to have multiple concurrent run loops in a single fiber`)},[xv]:(e,t,n,r)=>(r.onFiber(e,fg(t)),n),[Cv]:(e,t,n,r)=>R(hf(),()=>n)},hx=e=>Jd(Vu(e),e=>Ax(ad(e),([e,t])=>{let n=new Map,r=[];for(let e of t){r.push(ii(e));for(let t of e)n.set(t.request,t)}let i=r.flat();return If($x(e.runAll(r),i,()=>i.forEach(e=>{e.listeners.interrupted=!0})),K_,n)},!1,!1)),gx=pt();var _x=class extends hh{[Nv]=Pv;[Iv]=lx;_fiberRefs;_fiberId;_queue=[];_children=null;_observers=[];_running=!1;_stack=[];_asyncInterruptor=null;_asyncBlockingOn=null;_exitValue=null;_steps=[];_isYielding=!1;currentRuntimeFlags;currentOpCount=0;currentSupervisor;currentScheduler;currentTracer;currentSpan;currentContext;currentDefaultServices;constructor(e,t,n){if(super(),this.currentRuntimeFlags=n,this._fiberId=e,this._fiberRefs=t,ju(n)){let e=this.getFiberRef(ep);nx.unsafeUpdate(1,e),rx.unsafeUpdate(1,e)}this.refreshRefCache()}commit(){return Lv(this)}id(){return this._fiberId}resume(e){this.tell(Ev(e))}get status(){return this.ask((e,t)=>t)}get runtimeFlags(){return this.ask((e,t)=>mg(t)?e.currentRuntimeFlags:t.runtimeFlags)}scope(){return jv(this)}get children(){return this.ask(e=>Array.from(e.getChildren()))}getChildren(){return this._children===null&&(this._children=new Set),this._children}getInterruptedCause(){return this.getFiberRef(np)}fiberRefs(){return this.ask(e=>e.getFiberRefs())}ask(e){return V(()=>{let t=Lp(this._fiberId);return this.tell(Tv((n,r)=>{Wp(t,H(()=>e(n,r)))})),Bp(t)})}tell(e){this._queue.push(e),this._running||(this._running=!0,this.drainQueueLaterOnExecutor())}get await(){return Od(e=>{let t=t=>e(B(t));if(this._exitValue!==null){t(this._exitValue);return}return this.tell(Tv((e,n)=>{e._exitValue===null?e.addObserver(t):t(this._exitValue)})),H(()=>this.tell(Tv((e,n)=>{e.removeObserver(t)})))},this.id())}get inheritAll(){return xd((e,t)=>{let n=e.id(),r=e.getFiberRefs(),i=t.runtimeFlags,a=jh(r,n,this.getFiberRefs());return e.setFiberRefs(a),lf(c(Nu(i,e.getFiberRef(Xx)),Ru(1),Ru(16)))})}get poll(){return H(()=>mn(this._exitValue))}unsafePoll(){return this._exitValue}interruptAsFork(e){return H(()=>this.tell(wv(ao(e))))}unsafeInterruptAsFork(e){this.tell(wv(ao(e)))}addObserver(e){this._exitValue===null?this._observers.push(e):e(this._exitValue)}removeObserver(e){this._observers=this._observers.filter(t=>t!==e)}getFiberRefs(){return this.setFiberRef(Xx,this.currentRuntimeFlags),this._fiberRefs}unsafeDeleteFiberRef(e){this._fiberRefs=Ph(this._fiberRefs,e)}getFiberRef(e){return this._fiberRefs.locals.has(e)?this._fiberRefs.locals.get(e)[0][1]:e.initial}setFiberRef(e,t){this._fiberRefs=Lh(this._fiberRefs,{fiberId:this._fiberId,fiberRef:e,value:t}),this.refreshRefCache()}refreshRefCache(){this.currentDefaultServices=this.getFiberRef(uh),this.currentTracer=this.currentDefaultServices.unsafeMap.get(rh.key),this.currentSupervisor=this.getFiberRef(Zx),this.currentScheduler=this.getFiberRef(G_),this.currentContext=this.getFiberRef(Uf),this.currentSpan=this.currentContext.unsafeMap.get(ih.key)}setFiberRefs(e){this._fiberRefs=e,this.refreshRefCache()}addChild(e){this.getChildren().add(e)}removeChild(e){this.getChildren().delete(e)}transferChildren(e){let t=this._children;if(this._children=null,t!==null&&t.size>0)for(let n of t)n._exitValue===null&&e.add(this.currentRuntimeFlags,n)}drainQueueOnCurrentThread(){let e=!0;for(;e;){let t=sx,n=globalThis[Rv];globalThis[Rv]=this;try{for(;t===sx;)t=this._queue.length===0?`Done`:this.evaluateMessageWhileSuspended(this._queue.splice(0,1)[0])}finally{this._running=!1,globalThis[Rv]=n}this._queue.length>0&&!this._running?(this._running=!0,t===cx?(this.drainQueueLaterOnExecutor(),e=!1):e=!0):e=!1}}drainQueueLaterOnExecutor(){this.currentScheduler.scheduleTask(this.run,this.getFiberRef(Wf),this)}drainQueueWhileRunning(e,t){let n=t;for(;this._queue.length>0;){let t=this._queue.splice(0,1)[0];n=mx[t._tag](this,e,n,t)}return n}isInterrupted(){return!fo(this.getFiberRef(np))}addInterruptedCause(e){let t=this.getFiberRef(np);this.setFiberRef(np,so(t,e))}processNewInterruptSignal(e){this.addInterruptedCause(e),this.sendInterruptSignalToAllChildren()}sendInterruptSignalToAllChildren(){if(this._children===null||this._children.size===0)return!1;let e=!1;for(let t of this._children)t.tell(wv(ao(this.id()))),e=!0;return e}interruptAllChildren(){if(this.sendInterruptSignalToAllChildren()){let e=this._children.values();this._children=null;let t=!1;return df({while:()=>!t,body:()=>{let n=e.next();return n.done?H(()=>{t=!0}):wd(n.value.await)},step:()=>{}})}return null}reportExitValue(e){if(ju(this.currentRuntimeFlags)){let t=this.getFiberRef(ep),n=this.id().startTimeMillis,r=Date.now();switch(ox.unsafeUpdate(r-n,t),rx.unsafeUpdate(-1,t),e._tag){case at:ix.unsafeUpdate(1,t);break;case tt:ax.unsafeUpdate(1,t);break}}if(e._tag===`Failure`){let t=this.getFiberRef(Qf);!mo(e.cause)&&t._tag===`Some`&&this.log(`Fiber terminated with an unhandled error`,e.cause,t)}}setExitValue(e){this._exitValue=e,this.reportExitValue(e);for(let t=this._observers.length-1;t>=0;t--)this._observers[t](e);this._observers=[]}getLoggers(){return this.getFiberRef(Sx)}log(e,t,n){let r=P(n)?n.value:this.getFiberRef(qf);if(Cg(this.getFiberRef(vx),r))return;let i=this.getFiberRef(Jf),a=this.getFiberRef(Kf),o=this.getLoggers(),s=this.getFiberRefs();if(Va(o)>0){let n=bs(this.getFiberRef(uh),hm),c=new Date(n.unsafeCurrentTimeMillis());Ze(s,()=>{for(let n of o)n.log({fiberId:this.id(),logLevel:r,message:e,cause:t,context:s,spans:i,annotations:a,date:c})})}}evaluateMessageWhileSuspended(e){switch(e._tag){case Cv:return cx;case bv:return this.processNewInterruptSignal(e.cause),this._asyncInterruptor!==null&&(this._asyncInterruptor(W(e.cause)),this._asyncInterruptor=null),sx;case Sv:return this._asyncInterruptor=null,this._asyncBlockingOn=null,this.evaluateEffect(e.effect),sx;case xv:return e.onFiber(this,this._exitValue===null?pg(this.currentRuntimeFlags,this._asyncBlockingOn):dg),sx;default:return ux(e)}}evaluateEffect(e){this.currentSupervisor.onResume(this);try{let t=Eu(this.currentRuntimeFlags)&&this.isInterrupted()?W(this.getInterruptedCause()):e;for(;t!==null;){let e=t,n=this.runLoop(e);if(n===dx){let e=fx.currentOp;fx.currentOp=null,e._op===`Yield`?wu(this.currentRuntimeFlags)?(this.tell(Dv()),this.tell(Ev(Pp)),t=null):t=Pp:e._op===`Async`&&(t=null)}else{this.currentRuntimeFlags=c(this.currentRuntimeFlags,Tu(16));let e=this.interruptAllChildren();e===null?(this._queue.length===0?this.setExitValue(n):this.tell(Ev(n)),t=null):t=R(e,()=>n)}}}finally{this.currentSupervisor.onSuspend(this)}}start(e){if(this._running)this.tell(Ev(e));else{this._running=!0;let t=globalThis[Rv];globalThis[Rv]=this;try{this.evaluateEffect(e)}finally{this._running=!1,globalThis[Rv]=t,this._queue.length>0&&this.drainQueueLaterOnExecutor()}}}startFork(e){this.tell(Ev(e))}patchRuntimeFlags(e,t){let n=Pu(e,t);return globalThis[Rv]=this,this.currentRuntimeFlags=n,n}initiateAsync(e,t){let n=!1,r=e=>{n||(n=!0,this.tell(Ev(e)))};Eu(e)&&(this._asyncInterruptor=r);try{t(r)}catch(e){r(Rd(io(e)))}}pushStack(e){this._stack.push(e),e._op===`OnStep`&&this._steps.push({refs:this.getFiberRefs(),flags:this.currentRuntimeFlags})}popStack(){let e=this._stack.pop();if(e)return e._op===`OnStep`&&this._steps.pop(),e}getNextSuccessCont(){let e=this.popStack();for(;e;){if(e._op!==`OnFailure`)return e;e=this.popStack()}}getNextFailCont(){let e=this.popStack();for(;e;){if(e._op!==`OnSuccess`&&e._op!==`While`&&e._op!==`Iterator`)return e;e=this.popStack()}}Tag(e){return H(()=>xs(this.currentContext,e))}Left(e){return Id(e.left)}None(e){return Id(new vp)}Right(e){return G(e.right)}Some(e){return G(e.value)}Micro(e){return Ed(t=>{let n=t,r=E_(__(e,this.currentContext));return r.addObserver(e=>{if(e._tag===`Success`)return n(G(e.value));switch(e.cause._tag){case`Interrupt`:return n(W(ao(Fc)));case`Fail`:return n(Id(e.cause.error));case`Die`:return n(Md(e.cause.defect))}}),Ed(e=>{n=t=>{e(U)},r.unsafeInterrupt()})})}[ot](e){let t=Oe(()=>e.effect_instruction_i0()),n=this.getNextSuccessCont();return n===void 0?(fx.currentOp=G(t),dx):(n._op in px||ux(n),px[n._op](this,n,t))}[at](e){let t=e,n=this.getNextSuccessCont();return n===void 0?(fx.currentOp=t,dx):(n._op in px||ux(n),px[n._op](this,n,t.effect_instruction_i0))}[tt](e){let t=e.effect_instruction_i0,n=this.getNextFailCont();if(n!==void 0)switch(n._op){case nt:case it:return Eu(this.currentRuntimeFlags)&&this.isInterrupted()?W(So(t)):Oe(()=>n.effect_instruction_i1(t));case`OnStep`:return Eu(this.currentRuntimeFlags)&&this.isInterrupted()?W(So(t)):G(W(t));case ft:return this.patchRuntimeFlags(this.currentRuntimeFlags,n.patch),Eu(this.currentRuntimeFlags)&&this.isInterrupted()?W(so(t,this.getInterruptedCause())):W(t);default:ux(n)}else return fx.currentOp=W(t),dx}[ut](e){return Oe(()=>e.effect_instruction_i0(this,fg(this.currentRuntimeFlags)))}Blocked(e){let t=this.getFiberRefs(),n=this.currentRuntimeFlags;if(this._steps.length>0){let r=[],i=this._steps[this._steps.length-1],a=this.popStack();for(;a&&a._op!==`OnStep`;)r.push(a),a=this.popStack();this.setFiberRefs(i.refs),this.currentRuntimeFlags=i.flags;let o=Zh(i.refs,t),s=Nu(i.flags,n);return G(pd(e.effect_instruction_i0,xd(t=>{for(;r.length>0;)t.pushStack(r.pop());return t.setFiberRefs(Qh(t.id(),t.getFiberRefs())(o)),t.currentRuntimeFlags=Pu(s)(t.currentRuntimeFlags),e.effect_instruction_i1})))}return cf(t=>R(Mx(md(e.effect_instruction_i0)),()=>t(e.effect_instruction_i1)))}RunBlocked(e){return hx(e.effect_instruction_i0)}[st](e){let t=e.effect_instruction_i0,n=this.currentRuntimeFlags,r=Pu(n,t);if(Eu(r)&&this.isInterrupted())return W(this.getInterruptedCause());if(this.patchRuntimeFlags(this.currentRuntimeFlags,t),e.effect_instruction_i1){let t=Nu(r,n);return this.pushStack(new gd(t,e)),Oe(()=>e.effect_instruction_i1(n))}else return Pp}[rt](e){return this.pushStack(e),e.effect_instruction_i0}OnStep(e){return this.pushStack(e),e.effect_instruction_i0}[nt](e){return this.pushStack(e),e.effect_instruction_i0}[it](e){return this.pushStack(e),e.effect_instruction_i0}[$e](e){return this._asyncBlockingOn=e.effect_instruction_i1,this.initiateAsync(this.currentRuntimeFlags,e.effect_instruction_i0),fx.currentOp=e,dx}[dt](e){return this._isYielding=!1,fx.currentOp=e,dx}[ct](e){let t=e.effect_instruction_i0,n=e.effect_instruction_i1;return t()?(this.pushStack(e),n()):Pp}[lt](e){return px[lt](this,e,void 0)}[et](e){return Oe(()=>e.commit())}runLoop(e){let t=e;for(this.currentOpCount=0;;){if(this.currentRuntimeFlags&2&&this.currentSupervisor.onEffect(this,t),this._queue.length>0&&(t=this.drainQueueWhileRunning(this.currentRuntimeFlags,t)),!this._isYielding){this.currentOpCount+=1;let e=this.currentScheduler.shouldYield(this);if(e!==!1){this._isYielding=!0,this.currentOpCount=0;let n=t;t=R(hf({priority:e}),()=>n)}}try{if(t=this.currentTracer.context(()=>{if(gx!==t[hd]._V){let e=this.getFiberRef($f);if(e._tag===`Some`){let n=t[hd]._V;this.log(`Executing an Effect versioned ${n} with a Runtime of version ${pt()}, you may want to dedupe the effect dependencies, you can use the language service plugin to detect this at compile time: https://github.com/Effect-TS/language-service`,no,e)}}return this[t._op](t)},this),t===dx){let e=fx.currentOp;return e._op===`Yield`||e._op===`Async`?dx:(fx.currentOp=null,e._op===`Success`||e._op===`Failure`?e:W(io(e)))}}catch(e){t=t!==dx&&!v(t,`_op`)||!(t._op in this)?Nd(`Not a valid effect: ${Ke(t)}`):mp(e)?W(so(io(e),ao(Fc))):Md(e)}}}run=()=>{this.drainQueueOnCurrentThread()}};const vx=g(`effect/FiberRef/currentMinimumLogLevel`,()=>Lf(wg(`Info`))),yx=e=>Vv(t=>{bs(Bh(t.context,uh),qm).unsafe.log(e.log(t))}),bx=g(Symbol.for(`effect/Logger/defaultLogger`),()=>yx(Uv)),xx=g(Symbol.for(`effect/Logger/tracerLogger`),()=>Vv(({annotations:e,cause:t,context:n,fiberId:r,logLevel:i,message:a})=>{let o=_v(Ss(Ih(n,Uf),ih));if(o._tag===`None`||o.value._tag===`ExternalSpan`)return;let s=xs(Ih(n,uh),hm),c={};for(let[t,n]of e)c[t]=n;c[`effect.fiberId`]=zc(r),c[`effect.logLevel`]=i.label,t!==null&&t._tag!==`Empty`&&(c[`effect.cause`]=Fo(t,{renderErrorCause:!0})),o.value.event(Ke(Array.isArray(a)&&a.length===1?a[0]:a),s.unsafeCurrentTimeNanos(),c)})),Sx=g(Symbol.for(`effect/FiberRef/currentLoggers`),()=>Rf(Ra(bx,xx))),Cx=(e,t,n)=>{let r=e.next();return r.done?B(!1):R(n(r.value,t),r=>r?B(r):Cx(e,t+1,n))},wx=e=>{if(Array.isArray(e)||he(e))return[e,j()];let t=Object.keys(e),n=t.length;return[t.map(t=>e[t]),M(e=>{let r={};for(let i=0;i<n;i++)r[t[i]]=e[i];return r})]},Tx=(e,t,r)=>{let i=[];for(let t of e)i.push(Pd(t));return R(Ox(i,n,{concurrency:r?.concurrency,batching:r?.batching,concurrentFinalizers:r?.concurrentFinalizers}),e=>{let n=j(),i=e.length,a=Array(i),o=Array(i),s=!1;for(let t=0;t<i;t++){let r=e[t];r._tag===`Left`?(a[t]=M(r.left),s=!0):(o[t]=r.right,a[t]=n)}return s?t._tag===`Some`?Id(t.value(a)):Id(a):r?.discard?U:t._tag===`Some`?B(t.value(o)):B(o)})},Ex=(e,t,r)=>{let i=[];for(let t of e)i.push(Pd(t));return r?.discard?Ox(i,n,{concurrency:r?.concurrency,batching:r?.batching,discard:!0,concurrentFinalizers:r?.concurrentFinalizers}):z(Ox(i,n,{concurrency:r?.concurrency,batching:r?.batching,concurrentFinalizers:r?.concurrentFinalizers}),e=>t._tag===`Some`?t.value(e):e)},Dx=(e,t)=>{let[r,i]=wx(e);return t?.mode===`validate`?Tx(r,i,t):t?.mode===`either`?Ex(r,i,t):t?.discard!==!0&&i._tag===`Some`?z(Ox(r,n,t),i.value):Ox(r,n,t)},Ox=t(e=>he(e[0]),(e,t,n)=>xd(r=>{let i=n?.batching===!0||n?.batching===`inherit`&&r.getFiberRef(Zf);return n?.discard?q_(n.concurrency,()=>zx(Ch,n?.concurrentFinalizers)(n=>i?Ax(e,(e,r)=>n(t(e,r)),!0,!1,1):Jd(e,(e,r)=>n(t(e,r)))),()=>zx(wh,n?.concurrentFinalizers)(n=>Ax(e,(e,r)=>n(t(e,r)),i,!1)),r=>zx(Th(r),n?.concurrentFinalizers)(n=>Ax(e,(e,r)=>n(t(e,r)),i,!1,r))):q_(n?.concurrency,()=>zx(Ch,n?.concurrentFinalizers)(n=>i?jx(e,1,(e,r)=>n(t(e,r)),!0):qd(e,(e,r)=>n(t(e,r)))),()=>zx(wh,n?.concurrentFinalizers)(n=>kx(e,(e,r)=>n(t(e,r)),i)),r=>zx(Th(r),n?.concurrentFinalizers)(n=>jx(e,r,(e,r)=>n(t(e,r)),i)))})),kx=(e,t,n)=>V(()=>{let r=I(e),i=Array(r.length);return vf(Ax(r,(e,n)=>R(t(e,n),e=>H(()=>i[n]=e)),n,!1),B(i))}),Ax=(e,t,n,r,i)=>cf(a=>af(o=>xd(s=>{let c=Array.from(e).reverse(),l=c.length;if(l===0)return U;let u=0,d=!1,f=i?Math.min(c.length,i):c.length,p=new Set,m=[],h=()=>p.forEach(e=>{e.currentScheduler.scheduleTask(()=>{e.unsafeInterruptAsFork(s.id())},0,e)}),g=[],ee=[],_=[],te=()=>{let e=m.filter(({exit:e})=>e._tag===`Failure`).sort((e,t)=>e.index<t.index?-1:e.index===t.index?0:1).map(({exit:e})=>e);return e.length===0&&e.push(Pp),e},ne=(e,t=!1)=>{let n=sf(o(e)),r=Px(n,s,s.currentRuntimeFlags,Mv);return s.currentScheduler.scheduleTask(()=>{t&&r.unsafeInterruptAsFork(s.id()),r.resume(n)},0,r),r},re=()=>{r||(l-=c.length,c=[]),d=!0,h()},ie=n?Hd:Fd,ae=ne(Od(e=>{let r=(e,t)=>{e._op===`Blocked`?_.push(e):(m.push({index:t,exit:e}),e._op===`Failure`&&!d&&re())},o=()=>{if(c.length>0){let f=c.pop(),h=u++,re=()=>{let e=c.pop();return h=u++,R(hf(),()=>R(ie(a(t(e,h))),ae))},ae=e=>c.length>0&&(r(e,h),c.length>0)?re():B(e),oe=ne(R(ie(a(t(f,h))),ae));g.push(oe),p.add(oe),d&&oe.currentScheduler.scheduleTask(()=>{oe.unsafeInterruptAsFork(s.id())},0,oe),oe.addObserver(t=>{let a;if(a=t._op===`Failure`?t:t.effect_instruction_i0,ee.push(oe),p.delete(oe),r(a,h),m.length===l)e(B(F(Tp(te(),{parallel:!0}),()=>Pp)));else if(_.length+m.length===l){let t=te();e(B(pd(_.map(e=>e.effect_instruction_i0).reduce(zu),Ax([F(Tp(t,{parallel:!0}),()=>Pp),..._.map(e=>e.effect_instruction_i1)],e=>e,n,!0,i))))}else o()})}};for(let e=0;e<f;e++)o()}));return wd(Qd(Ud(a(Lv(ae))),Mp({onFailure:e=>{re();let t=_.length+1,n=Math.min(typeof i==`number`?i:_.length,_.length),r=Array.from(_);return Od(i=>{let a=[],o=0,s=0,c=(n,s)=>c=>{a[n]=c,o++,o===t&&i(G(W(e))),r.length>0&&s&&l()},l=()=>{ne(r.pop(),!0).addObserver(c(s,!0)),s++};ae.addObserver(c(s,!1)),s++;for(let e=0;e<n;e++)l()})},onSuccess:()=>qd(ee,e=>e.inheritAll)})))}))),jx=(e,t,n,r)=>V(()=>{let i=I(e),a=Array(i.length);return vf(Ax(i,(e,t)=>z(n(e,t),e=>a[t]=e),r,!1,t),B(a))}),Mx=e=>Ix(e,Mv),Nx=(e,t,n,r=null)=>{let i=Fx(e,t,n,r);return i.resume(e),i},Px=(e,t,n,r=null)=>Fx(e,t,n,r),Fx=(e,t,n,r=null)=>{let i=Bc(),a=Mh(t.getFiberRefs(),i),o=new _x(i,a,n),s=Ih(a,Uf),l=o.currentSupervisor;return l.onStart(s,e,M(t),o),o.addObserver(e=>l.onEnd(e,o)),(r===null?c(t.getFiberRef(tp),F(()=>t.scope())):r).add(n,o),o},Ix=(e,t)=>xd((n,r)=>B(Nx(e,n,r.runtimeFlags,t))),Lx=e=>Jp(t=>dn(Ss(t,Ux),{onNone:()=>e,onSome:t=>{switch(t.strategy._tag){case`Parallel`:return e;case`Sequential`:case`ParallelN`:return R(cp(t,wh),t=>Jx(e,t))}}})),Rx=e=>t=>Jp(n=>dn(Ss(n,Ux),{onNone:()=>t,onSome:n=>n.strategy._tag===`ParallelN`&&n.strategy.parallelism===e?t:R(cp(n,Th(e)),e=>Jx(t,e))})),zx=(e,t)=>r=>Jp(i=>dn(Ss(i,Ux),{onNone:()=>r(n),onSome:i=>{if(t===!0){let t=e._tag===`Parallel`?Lx:e._tag===`Sequential`?Vx:Rx(e.parallelism);switch(i.strategy._tag){case`Parallel`:return t(r(Lx));case`Sequential`:return t(r(Vx));case`ParallelN`:return t(r(Rx(i.strategy.parallelism)))}}else return r(n)}})),Bx=e=>R(Ux,e),Vx=e=>Jp(t=>dn(Ss(t,Ux),{onNone:()=>e,onSome:t=>{switch(t.strategy._tag){case`Sequential`:return e;case`Parallel`:case`ParallelN`:return R(cp(t,Ch),t=>Jx(e,t))}}})),Hx=t(e=>bd(e[1]),(e,t,n,r)=>z(Dx([e,t],{concurrency:r?.concurrent?2:1,batching:r?.batching,concurrentFinalizers:r?.concurrentFinalizers}),([e,t])=>n(e,t))),Ux=gs(`effect/Scope`),Wx=(e,t)=>{e.state._tag===`Open`&&e.state.finalizers.set({},t)},Gx={[rp]:rp,[ip]:ip,pipe(){return O(this,arguments)},fork(e){return H(()=>{let t=Kx(e);if(this.state._tag===`Closed`)return t.state=this.state,t;let n={};return this.state.finalizers.set(n,e=>t.close(e)),Wx(t,e=>H(()=>{this.state._tag===`Open`&&this.state.finalizers.delete(n)})),t})},close(e){return V(()=>{if(this.state._tag===`Closed`)return U;let t=Array.from(this.state.finalizers.values()).reverse();return this.state={_tag:`Closed`,exit:e},t.length===0?U:xh(this.strategy)?c(qd(t,t=>Fd(t(e))),R(e=>c(Tp(e),yn(wp),F(()=>Pp)))):Sh(this.strategy)?c(kx(t,t=>Fd(t(e)),!1),R(e=>c(Tp(e,{parallel:!0}),yn(wp),F(()=>Pp)))):c(jx(t,this.strategy.parallelism,t=>Fd(t(e)),!1),R(e=>c(Tp(e,{parallel:!0}),yn(wp),F(()=>Pp))))})},addFinalizer(e){return V(()=>this.state._tag===`Closed`?e(this.state.exit):(this.state.finalizers.set({},e),U))}},Kx=(e=vh)=>{let t=Object.create(Gx);return t.strategy=e,t.state={_tag:`Open`,finalizers:new Map},t},qx=(e=vh)=>H(()=>Kx(e)),Jx=t(2,(e,t)=>Xp(e,Cs(vs(Ux,t)))),Yx=e=>Vf(e,{differ:tx,fork:Yb}),Xx=Hf(Au),Zx=Yx(Ub),Qx=t(2,(e,t)=>cf(n=>Gd(n(e),{onFailure:e=>Gd(t,{onFailure:t=>Rd(so(e,t)),onSuccess:()=>Rd(e)}),onSuccess:e=>Cd(t,e)}))),$x=(e,t,n)=>Vd(r=>R(R(Mx(Yd(e)),e=>Od(r=>{let i=t.map(e=>e.listeners.count),a=()=>{i.every(e=>e===0)&&t.every(e=>e.result.state.current._tag===`Pending`?!0:!!(e.result.state.current._tag===`Done`&&xp(e.result.state.current.effect)&&e.result.state.current.effect._tag===`Failure`&&po(e.result.state.current.effect.cause)))&&(o.forEach(e=>e()),n?.(),r(bf(e)))};e.addObserver(e=>{o.forEach(e=>e()),r(e)});let o=t.map((e,t)=>{let n=e=>{i[t]=e,a()};return e.listeners.addObserver(n),()=>e.listeners.removeObserver(n)});return a(),H(()=>{o.forEach(e=>e())})})),()=>V(()=>Jd(t.flatMap(e=>e.state.completed?[]:[e]),e=>Fb(e.request,Ap(r)))))),eS=Symbol.for(`effect/ScheduleInterval`),tS={[eS]:eS,startMillis:0,endMillis:0},nS=e=>c(e.intervals,gi,F(()=>tS)).startMillis,rS=e=>c(e.intervals,gi,F(()=>tS)).endMillis,iS=t(2,(e,t)=>nS(e)<nS(t)),aS=e=>hi(e.intervals),oS=rS,sS=iS,cS=aS,lS=`Done`,uS=e=>({_tag:`Continue`,intervals:e}),dS={_tag:lS},fS=e=>e._tag===lS,pS=uS,mS=dS,hS=fS,gS=sp,_S=cp;var vS=class{permits;waiters=new Set;taken=0;constructor(e){this.permits=e}get free(){return this.permits-this.taken}take=e=>Dd(t=>{if(this.free<e){let n=()=>{this.free<e||(this.waiters.delete(n),t(V(()=>this.free<e?this.take(e):(this.taken+=e,B(e)))))};return this.waiters.add(n),H(()=>{this.waiters.delete(n)})}t(V(()=>this.free<e?this.take(e):(this.taken+=e,B(e))))});updateTakenUnsafe(e,t){return this.taken=t(this.taken),this.waiters.size>0&&e.getFiberRef(G_).scheduleTask(()=>{let e=this.waiters.values(),t=e.next();for(;t.done===!1&&this.free>0;)t.value(),t=e.next()},e.getFiberRef(Wf),e),B(this.free)}updateTaken(e){return xd(t=>this.updateTakenUnsafe(t,e))}resize=e=>wd(xd(t=>(this.permits=e,this.free<0?U:this.updateTakenUnsafe(t,e=>e))));release=e=>this.updateTaken(t=>t-e);releaseAll=this.updateTaken(e=>0);withPermits=e=>t=>cf(n=>R(n(this.take(e)),e=>Qx(n(t),this.release(e))));withPermitsIfAvailable=e=>t=>cf(n=>V(()=>this.free<e?mv:(this.taken+=e,Qx(n(tv(t)),this.release(e)))))};const yS=e=>new vS(e),bS=Symbol.for(`effect/Ref/SynchronizedRef`),xS={_A:e=>e};var SS=class extends hh{ref;withLock;[bS]=xS;[j_]=M_;[A_]=A_;constructor(e,t){super(),this.ref=e,this.withLock=t,this.get=I_(this.ref)}get;commit(){return this.get}modify(e){return this.modifyEffect(t=>B(e(t)))}modifyEffect(e){return this.withLock(c(R(I_(this.ref),e),R(([e,t])=>Cd(L_(this.ref,t),e))))}};const CS=e=>H(()=>wS(e)),wS=e=>new SS(P_(e),yS(1).withPermits(1)),TS=xf,ES=e=>function(){if(arguments.length===1){let t=arguments[0];return(n,...r)=>e(t,n,...r)}return e.apply(this,arguments)},DS=ES((e,t,n)=>{let r=Bc(),i=[[Uf,[[r,e.context]]]];n?.scheduler&&i.push([G_,[[r,n.scheduler]]]);let a=Vh(e.fiberRefs,{entries:i,forkAs:r});n?.updateRefs&&(a=n.updateRefs(a,r));let o=new _x(r,a,e.runtimeFlags),s=t;n?.scope&&(s=R(_S(n.scope,vh),e=>vf(ap(e,Vd(e=>T(e,o.id())?U:xf(o,e))),Qd(t,t=>gS(e,t)))));let c=o.currentSupervisor;return c!==Ub&&(c.onStart(e.context,s,j(),o),o.addObserver(e=>c.onEnd(e,o))),Mv.add(e.runtimeFlags,o),n?.immediate===!1?o.resume(s):o.start(s),o}),OS=ES((e,t,n={})=>{let r=DS(e,t,n);return n.onExit&&r.addObserver(e=>{n.onExit(e)}),(t,n)=>OS(e)(c(r,TS(t??Fc)),{...n,onExit:n?.onExit?e=>n.onExit(yv(e)):void 0})}),kS=ES((e,t)=>{let n=LS(e)(t);if(n._tag===`Failure`)throw FS(n.effect_instruction_i0);return n.effect_instruction_i0});var AS=class extends Error{fiber;_tag=`AsyncFiberException`;constructor(e){super(`Fiber #${e.id().id} cannot be resolved synchronously. This is caused by using runSync on an effect that performs async work`),this.fiber=e,this.name=this._tag,this.stack=this.message}};const jS=e=>{let t=Error.stackTraceLimit;Error.stackTraceLimit=0;let n=new AS(e);return Error.stackTraceLimit=t,n},MS=Symbol.for(`effect/Runtime/FiberFailure`),NS=Symbol.for(`effect/Runtime/FiberFailure/Cause`);var PS=class extends Error{[MS];[NS];constructor(e){let t=Uo(e)[0];super(t?.message||`An error has occurred`),this[MS]=MS,this[NS]=e,this.name=t?`(FiberFailure) ${t.name}`:`FiberFailure`,t?.stack&&(this.stack=t.stack)}toJSON(){return{_id:`FiberFailure`,cause:this[NS].toJSON()}}toString(){return`(FiberFailure) `+Fo(this[NS],{renderErrorCause:!0})}[E](){return this.toString()}};const FS=e=>{let t=Error.stackTraceLimit;Error.stackTraceLimit=0;let n=new PS(e);return Error.stackTraceLimit=t,n},IS=e=>{let t=e;switch(t._op){case`Failure`:case`Success`:return t;case`Left`:return Dp(t.left);case`Right`:return G(t.right);case`Some`:return G(t.value);case`None`:return Dp(new vp)}},LS=ES((e,t)=>{let n=IS(t);if(n)return n;let r=new W_,i=DS(e)(t,{scheduler:r});return r.flush(),i.unsafePoll()||Ep(jd(jS(i),Zp(i)))});var RS=class{context;runtimeFlags;fiberRefs;constructor(e,t,n){this.context=e,this.runtimeFlags=t,this.fiberRefs=n}pipe(){return O(this,arguments)}};const zS=(e=>new RS(e.context,e.runtimeFlags,e.fiberRefs))({context:_s(),runtimeFlags:ku(1,32,4),fiberRefs:Hh()}),BS=DS(zS),VS=kS(zS),HS=t(2,(e,t)=>e.modifyEffect(t)),US=Symbol.for(`effect/Layer/MemoMap`),WS=Es()(`effect/Layer/CurrentMemoMap`,{defaultValue:()=>JS()}),GS=e=>e._op_layer===`Fresh`;var KS=class{ref;[US];constructor(e){this.ref=e,this[US]=US}getOrElseMemoize(e,t){return c(HS(this.ref,n=>{let r=n.get(e);if(r!==void 0){let[e,i]=r;return B([c(e,R(([e,t])=>c(uv(e),Cd(t))),Qd(Mp({onFailure:()=>U,onSuccess:()=>op(t,i)}))),n])}return c(F_(0),R(r=>c(Rp(),R(i=>c(F_(()=>U),z(a=>{let o=cf(o=>c(qx(),R(s=>c(o(R(ZS(e,s,!0),e=>nv(e(this)))),Fd,R(o=>{switch(o._tag){case tt:return c(Hp(i,o.effect_instruction_i0),vf(sp(s,o)),vf(Rd(o.effect_instruction_i0)));case at:return c(L_(a,e=>c(sp(s,e),uf(R_(r,e=>[e===1,e-1])),wd)),vf(z_(r,e=>e+1)),vf(op(t,t=>c(H(()=>n.delete(e)),vf(I_(a)),R(e=>e(t))))),vf(Up(i,o.effect_instruction_i0)),Cd(o.effect_instruction_i0[1]))}}))))),s=[c(Bp(i),Qd(Np({onFailure:()=>U,onSuccess:()=>z_(r,e=>e+1)}))),e=>c(I_(a),R(t=>t(e)))];return[o,GS(e)?n:n.set(e,s)]}))))))}),Ud)}};const qS=V(()=>z(CS(new Map),e=>new KS(e))),JS=()=>new KS(wS(new Map)),YS=t(2,(e,t)=>R(qS,n=>XS(e,n,t))),XS=t(3,(e,t,n)=>R(ZS(e,n),e=>dv(e(t),WS,t))),ZS=(e,t,n=!1)=>{let r=e;switch(r._op_layer){case`Locally`:return H(()=>e=>r.f(e.getOrElseMemoize(r.self,t)));case`ExtendScope`:return H(()=>e=>Bx(t=>e.getOrElseMemoize(r.layer,t)));case`Fold`:return H(()=>e=>c(e.getOrElseMemoize(r.layer,t),Gd({onFailure:n=>e.getOrElseMemoize(r.failureK(n),t),onSuccess:n=>e.getOrElseMemoize(r.successK(n),t)})));case`Fresh`:return H(()=>e=>c(r.layer,YS(t)));case`FromEffect`:return H(n?()=>e=>r.effect:()=>n=>n.getOrElseMemoize(e,t));case`Provide`:return H(()=>e=>c(e.getOrElseMemoize(r.first,t),R(n=>c(e.getOrElseMemoize(r.second,t),Yp(n)))));case`Scoped`:return H(n?()=>e=>Jx(r.effect,t):()=>n=>n.getOrElseMemoize(e,t));case`Suspend`:return H(()=>e=>e.getOrElseMemoize(r.evaluate(),t));case`ProvideMerge`:return H(()=>e=>c(e.getOrElseMemoize(r.first,t),yf(e.getOrElseMemoize(r.second,t),r.zipK)));case`ZipWith`:return pf(function*(){let e=yield*cp(t,yh),n=yield*cp(e,vh),i=yield*cp(e,vh);return e=>c(e.getOrElseMemoize(r.first,n),Hx(e.getOrElseMemoize(r.second,i),r.zipK,{concurrent:!0}))});case`MergeAll`:{let e=r.layers;return z(cp(t,yh),t=>n=>{let r=Array(e.length);return z(Ax(e,mf(function*(e,i){let a=yield*cp(t,vh);r[i]=yield*n.getOrElseMemoize(e,a)}),!1,!1),()=>ws(...r))})}}},QS=Symbol.for(`effect/DateTime`),$S=Symbol.for(`effect/DateTime/TimeZone`),eC={[QS]:QS,pipe(){return O(this,arguments)},[E](){return this.toString()},toJSON(){return jC(this).toJSON()}},tC={...eC,_tag:`Utc`,[y](){return C(this,Ne(this.epochMillis))},[w](e){return sC(e)&&e._tag===`Utc`&&this.epochMillis===e.epochMillis},toString(){return`DateTime.Utc(${jC(this).toJSON()})`}},nC={...eC,_tag:`Zoned`,[y](){return c(Ne(this.epochMillis),x(b(this.zone)),C(this))},[w](e){return sC(e)&&e._tag===`Zoned`&&this.epochMillis===e.epochMillis&&T(this.zone,e.zone)},toString(){return`DateTime.Zoned(${GC(this)})`}},rC={[$S]:$S,[E](){return this.toString()}},iC={...rC,_tag:`Named`,[y](){return C(this,S(`Named:${this.id}`))},[w](e){return cC(e)&&e._tag===`Named`&&this.id===e.id},toString(){return`TimeZone.Named(${this.id})`},toJSON(){return{_id:`TimeZone`,_tag:`Named`,id:this.id}}},aC={...rC,_tag:`Offset`,[y](){return C(this,S(`Offset:${this.offset}`))},[w](e){return cC(e)&&e._tag===`Offset`&&this.offset===e.offset},toString(){return`TimeZone.Offset(${PC(this.offset)})`},toJSON(){return{_id:`TimeZone`,_tag:`Offset`,offset:this.offset}}},oC=(e,t,n)=>{let r=Object.create(nC);return r.epochMillis=e,r.zone=t,Object.defineProperty(r,`partsUtc`,{value:n,enumerable:!1,writable:!0}),Object.defineProperty(r,`adjustedEpochMillis`,{value:void 0,enumerable:!1,writable:!0}),Object.defineProperty(r,`partsAdjusted`,{value:void 0,enumerable:!1,writable:!0}),r},sC=e=>v(e,QS),cC=e=>v(e,$S),lC=e=>cC(e)&&e._tag===`Offset`,uC=e=>cC(e)&&e._tag===`Named`,dC=e=>e._tag===`Utc`,fC=e=>e._tag===`Zoned`,pC=l((e,t)=>e.epochMillis===t.epochMillis),mC=e=>{let t=Object.create(tC);return t.epochMillis=e,Object.defineProperty(t,`partsUtc`,{value:void 0,enumerable:!1,writable:!0}),t},hC=e=>{let t=e.getTime();if(Number.isNaN(t))throw new $p(`Invalid date`);return mC(t)},gC=e=>{if(sC(e))return e;if(e instanceof Date)return hC(e);if(typeof e==`object`){let t=new Date(0);return LC(t,e),hC(t)}else if(typeof e==`string`&&!_C(e))return hC(new Date(e+`Z`));return hC(new Date(e))},_C=e=>/Z|[+-]\d{2}$|[+-]\d{2}:?\d{2}$|\]$/.test(e),vC=(e,t)=>{if(t?.timeZone===void 0&&sC(e)&&fC(e))return e;let n=gC(e);if(n.epochMillis<-86399999568e5||n.epochMillis>86399999496e5)throw RangeError(`Epoch millis out of range: ${n.epochMillis}`);let r;if(t?.timeZone===void 0)r=EC(new Date(n.epochMillis).getTimezoneOffset()*-60*1e3);else if(cC(t?.timeZone))r=t.timeZone;else if(typeof t?.timeZone==`number`)r=EC(t.timeZone);else{let e=kC(t.timeZone);if(N(e))throw new $p(`Invalid time zone: ${t.timeZone}`);r=e.value}return t?.adjustForTimeZone===!0?zC(n.epochMillis,r,t?.disambiguation??`compatible`):oC(n.epochMillis,r,n.partsUtc)},yC=gn(vC),bC=/^(.{17,35})\[(.+)\]$/,xC=e=>{let t=bC.exec(e);if(t===null){let t=VC(e);return t===null?j():yC(e,{timeZone:t})}let[,n,r]=t;return yC(n,{timeZone:r})},SC=g(`effect/DateTime/validZoneCache`,()=>new Map),CC={day:`numeric`,month:`numeric`,year:`numeric`,hour:`numeric`,minute:`numeric`,second:`numeric`,timeZoneName:`longOffset`,fractionalSecondDigits:3,hourCycle:`h23`},wC=e=>{let t=e.resolvedOptions().timeZone;if(SC.has(t))return SC.get(t);let n=Object.create(iC);return n.id=t,n.format=e,SC.set(t,n),n},TC=e=>{if(SC.has(e))return SC.get(e);try{return wC(new Intl.DateTimeFormat(`en-US`,{...CC,timeZone:e}))}catch{throw new $p(`Invalid time zone: ${e}`)}},EC=e=>{let t=Object.create(aC);return t.offset=e,t},DC=gn(TC),OC=/^(?:GMT|[+-])/,kC=e=>{if(OC.test(e)){let t=VC(e);return t===null?j():M(EC(t))}return DC(e)},AC=e=>e._tag===`Offset`?PC(e.offset):e.id,jC=e=>new Date(e.epochMillis),MC=e=>{if(e._tag===`Utc`)return new Date(e.epochMillis);if(e.zone._tag===`Offset`)return new Date(e.epochMillis+e.zone.offset);if(e.adjustedEpochMillis!==void 0)return new Date(e.adjustedEpochMillis);let t=e.zone.format.formatToParts(e.epochMillis).filter(e=>e.type!==`literal`),n=new Date(0);return n.setUTCFullYear(Number(t[2].value),Number(t[0].value)-1,Number(t[1].value)),n.setUTCHours(Number(t[3].value),Number(t[4].value),Number(t[5].value),Number(t[6].value)),e.adjustedEpochMillis=n.getTime(),n},NC=e=>MC(e).getTime()-IC(e),PC=e=>{let t=Math.abs(e),n=Math.floor(t/(3600*1e3)),r=Math.round(t%(3600*1e3)/(60*1e3));return r===60&&(n+=1,r=0),`${e<0?`-`:`+`}${String(n).padStart(2,`0`)}:${String(r).padStart(2,`0`)}`},FC=e=>PC(NC(e)),IC=e=>e.epochMillis,LC=(e,t)=>{if(t.year!==void 0&&e.setUTCFullYear(t.year),t.month!==void 0&&e.setUTCMonth(t.month-1),t.day!==void 0&&e.setUTCDate(t.day),t.weekDay!==void 0){let n=t.weekDay-e.getUTCDay();e.setUTCDate(e.getUTCDate()+n)}t.hours!==void 0&&e.setUTCHours(t.hours),t.minutes!==void 0&&e.setUTCMinutes(t.minutes),t.seconds!==void 0&&e.setUTCSeconds(t.seconds),t.millis!==void 0&&e.setUTCMilliseconds(t.millis)},RC=1440*60*1e3,zC=(e,t,n)=>{if(t._tag===`Offset`)return oC(e-t.offset,t);let r=HC(e-RC,e,t),i=HC(e+RC,e,t);if(r===i)return oC(e-r,t);let a=r<i,o=r-i;if(a){if(HC(e-i,e,t)===i)return oC(e-i,t);let a=oC(e-r,t);if(e!==MC(a).getTime())switch(n){case`reject`:{let n=new Date(e).toISOString();throw RangeError(`Gap time: ${n} does not exist in time zone ${t.id}`)}case`earlier`:return oC(e-i,t);case`compatible`:case`later`:return a}return a}if(HC(e-r,e,t)===r){if(n===`earlier`||n===`compatible`||HC(e-r+o,e+o,t)===r)return oC(e-r,t);if(n===`reject`){let n=new Date(e).toISOString();throw RangeError(`Ambiguous time: ${n} occurs twice in time zone ${t.id}`)}}return oC(e-i,t)},BC=/([+-])(\d{2}):(\d{2})$/,VC=e=>{let t=BC.exec(e);if(t===null)return null;let[,n,r,i]=t;return(n===`+`?1:-1)*(Number(r)*60+Number(i))*60*1e3},HC=(e,t,n)=>{let r=n.format.formatToParts(e).find(e=>e.type===`timeZoneName`)?.value??``;if(r===`GMT`)return 0;let i=VC(r);return i===null?NC(oC(t,n)):i},UC=e=>jC(e).toISOString(),WC=e=>{let t=MC(e);return e._tag===`Utc`?t.toISOString():`${t.toISOString().slice(0,-1)}${FC(e)}`},GC=e=>e.zone._tag===`Offset`?WC(e):`${WC(e)}[${e.zone.id}]`,KC=e=>e.toUpperCase(),qC=e=>e.toLowerCase(),JC=e=>e.length===0?e:KC(e[0])+e.slice(1),YC=e=>e.length===0?e:qC(e[0])+e.slice(1),XC=e=>e.length>0,ZC=(e,t,n,r,i,a,o,s,l,u)=>{let d=u(a,l);return cS(d)?B([[r,o],[i,s],pS(d)]):c(a,sS(l))?R(e.step(oS(a),n,r),([r,i,a])=>hS(a)?B([[r,o],[i,s],mS]):ZC(e,t,n,r,i,a.intervals,o,s,l,u)):R(t.step(oS(l),n,o),([o,s,c])=>hS(c)?B([[r,o],[i,s],mS]):ZC(e,t,n,r,i,a,o,s,c.intervals,u))},QC=(e,t,n,r)=>Kd(t.next(r),{onFailure:()=>tf(t.last),onSuccess:r=>Kd(e,{onFailure:e=>n(e,M(r)),onSuccess:r=>QC(e,t,n,r)})}),$C=(e,t,n)=>kd(e,r=>Kd(t.next(r),{onFailure:()=>c(t.last,tf,R(e=>n(r,e))),onSuccess:()=>$C(e,t,n)})),ew=(e,t,n)=>Kd(n.next(t),{onFailure:()=>tf(n.last),onSuccess:()=>R(e,t=>ew(e,t,n))}),tw=bd,nw=Ox,rw=V,iw=U,aw=kd,ow=z,sw=Xd,cw=Zd,lw=Pd,uw=R,dw=BS,fw=VS,pw=sC,mw=lC,hw=uC,gw=dC,_w=fC,vw=pC,yw=hC,bw=gC,xw=vC,Sw=xC,Cw=TC,ww=EC,Tw=kC,Ew=AC,Dw=jC,Ow=IC;Ts(`effect/DateTime/CurrentTimeZone`)();const kw=UC,Aw=GC,jw=(e,t)=>{switch(t._tag){case`StringKeyword`:case`TemplateLiteral`:return Object.keys(e);case`SymbolKeyword`:return Object.getOwnPropertySymbols(e);case`Refinement`:return jw(e,t.from)}},Mw=e=>{let t=!1,n;return()=>t?n:(n=e(),t=!0,n)},Nw=e=>Array.isArray(e),Pw=e=>!Array.isArray(e),Fw=e=>`[${Ue(e)}]`,Iw=e=>Nw(e)?e.map(Fw).join(``):Fw(e),Lw=(e,t,n,r)=>{let i=e;return n&&L(n)&&(i+=`\nat path: ${Iw(n)}`),t!==void 0&&(i+=`\ndetails: ${t}`),r&&(i+=`\nschema (${r._tag}): ${r}`),i},Rw=e=>Lw(`Unsupported key schema`,void 0,void 0,e),zw=e=>Lw(`Unsupported literal`,`literal value: ${We(e)}`),Bw=e=>Lw(`Duplicate index signature`,`${e} index signature`),Vw=Lw(`Unsupported index signature parameter`,"An index signature parameter type must be `string`, `symbol`, a template literal type or a refinement of the previous types"),Hw=Lw(`Invalid element`,`A required element cannot follow an optional element. ts(1257)`),Uw=e=>Lw(`Duplicate property signature transformation`,`Duplicate key ${We(e)}`),Ww=e=>Lw(`Duplicate property signature`,`Duplicate key ${We(e)}`),Gw=Symbol.for(`effect/SchemaId/DateFromSelf`),Kw=Symbol.for(`effect/SchemaId/GreaterThan`),qw=Symbol.for(`effect/SchemaId/GreaterThanOrEqualTo`),Jw=Symbol.for(`effect/SchemaId/LessThan`),Yw=Symbol.for(`effect/SchemaId/LessThanOrEqualTo`),Xw=Symbol.for(`effect/SchemaId/Int`),Zw=Symbol.for(`effect/SchemaId/NonNaN`),Qw=Symbol.for(`effect/SchemaId/Finite`),$w=Symbol.for(`effect/SchemaId/JsonNumber`),eT=Symbol.for(`effect/SchemaId/Between`),tT=Symbol.for(`effect/SchemaId/GreaterThanOrEqualToBigint`),nT=Symbol.for(`effect/SchemaId/BetweenBigint`),rT=Symbol.for(`effect/SchemaId/MinLength`),iT=Symbol.for(`effect/SchemaId/MaxLength`),aT=Symbol.for(`effect/SchemaId/Length`),oT=Symbol.for(`effect/annotation/TypeConstructor`),sT=Symbol.for(`effect/annotation/Brand`),cT=Symbol.for(`effect/annotation/SchemaId`),lT=Symbol.for(`effect/annotation/Message`),uT=Symbol.for(`effect/annotation/MissingMessage`),dT=Symbol.for(`effect/annotation/Identifier`),fT=Symbol.for(`effect/annotation/Title`),pT=Symbol.for(`effect/annotation/AutoTitle`),mT=Symbol.for(`effect/annotation/Description`),hT=Symbol.for(`effect/annotation/Examples`),gT=Symbol.for(`effect/annotation/Default`),_T=Symbol.for(`effect/annotation/JSONSchema`),vT=Symbol.for(`effect/annotation/Arbitrary`),yT=Symbol.for(`effect/annotation/Pretty`),bT=Symbol.for(`effect/annotation/Equivalence`),xT=Symbol.for(`effect/annotation/Documentation`),ST=Symbol.for(`effect/annotation/Concurrency`),CT=Symbol.for(`effect/annotation/Batching`),wT=Symbol.for(`effect/annotation/ParseIssueTitle`),TT=Symbol.for(`effect/annotation/ParseOptions`),ET=Symbol.for(`effect/annotation/DecodingFallback`),DT=Symbol.for(`effect/annotation/Surrogate`),OT=Symbol.for(`effect/annotation/StableFilter`),kT=t(2,(e,t)=>Object.prototype.hasOwnProperty.call(e.annotations,t)?M(e.annotations[t]):j()),AT=kT(sT),jT=kT(lT),MT=kT(uT),NT=kT(fT),PT=kT(pT),FT=kT(dT),IT=kT(mT),LT=kT(ST),RT=kT(CT),zT=kT(wT),BT=kT(TT),VT=kT(ET),HT=kT(DT),UT=kT(OT),WT=e=>En(UT(e),e=>e===!0),GT=Symbol.for(`effect/annotation/JSONIdentifier`),KT=kT(GT),qT=e=>fn(KT(e),()=>FT(e));var JT=class{typeParameters;decodeUnknown;encodeUnknown;annotations;_tag=`Declaration`;constructor(e,t,n,r={}){this.typeParameters=e,this.decodeUnknown=t,this.encodeUnknown=n,this.annotations=r}toString(){return F(nD(this),()=>`<declaration schema>`)}toJSON(){return{_tag:this._tag,typeParameters:this.typeParameters.map(e=>e.toJSON()),annotations:K(this.annotations)}}};const YT=e=>t=>t._tag===e;var XT=class{literal;annotations;_tag=`Literal`;constructor(e,t={}){this.literal=e,this.annotations=t}toString(){return F(nD(this),()=>We(this.literal))}toJSON(){return{_tag:this._tag,literal:re(this.literal)?String(this.literal):this.literal,annotations:K(this.annotations)}}};const ZT=YT(`Literal`),QT=new XT(null);var $T=class{symbol;annotations;_tag=`UniqueSymbol`;constructor(e,t={}){this.symbol=e,this.annotations=t}toString(){return F(nD(this),()=>We(this.symbol))}toJSON(){return{_tag:this._tag,symbol:String(this.symbol),annotations:K(this.annotations)}}};const eE=new class{annotations;_tag=`NeverKeyword`;constructor(e={}){this.annotations=e}toString(){return $E(this)}toJSON(){return{_tag:this._tag,annotations:K(this.annotations)}}}({[fT]:`never`}),tE=new class{annotations;_tag=`UnknownKeyword`;constructor(e={}){this.annotations=e}toString(){return $E(this)}toJSON(){return{_tag:this._tag,annotations:K(this.annotations)}}}({[fT]:`unknown`}),nE=new class{annotations;_tag=`AnyKeyword`;constructor(e={}){this.annotations=e}toString(){return $E(this)}toJSON(){return{_tag:this._tag,annotations:K(this.annotations)}}}({[fT]:`any`}),rE=new class{annotations;_tag=`StringKeyword`;constructor(e={}){this.annotations=e}toString(){return $E(this)}toJSON(){return{_tag:this._tag,annotations:K(this.annotations)}}}({[fT]:`string`,[mT]:`a string`}),iE=YT(`StringKeyword`),aE=new class{annotations;_tag=`NumberKeyword`;constructor(e={}){this.annotations=e}toString(){return $E(this)}toJSON(){return{_tag:this._tag,annotations:K(this.annotations)}}}({[fT]:`number`,[mT]:`a number`}),oE=new class{annotations;_tag=`BooleanKeyword`;constructor(e={}){this.annotations=e}toString(){return $E(this)}toJSON(){return{_tag:this._tag,annotations:K(this.annotations)}}}({[fT]:`boolean`,[mT]:`a boolean`}),sE=new class{annotations;_tag=`BigIntKeyword`;constructor(e={}){this.annotations=e}toString(){return $E(this)}toJSON(){return{_tag:this._tag,annotations:K(this.annotations)}}}({[fT]:`bigint`,[mT]:`a bigint`}),cE=new class{annotations;_tag=`SymbolKeyword`;constructor(e={}){this.annotations=e}toString(){return $E(this)}toJSON(){return{_tag:this._tag,annotations:K(this.annotations)}}}({[fT]:`symbol`,[mT]:`a symbol`}),lE=YT(`SymbolKeyword`);var uE=class{type;annotations;constructor(e,t={}){this.type=e,this.annotations=t}toJSON(){return{type:this.type.toJSON(),annotations:K(this.annotations)}}toString(){return String(this.type)}},dE=class extends uE{isOptional;constructor(e,t,n={}){super(e,n),this.isOptional=t}toJSON(){return{type:this.type.toJSON(),isOptional:this.isOptional,annotations:K(this.annotations)}}toString(){return String(this.type)+(this.isOptional?`?`:``)}};const fE=e=>e.map(e=>e.type);var pE=class{elements;rest;isReadonly;annotations;_tag=`TupleType`;constructor(e,t,n,r={}){this.elements=e,this.rest=t,this.isReadonly=n,this.annotations=r;let i=!1,a=!1;for(let t of e)if(t.isOptional)i=!0;else if(i){a=!0;break}if(a||i&&t.length>1)throw Error(Hw)}toString(){return F(nD(this),()=>mE(this))}toJSON(){return{_tag:this._tag,elements:this.elements.map(e=>e.toJSON()),rest:this.rest.map(e=>e.toJSON()),isReadonly:this.isReadonly,annotations:K(this.annotations)}}};const mE=e=>{let t=e.elements.map(String).join(`, `);return Mn(e.rest,{onEmpty:()=>`readonly [${t}]`,onNonEmpty:(n,r)=>{let i=String(n),a=i.includes(` | `)?`(${i})`:i;if(r.length>0){let n=r.map(String).join(`, `);return e.elements.length>0?`readonly [${t}, ...${a}[], ${n}]`:`readonly [...${a}[], ${n}]`}else if(e.elements.length>0)return`readonly [${t}, ...${a}[]]`;else return`ReadonlyArray<${i}>`}})};var hE=class extends dE{name;isReadonly;constructor(e,t,n,r,i){super(t,n,i),this.name=e,this.isReadonly=r}toString(){return(this.isReadonly?`readonly `:``)+String(this.name)+(this.isOptional?`?`:``)+`: `+this.type}toJSON(){return{name:String(this.name),type:this.type.toJSON(),isOptional:this.isOptional,isReadonly:this.isReadonly,annotations:K(this.annotations)}}};const gE=e=>{switch(e._tag){case`StringKeyword`:case`SymbolKeyword`:case`TemplateLiteral`:return!0;case`Refinement`:return gE(e.from)}return!1};var _E=class{type;isReadonly;parameter;constructor(e,t,n){if(this.type=t,this.isReadonly=n,gE(e))this.parameter=e;else throw Error(Vw)}toString(){return(this.isReadonly?`readonly `:``)+`[x: ${this.parameter}]: ${this.type}`}toJSON(){return{parameter:this.parameter.toJSON(),type:this.type.toJSON(),isReadonly:this.isReadonly}}},vE=class{annotations;_tag=`TypeLiteral`;propertySignatures;indexSignatures;constructor(e,t,n={}){this.annotations=n;let r={};for(let t=0;t<e.length;t++){let n=e[t].name;if(Object.prototype.hasOwnProperty.call(r,n))throw Error(Ww(n));r[n]=null}let i={string:!1,symbol:!1};for(let e=0;e<t.length;e++){let n=QE(t[e].parameter);if(iE(n)){if(i.string)throw Error(Bw(`string`));i.string=!0}else if(lE(n)){if(i.symbol)throw Error(Bw(`symbol`));i.symbol=!0}}this.propertySignatures=e,this.indexSignatures=t}toString(){return F(nD(this),()=>bE(this))}toJSON(){return{_tag:this._tag,propertySignatures:this.propertySignatures.map(e=>e.toJSON()),indexSignatures:this.indexSignatures.map(e=>e.toJSON()),annotations:K(this.annotations)}}};const yE=e=>e.map(String).join(`; `),bE=e=>{if(e.propertySignatures.length>0){let t=e.propertySignatures.map(String).join(`; `);return e.indexSignatures.length>0?`{ ${t}; ${yE(e.indexSignatures)} }`:`{ ${t} }`}else if(e.indexSignatures.length>0)return`{ ${yE(e.indexSignatures)} }`;else return`{}`},xE=Qn(cn(Sm,e=>{switch(e._tag){case`AnyKeyword`:return 0;case`UnknownKeyword`:return 1;case`ObjectKeyword`:return 2;case`StringKeyword`:case`NumberKeyword`:case`BooleanKeyword`:case`BigIntKeyword`:case`SymbolKeyword`:return 3}return 4})),SE={string:`StringKeyword`,number:`NumberKeyword`,boolean:`BooleanKeyword`,bigint:`BigIntKeyword`},CE=e=>ur(e,e=>OE(e)?CE(e.types):[e]),wE=e=>{let t=xE(e),n=[],r={},i=[];for(let e of t)switch(e._tag){case`NeverKeyword`:break;case`AnyKeyword`:return[nE];case`UnknownKeyword`:return[tE];case`ObjectKeyword`:case`UndefinedKeyword`:case`VoidKeyword`:case`StringKeyword`:case`NumberKeyword`:case`BooleanKeyword`:case`BigIntKeyword`:case`SymbolKeyword`:r[e._tag]||(r[e._tag]=e,n.push(e));break;case`Literal`:{let t=typeof e.literal;switch(t){case`string`:case`number`:case`bigint`:case`boolean`:!r[SE[t]]&&!i.includes(e.literal)&&(i.push(e.literal),n.push(e));break;case`object`:i.includes(e.literal)||(i.push(e.literal),n.push(e));break}break}case`UniqueSymbol`:!r.SymbolKeyword&&!i.includes(e.symbol)&&(i.push(e.symbol),n.push(e));break;case`TupleType`:r.ObjectKeyword||n.push(e);break;case`TypeLiteral`:e.propertySignatures.length===0&&e.indexSignatures.length===0?r[`{}`]||(r[`{}`]=e,n.push(e)):r.ObjectKeyword||n.push(e);break;default:n.push(e)}return n};var TE=class e{types;annotations;static make=(t,n)=>DE(t)?new e(t,n):t.length===1?t[0]:eE;static unify=(t,n)=>e.make(wE(CE(t)),n);_tag=`Union`;constructor(e,t={}){this.types=e,this.annotations=t}toString(){return F(nD(this),()=>this.types.map(String).join(` | `))}toJSON(){return{_tag:this._tag,types:this.types.map(e=>e.toJSON()),annotations:K(this.annotations)}}};const EE=(e,t)=>e.map(t),DE=e=>e.length>1,OE=YT(`Union`),kE=g(Symbol.for(`effect/Schema/AST/toJSONMemoMap`),()=>new WeakMap);var AE=class{f;annotations;_tag=`Suspend`;constructor(e,t={}){this.f=e,this.annotations=t,this.f=Mw(e)}toString(){return nD(this).pipe(fn(()=>bn(gn(this.f)(),e=>nD(e))),F(()=>`<suspended schema>`))}toJSON(){let e=this.f(),t=kE.get(e);return t||(kE.set(e,{_tag:this._tag}),t={_tag:this._tag,ast:e.toJSON(),annotations:K(this.annotations)},kE.set(e,t),t)}},jE=class{from;filter;annotations;_tag=`Refinement`;constructor(e,t,n={}){this.from=e,this.filter=t,this.annotations=n}toString(){return FT(this).pipe(F(()=>dn(tD(this),{onNone:()=>`{ ${this.from} | filter }`,onSome:e=>ME(this.from)?String(this.from)+` & `+e:e})))}toJSON(){return{_tag:this._tag,from:this.from.toJSON(),annotations:K(this.annotations)}}};const ME=YT(`Refinement`),NE={};var PE=class{from;to;transformation;annotations;_tag=`Transformation`;constructor(e,t,n,r={}){this.from=e,this.to=t,this.transformation=n,this.annotations=r}toString(){return F(nD(this),()=>`(${String(this.from)} <-> ${String(this.to)})`)}toJSON(){return{_tag:this._tag,from:this.from.toJSON(),to:this.to.toJSON(),annotations:K(this.annotations)}}},FE=class{decode;encode;_tag=`FinalTransformation`;constructor(e,t){this.decode=e,this.encode=t}},IE=class{from;to;decode;encode;constructor(e,t,n,r){this.from=e,this.to=t,this.decode=n,this.encode=r}},LE=class{propertySignatureTransformations;_tag=`TypeLiteralTransformation`;constructor(e){this.propertySignatureTransformations=e;let t={},n={};for(let r of e){let e=r.from;if(t[e])throw Error(Uw(e));t[e]=!0;let i=r.to;if(n[i])throw Error(Uw(i));n[i]=!0}}};const RE=(e,t)=>{let n=Object.getOwnPropertyDescriptors(e),r={...e.annotations};delete r[dT];let i={...r,...t},a=HT(e);return P(a)&&(i[DT]=RE(a.value,t)),n.annotations.value=i,Object.create(Object.getPrototypeOf(e),n)},zE=(e,t)=>{switch(e._tag){case`Literal`:return wm(String(e.literal));case`StringKeyword`:return`[\\s\\S]*?`;case`NumberKeyword`:return`[+-]?\\d*\\.?\\d+(?:[Ee][+-]?\\d+)?`;case`TemplateLiteral`:return VE(e,t,!1);case`Union`:return e.types.map(e=>zE(e,t)).join(`|`)}},BE=(e,t,n,r)=>{if(OE(e)){if(n&&!r)return`(?:${t})`}else if(!n||!r)return t;return`(${t})`},VE=(e,t,n)=>{let r=``;if(e.head!==``){let i=wm(e.head);r+=t&&n?`(${i})`:i}for(let i of e.spans){let e=zE(i.type,t);if(r+=BE(i.type,e,t,n),i.literal!==``){let e=wm(i.literal);r+=t&&n?`(${e})`:e}}return r},HE=e=>RegExp(`^${VE(e,!1,!0)}$`),UE=(e,t)=>{let n=[],r=[],i=e=>{switch(e._tag){case`NeverKeyword`:break;case`StringKeyword`:case`SymbolKeyword`:case`TemplateLiteral`:case`Refinement`:r.push(new _E(e,t,!0));break;case`Literal`:if(_(e.literal)||te(e.literal))n.push(new hE(e.literal,t,!1,!0));else throw Error(zw(e.literal));break;case`Enums`:for(let[r,i]of e.enums)n.push(new hE(i,t,!1,!0));break;case`UniqueSymbol`:n.push(new hE(e.symbol,t,!1,!0));break;case`Union`:e.types.forEach(i);break;default:throw Error(Rw(e))}};return i(e),{propertySignatures:n,indexSignatures:r}},WE=e=>{switch(e._tag){case`TupleType`:return e.isReadonly===!1?e:new pE(e.elements,e.rest,!1,e.annotations);case`TypeLiteral`:{let t=JE(e.propertySignatures,e=>e.isReadonly===!1?e:new hE(e.name,e.type,e.isOptional,!1,e.annotations)),n=JE(e.indexSignatures,e=>e.isReadonly===!1?e:new _E(e.parameter,e.type,!1));return t===e.propertySignatures&&n===e.indexSignatures?e:new vE(t,n,e.annotations)}case`Union`:{let t=JE(e.types,WE);return t===e.types?e:TE.make(t,e.annotations)}case`Suspend`:return new AE(()=>WE(e.f()),e.annotations);case`Refinement`:{let t=WE(e.from);return t===e.from?e:new jE(t,e.filter,e.annotations)}case`Transformation`:{let t=WE(e.from),n=WE(e.to);return t===e.from&&n===e.to?e:new PE(t,n,e.transformation,e.annotations)}}return e},GE=e=>t=>{let n;for(let r of e)Object.prototype.hasOwnProperty.call(t.annotations,r)&&(n===void 0&&(n={}),n[r]=t.annotations[r]);return n},KE=GE([hT,gT,_T,vT,yT,bT]),qE=e=>{switch(e._tag){case`Declaration`:{let t=JE(e.typeParameters,qE);return t===e.typeParameters?e:new JT(t,e.decodeUnknown,e.encodeUnknown,e.annotations)}case`TupleType`:{let t=JE(e.elements,e=>{let t=qE(e.type);return t===e.type?e:new dE(t,e.isOptional)}),n=fE(e.rest),r=JE(n,qE);return t===e.elements&&r===n?e:new pE(t,r.map(e=>new uE(e)),e.isReadonly,e.annotations)}case`TypeLiteral`:{let t=JE(e.propertySignatures,e=>{let t=qE(e.type);return t===e.type?e:new hE(e.name,t,e.isOptional,e.isReadonly)}),n=JE(e.indexSignatures,e=>{let t=qE(e.type);return t===e.type?e:new _E(e.parameter,t,e.isReadonly)});return t===e.propertySignatures&&n===e.indexSignatures?e:new vE(t,n,e.annotations)}case`Union`:{let t=JE(e.types,qE);return t===e.types?e:TE.make(t,e.annotations)}case`Suspend`:return new AE(()=>qE(e.f()),e.annotations);case`Refinement`:{let t=qE(e.from);return t===e.from?e:new jE(t,e.filter,e.annotations)}case`Transformation`:{let t=KE(e);return qE(t===void 0?e.to:RE(e.to,t))}}return e};function JE(e,t){let n=!1,r=kn(e.length);for(let i=0;i<e.length;i++){let a=e[i],o=t(a);o!==a&&(n=!0),r[i]=o}return n?r:e}const YE=e=>{switch(e._tag){case`Transformation`:return e.from;case`Refinement`:return YE(e.from);case`Suspend`:return YE(e.f())}},XE=(e,t)=>{switch(e._tag){case`Declaration`:{let n=JE(e.typeParameters,e=>XE(e,t));return n===e.typeParameters?e:new JT(n,e.decodeUnknown,e.encodeUnknown)}case`TupleType`:{let n=JE(e.elements,e=>{let n=XE(e.type,t);return n===e.type?e:new dE(n,e.isOptional)}),r=fE(e.rest),i=JE(r,e=>XE(e,t));return n===e.elements&&i===r?e:new pE(n,i.map(e=>new uE(e)),e.isReadonly)}case`TypeLiteral`:{let n=JE(e.propertySignatures,e=>{let n=XE(e.type,t);return n===e.type?e:new hE(e.name,n,e.isOptional,e.isReadonly)}),r=JE(e.indexSignatures,e=>{let n=XE(e.type,t);return n===e.type?e:new _E(e.parameter,n,e.isReadonly)});return n===e.propertySignatures&&r===e.indexSignatures?e:new vE(n,r)}case`Union`:{let n=JE(e.types,e=>XE(e,t));return n===e.types?e:TE.make(n)}case`Suspend`:{let n,r=qT(e);if(P(r)){let e=t?`Bound`:``;n={[GT]:`${r.value}Encoded${e}`}}return new AE(()=>XE(e.f(),t),n)}case`Refinement`:{let n=XE(e.from,t);return t?n===e.from?e:YE(e.from)===void 0&&WT(e)?new jE(n,e.filter,e.annotations):n:n}case`Transformation`:return XE(e.from,t)}return e},ZE=e=>XE(e,!1),K=e=>{let t={};for(let n of Object.getOwnPropertySymbols(e))t[String(n)]=e[n];return t},QE=e=>{switch(e._tag){case`StringKeyword`:case`SymbolKeyword`:case`TemplateLiteral`:return e;case`Refinement`:return QE(e.from)}},$E=e=>F(nD(e),()=>e._tag);function eD(e){return dn(AT(e),{onNone:()=>``,onSome:e=>e.map(e=>` & Brand<${We(e)}>`).join(``)})}const tD=e=>NT(e).pipe(fn(()=>IT(e)),fn(()=>PT(e)),yn(t=>t+eD(e))),nD=e=>fn(FT(e),()=>tD(e));var rD=class{path;actual;issue;_tag=`Pointer`;constructor(e,t,n){this.path=e,this.actual=t,this.issue=n}},iD=class{actual;message;_tag=`Unexpected`;constructor(e,t){this.actual=e,this.message=t}},aD=class{ast;message;_tag=`Missing`;actual=void 0;constructor(e,t){this.ast=e,this.message=t}},q=class{ast;actual;issues;output;_tag=`Composite`;constructor(e,t,n,r){this.ast=e,this.actual=t,this.issues=n,this.output=r}},oD=class{ast;actual;kind;issue;_tag=`Refinement`;constructor(e,t,n,r){this.ast=e,this.actual=t,this.kind=n,this.issue=r}},sD=class{ast;actual;kind;issue;_tag=`Transformation`;constructor(e,t,n,r){this.ast=e,this.actual=t,this.kind=n,this.issue=r}},J=class{ast;actual;message;_tag=`Type`;constructor(e,t,n){this.ast=e,this.actual=t,this.message=n}},cD=class{ast;actual;message;_tag=`Forbidden`;constructor(e,t,n){this.ast=e,this.actual=t,this.message=n}};const lD=Symbol.for(`effect/Schema/ParseErrorTypeId`);var uD=class extends fh(`ParseError`){[lD]=lD;get message(){return this.toString()}toString(){return WD.formatIssueSync(this.issue)}toJSON(){return{_id:`ParseError`,message:this.toString()}}[E](){return this.toJSON()}};const dD=e=>new uD({issue:e}),Y=k,fD=A,pD=qt,mD=Kt,hD=Jt,gD=t(2,(e,t)=>hD(e)?en(e,{onLeft:A,onRight:t}):uw(e,t)),_D=t(2,(e,t)=>hD(e)?$t(e,t):ow(e,t)),vD=t(2,(e,t)=>hD(e)?Qt(e,t):cw(e,t)),yD=t(2,(e,t)=>hD(e)?Zt(e,{onLeft:t.onFailure,onRight:t.onSuccess}):sw(e,t)),bD=t(2,(e,t)=>hD(e)?en(e,{onLeft:t,onRight:k}):aw(e,t)),xD=(e,t)=>t===void 0||te(t)?e:e===void 0?t:{...e,...t},SD=(e,t,n)=>{let r=jD(e,t);return(e,t)=>r(e,xD(n,t))},CD=(e,t,n)=>{let r=SD(e,t,n);return(e,t)=>nn(r(e,t),dD)},wD=(e,t,n)=>{let r=jD(e,t);return(e,t)=>r(e,{...xD(n,t),isEffectAllowed:!0})},TD=(e,t)=>SD(e.ast,!0,t),ED=(e,t)=>wD(e.ast,!0,t),DD=(e,t)=>wD(e.ast,!1,t),OD=(e,t)=>CD(qE(e.ast),!0,t),kD=g(Symbol.for(`effect/ParseResult/decodeMemoMap`),()=>new WeakMap),AD=g(Symbol.for(`effect/ParseResult/encodeMemoMap`),()=>new WeakMap),jD=(e,t)=>{let n=t?kD:AD,r=n.get(e);if(r)return r;let i=PD(e,t),a=BT(e),o=P(a)?(e,t)=>i(e,xD(t,a.value)):i,s=VT(e),c=t&&P(s)?(t,n)=>zD(bD(o(t,n),s.value),e,t,n):o;return n.set(e,c),c},MD=e=>hn(LT(e)),ND=e=>hn(RT(e)),PD=(e,t)=>{switch(e._tag){case`Refinement`:if(t){let t=jD(e.from,!0);return(n,r)=>{r??=NE;let i=r?.errors===`all`;return zD(gD(bD(t(n,r),t=>{let a=new oD(e,n,`From`,t);return i&&WT(e)&&$D(t)?dn(e.filter(n,r,e),{onNone:()=>A(a),onSome:t=>A(new q(e,n,[a,new oD(e,n,`Predicate`,t)]))}):A(a)}),t=>dn(e.filter(t,r,e),{onNone:()=>k(t),onSome:t=>A(new oD(e,n,`Predicate`,t))})),e,n,r)}}else{let t=jD(qE(e),!0),n=jD(RD(e.from),!1);return(r,i)=>zD(gD(t(r,i),e=>n(e,i)),e,r,i)}case`Transformation`:{let n=HD(e.transformation,t),r=t?jD(e.from,!0):jD(e.to,!1),i=t?jD(e.to,!0):jD(e.from,!1);return(a,o)=>zD(gD(vD(r(a,o),n=>new sD(e,a,t?`Encoded`:`Type`,n)),r=>gD(vD(n(r,o??NE,e,a),t=>new sD(e,a,`Transformation`,t)),n=>vD(i(n,o),n=>new sD(e,a,t?`Type`:`Encoded`,n)))),e,a,o)}case`Declaration`:{let n=t?e.decodeUnknown(...e.typeParameters):e.encodeUnknown(...e.typeParameters);return(t,r)=>zD(n(t,r??NE,e),e,t,r)}case`Literal`:return FD(e,t=>t===e.literal);case`UniqueSymbol`:return FD(e,t=>t===e.symbol);case`UndefinedKeyword`:return FD(e,oe);case`NeverKeyword`:return FD(e,se);case`UnknownKeyword`:case`AnyKeyword`:case`VoidKeyword`:return k;case`StringKeyword`:return FD(e,_);case`NumberKeyword`:return FD(e,te);case`BooleanKeyword`:return FD(e,ne);case`BigIntKeyword`:return FD(e,re);case`SymbolKeyword`:return FD(e,ie);case`ObjectKeyword`:return FD(e,le);case`Enums`:return FD(e,t=>e.enums.some(([e,n])=>n===t));case`TemplateLiteral`:{let t=HE(e);return FD(e,e=>_(e)&&t.test(e))}case`TupleType`:{let n=e.elements.map(e=>jD(e.type,t)),r=e.rest.map(e=>jD(e.type,t)),i=e.elements.filter(e=>!e.isOptional);e.rest.length>0&&(i=i.concat(e.rest.slice(1)));let a=i.length,o=e.elements.length>0?e.elements.map((e,t)=>t).join(` | `):`never`,s=MD(e),c=ND(e);return(t,l)=>{if(!In(t))return A(new J(e,t));let u=l?.errors===`all`,d=[],f=0,p=[],m=t.length;for(let n=m;n<=a-1;n++){let r=new rD(n,t,new aD(i[n-m]));if(u){d.push([f++,r]);continue}else return A(new q(e,t,r,p))}if(e.rest.length===0)for(let n=e.elements.length;n<=m-1;n++){let r=new rD(n,t,new iD(t[n],`is unexpected, expected: ${o}`));if(u){d.push([f++,r]);continue}else return A(new q(e,t,r,p))}let h=0,g;for(;h<n.length;h++)if(m<h+1){if(e.elements[h].isOptional)continue}else{let r=n[h],i=r(t[h],l);if(hD(i)){if(Yt(i)){let n=new rD(h,t,i.left);if(u){d.push([f++,n]);continue}else return A(new q(e,t,n,VD(p)))}p.push([f++,i.right])}else{let n=f++,r=h;g||=[],g.push(({es:a,output:o})=>uw(lw(i),i=>{if(Yt(i)){let s=new rD(r,t,i.left);return u?(a.push([n,s]),iw):A(new q(e,t,s,VD(o)))}return o.push([n,i.right]),iw}))}}if(L(r)){let[n,...i]=r;for(;h<m-i.length;h++){let r=n(t[h],l);if(hD(r))if(Yt(r)){let n=new rD(h,t,r.left);if(u){d.push([f++,n]);continue}else return A(new q(e,t,n,VD(p)))}else p.push([f++,r.right]);else{let n=f++,i=h;g||=[],g.push(({es:a,output:o})=>uw(lw(r),r=>{if(Yt(r)){let s=new rD(i,t,r.left);return u?(a.push([n,s]),iw):A(new q(e,t,s,VD(o)))}else return o.push([n,r.right]),iw}))}}for(let n=0;n<i.length;n++){let r=h+n;if(!(m<r+1)){let a=i[n](t[r],l);if(hD(a)){if(Yt(a)){let n=new rD(r,t,a.left);if(u){d.push([f++,n]);continue}else return A(new q(e,t,n,VD(p)))}p.push([f++,a.right])}else{let n=f++;g||=[],g.push(({es:i,output:o})=>uw(lw(a),a=>{if(Yt(a)){let s=new rD(r,t,a.left);return u?(i.push([n,s]),iw):A(new q(e,t,s,VD(o)))}return o.push([n,a.right]),iw}))}}}}let ee=({es:n,output:r})=>Rn(n)?A(new q(e,t,VD(n),VD(r))):k(VD(r));if(g&&g.length>0){let e=g;return rw(()=>{let t={es:ir(d),output:ir(p)};return uw(nw(e,e=>e(t),{concurrency:s,batching:c,discard:!0}),()=>ee(t))})}return ee({output:p,es:d})}}case`TypeLiteral`:{if(e.propertySignatures.length===0&&e.indexSignatures.length===0)return FD(e,fe);let n=[],r={},i=[];for(let a of e.propertySignatures)n.push([jD(a.type,t),a]),r[a.name]=null,i.push(a.name);let a=e.indexSignatures.map(e=>[jD(e.parameter,t),jD(e.type,t),e.parameter]),o=TE.make(e.indexSignatures.map(e=>e.parameter).concat(i.map(e=>ie(e)?new $T(e):new XT(e)))),s=jD(o,t),c=MD(e),l=ND(e);return(t,u)=>{if(!ge(t))return A(new J(e,t));let d=u?.errors===`all`,f=[],p=0,m=u?.onExcessProperty===`error`,h=u?.onExcessProperty===`preserve`,g={},ee;if(m||h){ee=Reflect.ownKeys(t);for(let n of ee){let r=s(n,u);if(hD(r)&&Yt(r))if(m){let r=new rD(n,t,new iD(t[n],`is unexpected, expected: ${String(o)}`));if(d){f.push([p++,r]);continue}else return A(new q(e,t,r,g))}else g[n]=t[n]}}let _,te=u?.exact===!0;for(let r=0;r<n.length;r++){let i=n[r][1],a=i.name,o=Object.prototype.hasOwnProperty.call(t,a);if(!o){if(i.isOptional)continue;if(te){let n=new rD(a,t,new aD(i));if(d){f.push([p++,n]);continue}else return A(new q(e,t,n,g))}}let s=n[r][0],c=s(t[a],u);if(hD(c)){if(Yt(c)){let n=new rD(a,t,o?c.left:new aD(i));if(d){f.push([p++,n]);continue}else return A(new q(e,t,n,g))}g[a]=c.right}else{let n=p++,r=a;_||=[],_.push(({es:a,output:s})=>uw(lw(c),c=>{if(Yt(c)){let l=new rD(r,t,o?c.left:new aD(i));return d?(a.push([n,l]),iw):A(new q(e,t,l,s))}return s[r]=c.right,iw}))}}for(let n=0;n<a.length;n++){let i=a[n],o=i[0],s=i[1],c=jw(t,i[2]);for(let n of c){let i=o(n,u);if(hD(i)&&Xt(i)){let i=s(t[n],u);if(hD(i))if(Yt(i)){let r=new rD(n,t,i.left);if(d){f.push([p++,r]);continue}else return A(new q(e,t,r,g))}else Object.prototype.hasOwnProperty.call(r,n)||(g[n]=i.right);else{let a=p++,o=n;_||=[],_.push(({es:s,output:c})=>uw(lw(i),i=>{if(Yt(i)){let n=new rD(o,t,i.left);return d?(s.push([a,n]),iw):A(new q(e,t,n,c))}else return Object.prototype.hasOwnProperty.call(r,n)||(c[n]=i.right),iw}))}}}}let ne=({es:n,output:r})=>{if(Rn(n))return A(new q(e,t,VD(n),r));if(u?.propertyOrder===`original`){let e=ee||Reflect.ownKeys(t);for(let t of i)e.indexOf(t)===-1&&e.push(t);let n={};for(let t of e)Object.prototype.hasOwnProperty.call(r,t)&&(n[t]=r[t]);return k(n)}return k(r)};if(_&&_.length>0){let e=_;return rw(()=>{let t={es:ir(f),output:Object.assign({},g)};return uw(nw(e,e=>e(t),{concurrency:c,batching:l,discard:!0}),()=>ne(t))})}return ne({es:f,output:g})}}case`Union`:{let n=LD(e.types,t),r=Reflect.ownKeys(n.keys),i=r.length,a=e.types.length,o=new Map;for(let n=0;n<a;n++)o.set(e.types[n],jD(e.types[n],t));let s=MD(e)??1,c=ND(e);return(t,l)=>{let u=[],d=0,f=[];if(i>0)if(ce(t))for(let e=0;e<i;e++){let i=r[e],o=n.keys[i].buckets;if(Object.prototype.hasOwnProperty.call(t,i)){let e=String(t[i]);if(Object.prototype.hasOwnProperty.call(o,e))f=f.concat(o[e]);else{let{candidates:e,literals:r}=n.keys[i],o=TE.make(r),s=e.length===a?new vE([new hE(i,o,!1,!0)],[]):TE.make(e);u.push([d++,new q(s,t,new rD(i,t,new J(o,t[i])))])}}else{let{candidates:e,literals:r}=n.keys[i],o=new hE(i,TE.make(r),!1,!0),s=e.length===a?new vE([o],[]):TE.make(e);u.push([d++,new q(s,t,new rD(i,t,new aD(o)))])}}else{let r=n.candidates.length===a?e:TE.make(n.candidates);u.push([d++,new J(r,t)])}n.otherwise.length>0&&(f=f.concat(n.otherwise));let p;for(let e=0;e<f.length;e++){let n=f[e],r=o.get(n)(t,l);if(hD(r)&&(!p||p.length===0)){if(Xt(r))return r;u.push([d++,r.left])}else{let e=d++;p||=[],p.push(t=>rw(()=>`finalResult`in t?iw:uw(lw(r),n=>(Xt(n)?t.finalResult=n:t.es.push([e,n.left]),iw))))}}let m=n=>Rn(n)?n.length===1&&n[0][1]._tag===`Type`?A(n[0][1]):A(new q(e,t,VD(n))):A(new J(e,t));if(p&&p.length>0){let e=p;return rw(()=>{let t={es:ir(u)};return uw(nw(e,e=>e(t),{concurrency:s,batching:c,discard:!0}),()=>`finalResult`in t?t.finalResult:m(t.es))})}return m(u)}}case`Suspend`:{let n=Mw(()=>jD(e.f(),t));return(e,t)=>n()(e,t)}}},FD=(e,t)=>n=>t(n)?k(n):A(new J(e,n)),ID=(e,t)=>{switch(e._tag){case`Declaration`:{let n=HT(e);if(P(n))return ID(n.value,t);break}case`TypeLiteral`:{let n=[];for(let r=0;r<e.propertySignatures.length;r++){let i=e.propertySignatures[r],a=t?ZE(i.type):qE(i.type);ZT(a)&&!i.isOptional&&n.push([i.name,a])}return n}case`TupleType`:{let n=[];for(let r=0;r<e.elements.length;r++){let i=e.elements[r],a=t?ZE(i.type):qE(i.type);ZT(a)&&!i.isOptional&&n.push([r,a])}return n}case`Refinement`:return ID(e.from,t);case`Suspend`:return ID(e.f(),t);case`Transformation`:return ID(t?e.from:e.to,t)}return[]},LD=(e,t)=>{let n={},r=[],i=[];for(let a=0;a<e.length;a++){let o=e[a],s=ID(o,t);if(s.length>0){i.push(o);for(let e=0;e<s.length;e++){let[t,r]=s[e],i=String(r.literal);n[t]=n[t]||{buckets:{},literals:[],candidates:[]};let a=n[t].buckets;if(Object.prototype.hasOwnProperty.call(a,i)){if(e<s.length-1)continue;a[i].push(o),n[t].literals.push(r),n[t].candidates.push(o)}else{a[i]=[o],n[t].literals.push(r),n[t].candidates.push(o);break}}}else r.push(o)}return{keys:n,otherwise:r,candidates:i}},RD=e=>ME(e)?RD(e.from):e,zD=(e,t,n,r)=>{if(r?.isEffectAllowed===!0||hD(e))return e;let i=new W_,a=dw(e,{scheduler:i});i.flush();let o=a.unsafePoll();if(o){if(vv(o))return k(o.value);let e=o.cause;return Qp(e)?A(e.error):A(new cD(t,n,em(e)))}return A(new cD(t,n,`cannot be be resolved synchronously, this is caused by using runSync on an effect that performs async work`))},BD=([e],[t])=>e>t?1:e<t?-1:0;function VD(e){return e.sort(BD).map(e=>e[1])}const HD=(e,t)=>{switch(e._tag){case`FinalTransformation`:return t?e.decode:e.encode;case`ComposeTransformation`:return k;case`TypeLiteralTransformation`:return n=>{let r=k(n);for(let n of e.propertySignatureTransformations){let[e,i]=t?[n.from,n.to]:[n.to,n.from],a=t?n.decode:n.encode;r=_D(r,t=>{let n=a(Object.prototype.hasOwnProperty.call(t,e)?M(t[e]):j());return delete t[e],P(n)&&(t[i]=n.value),t})}return r}}},UD=(e,t=[])=>({value:e,forest:t}),WD={formatIssue:e=>_D(dO(e),GD),formatIssueSync:e=>{let t=WD.formatIssue(e);return hD(t)?rn(t):fw(t)},formatError:e=>WD.formatIssue(e.issue),formatErrorSync:e=>WD.formatIssueSync(e.issue)},GD=e=>e.value+KD(`
`,e.forest),KD=(e,t)=>{let n=``,r=t.length,i;for(let a=0;a<r;a++){i=t[a];let o=a===r-1;n+=e+(o?`└`:`├`)+`─ `+i.value,n+=KD(e+(r>1&&!o?`│  `:`   `),i.forest)}return n},qD=e=>{switch(e){case`Encoded`:return`Encoded side transformation failure`;case`Transformation`:return`Transformation process failure`;case`Type`:return`Type side transformation failure`}},JD=e=>{switch(e){case`From`:return`From side refinement failure`;case`Predicate`:return`Predicate refinement failure`}},YD=e=>`ast`in e?M(e.ast):j(),XD=k(void 0),ZD=e=>YD(e).pipe(bn(jT),dn({onNone:()=>XD,onSome:t=>{let n=t(e);return _(n)?k({message:n,override:!1}):tw(n)?ow(n,e=>({message:e,override:!1})):_(n.message)?k({message:n.message,override:n.override}):ow(n.message,e=>({message:e,override:n.override}))}})),QD=e=>t=>t._tag===e,$D=QD(`Composite`),eO=QD(`Refinement`),tO=QD(`Transformation`),nO=e=>gD(ZD(e),t=>t===void 0?XD:!t.override&&($D(e)||eO(e)&&e.kind===`From`||tO(e)&&e.kind!==`Transformation`)?tO(e)||eO(e)?nO(e.issue):XD:k(t.message)),rO=e=>YD(e).pipe(bn(zT),xn(t=>t(e)),hn);function iO(e){return IT(e).pipe(fn(()=>NT(e)),fn(()=>PT(e)),fn(()=>FT(e)),F(()=>`{ ${e.from} | filter }`))}function aO(e){return e.message===void 0?`Expected ${ME(e.ast)?iO(e.ast):String(e.ast)}, actual ${We(e.actual)}`:e.message}const oO=e=>_D(nO(e),t=>t??rO(e)??aO(e)),sO=e=>rO(e)??String(e.ast),cO=e=>e.message??`is forbidden`,lO=e=>e.message??`is unexpected`,uO=e=>{let t=MT(e.ast);if(P(t)){let e=t.value();return _(e)?k(e):e}return k(e.message??`is missing`)},dO=e=>{switch(e._tag){case`Type`:return _D(oO(e),UD);case`Forbidden`:return k(UD(sO(e),[UD(cO(e))]));case`Unexpected`:return k(UD(lO(e)));case`Missing`:return _D(uO(e),UD);case`Transformation`:return gD(nO(e),t=>t===void 0?_D(dO(e.issue),t=>UD(sO(e),[UD(qD(e.kind),[t])])):k(UD(t)));case`Refinement`:return gD(nO(e),t=>t===void 0?_D(dO(e.issue),t=>UD(sO(e),[UD(JD(e.kind),[t])])):k(UD(t)));case`Pointer`:return _D(dO(e.issue),t=>UD(Iw(e.path),[t]));case`Composite`:return gD(nO(e),t=>{if(t!==void 0)return k(UD(t));let n=sO(e);return Nw(e.issues)?_D(nw(e.issues,dO),e=>UD(n,e)):_D(dO(e.issues),e=>UD(n,[e]))})}},fO=t(e=>le(e[0]),(e,...t)=>{let n={};for(let r of t)r in e&&(n[r]=e[r]);return n}),pO=t(e=>le(e[0]),(e,...t)=>{let n={...e};for(let e of t)delete n[e];return n}),mO=Symbol.for(`effect/Schema`);function X(e){return class{[mO]=hO;static ast=e;static annotations(e){return X(vO(this.ast,e))}static pipe(){return O(this,arguments)}static toString(){return String(e)}static Type;static Encoded;static Context;static[mO]=hO}}const hO={_A:e=>e,_I:e=>e,_R:e=>e},gO={typeConstructor:oT,schemaId:cT,message:lT,missingMessage:uT,identifier:dT,title:fT,description:mT,examples:hT,default:gT,documentation:xT,jsonSchema:_T,arbitrary:vT,pretty:yT,equivalence:bT,concurrency:ST,batching:CT,parseIssueTitle:wT,parseOptions:TT,decodingFallback:ET},_O=e=>{if(!e)return{};let t={...e};for(let n in gO)if(n in e){let r=gO[n];t[r]=e[n],delete t[n]}return t},vO=(e,t)=>RE(e,_O(t)),yO=e=>String(e.ast),bO=(e,t)=>{let n=TD(e,t);return(e,t)=>Qt(n(e,t),dD)},xO=e=>v(e,mO)&&le(e[mO]);function SO(e){return DE(e)?TE.make(EE(e,e=>new XT(e))):new XT(e[0])}function CO(e,t=SO(e)){return class extends X(t){static annotations(e){return CO(this.literals,vO(this.ast,e))}static literals=[...e]}}function wO(...e){return L(e)?CO(e):MO}const TO=(e,t,n)=>DO(e,new JT(e.map(e=>e.ast),(...e)=>t.decode(...e.map(X)),(...e)=>t.encode(...e.map(X)),_O(n))),EO=(e,t)=>{let n=()=>(t,n,r)=>e(t)?Y(t):fD(new J(r,t));return DO([],new JT([],n,n,_O(t)))};function DO(e,t){return class extends X(t){static annotations(e){return DO(this.typeParameters,vO(this.ast,e))}static typeParameters=[...e]}}const OO=function(){if(Array.isArray(arguments[0])){let e=arguments[0],t=arguments[1],n=arguments[2];return TO(e,t,n)}let e=arguments[0],t=arguments[1];return EO(e,t)},kO=Symbol.for(`effect/SchemaId/InstanceOf`),AO=(e,t)=>OO(t=>t instanceof e,{title:e.name,description:`an instance of ${e.name}`,pretty:()=>String,schemaId:kO,[kO]:{constructor:e},...t});var jO=class extends X(QT){},MO=class extends X(eE){},NO=class extends X(tE){},PO=class extends X(sE){},FO=class extends X(cE){},Z=class extends X(rE){},Q=class extends X(aE){},IO=class extends X(oE){};const LO=e=>TE.make(e.map(e=>e.ast));function RO(e,t=LO(e)){return class extends X(t){static annotations(e){return RO(this.members,vO(this.ast,e))}static members=[...e]}}function zO(...e){return DE(e)?RO(e):L(e)?e[0]:MO}const BO=e=>zO(e,jO),VO=e=>new HO(new dE(e.ast,!1),e);var HO=class e{ast;from;[mO];_Token;constructor(e,t){this.ast=e,this.from=t}annotations(t){return new e(new dE(this.ast.type,this.ast.isOptional,{...this.ast.annotations,..._O(t)}),this.from)}toString(){return`${this.ast.type}${this.ast.isOptional?`?`:``}`}};const UO=(e,t)=>new pE(e.map(e=>xO(e)?new dE(e.ast,!1):e.ast),t.map(e=>xO(e)?new uE(e.ast):e.ast),!0);function WO(e,t,n=UO(e,t)){return class extends X(n){static annotations(e){return WO(this.elements,this.rest,vO(this.ast,e))}static elements=[...e];static rest=[...t]}}function GO(...e){return Array.isArray(e[0])?WO(e[0],e.slice(1)):WO(e,[])}function KO(e,t){return class extends WO([],[e],t){static annotations(e){return KO(this.value,vO(this.ast,e))}static value=e}}const qO=e=>KO(e),JO=e=>e?`"?:"`:`":"`;var YO=class extends dE{isReadonly;defaultValue;_tag=`PropertySignatureDeclaration`;constructor(e,t,n,r,i){super(e,t,r),this.isReadonly=n,this.defaultValue=i}toString(){let e=JO(this.isOptional),t=String(this.type);return`PropertySignature<${e}, ${t}, never, ${e}, ${t}>`}},XO=class extends dE{isReadonly;defaultValue;constructor(e,t,n,r,i){super(e,t,r),this.isReadonly=n,this.defaultValue=i}};const ZO=e=>e===void 0?`never`:_(e)?JSON.stringify(e):String(e);var QO=class{from;to;decode;encode;_tag=`PropertySignatureTransformation`;constructor(e,t,n,r){this.from=e,this.to=t,this.decode=n,this.encode=r}toString(){return`PropertySignature<${JO(this.to.isOptional)}, ${this.to.type}, ${ZO(this.from.fromKey)}, ${JO(this.from.isOptional)}, ${this.from.type}>`}};const $O=(e,t)=>{switch(e._tag){case`PropertySignatureDeclaration`:return new YO(e.type,e.isOptional,e.isReadonly,{...e.annotations,...t},e.defaultValue);case`PropertySignatureTransformation`:return new QO(e.from,new XO(e.to.type,e.to.isOptional,e.to.isReadonly,{...e.to.annotations,...t},e.to.defaultValue),e.decode,e.encode)}},ek=Symbol.for(`effect/PropertySignature`),tk=e=>v(e,ek);var nk=class e{ast;[mO];[ek]=null;_TypeToken;_Key;_EncodedToken;_HasDefault;constructor(e){this.ast=e}pipe(){return O(this,arguments)}annotations(t){return new e($O(this.ast,_O(t)))}toString(){return String(this.ast)}};const rk=e=>new nk(e);var ik=class e extends nk{from;constructor(e,t){super(e),this.from=t}annotations(t){return new e($O(this.ast,_O(t)),this.from)}};const ak=e=>new ik(new YO(e.ast,!1,!0,{},void 0),e),ok=t(2,(e,t)=>{let n=e.ast;switch(n._tag){case`PropertySignatureDeclaration`:return rk(new YO(n.type,n.isOptional,n.isReadonly,n.annotations,t));case`PropertySignatureTransformation`:return rk(new QO(n.from,new XO(n.to.type,n.to.isOptional,n.to.isReadonly,n.to.annotations,t),n.decode,n.encode))}}),sk=GE([uT]),ck=(e,t)=>{let n=Reflect.ownKeys(e),r=[];if(n.length>0){let i=[],a=[],o=[];for(let t=0;t<n.length;t++){let s=n[t],c=e[s];if(tk(c)){let e=c.ast;switch(e._tag){case`PropertySignatureDeclaration`:{let t=e.type,n=e.isOptional,o=e.annotations;i.push(new hE(s,t,n,!0,sk(e))),a.push(new hE(s,qE(t),n,!0,o)),r.push(new hE(s,t,n,!0,o));break}case`PropertySignatureTransformation`:{let t=e.from.fromKey??s;i.push(new hE(t,e.from.type,e.from.isOptional,!0,e.from.annotations)),a.push(new hE(s,e.to.type,e.to.isOptional,!0,e.to.annotations)),o.push(new IE(t,s,e.decode,e.encode));break}}}else i.push(new hE(s,c.ast,!1,!0)),a.push(new hE(s,qE(c.ast),!1,!0)),r.push(new hE(s,c.ast,!1,!0))}if(L(o)){let e=[],n=[];for(let r of t){let{indexSignatures:t,propertySignatures:o}=UE(r.key.ast,r.value.ast);o.forEach(e=>{i.push(e),a.push(new hE(e.name,qE(e.type),e.isOptional,e.isReadonly,e.annotations))}),t.forEach(t=>{e.push(t),n.push(new _E(t.parameter,qE(t.type),t.isReadonly))})}return new PE(new vE(i,e,{[pT]:`Struct (Encoded side)`}),new vE(a,n,{[pT]:`Struct (Type side)`}),new LE(o))}}let i=[];for(let e of t){let{indexSignatures:t,propertySignatures:n}=UE(e.key.ast,e.value.ast);n.forEach(e=>r.push(e)),t.forEach(e=>i.push(e))}return new vE(r,i)},lk=(e,t)=>{let n=Reflect.ownKeys(e);for(let r of n){let n=e[r];if(t[r]===void 0&&tk(n)){let e=n.ast,i=e._tag===`PropertySignatureDeclaration`?e.defaultValue:e.to.defaultValue;i!==void 0&&(t[r]=i())}}return t};function uk(e,t,n=ck(e,t)){return class extends X(n){static annotations(e){return uk(this.fields,this.records,vO(this.ast,e))}static fields={...e};static records=[...t];static make=(t,n)=>{let r=lk(e,{...t});return uj(n)?r:OD(this)(r)};static pick(...t){return dk(fO(e,...t))}static omit(...t){return dk(pO(e,...t))}}}function dk(e,...t){return uk(e,t)}const fk=e=>wO(e).pipe(ak,ok(()=>e)),pk=(e,t)=>dk({_tag:fk(e),...t}),mk=e=>X(WE(e.ast)),hk=e=>X(new AE(()=>e().ast)),gk=Symbol.for(`effect/SchemaId/Refine`);function _k(e,t,n){return class extends X(n){static annotations(e){return _k(this.from,this.filter,vO(this.ast,e))}static[gk]=e;static from=e;static filter=t;static make=(e,t)=>uj(t)?e:OD(this)(e)}}const vk=(e,t,n)=>{if(ne(e))return e?j():M(new J(t,n));if(_(e))return M(new J(t,n,e));if(e!==void 0){if(`_tag`in e)return M(e);let r=new J(t,n,e.message);return M(L(e.path)?new rD(e.path,n,r):r)}return j()},yk=(e,t,n)=>{if(Pw(e))return vk(e,t,n);if(L(e)){let r=fr(e,e=>vk(e,t,n));if(L(r))return M(r.length===1?r[0]:new q(t,n,r))}return j()};function $(e,t){return n=>{function r(t,n,r){return yk(e(t,n,r),r,t)}return _k(n,r,new jE(n.ast,r,_O(t)))}}function bk(e,t,n){return class extends X(n){static annotations(e){return bk(this.from,this.to,vO(this.ast,e))}static from=e;static to=t}}const xk=t(e=>xO(e[0])&&xO(e[1]),(e,t,n)=>bk(e,t,new PE(e.ast,t.ast,new FE(n.decode,n.encode)))),Sk=t(e=>xO(e[0])&&xO(e[1]),(e,t,n)=>xk(e,t,{strict:!0,decode:(e,t,r,i)=>Y(n.decode(e,i)),encode:(e,t,r,i)=>Y(n.encode(e,i))})),Ck=Symbol.for(`effect/SchemaId/Trimmed`),wk=e=>t=>t.pipe($(e=>e===e.trim(),{schemaId:Ck,title:`trimmed`,description:`a string with no leading or trailing whitespace`,jsonSchema:{pattern:`^\\S[\\s\\S]*\\S$|^\\S$|^$`},...e})),Tk=iT,Ek=(e,t)=>n=>n.pipe($(t=>t.length<=e,{schemaId:Tk,title:`maxLength(${e})`,description:`a string at most ${e} character(s) long`,jsonSchema:{maxLength:e},...t})),Dk=rT,Ok=(e,t)=>n=>n.pipe($(t=>t.length>=e,{schemaId:Dk,title:`minLength(${e})`,description:`a string at least ${e} character(s) long`,jsonSchema:{minLength:e},...t})),kk=aT,Ak=(e,t)=>n=>{let r=le(e)?Math.max(0,Math.floor(e.min)):Math.max(0,Math.floor(e)),i=le(e)?Math.max(r,Math.floor(e.max)):r;return r===i?n.pipe($(e=>e.length===r,{schemaId:kk,title:`length(${r})`,description:r===1?`a single character`:`a string ${r} character(s) long`,jsonSchema:{minLength:r,maxLength:r},...t})):n.pipe($(e=>e.length>=r&&e.length<=i,{schemaId:kk,title:`length({ min: ${r}, max: ${i})`,description:`a string at least ${r} character(s) and at most ${i} character(s) long`,jsonSchema:{minLength:r,maxLength:i},...t}))},jk=Symbol.for(`effect/SchemaId/Pattern`),Mk=(e,t)=>n=>{let r=e.source;return n.pipe($(t=>(e.lastIndex=0,e.test(t)),{schemaId:jk,[jk]:{regex:e},description:`a string matching the pattern ${r}`,jsonSchema:{pattern:r},...t}))},Nk=Symbol.for(`effect/SchemaId/Lowercased`),Pk=e=>t=>t.pipe($(e=>e===e.toLowerCase(),{schemaId:Nk,title:`lowercased`,description:`a lowercase string`,jsonSchema:{pattern:`^[^A-Z]*$`},...e}));var Fk=class extends Z.pipe(Pk({identifier:`Lowercased`})){};const Ik=Symbol.for(`effect/SchemaId/Uppercased`),Lk=e=>t=>t.pipe($(e=>e===e.toUpperCase(),{schemaId:Ik,title:`uppercased`,description:`an uppercase string`,jsonSchema:{pattern:`^[^a-z]*$`},...e}));var Rk=class extends Z.pipe(Lk({identifier:`Uppercased`})){};const zk=Symbol.for(`effect/SchemaId/Capitalized`),Bk=e=>t=>t.pipe($(e=>e[0]?.toUpperCase()===e[0],{schemaId:zk,title:`capitalized`,description:`a capitalized string`,jsonSchema:{pattern:`^[^a-z]?.*$`},...e}));var Vk=class extends Z.pipe(Bk({identifier:`Capitalized`})){};const Hk=Symbol.for(`effect/SchemaId/Uncapitalized`),Uk=e=>t=>t.pipe($(e=>e[0]?.toLowerCase()===e[0],{schemaId:Hk,title:`uncapitalized`,description:`a uncapitalized string`,jsonSchema:{pattern:`^[^A-Z]?.*$`},...e}));var Wk=class extends Z.pipe(Uk({identifier:`Uncapitalized`})){};Z.pipe(Ak(1,{identifier:`Char`}));const Gk=e=>Ok(1,{title:`nonEmptyString`,description:`a non empty string`,...e});Sk(Z.annotations({description:`a string that will be converted to lowercase`}),Fk,{strict:!0,decode:e=>e.toLowerCase(),encode:n}).annotations({identifier:`Lowercase`}),Sk(Z.annotations({description:`a string that will be converted to uppercase`}),Rk,{strict:!0,decode:e=>e.toUpperCase(),encode:n}).annotations({identifier:`Uppercase`}),Sk(Z.annotations({description:`a string that will be converted to a capitalized format`}),Vk,{strict:!0,decode:e=>JC(e),encode:n}).annotations({identifier:`Capitalize`}),Sk(Z.annotations({description:`a string that will be converted to an uncapitalized format`}),Wk,{strict:!0,decode:e=>YC(e),encode:n}).annotations({identifier:`Uncapitalize`});var Kk=class extends Z.pipe(wk({identifier:`Trimmed`})){},qk=class extends Kk.pipe(Gk({identifier:`NonEmptyTrimmedString`})){};Sk(Z.annotations({description:`a string that will be trimmed`}),Kk,{strict:!0,decode:e=>e.trim(),encode:n}).annotations({identifier:`Trim`});const Jk=e=>e instanceof Error?e.message:String(e);Z.pipe(Gk({identifier:`NonEmptyString`}));const Yk=Symbol.for(`effect/SchemaId/UUID`),Xk=/^[0-9a-fA-F]{8}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{12}$/i;Z.pipe(Mk(Xk,{schemaId:Yk,identifier:`UUID`,jsonSchema:{format:`uuid`,pattern:Xk.source},description:`a Universally Unique Identifier`,arbitrary:()=>e=>e.uuid()}));const Zk=Symbol.for(`effect/SchemaId/ULID`);Z.pipe(Mk(/^[0-7][0-9A-HJKMNP-TV-Z]{25}$/i,{schemaId:Zk,identifier:`ULID`,description:`a Universally Unique Lexicographically Sortable Identifier`,arbitrary:()=>e=>e.ulid()}));var Qk=class extends AO(URL,{typeConstructor:{_tag:`URL`},identifier:`URLFromSelf`,arbitrary:()=>e=>e.webUrl().map(e=>new URL(e)),pretty:()=>e=>e.toString()}){};xk(Z.annotations({description:`a string to be decoded into a URL`}),Qk,{strict:!0,decode:(e,t,n)=>pD({try:()=>new URL(e),catch:t=>new J(n,e,`Unable to decode ${JSON.stringify(e)} into a URL. ${Jk(t)}`)}),encode:e=>Y(e.toString())}).annotations({identifier:`URL`,pretty:()=>e=>e.toString()});const $k=Qw,eA=e=>t=>t.pipe($(Number.isFinite,{schemaId:$k,title:`finite`,description:`a finite number`,jsonSchema:{},...e})),tA=Kw,nA=(e,t)=>n=>n.pipe($(t=>t>e,{schemaId:tA,title:`greaterThan(${e})`,description:e===0?`a positive number`:`a number greater than ${e}`,jsonSchema:{exclusiveMinimum:e},...t})),rA=qw,iA=(e,t)=>n=>n.pipe($(t=>t>=e,{schemaId:rA,title:`greaterThanOrEqualTo(${e})`,description:e===0?`a non-negative number`:`a number greater than or equal to ${e}`,jsonSchema:{minimum:e},...t})),aA=Xw,oA=e=>t=>t.pipe($(e=>Number.isSafeInteger(e),{schemaId:aA,title:`int`,description:`an integer`,jsonSchema:{type:`integer`},...e})),sA=Jw,cA=(e,t)=>n=>n.pipe($(t=>t<e,{schemaId:sA,title:`lessThan(${e})`,description:e===0?`a negative number`:`a number less than ${e}`,jsonSchema:{exclusiveMaximum:e},...t})),lA=Yw,uA=(e,t)=>n=>n.pipe($(t=>t<=e,{schemaId:lA,title:`lessThanOrEqualTo(${e})`,description:e===0?`a non-positive number`:`a number less than or equal to ${e}`,jsonSchema:{maximum:e},...t})),dA=eT,fA=(e,t,n)=>r=>r.pipe($(n=>n>=e&&n<=t,{schemaId:dA,title:`between(${e}, ${t})`,description:`a number between ${e} and ${t}`,jsonSchema:{minimum:e,maximum:t},...n})),pA=Zw,mA=e=>t=>t.pipe($(e=>!Number.isNaN(e),{schemaId:pA,title:`nonNaN`,description:`a number excluding NaN`,...e})),hA=e=>nA(0,{title:`positive`,...e}),gA=e=>cA(0,{title:`negative`,...e}),_A=e=>uA(0,{title:`nonPositive`,...e}),vA=e=>iA(0,{title:`nonNegative`,...e});function yA(e){return xk(e,Q,{strict:!1,decode:(e,t,n)=>mD(Cm(e),()=>new J(n,e,`Unable to decode ${JSON.stringify(e)} into a number`)),encode:e=>Y(String(e))})}yA(Z.annotations({description:`a string to be decoded into a number`})).annotations({identifier:`NumberFromString`}),Q.pipe(eA({identifier:`Finite`}));var bA=class extends Q.pipe(oA({identifier:`Int`})){};Q.pipe(mA({identifier:`NonNaN`})),Q.pipe(hA({identifier:`Positive`})),Q.pipe(gA({identifier:`Negative`})),Q.pipe(_A({identifier:`NonPositive`}));var xA=class extends Q.pipe(vA({identifier:`NonNegative`})){};const SA=$w;Q.pipe(eA({schemaId:SA,identifier:`JsonNumber`})),Sk(IO.annotations({description:`a boolean that will be negated`}),IO,{strict:!0,decode:e=>Wr(e),encode:e=>Wr(e)});const CA=(e,t)=>{let n=Symbol.keyFor(e);return n===void 0?fD(new J(t,e,`Unable to encode a unique symbol ${String(e)} into a string`)):Y(n)},wA=e=>Y(Symbol.for(e));xk(Z.annotations({description:`a string to be decoded into a globally shared symbol`}),FO,{strict:!1,decode:e=>wA(e),encode:(e,t,n)=>CA(e,n)}).annotations({identifier:`Symbol`});const TA=tT,EA=(e,t)=>n=>n.pipe($(t=>t>=e,{schemaId:TA,[TA]:{min:e},title:`greaterThanOrEqualToBigInt(${e})`,description:e===0n?`a non-negative bigint`:`a bigint greater than or equal to ${e}n`,...t})),DA=nT,OA=(e,t,n)=>r=>r.pipe($(n=>n>=e&&n<=t,{schemaId:DA,[DA]:{min:e,max:t},title:`betweenBigInt(${e}, ${t})`,description:`a bigint between ${e}n and ${t}n`,...n})),kA=e=>EA(0n,{title:`nonNegativeBigInt`,...e});var AA=class extends xk(Z.annotations({description:`a string to be decoded into a bigint`}),PO,{strict:!0,decode:(e,t,n)=>mD(Hr(e),()=>new J(n,e,`Unable to decode ${JSON.stringify(e)} into a bigint`)),encode:e=>Y(String(e))}).annotations({identifier:`BigInt`}){};const jA=PO.pipe(kA({identifier:`NonNegativeBigintFromSelf`}));xk(Q.annotations({description:`a number to be decoded into a bigint`}),PO.pipe(OA(BigInt(-(2**53-1)),BigInt(2**53-1))),{strict:!0,decode:(e,t,n)=>mD(Ur(e),()=>new J(n,e,`Unable to decode ${e} into a bigint`)),encode:(e,t,n)=>mD(Vr(e),()=>new J(n,e,`Unable to encode ${e}n into a number`))}).annotations({identifier:`BigIntFromNumber`});const MA=(e,t,n,r)=>yD(e,{onFailure:e=>new q(n,r,e),onSuccess:t});var NA=class extends OO(Bs,{typeConstructor:{_tag:`effect/Duration`},identifier:`DurationFromSelf`,pretty:()=>String,arbitrary:()=>e=>e.oneof(e.constant(Ws),e.bigInt({min:0n}).map(e=>Gs(e)),e.maxSafeNat().map(e=>qs(e))),equivalence:()=>ac}){};xk(jA.annotations({description:`a bigint to be decoded into a Duration`}),NA.pipe($(e=>Vs(e),{description:`a finite duration`})),{strict:!0,decode:e=>Y(Gs(e)),encode:(e,t,n)=>dn(ec(e),{onNone:()=>fD(new J(n,e,`Unable to encode ${e} into a bigint`)),onSome:e=>Y(e)})}).annotations({identifier:`DurationFromNanos`});const PA=xA.pipe(oA()).annotations({identifier:`NonNegativeInt`});Sk(xA.annotations({description:`a non-negative number to be decoded into a Duration`}),NA,{strict:!0,decode:e=>qs(e),encode:e=>$s(e)}).annotations({identifier:`DurationFromMillis`});const FA=pk(`Millis`,{millis:PA}),IA=pk(`Nanos`,{nanos:AA}),LA=pk(`Infinity`,{}),RA=LA.make({}),zA=zO(FA,IA,LA).annotations({identifier:`DurationValue`,description:`an JSON-compatible tagged union to be decoded into a Duration`}),BA=zO(GO(VO(PA).annotations({title:`seconds`}),VO(PA).annotations({title:`nanos`})).annotations({identifier:`FiniteHRTime`}),GO(wO(-1),wO(0)).annotations({identifier:`InfiniteHRTime`})).annotations({identifier:`HRTime`,description:`a tuple of seconds and nanos to be decoded into a Duration`}),VA=e=>typeof e==`object`;Sk(zO(zA,BA),NA,{strict:!0,decode:e=>{if(VA(e))switch(e._tag){case`Millis`:return qs(e.millis);case`Nanos`:return Gs(e.nanos);case`Infinity`:return Ws}let[t,n]=e;return t===-1?Ws:Gs(BigInt(t)*BigInt(1e9)+BigInt(n))},encode:e=>{switch(e.value._tag){case`Millis`:return FA.make({millis:e.value.millis});case`Nanos`:return IA.make({nanos:e.value.nanos});case`Infinity`:return RA}}}).annotations({identifier:`Duration`});var HA=class extends OO(pe,{typeConstructor:{_tag:`Uint8Array`},identifier:`Uint8ArrayFromSelf`,pretty:()=>e=>`new Uint8Array(${JSON.stringify(Array.from(e))})`,arbitrary:()=>e=>e.uint8Array(),equivalence:()=>hr(T)}){};Sk(qO(class extends Q.pipe(fA(0,255,{identifier:`Uint8`,description:`a 8-bit unsigned integer`})){}).annotations({description:`an array of 8-bit unsigned integers to be decoded into a Uint8Array`}),HA,{strict:!0,decode:e=>Uint8Array.from(e),encode:e=>Array.from(e)}).annotations({identifier:`Uint8Array`});const UA=Symbol.for(`effect/SchemaId/ValidDate`),WA=e=>t=>t.pipe($(e=>!Number.isNaN(e.getTime()),{schemaId:UA,[UA]:{noInvalidDate:!0},title:`validDate`,description:`a valid Date`,...e})),GA=Gw;var KA=class extends OO(me,{typeConstructor:{_tag:`Date`},identifier:`DateFromSelf`,schemaId:GA,[GA]:{noInvalidDate:!1},description:`a potentially invalid Date instance`,pretty:()=>e=>`new Date(${JSON.stringify(e)})`,arbitrary:()=>e=>e.date({noInvalidDate:!1}),equivalence:()=>f}){};KA.pipe(WA({identifier:`ValidDateFromSelf`,description:`a valid Date instance`})),class extends Sk(Z.annotations({description:`a string to be decoded into a Date`}),KA,{strict:!0,decode:e=>new Date(e),encode:e=>Ve(e)}).annotations({identifier:`DateFromString`}){}.pipe(WA({identifier:`Date`})),Sk(Q.annotations({description:`a number to be decoded into a Date`}),KA,{strict:!0,decode:e=>new Date(e),encode:e=>e.getTime()}).annotations({identifier:`DateFromNumber`});var qA=class extends OO(e=>pw(e)&&gw(e),{typeConstructor:{_tag:`effect/DateTime.Utc`},identifier:`DateTimeUtcFromSelf`,description:`a DateTime.Utc instance`,pretty:()=>e=>e.toString(),arbitrary:()=>e=>e.date({noInvalidDate:!0}).map(e=>yw(e)),equivalence:()=>vw}){};const JA=(e,t)=>pD({try:()=>bw(e),catch:()=>new J(t,e,`Unable to decode ${We(e)} into a DateTime.Utc`)});xk(Q.annotations({description:`a number to be decoded into a DateTime.Utc`}),qA,{strict:!0,decode:(e,t,n)=>JA(e,n),encode:e=>Y(Ow(e))}).annotations({identifier:`DateTimeUtcFromNumber`}),xk(KA.annotations({description:`a Date to be decoded into a DateTime.Utc`}),qA,{strict:!0,decode:(e,t,n)=>JA(e,n),encode:e=>Y(Dw(e))}).annotations({identifier:`DateTimeUtcFromDate`}),xk(Z.annotations({description:`a string to be decoded into a DateTime.Utc`}),qA,{strict:!0,decode:(e,t,n)=>JA(e,n),encode:e=>Y(kw(e))}).annotations({identifier:`DateTimeUtc`});const YA=()=>e=>e.integer({min:-720*60*1e3,max:840*60*1e3}).map(ww);var XA=class extends OO(mw,{typeConstructor:{_tag:`effect/DateTime.TimeZone.Offset`},identifier:`TimeZoneOffsetFromSelf`,description:`a TimeZone.Offset instance`,pretty:()=>e=>e.toString(),arbitrary:YA}){};Sk(Q.annotations({description:`a number to be decoded into a TimeZone.Offset`}),XA,{strict:!0,decode:e=>ww(e),encode:e=>e.offset}).annotations({identifier:`TimeZoneOffset`});const ZA=()=>e=>e.constantFrom(...Intl.supportedValuesOf(`timeZone`)).map(Cw);var QA=class extends OO(hw,{typeConstructor:{_tag:`effect/DateTime.TimeZone.Named`},identifier:`TimeZoneNamedFromSelf`,description:`a TimeZone.Named instance`,pretty:()=>e=>e.toString(),arbitrary:ZA}){};xk(Z.annotations({description:`a string to be decoded into a TimeZone.Named`}),QA,{strict:!0,decode:(e,t,n)=>pD({try:()=>Cw(e),catch:()=>new J(n,e,`Unable to decode ${JSON.stringify(e)} into a TimeZone.Named`)}),encode:e=>Y(e.id)}).annotations({identifier:`TimeZoneNamed`});var $A=class extends zO(XA,QA){};xk(Z.annotations({description:`a string to be decoded into a TimeZone`}),$A,{strict:!0,decode:(e,t,n)=>dn(Tw(e),{onNone:()=>fD(new J(n,e,`Unable to decode ${JSON.stringify(e)} into a TimeZone`)),onSome:Y}),encode:e=>Y(Ew(e))}).annotations({identifier:`TimeZone`});const ej=e=>e.oneof(YA()(e),ZA()(e));var tj=class extends OO(e=>pw(e)&&_w(e),{typeConstructor:{_tag:`effect/DateTime.Zoned`},identifier:`DateTimeZonedFromSelf`,description:`a DateTime.Zoned instance`,pretty:()=>e=>e.toString(),arbitrary:()=>e=>e.tuple(e.integer({min:-31536e9,max:31536e9}),ej(e)).map(([e,t])=>xw(e,{timeZone:t})),equivalence:()=>vw}){};xk(Z.annotations({description:`a string to be decoded into a DateTime.Zoned`}),tj,{strict:!0,decode:(e,t,n)=>dn(Sw(e),{onNone:()=>fD(new J(n,e,`Unable to decode ${JSON.stringify(e)} into a DateTime.Zoned`)),onSome:Y}),encode:e=>Y(Aw(e))}).annotations({identifier:`DateTimeZoned`});const nj=e=>e._tag===`None`?j():M(e.value),rj=(e,t)=>n=>n.oneof(t,n.record({_tag:n.constant(`None`)}),n.record({_tag:n.constant(`Some`),value:e(n)})).map(nj),ij=e=>dn({onNone:()=>`none()`,onSome:t=>`some(${e(t)})`}),aj=e=>(t,n,r)=>un(t)?N(t)?Y(j()):MA(e(t.value,n),M,r,t):fD(new J(r,t)),oj=e=>OO([e],{decode:e=>aj(ED(e)),encode:e=>aj(DD(e))},{typeConstructor:{_tag:`effect/Option`},pretty:ij,arbitrary:rj,equivalence:wn});Sk(Z,(e=>oj(e).annotations({description:`Option<${yO(e)}>`}))(qk),{strict:!0,decode:e=>Cn(M(e.trim()),XC),encode:e=>F(e,()=>``)});const sj=()=>e=>`BigDecimal(${Ir(Or(e))})`,cj=()=>e=>e.tuple(e.bigInt(),e.integer({min:-18,max:18})).map(([e,t])=>Cr(e,t));var lj=class extends OO(Sr,{typeConstructor:{_tag:`effect/BigDecimal`},identifier:`BigDecimalFromSelf`,pretty:sj,arbitrary:cj,equivalence:()=>jr}){};xk(Z.annotations({description:`a string to be decoded into a BigDecimal`}),lj,{strict:!0,decode:(e,t,n)=>Fr(e).pipe(dn({onNone:()=>fD(new J(n,e,`Unable to decode ${JSON.stringify(e)} into a BigDecimal`)),onSome:e=>Y(Or(e))})),encode:e=>Y(Ir(Or(e)))}).annotations({identifier:`BigDecimal`}),Sk(Q.annotations({description:`a number to be decoded into a BigDecimal`}),lj,{strict:!0,decode:e=>Nr(e),encode:e=>Rr(e)}).annotations({identifier:`BigDecimalFromNumber`});function uj(e){return ne(e)?e:e?.disableValidation??!1}const dj=zO(dk({_tag:wO(`None`)}).annotations({identifier:`FiberIdNoneEncoded`}),dk({_tag:wO(`Runtime`),id:bA,startTimeMillis:bA}).annotations({identifier:`FiberIdRuntimeEncoded`}),dk({_tag:wO(`Composite`),left:hk(()=>dj),right:hk(()=>dj)}).annotations({identifier:`FiberIdCompositeEncoded`})).annotations({identifier:`FiberIdEncoded`}),fj=e=>e.letrec(t=>({None:e.record({_tag:e.constant(`None`)}),Runtime:e.record({_tag:e.constant(`Runtime`),id:e.integer(),startTimeMillis:e.integer()}),Composite:e.record({_tag:e.constant(`Composite`),left:t(`FiberId`),right:t(`FiberId`)}),FiberId:e.oneof(t(`None`),t(`Runtime`),t(`Composite`))})).FiberId.map(hj),pj=e=>{switch(e._tag){case`None`:return`FiberId.none`;case`Runtime`:return`FiberId.runtime(${e.id}, ${e.startTimeMillis})`;case`Composite`:return`FiberId.composite(${pj(e.right)}, ${pj(e.left)})`}};var mj=class extends OO(Rc,{typeConstructor:{_tag:`effect/FiberId`},identifier:`FiberIdFromSelf`,pretty:()=>pj,arbitrary:()=>fj}){};const hj=e=>{switch(e._tag){case`None`:return Fc;case`Runtime`:return Ic(e.id,e.startTimeMillis);case`Composite`:return Lc(hj(e.left),hj(e.right))}},gj=e=>{switch(e._tag){case`None`:return{_tag:`None`};case`Runtime`:return{_tag:`Runtime`,id:e.id,startTimeMillis:e.startTimeMillis};case`Composite`:return{_tag:`Composite`,left:gj(e.left),right:gj(e.right)}}};Sk(dj,mj,{strict:!0,decode:e=>hj(e),encode:e=>gj(e)}).annotations({identifier:`FiberId`}),Sk(NO,NO,{strict:!0,decode:e=>{if(le(e)&&`message`in e&&typeof e.message==`string`){let t=Error(e.message,{cause:e});return`name`in e&&typeof e.name==`string`&&(t.name=e.name),t.stack=`stack`in e&&typeof e.stack==`string`?e.stack:``,t}return Ro(e)},encode:e=>e instanceof Error?{name:e.name,message:e.message}:Ro(e)}).annotations({identifier:`Defect`}),Sk(NO,IO,{strict:!0,decode:e=>ee(e),encode:n}).annotations({identifier:`BooleanFromUnknown`}),Sk(wO(`true`,`false`).annotations({description:`a string to be decoded into a boolean`}),IO,{strict:!0,decode:e=>e===`true`,encode:e=>e?`true`:`false`}).annotations({identifier:`BooleanFromString`});const _j=pk(`symbol`,{key:Z}).annotations({description:`an object to be decoded into a globally shared symbol`}),vj=xk(_j,FO,{strict:!0,decode:e=>wA(e.key),encode:(e,t,n)=>_D(CA(e,n),e=>_j.make({key:e}))});var yj=class extends zO(Z,Q,vj).annotations({identifier:`PropertyKey`}){};dk({_tag:ak(wO(`Pointer`,`Unexpected`,`Missing`,`Composite`,`Refinement`,`Transformation`,`Type`,`Forbidden`)).annotations({description:`The tag identifying the type of parse issue`}),path:ak(qO(yj)).annotations({description:`The path to the property where the issue occurred`}),message:ak(Z).annotations({description:`A descriptive message explaining the issue`})}).annotations({identifier:`ArrayFormatterIssue`,description:`Represents an issue returned by the ArrayFormatter formatter`});const bj=dk({id:Q,created:AO(Date),title:Z.pipe(Ok(1),Ek(100)),type:wO(`jpg`,`png`),size:Q,url:Z.pipe($(e=>URL.canParse(e)))}),xj=dk({id:Q,stars:Q.pipe(iA(0),uA(5)),title:Z.pipe(Ok(1),Ek(100)),text:Z.pipe(Ok(1),Ek(1e3)),images:mk(qO(bj))});bO(dk({id:Q,created:AO(Date),title:Z.pipe(Ok(1),Ek(100)),brand:Z.pipe(Ok(1),Ek(30)),description:Z.pipe(Ok(1),Ek(500)),price:Q.pipe(iA(1),uA(1e4)),discount:BO(Q.pipe(iA(1),uA(100))),quantity:Q.pipe(iA(1),uA(10)),tags:mk(qO(Z.pipe(Ok(1),Ek(30)))),images:mk(qO(bj)),ratings:mk(qO(xj))}))({});