incorporate parsed options

* allow say verb failed as NonFatalTaskError for File Not Found

* wip

lib/middleware.js

@@ -112,6 +112,14 @@ module.exports = function(srf, logger) {
         req.locals.callingNumber = sipURIs[1];
       }
     }
+
+    // Feature server INVITE request pipelines taking time to finish,
+    // while connecting and fetch application from db and invoking webhook.
+    // call can be canceled without any handling, so we add a listener here
+    req.once('cancel', (sipMsg) => {
+      logger.info(`${callId} got CANCEL request`);
+      req.locals.canceled = true;
+    });
     next();
   }
 
@@ -362,13 +370,14 @@ module.exports = function(srf, logger) {
       });
       // if transferred call contains callInfo, let update original data to newly created callInfo in this instance.
       if (app.transferredCall && app.callInfo) {
-        const {direction, callerName, from, to, originatingSipIp, originatingSipTrunkName} = app.callInfo;
+        const {direction, callerName, from, to, originatingSipIp, originatingSipTrunkName, customerData} = app.callInfo;
         req.locals.callInfo.direction = direction;
         req.locals.callInfo.callerName = callerName;
         req.locals.callInfo.from = from;
         req.locals.callInfo.to = to;
         req.locals.callInfo.originatingSipIp = originatingSipIp;
         req.locals.callInfo.originatingSipTrunkName = originatingSipTrunkName;
+        if (customerData) req.locals.callInfo.customerData = customerData;
         delete app.callInfo;
       }
       next();

lib/session/call-session.js

@@ -658,6 +658,15 @@ class CallSession extends Emitter {
     }
   }
 
+  // disableTtsCache
+  get disableTtsCache() {
+    return this._disableTtsCache || false;
+  }
+
+  set disableTtsCache(d) {
+    this._disableTtsCache = d;
+  }
+
   getTsStreamingVendor() {
     let v;
     if (this.currentTask?.isStreamingTts) {
@@ -941,6 +950,12 @@ class CallSession extends Emitter {
     this.ttsStreamingBuffer?.start();
   }
 
+  stopTtsStream() {
+    this.requestor?.request('tts:streaming-event', '/streaming-event', {event_type: 'stream_closed'})
+      .catch((err) => this.logger.info({err}, 'CallSession:clearTtsStream - Error sending user_interruption'));
+    this.ttsStreamingBuffer?.stop();
+  }
+
   async enableBotMode(gather, autoEnable) {
     try {
       let task;
@@ -1086,6 +1101,13 @@ class CallSession extends Emitter {
             deepgram_stt_use_tls: credential.deepgram_stt_use_tls
           };
         }
+        else if ('gladia' === vendor) {
+          return {
+            speech_credential_sid: credential.speech_credential_sid,
+            api_key: credential.api_key,
+            region: credential.region,
+          };
+        }
         else if ('soniox' === vendor) {
           return {
             speech_credential_sid: credential.speech_credential_sid,
@@ -1117,6 +1139,7 @@ class CallSession extends Emitter {
           return {
             api_key: credential.api_key,
             model_id: credential.model_id,
+            api_uri: credential.api_uri,
             options: credential.options
           };
         }
@@ -1165,6 +1188,14 @@ class CallSession extends Emitter {
             service_version: credential.service_version
           };
         }
+        else if ('houndify' === vendor) {
+          return {
+            speech_credential_sid: credential.speech_credential_sid,
+            client_id: credential.client_id,
+            client_key: credential.client_key,
+            user_id: credential.user_id
+          };
+        }
         else if ('deepgramflux' === vendor) {
           return {
             speech_credential_sid: credential.speech_credential_sid,
@@ -1247,6 +1278,7 @@ class CallSession extends Emitter {
       this.ttsStreamingBuffer.on(TtsStreamingEvents.Pause, this._onTtsStreamingPause.bind(this));
       this.ttsStreamingBuffer.on(TtsStreamingEvents.Resume, this._onTtsStreamingResume.bind(this));
       this.ttsStreamingBuffer.on(TtsStreamingEvents.ConnectFailure, this._onTtsStreamingConnectFailure.bind(this));
+      this.ttsStreamingBuffer.on(TtsStreamingEvents.Connected, this._onTtsStreamingConnected.bind(this));
     }
     else {
       this.logger.info(`CallSession:exec - not a normal call session: ${this.constructor.name}`);
@@ -2399,7 +2431,7 @@ Duration=${duration} `
         this.logger.debug(`endpoint was destroyed!! ${this.ep.uuid}`);
       });
 
-      if (this.direction === CallDirection.Inbound) {
+      if (this.direction === CallDirection.Inbound || this.application?.transferredCall) {
         if (task.earlyMedia && !this.req.finalResponseSent) {
           this.res.send(183, {body: ep.local.sdp});
           return {ep};
@@ -2531,7 +2563,7 @@ Duration=${duration} `
     this.backgroundTaskManager.stopAll();
     this.clearOrRestoreActionHookDelayProcessor().catch((err) => {});
 
-    this.ttsStreamingBuffer?.stop();
+    this.stopTtsStream();
 
     this.sttLatencyCalculator?.stop();
   }
@@ -3078,6 +3110,11 @@ Duration=${duration} `
     }
   }
 
+  _onTtsStreamingConnected() {
+    this.requestor?.request('tts:streaming-event', '/streaming-event', {event_type: 'stream_open'})
+      .catch((err) => this.logger.info({err}, 'CallSession:_onTtsStreamingConnected - Error sending'));
+  }
+
   _onTtsStreamingEmpty() {
     const task = this.currentTask;
     if (task && TaskName.Say === task.name) {

lib/session/inbound-call-session.js

@@ -22,6 +22,12 @@ class InboundCallSession extends CallSession {
     this.req = req;
     this.res = res;
 
+    // if the call was canceled before we got here, handle it
+    if (this.req.locals.canceled) {
+      req.locals.logger.info('InboundCallSession: constructor - call was already canceled');
+      this._onCancel();
+    }
+
     req.once('cancel', this._onCancel.bind(this));
 
     this.on('callStatusChange', this._notifyCallStatusChange.bind(this));

lib/tasks/conference.js

@@ -49,7 +49,8 @@ class Conference extends Task {
     this.confName = this.data.name;
     [
       'beep', 'startConferenceOnEnter', 'endConferenceOnExit', 'joinMuted',
-      'maxParticipants', 'waitHook', 'statusHook', 'endHook', 'enterHook', 'endConferenceDuration'
+      'maxParticipants', 'waitHook', 'statusHook', 'endHook', 'enterHook',
+      'endConferenceDuration', 'distributeDtmf'
     ].forEach((attr) => this[attr] = this.data[attr]);
     this.record = this.data.record || {};
     this.statusEvents = [];
@@ -356,6 +357,7 @@ class Conference extends Task {
         //https://developer.signalwire.com/freeswitch/FreeSWITCH-Explained/Modules/mod_conference_3965534/
         // mute |	Enter conference muted
         ...((this.joinMuted || this.speakOnlyTo) && {mute: true}),
+        ...(this.distributeDtmf && {'dist-dtmf': true})
       }});
 
       /**

lib/tasks/config.js

@@ -18,7 +18,8 @@ class TaskConfig extends Task {
       'boostAudioSignal',
       'vad',
       'ttsStream',
-      'autoStreamTts'
+      'autoStreamTts',
+      'disableTtsCache'
     ].forEach((k) => this[k] = this.data[k] || {});
 
     if ('notifyEvents' in this.data) {
@@ -88,6 +89,7 @@ class TaskConfig extends Task {
   get hasReferHook() { return Object.keys(this.data).includes('referHook'); }
   get hasNotifySttLatency() { return Object.keys(this.data).includes('notifySttLatency'); }
   get hasTtsStream() { return Object.keys(this.ttsStream).length; }
+  get hasDisableTtsCache() { return Object.keys(this.data).includes('disableTtsCache'); }
 
   get summary() {
     const phrase = [];
@@ -125,6 +127,7 @@ class TaskConfig extends Task {
       phrase.push(`${this.ttsStream.enable ? 'enable' : 'disable'} ttsStream`);
     }
     if ('autoStreamTts' in this.data) phrase.push(`enable Say.stream value ${this.data.autoStreamTts ? 'on' : 'off'}`);
+    if (this.hasDisableTtsCache) phrase.push(`disableTtsCache ${this.data.disableTtsCache ? 'on' : 'off'}`);
     return `${this.name}{${phrase.join(',')}}`;
   }
 
@@ -357,6 +360,11 @@ class TaskConfig extends Task {
       this.logger.info('Config: disabling ttsStream');
       cs.disableTtsStream();
     }
+
+    if (this.hasDisableTtsCache) {
+      this.logger.info(`set disableTtsCache = ${this.disableTtsCache}`);
+      cs.disableTtsCache = this.data.disableTtsCache;
+    }
   }
 
   async kill(cs) {

lib/tasks/gather.js

@@ -5,12 +5,14 @@ const {
   AwsTranscriptionEvents,
   AzureTranscriptionEvents,
   DeepgramTranscriptionEvents,
+  GladiaTranscriptionEvents,
   SonioxTranscriptionEvents,
   CobaltTranscriptionEvents,
   IbmTranscriptionEvents,
   NvidiaTranscriptionEvents,
   JambonzTranscriptionEvents,
   AssemblyAiTranscriptionEvents,
+  HoundifyTranscriptionEvents,
   DeepgramfluxTranscriptionEvents,
   VoxistTranscriptionEvents,
   CartesiaTranscriptionEvents,
@@ -93,6 +95,8 @@ class TaskGather extends SttTask {
 
   get needsStt() { return this.input.includes('speech'); }
 
+  get isBackgroundGather() { return this.bugname_prefix === 'background_bargeIn_'; }
+
   get wantsSingleUtterance() {
     return this.data.recognizer?.singleUtterance === true;
   }
@@ -227,7 +231,9 @@ class TaskGather extends SttTask {
 
     const startListening = async(cs, ep) => {
       this._startTimer();
-      if (this.isContinuousAsr && 0 === this.timeout) this._startAsrTimer();
+      if (this.isContinuousAsr && 0 === this.timeout && !this.isBackgroundGather) {
+        this._startAsrTimer();
+      }
       if (this.input.includes('speech') && !this.listenDuringPrompt) {
         try {
           await this._setSpeechHandlers(cs, ep);
@@ -264,19 +270,21 @@ class TaskGather extends SttTask {
         };
         this.sayTask.span = span;
         this.sayTask.ctx = ctx;
-        this.sayTask.exec(cs, {ep})  // kicked off, _not_ waiting for it to complete
+        this.sayTask
+          .exec(cs, {ep})  // kicked off, _not_ waiting for it to complete
+          .then(() => {
+            if (this.sayTask.isStreamingTts) return;
+            this.logger.debug('Gather:exec - nested say task completed');
+            span.end();
+            process();
+            return;
+          })
           .catch((err) => {
             process();
           });
         if (this.sayTask.isStreamingTts && !this.sayTask.closeOnStreamEmpty) {
           // if streaming tts, we do not wait for it to complete if it is not closing the stream automatically
           process();
-        } else {
-          this.sayTask.on('playDone', (err) => {
-            span.end();
-            if (err) this.logger.error({err}, 'Gather:exec Error playing tts');
-            process();
-          });
         }
       }
       else if (this.playTask) {
@@ -300,15 +308,17 @@ class TaskGather extends SttTask {
         };
         this.playTask.span = span;
         this.playTask.ctx = ctx;
-        this.playTask.exec(cs, {ep})  // kicked off, _not_ waiting for it to complete
+        this.playTask
+          .exec(cs, {ep})  // kicked off, _not_ waiting for it to complete
+          .then(() => {
+            this.logger.debug('Gather:exec - nested play task completed');
+            span.end();
+            process();
+            return;
+          })
           .catch((err) => {
             process();
           });
-        this.playTask.on('playDone', (err) => {
-          span.end();
-          if (err) this.logger.error({err}, 'Gather:exec Error playing url');
-          process();
-        });
       }
       else {
         if (this.killed) {
@@ -482,6 +492,16 @@ class TaskGather extends SttTask {
         this.addCustomEventListener(ep, DeepgramfluxTranscriptionEvents.Error, this._onVendorError.bind(this, cs, ep));
         break;
 
+      case 'gladia':
+        this.bugname = `${this.bugname_prefix}gladia_transcribe`;
+        this.addCustomEventListener(
+          ep, GladiaTranscriptionEvents.Transcription, this._onTranscription.bind(this, cs, ep));
+        this.addCustomEventListener(ep, GladiaTranscriptionEvents.Connect, this._onVendorConnect.bind(this, cs, ep));
+        this.addCustomEventListener(ep, GladiaTranscriptionEvents.ConnectFailure,
+          this._onVendorConnectFailure.bind(this, cs, ep));
+        this.addCustomEventListener(ep, GladiaTranscriptionEvents.Error, this._onVendorError.bind(this, cs, ep));
+        break;
+
       case 'soniox':
         this.bugname = `${this.bugname_prefix}soniox_transcribe`;
         this.addCustomEventListener(
@@ -559,6 +579,18 @@ class TaskGather extends SttTask {
           this._onVendorConnectFailure.bind(this, cs, ep));
         break;
 
+      case 'houndify':
+        this.bugname = `${this.bugname_prefix}houndify_transcribe`;
+        this.addCustomEventListener(ep, HoundifyTranscriptionEvents.Transcription,
+          this._onTranscription.bind(this, cs, ep));
+        this.addCustomEventListener(ep, HoundifyTranscriptionEvents.Error,
+          this._onVendorError.bind(this, cs, ep));
+        this.addCustomEventListener(ep, HoundifyTranscriptionEvents.ConnectFailure,
+          this._onVendorConnectFailure.bind(this, cs, ep));
+        this.addCustomEventListener(ep, HoundifyTranscriptionEvents.Connect,
+          this._onVendorConnect.bind(this, cs, ep));
+        break;
+
       case 'voxist':
         this.bugname = `${this.bugname_prefix}voxist_transcribe`;
         this.addCustomEventListener(ep, VoxistTranscriptionEvents.Transcription,
@@ -854,12 +886,10 @@ class TaskGather extends SttTask {
       return;
     }
     if (this.sayTask && !this.sayTask.killed) {
-      this.sayTask.removeAllListeners('playDone');
       this.sayTask.kill(cs);
       this.sayTask = null;
     }
     if (this.playTask && !this.playTask.killed) {
-      this.playTask.removeAllListeners('playDone');
       this.playTask.kill(cs);
       this.playTask = null;
     }

lib/tasks/listen.js

@@ -5,6 +5,17 @@ const moment = require('moment');
 const MAX_PLAY_AUDIO_QUEUE_SIZE = 10;
 const DTMF_SPAN_NAME = 'dtmf';
 
+function escapeString(str) {
+  return str
+    .replace(/\\/g, '\\\\')   // Escape backslashes
+    .replace(/"/g, '\\"')     // Escape double quotes
+    .replace(/[\b]/g, '\\b')  // Escape backspace (NOTE: [\b] not \b)
+    .replace(/\f/g, '\\f')    // Escape formfeed
+    .replace(/\n/g, '\\n')    // Escape newlines
+    .replace(/\r/g, '\\r')    // Escape carriage returns
+    .replace(/\t/g, '\\t');   // Escape tabs
+}
+
 class TaskListen extends Task {
   constructor(logger, opts, parentTask) {
     super(logger, opts);
@@ -16,10 +27,21 @@ class TaskListen extends Task {
     this.preconditions = TaskPreconditions.Endpoint;
 
     [
-      'action', 'auth', 'method', 'url', 'finishOnKey', 'maxLength', 'metadata', 'mixType', 'passDtmf', 'playBeep',
+      'action', 'auth', 'method', 'url', 'finishOnKey', 'maxLength', 'mixType', 'passDtmf', 'playBeep',
       'sampleRate', 'timeout', 'transcribe', 'wsAuth', 'disableBidirectionalAudio', 'channel'
     ].forEach((k) => this[k] = this.data[k]);
 
+    //Escape JSON special characters in metadata
+    if (this.data.metadata) {
+      this.metadata = {};
+      for (const key in this.data.metadata) {
+        if (this.data.metadata.hasOwnProperty(key)) {
+          const value = this.data.metadata[key];
+          this.metadata[key] = typeof value === 'string' ? escapeString(value) : value;
+        }
+      }
+    }
+
     this.mixType = this.mixType || 'mono';
     this.sampleRate = this.sampleRate || 8000;
     this.earlyMedia = this.data.earlyMedia === true;

lib/tasks/play.js

@@ -6,9 +6,21 @@ class TaskPlay extends Task {
     super(logger, opts);
     this.preconditions = TaskPreconditions.Endpoint;
 
-    this.url = this.data.url.includes('?')
-      ? this.data.url.split('?')[0] + '?' + this.data.url.split('?')[1].replaceAll('.', '%2E')
-      : this.data.url;
+    //Cleanup URLs that contain a querystring with a . unless that querystring is the filename
+    // see https://github.com/jambonz/jambonz-feature-server/pull/1293
+    // and https://github.com/jambonz/jambonz-feature-server/issues/1394 for background
+    if (this.data.url.includes('?')) {
+      if (['.mp3', '.wav'].includes(this.data.url.slice(-4))) {
+        this.url = this.data.url;
+      }
+      else {
+        this.url =  this.data.url.split('?')[0] + '?' + this.data.url.split('?')[1].replaceAll('.', '%2E');
+      }
+    }
+    else {
+      this.url = this.data.url;
+    }
+
     this.seekOffset = this.data.seekOffset || -1;
     this.timeoutSecs = this.data.timeoutSecs || -1;
     this.loop = this.data.loop || 1;

lib/tasks/say.js

@@ -2,8 +2,9 @@ const assert = require('assert');
 const TtsTask = require('./tts-task');
 const {TaskName, TaskPreconditions} = require('../utils/constants');
 const pollySSMLSplit = require('polly-ssml-split');
-const { SpeechCredentialError } = require('../utils/error');
+const { SpeechCredentialError, NonFatalTaskError } = require('../utils/error');
 const { sleepFor } = require('../utils/helpers');
+const { NON_FANTAL_ERRORS } = require('../utils/constants.json');
 
 /**
  * Discard unmatching responses:
@@ -120,13 +121,11 @@ class TaskSay extends TtsTask {
       }
       if (this.isStreamingTts) await this.handlingStreaming(cs, obj);
       else await this.handling(cs, obj);
-      this.emit('playDone');
     } catch (error) {
       if (error instanceof SpeechCredentialError) {
         // if say failed due to speech credentials, alarm is writtern and error notification is sent
         // finished this say to move to next task.
         this.logger.info({error}, 'Say failed due to SpeechCredentialError, finished!');
-        this.emit('playDone');
         return;
       }
       throw error;
@@ -147,9 +146,6 @@ class TaskSay extends TtsTask {
 
       await cs.startTtsStream();
 
-      cs.requestor?.request('tts:streaming-event', '/streaming-event', {event_type: 'stream_open'})
-        .catch((err) => this.logger.info({err}, 'TaskSay:handlingStreaming - Error sending'));
-
       if (this.text.length !== 0) {
         this.logger.info('TaskSay:handlingStreaming - sending text to TTS stream');
         for (const t of this.text) {
@@ -407,11 +403,19 @@ class TaskSay extends TtsTask {
             this._playResolve = resolve;
             this._playReject = reject;
           });
-          const r = await ep.play(filename);
-          this.logger.debug({r}, 'Say:exec play result');
-          if (r.playbackSeconds == null && r.playbackMilliseconds == null && r.playbackLastOffsetPos == null) {
-            this._playReject(new Error('Playback failed to start'));
+          try {
+            const r = await ep.play(filename);
+            this.logger.debug({r}, 'Say:exec play result');
+            if (r.playbackSeconds == null && r.playbackMilliseconds == null && r.playbackLastOffsetPos == null) {
+              this._playReject(new Error('Playback failed to start'));
+            }
+          } catch (err) {
+            if (NON_FANTAL_ERRORS.includes(err.message)) {
+              throw new NonFatalTaskError(err.message);
+            }
+            throw err;
           }
+
           try {
             // wait for playback-stop event received to confirm if the playback is successful
             await this._playPromise;
@@ -449,8 +453,8 @@ class TaskSay extends TtsTask {
         const {memberId, confName} = cs;
         this.killPlayToConfMember(this.ep, memberId, confName);
       } else if (this.isStreamingTts) {
-        this.logger.debug('TaskSay:kill - clearing TTS stream for streaming audio');
-        cs.clearTtsStream();
+        this.logger.debug('TaskSay:kill - stopping TTS stream for streaming audio');
+        cs.stopTtsStream();
       } else {
         if (!this.notifiedPlayBackStop) {
           this.notifyStatus({event: 'stop-playback'});

lib/tasks/stt-task.js

@@ -203,6 +203,56 @@ class SttTask extends Task {
     if (cs.hasGlobalSttPunctuation && !this.data.recognizer.punctuation) {
       this.data.recognizer.punctuation = cs.globalSttPunctuation;
     }
+    if (this.vendor === 'gladia') {
+      const { api_key, region } = this.sttCredentials;
+      const {url} = await this.createGladiaLiveSession({
+        api_key, region,
+        model: this.data.recognizer.model || 'solaria-1',
+        options: this.data.recognizer.gladiaOptions || {}
+      });
+      const {host, pathname, search} = new URL(url);
+      this.sttCredentials.host = host;
+      this.sttCredentials.path = `${pathname}${search}`;
+    }
+  }
+
+
+  async createGladiaLiveSession({
+    api_key,
+    region = 'us-west',
+    model = 'solaria-1',
+    options = {},
+  }) {
+    const url = `https://api.gladia.io/v2/live?region=${region}`;
+    const response = await fetch(url, {
+      method: 'POST',
+      headers: {
+        'x-gladia-key': api_key,
+        'Content-Type': 'application/json'
+      },
+      body: JSON.stringify({
+        encoding: 'wav/pcm',
+        bit_depth: 16,
+        sample_rate: 8000,
+        channels: 1,
+        model,
+        ...options,
+        messages_config: {
+          receive_final_transcripts: true,
+          receive_speech_events: true,
+          receive_errors: true,
+        }
+      })
+    });
+    if (!response.ok) {
+      const error = await response.text();
+      this.logger.error({url, status: response.status, error}, 'Error creating Gladia live session');
+      throw new Error(`Error creating Gladia live session: ${response.status} ${error}`);
+    }
+
+    const data = await response.json();
+    this.logger.debug({url: data.url}, 'Gladia Call registered');
+    return data;
   }
 
   addCustomEventListener(ep, event, handler) {

lib/tasks/transcribe.js

@@ -6,6 +6,7 @@ const {
   AwsTranscriptionEvents,
   AzureTranscriptionEvents,
   DeepgramTranscriptionEvents,
+  GladiaTranscriptionEvents,
   DeepgramfluxTranscriptionEvents,
   SonioxTranscriptionEvents,
   CobaltTranscriptionEvents,
@@ -14,6 +15,7 @@ const {
   JambonzTranscriptionEvents,
   TranscribeStatus,
   AssemblyAiTranscriptionEvents,
+  HoundifyTranscriptionEvents,
   VoxistTranscriptionEvents,
   CartesiaTranscriptionEvents,
   OpenAITranscriptionEvents,
@@ -254,6 +256,18 @@ class TaskTranscribe extends SttTask {
           this._onVendorConnectFailure.bind(this, cs, ep, channel));
         this.addCustomEventListener(ep, DeepgramfluxTranscriptionEvents.Error, this._onVendorError.bind(this, cs, ep));
 
+        break;
+
+      case 'gladia':
+        this.bugname = `${this.bugname_prefix}gladia_transcribe`;
+        this.addCustomEventListener(ep, GladiaTranscriptionEvents.Transcription,
+          this._onTranscription.bind(this, cs, ep, channel));
+        this.addCustomEventListener(ep, GladiaTranscriptionEvents.Connect,
+          this._onVendorConnect.bind(this, cs, ep));
+        this.addCustomEventListener(ep, GladiaTranscriptionEvents.ConnectFailure,
+          this._onVendorConnectFailure.bind(this, cs, ep, channel));
+        this.addCustomEventListener(ep, GladiaTranscriptionEvents.Error, this._onVendorError.bind(this, cs, ep));
+
         break;
       case 'soniox':
         this.bugname = `${this.bugname_prefix}soniox_transcribe`;
@@ -324,6 +338,18 @@ class TaskTranscribe extends SttTask {
           this._onVendorConnectFailure.bind(this, cs, ep, channel));
         break;
 
+      case 'houndify':
+        this.bugname = `${this.bugname_prefix}houndify_transcribe`;
+        this.addCustomEventListener(ep, HoundifyTranscriptionEvents.Transcription,
+          this._onTranscription.bind(this, cs, ep, channel));
+        this.addCustomEventListener(ep, HoundifyTranscriptionEvents.Error,
+          this._onVendorError.bind(this, cs, ep));
+        this.addCustomEventListener(ep, HoundifyTranscriptionEvents.ConnectFailure,
+          this._onVendorConnectFailure.bind(this, cs, ep, channel));
+        this.addCustomEventListener(ep, HoundifyTranscriptionEvents.Connect,
+          this._onVendorConnect.bind(this, cs, ep));
+        break;
+
       case 'voxist':
         this.bugname = `${this.bugname_prefix}voxist_transcribe`;
         this.addCustomEventListener(ep, VoxistTranscriptionEvents.Transcription,

lib/tasks/tts-task.js

@@ -41,6 +41,10 @@ class TtsTask extends Task {
 
   async exec(cs) {
     super.exec(cs);
+    // update disableTtsCache from call session if not set in task
+    if (this.data.disableTtsCache == null) {
+      this.disableTtsCache = cs.disableTtsCache;
+    }
     if (cs.synthesizer) {
       this.options = {...cs.synthesizer.options, ...this.options};
       this.data.synthesizer = this.data.synthesizer || {};
@@ -81,54 +85,67 @@ class TtsTask extends Task {
   }
 
   async setTtsStreamingChannelVars(vendor, language, voice, credentials, ep) {
-    const {api_key, model_id, custom_tts_streaming_url, auth_token} = credentials;
-    let obj;
+    const {api_key, model_id, api_uri, custom_tts_streaming_url, auth_token, options} = credentials;
+    // api_key, model_id, api_uri, custom_tts_streaming_url, and auth_token are encoded in the credentials
+    // allow them to be overriden via config, using options
+    // give preference to options passed in via config
+    const parsed_options = JSON.parse(options ?? '{}');
+    const local_options = {...parsed_options, ...this.options ?? {}};
+    const local_voice_settings = {...parsed_options.voice_settings ?? {}, ...this.options?.voice_settings ?? {}};
+    const local_api_key =  local_options.api_key ?? api_key;
+    const local_model_id = local_options.model_id ?? model_id;
+    const local_api_uri = local_options.api_uri ?? api_uri;
+    const local_custom_tts_streaming_url = local_options.custom_tts_streaming_url ?? custom_tts_streaming_url;
+    const local_auth_token = local_options.auth_token ?? auth_token;
 
-    this.logger.debug(`setTtsStreamingChannelVars: vendor: ${vendor}, language: ${language}, voice: ${voice}`);
+
+    let obj;
 
     switch (vendor) {
       case 'deepgram':
         obj = {
-          DEEPGRAM_API_KEY: api_key,
+          DEEPGRAM_API_KEY: local_api_key,
           DEEPGRAM_TTS_STREAMING_MODEL: voice
         };
         break;
       case 'cartesia':
         obj = {
-          CARTESIA_API_KEY: api_key,
-          CARTESIA_TTS_STREAMING_MODEL_ID: model_id,
+          CARTESIA_API_KEY: local_api_key,
+          CARTESIA_TTS_STREAMING_MODEL_ID: local_model_id,
           CARTESIA_TTS_STREAMING_VOICE_ID: voice,
           CARTESIA_TTS_STREAMING_LANGUAGE: language || 'en',
         };
         break;
       case 'elevenlabs':
-        const {stability, similarity_boost, use_speaker_boost, style, speed} = this.options.voice_settings || {};
+        // eslint-disable-next-line max-len
+        const {stability, similarity_boost, use_speaker_boost, style, speed} = local_voice_settings || {};
         obj = {
-          ELEVENLABS_API_KEY: api_key,
-          ELEVENLABS_TTS_STREAMING_MODEL_ID: model_id,
+          ELEVENLABS_API_KEY: local_api_key,
+          ...(api_uri && {ELEVENLABS_API_URI: local_api_uri}),
+          ELEVENLABS_TTS_STREAMING_MODEL_ID: local_model_id,
           ELEVENLABS_TTS_STREAMING_VOICE_ID: voice,
           // 20/12/2024 - only eleven_turbo_v2_5 support multiple language
-          ...(['eleven_turbo_v2_5'].includes(model_id) && {ELEVENLABS_TTS_STREAMING_LANGUAGE: language}),
+          ...(['eleven_turbo_v2_5'].includes(local_model_id) && {ELEVENLABS_TTS_STREAMING_LANGUAGE: language}),
           ...(stability && {ELEVENLABS_TTS_STREAMING_VOICE_SETTINGS_STABILITY: stability}),
           ...(similarity_boost && {ELEVENLABS_TTS_STREAMING_VOICE_SETTINGS_SIMILARITY_BOOST: similarity_boost}),
           ...(use_speaker_boost && {ELEVENLABS_TTS_STREAMING_VOICE_SETTINGS_USE_SPEAKER_BOOST: use_speaker_boost}),
           ...(style && {ELEVENLABS_TTS_STREAMING_VOICE_SETTINGS_STYLE: style}),
           // speed has value 0.7 to 1.2, 1.0 is default, make sure we send the value event it's 0
           ...(speed !== null && speed !== undefined && {ELEVENLABS_TTS_STREAMING_VOICE_SETTINGS_SPEED: `${speed}`}),
-          ...(this.options.pronunciation_dictionary_locators &&
-            Array.isArray(this.options.pronunciation_dictionary_locators) && {
+          ...(local_options.pronunciation_dictionary_locators &&
+            Array.isArray(local_options.pronunciation_dictionary_locators) && {
             ELEVENLABS_TTS_STREAMING_PRONUNCIATION_DICTIONARY_LOCATORS:
-            JSON.stringify(this.options.pronunciation_dictionary_locators)
+            JSON.stringify(local_options.pronunciation_dictionary_locators)
           }),
         };
         break;
       case 'rimelabs':
         const {
           pauseBetweenBrackets, phonemizeBetweenBrackets, inlineSpeedAlpha, speedAlpha, reduceLatency
-        } = this.options;
+        } = local_options;
         obj = {
-          RIMELABS_API_KEY: api_key,
-          RIMELABS_TTS_STREAMING_MODEL_ID: model_id,
+          RIMELABS_API_KEY: local_api_key,
+          RIMELABS_TTS_STREAMING_MODEL_ID: local_model_id,
           RIMELABS_TTS_STREAMING_VOICE_ID: voice,
           RIMELABS_TTS_STREAMING_LANGUAGE: language || 'en',
           ...(pauseBetweenBrackets && {RIMELABS_TTS_STREAMING_PAUSE_BETWEEN_BRACKETS: pauseBetweenBrackets}),
@@ -143,8 +160,8 @@ class TtsTask extends Task {
         if (vendor.startsWith('custom:')) {
           const use_tls = custom_tts_streaming_url.startsWith('wss://');
           obj = {
-            CUSTOM_TTS_STREAMING_HOST: custom_tts_streaming_url.replace(/^(ws|wss):\/\//, ''),
-            CUSTOM_TTS_STREAMING_API_KEY: auth_token,
+            CUSTOM_TTS_STREAMING_HOST: local_custom_tts_streaming_url.replace(/^(ws|wss):\/\//, ''),
+            CUSTOM_TTS_STREAMING_API_KEY: local_auth_token,
             CUSTOM_TTS_STREAMING_VOICE_ID: voice,
             CUSTOM_TTS_STREAMING_LANGUAGE: language || 'en',
             CUSTOM_TTS_STREAMING_USE_TLS: use_tls
@@ -263,9 +280,9 @@ class TtsTask extends Task {
       }
 
       /* produce an audio segment from the provided text */
-      const generateAudio = async(text) => {
-        if (this.killed) return;
-        if (text.startsWith('silence_stream://')) return text;
+      const generateAudio = async(text, index) => {
+        if (this.killed) return {index, filePath: null};
+        if (text.startsWith('silence_stream://')) return {index, filePath: text};
 
         /* otel: trace time for tts */
         if (!preCache && !this._disableTracing)  {
@@ -294,7 +311,6 @@ class TtsTask extends Task {
             renderForCaching: preCache
           });
           if (!filePath.startsWith('say:')) {
-            this.playbackIds.push(null);
             this.logger.debug(`Say: file ${filePath}, served from cache ${servedFromCache}`);
             if (filePath) cs.trackTmpFile(filePath);
             if (this.otelSpan) {
@@ -322,10 +338,11 @@ class TtsTask extends Task {
                 'id': this.id
               });
             }
+            return {index, filePath, playbackId: null};
           }
           else {
-            this.playbackIds.push(extractPlaybackId(filePath));
-            this.logger.debug({playbackIds: this.playbackIds}, 'Say: a streaming tts api will be used');
+            const playbackId = extractPlaybackId(filePath);
+            this.logger.debug('Say: a streaming tts api will be used');
             const modifiedPath = filePath.replace('say:{', `say:{session-uuid=${ep.uuid},`);
             this.notifyStatus({
               event: 'synthesized-audio',
@@ -334,9 +351,8 @@ class TtsTask extends Task {
               servedFromCache,
               'id': this.id
             });
-            return modifiedPath;
+            return {index, filePath: modifiedPath, playbackId};
           }
-          return filePath;
         } catch (err) {
           this.logger.info({err}, 'Error synthesizing tts');
           if (this.otelSpan) this.otelSpan.end();
@@ -351,8 +367,20 @@ class TtsTask extends Task {
         }
       };
 
-      const arr = this.text.map((t) => (this._validateURL(t) ? t : generateAudio(t)));
-      return (await Promise.all(arr)).filter((fp) => fp && fp.length);
+      // process all text segments in parallel will cause ordering issue
+      // so we attach index to each promise result and sort them later
+
+      const arr = this.text.map((t, index) => (this._validateURL(t) ?
+        Promise.resolve({index, filePath: t, playbackId: null}) : generateAudio(t, index)));
+      const results = await Promise.all(arr);
+      const sorted = results.sort((a, b) => a.index - b.index);
+
+      return sorted
+        .filter((fp) => fp.filePath && fp.filePath.length)
+        .map((r) => {
+          this.playbackIds.push(r.playbackId);
+          return r.filePath;
+        });
     } catch (err) {
       this.logger.info(err, 'TaskSay:exec error');
       throw err;

lib/utils/constants.json

@@ -103,6 +103,12 @@
     "Connect": "deepgramflux_transcribe::connect",
     "Error": "deepgramflux_transcribe::error"
   },
+  "GladiaTranscriptionEvents": {
+    "Transcription": "gladia_transcribe::transcription",
+    "ConnectFailure": "gladia_transcribe::connect_failed",
+    "Connect": "gladia_transcribe::connect",
+    "Error": "gladia_transcribe::error"
+  },
   "SonioxTranscriptionEvents": {
     "Transcription": "soniox_transcribe::transcription",
     "Error": "soniox_transcribe::error"
@@ -169,6 +175,12 @@
     "ConnectFailure": "assemblyai_transcribe::connect_failed",
     "Connect": "assemblyai_transcribe::connect"
   },
+  "HoundifyTranscriptionEvents": {
+    "Transcription": "houndify_transcribe::transcription",
+    "Error": "houndify_transcribe::error",
+    "ConnectFailure": "houndify_transcribe::connect_failed",
+    "Connect": "houndify_transcribe::connect"
+  },
   "VoxistTranscriptionEvents": {
     "Transcription": "voxist_transcribe::transcription",
     "Error": "voxist_transcribe::error",
@@ -323,7 +335,8 @@
     "Empty": "tts_streaming::empty",
     "Pause": "tts_streaming::pause",
     "Resume": "tts_streaming::resume",
-    "ConnectFailure": "tts_streaming::connect_failed"
+    "ConnectFailure": "tts_streaming::connect_failed",
+    "Connected": "tts_streaming::connected"
   },
   "TtsStreamingConnectionStatus": {
     "NotConnected": "not_connected",
@@ -343,5 +356,8 @@
   "WS_CLOSE_CODES": {
     "NormalClosure": 1000,
     "GoingAway": 1001
-  }
+  },
+  "NON_FANTAL_ERRORS": [
+    "File Not Found"
+  ]
 }

lib/utils/db-utils.js

@@ -81,6 +81,11 @@ const speechMapper = (cred) => {
       obj.deepgram_tts_uri = o.deepgram_tts_uri;
       obj.deepgram_stt_use_tls = o.deepgram_stt_use_tls;
     }
+    else if ('gladia' === obj.vendor) {
+      const o = JSON.parse(decrypt(credential));
+      obj.api_key = o.api_key;
+      obj.region = o.region;
+    }
     else if ('deepgramflux' === obj.vendor) {
       const o = JSON.parse(decrypt(credential));
       obj.api_key = o.api_key;
@@ -101,6 +106,7 @@ const speechMapper = (cred) => {
       const o = JSON.parse(decrypt(credential));
       obj.api_key = o.api_key;
       obj.model_id = o.model_id;
+      obj.api_uri = o.api_uri;
       obj.options = o.options;
     }
     else if ('playht' === obj.vendor) {
@@ -141,6 +147,12 @@ const speechMapper = (cred) => {
       obj.api_key = o.api_key;
       obj.service_version = o.service_version;
     }
+    else if ('houndify' === obj.vendor) {
+      const o = JSON.parse(decrypt(credential));
+      obj.client_id = o.client_id;
+      obj.client_key = o.client_key;
+      obj.user_id = o.user_id;
+    }
     else if ('voxist' === obj.vendor) {
       const o = JSON.parse(decrypt(credential));
       obj.api_key = o.api_key;

lib/utils/transcription-utils.js

@@ -131,6 +131,43 @@ const stickyVars = {
     'OPENAI_TURN_DETECTION_PREFIX_PADDING_MS',
     'OPENAI_TURN_DETECTION_SILENCE_DURATION_MS',
   ],
+  houndify: [
+    'HOUNDIFY_CLIENT_ID',
+    'HOUNDIFY_CLIENT_KEY',
+    'HOUNDIFY_USER_ID',
+    'HOUNDIFY_MAX_SILENCE_SECONDS',
+    'HOUNDIFY_MAX_SILENCE_AFTER_FULL_QUERY_SECONDS',
+    'HOUNDIFY_MAX_SILENCE_AFTER_PARTIAL_QUERY_SECONDS',
+    'HOUNDIFY_VAD_SENSITIVITY',
+    'HOUNDIFY_VAD_TIMEOUT',
+    'HOUNDIFY_VAD_MODE',
+    'HOUNDIFY_VAD_VOICE_MS',
+    'HOUNDIFY_VAD_SILENCE_MS',
+    'HOUNDIFY_VAD_DEBUG',
+    'HOUNDIFY_AUDIO_FORMAT',
+    'HOUNDIFY_ENABLE_NOISE_REDUCTION',
+    'HOUNDIFY_AUDIO_ENDPOINT',
+    'HOUNDIFY_ENABLE_PROFANITY_FILTER',
+    'HOUNDIFY_ENABLE_PUNCTUATION',
+    'HOUNDIFY_ENABLE_CAPITALIZATION',
+    'HOUNDIFY_CONFIDENCE_THRESHOLD',
+    'HOUNDIFY_ENABLE_DISFLUENCY_FILTER',
+    'HOUNDIFY_MAX_RESULTS',
+    'HOUNDIFY_ENABLE_WORD_TIMESTAMPS',
+    'HOUNDIFY_MAX_ALTERNATIVES',
+    'HOUNDIFY_PARTIAL_TRANSCRIPT_INTERVAL',
+    'HOUNDIFY_SESSION_TIMEOUT',
+    'HOUNDIFY_CONNECTION_TIMEOUT',
+    'HOUNDIFY_LATITUDE',
+    'HOUNDIFY_LONGITUDE',
+    'HOUNDIFY_CITY',
+    'HOUNDIFY_STATE',
+    'HOUNDIFY_COUNTRY',
+    'HOUNDIFY_TIMEZONE',
+    'HOUNDIFY_DOMAIN',
+    'HOUNDIFY_CUSTOM_VOCABULARY',
+    'HOUNDIFY_LANGUAGE_MODEL'
+  ],
 };
 
 /**
@@ -339,6 +376,30 @@ const normalizeDeepgram = (evt, channel, language, shortUtterance) => {
   };
 };
 
+const normalizeGladia = (evt, channel, language, shortUtterance) => {
+  const copy = JSON.parse(JSON.stringify(evt));
+
+  // Handle Gladia transcript format
+  if (evt.type === 'transcript' && evt.data && evt.data.utterance) {
+    const utterance = evt.data.utterance;
+    const alternatives = [{
+      confidence: utterance.confidence || 0,
+      transcript: utterance.text || '',
+    }];
+
+    return {
+      language_code: utterance.language || language,
+      channel_tag: channel,
+      is_final: evt.data.is_final || false,
+      alternatives,
+      vendor: {
+        name: 'gladia',
+        evt: copy
+      }
+    };
+  }
+};
+
 const normalizeDeepgramFlux = (evt, channel, language) => {
   const copy = JSON.parse(JSON.stringify(evt));
 
@@ -582,6 +643,30 @@ const normalizeAssemblyAi = (evt, channel, language) => {
   };
 };
 
+const normalizeHoundify = (evt, channel, language) => {
+  const copy = JSON.parse(JSON.stringify(evt));
+  const alternatives = [];
+  const is_final = evt.ResultsAreFinal && evt.ResultsAreFinal[0] === true;
+  if (evt.Disambiguation && evt.Disambiguation.ChoiceData && evt.Disambiguation.ChoiceData.length > 0) {
+    // Handle Houndify Voice Search Result format
+    const choiceData = evt.Disambiguation.ChoiceData[0];
+    alternatives.push({
+      confidence: choiceData.ConfidenceScore || choiceData.ASRConfidence || 0.0,
+      transcript: choiceData.FormattedTranscription || choiceData.Transcription || '',
+    });
+  }
+  return {
+    language_code: language,
+    channel_tag: channel,
+    is_final,
+    alternatives,
+    vendor: {
+      name: 'houndify',
+      evt: copy
+    }
+  };
+};
+
 const normalizeVoxist = (evt, channel, language) => {
   const copy = JSON.parse(JSON.stringify(evt));
   return {
@@ -681,6 +766,8 @@ module.exports = (logger) => {
     switch (vendor) {
       case 'deepgram':
         return normalizeDeepgram(evt, channel, language, shortUtterance);
+      case 'gladia':
+        return normalizeGladia(evt, channel, language, shortUtterance);
       case 'deepgramflux':
         return normalizeDeepgramFlux(evt, channel, language, shortUtterance);
       case 'microsoft':
@@ -701,6 +788,8 @@ module.exports = (logger) => {
         return normalizeCobalt(evt, channel, language);
       case 'assemblyai':
         return normalizeAssemblyAi(evt, channel, language, shortUtterance);
+      case 'houndify':
+        return normalizeHoundify(evt, channel, language, shortUtterance);
       case 'voxist':
         return normalizeVoxist(evt, channel, language);
       case 'cartesia':
@@ -996,6 +1085,13 @@ module.exports = (logger) => {
         ...(keyterms && keyterms.length > 0 && {DEEPGRAMFLUX_SPEECH_KEYTERMS: keyterms.join(',')}),
       };
     }
+    else if ('gladia' === vendor) {
+      const {host, path} = sttCredentials;
+      opts = {
+        GLADIA_SPEECH_HOST: host,
+        GLADIA_SPEECH_PATH: path,
+      };
+    }
     else if ('soniox' === vendor) {
       const {sonioxOptions = {}} = rOpts;
       const {storage = {}} = sonioxOptions;
@@ -1122,6 +1218,57 @@ module.exports = (logger) => {
           {ASSEMBLYAI_WORD_BOOST: JSON.stringify(rOpts.hints)})
       };
     }
+    else if ('houndify' === vendor) {
+      const {
+        latitude, longitude, city, state, country, timeZone, domain, audioEndpoint,
+        maxSilenceSeconds, maxSilenceAfterFullQuerySeconds, maxSilenceAfterPartialQuerySeconds,
+        vadSensitivity, vadTimeout, vadMode, vadVoiceMs, vadSilenceMs, vadDebug,
+        audioFormat, enableNoiseReduction, enableProfanityFilter, enablePunctuation,
+        enableCapitalization, confidenceThreshold, enableDisfluencyFilter,
+        maxResults, enableWordTimestamps, maxAlternatives, partialTranscriptInterval,
+        sessionTimeout, connectionTimeout, customVocabulary, languageModel
+      } = rOpts.houndifyOptions || {};
+
+      opts = {
+        ...opts,
+        HOUNDIFY_CLIENT_ID: sttCredentials.client_id,
+        HOUNDIFY_CLIENT_KEY: sttCredentials.client_key,
+        HOUNDIFY_USER_ID: sttCredentials.user_id,
+        HOUNDIFY_MAX_SILENCE_SECONDS: maxSilenceSeconds || 5,
+        HOUNDIFY_MAX_SILENCE_AFTER_FULL_QUERY_SECONDS: maxSilenceAfterFullQuerySeconds || 1,
+        HOUNDIFY_MAX_SILENCE_AFTER_PARTIAL_QUERY_SECONDS: maxSilenceAfterPartialQuerySeconds || 1.5,
+        ...(vadSensitivity && {HOUNDIFY_VAD_SENSITIVITY: vadSensitivity}),
+        ...(vadTimeout && {HOUNDIFY_VAD_TIMEOUT: vadTimeout}),
+        ...(vadMode && {HOUNDIFY_VAD_MODE: vadMode}),
+        ...(vadVoiceMs && {HOUNDIFY_VAD_VOICE_MS: vadVoiceMs}),
+        ...(vadSilenceMs && {HOUNDIFY_VAD_SILENCE_MS: vadSilenceMs}),
+        ...(vadDebug && {HOUNDIFY_VAD_DEBUG: vadDebug}),
+        ...(audioFormat && {HOUNDIFY_AUDIO_FORMAT: audioFormat}),
+        ...(enableNoiseReduction && {HOUNDIFY_ENABLE_NOISE_REDUCTION: enableNoiseReduction}),
+        ...(enableProfanityFilter && {HOUNDIFY_ENABLE_PROFANITY_FILTER: enableProfanityFilter}),
+        ...(enablePunctuation && {HOUNDIFY_ENABLE_PUNCTUATION: enablePunctuation}),
+        ...(enableCapitalization && {HOUNDIFY_ENABLE_CAPITALIZATION: enableCapitalization}),
+        ...(confidenceThreshold && {HOUNDIFY_CONFIDENCE_THRESHOLD: confidenceThreshold}),
+        ...(enableDisfluencyFilter && {HOUNDIFY_ENABLE_DISFLUENCY_FILTER: enableDisfluencyFilter}),
+        ...(maxResults && {HOUNDIFY_MAX_RESULTS: maxResults}),
+        ...(enableWordTimestamps && {HOUNDIFY_ENABLE_WORD_TIMESTAMPS: enableWordTimestamps}),
+        ...(maxAlternatives && {HOUNDIFY_MAX_ALTERNATIVES: maxAlternatives}),
+        ...(partialTranscriptInterval && {HOUNDIFY_PARTIAL_TRANSCRIPT_INTERVAL: partialTranscriptInterval}),
+        ...(sessionTimeout && {HOUNDIFY_SESSION_TIMEOUT: sessionTimeout}),
+        ...(connectionTimeout && {HOUNDIFY_CONNECTION_TIMEOUT: connectionTimeout}),
+        ...(latitude && {HOUNDIFY_LATITUDE: latitude}),
+        ...(longitude && {HOUNDIFY_LONGITUDE: longitude}),
+        ...(city && {HOUNDIFY_CITY: city}),
+        ...(state && {HOUNDIFY_STATE: state}),
+        ...(country && {HOUNDIFY_COUNTRY: country}),
+        ...(timeZone && {HOUNDIFY_TIMEZONE: timeZone}),
+        ...(domain && {HOUNDIFY_DOMAIN: domain}),
+        ...(audioEndpoint && {HOUNDIFY_AUDIO_ENDPOINT: audioEndpoint}),
+        ...(customVocabulary && {HOUNDIFY_CUSTOM_VOCABULARY:
+          Array.isArray(customVocabulary) ? customVocabulary.join(',') : customVocabulary}),
+        ...(languageModel && {HOUNDIFY_LANGUAGE_MODEL: languageModel}),
+      };
+    }
     else if ('voxist' === vendor) {
       opts = {
         ...opts,

lib/utils/tts-streaming-buffer.js

@@ -80,7 +80,7 @@ class TtsStreamingBuffer extends Emitter {
     clearTimeout(this.timer);
     this.removeCustomEventListeners();
     if (this.ep) {
-      this._api(this.ep, [this.ep.uuid, 'close'])
+      this._api(this.ep, [this.ep.uuid, 'stop'])
         .catch((err) =>
           this.logger.info({ err }, 'TtsStreamingBuffer:stop Error closing TTS streaming')
         );
@@ -193,10 +193,7 @@ class TtsStreamingBuffer extends Emitter {
         this.logger.debug('TtsStreamingBuffer:_feedQueue TTS stream is not open or no endpoint available');
         return;
       }
-      if (
-        this._connectionStatus === TtsStreamingConnectionStatus.NotConnected ||
-        this._connectionStatus === TtsStreamingConnectionStatus.Failed
-      ) {
+      if (this._connectionStatus !== TtsStreamingConnectionStatus.Connected) {
         this.logger.debug('TtsStreamingBuffer:_feedQueue TTS stream is not connected');
         return;
       }
@@ -278,6 +275,14 @@ class TtsStreamingBuffer extends Emitter {
       }
       const chunk = combinedText.slice(0, chunkEnd);
 
+      // Check if the chunk is only whitespace before processing the queue
+      // If so, wait for more meaningful text
+      if (isWhitespace(chunk)) {
+        this.logger.debug('TtsStreamingBuffer:_feedQueue chunk is only whitespace, waiting for more text');
+        this._setTimerIfNeeded();
+        return;
+      }
+
       // Now we iterate over the queue items
       // and deduct their lengths until we've accounted for chunkEnd characters.
       let remaining = chunkEnd;
@@ -301,6 +306,14 @@ class TtsStreamingBuffer extends Emitter {
       this.bufferedLength -= chunkEnd;
 
       const modifiedChunk = chunk.replace(/\n\n/g, '\n \n');
+
+      if (isWhitespace(modifiedChunk)) {
+        this.logger.debug('TtsStreamingBuffer:_feedQueue modified chunk is only whitespace, restoring queue');
+        this.queue.unshift({ type: 'text', value: chunk });
+        this.bufferedLength += chunkEnd;
+        this._setTimerIfNeeded();
+        return;
+      }
       this.logger.debug(`TtsStreamingBuffer:_feedQueue sending chunk to tts: ${modifiedChunk}`);
 
       try {
@@ -349,6 +362,7 @@ class TtsStreamingBuffer extends Emitter {
     if (this.queue.length > 0) {
       await this._feedQueue();
     }
+    this.emit(TtsStreamingEvents.Connected, { vendor });
   }
 
   _onConnectFailure(vendor) {
@@ -399,6 +413,7 @@ class TtsStreamingBuffer extends Emitter {
 
   removeCustomEventListeners() {
     this.eventHandlers.forEach((h) => h.ep.removeCustomEventListener(h.event, h.handler));
+    this.eventHandlers.length = 0;
   }
 
   _initHandlers(ep) {

package-lock.json

@@ -11,14 +11,14 @@
       "dependencies": {
         "@aws-sdk/client-auto-scaling": "^3.549.0",
         "@aws-sdk/client-sns": "^3.549.0",
-        "@jambonz/db-helpers": "^0.9.17",
+        "@jambonz/db-helpers": "^0.9.18",
         "@jambonz/http-health-check": "^0.0.1",
         "@jambonz/mw-registrar": "^0.2.7",
         "@jambonz/realtimedb-helpers": "^0.8.15",
-        "@jambonz/speech-utils": "^0.2.24",
+        "@jambonz/speech-utils": "^0.2.26",
         "@jambonz/stats-collector": "^0.1.10",
         "@jambonz/time-series": "^0.2.14",
-        "@jambonz/verb-specifications": "^0.0.116",
+        "@jambonz/verb-specifications": "^0.0.119",
         "@modelcontextprotocol/sdk": "^1.9.0",
         "@opentelemetry/api": "^1.8.0",
         "@opentelemetry/exporter-jaeger": "^1.23.0",
@@ -33,12 +33,12 @@
         "debug": "^4.3.4",
         "deepcopy": "^2.1.0",
         "drachtio-fsmrf": "^4.1.2",
-        "drachtio-srf": "^5.0.11",
+        "drachtio-srf": "^5.0.14",
         "express": "^4.19.2",
         "express-validator": "^7.0.1",
         "moment": "^2.30.1",
         "parse-url": "^9.2.0",
-        "pino": "^8.20.0",
+        "pino": "^10.1.0",
         "polly-ssml-split": "^0.1.0",
         "sdp-transform": "^2.15.0",
         "short-uuid": "^5.1.0",
@@ -1253,15 +1253,17 @@
       }
     },
     "node_modules/@cartesia/cartesia-js": {
-      "version": "2.1.1",
+      "version": "2.2.7",
+      "resolved": "https://registry.npmjs.org/@cartesia/cartesia-js/-/cartesia-js-2.2.7.tgz",
+      "integrity": "sha512-yXIK/rEQzY3LPdrFd+oWlW39dxuAb5mnP3NOemaeLiMaRKAYatMdh154NyB3lAf3BgqMXpGWUg46vSzBCDiEnQ==",
       "dependencies": {
         "emittery": "^0.13.1",
         "form-data": "^4.0.0",
         "form-data-encoder": "^4.0.2",
         "formdata-node": "^6.0.3",
         "human-id": "^4.1.1",
-        "node-fetch": "2.7.0",
-        "qs": "6.11.2",
+        "node-fetch": "^2.7.0",
+        "qs": "^6.13.1",
         "readable-stream": "^4.5.2",
         "url-join": "4.0.1",
         "ws": "^8.15.13"
@@ -1284,7 +1286,9 @@
       }
     },
     "node_modules/@cartesia/cartesia-js/node_modules/form-data-encoder": {
-      "version": "4.0.2",
+      "version": "4.1.0",
+      "resolved": "https://registry.npmjs.org/form-data-encoder/-/form-data-encoder-4.1.0.tgz",
+      "integrity": "sha512-G6NsmEW15s0Uw9XnCg+33H3ViYRyiM0hMrMhhqQOR8NFc5GhYrI+6I3u7OTw7b91J2g8rtvMBZJDbcGb2YUniw==",
       "license": "MIT",
       "engines": {
         "node": ">= 18"
@@ -1292,6 +1296,8 @@
     },
     "node_modules/@cartesia/cartesia-js/node_modules/formdata-node": {
       "version": "6.0.3",
+      "resolved": "https://registry.npmjs.org/formdata-node/-/formdata-node-6.0.3.tgz",
+      "integrity": "sha512-8e1++BCiTzUno9v5IZ2J6bv4RU+3UKDmqWUQD0MIMVCd9AdhWkO1gw57oo1mNEX1dMq2EGI+FbWz4B92pscSQg==",
       "license": "MIT",
       "engines": {
         "node": ">= 18"
@@ -1299,16 +1305,20 @@
     },
     "node_modules/@cartesia/cartesia-js/node_modules/process": {
       "version": "0.11.10",
+      "resolved": "https://registry.npmjs.org/process/-/process-0.11.10.tgz",
+      "integrity": "sha512-cdGef/drWFoydD1JsMzuFf8100nZl+GT+yacc2bEced5f9Rjk4z+WtFUTBu9PhOi9j/jfmBPu0mMEY4wIdAF8A==",
       "license": "MIT",
       "engines": {
         "node": ">= 0.6.0"
       }
     },
     "node_modules/@cartesia/cartesia-js/node_modules/qs": {
-      "version": "6.11.2",
+      "version": "6.14.0",
+      "resolved": "https://registry.npmjs.org/qs/-/qs-6.14.0.tgz",
+      "integrity": "sha512-YWWTjgABSKcvs/nWBi9PycY/JiPJqOD4JA6o9Sej2AtvSGarXxKC3OQSk4pAarbdQlKAh5D4FCQkJNkW+GAn3w==",
       "license": "BSD-3-Clause",
       "dependencies": {
-        "side-channel": "^1.0.4"
+        "side-channel": "^1.1.0"
       },
       "engines": {
         "node": ">=0.6"
@@ -1318,7 +1328,9 @@
       }
     },
     "node_modules/@cartesia/cartesia-js/node_modules/readable-stream": {
-      "version": "4.5.2",
+      "version": "4.7.0",
+      "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-4.7.0.tgz",
+      "integrity": "sha512-oIGGmcpTLwPga8Bn6/Z75SVaH1z5dUut2ibSyAMVhmUggWpmDn2dapB0n7f8nwaSiRtepAsfJyfXIO5DCVAODg==",
       "license": "MIT",
       "dependencies": {
         "abort-controller": "^3.0.0",
@@ -1441,9 +1453,9 @@
       }
     },
     "node_modules/@jambonz/db-helpers": {
-      "version": "0.9.17",
-      "resolved": "https://registry.npmjs.org/@jambonz/db-helpers/-/db-helpers-0.9.17.tgz",
-      "integrity": "sha512-LQErcrT/uts83Up9UJVqPPSZy0+CLw/djES3bgUoB600uLz7Wfgpi309XTIjNLikQjDsNFaTneZY0QwDKMCbzg==",
+      "version": "0.9.18",
+      "resolved": "https://registry.npmjs.org/@jambonz/db-helpers/-/db-helpers-0.9.18.tgz",
+      "integrity": "sha512-rrrBzz6UnEW0LV4OXRUzjg2XzwUGNjuJptKPxozvCQYOSuXQsRYcc7AM+p32ssBd+LdTX866pQ0QwRc2cUEAPw==",
       "license": "MIT",
       "dependencies": {
         "cidr-matcher": "^2.1.1",
@@ -1480,14 +1492,15 @@
       }
     },
     "node_modules/@jambonz/speech-utils": {
-      "version": "0.2.24",
-      "resolved": "https://registry.npmjs.org/@jambonz/speech-utils/-/speech-utils-0.2.24.tgz",
-      "integrity": "sha512-8tHtoeF+aWTA6K88iHx4ycK/8AQY0dDzbqilX+KpyoECnjCe2xd2FtRzMo8AWfspnvYk5Abk8kVbJtVKPoBp2g==",
+      "version": "0.2.26",
+      "resolved": "https://registry.npmjs.org/@jambonz/speech-utils/-/speech-utils-0.2.26.tgz",
+      "integrity": "sha512-gL5PBd2zSDCxAgz5cIdiLgkhqGEkW5UizF93BV8xcpMZuzIuLhsr2WlIMY3L3vVpFSx8AtZ9XdgPtxIOqI+FHw==",
+      "license": "MIT",
       "dependencies": {
         "23": "^0.0.0",
         "@aws-sdk/client-polly": "^3.496.0",
         "@aws-sdk/client-sts": "^3.496.0",
-        "@cartesia/cartesia-js": "^2.1.0",
+        "@cartesia/cartesia-js": "^2.2.7",
         "@google-cloud/text-to-speech": "^5.5.0",
         "@grpc/grpc-js": "^1.9.14",
         "@jambonz/realtimedb-helpers": "^0.8.7",
@@ -1520,14 +1533,102 @@
       }
     },
     "node_modules/@jambonz/verb-specifications": {
-      "version": "0.0.116",
-      "resolved": "https://registry.npmjs.org/@jambonz/verb-specifications/-/verb-specifications-0.0.116.tgz",
-      "integrity": "sha512-EFAtwSpSWA12nk7eQfAiWS0bGkCA5+NqKsylnVIXNWuSjRZ5wTS0dAZZZxqtZxPZ1DxdBLCafbLsKZJ4fkC+tQ==",
+      "version": "0.0.119",
+      "resolved": "https://registry.npmjs.org/@jambonz/verb-specifications/-/verb-specifications-0.0.119.tgz",
+      "integrity": "sha512-AQsZ7EY2bBOjdhufKtZpdrhFobo6LBMLkuDJY058Q3qxGBtlZr3Wx9zrlVjJuNOGCEJSmMP7Gr/EtjtFFX2iTw==",
+      "license": "MIT",
       "dependencies": {
         "debug": "^4.3.4",
         "pino": "^8.8.0"
       }
     },
+    "node_modules/@jambonz/verb-specifications/node_modules/pino": {
+      "version": "8.21.0",
+      "resolved": "https://registry.npmjs.org/pino/-/pino-8.21.0.tgz",
+      "integrity": "sha512-ip4qdzjkAyDDZklUaZkcRFb2iA118H9SgRh8yzTkSQK8HilsOJF7rSY8HoW5+I0M46AZgX/pxbprf2vvzQCE0Q==",
+      "license": "MIT",
+      "dependencies": {
+        "atomic-sleep": "^1.0.0",
+        "fast-redact": "^3.1.1",
+        "on-exit-leak-free": "^2.1.0",
+        "pino-abstract-transport": "^1.2.0",
+        "pino-std-serializers": "^6.0.0",
+        "process-warning": "^3.0.0",
+        "quick-format-unescaped": "^4.0.3",
+        "real-require": "^0.2.0",
+        "safe-stable-stringify": "^2.3.1",
+        "sonic-boom": "^3.7.0",
+        "thread-stream": "^2.6.0"
+      },
+      "bin": {
+        "pino": "bin.js"
+      }
+    },
+    "node_modules/@jambonz/verb-specifications/node_modules/pino-abstract-transport": {
+      "version": "1.2.0",
+      "resolved": "https://registry.npmjs.org/pino-abstract-transport/-/pino-abstract-transport-1.2.0.tgz",
+      "integrity": "sha512-Guhh8EZfPCfH+PMXAb6rKOjGQEoy0xlAIn+irODG5kgfYV+BQ0rGYYWTIel3P5mmyXqkYkPmdIkywsn6QKUR1Q==",
+      "license": "MIT",
+      "dependencies": {
+        "readable-stream": "^4.0.0",
+        "split2": "^4.0.0"
+      }
+    },
+    "node_modules/@jambonz/verb-specifications/node_modules/pino-std-serializers": {
+      "version": "6.2.2",
+      "resolved": "https://registry.npmjs.org/pino-std-serializers/-/pino-std-serializers-6.2.2.tgz",
+      "integrity": "sha512-cHjPPsE+vhj/tnhCy/wiMh3M3z3h/j15zHQX+S9GkTBgqJuTuJzYJ4gUyACLhDaJ7kk9ba9iRDmbH2tJU03OiA==",
+      "license": "MIT"
+    },
+    "node_modules/@jambonz/verb-specifications/node_modules/process": {
+      "version": "0.11.10",
+      "resolved": "https://registry.npmjs.org/process/-/process-0.11.10.tgz",
+      "integrity": "sha512-cdGef/drWFoydD1JsMzuFf8100nZl+GT+yacc2bEced5f9Rjk4z+WtFUTBu9PhOi9j/jfmBPu0mMEY4wIdAF8A==",
+      "license": "MIT",
+      "engines": {
+        "node": ">= 0.6.0"
+      }
+    },
+    "node_modules/@jambonz/verb-specifications/node_modules/process-warning": {
+      "version": "3.0.0",
+      "resolved": "https://registry.npmjs.org/process-warning/-/process-warning-3.0.0.tgz",
+      "integrity": "sha512-mqn0kFRl0EoqhnL0GQ0veqFHyIN1yig9RHh/InzORTUiZHFRAur+aMtRkELNwGs9aNwKS6tg/An4NYBPGwvtzQ==",
+      "license": "MIT"
+    },
+    "node_modules/@jambonz/verb-specifications/node_modules/readable-stream": {
+      "version": "4.7.0",
+      "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-4.7.0.tgz",
+      "integrity": "sha512-oIGGmcpTLwPga8Bn6/Z75SVaH1z5dUut2ibSyAMVhmUggWpmDn2dapB0n7f8nwaSiRtepAsfJyfXIO5DCVAODg==",
+      "license": "MIT",
+      "dependencies": {
+        "abort-controller": "^3.0.0",
+        "buffer": "^6.0.3",
+        "events": "^3.3.0",
+        "process": "^0.11.10",
+        "string_decoder": "^1.3.0"
+      },
+      "engines": {
+        "node": "^12.22.0 || ^14.17.0 || >=16.0.0"
+      }
+    },
+    "node_modules/@jambonz/verb-specifications/node_modules/sonic-boom": {
+      "version": "3.8.1",
+      "resolved": "https://registry.npmjs.org/sonic-boom/-/sonic-boom-3.8.1.tgz",
+      "integrity": "sha512-y4Z8LCDBuum+PBP3lSV7RHrXscqksve/bi0as7mhwVnBW+/wUqKT/2Kb7um8yqcFy0duYbbPxzt89Zy2nOCaxg==",
+      "license": "MIT",
+      "dependencies": {
+        "atomic-sleep": "^1.0.0"
+      }
+    },
+    "node_modules/@jambonz/verb-specifications/node_modules/thread-stream": {
+      "version": "2.7.0",
+      "resolved": "https://registry.npmjs.org/thread-stream/-/thread-stream-2.7.0.tgz",
+      "integrity": "sha512-qQiRWsU/wvNolI6tbbCKd9iKaTnCXsTwVxhhKM6nctPdujTyztjlbUkUTUymidWcMnZ5pWR0ej4a0tjsW021vw==",
+      "license": "MIT",
+      "dependencies": {
+        "real-require": "^0.2.0"
+      }
+    },
     "node_modules/@jridgewell/gen-mapping": {
       "version": "0.3.3",
       "dev": true,
@@ -2144,6 +2245,12 @@
         "node": ">=14"
       }
     },
+    "node_modules/@pinojs/redact": {
+      "version": "0.4.0",
+      "resolved": "https://registry.npmjs.org/@pinojs/redact/-/redact-0.4.0.tgz",
+      "integrity": "sha512-k2ENnmBugE/rzQfEcdWHcCY+/FM3VLzH9cYEsbdsoqrvzAKRhUZeRNhAZvB8OitQJ1TBed3yqWtdjzS6wJKBwg==",
+      "license": "MIT"
+    },
     "node_modules/@protobufjs/aspromise": {
       "version": "1.1.2",
       "license": "BSD-3-Clause"
@@ -3075,6 +3182,8 @@
     },
     "node_modules/atomic-sleep": {
       "version": "1.0.0",
+      "resolved": "https://registry.npmjs.org/atomic-sleep/-/atomic-sleep-1.0.0.tgz",
+      "integrity": "sha512-kNOjDqAh7px0XWNI+4QbzoiR/nTkHAWNud2uvnJquD1/x5a7EQZMJT0AczqK0Qn67oY/TTQ1LbUKajZpp3I9tQ==",
       "license": "MIT",
       "engines": {
         "node": ">=8.0.0"
@@ -3104,9 +3213,9 @@
       }
     },
     "node_modules/axios": {
-      "version": "1.12.2",
-      "resolved": "https://registry.npmjs.org/axios/-/axios-1.12.2.tgz",
-      "integrity": "sha512-vMJzPewAlRyOgxV2dU0Cuz2O8zzzx9VYtbJOaBgXFeLc4IV/Eg50n4LowmehOOR61S8ZMpc2K5Sa7g6A4jfkUw==",
+      "version": "1.13.1",
+      "resolved": "https://registry.npmjs.org/axios/-/axios-1.13.1.tgz",
+      "integrity": "sha512-hU4EGxxt+j7TQijx1oYdAjw4xuIp1wRQSsbMFwSthCWeBQur1eF+qJ5iQ5sN3Tw8YRzQNKb8jszgBdMDVqwJcw==",
       "license": "MIT",
       "dependencies": {
         "follow-redirects": "^1.15.6",
@@ -3654,9 +3763,9 @@
       }
     },
     "node_modules/debug": {
-      "version": "4.4.1",
-      "resolved": "https://registry.npmjs.org/debug/-/debug-4.4.1.tgz",
-      "integrity": "sha512-KcKCqiftBJcZr++7ykoDIEwSa3XWowTfNPo92BYxjXiyYEVrUQh2aLyhxBCwww+heortUFxEJYcRzosstTEBYQ==",
+      "version": "4.4.3",
+      "resolved": "https://registry.npmjs.org/debug/-/debug-4.4.3.tgz",
+      "integrity": "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA==",
       "license": "MIT",
       "dependencies": {
         "ms": "^2.1.3"
@@ -3892,42 +4001,31 @@
       }
     },
     "node_modules/drachtio-srf": {
-      "version": "5.0.13",
-      "resolved": "https://registry.npmjs.org/drachtio-srf/-/drachtio-srf-5.0.13.tgz",
-      "integrity": "sha512-IG62MLLzhXjQtbjX6T6I8jXK6QhWQwsblkO3+F2Zhcu4lXBO3W12rrKyAPsw6GimRSSXIkvMbn5/je8AU/xehQ==",
+      "version": "5.0.14",
+      "resolved": "https://registry.npmjs.org/drachtio-srf/-/drachtio-srf-5.0.14.tgz",
+      "integrity": "sha512-EOSuhdg1wTITbm69/Jh4i5WnHhSltgYZqkwAoNlpf/GuJUPOYJVt3QPRuhGHpkGKHGMn/jyKT4YJ6vzhBmGnXQ==",
+      "license": "MIT",
       "dependencies": {
-        "debug": "^3.2.7",
-        "delegates": "^0.1.0",
-        "node-noop": "^0.0.1",
+        "debug": "^4.4.3",
+        "delegates": "^1.0.0",
+        "node-noop": "^1.0.0",
         "only": "^0.0.2",
         "sdp-transform": "^2.15.0",
-        "short-uuid": "^4.2.2",
+        "short-uuid": "^5.2.0",
         "sip-methods": "^0.3.0",
         "sip-status": "^0.1.0",
-        "utils-merge": "^1.0.0",
+        "utils-merge": "^1.0.1",
         "uuid-random": "^1.3.2"
       },
       "engines": {
         "node": ">= 18.x"
       }
     },
-    "node_modules/drachtio-srf/node_modules/debug": {
-      "version": "3.2.7",
-      "license": "MIT",
-      "dependencies": {
-        "ms": "^2.1.1"
-      }
-    },
-    "node_modules/drachtio-srf/node_modules/short-uuid": {
-      "version": "4.2.2",
-      "license": "MIT",
-      "dependencies": {
-        "any-base": "^1.1.0",
-        "uuid": "^8.3.2"
-      },
-      "engines": {
-        "node": ">=8"
-      }
+    "node_modules/drachtio-srf/node_modules/delegates": {
+      "version": "1.0.0",
+      "resolved": "https://registry.npmjs.org/delegates/-/delegates-1.0.0.tgz",
+      "integrity": "sha512-bd2L678uiWATM6m5Z1VzNCErI3jiGzt6HGY8OVICs40JQq/HALfbyNJmp0UDakEY4pMMaN0Ly5om/B1VI/+xfQ==",
+      "license": "MIT"
     },
     "node_modules/dunder-proto": {
       "version": "1.0.1",
@@ -3971,6 +4069,8 @@
     },
     "node_modules/emittery": {
       "version": "0.13.1",
+      "resolved": "https://registry.npmjs.org/emittery/-/emittery-0.13.1.tgz",
+      "integrity": "sha512-DeWwawk6r5yR9jFgnDKYt4sLS0LmHJJi3ZOnb5/JdbYwj3nW+FxQnHIjhBKz8YLC7oRNPVM9NQ47I3CVx34eqQ==",
       "license": "MIT",
       "engines": {
         "node": ">=12"
@@ -5349,7 +5449,9 @@
       }
     },
     "node_modules/human-id": {
-      "version": "4.1.1",
+      "version": "4.1.2",
+      "resolved": "https://registry.npmjs.org/human-id/-/human-id-4.1.2.tgz",
+      "integrity": "sha512-v/J+4Z/1eIJovEBdlV5TYj1IR+ZiohcYGRY+qN/oC9dAfKzVT023N/Bgw37hrKCoVRBvk3bqyzpr2PP5YeTMSg==",
       "license": "MIT",
       "bin": {
         "human-id": "dist/cli.js"
@@ -6718,8 +6820,10 @@
       "license": "MIT"
     },
     "node_modules/node-noop": {
-      "version": "0.0.1",
-      "license": "BSD 2-Clause"
+      "version": "1.0.0",
+      "resolved": "https://registry.npmjs.org/node-noop/-/node-noop-1.0.0.tgz",
+      "integrity": "sha512-1lpWqKwZ9yUosQfW1uy3jm6St4ZbmeDKKGmdzwzedbyBI4LgHtGyL1ofDdqiSomgaYaSERi+qWtj64huJQjl7g==",
+      "license": "BSD-2-Clause"
     },
     "node_modules/node-object-hash": {
       "version": "2.3.10",
@@ -7161,64 +7265,40 @@
       "license": "ISC"
     },
     "node_modules/pino": {
-      "version": "8.21.0",
-      "resolved": "https://registry.npmjs.org/pino/-/pino-8.21.0.tgz",
-      "integrity": "sha512-ip4qdzjkAyDDZklUaZkcRFb2iA118H9SgRh8yzTkSQK8HilsOJF7rSY8HoW5+I0M46AZgX/pxbprf2vvzQCE0Q==",
+      "version": "10.1.0",
+      "resolved": "https://registry.npmjs.org/pino/-/pino-10.1.0.tgz",
+      "integrity": "sha512-0zZC2ygfdqvqK8zJIr1e+wT1T/L+LF6qvqvbzEQ6tiMAoTqEVK9a1K3YRu8HEUvGEvNqZyPJTtb2sNIoTkB83w==",
       "license": "MIT",
       "dependencies": {
+        "@pinojs/redact": "^0.4.0",
         "atomic-sleep": "^1.0.0",
-        "fast-redact": "^3.1.1",
         "on-exit-leak-free": "^2.1.0",
-        "pino-abstract-transport": "^1.2.0",
-        "pino-std-serializers": "^6.0.0",
-        "process-warning": "^3.0.0",
+        "pino-abstract-transport": "^2.0.0",
+        "pino-std-serializers": "^7.0.0",
+        "process-warning": "^5.0.0",
         "quick-format-unescaped": "^4.0.3",
         "real-require": "^0.2.0",
         "safe-stable-stringify": "^2.3.1",
-        "sonic-boom": "^3.7.0",
-        "thread-stream": "^2.6.0"
+        "sonic-boom": "^4.0.1",
+        "thread-stream": "^3.0.0"
       },
       "bin": {
         "pino": "bin.js"
       }
     },
     "node_modules/pino-abstract-transport": {
-      "version": "1.2.0",
-      "resolved": "https://registry.npmjs.org/pino-abstract-transport/-/pino-abstract-transport-1.2.0.tgz",
-      "integrity": "sha512-Guhh8EZfPCfH+PMXAb6rKOjGQEoy0xlAIn+irODG5kgfYV+BQ0rGYYWTIel3P5mmyXqkYkPmdIkywsn6QKUR1Q==",
+      "version": "2.0.0",
+      "resolved": "https://registry.npmjs.org/pino-abstract-transport/-/pino-abstract-transport-2.0.0.tgz",
+      "integrity": "sha512-F63x5tizV6WCh4R6RHyi2Ml+M70DNRXt/+HANowMflpgGFMAym/VKm6G7ZOQRjqN7XbGxK1Lg9t6ZrtzOaivMw==",
       "license": "MIT",
       "dependencies": {
-        "readable-stream": "^4.0.0",
         "split2": "^4.0.0"
       }
     },
-    "node_modules/pino-abstract-transport/node_modules/process": {
-      "version": "0.11.10",
-      "resolved": "https://registry.npmjs.org/process/-/process-0.11.10.tgz",
-      "integrity": "sha512-cdGef/drWFoydD1JsMzuFf8100nZl+GT+yacc2bEced5f9Rjk4z+WtFUTBu9PhOi9j/jfmBPu0mMEY4wIdAF8A==",
-      "license": "MIT",
-      "engines": {
-        "node": ">= 0.6.0"
-      }
-    },
-    "node_modules/pino-abstract-transport/node_modules/readable-stream": {
-      "version": "4.7.0",
-      "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-4.7.0.tgz",
-      "integrity": "sha512-oIGGmcpTLwPga8Bn6/Z75SVaH1z5dUut2ibSyAMVhmUggWpmDn2dapB0n7f8nwaSiRtepAsfJyfXIO5DCVAODg==",
-      "license": "MIT",
-      "dependencies": {
-        "abort-controller": "^3.0.0",
-        "buffer": "^6.0.3",
-        "events": "^3.3.0",
-        "process": "^0.11.10",
-        "string_decoder": "^1.3.0"
-      },
-      "engines": {
-        "node": "^12.22.0 || ^14.17.0 || >=16.0.0"
-      }
-    },
     "node_modules/pino-std-serializers": {
-      "version": "6.2.1",
+      "version": "7.0.0",
+      "resolved": "https://registry.npmjs.org/pino-std-serializers/-/pino-std-serializers-7.0.0.tgz",
+      "integrity": "sha512-e906FRY0+tV27iq4juKzSYPbUj2do2X2JX4EzSca1631EB2QJQUqGbDuERal7LCtOpxl6x3+nvo9NPZcmjkiFA==",
       "license": "MIT"
     },
     "node_modules/pkce-challenge": {
@@ -7286,7 +7366,19 @@
       }
     },
     "node_modules/process-warning": {
-      "version": "3.0.0",
+      "version": "5.0.0",
+      "resolved": "https://registry.npmjs.org/process-warning/-/process-warning-5.0.0.tgz",
+      "integrity": "sha512-a39t9ApHNx2L4+HBnQKqxxHNs1r7KF+Intd8Q/g1bUh6q0WIp9voPXJ/x0j+ZL45KF1pJd9+q2jLIRMfvEshkA==",
+      "funding": [
+        {
+          "type": "github",
+          "url": "https://github.com/sponsors/fastify"
+        },
+        {
+          "type": "opencollective",
+          "url": "https://opencollective.com/fastify"
+        }
+      ],
       "license": "MIT"
     },
     "node_modules/progress": {
@@ -7871,7 +7963,9 @@
       "license": "BSD-2-Clause"
     },
     "node_modules/short-uuid": {
-      "version": "5.1.0",
+      "version": "5.2.0",
+      "resolved": "https://registry.npmjs.org/short-uuid/-/short-uuid-5.2.0.tgz",
+      "integrity": "sha512-296/Nzi4DmANh93iYBwT4NoYRJuHnKEzefrkSagQbTH/A6NTaB68hSPDjm5IlbI5dx9FXdmtqPcj6N5H+CPm6w==",
       "license": "MIT",
       "dependencies": {
         "any-base": "^1.1.0",
@@ -8018,7 +8112,9 @@
       }
     },
     "node_modules/sonic-boom": {
-      "version": "3.8.1",
+      "version": "4.2.0",
+      "resolved": "https://registry.npmjs.org/sonic-boom/-/sonic-boom-4.2.0.tgz",
+      "integrity": "sha512-INb7TM37/mAcsGmc9hyyI6+QR3rR1zVRu36B0NeGXKnOOLiZOfER5SA+N7X7k3yUYRzLWafduTDvJAfDswwEww==",
       "license": "MIT",
       "dependencies": {
         "atomic-sleep": "^1.0.0"
@@ -8397,9 +8493,9 @@
       "license": "MIT"
     },
     "node_modules/thread-stream": {
-      "version": "2.7.0",
-      "resolved": "https://registry.npmjs.org/thread-stream/-/thread-stream-2.7.0.tgz",
-      "integrity": "sha512-qQiRWsU/wvNolI6tbbCKd9iKaTnCXsTwVxhhKM6nctPdujTyztjlbUkUTUymidWcMnZ5pWR0ej4a0tjsW021vw==",
+      "version": "3.1.0",
+      "resolved": "https://registry.npmjs.org/thread-stream/-/thread-stream-3.1.0.tgz",
+      "integrity": "sha512-OqyPZ9u96VohAyMfJykzmivOrY2wfMSf3C5TtFJVgN+Hm6aj+voFhlK+kZEIv2FBh1X6Xp3DlnCOfEQ3B2J86A==",
       "license": "MIT",
       "dependencies": {
         "real-require": "^0.2.0"
@@ -8708,6 +8804,8 @@
     },
     "node_modules/url-join": {
       "version": "4.0.1",
+      "resolved": "https://registry.npmjs.org/url-join/-/url-join-4.0.1.tgz",
+      "integrity": "sha512-jk1+QP6ZJqyOiuEI9AEWQfju/nB2Pw466kbA0LEZljHwKeMgd9WrAEgEGxjPDD2+TNbbb37rTyhEfrCXfuKXnA==",
       "license": "MIT"
     },
     "node_modules/url-parse": {
@@ -8760,7 +8858,9 @@
       "license": "MIT"
     },
     "node_modules/validator": {
-      "version": "13.11.0",
+      "version": "13.15.20",
+      "resolved": "https://registry.npmjs.org/validator/-/validator-13.15.20.tgz",
+      "integrity": "sha512-KxPOq3V2LmfQPP4eqf3Mq/zrT0Dqp2Vmx2Bn285LwVahLc+CsxOM0crBHczm8ijlcjZ0Q5Xd6LW3z3odTPnlrw==",
       "license": "MIT",
       "engines": {
         "node": ">= 0.10"

package.json

@@ -27,14 +27,14 @@
   "dependencies": {
     "@aws-sdk/client-auto-scaling": "^3.549.0",
     "@aws-sdk/client-sns": "^3.549.0",
-    "@jambonz/db-helpers": "^0.9.17",
+    "@jambonz/db-helpers": "^0.9.18",
     "@jambonz/http-health-check": "^0.0.1",
     "@jambonz/mw-registrar": "^0.2.7",
     "@jambonz/realtimedb-helpers": "^0.8.15",
-    "@jambonz/speech-utils": "^0.2.24",
+    "@jambonz/speech-utils": "^0.2.26",
     "@jambonz/stats-collector": "^0.1.10",
     "@jambonz/time-series": "^0.2.14",
-    "@jambonz/verb-specifications": "^0.0.116",
+    "@jambonz/verb-specifications": "^0.0.119",
     "@modelcontextprotocol/sdk": "^1.9.0",
     "@opentelemetry/api": "^1.8.0",
     "@opentelemetry/exporter-jaeger": "^1.23.0",
@@ -49,12 +49,12 @@
     "debug": "^4.3.4",
     "deepcopy": "^2.1.0",
     "drachtio-fsmrf": "^4.1.2",
-    "drachtio-srf": "^5.0.11",
+    "drachtio-srf": "^5.0.14",
     "express": "^4.19.2",
     "express-validator": "^7.0.1",
     "moment": "^2.30.1",
     "parse-url": "^9.2.0",
-    "pino": "^8.20.0",
+    "pino": "^10.1.0",
     "polly-ssml-split": "^0.1.0",
     "sdp-transform": "^2.15.0",
     "short-uuid": "^5.1.0",

test/webhooks-tests.js

@@ -83,7 +83,8 @@ test('invalid jambonz json create alert tests', async(t) => {
       {account_sid: 'bb845d4b-83a9-4cde-a6e9-50f3743bab3f', page: 1, page_size: 25, days: 7});
     let checked = false;
     for (let i = 0; i < data.total; i++) {
-      checked = data.data[i].message === 'malformed jambonz payload: must be array'
+      checked = data.data[i].message === 'malformed jambonz payload: must be array';
+      if (checked) break;
     }
     t.ok(checked, 'alert is raised as expected');
     disconnect();