diff --git a/packages/contracts/src/orchestration.ts b/packages/contracts/src/orchestration.ts index e90ddd4b59..af496ad2a9 100644 --- a/packages/contracts/src/orchestration.ts +++ b/packages/contracts/src/orchestration.ts @@ -769,20 +769,6 @@ const EventBaseFields = { metadata: OrchestrationEventMetadata, } as const; -const PersistedEventBaseFields = { - sequence: NonNegativeInt, - eventId: EventId, - aggregateKind: OrchestrationAggregateKind, - streamId: Schema.Union([ProjectId, ThreadId]), - streamVersion: NonNegativeInt, - occurredAt: IsoDateTime, - commandId: Schema.NullOr(CommandId), - causationEventId: Schema.NullOr(EventId), - correlationId: Schema.NullOr(CommandId), - actorKind: OrchestrationActorKind, - metadata: OrchestrationEventMetadata, -} as const; - export const OrchestrationEvent = Schema.Union([ Schema.Struct({ ...EventBaseFields, @@ -887,110 +873,6 @@ export const OrchestrationEvent = Schema.Union([ ]); export type OrchestrationEvent = typeof OrchestrationEvent.Type; -export const OrchestrationPersistedEvent = Schema.Union([ - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("project.created"), - payload: ProjectCreatedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("project.meta-updated"), - payload: ProjectMetaUpdatedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("project.deleted"), - payload: ProjectDeletedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.created"), - payload: ThreadCreatedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.deleted"), - payload: ThreadDeletedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.meta-updated"), - payload: ThreadMetaUpdatedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.runtime-mode-set"), - payload: ThreadRuntimeModeSetPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.interaction-mode-set"), - payload: ThreadInteractionModeSetPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.message-sent"), - payload: ThreadMessageSentPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.turn-start-requested"), - payload: ThreadTurnStartRequestedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.turn-interrupt-requested"), - payload: ThreadTurnInterruptRequestedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.approval-response-requested"), - payload: ThreadApprovalResponseRequestedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.user-input-response-requested"), - payload: ThreadUserInputResponseRequestedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.checkpoint-revert-requested"), - payload: ThreadCheckpointRevertRequestedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.reverted"), - payload: ThreadRevertedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.session-stop-requested"), - payload: ThreadSessionStopRequestedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.session-set"), - payload: ThreadSessionSetPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.proposed-plan-upserted"), - payload: ThreadProposedPlanUpsertedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.turn-diff-completed"), - payload: ThreadTurnDiffCompletedPayload, - }), - Schema.Struct({ - ...PersistedEventBaseFields, - eventType: Schema.Literal("thread.activity-appended"), - payload: ThreadActivityAppendedPayload, - }), -]); -export type OrchestrationPersistedEvent = typeof OrchestrationPersistedEvent.Type; - export const OrchestrationCommandReceiptStatus = Schema.Literals(["accepted", "rejected"]); export type OrchestrationCommandReceiptStatus = typeof OrchestrationCommandReceiptStatus.Type;