o @MÆhêTã@sÐddlZddlZddlZddlmZmZmZmZmZm Z ddl Z ddl m Z ddl mZddlZddlZddlmZddlmZmZmZmZmZmZmZzddlZWn ey_ddlZYnwdZe  d¡Z!e "¡Z#gd ¢Z$gd ¢Z%gd ¢Z&Gd d „d ej'ƒZ(Gdd„dƒZ)Gdd„dƒZ*Gdd„dƒZ+dd„Z,de-de.fdd„Z/de-de e-dffdd„Z0de-de e-dffdd„Z1de-dej2de-fdd „Z3de-d!e4dee-fd"d#„Z5efde-d!e4dee-fd$d%„Z6de-dee-fd&d'„Z7dSd)ej8d*e.de-fd+d,„Z9dTd.ee-ee-effd/e4dej:fd0d1„Z;d2d3„Zd8d9„Z?dSd:d;„Z@dUd=e.d>eefd?d@„ZAdAdB„ZBdCdDœdEefdFdG„ZCdHe-dIe-fdJdK„ZDdHe-dIe-fdLdM„ZEde.fdNdO„ZFde e4dffdPdQ„ZGdRZHdS)VéN)ÚAnyÚCallableÚListÚDictÚOptionalÚUnion)Úsha256)Ú parse_qsl)Útypes)Ú is_pil_imageÚis_dictÚ is_stringÚis_bytesÚchunksÚgenerate_random_tokenÚpil_image_to_fileiÚTeleBot)ÚtextÚaudioÚdocumentÚ animationÚgameÚphotoÚstickerÚvideoÚ video_noteÚvoiceÚcontactÚlocationÚvenueÚdiceÚinvoiceÚsuccessful_paymentÚconnected_websiteÚpollÚ passport_dataÚ web_app_dataÚstoryÚgiveawayÚgiftÚ unique_gift))Únew_chat_membersÚleft_chat_memberÚnew_chat_titleÚnew_chat_photoÚdelete_chat_photoÚgroup_chat_createdÚsupergroup_chat_createdÚchannel_chat_createdÚmigrate_to_chat_idÚmigrate_from_chat_idÚpinned_messageÚproximity_alert_triggeredÚvideo_chat_scheduledÚvideo_chat_startedÚvideo_chat_endedÚvideo_chat_participants_invitedÚ!message_auto_delete_timer_changedÚchat_background_setÚforum_topic_createdÚforum_topic_closedÚforum_topic_reopenedÚforum_topic_editedÚgeneral_forum_topic_hiddenÚgeneral_forum_topic_unhiddenÚwrite_access_allowedÚ users_sharedÚ chat_sharedÚgiveaway_createdÚgiveaway_winnersÚgiveaway_completedÚ boost_addedÚpaid_message_price_changedÚchecklist_tasks_doneÚchecklist_tasks_addedÚdirect_message_price_changedÚsuggested_post_refundedÚsuggested_post_infoÚsuggested_post_approvedÚsuggested_post_approval_failedÚsuggested_post_declinedÚsuggested_post_paid)ÚmessageÚedited_messageÚ channel_postÚedited_channel_postÚ inline_queryÚchosen_inline_resultÚcallback_queryÚshipping_queryÚpre_checkout_queryr$Ú poll_answerÚmy_chat_memberÚ chat_memberÚchat_join_requestÚmessage_reactionÚmessage_reaction_countÚremoved_chat_boostÚ chat_boostÚbusiness_connectionÚbusiness_messageÚedited_business_messageÚdeleted_business_messagesÚpurchased_paid_mediac@sFeZdZdZdZddd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dS)Ú WorkerThreadú :meta private: rNcCs”|sd |jjd¡}|jjd7_|st ¡}tjj||d||_d|_t  ¡|_ t  ¡|_ t  ¡|_ t  ¡|_ ||_d|_d|_| ¡dS)NzWorkerThread{0}é)ÚnameT)ÚformatÚ __class__ÚcountÚQueueÚ threadingÚThreadÚ__init__ÚqueueÚdaemonÚEventÚreceived_task_eventÚ done_eventÚexception_eventÚcontinue_eventÚexception_callbackÚexception_infoÚ_runningÚstart)Úselfr|rurm©rú?/var/www/html/venv/lib/python3.10/site-packages/telebot/util.pyrtAs      zWorkerThread.__init__c Cs|jrŒz<|jjddd\}}}|j ¡|j ¡|j ¡|j ¡t  d¡|j  ¡||i|¤Žt  d¡|j  ¡WnGt j yIYn>t y†}z2t  t|ƒjdt|jƒdt ¡¡||_|j  ¡|jrw| ||j¡|j ¡WYd}~nd}~ww|jsdSdS)NTgà?)ÚblockÚtimeoutz Received taskz Task completez occurred, args=Ú )r~ruÚgetr{ÚclearrxryrzÚloggerÚdebugÚsetrqÚEmptyÚ ExceptionÚtypeÚ__name__ÚstrÚargsÚ tracebackÚ format_excr}r|Úwait)r€ÚtaskrÚkwargsÚerrr‚ÚrunVs0       * €úñzWorkerThread.runcOó|j |||f¡dS©N)ruÚput)r€r”rr•rrr‚ršnózWorkerThread.putcCó|j ¡r|j‚dSr™©rzÚis_setr}©r€rrr‚Úraise_exceptionsqó ÿzWorkerThread.raise_exceptionscCs|j ¡|j ¡dSr™)rzr‡r{rŠrŸrrr‚Úclear_exceptionsus zWorkerThread.clear_exceptionscCs d|_dS©NF)r~rŸrrr‚Ústopys zWorkerThread.stop)NNN) rŽÚ __module__Ú __qualname__Ú__doc__rprtr—ršr r¢r¤rrrr‚rj;s  rjc@sBeZdZdZddd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dS)Ú ThreadPoolrkécsB|ˆ_t ¡ˆ_‡fdd„t|ƒDƒˆ_|ˆ_t ¡ˆ_dˆ_ dS)Ncsg|] }tˆjˆjƒ‘qSr)rjÚ on_exceptionÚtasks)Ú.0Ú_rŸrr‚Ú …sz'ThreadPool.__init__..) Útelebotrqr«ÚrangeÚworkersÚ num_threadsrrrwrzr})r€r¯r²rrŸr‚rt‚s    zThreadPool.__init__cOr˜r™)r«rš)r€Úfuncrr•rrr‚rš‹r›zThreadPool.putcCsB|jjdur|jj |¡}nd}|s||_|j ¡|j ¡dSr£)r¯Úexception_handlerÚhandler}rzrŠr{)r€Ú worker_threadÚexc_infoÚhandledrrr‚rªŽs  zThreadPool.on_exceptioncCrœr™rrŸrrr‚r ˜r¡zThreadPool.raise_exceptionscCs|j ¡dSr™)rzr‡rŸrrr‚r¢œszThreadPool.clear_exceptionscCs8|jD]}| ¡q|jD] }|t ¡kr| ¡q dSr™)r±r¤rrÚcurrent_threadÚjoin)r€Úworkerrrr‚ÚcloseŸs    €þzThreadPool.closeN©r©) rŽr¥r¦r§rtršrªr r¢r¼rrrr‚r¨}s    r¨c@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú AsyncTaskrkcOs6||_||_||_d|_tj|jd|_|j ¡dS)NF)Útarget) r¿rr•ÚdonerrrsÚ_runÚthreadr)r€r¿rr•rrr‚rt¬s zAsyncTask.__init__c CsPz |j|ji|j¤Ž|_Wnty"}z ||_WYd}~nd}~wwd|_dS)NT)r¿rr•ÚresultrŒrÀ)r€r–rrr‚rÁµs€ÿ zAsyncTask._runcCs(|js|j ¡t|jtƒr|j‚|jSr™)rÀrÂrºÚ isinstancerÃÚ BaseExceptionrŸrrr‚r“¼s   zAsyncTask.waitN)rŽr¥r¦r§rtrÁr“rrrr‚r¾§s  r¾c@s"eZdZdZd dd„Zdd„ZdS) ÚCustomRequestResponserkéÈÚcCs||_||_||_dSr™)Ú status_coderÚreason)r€Ú json_textrÉrÊrrr‚rtÊs zCustomRequestResponse.__init__cCs t |j¡Sr™)ÚjsonÚloadsrrŸrrr‚rÌÏs zCustomRequestResponse.jsonN)rÇrÈ)rŽr¥r¦r§rtrÌrrrr‚rÆÅs  rÆcCs dd„}|S)rkcs‡fdd„}|S)Ncstˆg|¢Ri|¤ŽSr™)r¾)rr•©Úfnrr‚ÚwrapperÙr›z-async_dec..decorator..wrapperr)rÏrÐrrÎr‚Ú decoratorØs zasync_dec..decoratorr)rÑrrr‚Ú async_decÓsrÒrÚreturncCs|durdS| d¡S)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` NFú/)Ú startswith©rrrr‚Ú is_commandás r×cCs6|durdSt|ƒr| ¡d d¡ddd…SdS)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ú@rl)r×ÚsplitrÖrrr‚Úextract_commandïs *rÚcCs.t dtj¡}| |¡}t|ƒr| d¡SdS)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]*)r©N)ÚreÚcompileÚ IGNORECASEÚmatchr×Úgroup)rÚregexprÃrrr‚Úextract_argumentss rár–cCsŒd}d}| ¡}t|ƒ}d}|D]-}|d@dkr9||jkr |}n ||j|jkr,|}n|dkr5|d7}n|d7}|d7}q|||… ¡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` réÀé€éðr©rl)ÚencodeÚlenÚoffsetÚlengthÚdecode)rr–rçrÚ encoded_textÚendÚiÚbyterrr‚Úextract_entitys"     rîÚchars_per_stringcs ‡‡fdd„tdtˆƒˆƒDƒS)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` csg|] }ˆ||ˆ…‘qSrr)r¬rì©rïrrr‚r®Ksz split_string..r)r°ræ)rrïrrðr‚Ú split_string=s rñcsždtdtf‡fdd„ }|tkrt}g} t|ƒ|kr!| |¡|S|d|…‰dˆvr0|dƒ‰ndˆvr9|dƒ‰nd ˆvrA|d ƒ‰| ˆ¡|tˆƒd…}q) 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` ÚsubstrrÓcs| ˆ |¡dd…¡|S)Néÿÿÿÿ)rºrÙ)rò©Úpartrr‚Ú_text_before_last_sz&smart_split.._text_before_lastTNr…z. ú )rÚMAX_MESSAGE_LENGTHræÚappend)rrïröÚpartsrrôr‚Ú smart_splitNs"       ñrûcCs:ddddœ}|dur dS| ¡D] \}}| ||¡}q|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)ÚitemsÚreplace)rÚcharsÚoldÚnewrrr‚Úescapews rFÚuserÚ include_idcCs6t|jƒ}d|j›d|›d|rd|j›dSdS)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_nameÚid)rrrmrrr‚Ú user_link†s ÿÿr r©ÚvaluesÚ row_widthcCs,tj|d}dd„| ¡Dƒ}|j|Ž|S)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` )r cSs$g|]\}}tjdd|i|¤Ž‘qS)rr)r ÚInlineKeyboardButton)r¬rr•rrr‚r®Îsÿÿz quick_markup..)r ÚInlineKeyboardMarkuprÿÚadd)r r ÚmarkupÚbuttonsrrr‚Ú quick_markup¤s )þ rcCó| ¡| ¡dS©rkN)Ú_setÚchangedrŸrrr‚Úor_set×ó rcCrr)Ú_clearrrŸrrr‚Úor_clearßrrcsJtˆdƒs ˆjˆ_tˆdƒsˆjˆ_|ˆ_‡fdd„ˆ_‡fdd„ˆ_dS)rkrrcótˆƒSr™)rr©r–rr‚Úðózorify..crr™)rrrrr‚rñrN)ÚhasattrrŠrr‡rr)r–Úchanged_callbackrrr‚Úorifyçs  r csNt ¡‰‡‡fdd„}‡fdd„}ˆD]}t||ƒqˆjˆ_|ˆ_|ƒˆS)rkcs.dd„ˆDƒ}t|ƒrˆ ¡dSˆ ¡dS)NcSsg|]}| ¡‘qSr)rž)r¬Úevrrr‚r®ûsz,OrEvent..changed..)ÚanyrŠr‡)Úbools©ÚeventsÚor_eventrr‚rús  zOrEvent..changedcs"ˆ ¡sˆ d¡ˆ ¡rdSdS)Né)ržÚ_waitr)r&rr‚Ú busy_waits þzOrEvent..busy_wait)rrrwr r“r()r%rr)r–rr$r‚ÚOrEventôs  r*cCs*|stt|ƒs|ƒ}tt||ƒtt|ƒS)rk)rÚ thread_localÚsetattrÚgetattr)ÚkeyÚconstruct_valueÚresetÚvaluerrr‚Ú per_threads  r2TÚwarnÚ alternativecs‡‡‡fdd„}|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 cs‡‡‡‡fdd„}|S)Ncs\dˆj›d}ˆr|dˆj›d7}ˆr|dˆ7}ˆs"t |¡nt |¡ˆ|i|¤ŽS)Nú`z` is deprecated.z Use `z ` insteadr÷)rŽrˆÚinfoÚwarning)rr•r6)r4Údeprecation_textÚfunctionr3rr‚rÐ-s   z.deprecated..decorator..wrapperr)r9rЩr4r8r3)r9r‚rÑ,s zdeprecated..decoratorr)r3r4r8rÑrr:r‚Ú deprecatedsr;c Cs`|jr.z| ¡}tj |¡}| |g¡WdSty-}z t|ƒWYd}~dSd}~wwdS)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 rÈN)zBot FAILizBot ON)Úis_jsonÚget_jsonr ÚUpdateÚde_jsonÚprocess_new_updatesrŒÚprint)ÚbotÚrequestÚ request_jsonÚupdater–rrr‚Úwebhook_google_functions?s   €þrFé)Únumber_retriesr9c Osddlm}ddlm}t|dƒD].}z ||i|¤ŽWS|y@}z|jdkr5||jddƒn‚WYd}~qd}~ww||i|¤ŽS) 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 r)ÚApiTelegramException)Úsleeprli­Ú parametersÚ retry_afterN)Útelebot.apihelperrIÚtimerJr°Ú error_codeÚ result_json)r9rHrr•rIrJr­Úexrrr‚Ú antifloodXs    þ€þrRÚtokenÚ raw_init_datac Cs`t||ƒ}|s dSi}t|ƒD]\}}zt |¡}Wntjy(|||<Yqw|||<q|S)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 rÌrÍÚJSONDecodeError)rSrTÚis_validrÃr.r1rrr‚Úparse_web_app_data€s  ÿ rXcCsŠztt|ƒƒ}Wn tyYdSwd|vrdS| d¡}d dd„t| ¡ƒDƒ¡}tjd|  ¡t d}t |  ¡|  ¡t ¡  ¡|kS)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 FÚhashr…css"|] \}}|›d|›VqdS)ú=Nr)r¬r.r1rrr‚Ú ¯s€ z(validate_web_app_data..s WebAppData)r.ÚmsgÚ digestmod) Údictr Ú ValueErrorÚpoprºÚsortedrÿÚhmacrrårÚdigestÚ hexdigest)rSrTÚ parsed_dataÚinit_data_hashÚdata_check_stringÚ secret_keyrrr‚rU›s  ÿ rUcCsHtdd„|Dƒƒr tdƒ‚d|vrtdƒ‚t| d¡ƒdkr"tdƒ‚dS) Ncss|]}| ¡VqdSr™)Úisspace)r¬Úcharrrr‚r[¶s€z!validate_token..zToken must not contain spacesú:zToken must contain a colonr©z7Token must contain exactly 2 parts separated by a colonT)r"r_rærÙ©rSrrr‚Úvalidate_tokenµsrmcCs4zt|ƒWn tyYdSwt| d¡dƒS)Nrkr)rmr_ÚintrÙrlrrr‚Úextract_bot_idÁs   ÿro)"Úcontent_type_mediaÚcontent_type_serviceÚ update_typesrjr¾rÆrÒr;rr r r rrrr×rÚrárñrûrr rrRrXrUrrr r*r2rFrmro)Fr½)TNN)IrÛrrr‘ÚtypingrrrrrrrbÚhashlibrÚ urllib.parser rurqÚloggingr¯r Útelebot.service_utilsr r r rrrrÚujsonrÌÚ ImportErrorrøÚ getLoggerrˆÚlocalr+rprqrrrsrjr¨r¾rÆrÒrÚboolr×rÚráÚ MessageEntityrîrnrñrûrÚUserr r rrrr r*r2r;rFrRrXrUrmroÚ__all__rrrr‚Úsb    $   ÿ  B*")*3  &(