protoo-server

import * as http from 'http'; import { WebSocketServer } from 'ws'; import Server from 'protoo-server'; const httpServer = http.createServer(); const wsServer = new WebSocketServer({ server: httpServer, noServer: true }); const protooServer = new Server(); wsServer.on('connection', (ws, request) => { const { url } = request; if (!url) { ws.close(); return; } const peerId = url.split('/').pop() || `peer-${Date.now()}`; console.log(`New WebSocket connection from peer: ${peerId}`); let peer; try { peer = protooServer.createPeer(peerId, ws); } catch (error) { console.error(`Error creating protoo peer: ${error}`); ws.close(); return; } peer.on('request', async (request, accept, reject) => { console.log(`Peer '${peer.id}' sent request:`, request); try { const response = await handlePeerRequest(peer, request); accept(response); } catch (error) { reject(error); } }); peer.on('notification', (notification) => { console.log(`Peer '${peer.id}' sent notification:`, notification); }); peer.on('close', () => { console.log(`Peer '${peer.id}' disconnected.`); }); }); httpServer.on('upgrade', (request, socket, head) => { wsServer.handleUpgrade(request, socket, head, (ws) => { wsServer.emit('connection', ws, request); }); }); async function handlePeerRequest(peer, request) { switch (request.method) { case 'echo': return { message: `Echoing: ${request.data.text}` }; case 'joinRoom': // In a real app, you'd manage rooms here and add the peer console.log(`Peer '${peer.id}' wants to join room '${request.data.roomId}'`); peer.notify('roomJoined', { roomId: request.data.roomId, peers: [] }); return { joined: true }; default: throw new Error(`Unknown method: ${request.method}`); } } const PORT = process.env.PORT || 8080; httpServer.listen(PORT, () => { console.log(`protoo-server listening on ws://localhost:${PORT}`); console.log('Connect with protoo-client: protoo-client.createPeer(wsUrl, { requestTimeout: 3000 })'); });