hrddlmZddlmZddlmZddlZddlmZm Z m Z m Z ddl m Z Gdd e ZdS) ) annotations)iscoroutinefunction)CallableN) IdentifierListener ListenerTypesMessage)HandlercNeZdZdZddfd Zedd ZddZddZxZ S)MessageHandleraThe Message handler class. Used to handle new messages. It is intended to be used with :meth:`~hydrogram.Client.add_handler` For a nicer way to register this handler, have a look at the :meth:`~hydrogram.Client.on_message` decorator. Parameters: callback (``Callable``): Pass a function that will be called when a new Message arrives. It takes *(client, message)* as positional arguments (look at the section below for a detailed description). filters (:obj:`Filters`): Pass one or more filters to allow only a subset of messages to be passed in your callback function. Other parameters: client (:obj:`~hydrogram.Client`): The Client itself, useful when you want to call other API methods inside the message handler. message (:obj:`~hydrogram.types.Message`): The received message. Ncallbackrcd||_t|j|dSN)original_callbacksuper__init__resolve_future_or_callback)selfrfilters __class__s b/var/www/html/auto_sub_bot/venv/lib/python3.11/site-packages/hydrogram/handlers/message_handler.pyrzMessageHandler.__init__7s.!) 8'BBBBBclienthydrogram.Clientmessager returntuple[bool, Listener | None]c K|j}|r|jnd}|r|jnd}t|dt|dd}t ||jj|jjg||g}||tj}d}|rc|j } t| rKt| j r| ||d{V}n&|j d| ||d{V}nd}||fS)a Checks if the message has a matching listener. Parameters: client (:obj:`~hydrogram.Client`): The Client object to check with. message (:obj:`~hydrogram.types.Message`): The Message object to check with. Returns: ``tuple``: A tuple of two elements, the first one is whether the message has a matching listener or not, the second one is the matching listener if exists. Nid message_id)r!chat_id from_user_idFT) from_userr usernamegetattrrchatget_listener_matching_with_datarMESSAGErcallabler__call__looprun_in_executor) rrr$r#from_user_usernamer!datalistenerlistener_does_matchrs rcheck_if_has_matching_listenerz-MessageHandler.check_if_has_matching_listener;sP$% '0:y||d 3<FY//$WdGG\4,P,PQQ !\_gl&;<&(:;    99$ @UVV#  +&G   +&w'788070H0H*H*H*H*H*H*H''06 0K0Kgvw11++++++'''+#"H,,rboolc<K|||d{Vd}t|jr_t|jjr|||d{V}n+|jd|j||d{V}nd}|p|S)a Checks if the message has a matching listener or handler and its filters does match with the Message. Parameters: client (:obj:`~hydrogram.Client`): The Client object to check with. message (:obj:`~hydrogram.types.Message`): The Message object to check with. Returns: ``bool``: Whether the message has a matching listener or handler and its filters does match with the Message. NrT)r2r*rrr+r,r-)rrrr1handler_does_matchs rcheckzMessageHandler.checkks&*%H%HQX%Y%YYYYYYY[\] DL ! ! &"4<#899 +/<<+H+H%H%H%H%H%H%H""+1;+F+F$,,,&&&&&&"""& #8&88rcK|||d{V\}}|r|r|||jr?|js&|j|t j|jrEt|jr|j||g|Rd{Vn|j||g|Rt jtd|j ||g|Rd{VdS)a Resolves the future or calls the callback of the listener if the message has a matching listener. Parameters: client (:obj:`~hydrogram.Client`): The Client object to resolve or call with. message (:obj:`~hydrogram.types.Message`): The Message object to resolve or call with. args (``tuple``): Arguments to call the callback with. Nz0Listener must have either a future or a callback) r2remove_listenerfuturedone set_result hydrogramStopPropagationrr ValueErrorr)rrrargsr1r0s rrz)MessageHandler.resolve_future_or_callbacksU/3.Q.QRXZa.b.b(b(b(b(b(b(b%X  Q+ Q  " "8 , , , 0x';';'='= 0**7333//  0&x'899>+(+FGCdCCCCCCCCCCC%H%fg=====//OPP P$d$VWrLs(#"""""''''''HHHHHHHHHHHHK=K=K=K=K=WK=K=K=K=K=r