1import{i as e}from"./rolldown-runtime-Dd_uD5pT.js";import{C as t,E as n,S as r,T as i,_ as a,a as o,b as s,c,d as l,g as u,h as d,i as f,l as p,m,o as h,p as g,s as _,v,x as y}from"./src-C6CrqkOt.js";import{n as b,r as ee,t as x}from"./compiler-runtime-5zjLlyPH.js";import{n as te}from"./dist-DjSz73FF.js";import{t as S}from"./events-CLTOOFOh.js";import{$ as ne,B as C,Et as re,N as w,P as T,Q as ie,R as ae,T as E,Tt as oe,X as D,b as O,bt as se,d as ce,dt as k,et as le,ft as ue,m as A,n as j,nn as de,p as M,r as fe,st as pe,t as me,w as N,y as P,z as he}from"./Schema-CZHV2hOB.js";import"./limits-DqKQWoi2.js";import{D as ge,E as _e,O as ve}from"./co-models-C5RJ7IBQ.js";import{t as ye}from"./model-config-D1_XeiP9.js";import{t as F}from"./StripUndefined-BSTNQdSW.js";import{A as be,C as xe,E as Se,M as Ce,N as we,O as Te,R as Ee,S as De,U as Oe,_ as ke,a as Ae,b as je,c as Me,d as Ne,g as Pe,h as Fe,i as Ie,j as Le,l as Re,m as ze,n as Be,r as Ve,s as He,t as Ue,u as We,v as Ge,w as Ke,x as qe}from"./Events-DR-IKN4x.js";import{t as I}from"./Guards-C_DUG1sx.js";import{t as Je}from"./Subscriptions-CNXmxaZN.js";var L={entry:`co:entry`,authOptimistic:`co:auth:optimistic`,authLive:`co:auth:live`,authFailed:`co:auth:failed`,epochActive:`co:auth-epoch:active`,epochClaimFailed:`co:auth-epoch:claim-failed`,runtimeStarted:`co:runtime:started`,workerConstructed:`co:worker:constructed`,workerHello:`co:worker:hello`,workerReady:`co:worker:ready`,runtimeFallback:`co:runtime:fallback`,persistenceOpenStarted:`co:persistence:open-started`,persistenceOpened:`co:persistence:opened`,persistencePopulated:`co:persistence:populated`,persistenceReady:`co:persistence:ready`,workspaceAdmitted:`co:workspace:admitted`,collectionsOpenStarted:`co:collections:open-started`,criticalHydrated:`co:collections:critical-hydrated`,appDbHydrated:`co:app-db:hydrated`,shellMounted:`co:shell:mounted`,sidebarReady:`co:sidebar:ready`,currentSessionReady:`co:current-session:ready`,bootComplete:`co:boot:complete`};L.persistenceOpenStarted,L.persistenceOpened,L.persistencePopulated,L.persistenceReady;var Ye=Object.values(L),Xe=new Set(Ye);function Ze(e){return Xe.has(e)}var Qe=new Map,$e=new Map,et,tt=new Set;function nt(){return typeof performance?.now==`function`?performance.timeOrigin+performance.now():Date.now()}function rt(e,t,n){for(let r of[...tt])try{r(e,t,n)}catch(e){console.error(`[startup-marks] listener failed:`,e)}}function it(e){if(Qe.has(e))return!1;let t=nt();return Qe.set(e,t),typeof performance?.mark==`function`&&performance.mark(e),rt(`local`,e,t),!0}function at(e){let t={};for(let[n,r]of e)t[n]=r;return t}function ot(){return at(Qe)}function st(e,t){et!==e&&(et=e,$e.clear());let n=new Set;for(let[e,r]of Object.entries(t))Ze(e)&&typeof r==`number`&&(n.add(e),!$e.has(e)&&($e.set(e,r),rt(`worker`,e,r)));for(let e of[...$e.keys()])n.has(e)||$e.delete(e)}function ct(){return at($e)}function lt(e){return tt.add(e),()=>{tt.delete(e)}}var R=e(ee(),1),ut=b(),dt=x(),ft=e=>typeof e==`object`&&!!e&&!Array.isArray(e),pt=e=>e.then(()=>void 0,()=>void 0),z=class extends Error{name=`TransportError`};function mt(e,t){return{lastEventId:e.afterEventId,deltas:e.deltas,...e.liveOnly===!0?{liveOnly:!0}:{},...e.refresh===!0?{refresh:!0}:{},signal:t}}var ht=45e3,gt=3e4,_t=3e4,vt=5e3,yt=class extends z{reason;lastFrameAgeMs;constructor(e,t){super(e),this.reason=t.reason,this.lastFrameAgeMs=t.lastFrameAgeMs??null}},bt=class extends z{},xt=class extends z{retryAfterMs;constructor(e,t){super(`Session event stream rate limit exceeded`,t),this.retryAfterMs=e}},St=class extends z{retryAfterMs;constructor(e,t){super(`Session event page rate limit exceeded`,t),this.retryAfterMs=e}},Ct=class extends z{status;constructor(e,t){super(`Session event push failed with status ${e}`,t),this.status=e}},wt=class extends Ct{retryAfterMs;constructor(e,t){super(429,t),this.retryAfterMs=e}},Tt=class extends z{},Et=200,Dt=e=>e.headId===void 0?{}:{headId:e.headId},Ot=(e,t)=>ft(t)&&typeof t.id==`number`&&t.id>0&&t.transient!==!0&&(e===void 0||t.id>e)?t.id:e,kt=e=>{if(!ft(e)||typeof e.id!=`number`||typeof e.threadId!=`number`||typeof e.at!=`number`||typeof e.transient!=`boolean`)return!1;let t=e.payload;return ft(t)&&typeof t.type==`string`};function At(e){let{api:t}=e,n=e.staleAfterMs??ht,r=e.sendTimeoutMs===!1?void 0:e.sendTimeoutMs??gt,i=Promise.resolve(void 0),a=[],o=null,s=null,c=null,l={ping:0,live:0,event:0,watchdog_fired:0,behind_head:0,malformed_event:0},u=new Set,d=()=>{l.malformed_event+=1;for(let e of u)e()},f=e=>{let t=Date.now();
1e!==`watchdog_fired`&&(o=t),e===`live`&&(s=t),e===`event`&&(c=t),l[e]+=1;let n=[...a,{type:e,at:t}];a=n.length>Et?n.slice(n.length-Et):n;for(let e of u)e()},p=async n=>{let r=AbortSignal.timeout(e.readTimeoutMs??_t),i=n?.signal===void 0?r:AbortSignal.any([n.signal,r]),a=await t.listEvents({...n,signal:i}),o=[],s;for(let e of a.events){if(kt(e)&&!e.transient){o.push(e);continue}d(),s=Ot(s,e)}return{events:o,hasMore:a.hasMore,...s===void 0?{}:{skippedMaxId:s},...a.headId===void 0?{}:{headId:a.headId}}};return{...t.createThread===void 0?{}:{createThread:t.createThread},...t.forkThread===void 0?{}:{forkThread:t.forkThread},diagnostics:{lastFrameAt:()=>o,lastLiveFrameAt:()=>s,lastEventFrameAt:()=>c,frameCounts:()=>({...l}),entries:()=>a,subscribe(e){return u.add(e),()=>u.delete(e)}},listEvents:p,events(e){let r=new AbortController,i=!1,a=!1,s=null,c=null,l=e.afterEventId??0,u=!1,d=0,m=0,h=0,g=0,_=null,v=0,y=!1,b=null,ee=()=>void 0,x=()=>void 0,te=new Promise((e,t)=>{ee=e,x=t}),S=()=>{c!==null&&(clearTimeout(c),c=null)},ne=(e,t)=>{let n=o===null?null:Math.max(0,Date.now()-o);f(e),s=new yt(t,{reason:e,lastFrameAgeMs:n}),r.abort()},C=()=>{S(),c=setTimeout(()=>{ne(`watchdog_fired`,`HTTP event stream went stale: no frames for ${n}ms`)},n)},re=e=>{ne(`behind_head`,`HTTP event stream fell behind the server's durable head: ${e}`)},w=async e=>{y=!0;try{let t=await p({afterEventId:e,limit:1,signal:r.signal});return t.events.find(t=>t.id>e)?.id??(t.skippedMaxId!==void 0&&t.skippedMaxId>e?t.skippedMaxId:void 0)}catch{return}finally{y=!1}},T=e=>!i&&s===null&&g===e,ie=()=>{b!==null&&(clearTimeout(b),b=null)},ae=async()=>{let e=l,t=g,n=await w(e);n===void 0||!T(t)||(b=setTimeout(()=>{b=null,T(t)&&re(`heartbeats carried no events while durable event ${n} was appended after ${e}`)},vt))},E=()=>{let e=a&&_!==null&&_===g;if(_=a?g:null,!e){v=0;return}y||b!==null||v>=3||(v+=1,pt(ae()))},oe=e=>{let t=e.headId!==void 0&&e.headId>l,n=l>d,r=t&&e.headId!==void 0?e.headId-l:0,i=r>m,a=t&&u&&!n;if(h=t&&u&&i?h+1:0,a||h>=2){re(`heartbeat reported head ${e.headId} while ${l} was the last delivered`);return}u=t,d=l,m=r,E()},D=e=>{ft(e)&&typeof e.id==`number`&&e.id>l&&e.transient!==!0&&(l=e.id)},O=e=>{a=!0,e.headId!==void 0&&(l=Math.max(l,e.headId)),ee(Dt(e))},se=(e,t)=>{e.transient||(l=Math.max(l,e.id)),t.enqueue(e)};return{stream:new ReadableStream({start(n){let o=e=>{if(e.type===`ping`){f(`ping`),oe(e);return}if(e.type===`live`){f(`live`),O(e);return}if(g+=1,!kt(e.event)){f(`malformed_event`),D(e.event);return}f(`event`),se(e.event,n)},c=async()=>{let n=t.streamEvents(mt(e,r.signal));C();for await(let e of n){if(i||s!==null)return;C(),o(e)}},l=e=>{let t=e instanceof z?e:new z(`HTTP event stream failed`,{cause:e});n.error(t),x(t)};pt((async()=>{try{await c()}catch(e){S(),ie(),i||l(s??e);return}if(S(),ie(),!i){if(s!==null){l(s);return}a||x(new z(`HTTP event stream ended before the live boundary`)),n.close()}})())},cancel(){i=!0,S(),ie(),x(new z(`stream cancelled before backfill complete`)),r.abort()}}),backfillDone:te}},async sendEvent(e,n){let a=i.then(()=>t.pushEvents([e],{...r===void 0?{}:{signal:AbortSignal.timeout(r),deadlineAt:Date.now()+r},idempotencyKey:n?.idempotencyKey??crypto.randomUUID(),...n?.threadId===void 0?{}:{threadId:n.threadId}}));i=pt(a);try{await a}catch(e){throw e instanceof Ct?e:new z(`HTTP event dispatch failed`,{cause:e})}}}}var jt=(0,R.createContext)(null);function Mt(e){let t=(0,dt.c)(5),{children:n,client:r}=e,i;t[0]===r?i=t[1]:(i={client:r},t[0]=r,t[1]=i);let a=i,o;return t[2]!==n||t[3]!==a?(o=(0,ut.jsx)(jt.Provider,{value:a,children:n}),t[2]=n,t[3]=a,t[4]=o):o=t[4],o}function Nt(){let e=(0,R.useContext)(jt);if(!e)throw Error(`useAgentClient must be used within an AgentClientProvider`);return e}var Pt=ce.pipe(he(ne(0)),ae(`ThreadId`)),Ft=Pt.make(0);function It(e){return e[L.runtimeFallback]===void 0?`worker`:`tab`}function Lt({worker:e,navigationStart:t}){let n=e[L.persistenceOpened];return n!==void 0&&n<t?`returning`:e[L.persistencePopulated]===void 0?`cold`:`warm`}function Rt({worker:e,navigationStart:t}){let n=e[L.persistenceOpenStarted];if(n===void 0||n<t)return!1;let r=e[L.persistenceReady];return r===void 0||r-n>15e3}function zt(e,t,n){let r=e[t];return r===void 0||r<n?null:Math.round(r-n)}function Bt(e){let{page:t,navigationStart:n}=e,r=It(t),i=r===`worker`?e.worker:{},a=e=>zt(t,e,n);return{entryMs:a(L.entry),workerReadyMs:a(L.workerReady),persistenceReadyMs:(e=>zt(i,e,n))(L.persistenceReady),criticalHydratedMs:a(L.criticalHydrated),shellMountedMs:a(L.shellMounted),sidebarReadyMs:a(L.sidebarReady),currentSessionReadyMs:a(L.currentSessionReady),runtime:r,sce
1nario:Lt({worker:i,navigationStart:n}),persistenceTimedOut:Rt({worker:i,navigationStart:n}),capture:t[L.sidebarReady]===void 0?`capped`:`settled`}}var Vt=new Set,Ht=3e4,Ut=[];function Wt(e){let t=e-Ht,n=Ut[0];for(;n!==void 0&&n.end<t;)Ut.shift(),n=Ut[0]}function Gt(e,t){Wt(performance.now());let n=t===void 0?[]:Ut.filter(e=>e.sessionId===t.sessionId&&e.end>=t.since&&(t.until===void 0||e.end<=t.until));Vt.add(e);for(let t of n)e(t);return()=>Vt.delete(e)}function Kt(e,t){let n=performance.now();return r=>{let i=performance.now(),a={label:e,sessionId:t,start:n,end:i,rowCount:r?.rowCount,eventCount:r?.eventCount};if(Wt(i),Ut.push(a),Ut.length>256&&Ut.shift(),Vt.size!==0)for(let e of Vt)e(a)}}function qt(e){let t={pageCount:0,cacheHitCount:0,networkFetchCount:0,networkMs:0,writeQueueWaitMs:0,writeBackMs:0},n=Gt(n=>{n.sessionId===e&&Jt(t,n)});return e=>(n(),{outcome:e,pageCount:t.pageCount,cacheHitCount:t.cacheHitCount,networkFetchCount:t.networkFetchCount,networkMs:Math.round(t.networkMs),writeQueueWaitMs:Math.round(t.writeQueueWaitMs),writeBackMs:Math.round(t.writeBackMs)})}function Jt(e,t){let n=t.end-t.start;switch(t.label){case`page step`:e.pageCount+=1;return;case`cache hit`:e.cacheHitCount+=1;return;case`network fetch`:e.networkFetchCount+=1,e.networkMs+=n;return;case`write-queue wait`:e.writeQueueWaitMs+=n;return;case`write-back`:e.writeBackMs+=n;return;case`peek write-queue wait`:case`client network fetch`:case`hydrate`:case`fold`:case`boot-span fold`:return;default:Yt(t.label)}}function Yt(e){throw Error(`Unhandled history timing label: ${String(e)}`)}function Xt(e,t){let n=e[0][1];for(let[r,i]of e)t>=r&&(n=i);return n}var Zt=[[0,`0-50`],[51,`51-200`],[201,`201-1k`],[1001,`1k-5k`],[5001,`5k+`]],Qt=[[0,`0`],[1,`1-5`],[6,`6-20`],[21,`21-100`],[101,`100+`]],$t=[[0,`0`],[1,`1-3`],[4,`4-10`],[11,`11-50`],[51,`50+`]],en=[[0,`0-64k`],[65536,`64k-512k`],[524288,`512k-4m`],[4194304,`4m+`]],tn=[[0,`<5s`],[5e3,`5s-1m`],[6e4,`1m-15m`],[9e5,`15m+`]],nn=[[0,`0`],[1,`1-5`],[6,`6-20`],[21,`21+`]],rn=e=>Xt(Zt,e),an=e=>Xt(Zt,e),on=e=>Xt(Qt,e),sn=e=>Xt($t,e),cn=e=>Xt(en,e),ln=e=>Xt(tn,e),un=e=>Xt(nn,e),dn=3e4,fn=5e3,pn=1e4,mn=5e3,hn=[{feature:`sync_commit`,start:`co:sync:commit:start`,end:`co:sync:commit:end`},{feature:`live_query`,start:`co:sync:live-query-flush:start`,end:`co:sync:live-query-flush:end`}],gn=1e3,_n=`co:commit:`;function vn(e,t){let n=[...t].sort((e,t)=>e-t),r=0;return[...e].sort((e,t)=>e-t).flatMap(e=>{for(;r<n.length;){let t=n[r];if(r+=1,t!==void 0&&t>=e)return[{start:e,end:t}]}return[]})}function yn(e){let{task:t,syncWindows:n,commits:r}=e,i=new Map;for(let e of n){let n=Math.min(e.end,t.end)-Math.max(e.start,t.start);n>=0&&i.set(e.feature,(i.get(e.feature)??0)+n)}let a;for(let{feature:e}of hn){let t=i.get(e);t!==void 0&&(a===void 0||t>(i.get(a)??0))&&(a=e)}return a??xn(r,t.start)}function bn(e){let t=new Map,n=new Map;return{admit(r,i){let a=e(),o=t.get(r);if(o!==void 0&&a-o<i)return n.set(r,(n.get(r)??0)+1),{admitted:!1};t.set(r,a);let s=n.get(r)??0;return n.set(r,0),{admitted:!0,droppedSinceLast:s}}}}function xn(e,t){for(let n=e.length-1;n>=0;--n){let r=e[n];if(!(r===void 0||r.at>t))return t-r.at<=gn?r.feature:`unknown`}return`unknown`}function Sn(e){let{now:t,openedAt:n,readDimensions:r,sampler:i,track:a}=e,o={gateOpen:null,hydrated:null,folded:null,firstRow:null,live:null},s=null,c=!1,l={hydrateMs:0,hydrateRowCount:0,networkFetchMs:0,networkEventCount:0,networkFetchCount:0,foldMs:0,foldEventCount:0,writeQueueWaitMs:0,writeBackMs:0,cacheHitMs:0},u=!1,d=!1,f=()=>void 0,p=()=>void 0,m=[],h=[],g,_=[],v=t=>{c||(c=!0,f(),p(),a(`session.open`,{...l,...r(),gateOpenMs:e.wasLive?null:o.gateOpen,hydratedMs:o.hydrated,foldedMs:o.folded,firstRowMs:o.firstRow,liveMs:o.live,interactiveMs:s,outcome:t}))},y=()=>{if(!u||c||o.firstRow===null)return;p();let r=t();p=e.schedule(()=>{s=Math.round(r-n),v(`complete`)},200)},b=()=>{let e=t()-dn;for(;m.length>64||(m[0]?.at??1/0)<e;)m.shift();for(;h.length>64||(h[0]?.startTime??1/0)<e;)h.shift()},ee=(e,t)=>h.reduce((n,r)=>r.startTime>=e&&r.startTime<=t?Math.max(n,r.duration):n,0),x=(e,t)=>m.filter(n=>n.at>
1=e&&n.at<=t).length,te=(e,t,n)=>{if(d||n<t)return;let o=i.admit(`interaction:${e.kind}`,fn);o.admitted&&a(`session.interaction`,{...r(),droppedSinceLast:o.droppedSinceLast,durationMs:Math.round(n-t),longestTaskMs:Math.round(ee(t,n)),commitCount:x(t,n),...e})},S=t=>yn({task:{start:t.startTime,end:t.startTime+t.duration},syncWindows:e.syncWindowsSince(t.startTime),commits:m}),ne=e=>{let t=_.indexOf(e);if(t===-1||d)return;_.splice(t,1);let{at:n,firstFrameAt:i,tasks:o}=e,s=o.reduce((e,t)=>e===void 0||t.duration>e.duration?t:e,void 0);a(`session.tab_resume`,{...r(),msToFirstFrame:i===void 0?null:Math.round(i-n),queuedWorkMs:Math.round(o.reduce((e,t)=>e+t.duration,0)),queuedWorkCount:o.length,longestTaskMs:Math.round(s?.duration??0),longestFeature:s===void 0?`unknown`:S(s)})},C=()=>c?e.isStreaming()?`streaming`:`idle`:`open`;return{start(){u||d||(u=!0,f=e.schedule(()=>v(`timedOut`),Math.max(0,dn-(t()-n))),y())},observeHistoryTiming(e){if(d||c||e.end<n||e.end>n+3e4)return;let t=Math.max(0,e.end-Math.max(e.start,n));switch(e.label){case`hydrate`:l.hydrateMs+=t,l.hydrateRowCount+=e.rowCount??0;break;case`client network fetch`:case`network fetch`:l.networkFetchMs+=t,l.networkFetchCount+=1,l.networkEventCount+=e.eventCount??0;break;case`fold`:case`boot-span fold`:l.foldMs+=t,l.foldEventCount+=e.eventCount??0;break;case`peek write-queue wait`:case`write-queue wait`:l.writeQueueWaitMs+=t;break;case`write-back`:l.writeBackMs+=t;break;case`cache hit`:l.cacheHitMs+=t}},markPhase(r,i){if(d||o[r]!==null)return;let a=i??t();o[r]=Math.max(0,Math.round(a-n)),r===`firstRow`&&(y(),e.isSwitch&&te({kind:`switch`},n,a))},recordCommit(n){d||(e.mark(`${_n}${n}`),m.push({feature:n,at:t()}),b())},observeLongTask(t){if(d)return;h.push(t),b(),y();for(let e of _)t.startTime>=e.at&&t.startTime<=e.at+5e3&&e.tasks.push(t);if(t.duration<100)return;let n=e.visibilityAt(t.startTime),o=i.admit(`long_task:${n}`,pn);o.admitted&&a(`session.long_task`,{...r(),droppedSinceLast:o.droppedSinceLast,durationMs:Math.round(t.duration),feature:S(t),phase:C(),visibility:n})},observeInputTiming(e){let t=e.startTime+e.duration;if(e.kind===`scroll-backfill`){te({kind:e.kind,...e.breakdown},e.startTime,t);return}te({kind:e.kind},e.startTime,t)},beginSend(){g=t()},completeSend(){if(g===void 0)return;let e=g;g=void 0,te({kind:`send`},e,t())},beginTabResume({hiddenMs:t,at:n}){if(d)return;let r={at:n,hiddenMs:t,firstFrameAt:void 0,tasks:[],cancel:()=>void 0};_.push(r),r.cancel=e.schedule(()=>ne(r),mn)},recordResumeFrame(e){let t=_.at(-1);t!==void 0&&t.firstFrameAt===void 0&&(t.firstFrameAt=e)},isOpenCaptured:()=>c,dispose(){if(!d){v(`aborted`),d=!0,f(),p();for(let e of _.splice(0))e.cancel()}}}}var B=e=>typeof e==`object`&&!!e&&!Array.isArray(e),Cn=new Set(_e),wn=new Set(ge),Tn=e=>B(e)&&typeof e.modelId==`string`&&typeof e.reasoning==`string`&&Cn.has(e.reasoning)&&(e.speed===void 0||typeof e.speed==`string`&&wn.has(e.speed)),V=(e,t)=>e.type===t;function En(e,t){let n=[],r=new Set,i=t;for(;!r.has(i);){if(n.unshift(i),i===0)return n;r.add(i);let t=e.find(e=>e.branchId===i);if(t===void 0)return n;i=t.parentBranchId}return[t]}function Dn(e,t){return e.find(e=>e.branchId===t)}var On=e=>B(e)&&typeof e.branchId==`number`&&Number.isInteger(e.branchId)&&e.branchId>0&&typeof e.parentBranchId==`number`&&Number.isInteger(e.parentBranchId)&&e.parentBranchId>=0&&typeof e.forkedAfterMessageId==`number`&&Number.isInteger(e.forkedAfterMessageId)&&e.forkedAfterMessageId>=0&&(e.forkedAfterClientMessageId===null||typeof e.forkedAfterClientMessageId==`string`)&&(e.reason===`rewind`||e.reason===`edit`||e.reason===`regenerate`),kn=e=>{for(let t of e){let n=new Set,r=t.branchId;for(;r!==0;){if(n.has(r))return!0;n.add(r);let t=Dn(e,r);if(t===void 0)break;r=t.parentBranchId}}return!1},An={name:`branches`,version:1,initial:()=>({activeBranchId:0,branches:[]}),reduce:(e,t)=>{let n=t.payload;if(V(n,`branch.created`)){let t={branchId:n.branchId,parentBranchId:n.parentBranchId,forkedAfterMessageId:n.forkedAfterMessageId,forkedAfterClientMessageId:n.forkedAfterClientMessageId,reason:n.reason},r=e.branches.findIndex(e=>e.branchId===t.branchId),i=e.branches.slice();return r<0?i.push(t):i[r]=t,{activeBranchId:t.branchId,branches:i}}return V(n,`branch.switched`)&&n.branchId!==e.activeBranchId?{...e,activeBranchId:n.branchId}:e},validate:e=>{if(!B(e)||typeof e.activeBranchId!=`number`||!Number.isInteger(e.activeBranchId)||e.activeBranchId<0||!Array.isArray(e.branches)||!e.branches.every(On))return!1;let t=e.branches.map(e=>e.branchId);return new Set(t).size===t.length&&!kn(e.branches)}};function jn(e,t,n){let r=e.branches.filter(e=>e.forkedAfterMessageId===t&&(n===void 0||e.parentBranchId===n)),i=new Set(r.map(e=>e.parentBranchId));if(t===0&&n===void 0&&i.size>1)return;let a=n??r[0]?.parentBranchId;if(a===void 0)return;let o=r.filter(e=>e.parentBranchId===a),s=[a,...o.map(e=>e.branchId)],c=new Set(En(e.branches,e.activeBranchId)),l=o.findIndex(e=>c.has(e.branchId));return{index:l<0?0:l+1,count:s.length,branchIds:s}}function Mn(e){return{name:e.name,threadScope:e.threadScope,isSnapshotable:e.isSnapshotable,consumedTypes:[`branch.created`,`branch.switched`],reducer:An}}var Nn=Mn({name:An.name,threadScope:{kind:`thread`,threadId:0}}),Pn=e=>B(e)&&(e.usedTokens===void 0||typeof e.usedTokens==`number`)&&(e.basis===void 0||e.basis===`reported`||e.basis===`estimated`),Fn=(e,t)=>{let n=t?.contextInputTokens??t?.usage?.inputTokens??t?.usage?.totalTokens;
1return typeof n==`number`?e.usedTokens===n&&e.basis===`reported`?e:{usedTokens:n,basis:`reported`}:e},In=(e,t)=>t===void 0||e.usedTokens===t&&e.basis===`estimated`?e:{usedTokens:t,basis:`estimated`},Ln={name:`context-usage`,version:2,initial:()=>({}),reduce:(e,t)=>{let n=t.payload;return V(n,`message.completed`)?Fn(e,n.metadata):V(n,`compaction.completed`)?In(e,n.compaction?.usage.replayInputTokensEstimate):V(n,`history.truncated`)?e.usedTokens===void 0&&e.basis===void 0?e:{}:e},validate:Pn},Rn={name:Ln.name,consumedTypes:[`message.completed`,`compaction.completed`,`history.truncated`],latestEventBootstrap:!0,reducer:Ln},zn={name:`events-log`,consumesTransient:!0,initial:()=>({events:[]}),reduce:(e,t)=>({events:[...e.events,t].slice(-200)})},Bn=new Set([`pursuing`,`paused`,`achieved`,`unmet`,`budget_limited`]),Vn=e=>B(e)&&typeof e.inputTokens==`number`&&typeof e.outputTokens==`number`&&typeof e.cacheReadTokens==`number`&&typeof e.cacheWriteTokens==`number`&&typeof e.turns==`number`,Hn=e=>B(e)&&typeof e.summary==`string`&&typeof e.evidence==`string`,Un=e=>{if(!B(e))return!1;let t=e.goal;return t===null||B(t)&&typeof t.goalId==`number`&&typeof t.objective==`string`&&typeof t.revision==`number`&&typeof t.status==`string`&&Bn.has(t.status)&&(t.hold===null||t.hold===`plan`)&&(t.tokenBudget===null||typeof t.tokenBudget==`number`)&&Vn(t.usage)&&typeof t.activeMs==`number`&&(t.lastResumedAt===null||typeof t.lastResumedAt==`number`)&&(t.wrapUpStartedAt===null||typeof t.wrapUpStartedAt==`number`)&&(t.result===null||Hn(t.result))&&typeof t.createdAt==`number`&&(t.endedAt===null||typeof t.endedAt==`number`)},Wn=(e,t)=>({goalId:e.goalId,objective:e.objective,revision:e.revision,status:`pursuing`,hold:null,tokenBudget:e.tokenBudget,usage:{inputTokens:0,outputTokens:0,cacheReadTokens:0,cacheWriteTokens:0,turns:0},activeMs:0,lastResumedAt:t,wrapUpStartedAt:null,result:null,createdAt:t,endedAt:null}),Gn=(e,t)=>({...e,revision:t.revision,objective:t.objective??e.objective,tokenBudget:t.budget===void 0?e.tokenBudget:t.budget.tokenBudget,wrapUpStartedAt:null}),Kn=e=>e===`achieved`||e===`unmet`||e===`budget_limited`,qn=(e,t,n)=>({...e,status:t.status,hold:t.hold??null,activeMs:t.activeMs,lastResumedAt:t.lastResumedAt,wrapUpStartedAt:t.cause===`wrap_up_armed`?n:e.wrapUpStartedAt,result:t.result??e.result,endedAt:Kn(t.status)?n:e.endedAt}),Jn=(e,t)=>({...e,usage:t.usage}),Yn=(e,t)=>e===t||e<0,Xn={name:`goal`,version:1,initial:()=>({goal:null}),reduce:(e,t)=>{let n=t.payload;if(V(n,`goal.set`))return{goal:Wn(n,t.at)};let r=e.goal;return r===null?e:V(n,`goal.cleared`)?{goal:null}:V(n,`goal.updated`)&&Yn(n.goalId,r.goalId)?{goal:Gn(r,n)}:V(n,`goal.status`)&&Yn(n.goalId,r.goalId)?{goal:qn(r,n,t.at)}:V(n,`goal.usage`)&&n.goalId===r.goalId?{goal:Jn(r,n)}:e},validate:Un},Zn={name:Xn.name,consumedTypes:[`goal.set`,`goal.updated`,`goal.status`,`goal.usage`,`goal.cleared`],reducer:Xn},Qn={name:`mode`,version:3,initial:()=>({mode:null,displaced:null}),reduce:(e,t)=>{if(!V(t.payload,`mode.changed`))return e;let n=t.payload.mode;return t.payload.displaced===void 0?e.mode===n?e:{mode:n,displaced:n===`plan`?e.mode:null}:e.mode===n&&e.displaced===t.payload.displaced?e:{mode:n,displaced:t.payload.displaced}},validate:e=>B(e)&&(e.mode===null||typeof e.mode==`string`)&&(e.displaced===null||typeof e.displaced==`string`)};function $n(e){return e.type===`mode.changed`}var er={name:Qn.name,consumedTypes:[`mode.changed`],reducer:Qn},tr={name:`model`,version:1,initial:()=>({config:null}),reduce:(e,t)=>!V(t.payload,`model.changed`)||e.config!==null&&ye(e.config,t.payload.config)?e:{config:t.payload.config},validate:e=>B(e)&&(e.config===null||Tn(e.config))};function nr(e){return e.type===`model.changed`}var rr={name:tr.name,consumedTypes:[`model.changed`],reducer:tr};function ir(e){return{...rr,name:`${rr.name}@${e}`,threadScope:{kind:`thread`,threadId:e}
vendor: 32,214 bytes, lines 1-7
1,isSnapshotable:!1,consumedTypes:[...rr.consumedTypes,`thread.created`],reducer:{...tr,reduce:(e,t)=>V(t.payload,`thread.created`)&&t.payload.modelConfig!==void 0?tr.reduce(e,{...t,payload:{type:`model.changed`,config:t.payload.modelConfig}}):tr.reduce(e,t)}}}var ar=`vercel.ai.error`,or=Symbol.for(ar),sr,cr,lr=class e extends (cr=Error,sr=or,cr){constructor({name:e,message:t,cause:n}){super(t),this[sr]=!0,this.name=e,this.cause=n}static isInstance(t){return e.hasMarker(t,ar)}static hasMarker(e,t){let n=Symbol.for(t);return typeof e==`object`&&!!e&&n in e&&typeof e[n]==`boolean`&&e[n]===!0}};function ur(e){return e==null?`unknown error`:typeof e==`string`?e:e instanceof Error?e.toString():JSON.stringify(e)}var dr=`AI_InvalidArgumentError`,fr=`vercel.ai.error.${dr}`,pr=Symbol.for(fr),mr,hr,gr=class extends (hr=lr,mr=pr,hr){constructor({message:e,cause:t,argument:n}){super({name:dr,message:e,cause:t}),this[mr]=!0,this.argument=n}static isInstance(e){return lr.hasMarker(e,fr)}},_r=`AI_JSONParseError`,vr=`vercel.ai.error.${_r}`,yr=Symbol.for(vr),br,xr,Sr=class extends (xr=lr,br=yr,xr){constructor({text:e,cause:t}){super({name:_r,message:`JSON parsing failed: Text: ${e}. 2Error message: ${ur(t)}`,cause:t}),this[br]=!0,this.text=e}static isInstance(e){return lr.hasMarker(e,vr)}},Cr=`AI_TypeValidationError`,wr=`vercel.ai.error.${Cr}`,Tr=Symbol.for(wr),Er,Dr,Or=class e extends (Dr=lr,Er=Tr,Dr){constructor({value:e,cause:t,context:n}){let r=`Type validation failed`;if(n?.field&&(r+=` for ${n.field}`),n?.entityName||n?.entityId){r+=` (`;let e=[];n.entityName&&e.push(n.entityName),n.entityId&&e.push(`id: "${n.entityId}"`),r+=e.join(`, `),r+=`)`}super({name:Cr,message:`${r}: Value: ${JSON.stringify(e)}. 3Error message: ${ur(t)}`,cause:t}),this[Er]=!0,this.value=e,this.context=n}static isInstance(e){return lr.hasMarker(e,wr)}static wrap({value:t,cause:n,context:r}){return e.isInstance(n)&&n.value===t&&n.context?.field===r?.field&&n.context?.entityName===r?.entityName&&n.context?.entityId===r?.entityId?n:new e({value:t,cause:n,context:r})}};new TextDecoder;var{btoa:kr,atob:Ar}=globalThis,H=({prefix:e,size:t=16,alphabet:n=`0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz`,separator:r=`-`}={})=>{let i=()=>{let e=n.length,r=Array(t);for(let i=0;i<t;i++)r[i]=n[Math.random()*e|0];return r.join(``)};if(e==null)return i;if(n.includes(r))throw new gr({argument:`separator`,message:`The separator "${r}" must not be part of the alphabet "${n}".`});return()=>`${e}${r}${i()}`};H();function jr(e){return globalThis.Buffer?.isBuffer(e)??!1}var Mr=/"(?:_|\\u005[Ff])(?:_|\\u005[Ff])(?:p|\\u0070)(?:r|\\u0072)(?:o|\\u006[Ff])(?:t|\\u0074)(?:o|\\u006[Ff])(?:_|\\u005[Ff])(?:_|\\u005[Ff])"\s*:/,Nr=/"(?:c|\\u0063)(?:o|\\u006[Ff])(?:n|\\u006[Ee])(?:s|\\u0073)(?:t|\\u0074)(?:r|\\u0072)(?:u|\\u0075)(?:c|\\u0063)(?:t|\\u0074)(?:o|\\u006[Ff])(?:r|\\u0072)"\s*:/;function Pr(e){let t=JSON.parse(e);return typeof t!=`object`||!t||Mr.test(e)===!1&&Nr.test(e)===!1?t:Fr(t)}function Fr(e){let t=[e];for(;t.length;){let e=t;t=[];for(let n of e){if(Object.prototype.hasOwnProperty.call(n,`__proto__`)||Object.prototype.hasOwnProperty.call(n,`constructor`)&&n.constructor!==null&&typeof n.constructor==`object`&&Object.prototype.hasOwnProperty.call(n.constructor,`prototype`))throw SyntaxError(`Object contains forbidden prototype property`);for(let e in n){let r=n[e];r&&typeof r==`object`&&t.push(r)}}}return e}function Ir(e){let{stackTraceLimit:t}=Error;try{Error.stackTraceLimit=0}catch{return Pr(e)}try{return Pr(e)}finally{Error.stackTraceLimit=t}}function Lr(e){if(e.type===`object`||Array.isArray(e.type)&&e.type.includes(`object`)){let{additionalProperties:t}=e;e.additionalProperties=t!=null&&typeof t!=`boolean`&&Rr(t);let{properties:n}=e;if(n!=null)for(let e of Object.keys(n))n[e]=Rr(n[e])}e.items!=null&&(e.items=Array.isArray(e.items)?e.items.map(Rr):Rr(e.items)),e.anyOf!=null&&(e.anyOf=e.anyOf.map(Rr)),e.allOf!=null&&(e.allOf=e.allOf.map(Rr)),e.oneOf!=null&&(e.oneOf=e.oneOf.map(Rr));let{definitions:t}=e;if(t!=null)for(let e of Object.keys(t))t[e]=Rr(t[e]);return e}function Rr(e){return typeof e==`boolean`?e:Lr(e)}var zr=Symbol(`Let zodToJsonSchema decide on which parser to use`),Br={name:void 0,$refStrategy:`root`,basePath:[`#`],effectStrategy:`input`,pipeStrategy:`all`,dateStrategy:`format:date-time`,mapStrategy:`entries`,removeAdditionalStrategy:`passthrough`,allowedAdditionalProperties:!0,rejectedAdditionalProperties:!1,definitionPath:`definitions`,strictUnions:!1,definitions:{},errorMessages:!1,patternStrategy:`escape`,applyRegexFlags:!1,emailStrategy:`format:email`,base64Strategy:`contentEncoding:base64`,nameStrategy:`ref`},Vr=e=>typeof e==`string`?{...Br,name:e}:{...Br,...e};function U(){return{}}function Hr(e,t){let n={type:`array`};return e.type?._def&&e.type?._def?.typeName!==`ZodAny`&&(n.items=K(e.type._def,{...t,currentPath:[...t.currentPath,`items`]})),e.minLength&&(n.minItems=e.minLength.value),e.maxLength&&(n.maxItems=e.maxLength.value),e.exactLength&&(n.minItems=e.exactLength.value,n.maxItems=e.exactLength.value),n}function Ur(e){let t={type:`integer`,format:`int64`};if(!e.checks)return t;for(let n of e.checks)switch(n.kind){case`min`:n.inclusive?t.minimum=n.value:t.exclusiveMinimum=n.value;break;case`max`:n.inclusive?t.maximum=n.value:t.exclusiveMaximum=n.value;break;case`multipleOf`:t.multipleOf=n.value}return t}function Wr(){return{type:`boolean`}}function Gr(e,t){return K(e.type._def,t)}var Kr=(e,t)=>K(e.innerType._def,t);function qr(e,t,n){let r=n??t.dateStrategy;if(Array.isArray(r))return{anyOf:r.map(n=>qr(e,t,n))};switch(r){case`string`:case`format:date-time`:return{type:`string`,format:`date-time`};case`format:date`:return{type:`string`,format:`date`};case`integer`:return Jr(e)}}var Jr=e=>{let t={type:`integer`,format:`unix-time`};for(let n of e.checks)switch(n.kind){case`min`:t.minimum=n.value;break;case`max`:t.maximum=n.value}return t};function Yr(e,t){return{...K(e.innerType._def,t),default:e.defaultValue()}}function Xr(e,t){return t.effectStrategy===`input`?K(e.schema._def,t):U()}function Zr(e){return{type:`string`,enum:Array.from(e.values)}}var Qr=e=>`type`in e&&e.type===`string`?!1:`allOf`in e;function $r(e,t){let n=[K(e.left._def,{...t,currentPath:[...t.currentPath,`allOf`,`0`]}),K(e.right._def,{...t,currentPath:[...t.currentPath,`allOf`,`1`]})].filter(e=>!!e),r=[];return n.forEach(e=>{if(Qr(e))r.push(...e.allOf);else{let t=e;if(`additionalProperties`in e&&e.additionalProperties===!1){let{additionalProperties:n,...r}=e;t=r}r.push(t)}}),r.length?{allOf:r}:void 0}function ei(e){let t=typeof e.value;return t!==`bigint`&&t!==`number`&&t!==`boolean`&&t!==`string`?{type:Array.isArray(e.value)?`array`:`object`}:{type:t===`bigint`?`integer`:t,const:e.value}}var ti=void 0,W={cuid:/^[cC][^\s-]{8,}$/,cuid2:/^[0-9a-z]+$/,ulid:/^[0-9A-HJKMNP-TV-Z]{26}$/,email:/^(?!\.)(?!.*\.\.)([a-zA-Z0-9_'+\-\.]*)[a-zA-Z0-9_+-]@([a-zA-Z0-9][a-zA-Z0-9\-]*\.)+[a-zA-Z]{2,}$/,emoji:()=>(ti===void 0&&(ti=RegExp(`^(\\p{Extended_Pictographic}|\\p{Emoji_Component})+$`,`u`)),ti),uuid:/^[0-9a-fA-F]{8}\b-[0-9a-fA-F]{4}\b-[0-9a-fA-F]{4}\b-[0-9a-fA-F]{4}\b-[0-9a-fA-F]{12}$/,ipv4:/^(?:(?:25[0-5]|2[0-4][0-9]|1[0-9][0-9]|[1-9][0-9]|[0-9])\.){3}(?:25[0-5]|2[0-4][0-9]|1[0-9][0-9]|[1-9][0-9]|[0-9])$/,ipv4Cidr:/^(?:(?:25[0-5]|2[0-4][0-9]|1[0-9][0-9]|[1-9][0-9]|[0-9])\.){3}(?:25[0-5]|2[0-4][0-9]|1[0-9][0-9]|[1-9][0-9]|[0-9])\/(3[0-2]|[12]?[0-9])$/,ipv6:/^(([a-f0-9]{1,4}:){7}|::([a-f0-9]{1,4}:){0,6}|([a-f0-9]{1,4}:){1}:([a-f0-9]{1,4}:){0,5}|([a-f0-9]{1,4}:){2}:([a-f0-9]{1,4}:){0,4}|([a-f0-9]{1,4}:){3}:([a-f0-9]{1,4}:){0,3}|([a-f0-9]{1,4}:){4}:([a-f0-9]{1,4}:){0,2}|([a-f0-9]{1,4}:){5}:([a-f0-9]{1,4}:){0,1})([a-f0-9]{1,4}|(((25[0-5])|(2[0-4][0-9])|(1[0-9]{2})|([0-9]{1,2}))\.){3}((25[0-5])|(2[0-4][0-9])|(1[0-9]{2})|([0-9]{1,2})))$/,ipv6Cidr:/^(([0-9a-fA-F]{1,4}:){7,7}[0-9a-fA-F]{1,4}|([0-9a-fA-F]{1,4}:){1,7}:|([0-9a-fA-F]{1,4}:){1,6}:[0-9a-fA-F]{1,4}|([0-9a-fA-F]{1,4}:){1,5}(:[0-9a-fA-F]{1,4}){1,2}|([0-9a-fA-F]{1,4}:){1,4}(:[0-9a-fA-F]{1,4}){1,3}|([0-9a-fA-F]{1,4}:){1,3}(:[0-9a-fA-F]{1,4}){1,4}|([0-9a-fA-F]{1,4}:){1,2}(:[0-9a-fA-F]{1,4}){1,5}|[0-9a-fA-F]{1,4}:((:[0-9a-fA-F]{1,4}){1,6})|:((:[0-9a-fA-F]{1,4}){1,7}|:)|fe80:(:[0-9a-fA-F]{0,4}){0,4}%[0-9a-zA-Z]{1,}|::(ffff(:0{1,4}){0,1}:){0,1}((25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])\.){3,3}(25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])|([0-9a-fA-F]{1,4}:){1,4}:((25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])\.){3,3}(25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9]))\/(12[0-8]|1[01][0-9]|[1-9]?[0-9])$/,base64:/^([0-9a-zA-Z+/]{4})*(([0-9a-zA-Z+/]{2}==)|([0-9a-zA-Z+/]{3}=))?$/,base64url:/^([0-9a-zA-Z-_]{4})*(([0-9a-zA-Z-_]{2}(==)?)|([0-9a-zA-Z-_]{3}(=)?))?$/,nanoid:/^[a-zA-Z0-9_-]{21}$/,jwt:/^[A-Za-z0-9-_]+\.[A-Za-z0-9-_]+\.[A-Za-z0-9-_]*$/};function ni(e,t){let n={type:`string`};if(e.checks)for(let r of e.checks)switch(r.kind){case`min`:n.minLength=typeof n.minLength==`number`?Math.max(n.minLength,r.value):r.value;break;case`max`:n.maxLength=typeof n.maxLength==`number`?Math.min(n.maxLength,r.value):r.value;break;case`email`:switch(t.emailStrategy){case`format:email`:oi(n,`email`,r.message,t);break;case`format:idn-email`:oi(n,`idn-email`,r.message,t);break;case`pattern:zod`:G(n,W.email,r.message,t)}break;case`url`:oi(n,`uri`,r.message,t);break;case`uuid`:oi(n,`uuid`,r.message,t);break;case`regex`:G(n,r.regex,r.message,t);break;case`cuid`:G(n,W.cuid,r.message,t);break;case`cuid2`:G(n,W.cuid2,r.message,t);break;case`startsWith`:G(n,RegExp(`^${ri(r.value,t)}`),r.message,t);break;case`endsWith`:G(n,RegExp(`${ri(r.value,t)}$`),r.message,t);break;case`datetime`:oi(n,`date-time`,r.message,t);break;case`date`:oi(n,`date`,r.message,t);break;case`time`:oi(n,`time`,r.message,t);break;case`duration`:oi(n,`duration`,r.message,t);break;case`length`:n.minLength=typeof n.minLength==`number`?Math.max(n.minLength,r.value):r.value,n.maxLength=typeof n.maxLength==`number`?Math.min(n.maxLength,r.value):r.value;break;case`includes`:G(n,RegExp(ri(r.value,t)),r.message,t);break;case`ip`:r.version!==`v6`&&oi(n,`ipv4`,r.message,t),r.version!==`v4`&&oi(n,`ipv6`,r.message,t);break;case`base64url`:G(n,W.base64url,r.message,t);break;case`jwt`:G(n,W.jwt,r.message,t);break;case`cidr`:r.version!==`v6`&&G(n,W.ipv4Cidr,r.message,t),r.version!==`v4`&&G(n,W.ipv6Cidr,r.message,t);break;case`emoji`:G(n,W.emoji(),r.message,t);break;case`ulid`:G(n,W.ulid,r.message,t);break;case`base64`:switch(t.base64Strategy){case`format:binary`:oi(n,`binary`,r.message,t);break;case`contentEncoding:base64`:n.contentEncoding=`base64`;break;case`pattern:zod`:G(n,W.base64,r.message,t)}break;case`nanoid`:G(n,W.nanoid,r.message,t)}return n}function ri(e,t){return t.patternStrategy===`escape`?ai(e):e}var ii=new Set(`ABCDEFGHIJKLMNOPQRSTUVXYZabcdefghijklmnopqrstuvxyz0123456789`);function ai(e){let t=``;for(let n=0;n<e.length;n++)ii.has(e[n])||(t+=`\\`),t+=e[n];return t}function oi(e,t,n,r){e.format||e.anyOf?.some(e=>e.format)?(e.anyOf||=[],e.format&&(e.anyOf.push({format:e.format}),delete e.format),e.anyOf.push({format:t,...n&&r.errorMessages&&{errorMessage:{format:n}}})):e.format=t}function G(e,t,n,r){e.pattern||e.allOf?.some(e=>e.pattern)?(e.allOf||=[],e.pattern&&(e.allOf.push({pattern:e.pattern}),delete e.pattern),e.allOf.push({pattern:si(t,r),...n&&r.errorMessages&&{errorMessage:{pattern:n}}})):e.pattern=si(t,r)}function si(e,t){if(!t.applyRegexFlags||!e.flags)return e.source;let n={i:e.flags.includes(`i`),m:e.flags.includes(`m`),s:e.flags.includes(`s`)},r=n.i?e.source.toLowerCase():e.source,i=``,a=!1,o=!1,s=!1;for(let e=0;e<r.length;e++){if(a){i+=r[e],a=!1;continue}if(n.i){if(o){if(r[e].match(/[a-z]/)){s?(i+=r[e],i+=`${r[e-2]}-${r[e]}`.toUpperCase(),s=!1):r[e+1]===`-`&&r[e+2]?.match(/[a-z]/)?(i+=r[e],s=!0):i+=`${r[e]}${r[e].toUpperCase()}`;continue}}else if(r[e].match(/[a-z]/)){i+=`[${r[e]}${r[e].toUpperCase()}]`;continue}}if(n.m){if(r[e]===`^`){i+=`(^|(?<=[\r 4]))`;continue}if(r[e]===`$`){i+=`($|(?=[\r 5]))`;continue}}if(n.s&&r[e]===`.`){i+=o?`${r[e]}\r 6`:`[${r[e]}\r 7]`;continue}i+=r[e],r[e]===`\\`?a=!0:o&&r[e]===`]`?o=!1:!o&&r[e]===`[`&&(o=!0)}try{new RegExp(i)}catch{return console.warn(`Could not convert regex pattern at ${t.currentPath.join(`/`)} to a flag-independent form! Falling back to the flag-ignorant source`),e.source}return i}function ci(e,t){let n={type:`object`,additionalProperties:K(e.valueType._def,{...t,currentPath:[...t.currentPath,`additionalProperties`]})??t.allowedAdditionalProperties};if(e.keyType?._def.typeName===`ZodString`&&e.keyType._def.checks?.length){let{type:r,...i}=ni(e.keyType._def,t);return{...n,propertyNames:i}}if(e.keyType?._def.typeName===`ZodEnum`)return{...n,propertyNames:{enum:e.keyType._def.values}};if(e.keyType?._def.typeName===`ZodBranded`&&e.keyType._def.type._def.typeName===`ZodString`&&e.keyType._def.type._def.checks?.length){let{type:r,...i}=Gr(e.keyType._def,t);return{...n,propertyNames:i}}return n}function li(e,t){return t.mapStrategy===`record`?ci(e,t):{type:`array`,maxItems:125,items:{type:`array`,items:[K(e.keyType._def,{...t,currentPath:[...t.currentPath,`items`,`items`,`0`]})||U(),K(e.valueType._def,{...t,currentPath:[...t.currentPath,`items`,`items`,`1`]})||U()],minItems:2,maxItems:2}}}function ui(e){let t=e.values,n=Object.keys(e.values).filter(e=>typeof t[t[e]]!=`number`).map(e=>t[e]),r=Array.from(new Set(n.map(e=>typeof e)));return{type:r.length===1?r[0]===`string`?`string`:`number`:[`string`,`number`],enum:n}}function di(){return{not:U()}}function fi(){return{type:`null`}}var pi={ZodString:`string`,ZodNumber:`number`,ZodBigInt:`integer`,ZodBoolean:`boolean`,ZodNull:`null`};function mi(e,t){let n=e.options instanceof Map?Array.from(e.options.values()):e.options;if(n.every(e=>e._def.typeName in pi&&(!e._def.checks||!e._def.checks.length))){let e=n.reduce((e,t)=>{let n=pi[t._def.typeName];return n&&!e.includes(n)?[...e,n]:e},[]);return{type:e.length>1?e:e[0]}}if(n.every(e=>e._def.typeName===`ZodLiteral`&&!e.description)){let e=n.reduce((e,t)=>{let n=typeof t._def.value;switch(n){case`string`:case`number`:case`boolean`:return[...e,n];case`bigint`:return[...e,`integer`];case`object`:if(t._def.value===null)return[...e,`null`];default:return e}},[]);if(e.length===n.length){let t=e.filter((e,t,n)=>n.indexOf(e)===t);return{type:t.length>1?t:t[0],enum:n.reduce((e,t)=>e.includes(t._def.value)?e:[...e,t._def.value],[])}}}else if(n.every(e=>e._def.typeName===`ZodEnum`))return{type:`string`,enum:n.reduce((e,t)=>[...e,...t._def.values.filter(t=>!e.includes(t))],[])};return hi(e,t)}var hi=(e,t)=>{let n=(e.options instanceof Map?Array.from(e.options.values()):e.options).map((e,n)=>K(e._def,{...t,currentPath:[...t.currentPath,`anyOf`,`${n}`]})).filter(e=>!!e&&(!t.strictUnions||typeof e==`object`&&Object.keys(e).length>0));return n.length?{anyOf:n}:void 0};function gi(e,t){if([`ZodString`,`ZodNumber`,`ZodBigInt`,`ZodBoolean`,`ZodNull`].includes(e.innerType._def.typeName)&&(!e.innerType._def.checks||!e.innerType._def.checks.length))return{type:[pi[e.innerType._def.typeName],`null`]};let n=K(e.innerType._def,{...t,currentPath:[...t.currentPath,`anyOf`,`0`]});return n&&{anyOf:[n,{type:`null`}]}}function _i(e){let t={type:`number`};if(!e.checks)return t;for(let n of e.checks)switch(n.kind){case`int`:t.type=`integer`;break;case`min`:n.inclusive?t.minimum=n.value:t.exclusiveMinimum=n.value;break;case`max`:n.inclusive?t.maximum=n.value:t.exclusiveMaximum=n.value;break;case`multipleOf`:t.multipleOf=n.value}return t}function vi(e,t){let n={type:`object`,properties:{}},r=[],i=e.shape();for(let e in i){let a=i[e];if(a===void 0||a._def===void 0)continue;let o=bi(a),s=K(a._def,{...t,currentPath:[...t.currentPath,`properties`,e],propertyPath:[...t.currentPath,`properties`,e]});s!==void 0&&(n.properties[e]=s,o||r.push(e))}r.length&&(n.required=r);let a=yi(e,t);return a!==void 0&&(n.additionalProperties=a),n}function yi(e,t){if(e.catchall._def.typeName!==`ZodNever`)return K(e.catchall._def,{...t,currentPath:[...t.currentPath,`additionalProperties`]});switch(e.unknownKeys){case`passthrough`:return t.allowedAdditionalProperties;case`strict`:return t.rejectedAdditionalProperties;case`strip`:return t.removeAdditionalStrategy===`strict`?t.allowedAdditionalProperties:t.rejectedAdditionalProperties}}function bi(e){try{return e.isOptional()}catch{return!0}}var xi=(e,t)=>{if(t.currentPath.toString()===t.propertyPath?.toString())return K(e.innerType._def,t);let n=K(e.innerType._def,{...t,currentPath:[...t.currentPath,`anyOf`,`1`]});return n?{anyOf:[{not:U()},n]}:U()},Si=(e,t)=>{if(t.pipeStrategy===`input`)return K(e.in._def,t);if(t.pipeStrategy===`output`)return K(e.out._def,t);let n=K(e.in._def,{...t,currentPath:[...t.currentPath,`allOf`,`0`]});return{allOf:[n,K(e.out._def,{...t,currentPath:[...t.currentPath,`allOf`,n?`1`:`0`]})].filter(e=>e!==void 0)}};function Ci(e,t){return K(e.type._def,t)}function wi(e,t){let n={type:`array`,uniqueItems:!0,items:K(e.valueType._def,{...t,currentPath:[...t.currentPath,`items`]})};return e.minSize&&(n.minItems=e.minSize.value),e.maxSize&&(n.maxItems=e.maxSize.value),n}function Ti(e,t){return e.rest?{type:`array`,minItems:e.items.length,items:e.items.map((e,n)=>K(e._def,{...t,currentPath:[...t.currentPath,`items`,`${n}`]})).reduce((e,t)=>t===void 0?e:[...e,t],[]),additionalItems:K(e.rest._def,{...t,currentPath:[...t.currentPath,`additionalItems`]})}:{type:`array`,minItems:e.items.length,maxItems:e.items.length,items:e.items.map((e,n)=>K(e._def,{...t,currentPath:[...t.currentPath,`items`,`${n}`]})).reduce((e,t)=>t===void 0?e:[...e,t],[])}}function Ei(){return{not:U()}}function Di(){return U()}var Oi=(e,t)=>K(e.innerType._def,t),ki=(e,t,n)=>{switch(t){case`ZodString`:return ni(e,n);case`ZodNumber`:return _i(e);case`ZodObject`:return vi(e,n);case`ZodBigInt`:return Ur(e);case`ZodBoolean`:return Wr();case`ZodDate`:return qr(e,n);case`ZodUndefined`:return Ei();case`ZodNull`:return fi();case`ZodArray`:return Hr(e,n);case`ZodUnion`:case`ZodDiscriminatedUnion`:return mi(e,n);case`ZodIntersection`:return $r(e,n);case`ZodTuple`:return Ti(e,n);case`ZodRecord`:return ci(e,n);case`ZodLiteral`:return ei(e);case`ZodEnum`:return Zr(e);case`ZodNativeEnum`:return ui(e);case`ZodNullable`:return gi(e,n);case`ZodOptional`:return xi(e,n);case`ZodMap`:return li(e,n);case`ZodSet`:return wi(e,n);case`ZodLazy`:return()=>e.getter()._def;case`ZodPromise`:return Ci(e,n);case`ZodNaN`:case`ZodNever`:return di();case`ZodEffects`:return Xr(e,n);case`ZodAny`:return U();case`ZodUnknown`:return Di();case`ZodDefault`:return Yr(e,n);case`ZodBranded`:return Gr(e,n);case`ZodReadonly`:return Oi(e,n);case`ZodCatch`:return Kr(e,n);case`ZodPipeline`:return Si(e,n);case`ZodFunction`:case`ZodVoid`:case`ZodSymbol`:return;default:return(e=>void 0)(t)}},Ai=(e,t)=>{let n=0;for(;n<e.length&&n<t.length&&e[n]===t[n];n++);return[(e.length-n).toString(),...t.slice(n)].join(`/`)};function K(e,t,n=!1){let r=t.seen.get(e);if(t.override){let i=t.override?.call(t,e,t,r,n);if(i!==zr)return i}if(r&&!n){let e=ji(r,t);if(e!==void 0)return e}let i={def:e,path:t.currentPath,jsonSchema:void 0};t.seen.set(e,i);let a=ki(e,e.typeName,t),o=typeof a==`function`?K(a(),t):a;if(o&&Mi(e,t,o),t.postProcess){let n=t.postProcess(o,e,t);return i.jsonSchema=o,n}return i.jsonSchema=o,o}var ji=(e,t)=>{switch(t.$refStrategy){case`root`:return{$ref:e.path.join(`/`)};case`relative`:return{$ref:Ai(t.currentPath,e.path)};case`none`:case`seen`:return e.path.length<t.currentPath.length&&e.path.every((e,n)=>t.currentPath[n]===e)?(console.warn(`Recursive reference detected at ${t.currentPath.join(`/`)}! Defaulting to any`),U()):t.$refStrategy===`seen`?U():void 0}},Mi=(e,t,n)=>(e.description&&(n.description=e.description),n),Ni=e=>{let t=Vr(e),n=t.name===void 0?t.basePath:[...t.basePath,t.definitionPath,t.name];return{...t,currentPath:n,propertyPath:void 0,seen:new Map(Object.entries(t.definitions).map(([e,n])=>[n._def,{def:n._def,path:[...t.basePath,t.definitionPath,e],jsonSchema:void 0}]))}},Pi=(e,t)=>{let n=Ni(t),r=typeof t==`object`&&t.definitions?Object.entries(t.definitions).reduce((e,[t,r])=>({...e,[t]:K(r._def,{...n,currentPath:[...n.basePath,n.definitionPath,t]},!0)??U()}),{}):void 0,i=typeof t==`string`?t:t?.nameStrategy===`title`?void 0:t?.name,a=K(e._def,i===void 0?n:{...n,currentPath:[...n.basePath,n.definitionPath,i]},!1)??U(),o=typeof t==`object`&&t.name!==void 0&&t.nameStrategy===`title`?t.name:void 0;o!==void 0&&(a.title=o);let s=i===void 0?r?{...a,[n.definitionPath]:r}:a:{$ref:[...n.$refStrategy===`relative`?[]:n.basePath,n.definitionPath,i].join(`/`),[n.definitionPath]:{...r,[i]:a}};return s.$schema=`http://json-schema.org/draft-07/schema#`,s},Fi=Symbol.for(`vercel.ai.schema`);function Ii(e,{validate:t}={}){return{[Fi]:!0,_type:void 0,get jsonSchema(){return typeof e==`function`&&(e=e()),e},validate:t}}function Li(e){return typeof e==`object`&&!!e&&Fi in e&&e[Fi]===!0&&`jsonSchema`in e&&`validate`in e}function Ri(e){return e==null?Ii({type:`object`,properties:{},additionalProperties:!1}):Li(e)?e:`~standard`in e?e[`~standard`].vendor===`zod`?Wi(e):zi(e):e()}function zi(e){return Ii(()=>{if(!Bi(e))throw Error(`Standard schema vendor '${e[`~standard`].vendor}' does not support JSON Schema conversion.`);return Lr(e[`~standard`].jsonSchema.input({target:`draft-07`}))},{validate:async t=>{let n=await e[`~standard`].validate(t);return`value`in n?{success:!0,value:n.value}:{success:!1,error:new Or({value:t,cause:n.issues})}}})}function Bi(e){return e[`~standard`].jsonSchema!=null}function Vi(e,t){let n=t?.useReferences??!1;return Ii(()=>Pi(e,{$refStrategy:n?`root`:`none`}),{validate:async t=>{let n=await e.safeParseAsync(t);return n.success?{success:!0,value:n.data}:{success:!1,error:n.error}}})}function Hi(e,t){let r=t?.useReferences??!1;return Ii(()=>Lr(n(e,{target:`draft-7`,io:`input`,reused:r?`ref`:`inline`})),{validate:async t=>{let n=await i(e,t);return n.success?{success:!0,value:n.data}:{success:!1,error:n.error}}})}function Ui(e){return`_zod`in e}function Wi(e,t){return Ui(e)?Hi(e,t):Vi(e,t)}async function Gi({value:e,schema:t,context:n}){let r=Ri(t);try{if(r.validate==null)return{success:!0,value:e,rawValue:e};let t=await r.validate(e);return t.success?{success:!0,value:t.value,rawValue:e}:{success:!1,error:Or.wrap({value:e,cause:t.error,context:n}),rawValue:e}}catch(t){return{success:!1,error:Or.wrap({value:e,cause:t,context:n}),rawValue:e}}}async function Ki({text:e,schema:t}){try{let n=Ir(e);return t==null?{success:!0,value:n,rawValue:n}:await Gi({value:n,schema:t})}catch(t){return{success:!1,error:Sr.isInstance(t)?t:new Sr({text:e,cause:t}),rawValue:void 0}}}async function qi(e){return typeof e==`function`&&(e=e()),Promise.resolve(e)}new TextDecoder;var Ji=Object.defineProperty,Yi=(e,t)=>{for(var n in t)Ji(e,n,{get:t[n],enumerable:!0})},Xi=`AI_InvalidArgumentError`,Zi=`vercel.ai.error.${Xi}`,Qi=Symbol.for(Zi),$i,ea,ta=class extends (ea=lr,$i=Qi,ea){constructor({parameter:e,value:t,message:n}){super({name:Xi,message:`Invalid argument for parameter ${e}: ${n}`}),this[$i]=!0,this.parameter=e,this.value=t}static isInstance(e){return lr.hasMarker(e,Zi)}},na=`AI_NoObjectGeneratedError`,ra=`vercel.ai.error.${na}`,ia=Symbol.for(ra),aa,oa,sa=class extends (oa=lr,aa=ia,oa){constructor({message:e=`No object generated.`,cause:t,text:n,response:r,usage:i,finishReason:a}){super({name:na,message:e,cause:t}),this[aa]=!0,this.text=n,this.response=r,this.usage=i,this.finishReason=a}static isInstance(e){return lr.hasMarker(e,ra)}},q={array:_,boolean:c,custom:p,discriminatedUnion:l,enum:f,instanceof:o,lazy:g,literal:m,looseObject:d,never:u,null:h,number:a,object:v,record:s,string:y,union:r,unknown:t},ca=q.lazy(()=>q.union([q.null(),q.string(),q.number(),q.boolean(),q.record(q.string(),ca.optional()),q.array(ca)])),J=q.record(q.string(),q.record(q.string(),ca.optional())),la=q.union([q.string(),q.instanceof(Uint8Array),q.instanceof(ArrayBuffer),q.custom(jr,{message:`Must be a Buffer`})]),ua=q.record(q.string(),q.string()),da=q.object({type:q.literal(`text`),text:q.string(),providerOptions:J.optional()}),fa=q.object({type:q.literal(`image`),image:q.union([la,q.instanceof(URL),ua]),mediaType:q.string().optional(),providerOptions:J.optional()}),pa=q.discriminatedUnion(`type`,[q.object({type:q.literal(`data`),data:la}),q.object({type:q.literal(`url`),url:q.instanceof(URL)}),q.object({type:q.literal(`reference`),reference:ua}),q.object({type:q.literal(`text`),text:q.string()})]),ma=q.discriminatedUnion(`type`,[q.object({type:q.literal(`data`),data:la}),q.object({type:q.literal(`url`),url:q.instanceof(URL)})]),ha=q.object({type:q.literal(`file`),data:q.union([pa,la,q.instanceof(URL),ua]),filename:q.string().optional(),mediaType:q.string(),providerOptions:J.optional()}),ga=q.object({type:q.literal(`reasoning`),text:q.string(),providerOptions:J.optional()}),_a=q.object({type:q.literal(`custom`),kind:q.string().transform(e=>e),providerOptions:J.optional()}),va=q.object({type:q.literal(`reasoning-file`),data:q.union([ma,la,q.instanceof(URL)]),mediaType:q.string(),providerOptions:J.optional()}),ya=q.object({type:q.literal(`tool-call`),toolCallId:q.string(),toolName:q.string(),input:q.unknown(),providerOptions:J.optional(),providerExecuted:q.boolean().optional()}),ba=q.discriminatedUnion(`type`,[q.object({type:q.literal(`text`),value:q.string(),providerOptions:J.optional()}),q.object({type:q.literal(`json`),value:ca,providerOptions:J.optional()}),q.object({type:q.literal(`execution-denied`),reason:q.string().optional(),providerOptions:J.optional()}),q.object({type:q.literal(`error-text`),value:q.string(),providerOptions:J.optional()}),q.object({type:q.literal(`error-json`),value:ca,providerOptions:J.optional()}),q.object({type:q.literal(`content`),value:q.array(q.union([q.object({type:q.literal(`text`),text:q.string(),providerOptions:J.optional()}),q.object({type:q.literal(`file`),data:pa,mediaType:q.string(),filename:q.string().optional(),providerOptions:J.optional()}),q.object({type:q.literal(`file-data`),data:q.string(),mediaType:q.string(),filename:q.string().optional(),providerOptions:J.optional()}),q.object({type:q.literal(`file-url`),url:q.string(),mediaType:q.string().optional(),providerOptions:J.optional()}),q.object({type:q.literal(`file-id`),fileId:q.union([q.string(),q.record(q.string(),q.string())]),providerOptions:J.optional()}),q.object({type:q.literal(`file-reference`),providerReference:q.record(q.string(),q.string()),providerOptions:J.optional()}),q.object({type:q.literal(`image-data`),data:q.string(),mediaType:q.string(),providerOptions:J.optional()}),q.object({type:q.literal(`image-url`),url:q.string(),providerOptions:J.optional()}),q.object({type:q.literal(`image-file-id`),fileId:q.union([q.string(),q.record(q.string(),q.string())]),providerOptions:J.optional()}),q.object({type:q.literal(`image-file-reference`),providerReference:q.record(q.string(),q.string()),providerOptions:J.optional()}),q.object({type:q.literal(`custom`),providerOptions:J.optional()})]))})]),xa=q.object({type:q.literal(`tool-result`),toolCallId:q.string(),toolName:q.string(),output:ba,providerOptions:J.optional()}),Sa=q.object({type:q.literal(`tool-approval-request`),approvalId:q.string(),toolCallId:q.string(),reason:q.string().optional()}),Ca=q.object({type:q.literal(`tool-approval-response`),approvalId:q.string(),approved:q.boolean(),reason:q.string().optional()}),wa=q.object({role:q.literal(`system`),content:q.string(),providerOptions:J.optional()}),Ta=q.object({role:q.literal(`user`),content:q.union([q.string(),q.array(q.union([da,fa,ha]))]),providerOptions:J.optional()}),Ea=q.object({role:q.literal(`assistant`),content:q.union([q.string(),q.array(q.union([da,_a,ha,ga,va,ya,xa,Sa]))]),providerOptions:J.optional()}),Da=q.object({role:q.literal(`tool`),content:q.array(q.union([xa,Ca])),providerOptions:J.optional()});q.union([wa,Ta,Ea,Da]),Yi({},{array:()=>Ma,choice:()=>Fa,json:()=>Ia,object:()=>ja,text:()=>Aa});function Oa(e){let t=[`ROOT`],n=-1,r=null,i=0;function a(e){return e>=`0`&&e<=`9`||e>=`A`&&e<=`F`||e>=`a`&&e<=`f`}function o(e,i,a){switch(e){case`"`:n=i,t.pop(),t.push(a),t.push(`INSIDE_STRING`);break;case`f`:case`t`:case`n`:n=i,r=i,t.pop(),t.push(a),t.push(`INSIDE_LITERAL`);break;case`-`:t.pop(),t.push(a),t.push(`INSIDE_NUMBER`);break;case`0`:case`1`:case`2`:case`3`:case`4`:case`5`:case`6`:case`7`:case`8`:case`9`:n=i,t.pop(),t.push(a),t.push(`INSIDE_NUMBER`);break;case`{`:n=i,t.pop(),t.push(a),t.push(`INSIDE_OBJECT_START`);break;case`[`:n=i,t.pop(),t.push(a),t.push(`INSIDE_ARRAY_START`)}}function s(e,r){switch(e){case`,`:t.pop(),t.push(`INSIDE_OBJECT_AFTER_COMMA`);break;case`}`:n=r,t.pop()}}function c(e,r){switch(e){case`,`:t.pop(),t.push(`INSIDE_ARRAY_AFTER_COMMA`);break;case`]`:n=r,t.pop()}}for(let l=0;l<e.length;l++){let u=e[l];switch(t[t.length-1]){case`ROOT`:o(u,l,`FINISH`);break;case`INSIDE_OBJECT_START`:switch(u){case`"`:t.pop(),t.push(`INSIDE_OBJECT_KEY`);break;case`}`:n=l,t.pop()}break;case`INSIDE_OBJECT_AFTER_COMMA`:u===`"`&&(t.pop(),t.push(`INSIDE_OBJECT_KEY`));break;case`INSIDE_OBJECT_KEY`:u===`"`&&(t.pop(),t.push(`INSIDE_OBJECT_AFTER_KEY`));break;case`INSIDE_OBJECT_AFTER_KEY`:u===`:`&&(t.pop(),t.push(`INSIDE_OBJECT_BEFORE_VALUE`));break;case`INSIDE_OBJECT_BEFORE_VALUE`:o(u,l,`INSIDE_OBJECT_AFTER_VALUE`);break;case`INSIDE_OBJECT_AFTER_VALUE`:s(u,l);break;case`INSIDE_STRING`:switch(u){case`"`:t.pop(),n=l;break;case`\\`:t.push(`INSIDE_STRING_ESCAPE`);break;default:n=l}break;case`INSIDE_ARRAY_START`:switch(u){case`]`:n=l,t.pop();break;default:n=l,o(u,l,`INSIDE_ARRAY_AFTER_VALUE`)}break;case`INSIDE_ARRAY_AFTER_VALUE`:switch(u){case`,`:t.pop(),t.push(`INSIDE_ARRAY_AFTER_COMMA`);break;case`]`:n=l,t.pop();break;default:n=l}break;case`INSIDE_ARRAY_AFTER_COMMA`:o(u,l,`INSIDE_ARRAY_AFTER_VALUE`);break;case`INSIDE_STRING_ESCAPE`:t.pop(),u===`u`?(i=0,t.push(`INSIDE_STRING_UNICODE_ESCAPE`)):n=l;break;case`INSIDE_STRING_UNICODE_ESCAPE`:a(u)&&(i++,i===4&&(t.pop(),n=l));break;case`INSIDE_NUMBER`:switch(u){case`0`:case`1`:case`2`:case`3`:case`4`:case`5`:case`6`:case`7`:case`8`:case`9`:n=l;break;case`e`:case`E`:case`-`:case`.`:break;case`,`:t.pop(),t[t.length-1]===`INSIDE_ARRAY_AFTER_VALUE`&&c(u,l),t[t.length-1]===`INSIDE_OBJECT_AFTER_VALUE`&&s(u,l);break;case`}`:t.pop(),t[t.length-1]===`INSIDE_OBJECT_AFTER_VALUE`&&s(u,l);break;case`]`:t.pop(),t[t.length-1]===`INSIDE_ARRAY_AFTER_VALUE`&&c(u,l);break;default:t.pop()}break;case`INSIDE_LITERAL`:{let i=e.substring(r,l+1);!`false`.startsWith(i)&&!`true`.startsWith(i)&&!`null`.startsWith(i)?(t.pop(),t[t.length-1]===`INSIDE_OBJECT_AFTER_VALUE`?s(u,l):t[t.length-1]===`INSIDE_ARRAY_AFTER_VALUE`&&c(u,l)):n=l;break}}}let l=e.slice(0,n+1);for(let n=t.length-1;n>=0;n--)switch(t[n]){case`INSIDE_STRING`:l+=`"`;break;case`INSIDE_OBJECT_KEY`:case`INSIDE_OBJECT_AFTER_KEY`:case`INSIDE_OBJECT_AFTER_COMMA`:case`INSIDE_OBJECT_START`:case`INSIDE_OBJECT_BEFORE_VALUE`:case`INSIDE_OBJECT_AFTER_VALUE`:l+=`}`;break;case`INSIDE_ARRAY_START`:case`INSIDE_ARRAY_AFTER_COMMA`:case`INSIDE_ARRAY_AFTER_VALUE`:l+=`]`;break;case`INSIDE_LITERAL`:{let t=e.substring(r,e.length);`true`.startsWith(t)?l+=`true`.slice(t.length):`false`.startsWith(t)?l+=`false`.slice(t.length):`null`.startsWith(t)&&(l+=`null`.slice(t.length))}}return l}async function ka(e){if(e===void 0)return{value:void 0,state:`undefined-input`};let t=await Ki({text:e});return t.success?{value:t.value,state:`successful-parse`}:(t=await Ki({text:Oa(e)}),t.success?{value:t.value,state:`repaired-parse`}:{value:void 0,state:`failed-parse`})}var Aa=()=>({name:`text`,responseFormat:Promise.resolve({type:`text`}),async parseCompleteOutput({text:e}){return e},async parsePartialOutput({text:e}){return{partial:e}},createElementStreamTransform(){}}),ja=({schema:e,name:t,description:n})=>{let r=Ri(e);return{name:`object`,responseFormat:qi(r.jsonSchema).then(e=>({type:`json`,schema:e,...t!=null&&{name:t},...n!=null&&{description:n}})),async parseCompleteOutput({text:e},t){let n=await Ki({text:e});if(!n.success)throw new sa({message:`No object generated: could not parse the response.`,cause:n.error,text:e,response:t.response,usage:t.usage,finishReason:t.finishReason});let i=await Gi({value:n.value,schema:r});if(!i.success)throw new sa({message:`No object generated: response did not match sc
7hema.`,cause:i.error,text:e,response:t.response,usage:t.usage,finishReason:t.finishReason});return i.value},async parsePartialOutput({text:e}){let t=await ka(e);switch(t.state){case`failed-parse`:case`undefined-input`:return;case`repaired-parse`:case`successful-parse`:return{partial:t.value}}},createElementStreamTransform(){}}},Ma=({element:e,minItems:t,maxItems:n,name:r,description:i})=>{if(Na({name:`minItems`,value:t}),Na({name:`maxItems`,value:n}),t!=null&&n!=null&&t>n)throw new ta({parameter:`minItems`,value:t,message:`minItems must be less than or equal to maxItems`});let a=Ri(e);return{name:`array`,responseFormat:qi(a.jsonSchema).then(e=>{let{$schema:a,definitions:o,$defs:s,...c}=e;return{type:`json`,schema:{$schema:`http://json-schema.org/draft-07/schema#`,...o!=null&&{definitions:o},...s!=null&&{$defs:s},type:`object`,properties:{elements:{type:`array`,items:c,...t!=null&&{minItems:t},...n!=null&&{maxItems:n}}},required:[`elements`],additionalProperties:!1},...r!=null&&{name:r},...i!=null&&{description:i}}}),async parseCompleteOutput({text:e},r){let i=await Ki({text:e});if(!i.success)throw new sa({message:`No object generated: could not parse the response.`,cause:i.error,text:e,response:r.response,usage:r.usage,finishReason:r.finishReason});let o=i.value;if(typeof o!=`object`||!o||!(`elements`in o)||!Array.isArray(o.elements))throw new sa({message:`No object generated: response did not match schema.`,cause:new Or({value:o,cause:`response must be an object with an elements array`}),text:e,response:r.response,usage:r.usage,finishReason:r.finishReason});let s=Pa({value:o.elements,minItems:t,maxItems:n});if(s!=null)throw new sa({message:`No object generated: response did not match schema.`,cause:s,text:e,response:r.response,usage:r.usage,finishReason:r.finishReason});let c=[];for(let t of o.elements){let n=await Gi({value:t,schema:a});if(!n.success)throw new sa({message:`No object generated: response did not match schema.`,cause:n.error,text:e,response:r.response,usage:r.usage,finishReason:r.finishReason});c.push(n.value)}return c},async parsePartialOutput({text:e}){let t=await ka(e);switch(t.state){case`failed-parse`:case`undefined-input`:return;case`repaired-parse`:case`successful-parse`:{let e=t.value;if(typeof e!=`object`||!e||!(`elements`in e)||!Array.isArray(e.elements))return;let n=t.state===`repaired-parse`&&e.elements.length>0?e.elements.slice(0,-1):e.elements,r=[];for(let e of n){let t=await Gi({value:e,schema:a});t.success&&r.push(t.value)}return{partial:r}}}},createElementStreamTransform(){let e=0;return new TransformStream({transform({partialOutput:t},r){if(t!=null)for(;e<t.length;e++){if(n!=null&&e>=n){r.error(Pa({value:t,maxItems:n}));return}r.enqueue(t[e])}}})}}};function Na({name:e,value:t}){if(t!=null){if(!Number.isInteger(t))throw new ta({parameter:e,value:t,message:`${e} must be an integer`});if(t<0)throw new ta({parameter:e,value:t,message:`${e} must be greater than or equal to 0`})}}function Pa({value:e,minItems:t,maxItems:n}){if(t!=null&&e.length<t)return new Or({value:e,cause:`elements array must contain at least ${t} items`});if(n!=null&&e.length>n)return new Or({value:e,cause:`elements array must contain at most ${n} items`})}var Fa=({options:e,name:t,description:n})=>({name:`choice`,responseFormat:Promise.resolve({type:`json`,schema:{$schema:`http://json-schema.org/draft-07/schema#`,type:`object`,properties:{result:{type:`string`,enum:e}},required:[`result`],additionalProperties:!1},...t!=null&&{name:t},...n!=null&&{description:n}}),async parseCompleteOutput({text:t},n){let r=await Ki({text:t});if(!r.success)throw new sa({message:`No object generated: could not parse the response.`,cause:r.error,text:t,response:n.response,usage:n.usage,finishReason:n.finishReason});let i=r.value;if(typeof i!=`object`||!i||!(`result`in i)||typeof i.result!=`string`||!e.includes(i.result))throw new sa({message:`No object generated: response did not match schema.`,cause:new Or({value:i,cause:`response must be an object that contains a choice value.`}),text:t,response:n.response,usage:n.usage,finishReason:n.finishReason});return i.result},async parsePartialOutput({text:t}){let n=await ka(t);switch(n.state){case`failed-parse`:case`undefined-input`:return;case`repaired-parse`:case`successful-parse`:{let t=n.value;if(typeof t!=`object`||!t||!(`result`in t)||typeof t.result!=`string`)return;let r=e.filter(e=>e.startsWith(t.result));return n.state===`successful-parse`?r.includes(t.result)?{partial:t.result}:void 0:r.length===1?{partial:r[0]}:void 0}}},createElementStreamTransform(){}}),Ia=({name:e,description:t}={})=>({name:`json`,responseFormat:Promise.resolve({type:`json`,...e!=null&&{name:e},...t!=null&&{description:t}}),async parseCompleteOutput({text:e},t){let n=await Ki({text:e});if(!n.success)throw new sa({message:`No object generated: could not parse the response.`,cause:n.error,text:e,response:t.response,usage:t.usage,finishReason:t.finishReason});return n.value},async parsePartialOutput({text:e}){let t=await ka(e);switch(t.state){case`failed-parse`:case`undefined-input`:return;case`repaired-parse`:case`successful-parse`:return t.value===void 0?void 0:{partial:t.value}}},createElementStreamTransform(){}});new TextEncoder,new TextEncoder,H({prefix:`aitxt`,size:24}),H({prefix:`call`,size:24}),TransformStream,q.record(q.string(),ca.optional());function La(e){return e.type.startsWith(`tool-`)}function Ra(e){return e.type===`dynamic-tool`}function za(e){return La(e)||Ra(e)}function Ba(e){return e.type.split(`-`).slice(1).join(`-`)}function Va(e){return Ra(e)?e.toolName:Ba(e)}H({prefix:`aitxt`,size:24}),H({prefix:`call`,size:24}),H({prefix:`aitxt`,size:24}),H({prefix:`call`,size:24}),q.record(q.string(),ca.optional()),q.record(q.string(),q.string()),H({prefix:`call`,size:24}),H({prefix:`call`,size:24}),new TextEncoder,H({prefix:`aiobj`,size:24});var{atob:Ha}=globalThis;H({prefix:`aiobj`,size:24}),q.object({token:q.string().refine(e=>e.trim().length>0),url:q.string().refine(e=>{try{let t=new URL(e);return(t.protocol===`ws:`||t.protocol===`wss:`)&&t.hostname!==``}catch{return!1}}),expiresAt:q.number().positive().max(2**53-1).optional(),tools:q.array(q.object({type:q.literal(`function`),name:q.string().min(1),description:q.string().optional(),parameters:q.record(q.string(),q.unknown())})).optional()}),H({prefix:`call`,size:24});var Ua=e=>e.type===`tool.approval_response_submitted`,Wa=new Set([`tool.approval_resolved`,`tool.denied`,`tool.completed`,`tool.failed`]);function Ga(e,t){if(`approvalId`in t&&typeof t.approvalId==`string`)return e.responses[t.approvalId];if(!(`toolCallId`in t)||typeof t.toolCallId!=`string`)return;let n=t.toolCallId,r=Object.values(e.responses).filter(e=>e.toolCallId===n);if(t.type===`tool.denied`){let e=r.filter(e=>!e.approved);return e.find(e=>e.resolveSeen===!0)??e[0]}return r.find(e=>e.approved)}var Ka={name:`pending-approval-responses`,replaysHistory:!1,initial:()=>({responses:{}}),reduce(e,t){if(Ua(t.payload)){let n={...e.responses};for(let e of t.payload.responses)n[e.approvalId]=e;return{responses:n}}let n=t.payload;if(!Wa.has(n.type))return e;let r=Ga(e,n);if(r===void 0)return e;if(n.type===`tool.approval_resolved`&&!r.approved)return r.resolveSeen===!0?e:{responses:{...e.responses,[r.approvalId]:{...r,resolveSeen:!0}}};let i={...e.responses};return delete i[r.approvalId],{responses:i}}};function qa(e){let t=e.approval;return typeof t==`object`&&t&&`id`in t&&typeof t.id==`string`?t.id:void 0}function Ja(e,t){let n=e.state===`approval-responded`&&e.approval.approved===!1&&!t.approved;return e.state!==`approval-requested`&&!n?null:t.approved?{...e,state:`approval-responded`,approval:{id:e.approval.id,approved:!0}}:{...e,state:`output-denied`,approval:t.reason===void 0?{id:e.approval.id,approved:!1}:{id:e.approval.id,approved:!1,reason:t.reason}}}function Ya(e,t){if(Object.keys(t).length===0)return e;let n=!1,r=e.map(e=>{if(e.role!==`assistant`)return e;let r=!1,i=e.parts.map(e=>{if(!za(e))return e;let n=qa(e),i=n===void 0?void 0:t[n];if(i===void 0)return e;let a=Ja(e,i);return a===null?e:(r=!0,a)});return r?(n=!0,{...e,parts:i}):e});return n?r:e}var Xa=`Tool execution interrupted by user.`,Za=`Tool call cancelled by user.`,Qa=e=>e.type===`tool.results_submitted`,$a=e=>e.type===`tool.calls_interrupted`,eo=e=>e.type===`tool.approval_resolved`,to={name:`pending-tool-results`,replaysHistory:!1,initial:()=>({results:{}}),reduce(e,t){if(Qa(t.payload)){let n={...e.results};for(let e of t.payload.results)n[e.toolCallId]=e;return{results:n}}if($a(t.payload)){let n={...e.results};for(let e of t.payload.toolCallIds)n[e]={toolCallId:e,state:`output-error`,errorText:Za};return{results:n}}if(eo(t.payload)){let n=t.payload.toolCallId;if(n===void 0||e.results[n]===void 0)return e;let r={...e.results};return delete r[n],{results:r}}if((t.payload.type===`tool.completed`||t.payload.type===`tool.failed`||t.payload.type===`tool.denied`)&&typeof t.payload.toolCallId==`string`&&e.results[t.payload.toolCallId]!==void 0){let n={...e.results};return delete n[t.payload.toolCallId],{results:n}}return e}};function no(e,t){if(Object.keys(t).length===0)return e;let n=!1,r=e.map(e=>{if(e.role!==`assistant`)return e;let r=!1,i=e.parts.map(e=>{if(!za(e)||e.state!==`input-available`)return e;let n=t[e.toolCallId];
7return n===void 0?e:(r=!0,n.state===`output-available`?{...e,state:`output-available`,output:n.output}:{...e,state:`output-error`,errorText:n.errorText})});return r?(n=!0,{...e,parts:i}):e});return n?r:e}var ro=(e,t)=>e.id===t.id&&e.queueIndex===t.queueIndex&&e.message===t.message&&e.held===t.held&&e.heldReason===t.heldReason&&e.heldStrategy===t.heldStrategy&&e.fold===t.fold,io=(e,t)=>e.length===t.length&&e.every((e,n)=>e===t[n]),ao=e=>({id:e.id,queueIndex:e.queueIndex,message:e.message,...F({held:e.held?!0:void 0,heldStrategy:e.held?e.heldStrategy:void 0,fold:e.fold?!0:void 0})}),oo=(e,t)=>{let n=new Map(e.map(e=>[e.id,e])),r=new Set,i=[];for(let e=0;e<t.length;e+=1){let a=t[e];if(a!==void 0)for(let t of a){let a=n.get(t);a!==void 0&&(r.add(t),i.push(a.queueIndex===e?a:{...a,queueIndex:e}))}}for(let t of e)r.has(t.id)||i.push(t);return i},so=e=>{let t=Array.isArray(e.order)?oo(e.projected,e.order):e.projected;return io(t,e.current)?e.current:t},co=(e,t)=>e.length===t.length&&e.every((e,n)=>{let r=t[n];return r!==void 0&&e.length===r.length&&e.every((e,t)=>e===r[t])}),lo=(e,t)=>!Array.isArray(t)||co(e,t)?e:t,uo=(e,t)=>{if(e.length===0)return t;let n=new Map;for(let t of e)for(let e of t)n.set(e,t);let r=new Set,i=[];for(let e of t)for(let t of e){let e=n.get(t);e!==void 0&&!r.has(e)&&(r.add(e),i.push(e))}let a=e.filter(e=>!r.has(e));return lo(e,[...i,...a])},fo=e=>{if(Array.isArray(e.published))return lo(e.previous,e.published);let t=e.previous.map(t=>t.some(t=>e.removed.has(t))?t.filter(t=>!e.removed.has(t)&&e.projected.has(t)):t).filter(e=>e.length>0);return co(e.previous,t)?e.previous:t},po=e=>{let t=new Set;for(let n of e.items)t.add(n.id);for(let n of e.materializing)t.add(n.id);return t},mo=(e,t)=>{let n=t.order?.[t.index],r=e.items.find(e=>n?.includes(e.id))?.heldStrategy,i=new Map;for(let[e,n]of t.queueEntryIds.entries()){let a=t.messages[e];a!==void 0&&i.set(n,ao({id:n,queueIndex:t.index,message:a,held:t.held,heldStrategy:r,fold:t.fold===!0}))}let a=e.items.map(e=>{let t=i.get(e.id);return t===void 0?e:(i.delete(e.id),ro(e,t)?e:t)});for(let e of i.values())a.push(e);let o=so({projected:a,current:e.items,order:t.order}),s=lo(e.order,t.order),c=t.held?e.paused:!1;return o===e.items&&s===e.order&&c===e.paused?e:{...e,items:o,order:s,paused:c}},ho=(e,t)=>{let n=new Set(t.queueEntryIds),r=[],i=[];for(let t of e.items)n.has(t.id)?t.message.parts.length>0&&r.push(t):i.push(t);let a=fo({previous:e.order,published:t.order,removed:n,projected:po(e)}),o=so({projected:i,current:e.items,order:a}),s=new Map(e.materializing.map(e=>[e.id,e]));for(let e of r)s.set(e.id,e);let c=[...s.values()];return o===e.items&&a===e.order&&io(c,e.materializing)&&!e.paused?e:{...e,items:o,order:a,materializing:c,paused:!1}},go=(e,t)=>{let n=new Set(t.queueEntryIds),r=fo({previous:e.order,published:t.order,removed:n,projected:po(e)}),i=so({projected:e.items.filter(e=>!n.has(e.id)),current:e.items,order:r}),a=e.materializing.filter(e=>!n.has(e.id)),o=e.paused&&i.length>0;return i===e.items&&r===e.order&&io(a,e.materializing)&&o===e.paused?e:{...e,items:i,order:r,materializing:a,paused:o}},_o=(e,t,n)=>{let r=!1,i=e.items.map(e=>e.id!==t||e.message===n?e:(r=!0,{...e,message:n}));return r?{...e,items:i}:e},vo=(e,t)=>{let n=new Set(t),r=!1,i=e.items.map(e=>!n.has(e.id)||e.held===!0||e.fold===!0?e:(r=!0,{...e,fold:!0}));return r?{...e,items:i}:e},yo=(e,t)=>{let{strategy:n,reason:r,reasonEntryId:i}=t,a=n!==void 0,o=n===`skip`?n:void 0,s=new Set(t.queueEntryIds),c=!1,l=e.items.map(e=>{let t=a&&e.id===i?r:void 0;return!s.has(e.id)||e.held===!0===a&&e.heldReason===t&&e.heldStrategy===o?e:(c=!0,a?{id:e.id,queueIndex:e.queueIndex,message:e.message,held:!0,...F({heldReason:t,heldStrategy:o,fold:e.fold===void 0&&void 0})}:{id:e.id,queueIndex:e.queueIndex,message:e.message,...F({fold:e.fold})})});return c?{...e,items:l}:e},bo=e=>e.items.some(e=>e.fold===!0)?{...e,items:e.items.map(e=>e.fold===!0?{...e,fold:!1}:e)}:e,xo=(e,t)=>{if(t===`running`)return e.paused?{...e,paused:!1}:e;let n=e.items.length>0;return!e.turnActive&&e.materializing.length===0&&e.paused===n?e:{...e,turnActive:!1,materializing:[],paused:n}},So=(e,t)=>{let n=new Set(t),r=fo({previous:e.order,published:void 0,removed:n,projected:po(e)}),i=so({projected:e.items.filter(e=>!n.has(e.id)),current:e.items,order:r}),a=e.materializing.filter(e=>!n.has(e.id)),o=e.paused&&i.length>0;return!e.turnActive&&i===e.items&&r===e.order&&a.length===e.materializing.length&&o===e.paused?e:{...e,items:i,order:r,materializing:a,turnActive:!1,paused:o}},Co=e=>B(e)&&typeof e.id==`number`&&typeof e.queueIndex==`number`&&B(e.message)&&typeof e.message.id==`
7string`&&Array.isArray(e.message.parts)&&(e.held===void 0||typeof e.held==`boolean`)&&(e.heldReason===void 0||e.heldReason===`edit`)&&(e.heldStrategy===void 0||e.heldStrategy===`block`||e.heldStrategy===`skip`)&&(e.fold===void 0||typeof e.fold==`boolean`),wo=e=>Array.isArray(e)&&e.every(e=>Array.isArray(e)&&e.every(e=>typeof e==`number`)),To=e=>B(e)&&Array.isArray(e.items)&&e.items.every(Co)&&Array.isArray(e.materializing)&&e.materializing.every(Co)&&typeof e.turnActive==`boolean`&&typeof e.paused==`boolean`&&wo(e.order),Eo=(e,t)=>{if(V(t,`queue.enqueued`))return mo(e,t);if(V(t,`queue.dequeued`))return ho(e,t);if(V(t,`queue.cancelled`))return go(e,t);if(V(t,`queue.edited`))return _o(e,t.queueEntryId,t.message);if(V(t,`queue.folded`))return vo(e,t.queueEntryIds);if(V(t,`queue.held`)||V(t,`queue.released`))return yo(e,t);if(V(t,`queue.moved`)){let n=uo(e.order,t.order),r=so({projected:e.items,current:e.items,order:n});return r===e.items&&n===e.order?e:{...e,items:r,order:n}}},Do=(e,t)=>{if(V(t,`turn.started`))return e.turnActive&&!e.paused?e:{...e,turnActive:!0,paused:!1};if(V(t,`turn.completed`)||V(t,`turn.failed`)||V(t,`turn.cancelled`))return t.queueEntryIds===void 0?xo(e,`idle`):So(e,t.queueEntryIds);if(V(t,`session.status`))return xo(e,t.status)},Oo={name:`queue`,version:6,initial:()=>({items:[],materializing:[],turnActive:!1,paused:!1,order:[]}),reduce:(e,t)=>Eo(e,t.payload)??Do(e,t.payload)??(t.payload.type===`actor.state`?bo(e):void 0)??e,validate:To},ko=e=>({type:`session.status`,status:e}),Ao=(e,t)=>({...e,reduce:(n,r)=>V(r.payload,`thread.archived`)?t===void 0?e.reduce(n,{...r,payload:ko(`idle`)}):t(n):V(r.payload,`thread.status`)?e.reduce(n,{...r,payload:ko(r.payload.status)}):e.reduce(n,r)});function jo(e){return e.type===`queue.enqueued`}function Mo(e){return e.type===`queue.dequeued`}function No(e){return e.type===`queue.cancelled`}function Po(e){return e.type===`queue.edited`}function Fo(e){return e.type===`queue.folded`}function Io(e){return e.type===`queue.moved`}function Lo(e){return e.type===`queue.held`}function Ro(e){return e.type===`queue.released`}function zo(e,t){if(t.payload.type===`queue.resumed`)return e.paused?{...e,paused:!1}:e;if(Po(t.payload)&&t.synthetic===!0){let n=t.payload.queueEntryId;return{...e,items:e.items.map(e=>e.id===n?{...e,failed:t.failed===void 0?void 0:{...t.failed,operation:`edit`}}:e)}}if(!jo(t.payload))return e;let n=e.items;if(t.synthetic===!0){let e=new Set;n=n.filter(t=>!e.has(t.message.id)&&(e.add(t.message.id),!0))}let r=new Set(t.payload.queueEntryIds),i=n.length!==e.items.length;return n=n.map(e=>{if(!r.has(e.id))return e;let n=t.synthetic===!0,a=n&&e.optimistic!==!0,o=t.failed!==void 0&&e.failed!==t.failed,s=t.isConfirming===!0&&e.isConfirming!==!0;return a||o||s?(i=!0,{...e,...n?{optimistic:!0,queueIndex:-1}:{},...t.failed===void 0?{}:{failed:t.failed},...t.isConfirming===!0?{isConfirming:!0}:{}}):e}),i?{...e,items:n}:e}var Bo={name:Oo.name,consumedTypes:[`queue.enqueued`,`queue.dequeued`,`queue.cancelled`,`queue.edited`,`queue.folded`,`queue.held`,`queue.released`,`queue.moved`,`turn.started`,`turn.completed`,`turn.failed`,`turn.cancelled`,`session.status`,`actor.state`],reducer:Oo,canonicalGate:e=>e.synthetic!==!0||e.payload.type!==`session.status`,clientReduce:zo};function Vo(e){return{...Bo,name:`queue@${e}`,threadScope:{kind:`thread`,threadId:e}
7,admitRootEventTypes:[`actor.state`],isSnapshotable:!1,consumedTypes:[...Bo.consumedTypes??[],`thread.status`,`thread.archived`,`thread.unarchived`],reducer:Ao(Oo),clientReduce:(e,t)=>{if(t.payload.type===`thread.archived`)return{...e,archived:!0,turnActive:!1,paused:!0};if(t.payload.type===`thread.unarchived`){let{archived:t,...n}=e;return{...n,paused:!1}}return e.archived===!0?{...e,turnActive:!1,paused:!0}:zo(e,t)}}}var Ho=D(Oe);function Uo(e){return e===null||B(e)&&typeof e.forkEventId==`number`&&Number.isSafeInteger(e.forkEventId)&&e.forkEventId>0&&typeof e.sourceSessionId==`string`&&e.sourceSessionId.length>0&&typeof e.sourceMessageId==`number`&&Number.isSafeInteger(e.sourceMessageId)&&e.sourceMessageId>0&&typeof e.copiedCount==`number`&&Number.isSafeInteger(e.copiedCount)&&e.copiedCount>=0&&Ho(e.machine)}var Wo={name:`session-fork`,version:2,initial:()=>null,reduce:(e,t)=>{if(!V(t.payload,`session.forked`))return e;let n=t.payload.machine;return n!==void 0&&!Ho(n)?e:{forkEventId:t.id,sourceSessionId:t.payload.sourceSessionId,sourceMessageId:t.payload.sourceMessageId,copiedCount:t.payload.copiedCount,machine:n??`shared`}},validate:Uo},Go={name:Wo.name,threadScope:{kind:`thread`,threadId:0},consumedTypes:[`session.forked`],reducer:Wo,canonicalGate:e=>e.synthetic!==!0},Ko=[`unknown`,`disabled`,`subscription-only`,`subscription-required`,`subscription-expired`],qo=e=>B(e)&&typeof e.modelId==`string`&&typeof e.kind==`string`&&Ko.includes(e.kind)&&(e.provider===void 0||typeof e.provider==`string`)&&(e.setBy===void 0||e.setBy===`organization`||e.setBy===`member`),Jo=e=>B(e)&&(e.status===`active`||e.status===`idle`||e.status===`error`)&&(e.error===void 0||typeof e.error==`string`)&&(e.usageLimit===void 0||B(e.usageLimit)&&(e.usageLimit.resetsAt===void 0||typeof e.usageLimit.resetsAt==`number`)&&(e.usageLimit.planType===void 0||typeof e.usageLimit.planType==`string`))&&(e.modelUnavailable===void 0||qo(e.modelUnavailable))&&typeof e.waiting==`boolean`&&Array.isArray(e.openToolCallIds)&&e.openToolCallIds.every(e=>typeof e==`string`),Yo=e=>e.status===`active`&&!e.waiting&&e.openToolCallIds.length===0?e:{status:`active`,waiting:!1,openToolCallIds:[]},Xo=e=>e.status===`error`||e.status===`idle`?e:{status:`idle`,waiting:e.waiting,openToolCallIds:e.openToolCallIds},Zo=e=>e.status===`idle`&&e.waiting?e:{status:`idle`,waiting:!0,openToolCallIds:e.openToolCallIds},Qo=(e,t)=>e.openToolCallIds.includes(t)?e:{...e,openToolCallIds:[...e.openToolCallIds,t]},$o=(e,t)=>{if(!e.openToolCallIds.includes(t))return e;let n=e.openToolCallIds.filter(e=>e!==t);return{...e,openToolCallIds:n,waiting:e.waiting&&n.length>0}},es=(e,t)=>e?.modelId===t?.modelId&&e?.kind===t?.kind&&e?.provider===t?.provider&&e?.setBy===t?.setBy,ts=(e,t,n,r)=>e.status===`error`&&e.error===t&&e.usageLimit?.resetsAt===n?.resetsAt&&e.usageLimit?.planType===n?.planType&&es(e.modelUnavailable,r)&&!e.waiting&&e.openToolCallIds.length===0?e:{status:`error`,error:t,...n===void 0?{}:{usageLimit:n},...r===void 0?{}:{modelUnavailable:r},waiting:!1,openToolCallIds:[]},ns={name:`status`,version:3,initial:()=>({status:`idle`,waiting:!1,openToolCallIds:[]}),reduce:(e,t)=>{let n=t.payload;return V(n,`session.status`)?n.status===`running`?Yo(e):Xo(e):V(n,`turn.started`)?Yo(e):V(n,`turn.failed`)?ts(e,n.error,n.usageLimit,n.modelUnavailable):V(n,`turn.completed`)?n.stopReason===`paused`?Zo(e):Xo(e):V(n,`turn.cancelled`)?Xo(e):V(n,`tool.started`)&&typeof n.toolCallId==`string`?Qo(e,n.toolCallId):(V(n,`tool.completed`)||V(n,`tool.failed`)||V(n,`tool.denied`))&&typeof n.toolCallId==`string`?$o(e,n.toolCallId):e},validate:Jo};function rs(e){return e.type===`session.status`}var is={name:ns.name,consumedTypes:[`session.status`,`turn.started`,`turn.completed`,`turn.failed`,`turn.cancelled`,`tool.started`,`tool.completed`,`tool.failed`,`tool.denied`],reducer:ns,tailBootstrap:!0,requiresTailBoundary:!0};function as(e,t=0){return e.some(e=>(e.threadId??0)===t&&e.events.some(e=>rs(e.payload)))}var os=ce.check(ne(0)),ss=A([`rewind`,`edit`,`regenerate`]),cs=E({noCacheTokens:k(O),cacheReadTokens:k(O),cacheWriteTokens:k(O)}),ls=E({textTokens:k(O),reasoningTokens:k(O)}),us=E({inputTokens:k(O),outputTokens:k(O),totalTokens:k(O),inputTokenDetails:k(cs),outputTokenDetails:k(ls),modelId:k(N),payer:k(A(ve)),speed:k(A(ge))}
7),ds=A([`system`,`user`,`assistant`,`developer`]).annotate({description:`Role of the message sender`});fe(`Message`)({id:O.annotate({description:`Message ID (id of the originating event)`}),role:ds,parts:T.annotate({description:`Message content parts`}),metadata:P(T).annotate({description:`Optional message metadata`}),createdAt:O.annotate({description:`Creation timestamp (epoch ms)`})},{identifier:`Message`,title:`Message`,description:`A message within the agent conversation`}),fe(`MessageListParams`)({cursor:k(O),limit:k(O)}),fe(`MessagePage`)({messages:me(T).annotate({description:`Messages in this page`}),nextCursor:P(O).annotate({description:`Message id to pass as the next cursor (null if no more pages)`})}),fe(`MessageSearchParams`)({query:N.annotate({description:`Literal substring matched against text parts (SQL LIKE semantics); results are ordered newest first.`}),limit:k(O).annotate({description:`Max results to return (default 50, max 200)`})}),C(e=>I(e)&&typeof e.id==`number`&&typeof e.role==`string`&&Array.isArray(e.parts)&&typeof e.createdAt==`number`,{identifier:`MessageRow`}),E({organizationId:N,userId:N,teamId:ue(N)});var fs=[`manual`,`threshold`,`overflow`],ps=[...fs,`provider`],ms=e=>fs.some(t=>t===e),hs=e=>ps.some(t=>t===e),gs=A(fs),_s=A(ps);A([`empty-history`,`pending-tools`,`stale-history`,`no-retained-tail`]);var vs=E({firstMessageId:P(O),lastMessageId:P(O),messageIds:k(me(O))}),ys=E({summarized:vs,retained:vs,carryMessageId:k(P(N))}),bs=E({beforeInputTokensEstimate:O,replayInputTokensEstimate:O,trigger:k(us),summary:k(us)}),xs=E({compaction:E({trigger:gs,model:E({id:N,summarizerId:N}),history:ys,usage:bs})}),Ss=D(xs),Cs=()=>pe()(T,{decode:re(),encode:oe()}),ws=A([`end_turn`,`max_tokens`,`max_turn_requests`,`refusal`,`paused`,`stop_requested`,`stop_condition`,`step_vetoed`,`loop_detected`,`no_progress`]).annotate({identifier:`StopReason`,description:`Why a turn stopped after completing normally. Cancellation and failure are their own terminal events (turn.cancelled, turn.failed) and carry no stop reason.`}),Ts=C(e=>I(e)&&typeof e.id==`string`&&typeof e.role==`string`&&Array.isArray(e.parts),{identifier:`HarnessMessage`,toCodecJson:()=>Cs()}).annotate({jsonSchema:{type:`object`,additionalProperties:!0,description:`A full harness message: an AI SDK UIMessage (id, role, parts) with harness metadata`}}),Es=C(e=>I(e)&&typeof e.type==`string`,{identifier:`UIMessagePart`,toCodecJson:()=>Cs()}).annotate({jsonSchema:{type:`object`,additionalProperties:!0,description:`AI SDK UIMessagePart (discriminated by 'type')`}}),Ds=C(e=>I(e),{identifier:`ProviderMetadata`,toCodecJson:()=>Cs()}).annotate({jsonSchema:{type:`object`,additionalProperties:!0,description:`AI SDK provider metadata, namespaced by provider id`}}),Os=C(e=>I(e),{identifier:`ToolMetadata`,toCodecJson:()=>Cs()}).annotate({jsonSchema:{type:`object`,additionalProperties:!0,description:"Source-identity capture from the tool definition (SDK tool `metadata`); pins an approved call to the binding it was approved against"}}),ks=C(e=>I(e)&&typeof e.modelId==`string`&&typeof e.reasoning==`string`,{identifier:`ModelConfig`,toCodecJson:()=>Cs()}).annotate({jsonSchema:{type:`object`,additionalProperties:!0,description:`Model selection: model id, reasoning tier, optional speed`}}
7),Y=O.annotate({description:`Numeric row id of the message in the transcript projection`}),As=N.annotate({description:`Part id shared by every event of one streamed part`}),js=N.annotate({description:`Provider tool-call id shared by every event of one tool call`}),Ms=N.annotate({description:`Approval id pairing a request with its resolution`}),Ns=me(O).annotate({description:`Queue entry row ids, in delivery order`}),Ps=me(me(O)).annotate({description:`Post-mutation queue order snapshot: slot = group position, values = entry ids in delivery order`}),Fs=E({type:M(`message.created`),branchId:k(os),message:Ts}).annotate({identifier:`MessageCreated`,description:`A transcript row appended whole (user and system rows, compaction checkpoint rows). The event id becomes the row id.`}),Is=E({type:M(`message.started`),branchId:k(os),role:M(`assistant`)}).annotate({identifier:`MessageStarted`,description:`Reserves the streaming assistant row; the event id becomes the message row id.`}),Ls=C(e=>I(e),{identifier:`MessageMetadata`,toCodecJson:()=>Cs()}).annotate({jsonSchema:{type:`object`,additionalProperties:!0,description:`Harness message metadata (terminal outcome, usage, compaction, channel context)`}}),Rs=E({type:M(`message.completed`),messageId:Y,metadata:k(Ls)}).annotate({identifier:`MessageCompleted`,description:`The assistant row settled: closes the streamed bracket and stamps row metadata. Parts are the fold of the durable part events.`}),zs=E({type:M(`message.edited`),messageId:Y,message:Ts}).annotate({identifier:`MessageEdited`,description:`In-place content replacement; the row keeps its id, clientId, and createdAt.`}),Bs=E({kind:A([`user`,`agent`]),id:N}).annotate({identifier:`MessageReactor`,description:`Reacting identity: a human viewer or the agent itself.`}),Vs=E({type:M(`message.reaction_set`),messageId:Y,clientMessageId:N,emoji:N,active:j,reactor:Bs,phoneChannelId:k(N),phoneMessageId:k(N)}).annotate({identifier:`MessageReactionSet`,description:`Sets or clears one reactor's emoji reaction on a persisted row, folded into the row's metadata.`}),Hs=E({type:M(`message.phone_delivery_status`),messageId:Y,clientMessageId:N,phoneDelivery:Ge}).annotate({identifier:`MessagePhoneDeliveryStatus`,description:`Records the latest aggregate phone delivery receipt for a persisted message.`}),Us={messageId:Y,partId:As,providerMetadata:k(Ds)},Ws=E({type:M(`text.started`),...Us}).annotate({identifier:`TextStarted`,description:`A streamed text part opened.`}
7),Gs=E({type:M(`text.delta`),...Us,delta:N.annotate({description:`Appended text fragment`})}).annotate({identifier:`TextDelta`,description:`Live-only text fragment; the settled value is on text.ended.`}),Ks=E({type:M(`text.ended`),...Us,text:N.annotate({description:`Full accumulated text of the settled part`})}).annotate({identifier:`TextEnded`,description:`A streamed text part settled; carries the full text.`}),qs=E({type:M(`reasoning.started`),...Us}).annotate({identifier:`ReasoningStarted`,description:`A streamed reasoning part opened.`}),Js=E({type:M(`reasoning.delta`),...Us,delta:N.annotate({description:`Appended reasoning fragment`})}).annotate({identifier:`ReasoningDelta`,description:`Live-only reasoning fragment; the settled value is on reasoning.ended.`}),Ys=E({type:M(`reasoning.ended`),...Us,text:N.annotate({description:`Full accumulated reasoning text of the settled part`})}).annotate({identifier:`ReasoningEnded`,description:`A streamed reasoning part settled; carries the full text. Timing derives from the reasoning.started/reasoning.ended envelope timestamps.`}),Xs=C(e=>typeof e==`string`,{identifier:`FinishReason`}).annotate({jsonSchema:{type:`string`,description:`AI SDK provider finish reason`}}),Zs=C(e=>I(e),{identifier:`LanguageModelUsage`,toCodecJson:()=>Cs()}).annotate({jsonSchema:{type:`object`,additionalProperties:!0,description:`AI SDK token usage for one model step`}}),Qs=E({type:M(`step.started`),messageId:Y}).annotate({identifier:`StepStarted`,description:`A model step opened within the streaming message.`}),$s=E({type:M(`step.ended`),messageId:Y,config:k(E({modelId:N})),usage:k(Zs),finishReason:k(Xs)}).annotate({identifier:`StepEnded`,description:`A model step settled within the streaming message; carries the executing model config, step token usage, and provider finish reason.`}),ec=E({type:M(`part.created`),messageId:Y,part:Es}).annotate({identifier:`PartCreated`,description:`A non-streamed model-emitted part (files, search-grounding sources) added to the streaming message.`}
7),tc={visibility:k(M(`internal`).annotate({description:`Internal tool call: never delivered to clients, replayed to the model`}))},nc=E({type:M(`tool.input_started`),messageId:Y,toolCallId:js,toolName:N.annotate({description:`Registered tool name`}),dynamic:k(j.annotate({description:`True for tools not statically registered (MCP, provider)`})),providerMetadata:k(Ds),...tc}).annotate({identifier:`ToolInputStarted`,description:`Tool input streaming opened; carries the tool name before the input settles.`}),rc=E({type:M(`tool.input_delta`),toolCallId:js,delta:N.annotate({description:`Appended raw tool-input text fragment`}),...tc}).annotate({identifier:`ToolInputDelta`,description:`Live-only tool input fragment; the settled input is on tool.started.`}),ic=E({type:M(`tool.started`),messageId:Y,toolCallId:js,toolName:N.annotate({description:`Registered tool name`}),input:T.annotate({description:`Settled tool input as parsed JSON`}),dynamic:k(j.annotate({description:`True for tools not statically registered (MCP, provider)`}
7)),execution:k(M(`client`).annotate({description:`Client-executed call: parked for a client surface from dispatch, so its whole span to the terminal is a user wait, not work`})),providerMetadata:k(Ds),toolMetadata:k(Os),...tc}).annotate({identifier:`ToolStarted`,description:`Tool call created with its settled input; the durable start of a tool call's lifecycle.`}),ac=E({type:M(`tool.approval_requested`),messageId:Y,approvalId:Ms,toolCallId:js}).annotate({identifier:`ToolApprovalRequested`,description:`Tool execution paused awaiting a client approval decision.`}),oc=E({type:M(`tool.approval_resolved`),messageId:Y,approvalId:Ms,toolCallId:k(js),approved:j.annotate({description:`Whether the tool call may execute`})}).annotate({identifier:`ToolApprovalResolved`,description:`An approval decision landed; every client converges without waiting for tool output.`}),sc=E({type:M(`tool.elicit_requested`),messageId:Y,toolCallId:js,clientInput:T.annotate({description:`Tool-owned payload the client renders to collect the response; never sent to the model`})}).annotate({identifier:`ToolElicitRequested`,description:`Tool call paused awaiting a client response; carries the client-facing payload.`}),cc=E({type:M(`tool.elicit_cleared`),messageId:Y,toolCallId:js}).annotate({identifier:`ToolElicitCleared`,description:`Strips a superseded elicit payload from its tool part; the call itself is untouched.`}),lc=E({type:M(`tool.completed`),messageId:Y,toolCallId:js,output:T.annotate({de
7scription:`Tool result value`}),dynamic:k(j),providerMetadata:k(Ds),...tc}).annotate({identifier:`ToolCompleted`,description:`Tool call finished with output.`}),uc=E({type:M(`tool.failed`),toolCallId:js,error:N.annotate({description:`Failure description`}),messageId:Y,toolName:k(N.annotate({description:`Present when the failure happened before execution (input parse errors)`})),input:k(T.annotate({description:`Raw input of a pre-execution failure`})),dynamic:k(j),providerMetadata:k(Ds),...tc}).annotate({identifier:`ToolFailed`,description:`Tool call finished with an error (execution failure or unparsable input).`}),dc=E({type:M(`tool.prepared`),messageId:Y,toolCallId:js,payload:T.annotate({description:`UI payload derived by the tool prepare transform; never shown to the model`})}).annotate({identifier:`ToolPrepared`,description:`Server-side prepare transform derived a client payload for a parked call.`}),fc=E({type:M(`tool.denied`),messageId:Y,toolCallId:js,reason:k(N.annotate({description:`Denial reason surfaced to the model on replay`}))}).annotate({identifier:`ToolDenied`,description:`Tool call terminated because its approval was denied.`}
7),pc={queueEntryIds:k(Ns),queueIndex:k(O.annotate({description:`Pre-mutation queue group position the turn drained`}))},mc=E({type:M(`turn.started`),trigger:A([`queue`,`steer`,`regenerate`,`edit`,`retry`]).annotate({description:`What initiated the turn`}),...pc,messageCount:k(O.annotate({description:`History row count when the turn started`})),continuesTurnId:k(O.annotate({description:`Event id of the interrupted turn.started event this turn continues`})),lostWork:k(j.annotate({description:`Whether restart recovery discarded partial output or replaced a missing tool result`}))}).annotate({identifier:`TurnStarted`,description:`A turn began.`}),hc=E({type:M(`turn.completed`),stopReason:ws,...pc}).annotate({identifier:`TurnCompleted`,description:`A turn ran to completion.`}),gc=A([`drain`,`sleep`,`steer`]).annotate({description:"Why something other than a user Stop cancelled the turn: `drain` marks a host shutdown whose grace budget expired, `sleep` an idle actor settling before it parks, `steer` a steer superseding the running turn"}),_c=E({type:M(`turn.cancelled`),reason:k(gc),...pc}).annotate({identifier:`TurnCancelled`,description:`A turn was aborted before completing.`}),vc=`Session restarted mid-turn.`,yc=A([`execution`,`session-restart`]).annotate({de
7scription:`Machine-readable cause of the failed turn`}),bc=E({resetsAt:k(O).annotate({description:`Epoch milliseconds when the exhausted window resets`}),planType:k(N).annotate({description:`Subscription plan the limit applies to`}),pooled:k(j).annotate({description:`Whether every eligible pooled subscription was exhausted`}),exhaustedMembers:k(O).annotate({description:`Number of exhausted subscriptions in the pool`}),provider:k(Je).annotate({description:`Subscription provider whose limit was reached, when known`})}).annotate({identifier:`TurnUsageLimit`,description:`Structured detail of a subscription usage-limit turn failure.`}),xc=E({modelId:N.annotate({description:`Qualified id of the model the turn could not run on`}),kind:A([`unknown`,`disabled`,`subscription-only`,`subscription-required`,`subscription-expired`]).annotate({description:`The first failing model-policy check`}),provider:k(N).annotate({description:`Subscription provider to connect or reconnect, for the subscription kinds`}),setBy:k(A([`organization`,`member`])).annotate({de
7scription:`Which setting turned subscription only on, for kind subscription-only`})}).annotate({identifier:`TurnModelUnavailable`,description:`Structured detail of a turn that could not run on its selected model.`}),Sc=E({type:M(`turn.failed`),error:N.annotate({description:`Failure description`}),reason:k(yc),usageLimit:k(bc).annotate({description:`Present when the failure was a subscription usage limit; the UI renders the structured card from it.`}),modelUnavailable:k(xc).annotate({description:`Present when the turn could not run on its model; the UI renders the connect or choose-model card from it.`}),...pc}).annotate({identifier:`TurnFailed`,description:`A turn failed; the single durable record of the failure.`}),Cc=E({type:M(`turn.steered`)}).annotate({identifier:`TurnSteered`,description:`The user steered the running turn.`}),wc=E({type:M(`session.status`),status:A([`running`,`idle`]).annotate({description:`Coarse session activity`})}).annotate({identifier:`SessionStatus`,description:`Coarse session activity transition; failure detail lives on turn.failed.`}),Tc=E({type:M(`thread.created`),threadId:Pt,agentName:N.annotate({de
7scription:`Agent definition bound to the thread`}),label:N.annotate({description:`Human-readable thread label`}),parentThreadId:Pt,dispose:A([`persistent`,`auto`]).annotate({description:`Thread disposal policy`}),modelConfig:k(ks).annotate({description:`Spawn-time model override persisted on the thread`})}).annotate({identifier:`ThreadCreated`,description:`A thread was created and became available for work.`}),Ec=E({type:M(`session.forked`),sourceSessionId:N,sourceMessageId:O,copiedCount:O,machine:k(Oe).pipe(se(de(`shared`)))}),Dc=E({type:M(`thread.forked`),sourceThreadId:Pt,sourceMessageId:Y,copiedCount:O.pipe(he(le(),ne(0)))}).annotate({identifier:`ThreadForked`,description:`A thread was forked from a settled source transcript cutoff.`}),Oc=E({type:M(`thread.renamed`),threadId:Pt,label:N}).annotate({identifier:`ThreadRenamed`,description:`A thread label was changed.`}),kc=E({type:M(`thread.status`),threadId:Pt,status:A([`running`,`idle`]).annotate({description:`Current thread activity`})}).annotate({identifier:`ThreadActivityStatus`,description:`A thread activity transition occurred.`}),Ac=E({type:M(`thread.archived`),threadId:Pt}).annotate({identifier:`ThreadArchived`,description:`A thread was archived and left the live roster.`}),jc=E({type:M(`thread.unarchived`),threadId:Pt}).annotate({identifier:`ThreadUnarchived`,description:`An archived thread was revived and rejoined the live roster.`}
7),Mc=[E({type:M(`session.idle_heartbeat`),idleMs:O.annotate({description:`Milliseconds since the last agent activity`})}).annotate({identifier:`SessionIdleHeartbeat`,description:`Live-only inactivity heartbeat consumed by the hosting runner's sleep logic.`}),E({type:M(`session.settled`)}).annotate({identifier:`SessionSettled`,description:`Live-only aggregate-quiet signal; the hosting runner syncs idle status without parking.`})],Nc=w(Mc).annotate({identifier:`InternalSignal`,description:`Actor-local signals consumed within the harness runtime.`});D(Nc);var Pc=new Set(Mc.map(e=>e.fields.type.literal)),Fc=E({type:M(`subscription.switched`),provider:Je,connectionId:N,ownerUserId:N,ownerDisplayName:k(N),ownedBySpeaker:j,revision:O,reason:A([`initial`,`usage-limit`,`expired`,`unpooled`,`manual`]),previousConnectionId:k(N)}).annotate({identifier:`SubscriptionSwitched`,description:`The session subscription pin moved to an eligible pool member.`}),Ic=E({type:M(`model.changed`),config:ks}).annotate({identifier:`ModelChanged`,description:`Active model config transitioned; re-asserting the same pair emits nothing.`}
7),Lc=E({type:M(`mode.changed`),mode:P(N).annotate({description:`The mode now active; null when no mode is active`}),displaced:k(P(N)).annotate({description:`The mode plan displaced, authoritative when present; absent on legacy events, which derive it from the transition`})}).annotate({identifier:`ModeChanged`,description:`Active mode transitioned; null clears; re-asserting the same mode emits nothing unless it corrects the displaced mode.`}),Rc=E({type:M(`history.truncated`),afterRowId:O.annotate({description:`Boundary row id; every later row is deleted`}),afterMessageId:P(N).annotate({description:`Client-visible boundary id (clientId ?? String(rowId)); null clears the whole transcript`})}).annotate({identifier:`HistoryTruncated`,description:`Deletes all messages after the boundary.`}),zc=E({type:M(`queue.enqueued`),queueEntryIds:Ns,index:O.annotate({description:`Pre-mutation group position the entries landed at`}),messages:me(Ts).annotate({description:`Full message per entry id (same order as queueEntryIds), so clients render content without a queue round-trip`}
7),held:j.annotate({description:`Whether the entries landed in a held group`}),fold:k(j.annotate({description:`Whether the entries were enqueued as a fold group for priority delivery into the running turn; provenance only`})),order:Ps}).annotate({identifier:`QueueEnqueued`,description:`Entries joined the pending queue.`}),Bc=E({type:M(`queue.dequeued`),queueEntryIds:Ns,index:O,order:Ps}).annotate({identifier:`QueueDequeued`,description:`Entries left the queue for a turn.`}),Vc=E({type:M(`queue.cancelled`),queueEntryIds:Ns,order:Ps}).annotate({identifier:`QueueCancelled`,description:`Entries were cancelled out of the queue.`}),Hc=E({type:M(`queue.edited`),queueEntryId:O.annotate({description:`Edited queue entry row id`}),message:Ts}).annotate({identifier:`QueueEdited`,description:`A pending entry's content was replaced.`}),Uc=E({type:M(`queue.folded`),queueEntryIds:Ns}).annotate({identifier:`QueueFolded`,description:`Pending entries were promoted into fold-priority delivery.`}),Wc=E({type:M(`queue.held`),queueEntryIds:Ns,index:O,strategy:A([`block`,`skip`]).annotate({de
7scription:`block stalls the queue at the group; skip lets later groups drain around it`}),reason:k(M(`edit`).annotate({description:`edit marks a hold placed while a client edits one row of the group`})),reasonEntryId:k(O.annotate({description:`The single row under edit; the gate spans the group but only this row carries the edit mark and may settle it`}))}).annotate({identifier:`QueueHeld`,description:`A queue group was held back from draining.`}),Gc=E({type:M(`queue.released`),queueEntryIds:Ns,index:O}).annotate({identifier:`QueueReleased`,description:`A held queue group was released.`}),Kc=E({type:M(`queue.moved`),operationId:k(N.annotate({description:`Correlation id of the inbound queue move request`})),queueEntryIds:Ns,from:O.annotate({description:`Pre-mutation group position`}),to:O.annotate({description:`Effective target position`}),order:Ps}).annotate({identifier:`QueueMoved`,description:`A queue group moved to a new position.`}),qc=N.annotate({description:`Correlation id of the manual compaction request this event answers`}),Jc={inline:`inline`,background:`background`}
7,Yc=A([Jc.inline,Jc.background]).annotate({description:`inline blocks the turn until the checkpoint commits; background runs beside it and renders no transcript divider. Absent means inline.`}),Xc=E({type:M(`compaction.started`),trigger:gs,mode:k(Yc),attemptId:k(qc)}).annotate({identifier:`CompactionStarted`,description:`Context compaction began.`}),Zc=E({type:M(`compaction.completed`),trigger:_s,mode:k(Yc),attemptId:k(qc),messageId:N.annotate({description:`Client-visible id of the checkpoint message row`}),compaction:k(xs.fields.compaction)}).annotate({identifier:`CompactionCompleted`,description:`Context compaction wrote a checkpoint. The checkpoint row itself arrives as a message event; its anchor role is internal persistence detail.`}),Qc=E({type:M(`compaction.failed`),trigger:gs,mode:k(Yc),attemptId:k(qc),error:N.annotate({description:`Failure description`})}).annotate({identifier:`CompactionFailed`,description:`Context compaction failed without writing a checkpoint.`}),$c=A([`pursuing`,`paused`,`achieved`,`unmet`,`budget_limited`]).annotate({identifier:`GoalStatus`}),el=A([`user`,`stopped`,`resumed`,`plan`,`plan_released`,`wrap_up_armed`,`model`,`budget`]).annotate({identifier:`GoalStatusCause`}),tl=E({inputTokens:O,outputTokens:O,cacheReadTokens:O,cacheWriteTokens:O,turns:O}).annotate({identifier:`GoalUsage`,description:`Cumulative usage attributed to the goal, never a delta`}),nl=E({organizationId:N,userId:N,teamId:k(N)}).annotate({identifier:`GoalAuthor`}
7),rl=E({type:M(`goal.set`),goalId:O.annotate({description:`Monotonic id chosen at set; distinguishes successive goals`}),objective:N.annotate({description:`The user's objective, verbatim`}),revision:O,tokenBudget:P(O).annotate({description:`Token budget; null is unlimited`}),author:nl.annotate({description:`Durable-safe author snapshot stamped on continuation rows`}),foldCursor:P(O).annotate({description:`Newest usage-stamped assistant row id at creation; folding starts past it, so settled pre-goal turns are never charged while an in-flight turn (usage stamped at settlement) still folds`})}).annotate({identifier:`GoalSet`,description:`A goal was created; pursuit starts immediately.`}),il=E({type:M(`goal.updated`),goalId:O,revision:O.annotate({description:`The bumped revision; queued continuations go stale`}),objective:k(N.annotate({description:`New objective; absent = unchanged`})),budget:k(E({tokenBudget:P(O)}).annotate({description:`New budget wrapper; absent = unchanged, null inside = unlimited`}))}).annotate({identifier:`GoalUpdated`,description:`The goal was edited; wrap-up arming resets.`}),al=E({type:M(`goal.status`),goalId:O,status:$c,hold:P(M(`plan`)),cause:el,activeMs:O.annotate({de
7scription:`Folded active pursuit ms after this transition`}),lastResumedAt:P(O).annotate({description:`Open active segment start; null while paused/held/terminal`}),result:k(E({summary:N,evidence:N}))}).annotate({identifier:`GoalStatusChanged`,description:`Goal lifecycle transition (pause/resume/hold/release/terminal), full post-transition values.`}),ol=E({type:M(`goal.usage`),goalId:O,usage:tl,lastFoldedRowId:O.annotate({description:`Newest assistant message row folded; the fold idempotence cursor`})}).annotate({identifier:`GoalUsageFolded`,description:`Turn-boundary usage fold; counters are cumulative.`}),sl=E({type:M(`goal.cleared`),goalId:O}).annotate({identifier:`GoalCleared`,description:`The goal was deleted by the user.`}),cl=[E({type:M(`branch.created`),branchId:os,parentBranchId:os,forkedAfterMessageId:ce.check(ne(0)),forkedAfterClientMessageId:P(N),targetMessageId:k(ce.check(ie(0))),reason:ss,operationId:k(N),author:E({organizationId:N,userId:N,teamId:k(N)})}).annotate({identifier:`BranchCreated`}),E({type:M(`branch.switched`),branchId:os,fromBranchId:os}).annotate({identifier:`BranchSwitched`}),Fs,Is,Rs,zs,Vs,Hs,Ws,Gs,Ks,qs,Js,Ys,Qs,$s,ec,nc,rc,ic,dc,ac,oc,sc,cc,lc,uc,fc,mc,hc,_c,Sc,Cc,wc,Tc,Dc,Ec,Oc,kc,Ac,jc,Fc,Ic,Lc,Rc,zc,Bc,Vc,Hc,Uc,Wc,Gc,Kc,Xc,Zc,Qc,rl,il,al,ol,sl],ll=w(cl).annotate({identifier:`HarnessEvent`,description:`Every event tag the harness itself produces`}),ul=D(ll),dl=new Set(cl.map(e=>e.fields.type.literal)),fl=(e=>C(t=>I(t)&&typeof t.type==`string`&&!e.has(t.type),{identifier:`CustomHarnessEvent`,toCodecJson:()=>Cs()}).annotate({jsonSchema:{type:`object`,additionalProperties:!0,description:`Custom or future event (discriminated by 'type'); stored, replayed, and streamed losslessly`}}))(new Set([...dl,...Pc])),pl=D(fl);w([...cl,fl]).annotate({identifier:`AgentEventPayload`,description:`Harness events plus custom or future event tags`});var ml=D(Fc),hl={name:`subscription`,version:1,initial:()=>({byProvider:{}}),reduce:(e,t)=>V(t.payload,`subscription.switched`)?{byProvider:{...e.byProvider,[t.payload.provider]:t.payload}}:e,validate:e=>B(e)&&B(e.byProvider)&&Object.entries(e.byProvider).every(([e,t])=>ml(t)&&t.provider===e)},gl={name:hl.name,threadScope:{kind:`all`},consumedTypes:[`subscription.switched`],reducer:hl,canonicalGate:e=>e.synthetic!==!0&&e.id>0},_l={forkEventId:null};function vl(e){return{name:`fork@${e}`,threadScope:{kind:`thread`,threadId:e},consumedTypes:[`thread.forked`],initial:()=>_l,reduce:(e,t)=>V(t.payload,`thread.forked`)&&!t.synthetic?{forkEventId:t.id}:e}}var yl=vl(0),bl=[`thread.created`,`thread.forked`,`thread.renamed`,`thread.status`,`thread.archived`,`thread.unarchived`],xl={lastEventId:null};function Sl(e){let t=e.payload.type;return bl.some(e=>e===t)}var Cl={name:`thread-lifecycle-events`,threadScope:{kind:`all`},replaysHistory:!1,consumedTypes:[...bl],initial:()=>xl,reduce:(e,t)=>Sl(t)&&!t.synthetic?{lastEventId:t.id}:e},wl=Ao(ns,()=>({status:`idle`,waiting:!1,openToolCallIds:[]}));function Tl(e){return{name:`status@${e}`,threadScope:{kind:`thread`,threadId:e}
7,isSnapshotable:!1,consumedTypes:[`thread.status`,`thread.archived`,`turn.started`,`turn.completed`,`turn.failed`,`turn.cancelled`,`tool.started`,`tool.completed`,`tool.failed`,`tool.denied`],reducer:wl,tailBootstrap:!0,requiresTailBoundary:!0}}var El=e=>B(e)&&(e.outcome===`completed`||e.outcome===`paused`||e.outcome===`cancelled`||e.outcome===`failed`)&&typeof e.at==`number`,Dl=e=>B(e)&&typeof e.threadId==`number`&&typeof e.agentName==`string`&&typeof e.label==`string`&&typeof e.parentThreadId==`number`&&(e.dispose===`persistent`||e.dispose===`auto`)&&(e.modelConfig===void 0||Tn(e.modelConfig))&&(e.status===`idle`||e.status===`running`||e.status===`archived`)&&typeof e.createdAt==`number`&&(e.completion===void 0||El(e.completion))&&(e.lastCompletionMessageId===void 0||typeof e.lastCompletionMessageId==`number`)&&(e.latestPausedTerminalMessageId===void 0||typeof e.latestPausedTerminalMessageId==`number`)&&(e.lastCompletionEventId===void 0||typeof e.lastCompletionEventId==`number`)&&(e.hasSettledRun===void 0||typeof e.hasSettledRun==`boolean`)&&(e.crashSettled===void 0||typeof e.crashSettled==`boolean`),Ol=e=>B(e)&&B(e.threads)&&Object.values(e.threads).every(Dl),kl=(e,t,n)=>{let r=e.threads[t];if(r===void 0)return e;let i=n===`running`,a=i&&(r.completion!==void 0||r.crashSettled===!0);if(r.status===n&&!a)return e;let{completion:o,crashSettled:s,...c}=r,l=r.status===`running`?{hasSettledRun:!0}:{};return{...e,threads:{...e.threads,[t]:i?{...c,status:n}:{...r,...l,status:n}}}},Al=(e,t)=>{let n=e.threads[t];if(n===void 0||n.status===`archived`)return e;let{completion:r,...i}=n;return{...e,threads:{...e.threads,[t]:{...i,hasSettledRun:!0,crashSettled:!0}}}},jl=(e,t)=>{let n=e.threads[t];if(n===void 0||n.status===`archived`||n.completion===void 0&&n.crashSettled!==!0)return e;let{completion:r,crashSettled:i,...a}=n;return{...e,threads:{...e.threads,[t]:a}}},Ml=e=>{if(!B(e))return null;let t=e.source;if(!B(t)||t.type!==`thread.completion`||!B(t.payload))return null;let{threadId:n,outcome:r,terminalMessageId:i,terminalEventId:a}=t.payload;return typeof n!=`number`||r!==`completed`&&r!==`paused`&&r!==`cancelled`&&r!==`failed`?null:{threadId:n,outcome:r,...F({terminalMessageId:typeof i==`number`?i:void 0,terminalEventId:typeof a==`number`?a:void 0})}},Nl=e=>{if(V(e,`message.created`)){let t=Ml(e.message.metadata);return t===null?[]:[t]}return V(e,`queue.enqueued`)?e.messages.flatMap(e=>{let t=Ml(e.metadata);return t===null?[]:[t]}):[]},Pl=(e,t)=>e.status===`archived`||e.crashSettled===!0||e.completion!==void 0&&e.completion.outcome!==`paused`||t.terminalEventId===void 0&&(t.terminalMessageId===void 0||e.lastCompletionMessageId!==void 0&&t.terminalMessageId<=e.lastCompletionMessageId||e.latestPausedTerminalMessageId!==void 0&&t.terminalMessageId<=e.latestPausedTerminalMessageId),Fl=(e,t)=>t!==void 0&&e.lastCompletionMessageId!==void 0&&t<=e.lastCompletionMessageId||t!==void 0&&e.latestPausedTerminalMessageId!==void 0&&t<e.latestPausedTerminalMessageId||t===void 0&&e.completion!==void 0&&e.completion.outcome!==`paused`,Il=(e,t,n)=>{let r=t.terminalMessageId,i=t.outcome===`paused`;if(t.terminalEventId!==void 0&&e.lastCompletionEventId!==void 0&&t.terminalEventId<=e.lastCompletionEventId||(i?Pl(e,t):t.terminalEventId===void 0&&Fl(e,r)))return null;let a={...e,completion:{outcome:t.outcome,at:n},...F({lastCompletionEventId:t.terminalEventId??e.lastCompletionEventId})};return i?r===void 0?a:{...a,latestPausedTerminalMessageId:Math.max(e.latestPausedTerminalMessageId??r,r)}:r===void 0?a:{...a,lastCompletionMessageId:Math.max(e.lastCompletionMessageId??r,r)}},Ll=(e,t,n)=>{let r=e.threads[t];return r===void 0||r.label===n?e:{...e,threads:{...e.threads,[t]:{...r,label:n}}}},Rl=(e,t)=>{let n=t.payload;if(V(n,`thread.created`)){let r={threadId:n.threadId,agentName:n.agentName,label:n.label,parentThreadId:n.parentThreadId,dispose:n.dispose,modelConfig:n.modelConfig,status:`idle`,createdAt:t.at};return{...e,threads:{...e.threads,[n.threadId]:r}}}return V(n,`thread.renamed`)?Ll(e,n.threadId,n.label):V(n,`thread.status`)?kl(e,n.threadId,n.status):V(n,`thread.archived`)?kl(e,n.threadId,`archived`):V(n,`thread.unarchived`)?kl(e,n.threadId,`idle`):V(n,`turn.started`)?jl(e,t.threadId):V(n,`turn.failed`)&&(n.reason===`session-restart`||n.reason===void 0&&n.error===`Session restarted mid-turn.`)?Al(e,t.threadId):null},zl={name:`threads`,version:8,initial:()=>({threads:{}}),reduce:(e,t)=>{let n=Rl(e,t);if(n!==null)return n;let r=e,i=t.payload;for(let e of Nl(i)){let n=r.threads[e.threadId];if(n===void 0)continue;let i=Il(n,e,t.at);i!==null&&(r={...r,threads:{...r.threads,[e.threadId]:i}})}return r},validate:Ol},Bl={name:zl.name,threadScope:{kind:`all`},consumedTypes:[`thread.created`,`thread.status`,`thread.archived`,`thread.unarchived`,`message.created`,`queue.enqueued`,`turn.started`,`turn.failed`],reducer:zl},Vl={name:`turn-timing`,version:1,initial:()=>({}),reduce:(e,t)=>{let n=t.payload;return V(n,`turn.started`)?e.startedAt===t.at?e:{startedAt:t.at}:V(n,`turn.completed`)||V(n,`turn.failed`)||V(n,`turn.cancelled`)||V(n,`session.status`)&&n.status===`idle`?e.startedAt===void 0?e:{}:e},validate:e=>B(e)&&(e.startedAt===void 0||typeof e.startedAt==`number`)};function Hl(e){let t=e.threadScope===void 0||e.threadScope.kind===`thread`&&e.threadScope.threadId===0;return{name:e.name,...e.threadScope===void 0?{}:{threadScope:e.threadScope},...e.isSnapshotable===void 0?{}:{isSnapshotable:e.isSnapshotable},consumedTypes:[`turn.started`,`turn.completed`,`turn.failed`,`turn.cancelled`,`session.status`],...t?{tailBootstrap:!0,requiresTailBoundary:!0}:{},reducer:Vl}}var Ul=Hl({name:Vl.name}),Wl=e=>e.type===`presence.typing`,Gl={name:`typing`,consumesTransient:!0,replaysHistory:!1,threadScope:{kind:`all`},initial:()=>({typing:{}}),reduce:(e,t)=>{if(!(t.transient&&Wl(t.payload)))return e;let{userId:n,typing:r}=t.payload;if(!r){if(!(n in e.typing))return e;let{[n]:t,...r}=e.typing;return{typing:r}}return{typing:{...e.typing,[n]:{threadId:t.threadId,at:t.at}}}}},Kl=new Set([`text.started`,`text.delta`,`text.ended`,`reasoning.started`,`reasoning.delta`,`reasoning.ended`,`part.created`,`tool.input_started`,`tool.input_delta`,`tool.started`,`tool.prepared`,`tool.approval_requested`,`tool.approval_resolved`,`tool.elicit_requested`,`tool.elicit_cleared`,`tool.completed`,`tool.failed`,`tool.denied`,`step.started`,`step.ended`]),ql=e=>Kl.has(e.type),Jl=e=>
7e.type===`tool.input_delta`?void 0:e.messageId,Yl=(e,t,n)=>e.type===t&&e.state===`streaming`&&e.id===n,Xl=e=>za(e),X=(e,t)=>{for(let[n,r]of e.entries())if(Xl(r)&&r.toolCallId===t)return{index:n,part:r};return null},Z=(e,t,n)=>{let r=e.slice();return r[t]=n,r},Zl=e=>e.providerMetadata===void 0?{}:{providerMetadata:e.providerMetadata},Ql=(e,t,n)=>[...e,{type:t.type===`text.started`?`text`:`reasoning`,text:``,state:`streaming`,id:t.partId,startedAt:n,...Zl(t)}],$l=(e,t,n)=>e.some(e=>e.type===t&&e.state===`done`&&e.id===n),eu=(e,t)=>{let n=t.type===`text.delta`?`text`:`reasoning`,r=e.findIndex(e=>Yl(e,n,t.partId)),i=e[r];return i===void 0||!Yl(i,n,t.partId)?$l(e,n,t.partId)?e:[...e,{type:n,text:t.delta,state:`streaming`,id:t.partId}]:Z(e,r,{...i,text:`${i.text}${t.delta}`,...Zl(t)})},tu=(e,t,n)=>{let r=t.type===`text.ended`?`text`:`reasoning`,i={endedAt:n},a=e.findIndex(e=>Yl(e,r,t.partId)),o=e[a];return o===void 0||!Yl(o,r,t.partId)?[...e,{type:r,text:t.text,state:`done`,id:t.partId,...Zl(t),...i}]:Z(e,a,{type:r,text:t.text,state:`done`,id:t.partId,...o.startedAt===void 0?{}:{startedAt:o.startedAt},...Zl(o),...Zl(t),...i})},nu=e=>e.dynamic===!0?{type:`dynamic-tool`,toolName:e.toolName}:{type:`tool-${e.toolName}`},ru=e=>e.type===`dynamic-tool`?{type:`dynamic-tool`,toolName:e.toolName}:{type:e.type},iu=(e,t)=>e===void 0?t:t===void 0?e:Math.min(e,t),au=(e,t)=>e===void 0?t:t===void 0?e:Math.max(e,t),ou=(e,t={})=>{let n=iu(e.startedAt,t.startedAt),r=au(e.endedAt,t.endedAt),i=e.parked;if(t.parkFrom!==void 0&&(i=[...i??[],{from:t.parkFrom}]),t.parkTo!==void 0&&i!==void 0){let e=i.findLastIndex(e=>e.to===void 0);e>=0&&(i=i.map((n,r)=>r===e?{...n,to:t.parkTo}:n))}let a=t.parkToAll;return a!==void 0&&i!==void 0&&(i=i.map(e=>e.to===void 0?{...e,to:a}:e)),{...n===void 0?{}:{startedAt:n},...r===void 0?{}:{endedAt:r},...i===void 0?{}:{parked:i}}},su=e=>({...e.callProviderMetadata===void 0?{}:{callProviderMetadata:e.callProviderMetadata},...e.toolMetadata===void 0?{}:{toolMetadata:e.toolMetadata},...e.prepared===void 0?{}:{prepared:e.prepared},...e.visibility===void 0?{}:{visibility:e.visibility}}),cu=e=>({...e.providerMetadata===void 0?{}:{callProviderMetadata:e.providerMetadata},...e.visibility===void 0?{}:{visibility:e.visibility}}),lu=e=>e.providerMetadata===void 0?{}:{resultProviderMetadata:e.providerMetadata},uu=(e,t)=>{let n={...nu(t),toolCallId:t.toolCallId,state:`input-streaming`,inputText:``,...cu(t)},r=X(e,t.toolCallId);return r===null?[...e,n]:r.part.state===`input-streaming`?Z(e,r.index,{...n,...ou(r.part)}):e},du=(e,t)=>{let n=X(e,t.toolCallId);return n===null||n.part.state!==`input-streaming`?e:Z(e,n.index,{...n.part,inputText:`${n.part.inputText??``}${t.delta}`})},fu=(e,t,n)=>{let r=X(e,t.toolCallId),i={...nu(t),toolCallId:t.toolCallId,state:`input-available`,input:t.input,...cu(t),...t.toolMetadata===void 0?{}:{toolMetadata:t.toolMetadata},...ou(r?.part??{},F({startedAt:n,parkFrom:t.execution===`client`?n:void 0}))};return r===null?[...e,i]:Z(e,r.index,i)},pu=(e,t)=>{let n=X(e,t.toolCallId);return n===null?e:Z(e,n.index,{...n.part,prepared:t.payload})},mu=(e,t,n)=>{let r=X(e,t.toolCallId);return r===null?e:Z(e,r.index,{...ru(r.part),toolCallId:r.part.toolCallId,state:`approval-requested`,input:r.part.input,...su(r.part),...ou(r.part,{parkFrom:n}),approval:{id:t.approvalId}})},hu=(e,t,n)=>{let r=null;for(let[n,i]of e.entries())if(Xl(i)&&i.state===`approval-requested`&&i.approval.id===t.approvalId){r={index:n,part:i};break}if(r===null&&t.toolCallId!==void 0&&(r=X(e,t.toolCallId)),r===null)return e;if(r.part.state===`output-available`&&I(r.part.output)&&Array.isArray(r.part.output.pendingApprovals)){let n=!1,i=r.part.output.pendingApprovals.map(e=>!I(e)||e.approvalId!==t.approvalId?e:(n=!0,{...e,approved:t.approved}));if(n)return Z(e,r.index,{...r.part,output:{...r.part.output,pendingApprovals:i}})}return Z(e,r.index,{...ru(r.part),toolCallId:r.part.toolCallId,state:`approval-responded`,input:r.part.input,...su(r.part),...ou(r.part,{parkTo:n}),approval:{id:t.approvalId,approved:t.approved}})},gu=(e,t,n)=>{let r=X(e,t.toolCallId);return r===null?e:r.part.state===`approval-responded`?Z(e,r.index,{...ru(r.part),toolCallId:r.part.toolCallId,state:`input-available`,input:r.part.input,...su(r.part),...ou(r.part,{par
7kFrom:n}),clientInput:t.clientInput}):Z(e,r.index,{...r.part,...ou(r.part,{parkFrom:n}),clientInput:t.clientInput})},_u=`Superseded by a newer user message; the call did not run.`,vu={unanswered:`The user did not answer; they sent a new message instead.`,undecided:`The user sent a new message instead of responding.`,approvedUnexecuted:`Approved, but the user sent a new message before it executed.`},yu=(e,t,n)=>{let r=X(e,t.toolCallId);if(r===null)return e;let i=r.part.parked?.some(e=>e.to===void 0)===!0;if(r.part.clientInput===void 0&&!i)return e;let{clientInput:a,...o}=r.part;return Z(e,r.index,{...o,...ou(r.part,{parkTo:n})})},bu=e=>e.clientInput===void 0?{}:{clientInput:e.clientInput},xu=(e,t,n)=>{let r=X(e,t.toolCallId);return r===null?e:Z(e,r.index,{...ru(r.part),toolCallId:r.part.toolCallId,state:`output-available`,input:r.part.input,output:t.output,...su(r.part),...bu(r.part),...ou(r.part,{endedAt:n,parkToAll:n}),...lu(t)})},Su=(e,t,n,r)=>({...nu({toolName:t,dynamic:e.dynamic}),toolCallId:e.toolCallId,state:`output-error`,errorText:e.error,...e.dynamic===!0?{input:e.input}:{input:void 0,rawInput:e.input},...e.visibility===void 0?{}:{visibility:e.visibility},...ou(r??{},{endedAt:n,parkToAll:n})}),Cu=(e,t,n)=>{let r=X(e,t.toolCallId);return r===null?t.toolName===void 0?e:[...e,Su(t,t.toolName,n)]:t.toolName===void 0?Z(e,r.index,{...ru(r.part),toolCallId:r.part.toolCallId,state:`output-error`,input:r.part.input,errorText:t.error,...su(r.part),...bu(r.part),...ou(r.part,{endedAt:n,parkToAll:n}),...lu(t)}):Z(e,r.index,Su(t,t.toolName,n,r.part))},wu=(e,t,n)=>{let r=X(e,t.toolCallId);if(r===null)return e;let i=r.part.state===`approval-requested`||r.part.state===`approval-responded`?r.part.approval?.id:void 0;return i===void 0?e:Z(e,r.index,{...ru(r.part),toolCallId:r.part.toolCallId,state:`output-denied`,input:r.part.input,...su(r.part),...ou(r.part,{endedAt:n,parkToAll:n}),approval:t.reason===void 0?{id:i,approved:!1}:{id:i,approved:!1,reason:t.reason}})},Tu=(e,t)=>{let{payload:n,at:r}=t;switch(n.type){case`text.started`:case`reasoning.started`:return Ql(e,n,r);case`text.delta`:case`reasoning.delta`:return eu(e,n);case`text.ended`:case`reasoning.ended`:return tu(e,n,r);case`part.created`:return[...e,n.part];case`tool.input_started`:return uu(e,n);case`tool.input_delta`:return du(e,n);case`tool.started`:return fu(e,n,r);case`tool.approval_requested`:return mu(e,n,r);case`tool.prepared`:return pu(e,n);case`tool.approval_resolved`:return hu(e,n,r);case`tool.elicit_requested`:return gu(e,n,r);case`tool.elicit_cleared`:return yu(e,n,r);case`tool.completed`:return xu(e,n,r);case`tool.failed`:return Cu(e,n,r);case`tool.denied`:return wu(e,n,r);case`step.started`:return e.length===0?e:[...e,{type:`step-start`}];case`step.ended`:return e;default:return n}},Eu=(e,t,n)=>{let r=X(e,t);return r===null||r.part.state!==`input-streaming`?e:Z(e,r.index,{...r.part,input:n})},Du=(e,t)=>{let n=X(e,t);return n!==null&&n.part.state===`input-streaming`?n.part.inputText:void 0},Ou=e=>{if(!(`providerMetadata`in e&&I(e.providerMetadata)))return!1;let t=e.providerMetadata.openai;return I(t)&&typeof t.reasoningEncryptedContent==`string`},ku=e=>{let t=e.flatMap(e=>{if(Xl(e)&&e.state===`input-streaming`)return[];if(e.type===`text`||e.type===`reasoning`){if(e.text===``&&!(e.type===`reasoning`&&Ou(e)))return[];let{id:t,...n}=e;return[{...n,state:`done`}]}return[e]});return Au(t)?t:t.filter(e=>e.type!==`step-start`&&(e.type!==`reasoning`||e.text!==``))},Au=e=>e.some(e=>e.type===`step-start`?!1:e.type===`text`||e.type===`reasoning`?e.text.length>0:!0),ju={sent:0,failed:1,delivered:2,read:3},Mu=e=>D(Ge)(e)?e:void 0,Nu=(e,t)=>e===void 0||t.at>e.at||t.at===e.at&&ju[t.status]>ju[e.status],Pu=e=>I(e)&&typeof e.emoji==`string`&&typeof e.at==`number`&&I(e.reactor)&&(e.reactor.kind===`user`||e.reactor.kind===`agent`)&&typeof e.reactor.id==`string`&&(e.phoneChannelId===void 0||typeof e.phoneChannelId==`string`)&&(e.phoneMessageId===void 0||typeof e.phoneMessageId==`string`),Fu=e=>Array.isArray(e)?e.filter(Pu):[],Iu=(e,t)=>e.reactor.kind===t.kind&&e.reactor.id===t.id,Lu=(e,t,n)=>{let r=e.filter(e=>Iu(e,t.reactor)&&e.phoneChannelId===n&&e.phoneMessageId===t.phoneMessageId);if(t.active&&r.length===1&&r[0]?.emoji===t.emoji)return e;let i=e.filter(e=>!(Iu(e,t.reactor)&&e.phoneChannelId===n&&e.phoneMessageId===t.phoneMessageId&&(t.active||t.emoji.length===0||e.emoji===t.emoji)));if(!t.active)return i.length===e.length?e:i;let a=i.findIndex(e=>Iu(e,t.reactor)&&e.emoji===t.emoji&&e.phoneChannelId===void 0);return a>=0?i.map((e,r)=>r===a?{...e,phoneChannelId:n,...F({phoneMessageId:t.phoneMessageId}),at:t.at}:e):[...i,{emoji:t.emoji,reactor:t.reactor,phoneChannelId:n,...F({phoneMessageId:t.phoneMessageId}),at:t.at}]};function Ru(e,t){if(t.phoneChannelId!==void 0)return Lu(e,t,t.ph
7oneChannelId);let n=e.filter(e=>!(e.emoji===t.emoji&&Iu(e,t.reactor))),r=n.length<e.length;return t.active?r?e:[...e,{emoji:t.emoji,reactor:t.reactor,at:t.at}]:r?n:e}var zu=e=>typeof e==`object`&&!!e&&`source`in e&&e.source!==void 0,Bu=e=>e!==void 0&&(e.role===`user`||e.role===`developer`&&e.visibility!==`internal`&&zu(e.metadata)),Vu=e=>e.role===`developer`&&Bu(e)&&Ee(e.metadata),Hu=e=>e.role===`developer`&&!Bu(e);function Uu(e,t){let n=e.findLastIndex(Bu);if(n<0)return;let r=e.slice(0,n).findLastIndex(e=>!(Bu(e)||Hu(e)))+1;return t(e[r+e.slice(r).findIndex(Bu)])}var Wu=`data-model-retry`,Gu=`data-turn-error`,Ku=e=>({type:Gu,data:e}),qu=e=>typeof e==`object`&&!!e,Ju=e=>{if(!qu(e)||e.type!==`data-model-retry`)return null;let t=e.data;return!qu(t)||typeof t.attempt!=`number`||typeof t.maxAttempts!=`number`?null:{attempt:t.attempt,maxAttempts:t.maxAttempts}},Yu=e=>{if(!qu(e)||e.type!==`data-turn-error`)return null;let t=e.data;return!qu(t)||typeof t.message!=`string`?null:{message:t.message,...typeof t.writtenAtEventId==`number`&&Number.isSafeInteger(t.writtenAtEventId)&&t.writtenAtEventId>0?{writtenAtEventId:t.writtenAtEventId}:{},...typeof t.writtenAt==`number`&&Number.isFinite(t.writtenAt)?{writtenAt:t.writtenAt}:{}}};function Xu(e,t){let n=Yu(e);return n===null?e:{...e,type:Gu,data:{message:n.message,writtenAtEventId:t.id,writtenAt:t.at}}}var Zu=new WeakMap,Qu=(e,t,n)=>{e!==t&&Zu.set(e,{from:t,index:n})},$u=(e,t)=>{let n=e.length,r=e;for(;r!==t;){let e=Zu.get(r);if(e===void 0)return;n=Math.min(n,e.index),r=e.from}return n},ed=(e,t)=>{let n=Math.min(e.length,t.length),r=0;for(;r<n&&e[r]===t[r];)r+=1;return r},td=e=>({branchId:e,rows:[],rowIds:[]}),nd=e=>({...td(e),enteredMidFold:!0}),rd=e=>e.activeBranchId!==void 0&&e.branches!==void 0&&e.rowsByBranch!==void 0,id=(e,t)=>{if(e.kind===`divider`)return t;if(e.message.role!==`assistant`)return e.message.metadata?.rowId??t;let n=Number(e.message.id);return Number.isInteger(n)&&n>=0?n:t},ad=(e,t,n)=>_d([{...e,branchId:t,rowIds:e.rows.map(e=>id(e,n))}],[],t);function od(e){if(`branchId`in e&&`rowIds`in e){let{branchId:t,rowIds:n,...r}=e;return r}let{activeBranchId:t,branches:n,rowsByBranch:r,retainedWindow:i,...a}=e;return a}var sd=e=>od(e),cd=e=>e.kind===`message`?`message:${e.message.id}`:`divider:${e.divider.id}`,ld=(e,t)=>{if(e.kind===`message`){if(e.message.role!==`assistant`)return e.message.metadata?.rowId??t;let n=Number(e.message.id);if(Number.isInteger(n)&&n>=0)return n}return t},ud=new WeakMap,dd=(e,t,n)=>{let r=e.get(t);if(r===void 0){e.set(t,{id:n,count:1});return}r.count+=1,r.id=n},fd=(e,t)=>{let n=e.get(t);n!==void 0&&(--n.count,n.count===0&&e.delete(t))},pd=e=>{let t=new Map;for(let[n,r]of e.rows.entries()){let i=e.rowIds[n];i!==void 0&&dd(t,cd(r),i)}return t},md=e=>{let t=ud.get(e);return t===void 0?pd(e):(ud.delete(e),t)},hd=(e,t,n)=>{let r=md(e),i=Math.min(e.rows.length,t.length,$u(t,e.rows)??ed(e.rows,t)),a=e.rowIds.slice(0,i),o=[];for(let e of t.slice(i)){let t=cd(e),i=r.get(t)?.id??ld(e,n);a.push(i),o.push({key:t,rowId:i})}for(let t of e.rows.slice(i))fd(r,cd(t));for(let e of o)dd(r,e.key,e.rowId);return{rowIds:a,index:r}},gd=e=>{let{segments:t,branches:n,activeBranchId:r}=e,i=En(n,r);if(i.length===1)return t.find(e=>e.branchId===r)?.rows??[];let a=[];for(let[e,r]of i.entries()){let o=t.find(e=>e.branchId===r);if(o===void 0)continue;let s=i[e+1],c=s===void 0?void 0:Dn(n,s)?.forkedAfterMessageId;for(let[e,t]of o.rows.entries()){let n=o.rowIds[e];(c===void 0||n!==void 0&&n<=c)&&a.push(t)}}return a},_d=(e,t,n,r)=>{let i=gd({segments:e,branches:t,activeBranchId:n}),a=r===void 0?i:r(i);return{...sd(e.find(e=>e.branchId===n)??td(n)),rows:a,activeBranchId:n,branches:t,rowsByBranch:e,...r===void 0?{}:{retainedWindow:!0}}},vd=e=>{let t=Reflect.get(e,`messageId`);return typeof t==`number`?t:void 0},yd=(e,t)=>{let n=String(t);for(let r of e.rowsByBranch)if(r.draft?.id===n||r.rows.some((e,i)=>e.kind===`message`&&e.message.id===n||r.rowIds[i]===t))return r.branchId},bd=(e,t)=>{let n=t.payload;if(V(n,`message.created`)||V(n,`message.started`))return n.branchId??0;let r=vd(n);return r===void 0?e.activeBranchId:yd(e,r)??e.activeBranchId},xd=(e,t)=>{let n=0;for(;n<e.rowIds.length&&e.rowIds[n]<=t;)n+=1;return n===e.rows.length&&e.draft===void 0?e:{...e,rows:e.rows.slice(0,n),rowIds:e.rowIds.slice(0,n),draft:void 0}},Sd=(e,t)=>{let n=t.payload;if(!V(n,`branch.created`))return td(e.activeBranchId);let r=e.rowsByBranch.find(e=>e.branchId===n.branchId);if(r!==void 0)return r;let i={type:`branch`,id:`branch-${n.branchId}`,branchId:n.branchId,parentBranchId:n.parentBranchId,forkedAfterClientMessageId:n.forkedAfterClientMessageId,reason:n.reason,author:n.author};return{branchId:n.branchId,rows:[{kind:`divider`,divider:i}],rowIds:[t.id]}},Cd=(e,t)=>e.includes(t)?e:[...e.filter(e=>e.branchId!==t.branchId),t],wd=e=>(V(e.payload,`message.created`)||V(e.payload,`message.started`))&&e.payload.branchId!==void 0,Td=e=>{let t=e.payload;return V(t,`branch.created`)||V(t,`branch.switched`)||wd(e)},Ed=e=>{let t=(t,n)=>{if(V(n.payload,`history.truncated`))return xd(t,n.payload.afterRowId);let r=sd(t),i=e(r,n);if(i===r)return t;let{rowIds:a,index:o}=hd(t,i.rows,n.id),s={...i,branchId:t.branchId,rowIds:a};return ud.set(s,o),s},n=(e,n)=>{let r=An.reduce({activeBranchId:e.activeBranchId,branches:e.branches},n);if(V(n.payload,`branch.created`)){let t=Sd(e,n);return _d(Cd(e.rowsByBranch,t),r.branches,r.activeBranchId)}if(V(n.payload,`branch.switched`))return _d(e.rowsByBranch.some(e=>e.branchId===r.activeBranchId)?e.rowsByBranch:[...e.rowsByBranch,nd(r.activeBranchId)],r.branches,r.activeBranchId);let i=bd(e,n),a=e.rowsByBranch.find(e=>e.branchId===i)??nd(i),o=t(a,n),s=Cd(e.rowsByBranch,o),c=wd(n)?i:r.activeBranchId;return s===e.rowsByBranch&&c===e.activeBranchId?e:_d(s,r.branches,c)};return(t,r)=>{if(rd(t))return n(t,r);if(Td(r)){let e=r.payload,i=V(e,`message.created`)||V(e,`message.started`)?e.branchId??0:0,a=i===0?t:{...t,enteredMidFold:!0};return n(ad(a,i,r.id),r)}let i=e(t,r);return i===t?t:ad(i,0,r.id)}},Dd=e=>e===void 0||e===!0,Od=e=>{if(Array.isArray(e))return e.map(Od);if(!B(e))return e;let t={};for(let n of Object.keys(e).sort()){let r=Od(e[n]);r!==void 0&&(t[n]=r)}return t},kd=e=>JSON.stringify(Od(e)),Ad=(e,t,n)=>kd(od(e))===kd({...sd(t),rows:n}),jd=(e,t)=>{let n=t=>{if(!B(t))return!1;let n=t.branchId,r=t.rowIds;
7return e(t)&&typeof n==`number`&&Number.isInteger(n)&&n>=0&&Array.isArray(r)&&r.length===t.rows.length&&r.every(e=>typeof e==`number`&&Number.isInteger(e)&&e>=0)};return r=>{if(!B(r))return!1;let i=r.activeBranchId,a=r.branches,o=r.rowsByBranch,s=r.retainedWindow;if(!e(r))return!1;if(i===void 0&&a===void 0&&o===void 0)return s===void 0;if(typeof i!=`number`||!Array.isArray(a)||!An.validate({activeBranchId:i,branches:a})||!Array.isArray(o)||!o.every(n)||!Dd(s))return!1;let c=o.map(e=>e.branchId),l=o.find(e=>e.branchId===i);if(new Set(c).size!==c.length||l===void 0)return!1;let u=gd({segments:o,branches:a,activeBranchId:i});return Ad(r,l,s===!0?t(u):u)}},Md=e=>V(e,`turn.completed`)||V(e,`turn.failed`)||V(e,`turn.cancelled`),Nd=e=>V(e,`turn.failed`)&&(e.reason===`session-restart`||e.reason===void 0&&e.error===`Session restarted mid-turn.`),Pd=(e,t)=>{let n=t.payload;if(Md(n))return e.idleSince===void 0?{...e,idleSince:t.at}:e;if(!V(n,`turn.started`))return e;let{idleSince:r,...i}=e;return r===void 0?e:{...i,pausedMs:(e.pausedMs??0)+Math.max(0,t.at-r)}},Fd=e=>{let t=e.pausedMs??0;if(e.idleSince===void 0&&e.windowPausedMs===t)return e;let{idleSince:n,...r}=e;return{...r,windowPausedMs:t}},Id=(e,t)=>e.length===t.length&&e.every((e,n)=>e===t[n]),Ld=(e,t,n)=>{if(e.length!==t.length)return!1;for(let r=n;r<e.length;r+=1)if(e[r]!==t[r])return!1;return!0},Rd=e=>{let t=0;for(let n of e)n.kind===`message`&&(t+=1);if(t<=50)return e;let n=t-50;for(let t=0;t<e.length;t+=1)if(e[t]?.kind===`message`&&(--n,n===0))return e.slice(t+1);return e},Q=(e,t,n)=>Ld(t,e.rows,n)?e:(Qu(t,e.rows,n),{...e,rows:t});function zd(e){let t=Rd(e.rows);return t===e.rows?e:{...e,rows:t}}var Bd=(e,t)=>{for(let[n,r]of e.entries())if(r.kind===`message`&&r.message.id===t&&r.message.role===`assistant`)return{index:n,message:r.message}},Vd=(e,t)=>{if(e.role===`assistant`){let n=e.parts.some(e=>Yu(e)!==null)?e.parts.map(e=>Xu(e,t)):e.parts;return e.metadata?.settledAt!==void 0&&e.metadata.rowId===t.id&&n===e.parts?e:{...e,parts:n,metadata:{...e.metadata,settledAt:e.metadata?.settledAt??t.at,rowId:t.id}}}let n=e.metadata;return n?.createdAt!==void 0&&n.rowId===t.id?e:{...e,metadata:{...n,createdAt:n?.createdAt??t.at,rowId:t.id}}},Hd=(e,t,n)=>e.rows.some(e=>e.kind===`message`&&e.message.id===t&&e.message.metadata?.rowId===n),Ud=(e,t)=>{let n=e.rows.findIndex(e=>e.kind===`message`&&e.message.id===t.id);if(n<0)return Q(e,[...e.rows,{kind:`message`,message:t}],e.rows.length);let r=e.rows[n];if(r?.kind!==`message`||r.message===t)return e;let i=e.rows.slice();return i[n]={kind:`message`,message:t},Q(e,i,n)},Wd=(e,t)=>{let n=Bd(e.rows,t)?.message??{id:t,role:`assistant`,parts:[]};return e.draft===n?e:{...e,draft:n}},Gd=(e,t)=>{if(e.type!==`part.created`)return e;let n=Xu(e.part,t);return n===e.part?e:{...e,part:n}},Kd=(e,t)=>{let n=t.payload;if(!ql(n))return e;let r=Jl(n),i=r===void 0?e.draft?.id:String(r);if(i===void 0)return e;let a=e.draft?.id===i?e.draft:void 0,o=a===void 0?Bd(e.rows,i):void 0,s=n.type===`text.started`||n.type===`text.ended`||n.type===`reasoning.started`||n.type===`reasoning.ended`||n.type===`tool.input_started`||n.type===`tool.started`||n.type===`tool.failed`||n.type===`part.created`;if(a===void 0&&o===void 0&&!s)return e;let c=a??o?.message??{id:i,role:`assistant`,parts:[]},l=Tu(c.parts,{payload:Gd(n,t),at:t.at});if(l===c.parts)return e;let u={...c,parts:[...l]};if(a===void 0&&o!==void 0&&!s){let t=e.rows.slice();return t[o.index]={kind:`message`,message:u},Q(e,t,o.index)}if(!(Bd(e.rows,i)!==void 0||Au(l)))return{...e,draft:u};let d=Bd(e.rows,i);if(d===void 0)return Q({...e,draft:u},[...e.rows,{kind:`message`,message:u}],e.rows.length);let f=e.rows.slice();return f[d.index]={kind:`message`,message:u},Q({...e,draft:u},f,d.index)},qd=(e,t)=>{if(e.metadata?.settledAt===void 0)return!1;let{settledAt:n,...r}=e.metadata,{settledAt:i,...a}=t.metadata??{};return JSON.stringify({...e,metadata:r})===JSON.stringify({...t,metadata:a})},Jd=(e,t,n)=>{let r=e.metadata?.reactions??t?.metadata?.reactions,i=Mu(e.metadata?.phoneDelivery)??Mu(t?.metadata?.phoneDelivery);return{...n??e.metadata,...r===void 0?{}:{reactions:r},...i===void 0?{}
7:{phoneDelivery:i}}},Yd=(e,t)=>{let{messageId:n,at:r,metadata:i,rowId:a}=t,o=e.draft?.id===n?e.draft:void 0,s=Bd(e.rows,n),c=o??s?.message;if(c===void 0)return e;let l=ku(c.parts);if(!Au(l)){let t=s===void 0?e.rows:e.rows.filter((e,t)=>t!==s.index);return Q({...e,draft:void 0},t,s?.index??e.rows.length)}let u=(e.rowPausedId===n?e.rowPausedMs:e.windowPausedMs)??0,d=Math.max(0,(e.pausedMs??0)-u),f={...c,parts:[...l],metadata:{...Jd(c,s?.message,i),...F({rowId:a}),settledAt:r,...d>0?{pausedMs:d}:{}}};if(s===void 0)return Q({...e,draft:void 0},[...e.rows,{kind:`message`,message:f}],e.rows.length);if(o===void 0&&qd(s.message,f))return e;let p=e.rows.slice();return p[s.index]={kind:`message`,message:f},Q({...e,draft:void 0},p,s.index)},Xd=(e,t,n)=>{let r=e.draft;return r===void 0?e:Yd(e,{messageId:r.id,at:t,metadata:{...r.metadata,outcome:n}})},Zd=(e,t,n)=>{let r=Fu(e.metadata?.reactions),i=Ru(r,{emoji:t.emoji,active:t.active,reactor:t.reactor,phoneChannelId:t.phoneChannelId,phoneMessageId:t.phoneMessageId,at:n});if(i===r)return e;let{reactions:a,...o}=e.metadata??{};return{...e,metadata:{...o,...i.length===0?{}:{reactions:i}}}},Qd=(e,t,n)=>{let r=e.rows.findIndex(e=>e.kind===`message`&&e.message.id===t.clientMessageId),i=e.rows[r],a=e.draft?.id===t.clientMessageId?Zd(e.draft,t,n):e.draft,o=a===e.draft?e:{...e,draft:a};if(r<0||i?.kind!==`message`)return o;let s=Zd(i.message,t,n);if(s===i.message)return o;let c=o.rows.slice();return c[r]={kind:`message`,message:s},Q(o,c,r)},$d=(e,t)=>{let n=e.rows.findIndex(e=>e.kind===`message`&&e.message.id===t.clientMessageId),r=e.rows[n],i=e.draft?.id===t.clientMessageId?ef(e.draft,t):e.draft,a=i===e.draft?e:{...e,draft:i};if(n<0||r?.kind!==`message`)return a;let o=ef(r.message,t);if(o===r.message)return a;let s=a.rows.slice();return s[n]={kind:`message`,message:o},Q(a,s,n)},ef=(e,t)=>{let n=e.metadata??{};return Nu(Mu(n.phoneDelivery),t.phoneDelivery)?{...e,metadata:{...n,phoneDelivery:t.phoneDelivery}}:e},tf=(e,t)=>{let n=e.rows.findIndex(e=>e.kind===`message`&&e.message.id===t.id),r=e.rows[n];if(n<0||r?.kind!==`message`)return e;let i=nf(r.message,t.metadata??r.message.metadata);if(r.message.parts===t.parts&&rf(r.message.metadata,i))return e;let a=e.rows.slice();return a[n]={kind:`message`,message:{...r.message,parts:t.parts,metadata:i}},Q(e,a,n)},nf=(e,t)=>{let n=e.metadata;return e.role===`assistant`||n?.rowId===void 0||t?.rowId===n.rowId&&t.createdAt!==void 0?t:{...t,createdAt:t?.createdAt??n.createdAt,rowId:n.rowId}},rf=(e,t)=>{if(e===t)return!0;if(e===void 0||t===void 0)return!1;let n=Object.keys(e);return n.length===Object.keys(t).length&&n.every(n=>Object.hasOwn(t,n)&&Reflect.get(e,n)===Reflect.get(t,n))},af=(e,t)=>{if(t===null)return e.rows.length===0&&e.draft===void 0?e:{...e,rows:[],draft:void 0};let n=e.rows.findIndex(e=>e.kind===`message`&&e.message.id===t);return n<0?e.rows.length===0&&e.draft===void 0?e:{...e,rows:[],draft:void 0}:n===e.rows.length-1&&e.draft===void 0?e:{...e,rows:e.rows.slice(0,n+1),draft:void 0}},of=(e,t)=>JSON.stringify(e)===JSON.stringify(t),sf=(e,t,n)=>{let r=e.rows.findIndex(n);if(r<0)return Q(e,[...e.rows,{kind:`divider`,divider:t}],e.rows.length);let i=e.rows[r];if(i?.kind===`divider`&&of(i.divider,t))return e;let a=e.rows.slice();return a[r]={kind:`divider`,divider:t},Q(e,a,r)},cf=(e,t)=>e.kind===`divider`&&e.divider.type===`compaction`&&e.divider.status===`started`&&e.divider.trigger===t,lf=(e,t)=>e.findLastIndex(e=>cf(e,t)),uf=(e,t,n)=>{let r=lf(e.rows,n),i=e.rows.at(-1);return r===e.rows.length-1&&i?.kind===`divider`&&of(i.divider,t)?e:Q(e,[...r<0?e.rows:e.rows.filter((e,t)=>t!==r),{kind:`divider`,divider:t}],r<0?e.rows.length:r)},df=(e,t)=>{let n=lf(e.rows,t);return n<0?e:{...e,rows:e.rows.filter((e,t)=>t!==n)}},ff=(e,t,n)=>{let r=e.rows.findIndex(e=>e.kind===`divider`&&e.divider.type===`compaction`&&e.divider.id===t.id),i=r>=0?r:lf(e.rows,n);if(i<0)return Q(e,[...e.rows,{kind:`divider`,divider:t}],e.rows.length);let a=e.rows[i];if(a?.kind===`divider`&&of(a.divider,t))return e;let o=e.rows.slice();return o[i]={kind:`divider`,divider:t},Q(e,o,i)},pf=(e,t)=>
7{let n=t.payload;return V(n,`compaction.started`)?n.mode===`background`?e:uf(e,{type:`compaction`,id:`compaction-pending-${t.id}`,status:`started`,trigger:n.trigger,startedAt:t.at},n.trigger):V(n,`compaction.failed`)?n.mode===`background`?e:df(e,n.trigger):V(n,`compaction.completed`)?n.mode===`background`?e:ff(e,n.compaction===void 0?{type:`compaction`,id:`compaction-${n.messageId}`,status:`completed`,trigger:n.trigger,messageId:n.messageId}:{type:`compaction`,id:`compaction-${n.messageId}`,status:`completed`,trigger:n.trigger,messageId:n.messageId,compaction:n.compaction},n.trigger):e};function mf(e){return B(e)&&e.type===`subscription-switch`&&typeof e.id==`string`&&typeof e.connectionId==`string`&&typeof e.ownerUserId==`string`&&typeof e.ownedBySpeaker==`boolean`&&(e.provider===`codex`||e.provider===`supergrok`)&&(e.reason===`initial`||e.reason===`usage-limit`||e.reason===`expired`||e.reason===`unpooled`||e.reason===`manual`)&&typeof e.revision==`number`&&(e.ownerDisplayName===void 0||typeof e.ownerDisplayName==`string`)&&(e.previousConnectionId===void 0||typeof e.previousConnectionId==`string`)}var hf=e=>typeof e.branchId==`number`&&typeof e.parentBranchId==`number`&&(e.forkedAfterClientMessageId===null||typeof e.forkedAfterClientMessageId==`string`)&&(e.reason===`rewind`||e.reason===`edit`||e.reason===`regenerate`)&&B(e.author)&&typeof e.author.organizationId==`string`&&typeof e.author.userId==`string`&&(e.author.teamId===void 0||typeof e.author.teamId==`string`),gf=e=>e===`no_progress`||e===`loop_detected`,_f=e=>typeof e.continuesTurnId==`number`&&Number.isSafeInteger(e.continuesTurnId)&&e.continuesTurnId>0&&typeof e.turnId==`number`&&Number.isSafeInteger(e.turnId)&&e.turnId>0&&typeof e.startedAt==`number`&&Number.isFinite(e.startedAt)&&typeof e.lostWork==`boolean`,vf=e=>e.status===`started`&&typeof e.trigger==`string`&&typeof e.startedAt==`number`||e.status===`completed`&&typeof e.trigger==`string`&&typeof e.messageId==`string`,yf=e=>typeof e.failedAt==`number`&&Number.isFinite(e.failedAt)&&D(Sc)(e.failure)&&(e.traceMessageId===void 0||typeof e.traceMessageId==`string`),bf=e=>!B(e)||typeof e.id!=`string`?!1:e.type===`turn-failure`?yf(e):e.type===`subscription-switch`?mf(e):e.type===`branch`?hf(e):e.type===`model-switch`?typeof e.modelId==`string`&&(e.previousModelId===void 0||typeof e.previousModelId==`string`):e.type===`interruption`||e.type===`safety-stop`?!0:e.type===`restart-continuation`?_f(e):e.type===`stall-stop`?gf(e.reason):e.type===`compaction`?vf(e):e.type===`goal`&&xf(e),xf=e=>typeof e.goalId==`number`?e.kind===`set`?e.tokenBudget===null||typeof e.tokenBudget==`number`:e.kind===`status`?typeof e.status==`string`&&typeof e.cause==`string`&&typeof e.activeMs==`number`:e.kind===`cleared`:!1,Sf=e=>B(e)&&(e.kind===`message`&&B(e.message)&&typeof e.message.id==`string`&&Array.isArray(e.message.parts)||e.kind===`divider`&&bf(e.divider)),Cf=e=>e===void 0||typeof e==`number`&&Number.isFinite(e),wf=e=>e===void 0||typeof e==`number`&&Number.isSafeInteger(e)&&e>0,Tf=e=>B(e)&&Array.isArray(e.rows)&&e.rows.every(Sf)&&(e.lastModelId===void 0||typeof e.lastModelId==`string`)&&Cf(e.idleSince)&&Cf(e.pausedMs)&&Cf(e.windowPausedMs)&&Cf(e.rowPausedMs)&&wf(e.latestTurnEventId)&&wf(e.activeTurnId)&&(e.crashedTurnId===null||wf(e.crashedTurnId))&&(e.enteredMidFold===void 0||e.enteredMidFold===!0)&&(e.rowPausedId===void 0||typeof e.rowPausedId==`string`)&&(e.draft===void 0||B(e.draft)&&typeof e.draft.id==`string`&&Array.isArray(e.draft.parts)),Ef=(e,t)=>{let n=t.payload;if(V(n,`message.created`))return n.message.metadata?.compaction!==void 0||Hd(e,n.message.id,t.id)?e:Ud(Bu(n.message)?Fd(e):e,Vd(n.message,t));if(V(n,`message.started`))return Wd(e,String(t.id));if(V(n,`message.completed`))return Yd(e,{messageId:String(n.messageId),at:t.at,metadata:n.metadata,rowId:n.messageId});if(V(n,`message.edited`))return tf(e,n.message);if(V(n,`message.reaction_set`))return Qd(e,n,t.at);if(V(n,`message.phone_delivery_status`))return $d(e,n);if(V(n,`history.truncated`))return af(e,n.afterMessageId)},Df=(e,t)=>{let n=t.payload;if(V(n,`goal.set`)){let r={type:`goal`,id:`goal-set-${t.id}`,kind:`set`,goalId:n.goalId,tokenBudget:n.tokenBudget};return Q(e,[...e.rows,{kind:`divider`,divider:r}],e.rows.length)}if(V(n,`goal.status`)){if(n.cause===`plan`||n.cause===`plan_released`||n.cause===`wrap_up_armed`)return e;let r={type:`goal`,id:`goal-status-${t.id}`,kind:`status`,goalId:n.goalId,status:n.status,cause:n.cause,activeMs:n.activeMs};return Q(e,[...e.rows,{kind:`divider`,divider:r}],e.rows.length)}if(V(n,`goal.cleared`)){let r={type:`goal`,id:`goal-cleared-${t.id}`,kind:`cleared`,goalId:n.goalId};return Q(e,[...e.rows,{kind:`divider`,divider:r}],e.rows.length)}};function Of(e,t){let n=`subscription-switch-${t.id}`;if(t.id<=0||t.payload.reason===`initial`&&t.payload.ownedBySpeaker||e.rows.some(e=>e.kind===`divider`&&e.divider.id===n))return e;let r={...t.payload,type:`subscription-switch`,id:n};return Q(e,[...e.rows,{kind:`divider`,divider:r}],e.rows.length)}var kf=(e,t)=>
7{let n=t.payload;if(V(n,`compaction.started`)||V(n,`compaction.completed`)||V(n,`compaction.failed`))return pf(e,t);let r=Df(e,t);if(r!==void 0)return r;if(V(n,`subscription.switched`))return Of(e,{id:t.id,payload:n});if(!V(n,`model.changed`))return;if(e.lastModelId===n.config.modelId)return e;if(e.lastModelId===void 0)return{...e,lastModelId:n.config.modelId};let i={...e,lastModelId:n.config.modelId},a=Af(e),o=a?.previousModelId??e.lastModelId;if(a!==void 0&&a.previousModelId===n.config.modelId)return Q(i,e.rows.filter(e=>e.kind!==`divider`||e.divider!==a),0);let s={type:`model-switch`,id:a?.id??`model-switch-${t.id}`,modelId:n.config.modelId,...o===void 0?{}:{previousModelId:o}};return sf(i,s,e=>e.kind===`divider`&&e.divider.type===`model-switch`&&e.divider.id===s.id)},Af=e=>{for(let t=e.rows.length-1;t>=0;--t){let n=e.rows[t];if(n?.kind!==`divider`)return;if(n.divider.type===`model-switch`)return n.divider;if(n.divider.type!==`compaction`||n.divider.status!==`started`)return}},jf=(e,t)=>{for(let n=e.rows.length-1;n>=0;--n){let r=e.rows[n];if(r.kind!==`message`)continue;let i=r.message;if(e.activeTurnId===void 0&&i.role===`user`)return;if(i.role!==`assistant`)continue;let a=i.metadata?.rowId??Number(i.id);return i.parts.some(n=>{let r=Yu(n);return r?.message===t&&(e.activeTurnId===void 0||(r.writtenAtEventId??a)>e.activeTurnId)})?i.id:void 0}},Mf=(e,t)=>{let n=t.payload;if(!Md(n))return;let r=`failed`;n.type===`turn.completed`?r=`completed`:n.type===`turn.cancelled`&&(r=`cancelled`);let i=Xd(e,t.at,r);if(V(n,`turn.failed`)&&!Nd(n)){let e=jf(i,n.error),r=`turn-failure-${t.id}`;return sf(i,{type:`turn-failure`,id:r,failedAt:t.at,failure:n,...e===void 0?{}:{traceMessageId:e}},e=>e.kind===`divider`&&e.divider.id===r)}if(V(n,`turn.completed`)){let e=If(n.stopReason);if(e===void 0)return i;let r=`stall-stop-${t.id}`;return sf(i,{type:`stall-stop`,id:r,reason:e},e=>e.kind===`divider`&&e.divider.type===`stall-stop`&&e.divider.id===r)}if(n.type!==`turn.cancelled`||n.reason!==void 0)return i;let a=`interruption-${t.id}`;return sf(i,{type:`interruption`,id:a},e=>e.kind===`divider`&&e.divider.type===`interruption`&&e.divider.id===a)},Nf=(e,t)=>{let n=t.payload;if(!(V(n,`turn.started`)||Md(n))||e.latestTurnEventId!==void 0&&t.id<=e.latestTurnEventId)return e;if(V(n,`turn.started`)){let{continuesTurnId:r}=n,i=r!==void 0&&Pf(e,r,t.id),a={...e,latestTurnEventId:t.id,activeTurnId:t.id,crashedTurnId:void 0};if(!i)return a;let o={...a,windowPausedMs:a.pausedMs??0},s={type:`restart-continuation`,id:`restart-continuation-${t.id}`,continuesTurnId:r,turnId:t.id,startedAt:t.at,lostWork:n.lostWork===!0};return sf(o,s,e=>e.kind===`divider`&&e.divider.type===`restart-continuation`&&e.divider.id===s.id)}return{...e,latestTurnEventId:t.id,activeTurnId:void 0,crashedTurnId:Nd(n)?e.activeTurnId??null:void 0}},Pf=(e,t,n)=>t===e.crashedTurnId||(e.crashedTurnId===null||e.latestTurnEventId===void 0&&e.enteredMidFold!==!0&&!Ff(e))&&t<n,Ff=e=>{let t=e.rows[0];return t?.kind===`divider`&&t.divider.type===`branch`},If=e=>gf(e)?e:void 0,Lf=(e,t)=>{let n=t.payload;if(!ql(n)||n.type!==`step.ended`||n.finishReason!==`content-filter`)return e;let r=`safety-stop-${t.id}`;return sf(e,{type:`safety-stop`,id:r},e=>e.kind===`divider`&&e.divider.type===`safety-stop`&&e.divider.id===r)},Rf=(e,t)=>{let n=Ef(e,t);if(n!==void 0)return n;if(ql(t.payload))return Lf(Kd(e,t),t);let r=kf(e,t);if(r!==void 0)return r;let i=Pd(e,t);return Nf(Mf(i,t)??i,t)},zf=(e,t)=>{let n=Rf(e,t),r=n.draft?.id;return r===void 0||r===e.draft?.id||r===n.rowPausedId?n:{...n,rowPausedId:r,rowPausedMs:n.windowPausedMs??0}};function Bf(e){if(!rd(e))return zd(e);if(e.branches.length===0&&e.activeBranchId===0&&e.rowsByBranch.every(e=>e.branchId===0)){let t=e.rowsByBranch.find(e=>e.branchId===0);if(t!==void 0){let n=zd(sd(t));if(n.rows===t.rows)return e;let r=n.rows[0],i=r===void 0?t.rows.length:t.rows.indexOf(r);return _d([{...n,branchId:0,rowIds:t.rowIds.slice(i)}],e.branches,0,Rd)}}return Id(Rd(gd({segments:e.rowsByBranch,branches:e.branches,activeBranchId:e.activeBranchId})),e.rows)?e:_d(e.rowsByBranch,e.branches,e.activeBranchId,Rd)}var Vf=Ed(zf),Hf=jd(Tf,Rd);function Uf(e){return e.reduce((e,t)=>
7Vf(e,t),Wf.initial())}var Wf={name:`ui-events`,version:21,initial:()=>({rows:[]}),reduce:Vf,validate:Hf},Gf=0,$=()=>(--Gf,Gf);function Kf(e){return{id:$(),threadId:0,at:Date.now(),transient:!0,previewKind:`stopped-interruption`,stagedAfterEventId:e?.stagedAfterEventId??null,payload:{type:`turn.cancelled`}}}function qf(e){return e.synthetic===!0&&e.transient===!0&&e.payload.type===`turn.cancelled`&&`previewKind`in e&&e.previewKind===`stopped-interruption`&&`stagedAfterEventId`in e&&(e.stagedAfterEventId===null||typeof e.stagedAfterEventId==`number`&&Number.isSafeInteger(e.stagedAfterEventId))}var Jf=new Set([` `,` `,` 8`,`\r`]),Yf=new Set([`"`,`\\`,`/`,`b`,`f`,`n`,`r`,`t`]),Xf={t:`true`,f:`false`,n:`null`},Zf=/^[0-9]$/,Qf=/^[1-9]$/,$f=/^[0-9a-fA-F]$/,ep=/^[eE]$/,tp=/^[+-]$/,np=/^\.$/,rp={sign:[[/^0$/,`zero`],[Qf,`int`]],zero:[[np,`dot`],[ep,`exp`]],int:[[Zf,`int`],[np,`dot`],[ep,`exp`]],dot:[[Zf,`frac`]],frac:[[Zf,`frac`],[ep,`exp`]],exp:[[tp,`expSign`],[Zf,`expDigits`]],expSign:[[Zf,`expDigits`]],expDigits:[[Zf,`expDigits`]]},ip={"-":`sign`,0:`zero`},ap=new Set([`zero`,`int`,`frac`,`expDigits`]),op=class extends Error{};function sp(e){e.token=null,e.expect=e.stack.length===0?`end`:`afterValue`}function cp(e,t,n){if(t===`{`||t===`[`)e.stack.push(t),e.expect=t===`{`?`firstKey`:`firstValue`;else if(t===`"`)e.token={kind:`string`,startAt:n,isKey:!1,escapeAt:null,hexLeft:0};else if(t===`-`||Zf.test(t))e.token={kind:`number`,startAt:n,state:ip[t]??`int`};else if(t in Xf)e.token={kind:`literal`,startAt:n,word:Xf[t],matched:1};else throw new op}function lp(e,t){let n=e.stack.at(-1)===`{`?`}`:`]`;if(e.stack.length===0||t!==n)throw new op;e.stack.pop(),sp(e)}function up(e,t,n){if(t===`}`&&e.expect===`firstKey`)lp(e,t);else if(t===`"`)e.token={kind:`string`,startAt:n,isKey:!0,escapeAt:null,hexLeft:0};else throw new op}function dp(e,t){t===`,`?e.expect=e.stack.at(-1)===`{`?`key`:`value`:lp(e,t)}function fp(e,t,n){if(!Jf.has(t))switch(e.expect){case`firstValue`:t===`]`?lp(e,t):cp(e,t,n);break;case`value`:cp(e,t,n);break;case`firstKey`:case`key`:up(e,t,n);break;case`colon`:if(t!==`:`)throw new op;e.expect=`value`;break;case`afterValue`:dp(e,t);break;default:throw new op}}function pp(e,t){if(e.hexLeft>0){if(!$f.test(t))throw new op;--e.hexLeft,e.hexLeft===0&&(e.escapeAt=null)}else if(t===`u`)e.hexLeft=4;else if(Yf.has(t))e.escapeAt=null;else throw new op}function mp(e,t){t.isKey?(e.token=null,e.keyStartAt=t.startAt,e.expect=`colon`):sp(e)}function hp(e,t,n,r){if(t.escapeAt!==null)pp(t,n);else if(n===`\\`)t.escapeAt=r;else if(n===`"`)mp(e,t);else if(n.charCodeAt(0)<32)throw new op}function gp(e,t,n,r){let i=rp[t.state].find(([e])=>e.test(n));if(i!==void 0){t.state=i[1];return}if(!ap.has(t.state))throw new op;sp(e),fp(e,n,r)}function _p(e,t,n){if(n!==t.word[t.matched])throw new op;t.matched+=1,t.matched===t.word.length&&sp(e)}function vp(e){let t={stack:[],expect:`value`,token:null,keyStartAt:0};try{for(let n=0;n<e.length;n+=1){let r=e[n],i=t.token;i===null?fp(t,r,n):i.kind===`string`?hp(t,i,r,n):i.kind===`number`?gp(t,i,r,n):_p(t,i,r)}}catch(e){if(e instanceof op)return null;throw e}return t}function yp(e,t){let n=t.token;return n?.kind===`string`&&!n.isKey?{at:n.escapeAt??e.length,isInString:!0}:n===null?{at:t.expect===`colon`?t.keyStartAt:e.length,isInString:!1}:{at:n.startAt,isInString:!1}}function bp(e,t){let n=yp(e,t),r=e.slice(0,n.at);n.isInString?r+=`"`:(r=r.trimEnd(),r.endsWith(`,`)?r=r.slice(0,-1):r.endsWith(`:`)&&(r+=`null`));for(let e=t.stack.length-1;e>=0;--e)r+=t.stack[e]===`{`?`}`:`]`;return r}function xp(e){let t=vp(e);if(t===null)return;let n=t.expect===`end`&&t.token===null?e:bp(e,t);if(n.trim()!==``)try{return JSON.parse(n)}catch{return}}function Sp(e){let{stopTerminal:t,stopLifecycle:n,stopPreview:r,...i}=e;return i}function Cp(e){return Sp(e)}function wp(e,t){let n=Cp(e),r=Wf.reduce(n,t);return r===n?e:r}function Tp(e,t){let n=t.stopLifecycle;if(e.stopTerminal===t.stopTerminal&&e.stopLifecycle===n&&e.stopPreview===t.stopPreview)return e;let{stopTerminal:r,stopLifecycle:i,stopPreview:a,...o}=e;return{...o,...n===void 0?{}:{stopLifecycle:n},...t.stopTerminal===void 0?{}:{stopTerminal:t.stopTerminal},...t.stopPreview===void 0?{}:{stopPreview:t.stopPreview}}}function Ep(e){if(`synthetic`in e&&e.synthetic===!0)return;let t=e.payload.type;
8if(t===`turn.cancelled`||t===`turn.completed`||t===`turn.failed`)return{eventId:e.id,type:t}}function Dp(e){if(`synthetic`in e&&e.synthetic===!0)return;if(Ep(e)!==void 0)return{eventId:e.id,state:`idle`};let t=e.payload;if(t.type===`turn.started`||t.type===`session.status`&&t.status===`running`)return{eventId:e.id,state:`running`};if(t.type===`session.status`&&t.status===`idle`)return{eventId:e.id,state:`idle`}}function Op(e){return e===null||B(e)&&typeof e.eventId==`number`&&Number.isSafeInteger(e.eventId)&&(e.state===`running`||e.state===`idle`)}function kp(e,t){let n=wp(e,t),r=Ep(t),i=r!==void 0&&(e.stopTerminal===void 0||r.eventId>e.stopTerminal.eventId)?r:e.stopTerminal,a=Dp(t),o=e.stopLifecycle;return Tp(n,{stopTerminal:i,stopLifecycle:(a!==void 0&&(o==null||a.eventId>o.eventId)?a:o)??null,stopPreview:e.stopPreview})}function Ap(e){if(!B(e))return!1;let t=Sp(e);if(!Wf.validate(t)||!(t.rows.length===0&&Object.keys(e).every(e=>e===`rows`)||`stopLifecycle`in e&&Op(e.stopLifecycle))||`stopPreview`in e&&e.stopPreview!==void 0)return!1;if(!(`stopTerminal`in e)||e.stopTerminal===void 0)return!0;let n=e.stopTerminal;return B(n)&&typeof n.eventId==`number`&&Number.isSafeInteger(n.eventId)&&(n.type===`turn.cancelled`||n.type===`turn.completed`||n.type===`turn.failed`)}function jp(e){let t=Cp(e),n=Bf(t);return n===t&&e.stopPreview===void 0?e:Tp(n,{stopTerminal:e.stopTerminal,stopLifecycle:e.stopLifecycle})}var Mp={...Wf,version:Wf.version+1,reduce:kp,validate:Ap};function Np(e,t){for(let[n,r]of e.entries())if(r.kind===`message`&&r.message.id===t.id)return{index:n,message:r.message}}function Pp(e,t,n){let r=Np(e,t);if(r===void 0||r.message===n)return e;let i=e.slice();return i[r.index]={kind:`message`,message:n},i}function Fp(e,t){let n=e.draft;if(n===void 0||n===t)return e;let r=Pp(e.rows,n,t),i=e.activeBranchId,a=e.rowsByBranch;if(i===void 0||a===void 0)return{...e,rows:r,draft:t};let o=!1,s=a.map(e=>{if(e.branchId!==i)return e;let r=Pp(e.rows,n,t);return r===e.rows&&e.draft===t?e:(o=!0,{...e,rows:r,draft:t})});return r===e.rows&&!o?{...e,draft:t}:{...e,rows:r,rowsByBranch:s,draft:t}}function Ip(e){let t=e.draft;if(t===void 0)return e;let n=!1,r=t.parts.flatMap(e=>(e.type===`text`||e.type===`reasoning`)&&e.state===`streaming`?e.text===``?[e]:(n=!0,[{...e,text:``}]):za(e)&&e.state===`input-streaming`?(n=!0,[]):[e]);return n?Fp(e,{...t,parts:r}):e}function Lp(e,t){let n=e.draft;if(n===void 0)return e;let r=Du(n.parts,t);if(r===void 0||r===``)return e;let i=xp(r);if(i===void 0)return e;let a=Eu(n.parts,t,i);return a===n.parts?e:Fp(e,{...n,parts:[...a]})}function Rp(e){return e.parts.some(e=>za(e)&&e.state!==`output-available`&&e.state!==`output-error`&&e.state!==`output-denied`)}function zp(e){return e.draft===void 0&&(e.idleSince!==void 0||!e.rows.some(e=>e.kind===`message`&&Rp(e.message)))}function Bp(e,t){return qf(t)?t.stagedAfterEventId!==null&&(e.stopTerminal!==void 0&&e.stopTerminal.eventId>=t.stagedAfterEventId||e.stopLifecycle?.state===`idle`)||e.stopPreview===!0?e:Tp(wp(e,t),{stopTerminal:e.stopTerminal,stopLifecycle:e.stopLifecycle,stopPreview:!0}):e}function Vp(e,t){if(qf(t))return Bp(e,t);if(t.payload.type===`client.stream_opened`)return Ip(e);if(!(t.transient&&ql(t.payload)))return e;let n=Tp(wp(e,t),e);return t.payload.type===`tool.input_delta`?Lp(n,t.payload.toolCallId):n}function Hp(e){let t=e.threadScope.kind===`thread`&&e.threadScope.threadId!==0;return{name:e.name,consumesTransient:!0,threadScope:e.threadScope,isSnapshotable:e.isSnapshotable,historyAnchor:e.threadScope.kind===`thread`&&e.threadScope.threadId===0,tailBootstrap:!0,reducer:t?Ao(Mp):Mp,canonicalGate:e=>e.payload.type!==`subscription.switched`||e.synthetic!==!0,isSnapshotPaintSafe:zp,clientReduce:Vp,snapshotState:jp}}var Up=Hp({name:Wf.name,threadScope:{kind:`thread`,threadId:0}}),Wp=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,payload:{type:`queue.cancelled`,queueEntryIds:[e]}}),Gp=e=>t=>No(t.payload)&&t.payload.queueEntryIds.includes(e),Kp=[`queue.cancelled`],qp={rowExpectation:()=>null,wire:({queueEntryId:e})=>Be.make({queueEntryId:e}),ordered:!0,canBypassPreparation:!0,optimistic:{overlay:({queueEntryId:e})=>[Wp(e)],confirmedBy:({queueEntryId:e})=>Gp(e),confirmTypes:Kp,recovery:`drop`}},Jp=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,payload:{type:`goal.status`,goalId:e.goalId,status:e.status,hold:e.hold,cause:e.cause,activeMs:e.activeMs,lastResumedAt:e.status===`pursuing`?Date.now():null}}),Yp=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,payload:{type:`goal.cleared`,goalId:e}}),Xp=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,payload:{type:`goal.updated`,goalId:e.goalId,revision:e.revision+1,...e.objective===void 0?{}:{objective:e.objective},...e.budget===void 0?{}:{budget:e.budget}}}),Zp={ordered:!0,wire:()=>He.make({}),optimistic:{overlay:({goalId:e})=>[Yp(e)],confirmedBy:()=>e=>V(e.payload,`goal.cleared`),confirmTypes:[`goal.cleared`],recovery:`drop`}};function Qp(e){throw Error(`Unexpected harness event: ${JSON.stringify(e)}`)}function $p(e,t){return e.behavior===`queue`&&e.queue?.hold===!0?{lastUsedAt:t}:{status:`running`,statusDetail:null,lastUsedAt:t}}function em(e,t){switch(e._tag){case`MessagesSubmitted`:return $p(e,t);case`TextSubmitted`:return{status:`running`,statusDetail:null,lastUsedAt:t};case`ToolResultSubmitted`:case`ToolApprovalResponded`:case`Steered`:case`QueueFolded`:case`QueueReleased`:case`QuestionAnswerSubmitted`:case`DetachedInteractionSubmitted`:case`NoteActionSubmitted`:case`SecretAskOutcomeSubmitted`:return{status:`running`,statusDetail:null,lastUsedAt:t};case`GoalSubmitted`:return{status:`running`,statusDetail:null,lastUsedAt:t};case`Resumed`:return{status:`running`,answersUserAsk:!0,lastUsedAt:t};case`Regenerated`:case`Retried`:return{status:`running`,statusDetail:null,lastUsedAt:t};case`Edited`:return{lastUsedAt:t};case`GoalResumeRequested`:case`GoalEdited`:return{lastUsedAt:t};case`QueueEntryReleased`:return e.wake===!1?null:{status:`running`,statusDetail:null,lastUsedAt:t};case`Rewound`:case`BranchSwitched`:case`Stopped`:return{status:`idle`,statusDetail:null};case`Cancelled`:case`QueueCancelled`:case`QueueEdited`:case`QueueHeld`:case`QueueEntryHeld`:case`QueueMoved`:case`MessageReactionSet`:case`SubscriptionPin`:case`ModelConfigChanged`:case`ModeChanged`:case`AllowedModesChanged`:case`CompactionRequested`:case`GoalPauseRequested`:case`GoalCleared`:return null;default:return Qp(e)}}var tm={rowExpectation:({objective:e,budget:t,revision:n})=>em(Me.make({...e===void 0?{}:{objective:e},...t===void 0?{}:{budget:t},revision:n}),Date.now()),ordered:!0,wire:({objective:e,budget:t,revision:n})=>Me.make({...e===void 0?{}:{objective:e},...t===void 0?{}:{budget:t},revision:n}),optimistic:{overlay:e=>[Xp(e)],confirmedBy:e=>t=>{let n=t.payload;return V(n,`goal.updated`)?n.revision===e.revision+1&&(e.objective===void 0||n.objective===e.objective)&&(e.budget===void 0||n.budget?.tokenBudget===e.budget.tokenBudget):!1},confirmTypes:[`goal.updated`],recovery:`drop`}},nm={ordered:!0,rowExpectation:()=>({status:`running`,statusDetail:null,lastUsedAt:Date.now()}),wire:({messageId:e,parts:t})=>Ae.make({messageId:e,parts:t}),threadId:({threadId:e})=>e,optimistic:{overlay:({threadId:e})=>[{id:$(),at:Date.now(),transient:!1,threadId:e??0,payload:{type:`session.status`,status:`running`}}],confirmedBy:()=>()=>!1,confirmTypes:[`branch.created`],recovery:`drop`}},rm=(e,t)=>
8({id:$(),threadId:0,at:Date.now(),transient:!1,synthetic:!0,payload:{type:`queue.edited`,queueEntryId:e,message:t}}),im=e=>{let t=e.metadata;if(!(ft(t)&&`sentAsGoal`in t))return e;let{sentAsGoal:n,...r}=t;return{...e,metadata:r}},am=e=>JSON.stringify(e,(e,t)=>ft(t)?Object.fromEntries(Object.entries(t).sort(([e],[t])=>e<t?-1:1)):t),om=(e,t)=>n=>Po(n.payload)&&n.payload.queueEntryId===e&&am(n.payload.message.parts)===am(t.parts),sm={wire:({queueEntryId:e,message:t,releaseHold:n})=>je.make({queueEntryId:e,message:im(t),...F({releaseHold:n})}),ordered:!0,optimistic:{overlay:({queueEntryId:e,message:t})=>[rm(e,t)],confirmedBy:({queueEntryId:e,message:t})=>om(e,t),confirmTypes:[`queue.edited`],recovery:`retryable`}},cm=(e,t)=>{let n=t?.queueEntryId??$();return{id:n,threadId:0,at:Date.now(),transient:!1,payload:{type:`queue.enqueued`,queueEntryIds:[n],index:t?.index??-1,messages:[e],held:t?.held??!1,fold:t?.fold===!0}}},lm=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,payload:{type:`queue.dequeued`,queueEntryIds:[e],index:-1}}),um=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,payload:{type:`queue.folded`,queueEntryIds:[e]}}),dm=e=>t=>jo(t.payload)&&t.payload.messages.some(t=>t.id===e),fm=[`queue.enqueued`],pm={isMessageSend:!0,rowExpectation:()=>({status:`running`,statusDetail:null,lastUsedAt:Date.now()}),ordered:!0,durable:{key:({message:e})=>e.id,deferred:({finalize:e})=>e!==void 0},prepare:async e=>e.finalize?{message:await e.finalize()}:e,wire:({message:e})=>ze.make({messages:[e],behavior:`queue`}),optimistic:{overlay:({message:e})=>[cm(e)],confirmedBy:({message:e})=>dm(e.id),confirmTypes:fm,recovery:`retryable`}},mm=(e,t)=>e.filter(e=>e.events.some(e=>jo(e.payload)&&e.payload.messages.some(e=>e.id===t))).map(e=>e.clientTag),hm={isMessageSend:!0,rowExpectation:()=>({status:`running`,statusDetail:null,lastUsedAt:Date.now()}),durable:{key:({message:e})=>e.id,deferred:({finalize:e})=>e!==void 0},prepare:async e=>e.finalize?{message:await e.finalize()}:e,wire:({message:e})=>ze.make({messages:[e],behavior:`fold`}),optimistic:{overlay:({message:e})=>[cm(e,{fold:!0})],confirmedBy:({message:e})=>dm(e.id),confirmTypes:fm,recovery:`retryable`}},gm=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,synthetic:!0,payload:{type:`queue.held`,queueEntryIds:e.queueEntryIds,index:e.queueIndex,strategy:e.strategy??`block`,...F({reason:e.reason,reasonEntryId:e.reason===void 0?void 0:e.queueEntryId})}}),_m=e=>t=>Lo(t.payload)&&t.payload.queueEntryIds.includes(e),vm={rowExpectation:()=>null,wire:({queueEntryId:e,strategy:t,reason:n})=>qe.make({queueEntryId:e,...F({strategy:t,reason:n})}),ordered:!0,optimistic:{overlay:e=>[gm(e)],confirmedBy:({queueEntryId:e})=>_m(e),confirmTypes:[`queue.held`],recovery:`drop`}},ym=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,synthetic:!0,payload:{type:`queue.moved`,queueEntryIds:[e.queueEntryId],from:e.from,to:e.to,order:e.order}}),bm=({queueEntryId:e,from:t,to:n})=>r=>Io(r.payload)&&r.payload.queueEntryIds.includes(e)&&r.payload.from===t&&r.payload.to===n,xm={wire:({queueEntryId:e,to:t})=>Ke.make({_tag:`QueueMoved`,queueEntryId:e,to:t}),ordered:!0,isPreparationBypassBarrier:!0,optimistic:{overlay:e=>[ym(e)],confirmedBy:e=>bm(e),confirmTypes:[`queue.moved`],recovery:`drop`}},Sm={ordered:!0,wire:()=>Re.make({}),optimistic:{overlay:e=>[Jp({...e,status:`paused`,cause:`user`})],confirmedBy:()=>e=>V(e.payload,`goal.status`)&&e.payload.status===`paused`,confirmTypes:[`goal.status`],recovery:`drop`}},Cm=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,synthetic:!0,payload:{type:`queue.released`,queueEntryIds:e.queueEntryIds,index:e.queueIndex}}),wm=e=>t=>Ro(t.payload)&&t.payload.queueEntryIds.includes(e),Tm=({queueEntryId:e,wake:t})=>De.make(t===void 0?{queueEntryId:e}:{queueEntryId:e,wake:t}),Em={rowExpectation:e=>em(Tm(e),Date.now()),wire:Tm,ordered:!0,optimistic:{overlay:e=>[Cm(e)],confirmedBy:({queueEntryId:e})=>wm(e),confirmTypes:[`queue.released`],recovery:`drop`}},Dm=()=>crypto.randomUUID(),Om=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,payload:{type:`compaction.started`,trigger:`manual`,attemptId:e}}),km=e=>t=>{let n=t.payload;return(V(n,`compaction.started`)||V(n,`compaction.completed`)||V(n,`compaction.failed`))&&n.trigger===`manual`&&n.attemptId===e},Am=[`compaction.started`,`compaction.completed`,`compaction.failed`],jm=e=>({events:[Om(e)],confirmedBy:km(e),confirmTypes:Am}),Mm=e=>({events:[],confirmedBy:t=>{let n=t.payload;return(V(n,`compaction.completed`)||V(n,`compaction.failed`))&&n.trigger===`manual`&&n.attemptId===e},confirmTypes:[`compaction.completed`,`compaction.failed`]}),Nm={wire:({instructions:e,attemptId:t})=>Ve.make(F({instructions:e,attemptId:t}))},Pm=()=>({id:$(),threadId:0,at:Date.now(),transient:!1,payload:{type:`queue.resumed`}}),Fm=e=>Mo(e.payload)||e.payload.type===`turn.started`||rs(e.payload)&&e.payload.status===`running`,Im=[`queue.dequeued`,`turn.started`,`session.status`],Lm={rowExpectation:()=>({status:`running`,answersUserAsk:!0,lastUsedAt:Date.now()}),wire:()=>Se.make({}),optimistic:{overlay:()=>[Pm()],confirmedBy:()=>Fm,confirmTypes:Im,recovery:`drop`}},Rm={rowExpectation:()=>em(We.make({}),Date.now()),ordered:!0,wire:()=>We.make({}),optimistic:{overlay:e=>[Jp({...e,status:`pursuing`,cause:`resumed`,hold:null})],confirmedBy:()=>e=>V(e.payload,`goal.status`)&&e.payload.status===`pursuing`&&e.payload.cause===`resumed`,confirmTypes:[`goal.status`],recovery:`drop`}},zm=()=>({id:$(),threadId:0,at:Date.now(),transient:!1,payload:{type:`session.status`,status:`idle`}}),Bm=e=>{let{payload:t,threadId:n}=e;return rs(t)?t.status===`idle`:n!==0&&t.type===`thread.status`&&t.status===`idle`&&t.threadId===n},Vm=[`session.status`,`thread.status`],Hm=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,payload:{type:`tool.calls_interrupted`,toolCallIds:e}}),Um={rowExpectation:()=>({status:`idle`,statusDetail:null}),wire:()=>be.make({}),optimistic:{overlay:(e,t)=>
8[zm(),Kf(t)],confirmedBy:()=>Bm,confirmTypes:Vm,recovery:`drop`}},Wm=e=>t=>t.threadId===(e.threadId??0)&&V(t.payload,`branch.created`)&&t.payload.reason===`rewind`&&t.payload.targetMessageId===e.messageId,Gm={ordered:!0,wire:({messageId:e,restoreWorkspace:t})=>Te.make({messageId:e,...t===void 0?{}:{restoreWorkspace:t}}),threadId:({threadId:e})=>e,optimistic:{overlay:({threadId:e})=>[{...zm(),threadId:e??0}],confirmedBy:e=>Wm(e),confirmTypes:[`branch.created`],recovery:`drop`}},Km=e=>t=>Fo(t.payload)&&t.payload.queueEntryIds.includes(e),qm=[`queue.folded`],Jm={rowExpectation:()=>({status:`running`,statusDetail:null,lastUsedAt:Date.now()}),ordered:!0,wire:({queueEntryId:e})=>xe.make({queueEntryId:e}),optimistic:{overlay:({queueEntryId:e})=>[um(e)],confirmedBy:({queueEntryId:e})=>Km(e),confirmTypes:qm,recovery:`drop`}},Ym=e=>e.parts.flatMap(e=>e.type===`text`&&typeof e.text==`string`?[e.text]:[]).join(` 9`).trim(),Xm=({message:e,tokenBudget:t,behavior:n})=>Ne.make({message:e,tokenBudget:t,...F({behavior:n})}),Zm=e=>({...e,metadata:{...I(e.metadata)?e.metadata:{},sentAsGoal:!0}}),Qm=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,payload:{type:`goal.set`,goalId:-1,objective:Ym(e.message),revision:1,tokenBudget:e.tokenBudget,author:{}}}),$m={isMessageSend:!0,rowExpectation:e=>em(Xm(e),Date.now()),ordered:!0,durable:{key:({message:e})=>e.id},wire:Xm,optimistic:{overlay:e=>[Qm(e),cm(Zm(e.message),{fold:e.behavior===`fold`})],confirmedBy:({message:e})=>dm(e.id),confirmTypes:fm,recovery:`drop`}},eh=(e,t=0)=>({id:$(),threadId:t,at:Date.now(),transient:!1,payload:{type:`mode.changed`,mode:e}}),th=e=>t=>$n(t.payload)&&t.payload.mode===e,nh=[`mode.changed`],rh={ordered:!0,wire:({mode:e})=>Fe.make({mode:e}),optimistic:{overlay:({mode:e})=>[eh(e)],confirmedBy:({mode:e})=>th(e),confirmTypes:nh,recovery:`drop`}},ih=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,payload:{type:`model.changed`,config:e}}),ah=e=>t=>nr(t.payload)&&ye(t.payload.config,e),oh=[`model.changed`],sh={ordered:!0,wire:({config:e})=>Pe.make({config:e}),optimistic:{overlay:({config:e})=>[ih(e)],confirmedBy:({config:e})=>ah(e),confirmTypes:oh,recovery:`drop`}},ch=(e,t=0)=>({id:$(),threadId:t,at:Date.now(),transient:!1,payload:{type:`tool.approval_response_submitted`,responses:e}}),lh=e=>{let t=new Map(e.map(e=>[e.approvalId,{toolCallId:e.toolCallId,approved:e.approved}]));return e=>{let n=e.payload;if(n.type===`tool.approval_resolved`&&`approvalId`in n&&typeof n.approvalId==`string`&&t.get(n.approvalId)?.approved===!0&&t.delete(n.approvalId),(n.type===`tool.denied`||n.type===`tool.completed`||n.type===`tool.failed`)&&`toolCallId`in n&&typeof n.toolCallId==`string`){let e=n.type===`tool.denied`;for(let[r,i]of t)if(i.toolCallId===n.toolCallId&&i.approved!==e){t.delete(r);break}}return t.size===0}},uh=[`tool.approval_resolved`,`tool.denied`,`tool.completed`,`tool.failed`],dh={rowExpectation:()=>({status:`running`,statusDetail:null,lastUsedAt:Date.now()}),wire:({responses:e})=>Ce.make({responses:e}),threadId:({threadId:e})=>e,optimistic:{overlay:({responses:e,threadId:t})=>[ch(e,t)],confirmedBy:({responses:e})=>lh(e),confirmTypes:uh,recovery:`drop`}},fh={rowExpectation:()=>({status:`running`,statusDetail:null,lastUsedAt:Date.now()}),wire:({toolCallId:e,toolName:t,resolution:n})=>Ie.make({toolCallId:e,toolName:t,resolution:n}),threadId:({threadId:e})=>e},ph={rowExpectation:()=>({status:`running`,statusDetail:null,lastUsedAt:Date.now()}),wire:({threadId:e,...t})=>ke.make(t),threadId:({threadId:e})=>e},mh=(e,t=0)=>({id:$(),threadId:t,at:Date.now(),transient:!1,payload:{type:`tool.results_submitted`,results:e}}),hh=e=>{let[t]=e;return e.length===1&&t!==void 0&&t.state===`output-available`&&typeof t.output==`object`&&t.output!==null&&`decision`in t.output&&t.output.decision===`approved`},gh=(e,t=0,n=null)=>hh(e)?[mh(e,t),eh(n,t)]:[mh(e,t)],_h=e=>{let t=hh(e)?e[0]?.toolCallId:void 0,n,r=t!==void 0;return{onSettle(e,i){e===t&&(n===void 0?n=i:i>n&&(r=!1))},onEvent(e){let t=e.payload;$n(t)&&t.mode!==`plan`&&n!==void 0&&e.id>n&&(r=!1)},get holds(){return r}}},vh=e=>{let t=new Set(e.map(e=>e.toolCallId)),n=e.length===1,r=_h(e);return e=>{let i=e.payload;return i.type===`tool.approval_resolved`&&n&&typeof i.toolCallId==`string`&&t.delete(i.toolCallId),(i.type===`tool.completed`||i.type===`tool.failed`)&&typeof i.toolCallId==`string`&&(r.onSettle(i.toolCallId,e.id),t.delete(i.toolCallId)),r.onEvent(e),t.size===0&&!r.holds}},yh=[`tool.approval_resolved`,`tool.completed`,`tool.failed`,`mode.changed`],bh={rowExpectation:()=>({status:`running`,statusDetail:null,lastUsedAt:Date.now()}),ordered:!0,wire:({results:e})=>we.make({results:e}),threadId:({threadId:e})=>e,optimistic:{overlay:({results:e,threadId:t,restoredMode:n})=>
9gh(e,t,n??null),confirmedBy:({results:e})=>vh(e),confirmTypes:yh,recovery:`drop`}},xh=e=>({id:$(),threadId:0,at:Date.now(),transient:!1,payload:{type:`subscription.switched`,provider:e.provider,connectionId:e.connectionId,ownerUserId:e.ownerUserId,...e.ownerDisplayName===void 0?{}:{ownerDisplayName:e.ownerDisplayName},ownedBySpeaker:e.ownedBySpeaker,revision:0,reason:`manual`}}),Sh=e=>e.type===`subscription.switched`,Ch=(e,t)=>n=>Sh(n.payload)&&n.payload.provider===e&&n.payload.connectionId===t,wh=[`subscription.switched`],Th={ordered:!0,wire:({provider:e,connectionId:t})=>Le.make({provider:e,connectionId:t}),optimistic:{overlay:e=>[xh(e)],confirmedBy:({provider:e,connectionId:t})=>Ch(e,t),confirmTypes:wh,recovery:`drop`}},Eh=(e,t=0)=>({id:$(),threadId:t,at:Date.now(),transient:!1,synthetic:!0,payload:{type:`branch.switched`,branchId:e,fromBranchId:e}}),Dh=(e,t=0)=>n=>n.threadId===t&&V(n.payload,`branch.switched`)&&n.payload.branchId===e,Oh={ordered:!0,wire:({branchId:e})=>Ue.make({branchId:e}),threadId:({threadId:e})=>e,optimistic:{overlay:({branchId:e,threadId:t})=>[Eh(e,t)],confirmedBy:({branchId:e,threadId:t})=>Dh(e,t),confirmTypes:[`branch.switched`],recovery:`drop`}};function kh(e,t){return{...e,name:`${e.name}@${t}`,threadScope:{kind:`thread`,threadId:t}}}var Ah=new Map,jh=new Map,Mh=new WeakMap;function Nh(){return[...Ah.keys()].filter(e=>e!==0&&!jh.has(e)).length}function Ph(){let e=Nh()-64;if(!(e<=0)){for(let t of Ah.keys())if(!(t===0||jh.has(t))&&(Ah.delete(t),--e,e===0))return}}function Fh(e){for(let t of Object.values(e))Mh.set(t,e)}function Ih(e,t){if(e===0)return;let n=jh.get(e),r=t===void 0?void 0:Mh.get(t);r!==void 0&&(n===void 0||!Ah.has(e))&&Ah.set(e,r),jh.set(e,(n??0)+1)}function Lh(e){if(e===0)return;let t=jh.get(e);if(t===void 0||t===1){jh.delete(e),Ah.delete(e);return}jh.set(e,t-1)}function Rh(e){let t=Ah.get(e);if(t!==void 0)return e!==0&&!jh.has(e)&&(Ah.delete(e),Ah.set(e,t)),t;let n={transcript:e===0?Up:Hp({name:`transcript@${e}`,threadScope:{kind:`thread`,threadId:e},isSnapshotable:!1}),branches:e===0?Nn:Mn({name:`branches@${e}`,threadScope:{kind:`thread`,threadId:e},isSnapshotable:!1}),turnTiming:e===0?Ul:Hl({name:`turn-timing@${e}`,threadScope:{kind:`thread`,threadId:e},isSnapshotable:!1}),status:e===0?is:Tl(e),queue:e===0?Bo:Vo(e),pendingToolResults:e===0?to:kh(to,e),pendingApprovalResponses:e===0?Ka:kh(Ka,e),model:e===0?rr:ir(e),fork:e===0?yl:vl(e)};return Fh(n),Ah.set(e,n),Ph(),n}var zh={thread:Rh,views:{transcript:Up,branches:Nn,queue:Bo,status:is,turnTiming:Ul,model:rr,subscription:gl,mode:er,eventsLog:zn,pendingToolResults:to,pendingApprovalResponses:Ka,contextUsage:Rn,threads:Bl,goals:Zn,threadLifecycleEvents:Cl,sessionFork:Go,typing:Gl},intents:{sendMessage:pm,foldMessage:hm,stop:Um,cancelQueued:qp,editQueued:sm,editMessage:nm,holdQueued:vm,releaseQueued:Em,moveQueued:xm,sendQueued:Jm,resume:Lm,submitToolResults:bh,submitDetachedInteraction:fh,submitNoteAction:ph,submitApprovalResponses:dh,setModelConfig:sh,subscriptionPin:Th,setMode:rh,requestCompaction:Nm,rewind:Gm,switchBranch:Oh,setGoal:$m,editGoal:tm,pauseGoal:Sm,resumeGoal:Rm,clearGoal:Zp}},Bh=(0,R.createContext)(0),Vh={transcript:zh.views.transcript,branches:zh.views.branches,turnTiming:zh.views.turnTiming,status:zh.views.status,queue:zh.views.queue,pendingToolResults:zh.views.pendingToolResults,pendingApprovalResponses:zh.views.pendingApprovalResponses,model:zh.views.model,fork:yl};function Hh(e){return e===0?Vh:zh.thread(e)}function Uh({children:e,threadId:t=0}){return(0,R.createElement)(Bh.Provider,{value:t},e)}function Wh(){return(0,R.useContext)(Bh)}var Gh=(0,R.createContext)(null),Kh=bn(()=>performance.now()),qh,Jh;function Yh(){return typeof document<`u`&&document.visibilityState===`hidden`?`hidden`:`visible`}function Xh(){if(Jh!==void 0)return Jh;let e=[{at:0,state:Yh()}];return Jh=e,typeof document<`u`&&document.addEventListener(`visibilitychange`,()=>{for(e.push({at:performance.now(),state:Yh()});e.length>64;)e.shift()}),e}function Zh(e){let t=Xh();for(let n=t.length-1;n>=0;--n){let r=t[n];if(r!==void 0&&r.at<=e)return r.state}return t[0]?.state??`visible`}function Qh(){let e=Xh();for(let t=e.length-1;t>0;--t){let n=e[t],r=e[t-1];if(n?.state===`visible`&&r?.state===`hidden`)return n.at-r.at}return 0}function $h(e){let t=Xh();for(let n=t.length-1;n>=0;--n){let r=t[n];if(r!==void 0&&r.at<e&&r.state===`hidden`)return r.at}}var eg;function tg(e,t){for(e.push(t);e.length>256;)e.shift()}function ng(){if(eg!==void 0)return eg;let e={};eg=e;let t=new Set(hn.flatMap(e=>[e.start,e.end])),n=e=>t.has(e);return typeof PerformanceObserver>`u`||!(PerformanceObserver.supportedEntryTypes??[]).includes(`mark`)||new PerformanceObserver(t=>{for(let r of t.getEntries()){if(!n(r.name))continue;let t=e[r.name]??[];e[r.name]=t,tg(t,r.startTime)}}).observe({type:`mark`,buffered:!0}),e}function rg(e){let t=ng();return hn.flatMap(n=>vn(t[n.start]??[],t[n.end]??[]).filter(t=>t.end>=e).map(e=>({...e,feature:n.feature})))}var ig=new TextEncoder;function ag(e){if(typeof e!=`object`||!e||!(`output`in e))return 0;let{output:t}=e;if(t==null)return 0;try{return ig.encode(typeof t==`string`?t:JSON.stringify(t)).byteLength}catch{return 0}}var og=new WeakMap,sg=new WeakMap;function cg(e){let t=sg.get(e);if(t!==void 0)return t;let n=0;for(let t of e.parts)n+=ag(t);return sg.set(e,n),n}function lg(e){let t=og.get(e);if(t!==void 0)return t;let n=0,r=0;for(let t of e)t.kind===`message`&&(n+=1,r+=cg(t.message));let i={messageCount:n,toolResultBytes:r};return og.set(e,i),i}function ug(e){let t=new Set;for(let n of e)n.kind===`message`&&n.message.metadata?.optimistic===!0&&t.add(n.message.id);return t}function dg(e){return e instanceof Element&&e.closest(`[data-slot="composer"]`)!==null}function fg(e){let{sessionId:t,client:n,pool:r}=e,i=(0,R.useMemo)(()=>mg(t,n),[n,t]);return i.clientRef.current=n,i.poolRef.current=r,(0,R.useEffect)(()=>
9{if(i.cancelAbort(),i.cancelAbort=()=>void 0,i.isDisposed)return;let{recorder:e}=i;qh=i.sessionId,e.start();let t=yg(n,()=>e.markPhase(`live`));i.poolRef.current.syncGateSettled?.(i.sessionId).then(()=>e.markPhase(`gateOpen`),()=>void 0);let r=Gt(t=>{t.sessionId!==i.sessionId||t.end<i.openedAt||i.seenHistorySpans.has(t)||(i.seenHistorySpans.add(t),e.observeHistoryTiming(t),t.label===`hydrate`&&e.markPhase(`hydrated`,t.end),(t.label===`fold`||t.label===`boot-span fold`)&&(i.foldCountRef.current+=1,e.markPhase(`folded`,t.end)))},{sessionId:i.sessionId,since:i.openedAt,until:i.openedAt+dn}),a=xg(e),o=bg(e);return()=>{t(),r(),a.disconnect(),o(),i.cancelAbort=hg(i)}},[n,i]),i.metrics}var pg=new Map;function mg(e,t){let n=pg.get(e);if(n!==void 0&&!n.isDisposed)return n;let r=gg(e,t);return pg.set(e,r),r}function hg(e){let t=window.setTimeout(()=>{e.isDisposed=!0,e.recorder.dispose(),pg.get(e.sessionId)===e&&pg.delete(e.sessionId)},0);return()=>window.clearTimeout(t)}function gg(e,t){let n=performance.now(),r=qh!==void 0&&qh!==e,i=t.status.snapshot().phase===`live`,a={current:t},o={current:{}},s={current:{readRows:()=>[],isStreaming:!1}},c={sessionId:e,openedAt:n,seenHistorySpans:new WeakSet,clientRef:a,poolRef:o,transcriptRef:s,foldCountRef:{current:0},isDisposed:!1,cancelAbort:()=>void 0},l=Sn({now:()=>performance.now(),openedAt:n,isSwitch:r,wasLive:i,isStreaming:()=>s.current.isStreaming,sampler:Kh,visibilityAt:Zh,syncWindowsSince:rg,track:S,schedule:(e,t)=>{let n=window.setTimeout(e,t);return()=>window.clearTimeout(n)},mark:e=>performance.mark(e),readDimensions:()=>vg({client:a.current,scale:o.current.readSessionScale?.(e),sessionId:e,transcript:s.current,foldCount:c.foldCountRef.current})}),u,d={recorder:l,sessionId:e,beginSend:()=>{u=ug(s.current.readRows()),l.beginSend()},commitTranscript:e=>{s.current=e,l.recordCommit(e.isStreaming?`stream_delta`:`transcript`);let t=e.readRows();if(t.length===0||(l.markPhase(`firstRow`),u===void 0))return;let n=u;[...ug(t)].some(e=>!n.has(e))&&(u=void 0,l.completeSend())}};return{...c,recorder:l,metrics:d}}function _g(){try{return Lt({worker:ct(),navigationStart:performance.timeOrigin})}catch{return`cold`}}function vg(e){let{client:t,scale:n,transcript:r}=e,{messageCount:i,toolResultBytes:a}=lg(r.readRows()),o=typeof t.lastEventId==`function`?t.lastEventId():null;return{eventBucket:o===null?null:rn(o),messageBucket:an(i),toolResultBytesBucket:cn(a),prBucket:n===void 0?null:on(n.pullRequestCount),subsessionBucket:n===void 0?null:sn(n.subsessionCount),foldBucket:un(e.foldCount),hiddenMsBucket:ln(Qh()),scenario:_g(),build:`production`}}function yg(e,t){if(e.status.snapshot().phase===`live`)return t(),()=>void 0;let n;return n=e.status.subscribe(()=>{e.status.snapshot().phase===`live`&&(t(),n?.(),n=void 0)}),()=>{n?.(),n=void 0}}function bg(e){if(typeof document>`u`)return()=>void 0;Xh();let t,n=()=>{if(document.visibilityState===`hidden`)return;let n=performance.now(),r=$h(n);r!==void 0&&(e.beginTabResume({hiddenMs:n-r,at:n}),t!==void 0&&window.cancelAnimationFrame(t),t=window.requestAnimationFrame(()=>{t=void 0,e.recordResumeFrame(performance.now())}))};return document.addEventListener(`visibilitychange`,n),()=>{document.removeEventListener(`visibilitychange`,n),t!==void 0&&window.cancelAnimationFrame(t)}}function xg(e){if(typeof PerformanceObserver>`u`)return{disconnect:()=>void 0};let t=PerformanceObserver.supportedEntryTypes??[],n=[];if(t.includes(`longtask`)){let t=new PerformanceObserver(t=>{for(let n of t.getEntries())e.observeLongTask({startTime:n.startTime,duration:n.duration})});t.observe({type:`longtask`,buffered:!1}),n.push(t)}if(t.includes(`event`)){let t=new PerformanceObserver(t=>{for(let n of t.getEntries())(n.name===`keydown`||n.name===`input`)&&`target`in n&&dg(n.target)&&e.observeInputTiming({kind:`keystroke`,startTime:n.startTime,duration:n.duration})});t.observe({type:`event`,durationThreshold:16}),n.push(t)}return{disconnect:()=>{for(let e of n)e.disconnect()}}}function Sg(){return(0,R.use)(Gh)}function Cg(){let e=Sg();return Wh()===Ft?e:null}function wg(e){let t=(0,dt.c)(3),n=Cg(),r;t[0]!==e||t[1]!==n?.recorder?(r=()=>{n?.recorder.recordCommit(e)},t[0]=e,t[1]=n?.recorder,t[2]=r):r=t[2],(0,R.useLayoutEffect)(r)}function Tg(e){let t=(0,dt.c)(5),{isStreaming:n,source:r,readRows:i}=e,a=Cg(),o;t[0]!==n||t[1]!==a||t[2]!==i||t[3]!==r?(o=()=>{a?.commitTranscript({isStreaming:n,readRows:()=>Dg(r,i)})},t[0]=n,t[1]=a,t[2]=i,t[3]=r,t[4]=o):o=t[4],(0,R.useLayoutEffect)(o)}var Eg=new WeakMap;function Dg(e,t){let n=Eg.get(e);if(n!==void 0)return n;let r=t(e);
9return Eg.set(e,r),r}function Og(e){let t=(0,dt.c)(3),n=Cg(),r;return t[0]!==e||t[1]!==n?(r=()=>{if(n===null)return kg;let t=performance.now();return()=>{window.requestAnimationFrame(()=>{n.recorder.observeInputTiming({kind:e,startTime:t,duration:performance.now()-t})})}},t[0]=e,t[1]=n,t[2]=r):r=t[2],r}function kg(){}function Ag(){let e=(0,dt.c)(2),t=Cg(),n;return e[0]===t?n=e[1]:(n=()=>{if(t===null)return jg;let e=performance.now(),n=qt(t.sessionId);return r=>{if(n===void 0)return;let i=n(r);n=void 0,window.requestAnimationFrame(()=>{t.recorder.observeInputTiming({kind:`scroll-backfill`,startTime:e,duration:performance.now()-e,breakdown:i})})}},e[0]=t,e[1]=n),n}function jg(){}function Mg(){let e=(0,dt.c)(4),t=Cg(),n=(0,R.useRef)(Pg),r,i;e[0]===Symbol.for(`react.memo_cache_sentinel`)?(r=()=>()=>n.current(),i=[],e[0]=r,e[1]=i):(r=e[0],i=e[1]),(0,R.useEffect)(r,i);let a;return e[2]===t?a=e[3]:(a=e=>{n.current(),n.current=Ng;let r=e?.querySelector(`[data-slot="message-list-scroller"]`)??e;if(t===null||r==null)return;let i,a=e=>{if(i!==void 0)return;let n=e.timeStamp;i=window.requestAnimationFrame(()=>{window.setTimeout(()=>{i=void 0,t.recorder.observeInputTiming({kind:`scroll-step`,startTime:n,duration:performance.now()-n})},0)})};r.addEventListener(`scroll`,a,{passive:!0}),n.current=()=>{r.removeEventListener(`scroll`,a),i!==void 0&&window.cancelAnimationFrame(i)}},e[2]=t,e[3]=a),a}function Ng(){}function Pg(){}function Fg(e,t){if(typeof e!=`function`)throw TypeError(`Expected the first argument to be a \`function\`, got \`${typeof e}\`.`);if(!Number.isFinite(t)||t<0)throw TypeError(`Expected the second argument to be a non-negative finite number, got \`${t}\`.`);let n,r=0,i;return function(...a){clearTimeout(n);let o=Date.now(),s=t-(o-r);return s<=0?(r=o,i=e.apply(this,a)):n=setTimeout(()=>{r=Date.now(),i=e.apply(this,a)},s),i}}function Ig(e,t){let n=null;return(...r)=>{n!==null&&clearTimeout(n),n=setTimeout(()=>{n=null,e(...r)},t)}}function Lg(e,t){if(t?.throttleMs!==void 0&&t?.debounceMs!==void 0)throw Error(`agent-client: pass throttleMs OR debounceMs to subscribe, not both`);return t?.throttleMs===void 0?t?.debounceMs===void 0?e:Ig(e,t.debounceMs):Fg(e,t.throttleMs)}function Rg(e,t,n){let r=!0,i=Lg(()=>{r&&t()},n);return e.add(i),()=>{r=!1,e.delete(i)}}function zg(e){let t=e,n=new Set;return{view:{snapshot:()=>t,subscribe:(e,t)=>Rg(n,e,t)},set(e){t=e;for(let e of n)e()}}}function Bg(e){return Math.round(e*(.5+Math.random()*.5))}function Vg(e,t){let n=Bg(t);return!(e instanceof St||e instanceof xt)||e.retryAfterMs===void 0||!Number.isFinite(e.retryAfterMs)?n:Math.max(n,Math.max(0,e.retryAfterMs))}var Hg=2e3,Ug=16e3,Wg=3e4,Gg=class extends Error{name=`RuntimeStartingError`;constructor(e){super(`Session runtime is still starting`,{cause:e})}};function Kg(){return{id:$(),threadId:0,at:Date.now(),transient:!0,synthetic:!0,payload:{type:`client.stream_opened`}}}function qg(e){if(e.transient||e.payload.type!==`actor.state`)return;let{state:t}=e.payload;return t===`awake`||t===`sleeping`?t:void 0}function Jg(){return{id:$(),threadId:0,at:Date.now(),transient:!0,synthetic:!0,payload:{type:`client.stream_live`}}}function Yg(e,t){let n=null,r=null,i=100,a=null,o=null,s=zg([]);function c(e){s.set([...s.view.snapshot(),e].slice(-200))}function l(e,n){let r=s.view.snapshot().at(-1);(r?.type!==`phase`||r.phase!==e||r.generation!==g)&&c({type:`phase`,at:Date.now(),generation:g,phase:e,...n===void 0?{}:{error:n}}),t.onPhase(e,n)}function u(e){c({type:`phase`,at:Date.now(),generation:g,phase:`error`,error:e}),t.onPhase(`error`,e)}let d,f=!1,p=!1,m=!1,h=!1,g=0,_=!1,v=!1,y=!1,b,ee=null,x=!1,te=0,S,ne=0,C=0,re=null,w;function T(){return a??d}function ie(){w=void 0,re!==null&&(clearTimeout(re),re=null)}async function ae(e){w!==e||!A(e.generation)||(w=void 0,m=!0,ce(),e.result.headId!==void 0&&(a=a===null?e.result.headId:Math.max(a,e.result.headId)),await oe(Jg(),e.generation),A(e.generation)&&(l(`live`),p&&v&&(D(),he())))}function E(){w!==void 0&&re===null&&(re=setTimeout(()=>{re=null;let e=w;e===void 0||!A(e.generation)||te>0||pt(ae(e))},0))}async function oe(e,n){te+=1;try{await t.onEvent(e,n)}finally{--te,E()}}function D(){g+=1,ie();let e=n;n=null,e!==null&&pt(e.cancel())}function O(e){S=e,l(`error`,e)}function se(){ne=0,C=0}function ce(){se(),i=100}function k(e){return e instanceof bt&&!h}function le(e){r=setTimeout(()=>{r=null,he()},e)}function ue(){if(x||!v||r!==null)return;let e=S;if(S=void 0,e instanceof Tt){se();return}if(k(e)?ne+=1:se(),ne<5){l(`reconnecting`);let t=e===void 0,n=t?Math.max(i,400):i;i=Math.min(n*2,t?Ug:Hg),le(Vg(e,n));return}u(new Gg(e)),!(C>=4)&&(C+=1,le(Wg))}function A(e){return!x&&v&&e===g}function j(e){return m?!0:b!==void 0&&e.id>b}function de(e,t){let n=qg(e);n===void 0||!j(e)||(ee=n===`sleeping`?t:null)}function M(){D(),y=!0,l(`asleep`)}function fe(e){e.transient||(a=a===null?e.id:Math.max(a,e.id))}async function pe(e){w?.generation===e&&await pt(ae(w)),A(e)&&M()}async function me(e,t){for(;A(t);){let n=await e.read();if(n.done)return;let r=n.value;if(o=Date.now(),await oe(r,t),!A(t))return;if(i=100,fe(r),de(r,t),ee===t){await pe(t);return}}}async function N(e,t){try{await me(e,t)}catch(e){A(t)&&O(e)}A(t)&&(D(),ue());try{e.releaseLock()}catch{}}let P=!1;function he(){if(x)return;p=!1,m=!1,h=!1,b=void 0,y=!1;let r=g+1;
9g=r,o=Date.now();let i=t.shouldRequestDeltas();c({type:`open`,at:Date.now(),generation:r,afterEventId:T(),deltas:i});let a=f&&T()===void 0,s=P;P=!1,f=!1;let u;try{u=e.events({afterEventId:T(),deltas:i,...a?{liveOnly:!0}:{},...s?{refresh:!0}:{}})}catch(e){A(r)&&O(e),A(r)&&ue();return}let d=u.stream.getReader();n=d,l(`backfilling`),pt((async()=>{await oe(Kg(),r),pt(N(d,r))})()),u.backfillDone.then(e=>{!x&&r===g&&(h=!0,b=e.headId,w={generation:r,result:e},E())},e=>{!x&&r===g&&l(`error`,e)})}return{open(e){x||_||(_=!0,v=!0,ce(),d=e?.afterEventId,f=e?.liveOnly===!0,a=e?.afterEventId??null,he())},close(){x||!v||(v=!1,y=!1,r!==null&&(clearTimeout(r),r=null),D())},reopen(e){if(!(x||!_)){if(e?.deferUntilCursor===!0&&v&&T()===void 0){if(r!==null)return;if(n!==null&&!m){p=!0;return}}r!==null&&(clearTimeout(r),r=null),D(),v=!0,ce(),P=e?.refresh===!0,he()}},wake(){x||!v||!y||he()},generation:()=>g,lastEventId:()=>a,lastActivityAt:()=>o,timeline:s.view,dispose(){x||(x=!0,v=!1,y=!1,r!==null&&(clearTimeout(r),r=null),D())}}}var Xg=1e4,Zg=3e3,Qg={title:`Session connection interrupted`,description:`Reconnecting. Session updates may be delayed.`},$g={title:`Session updates stalled, reconnecting`,description:`The live stream stopped delivering. Catching up now.`},e_={title:`Session is starting`,description:`The session runtime is not ready yet. Retry now or wait for it to come up.`},t_={title:`This session is no longer available`,description:`Its runtime is gone, so its history and threads cannot be loaded.`},n_={title:`Retrying connection`,description:`Session updates may be delayed.`},r_={title:`Still reconnecting`,description:`Retry did not reconnect yet. Session updates may be delayed.`},i_=new WeakMap,a_=new WeakSet;function o_(e){let{phase:t}=e.status.snapshot();if(t!==`degraded`)return t;let n=e.connectionTimeline.snapshot().at(-1);return n?.type===`phase`?n.phase:void 0}function s_(e){return e===`live`||e===`asleep`||e===`idle`||e===`disposed`}var c_=[[0,`under-5s`],[5e3,`5s-15s`],[15e3,`15s-60s`],[6e4,`60s-plus`]],l_=new WeakMap;function u_(e){for(let t=e.length-1;t>=0;--t){let n=e[t];if(n===void 0||n.type===`open`)return;if(n.error instanceof yt)return{at:n.at,generation:n.generation,error:n.error}}}function d_(e){return e===null?`unknown`:Xt(c_,e)}function f_(e){return Xt(c_,e)}function p_(e,t){let n=t.at(-1);return e===`error`&&n?.type===`phase`&&n.error instanceof Gg}function m_(e){if(e.status.snapshot().error instanceof Tt)return t_;let t=e.connectionTimeline.snapshot();return p_(o_(e),t)?e_:void 0}function h_(e){let t,n,r,i=!1;function a(){clearTimeout(t),t=void 0,i=!1,n!==void 0&&(te.dismiss(n),n=void 0),r=void 0}function o(e){e.id===n&&(clearTimeout(t),t=void 0,n=void 0,r=void 0,i=!0)}function s(e){r=e,n=te(e.title,{id:n,description:e.description,duration:1/0,action:{label:`Retry`,onClick:c},onDismiss:o})}
9function c(i){i.preventDefault();let a=l_.get(e);a?.status===`active`&&(a.retryButtonUsed=!0),e.connect(),e.resync(),r=n_,n=te.loading(n_.title,{id:n,description:n_.description,duration:1/0,action:void 0,onDismiss:o}),t=setTimeout(()=>{t=void 0,s(m_(e)??r_)},Xg)}function l(e){i||r===e||(clearTimeout(t),t=void 0,s(e))}function u(e){if(i||t!==void 0||n!==void 0)return;let r=u_(e)!==void 0;t=setTimeout(()=>{t=void 0,s(r?$g:Qg)},r?Zg:Xg)}function d(t){let n=u_(t),r=l_.get(e);if(n===void 0||r?.generation===n.generation&&r.at===n.at)return;let i=d_(n.error.lastFrameAgeMs);l_.set(e,{...n,lastFrameAgeBucket:i,retryButtonUsed:!1,status:`active`}),S(`session_stream.stalled`,{phase:`detected`,reason:n.error.reason,lastFrameAgeBucket:i,recoveredWithinBucket:`pending`,retryButtonUsed:!1})}function f(t){let n=l_.get(e);n!==void 0&&(n.status===`active`&&S(`session_stream.stalled`,{phase:`recovered`,reason:n.error.reason,lastFrameAgeBucket:n.lastFrameAgeBucket,recoveredWithinBucket:f_(t-n.at),retryButtonUsed:n.retryButtonUsed}),l_.delete(e))}function p(){let t=l_.get(e);t?.status===`active`&&(S(`session_stream.stalled`,{phase:`abandoned`,reason:t.error.reason,lastFrameAgeBucket:t.lastFrameAgeBucket,retryButtonUsed:t.retryButtonUsed}),t.status=`abandoned`)}function m(){let t=e.connectionTimeline.snapshot();d(t),!a_.has(e)&&t.some(e=>e.type===`phase`&&e.phase===`live`)&&a_.add(e);let n=o_(e);if(s_(n)){if(n===`live`){a_.add(e);let n=t.findLast(e=>e.type===`phase`&&e.phase===`live`)?.at;f(n??Date.now())}else p();a();return}let r=m_(e);if(r!==void 0){l(r);return}
9(n===`error`||n===`reconnecting`||n===`backfilling`&&a_.has(e))&&u(t)}let h=e.status.subscribe(m),g=e.connectionTimeline.subscribe(m);return m(),()=>{h(),g(),a()}}function g_(e){let t=i_.get(e);t===void 0&&(t={users:0,dispose:h_(e)},i_.set(e,t)),t.users+=1;let n=t;return()=>{--n.users,n.users===0&&(n.dispose(),i_.delete(e))}}var __=(0,R.createContext)(null);function v_(){let e=(0,R.use)(__);if(!e)throw Error(`useSessionClientPoolInternal must be used inside <SessionClientPool>`);return e}function y_(){return(0,R.use)(__)??void 0}var b_=(0,R.createContext)(null);function x_(e){let t=(0,dt.c)(21),{children:n,sessionId:r}=e,i=v_(),a,o;t[0]!==i||t[1]!==r?(a=()=>i.getClient(r),o=()=>i.getClient(r),t[0]=i,t[1]=r,t[2]=a,t[3]=o):(a=t[2],o=t[3]);let s=(0,R.useSyncExternalStore)(i.subscribeClients,a,o),c,l;t[4]!==i||t[5]!==r?(c=()=>i.mount(r),l=[i,r],t[4]=i,t[5]=r,t[6]=c,t[7]=l):(c=t[6],l=t[7]),(0,R.useEffect)(c,l);let u;t[8]!==s||t[9]!==r?(u={sessionId:r,client:s,clientScope:`pooled`},t[8]=s,t[9]=r,t[10]=u):u=t[10];let d=u,f;t[11]!==s||t[12]!==i||t[13]!==r?(f={sessionId:r,client:s,pool:i},t[11]=s,t[12]=i,t[13]=r,t[14]=f):f=t[14];let p=fg(f),m;t[15]!==n||t[16]!==p?(m=(0,ut.jsx)(Gh.Provider,{value:p,children:n}),t[15]=n,t[16]=p,t[17]=m):m=t[17];let h;return t[18]!==m||t[19]!==d?(h=(0,ut.jsx)(S_,{value:d,children:m}),t[18]=m,t[19]=d,t[20]=h):h=t[20],h}function S_(e){let t=(0,dt.c)(9),{children:n,value:r}=e,i,a;t[0]===r.client?(i=t[1],a=t[2]):(i=()=>g_(r.client),a=[r.client],t[0]=r.client,t[1]=i,t[2]=a),(0,R.useEffect)(i,a);let o;t[3]!==n||t[4]!==r.client?(o=(0,ut.jsx)(Mt,{client:r.client,children:n}),t[3]=n,t[4]=r.client,t[5]=o):o=t[5];let s;return t[6]!==o||t[7]!==r?(s=(0,ut.jsx)(b_.Provider,{value:r,children:o}),t[6]=o,t[7]=r,t[8]=s):s=t[8],s}function C_(){let e=(0,R.use)(b_);if(e===null)throw Error(`useSessionClient must be used inside <SessionClientProvider>`);return e}function w_(){return(0,R.use)(b_)??void 0}export{Fm as $,Za as $t,gh as A,ct as An,Bu as At,ih as B,as as Bt,Hh as C,ft as Cn,Wu as Ct,Ih as D,lt as Dn,Ku as Dt,Lh as E,it as En,Yu as Et,uh as F,pl as Ft,Qm as G,Po as Gt,th as H,ns as Ht,lh as I,ul as It,Vm as J,Io as Jt,qm as K,jo as Kt,ch as L,Ss as Lt,vh as M,vu as Mt,ph as N,zl as Nt,wh as O,st as On,Uu as Ot,fh as P,vc as Pt,Im as Q,no as Qt,oh as R,hs as Rt,Uh as S,pt as Sn,ed as St,zh as T,Ze as Tn,Ju as Tt,eh as U,No as Ut,nh as V,is as Vt,Zm as W,Mo as Wt,zm as X,Ao as Xt,Bm as Y,Ro as Yt,Hm as Z,Oo as Zt,Ag as _,wt as _n,mf as _t,b_ as a,er as an,fm as at,Og as b,bt as bn,Qu as bt,v_ as c,Dn as cn,cm as ct,Yg as d,Bt as dn,Kp as dt,Xa as en,Pm as et,Vg as f,Ft as fn,Gp as ft,Cg as g,Ct as gn,Uf as gt,Rg as h,St as hn,Id as ht,C_ as i,nr as in,mm as it,yh as j,_u as jt,Ch as k,ot as kn,Vu as kt,t_ as l,V as ln,um as lt,zg as m,Nt as mn,Kf as mt,S_ as n,Va as nn,Mm as nt,__ as o,jn as on,dm as ot,Bg as p,Pt as pn,Wp as pt,Km as q,Lo as qt,w_ as r,za as rn,Dm as rt,y_ as s,En as sn,lm as st,x_ as t,Ya as tn,jm as tt,Hg as u,Kt as un,em as ut,wg as v,Tt as vn,Wf as vt,Wh as w,L as wn,Gu as wt,Tg as x,At as xn,$u as xt,Mg as y,xt as yn,gd as yt,ah as z,ms as zt};
Line numbers count LF bytes from the start of the resource, as the search results do. Vendor segments are library code the classifier recognised; they are stored but not indexed. Bytes are shown as Latin1 characters, one per byte.