| author |  Julius Marminge <julius0216@outlook.com> 2026-02-26 20:35:30-08:00 |
| committer |  Julius Marminge <jmarminge@gmail.com> 2026-02-26 20:43:22-08:00 |
| log | 7e4da5b15780307d7616e6b9db190a60a8a2fd90 |
| tree | 5361e8579add5b4a10fcc456e772ef9bf47a135e |
| parent | 9acce6ddaa441a62dfb8a4c9a06f81c5e21dabc2 |
Remove assistant-complete text payload from orchestration flow
- Drop optional `text` from `ThreadMessageAssistantCompleteCommand`
- Stop passing text on assistant-complete ingestion and decider paths
- Ensure completion events no longer overwrite message content3 files changed, 1 insertions(+), 3 deletions(-)
apps
server
src
orchestration
packages
contracts
apps/server/src/orchestration/Layers/ProviderRuntimeIngestion.ts-1
| ... | @@ -288,7 +288,6 @@ const make = Effect.gen(function* () { | ... | @@ -288,7 +288,6 @@ const make = Effect.gen(function* () { |
| 288 | threadId: input.threadId, | 288 | threadId: input.threadId, |
| 289 | messageId: input.messageId, | 289 | messageId: input.messageId, |
| 290 | ...(input.turnId ? { turnId: input.turnId } : {}), | 290 | ...(input.turnId ? { turnId: input.turnId } : {}), |
| 291 | text: "", | ||
| 292 | createdAt: input.createdAt, | 291 | createdAt: input.createdAt, |
| 293 | }); | 292 | }); |
| 294 | yield* clearAssistantMessageState(input.messageId); | 293 | yield* clearAssistantMessageState(input.messageId); |
apps/server/src/orchestration/decider.ts+1-1
| ... | @@ -425,7 +425,7 @@ export const decideOrchestrationCommand = Effect.fn("decideOrchestrationCommand" | ... | @@ -425,7 +425,7 @@ export const decideOrchestrationCommand = Effect.fn("decideOrchestrationCommand" |
| 425 | threadId: command.threadId, | 425 | threadId: command.threadId, |
| 426 | messageId: command.messageId, | 426 | messageId: command.messageId, |
| 427 | role: "assistant", | 427 | role: "assistant", |
| 428 | text: command.text ?? "", | 428 | text: "", |
| 429 | turnId: command.turnId ?? null, | 429 | turnId: command.turnId ?? null, |
| 430 | streaming: false, | 430 | streaming: false, |
| 431 | createdAt: command.createdAt, | 431 | createdAt: command.createdAt, |
packages/contracts/src/orchestration.ts-1
| ... | @@ -356,7 +356,6 @@ export const ThreadMessageAssistantCompleteCommand = Schema.Struct({ | ... | @@ -356,7 +356,6 @@ export const ThreadMessageAssistantCompleteCommand = Schema.Struct({ |
| 356 | threadId: ThreadId, | 356 | threadId: ThreadId, |
| 357 | messageId: MessageId, | 357 | messageId: MessageId, |
| 358 | turnId: Schema.optional(TurnId), | 358 | turnId: Schema.optional(TurnId), |
| 359 | text: Schema.optional(Schema.String), | ||
| 360 | createdAt: IsoDateTime, | 359 | createdAt: IsoDateTime, |
| 361 | }); | 360 | }); |
| 362 | 361 |