mirror of
https://github.com/denoland/deno.git
synced 2024-11-24 15:19:26 -05:00
chore(ext/node): restore http_test from std (#18747)
This commit is contained in:
Yoshiya Hinosawa
Levente Kurusa
parent
3afecb923e
commit
8176b18a5e
1 changed files with 459 additions and 2 deletions
|
|
@ -1,10 +1,467 @@
|
|||
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
|
||||
|
||||
import http from "node:http";
|
||||
import { assertEquals } from "../../../test_util/std/testing/asserts.ts";
|
||||
import EventEmitter from "node:events";
|
||||
import http, { type RequestOptions } from "node:http";
|
||||
import {
|
||||
assert,
|
||||
assertEquals,
|
||||
} from "../../../test_util/std/testing/asserts.ts";
|
||||
import { assertSpyCalls, spy } from "../../../test_util/std/testing/mock.ts";
|
||||
import { deferred } from "../../../test_util/std/async/deferred.ts";
|
||||
|
||||
import { gzip } from "node:zlib";
|
||||
import { Buffer } from "node:buffer";
|
||||
import { serve } from "../../../test_util/std/http/server.ts";
|
||||
|
||||
Deno.test("[node/http listen]", async () => {
|
||||
{
|
||||
const server = http.createServer();
|
||||
assertEquals(0, EventEmitter.listenerCount(server, "request"));
|
||||
}
|
||||
|
||||
{
|
||||
const server = http.createServer(() => {});
|
||||
assertEquals(1, EventEmitter.listenerCount(server, "request"));
|
||||
}
|
||||
|
||||
{
|
||||
const promise = deferred<void>();
|
||||
const server = http.createServer();
|
||||
|
||||
server.listen(() => {
|
||||
server.close();
|
||||
});
|
||||
server.on("close", () => {
|
||||
promise.resolve();
|
||||
});
|
||||
|
||||
await promise;
|
||||
}
|
||||
|
||||
{
|
||||
const promise = deferred<void>();
|
||||
const server = http.createServer();
|
||||
|
||||
server.listen().on("listening", () => {
|
||||
server.close();
|
||||
});
|
||||
server.on("close", () => {
|
||||
promise.resolve();
|
||||
});
|
||||
|
||||
await promise;
|
||||
}
|
||||
|
||||
for (const port of [0, -0, 0.0, "0", null, undefined]) {
|
||||
const promise = deferred<void>();
|
||||
const server = http.createServer();
|
||||
|
||||
server.listen(port, () => {
|
||||
server.close();
|
||||
});
|
||||
server.on("close", () => {
|
||||
promise.resolve();
|
||||
});
|
||||
|
||||
await promise;
|
||||
}
|
||||
});
|
||||
|
||||
Deno.test("[node/http close]", async () => {
|
||||
{
|
||||
const promise1 = deferred<void>();
|
||||
const promise2 = deferred<void>();
|
||||
// Node quirk: callback gets exception object, event listener does not.
|
||||
// deno-lint-ignore no-explicit-any
|
||||
const server = http.createServer().close((err: any) => {
|
||||
assertEquals(err.code, "ERR_SERVER_NOT_RUNNING");
|
||||
promise1.resolve();
|
||||
});
|
||||
// deno-lint-ignore no-explicit-any
|
||||
server.on("close", (err: any) => {
|
||||
assertEquals(err, undefined);
|
||||
promise2.resolve();
|
||||
});
|
||||
server.on("listening", () => {
|
||||
throw Error("unreachable");
|
||||
});
|
||||
await promise1;
|
||||
await promise2;
|
||||
}
|
||||
|
||||
{
|
||||
const promise1 = deferred<void>();
|
||||
const promise2 = deferred<void>();
|
||||
const server = http.createServer().listen().close((err) => {
|
||||
assertEquals(err, undefined);
|
||||
promise1.resolve();
|
||||
});
|
||||
// deno-lint-ignore no-explicit-any
|
||||
server.on("close", (err: any) => {
|
||||
assertEquals(err, undefined);
|
||||
promise2.resolve();
|
||||
});
|
||||
server.on("listening", () => {
|
||||
throw Error("unreachable");
|
||||
});
|
||||
await promise1;
|
||||
await promise2;
|
||||
}
|
||||
});
|
||||
|
||||
Deno.test("[node/http] chunked response", async () => {
|
||||
for (
|
||||
const body of [undefined, "", "ok"]
|
||||
) {
|
||||
const expected = body ?? "";
|
||||
const promise = deferred<void>();
|
||||
|
||||
const server = http.createServer((_req, res) => {
|
||||
res.writeHead(200, { "transfer-encoding": "chunked" });
|
||||
res.end(body);
|
||||
});
|
||||
|
||||
server.listen(async () => {
|
||||
const res = await fetch(
|
||||
// deno-lint-ignore no-explicit-any
|
||||
`http://127.0.0.1:${(server.address() as any).port}/`,
|
||||
);
|
||||
assert(res.ok);
|
||||
|
||||
const actual = await res.text();
|
||||
assertEquals(actual, expected);
|
||||
|
||||
server.close(() => promise.resolve());
|
||||
});
|
||||
|
||||
await promise;
|
||||
}
|
||||
});
|
||||
|
||||
// TODO(kt3k): This test case exercises the workaround for https://github.com/denoland/deno/issues/17194
|
||||
// This should be removed when #17194 is resolved.
|
||||
Deno.test("[node/http] empty chunk in the middle of response", async () => {
|
||||
const promise = deferred<void>();
|
||||
|
||||
const server = http.createServer((_req, res) => {
|
||||
res.write("a");
|
||||
res.write("");
|
||||
res.write("b");
|
||||
res.end();
|
||||
});
|
||||
|
||||
server.listen(async () => {
|
||||
const res = await fetch(
|
||||
// deno-lint-ignore no-explicit-any
|
||||
`http://127.0.0.1:${(server.address() as any).port}/`,
|
||||
);
|
||||
const actual = await res.text();
|
||||
assertEquals(actual, "ab");
|
||||
server.close(() => promise.resolve());
|
||||
});
|
||||
|
||||
await promise;
|
||||
});
|
||||
|
||||
Deno.test("[node/http] server can respond with 101, 204, 205, 304 status", async () => {
|
||||
for (const status of [101, 204, 205, 304]) {
|
||||
const promise = deferred<void>();
|
||||
const server = http.createServer((_req, res) => {
|
||||
res.statusCode = status;
|
||||
res.end("");
|
||||
});
|
||||
server.listen(async () => {
|
||||
const res = await fetch(
|
||||
// deno-lint-ignore no-explicit-any
|
||||
`http://127.0.0.1:${(server.address() as any).port}/`,
|
||||
);
|
||||
await res.arrayBuffer();
|
||||
assertEquals(res.status, status);
|
||||
server.close(() => promise.resolve());
|
||||
});
|
||||
await promise;
|
||||
}
|
||||
});
|
||||
|
||||
Deno.test("[node/http] request default protocol", async () => {
|
||||
const promise = deferred<void>();
|
||||
const server = http.createServer((_, res) => {
|
||||
res.end("ok");
|
||||
});
|
||||
server.listen(() => {
|
||||
const req = http.request(
|
||||
// deno-lint-ignore no-explicit-any
|
||||
{ host: "localhost", port: (server.address() as any).port },
|
||||
(res) => {
|
||||
res.on("data", () => {});
|
||||
res.on("end", () => {
|
||||
server.close();
|
||||
});
|
||||
assertEquals(res.statusCode, 200);
|
||||
},
|
||||
);
|
||||
req.end();
|
||||
});
|
||||
server.on("close", () => {
|
||||
promise.resolve();
|
||||
});
|
||||
await promise;
|
||||
});
|
||||
|
||||
Deno.test("[node/http] request with headers", async () => {
|
||||
const promise = deferred<void>();
|
||||
const server = http.createServer((req, res) => {
|
||||
assertEquals(req.headers["x-foo"], "bar");
|
||||
res.end("ok");
|
||||
});
|
||||
server.listen(() => {
|
||||
const req = http.request(
|
||||
{
|
||||
host: "localhost",
|
||||
// deno-lint-ignore no-explicit-any
|
||||
port: (server.address() as any).port,
|
||||
headers: { "x-foo": "bar" },
|
||||
},
|
||||
(res) => {
|
||||
res.on("data", () => {});
|
||||
res.on("end", () => {
|
||||
server.close();
|
||||
});
|
||||
assertEquals(res.statusCode, 200);
|
||||
},
|
||||
);
|
||||
req.end();
|
||||
});
|
||||
server.on("close", () => {
|
||||
promise.resolve();
|
||||
});
|
||||
await promise;
|
||||
});
|
||||
|
||||
Deno.test("[node/http] non-string buffer response", {
|
||||
// TODO(kt3k): Enable sanitizer. A "zlib" resource is leaked in this test case.
|
||||
sanitizeResources: false,
|
||||
}, async () => {
|
||||
const promise = deferred<void>();
|
||||
const server = http.createServer((_, res) => {
|
||||
gzip(
|
||||
Buffer.from("a".repeat(100), "utf8"),
|
||||
{},
|
||||
(_err: Error | null, data: Buffer) => {
|
||||
res.setHeader("Content-Encoding", "gzip");
|
||||
res.end(data);
|
||||
},
|
||||
);
|
||||
});
|
||||
server.listen(async () => {
|
||||
const res = await fetch(
|
||||
// deno-lint-ignore no-explicit-any
|
||||
`http://localhost:${(server.address() as any).port}`,
|
||||
);
|
||||
try {
|
||||
const text = await res.text();
|
||||
assertEquals(text, "a".repeat(100));
|
||||
} catch (e) {
|
||||
server.emit("error", e);
|
||||
} finally {
|
||||
server.close(() => promise.resolve());
|
||||
}
|
||||
});
|
||||
await promise;
|
||||
});
|
||||
|
||||
// TODO(kt3k): Enable this test
|
||||
// Currently ImcomingMessage constructor has incompatible signature.
|
||||
/*
|
||||
Deno.test("[node/http] http.IncomingMessage can be created without url", () => {
|
||||
const message = new http.IncomingMessage(
|
||||
// adapted from https://github.com/dougmoscrop/serverless-http/blob/80bfb3e940057d694874a8b0bc12ad96d2abe7ab/lib/request.js#L7
|
||||
{
|
||||
// @ts-expect-error - non-request properties will also be passed in, e.g. by serverless-http
|
||||
encrypted: true,
|
||||
readable: false,
|
||||
remoteAddress: "foo",
|
||||
address: () => ({ port: 443 }),
|
||||
// deno-lint-ignore no-explicit-any
|
||||
end: Function.prototype as any,
|
||||
// deno-lint-ignore no-explicit-any
|
||||
destroy: Function.prototype as any,
|
||||
},
|
||||
);
|
||||
message.url = "https://example.com";
|
||||
});
|
||||
*/
|
||||
|
||||
Deno.test("[node/http] set http.IncomingMessage.statusMessage", () => {
|
||||
// deno-lint-ignore no-explicit-any
|
||||
const message = new (http as any).IncomingMessageForClient(
|
||||
new Response(null, { status: 404, statusText: "Not Found" }),
|
||||
{
|
||||
encrypted: true,
|
||||
readable: false,
|
||||
remoteAddress: "foo",
|
||||
address() {
|
||||
return { port: 443, family: "IPv4" };
|
||||
},
|
||||
// deno-lint-ignore no-explicit-any
|
||||
end(_cb: any) {
|
||||
return this;
|
||||
},
|
||||
// deno-lint-ignore no-explicit-any
|
||||
destroy(_e: any) {
|
||||
return;
|
||||
},
|
||||
},
|
||||
);
|
||||
assertEquals(message.statusMessage, "Not Found");
|
||||
message.statusMessage = "boom";
|
||||
assertEquals(message.statusMessage, "boom");
|
||||
});
|
||||
|
||||
Deno.test("[node/http] send request with non-chunked body", async () => {
|
||||
let requestHeaders: Headers;
|
||||
let requestBody = "";
|
||||
|
||||
const hostname = "localhost";
|
||||
const port = 4505;
|
||||
|
||||
// NOTE: Instead of node/http.createServer(), serve() in std/http/server.ts is used.
|
||||
// https://github.com/denoland/deno_std/pull/2755#discussion_r1005592634
|
||||
const handler = async (req: Request) => {
|
||||
requestHeaders = req.headers;
|
||||
requestBody = await req.text();
|
||||
return new Response("ok");
|
||||
};
|
||||
const abortController = new AbortController();
|
||||
const servePromise = serve(handler, {
|
||||
hostname,
|
||||
port,
|
||||
signal: abortController.signal,
|
||||
onListen: undefined,
|
||||
});
|
||||
|
||||
const opts: RequestOptions = {
|
||||
host: hostname,
|
||||
port,
|
||||
method: "POST",
|
||||
headers: {
|
||||
"Content-Type": "text/plain; charset=utf-8",
|
||||
"Content-Length": "11",
|
||||
},
|
||||
};
|
||||
const req = http.request(opts, (res) => {
|
||||
res.on("data", () => {});
|
||||
res.on("end", () => {
|
||||
abortController.abort();
|
||||
});
|
||||
assertEquals(res.statusCode, 200);
|
||||
assertEquals(requestHeaders.get("content-length"), "11");
|
||||
assertEquals(requestHeaders.has("transfer-encoding"), false);
|
||||
assertEquals(requestBody, "hello world");
|
||||
});
|
||||
req.write("hello ");
|
||||
req.write("world");
|
||||
req.end();
|
||||
|
||||
await servePromise;
|
||||
});
|
||||
|
||||
Deno.test("[node/http] send request with chunked body", async () => {
|
||||
let requestHeaders: Headers;
|
||||
let requestBody = "";
|
||||
|
||||
const hostname = "localhost";
|
||||
const port = 4505;
|
||||
|
||||
// NOTE: Instead of node/http.createServer(), serve() in std/http/server.ts is used.
|
||||
// https://github.com/denoland/deno_std/pull/2755#discussion_r1005592634
|
||||
const handler = async (req: Request) => {
|
||||
requestHeaders = req.headers;
|
||||
requestBody = await req.text();
|
||||
return new Response("ok");
|
||||
};
|
||||
const abortController = new AbortController();
|
||||
const servePromise = serve(handler, {
|
||||
hostname,
|
||||
port,
|
||||
signal: abortController.signal,
|
||||
onListen: undefined,
|
||||
});
|
||||
|
||||
const opts: RequestOptions = {
|
||||
host: hostname,
|
||||
port,
|
||||
method: "POST",
|
||||
headers: {
|
||||
"Content-Type": "text/plain; charset=utf-8",
|
||||
"Content-Length": "11",
|
||||
"Transfer-Encoding": "chunked",
|
||||
},
|
||||
};
|
||||
const req = http.request(opts, (res) => {
|
||||
res.on("data", () => {});
|
||||
res.on("end", () => {
|
||||
abortController.abort();
|
||||
});
|
||||
assertEquals(res.statusCode, 200);
|
||||
assertEquals(requestHeaders.has("content-length"), false);
|
||||
assertEquals(requestHeaders.get("transfer-encoding"), "chunked");
|
||||
assertEquals(requestBody, "hello world");
|
||||
});
|
||||
req.write("hello ");
|
||||
req.write("world");
|
||||
req.end();
|
||||
|
||||
await servePromise;
|
||||
});
|
||||
|
||||
Deno.test("[node/http] send request with chunked body as default", async () => {
|
||||
let requestHeaders: Headers;
|
||||
let requestBody = "";
|
||||
|
||||
const hostname = "localhost";
|
||||
const port = 4505;
|
||||
|
||||
// NOTE: Instead of node/http.createServer(), serve() in std/http/server.ts is used.
|
||||
// https://github.com/denoland/deno_std/pull/2755#discussion_r1005592634
|
||||
const handler = async (req: Request) => {
|
||||
requestHeaders = req.headers;
|
||||
requestBody = await req.text();
|
||||
return new Response("ok");
|
||||
};
|
||||
const abortController = new AbortController();
|
||||
const servePromise = serve(handler, {
|
||||
hostname,
|
||||
port,
|
||||
signal: abortController.signal,
|
||||
onListen: undefined,
|
||||
});
|
||||
|
||||
const opts: RequestOptions = {
|
||||
host: hostname,
|
||||
port,
|
||||
method: "POST",
|
||||
headers: {
|
||||
"Content-Type": "text/plain; charset=utf-8",
|
||||
},
|
||||
};
|
||||
const req = http.request(opts, (res) => {
|
||||
res.on("data", () => {});
|
||||
res.on("end", () => {
|
||||
abortController.abort();
|
||||
});
|
||||
assertEquals(res.statusCode, 200);
|
||||
assertEquals(requestHeaders.has("content-length"), false);
|
||||
assertEquals(requestHeaders.get("transfer-encoding"), "chunked");
|
||||
assertEquals(requestBody, "hello world");
|
||||
});
|
||||
req.write("hello ");
|
||||
req.write("world");
|
||||
req.end();
|
||||
|
||||
await servePromise;
|
||||
});
|
||||
|
||||
Deno.test("[node/http] ServerResponse _implicitHeader", async () => {
|
||||
const d = deferred<void>();
|
||||
const server = http.createServer((_req, res) => {
|
||||
|
|
|
|||
Loading…
Reference in a new issue