ben.carrasco/jambonz-feature-server
1
0
Fork 0
mirror of https://github.com/jambonz/jambonz-feature-server.git synced 2025-12-21 17:17:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

try a different approach

Browse Source
This commit is contained in:
akirilyuk
2022-02-03 19:14:37 +01:00
parent 1fd94dce94
commit fce40a47ce
2 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
lib/tasks/cognigy/index.js
View File

@@ -305,8 +305,8 @@ class Cognigy extends Task {
this.logger.info({text}, 'received text'); this.logger.info({text}, 'received text');
this._enqueueTask(async() => { this._enqueueTask(async() => {
// todo inject the session config into the say task // todo inject the session config into the say task
const sayTask = this._createPromtTask({ text, dontListenAfterSpeech: true }); const promtTask = this._createPromtTask({ text, dontListenAfterSpeech: true });
await sayTask.exec(cs, ep, this); await promtTask.exec(cs, ep, this);
this.logger.debug({text}, 'executed say task'); this.logger.debug({text}, 'executed say task');
}); });
} }
@@ -369,11 +369,10 @@ class Cognigy extends Task {
//then stop execution of currently queues bot output before sending the //then stop execution of currently queues bot output before sending the
//response to waiting bot since otherwise we could stop upcoming bot output //response to waiting bot since otherwise we could stop upcoming bot output
if (this.config.skipUntilBotInput) { if (this.config.bargeInEnabled && this.config.skipUntilBotInput) {
// clear task queue, resolve the last promise and cleanup; // clear task queue, resolve the last promise and cleanup;
this.taskQueue.lastPromise.resolve(); this.taskQueue.lastPromise.resolve();
this.taskQueue.end(); this.taskQueue.end();
//this._killSayTasks();
this.taskQueue.autostart = true; this.taskQueue.autostart = true;
} }

12
lib/tasks/gather.js
View File

@@ -104,10 +104,12 @@ class TaskGather extends Task {
this.sayTask.on('playDone', async(err) => { this.sayTask.on('playDone', async(err) => {
if (err) return this.logger.error({err}, 'Gather:exec Error playing tts'); if (err) return this.logger.error({err}, 'Gather:exec Error playing tts');
this.logger.debug('Gather: say task completed'); this.logger.debug('Gather: say task completed');
if (!this.killed) { if (!this.killed) {
if(this.listenAfterSpeech){ if (this.listenAfterSpeech) {
startListening(cs, ep); startListening(cs, ep);
} } else {
this.notifyTaskDone();
}
} }
}); });
} }
@@ -116,7 +118,7 @@ class TaskGather extends Task {
this.playTask.on('playDone', async(err) => { this.playTask.on('playDone', async(err) => {
if (err) return this.logger.error({err}, 'Gather:exec Error playing url'); if (err) return this.logger.error({err}, 'Gather:exec Error playing url');
if (!this.killed) { if (!this.killed) {
startListening(cs, ep); startListening(cs, ep);
}} }}
); );
} }