diff options
| author | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-05-26 21:52:19 +0300 |
|---|---|---|
| committer | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-05-26 21:53:50 +0300 |
| commit | 427c2606d8f62558e3949d2f44173175e96bed49 (patch) | |
| tree | 0d351c30c3132037beb75ea20c378d75e6b34c80 /tests/api_ping.rs | |
| parent | 31e973502af205666cb4a48e3f9e10328f65cd4e (diff) | |
fix: deliver agent status subscriptions from event hub
Diffstat (limited to 'tests/api_ping.rs')
| -rw-r--r-- | tests/api_ping.rs | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/tests/api_ping.rs b/tests/api_ping.rs index 31443317..239daeae 100644 --- a/tests/api_ping.rs +++ b/tests/api_ping.rs @@ -1979,12 +1979,16 @@ fn metadata_status_subscription_filter_and_ttl_expiry_are_observable() { let set_event = reader.read_json_line(Duration::from_secs(2)); assert_eq!(set_event["event"], "pane.agent_status_changed"); + assert_eq!(set_event["data"]["pane_id"], pane_id); assert_eq!(set_event["data"]["agent_status"], "working"); + assert_eq!(set_event["data"]["agent"], "pi"); assert_eq!(set_event["data"]["custom_status"], "short lived"); let expiry_event = reader.read_json_line(Duration::from_secs(3)); assert_eq!(expiry_event["event"], "pane.agent_status_changed"); + assert_eq!(expiry_event["data"]["pane_id"], pane_id); assert_eq!(expiry_event["data"]["agent_status"], "working"); + assert_eq!(expiry_event["data"]["agent"], "pi"); assert!(expiry_event["data"]["custom_status"].is_null()); cleanup_spawned_herdr(child, base); |
