Detect monitored accounts that are live as guests inside another host's room (linker_map)

app.py

@@ -280,6 +280,8 @@ def get_json(url,params,user=None):
 _observation_cache={}
 _observation_locks={}
 _observation_guard=threading.Lock()
+_uid_cache={}          # user -> numeric TikTok id (من user/room)
+_guest_logged={}       # user -> غرفة المذيع المضيف التي سُجّل الدخول إليها
 
 def _as_dict(x):
     return x if isinstance(x, dict) else {}
@@ -295,9 +297,43 @@ def observe_session(user,force=False):
         cached=_observation_cache.get(user)
         if cached and not force and time.monotonic()-cached[0]<15:return cached[1]
         result=_observe_session(user)
+        if result.get('status')!='live':
+            # الحساب قد يكون ضيفًا داخل بث مذيع آخر: غرفته الخاصة تبقى «منتهية» بينما البث الحي في غرفة الضيوف
+            try:
+                guest=_guest_observation(user)
+            except Exception:
+                guest=None
+            if guest:result=guest
         _observation_cache[user]=(time.monotonic(),result)
         return result
 
+def _guest_observation(user):
+    """Account is not live in its own room. Check whether TikTok lists it in the linker_map
+    of another monitored host that is live right now; if so the live show is that room."""
+    uid=str(_uid_cache.get(user) or '')
+    if not uid.isdigit():return None
+    for other in enabled_accounts():
+        if other==user:continue
+        cached=_observation_cache.get(other)
+        if not cached or (cached[1] or {}).get('status')!='live':continue
+        host_room=str((cached[1] or {}).get('room_id') or '')
+        if not host_room.isdigit() or host_room=='0':continue
+        j=_as_dict(get_json('https://webcast.tiktok.com/webcast/room/info/',{'aid':1988,'room_id':host_room},other))
+        info=_as_dict(j.get('data'))
+        if str(info.get('status'))!='2':continue
+        if str(_as_dict(info.get('owner')).get('id_str') or info.get('owner_user_id') or '')==uid:continue
+        linkers=info.get('linker_map')
+        if not linkers or uid not in json.dumps(linkers,ensure_ascii=False):continue
+        sources=rank_sources(_as_dict(info.get('stream_url')))
+        if not sources:continue
+        if _guest_logged.get(user)!=host_room:
+            _guest_logged[user]=host_room
+            log(user,'[GUEST] @%s داخل بث @%s كضيف؛ نرصد غرفة المذيع المضيف'%(user,other))
+        return {'status':'live','room_id':host_room,'sources':sources,'nickname':user,
+                'live_title':str(info.get('title') or '').strip(),'guest_of':other}
+    _guest_logged.pop(user,None)
+    return None
+
 def _observe_session(user):
     """TikTok room lookup. Null liveRoom/user/data must be Offline, not a crash.
 
@@ -308,6 +344,7 @@ def _observe_session(user):
     j=_as_dict(get_json('https://www.tiktok.com/api-live/user/room',{'aid':1988,'uniqueId':user,'sourceType':54,'staleTime':0},user))
     d=_as_dict(j.get('data')); live=_as_dict(d.get('liveRoom')); person=_as_dict(d.get('user'))
     status=live.get('status')
+    if str(person.get('id') or '').isdigit():_uid_cache[user]=str(person.get('id'))
     room=str(person.get('roomId') or person.get('room_id') or live.get('roomId') or live.get('room_id') or '')
     nickname=str(person.get('nickname') or live.get('nickname') or '').strip()
     live_title=str(live.get('title') or '').strip()