escape json special chars in metadata (#1399)

* add customerData on transferred calls

* change to if statement

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

@@ -1086,6 +1086,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,
@@ -1166,6 +1173,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,

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/gather.js

@@ -5,12 +5,14 @@ const {
   AwsTranscriptionEvents,
   AzureTranscriptionEvents,
   DeepgramTranscriptionEvents,
+  GladiaTranscriptionEvents,
   SonioxTranscriptionEvents,
   CobaltTranscriptionEvents,
   IbmTranscriptionEvents,
   NvidiaTranscriptionEvents,
   JambonzTranscriptionEvents,
   AssemblyAiTranscriptionEvents,
+  HoundifyTranscriptionEvents,
   DeepgramfluxTranscriptionEvents,
   VoxistTranscriptionEvents,
   CartesiaTranscriptionEvents,
@@ -486,6 +488,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(
@@ -563,6 +575,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,

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
+    .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,20 @@ 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)) {
+          this.metadata[key] = escapeString(this.data.metadata[key]);
+        }
+      }
+    }
+
     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/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/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",

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;
@@ -142,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,

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.25",
         "@jambonz/stats-collector": "^0.1.10",
         "@jambonz/time-series": "^0.2.14",
-        "@jambonz/verb-specifications": "^0.0.116",
+        "@jambonz/verb-specifications": "^0.0.118",
         "@modelcontextprotocol/sdk": "^1.9.0",
         "@opentelemetry/api": "^1.8.0",
         "@opentelemetry/exporter-jaeger": "^1.23.0",
@@ -1268,15 +1268,11 @@
       }
     },
     "node_modules/@cartesia/cartesia-js/node_modules/form-data": {
-      "version": "4.0.4",
-      "resolved": "https://registry.npmjs.org/form-data/-/form-data-4.0.4.tgz",
-      "integrity": "sha512-KrGhL9Q4zjj0kiUt5OO4Mr/A/jlI2jDYs5eHBpYHPcBEVSiipAvn2Ko2HnPe20rmcuuvMHNdZFp+4IlGTMF0Ow==",
+      "version": "4.0.1",
       "license": "MIT",
       "dependencies": {
         "asynckit": "^0.4.0",
         "combined-stream": "^1.0.8",
-        "es-set-tostringtag": "^2.1.0",
-        "hasown": "^2.0.2",
         "mime-types": "^2.1.12"
       },
       "engines": {
@@ -1441,9 +1437,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",
@@ -1521,9 +1517,10 @@
       }
     },
     "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.118",
+      "resolved": "https://registry.npmjs.org/@jambonz/verb-specifications/-/verb-specifications-0.0.118.tgz",
+      "integrity": "sha512-1dGnc6TUCehjt1yGNuqh1uzk1xw9HhUm39aVUosQMHlnT0fK0ItikeJ0uttTjFastHNmPPxqJwb20wOvVGTCFg==",
+      "license": "MIT",
       "dependencies": {
         "debug": "^4.3.4",
         "pino": "^8.8.0"
@@ -2788,9 +2785,9 @@
       }
     },
     "node_modules/@types/node-fetch/node_modules/form-data": {
-      "version": "4.0.4",
-      "resolved": "https://registry.npmjs.org/form-data/-/form-data-4.0.4.tgz",
-      "integrity": "sha512-KrGhL9Q4zjj0kiUt5OO4Mr/A/jlI2jDYs5eHBpYHPcBEVSiipAvn2Ko2HnPe20rmcuuvMHNdZFp+4IlGTMF0Ow==",
+      "version": "4.0.3",
+      "resolved": "https://registry.npmjs.org/form-data/-/form-data-4.0.3.tgz",
+      "integrity": "sha512-qsITQPfmvMOSAdeyZ+12I1c+CKSstAFAwu+97zrnWAbIr5u8wfsExUzCesVLC8NgHuRUqNN4Zy6UPWUTRGslcA==",
       "license": "MIT",
       "dependencies": {
         "asynckit": "^0.4.0",
@@ -3105,20 +3102,20 @@
       }
     },
     "node_modules/axios": {
-      "version": "1.12.2",
-      "resolved": "https://registry.npmjs.org/axios/-/axios-1.12.2.tgz",
-      "integrity": "sha512-vMJzPewAlRyOgxV2dU0Cuz2O8zzzx9VYtbJOaBgXFeLc4IV/Eg50n4LowmehOOR61S8ZMpc2K5Sa7g6A4jfkUw==",
+      "version": "1.10.0",
+      "resolved": "https://registry.npmjs.org/axios/-/axios-1.10.0.tgz",
+      "integrity": "sha512-/1xYAC4MP/HEG+3duIhFr4ZQXR4sQXOIe+o6sdqzeykGLx6Upp/1p8MHqhINOvGeP7xyNHe7tsiJByc4SSVUxw==",
       "license": "MIT",
       "dependencies": {
         "follow-redirects": "^1.15.6",
-        "form-data": "^4.0.4",
+        "form-data": "^4.0.0",
         "proxy-from-env": "^1.1.0"
       }
     },
     "node_modules/axios/node_modules/form-data": {
-      "version": "4.0.4",
-      "resolved": "https://registry.npmjs.org/form-data/-/form-data-4.0.4.tgz",
-      "integrity": "sha512-KrGhL9Q4zjj0kiUt5OO4Mr/A/jlI2jDYs5eHBpYHPcBEVSiipAvn2Ko2HnPe20rmcuuvMHNdZFp+4IlGTMF0Ow==",
+      "version": "4.0.3",
+      "resolved": "https://registry.npmjs.org/form-data/-/form-data-4.0.3.tgz",
+      "integrity": "sha512-qsITQPfmvMOSAdeyZ+12I1c+CKSstAFAwu+97zrnWAbIr5u8wfsExUzCesVLC8NgHuRUqNN4Zy6UPWUTRGslcA==",
       "license": "MIT",
       "dependencies": {
         "asynckit": "^0.4.0",
@@ -3896,6 +3893,7 @@
       "version": "5.0.13",
       "resolved": "https://registry.npmjs.org/drachtio-srf/-/drachtio-srf-5.0.13.tgz",
       "integrity": "sha512-IG62MLLzhXjQtbjX6T6I8jXK6QhWQwsblkO3+F2Zhcu4lXBO3W12rrKyAPsw6GimRSSXIkvMbn5/je8AU/xehQ==",
+      "license": "MIT",
       "dependencies": {
         "debug": "^3.2.7",
         "delegates": "^0.1.0",
@@ -4604,9 +4602,7 @@
       "license": "MIT"
     },
     "node_modules/fast-redact": {
-      "version": "3.5.0",
-      "resolved": "https://registry.npmjs.org/fast-redact/-/fast-redact-3.5.0.tgz",
-      "integrity": "sha512-dwsoQlS7h9hMeYUq1W++23NDcBLV4KqONnITDV9DjfS3q1SgDGVrBdvvTLUotWtPSD7asWDV9/CmsZPy8Hf70A==",
+      "version": "3.2.0",
       "license": "MIT",
       "engines": {
         "node": ">=6"
@@ -4790,16 +4786,12 @@
       }
     },
     "node_modules/form-data": {
-      "version": "2.5.5",
-      "resolved": "https://registry.npmjs.org/form-data/-/form-data-2.5.5.tgz",
-      "integrity": "sha512-jqdObeR2rxZZbPSGL+3VckHMYtu+f9//KXBsVny6JSX/pa38Fy+bGjuG8eW/H6USNQWhLi8Num++cU2yOCNz4A==",
+      "version": "2.5.2",
       "license": "MIT",
       "dependencies": {
         "asynckit": "^0.4.0",
-        "combined-stream": "^1.0.8",
-        "es-set-tostringtag": "^2.1.0",
-        "hasown": "^2.0.2",
-        "mime-types": "^2.1.35",
+        "combined-stream": "^1.0.6",
+        "mime-types": "^2.1.12",
         "safe-buffer": "^5.2.1"
       },
       "engines": {
@@ -5366,21 +5358,21 @@
       }
     },
     "node_modules/ibm-cloud-sdk-core": {
-      "version": "5.4.3",
-      "resolved": "https://registry.npmjs.org/ibm-cloud-sdk-core/-/ibm-cloud-sdk-core-5.4.3.tgz",
-      "integrity": "sha512-D0lvClcoCp/HXyaFlCbOT4aTYgGyeIb4ncxZpxRuiuw7Eo79C6c49W53+8WJRD9nxzT5vrIdaky3NBcTdBtaEg==",
+      "version": "5.4.0",
+      "resolved": "https://registry.npmjs.org/ibm-cloud-sdk-core/-/ibm-cloud-sdk-core-5.4.0.tgz",
+      "integrity": "sha512-c4cwOuUDbMiFROYM/Ti1aC+Umi1v3TdvC2DO5zR7w44FYY/3xrs79+3DVPXt/nRhJeaMHN2L9XwlXsPSoVDHJA==",
       "license": "Apache-2.0",
       "dependencies": {
         "@types/debug": "^4.1.12",
         "@types/node": "^18.19.80",
         "@types/tough-cookie": "^4.0.0",
-        "axios": "^1.12.2",
+        "axios": "^1.8.2",
         "camelcase": "^6.3.0",
         "debug": "^4.3.4",
         "dotenv": "^16.4.5",
         "extend": "3.0.2",
         "file-type": "16.5.4",
-        "form-data": "^4.0.4",
+        "form-data": "4.0.0",
         "isstream": "0.1.2",
         "jsonwebtoken": "^9.0.2",
         "mime-types": "2.1.35",
@@ -5401,15 +5393,13 @@
       }
     },
     "node_modules/ibm-cloud-sdk-core/node_modules/form-data": {
-      "version": "4.0.4",
-      "resolved": "https://registry.npmjs.org/form-data/-/form-data-4.0.4.tgz",
-      "integrity": "sha512-KrGhL9Q4zjj0kiUt5OO4Mr/A/jlI2jDYs5eHBpYHPcBEVSiipAvn2Ko2HnPe20rmcuuvMHNdZFp+4IlGTMF0Ow==",
+      "version": "4.0.0",
+      "resolved": "https://registry.npmjs.org/form-data/-/form-data-4.0.0.tgz",
+      "integrity": "sha512-ETEklSGi5t0QMZuiXoA/Q6vcnxcLQP5vdugSpuAyi6SVGi2clPPp+xgEhuMaHC+zGgn31Kd235W35f7Hykkaww==",
       "license": "MIT",
       "dependencies": {
         "asynckit": "^0.4.0",
         "combined-stream": "^1.0.8",
-        "es-set-tostringtag": "^2.1.0",
-        "hasown": "^2.0.2",
         "mime-types": "^2.1.12"
       },
       "engines": {
@@ -7162,31 +7152,27 @@
       "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": "8.20.0",
       "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-abstract-transport": "^1.1.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"
+        "thread-stream": "^2.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": "1.1.0",
       "license": "MIT",
       "dependencies": {
         "readable-stream": "^4.0.0",
@@ -7195,17 +7181,13 @@
     },
     "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==",
+      "version": "4.5.2",
       "license": "MIT",
       "dependencies": {
         "abort-controller": "^3.0.0",
@@ -7480,8 +7462,6 @@
     },
     "node_modules/real-require": {
       "version": "0.2.0",
-      "resolved": "https://registry.npmjs.org/real-require/-/real-require-0.2.0.tgz",
-      "integrity": "sha512-57frrGM/OCTLqLOAh0mhVA9VBMHd+9U7Zb2THMGdBUoZVOtGbJzjxsYGDJ3A9AYYCP4hn6y1TVbaOfzWtm5GFg==",
       "license": "MIT",
       "engines": {
         "node": ">= 12.13.0"
@@ -8051,8 +8031,6 @@
     },
     "node_modules/split2": {
       "version": "4.2.0",
-      "resolved": "https://registry.npmjs.org/split2/-/split2-4.2.0.tgz",
-      "integrity": "sha512-UcjcJOWknrNkF6PLX83qcHM6KHgVKNkV62Y8a5uYDVv9ydGQVwAHMKqHdJje1VTWpljG0WYpCDhrCdAOYH4TWg==",
       "license": "ISC",
       "engines": {
         "node": ">= 10.x"
@@ -8398,9 +8376,7 @@
       "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": "2.3.0",
       "license": "MIT",
       "dependencies": {
         "real-require": "^0.2.0"

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.25",
     "@jambonz/stats-collector": "^0.1.10",
     "@jambonz/time-series": "^0.2.14",
-    "@jambonz/verb-specifications": "^0.0.116",
+    "@jambonz/verb-specifications": "^0.0.118",
     "@modelcontextprotocol/sdk": "^1.9.0",
     "@opentelemetry/api": "^1.8.0",
     "@opentelemetry/exporter-jaeger": "^1.23.0",