Extremely Popular
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338// Copyright 2018-2020 the oak authors. All rights reserved. MIT license.
import { test, assertEquals, assertStrictEq,} from "./test_deps.ts";import { ServerRequest } from "./deps.ts";import { Request } from "./request.ts";import { assert } from "https://deno.land/std@0.51.0/testing/asserts.ts";import { decoder } from "https://deno.land/std@0.51.0/encoding/utf8.ts";const encoder = new TextEncoder();
function createMockBodyReader(body: string): Deno.Reader { const buf = encoder.encode(body); let offset = 0; return { async read(p: Uint8Array): Promise<number | null> { if (offset >= buf.length) { return null; } const chunkSize = Math.min(p.length, buf.length - offset); p.set(buf); offset += chunkSize; return chunkSize; }, };}
interface MockServerRequestOptions { url?: string; host?: string; body?: string; headerValues?: Record<string, string>; proto?: string;}
function createMockServerRequest( { url = "/", host = "localhost", body = "", headerValues = {}, proto = "HTTP/1.1", }: MockServerRequestOptions = {},): ServerRequest { const headers = new Headers(); headers.set("host", host); for (const [key, value] of Object.entries(headerValues)) { headers.set(key, value); } if (body.length && !headers.has("content-length")) { headers.set("content-length", String(body.length)); } return { headers, method: "GET", url, proto, body: createMockBodyReader(body), async respond() {}, } as any;}
test({ name: "request.searchParams", fn() { const request = new Request( createMockServerRequest({ url: "/foo?bar=baz&qat=qux" }), ); assertEquals(request.url.pathname, "/foo"); assertEquals(request.url.search, "?bar=baz&qat=qux"); assertEquals(request.method, "GET"); assertEquals(Array.from(request.url.searchParams.entries()), [ ["bar", "baz"], ["qat", "qux"], ]); },});
test({ name: "request.url", fn() { const mockServerRequest = createMockServerRequest({ host: "oakserver.github.io:8080", url: "/foo/bar/baz?up=down", proto: "HTTPS/1.1", }); const request = new Request(mockServerRequest); assert(request.url instanceof URL); assertEquals(request.url.protocol, "https:"); assertEquals(request.url.hostname, "oakserver.github.io"); assertEquals(request.url.host, "oakserver.github.io:8080"); assertEquals(request.url.pathname, "/foo/bar/baz"); },});
test({ name: "request.serverRequest", fn() { const mockServerRequest = createMockServerRequest(); const request = new Request(mockServerRequest); assertStrictEq(request.serverRequest, mockServerRequest); },});
test({ name: "request.acceptsEncodings", fn() { const request = new Request( createMockServerRequest({ headerValues: { "Accept-Encoding": "gzip, compress;q=0.2, identity;q=0.5", }, }), ); assertEquals(request.acceptsEncodings("gzip", "identity"), "gzip"); },});
test({ name: "request.accepts()", fn() { const request = new Request( createMockServerRequest({ headerValues: { Accept: "application/json;q=0.2, text/html", }, }), ); assertEquals(request.accepts("application/json", "text/html"), "text/html"); },});
test({ name: "request.accepts not provided", fn() { const request = new Request( createMockServerRequest({ headerValues: { Accept: "application/json;q=0.2, text/html", }, }), ); assertEquals(request.accepts(), ["text/html", "application/json"]); },});
test({ name: "request.accepts none", fn() { const request = new Request(createMockServerRequest({ url: "/" })); assertEquals(request.accepts("application/json"), undefined); },});
test({ name: "request.accepts no match", fn() { const request = new Request( createMockServerRequest({ headerValues: { Accept: "text/html" } }), ); assertEquals(request.accepts("application/json"), undefined); },});
test({ name: "request.body JSON", async fn() { const request = new Request( createMockServerRequest({ body: `{"foo":"bar"}`, headerValues: { "Content-Type": "application/json", }, }), ); assertEquals(await request.body(), { type: "json", value: { foo: "bar" }, }); },});
test({ name: "request.body Form URLEncoded", async fn() { const request = new Request( createMockServerRequest( { body: `foo=bar&bar=1&baz=qux+%2B+quux`, headerValues: { "Content-Type": "application/x-www-form-urlencoded", }, }, ), ); const actual = await request.body(); assertEquals(actual.type, "form"); if (actual && actual.type === "form") { assertEquals(Array.from(actual.value.entries()), [ ["foo", "bar"], ["bar", "1"], ["baz", "qux + quux"], ]); } else { throw Error("Unexpected response"); } },});
test({ name: "request.body text", async fn() { const request = new Request( createMockServerRequest({ body: "hello world!", headerValues: { "Content-Type": "text/plain", }, }), ); assertEquals(await request.body(), { type: "text", value: "hello world!", }); },});
test({ name: "request.body({ asReader: true })", async fn() { const request = new Request( createMockServerRequest({ body: "foo", headerValues: { "Content-Type": "text/plain", }, }), ); const actual = await request.body({ asReader: true }); assertEquals(actual.type, "reader"); assertEquals(decoder.decode(await Deno.readAll(actual.value)), "foo"); },});
test({ name: "request.body(contentTypes)", async fn() { const request = new Request( createMockServerRequest({ body: "console.log('hello world!');", headerValues: { "Content-Type": "application/javascript", }, }), ); assertEquals( await request.body( { contentTypes: { text: ["application/javascript"] } }, ), { type: "text", value: "console.log('hello world!');", }, ); },});
test({ name: "request.body(contentTypes) does not overwrite", async fn() { const request = new Request( createMockServerRequest({ body: "hello world!", headerValues: { "Content-Type": "text/plain", }, }), ); assertEquals( await request.body( { contentTypes: { text: ["application/javascript"] } }, ), { type: "text", value: "hello world!", }, ); },});
test({ name: "request.body resolves undefined", async fn() { const request = new Request(createMockServerRequest()); assertEquals(await request.body(), { type: "undefined", value: undefined, }); },});
test({ name: "request.body unsupported media type", async fn() { const request = new Request( createMockServerRequest({ body: "blah", headerValues: { "Content-Type": "multipart/form-data", }, }), ); const actual = await request.body(); assertEquals(actual.type, "raw"); assert(actual.value instanceof Uint8Array); },});
test({ name: "request.secure is false", fn() { const request = new Request(createMockServerRequest()); assertEquals(request.secure, false); },});
test({ name: "request.secure is true", fn() { const request = new Request( createMockServerRequest({ proto: "HTTPS/1.1" }), ); assertEquals(request.secure, true); },});