import { CommandId, EventId, MessageId, ProjectId, ThreadId } from "@t3tools/contracts";import { describe, expect, it } from "vitest";import { Effect } from "effect"; import { decideOrchestrationCommand } from "./decider.ts";import { createEmptyReadModel, projectEvent } from "./projector.ts"; const asEventId = (value: string): EventId => EventId.makeUnsafe(value);const asProjectId = (value: string): ProjectId => ProjectId.makeUnsafe(value);const asMessageId = (value: string): MessageId => MessageId.makeUnsafe(value); describe("decider project scripts", () => {  it("emits empty scripts on project.create", async () => {    const now = new Date().toISOString();    const readModel = createEmptyReadModel(now);     const result = await Effect.runPromise(      decideOrchestrationCommand({        command: {          type: "project.create",          commandId: CommandId.makeUnsafe("cmd-project-create-scripts"),          projectId: asProjectId("project-scripts"),          title: "Scripts",          workspaceRoot: "/tmp/scripts",          createdAt: now,        },        readModel,      }),    );     const event = Array.isArray(result) ? result[0] : result;    expect(event.type).toBe("project.created");    expect((event.payload as { scripts: unknown[] }).scripts).toEqual([]);  });   it("propagates scripts in project.meta.update payload", async () => {    const now = new Date().toISOString();    const initial = createEmptyReadModel(now);    const readModel = await Effect.runPromise(      projectEvent(initial, {        sequence: 1,        eventId: asEventId("evt-project-create-scripts"),        aggregateKind: "project",        aggregateId: asProjectId("project-scripts"),        type: "project.created",        occurredAt: now,        commandId: CommandId.makeUnsafe("cmd-project-create-scripts"),        causationEventId: null,        correlationId: CommandId.makeUnsafe("cmd-project-create-scripts"),        metadata: {},        payload: {          projectId: asProjectId("project-scripts"),          title: "Scripts",          workspaceRoot: "/tmp/scripts",          defaultModel: null,          scripts: [],          createdAt: now,          updatedAt: now,        },      }),    );     const scripts = [      {        id: "lint",        name: "Lint",        command: "bun run lint",        icon: "lint",        runOnWorktreeCreate: false,      },    ] as const;     const result = await Effect.runPromise(      decideOrchestrationCommand({        command: {          type: "project.meta.update",          commandId: CommandId.makeUnsafe("cmd-project-update-scripts"),          projectId: asProjectId("project-scripts"),          scripts: Array.from(scripts),        },        readModel,      }),    );     const event = Array.isArray(result) ? result[0] : result;    expect(event.type).toBe("project.meta-updated");    expect((event.payload as { scripts?: unknown[] }).scripts).toEqual(scripts);  });   it("emits user message and turn-start-requested events for thread.turn.start", async () => {    const now = new Date().toISOString();    const initial = createEmptyReadModel(now);    const withProject = await Effect.runPromise(      projectEvent(initial, {        sequence: 1,        eventId: asEventId("evt-project-create"),        aggregateKind: "project",        aggregateId: asProjectId("project-1"),        type: "project.created",        occurredAt: now,        commandId: CommandId.makeUnsafe("cmd-project-create"),        causationEventId: null,        correlationId: CommandId.makeUnsafe("cmd-project-create"),        metadata: {},        payload: {          projectId: asProjectId("project-1"),          title: "Project",          workspaceRoot: "/tmp/project",          defaultModel: null,          scripts: [],          createdAt: now,          updatedAt: now,        },      }),    );    const readModel = await Effect.runPromise(      projectEvent(withProject, {        sequence: 2,        eventId: asEventId("evt-thread-create"),        aggregateKind: "thread",        aggregateId: ThreadId.makeUnsafe("thread-1"),        type: "thread.created",        occurredAt: now,        commandId: CommandId.makeUnsafe("cmd-thread-create"),        causationEventId: null,        correlationId: CommandId.makeUnsafe("cmd-thread-create"),        metadata: {},        payload: {          threadId: ThreadId.makeUnsafe("thread-1"),          projectId: asProjectId("project-1"),          title: "Thread",          model: "gpt-5-codex",          branch: null,          worktreePath: null,          createdAt: now,          updatedAt: now,        },      }),    );     const result = await Effect.runPromise(      decideOrchestrationCommand({        command: {          type: "thread.turn.start",          commandId: CommandId.makeUnsafe("cmd-turn-start"),          threadId: ThreadId.makeUnsafe("thread-1"),          message: {            messageId: asMessageId("message-user-1"),            role: "user",            text: "hello",            attachments: [],          },          provider: "claudeCode",          model: "gpt-5",          effort: "high",          approvalPolicy: "on-request",          sandboxMode: "workspace-write",          createdAt: now,        },        readModel,      }),    );     expect(Array.isArray(result)).toBe(true);    const events = Array.isArray(result) ? result : [result];    expect(events).toHaveLength(2);    expect(events[0]?.type).toBe("thread.message-sent");    const turnStartEvent = events[1];    expect(turnStartEvent?.type).toBe("thread.turn-start-requested");    expect(turnStartEvent?.causationEventId).toBe(events[0]?.eventId ?? null);    if (turnStartEvent?.type !== "thread.turn-start-requested") {      return;    }    expect(turnStartEvent.payload.assistantDeliveryMode).toBe("buffered");    expect(turnStartEvent.payload).toMatchObject({      threadId: ThreadId.makeUnsafe("thread-1"),      messageId: asMessageId("message-user-1"),      provider: "claudeCode",      model: "gpt-5",      effort: "high",      approvalPolicy: "on-request",      sandboxMode: "workspace-write",    });  });});