refactor(events): define orchestration SSE frames once - #632
Open
jakedipity wants to merge 2 commits into
Open
Conversation
Greptile SummaryThe PR centralizes orchestration event payloads and SSE frame definitions in
Confidence Score: 5/5The PR appears safe to merge. No blocking failure remains.
|
| Filename | Overview |
|---|---|
| crates/aura-events/src/agent.rs | Extends the shared agent payload vocabulary with orchestration, task attribution, and unified outcome fields. |
| crates/aura-events/src/orchestration.rs | Centralizes orchestration SSE frame types, constructors, routing modes, and iteration timings. |
| crates/aura/src/orchestration/orchestrator.rs | Replaces the private orchestration event enum with enveloped shared AgentEvent payloads. |
| crates/aura-web-server/src/streaming/handlers.rs | Projects shared AgentEvent payloads into the centralized orchestration SSE frame schema. |
| crates/aura/src/orchestration/stream_events.rs | Re-exports the centralized orchestration stream definitions while retaining local serialization tests. |
Flowchart
%%{init: {'theme': 'neutral'}}%%
flowchart LR
O[Orchestration runtime] --> A[AgentEvent]
A --> P[AgentEventPayload]
P --> H[Web stream projection]
H --> S[Shared OrchestrationStreamEvent]
S --> C[CLI and SSE consumers]
Reviews (5): Last reviewed commit: "feat(events): orchestration emits the ag..." | Re-trigger Greptile
jakedipity
force-pushed
the
jakedipity/orchestration-event-schema
branch
2 times, most recently
from
September 1, 2026 21:38
10de369 to
1e780d5
Compare
jakedipity
changed the base branch from
jakedipity/single-agent-event-producer
to
jakedipity/agent-event-schema
September 1, 2026 21:43
dhable
approved these changes
Sep 2, 2026
jakedipity
force-pushed
the
jakedipity/agent-event-schema
branch
from
September 3, 2026 19:24
4a4586f to
9e0dfbd
Compare
jakedipity
force-pushed
the
jakedipity/orchestration-event-schema
branch
from
September 3, 2026 20:06
1e780d5 to
966c455
Compare
jakedipity
force-pushed
the
jakedipity/agent-event-schema
branch
from
September 3, 2026 20:22
9e0dfbd to
f6e769b
Compare
The producer and consumer each declared their own copy of OrchestrationStreamEvent, and they disagreed: plan_created did not parse, and iteration_complete bound to synthesizing. aura-events now holds the single definition, matching what the server emits, and the aura copy re-exports it. RoutingMode and IterationTimings move with it. Emitted frames are unchanged; only the parsing side is corrected. Ref: #623 Signed-off-by: Jacob Hull <jacob@planethull.com>
Orchestration carried its own OrchestratorEvent enum between the orchestrator and the SSE projection. Its variants move onto AgentEventPayload, so orchestrated and single-agent runs share one vocabulary, and StreamItem carries that payload directly. Emitted frames are unchanged; the projection reads the same field sets under a different type. Ref: #623 Signed-off-by: Jacob Hull <jacob@planethull.com>
jakedipity
force-pushed
the
jakedipity/orchestration-event-schema
branch
from
September 3, 2026 20:34
966c455 to
025fbbd
Compare
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
refactor(events): define orchestration SSE frames once
The producer and consumer each declared their own copy of OrchestrationStreamEvent, and they disagreed: plan_created did not parse, and iteration_complete bound to synthesizing. aura-events now holds the single definition, matching what the server emits, and the aura copy re-exports it. RoutingMode and IterationTimings move with it.
Emitted frames are unchanged; only the parsing side is corrected.
Ref: #623
feat(events): orchestration emits the agent event schema
Orchestration carried its own OrchestratorEvent enum between the orchestrator and the SSE projection. Its variants move onto AgentEventPayload, so orchestrated and single-agent runs share one vocabulary, and StreamItem carries that payload directly.
Emitted frames are unchanged; the projection reads the same field sets under a different type.
Ref: #623