add namespacing for tools, tested

tested with claude desktop and 4 different namespaced Cypher MCP servers

Author: a-s-g93

servers/mcp-neo4j-cypher/CHANGELOG.md

@@ -5,6 +5,8 @@
 ### Changed
 
 ### Added
+* Namespace option via CLI or env variables. This allows many Cypher MCP servers to be used at once.
+* Allow transport to be specified via env variables
 
 
 ## v0.2.2 

servers/mcp-neo4j-cypher/src/mcp_neo4j_cypher/__init__.py

@@ -12,7 +12,8 @@ def main():
     parser.add_argument("--username", default=None, help="Neo4j username")
     parser.add_argument("--password", default=None, help="Neo4j password")
     parser.add_argument("--database", default=None, help="Neo4j database name")
-    parser.add_argument("--transport", default="stdio", help="Transport type")
+    parser.add_argument("--transport", default=None, help="Transport type")
+    parser.add_argument("--namespace", default=None, help="Tool namespace")
 
     args = parser.parse_args()
     asyncio.run(
@@ -21,7 +22,8 @@ def main():
             args.username or os.getenv("NEO4J_USERNAME", "neo4j"),
             args.password or os.getenv("NEO4J_PASSWORD", "password"),
             args.database or os.getenv("NEO4J_DATABASE", "neo4j"),
-            args.transport,
+            args.transport or os.getenv("NEO4J_TRANSPORT", "stdio"),
+            args.namespace or os.getenv("NEO4J_NAMESPACE", ""),
         )
     )
 

servers/mcp-neo4j-cypher/src/mcp_neo4j_cypher/server.py

@@ -19,6 +19,14 @@
 
 logger = logging.getLogger("mcp_neo4j_cypher")
 
+def _format_namespace(namespace: str) -> str:
+    if namespace:
+        if namespace.endswith("-"):
+            return namespace
+        else:
+            return namespace + "-"
+    else:
+        return ""
 
 async def _read(tx: AsyncTransaction, query: str, params: dict[str, Any]) -> str:
     raw_results = await tx.run(query, params)
@@ -41,7 +49,7 @@ def _is_write_query(query: str) -> bool:
     )
 
 
-def create_mcp_server(neo4j_driver: AsyncDriver, database: str = "neo4j") -> FastMCP:
+def create_mcp_server(neo4j_driver: AsyncDriver, database: str = "neo4j", namespace: str = "") -> FastMCP:
     mcp: FastMCP = FastMCP("mcp-neo4j-cypher", dependencies=["neo4j", "pydantic"])
 
     async def get_neo4j_schema() -> list[types.TextContent]:
@@ -126,9 +134,11 @@ async def write_neo4j_cypher(
                 types.TextContent(type="text", text=f"Error: {e}\n{query}\n{params}")
             ]
 
-    mcp.add_tool(get_neo4j_schema)
-    mcp.add_tool(read_neo4j_cypher)
-    mcp.add_tool(write_neo4j_cypher)
+    namespace_prefix = _format_namespace(namespace)
+    
+    mcp.add_tool(get_neo4j_schema, name=namespace_prefix+"get_neo4j_schema")
+    mcp.add_tool(read_neo4j_cypher, name=namespace_prefix+"read_neo4j_cypher")
+    mcp.add_tool(write_neo4j_cypher, name=namespace_prefix+"write_neo4j_cypher")
 
     return mcp
 
@@ -139,6 +149,7 @@ async def main(
     password: str,
     database: str,
     transport: Literal["stdio", "sse"] = "stdio",
+    namespace: str = "",
 ) -> None:
     logger.info("Starting MCP neo4j Server")
 
@@ -150,7 +161,7 @@ async def main(
         ),
     )
 
-    mcp = create_mcp_server(neo4j_driver, database)
+    mcp = create_mcp_server(neo4j_driver, database, namespace)
 
     match transport:
         case "stdio":