github-public-mirror/gulag
1
0
Fork 0
mirror of https://github.com/chillout2k/gulag.git synced 2025-12-13 16:00:18 +00:00
Code Issues Projects Releases Wiki Activity

Gulag::get_quarmails()

Browse Source
This commit is contained in:
Dominik Chilla 2018-12-22 22:42:39 +01:00
parent eb3a1e9bf2
commit 1e35dfef7a
2 changed files with 32 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
app/Gulag.py
View File

@ -58,7 +58,8 @@ class Gulag:
) )
for arg in args: for arg in args:
if(arg == 'query_offset' or arg == 'query_limit' if(arg == 'query_offset' or arg == 'query_limit'
or arg == 'sort_index' or arg == 'sort_order'): or arg == 'sort_index' or arg == 'sort_order'
or arg == 'rfc822_message'):
continue continue
if arg not in self.fields[fields_target]: if arg not in self.fields[fields_target]:
raise GulagException( raise GulagException(
@ -212,14 +213,41 @@ class Gulag:
raise GulagException(whoami(self) + e.message) from e raise GulagException(whoami(self) + e.message) from e
def get_quarmails(self,args): def get_quarmails(self,args):
qms_db = None
try: try:
self.check_fields('QuarMails',args) self.check_fields('QuarMails',args)
return self.db.get_quarmails(args) qms_db = self.db.get_quarmails(args)
except(GulagException,GulagDBException) as e: except(GulagException,GulagDBException) as e:
logging.warning(whoami(self) + e.message) logging.warning(whoami(self) + e.message)
raise GulagException( raise GulagException(
whoami(self) + e.message whoami(self) + e.message
) from e ) from e
if 'rfc822_message' not in args:
return qms_db
# collect all IMAP mailboxes to read from
mailboxes = {}
for qm in qms_db:
if qm['mailbox_id'] not in mailboxes:
mailboxes[qm['mailbox_id']] = []
# any qm_db with full RFC822 messages from IMAP mailbox
for mailbox_id in mailboxes:
try:
mailbox = self.db.get_mailbox(mailbox_id)
except GulagDBException as e:
logging.warning(whoami(self) + e.message)
raise GulagException(whoami(self) + e.message) from e
imap_mb = None
try:
imap_mb = IMAPmailbox(mailbox)
except IMAPmailboxException as e:
logging.warning(whoami(self) + e.message)
raise GulagException(whoami(self) + e.message) from e
for qm_db in qms_db:
qm_db['rfc822_message'] = imap_mb.get_message(qm_db['imap_uid']).decode("utf-8")
logging.info(whoami(self) +
str(qm_db['imap_uid']) + " size: " + str(qm_db['msg_size'])
)
return qms_db
def get_quarmail(self,args): def get_quarmail(self,args):
qm_db = None qm_db = None

3
app/GulagDB.py
View File

@ -90,7 +90,8 @@ class GulagDB:
cnt = 0 cnt = 0
for arg in args: for arg in args:
if(arg == 'query_offset' or arg == 'query_limit' if(arg == 'query_offset' or arg == 'query_limit'
or arg == 'sort_index' or arg == 'sort_order'): or arg == 'sort_index' or arg == 'sort_order'
or arg == 'rfc822_message'):
continue continue
if(cnt == 0): if(cnt == 0):
where_clause += "where " + arg + "='" + args[arg] + "' " where_clause += "where " + arg + "='" + args[arg] + "' "