Actually enforce rate limiting
authorMagnus Hagander <magnus@hagander.net>
Wed, 19 Jun 2019 16:46:55 +0000 (18:46 +0200)
committerMagnus Hagander <magnus@hagander.net>
Wed, 19 Jun 2019 16:46:55 +0000 (18:46 +0200)
Forgot to commit the changes to the sender

resender/archives_resender.py

index 061ea16feb00fc3c334989a55d608b00ea791b6b..83bb10d60a465acd2b33b50e8a8f2a26e8c016ad 100755 (executable)
@@ -16,7 +16,7 @@ import psycopg2
 
 def process_queue(conn, sender, smtpserver, heloname):
     with conn.cursor() as curs:
-        curs.execute("SELECT r.id, u.email, m.rawtxt FROM mailarchives_resendmessage r INNER JOIN auth_user u ON u.id=r.sendto_id INNER JOIN messages m ON m.id=r.message_id ORDER BY r.id FOR UPDATE OF r LIMIT 1")
+        curs.execute("SELECT r.id, u.email, m.rawtxt FROM mailarchives_resendmessage r INNER JOIN auth_user u ON u.id=r.sendto_id INNER JOIN messages m ON m.id=r.message_id WHERE registeredat > CURRENT_TIMESTAMP ORDER BY r.id FOR UPDATE OF r LIMIT 1")
         ll = curs.fetchall()
         if len(ll) == 0:
             conn.rollback()