https://www.listening.com/assets/kvs-C_4L7zkd.js

1import{a as e,n as t,r as n}from"./jsx-runtime-D3jfb0Ew.js";import{$o as r,B as i,Bo as a,Ca as o,Ci as s,Ea as c,Ei as l,Er as u,Fa as d,Hn as f,Ho as ee,Ia as p,In as m,Jn as h,Jr as te,Kn as ne,Ko as re,La as g,Lr as _,Mn as v,Mo as y,Na as b,No as ie,Oi as x,On as S,Pa as C,Pi as ae,Po as oe,Ri as w,Si as se,So as ce,Sr as T,Ta as le,Ti as ue,Tr as E,U as de,Ua as fe,Ui as pe,Uo as D,Vo as me,W as he,Wa as ge,Wo as _e,Xa as ve,Xn as ye,Xr as be,Ya as xe,Zr as Se,_o as Ce,_r as we,as as Te,bi as Ee,bn as De,bo as O,br as Oe,cn as ke,co as Ae,cs as je,di as Me,dr as Ne,ei as Pe,fo as Fe,go as Ie,hn as Le,ho as Re,is as ze,ja as Be,li as Ve,ln as He,lo as Ue,lr as We,mn as Ge,mo as Ke,mr as qe,ni as Je,nr as Ye,oi as Xe,q as Ze,qo as Qe,ri as $e,rs as k,si as et,sr as tt,ss as nt,ts as rt,vo as A,vr as it,wa as at,wr as ot,xi as st,xn as j,yn as ct,zr as lt}from"./Schema-CAUmIdFq.js";import{Bt as ut,It as dt,Jt as ft,Kt as pt,Lt as mt,Pt as ht,Rt as gt,Ut as _t,Vt as vt,Zt as yt,cn as bt,dn as xt,ln as St,mn as Ct,on as wt,zt as Tt}from"./api-contract-BBRQu6_I.js";import{a as Et,n as Dt,o as Ot}from"./Fiber-B24_yXY7.js";var kt=`~effect/MutableHashMap`,At={[kt]:kt,[Symbol.iterator](){return this.backing[Symbol.iterator]()},toString(){return`MutableHashMap(${oe(Array.from(this))})`},toJSON(){return{_id:`MutableHashMap`,values:ie(Array.from(this))}},[y](){return this.toJSON()},pipe(){return je(this,arguments)}},jt=()=>{let e=Object.create(At);return e.backing=new Map,e.buckets=new Map,e},Mt=k(2,(e,t)=>{if(e.backing.has(t))return O(e.backing.get(t));if(Nt(t))return A();let n=M.get(e);if(n!==void 0)return e.backing.has(n)?O(e.backing.get(n)):A();let r=D(t),i=e.buckets.get(r);return i===void 0?A():Pt(e,i,t)}),M=new WeakMap,Nt=e=>typeof e!=`object`&&typeof e!=`function`,Pt=(e,t,n)=>{for(let r=0,i=t.length;r<i;r++)if(a(n,t[r])){let i=t[r];return M.set(n,i),O(e.backing.get(i))}return A()},Ft=k(3,(e,t,n)=>{if(e.backing.has(t)||Nt(t))return e.backing.set(t,n),e;let r=M.get(e);if(r!==void 0&&e.backing.has(r))return e.backing.set(r,n),e;let i=D(t),a=e.buckets.get(i);return a===void 0?(e.buckets.set(i,[t]),e.backing.set(t,n),e):(r=It(a,t),r===void 0&&(a.push(t),r=t),e.backing.set(r,n),e)}),It=(e,t)=>{for(let n=0,r=e.length;n<r;n++)if(a(t,e[n]))return M.set(t,e[n]),e[n]},Lt=k(2,(e,t)=>{if(Nt(t))return e.backing.delete(t),e;let n=M.get(e)??t,r=D(n),i=e.buckets.get(r);if(i===void 0)return e;for(let t=0,r=i.length;t<r;t++){let r=i[t];if(r===n||a(n,r)){e.backing.delete(r),i.splice(t,1);break}}return i.length===0&&e.buckets.delete(r),e}),Rt=`~effect/reactivity/Reactivity`,N=b(`effect/reactivity/Reactivity`),zt=E(()=>{let e=new Map,t=t=>{Gt(t,t=>{let n=e.get(t);n!==void 0&&n.forEach(e=>e())})},n=e=>Le(n=>{let r=g(n,Bt);return r?Gt(e,e=>{r.add(e)}):t(e),_}),r=(e,t)=>u(t,n(e)),i=(t,n)=>{let r=[];return Gt(t,t=>{r.push(t);let i=e.get(t);i===void 0&&(i=new Set,e.set(t,i)),i.add(n)}),()=>{for(let t=0;t<r.length;t++){let i=e.get(r[t]);i!==void 0&&(i.delete(n),i.size===0&&e.delete(r[t]))}}},a=(e,t)=>v(function*(){let n=yield*Ge(),r=p(n,Xe),a=yield*St(),o=ze(We(n),Ot(r)),s=!1,c=!1,l=e=>{e._tag===`Failure`?bt(a,e.cause):xt(a,e.value),c?(c=!1,o(t).addObserver(l)):s=!1};function u(){if(s){c=!0;return}s=!0,o(t).addObserver(l)}let d=i(e,u);return yield*et(r,E(d)),u(),a}),o=(e,t)=>a(e,t).pipe(f(ut),yt),s=t=>ot(()=>{let n=new Set;return t.pipe(Ye(Bt,n),ye(t=>E(()=>{n.forEach(t=>{let n=e.get(t);n!==void 0&&n.forEach(e=>e())})})))});return N.of({[Rt]:Rt,mutation:r,query:a,stream:o,invalidateUnsafe:t,invalidate:n,registerUnsafe:i,withBatch:s})}),Bt=class extends b()(`effect/reactivity/Reactivity/PendingInvalidation`){},Vt=k(2,(e,t)=>N.use(n=>n.mutation(t,e))),Ht=e=>N.use(t=>t.invalidate(e)),Ut=Se(N)(zt);function Wt(e){switch(typeof e){case`string`:case`number`:case`bigint`:case`boolean`:return String(e);default:return D(e)}}var Gt=(e,t)=>{if(Array.isArray(e)){for(let n=0;n<e.length;n++)t(Wt(e[n]));return}for(let n in e){t(n);let r=e[n];for(let e=0;e<r.length;e++)t(`${n}:${Wt(r[e])}`)}},Kt=`~effect/SubscriptionRef`,P=e=>Qe(e,Kt);({...ce});var qt=e=>Tt(e.pubsub),Jt=e=>E(()=>e.value),Yt=(e,t)=>{e.value=t,Ct(e.pubsub,t)},Xt=k(2,(e,t)=>e.semaphore.withPermit(E(()=>Yt(e,t)))),F={"~effect/reactivity/AsyncResult":{E:Te,A:Te},pipe(){return je(this,arguments)},[me](e){if(this._tag!==e._tag||this.waiting!==e.waiting)return!1;switch(this._tag){case`Initial`:return!0;case`Success`:return a(this.value,e.value);case`Failure`:return a(this.cause,e.cause)}},[re](){let e=_e(`${this._tag}:${this.waiting}`);return this._tag===`Initial`?e:ee(e)(this._tag===`Success`?D(this.value):D(this.cause))}},Zt=(e,t)=>

1e._tag===`Success`?R(e.value):z(e.cause,{previous:t}),Qt=e=>e._tag===`None`?I(!0):B(e.value),$t=e=>e._tag!==`Initial`,I=(e=!1)=>{let t=Object.create(F);return t._tag=`Initial`,t.waiting=e,t},L=e=>e._tag===`Success`,R=(e,t)=>{let n=Object.create(F);return n._tag=`Success`,n.value=e,n.waiting=t?.waiting??!1,n.timestamp=t?.timestamp??Date.now(),n},en=e=>e._tag===`Failure`,tn=(e,t)=>{let n=Object.create(F);return n._tag=`Failure`,n.cause=e,n.previousSuccess=t?.previousSuccess??A(),n.waiting=t?.waiting??!1,n},z=(e,t)=>tn(e,{previousSuccess:Ae(t.previous,e=>L(e)?O(e):en(e)?e.previousSuccess:A()),waiting:t.waiting}),nn=(e,t)=>z(ae(e),t),B=(e,t)=>{if(e.waiting)return t?.touch?rn(e):e;let n=Object.assign(Object.create(F),e);return n.waiting=!0,t?.touch&&L(n)&&(n.timestamp=Date.now()),n},rn=e=>L(e)?R(e.value,{waiting:e.waiting}):e,V=(e,t)=>e._tag===`Failure`?z(e.cause,{previous:t,waiting:e.waiting}):e,an=e=>e._tag===`Success`?O(e.value):e._tag===`Failure`?Ie(e.previousSuccess,e=>e.value):A(),on=e=>Fe(an(e),()=>new x(`AsyncResult.getOrThrow: no value found`)),H=e=>{switch(e._tag){case`Success`:return ue(e.value);case`Failure`:return st(e.cause);default:return Ee(new x)}},U=`~effect/reactivity/AtomRegistry`,sn=e=>Qe(e,U),cn=e=>new mn(e?.initialValues,e?.scheduleTask,e?.timeoutResolution,e?.defaultIdleTTL),ln=b(U),un=k(e=>sn(e[0]),(e,t,n)=>{let r=n?.suspendOnWaiting??!1;return ke(n=>{let i=e.get(t);if(i._tag!==`Initial`&&!(r&&i.waiting))return n(H(i));let a=e.subscribe(t,e=>{e._tag!==`Initial`&&!(r&&e.waiting)&&(n(H(e)),a())});return E(a)})}),dn={immediate:!0},fn=e=>{e()},pn=`~effect-atom/atom/Atom/Serializable`,W=e=>pn in e?e[pn].key:e,mn=class{[U];timeoutResolution;defaultIdleTTL;scheduler;schedulerAsync;dispatcher;onNodeAdded;onNodeRemoved;constructor(e,t,n,r){if(this[U]=U,this.scheduler=new o(`sync`,t),this.schedulerAsync=new o(`async`,t),this.dispatcher=this.schedulerAsync.makeDispatcher(),this.defaultIdleTTL=r,this.timeoutResolution=n===void 0&&r!==void 0?Math.round(r/2):n??1e3,e!==void 0)for(let[t,n]of e){let e=t;for(;e.initialValueTarget;)e=e.initialValueTarget;this.ensureNode(e).setInitialValue(n)}}nodes=new Map;preloadedSerializable=new Map;timeoutBuckets=new Map;nodeTimeoutBucket=new Map;disposed=!1;getNodes(){return this.nodes}get(e){return this.ensureNode(e).value()}set(e,t){e.write(this.ensureNode(e).writeContext,t)}setSerializable(e,t){this.preloadedSerializable.set(e,t)}modify(e,t){let n=this.ensureNode(e),r=t(n.value());return e.write(n.writeContext,r[1]),r[0]}update(e,t){let n=this.ensureNode(e);e.write(n.writeContext,t(n.value()))}refresh=e=>{e.refresh===void 0?this.invalidateAtom(e):e.refresh(this.refresh)};subscribe(e,t,n){let r=this.ensureNode(e);n?.immediate&&t(r.value());let i=r.subscribe(function(){t(r._value)});return()=>{i(),r.canBeRemoved&&this.scheduleNodeRemoval(r)}}mount(e){return this.subscribe(e,rt,dn)}atomHasTtl(e){return!e.keepAlive&&e.idleTTL!==0&&(e.idleTTL!==void 0||this.defaultIdleTTL!==void 0)}ensureNode(e){let t=W(e),n=this.nodes.get(t);if(n===void 0?(n=this.createNode(e),this.nodes.set(t,n),this.onNodeAdded?.(n)):this.atomHasTtl(e)&&this.removeNodeTimeout(n),typeof t==`string`&&this.preloadedSerializable.has(t)){let r=this.preloadedSerializable.get(t);this.preloadedSerializable.delete(t);let i=e[pn].decode(r),a=e;for(;a.initialValueTarget;)a=a.initialValueTarget;a===e?n.setValue(i):this.ensureNode(a).setInitialValue(i)}return n}createNode(e){if(this.disposed)throw Error(`Cannot access Atom ${e}: registry is disposed`);return e.keepAlive||this.scheduleAtomRemoval(e),new hn(this,e)}invalidateAtom=e=>{this.ensureNode(e).invalidate()};scheduleAtomRemoval(e){this.dispatcher.scheduleTask(()=>{let t=this.nodes.get(W(e));t!==void 0&&t.canBeRemoved&&this.removeNode(t)},0)}scheduleNodeRemoval(e){this.dispatcher.scheduleTask(()=>{e.canBeRemoved&&this.removeNode(e)},0)}removeNode(e){this.atomHasTtl(e.atom)?this.setNodeTimeout(e):(this.nodes.delete(W(e.atom)),e.remove(),this.onNodeRemoved?.(e))}setNodeTimeout(e){if(this.nodeTimeoutBucket.has(e))return;let t=e.atom.idleTTL??this.defaultIdleTTL;if(this.#e!==null&&(t-=this.#e,t<=0)){this.nodes.delete(W(e.atom)),e.remove(),this.onNodeRemoved?.(e);return}let n=Math.ceil(t/this.timeoutResolution)*this.timeoutResolution,r=Date.now()+n,i=r-r%this.timeoutResolution+this.timeoutResolution,a=this.timeoutBuckets.get(i);a===void 0&&(a=[new Set,setTimeout(()=>this.sweepBucket(i),i-Date.now())],this.timeoutBuckets.set(i,a)),a[0].add(e),this.nodeTimeoutBucket.set(e,i)}removeNodeTimeout(e){let t=this.nodeTimeoutBucket.get(e);if(t===void 0)return;this.nodeTimeoutBucket.delete(e),this.scheduleNodeRemoval(e);let[n,r]=this.timeoutBuckets.get(t);n.delete(e),n.size===0&&(clearTimeout(r),this.timeoutBuckets.delete(t))}#e=null;sweepBucket(e){let t=this.timeoutBuckets.get(e)[0];

1this.timeoutBuckets.delete(e),t.forEach(e=>{this.nodeTimeoutBucket.delete(e),e.canBeRemoved&&(this.nodes.delete(W(e.atom)),this.onNodeRemoved?.(e),this.#e=e.atom.idleTTL??this.defaultIdleTTL,e.remove(),this.#e=null)})}reset(){this.timeoutBuckets.forEach(([,e])=>clearTimeout(e)),this.timeoutBuckets.clear(),this.nodeTimeoutBucket.clear(),this.nodes.forEach(e=>{e.remove(),this.onNodeRemoved?.(e)}),this.nodes.clear()}dispose(){this.disposed=!0,this.reset()}},G={alive:1,initialized:2,waitingForValue:4},K={uninitialized:G.alive|G.waitingForValue,stale:G.alive|G.initialized|G.waitingForValue,valid:G.alive|G.initialized,removed:0},hn=class{constructor(e,t){this.registry=e,this.atom=t,this.writeContext=new yn(e,this)}registry;atom;state=K.uninitialized;lifetime;writeContext;preserveInitialValueOnBuild=!1;parents=new Set;previousParents;children=new Set;listeners=new Set;skipInvalidation=!1;building=!1;invalidatedDuringBuild=!1;currentState(){switch(this.state){case K.uninitialized:return`uninitialized`;case K.stale:return`stale`;case K.valid:return`valid`;default:return`removed`}}get canBeRemoved(){return!this.atom.keepAlive&&this.listeners.size===0&&this.children.size===0&&this.state!==0}_value=void 0;value(){if((this.state&G.waitingForValue)!==0){this.lifetime=vn(this),this.building=!0;let e=this.atom.read(this.lifetime);if(this.building=!1,(this.state&G.waitingForValue)!==0&&(this.preserveInitialValueOnBuild?(this.preserveInitialValueOnBuild=!1,this.state=K.valid):this.setValue(e)),this.previousParents){let e=this.previousParents;this.previousParents=void 0;for(let t of e)t.removeChild(this),t.canBeRemoved&&this.registry.scheduleNodeRemoval(t)}}return this._value}valueOption(){return(this.state&G.initialized)===0?A():O(this._value)}setInitialValue(e){if((this.state&G.initialized)===0){this.preserveInitialValueOnBuild=!0,this.state=K.stale,this._value=e,J.phase===q.collect?J.notify.add(this):this.notify();return}this.setValue(e)}setValue(e){if((this.state&G.initialized)===0){this.state=K.valid,this._value=e,J.phase===q.collect?J.notify.add(this):this.notify();return}this.state=K.valid,!this.atom.equals(this._value,e)&&(this._value=e,this.skipInvalidation?this.skipInvalidation=!1:this.invalidateChildren(),this.listeners.size>0&&(J.phase===q.collect?J.notify.add(this):this.notify()))}addParent(e){this.parents.add(e),this.previousParents!==void 0&&(this.previousParents.delete(e),this.previousParents.size===0&&(this.previousParents=void 0)),e.children.has(this)||(e.children.add(this),e.skipInvalidation&&=!1)}removeChild(e){this.children.delete(e)}invalidate(){this.building&&J.phase===q.collect&&(this.invalidatedDuringBuild=!0),this.state===K.valid&&(this.state=K.stale,this.disposeLifetime()),J.phase===q.collect?J.stale.push(this):this.atom.lazy&&this.listeners.size===0&&!gn(this.children)?(this.invalidateChildren(),this.skipInvalidation=!0):this.value()}invalidateChildren(){if(this.children.size===0)return;let e=this.children;this.children=new Set;for(let t of e)t.invalidate()}notify(){this.listeners.forEach(fn),J.phase===q.commit&&J.notify.delete(this)}disposeLifetime(){this.lifetime!==void 0&&(this.lifetime.dispose(),this.lifetime=void 0),this.parents.size!==0&&(this.previousParents=this.parents,this.parents=new Set)}remove(){if(this.state=K.removed,this.listeners.clear(),this.lifetime!==void 0&&this.disposeLifetime(),this.previousParents===void 0)return;let e=this.previousParents;this.previousParents=void 0;for(let t of e)t.removeChild(this),t.canBeRemoved&&this.registry.removeNode(t)}subscribe(e){return this.listeners.add(e),()=>this.listeners.delete(e)}};function gn(e){if(e.size===0)return!1;let t=e,n,r=0;for(;t!==void 0;){for(let e of t)if(!e.atom.lazy||e.listeners.size>0)return!0;else e.children.size>0&&(n===void 0?n=[e.children]:n.push(e.children));t=n?.[r++]}return!1}var _n={get registry(){return this.node.registry},addFinalizer(e){if(this.disposed)return e();this.finalizers??=[],this.finalizers.push(e)},get(e){if(this.disposed)return this.node.registry.get(e);let t=this.node.registry.ensureNode(e),n=t.value();return this.node.addParent(t),n},result(e,t){if(this.disposed||this.isFn)return this.resultOnce(e,t);let n=this.get(e);if(t?.suspendOnWaiting&&n.waiting)return h;switch(n._tag){case`Initial`:return h;case`Failure`:return st(n.cause);case`Success`:return T(n.value)}},resultOnce(e,t){return ke(n=>{let r=this.once(e);if(r._tag!==`Initial`&&!(t?.suspendOnWaiting&&r.waiting))return n(H(r));let i=this.node.registry.subscribe(e,e=>{e._tag===`Initial`||t?.suspendOnWaiting&&e.waiting||(i(),n(H(e)))},{immediate:!1});return E(i)})},setResult(e,t){return this.disposed?h:(this.node.registry.set(e,t),this.resultOnce(e,{suspendOnWaiting:!0}))},some(e){if(this.disposed||this.isFn)return this.someOnce(e);let t=this.get(e);return t._tag===`None`?h:T(t.value)},someOnce(e){return ke(t=>{let n=this.once(e);if(Re(n))return t(T(n.value));let r=this.node.registry.subscribe(e,e=>{Ke(e)||(r(),t(T(e.value)))},{immediate:!1});return E(r)})},once(e){return this.node.registry.get(e)},self(){return this.disposed?A():this.node.valueOption()},refresh(e){this.disposed||this.node.registry.refresh(e)},refreshSelf(){this.disposed||this.node.invalidate()},mount(e){this.disposed||this.addFinalizer(this.node.registry.mount(e))},subscribe(e,t,n){this.disposed||this.addFinalizer(this.node.registry.subscribe(e,t,n))},setSelf(e){this.disposed||this.node.setValue(e)},set(e,t){this.disposed||this.node.registry.set(e,t)},stream(e,t){return this.disposed?dt:ht(n=>E(()=>{this.subscribe(e,e=>xt(n,e),{immediate:!t?.withoutInitialValue})}))},streamResult(e,t){return this.stream(e,t).pipe(gt($t),_t(e=>e._tag===`Success`?T(e.value):De(e.cause)))},dispose(){if(this.disposed=!0,this.finalizers===void 0)return;let e=this.finalizers;this.finalizers=void 0;for(let t=e.length-1;t>=0;t--)e[t]()}},vn=e=>{function t(n){if(t.disposed||t.isFn)return e.registry.get(n);let r=e.registry.ensureNode(n),i=r.value();return e.addParent(r),i}return Object.setPrototypeOf(t,_n),t.isFn=!1,t.disposed=!1,t.finalizers=void 0,t.node=e,t},yn=class{constructor(e,t){this.registry=e,this.node=t}registry;node;get(e){return this.registry.get(e)}set(e,t){return this.registry.set(e,t)}setSelf(e){return this.node.setValue(e)}refreshSelf(){return this.node.invalidate()}},q={disabled:0,collect:1,commit:2},J={phase:q.disabled,depth:0,stale:[],notify:new Set};function bn(e){J.phase=q.collect,J.depth++;try{if(e(),J.depth===1){for(let e=0;e<J.stale.length;e++)xn(J.stale[e]);J.phase=q.commit;for(let e of J.notify)e.notify();J.notify.clear()}}finally{J.depth--,J.depth===0&&(J.phase=q.disabled,J.stale=[])}}function xn(e){if(e.state===K.valid){if(!e.invalidatedDuringBuild)return;

1e.invalidatedDuringBuild=!1,e.state=K.stale,e.disposeLifetime()}for(let t of e.parents)t.state!==K.valid&&xn(t);e.state!==K.valid&&e.value()}var Sn=`~effect/reactivity/Atom`,Cn=e=>Qe(e,Sn),wn=`~effect/reactivity/Atom/Writable`,Y=k(2,(e,t)=>{let n=le(t),r=c(n);return Object.assign(Object.create(Object.getPrototypeOf(e)),{...e,keepAlive:!r,idleTTL:r?Be(n):void 0})})(0),Tn={[Sn]:Sn,equals:Object.is,...ce,toJSON(){return{_id:`Atom`,keepAlive:this.keepAlive,lazy:this.lazy,label:this.label}}},En={...Tn,atom(e,t){let n=Mn(e,t);return X(e=>{let t=e.self(),r=e(this);return r._tag===`Success`?n(e,r.value):V(r,t)})},fn(e,t){return arguments.length===0?(e,t)=>Dn(this,e,t):Dn(this,e,t)},pull(e,t){let n=Y(Fn(0));return Xn(n,X(r=>{let i=r.self(),a=r(this);return a._tag===`Success`?Ln(r,Yn(r,n,e,t),I(!0),a.value):V(a,i)}))},subscriptionRef(e){return Un(Y(X(t=>{let n=t.self(),r=t(this);if(r._tag!==`Success`)return V(r,n);let i=typeof e==`function`?e(t):e;return P(i)?i:Ln(t,i,I(!0),r.value)})),(e,t)=>Hn(e,t,on(e(this))))}},Dn=(e,t,n)=>{let[r,i,a]=Jn(n?.reactivityKeys?(e,r)=>{let i=t(e,r);return m(i)?Vt(i,n.reactivityKeys):mt(i,Ht(n.reactivityKeys))}:t,n);return Z(t=>{t.get(a);let n=t.self(),i=t.get(e);return i._tag===`Success`?r(t,i.value):V(i,n)},i)},On={...Tn,[wn]:wn},kn=e=>wn in e,X=(e,t)=>{let n=Object.create(Tn);return n.keepAlive=!1,n.lazy=!0,n.read=e,n.refresh=t,n},Z=(e,t,n)=>{let r=Object.create(On);return r.keepAlive=!1,r.lazy=!0,r.read=e,r.write=t,r.refresh=n,r};function An(e,t){e.setSelf(t)}var jn=(e,t)=>{let n=Mn(e,t);return`~effect/reactivity/Atom`in n?n:X(n)},Mn=(e,t)=>{if(typeof e==`function`&&!m(e)&&!vt(e)){let n=e;return function(e,r){let i=n(e);switch(typeof i){case`function`:case`object`:return i===null?i:Nn in i?In(e,i,t,r):Pn in i?Bn(e,i,t,r):i;default:return i}}}return m(e)?function(n,r){return In(n,e,t,r)}:vt(e)?function(n,r){return Bn(n,e,t,r)}:Fn(e)},Nn=`~effect/Effect`,Pn=`~effect/Stream`,Fn=e=>Z(function(t){return e},An),In=(e,t,n,r)=>Ln(e,t,n?.initialValue===void 0?I():R(n.initialValue),r,n?.uninterruptible);function Ln(e,t,n,r=d(),i=!1){let a=e.self(),o=Me();e.addFinalizer(()=>{We(r)(Ve(o,l))});let s,c=!1,u=Rn(r.pipe(C(Xe,o),C(ln,e.registry),C(at,e.registry.scheduler)),t,function(t){s=Zt(t,a),c&&e.setSelf(s)},i);return c=!0,u!==void 0&&e.addFinalizer(u),s===void 0?a._tag===`Some`?Qt(a):B(n):s}function Rn(e,t,n,r=!1){if(se(t)){n(t);return}let i=We(e)(t);i.currentDispatcher?.flush();let a=i.pollUnsafe();if(a){n(a);return}let o=i.addObserver(n);function s(){o(),r||i.interruptUnsafe()}return s}function zn(e){let t=e?.memoMap??Y(jn(()=>Pe())),n=e=>Cn(t)?e(t):t,r=Ut;function i(e){let t=Object.create(En);t.keepAlive=!1,t.lazy=!0,t.refresh=void 0,t.factory=i;let a=Qn(X(typeof e==`function`?t=>$e(e(t),r):()=>$e(e,r)));return t.layer=a,t.read=function(e){let t=e(a);return In(e,j(it,r=>be(t,n(e),r)),{uninterruptible:!0})},t}i.memoMap=t,i.addGlobalLayer=e=>{r=$e(r,Je(e,Ut))};let a=Y(jn(e=>Le(t=>be(Ut,n(e),p(t,Xe))).pipe(f(p(N)))));return i.withReactivity=e=>t=>$n(t,n=>{let r=on(n(a));return n.addFinalizer(r.registerUnsafe(e,()=>{n.refresh(t)})),n.subscribe(t,e=>n.setSelf(e)),n.once(t)},{initialValueTarget:t}),i}zn().withReactivity;var Bn=(e,t,n,r)=>Vn(e,t,n?.initialValue===void 0?I():R(n.initialValue),r);function Vn(e,t,n,i=d()){let a=e.self();i=C(i,ln,e.registry);let o=Oe(n=>j(wt(t.channel,n),t=>lt({while:r,body:()=>t,step(t){e.setSelf(R(ve(t),{waiting:!0}))}}))).pipe(He(t=>(te(t)?nt(e.self(),Ae(an),Ce({onNone:()=>e.setSelf(nn(new x,{previous:e.self()})),onSome:t=>e.setSelf(R(t))})):e.setSelf(z(t,{previous:e.self()})),_))),s=Rn(i.pipe(C(ln,e.registry),C(at,e.registry.scheduler)),o,rt,!1);return s!==void 0&&e.addFinalizer(s),a._tag===`Some`?Qt(a):B(n)}var Hn=(e,t,n=d())=>P(t)?(e.addFinalizer(qt(t).pipe(pt(t=>{for(let n=0;n<t.length;n++)e.setSelf(t[n]);return _}),tt(n))),we(n)(Jt(t))):t._tag===`Success`?Vn(e,qt(t.value),I(!0),n):t,Un=(e,t)=>{function n(t,n){let r=t.get(e);P(r)?qe(Xt(r,n)):L(r)&&qe(Xt(r.value,n))}return Z(n=>{let r=n(e);return P(r)||L(r)?t(n,r):r},n)},Wn=Symbol.for(`effect/reactivity/atom/Atom/Reset`),Gn=Symbol.for(`effect/reactivity/atom/Atom/Interrupt`),Kn=function(...e){return e.length===0?qn:qn(...e)},qn=(e,t)=>

1{let[n,r]=Jn(e,t);return Z(n,r)};function Jn(e,t){let n=Y(Fn([0,void 0])),r=t?.initialValue===void 0?I():R(t.initialValue),i=t?.concurrent?Y(X(e=>{let t=new Set;return e.addFinalizer(()=>t.forEach(e=>e.interruptUnsafe())),t})):void 0;function a(t,a){let o=i?t(i):void 0;t.isFn=!0;let[s,c]=t.get(n);if(s===0)return r;if(c===Gn)return z(w(),{previous:t.self()});let l=e(c,t);return Nn in l?(o&&(l=j(S(l,{startImmediately:!0}),e=>(o.add(e),e.addObserver(()=>o.delete(e)),f(Et(o),e=>e[0])))),Ln(t,l,r,a,!1)):Vn(t,l,r,a)}function o(e,t){nr(()=>{t===Wn?e.set(n,[0,void 0]):t===Gn?e.set(n,[e.get(n)[0]+1,Gn]):e.set(n,[e.get(n)[0]+1,t]),e.refreshSelf()})}return[a,o,n]}var Yn=(e,t,n,r)=>j(ft(typeof n==`function`?n(e):n),n=>{let i=Dt().context,a=ge(),o=ne(n,{onFailure(e){return te(e)?xe(a)?T({done:!0,items:a}):ct(new x(`Atom.pull: no items`)):De(e)},onSuccess(e){let t;return r?.disableAccumulation?t=e:(t=fe(a,e),a=t),T({done:!1,items:t})}}),s=new Set;return e.addFinalizer(()=>{for(let e of s)e()}),e.once(t),e.subscribe(t,()=>{e.setSelf(Qt(e.self()));let t;t=Rn(i,o,n=>{t&&s.delete(t);let r=Zt(n,e.self()),i=s.size>0;e.setSelf(i?B(r):r)}),t&&s.add(t)}),o}),Xn=(e,t)=>Z(t.read,function(t,n){t.set(e,t.get(e)+1)}),Zn=typeof WeakRef>`u`||typeof FinalizationRegistry>`u`?e=>{let t=jt();return function(n){let r=Mt(t,n);if(r._tag===`Some`)return r.value;let i=e(n);return Ft(t,n,i),i}}:e=>{let t=jt(),n=new FinalizationRegistry(e=>{Lt(t,e)});return function(r){let i=Mt(t,r).pipe(Ue(e=>e.deref()));if(i._tag===`Some`)return i.value;let a=e(r);return Ft(t,r,new WeakRef(a)),n.register(a,r),a}},Qn=e=>Object.assign(Object.create(Object.getPrototypeOf(e)),{...e,keepAlive:!0}),$n=k(e=>Cn(e[0]),(e,t,n)=>{let r=Y(kn(e)?Z(n=>t(n,e),function(t,n){t.set(e,n)},e.refresh??function(t){t(e)}):X(n=>t(n,e),e.refresh??function(t){t(e)}));return n?.initialValueTarget&&(r.initialValueTarget=er(n.initialValueTarget)),r}),er=e=>{let t=e;for(;t.initialValueTarget;)t=t.initialValueTarget;return t},tr=k(2,(e,t)=>$n(e,n=>t(n(e)))),nr=bn,rr=`~effect-atom/atom/Atom/ServerValue`,ir=k(2,(e,t)=>Object.assign(Object.create(Object.getPrototypeOf(e)),{...e,[rr]:t})),ar=k(2,(e,t)=>`~effect-atom/atom/Atom/ServerValue`in e?e[rr](e=>t.get(e)):t.get(e)),or=n((e=>{function t(e,t){var n=e.length;e.push(t);a:for(;0<n;){var r=n-1>>>1,a=e[r];if(0<i(a,t))e[r]=t,e[n]=a,n=r;else break a}}function n(e){return e.length===0?null:e[0]}function r(e){if(e.length===0)return null;var t=e[0],n=e.pop();if(n!==t){e[0]=n;a:for(var r=0,a=e.length,o=a>>>1;r<o;){var s=2*(r+1)-1,c=e[s],l=s+1,u=e[l];if(0>i(c,n))l<a&&0>i(u,c)?(e[r]=u,e[l]=n,r=l):(e[r]=c,e[s]=n,r=s);else if(l<a&&0>i(u,n))e[r]=u,e[l]=n,r=l;else break a}}return t}function i(e,t){var n=e.sortIndex-t.sortIndex;return n===0?e.id-t.id:n}if(e.unstable_now=void 0,typeof performance==`object`&&typeof performance.now==`function`){var a=performance;e.unstable_now=function(){return a.now()}}else{var o=Date,s=o.now();e.unstable_now=function(){return o.now()-s}}var c=[],l=[],u=1,d=null,f=3,ee=!1,p=!1,m=!1,h=!1,te=typeof setTimeout==`function`?setTimeout:null,ne=typeof clearTimeout==`function`?clearTimeout:null,re=typeof setImmediate<`u`?setImmediate:null;function g(e){for(var i=n(l);i!==null;){if(i.callback===null)r(l);else if(i.startTime<=e)r(l),i.sortIndex=i.expirationTime,t(c,i);else break;i=n(l)}}function _(e){if(m=!1,g(e),!p){if(n(c)!==null)p=!0,v||(v=!0,C());else{var t=n(l);t!==null&&w(_,t.startTime-e)}}}var v=!1,y=-1,b=5,ie=-1;function x(){return h?!0:!(e.unstable_now()-ie<b)}function S(){if(h=!1,v){var t=e.unstable_now();ie=t;var i=!0;try{a:{p=!1,m&&(m=!1,ne(y),y=-1),ee=!0;var a=f;try{b:{for(g(t),d=n(c);d!==null&&!(d.expirationTime>t&&x());){var o=d.callback;if(typeof o==`function`){d.callback=null,f=d.priorityLevel;var s=o(d.expirationTime<=t);if(t=e.unstable_now(),typeof s==`function`){d.callback=s,g(t),i=!0;break b}d===n(c)&&r(c),g(t)}else r(c);d=n(c)}if(d!==null)i=!0;else{var u=n(l);u!==null&&w(_,u.startTime-t),i=!1}}break a}finally{d=null,f=a,ee=!1}i=void 0}}finally{i?C():v=!1}}}var C;if(typeof re==`function`)C=function(){re(S)};

1else if(typeof MessageChannel<`u`){var ae=new MessageChannel,oe=ae.port2;ae.port1.onmessage=S,C=function(){oe.postMessage(null)}}else C=function(){te(S,0)};function w(t,n){y=te(function(){t(e.unstable_now())},n)}e.unstable_IdlePriority=5,e.unstable_ImmediatePriority=1,e.unstable_LowPriority=4,e.unstable_NormalPriority=3,e.unstable_Profiling=null,e.unstable_UserBlockingPriority=2,e.unstable_cancelCallback=function(e){e.callback=null},e.unstable_forceFrameRate=function(e){0>e||125<e?console.error(`forceFrameRate takes a positive int between 0 and 125, forcing frame rates higher than 125 fps is not supported`):b=0<e?Math.floor(1e3/e):5},e.unstable_getCurrentPriorityLevel=function(){return f},e.unstable_next=function(e){switch(f){case 1:case 2:case 3:var t=3;break;default:t=f}var n=f;f=t;try{return e()}finally{f=n}},e.unstable_requestPaint=function(){h=!0},e.unstable_runWithPriority=function(e,t){switch(e){case 1:case 2:case 3:case 4:case 5:break;default:e=3}var n=f;f=e;try{return t()}finally{f=n}},e.unstable_scheduleCallback=function(r,i,a){var o=e.unstable_now();switch(typeof a==`object`&&a?(a=a.delay,a=typeof a==`number`&&0<a?o+a:o):a=o,r){case 1:var s=-1;break;case 2:s=250;break;case 5:s=1073741823;break;case 4:s=1e4;break;default:s=5e3}return s=a+s,r={id:u++,callback:i,priorityLevel:r,startTime:a,expirationTime:s,sortIndex:-1},a>o?(r.sortIndex=a,t(l,r),n(c)===null&&r===n(l)&&(m?(ne(y),y=-1):m=!0,w(_,a-o))):(r.sortIndex=s,t(c,r),p||ee||(p=!0,v||(v=!0,C()))),r},e.unstable_shouldYield=x,e.unstable_wrapCallback=function(e){var t=f;return function(){var n=f;f=t;try{return e.apply(this,arguments)}finally{f=n}}}})),sr=n(((e,t)=>{t.exports=or()})),Q=e(t(),1),cr=e(sr(),1);function lr(e){let t=cr.unstable_scheduleCallback(4,e);return()=>cr.unstable_cancelCallback(t)}var $=Q.createContext(cn({scheduleTask:lr,defaultIdleTTL:400})),ur=e=>{let t=Q.useRef(null);return t.current===null&&(t.current={registry:cn({scheduleTask:e.scheduleTask??lr,initialValues:e.initialValues,timeoutResolution:e.timeoutResolution,defaultIdleTTL:e.defaultIdleTTL})}),Q.useEffect(()=>(t.current?.timeout!==void 0&&clearTimeout(t.current.timeout),()=>{t.current.timeout=setTimeout(()=>{t.current?.registry.dispose(),t.current=null},500)}),[t]),Q.createElement($.Provider,{value:t.current.registry},e?.children)},dr=new WeakMap;function fr(e,t){let n=dr.get(e);n===void 0&&(n=new WeakMap,dr.set(e,n));let r=n.get(t);if(r!==void 0)return r;let i={subscribe(n){return e.subscribe(t,n)},snapshot(){return e.get(t)},getServerSnapshot(){return ar(t,e)}};return n.set(t,i),i}function pr(e,t){let n=fr(e,t);return Q.useSyncExternalStore(n.subscribe,n.snapshot,n.getServerSnapshot)}var mr=(e,t)=>{let n=Q.useContext($);return t?pr(n,Q.useMemo(()=>tr(e,t),[e,t])):pr(n,e)};function hr(e,t){Q.useEffect(()=>e.mount(t),[t,e])}function gr(e,t,n){return n?.mode===`promise`||n?.mode===`promiseExit`?Q.useCallback(r=>{e.set(t,r);let i=Ne(un(e,t,{suspendOnWaiting:!0}));return n.mode===`promise`?i.then(_r):i},[e,t,n.mode]):Q.useCallback(n=>{e.set(t,typeof n==`function`?n(e.get(t)):n)},[e,t])}var _r=e=>{if(s(e))return e.value;throw pe(e.cause)},vr=(e,t)=>{let n=Q.useContext($);return hr(n,e),gr(n,e,t)},yr=(e,t)=>{let n=Q.useContext($);return[pr(n,e),gr(n,e,t)]},br={getItem:()=>null,setItem:()=>void 0,removeItem:()=>void 0},xr=(()=>{try{return typeof localStorage>`u`?br:localStorage}catch{return br}})(),Sr=()=>xr;function Cr(e){let t=()=>e.storage??xr,n=i(Ze(e.schema));return()=>{let r;try{r=t().getItem(e.key)}catch{r=null}if(r===null)return e.defaultValue();try{return n(r)}catch{return e.fieldFallback?e.fieldFallback(r):e.defaultValue()}}}function wr(e){let t=()=>e.storage??xr,n=he(Ze(e.schema)),r=Cr(e),i=r=>{try{let i=n(r);t().setItem(e.key,i)}catch{}};return Z(()=>r(),(e,t)=>{i(t),e.setSelf(t)}).pipe(Qn,ir(()=>e.defaultValue()))}function Tr(e){let t=Object.entries(e.schema.fields);return n=>{let r=e.defaultValue(),i;try{i=JSON.parse(n)}catch{i=null}if(typeof i!=`object`||!i)return r;let a=i,o=typeof a.state==`object`&&a.state!==null?a.state:a,s={...r};for(let[e,n]of t)if(e in o)try{s[e]=de(n)(o[e])}catch{}return s}}export{yr as a,$ as c,Zn as d,Kn as f,Z as g,ir as h,Cr as i,ur as l,jn as m,Tr as n,vr as o,Qn as p,Sr as r,mr as s,wr as t,Gn as u};
2//# sourceMappingURL=kvs-C_4L7zkd.js.map