123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
import { join, SEP } from "../deps/path.ts";import Events from "./events.ts";import { serveFile, Server as HttpServer } from "../deps/http.ts";
import type { Event, EventListener, EventOptions } from "../core.ts";
/** The options to configure the local server */export interface Options {  /** The root path */  root: string;
  /** The port to listen on */  port: number;}
export type RequestHandler = (req: Request) => Promise<Response>;export type Middleware = (  req: Request,  next: RequestHandler,) => Promise<Response>;
/** Custom events for server */export interface ServerEvent extends Event {  /** The event type */  type: ServerEventType;
  /** The request object */  request?: Request;
  /** The error object (only for "error" events) */  error?: Error;}
/** The available event types */export type ServerEventType =  | "start"  | "error";
export default class Server {  events: Events<ServerEvent> = new Events<ServerEvent>();  options: Options;  middlewares: Middleware[] = [];
  constructor(options: Options) {    this.options = options;  }
  /** Register one or more middlewares */  use(...middleware: Middleware[]) {    this.middlewares.push(...middleware);    return this;  }
  /** Add a listener to an event */  addEventListener(    type: ServerEventType,    listener: EventListener<ServerEvent>,    options?: EventOptions,  ) {    this.events.addEventListener(type, listener, options);    return this;  }
  /** Dispatch an event */  dispatchEvent(event: ServerEvent) {    return this.events.dispatchEvent(event);  }
  /** Start the server */  async start() {    const { port } = this.options;
    const server = new HttpServer({      port: port,      handler: (request) => this.handle(request),    });
    this.dispatchEvent({ type: "start" });
    await server.listenAndServe();  }
  /** Handle a http request event */  async handle(request: Request): Promise<Response> {    const middlewares = [...this.middlewares];
    const next: RequestHandler = async (      request: Request,    ): Promise<Response> => {      const middleware = middlewares.shift();
      if (middleware) {        return await middleware(request, next);      }
      return await this.serveFile(request);    };
    return await next(request);  }
  /** Server a static file */  async serveFile(request: Request): Promise<Response> {    const url = new URL(request.url);    const pathname = decodeURIComponent(url.pathname);    let path = join(this.options.root, pathname);
    try {      if (path.endsWith(SEP)) {        path += "index.html";      }
      // Redirect /example to /example/      const info = await Deno.stat(path);
      if (info.isDirectory) {        return new Response(null, {          status: 301,          headers: {            location: join(pathname, "/"),          },        });      }
      // Serve the static file      return await serveFile(request, path);    } catch {      return new Response(        "Not found",        { status: 404 },      );    }  }}