Skip to content
Sign up

flagon-io/g1t

public
00

Where people and agents ship software together. The open-source git platform for the whole job: issues, agents, checks and deploys to the edge.

gitagentscloudflarerustforgemcp
116 linesCodeBlameRaw
1import assert from "node:assert/strict";
2import test from "node:test";
3
4import {
5 PATIENCE_MS,
6 REFRESH_PATIENCE_MS,
7 installResilientFetch,
8 isNetworkFailure,
9 keepTrying,
10 refreshesCurrent,
11 retriable,
12 retryDelay,
13 watchBuildNavigation,
14} from "./resilient-fetch.ts";
15import { reconnectDelay } from "./reconnect.ts";
16
17const ORIGIN = "https://g1t.sh";
18const url = (path: string) => new URL(path, ORIGIN);
19
20test("only an active navigation carries its build; fetchers, refreshes and writes never force a document switch", async () => {
21 const calls: Headers[] = [];
22 const previous = Object.getOwnPropertyDescriptor(globalThis, "window");
23 let late: Promise<Response> | undefined;
24 const browser = {
25 location: new URL("https://g1t.sh/edit"),
26 fetch: async (_input: unknown, init?: RequestInit) => {
27 calls.push(new Headers(init?.headers));
28 return late ?? new Response(null);
29 },
30 };
31 Object.defineProperty(globalThis, "window", { value: browser, configurable: true });
32 let destination: { pathname: string; search: string } | undefined;
33 const stop = watchBuildNavigation(() => destination);
34 try {
35 installResilientFetch("old-build");
36 await browser.fetch("/notifications.data");
37 destination = { pathname: "/next", search: "?tab=one" };
38 await browser.fetch("/next.data?tab=one&_routes=root");
39 await browser.fetch("/unrelated.data");
40 await browser.fetch("/next.data?tab=one", { method: "POST" });
41 await browser.fetch("/edit.data");
42 await browser.fetch("https://external.example/next.data?tab=one");
43 assert.deepEqual(
44 calls.map((headers) => headers.get("x-g1t-build")),
45 [null, "old-build", null, null, null, null],
46 );
47 for (const path of ["/next.data?tab=one", "/__manifest?paths=/next"]) {
48 let finish!: (response: Response) => void;
49 late = new Promise<Response>((resolve) => {
50 finish = resolve;
51 });
52 const controller = new AbortController();
53 const abandoned = browser.fetch(path, { signal: controller.signal });
54 // A transport can finish after the second click canceled the first.
55 controller.abort();
56 const rejected = assert.rejects(abandoned, { name: "AbortError" });
57 finish(new Response(null, { status: 204, headers: { "X-Remix-Reload-Document": "true" } }));
58 await rejected;
59 late = undefined;
60 assert.equal((await browser.fetch("/newer.data")).status, 200);
61 }
62 } finally {
63 stop();
64 if (previous) Object.defineProperty(globalThis, "window", previous);
65 else Reflect.deleteProperty(globalThis, "window");
66 }
67});
68
69test("a request that got no answer, in each browser's words, is a network failure", () => {
70 assert.equal(isNetworkFailure(new TypeError("Failed to fetch")), true);
71 assert.equal(isNetworkFailure(new TypeError("NetworkError when attempting to fetch resource.")), true);
72 assert.equal(isNetworkFailure(new TypeError("Load failed")), true);
73});
74
75test("a stale build, an abort or a server's error is not", () => {
76 assert.equal(isNetworkFailure(new TypeError("Failed to fetch dynamically imported module: https://g1t.sh/assets/a.js")), false);
77 assert.equal(isNetworkFailure(new DOMException("The user aborted a request.", "AbortError")), false);
78 assert.equal(isNetworkFailure(new Error("Failed to fetch")), false);
79 assert.equal(isNetworkFailure({ status: 500 }), false);
80});
81
82test("only the router's own reads are sent again", () => {
83 assert.equal(retriable(url("/flagon-io/g1t/settings/repository.data?_routes=root"), "GET", ORIGIN), true);
84 assert.equal(retriable(url("/__manifest?p=/a"), "get", ORIGIN), true);
85 assert.equal(retriable(url("/flagon-io/g1t/settings/repository.data"), "POST", ORIGIN), false);
86 assert.equal(retriable(url("/-/notify"), "GET", ORIGIN), false);
87 assert.equal(retriable(new URL("https://otel.g1t.sh/x.data"), "GET", ORIGIN), false);
88});
89
90test("a read for the page already showing is a refresh; one for another page is a navigation", () => {
91 const here = { pathname: "/flagon-io/g1t/settings/repository", search: "" };
92 assert.equal(refreshesCurrent(url("/flagon-io/g1t/settings/repository.data?_routes=root,routes/repo/layout"), here), true);
93 assert.equal(refreshesCurrent(url("/flagon-io/g1t/issues.data"), here), false);
94 assert.equal(refreshesCurrent(url("/_root.data"), { pathname: "/", search: "" }), true);
95 assert.equal(refreshesCurrent(url("/a.data?tab=open&_routes=x"), { pathname: "/a", search: "?tab=open" }), true);
96 assert.equal(refreshesCurrent(url("/a.data?tab=closed"), { pathname: "/a", search: "?tab=open" }), false);
97});
98
99test("retries come quickly at first, then settle", () => {
100 assert.deepEqual([1, 2, 3, 4, 5, 9].map(retryDelay), [250, 500, 1000, 2000, 4000, 5000]);
101 assert.deepEqual([1, 2, 3, 4, 8].map(reconnectDelay), [3000, 6000, 12000, 24000, 30000]);
102});
103
104test("a refresh waits out the browser being offline, however long", () => {
105 assert.equal(keepTrying({ refresh: true, elapsedMs: 60 * 60_000, onlineMs: 0, erroring: false }, 5000), true);
106});
107
108test("a network that is up and never answers is no blip: a refresh gives up, and so does a click", () => {
109 assert.equal(keepTrying({ refresh: true, elapsedMs: 0, onlineMs: REFRESH_PATIENCE_MS - 5000, erroring: false }, 5000), true);
110 assert.equal(keepTrying({ refresh: true, elapsedMs: 0, onlineMs: REFRESH_PATIENCE_MS - 4000, erroring: false }, 5000), false);
111 assert.equal(keepTrying({ refresh: false, elapsedMs: PATIENCE_MS - 4000, onlineMs: 0, erroring: false }, 5000), false);
112});
113
114test("while the error page tries on its own, a read is tried once", () => {
115 assert.equal(keepTrying({ refresh: true, elapsedMs: 0, onlineMs: 0, erroring: true }, 250), false);
116});