@nestjs/cqrs - npm Package Compare versions

Comparing version 7.0.0-next.2 to 7.0.0-next.3

dist/command-bus.d.ts

 import { Type } from '@nestjs/common';
 import { ModuleRef } from '@nestjs/core';
 import 'reflect-metadata';
-import { ICommand, ICommandBus, ICommandHandler } from './interfaces/index';
+import { ICommand, ICommandBus, ICommandHandler, ICommandPublisher } from './interfaces/index';
 import { ObservableBus } from './utils/observable-bus';
@@ -10,3 +10,6 @@ export declare type CommandHandlerType = Type<ICommandHandler<ICommand>>;
     private handlers;
+    private _publisher;
     constructor(moduleRef: ModuleRef);
+    get publisher(): ICommandPublisher<CommandBase>;
+    set publisher(_publisher: ICommandPublisher<CommandBase>);
     execute<T extends CommandBase>(command: T): Promise<any>;
@@ -18,2 +21,3 @@ bind<T extends CommandBase>(handler: ICommandHandler<T>, name: string): void;
     private reflectCommandName;
+    private useDefaultPublisher;
 }

dist/command-bus.js

@@ -18,2 +18,3 @@ "use strict";
 const command_not_found_exception_1 = require("./exceptions/command-not-found.exception");
+const default_command_pubsub_1 = require("./helpers/default-command-pubsub");
 const index_1 = require("./index");
@@ -27,3 +28,10 @@ const observable_bus_1 = require("./utils/observable-bus");
             this.handlers = new Map();
+            this.useDefaultPublisher();
         }
+        get publisher() {
+            return this._publisher;
+        }
+        set publisher(_publisher) {
+            this._publisher = _publisher;
+        }
         execute(command) {
@@ -62,2 +70,5 @@ const commandName = this.getCommandName(command);
         }
+        useDefaultPublisher() {
+            this._publisher = new default_command_pubsub_1.DefaultCommandPubSub(this.subject$);
+        }
     };
@@ -64,0 +75,0 @@ CommandBus = __decorate([

dist/interfaces/commands/command-handler.interface.d.ts

 import { ICommand } from './command.interface';
-export interface ICommandHandler<T extends ICommand = any> {
-    execute(command: T): Promise<any>;
+export interface ICommandHandler<TCommand extends ICommand = any, TResult = any> {
+    execute(command: TCommand): Promise<TResult>;
 }

dist/interfaces/index.d.ts

 export * from './commands/command-bus.interface';
 export * from './commands/command-handler.interface';
+export * from './commands/command-publisher.interface';
 export * from './commands/command.interface';
@@ -11,4 +12,5 @@ export * from './events/event-bus.interface';
 export * from './queries/query-handler.interface';
+export * from './queries/query-publisher.interface';
 export * from './queries/query-result.interface';
 export * from './queries/query.interface';
 export * from './saga.type';

dist/interfaces/index.js

@@ -15,2 +15,3 @@ "use strict";
 __exportStar(require("./commands/command-handler.interface"), exports);
+__exportStar(require("./commands/command-publisher.interface"), exports);
 __exportStar(require("./commands/command.interface"), exports);
@@ -24,4 +25,5 @@ __exportStar(require("./events/event-bus.interface"), exports);
 __exportStar(require("./queries/query-handler.interface"), exports);
+__exportStar(require("./queries/query-publisher.interface"), exports);
 __exportStar(require("./queries/query-result.interface"), exports);
 __exportStar(require("./queries/query.interface"), exports);
 __exportStar(require("./saga.type"), exports);

dist/query-bus.d.ts

 import { Type } from '@nestjs/common';
 import { ModuleRef } from '@nestjs/core';
 import 'reflect-metadata';
-import { IQuery, IQueryBus, IQueryHandler, IQueryResult } from './interfaces';
+import { IQuery, IQueryBus, IQueryHandler, IQueryPublisher, IQueryResult } from './interfaces';
 import { ObservableBus } from './utils/observable-bus';
-export declare type QueryHandlerType = Type<IQueryHandler<IQuery, IQueryResult>>;
+export declare type QueryHandlerType<QueryBase extends IQuery = IQuery, QueryResultBase extends IQueryResult = IQueryResult> = Type<IQueryHandler<QueryBase, QueryResultBase>>;
 export declare class QueryBus<QueryBase extends IQuery = IQuery> extends ObservableBus<QueryBase> implements IQueryBus<QueryBase> {
     private readonly moduleRef;
     private handlers;
+    private _publisher;
     constructor(moduleRef: ModuleRef);
-    execute<T extends QueryBase, TResult extends IQueryResult>(query: T): Promise<TResult>;
-    bind<T extends QueryBase, TResult>(handler: IQueryHandler<T, TResult>, name: string): void;
-    register(handlers?: QueryHandlerType[]): void;
-    protected registerHandler(handler: QueryHandlerType): void;
+    get publisher(): IQueryPublisher<QueryBase>;
+    set publisher(_publisher: IQueryPublisher<QueryBase>);
+    execute<T extends QueryBase, TResult = any>(query: T): Promise<TResult>;
+    bind<T extends QueryBase, TResult = any>(handler: IQueryHandler<T, TResult>, name: string): void;
+    register(handlers?: QueryHandlerType<QueryBase>[]): void;
+    protected registerHandler(handler: QueryHandlerType<QueryBase>): void;
     private getQueryName;
     private reflectQueryName;
+    private useDefaultPublisher;
 }

dist/query-bus.js

@@ -28,2 +28,3 @@ "use strict";
 const invalid_query_handler_exception_1 = require("./exceptions/invalid-query-handler.exception");
+const default_query_pubsub_1 = require("./helpers/default-query-pubsub");
 const observable_bus_1 = require("./utils/observable-bus");
@@ -36,3 +37,10 @@ let QueryBus = (() => {
             this.handlers = new Map();
+            this.useDefaultPublisher();
         }
+        get publisher() {
+            return this._publisher;
+        }
+        set publisher(_publisher) {
+            this._publisher = _publisher;
+        }
         execute(query) {
@@ -74,2 +82,5 @@ return __awaiter(this, void 0, void 0, function* () {
         }
+        useDefaultPublisher() {
+            this._publisher = new default_query_pubsub_1.DefaultQueryPubSub(this.subject$);
+        }
     };
@@ -76,0 +87,0 @@ QueryBus = __decorate([

package.json

 {
   "name": "@nestjs/cqrs",
-  "version": "7.0.0-next.2",
+  "version": "7.0.0-next.3",
   "description": "A lightweight CQRS module for Nest framework (node.js)",
@@ -25,8 +25,8 @@ "license": "MIT",
     "@types/node": "11.15.2",
-    "@types/jest": "25.2.1",
-    "@typescript-eslint/eslint-plugin": "2.23.0",
-    "@typescript-eslint/parser": "2.23.0",
-    "eslint": "6.8.0",
-    "eslint-config-prettier": "6.10.0",
-    "eslint-plugin-import": "2.20.1",
+    "@types/jest": "25.2.2",
+    "@typescript-eslint/eslint-plugin": "2.33.0",
+    "@typescript-eslint/parser": "2.33.0",
+    "eslint": "7.0.0",
+    "eslint-config-prettier": "6.11.0",
+    "eslint-plugin-import": "2.20.2",
     "husky": "4.2.5",
@@ -37,3 +37,3 @@ "jest": "26.0.1",
     "reflect-metadata": "0.1.13",
-    "release-it": "13.1.1",
+    "release-it": "13.5.8",
     "rxjs": "6.5.5",
@@ -40,0 +40,0 @@ "ts-jest": "25.5.1",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

71454

increased by5.04%

Number of package files

118

increased by7.27%

Lines of code

1192

increased by7.58%

No dependency changes