ben.carrasco/batch-speech-utils
1
0
Fork 0
mirror of https://github.com/jambonz/batch-speech-utils.git synced 2025-12-19 06:07:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

updated with example using jamboz call retrieval api

Browse Source
This commit is contained in:
surajshivakumar
2024-06-07 00:09:08 -04:00
parent ea547ea162
commit f018c2ab51
1 changed files with 55 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

74
index.js
View File

@@ -1,31 +1,67 @@
const { audioProcess } = require('./lib/transcription');
const { redactSensitiveInfo } = require('./lib/audioRedaction');
const {audioProcess} = require('./lib/transcription');
const axios = require('axios');
const {redactSensitiveInfo} = require('./lib/audioRedaction');
const path = require('path');
const fs = require('fs-extra');
require('dotenv').config();
const audioDir = process.env.AUDIO_DIR;
const inputFile = 'sampleop.wav';
const accountSid = process.env.ACCOUNT_SID;
const callSid = process.env.CALL_SID;
const jambonzApiToken = process.env.JAMBONZ_API_TOKEN;
const recordingDate = '2024/06/06';
const audioPath = path.join(audioDir, inputFile);
const outputDir = path.join(__dirname, 'redacts');
const dG = new audioProcess(process.env.DEEPGRAM_API_KEY, audioPath);
const outputPathAudio = path.join(outputDir, `${inputFile.split('.')[0]}-redacted.wav`);
const outputPathJson = path.join(__dirname, 'redacts', `${inputFile.split('.')[0]}-redacts.json`);
const audioURL = `https://jambonz.one/api/v1/Accounts/${accountSid}/RecentCalls/${callSid}/record/${recordingDate}/mp3`;
console.log(audioURL);
async function processAndRedactAudio() {
const config = {
responseType: 'stream',
headers: {
Authorization: `Bearer ${jambonzApiToken}`
}
};
// Function to download and process audio
async function downloadAndProcessAudio() {
try {
const results = await dG.processAudio();
const jsonContent = JSON.stringify(results, null, 2);
await fs.ensureDir(path.dirname(outputPathJson));
const response = await axios.get(audioURL, config);
const audioFilePath = path.join(audioDir, 'recording.mp3');
const writer = fs.createWriteStream(audioFilePath);
await fs.writeFile(outputPathJson, jsonContent, 'utf-8');
console.dir({ analysis: [results] }, { depth: null });
if (results && results.redactionTimestamps) {
redactSensitiveInfo(results.redactionTimestamps, audioPath, outputPathAudio);
}
response.data.pipe(writer);
await new Promise((resolve, reject) => {
writer.on('finish', resolve);
writer.on('error', reject);
});
console.log('File downloaded successfully');
await processAndRedactAudio(audioFilePath);
} catch (error) {
console.error('Error in main execution:', error);
console.error('Error downloading the file:', error);
}
}
processAndRedactAudio();
// Function to process and redact audio
async function processAndRedactAudio(audioFilePath) {
try {
const dG = new audioProcess(process.env.DEEPGRAM_API_KEY, audioFilePath);
const results = await dG.processAudio();
const jsonContent = JSON.stringify(results, null, 2);
const outputPathJson = path.join(__dirname, 'redacts', `${path.basename(audioFilePath, '.mp3')}-redacts.json`);
const outputPathAudio = path.join(__dirname, 'redacts', `${path.basename(audioFilePath, '.mp3')}-redacted.wav`);
await fs.ensureDir(path.dirname(outputPathJson));
await fs.writeFile(outputPathJson, jsonContent, 'utf-8');
console.dir({analysis: [results]}, {depth: null});
if (results && results.redactionTimestamps) {
await redactSensitiveInfo(results.redactionTimestamps, audioFilePath, outputPathAudio);
}
} catch (error) {
console.error('Error in processing audio:', error);
}
}
// Start the process
downloadAndProcessAudio();