Task Manager MCP Server

import { SSEServerTransport } from '@modelcontextprotocol/sdk/server/sse.js'; import express from 'express'; import { createServer } from './task_manager.js'; console.error('Starting SSE server...'); const app = express(); const transports = new Map(); app.get('/sse', async (req, res) => { let transport; const { server, cleanup } = createServer(); if (req?.query?.sessionId) { const sessionId = req?.query?.sessionId; transport = transports.get(sessionId); console.error("Client Reconnecting? This shouldn't happen; when client has a sessionId, GET /sse should not be called again.", transport.sessionId); } else { // Create and store transport for new session transport = new SSEServerTransport('/message', res); transports.set(transport.sessionId, transport); // Connect server to transport await server.connect(transport); console.error('Client Connected: ', transport.sessionId); // Handle close of connection server.onclose = async () => { console.error('Client Disconnected: ', transport.sessionId); transports.delete(transport.sessionId); await cleanup(); }; } }); app.post('/message', async (req, res) => { const sessionId = req?.query?.sessionId; const transport = transports.get(sessionId); if (transport) { console.error('Client Message from', sessionId); await transport.handlePostMessage(req, res); } else { console.error(`No transport found for sessionId ${sessionId}`); } }); const PORT = process.env.PORT || 3001; app.listen(PORT, () => { console.error(`Server is running on port ${PORT}`); });