feat: Add "deno_net" extension (#11150)

This commits moves implementation of net related APIs available on "Deno"
namespace to "deno_net" extension.

Following APIs were moved:
- Deno.listen()
- Deno.connect()
- Deno.listenTls()
- Deno.serveHttp()
- Deno.shutdown()
- Deno.resolveDns()
- Deno.listenDatagram()
- Deno.startTls()
- Deno.Conn
- Deno.Listener
- Deno.DatagramConn

1 files changed, 0 insertions, 220 deletions

diff --git a/runtime/js/30_net.js b/runtime/js/30_net.js
deleted file mode 100644
index 2d4b1e48e..000000000
--- a/runtime/js/30_net.js
+++ /dev/null
@@ -1,220 +0,0 @@
-// Copyright 2018-2021 the Deno authors. All rights reserved. MIT license.
-"use strict";
-
-((window) => {
-  const core = window.Deno.core;
-  const { errors } = window.__bootstrap.errors;
-  const { read, write } = window.__bootstrap.io;
-
-  function shutdown(rid) {
-    return core.opAsync("op_shutdown", rid);
-  }
-
-  function opAccept(rid, transport) {
-    return core.opAsync("op_accept", { rid, transport });
-  }
-
-  function opListen(args) {
-    return core.opSync("op_listen", args);
-  }
-
-  function opConnect(args) {
-    return core.opAsync("op_connect", args);
-  }
-
-  function opReceive(rid, transport, zeroCopy) {
-    return core.opAsync(
-      "op_datagram_receive",
-      { rid, transport },
-      zeroCopy,
-    );
-  }
-
-  function opSend(args, zeroCopy) {
-    return core.opAsync("op_datagram_send", args, zeroCopy);
-  }
-
-  function resolveDns(query, recordType, options) {
-    return core.opAsync("op_dns_resolve", { query, recordType, options });
-  }
-
-  class Conn {
-    #rid = 0;
-    #remoteAddr = null;
-    #localAddr = null;
-    constructor(rid, remoteAddr, localAddr) {
-      this.#rid = rid;
-      this.#remoteAddr = remoteAddr;
-      this.#localAddr = localAddr;
-    }
-
-    get rid() {
-      return this.#rid;
-    }
-
-    get remoteAddr() {
-      return this.#remoteAddr;
-    }
-
-    get localAddr() {
-      return this.#localAddr;
-    }
-
-    write(p) {
-      return write(this.rid, p);
-    }
-
-    read(p) {
-      return read(this.rid, p);
-    }
-
-    close() {
-      core.close(this.rid);
-    }
-
-    closeWrite() {
-      return shutdown(this.rid);
-    }
-  }
-
-  class Listener {
-    #rid = 0;
-    #addr = null;
-
-    constructor(rid, addr) {
-      this.#rid = rid;
-      this.#addr = addr;
-    }
-
-    get rid() {
-      return this.#rid;
-    }
-
-    get addr() {
-      return this.#addr;
-    }
-
-    async accept() {
-      const res = await opAccept(this.rid, this.addr.transport);
-      return new Conn(res.rid, res.remoteAddr, res.localAddr);
-    }
-
-    async next() {
-      let conn;
-      try {
-        conn = await this.accept();
-      } catch (error) {
-        if (error instanceof errors.BadResource) {
-          return { value: undefined, done: true };
-        }
-        throw error;
-      }
-      return { value: conn, done: false };
-    }
-
-    return(value) {
-      this.close();
-      return Promise.resolve({ value, done: true });
-    }
-
-    close() {
-      core.close(this.rid);
-    }
-
-    [Symbol.asyncIterator]() {
-      return this;
-    }
-  }
-
-  class Datagram {
-    #rid = 0;
-    #addr = null;
-
-    constructor(rid, addr, bufSize = 1024) {
-      this.#rid = rid;
-      this.#addr = addr;
-      this.bufSize = bufSize;
-    }
-
-    get rid() {
-      return this.#rid;
-    }
-
-    get addr() {
-      return this.#addr;
-    }
-
-    async receive(p) {
-      const buf = p || new Uint8Array(this.bufSize);
-      const { size, remoteAddr } = await opReceive(
-        this.rid,
-        this.addr.transport,
-        buf,
-      );
-      const sub = buf.subarray(0, size);
-      return [sub, remoteAddr];
-    }
-
-    send(p, addr) {
-      const remote = { hostname: "127.0.0.1", ...addr };
-
-      const args = { ...remote, rid: this.rid };
-      return opSend(args, p);
-    }
-
-    close() {
-      core.close(this.rid);
-    }
-
-    async *[Symbol.asyncIterator]() {
-      while (true) {
-        try {
-          yield await this.receive();
-        } catch (err) {
-          if (err instanceof errors.BadResource) {
-            break;
-          }
-          throw err;
-        }
-      }
-    }
-  }
-
-  function listen({ hostname, ...options }) {
-    const res = opListen({
-      transport: "tcp",
-      hostname: typeof hostname === "undefined" ? "0.0.0.0" : hostname,
-      ...options,
-    });
-
-    return new Listener(res.rid, res.localAddr);
-  }
-
-  async function connect(options) {
-    let res;
-
-    if (options.transport === "unix") {
-      res = await opConnect(options);
-    } else {
-      res = await opConnect({
-        transport: "tcp",
-        hostname: "127.0.0.1",
-        ...options,
-      });
-    }
-
-    return new Conn(res.rid, res.remoteAddr, res.localAddr);
-  }
-
-  window.__bootstrap.net = {
-    connect,
-    Conn,
-    opConnect,
-    listen,
-    opListen,
-    Listener,
-    shutdown,
-    Datagram,
-    resolveDns,
-  };
-})(this);