feat(net): add Deno.UnixConn interface (#13787)

cli/dts/lib.deno.unstable.d.ts

@@ -1053,7 +1053,7 @@ declare namespace Deno {
   ): Promise<TcpConn>;
   export function connect(
     options: UnixConnectOptions,
-  ): Promise<Conn>;
+  ): Promise<UnixConn>;
 
   export interface ConnectTlsOptions {
     /** PEM formatted client certificate chain. */

ext/net/01_net.js

@@ -9,6 +9,7 @@
     ObjectPrototypeIsPrototypeOf,
     PromiseResolve,
     SymbolAsyncIterator,
+    Error,
     Uint8Array,
     TypedArrayPrototypeSubarray,
   } = window.__bootstrap.primordials;
@@ -188,6 +189,8 @@
     }
   }
 
+  class UnixConn extends Conn {}
+
   class Listener {
     #rid = 0;
     #addr = null;
@@ -209,8 +212,11 @@
       const res = await opAccept(this.rid, this.addr.transport);
       if (this.addr.transport == "tcp") {
         return new TcpConn(res.rid, res.remoteAddr, res.localAddr);
+      } else if (this.addr.transport == "unix") {
+        return new UnixConn(res.rid, res.remoteAddr, res.localAddr);
+      } else {
+        throw new Error("unreachable");
       }
-      return new Conn(res.rid, res.remoteAddr, res.localAddr);
     }
 
     async next() {
@@ -311,18 +317,16 @@
   }
 
   async function connect(options) {
-    let res;
-
     if (options.transport === "unix") {
-      res = await opConnect(options);
+      const res = await opConnect(options);
-    } else {
+      return new UnixConn(res.rid, res.remoteAddr, res.localAddr);
-      res = await opConnect({
+    }
+
+    const res = await opConnect({
       transport: "tcp",
       hostname: "127.0.0.1",
       ...options,
     });
-    }
-
     return new TcpConn(res.rid, res.remoteAddr, res.localAddr);
   }
 
@@ -330,6 +334,7 @@
     connect,
     Conn,
     TcpConn,
+    UnixConn,
     opConnect,
     listen,
     opListen,

ext/net/lib.deno_net.d.ts

@@ -160,6 +160,9 @@ declare namespace Deno {
     setKeepAlive(keepalive?: boolean): void;
   }
 
+  // deno-lint-ignore no-empty-interface
+  export interface UnixConn extends Conn {}
+
   export interface ConnectTlsOptions {
     /** The port to connect to. */
     port: number;