feat: multi-tenant Phase 4 — context-tagged event producer

Cargo.toml

@@ -51,7 +51,7 @@ exclude         = ["examples", "tests", "docs", "scripts"]
 default-members = ["ras-cli", "ras-daemon"]
 
 [workspace.package]
-version       = "3.4.0"
+version       = "3.5.0"
 edition       = "2024"
 rust-version  = "1.95.0"
 license       = "MIT"

ras-cdp/Cargo.toml

@@ -27,7 +27,8 @@ tracing       = { workspace = true }
 url           = { workspace = true }
 
 [dev-dependencies]
-tokio      = { workspace = true, features = ["macros", "rt-multi-thread"] }
+tokio      = { workspace = true, features = ["macros", "rt-multi-thread", "time"] }
 url        = { workspace = true }
 serde_json = { workspace = true }
 ras-types  = { workspace = true }
+ras-events = { workspace = true }

ras-cdp/src/domain/repository.rs

@@ -1,5 +1,8 @@
+use std::sync::Arc;
+
 use async_trait::async_trait;
 use ras_errors::AppError;
+use ras_events::EventBus;
 use ras_types::{BackendNodeId, ContextId, TargetId};
 use serde::{Deserialize, Serialize};
 use url::Url;
@@ -92,4 +95,15 @@ pub trait BrowserPort: Send + Sync + 'static {
             "list_targets_in not supported by this BrowserPort".into(),
         ))
     }
+
+    /// Forward this target's browser events to `bus` (per-session isolation).
+    ///
+    /// Default: no-op. Override in adapters that support live CDP streams.
+    async fn attach_events(
+        &self,
+        _target: &TargetId,
+        _bus: Arc<dyn EventBus>,
+    ) -> Result<(), AppError> {
+        Ok(())
+    }
 }