fix transcribe

This commit is contained in:
Quan HL
2023-08-18 10:38:27 +07:00
parent 09961f564a
commit 18d7ea3e37

View File

@@ -73,13 +73,14 @@ class TaskTranscribe extends Task {
get name() { return TaskName.Transcribe; } get name() { return TaskName.Transcribe; }
async _initSpeechCredential(cs, vendor, label) { async _initSpeechCredential(cs, vendor, label) {
const {getNuanceAccessToken, getIbmAccessToken} = cs.srf.locals.dbHelpers;
let credentials = cs.getSpeechCredentials(vendor, 'stt', label); let credentials = cs.getSpeechCredentials(vendor, 'stt', label);
if (!credentials) { if (!credentials) {
const {writeAlerts, AlertType} = cs.srf.locals; const {writeAlerts, AlertType} = cs.srf.locals;
this.logger.info(`TaskTranscribe:exec - ERROR stt using ${vendor} requested but creds not supplied`); this.logger.info(`TaskTranscribe:exec - ERROR stt using ${vendor} requested but creds not supplied`);
writeAlerts({ writeAlerts({
account_sid: cs.accountSid, account_sid: cs.accountSid,
alert_type: AlertType.STT_NOT_PROVISIONED, alert_type: AlertType.STT_NOT_PROVISIONED,
vendor: vendor vendor: vendor
}).catch((err) => this.logger.info({err}, 'Error generating alert for no stt')); }).catch((err) => this.logger.info({err}, 'Error generating alert for no stt'));
@@ -92,7 +93,7 @@ class TaskTranscribe extends Task {
const {access_token, servedFromCache} = await getNuanceAccessToken(client_id, secret, 'asr tts'); const {access_token, servedFromCache} = await getNuanceAccessToken(client_id, secret, 'asr tts');
this.logger.debug({client_id}, this.logger.debug({client_id},
`Transcribe:exec - got nuance access token ${servedFromCache ? 'from cache' : ''}`); `Transcribe:exec - got nuance access token ${servedFromCache ? 'from cache' : ''}`);
credentials = {...credentials, access_token}; credentials = {...credentials, access_token};
} }
else if (vendor == 'ibm' && credentials.stt_api_key) { else if (vendor == 'ibm' && credentials.stt_api_key) {
/* get ibm access token */ /* get ibm access token */
@@ -108,7 +109,6 @@ class TaskTranscribe extends Task {
async exec(cs, {ep, ep2}) { async exec(cs, {ep, ep2}) {
super.exec(cs); super.exec(cs);
const {updateSpeechCredentialLastUsed} = require('../utils/db-utils')(this.logger, cs.srf); const {updateSpeechCredentialLastUsed} = require('../utils/db-utils')(this.logger, cs.srf);
const {getNuanceAccessToken, getIbmAccessToken} = cs.srf.locals.dbHelpers;
if (cs.hasGlobalSttHints) { if (cs.hasGlobalSttHints) {
const {hints, hintsBoost} = cs.globalSttHints; const {hints, hintsBoost} = cs.globalSttHints;
@@ -185,7 +185,7 @@ class TaskTranscribe extends Task {
isFallbackSuccess = true; isFallbackSuccess = true;
} catch (error) { } catch (error) {
this.logger.info(err, 'TaskTranscribe:exec - fallback error'); this.logger.info(err, 'TaskTranscribe:exec - fallback error');
} }
} }
if (!isFallbackSuccess) { if (!isFallbackSuccess) {
this.parentTask && this.parentTask.emit('error', err); this.parentTask && this.parentTask.emit('error', err);