BTh6ZdZddlZddlmZmZmZddlmZddlm Z ddl m Z ddl m Z ejeZGd d Zd Zd ZGd deZGddZej,j/D]\ZZeeeseeeeGddeZGddeZy)z*Stubs for patching HTTP and HTTPS requestsN)HTTPConnection HTTPResponseHTTPSConnection)BytesIO)(CannotOverwriteExistingCassetteException)Request)compatc"eZdZdZdZdZdZy) VCRFakeSocketz{ A socket that doesn't do anything! Used when playing back cassettes, when there is no actual open socket. cyNselfs d/var/www/catia.catastroantioquia-mas.com/valormas/lib/python3.12/site-packages/vcr/stubs/__init__.pyclosezVCRFakeSocket.close cyrrrargskwargss r settimeoutzVCRFakeSocket.settimeoutrrcy)z This is kinda crappy. requests will watch this descriptor and make sure it's not closed. Return file descriptor 0 since that's stdin. rrrs rfilenozVCRFakeSocket.filenos rN)__name__ __module__ __qualname____doc__rrrrrrr r s   rr cd}|jD]8\}}|D].}||jddz|jdzdzz }0:tj|S)z[ Convert headers from our serialized dict with lists for keys to a HTTPMessage rzutf-8:s )itemsencoder get_httpmessage) header_list header_stringkeyvaluesvs r parse_headersr+%sv M"((*V V VA SZZ047!((7:KKgU UM VV  ! !- 00rc|j |jn |j}i}tj|D]+\}}|j |g||j |-|Sr)msgheadersr get_headers setdefaultextend)responser.outr(r)s rserialize_headersr41sd"*,,"6hHLLG C))'2 V sB C  JrceZdZdZdZedZdZdZdZ dZ dZ d Z d Z d Zd Zd ZdZdZdZdZdZddZdZedZdZedZdZddZy)VCRHTTPResponsezJ Stub response class that gets returned instead of a HTTPResponse cd|_||_|dd|_|ddx|_|_d|_d|_t|jdd|_d|_ ||_ |jd}|jDcgc]}|jdk(s|}}|r||d =t|x|_|_t!j"|jd xsd|_ycc}w) NstatusmessagecodebodystringFr.zTRANSFER-ENCODINGrzcontent-length)fprecorded_responsereasonr8r:versionversion_stringr_content_closed_original_responsekeysupperr+r.r-r get_headerlength)rr>r.hte_keys r__init__zVCRHTTPResponse.__init__?s!2'1)< "3H"=f"EE di " 6 6v >x HI  "&((3 %\\^Pqwwyrs rinfozVCRHTTPResponse.infosT33I>??rcnt|jd}ttj|Srn)r+r>listr get_header_items)rr9s r getheaderszVCRHTTPResponse.getheaderss- 6 6y ABF++G455rNc|jDcgc])\}}|j|jk(s(|+}}}|rdj|S|Scc}}w)Nz, )rslowerjoin)rheaderdefaultkr*r)s r getheaderzVCRHTTPResponse.getheadersP"&//"3SAqwwyFLLN7R!SS 99V$ $N Ts )AAc6|jjSr)rBreadablers rr|zVCRHTTPResponse.readabler`rc|jjj|jjz Sr)rB getbuffernbytesrbrs rlength_remainingz VCRHTTPResponse.length_remainings-}}&&(//$--2D2D2FFFrcTd|jcxkrdksyy|jdS)a( Returns (a) redirect location string if we got a redirect status code and valid location, (b) None if redirect status and no location, (c) False if not a redirect status code. See https://urllib3.readthedocs.io/en/stable/reference/urllib3.response.html . i,iFLocation)r8rzrs rget_redirect_locationz%VCRHTTPResponse.get_redirect_locations/t{{)c)*~~j))rcR|jjjSr)rBr~tobytesrs rdatazVCRHTTPResponse.datas}}&&(0022rcyrrrs r drain_connzVCRHTTPResponse.drain_connrrc#RK |jj|}||sy#wrrP)ramtdecode_contentbs rstreamzVCRHTTPResponse.streams- ""3'AG s%'r)iN)rrrr rKpropertyrNrQrTrVrXr[r]r_rbrdrfrrirlrorsrzr|rrrrrrrrr6r6:sL0 34'778($&3@6(GG *33 rr6ceZdZdZdZdZdZddZdZdZ dZ d Z dd Z dd Z d Zd ZedZej$dZdZfdZfdZxZS) VCRConnectionNcj|jj}ddd|j}||k7rd|SdS)zQ Returns empty string for the default port and ':port' otherwise iP)httpshttp:)real_connectionport _protocol)rr default_ports r _port_postfixzVCRConnection._port_postfixs@##((!$b1$..A !\14&z9r9rc|r|jds|S|jd|jj|j |}t j d||S)zReturns request absolute URI/://zAbsolute URI: %s) startswithrrhostrlogdebug)rurluris r_urizVCRConnection._uris_ s~~c*J D$8$8$=$=#>t?Q?Q?S>TUXTYZ $c* rc|jd|jj|j}|j |ddS)z.Returns request selector url from absolute URIrrr )rrrrreplace)rrprefixs r_urlzVCRConnection._urlsENN#3t';';'@'@&A$BTBTBVAWX{{62q))rct||j|||xsi|_tj d|jt |_y)z1Persist the request metadata in self._vcr_requestmethodrr;r.Got N)rr _vcr_requestrrr _sock)rrrr;r.rrs rrequestzVCRConnection.requestsI#6tyy~DZaZgegh D**+,-#_ rct||j|di|_tj d|jy)z httplib gives you more than one way to do it. This is a way to start building up a request. Usually followed by a bunch of putheader() calls. rrrN)rrrrr)rrrrrs r putrequestzVCRConnection.putrequests: $6tyy~BXZ[ D**+,-rc6||jj|<yr)rr.)rrwr)s r putheaderzVCRConnection.putheaders,2!!&)rc|jjr)|jj|z|j_y||j_y)z This method is called after request(), to add additional data to the body of the request. So if that happens, let's just append the data onto the most recent request in the cassette. Nrr;)rrs rsendzVCRConnection.sendsA CGBSBSBXBX!2!2!7!7$!>^brc8|jjyr)rrrs rrzVCRConnection.closes ""$rc,|||j_yy)z Normally, this would actually send the request to the server. We are not sending the request until getting the response, so bypass this part and just append the message body, if any. Nr)r message_bodys r endheaderszVCRConnection.endheaderss  #%1D   " $rc d|jj|jrStj d|jd|jj |j}t |S|jjrF|jj|jr!t|j|jtj |jdddl m }|5|jj|jj|j|jj |jj"|jj$ddd|jj'}t)|d r |j*n|j-}|j.|j0d t3|d |id }|jj5|j|t |S#1swYxYw) zRetrieve the responsezPlaying response for z from cassette)cassettefailed_requestz( not in cassette, sending to real serverr force_reset)rrr;r.Nr)r:r9r<)r8r.r;)rcan_play_response_forrrro play_responser6write_protectedfilter_requestr vcr.patchrrrrrrr;r. getresponsehasattrrrQr8r?r4append)r_rr2r response_datas rrzVCRConnection.getresponses == . .t/@/@ A HH,T->->,?~N O}}2243D3DEH"8, ,}},,1M1MdN_N_1`>!]]#'#4#4 HH))**RS T . $$,,,,33 $"3"3"7"78**// --55 - ++779H-4Xv-FHMMHMMOM$,??xO,X6!=1H MM !2!2H =x(('  s A?H&&H/c<|jj|i|yr)rset_debuglevelrs rrzVCRConnection.set_debuglevel*s+++Trs0EE?g!, 1ylyxF)F)R  # # ) ) +%DAq!\" q!$% % %%%r