app/job_runner.py

136 lines
4.4 KiB
Python
Raw Normal View History

2020-02-03 14:11:11 +08:00
"""
Run scheduled jobs.
Not meant for running job at precise time (+- 1h)
"""
import time
import arrow
2020-04-03 05:26:17 +08:00
from app.config import (
JOB_ONBOARDING_1,
JOB_ONBOARDING_2,
JOB_ONBOARDING_3,
JOB_ONBOARDING_4,
)
2020-03-05 18:00:58 +08:00
from app.email_utils import send_email, render
2020-02-03 14:11:11 +08:00
from app.extensions import db
from app.log import LOG
2020-03-05 18:00:58 +08:00
from app.models import User, Job
2020-02-03 14:11:11 +08:00
from server import create_app
# fix the database connection leak issue
# use this method instead of create_app
def new_app():
app = create_app()
@app.teardown_appcontext
def shutdown_session(response_or_exc):
# same as shutdown_session() in flask-sqlalchemy but this is not enough
db.session.remove()
# dispose the engine too
db.engine.dispose()
return app
def onboarding_send_from_alias(user):
2020-02-03 14:11:11 +08:00
send_email(
user.email,
f"Do you know you can send emails to anyone from your alias?",
render("com/onboarding/send-from-alias.txt", user=user),
render("com/onboarding/send-from-alias.html", user=user),
2020-02-03 14:11:11 +08:00
)
def onboarding_pgp(user):
send_email(
user.email,
2020-03-25 04:19:45 +08:00
f"Do you know you can encrypt your emails so only you can read them?",
render("com/onboarding/pgp.txt", user=user),
render("com/onboarding/pgp.html", user=user),
)
2020-04-03 05:26:17 +08:00
def onboarding_browser_extension(user):
send_email(
user.email,
f"Do you know you can create aliases without leaving the browser?",
render("com/onboarding/browser-extension.txt", user=user),
render("com/onboarding/browser-extension.html", user=user),
)
2020-03-25 04:19:45 +08:00
def onboarding_mailbox(user):
send_email(
user.email,
f"Do you know SimpleLogin can manage several email addresses?",
render("com/onboarding/mailbox.txt", user=user),
render("com/onboarding/mailbox.html", user=user),
)
2020-02-03 14:11:11 +08:00
if __name__ == "__main__":
while True:
# run a job 1h earlier or later is not a big deal ...
min_dt = arrow.now().shift(hours=-1)
max_dt = arrow.now().shift(hours=1)
app = new_app()
with app.app_context():
for job in Job.query.filter(
Job.taken == False, Job.run_at > min_dt, Job.run_at <= max_dt
).all():
LOG.d("Take job %s", job)
# mark the job as taken, whether it will be executed successfully or not
job.taken = True
db.session.commit()
if job.name == JOB_ONBOARDING_1:
user_id = job.payload.get("user_id")
user = User.get(user_id)
# user might delete their account in the meantime
# or disable the notification
if user and user.notification and user.activated:
LOG.d("send onboarding send-from-alias email to user %s", user)
onboarding_send_from_alias(user)
elif job.name == JOB_ONBOARDING_2:
user_id = job.payload.get("user_id")
user = User.get(user_id)
# user might delete their account in the meantime
# or disable the notification
if user and user.notification and user.activated:
LOG.d("send onboarding mailbox email to user %s", user)
onboarding_mailbox(user)
2020-03-25 04:19:45 +08:00
elif job.name == JOB_ONBOARDING_3:
user_id = job.payload.get("user_id")
user = User.get(user_id)
# user might delete their account in the meantime
# or disable the notification
if user and user.notification and user.activated:
LOG.d("send onboarding pgp email to user %s", user)
onboarding_pgp(user)
2020-04-03 05:26:17 +08:00
elif job.name == JOB_ONBOARDING_4:
user_id = job.payload.get("user_id")
user = User.get(user_id)
# user might delete their account in the meantime
# or disable the notification
if user and user.notification and user.activated:
LOG.d(
"send onboarding browser-extension email to user %s", user
)
onboarding_browser_extension(user)
2020-02-03 14:11:11 +08:00
else:
LOG.error("Unknown job name %s", job.name)
time.sleep(10)