Update app.py

app.py

@@ -69,11 +69,15 @@ app = FastAPI(
 def is_video_url_for_gemini(url: Optional[str]) -> bool:
     if not url:
         return False
+    # Use raw strings (r"...") for regular expressions to avoid SyntaxWarnings
     youtube_regex = (
         r'(https_?://)?(www\.)?'
-        '(youtube|youtu|youtube-nocookie)\.(com|be)/'
-        '(watch\?v=|embed/|v/|.+\?v=)?([^&=%\?]{11})')
+        r'(youtube|youtu|youtube-nocookie)\.(com|be)/'  # Changed to raw string
+        r'(watch\?v=|embed/|v/|.+\?v=)?([^&=%\?]{11})'  # Changed to raw string
+    )
+    # This regex was likely fine as it didn't have ambiguous escapes, but good practice to make it raw too
     googleusercontent_youtube_regex = r'https_?://googleusercontent\.com/youtube\.com/\w+'
+    
     return re.match(youtube_regex, url) is not None or \
            re.match(googleusercontent_youtube_regex, url) is not None
 
@@ -227,6 +231,48 @@ async def direct_chat(payload: ChatPayload):
         }
     )
 
+@app.post("/gemini/submit_task", response_model=TaskSubmissionResponse)
+async def submit_gemini_task(request: GeminiTaskRequest, background_tasks: BackgroundTasks):
+    task_id = str(uuid.uuid4())
+    logger.info(f"Received Gemini task submission. Assigning Task ID: {task_id}. Message: '{request.message[:50]}...'")
+
+    gemini_api_key_from_request = request.api_key
+    gemini_api_key_secret = os.getenv("GEMINI_API_KEY")
+    key_to_use = gemini_api_key_from_request or gemini_api_key_secret
+
+    if not key_to_use:
+        logger.error(f"[Task {task_id}] Gemini API Key missing for task submission.")
+        raise HTTPException(status_code=400, detail="Gemini API Key required.")
+
+    requested_model = request.gemini_model or DEFAULT_GEMINI_MODEL
+    
+    current_time = datetime.now(timezone.utc)
+    tasks_db[task_id] = {
+        "status": "PENDING",
+        "result": None,
+        "error": None,
+        "submitted_at": current_time,
+        "last_updated_at": current_time,
+        "request_params": request.model_dump() # Store original request
+    }
+
+    background_tasks.add_task(
+        process_gemini_request_background,
+        task_id,
+        request.message,
+        request.url,
+        requested_model,
+        key_to_use
+    )
+    
+    logger.info(f"[Task {task_id}] Task submitted to background processing.")
+    return TaskSubmissionResponse(
+        task_id=task_id,
+        status="PENDING",
+        task_detail_url=f"/gemini/task/{task_id}" # Provide the URL to poll
+    )
+
+
 
 @app.get("/gemini/task/{task_id}", response_model=TaskStatusResponse)
 async def get_gemini_task_status(task_id: str = Path(..., description="The ID of the task to retrieve")):