Adjust logging level for frequent / low-level events

Author: mattt

Sources/MCP/Base/Transports/HTTPClientTransport.swift

@@ -131,7 +131,7 @@ public actor HTTPClientTransport: Transport {
         if let continuation = self.initialSessionIDContinuation {
             continuation.resume()
             self.initialSessionIDContinuation = nil  // Consume the continuation
-            logger.debug("Initial session ID signal triggered for SSE task.")
+            logger.trace("Initial session ID signal triggered for SSE task.")
         }
     }
 
@@ -251,7 +251,7 @@ public actor HTTPClientTransport: Transport {
                 logger.warning("SSE responses aren't fully supported on Linux")
                 messageContinuation.yield(data)
             } else if contentType.contains("application/json") {
-                logger.debug("Received JSON response", metadata: ["size": "\(data.count)"])
+                logger.trace("Received JSON response", metadata: ["size": "\(data.count)"])
                 messageContinuation.yield(data)
             } else {
                 logger.warning("Unexpected content type: \(contentType)")
@@ -285,15 +285,15 @@ public actor HTTPClientTransport: Transport {
 
             if contentType.contains("text/event-stream") {
                 // For SSE, processing happens via the stream
-                logger.debug("Received SSE response, processing in streaming task")
+                logger.trace("Received SSE response, processing in streaming task")
                 try await self.processSSE(stream)
             } else if contentType.contains("application/json") {
                 // For JSON responses, collect and deliver the data
                 var buffer = Data()
                 for try await byte in stream {
                     buffer.append(byte)
                 }
-                logger.debug("Received JSON response", metadata: ["size": "\(buffer.count)"])
+                logger.trace("Received JSON response", metadata: ["size": "\(buffer.count)"])
                 messageContinuation.yield(buffer)
             } else {
                 logger.warning("Unexpected content type: \(contentType)")
@@ -390,7 +390,7 @@ public actor HTTPClientTransport: Transport {
 
             // Wait for the initial session ID signal, but only if sessionID isn't already set
             if self.sessionID == nil, let signalTask = self.initialSessionIDSignalTask {
-                logger.debug("SSE streaming task waiting for initial sessionID signal...")
+                logger.trace("SSE streaming task waiting for initial sessionID signal...")
 
                 // Race the signalTask against a timeout
                 let timeoutTask = Task {
@@ -429,16 +429,16 @@ public actor HTTPClientTransport: Transport {
                 timeoutTask.cancel()
 
                 if signalReceived {
-                    logger.debug("SSE streaming task proceeding after initial sessionID signal.")
+                    logger.trace("SSE streaming task proceeding after initial sessionID signal.")
                 } else {
                     logger.warning(
                         "Timeout waiting for initial sessionID signal. SSE stream will proceed (sessionID might be nil)."
                     )
                 }
             } else if self.sessionID != nil {
-                logger.debug(
-                    "Initial sessionID already available. Proceeding with SSE streaming task immediately."
-                )
+            logger.trace(
+            "Initial sessionID already available. Proceeding with SSE streaming task immediately."
+            )
             } else {
                 logger.info(
                     "Proceeding with SSE connection attempt; sessionID is nil. This might be expected for stateless servers or if initialize hasn't provided one yet."
@@ -525,7 +525,7 @@ public actor HTTPClientTransport: Transport {
                     // Check if task has been cancelled
                     if Task.isCancelled { break }
 
-                    logger.debug(
+                    logger.trace(
                         "SSE event received",
                         metadata: [
                             "type": "\(event.event ?? "message")",

Sources/MCP/Base/Transports/NetworkTransport.swift

@@ -309,11 +309,11 @@ import Logging
                         case .cancelled:
                             await self.handleConnectionCancelled(continuation: continuation)
                         case .waiting(let error):
-                            self.logger.debug("Connection waiting: \(error)")
+                            self.logger.trace("Connection waiting: \(error)")
                         case .preparing:
-                            self.logger.debug("Connection preparing...")
+                            self.logger.trace("Connection preparing...")
                         case .setup:
-                            self.logger.debug("Connection setup...")
+                            self.logger.trace("Connection setup...")
                         @unknown default:
                             self.logger.warning("Unknown connection state")
                         }
@@ -408,7 +408,7 @@ import Logging
                     })
             }
 
-            logger.debug("Heartbeat sent")
+            logger.trace("Heartbeat sent")
         }
 
         /// Handles connection failure
@@ -638,11 +638,11 @@ import Logging
 
                     // Check if this is a heartbeat message
                     if Heartbeat.isHeartbeat(newData) {
-                        logger.debug("Received heartbeat from peer")
+                        logger.trace("Received heartbeat from peer")
 
                         // Extract timestamp if available
                         if let heartbeat = Heartbeat.from(data: newData) {
-                            logger.debug("Heartbeat timestamp: \(heartbeat.timestamp)")
+                            logger.trace("Heartbeat timestamp: \(heartbeat.timestamp)")
                         }
 
                         // Reset the counter since we got valid data