https://clonesite.ai/assets/esm-DIuQSwbX.js

1import{s as e,t}from"./notifyManager-CyFTn-je.js";import{c as n,d as r,f as i,l as a,r as o,s,u as c}from"./api-6zgOx0J1.js";import{a as l,n as u,o as d,r as f}from"./validator-BGE8bN0Z.js";var p=Object.defineProperty,m=(e,t,n)=>t in e?p(e,t,{enumerable:!0,configurable:!0,writable:!0,value:n}):e[t]=n,h=(e,t,n)=>m(e,typeof t==`symbol`?t:t+``,n),g=void 0,_=class{constructor(e,t){if(h(this,`address`),h(this,`auth`),h(this,`adminAuth`),h(this,`encodedTsPromise`),h(this,`debug`),h(this,`fetchOptions`),h(this,`fetch`),h(this,`logger`),h(this,`mutationQueue`,[]),h(this,`isProcessingQueue`,!1),typeof t==`boolean`)throw Error("skipConvexDeploymentUrlCheck as the second argument is no longer supported. Please pass an options object, `{ skipConvexDeploymentUrlCheck: true }`.");(t??{}).skipConvexDeploymentUrlCheck!==!0&&d(e),this.logger=t?.logger===!1?a({verbose:!1}):t?.logger!==!0&&t?.logger?t.logger:n({verbose:!1}),this.address=e,this.debug=!0,this.auth=void 0,this.adminAuth=void 0,this.fetch=t?.fetch,t?.auth&&this.setAuth(t.auth)}backendUrl(){return`${this.address}/api`}get url(){return this.address}setAuth(e){this.clearAuth(),this.auth=e}setAdminAuth(e,t){if(this.clearAuth(),t!==void 0){let n=new TextEncoder().encode(JSON.stringify(t)),r=btoa(String.fromCodePoint(...n));this.adminAuth=`${e}:${r}`}else this.adminAuth=e}clearAuth(){this.auth=void 0,this.adminAuth=void 0}setDebug(e){this.debug=e}setFetchOptions(e){this.fetchOptions=e}async consistentQuery(e,...t){let n=l(t[0]),r=this.getTimestamp();return await this.queryInner(e,n,{timestampPromise:r})}async getTimestamp(){return this.encodedTsPromise?this.encodedTsPromise:this.encodedTsPromise=this.getTimestampInner()}async getTimestampInner(){let e=this.fetch||g||fetch,t={"Content-Type":`application/json`,"Convex-Client":`npm-${i}`},n=await e(`${this.address}/api/query_ts`,{...this.fetchOptions,method:`POST`,headers:t});if(!n.ok)throw Error(await n.text());let{ts:r}=await n.json();return r}async query(e,...t){let n=l(t[0]);return await this.queryInner(e,n,{})}async queryInner(e,t,n){let a=s(e),o=[u(t)],l={"Content-Type":`application/json`,"Convex-Client":`npm-${i}`};this.adminAuth?l.Authorization=`Convex ${this.adminAuth}`:this.auth&&(l.Authorization=`Bearer ${this.auth}`);let d=this.fetch||g||fetch,p=n.timestampPromise?await n.timestampPromise:void 0,m=JSON.stringify({path:a,format:`convex_encoded_json`,args:o,...p?{ts:p}:{}}),h=await d(p?`${this.address}/api/query_at_ts`:`${this.address}/api/query`,{...this.fetchOptions,body:m,method:`POST`,headers:l});if(!h.ok&&h.status!==560)throw Error(await h.text());let _=await h.json();if(this.debug)for(let e of _.logLines??[])c(this.logger,`info`,`query`,a,e);switch(_.status){case`success`:return f(_.value);case`error`:throw _.errorData===void 0?Error(_.errorMessage):v(_.errorData,new r(_.errorMessage));default:throw Error(`Invalid response: ${JSON.stringify(_)}`)}}async mutationInner(e,t){let n=s(e),a=JSON.stringify({path:n,format:`convex_encoded_json`,args:[u(t)]}),o={"Content-Type":`application/json`,"Convex-Client":`npm-${i}`};this.adminAuth?o.Authorization=`Convex ${this.adminAuth}`:this.auth&&(o.Authorization=`Bearer ${this.auth}`);let l=await(this.fetch||g||fetch)(`${this.address}/api/mutation`,{...this.fetchOptions,body:a,method:`POST`,headers:o});if(!l.ok&&l.status!==560)throw Error(await l.text());let d=await l.json();if(this.debug)for(let e of d.logLines??[])c(this.logger,`info`,`mutation`,n,e);switch(d.status){case`success`:return f(d.value);case`error`:throw d.errorData===void 0?Error(d.errorMessage):v(d.errorData,new r(d.errorMessage));default:throw Error(`Invalid response: ${JSON.stringify(d)}`)}}async processMutationQueue(){if(!this.isProcessingQueue){for(this.isProcessingQueue=!0;this.mutationQueue.length>0;){let{mutation:e,args:t,resolve:n,reject:r}=this.mutationQueue.shift();try{n(await this.mutationInner(e,t))}catch(e){r(e)}}this.isProcessingQueue=!1}}enqueueMutation(e,t){return new Promise((n,r)=>{this.mutationQueue.push({mutation:e,args:t,resolve:n,reject:r}),this.processMutationQueue()})}async mutation(e,...t){let[n,r]=t,i=l(n);return r?.skipQueue?await this.mutationInner(e,i):await this.enqueueMutation(e,i)}async action(e,...t){let n=l(t[0]),a=s(e),o=JSON.stringify({path:a,format:`convex_encoded_json`,args:[u(n)]}),d={"Content-Type":`application/json`,"Convex-Client":`npm-${i}`};this.adminAuth?d.Authorization=`Convex ${this.adminAuth}`:this.auth&&(d.Authorization=`Bearer ${this.auth}`);let p=await(this.fetch||g||fetch)(`${this.address}/api/action`,{...this.fetchOptions,body:o,method:`POST`,headers:d});if(!p.ok&&p.status!==560)throw Error(await p.text());let m=await p.json();if(this.debug)for(let e of m.logLines??[])c(this.logger,`info`,`action`,a,e);switch(m.status){case`success`:return f(m.value);case`error`:throw m.errorData===void 0?Error(m.errorMessage):v(m.errorData,new r(m.errorMessage));default:throw Error(`Invalid response: ${JSON.stringify(m)}`)}}async function(e,t,...n){let a=l(n[0]),o=typeof e==`string`?e:s(e),d=JSON.stringify({componentPath:t,path:o,format:`convex_encoded_json`,args:u(a

1)}),p={"Content-Type":`application/json`,"Convex-Client":`npm-${i}`};this.adminAuth?p.Authorization=`Convex ${this.adminAuth}`:this.auth&&(p.Authorization=`Bearer ${this.auth}`);let m=await(this.fetch||g||fetch)(`${this.address}/api/function`,{...this.fetchOptions,body:d,method:`POST`,headers:p});if(!m.ok&&m.status!==560)throw Error(await m.text());let h=await m.json();if(this.debug)for(let e of h.logLines??[])c(this.logger,`info`,`any`,o,e);switch(h.status){case`success`:return f(h.value);case`error`:throw h.errorData===void 0?Error(h.errorMessage):v(h.errorData,new r(h.errorMessage));default:throw Error(`Invalid response: ${JSON.stringify(h)}`)}}};function v(e,t){return t.data=f(e),t}var y=typeof window>`u`;function b(e){return e.length>=2&&[`convexQuery`,`convexAction`].includes(e[0])&&e[2]===`skip`}function x(e){return e.length>=2&&e[0]===`convexQuery`}function S(e){return e.length>=2&&e[0]===`convexAction`}function C(e){return`convexQuery|${s(e[1])}|${JSON.stringify(u(e[2]))}`}var w=class{convexClient;subscriptions;unsubscribe;serverHttpClient;_queryClient;ssrQueryMode;get queryClient(){if(!this._queryClient)throw Error(`ConvexQueryClient not connected to TanStack QueryClient.`);return this._queryClient}constructor(e,t={}){typeof e==`string`?this.convexClient=new o(e,t):this.convexClient=e,t.dangerouslyUseInconsistentQueriesDuringSSR?this.ssrQueryMode=`inconsistent`:this.ssrQueryMode=`consistent`,this.subscriptions={},t.queryClient&&(this._queryClient=t.queryClient,this.unsubscribe=this.subscribeInner(t.queryClient.getQueryCache())),y&&(this.serverHttpClient=new _(this.convexClient.url))}connect(e){if(this.unsubscribe)throw Error(`already subscribed!`);this._queryClient=e,this.unsubscribe=this.subscribeInner(e.getQueryCache())}onUpdate=()=>{t.batch(()=>{for(let e of Object.keys(this.subscriptions))this.onUpdateQueryKeyHash(e)})};onUpdateQueryKeyHash(e){let t=this.subscriptions[e];if(!t)throw Error(`Internal ConvexQueryClient error: onUpdateQueryKeyHash called for ${e}`);let n=this.queryClient.getQueryCache().get(e);if(!n)return;let{queryKey:r,watch:i}=t,a;try{a={ok:!0,value:i.localQueryResult()}}catch(e){a={ok:!1,error:e}}if(a.ok){let e=a.value;this.queryClient.setQueryData(r,t=>{if(t!==void 0)return e})}else{let{error:e}=a;n?.setState({error:e,errorUpdateCount:n.state.errorUpdateCount+1,errorUpdatedAt:Date.now(),fetchFailureCount:n.state.fetchFailureCount+1,fetchFailureReason:e,fetchStatus:`idle`,status:`error`},{meta:`set by ConvexQueryClient`})}}subscribeInner(e){return y?()=>{}:e.subscribe(e=>{if(x(e.query.queryKey)&&!b(e.query.queryKey))switch(e.type){case`removed`:this.subscriptions[e.query.queryHash].unsubscribe(),delete this.subscriptions[e.query.queryHash];break;case`added`:{let[t,n,r,i]=e.query.queryKey,a=this.convexClient.watchQuery(n,r,{}),o=a.onUpdate(()=>{this.onUpdateQueryKeyHash(e.query.queryHash)});this.subscriptions[e.query.queryHash]={queryKey:e.query.queryKey,watch:a,unsubscribe:o};break}case`observerAdded`:break;case`observerRemoved`:e.query.getObserversCount();break;case`observerResultsUpdated`:break;case`updated`:if(e.action.type===`setState`&&e.action.setStateOptions?.meta===`set by ConvexQueryClient`)break;break;case`observerOptionsUpdated`:break}})}queryFn(e=E){return async t=>{if(b(t.queryKey))throw Error(`Skipped query should not actually be run, should { enabled: false }`);if(x(t.queryKey)){let[e,n,r]=t.queryKey;return y?this.ssrQueryMode===`consistent`?await this.serverHttpClient.consistentQuery(n,r):await this.serverHttpClient.query(n,r):await this.convexClient.query(n,r)}if(S(t.queryKey)){let[e,n,r]=t.queryKey;return y?await this.serverHttpClient.action(n,r):await this.convexClient.action(n,r)}return e(t)}}hashFn(t=e){return e=>x(e)?C(e):t(e)}queryOptions=(e,t)=>({queryKey:[`convexQuery`,s(e),t],queryFn:this.queryFn(),staleTime:1/0})};function T(e,...t){let n=t[0]??{};return{queryKey:[`convexQuery`,s(e),n===`skip`?`skip`:n],staleTime:1/0,...n===`skip`?{enabled:!1}:{}}}function E(e){throw Error(`Query key is not for a Convex Query: `+e.queryKey)}export{T as n,w as t};