o -jG@sPddlmZddlmZddlZddlmZmZddlm Z Gddde Z dS) )iscoroutinefunction)CallableN)Message Identifier)Handlercs^eZdZdZddeffdd Zdddefd d Zdddefd d Zdddefd dZ Z S)MessageHandleraThe Message handler class. Used to handle new messages. It is intended to be used with :meth:`~pyrogram.Client.add_handler` For a nicer way to register this handler, have a look at the :meth:`~pyrogram.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:`~pyrogram.Client`): The Client itself, useful when you want to call other API methods inside the message handler. message (:obj:`~pyrogram.types.Message`): The received message. Ncallbackcs||_t|j|dSN)original_callbacksuper__init__resolve_future_or_callback)selfr filters __class__^/var/www/kodo/Anonymous/send/lib/python3.10/site-packages/pyrogram/handlers/message_handler.pyr 4szMessageHandler.__init__clientzpyrogram.Clientmessagecs|j}|r |jnd}|r|jnd}|j}|r|jnd}|r!|jnd}t|dt|dd} t| ||g||gd} || tjj j } d} | ro| j } t | rmt | jr]| ||IdH} | | fS|jd| ||IdH} | | fSd} | | fS)aJ Checks if the message has a matching listener. :param client: The Client object to check with. :param message: The Message object to check with. :return: A tuple of whether the message has a matching listener and its filters does match with the Message and the matching listener; Nid message_id)rchat_id from_user_idFT)chatrusername from_usergetattrrget_listener_matching_with_datapyrogramenums ListenerTypesMESSAGErcallabler__call__looprun_in_executor)rrrrr chat_usernamerrfrom_user_usernamerdatalistenerlistener_does_matchrrrrcheck_if_has_matching_listener8s6   z-MessageHandler.check_if_has_matching_listenercsj|||IdHd}t|jr/t|jjr!|||IdH}n|jd|j||IdH}nd}|p4|S)aW Checks if the message has a matching listener or handler and its filters does match with the Message. :param client: Client object to check with. :param message: Message object to check with. :return: Whether the message has a matching listener or handler and its filters does match with the Message. NrT)r-r$rrr%r&r')rrrr,handler_does_matchrrrcheckbs     zMessageHandler.checkcs|||IdH\}}|rO|rO|||jr&|js&|j|tj|jrKt|jr>|j||g|RIdHtj|j||g|Rtjt d|j ||g|RIdHdS)aB Resolves the future or calls the callback of the listener if the message has a matching listener. :param client: Client object to resolve or call with. :param message: Message object to resolve or call with. :param args: Arguments to call the callback with. :return: None Nz0Listener must have either a future or a callback) r-remove_listenerfuturedone set_resultr StopPropagationr r ValueErrorr )rrrargsr,r+rrrr|s"    z)MessageHandler.resolve_future_or_callbackr ) __name__ __module__ __qualname____doc__rr rr-r/r __classcell__rrrrrs *r) inspectrtypingrr pyrogram.typesrrhandlerrrrrrrs