fix: harden okcode release migrations

Author: BunsDev

apps/server/src/persistence/Migrations.ts

@@ -38,6 +38,7 @@ import Migration0023 from "./Migrations/023_ProjectionPendingUserInputsBackfill.
 import Migration0024 from "./Migrations/024_OpenclawGatewayConfig.ts";
 import Migration0025 from "./Migrations/025_CanonicalizeModelSelections.ts";
 import Migration0026 from "./Migrations/025_ProjectionProjectIconPath.ts";
+import Migration0027 from "./Migrations/027_CanonicalizeModelSelectionsBackfill.ts";
 import { Effect } from "effect";
 
 /**
@@ -77,6 +78,7 @@ const loader = Migrator.fromRecord({
   "24_OpenclawGatewayConfig": Migration0024,
   "25_CanonicalizeModelSelections": Migration0025,
   "26_ProjectionProjectIconPath": Migration0026,
+  "27_CanonicalizeModelSelectionsBackfill": Migration0027,
 });
 
 /**

apps/server/src/persistence/Migrations/025_ProjectionProjectIconPath.ts

@@ -7,5 +7,5 @@ export default Effect.gen(function* () {
   yield* sql`
     ALTER TABLE projection_projects
     ADD COLUMN icon_path TEXT
-  `;
+  `.pipe(Effect.catch(() => Effect.void));
 });

apps/server/src/persistence/Migrations/027_CanonicalizeModelSelectionsBackfill.ts

@@ -0,0 +1,127 @@
+import type { ModelSelection, ProviderKind, ProviderModelOptions } from "@okcode/contracts";
+import { toCanonicalModelSelection } from "@okcode/shared/modelSelection";
+import { Effect } from "effect";
+import * as SqlClient from "effect/unstable/sql/SqlClient";
+
+type ProjectRow = {
+  readonly projectId: string;
+  readonly defaultModel: string | null;
+  readonly defaultModelSelection: string | null;
+};
+
+type ThreadRow = {
+  readonly threadId: string;
+  readonly model: string | null;
+  readonly modelSelection: string | null;
+};
+
+function inferProviderKind(model: string): ProviderKind {
+  if (model.startsWith("claude-")) return "claudeAgent";
+  if (model.startsWith("openclaw/")) return "openclaw";
+  if (model.startsWith("copilot/")) return "copilot";
+  if (model.startsWith("gemini-") || model.startsWith("auto-gemini-")) return "gemini";
+  return "codex";
+}
+
+function parseStoredSelection(raw: string | null | undefined): ModelSelection | string | null {
+  const trimmed = typeof raw === "string" ? raw.trim() : "";
+  if (!trimmed) return null;
+
+  try {
+    const parsed = JSON.parse(trimmed) as unknown;
+    if (typeof parsed === "string") {
+      return parseStoredSelection(parsed);
+    }
+    if (
+      parsed &&
+      typeof parsed === "object" &&
+      "provider" in parsed &&
+      typeof parsed.provider === "string" &&
+      "model" in parsed &&
+      typeof parsed.model === "string"
+    ) {
+      return parsed as ModelSelection;
+    }
+  } catch {
+    // Fall through and treat legacy plain strings as model slugs.
+  }
+
+  return trimmed;
+}
+
+function toCanonicalSelectionJson(
+  rawSelection: string | null | undefined,
+  fallbackModel: string | null | undefined,
+): string | null {
+  const parsed = parseStoredSelection(rawSelection);
+
+  if (parsed && typeof parsed === "object") {
+    const providerOptions = parsed.options
+      ? ({ [parsed.provider]: parsed.options } as ProviderModelOptions)
+      : undefined;
+    return JSON.stringify(
+      toCanonicalModelSelection(parsed.provider, parsed.model, providerOptions),
+    );
+  }
+
+  const model =
+    typeof parsed === "string" && parsed.length > 0
+      ? parsed
+      : typeof fallbackModel === "string" && fallbackModel.trim().length > 0
+        ? fallbackModel.trim()
+        : null;
+
+  if (!model) return null;
+  return JSON.stringify(toCanonicalModelSelection(inferProviderKind(model), model, undefined));
+}
+
+export default Effect.gen(function* () {
+  const sql = yield* SqlClient.SqlClient;
+
+  yield* sql`
+    ALTER TABLE projection_projects
+    ADD COLUMN default_model_selection TEXT
+  `.pipe(Effect.catch(() => Effect.void));
+
+  yield* sql`
+    ALTER TABLE projection_threads
+    ADD COLUMN model_selection TEXT
+  `.pipe(Effect.catch(() => Effect.void));
+
+  const projectRows = yield* sql<ProjectRow>`
+    SELECT
+      project_id AS projectId,
+      default_model AS defaultModel,
+      default_model_selection AS defaultModelSelection
+    FROM projection_projects
+  `;
+
+  for (const row of projectRows) {
+    const nextSelection = toCanonicalSelectionJson(
+      row.defaultModelSelection,
+      row.defaultModel,
+    );
+    yield* sql`
+      UPDATE projection_projects
+      SET default_model_selection = ${nextSelection}
+      WHERE project_id = ${row.projectId}
+    `;
+  }
+
+  const threadRows = yield* sql<ThreadRow>`
+    SELECT
+      thread_id AS threadId,
+      model,
+      model_selection AS modelSelection
+    FROM projection_threads
+  `;
+
+  for (const row of threadRows) {
+    const nextSelection = toCanonicalSelectionJson(row.modelSelection, row.model);
+    yield* sql`
+      UPDATE projection_threads
+      SET model_selection = ${nextSelection}
+      WHERE thread_id = ${row.threadId}
+    `;
+  }
+});