՟f_PNdZddlZddlZddlmZddlmZddlmZm Z m Z m Z m Z m Z mZmZmZddlmZddlmZddlmZdd lmZdd lmZmZdd lmZdd lmZ dd l!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)ddl*m+Z+ddl,m-Z-eddZ.ee/dZ0GddedejbZ2y)zEThis module contains an abstract class to make POST and GET requests.N) HTTPStatus) TracebackType) AsyncContextManagerFinalListOptionalTupleTypeTypeVarUnionfinal) DEFAULT_NONE) DefaultValue) get_logger) TextEncoding)JSONDictODVInput)warn) __version__) BadRequest ChatMigratedConflict Forbidden InvalidToken NetworkError RetryAfter TelegramError) RequestData)PTBDeprecationWarningRT BaseRequest)bound) class_nameceZdZUdZdZdedZeee d< e Z ee de d< de d e fd Zd eeed eed eed dfdZed eefdZej0ddZej0ddZede e e e fdedeedeedeedeedeed eee ee!ffdZ"ee e e e fdedeedeedeedeed e#f dZ$de e e e fdededeedeedeedeedeed e#fdZ%e&de#d efdZ'ej0de e e e fdededeedeedeedeedeed e(e)e#ffdZ*y) r!a?Abstract interface class that allows python-telegram-bot to make requests to the Bot API. Can be implemented via different asyncio HTTP libraries. An implementation of this class must implement all abstract methods and properties. Instances of this class can be used as asyncio context managers, where .. code:: python async with request_object: # code is roughly equivalent to .. code:: python try: await request_object.initialize() # code finally: await request_object.shutdown() .. seealso:: :meth:`__aenter__` and :meth:`__aexit__`. Tip: JSON encoding and decoding is done with the standard library's :mod:`json` by default. To use a custom library for this, you can override :meth:`parse_json_payload` and implement custom logic to encode the keys of :attr:`telegram.request.RequestData.parameters`. .. seealso:: :wiki:`Architecture Overview `, :wiki:`Builder Pattern ` .. versionadded:: 20.0 zpython-telegram-bot vz" (https://python-telegram-bot.org) USER_AGENTNrselfreturncK |jd{|S7#t$r|jd{7wxYww)a'|async_context_manager| :meth:`initializes ` the Request. Returns: The initialized Request instance. Raises: :exc:`Exception`: If an exception is raised during initialization, :meth:`shutdown` is called in this case. N) initialize Exceptionshutdownr's X/var/www/cvtools/html/venv/lib/python3.12/site-packages/telegram/request/_baserequest.py __aenter__zBaseRequest.__aenter__jsG //# # # $ --/ ! !  s.A  A A?AAexc_typeexc_valexc_tbc@K|jd{y7w)zB|async_context_manager| :meth:`shuts down ` the Request.N)r,)r'r0r1r2s r. __aexit__zBaseRequest.__aexit__{smmos ct)aThis property must return the default read timeout in seconds used by this class. More precisely, the returned value should be the one used when :paramref:`post.read_timeout` of :meth:post` is not passed/equal to :attr:`DEFAULT_NONE`. .. versionadded:: 20.7 Warning: For now this property does not need to be implemented by subclasses and will raise :exc:`NotImplementedError` if accessed without being overridden. However, in future versions, this property will be abstract and must be implemented by subclasses. Returns: :obj:`float` | :obj:`None`: The read timeout in seconds. )NotImplementedErrorr-s r. read_timeoutzBaseRequest.read_timeouts "!c Kyw)zKInitialize resources used by this class. Must be implemented by a subclass.Nr%r-s r.r*zBaseRequest.initializec Kyw)zMStop & clear resources used by this class. Must be implemented by a subclass.Nr%r-s r.r,zBaseRequest.shutdownr:r;url request_datar7 write_timeoutconnect_timeout pool_timeoutc zK|j|d|||||d{}|j|}|dS7w)a_Makes a request to the Bot API handles the return code and parses the answer. Warning: This method will be called by the methods of :class:`telegram.Bot` and should *not* be called manually. Args: url (:obj:`str`): The URL to request. request_data (:class:`telegram.request.RequestData`, optional): An object containing information about parameters and files to upload for the request. read_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a response from Telegram's server instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. write_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a write operation to complete (in terms of a network socket; i.e. POSTing a request or uploading a file) instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. connect_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a connection attempt to a server to succeed instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. pool_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a connection to become available instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. Returns: The JSON response of the Bot API. POSTr=methodr>r7r?r@rANresult)_request_wrapperparse_json_payload) r'r=r>r7r?r@rArF json_datas r.postzBaseRequest.posts\R,,%%'+%-  ++F3 "" s ;9;cLK|j|d||||d{S7w)aRetrieve the contents of a file by its URL. Warning: This method will be called by the methods of :class:`telegram.Bot` and should *not* be called manually. Args: url (:obj:`str`): The web location we want to retrieve. read_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a response from Telegram's server instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. write_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a write operation to complete (in terms of a network socket; i.e. POSTing a request or uploading a file) instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. connect_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a connection attempt to a server to succeed instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. pool_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a connection to become available instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. Returns: :obj:`bytes`: The files contents. GET)r=rEr7r?r@rAN)rG)r'r=r7r?r@rAs r.retrievezBaseRequest.retrieves=L**%'+% +    s $"$rEc Kddlm}|xr |j} | rMt||sAt|tr1t t dd|jjddd} |j||||||| d {\} } tj| cxkrd kr| S|j| } | j!d }|r|nd}| j!d}|rD|j!d}|r t#||j!d}|r t%||d|z }| tj&k(r t)|| tj*tj,fvr t/|| tj0k(r t3|| tj4k(r t7|| tj8k(rt|xsdt|d| d7]#t$rt$r} td | | d } ~ wwxYww)aWraps the real implementation request method. Performs the following tasks: * Handle the various HTTP response codes. * Parse the Telegram server response. Args: url (:obj:`str`): The URL to request. method (:obj:`str`): HTTP method (i.e. 'POST', 'GET', etc.). request_data (:class:`telegram.request.RequestData`, optional): An object containing information about parameters and files to upload for the request. read_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a response from Telegram's server instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. write_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a write operation to complete (in terms of a network socket; i.e. POSTing a request or uploading a file) instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. connect_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a connection attempt to a server to succeed instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. pool_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a connection to become available instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. Returns: bytes: The payload part of the HTTP server response. Raises: TelegramError r) HTTPXRequestz20.7z(The `write_timeout` parameter passed to z.do_request will default to `BaseRequest.DEFAULT_NONE` instead of 20 in future versions for *all* methods of the `Bot` class, including methods sending media.) stacklevelrDNz&Unknown error in HTTP implementation: i+ descriptionzUnknown HTTPError parametersmigrate_to_chat_id retry_afterz3 The server response contained unknown parameters: z Bad Gatewayz ())telegram.requestrOmultipart_data isinstancerrr __class____name__ do_requestrr+rrOKrHgetrr FORBIDDENr NOT_FOUND UNAUTHORIZEDr BAD_REQUESTrCONFLICTr BAD_GATEWAY)r'r=rEr>r7r?r@rArO has_filescodepayloadexc response_datarSmessagerTrUrVs r.rGzBaseRequest._request_wrappers6\ 2!@\%@%@ t\2=,7 %>t~~?V?V>WX]]  M Z"&//))+ /)#2#MD' ==D 'C 'N (//8 #'' 6 !,+2E#&&|4 !+0D!E !"#566$..7K -- Mj\Z ZG :'' 'G$ $ J((**A*AB B w' ' :)) )W% % :&& &7# # :)) ){;m< <gYba011m   Z!GwOPVY Y Zs=A&H )G$G!G$ EH !G$$H 6HH  H rhc|jtjd} tj|S#t $r'}t jd|td|d}~wwxYw)aParse the JSON returned from Telegram. Tip: By default, this method uses the standard library's :func:`json.loads` and ``errors="replace"`` in :meth:`bytes.decode`. You can override it to customize either of these behaviors. Args: payload (:obj:`bytes`): The UTF-8 encoded JSON payload as returned by Telegram. Returns: dict: A JSON parsed as Python dict with results. Raises: TelegramError: If loading the JSON data failed replacez$Can not load invalid JSON data: "%s"zInvalid server responseN) decoderUTF_8jsonloads ValueError_LOGGER exceptionr)rh decoded_sris r.rHzBaseRequest.parse_json_payloads`$NN<#5#5yA  D::i( ( D   Di P 9: C Ds7 A'"A""A'c Kyw)aMakes a request to the Bot API. Must be implemented by a subclass. Warning: This method will be called by :meth:`post` and :meth:`retrieve`. It should *not* be called manually. Args: url (:obj:`str`): The URL to request. method (:obj:`str`): HTTP method (i.e. ``'POST'``, ``'GET'``, etc.). request_data (:class:`telegram.request.RequestData`, optional): An object containing information about parameters and files to upload for the request. read_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a response from Telegram's server instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. write_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a write operation to complete (in terms of a network socket; i.e. POSTing a request or uploading a file) instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. connect_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a connection attempt to a server to succeed instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. pool_timeout (:obj:`float` | :obj:`None`, optional): If passed, specifies the maximum amount of time (in seconds) to wait for a connection to become available instead of the time specified during creating of this object. Defaults to :attr:`DEFAULT_NONE`. Returns: Tuple[:obj:`int`, :obj:`bytes`]: The HTTP return code & the payload part of the server response. Nr%)r'r=rEr>r7r?r@rAs r.r]zBaseRequest.do_requestr:r;)r(N)+r\ __module__ __qualname____doc__ __slots__ptb_verr&rstr__annotations__ _DEFAULT_NONErrr r/rr BaseExceptionrr4propertyfloatr7abcabstractmethodr*r,r rrr rrboolrJbytesrMrG staticmethodrHr intr]r%r8r.r!r!3s* DI4WI=_`Jc `.;L% T*+; rb" 4 ./ -( '   "huo""" ZZ \\ /3(4)5+7(44# 4#{+4#uo 4#   4# "% 4#uo4# xh- .4# 4#l )5)5+7(4 , , uo,   , "% , uo ,  ,  , d/3(4)5+7(4}2 }2}2{+ }2 uo }2   }2"%}2uo}2 }2~DEDhDD0  /3(4)5+7(4) ) ) {+ ) uo )   ) "%) uo)  sEz ) ) r8)3ryrrphttprtypesrtypingrrrrr r r r r telegram._utils.defaultvaluerr~rtelegram._utils.loggingrtelegram._utils.stringsrtelegram._utils.typesrrtelegram._utils.warningsrtelegram._versionrr{telegram.errorrrrrrrrrtelegram.request._requestdatartelegram.warningsrr r\rsABCr!r%r8r.rs&L aaaF5.04)4   63 T' X- 8U  &GGU r8