yannic/stacosys
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

enforce inbox mngt

Browse source
This commit is contained in:
Yax 2021-12-11 16:41:38 +01:00
parent aac1e817bb
commit 5386c82b0e
1 changed files with 27 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
stacosys/core/cron.py
View file

@ -21,28 +21,36 @@ templater = Templater(template_path)
def fetch_mail_answers(lang, mailer: Mailer, rss: Rss, site_token): def fetch_mail_answers(lang, mailer: Mailer, rss: Rss, site_token):
for msg in mailer.fetch(): while True:
# filter stacosys e-mails msgs = mailer.fetch()
m = re.search(REGEX_EMAIL_SUBJECT, msg.subject, re.DOTALL) if len(msgs) == 0:
if not m: break
continue msg = msgs[0]
_process_answer_msg(msg, lang, mailer, rss, site_token)
comment_id = int(m.group(1))
submitted_token = m.group(2)
# validate token
if submitted_token != site_token:
logger.warning("ignore corrupted email. Unknown token %d" % comment_id)
continue
if not msg.plain_text_content:
logger.warning("ignore empty email")
continue
_reply_comment_email(lang, mailer, rss, msg, comment_id)
mailer.delete(msg.id) mailer.delete(msg.id)
def _process_answer_msg(msg, lang, mailer: Mailer, rss: Rss, site_token):
# filter stacosys e-mails
m = re.search(REGEX_EMAIL_SUBJECT, msg.subject, re.DOTALL)
if not m:
return
comment_id = int(m.group(1))
submitted_token = m.group(2)
# validate token
if submitted_token != site_token:
logger.warning("ignore corrupted email. Unknown token %d" % comment_id)
return
if not msg.plain_text_content:
logger.warning("ignore empty email")
return
_reply_comment_email(lang, mailer, rss, msg, comment_id)
def _reply_comment_email(lang, mailer: Mailer, rss: Rss, email: Email, comment_id): def _reply_comment_email(lang, mailer: Mailer, rss: Rss, email: Email, comment_id):
# retrieve comment # retrieve comment
comment = dao.find_comment_by_id(comment_id) comment = dao.find_comment_by_id(comment_id)