123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237
// -------------------------------------------------------------------------// Main exports// -------------------------------------------------------------------------
// Http errors
export * from './http-error/HttpError.ts';export * from './http-error/InternalServerError.ts';export * from './http-error/BadRequestError.ts';export * from './http-error/ForbiddenError.ts';export * from './http-error/NotAcceptableError.ts';export * from './http-error/MethodNotAllowedError.ts';export * from './http-error/NotFoundError.ts';export * from './http-error/UnauthorizedError.ts';
// Rendererexport * from './renderer/content.ts';export * from './renderer/view.ts';
// Decoratorsexport * from './decorator/Area.ts';export * from './decorator/Controller.ts';export * from './decorator/Get.ts';export * from './decorator/Post.ts';export * from './decorator/Patch.ts';export * from './decorator/Put.ts';export * from './decorator/Delete.ts';
// Action decoratorsexport * from './decorator/Cookie.ts';export * from './decorator/QueryParam.ts';export * from './decorator/Body.ts';export * from './decorator/Req.ts';export * from './decorator/Res.ts';export * from './decorator/Param.ts';
// Http exportsexport { Response, ServerRequest } from './package.ts';
// Standart middlwaresexport { CorsBuilder } from './middlewares/cors-builder.ts';
// DIexport * from './injection/index.ts';
// Interfacesexport * from './models/view-render-config.ts';
import { MetadataArgsStorage } from './metadata/metadata.ts';import { serve, Response } from './package.ts';import { getAction, notFoundAction } from './route/get-action.ts';import { getActionParams } from './route/get-action-params.ts';import { container } from './injection/index.ts';import { send } from './static/send.ts';import { StaticFilesConfig } from './models/static-config.ts';import { ViewRenderConfig } from './models/view-render-config.ts';import { CorsBuilder } from './middlewares/cors-builder.ts';import { Content } from './renderer/content.ts';import { MetaRoute } from './models/meta-route.ts';
const global = {};
export function getMetadataArgsStorage(): MetadataArgsStorage {  if (!(global as any).routingControllersMetadataArgsStorage)    (global as any).routingControllersMetadataArgsStorage = new MetadataArgsStorage();
  return (global as any).routingControllersMetadataArgsStorage;}
export function getViewRenderConfig(): ViewRenderConfig {  return (global as any).viewRenderConfig;}export interface AppSettings {  areas: Function[];  middlewares?: Function[];}export class App {  private routes: MetaRoute[] = [];  private classes: any[] = [];  private metadata: MetadataArgsStorage;  private staticConfig: StaticFilesConfig;  private viewRenderConfig: ViewRenderConfig;
  constructor(settings: AppSettings) {    this.metadata = getMetadataArgsStorage();    this.registerAreas(this.metadata);    this.registerControllers(this.metadata.controllers);  }
  async listen(address: string = '0.0.0.0:8000') {    const s = serve(address);    console.log(`Server start in ${address}`);    for await (const req of s) {      try {      const res: Response = {};      res.headers = new Headers();      if (await this.getStaticFile(req, res)) {        await req.respond(res);      } else {        // Get middlewares in request        const middlewares = this.metadata.middlewares.filter(m =>          m.route.test(req.url)        );
        // Resolve every pre middleware        for (const middleware of middlewares) {          await middleware.target.onPreRequest(req, res);        }
        const action = getAction(this.routes, req.method, req.url);
        if (action === null) {          req.respond(notFoundAction());        } else {          // Get arguments in this action          const args = await getActionParams(req, res, action);
          // Get Action result          const result = await action.target[action.actionName](...args);
          // Resolve every post middleware          for (const middleware of middlewares) {            await middleware.target.onPostRequest(req, result);          }
          req.respond(result);        }      }      } catch (error) {          req.respond(Content(error, error.httpCode || 500));      }    }  }
  public useStatic(config: StaticFilesConfig) {    this.staticConfig = config;  }  public useViewRender(config: ViewRenderConfig) {    this.viewRenderConfig = config;    (global as any).viewRenderConfig = config;  }  public useCors(builder: CorsBuilder) {    this.metadata.middlewares.push({      type: 'middleware',      target: builder,      route: /\//    });  }
  private addRoute(route: MetaRoute) {    this.routes.push(route);  }
  // Add area to controllers  private registerAreas(metadata: MetadataArgsStorage) {    metadata.controllers.map(c => {      if (c.area == null) {        const area: any = metadata.areas.find(area => {          return !!area.controllers.find(            areaController => areaController === c.target          );        });        c.area = area;      }      return c;    });  }
  private registerControllers(controllers: any[] = []) {    // TODO: add two route Map (with route params / exact match)    // example: new Map(); key = route, value = object
    controllers.forEach(controller => {      const actions = getMetadataArgsStorage().actions.filter(        action => action.target === controller.target      );      const params = getMetadataArgsStorage().params.filter(        param => param.target === controller.target      );
      // TODO: if obj not in classes      // resolve from DI      const obj = container.resolve(controller.target);      this.classes.push(obj);
      console.log(        `register Controller: `,        controller.target.name || controller.target.constructor.name      );      let areaRoute = ``;      if (controller.area.baseRoute) {        areaRoute = controller.area.baseRoute;      }      actions.forEach(action => {        const metaRoute: MetaRoute = {          route: `${areaRoute}${controller.route}${action.route}`,          target: obj,          action: action.method,          method: action.type,          params: params.filter(param => param.method === action.method)        };        console.log(`register route: `, metaRoute.route);        this.addRoute(metaRoute);      });    });  }  private async getStaticFile(req, res) {    if (this.staticConfig == null) {      return false;    }    let url = req.url;    if (this.staticConfig.baseRoute) {      const regexUrl = new RegExp(`^${this.staticConfig.baseRoute}`);      if (regexUrl.test(req.url)) {        url = req.url.replace(regexUrl, '/');      } else {        return false;      }    }    const pathname = new URL(url, '/').pathname;    try {      const filePath = await send(        { request: req, response: res },        pathname,        this.staticConfig      );      return filePath ? true : false;    } catch (error) {      // TODO: exception      if (this.staticConfig.baseRoute) {        console.warn(error);      }      return null;    }  }}