KofTwentyTwo/Jarvis
2
0 Fork 0
Code Issues 111 Pull Requests 16 Actions Packages Projects Releases 4 Wiki Activity

M-0: BusForwarder sink fanout + check-fanout-drainer.sh boundary gate (R-009) #97

New Issue
Open
opened 2026-05-12 19:36:44 +00:00 by KofTwentyTwo · 0 comments
KofTwentyTwo commented 2026-05-12 19:36:44 +00:00 (Migrated from github.com)
Copy link
Copy source

Goal

BusForwarder.drain takes sink fan-out: 1 drainer, N>=1 sinks (AppBusForwarderSink, HarnessSink, ReplaySink). Add check-fanout-drainer.sh as 18th boundary gate asserting exactly one fanout drainer. Mitigates R-009.

Scope

  • BusForwarder.drain accepts [Sink] parameter
  • Multiple sinks supported: AppBusForwarderSink, HarnessSink, ReplaySink
  • scripts/check-orchestrator-events-single-consumer.sh updated to assert exactly one fanout drainer
  • New scripts/check-fanout-drainer.sh

Files

  • packages/AgentCore/Sources/AgentOrchestrator/BusForwarder.swift
  • scripts/check-orchestrator-events-single-consumer.sh (update)
  • scripts/check-fanout-drainer.sh (new)

Acceptance

  • Drainer count == 1
  • Sink count >= 1 with all three sinks registered
  • scripts/check-fanout-drainer.sh green
  • scripts/check-orchestrator-events-single-consumer.sh green with new semantics

Test

Unit test: register 3 sinks → all receive each event. Boundary script asserts single drainer literal.

Parent epic

#4

Source

.planning/architecture/JARVIS-API-MIGRATION-PLAN.md §2.1 (M-0.8)
.planning/architecture/REVIEW-MIGRATION-RISK.md R-009

## Goal BusForwarder.drain takes sink fan-out: 1 drainer, N>=1 sinks (AppBusForwarderSink, HarnessSink, ReplaySink). Add check-fanout-drainer.sh as 18th boundary gate asserting exactly one fanout drainer. Mitigates R-009. ## Scope - `BusForwarder.drain` accepts `[Sink]` parameter - Multiple sinks supported: `AppBusForwarderSink`, `HarnessSink`, `ReplaySink` - `scripts/check-orchestrator-events-single-consumer.sh` updated to assert exactly one fanout drainer - New `scripts/check-fanout-drainer.sh` ## Files - `packages/AgentCore/Sources/AgentOrchestrator/BusForwarder.swift` - `scripts/check-orchestrator-events-single-consumer.sh` (update) - `scripts/check-fanout-drainer.sh` (new) ## Acceptance - [ ] Drainer count == 1 - [ ] Sink count >= 1 with all three sinks registered - [ ] `scripts/check-fanout-drainer.sh` green - [ ] `scripts/check-orchestrator-events-single-consumer.sh` green with new semantics ## Test Unit test: register 3 sinks → all receive each event. Boundary script asserts single drainer literal. ## Parent epic #4 ## Source `.planning/architecture/JARVIS-API-MIGRATION-PLAN.md` §2.1 (M-0.8) `.planning/architecture/REVIEW-MIGRATION-RISK.md` R-009
Sign in to join this conversation.
No Branch/Tag Specified
Labels
Clear labels
area:agent
area:build
area:bus
area:devtool
area:hud
area:logging
area:mcp
area:memory
area:vision
area:voice
audit-finding
bug
Something isn't working
 carry-forward
comment-cleanup
Comment / docstring cleanup per .planning/code-commenting-guide.md
 dependencies
Dependency updates
 documentation
Improvements or additions to documentation
 duplicate
This issue or pull request already exists
 enhancement
New feature or request
 epic
good first issue
Good for newcomers
 help wanted
Extra attention is needed
 invalid
This doesn't seem right
 javascript
Pull requests that update javascript code
 migration
question
Further information is requested
 severity:critical
severity:high
severity:low
severity:medium
wontfix
This will not be worked on
No labels area:bus enhancement migration
Milestone
No items
No Milestone v0.5 — API M-0..M-3 (Self / Settings / Diagnostics surfaces)
Projects
Clear projects
No projects
Assignees
Clear assignees
forge-recovery (Forge Recovery) james.maes (James Maes)
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: KofTwentyTwo/Jarvis#97