get hobs

routers/gemini.py

@@ -256,6 +256,66 @@ async def analyze_image(
     }
 
 
+@router.get("/jobs")
+async def get_jobs(
+    user: User = Depends(get_current_user),
+    db: AsyncSession = Depends(get_db),
+    page: int = 1,
+    limit: int = 20
+):
+    """
+    Get all jobs created by the current user.
+    Returns a paginated list of jobs with status, type, and prompt (for video jobs).
+    """
+    offset = (page - 1) * limit
+    
+    # Query jobs for the current user
+    query = select(GeminiJob).where(
+        GeminiJob.user_id == user.user_id
+    ).order_by(GeminiJob.created_at.desc()).offset(offset).limit(limit)
+    
+    result = await db.execute(query)
+    jobs = result.scalars().all()
+    
+    # Get total count
+    count_query = select(func.count()).where(GeminiJob.user_id == user.user_id)
+    count_result = await db.execute(count_query)
+    total_count = count_result.scalar()
+    
+    # Build job list
+    job_list = []
+    for job in jobs:
+        job_item = {
+            "job_id": job.job_id,
+            "job_type": job.job_type,
+            "status": job.status,
+            "created_at": job.created_at.isoformat() if job.created_at else None,
+            "completed_at": job.completed_at.isoformat() if job.completed_at else None,
+        }
+        
+        # Include prompt for video jobs
+        if job.job_type == "video" and job.input_data:
+            job_item["prompt"] = job.input_data.get("prompt")
+        
+        # Include error message for failed jobs
+        if job.status == "failed":
+            job_item["error"] = job.error_message
+        
+        # Include download URL for completed video jobs
+        if job.status == "completed" and job.job_type == "video" and job.output_data and job.output_data.get("filename"):
+            job_item["download_url"] = f"/gemini/download/{job.job_id}"
+        
+        job_list.append(job_item)
+    
+    return {
+        "success": True,
+        "jobs": job_list,
+        "total_count": total_count,
+        "page": page,
+        "limit": limit
+    }
+
+
 @router.get("/job/{job_id}")
 async def get_job_status(
     job_id: str,