@elysiajs/eden
Advanced tools
Comparing version 1.0.5 to 1.0.6
@@ -69,2 +69,3 @@ import { InputSchema, Elysia } from 'elysia'; | ||
onResponse?: MaybeArray<(response: Response) => MaybePromise<unknown>>; | ||
keepDomain?: boolean; | ||
} | ||
@@ -71,0 +72,0 @@ type TreatyResponse<Res extends Record<number, unknown>> = { |
@@ -1,1 +0,1 @@ | ||
"use strict";var Eden=(()=>{var P=Object.defineProperty;var Y=Object.getOwnPropertyDescriptor;var ee=Object.getOwnPropertyNames;var te=Object.prototype.hasOwnProperty;var re=(t,e)=>{for(var r in e)P(t,r,{get:e[r],enumerable:!0})},ne=(t,e,r,a)=>{if(e&&typeof e=="object"||typeof e=="function")for(let f of ee(e))!te.call(t,f)&&f!==r&&P(t,f,{get:()=>e[f],enumerable:!(a=Y(e,f))||a.enumerable});return t};var se=t=>ne(P({},"__esModule",{value:!0}),t);var ue={};re(ue,{edenFetch:()=>X,edenTreaty:()=>Q,treaty:()=>Z});var U=(t,e,r)=>{if(t.endsWith("/")||(t+="/"),e==="index"&&(e=""),!r||!Object.keys(r).length)return`${t}${e}`;let a="";for(let[f,n]of Object.entries(r))a+=`${f}=${n}&`;return`${t}${e}?${a.slice(0,-1)}`},x=t=>t.trim().length!==0&&!Number.isNaN(Number(t));var A=class extends Error{constructor(r,a){super(a+"");this.status=r;this.value=a}};var N=class{constructor(e){this.url=e;this.ws=new WebSocket(e)}ws;send(e){return Array.isArray(e)?(e.forEach(r=>this.send(r)),this):(this.ws.send(typeof e=="object"?JSON.stringify(e):e.toString()),this)}on(e,r,a){return this.addEventListener(e,r,a)}off(e,r,a){return this.ws.removeEventListener(e,r,a),this}subscribe(e,r){return this.addEventListener("message",e,r)}addEventListener(e,r,a){return this.ws.addEventListener(e,f=>{if(e==="message"){let n=f.data.toString(),i=n.charCodeAt(0);if(i===47||i===123)try{n=JSON.parse(n)}catch{}else x(n)?n=+n:n==="true"?n=!0:n==="false"&&(n=!1);r({...f,data:n})}else r(f)},a),this}removeEventListener(e,r,a){return this.off(e,r,a),this}close(){return this.ws.close(),this}};var ae=["get","post","put","delete","patch","options","head","connect","subscribe"],G=["localhost","127.0.0.1","0.0.0.0"],D=typeof FileList>"u",ie=/(\d{4}-[01]\d-[0-3]\dT[0-2]\d:[0-5]\d:[0-5]\d\.\d+([+-][0-2]\d:[0-5]\d|Z))|(\d{4}-[01]\d-[0-3]\dT[0-2]\d:[0-5]\d:[0-5]\d([+-][0-2]\d:[0-5]\d|Z))|(\d{4}-[01]\d-[0-3]\dT[0-2]\d:[0-5]\d([+-][0-2]\d:[0-5]\d|Z))/,oe=/(?:Sun|Mon|Tue|Wed|Thu|Fri|Sat)\s(?:Jan|Feb|Mar|Apr|May|Jun|Jul|Aug|Sep|Oct|Nov|Dec)\s\d{2}\s\d{4}\s\d{2}:\d{2}:\d{2}\sGMT(?:\+|-)\d{4}\s\([^)]+\)/,ce=/^(?:(?:(?:(?:0?[1-9]|[12][0-9]|3[01])[/\s-](?:0?[1-9]|1[0-2])[/\s-](?:19|20)\d{2})|(?:(?:19|20)\d{2}[/\s-](?:0?[1-9]|1[0-2])[/\s-](?:0?[1-9]|[12][0-9]|3[01]))))(?:\s(?:1[012]|0?[1-9]):[0-5][0-9](?::[0-5][0-9])?(?:\s[AP]M)?)?$/,_=t=>D?t instanceof Blob:t instanceof FileList||t instanceof File,fe=t=>{if(!t)return!1;for(let e in t)if(_(t[e])||Array.isArray(t[e])&&t[e].find(_))return!0;return!1},q=t=>D?t:new Promise(e=>{let r=new FileReader;r.onload=()=>{let a=new File([r.result],t.name,{lastModified:t.lastModified,type:t.type});e(a)},r.readAsArrayBuffer(t)}),M=(t,e,r=[],a)=>new Proxy(()=>{},{get(f,n){return M(t,e,n==="index"?r:[...r,n],a)},apply(f,n,[i,p]){if(!i||p||typeof i=="object"&&Object.keys(i).length!==1||ae.includes(r.at(-1))){let k=r.pop(),S="/"+r.join("/"),{fetcher:F=fetch,headers:s,onRequest:m,onResponse:g,fetch:K}=e,T=k==="get"||k==="head"||k==="subscribe";s={...typeof s=="object"&&!Array.isArray(s)?s:{},...T?i?.headers:p?.headers};let L=T?i?.query:p?.query,R="";if(L)for(let[c,u]of Object.entries(L))R+=(R?"&":"?")+`${c}=${u}`;if(typeof e.headers=="function"&&!(s instanceof Headers)){let c=e.headers(S,p??{});c&&(s={...s,...c})}else if(Array.isArray(e.headers)&&e.headers.every(c=>typeof c=="function"))for(let c of e.headers){let u=c(S,p??{});u&&(s={...s,...u})}else if(s instanceof Headers){s||(s={});for(let[c,u]of Object.entries(s))s[c]=u}if(k==="subscribe"){let c=t.replace(/^([^]+):\/\//,t.startsWith("https://")?"wss://":t.startsWith("http://")||G.find(u=>t.includes(u))?"ws://":"wss://")+S+R;return new N(c)}return(async()=>{let c=(s instanceof Headers?s.get("content-type"):Array.isArray(s)?s.find(o=>Array.isArray(o)&&o[0]==="headers"?o[1]:!1):typeof s=="function"?s(S,p??{}):s?.contentType)||p?.headers?.contentType;if(!c)if(typeof i=="object")c="application/json",i=JSON.stringify(i);else if(fe(i)){let o=new FormData;for(let[l,h]of Object.entries(i)){if(D){o.append(l,h);continue}if(h instanceof File){o.append(l,await q(h));continue}if(h instanceof FileList){for(let d=0;d<h.length;d++)o.append(l,await q(h[d]));continue}if(Array.isArray(h)){for(let d=0;d<h.length;d++){let b=h[d];o.append(l,b instanceof File?await q(b):b)}continue}o.append(l,h)}i=o}else i!=null&&(c="text/plain");let u={method:k,body:i,...K,headers:{...s,"content-type":c}};if(T&&delete u.body,m){Array.isArray(m)||(m=[m]);for(let o of m){let l=await o(S,u);typeof l=="object"&&(u={...u,...l,headers:{...u.headers,...l.headers}})}}let C=t+S+R,E=await(a?.handle(new Request(C,u))??F(C,u)),y=null,O;if(g){Array.isArray(g)||(g=[g]);for(let o of g)try{if(y=await o(E.clone()),y!=null)break}catch(l){l instanceof A?O=l:O=new A(422,l);break}}if(y===null){switch(E.headers.get("Content-Type")?.split(";")[0]){case"application/json":y=await E.json();break;case"application/octet-stream":y=await E.arrayBuffer();break;default:y=await E.text().then(o=>{if(x(o))return+o;if(o==="true")return!0;if(o==="false")return!1;if(!o)return o;let l=o.replace(/"/g,"");if(ie.test(l)||oe.test(l)||ce.test(l)){let h=new Date(l);if(!Number.isNaN(h.getTime()))return h}return o})}(E.status>=300||E.status<200)&&(O=new A(E.status,y),y=null)}return{data:y,error:O,response:E,status:E.status,headers:E.headers}})()}return typeof i=="object"?M(t,e,[...r,Object.values(i)[0]],a):M(t,e,r)}}),Z=(t,e={})=>typeof t=="string"?(t.includes("://")||(t=(G.find(r=>t.includes(r))?"http://":"https://")+t),t.endsWith("/")&&(t=t.slice(0,-1)),M(t,e)):(typeof window<"u"&&console.warn("Elysia instance server found on client side, this is not recommended for security reason. Use generic type instead."),M("http://e.ly",e,[],t));var B=typeof FileList>"u",V=t=>B?t instanceof Blob:t instanceof FileList||t instanceof File,ye=t=>{if(!t)return!1;for(let e in t){if(V(t[e]))return!0;if(Array.isArray(t[e])&&t[e].find(r=>V(r)))return!0}return!1},J=t=>B?t:new Promise(e=>{let r=new FileReader;r.onload=()=>{let a=new File([r.result],t.name,{lastModified:t.lastModified,type:t.type});e(a)},r.readAsArrayBuffer(t)}),H=class{ws;url;constructor(e){this.ws=new WebSocket(e),this.url=e}send(e){return Array.isArray(e)?(e.forEach(r=>this.send(r)),this):(this.ws.send(typeof e=="object"?JSON.stringify(e):e.toString()),this)}on(e,r,a){return this.addEventListener(e,r,a)}off(e,r,a){return this.ws.removeEventListener(e,r,a),this}subscribe(e,r){return this.addEventListener("message",e,r)}addEventListener(e,r,a){return this.ws.addEventListener(e,f=>{if(e==="message"){let n=f.data.toString(),i=n.charCodeAt(0);if(i===47||i===123)try{n=JSON.parse(n)}catch{}else x(n)?n=+n:n==="true"?n=!0:n==="false"&&(n=!1);r({...f,data:n})}else r(f)},a),this}removeEventListener(e,r,a){return this.off(e,r,a),this}close(){return this.ws.close(),this}},z=(t,e="",r)=>new Proxy(()=>{},{get(a,f,n){return z(t,`${e}/${f.toString()}`,r)},apply(a,f,[n,i={}]=[{},{}]){let p=n!==void 0&&(typeof n!="object"||Array.isArray(n))?n:void 0,{$query:k,$fetch:S,$headers:F,$transform:s,getRaw:m,...g}=n??{};p??=g;let K=e.lastIndexOf("/"),T=e.slice(K+1).toUpperCase(),L=U(t,K===-1?"/":e.slice(0,K),Object.assign(i.query??{},k)),R=r.fetcher??fetch,c=r.transform?Array.isArray(r.transform)?r.transform:[r.transform]:void 0,u=s?Array.isArray(s)?s:[s]:void 0;return u&&(c?c=u.concat(c):c=u),T==="SUBSCRIBE"?new H(L.replace(/^([^]+):\/\//,L.startsWith("https://")?"wss://":"ws://")):(async E=>{let y,O={...r.$fetch?.headers,...S?.headers,...i.headers,...F};if(T!=="GET"&&T!=="HEAD"){y=Object.keys(p).length||Array.isArray(p)?p:void 0;let d=y&&(typeof y=="object"||Array.isArray(p));if(d&&ye(y)){let j=new FormData;for(let[$,v]of Object.entries(y))if(B)j.append($,v);else if(v instanceof File)j.append($,await J(v));else if(v instanceof FileList)for(let W=0;W<v.length;W++)j.append($,await J(v[W]));else if(Array.isArray(v))for(let W=0;W<v.length;W++){let I=v[W];j.append($,I instanceof File?await J(I):I)}else j.append($,v);y=j}else y!=null&&(O["content-type"]=d?"application/json":"text/plain",y=d?JSON.stringify(y):p)}let w=await R(L,{method:T,body:y,...r.$fetch,...i.fetch,...S,headers:O}),o;if(E.getRaw)return w;switch(w.headers.get("Content-Type")?.split(";")[0]){case"application/json":o=await w.json();break;default:o=await w.text().then(d=>x(d)?+d:d==="true"?!0:d==="false"?!1:d)}let l=w.status>=300||w.status<200?new A(w.status,o):null,h={data:o,error:l,response:w,status:w.status,headers:w.headers};if(c)for(let d of c){let b=d(h);b instanceof Promise&&(b=await b),b!=null&&(h=b)}return h})({getRaw:m})}}),Q=(t,e={fetcher:fetch})=>new Proxy({},{get(r,a){return z(t,a,e)}});var X=(t,e)=>(r,{query:a,params:f,body:n,...i}={})=>{f&&Object.entries(f).forEach(([s,m])=>{r=r.replace(`:${s}`,m)});let p=i.headers?.["Content-Type"];if(!p||p==="application/json")try{n=JSON.stringify(n)}catch{}let k=e?.fetcher||globalThis.fetch,S=a?`?${new URLSearchParams(a).toString()}`:"",F=()=>k(t+r+S,{...i,method:i.method?.toUpperCase()||"GET",headers:n?{"content-type":"application/json",...i.headers}:i.headers,body:n}).then(async s=>{let m;switch(s.headers.get("Content-Type")?.split(";")[0]){case"application/json":m=await s.json();break;default:m=await s.text().then(g=>x(g)?parseInt(g):g==="true"?!0:g==="false"?!1:g);break}return s.status>300?{data:null,status:s.status,headers:s.headers,retry:F,error:new A(s.status,m)}:{data:m,error:null,status:s.status,headers:s.headers,retry:F}});return F()};return se(ue);})(); | ||
"use strict";var Eden=(()=>{var P=Object.defineProperty;var Y=Object.getOwnPropertyDescriptor;var ee=Object.getOwnPropertyNames;var te=Object.prototype.hasOwnProperty;var re=(t,e)=>{for(var r in e)P(t,r,{get:e[r],enumerable:!0})},ne=(t,e,r,a)=>{if(e&&typeof e=="object"||typeof e=="function")for(let f of ee(e))!te.call(t,f)&&f!==r&&P(t,f,{get:()=>e[f],enumerable:!(a=Y(e,f))||a.enumerable});return t};var se=t=>ne(P({},"__esModule",{value:!0}),t);var ue={};re(ue,{edenFetch:()=>X,edenTreaty:()=>Q,treaty:()=>Z});var B=(t,e,r)=>{if(t.endsWith("/")||(t+="/"),e==="index"&&(e=""),!r||!Object.keys(r).length)return`${t}${e}`;let a="";for(let[f,n]of Object.entries(r))a+=`${f}=${n}&`;return`${t}${e}?${a.slice(0,-1)}`},T=t=>t.trim().length!==0&&!Number.isNaN(Number(t));var A=class extends Error{constructor(r,a){super(a+"");this.status=r;this.value=a}};var N=class{constructor(e){this.url=e;this.ws=new WebSocket(e)}ws;send(e){return Array.isArray(e)?(e.forEach(r=>this.send(r)),this):(this.ws.send(typeof e=="object"?JSON.stringify(e):e.toString()),this)}on(e,r,a){return this.addEventListener(e,r,a)}off(e,r,a){return this.ws.removeEventListener(e,r,a),this}subscribe(e,r){return this.addEventListener("message",e,r)}addEventListener(e,r,a){return this.ws.addEventListener(e,f=>{if(e==="message"){let n=f.data.toString(),i=n.charCodeAt(0);if(i===47||i===123)try{n=JSON.parse(n)}catch{}else T(n)?n=+n:n==="true"?n=!0:n==="false"&&(n=!1);r({...f,data:n})}else r(f)},a),this}removeEventListener(e,r,a){return this.off(e,r,a),this}close(){return this.ws.close(),this}};var ae=["get","post","put","delete","patch","options","head","connect","subscribe"],G=["localhost","127.0.0.1","0.0.0.0"],D=typeof FileList>"u",ie=/(\d{4}-[01]\d-[0-3]\dT[0-2]\d:[0-5]\d:[0-5]\d\.\d+([+-][0-2]\d:[0-5]\d|Z))|(\d{4}-[01]\d-[0-3]\dT[0-2]\d:[0-5]\d:[0-5]\d([+-][0-2]\d:[0-5]\d|Z))|(\d{4}-[01]\d-[0-3]\dT[0-2]\d:[0-5]\d([+-][0-2]\d:[0-5]\d|Z))/,oe=/(?:Sun|Mon|Tue|Wed|Thu|Fri|Sat)\s(?:Jan|Feb|Mar|Apr|May|Jun|Jul|Aug|Sep|Oct|Nov|Dec)\s\d{2}\s\d{4}\s\d{2}:\d{2}:\d{2}\sGMT(?:\+|-)\d{4}\s\([^)]+\)/,ce=/^(?:(?:(?:(?:0?[1-9]|[12][0-9]|3[01])[/\s-](?:0?[1-9]|1[0-2])[/\s-](?:19|20)\d{2})|(?:(?:19|20)\d{2}[/\s-](?:0?[1-9]|1[0-2])[/\s-](?:0?[1-9]|[12][0-9]|3[01]))))(?:\s(?:1[012]|0?[1-9]):[0-5][0-9](?::[0-5][0-9])?(?:\s[AP]M)?)?$/,_=t=>D?t instanceof Blob:t instanceof FileList||t instanceof File,fe=t=>{if(!t)return!1;for(let e in t)if(_(t[e])||Array.isArray(t[e])&&t[e].find(_))return!0;return!1},q=t=>D?t:new Promise(e=>{let r=new FileReader;r.onload=()=>{let a=new File([r.result],t.name,{lastModified:t.lastModified,type:t.type});e(a)},r.readAsArrayBuffer(t)}),$=(t,e,r=[],a)=>new Proxy(()=>{},{get(f,n){return $(t,e,n==="index"?r:[...r,n],a)},apply(f,n,[i,p]){if(!i||p||typeof i=="object"&&Object.keys(i).length!==1||ae.includes(r.at(-1))){let k=r.pop(),w="/"+r.join("/"),{fetcher:F=fetch,headers:s,onRequest:m,onResponse:g,fetch:M}=e,x=k==="get"||k==="head"||k==="subscribe";s={...typeof s=="object"&&!Array.isArray(s)?s:{},...x?i?.headers:p?.headers};let L=x?i?.query:p?.query,R="";if(L)for(let[c,u]of Object.entries(L))R+=(R?"&":"?")+`${c}=${u}`;if(typeof e.headers=="function"&&!(s instanceof Headers)){let c=e.headers(w,p??{});c&&(s={...s,...c})}else if(Array.isArray(e.headers)&&e.headers.every(c=>typeof c=="function"))for(let c of e.headers){let u=c(w,p??{});u&&(s={...s,...u})}else if(s instanceof Headers){s||(s={});for(let[c,u]of Object.entries(s))s[c]=u}if(k==="subscribe"){let c=t.replace(/^([^]+):\/\//,t.startsWith("https://")?"wss://":t.startsWith("http://")||G.find(u=>t.includes(u))?"ws://":"wss://")+w+R;return new N(c)}return(async()=>{let c=(s instanceof Headers?s.get("content-type"):Array.isArray(s)?s.find(o=>Array.isArray(o)&&o[0]==="headers"?o[1]:!1):typeof s=="function"?s(w,p??{}):s?.contentType)||p?.headers?.contentType;if(!c)if(typeof i=="object")c="application/json",i=JSON.stringify(i);else if(fe(i)){let o=new FormData;for(let[l,h]of Object.entries(i)){if(D){o.append(l,h);continue}if(h instanceof File){o.append(l,await q(h));continue}if(h instanceof FileList){for(let d=0;d<h.length;d++)o.append(l,await q(h[d]));continue}if(Array.isArray(h)){for(let d=0;d<h.length;d++){let b=h[d];o.append(l,b instanceof File?await q(b):b)}continue}o.append(l,h)}i=o}else i!=null&&(c="text/plain");let u={method:k?.toUpperCase(),body:i,...M,headers:{...s,"content-type":c}};if(x&&delete u.body,m){Array.isArray(m)||(m=[m]);for(let o of m){let l=await o(w,u);typeof l=="object"&&(u={...u,...l,headers:{...u.headers,...l.headers}})}}let C=t+w+R,E=await(a?.handle(new Request(C,u))??F(C,u)),y=null,O=null;if(g){Array.isArray(g)||(g=[g]);for(let o of g)try{if(y=await o(E.clone()),y!=null)break}catch(l){l instanceof A?O=l:O=new A(422,l);break}}if(y===null){switch(E.headers.get("Content-Type")?.split(";")[0]){case"application/json":y=await E.json();break;case"application/octet-stream":y=await E.arrayBuffer();break;default:y=await E.text().then(o=>{if(T(o))return+o;if(o==="true")return!0;if(o==="false")return!1;if(!o)return o;let l=o.replace(/"/g,"");if(ie.test(l)||oe.test(l)||ce.test(l)){let h=new Date(l);if(!Number.isNaN(h.getTime()))return h}return o})}(E.status>=300||E.status<200)&&(O=new A(E.status,y),y=null)}return{data:y,error:O,response:E,status:E.status,headers:E.headers}})()}return typeof i=="object"?$(t,e,[...r,Object.values(i)[0]],a):$(t,e,r)}}),Z=(t,e={})=>typeof t=="string"?(e.keepDomain||(t.includes("://")||(t=(G.find(r=>t.includes(r))?"http://":"https://")+t),t.endsWith("/")&&(t=t.slice(0,-1))),$(t,e)):(typeof window<"u"&&console.warn("Elysia instance server found on client side, this is not recommended for security reason. Use generic type instead."),$("http://e.ly",e,[],t));var U=typeof FileList>"u",V=t=>U?t instanceof Blob:t instanceof FileList||t instanceof File,ye=t=>{if(!t)return!1;for(let e in t){if(V(t[e]))return!0;if(Array.isArray(t[e])&&t[e].find(r=>V(r)))return!0}return!1},J=t=>U?t:new Promise(e=>{let r=new FileReader;r.onload=()=>{let a=new File([r.result],t.name,{lastModified:t.lastModified,type:t.type});e(a)},r.readAsArrayBuffer(t)}),H=class{ws;url;constructor(e){this.ws=new WebSocket(e),this.url=e}send(e){return Array.isArray(e)?(e.forEach(r=>this.send(r)),this):(this.ws.send(typeof e=="object"?JSON.stringify(e):e.toString()),this)}on(e,r,a){return this.addEventListener(e,r,a)}off(e,r,a){return this.ws.removeEventListener(e,r,a),this}subscribe(e,r){return this.addEventListener("message",e,r)}addEventListener(e,r,a){return this.ws.addEventListener(e,f=>{if(e==="message"){let n=f.data.toString(),i=n.charCodeAt(0);if(i===47||i===123)try{n=JSON.parse(n)}catch{}else T(n)?n=+n:n==="true"?n=!0:n==="false"&&(n=!1);r({...f,data:n})}else r(f)},a),this}removeEventListener(e,r,a){return this.off(e,r,a),this}close(){return this.ws.close(),this}},z=(t,e="",r)=>new Proxy(()=>{},{get(a,f,n){return z(t,`${e}/${f.toString()}`,r)},apply(a,f,[n,i={}]=[{},{}]){let p=n!==void 0&&(typeof n!="object"||Array.isArray(n))?n:void 0,{$query:k,$fetch:w,$headers:F,$transform:s,getRaw:m,...g}=n??{};p??=g;let M=e.lastIndexOf("/"),x=e.slice(M+1).toUpperCase(),L=B(t,M===-1?"/":e.slice(0,M),Object.assign(i.query??{},k)),R=r.fetcher??fetch,c=r.transform?Array.isArray(r.transform)?r.transform:[r.transform]:void 0,u=s?Array.isArray(s)?s:[s]:void 0;return u&&(c?c=u.concat(c):c=u),x==="SUBSCRIBE"?new H(L.replace(/^([^]+):\/\//,L.startsWith("https://")?"wss://":"ws://")):(async E=>{let y,O={...r.$fetch?.headers,...w?.headers,...i.headers,...F};if(x!=="GET"&&x!=="HEAD"){y=Object.keys(p).length||Array.isArray(p)?p:void 0;let d=y&&(typeof y=="object"||Array.isArray(p));if(d&&ye(y)){let j=new FormData;for(let[K,v]of Object.entries(y))if(U)j.append(K,v);else if(v instanceof File)j.append(K,await J(v));else if(v instanceof FileList)for(let W=0;W<v.length;W++)j.append(K,await J(v[W]));else if(Array.isArray(v))for(let W=0;W<v.length;W++){let I=v[W];j.append(K,I instanceof File?await J(I):I)}else j.append(K,v);y=j}else y!=null&&(O["content-type"]=d?"application/json":"text/plain",y=d?JSON.stringify(y):p)}let S=await R(L,{method:x,body:y,...r.$fetch,...i.fetch,...w,headers:O}),o;if(E.getRaw)return S;switch(S.headers.get("Content-Type")?.split(";")[0]){case"application/json":o=await S.json();break;default:o=await S.text().then(d=>T(d)?+d:d==="true"?!0:d==="false"?!1:d)}let l=S.status>=300||S.status<200?new A(S.status,o):null,h={data:o,error:l,response:S,status:S.status,headers:S.headers};if(c)for(let d of c){let b=d(h);b instanceof Promise&&(b=await b),b!=null&&(h=b)}return h})({getRaw:m})}}),Q=(t,e={fetcher:fetch})=>new Proxy({},{get(r,a){return z(t,a,e)}});var X=(t,e)=>(r,{query:a,params:f,body:n,...i}={})=>{f&&Object.entries(f).forEach(([s,m])=>{r=r.replace(`:${s}`,m)});let p=i.headers?.["Content-Type"];if(!p||p==="application/json")try{n=JSON.stringify(n)}catch{}let k=e?.fetcher||globalThis.fetch,w=a?`?${new URLSearchParams(a).toString()}`:"",F=()=>k(t+r+w,{...i,method:i.method?.toUpperCase()||"GET",headers:n?{"content-type":"application/json",...i.headers}:i.headers,body:n}).then(async s=>{let m;switch(s.headers.get("Content-Type")?.split(";")[0]){case"application/json":m=await s.json();break;default:m=await s.text().then(g=>T(g)?parseInt(g):g==="true"?!0:g==="false"?!1:g);break}return s.status>300?{data:null,status:s.status,headers:s.headers,retry:F,error:new A(s.status,m)}:{data:m,error:null,status:s.status,headers:s.headers,retry:F}});return F()};return se(ue);})(); |
@@ -1,1 +0,1 @@ | ||
"use strict";var P=Object.defineProperty;var Y=Object.getOwnPropertyDescriptor;var ee=Object.getOwnPropertyNames;var te=Object.prototype.hasOwnProperty;var re=(t,e)=>{for(var r in e)P(t,r,{get:e[r],enumerable:!0})},ne=(t,e,r,a)=>{if(e&&typeof e=="object"||typeof e=="function")for(let f of ee(e))!te.call(t,f)&&f!==r&&P(t,f,{get:()=>e[f],enumerable:!(a=Y(e,f))||a.enumerable});return t};var se=t=>ne(P({},"__esModule",{value:!0}),t);var ue={};re(ue,{edenFetch:()=>X,edenTreaty:()=>Q,treaty:()=>Z});module.exports=se(ue);var U=(t,e,r)=>{if(t.endsWith("/")||(t+="/"),e==="index"&&(e=""),!r||!Object.keys(r).length)return`${t}${e}`;let a="";for(let[f,n]of Object.entries(r))a+=`${f}=${n}&`;return`${t}${e}?${a.slice(0,-1)}`},x=t=>t.trim().length!==0&&!Number.isNaN(Number(t));var A=class extends Error{constructor(r,a){super(a+"");this.status=r;this.value=a}};var N=class{constructor(e){this.url=e;this.ws=new WebSocket(e)}ws;send(e){return Array.isArray(e)?(e.forEach(r=>this.send(r)),this):(this.ws.send(typeof e=="object"?JSON.stringify(e):e.toString()),this)}on(e,r,a){return this.addEventListener(e,r,a)}off(e,r,a){return this.ws.removeEventListener(e,r,a),this}subscribe(e,r){return this.addEventListener("message",e,r)}addEventListener(e,r,a){return this.ws.addEventListener(e,f=>{if(e==="message"){let n=f.data.toString(),i=n.charCodeAt(0);if(i===47||i===123)try{n=JSON.parse(n)}catch{}else x(n)?n=+n:n==="true"?n=!0:n==="false"&&(n=!1);r({...f,data:n})}else r(f)},a),this}removeEventListener(e,r,a){return this.off(e,r,a),this}close(){return this.ws.close(),this}};var ae=["get","post","put","delete","patch","options","head","connect","subscribe"],G=["localhost","127.0.0.1","0.0.0.0"],D=typeof FileList>"u",ie=/(\d{4}-[01]\d-[0-3]\dT[0-2]\d:[0-5]\d:[0-5]\d\.\d+([+-][0-2]\d:[0-5]\d|Z))|(\d{4}-[01]\d-[0-3]\dT[0-2]\d:[0-5]\d:[0-5]\d([+-][0-2]\d:[0-5]\d|Z))|(\d{4}-[01]\d-[0-3]\dT[0-2]\d:[0-5]\d([+-][0-2]\d:[0-5]\d|Z))/,oe=/(?:Sun|Mon|Tue|Wed|Thu|Fri|Sat)\s(?:Jan|Feb|Mar|Apr|May|Jun|Jul|Aug|Sep|Oct|Nov|Dec)\s\d{2}\s\d{4}\s\d{2}:\d{2}:\d{2}\sGMT(?:\+|-)\d{4}\s\([^)]+\)/,ce=/^(?:(?:(?:(?:0?[1-9]|[12][0-9]|3[01])[/\s-](?:0?[1-9]|1[0-2])[/\s-](?:19|20)\d{2})|(?:(?:19|20)\d{2}[/\s-](?:0?[1-9]|1[0-2])[/\s-](?:0?[1-9]|[12][0-9]|3[01]))))(?:\s(?:1[012]|0?[1-9]):[0-5][0-9](?::[0-5][0-9])?(?:\s[AP]M)?)?$/,_=t=>D?t instanceof Blob:t instanceof FileList||t instanceof File,fe=t=>{if(!t)return!1;for(let e in t)if(_(t[e])||Array.isArray(t[e])&&t[e].find(_))return!0;return!1},q=t=>D?t:new Promise(e=>{let r=new FileReader;r.onload=()=>{let a=new File([r.result],t.name,{lastModified:t.lastModified,type:t.type});e(a)},r.readAsArrayBuffer(t)}),M=(t,e,r=[],a)=>new Proxy(()=>{},{get(f,n){return M(t,e,n==="index"?r:[...r,n],a)},apply(f,n,[i,p]){if(!i||p||typeof i=="object"&&Object.keys(i).length!==1||ae.includes(r.at(-1))){let k=r.pop(),S="/"+r.join("/"),{fetcher:F=fetch,headers:s,onRequest:m,onResponse:g,fetch:K}=e,T=k==="get"||k==="head"||k==="subscribe";s={...typeof s=="object"&&!Array.isArray(s)?s:{},...T?i?.headers:p?.headers};let L=T?i?.query:p?.query,R="";if(L)for(let[c,u]of Object.entries(L))R+=(R?"&":"?")+`${c}=${u}`;if(typeof e.headers=="function"&&!(s instanceof Headers)){let c=e.headers(S,p??{});c&&(s={...s,...c})}else if(Array.isArray(e.headers)&&e.headers.every(c=>typeof c=="function"))for(let c of e.headers){let u=c(S,p??{});u&&(s={...s,...u})}else if(s instanceof Headers){s||(s={});for(let[c,u]of Object.entries(s))s[c]=u}if(k==="subscribe"){let c=t.replace(/^([^]+):\/\//,t.startsWith("https://")?"wss://":t.startsWith("http://")||G.find(u=>t.includes(u))?"ws://":"wss://")+S+R;return new N(c)}return(async()=>{let c=(s instanceof Headers?s.get("content-type"):Array.isArray(s)?s.find(o=>Array.isArray(o)&&o[0]==="headers"?o[1]:!1):typeof s=="function"?s(S,p??{}):s?.contentType)||p?.headers?.contentType;if(!c)if(typeof i=="object")c="application/json",i=JSON.stringify(i);else if(fe(i)){let o=new FormData;for(let[l,h]of Object.entries(i)){if(D){o.append(l,h);continue}if(h instanceof File){o.append(l,await q(h));continue}if(h instanceof FileList){for(let d=0;d<h.length;d++)o.append(l,await q(h[d]));continue}if(Array.isArray(h)){for(let d=0;d<h.length;d++){let b=h[d];o.append(l,b instanceof File?await q(b):b)}continue}o.append(l,h)}i=o}else i!=null&&(c="text/plain");let u={method:k,body:i,...K,headers:{...s,"content-type":c}};if(T&&delete u.body,m){Array.isArray(m)||(m=[m]);for(let o of m){let l=await o(S,u);typeof l=="object"&&(u={...u,...l,headers:{...u.headers,...l.headers}})}}let C=t+S+R,E=await(a?.handle(new Request(C,u))??F(C,u)),y=null,O;if(g){Array.isArray(g)||(g=[g]);for(let o of g)try{if(y=await o(E.clone()),y!=null)break}catch(l){l instanceof A?O=l:O=new A(422,l);break}}if(y===null){switch(E.headers.get("Content-Type")?.split(";")[0]){case"application/json":y=await E.json();break;case"application/octet-stream":y=await E.arrayBuffer();break;default:y=await E.text().then(o=>{if(x(o))return+o;if(o==="true")return!0;if(o==="false")return!1;if(!o)return o;let l=o.replace(/"/g,"");if(ie.test(l)||oe.test(l)||ce.test(l)){let h=new Date(l);if(!Number.isNaN(h.getTime()))return h}return o})}(E.status>=300||E.status<200)&&(O=new A(E.status,y),y=null)}return{data:y,error:O,response:E,status:E.status,headers:E.headers}})()}return typeof i=="object"?M(t,e,[...r,Object.values(i)[0]],a):M(t,e,r)}}),Z=(t,e={})=>typeof t=="string"?(t.includes("://")||(t=(G.find(r=>t.includes(r))?"http://":"https://")+t),t.endsWith("/")&&(t=t.slice(0,-1)),M(t,e)):(typeof window<"u"&&console.warn("Elysia instance server found on client side, this is not recommended for security reason. Use generic type instead."),M("http://e.ly",e,[],t));var B=typeof FileList>"u",V=t=>B?t instanceof Blob:t instanceof FileList||t instanceof File,ye=t=>{if(!t)return!1;for(let e in t){if(V(t[e]))return!0;if(Array.isArray(t[e])&&t[e].find(r=>V(r)))return!0}return!1},J=t=>B?t:new Promise(e=>{let r=new FileReader;r.onload=()=>{let a=new File([r.result],t.name,{lastModified:t.lastModified,type:t.type});e(a)},r.readAsArrayBuffer(t)}),H=class{ws;url;constructor(e){this.ws=new WebSocket(e),this.url=e}send(e){return Array.isArray(e)?(e.forEach(r=>this.send(r)),this):(this.ws.send(typeof e=="object"?JSON.stringify(e):e.toString()),this)}on(e,r,a){return this.addEventListener(e,r,a)}off(e,r,a){return this.ws.removeEventListener(e,r,a),this}subscribe(e,r){return this.addEventListener("message",e,r)}addEventListener(e,r,a){return this.ws.addEventListener(e,f=>{if(e==="message"){let n=f.data.toString(),i=n.charCodeAt(0);if(i===47||i===123)try{n=JSON.parse(n)}catch{}else x(n)?n=+n:n==="true"?n=!0:n==="false"&&(n=!1);r({...f,data:n})}else r(f)},a),this}removeEventListener(e,r,a){return this.off(e,r,a),this}close(){return this.ws.close(),this}},z=(t,e="",r)=>new Proxy(()=>{},{get(a,f,n){return z(t,`${e}/${f.toString()}`,r)},apply(a,f,[n,i={}]=[{},{}]){let p=n!==void 0&&(typeof n!="object"||Array.isArray(n))?n:void 0,{$query:k,$fetch:S,$headers:F,$transform:s,getRaw:m,...g}=n??{};p??=g;let K=e.lastIndexOf("/"),T=e.slice(K+1).toUpperCase(),L=U(t,K===-1?"/":e.slice(0,K),Object.assign(i.query??{},k)),R=r.fetcher??fetch,c=r.transform?Array.isArray(r.transform)?r.transform:[r.transform]:void 0,u=s?Array.isArray(s)?s:[s]:void 0;return u&&(c?c=u.concat(c):c=u),T==="SUBSCRIBE"?new H(L.replace(/^([^]+):\/\//,L.startsWith("https://")?"wss://":"ws://")):(async E=>{let y,O={...r.$fetch?.headers,...S?.headers,...i.headers,...F};if(T!=="GET"&&T!=="HEAD"){y=Object.keys(p).length||Array.isArray(p)?p:void 0;let d=y&&(typeof y=="object"||Array.isArray(p));if(d&&ye(y)){let j=new FormData;for(let[$,v]of Object.entries(y))if(B)j.append($,v);else if(v instanceof File)j.append($,await J(v));else if(v instanceof FileList)for(let W=0;W<v.length;W++)j.append($,await J(v[W]));else if(Array.isArray(v))for(let W=0;W<v.length;W++){let I=v[W];j.append($,I instanceof File?await J(I):I)}else j.append($,v);y=j}else y!=null&&(O["content-type"]=d?"application/json":"text/plain",y=d?JSON.stringify(y):p)}let w=await R(L,{method:T,body:y,...r.$fetch,...i.fetch,...S,headers:O}),o;if(E.getRaw)return w;switch(w.headers.get("Content-Type")?.split(";")[0]){case"application/json":o=await w.json();break;default:o=await w.text().then(d=>x(d)?+d:d==="true"?!0:d==="false"?!1:d)}let l=w.status>=300||w.status<200?new A(w.status,o):null,h={data:o,error:l,response:w,status:w.status,headers:w.headers};if(c)for(let d of c){let b=d(h);b instanceof Promise&&(b=await b),b!=null&&(h=b)}return h})({getRaw:m})}}),Q=(t,e={fetcher:fetch})=>new Proxy({},{get(r,a){return z(t,a,e)}});var X=(t,e)=>(r,{query:a,params:f,body:n,...i}={})=>{f&&Object.entries(f).forEach(([s,m])=>{r=r.replace(`:${s}`,m)});let p=i.headers?.["Content-Type"];if(!p||p==="application/json")try{n=JSON.stringify(n)}catch{}let k=e?.fetcher||globalThis.fetch,S=a?`?${new URLSearchParams(a).toString()}`:"",F=()=>k(t+r+S,{...i,method:i.method?.toUpperCase()||"GET",headers:n?{"content-type":"application/json",...i.headers}:i.headers,body:n}).then(async s=>{let m;switch(s.headers.get("Content-Type")?.split(";")[0]){case"application/json":m=await s.json();break;default:m=await s.text().then(g=>x(g)?parseInt(g):g==="true"?!0:g==="false"?!1:g);break}return s.status>300?{data:null,status:s.status,headers:s.headers,retry:F,error:new A(s.status,m)}:{data:m,error:null,status:s.status,headers:s.headers,retry:F}});return F()};0&&(module.exports={edenFetch,edenTreaty,treaty}); | ||
"use strict";var P=Object.defineProperty;var Y=Object.getOwnPropertyDescriptor;var ee=Object.getOwnPropertyNames;var te=Object.prototype.hasOwnProperty;var re=(t,e)=>{for(var r in e)P(t,r,{get:e[r],enumerable:!0})},ne=(t,e,r,a)=>{if(e&&typeof e=="object"||typeof e=="function")for(let f of ee(e))!te.call(t,f)&&f!==r&&P(t,f,{get:()=>e[f],enumerable:!(a=Y(e,f))||a.enumerable});return t};var se=t=>ne(P({},"__esModule",{value:!0}),t);var ue={};re(ue,{edenFetch:()=>X,edenTreaty:()=>Q,treaty:()=>Z});module.exports=se(ue);var B=(t,e,r)=>{if(t.endsWith("/")||(t+="/"),e==="index"&&(e=""),!r||!Object.keys(r).length)return`${t}${e}`;let a="";for(let[f,n]of Object.entries(r))a+=`${f}=${n}&`;return`${t}${e}?${a.slice(0,-1)}`},T=t=>t.trim().length!==0&&!Number.isNaN(Number(t));var A=class extends Error{constructor(r,a){super(a+"");this.status=r;this.value=a}};var N=class{constructor(e){this.url=e;this.ws=new WebSocket(e)}ws;send(e){return Array.isArray(e)?(e.forEach(r=>this.send(r)),this):(this.ws.send(typeof e=="object"?JSON.stringify(e):e.toString()),this)}on(e,r,a){return this.addEventListener(e,r,a)}off(e,r,a){return this.ws.removeEventListener(e,r,a),this}subscribe(e,r){return this.addEventListener("message",e,r)}addEventListener(e,r,a){return this.ws.addEventListener(e,f=>{if(e==="message"){let n=f.data.toString(),i=n.charCodeAt(0);if(i===47||i===123)try{n=JSON.parse(n)}catch{}else T(n)?n=+n:n==="true"?n=!0:n==="false"&&(n=!1);r({...f,data:n})}else r(f)},a),this}removeEventListener(e,r,a){return this.off(e,r,a),this}close(){return this.ws.close(),this}};var ae=["get","post","put","delete","patch","options","head","connect","subscribe"],G=["localhost","127.0.0.1","0.0.0.0"],D=typeof FileList>"u",ie=/(\d{4}-[01]\d-[0-3]\dT[0-2]\d:[0-5]\d:[0-5]\d\.\d+([+-][0-2]\d:[0-5]\d|Z))|(\d{4}-[01]\d-[0-3]\dT[0-2]\d:[0-5]\d:[0-5]\d([+-][0-2]\d:[0-5]\d|Z))|(\d{4}-[01]\d-[0-3]\dT[0-2]\d:[0-5]\d([+-][0-2]\d:[0-5]\d|Z))/,oe=/(?:Sun|Mon|Tue|Wed|Thu|Fri|Sat)\s(?:Jan|Feb|Mar|Apr|May|Jun|Jul|Aug|Sep|Oct|Nov|Dec)\s\d{2}\s\d{4}\s\d{2}:\d{2}:\d{2}\sGMT(?:\+|-)\d{4}\s\([^)]+\)/,ce=/^(?:(?:(?:(?:0?[1-9]|[12][0-9]|3[01])[/\s-](?:0?[1-9]|1[0-2])[/\s-](?:19|20)\d{2})|(?:(?:19|20)\d{2}[/\s-](?:0?[1-9]|1[0-2])[/\s-](?:0?[1-9]|[12][0-9]|3[01]))))(?:\s(?:1[012]|0?[1-9]):[0-5][0-9](?::[0-5][0-9])?(?:\s[AP]M)?)?$/,_=t=>D?t instanceof Blob:t instanceof FileList||t instanceof File,fe=t=>{if(!t)return!1;for(let e in t)if(_(t[e])||Array.isArray(t[e])&&t[e].find(_))return!0;return!1},q=t=>D?t:new Promise(e=>{let r=new FileReader;r.onload=()=>{let a=new File([r.result],t.name,{lastModified:t.lastModified,type:t.type});e(a)},r.readAsArrayBuffer(t)}),$=(t,e,r=[],a)=>new Proxy(()=>{},{get(f,n){return $(t,e,n==="index"?r:[...r,n],a)},apply(f,n,[i,p]){if(!i||p||typeof i=="object"&&Object.keys(i).length!==1||ae.includes(r.at(-1))){let k=r.pop(),w="/"+r.join("/"),{fetcher:F=fetch,headers:s,onRequest:m,onResponse:g,fetch:M}=e,x=k==="get"||k==="head"||k==="subscribe";s={...typeof s=="object"&&!Array.isArray(s)?s:{},...x?i?.headers:p?.headers};let L=x?i?.query:p?.query,R="";if(L)for(let[c,u]of Object.entries(L))R+=(R?"&":"?")+`${c}=${u}`;if(typeof e.headers=="function"&&!(s instanceof Headers)){let c=e.headers(w,p??{});c&&(s={...s,...c})}else if(Array.isArray(e.headers)&&e.headers.every(c=>typeof c=="function"))for(let c of e.headers){let u=c(w,p??{});u&&(s={...s,...u})}else if(s instanceof Headers){s||(s={});for(let[c,u]of Object.entries(s))s[c]=u}if(k==="subscribe"){let c=t.replace(/^([^]+):\/\//,t.startsWith("https://")?"wss://":t.startsWith("http://")||G.find(u=>t.includes(u))?"ws://":"wss://")+w+R;return new N(c)}return(async()=>{let c=(s instanceof Headers?s.get("content-type"):Array.isArray(s)?s.find(o=>Array.isArray(o)&&o[0]==="headers"?o[1]:!1):typeof s=="function"?s(w,p??{}):s?.contentType)||p?.headers?.contentType;if(!c)if(typeof i=="object")c="application/json",i=JSON.stringify(i);else if(fe(i)){let o=new FormData;for(let[l,h]of Object.entries(i)){if(D){o.append(l,h);continue}if(h instanceof File){o.append(l,await q(h));continue}if(h instanceof FileList){for(let d=0;d<h.length;d++)o.append(l,await q(h[d]));continue}if(Array.isArray(h)){for(let d=0;d<h.length;d++){let b=h[d];o.append(l,b instanceof File?await q(b):b)}continue}o.append(l,h)}i=o}else i!=null&&(c="text/plain");let u={method:k?.toUpperCase(),body:i,...M,headers:{...s,"content-type":c}};if(x&&delete u.body,m){Array.isArray(m)||(m=[m]);for(let o of m){let l=await o(w,u);typeof l=="object"&&(u={...u,...l,headers:{...u.headers,...l.headers}})}}let C=t+w+R,E=await(a?.handle(new Request(C,u))??F(C,u)),y=null,O=null;if(g){Array.isArray(g)||(g=[g]);for(let o of g)try{if(y=await o(E.clone()),y!=null)break}catch(l){l instanceof A?O=l:O=new A(422,l);break}}if(y===null){switch(E.headers.get("Content-Type")?.split(";")[0]){case"application/json":y=await E.json();break;case"application/octet-stream":y=await E.arrayBuffer();break;default:y=await E.text().then(o=>{if(T(o))return+o;if(o==="true")return!0;if(o==="false")return!1;if(!o)return o;let l=o.replace(/"/g,"");if(ie.test(l)||oe.test(l)||ce.test(l)){let h=new Date(l);if(!Number.isNaN(h.getTime()))return h}return o})}(E.status>=300||E.status<200)&&(O=new A(E.status,y),y=null)}return{data:y,error:O,response:E,status:E.status,headers:E.headers}})()}return typeof i=="object"?$(t,e,[...r,Object.values(i)[0]],a):$(t,e,r)}}),Z=(t,e={})=>typeof t=="string"?(e.keepDomain||(t.includes("://")||(t=(G.find(r=>t.includes(r))?"http://":"https://")+t),t.endsWith("/")&&(t=t.slice(0,-1))),$(t,e)):(typeof window<"u"&&console.warn("Elysia instance server found on client side, this is not recommended for security reason. Use generic type instead."),$("http://e.ly",e,[],t));var U=typeof FileList>"u",V=t=>U?t instanceof Blob:t instanceof FileList||t instanceof File,ye=t=>{if(!t)return!1;for(let e in t){if(V(t[e]))return!0;if(Array.isArray(t[e])&&t[e].find(r=>V(r)))return!0}return!1},J=t=>U?t:new Promise(e=>{let r=new FileReader;r.onload=()=>{let a=new File([r.result],t.name,{lastModified:t.lastModified,type:t.type});e(a)},r.readAsArrayBuffer(t)}),H=class{ws;url;constructor(e){this.ws=new WebSocket(e),this.url=e}send(e){return Array.isArray(e)?(e.forEach(r=>this.send(r)),this):(this.ws.send(typeof e=="object"?JSON.stringify(e):e.toString()),this)}on(e,r,a){return this.addEventListener(e,r,a)}off(e,r,a){return this.ws.removeEventListener(e,r,a),this}subscribe(e,r){return this.addEventListener("message",e,r)}addEventListener(e,r,a){return this.ws.addEventListener(e,f=>{if(e==="message"){let n=f.data.toString(),i=n.charCodeAt(0);if(i===47||i===123)try{n=JSON.parse(n)}catch{}else T(n)?n=+n:n==="true"?n=!0:n==="false"&&(n=!1);r({...f,data:n})}else r(f)},a),this}removeEventListener(e,r,a){return this.off(e,r,a),this}close(){return this.ws.close(),this}},z=(t,e="",r)=>new Proxy(()=>{},{get(a,f,n){return z(t,`${e}/${f.toString()}`,r)},apply(a,f,[n,i={}]=[{},{}]){let p=n!==void 0&&(typeof n!="object"||Array.isArray(n))?n:void 0,{$query:k,$fetch:w,$headers:F,$transform:s,getRaw:m,...g}=n??{};p??=g;let M=e.lastIndexOf("/"),x=e.slice(M+1).toUpperCase(),L=B(t,M===-1?"/":e.slice(0,M),Object.assign(i.query??{},k)),R=r.fetcher??fetch,c=r.transform?Array.isArray(r.transform)?r.transform:[r.transform]:void 0,u=s?Array.isArray(s)?s:[s]:void 0;return u&&(c?c=u.concat(c):c=u),x==="SUBSCRIBE"?new H(L.replace(/^([^]+):\/\//,L.startsWith("https://")?"wss://":"ws://")):(async E=>{let y,O={...r.$fetch?.headers,...w?.headers,...i.headers,...F};if(x!=="GET"&&x!=="HEAD"){y=Object.keys(p).length||Array.isArray(p)?p:void 0;let d=y&&(typeof y=="object"||Array.isArray(p));if(d&&ye(y)){let j=new FormData;for(let[K,v]of Object.entries(y))if(U)j.append(K,v);else if(v instanceof File)j.append(K,await J(v));else if(v instanceof FileList)for(let W=0;W<v.length;W++)j.append(K,await J(v[W]));else if(Array.isArray(v))for(let W=0;W<v.length;W++){let I=v[W];j.append(K,I instanceof File?await J(I):I)}else j.append(K,v);y=j}else y!=null&&(O["content-type"]=d?"application/json":"text/plain",y=d?JSON.stringify(y):p)}let S=await R(L,{method:x,body:y,...r.$fetch,...i.fetch,...w,headers:O}),o;if(E.getRaw)return S;switch(S.headers.get("Content-Type")?.split(";")[0]){case"application/json":o=await S.json();break;default:o=await S.text().then(d=>T(d)?+d:d==="true"?!0:d==="false"?!1:d)}let l=S.status>=300||S.status<200?new A(S.status,o):null,h={data:o,error:l,response:S,status:S.status,headers:S.headers};if(c)for(let d of c){let b=d(h);b instanceof Promise&&(b=await b),b!=null&&(h=b)}return h})({getRaw:m})}}),Q=(t,e={fetcher:fetch})=>new Proxy({},{get(r,a){return z(t,a,e)}});var X=(t,e)=>(r,{query:a,params:f,body:n,...i}={})=>{f&&Object.entries(f).forEach(([s,m])=>{r=r.replace(`:${s}`,m)});let p=i.headers?.["Content-Type"];if(!p||p==="application/json")try{n=JSON.stringify(n)}catch{}let k=e?.fetcher||globalThis.fetch,w=a?`?${new URLSearchParams(a).toString()}`:"",F=()=>k(t+r+w,{...i,method:i.method?.toUpperCase()||"GET",headers:n?{"content-type":"application/json",...i.headers}:i.headers,body:n}).then(async s=>{let m;switch(s.headers.get("Content-Type")?.split(";")[0]){case"application/json":m=await s.json();break;default:m=await s.text().then(g=>T(g)?parseInt(g):g==="true"?!0:g==="false"?!1:g);break}return s.status>300?{data:null,status:s.status,headers:s.headers,retry:F,error:new A(s.status,m)}:{data:m,error:null,status:s.status,headers:s.headers,retry:F}});return F()};0&&(module.exports={edenFetch,edenTreaty,treaty}); |
@@ -10,3 +10,3 @@ import { Elysia, InputSchema } from 'elysia'; | ||
}; | ||
type MaybeArray<T> = T | T[]; | ||
type MaybeArray$1<T> = T | T[]; | ||
declare namespace EdenTreaty { | ||
@@ -27,3 +27,3 @@ export type Create<App extends Elysia<any, any, any, any, any, any, any, any>> = App extends { | ||
$query: Route['query']; | ||
}) => EdenWS<Route> : ((params: Prettify<{ | ||
}) => EdenWS<Route['subscribe']> : ((params: Prettify<{ | ||
$fetch?: RequestInit; | ||
@@ -69,3 +69,3 @@ getRaw?: boolean; | ||
type UnwrapPromise<T> = T extends Promise<infer A> ? A : T; | ||
export type Transform<T = unknown> = MaybeArray<(response: unknown extends T ? { | ||
export type Transform<T = unknown> = MaybeArray$1<(response: unknown extends T ? { | ||
data: any; | ||
@@ -104,2 +104,3 @@ error: any; | ||
type MaybeArray<T> = T | T[]; | ||
declare class EdenWS<Schema extends InputSchema<any> = InputSchema> { | ||
@@ -109,3 +110,3 @@ ws: WebSocket; | ||
constructor(url: string); | ||
send(data: Schema['body'] | Schema['body'][]): this; | ||
send(data: MaybeArray<Schema['body']>): this; | ||
on<K extends keyof WebSocketEventMap>(type: K, listener: (event: EdenTreaty.WSEvent<K, Schema['response']>) => void, options?: boolean | AddEventListenerOptions): this; | ||
@@ -112,0 +113,0 @@ off<K extends keyof WebSocketEventMap>(type: K, listener: (this: WebSocket, ev: WebSocketEventMap[K]) => any, options?: boolean | EventListenerOptions): this; |
@@ -1,1 +0,1 @@ | ||
"use strict";var Eden=(()=>{var $=Object.defineProperty;var B=Object.getOwnPropertyDescriptor;var H=Object.getOwnPropertyNames;var U=Object.prototype.hasOwnProperty;var V=(t,e)=>{for(var n in e)$(t,n,{get:e[n],enumerable:!0})},G=(t,e,n,r)=>{if(e&&typeof e=="object"||typeof e=="function")for(let a of H(e))!U.call(t,a)&&a!==n&&$(t,a,{get:()=>e[a],enumerable:!(r=B(e,a))||r.enumerable});return t};var _=t=>G($({},"__esModule",{value:!0}),t);var X={};V(X,{EdenWS:()=>w,edenTreaty:()=>Q});var S=class extends Error{constructor(n,r){super(r+"");this.status=n;this.value=r}};var K=(t,e,n)=>{if(t.endsWith("/")||(t+="/"),e==="index"&&(e=""),!n||!Object.keys(n).length)return`${t}${e}`;let r="";for(let[a,s]of Object.entries(n))r+=`${a}=${s}&`;return`${t}${e}?${r.slice(0,-1)}`},O=t=>t.trim().length!==0&&!Number.isNaN(Number(t));var F=typeof FileList>"u",N=t=>F?t instanceof Blob:t instanceof FileList||t instanceof File,z=t=>{if(!t)return!1;for(let e in t){if(N(t[e]))return!0;if(Array.isArray(t[e])&&t[e].find(n=>N(n)))return!0}return!1},R=t=>F?t:new Promise(e=>{let n=new FileReader;n.onload=()=>{let r=new File([n.result],t.name,{lastModified:t.lastModified,type:t.type});e(r)},n.readAsArrayBuffer(t)}),w=class{ws;url;constructor(e){this.ws=new WebSocket(e),this.url=e}send(e){return Array.isArray(e)?(e.forEach(n=>this.send(n)),this):(this.ws.send(typeof e=="object"?JSON.stringify(e):e.toString()),this)}on(e,n,r){return this.addEventListener(e,n,r)}off(e,n,r){return this.ws.removeEventListener(e,n,r),this}subscribe(e,n){return this.addEventListener("message",e,n)}addEventListener(e,n,r){return this.ws.addEventListener(e,a=>{if(e==="message"){let s=a.data.toString(),l=s.charCodeAt(0);if(l===47||l===123)try{s=JSON.parse(s)}catch{}else O(s)?s=+s:s==="true"?s=!0:s==="false"&&(s=!1);n({...a,data:s})}else n(a)},r),this}removeEventListener(e,n,r){return this.off(e,n,r),this}close(){return this.ws.close(),this}},j=(t,e="",n)=>new Proxy(()=>{},{get(r,a,s){return j(t,`${e}/${a.toString()}`,n)},apply(r,a,[s,l={}]=[{},{}]){let y=s!==void 0&&(typeof s!="object"||Array.isArray(s))?s:void 0,{$query:M,$fetch:L,$headers:I,$transform:g,getRaw:P,...C}=s??{};y??=C;let v=e.lastIndexOf("/"),E=e.slice(v+1).toUpperCase(),x=K(t,v===-1?"/":e.slice(0,v),Object.assign(l.query??{},M)),q=n.fetcher??fetch,p=n.transform?Array.isArray(n.transform)?n.transform:[n.transform]:void 0,k=g?Array.isArray(g)?g:[g]:void 0;return k&&(p?p=k.concat(p):p=k),E==="SUBSCRIBE"?new w(x.replace(/^([^]+):\/\//,x.startsWith("https://")?"wss://":"ws://")):(async D=>{let i,W={...n.$fetch?.headers,...L?.headers,...l.headers,...I};if(E!=="GET"&&E!=="HEAD"){i=Object.keys(y).length||Array.isArray(y)?y:void 0;let o=i&&(typeof i=="object"||Array.isArray(y));if(o&&z(i)){let h=new FormData;for(let[m,f]of Object.entries(i))if(F)h.append(m,f);else if(f instanceof File)h.append(m,await R(f));else if(f instanceof FileList)for(let d=0;d<f.length;d++)h.append(m,await R(f[d]));else if(Array.isArray(f))for(let d=0;d<f.length;d++){let T=f[d];h.append(m,T instanceof File?await R(T):T)}else h.append(m,f);i=h}else i!=null&&(W["content-type"]=o?"application/json":"text/plain",i=o?JSON.stringify(i):y)}let c=await q(x,{method:E,body:i,...n.$fetch,...l.fetch,...L,headers:W}),b;if(D.getRaw)return c;switch(c.headers.get("Content-Type")?.split(";")[0]){case"application/json":b=await c.json();break;default:b=await c.text().then(o=>O(o)?+o:o==="true"?!0:o==="false"?!1:o)}let J=c.status>=300||c.status<200?new S(c.status,b):null,A={data:b,error:J,response:c,status:c.status,headers:c.headers};if(p)for(let o of p){let u=o(A);u instanceof Promise&&(u=await u),u!=null&&(A=u)}return A})({getRaw:P})}}),Q=(t,e={fetcher:fetch})=>new Proxy({},{get(n,r){return j(t,r,e)}});return _(X);})(); | ||
"use strict";var Eden=(()=>{var $=Object.defineProperty;var B=Object.getOwnPropertyDescriptor;var H=Object.getOwnPropertyNames;var U=Object.prototype.hasOwnProperty;var V=(t,e)=>{for(var n in e)$(t,n,{get:e[n],enumerable:!0})},G=(t,e,n,r)=>{if(e&&typeof e=="object"||typeof e=="function")for(let a of H(e))!U.call(t,a)&&a!==n&&$(t,a,{get:()=>e[a],enumerable:!(r=B(e,a))||r.enumerable});return t};var _=t=>G($({},"__esModule",{value:!0}),t);var X={};V(X,{EdenWS:()=>S,edenTreaty:()=>Q});var w=class extends Error{constructor(n,r){super(r+"");this.status=n;this.value=r}};var K=(t,e,n)=>{if(t.endsWith("/")||(t+="/"),e==="index"&&(e=""),!n||!Object.keys(n).length)return`${t}${e}`;let r="";for(let[a,s]of Object.entries(n))r+=`${a}=${s}&`;return`${t}${e}?${r.slice(0,-1)}`},O=t=>t.trim().length!==0&&!Number.isNaN(Number(t));var F=typeof FileList>"u",M=t=>F?t instanceof Blob:t instanceof FileList||t instanceof File,z=t=>{if(!t)return!1;for(let e in t){if(M(t[e]))return!0;if(Array.isArray(t[e])&&t[e].find(n=>M(n)))return!0}return!1},R=t=>F?t:new Promise(e=>{let n=new FileReader;n.onload=()=>{let r=new File([n.result],t.name,{lastModified:t.lastModified,type:t.type});e(r)},n.readAsArrayBuffer(t)}),S=class{ws;url;constructor(e){this.ws=new WebSocket(e),this.url=e}send(e){return Array.isArray(e)?(e.forEach(n=>this.send(n)),this):(this.ws.send(typeof e=="object"?JSON.stringify(e):e.toString()),this)}on(e,n,r){return this.addEventListener(e,n,r)}off(e,n,r){return this.ws.removeEventListener(e,n,r),this}subscribe(e,n){return this.addEventListener("message",e,n)}addEventListener(e,n,r){return this.ws.addEventListener(e,a=>{if(e==="message"){let s=a.data.toString(),l=s.charCodeAt(0);if(l===47||l===123)try{s=JSON.parse(s)}catch{}else O(s)?s=+s:s==="true"?s=!0:s==="false"&&(s=!1);n({...a,data:s})}else n(a)},r),this}removeEventListener(e,n,r){return this.off(e,n,r),this}close(){return this.ws.close(),this}},N=(t,e="",n)=>new Proxy(()=>{},{get(r,a,s){return N(t,`${e}/${a.toString()}`,n)},apply(r,a,[s,l={}]=[{},{}]){let y=s!==void 0&&(typeof s!="object"||Array.isArray(s))?s:void 0,{$query:j,$fetch:L,$headers:I,$transform:g,getRaw:P,...C}=s??{};y??=C;let v=e.lastIndexOf("/"),E=e.slice(v+1).toUpperCase(),x=K(t,v===-1?"/":e.slice(0,v),Object.assign(l.query??{},j)),q=n.fetcher??fetch,p=n.transform?Array.isArray(n.transform)?n.transform:[n.transform]:void 0,A=g?Array.isArray(g)?g:[g]:void 0;return A&&(p?p=A.concat(p):p=A),E==="SUBSCRIBE"?new S(x.replace(/^([^]+):\/\//,x.startsWith("https://")?"wss://":"ws://")):(async D=>{let i,W={...n.$fetch?.headers,...L?.headers,...l.headers,...I};if(E!=="GET"&&E!=="HEAD"){i=Object.keys(y).length||Array.isArray(y)?y:void 0;let o=i&&(typeof i=="object"||Array.isArray(y));if(o&&z(i)){let h=new FormData;for(let[m,f]of Object.entries(i))if(F)h.append(m,f);else if(f instanceof File)h.append(m,await R(f));else if(f instanceof FileList)for(let d=0;d<f.length;d++)h.append(m,await R(f[d]));else if(Array.isArray(f))for(let d=0;d<f.length;d++){let T=f[d];h.append(m,T instanceof File?await R(T):T)}else h.append(m,f);i=h}else i!=null&&(W["content-type"]=o?"application/json":"text/plain",i=o?JSON.stringify(i):y)}let c=await q(x,{method:E,body:i,...n.$fetch,...l.fetch,...L,headers:W}),b;if(D.getRaw)return c;switch(c.headers.get("Content-Type")?.split(";")[0]){case"application/json":b=await c.json();break;default:b=await c.text().then(o=>O(o)?+o:o==="true"?!0:o==="false"?!1:o)}let J=c.status>=300||c.status<200?new w(c.status,b):null,k={data:b,error:J,response:c,status:c.status,headers:c.headers};if(p)for(let o of p){let u=o(k);u instanceof Promise&&(u=await u),u!=null&&(k=u)}return k})({getRaw:P})}}),Q=(t,e={fetcher:fetch})=>new Proxy({},{get(n,r){return N(t,r,e)}});return _(X);})(); |
@@ -1,1 +0,1 @@ | ||
"use strict";var $=Object.defineProperty;var B=Object.getOwnPropertyDescriptor;var H=Object.getOwnPropertyNames;var U=Object.prototype.hasOwnProperty;var V=(t,e)=>{for(var n in e)$(t,n,{get:e[n],enumerable:!0})},G=(t,e,n,r)=>{if(e&&typeof e=="object"||typeof e=="function")for(let a of H(e))!U.call(t,a)&&a!==n&&$(t,a,{get:()=>e[a],enumerable:!(r=B(e,a))||r.enumerable});return t};var _=t=>G($({},"__esModule",{value:!0}),t);var X={};V(X,{EdenWS:()=>w,edenTreaty:()=>Q});module.exports=_(X);var S=class extends Error{constructor(n,r){super(r+"");this.status=n;this.value=r}};var K=(t,e,n)=>{if(t.endsWith("/")||(t+="/"),e==="index"&&(e=""),!n||!Object.keys(n).length)return`${t}${e}`;let r="";for(let[a,s]of Object.entries(n))r+=`${a}=${s}&`;return`${t}${e}?${r.slice(0,-1)}`},O=t=>t.trim().length!==0&&!Number.isNaN(Number(t));var F=typeof FileList>"u",N=t=>F?t instanceof Blob:t instanceof FileList||t instanceof File,z=t=>{if(!t)return!1;for(let e in t){if(N(t[e]))return!0;if(Array.isArray(t[e])&&t[e].find(n=>N(n)))return!0}return!1},R=t=>F?t:new Promise(e=>{let n=new FileReader;n.onload=()=>{let r=new File([n.result],t.name,{lastModified:t.lastModified,type:t.type});e(r)},n.readAsArrayBuffer(t)}),w=class{ws;url;constructor(e){this.ws=new WebSocket(e),this.url=e}send(e){return Array.isArray(e)?(e.forEach(n=>this.send(n)),this):(this.ws.send(typeof e=="object"?JSON.stringify(e):e.toString()),this)}on(e,n,r){return this.addEventListener(e,n,r)}off(e,n,r){return this.ws.removeEventListener(e,n,r),this}subscribe(e,n){return this.addEventListener("message",e,n)}addEventListener(e,n,r){return this.ws.addEventListener(e,a=>{if(e==="message"){let s=a.data.toString(),l=s.charCodeAt(0);if(l===47||l===123)try{s=JSON.parse(s)}catch{}else O(s)?s=+s:s==="true"?s=!0:s==="false"&&(s=!1);n({...a,data:s})}else n(a)},r),this}removeEventListener(e,n,r){return this.off(e,n,r),this}close(){return this.ws.close(),this}},j=(t,e="",n)=>new Proxy(()=>{},{get(r,a,s){return j(t,`${e}/${a.toString()}`,n)},apply(r,a,[s,l={}]=[{},{}]){let y=s!==void 0&&(typeof s!="object"||Array.isArray(s))?s:void 0,{$query:M,$fetch:L,$headers:I,$transform:g,getRaw:P,...C}=s??{};y??=C;let v=e.lastIndexOf("/"),E=e.slice(v+1).toUpperCase(),x=K(t,v===-1?"/":e.slice(0,v),Object.assign(l.query??{},M)),q=n.fetcher??fetch,p=n.transform?Array.isArray(n.transform)?n.transform:[n.transform]:void 0,k=g?Array.isArray(g)?g:[g]:void 0;return k&&(p?p=k.concat(p):p=k),E==="SUBSCRIBE"?new w(x.replace(/^([^]+):\/\//,x.startsWith("https://")?"wss://":"ws://")):(async D=>{let i,W={...n.$fetch?.headers,...L?.headers,...l.headers,...I};if(E!=="GET"&&E!=="HEAD"){i=Object.keys(y).length||Array.isArray(y)?y:void 0;let o=i&&(typeof i=="object"||Array.isArray(y));if(o&&z(i)){let h=new FormData;for(let[m,f]of Object.entries(i))if(F)h.append(m,f);else if(f instanceof File)h.append(m,await R(f));else if(f instanceof FileList)for(let d=0;d<f.length;d++)h.append(m,await R(f[d]));else if(Array.isArray(f))for(let d=0;d<f.length;d++){let T=f[d];h.append(m,T instanceof File?await R(T):T)}else h.append(m,f);i=h}else i!=null&&(W["content-type"]=o?"application/json":"text/plain",i=o?JSON.stringify(i):y)}let c=await q(x,{method:E,body:i,...n.$fetch,...l.fetch,...L,headers:W}),b;if(D.getRaw)return c;switch(c.headers.get("Content-Type")?.split(";")[0]){case"application/json":b=await c.json();break;default:b=await c.text().then(o=>O(o)?+o:o==="true"?!0:o==="false"?!1:o)}let J=c.status>=300||c.status<200?new S(c.status,b):null,A={data:b,error:J,response:c,status:c.status,headers:c.headers};if(p)for(let o of p){let u=o(A);u instanceof Promise&&(u=await u),u!=null&&(A=u)}return A})({getRaw:P})}}),Q=(t,e={fetcher:fetch})=>new Proxy({},{get(n,r){return j(t,r,e)}});0&&(module.exports={EdenWS,edenTreaty}); | ||
"use strict";var $=Object.defineProperty;var B=Object.getOwnPropertyDescriptor;var H=Object.getOwnPropertyNames;var U=Object.prototype.hasOwnProperty;var V=(t,e)=>{for(var n in e)$(t,n,{get:e[n],enumerable:!0})},G=(t,e,n,r)=>{if(e&&typeof e=="object"||typeof e=="function")for(let a of H(e))!U.call(t,a)&&a!==n&&$(t,a,{get:()=>e[a],enumerable:!(r=B(e,a))||r.enumerable});return t};var _=t=>G($({},"__esModule",{value:!0}),t);var X={};V(X,{EdenWS:()=>S,edenTreaty:()=>Q});module.exports=_(X);var w=class extends Error{constructor(n,r){super(r+"");this.status=n;this.value=r}};var K=(t,e,n)=>{if(t.endsWith("/")||(t+="/"),e==="index"&&(e=""),!n||!Object.keys(n).length)return`${t}${e}`;let r="";for(let[a,s]of Object.entries(n))r+=`${a}=${s}&`;return`${t}${e}?${r.slice(0,-1)}`},O=t=>t.trim().length!==0&&!Number.isNaN(Number(t));var F=typeof FileList>"u",M=t=>F?t instanceof Blob:t instanceof FileList||t instanceof File,z=t=>{if(!t)return!1;for(let e in t){if(M(t[e]))return!0;if(Array.isArray(t[e])&&t[e].find(n=>M(n)))return!0}return!1},R=t=>F?t:new Promise(e=>{let n=new FileReader;n.onload=()=>{let r=new File([n.result],t.name,{lastModified:t.lastModified,type:t.type});e(r)},n.readAsArrayBuffer(t)}),S=class{ws;url;constructor(e){this.ws=new WebSocket(e),this.url=e}send(e){return Array.isArray(e)?(e.forEach(n=>this.send(n)),this):(this.ws.send(typeof e=="object"?JSON.stringify(e):e.toString()),this)}on(e,n,r){return this.addEventListener(e,n,r)}off(e,n,r){return this.ws.removeEventListener(e,n,r),this}subscribe(e,n){return this.addEventListener("message",e,n)}addEventListener(e,n,r){return this.ws.addEventListener(e,a=>{if(e==="message"){let s=a.data.toString(),l=s.charCodeAt(0);if(l===47||l===123)try{s=JSON.parse(s)}catch{}else O(s)?s=+s:s==="true"?s=!0:s==="false"&&(s=!1);n({...a,data:s})}else n(a)},r),this}removeEventListener(e,n,r){return this.off(e,n,r),this}close(){return this.ws.close(),this}},N=(t,e="",n)=>new Proxy(()=>{},{get(r,a,s){return N(t,`${e}/${a.toString()}`,n)},apply(r,a,[s,l={}]=[{},{}]){let y=s!==void 0&&(typeof s!="object"||Array.isArray(s))?s:void 0,{$query:j,$fetch:L,$headers:I,$transform:g,getRaw:P,...C}=s??{};y??=C;let v=e.lastIndexOf("/"),E=e.slice(v+1).toUpperCase(),x=K(t,v===-1?"/":e.slice(0,v),Object.assign(l.query??{},j)),q=n.fetcher??fetch,p=n.transform?Array.isArray(n.transform)?n.transform:[n.transform]:void 0,A=g?Array.isArray(g)?g:[g]:void 0;return A&&(p?p=A.concat(p):p=A),E==="SUBSCRIBE"?new S(x.replace(/^([^]+):\/\//,x.startsWith("https://")?"wss://":"ws://")):(async D=>{let i,W={...n.$fetch?.headers,...L?.headers,...l.headers,...I};if(E!=="GET"&&E!=="HEAD"){i=Object.keys(y).length||Array.isArray(y)?y:void 0;let o=i&&(typeof i=="object"||Array.isArray(y));if(o&&z(i)){let h=new FormData;for(let[m,f]of Object.entries(i))if(F)h.append(m,f);else if(f instanceof File)h.append(m,await R(f));else if(f instanceof FileList)for(let d=0;d<f.length;d++)h.append(m,await R(f[d]));else if(Array.isArray(f))for(let d=0;d<f.length;d++){let T=f[d];h.append(m,T instanceof File?await R(T):T)}else h.append(m,f);i=h}else i!=null&&(W["content-type"]=o?"application/json":"text/plain",i=o?JSON.stringify(i):y)}let c=await q(x,{method:E,body:i,...n.$fetch,...l.fetch,...L,headers:W}),b;if(D.getRaw)return c;switch(c.headers.get("Content-Type")?.split(";")[0]){case"application/json":b=await c.json();break;default:b=await c.text().then(o=>O(o)?+o:o==="true"?!0:o==="false"?!1:o)}let J=c.status>=300||c.status<200?new w(c.status,b):null,k={data:b,error:J,response:c,status:c.status,headers:c.headers};if(p)for(let o of p){let u=o(k);u instanceof Promise&&(u=await u),u!=null&&(k=u)}return k})({getRaw:P})}}),Q=(t,e={fetcher:fetch})=>new Proxy({},{get(n,r){return N(t,r,e)}});0&&(module.exports={EdenWS,edenTreaty}); |
import type { Elysia, InputSchema } from 'elysia'; | ||
import type { EdenTreaty } from './types'; | ||
export type { EdenTreaty } from './types'; | ||
type MaybeArray<T> = T | T[]; | ||
export declare class EdenWS<Schema extends InputSchema<any> = InputSchema> { | ||
@@ -8,3 +9,3 @@ ws: WebSocket; | ||
constructor(url: string); | ||
send(data: Schema['body'] | Schema['body'][]): this; | ||
send(data: MaybeArray<Schema['body']>): this; | ||
on<K extends keyof WebSocketEventMap>(type: K, listener: (event: EdenTreaty.WSEvent<K, Schema['response']>) => void, options?: boolean | AddEventListenerOptions): this; | ||
@@ -11,0 +12,0 @@ off<K extends keyof WebSocketEventMap>(type: K, listener: (this: WebSocket, ev: WebSocketEventMap[K]) => any, options?: boolean | EventListenerOptions): this; |
@@ -26,3 +26,3 @@ /// <reference lib="dom" /> | ||
$query: Route['query']; | ||
}) => EdenWS<Route> : ((params: Prettify<{ | ||
}) => EdenWS<Route['subscribe']> : ((params: Prettify<{ | ||
$fetch?: RequestInit; | ||
@@ -29,0 +29,0 @@ getRaw?: boolean; |
@@ -54,2 +54,3 @@ /// <reference types="bun-types" /> | ||
onResponse?: MaybeArray<(response: Response) => MaybePromise<unknown>>; | ||
keepDomain?: boolean; | ||
} | ||
@@ -56,0 +57,0 @@ type TreatyResponse<Res extends Record<number, unknown>> = { |
{ | ||
"name": "@elysiajs/eden", | ||
"version": "1.0.5", | ||
"version": "1.0.6", | ||
"description": "Fully type-safe Elysia client", | ||
@@ -5,0 +5,0 @@ "author": { |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
100303
887