123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309
// Copyright 2018-2021 the oak authors. All rights reserved. MIT license.
// deno-lint-ignore-file
import {  assert,  assertEquals,  assertStrictEquals,  assertThrows,  assertThrowsAsync,} from "./test_deps.ts";import type { ServerRequest } from "./http_server_std.ts";import { Request } from "./request.ts";
const { test } = Deno;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;  conn?: {    remoteAddr: {      hostname: 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: "HTTP/1.1",    });    const request = new Request(mockServerRequest, false, true);    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);    assertStrictEquals(request.originalRequest, 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()",  async fn() {    const request = new Request(      createMockServerRequest(        {          body: JSON.stringify({ hello: "world" }),          headerValues: { "content-type": "application/json" },        },      ),    );    assert(request.hasBody);    const actual = request.body();    assertEquals(actual.type, "json");    assertEquals(await actual.value, { hello: "world" });  },});
test({  name: "request.body() passes args",  async fn() {    const request = new Request(      createMockServerRequest(        {          body: JSON.stringify({ hello: "world" }),          headerValues: { "content-type": "text/plain" },        },      ),    );    const actual = request.body({ type: "json" });    assertEquals(actual.type, "json");    assertEquals(await actual.value, { hello: "world" });  },});
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(),      false,      true,    );    assertEquals(request.secure, true);  },});
test({  name: "request with proxy true",  fn() {    const request = new Request(      createMockServerRequest({        headerValues: {          "x-forwarded-host": "10.10.10.10",          "x-forwarded-proto": "http",          "x-forwarded-for": "10.10.10.10, 192.168.1.1, 10.255.255.255",        },        conn: {          remoteAddr: {            hostname: "10.255.255.255",          },        },      }),      true,      true,    );    assertEquals(request.secure, true);    assertEquals(request.url.hostname, "10.10.10.10");    assertEquals(request.url.protocol, "http:");    assertEquals(request.ip, "10.10.10.10");    assertEquals(request.ips, ["10.10.10.10", "192.168.1.1", "10.255.255.255"]);  },});
test({  name: "request with bad url",  fn() {    const request = new Request(createMockServerRequest({      url: " a ",    }));    assertThrows(      () => {        request.url;      },      TypeError,      `The server request URL of "http://localhost a " is invalid.`,    );  },});
test({  name: "request with invalid JSON",  async fn() {    const request = new Request(      createMockServerRequest(        {          body: "random text, but not JSON",          headerValues: { "content-type": "application/json" },        },      ),    );    assert(request.hasBody, "should have body");    const actual = request.body();    assert(actual.type === "json", "should be a JSON body");    await assertThrowsAsync(      async () => {        await actual.value;      },      SyntaxError,      "Unexpected token r in JSON at position 0",    );  },});
test({  name: "Request - inspecting",  fn() {    assertEquals(      Deno.inspect(        new Request(createMockServerRequest({ url: "/foo?bar=baz&qat=qux" })),      ),      `Request {\n  hasBody: false,\n  headers: Headers { host: "localhost" },\n  ip: "",\n  ips: [],\n  method: "GET",\n  secure: false,\n  url: "http://localhost/foo?bar=baz&qat=qux"\n}`,    );  },});