Allow legacy text endpoints to use guest auth when no Authorization header is present

backend/app/routers/legacy_router.py

@@ -1,5 +1,5 @@
 
-from fastapi import APIRouter, HTTPException, BackgroundTasks, Depends
+from fastapi import APIRouter, HTTPException, BackgroundTasks, Depends, Header
 from fastapi.responses import JSONResponse
 from app.schemas.text_schema import TextRequest
 from app.dependencies import get_current_user
@@ -10,53 +10,64 @@ router = APIRouter()
 _legacy_jobs = {}
 
 
+async def get_optional_user(authorization: str = Header(None)):
+    if not authorization:
+        return {
+            "email": "guest@fakeshield.local",
+            "full_name": "Guest User",
+            "subscription_tier": "free",
+            "is_offline": True,
+        }
+    return await get_current_user(authorization)
+
+
 @router.post("/analyze/text")
-async def legacy_analyze_sync(req: TextRequest, user: dict = Depends(get_current_user)):
-	"""Compatibility endpoint for older clients that POST to /analyze/text"""
-	from app.services.pipeline import run_text_pipeline
-	try:
-		result, _ = await run_text_pipeline(
-			user_email=user["email"],
-			text=req.text,
-			mode=req.mode,
-			include_highlights=req.include_highlights,
-		)
-		return JSONResponse({"status": "success", "data": result})
-	except ValueError as e:
-		raise HTTPException(400, str(e))
-	except Exception as e:
-		raise HTTPException(500, str(e))
+async def legacy_analyze_sync(req: TextRequest, user: dict = Depends(get_optional_user)):
+    """Compatibility endpoint for older clients that POST to /analyze/text"""
+    from app.services.pipeline import run_text_pipeline
+    try:
+        result, _ = await run_text_pipeline(
+            user_email=user["email"],
+            text=req.text,
+            mode=req.mode,
+            include_highlights=req.include_highlights,
+        )
+        return JSONResponse({"status": "success", "data": result})
+    except ValueError as e:
+        raise HTTPException(400, str(e))
+    except Exception as e:
+        raise HTTPException(500, str(e))
 
 
 @router.post("/analyze/text/async")
-async def legacy_analyze_async(req: TextRequest, background_tasks: BackgroundTasks, user: dict = Depends(get_current_user)):
-	"""Compatibility async endpoint for older clients that POST to /analyze/text/async"""
-	import uuid
-	job_id = "job_" + str(uuid.uuid4())[:8]
-	_legacy_jobs[job_id] = {"status": "processing", "data": None, "user_email": user["email"]}
-
-	async def run_job():
-		from app.services.pipeline import run_text_pipeline
-		try:
-			result, _ = await run_text_pipeline(
-				user_email=user["email"],
-				text=req.text,
-				mode=req.mode,
-				include_highlights=req.include_highlights,
-			)
-			_legacy_jobs[job_id] = {"status": "complete", "data": result, "user_email": user["email"]}
-		except Exception as e:
-			_legacy_jobs[job_id] = {"status": "error", "data": str(e), "user_email": user["email"]}
-
-	background_tasks.add_task(run_job)
-	return {"status": "accepted", "job_id": job_id}
+async def legacy_analyze_async(req: TextRequest, background_tasks: BackgroundTasks, user: dict = Depends(get_optional_user)):
+    """Compatibility async endpoint for older clients that POST to /analyze/text/async"""
+    import uuid
+    job_id = "job_" + str(uuid.uuid4())[:8]
+    _legacy_jobs[job_id] = {"status": "processing", "data": None, "user_email": user["email"]}
+
+    async def run_job():
+        from app.services.pipeline import run_text_pipeline
+        try:
+            result, _ = await run_text_pipeline(
+                user_email=user["email"],
+                text=req.text,
+                mode=req.mode,
+                include_highlights=req.include_highlights,
+            )
+            _legacy_jobs[job_id] = {"status": "complete", "data": result, "user_email": user["email"]}
+        except Exception as e:
+            _legacy_jobs[job_id] = {"status": "error", "data": str(e), "user_email": user["email"]}
+
+    background_tasks.add_task(run_job)
+    return {"status": "accepted", "job_id": job_id}
 
 
 @router.get("/analyze/text/status/{job_id}")
-async def legacy_job_status(job_id: str, user: dict = Depends(get_current_user)):
-	if job_id not in _legacy_jobs:
-		raise HTTPException(404, "Job not found")
-	job = _legacy_jobs[job_id]
-	if job.get("user_email") != user["email"]:
-		raise HTTPException(403, "Not authorized to view this job status")
-	return job
+async def legacy_job_status(job_id: str, user: dict = Depends(get_optional_user)):
+    if job_id not in _legacy_jobs:
+        raise HTTPException(404, "Job not found")
+    job = _legacy_jobs[job_id]
+    if job.get("user_email") != user["email"]:
+        raise HTTPException(403, "Not authorized to view this job status")
+    return job