public/coins-demo
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Add a mail tracker title format pattern

Browse source
This commit is contained in:
Victor "multun" Collod 2019-01-06 16:09:09 +01:00
parent 99f4e34203
commit 46ade262ec
1 changed files with 15 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

19
todo/mail/consumers/tracker.py
View file

@ -34,10 +34,18 @@ def message_text(message):
if html_part is not None: if html_part is not None:
return html2text(part_decode(html_part)) return html2text(part_decode(html_part))
# TODO: find something smart to do when no text if found
return "" return ""
def insert_message(task_list, message, priority): def format_task_title(format_string, message):
return format_string.format(
subject=message["subject"],
author=message["from"],
)
def insert_message(task_list, message, priority, task_title_format):
if "message-id" not in message: if "message-id" not in message:
logger.warning("missing message id, ignoring message") logger.warning("missing message id, ignoring message")
return return
@ -80,7 +88,9 @@ def insert_message(task_list, message, priority):
with transaction.atomic(): with transaction.atomic():
if best_task is None: if best_task is None:
best_task = Task.objects.create( best_task = Task.objects.create(
priority=priority, title=message["subject"], task_list=task_list priority=priority,
title=format_task_title(task_title_format, message),
task_list=task_list
) )
logger.info(f"using task: {repr(best_task)}") logger.info(f"using task: {repr(best_task)}")
@ -92,11 +102,12 @@ def insert_message(task_list, message, priority):
logger.info(f"created comment: {repr(comment)}") logger.info(f"created comment: {repr(comment)}")
def tracker_consumer(producer, group=None, task_list_slug=None, priority=1): def tracker_consumer(producer, group=None, task_list_slug=None,
priority=1, task_title_format="[MAIL] {subject}"):
task_list = TaskList.objects.get(group__name=group, slug=task_list_slug) task_list = TaskList.objects.get(group__name=group, slug=task_list_slug)
for message in producer: for message in producer:
try: try:
insert_message(task_list, message, priority) insert_message(task_list, message, priority, title_format)
except Exception: except Exception:
# ignore exceptions during insertion, in order to avoid # ignore exceptions during insertion, in order to avoid
logger.exception("got exception while inserting message") logger.exception("got exception while inserting message")