Update app.py

app.py

@@ -674,63 +674,18 @@ def send_notifications_for_events(new_events):
 
         total_sent = 0
 
-        from concurrent.futures import ThreadPoolExecutor, as_completed
-        import threading
-        import time
+        for uid, mail, unsubscribe_token in users:
 
-        send_lock = threading.Lock()
-        last_sent_time = [0]
-
-
-        def rate_limited_send(mail, subject, html):
-
-            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
+            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>
+            """
 
-            # 🔥 COOL DOWN between batches
-            print("⏸️ Cooling down 3 sec...")
-            time.sleep(3)
+            if send_email(mail, subject, html):
+                total_sent += 1
 
         cur.close()
         db.close()