Function startWsServer

javascript/selenium-webdriver/test/bidi/index_test.js:30–48

(onMessage)

// plumbing and per-connection message parsing, so each server only has to supply how
// it replies to a parsed `{id, method, params}` message.
function startWsServer(onMessage) {
  return new Promise((resolve) => {
    const server = new WebSocketServer({ port: 0 }, () => {
      const { port } = server.address()
      resolve({
        server,
        url: `ws://127.0.0.1:${port}`,
        emitEvent(method, params) {
          for (const client of server.clients) {
            client.send(JSON.stringify({ method, params }))
          }
        },
      })
    })
    server.on('connection', (ws) => {
      ws.on('message', (data) => onMessage(JSON.parse(data.toString()), ws))
    })
  })
}

function startEchoServer() {
  return startWsServer(({ id }, ws) => ws.send(JSON.stringify({ id, result: {} })))