jUdZddlmZddlZddlmZmZmZddlm Z m Z ddl m Z ddl mZeegedfZdaded <dd Zddd Zdd Zddd ZddZddZddZ ddZddZy)ufЛовля сообщений по ключевым словам — без команд панели.) annotationsN) AwaitableCallableOptional)TelegramClientevents)Channel)get_watch_settingszOptional[AlertSender] _send_alertc|ayN)r )fns ,/var/www/api.ozpay.ru/ozpay/catcher/watch.pyset_alert_senderrsKct|tr'ttt |j S||n t |dd}|ytt |}|jdr|ddSy)Nidz-100) isinstancer strabsintrgetattr startswith)chatmarked_chat_idmarkedraws r_internal_chat_idrsj$ 3s477|$%%-9^wtTSW?XF ~ c&k C ~~f12w rct|dd}| t|ddsyt|ddxs t|dd} t|}|dkDr|SdS#ttf$rYywxYw)Nreply_to forum_topicFreply_to_top_idreply_to_msg_idr)rr TypeError ValueError)messager!topics r _topic_idr)"s}w D1HwxF H/ 6 d'(L]_c:dEE AI5'4' z "s AA! A!c tt|ddxsd}|dkryt|ddxsdj}t|}|r|r d|d|d|Sd|d|St ||}|sy|r d|d|d|Sd|d|S)Nrrusernamez https://t.me//zhttps://t.me/c/)rrstripr)r)rr'r message_idr,r(internals r _message_linkr1.sWWdA.3!4JQj$/52<<>H g E "8*AeWAj\B Bxj*66 ~6H    !E7!J<@@ XJa | 44rc|j}g}|D]+}|j}|s||vs|j|-|Sr )casefoldappend)textkeywordshaystackfoundwordneedles r_match_keywordsr;@sI}}H E f( LL  Lrc n|yt|ddxsdj}t|ddxsdj}|xs>djdt|ddt|ddfDj}|r |r|d|d S|rd |S|r|St|d d}|r t|SdS) Nr+r,title c3$K|]}|r| ywr .0parts r z _sender_label..Os  first_name last_namez (@)@r)rr.joinr)senderr,r=name sender_ids r _sender_labelrNJs ~ D17R>>@H VWd + 1r 8 8 :E  CHH FL$ / FK .   eg  Ds8*A&&8*~  d+I&3y>.B.rctjt|jdxsd}tjt|jdxs|jdxsd}tjt|jdxsdj }tjt|jdxsddd}t|jd xsdj }d |d d |g}|r|j d |d}|j drHtj|d}|j d|j d|ddd|dddggi}|j d|j d|j |dj||fS)Nkeywordr+ chat_titlechat_iduчатrKr5i linkuc🔍 Ключевое слово: zuH📢 Чат: uH👤 Кто: zhttps://T)quoteuB🔗 Перейти к сообщениюinline_keyboardu$Перейти к сообщениюprimary5206222720416643915)r5urlstyleicon_custom_emoji_iduS🔔 Сообщение: )htmlescapergetr.r4rrJ) payloadrPrQwhobodyrSlinesmarkup safe_links rformat_watch_alertre_skk#gkk)4:;T!`X`abJ ++c'++h/526<<> ?C ;;s7;;v.4"5 6u =D w{{6"(b ) / / 1D mnumvv}~ RS]R^_ E  _`c_def F z"KKD1  R !{"S U >"(= "!   LL LLfg LL 99U V ##rc K|jry|jxsdj}|syt|}|j dsy|j d} |dvr t |nd}|rt||kDry|j dxsg}|j dxsg}|r|sy|Dchc]"}|j dt |d$} }|j} | | vry|j d} | dvr t | n t |} | | k(ry|j} | t| d d ryt||} | syt | t |jf}||vry|j|t|d kDr!|j|j||  |j!d{} | t| d d ry|j%d{}t|d dxs=d j'dt|ddt|ddfDxs t)| }t || dj'| | |t+| |t-||j.| d}t0yt1|d{y#t tf$rd}Y?wxYwcc}w#t tf$rt |} YwxYw7#t"$rd} YwxYw77Zw)Nr+enabled max_chars)Nr+r6chatsr alert_chat_idbotFir=r>c3$K|]}|r| ywr r@rAs rrDz'handle_watch_message..s5 5rErFrGz, ) owner_tg_idrjrPrRrQrKr5rS)outraw_textr.r r^rr%r&lenrRrKrr;raddclear get_sender Exceptionget_chatrJrrNr1r'r )eventrmseenr5settingsrhr6riitemwatchedrRalert_idrKmatchedkeyrr=r_s rhandle_watch_messager~s  yy NN b ' ' )D !+.H << " [)I&/z&AC Nt SY*||J'-2H LL ! 'RE 5+0O4DHHTN4Ns4:OGOmmGg||O,H$$,J$>3x=C DT( \\F gfeU;dH-G  w<UXX 'C d{HHSM 4y4    ~  ++--FgfeU;! !D D'4 ( CHH5 D, - D+t , 5-  W  ;'!99W%'dEMM7; G g u z " P z "${#$&. F  "&sAK3 J1AK35J4 J4$K3J9BK34KKK #K3/K/0B&K3K1K3J1-K30J11K39KK3KK3K K,(K3+K,,K31K3ct|ddryd|_|jtjddfd }y)N_catcher_watchFT)incomingc K t|d{y7#t$r1}tddt|jd|Yd}~yd}~wwxYww)Nzcatcher watch [z]: z: )r~rtprinttype__name__)rvexcrmrws ron_watchz)register_watch_handlers..on_watchsY Q&uk4@ @ @ Q OK=DI4F4F3Gr#O P P Qs6AA A'A AAA)rvevents.NewMessage.EventreturnNone)rronr NewMessage)clientrmrwrs `` rregister_watch_handlersrsCv'/ F YYv  $/0Q1Qr)r AlertSenderrrr )rz str | None)rz int | None)rr)r5rr6 list[str]rr)r_dictrztuple[str, Optional[dict]])rvrrmrrwset[tuple[int, int]]rr)rrrmrrwrrr)__doc__ __future__rr\typingrrrtelethonrrtelethon.tl.typesr dbr rrr __annotations__rrr)r1r;rNrer~rr@rrrsl" 00+%!vy./ %) ")  (5$/*$DJ "JJ J JZ Qr