Update app.py

app.py

@@ -674,18 +674,64 @@ def send_notifications_for_events(new_events):
 
         total_sent = 0
 
-        for uid, mail, unsubscribe_token in users:
+        from concurrent.futures import ThreadPoolExecutor, as_completed
+        import threading
+        import time
 
-            html = f"""
-            <h2>📢 New BIP Events Alert</h2>
-            <p>{len(new_events)} new events have been added:</p>
-            {events_html}
-            <hr>
-            <a href="{HF_URL}?unsubscribe={unsubscribe_token}">Unsubscribe</a>
-            """
+        send_lock = threading.Lock()
+        last_sent_time = 0
+
+
+        def rate_limited_send(mail, subject, html):
+            global last_sent_time
+
+            with send_lock:
+                now = time.time()
+
+                # 🔥 STRICT: 1 mail per second globally
+                if now - last_sent_time < 1:
+                    time.sleep(1 - (now - last_sent_time))
+
+                last_sent_time = time.time()
+
+            return send_email(mail, subject, html)
+
+
+        # ================= REPLACE LOOP =================
+
+        max_workers = 5
+        batch_size = 20
+        total_sent = 0
+
+        for i in range(0, len(users), batch_size):
+            batch = users[i:i + batch_size]
+
+            print(f"📦 Sending batch {i//batch_size + 1} ({len(batch)} users)")
+
+            with ThreadPoolExecutor(max_workers=max_workers) as executor:
+                futures = []
+
+                for uid, mail, unsubscribe_token in batch:
+
+                    html = f"""
+                    <h2>📢 New BIP Events Alert</h2>
+                    <p>{len(new_events)} new events have been added:</p>
+                    {events_html}
+                    <hr>
+                    <a href="{HF_URL}?unsubscribe={unsubscribe_token}">Unsubscribe</a>
+                    """
+
+                    futures.append(
+                        executor.submit(rate_limited_send, mail, subject, html)
+                    )
+
+                for future in as_completed(futures):
+                    if future.result():
+                        total_sent += 1
 
-            if send_email(mail, subject, html):
-                total_sent += 1
+            # 🔥 COOL DOWN between batches
+            print("⏸️ Cooling down 3 sec...")
+            time.sleep(3)
 
         cur.close()
         db.close()