Add optional id to Schema so user-defined schemas preserve identity at runtime

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: bchapuis

apps/api/src/runtime/cloudflare-schema-service.ts

@@ -21,6 +21,7 @@ export class CloudflareSchemaService implements SchemaService {
     if (!row) return undefined;
 
     return {
+      id: schemaId,
       name: row.name,
       description: row.description,
       fields: JSON.parse(row.fields),

apps/app/src/pages/database-explorer-page.tsx

@@ -142,9 +142,7 @@ function SchemaFlowCanvas({ tables }: SchemaFlowCanvasProps) {
           // fall back to the primary key column of the referenced table.
           let targetCol = fk.referencedColumn;
           if (!targetCol) {
-            const refTable = tables.find(
-              (t) => t.name === fk.referencedTable
-            );
+            const refTable = tables.find((t) => t.name === fk.referencedTable);
             const pk = refTable?.columns.find((c) => c.primaryKey);
             if (!pk) return null;
             targetCol = pk.name;

packages/runtime/src/nodes/database/database-put-row-node.test.ts

@@ -149,18 +149,25 @@ describe("DatabasePutRowNode", () => {
     expect(result.error).toContain("Invalid schema");
   });
 
-  it("should return error for schema without primary key", async () => {
+  it("should insert row with INSERT INTO for schema without primary key", async () => {
     const node = createNode();
+    const connection = createMockConnection();
     const result = await node.execute(
-      createContext({
-        database: "db-1",
-        schema: schemaWithoutPk,
-        record: { message: "test" },
-      })
+      createContext(
+        {
+          database: "db-1",
+          schema: schemaWithoutPk,
+          record: { message: "hello", level: "info" },
+        },
+        connection
+      )
     );
 
-    expect(result.status).toBe("error");
-    expect(result.error).toContain("no primary key defined");
+    expect(result.status).toBe("completed");
+    expect(connection.execute).toHaveBeenCalledWith(
+      "INSERT INTO logs (message, level) VALUES (?, ?)",
+      ["hello", "info"]
+    );
   });
 
   it("should return error for missing record", async () => {

packages/types/src/types.ts

@@ -45,6 +45,7 @@ export interface Field {
  * Schema definition
  */
 export interface Schema {
+  id?: string;
   name: string;
   description?: string;
   fields: Field[];