diff --git a/src/redis/package.json b/src/redis/package.json index 33155265..e2fa50b1 100644 --- a/src/redis/package.json +++ b/src/redis/package.json @@ -1,6 +1,6 @@ { "name": "@modelcontextprotocol/server-redis", - "version": "0.1.0", + "version": "0.1.1", "description": "MCP server for using Redis", "license": "MIT", "author": "Anthropic, PBC (https://anthropic.com)", @@ -8,13 +8,13 @@ "bugs": "https://github.com/modelcontextprotocol/servers/issues", "type": "module", "bin": { - "redis": "./build/index.js" + "mcp-server-redis": "dist/index.js" }, "files": [ - "build" + "dist" ], "scripts": { - "build": "tsc && shx chmod +x build/*.js", + "build": "tsc && shx chmod +x dist/*.js", "prepare": "npm run build", "watch": "tsc --watch" }, diff --git a/src/redis/src/index.ts b/src/redis/src/index.ts index 27ce91fa..c16d8d85 100644 --- a/src/redis/src/index.ts +++ b/src/redis/src/index.ts @@ -1,3 +1,5 @@ +#!/usr/bin/env node + import { Server } from "@modelcontextprotocol/sdk/server/index.js"; import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js"; import { @@ -233,26 +235,25 @@ server.setRequestHandler(CallToolRequestSchema, async (request) => { } }); -// Start the server -async function main() { +// Set up Redis event handlers +redisClient.on('error', (err: Error) => { + console.error('Redis Client Error:', err); +}); + +redisClient.on('connect', () => { + console.error(`Connected to Redis at ${REDIS_URL}`); +}); + +redisClient.on('reconnecting', () => { + console.error('Attempting to reconnect to Redis...'); +}); + +redisClient.on('end', () => { + console.error('Redis connection closed'); +}); + +async function runServer() { try { - // Set up Redis event handlers - redisClient.on('error', (err: Error) => { - console.error('Redis Client Error:', err); - }); - - redisClient.on('connect', () => { - console.error(`Connected to Redis at ${REDIS_URL}`); - }); - - redisClient.on('reconnecting', () => { - console.error('Attempting to reconnect to Redis...'); - }); - - redisClient.on('end', () => { - console.error('Redis connection closed'); - }); - // Connect to Redis await redisClient.connect(); @@ -261,26 +262,21 @@ async function main() { await server.connect(transport); console.error("Redis MCP Server running on stdio"); } catch (error) { - console.error("Error during startup:", error); - await cleanup(); + console.error("Fatal error running server:", error); + await redisClient.quit().catch(() => {}); + process.exit(1); } } -// Cleanup function -async function cleanup() { - try { - await redisClient.quit(); - } catch (error) { - console.error("Error during cleanup:", error); - } - process.exit(1); -} - // Handle process termination -process.on('SIGINT', cleanup); -process.on('SIGTERM', cleanup); - -main().catch((error) => { - console.error("Fatal error in main():", error); - cleanup(); +process.on('SIGINT', async () => { + await redisClient.quit().catch(() => {}); + process.exit(0); }); + +process.on('SIGTERM', async () => { + await redisClient.quit().catch(() => {}); + process.exit(0); +}); + +runServer(); diff --git a/src/redis/tsconfig.json b/src/redis/tsconfig.json index efcd96e7..e4d02eb5 100644 --- a/src/redis/tsconfig.json +++ b/src/redis/tsconfig.json @@ -3,7 +3,7 @@ "target": "ES2022", "module": "Node16", "moduleResolution": "Node16", - "outDir": "./build", + "outDir": "./dist", "rootDir": "./src", "strict": true, "esModuleInterop": true, @@ -13,4 +13,3 @@ "include": ["src/**/*"], "exclude": ["node_modules"] } - \ No newline at end of file