Rapport email a contact@copydev.fr apres vidage du spool

Au demarrage, si le spool contient des emails en attente, les envoie
puis envoie un rapport recapitulatif (nb envoyes + liste destinataires)

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
2026-06-22 19:42:25 +02:00
parent 9bdad23cf5
commit 85f32c35bb

View File

@@ -104,14 +104,18 @@ def taille_spool() -> int:
return len(_charger_spool()) return len(_charger_spool())
def traiter_spool() -> int: EMAIL_RAPPORT = "contact@copydev.fr"
"""Tente d'envoyer les emails en attente. Retourne le nombre envoyes."""
def traiter_spool() -> tuple[int, list[str]]:
"""Tente d'envoyer les emails en attente. Retourne (nb envoyes, liste destinataires)."""
with _spool_lock: with _spool_lock:
spool = _charger_spool() spool = _charger_spool()
if not spool: if not spool:
return 0 return 0, []
envoyes = 0 envoyes = 0
destinataires = []
restants = [] restants = []
for entry in spool: for entry in spool:
chemin = Path(entry["photo"]) chemin = Path(entry["photo"])
@@ -121,27 +125,71 @@ def traiter_spool() -> int:
ok = envoyer_photo(entry["email"], chemin) ok = envoyer_photo(entry["email"], chemin)
if ok: if ok:
envoyes += 1 envoyes += 1
destinataires.append(entry["email"])
else: else:
restants.append(entry) restants.append(entry)
break # si un echoue, inutile de continuer (pas de connexion) break
if envoyes > 0 or len(restants) < len(spool): if envoyes > 0 or len(restants) < len(spool):
# garder les non-envoyes + ceux pas encore tentes
idx = envoyes + len(restants) idx = envoyes + len(restants)
restants.extend(spool[idx:]) restants.extend(spool[idx:])
with _spool_lock: with _spool_lock:
_sauver_spool(restants) _sauver_spool(restants)
log.info(f"Spool: {envoyes} envoye(s), {len(restants)} en attente") log.info(f"Spool: {envoyes} envoye(s), {len(restants)} en attente")
return envoyes return envoyes, destinataires
def envoyer_rapport_spool(nb_envoyes: int, destinataires: list[str], nb_echoues: int):
"""Envoie un rapport a contact@copydev.fr apres vidage du spool."""
config = charger_config()
conf_email = config.get("email", {})
conf_event = config.get("evenement", {})
nom_event = conf_event.get("nom", "Photobooth")
smtp_host = conf_email.get("smtp_host", "")
smtp_port = conf_email.get("smtp_port", 587)
smtp_user = conf_email.get("smtp_user", "")
smtp_password = conf_email.get("smtp_password", "")
expediteur = conf_email.get("expediteur", smtp_user)
if not smtp_host or not smtp_user:
return
liste = "\n".join(f" - {d}" for d in destinataires)
corps = f"{nb_envoyes} photo(s) envoyée(s) par email.\n\n"
corps += f"Destinataires :\n{liste}\n"
if nb_echoues > 0:
corps += f"\n{nb_echoues} email(s) en échec (restent en file d'attente).\n"
msg = MIMEMultipart()
msg["From"] = expediteur
msg["To"] = EMAIL_RAPPORT
msg["Subject"] = f"[{nom_event}] {nb_envoyes} photo(s) envoyée(s)"
msg.attach(MIMEText(corps, "plain", "utf-8"))
try:
with smtplib.SMTP(smtp_host, smtp_port, timeout=10) as serveur:
serveur.starttls()
serveur.login(smtp_user, smtp_password)
serveur.send_message(msg)
log.info(f"Rapport spool envoye a {EMAIL_RAPPORT}")
except (smtplib.SMTPException, OSError) as e:
log.error(f"Erreur envoi rapport spool : {e}")
async def tache_spool_demarrage(): async def tache_spool_demarrage():
"""Tente de vider le spool une seule fois au demarrage du serveur.""" """Tente de vider le spool une seule fois au demarrage du serveur."""
await asyncio.sleep(10) await asyncio.sleep(10)
if taille_spool() > 0: total = taille_spool()
log.info(f"Spool: tentative d'envoi au demarrage ({taille_spool()} en attente)") if total > 0:
await asyncio.get_event_loop().run_in_executor(None, traiter_spool) log.info(f"Spool: tentative d'envoi au demarrage ({total} en attente)")
nb, dests = await asyncio.get_event_loop().run_in_executor(None, traiter_spool)
if nb > 0:
echoues = total - nb
await asyncio.get_event_loop().run_in_executor(
None, envoyer_rapport_spool, nb, dests, echoues
)
FICHIER_EMAILS = RACINE / "data" / "emails_history.json" FICHIER_EMAILS = RACINE / "data" / "emails_history.json"