Function countStaleStepUpdates

src/node/services/__tests__/devToolsService.test.ts:60–86

(logContents: string, stepId: string)

}

function countStaleStepUpdates(logContents: string, stepId: string): number {
  return logContents.split("\n").reduce((count, line) => {
    if (!line.trim()) {
      return count;
    }

    try {
      const parsed = JSON.parse(line) as {
        type?: unknown;
        stepId?: unknown;
        update?: { error?: unknown } | null;
      };

      if (
        parsed.type === "step-update" &&
        parsed.stepId === stepId &&
        parsed.update?.error === "Interrupted (stale)"
      ) {
        return count + 1;
      }
    } catch {
      // Ignore malformed test fixture lines while counting stale-step updates.
    }

    return count;
  }, 0);
}

describe("DevToolsService", () => {
  let tempDir: string;