import { runIfMain, test } from "./vendor/https/deno.land/std/testing/mod.ts";import { parseKeepAlive, readRequest, readResponse, writeResponse} from "./serveio.ts";import { assert, assertEquals} from "./vendor/https/deno.land/std/testing/asserts.ts";import { StringReader } from "./vendor/https/deno.land/std/io/readers.ts";import { encode } from "./vendor/https/deno.land/std/strings/encode.ts";import Reader = Deno.Reader;import Buffer = Deno.Buffer;import copy = Deno.copy;import { ServerResponse } from "./server.ts";import { readString } from "./util.ts";
test(async function serveioReadRequestGet() { const f = await Deno.open("./fixtures/request_get.txt"); const req = await readRequest(f); assertEquals(req.method, "GET"); assertEquals(req.url, "/index.html?deno=land&msg=gogo"); assertEquals(req.proto, "HTTP/1.1"); assertEquals(req.headers.get("host"), "deno.land"); assertEquals(req.headers.get("content-type"), "text/plain"); assert(req.body === void 0); assert(req.trailers === void 0); f.close();});
test(async function serveioReadRequestGetCapital() { const f = await Deno.open("./fixtures/request_get_capital.txt"); const req = await readRequest(f); assertEquals(req.method, "GET"); assertEquals(req.url, "/About/Index.html?deno=land&msg=gogo"); assertEquals(req.proto, "HTTP/1.1"); assertEquals(req.headers.get("host"), "deno.land"); assertEquals(req.headers.get("content-type"), "text/plain"); assert(req.body === void 0); assert(req.trailers === void 0); f.close();});
test(async function serveioReadRequestEncoded() { const f = await Deno.open("./fixtures/request_get_encoded.txt"); const req = await readRequest(f); assertEquals(req.method, "GET"); assertEquals( req.url, "/%E3%81%A7%E3%81%AE%E3%81%8F%E3%81%AB?deno=%F0%9F%A6%95" ); assertEquals(req.proto, "HTTP/1.1"); assertEquals(req.headers.get("host"), "deno.land"); assertEquals(req.headers.get("content-type"), "text/plain"); assert(req.body === void 0); assert(req.trailers === void 0); f.close();});
test(async function serveioReadRequestPost() { const f = await Deno.open("./fixtures/request_post.txt"); const req = await readRequest(f); assertEquals(req.method, "POST"); assertEquals(req.url, "/index.html"); assertEquals(req.proto, "HTTP/1.1"); assertEquals(req.headers.get("host"), "deno.land"); assertEquals(req.headers.get("content-type"), "text/plain"); assertEquals(req.headers.get("content-length"), "69"); assertEquals( await readString(req.body), "A secure JavaScript/TypeScript runtime built with V8, Rust, and Tokio" ); assert(req.trailers === void 0); f.close();});
test(async function serveioReadRequestPostChunked() { const f = await Deno.open("./fixtures/request_post_chunked.txt"); const req = await readRequest(f); assertEquals(req.method, "POST"); assertEquals(req.url, "/index.html"); assertEquals(req.proto, "HTTP/1.1"); assertEquals(req.headers.get("host"), "deno.land"); assertEquals(req.headers.get("content-type"), "text/plain"); assertEquals(req.headers.get("transfer-encoding"), "chunked"); assertEquals( await readString(req.body), "A secure JavaScript/TypeScript runtime built with V8, Rust, and Tokio" ); assertEquals(req.trailers, void 0); f.close();});
test(async function serveioReadRequestPostChunkedWithTrailers() { const f = await Deno.open("./fixtures/request_post_chunked_trailers.txt"); const req = await readRequest(f); assertEquals(req.method, "POST"); assertEquals(req.url, "/index.html"); assertEquals(req.proto, "HTTP/1.1"); assertEquals(req.headers.get("host"), "deno.land"); assertEquals(req.headers.get("content-type"), "text/plain"); assertEquals(req.headers.get("transfer-encoding"), "chunked"); assertEquals( await readString(req.body), "A secure JavaScript/TypeScript runtime built with V8, Rust, and Tokio" ); assertEquals(req.trailers, void 0); assertEquals(typeof req.finalize, "function"); await req.finalize(); assertEquals(req.trailers.constructor, Headers); assertEquals(req.trailers.get("x-deno"), "land"); assertEquals(req.trailers.get("x-node"), "js"); f.close();});
test(async function serveioReadResponse() { const f = await Deno.open("./fixtures/response.txt"); const res = await readResponse(f); assertEquals(res.proto, "HTTP/1.1"); assertEquals(res.status, 200); assertEquals(res.statusText, "OK"); assertEquals(res.headers.get("content-type"), "text/plain"); assertEquals(res.headers.get("content-length"), "69"); assertEquals( await readString(res.body), "A secure JavaScript/TypeScript runtime built with V8, Rust, and Tokio" ); assertEquals(res.trailers, void 0); assertEquals(typeof res.finalize, "function"); f.close();});
test(async function serveioReadResponseChunked() { const f = await Deno.open("./fixtures/response_chunked.txt"); const res = await readResponse(f); assertEquals(res.proto, "HTTP/1.1"); assertEquals(res.status, 200); assertEquals(res.statusText, "OK"); assertEquals(res.headers.get("content-type"), "text/plain"); assertEquals(res.headers.get("transfer-encoding"), "chunked"); assertEquals( await readString(res.body), "A secure JavaScript/TypeScript runtime built with V8, Rust, and Tokio" ); assertEquals(res.trailers, void 0); await res.finalize(); assertEquals(res.trailers.get("x-deno"), "land"); assertEquals(res.trailers.get("x-node"), "js"); assert(typeof res.finalize === "function"); f.close();});
test(async function serveioWriteResponse() { const list: ([ ServerResponse["body"], string | null, string | undefined, string ])[] = [ ["ok", "2", undefined, "text/plain; charset=UTF-8"], [encode("ok"), "2", "text/plain", "text/plain"], [new StringReader("ok"), null, undefined, "application/octet-stream"] ]; for (const [body, len, contentType, expContentType] of list) { const buf = new Buffer(); const headers = new Headers(); if (contentType) { headers.set("content-type", "text/plain"); } await writeResponse(buf, { status: 200, headers, body }); const res = await readResponse(buf); assertEquals(res.status, 200); assertEquals(res.headers.get("content-type"), expContentType); assertEquals(res.headers.get("content-length"), len); const resBody = new Buffer(); await copy(resBody, res.body); assertEquals(resBody.toString(), "ok"); }});
test(async function serveioWriteResponseWithoutHeaders() { const buf = new Buffer(); await writeResponse(buf, { status: 200, body: encode("ok") }); const res = await readResponse(buf); assertEquals(res.status, 200); assertEquals(res.headers.get("content-length"), "2"); const resBody = new Buffer(); await copy(resBody, res.body); assertEquals(resBody.toString(), "ok");});
test(function serveioParseKeepAlive() { const ka = parseKeepAlive( new Headers({ "keep-alive": "timeout=5, max=100" }) ); assertEquals(ka.timeout, 5); assertEquals(ka.max, 100);});
runIfMain(import.meta);