feat(acp): accept signed events through a local forward socket - #7764
Draft
Gforce10-design wants to merge 1 commit into
Draft
Gforce10-design wants to merge 1 commit into
Gforce10-design wants to merge 1 commit into
Conversation
Signed-off-by: Gforce10_desighn <sudoli819@gmail.com>
🔐 Codex Security Review
|
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.
Summary
Allow a local gateway to deliver original signed Buzz events to ACP through an opt-in Unix socket, while preserving the existing author, mention, thread/session, queue, and steering decisions.
--relay-input falsedisables data subscriptions while retaining membership notifications and outbound publishing.The socket checks native peer UID, event signature, channel membership, canonical channel ID, and dedupe key. Both sources enter one typed admission function. Explicit state storage, frame/read/concurrency limits, and startup path checks bound the local interface. Forward input is Unix-only; default relay operation remains available on other platforms.
acceptedmeans admission or intentional policy filtering with persisted occupancy, not completed work. Queues remain in memory and the bounded occupancy history does not provide exactly-once delivery. Seecrates/buzz-acp/FORWARDING.mdfor protocol and failure semantics.This branch is based directly on upstream
ef2aa1ae38fadcc0bc22b8bf6ed96b35933146be; it does not carry the original prototype's unrelated ancestor commits.Related issue
N/A. Searched existing block/buzz issues and PRs for "forward socket"; none found. Companion gateway implementation: NousResearch/hermes-agent#116264.
Testing
cargo test -p buzz-acp, 993 passed, 1 ignored, including native peer credentials, shared admission, concurrent persistence and socket path preservation.cargo test -p buzz-acp, 993 passed, 1 ignored, with the rustdoc phase passing. An earlier rustdoc dependency-artifact failure during concurrent builds did not recur in this serial run.just ci: exit 0, covering repository checks and Rust, desktop, web and mobile test/build gates. After the final narrow review fixes, the affected crate tests, Clippy (--all-targets -- -D warnings), workspace formatting and file-size checks were revalidated and passed.