| 1 |
- import{i as e}from"./chunk-aKtaBQYM.js";import{D as t}from"./client-BdOyoZJz.js";import{N as n,O as r,S as i,T as a,c as o,n as s}from"./QueryClientProvider-Clbyr4Jg.js";import{a as c,c as l,d as u,i as d,l as f,n as p,o as m,r as h,s as g,u as _}from"./useQuery-CCy0EwsM.js";function v(e,t){let n=new Set(t);return e.filter(e=>!n.has(e))}function y(e,t,n){let r=e.slice(0);return r[t]=n,r}var b=class extends n{#e;#t;#n;#r;#i;#a;#o;#s;#c;#l=[];constructor(e,t,n){super(),this.#e=e,this.#r=n,this.#n=[],this.#i=[],this.#t=[],this.setQueries(t)}onSubscribe(){this.listeners.size===1&&this.#i.forEach(e=>{e.subscribe(t=>{this.#p(e,t)})})}onUnsubscribe(){this.listeners.size||this.destroy()}destroy(){this.listeners=new Set,this.#i.forEach(e=>{e.destroy()})}setQueries(e,t){this.#n=e,this.#r=t,o.batch(()=>{let e=this.#i,t=this.#f(this.#n);t.forEach(e=>e.observer.setOptions(e.defaultedQueryOptions));let n=t.map(e=>e.observer),i=n.map(e=>e.getCurrentResult()),a=e.length!==n.length,o=n.some((t,n)=>t!==e[n]),s=a||o,c=s?!0:i.some((e,t)=>{let n=this.#t[t];return!n||!r(e,n)});!s&&!c||(s&&(this.#l=t,this.#i=n),this.#t=i,this.hasListeners()&&(s&&(v(e,n).forEach(e=>{e.destroy()}),v(n,e).forEach(e=>{e.subscribe(t=>{this.#p(e,t)})})),this.#m()))})}getCurrentResult(){return this.#t}getQueries(){return this.#i.map(e=>e.getCurrentQuery())}getObservers(){return this.#i}getOptimisticResult(e,t){let n=this.#f(e),r=n.map(e=>e.observer.getOptimisticResult(e.defaultedQueryOptions)),i=n.map(e=>e.defaultedQueryOptions.queryHash);return[r,e=>this.#d(e??r,t,i),()=>this.#u(r,n)]}#u(e,t){return t.map((n,r)=>{let i=e[r];return n.defaultedQueryOptions.notifyOnChangeProps?i:n.observer.trackResult(i,e=>{t.forEach(t=>{t.observer.trackProp(e)})})})}#d(e,t,n){if(t){let r=this.#c,i=n!==void 0&&r!==void 0&&(r.length!==n.length||n.some((e,t)=>e!==r[t]));return(!this.#a||this.#t!==this.#s||i||t!==this.#o)&&(this.#o=t,this.#s=this.#t,n!==void 0&&(this.#c=n),this.#a=a(this.#a,t(e))),this.#a}return e}#f(e){let t=new Map;this.#i.forEach(e=>{let n=e.options.queryHash;if(!n)return;let r=t.get(n);r?r.push(e):t.set(n,[e])});let n=[];return e.forEach(e=>{let r=this.#e.defaultQueryOptions(e),i=t.get(r.queryHash)?.shift()??new u(this.#e,r);n.push({defaultedQueryOptions:r,observer:i})}),n}#p(e,t){let n=this.#i.indexOf(e);n!==-1&&(this.#t=y(this.#t,n,t),this.#m())}#m(){if(this.hasListeners()){let e=this.#a,t=this.#u(this.#t,this.#l);e!==this.#d(t,this.#r?.combine)&&o.batch(()=>{this.listeners.forEach(e=>{e(this.#t)})})}}},x=e(t(),1);function S({queries:e,...t},n){let r=s(n),a=_(),v=f(),y=x.useMemo(()=>e.map(e=>{let t=r.defaultQueryOptions(e);return t._optimisticResults=a?`isRestoring`:`optimistic`,t}),[e,r,a]);y.forEach(e=>{p(e),m(e,v,r.getQueryCache().get(e.queryHash))}),l(v);let[S]=x.useState(()=>new b(r,y,t)),[C,w,T]=S.getOptimisticResult(y,t.combine),E=!a&&t.subscribed!==!1;x.useSyncExternalStore(x.useCallback(e=>E?S.subscribe(o.batchCalls(e)):i,[S,E]),()=>S.getCurrentResult(),()=>S.getCurrentResult()),x.useEffect(()=>{S.setQueries(y,t)},[y,t,S]);let D=C.some((e,t)=>d(y[t],e))?C.flatMap((e,t)=>{let n=y[t];if(n){let t=new u(r,n);if(d(n,e))return h(n,t,v);c(e,a)&&h(n,t,v)}return[]}):[];if(D.length>0)throw Promise.all(D);let O=C.find((e,t)=>{let n=y[t];return n&&g({result:e,errorResetBoundary:v,throwOnError:n.throwOnError,query:r.getQueryCache().get(n.queryHash),suspense:n.suspense})});if(O?.error)throw O.error;return w(T())}export{S as t};
|