responder_test.ts

// Copyright 2019 Yusuke Sakurai. All rights reserved. MIT license.
import { createResponder } from "./responder.ts";
import {
  assert,
  assertEquals,
  assertThrowsAsync
} from "./vendor/https/deno.land/std/testing/asserts.ts";
import { StringReader } from "./vendor/https/deno.land/std/io/readers.ts";
import { readResponse, readRequest } from "./serveio.ts";
import { StringWriter } from "./vendor/https/deno.land/std/io/writers.ts";
import Buffer = Deno.Buffer;
import copy = Deno.copy;
import Reader = Deno.Reader;
import { it } from "./test_util.ts";

it("responder", (t) => {
  t.run("basic", async function () {
    const w = new Buffer();
    const res = createResponder(w);
    assert(!res.isResponded());
    await res.respond({
      status: 200,
      headers: new Headers({
        "content-type": "text/plain",
      }),
      body: new StringReader("ok"),
    });
    assert(res.isResponded());
    const resp = await readResponse(w);
    assertEquals(resp.status, 200);
    assertEquals(resp.headers.get("content-type"), "text/plain");
    const sw = new StringWriter();
    await copy(sw, resp.body as Reader);
    assertEquals(sw.toString(), "ok");
  });

  t.run("respond() should throw if already responded", async function () {
    const w = new Buffer();
    const res = createResponder(w);
    await res.respond({
      status: 200,
      headers: new Headers(),
    });
    await assertThrowsAsync(async () =>
      res.respond({
        status: 200,
        headers: new Headers(),
      }), Error, "responded");
  });

  t.run("sendFile() basic", async function () {
    const w = new Buffer();
    const res = createResponder(w);
    await res.sendFile("./fixtures/sample.txt");
    const resp = await readResponse(w);
    assertEquals(resp.status, 200);
    assertEquals(resp.headers.get("content-type"), "text/plain");
    assertEquals(await resp.body?.text(), "sample");
  });

  t.run("sendFile() should throw if file not found", async () => {
    const w = new Buffer();
    const res = createResponder(w);
    await assertThrowsAsync(
      () => res.sendFile("./fixtures/not-found"),
      Deno.errors.NotFound,
    );
  });

  t.run("sendFile() with attachment", async () => {
    const w = new Buffer();
    const res = createResponder(w);
    await res.sendFile("./fixtures/sample.txt", {
      contentDisposition: "inline",
    });
    const resp = await readResponse(w);
    assertEquals(resp.status, 200);
    assertEquals(resp.headers.get("content-disposition"), "inline");
    assertEquals(await resp.body?.text(), "sample");
  });

  t.run("sendFile() with attachment", async () => {
    const w = new Buffer();
    const res = createResponder(w);
    await res.sendFile("./fixtures/sample.txt", {
      contentDisposition: "attachment",
    });
    const resp = await readResponse(w);
    assertEquals(resp.status, 200);
    assertEquals(
      resp.headers.get("content-disposition"),
      'attachment; filename="sample.txt"',
    );
    assertEquals(await resp.body?.text(), "sample");
  });

  t.run("responder redirect should set Location header", async () => {
    const w = new Buffer();
    const res = createResponder(w);
    await res.redirect("/index.html");
    const { status, headers } = await readResponse(w);
    assertEquals(status, 302);
    assertEquals(headers.get("location"), "/index.html");
  });

  t.run("markResponded()", async () => {
    const w = new Buffer();
    const res = createResponder(w);
    res.markAsResponded(200);
    assertEquals(res.isResponded(), true);
    assertEquals(res.respondedStatus(), 200);
    await assertThrowsAsync(
      () => res.respond({ status: 404, body: "404" }),
      Error,
      "already",
    );
  });
});