import {  CommandId,  EventId,  ProjectId,  ThreadId,  type OrchestrationEvent,} from "@t3tools/contracts";import { expect, it } from "@effect/vitest";import * as Effect from "effect/Effect"; import { createEmptyReadModel, projectEvent } from "./projector.ts"; function makeEvent(input: {  readonly sequence: number;  readonly type: OrchestrationEvent["type"];  readonly payload: unknown;}): OrchestrationEvent {  return {    sequence: input.sequence,    eventId: EventId.make(`event-${input.sequence}`),    type: input.type,    aggregateKind: "thread",    aggregateId: ThreadId.make("thread-1"),    occurredAt: "2026-01-01T00:00:00.000Z",    commandId: CommandId.make(`command-${input.sequence}`),    causationEventId: null,    correlationId: null,    metadata: {},    payload: input.payload as never,  } as OrchestrationEvent;} it.effect("projects settled lifecycle events", () =>  Effect.gen(function* () {    const now = "2026-01-01T00:00:00.000Z";    const created = yield* projectEvent(      createEmptyReadModel(now),      makeEvent({        sequence: 1,        type: "thread.created",        payload: {          threadId: ThreadId.make("thread-1"),          projectId: ProjectId.make("project-1"),          title: "Thread",          modelSelection: { provider: "codex", model: "gpt-5.4" },          runtimeMode: "full-access",          interactionMode: "default",          branch: null,          worktreePath: null,          createdAt: now,          updatedAt: now,        },      }),    );    const settled = yield* projectEvent(      created,      makeEvent({        sequence: 2,        type: "thread.settled",        payload: { threadId: ThreadId.make("thread-1"), settledAt: now, updatedAt: now },      }),    );    expect(settled.threads[0]?.settledOverride).toBe("settled");    expect(settled.threads[0]?.settledAt).toBe(now);    expect(settled.threads[0]?.unsettledAt).toBeNull();     const unsettleAt = "2026-01-02T00:00:00.000Z";    const userUnsettled = yield* projectEvent(      settled,      makeEvent({        sequence: 3,        type: "thread.unsettled",        payload: { threadId: ThreadId.make("thread-1"), reason: "user", updatedAt: unsettleAt },      }),    );    expect(userUnsettled.threads[0]?.settledOverride).toBe("active");    expect(userUnsettled.threads[0]?.settledAt).toBeNull();    expect(userUnsettled.threads[0]?.unsettledAt).toBe(unsettleAt);     // Clearing the keep-active pin on activity is not a re-entry: the thread    // is already in the active list, so the stamp must not move it.    const activityAt = "2026-01-03T00:00:00.000Z";    const activityUnsettled = yield* projectEvent(      userUnsettled,      makeEvent({        sequence: 4,        type: "thread.unsettled",        payload: { threadId: ThreadId.make("thread-1"), reason: "activity", updatedAt: activityAt },      }),    );    expect(activityUnsettled.threads[0]?.settledOverride).toBeNull();    expect(activityUnsettled.threads[0]?.settledAt).toBeNull();    expect(activityUnsettled.threads[0]?.unsettledAt).toBe(unsettleAt);     const resettledAt = "2026-01-04T00:00:00.000Z";    const resettled = yield* projectEvent(      activityUnsettled,      makeEvent({        sequence: 5,        type: "thread.settled",        payload: {          threadId: ThreadId.make("thread-1"),          settledAt: resettledAt,          updatedAt: resettledAt,        },      }),    );    expect(resettled.threads[0]?.unsettledAt).toBeNull();     // Waking a settled thread on activity IS a re-entry and stamps.    const wakeAt = "2026-01-05T00:00:00.000Z";    const woke = yield* projectEvent(      resettled,      makeEvent({        sequence: 6,        type: "thread.unsettled",        payload: { threadId: ThreadId.make("thread-1"), reason: "activity", updatedAt: wakeAt },      }),    );    expect(woke.threads[0]?.settledOverride).toBeNull();    expect(woke.threads[0]?.unsettledAt).toBe(wakeAt);  }),);