12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182
// Copyright 2019 Yusuke Sakurai. All rights reserved. MIT license.import Writer = Deno.Writer;import * as serveio from "./serveio.ts";import { ServerResponse } from "./server.ts";import { cookieSetter, CookieSetter } from "./cookie.ts";
/** Basic responder for http response */export interface ServerResponder extends CookieSetter {  /** 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 {  const responseHeaders = new Headers();  const cookie = cookieSetter(responseHeaders);  let responseStatus: number | undefined;  function isResponded() {    return responseStatus !== 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, responseHeaders, 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");    }    const { status, headers, body } = response;    responseStatus = status;    if (headers) {      for (const [k, v] of headers.entries()) {        responseHeaders.append(k, v);      }    }    await serveio.writeResponse(w, {      status,      headers: responseHeaders,      body    });  }  function respondedStatus() {    return responseStatus;  }  return {    respond,    redirect,    isResponded,    respondedStatus,    writeTrailers,    ...cookie  };}