fixed oauth exceptions

Author: chrishayuk

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "chuk-tool-processor"
-version = "0.9.5"
+version = "0.9.6"
 description = "Async-native framework for registering, discovering, and executing tools referenced in LLM responses"
 readme = "README.md"
 requires-python = ">=3.11"

src/chuk_tool_processor/mcp/transport/http_streamable_transport.py

@@ -239,13 +239,13 @@ async def initialize(self) -> bool:
             await self._cleanup()
             if self.enable_metrics and self._metrics:
                 self._metrics.connection_errors += 1
-            return False
+            raise  # Re-raise for OAuth error detection in mcp-cli
         except Exception as e:
             logger.error("Error initializing HTTP Streamable transport: %s", e, exc_info=True)
             await self._cleanup()
             if self.enable_metrics and self._metrics:
                 self._metrics.connection_errors += 1
-            return False
+            raise  # Re-raise for OAuth error detection in mcp-cli
 
     async def _attempt_recovery(self) -> bool:
         """Attempt to recover from connection issues (NEW - like SSE resilience)."""

tests/mcp/transport/test_http_streamable.py

@@ -132,10 +132,14 @@ async def test_initialize_timeout(self, transport):
             # Simulate timeout during context entry
             mock_http_transport.__aenter__.side_effect = TimeoutError()
 
-            result = await transport.initialize()
+            # Now expecting TimeoutError to be raised instead of returning False
+            with pytest.raises(TimeoutError):
+                await transport.initialize()
 
-            assert result is False
             assert transport._initialized is False
+            # Check metrics were updated
+            metrics = transport.get_metrics()
+            assert metrics["connection_errors"] == 1
 
     @pytest.mark.asyncio
     async def test_send_ping_success(self, transport):
@@ -555,8 +559,14 @@ async def test_initialize_with_exception(self, transport):
             "chuk_tool_processor.mcp.transport.http_streamable_transport.ChukHTTPTransport",
             side_effect=Exception("Connection error"),
         ):
-            result = await transport.initialize()
-            assert result is False
+            # Now expecting Exception to be raised instead of returning False
+            with pytest.raises(Exception, match="Connection error"):
+                await transport.initialize()
+
+            assert transport._initialized is False
+            # Check metrics were updated
+            metrics = transport.get_metrics()
+            assert metrics["connection_errors"] == 1
 
     @pytest.mark.asyncio
     async def test_send_ping_increments_failures(self, transport):
@@ -791,8 +801,11 @@ async def test_initialize_connection_error_increments_metric(self, transport):
             "chuk_tool_processor.mcp.transport.http_streamable_transport.ChukHTTPTransport",
             side_effect=Exception("Connection error"),
         ):
-            result = await transport.initialize()
-            assert result is False
+            # Now expecting Exception to be raised instead of returning False
+            with pytest.raises(Exception, match="Connection error"):
+                await transport.initialize()
+
+            assert transport._initialized is False
             assert transport._metrics.connection_errors == 1
 
     @pytest.mark.asyncio