a fi#@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|dur*|dur*| }n6|durB|durB| }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|]}|duo| VqdSN.0xrrO/home/ec2-user/.local/lib/python3.9/site-packages/telethon/events/newmessage.py Dz&NewMessage.__init__..zNDon't create an event handler if you don't want neither incoming nor outgoing!)r r matchzInvalid pattern type givencss|]}|duVqdSrrrrrrrWr)all ValueErrorsuper__init__r rrr isinstancestrrecompilerrcallablehasattr TypeErrorchatsr _no_check) selfr&r r r rrrr __class__rrr;s0    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/r0r1r3r2r4r5r6r7r8r9r:)rr ZUpdateNewMessageZUpdateNewChannelMessager4MessageEventZUpdateShortMessager-r.r/r0r1ZPeerUserZuser_idr5r6r7r8r9r:ZUpdateShortChatMessager3ZPeerChatZchat_id)clsupdateZothersself_ideventrrrbuild`sT      zNewMessage.buildcs|jr |S|jr|jjrdS|jr.|jjs.dS|jdurRt|jt|jjkrRdS|jdurn|jj |jvrndS|j r| |jjpd}|sdS||_ t |S)N)r'r r4r-rrboolr6rZ sender_idr pattern_matchrfilter)r(r@rr)rrrEs$  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__rrr2r1rCpostrDr4)r(r4r)rrrs    zNewMessage.Event.__init__cs0t||j}|||jdd|jd<dS)NTrF)r _set_clientr4Z _finish_initZ _entitiesrH)r(r,mr)rrrJs zNewMessage.Event._set_clientcCs$||jvr|j|St|j|SdSr)rHgetattrr4)r(itemrrr __getattr__s  zNewMessage.Event.__getattr__cCs2|jdr||jvr ||j|<nt|j||dS)NrF)rHsetattrr4)r(namevaluerrr __setattr__s zNewMessage.Event.__setattr__) __name__ __module__ __qualname____doc__rrJrNrR __classcell__rrr)rr<s   r<)N)NN) rSrTrUrVrr+ classmethodrArErr<rWrrr)rr s1!  - r ) r!commonrrrrrBrtlr r rrrrs