test-sse.js•2.03 kB
// Test script voor SSE functionaliteit
const http = require('http');
console.log('🧪 Testing MCP Server SSE functionality...\n');
// Test 1: Health check
console.log('1️⃣ Testing health endpoint...');
http.get('http://localhost:3000/health', (res) => {
let data = '';
res.on('data', chunk => data += chunk);
res.on('end', () => {
console.log('✅ Health check response:', JSON.parse(data));
console.log('');
// Test 2: SSE connection
console.log('2️⃣ Testing SSE endpoint...');
testSSE();
});
}).on('error', (err) => {
console.error('❌ Health check failed:', err.message);
});
function testSSE() {
const req = http.request({
hostname: 'localhost',
port: 3000,
path: '/sse',
method: 'GET',
headers: {
'Accept': 'text/event-stream',
'Cache-Control': 'no-cache'
}
}, (res) => {
console.log('✅ SSE connection established');
console.log('📡 Listening for events...\n');
let eventCount = 0;
res.on('data', (chunk) => {
const data = chunk.toString();
if (data.startsWith('data:')) {
eventCount++;
try {
const jsonData = JSON.parse(data.substring(5).trim());
console.log(`📨 Event ${eventCount}:`, jsonData);
} catch (e) {
console.log(`📨 Raw event ${eventCount}:`, data.trim());
}
// Stop na 3 events
if (eventCount >= 3) {
console.log('\n✅ SSE test completed successfully!');
req.destroy();
process.exit(0);
}
} else if (data.startsWith(':')) {
console.log('💓 Keep-alive ping received');
}
});
res.on('error', (err) => {
console.error('❌ SSE error:', err);
});
});
req.on('error', (err) => {
console.error('❌ SSE connection failed:', err.message);
});
req.end();
// Timeout na 20 seconden
setTimeout(() => {
console.log('\n⏰ Test timeout - stopping');
process.exit(0);
}, 20000);
}