o
    eOj[                     @   s   d dl mZ d dlmZmZ d dlmZ d dlmZ d dl	m
Z
 d dlmZmZ d dlmZ d dlmZ ed	d
Zedd dedede
deddf
ddZdS )    )Router)CallbackQueryMessage)AsyncSession)get_active_channels)User)build_subscription_keyboardbuild_main_menu)check_user_subscriptions)get_textsubscription)namec                 C   s
   | j dkS )N	check_sub)data)c r   K/var/www/www-root/data/www/ai-bot.pdev.uz/bot/handlers/user/subscription.py<lambda>   s   
 r   callbacksessiondb_userlangreturnNc           
         sN  t |I dH }|s7z
| j I dH  W n	 ty   Y nw | jjtd|t|dI dH  |  I dH  dS t|| jj	|dI dH }|skz
| j I dH  W n	 tyX   Y nw | jjtd|t|dI dH  dS ddl
m} ||||dI dH }t|||d}	z| jj|	dI dH  W n	 ty   Y nw | jtd	|d
dI dH  dS )z-'Obuna bo'ldim, tekshir!' tugmasini bosganidaNzsubscription-ok)reply_markup)botuser_idchannelsr   )_get_invite_links)r   )channel_urlszsubscription-failT)
show_alert)r   messagedelete	Exceptionanswerr   r	   r
   	from_useridbot.middlewares.subscriptionr   r   edit_reply_markup)
r   r   r   r   r   r   not_subscribedr   r   keyboardr   r   r   process_check_subscription   sR   	r*   )aiogramr   aiogram.typesr   r   sqlalchemy.ext.asyncior   bot.database.crud.channelr   bot.database.modelsr   bot.keyboards.user_kbr   r	   !bot.services.subscription_checkerr
   bot.services.i18nr   routercallback_querystrr*   r   r   r   r   <module>   s*    
