https://www.listening.com/assets/get-runtime-DbcBsDdd.js

1import{n as e}from"./not-found-i5RsCZif.js";import{$t as t,Ai as n,Ci as r,G as i,H as a,Hn as o,Ht as s,Ii as c,J as l,La as u,Lr as d,M as f,Ma as p,Mn as m,Mt as h,N as g,Na as _,O as v,Oa as ee,Pi as te,Qt as ne,R as re,Ro as ie,Rt as ae,Sa as y,Sr as b,St as oe,Tn as se,Tr as ce,Ui as le,V as x,Vt as S,Yo as ue,Zr as de,an as fe,ao as pe,as as me,b as C,bn as w,bt as T,f as E,ft as he,gt as ge,h as _e,hi as ve,ho as ye,i as be,ii as D,j as O,jr as xe,k as Se,ln as Ce,mn as we,ni as Te,pi as Ee,q as De,qa as Oe,qo as ke,ri as Ae,rs as je,s as Me,ti as Ne,to as Pe,ut as Fe,v as Ie,wr as Le,x as k,xa as Re,xn as A,yn as j,z as ze,zi as Be}from"./Schema-CAUmIdFq.js";import{$t as Ve,A as He,At as Ue,C as We,Ct as Ge,D as Ke,E as qe,Et as Je,Ft as Ye,Gt as Xe,Ht as Ze,M as Qe,Mt as $e,N as M,Nt as et,O as tt,P as N,S as nt,St as rt,T as it,Tt as at,Wt as ot,Xt as st,Yt as ct,an as lt,bt as P,in as F,j as ut,jt as I,k as L,kt as R,nn as dt,rn as ft,t as pt,vt as mt,w as z,wt as ht,xt as gt}from"./api-contract-BBRQu6_I.js";import{t as B}from"./env-CEkZxYq9.js";import{i as _t,r as vt,t as yt}from"./ManagedRuntime-5RiSlvNa.js";import{U as bt,V,W as xt,z as H}from"./errors-BkW-dFDO.js";import{i as St,n as Ct,r as wt,t as Tt}from"./HttpClient-ByWE9G_N.js";import{t as U}from"./api-client-tag-CiSoiJH1.js";var Et=e=>()=>{let t=ze(_e(e));return F((e,n)=>b(A(e,e=>t(e))))},W=je(2,(e,t)=>e===void 0?void 0:t(e)),Dt=p(`effect/http/FetchHttpClient/Fetch`,{defaultValue:()=>globalThis.fetch}),Ot=class extends _()(`effect/http/FetchHttpClient/RequestInit`){},G=Ct(b(wt((e,t,n,r)=>{let i=r.getRef(Dt),a=u(r.context,Ot)??{},s=a.headers?dt(Ve(a.headers),e.headers):e.headers;s[`content-length`]&&(s=ft(s,`content-length`));let c=r=>o(xe({try:()=>i(t,{...a,method:e.method,headers:s,body:r,duplex:typeof ReadableStream<`u`&&r instanceof ReadableStream?`half`:void 0,signal:n}),catch:t=>new V({reason:new xt({request:e,cause:t})})}),t=>mt(e,t));switch(e.body._tag){case`Raw`:case`Uint8Array`:return c(e.body.body);case`FormData`:return c(e.body.formData);case`Stream`:return A(ct(e.body.stream),c)}return c(void 0)}))),K=`~effect/encoding/Sse/SseError`,kt=class extends y(`EventTooLarge`){get message(){return`Pending SSE event exceeded the maximum size of ${this.maxEventSize}`}},At=class extends y(`SseError`){[K]=K;get message(){return this.reason.message}},jt=10485760,Mt=e=>F((t,n)=>ce(()=>{let n=[],r,i=Pt(e=>{e._tag===`Retry`?r=e:n.push(e)},e),a=A(t,e=>{for(let t=0;t<e.length;t++){let n=i.feed(e[t]);if(n!==void 0)return j(n)}return d});return Le(function e(){if(Oe(n)){let e=n;return n=[],b(e)}return r?j(r):A(a,e)})})),Nt=(e,t)=>lt(Mt(t),Et(It.pipe(x(e)))());function Pt(e,t){let n=t?.maxEventSize??jt,r,i,a,o,s,c,l,u;return d(),{feed:f,reset:d};function d(){r=!0,i=``,a=0,o=-1,s=!1,c=void 0,l=void 0,u=``}function f(e){i=i?i+e:e,r&&i.startsWith(Ft)&&(i=i.slice(Ft.length)),r=!1;let t=i.length,c=0;for(;c<t;){s&&=(i[c]===`
2`&&++c,!1);let e=-1,n=o,r;for(let o=c+a;e<0&&o<t;++o)r=i[o],r===`:`&&n<0?n=o-c:r===`\r`?(s=!0,e=o-c):r===`
3`&&(e=o-c);if(e<0){a=t-c,o=n;break}a=0,o=-1,p(i,c,n,e),c+=e+1}if(c===t?i=``:c>0&&(i=i.slice(c)),i.length+u.length>n){let e=new At({reason:new kt({maxEventSize:n})});return d(),e}}function p(t,n,r,i){if(i===0){u.length>0&&(e({_tag:`Event`,id:c,event:l||`message`,data:u.slice(0,-1)}),u=``),l=void 0;return}let a=r<0,o=t.slice(n,n+(a?i:r)),s=0;s=a?i:t[n+r+1]===` `?r+2:r+1;let d=n+s,f=i-s,p=t.slice(d,d+f).toString();o===`data`?u+=p?`${p}\n`:`

4`:o===`event`?l=p:o===`id`&&!p.includes(`\0`)?c=p:o===`retry`&&/^\d+$/.test(p)&&e(new Lt({duration:ee(parseInt(p,10)),lastEventId:c}))}}var Ft=``,It=k({id:Fe(C),event:C,data:C}),q=`~effect/encoding/Sse/Retry`,Lt=class e extends Re(`Retry`){[q]=q;static is(e){return ke(e,q)}static filter(t){return e.is(t)?pe(t):Pe(t)}},Rt=(e,t)=>m(function*(){let r=yield*we(),a=t.httpClient.pipe(t?.baseUrl===void 0?me:St(Ge(t.baseUrl.toString())));function o(e,t,n,i,s){if(s===-1)return a.execute(n);let c=r.mapUnsafe.get(i[s]);return c===void 0?o(e,t,n,i,s-1):c({endpoint:t,group:e,request:n,next(n){return o(e,t,n,i,s-1)}})}nt(e,{predicate:t?.predicate,onGroup(e){t.onGroup?.(e)},onEndpoint(e){let{group:r,endpoint:a,errors:s,successes:c}=e,l=Vt(a.path),u={orElse:nn},d=new Map;for(let[e,t]of s.entries()){let n=Gt(t);for(let[t,r]of n.entries())Y(d,e,t,Ht(r))}for(let[e,t]of d.entries()){let r=Wt(t);u[e]=e=>A(Ce(r(e),t=>w(n(te(new V({reason:new bt({request:e.request,response:e})})),t))),j)}let f=new Map;for(let[e,t]of c.entries()){let n=Gt(t);for(let[t,r]of n.entries())Y(f,e,t,Ht(r))}for(let e of Yt(a)){let t=Jt(e)?e.schema:e;Y(f,tt(e),t.contentType,Xt(e))}for(let[e,t]of f.entries())u[e]=Wt(t);let p=W(a.params,i),m=We(a),h=Oe(m)?R(a.method)?i(an(m,a.method)):i(O(m)):void 0,g=W(a.headers,i),_=W(a.query,i),v=Array.from(e.middleware,e=>`${e.key}/Client`),ee=se(function*(e){let n=rt(a.method)(a.path);if(e!==void 0){if(p!==void 0){let t=yield*p(e.params);n=Je(n,l(t))}if(h!==void 0){if(R(a.method)){if(e.payload instanceof FormData)n=gt(n,e.payload);else{let t=yield*h(e.payload);n=ht(n,t)}}else{let t=yield*h(e.payload);n=P(n,t)}}if(g!==void 0){let t=yield*g(e.headers);n=at(n,t)}if(_!==void 0){let t=yield*_(e.query);n=P(n,t)}}let i=yield*o(r,a,n,v,v.length-1);if(e?.responseMode===`response-only`)return i;let s=(u[i.status]??u.orElse)(i,e?.sseOptions),c=yield*t.transformResponse===void 0?s:t.transformResponse(s);return e?.responseMode===`decoded-and-response`?[c,i]:c});t.onEndpoint({...e,endpointFn:ee})}})}),zt=(e,t)=>A(Tt,n=>Bt(e,{...t,httpClient:t?.transformClient?t.transformClient(n):n})),Bt=(e,t)=>{let n={};return Rt(e,{...t,onGroup({group:e}){e.topLevel||ie(n,e.identifier,{})},onEndpoint({endpoint:e,endpointFn:t,group:r}){ie(r.topLevel?n:n[r.identifier],e.identifier,t)}}).pipe(fe(n))},J=/(\/?):(\w+)(\?)?/g,Vt=e=>J.test(e)?(J.lastIndex=0,t=>(J.lastIndex=0,e.replace(J,(e,n,r,i)=>{let a=t[r];if(a===void 0){if(i!==void 0)return``;throw Error(`Missing path parameter: ${r}`)}return`${n}${encodeURIComponent(a)}`}))):t=>e;function Ht(e){let t=e.some(e=>M(e)||L(e.ast)!==void 0),n=t?O(e.map(Ut)):tn(e),r=ze(n);return e=>A(e.arrayBuffer,t?t=>r({body:t,headers:e.headers}):r)}function Ut(e){let t=M(e),n=L(e.ast);if(n!==void 0)return k({body:Q(n.body),headers:n.headersCodec}).pipe(x(e));let r=t?e.schema:e;return k({body:Q(r).pipe(x(r)),headers:t?e.headers:f}).pipe(x(t?e:ge(e),S({decode:e=>t?N(e):e.body,encode:e=>t?e:{body:e,headers:void 0}})))}function Y(e,t,n,r){let i=z(n),a=e.get(t);a===void 0?e.set(t,[{contentType:i,decode:r}]):a.push({contentType:i,decode:r})}function Wt(e){let t=e[0];return e.length===1&&t!==void 0?t.decode:(t,n)=>{let r=z(t.headers[`content-type`]??``),i=e.find(e=>e.contentType===r);return i===void 0?Kt(t,r,e):i.decode(t,n)}}function Gt(e){let t=new Map;for(let n of e){let e=M(n)?n.schema:n,r=He(e.ast)?``:z(Ke(n).contentType),i=t.get(r);i===void 0?t.set(r,[n]):i.push(n)}return t}function Kt(e,t,n){let r=Array.from(new Set(n.map(e=>e.contentType))).join(`, `);return j(new V({reason:new H({request:e.request,response:e,description:`Unsupported response content-type for status ${e.status}: ${t||`<missing>`}. Expected one of: ${r}`})}))}var qt=`effect/httpapi/stream/failure`,Jt=e=>M(e);function Yt(e){let t=[];for(let n of e.success){let e=M(n)?n.schema:n;ut(e)&&t.push(n)}return t}function Xt(e){let t=Jt(e),n=t?e.schema:e,r=Qe(n)?void 0:{declaration:n,decoder:Zt(n)},i=(e,t)=>o(we(),n=>Xe(r===void 0?e.stream:Qt(e.stream,r.declaration,r.decoder(t)),n));if(!t)return i;let s=a(e.headers);return(e,t)=>A(s(e.headers),n=>o(i(e,t),e=>N({body:e,headers:n})))}function Zt(e){let t=O([k({event:E(qt),data:De(he(be(e.error,Me()

4)))}),e.events]),n=Nt(t);return e=>e===void 0?n:Nt(t,e)}function Qt(e,t,n){let r=st(e.pipe(Ye,ot(n)),e=>ce(()=>{let t;return Le(()=>t===void 0?A(e,e=>{for(let n=0;n<e.length;n++){let r=e[n];if(r.event===qt&&Be(r.data)){if(n===0)return w(r.data);t=r.data,e=e.slice(0,n);break}}return b(e)}):w(t))}));return t.sseMode===`data`?Ze(r,e=>e.data):r}var X=l(globalThis.ArrayBuffer,{expected:`ArrayBuffer`}),$t=X.pipe(x(v,S({decode(e){return new Uint8Array(e)},encode(e){return e.byteLength===e.buffer.byteLength?e.buffer:e.buffer.slice(e.byteOffset,e.byteOffset+e.byteLength)}}))),Z=X.pipe(x(C,S({decode(e){return new TextDecoder().decode(e)},encode(e){let t=new TextEncoder().encode(e);return t.byteLength===t.buffer.byteLength?t.buffer:t.buffer.slice(t.byteOffset,t.byteOffset+t.byteLength)}}))),en=Z.pipe(x(O([E(``).pipe(x(Se,S({decode:()=>void 0,encode:()=>``}))),g])));function tn(e){return O(e.map(t));function t(e){return Q(e).pipe(x(e))}}function Q(e){switch(qe(e.ast)._tag){case`Json`:return h(ae(e.ast))?en.pipe(x(f,S({decode:e=>e===void 0?null:e,encode:e=>e===null?void 0:e}))):en;case`FormUrlEncoded`:return Z.pipe(x(Ie,S({decode:e=>T(new URLSearchParams(e)),encode:oe})));case`Uint8Array`:return $t;case`Text`:return Z}}var nn=e=>j(new V({reason:new H({request:e.request,response:e})})),rn=re(Ue);function an(e,t){return O(e.map(e=>sn(e,t)))}var on=new WeakMap;function sn(e,n){let r=e.ast,i=on.get(r);if(i!==void 0)return i;let a=it(r,n),o=rn.pipe(x(e,s({decode(e,t){return j(new ne({message:`Encode only schema`},e,t))},encode(e,n){switch(a._tag){case`Multipart`:return j(new ne({message:`Payload must be a FormData`},e,n));case`Json`:try{let t=JSON.stringify(e);return b(I(t,a.contentType))}catch{return j(new t({expected:`a JSON-serializable request body`},e,n))}case`Text`:return typeof e==`string`?b(I(e,a.contentType)):j(new t({message:`Expected a string`},e,n));case`FormUrlEncoded`:return ue(e)?b(et(T(e),a.contentType)):j(new t({message:`Expected a record`},e,n));case`Uint8Array`:return e instanceof Uint8Array?b($e(e,a.contentType)):j(new t({message:`Expected a Uint8Array`},e,n))}}})));return on.set(r,o),o}function cn(e,t,n){let i=n?.throwOnTag;return(n,a)=>{let o=t(),s=A(e,n),l=async e=>{let t=await e.runPromiseExit(s,{signal:a?.signal});if(r(t))return t.value;let n=t.cause,o=c(n);if(ye(o)){let e=o.value;if(typeof e==`object`&&e&&`_tag`in e){let t=e._tag,n=a?.throwOnTag?.[t]??i?.[t];if(n)throw n(e)}}throw le(n)};return o instanceof Promise?o.then(l):l(o)}}

4function ln(e,t,n){let r=n?.baseUrl?.toString()??(typeof globalThis<`u`&&`location`in globalThis?globalThis.location.origin:`http://localhost:3000`);return de(t)(m(function*(){return yield*zt(e,{...n,baseUrl:r})})).pipe(Te(G))}var un=Symbol.for(`@listening/utils/globalValue`),$=(()=>{let e=globalThis;return e[un]??=new Map,e[un]})(),dn=(e,t)=>($.has(e)||$.set(e,t()),$.get(e)),fn=ln(pt,U),pn=Ne(_t([vt()]),D(ve,B.mode===`production`?`Warn`:`Debug`),D(Ee,{app:`@listening/start`,env:B.mode})),mn=dn(`Listening/ClientRuntime`,()=>yt(Ne(fn,G).pipe(Ae(pn)))),hn=()=>mn,gn=cn(U,hn,{throwOnTag:{NotFoundError:()=>e()}});export{dn as i,hn as n,mn as r,gn as t};
5//# sourceMappingURL=get-runtime-DbcBsDdd.js.map