LongArticleTaskServer/app/api/v1/endpoints/monitor.py

from __future__ import annotations

from quart import Blueprint, jsonify

from app.api.v1.utils import ApiDependencies
from app.domains.monitor_tasks import FwhGroupPublishMonitor


def create_monitor_bp(deps: ApiDependencies) -> Blueprint:
    bp = Blueprint("monitor", __name__)

    @bp.route("/fwh_group_sent_monitor", methods=["GET"])
    async def fwh_group_sent_monitor():
        service = FwhGroupPublishMonitor(deps.db, deps.log)
        await service.deal(task_name="bot")
        return jsonify({"status": "success"})

    return bp