Implement InMemoryQueryBus

Co-authored-by: Rubén Salado <rsaladocid@users.noreply.github.com>
Co-authored-by: aliondev <antonioleon@audiense.com>

Author: 3 people

src/Contexts/Shared/domain/QueryBus.ts

@@ -1,5 +1,6 @@
 import { Query } from './Query';
+import { Response } from './Response';
 
 export interface QueryBus {
-  ask<T>(query: Query): Promise<T>;
+  ask<R extends Response>(query: Query): Promise<R>;
 }

src/Contexts/Shared/domain/QueryHandler.ts

@@ -1,7 +1,7 @@
 import { Query } from './Query';
 import { Response } from './Response';
 
-export interface QueryHandler<T extends Query, R extends Response> {
+export interface QueryHandler<Q extends Query, R extends Response> {
   subscribedTo(): Query;
-  handle(query: T): Promise<R>;
+  handle(query: Q): Promise<R>;
 }

src/Contexts/Shared/infrastructure/QueryBus/InMemoryQueryBus.ts

@@ -0,0 +1,14 @@
+import { Query } from '../../domain/Query';
+import { Response } from '../../domain/Response';
+import { QueryBus } from './../../domain/QueryBus';
+import { QueryHandlersInformation } from './QueryHandlersInformation';
+
+export class InMemoryQueryBus implements QueryBus {
+  constructor(private queryHandlersInformation: QueryHandlersInformation) {}
+
+  async ask<R extends Response>(query: Query): Promise<R> {
+    const handler = this.queryHandlersInformation.search(query);
+
+    return handler.handle(query) as Promise<R>;
+  }
+}

tests/Contexts/Shared/infrastructure/QueryBus/InMemoryQueryBus.test.ts

@@ -3,6 +3,7 @@ import { QueryHandlersInformation } from '../../../../../src/Contexts/Shared/inf
 import { QueryNotRegisteredError } from '../../../../../src/Contexts/Shared/domain/QueryNotRegisteredError';
 import { QueryHandler } from '../../../../../src/Contexts/Shared/domain/QueryHandler';
 import { Response } from '../../../../../src/Contexts/Shared/domain/Response';
+import { InMemoryQueryBus } from '../../../../../src/Contexts/Shared/infrastructure/QueryBus/InMemoryQueryBus';
 
 class UnhandledQuery extends Query {
   static QUERY_NAME = 'unhandled.query';
@@ -35,7 +36,7 @@ describe('InMemoryQueryBus', () => {
     }
 
     expect(exception).toBeInstanceOf(QueryNotRegisteredError);
-    expect(exception.message).toBe(`The query <UnhandledCommand> hasn't a query handler associated`);
+    expect(exception.message).toBe(`The query <UnhandledQuery> hasn't a query handler associated`);
   });
 
   it('accepts a query with handler', async () => {