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);
});