chore(@nestjs) publish v5.3.9 release

bugfix: multiple HttpModule collision

CONTRIBUTING.md

@@ -186,7 +186,7 @@ Samples: (even more [samples](https://github.com/nestjs/nest/commits/master))
 docs(changelog) update change log to beta.5
 ```
 ```
-bugfix(@nestjs/core) need to depend on latest rxjs and zone.js
+bugfix(core) need to depend on latest rxjs and zone.js
 
 The version in our package.json gets copied to the one we publish, and users need the latest of these.
 ```

Readme.md

@@ -58,7 +58,8 @@ Nest is an MIT-licensed open source project. It can grow thanks to the sponsors
 
 #### Sponsors
 
-<a href="https://scal.io"><img src="https://nestjs.com/img/scalio-logo.svg" width="110" /></a> &nbsp; <a href="http://angularity.io"><img src="http://angularity.io/media/logo.svg" height="30" /></a> &nbsp; <a href="http://gojob.com"><img src="https://gojob.com/w/wp-content/uploads/2017/02/cropped-Logo-web-home.png" height="40" /> &nbsp; <!--<a href="https://keycdn.com"><img src="https://nestjs.com/img/keycdn.svg" height="30" /></a> &nbsp;--> <a href="https://hostpresto.com"><img src="https://nestjs.com/img/hostpresto.png" height="30" /></a>
+<a href="https://scal.io"><img src="https://nestjs.com/img/scalio-logo.svg" width="110" /></a> &nbsp; <a href="http://angularity.io"><img src="http://angularity.io/media/logo.svg" height="30" /></a> &nbsp; <a href="http://gojob.com"><img src="https://gojob.com/w/wp-content/uploads/2017/02/cropped-Logo-web-home.png" height="40" /> &nbsp; <!--<a href="https://keycdn.com"><img src="https://nestjs.com/img/keycdn.svg" height="30" /></a> &nbsp;--> <a href="https://hostpresto.com"><img src="https://nestjs.com/img/hostpresto.png" height="30" /></a> &nbsp; <a href="https://genuinebee.com/"><img src="https://nestjs.com/img/genuinebee.svg" height="34" /></a>
+
 
 ## Backers
 

benchmarks/all_output.txt

@@ -0,0 +1,48 @@
+-----------------------
+express
+-----------------------
+Running 10s test @ http://localhost:3000
+  8 threads and 1024 connections
+  Thread Stats   Avg      Stdev     Max   +/- Stdev
+    Latency    47.78ms   19.09ms 212.47ms   66.94%
+    Req/Sec     1.31k   268.90     2.07k    72.38%
+  104687 requests in 10.02s, 21.47MB read
+  Socket errors: connect 0, read 877, write 0, timeout 0
+Requests/sec:  10444.24
+Transfer/sec:      2.14MB
+-----------------------
+fastify
+-----------------------
+Running 10s test @ http://localhost:3000
+  8 threads and 1024 connections
+  Thread Stats   Avg      Stdev     Max   +/- Stdev
+    Latency    21.80ms    8.73ms  78.12ms   55.78%
+    Req/Sec     2.99k     0.92k    5.67k    68.88%
+  238550 requests in 10.02s, 31.17MB read
+  Socket errors: connect 0, read 862, write 0, timeout 0
+Requests/sec:  23795.79
+Transfer/sec:      3.11MB
+-----------------------
+nest
+-----------------------
+Running 10s test @ http://localhost:3000
+  8 threads and 1024 connections
+  Thread Stats   Avg      Stdev     Max   +/- Stdev
+    Latency    54.00ms   22.33ms 200.25ms   62.23%
+    Req/Sec     1.15k   338.60     1.88k    66.12%
+  91348 requests in 10.05s, 18.82MB read
+  Socket errors: connect 0, read 983, write 0, timeout 0
+Requests/sec:   9093.64
+Transfer/sec:      1.87MB
+-----------------------
+nest-fastify
+-----------------------
+Running 10s test @ http://localhost:3000
+  8 threads and 1024 connections
+  Thread Stats   Avg      Stdev     Max   +/- Stdev
+    Latency    29.31ms   11.71ms 101.96ms   70.03%
+    Req/Sec     2.17k     0.93k    4.12k    63.13%
+  173241 requests in 10.05s, 22.80MB read
+  Socket errors: connect 0, read 934, write 0, timeout 0
+Requests/sec:  17233.87
+Transfer/sec:      2.27MB

benchmarks/express.js

@@ -0,0 +1,7 @@
+'use strict';
+
+const express = require('express');
+const app = express();
+
+app.get('/', async (req, res) => res.send('Hello world'));
+app.listen(3000);

benchmarks/fastify.js

@@ -0,0 +1,5 @@
+'use strict';
+
+const fastify = require('fastify')();
+fastify.get('/', async (req, reply) => reply.send('Hello world'));
+fastify.listen(3000);

benchmarks/nest-fastify.js

@@ -0,0 +1,9 @@
+'use strict';
+Object.defineProperty(exports, '__esModule', { value: true });
+const core_1 = require('@nestjs/core');
+const app_module_1 = require('./nest/app.module');
+core_1.NestFactory.create(app_module_1.AppModule, new core_1.FastifyAdapter(), {
+  logger: false,
+  bodyParser: false,
+}).then(app => app.listen(3000));
+//# sourceMappingURL=main.js.map

benchmarks/nest.js

@@ -0,0 +1,9 @@
+'use strict';
+Object.defineProperty(exports, '__esModule', { value: true });
+const core_1 = require('@nestjs/core');
+const app_module_1 = require('./nest/app.module');
+core_1.NestFactory.create(app_module_1.AppModule, {
+  logger: false,
+  bodyParser: false,
+}).then(app => app.listen(3000));
+//# sourceMappingURL=main.js.map

benchmarks/nest/app.controller.d.ts

@@ -0,0 +1,3 @@
+export declare class AppController {
+  root(): string;
+}

benchmarks/nest/app.controller.js

@@ -0,0 +1,28 @@
+"use strict";
+var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
+    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
+    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
+    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
+    return c > 3 && r && Object.defineProperty(target, key, r), r;
+};
+var __metadata = (this && this.__metadata) || function (k, v) {
+    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const common_1 = require("@nestjs/common");
+let AppController = class AppController {
+    root() {
+        return 'Hello world!';
+    }
+};
+__decorate([
+    common_1.Get(),
+    __metadata("design:type", Function),
+    __metadata("design:paramtypes", []),
+    __metadata("design:returntype", String)
+], AppController.prototype, "root", null);
+AppController = __decorate([
+    common_1.Controller()
+], AppController);
+exports.AppController = AppController;
+//# sourceMappingURL=app.controller.js.map

benchmarks/nest/app.controller.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"app.controller.js","sourceRoot":"","sources":["../src/app.controller.ts"],"names":[],"mappings":";;;;;;;;;;;AAAA,2CAAiD;AAGjD,IAAa,aAAa,GAA1B,MAAa,aAAa;IAExB,IAAI;QACF,OAAO,cAAc,CAAA;IACvB,CAAC;CACF,CAAA;AAHC;IADC,YAAG,EAAE;;;;yCAGL;AAJU,aAAa;IADzB,mBAAU,EAAE;GACA,aAAa,CAKzB;AALY,sCAAa"}

benchmarks/nest/app.module.d.ts

@@ -0,0 +1 @@
+export declare class AppModule {}

benchmarks/nest/app.module.js

@@ -0,0 +1,20 @@
+"use strict";
+var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
+    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
+    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
+    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
+    return c > 3 && r && Object.defineProperty(target, key, r), r;
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const common_1 = require("@nestjs/common");
+const app_controller_1 = require("./app.controller");
+let AppModule = class AppModule {
+};
+AppModule = __decorate([
+    common_1.Module({
+        imports: [],
+        controllers: [app_controller_1.AppController],
+    })
+], AppModule);
+exports.AppModule = AppModule;
+//# sourceMappingURL=app.module.js.map

benchmarks/nest/app.module.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"app.module.js","sourceRoot":"","sources":["../src/app.module.ts"],"names":[],"mappings":";;;;;;;;AAAA,2CAAwC;AACxC,qDAAiD;AAMjD,IAAa,SAAS,GAAtB,MAAa,SAAS;CAAG,CAAA;AAAZ,SAAS;IAJrB,eAAM,CAAC;QACN,OAAO,EAAE,EAAE;QACX,WAAW,EAAE,CAAC,8BAAa,CAAC;KAC7B,CAAC;GACW,SAAS,CAAG;AAAZ,8BAAS"}

benchmarks/nest/main.d.ts

@@ -0,0 +1 @@
+export {};

benchmarks/nest/main.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"main.js","sourceRoot":"","sources":["../src/main.ts"],"names":[],"mappings":";;AAAA,uCAA2C;AAC3C,6CAAyC;AAEzC,KAAK,UAAU,SAAS;IACtB,MAAM,GAAG,GAAG,MAAM,kBAAW,CAAC,MAAM,CAAC,sBAAS,CAAC,CAAC;IAChD,MAAM,GAAG,CAAC,MAAM,CAAC,IAAI,CAAC,CAAC;AACzB,CAAC;AACD,SAAS,EAAE,CAAC"}

benchmarks/run.sh

@@ -0,0 +1,14 @@
+#!/usr/bin/env bash
+
+echo 'Library:' $1
+node $1 &
+pid=$!
+
+sleep 2
+
+wrk 'http://localhost:3000' \
+  -d 10 \
+  -c 1024 \
+  -t 8 
+
+kill $pid

benchmarks/run_all.sh

@@ -0,0 +1,23 @@
+#!/usr/bin/env bash
+
+: > all_output.txt
+
+lib=(express fastify nest nest-fastify)
+for item in ${lib[*]}
+do
+  echo '-----------------------' >> all_output.txt
+  echo $item >> all_output.txt
+  echo '-----------------------' >> all_output.txt
+
+  node $item &
+  pid=$!
+
+  sleep 2
+  
+  wrk 'http://localhost:3000' \
+    -d 10 \
+    -c 1024 \
+    -t 8 >> all_output.txt
+
+    kill $pid
+done

bundle/common/Readme.md

@@ -58,7 +58,8 @@ Nest is an MIT-licensed open source project. It can grow thanks to the sponsors
 
 #### Sponsors
 
-<a href="https://scal.io"><img src="https://nestjs.com/img/scalio-logo.svg" width="110" /></a> &nbsp; <a href="http://angularity.io"><img src="http://angularity.io/media/logo.svg" height="30" /></a> &nbsp; <a href="http://gojob.com"><img src="https://gojob.com/w/wp-content/uploads/2017/02/cropped-Logo-web-home.png" height="40" /> &nbsp; <!--<a href="https://keycdn.com"><img src="https://nestjs.com/img/keycdn.svg" height="30" /></a> &nbsp;--> <a href="https://hostpresto.com"><img src="https://nestjs.com/img/hostpresto.png" height="30" /></a>
+<a href="https://scal.io"><img src="https://nestjs.com/img/scalio-logo.svg" width="110" /></a> &nbsp; <a href="http://angularity.io"><img src="http://angularity.io/media/logo.svg" height="30" /></a> &nbsp; <a href="http://gojob.com"><img src="https://gojob.com/w/wp-content/uploads/2017/02/cropped-Logo-web-home.png" height="40" /> &nbsp; <!--<a href="https://keycdn.com"><img src="https://nestjs.com/img/keycdn.svg" height="30" /></a> &nbsp;--> <a href="https://hostpresto.com"><img src="https://nestjs.com/img/hostpresto.png" height="30" /></a> &nbsp; <a href="https://genuinebee.com/"><img src="https://nestjs.com/img/genuinebee.svg" height="34" /></a>
+
 
 ## Backers
 

bundle/common/cache/cache.constants.d.ts

@@ -0,0 +1,3 @@
+export declare const CACHE_MANAGER = "CACHE_MANAGER";
+export declare const CACHE_MODULE_OPTIONS = "CACHE_MODULE_OPTIONS";
+export declare const CACHE_KEY_METADATA = "cache_module:cache_key";

bundle/common/cache/cache.constants.js

@@ -0,0 +1,5 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.CACHE_MANAGER = 'CACHE_MANAGER';
+exports.CACHE_MODULE_OPTIONS = 'CACHE_MODULE_OPTIONS';
+exports.CACHE_KEY_METADATA = 'cache_module:cache_key';

bundle/common/cache/cache.module.d.ts

@@ -0,0 +1,8 @@
+import { DynamicModule } from '../interfaces';
+import { CacheModuleAsyncOptions, CacheModuleOptions } from './interfaces/cache-module.interface';
+export declare class CacheModule {
+    static register(options?: CacheModuleOptions): DynamicModule;
+    static registerAsync(options: CacheModuleAsyncOptions): DynamicModule;
+    private static createAsyncProviders(options);
+    private static createAsyncOptionsProvider(options);
+}

bundle/common/cache/cache.module.js

@@ -0,0 +1,60 @@
+"use strict";
+var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
+    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
+    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
+    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
+    return c > 3 && r && Object.defineProperty(target, key, r), r;
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const decorators_1 = require("../decorators");
+const cache_constants_1 = require("./cache.constants");
+const cache_providers_1 = require("./cache.providers");
+let CacheModule = CacheModule_1 = class CacheModule {
+    static register(options = {}) {
+        return {
+            module: CacheModule_1,
+            providers: [{ provide: cache_constants_1.CACHE_MODULE_OPTIONS, useValue: options }],
+        };
+    }
+    static registerAsync(options) {
+        return {
+            module: CacheModule_1,
+            imports: options.imports,
+            providers: this.createAsyncProviders(options),
+        };
+    }
+    static createAsyncProviders(options) {
+        if (options.useExisting || options.useFactory) {
+            return [this.createAsyncOptionsProvider(options)];
+        }
+        return [
+            this.createAsyncOptionsProvider(options),
+            {
+                provide: options.useClass,
+                useClass: options.useClass,
+            },
+        ];
+    }
+    static createAsyncOptionsProvider(options) {
+        if (options.useFactory) {
+            return {
+                provide: cache_constants_1.CACHE_MODULE_OPTIONS,
+                useFactory: options.useFactory,
+                inject: options.inject || [],
+            };
+        }
+        return {
+            provide: cache_constants_1.CACHE_MODULE_OPTIONS,
+            useFactory: async (optionsFactory) => await optionsFactory.createCacheOptions(),
+            inject: [options.useExisting || options.useClass],
+        };
+    }
+};
+CacheModule = CacheModule_1 = __decorate([
+    decorators_1.Module({
+        providers: [cache_providers_1.createCacheManager()],
+        exports: [cache_constants_1.CACHE_MANAGER],
+    })
+], CacheModule);
+exports.CacheModule = CacheModule;
+var CacheModule_1;

bundle/common/cache/cache.providers.d.ts

@@ -0,0 +1,2 @@
+import { Provider } from '../interfaces';
+export declare function createCacheManager(): Provider;

bundle/common/cache/cache.providers.js

@@ -0,0 +1,17 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const load_package_util_1 = require("../utils/load-package.util");
+const cache_constants_1 = require("./cache.constants");
+const default_options_1 = require("./default-options");
+function createCacheManager() {
+    return {
+        provide: cache_constants_1.CACHE_MANAGER,
+        useFactory: (options) => {
+            const cacheManager = load_package_util_1.loadPackage('cache-manager', 'CacheModule');
+            const memoryCache = cacheManager.caching(Object.assign({}, default_options_1.defaultCacheOptions, (options || {})));
+            return memoryCache;
+        },
+        inject: [cache_constants_1.CACHE_MODULE_OPTIONS],
+    };
+}
+exports.createCacheManager = createCacheManager;

bundle/common/cache/decorators/cache-key.decorator.d.ts

@@ -0,0 +1 @@
+export declare const CacheKey: (key: string) => (target: object, key?: any, descriptor?: any) => any;

bundle/common/cache/decorators/cache-key.decorator.js

@@ -0,0 +1,5 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const decorators_1 = require("../../decorators");
+const cache_constants_1 = require("../cache.constants");
+exports.CacheKey = (key) => decorators_1.ReflectMetadata(cache_constants_1.CACHE_KEY_METADATA, key);

bundle/common/cache/decorators/index.d.ts

@@ -0,0 +1 @@
+export * from './cache-key.decorator';

bundle/common/cache/decorators/index.js

@@ -0,0 +1,6 @@
+"use strict";
+function __export(m) {
+    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
+}
+Object.defineProperty(exports, "__esModule", { value: true });
+__export(require("./cache-key.decorator"));

bundle/common/cache/default-options.d.ts

@@ -0,0 +1,5 @@
+export declare const defaultCacheOptions: {
+    ttl: number;
+    max: number;
+    store: string;
+};

bundle/common/cache/default-options.js

@@ -0,0 +1,7 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.defaultCacheOptions = {
+    ttl: 5,
+    max: 100,
+    store: 'memory',
+};

bundle/common/cache/index.d.ts

@@ -0,0 +1,5 @@
+export { CACHE_MANAGER } from './cache.constants';
+export * from './cache.module';
+export * from './decorators';
+export * from './interceptors';
+export * from './interfaces';

bundle/common/cache/index.js

@@ -0,0 +1,10 @@
+"use strict";
+function __export(m) {
+    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
+}
+Object.defineProperty(exports, "__esModule", { value: true });
+var cache_constants_1 = require("./cache.constants");
+exports.CACHE_MANAGER = cache_constants_1.CACHE_MANAGER;
+__export(require("./cache.module"));
+__export(require("./decorators"));
+__export(require("./interceptors"));

bundle/common/cache/interceptors/cache.interceptor.d.ts

@@ -0,0 +1,11 @@
+import { Observable } from 'rxjs';
+import { ExecutionContext, HttpServer, NestInterceptor } from '../../interfaces';
+export declare class CacheInterceptor implements NestInterceptor {
+    protected readonly httpServer: HttpServer;
+    protected readonly cacheManager: any;
+    protected readonly reflector: any;
+    protected readonly isHttpApp: boolean;
+    constructor(httpServer: HttpServer, cacheManager: any, reflector: any);
+    intercept(context: ExecutionContext, call$: Observable<any>): Promise<Observable<any>>;
+    trackBy(context: ExecutionContext): string | undefined;
+}

bundle/common/cache/interceptors/cache.interceptor.js

@@ -0,0 +1,66 @@
+"use strict";
+var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
+    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
+    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
+    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
+    return c > 3 && r && Object.defineProperty(target, key, r), r;
+};
+var __metadata = (this && this.__metadata) || function (k, v) {
+    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
+};
+var __param = (this && this.__param) || function (paramIndex, decorator) {
+    return function (target, key) { decorator(target, key, paramIndex); }
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const rxjs_1 = require("rxjs");
+const operators_1 = require("rxjs/operators");
+const decorators_1 = require("../../decorators");
+const cache_constants_1 = require("../cache.constants");
+// NOTE (external)
+// We need to deduplicate them here due to the circular dependency
+// between core and common packages
+const HTTP_SERVER_REF = 'HTTP_SERVER_REF';
+const REFLECTOR = 'Reflector';
+let CacheInterceptor = class CacheInterceptor {
+    constructor(httpServer, cacheManager, reflector) {
+        this.httpServer = httpServer;
+        this.cacheManager = cacheManager;
+        this.reflector = reflector;
+        this.isHttpApp = httpServer && !!httpServer.getRequestMethod;
+    }
+    async intercept(context, call$) {
+        const key = this.trackBy(context);
+        if (!key) {
+            return call$;
+        }
+        try {
+            const value = await this.cacheManager.get(key);
+            if (value) {
+                return rxjs_1.of(value);
+            }
+            return call$.pipe(operators_1.tap(response => this.cacheManager.set(key, response)));
+        }
+        catch (_a) {
+            return call$;
+        }
+    }
+    trackBy(context) {
+        if (!this.isHttpApp) {
+            return this.reflector.get(cache_constants_1.CACHE_KEY_METADATA, context.getHandler());
+        }
+        const request = context.getArgByIndex(0);
+        if (this.httpServer.getRequestMethod(request) !== 'GET') {
+            return undefined;
+        }
+        return this.httpServer.getRequestUrl(request);
+    }
+};
+CacheInterceptor = __decorate([
+    decorators_1.Injectable(),
+    __param(0, decorators_1.Optional()),
+    __param(0, decorators_1.Inject(HTTP_SERVER_REF)),
+    __param(1, decorators_1.Inject(cache_constants_1.CACHE_MANAGER)),
+    __param(2, decorators_1.Inject(REFLECTOR)),
+    __metadata("design:paramtypes", [Object, Object, Object])
+], CacheInterceptor);
+exports.CacheInterceptor = CacheInterceptor;

bundle/common/cache/interceptors/index.d.ts

@@ -0,0 +1 @@
+export * from './cache.interceptor';

bundle/common/cache/interceptors/index.js

@@ -0,0 +1,6 @@
+"use strict";
+function __export(m) {
+    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
+}
+Object.defineProperty(exports, "__esModule", { value: true });
+__export(require("./cache.interceptor"));

bundle/common/cache/interfaces/cache-manager.interface.d.ts

@@ -0,0 +1,17 @@
+export interface LiteralObject {
+    [key: string]: any;
+}
+export interface CacheStore {
+    set<T>(key: string, value: T): Promise<void> | void;
+    get<T>(key: string): Promise<void> | void;
+    del(key: string): void | Promise<void>;
+}
+export interface CacheStoreFactory {
+    create(args: LiteralObject): CacheStore;
+}
+export interface CacheManagerOptions {
+    store?: string | CacheStoreFactory;
+    ttl?: number;
+    max?: number;
+    isCacheableValue?: (value: any) => boolean;
+}

bundle/common/cache/interfaces/cache-manager.interface.js

@@ -0,0 +1,2 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });

bundle/common/cache/interfaces/cache-module.interface.d.ts

@@ -0,0 +1,14 @@
+import { ModuleMetadata, Type } from '../../interfaces';
+import { CacheManagerOptions } from './cache-manager.interface';
+export interface CacheModuleOptions extends CacheManagerOptions {
+    [key: string]: any;
+}
+export interface CacheOptionsFactory {
+    createCacheOptions(): Promise<CacheModuleOptions> | CacheModuleOptions;
+}
+export interface CacheModuleAsyncOptions extends Pick<ModuleMetadata, 'imports'> {
+    useExisting?: Type<CacheOptionsFactory>;
+    useClass?: Type<CacheOptionsFactory>;
+    useFactory?: (...args: any[]) => Promise<CacheModuleOptions> | CacheModuleOptions;
+    inject?: any[];
+}

bundle/common/cache/interfaces/cache-module.interface.js

@@ -0,0 +1,2 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });

bundle/common/cache/interfaces/index.d.ts

@@ -0,0 +1,2 @@
+export * from './cache-manager.interface';
+export * from './cache-module.interface';

bundle/common/cache/interfaces/index.js

@@ -0,0 +1,2 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });

bundle/common/constants.d.ts

@@ -1,4 +1,4 @@
-export declare const metadata: {
+export declare const METADATA: {
     MODULES: string;
     IMPORTS: string;
     COMPONENTS: string;

bundle/common/constants.js

@@ -1,6 +1,6 @@
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.metadata = {
+exports.METADATA = {
     MODULES: 'modules',
     IMPORTS: 'imports',
     COMPONENTS: 'components',

bundle/common/decorators/core/component.decorator.js

@@ -1,6 +1,7 @@
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 const deprecate = require("deprecate");
+const uuid = require("uuid/v4");
 /**
  * Defines the injectable class. This class can inject dependencies through constructor.
  * Those dependencies have to belong to the same module.
@@ -55,10 +56,9 @@ function Interceptor() {
     return (target) => { };
 }
 exports.Interceptor = Interceptor;
-let offset = Math.random() * 100;
 function mixin(mixinClass) {
     Object.defineProperty(mixinClass, 'name', {
-        value: JSON.stringify(offset++),
+        value: uuid(),
     });
     Injectable()(mixinClass);
     return mixinClass;

bundle/common/decorators/http/create-route-param-metadata.decorator.d.ts

@@ -6,7 +6,7 @@ export declare type ParamDecoratorEnhancer = ParameterDecorator;
  * Defines HTTP route param decorator
  * @param factory
  */
-export declare function createParamDecorator(factory: CustomParamFactory, enhancers?: ParamDecoratorEnhancer[]): (...dataOrPipes: (Type<PipeTransform> | PipeTransform | string)[]) => ParameterDecorator;
+export declare function createParamDecorator(factory: CustomParamFactory, enhancers?: ParamDecoratorEnhancer[]): (...dataOrPipes: (Type<PipeTransform> | PipeTransform | any)[]) => ParameterDecorator;
 /**
  * Defines HTTP route param decorator
  * @deprecated

bundle/common/decorators/http/create-route-param-metadata.decorator.js

@@ -1,6 +1,7 @@
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 const deprecate = require("deprecate");
+const uuid = require("uuid/v4");
 const constants_1 = require("../../constants");
 const shared_utils_1 = require("../../utils/shared.utils");
 const assignCustomMetadata = (args, paramtype, index, factory, data, ...pipes) => (Object.assign({}, args, { [`${paramtype}${constants_1.CUSTOM_ROUTE_AGRS_METADATA}:${index}`]: {
@@ -9,18 +10,17 @@ const assignCustomMetadata = (args, paramtype, index, factory, data, ...pipes) =
         data,
         pipes,
     } }));
-const randomString = () => Math.random()
-    .toString(36)
-    .substring(2, 15);
 /**
  * Defines HTTP route param decorator
  * @param factory
  */
 function createParamDecorator(factory, enhancers = []) {
-    const paramtype = randomString() + randomString();
+    const paramtype = uuid();
     return (data, ...pipes) => (target, key, index) => {
         const args = Reflect.getMetadata(constants_1.ROUTE_ARGS_METADATA, target.constructor, key) || {};
-        const hasParamData = shared_utils_1.isNil(data) || shared_utils_1.isString(data);
+        const isPipe = pipe => pipe &&
+            ((shared_utils_1.isFunction(pipe) && pipe.prototype) || shared_utils_1.isFunction(pipe.transform));
+        const hasParamData = shared_utils_1.isNil(data) || !isPipe(data);
         const paramData = hasParamData ? data : undefined;
         const paramPipes = hasParamData ? pipes : [data, ...pipes];
         Reflect.defineMetadata(constants_1.ROUTE_ARGS_METADATA, assignCustomMetadata(args, paramtype, index, factory, paramData, ...paramPipes), target.constructor, key);

bundle/common/decorators/modules/module.decorator.js

@@ -1,16 +1,16 @@
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-require("reflect-metadata");
 const deprecate = require("deprecate");
+require("reflect-metadata");
 const constants_1 = require("../../constants");
 const invalid_module_config_exception_1 = require("./exceptions/invalid-module-config.exception");
 const metadataKeys = [
-    constants_1.metadata.MODULES,
-    constants_1.metadata.IMPORTS,
-    constants_1.metadata.EXPORTS,
-    constants_1.metadata.COMPONENTS,
-    constants_1.metadata.CONTROLLERS,
-    constants_1.metadata.PROVIDERS,
+    constants_1.METADATA.MODULES,
+    constants_1.METADATA.IMPORTS,
+    constants_1.METADATA.EXPORTS,
+    constants_1.METADATA.COMPONENTS,
+    constants_1.METADATA.CONTROLLERS,
+    constants_1.METADATA.PROVIDERS,
 ];
 const validateKeys = (keys) => {
     const isKeyInvalid = key => metadataKeys.findIndex(k => k === key) < 0;
@@ -54,8 +54,8 @@ function overrideModuleMetadata(moduleMetadata) {
         : moduleMetadata.components;
 }
 function showDeprecatedWarnings(moduleMetadata) {
-    const modulesDeprecatedWarning = 'The "modules" key in the @Module() decorator is deprecated and will be removed within next major release. Use the "imports" key instead.';
-    const componentsDeprecatetWarning = 'The "components" key in the @Module() decorator is deprecated and will be removed within next major release. Use the "providers" key instead.';
-    moduleMetadata.modules && deprecate(modulesDeprecatedWarning);
-    moduleMetadata.components && deprecate(componentsDeprecatetWarning);
+    const MODULES_DEPRECATED_WARNING = 'The "modules" key in the @Module() decorator is deprecated and will be removed within next major release. Use the "imports" key instead.';
+    const COMPONENTS_DEPRECATED_WARNING = 'The "components" key in the @Module() decorator is deprecated and will be removed within next major release. Use the "providers" key instead.';
+    moduleMetadata.modules && deprecate(MODULES_DEPRECATED_WARNING);
+    moduleMetadata.components && deprecate(COMPONENTS_DEPRECATED_WARNING);
 }

bundle/common/exceptions/bad-gateway.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class BadGatewayException extends http_exception_1.HttpException {
     constructor(message, error = 'Bad Gateway') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.BAD_GATEWAY), http_status_enum_1.HttpStatus.BAD_GATEWAY);

bundle/common/exceptions/bad-request.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class BadRequestException extends http_exception_1.HttpException {
     constructor(message, error = 'Bad Request') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.BAD_REQUEST), http_status_enum_1.HttpStatus.BAD_REQUEST);

bundle/common/exceptions/conflict.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class ConflictException extends http_exception_1.HttpException {
     constructor(message, error = 'Conflict') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.CONFLICT), http_status_enum_1.HttpStatus.CONFLICT);

bundle/common/exceptions/forbidden.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class ForbiddenException extends http_exception_1.HttpException {
     constructor(message, error = 'Forbidden') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.FORBIDDEN), http_status_enum_1.HttpStatus.FORBIDDEN);

bundle/common/exceptions/gateway-timeout.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class GatewayTimeoutException extends http_exception_1.HttpException {
     constructor(message, error = 'Gateway Timeout') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.GATEWAY_TIMEOUT), http_status_enum_1.HttpStatus.GATEWAY_TIMEOUT);

bundle/common/exceptions/gone.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class GoneException extends http_exception_1.HttpException {
     constructor(message, error = 'Gone') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.GONE), http_status_enum_1.HttpStatus.GONE);

bundle/common/exceptions/im-a-teapot.exception.d.ts

@@ -0,0 +1,10 @@
+import { HttpException } from './http.exception';
+/**
+ * Any attempt to brew coffee with a teapot should result in the error code "418 I'm a teapot".
+ * The resulting entity body MAY be short and stout.
+ *
+ * http://save418.com/
+ */
+export declare class ImATeapotException extends HttpException {
+    constructor(message?: string | object | any, error?: string);
+}

bundle/common/exceptions/im-a-teapot.exception.js

@@ -0,0 +1,17 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const http_exception_1 = require("./http.exception");
+const http_status_enum_1 = require("../enums/http-status.enum");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
+/**
+ * Any attempt to brew coffee with a teapot should result in the error code "418 I'm a teapot".
+ * The resulting entity body MAY be short and stout.
+ *
+ * http://save418.com/
+ */
+class ImATeapotException extends http_exception_1.HttpException {
+    constructor(message, error = 'I\'m a teapot') {
+        super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.I_AM_A_TEAPOT), http_status_enum_1.HttpStatus.I_AM_A_TEAPOT);
+    }
+}
+exports.ImATeapotException = ImATeapotException;

bundle/common/exceptions/index.d.ts

@@ -16,3 +16,4 @@ export * from './not-implemented.exception';
 export * from './bad-gateway.exception';
 export * from './service-unavailable.exception';
 export * from './gateway-timeout.exception';
+export * from './im-a-teapot.exception';

bundle/common/exceptions/index.js

@@ -21,3 +21,4 @@ __export(require("./not-implemented.exception"));
 __export(require("./bad-gateway.exception"));
 __export(require("./service-unavailable.exception"));
 __export(require("./gateway-timeout.exception"));
+__export(require("./im-a-teapot.exception"));

bundle/common/exceptions/internal-server-error.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class InternalServerErrorException extends http_exception_1.HttpException {
     constructor(message, error = 'Internal Server Error') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.INTERNAL_SERVER_ERROR), http_status_enum_1.HttpStatus.INTERNAL_SERVER_ERROR);

bundle/common/exceptions/method-not-allowed.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class MethodNotAllowedException extends http_exception_1.HttpException {
     constructor(message, error = 'Method Not Allowed') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.METHOD_NOT_ALLOWED), http_status_enum_1.HttpStatus.METHOD_NOT_ALLOWED);

bundle/common/exceptions/not-acceptable.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class NotAcceptableException extends http_exception_1.HttpException {
     constructor(message, error = 'Not Acceptable') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.NOT_ACCEPTABLE), http_status_enum_1.HttpStatus.NOT_ACCEPTABLE);

bundle/common/exceptions/not-found.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class NotFoundException extends http_exception_1.HttpException {
     constructor(message, error = 'Not Found') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.NOT_FOUND), http_status_enum_1.HttpStatus.NOT_FOUND);

bundle/common/exceptions/not-implemented.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class NotImplementedException extends http_exception_1.HttpException {
     constructor(message, error = 'Not Implemented') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.NOT_IMPLEMENTED), http_status_enum_1.HttpStatus.NOT_IMPLEMENTED);

bundle/common/exceptions/payload-too-large.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class PayloadTooLargeException extends http_exception_1.HttpException {
     constructor(message, error = 'Payload Too Large') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.PAYLOAD_TOO_LARGE), http_status_enum_1.HttpStatus.PAYLOAD_TOO_LARGE);

bundle/common/exceptions/request-timeout.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class RequestTimeoutException extends http_exception_1.HttpException {
     constructor(message, error = 'Request Timeout') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.REQUEST_TIMEOUT), http_status_enum_1.HttpStatus.REQUEST_TIMEOUT);

bundle/common/exceptions/service-unavailable.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class ServiceUnavailableException extends http_exception_1.HttpException {
     constructor(message, error = 'Service Unavailable') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.SERVICE_UNAVAILABLE), http_status_enum_1.HttpStatus.SERVICE_UNAVAILABLE);

bundle/common/exceptions/unauthorized.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class UnauthorizedException extends http_exception_1.HttpException {
     constructor(message, error = 'Unauthorized') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.UNAUTHORIZED), http_status_enum_1.HttpStatus.UNAUTHORIZED);

bundle/common/exceptions/unprocessable-entity.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class UnprocessableEntityException extends http_exception_1.HttpException {
     constructor(message, error = 'Unprocessable Entity') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.UNPROCESSABLE_ENTITY), http_status_enum_1.HttpStatus.UNPROCESSABLE_ENTITY);

bundle/common/exceptions/unsupported-media-type.exception.js

@@ -2,7 +2,7 @@
 Object.defineProperty(exports, "__esModule", { value: true });
 const http_exception_1 = require("./http.exception");
 const http_status_enum_1 = require("../enums/http-status.enum");
-const http_exception_body_util_1 = require("./../utils/http-exception-body.util");
+const http_exception_body_util_1 = require("../utils/http-exception-body.util");
 class UnsupportedMediaTypeException extends http_exception_1.HttpException {
     constructor(message, error = 'Unsupported Media Type') {
         super(http_exception_body_util_1.createHttpExceptionBody(message, error, http_status_enum_1.HttpStatus.UNSUPPORTED_MEDIA_TYPE), http_status_enum_1.HttpStatus.UNSUPPORTED_MEDIA_TYPE);

bundle/common/files/files.constants.d.ts

@@ -0,0 +1 @@
+export declare const MULTER_MODULE_OPTIONS = "MULTER_MODULE_OPTIONS";

bundle/common/files/files.constants.js

@@ -0,0 +1,3 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.MULTER_MODULE_OPTIONS = 'MULTER_MODULE_OPTIONS';

bundle/common/files/index.d.ts

@@ -0,0 +1,3 @@
+export * from './interceptors';
+export * from './interfaces';
+export * from './multer.module';

bundle/common/files/index.js

@@ -0,0 +1,7 @@
+"use strict";
+function __export(m) {
+    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
+}
+Object.defineProperty(exports, "__esModule", { value: true });
+__export(require("./interceptors"));
+__export(require("./multer.module"));

bundle/common/files/interceptors/file-fields.interceptor.d.ts

@@ -0,0 +1,2 @@
+import { MulterField, MulterOptions } from '../../interfaces/external/multer-options.interface';
+export declare function FileFieldsInterceptor(uploadFields: MulterField[], localOptions?: MulterOptions): any;

bundle/common/files/interceptors/file-fields.interceptor.js

@@ -0,0 +1,45 @@
+"use strict";
+var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
+    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
+    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
+    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
+    return c > 3 && r && Object.defineProperty(target, key, r), r;
+};
+var __metadata = (this && this.__metadata) || function (k, v) {
+    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
+};
+var __param = (this && this.__param) || function (paramIndex, decorator) {
+    return function (target, key) { decorator(target, key, paramIndex); }
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const multer = require("multer");
+const decorators_1 = require("../../decorators");
+const component_decorator_1 = require("../../decorators/core/component.decorator");
+const files_constants_1 = require("../files.constants");
+const multer_utils_1 = require("../multer/multer.utils");
+function FileFieldsInterceptor(uploadFields, localOptions) {
+    let MixinInterceptor = class MixinInterceptor {
+        constructor(options = {}) {
+            this.upload = multer(Object.assign({}, options, localOptions));
+        }
+        async intercept(context, call$) {
+            const ctx = context.switchToHttp();
+            await new Promise((resolve, reject) => this.upload.fields(uploadFields)(ctx.getRequest(), ctx.getResponse(), err => {
+                if (err) {
+                    const error = multer_utils_1.transformException(err);
+                    return reject(error);
+                }
+                resolve();
+            }));
+            return call$;
+        }
+    };
+    MixinInterceptor = __decorate([
+        __param(0, decorators_1.Optional()),
+        __param(0, decorators_1.Inject(files_constants_1.MULTER_MODULE_OPTIONS)),
+        __metadata("design:paramtypes", [Object])
+    ], MixinInterceptor);
+    const Interceptor = component_decorator_1.mixin(MixinInterceptor);
+    return Interceptor;
+}
+exports.FileFieldsInterceptor = FileFieldsInterceptor;

bundle/common/files/interceptors/file.interceptor.d.ts

@@ -0,0 +1,2 @@
+import { MulterOptions } from '../../interfaces/external/multer-options.interface';
+export declare function FileInterceptor(fieldName: string, localOptions?: MulterOptions): any;

bundle/common/files/interceptors/file.interceptor.js

@@ -0,0 +1,45 @@
+"use strict";
+var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
+    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
+    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
+    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
+    return c > 3 && r && Object.defineProperty(target, key, r), r;
+};
+var __metadata = (this && this.__metadata) || function (k, v) {
+    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
+};
+var __param = (this && this.__param) || function (paramIndex, decorator) {
+    return function (target, key) { decorator(target, key, paramIndex); }
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const multer = require("multer");
+const decorators_1 = require("../../decorators");
+const component_decorator_1 = require("../../decorators/core/component.decorator");
+const files_constants_1 = require("../files.constants");
+const multer_utils_1 = require("../multer/multer.utils");
+function FileInterceptor(fieldName, localOptions) {
+    let MixinInterceptor = class MixinInterceptor {
+        constructor(options = {}) {
+            this.upload = multer(Object.assign({}, options, localOptions));
+        }
+        async intercept(context, call$) {
+            const ctx = context.switchToHttp();
+            await new Promise((resolve, reject) => this.upload.single(fieldName)(ctx.getRequest(), ctx.getResponse(), err => {
+                if (err) {
+                    const error = multer_utils_1.transformException(err);
+                    return reject(error);
+                }
+                resolve();
+            }));
+            return call$;
+        }
+    };
+    MixinInterceptor = __decorate([
+        __param(0, decorators_1.Optional()),
+        __param(0, decorators_1.Inject(files_constants_1.MULTER_MODULE_OPTIONS)),
+        __metadata("design:paramtypes", [Object])
+    ], MixinInterceptor);
+    const Interceptor = component_decorator_1.mixin(MixinInterceptor);
+    return Interceptor;
+}
+exports.FileInterceptor = FileInterceptor;

bundle/common/files/interceptors/files.interceptor.d.ts

@@ -0,0 +1,2 @@
+import { MulterOptions } from '../../interfaces/external/multer-options.interface';
+export declare function FilesInterceptor(fieldName: string, maxCount?: number, localOptions?: MulterOptions): any;

bundle/common/files/interceptors/files.interceptor.js

@@ -0,0 +1,45 @@
+"use strict";
+var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
+    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
+    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
+    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
+    return c > 3 && r && Object.defineProperty(target, key, r), r;
+};
+var __metadata = (this && this.__metadata) || function (k, v) {
+    if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v);
+};
+var __param = (this && this.__param) || function (paramIndex, decorator) {
+    return function (target, key) { decorator(target, key, paramIndex); }
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const multer = require("multer");
+const decorators_1 = require("../../decorators");
+const component_decorator_1 = require("../../decorators/core/component.decorator");
+const files_constants_1 = require("../files.constants");
+const multer_utils_1 = require("../multer/multer.utils");
+function FilesInterceptor(fieldName, maxCount, localOptions) {
+    let MixinInterceptor = class MixinInterceptor {
+        constructor(options = {}) {
+            this.upload = multer(Object.assign({}, options, localOptions));
+        }
+        async intercept(context, call$) {
+            const ctx = context.switchToHttp();
+            await new Promise((resolve, reject) => this.upload.array(fieldName, maxCount)(ctx.getRequest(), ctx.getResponse(), err => {
+                if (err) {
+                    const error = multer_utils_1.transformException(err);
+                    return reject(error);
+                }
+                resolve();
+            }));
+            return call$;
+        }
+    };
+    MixinInterceptor = __decorate([
+        __param(0, decorators_1.Optional()),
+        __param(0, decorators_1.Inject(files_constants_1.MULTER_MODULE_OPTIONS)),
+        __metadata("design:paramtypes", [Object])
+    ], MixinInterceptor);
+    const Interceptor = component_decorator_1.mixin(MixinInterceptor);
+    return Interceptor;
+}
+exports.FilesInterceptor = FilesInterceptor;

bundle/common/files/interceptors/index.js

@@ -0,0 +1,8 @@
+"use strict";
+function __export(m) {
+    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
+}
+Object.defineProperty(exports, "__esModule", { value: true });
+__export(require("./file-fields.interceptor"));
+__export(require("./file.interceptor"));
+__export(require("./files.interceptor"));

bundle/common/files/interfaces/files-upload-module.interface.d.ts

@@ -0,0 +1,13 @@
+import { ModuleMetadata, Type } from '@nestjs/common/interfaces';
+import { MulterOptions } from '../../interfaces/external/multer-options.interface';
+export interface MulterModuleOptions extends MulterOptions {
+}
+export interface MulterOptionsFactory {
+    createMulterOptions(): Promise<MulterModuleOptions> | MulterModuleOptions;
+}
+export interface MulterModuleAsyncOptions extends Pick<ModuleMetadata, 'imports'> {
+    useExisting?: Type<MulterOptionsFactory>;
+    useClass?: Type<MulterOptionsFactory>;
+    useFactory?: (...args: any[]) => Promise<MulterModuleOptions> | MulterModuleOptions;
+    inject?: any[];
+}

bundle/common/files/interfaces/files-upload-module.interface.js

@@ -0,0 +1,2 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });

bundle/common/files/interfaces/index.d.ts

@@ -0,0 +1 @@
+export * from './files-upload-module.interface';

bundle/common/files/interfaces/index.js

@@ -0,0 +1,2 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });

bundle/common/files/multer.module.d.ts

@@ -0,0 +1,8 @@
+import { DynamicModule } from '@nestjs/common';
+import { MulterModuleAsyncOptions, MulterModuleOptions } from './interfaces/files-upload-module.interface';
+export declare class MulterModule {
+    static register(options?: MulterModuleOptions): DynamicModule;
+    static registerAsync(options: MulterModuleAsyncOptions): DynamicModule;
+    private static createAsyncProviders(options);
+    private static createAsyncOptionsProvider(options);
+}

bundle/common/files/multer.module.js

@@ -0,0 +1,58 @@
+"use strict";
+var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
+    var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d;
+    if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc);
+    else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r;
+    return c > 3 && r && Object.defineProperty(target, key, r), r;
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const common_1 = require("@nestjs/common");
+const files_constants_1 = require("./files.constants");
+let MulterModule = MulterModule_1 = class MulterModule {
+    static register(options = {}) {
+        return {
+            module: MulterModule_1,
+            providers: [{ provide: files_constants_1.MULTER_MODULE_OPTIONS, useValue: options }],
+            exports: [files_constants_1.MULTER_MODULE_OPTIONS],
+        };
+    }
+    static registerAsync(options) {
+        return {
+            module: MulterModule_1,
+            imports: options.imports,
+            providers: this.createAsyncProviders(options),
+            exports: [files_constants_1.MULTER_MODULE_OPTIONS],
+        };
+    }
+    static createAsyncProviders(options) {
+        if (options.useExisting || options.useFactory) {
+            return [this.createAsyncOptionsProvider(options)];
+        }
+        return [
+            this.createAsyncOptionsProvider(options),
+            {
+                provide: options.useClass,
+                useClass: options.useClass,
+            },
+        ];
+    }
+    static createAsyncOptionsProvider(options) {
+        if (options.useFactory) {
+            return {
+                provide: files_constants_1.MULTER_MODULE_OPTIONS,
+                useFactory: options.useFactory,
+                inject: options.inject || [],
+            };
+        }
+        return {
+            provide: files_constants_1.MULTER_MODULE_OPTIONS,
+            useFactory: async (optionsFactory) => await optionsFactory.createMulterOptions(),
+            inject: [options.useExisting || options.useClass],
+        };
+    }
+};
+MulterModule = MulterModule_1 = __decorate([
+    common_1.Module({})
+], MulterModule);
+exports.MulterModule = MulterModule;
+var MulterModule_1;

bundle/common/files/multer/multer.constants.d.ts

@@ -0,0 +1,9 @@
+export declare const multerExceptions: {
+    LIMIT_PART_COUNT: string;
+    LIMIT_FILE_SIZE: string;
+    LIMIT_FILE_COUNT: string;
+    LIMIT_FIELD_KEY: string;
+    LIMIT_FIELD_VALUE: string;
+    LIMIT_FIELD_COUNT: string;
+    LIMIT_UNEXPECTED_FILE: string;
+};

bundle/common/files/multer/multer.constants.js

@@ -0,0 +1,11 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.multerExceptions = {
+    LIMIT_PART_COUNT: 'Too many parts',
+    LIMIT_FILE_SIZE: 'File too large',
+    LIMIT_FILE_COUNT: 'Too many files',
+    LIMIT_FIELD_KEY: 'Field name too long',
+    LIMIT_FIELD_VALUE: 'Field value too long',
+    LIMIT_FIELD_COUNT: 'Too many fields',
+    LIMIT_UNEXPECTED_FILE: 'Unexpected field',
+};

bundle/common/files/multer/multer.utils.d.ts

@@ -0,0 +1,2 @@
+import { BadRequestException, PayloadTooLargeException } from '../../exceptions';
+export declare function transformException(error: Error | undefined): Error | BadRequestException | PayloadTooLargeException;

bundle/common/files/multer/multer.utils.js

@@ -0,0 +1,22 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const exceptions_1 = require("../../exceptions");
+const multer_constants_1 = require("./multer.constants");
+function transformException(error) {
+    if (!error || error instanceof exceptions_1.HttpException) {
+        return error;
+    }
+    switch (error.message) {
+        case multer_constants_1.multerExceptions.LIMIT_FILE_SIZE:
+            return new exceptions_1.PayloadTooLargeException(error.message);
+        case multer_constants_1.multerExceptions.LIMIT_FILE_COUNT:
+        case multer_constants_1.multerExceptions.LIMIT_FIELD_KEY:
+        case multer_constants_1.multerExceptions.LIMIT_FIELD_VALUE:
+        case multer_constants_1.multerExceptions.LIMIT_FIELD_COUNT:
+        case multer_constants_1.multerExceptions.LIMIT_UNEXPECTED_FILE:
+        case multer_constants_1.multerExceptions.LIMIT_PART_COUNT:
+            return new exceptions_1.BadRequestException(error.message);
+    }
+    return error;
+}
+exports.transformException = transformException;

bundle/common/http/http.constants.d.ts

@@ -1 +1,2 @@
 export declare const AXIOS_INSTANCE_TOKEN = "AXIOS_INSTANCE_TOKEN";
+export declare const HTTP_MODULE_ID = "HTTP_MODULE_ID";

bundle/common/http/http.constants.js

@@ -1,3 +1,4 @@
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.AXIOS_INSTANCE_TOKEN = 'AXIOS_INSTANCE_TOKEN';
+exports.HTTP_MODULE_ID = 'HTTP_MODULE_ID';

bundle/common/http/http.module.js

@@ -8,25 +8,35 @@ var __decorate = (this && this.__decorate) || function (decorators, target, key,
 Object.defineProperty(exports, "__esModule", { value: true });
 const axios_1 = require("axios");
 const module_decorator_1 = require("../decorators/modules/module.decorator");
+const random_string_generator_util_1 = require("../utils/random-string-generator.util");
 const http_constants_1 = require("./http.constants");
 const http_service_1 = require("./http.service");
 let HttpModule = HttpModule_1 = class HttpModule {
     static register(config) {
         return {
             module: HttpModule_1,
-            providers: [{
+            providers: [
+                {
                     provide: http_constants_1.AXIOS_INSTANCE_TOKEN,
                     useValue: axios_1.default.create(config),
-                }],
+                },
+                {
+                    provide: http_constants_1.HTTP_MODULE_ID,
+                    useValue: random_string_generator_util_1.randomStringGenerator(),
+                },
+            ],
         };
     }
 };
 HttpModule = HttpModule_1 = __decorate([
     module_decorator_1.Module({
-        providers: [http_service_1.HttpService, {
+        providers: [
+            http_service_1.HttpService,
+            {
                 provide: http_constants_1.AXIOS_INSTANCE_TOKEN,
                 useValue: axios_1.default,
-            }],
+            },
+        ],
         exports: [http_service_1.HttpService],
     })
 ], HttpModule);

bundle/common/index.d.ts

@@ -1,9 +1,11 @@
+export * from './cache';
 export * from './decorators';
 export * from './enums';
 export * from './exceptions';
+export * from './files';
 export * from './http';
-export * from './interceptors';
-export { ArgumentMetadata, ArgumentsHost, CanActivate, DynamicModule, ExceptionFilter, ExecutionContext, ForwardReference, HttpServer, HttpServerFactory, INestApplication, INestApplicationContext, INestExpressApplication, INestFastifyApplication, INestMicroservice, MiddlewareConsumer, MiddlewareFunction, NestInterceptor, NestMiddleware, NestModule, OnModuleDestroy, OnModuleInit, Paramtype, PipeTransform, Provider, RpcExceptionFilter, Type, WebSocketAdapter, WsExceptionFilter } from './interfaces';
+export { ArgumentMetadata, ArgumentsHost, CanActivate, DynamicModule, ExceptionFilter, ExecutionContext, ForwardReference, HttpServer, HttpServerFactory, INestApplication, INestApplicationContext, INestExpressApplication, INestFastifyApplication, INestMicroservice, MiddlewareConsumer, MiddlewareFunction, NestInterceptor, NestMiddleware, NestModule, OnApplicationBootstrap, OnModuleDestroy, OnModuleInit, Paramtype, PipeTransform, Provider, RpcExceptionFilter, Type, WebSocketAdapter, WsExceptionFilter } from './interfaces';
 export * from './pipes';
+export * from './serializer';
 export * from './services/logger.service';
 export * from './utils';

bundle/common/index.js

@@ -9,11 +9,13 @@ function __export(m) {
     for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
 }
 Object.defineProperty(exports, "__esModule", { value: true });
+__export(require("./cache"));
 __export(require("./decorators"));
 __export(require("./enums"));
 __export(require("./exceptions"));
+__export(require("./files"));
 __export(require("./http"));
-__export(require("./interceptors"));
 __export(require("./pipes"));
+__export(require("./serializer"));
 __export(require("./services/logger.service"));
 __export(require("./utils"));

bundle/common/interfaces/exceptions/exception-filter.interface.d.ts

@@ -1,4 +1,4 @@
-import { ArgumentsHost } from './../features/arguments-host.interface';
+import { ArgumentsHost } from '../features/arguments-host.interface';
 export interface ExceptionFilter<T = any> {
     catch(exception: T, host: ArgumentsHost): any;
 }

bundle/common/interfaces/exceptions/rpc-exception-filter.interface.d.ts

@@ -1,5 +1,5 @@
 import { Observable } from 'rxjs';
-import { ArgumentsHost } from './../features/arguments-host.interface';
+import { ArgumentsHost } from '../features/arguments-host.interface';
 export interface RpcExceptionFilter<T = any, R = any> {
     catch(exception: T, host: ArgumentsHost): Observable<R>;
 }

bundle/common/interfaces/exceptions/ws-exception-filter.interface.d.ts

@@ -1,4 +1,4 @@
-import { ArgumentsHost } from './../features/arguments-host.interface';
+import { ArgumentsHost } from '../features/arguments-host.interface';
 export interface WsExceptionFilter<T = any> {
     catch(exception: T, host: ArgumentsHost): any;
 }

bundle/common/interfaces/external/class-transform-options.interface.d.ts

@@ -0,0 +1,41 @@
+/**
+ * Options to be passed during transformation.
+ * @see https://github.com/typestack/class-transformer
+ */
+export interface ClassTransformOptions {
+    /**
+     * Exclusion strategy. By default exposeAll is used, which means that it will expose all properties are transformed
+     * by default.
+     */
+    strategy?: 'excludeAll' | 'exposeAll';
+    /**
+     * Only properties with given groups gonna be transformed.
+     */
+    groups?: string[];
+    /**
+     * Only properties with "since" > version < "until" gonna be transformed.
+     */
+    version?: number;
+    /**
+     * Excludes properties with the given prefixes. For example, if you mark your private properties with "_" and "__"
+     * you can set this option's value to ["_", "__"] and all private properties will be skipped.
+     * This works only for "exposeAll" strategy.
+     */
+    excludePrefixes?: string[];
+    /**
+     * If set to true then class transformer will ignore all @Expose and @Exclude decorators and what inside them.
+     * This option is useful if you want to kinda clone your object but do not apply decorators affects.
+     */
+    ignoreDecorators?: boolean;
+    /**
+     * Target maps allows to set a Types of the transforming object without using @Type decorator.
+     * This is useful when you are transforming external classes, or if you already have type metadata for
+     * objects and you don't want to set it up again.
+     */
+    targetMaps?: any[];
+    /**
+     * If set to true then class transformer will perform a circular check. (circular check is turned off by default)
+     * This option is useful when you know for sure that your types might have a circular dependency.
+     */
+    enableCircularCheck?: boolean;
+}