tcp_socket.https.html

Enable keyboard shortcuts

This WPT test may be referenced by the following Test IDs:
- /direct-sockets/tcp_socket.https.html - WPT Dashboard Interop Dashboard

<!DOCTYPE html>

<script src="/resources/testharness.js"></script>

<script src="/resources/testharnessreport.js"></script>

<script src="/resources/test-only-api.js"></script>

<script>

'use strict';

promise_test(async () => {

  const kPacket = "I'm a netcat. Meow-meow!"

  const serverSocket = new TCPServerSocket("127.0.0.1");

  const { localPort } = await serverSocket.opened;

  const clientSocket = new TCPSocket("127.0.0.1", localPort);

  const acceptedSocket = await (async () => {

    const { readable } = await serverSocket.opened;

    const reader = readable.getReader();

    const { value: acceptedSocket, done } = await reader.read();

    assert_false(done);

    reader.releaseLock();

    return acceptedSocket;

  })();

  const encoder = new TextEncoder();

  const decoder = new TextDecoder();

  const readPacket = async socket => {

    const { readable } = await socket.opened;

    const reader = readable.getReader();

    let result = "";

    while (result.length < kPacket.length) {

      const { value, done } = await reader.read();

      assert_false(done);

      result += decoder.decode(value);

    assert_equals(result, kPacket);

    reader.releaseLock();

};

  const sendPacket = async socket => {

    const { writable } = await socket.opened;

    const writer = writable.getWriter();

    await writer.ready;

    await writer.write(encoder.encode(kPacket));

    writer.releaseLock();

};

  const acceptedSocketEcho = (async () => {

    await readPacket(acceptedSocket);

    await sendPacket(acceptedSocket);

  })();

  const clientSocketSend = (async () => {

    await sendPacket(clientSocket);

  })();

  const clientSocketReceive = (async () => {

    await readPacket(clientSocket);

  })();

  await clientSocketReceive;

  await clientSocket.close();

  await acceptedSocket.close();

  await serverSocket.close();

}, 'TCPSocket exchanges packets with TCPServerSocket');

</script>