in src/main/java/com/amazonaws/kvstranscribestreaming/KVSTranscribeStreamingLambda.java [272:290]
private void closeFileAndUploadRawAudio(KVSStreamTrackObject kvsStreamTrackObject, String contactId, Optional<Boolean> saveCallRecording) throws IOException {
kvsStreamTrackObject.getInputStream().close();
kvsStreamTrackObject.getOutputStream().close();
//Upload the Raw Audio file to S3
if ((saveCallRecording.isPresent() ? saveCallRecording.get() : false) && (new File(kvsStreamTrackObject.getSaveAudioFilePath().toString()).length() > 0)) {
AudioUtils.uploadRawAudio(REGION, RECORDINGS_BUCKET_NAME, RECORDINGS_KEY_PREFIX, kvsStreamTrackObject.getSaveAudioFilePath().toString(), contactId, RECORDINGS_PUBLIC_READ_ACL,
getAWSCredentials());
} else {
logger.info("Skipping upload to S3. saveCallRecording was disabled or audio file has 0 bytes: " + kvsStreamTrackObject.getSaveAudioFilePath().toString());
}
//Delete raw files from the lambda function
File fileToDelete = new File(kvsStreamTrackObject.getSaveAudioFilePath().toString());
if (fileToDelete != null) {
Boolean deletionResult = fileToDelete.delete();
logger.info("Raw file for contactId {} deletion result: {}", contactId, deletionResult);
}
}