|
|
@ -39,6 +39,8 @@ class Processor(Thread):
|
|
|
|
reply_comment_email(msg['data'])
|
|
|
|
reply_comment_email(msg['data'])
|
|
|
|
elif msg['request'] == 'unsubscribe':
|
|
|
|
elif msg['request'] == 'unsubscribe':
|
|
|
|
unsubscribe_reader(msg['data'])
|
|
|
|
unsubscribe_reader(msg['data'])
|
|
|
|
|
|
|
|
elif msg['request'] == 'report':
|
|
|
|
|
|
|
|
report(msg['data'])
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
logger.info("throw unknown request " + str(msg))
|
|
|
|
logger.info("throw unknown request " + str(msg))
|
|
|
|
except:
|
|
|
|
except:
|
|
|
@ -123,11 +125,17 @@ def reply_comment_email(data):
|
|
|
|
|
|
|
|
|
|
|
|
# safe logic: no answer or unknown answer is a go for publishing
|
|
|
|
# safe logic: no answer or unknown answer is a go for publishing
|
|
|
|
if message[:2].upper() == 'NO':
|
|
|
|
if message[:2].upper() == 'NO':
|
|
|
|
|
|
|
|
# report event
|
|
|
|
|
|
|
|
report_rejected(comment)
|
|
|
|
|
|
|
|
|
|
|
|
logger.info('discard comment: %d' % comment_id)
|
|
|
|
logger.info('discard comment: %d' % comment_id)
|
|
|
|
comment.delete_instance()
|
|
|
|
comment.delete_instance()
|
|
|
|
email_body = get_template('drop_comment').render(original=message)
|
|
|
|
email_body = get_template('drop_comment').render(original=message)
|
|
|
|
mail(from_email, 'Re: ' + subject, email_body)
|
|
|
|
mail(from_email, 'Re: ' + subject, email_body)
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
|
|
|
|
# report event
|
|
|
|
|
|
|
|
report_published(comment)
|
|
|
|
|
|
|
|
|
|
|
|
# update Comment row
|
|
|
|
# update Comment row
|
|
|
|
comment.published = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
|
|
|
|
comment.published = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
|
|
|
|
comment.save()
|
|
|
|
comment.save()
|
|
|
@ -169,6 +177,9 @@ def subscribe_reader(email, token, url):
|
|
|
|
reader = Reader(site=site, email=email, url=url)
|
|
|
|
reader = Reader(site=site, email=email, url=url)
|
|
|
|
reader.save()
|
|
|
|
reader.save()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# report event
|
|
|
|
|
|
|
|
report_subscribed(reader)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def unsubscribe_reader(data):
|
|
|
|
def unsubscribe_reader(data):
|
|
|
|
token = data.get('token', '')
|
|
|
|
token = data.get('token', '')
|
|
|
@ -178,6 +189,9 @@ def unsubscribe_reader(data):
|
|
|
|
for reader in Reader.select().join(Site).where(Site.token == token,
|
|
|
|
for reader in Reader.select().join(Site).where(Site.token == token,
|
|
|
|
Reader.email == email,
|
|
|
|
Reader.email == email,
|
|
|
|
Reader.url == url):
|
|
|
|
Reader.url == url):
|
|
|
|
|
|
|
|
# report event
|
|
|
|
|
|
|
|
report_unsubscribed(reader)
|
|
|
|
|
|
|
|
|
|
|
|
reader.delete_instance()
|
|
|
|
reader.delete_instance()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@ -203,6 +217,29 @@ def notify_reader(from_email, to_email, token, url):
|
|
|
|
mail(to_email, subject, email_body)
|
|
|
|
mail(to_email, subject, email_body)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def report_rejected(comment):
|
|
|
|
|
|
|
|
pass
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def report_published(comment):
|
|
|
|
|
|
|
|
pass
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def report_subscribed(comment):
|
|
|
|
|
|
|
|
pass
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def report_unsubscribed(comment):
|
|
|
|
|
|
|
|
pass
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def report(token):
|
|
|
|
|
|
|
|
print('report requested for {}'.format(token))
|
|
|
|
|
|
|
|
standby_count = Comment.select().join(Site).where(
|
|
|
|
|
|
|
|
Site.token == token, Comment.published.is_null(True)).count()
|
|
|
|
|
|
|
|
print('standby {}'.format(standby_count))
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def mail(to_email, subject, message):
|
|
|
|
def mail(to_email, subject, message):
|
|
|
|
|
|
|
|
|
|
|
|
headers = {'Content-Type': 'application/json; charset=utf-8'}
|
|
|
|
headers = {'Content-Type': 'application/json; charset=utf-8'}
|
|
|
|