dylan/rewind
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor & silence ConnectionRefusedError when attempting to connect to OBS instance

Browse Source
This commit is contained in:
Dylan De Faoite
2026-01-18 23:37:49 +00:00
parent 7a2b4e806f
commit 47bbfb9607
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
rewind/daemon.py
View File

@@ -5,6 +5,7 @@ import signal
import time import time
import obsws_python as obs import obsws_python as obs
import subprocess import subprocess
import logging
from watchdog.observers import Observer from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler from watchdog.events import FileSystemEventHandler
@@ -14,6 +15,7 @@ from rewind.state import add_file_to_state, create_state_file_if_needed, cleanup
INTERVAL = 10 INTERVAL = 10
running = True running = True
logging.getLogger("obsws_python").setLevel(logging.CRITICAL)
def open_obs(): def open_obs():
kill_command = subprocess.Popen(["pkill", "obs"]) kill_command = subprocess.Popen(["pkill", "obs"])
@@ -27,12 +29,14 @@ def open_obs():
def open_obs_connection(host: str, port: int, password: str) -> obs.ReqClient | None: def open_obs_connection(host: str, port: int, password: str) -> obs.ReqClient | None:
con = None con = None
max_attempts = 10
init_sleep = 1 init_sleep = 1
for _ in range(10):
for _ in range(max_attempts):
try: try:
con = obs.ReqClient(host=host, port=port, password=password) con = obs.ReqClient(host=host, port=port, password=password)
except Exception: except ConnectionRefusedError:
pass print("OBS WebSocket not ready, retrying...")
if con: if con:
return con return con