Files
PaperClipAI/packages/db/src/client.test.ts
T
DottaandPaperclip fc6304dfe5 feat(runner): add experimental OpenAI Dot provider over MCP Events (#15402)
## Thinking Path

> - Paperclip manages AI agents, tasks, permissions, and execution
budgets.
> - Paperclip Runner gives each provider the same admitted task and tool
authority.
> - OpenAI Dot runs outside the local process tree and needs
asynchronous work delivery.
> - The merged MCP gateway supplies OAuth consent and signed event
delivery.
> - A personal assistant grant cannot safely stand in for an assigned
agent.
> - This pull request adds a separate Dot agent connection and a durable
Rust Runner bridge.
> - The operator can assign work to Dot and inspect its accepted work,
tool receipts, and result.

## Linked Issues or Issue Description

**Agent or provider**

OpenAI Dot, as an experimental provider of the existing Paperclip Runner
adapter.

**Why this adapter is useful**

An operator can assign normal Paperclip tasks to an existing Dot. Dot
can read its mailbox, request work on an assigned task, use admitted
task tools, and submit a result. Paperclip keeps company scope,
checkout, approvals, known budget limits, and activity attribution.

**How the agent is invoked**

A dedicated `/mcp/runner` OAuth resource pairs one Dot grant with one
agent. A signed MCP mailbox event wakes Dot. Dot explicitly accepts the
assignment. The Rust Runner owns the durable turn and operation
receipts. The first release supports self-hosted instances with a local
Runner controller.

**Additional context**

This extends the merged public MCP gateway from #14846 and the assistant
invitation and device-consent work from #14933. This also integrates the
merged assistant tool and configuration expansion in #15380. Dot retains
its dedicated agent resource and cannot receive personal configuration
permission. The public assistant connection remains a personal
connection.

## What Changed

- Add a durable Rust Dot provider and its TypeScript Runner driver.
- Add closed PRP v3 external-provider operations and native execution
input v6.
- Add company-scoped pairing, mailbox, assignment, and operation
records.
- Reuse merged browser/device consent, client metadata verification,
webhook admissions, refresh, secret rotation, and warm-standby gates.
- Keep Dot scopes, issuer, grants, event workers, and tool access
separate from personal assistant access.
- Add Dot configuration, pairing, readiness, and consent UI. Keep agent
grants out of the personal Connections entry.
- Regenerate the Dot-only migration after master. Preserve published
gateway migrations. Make the new migration safe to reapply.
- Document setup, recovery, accounting limits, evidence, and remaining
account qualification.
- Reverify reconnect callbacks and wake outstanding work with a fresh
mailbox reference; preserve the existing assignment and operation
receipts.
- Clean up Dot bindings and waiting runs on OAuth revoke and
refresh-token replay. Old grants cannot revoke replacement bindings.
- Restore the pairing reference when an unsaved agent form is reopened;
document board-only pairing routes in OpenAPI.
- Accept a clean Rust exit after the acknowledged shutdown receipt.
Unexpected exits still require recovery.
- Clear the cached binding after a successful revoke so a failed
connection refresh cannot restore it.
- Add production-component Storybook states and screenshots for pairing
and connection review. All preview account data is synthetic.
- Persist normalized completion, serialize Dot turns and durable work
admission, and poll subscription readiness.
- Serialize mailbox writes and cursor reads; retain paused fence
acknowledgement without task authority.
- Authorize admitted review runs without changing the worker assignee.
Include the fenced assignment ID in production stop notices.

## Verification

- This PR integrates master `4a8178e9c`. Dot migration
`0317_messy_famine.sql` follows the published history and is safe to
reapply. The merge preserves the reserved migration connection,
batch-commit handling, private task checks, task monitors, and native
accounting.
- Local workspace typecheck, full build, and UI token gates pass. The
server typecheck passes after the review fixes. Database and native
executor regressions pass.
- All twelve real Rust/PostgreSQL Dot integration tests and twelve Dot
driver tests pass. The tests cover native document writing and
finalization, durable replay, queue admission, mailbox ordering,
admitted reviews, stale authority, production stop references, and
paused acknowledgements.
- Current head `d0e7e0626` passes all 57 checks: 53 pass and four are
intentionally skipped. This includes full typecheck, build, tests, Rust
Runner verification, browser E2E, release verification, and Canary Dry
Run. Greptile rates this exact head 5/5. All review threads are
resolved.
- The full local root test run is slower than the sharded CI run and has
not completed. The full CI test gates pass on the current commit.
Focused local regressions pass.
- Real-account pairing and event delivery on this base commit remain
unqualified. Live account and setup proof are recorded in the follow-up
#15414.

The following screenshots use synthetic preview data. They show the
production pairing component and do not qualify a real account or the
full agent setup journey.

![Synthetic pairing
preview](https://github.com/paperclipai/paperclip/blob/codex/dot-events-prototype/doc/screenshots/openai-dot-runner/pairing.jpg?raw=true)

![Synthetic connected
preview](https://github.com/paperclipai/paperclip/blob/codex/dot-events-prototype/doc/screenshots/openai-dot-runner/connected.jpg?raw=true)

## Risks

- This base adapter uses `PAPERCLIP_ENABLE_OPENAI_DOT=1` plus Public MCP
and Paperclip Runner. The separate experimental-settings follow-up in
#15414 replaces this environment flag with saved operator settings.
- Dot does not expose provider token usage or cost. The operator must
acknowledge external billing. Known Paperclip budget gates still apply.
- Cancellation fences Paperclip authority. It does not confirm that Dot
stopped all external activity.
- Assigned skill files and third-party MCP bindings are unsupported and
reject admission. There is no mounted workspace, model selector, or
provider thread identifier.
- Hosted agent-broker and remote controller deployments are not
qualified.
- The new migration follows the merged master history. Existing
prototype databases still need the normal master migration history
before this Dot-only migration.

## Model Used

OpenAI Codex, based on GPT-6. The exact deployment ID and context window
size are not exposed in this session. Capabilities used: reasoning,
repository editing, code execution, and test inspection.

## Checklist

- [x] I have included a thinking path that traces from project context
to this change
- [x] I have specified the model used (with version and capability
details)
- [x] I have checked ROADMAP.md and confirmed this PR does not duplicate
planned core work
- [x] I have searched GitHub for duplicate or related PRs and linked
them above
- [x] I have either (a) linked existing issues with `Fixes: #` / `Closes
#` / `Refs #123` OR (b) described the issue in-PR following the relevant
issue template
- [x] I have not referenced internal/instance-local Paperclip issues or
links (only public GitHub references)
- [x] My branch name describes the change and contains no internal
Paperclip ticket id or instance-derived details
- [x] I have run tests locally and they pass
- [x] I have added or updated tests where applicable
- [x] I have updated relevant documentation to reflect my changes
- [x] I have considered and documented any risks above
- [x] All Paperclip CI gates are green
- [x] Greptile is 5/5 with no open P2s, recommendations, or follow-ups
- [x] I will address all Greptile and reviewer comments before
requesting merge

---------

Co-authored-by: Paperclip <noreply@paperclip.ing>
2026-10-07 19:11:50 -05:00

2103 lines
77 KiB
TypeScript

import { createHash } from "node:crypto";
import fs from "node:fs";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { drizzle } from "drizzle-orm/postgres-js";
import { migrate } from "drizzle-orm/postgres-js/migrator";
import { afterEach, describe, expect, it } from "vitest";
import postgres from "postgres";
import {
DEFAULT_DATABASE_APPLICATION_NAME,
applyPendingMigrations,
closeRegisteredClients,
createDb,
ensurePostgresDatabase,
inspectMigrations,
resetPostgresDatabase,
} from "./client.js";
import {
getEmbeddedPostgresTestSupport,
startEmbeddedPostgresTestDatabase,
} from "./test-embedded-postgres.js";
const cleanups: Array<() => Promise<void>> = [];
const embeddedPostgresSupport = await getEmbeddedPostgresTestSupport();
const describeEmbeddedPostgres = embeddedPostgresSupport.supported ? describe : describe.skip;
async function createTempDatabase(): Promise<string> {
const db = await startEmbeddedPostgresTestDatabase("paperclip-db-client-");
cleanups.push(db.cleanup);
return db.connectionString;
}
async function migrationHash(migrationFile: string): Promise<string> {
const content = await fs.promises.readFile(
new URL(`./migrations/${migrationFile}`, import.meta.url),
"utf8",
);
return createHash("sha256").update(content).digest("hex");
}
const userVisibleUpdatedAtTables = new Set([
"companies",
"heartbeat_runs",
"issue_comments",
"issues",
"routine_runs",
"routines",
]);
const migrationUpdatedAtUpdateAllowlist = new Map<string, ReadonlySet<string>>([
[
"0105_instance_scoped_environments.sql",
new Set(["issues"]),
],
[
"0131_repair_run_responsible_user_context_refs.sql",
new Set(["heartbeat_runs"]),
],
[
"0135_repair_run_responsible_user_updated_at_sweep.sql",
new Set(["companies", "heartbeat_runs", "issues", "routine_runs", "routines"]),
],
]);
function findUserVisibleUpdatedAtBackfillViolations(
migrationFile: string,
content: string,
): string[] {
const allowedTables = migrationUpdatedAtUpdateAllowlist.get(migrationFile) ?? new Set<string>();
const violations: string[] = [];
for (const statement of content.split("--> statement-breakpoint")) {
const updateMatch = statement.match(/\bUPDATE\s+"([^"]+)"/i);
if (!updateMatch) continue;
const tableName = updateMatch[1];
if (!userVisibleUpdatedAtTables.has(tableName)) continue;
if (!/\bSET\b[\s\S]*"updated_at"\s*=/i.test(statement)) continue;
if (allowedTables.has(tableName)) continue;
violations.push(`${migrationFile}: UPDATE "${tableName}" sets updated_at`);
}
return violations;
}
afterEach(async () => {
while (cleanups.length > 0) {
const cleanup = cleanups.pop();
await cleanup?.();
}
});
if (!embeddedPostgresSupport.supported) {
console.warn(
`Skipping embedded Postgres migration tests on this host: ${embeddedPostgresSupport.reason ?? "unsupported environment"}`,
);
}
describeEmbeddedPostgres("createDb pool defaults", () => {
it("names its backends and closes them once idle", async () => {
const url = await createTempDatabase();
const observer = postgres(url, { max: 1, onnotice: () => {} });
cleanups.push(async () => {
await observer.end({ timeout: 1 });
});
const backendsNamed = async (name: string) => {
const rows = await observer`
select count(*)::int as count from pg_stat_activity where application_name = ${name}
`;
return rows[0]?.count ?? 0;
};
const db = createDb(url);
cleanups.push(async () => {
await db.$client.end({ timeout: 1 });
});
const [self] = await db.$client`select application_name from pg_stat_activity where pid = pg_backend_pid()`;
expect(self?.application_name).toBe(DEFAULT_DATABASE_APPLICATION_NAME);
const shortLived = createDb(url, { applicationName: "paperclip-idle-test", idleTimeoutSeconds: 1 });
cleanups.push(async () => {
await shortLived.$client.end({ timeout: 1 });
});
await shortLived.$client`select 1`;
expect(await backendsNamed("paperclip-idle-test")).toBe(1);
// The driver closes the idle connection after `idle_timeout`; without the
// option (the driver default) the backend would stay until the process
// exits. Wait past the timeout, then poll PostgreSQL's own view.
const deadline = Date.now() + 10_000;
let remaining = await backendsNamed("paperclip-idle-test");
while (remaining > 0 && Date.now() < deadline) {
await new Promise((resolve) => setTimeout(resolve, 250));
remaining = await backendsNamed("paperclip-idle-test");
}
expect(remaining).toBe(0);
}, 30_000);
});
describeEmbeddedPostgres("resetPostgresDatabase", () => {
it("recreates an existing database so stale tables are removed", async () => {
const connectionString = await createTempDatabase();
const adminUrl = new URL(connectionString);
const databaseName = adminUrl.pathname.replace(/^\//, "");
adminUrl.pathname = "/postgres";
const setupSql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
await setupSql.unsafe(`CREATE TABLE stale_reseed_target_only (id integer PRIMARY KEY)`);
} finally {
await setupSql.end();
}
await resetPostgresDatabase(adminUrl.toString(), databaseName);
const verifySql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const rows = await verifySql.unsafe<{ stale_table: string | null }[]>(
`SELECT to_regclass('public.stale_reseed_target_only')::text AS stale_table`,
);
expect(rows[0]?.stale_table).toBeNull();
} finally {
await verifySql.end();
}
}, 30_000);
});
describeEmbeddedPostgres("applyPendingMigrations", () => {
it("upgrades an older clone whose replaced connection constraint is already absent", async () => {
const clusterUrl = new URL(await createTempDatabase());
const databaseName = "missing_connection_constraint";
clusterUrl.pathname = "/postgres";
await ensurePostgresDatabase(clusterUrl.toString(), databaseName);
clusterUrl.pathname = "/" + databaseName;
const connectionString = clusterUrl.toString();
const prefixFolder = await fs.promises.mkdtemp(join(tmpdir(), "paperclip-migration-prefix-"));
cleanups.push(() => fs.promises.rm(prefixFolder, { recursive: true, force: true }));
await fs.promises.mkdir(join(prefixFolder, "meta"));
const journal = JSON.parse(await fs.promises.readFile(new URL("./migrations/meta/_journal.json", import.meta.url), "utf8"));
journal.entries = journal.entries.filter((entry: { idx: number }) => entry.idx < 255);
await fs.promises.writeFile(join(prefixFolder, "meta/_journal.json"), JSON.stringify(journal));
for (const entry of journal.entries) {
await fs.promises.copyFile(new URL(`./migrations/${entry.tag}.sql`, import.meta.url), join(prefixFolder, `${entry.tag}.sql`));
}
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
await migrate(drizzle(sql), { migrationsFolder: prefixFolder });
await sql`ALTER TABLE "tool_connections" DROP CONSTRAINT "tool_connections_transport_check"`;
await applyPendingMigrations(connectionString);
expect((await inspectMigrations(connectionString)).status).toBe("upToDate");
const [constraint] = await sql<{ definition: string }[]>`
SELECT pg_get_constraintdef(oid) AS definition FROM pg_constraint
WHERE conrelid = 'tool_connections'::regclass AND conname = 'tool_connections_transport_check'
`;
expect(constraint?.definition).toContain("chat_sdk");
expect(constraint?.definition).toContain("runtime_auth");
} finally { await sql.end(); }
}, 30_000);
it("upgrades renumbered recovery migrations and replays their schema idempotently", async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const recoveryFiles = [
"0250_exotic_dakota_north.sql", "0251_narrow_mastermind.sql",
"0252_friendly_kate_bishop.sql", "0253_real_firebrand.sql",
"0254_military_calypso.sql",
];
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
// An instance may have applied this identical SQL under the pre-rebase
// numbers, before the new session-goal and tool-action migrations existed.
for (const file of recoveryFiles) {
const hash = await migrationHash(file);
await sql`UPDATE "drizzle"."__drizzle_migrations" SET created_at = 1788825600000 WHERE hash = ${hash}`;
const source = await fs.promises.readFile(new URL(`./migrations/${file}`, import.meta.url), "utf8");
for (const statement of source.split("--> statement-breakpoint")) {
if (statement.trim()) await sql.unsafe(statement);
}
}
for (const file of ["0248_small_manta.sql", "0249_fast_silverclaw.sql"]) {
const hash = await migrationHash(file);
await sql`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = ${hash}`;
}
await applyPendingMigrations(connectionString);
expect((await inspectMigrations(connectionString)).status).toBe("upToDate");
for (const file of recoveryFiles) {
const hash = await migrationHash(file);
const rows = await sql`SELECT id FROM "drizzle"."__drizzle_migrations" WHERE hash = ${hash}`;
expect(rows).toHaveLength(1);
}
const indexes = await sql`SELECT indexname FROM pg_indexes WHERE indexname = 'heartbeat_runs_native_replacement_predecessor_uq'`;
expect(indexes).toHaveLength(1);
} finally {
await sql.end();
}
}, 30_000);
it("rejects unallowlisted migration backfills that bump updated_at on user-visible tables", async () => {
const entries = await fs.promises.readdir(new URL("./migrations", import.meta.url), {
withFileTypes: true,
});
const violations: string[] = [];
for (const entry of entries) {
if (!entry.isFile() || !entry.name.endsWith(".sql")) continue;
const content = await fs.promises.readFile(
new URL(`./migrations/${entry.name}`, import.meta.url),
"utf8",
);
violations.push(...findUserVisibleUpdatedAtBackfillViolations(entry.name, content));
}
expect(violations).toEqual([]);
expect(
findUserVisibleUpdatedAtBackfillViolations(
"9999_bad_backfill.sql",
`
UPDATE "issues" AS i
SET "responsible_user_id" = 'owner-user',
"updated_at" = now()
WHERE i."responsible_user_id" IS NULL;
`,
),
).toEqual(['9999_bad_backfill.sql: UPDATE "issues" sets updated_at']);
});
it(
"applies an inserted earlier migration without replaying later legacy migrations",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const richMagnetoHash = await migrationHash("0030_rich_magneto.sql");
await sql.unsafe(
`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = '${richMagnetoHash}'`,
);
await sql.unsafe(`DROP TABLE "company_logos"`);
} finally {
await sql.end();
}
const pendingState = await inspectMigrations(connectionString);
expect(pendingState).toMatchObject({
status: "needsMigrations",
pendingMigrations: ["0030_rich_magneto.sql"],
reason: "pending-migrations",
});
await applyPendingMigrations(connectionString);
const finalState = await inspectMigrations(connectionString);
expect(finalState.status).toBe("upToDate");
const verifySql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const rows = await verifySql.unsafe<{ table_name: string }[]>(
`
SELECT table_name
FROM information_schema.tables
WHERE table_schema = 'public'
AND table_name IN ('company_logos', 'execution_workspaces')
ORDER BY table_name
`,
);
expect(rows.map((row) => row.table_name)).toEqual([
"company_logos",
"execution_workspaces",
]);
} finally {
await verifySql.end();
}
},
20_000,
);
it(
"replays migration 0044 safely when its schema changes already exist",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const illegalToadHash = await migrationHash("0044_illegal_toad.sql");
await sql.unsafe(
`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = '${illegalToadHash}'`,
);
const columns = await sql.unsafe<{ column_name: string }[]>(
`
SELECT column_name
FROM information_schema.columns
WHERE table_schema = 'public'
AND table_name = 'instance_settings'
AND column_name = 'general'
`,
);
expect(columns).toHaveLength(1);
} finally {
await sql.end();
}
const pendingState = await inspectMigrations(connectionString);
expect(pendingState).toMatchObject({
status: "needsMigrations",
pendingMigrations: ["0044_illegal_toad.sql"],
reason: "pending-migrations",
});
await applyPendingMigrations(connectionString);
const finalState = await inspectMigrations(connectionString);
expect(finalState.status).toBe("upToDate");
},
20_000,
);
it(
"enforces a unique board_api_keys.key_hash after migration 0044",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
await sql.unsafe(`
INSERT INTO "user" ("id", "name", "email", "email_verified", "created_at", "updated_at")
VALUES ('user-1', 'User One', 'user@example.com', true, now(), now())
`);
await sql.unsafe(`
INSERT INTO "board_api_keys" ("id", "user_id", "name", "key_hash", "created_at")
VALUES ('00000000-0000-0000-0000-000000000001', 'user-1', 'Key One', 'dup-hash', now())
`);
await expect(
sql.unsafe(`
INSERT INTO "board_api_keys" ("id", "user_id", "name", "key_hash", "created_at")
VALUES ('00000000-0000-0000-0000-000000000002', 'user-1', 'Key Two', 'dup-hash', now())
`),
).rejects.toThrow();
} finally {
await sql.end();
}
},
20_000,
);
it(
"replays migration 0046 safely when document revision columns already exist",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const smoothSentinelsHash = await migrationHash("0046_smooth_sentinels.sql");
await sql.unsafe(
`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = '${smoothSentinelsHash}'`,
);
const columns = await sql.unsafe<{ column_name: string; is_nullable: string; column_default: string | null }[]>(
`
SELECT column_name, is_nullable, column_default
FROM information_schema.columns
WHERE table_schema = 'public'
AND table_name = 'document_revisions'
AND column_name IN ('title', 'format')
ORDER BY column_name
`,
);
expect(columns).toHaveLength(2);
} finally {
await sql.end();
}
const pendingState = await inspectMigrations(connectionString);
expect(pendingState).toMatchObject({
status: "needsMigrations",
pendingMigrations: ["0046_smooth_sentinels.sql"],
reason: "pending-migrations",
});
await applyPendingMigrations(connectionString);
const finalState = await inspectMigrations(connectionString);
expect(finalState.status).toBe("upToDate");
const verifySql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const columns = await verifySql.unsafe<{ column_name: string; is_nullable: string; column_default: string | null }[]>(
`
SELECT column_name, is_nullable, column_default
FROM information_schema.columns
WHERE table_schema = 'public'
AND table_name = 'document_revisions'
AND column_name IN ('title', 'format')
ORDER BY column_name
`,
);
expect(columns).toEqual([
expect.objectContaining({
column_name: "format",
is_nullable: "NO",
}),
expect.objectContaining({
column_name: "title",
is_nullable: "YES",
}),
]);
expect(columns[0]?.column_default).toContain("'markdown'");
} finally {
await verifySql.end();
}
},
20_000,
);
it(
"replays migration 0047 safely when feedback tables and run columns already exist",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const overjoyedGrootHash = await migrationHash("0047_overjoyed_groot.sql");
await sql.unsafe(
`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = '${overjoyedGrootHash}'`,
);
const tables = await sql.unsafe<{ table_name: string }[]>(
`
SELECT table_name
FROM information_schema.tables
WHERE table_schema = 'public'
AND table_name IN ('feedback_exports', 'feedback_votes')
ORDER BY table_name
`,
);
expect(tables.map((row) => row.table_name)).toEqual([
"feedback_exports",
"feedback_votes",
]);
const columns = await sql.unsafe<{ table_name: string; column_name: string }[]>(
`
SELECT table_name, column_name
FROM information_schema.columns
WHERE table_schema = 'public'
AND (
(table_name = 'companies' AND column_name IN (
'feedback_data_sharing_enabled',
'feedback_data_sharing_consent_at',
'feedback_data_sharing_consent_by_user_id',
'feedback_data_sharing_terms_version'
))
OR (table_name = 'document_revisions' AND column_name = 'created_by_run_id')
OR (table_name = 'issue_comments' AND column_name = 'created_by_run_id')
)
ORDER BY table_name, column_name
`,
);
expect(columns).toHaveLength(6);
} finally {
await sql.end();
}
const pendingState = await inspectMigrations(connectionString);
expect(pendingState).toMatchObject({
status: "needsMigrations",
pendingMigrations: ["0047_overjoyed_groot.sql"],
reason: "pending-migrations",
});
await applyPendingMigrations(connectionString);
const finalState = await inspectMigrations(connectionString);
expect(finalState.status).toBe("upToDate");
const verifySql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const constraints = await verifySql.unsafe<{ conname: string }[]>(
`
SELECT conname
FROM pg_constraint
WHERE conname IN (
'feedback_exports_company_id_companies_id_fk',
'feedback_exports_feedback_vote_id_feedback_votes_id_fk',
'feedback_exports_issue_id_issues_id_fk',
'feedback_votes_company_id_companies_id_fk',
'feedback_votes_issue_id_issues_id_fk'
)
ORDER BY conname
`,
);
expect(constraints.map((row) => row.conname)).toEqual([
"feedback_exports_company_id_companies_id_fk",
"feedback_exports_feedback_vote_id_feedback_votes_id_fk",
"feedback_exports_issue_id_issues_id_fk",
"feedback_votes_company_id_companies_id_fk",
"feedback_votes_issue_id_issues_id_fk",
]);
} finally {
await verifySql.end();
}
},
20_000,
);
it(
"replays migration 0048 safely when routines.variables already exists",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const flashyMarrowHash = await migrationHash("0048_flashy_marrow.sql");
await sql.unsafe(
`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = '${flashyMarrowHash}'`,
);
const columns = await sql.unsafe<{ column_name: string }[]>(
`
SELECT column_name
FROM information_schema.columns
WHERE table_schema = 'public'
AND table_name = 'routines'
AND column_name = 'variables'
`,
);
expect(columns).toHaveLength(1);
} finally {
await sql.end();
}
const pendingState = await inspectMigrations(connectionString);
expect(pendingState).toMatchObject({
status: "needsMigrations",
pendingMigrations: ["0048_flashy_marrow.sql"],
reason: "pending-migrations",
});
await applyPendingMigrations(connectionString);
const finalState = await inspectMigrations(connectionString);
expect(finalState.status).toBe("upToDate");
const verifySql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const columns = await verifySql.unsafe<{ column_name: string; is_nullable: string; data_type: string }[]>(
`
SELECT column_name, is_nullable, data_type
FROM information_schema.columns
WHERE table_schema = 'public'
AND table_name = 'routines'
AND column_name = 'variables'
`,
);
expect(columns).toEqual([
expect.objectContaining({
column_name: "variables",
is_nullable: "NO",
data_type: "jsonb",
}),
]);
} finally {
await verifySql.end();
}
},
20_000,
);
it(
"replays migration 0050 safely when projects.env already exists",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const stiffLuckmanHash = await migrationHash("0050_stiff_luckman.sql");
await sql.unsafe(
`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = '${stiffLuckmanHash}'`,
);
const columns = await sql.unsafe<{ column_name: string }[]>(
`
SELECT column_name
FROM information_schema.columns
WHERE table_schema = 'public'
AND table_name = 'projects'
AND column_name = 'env'
`,
);
expect(columns).toHaveLength(1);
} finally {
await sql.end();
}
const pendingState = await inspectMigrations(connectionString);
expect(pendingState).toMatchObject({
status: "needsMigrations",
pendingMigrations: ["0050_stiff_luckman.sql"],
reason: "pending-migrations",
});
await applyPendingMigrations(connectionString);
const finalState = await inspectMigrations(connectionString);
expect(finalState.status).toBe("upToDate");
const verifySql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const columns = await verifySql.unsafe<{ column_name: string; is_nullable: string; data_type: string }[]>(
`
SELECT column_name, is_nullable, data_type
FROM information_schema.columns
WHERE table_schema = 'public'
AND table_name = 'projects'
AND column_name = 'env'
`,
);
expect(columns).toEqual([
expect.objectContaining({
column_name: "env",
is_nullable: "YES",
data_type: "jsonb",
}),
]);
} finally {
await verifySql.end();
}
},
20_000,
);
it(
"replays migration 0059 safely when plugin_database_namespaces already exists",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const pluginNamespacesHash = await migrationHash(
"0059_plugin_database_namespaces.sql",
);
await sql.unsafe(
`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = '${pluginNamespacesHash}'`,
);
const tables = await sql.unsafe<{ table_name: string }[]>(
`
SELECT table_name
FROM information_schema.tables
WHERE table_schema = 'public'
AND table_name IN ('plugin_database_namespaces', 'plugin_migrations')
ORDER BY table_name
`,
);
expect(tables.map((row) => row.table_name)).toEqual([
"plugin_database_namespaces",
"plugin_migrations",
]);
} finally {
await sql.end();
}
const pendingState = await inspectMigrations(connectionString);
expect(pendingState).toMatchObject({
status: "needsMigrations",
pendingMigrations: ["0059_plugin_database_namespaces.sql"],
reason: "pending-migrations",
});
await applyPendingMigrations(connectionString);
const finalState = await inspectMigrations(connectionString);
expect(finalState.status).toBe("upToDate");
const verifySql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const indexes = await verifySql.unsafe<{ indexname: string }[]>(
`
SELECT indexname
FROM pg_indexes
WHERE schemaname = 'public'
AND tablename IN ('plugin_database_namespaces', 'plugin_migrations')
ORDER BY indexname
`,
);
expect(indexes.map((row) => row.indexname)).toEqual(
expect.arrayContaining([
"plugin_database_namespaces_namespace_idx",
"plugin_database_namespaces_plugin_idx",
"plugin_database_namespaces_status_idx",
"plugin_migrations_plugin_idx",
"plugin_migrations_plugin_key_idx",
"plugin_migrations_status_idx",
]),
);
} finally {
await verifySql.end();
}
},
20_000,
);
it(
"replays the built-in managed resources migration after the legacy 0136 journal entry",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const builtInResourcesHash = await migrationHash(
"0140_built_in_managed_resources.sql",
);
const legacyBuiltInResourcesHash = createHash("sha256")
.update("legacy 0136_built_in_managed_resources.sql")
.digest("hex");
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
await sql.unsafe(
`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = '${builtInResourcesHash}'`,
);
await sql.unsafe(
`
INSERT INTO "drizzle"."__drizzle_migrations" ("hash", "created_at")
VALUES ('${legacyBuiltInResourcesHash}', 1783555200000)
`,
);
await sql.unsafe(`
ALTER TABLE "built_in_managed_resources"
DROP CONSTRAINT IF EXISTS "built_in_managed_resources_company_id_companies_id_fk"
`);
await sql.unsafe(`DROP INDEX IF EXISTS "built_in_managed_resources_company_idx"`);
await sql.unsafe(`DROP INDEX IF EXISTS "built_in_managed_resources_resource_idx"`);
await sql.unsafe(`DROP INDEX IF EXISTS "built_in_managed_resources_company_bundle_resource_uq"`);
} finally {
await sql.end();
}
const pendingState = await inspectMigrations(connectionString);
expect(pendingState).toMatchObject({
status: "needsMigrations",
pendingMigrations: ["0140_built_in_managed_resources.sql"],
reason: "pending-migrations",
});
await applyPendingMigrations(connectionString);
const finalState = await inspectMigrations(connectionString);
expect(finalState.status).toBe("upToDate");
const verifySql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const rows = await verifySql.unsafe<{
foreign_key_exists: boolean;
company_index_exists: boolean;
resource_index_exists: boolean;
unique_index_exists: boolean;
}[]>(`
SELECT
EXISTS (
SELECT 1
FROM "pg_constraint" c
JOIN "pg_class" t ON t.oid = c.conrelid
JOIN "pg_namespace" n ON n.oid = t.relnamespace
WHERE n.nspname = 'public'
AND t.relname = 'built_in_managed_resources'
AND c.conname = 'built_in_managed_resources_company_id_companies_id_fk'
) AS "foreign_key_exists",
EXISTS (
SELECT 1
FROM "pg_class" c
JOIN "pg_namespace" n ON n.oid = c.relnamespace
WHERE n.nspname = 'public'
AND c.relkind = 'i'
AND c.relname = 'built_in_managed_resources_company_idx'
) AS "company_index_exists",
EXISTS (
SELECT 1
FROM "pg_class" c
JOIN "pg_namespace" n ON n.oid = c.relnamespace
WHERE n.nspname = 'public'
AND c.relkind = 'i'
AND c.relname = 'built_in_managed_resources_resource_idx'
) AS "resource_index_exists",
EXISTS (
SELECT 1
FROM "pg_class" c
JOIN "pg_namespace" n ON n.oid = c.relnamespace
WHERE n.nspname = 'public'
AND c.relkind = 'i'
AND c.relname = 'built_in_managed_resources_company_bundle_resource_uq'
) AS "unique_index_exists"
`);
expect(rows[0]).toEqual({
foreign_key_exists: true,
company_index_exists: true,
resource_index_exists: true,
unique_index_exists: true,
});
} finally {
await verifySql.end();
}
},
20_000,
);
it(
"replays migration 0134 without bumping issue updated_at for inbox archives",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const runResponsibleUserHash = await migrationHash(
"0134_run_responsible_user_invariant.sql",
);
await sql.unsafe(`
INSERT INTO "companies" ("id", "name", "issue_prefix", "created_at", "updated_at")
VALUES (
'00000000-0000-0000-0000-000000000120',
'Migration Inbox Co',
'TST120',
'2026-03-26T09:00:00.000Z',
'2026-03-26T09:00:00.000Z'
)
`);
await sql.unsafe(`
INSERT INTO "company_memberships" (
"id",
"company_id",
"principal_type",
"principal_id",
"status",
"membership_role",
"created_at",
"updated_at"
)
VALUES (
'00000000-0000-0000-0000-000000000121',
'00000000-0000-0000-0000-000000000120',
'user',
'owner-user',
'active',
'owner',
'2026-03-26T09:00:00.000Z',
'2026-03-26T09:00:00.000Z'
)
`);
await sql.unsafe(`
INSERT INTO "issues" (
"id",
"company_id",
"title",
"status",
"responsible_user_id",
"created_at",
"updated_at"
)
VALUES (
'00000000-0000-0000-0000-000000000122',
'00000000-0000-0000-0000-000000000120',
'Archived issue needing responsible user backfill',
'todo',
NULL,
'2026-03-26T10:00:00.000Z',
'2026-03-26T10:00:00.000Z'
)
`);
await sql.unsafe(`
INSERT INTO "issue_inbox_archives" (
"id",
"company_id",
"issue_id",
"user_id",
"archived_at",
"created_at",
"updated_at"
)
VALUES (
'00000000-0000-0000-0000-000000000123',
'00000000-0000-0000-0000-000000000120',
'00000000-0000-0000-0000-000000000122',
'owner-user',
'2026-03-26T12:00:00.000Z',
'2026-03-26T12:00:00.000Z',
'2026-03-26T12:00:00.000Z'
)
`);
await sql.unsafe(
`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = '${runResponsibleUserHash}'`,
);
} finally {
await sql.end();
}
const pendingState = await inspectMigrations(connectionString);
expect(pendingState).toMatchObject({
status: "needsMigrations",
pendingMigrations: ["0134_run_responsible_user_invariant.sql"],
reason: "pending-migrations",
});
await applyPendingMigrations(connectionString);
const verifySql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const rows = await verifySql.unsafe<{
responsible_user_id: string | null;
updated_at: Date;
inbox_archive_still_current: boolean;
}[]>(`
SELECT
i."responsible_user_id",
i."updated_at",
EXISTS (
SELECT 1
FROM "issue_inbox_archives" AS archive
WHERE archive."company_id" = i."company_id"
AND archive."issue_id" = i."id"
AND archive."user_id" = 'owner-user'
AND archive."archived_at" >= i."updated_at"
) AS "inbox_archive_still_current"
FROM "issues" AS i
WHERE i."id" = '00000000-0000-0000-0000-000000000122'
`);
expect(rows).toHaveLength(1);
expect(rows[0]?.responsible_user_id).toBe("owner-user");
expect(rows[0]?.updated_at.toISOString()).toBe("2026-03-26T10:00:00.000Z");
expect(rows[0]?.inbox_archive_still_current).toBe(true);
} finally {
await verifySql.end();
}
},
20_000,
);
it(
"replays migration 0135 to repair updated_at sweeps and no-op when clean",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const repairSweepHash = await migrationHash(
"0135_repair_run_responsible_user_updated_at_sweep.sql",
);
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
await sql.unsafe(`
INSERT INTO "companies" ("id", "name", "issue_prefix", "created_at", "updated_at")
VALUES (
'00000000-0000-0000-0000-000000000240',
'Clean Migration Co',
'CLN134',
'2026-04-01T09:00:00.000Z',
'2026-04-02T09:00:00.000Z'
)
`);
await sql.unsafe(`
INSERT INTO "issues" ("id", "company_id", "title", "status", "created_at", "updated_at")
VALUES (
'00000000-0000-0000-0000-000000000241',
'00000000-0000-0000-0000-000000000240',
'Clean issue should not be touched',
'todo',
'2026-04-01T10:00:00.000Z',
'2026-04-02T10:00:00.000Z'
)
`);
await sql.unsafe(
`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = '${repairSweepHash}'`,
);
} finally {
await sql.end();
}
await applyPendingMigrations(connectionString);
const afterCleanReplay = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const cleanRows = await afterCleanReplay.unsafe<{ updated_at: Date }[]>(`
SELECT "updated_at"
FROM "issues"
WHERE "id" = '00000000-0000-0000-0000-000000000241'
`);
expect(cleanRows[0]?.updated_at.toISOString()).toBe("2026-04-02T10:00:00.000Z");
await afterCleanReplay.unsafe(`
INSERT INTO "companies" ("id", "name", "issue_prefix", "created_at", "updated_at")
VALUES (
'00000000-0000-0000-0000-000000000250',
'Sweep Migration Co',
'SWP134',
'2026-01-01T00:00:00.000Z',
'2026-04-03T12:00:00.123456Z'
)
`);
await afterCleanReplay.unsafe(`
INSERT INTO "agents" ("id", "company_id", "name", "role", "adapter_type", "created_at", "updated_at")
VALUES (
'00000000-0000-0000-0000-000000000251',
'00000000-0000-0000-0000-000000000250',
'Sweep Agent',
'general',
'process',
'2026-01-02T00:00:00.000Z',
'2026-01-02T00:00:00.000Z'
)
`);
await afterCleanReplay.unsafe(`
INSERT INTO "issues" ("id", "company_id", "title", "status", "created_at", "updated_at")
SELECT
('10000000-0000-0000-0000-' || lpad(gs::text, 12, '0'))::uuid,
'00000000-0000-0000-0000-000000000250',
'Swept issue ' || gs::text,
'todo',
'2026-02-01T00:00:00.000Z'::timestamptz + (gs::text || ' minutes')::interval,
'2026-04-03T12:00:00.123456Z'
FROM generate_series(1, 101) AS gs
`);
await afterCleanReplay.unsafe(`
UPDATE "issues"
SET
"status" = 'done',
"completed_at" = '2026-04-03T12:00:00.123456Z'
WHERE "id" = '10000000-0000-0000-0000-000000000003'
`);
await afterCleanReplay.unsafe(`
INSERT INTO "issue_comments" ("id", "company_id", "issue_id", "body", "created_at", "updated_at")
VALUES (
'00000000-0000-0000-0000-000000000252',
'00000000-0000-0000-0000-000000000250',
'10000000-0000-0000-0000-000000000001',
'Latest pre-sweep activity',
'2026-03-01T15:30:00.000Z',
'2026-03-02T16:45:00.000Z'
)
`);
await afterCleanReplay.unsafe(`
INSERT INTO "heartbeat_runs" (
"id",
"company_id",
"agent_id",
"status",
"started_at",
"finished_at",
"created_at",
"updated_at"
)
VALUES (
'00000000-0000-0000-0000-000000000253',
'00000000-0000-0000-0000-000000000250',
'00000000-0000-0000-0000-000000000251',
'completed',
'2026-02-10T10:00:00.000Z',
'2026-02-10T10:30:00.000Z',
'2026-02-10T09:55:00.000Z',
'2026-04-03T12:00:00.123456Z'
)
`);
await afterCleanReplay.unsafe(`
INSERT INTO "heartbeat_runs" (
"id",
"company_id",
"agent_id",
"status",
"started_at",
"last_output_at",
"created_at",
"updated_at"
)
VALUES (
'00000000-0000-0000-0000-000000000256',
'00000000-0000-0000-0000-000000000250',
'00000000-0000-0000-0000-000000000251',
'running',
'2026-02-10T11:00:00.000Z',
'2026-04-03T12:00:00.123456Z',
'2026-02-10T10:55:00.000Z',
'2026-04-03T12:00:00.123456Z'
)
`);
await afterCleanReplay.unsafe(`
INSERT INTO "routines" (
"id",
"company_id",
"title",
"last_triggered_at",
"last_enqueued_at",
"created_at",
"updated_at"
)
VALUES (
'00000000-0000-0000-0000-000000000254',
'00000000-0000-0000-0000-000000000250',
'Swept routine',
'2026-03-20T10:00:00.000Z',
'2026-03-21T11:00:00.000Z',
'2026-02-11T00:00:00.000Z',
'2026-04-03T12:00:00.123456Z'
)
`);
await afterCleanReplay.unsafe(`
INSERT INTO "routines" (
"id",
"company_id",
"title",
"last_triggered_at",
"last_enqueued_at",
"created_at",
"updated_at"
)
VALUES (
'00000000-0000-0000-0000-000000000257',
'00000000-0000-0000-0000-000000000250',
'Same-timestamp active routine',
'2026-03-20T10:00:00.000Z',
'2026-04-03T12:00:00.123456Z',
'2026-02-11T00:00:00.000Z',
'2026-04-03T12:00:00.123456Z'
)
`);
await afterCleanReplay.unsafe(`
INSERT INTO "routine_runs" (
"id",
"company_id",
"routine_id",
"source",
"status",
"completed_at",
"created_at",
"updated_at"
)
VALUES (
'00000000-0000-0000-0000-000000000255',
'00000000-0000-0000-0000-000000000250',
'00000000-0000-0000-0000-000000000254',
'schedule',
'completed',
'2026-02-12T12:00:00.000Z',
'2026-02-12T11:00:00.000Z',
'2026-04-03T12:00:00.123456Z'
)
`);
await afterCleanReplay.unsafe(`
INSERT INTO "routine_runs" (
"id",
"company_id",
"routine_id",
"source",
"status",
"triggered_at",
"created_at",
"updated_at"
)
VALUES (
'00000000-0000-0000-0000-000000000258',
'00000000-0000-0000-0000-000000000250',
'00000000-0000-0000-0000-000000000257',
'schedule',
'running',
'2026-04-03T12:00:00.123456Z',
'2026-02-12T13:00:00.000Z',
'2026-04-03T12:00:00.123456Z'
)
`);
await afterCleanReplay.unsafe(`
INSERT INTO "companies" ("id", "name", "issue_prefix", "created_at", "updated_at")
VALUES (
'00000000-0000-0000-0000-000000000260',
'Coincident Timestamp Co',
'CTS134',
'2026-01-05T00:00:00.000Z',
'2026-04-03T12:00:00.123456Z'
)
`);
await afterCleanReplay.unsafe(`
INSERT INTO "agents" ("id", "company_id", "name", "role", "adapter_type", "created_at", "updated_at")
VALUES (
'00000000-0000-0000-0000-000000000261',
'00000000-0000-0000-0000-000000000260',
'Coincident Agent',
'general',
'process',
'2026-01-05T00:10:00.000Z',
'2026-01-05T00:10:00.000Z'
)
`);
await afterCleanReplay.unsafe(`
INSERT INTO "issues" ("id", "company_id", "title", "status", "created_at", "updated_at")
VALUES (
'20000000-0000-0000-0000-000000000001',
'00000000-0000-0000-0000-000000000260',
'Coincident timestamp issue should not be touched',
'todo',
'2026-02-05T00:00:00.000Z',
'2026-04-03T12:00:00.123456Z'
)
`);
await afterCleanReplay.unsafe(`
INSERT INTO "heartbeat_runs" (
"id",
"company_id",
"agent_id",
"status",
"started_at",
"finished_at",
"created_at",
"updated_at"
)
VALUES (
'00000000-0000-0000-0000-000000000262',
'00000000-0000-0000-0000-000000000260',
'00000000-0000-0000-0000-000000000261',
'completed',
'2026-02-05T10:00:00.000Z',
'2026-02-05T10:30:00.000Z',
'2026-02-05T09:55:00.000Z',
'2026-04-03T12:00:00.123456Z'
)
`);
await afterCleanReplay.unsafe(
`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = '${repairSweepHash}'`,
);
} finally {
await afterCleanReplay.end();
}
await applyPendingMigrations(connectionString);
const afterRepair = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const repairedRows = await afterRepair.unsafe<{
subject: string;
updated_at: Date;
}[]>(`
SELECT 'company' AS subject, "updated_at"
FROM "companies"
WHERE "id" = '00000000-0000-0000-0000-000000000250'
UNION ALL
SELECT 'issue_with_comment' AS subject, "updated_at"
FROM "issues"
WHERE "id" = '10000000-0000-0000-0000-000000000001'
UNION ALL
SELECT 'issue_without_comment' AS subject, "updated_at"
FROM "issues"
WHERE "id" = '10000000-0000-0000-0000-000000000002'
UNION ALL
SELECT 'issue_with_state_activity' AS subject, "updated_at"
FROM "issues"
WHERE "id" = '10000000-0000-0000-0000-000000000003'
UNION ALL
SELECT 'heartbeat_run' AS subject, "updated_at"
FROM "heartbeat_runs"
WHERE "id" = '00000000-0000-0000-0000-000000000253'
UNION ALL
SELECT 'heartbeat_run_with_output' AS subject, "updated_at"
FROM "heartbeat_runs"
WHERE "id" = '00000000-0000-0000-0000-000000000256'
UNION ALL
SELECT 'other_company' AS subject, "updated_at"
FROM "companies"
WHERE "id" = '00000000-0000-0000-0000-000000000260'
UNION ALL
SELECT 'other_heartbeat_run' AS subject, "updated_at"
FROM "heartbeat_runs"
WHERE "id" = '00000000-0000-0000-0000-000000000262'
UNION ALL
SELECT 'other_issue' AS subject, "updated_at"
FROM "issues"
WHERE "id" = '20000000-0000-0000-0000-000000000001'
UNION ALL
SELECT 'routine' AS subject, "updated_at"
FROM "routines"
WHERE "id" = '00000000-0000-0000-0000-000000000254'
UNION ALL
SELECT 'routine_with_activity' AS subject, "updated_at"
FROM "routines"
WHERE "id" = '00000000-0000-0000-0000-000000000257'
UNION ALL
SELECT 'routine_run' AS subject, "updated_at"
FROM "routine_runs"
WHERE "id" = '00000000-0000-0000-0000-000000000255'
UNION ALL
SELECT 'routine_run_with_trigger' AS subject, "updated_at"
FROM "routine_runs"
WHERE "id" = '00000000-0000-0000-0000-000000000258'
ORDER BY subject
`);
const repaired = Object.fromEntries(
repairedRows.map((row) => [row.subject, row.updated_at.toISOString()]),
);
expect(repaired).toEqual({
company: "2026-01-01T00:00:00.000Z",
heartbeat_run: "2026-02-10T10:30:00.000Z",
heartbeat_run_with_output: "2026-04-03T12:00:00.123Z",
issue_with_comment: "2026-03-02T16:45:00.000Z",
issue_with_state_activity: "2026-04-03T12:00:00.123Z",
issue_without_comment: "2026-02-01T00:02:00.000Z",
other_company: "2026-04-03T12:00:00.123Z",
other_heartbeat_run: "2026-04-03T12:00:00.123Z",
other_issue: "2026-04-03T12:00:00.123Z",
routine: "2026-03-21T11:00:00.000Z",
routine_run_with_trigger: "2026-04-03T12:00:00.123Z",
routine_with_activity: "2026-04-03T12:00:00.123Z",
routine_run: "2026-02-12T12:00:00.000Z",
});
await afterRepair.unsafe(
`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = '${repairSweepHash}'`,
);
} finally {
await afterRepair.end();
}
await applyPendingMigrations(connectionString);
const afterSecondRun = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const secondRunRows = await afterSecondRun.unsafe<{ updated_at: Date }[]>(`
SELECT "updated_at"
FROM "issues"
WHERE "id" = '10000000-0000-0000-0000-000000000001'
`);
expect(secondRunRows[0]?.updated_at.toISOString()).toBe("2026-03-02T16:45:00.000Z");
} finally {
await afterSecondRun.end();
}
},
20_000,
);
it(
"replays the run responsible user repair migration when heartbeat run issue refs are identifiers",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const runResponsibleUserRepairHash = await migrationHash(
"0131_repair_run_responsible_user_context_refs.sql",
);
await sql.unsafe(`
INSERT INTO "companies" ("id", "name", "issue_prefix", "created_at", "updated_at")
VALUES ('00000000-0000-0000-0000-000000000130', 'Migration Test Co', 'TST130', now(), now())
`);
await sql.unsafe(`
INSERT INTO "company_memberships" (
"id",
"company_id",
"principal_type",
"principal_id",
"status",
"membership_role",
"created_at",
"updated_at"
)
VALUES (
'00000000-0000-0000-0000-000000000131',
'00000000-0000-0000-0000-000000000130',
'user',
'owner-user',
'active',
'owner',
now(),
now()
)
`);
await sql.unsafe(`
INSERT INTO "agents" ("id", "company_id", "name", "role", "adapter_type", "created_at", "updated_at")
VALUES (
'00000000-0000-0000-0000-000000000132',
'00000000-0000-0000-0000-000000000130',
'Migration Agent',
'general',
'process',
now(),
now()
)
`);
await sql.unsafe(`
INSERT INTO "issues" (
"id",
"company_id",
"title",
"status",
"responsible_user_id",
"identifier",
"created_at",
"updated_at"
)
VALUES (
'00000000-0000-0000-0000-000000000133',
'00000000-0000-0000-0000-000000000130',
'Identifier referenced issue',
'todo',
'issue-user',
'TST130-1',
now(),
now()
)
`);
await sql.unsafe(`
INSERT INTO "heartbeat_runs" (
"id",
"company_id",
"agent_id",
"status",
"responsible_user_id",
"context_snapshot",
"created_at",
"updated_at"
)
VALUES (
'00000000-0000-0000-0000-000000000134',
'00000000-0000-0000-0000-000000000130',
'00000000-0000-0000-0000-000000000132',
'completed',
NULL,
'{"issueId":"TST130-1"}'::jsonb,
now(),
now()
)
`);
await sql.unsafe(
`DELETE FROM "drizzle"."__drizzle_migrations" WHERE hash = '${runResponsibleUserRepairHash}'`,
);
} finally {
await sql.end();
}
const pendingState = await inspectMigrations(connectionString);
expect(pendingState).toMatchObject({
status: "needsMigrations",
pendingMigrations: ["0131_repair_run_responsible_user_context_refs.sql"],
reason: "pending-migrations",
});
await applyPendingMigrations(connectionString);
const verifySql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const runs = await verifySql.unsafe<{ responsible_user_id: string | null }[]>(`
SELECT "responsible_user_id"
FROM "heartbeat_runs"
WHERE "id" = '00000000-0000-0000-0000-000000000134'
`);
expect(runs).toEqual([{ responsible_user_id: "issue-user" }]);
} finally {
await verifySql.end();
}
},
20_000,
);
it(
"preserves legacy runs while adding native persistence and replay-safe status versioning",
async () => {
const clusterUrl = await createTempDatabase();
await ensurePostgresDatabase(clusterUrl, "native_legacy");
const legacyUrl = new URL(clusterUrl);
legacyUrl.pathname = "/native_legacy";
const connectionString = legacyUrl.href;
cleanups.push(() => closeRegisteredClients(connectionString));
const directory = await fs.promises.mkdtemp(join(tmpdir(), "paperclip-native-prior-migrations-"));
cleanups.push(() => fs.promises.rm(directory, { recursive: true, force: true }));
const migrationsRoot = new URL("./migrations/", import.meta.url);
const journal = JSON.parse(await fs.promises.readFile(new URL("meta/_journal.json", migrationsRoot), "utf8"));
const priorEntries = journal.entries.filter((entry: { idx: number }) => entry.idx < 227);
await fs.promises.mkdir(join(directory, "meta"));
for (const entry of priorEntries) {
await fs.promises.copyFile(new URL(`${entry.tag}.sql`, migrationsRoot), join(directory, `${entry.tag}.sql`));
}
await fs.promises.writeFile(join(directory, "meta/_journal.json"), JSON.stringify({ ...journal, entries: priorEntries }));
const nativePersistenceHash = await migrationHash("0227_modern_pandemic.sql");
const eventSequenceUniquenessHash = await migrationHash(
"0235_heartbeat_run_event_sequence_uniqueness.sql",
);
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
const companyId = "10000000-0000-4000-8000-000000000227";
const agentId = "20000000-0000-4000-8000-000000000227";
const runId = "30000000-0000-4000-8000-000000000227";
const issueId = "40000000-0000-4000-8000-000000000227";
const contractId = "50000000-0000-4000-8000-000000000227";
const resultId = "60000000-0000-4000-8000-000000000227";
const assessmentId = "70000000-0000-4000-8000-000000000227";
const decisionId = "80000000-0000-4000-8000-000000000227";
const otherCompanyId = "11000000-0000-4000-8000-000000000227";
const otherAgentId = "21000000-0000-4000-8000-000000000227";
const otherRunId = "31000000-0000-4000-8000-000000000227";
const otherIssueId = "41000000-0000-4000-8000-000000000227";
const otherContractId = "51000000-0000-4000-8000-000000000227";
const otherResultId = "61000000-0000-4000-8000-000000000227";
const otherAssessmentId = "71000000-0000-4000-8000-000000000227";
const otherDecisionId = "81000000-0000-4000-8000-000000000227";
try {
// Build the real pre-native schema. Downgrading the latest schema by
// dropping its unique index is invalid once later tenant FKs use it.
await migrate(drizzle(sql), { migrationsFolder: directory });
expect(await sql`SELECT to_regclass('public.native_run_results') AS native_results`).toEqual([{ native_results: null }]);
await sql`
INSERT INTO companies (id, name, issue_prefix)
VALUES (${companyId}, 'Native persistence fixture', 'NPF')
`;
await sql`
INSERT INTO agents (id, company_id, name)
VALUES (${agentId}, ${companyId}, 'Legacy migration agent')
`;
await sql`
INSERT INTO heartbeat_runs (id, company_id, agent_id, status)
VALUES (${runId}, ${companyId}, ${agentId}, 'succeeded')
`;
await sql`
INSERT INTO issues (id, company_id, title, status)
VALUES (${issueId}, ${companyId}, 'Legacy migration issue', 'in_progress')
`;
await sql.unsafe(`
INSERT INTO heartbeat_run_events
(company_id, run_id, agent_id, seq, event_type, stream, level, message, payload, created_at)
VALUES
('${companyId}', '${runId}', '${agentId}', 1, 'legacy.start', 'system', 'info', 'one', '{"bytes":"alpha-1"}'::jsonb, '2026-08-01T00:00:01.000Z'),
('${companyId}', '${runId}', '${agentId}', 5, 'legacy.log', 'stdout', 'info', 'first-five', '{"bytes":"beta-5a"}'::jsonb, '2026-08-01T00:00:02.000Z'),
('${companyId}', '${runId}', '${agentId}', 5, 'legacy.log', 'stderr', 'warn', 'duplicate-five', '{"bytes":"gamma-5b"}'::jsonb, '2026-08-01T00:00:03.000Z'),
('${companyId}', '${runId}', '${agentId}', 9, 'legacy.end', 'system', 'info', 'nine', '{"bytes":"delta-9"}'::jsonb, '2026-08-01T00:00:04.000Z')
`);
} finally {
await sql.end();
}
await applyPendingMigrations(connectionString);
const verifySql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const events = await verifySql.unsafe<{
seq: string;
event_type: string;
stream: string;
level: string;
message: string;
payload: { bytes: string };
created_at: Date;
}[]>(`
SELECT seq, event_type, stream, level, message, payload, created_at
FROM heartbeat_run_events
WHERE run_id = '${runId}'
ORDER BY id
`);
// 0235 preserves every legacy event while moving only duplicate
// sequence values above the old run maximum before installing the
// durable (run_id, seq) uniqueness invariant.
expect(events.map((event) => Number(event.seq))).toEqual([1, 5, 10, 9]);
expect(events.map(({ seq: _seq, ...event }) => ({
...event,
created_at: event.created_at.toISOString(),
}))).toEqual([
{
event_type: "legacy.start",
stream: "system",
level: "info",
message: "one",
payload: { bytes: "alpha-1" },
created_at: "2026-08-01T00:00:01.000Z",
},
{
event_type: "legacy.log",
stream: "stdout",
level: "info",
message: "first-five",
payload: { bytes: "beta-5a" },
created_at: "2026-08-01T00:00:02.000Z",
},
{
event_type: "legacy.log",
stream: "stderr",
level: "warn",
message: "duplicate-five",
payload: { bytes: "gamma-5b" },
created_at: "2026-08-01T00:00:03.000Z",
},
{
event_type: "legacy.end",
stream: "system",
level: "info",
message: "nine",
payload: { bytes: "delta-9" },
created_at: "2026-08-01T00:00:04.000Z",
},
]);
const runs = await verifySql.unsafe<{ runtime_mode: string; next_event_seq: string }[]>(`
SELECT runtime_mode, next_event_seq
FROM heartbeat_runs
WHERE id = '${runId}'
`);
expect(runs.map((run) => ({
runtimeMode: run.runtime_mode,
nextEventSeq: Number(run.next_event_seq),
}))).toEqual([{ runtimeMode: "legacy", nextEventSeq: 11 }]);
const nativeRowsBefore = await verifySql.unsafe<{ table_name: string; row_count: number }[]>(`
SELECT 'completion_contracts' AS table_name, count(*)::int AS row_count FROM completion_contracts
UNION ALL SELECT 'native_run_results', count(*)::int FROM native_run_results
UNION ALL SELECT 'native_run_finalizations', count(*)::int FROM native_run_finalizations
UNION ALL SELECT 'work_assessments', count(*)::int FROM work_assessments
UNION ALL SELECT 'status_decisions', count(*)::int FROM status_decisions
UNION ALL SELECT 'status_decision_effects', count(*)::int FROM status_decision_effects
ORDER BY table_name
`);
expect(nativeRowsBefore.every((row) => row.row_count === 0)).toBe(true);
await verifySql`
INSERT INTO companies (id, name, issue_prefix)
VALUES (${otherCompanyId}, 'Other native persistence fixture', 'ONP')
`;
await verifySql`
INSERT INTO agents (id, company_id, name)
VALUES (${otherAgentId}, ${otherCompanyId}, 'Other native migration agent')
`;
await verifySql`
INSERT INTO heartbeat_runs (
id, company_id, agent_id, status, native_issue_id, completion_contract_id
) VALUES (
${otherRunId}, ${otherCompanyId}, ${otherAgentId}, 'succeeded',
${otherIssueId}, ${otherContractId}
)
`;
await verifySql`
INSERT INTO issues (id, company_id, title, status)
VALUES (${otherIssueId}, ${otherCompanyId}, 'Other native issue', 'in_progress')
`;
await verifySql`
UPDATE heartbeat_runs
SET native_issue_id = ${issueId}, completion_contract_id = ${contractId}
WHERE id = ${runId}
`;
await expect(verifySql`
INSERT INTO completion_contracts (
company_id, issue_id, revision, schema_version, policy_version,
risk, completion_authority, incomplete_criteria_policy, contract_json,
canonical_sha256, created_by_actor_type, created_by_actor_id
) VALUES (
${companyId}, ${otherIssueId}, 1, 'paperclip.completion-contract.v1',
'policy-v1', 'low', 'server', 'review', ${JSON.stringify({ criteria: [] })}::jsonb,
'cross-company-contract-sha', 'system', 'migration-test'
)
`).rejects.toThrow(/completion_contracts_issue_company_fk/);
await verifySql`
INSERT INTO completion_contracts (
id, company_id, issue_id, revision, schema_version, policy_version,
risk, completion_authority, incomplete_criteria_policy, contract_json,
canonical_sha256, created_by_actor_type, created_by_actor_id
) VALUES (
${contractId}, ${companyId}, ${issueId}, 1, 'paperclip.completion-contract.v1',
'policy-v1', 'low', 'server', 'review', ${JSON.stringify({ criteria: [] })}::jsonb,
'contract-sha', 'system', 'migration-test'
)
`;
await verifySql`
INSERT INTO completion_contracts (
id, company_id, issue_id, revision, schema_version, policy_version,
risk, completion_authority, incomplete_criteria_policy, contract_json,
canonical_sha256, created_by_actor_type, created_by_actor_id
) VALUES (
${otherContractId}, ${otherCompanyId}, ${otherIssueId}, 1,
'paperclip.completion-contract.v1', 'policy-v1', 'low', 'server', 'review',
${JSON.stringify({ criteria: [] })}::jsonb, 'other-contract-sha',
'system', 'migration-test'
)
`;
await expect(verifySql`
INSERT INTO native_run_results (
company_id, issue_id, run_id, completion_contract_id,
server_fingerprint, schema_status, result_json, canonical_sha256
) VALUES (
${companyId}, ${issueId}, ${otherRunId}, ${contractId},
'cross-company-run', 'valid', ${JSON.stringify({ summary: "invalid" })}::jsonb,
'cross-company-run-sha'
)
`).rejects.toThrow(/native_run_results_run_contract_owner_fk/);
await expect(verifySql`
INSERT INTO native_run_results (
company_id, issue_id, run_id, completion_contract_id,
server_fingerprint, schema_status, result_json, canonical_sha256
) VALUES (
${companyId}, ${issueId}, ${runId}, ${otherContractId},
'cross-company-contract', 'valid', ${JSON.stringify({ summary: "invalid" })}::jsonb,
'cross-company-contract-sha'
)
`).rejects.toThrow(/native_run_results_run_contract_owner_fk/);
await verifySql`
INSERT INTO native_run_results (
id, company_id, issue_id, run_id, completion_contract_id,
server_fingerprint, schema_status, result_json, canonical_sha256
) VALUES (
${resultId}, ${companyId}, ${issueId}, ${runId}, ${contractId},
'result-fingerprint', 'valid', ${JSON.stringify({ summary: "done" })}::jsonb, 'result-sha'
)
`;
await verifySql`
INSERT INTO native_run_results (
id, company_id, issue_id, run_id, completion_contract_id,
server_fingerprint, schema_status, result_json, canonical_sha256
) VALUES (
${otherResultId}, ${otherCompanyId}, ${otherIssueId}, ${otherRunId},
${otherContractId}, 'other-result-fingerprint', 'valid',
${JSON.stringify({ summary: "other" })}::jsonb, 'other-result-sha'
)
`;
await expect(verifySql`
INSERT INTO work_assessments (
company_id, issue_id, run_id, contract_id, result_id,
trigger_kind, trigger_actor_company_id, prior_issue_status,
prior_status_version, policy_version, assessment_json, input_digest
) VALUES (
${companyId}, ${issueId}, ${runId}, ${contractId}, ${otherResultId},
'run_terminal', ${companyId}, 'in_progress', 0, 'policy-v1',
${JSON.stringify({ disposition: "invalid" })}::jsonb,
'cross-company-assessment-input-sha'
)
`).rejects.toThrow(/work_assessments_result_owner_fk/);
await expect(verifySql`
INSERT INTO work_assessments (
company_id, issue_id, run_id, contract_id, result_id,
trigger_kind, trigger_actor_company_id, prior_issue_status,
prior_status_version, policy_version, assessment_json, input_digest
) VALUES (
${companyId}, ${issueId}, ${runId}, ${contractId}, ${resultId},
'run_terminal', ${otherCompanyId}, 'in_progress', 0, 'policy-v1',
${JSON.stringify({ disposition: "invalid" })}::jsonb,
'cross-company-trigger-input-sha'
)
`).rejects.toThrow(/work_assessments_trigger_actor_company_check/);
await verifySql`
INSERT INTO work_assessments (
id, company_id, issue_id, run_id, contract_id, result_id,
trigger_kind, trigger_actor_company_id, prior_issue_status,
prior_status_version, policy_version, assessment_json, input_digest
) VALUES (
${assessmentId}, ${companyId}, ${issueId}, ${runId}, ${contractId}, ${resultId},
'run_terminal', ${companyId}, 'in_progress', 0, 'policy-v1',
${JSON.stringify({ disposition: "done" })}::jsonb, 'assessment-input-sha'
)
`;
await verifySql`
INSERT INTO work_assessments (
id, company_id, issue_id, run_id, contract_id, result_id,
trigger_kind, trigger_actor_company_id, prior_issue_status,
prior_status_version, policy_version, assessment_json, input_digest
) VALUES (
${otherAssessmentId}, ${otherCompanyId}, ${otherIssueId}, ${otherRunId},
${otherContractId}, ${otherResultId}, 'run_terminal', ${otherCompanyId},
'in_progress', 0, 'policy-v1',
${JSON.stringify({ disposition: "done" })}::jsonb, 'other-assessment-input-sha'
)
`;
await expect(verifySql`
INSERT INTO status_decisions (
company_id, issue_id, run_id, assessment_id, decision_version,
policy_version, from_status, to_status, reason_code,
decision_json, decision_digest
) VALUES (
${companyId}, ${issueId}, ${runId}, ${otherAssessmentId}, 1,
'policy-v1', 'in_progress', 'done', 'native_result_accepted',
${JSON.stringify({ toStatus: "done" })}::jsonb, 'cross-company-decision-sha'
)
`).rejects.toThrow(/status_decisions_assessment_owner_fk/);
await verifySql`
INSERT INTO status_decisions (
id, company_id, issue_id, run_id, assessment_id, decision_version,
policy_version, from_status, to_status, reason_code,
decision_json, decision_digest
) VALUES (
${decisionId}, ${companyId}, ${issueId}, ${runId}, ${assessmentId}, 1,
'policy-v1', 'in_progress', 'done', 'native_result_accepted',
${JSON.stringify({ toStatus: "done" })}::jsonb, 'decision-sha'
)
`;
await verifySql`
INSERT INTO status_decisions (
id, company_id, issue_id, run_id, assessment_id, decision_version,
policy_version, from_status, to_status, reason_code,
decision_json, decision_digest
) VALUES (
${otherDecisionId}, ${otherCompanyId}, ${otherIssueId}, ${otherRunId},
${otherAssessmentId}, 1, 'policy-v1', 'in_progress', 'done',
'native_result_accepted', ${JSON.stringify({ toStatus: "done" })}::jsonb,
'other-decision-sha'
)
`;
await expect(verifySql`
INSERT INTO status_decision_effects (
company_id, issue_id, decision_id, ordinal, effect_kind,
target_type, idempotency_key, payload
) VALUES (
${companyId}, ${issueId}, ${otherDecisionId}, 0, 'update_issue_status',
'issue', 'cross-company-decision-effect', ${JSON.stringify({ status: "done" })}::jsonb
)
`).rejects.toThrow(/status_decision_effects_decision_owner_fk/);
await verifySql`
INSERT INTO status_decision_effects (
company_id, issue_id, decision_id, ordinal, effect_kind,
target_type, idempotency_key, payload
) VALUES (
${companyId}, ${issueId}, ${decisionId}, 0, 'update_issue_status',
'issue', 'decision-effect-1', ${JSON.stringify({ status: "done" })}::jsonb
)
`;
await expect(verifySql`
INSERT INTO native_run_finalizations (
run_id, company_id, issue_id, phase, result_id, assessment_id, decision_id
) VALUES (
${runId}, ${companyId}, ${issueId}, 'committed', ${resultId},
${assessmentId}, ${otherDecisionId}
)
`).rejects.toThrow(/native_run_finalizations_decision_owner_fk/);
await verifySql`
INSERT INTO native_run_finalizations (
run_id, company_id, issue_id, phase, result_id, assessment_id, decision_id
) VALUES (
${runId}, ${companyId}, ${issueId}, 'committed', ${resultId}, ${assessmentId}, ${decisionId}
)
`;
await verifySql`UPDATE issues SET title = 'Renamed legacy issue' WHERE id = ${issueId}`;
await verifySql`UPDATE issues SET status = 'done' WHERE id = ${issueId}`;
const issues = await verifySql.unsafe<{ status: string; status_version: string }[]>(`
SELECT status, status_version
FROM issues
WHERE id = '${issueId}'
`);
expect(issues.map((issue) => ({
status: issue.status,
statusVersion: Number(issue.status_version),
}))).toEqual([{ status: "done", statusVersion: 1 }]);
await verifySql`DELETE FROM "drizzle"."__drizzle_migrations" WHERE "hash" = ${nativePersistenceHash}`;
await verifySql`DELETE FROM "drizzle"."__drizzle_migrations" WHERE "hash" = ${eventSequenceUniquenessHash}`;
} finally {
await verifySql.end();
}
await expect(applyPendingMigrations(connectionString)).resolves.toBeUndefined();
await expect(inspectMigrations(connectionString)).resolves.toMatchObject({
status: "upToDate",
});
const replaySql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const replayed = await replaySql.unsafe<{
status_version: string;
next_event_seq: string;
trigger_count: number;
finalization_count: number;
}[]>(`
SELECT
issue.status_version,
run.next_event_seq,
(
SELECT count(*)::int
FROM pg_trigger
WHERE tgname = 'paperclip_issue_status_version_trigger'
AND NOT tgisinternal
) AS trigger_count,
(
SELECT count(*)::int
FROM native_run_finalizations
WHERE run_id = '${runId}'
) AS finalization_count
FROM issues issue
CROSS JOIN heartbeat_runs run
WHERE issue.id = '${issueId}' AND run.id = '${runId}'
`);
expect(replayed.map((row) => ({
statusVersion: Number(row.status_version),
nextEventSeq: Number(row.next_event_seq),
triggerCount: row.trigger_count,
finalizationCount: row.finalization_count,
}))).toEqual([{
statusVersion: 1,
nextEventSeq: 11,
triggerCount: 1,
finalizationCount: 1,
}]);
} finally {
await replaySql.end();
}
},
60_000,
);
it(
"replays the idempotent provider trace migration",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const hash = await migrationHash(
"0234_provider_trace_records.sql",
);
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
await sql`
DELETE FROM "drizzle"."__drizzle_migrations"
WHERE "hash" = ${hash}
`;
} finally {
await sql.end();
}
await expect(
applyPendingMigrations(connectionString),
).resolves.toBeUndefined();
await expect(inspectMigrations(connectionString)).resolves.toMatchObject({
status: "upToDate",
});
},
30_000,
);
it(
"removes retired model profiles from live records and configuration revisions",
async () => {
const connectionString = await createTempDatabase();
await applyPendingMigrations(connectionString);
const hash = await migrationHash("0236_remove_cheap_model_profiles.sql");
const companyId = "10000000-0000-4000-8000-000000000236";
const agentId = "20000000-0000-4000-8000-000000000236";
const issueId = "30000000-0000-4000-8000-000000000236";
const sql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
await sql`
INSERT INTO companies (id, name, issue_prefix)
VALUES (${companyId}, 'Model profile migration fixture', 'MPF')
`;
await sql`
INSERT INTO agents (id, company_id, name, runtime_config)
VALUES (
${agentId},
${companyId},
'Legacy model profile agent',
'{"heartbeat":{"enabled":true},"modelProfiles":{"cheap":{"model":"legacy"}}}'::jsonb
)
`;
await sql`
INSERT INTO issues (id, company_id, title, assignee_adapter_overrides)
VALUES (
${issueId},
${companyId},
'Legacy model profile issue',
'{"modelProfile":"cheap","workingDirectory":"/workspace"}'::jsonb
)
`;
await sql`
INSERT INTO agent_config_revisions (
company_id,
agent_id,
changed_keys,
before_config,
after_config
)
VALUES (
${companyId},
${agentId},
'["runtimeConfig"]'::jsonb,
'{"name":"Legacy model profile agent","runtimeConfig":{"modelProfiles":{"cheap":{"model":"legacy-before"}},"heartbeat":{"enabled":true}}}'::jsonb,
'{"name":"Legacy model profile agent","runtimeConfig":{"modelProfiles":{"cheap":{"model":"legacy-after"}},"heartbeat":{"enabled":false}}}'::jsonb
)
`;
await sql`
DELETE FROM "drizzle"."__drizzle_migrations"
WHERE "hash" = ${hash}
`;
} finally {
await sql.end();
}
await applyPendingMigrations(connectionString);
const verifySql = postgres(connectionString, { max: 1, onnotice: () => {} });
try {
const [result] = await verifySql.unsafe<{
runtime_config: Record<string, unknown>;
assignee_adapter_overrides: Record<string, unknown> | null;
before_config: Record<string, unknown>;
after_config: Record<string, unknown>;
}[]>(`
SELECT
agent.runtime_config,
issue.assignee_adapter_overrides,
revision.before_config,
revision.after_config
FROM agents agent
JOIN issues issue ON issue.company_id = agent.company_id
JOIN agent_config_revisions revision ON revision.agent_id = agent.id
WHERE agent.id = '${agentId}' AND issue.id = '${issueId}'
`);
expect(result.runtime_config).toEqual({ heartbeat: { enabled: true } });
expect(result.assignee_adapter_overrides).toEqual({ workingDirectory: "/workspace" });
expect(result.before_config).toEqual({
name: "Legacy model profile agent",
runtimeConfig: { heartbeat: { enabled: true } },
});
expect(result.after_config).toEqual({
name: "Legacy model profile agent",
runtimeConfig: { heartbeat: { enabled: false } },
});
} finally {
await verifySql.end();
}
},
30_000,
);
});