o Xzj#@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 |r d}}n'|dur|dur| }n|dur!|dur!| }ntdd||fDr0tdtj|||d||_||_||_||_t|t rRt |j |_ n|rXt|r\||_ nt|drkt|j rk|j |_ ntdtdd|j|j|j|j |j|j|j|jfD|_dS)Ncss|] }|duo | VqdSN.0xrrU/var/www/kodo/tsheker/venv/lib/python3.10/site-packages/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|]}|duVqdSrrrrrrrWs)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|tjtjfrt|jtjsdS||j}|St|tjrQ|tj|j|j |j |j |j t |jt |jr:|n|j|j|j|j|j|j|j|jd}|St|tjr|tj|j|j |j |j |j t |jrl|n|jt|j|j|j|j|j|j|j|jd}|SdS)N)out mentioned media_unreadsilentidpeer_idfrom_idmessagedatefwd_from via_bot_idreply_toentities ttl_period)r,r-r.r/r0r2r1r3r4r5r6r7r8r9)rr UpdateNewMessageUpdateNewChannelMessager3MessageEventUpdateShortMessager,r-r.r/r0PeerUseruser_idr4r5r6r7r8r9UpdateShortChatMessager2PeerChatchat_id)clsupdateothersself_ideventrrrbuild`sX  &  $  zNewMessage.buildcs|jr|S|jr|jjrdS|jr|jjsdS|jdur)t|jt|jjkr)dS|jdur7|jj |jvr7dS|j rJ| |jjpAd}|sGdS||_ t |S)N)r&r r3r,rrboolr5r sender_idr pattern_matchrfilter)r'rHrr(rrrNs$   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) chat_peermsg_id broadcast) __dict__rrr1r0rKpostrMr3)r'r3r(rrrs    zNewMessage.Event.__init__cs0t||j}|||jdd|jd<dS)NTrO)r _set_clientr3 _finish_init _entitiesrS)r'r+mr(rrrUs zNewMessage.Event._set_clientcCs ||jvr |j|St|j|Sr)rSgetattrr3)r'itemrrr __getattr__s   zNewMessage.Event.__getattr__cCs4|jdr ||jvr||j|<dSt|j||dS)NrO)rSsetattrr3)r'namevaluerrr __setattr__szNewMessage.Event.__setattr__) __name__ __module__ __qualname____doc__rrUr[r_ __classcell__rrr(rr=s  r=r)NN) r`rarbrcrr* classmethodrIrNrr=rdrrr(rr s1 !  -r ) r commonrrrrrJrtlr r rrrrs