i2dZddlmZmZmZmZddlZddlmZddl m Z ddl m Z m Z mZddlmZddlmZmZdd lmZdd lmZdd lmZe ed ZGd d eZdS)zSThis module contains methods to make POST and GET requests using the httpx library.) CollectionOptionalTupleUnionN) DefaultValue) get_logger) HTTPVersionODVInput SocketOpt)warn) NetworkErrorTimedOut) BaseRequest) RequestData)PTBDeprecationWarning HTTPXRequestc&eZdZdZdZ dd ed eeee j e j fd ee d ee d ee dee de deeedeeee j e j fdee fdZedefdZedee fdZde jfdZddZddZdejejejejfdededeed ee d ee d ee dee deeeffdZdS) raImplementation of :class:`~telegram.request.BaseRequest` using the library `httpx `_. .. versionadded:: 20.0 Args: connection_pool_size (:obj:`int`, optional): Number of connections to keep in the connection pool. Defaults to ``1``. Note: Independent of the value, one additional connection will be reserved for :meth:`telegram.Bot.get_updates`. proxy_url (:obj:`str`, optional): Legacy name for :paramref:`proxy`, kept for backward compatibility. Defaults to :obj:`None`. .. deprecated:: 20.7 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. This value is used unless a different value is passed to :meth:`do_request`. Defaults to ``5``. 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). This value is used unless a different value is passed to :meth:`do_request`. Defaults to ``5``. Hint: This timeout is used for all requests except for those that upload media/files. For the latter, :paramref:`media_write_timeout` is used. 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. This value is used unless a different value is passed to :meth:`do_request`. Defaults to ``5``. 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. This value is used unless a different value is passed to :meth:`do_request`. Defaults to ``1``. Warning: With a finite pool timeout, you must expect :exc:`telegram.error.TimedOut` exceptions to be thrown when more requests are made simultaneously than there are connections in the connection pool! http_version (:obj:`str`, optional): If ``"2"`` or ``"2.0"``, HTTP/2 will be used instead of HTTP/1.1. Defaults to ``"1.1"``. .. versionadded:: 20.1 .. versionchanged:: 20.2 Reset the default version to 1.1. .. versionchanged:: 20.5 Accept ``"2"`` as a valid value. socket_options (Collection[:obj:`tuple`], optional): Socket options to be passed to the underlying `library `_. Note: The values accepted by this parameter depend on the operating system. This is a low-level parameter and should only be used if you are familiar with these concepts. .. versionadded:: 20.7 proxy (:obj:`str` | ``httpx.Proxy`` | ``httpx.URL``, optional): The URL to a proxy server, a ``httpx.Proxy`` object or a ``httpx.URL`` object. For example ``'http://127.0.0.1:3128'`` or ``'socks5://127.0.0.1:3128'``. Defaults to :obj:`None`. Note: * The proxy URL can also be set via the environment variables ``HTTPS_PROXY`` or ``ALL_PROXY``. See `the docs of httpx`_ for more info. * HTTPS proxies can be configured by passing a ``httpx.Proxy`` object with a corresponding ``ssl_context``. * For Socks5 support, additional dependencies are required. Make sure to install PTB via :command:`pip install "python-telegram-bot[socks]"` in this case. * Socks5 proxies can not be set via environment variables. .. _the docs of httpx: https://www.python-httpx.org/environment_variables/#proxies .. versionadded:: 20.7 media_write_timeout (:obj:`float` | :obj:`None`, optional): Like :paramref:`write_timeout`, but used only for requests that upload media/files. This value is used unless a different value is passed to :paramref:`do_request.write_timeout` of :meth:`do_request`. Defaults to ``20`` seconds. .. versionadded:: 21.0 )_client_client_kwargs _http_version_media_write_timeoutN@?1.14@connection_pool_size proxy_url read_timeout write_timeoutconnect_timeout pool_timeout http_versionsocket_optionsproxymedia_write_timeoutc x|| td|!|} ttddd||_| |_t j||||} t j||} |dvrtd |d k} | | d }|rt j| nd}| | | |d ||_ | |_ dS#t$rZ}dt|vrdt|vr|dt|vrtd|td|d}~wwxYw)Nz>The parameters `proxy_url` and `proxy` are mutually exclusive.z20.7z=The parameter `proxy_url` is deprecated. Use `proxy` instead.) stacklevelconnectreadwritepool)max_connectionsmax_keepalive_connections)r2z2.0z2`http_version` must be either '1.1', '2.0' or '2'.r)http1http2)r$)timeoutr%limits transportz httpx[http2]z httpx[socks]z\To use Socks5 proxies, PTB must be installed via `pip install "python-telegram-bot[socks]"`.zTTo use HTTP/2, PTB must be installed via `pip install "python-telegram-bot[http2]"`.) ValueErrorr rrrhttpxTimeoutLimitsAsyncHTTPTransportr _build_clientr ImportErrorstr RuntimeError)selfrrrr r!r"r#r$r%r&r4r5r2 http_kwargsr6excs d/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/telegram/request/_httpxrequest.py__init__zHTTPXRequest.__init__s  U%6]^^ ^  E %[     *$7!-#     0&:    2 2 2QRR R% %E ::  E $-     "      --//DLLL   SXX--.C2P2P S))"51  s:C D9AD44D9returnc|jS)zn :obj:`str`: Used HTTP version, see :paramref:`http_version`. .. versionadded:: 20.2 )rr@s rCr#zHTTPXRequest.http_versions !!c$|jjjS)zSee :attr:`BaseRequest.read_timeout`. Returns: :obj:`float` | :obj:`None`: The default read timeout in seconds as passed to :paramref:`HTTPXRequest.read_timeout`. )rr4r,rGs rCrzHTTPXRequest.read_timeouts|#((rHc.tjdi|jS)N)r8 AsyncClientrrGs rCr<zHTTPXRequest._build_clients 774#6777rHcXK|jjr||_dSdS)z#See :meth:`BaseRequest.initialize`.N)r is_closedr<rGs rC initializezHTTPXRequest.initializes4 < ! 0--//DLLL 0 0rHcK|jjrtddS|jd{VdS)z!See :meth:`BaseRequest.shutdown`.z2This HTTPXRequest is already shut down. Returning.N)rrN_LOGGERdebugacloserGs rCshutdownzHTTPXRequest.shutdownsW < !  MMN O O O Fl!!###########rHurlmethod request_datacLK|jjrtd|r|jnd}|r|jnd} t |t r|jjj}t |t r|jjj }t |t r|jjj }t |t r|s|jjj n|j }tj||||} |j||d|ji| || d{V} n|#tj$r8} t | tjrt'd| t&| d} ~ wtj$r%} t+d| jjd | | d} ~ wwxYw| j| jfS) z#See :meth:`BaseRequest.do_request`.z%This HTTPXRequest is not initialized!Nr*z User-Agent)rVrUheadersr4filesdatazPool timeout: All connections in the connection pool are occupied. Request was *not* sent to Telegram. Consider adjusting the connection pool size or the pool timeout.)messagezhttpx.z: )rrNr?multipart_datajson_parameters isinstancerr4r,r+r.r-rr8r9request USER_AGENTTimeoutException PoolTimeoutr HTTPErrorr __class____name__ status_codecontent) r@rUrVrWrr r!r"rZr[r4reserrs rC do_requestzHTTPXRequest.do_requests  < ! HFGG G/;E ++/;E|++ lL 1 1 5</4L o| 4 4 ;"l2:O lL 1 1 5</4L m\ 2 2 c>CbDL066IbM-#     R ,,%t7 -CC% $ $ $#u011 9   # R R R G (>GG#GGHHc Q  R ++s$.-DF+3EF0 FF) rNrrrrrNNr)rEN)rf __module__ __qualname____doc__ __slots__intrrr>r8ProxyURLfloatr rr rDpropertyr#rrLr<rOrTr DEFAULT_NONErr rbytesrkrKrHrCrr)sVTTlWI%&BF(+),+.(+$):>>B/3HH!HE#u{EI"=>?Huo H   H "% HuoH"H!I!67Hc5; 9:;H&e_HHHHT"c"""X")huo)))X)8u088880000 $$$$/3(3(@)4)A+6+C(3(@?,?, ?,?,{+ ?, uo ?,   ?,"%?,uo?, sEz ?,?,?,?,?,?,rH)rntypingrrrrr8telegram._utils.defaultvaluertelegram._utils.loggingrtelegram._utils.typesr r r telegram._utils.warningsr telegram.errorr rtelegram.request._baserequestrtelegram.request._requestdatartelegram.warningsrrfrQrrKrHrCrs.&ZY555555555555 555555......BBBBBBBBBB))))))11111111555555555555333333 *X~ . .E,E,E,E,E,;E,E,E,E,E,rH