Add MCP AI assistant code

Author: ChawlaAvi

.gitmodules

@@ -0,0 +1 @@
+3.12

ultimate-ai-assitant-using-mcp/.python-version

@@ -0,0 +1,82 @@
+# MCP-powered Ultimate AI Assistant
+
+A Streamlit application that provides a chat interface for interacting with MCP (Model Context Protocol) servers. This app allows you to configure multiple MCP servers and chat with them using natural language.
+
+Tech stack:
+- [mcp-use](https://github.com/mcp-use/mcp-use) to connect LLM to MCP servers
+- [Stagehand MCP](https://github.com/browserbase/mcp-server-browserbase) for browser access
+- [Firecrawl MCP](https://github.com/mendableai/firecrawl-mcp-server) for scraping
+- [Ragie MCP](https://github.com/ragieai/ragie-mcp-server) for multimodal RAG
+- [Graphiti MCP](https://github.com/getzep/graphiti/tree/main/mcp_server) as memory
+- [Terminal](https://github.com/wonderwhy-er/DesktopCommanderMCP) & [GitIngest](https://github.com/adhikasp/mcp-git-ingest) MCP
+
+## Setup
+
+1. **Install Dependencies**: 
+   ```bash
+   uv sync 
+   ```
+
+2. **Environment Variables**:
+   Create a `.env` file with your API keys:
+   ```env
+   OPENAI_API_KEY=your-openai-api-key
+   FIRECRAWL_API_KEY=your-firecrawl-api-key
+   RAGIE_API_KEY=your-ragie-api-key
+   ```
+
+3. **Setup MCP Servers**
+
+    Go to server.py and update the paths to the MCP servers according to your system.
+
+3. **Run the App**:
+   ```bash
+   streamlit run mcp_streamlit_app.py
+   ```
+
+## Usage
+
+1. **Configure MCP Servers**:
+   - Use the sidebar to enter your MCP server configuration in JSON format
+   - Click "Load Example Config" to see a sample configuration
+   - Click "Activate Configuration" to initialize the MCP client
+
+2. **Chat with MCP Tools**:
+   - Once configured, use the chat interface to interact with your MCP servers
+   - Ask questions about available tools or request specific actions
+   - The agent will use the appropriate MCP tools to respond
+
+## Example Configuration
+
+```json
+{
+  "mcpServers": {
+    "stagehand": {
+      "command": "node",
+      "args": ["/path/to/stagehand/dist/index.js"],
+      "env": {
+        "OPENAI_API_KEY": "your-api-key",
+        "LOCAL_CDP_URL": "http://localhost:9222"
+      }
+    },
+    "firecrawl": {
+      "command": "npx",
+      "args": ["-y", "firecrawl-mcp"],
+      "env": {
+        "FIRECRAWL_API_KEY": "your-firecrawl-key"
+      }
+    }
+  }
+}
+```
+
+## 📬 Stay Updated with Our Newsletter!
+**Get a FREE Data Science eBook** 📖 with 150+ essential lessons in Data Science when you subscribe to our newsletter! Stay in the loop with the latest tutorials, insights, and exclusive resources. [Subscribe now!](https://join.dailydoseofds.com)
+
+[![Daily Dose of Data Science Newsletter](https://github.com/patchy631/ai-engineering/blob/main/resources/join_ddods.png)](https://join.dailydoseofds.com)
+
+---
+
+## Contribution
+
+Contributions are welcome! Please fork the repository and submit a pull request with your improvements. 

ultimate-ai-assitant-using-mcp/README.md

@@ -0,0 +1,231 @@
+import streamlit as st
+import asyncio
+import os
+import json
+from dotenv import load_dotenv
+# from langchain_ollama import ChatOllama
+from langchain_openai import ChatOpenAI
+from mcp_use import MCPAgent, MCPClient
+import mcp_use
+import warnings
+import base64
+
+# Suppress warnings
+warnings.filterwarnings("ignore")
+mcp_use.set_debug(0)
+
+# Load environment variables
+load_dotenv()
+
+# Page configuration
+st.set_page_config(
+    page_title="MCP-powered Perplexity Clone",
+    page_icon="🤖",
+    layout="wide",
+    initial_sidebar_state="expanded"
+)
+
+# Initialize session state
+if "messages" not in st.session_state:
+    st.session_state.messages = []
+
+if "mcp_client" not in st.session_state:
+    st.session_state.mcp_client = None
+
+if "agent" not in st.session_state:
+    st.session_state.agent = None
+
+def reset_chat():
+    st.session_state.messages = []
+    st.session_state.mcp_client = None
+    st.session_state.agent = None
+
+def create_mcp_client(config_dict):
+    """Create MCPClient from configuration dictionary."""
+    try:
+        client = MCPClient.from_dict(config_dict)
+        return client
+    except Exception as e:
+        st.error(f"Error creating MCP client: {str(e)}")
+        return None
+
+def create_agent(client):
+    """Create MCPAgent with the client."""
+    try:
+        # Create LLM - you can switch between Ollama and OpenAI
+        llm = ChatOpenAI(model="gpt-4o")
+        # llm = ChatOllama(model="qwen3:1.7b")
+        
+        agent = MCPAgent(llm=llm, client=client, max_steps=100)
+        return agent
+    except Exception as e:
+        st.error(f"Error creating agent: {str(e)}")
+        return None
+
+async def run_agent_query(agent, query):
+    """Run a query through the MCP agent."""
+    try:
+        result = await agent.run(query)
+        return result
+    except Exception as e:
+        return f"Error running query: {str(e)}"
+
+# Main title
+st.markdown("""
+    # 100% local Ultimate AI Assistant using mcp-use
+""", unsafe_allow_html=True)
+
+st.markdown("Configure your MCP servers and chat with them using natural language!")
+
+# Sidebar for configuration
+with st.sidebar:
+    st.header("MCP Configuration")
+    
+    # Configuration text area
+    config_text = st.text_area(
+        "Enter MCP Configuration (JSON)",
+        height=400,
+        placeholder='''{
+  "mcpServers": {
+    "stagehand": {
+      "command": "node",
+      "args": ["/path/to/mcp-server-browserbase/stagehand/dist/index.js"],
+      "env": {
+        "OPENAI_API_KEY": "your-api-key",
+        "LOCAL_CDP_URL": "http://localhost:9222"
+      }
+    }
+  }
+}''',
+        help="Enter your MCP server configuration in JSON format"
+    )
+    
+    # Load example configuration
+    if st.button("Load Example Config"):
+        example_config = {
+            "mcpServers": {
+                "stagehand": {
+                    "command": "node",
+                    "args": ["/path/to/mcp-server-browserbase/stagehand/dist/index.js"],
+                    "env": {
+                        "OPENAI_API_KEY": os.getenv("OPENAI_API_KEY"),
+                        "LOCAL_CDP_URL": "http://localhost:9222",
+                        "DOWNLOADS_DIR": "/path/to/downloads/stagehand"
+                    }
+                },
+                "mcp-server-firecrawl": {
+                    "command": "npx",
+                    "args": ["-y", "firecrawl-mcp"],
+                    "env": {
+                        "FIRECRAWL_API_KEY": os.getenv("FIRECRAWL_API_KEY")
+                    }
+                },
+                "ragie": {
+                    "command": "npx",
+                    "args": ["-y", "@ragieai/mcp-server", "--partition", "default"],
+                    "env": {
+                        "RAGIE_API_KEY": os.getenv("RAGIE_API_KEY")
+                    }
+                }
+            }
+        }
+        st.session_state.example_config = json.dumps(example_config, indent=2)
+        st.rerun()
+    
+    # Display example config if loaded
+    if 'example_config' in st.session_state:
+        st.text_area("Example Configuration", st.session_state.example_config, height=200, disabled=True)
+    
+    st.divider()
+    
+    # Activate configuration button
+    if st.button("Activate Configuration", type="primary"):
+        if config_text.strip():
+            try:
+                # Parse JSON configuration
+                config_dict = json.loads(config_text)
+                
+                # Create MCP client
+                client = create_mcp_client(config_dict)
+                if client:
+                    st.session_state.mcp_client = client
+                    
+                    # Create agent
+                    agent = create_agent(client)
+                    if agent:
+                        st.session_state.agent = agent
+                        st.success("✅ Configuration activated successfully!")
+                        
+                        # Show available tools
+                        try:
+                            tools_info = "Available MCP tools:\n"
+                            for server_name, server_info in config_dict.get("mcpServers", {}).items():
+                                tools_info += f"- {server_name}\n"
+                            st.info(tools_info)
+                        except Exception as e:
+                            st.warning(f"Could not display tools info: {str(e)}")
+                    else:
+                        st.error("Failed to create agent")
+                else:
+                    st.error("Failed to create MCP client")
+            except json.JSONDecodeError as e:
+                st.error(f"Invalid JSON configuration: {str(e)}")
+            except Exception as e:
+                st.error(f"Error activating configuration: {str(e)}")
+        else:
+            st.warning("Please enter a configuration first")
+    
+    # Clear button
+    if st.button("Clear Chat & Config"):
+        reset_chat()
+        st.rerun()
+    
+    # Status indicator
+    st.divider()
+    st.subheader("Status")
+    if st.session_state.mcp_client and st.session_state.agent:
+        st.success("✅ MCP Client Active")
+        st.success("✅ Agent Ready")
+    else:
+        st.warning("⚠️ Configuration not activated")
+
+# Main chat interface
+
+
+# Display chat messages
+for message in st.session_state.messages:
+    with st.chat_message(message["role"]):
+        st.markdown(message["content"])
+
+# Chat input
+if prompt := st.chat_input("Ask about your MCP tools..."):
+    # Add user message to chat
+    st.session_state.messages.append({"role": "user", "content": prompt})
+    with st.chat_message("user"):
+        st.markdown(prompt)
+    
+    # Check if agent is available
+    if not st.session_state.agent:
+        with st.chat_message("assistant"):
+            st.error("Please activate the MCP configuration first!")
+    else:
+        with st.chat_message("assistant"):
+            with st.spinner("Processing your request..."):
+                try:
+                    # Run the query asynchronously
+                    loop = asyncio.new_event_loop()
+                    asyncio.set_event_loop(loop)
+                    result = loop.run_until_complete(run_agent_query(st.session_state.agent, prompt))
+                    loop.close()
+                    
+                    # Display result
+                    st.markdown(result)
+                    st.session_state.messages.append({"role": "assistant", "content": result})
+                except Exception as e:
+                    error_msg = f"Error processing request: {str(e)}"
+                    st.error(error_msg)
+                    st.session_state.messages.append({"role": "assistant", "content": error_msg})
+
+# Footer
+st.markdown("---")
+st.markdown("Built using mcp-use and Streamlit") 

ultimate-ai-assitant-using-mcp/mcp_streamlit_app.py

@@ -0,0 +1,14 @@
+[project]
+name = "mcp-use-visual"
+version = "0.1.0"
+description = "Add your description here"
+readme = "README.md"
+requires-python = ">=3.12"
+dependencies = [
+    "assemblyai>=0.42.0",
+    "ipykernel>=6.30.0",
+    "langchain-ollama>=0.3.5",
+    "langchain-openai>=0.3.28",
+    "mcp-use>=1.3.7",
+    "streamlit>=1.47.1",
+]

ultimate-ai-assitant-using-mcp/pyproject.toml

@@ -0,0 +1,6 @@
+streamlit>=1.28.0
+python-dotenv>=1.0.0
+langchain-openai>=0.1.0
+langchain-ollama>=0.1.0
+mcp-use>=0.1.0
+asyncio