import { createServer, createWebSocketServer } from '@libp2p/http'
const wss = createWebSocketServer()
wss.addEventListener('connection', (evt) => {
const ws = evt.webSocket
ws.addEventListener('message', (evt) => {
ws.send(evt.data)
})
})
const server = createServer((req, res) => {
// handle HTTP request
})
server.addListener('upgrade', (request, socket, head) => {
wss.handleUpgrade(request, socket, head)
})
Creates a WebSocket server that can handle upgrade requests from clients.
Add a listener for the
connection
event to receive incoming WebSocket connections.