fix: update protocol to v0.5.11, fix integration test connect() pattern

Update zentinel-agent-protocol lockfile. Fix integration test
to separate new() and connect() calls.

Author: raffaelschneider

src/lib.rs

@@ -29,12 +29,12 @@ use tokio::sync::RwLock;
 use tracing::{debug, info, warn};
 
 use zentinel_agent_protocol::{
-    AgentResponse, AuditMetadata, HeaderOp, RequestBodyChunkEvent,
-    RequestHeadersEvent, ResponseBodyChunkEvent, ResponseHeadersEvent, EventType,
     v2::{
-        AgentCapabilities, AgentFeatures, AgentHandlerV2, AgentLimits, DrainReason,
-        HealthStatus, MetricsReport, ShutdownReason,
+        AgentCapabilities, AgentFeatures, AgentHandlerV2, AgentLimits, DrainReason, HealthStatus,
+        MetricsReport, ShutdownReason,
     },
+    AgentResponse, AuditMetadata, EventType, HeaderOp, RequestBodyChunkEvent, RequestHeadersEvent,
+    ResponseBodyChunkEvent, ResponseHeadersEvent,
 };
 
 /// ModSecurity configuration

src/main.rs

@@ -123,7 +123,10 @@ async fn main() -> Result<()> {
         // gRPC transport (v2 protocol)
         info!(address = %grpc_addr, "Starting gRPC v2 agent server");
         let server = GrpcAgentServerV2::new("zentinel-modsec-agent", Box::new(agent));
-        server.run(grpc_addr).await.map_err(|e| anyhow::anyhow!("{}", e))?;
+        server
+            .run(grpc_addr)
+            .await
+            .map_err(|e| anyhow::anyhow!("{}", e))?;
     } else {
         // UDS transport (v2 protocol)
         info!(socket = ?args.socket, "Starting UDS agent server");

tests/crs_integration.rs

@@ -4,16 +4,15 @@
 //! The CRS must be present in testdata/crs/ for these tests to run.
 
 use base64::Engine;
-use zentinel_agent_modsec::{ModSecAgent, ModSecConfig};
-use zentinel_agent_protocol::{
-    Decision, RequestBodyChunkEvent, RequestHeadersEvent,
-    RequestMetadata,
-    v2::{AgentClientV2Uds, UdsAgentServerV2},
-};
 use std::collections::HashMap;
 use std::path::Path;
 use std::time::Duration;
 use tempfile::tempdir;
+use zentinel_agent_modsec::{ModSecAgent, ModSecConfig};
+use zentinel_agent_protocol::{
+    v2::{AgentClientV2Uds, UdsAgentServerV2},
+    Decision, RequestBodyChunkEvent, RequestHeadersEvent, RequestMetadata,
+};
 
 /// Check if CRS is available
 fn crs_available() -> bool {
@@ -59,12 +58,16 @@ async fn start_crs_server(config: ModSecConfig) -> Option<(tempfile::TempDir, st
 
 /// Create a client connected to the test server
 async fn create_client(socket_path: &std::path::Path) -> AgentClientV2Uds {
-    AgentClientV2Uds::new("test-client", socket_path.to_string_lossy().to_string(), Duration::from_secs(5))
-        .await
-        .expect("Failed to create agent client")
-        .connect()
-        .await
-        .expect("Failed to connect to agent")
+    AgentClientV2Uds::new(
+        "test-client",
+        socket_path.to_string_lossy().to_string(),
+        Duration::from_secs(5),
+    )
+    .await
+    .expect("Failed to create agent client")
+    .connect()
+    .await
+    .expect("Failed to connect to agent")
 }
 
 /// Create a basic request metadata

tests/integration.rs

@@ -7,16 +7,15 @@
 //! you would typically use the full OWASP CRS ruleset.
 
 use base64::Engine;
-use zentinel_agent_modsec::{ModSecAgent, ModSecConfig};
-use zentinel_agent_protocol::{
-    Decision, RequestBodyChunkEvent, RequestHeadersEvent,
-    RequestMetadata, ResponseBodyChunkEvent,
-    v2::{AgentClientV2Uds, UdsAgentServerV2},
-};
 use std::collections::HashMap;
 use std::io::Write;
 use std::time::Duration;
 use tempfile::tempdir;
+use zentinel_agent_modsec::{ModSecAgent, ModSecConfig};
+use zentinel_agent_protocol::{
+    v2::{AgentClientV2Uds, UdsAgentServerV2},
+    Decision, RequestBodyChunkEvent, RequestHeadersEvent, RequestMetadata, ResponseBodyChunkEvent,
+};
 
 /// Basic ModSecurity rules for testing
 /// These are simplified rules that mirror common attack patterns
@@ -108,12 +107,15 @@ async fn start_test_server_with_rules() -> (tempfile::TempDir, std::path::PathBu
 
 /// Create a client connected to the test server
 async fn create_client(socket_path: &std::path::Path) -> AgentClientV2Uds {
-    AgentClientV2Uds::new("test-client", socket_path.to_string_lossy().to_string(), Duration::from_secs(5))
-        .await
-        .expect("Failed to create agent client")
-        .connect()
-        .await
-        .expect("Failed to connect to agent")
+    let client = AgentClientV2Uds::new(
+        "test-client",
+        socket_path.to_string_lossy().to_string(),
+        Duration::from_secs(5),
+    )
+    .await
+    .expect("Failed to create agent client");
+    client.connect().await.expect("Failed to connect to agent");
+    client
 }
 
 /// Create a basic request metadata