Restreaming mic

gui/modules/handlers/register.py

@@ -4,18 +4,14 @@ from gui.modules import menu
 from gui.modules import pads
 from gui.modules import player
 from gui.modules import settings
+from gui.modules import restreammic
 from modules.player.player import Player
+from modules.restream.restream import Restreamer
 
 
-def register_handlers(ui: Ui_MainWindow, MainWindow: QMainWindow, p: Player):
-    """
-    Register all handlers
-    :param ui:
-    :param MainWindow:
-    :param p:
-    :return:
-    """
+def register_handlers(ui: Ui_MainWindow, MainWindow: QMainWindow, p: Player, rs: Restreamer):
     menu.register_handlers(ui)
     pads.register_handlers(ui, MainWindow, p)
     player.register_handlers(ui, MainWindow, p)
     settings.register_handlers(ui)
+    restreammic.register_handlers(ui, MainWindow, rs)

gui/modules/initialize/setup_ui.py

@@ -7,6 +7,7 @@ from PyQt5.QtWidgets import QMainWindow
 from PyQt5 import QtCore
 from modules.config import Config
 from modules.player.player import Player
+from modules.restream.restream import Restreamer
 
 
 def on_load(ui: Ui_MainWindow, MainWindow: QMainWindow):
@@ -27,7 +28,10 @@ def on_load(ui: Ui_MainWindow, MainWindow: QMainWindow):
     ui.timer.start(100)
 
     p = Player()
+    rs = Restreamer()
 
     fill_settings.fill_settings(ui)
 
-    register.register_handlers(ui, MainWindow, p)
+    (lambda: rs.restart(ui) if ui.restream_micro_checkbox.isChecked() else rs.stop())()
+
+    register.register_handlers(ui, MainWindow, p, rs)

gui/modules/restreammic/handlers.py

@@ -0,0 +1,12 @@
+from gui.gui import Ui_MainWindow
+from PyQt5.QtWidgets import QMainWindow
+from modules.restream.restream import Restreamer
+
+
+def register_handlers(ui: Ui_MainWindow, MainWindow: QMainWindow, rs: Restreamer):
+    ui.restream_micro_checkbox.clicked.connect(
+        lambda: rs.restart(ui) if ui.restream_micro_checkbox.isChecked() else rs.stop()
+    )
+
+    ui.output_device_restream_box.currentTextChanged.connect(lambda: rs.restart(ui))
+    ui.input_device_restream_box.currentTextChanged.connect(lambda: rs.restart(ui))

modules/restream/restream.py

@@ -19,3 +19,6 @@ class Restreamer(object):
                                         get_streaming_devices().output[ui.output_device_restream_box.currentText()]),
                                 callback=Restreamer.callback)
         self.stream.start()
+
+    def stop(self):
+        self.stream.stop()