engine.io

import { Server } from 'engine.io'; import * as http from 'http'; // Create a basic HTTP server const httpServer = http.createServer((req, res) => { res.writeHead(200, { 'Content-Type': 'text/plain' }); res.end('Engine.IO is running!\n'); }); // Attach Engine.IO to the HTTP server const eioServer = new Server({ pingInterval: 1000, // Client pings server every 1 second pingTimeout: 500 // Server considers client disconnected if no ping for 0.5 seconds }); eioServer.attach(httpServer); // Handle connections eioServer.on('connection', (socket) => { console.log(`Client connected: ${socket.id}`); // Send a message to the client socket.send('Hello from Engine.IO server!'); // Listen for messages from the client socket.on('message', (data) => { console.log(`Received message from ${socket.id}: ${data}`); // Echo the message back to the client socket.send(`Server received: ${data}`); }); // Handle client disconnection socket.on('close', (reason, description) => { console.log(`Client ${socket.id} disconnected. Reason: ${reason}, Description: ${description}`); }); // Handle errors socket.on('error', (err) => { console.error(`Error on socket ${socket.id}:`, err); }); }); // Start the HTTP server const PORT = process.env.PORT || 3000; httpServer.listen(PORT, () => { console.log(`Engine.IO server listening on http://localhost:${PORT}`); console.log('Connect with an Engine.IO client, e.g., in browser: new eio.Socket(\'ws://localhost:3000\');'); });