File size: 1,742 Bytes
89a2873 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 | import { describe, expect, test } from "bun:test"
import { LegacyEvent } from "../src/legacy-event"
import { PermissionV1 } from "../src/permission-v1"
import { QuestionV1 } from "../src/question-v1"
import { Project } from "../src/project"
import { SessionV1 } from "../src/session-v1"
describe("legacy public event schemas", () => {
test("owns all SessionV1 definitions", () => {
expect(SessionV1.Event.Definitions.map((event) => event.type)).toEqual([
"session.created",
"session.updated",
"session.deleted",
"message.updated",
"message.removed",
"message.part.updated",
"message.part.removed",
"message.part.delta",
"session.diff",
"session.error",
])
const durable = SessionV1.Event.Definitions.filter((event) => event.durable !== undefined)
expect(durable).toHaveLength(7)
expect(durable.every((event) => event.durable?.aggregate === "sessionID")).toBe(true)
expect(durable.every((event) => event.durable?.version === 1)).toBe(true)
})
test("owns the legacy transient public definitions", () => {
expect([
SessionV1.PartDelta.type,
SessionV1.Diff.type,
SessionV1.Error.type,
PermissionV1.Event.Asked.type,
PermissionV1.Event.Replied.type,
QuestionV1.Event.Asked.type,
QuestionV1.Event.Replied.type,
QuestionV1.Event.Rejected.type,
Project.Event.Updated.type,
LegacyEvent.CommandExecuted.type,
]).toEqual([
"message.part.delta",
"session.diff",
"session.error",
"permission.asked",
"permission.replied",
"question.asked",
"question.replied",
"question.rejected",
"project.updated",
"command.executed",
])
})
})
|