v27.3.4 (#95)

* remove mongo memory as was caching old values and confusing tools

* update poetry

* update poetry and readme

Author: truemagic-coder

README.md

@@ -485,6 +485,40 @@ async for response in solana_agent.process("user123", "What is the latest news o
     print(response, end="")
 ```
 
+### MCP
+
+[Zapier](https://zapier.com) MCP has been tested, works, and is supported.
+
+Other MCP servers may work but are not supported.
+
+`pip install sakit`
+
+```python
+
+from solana_agent import SolanaAgent
+
+config = {
+    "tools": {
+        "mcp": {
+            "urls": ["my-zapier-mcp-url"],
+        }
+    },
+    "agents": [
+        {
+            "name": "zapier_expert",
+            "instructions": "You are an expert in using Zapier integrations using MCP. You always use the mcp tool to perform Zapier AI like actions.",
+            "specialization": "Zapier service integration expert",
+            "tools": ["mcp"],  # Enable the tool for this agent
+        }
+    ]
+}
+
+solana_agent = SolanaAgent(config=config)
+
+async for response in solana_agent.process("user123", "Send an email to bob@bob.com to clean his room!"):
+    print(response, end="")
+```
+
 ### Inline Tool Example
 
 ```python

docs/index.rst

@@ -444,6 +444,42 @@ Internet Search
       print(response, end="")
 
 
+MCP
+~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+
+Zapier MCP has been tested, works, and is supported. 
+
+Other MCP servers may work but are not supported.
+
+.. code-block:: bash
+   
+   pip install sakit
+
+.. code-block:: python
+
+   from solana_agent import SolanaAgent
+
+   config = {
+      "tools": {
+         "mcp": {
+               "urls": ["my-zapier-mcp-url"],
+         }
+      },
+      "agents": [
+         {
+               "name": "zapier_expert",
+               "instructions": "You are an expert in using Zapier integrations using MCP. You always use the mcp tool to perform Zapier AI like actions.",
+               "specialization": "Zapier service integration expert",
+               "tools": ["mcp"],  # Enable the tool for this agent
+         }
+      ]
+   }
+
+   solana_agent = SolanaAgent(config=config)
+
+   async for response in solana_agent.process("user123", "Send an email to bob@bob.com to clean his room!"):
+      print(response, end="")
+
 Inline Tool Example
 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~
 

poetry.lock

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "solana-agent"
-version = "27.3.3"
+version = "27.3.4"
 description = "Agentic IQ"
 authors = ["Bevan Hunt <bevan@bevanhunt.com>"]
 license = "MIT"
@@ -23,7 +23,7 @@ python_paths = [".", "tests"]
 
 [tool.poetry.dependencies]
 python = ">=3.12,<4.0"
-openai = "^1.74.0"
+openai = "^1.75.0"
 pydantic = ">=2"
 pymongo = "^4.12.0"
 zep-cloud = "^2.10.1"

pyproject.toml

@@ -127,20 +127,6 @@ async def retrieve(self, user_id: str) -> str:
                 memory = await self.zep.memory.get(session_id=user_id)
                 if memory and memory.context:
                     memories = memory.context
-            if self.mongo:
-                mongo_memory = self.mongo.find(
-                    self.collection,
-                    {"user_id": user_id},
-                    sort=[("timestamp", -1)],
-                    limit=3
-                )
-                if mongo_memory:
-                    # Concatenate MongoDB memory with Zep memory
-                    mongo_memory = [
-                        f"{msg['user_message']} {msg['assistant_message']}"
-                        for msg in mongo_memory
-                    ]
-                    memories += " ".join(mongo_memory)
             return memories
 
         except Exception as e:

solana_agent/repositories/memory.py

@@ -422,96 +422,3 @@ def test_find_mongo_error(self, mock_mongo_adapter):
         result = repo.find("conversations", {})
         assert result == []
         mock_mongo_adapter.find.assert_called_once()
-
-    @pytest.mark.asyncio
-    async def test_retrieve_with_zep_and_mongo(self, mock_zep, mock_mongo_adapter):
-        """Test retrieving memories from both Zep and MongoDB."""
-        # Setup MongoDB mock with sample data
-        mock_mongo_data = [
-            {"user_message": "User1", "assistant_message": "Assistant1"},
-            {"user_message": "User2", "assistant_message": "Assistant2"},
-            {"user_message": "User3", "assistant_message": "Assistant3"}
-        ]
-        mock_mongo_adapter.find.return_value = mock_mongo_data
-
-        # Setup Zep mock with sample data
-        mock_memory = MagicMock(spec=Memory)
-        mock_memory.context = "Zep memory context"
-        mock_zep.memory.get.return_value = mock_memory
-
-        # Create repository with both adapters
-        repo = MemoryRepository(
-            mongo_adapter=mock_mongo_adapter, zep_api_key="test_key")
-        repo.zep = mock_zep
-
-        # Call retrieve method
-        result = await repo.retrieve("test_user")
-
-        # Verify correct data retrieval and formatting
-        mock_zep.memory.get.assert_called_once_with(session_id="test_user")
-        mock_mongo_adapter.find.assert_called_once()
-
-        # Verify the memories were combined correctly
-        assert "Zep memory context" in result
-        assert "User1 Assistant1" in result
-        assert "User2 Assistant2" in result
-        assert "User3 Assistant3" in result
-
-    @pytest.mark.asyncio
-    async def test_retrieve_mongo_only(self, mock_mongo_adapter):
-        """Test retrieving memories from MongoDB only (no Zep)."""
-        # Setup MongoDB mock with sample data
-        mock_mongo_data = [
-            {"user_message": "MongoUser1", "assistant_message": "MongoAssistant1"},
-            {"user_message": "MongoUser2", "assistant_message": "MongoAssistant2"}
-        ]
-        mock_mongo_adapter.find.return_value = mock_mongo_data
-
-        # Create repository with MongoDB only
-        repo = MemoryRepository(mongo_adapter=mock_mongo_adapter)
-
-        # Call retrieve method
-        result = await repo.retrieve("test_user")
-
-        # Verify correct behavior
-        mock_mongo_adapter.find.assert_called_once_with(
-            "conversations",
-            {"user_id": "test_user"},
-            sort=[("timestamp", -1)],
-            limit=3
-        )
-        assert "MongoUser1 MongoAssistant1" in result
-        assert "MongoUser2 MongoAssistant2" in result
-
-    @pytest.mark.asyncio
-    async def test_retrieve_mongo_empty_results(self, mock_mongo_adapter):
-        """Test retrieving when MongoDB returns empty results."""
-        # Setup MongoDB mock with empty data
-        mock_mongo_adapter.find.return_value = []
-
-        # Create repository with MongoDB only
-        repo = MemoryRepository(mongo_adapter=mock_mongo_adapter)
-
-        # Call retrieve method
-        result = await repo.retrieve("test_user")
-
-        # Verify correct behavior
-        mock_mongo_adapter.find.assert_called_once()
-        assert result == ""  # Should be empty string
-
-    @pytest.mark.asyncio
-    async def test_retrieve_mongo_error(self, mock_mongo_adapter):
-        """Test handling MongoDB retrieval error."""
-        # Setup MongoDB mock to throw an error
-        mock_mongo_adapter.find.side_effect = Exception(
-            "MongoDB retrieval error")
-
-        # Create repository with MongoDB only
-        repo = MemoryRepository(mongo_adapter=mock_mongo_adapter)
-
-        # Call retrieve method - should handle the error gracefully
-        result = await repo.retrieve("test_user")
-
-        # Verify behavior
-        mock_mongo_adapter.find.assert_called_once()
-        assert result == ""  # Should return empty string on error