02-ago: [proyecto] vigilancia - YouTube en la tele: youtube <URL> reproduce video y apaga al terminar. Comando en el bot.

vigilancia/pi_bot.py

@@ -94,6 +94,15 @@ def mandar_tv(mensaje, simple):
         return False
 
 
+def mandar_youtube(url):
+    try:
+        r = requests.get(f"http://127.0.0.1:8600/tv/youtube?url={url}", timeout=10)
+        return r.status_code == 200
+    except Exception as e:
+        log(f"youtube error: {e}")
+        return False
+
+
 def procesar(texto, chat_id):
     t = texto.lower().strip()
     log(f"RECIBIDO chat={chat_id} texto={texto!r}")
@@ -119,7 +128,7 @@ def procesar(texto, chat_id):
             ok = mandar_tv(msj, simple=False)
             enviar("🚨 Alarma lanzada en la tele ✅" if ok
                    else "❌ No se pudo lanzar la alarma", chat_id)
-    elif t in ("panorama", "/panorama"):
+    elif t.startswith("panorama") or t.startswith("/panorama"):
         enviar("📷 Capturando snapshots de las cámaras...", chat_id)
         try:
             import subprocess as sp
@@ -128,12 +137,20 @@ def procesar(texto, chat_id):
             log(f"panorama: {r.stdout.strip()[-200:]}")
         except Exception as e:
             log(f"panorama error: {e}")
+    elif t.startswith("youtube ") or t.startswith("/youtube "):
+        url = texto.split(" ", 1)[1].strip()
+        if not url:
+            enviar("Uso: <b>youtube &lt;URL&gt;</b>", chat_id)
+        else:
+            ok = mandar_youtube(url)
+            enviar("🎬 YouTube lanzado en la TV ✅" if ok else "❌ No se pudo lanzar YouTube", chat_id)
     elif t in ("ayuda", "/ayuda", "help", "/help"):
         enviar("Comandos:\n"
                "<b>estado</b> — estado de la Pi\n"
                "<b>temperatura</b> — temperatura\n"
                "<b>tv &lt;mensaje&gt;</b> — mensaje rápido a la tele\n"
                "<b>alarma &lt;mensaje&gt;</b> — secuencia completa (sirena x3)\n"
+               "<b>youtube &lt;URL&gt;</b> — reproduce YouTube y apaga al terminar\n"
                "<b>panorama</b> — fotos de las cámaras",
                chat_id)
 

vigilancia/tv_api.py

@@ -9,12 +9,24 @@ import sys
 sys.path.insert(0, sys_dir)
 
 import config
-from voz import anuncio_en_teles, anuncio_simple
+from voz import anuncio_en_teles, anuncio_simple, youtube_en_teles
 
 
 class Handler(BaseHTTPRequestHandler):
     def do_GET(self):
         q = parse_qs(urlparse(self.path).query)
+        path = urlparse(self.path).path
+
+        if path == "/tv/youtube":
+            url = (q.get("url") or [""])[0]
+            if not url:
+                self._resp(400, {"error": "falta parametro url"})
+                return
+            threading.Thread(target=youtube_en_teles, args=(url,), daemon=True).start()
+            print(f"[TV-API] YouTube lanzado: {url[:80]}")
+            self._resp(200, {"ok": True, "url": url, "modo": "youtube"})
+            return
+
         texto = (q.get("texto") or q.get("msg") or [""])[0]
         if not texto:
             self._resp(400, {"error": "falta parametro texto"})

vigilancia/voz.py

@@ -316,6 +316,53 @@ def reproducir_en_teles(texto):
     anuncio_en_teles(texto)
 
 
+def youtube_en_teles(url):
+    """Reproduce un video de YouTube en la tele y la apaga al terminar."""
+    import re
+    match = re.search(r"(?:v=|youtu\.be/)([A-Za-z0-9_-]{11})", url)
+    if not match:
+        print("[Voz] URL de YouTube no válida")
+        return
+    video_id = match.group(1)
+    try:
+        import pychromecast
+        from pychromecast.controllers.youtube import YouTubeController
+
+        chromecasts, browser = pychromecast.get_chromecasts(timeout=8)
+        try:
+            if config.GOOGLE_TV_NOMBRES:
+                objetivos = [c for c in chromecasts
+                             if c.cast_info.friendly_name in config.GOOGLE_TV_NOMBRES]
+            else:
+                objetivos = chromecasts
+            for c in objetivos:
+                try:
+                    c.wait(timeout=10)
+                    c.set_volume(config.GOOGLE_TV_VOLUMEN / 100.0)
+                    yt = YouTubeController()
+                    c.register_handler(yt)
+                    print(f"[Voz] Lanzando YouTube en {c.cast_info.friendly_name}: {video_id}")
+                    yt.play_video(video_id)
+                    # Esperar a que termine el video
+                    time.sleep(5)
+                    while True:
+                        try:
+                            state = c.media_controller.status.player_state
+                            if state == "IDLE":
+                                break
+                        except Exception:
+                            pass
+                        time.sleep(3)
+                    apagar_tv_remote()
+                    print(f"[Voz] Video terminado, TV apagada")
+                except Exception as e:
+                    print(f"[Voz] Error en {c.cast_info.friendly_name}: {e}")
+        finally:
+            pychromecast.discovery.stop_discovery(browser)
+    except Exception as e:
+        print(f"[Voz] Error YouTube: {e}")
+
+
 def apagar_tv_remote():
     """Apaga la TV via AndroidTVRemote (protocolo oficial Google)."""
     try: