from huey import Huey, crontab

from .. import HUEY, create_app


def create_consumer() -> Huey:
    app = create_app()

    from . import receiver, scanner, sender  # noqa: E402, F401

    schedule = crontab(
        *app.config["WEBMENTIONS_SSG_SCANNER_SCHEDULE"].split(), strict=True
    )
    HUEY.periodic_task(schedule)(scanner.scan_sources)

    return HUEY.huey


huey = create_consumer()