diff --git a/scripts/verify_sse.cjs b/scripts/verify_sse.cjs new file mode 100644 index 0000000..1f85a71 --- /dev/null +++ b/scripts/verify_sse.cjs @@ -0,0 +1,41 @@ +const http = require('http'); + +async function verifySse() { + console.log("Connecting to MCP SSE at http://localhost:3000/sse..."); + + return new Promise((resolve, reject) => { + const timeout = setTimeout(() => { + console.error("Timeout waiting for SSE event"); + reject(new Error("Timeout")); + }, 5000); + + const req = http.get('http://127.0.0.1:3000/sse', (res) => { + if (res.statusCode !== 200) { + clearTimeout(timeout); + reject(new Error(`HTTP ${res.statusCode}`)); + return; + } + + res.on('data', (chunk) => { + const data = chunk.toString(); + console.log("Received data:", data); + if (data.includes('event: endpoint')) { + console.log("SUCCESS: Received endpoint event."); + clearTimeout(timeout); + req.destroy(); + resolve(); + } + }); + }); + + req.on('error', (e) => { + clearTimeout(timeout); + reject(e); + }); + }); +} + +verifySse().catch(err => { + console.error("Verification failed:", err.message); + process.exit(1); +});