tcp_socket.https.html | Explore in Territory

<!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>
chromium/third_party/blink/web_tests/external/wpt/direct-sockets/tcp_socket.https.html
