Fix video title fetch for live streams + fix subtitle encoding

app.py

@@ -569,13 +569,34 @@ def extract_video_id(url_or_id):
 
 
 def fetch_video_title(video_id):
+    """Try oembed first (works for non-live), then YouTube Data API v3 (works for live)."""
+    import urllib.request
+    import urllib.parse
+    # Try oembed first (fast, no API key needed)
     try:
-        import urllib.request
         url = f"https://www.youtube.com/oembed?url=https://www.youtube.com/watch?v={video_id}&format=json"
         with urllib.request.urlopen(url, timeout=5) as resp:
-            return json.loads(resp.read())["title"]
+            title = json.loads(resp.read()).get("title")
+            if title:
+                return title
     except Exception:
-        return None
+        pass
+    # Fallback: YouTube Data API v3 (works for live streams)
+    try:
+        api_key = os.getenv("YOUTUBE_API_KEY", "")
+        if api_key:
+            url = (
+                "https://www.googleapis.com/youtube/v3/videos"
+                f"?part=snippet&id={urllib.parse.quote(video_id)}&key={api_key}"
+            )
+            with urllib.request.urlopen(url, timeout=5) as resp:
+                data = json.loads(resp.read())
+                items = data.get("items", [])
+                if items:
+                    return items[0]["snippet"]["title"]
+    except Exception:
+        pass
+    return None
 
 
 def clean_topic(val):
@@ -1098,11 +1119,11 @@ for _si, _ss in enumerate(st.session_state.streams):
     _st = _ss.get("video_title") or _ss.get("video_id")
     _sk = _ss.get("redis_key", "")
     if _st and (store_llen(_sk) > 0 or is_scraper_running(_si)):
-        _all_titles.append(f"? {_st}")
+        _all_titles.append(f"\u25b6 {_st}")
 if _all_titles:
-    _subtitle = "  �  ".join(_all_titles)
+    _subtitle = "  \u00b7  ".join(_all_titles)
 else:
-    _subtitle = "Real-time sentiment � topic classification � engagement insights"
+    _subtitle = "Real-time sentiment \u00b7 topic classification \u00b7 engagement insights"
 
 # Build active stream pills for header
 _active_stream_pills = ""

shared.py

@@ -332,13 +332,32 @@ def extract_video_id(url_or_id: str) -> str:
 
 
 def fetch_video_title(video_id: str) -> str | None:
+    """Try oembed first (works for non-live), then YouTube Data API v3 (works for live)."""
+    import urllib.request
+    import urllib.parse
     try:
-        import urllib.request
         url = f"https://www.youtube.com/oembed?url=https://www.youtube.com/watch?v={video_id}&format=json"
         with urllib.request.urlopen(url, timeout=5) as resp:
-            return json.loads(resp.read())["title"]
+            title = json.loads(resp.read()).get("title")
+            if title:
+                return title
     except Exception:
-        return None
+        pass
+    try:
+        api_key = os.getenv("YOUTUBE_API_KEY", "")
+        if api_key:
+            url = (
+                "https://www.googleapis.com/youtube/v3/videos"
+                f"?part=snippet&id={urllib.parse.quote(video_id)}&key={api_key}"
+            )
+            with urllib.request.urlopen(url, timeout=5) as resp:
+                data = json.loads(resp.read())
+                items = data.get("items", [])
+                if items:
+                    return items[0]["snippet"]["title"]
+    except Exception:
+        pass
+    return None
 
 
 def clean_topic(val) -> str: