Guest: never publish twice when host is already relayed; log guest transitions once

app.py

@@ -470,6 +470,17 @@ def _guest_source(user, own):
     nick=str((own or {}).get('nickname') or hobs.get('nickname') or user)
     return {**hobs,'nickname':nick}, host
 
+_guest_logged={}
+
+def _guest_note(user, host):
+    """Log guest transitions only (the monitor runs every cycle)."""
+    if host:
+        if _guest_logged.get(user)!=host:
+            _guest_logged[user]=host
+            log(user,'[GUEST] @%s is a guest on @%s'%(user,host))
+    else:
+        _guest_logged.pop(user,None)
+
 def _oauth_automation_on():
     try:return bool(youtube.journal.read().get('enabled'))
     except Exception:return False
@@ -848,13 +859,19 @@ def _check_account(user):
         if top:log(user,'[SOURCE] @%s selected %s'%(user,brief))
         if prev_room and prev_room!=obs.get('room_id') and relaying:
             log(user,'[MONITOR] @%s session/room changed; source will be refreshed'%user)
+    if src_host and hub.busy(src_host):
+        # Host is already published by this project on the single RTMPS key: never publish twice.
+        if relaying:
+            _stop_direct(user, 'guest on @%s (host already relayed)'%src_host)
+        _guest_note(user, src_host)
+        _set_state(user,'LIVE','LIVE · ضيف عند @%s (البث عبر @%s)'%(src_host,src_host),**extra)
+        return
     if relaying:
         with _direct_guard:cur_src=(_direct_handles.get(user) or {}).get('src','')
         if cur_src!=src_host:
             _stop_direct(user, 'guest source switch')
             log(user,'[GUEST] @%s source switch: %s'%(user, ('guest on @%s'%src_host) if src_host else 'own room'))
-    if src_host:
-        log(user,'[GUEST] @%s is a guest on @%s; relaying host stream'%(user,src_host))
+    _guest_note(user, src_host)
     _set_state(user,'LIVE','LIVE' if not src_host else 'LIVE · ضيف عند @%s'%src_host,**extra)
     _maybe_start_direct(user, obs, src_host)
     if _oauth_automation_on() and not hub.busy(user) and (obs.get('sources') or []):