Broadcast + setCompressorLevel

.github/workflows/build.yml

@@ -12,23 +12,46 @@ on:
 
 jobs:
   build:
-    runs-on: ubuntu-latest
+    runs-on: ubuntu-20.04
     steps:
     - uses: actions/checkout@v2
     - uses: actions/setup-node@master
       with:
         node-version: 16
     - name: Install windows dependencies
       run: |
+        sudo apt-get update -y
+        sudo apt-get install -y --no-install-recommends software-properties-common
+
         sudo dpkg --add-architecture i386
-        sudo apt update
-        wget -qO- https://dl.winehq.org/wine-builds/winehq.key | sudo apt-key add -
-        sudo apt install software-properties-common
-        sudo apt-add-repository 'deb http://dl.winehq.org/wine-builds/ubuntu/ bionic main'
-        wget -qO- https://download.opensuse.org/repositories/Emulators:/Wine:/Debian/xUbuntu_18.04/Release.key | sudo apt-key add -
-        sudo sh -c 'echo "deb https://download.opensuse.org/repositories/Emulators:/Wine:/Debian/xUbuntu_18.04/ ./" > /etc/apt/sources.list.d/obs.list'
-        sudo apt update
-        sudo apt-get install -y --install-recommends winehq-devel
+
+        curl -L https://download.opensuse.org/repositories/Emulators:/Wine:/Debian/xUbuntu_20.04/Release.key > winehq.key
+        sudo apt-key add winehq.key
+
+        sudo apt-add-repository 'deb https://download.opensuse.org/repositories/Emulators:/Wine:/Debian/xUbuntu_20.04/ ./'
+        sudo apt-get update -y
+
+        sudo apt-get -y purge software-properties-common libdbus-glib-1-2 python3-dbus python3-gi python3-pycurl python3-software-properties
+
+        sudo apt-get install aptitude
+        sudo aptitude install -y libglib2.0-0:i386
+        sudo aptitude install -y libgphoto2-6:i386
+        sudo aptitude install -y libgstreamer-plugins-base1.0-0:i386
+        sudo aptitude install -y libgstreamer1.0-0:i386
+        sudo aptitude install -y libsane:i386
+        sudo aptitude install -y libodbc1:i386
+
+        sudo rm -rvf /var/lib/apt/lists/*
+        sudo apt-get install -f
+        sudo apt-get update
+        sudo apt-get upgrade
+        sudo apt-get dist-upgrade
+
+        sudo apt-get install -y wine-stable-i386
+
+        sudo apt-get install -y --no-install-recommends winehq-stable
+
+        wine --version
         sudo apt-get install -y fakeroot
     - name: Install mono
       run: |
@@ -39,4 +62,4 @@ jobs:
     - name: build
       run: yarn run dist
       env:
-        GH_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+        GH_TOKEN: ${{ secrets.GITHUB_TOKEN }}

public/electron.js

@@ -18,6 +18,7 @@ console.log("notRelease", notRelease)
 let loadingScreen;
 let mainWindow;
 let tcpConn;
+let boadcastConn;
 
 const createWindow = () => {
   // Create the browser window.
@@ -150,7 +151,7 @@ ipcMain.on("getActReactCouples", (event, arg) => {
   }
 });
 
-ipcMain.on("setMicLevel", (event, arg) => {
+ipcMain.on("setCompressorLevel", (event, arg) => {
   if (isDev) {
     let res = {
       message: "OK",
@@ -203,22 +204,6 @@ ipcMain.on("setActionReaction", (event, arg) => {
   }
 });
 
-ipcMain.on("setAutoAudioLeveler", (event, arg) => {
-  if (isDev) {
-    let res = {
-      message: "OK",
-      statusCode: 200,
-    };
-    event.returnValue = res;
-    return res;
-  } else {
-    return tcpConn.setAutoAudioLeveler(arg).then((res) => {
-      console.log("setAutoAudioLeveler : " + res);
-      event.returnValue = res;
-    });
-  }
-});
-
 ipcMain.on("removeActReact", (event, arg) => {
   if (isDev) {
     console.log("removeActReact")
@@ -239,15 +224,22 @@ ipcMain.on("removeActReact", (event, arg) => {
   }
 });
 
+ipcMain.on("compressor-level-updated", (evt, arg) => { // Get from socket broadcast
+    mainWindow.webContents.send('compressor-level-updated'); // To renderer
+});
+
+ipcMain.on("scenes-updated", (evt, arg) => { // Get from socket broadcast
+  mainWindow.webContents.send('scenes-updated'); // To renderer
+});
+
 ipcMain.on("connection-server-lost", (evt, arg) => {
   // Quit main app
   if (mainWindow)
     mainWindow.close();
   tcpConn = null;
+  boadcastConn = null;
 
   // Load Loading page
-  if (loadingScreen)
-    loadingScreen.close()
   createLoadingScreen()
 });
 
@@ -258,19 +250,33 @@ ipcMain.on("close-me", (evt, arg) => {
 const createLoadingScreen = () => {
 
   tcpConn = new TCPConnection("localhost", 47920, ipcMain);
+  boadcastConn = new TCPConnection("localhost", 47920, ipcMain)
   // Try to connect every 5 seconds 
   let refreshIntervalId = setInterval(() => {
 
     tcpConn
       .connect()
       .then((res) => {
-        console.log("TCPConnection is connected");
-        launchingApplication();
-        console.log("res", res);
         clearInterval(refreshIntervalId);
-        return res;
-      })
-      .catch((err) => {
+        boadcastConn.connectBroadcast()
+        .then((broadcast_res) => {
+          console.log("TCPConnection and Broadcast is connected");
+          launchingApplication();
+          clearInterval(refreshIntervalId);
+          return res;
+        }).catch((err) => {
+          tcpConn.disconnectSocket()
+          if (isDev) {
+            console.log("DEV MODE");
+            clearInterval(refreshIntervalId);
+            return null;
+          } else {
+            console.log("Can't locate the server", err);
+            setInterval(refreshIntervalId, 5000)
+            return null;
+          }
+        })
+      }).catch((err) => {
         if (isDev) {
           console.log("DEV MODE");
           clearInterval(refreshIntervalId);
@@ -281,33 +287,35 @@ const createLoadingScreen = () => {
         }
       });
 
-  }, 5000);
-
-  /// create a browser window
-  loadingScreen = new BrowserWindow(
-    Object.assign({
-      /// define width and height for the window
-      width: 440,
-      height: 260,
-      title: "EasyStream",
-      icon: __dirname + '/icon.png',
-      /// remove the window frame, so it will become a frameless window
-      frame: false,
-      /// and set the transparency, to remove any window background color
-      transparent: true,
-      webPreferences: {
-        nodeIntegration: true,
-        enableRemoteModule: isDev,
-        contextIsolation: false,
-      },
-    }),
-  );
-  loadingScreen.setResizable(false);
-  loadingScreen.loadURL(`file://${path.join(__dirname, "./loading.html")}`);
-  loadingScreen.on("closed", () => (loadingScreen = null));
-  loadingScreen.webContents.on("did-finish-load", () => {
-    loadingScreen.show();
-  });
+  }, 3000);
+
+  if (!loadingScreen) {
+    /// create a browser window
+    loadingScreen = new BrowserWindow(
+      Object.assign({
+        /// define width and height for the window
+        width: 440,
+        height: 260,
+        title: "EasyStream",
+        icon: __dirname + '/icon.png',
+        /// remove the window frame, so it will become a frameless window
+        frame: false,
+        /// and set the transparency, to remove any window background color
+        transparent: true,
+        webPreferences: {
+          nodeIntegration: true,
+          enableRemoteModule: isDev,
+          contextIsolation: false,
+        },
+      }),
+    );
+    loadingScreen.setResizable(false);
+    loadingScreen.loadURL(`file://${path.join(__dirname, "./loading.html")}`);
+    loadingScreen.on("closed", () => (loadingScreen = null));
+    loadingScreen.webContents.on("did-finish-load", () => {
+      loadingScreen.show();
+    });
+  }
 };
 
 const launchingApplication = () => {
@@ -375,6 +383,7 @@ app.on("window-all-closed", () => {
 
 app.on("before-quit", () => {
   tcpConn.disconnectSocket();
+  boadcastConn.disconnectSocket();
 });
 
 // In this file you can include the rest of your app's specific main process

src/Components/CompressorLevel/CompressorLevel.tsx

@@ -46,40 +46,39 @@ export const CompressorLevel = () => {
   const setVolumeToCompressor = (mic: Mic): Promise<resultFormat> => {
     return new Promise(async (resolve, reject) => {
       const result: resultFormat = await ipcRenderer.sendSync(
-        "setMicLevel",
+        "setCompressorLevel",
         mic
       );
       console.log("setVolumeToCompressor invoke", result);
       resolve(result);
     });
   };
 
-  const getData = (index: number, value: number) => {
+  const setCompressorValue = (index: number, value: number) => {
     let copy = exampleCompressorArray.slice();
     copy[index].level = value;
     console.log("Value", copy[index]);
     setExampleCompressorArray(copy);
 
-    // Update to server
-    clearTimeout(timeoutCommit);
-    timeoutCommit = setTimeout(() => {
-      setVolumeToCompressor(copy[index]);
-    }, 3000);
+    setVolumeToCompressor(copy[index]);
   };
 
   const setActive = (index: number, value: boolean) => {
     let copy = exampleCompressorArray.slice();
     copy[index].isActive = value;
     setExampleCompressorArray(copy);
 
-    // Update to server
-    clearTimeout(timeoutCommit);
-    timeoutCommit = setTimeout(() => {
-      setVolumeToCompressor(copy[index]);
-    }, 3000);
+    setVolumeToCompressor(copy[index]);
   };
 
   useEffect(() => {
+    ipcRenderer.on('compressor-level-updated', (evt: any, message: any) => {
+      getAllCompressors().then((res) => {
+        if (res.statusCode === 200) {
+          setExampleCompressorArray(res.data.mics);
+        }
+      });
+    })
     async function sleep(): Promise<boolean> {
       return new Promise((resolve) => {
         getAllCompressors().then((res) => {
@@ -145,7 +144,7 @@ export const CompressorLevel = () => {
                           isActive={item.isActive}
                           name={item.micName}
                           value={item.level}
-                          sendData={(val: number) => getData(index, val)}
+                          sendData={(val: number) => setCompressorValue(index, val)}
                           sendActive={(val: boolean) => setActive(index, val)}
                         />
                       );