mirror of
https://github.com/mountain-loop/yaak.git
synced 2026-01-14 21:23:40 +01:00
Events from previous WebSocket/gRPC connections and HTTP responses were persisting in the store and displaying in new connections. Added filter parameter to mergeModelsInStore that clears old events when switching connections, plus render-time filtering as a safety net. Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
30 lines
1.0 KiB
TypeScript
30 lines
1.0 KiB
TypeScript
import { invoke } from '@tauri-apps/api/core';
|
|
import type { HttpResponse, HttpResponseEvent } from '@yaakapp-internal/models';
|
|
import {
|
|
httpResponseEventsAtom,
|
|
mergeModelsInStore,
|
|
replaceModelsInStore,
|
|
} from '@yaakapp-internal/models';
|
|
import { useAtomValue } from 'jotai';
|
|
import { useEffect } from 'react';
|
|
|
|
export function useHttpResponseEvents(response: HttpResponse | null) {
|
|
const allEvents = useAtomValue(httpResponseEventsAtom);
|
|
|
|
useEffect(() => {
|
|
if (response?.id == null) {
|
|
replaceModelsInStore('http_response_event', []);
|
|
return;
|
|
}
|
|
|
|
// Fetch events from database, filtering out events from other responses and merging atomically
|
|
invoke<HttpResponseEvent[]>('cmd_get_http_response_events', { responseId: response.id }).then(
|
|
(events) =>
|
|
mergeModelsInStore('http_response_event', events, (e) => e.responseId === response.id),
|
|
);
|
|
}, [response?.id]);
|
|
|
|
const events = allEvents.filter((e) => e.responseId === response?.id);
|
|
return { data: events, error: null, isLoading: false };
|
|
}
|