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
57 linesCodeBlameRaw
1import assert from "node:assert/strict";
2import test from "node:test";
3
4import { PATIENCE_MS, REFRESH_PATIENCE_MS, isNetworkFailure, keepTrying, refreshesCurrent, retriable, retryDelay } from "./resilient-fetch.ts";
5import { reconnectDelay } from "./reconnect.ts";
6
7const ORIGIN = "https://g1t.sh";
8const url = (path: string) => new URL(path, ORIGIN);
9
10test("a request that got no answer, in each browser's words, is a network failure", () => {
11 assert.equal(isNetworkFailure(new TypeError("Failed to fetch")), true);
12 assert.equal(isNetworkFailure(new TypeError("NetworkError when attempting to fetch resource.")), true);
13 assert.equal(isNetworkFailure(new TypeError("Load failed")), true);
14});
15
16test("a stale build, an abort or a server's error is not", () => {
17 assert.equal(isNetworkFailure(new TypeError("Failed to fetch dynamically imported module: https://g1t.sh/assets/a.js")), false);
18 assert.equal(isNetworkFailure(new DOMException("The user aborted a request.", "AbortError")), false);
19 assert.equal(isNetworkFailure(new Error("Failed to fetch")), false);
20 assert.equal(isNetworkFailure({ status: 500 }), false);
21});
22
23test("only the router's own reads are sent again", () => {
24 assert.equal(retriable(url("/flagon-io/g1t/settings/repository.data?_routes=root"), "GET", ORIGIN), true);
25 assert.equal(retriable(url("/__manifest?p=/a"), "get", ORIGIN), true);
26 assert.equal(retriable(url("/flagon-io/g1t/settings/repository.data"), "POST", ORIGIN), false);
27 assert.equal(retriable(url("/-/notify"), "GET", ORIGIN), false);
28 assert.equal(retriable(new URL("https://otel.g1t.sh/x.data"), "GET", ORIGIN), false);
29});
30
31test("a read for the page already showing is a refresh; one for another page is a navigation", () => {
32 const here = { pathname: "/flagon-io/g1t/settings/repository", search: "" };
33 assert.equal(refreshesCurrent(url("/flagon-io/g1t/settings/repository.data?_routes=root,routes/repo/layout"), here), true);
34 assert.equal(refreshesCurrent(url("/flagon-io/g1t/issues.data"), here), false);
35 assert.equal(refreshesCurrent(url("/_root.data"), { pathname: "/", search: "" }), true);
36 assert.equal(refreshesCurrent(url("/a.data?tab=open&_routes=x"), { pathname: "/a", search: "?tab=open" }), true);
37 assert.equal(refreshesCurrent(url("/a.data?tab=closed"), { pathname: "/a", search: "?tab=open" }), false);
38});
39
40test("retries come quickly at first, then settle", () => {
41 assert.deepEqual([1, 2, 3, 4, 5, 9].map(retryDelay), [250, 500, 1000, 2000, 4000, 5000]);
42 assert.deepEqual([1, 2, 3, 4, 8].map(reconnectDelay), [3000, 6000, 12000, 24000, 30000]);
43});
44
45test("a refresh waits out the browser being offline, however long", () => {
46 assert.equal(keepTrying({ refresh: true, elapsedMs: 60 * 60_000, onlineMs: 0, erroring: false }, 5000), true);
47});
48
49test("a network that is up and never answers is no blip: a refresh gives up, and so does a click", () => {
50 assert.equal(keepTrying({ refresh: true, elapsedMs: 0, onlineMs: REFRESH_PATIENCE_MS - 5000, erroring: false }, 5000), true);
51 assert.equal(keepTrying({ refresh: true, elapsedMs: 0, onlineMs: REFRESH_PATIENCE_MS - 4000, erroring: false }, 5000), false);
52 assert.equal(keepTrying({ refresh: false, elapsedMs: PATIENCE_MS - 4000, onlineMs: 0, erroring: false }, 5000), false);
53});
54
55test("while the error page tries on its own, a read is tried once", () => {
56 assert.equal(keepTrying({ refresh: true, elapsedMs: 0, onlineMs: 0, erroring: true }, 250), false);
57});