From 8282b11fb55e50147a33e476ee8563ceaf1e75d7 Mon Sep 17 00:00:00 2001
From: 0x1f99d <crazywolf132@gmail.com>
Date: Tue, 10 Mar 2026 02:29:49 +1100
Subject: [PATCH] refactor(contracts): remove unused
 OrchestrationPersistedEvent schema (#601)

---
 packages/contracts/src/orchestration.ts | 118 ------------------------
 1 file changed, 118 deletions(-)

diff --git a/packages/contracts/src/orchestration.ts b/packages/contracts/src/orchestration.ts
index e90ddd4b597b225fff5980c352427e088336295c..af496ad2a93a7c69458c0ab864046eba103108d3 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;
 
-- 
2.54.0