Techsystech
/
server-tools
mirror of https://github.com/OCA/server-tools.git
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[IMP] refactored fetch_mail 

[IMP] also log when we're done with one folder
pull/3071/head
Holger Brunn 2013-04-15 15:04:57 +02:00 committed by Jose Zambudio
parent e77fe1e0f6
commit 972b540516
1 changed files with 69 additions and 49 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
fetchmail_attach_from_folder/model/fetchmail_server.py
View File

@ -74,9 +74,19 @@ class fetchmail_server(Model):
connection = this.connect()
for folder in this.folder_ids:
this.handle_folder(connection, folder)
connection.close()
return super(fetchmail_server, self).fetch_mail(
cr, uid, check_original, context)
def handle_folder(self, cr, uid, ids, connection, folder, context=None):
for this in self.browse(cr, uid, ids, context=context):
logger.info('start checking for emails in %s server %s',
folder.path, this.name)
matcher = folder.get_algorithm()
match_algorithm = folder.get_algorithm()
if connection.select(folder.path)[0] != 'OK':
logger.error(
@ -84,14 +94,28 @@ class fetchmail_server(Model):
folder.path, this.server))
connection.select()
continue
result, msgids = connection.search(None, 'UNDELETED')
result, msgids = this.get_msgids(connection)
if result != 'OK':
logger.error(
'Could not search mailbox %s on %s' % (
folder.path, this.server))
continue
for msgid in msgids[0].split():
this.apply_matching(connection, folder, msgid, match_algorithm)
logger.info('finished checking for emails in %s server %s',
folder.path, this.name)
def get_msgids(self, cr, uid, ids, connection, context=None):
return connection.search(None, 'UNDELETED')
def apply_matching(self, cr, uid, ids, connection, folder, msgid,
match_algorithm, context=None):
for this in self.browse(cr, uid, ids, context=context):
result, msgdata = connection.fetch(msgid, '(RFC822)')
if result != 'OK':
logger.error(
'Could not fetch %s in %s on %s' % (
@ -105,14 +129,14 @@ class fetchmail_server(Model):
('message_id', '=', mail_message['message-id'])]):
continue
found_ids = matcher.search_matches(
found_ids = match_algorithm.search_matches(
cr, uid, folder,
mail_message, msgdata[0][1])
if found_ids and (len(found_ids) == 1 or
folder.match_first):
try:
matcher.handle_match(
match_algorithm.handle_match(
cr, uid, connection,
found_ids[0], folder, mail_message,
msgdata[0][1], msgid, context)
@ -124,10 +148,6 @@ class fetchmail_server(Model):
msgid, this.name)
elif folder.flag_nonmatching:
connection.store(msgid, '+FLAGS', '\\FLAGGED')
connection.close()
return super(fetchmail_server, self).fetch_mail(
cr, uid, check_original, context)
def attach_mail(
self, cr, uid, ids, connection, object_id, folder,