1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
|
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
import * as net from "node:net";
import { assertEquals } from "../../../test_util/std/testing/asserts.ts";
import { deferred } from "../../../test_util/std/async/deferred.ts";
import * as path from "../../../test_util/std/path/mod.ts";
import * as http from "node:http";
import { assert } from "../../../test_util/std/testing/asserts.ts";
Deno.test("[node/net] close event emits after error event", async () => {
const socket = net.createConnection(27009, "doesnotexist");
const events: ("error" | "close")[] = [];
const errorEmitted = deferred();
const closeEmitted = deferred();
socket.once("error", () => {
events.push("error");
errorEmitted.resolve();
});
socket.once("close", () => {
events.push("close");
closeEmitted.resolve();
});
await Promise.all([errorEmitted, closeEmitted]);
// `error` happens before `close`
assertEquals(events, ["error", "close"]);
});
Deno.test("[node/net] the port is available immediately after close callback", async () => {
const p = deferred();
// 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) => p.reject(e));
httpServer.listen(port, () => {
httpServer.close(() => p.resolve());
});
await p;
});
Deno.test("[node/net] net.connect().unref() works", async () => {
const ctl = new AbortController();
const server = Deno.serve({
signal: ctl.signal,
handler: () => new Response("hello"),
onListen: async ({ port, 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) => console.log(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.PermissionDenied);
}
},
});
|
