https://pockethost.io/_app/immutable/chunks/CmsztqYw.js

1import{B as e,C as t,E as n,H as r,S as i,V as a,l as o,o as s,v as c,x as l,y as u}from"./Du7Y30mz.js";async function d(e,t){let n=e.getReader(),r;for(;!(r=await n.read()).done;)t(r.value)}var f=function(e){return e[e.NewLine=10]=`NewLine`,e[e.CarriageReturn=13]=`CarriageReturn`,e[e.Space=32]=`Space`,e[e.Colon=58]=`Colon`,e}(f||{});function p(e){let t,n,r,i=!1;return function(a){t===void 0?(t=a,n=0,r=-1):t=h(t,a);let o=t.length,s=0;for(;n<o;){i&&=(t[n]===f.NewLine&&(s=++n),!1);let a=-1;for(;n<o&&a===-1;++n)switch(t[n]){case f.Colon:r===-1&&(r=n-s);break;case f.CarriageReturn:i=!0;case f.NewLine:a=n;break}if(a===-1)break;e(t.subarray(s,a),r),s=n,r=-1}s===o?t=void 0:s!==0&&(t=t.subarray(s),n-=s)}}function m(e,t,n){let r=g(),i=new TextDecoder;return function(a,o){if(a.length===0)n?.(r),r=g();else if(o>0){let n=i.decode(a.subarray(0,o)),s=o+(a[o+1]===f.Space?2:1),c=i.decode(a.subarray(s));switch(n){case`data`:r.data=r.data?r.data+`
2`+c:c;break;case`event`:r.event=c;break;case`id`:e(r.id=c);break;case`retry`:let n=parseInt(c,10);isNaN(n)||t(r.retry=n);break}}}}function h(e,t){let n=new Uint8Array(e.length+t.length);return n.set(e),n.set(t,e.length),n}function g(){return{data:``,event:``,id:``,retry:void 0}}var _=`text/event-stream`,v=1e3,y=`last-event-id`;function b(e,{signal:t,headers:n,onopen:r,onmessage:i,onclose:a,onerror:o,openWhenHidden:s,fetch:c,...l}){return new Promise((u,f)=>{let h={...n};h.accept||=_;let g;function b(){g.abort(),globalThis.document?.hidden||D()}globalThis.document&&!s&&globalThis.document?.addEventListener(`visibilitychange`,b);let S=v,C;function w(){globalThis.document?.removeEventListener(`visibilitychange`,b),globalThis.clearTimeout(C),g.abort()}t?.addEventListener(`abort`,()=>{w(),u()});let T=c??globalThis.fetch,E=r??x;async function D(){g&&g.abort(),g=new AbortController;try{let t=await T(e,{...l,headers:h,signal:g.signal});await E(t),await d(t.body,p(m(e=>{e?h[y]=e:delete h[y]},e=>{S=e},i))),a?.(),w(),u()}catch(e){if(!g.signal.aborted)try{let t=o?.(e)??S;globalThis.clearTimeout(C),C=globalThis.setTimeout(D,t)}catch(e){w(),f(e)}}}D()})}function x(e){let t=e.headers.get(`content-type`);if(!t?.startsWith(`text/event-stream`))throw Error(`Expected content-type to be ${_}, Actual: ${t}`)}var S=()=>{let e=0,t={};return[n=>{let r=e++;return t[r]=n,()=>{delete t[r]}},e=>{Object.values(t).forEach(t=>t(e))}]},C=o=>{let{url:d}=o,f=new a(d),{authStore:p}=f,m=()=>p.model,h=()=>p.isValid,g=()=>p.clear(),_=async(e,t)=>{let n={email:e,password:t,passwordConfirm:t},r=await f.collection(`users`).create(n);return await L(),r},v=async e=>await f.collection(`users`).confirmVerification(e),y=async e=>await f.collection(`users`).requestPasswordReset(e),x=async(e,t)=>await f.collection(`users`).confirmPasswordReset(e,t,t),C=async e=>{await f.collection(`users`).requestEmailChange(e)},w=async(e,t)=>{await f.collection(`users`).confirmEmailChange(e,t),f.authStore.clear()},T=async(e,t)=>await f.collection(`users`).authWithPassword(e,t),E=()=>f.collection(`users`).authRefresh(),{mkRest:D}=n({client:f}),O=D(c.Instance,u.Post,t),k=D(c.Instance,u.Put,l),A=D(c.Instance,u.Delete,i),j=async()=>f.send(`/api/user/trusted-ips`,{method:`GET`}),M=async e=>f.send(`/api/user/trusted-ips`,{method:`PATCH`,body:{trusted_ips:e}}),N=e=>f.collection(`instances`).getOne(e),P=e=>f.collection(`instances`).getFirstListItem(`subdomain='${e}'`),F=async()=>(await f.collection(`instances`).getFullList()).reduce((e,t)=>(e[t.id]=t,e),{}),I=e=>e instanceof r?e.data.message&&Object.keys(e.data.data).length===0?[e.data.message]:Object.values(e.data.data).map(e=>e?.message).filter(e=>!!e):[`${e}`],L=async()=>{let t=f.authStore.model;e(t,`Login required`),await f.collection(`users`).requestVerification(t.email)},R=()=>{let{isSuperuser:e,model:t,token:n,isValid:r}=f.authStore;if(e)throw Error(`Superuser models not supported`);if(t&&!t.email)throw Error(`Expected model to be a user here`);return{token:n,model:t,isValid:r}},[z,B]=S();{f.authStore.onChange(()=>{B(f.authStore)}),E().catch(e=>{f.authStore.clear()}).finally(()=>{B(f.authStore)});let e=z(t=>{let{model:n,isSuperuser:r}=t;if(n&&!r){if(n.verified){e();return}setTimeout(E,1e3)}})}return{client:f,watchInstanceLog:(e,t,n=100)=>{let r=f.authStore.exportToCookie(),i=new AbortController,a=i.signal,o=()=>{let i=s(e,`logs`);b(i,{method:`POST`,headers:{"Content-Type":`application/json`,Authorization:f.authStore.token},openWhenHidden:!0,body:JSON.stringify({instanceId:e.id,n,auth:r}),onmessage:e=>{let{}=e;t(JSON.parse(e.data))},onopen:async e=>{if(!e.ok)throw Error(`Log stream failed: ${e.status} ${e.statusText}`)},onerror:e=>{console.error(`Log stream error (${i}):`,e)},onclose:()=>{setTimeout(o,100)},signal:a})};return o(),()=>{i.abort()}},getAuthStoreProps:R,parseError:I,getInstanceById:N,getInstanceBySubdomain:P,createInstance:O,authViaEmail:T,createUser:_,requestPasswordReset:y,requestPasswordResetConfirm:x,requestEmailChange:C,confirmEmailChange:w,confirmVerification:v,logOut:g,onAuthChange:z,isLoggedIn:h,user:m,getAllInstancesById:F,resendVerificationEmail

2:L,updateInstance:k,deleteInstance:A,getTrustedIps:j,updateTrustedIps:M}},w=(()=>{let e;return()=>e||(e=C({url:o}),e)})();export{w as t};