update db-helper 0.9.16 (#1316)

* include callSid on INVITEs to freeeswitch

* remove unnecessary warning

lib/session/call-session.js

@@ -1963,6 +1963,17 @@ Duration=${duration} `
       }
     } catch (err) {
       this.logger.info({err, opts, callSid}, 'CallSession:updateCall - error updating call');
+      const {writeAlerts} = this.srf.locals;
+      try {
+        writeAlerts({
+          alert_type: 'error-updating-call',
+          account_sid: this.accountSid,
+          message: err.message,
+          target_sid: callSid
+        });
+      } catch (err) {
+        this.logger.error({err}, 'Error writing error-updating-call alert');
+      }
     }
   }
 
@@ -2367,6 +2378,7 @@ Duration=${duration} `
       const ep = await this._createMediaEndpoint({
         headers: {
           'X-Jambones-Call-ID': this.callId,
+          'X-Call-Sid': this.callSid,
         },
         remoteSdp: this.req.body
       });

lib/session/confirm-call-session.js

@@ -8,7 +8,8 @@ const CallSession = require('./call-session');
 
  */
 class ConfirmCallSession extends CallSession {
-  constructor({logger, application, dlg, ep, tasks, callInfo, accountInfo, memberId, confName, rootSpan, req}) {
+  // eslint-disable-next-line max-len
+  constructor({logger, application, dlg, ep, tasks, callInfo, accountInfo, memberId, confName, rootSpan, req, tmpFiles}) {
     super({
       logger,
       application,
@@ -24,6 +25,7 @@ class ConfirmCallSession extends CallSession {
     this.dlg = dlg;
     this.ep = ep;
     this.req = req;
+    this.tmpFiles = tmpFiles;
   }
 
   /**

lib/tasks/conference.js

@@ -673,7 +673,8 @@ class Conference extends Task {
         confName: this.confName,
         tasks,
         rootSpan: cs.rootSpan,
-        req: cs.req
+        req: cs.req,
+        tmpFiles: cs.tmpFiles,
       });
       await this._playSession.exec();
       this._playSession = null;

lib/tasks/dial.js

@@ -1098,7 +1098,8 @@ class TaskDial extends Task {
               accountInfo: this.cs.accountInfo,
               tasks,
               rootSpan: this.cs.rootSpan,
-              req: this.cs.req
+              req: this.cs.req,
+              tmpFiles: this.cs.tmpFiles,
             });
             await this._onHoldSession.exec();
             this._onHoldSession = null;

lib/tasks/enqueue.js

@@ -370,7 +370,8 @@ class TaskEnqueue extends Task {
         accountInfo: cs.accountInfo,
         tasks: tasksToRun,
         rootSpan: cs.rootSpan,
-        req: cs.req
+        req: cs.req,
+        tmpFiles: cs.tmpFiles,
       });
       await this._playSession.exec();
       this._playSession = null;

lib/tasks/listen.js

@@ -72,7 +72,7 @@ class TaskListen extends Task {
     } catch (err) {
       this.logger.info(err, `TaskListen:exec - error ${this.url}`);
     }
-    if (this.transcribeTask) this.transcribeTask.kill();
+    if (this.transcribeTask) this.transcribeTask.kill(cs);
     this._removeListeners(ep);
   }
 

lib/utils/amd-utils.js

@@ -281,13 +281,17 @@ module.exports = (logger) => {
 
     /* set stt options */
     logger.info(`starting amd for vendor ${vendor} and language ${language}`);
-    const sttOpts = amd.setChannelVarsForStt({name: TaskName.Gather}, sttCredentials, language, {
-      vendor,
-      hints,
-      enhancedModel: true,
-      altLanguages: opts.recognizer?.altLanguages || [],
-      initialSpeechTimeoutMs: opts.resolveTimeoutMs,
-    });
+    /* if opts contains recognizer object use that config for stt, otherwise use defaults */
+    const rOpts = opts.recognizer ?
+      opts.recognizer :
+      {
+        vendor,
+        hints,
+        enhancedModel: true,
+        altLanguages: opts.recognizer?.altLanguages || [],
+        initialSpeechTimeoutMs: opts.resolveTimeoutMs,
+      };
+    const sttOpts = amd.setChannelVarsForStt({name: TaskName.Gather}, sttCredentials, language, rOpts);
 
     await ep.set(sttOpts).catch((err) => logger.info(err, 'Error setting channel variables'));
 

lib/utils/background-task-manager.js

@@ -65,7 +65,7 @@ class BackgroundTaskManager extends Emitter {
       this.logger.info(`stopping background task: ${type}`);
       task.removeAllListeners();
       task.span.end();
-      task.kill();
+      task.kill(this.cs);
       // Remove task from managed List
       this.tasks.delete(type);
     }

lib/utils/http-requestor.js

@@ -41,7 +41,7 @@ class HttpRequestor extends BaseRequestor {
   constructor(logger, account_sid, hook, secret) {
     super(logger, account_sid, hook, secret);
 
-    this.method = hook.method || 'POST';
+    this.method = hook.method?.toUpperCase() || 'POST';
     this.authHeader = basicAuth(hook.username, hook.password);
     this.backoffMs = 500;
 
@@ -111,7 +111,7 @@ class HttpRequestor extends BaseRequestor {
 
     const payload = params ? snakeCaseKeys(params, ['customerData', 'sip', 'env_vars', 'args']) : null;
     const url = hook.url || hook;
-    const method = hook.method || 'POST';
+    const method = hook.method?.toUpperCase() || 'POST';
     let buf = '';
     httpHeaders = {
       ...httpHeaders,
@@ -119,7 +119,7 @@ class HttpRequestor extends BaseRequestor {
     };
 
     assert.ok(url, 'HttpRequestor:request url was not provided');
-    assert.ok, (['GET', 'POST'].includes(method), `HttpRequestor:request method must be 'GET' or 'POST' not ${method}`);
+    assert.ok(['GET', 'POST'].includes(method), `HttpRequestor:request method must be 'GET' or 'POST' not ${method}`);
     const startAt = process.hrtime();
 
     /* if we have an absolute url, and it is ws then do a websocket connection */

lib/utils/place-outdial.js

@@ -401,7 +401,8 @@ class SingleDialer extends Emitter {
         accountInfo: this.accountInfo,
         tasks,
         rootSpan: this.rootSpan,
-        req: this.req
+        req: this.req,
+        tmpFiles: cs.tmpFiles,
       });
       await cs.exec();
 

lib/utils/stt-latency-calculator.js

@@ -101,8 +101,6 @@ class SttLatencyCalculator extends Emitter {
       }
       this.isRunning = false;
       this.logger.info('STT Latency Calculator stopped');
-    } else {
-      this.logger.warn('Latency calculator is not running, no VAD detection to stop');
     }
   }
 
@@ -116,7 +114,7 @@ class SttLatencyCalculator extends Emitter {
       return;
     }
     this._startVad();
-    this.logger.info('STT Latency Calculator started');
+    this.logger.debug('STT Latency Calculator started');
   }
 
   stop() {

package.json

@@ -27,10 +27,10 @@
   "dependencies": {
     "@aws-sdk/client-auto-scaling": "^3.549.0",
     "@aws-sdk/client-sns": "^3.549.0",
-    "@jambonz/db-helpers": "^0.9.12",
+    "@jambonz/db-helpers": "^0.9.16",
     "@jambonz/http-health-check": "^0.0.1",
     "@jambonz/mw-registrar": "^0.2.7",
-    "@jambonz/realtimedb-helpers": "^0.8.13",
+    "@jambonz/realtimedb-helpers": "^0.8.15",
     "@jambonz/speech-utils": "^0.2.15",
     "@jambonz/stats-collector": "^0.1.10",
     "@jambonz/time-series": "^0.2.14",