fix for #186 : unhandled error when amd webhook returns non-success status code

fixes for custom voice testing in azure
update to synthAudio with support for Azure custom voices
2026-02-08 04:52:35 +00:00 · 2022-11-05 10:27:00 -04:00 · 2022-11-04 09:36:44 -04:00 · 2022-11-04 08:27:09 -04:00 · 2022-11-02 13:40:25 -04:00 · 2022-11-01 20:57:18 -04:00
12 changed files with 71 additions and 25 deletions
--- a/lib/session/call-session.js
+++ b/lib/session/call-session.js
@@ -551,7 +551,9 @@ class CallSession extends Emitter {
            api_key: credential.api_key,
            region: credential.region,
            use_custom_stt: credential.use_custom_stt,
-            custom_stt_endpoint: credential.custom_stt_endpoint
+            custom_stt_endpoint: credential.custom_stt_endpoint,
+            use_custom_tts: credential.use_custom_tts,
+            custom_tts_endpoint: credential.custom_tts_endpoint
          };
        }
        else if ('wellsaid' === vendor) {
--- a/lib/tasks/config.js
+++ b/lib/tasks/config.js
@@ -146,7 +146,11 @@ class TaskConfig extends Task {
  _onAmdEvent(cs, evt) {
    this.logger.info({evt}, 'Config:_onAmdEvent');
    const {actionHook} = this.data.amd;
-    this.performHook(cs, actionHook, evt);
+    this.performHook(cs, actionHook, evt)
+      .catch((err) => {
+        this.logger.error({err}, 'Config:_onAmdEvent - error calling actionHook');
+      });
+
  }
 }

--- a/lib/tasks/dial.js
+++ b/lib/tasks/dial.js
@@ -689,7 +689,10 @@ class TaskDial extends Task {
  _onAmdEvent(cs, evt) {
    this.logger.info({evt}, 'Dial:_onAmdEvent');
    const {actionHook} = this.data.amd;
-    this.performHook(cs, actionHook, evt);
+    this.performHook(cs, actionHook, evt)
+      .catch((err) => {
+        this.logger.error({err}, 'Dial:_onAmdEvent - error calling actionHook');
+      });
  }
 }

--- a/lib/tasks/gather.js
+++ b/lib/tasks/gather.js
@@ -83,6 +83,7 @@ class TaskGather extends Task {
      this.initialSpeechTimeoutMs = recognizer.initialSpeechTimeoutMs || 0;
      this.azureServiceEndpoint = recognizer.azureServiceEndpoint;
      this.azureSttEndpointId = recognizer.azureSttEndpointId;
+      this.azureAudioLogging = recognizer.audioLogging;
    }
    else {
      this.hints = [];
@@ -381,6 +382,7 @@ class TaskGather extends Task {
      else {
        opts.AZURE_SPEECH_ALTERNATIVE_LANGUAGE_CODES = '';
      }
+      if (this.azureAudioLogging) opts.AZURE_AUDIO_LOGGING = 1;
      if (this.requestSnr) opts.AZURE_REQUEST_SNR = 1;
      if (this.profanityOption && this.profanityOption !== 'raw') opts.AZURE_PROFANITY_OPTION = this.profanityOption;
      if (this.azureServiceEndpoint) opts.AZURE_SERVICE_ENDPOINT = this.azureServiceEndpoint;
--- a/lib/tasks/specs.json
+++ b/lib/tasks/specs.json
@@ -509,7 +509,8 @@
      "azureServiceEndpoint": "string",
      "azureSttEndpointId": "string",
      "asrDtmfTerminationDigit": "string",
-      "asrTimeout": "number"
+      "asrTimeout": "number",
+      "audioLogging": "boolean"
    },
    "required": [
      "vendor"
--- a/lib/tasks/transcribe.js
+++ b/lib/tasks/transcribe.js
@@ -55,6 +55,7 @@ class TaskTranscribe extends Task {
    this.initialSpeechTimeoutMs = recognizer.initialSpeechTimeoutMs || 0;
    this.azureServiceEndpoint = recognizer.azureServiceEndpoint;
    this.azureSttEndpointId = recognizer.azureSttEndpointId;
+    this.azureAudioLogging = recognizer.audioLogging;
  }

  get name() { return TaskName.Transcribe; }
@@ -249,6 +250,7 @@ class TaskTranscribe extends Task {
      }
      if (this.altLanguages.length > 0) opts.AZURE_SPEECH_ALTERNATIVE_LANGUAGE_CODES = this.altLanguages.join(',');
      else opts.AZURE_SPEECH_ALTERNATIVE_LANGUAGE_CODES = '';
+      if (this.azureAudioLogging) opts.AZURE_AUDIO_LOGGING = 1;
      if (this.requestSnr) opts.AZURE_REQUEST_SNR = 1;
      if (this.profanityOption !== 'raw') opts.AZURE_PROFANITY_OPTION = this.profanityOption;
      if (this.initialSpeechTimeoutMs > 0) opts.AZURE_INITIAL_SPEECH_TIMEOUT_MS = this.initialSpeechTimeoutMs;
--- a/lib/utils/aws-sns-lifecycle.js
+++ b/lib/utils/aws-sns-lifecycle.js
@@ -36,7 +36,7 @@ class SnsNotifier extends Emitter {

      logger.info(`SNS lifecycle server failed to bind port on ${e.port}, will try next port`);
      const server = this._doListen(logger, app, ++e.port, resolve);
-      server.on('error', this._handleErrors.bind(null, logger, app, resolve, reject));
+      server.on('error', this._handleErrors.bind(this, logger, app, resolve, reject));
      return;
    }
    reject(e);
@@ -120,7 +120,7 @@ class SnsNotifier extends Emitter {
      });
      return new Promise((resolve, reject) => {
        const server = this._doListen(this.logger, app, PORT, resolve);
-        server.on('error', this._handleErrors.bind(null, this.logger, app, resolve, reject));
+        server.on('error', this._handleErrors.bind(this, this.logger, app, resolve, reject));
      });

    } catch (err) {
--- a/lib/utils/db-utils.js
+++ b/lib/utils/db-utils.js
@@ -39,6 +39,8 @@ const speechMapper = (cred) => {
      obj.region = o.region;
      obj.use_custom_stt = o.use_custom_stt;
      obj.custom_stt_endpoint = o.custom_stt_endpoint;
+      obj.use_custom_tts = o.use_custom_tts;
+      obj.custom_tts_endpoint = o.custom_tts_endpoint;
    }
    else if ('wellsaid' === obj.vendor) {
      const o = JSON.parse(decrypt(credential));
--- a/lib/utils/http-listener.js
+++ b/lib/utils/http-listener.js
@@ -21,6 +21,7 @@ const handleErrors = (logger, app, resolve, reject, e) => {
    server.on('error', handleErrors.bind(null, logger, app, resolve, reject));
    return;
  }
+  logger.info({err: e, port: PORT}, 'httpListener error');
  reject(e);
 };

@@ -30,7 +31,7 @@ const createHttpListener = (logger, srf) => {
  app.use(express.urlencoded({ extended: true }));
  app.use(express.json());
  app.use('/', httpRoutes);
-  app.use((err, req, res, next) => {
+  app.use((err, _req, res, _next) => {
    logger.error(err, 'burped error');
    res.status(err.status || 500).json({msg: err.message});
  });
--- a/lib/utils/ws-requestor.js
+++ b/lib/utils/ws-requestor.js
@@ -69,7 +69,7 @@ class WsRequestor extends BaseRequestor {
      this.connectInProgress = true;
      this.logger.debug(`WsRequestor:request(${this.id}) - connecting since we do not have a connection`);
      if (this.connections >= MAX_RECONNECTS) {
-        throw new Error(`max attempts connecting to ${this.url}`);
+        return Promise.reject(`max attempts connecting to ${this.url}`);
      }
      try {
        const startAt = process.hrtime();
@@ -79,7 +79,7 @@ class WsRequestor extends BaseRequestor {
      } catch (err) {
        this.logger.info({url, err}, 'WsRequestor:request - failed connecting');
        this.connectInProgress = false;
-        throw err;
+        return Promise.reject(err);
      }
    }
    assert(this.ws);
--- a/package-lock.json
+++ b/package-lock.json
@@ -9,9 +9,9 @@
      "version": "v0.7.7",
      "license": "MIT",
      "dependencies": {
-        "@jambonz/db-helpers": "^0.6.19",
+        "@jambonz/db-helpers": "^0.7.3",
        "@jambonz/http-health-check": "^0.0.1",
-        "@jambonz/realtimedb-helpers": "^0.4.35",
+        "@jambonz/realtimedb-helpers": "^0.5.5",
        "@jambonz/stats-collector": "^0.1.6",
        "@jambonz/time-series": "^0.2.5",
        "@opentelemetry/api": "^1.1.0",
@@ -509,13 +509,14 @@
      }
    },
    "node_modules/@jambonz/db-helpers": {
-      "version": "0.6.19",
-      "resolved": "https://registry.npmjs.org/@jambonz/db-helpers/-/db-helpers-0.6.19.tgz",
-      "integrity": "sha512-mR9PqPY4aEoeTtUuZI1+4r+k1BFKoe0Dl9pyeAEvm7KSlRMHCVWbOzVE8WfoifC9dZ9541iW5pseqqip3QMkyw==",
+      "version": "0.7.3",
+      "resolved": "https://registry.npmjs.org/@jambonz/db-helpers/-/db-helpers-0.7.3.tgz",
+      "integrity": "sha512-FXQPnl5AGV3P6RhvdSKfjIOdEXShYe7aKJayJjaPARPTCTGqLTDhV2tfsWirCrpQhn+vanJHAiOyzOTmbDIfzA==",
      "dependencies": {
        "cidr-matcher": "^2.1.1",
        "debug": "^4.3.3",
        "mysql2": "^2.3.3",
+        "node-object-hash": "^2.3.10",
        "uuid": "^8.3.2"
      }
    },
@@ -542,16 +543,18 @@
      }
    },
    "node_modules/@jambonz/realtimedb-helpers": {
-      "version": "0.4.35",
-      "resolved": "https://registry.npmjs.org/@jambonz/realtimedb-helpers/-/realtimedb-helpers-0.4.35.tgz",
-      "integrity": "sha512-lfNTlWRnLbOKVRDto1nUgOmr2jlmOHxslg+Zs9dSB8eEEkIqCNZn9f5kxxXThVpRSrCtsgGsX/w1wXygGiTn5w==",
+      "version": "0.5.5",
+      "resolved": "https://registry.npmjs.org/@jambonz/realtimedb-helpers/-/realtimedb-helpers-0.5.5.tgz",
+      "integrity": "sha512-tQJfTqN1FtFfKR9ceBYuQ9yddCDshBGVI6v1N/IxOyhTywyueNFXg6JMIOx0Rci7UqIDhtcBjl5R64zWgTo04A==",
      "dependencies": {
        "@google-cloud/text-to-speech": "^4.0.3",
+        "@grpc/grpc-js": "^1.7.3",
        "@jambonz/promisify-redis": "^0.0.6",
        "aws-sdk": "^2.1238.0",
        "bent": "^7.3.12",
        "debug": "^4.3.3",
        "form-urlencoded": "^6.1.0",
+        "google-protobuf": "^3.21.2",
        "microsoft-cognitiveservices-speech-sdk": "^1.24.0",
        "redis": "^3.1.2",
        "undici": "^5.11.0"
@@ -3196,6 +3199,11 @@
        "node": ">=12.0.0"
      }
    },
+    "node_modules/google-protobuf": {
+      "version": "3.21.2",
+      "resolved": "https://registry.npmjs.org/google-protobuf/-/google-protobuf-3.21.2.tgz",
+      "integrity": "sha512-3MSOYFO5U9mPGikIYCzK0SaThypfGgS6bHqrUGXG3DPHCrb+txNqeEcns1W0lkGfk0rCyNXm7xB9rMxnCiZOoA=="
+    },
    "node_modules/graceful-fs": {
      "version": "4.2.3",
      "resolved": "https://registry.npmjs.org/graceful-fs/-/graceful-fs-4.2.3.tgz",
@@ -4641,6 +4649,14 @@
      "resolved": "https://registry.npmjs.org/node-noop/-/node-noop-0.0.1.tgz",
      "integrity": "sha512-kAUvIRxZyDYFTLqGj+7zqXduG89vtqGmNMt9qDMvYH3H8uNTCOTz5ZN1q2Yg8++fWbzv+ERtYVqaOH42Ag5OpA=="
    },
+    "node_modules/node-object-hash": {
+      "version": "2.3.10",
+      "resolved": "https://registry.npmjs.org/node-object-hash/-/node-object-hash-2.3.10.tgz",
+      "integrity": "sha512-jY5dPJzw6NHd/KPSfPKJ+IHoFS81/tJ43r34ZeNMXGzCOM8jwQDCD12HYayKIB6MuznrnqIYy2e891NA2g0ibA==",
+      "engines": {
+        "node": ">=0.10.0"
+      }
+    },
    "node_modules/node-preload": {
      "version": "0.2.1",
      "resolved": "https://registry.npmjs.org/node-preload/-/node-preload-0.2.1.tgz",
@@ -7043,13 +7059,14 @@
      "dev": true
    },
    "@jambonz/db-helpers": {
-      "version": "0.6.19",
-      "resolved": "https://registry.npmjs.org/@jambonz/db-helpers/-/db-helpers-0.6.19.tgz",
-      "integrity": "sha512-mR9PqPY4aEoeTtUuZI1+4r+k1BFKoe0Dl9pyeAEvm7KSlRMHCVWbOzVE8WfoifC9dZ9541iW5pseqqip3QMkyw==",
+      "version": "0.7.3",
+      "resolved": "https://registry.npmjs.org/@jambonz/db-helpers/-/db-helpers-0.7.3.tgz",
+      "integrity": "sha512-FXQPnl5AGV3P6RhvdSKfjIOdEXShYe7aKJayJjaPARPTCTGqLTDhV2tfsWirCrpQhn+vanJHAiOyzOTmbDIfzA==",
      "requires": {
        "cidr-matcher": "^2.1.1",
        "debug": "^4.3.3",
        "mysql2": "^2.3.3",
+        "node-object-hash": "^2.3.10",
        "uuid": "^8.3.2"
      }
    },
@@ -7070,16 +7087,18 @@
      }
    },
    "@jambonz/realtimedb-helpers": {
-      "version": "0.4.35",
-      "resolved": "https://registry.npmjs.org/@jambonz/realtimedb-helpers/-/realtimedb-helpers-0.4.35.tgz",
-      "integrity": "sha512-lfNTlWRnLbOKVRDto1nUgOmr2jlmOHxslg+Zs9dSB8eEEkIqCNZn9f5kxxXThVpRSrCtsgGsX/w1wXygGiTn5w==",
+      "version": "0.5.5",
+      "resolved": "https://registry.npmjs.org/@jambonz/realtimedb-helpers/-/realtimedb-helpers-0.5.5.tgz",
+      "integrity": "sha512-tQJfTqN1FtFfKR9ceBYuQ9yddCDshBGVI6v1N/IxOyhTywyueNFXg6JMIOx0Rci7UqIDhtcBjl5R64zWgTo04A==",
      "requires": {
        "@google-cloud/text-to-speech": "^4.0.3",
+        "@grpc/grpc-js": "^1.7.3",
        "@jambonz/promisify-redis": "^0.0.6",
        "aws-sdk": "^2.1238.0",
        "bent": "^7.3.12",
        "debug": "^4.3.3",
        "form-urlencoded": "^6.1.0",
+        "google-protobuf": "^3.21.2",
        "microsoft-cognitiveservices-speech-sdk": "^1.24.0",
        "redis": "^3.1.2",
        "undici": "^5.11.0"
@@ -9110,6 +9129,11 @@
        "node-forge": "^1.3.1"
      }
    },
+    "google-protobuf": {
+      "version": "3.21.2",
+      "resolved": "https://registry.npmjs.org/google-protobuf/-/google-protobuf-3.21.2.tgz",
+      "integrity": "sha512-3MSOYFO5U9mPGikIYCzK0SaThypfGgS6bHqrUGXG3DPHCrb+txNqeEcns1W0lkGfk0rCyNXm7xB9rMxnCiZOoA=="
+    },
    "graceful-fs": {
      "version": "4.2.3",
      "resolved": "https://registry.npmjs.org/graceful-fs/-/graceful-fs-4.2.3.tgz",
@@ -10192,6 +10216,11 @@
      "resolved": "https://registry.npmjs.org/node-noop/-/node-noop-0.0.1.tgz",
      "integrity": "sha512-kAUvIRxZyDYFTLqGj+7zqXduG89vtqGmNMt9qDMvYH3H8uNTCOTz5ZN1q2Yg8++fWbzv+ERtYVqaOH42Ag5OpA=="
    },
+    "node-object-hash": {
+      "version": "2.3.10",
+      "resolved": "https://registry.npmjs.org/node-object-hash/-/node-object-hash-2.3.10.tgz",
+      "integrity": "sha512-jY5dPJzw6NHd/KPSfPKJ+IHoFS81/tJ43r34ZeNMXGzCOM8jwQDCD12HYayKIB6MuznrnqIYy2e891NA2g0ibA=="
+    },
    "node-preload": {
      "version": "0.2.1",
      "resolved": "https://registry.npmjs.org/node-preload/-/node-preload-0.2.1.tgz",
--- a/package.json
+++ b/package.json
@@ -25,8 +25,8 @@
  },
  "dependencies": {
    "@jambonz/http-health-check": "^0.0.1",
-    "@jambonz/db-helpers": "^0.6.19",
-    "@jambonz/realtimedb-helpers": "^0.4.35",
+    "@jambonz/db-helpers": "^0.7.3",
+    "@jambonz/realtimedb-helpers": "^0.5.5",
    "@jambonz/stats-collector": "^0.1.6",
    "@jambonz/time-series": "^0.2.5",
    "@opentelemetry/api": "^1.1.0",
Author	SHA1	Message	Date
Dave Horton	9fd116b05f	fix for #186 : unhandled error when amd webhook returns non-success status code	2022-11-05 10:27:00 -04:00
Dave Horton	19098aee98	fixes for custom voice testing in azure	2022-11-04 09:36:44 -04:00
Dave Horton	d15dbf7f5a	update to synthAudio with support for Azure custom voices	2022-11-04 08:27:09 -04:00
Dave Horton	824f983955	update deps	2022-11-02 13:40:25 -04:00
Dave Horton	7c76bc52f6	update to db-helpers with caching fix	2022-11-01 20:57:18 -04:00
Dave Horton	bfc8a99950	bugfix: ws error max connections error causes a crash	2022-11-01 11:33:03 -04:00
Dave Horton	9097c6d6ac	bugfix when running multiple instances in EC2	2022-10-31 14:42:53 -04:00
Dave Horton	15b2fdd5a8	update to db-helpers@0.7.0 with caching option	2022-10-31 11:43:07 -04:00
Dave Horton	979e17c814	add support for Azure audio logging in gather and transcribe	2022-10-31 11:08:16 -04:00