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

1(function(){try{var e=typeof window<`u`?window:typeof global<`u`?global:typeof globalThis<`u`?globalThis:typeof self<`u`?self:{};e.SENTRY_RELEASE={id:`798154dfe6f02312abe2ebb46dcac5b55267091e`},e._sentryModuleMetadata=e._sentryModuleMetadata||{},e._sentryModuleMetadata[new e.Error().stack]=function(e){for(var t=1;t<arguments.length;t++){var n=arguments[t];if(n!=null)for(var r in n)n.hasOwnProperty(r)&&(e[r]=n[r])}return e}({},e._sentryModuleMetadata[new e.Error().stack],{"_sentryBundlerPluginAppKey:listening-web":!0});var t=new e.Error().stack;t&&(e._sentryDebugIds=e._sentryDebugIds||{},e._sentryDebugIds[t]=`7523393b-280a-4c69-be82-ea9a77547b81`,e._sentryDebugIdIdentifier=`sentry-dbid-7523393b-280a-4c69-be82-ea9a77547b81`)}catch{}})();import{a as e,n as t,r as n}from"./jsx-runtime-HLTtilDO.js";import{B as r,Ca as i,Ci as a,Co as o,Ea as s,Ei as c,Er as l,Fa as u,Fo as d,Go as f,Hn as p,Ho as m,Ia as h,In as g,Jn as _,Jo as v,Jr as ee,Kn as y,La as te,Lr as b,Mn as x,Na as S,No as ne,Oi as C,On as w,Pa as T,Pi as re,Po as ie,Ri as E,Si as ae,Sr as D,Ta as oe,Ti as se,Tr as O,U as ce,Ua as le,Ui as ue,Uo as de,Vo as k,W as fe,Wa as pe,Wo as A,Xa as me,Xn as he,Xr as ge,Ya as _e,Zr as ve,_o as ye,_r as be,as as xe,bi as Se,bn as Ce,br as we,cn as Te,cs as Ee,di as De,dr as Oe,ei as ke,es as Ae,go as je,hn as Me,ho as Ne,is as j,ja as Pe,li as Fe,ln as Ie,lo as Le,lr as Re,ls as ze,mn as Be,mr as Ve,ni as He,nr as Ue,ns as We,oi as Ge,os as Ke,po as qe,q as Je,qo as Ye,ri as Xe,si as Ze,sr as Qe,uo as $e,vo as et,vr as tt,wa as nt,wr as rt,xi as it,xn as M,xo as N,yn as at,yo as P,zr as ot}from"./Schema-BiKO9Vds.js";import{Bt as st,Gt as ct,Ht as lt,Qt as ut,Rt as dt,Ut as ft,Vt as pt,Wt as mt,Xt as ht,fn as gt,hn as _t,pn as vt,qt as yt,tn as bt,un as xt,vn as St}from"./api-contract-CCE5gx-b.js";import{a as Ct,n as wt,o as Tt}from"./Fiber-CrRAfIeK.js";var Et=`~effect/MutableHashMap`,Dt={[Et]:Et,[Symbol.iterator](){return this.backing[Symbol.iterator]()},toString(){return`MutableHashMap(${d(Array.from(this))})`},toJSON(){return{_id:`MutableHashMap`,values:ie(Array.from(this))}},[ne](){return this.toJSON()},pipe(){return ze(this,arguments)}},Ot=()=>{let e=Object.create(Dt);return e.backing=new Map,e.buckets=new Map,e},kt=j(2,(e,t)=>{if(e.backing.has(t))return N(e.backing.get(t));if(At(t))return P();let n=F.get(e);if(n!==void 0)return e.backing.has(n)?N(e.backing.get(n)):P();let r=A(t),i=e.buckets.get(r);return i===void 0?P():jt(e,i,t)}),F=new WeakMap,At=e=>typeof e!=`object`&&typeof e!=`function`,jt=(e,t,n)=>{for(let r=0,i=t.length;r<i;r++)if(k(n,t[r])){let i=t[r];return F.set(n,i),N(e.backing.get(i))}return P()},Mt=j(3,(e,t,n)=>{if(e.backing.has(t)||At(t))return e.backing.set(t,n),e;let r=F.get(e);if(r!==void 0&&e.backing.has(r))return e.backing.set(r,n),e;let i=A(t),a=e.buckets.get(i);return a===void 0?(e.buckets.set(i,[t]),e.backing.set(t,n),e):(r=Nt(a,t),r===void 0&&(a.push(t),r=t),e.backing.set(r,n),e)}),Nt=(e,t)=>{for(let n=0,r=e.length;n<r;n++)if(k(t,e[n]))return F.set(t,e[n]),e[n]},Pt=j(2,(e,t)=>{if(At(t))return e.backing.delete(t),e;let n=F.get(e)??t,r=A(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||k(n,r)){e.backing.delete(r),i.splice(t,1);break}}return i.length===0&&e.buckets.delete(r),e}),Ft=`~effect/reactivity/Reactivity`,I=S(`effect/reactivity/Reactivity`),It=O(()=>{let e=new Map,t=t=>{Ht(t,t=>{let n=e.get(t);n!==void 0&&n.forEach(e=>e())})},n=e=>Me(n=>{let r=te(n,Lt);return r?Ht(e,e=>{r.add(e)}):t(e),b}),r=(e,t)=>l(t,n(e)),i=(t,n)=>{let r=[];return Ht(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)=>x(function*(){let n=yield*Be(),r=h(n,Ge),a=yield*vt(),o=xe(Re(n),Tt(r)),s=!1,c=!1,l=e=>{e._tag===`Failure`?gt(a,e.cause):_t(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*Ze(r,O(d)),u(),a}),o=(e,t)=>a(e,t).pipe(p(mt),bt),s=t=>rt(()=>{let n=new Set;return t.pipe(Ue(Lt,n),he(t=>O(()=>

1{n.forEach(t=>{let n=e.get(t);n!==void 0&&n.forEach(e=>e())})})))});return I.of({[Ft]:Ft,mutation:r,query:a,stream:o,invalidateUnsafe:t,invalidate:n,registerUnsafe:i,withBatch:s})}),Lt=class extends S()(`effect/reactivity/Reactivity/PendingInvalidation`){},Rt=j(2,(e,t)=>I.use(n=>n.mutation(t,e))),zt=e=>I.use(t=>t.invalidate(e)),Bt=ve(I)(It);function Vt(e){switch(typeof e){case`string`:case`number`:case`bigint`:case`boolean`:return String(e);default:return A(e)}}var Ht=(e,t)=>{if(Array.isArray(e)){for(let n=0;n<e.length;n++)t(Vt(e[n]));return}for(let n in e){t(n);let r=e[n];for(let e=0;e<r.length;e++)t(`${n}:${Vt(r[e])}`)}},Ut=`~effect/SubscriptionRef`,Wt=e=>v(e,Ut);({...o});var Gt=e=>ft(e.pubsub),Kt=e=>O(()=>e.value),qt=(e,t)=>{e.value=t,St(e.pubsub,t)},Jt=j(2,(e,t)=>e.semaphore.withPermit(O(()=>qt(e,t)))),Yt={"~effect/reactivity/AsyncResult":{E:Ke,A:Ke},pipe(){return ze(this,arguments)},[m](e){if(this._tag!==e._tag||this.waiting!==e.waiting)return!1;switch(this._tag){case`Initial`:return!0;case`Success`:return k(this.value,e.value);case`Failure`:return k(this.cause,e.cause)}},[Ye](){let e=f(`${this._tag}:${this.waiting}`);return this._tag===`Initial`?e:de(e)(this._tag===`Success`?A(this.value):A(this.cause))}},Xt=(e,t)=>e._tag===`Success`?z(e.value):B(e.cause,{previous:t}),Zt=e=>e._tag===`None`?L(!0):V(e.value),Qt=e=>e._tag!==`Initial`,L=(e=!1)=>{let t=Object.create(Yt);return t._tag=`Initial`,t.waiting=e,t},R=e=>e._tag===`Success`,z=(e,t)=>{let n=Object.create(Yt);return n._tag=`Success`,n.value=e,n.waiting=t?.waiting??!1,n.timestamp=t?.timestamp??Date.now(),n},$t=e=>e._tag===`Failure`,en=(e,t)=>{let n=Object.create(Yt);return n._tag=`Failure`,n.cause=e,n.previousSuccess=t?.previousSuccess??P(),n.waiting=t?.waiting??!1,n},B=(e,t)=>en(e,{previousSuccess:Le(t.previous,e=>R(e)?N(e):$t(e)?e.previousSuccess:P()),waiting:t.waiting}),tn=(e,t)=>B(re(e),t),V=(e,t)=>{if(e.waiting)return t?.touch?nn(e):e;let n=Object.assign(Object.create(Yt),e);return n.waiting=!0,t?.touch&&R(n)&&(n.timestamp=Date.now()),n},nn=e=>R(e)?z(e.value,{waiting:e.waiting}):e,H=(e,t)=>e._tag===`Failure`?B(e.cause,{previous:t,waiting:e.waiting}):e,rn=e=>e._tag===`Success`?N(e.value):e._tag===`Failure`?ye(e.previousSuccess,e=>e.value):P(),an=e=>qe(rn(e),()=>new C(`AsyncResult.getOrThrow: no value found`)),on=e=>{switch(e._tag){case`Success`:return se(e.value);case`Failure`:return it(e.cause);default:return Se(new C)}},U=`~effect/reactivity/AtomRegistry`,sn=e=>v(e,U),cn=e=>new mn(e?.initialValues,e?.scheduleTask,e?.timeoutResolution,e?.defaultIdleTTL),ln=S(U),un=j(e=>sn(e[0]),(e,t,n)=>{let r=n?.suspendOnWaiting??!1;return Te(n=>{let i=e.get(t);if(i._tag!==`Initial`&&!(r&&i.waiting))return n(on(i));let a=e.subscribe(t,e=>{e._tag!==`Initial`&&!(r&&e.waiting)&&(n(on(e)),a())});return O(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 i(`sync`,t),this.schedulerAsync=new i(`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,We,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?P():N(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 _;switch(n._tag){case`Initial`:return _;case`Failure`:return it(n.cause);case`Success`:return D(n.value)}},resultOnce(e,t){return Te(n=>{let r=this.once(e);if(r._tag!==`Initial`&&!(t?.suspendOnWaiting&&r.waiting))return n(on(r));let i=this.node.registry.subscribe(e,e=>{e._tag===`Initial`||t?.suspendOnWaiting&&e.waiting||(i(),n(on(e)))},{immediate:!1});return O(i)})},setResult(e,t){return this.disposed?_:(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`?_:D(t.value)},someOnce(e){return Te(t=>{let n=this.once(e);if(je(n))return t(D(n.value));let r=this.node.registry.subscribe(e,e=>{Ne(e)||(r(),t(D(e.value)))},{immediate:!1});return O(r)})},once(e){return this.node.registry.get(e)},self(){return this.disposed?P():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?st:dt(n=>O(()=>{this.subscribe(e,e=>_t(n,e),{immediate:!t?.withoutInitialValue})}))},streamResult(e,t){return this.stream(e,t).pipe(lt(Qt),yt(e=>e._tag===`Success`?D(e.value):Ce(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=>v(e,Sn),wn=`~effect/reactivity/Atom/Writable`,Y=j(2,(e,t)=>{let n=oe(t),r=s(n);return Object.assign(Object.create(Object.getPrototypeOf(e)),{...e,keepAlive:!r,idleTTL:r?Pe(n):void 0})})(0),Tn={[Sn]:Sn,equals:Object.is,...o,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):H(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),L(!0),a.value):H(a,i)}))},subscriptionRef(e){return Un(Y(X(t=>{let n=t.self(),r=t(this);if(r._tag!==`Success`)return H(r,n);let i=typeof e==`function`?e(t):e;return Wt(i)?i:Ln(t,i,L(!0),r.value)})),(e,t)=>Hn(e,t,an(e(this))))}},Dn=(e,t,n)=>{let[r,i,a]=Jn(n?.reactivityKeys?(e,r)=>{let i=t(e,r);return g(i)?Rt(i,n.reactivityKeys):pt(i,zt(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):H(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`&&!g(e)&&!ct(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 g(e)?function(n,r){return In(n,e,t,r)}:ct(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?L():z(n.initialValue),r,n?.uninterruptible);function Ln(e,t,n,r=u(),i=!1){let a=e.self(),o=De();e.addFinalizer(()=>{Re(r)(Fe(o,c))});let s,l=!1,d=Rn(r.pipe(T(Ge,o),T(ln,e.registry),T(nt,e.registry.scheduler)),t,function(t){s=Xt(t,a),l&&e.setSelf(s)},i);return l=!0,d!==void 0&&e.addFinalizer(d),s===void 0?a._tag===`Some`?Zt(a):V(n):s}function Rn(e,t,n,r=!1){if(ae(t)){n(t);return}let i=Re(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(()=>ke())),n=e=>Cn(t)?e(t):t,r=Bt;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=>Xe(e(t),r):()=>Xe(e,r)));return t.layer=a,t.read=function(e){let t=e(a);return In(e,M(tt,r=>ge(t,n(e),r)),{uninterruptible:!0})},t}i.memoMap=t,i.addGlobalLayer=e=>{r=Xe(r,He(e,Bt))};let a=Y(jn(e=>Me(t=>ge(Bt,n(e),h(t,Ge))).pipe(p(h(I)))));return i.withReactivity=e=>t=>$n(t,n=>{let r=an(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?L():z(n.initialValue),r);function Vn(e,t,n,r=u()){let i=e.self();r=T(r,ln,e.registry);let a=we(n=>M(xt(t.channel,n),t=>ot({while:Ae,body:()=>t,step(t){e.setSelf(z(me(t),{waiting:!0}))}}))).pipe(Ie(t=>(ee(t)?Ee(e.self(),Le(rn),et({onNone:()=>e.setSelf(tn(new C,{previous:e.self()})),onSome:t=>e.setSelf(z(t))})):e.setSelf(B(t,{previous:e.self()})),b))),o=Rn(r.pipe(T(ln,e.registry),T(nt,e.registry.scheduler)),a,We,!1);return o!==void 0&&e.addFinalizer(o),i._tag===`Some`?Zt(i):V(n)}var Hn=(e,t,n=u())=>Wt(t)?(e.addFinalizer(Gt(t).pipe(ht(t=>{for(let n=0;n<t.length;n++)e.setSelf(t[n]);return b}),Qe(n))),be(n)(Kt(t))):t._tag===`Success`?Vn(e,Gt(t.value),L(!0),n):t,Un=(e,t)=>{function n(t,n){let r=t.get(e);Wt(r)?Ve(Jt(r,n)):R(r)&&Ve(Jt(r.value,n))}return Z(n=>{let r=n(e);return Wt(r)||R(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?L():z(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 B(E(),{previous:t.self()});let l=e(c,t);return Nn in l?(o&&(l=M(w(l,{startImmediately:!0}),e=>(o.add(e),e.addObserver(()=>o.delete(e)),p(Ct(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)=>M(ut(typeof n==`function`?n(e):n),n=>{let i=wt().context,a=pe(),o=y(n,{onFailure(e){return ee(e)?_e(a)?D({done:!0,items:a}):at(new C(`Atom.pull: no items`)):Ce(e)},onSuccess(e){let t;return r?.disableAccumulation?t=e:(t=le(a,e),a=t),D({done:!1,items:t})}}),s=new Set;return e.addFinalizer(()=>{for(let e of s)e()}),e.once(t),e.subscribe(t,()=>{e.setSelf(Zt(e.self()));let t;t=Rn(i,o,n=>{t&&s.delete(t);let r=Xt(n,e.self()),i=s.size>0;e.setSelf(i?V(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=Ot();return function(n){let r=kt(t,n);if(r._tag===`Some`)return r.value;let i=e(n);return Mt(t,n,i),i}}:e=>{let t=Ot(),n=new FinalizationRegistry(e=>{Pt(t,e)});return function(r){let i=kt(t,r).pipe($e(e=>e.deref()));if(i._tag===`Some`)return i.value;let a=e(r);return Mt(t,r,new WeakRef(a)),n.register(a,r),a}},Qn=e=>Object.assign(Object.create(Object.getPrototypeOf(e)),{...e,keepAlive:!0}),$n=j(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=j(2,(e,t)=>$n(e,n=>t(n(e)))),nr=bn,rr=`~effect-atom/atom/Atom/ServerValue`,ir=j(2,(e,t)=>Object.assign(Object.create(Object.getPrototypeOf(e)),{...e,[rr]:t})),ar=j(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,p=!1,m=!1,h=!1,g=!1,_=typeof setTimeout==`function`?setTimeout:null,v=typeof clearTimeout==`function`?clearTimeout:null,ee=typeof setImmediate<`u`?setImmediate:null;function y(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 te(e){if(h=!1,y(e),!m){if(n(c)!==null)m=!0,b||(b=!0,T());else{var t=n(l);t!==null&&E(te,t.startTime-e)}}}var b=!1,x=-1,S=5,ne=-1;function C(){return g?!0:!(e.unstable_now()-ne<S)}function w(){if(g=!1,b){var t=e.unstable_now();ne=t;var i=!0;try{a:{m=!1,h&&(h=!1,v(x),x=-1),p=!0;var a=f;try{b:{for(y(t),d=n(c);d!==null&&!(d.expirationTime>t&&C());){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,y(t),i=!0;break b}d===n(c)&&r(c),y(t)}else r(c);d=n(c)}if(d!==null)i=!0;else{var u=n(l);u!==null&&E(te,u.startTime-t),i=!1}}break a}finally{d=null,f=a,p=!1}i=void 0}}finally{i?T():b=!1}}}var T;if(typeof ee==`function`)T=function(){ee(w)};else if(typeof MessageChannel<`u`){var re=new MessageChannel,ie=re.port2;re.port1.onmessage=w,T=function(){ie.postMessage(null)}}else T=function(){_(w,0)};function E(t,n){x=_(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`):S=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(){g=!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)&&(h?(v(x),x=-1):h=!0,E(te,a-o))):(r.sortIndex=s,t(c,r),m||p||(m=!0,b||(b=!0,T()))),r},e.unstable_shouldYield=C,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($);

1return 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=Oe(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(a(e))return e.value;throw ue(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=r(Je(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=fe(Je(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]=ce(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-_HSp1xFW.js.map