feat(workflows)!: implement event bus streaming architecture and unified workflow SDK - #304

Merged

lavaman131 merged 151 commits into

mainfrom

lavaman131/feature/workflow-sdk

Mar 2, 2026

Commits on Feb 25, 2026

fix(ui): hide redundant Task ToolParts when agent tree is present

lavaman131
and
Copilot
committed
6117efe
fix(ui): deduplicate sub-agent entries in parallel agents tree

lavaman131
and
Copilot
committed
736cd4a
fix(ui): show only one sub-agent tree based on background mode

lavaman131
and
Copilot
committed
26e91b7
fix(opencode): register sub-agent session IDs for tool event routing

lavaman131
and
Copilot
committed
3ecf068
fix(opencode): emit tool.complete for tools with undefined output

lavaman131
and
Copilot
committed
b0b4ee2
fix(autocomplete): filter build artifact directories from @ file suggestions

lavaman131
and
Copilot
committed
b065450
fix(ui): prevent text chunking loss after sub-agent blocks

lavaman131
and
Copilot
committed
eadcdfa
fix(ui): merge text deltas into finalized TextParts to prevent orphaned fragments

lavaman131
and
Copilot
committed
e3f2cfc
fix(ui): improve parallel sub-agent attribution and status rendering
lavaman131
committed
d9427f6
fix(sdk): prevent OpenCode sub-agent freezing with abort/timeout support

lavaman131
and
Copilot
committed
6b49c55
fix(ui): enable text selection and copy on markdown content

lavaman131
and
Copilot
committed
9a6b97c
fix(ralph): use DAG-aware dispatch for parallel task execution

lavaman131
and
Copilot
committed
6e11bdd
feat(ralph): replace prompt-based dispatch with deterministic parallel workers

lavaman131
and
Copilot
committed
a8b2be7
fix(ralph): wire Ctrl+C abort to bridge sessions and fix streaming state

lavaman131
and
Copilot
committed
0b81f58
fix(ui): handle unbound thinking events and reasoning display
lavaman131
committed
f570e61
fix(ui): preserve parallel agent lifecycle after stream end
lavaman131
committed
ea43397
docs: add research and spec for @-command duplicate subagent tree fix
lavaman131
committed
a375d1e
fix(ui): prevent duplicate subagent tree nodes from @-command dispatch
lavaman131
committed
640d5b1
fix(ralph): add progress file to review prompt and use debugger for fix phase

lavaman131
and
Copilot
committed
34fc302
docs: add research and spec for playwright-cli integration

lavaman131
and
Copilot
committed
3cc5901
refactor(agents): replace WebFetch/WebSearch with DeepWiki and playwright-cli

lavaman131
and
Copilot
committed
80abfb0
feat(skills): add playwright-cli skill and builtin skill infrastructure

lavaman131
and
Copilot
committed
a95b6dd
feat(install): integrate playwright-cli into postinstall and shell installers

lavaman131
and
Copilot
committed
8c3bb00
test: add playwright-cli integration and skill tests

lavaman131
and
Copilot
committed
e782875
ci: add installer validation workflow

lavaman131
and
Copilot
committed
918e576
build(deps): bump claude-agent-sdk, opencode-sdk, and opentui packages

lavaman131
and
Copilot
committed
ace7e15
fix(ui): always group parallel agents into single tree

lavaman131
and
Copilot
committed
baa0a67
fix: update import paths in src/workflows/graph/ after directory move
lavaman131
committed
f091949
refactor: update import paths from src/graph/ to src/workflows/graph/
lavaman131
committed
b67f6c6
refactor: update workflows barrel to re-export graph/ and ralph/ modules
lavaman131
committed
71a8ed3
fix(ui): explicitly handle AbortError with onComplete() call in index.ts
lavaman131
committed
a582182
feat(graph): add SubAgentConfig, ToolBuilderConfig, and IfConfig interfaces to builder
lavaman131
committed
34b5d68
fix(ui): add 30s spawn-initiation timeout and relax generation guard
lavaman131
committed
3cb8c00
feat(graph): implement .subagent() and .tool() chaining methods; refactor(ralph): remove 4 unused prompt builders
lavaman131
committed
24a08ea
feat(ralph): add graph workflow state fields to RalphWorkflowState
lavaman131
committed
ec47b09
test(graph): add unit tests for config-based .if() method
lavaman131
committed
2da6255
test(graph): add comprehensive unit tests for .subagent() and .tool() builder methods
lavaman131
committed
afc83db
feat(ralph): add graph-based Ralph workflow in graph.ts
lavaman131
committed
79a3df2
refactor(ralph): replace procedural handler with thin graph adapter in workflow-commands.ts
lavaman131
committed
3f073cb
refactor(ralph): move parseReviewResult to prompts.ts and update imports
lavaman131
committed
766c17b
feat(ralph): add planner agent and fix workflow-commands registry bug
lavaman131
committed
38c21d6
test: remove 10 obsolete workflow-commands tests
lavaman131
committed
25d061f
test: remove 2 broken tests that mock streamAndWait
lavaman131
committed
98b8864
test: remove 2 broken E2E tests that mock streamAndWait
lavaman131
committed
224f750
refactor: remove dead code from workflow-commands.ts
lavaman131
committed
439615d
docs: update documentation for graph module move and Ralph workflow refactor
lavaman131
committed
0756a9c

Commits on Feb 26, 2026

feat(workflows): create executor.ts skeleton with helper functions
lavaman131
committed
2e8ad75
feat(workflows): create WorkflowBridge interface and createTUIBridge() adapter
lavaman131
committed
8d25be0
feat(workflows): extend loadWorkflowsFromDisk() to extract graphConfig, createState, and nodeDescriptions
lavaman131
committed
acf42ce
feat(ralph): create WorkflowDefinition with metadata, state factory, and node descriptions
lavaman131
committed
5517c51
refactor(ui): rename ralph-task-state to workflow-task-state
lavaman131
committed
4b71021
feat(workflows): implement executeWorkflow() generic executor function

lavaman131
and
Copilot
committed
854db3c
feat(workflows): unify Ralph workflow dispatch through generic executeWorkflow path
lavaman131
committed
b68de76
refactor(workflows): remove WorkflowSDK class - Task #13 complete
lavaman131
committed
58cb99d
refactor(workflows): unify dispatch, delete createRalphCommand, remove SDK exports

lavaman131
and
Copilot
committed
dae7a66
test(workflows): add integration tests for executor features (tasks #46-48)
lavaman131
committed
b4ca4c8
test(workflows): add integration tests for Ralph, graphConfig compilation, and chat fallback
lavaman131
committed
093485b
fix(workflows): improve null safety and session tracking robustness

lavaman131
and
Copilot
committed
e9bffa3
refactor(workflows): remove SubagentGraphBridge in favor of direct spawn functions

lavaman131
and
Copilot
committed
c399d54
feat(events): implement BusEvent type definitions and BusEventDataMap
lavaman131
committed
fd8fd79
feat(events): implement EchoSuppressor replacing inline echo suppression logic
lavaman131
committed
2caa9b3
feat(events): implement coalescingKey() function with event-type routing
lavaman131
committed
42a198f
feat(events): implement AtomicEventBus class with typed pub/sub
lavaman131
committed
3b933d7
fix(telemetry): fix boundary condition race in filterStaleEvents test
lavaman131
committed
231a5c6
feat(events): implement BatchDispatcher with frame-aligned batching
lavaman131
committed
3a644f3
feat(events): add debug subscriber for event logging
lavaman131
committed
1f2a287
feat(events): add debug subscriber for event logging
lavaman131
committed
e08cf52
feat(events): implement OpenCode SDK stream adapter
lavaman131
committed
5a3459b
feat(events): wire event bus singleton via React context provider
lavaman131
committed
9bad750
test(events): add unit tests for BatchDispatcher and coalescingKey
lavaman131
committed
c3dbe9e
feat(events): add observability metrics to BatchDispatcher
lavaman131
committed
a520255
feat(events): implement StreamPipelineConsumer for BusEvent to StreamPartEvent mapping
lavaman131
committed
aef8f45
test(events): add SDK adapter tests with mock streams
lavaman131
committed
72fadab
feat(events): implement StreamPipelineConsumer for BusEvent to StreamPartEvent mapping
lavaman131
committed
b5a4ca2
feat(events): implement useEventBus and useBusSubscription React hooks
lavaman131
committed
bb3c9c8
refactor(workflows): remove legacy context calls replaced by bus events
lavaman131
committed
eb105ea
feat(events): implement useStreamConsumer hook
lavaman131
committed
cceb4b2
test(events): add integration tests for full event bus pipeline
lavaman131
committed
71b2b6a
refactor(ui): delete use-throttled-value hook replaced by batch flush
lavaman131
committed
4500022
refactor(ui): delete streamGenerationRef replaced by BusEvent runId
lavaman131
committed
6465db2
refactor(ui): fix ToolExecutionStatus imports after use-streaming-state deletion

lavaman131
and
Copilot
committed
4aaad1a
refactor(sdk): delete unused EventEmitter base class

lavaman131
and
Copilot
committed
a0f685f
refactor(ui): delete use-streaming-state hook replaced by useStreamConsumer
lavaman131
committed
9c01db1
refactor(ui): delete subscribeToToolEvents() function

lavaman131
and
Copilot
committed
b583c9f
refactor(ui): complete event bus migration tasks #21, #31, #32
lavaman131
committed
5592d69
test(events): add Zod validation failure tests to event-bus.test.ts
lavaman131
committed
9892a16
feat(events): add startStreaming/stopStreaming/isStreaming to useStreamConsumer hook
lavaman131
committed
7db94b2
feat(events): implement JSONL file-based event logging with rotation and replay
lavaman131
committed
b85627a
fix(events): cast chunk.type to string for agent event type checks

lavaman131
and
Copilot
committed
e775419
refactor(events): unify adapter stream contracts with UI pipeline
lavaman131
committed
4a8105a
chore: remove temporary debug and report files

lavaman131
and
Copilot
committed
e5a76ab
feat(events): expand unified event parity with reasoning, turn, and session lifecycle events

lavaman131
and
Copilot
committed
3496006
fix(events): prevent session event coalescing across types and fix tool-start race

lavaman131
and
Copilot
committed
f724e25
fix(tests): remove stale tests
lavaman131
committed
3a738af

Commits on Feb 27, 2026

fix(events): reconcile text-complete to prevent lost trailing content

lavaman131
and
Copilot
committed
c5cd49e
fix(events): accumulate output tokens across multi-turn API calls
lavaman131
committed
27b6476
chore: add .claude/settings.local.json to .gitignore
lavaman131
committed
c366591
fix(events): prevent double-counting output tokens during streaming
lavaman131
committed
3946347
feat(events): add subagent tool tracking with update events

lavaman131
and
Copilot
committed
a4b00a5
feat(ui): improve agent tree display and tool registry

lavaman131
and
Copilot
committed
56e7d0c
chore: update docs, deps, and remove stale files

lavaman131
and
Copilot
committed
08b39e5
fix(agent-commands): stop premature stream finalization for @ sub-agents

lavaman131
and
Copilot
committed
ed0ffb8
fix(utils): handle CRLF line endings in markdown frontmatter parsing

lavaman131
and
Copilot
committed
58ce692
feat(events): add permission.requested event forwarding in Claude adapter

lavaman131
and
Copilot
committed
b6cbbd7
feat(sdk): synthesize subagent lifecycle events for OpenCode Task tools

lavaman131
and
Copilot
committed
445167b
refactor(ui): improve newline and enqueue shortcut handling

lavaman131
and
Copilot
committed
c1ca2b5
fix(copilot): provide onPermissionRequest for probe session

lavaman131
and
Copilot
committed
4b8c6fc
fix(update): handle cross-device rename during binary replacement

lavaman131
and
Copilot
committed
9790fdd
fix(chat): cancel active stream on direct send regardless of foreground subagents

lavaman131
and
Copilot
committed
07278e1
chore(deps): bump up deps
lavaman131
committed
60eb300
fix(streaming): fix 6 sub-agent tree streaming bugs in workflows

lavaman131
and
Copilot
committed
aed66d9

Commits on Feb 28, 2026

refactor(types): replace deprecated SubagentResult with SubagentStreamResult
lavaman131
committed
db48286
fix(workflow): fix loop exit edge, parallel workers, and event pipeline bugs

lavaman131
and
Copilot
committed
8db3633
refactor(workflow): require spawnSubagentParallel for worker node dispatch
lavaman131
committed
fb43aae
perf(chat): consolidate React state updates in handleStreamComplete
lavaman131
committed
e5f4d18
feat(events): add workflow.task.statusChange bus event, executor subscriber, and debounce
lavaman131
committed
2120162
feat(ui): wire TimestampDisplay into MessageBubble for verbose mode

lavaman131
and
Copilot
committed
30631dc
fix(mcp-bridge): replace placeholder with actual tool handler dispatch

lavaman131
and
Copilot
committed
450a8d3
docs: add workflow research and implementation specs

lavaman131
and
Copilot
committed
d546b8e
feat(events): add pipeline logger and agentId to bus events

lavaman131
and
Copilot
committed
9a363f5
feat(ui): add workflow step rendering, turn lifecycle, and session events

lavaman131
and
Copilot
committed
1795604
feat(workflows): add failure/cancellation handling and subagent logging

lavaman131
and
Copilot
committed
4fc2118
feat(sdk): add custom tool discovery and wire into chat init

lavaman131
and
Copilot
committed
0a68d71
fix(ui): render sub-agent inline parts and fix task list blinking

lavaman131
and
Copilot
committed
f209a0f
build(deps): bump claude-agent-sdk and copilot-sdk

lavaman131
and
Copilot
committed
882bb0e
feat(events): propagate parentAgentId through stream pipeline

lavaman131
and
Copilot
committed
19fbd99
refactor(ui): simplify auto-compaction and improve workflow streaming

lavaman131
and
Copilot
committed
c88d4d1
refactor(ui): unify workflow TUI rendering pipeline

lavaman131
and
Copilot
committed
2ede0d3

Commits on Mar 1, 2026

refactor(ui): remove appendBackgroundAgentMessage wrapper

lavaman131
and
Copilot
committed
a9d09fd
fix(opencode): defer session.idle to prevent race condition dropping responses

lavaman131
and
Copilot
committed
c16b9d3
feat(events,sdk): normalize sub-agent correlation IDs, hook routing, and terminal signals
lavaman131
committed
06483d0
refactor(ui): harden background termination, workflow input lifecycle, and agent tree rendering
lavaman131
committed
e5a87c5
docs: add troubleshooting for stuck sub-agent loading indicators
lavaman131
committed
984d2a0
fix(sdk): render thinking traces for all SDKs

lavaman131
and
Copilot
committed
6d1f99a
fix(opencode): start SSE event loop before setting isRunning flag

lavaman131
and
Copilot
committed
e207914
fix(opencode): prevent duplicate message deltas in v2 SSE stream

lavaman131
and
Copilot
committed
b7b4d83
fix(opencode): prevent duplicate stream deltas and cancellation notices
lavaman131
committed
a393bf6
refactor(opencode): migrate from prompt() to promptAsync() for SSE-only streaming

lavaman131
and
Copilot
committed
d9f522b
feat(streaming): add robustness improvements to streaming architecture

lavaman131
and
Copilot
committed
ede4deb
feat(runtime): default-enable strict task contract rollout
lavaman131
committed
7debf48
feat(runtime): align opencode streaming and workflow event parity
lavaman131
committed
8865781

Commits on Mar 2, 2026

feat(playwright): expand references and harden stream lifecycle
lavaman131
committed
0206c8c
feat(runtime): harden cross-provider streaming contracts and observability
lavaman131
committed
c474064
feat(events): add raw stream debug log and per-session log folders
lavaman131
committed
49fab1c
feat(streaming): improve cross-provider sub-agent correlation and display
lavaman131
committed
0fe29f9
feat(events): improve sub-agent tool event correlation and early buffering
lavaman131
committed
01d5e57
feat(streaming): harden parallel sub-agent tool attribution and lifecycle
lavaman131
committed
e73c235
fix(streaming): preserve sub-agent TaskOutput attribution across child sessions
lavaman131
committed
f643056
fix(installer): address PR review feedback

lavaman131
and
Copilot
committed
86f3b13
fix(ci): initialize parser variables before use in syntax validation

lavaman131
and
Copilot
committed
9696bfa
fix(installer): add PSScriptAnalyzer suppressions and fix function naming

lavaman131
and
Copilot
committed
b678143