Archive v0.6: catalog change detection and identity drift

apps/api/src/app.ts

@@ -16,6 +16,7 @@ import type {
 
 const UUID_RE =
   /^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i;
+const PROVIDER_SLUG_RE = /^[a-z0-9][a-z0-9-]*$/;
 
 type RunApiRepository = Pick<RunRepository, "ping" | "getRun">;
 type ControlQueue = Pick<PgRunJobQueue, "ping" | "enqueue" | "get">;
@@ -29,6 +30,7 @@ type ArchiveRepository = Pick<
   | "listModels"
   | "listTests"
   | "listRuns"
+  | "listCatalogChanges"
   | "getRun"
   | "getModel"
   | "getTest"
@@ -164,6 +166,39 @@ export function createApp(deps: AppDependencies) {
     return c.json({ tests: await deps.archive.listTests() });
   });
 
+  app.get("/v1/archive/changes", async (c) => {
+    if (!deps.archive) {
+      return c.json({ error: "archive_unavailable" }, 503);
+    }
+
+    const modelId = c.req.query("modelId");
+    const provider = c.req.query("provider");
+    const rawLimit = c.req.query("limit");
+
+    if (modelId && !UUID_RE.test(modelId)) {
+      return c.json({ error: "invalid_model_id" }, 400);
+    }
+    if (provider && !PROVIDER_SLUG_RE.test(provider)) {
+      return c.json({ error: "invalid_provider" }, 400);
+    }
+
+    const limit = rawLimit === undefined ? undefined : Number(rawLimit);
+    if (
+      limit !== undefined &&
+      (!Number.isInteger(limit) || limit < 1 || limit > 100)
+    ) {
+      return c.json({ error: "invalid_limit" }, 400);
+    }
+
+    return c.json({
+      changes: await deps.archive.listCatalogChanges({
+        ...(modelId ? { modelId } : {}),
+        ...(provider ? { providerSlug: provider } : {}),
+        ...(limit !== undefined ? { limit } : {}),
+      }),
+    });
+  });
+
   app.get("/v1/archive/models/:modelId", async (c) => {
     if (!deps.archive) {
       return c.json({ error: "archive_unavailable" }, 503);

apps/api/test/archive-api.test.ts

@@ -22,6 +22,49 @@ const archiveSource = {
   contentSha256: null,
 } as const;
 
+const archiveCatalogChange = {
+  id: `alias:${ALIAS_EVENT_ID}`,
+  changeType: "alias_target_changed",
+  occurredAt: "2026-09-02T00:00:00.000Z",
+  provider: {
+    id: "00000000-0000-4000-8000-000000000024",
+    slug: "deepseek",
+    name: "DeepSeek",
+  },
+  alias: {
+    id: ALIAS_ID,
+    value: "deepseek-flash",
+  },
+  changedFields: ["snapshot"],
+  previous: {
+    model: {
+      id: MODEL_ID,
+      canonicalSlug: "deepseek-flash",
+      marketingName: "DeepSeek Flash",
+    },
+    snapshot: null,
+    endpoint: null,
+    apiModelId: null,
+  },
+  current: {
+    model: {
+      id: MODEL_ID,
+      canonicalSlug: "deepseek-flash",
+      marketingName: "DeepSeek Flash",
+    },
+    snapshot: {
+      id: "00000000-0000-4000-8000-000000000034",
+      providerSnapshotId: "deepseek-flash-202609",
+    },
+    endpoint: null,
+    apiModelId: null,
+  },
+  previousRecordId: "00000000-0000-4000-8000-000000000042",
+  currentRecordId: ALIAS_EVENT_ID,
+  previousSource: archiveSource,
+  currentSource: archiveSource,
+} as const;
+
 
 function baseRuns() {
   return {
@@ -259,6 +302,7 @@ const archiveModelDetail = {
       snapshotId: null,
     },
   ],
+  identityDrift: [archiveCatalogChange],
   testCoverage: [
     {
       testCaseId: TEST_CASE_ID,
@@ -444,6 +488,7 @@ describe("Archive read API", () => {
           },
         ],
         listRuns: async () => [archiveRun],
+        listCatalogChanges: async () => [archiveCatalogChange],
         getRun: async (runId) => (runId === RUN_ID ? archiveRun : null),
         getModel: async (modelId) =>
           modelId === MODEL_ID ? archiveModelDetail : null,
@@ -471,6 +516,22 @@ describe("Archive read API", () => {
       ],
     });
 
+    const changes = await app.request(
+      `/v1/archive/changes?modelId=${MODEL_ID}&provider=deepseek&limit=10`,
+    );
+    expect(changes.status).toBe(200);
+    await expect(changes.json()).resolves.toMatchObject({
+      changes: [
+        {
+          changeType: "alias_target_changed",
+          changedFields: ["snapshot"],
+          current: {
+            snapshot: { providerSnapshotId: "deepseek-flash-202609" },
+          },
+        },
+      ],
+    });
+
     const model = await app.request("/v1/archive/models/" + MODEL_ID);
     expect(model.status).toBe(200);
     await expect(model.json()).resolves.toMatchObject({
@@ -530,6 +591,7 @@ describe("Archive read API", () => {
         listModels: async () => [],
         listTests: async () => [],
         listRuns: async () => [],
+        listCatalogChanges: async () => [],
         getRun: async () => null,
         getModel: async () => null,
         getTest: async () => null,
@@ -544,6 +606,15 @@ describe("Archive read API", () => {
     expect(
       (await app.request("/v1/archive/runs?limit=101")).status,
     ).toBe(400);
+    expect(
+      (await app.request("/v1/archive/changes?modelId=nope")).status,
+    ).toBe(400);
+    expect(
+      (await app.request("/v1/archive/changes?provider=Bad.Provider")).status,
+    ).toBe(400);
+    expect(
+      (await app.request("/v1/archive/changes?limit=101")).status,
+    ).toBe(400);
     expect(
       (await app.request("/v1/archive/models/nope")).status,
     ).toBe(400);

apps/web/src/modelapse.ts

@@ -82,6 +82,47 @@ export interface ArchiveSource {
   readonly contentSha256: string | null;
 }
 
+export interface ArchiveCatalogIdentityState {
+  readonly model: {
+    readonly id: string;
+    readonly canonicalSlug: string;
+    readonly marketingName: string;
+  } | null;
+  readonly snapshot: {
+    readonly id: string;
+    readonly providerSnapshotId: string;
+  } | null;
+  readonly endpoint: {
+    readonly id: string;
+    readonly path: string;
+    readonly baseUrl: string;
+    readonly hostname: string;
+  } | null;
+  readonly apiModelId: string | null;
+}
+
+export interface ArchiveCatalogChange {
+  readonly id: string;
+  readonly changeType: "alias_target_changed" | "execution_binding_changed";
+  readonly occurredAt: string;
+  readonly provider: {
+    readonly id: string;
+    readonly slug: string;
+    readonly name: string;
+  };
+  readonly alias: {
+    readonly id: string;
+    readonly value: string;
+  } | null;
+  readonly changedFields: readonly string[];
+  readonly previous: ArchiveCatalogIdentityState;
+  readonly current: ArchiveCatalogIdentityState;
+  readonly previousRecordId: string;
+  readonly currentRecordId: string;
+  readonly previousSource: ArchiveSource | null;
+  readonly currentSource: ArchiveSource;
+}
+
 export interface ArchiveModelAliasResolution {
   readonly id: string;
   readonly alias: {
@@ -220,6 +261,7 @@ export interface ArchiveModelDetail extends ArchiveModel {
   readonly aliasResolutions: readonly ArchiveModelAliasResolution[];
   readonly executionBindings: readonly ArchiveModelExecutionBinding[];
   readonly identityTimeline: readonly ArchiveIdentityTimelineEvent[];
+  readonly identityDrift: readonly ArchiveCatalogChange[];
   readonly testCoverage: readonly {
     readonly testCaseId: string;
     readonly familySlug: string;
@@ -786,6 +828,15 @@ export const getArchiveRun = createServerFn({ method: "POST" })
     }
   });
 
+export const getArchiveCatalogChanges = createServerFn({ method: "GET" }).handler(
+  async (): Promise<readonly ArchiveCatalogChange[]> => {
+    const result = await requestJson<{ changes: readonly ArchiveCatalogChange[] }>(
+      "/v1/archive/changes?limit=100",
+    );
+    return result.changes;
+  },
+);
+
 export const getArchiveCatalog = createServerFn({ method: "GET" }).handler(
   async (): Promise<ArchiveCatalog> => {
     const [models, tests] = await Promise.all([