bot telegram con todos los avisos

cliente_template.py

@@ -212,7 +212,7 @@ async def pipeline():
                     proyecto_idx = CONFIG.get("proyecto_idx", -1)
                     if proyecto_idx >= 0:
                         requests.post("https://cristobal299-iaweb.hf.space/reportar-uso",
-                            json={"proyecto_idx": proyecto_idx}, timeout=10)
+                            json={"proyecto_idx": proyecto_idx, "email": CLIENT_EMAIL, "titulo": titulo}, timeout=10)
                 except Exception as eu:
                     log(f"No se pudo reportar uso: {eu}")
             except FileNotFoundError:

main.py

@@ -84,6 +84,21 @@ def enviar_email(email, nicho, url):
 
 CLIENTES = {}
 
+def avisar_telegram(mensaje):
+    """Manda mensaje al canal de Telegram"""
+    try:
+        import requests as _r
+        token = os.environ.get("TELEGRAM_BOT_TOKEN", "")
+        chat_id = os.environ.get("TELEGRAM_CHAT_ID", "")
+        if not token or not chat_id:
+            return
+        _r.post(f"https://api.telegram.org/bot{token}/sendMessage",
+            json={"chat_id": chat_id, "text": mensaje, "parse_mode": "HTML"},
+            timeout=10
+        )
+    except Exception as e:
+        print(f"Error telegram: {e}", flush=True)
+
 def cargar_clientes():
     global CLIENTES
     try:
@@ -650,8 +665,20 @@ function copiar(){
 # ══════════════════════════════════════════
 #  RUTAS
 # ══════════════════════════════════════════
+VISITAS_CACHE = {}  # IP -> timestamp para no spamear avisos
+
 @app.get("/", response_class=HTMLResponse)
-async def home():
+async def home(request: Request):
+    try:
+        ip = request.client.host if request.client else "?"
+        import time as _t
+        ahora = _t.time()
+        # Avisar solo si esa IP no visito en los ultimos 10 min
+        if ip not in VISITAS_CACHE or ahora - VISITAS_CACHE[ip] > 600:
+            VISITAS_CACHE[ip] = ahora
+            ua = request.headers.get("user-agent","?")[:80]
+            avisar_telegram(f"👤 <b>Visita a landing</b>\n🌐 IP: {ip}\n📱 {ua}")
+    except: pass
     return VENTAS_HTML
 
 PLANES_CANALES = {"basico": 1, "oro": 5, "diamante": 9, "platinum": 20}
@@ -662,6 +689,7 @@ async def activar_canal(token: str = "", plan: str = ""):
         import secrets
         nuevo_token = secrets.token_urlsafe(32)
         TOKENS_VALIDOS[nuevo_token] = {"plan": plan}
+        avisar_telegram(f"💰 <b>POSIBLE VENTA</b>\n📦 Plan: {plan.upper()}\n🔥 Cliente llego a activar-canal tras pago Stripe")
         return ACTIVAR_HTML.replace("PLAN_PLACEHOLDER", plan).replace("TOKEN_PLACEHOLDER", nuevo_token).replace("CANALES_PLACEHOLDER", str(PLANES_CANALES[plan]))
     if token and token in TOKENS_VALIDOS:
         plan_token = TOKENS_VALIDOS[token].get("plan", "basico") if isinstance(TOKENS_VALIDOS[token], dict) else "basico"
@@ -759,6 +787,7 @@ async def crear(request: Request):
         CLIENTES[email]["canales"] = []
     CLIENTES[email]["canales"].append({"url": u, "nicho": nicho, "tipo": tipo, "repo": repo, "youtube": False, "config": config_parsed, "config_texto": config_libre})
     guardar_clientes()
+    avisar_telegram(f"🎬 <b>Canal creado</b>\n📧 {email}\n📺 Plan: {plan}\n🎯 Nicho: {nicho}\n🔗 {u}")
     # Consumir token si era nuevo
     if token in TOKENS_VALIDOS:
         del TOKENS_VALIDOS[token]
@@ -1150,8 +1179,11 @@ async def reportar_uso(request: Request):
     try:
         data = await request.json()
         idx = data.get("proyecto_idx", -1)
+        email = data.get("email", "?")
+        titulo = data.get("titulo", "?")
         if 0 <= idx < len(GOOGLE_PROYECTOS):
             incrementar_uso(idx)
+            avisar_telegram(f"📺 <b>Video subido a YouTube</b>\n📧 {email}\n🎬 {titulo[:60]}\n📊 Proyecto {idx+1}: {USOS_PROYECTO[idx]['count']} videos hoy")
             return {"ok": True, "usos_hoy": USOS_PROYECTO[idx]["count"]}
     except Exception as e:
         print(f"Error reportar uso: {e}", flush=True)