Update data_updating_scripts/generate_newsletter.py

data_updating_scripts/generate_newsletter.py

@@ -306,10 +306,66 @@ def main():
     print(f"Newsletter draft saved: {output_path}")
     _update_pipeline_progress(1, 1, "newsletter", "Newsletter generated")
 
+    # Email the newsletter
+    _send_email_notification(output_path, markdown)
+
     # Upload newsletter draft to HF dataset for persistence
     _upload_newsletter_to_hf(output_path)
 
 
+def _send_email_notification(draft_path: Path, markdown: str):
+    """Email the newsletter draft to all subscribers + NOTIFY_EMAIL via Gmail SMTP."""
+    import smtplib
+    from email.mime.multipart import MIMEMultipart
+    from email.mime.text import MIMEText
+
+    gmail_from = os.environ.get("GMAIL_FROM", "").strip()
+    app_password = os.environ.get("GMAIL_APP_PASSWORD", "").replace(" ", "")
+    notify_to = os.environ.get("NOTIFY_EMAIL", "").strip()
+
+    if not gmail_from or not app_password:
+        logger.info("Email credentials not configured — skipping notification")
+        return
+
+    # Load subscriber list
+    subscribers_path = Path("data/subscribers.json")
+    subscribers = []
+    if subscribers_path.exists():
+        try:
+            with open(subscribers_path, "r") as f:
+                subscribers = json.load(f)
+        except Exception:
+            pass
+
+    # Combine subscribers with NOTIFY_EMAIL (deduped)
+    all_recipients = list({e.strip().lower() for e in subscribers + ([notify_to] if notify_to else []) if e.strip()})
+
+    if not all_recipients:
+        logger.info("No recipients configured — skipping email")
+        return
+
+    subject = f"VAILL Newsletter — {datetime.now().strftime('%B %d, %Y')}"
+
+    sent, failed = 0, 0
+    with smtplib.SMTP_SSL("smtp.gmail.com", 465) as server:
+        server.login(gmail_from, app_password)
+        for recipient in all_recipients:
+            msg = MIMEMultipart("alternative")
+            msg["Subject"] = subject
+            msg["From"] = f"VAILL Tracker <{gmail_from}>"
+            msg["To"] = recipient
+            msg.attach(MIMEText(markdown, "plain", "utf-8"))
+            try:
+                server.sendmail(gmail_from, recipient, msg.as_string())
+                logger.info(f"Newsletter emailed to {recipient}")
+                sent += 1
+            except Exception as e:
+                logger.warning(f"Failed to send to {recipient}: {e}")
+                failed += 1
+
+    print(f"Newsletter sent: {sent} succeeded, {failed} failed ({len(all_recipients)} total recipients)")
+
+
 def _upload_newsletter_to_hf(draft_path: Path):
     """Upload the newsletter draft to HF dataset."""
     try: