# SPDX-FileCopyrightText: 2023 Marlon W (Mawoka)
#
# SPDX-License-Identifier: MPL-2.0


from arq import cron
from arq.connections import RedisSettings

from classquiz import settings
from classquiz.db import database
from classquiz.worker.storage import clean_editor_images_up, calculate_hash, quiz_update


async def startup(ctx):
    ctx["db"] = database
    if not ctx["db"].is_connected:
        await ctx["db"].connect()


async def shutdown(ctx):
    if ctx["db"].is_connected:
        await ctx["db"].disconnect()


class WorkerSettings:
    functions = [calculate_hash, quiz_update]
    cron_jobs = [cron(clean_editor_images_up, hour={0, 6, 12, 18}, minute=0)]
    on_startup = startup
    on_shutdown = shutdown
    redis_settings = RedisSettings.from_dsn(str(settings.redis))