Skip to content

Commit dbd015d

Browse files
github1github1
authored andcommitted
log handler call if one exists
1 parent c321396 commit dbd015d

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/mesh.ts

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -417,8 +417,7 @@ export abstract class MeshBackendBase implements MeshBackend {
417417
// tslint:disable-next-line:no-any
418418
protected async invokeHandler<T>(message : SubjectMessageEnvelope,
419419
callback? : (err? : MeshError, result? : T) => void) : Promise<T> {
420-
const localLog : debug.Debugger = log.extend(`MeshBackendBase.handler.${message.header.subject}.${message.header.name}`);
421-
localLog.extend('debug')('Invoking handler for %o', message);
420+
const localLog : debug.Debugger = log.extend(`invokeHandler.${message.header.subject}.${message.header.name}`);
422421
if (!this.lruCache) {
423422
this.lruCache = new LRUCache({
424423
max: 1000,
@@ -440,10 +439,12 @@ export abstract class MeshBackendBase implements MeshBackend {
440439
try {
441440
// tslint:disable-next-line:no-any
442441
if (this.handlers[message.header.subject][PSEUDO_MESSAGE_BEFORE]) {
442+
localLog.extend('debug')('before -> %o', message);
443443
// tslint:disable-next-line:no-unsafe-any
444444
response = await this.handlers[message.header.subject][PSEUDO_MESSAGE_BEFORE].handler(undefined, message);
445445
}
446446
if (response === undefined && this.handlers[message.header.subject][message.header.name]) {
447+
localLog.extend('debug')('%o', message);
447448
// tslint:disable-next-line:no-unsafe-any
448449
response = await this.handlers[message.header.subject][message.header.name].handler(undefined, message);
449450
}
@@ -455,6 +456,7 @@ export abstract class MeshBackendBase implements MeshBackend {
455456
}
456457
} finally {
457458
if (this.handlers[message.header.subject] && this.handlers[message.header.subject][PSEUDO_MESSAGE_AFTER]) {
459+
localLog.extend('debug')('after -> %o', message);
458460
// tslint:disable-next-line:no-unsafe-any
459461
await this.handlers[message.header.subject][PSEUDO_MESSAGE_AFTER].handler(undefined, message);
460462
}

0 commit comments

Comments
 (0)