Something went wrong. Try again.
Monorepo for Tangled forked from tangled.org/core
Something went wrong. Try again.
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273import { describe, expect, it, vi } from "vitest";import { didOf } from "#lib/api/syntax.ts";import type { OAuthUserAgent } from "@atcute/oauth-browser-client";import type { Fetch } from "#lib/fetch.ts";
vi.mock("#lib/auth/agent.ts", () => ({ createClient: () => ({}), mintServiceAuth: async () => "token", serviceDidForHost: (host: string) => `did:web:${host}`, hostForServiceDid: () => null}));
vi.mock("#lib/api/knot.ts", () => ({ knotCapabilities: async () => null}));
const { approvePipeline, retryPipeline } = await import("#lib/api/pipelineActions.ts");const agent = { sub: "did:plc:nel" } as unknown as OAuthUserAgent;const target = { repoDid: didOf("did:plc:repoproof") };const spindle = new URL("https://spindle.test");
const answer = (status: number, body?: unknown) => { const fetch = vi.fn<Fetch>( async () => new Response(body === undefined ? null : JSON.stringify(body), { status, headers: { "content-type": "application/json" } }) ); vi.stubGlobal("fetch", fetch); return fetch;};
describe("pipeline actions", () => { it("approves a pipeline on the repo's spindle", async () => { const fetch = answer(200);
await approvePipeline(agent, spindle, target, "3mypipeline"); const [url, init] = fetch.mock.calls[0]; expect(String(url)).toBe("https://spindle.test/xrpc/org.tangled.ci.approvePipeline"); expect(new Headers(init?.headers).get("authorization")).toBe("Bearer token"); expect(JSON.parse(String(init?.body))).toEqual({ repo: target.repoDid, pipeline: "3mypipeline" }); });
it("rejects with the spindle's reason", async () => { answer(400, { error: "PipelineNotBlocked", message: "the pipeline has no blocked workflow" });
await expect(approvePipeline(agent, spindle, target, "3mypipeline")).rejects.toThrow( "the pipeline has no blocked workflow" ); });
it("retries a pipeline and hands back the new run", async () => { const fetch = answer(200, { pipeline: "3mretried" });
await expect(retryPipeline(agent, spindle, target, "3mpipeline")).resolves.toBe( "3mretried" ); const [url, init] = fetch.mock.calls[0]; expect(String(url)).toBe("https://spindle.test/xrpc/org.tangled.ci.retryPipeline"); expect(JSON.parse(String(init?.body))).toEqual({ repo: target.repoDid, pipeline: "3mpipeline" }); });});