Update app.py

app.py

@@ -16,6 +16,9 @@ from starlette.requests import Request
 from starlette.responses import JSONResponse, Response
 from starlette.routing import Mount, Route
 
+import smtplib
+from email.message import EmailMessage
+
 # -----------------------------------------------------------------------------
 # HF Hub persistence (FREE): save/load cards_state.json from a dataset repo
 # -----------------------------------------------------------------------------
@@ -65,6 +68,29 @@ STATE_LOCK = asyncio.Lock()
 
 SERVER_PASSWORD = (os.environ.get("password") or "").strip()
 
+SMTP_HOST = os.environ.get("SMTP_HOST", "").strip()
+SMTP_PORT = int(os.environ.get("SMTP_PORT", "587"))
+SMTP_USER = os.environ.get("SMTP_USER", "").strip()
+SMTP_PASS = os.environ.get("SMTP_PASS", "").strip()
+SMTP_FROM = os.environ.get("SMTP_FROM", SMTP_USER).strip()
+SMTP_TO = [x.strip() for x in os.environ.get("SMTP_TO", "").split(",") if x.strip()]
+
+EMAIL_ENABLED = bool(SMTP_HOST and SMTP_USER and SMTP_PASS and SMTP_TO)
+
+def _send_email(subject: str, body: str) -> None:
+    if not EMAIL_ENABLED:
+        return
+    msg = EmailMessage()
+    msg["Subject"] = subject
+    msg["From"] = SMTP_FROM
+    msg["To"] = ", ".join(SMTP_TO)
+    msg.set_content(body)
+
+    with smtplib.SMTP(SMTP_HOST, SMTP_PORT, timeout=20) as s:
+        s.starttls()
+        s.login(SMTP_USER, SMTP_PASS)
+        s.send_message(msg)
+
 
 def _hub_pull_into_local() -> None:
     """If local state missing, download cards_state.json from dataset repo."""
@@ -234,8 +260,20 @@ async def api_cards(request: Request) -> Response:
         state["cards"].append(card)
         state["version"] += 1
         await set_state(state)
+
+       if EMAIL_ENABLED:
+            subject = f"New model card posted: {card.get('model','')}"
+            body = (
+                f"Model: {card.get('model','')}\n"
+                f"Tags: {', '.join(card.get('tags', []) or [])}\n"
+                f"By: {card.get('author','')}\n"
+                f"Link: {card.get('link','')}\n"
+            )
+            asyncio.create_task(asyncio.to_thread(_send_email, subject, body))
+            
         return _json(state)
 
+
     return _json({"error": "Method not allowed"}, status_code=405)