Delete Transcription Job

deleteTranscriptionJob.js

const AWS = require('aws-sdk');
const https = require('https');
var assert = require('assert');

exports.handler = async (event) => {
    
    // required params
    var region = 'put ypur region';
    var payload = event['Input']['Payload']
    var transcriptFileUri = payload['TranscriptFileUri'];
    var transcriptionJobName = payload['TranscriptionJobName'];
    var transcriptionJobStatus = payload['TranscriptionJobStatus'];
    var userEmail = payload['Email'];
    
    var transcribe = new AWS.TranscribeService(region);
    // sns notifications
    const ses = new AWS.SES({ region: region });

    // donwload generated file by Transcribe from s3
    const transcription = await new Promise((resolve, reject) => {
        const req = https.get(transcriptFileUri, function(res) {
          var dataString = '';
          res.on('data', chunk => {
            dataString += chunk;
          });
          res.on('end', () => {
            resolve({
                body: dataString ? JSON.parse(dataString)["results"]["transcripts"][0]['transcript'] : 'No response'
            });
          });
        });
        
        req.on('error', (e) => {
          reject({
              statusCode: 500,
              body: 'Something went wrong!'
          });
        });
    })
    
    // delete current job after completion
    var params = {
        TranscriptionJobName: transcriptionJobName
    }
    const response = await new Promise((resolve, reject) => {
      transcribe.deleteTranscriptionJob(params, function(err, data) {
            if(err) reject(err);    // an error occurred
            else    resolve(data);  // successful response
        });  
    });
    
    // send AWS SNS Notifications
    const sendNotificationEmail = function(msg) {
      var params = {
        Destination: {
          ToAddresses: [userEmail],
        },
        Message: {
          Body: {
            Text: { Data: msg['body'] },
          },
    
          Subject: { Data: "Test Email" },
        },
        Source: process.env.SENDER_EMAIL,
      };
    
      return new Promise((resolve, reject) => {
        ses.sendEmail(params, (err, data) => {
          if(err) reject(err);
          else resolve(data);
        })
      });
    }
    
    // send data via mail
    await sendNotificationEmail(transcription);
    return {
        response: transcription,
        TranscriptFileUri: transcriptFileUri,
        TranscriptionJobName: transcriptionJobName,
        TranscriptionJobStatus: transcriptionJobStatus
    }
};