deploy from github actions

app/routers/lyrics.py

@@ -374,7 +374,7 @@ def update_lyric(
 def delete_lyric(lyric_id: int, db: Session = Depends(get_db), current_user: User = Depends(get_current_user)):
     db_lyric = db.query(Lyric).filter(Lyric.id == lyric_id).first()
     if not db_lyric:
-        raise HTTPException(status_code=404, detail="Lyric not found")
+        raise HTTPException(status_code=404, detail="Letra no encontrada")
         
     is_authorized = False
     if db_lyric.created_by == current_user.id:
@@ -395,18 +395,35 @@ def delete_lyric(lyric_id: int, db: Session = Depends(get_db), current_user: Use
                 break
 
     if not is_authorized:
-        raise HTTPException(status_code=403, detail="Not authorized to delete this lyric")
+        raise HTTPException(
+            status_code=403, 
+            detail="No tienes permisos para eliminar esta letra. Solo el creador o un administrador del grupo pueden eliminarla."
+        )
         
     shared_group_ids = list(db_lyric.group_ids)
+    if db_lyric.group_id is not None and db_lyric.group_id not in shared_group_ids:
+        shared_group_ids.append(db_lyric.group_id)
+
+    # 1. Limpiar asociaciones en repertorios
+    db.query(RepertorioLyric).filter(RepertorioLyric.lyric_id == lyric_id).delete()
+
+    # 2. Desvincular letras hijas si existieran
+    db.query(Lyric).filter(Lyric.parent_lyric_id == lyric_id).update({"parent_lyric_id": None})
+
+    # 3. Limpiar asociaciones secundarias de grupos
+    db_lyric.groups_shared.clear()
+
+    # 4. Eliminar la letra
     db.delete(db_lyric)
     db.commit()
+
     for gid in shared_group_ids:
         try:
             from app.routers.alabanza import broadcast_to_group
             broadcast_to_group(gid, {"type": "group_updated", "grupo_id": gid}, db)
         except Exception:
             pass
-    return {"message": "Lyric deleted successfully"}
+    return {"message": "Letra eliminada correctamente"}
 
 
 

app/routers/songs.py

@@ -419,6 +419,18 @@ async def subir_cancion(
         actual_size = os.path.getsize(upload_path)
         logger.info(f"[{task_id}] Archivo guardado: {file.filename} ({actual_size / (1024*1024):.2f}MB)")
 
+        # ==========================================
+        # SUBIDA A HUGGING FACE DATASET (COSTO $0 / EGRESS ILIMITADO)
+        # ==========================================
+        cloud_url = None
+        try:
+            from app.utils.hf_storage import upload_to_hf
+            hf_orig_key = f"originals/{task_id}_{safe_filename}"
+            cloud_url = upload_to_hf(upload_path, hf_orig_key)
+            logger.info(f"[{task_id}] Audio original subido a Hugging Face Dataset: {cloud_url}")
+        except Exception as hfe:
+            logger.warning(f"[{task_id}] No se pudo subir original a Hugging Face: {hfe}. Se procesará de forma local si aplica.")
+
         # ==========================================
         # CREAR REGISTRO EN BASE DE DATOS
         # ==========================================
@@ -447,6 +459,7 @@ async def subir_cancion(
             nuevo_proceso = db.query(Task).filter(Task.task_id == task_id).first()
             if nuevo_proceso:
                 nuevo_proceso.status = "pending"
+                nuevo_proceso.cloud_url = cloud_url
                 nuevo_proceso.telegram_file_ids = None
                 nuevo_proceso.folder = None
                 nuevo_proceso.song_name = song_name_val
@@ -461,6 +474,7 @@ async def subir_cancion(
                 artist=artist_val,
                 stems=stems,
                 status="pending",
+                cloud_url=cloud_url,
                 consumed_credit_type=consumed_type
             )
             db.add(nuevo_proceso)
@@ -475,8 +489,8 @@ async def subir_cancion(
         # ==========================================
         queue_name = get_user_routing_queue(db, current_user.id)
         kwargs_async = {
-            "args": [upload_path, task_id, stems, trim_start, trim_end],
-            "kwargs": {"auto_harmonize": auto_harmonize},
+            "args": [upload_path if not queue_name else "", task_id, stems, trim_start, trim_end],
+            "kwargs": {"cloud_url": cloud_url, "auto_harmonize": auto_harmonize},
             "task_id": task_id
         }
         if queue_name:
@@ -1421,13 +1435,18 @@ async def limpiar_tarea(
         except Exception as e:
             logger.warning(f"Error general al limpiar archivos de {task_id}: {e}. Se continuará con el borrado en BD.")
     
-    # Eliminar stems de Hugging Face Dataset si existen
+    # Eliminar stems y archivos de Hugging Face Dataset si existen
     try:
-        from app.utils.hf_storage import delete_folder_from_hf
+        from app.utils.hf_storage import delete_folder_from_hf, delete_from_hf
         delete_folder_from_hf(f"stems/{task_id}")
-        logger.info(f"[{task_id}] Stems eliminados de Hugging Face por eliminación explícita.")
+        if task_record.cloud_url and "/originals/" in task_record.cloud_url:
+            import re as _re
+            _m = _re.search(r'/resolve/main/(originals/.+)$', task_record.cloud_url)
+            if _m:
+                delete_from_hf(_m.group(1))
+        logger.info(f"[{task_id}] Stems y archivos eliminados de Hugging Face por eliminación explícita.")
     except Exception as e:
-        logger.warning(f"Error eliminando stems de Hugging Face: {e}")
+        logger.warning(f"Error eliminando archivos de Hugging Face: {e}")
 
     # Eliminar pista original y stems de Supabase storage
     try:

app/routers/workers.py

@@ -410,6 +410,7 @@ def agent_poll(
     return {
         "command": current_command,
         "is_active": worker.is_active,
+        "is_public": bool(getattr(worker, "is_public", False)),
         "user_id": worker.user_id,
         "status": worker.status
     }

tasks.py

@@ -789,7 +789,7 @@ def procesar_cancion_completa(self, file_path, task_id, stems, trim_start="", tr
         # DESCARGA DE SUPABASE (CLOUD QUEUE)
         # ==========================================
         if cloud_url:
-            logger.info(f"[{task_id}] Descargando audio desde Supabase (Cola Offline): {cloud_url}")
+            logger.info(f"[{task_id}] Descargando audio desde la nube (Cola Offline / HF): {cloud_url}")
             self.update_state(state='PROGRESS', meta={'progress': 1, 'message': 'Preparando pista...'})
             
             UPLOADS_DIR = os.getenv("UPLOADS_DIR", os.path.join(os.path.dirname(os.path.abspath(__file__)), "uploads"))
@@ -802,9 +802,20 @@ def procesar_cancion_completa(self, file_path, task_id, stems, trim_start="", tr
             with open(file_path, 'wb') as f:
                 for chunk in response.iter_content(chunk_size=8192):
                     f.write(chunk)
-            logger.info(f"[{task_id}] Archivo de Supabase descargado con éxito.")
+            logger.info(f"[{task_id}] Archivo descargado con éxito.")
             
-            # Eliminar archivo original de Supabase inmediatamente tras descarga a la laptop
+            # Eliminar archivo original temporal de Hugging Face tras descarga
+            try:
+                from app.utils.hf_storage import delete_from_hf
+                import re as _re
+                _m = _re.search(r'/resolve/main/(originals/.+)$', cloud_url)
+                if _m:
+                    delete_from_hf(_m.group(1))
+                    logger.info(f"[{task_id}] Archivo original temporal de Hugging Face eliminado: {_m.group(1)}")
+            except Exception as _hfe:
+                logger.warning(f"[{task_id}] Error al eliminar original temporal de Hugging Face tras descarga: {_hfe}")
+            
+            # Eliminar archivo original de Supabase (legacy fallback)
             try:
                 from app.utils.supabase_storage import delete_supabase_file, parse_supabase_path
                 orig_path = parse_supabase_path(cloud_url)
@@ -812,7 +823,7 @@ def procesar_cancion_completa(self, file_path, task_id, stems, trim_start="", tr
                     delete_supabase_file(orig_path)
                     logger.info(f"[{task_id}] Archivo original de Supabase storage eliminado.")
             except Exception as e:
-                logger.warning(f"[{task_id}] Error al eliminar original de Supabase tras descarga: {e}")
+                pass
             
         # ==========================================
         # DESCARGA DE YOUTUBE (SI APLICA)