Function useTestLogs

apps/ui/src/hooks/use-test-logs.ts:116–344

({
  worktreePath,
  sessionId: targetSessionId,
  autoSubscribe = true,
}: UseTestLogsOptions)

 * ```
 */
export function useTestLogs({
  worktreePath,
  sessionId: targetSessionId,
  autoSubscribe = true,
}: UseTestLogsOptions) {
  const [state, setState] = useState<TestLogState>(initialState);

  // Keep track of whether we've fetched initial logs
  const hasFetchedInitialLogs = useRef(false);

  // Track the current session ID for filtering events
  const currentSessionId = useRef<string | null>(targetSessionId ?? null);

  // Guard against stale fetch results when switching worktrees/sessions
  const fetchSeq = useRef(0);

  /**
   * Derived state: whether tests are currently running
   */
  const isRunning = state.status === 'running' || state.status === 'pending';

  /**
   * Fetch buffered logs from the server
   */
  const fetchLogs = useCallback(async () => {
    if (!worktreePath && !targetSessionId) return;

    // Increment sequence to guard against stale responses
    const seq = ++fetchSeq.current;

    setState((prev) => ({ ...prev, isLoading: true, error: null }));

    try {
      const api = getElectronAPI();
      if (!api?.worktree?.getTestLogs) {
        // Check if this request is still current
        if (seq !== fetchSeq.current) return;
        setState((prev) => ({
          ...prev,
          isLoading: false,
          error: 'Test logs API not available',
        }));
        return;
      }

      const result = await api.worktree.getTestLogs(worktreePath ?? undefined, targetSessionId);

      // Check if this request is still current (prevent stale updates)
      if (seq !== fetchSeq.current) return;

      if (result.success && result.result) {
        const { sessionId, command, status, testFile, logs, startedAt, finishedAt, exitCode } =
          result.result;

        // Update current session ID for event filtering
        currentSessionId.current = sessionId;

        setState((prev) => ({