jH\^ddlZddlZddlZddlmZmZmZmZmZm Z ddl Z ddl m Z ddl mZddlZddlZddlmZddlmZmZmZmZmZmZmZ ddlZdZej@dZ!ejDZ#gd Z$gd Z%gd Z&Gd d ejNZ(GddZ)GddZ*GddZ+dZ,de-de.fdZ/de-de e-dffdZ0de-de e-dffdZ1de-dejdde-fdZ3de-de4dee-fdZ5efde-de4dee-fdZ6de-dee-fdZ7d;d ejpd!e.de-fd"Z9dd)Z?d;d*Z@d=d+e.d,eefd-ZAd.ZBd/d0d1efd2ZCd/d0d1efd3ZDd4e-d5e-fd6ZEd4e-d5e-fd7ZFde.fd8ZGde e4dffd9ZHd:ZIy#e$rddlZYYwxYw)>N)AnyCallableListDictOptionalUnion)sha256) parse_qsl)types) is_pil_imageis_dict is_stringis_byteschunksgenerate_random_tokenpil_image_to_fileiTeleBot)textaudiodocument animationgamephotostickervideo video_notevoicecontactlocationvenuediceinvoicesuccessful_paymentconnected_websitepoll passport_data web_app_datastorygiveawaygift unique_gift)1new_chat_membersleft_chat_membernew_chat_titlenew_chat_photodelete_chat_photogroup_chat_createdsupergroup_chat_createdchannel_chat_createdmigrate_to_chat_idmigrate_from_chat_idpinned_messageproximity_alert_triggeredvideo_chat_scheduledvideo_chat_startedvideo_chat_endedvideo_chat_participants_invited!message_auto_delete_timer_changedchat_background_setforum_topic_createdforum_topic_closedforum_topic_reopenedforum_topic_editedgeneral_forum_topic_hiddengeneral_forum_topic_unhiddenwrite_access_allowed users_shared chat_sharedgiveaway_createdgiveaway_winnersgiveaway_completed boost_addedpaid_message_price_changedchecklist_tasks_donechecklist_tasks_addeddirect_message_price_changedsuggested_post_refundedsuggested_post_infosuggested_post_approvedsuggested_post_approval_failedsuggested_post_declinedsuggested_post_paidgift_upgrade_sentchat_owner_leftchat_owner_changedmanaged_bot_createdpoll_option_addedpoll_option_deletedcommunity_chat_addedcommunity_chat_removed)messageedited_message channel_postedited_channel_post inline_querychosen_inline_resultcallback_queryshipping_querypre_checkout_queryr% poll_answermy_chat_member chat_memberchat_join_requestmessage_reactionmessage_reaction_countremoved_chat_boost chat_boostbusiness_connectionbusiness_messageedited_business_messagedeleted_business_messagespurchased_paid_media managed_bot guest_message subscriptionc:eZdZdZdZd dZdZdZdZdZ d Z y) WorkerThread :meta private: rNc2|sGdj|jjdz}|jxjdz c_|stj}tj j ||||_d|_t j|_ t j|_ t j|_ t j|_ ||_d|_d|_|j#y)NzWorkerThread{0})nameT)format __class__countQueue threadingThread__init__queuedaemonEventreceived_task_event done_eventexception_eventcontinue_eventexception_callbackexception_info_runningstart)selfrrr{s ?/var/www/html/venv/lib/python3.12/site-packages/telebot/util.pyrzWorkerThread.__init__Bs$++DNN,@,@1,DED NN A % KKME!!$T!2  #,??#4 #//+(0'oo/"4"  c|jr |jjdd\}}}|jj |j j |j j |jj tjd|j j||i|tjd|j j|jryy#tj$rY$t$r}tjt|jdzt!|j"zdzt%j&z||_|jj|j*r|j+||j(|jj-Yd}~d}~wwxYw)NTg?)blocktimeoutz Received taskz Task completez occurred, args= )rrgetrclearrrrloggerdebugsetrEmpty Exceptiontype__name__strargs traceback format_excrrwait)rtaskrkwargses rrunzWorkerThread.runWsnmm +%)ZZ^^$^%K"dF##))+((..0%%'$$**, _-((,,.d%f% _-##%mm;;  + T!W--0BBS[PSWWZcZnZnZppq&'#$$((***++D$2E2EF##((**  +sC/D G/!G/)B.decorator..wrappersR1$1&1 1rr)rrs` r decoratorzasync_dec..decorators 2rr)rs r async_decrs  rrreturnc*|y|jdS)z Checks if `text` is a command. Telegram chat commands start with the '/' character. :param text: Text to check. :type text: :obj:`str` :return: True if `text` is a command, else False. :rtype: :obj:`bool` F/) startswithrs r is_commandrs |E ??3 rcr|yt|r(|jdjddddSdS)av Extracts the command from `text` (minus the '/') if `text` is a command (see is_command). If `text` is not a command, this function returns None. .. code-block:: python3 :caption: Examples: extract_command('/help'): 'help' extract_command('/help@BotName'): 'help' extract_command('/search black eyed peas'): 'search' extract_command('Good day to you'): None :param text: String to extract the command from :type text: :obj:`str` :return: the command if `text` is a command (according to is_command), else None. :rtype: :obj:`str` or :obj:`None` Nr@rz)rsplitrs rextract_commandrs>& |D0:40@4::<?  %a ( ,JdJrctjdtj}|j|}t |r|j dSdS)a Returns the argument after the command. .. code-block:: python3 :caption: Examples: extract_arguments("/get name"): 'name' extract_arguments("/get"): '' extract_arguments("/get@botName name"): 'name' :param text: String to extract the arguments from a command :type text: :obj:`str` :return: the arguments if `text` is a command (according to is_command), else None. :rtype: :obj:`str` or :obj:`None` z/\w*(@\w*)*\s*([\s\S]*)rN)recompile IGNORECASEmatchrgroup)rregexprs rextract_argumentsrsA"ZZ2BMM BF \\$ F(.6<<?8D8rrcd}d}|j}t|}d}|D]Q}|dzdk7rB||jk(r|}n ||jz |jk(r|}n|dk\r|dz }n|dz }|dz }S|||j S)a Returns the content of the entity. :param text: The text of the message the entity belongs to :type text: :obj:`str` :param e: The entity to extract :type e: :obj:`MessageEntity` :return: The content of the entity :rtype: :obj:`str` rrrz)encodelenoffsetlengthdecode)rrr r encoded_textendibytes rextract_entityrsF E;;=L l C A  4KD !!(("ahh.t|! !  Q  c " ) ) ++rchars_per_stringc`tdt||Dcgc] }||||z c}Scc}w)a Splits one string into multiple strings, with a maximum amount of `chars_per_string` characters per string. This is very useful for splitting one giant message into multiples. :param text: The text to split :type text: :obj:`str` :param chars_per_string: The number of characters per line the text is split into. :type chars_per_string: :obj:`int` :return: The splitted text as a list of strings. :rtype: :obj:`list` of :obj:`str` r)rr )rrrs r split_stringr>s3383t9FV2W XQD1'' ( XX Xs+c$dtdtffd }|tkDrt}g} t||kr|j||S|d|dvr |dndvr |dn dvr|d|j|td}l)aT Splits one string into multiple strings, with a maximum amount of `chars_per_string` characters per string. This is very useful for splitting one giant message into multiples. If `chars_per_string` > 4096: `chars_per_string` = 4096. Splits by '\n', '. ' or ' ' in exactly this priority. :param text: The text to split :type text: :obj:`str` :param chars_per_string: The number of maximum characters per part the text is split to. :type chars_per_string: :obj:`int` :return: The splitted text as a list of strings. :rtype: :obj:`list` of :obj:`str` substrrcP|jj|dd|zS)N)rr)rparts r_text_before_lastz&smart_split.._text_before_last`s'{{4::f-cr23f< E  t9' ' LL L%%& 4<$T*D T\$T*D D[$S)D TCIJ rcldddd}|y|jD]\}}|j||}|S)z Replaces the following chars in `text` ('&' with '&', '<' with '<' and '>' with '>'). :param text: the text to escape :return: the escaped text z&z<z>)&<>N)itemsreplace)rcharsoldnews rescaper*xsFV 4E |KKM&S||C%& Kruser include_idct|j}d|jd|d|rd|jdzSdzS)a Returns an HTML user link. This is useful for reports. Attention: Don't forget to set parse_mode to 'HTML'! .. code-block:: python3 :caption: Example: bot.send_message(your_user_id, user_link(message.from_user) + ' started the bot!', parse_mode='HTML') .. note:: You can use formatting.* for all other formatting options(bold, italic, links, and etc.) This method is kept for backward compatibility, and it is recommended to use formatting.* for more options. :param user: the user (not the user_id) :type user: :obj:`telebot.types.User` :param include_id: include the user_id :type include_id: :obj:`bool` :return: HTML user link :rtype: :obj:`str` zzz (
z
)r)r* first_nameid)r+r,r{s r user_linkr0sU2 $// "D$TWWIRvT :-7 ) AB=? ABrvalues row_widthc tj|}|jDcgc]\}}tjdd|i|}}}|j||Scc}}w)aK Returns a reply markup from a dict in this format: {'text': kwargs} This is useful to avoid always typing 'btn1 = InlineKeyboardButton(...)' 'btn2 = InlineKeyboardButton(...)' Example: .. code-block:: python3 :caption: Using quick_markup: from telebot.util import quick_markup markup = quick_markup({ 'Twitter': {'url': 'https://twitter.com'}, 'Facebook': {'url': 'https://facebook.com'}, 'Back': {'callback_data': 'whatever'} }, row_width=2) # returns an InlineKeyboardMarkup with two buttons in a row, one leading to Twitter, the other to facebook # and a back button below # kwargs can be: { 'url': None, 'callback_data': None, 'switch_inline_query': None, 'switch_inline_query_current_chat': None, 'callback_game': None, 'pay': None, 'login_url': None, 'web_app': None } :param values: a dict containing all buttons to create in this format: {text: kwargs} {str:} :type values: :obj:`dict` :param row_width: number of :class:`telebot.types.InlineKeyboardButton` objects on each row :type row_width: :obj:`int` :return: InlineKeyboardMarkup :rtype: :obj:`types.InlineKeyboardMarkup` )r2rr)r InlineKeyboardMarkupr%InlineKeyboardButtonadd)r1r2markuprrbuttonss r quick_markupr9skR ' ') s IIKLLNrcD|j|jyr;)_clearr=rs ror_clearrAs KKMLLNrctdsj_tdsj_|_fd_fd_y)rxr<r@ctSr)r>rsrzorify..s F1IrctSr)rArDsrrEzorify..s hqkrN)hasattrrr<rr@r=)rchanged_callbacks` rorifyrIsD 1f  1h 77 AI AE!AGrctjfd}fd}D]}t||j_|_|S)rxcDcgc]}|j}}t|rjyjycc}wr)ranyrr)evboolseventsor_events rr=zOrEvent..changeds;'-... u: LLN NN  /sA cljs#jdjs"yy)N)r_wait)rPsr busy_waitzOrEvent..busy_waits%//# NN1 //#r)rrrIrrS)rOr=rTrrPs` @rOrEventrUsR H  a]]HNHM I Orcv|stt|s|}tt||tt|S)rx)rG thread_localsetattrgetattr)keyconstruct_valueresetvalues r per_threadr^s1 GL#.! c5) < %%rwarn alternativecfd}|S)a Use this decorator to mark functions as deprecated. When the function is used, an info (or warning if `warn` is True) is logged. :meta private: :param warn: If True a warning is logged else an info :type warn: :obj:`bool` :param alternative: The new function to use instead :type alternative: :obj:`Callable` :param deprecation_text: Custom deprecation text :type deprecation_text: :obj:`str` :return: The decorated function cfd}|S)Ncdjd}r|djdz }r|dzz }stj|ntj||i|S)N`z` is deprecated.z Use `z ` insteadr)rrinfowarning)rrrer`deprecation_textfunctionr_s rrz.deprecated..decorator..wrapper.stx(())9:D&!5!5 6i@@... D!t$T,V, ,rr)rhrr`rgr_s` rrzdeprecated..decorator-s -rr)r_r`rgrs``` r deprecatedris&  rc|jrC |j}tjj |}|j |gyy#t $r}t|Yd}~yd}~wwxYw)a( A webhook endpoint for Google Cloud Functions FaaS. :param bot: The bot instance :type bot: :obj:`telebot.TeleBot` or :obj:`telebot.async_telebot.AsyncTeleBot` :param request: The request object :type request: :obj:`flask.Request` :return: The response object rN)zBot FAILizBot ON)is_jsonget_jsonr Updatede_jsonprocess_new_updatesrprint)botrequest request_jsonupdaters rwebhook_google_functionsru@sf #"++-L\\)),7F  # #VH -   # !H" #sAA A/ A**A/)number_retriesrhcddlm}ddlm}t |dz D] } ||i|cS||i|S#|$r3}|j dk(r||j ddnYd}~Jd}~wwxYw) a Use this function inside loops in order to avoid getting TooManyRequests error. Example: .. code-block:: python3 from telebot.util import antiflood for chat_id in chat_id_list: msg = antiflood(bot.send_message, chat_id, text) :param function: The function to call :type function: :obj:`Callable` :param number_retries: Number of retries to send :type function: :obj:int :param args: The arguments to pass to the function :type args: :obj:`tuple` :param kwargs: The keyword arguments to pass to the function :type kwargs: :obj:`dict` :return: None rApiTelegramException)sleeprz parameters retry_afterN)telebot.apihelperrztimer{r error_code result_json)rhrwrrrzr{rexs r antifloodrYs27 >A% & ) T,V, , )((( $ }}#bnn\2=ABC s2A*)A%%A*c*Kddlm}ddl}t|dz D]} ||i|d{cS||i|d{S7#|$rE}|jdk(r+|j |j ddd{7nYd}~nd}~wwxYw7Sw)aZ Async counterpart to :func:`antiflood`. Awaits ``function(*args, **kwargs)`` in a retry loop that honours Telegram's ``retry_after`` parameter on 429 responses. Use with :obj:`telebot.async_telebot.AsyncTeleBot` calls. Example: .. code-block:: python3 from telebot.util import async_antiflood for chat_id in chat_id_list: msg = await async_antiflood(bot.send_message, chat_id, text) :param function: The awaitable callable to invoke. Called fresh on each attempt, so pass the function itself (for example ``bot.send_message``), not a pre-awaited coroutine. :type function: :obj:`Callable` :param number_retries: Total number of attempts. After ``number_retries - 1`` retried 429 responses the final call is issued without the 429 guard, so its exception will propagate. :type number_retries: :obj:`int` :param args: Positional arguments forwarded to ``function``. :param kwargs: Keyword arguments forwarded to ``function``. :return: Whatever ``function`` returns on the first successful call. rryNrzr|r}r~)telebot.asyncio_helperrzasynciorrr{r)rhrwrrrzrrrs rasync_antifloodrs<< >A% & !42622 24*6* ** 3# }}#mmBNN<$@$OPPPQ  +sSB AAABBBAB 3B <A?=B B BBtoken raw_init_datact||}|syi}t|D] \}} tj|}|||<"|S#tj$r|||<Y?wxYw)z Parses web app data. :param token: The bot token :type token: :obj:`str` :param raw_init_data: The raw init data :type raw_init_data: :obj:`str` :return: The parsed init data F)validate_web_app_datar rrJSONDecodeError)rris_validrrZr]s rparse_web_app_datarsx%UM:H  F . U JJu%E F3K   M ## F3K sAAAc tt|}d|vry|jd}dj dt |j D}tjd|jt}tj|j|jtj|k(S#t$rYywxYw)z Validates web app data. :param token: The bot token :type token: :obj:`str` :param raw_init_data: The raw init data :type raw_init_data: :obj:`str` :return: The parsed init data Fhashrc30K|]\}}|d|yw)=Nr).0rZr]s r z(validate_web_app_data..s!azsESE5'"2!ass WebAppData)rZmsg digestmod) dictr ValueErrorpoprsortedr%hmacr)r r digest hexdigest)rr parsed_datainit_data_hashdata_check_string secret_keys rrrs9]34 [  __V,N !aVKL]L]L_E`!aam6RJ 88J%%'):)A)A)CV L V V X\j jj sC CCctd|Dr tdd|vr tdt|jddk7r tdy)Nc3<K|]}|jywr)isspace)rchars rrz!validate_token..s ,d4<<> ,szToken must not contain spaces:zToken must contain a colonrz7Token must contain exactly 2 parts separated by a colonT)rLrr rrs rvalidate_tokenrsU ,e ,,899 %566 5;;s !RSS rcr t|t|jddS#t$rYywxYw)Nrr)rrintrrs rextract_bot_idrs>u u{{3" ## s * 66)#content_type_mediacontent_type_service update_typesrwrrrrirrr r rrrrrrrr r*r0r9rrrrr>rArIrUr^rurr)Fr)TNN)Jrrrtypingrrrrrrrhashlibr urllib.parser rrloggingrr telebot.service_utilsr r rrrrrujsonr ImportErrorr getLoggerrlocalrWrrrrrwrrrrrboolrrr MessageEntityrrrr r*Userr0r4r9r>rArIrUr^rirurrrrrr__all__rrrrs == "~~~   9 %y   ?9##?D''T< % %   S  T  K#K%T "2K.9C9E#t)$49* , ,!4!4 , ,DYsYcYd3iY"4F& c& S& $s)& R  # BEJJBDBSB12/s/5KeKe/f "4&"T"x/A"L29:%)%)PEF)+H)+Xc#6kkSk4 T $U39-$ GsF F,+F,