U h#@sPddlZddlmZmZmZmZddlmZddlm Z eGdddeZ dS) N) EventBuilder EventCommonname_inner_event _into_id_set)utils)typesc sjeZdZdZdddddddddfdd ZfddZedd d Zfd d ZGd dde Z Z S) NewMessagea Occurs whenever a new text message or a message with media arrives. Args: incoming (`bool`, optional): If set to `True`, only **incoming** messages will be handled. Mutually exclusive with ``outgoing`` (can only set one of either). outgoing (`bool`, optional): If set to `True`, only **outgoing** messages will be handled. Mutually exclusive with ``incoming`` (can only set one of either). from_users (`entity`, optional): Unlike `chats`, this parameter filters the *senders* of the message. That is, only messages *sent by these users* will be handled. Use `chats` if you want private messages with this/these users. `from_users` lets you filter by messages sent by *one or more* users across the desired chats (doesn't need a list). forwards (`bool`, optional): Whether forwarded messages should be handled or not. By default, both forwarded and normal messages are included. If it's `True` *only* forwards will be handled. If it's `False` only messages that are *not* forwards will be handled. pattern (`str`, `callable`, `Pattern`, optional): If set, only messages matching this pattern will be handled. You can specify a regex-like string which will be matched against the message, a callable function that returns `True` if a message is acceptable, or a compiled regex pattern. Example .. code-block:: python import asyncio from telethon import events @client.on(events.NewMessage(pattern='(?i)hello.+')) async def handler(event): # Respond whenever someone says "Hello" and something else await event.reply('Hey!') @client.on(events.NewMessage(outgoing=True, pattern='!ping')) async def handler(event): # Say "!pong" whenever you send "!ping", then delete both messages m = await event.respond('!pong') await asyncio.sleep(5) await client.delete_messages(event.chat_id, [event.id, m.id]) NF)blacklist_chatsfuncincomingoutgoing from_usersforwardspatternc s|r|rd}}nN|dk r*|dkr*| }n6|dk rB|dkrB| }ntdd||fDr`tdtj|||d||_||_||_||_t|t rt |j |_ n:|rt|r||_ n&t|drt|j r|j |_ ntdtdd|j|j|j|j |j|j|j|jfD|_dS)Ncss|]}|dk o| VqdSN.0xrr>/tmp/pip-unpacked-wheel-c81u5j2r/telethon/events/newmessage.py Dsz&NewMessage.__init__..zNDon't create an event handler if you don't want neither incoming nor outgoing!)r r matchzInvalid pattern type givencss|]}|dkVqdSrrrrrrrWs)all ValueErrorsuper__init__r rrr isinstancestrrecompilerrcallablehasattr TypeErrorchatsr _no_check) selfr%r r r rrrr __class__rrr;s<    zNewMessage.__init__cs*t|IdHt||jIdH|_dSr)r_resolverr)r'clientr(rrr*\szNewMessage._resolvecCst|tjtjfr2t|jtjs$dS||j}nt|tjr|tj|j|j |j |j |j t |jt |jrr|n|j|j|j|j|j|j|j|jd}nrt|tjr |tj|j|j |j |j |j t |jr|n|jt|j|j|j|j|j|j|j|jd}ndS|S)N)out mentioned media_unreadsilentidpeer_idfrom_idmessagedatefwd_from via_bot_idreply_toentities ttl_period)r,r-r.r/r0r2r1r3r4r5r6r7r8r9)rr ZUpdateNewMessageZUpdateNewChannelMessager3MessageEventZUpdateShortMessager,r-r.r/r0ZPeerUserZuser_idr4r5r6r7r8r9ZUpdateShortChatMessager2ZPeerChatZchat_id)clsupdateZothersself_ideventrrrbuild`sT      zNewMessage.buildcs|jr |S|jr|jjrdS|jr.|jjs.dS|jdk rRt|jt|jjkrRdS|jdk rn|jj |jkrndS|j r| |jjpd}|sdS||_ t |S)N)r&r r3r,rrboolr5rZ sender_idr pattern_matchrfilter)r'r?rr(rrrDs$  zNewMessage.filtercs<eZdZdZfddZfddZddZdd ZZS) zNewMessage.Eventa Represents the event of a new message. This event can be treated to all effects as a `Message `, so please **refer to its documentation** to know what you can do with this event. Members: message (`Message `): This is the only difference with the received `Message `, and will return the `telethon.tl.custom.message.Message` itself, not the text. See `Message ` for the rest of available members and methods. pattern_match (`obj`): The resulting object from calling the passed ``pattern`` function. Here's an example using a string (defaults to regex match): >>> from telethon import TelegramClient, events >>> client = TelegramClient(...) >>> >>> @client.on(events.NewMessage(pattern=r'hi (\w+)!')) ... async def handler(event): ... # In this case, the result is a ``Match`` object ... # since the `str` pattern was converted into ... # the ``re.compile(pattern).match`` function. ... print('Welcomed', event.pattern_match.group(1)) ... >>> cs6d|jd<tj|j|jt|jdd|_||_dS)NF_init)Z chat_peerZmsg_id broadcast) __dict__rrr1r0rBpostrCr3)r'r3r(rrrs  zNewMessage.Event.__init__cs0t||j}|||jdd|jd<dS)NTrE)r _set_clientr3Z _finish_initZ _entitiesrG)r'r+mr(rrrIs zNewMessage.Event._set_clientcCs$||jkr|j|St|j|SdSr)rGgetattrr3)r'itemrrr __getattr__s  zNewMessage.Event.__getattr__cCs2|jdr||jkr ||j|<nt|j||dS)NrE)rGsetattrr3)r'namevaluerrr __setattr__s zNewMessage.Event.__setattr__) __name__ __module__ __qualname____doc__rrIrMrQ __classcell__rrr(rr;s   r;)N)NN) rRrSrTrUrr* classmethodr@rDrr;rVrrr(rr s1!  - r ) r commonrrrrrArtlr r rrrrs