Feat/http server

.gitignore

@@ -28,6 +28,9 @@ storage/**/*.log
 packages/**/*.d.ts
 packages/**/*.js
 
+!packages/hyper-express/**/*.js
+!packages/hyper-express/**/*.d.ts
+
 #yarn
 .pnp.*
 .yarn/*

.husky/pre-commit

@@ -1 +0,0 @@
-npm run build

integrations/sample-app/app/boot/sp/app.ts

@@ -1,9 +1,6 @@
 /* eslint-disable @typescript-eslint/no-unused-vars */
-import {
-  IntentApplication,
-  IntentApplicationContext,
-  ServiceProvider,
-} from '@intentjs/core';
+import { IntentApplicationContext, ServiceProvider } from '@intentjs/core';
+import { IntentController } from 'app/http/controllers/icon';
 import { QueueJobs } from 'app/jobs/job';
 import { UserDbRepository } from 'app/repositories/userDbRepository';
 import { UserService } from 'app/services';
@@ -35,5 +32,5 @@ export class AppServiceProvider extends ServiceProvider {
   /**
    * Bootstrap any application service here.
    */
-  boot(app: IntentApplication | IntentApplicationContext) {}
+  boot(app: IntentApplicationContext) {}
 }

integrations/sample-app/app/boot/sp/console.ts

@@ -1,8 +1,4 @@
-import {
-  IntentApplication,
-  IntentApplicationContext,
-  ServiceProvider,
-} from '@intentjs/core';
+import { IntentApplicationContext, ServiceProvider } from '@intentjs/core';
 import { TestCacheConsoleCommand } from 'app/console/cache';
 import { GreetingCommand } from 'app/console/greeting';
 import { TestLogConsoleCommand } from 'app/console/log';
@@ -27,5 +23,5 @@ export class ConsoleServiceProvider extends ServiceProvider {
    *
    */
   // eslint-disable-next-line @typescript-eslint/no-unused-vars
-  boot(app: IntentApplication | IntentApplicationContext) {}
+  boot(app: IntentApplicationContext) {}
 }

integrations/sample-app/app/errors/filter.ts

@@ -1,16 +1,16 @@
 import {
-  Catch,
+  ConfigService,
+  ExecutionContext,
   HttpException,
-  HttpStatus,
   IntentExceptionFilter,
-  Request,
-  Response,
   Type,
-  ValidationFailed,
 } from '@intentjs/core';
 
-@Catch()
 export class ApplicationExceptionFilter extends IntentExceptionFilter {
+  constructor(private config: ConfigService) {
+    super();
+  }
+
   doNotReport(): Array<Type<HttpException>> {
     return [];
   }
@@ -19,19 +19,7 @@ export class ApplicationExceptionFilter extends IntentExceptionFilter {
     return '*';
   }
 
-  handleHttp(exception: any, req: Request, res: Response) {
-    if (exception instanceof ValidationFailed) {
-      return res
-        .status(422)
-        .json({ message: 'validation failed', errors: exception.getErrors() });
-    }
-
-    return res.status(this.getStatus(exception)).json(exception);
-  }
-
-  getStatus(exception: any): HttpStatus {
-    return exception instanceof HttpException
-      ? exception.getStatus()
-      : HttpStatus.INTERNAL_SERVER_ERROR;
+  handleHttp(context: ExecutionContext, exception: any) {
+    return super.handleHttp(context, exception);
   }
 }

integrations/sample-app/app/http/controllers/app.ts

@@ -1,4 +1,4 @@
-import { Controller, Get, Req, Request } from '@intentjs/core';
+import { Controller, Get, Req } from '@intentjs/core';
 import { UserService } from 'app/services';
 
 @Controller()
@@ -7,7 +7,11 @@ export class UserController {
 
   @Get()
   async getHello(@Req() req: Request) {
-    console.log(req.all());
-    return this.service.getHello();
+    return { hello: 'Intent' };
+  }
+
+  @Get('hello')
+  async getHello2(@Req() req: Request) {
+    return { hello: 'Intent' };
   }
 }

integrations/sample-app/app/http/controllers/icon.ts

@@ -0,0 +1,163 @@
+import {
+  Accepts,
+  BufferBody,
+  Controller,
+  Dto,
+  File,
+  findProjectRoot,
+  Get,
+  Header,
+  Host,
+  IP,
+  Param,
+  Post,
+  Query,
+  Req,
+  Res,
+  Response,
+  StreamableFile,
+  UseGuards,
+  UserAgent,
+  Validate,
+} from '@intentjs/core';
+import { CustomGuard } from '../guards/custom';
+import { Request, UploadedFile } from '@intentjs/hyper-express';
+import { createReadStream } from 'fs';
+import { join } from 'path';
+import { LoginDto } from 'app/validators/auth';
+
+@Controller('/icon')
+@UseGuards(CustomGuard)
+export class IntentController {
+  public service: any;
+
+  constructor() {
+    this.service = null;
+  }
+
+  @Get('/:name')
+  @UseGuards(CustomGuard)
+  async getHello(
+    // @Req() req: Request,
+    // @Param('name') name: string,
+    // @Query() query: Record<string, any>,
+    // @Query('b') bQuery: string,
+    // @Param() pathParams: string,
+    // @Host() hostname: string,
+    // @IP() ips: string,
+    // @Accepts() accepts: string,
+    // @BufferBody() bufferBody: Promise<Buffer>,
+    // @UserAgent() userAgent: string,
+    // @Header() headers: Record<string, any>,
+    @Res() res: Response,
+  ) {
+    // console.log(
+    //   'query ==> ',
+    //   query,
+    //   'bQuyery ==> ',
+    //   bQuery,
+    //   'name ===> ',
+    //   name,
+    //   bufferBody,
+    //   pathParams,
+    //   'hostname===> ',
+    //   hostname,
+    //   'accepts ===> ',
+    //   accepts,
+    //   'ips ===> ',
+    //   ips,
+    //   'inside get method',
+    //   'user agent ===> ',
+    //   userAgent,
+    // );
+    // console.log('all headers ===> ', headers);
+    // throw new Error('hello there');
+    // return { hello: 'world' };
+    // const readStream = createReadStream(
+    //   join(findProjectRoot(), 'storage/uploads/sample-image.jpg'),
+    // );
+    // return new StreamableFile(readStream, { type: 'image/jpeg' });
+  }
+
+  @Get('/plain-with-query-param')
+  @UseGuards(CustomGuard)
+  async plainWithQueryParam(@Req() req: Request) {
+    console.log(req);
+    return { hello: 'world' };
+  }
+
+  @Get('/:id')
+  @UseGuards(CustomGuard)
+  async plainWithPathParam(@Req() req: Request) {
+    console.log(req);
+    return { hello: 'world' };
+  }
+
+  @Post('/json')
+  @Validate(LoginDto)
+  async postJson(
+    @Req() req: Request,
+    @Dto() dto: LoginDto,
+    @Param('name') name: string,
+    @Query() query: Record<string, any>,
+    @Query('b') bQuery: string,
+    @Param() pathParams: string,
+    @Host() hostname: string,
+    @IP() ips: string,
+    @Accepts() accepts: string,
+    @BufferBody() bufferBody: Promise<Buffer>,
+    @UserAgent() userAgent: string,
+    @Header() headers: Record<string, any>,
+    @File('file') file: UploadedFile,
+    @Res() res: Response,
+  ) {
+    // console.log(
+    //   'query ==> ',
+    //   query,
+    //   'bQuyery ==> ',
+    //   bQuery,
+    //   'name ===> ',
+    //   name,
+    //   bufferBody,
+    //   pathParams,
+    //   'hostname===> ',
+    //   hostname,
+    //   'accepts ===> ',
+    //   accepts,
+    //   'ips ===> ',
+    //   ips,
+    //   'inside get method',
+    //   'user agent ===> ',
+    //   userAgent,
+    // );
+
+    // console.log('all headers ===> ', headers);
+    console.log('uploaded files ==> ', req.dto(), dto);
+
+    const readStream = createReadStream(
+      join(findProjectRoot(), 'storage/uploads/sample-image.jpg'),
+    );
+
+    return new StreamableFile(readStream, { type: 'image/jpeg' });
+
+    return { hello: 'world from POST /json' };
+  }
+
+  @Post('/multipart')
+  @UseGuards(CustomGuard)
+  async postHello(@Req() req: Request) {
+    return { hello: 'world' };
+  }
+
+  @Post('/form-data')
+  @UseGuards(CustomGuard)
+  async postFormData(@Req() req: Request) {
+    return { hello: 'world' };
+  }
+
+  @Post('/binary')
+  @UseGuards(CustomGuard)
+  async postBinary(@Req() req: Request) {
+    return { hello: 'world' };
+  }
+}

integrations/sample-app/app/http/decorators/custom-param.ts

@@ -0,0 +1,7 @@
+import { createParamDecorator, ExecutionContext } from '@intentjs/core';
+
+export const CustomParam = createParamDecorator(
+  (data: any, ctx: ExecutionContext, argIndex: number) => {
+    return 'data from custom decorator param';
+  },
+);

integrations/sample-app/app/http/guards/custom.ts

@@ -0,0 +1,8 @@
+import { ExecutionContext, Injectable, IntentGuard } from '@intentjs/core';
+
+@Injectable()
+export class CustomGuard extends IntentGuard {
+  async guard(ctx: ExecutionContext): Promise<boolean> {
+    return true;
+  }
+}

integrations/sample-app/app/http/guards/global.ts

@@ -0,0 +1,8 @@
+import { ExecutionContext, Injectable, IntentGuard } from '@intentjs/core';
+
+@Injectable()
+export class GlobalGuard extends IntentGuard {
+  async guard(ctx: ExecutionContext): Promise<boolean> {
+    return true;
+  }
+}