fix: propagate client connection errors and check capability value truthiness

src/agent-client-protocol/src/capabilities.rs

@@ -17,7 +17,7 @@
 //! ```
 
 use crate::schema::{InitializeRequest, InitializeResponse};
-use serde_json::json;
+use serde_json::{json, Value};
 
 /// Trait for capabilities stored in the `_meta.symposium` object.
 ///
@@ -67,7 +67,8 @@ impl MetaCapabilityExt for InitializeRequest {
             .as_ref()
             .and_then(|meta| meta.get("symposium"))
             .and_then(|symposium| symposium.get(capability.key()))
-            .is_some()
+            .map(|v| !matches!(v, Value::Bool(false) | Value::Null))
+            .unwrap_or(false)
     }
 
     fn add_meta_capability(mut self, capability: impl MetaCapability) -> Self {
@@ -104,7 +105,8 @@ impl MetaCapabilityExt for InitializeResponse {
             .as_ref()
             .and_then(|meta| meta.get("symposium"))
             .and_then(|symposium| symposium.get(capability.key()))
-            .is_some()
+            .map(|v| !matches!(v, Value::Bool(false) | Value::Null))
+            .unwrap_or(false)
     }
 
     fn add_meta_capability(mut self, capability: impl MetaCapability) -> Self {
@@ -185,4 +187,40 @@ mod tests {
             json!(true)
         );
     }
+
+    #[test]
+    fn test_has_meta_capability_false_value() {
+        let mut meta = serde_json::Map::new();
+        meta.insert(
+            "symposium".to_string(),
+            json!({
+                "version": "1.0",
+                "mcp_acp_transport": false
+            }),
+        );
+        let client_capabilities = ClientCapabilities::new().meta(meta);
+
+        let request = InitializeRequest::new(ProtocolVersion::LATEST)
+            .client_capabilities(client_capabilities);
+
+        assert!(!request.has_meta_capability(McpAcpTransport));
+    }
+
+    #[test]
+    fn test_has_meta_capability_null_value() {
+        let mut meta = serde_json::Map::new();
+        meta.insert(
+            "symposium".to_string(),
+            json!({
+                "version": "1.0",
+                "mcp_acp_transport": null
+            }),
+        );
+        let client_capabilities = ClientCapabilities::new().meta(meta);
+
+        let request = InitializeRequest::new(ProtocolVersion::LATEST)
+            .client_capabilities(client_capabilities);
+
+        assert!(!request.has_meta_capability(McpAcpTransport));
+    }
 }

src/agent-client-protocol/src/mcp_server/builder.rs

@@ -393,17 +393,13 @@ impl<Counterpart: Role> ConnectTo<role::mcp::Client> for McpServerConnection<Cou
         let (mcp_client_read, mcp_client_write) = tokio::io::split(mcp_client_stream);
 
         let run_client = async {
-            // Connect byte_streams to the provided client
             let byte_streams =
                 ByteStreams::new(mcp_client_write.compat_write(), mcp_client_read.compat());
-            drop(
-                <ByteStreams<_, _> as ConnectTo<role::mcp::Client>>::connect_to(
-                    byte_streams,
-                    client,
-                )
-                .await,
-            );
-            Ok(())
+            <ByteStreams<_, _> as ConnectTo<role::mcp::Client>>::connect_to(
+                byte_streams,
+                client,
+            )
+            .await
         };
 
         let run_server = async {