o TjJ<@sddlmZddlZddlZddlZddlZddlZddlZddl Zddl Z ddl Z ddl Z ddlZ ddlZ ddlmZddlmZddlmZddlmZejrUddlZdd d ZdddZddddZdd d!Zddd"d#Zdd$d%Zdd&d'Z e!e!e"e"fd(fZ#e!e#d(fZ$e%e"e"e$Be#BfZ&dd+d,Z'ddd1d2Z(dd5d6Z)dd=d>Z*dd?d@Z+ddAdBZ,ej-ddCej.dDe"dEej/dFdGdHe"dIdJej/dKdLdMe"e"fdNdOdPej/dQdRdSe"dTdJej/dUdVdWe"e"fdNdXdPej/dYdZd[e"ej0d\d]fdNd^dPej/d_d`dae"e*dbdcej/dddede"e"fdNdfdPej/dgdhe"e"fdNdidPej/djdke"e"fdle+dmdnej/dodpe"ddqdrej/dsdte1dudvdrej/dwdxdNddydzej/d{dNd|d}ej/d~de2dNdddej/de0dddJej/dde2dNdddej/ddNdNde,dddddZ3dS)) annotationsN)Client) RequestError)Response)codesreturnNonecCsTtj}|jddd||jddd||jddd|tjjjddd }|jd ddd d |d |dd|dd|dd|dd|dd|dd|dd|dd|dd|d d!|d"d#|d$d%|d&d'|d(d)|d*d+|d,d-|d.d/||dS)0Nz[bold]HTTPX :butterfly:center)justifyzA next generation HTTP client.z8Usage: [bold]httpx2[/bold] [cyan] [OPTIONS][/cyan] leftrT)paddingpad_edge Parameterbold)no_wrapr style Descriptionz-m, --method [cyan]METHODzRequest method, such as GET, POST, PUT, PATCH, DELETE, OPTIONS, HEAD, QUERY. [Default: GET, or POST if a request body is included]z#-p, --params [cyan] .../Query parameters to include in the request URL.z-c, --content [cyan]TEXT,Byte content to include in the request body.z!-d, --data [cyan] ...)Form data to include in the request body.z%-f, --files [cyan] ...*Form files to include in the request body.z-j, --json [cyan]TEXT)JSON data to include in the request body.z$-h, --headers [cyan] .../Include additional HTTP headers in the request.z --cookies [cyan] ..."Cookies to include in the request.z--auth [cyan]Username and password to include in the request. Specify '-' for the password to use a password prompt. Note that using --verbose/-v will expose the Authorization header, including the password encoding in a trivially reversible format.z--proxy [cyan]URLISend the request via a proxy. Should be the URL giving the proxy address.z--timeout [cyan]FLOATzTimeout value to use for network operations, such as establishing the connection, reading some data, etc... [Default: 5.0]--follow-redirectsAutomatically follow redirects.z--verify / --no-verifyEnable SSL verification.--http2@Send the request using HTTP/2, if the remote server supports it.z--download [cyan]FILE?Save the response content as a file, rather than displaying it.z -v, --verbosez1Verbose output. Show request as well as response.--helpShow this message and exit.) richconsoleConsoleprinttableTablegrid add_columnadd_row)r'r*r/O/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/httpx2/_main.py print_helpsh           r1responserstrcCs^|jd}|dur-|d\}}}ztttj| j WStj j y,YdSwdS)Nz Content-Type;) headersget partitiontypingcastr3pygmentslexersget_lexer_for_mimetypestripnameutil ClassNotFound)r2 content_type mime_type_r/r/r0get_lexer_for_response]s rEFrequesthttpcore2.Requesthttp2boolcshrdnd}fdd|jD}|jd}|jjd}|d|d|gdd|D}d|S) NzHTTP/2zHTTP/1.1cs$g|]\}}r |n||fqSr/)lower.0r?valuerHr/r0 js$z*format_request_headers..ascii cS*g|]\}}|dd|dqSrP: decoderKr/r/r0rOm )r6methodrVurltargetjoin)rFrHversionr6rYr[linesr/rNr0format_request_headershs   r_ http_versionbytesstatusint reason_phrase bytes | Noner6list[tuple[bytes, bytes]]cCsT|d}|durt|n|d}|d|d|gdd|D}d|S)NrPrQcSrRrSrUrKr/r/r0rO{rWz+format_response_headers..rX)rVrget_reason_phraser\)r`rbrdr6r]reasonr^r/r/r0format_response_headersss  ricCsVtj}t||d}tjj|dddd}||tjjddddd}||dS)NrNhttp ansi_darkTtheme word_wrapr5)r&r'r(r_syntaxSyntaxr))rFrHr' http_textror/r/r0print_request_headerss   rrcCsXtj}t||||}tjj|dddd}||tjjddddd}||dS)NrjrkTrlr5)r&r'r(rirorpr))r`rbrdr6r'rqror/r/r0print_response_headerss  rscCstj}t|}|r?|dkr+z |}tj|dd}Wnty*|j}Ynw|j}tj j ||ddd}| |dS| dt |j ddS) Njson)indentrkTrl)r&r'r(rErJrtdumps ValueErrortextrorpr)lencontent)r2r' lexer_namedatarzror/r/r0print_responses    r.cert_PeerCertRetDictTypec Csg}|D]W\}}t|ttfrR|d|d|D]4}|dvr-|dd|Dqt|trHt|dkrH|d|dd |d q|d|qq|d|d |qd |S) Nz* :)subjectissuercss(|]}d|dd|dVqdS)* rrTrNr/)rLsub_itemr/r/r0 s&z%format_certificate..rrrTrrX)items isinstancelisttupleappendextendr{r\)rr^keyrMitemr/r/r0format_certificates  rr?infotyping.Mapping[str, typing.Any]verbosecCstj}|dkr|r|d}|d|dS|dkr9|r9|d}|d}|d|dd |d dS|d kr|r|d}|d }|}|} |} |} |d |d| d|d| | r}|d|t | dSdS|dkr|r|d} t | dddS|dkr|r|d} t | dddS|dkr|d\} }}}t | |||dS|dkr|d\}}d} d}t | |||dSdS)Nzconnection.connect_tcp.startedhostz* Connecting to zconnection.connect_tcp.complete return_value server_addrz* Connected to rz on port rzconnection.start_tls.complete ssl_objectz* SSL established using z / z* Selected ALPN protocol: z* Server certificate:z#http11.send_request_headers.startedrFFrNz"http2.send_request_headers.startedTz(http11.receive_response_headers.completez'http2.receive_response_headers.completesHTTP/2) r&r'r(r)get_extra_infor]cipher getpeercertselected_alpn_protocolrrrrs)r?rrr'rstreamrrr]r server_certalpnrFr`rbrdr6r/r/r0tracesH    "      rdownloadtyping.BinaryIOcCstj}||jd}tjddtjjddtj tj 5}dtj |j }|j|t|p6d|dud}|D]}|||j||jdqAWddS1s\wYdS) NzContent-Lengthz([progress.description]{task.description}z-[progress.percentage]{task.percentage:>3.0f}%) bar_widthzDownloading [bold]r)totalstart) completed)r&r'r(r)r6r7progressProgress BarColumnDownloadColumnTransferSpeedColumnmarkupescaper?add_taskrc iter_byteswriteupdatenum_bytes_downloaded)r2rr'content_lengthr description download_taskchunkr/r/r0download_responses,      "rctx click.Contextparamclick.Option | click.ParameterrM typing.AnycCs4|durdSzt|WStjytdw)NzNot valid JSON)rtloadsJSONDecodeErrorclick BadParameterrrrMr/r/r0 validate_jsons  rcCs2|dkrdS|\}}|dkrtjddd}||fS)NNN-PasswordT) hide_input)rprompt)rrrMusernamepasswordr/r/r0 validate_auth s rcCs |r|jrdSt|dS)N)resilient_parsingr1exitrr/r/r0 handle_helps  r)add_help_optionrZ)typez--methodz-mrYzRequest method, such as GET, POST, PUT, PATCH, DELETE, OPTIONS, HEAD, QUERY. [Default: GET, or POST if a request body is included])rhelpz--paramsz-pparamsTr)rmultiplerz --contentz-cr|rz--dataz-dr~rz--filesz-ffilesrb)moderz--jsonz-jrtr)rcallbackrz --headersz-hrz --cookiescookiesrz--authauthrr)rdefaultrrz--proxyproxyr)rrrz --timeouttimeoutg@rrfollow_redirectsr)is_flagrrz--verify/--no-verifyr )rrr!r")rrrrz --downloadwbr#z --verbosez-vz*Verbose. Show request as well as response.r$r%)ris_eager expose_valuerrlist[tuple[str, str]]list[tuple[str, click.File]]tuple[str, str] | Nonefloatverifytyping.BinaryIO | NonecCsJ|s|s |s |s |r dnd}z]t| | || dK}|j||t||t||||t|| | dtjt|did }|durAt||n ||j rLt |Wdn1sVwYWdn1sewYWn*t y}zt j }|dt|jd |td WYd}~nd}~wwt|jrd dSd dS) zU An HTTP command line client. Sends a request and displays the response. POSTGET)rrrHrr)r) rr|r~rrtr6rrr extensionsNz[red]z[/red]: rr)rrrdict functoolspartialrrreadr|rrr&r'r(r)r__name__sysr is_success)rZrYrr|r~rrtr6rrrrrrrHrrclientr2excr'r/r/r0main$sJ!   r)rr )r2rrr3)F)rFrGrHrIrr3) r`rarbrcrdrer6rfrr3)rFrGrHrIrr ) r`rarbrcrdrer6rfrr )r2rrr )rrrr3)r?r3rrrrIrr )r2rrrrr )rrrrrMrrr)rrrrrMrrr )$rZr3rYr3rrr|r3r~rrrrtr3r6rrrrrrr3rrrrIrrIrHrIrrrrIrr )4 __future__rrrtrr9rpygments.lexersr; pygments.util rich.consoler& rich.markup rich.progress rich.syntax rich.table_clientr _exceptionsr_modelsr _status_codesr TYPE_CHECKING httpcore2r1rEr_rirrrsrrr3_PCTRTT_PCTRTTTrrrrrrrrcommandargumentoptionFilerrIrr/r/r/r0sD       C      %       4