mirror/django-mailbox
1
0
Fork 1
mirror of https://github.com/coddingtonbear/django-mailbox.git synced 2026-07-09 22:38:19 +02:00
Code Activity

Adding ability to limit messages by max size

Browse source 
Adding a new setting for maximum message size
 Adding method to limit a set of message uids by size
 Switching to IMAP uids so that we can trust that subsequent
 commands will use the same ids
This commit is contained in:
Alex Lovell-Troy 2014-05-28 20:39:13 -06:00
parent 6336e910bd
commit 29d36a493a
1 changed files with 52 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

59
django_mailbox/transports/imap.py
View file

@ -2,12 +2,20 @@ from imaplib import IMAP4, IMAP4_SSL
from .base import EmailTransport, MessageParseError
from django.conf import settings
MAX_MESSAGE_SIZE = getattr(
settings,
'DJANGO_MAILBOX_MAX_MESSAGE_SIZE',
False
)
class ImapTransport(EmailTransport):
def __init__(self, hostname, port=None, ssl=False, archive=''):
self.hostname = hostname
self.port = port
self.archive = archive
self.MAX_MSG_SIZE = MAX_MESSAGE_SIZE
if ssl:
self.transport = IMAP4_SSL
if not self.port:
@ -22,10 +30,47 @@ class ImapTransport(EmailTransport):
typ, msg = self.server.login(username, password)
self.server.select()
def get_message(self):
typ, inbox = self.server.search(None, 'ALL')
if not inbox[0]:
def _get_all_message_ids(self):
# Fetch all the message uids
response, message_ids = self.server.uid('search', None, 'ALL', )
return message_ids[0].split(' ')
def _get_small_message_ids(self, message_ids):
# Using existing message uids, get the sizes and
# return only those that are under the size
# limit
safe_message_ids = []
status, data = self.server.uid(
'fetch',
','.join(message_ids),
'(BODY.PEEK[HEADER] RFC822.SIZE BODYSTRUCTURE)'
)
for each_msg in data:
if isinstance(each_msg, tuple):
try:
metadata, structure = each_msg[0].split(' BODYSTRUCTURE ')
uid = metadata.split('(')[1].split(' ')[1]
size = metadata.split('(')[1].split(' ')[3]
if int(size) <= int(self.MAX_MSG_SIZE):
safe_message_ids.append(uid)
except ValueError, e:
print "ValueError: %s working on %s" % (e, each_msg[0])
print each_msg
pass
return safe_message_ids
def get_message(self):
message_ids = self._get_all_message_ids()
# Limit the uids to the small ones if we care about that
if self.MAX_MSG_SIZE:
message_ids = self._get_small_message_ids(message_ids)
if not message_ids:
return
if self.archive:
@ -34,17 +79,17 @@ class ImapTransport(EmailTransport):
# If the archive folder does not exist, create it
self.server.create(self.archive)
for key in inbox[0].split():
for uid in message_ids:
try:
typ, msg_contents = self.server.fetch(key, '(RFC822)')
typ, msg_contents = self.server.uid('fetch', uid, '(RFC822)')
message = self.get_email_from_bytes(msg_contents[0][1])
yield message
except MessageParseError:
continue
if self.archive:
self.server.copy(key, self.archive)
self.server.uid('copy', uid, self.archive)
self.server.store(key, "+FLAGS", "\\Deleted")
self.server.uid('store', uid, "+FLAGS", "\\Deleted")
self.server.expunge()
return