123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159
import { Status as STATUS_CODES } from "../http/http_status.ts";import { Buffer } from "./buffer.ts";
const METHODS = [  "ACL",  "BIND",  "CHECKOUT",  "CONNECT",  "COPY",  "DELETE",  "GET",  "HEAD",  "LINK",  "LOCK",  "M-SEARCH",  "MERGE",  "MKACTIVITY",  "MKCALENDAR",  "MKCOL",  "MOVE",  "NOTIFY",  "OPTIONS",  "PATCH",  "POST",  "PROPFIND",  "PROPPATCH",  "PURGE",  "PUT",  "REBIND",  "REPORT",  "SEARCH",  "SOURCE",  "SUBSCRIBE",  "TRACE",  "UNBIND",  "UNLINK",  "UNLOCK",  "UNSUBSCRIBE",];
type Chunk = string | Buffer | Uint8Array;type Headers = Record<string, string>;
export class ServerResponse {  status?: number;  headers: Headers;  chunks: Chunk[];  headersSent: boolean;  private reqEvent: Deno.RequestEvent;
  constructor(reqEvent: Deno.RequestEvent) {    this.status = undefined;    this.headers = {};    this.chunks = [];    this.headersSent = false;    this.reqEvent = reqEvent;  }
  setHeader(name: string, value: string) {    this.headers[name] = value;  }
  getHeader(name: string) {    return this.headers[name];  }
  writeHead(status: number, headers: Headers) {    this.status = status;    Object.assign(this.headers, headers);  }  write(chunk: Chunk) {    this._addChunk(chunk);  }
  _addChunk(chunk: Chunk) {    if (this.status === null) {      this.status = 200;      this.headers = { "content-type": "text/plain" };    }    this.chunks.push(chunk);  }
  _body(lastChunk?: Chunk) {    // TODO: incorrectly assumes all chunks are strings    return this.chunks ? this.chunks.join("") + lastChunk : lastChunk;  }
  end(lastChunk: Chunk) {    const body = this._body(lastChunk);    this.headersSent = true;    this.reqEvent.respondWith(new Response(body, { headers: this.headers }));  }}
export class IncomingMessage {  private req: Request;
  constructor(req: Request) {    this.req = req;  }
  get aborted() {    return false;  }  get completed() {    return true;  }  get httpVersion() {    return "1.1";  }
  get headers() {    return this.req.headers;  }
  get url() {    // TODO: consider more robust path extraction, e.g:    // url: (new URL(request.url).pathname),    return this.req.url.slice(this.req.url.indexOf("/", 8));  }}
type ServerHandler = (req: IncomingMessage, res: ServerResponse) => void;
export class Server {  handler: ServerHandler;
  constructor(handler: ServerHandler) {    this.handler = handler;  }
  async listen(port: number) {    for await (const conn of Deno.listen({ port })) {      (async () => {        for await (const reqEvent of Deno.serveHttp(conn)) {          this.handler(            new IncomingMessage(reqEvent.request),            new ServerResponse(reqEvent),          );        }      })();    }  }}
export function createServer(handler: ServerHandler) {  return new Server(handler);}
export { METHODS, STATUS_CODES };export default {  STATUS_CODES,  METHODS,  createServer,  Server,  IncomingMessage,  ServerResponse,};