Updated to recieve SAS URL in queue message

MauriRojas · Mar 25, 2024 · 4945056 · 4945056
1 parent 01e73f2
commit 4945056
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/VirtualEncoder/index.js b/VirtualEncoder/index.js
@@ -3,17 +3,15 @@ const { resolve } = require('path');
 const ffmpegPath = require('@ffmpeg-installer/ffmpeg').path;
 const path = require("path");
 
-const streamToMux = (context) => {
+const streamToMux = (context, blobSasUrl) => {
     return new Promise(async (resolve, reject) => {
         context.log(`Running ffmpeg from ${ffmpegPath}`);
 
-        var inputAbsolutePath = path.resolve("./input.mp4");
-
         // ffmpeg -re -i myfile_1.mp4 -r 30 -c:v libx264 -x264-params keyint=60:scenecut=0 -preset fast -b:v 5M -maxrate 6M -bufsize 3M -threads 4 -f flv rtmp://global-live.mux.com:5222/app/{my_stream_key}
         const child = childProcess.spawn(
             ffmpegPath,
             // note, args must be an array when using spawn
-            ['-i', `${inputAbsolutePath}`, '-f', 'flv', 'rtmp://global-live.mux.com:5222/app/5ac28812-8320-0c76-2ba2-313288af035f'],
+            ['-i', `${blobSasUrl}`, '-f', 'flv', 'rtmp://global-live.mux.com:5222/app/5ac28812-8320-0c76-2ba2-313288af035f'],
             {
                 windowsVerbatimArguments: true,
             }
@@ -47,13 +45,13 @@ const streamToMux = (context) => {
     });
 };
 
-module.exports = async function (context, myQueueItem) {
-    context.log('JavaScript queue trigger function processing work item', myQueueItem);
+module.exports = async function (context, blobSasUrl) {
+    context.log('JavaScript queue trigger function processing work item', blobSasUrl);
 
     // 2. Process the message here
     context.log('Starting streaming blob');
 
-    var finished = await streamToMux(context);
+    var finished = await streamToMux(context, blobSasUrl);
 
     context.log("Finished execution", finished);
 };