misskey2telegram/modules/announcement.py

from defs.announcement import get_unread_announcements
from misskey_init import misskey_bot_map
from models.services.scheduler import scheduler


@scheduler.scheduled_job("interval", minutes=15, id="check_announcement")
async def announcement():
    for bot in misskey_bot_map.values():
        data = await get_unread_announcements(bot)
        for an in data:
            try:
                await an.send_notice()
            finally:
                await an.mark_as_read()