@node-ts/bus-core - npm Package Compare versions

Comparing version 0.1.18 to 0.2.0

dist/service-bus/service-bus.js

@@ -89,3 +89,2 @@ "use strict";
         const handlersToInvoke = handlers.map(h => h.resolveHandler(h.defaultContainer));
-        this.logger.debug('Dispatching message to handlers', { messageName: message.$name });
         await Promise.all(handlersToInvoke.map(async (h) => {
@@ -92,0 +91,0 @@ await h.handle(message);

dist/transport/memory-queue.js

@@ -64,3 +64,3 @@ "use strict";
         else {
-            this.logger.warn('Message was not sent as it has not registered handlers', { message });
+            this.logger.warn('Message was not sent as it has no registered handlers', { message });
         }
@@ -67,0 +67,0 @@ }

package.json

 {
   "name": "@node-ts/bus-core",
-  "version": "0.1.18",
+  "version": "0.2.0",
   "description": "A service bus for message-based, distributed node applications",
@@ -48,3 +48,3 @@ "main": "./dist/index.js",
   ],
-  "gitHead": "d2136911ed371a8f60647791f42dc3f4d959cc33"
+  "gitHead": "db665a2aa4ee1e7ee5a64dd30f38163bee47881d"
 }

src/handler/handler.integration.ts

@@ -23,3 +23,3 @@ import { TestEvent } from '../test/test-event'
   beforeAll(async () => {
-    container = new TestContainer()
+    container = new TestContainer().silenceLogs()
 
@@ -26,0 +26,0 @@ messageLogger = Mock.ofType<MessageLogger>()

src/service-bus/service-bus.integration.ts

@@ -11,2 +11,3 @@ import { ServiceBus } from './service-bus'
 import { Mock } from 'typemoq'
+import { HandlerRegistry } from '../handler'
 
@@ -21,5 +22,8 @@ const event = new TestEvent()
 
-  beforeAll(() => {
-    container = new TestContainer()
+  beforeAll(async () => {
+    container = new TestContainer().silenceLogs()
     queue = new MemoryQueue(Mock.ofType<Logger>().object)
+    const transport = container.get<MemoryQueue>(BUS_SYMBOLS.Transport)
+    const registry = container.get<HandlerRegistry>(BUS_SYMBOLS.HandlerRegistry)
+    await transport.initialize(registry)
     sut = container.get(BUS_SYMBOLS.Bus)
@@ -26,0 +30,0 @@ })

src/service-bus/service-bus.ts

@@ -107,4 +107,2 @@ import { injectable, inject } from 'inversify'
     const handlersToInvoke = handlers.map(h => h.resolveHandler(h.defaultContainer))
-    this.logger.debug('Dispatching message to handlers', { messageName: message.$name })
-
     await Promise.all(handlersToInvoke.map(async h => {
@@ -111,0 +109,0 @@ await h.handle(message)

src/test/test-container.ts

 import { Container } from 'inversify'
-import { LoggerModule } from '@node-ts/logger-core'
+import { LoggerModule, LOGGER_SYMBOLS, Logger } from '@node-ts/logger-core'
 import { BusModule } from '../bus-module'
+import { Mock } from 'typemoq'
 
@@ -12,2 +13,7 @@ export class TestContainer extends Container {
   }
+
+  silenceLogs (): this {
+    this.rebind(LOGGER_SYMBOLS.Logger).toConstantValue(Mock.ofType<Logger>().object)
+    return this
+  }
 }

src/transport/memory-queue.ts

@@ -86,3 +86,3 @@ import { injectable, inject } from 'inversify'
     } else {
-      this.logger.warn('Message was not sent as it has not registered handlers', { message })
+      this.logger.warn('Message was not sent as it has no registered handlers', { message })
     }
@@ -89,0 +89,0 @@ }

No alert changes

Improved metrics

Total package byte prevSize

105059

increased by0.17%

Lines of code

1972

increased by0.36%

No dependency changes