limite por plan + 1 canal por crear

main.py

@@ -601,29 +601,44 @@ async def activar_canal(token: str = "", plan: str = ""):
 @app.post("/crear")
 async def crear(request: Request):
     data = await request.json()
-    email = data.get("email","")
-    canales = data.get("canales", [])  # lista de {nicho, tipo}
+    email = data.get("email","").strip().lower()
+    nicho = data.get("nicho","tecnologia")
+    tipo = data.get("tipo","largo")
     token = data.get("token","")
-    if not token or token not in TOKENS_VALIDOS:
+    # Verificar token o sesion existente
+    plan = "basico"
+    if token and token in TOKENS_VALIDOS:
+        plan = TOKENS_VALIDOS[token].get("plan", "basico") if isinstance(TOKENS_VALIDOS[token], dict) else "basico"
+    elif email in CLIENTES and CLIENTES[email].get("plan"):
+        plan = CLIENTES[email]["plan"]
+    else:
         return JSONResponse({"error": "Token invalido"}, status_code=403)
-    if not canales:
-        return JSONResponse({"error": "Sin canales"}, status_code=400)
-    urls = []
-    for canal in canales:
-        nicho = canal.get("nicho", "tecnologia")
-        tipo = canal.get("tipo", "largo")
-        u = await crear_space(nicho, email, tipo)
-        if u:
-            urls.append(u)
-    if urls:
+    # Verificar limite del plan
+    limite = PLANES_CANALES.get(plan, 1)
+    canales_actuales = len(CLIENTES.get(email, {}).get("canales", []))
+    if canales_actuales >= limite:
+        return JSONResponse({"error": f"Has alcanzado el limite de tu plan {plan} ({limite} canales)"}, status_code=400)
+    # Crear el canal
+    u = await crear_space(nicho, email, tipo)
+    if not u:
+        return JSONResponse({"error": "No se pudo crear el canal"}, status_code=500)
+    # Guardar en CLIENTES
+    if email not in CLIENTES:
+        CLIENTES[email] = {"canales": [], "plan": plan}
+    CLIENTES[email]["plan"] = plan
+    if "canales" not in CLIENTES[email]:
+        CLIENTES[email]["canales"] = []
+    CLIENTES[email]["canales"].append({"url": u, "nicho": nicho, "tipo": tipo})
+    guardar_clientes()
+    # Consumir token si era nuevo
+    if token in TOKENS_VALIDOS:
         del TOKENS_VALIDOS[token]
-        # Enviar email con todas las URLs
-        try:
-            enviar_email_multi(email, urls)
-        except Exception as e:
-            print(f"Error email multi: {e}", flush=True)
-        return {"success": True, "urls": urls, "url": urls[0]}
-    return JSONResponse({"error": "No se pudo crear ningun Space"}, status_code=500)
+    urls = [c["url"] for c in CLIENTES[email]["canales"]]
+    try:
+        enviar_email_multi(email, urls)
+    except Exception as e:
+        print(f"Error email: {e}", flush=True)
+    return {"success": True, "url": u, "total": len(urls), "limite": limite}
 
 
 def enviar_email_multi(email, urls):