Skip to content

Commit 07e7688

Browse files
authored
fix: Move nats debug log in debug level (#91)
fix: Move nats debug log in debug level
1 parent 536b5ce commit 07e7688

File tree

3 files changed

+22
-10
lines changed

3 files changed

+22
-10
lines changed

package-lock.json

Lines changed: 7 additions & 7 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@
3434
"typescript": "^5.1.3"
3535
},
3636
"dependencies": {
37-
"@lad-tech/toolbelt": "^1.1.1",
37+
"@lad-tech/toolbelt": "^1.3.1",
3838
"@opentelemetry/api": "^1.1.0",
3939
"@opentelemetry/exporter-jaeger": "^1.3.1",
4040
"@opentelemetry/resources": "^1.3.1",

src/Service.ts

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import { Root } from './Root';
2-
import { JSONCodec, Subscription } from 'nats';
2+
import { JSONCodec, Subscription, DebugEvents, Events } from 'nats';
33
import {
44
Message,
55
Emitter,
@@ -9,7 +9,6 @@ import {
99
ExternalBaggage,
1010
ClientService,
1111
DependencyType,
12-
Adapter,
1312
container,
1413
InstanceContainer,
1514
ServiceContainer,
@@ -586,11 +585,24 @@ export class Service<E extends Emitter = Emitter> extends Root {
586585
});
587586
}
588587

588+
/**
589+
* Type guard for NATS debug event
590+
*/
591+
private isNATSDebugEvent(event: Events | DebugEvents): event is DebugEvents {
592+
return (
593+
event === DebugEvents.PingTimer || event === DebugEvents.Reconnecting || event === DebugEvents.StaleConnection
594+
);
595+
}
596+
589597
/**
590598
* Logs events from the broker
591599
*/
592600
private async watchBrokerEvents() {
593601
for await (const event of this.broker.status()) {
602+
if (this.isNATSDebugEvent(event.type)) {
603+
this.logger.debug(`${event.type}: ${event.data}`);
604+
return;
605+
}
594606
this.logger.warn(`${event.type}: ${event.data}`);
595607
}
596608
}

0 commit comments

Comments
 (0)