tests/unit_node/net_test.ts - main - githubmirror/deno

tests/unit_node/net_test.ts
380 строк12 KB
Nathan Whitaker
fix(ext/node): store blocklist ranges compactly (#36212)
02 авг 2026, 16:51
02 авг 2026, 16:51140ec24
// Copyright 2018-2026 the Deno authors. MIT license.

import * as net from "node:net";
import { assert, assertEquals } from "@std/assert";
import * as path from "@std/path";
import * as http from "node:http";
import * as dns from "node:dns";
import * as dnsPromises from "node:dns/promises";
import util from "node:util";
import console from "node:console";
import { createRequire } from "node:module";

const require = createRequire(import.meta.url);

Deno.test("[node/net] close event emits after error event - when host is not found", async () => {
  const socket = net.createConnection(27009, "doesnotexist");
  const events: ("error" | "close")[] = [];
  const errorEmitted = Promise.withResolvers<void>();
  const closeEmitted = Promise.withResolvers<void>();
  socket.once("error", () => {
    events.push("error");
    errorEmitted.resolve();
  });
  socket.once("close", () => {
    events.push("close");
    closeEmitted.resolve();
  });
  await Promise.all([errorEmitted.promise, closeEmitted.promise]);

  // `error` happens before `close`
  assertEquals(events, ["error", "close"]);
});

// Regression for https://github.com/denoland/deno/issues/33879. When a handle
// exposes `getAsyncId` borrowed from `TCP.prototype` (or any AsyncWrap-derived
// prototype) but isn't itself a real AsyncWrap, Node silently falls back to a
// fresh async id rather than throwing. The Deno op2 brand check throws
// `TypeError: expected AsyncWrap`, so `_getNewAsyncId` has to swallow that.
Deno.test("[node/net] Socket falls back when handle.getAsyncId has wrong receiver", () => {
  const { TCP } = require("internal/test/binding").internalBinding("tcp_wrap");
  const socket = new net.Socket({
    handle: {
      getAsyncId: TCP.prototype.getAsyncId,
    },
    readable: false,
    writable: false,
    // deno-lint-ignore no-explicit-any
  } as any);
  socket.destroy();
});

Deno.test("[node/net] close event emits after error event - when connection is refused", async () => {
  const socket = net.createConnection(27009, "127.0.0.1");
  const events: ("error" | "close")[] = [];
  const errorEmitted = Promise.withResolvers<void>();
  const closeEmitted = Promise.withResolvers<void>();
  socket.once("error", () => {
    events.push("error");
    errorEmitted.resolve();
  });
  socket.once("close", () => {
    events.push("close");
    closeEmitted.resolve();
  });
  await Promise.all([errorEmitted.promise, closeEmitted.promise]);

  // `error` happens before `close`
  assertEquals(events, ["error", "close"]);
});

// Regression for https://github.com/denoland/deno/issues/34729. The native
// TCPWrap must expose `setKeepAlive` so `socket.setKeepAlive()` toggles
// SO_KEEPALIVE on the underlying socket instead of silently no-op'ing.
// Libraries such as `tedious`/`mssql` enable keepalive right after connecting
// to keep tunneled connections alive; losing it surfaced as ECONNRESET.
Deno.test("[node/net] socket.setKeepAlive() reaches the handle", async () => {
  const server = net.createServer((socket) => {
    socket.end();
  });
  const listening = Promise.withResolvers<void>();
  server.listen(0, "127.0.0.1", () => listening.resolve());
  await listening.promise;
  const { port } = server.address() as net.AddressInfo;

  const done = Promise.withResolvers<void>();
  const socket = net.connect(port, "127.0.0.1", () => {
    // The handle backing a connected TCP socket must implement setKeepAlive.
    // deno-lint-ignore no-explicit-any
    assertEquals(typeof (socket as any)._handle.setKeepAlive, "function");
    // Must not throw and must return the socket for chaining (Node API).
    assertEquals(socket.setKeepAlive(true, 30000), socket);
    socket.setKeepAlive(false);
    socket.destroy();
    done.resolve();
  });
  await done.promise;
  server.close();
});

Deno.test("[node/net] the port is available immediately after close callback", async () => {
  const deferred = Promise.withResolvers<void>();

  // This simulates what get-port@5.1.1 does.
  const getAvailablePort = (port: number) =>
    new Promise((resolve, reject) => {
      const server = net.createServer();
      server.on("error", reject);
      server.listen({ port }, () => {
        // deno-lint-ignore no-explicit-any
        const { port } = server.address() as any;
        server.close(() => {
          resolve(port);
        });
      });
    });

  const port = await getAvailablePort(5555);

  const httpServer = http.createServer();
  httpServer.on("error", (e) => deferred.reject(e));
  httpServer.listen(port, () => {
    httpServer.close(() => deferred.resolve());
  });
  await deferred.promise;
});

Deno.test("[node/net] net.connect().unref() works", async () => {
  const ctl = new AbortController();
  const server = Deno.serve({
    signal: ctl.signal,
    port: 0, // any available port will do
    handler: () => new Response("hello"),
    onListen: async ({ port, hostname }) => {
      hostname = Deno.build.os === "windows" ? "localhost" : hostname;
      const { stdout, stderr } = await new Deno.Command(Deno.execPath(), {
        args: [
          "eval",
          `
            import * as net from "node:net";
            const socket = net.connect(${port}, "${hostname}", () => {
              console.log("connected");
              socket.unref();
              socket.on("data", (data) => data.toString());
              socket.write("GET / HTTP/1.1\\n\\n");
            });
          `,
        ],
        cwd: path.dirname(path.fromFileUrl(import.meta.url)),
      }).output();
      if (stderr.length > 0) {
        console.log(new TextDecoder().decode(stderr));
      }
      assertEquals(new TextDecoder().decode(stdout), "connected\n");
      ctl.abort();
    },
  });
  await server.finished;
});

Deno.test({
  name: "[node/net] throws permission error instead of unknown error",
  permissions: "none",
  fn: () => {
    try {
      const s = new net.Server();
      s.listen(3000);
    } catch (e) {
      assert(e instanceof Deno.errors.NotCapable);
    }
  },
});

Deno.test("[node/net] connection event has socket value", async () => {
  const deferred = Promise.withResolvers<void>();
  const deferred2 = Promise.withResolvers<void>();

  const server = net.createServer();
  server.on("error", deferred.reject);
  server.on("connection", (socket) => {
    assert(socket !== undefined);
    socket.end();
    server.close(() => {
      deferred.resolve();
    });
  });
  server.listen(async () => {
    // deno-lint-ignore no-explicit-any
    const { port } = server.address() as any;

    const conn = await Deno.connect({
      port,
      transport: "tcp",
    });

    for await (const _ of conn.readable) {
      //
    }

    deferred2.resolve();
  });

  await Promise.all([deferred.promise, deferred2.promise]);
});

/// We need to make sure that any shared buffers are never used concurrently by two reads.
// https://github.com/denoland/deno/issues/20188
Deno.test("[node/net] multiple Sockets should get correct server data", async () => {
  const socketCount = 9;

  class TestSocket {
    dataReceived: ReturnType<typeof Promise.withResolvers<void>> = Promise
      .withResolvers<void>();
    events: string[] = [];
    socket: net.Socket | undefined;
  }

  const finished = Promise.withResolvers<void>();
  const serverSocketsClosed: ReturnType<typeof Promise.withResolvers<void>>[] =
    [];
  const server = net.createServer();
  server.on("connection", (socket) => {
    assert(socket !== undefined);
    const i = serverSocketsClosed.push(Promise.withResolvers<void>());
    socket.on("data", (data) => {
      socket.write(new TextDecoder().decode(data));
    });
    socket.on("close", () => {
      serverSocketsClosed[i - 1].resolve();
    });
  });

  const sockets: TestSocket[] = [];
  for (let i = 0; i < socketCount; i++) {
    sockets[i] = new TestSocket();
  }

  server.listen(async () => {
    // deno-lint-ignore no-explicit-any
    const { port } = server.address() as any;

    for (let i = 0; i < socketCount; i++) {
      const socket = sockets[i].socket = net.createConnection(port);
      socket.on("data", (data) => {
        const count = sockets[i].events.length;
        sockets[i].events.push(new TextDecoder().decode(data));
        if (count === 0) {
          // Trigger an immediate second write
          sockets[i].socket?.write(`${i}`.repeat(3));
        } else {
          sockets[i].dataReceived.resolve();
        }
      });
    }

    for (let i = 0; i < socketCount; i++) {
      sockets[i].socket?.write(`${i}`.repeat(3));
    }

    await Promise.all(sockets.map((socket) => socket.dataReceived.promise));

    for (let i = 0; i < socketCount; i++) {
      sockets[i].socket?.end();
    }

    server.close(() => {
      finished.resolve();
    });
  });

  await finished.promise;
  await Promise.all(serverSocketsClosed.map(({ promise }) => promise));

  for (let i = 0; i < socketCount; i++) {
    assertEquals(sockets[i].events, [`${i}`.repeat(3), `${i}`.repeat(3)]);
  }
});

Deno.test("[node/net] BlockList doesn't leak resources", () => {
  const blockList = new net.BlockList();
  blockList.addAddress("1.1.1.1");
  assert(blockList.check("1.1.1.1"));
});

Deno.test("[node/net] BlockList stores large ranges compactly", () => {
  const blockList = new net.BlockList();
  blockList.addRange("0.0.0.0", "255.255.255.255");
  assert(blockList.check("1.2.3.4"));
  assert(blockList.check("::ffff:1.2.3.4", "ipv6"));
  assertEquals(blockList.rules, ["Range: IPv4 0.0.0.0-255.255.255.255"]);
});

Deno.test("[node/net] net.Server can listen on the same port immediately after it's closed", async () => {
  const serverClosed = Promise.withResolvers<void>();
  const server = net.createServer();
  server.on("error", (e) => {
    console.error(e);
  });
  server.listen(0, () => {
    // deno-lint-ignore no-explicit-any
    const { port } = server.address() as any;
    server.close();
    server.listen(port, () => {
      server.close(() => {
        serverClosed.resolve();
      });
    });
  });
  await serverClosed.promise;
});

Deno.test("dns.resolve with ttl", async () => {
  const d1 = Promise.withResolvers();
  dns.resolve4("www.example.com", { ttl: true }, (err, addresses) => {
    if (err) {
      d1.reject(err);
    } else {
      d1.resolve(addresses);
    }
  });
  // deno-lint-ignore no-explicit-any
  const ret1 = await d1.promise as any[];
  assert(ret1.length > 0);
  assert(typeof ret1[0].ttl === "number");

  const d2 = Promise.withResolvers();
  dns.resolve4("www.example.com", (err, addresses) => {
    if (err) {
      d2.reject(err);
    } else {
      d2.resolve(addresses);
    }
  });
  const ret2 = await d2.promise as string[];
  assert(ret2.length > 0);
  assert(typeof ret2[0] === "string");
});

Deno.test("[node/dns] dns.lookup (all=true) util promisify", async () => {
  const lookup = util.promisify(dns.lookup);
  const result = await lookup("localhost", { all: true });
  assert(Array.isArray(result));
  assert(typeof result[0].address === "string");
  assert(typeof result[0].family === "number");
});

Deno.test("[node/dns] resolve IPv6 addresses", async () => {
  const resolveResults = await dnsPromises.resolve("deno.land", "AAAA");
  for (const address of resolveResults) {
    await dnsPromises.lookup(address);
  }

  const resolve6Results = await dnsPromises.resolve6("deno.land");
  for (const address of resolve6Results) {
    await dnsPromises.lookup(address);
  }

  const resolve6ttlResults = await dnsPromises.resolve6("deno.land", {
    ttl: true,
  });
  for (const { address } of resolve6ttlResults) {
    await dnsPromises.lookup(address);
  }
});

Deno.test("[node/net] Socket.remoteFamily returns string", async () => {
  const deferred = Promise.withResolvers<void>();
  const server = net.createServer((socket) => {
    // Default-host listen() binds dual-stack, so IPv4 connections arrive
    // through the IPv6 socket as IPv4-mapped addresses with family "IPv6".
    assertEquals(typeof socket.remoteFamily, "string");
    socket.end();
    server.close(() => deferred.resolve());
  });
  server.listen(0, () => {
    const { port } = server.address() as net.AddressInfo;
    const client = net.createConnection(port, "127.0.0.1");
    client.on("end", () => client.destroy());
  });
  await deferred.promise;
});