From b15978e75643ce6c216e81f0e0efc11aab0be084 Mon Sep 17 00:00:00 2001
From: Jibon Costa <jiboncosta57@gmail.com>
Date: Sat, 28 Mar 2020 16:38:08 +0600
Subject: Live RTMP broadcasting

---
 liveRTMP.js | 99 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 99 insertions(+)
 create mode 100644 liveRTMP.js

(limited to 'liveRTMP.js')

diff --git a/liveRTMP.js b/liveRTMP.js
new file mode 100644
index 0000000..0fcbfef
--- /dev/null
+++ b/liveRTMP.js
@@ -0,0 +1,99 @@
+const puppeteer = require('puppeteer');
+const Xvfb      = require('xvfb');
+var exec = require('child_process').exec;
+const fs = require('fs');
+const homedir = require('os').homedir();
+const ffmpegServer = "ws://localhost:4000/auth/mZFZN4yc";
+
+var xvfb        = new Xvfb({silent: true});
+var width       = 1280;
+var height      = 720;
+var options     = {
+  headless: false,
+  args: [
+    '--enable-usermedia-screen-capturing',
+    '--allow-http-screen-capture',
+    '--auto-select-desktop-capture-source=bbbrecorder',
+    '--load-extension=' + __dirname,
+    '--disable-extensions-except=' + __dirname,
+    '--disable-infobars',
+    '--no-sandbox',    
+    '--shm-size=1gb',
+    '--disable-dev-shm-usage',
+    `--window-size=${width},${height}`,
+  ],
+}
+
+async function main() {
+    try{
+        xvfb.startSync()
+        var url = process.argv[2],
+            duration = process.argv[3], 
+            exportname = 'liveMeeting.webm'
+
+        if(!url){ url = 'http://tobiasahlin.com/spinkit/' }
+        //if(!duration){ duration = 10 }
+        
+        const browser = await puppeteer.launch(options)
+        const pages = await browser.pages()
+        
+        const page = pages[0]
+
+        page.on('console', msg => {
+            var m = msg.text();
+            console.log('PAGE LOG:', m)
+        });
+
+        await page._client.send('Emulation.clearDeviceMetricsOverride')
+        await page.goto(url, {waitUntil: 'networkidle2'})
+        await page.setBypassCSP(true)
+
+        await page.evaluate((serverAddress) => {
+            console.log("FFMPEG_SERVER");
+            window.postMessage({type: 'FFMPEG_SERVER', ffmpegServer: serverAddress}, '*')
+        }, ffmpegServer)
+
+        await page.waitForSelector('[aria-label="Listen only"]');
+        await page.click('[aria-label="Listen only"]', {waitUntil: 'domcontentloaded'});
+
+        await page.waitForSelector('[id="chat-toggle-button"]');
+        await page.click('[id="chat-toggle-button"]', {waitUntil: 'domcontentloaded'});
+        await page.click('button[aria-label="Users and messages toggle"]', {waitUntil: 'domcontentloaded'});
+        await page.$eval('[class^=navbar]', element => element.style.display = "none");
+
+        await page.$eval('.Toastify', element => element.style.display = "none");
+        await page.waitForSelector('button[aria-label="Leave audio"]');
+        await page.$eval('[class^=actionsbar] > [class^=center]', element => element.style.display = "none");
+        
+        await page.evaluate((x) => {
+            console.log("REC_START");
+            window.postMessage({type: 'REC_START'}, '*')
+        })
+
+        if(duration > 0){
+            await page.waitFor((duration * 1000))
+        }else{
+            await page.waitForSelector('[class^=modal] > [class^=content] > button[description="Logs you out of the meeting"]', {
+                timeout: 0
+            });
+        }
+
+        await page.evaluate(filename=>{
+            window.postMessage({type: 'SET_EXPORT_PATH', filename: filename}, '*')
+            window.postMessage({type: 'REC_STOP'}, '*')
+        }, exportname)
+
+        // Wait for download of webm to complete
+        await page.waitForSelector('html.downloadComplete', {timeout: 0})
+        await page.close()
+        await browser.close()
+        xvfb.stopSync()
+
+        fs.unlinkSync(homedir + "/Downloads/liveMeeting.webm");
+        
+    }catch(err) {
+        console.log(err)
+    }
+}
+
+main()
-- 
cgit v1.3.1