amorfo77/parsedmarc
1
0
Fork 0
mirror of https://github.com/domainaware/parsedmarc.git synced 2026-04-04 12:48:53 +00:00
Code Issues Projects Releases Wiki Activity

Move emails in chunks

Browse Source
This commit is contained in:
Sean Whalen
2018-03-14 22:12:00 -04:00
parent fc16bb8a2f
commit effbb0bceb
1 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
parsedmarc.py
View File

@@ -1029,6 +1029,12 @@ def get_dmarc_reports_from_inbox(host, user, password,
Returns:
OrderedDict: Lists of ``aggregate_reports`` and ``forensic_reports``
"""
def chunks(l, n):
"""Yield successive n-sized chunks from l."""
for i in range(0, len(l), n):
yield l[i:i + n]
if delete and test:
raise ValueError("delete and test options are mutually exclusive")
@@ -1075,13 +1081,14 @@ def get_dmarc_reports_from_inbox(host, user, password,
server.add_flags(processed_messages, [imapclient.DELETED])
server.expunge()
else:
logging.warning("Moving ")
if len(aggregate_report_msg_uids) > 0:
server.move(aggregate_report_msg_uids,
aggregate_reports_folder)
for chunk in chunks(aggregate_report_msg_uids, 100):
server.move(chunk,
aggregate_reports_folder)
if len(forensic_report_msg_uids) > 0:
server.move(forensic_report_msg_uids,
forensic_reports_folder)
for chunk in chunks(forensic_report_msg_uids, 100):
server.move(chunk,
forensic_reports_folder)
results = OrderedDict([("aggregate_reports", aggregate_reports),
("forensic_reports", forensic_reports)])