Skip to content

Commit 078682a

Browse files
committed
feat(acp-nats): add session_update client handler
- Add client proxy infrastructure (run loop, subject parsing) - Add session_update handler for SessionNotification forwarding - Add nats/parsing.rs with ClientMethod::SessionUpdate - Add client subjects (session_update, wildcards) - Add bytes, futures deps for subscriber stream - Tests: session_update forwards, invalid payload, client error Signed-off-by: Yordis Prieto <yordis.prieto@gmail.com>
1 parent 3af5a23 commit 078682a

9 files changed

Lines changed: 579 additions & 37 deletions

File tree

rsworkspace/Cargo.lock

Lines changed: 34 additions & 32 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

rsworkspace/crates/acp-nats/Cargo.toml

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,11 @@ workspace = true
88

99
[dependencies]
1010
agent-client-protocol = "0.9.4"
11-
opentelemetry = "0.31.0"
1211
async-nats = "0.45.0"
1312
async-trait = "0.1.89"
13+
bytes = "1.9"
14+
futures = "0.3"
15+
opentelemetry = "0.31.0"
1416
serde = { version = "1.0.228", features = ["derive"] }
1517
serde_json = "1.0.149"
1618
tokio = { version = "1.49.0", features = ["rt", "macros", "sync", "time"] }

0 commit comments

Comments
 (0)