Background mail sender

src/impl/Event/router_v1.py

@@ -1,7 +1,7 @@
 from datetime import datetime
 from typing import List, Union
 
-from fastapi import APIRouter, Depends
+from fastapi import APIRouter, Depends, BackgroundTasks, HTTPException
 
 from src.configuration.Settings import settings
 from src.error.AuthenticationException import AuthenticationException
@@ -20,6 +20,7 @@
 from src.utils.JWTBearer import JWTBearer
 from src.utils.service_utils import subtract_lists
 from src.utils.Token import AssistenceToken, BaseToken
+from src.utils.UserType import UserType
 
 # from src.error.NotFoundException import NotFoundException
 
@@ -380,20 +381,53 @@ def resend_accept_mail(
 
 
 @router.post("/{event_id}/send_slack_mail/")
-def send_slack_mail(event_id: int, slackUrl: str, token: BaseToken = Depends(JWTBearer())):
-    event_service.send_slack_mail(event_id, slackUrl, token)
-    return {"success": True}
+def send_slack_mail(
+    event_id: int,
+    slackUrl: str,
+    background_tasks: BackgroundTasks,
+    delay: float = 0.5,
+    token: BaseToken = Depends(JWTBearer()),
+):
+    """
+    Schedule sending slack invite mails in background. The endpoint validates
+    permissions and immediately returns while the work continues in background.
+    """
+    if not token.check([UserType.LLEIDAHACKER]):
+        raise AuthenticationException("Not authorized")
+    # guard: don't schedule if there's already a sending job for this event
+    if event_service.is_sending(event_id):
+        raise HTTPException(status_code=409, detail="Sending already in progress for this event")
+
+    # schedule background task to avoid request timeout
+    background_tasks.add_task(event_service.send_slack_mail_background, event_id, slackUrl, delay)
+    return {"success": True, "scheduled": True}
+
+
+@router.get("/{event_id}/send_progress")
+def get_send_progress(event_id: int, token: BaseToken = Depends(JWTBearer())):
+    """Return send progress for background jobs for an event."""
+    if not token.check([UserType.LLEIDAHACKER]):
+        raise AuthenticationException("Not authorized")
+    return event_service.get_send_progress(event_id)
 
 @router.post("/{event_id}/send_reminder_mails/")
 def send_reminder_mails(
     event_id: int,
+    background_tasks: BackgroundTasks,
+    delay: float = 0.0,
     token: BaseToken = Depends(JWTBearer()),
 ):
     """
-    Send reminder mails to all accepted hackers of an event
+    Schedule sending reminder mails to all accepted hackers of an event.
+    The endpoint validates permissions and immediately returns while the work
+    continues in background.
     """
-    event_service.send_reminder_mails(event_id, token)
-    return {"success": True}
+    if not token.check([UserType.LLEIDAHACKER]):
+        raise AuthenticationException("Not authorized")
+
+    # schedule background task to avoid request timeout
+    background_tasks.add_task(event_service.send_reminder_mails_background, event_id, delay)
+    return {"success": True, "scheduled": True}
 
 
 # @router.post("/{event_id}/send_remember")

src/impl/Event/service.py

@@ -1,6 +1,11 @@
 from fastapi_sqlalchemy import db
-from sqlalchemy import desc
+from sqlalchemy import desc, create_engine
+from sqlalchemy.orm import sessionmaker
 from datetime import datetime
+import time
+import logging
+import threading
+from src.configuration.Settings import settings
 from generated_src.lleida_hack_mail_api_client.models.mail_create import MailCreate
 from collections import Counter
 
@@ -40,6 +45,65 @@ class EventService(BaseService):
     hacker_service: HackerService = None
     company_service: CompanyService = None
     mail_client: MailClient = None
+    # background sending job tracking: event_id -> job info
+    _sending_jobs = {}
+    _sending_jobs_lock = threading.Lock()
+
+    def _start_job(self, event_id: int, job_type: str, total: int):
+        with self._sending_jobs_lock:
+            self._sending_jobs[event_id] = {
+                "type": job_type,
+                "start": datetime.now(),
+                "finish": None,
+                "total": int(total) if total is not None else 0,
+                "sent": 0,
+                "status": "running",
+            }
+
+    def _increment_sent(self, event_id: int):
+        with self._sending_jobs_lock:
+            job = self._sending_jobs.get(event_id)
+            if job and job.get("status") == "running":
+                job["sent"] = job.get("sent", 0) + 1
+
+    def _finish_job(self, event_id: int):
+        with self._sending_jobs_lock:
+            job = self._sending_jobs.get(event_id)
+            if job:
+                job["status"] = "finished"
+                job["finish"] = datetime.now()
+
+    def is_sending(self, event_id: int) -> bool:
+        with self._sending_jobs_lock:
+            job = self._sending_jobs.get(event_id)
+            return bool(job and job.get("status") == "running")
+
+    def get_send_progress(self, event_id: int):
+        with self._sending_jobs_lock:
+            job = self._sending_jobs.get(event_id)
+            if not job:
+                return {"running": False}
+            # copy minimal fields to compute without lock
+            start = job.get("start")
+            sent = job.get("sent", 0)
+            total = job.get("total", 0)
+            status = job.get("status")
+            finish = job.get("finish")
+        elapsed = (datetime.now() - start).total_seconds() if start else 0
+        estimated_remaining = None
+        if sent > 0 and total > sent:
+            avg = elapsed / sent
+            estimated_remaining = int(max(0, avg * (total - sent)))
+
+        return {
+            "running": status == "running",
+            "sent": int(sent),
+            "total": int(total),
+            "elapsed_seconds": int(elapsed),
+            "estimated_remaining_seconds": estimated_remaining,
+            "started_at": start.isoformat() if start else None,
+            "finished_at": finish.isoformat() if finish else None,
+        }
 
     def get_all(self):
         return db.session.query(Event).filter(Event.archived.is_(False)).all()
@@ -996,10 +1060,66 @@ def send_slack_mail(self, event_id: int, slackUrl: str, data: BaseToken):
                 )
             )
             # send the created mail
-            self.mail_client.send_mail_by_id(mail.id)
+            resp = self.mail_client.send_mail_by_id(mail.id)
 
         db.session.commit()
 
+    @BaseService.needs_service(MailClient)
+    def send_slack_mail_background(self, event_id: int, slackUrl: str, delay: float = 0.2):
+        """
+        Background-safe sender: creates its own DB session and sends slack invite mails
+        to accepted hackers with an optional `delay` between sends to avoid throttling.
+        """
+        engine = create_engine(settings.database.url)
+        SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
+        session = SessionLocal()
+        try:
+            event = session.query(Event).filter(Event.id == event_id).first()
+            if event is None or event.archived:
+                return
+
+            hackers = event.accepted_hackers
+            total = len(hackers) if hackers is not None else 0
+            # start tracking job
+            try:
+                self._start_job(event_id, "slack", total)
+            except Exception:
+                # best-effort tracking, don't fail send if tracking setup fails
+                pass
+
+            for hacker in hackers:
+                try:
+                    mail = self.mail_client.create_mail(
+                        MailCreate(
+                            template_id=self.mail_client.get_internall_template_id(
+                                InternalTemplate.EVENT_SLACK_INVITE
+                            ),
+                            subject="HackEPS2025 slack invitation",
+                            receiver_id=str(hacker.id),
+                            receiver_mail=str(hacker.email),
+                            fields=slackUrl,
+                        )
+                    )
+                    resp = self.mail_client.send_mail_by_id(mail.id)
+                    # increment progress
+                    try:
+                        self._increment_sent(event_id)
+                    except Exception:
+                        pass
+                    session.commit()
+                    if delay and delay > 0:
+                        time.sleep(delay)
+                except Exception:
+                    session.rollback()
+                    continue
+            # finish tracking
+            try:
+                self._finish_job(event_id)
+            except Exception:
+                pass
+        finally:
+            session.close()
+
     @BaseService.needs_service(MailClient)
     def send_reminder_mails(
         self,
@@ -1041,7 +1161,8 @@ def send_reminder_mails(
                 except Exception:
                     days_left = 0
 
-                fields = f"{hacker.name},{event.name},{days_left},{reg.confirm_assistance_token}"
+                # fields order: name, days_left, token, event_name
+                fields = f"{hacker.name},{days_left},{reg.confirm_assistance_token},{event.name}"
 
                 mail = self.mail_client.create_mail(
                     MailCreate(
@@ -1055,10 +1176,90 @@ def send_reminder_mails(
                     )
                 )
                 # send the created mail
-                self.mail_client.send_mail_by_id(mail.id)
+                resp = self.mail_client.send_mail_by_id(mail.id)
                 db.session.commit()
             except Exception as e:
                 db.session.rollback()
                 # Optionally log the error here, e.g.:
                 # print(f"Failed to send reminder to hacker {hacker.id}: {e}")
-                continue
+                continue
+
+    @BaseService.needs_service(MailClient)
+    def send_reminder_mails_background(self, event_id: int, delay: float = 0.0):
+        """
+        Background-safe sender: creates its own DB session and sends reminder mails
+        to accepted hackers. Optional `delay` between sends to avoid throttling.
+        """
+        engine = create_engine(settings.database.url)
+        SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
+        session = SessionLocal()
+        try:
+            event = session.query(Event).filter(Event.id == event_id).first()
+            if event is None or event.archived:
+                return
+
+            # build list of eligible (hacker, reg) to have accurate total
+            hackers = event.accepted_hackers
+            eligible = []
+            for hacker in hackers:
+                reg = (
+                    session.query(HackerRegistration)
+                    .filter(
+                        HackerRegistration.user_id == hacker.id,
+                        HackerRegistration.event_id == event.id,
+                    )
+                    .first()
+                )
+                if reg is None or reg.confirmed_assistance:
+                    continue
+                eligible.append((hacker, reg))
+
+            total = len(eligible)
+            try:
+                self._start_job(event_id, "reminder", total)
+            except Exception:
+                pass
+
+            for hacker, reg in eligible:
+                try:
+                    # ensure there is a confirmation token for this registration
+                    if not reg.confirm_assistance_token:
+                        reg.confirm_assistance_token = AssistenceToken(hacker, event.id).to_token()
+
+                    try:
+                        delta = event.start_date - datetime.now()
+                        days_left = max(0, int(delta.total_seconds() // 86400))
+                    except Exception:
+                        days_left = 0
+
+                    fields = f"{hacker.name},{days_left},{reg.confirm_assistance_token},{event.name}"
+
+                    mail = self.mail_client.create_mail(
+                        MailCreate(
+                            template_id=self.mail_client.get_internall_template_id(
+                                InternalTemplate.EVENT_HACKER_REMINDER
+                            ),
+                            subject=f"{event.name} - Recordatori de confirmació d'assistència",
+                            receiver_id=str(hacker.id),
+                            receiver_mail=str(hacker.email),
+                            fields=fields,
+                        )
+                    )
+
+                    resp = self.mail_client.send_mail_by_id(mail.id)
+                    try:
+                        self._increment_sent(event_id)
+                    except Exception:
+                        pass
+                    session.commit()
+                    if delay and delay > 0:
+                        time.sleep(delay)
+                except Exception:
+                    session.rollback()
+                    continue
+            try:
+                self._finish_job(event_id)
+            except Exception:
+                pass
+        finally:
+            session.close()

src/impl/Mail/client.py

@@ -1,5 +1,6 @@
 from http import HTTPStatus
 from typing import Any
+import logging
 from generated_src.lleida_hack_mail_api_client.api.health import health_check
 from generated_src.lleida_hack_mail_api_client.api.mail import (
     mail_create,
@@ -12,6 +13,8 @@
 from src.utils.Base.BaseClient import BaseClient
 from src.configuration.Settings import settings
 
+logger = logging.getLogger(__name__)
+
 
 def initialized(func):
     def wrapper(*args, **kwargs):
@@ -40,7 +43,7 @@ def __init__(self) -> Any:
             self._initialized = True
         except Exception:
             self._initialized = False
-            print("MailClient not initialized")
+            logger.warning("MailClient not initialized")
             # raise MailClientException('MailClient is not available')
 
     def check_health(self):
@@ -59,12 +62,22 @@ def create_mail(self, mail: MailCreate):
         r = mail_create.sync(client=self.client, body=mail)
         if r is None:
             raise Exception(f"error creating {mail}")
+        try:
+            mail_id = getattr(r, "id", None)
+            logger.info("Mail created id=%s receiver=%s subject=%s", mail_id, mail.receiver_mail, mail.subject)
+        except Exception:
+            logger.debug("Mail created (unable to log details)")
         return r
 
     @initialized
     def send_mail_by_id(self, id: int):
-        print('estem arrivant al send nanu')
+        logger.info("Sending mail id=%s", id)
         r = mail_send_by_id.sync_detailed(id, client=self.client)
+        status = getattr(r, "status_code", None)
+        try:
+            logger.info("Mail send result id=%s status=%s", id, status)
+        except Exception:
+            logger.debug("Mail send completed id=%s", id)
         return r
 
     def get_template_by_name(self, name):