Some fixes, recording toggle

Author: mrdon

src/sleuthdeck/actions.py

@@ -145,24 +145,28 @@ def __call__(self, scene: KeyScene, key: Key, click: ClickType):
 
 
 class SendHotkey(Action):
-    def __init__(self, title: Union[str, By], *hotkey: str):
+    def __init__(self, title: Union[str, By] | None, *hotkey: str):
         self.title = title
         self.hotkey = hotkey
 
     def __call__(self, scene: KeyScene, key: Key, click: ClickType):
         print("sending key")
+
         focused_window = get_focused_window()
+        if self.title:
+
+            window = get_window(self.title, attempts=5 * 10)
+            if not window:
+                print(f"No window found for {self.title}")
+                return
+            print(f"got window {self.title}")
+            window.focus()
 
-        window = get_window(self.title, attempts=5 * 10)
-        if not window:
-            print(f"No window found for {self.title}")
-            return
-        print(f"got window {self.title}")
-        window.focus()
         from pyautogui import hotkey
         hotkey(*self.hotkey)
         print("sent")
-        focused_window.focus()
+        if self.title:
+            focused_window.focus()
 
 
 class DeckBrightness(Action):

src/sleuthdeck/cli.py

@@ -10,6 +10,8 @@
 from multiprocessing import Queue
 from types import ModuleType
 
+from StreamDeck.Transport.Transport import TransportError
+
 from sleuthdeck.deck import Deck
 from watchdog.events import FileSystemEventHandler
 
@@ -57,7 +59,7 @@ def run(self):
                     self.deck.close()
                 try:
                     deck = Deck()
-                except RuntimeError as e:
+                except (RuntimeError, TransportError):
                     print("No streamdeck found, waiting 5s")
                     time.sleep(5)
                     self.deck = None
@@ -70,6 +72,7 @@ def run(self):
                 except Exception as e:
                     print(f"Error: {e}")
                     traceback.print_exc()
+                    self.deck = None
                     continue
                 while self.deck.stream_deck.is_open() and self._reloading_queue.empty():
                     time.sleep(1)

src/sleuthdeck/plugins/obs/actions.py

@@ -127,17 +127,30 @@ def set_scene_item_enabled(self, scene: str, name: str, enabled: bool = True):
             "sceneItemEnabled": enabled,
         })
 
-    def stop_recording(self):
-        return ObsAction(self, lambda obs: obs.call("StopRecord"))
+    def stop_recording(self, vertical=False):
+        def execute(obs):
+            obs.call("StopRecord")
+            if vertical:
+                obs.call("CallVendorRequest", {"vendorName": "aitum-vertical-canvas", "requestType": "stop_recording"})
 
-    def start_recording(self):
-        return ObsAction(self, lambda obs: obs.call("StartRecord"))
+        return ObsAction(self, execute)
+
+
+    def start_recording(self, vertical=False):
+        def execute(obs):
+            obs.call("StartRecord")
+            if vertical:
+                obs.call("CallVendorRequest", {"vendorName": "aitum-vertical-canvas", "requestType": "start_recording"})
+        return ObsAction(self, execute)
 
     def set_item_property(self, name: str, property: str, value: Any):
         self.call("SetInputSettings", {"inputName": name,
                                        "inputSettings": {property: value},
                                        "overlay": True})
 
+    def create_record_chapter(self, name: str):
+        self.call("CreateRecordChapter", {"chapterName": name})
+
     def get_filter_settings(self, source_name: str, filter_name: str):
         return self.call("GetSourceFilter", {"sourceName": source_name,
                                              "filterName": filter_name})

src/sleuthdeck/plugins/presentation/actions.py

@@ -46,6 +46,7 @@ def __init__(self, obs: OBS, path: str, title_scene_item="Section title",
         self.guest2_name_item = guest2_name_item
         self.guest2_title_item = guest2_title_item
 
+        self.current_section_idx = 0
         try:
             self._reload()
         except ConnectionError:
@@ -54,11 +55,11 @@ def __init__(self, obs: OBS, path: str, title_scene_item="Section title",
         if not self.event.sections:
             return
 
-        self.current_section_idx = 0
         self.title_scene_item = title_scene_item
         self.byline_scene_item = byline_scene_item
         self.title_scene = title_scene
         self.overlay_scene = overlay_scene
+        self._recording = False
 
     def _reload(self):
         with open(self.path, "r") as stream:
@@ -95,6 +96,7 @@ def action(scene: KeyScene, key: Key, click: ClickType):
             section = self._next_section()
 
             self._update_labels(section, next_scene=section.scene)
+            self.obs.create_record_chapter(section.title)
 
         return action
 
@@ -104,13 +106,26 @@ def action(scene: KeyScene, key: Key, click: ClickType):
                 self._reload()
             self.current_section_idx = 0
             self._update_labels(self.event.sections[0])
+            self.obs.create_record_chapter(self.event.sections[self.current_section_idx].title)
+
+        return action
+
+    def toggle_record(self) -> Action:
+        def action(scene: KeyScene, key: Key, click: ClickType):
+            if self._recording:
+                self.obs.stop_recording(vertical=True)
+                self._recording = False
+            else:
+                self.obs.start_recording(vertical=True)
+                self._recording = True
 
         return action
 
     def previous_section(self) -> Action:
         def action(scene: KeyScene, key: Key, click: ClickType):
             section = self._previous_section()
             self._update_labels(section, next_scene=section.scene)
+            self.obs.create_record_chapter(section.title)
 
         return action
 

src/work.py

@@ -88,6 +88,10 @@ def run(deck: Deck):
             ]
         ),
     )
+    scene1.add(
+        (0, 2),
+        OBSKey(text="Standing", actions=[obs.change_scene("Camera only (standing)")]),
+    )
 
     scene1.add(
         (0, 3),
@@ -143,7 +147,11 @@ def run(deck: Deck):
     scene1.add(
         (2, 0),
         FontAwesomeKey(name="regular/file-audio", tint="green", actions=[
-            SendHotkey(By.window_class("spotify.Spotify"), "space"),
+            #SendHotkey(By.window_class("spotify.Spotify"), "space"),
+            SendHotkey(None, "ctrl", "shift", "alt", "m"),
+            Wait(2),
+            SendHotkey(None, "space"),
+            SendHotkey(None, "ctrl", "shift", "alt", "m"),
         ]),
     )
 
@@ -166,6 +174,16 @@ def run(deck: Deck):
             )]
         ),
     )
+    scene1.add(
+        (2, 3),
+        FontAwesomeKey(
+            "regular/window-restore",
+            text="",
+            actions=[
+                Command("/home/mrdon/dev/dev-machine/windows.py", "-restore")
+            ]
+        ),
+    )
 
     sleep_toggle = Toggle(
         on_enable=DeckBrightness(5),
@@ -415,10 +433,13 @@ def _build_webinar_scene_base(obs, parent_scene, presso, webinar_scene):
 
                    ])])
     )
+
     webinar_scene.add(
         (1, 4),
-        FontAwesomeKey("solid/camera", text="T Cam", actions=[obs.toggle_source("[Scene] Me corner (shadowed)"),
-                                                              ]),
+        FontAwesomeKey("solid/camera", text="Record", actions=[Toggle(
+            on_enable=obs.start_recording(vertical=True),
+            on_disable=obs.stop_recording(vertical=True),
+        )]),
     )
     webinar_scene.add(
         (2, 1),