Function test

test/parallel/test-inspector-network-websocket.js:30–75

()

}

async function test() {
  await session.post('Network.enable');

  const CUSTOM_HEADER_NAME = 'X-Custom-Header';
  const CUSTOM_HEADER_VALUE = 'CustomHeaderValue';

  const server = new WebSocketServer({
    responseError: true,
    customHandleUpgradeHeaders: [
      `${CUSTOM_HEADER_NAME}: ${CUSTOM_HEADER_VALUE}`,
    ]
  });
  await server.start();
  const url = `ws://127.0.0.1:${server.port}/`;
  let requestId;
  once(session, 'Network.webSocketCreated').then(common.mustCall(([message]) => {
    assert.strictEqual(message.method, 'Network.webSocketCreated');
    assert.strictEqual(message.params.url, url);
    assert.ok(message.params.requestId);
    assert.strictEqual(typeof message.params.initiator, 'object');
    assert.strictEqual(message.params.initiator.type, 'script');
    assert.ok(findFrameInInitiator(nameRE, message.params.initiator));
    requestId = message.params.requestId;
  }));

  once(session, 'Network.webSocketHandshakeResponseReceived').then(common.mustCall(([message]) => {
    assert.strictEqual(message.params.requestId, requestId);
    assert.strictEqual(message.params.response.status, 101);
    assert.strictEqual(message.params.response.statusText, 'Switching Protocols');
    assert.strictEqual(message.params.response.headers.upgrade, 'websocket');
    assert.strictEqual(message.params.response.headers.connection, 'Upgrade');
    assert.ok(message.params.response.headers['sec-websocket-accept']);
    assert.ok(message.params.response.headers['sec-websocket-accept'].length > 0);
    assert.strictEqual(message.params.response.headers[CUSTOM_HEADER_NAME.toLowerCase()], CUSTOM_HEADER_VALUE);
    assert.strictEqual(typeof message.params.timestamp, 'number');
    socket.close();
  }));

  const socket = new WebSocket(url);
  once(session, 'Network.webSocketClosed').then(common.mustCall(([message]) => {
    assert.strictEqual(message.method, 'Network.webSocketClosed');
    assert.strictEqual(message.params.requestId, requestId);
    session.disconnect();
    server.server.close();
  }));
}

test().then(common.mustCall());