#!/usr/bin/env node
const { spawn } = require('child_process');
const path = require('path');
const fs = require('fs');
const children = new Set();
const args = process.argv.slice(2);
function parseSsePort(cliArgs) {
let port;
for (let i = 0; i < cliArgs.length; i += 1) {
const current = cliArgs[i];
if (current.startsWith('--sse-port=')) {
const value = current.split('=')[1];
if (value) {
port = parseInt(value, 10);
}
} else if (current === '--sse-port' && i + 1 < cliArgs.length) {
port = parseInt(cliArgs[i + 1], 10);
}
}
if (Number.isInteger(port) && port > 0 && port <= 65535) {
return port;
}
return 3001;
}
function ensureDistExists(entryPath) {
if (!fs.existsSync(entryPath)) {
process.stderr.write('[dev-sse] dist/server/v1/index.js not found. Please run "npm run build" first.\n');
process.exit(1);
}
}
function registerChild(child) {
if (!child) {
return;
}
children.add(child);
child.on('exit', () => {
children.delete(child);
});
}
function spawnServer(entryPath, cliArgs) {
const serverArgs = [entryPath, '--transport', 'sse', ...cliArgs];
const serverEnv = { ...process.env };
if (!serverEnv.DEBUG) {
serverEnv.DEBUG = 'true';
}
const child = spawn(process.execPath, serverArgs, {
stdio: 'inherit',
env: serverEnv,
cwd: process.cwd(),
shell: false, // Explicitly set shell to false
});
registerChild(child);
// Handle spawn errors (especially important on Windows)
child.on('error', (error) => {
process.stderr.write(`[dev-sse] ✗ Failed to spawn server: ${error.message}\n`);
if (error.code === 'EINVAL') {
process.stderr.write(`[dev-sse] EINVAL error - check paths and arguments\n`);
process.stderr.write(`[dev-sse] Entry path: ${entryPath}\n`);
process.stderr.write(`[dev-sse] Node exec path: ${process.execPath}\n`);
}
process.exit(1);
});
child.on('exit', (code, signal) => {
const reason = code !== null ? `code ${code}` : `signal ${signal}`;
process.stderr.write(`[dev-sse] SSE server exited (${reason}).\n`);
process.exit(code ?? 0);
});
return child;
}
function spawnInspector(port) {
const inspectorCmd = process.platform === 'win32' ? 'npx.cmd' : 'npx';
const args = [
'@modelcontextprotocol/inspector',
'--transport',
'sse',
'--server-url',
`http://localhost:${port}/sse`,
];
// On Windows, .cmd files require shell: true for proper execution
const spawnOptions = {
stdio: 'inherit',
env: process.env,
cwd: process.cwd(),
...(process.platform === 'win32' ? { shell: true } : {}),
};
const child = spawn(inspectorCmd, args, spawnOptions);
registerChild(child);
// Handle spawn errors (especially important on Windows)
child.on('error', (error) => {
process.stderr.write(`[dev-sse] ✗ Failed to spawn inspector: ${error.message}\n`);
if (error.code === 'EINVAL') {
process.stderr.write(`[dev-sse] EINVAL error - check npx installation and PATH\n`);
process.stderr.write(`[dev-sse] Inspector command: ${inspectorCmd}\n`);
}
});
child.on('exit', (code, signal) => {
if (code !== null && code !== 0) {
const reason = code !== null ? `code ${code}` : `signal ${signal}`;
process.stderr.write(`[dev-sse] MCP Inspector exited (${reason}).\n`);
}
});
return child;
}
(function main() {
const entryPath = path.resolve(__dirname, '../dist/server/v1/index.js');
ensureDistExists(entryPath);
const port = parseSsePort(args);
const server = spawnServer(entryPath, args);
const inspectorDelay = parseInt(process.env.MCP_DEV_SSE_INSPECTOR_DELAY || '1200', 10);
let inspector;
setTimeout(() => {
if (server.killed) {
return;
}
inspector = spawnInspector(port);
}, Number.isNaN(inspectorDelay) ? 1200 : inspectorDelay);
const signals = ['SIGINT', 'SIGTERM'];
for (const signal of signals) {
process.on(signal, () => {
for (const child of children) {
if (!child.killed) {
child.kill(signal);
}
}
process.exit(0);
});
}
})();
