123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
// Copyright 2020-2020 The Mandarine.TS Framework authors. All rights reserved. MIT license.
import { Application, Middleware } from "../deps.ts";import { Log } from "../logger/log.ts";import { Mandarine } from "../main-core/Mandarine.ns.ts";import { ResourceHandlerMiddleware } from "./core/middlewares/resourceHandlerMiddleware.ts";import { MandarineMvcFrameworkStarter } from "./engine/mandarineMvcFrameworkStarter.ts";import { handleBuiltinAuth } from "./core/middlewares/authMiddleware.ts";import { HttpUtils } from "../main-core/utils/httpUtils.ts";import { ExceptionHandler } from "./core/middlewares/exceptionHandler.ts";
/** * This class is the bridge between the HTTP server & the Mandarine Compiler. */export class MandarineMVC {  public logger: Log = Log.getLogger(MandarineMVC);
  private oakMiddleware: Array<Middleware> = new Array<Middleware>();
  get handle() {    let app: Application = this.initializeMVCApplication();
    if (this.onRun) {      this.onRun(this);    }
    return app.handle;  }
  public addMiddleware(middleware: Middleware): MandarineMVC {    this.oakMiddleware.push(middleware);    return this;  }
  constructor(onInitialization?: Function, private readonly onRun?: Function) {    if (onInitialization) {      onInitialization(this);    }  }
  public run(options?: { hostname?: string; port?: number }) {    let app: Application = this.initializeMVCApplication();
    let mandarineConfiguration: Mandarine.Properties = Mandarine.Global.getMandarineConfiguration();
    try {      setTimeout(async () => {        app.listen({          hostname:            options && options.hostname              ? options.hostname              : mandarineConfiguration.mandarine.server.host,          port:            options && options.port              ? options.port              : mandarineConfiguration.mandarine.server.port,        });      }, 1000);    } catch (error) {      this.logger.compiler(`Server has been shut down`, "error", error);    }
    if (this.onRun) {      this.onRun(this);    }  }
  private initializeMVCApplication(): Application {    let mandarineConfiguration: Mandarine.Properties = Mandarine.Global.getMandarineConfiguration();
    let starter: MandarineMvcFrameworkStarter = new MandarineMvcFrameworkStarter((engine: MandarineMvcFrameworkStarter) => {        engine.intializeControllersRoutes();        engine.initializeEssentials();      }    );
    let app: Application = new Application()      .use(ExceptionHandler())      .use(handleBuiltinAuth())      .use(ResourceHandlerMiddleware())      .use(starter.getRouter().routes())      .use(starter.getRouter().allowedMethods())      .use(async (ctx: any, next) => {        const typedContext: Mandarine.Types.RequestContext = ctx;        if (!typedContext.isResource) {          HttpUtils.assignContentType(ctx);        }        await next();      });    app.keys = [mandarineConfiguration.mandarine.security.cookiesSignKeys];
    this.oakMiddleware.forEach((middleware) => {      app = app.use(middleware);    });
    app.addEventListener("error", (event) => {      this.logger.compiler("Fatal error", "error", event.error);    });
    app.addEventListener("listen", (options) => {      this.logger.compiler(`Server has started ~ ${options.secure ? "https://" : "http://"}${options.hostname ?? "localhost"}:${options.port}`, "info");    });    return app;  }}