CustomRouter.js

import { parse } from "url";

export default class CustomRouter {
  #listeners = {
    ACL: [],
    BIND: [],
    CHECKOUT: [],
    CONNECT: [],
    COPY: [],
    DELETE: [],
    GET: [],
    HEAD: [],
    LINK: [],
    LOCK: [],
    MERGE: [],
    MKACTIVITY: [],
    MKCALENDAR: [],
    MKCOL: [],
    MOVE: [],
    NOTIFY: [],
    OPTIONS: [],
    PATCH: [],
    POST: [],
    PRI: [],
    PROPFIND: [],
    PROPPATCH: [],
    PURGE: [],
    PUT: [],
    REBIND: [],
    REPORT: [],
    SEARCH: [],
    SOURCE: [],
    SUBSCRIBE: [],
    TRACE: [],
    UNBIND: [],
    UNLINK: [],
    UNLOCK: [],
    UNSUBSCRIBE: [],
  };

  #errorListener = function (req, res) {
    res.writeHead(404);
    res.end();
  };

  #mapping = new Map();

  on = function (method, url, callback) {
    if (this.#mapping.has(url)) {
      console.error(`Error : Duplicate ${url} : Ignoring Endpoint`);
    } else {
      this.#listeners[method].push({ url, callback });
      this.#mapping.set(url, this.#listeners[method].length - 1);
    }
  };

  route = function (req, res, time = Date.now()) {
    const pathname = parse(req.url, true).pathname;
    const callback = this.#getListener(pathname, req.method.toUpperCase());

    if (callback === undefined) {
      this.#errorListener(req, res);
    } else {
      callback(req, res);
    }

    console.log(`${req.url}: Request took ${Date.now() - time}ms`);
  };

  #getListener = function (url, method) {
    if (this.#mapping.has(url)) {
      const index = this.#mapping.get(url);
      if (this.#listeners[method][index].url === url) {
        return this.#listeners[method][index].callback;
      }
    }
    return undefined;
  };
}