o HEDi 8@sddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddlm Z m Z m Z m Z mZddlZddlZddlmZddlmZddlmZmZdd lmZmZdd lmZdd lmZdd lmZGd ddZ dS)N) ContextVar)DictListOptionalUnionType)sentinel)api)TelegramAPIServerTELEGRAM_PRODUCTION) ParseModebase)json)check_integrity) deprecatedc@sHeZdZdZedZedZdddddddddef dej de e e j e jfde ejd e ej d e ejd e ejd ej ej d e ejde ejdej ej ejejejfdefddZdejfddZede e jfddZde ejfddZeedddde ejfddZedej ej ejejejfdej ejfd d!Z ed"d#Z!e!j"d$d#Z!e!j#d%d#Z!e$j%dej ejejejffd&d'Z&ed(d)Z'e'j"d*d)Z'e$j%dRd+ej d e ejfd,d-Z(ed.dd/d0d1Z)  dSd2ej d3e e*d4e e*de e+e*ejffd5d6Z,de-d7dddfd8ej d9e e ej.e/j0fde ejd:e ejd;e ejdd?Z5d@dAZ6de e*ejffdBdCZ7edDdEZ8e8j"dFdEZ8e8j#dGdEZ8edHdIZ9e9j"dJdIZ9e9j#dKdIZ9edLdMZ:e:j"dNdMZ:e:j#dOdMZ:dPdQZ;dS)TBaseBotz+ Base class for bot. It's raw bot. TelegramRequestTimeoutBotDifferentTokenNTtokenloopconnections_limitproxy proxy_authvalidate_token parse_modedisable_web_page_previewprotect_contenttimeoutserverc Cs ||_|r t|d|_||_t|jddd|_| |_||_ ||_ t j t d} d|_tj|_t|| d|_t|tr|dsI|drdd lm} dd lm}||\}}}}}|rj|se|j}|sj|j}| |_|jj|||||d d d|_ d|_ d|_| |_ ||_!||_"| |_#dS) a Instructions how to get Bot token is found here: https://core.telegram.org/bots#3-how-do-i-create-a-bot :param token: token from @BotFather :type token: :obj:`str` :param loop: event loop :type loop: Optional Union :obj:`asyncio.BaseEventLoop`, :obj:`asyncio.AbstractEventLoop` :param connections_limit: connections limit for aiohttp.ClientSession :type connections_limit: :obj:`int` :param proxy: HTTP proxy URL :type proxy: :obj:`str` :param proxy_auth: Authentication information :type proxy_auth: Optional :obj:`aiohttp.BasicAuth` :param validate_token: Validate token. :type validate_token: :obj:`bool` :param parse_mode: You can set default parse mode :type parse_mode: :obj:`str` :param disable_web_page_preview: You can set default disable web page preview parameter :type disable_web_page_preview: :obj:`bool` :param protect_content: Protects the contents of sent messages from forwarding and saving :type protect_content: :obj:`typing.Optional[base.Boolean]` :param timeout: Request timeout :type timeout: :obj:`typing.Optional[typing.Union[base.Integer, base.Float, aiohttp.ClientTimeout]]` :param server: Telegram Bot API Server endpoint. :type server: :obj:`TelegramAPIServer` :raise: when token is invalid throw an :obj:`aiogram.utils.exceptions.ValidationError` N:)sepr)cafile)limitsslz socks5://z socks4://)SocksConnector)parse_proxy_urlT) socks_verhostportusernamepasswordrdns)$ _main_loopr check_token_token_BaseBot__tokenintsplitidr rrr%create_default_contextcertifiwhere_sessionaiohttp TCPConnector_connector_classdict_connector_init isinstancestr startswith aiohttp_socksr&aiohttp_socks.utilsr'loginr,update_timeoutrrrr)selfrrrrrrrrrrr ssl_contextr&r'r(r)r*r+r,rH_/var/www/www-root/data/www/ovozai.pdev.uz/venv/lib/python3.10/site-packages/aiogram/bot/base.py__init__sD*    zBaseBot.__init__returncs tj|jdi|jtjdS)N) connectorjson_serializerH)r9 ClientSessionr;r=rdumpsrFrHrHrIget_new_sessionxs zBaseBot.get_new_sessioncC|jSN)r.rPrHrHrIr~sz BaseBot.loopcsV|jdus |jjr|IdH|_|jjs(|jIdH|IdH|_|jSrS)r8closedrQ_loop is_runningcloserPrHrHrI get_sessions zBaseBot.get_sessionz]Client session should be created inside async function, use `await bot.get_session()` instead)reason stacklevelcCrRrS)r8rPrHrHrIsessionszBaseBot.sessionvaluecCs$|dus t|tjr |Stj|dS)N)total)r>r9 ClientTimeout)r]rHrHrI_prepare_timeouts zBaseBot._prepare_timeoutcCs|j|j}|dur tS|SrS) _ctx_timeoutgetrEr)rFrrHrHrIrszBaseBot.timeoutcCs|||_dSrS)r`rErFr]rHrHrIrscC d|_dSrS)rrPrHrHrIr c cs@||}|j|}z dVW|j|dS|j|w)a  Context manager implements opportunity to change request timeout in current context :param timeout: Request timeout :type timeout: :obj:`typing.Optional[typing.Union[base.Integer, base.Float, aiohttp.ClientTimeout]]` :return: N)r`rasetreset)rFrrrHrHrIrequest_timeouts  zBaseBot.request_timeoutcCs|j|jSrS) _ctx_tokenrbr0rPrHrHrI__tokenszBaseBot.__tokencCs ||_dSrS)r0rcrHrHrIrjre bot_tokenc csD|rt||j|}z dVW|j|dS|j|wrS)r r/rirfrg)rFrkrrrHrHrI with_tokens  zBaseBot.with_tokenzkThis method's behavior will be changed in aiogram v3.0. More info: https://core.telegram.org/bots/api#closer[cs |jr|jIdHdSdS)z+ Close all client sessions N)r8rWrPrHrHrIrWsz BaseBot.closemethoddatafilescs@tj|IdH|j|j|||f|j|j|jd|IdHS)a Make an request to Telegram Bot API https://core.telegram.org/bots/api#making-requests :param method: API method :type method: :obj:`str` :param data: request parameters :type data: :obj:`dict` :param files: files :type files: :obj:`dict` :return: result :rtype: Union[List, Dict] :raise: :obj:`aiogram.exceptions.TelegramApiError` N)rrr)r make_requestrXr r1rrr)rFrnrorpkwargsrHrHrIrequests    zBaseBot.requesti file_path destination chunk_sizeseekdestination_dir make_dirsc s.|r |r td|dur|durt}n |rtj||}|r8t|tjs8tj|r8tj tj|dd| |}t|tjrE|nt |d} | IdH} | j |||j|jdd4IdH"} | j|IdH} | son | | | qcWdIdHn 1IdHswY|r| d| S)aY Download file by file_path to destination file or directory if You want to automatically create destination (:class:`io.BytesIO`) use default value of destination and handle result of this method. At most one of these parameters can be used: :param destination:, :param destination_dir: :param file_path: file path on telegram server (You can get it from :obj:`aiogram.types.File`) :type file_path: :obj:`str` :param destination: filename or instance of :class:`io.IOBase`. For e. g. :class:`io.BytesIO` :param timeout: Integer :param chunk_size: Integer :param seek: Boolean - go to start of file when downloading is finished. :param destination_dir: directory for saving files :param make_dirs: Make dirs if not exist :return: destination z>Use only one of the parameters:destination or destination_dir.NT)exist_okwb)rrrraise_for_statusr) ValueErrorioBytesIOospathjoinr>IOBasedirnamemakedirs get_file_urlopenrXrbrrcontentreadwriteflushrw) rFrtrurrvrwrxryurldestr\responsechunkrHrHrI download_filesB   ( zBaseBot.download_filecCs|jj|j|dS)N)rr)r file_urlr1)rFrtrHrHrIr.szBaseBot.get_file_urlcsD|duri}nt|tr|||<d}n||i}||||IdHS)a Send file https://core.telegram.org/bots/api#inputfile :param file_type: field name :param method: API method :param file: String or io.IOBase :param payload: request payload :return: response N)r>r?rs)rF file_typernfilepayloadrprHrHrI send_file1s  zBaseBot.send_filecC t|ddS)N _parse_modegetattrrPrHrHrIrH zBaseBot.parse_modecCs|dur t|dddSt|tstdt||}|tvr-tdtt|d||dkr@t j ddddSdS)NrzParse mode must be str, not zParse mode must be one of markdownzParse mode `Markdown` is legacy since Telegram Bot API 4.5, retained for backward compatibility. Use `MarkdownV2` instead. https://core.telegram.org/bots/api#markdown-stylerYrm) setattrr>r? TypeErrortypelowerrallr}warningswarnrcrHrHrIrLs    cCrdrS)rrPrHrHrIr\recCr)N_disable_web_page_previewrrPrHrHrIr`rz BaseBot.disable_web_page_previewcCD|dur t|dddSt|tstdt|t|d|dS)Nrz+Disable web page preview must be bool, not rr>boolrrrcrHrHrIrds  cCrdrS)rrPrHrHrIrmrecCr)N_protect_contentrrPrHrHrIrqrzBaseBot.protect_contentcCr)Nrz"Protect content must be bool, not rrcrHrHrIrus   cCrdrS)rrPrHrHrIr~recCs t|j|SrS)rr1)rFrorHrHrIcheck_auth_widgets zBaseBot.check_auth_widget)T)NN)<__name__ __module__ __qualname____doc__rrarir rStringrrasyncio BaseEventLoopAbstractEventLoopIntegerr9 BasicAuthBooleantypingFloatr_r rJrNrQpropertyrrXrr\ staticmethodr`rsetterdeleter contextlibcontextmanagerrhr1rlrWrrrsr InputFilepathlibPathr?r~rFileIOrrrrrrrrHrHrHrIrs     Y      "       ?          r)!rrr~rrr%rr contextvarsrrrrrrr9r6aiohttp.helpersrr r r typesrrutilsrutils.auth_widgetrutils.deprecatedrrrHrHrHrIs(