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

listen: when passDtmf is true, send dtmf events down websocket connection as json test frames (#129)

Browse Source
This commit is contained in:
Dave Horton
2022-07-07 11:55:29 +02:00
committed by GitHub
parent f95524863d
commit 7f808c6107
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
lib/tasks/listen.js
View File

@@ -22,8 +22,6 @@ class TaskListen extends Task {
this.results = {}; this.results = {};
if (this.transcribe) this.transcribeTask = makeTask(logger, {'transcribe': opts.transcribe}, this); if (this.transcribe) this.transcribeTask = makeTask(logger, {'transcribe': opts.transcribe}, this);
this._dtmfHandler = this._onDtmf.bind(this);
} }
get name() { return TaskName.Listen; } get name() { return TaskName.Listen; }
@@ -31,6 +29,7 @@ class TaskListen extends Task {
async exec(cs, ep) { async exec(cs, ep) {
await super.exec(cs); await super.exec(cs);
this.ep = ep; this.ep = ep;
this._dtmfHandler = this._onDtmf.bind(this, ep);
try { try {
this.hook = this.normalizeUrl(this.url, 'GET', this.wsAuth); this.hook = this.normalizeUrl(this.url, 'GET', this.wsAuth);
@@ -148,7 +147,13 @@ class TaskListen extends Task {
} }
_onDtmf(evt) { _onDtmf(ep, evt) {
this.logger.debug({evt}, `TaskListen:_onDtmf received dtmf ${evt.dtmf}`);
if (this.passDtmf && this.ep?.connected) {
const obj = {event: 'dtmf', dtmf: evt.dtmf, duration: evt.duration};
this.ep.forkAudioSendText(obj)
.catch((err) => this.logger.info({err}, 'TaskListen:_onDtmf error sending dtmf'));
}
if (evt.dtmf === this.finishOnKey) { if (evt.dtmf === this.finishOnKey) {
this.logger.info(`TaskListen:_onDtmf terminating task due to dtmf ${evt.dtmf}`); this.logger.info(`TaskListen:_onDtmf terminating task due to dtmf ${evt.dtmf}`);
this.results.digits = evt.dtmf; this.results.digits = evt.dtmf;