1 files changed, 72 insertions, 0 deletions
diff --git a/tests/test_obs.py b/tests/test_obs.py
new file mode 100644
index 0000000..876d48b
--- /dev/null
+++ b/tests/test_obs.py
@@ -0,0 +1,72 @@
+import sys
+from pathlib import Path
+
+sys.path.insert(0, str(Path(__file__).resolve().parent.parent))
+
+import threading
+import time
+import unittest
+
+import deckit.modules.obs as obs
+
+
+class Fake:
+    connected = True
+
+    def request(self, kind, data=None):
+        Fake.last = (kind, data)
+        return {"ok": True}
+
+
+class Actions(unittest.TestCase):
+    def setUp(self):
+        self.m = obs.make({"obs": {"host": "h", "port": 4455, "password": ""}, "client": Fake()})
+
+    def test_scene_and_record(self):
+        self.m.actions["scene"]({"scene": "Live"})
+        self.assertEqual(Fake.last[0], "SetCurrentProgramScene")
+        self.m.actions["record"]({"on": True})
+        self.assertEqual(Fake.last[0], "StartRecord")
+        self.m.actions["record"]({"on": False})
+        self.assertEqual(Fake.last[0], "StopRecord")
+
+    def test_mute_and_source(self):
+        self.m.actions["mute"]({"input": "Mic", "muted": True})
+        self.assertEqual(Fake.last[0], "SetInputMute")
+        self.m.actions["source"]({"scene": "S", "id": 2, "on": False})
+        self.assertEqual(Fake.last[0], "SetSceneItemEnabled")
+
+    def test_state_offline(self):
+        class Off:
+            connected = False
+        self.assertEqual(obs.make({"client": Off()}).state(), {"connected": False})
+
+
+class Serialized(unittest.TestCase):
+    def test_actions_do_not_overlap(self):
+        active = 0
+        overlap = []
+
+        class Guard:
+            connected = True
+
+            def request(self, kind, data=None):
+                nonlocal active
+                active += 1
+                if active > 1:
+                    overlap.append(kind)
+                time.sleep(0.02)
+                active -= 1
+                return {}
+
+        m = obs.make({"client": Guard()})
+        threads = [threading.Thread(target=m.actions["record"], args=({"on": True},)) for _ in range(5)]
+        for t in threads:
+            t.start()
+        for t in threads:
+            t.join()
+        self.assertEqual(overlap, [])
+
+
+if __name__ == "__main__":
+    unittest.main()