rotacion automatica proyectos google

cliente_template.py

@@ -39,7 +39,6 @@ except Exception as e:
 GROQ_KEY   = "GROQ_PLACEHOLDER"
 TIPO_VIDEO = "TIPO_PLACEHOLDER"
 PEXELS_KEY = "PEXELS_PLACEHOLDER"
-os.makedirs("media_cliente", exist_ok=True)
 LOGS       = []
 STATUS     = "Iniciando..."
 
@@ -93,10 +92,9 @@ async def pipeline():
             fondos = []
             # Revisar si hay media propia del cliente
             archivos_propios = []
-            if os.path.exists("media_cliente"):
-                for f in sorted(os.listdir("media_cliente")):
-                    if f.lower().endswith((".mp4", ".mov", ".jpg", ".jpeg", ".png", ".webp")):
-                        archivos_propios.append(f"media_cliente/{f}")
+            for f in sorted(os.listdir(".")):
+                if f.startswith("media_") and f.lower().endswith((".mp4", ".mov", ".jpg", ".jpeg", ".png", ".webp")):
+                    archivos_propios.append(f)
             if archivos_propios:
                 random.shuffle(archivos_propios)
                 fondos = archivos_propios[:6]
@@ -184,6 +182,14 @@ async def pipeline():
                 while resp is None:
                     _, resp = req_yt.next_chunk()
                 log(f"Subido: {titulo[:40]}")
+                # Reportar uso al IAweb
+                try:
+                    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)
+                except Exception as eu:
+                    log(f"No se pudo reportar uso: {eu}")
             except FileNotFoundError:
                 log("Sin token.json, saltando subida")
             except Exception as ey:

main.py

@@ -191,7 +191,7 @@ CMD [\"uvicorn\", \"main:app\", \"--host\", \"0.0.0.0\", \"--port\", \"7860\"]""
                     if not contenido_b64: continue
                     binario = base64.b64decode(contenido_b64)
                     r_up = await client.put(
-                        f"https://huggingface.co/api/repos/{repo_name}/upload/main/media_cliente/{nombre}",
+                        f"https://huggingface.co/api/repos/{repo_name}/upload/main/media_{nombre}",
                         headers={"Authorization": f"Bearer {token_actual}", "Content-Type": "application/octet-stream"},
                         content=binario
                     )
@@ -708,6 +708,11 @@ async def crear(request: Request):
         return JSONResponse({"error": f"Has alcanzado el limite de tu plan {plan} ({limite} canales)"}, status_code=400)
     # Parsear preferencias del cliente con Groq ANTES de crear
     config_parsed = await parsear_config_groq(config_libre)
+    # Asignar proyecto disponible y guardarlo en config
+    if not isinstance(config_parsed, dict):
+        config_parsed = {}
+    idx_disponible = proyecto_disponible()
+    config_parsed["proyecto_idx"] = idx_disponible
     # Crear el canal pasando la config
     resultado = await crear_space(nicho, email, tipo, config_parsed, archivos_subidos)
     if not resultado:
@@ -966,19 +971,37 @@ GOOGLE_PROYECTOS = [
 ]
 GOOGLE_PROYECTOS = [(c,s) for c,s in GOOGLE_PROYECTOS if c and s]
 
+import datetime as _dt
+USOS_PROYECTO = {}  # {idx: {"fecha": "2026-05-27", "count": 5}}
+
+def reset_si_nuevo_dia(idx):
+    hoy = _dt.date.today().isoformat()
+    if idx not in USOS_PROYECTO or USOS_PROYECTO[idx].get("fecha") != hoy:
+        USOS_PROYECTO[idx] = {"fecha": hoy, "count": 0}
+
+def incrementar_uso(idx):
+    reset_si_nuevo_dia(idx)
+    USOS_PROYECTO[idx]["count"] += 1
+
+def proyecto_disponible():
+    """Devuelve indice del proyecto con menos usos hoy (max 5 videos/dia)"""
+    if not GOOGLE_PROYECTOS:
+        return 0
+    contadores = []
+    for i in range(len(GOOGLE_PROYECTOS)):
+        reset_si_nuevo_dia(i)
+        contadores.append((USOS_PROYECTO[i]["count"], i))
+    contadores.sort()
+    return contadores[0][1]  # el indice con menos usos
+
 def get_proyecto_cliente(email):
     """Devuelve el proyecto Google asignado al cliente, o asigna uno nuevo"""
     if email in CLIENTES and "google_index" in CLIENTES[email]:
         idx = CLIENTES[email]["google_index"]
         if idx < len(GOOGLE_PROYECTOS):
             return GOOGLE_PROYECTOS[idx], idx
-    # Asignar el de menos uso
-    contador = [0] * len(GOOGLE_PROYECTOS)
-    for c in CLIENTES.values():
-        gi = c.get("google_index", -1)
-        if 0 <= gi < len(GOOGLE_PROYECTOS):
-            contador[gi] += 1
-    idx = contador.index(min(contador))
+    # Asignar el proyecto con menos USOS hoy (mejor reparto de cuota)
+    idx = proyecto_disponible()
     return GOOGLE_PROYECTOS[idx], idx
 
 # Default para arranque (se sobrescribe por cliente)
@@ -1087,3 +1110,27 @@ async def oauth_callback(code: str, state: str):
     </body></html>
     """)
 # restart
+
+
+@app.post("/reportar-uso")
+async def reportar_uso(request: Request):
+    """Endpoint que cada cliente Space llama cuando sube un video"""
+    try:
+        data = await request.json()
+        idx = data.get("proyecto_idx", -1)
+        if 0 <= idx < len(GOOGLE_PROYECTOS):
+            incrementar_uso(idx)
+            return {"ok": True, "usos_hoy": USOS_PROYECTO[idx]["count"]}
+    except Exception as e:
+        print(f"Error reportar uso: {e}", flush=True)
+    return {"ok": False}
+
+
+@app.get("/estado-proyectos")
+async def estado_proyectos():
+    """Ver estado de los proyectos Google"""
+    estado = []
+    for i in range(len(GOOGLE_PROYECTOS)):
+        reset_si_nuevo_dia(i)
+        estado.append({"proyecto": i+1, "usos_hoy": USOS_PROYECTO[i]["count"]})
+    return estado