improve log messages

This commit is contained in:
akirilyuk
2022-02-01 18:22:06 +01:00
parent b532a49e45
commit 9657017669

View File

@@ -63,14 +63,16 @@ class Cognigy extends Task {
async _enqueueTask(task) { async _enqueueTask(task) {
let resolver; let resolver;
let rejector; let rejector;
const boundTask = task.bind(this);
const taskPromise = new Promise(async(resolve, reject) => { const taskPromise = new Promise(async(resolve, reject) => {
resolver = resolve; resolver = resolve;
rejector = reject; rejector = reject;
}); });
this.taskQueue.push(async(cb) => { this.taskQueue.push(async(cb) => {
this.logger.info('EXECUTING SAY TASK'); this.logger.debug('executing say task from queue');
try { try {
const result = await task(); const result = await boundTask();
resolver(result); resolver(result);
cb(result); cb(result);
} catch (err) { } catch (err) {
@@ -78,7 +80,7 @@ class Cognigy extends Task {
rejector(err); rejector(err);
cb(err); cb(err);
} }
this.logger.info('SAY TASK EXECUTED'); this.logger.debug('say task executed from queue');
}); });
this.taskQueue.lastPromise = taskPromise; this.taskQueue.lastPromise = taskPromise;
return taskPromise; return taskPromise;
@@ -256,11 +258,11 @@ class Cognigy extends Task {
const text = parseBotText(evt); const text = parseBotText(evt);
if (evt.data) this.config.update(evt.data); if (evt.data) this.config.update(evt.data);
if (text) { if (text) {
this._enqueueTask((async() => { this._enqueueTask(async() => {
this.logger.info({text}, 'received text'); this.logger.info({text}, 'received text');
const sayTask = this._makeSayTask(text); const sayTask = this._makeSayTask(text);
await sayTask.exec(cs, ep, this); await sayTask.exec(cs, ep, this);
}).bind(this)); });
} }
@@ -268,7 +270,7 @@ class Cognigy extends Task {
try { try {
switch (evt.data.type) { switch (evt.data.type) {
case 'hangup': case 'hangup':
this._enqueueTask((async() => { this._enqueueTask(async() => {
this.performAction({cognigyResult: 'hangup Succeeded'}); this.performAction({cognigyResult: 'hangup Succeeded'});
this.reportedFinalAction = true; this.reportedFinalAction = true;
cs.replaceApplication([{hangup: { cs.replaceApplication([{hangup: {
@@ -277,18 +279,18 @@ class Cognigy extends Task {
} }
}}]); }}]);
this.taskQueue.end(); this.taskQueue.end();
}).bind(this)); });
return; return;
case 'refer': case 'refer':
this._enqueueTask((async() => { this._enqueueTask(async() => {
this.performAction({cognigyResult: 'refer succeeded'}); this.performAction({cognigyResult: 'refer succeeded'});
this.reportedFinalAction = true; this.reportedFinalAction = true;
cs.replaceApplication([{'sip:refer': { cs.replaceApplication([{'sip:refer': {
referTo: evt.data.number, referTo: evt.data.number,
referredBy: 'cognigy' referredBy: 'cognigy'
}}]); }}]);
}).bind(this)); });
return; return;
default: default:
break; break;