import { assert, it } from "@effect/vitest";
import * as Effect from "effect/Effect";
import * as Layer from "effect/Layer";
import * as SqlClient from "effect/unstable/sql/SqlClient";

import { runMigrations } from "../Migrations.ts";
import * as NodeSqliteClient from "@t3tools/shared/nodeSqliteClient";

const layer = it.layer(Layer.mergeAll(NodeSqliteClient.layerMemory()));

layer("026_CanonicalizeModelSelectionOptions", (it) => {
  it.effect("converts legacy object-shape options into array-shape on projections and events", () =>
    Effect.gen(function* () {
      const sql = yield* SqlClient.SqlClient;

      yield* runMigrations({ toMigrationInclusive: 25 });

      yield* sql`
          INSERT INTO projection_projects (
            project_id,
            title,
            workspace_root,
            default_model_selection_json,
            scripts_json,
            created_at,
            updated_at,
            deleted_at
          )
          VALUES
            (
              'project-legacy',
              'Legacy options project',
              '/tmp/legacy',
              '{"provider":"claudeAgent","model":"claude-opus-4-6","options":{"effort":"max","fastMode":true}}',
              '[]',
              '2026-01-01T00:00:00.000Z',
              '2026-01-01T00:00:00.000Z',
              NULL
            ),
            (
              'project-no-options',
              'No options project',
              '/tmp/no-options',
              '{"provider":"codex","model":"gpt-5.4"}',
              '[]',
              '2026-01-01T00:00:00.000Z',
              '2026-01-01T00:00:00.000Z',
              NULL
            ),
            (
              'project-null-selection',
              'Null model selection project',
              '/tmp/null-selection',
              NULL,
              '[]',
              '2026-01-01T00:00:00.000Z',
              '2026-01-01T00:00:00.000Z',
              NULL
            ),
            (
              'project-already-array',
              'Already-canonical options project',
              '/tmp/already-array',
              '{"provider":"codex","model":"gpt-5.4","options":[{"id":"reasoningEffort","value":"high"}]}',
              '[]',
              '2026-01-01T00:00:00.000Z',
              '2026-01-01T00:00:00.000Z',
              NULL
            )
        `;

      yield* sql`
          INSERT INTO projection_threads (
            thread_id,
            project_id,
            title,
            model_selection_json,
            branch,
            worktree_path,
            latest_turn_id,
            created_at,
            updated_at,
            archived_at,
            latest_user_message_at,
            pending_approval_count,
            pending_user_input_count,
            has_actionable_proposed_plan,
            deleted_at,
            runtime_mode,
            interaction_mode
          )
          VALUES
            (
              'thread-legacy',
              'project-legacy',
              'Legacy thread',
              '{"provider":"claudeAgent","model":"claude-opus-4-6","options":{"effort":"max","thinking":false,"contextWindow":"1m"}}',
              NULL, NULL, NULL,
              '2026-01-01T00:00:00.000Z',
              '2026-01-01T00:00:00.000Z',
              NULL, NULL, 0, 0, 0, NULL,
              'full-access', 'default'
            ),
            (
              'thread-empty-options',
              'project-legacy',
              'Empty options thread',
              '{"provider":"codex","model":"gpt-5.4","options":{}}',
              NULL, NULL, NULL,
              '2026-01-01T00:00:00.000Z',
              '2026-01-01T00:00:00.000Z',
              NULL, NULL, 0, 0, 0, NULL,
              'full-access', 'default'
            ),
            (
              'thread-drop-garbage',
              'project-legacy',
              'Thread with non-scalar entries',
              '{"provider":"claudeAgent","model":"claude-opus-4-6","options":{"effort":"high","thinking":{"enabled":true,"budgetTokens":2000},"emptyStr":"   ","nullish":null}}',
              NULL, NULL, NULL,
              '2026-01-01T00:00:00.000Z',
              '2026-01-01T00:00:00.000Z',
              NULL, NULL, 0, 0, 0, NULL,
              'full-access', 'default'
            ),
            (
              'thread-no-options',
              'project-legacy',
              'No options thread',
              '{"provider":"codex","model":"gpt-5.4"}',
              NULL, NULL, NULL,
              '2026-01-01T00:00:00.000Z',
              '2026-01-01T00:00:00.000Z',
              NULL, NULL, 0, 0, 0, NULL,
              'full-access', 'default'
            ),
            (
              'thread-already-array',
              'project-legacy',
              'Already array thread',
              '{"provider":"codex","model":"gpt-5.4","options":[{"id":"fastMode","value":true}]}',
              NULL, NULL, NULL,
              '2026-01-01T00:00:00.000Z',
              '2026-01-01T00:00:00.000Z',
              NULL, NULL, 0, 0, 0, NULL,
              'full-access', 'default'
            )
        `;

      yield* sql`
          INSERT INTO orchestration_events (
            event_id,
            aggregate_kind,
            stream_id,
            stream_version,
            event_type,
            occurred_at,
            command_id,
            causation_event_id,
            correlation_id,
            actor_kind,
            payload_json,
            metadata_json
          )
          VALUES
            (
              'event-project-created',
              'project',
              'project-legacy',
              1,
              'project.created',
              '2026-01-01T00:00:00.000Z',
              'cmd-pc',
              NULL,
              'corr-pc',
              'user',
              '{"projectId":"project-legacy","title":"Project","workspaceRoot":"/tmp/legacy","defaultModelSelection":{"provider":"claudeAgent","model":"claude-opus-4-6","options":{"effort":"max","fastMode":true}},"scripts":[],"createdAt":"2026-01-01T00:00:00.000Z","updatedAt":"2026-01-01T00:00:00.000Z"}',
              '{}'
            ),
            (
              'event-project-meta-updated',
              'project',
              'project-legacy',
              2,
              'project.meta-updated',
              '2026-01-01T00:00:00.000Z',
              'cmd-pmu',
              NULL,
              'corr-pmu',
              'user',
              '{"projectId":"project-legacy","defaultModelSelection":{"provider":"codex","model":"gpt-5.4","options":{"reasoningEffort":"low"}},"updatedAt":"2026-01-01T00:00:00.000Z"}',
              '{}'
            ),
            (
              'event-project-null-selection',
              'project',
              'project-legacy',
              3,
              'project.meta-updated',
              '2026-01-01T00:00:00.000Z',
              'cmd-null',
              NULL,
              'corr-null',
              'user',
              '{"projectId":"project-legacy","defaultModelSelection":null,"updatedAt":"2026-01-01T00:00:00.000Z"}',
              '{}'
            ),
            (
              'event-thread-created',
              'thread',
              'thread-legacy',
              1,
              'thread.created',
              '2026-01-01T00:00:00.000Z',
              'cmd-tc',
              NULL,
              'corr-tc',
              'user',
              '{"threadId":"thread-legacy","projectId":"project-legacy","title":"Thread","modelSelection":{"provider":"claudeAgent","model":"claude-opus-4-6","options":{"effort":"max","thinking":false}},"runtimeMode":"full-access","interactionMode":"default","branch":null,"worktreePath":null,"createdAt":"2026-01-01T00:00:00.000Z","updatedAt":"2026-01-01T00:00:00.000Z"}',
              '{}'
            ),
            (
              'event-thread-meta-updated',
              'thread',
              'thread-legacy',
              2,
              'thread.meta-updated',
              '2026-01-01T00:00:00.000Z',
              'cmd-tmu',
              NULL,
              'corr-tmu',
              'user',
              '{"threadId":"thread-legacy","modelSelection":{"provider":"codex","model":"gpt-5.4","options":{"fastMode":true}},"updatedAt":"2026-01-01T00:00:00.000Z"}',
              '{}'
            ),
            (
              'event-thread-turn-start',
              'thread',
              'thread-legacy',
              3,
              'thread.turn-start-requested',
              '2026-01-01T00:00:00.000Z',
              'cmd-tts',
              NULL,
              'corr-tts',
              'user',
              '{"threadId":"thread-legacy","messageId":"msg-1","modelSelection":{"provider":"claudeAgent","model":"claude-opus-4-6","options":{"effort":"high","contextWindow":"1m"}},"runtimeMode":"full-access","interactionMode":"default","createdAt":"2026-01-01T00:00:00.000Z"}',
              '{}'
            ),
            (
              'event-thread-already-array',
              'thread',
              'thread-legacy',
              4,
              'thread.created',
              '2026-01-01T00:00:00.000Z',
              'cmd-taa',
              NULL,
              'corr-taa',
              'user',
              '{"threadId":"thread-already-array","projectId":"project-legacy","title":"Already Array","modelSelection":{"provider":"codex","model":"gpt-5.4","options":[{"id":"reasoningEffort","value":"medium"}]},"runtimeMode":"full-access","interactionMode":"default","branch":null,"worktreePath":null,"createdAt":"2026-01-01T00:00:00.000Z","updatedAt":"2026-01-01T00:00:00.000Z"}',
              '{}'
            ),
            (
              'event-activity-append',
              'thread',
              'thread-legacy',
              5,
              'thread.activity-appended',
              '2026-01-01T00:00:00.000Z',
              'cmd-aa',
              NULL,
              'corr-aa',
              'user',
              '{"threadId":"thread-legacy","activity":{"id":"a","tone":"info","kind":"k","summary":"s","payload":null,"turnId":null,"createdAt":"2026-01-01T00:00:00.000Z"}}',
              '{}'
            )
        `;

      yield* runMigrations({ toMigrationInclusive: 26 });

      // Projection projects
      const projectRows = yield* sql<{
        readonly projectId: string;
        readonly defaultModelSelection: string | null;
      }>`
          SELECT
            project_id AS "projectId",
            default_model_selection_json AS "defaultModelSelection"
          FROM projection_projects
          ORDER BY project_id
        `;
      assert.deepStrictEqual(
        projectRows.map((row) => ({
          projectId: row.projectId,
          selection: row.defaultModelSelection ? JSON.parse(row.defaultModelSelection) : null,
        })),
        [
          {
            projectId: "project-already-array",
            selection: {
              provider: "codex",
              model: "gpt-5.4",
              options: [{ id: "reasoningEffort", value: "high" }],
            },
          },
          {
            projectId: "project-legacy",
            selection: {
              provider: "claudeAgent",
              model: "claude-opus-4-6",
              options: [
                { id: "effort", value: "max" },
                { id: "fastMode", value: true },
              ],
            },
          },
          {
            projectId: "project-no-options",
            selection: { provider: "codex", model: "gpt-5.4" },
          },
          { projectId: "project-null-selection", selection: null },
        ],
      );

      // Projection threads
      const threadRows = yield* sql<{
        readonly threadId: string;
        readonly modelSelection: string | null;
      }>`
          SELECT
            thread_id AS "threadId",
            model_selection_json AS "modelSelection"
          FROM projection_threads
          ORDER BY thread_id
        `;
      assert.deepStrictEqual(
        threadRows.map((row) => ({
          threadId: row.threadId,
          selection: row.modelSelection ? JSON.parse(row.modelSelection) : null,
        })),
        [
          {
            threadId: "thread-already-array",
            selection: {
              provider: "codex",
              model: "gpt-5.4",
              options: [{ id: "fastMode", value: true }],
            },
          },
          {
            threadId: "thread-drop-garbage",
            selection: {
              provider: "claudeAgent",
              model: "claude-opus-4-6",
              // Only the scalar string survives; nested object, whitespace
              // string, and null are dropped.
              options: [{ id: "effort", value: "high" }],
            },
          },
          {
            threadId: "thread-empty-options",
            selection: { provider: "codex", model: "gpt-5.4", options: [] },
          },
          {
            threadId: "thread-legacy",
            selection: {
              provider: "claudeAgent",
              model: "claude-opus-4-6",
              options: [
                { id: "effort", value: "max" },
                { id: "thinking", value: false },
                { id: "contextWindow", value: "1m" },
              ],
            },
          },
          {
            threadId: "thread-no-options",
            selection: { provider: "codex", model: "gpt-5.4" },
          },
        ],
      );

      // Orchestration events
      const eventRows = yield* sql<{
        readonly eventId: string;
        readonly payloadJson: string;
      }>`
          SELECT event_id AS "eventId", payload_json AS "payloadJson"
          FROM orchestration_events
          ORDER BY event_id
        `;

      const payloads = Object.fromEntries(
        eventRows.map((row) => [row.eventId, JSON.parse(row.payloadJson)]),
      );

      assert.deepStrictEqual(payloads["event-project-created"].defaultModelSelection, {
        provider: "claudeAgent",
        model: "claude-opus-4-6",
        options: [
          { id: "effort", value: "max" },
          { id: "fastMode", value: true },
        ],
      });

      assert.deepStrictEqual(payloads["event-project-meta-updated"].defaultModelSelection, {
        provider: "codex",
        model: "gpt-5.4",
        options: [{ id: "reasoningEffort", value: "low" }],
      });

      assert.strictEqual(payloads["event-project-null-selection"].defaultModelSelection, null);

      assert.deepStrictEqual(payloads["event-thread-created"].modelSelection, {
        provider: "claudeAgent",
        model: "claude-opus-4-6",
        options: [
          { id: "effort", value: "max" },
          { id: "thinking", value: false },
        ],
      });

      assert.deepStrictEqual(payloads["event-thread-meta-updated"].modelSelection, {
        provider: "codex",
        model: "gpt-5.4",
        options: [{ id: "fastMode", value: true }],
      });

      assert.deepStrictEqual(payloads["event-thread-turn-start"].modelSelection, {
        provider: "claudeAgent",
        model: "claude-opus-4-6",
        options: [
          { id: "effort", value: "high" },
          { id: "contextWindow", value: "1m" },
        ],
      });

      // Already-array records are left untouched.
      assert.deepStrictEqual(payloads["event-thread-already-array"].modelSelection, {
        provider: "codex",
        model: "gpt-5.4",
        options: [{ id: "reasoningEffort", value: "medium" }],
      });

      // Events with no modelSelection at all are untouched.
      assert.isUndefined(payloads["event-activity-append"].modelSelection);
      assert.isUndefined(payloads["event-activity-append"].defaultModelSelection);
    }),
  );
});