Upload 7 files

__init__.py

@@ -0,0 +1,4 @@
+# E2E MCP Module
+"""
+End-to-End MCP server implementations for diverse use cases.
+"""

file_explorer.py

@@ -0,0 +1,73 @@
+# File explorer tools
+"""
+MCP tools for exploring files and directories.
+"""
+import os
+from mcp.server.fastmcp import FastMCP
+
+
+def register_file_explorer_tools(mcp: FastMCP):
+    """Register file explorer tools with the MCP server."""
+    
+    @mcp.tool()
+    def list_directory(path: str) -> list:
+        """
+        List contents of a directory.
+        
+        Args:
+            path: Directory path to list
+            
+        Returns:
+            List of files and directories
+        """
+        if not os.path.exists(path):
+            return {"error": f"Path {path} does not exist"}
+            
+        if not os.path.isdir(path):
+            return {"error": f"Path {path} is not a directory"}
+            
+        try:
+            contents = os.listdir(path)
+            result = []
+            
+            for item in contents:
+                item_path = os.path.join(path, item)
+                item_type = "directory" if os.path.isdir(item_path) else "file"
+                
+                result.append({
+                    "name": item,
+                    "type": item_type,
+                    "path": item_path
+                })
+                
+            return result
+        except Exception as e:
+            return {"error": str(e)}
+    
+    @mcp.tool()
+    def file_info(path: str) -> dict:
+        """
+        Get information about a file.
+        
+        Args:
+            path: Path to the file
+            
+        Returns:
+            Information about the file
+        """
+        if not os.path.exists(path):
+            return {"error": f"Path {path} does not exist"}
+            
+        try:
+            stat_info = os.stat(path)
+            
+            return {
+                "name": os.path.basename(path),
+                "path": os.path.abspath(path),
+                "size": stat_info.st_size,
+                "last_modified": stat_info.st_mtime,
+                "is_directory": os.path.isdir(path),
+                "is_file": os.path.isfile(path)
+            }
+        except Exception as e:
+            return {"error": str(e)}

gradio_app.py

@@ -0,0 +1,12 @@
+import gradio as gr
+
+from sentiment_tools import analyze_sentiment
+
+demo = gr.Interface(fn=analyze_sentiment, 
+                 inputs=gr.Textbox(placeholder="Enter text to analyze..."), 
+                 outputs=gr.JSON(),
+                 title="Sentiment Analysis",
+                 description="Enter text to analyze its sentiment.")
+if __name__ == "__main__":
+    # Launch the Gradio UI for sentiment analysis
+    demo.launch(mcp_server=True)

mcp.json

@@ -0,0 +1,47 @@
+{
+  "servers": [
+    {
+      "name": "E2E MCP Server",
+      "transport": {
+        "type": "stdio",
+        "command": "python",
+        "args": [
+          "./server.py"
+        ]
+      }
+    },
+    {
+      "name": "Sentiment Analysis Server",
+      "transport": {
+        "type": "stdio",
+        "command": "python",
+        "args": [
+          "-c",
+          "from e2e_mcp.sentiment_tools import register_sentiment_tool; from mcp.server.fastmcp import FastMCP; mcp = FastMCP('SentimentTools'); register_sentiment_tool(mcp); mcp.run()"
+        ]
+      }
+    },
+    {
+      "name": "File Explorer Server",
+      "transport": {
+        "type": "stdio",
+        "command": "python",
+        "args": [
+          "-c",
+          "from e2e_mcp.file_explorer import register_file_explorer_tools; from mcp.server.fastmcp import FastMCP; mcp = FastMCP('FileExplorerTools'); register_file_explorer_tools(mcp); mcp.run()"
+        ]
+      }
+    },
+    
+      {
+        "gradio": {
+          "command": "npx",
+          "args": [
+            "mcp-remote",
+            "http://localhost:7860/gradio_api/mcp/sse"
+          ]
+        }
+      }
+    
+  ]
+}

requirements.txt

@@ -0,0 +1,3 @@
+textblob>=0.15.3
+gradio>=3.50.0
+gradio[mcp]

sentiment_tools.py

@@ -0,0 +1,33 @@
+from textblob import TextBlob
+
+def analyze_sentiment(text):
+    """Analyze the sentiment of a given text.
+    Args:
+        text (str): The text to analyze
+    Returns:
+        dict: A dictionary containing polarity, subjectivity, and assessment
+    """
+    blob = TextBlob(text)
+
+    return {
+        "polarity": round(blob.polarity, 2), 
+        "subjectivity": round(blob.subjectivity, 2),
+        "assessment": "positive" if blob.polarity > 0 else "negative" if blob.polarity < 0 else "neutral"
+    }
+
+
+def register_sentiment_tool(mcp):
+    """Register the sentiment analysis tool with the MCP server."""
+    
+    @mcp.tool()
+    def sentiment_analysis(text: str) -> dict:
+        """
+        Analyze the sentiment of a given text.
+        
+        Args:
+            text: The text to analyze
+            
+        Returns:
+            A dictionary with polarity, subjectivity, and assessment
+        """
+        return analyze_sentiment(text)

server.py

@@ -0,0 +1,24 @@
+# Main E2E MCP Server
+"""
+Main MCP server integrating all E2E tools.
+"""
+from mcp.server.fastmcp import FastMCP
+from sentiment_tools import register_sentiment_tool
+from file_explorer import register_file_explorer_tools
+
+
+def create_server(name="E2EMCP"):
+    """Create and configure the E2E MCP server instance."""
+    mcp = FastMCP(name)
+    
+    # Register all tools
+    register_sentiment_tool(mcp)
+    register_file_explorer_tools(mcp)
+    
+    return mcp
+
+
+# if __name__ == "__main__":
+#     # Create and start the server
+mcp = create_server()
+mcp.run()