File size: 1,729 Bytes
d4a4da7 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 |
"""Bulk export endpoint."""
import os
import logging
from fastapi import APIRouter, HTTPException, Depends, BackgroundTasks
from fastapi.responses import FileResponse
from api.schemas import BulkExportRequest
from services.database import db_service
from services.export_service import export_service
from services.auth_dependency import get_current_user
router = APIRouter(tags=["export"])
api_logger = logging.getLogger("api")
@router.post("/api/export/bulk")
async def export_bulk_ads(
request: BulkExportRequest,
background_tasks: BackgroundTasks,
username: str = Depends(get_current_user),
):
"""
Export multiple ad creatives as a ZIP package.
Creates /creatives/ folder and ad_copy_data.xlsx. Max 50 ads.
"""
if len(request.ad_ids) > 50:
raise HTTPException(status_code=400, detail="Maximum 50 ads can be exported at once")
ads = []
for ad_id in request.ad_ids:
ad = await db_service.get_ad_creative(ad_id, username=username)
if not ad:
raise HTTPException(status_code=404, detail=f"Ad '{ad_id}' not found or access denied")
ads.append(ad)
try:
api_logger.info("Creating export package for %d ads (user: %s)", len(ads), username)
zip_path = await export_service.create_export_package(ads)
background_tasks.add_task(export_service.cleanup_zip, zip_path)
return FileResponse(
zip_path,
media_type="application/zip",
filename=os.path.basename(zip_path),
)
except HTTPException:
raise
except Exception as e:
api_logger.error("Bulk export failed: %s", e)
raise HTTPException(status_code=500, detail=f"Export failed: {str(e)}")
|