OCI Cache integration (#600)

* Integrate OCI cache with Data science hosted MCP server

* Readme updates

Author: gargnipungarg

model-deployment/mcp-servers/oci-cache-redis-server/.dockerignore

@@ -0,0 +1,5 @@
+*
+!.env
+!src
+!uv.lock
+!pyproject.toml

model-deployment/mcp-servers/oci-cache-redis-server/.env

@@ -0,0 +1,13 @@
+REDIS_HOST=<OCI-CACHE-ENDPOINT> # Ex. <REDIS_OCID>-p.redis.<REGION>.oci.oraclecloud.com
+REDIS_PORT=6379
+REDIS_DB=0
+#REDIS_USERNAME=default
+#REDIS_PWD=your_password
+REDIS_SSL=1
+#REDIS_CA_PATH=/path/to/ca.pem
+#REDIS_SSL_KEYFILE=/path/to/key.pem
+#REDIS_SSL_CERTFILE=/path/to/cert.pem
+#REDIS_CERT_REQS=required
+#REDIS_CA_CERTS=/path/to/ca_certs.pem
+REDIS_CLUSTER_MODE=False
+MCP_TRANSPORT=streamable-http

model-deployment/mcp-servers/oci-cache-redis-server/Dockerfile

@@ -0,0 +1,8 @@
+FROM python:3.13-slim
+RUN pip install --upgrade uv
+
+WORKDIR /app
+COPY . /app
+RUN uv sync
+
+CMD ["uv", "--offline", "run", "python", "src/main.py"]

model-deployment/mcp-servers/oci-cache-redis-server/LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2025 Mirko Ortensi
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

model-deployment/mcp-servers/redis-server/Readme.md renamed to model-deployment/mcp-servers/oci-cache-redis-server/Readme.md

@@ -1,10 +1,20 @@
-This example is a fork from [REDIS MCP](https://github.com/redis/mcp-redis) server and showcase how we can host a redis mcp server on OCI Data Science Model deployment.
+# Introduction
 
+This example is a fork from [REDIS MCP](https://github.com/redis/mcp-redis) server and showcase how we can host a redis mcp server on OCI Data Science Model deployment.
 Following additions are done to accommodate it on OCI - 
 
 - Dockerize the application to host this as Bring Your Own Container(BYOC)
 - Add a custom route for health endpoint
 - Use streamable-http as the default mcp transport protocol
 
+# OCI Cache integration
+Create an OCI Cache cluster using [documentation](https://docs.oracle.com/en-us/iaas/Content/ocicache/createcluster.htm) and fetch the Redis cluster endpoint.
+We will use this endpoint to configure MCP redis server using TLS enabled config.
+
+Configure this endpoint as `REDIS_HOST` configuration in .env file or pass environment variables for dynamic binding.
+
+# Example
+Sample script on how to create a model deployment is present [here](./model-deplyment.py) and perform inferencing is shared in [here](./inference.py).
 
-Sample script on how to create a model deployment is present [here](./model-deplyment.py) and perform inferencing is shared in [here](./inference.py).
+# Help
+You can raise issues in this repository for any assistance.

model-deployment/mcp-servers/oci-cache-redis-server/examples/redis_assistant.py

@@ -0,0 +1,78 @@
+import asyncio
+from agents import Agent, Runner
+from openai.types.responses import ResponseTextDeltaEvent
+from agents.mcp import MCPServerStdio
+from collections import deque
+
+
+# Set up and create the agent
+async def build_agent():
+    # Redis MCP Server. Pass the environment configuration for the MCP Server in the JSON
+    server = MCPServerStdio(
+        params={
+            "command": "uv",
+            "args": [
+                "--directory", "../src/", # change with the path to the MCP server
+                "run", "main.py"
+            ],
+        "env": {
+            "REDIS_HOST": "127.0.0.1",
+            "REDIS_PORT": "6379",
+            "REDIS_USERNAME": "default",
+            "REDIS_PWD": ""
+        },
+        }
+    )
+
+    await server.connect()
+
+    # Create and return the agent
+    agent = Agent(
+        name="Redis Assistant",
+        instructions="You are a helpful assistant capable of reading and writing to Redis. Store every question and answer in the Redis Stream app:logger",
+        mcp_servers=[server]
+    )
+
+    return agent
+
+
+# CLI interaction
+async def cli(agent, max_history=30):
+    print("🔧 Redis Assistant CLI — Ask me something (type 'exit' to quit):\n")
+    conversation_history = deque(maxlen=max_history)
+
+    while True:
+        q = input("❓> ")
+        if q.strip().lower() in {"exit", "quit"}:
+            break
+
+        if (len(q.strip()) > 0):
+            # Format the context into a single string
+            history = ""
+            for turn in conversation_history:
+                prefix = "User" if turn["role"] == "user" else "Assistant"
+                history += f"{prefix}: {turn['content']}\n"
+
+            context = f"Conversation history:/n{history.strip()} /n New question:/n{q.strip()}"
+            result = Runner.run_streamed(agent, context)
+
+            response_text = ""
+            async for event in result.stream_events():
+                if event.type == "raw_response_event" and isinstance(event.data, ResponseTextDeltaEvent):
+                    print(event.data.delta, end="", flush=True)
+                    response_text += event.data.delta
+            print("\n")
+
+            # Add the user's message and the assistant's reply in history
+            conversation_history.append({"role": "user", "content": q})
+            conversation_history.append({"role": "assistant", "content": response_text})
+
+
+# Main entry point
+async def main():
+    agent = await build_agent()
+    await cli(agent)
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

model-deployment/mcp-servers/redis-server/inference.py renamed to model-deployment/mcp-servers/oci-cache-redis-server/inference.py

@@ -1,12 +1,12 @@
 [project]
 name = "redis-mcp-server"
-version = "0.1.0"
+version = "0.2.0-alpha"
 description = "Redis MCP Server, by Redis"
 readme = "README.md"
 requires-python = ">=3.13"
 dependencies = [
-    "mcp[cli]>=1.5.0",
-    "redis>=5.2.1",
+    "mcp[cli]>=1.9.4",
+    "redis>=6.0.0",
     "dotenv>=0.9.9",
     "numpy>=2.2.4",
 ]

model-deployment/mcp-servers/redis-server/model-deplyment.py renamed to model-deployment/mcp-servers/oci-cache-redis-server/model-deplyment.py

@@ -0,0 +1,79 @@
+# Smithery configuration file: https://smithery.ai/docs/config#smitheryyaml
+
+startCommand:
+  type: stdio
+  configSchema:
+    # JSON Schema defining the configuration options for the MCP.
+    type: object
+    required: []
+    properties:
+      redisHost:
+        type: string
+        default: 127.0.0.1
+        description: Redis IP or hostname
+      redisPort:
+        type: number
+        default: 6379
+        description: Redis port
+      redisUsername:
+        type: string
+        default: default
+        description: Redis username
+      redisPwd:
+        type: string
+        default: ""
+        description: Redis password
+      redisSSL:
+        type: boolean
+        default: false
+        description: Enable SSL for Redis connection
+      redisCAPath:
+        type: string
+        default: ""
+        description: CA certificate path for verifying server
+      redisSSLKeyfile:
+        type: string
+        default: ""
+        description: Client private key file for authentication
+      redisSSLCertfile:
+        type: string
+        default: ""
+        description: Client certificate file for authentication
+      redisCertReqs:
+        type: string
+        default: required
+        description: Certificate requirements
+      redisCACerts:
+        type: string
+        default: ""
+        description: Path to trusted CA certificates file
+  commandFunction:
+    # A JS function that produces the CLI command based on the given config to start the MCP on stdio.
+    |-
+    (config) => ({
+      command: 'uv',
+      args: ['run', 'python', 'src/main.py'],
+      env: {
+        REDIS_HOST: config.redisHost,
+        REDIS_PORT: String(config.redisPort),
+        REDIS_USERNAME: config.redisUsername,
+        REDIS_PWD: config.redisPwd,
+        REDIS_SSL: String(config.redisSSL),
+        REDIS_CA_PATH: config.redisCAPath,
+        REDIS_SSL_KEYFILE: config.redisSSLKeyfile,
+        REDIS_SSL_CERTFILE: config.redisSSLCertfile,
+        REDIS_CERT_REQS: config.redisCertReqs,
+        REDIS_CA_CERTS: config.redisCACerts
+      }
+    })
+  exampleConfig:
+    redisHost: 127.0.0.1
+    redisPort: 6379
+    redisUsername: default
+    redisPwd: ""
+    redisSSL: false
+    redisCAPath: ""
+    redisSSLKeyfile: ""
+    redisSSLCertfile: ""
+    redisCertReqs: required
+    redisCACerts: ""