Merge pull request #636 from rfcx/not-upload-audio-rfcx-ark

Replace old rfcx-ark bucket with ingest bucket
rfcx · Jun 21, 2024 · 719bb3a · 719bb3a
2 parents 6a4cd0f + 0822dde
commit 719bb3a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/noncore/_utils/rfcx-mqtt/mqtt-input-data.js b/noncore/_utils/rfcx-mqtt/mqtt-input-data.js
@@ -46,7 +46,9 @@ exports.mqttInputData = {
           cacheFileBufferToFile(audioFileBuffer, true, checkInObj.audio.metaArr[3], checkInObj.audio.metaArr[2])
             .then(function (audioFileCacheFilePath) {
               checkInObj.audio.filePath = audioFileCacheFilePath
-              return saveAssetFileToS3('audio', checkInObj)
+              // Skip upload audio to rfcx-ark
+              // return saveAssetFileToS3('audio', checkInObj)
+              return checkInObj
             })
             .then(function (checkInObj) {
               checkInObj.screenshots.metaArr = (strArrToJSArr(checkInObj.json.screenshots, '|', '*').length === 0) ? [] : strArrToJSArr(checkInObj.json.screenshots, '|', '*')[0]

diff --git a/noncore/_utils/rfcx-mqtt/mqtt-streams.js b/noncore/_utils/rfcx-mqtt/mqtt-streams.js
@@ -18,7 +18,7 @@ async function ingestGuardianAudio (checkInObj) {
     targetBitrate: checkInObj.audio.meta.bitRate,
     sampleRate: checkInObj.audio.meta.sampleRate
   })
-  await S3Service.copyObject(process.env.ASSET_BUCKET_AUDIO, checkInObj.audio.meta.s3Path, uploadData.bucket, uploadData.path)
+  await S3Service.putObject(checkInObj.audio.filePath, uploadData.path, uploadData.bucket)
 
   return checkInObj
 }