1!function(){try{var e="undefined"!=typeof window?window:"undefined"!=typeof global?global:"undefined"!=typeof globalThis?globalThis:"undefined"!=typeof self?self:{};e._posthogReleaseId=e._posthogReleaseId||"01a0d9fb-efe9-0000-3dbc-0b83bfea13f7";var n=(new e.Error).stack;n&&(e._posthogChunkIds=e._posthogChunkIds||{},e._posthogChunkIds[n]="b14b6983-7043-54c6-9004-c499abc7e674")}catch(e){}}();import{n as e,t}from"./apiFetch-Cd6IROe9.js";import{m as n,p as r}from"./QueryClientProvider-B9BmrVxx.js";import{t as i}from"./queryOptions-Dfvzj6n2.js";import{Mn as a}from"./sdk.gen-CHMoHuWd.js";import{h as o}from"./repositoryForge-BdfuNGCH.js";import{a as s,t as c}from"./repositoryStreamState-BqRA-NSa.js";function l({streamFn:e,refetchMode:t=`reset`,reducer:i=(e,t)=>n(e,t),initialValue:a=[]}){return async n=>{let o=n.client.getQueryCache().find({queryKey:n.queryKey,exact:!0}),s=!!o&&o.isFetched();s&&t===`reset`&&o.setState({...o.resetState,fetchStatus:`fetching`});let c=a,l=!1,u=await e(r({client:n.client,meta:n.meta,queryKey:n.queryKey,pageParam:n.pageParam,direction:n.direction},()=>n.signal,()=>l=!0)),d=s&&t===`replace`;for await(let e of u){if(l)break;d?c=i(c,e):n.client.setQueryData(n.queryKey,t=>i(t===void 0?a:t,e))}return d&&!l&&n.client.setQueryData(n.queryKey,c),n.client.getQueryData(n.queryKey)??a}}var u=[`repos`,`stream`];async function*d(n){let r=[],i=!1,o=!1,s=null,c=()=>{let e=s;s=null,e&&e()},l=e=>{r.push(e),c()},{stream:u}=a({url:`${e()}/api/v1/repos/stream`,fetch:t,credentials:`include`,signal:n,sseMaxRetryAttempts:0,onSseEvent:e=>l({event:e.event,data:e.data}),onSseError:e=>{if(n.aborted||o)return;o=!0;let t=e instanceof Error?e.message:`stream failed`,r=/SSE failed:\s*(\d+)/.exec(t),i=r?Number(r[1]):void 0;if(i===401||i===403){l({event:`error`,data:{authorization_rejected:!0,message:t,status:i}});return}l({event:`stream-error`,data:{message:t}})}}),d=(async()=>{try{for await(let e of u);}catch{}finally{i=!0,c()}})();try{for(;;){for(;r.length;)yield r.shift();if(i)break;await new Promise(e=>{s=e})}}finally{await d.catch(()=>{})}}var f=l({streamFn:({signal:e})=>d(e),reducer:(e,t)=>s(e,t),initialValue:c,refetchMode:`replace`});function p(e,t,n,r){e.setQueryData(u,e=>e&&{...e,rows:e.rows.map(e=>e.full_name===t&&e.repo&&(r===void 0||o(e)===r)?{...e,...typeof n.private==`boolean`?{visibility:n.private?`private`:`public`}:{},repo:{...e.repo,...n}}:e)})}var m=()=>i({queryKey:u,queryFn:f,staleTime:3e4,refetchInterval:e=>e.state.data?.repositoryListTruncated===!0&&5e3});export{l as i,u as n,m as r,p as t}; 2//# sourceMappingURL=repositoryStreamQuery-CQ86qHlx.js.map 3//# chunkId=b14b6983-7043-54c6-9004-c499abc7e674
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.