aboutsummaryrefslogtreecommitdiff
path: root/wqflask/wqflask/send_mail.py
diff options
context:
space:
mode:
Diffstat (limited to 'wqflask/wqflask/send_mail.py')
-rw-r--r--wqflask/wqflask/send_mail.py51
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()