configurable transport

Author: mortensi

src/common/config.py

@@ -4,6 +4,8 @@
 
 load_dotenv()
 
+MCP_TRANSPORT = os.getenv('MCP_TRANSPORT', 'stdio')
+
 REDIS_CFG = {"host": os.getenv('REDIS_HOST', '127.0.0.1'),
              "port": int(os.getenv('REDIS_PORT',6379)),
              "username": os.getenv('REDIS_USERNAME', None),

src/common/connection.py

@@ -15,7 +15,6 @@ class RedisConnectionManager:
     def get_connection(cls, decode_responses=True) -> Redis:
         if cls._instance is None:
             try:
-                print("Initializing Redis connection", file=sys.stderr)
                 cls._instance = redis.Redis(
                     host=REDIS_CFG["host"],
                     port=REDIS_CFG["port"],

src/main.py

@@ -1,3 +1,5 @@
+import sys
+
 from common.connection import RedisConnectionManager
 from common.server import mcp
 import tools.server_management
@@ -11,14 +13,15 @@
 import tools.set
 import tools.stream
 import tools.pub_sub
+from common.config import MCP_TRANSPORT
 
 
 class RedisMCPServer:
     def __init__(self):
-        redis_client = RedisConnectionManager.get_connection(decode_responses=False)
+        print("Starting the RedisMCPServer", file=sys.stderr)
 
     def run(self):
-        mcp.run(transport='stdio')
+        mcp.run(transport=MCP_TRANSPORT)
 
 if __name__ == "__main__":
     server = RedisMCPServer()