Move to esm

commitlint.config.js

@@ -4,6 +4,14 @@ const Configuration = {
    * Referenced packages must be installed
    */
   extends: ["@commitlint/config-conventional"],
+
+  // Add custom rules
+  rules: {
+    // Increase max line length (default is 100)
+    "body-max-line-length": [2, "always", 200],
+    // Increase header length (default is 100)
+    "header-max-length": [2, "always", 100],
+  },
 };
 
 module.exports = Configuration;

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

@@ -1,7 +1,7 @@
+import config from '#config/index';
 import { IntentAppContainer, IntentProvidersFactory } from '@intentjs/core';
-import { AppServiceProvider } from './sp/app';
-import { ConsoleServiceProvider } from './sp/console';
-import config from 'config';
+import { AppServiceProvider } from '#boot/sp/app';
+import { ConsoleServiceProvider } from '#boot/sp/console';
 
 export class ApplicationContainer extends IntentAppContainer {
   build() {

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

@@ -1,11 +1,10 @@
 /* eslint-disable @typescript-eslint/no-unused-vars */
 import { IntentApplicationContext, ServiceProvider } from '@intentjs/core';
-import { OrderPlacedListener } from 'app/events/listeners/sample-listener';
-import { IntentController } from 'app/http/controllers/icon';
-import { QueueJobs } from 'app/jobs/job';
-import { UserDbRepository } from 'app/repositories/userDbRepository';
-import { UserService } from 'app/services';
-import { AuthService } from 'app/services/auth';
+import { OrderPlacedListener } from '#events/listeners/sample-listener';
+import { QueueJobs } from '#jobs/job';
+import { UserDbRepository } from '#repositories/userDbRepository';
+import { UserService } from '#services/index';
+import { AuthService } from '#services/auth';
 
 export class AppServiceProvider extends ServiceProvider {
   /**

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

@@ -1,10 +1,11 @@
 import { IntentApplicationContext, ServiceProvider } from '@intentjs/core';
-import { TestCacheConsoleCommand } from 'app/console/cache';
-import { GreetingCommand } from 'app/console/greeting';
-import { TestLogConsoleCommand } from 'app/console/log';
-import { TestMailConsoleCommand } from 'app/console/mailer';
-import { TestQueueConsoleCommand } from 'app/console/queue';
-import { TestStorageConsoleCommand } from 'app/console/storage';
+import { TestCacheConsoleCommand } from '#console/cache';
+import { GreetingCommand } from '#console/greeting';
+import { TestLogConsoleCommand } from '#console/log';
+import { TestMailConsoleCommand } from '#console/mailer';
+import { TestQueueConsoleCommand } from '#console/queue';
+import { TestStorageConsoleCommand } from '#console/storage';
+import { Dispatch } from '@intentjs/core/queue';
 
 export class ConsoleServiceProvider extends ServiceProvider {
   /**
@@ -23,5 +24,13 @@ export class ConsoleServiceProvider extends ServiceProvider {
    *
    */
   // eslint-disable-next-line @typescript-eslint/no-unused-vars
-  boot(app: IntentApplicationContext) {}
+  boot(app: IntentApplicationContext) {
+    let i = 0;
+    setInterval(async () => {
+      await Dispatch({
+        job: 'redis_job',
+        data: { count: i++ },
+      });
+    }, 1000);
+  }
 }

integrations/sample-app/app/console/cache.ts

@@ -1,4 +1,5 @@
-import { Cache, Command, ConsoleIO } from '@intentjs/core';
+import { Cache } from '@intentjs/core/cache';
+import { Command, ConsoleIO } from '@intentjs/core/console';
 
 @Command('test:cache', { desc: 'Command to test the cache drivers' })
 export class TestCacheConsoleCommand {

integrations/sample-app/app/console/greeting.ts

@@ -1,4 +1,4 @@
-import { Command, ConsoleIO } from '@intentjs/core';
+import { Command, ConsoleIO } from '@intentjs/core/console';
 
 /**
  * Sample command, feel free to remove this file.

integrations/sample-app/app/console/log.ts

@@ -1,9 +1,11 @@
-import { Command, ConsoleIO, log } from '@intentjs/core';
+import { Command, ConsoleIO } from '@intentjs/core/console';
+import { disposeLogger, log } from '@intentjs/core/logger';
 
 @Command('test:log', { desc: 'Command to test the log' })
 export class TestLogConsoleCommand {
   async handle(_cli: ConsoleIO) {
     _cli.info('Testing the log');
     log('Hello world!!');
+    return true;
   }
 }

integrations/sample-app/app/console/mailer.ts

@@ -1,4 +1,6 @@
-import { Command, ConsoleIO, log, Mail, MailMessage } from '@intentjs/core';
+import { Command, ConsoleIO } from '@intentjs/core/console';
+import { Mail, MailMessage } from '@intentjs/core/mail';
+import { log } from '@intentjs/core/logger';
 
 @Command('test:mail', { desc: 'Command to test the log' })
 export class TestMailConsoleCommand {

integrations/sample-app/app/console/queue.ts

@@ -1,4 +1,5 @@
-import { Command, ConsoleIO, Dispatch } from '@intentjs/core';
+import { Command, ConsoleIO } from '@intentjs/core/console';
+import { Dispatch } from '@intentjs/core/queue';
 
 @Command('test:queue', { desc: 'Command to test the queue drivers' })
 export class TestQueueConsoleCommand {

integrations/sample-app/app/console/storage.ts

@@ -1,4 +1,5 @@
-import { Command, ConsoleIO, Storage } from '@intentjs/core';
+import { Command, ConsoleIO } from '@intentjs/core/console';
+import { Storage } from '@intentjs/core/storage';
 
 @Command('test:storage', { desc: 'Command to test the storage drivers' })
 export class TestStorageConsoleCommand {

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

@@ -1,12 +1,9 @@
-import {
-  ConfigService,
-  ExecutionContext,
-  HttpException,
-  IntentExceptionFilter,
-  Type,
-} from '@intentjs/core';
+import { Type } from '@intentjs/core';
+import { ConfigService } from '@intentjs/core/config';
+import { ExceptionHandler, HttpException } from '@intentjs/core/errors';
+import { ExecutionContext } from '@intentjs/core/http';
 
-export class ApplicationExceptionFilter extends IntentExceptionFilter {
+export class ApplicationExceptionHandler extends ExceptionHandler {
   constructor(private config: ConfigService) {
     super();
   }

integrations/sample-app/app/events/events/sample-event.ts

@@ -1,4 +1,4 @@
-import { EmitsEvent, Event } from '@intentjs/core';
+import { EmitsEvent, Event } from '@intentjs/core/events';
 
 @Event('order_placed')
 export class OrderPlacedEvent extends EmitsEvent {

integrations/sample-app/app/events/listeners/sample-listener.ts

@@ -1,4 +1,5 @@
-import { Injectable, ListensTo } from '@intentjs/core';
+import { Injectable } from '@intentjs/core';
+import { ListensTo } from '@intentjs/core/events';
 
 @Injectable()
 export class OrderPlacedListener {

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

@@ -1,14 +1,21 @@
-import { Controller, Get, Req } from '@intentjs/core';
-import { OrderPlacedEvent } from 'app/events/events/sample-event';
-import { UserService } from 'app/services';
+import { OrderPlacedEvent } from '#events/events/sample-event';
+import { UserService } from '#services/index';
+import {
+  Controller,
+  Get,
+  Req,
+  Request,
+  Res,
+  Response,
+} from '@intentjs/core/http';
 
-@Controller('blogs')
+@Controller('')
 export class UserController {
   constructor(private readonly service: UserService) {}
 
   @Get()
-  async getHello(@Req() req: Request) {
-    return { hello: 'Intent' };
+  async getHello(@Req() req: Request, @Res() res: Response) {
+    return res.json({ hello: 'Intent2' });
   }
 
   @Get('hello/')

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

@@ -1,20 +1,14 @@
-import {
-  Body,
-  Controller,
-  Get,
-  Post,
-  Transformable,
-  Validate,
-} from '@intentjs/core';
-import { AuthService } from 'app/services/auth';
-import { UserTransformer } from 'app/transformers/user';
+import { Body, Controller, Get, Post } from '@intentjs/core/http';
+import { AuthService } from '#services/auth';
+import { UserTransformer } from '#transformers/user';
 import {
   LoginDto,
   RegisterDto,
   RequestPasswordChangeOtpDto,
   VerifyEmailDto,
-} from 'app/validators/auth';
-
+} from '#validators/auth';
+import { Transformable } from '@intentjs/core';
+import { Validate } from '@intentjs/core/validator';
 @Controller('auth')
 export class AuthController extends Transformable {
   constructor(private auth: AuthService) {

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

@@ -1,10 +1,12 @@
+import { CustomGuard } from '#http/guards/custom';
+import { createReadStream } from 'fs';
+import { join } from 'path';
+import { LoginDto } from '#validators/auth';
 import {
   Accepts,
   BufferBody,
   Controller,
   Dto,
-  File,
-  findProjectRoot,
   Get,
   Header,
   Host,
@@ -14,17 +16,11 @@ import {
   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';
+} from '@intentjs/core/http';
+import { findProjectRoot } from '@intentjs/core';
 
 @Controller('/icon')
 @UseGuards(CustomGuard)
@@ -109,7 +105,7 @@ export class IntentController {
     @BufferBody() bufferBody: Promise<Buffer>,
     @UserAgent() userAgent: string,
     @Header() headers: Record<string, any>,
-    @File('file') file: UploadedFile,
+    // @File('file') file: UploadedFile,
     @Res() res: Response,
   ) {
     // console.log(

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

@@ -1,4 +1,5 @@
-import { createParamDecorator, ExecutionContext } from '@intentjs/core';
+import { ExecutionContext } from '@intentjs/core/http';
+import { createParamDecorator } from '@intentjs/core/http';
 
 export const CustomParam = createParamDecorator(
   (data: any, ctx: ExecutionContext, argIndex: number) => {

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

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

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

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

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

@@ -1,19 +1,19 @@
+import { UserController } from '#http/controllers/app';
+import { AuthController } from '#http/controllers/auth';
+import { SampleMiddleware } from '#http/middlewares/sample';
+import { IntentController } from '#http/controllers/icon';
+import { GlobalMiddleware } from '#http/middlewares/global';
+import { Server } from '@intentjs/hyper-express';
+import { GlobalGuard } from '#http/guards/global';
 import {
   CorsMiddleware,
+  HttpGuard,
   HttpMethods,
-  IntentGuard,
-  IntentMiddleware,
+  HttpMiddleware,
   Kernel,
   MiddlewareConfigurator,
-  Type,
-} from '@intentjs/core';
-import { UserController } from './controllers/app';
-import { AuthController } from './controllers/auth';
-import { SampleMiddleware } from './middlewares/sample';
-import { IntentController } from './controllers/icon';
-import { GlobalMiddleware } from './middlewares/global';
-import { Server } from '@intentjs/hyper-express';
-import { GlobalGuard } from './guards/global';
+} from '@intentjs/core/http';
+import { Type } from '@intentjs/core';
 
 export class HttpKernel extends Kernel {
   /**
@@ -31,7 +31,7 @@ export class HttpKernel extends Kernel {
    *
    * Read more - https://tryintent.com/docs/middlewares
    */
-  public middlewares(): Type<IntentMiddleware>[] {
+  public middlewares(): Type<HttpMiddleware>[] {
     return [GlobalMiddleware, CorsMiddleware];
   }
 
@@ -61,7 +61,7 @@ export class HttpKernel extends Kernel {
    *
    * Read more - https://tryintent.com/docs/guards
    */
-  public guards(): Type<IntentGuard>[] {
+  public guards(): Type<HttpGuard>[] {
     return [GlobalGuard];
   }
 

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

@@ -1,8 +1,10 @@
-import { ConfigService, Injectable, IntentMiddleware } from '@intentjs/core';
+import { ConfigService } from '@intentjs/core/config';
+import { Injectable } from '@intentjs/core';
+import { HttpMiddleware } from '@intentjs/core/http';
 import { MiddlewareNext, Request, Response } from '@intentjs/hyper-express';
 
 @Injectable()
-export class GlobalMiddleware extends IntentMiddleware {
+export class GlobalMiddleware extends HttpMiddleware {
   constructor(private readonly config: ConfigService) {
     super();
   }

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

@@ -1,7 +1,7 @@
-import { IntentMiddleware, MiddlewareNext } from '@intentjs/core';
 import { Request, Response } from '@intentjs/hyper-express';
+import { HttpMiddleware, MiddlewareNext } from '@intentjs/core/http';
 
-export class SampleMiddleware extends IntentMiddleware {
+export class SampleMiddleware extends HttpMiddleware {
   use(req: Request, res: Response, next: MiddlewareNext): void | Promise<void> {
     // console.log(req.isHttp(), req.httpHost(), req.all(), req.bearerToken());
     next();

integrations/sample-app/app/jobs/job.ts

@@ -1,10 +1,11 @@
-import { Injectable, Job } from '@intentjs/core';
+import { Injectable } from '@intentjs/core';
+import { Job } from '@intentjs/core/queue';
 
 @Injectable()
 export class QueueJobs {
   @Job('db_job')
   async handleDbJob(data: Record<string, any>) {
-    console.log(data);
+    console.log('db job ===> ', data);
   }
 
   @Job('redis_job', { connection: 'redis' })