# (c) cavaliba.com - app_status - tasks.py

from celery import shared_task

import app_home.cache as cache
from app_home.log import DEBUG, log
from app_status.common import cleanup_hour, cleanup_raw, run_monitors, sample_day, sample_hour


# @app.task
@shared_task(ignore_result=True)
def task_run_monitor():

    # flush_cache_per_request()
    cache.init()

    aaa = None
    count = run_monitors()
    log(
        DEBUG,
        aaa=aaa,
        app="status",
        view="cron",
        action="run_monitor",
        status="OK",
        data=f"{count} run",
    )


#   -- sample


@shared_task(ignore_result=True)
def task_sample_hour():

    # flush_cache_per_request()
    cache.init()

    aaa = None
    total = sample_hour()
    log(
        DEBUG,
        aaa=aaa,
        app="status",
        view="cron",
        action="sample_hour",
        status="OK",
        data=f"{total} updated",
    )


@shared_task(ignore_result=True)
def task_sample_day():

    # flush_cache_per_request()
    cache.init()

    aaa = None
    total = sample_day()
    log(
        DEBUG,
        aaa=aaa,
        app="status",
        view="cron",
        action="sample_day",
        status="OK",
        data=f"{total} updated",
    )


#   -- cleanup


@shared_task(ignore_result=True)
def task_cleanup_raw():

    # flush_cache_per_request()
    cache.init()

    aaa = None
    cleanup_raw()
    log(DEBUG, aaa=aaa, app="status", view="cron", action="cleanup_raw", status="OK", data="")


@shared_task(ignore_result=True)
def task_cleanup_hour():

    # flush_cache_per_request()
    cache.init()

    aaa = None
    cleanup_hour()
    log(DEBUG, aaa=aaa, app="status", view="cron", action="cleanup_hour", status="OK", data="")