Something went wrong. Try again.
Monorepo for Tangled tangled.org
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250import { describe, expect, it, vi } from "vitest";import type { Did } from "@atcute/lexicons/syntax";import { DocumentNotFoundError } from "@atcute/identity-resolver";import type { OAuthUserAgent } from "@atcute/oauth-browser-client";
const agent = { sub: "did:plc:alice"} as unknown as OAuthUserAgent;
interface HarnessOptions { createError?: Error; putError?: Error; identityNotFound?: number; identityError?: Error;}
// mocks have to be installed before the module is loadedconst load = async ({ createError, putError, identityNotFound = 0, identityError}: HarnessOptions = {}) => { vi.resetModules(); const events: string[] = []; let attempts = 0; const resolveIdentity = vi.fn(async () => { events.push("plc:resolve"); if (++attempts <= identityNotFound) throw new DocumentNotFoundError("did:plc:repo" as Did); if (identityError) throw identityError; return { id: "did:plc:repo" }; }); vi.doMock("@atcute/identity-resolver", async (importOriginal) => ({ ...(await importOriginal<typeof import("@atcute/identity-resolver")>()), PlcDidDocumentResolver: class { resolve = resolveIdentity; } })); const records: unknown[] = []; const knotInputs: Record<string, unknown>[] = []; const knotAgents: OAuthUserAgent[] = []; const createRecord = vi.fn(async (_agent, _collection, record) => { events.push("record:create"); records.push(record); return { uri: "at://did:plc:alice/sh.tangled.repo/demo", cid: "initial-cid" }; }); const putRecord = vi.fn(async (_agent, _collection, _rkey, record, swapRecord) => { events.push("record:put"); if (putError) throw putError; records.push(record); return { uri: "at://did:plc:alice/sh.tangled.repo/demo", cid: "committed-cid", swapRecord }; }); const deleteRecord = vi.fn(async () => { events.push("record:delete"); });
vi.doMock("./write", () => ({ createRecord, putRecord, deleteRecord })); vi.doMock("./client", () => ({ createBobbinClient: ({ serviceUrl, agent: caller }: { serviceUrl: string; agent?: OAuthUserAgent; }) => ({ xrpc: { call: async (_schema: unknown, options: { input?: Record<string, unknown> }) => { if (serviceUrl === "https://bobbin.test") { events.push("bobbin:await"); return { ok: true, data: { status: "indexed" } }; } if (caller) knotAgents.push(caller); if (options.input) knotInputs.push(options.input); if (options.input && "repo" in options.input) { events.push("knot:delete"); return { ok: true, data: null }; } events.push("knot:create"); if (createError) throw createError; return { ok: true, data: { repoDid: "did:plc:repo" } }; } } }) }));
return { api: await import("./repoCreate"), events, records, knotInputs, knotAgents, createRecord, putRecord, deleteRecord, resolveIdentity };};
const input = { ownerDid: "did:plc:alice" as Did, ownerHandle: "alice.test", name: "Demo.git", description: "a repo", defaultBranch: "main", knot: "knot.test", spindle: "spindle.test"};
describe("repository creation", () => { it("uses the organization agent for the PDS record and knot creation", async () => { const { api, createRecord, putRecord, knotAgents } = await load(); const org = { sub: "did:plc:org" } as unknown as OAuthUserAgent; const result = await api.createRepo(org, "https://bobbin.test", { ...input, ownerDid: "did:plc:org", ownerHandle: "org.test" }); expect(createRecord.mock.calls[0][0]).toBe(org); expect(putRecord.mock.calls[0][0]).toBe(org); expect(knotAgents).toEqual([org]); expect(result.ownerHandle).toBe("org.test"); }); it("rejects an organization owner paired with the controller's session", async () => { const { api, createRecord } = await load(); await expect( api.createRepo(agent, "https://bobbin.test", { ...input, ownerDid: "did:plc:org", ownerHandle: "org.test" }) ).rejects.toThrow("active account changed"); expect(createRecord).not.toHaveBeenCalled(); });
it("announces the record before creating the knot repo, then commits the repo DID", async () => { const { api, events, records, putRecord } = await load();
const creation = await api.createRepo(agent, "https://bobbin.test", input);
expect(creation.name).toBe("Demo"); expect(events).toEqual([ "record:create", "bobbin:await", "knot:create", "plc:resolve", "record:put", "bobbin:await" ]); expect(records[0]).toMatchObject({ $type: "sh.tangled.repo", knot: "knot.test", name: "Demo", spindle: "spindle.test" }); expect(records[1]).toMatchObject({ repoDid: "did:plc:repo" }); expect(putRecord).toHaveBeenCalledWith( agent, "sh.tangled.repo", "demo", expect.anything(), "initial-cid" ); });
it("waits for PLC genesis before claiming the new repo DID", async () => { const { api, events, resolveIdentity } = await load({ identityNotFound: 2 }); vi.useFakeTimers(); try { const creation = api.createRepo(agent, "https://bobbin.test", input); await vi.runAllTimersAsync(); await creation; expect(resolveIdentity).toHaveBeenCalledTimes(3); expect(events.indexOf("record:put")).toBeGreaterThan(events.lastIndexOf("plc:resolve")); } finally { vi.useRealTimers(); } });
it("rolls back without publishing a repo DID when PLC never registers it", async () => { const { api, events, resolveIdentity } = await load({ identityNotFound: 10 }); vi.useFakeTimers(); try { const creation = api.createRepo(agent, "https://bobbin.test", input); const rejected = expect(creation).rejects.toThrow( "did not publish repository identity" ); await vi.runAllTimersAsync(); await rejected; expect(resolveIdentity).toHaveBeenCalledTimes(6); expect(events).not.toContain("record:put"); expect(events.slice(-2)).toEqual(["record:delete", "knot:delete"]); } finally { vi.useRealTimers(); } });
it("removes the pds record before cleaning up the knot when commit fails", async () => { const { api, events, deleteRecord } = await load({ putError: new Error("pds refused") });
await expect(api.createRepo(agent, "https://bobbin.test", input)).rejects.toThrow( "pds refused" );
expect(events.slice(-2)).toEqual(["record:delete", "knot:delete"]); expect(deleteRecord).toHaveBeenCalledWith(agent, "sh.tangled.repo", "demo", "initial-cid"); });
it("removes the announced record when the knot rejects creation", async () => { const { api, events } = await load({ createError: new Error("no capacity") });
await expect(api.createRepo(agent, "https://bobbin.test", input)).rejects.toThrow( "no capacity" );
expect(events).toContain("record:delete"); expect(events).not.toContain("knot:delete"); });
it("passes fork identity and clone source to both halves", async () => { const { api, records, knotInputs } = await load(); await api.createRepo(agent, "https://bobbin.test", { ...input, name: "fork", source: { record: "did:plc:upstream", cloneUrl: "https://knot.source/did:plc:upstream" } });
expect(records[0]).toMatchObject({ source: "did:plc:upstream" }); expect(knotInputs[0]).toMatchObject({ source: "https://knot.source/did:plc:upstream" }); });});
describe("repository names", () => { it.each(["", ".hidden", "trail.", "a/b", "a..b", "self", "bad name"])( "rejects %j", async (name) => { const { api } = await load(); expect(() => api.validateRepoName(name)).toThrow(); } );});