https://www.listening.com/assets/api-client-tag-rKJyW-Av.js

1(function(){try{var e=typeof window<`u`?window:typeof global<`u`?global:typeof globalThis<`u`?globalThis:typeof self<`u`?self:{};e.SENTRY_RELEASE={id:`798154dfe6f02312abe2ebb46dcac5b55267091e`},e._sentryModuleMetadata=e._sentryModuleMetadata||{},e._sentryModuleMetadata[new e.Error().stack]=function(e){for(var t=1;t<arguments.length;t++){var n=arguments[t];if(n!=null)for(var r in n)n.hasOwnProperty(r)&&(e[r]=n[r])}return e}({},e._sentryModuleMetadata[new e.Error().stack],{"_sentryBundlerPluginAppKey:listening-web":!0});var t=new e.Error().stack;t&&(e._sentryDebugIds=e._sentryDebugIds||{},e._sentryDebugIds[t]=`8e1632fe-e9d8-453c-a5b3-2e439ef2cea7`,e._sentryDebugIdIdentifier=`sentry-dbid-8e1632fe-e9d8-453c-a5b3-2e439ef2cea7`)}catch{}})();import{$o as e,$t as t,Ai as n,Br as r,Fr as i,G as a,H as o,Hn as s,Ht as c,Ir as l,J as u,Jo as d,Kn as f,Li as p,Lr as m,M as h,Ma as g,Mn as _,Mt as v,N as y,Na as ee,No as te,O as ne,Oa as re,Pi as ie,Pr as b,Qt as ae,R as oe,Rt as se,Sa as x,Sr as S,Tn as ce,Tr as C,V as w,Va as le,Vr as ue,Vt as T,Xo as de,Zn as fe,Zr as pe,an as me,b as E,bn as D,dt as he,es as O,f as k,h as ge,hn as _e,ht as ve,i as ye,io as be,is as A,j,jo as xe,k as Se,ln as Ce,ls as M,lt as we,mn as N,mo as Te,no as Ee,oo as De,os as Oe,q as ke,qa as P,s as Ae,v as je,vo as Me,wr as F,x as I,xa as Ne,xn as L,xt as Pe,ya as Fe,yn as R,yt as z,z as B,zi as Ie,zo as Le}from"./Schema-BiKO9Vds.js";import{A as Re,At as ze,Ct as Be,D as Ve,Dt as He,E as Ue,Et as We,F as Ge,Ft as Ke,I as qe,It as Je,Jt as Ye,Kt as Xe,L as V,Lt as Ze,M as Qe,Mt as $e,N as H,Nt as et,O as U,Ot as tt,P as nt,Pt as rt,R as it,Tt as at,Vt as ot,Yt as st,Zt as ct,an as lt,cn as ut,en as dt,in as ft,j as pt,jt as mt,k as ht,kt as gt,ln as _t,nn as vt,t as yt,wt as bt,xt,zt as St}from"./api-contract-CCE5gx-b.js";import{H as Ct,U as wt,V as W,z as Tt}from"./errors-BnQcWde3.js";var Et=e=>()=>{let t=B(ge(e));return ut((e,n)=>S(L(e,e=>t(e))))},G=A(2,(e,t)=>e===void 0?void 0:t(e)),Dt=e=>ft({b3:`${e.traceId}-${e.spanId}-${e.sampled?`1`:`0`}${Me(e.parent,{onNone:()=>``,onSome:e=>`-${e.spanId}`})}`,traceparent:`00-${e.traceId}-${e.spanId}-${e.sampled?`01`:`00`}`}),Ot=`~effect/http/HttpClient`,K=ee(`effect/HttpClient`),kt=A(2,(e,t)=>q(n=>t(e.postprocess(n)),e.preprocess)),q=(e,t)=>{let n=Object.create(At);return n.preprocess=t,n.postprocess=e,n.execute=function(n){return e(t(n))},n},At={[Ot]:Ot,pipe(){return M(this,arguments)},...xe,toJSON(){return{_id:`effect/HttpClient`}},...Object.fromEntries($e.map(([e,t])=>[t,function(t,n){return this.execute(We(e)(t,n))}]))},jt=e=>q(t=>L(t,t=>r(n=>{let r=Rt.get(t),i=r??new AbortController,a=mt(t.url,t.urlParams,Te(t.hash));if(be(a))return R(new W({reason:new Ct({request:t,cause:a.failure})}));let o=a.success;if(n.getRef(Fe)||n.getRef(Nt)(t)){let a=e(t,o,i.signal,n);return r?a:b(e=>f(e(a),{onSuccess(e){return J.register(e,i),S(new zt(e,i))},onFailure(e){return p(e)&&i.abort(),D(e)}}))}return l(n.getRef(It)(t),{kind:`client`},a=>{a.attribute(`http.request.method`,t.method),a.attribute(`server.address`,o.origin),o.port!==``&&a.attribute(`server.port`,+o.port),a.attribute(`url.full`,o.toString()),a.attribute(`url.path`,o.pathname),a.attribute(`url.scheme`,o.protocol.slice(0,-1));let s=o.search.slice(1);s!==``&&a.attribute(`url.query`,s);let c=n.getRef(vt),l=n.getRef(Pt);for(let e in t.headers)l(e,`request`)&&a.attribute(`http.request.header.${e}`,lt(e,c)?`<redacted>`:t.headers[e]);return t=n.getRef(Ft)?gt(t,Dt(a)):t,b(s=>s(e(t,o,i.signal,n)).pipe(ue(a,{captureStackTrace:!1}),f({onSuccess:e=>{a.attribute(`http.response.status_code`,e.status);for(let t in e.headers)l(t,`response`)&&a.attribute(`http.response.header.${t}`,lt(t,c)?`<redacted>`:e.headers[t]);return r?S(e):(J.register(e,i),S(new zt(e,i)))},onFailure(e){return!r&&p(e)&&i.abort(),D(e)}})))})})),S),Mt=A(2,(e,t)=>q(e.postprocess,n=>s(e.preprocess(n),t))),Nt=g(`effect/http/HttpClient/TracerDisabledWhen`,{defaultValue:()=>e}),Pt=g(`effect/http/HttpClient/TracerHeaderFilter`,{defaultValue:()=>O}),Ft=g(`effect/http/HttpClient/TracerPropagationEnabled`,{defaultValue:O}),It=g(`effect/http/HttpClient/SpanNameGenerator`,{defaultValue:()=>e=>`http.client ${e.method}`}),Lt=e=>pe(K)(_e(t=>s(e,e=>kt(e,i(e=>le(t,e)))))),J=(()=>

1{if(`FinalizationRegistry`in globalThis&&globalThis.FinalizationRegistry){let e=new FinalizationRegistry(e=>{e.abort()});return{register(t,n){e.register(t,n,t)},unregister(t){e.unregister(t)}}}let e=new Map;return{register(t,n){e.set(t,setTimeout(()=>n.abort(),5e3))},unregister(t){let n=e.get(t);n!==void 0&&(clearTimeout(n),e.delete(t))}}})(),Rt=new WeakMap,zt=class{original;controller;constructor(e,t){this.original=e,this.controller=t}[xt]=xt;[Be]=Be;applyInterrupt(e){return F(()=>(J.unregister(this.original),fe(e,()=>C(()=>{this.controller.abort()}))))}get request(){return this.original.request}get url(){return this.original.url}get status(){return this.original.status}get headers(){return this.original.headers}get cookies(){return this.original.cookies}get remoteAddress(){return this.original.remoteAddress}get formData(){return this.applyInterrupt(this.original.formData)}get text(){return this.applyInterrupt(this.original.text)}get json(){return this.applyInterrupt(this.original.json)}get urlParamsBody(){return this.applyInterrupt(this.original.urlParamsBody)}get arrayBuffer(){return this.applyInterrupt(this.original.arrayBuffer)}get stream(){return ct(()=>(J.unregister(this.original),ot(this.original.stream,C(()=>{this.controller.abort()}))))}toJSON(){return this.original.toJSON()}[te](){return this.original[te]()}pipe(){return M(this,arguments)}},Bt=`~effect/encoding/Sse/SseError`,Vt=class extends x(`EventTooLarge`){get message(){return`Pending SSE event exceeded the maximum size of ${this.maxEventSize}`}},Ht=class extends x(`SseError`){[Bt]=Bt;get message(){return this.reason.message}},Ut=10485760,Wt=e=>ut((t,n)=>C(()=>{let n=[],r,i=Kt(e=>{e._tag===`Retry`?r=e:n.push(e)},e),a=L(t,e=>{for(let t=0;t<e.length;t++){let n=i.feed(e[t]);if(n!==void 0)return R(n)}return m});return F(function e(){if(P(n)){let e=n;return n=[],S(e)}return r?R(r):L(a,e)})})),Gt=(e,t)=>_t(Wt(t),Et(Jt.pipe(w(e)))());function Kt(e,t){let n=t?.maxEventSize??Ut,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(qt)&&(i=i.slice(qt.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 Ht({reason:new Vt({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 Yt({duration:re(parseInt(p,10)),lastEventId:c}))}}var qt=``,Jt=I({id:we(E),event:E,data:E}),Y=`~effect/encoding/Sse/Retry`,Yt=class e extends Ne(`Retry`){[Y]=Y;static is(e){return d(e,Y)}static filter(t){return e.is(t)?De(t):Ee(t)}},Xt=(e,t)=>_(function*(){let r=yield*N(),i=t.httpClient.pipe(t?.baseUrl===void 0?Oe:Mt(He(t.baseUrl.toString())));function o(e,t,n,a,s){if(s===-1)return i.execute(n);let c=r.mapUnsafe.get(a[s]);return c===void 0?o(e,t,n,a,s-1):c({endpoint:t,group:e,request:n,next(n){return o(e,t,n,a,s-1)}})}Ue(e,{predicate:t?.predicate,onGroup(e){t.onGroup?.(e)},onEndpoint(e){let{group:r,endpoint:i,errors:s,successes:c}=e,l=$t(i.path),u={orElse:gn},d=new Map;for(let[e,t]of s.entries()){let n=rn(t);for(let[t,r]of n.entries())Z(d,e,t,en(r))}for(let[e,t]of d.entries()){let r=nn(t);u[e]=e=>L(Ce(r(e),t=>D(n(ie(new W({reason:new wt({request:e.request,response:e})})),t))),R)}let f=new Map;for(let[e,t]of c.entries()){let n=rn(t);for(let[t,r]of n.entries())Z(f,e,t,en(r))}for(let e of cn(i)){let t=sn(e)?e.schema:e;Z(f,Qe(e),t.contentType,ln(e))}for(let[e,t]of f.entries())u[e]=nn(t);let p=G(i.params,a),m=Ve(i),h=P(m)?et(i.method)?a(vn(m,i.method)):a(j(m)):void 0,g=G(i.headers,a),_=G(i.query,a),v=Array.from(e.middleware,e=>`${e.key}/Client`),y=ce(function*(e){let n=We(i.method)(i.path);if(e!==void 0){if(p!==void 0){let t=yield*p(e.params);n=ze(n,l(t))}if(h!==void 0){if(et(i.method)){if(e.payload instanceof FormData)n=at(n,e.payload);else{let t=yield*h(e.payload);n=tt(n,t)}}else{let t=yield*h(e.payload);n=bt(n,t)}}if(g!==void 0){let t=yield*g(e.headers);n=gt(n,t)}if(_!==void 0){let t=yield*_(e.query);n=bt(n,t)}}let a=yield*o(r,i,n,v,v.length-1);if(e?.responseMode===`response-only`)return a;let s=(u[a.status]??u.orElse)(a,e?.sseOptions),c=yield*t.transformResponse===void 0?s:t.transformResponse(s);return e?.responseMode===`decoded-and-response`?[c,a]:c});t.onEndpoint({...e,endpointFn:y})}})}),Zt=(e,t)=>L(K,n=>Qt(e,{...t,httpClient:t?.transformClient?t.transformClient(n):n})),Qt=(e,t)=>{let n={};return Xt(e,{...t,onGroup({group:e}){e.topLevel||Le(n,e.identifier,{})},onEndpoint({endpoint:e,endpointFn:t,group:r}){Le(r.topLevel?n:n[r.identifier],e.identifier,t)}}).pipe(me(n))},X=/(\/?):(\w+)(\?)?/g,$t=e=>X.test(e)?(X.lastIndex=0,t=>(X.lastIndex=0,e.replace(X,(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 en(e){let t=e.some(e=>V(e)||H(e.ast)!==void 0),n=t?j(e.map(tn)):hn(e),r=B(n);return e=>L(e.arrayBuffer,t?t=>r({body:t,headers:e.headers}):r)}function tn(e){let t=V(e),n=H(e.ast);if(n!==void 0)return I({body:$(n.body),headers:n.headersCodec}).pipe(w(e));let r=t?e.schema:e;return I({body:$(r).pipe(w(r)),headers:t?e.headers:h}).pipe(w(t?e:ve(e),T({decode:e=>t?it(e):e.body,encode:e=>t?e:{body:e,headers:void 0}})))}function Z(e,t,n,r){let i=U(n),a=e.get(t);a===void 0?e.set(t,[{contentType:i,decode:r}]):a.push({contentType:i,decode:r})}function nn(e){let t=e[0];return e.length===1&&t!==void 0?t.decode:(t,n)=>{let r=U(t.headers[`content-type`]??``),i=e.find(e=>e.contentType===r);return i===void 0?an(t,r,e):i.decode(t,n)}}function rn(e){let t=new Map;for(let n of e){let e=V(n)?n.schema:n,r=nt(e.ast)?``:U(pt(n).contentType),i=t.get(r);i===void 0?t.set(r,[n]):i.push(n)}return t}function an(e,t,n){let r=Array.from(new Set(n.map(e=>e.contentType))).join(`, `);return R(new W({reason:new Tt({request:e.request,response:e,description:`Unsupported response content-type for status ${e.status}: ${t||`<missing>`}. Expected one of: ${r}`})}))}var on=`effect/httpapi/stream/failure`,sn=e=>V(e);function cn(e){let t=[];for(let n of e.success){let e=V(n)?n.schema:n;Ge(e)&&t.push(n)}return t}function ln(e){let t=sn(e),n=t?e.schema:e,r=qe(n)?void 0:{declaration:n,decoder:un(n)},i=(e,t)=>s(N(),n=>st(r===void 0?e.stream:dn(e.stream,r.declaration,r.decoder(t)),n));if(!t)return i;let a=o(e.headers);return(e,t)=>L(a(e.headers),n=>s(i(e,t),e=>it({body:e,headers:n})))}function un(e){let t=j([I({event:k(on),data:ke(he(ye(e.error,Ae(

4))))}),e.events]),n=Gt(t);return e=>e===void 0?n:Gt(t,e)}function dn(e,t,n){let r=dt(e.pipe(St,Ye(n)),e=>C(()=>{let t;return F(()=>t===void 0?L(e,e=>{for(let n=0;n<e.length;n++){let r=e[n];if(r.event===on&&Ie(r.data)){if(n===0)return D(r.data);t=r.data,e=e.slice(0,n);break}}return S(e)}):D(t))}));return t.sseMode===`data`?Xe(r,e=>e.data):r}var fn=u(globalThis.ArrayBuffer,{expected:`ArrayBuffer`}),pn=fn.pipe(w(ne,T({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)}}))),Q=fn.pipe(w(E,T({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)}}))),mn=Q.pipe(w(j([k(``).pipe(w(Se,T({decode:()=>void 0,encode:()=>``}))),y])));function hn(e){return j(e.map(t));function t(e){return $(e).pipe(w(e))}}function $(e){switch(Re(e.ast)._tag){case`Json`:return v(se(e.ast))?mn.pipe(w(h,T({decode:e=>e===void 0?null:e,encode:e=>e===null?void 0:e}))):mn;case`FormUrlEncoded`:return Q.pipe(w(je,T({decode:e=>z(new URLSearchParams(e)),encode:Pe})));case`Uint8Array`:return pn;case`Text`:return Q}}var gn=e=>R(new W({reason:new Tt({request:e.request,response:e})})),_n=oe(rt);function vn(e,t){return j(e.map(e=>bn(e,t)))}var yn=new WeakMap;function bn(e,n){let r=e.ast,i=yn.get(r);if(i!==void 0)return i;let a=ht(r,n),o=_n.pipe(w(e,c({decode(e,t){return R(new ae({message:`Encode only schema`},e,t))},encode(e,n){switch(a._tag){case`Multipart`:return R(new ae({message:`Payload must be a FormData`},e,n));case`Json`:try{let t=JSON.stringify(e);return S(Ke(t,a.contentType))}catch{return R(new t({expected:`a JSON-serializable request body`},e,n))}case`Text`:return typeof e==`string`?S(Ke(e,a.contentType)):R(new t({message:`Expected a string`},e,n));case`FormUrlEncoded`:return de(e)?S(Ze(z(e),a.contentType)):R(new t({message:`Expected a record`},e,n));case`Uint8Array`:return e instanceof Uint8Array?S(Je(e,a.contentType)):R(new t({message:`Expected a Uint8Array`},e,n))}}})));return yn.set(r,o),o}var xn=class extends ee()(`@listening/api-contract/ApiClient`){static layer=e=>pe(this,Zt(yt,e))};export{jt as i,K as n,Lt as r,xn as t};
5//# sourceMappingURL=api-client-tag-rKJyW-Av.js.map