update

Author: Tom Softreck

tests/unit/test_http_simple.py

@@ -0,0 +1,95 @@
+"""Simplified test for HTTPDestination."""
+import asyncio
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+
+# Import only what we need
+import sys
+import os
+sys.path.insert(0, os.path.abspath(os.path.join(os.path.dirname(__file__), '../../src')))
+
+from dialogchain.connectors import HTTPDestination
+
+class AsyncMockContext:
+    def __init__(self, return_value):
+        self.return_value = return_value
+    
+    async def __aenter__(self):
+        return self.return_value
+    
+    async def __aexit__(self, exc_type, exc_val, exc_tb):
+        pass
+
+class TestHTTPSimple:
+    """Simplified test for HTTPDestination."""
+    
+    @pytest.fixture
+    def http_dest(self):
+        """Create an HTTPDestination instance for testing."""
+        return HTTPDestination("http://example.com/webhook")
+    
+    @pytest.mark.asyncio
+    async def test_send_http_request(self, http_dest, capsys):
+        """Test sending an HTTP request."""
+        # Create a mock response
+        mock_response = AsyncMock()
+        mock_response.status = 200
+        mock_response.text = AsyncMock(return_value="OK")
+        
+        # Patch the ClientSession.post method
+        with patch('aiohttp.ClientSession.post', 
+                  return_value=AsyncMockContext(mock_response)) as mock_post:
+            # Test with dict message
+            await http_dest.send({"key": "value"})
+            
+            # Check output
+            captured = capsys.readouterr()
+            assert "🌐 HTTP sent to http://example.com/webhook" in captured.out
+            
+            # Verify the post was called correctly
+            mock_post.assert_called_once_with(
+                'http://example.com/webhook',
+                json={"key": "value"}
+            )
+    
+    @pytest.mark.asyncio
+    async def test_send_string_message(self, http_dest, capsys):
+        """Test sending a string message."""
+        # Create a mock response
+        mock_response = AsyncMock()
+        mock_response.status = 200
+        mock_response.text = AsyncMock(return_value="OK")
+        
+        # Patch the ClientSession.post method
+        with patch('aiohttp.ClientSession.post',
+                  return_value=AsyncMockContext(mock_response)) as mock_post:
+            # Test with string message
+            await http_dest.send("test message")
+            
+            # Check output
+            captured = capsys.readouterr()
+            assert "🌐 HTTP sent to http://example.com/webhook" in captured.out
+            
+            # Verify the post was called correctly
+            mock_post.assert_called_once_with(
+                'http://example.com/webhook',
+                json={"data": "test message"}
+            )
+    
+    @pytest.mark.asyncio
+    async def test_http_error(self, http_dest, capsys):
+        """Test handling of HTTP errors."""
+        # Create a mock response with error status
+        mock_response = AsyncMock()
+        mock_response.status = 400
+        mock_response.text = AsyncMock(return_value="Bad Request")
+        
+        # Patch the ClientSession.post method
+        with patch('aiohttp.ClientSession.post',
+                  return_value=AsyncMockContext(mock_response)) as mock_post:
+            # Test with dict message
+            await http_dest.send({"key": "value"})
+            
+            # Check error output
+            captured = capsys.readouterr()
+            assert "❌ HTTP error 400: Bad Request" in captured.out