annotate gpp/mailer/__init__.py @ 507:8631d32e6b16
Some users are still having problems with the pop-up login. I think they are actually getting 403s because of the CSRF protection. So I have modified the base template to always have a javascript variable called csrf_token available when they aren't logged in. The ajax_login.js script was then modified to send this value with the ajax post. Fingers crossed.
author |
Brian Neal <bgneal@gmail.com> |
date |
Sun, 04 Dec 2011 03:05:21 +0000 |
parents |
767cedc7d12a |
children |
|
rev |
line source |
bgneal@180
|
1 from socket import error as socket_error
|
bgneal@180
|
2 import smtplib
|
bgneal@180
|
3 import time
|
bgneal@316
|
4 import logging
|
bgneal@180
|
5
|
bgneal@180
|
6 import django.core.mail
|
bgneal@180
|
7
|
bgneal@180
|
8 import mailer.models
|
bgneal@180
|
9
|
bgneal@180
|
10
|
bgneal@180
|
11 def enqueue_mail(subject, message, from_email, recipient_list):
|
bgneal@180
|
12 """Creates mailer mail queue entries for the given email."""
|
bgneal@180
|
13
|
bgneal@180
|
14 if len(subject) > mailer.models.MAX_SUBJECT:
|
bgneal@180
|
15 subject = u'%s...' % subject[:mailer.models.MAX_SUBJECT - 3]
|
bgneal@180
|
16
|
bgneal@180
|
17 for recipient in recipient_list:
|
bgneal@180
|
18 mailer.models.Message(
|
bgneal@180
|
19 from_address=from_email,
|
bgneal@180
|
20 to_address=recipient,
|
bgneal@180
|
21 subject=subject,
|
bgneal@180
|
22 body=message).save()
|
bgneal@180
|
23
|
bgneal@180
|
24
|
bgneal@180
|
25 def send_queued_mail():
|
bgneal@180
|
26 """Reads the queued messages from the database, sends them, and removes them
|
bgneal@180
|
27 from the queue."""
|
bgneal@180
|
28
|
bgneal@180
|
29 sent, errors = 0, 0
|
bgneal@180
|
30
|
bgneal@180
|
31 logging.debug("Sending queued mail...")
|
bgneal@180
|
32 start_time = time.time()
|
bgneal@180
|
33
|
bgneal@180
|
34 msgs = mailer.models.Message.objects.all()
|
bgneal@180
|
35 for msg in msgs:
|
bgneal@180
|
36 try:
|
bgneal@180
|
37 django.core.mail.send_mail(
|
bgneal@316
|
38 msg.subject,
|
bgneal@316
|
39 msg.body,
|
bgneal@316
|
40 msg.from_address,
|
bgneal@180
|
41 [msg.to_address],
|
bgneal@180
|
42 fail_silently=False)
|
bgneal@180
|
43 except (socket_error, smtplib.SMTPException), e:
|
bgneal@180
|
44 errors += 1
|
bgneal@316
|
45 logging.error("Error sending queued mail: %s", e)
|
bgneal@180
|
46 else:
|
bgneal@316
|
47 sent += 1
|
bgneal@316
|
48 msg.delete()
|
bgneal@180
|
49
|
bgneal@180
|
50 end_time = time.time()
|
bgneal@180
|
51 logging.debug("Sent queued mail: %d successful, %d error(s); elapsed time: %.2f" % (
|
bgneal@180
|
52 sent, errors, end_time - start_time))
|