buzzert/Sybil-2
1
0
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

load error is no op

Browse Source
This commit is contained in:
James Magahern
2026-02-15 13:40:04 -08:00
parent 9cd7e963b9
commit cec7d902be
1 changed files with 18 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
web/src/pages/search-route-page.tsx
View File

@@ -95,6 +95,7 @@ export default function SearchRoutePage() {
streamAbortRef.current?.abort(); streamAbortRef.current?.abort();
const abortController = new AbortController(); const abortController = new AbortController();
streamAbortRef.current = abortController; streamAbortRef.current = abortController;
let wasInterrupted = false;
setError(null); setError(null);
setIsRunning(true); setIsRunning(true);
@@ -177,7 +178,10 @@ export default function SearchRoutePage() {
}, },
onAnswerError: (payload) => { onAnswerError: (payload) => {
if (requestId !== requestCounterRef.current) return; if (requestId !== requestCounterRef.current) return;
if (isInterruptedStreamError(payload.error)) return; if (isInterruptedStreamError(payload.error)) {
wasInterrupted = true;
return;
}
setSearch((current) => (current ? { ...current, answerError: payload.error } : current)); setSearch((current) => (current ? { ...current, answerError: payload.error } : current));
}, },
onDone: (payload) => { onDone: (payload) => {
@@ -186,23 +190,32 @@ export default function SearchRoutePage() {
}, },
onError: (payload) => { onError: (payload) => {
if (requestId !== requestCounterRef.current) return; if (requestId !== requestCounterRef.current) return;
if (isInterruptedStreamError(payload.message)) return; if (isInterruptedStreamError(payload.message)) {
wasInterrupted = true;
return;
}
setError(payload.message); setError(payload.message);
}, },
}, },
{ signal: abortController.signal } { signal: abortController.signal }
); );
} catch (err) { } catch (err) {
if (abortController.signal.aborted) return; if (abortController.signal.aborted) {
wasInterrupted = true;
return;
}
const message = err instanceof Error ? err.message : String(err); const message = err instanceof Error ? err.message : String(err);
if (isInterruptedStreamError(message)) return; if (isInterruptedStreamError(message)) {
wasInterrupted = true;
return;
}
if (message.includes("bearer token")) { if (message.includes("bearer token")) {
handleAuthFailure(message); handleAuthFailure(message);
} else if (requestId === requestCounterRef.current) { } else if (requestId === requestCounterRef.current) {
setError(message); setError(message);
} }
} finally { } finally {
if (requestId === requestCounterRef.current) { if (requestId === requestCounterRef.current && !wasInterrupted) {
streamAbortRef.current = null; streamAbortRef.current = null;
setIsRunning(false); setIsRunning(false);
} }