add poetry badge

README.md

@@ -1,5 +1,6 @@
 [![PyPI version](https://badge.fury.io/py/xair-api.svg)](https://badge.fury.io/py/xair-api)
 [![License: MIT](https://img.shields.io/badge/License-MIT-yellow.svg)](https://github.com/onyx-and-iris/xair-api-python/blob/dev/LICENSE)
+[![Poetry](https://img.shields.io/endpoint?url=https://python-poetry.org/badge/v0.json)](https://python-poetry.org/)
 [![Ruff](https://img.shields.io/endpoint?url=https://raw.githubusercontent.com/astral-sh/ruff/main/assets/badge/v2.json)](https://github.com/astral-sh/ruff)
 ![Tests Status](./tests/xair/MR18.svg?dummy=8484744)
 

examples/xair_obs/README.md

@@ -19,7 +19,7 @@ password = "mystrongpass"
 
 ## Use
 
-Change the xair ip argument from `mixer.local` to the ip of your xair mixer. Run the code and switch between scenes in OBS.
+Change the xair ip argument from `mixer.local` to the ip of your xair mixer. Run the code and switch between scenes in OBS. Closing OBS will end the script.
 
 ## Notes
 

examples/xair_obs/__main__.py

@@ -1,13 +1,48 @@
-import obsws_python as obs
+import threading
+from logging import config
+
+import obsws_python as obsws
 
 import xair_api
 
+config.dictConfig(
+    {
+        'version': 1,
+        'formatters': {
+            'standard': {
+                'format': '%(asctime)s,%(msecs)d %(name)s %(levelname)s %(message)s'
+            }
+        },
+        'handlers': {
+            'stream': {
+                'level': 'DEBUG',
+                'class': 'logging.StreamHandler',
+                'formatter': 'standard',
+            }
+        },
+        'loggers': {
+            'xair_api.xair': {
+                'handlers': ['stream'],
+                'level': 'DEBUG',
+                'propagate': False,
+            }
+        },
+        'root': {'handlers': ['stream'], 'level': 'WARNING'},
+    }
+)
+
 
 class Observer:
-    def __init__(self, mixer):
+    def __init__(self, mixer, stop_event):
         self._mixer = mixer
-        self._client = obs.EventClient()
-        self._client.callback.register(self.on_current_program_scene_changed)
+        self._stop_event = stop_event
+        self._client = obsws.EventClient()
+        self._client.callback.register(
+            (
+                self.on_current_program_scene_changed,
+                self.on_exit_started,
+            )
+        )
 
     def __enter__(self):
         return self
@@ -32,12 +67,16 @@ class Observer:
                 self._mixer.config.mute_group[0].on = True
                 print(f'Mute Group 1 is {self._mixer.config.mute_group[0].on}')
 
+    def on_exit_started(self, _):
+        self._stop_event.set()
+
 
 def main():
     with xair_api.connect('MR18', ip='mixer.local') as mixer:
-        with Observer(mixer):
-            while _ := input('Press <Enter> to exit\n'):
-                pass
+        stop_event = threading.Event()
+
+        with Observer(mixer, stop_event):
+            stop_event.wait()
 
 
 if __name__ == '__main__':