[34588f42] Keine Zusammenfassung angegeben.

Keine Zusammenfassung angegeben.

fotograf-de-scraper/backend/publish_request_api.py

@@ -1,7 +1,7 @@
 from fastapi import APIRouter, Depends, HTTPException, Request, BackgroundTasks
 from pydantic import BaseModel
 from sqlalchemy.orm import Session
-from database import get_db, DiscountCode, ReleaseParticipant
+from database import get_db, DiscountCode, ReleaseParticipant, ReleaseHistory
 import datetime
 import logging
 from gmail_service import GmailService
@@ -96,9 +96,18 @@ async def send_requests(data: SendReleaseRequest, background_tasks: BackgroundTa
     if data.scheduled_time:
         # Pass a way to get a new session to the background task
         from database import SessionLocal
+        
+        # Log to history
+        db.add(ReleaseHistory(recipient_count=len(data.emails), scheduled_time=data.scheduled_time))
+        db.commit()
+
         background_tasks.add_task(delayed_send, data.emails, data.scheduled_time, SessionLocal)
         return {"status": "scheduled", "message": f"Versand für {data.scheduled_time} geplant."}
     
+    # Log immediate send to history
+    db.add(ReleaseHistory(recipient_count=len(data.emails), scheduled_time="Sofort"))
+    db.commit()
+
     # Immediate send
     service = GmailService(db)
     success = 0
@@ -111,6 +120,11 @@ async def send_requests(data: SendReleaseRequest, background_tasks: BackgroundTa
     
     return {"status": "success", "success": success, "failed": failed}
 
+@router.get("/history")
+def get_history(db: Session = Depends(get_db)):
+    history = db.query(ReleaseHistory).order_by(ReleaseHistory.timestamp.desc()).all()
+    return [{"id": h.id, "timestamp": h.timestamp.isoformat(), "recipient_count": h.recipient_count, "scheduled_time": h.scheduled_time} for h in history]
+
 @router.get("/stats")
 def get_stats(db: Session = Depends(get_db)):
     total = db.query(DiscountCode).count()