ڰjO[SSKrSSKrSSKJr SSKrSSKJrJr SSK J r J r SSK r SSKJrJrJrJrJrJrJr SSKJr \R0"\5r"SS\5r"S S 5r"S S \\5r"S S\\5r"SS\ 5r"SS\ 5r S"Sjr!Sr"Sr#"SS5r$"SS5r%"SS5r&"SS5r'"SS5r("S S!\5r)g)#N)Mapping)HTTPConnectionVerifiedHTTPSConnection)HTTPConnectionPoolHTTPSConnectionPool) HTTPHeaders HTTPResponseMutableMapping urlencodeurlparseurlsplit urlunsplit)UnseekableStreamErrorc \rSrSrSrSrSrg)AWSHTTPResponse%cdURS5Ul[R"U/UQ70UD6 g)N status_tuple)pop _status_tupler __init__selfargskwargss P/home/mande/repo/quber/.venv/lib/python3.13/site-packages/botocore/awsrequest.pyrAWSHTTPResponse.__init__(s+#ZZ7d4T4V4crURbURnSUlU$[R"U5$N)rr _read_status)rrs rr!AWSHTTPResponse._read_status,s8    )--L!%D  ,,T2 2r)rN)__name__ __module__ __qualname____firstlineno__rr!__static_attributes__rrrr%s 53rrc|^\rSrSrSrU4SjrU4SjrSU4SjjrSrSSjr Sr S r S r U4S jr S rS rU=r$) AWSConnection5aMixin for HTTPConnection that supports Expect 100-continue. This when mixed with a subclass of httplib.HTTPConnection (though technically we subclass from urllib3, which subclasses httplib.HTTPConnection) and we only override this class to support Expect 100-continue, which we need for S3. As far as I can tell, this is general purpose enough to not be specific to S3, but I'm being tentative and keeping it in botocore because I've only tested this against AWS services. cr>[TU]"U0UD6 URUlSUlSUlSUlgNF)superrresponse_class_original_response_cls_response_received_expect_header_set _send_called)rrr __class__s rrAWSConnection.__init__Bs= $)&)&*&9&9##("'!rcn>[TU]5 SUlSUlSUlUR Ulgr-)r.closer1r2r3r0r/)rr4s rr7AWSConnection.closeOs2  "'"'!"99rc>Uc0nSUlURUlURSS5S:XaSUlOSUl[ TU]"XX4/UQ70UD6nSUlU$)NFExpectrs 100-continueT)r1r0r/getr2r.request) rmethodurlbodyheadersrrrvalr4s rr<AWSConnection.requestWsm ?G"'"99 ;;x % 8&*D #&+D #wvDKDKFK"' rc/nUHKn[U[5(a"URURS55 M:URU5 MM SR U5nU$)Nutf-8 ) isinstancestrappendencodejoin)r mixed_buffer bytes_bufferchunkmsgs r_convert_to_bytesAWSConnection._convert_to_bytesdsZ !E%%%##ELL$9:##E* " ll<( rcURRS5 URUR5nURSS2 [U[5(aXA- nSnUR U5 UR (ak[RS5 [RRURS5(aURU5 g[RS5 UbUR U5 gg)N)rrz"Waiting for 100 Continue response.zCNo response seen from server, continuing to send the response body.)_bufferextendrOrFbytessendr2loggerdebugurllib3util wait_for_readsock_handle_expect_response)r message_bodyrrrNs r _send_outputAWSConnection._send_outputqs J'$$T\\2 LLO lE * *  CL #  " " LL= >||))$))Q77,,\: .  # IIl # $rcFSnUS:waUR5nUS:waMgg)NrE)readline)rfpcurrents r_consume_headersAWSConnection._consume_headerss& kkmG rcURRSS5nUR5nURSS5nUR U5(a8UR U5 [ RS5 URU5 O[U5S:XaUSRS5(ap[ RS5 USRS5[US 5USRS54n[R"[US 9nX`lS UlUR%5 g!UR%5 f=f) Nrbrz5100 Continue response seen, now sending request body.HTTP/zOReceived a non 100 Continue response from the server, NOT sending request body.asciirR)rT)r\makefilerbsplit_is_100_continue_statusrerWrX_send_message_bodylen startswithdecodeint functoolspartialrr/r1r7)rr^rcmaybe_status_linepartsrr/s rr]%AWSConnection._handle_expect_responsesYY  a (%  " %++D!4E++,=>>%%b) K'' 5UqU1X%8%8%B%B A !HOOG,aM!HOOG,  "+!2!2#,"'5#*.' HHJBHHJs DD77E c.UbURU5 ggr )rV)rr^s rrp AWSConnection._send_message_bodys  # IIl # $rc>UR(a.UR(d[RS5 SUlg[TU]U5$)Nz?send() called, but response already received. Not sending data.T)r1r3rWrXr.rV)rrGr4s rrVAWSConnection.sendsD  " "$$ (!%D  w|C  rcURSS5n[U5S:=(a# USRS5=(a USS:H$)NrirrkrRs100)rnrqrr)rrwrxs rro%AWSConnection._is_100_continue_statussN!''a0 J!O #a##H- #aF" r)r2r0r1r3r/NNr )r#r$r%r&__doc__rr7r<rOr_rer]rprVror' __classcell__)r4s@rr*r*5sA  ":  $$L $*X$ !  rr*c\rSrSrSrSrg)AWSHTTPConnectionz6An HTTPConnection that supports 100 Continue behavior.r(Nr#r$r%r&rr'r(rrrrs@rrc\rSrSrSrSrg)AWSHTTPSConnectionz7An HTTPSConnection that supports 100 Continue behavior.r(Nrr(rrrrsArrc\rSrSr\rSrg)AWSHTTPConnectionPoolr(N)r#r$r%r&r ConnectionClsr'r(rrrrs%Mrrc\rSrSr\rSrg)AWSHTTPSConnectionPoolr(N)r#r$r%r&rrr'r(rrrrs&MrrcUnUb USnX5S'URS5n[XSU5nUS(a<[RRnU"US5n SU;a USU 3- nOUSU 3- nXtS 'X$S 'Uc0US 'gg) a  This method prepares a request dict to be created into an AWSRequestObject. This prepares the request dict by adding the url and the user agent to the request dict. :type request_dict: dict :param request_dict: The request dict (created from the ``serialize`` module). :type user_agent: string :param user_agent: The user agent to use for this request. :type endpoint_url: string :param endpoint_url: The full endpoint url, which contains at least the scheme, the hostname, and optionally any path components. Nr@z User-Agent host_prefixurl_path query_string?&r>context)r;_urljoinbotocoreutilspercent_encode_sequence) request_dict endpoint_urlr user_agentrr@rr>rencoded_query_strings rprepare_request_dictrs& AI, * %% &K <: Q+,- -C Q+,- -CeHiL) rc nUn[USUSUSUSURS5S9nUSUlU$)a+ This method takes a request dict and creates an AWSRequest object from it. :type request_dict: dict :param request_dict: The request dict (created from the ``prepare_request_dict`` method). :rtype: ``botocore.awsrequest.AWSRequest`` :return: An AWSRequest object based on the request_dict. r=r>r?r@ auth_path)r=r>datar@rr) AWSRequestr;r)rrrequest_objects rcreate_request_objectr$sO A{ eH vY) %% $ Ny\N rc*[U5nU(aUS:XaUS(dSnOIUSnOCUSRS5(a"URS5(a USSSU-nOUSU-nUSnUbX%-n[USXTUSUS45nU$)N/rirRrrj)r endswithrrr)rrrpnew_path new_netloc reconstructeds rrr=sA x3tHtH 1s   3 3C 8 8Q49x'Q4(?1J - !jAaD!A$GHM rc@\rSrSrSrSrSrS SjrSrSr S r S r g) AWSRequestPrepareriYa This class performs preparation on AWSRequest objects similar to that of the PreparedRequest class does in the requests library. However, the logic has been boiled down to meet the specific use cases in botocore. Of note there are the following differences: This class does not heavily prepare the URL. Requests performed many validations and corrections to ensure the URL is properly formatted. Botocore either performs these validations elsewhere or otherwise consistently provides well formatted URLs. This class does not heavily prepare the body. Body preperation is simple and supports only the cases that we document: bytes and file-like objects to determine the content-length. This will also additionally prepare a body that is a dict to be url encoded params string as some signers rely on this. Finally, this class does not support multipart file uploads. This class does not prepare the method, auth or cookies. cURnURU5nURU5nURX5nURnUR n[ X#XTXg5$r )r= _prepare_url _prepare_body_prepare_headers stream_outputrAWSPreparedRequest)roriginalr=r>r?r@rrs rprepareAWSRequestPreparer.preparense)!!(+''7 .. ""!    rcVURnUR(a[U5nUR(aSOSn[ UR[ 5(a$[ URR55nO URn[USS9nURX&45nU$)NrrTdoseq) r>paramsr queryrFrlistitemsr rJ)rrr> url_partsdelimparams_to_encoders rrAWSRequestPreparer._prepare_urlzs}ll ??  I$??CE(//733#'(=(=(?#@ #+?? /trr@rrrrrr) rr=r>r@rrrrrrs rrAWSRequest.__init__sw"&!;!;!=~6 "}   "*  %mmo $) S!. rc8URRU5$)z>Constructs a :class:`AWSPreparedRequest `.)rrrs rrAWSRequest.prepares%%--d33rcUR5Rn[U[5(aUR S5nU$r)rr?rFrGrIrs rr?AWSRequest.bodys3||~"" dC ;;w'D r) rrrrr@r=rrr>)NNNNNNF) r#r$r%r&rrrrrpropertyr?r'r(rrrrsE/  "H4rrc0\rSrSrSrSSjrSrSrSrg) riaA data class representing a finalized request to be sent over the wire. Requests at this stage should be treated as final, and the properties of the request should not be modified. :ivar method: The HTTP Method :ivar url: The full url :ivar headers: The HTTP headers to send. :ivar body: The HTTP body. :ivar stream_output: If the response for this request should be streamed. :ivar context: The request context from the originating ``AWSRequest``. NcLXlX lX0lX@lXPlX`lgr )r=r>r@r?rr)rr=r>r@r?rrs rrAWSPreparedRequest.__init__s#   * rcfSnXRURURUR4-$)NzD)rr=r>r@)rfmts r__repr__AWSPreparedRequest.__repr__s2  (($++txxNNNrcf[[[4nURb[ URU5(ag[ R SUR5 URRS5 g![a.n[ R SU5 [URS9eSnAff=f)a Resets the streaming body to it's initial position. If the request contains a streaming body (a streamable file-like object) seek to the object's initial position to ensure the entire contents of the object is sent. This is a no-op for static bytes-like body types. NzRewinding stream: %srzUnable to rewind stream: %s) stream_object) rUrG bytearrayr?rFrWrXseek Exceptionr)rnon_seekable_typeses r reset_streamAWSPreparedRequest.reset_stream s$S)4 99  4996H I I  A LL/ ; IINN1  A LL6 :'dii@ @ As;A88 B0)B++B0)r?rr@r=rr>r ) r#r$r%r&rrrrr'r(rrrrs BFOArrc>\rSrSrSrSr\S5r\S5rSr g) AWSResponsei%aA data class representing an HTTP response. This class was originally inspired by requests.models.Response, but has been boiled down to meet the specific use cases in botocore. This has effectively been reduced to a named tuple. :ivar url: The full url. :ivar status_code: The status code of the HTTP response. :ivar headers: The HTTP headers received. :ivar body: The HTTP response body. cVXlX l[U5UlX@lSUlgr )r> status_coderr@raw_content)rr>rr@rs rrAWSResponse.__init__2s%&"7+  rcURc7SRURR55=(d SUlUR$)z!Content of the response as bytes.r)rrJrstreamrs rcontentAWSResponse.content:s: ==  HHTXX__%67>3DM}}rc[RRUR5nU(aURR U5$URR S5$)zContent of the response as a proper text type. Uses the encoding type provided in the reponse headers to decode the response content into a proper text type. If the encoding is not present in the headers, UTF-8 is used as a default. rD)rrget_encoding_from_headersr@rrs)rencodings rtextAWSResponse.textGsI>>;;DLLI <<&&x0 0<<&&w/ /r)rr@rrr>N) r#r$r%r&rrrrr r'r(rrrr%s4    0 0rrc2\rSrSrSrSrSrSrSrSr g) _HeaderKeyiVc:XlUR5Ulgr )_keylower_lowerrrs rr_HeaderKey.__init__Ws iik rc,[UR5$r )hashrrs r__hash___HeaderKey.__hash__[sDKK  rcb[U[5=(a URUR:H$r )rFr r)rothers r__eq___HeaderKey.__eq__^s!%,L 1LLrcUR$r )rrs r__str___HeaderKey.__str__as yyrc,[UR5$r )reprrrs rr_HeaderKey.__repr__dsDIIr)rrN) r#r$r%r&rrrrrr'r(rrr r Vs"!Mrr cH\rSrSrSrSrSrSrSrSr Sr S r S r S r g ) rihz9A case-insenseitive dictionary to represent HTTP headers.c60UlUR"U0UD6 gr )_dictupdaters rrHeadersDict.__init__ks  T$V$rc2X R[U5'gr r$r )rrrs r __setitem__HeadersDict.__setitem__os&+ :c?#rc2UR[U5$r r(rs r __getitem__HeadersDict.__getitem__rszz*S/**rc0UR[U5 gr r(rs r __delitem__HeadersDict.__delitem__us JJz# 'rc(SUR5$)Nc38# UHn[U5v M g7fr )rG).0rs r 'HeadersDict.__iter__..ys/JSCJsr$rs r__iter__HeadersDict.__iter__xs/DJJ//rc,[UR5$r )rqr$rs r__len__HeadersDict.__len__{s4::rc,[UR5$r )r r$rs rrHeadersDict.__repr__~sDJJrc4[UR55$r )rrrs rcopyHeadersDict.copys4::<((rr6N)r#r$r%r&rrr)r,r/r7r:rr?r'r(rrrrhs-C%,+(0 )rrr)*ruloggingcollections.abcr urllib3.utilrYurllib3.connectionrrurllib3.connectionpoolrrbotocore.utilsrbotocore.compatrr r r r r rbotocore.exceptionsr getLoggerr#rWrr*rrrrrrrrrrrr rr(rrrJs#FJ6   8 $ 3l 3 s s lA ~AB(?B&.&'0' :>&R28X=X=v77t4A4An.0.0b$).)r