Handlers

class IsInstagramLink(Filter):
    async def __call__(self, message: Message) -> dict | bool:
        if not message.text:
            return False
        match = INSTAGRAM_URL_REGEX.search(message.text)
        if match:
            return {"instagram_url": match.group(0)}
        return False

@link_router.message(IsInstagramLink())
async def handle_instagram_message(
    message: Message, instagram_url: str
) -> None:
    # Checks queue limits
    # Downloads and sends Instagram media
    # Handles reactions and status messages

@user_router.message(CommandStart(), F.chat.type == 'private')
async def send_start(message: Message) -> None:
    # Registers new users or displays welcome message

@user_router.message(Command('mode'))
async def change_mode(message: Message):
    # Toggles file_mode between True/False
    # Requires admin permissions in groups

@video_router.message(F.text)
async def send_tiktok_video(message: Message):
    # 1. Regex validation
    # 2. Queue limit check
    # 3. Set processing reaction/status
    # 4. Acquire queue slot
    # 5. Fetch video info (3-part retry strategy)
    # 6. Send video or slideshow
    # 7. Show ad if applicable
    # 8. Log to database

@video_router.message(F.video | F.video_note)
async def handle_video_upload(message: Message):
    # Informs users to send links, not video uploads

@video_router.message(F.photo)
async def handle_image_upload(message: Message):
    # Informs users that only links are supported

@video_router.message(F.voice | F.audio)
async def handle_voice_upload(message: Message):
    # Informs users that only links are supported

@video_router.message()
async def handle_unsupported_content(message: Message):
    # Catch-all for any other content

@video_router.callback_query(F.data == RETRY_CALLBACK_PREFIX)
async def handle_retry_callback(callback: CallbackQuery):
    # Re-processes the original message when "Try Again" is clicked

@music_router.callback_query(F.data.startswith("id"))
async def send_tiktok_sound(callback_query: CallbackQuery):
    # Triggered by music button callback
    # Downloads and sends audio file

@inline_router.inline_query()
async def handle_inline_query(inline_query: InlineQuery):
    # Returns inline results for TikTok/Instagram links

@inline_router.chosen_inline_result()
async def handle_chosen_inline_result(chosen_result: ChosenInlineResult):
    # Routes to TikTok or Instagram handler based on result_id

@lang_router.message(Command("lang"))
async def lang_change(message: Message):
    # Displays language selection keyboard

@lang_router.callback_query(F.data.startswith("lang"))
async def inline_lang(callback_query: CallbackQuery):
    # Updates user language in database

@admin_router.message(
    Command("msg", "tell", "say", "send"), 
    F.chat.type == "private", 
    IsSecondAdmin()
)
async def send_hi(message: Message):
    # Sends message to specific user
    # Usage: /msg <user_id> <message>

@admin_router.message(Command("export"), F.chat.type == "private", IsSecondAdmin())
async def export_users(message: Message):
    # Exports user list as file

# Link detection priority:
1. Instagram URL → link_router (IsInstagramLink filter)
2. TikTok URL → video_router (regex check in handler)
3. Other content → Appropriate content type handler

# Command routing:
/start → user_router
/mode → user_router
/lang → lang_router
/admin → advert_router
/msg → admin_router
/export → admin_router

# Callback routing:
id/{video_id} → music_router
lang/{lang_code} → lang_router
retry_video → video_router

from misc.queue_manager import QueueManager

queue = QueueManager.get_instance()

# Acquire slot with per-user limit
async with queue.info_queue(user_id) as acquired:
    if not acquired:
        await message.reply("Queue full, please wait...")
        return
    # Process download

# For inline downloads (bypass user limit)
async with queue.info_queue(user_id, bypass_user_limit=True) as acquired:
    # Process inline download

from media_types import get_error_message

try:
    video_info = await api.video(video_link)
except TikTokError as e:
    await message.reply(get_error_message(e, lang))