universal-websocket-client

const WebSocket = require('universal-websocket-client'); // Minimal Node.js echo server for demonstration purposes let wss; let server; if (typeof window === 'undefined') { // Only set up server in Node.js environment const http = require('http'); const { WebSocketServer } = require('ws'); server = http.createServer((req, res) => { res.writeHead(200, { 'Content-Type': 'text/plain' }); res.end('WebSocket server running for demo\n'); }); wss = new WebSocketServer({ server }); wss.on('connection', ws => { console.log('[Server] Client connected'); ws.on('message', message => { console.log(`[Server] Received: ${message}`); ws.send(`Echo: ${message}`); }); ws.on('close', () => console.log('[Server] Client disconnected')); }); server.listen(8080, () => { console.log('[Server] Echo WebSocket server listening on port 8080'); startClient('ws://localhost:8080'); }); } else { // For browser, connect to a public echo server or your own backend startClient('wss://echo.websocket.events'); } function startClient(url) { console.log(`[Client] Attempting to connect to WebSocket at ${url}`); const ws = new WebSocket(url); ws.onopen = () => { console.log('[Client] WebSocket connection opened!'); ws.send('Hello from universal-websocket-client!'); }; ws.onmessage = (event) => { console.log(`[Client] Received: ${event.data}`); }; ws.onerror = (error) => { console.error('[Client] WebSocket error:', error); }; ws.onclose = (event) => { if (event.wasClean) { console.log(`[Client] WebSocket connection closed cleanly, code=${event.code}, reason=${event.reason}`); } else { console.warn('[Client] WebSocket connection abruptly disconnected!'); } // Gracefully shut down the demo server if in Node.js if (wss && server) { wss.close(() => { server.close(() => { console.log('[Server] Server gracefully shut down.'); }); }); } }; // Send a message after 2 seconds, then close after 4 seconds setTimeout(() => ws.send('Another message!'), 2000); setTimeout(() => ws.close(1000, 'Demo complete'), 4000); }