https://gqv.ai/_next/static/chunks/af2f181aef1aac2b.js

1(globalThis.TURBOPACK||(globalThis.TURBOPACK=[])).push(["object"==typeof document?document.currentScript:void 0,399865,659853,113693,e=>{"use strict";function t(e){return e[0]??{}}function r(e){return Array.isArray(e)?e:null==e?[]:[e]}let n="orpc";class s extends Error{constructor(...e){super(...e),this.name="AbortError"}}function a(e){let t;return()=>{if(t)return t.result;let r=e();return t={result:r},r}}function i(){return globalThis["__@orpc/[email protected]/otel/config__"]}function o(e,t={},r){let n=i()?.tracer;return n?.startSpan(e,t,r)}function c(e,t,r={}){if(!e)return;let n=function(e){if(e instanceof Error){let t={message:e.message,name:e.name,stack:e.stack};return"code"in e&&("string"==typeof e.code||"number"==typeof e.code)&&(t.code=e.code),t}return{message:String(e)}}(t);e.recordException(n),r.signal?.aborted&&r.signal.reason===t||e.setStatus({code:2,message:n.message})}async function l({name:e,context:t,...r},n){let s=i()?.tracer;if(!s)return n();let a=async e=>{try{return await n(e)}catch(t){throw c(e,t,r),t}finally{e.end()}};return t?s.startActiveSpan(e,r,t,a):s.startActiveSpan(e,r,a)}async function u(e,t){let r=i();if(!e||!r)return t();let n=r.trace.setSpan(r.context.active(),e);return r.context.with(n,t)}class d{openIds=new Set;queues=new Map;waiters=new Map;get length(){return this.openIds.size}get waiterIds(){return Array.from(this.waiters.keys())}hasBufferedItems(e){return!!this.queues.get(e)?.length}open(e){this.openIds.add(e)}isOpen(e){return this.openIds.has(e)}push(e,t){this.assertOpen(e);let r=this.waiters.get(e);if(r?.length)r.shift()[0](t),0===r.length&&this.waiters.delete(e);else{let r=this.queues.get(e);r?r.push(t):this.queues.set(e,[t])}}async pull(e){this.assertOpen(e);let t=this.queues.get(e);if(t?.length){let r=t.shift();return 0===t.length&&this.queues.delete(e),r}return new Promise((t,r)=>{let n=this.waiters.get(e),s=[t,r];n?n.push(s):this.waiters.set(e,[s])})}close({id:e,reason:t}={}){if(void 0===e){this.waiters.forEach((e,r)=>{let n=t??new s(`[AsyncIdQueue] Queue[${r}] was closed or aborted while waiting for pulling.`);e.forEach(([,e])=>e(n))}),this.waiters.clear(),this.openIds.clear(),this.queues.clear();return}let r=t??new s(`[AsyncIdQueue] Queue[${e}] was closed or aborted while waiting for pulling.`);this.waiters.get(e)?.forEach(([,e])=>e(r)),this.waiters.delete(e),this.openIds.delete(e),this.queues.delete(e)}assertOpen(e){if(!this.isOpen(e))throw Error(`[AsyncIdQueue] Cannot access queue[${e}

1] because it is not open or aborted.`)}}function h(e){return!!e&&"object"==typeof e&&"next"in e&&"function"==typeof e.next&&Symbol.asyncIterator in e&&"function"==typeof e[Symbol.asyncIterator]}let f=Symbol.for("asyncDispose"),p=Symbol.asyncDispose??f;class m{#e=!1;#t=!1;#r;#n;constructor(e,t){this.#r=t,this.#n=function(e){let t=Promise.resolve();return(...r)=>t=t.catch(()=>{}).then(()=>e(...r))}(async()=>{if(this.#e)return{done:!0,value:void 0};try{let t=await e();return t.done&&(this.#e=!0),t}catch(e){throw this.#e=!0,e}finally{this.#e&&!this.#t&&(this.#t=!0,await this.#r("next"))}})}next(){return this.#n()}async return(e){return this.#e=!0,this.#t||(this.#t=!0,await this.#r("return")),{done:!0,value:e}}async throw(e){throw this.#e=!0,this.#t||(this.#t=!0,await this.#r("throw")),e}async [p](){this.#e=!0,this.#t||(this.#t=!0,await this.#r("dispose"))}[Symbol.asyncIterator](){return this}}function y(e,t){let r=new d,n=Array.from({length:t},(e,t)=>t.toString()),s=!1,i=a(async()=>{try{for(;;){let t=await e.next();if(n.forEach(e=>{r.isOpen(e)&&r.push(e,{next:t})}),t.done)break}}catch(e){n.forEach(t=>{r.isOpen(t)&&r.push(t,{error:e})})}finally{s=!0}});return n.map(t=>(r.open(t),new m(async()=>{i();let e=await r.pull(t);if(e.next)return e.next;throw e.error},async n=>{r.close({id:t}),"next"===n||r.length||s||(s=!0,await e?.return?.())})))}function g({name:e,...t},r){let n;return new m(async()=>{n??=o(e);try{let e=await u(n,()=>r.next());return n?.addEvent(e.done?"completed":"yielded"),e}catch(e){throw c(n,e,t),e}},async e=>{try{"next"!==e&&await u(n,()=>r.return?.())}catch(e){throw c(n,e,t),e}finally{n?.end()}})}function w(e){return async(t,...r)=>{try{return await t.next()}catch(n){throw await e(n,t,...r),n}}}function v(e,t,r){let n=(t,s)=>{let a=e[s];return a?a({...t,next:(e=t)=>n(e,s+1)}):r(t)};return n(t,0)}function E(e){if(e)return JSON.parse(e)}function b(e){return JSON.stringify(e)}function S(e){return I(e)?Object.getPrototypeOf(e)?.constructor:null}function O(e){if(!e||"object"!=typeof e)return!1;let t=Object.getPrototypeOf(e);return t===Object.prototype||!t||!t.constructor}function I(e){return!!e&&("object"==typeof e||"function"==typeof e)}function x(e,t){let r=e;for(let e of t){if(!I(r))return;r=r[e]}return r}function R(e,...t){return"function"==typeof e?e(...t):e}function A(e){return new Proxy(e,{get(e,t,r){let n=Reflect.get(e,t,r);return"then"!==t||"function"!=typeof n?n:new Proxy(n,{apply(t,r,n){if(2!==n.length||n.some(e=>{var t;return!("function"==typeof(t=e)&&T.test(t.toString()))}))return Reflect.apply(t,r,n);let s=!0;n[0].call(r,A(new Proxy(e,{get:(e,t,r)=>{if(s&&"then"===t){s=!1;return}return Reflect.get(e,t,r)}})))}})}})}let T=/^\s*function\s*\(\)\s*\{\s*\[native code\]\s*\}\s*$/;function C(e){return new ReadableStream({async pull(t){let{done:r,value:n}=await e.next();r?t.close():t.enqueue(n)},async cancel(){await e.return?.()}})}function _(e){try{return decodeURIComponent(e)}catch{return e}}e.s(["AbortError",()=>s,"AsyncIteratorClass",()=>m,"ORPC_NAME",()=>n,"asyncIteratorToStream",()=>C,"asyncIteratorWithSpan",()=>g,"get",()=>x,"getConstructor",()=>S,"getGlobalOtelConfig",()=>i,"intercept",()=>v,"isAsyncIteratorObject",()=>h,"isObject",()=>O,"isTypescriptObject",()=>I,"onError",()=>w,"once",()=>a,"parseEmptyableJSON",()=>E,"preventNativeAwait",()=>A,"replicateAsyncIterator",()=>y,"resolveMaybeOptionalOptions",()=>t,"runInSpanContext",()=>u,"runWithSpan",()=>l,"setSpanError",()=>c,"startSpan",()=>o,"stringifyJSON",()=>b,"toArray",()=>r,"tryDecodeURIComponent",()=>_,"value",()=>R],659853);let N={BAD_REQUEST:{status:400,message:"Bad Request"},UNAUTHORIZED:{status:401,message:"Unauthorized"},FORBIDDEN:{status:403,message:"Forbidden"},NOT_FOUND:{status:404,message:"Not Found"},METHOD_NOT_SUPPORTED:{status:405,message:"Method Not Supported"},NOT_ACCEPTABLE:{status:406,message:"Not Acceptable"},TIMEOUT:{status:408,message:"Request Timeout"},CONFLICT:{status:409,message:"Conflict"},PRECONDITION_FAILED:{status:412,message:"Precondition Failed"},PAYLOAD_TOO_LARGE:{status:413,message:"Payload Too Large"},UNSUPPORTED_MEDIA_TYPE:{status:415,message:"Unsupported Media Type"},UNPROCESSABLE_CONTENT:{status:422,message:"Unprocessable Content"},TOO_MANY_REQUESTS:{status:429,message:"Too Many Requests"},CLIENT_CLOSED_REQUEST:{status:499,message:"Client Closed Request"},INTERNAL_SERVER_ERROR:{status:500,message:"Internal Server Error"}

1,NOT_IMPLEMENTED:{status:501,message:"Not Implemented"},BAD_GATEWAY:{status:502,message:"Bad Gateway"},SERVICE_UNAVAILABLE:{status:503,message:"Service Unavailable"},GATEWAY_TIMEOUT:{status:504,message:"Gateway Timeout"}},z=Symbol.for("__@orpc/[email protected]/error/ORPC_ERROR_CONSTRUCTORS__");globalThis[z]??=new WeakSet;let U=globalThis[z];class P extends Error{defined;code;status;data;constructor(e,...r){const n=t(r);if(void 0!==n.status&&!D(n.status))throw Error("[ORPCError] Invalid error status code.");super(function(e,t){return t||N[e]?.message||e}(e,n.message),n),this.code=e,this.status=function(e,t){return t??N[e]?.status??500}(e,n.status),this.defined=n.defined??!1,this.data=n.data}toJSON(){return{defined:this.defined,code:this.code,status:this.status,message:this.message,data:this.data}}static[Symbol.hasInstance](e){if(U.has(this)){let t=S(e);if(t&&U.has(t))return!0}return super[Symbol.hasInstance](e)}}function D(e){return e<200||e>=400}function q(e){if(!O(e))return!1;let t=["defined","code","status","message","data"];return!Object.keys(e).some(e=>!t.includes(e))&&"defined"in e&&"boolean"==typeof e.defined&&"code"in e&&"string"==typeof e.code&&"status"in e&&"number"==typeof e.status&&D(e.status)&&"message"in e&&"string"==typeof e.message}function j(e,t={}){return new P(e.code,{...t,...e})}U.add(P);class M extends TypeError{}class L extends TypeError{}class $ extends Error{data;constructor(e){super(e?.message??"An error event was received",e),this.data=e?.data}}class k{constructor(e={}){this.options=e}incomplete="";feed(e){this.incomplete+=e;let t=this.incomplete.lastIndexOf("\n\n");if(-1===t)return;let r=this.incomplete.slice(0,t).split(/\n\n/);for(let e of(this.incomplete=this.incomplete.slice(t+2),r)){let t=function(e){let t=e.replace(/\n+$/,"").split(/\n/),r={data:void 0,event:void 0,id:void 0,retry:void 0,comments:[]};for(let e of t){let t=e.indexOf(":"),n=-1===t?e:e.slice(0,t),s=-1===t?"":e.slice(t+1).replace(/^\s/,"");if(0===t)r.comments.push(s);else if("data"===n)r.data??="",r.data+=`${s}
2`;else if("event"===n)r.event=s;else if("id"===n)r.id=s;else if("retry"===n){let e=Number.parseInt(s);Number.isInteger(e)&&e>=0&&e.toString()===s&&(r.retry=e)}}return r.data=r.data?.replace(/\n$/,""),r}(`${e}
3
4`);this.options.onEvent&&this.options.onEvent(t)}}end(){if(this.incomplete)throw new L("Event Iterator ended before complete")}}class F extends TransformStream{constructor(){let e;super({start(t){e=new k({onEvent:e=>{t.enqueue(e)}})},transform(t){e.feed(t)},flush(){e.end()}})}}function B(e){if(e.includes("\n"))throw new M("Event's id must not contain a newline character")}function W(e){if(!Number.isInteger(e)||e<0)throw new M("Event's retry must be a integer and >= 0")}function Q(e){if(e.includes("\n"))throw new M("Event's comment must not contain a newline character")}function J(e){let t="";if(t+=function(e){let t="";for(let r of e??[])Q(r),t+=`: ${r}
5`;return t}(e.comments),void 0!==e.event){if(e.event.includes("\n"))throw new M("Event's event must not contain a newline character");t+=`event: ${e.event}
6`}return void 0!==e.retry&&(W(e.retry),t+=`retry: ${e.retry}
7`),void 0!==e.id&&(B(e.id),t+=`id: ${e.id}
8`),t+=function(e){let t=e?.split(/\n/)??[],r="";for(let e of t)r+=`data: ${e}
9`;return r}(e.data),t+="\n"}let G=Symbol("ORPC_EVENT_SOURCE_META");function K(e,t){if(void 0===t.id&&void 0===t.retry&&!t.comments?.length)return e;if(void 0!==t.id&&B(t.id),void 0!==t.retry&&W(t.retry),void 0!==t.comments)for(let e of t.comments)Q(e);return new Proxy(e,{get:(e,r,n)=>r===G?t:Reflect.get(e,r,n)})}function H(e){return I(e)?Reflect.get(e,G):void 0}function V(e,t){let r=async e=>{let r=await t.error(e);if(r!==e){let t=H(e);t&&I(r)&&(r=K(r,t))}return r};return new m(async()=>{let{done:n,value:s}=await (async()=>{try{return await e.next()}catch(e){throw await r(e)}})(),a=await t.value(s,n);if(a!==s){let e=H(s);e&&I(a)&&(a=K(a,e))}return{done:n,value:a}},async()=>{try{await e.return?.()}catch(e){throw await r(e)}})}function Y(e,t={}){let r=t.path??[];return A(new Proxy(async(...[t,n={}])=>await e.call(r,t,{...n,context:n.context??{}}),{get:(n,s)=>"string"!=typeof s?Reflect.get(n,s):Y(e,{...t,path:[...r,s]})}))}function Z(e,t={}){return e.forEach((e,r)=>{Array.isArray(t[r])?t[r].push(e):void 0!==t[r]?t[r]=[t[r],e]:t[r]=e}),t}e.s(["createORPCClient",()=>Y],113693);class X{plugins;constructor(e=[]){this.plugins=[...e].sort((e,t)=>

9(e.order??0)-(t.order??0))}init(e){for(let t of this.plugins)t.init?.(e)}}class ee{constructor(e,t,n={}){this.codec=e,this.sender=t,new X(n.plugins).init(n),this.interceptors=r(n.interceptors),this.clientInterceptors=r(n.clientInterceptors)}interceptors;clientInterceptors;call(e,t,r){return l({name:`${n}.${e.join("/")}`,signal:r.signal},s=>(s?.setAttribute("rpc.system",n),s?.setAttribute("rpc.method",e.join(".")),h(t)&&(t=g({name:"consume_event_iterator_input",signal:r.signal},t)),v(this.interceptors,{...r,path:e,input:t},async({path:e,input:t,...r})=>{let n,a=i(),o=a?.trace.getActiveSpan()??s;o&&a&&(n=a?.trace.setSpan(a.context.active(),o));let c=await l({name:"encode_request",context:n},()=>this.codec.encode(e,t,r)),u=await v(this.clientInterceptors,{...r,input:t,path:e,request:c},({input:e,path:t,request:r,...s})=>l({name:"send_request",signal:s.signal,context:n},()=>this.sender.call(r,s,t,e))),d=await l({name:"decode_response",context:n},()=>this.codec.decode(u,r,e,t));return h(d)?g({name:"consume_event_iterator_output",signal:r.signal},d):d})))}}class et{customSerializers;constructor(e={}){if(this.customSerializers=e.customJsonSerializers??[],this.customSerializers.length!==new Set(this.customSerializers.map(e=>e.type)).size)throw Error("Custom serializer type must be unique.")}serialize(e,t=[],r=[],n=[],s=[]){for(let a of this.customSerializers)if(a.condition(e)){let i=this.serialize(a.serialize(e),t,r,n,s);return r.push([a.type,...t]),i}if(e instanceof Blob)return n.push(t),s.push(e),[e,r,n,s];if("bigint"==typeof e)return r.push([0,...t]),[e.toString(),r,n,s];if(e instanceof Date)return(r.push([1,...t]),Number.isNaN(e.getTime()))?[null,r,n,s]:[e.toISOString(),r,n,s];if(Number.isNaN(e))return r.push([2,...t]),[null,r,n,s];if(e instanceof URL)return r.push([4,...t]),[e.toString(),r,n,s];if(e instanceof RegExp)return r.push([5,...t]),[e.toString(),r,n,s];if(e instanceof Set){let a=this.serialize(Array.from(e),t,r,n,s);return r.push([6,...t]),a}if(e instanceof Map){let a=this.serialize(Array.from(e.entries()),t,r,n,s);return r.push([7,...t]),a}if(Array.isArray(e))return[e.map((e,a)=>void 0===e?(r.push([3,...t,a]),e):this.serialize(e,[...t,a],r,n,s)[0]),r,n,s];if(O(e)){let a={};for(let i in e)("toJSON"!==i||"function"!=typeof e[i])&&(a[i]=this.serialize(e[i],[...t,i],r,n,s)[0]);return[a,r,n,s]}return[e,r,n,s]}deserialize(e,t,r,n){let s={data:e};for(let e of(r&&n&&r.forEach((e,t)=>{let r=s,a="data";e.forEach(e=>{if(!Object.hasOwn(r=r[a],a=e))throw Error(`Security error: accessing non-existent path during deserialization. Path segment: ${a}`)}),r[a]=n(t)}),t)){let t=e[0],r=s,n="data";for(let t=1;t<e.length;t++)if(!Object.hasOwn(r=r[n],n=e[t]))throw Error(`Security error: accessing non-existent path during deserialization. Path segment: ${n}`);for(let e of this.customSerializers)if(e.type===t){r[n]=e.deserialize(r[n]);break}switch(t){case 0:r[n]=BigInt(r[n]);break;case 1:r[n]=new Date(r[n]??"Invalid Date");break;case 2:r[n]=NaN;break;case 3:r[n]=void 0;break;case 4:r[n]=new URL(r[n]);break;case 5:{let[,e,t]=r[n].match(/^\/(.*)\/([a-z]*)$/);r[n]=new RegExp(e,t);break}case 6:r[n]=new Set(r[n]);break;case 7:r[n]=new Map(r[n])}}return s.data}}class er{constructor(e,t){this.serializer=e,this.baseUrl=t.url,this.maxUrlLength=t.maxUrlLength??2083,this.fallbackMethod=t.fallbackMethod??"POST",this.expectedMethod=t.method??this.fallbackMethod,this.headers=t.headers??{}}baseUrl;maxUrlLength;fallbackMethod;expectedMethod;headers;async encode(e,t,n){var s;let a="function"==typeof(s=await R(this.headers,n,e,t)).forEach?Z(s):s;void 0!==n.lastEventId&&(a=function(e,t){let n={...e};for(let e in t)Array.isArray(t[e])?n[e]=[...r(n[e]),...t[e]]:void 0!==t[e]&&(Array.isArray(n[e])?n[e]=[...n[e],t[e]]:void 0!==n[e]?n[e]=[n[e],t[e]]:n[e]=t[e]);return n}(a,{"last-event-id":n.lastEventId}));let i=await R(this.expectedMethod,n,e,t),o=new URL(await R(this.baseUrl,n,e,t));o.pathname=`${o.pathname.replace(/\/$/,"")}/${e.map(encodeURIComponent).join("/")}`;let c=this.serializer.serialize(t);if("GET"===i&&!(c instanceof FormData)&&!h(c)){let r=await R(this.maxUrlLength,n,e,t),s=new URL(o);if(s.searchParams.append("data",b(c)),s.toString().length<=r)return{body:void 0,method:i,headers:a,url:s,signal:n.signal}}return{url:o,method:"GET"===i?this.fallbackMethod:i,headers:a,body:c,signal:n.signal}}async decode(e){let t=!D(e.status),r=await (async()=>{let t=!1;try{let r=await e.body();return t=!0,this.serializer.deserialize(r)}catch(e){if(!t)throw Error("Cannot parse response body, please check the response body and content-type.",{cause:e});throw Error("Invalid RPC response format.",{cause:e})}})();if(!t){var n;if(q(r))throw j(r);throw new P((n=e.status,Object.entries(N).find(([,e])=>e.status===n)?.[0]??"MALFORMED_ORPC_ERROR_RESPONSE"),{status:e.status,data:{...e,body:r}})}return r}}

9class en{constructor(e){this.jsonSerializer=e}serialize(e){return h(e)?V(e,{value:async e=>this.#s(e,!1),error:async e=>new $({data:this.#s((e instanceof P?e:new P("INTERNAL_SERVER_ERROR",{message:"Internal server error",cause:e})).toJSON(),!1),cause:e})}):this.#s(e,!0)}#s(e,t){let[r,n,s,a]=this.jsonSerializer.serialize(e),i=0===n.length?void 0:n;if(!t||0===a.length)return{json:r,meta:i};let o=new FormData;return o.set("data",b({json:r,meta:i,maps:s})),a.forEach((e,t)=>{o.set(t.toString(),e)}),o}deserialize(e){return h(e)?V(e,{value:async e=>this.#a(e),error:async e=>{if(!(e instanceof $))return e;let t=this.#a(e.data);return q(t)?j(t,{cause:e}):new $({data:t,cause:e})}}):this.#a(e)}#a(e){if(void 0===e)return;if(!(e instanceof FormData))return this.jsonSerializer.deserialize(e.json,e.meta??[]);let t=JSON.parse(e.get("data"));return this.jsonSerializer.deserialize(t.json,t.meta??[],t.maps,t=>e.get(t.toString()))}}class es extends ee{constructor(e,t){super(new er(new en(new et(t)),t),e,t)}}class ea extends X{initRuntimeAdapter(e){for(let t of this.plugins)t.initRuntimeAdapter?.(e)}}class ei{fetch;toFetchRequestOptions;adapterInterceptors;constructor(e){new ea(e.plugins).initRuntimeAdapter(e),this.fetch=e.fetch??globalThis.fetch.bind(globalThis),this.toFetchRequestOptions=e,this.adapterInterceptors=r(e.adapterInterceptors)}async call(e,t,r,n){let i=function(e,t={}){let r=function(e,t=new Headers){for(let[r,n]of Object.entries(e))if(Array.isArray(n))for(let e of n)t.append(r,e);else void 0!==n&&t.append(r,n);return t}(e.headers),n=function(e,t,r={}){let n=t.get("content-disposition");if(t.delete("content-type"),t.delete("content-disposition"),void 0!==e){if(e instanceof Blob){var s;let r,a;return t.set("content-type",e.type),t.set("content-length",e.size.toString()),t.set("content-disposition",n??(r=(s=e instanceof File?e.name:"blob").replace(/"/g,'\\"'),a=encodeURIComponent(s).replace(/['()*]/g,e=>`%${e.charCodeAt(0).toString(16).toUpperCase()}`).replace(/%(7C|60|5E)/g,(e,t)=>String.fromCharCode(Number.parseInt(t,16))),`inline; filename="${r}"; filename*=utf-8''${a}`)),e}return e instanceof FormData||e instanceof URLSearchParams?e:h(e)?(t.set("content-type","text/event-stream"),function(e,t={}){let r,n,s=t.eventIteratorKeepAliveEnabled??!0,a=t.eventIteratorKeepAliveInterval??5e3,i=t.eventIteratorKeepAliveComment??"",l=t.eventIteratorInitialCommentEnabled??!0,d=t.eventIteratorInitialComment??"",h=!1;return new ReadableStream({start(e){n=o("stream_event_iterator"),l&&e.enqueue(J({comments:[d]}))},async pull(t){try{s&&(r=setInterval(()=>{t.enqueue(J({comments:[i]})),n?.addEvent("keepalive")},a));let o=await u(n,()=>e.next());if(clearInterval(r),h)return;let c=H(o.value);if(!o.done||void 0!==o.value||void 0!==c){let e=o.done?"done":"message";t.enqueue(J({...c,event:e,data:b(o.value)})),n?.addEvent(e)}o.done&&(t.close(),n?.end())}catch(e){if(clearInterval(r),h)return;e instanceof $?(t.enqueue(J({...H(e),event:"error",data:b(e.data)})),n?.addEvent("error"),t.close()):(c(n,e),t.error(e)),n?.end()}},async cancel(){try{h=!0,clearInterval(r),n?.addEvent("cancelled"),await u(n,()=>e.return?.())}catch(e){throw c(n,e),e}finally{n?.end()}}}).pipeThrough(new TextEncoderStream)}(e,r)):(t.set("content-type","application/json"),b(e))}}(e.body,r,t);return new Request(e.url,{signal:e.signal,method:e.method,headers:r,body:n})}(e,this.toFetchRequestOptions);return function(e,t={}){return{body:a(()=>(function(e,t={}){return l({name:"parse_standard_body",signal:t.signal},async()=>{let r=e.headers.get("content-disposition");if("string"==typeof r){let t=function(e){let t=e.match(/filename\*=(UTF-8'')?([^;]*)/i);if(t&&"string"==typeof t[2])return _(t[2]);let r=e.match(/filename="((?:\\"|[^"])*)"/i);if(r&&"string"==typeof r[1])return r[1].replace(/\\"/g,'"')}(r)??"blob",n=await e.blob();return new File([n],t,{type:n.type})}let n=e.headers.get("content-type");if(!n||n.startsWith("application/json"))return E(await e.text());if(n.startsWith("multipart/form-data"))return await e.formData();if(n.startsWith("application/x-www-form-urlencoded"))return new URLSearchParams(await e.text());if(n.startsWith("text/event-stream"))return function(e,t={}){let r,n=e?.pipeThrough(new TextDecoderStream).pipeThrough(new F),a=n?.getReader(),i=!1;return new m(async()=>{r??=o("consume_event_iterator_stream");try{for(;;){if(void 0===a)return{done:!0,value:void 0};let{done:e,value:t}=await u(r,()=>a.read());if(e){if(i)throw new s("Stream was cancelled");return{done:!0,value:void 0}}switch(t.event){case"message":{let e=E(t.data);return I(e)&&(e=K(e,t)),r?.addEvent("message"),{done:!1,value:e}}case"error":{let e=new $({data:E(t.data)});throw e=K(e,t),r?.addEvent("error"),e}case"done":{let e=E(t.data);return I(e)&&(e=K(e,t)),r?.addEvent("done"),{done:!0,value:e}}default:r?.addEvent("maybe_keepalive")}}}catch(e){throw e instanceof $||c(r,e,t),e}},async e=>{try{"next"!==e&&(i=!0,r?.addEvent("cancelled")),await u(r,()=>a?.cancel())}catch(e){throw c(r,e,t),e}finally{r?.end()}})}(e.body,t);if(n.startsWith("text/plain"))return await e.text();let a=await e.blob();return new File([a],"blob",{type:a.type})})})(e,t)),status:e.status,get headers(){let t=Z(e.headers);return Object.defineProperty(this,"headers",{value:t,writable:!0}),t},set headers(value){Object.defineProperty(this,"headers",{value,writable:!0})}}}(await v(this.adapterInterceptors,{...t,request:i,path:r,input:n,init:{redirect:"manual"}},({request:e,path:t,input:r,init:n,...s})=>this.fetch(e,n,s,t,r)),{signal:i.signal})}}e.i(607316);let eo=Y(new class extends es{constructor(e){super(new ei(e),e)}}({url:"https://gqv.ai/api/rpc",headers:async()=>({}),interceptors:[w(e=>{e instanceof Error&&"AbortError"===e.name||console.error(e)})]}));e.s(["orpcClient",0,eo],399865)},735408,e=>{"use strict";var t=e.i(610753);e.s(["Loader2",()=>t.default])},532040,e=>{"use strict";var t=e.i(572188),r=e.i(399865),n=e.i(868729);function s(){let{user:e}=(0,t.useSession)(),s=(0,n.useQuery)({queryKey:["subscription","current"],queryFn:async()=>

9e?await r.orpcClient.subscriptions.getCurrent():null,staleTime:3e5,refetchOnWindowFocus:!0,enabled:!!e});return{...s,balance:s.data?.creditBalance??0,hasSubscription:s.data?.hasSubscription??!1}}function a(e=20,t=0){return(0,n.useQuery)({queryKey:["subscription","usage-history",e,t],queryFn:async()=>await r.orpcClient.subscriptions.getUsageHistory({limit:e,offset:t}),staleTime:6e4})}e.s(["useSubscription",()=>s,"useSubscriptionUsageHistory",()=>a])}]);