12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091
// Copyright 2019 Yusuke Sakurai. All rights reserved. MIT license.import Writer = Deno.Writer;import { kHttpStatusMessages } from "./serveio.ts";import * as serveio from "./serveio.ts";import { ServerResponse } from "./server.ts";
/** Basic responder for http response */export interface ServerResponder {  /** Respond to request */  respond(response: ServerResponse): Promise<void>;
  /** Redirect request with 302 (Found ) */  redirect(    url: string,    opts?: {      headers?: Headers;      body?: ServerResponse["body"];    }  ): Promise<void>;
  /** Write additional trailer headers in tail of response */  writeTrailers(trailers: Headers): Promise<void>;
  isResponded(): boolean;
  respondedStatus(): number | undefined;}
/** create ServerResponder object */export function createResponder(w: Writer): ServerResponder {  let headers: Headers;  let status: number | undefined;  function isResponded() {    return status !== undefined;  }  async function writeTrailers(trailers: Headers): Promise<void> {    if (!isResponded()) {      throw new Error("trailer headers can't be written before responding");    }    await serveio.writeTrailers(w, headers, trailers);  }  async function redirect(    url: string,    {      headers = new Headers(),      body    }: { headers?: Headers; body?: ServerResponse["body"] } = {}  ) {    headers.set("location", url);    await respond({ status: 302, headers, body });  }  async function respond(response: ServerResponse): Promise<void> {    if (isResponded()) {      throw new Error("http: already responded");    }    status = response.status;    headers = response.headers;    await serveio.writeResponse(w, response);  }  function respondedStatus() {    return status;  }  return {    respond,    redirect,    isResponded,    respondedStatus,    writeTrailers  };}
export function badRequest(): ServerResponse {  return { status: 400, body: kHttpStatusMessages[400] };}
export function unauthorized(): ServerResponse {  return { status: 401, body: kHttpStatusMessages[401] };}
export function forbidden(): ServerResponse {  return { status: 403, body: kHttpStatusMessages[403] };}
export function notFound(): ServerResponse {  return { status: 404, body: kHttpStatusMessages[404] };}
export function internalServerError(): ServerResponse {  return { status: 500, body: kHttpStatusMessages[500] };}