alice.pds.demo.boltless.dev
This repository has no description
1import { describe, expect, it, vi } from "vitest";
2import { createBobbinClient, type BobbinContext } from "./client";
3import { IdentityCache, type MiniDoc } from "./identity";
4
5const DOC: MiniDoc = { did: "did:plc:x", handle: "alice.test" };
6
7const docResponse = (doc: MiniDoc): Response =>
8 new Response(JSON.stringify(doc), {
9 status: 200,
10 headers: { "content-type": "application/json" }
11 });
12
13const makeCtx = (fetchMock: typeof globalThis.fetch): BobbinContext =>
14 createBobbinClient({ serviceUrl: "https://bobbin.test", fetch: fetchMock });
15
16const deferred = <T>(): { promise: Promise<T>; resolve: (value: T) => void } => {
17 let resolve!: (value: T) => void;
18 const promise = new Promise<T>((r) => {
19 resolve = r;
20 });
21 return { promise, resolve };
22};
23
24describe("IdentityCache.resolve", () => {
25 it("fetches on the first miss then serves the cached document", async () => {
26 const fetchMock = vi.fn<typeof globalThis.fetch>().mockResolvedValue(docResponse(DOC));
27 const cache = new IdentityCache(makeCtx(fetchMock));
28
29 const first = await cache.resolve("alice.test");
30 const second = await cache.resolve("alice.test");
31
32 expect(first).toEqual(DOC);
33 expect(second).toEqual(DOC);
34 expect(fetchMock).toHaveBeenCalledTimes(1);
35 expect((fetchMock.mock.calls[0][0] as URL).searchParams.get("identifier")).toBe("alice.test");
36 });
37
38 it("coalesces concurrent misses for the same key into one in-flight fetch", async () => {
39 const gate = deferred<Response>();
40 const fetchMock = vi.fn<typeof globalThis.fetch>().mockReturnValue(gate.promise);
41 const cache = new IdentityCache(makeCtx(fetchMock));
42
43 const a = cache.resolve("alice.test");
44 const b = cache.resolve("alice.test");
45 expect(fetchMock).toHaveBeenCalledTimes(1);
46
47 gate.resolve(docResponse(DOC));
48 const [ra, rb] = await Promise.all([a, b]);
49 expect(ra).toEqual(DOC);
50 expect(rb).toEqual(DOC);
51 expect(fetchMock).toHaveBeenCalledTimes(1);
52 });
53
54 it("re-fetches after the in-flight promise settles (no permanent stampede lock)", async () => {
55 const fetchMock = vi.fn<typeof globalThis.fetch>().mockResolvedValue(docResponse(DOC));
56 const cache = new IdentityCache(makeCtx(fetchMock));
57
58 await cache.resolve("bob.test");
59 fetchMock.mockResolvedValueOnce(docResponse({ did: "did:plc:y", handle: "carol.test" }));
60 await cache.resolve("carol.test");
61 expect(fetchMock).toHaveBeenCalledTimes(2);
62 });
63
64 it("populates both directions of the index from a resolved document", async () => {
65 const fetchMock = vi.fn<typeof globalThis.fetch>().mockResolvedValue(docResponse(DOC));
66 const cache = new IdentityCache(makeCtx(fetchMock));
67
68 await cache.resolve("alice.test");
69 expect(cache.didFor("alice.test")).toBe("did:plc:x");
70 expect(cache.handleFor("did:plc:x")).toBe("alice.test");
71 });
72});
73
74describe("IdentityCache.prime & map selection", () => {
75 it("seeds both directions without any fetch", () => {
76 const fetchMock = vi.fn<typeof globalThis.fetch>();
77 const cache = new IdentityCache(makeCtx(fetchMock));
78
79 cache.prime(DOC);
80 expect(cache.didFor("alice.test")).toBe("did:plc:x");
81 expect(cache.handleFor("did:plc:x")).toBe("alice.test");
82 expect(fetchMock).not.toHaveBeenCalled();
83 });
84
85 it("resolves a DID against the did map and a handle against the handle map", async () => {
86 const fetchMock = vi.fn<typeof globalThis.fetch>();
87 const cache = new IdentityCache(makeCtx(fetchMock));
88 cache.prime(DOC);
89
90 await expect(cache.resolve("did:plc:x")).resolves.toEqual(DOC);
91 await expect(cache.resolve("alice.test")).resolves.toEqual(DOC);
92 expect(fetchMock).not.toHaveBeenCalled();
93
94 // unknown dids miss the handle map and fetch.
95 fetchMock.mockResolvedValueOnce(docResponse({ did: "did:plc:z", handle: "dan.test" }));
96 await cache.resolve("did:plc:z");
97 expect(fetchMock).toHaveBeenCalledTimes(1);
98 expect((fetchMock.mock.calls[0][0] as URL).searchParams.get("identifier")).toBe("did:plc:z");
99 });
100});