Function upload_file

backend/app/main.py:116–133

Upload a file and ingest into the RAG pipeline. Delegates business logic to file_service. Validates file extension against SUPPORTED_EXTENSIONS.

(file: UploadFile = File(...), db: Session = Depends(get_db))

@app.post("/api/upload", response_model=FileUploadResponse)
def upload_file(file: UploadFile = File(...), db: Session = Depends(get_db)) -> FileUploadResponse:
    """
    Upload a file and ingest into the RAG pipeline. Delegates business logic to file_service.
    Validates file extension against SUPPORTED_EXTENSIONS.
    """
    ext = os.path.splitext(file.filename)[-1].lower()
    if ext not in SUPPORTED_EXTENSIONS:
        raise HTTPException(status_code=422, detail=f"Unsupported file type: {ext}")
    db_file = upload_file_service(file=file, db=db)
    # Ingest into RAG pipeline (kept here to avoid circular dependency)
    try:
        rag_pipeline.ingest(db_file.filepath, metadata={"file_id": db_file.id, "filename": db_file.filename})
    except Exception as e:
        db.delete(db_file)
        db.commit()
        os.remove(db_file.filepath)
        raise HTTPException(status_code=500, detail=f"RAG ingestion failed: {str(e)}")
    return FileUploadResponse(id=db_file.id, filename=db_file.filename)


from app.services.file_service import list_files as list_files_service