o àý°jå ã@s<ddlZddlmZddlmZdZdZGdd„deƒZdS)éN)ÚLOG)Ú SocksRelayÚHTTPSocksRelays c@s`eZdZdZdZdd„Zedd„ƒZdd„Zd d „Z d d „Z d d„Z dd„Z dd„Z dd„ZdS)rzHTTP Socks PluginÚHTTPcCst |||||¡d|_dS)Ni )rÚ__init__Ú packetSize)ÚselfÚ targetHostÚ targetPortÚ socksSocketÚ activeRelays©r ú©/root/aizidognhua/tmp/workspace/projects/ec89d86c-575f-41c9-af57-ac45cbdbf775/venv/lib/python3.10/site-packages/impacket/examples/ntlmrelayx/servers/socksplugins/http.pyr!s zHTTPSocksRelay.__init__cCsdS)NéPr r r r rÚgetProtocolPort%szHTTPSocksRelay.getProtocolPortcCsdS)Nr )rr r rÚinitConnection)szHTTPSocksRelay.initConnectionc Csˆ|j |j¡}| |¡}z…|d}d|vrtƒ‚t |dd…¡ d¡}| d¡d  ¡|_ d|j vrH|j  dd¡\}}d | d ¡d|f|_ |j |j vr€|j |j d d urht   d |j |j|jf¡WdSt  d|j |j|jf¡|j |j dj|_nt   d|j |j|jf¡WdSWnty­t  d¡gd¢}|j t |¡¡YdSw|jj|_| |¡}|j |¡| ¡d S)NÚ authorizationÚBasicéÚasciiú:rú@éz%s/%sÚ.ÚinUseTz;HTTP: Connection for %s@%s(%s) is being used at the moment!Fz+HTTP: Proxying client session for %s@%s(%s)ÚprotocolClientz(HTTP: No session for %s@%s(%s) availablez>No authentication provided, prompting for basic authentication)sHTTP/1.1 401 UnauthorizedsFWWW-Authenticate: Basic realm="ntlmrelayx - provide a DOMAIN/username"sConnection: closeór)r ÚrecvrÚ getHeadersÚKeyErrorÚbase64Ú b64decodeÚdecodeÚsplitÚupperÚusernamer rÚerrorr r ÚinfoÚsessionÚdebugÚsendÚEOLÚjoinÚsockÚ relaySocketÚprepareRequestÚtransferResponse) rÚdataÚ headerDictÚcredsÚ basicAuthÚuserÚdomainÚreplyÚtosendr r rÚskipAuthentication,sJ    ÿ ÿ ÿü  û  z!HTTPSocksRelay.skipAuthenticationcCsH| tt¡}|d|… t¡dd…}dd„|Dƒ}dd„|Dƒ}|S)NrcSsg|]}| d¡‘qS)r)r")Ú.0Úheaderr r rÚ hsz-HTTPSocksRelay.getHeaders..cSs4i|]}| d¡d ¡| dd¡ddd…“qS)rrrN)r#Úlower)r:ÚhdrKeyr r rÚ is4z-HTTPSocksRelay.getHeaders..)Úfindr+r#)rr1Ú headerSizeÚheadersr2r r rrcs zHTTPSocksRelay.getHeadersc Cs |j |j¡}| tt¡}| |¡}z9t|dƒ}t|ƒ}|j  |¡|||dkrJ|j |j¡}|t|ƒ7}|j  |¡|||dks,WdSWdSt y…z |ddkrft   d¡|  ||¡n |j  |¡WYdSWYdSt y„|j  |¡YYdSww)Núcontent-lengthéztransfer-encodingÚchunkedz+Server sent chunked encoding - transferring)r.rrr@r+rÚintÚlenr r*rrr)ÚtransferChunked)rr1rArBÚbodySizeÚreadSizer r rr0ls.     ý   ý þ÷zHTTPSocksRelay.transferResponsec Cs | tt¡}|j |d|d…¡||dd…}t|d| t¡…dƒ}|dkry| t¡d|d}t|ƒ}|j |¡||krb||}|j t|j |ƒ¡}|t|ƒ7}|j |¡||ksD|j |j ¡}t|d| t¡…dƒ}|dks+t   d¡|j |¡dS)NrDéréz.Last chunk received - exiting chunked transfer) r@r+r r*rFrGr.rÚminrrr)) rr1rBrAÚbodyÚdatasizerIrJÚ maxReadSizer r rrH†s&   üô zHTTPSocksRelay.transferChunkedc Cs g}| t¡D] }|dkrnd| ¡vrqd| ¡vr"| d¡q| |¡q| d¡| | tt¡d¡t |¡}| tt¡}| |¡}z1t|dƒ}t|ƒ}|||dkry|j   |j ¡}|t|ƒ7}||7}|||dks]W|SW|St y…Y|Sw) NÚs authorizationsconnection: closezConnection: Keep-AliverrrCrD) r#r+r=Úappendr,r@rrFrGr rrr) rr1ÚresponseÚpartÚsenddatarArBrIrJr r rr/žs<         ýø üüzHTTPSocksRelay.prepareRequestcCs< |j |j¡}|dkrdS| |¡}|j |¡| ¡q)NTrQ)r rrr/r.r*r0)rr1r8r r rÚtunnelConnectionÄs  ÷zHTTPSocksRelay.tunnelConnectionN)Ú__name__Ú __module__Ú __qualname__Ú PLUGIN_NAMEÚ PLUGIN_SCHEMErÚ staticmethodrrr9rr0rHr/rVr r r rrs 7  &)r ÚimpacketrÚ0impacket.examples.ntlmrelayx.servers.socksserverrÚ PLUGIN_CLASSr+rr r r rÚs