annotate gpp/mailer/__init__.py @ 467:b910cc1460c8
Add the ability to conditionally add model instances to the search index on update. This is not perfect, as some instances should be deleted from the index if they are updated such that they should not be in the index anymore. Will think about and address that later.
| author |
Brian Neal <bgneal@gmail.com> |
| date |
Sun, 24 Jul 2011 18:12:20 +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))
|
