diff options
Diffstat (limited to 'wqflask/wqflask/send_mail.py')
-rw-r--r-- | wqflask/wqflask/send_mail.py | 51 |
1 files changed, 0 insertions, 51 deletions
diff --git a/wqflask/wqflask/send_mail.py b/wqflask/wqflask/send_mail.py deleted file mode 100644 index 299c866a..00000000 --- a/wqflask/wqflask/send_mail.py +++ /dev/null @@ -1,51 +0,0 @@ -import datetime -import time - -import simplejson as json - -from redis import StrictRedis -Redis = StrictRedis() - -import mailer - - -def timestamp(): - ts = datetime.datetime.utcnow() - return ts.isoformat() - - -def main(): - while True: - print("I'm alive!") - - # Set something so we know it's running (or at least been running recently) - Redis.setex("send_mail:ping", 300, time.time()) - - msg = Redis.blpop("mail_queue", 30) - - if msg: - # Queue name is the first element, we want the second, which is the actual message - msg = msg[1] - - print("\n\nGot a msg in queue at {}: {}".format(timestamp(), msg)) - # Todo: Truncate mail_processed when it gets to long - Redis.rpush("mail_processed", msg) - process_message(msg) - - -def process_message(msg): - msg = json.loads(msg) - - message = mailer.Message() - message.From = msg['From'] - message.To = msg['To'] - message.Subject = msg['Subject'] - message.Body = msg['Body'] - - sender = mailer.Mailer('localhost') - sender.send(message) - print("Sent message at {}: {}\n".format(timestamp(), msg)) - - -if __name__ == '__main__': - main() |