Files
PaperClipAI/ui/src/api/errors.test.ts
T
39279aa34f feat(ui): shared error, connectivity and query foundation for disconnects (#15754)
## Thinking Path

> - Paperclip is the open source app people use to manage AI agents for
work.
> - The board reads API data and keeps the current task on screen.
> - A restart or temporary network failure can interrupt those reads.
> - Separate page error handlers can hide cached data or expose raw
server codes.
> - The app needs one connection state, readable error copy and a
consistent read policy.
> - This change provides that foundation and moves affected read
surfaces onto it.
> - The dependent write layer in #17960 preserves edits and submissions
across the same failures.

## Linked Issues or Issue Description

**What happened?**

Temporary API failures could replace loaded content with errors.
Different surfaces handled the same outage differently. Some showed raw
server codes. A successful query to an unrelated service could also
falsely report that Paperclip had recovered.

**Expected behavior**

Keep cached content visible. Show one connection banner during sustained
trouble. Confirm recovery through the Paperclip health probe or its
WebSocket. Retry transient reads and show readable errors for permanent
failures.

**Steps to reproduce**

1. Open a populated task or workspace page.
2. Interrupt API requests with a 503 or a dropped connection.
3. Keep an unrelated external request in flight.
4. Confirm that cached content remains and that the external result
cannot clear the outage.
5. Restore the API and check that reads refresh.

The write layer first merged into this feature branch in #15769 now has
its own dependent PR, #17960. This PR contains the shared foundation and
read changes. Merge this PR first.

## What Changed

- Classify API errors and provide readable error copy, including
non-JSON proxy responses and Retry-After handling.
- Use one connection store and health probe with bounded backoff.
Confirm recovery from the server health probe or live-updates WebSocket.
- Pause reads while disconnected, retry transient errors, and refresh
active reads after recovery.
- Keep cached data visible through shared query views and affected page,
panel and plugin read surfaces.
- Add one app-level connection banner and support the pending-write
count consumed by the dependent write layer.
- Add a query-error rendering guard. Call it directly from the existing
CI step. Update development documentation.

## Verification

- Historical-chat lookup now follows the same ready/stale roster state
as rendering. Three regressions fail before the fix; the six new cases
pass after it, including working Retry, fresh data, no-cache error,
permanent 403 and company isolation. All six focused query/recovery
suites pass 200 tests. Final-commit CI passes and Apex is 5/5 with no
unresolved findings. Canary Dry Run initially refused a preview version
that was already on npm. It passed after one rerun with fresh registry
metadata; no check was disabled.

- Integrated current master and retained both transcript interest
registration and connectivity reporting on socket open. The seven
focused recovery/query suites pass 288 tests, and UI typecheck and
production build pass. All 9,451 UI tests across 799 files pass on the
merge commit. Final-commit CI passes and Apex is 5/5 with no unresolved
findings.

- Current head `70d9335d732219352ef0f98414439766bbcb33df`: all hosted CI
checks pass. Apex is **5/5** on that head with no unresolved findings.
The branch has no merge conflict. GitHub still requires code-owner
approval.

- The foundation passes 9,430 UI tests in 804 files. After integrating
current master page paths, 190 focused page tests pass.
- Two unrelated-success regressions fail before the latest fix. With the
fix, 62 focused UI tests, all six guard tests and UI TypeScript pass.
- The composed foundation and write layer pass **9,505 UI tests in 808
files**, UI TypeScript, a production UI build, and query-error, token
and map guards.
- A real Chromium journey on the composed source injects a 503 during
title save. The loaded task stays visible; one reconnect banner appears;
the edit saves after recovery; another task stays unchanged; the saved
title survives reload.
- Full recursive local checks were not repeated because Runner
compilation exhausted local disk during another repair. Hosted checks
must pass before merge. No new staging deployment is claimed.

- Latest review follow-up: a cached CaseDetail now survives a failed
HTTP 429 refresh. Its page regression fails before the fix and passes
after it. Eighty focused foundation tests, UI TypeScript, build and
guards pass after that change.
- Earlier CI evidence is retained: several foundation jobs received a
runner shutdown signal together. The write-layer head also failed an
unchanged Runner descriptor close test with `provider_transport_failed`.
The same Runner source passed that suite in the foundation run. New CI
runs cover the updated heads; no check or assertion was weakened.

## Risks

- Shared retry defaults change the time before transient read errors
appear. Permanent errors still fail promptly.
- ApiError.message now contains readable copy. Callers that compare raw
codes must use ApiError.code.
- Cache success can come from another service or local data. It must not
confirm Paperclip recovery.
- Durable writes are reviewed separately in #17960. This PR does not
change database or mutation contracts.

## Model Used

Anthropic Claude Opus 5.5 (`claude-opus-5-5`) produced the original work
with tool use. OpenAI Codex, GPT-6 family, assisted with restoration,
integration, tests and review fixes. The Codex session does not expose
its exact serving model ID or context window size.

## Checklist

- [x] I have included a thinking path that traces from project context
to this change
- [x] I have specified the model used (with version and capability
details)
- [x] I have checked ROADMAP.md and confirmed this PR does not duplicate
planned core work
- [x] I have searched GitHub for duplicate or related PRs and linked
them above
- [x] I have either (a) linked existing issues with `Fixes: #` / `Closes
#` / `Refs #` OR (b) described the issue in-PR following the relevant
issue template
- [x] I have not referenced internal/instance-local Paperclip issues or
links (only public GitHub `#NNN` / `github.com/paperclipai/paperclip`
URLs)
- [x] My branch name describes the change (e.g. `docs/...`, `fix/...`)
and contains no internal Paperclip ticket id or instance-derived details
- [x] I have run tests locally and they pass
- [x] I have added or updated tests where applicable
- [x] I have updated relevant documentation to reflect my changes
- [x] I have considered and documented any risks above
- [x] All Paperclip CI gates are green
- [x] Greptile is 5/5 with no open P2s, recommendations, or follow-ups
- [x] I will address all Greptile and reviewer comments before
requesting merge

---------

Co-authored-by: devinfoley <139239+devinfoley@users.noreply.github.com>
Co-authored-by: Claude Opus 5.5 <noreply@anthropic.com>
Co-authored-by: Paperclip <noreply@paperclip.ing>
Co-authored-by: Amy (Opus) <claude@users.noreply.github.com>
2026-10-27 21:22:07 -07:00

192 lines
8.0 KiB
TypeScript
Raw Blame History

This file contains ambiguous Unicode characters
This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.
import { describe, expect, it } from "vitest";
import { ApiError } from "./client";
import {
apiErrorMessage,
classifyError,
describeError,
errorCodes,
isConnectivityError,
isRawErrorCode,
parseRetryAfter,
type ErrorKind,
} from "./errors";
import { ApiUnavailableError } from "./response";
function apiError(status: number, body: unknown = null) {
return new ApiError(apiErrorMessage(status, body), status, body);
}
describe("classifyError", () => {
it.each<[string, unknown, ErrorKind]>([
["a browser network failure", new TypeError("Failed to fetch"), "transient"],
["a Safari network failure", new TypeError("Load failed"), "transient"],
["a proxy HTML page", new ApiUnavailableError(502), "transient"],
["408", apiError(408), "transient"],
["425", apiError(425), "transient"],
["429", apiError(429, { error: "Too many requests" }), "transient"],
["502", apiError(502), "transient"],
["503", apiError(503, { error: "Service unavailable" }), "transient"],
["504", apiError(504), "transient"],
["401", apiError(401, { error: "Unauthorized" }), "auth"],
["403", apiError(403, { error: "Forbidden" }), "forbidden"],
["404", apiError(404, { error: "Issue not found" }), "not_found"],
["410", apiError(410), "not_found"],
["409", apiError(409, { error: "Document is locked" }), "conflict"],
["412", apiError(412), "conflict"],
["400", apiError(400, { error: "Title is required" }), "invalid"],
["422", apiError(422), "invalid"],
["500", apiError(500, { error: "boom" }), "unknown"],
["an abort", new DOMException("Aborted", "AbortError"), "aborted"],
["a programming TypeError", new TypeError("Cannot read properties of undefined"), "unknown"],
["a plain Error", new Error("nope"), "unknown"],
["undefined", undefined, "unknown"],
])("classifies %s", (_label, error, kind) => {
expect(classifyError(error)).toBe(kind);
});
it.each([200, 400, 403, 404, 409, 500])(
"treats the gateway's tenant_app_unavailable as transient in any status (%s)",
(status) => {
expect(classifyError(apiError(status, { error: "tenant_app_unavailable" }))).toBe("transient");
expect(classifyError(apiError(status, { error: "tenant_app_starting" }))).toBe("transient");
},
);
it.each(["WORKER_UNAVAILABLE", "TIMEOUT"])("treats plugin bridge %s as transient", (code) => {
expect(classifyError(apiError(500, { code, message: "Plugin worker is restarting" }))).toBe("transient");
});
it("reads a code from details, as HttpErrors serialize it", () => {
const error = apiError(409, { error: "Locked", details: { code: "tenant_app_starting" } });
expect(classifyError(error)).toBe("transient");
});
it("classifies structurally, without the ApiError class", () => {
expect(classifyError({ status: 503, body: null })).toBe("transient");
expect(classifyError({ name: "AuthApiError", status: 401, code: null })).toBe("auth");
});
});
describe("isConnectivityError", () => {
it("is true for server-wide outages only", () => {
expect(isConnectivityError(new TypeError("Failed to fetch"))).toBe(true);
expect(isConnectivityError(new ApiUnavailableError(200))).toBe(true);
expect(isConnectivityError(apiError(503))).toBe(true);
expect(isConnectivityError(apiError(404, { error: "tenant_app_unavailable" }))).toBe(true);
// Transient, but one route: left to query retry, not the app banner.
expect(isConnectivityError(apiError(429))).toBe(false);
expect(isConnectivityError(apiError(503, { code: "WORKER_UNAVAILABLE", message: "x" }))).toBe(false);
expect(isConnectivityError(apiError(500))).toBe(false);
expect(isConnectivityError(apiError(403))).toBe(false);
});
});
describe("describeError", () => {
const rawCode = /\b[a-z]+(?:_[a-z]+)+\b|\b[A-Z]+_[A-Z]+\b/;
it("never returns a raw code", () => {
const errors = [
apiError(503, { error: "tenant_app_unavailable" }),
apiError(200, { error: "tenant_app_starting" }),
apiError(404, { error: "issue_not_found" }),
apiError(500, { error: "internal_error" }),
apiError(503, { code: "WORKER_UNAVAILABLE", message: "WORKER_UNAVAILABLE" }),
new ApiError("tenant_app_unavailable", 503, { error: "tenant_app_unavailable" }),
];
for (const error of errors) {
const { title, body } = describeError(error);
expect(title).not.toMatch(rawCode);
expect(body).not.toMatch(rawCode);
}
});
it("uses the shared transient copy for outages", () => {
expect(describeError(new ApiUnavailableError(502))).toEqual({
title: "Connection interrupted",
body: "Paperclip is temporarily unavailable. Please try again in a moment.",
retryable: true,
});
expect(describeError(apiError(503, { error: "tenant_app_unavailable" }))).toMatchObject({
title: "Reconnecting to Paperclip",
retryable: true,
});
});
it("keeps a readable server message for client errors", () => {
expect(describeError(apiError(400, { error: "Title is required" }))).toEqual({
title: "Check your input",
body: "Title is required",
retryable: false,
});
});
it("falls back to the kind's copy when the server sent a code or nothing", () => {
expect(describeError(apiError(404, { error: "issue_not_found" })).body).toBe("This item doesn’t exist or was moved.");
expect(describeError(apiError(403, null))).toMatchObject({ title: "Not allowed", retryable: false });
expect(describeError(new Error("Something odd"))).toMatchObject({ body: "Something odd", retryable: true });
expect(describeError(undefined)).toMatchObject({ title: "Something went wrong", retryable: true });
});
it("names the action in the title for real failures, not outages", () => {
expect(describeError(apiError(409, { error: "Document is locked" }), { action: "save the document" })).toEqual({
title: "Couldn't save the document",
body: "Document is locked",
retryable: false,
});
expect(describeError(apiError(503), { action: "save the document" }).title).toBe("Connection interrupted");
});
});
describe("ApiError", () => {
it("keeps the raw body.error as code and a readable message", () => {
const error = apiError(503, { error: "tenant_app_unavailable" });
expect(error.code).toBe("tenant_app_unavailable");
expect(error.message).toBe("Paperclip is restarting or updating. Please try again in a moment.");
});
it("passes a readable server message through unchanged", () => {
const error = apiError(409, { error: "Document is locked" });
expect(error.code).toBe("Document is locked");
expect(error.message).toBe("Document is locked");
});
it("replaces the generic status line with readable copy", () => {
expect(apiError(404).message).toBe("This item doesn’t exist or was moved.");
expect(apiError(404).code).toBeNull();
});
it("exposes every code for matching", () => {
expect(errorCodes(apiError(403, { error: "Denied", code: "interaction_human_only", details: { code: "x_y" } })))
.toEqual(["Denied", "interaction_human_only", "x_y"]);
});
});
describe("isRawErrorCode", () => {
it.each(["tenant_app_unavailable", "WORKER_UNAVAILABLE", "TIMEOUT", "issue.not_found"])("%s is a code", (value) => {
expect(isRawErrorCode(value)).toBe(true);
});
it.each(["Forbidden", "Unauthorized", "Document is locked", "Request failed: 503", ""])("%s is not a code", (value) => {
expect(isRawErrorCode(value)).toBe(false);
});
});
describe("parseRetryAfter", () => {
it("parses delta-seconds", () => {
expect(parseRetryAfter("5")).toBe(5_000);
expect(parseRetryAfter(" 1.5 ")).toBe(1_500);
});
it("parses an HTTP date relative to now", () => {
const now = Date.parse("2026-10-09T12:00:00Z");
expect(parseRetryAfter("Fri, 09 Oct 2026 12:00:30 GMT", now)).toBe(30_000);
expect(parseRetryAfter("Fri, 09 Oct 2026 11:00:00 GMT", now)).toBe(0);
});
it("caps absurd values and ignores garbage", () => {
expect(parseRetryAfter("86400")).toBe(5 * 60_000);
expect(parseRetryAfter("soon")).toBeNull();
expect(parseRetryAfter(null)).toBeNull();
});
});