123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169
// Copyright 2018-2019 the oak authors. All rights reserved. MIT license.
import {  test,  assertEquals,  assertStrictEq,  assertThrowsAsync} from "./test_deps.ts";import { ServerRequest } from "./deps.ts";import httpErrors from "./httpError.ts";import { Request, BodyType } from "./request.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 | Deno.EOF> {      if (offset >= buf.length) {        return Deno.EOF;      }      const chunkSize = Math.min(p.length, buf.length - offset);      p.set(buf);      offset += chunkSize;      return chunkSize;    },  };}
function createMockServerRequest(  url = "/",  body = "",  headerValues: { [header: string]: string } = {},): ServerRequest {  const headers = new Headers();  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,    body: createMockBodyReader(body),    async respond() {},  } as any;}
test(function requestSearch() {  const request = new Request(createMockServerRequest("/foo?bar=baz&qat=qux"));  assertEquals(request.path, "/foo");  assertEquals(request.search, "?bar=baz&qat=qux");  assertEquals(request.method, "GET");  assertEquals(Array.from(request.searchParams.entries()), [    ["bar", "baz"],    ["qat", "qux"],  ]);});
test(function serverRequestAvail() {  const mockServerRequest = createMockServerRequest();  const request = new Request(mockServerRequest);  assertStrictEq(request.serverRequest, mockServerRequest);});
test(function requestAcceptEncoding() {  const request = new Request(    createMockServerRequest("/", "", {      "Accept-Encoding": "gzip, compress;q=0.2, identity;q=0.5",    }),  );  assertEquals(request.acceptsEncodings("gzip", "identity"), "gzip");});
test(function requestAccepts() {  const request = new Request(    createMockServerRequest("/", "", {      Accept: "application/json;q=0.2, text/html",    }),  );  assertEquals(request.accepts("application/json", "text/html"), "text/html");});
test(function requestAcceptsNoProvided() {  const request = new Request(    createMockServerRequest("/", "", {      Accept: "application/json;q=0.2, text/html",    }),  );  assertEquals(request.accepts(), ["text/html", "application/json"]);});
test(function requestNoAccepts() {  const request = new Request(createMockServerRequest("/"));  assertEquals(request.accepts("application/json"), undefined);});
test(function requestNoAcceptsMatch() {  const request = new Request(    createMockServerRequest("/", "", { Accept: "text/html" }),  );  assertEquals(request.accepts("application/json"), undefined);});
test(async function requestBodyJson() {  const request = new Request(    createMockServerRequest("/", `{"foo":"bar"}`, {      "Content-Type": "application/json",    }),  );  assertEquals(await request.body(), {    type: BodyType.JSON,    value: { foo: "bar" },  });});
test(async function requestBodyForm() {  const request = new Request(    createMockServerRequest("/", `foo=bar&bar=1&baz=qux+%2B+quux`, {      "Content-Type": "application/x-www-form-urlencoded",    }),  );  const actual = await request.body();  assertEquals(actual!.type, BodyType.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(async function requestBodyText() {  const request = new Request(    createMockServerRequest("/", "hello world!", {      "Content-Type": "text/plain",    }),  );  assertEquals(await request.body(), {    type: BodyType.Text,    value: "hello world!",  });});
test(async function noBodyResolvesUndefined() {  const request = new Request(createMockServerRequest());  assertEquals(await request.body(), {    type: BodyType.Undefined,    value: undefined,  });});
test(async function unsupportedMediaTypeBody() {  const request = new Request(    createMockServerRequest("/", "blah", {      "Content-Type": "multipart/form-data",    }),  );  await assertThrowsAsync(async () => {    await request.body();  }, httpErrors.UnsupportedMediaType);});