Bugfix/v0.1.22

.eslintrc.js

@@ -30,6 +30,7 @@ module.exports = {
   ],
   rules: {
     'no-console': 'error',
+    '@typescript-eslint/no-explicit-any': 'off',
     '@typescript-eslint/no-inferrable-types': 'error',
     '@typescript-eslint/interface-name-prefix': 'off',
     '@typescript-eslint/explicit-function-return-type': 'off',

lib/rest/decorators.ts

@@ -0,0 +1,15 @@
+import { ExecutionContext, createParamDecorator } from '@nestjs/common';
+
+export const Req = createParamDecorator(
+  (data: string, ctx: ExecutionContext) => {
+    const request = ctx.switchToHttp().getRequest();
+    return request.intent.req();
+  },
+);
+
+// export const Res = createParamDecorator(
+//   (data: string, ctx: ExecutionContext) => {
+//     const request = ctx.switchToHttp().getRequest();
+//     return request.intent.res();
+//   },
+// );

lib/rest/index.ts

@@ -2,6 +2,7 @@ export * from './restController';
 export * from './restServer';
 export * from './interceptors/timeout';
 export * from './interfaces';
-export * from './decoratorts';
+export * from './decorators';
+export { Res } from '@nestjs/common';
 export { Response } from 'express';
 export * from './request';

lib/rest/request.ts

@@ -16,15 +16,19 @@ export class Request {
   constructor(private request: ERequest) {
     this.$payload = {};
     this.$headers = {};
-    this.initiate();
+    this.initiate(request);
     this.id = ulid();
+    this.$query = request.query;
+    this.$body = request.body;
+    this.$pathParams = request.params;
+    this.$headers = request.headers;
   }
 
-  private initiate() {
-    this.$query = this.request.query;
-    this.$body = this.request.body;
-    this.$pathParams = this.request.params;
-    this.$headers = this.request.headers;
+  private initiate(request: ERequest) {
+    this.$query = request.query;
+    this.$body = request.body;
+    this.$pathParams = request.params;
+    this.$headers = request.headers;
     this.$payload = { ...this.$query, ...this.$pathParams, ...this.$body };
   }
 
@@ -151,22 +155,18 @@ export class Request {
   }
 
   only(...keys: string[]): Record<string, any> {
-    console.log(keys);
     return {};
   }
 
   except(...keys: string[]): Record<string, any> {
-    console.log(keys);
     return {};
   }
 
   is(pathPattern: string): boolean {
-    console.log(pathPattern);
     return false;
   }
 
   has(...keys: string[]): boolean {
-    console.log('kjeys ===> ', keys);
     for (const key of keys) {
       if (!(key in this.$payload)) return false;
     }

lib/rest/restServer.ts

@@ -13,7 +13,9 @@ export class RestServer {
    */
 
   static async make(module: any, options?: ServerOptions): Promise<void> {
-    const app = await NestFactory.create<NestExpressApplication>(module);
+    const app = await NestFactory.create<NestExpressApplication>(module, {
+      bodyParser: true,
+    });
 
     if (options?.addValidationContainer) {
       useContainer(app.select(module), { fallbackOnErrors: true });
@@ -25,6 +27,13 @@ export class RestServer {
       app.enable(corsRule);
     }
 
+    /**
+     * Explicitly enable body parsers, so that they are available in all of the middlewares.
+     */
+    app.useBodyParser('json');
+    app.useBodyParser('raw');
+    app.useBodyParser('urlencoded');
+
     app.use(requestMiddleware);
 
     this.configureErrorReporter(config.get('app.sentry'));
@@ -34,7 +43,9 @@ export class RestServer {
       app.useGlobalFilters(options.exceptionFilter(httpAdapter));
     }
 
-    options?.globalPrefix && app.setGlobalPrefix(options.globalPrefix);
+    if (options?.globalPrefix) {
+      app.setGlobalPrefix(options.globalPrefix);
+    }
 
     await app.listen(options?.port || config.get<number>('app.port'));
   }

lib/validator/validationGuard.ts

@@ -1,16 +1,17 @@
 import { CanActivate, ExecutionContext, Injectable } from '@nestjs/common';
 import { Reflector } from '@nestjs/core';
+import { Request as ERequest } from 'express';
 import { Request } from '../rest';
 
 @Injectable()
 export class IntentValidationGuard implements CanActivate {
   constructor(private reflector: Reflector) {}
 
   async canActivate(context: ExecutionContext): Promise<boolean> {
-    const request = context.switchToHttp().getRequest() as Request;
-    const iRequest = request['intent'].req();
+    const expressRequest = context.switchToHttp().getRequest() as ERequest;
+    const request = expressRequest['intent'].req() as Request;
     const schema = this.reflector.get('dtoSchema', context.getHandler());
-    iRequest.addDto(await iRequest.validate(schema));
+    request.addDto(await request.validate(schema));
     return true;
   }
 }