Upload app/modules/evidence/router.py with huggingface_hub

app/modules/evidence/router.py

@@ -0,0 +1,89 @@
+import logging
+import uuid
+from typing import Optional
+
+from fastapi import (
+    APIRouter,
+    Body,
+    Depends,
+    File,
+    Form,
+    Query,
+    UploadFile,
+)
+from pydantic import BaseModel
+from sqlalchemy.orm import Session
+
+from app.dependencies import get_current_project_id
+from app.modules.auth.service import auth_service
+from core.database import User, get_db
+
+from .service import evidence_service
+
+logger = logging.getLogger(__name__)
+
+router = APIRouter()
+
+# --- Schemas ---
+
+
+class EvidenceItemResponse(BaseModel):
+    id: str
+    case_id: str
+    file_name: str
+    file_type: str
+    size_bytes: int
+    uploaded_at: Optional[str] = None
+    processing_status: str
+
+
+@router.get("", response_model=dict)
+async def get_evidence(
+    case_id: str | None = Query(None),
+    file_type: str | None = Query(None),
+    q: str | None = Query(None),
+    page: int = Query(1, ge=1),
+    page_size: int = Query(20, ge=1),
+    db: Session = Depends(get_db),
+    project_id: str = Depends(get_current_project_id),
+    current_user: User = Depends(auth_service.get_current_user),
+):
+    """Get list of evidence items"""
+    return evidence_service.get_evidence_paginated(
+        db=db,
+        page=page,
+        page_size=page_size,
+        project_id=project_id,
+        case_id=case_id,
+        file_type=file_type,
+        search_query=q,
+    )
+
+
+@router.post("/upload")
+async def upload_evidence(
+    case_id: str = Form(...),
+    file: UploadFile = File(...),
+    description: Optional[str] = Form(None),
+    tags: Optional[str] = Form(None),
+    db: Session = Depends(get_db),
+    project_id: str = Depends(get_current_project_id),
+    current_user: User = Depends(auth_service.get_current_user),
+):
+    """Legacy individual file upload"""
+    # Simple logic placeholder as in legacy router
+    evidence_id = str(uuid.uuid4())
+    logger.info(f"Uploading evidence {evidence_id} for case {case_id}")
+    return {"message": "Evidence uploaded successfully", "evidence_id": evidence_id}
+
+
+@router.post("/bulk-delete")
+async def bulk_delete_evidence(
+    payload: dict = Body(...),
+    db: Session = Depends(get_db),
+    current_user: User = Depends(auth_service.get_current_user),
+):
+    """Bulk delete evidence records"""
+    ids = payload.get("ids", [])
+    count = evidence_service.delete_evidence(db, ids)
+    return {"deleted_count": count, "status": "success"}