tf(dZddlZddlZddlmZmZmZmZddlm Z ddl m Z m Z ddl mZddlmZddlmZd d lmZmZd d lmZmZmZmZGd d e ZGdde ZdZdZdZdZ e ej!GddZ"dS)zD IProxyParser implementation for version two of the PROXY protocol. N)CallableTupleTypeUnion) implementer) ValueConstantValues)Literal)address)compat)_info _interfaces)InvalidNetworkProtocolInvalidProxyHeaderMissingAddressData convertErrorcjeZdZdZedZedZedZedZdS) NetFamilyz( Values for the 'family' field. r 0N) __name__ __module__ __qualname____doc__rUNSPECINETINET6UNIXb/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/protocols/haproxy/_v2parser.pyrrsV]4 F =  D M$  E =  DDDr"rcTeZdZdZedZedZedZdS) NetProtocolz& Values for 'protocol' field. rr N)rrrrrrSTREAMDGRAMr!r"r#r%r%)sG]1  F ]1  F M!  EEEr"r%LOCALPROXYceZdZdZdZdgZeedZdddddddZ dd Z d e d e e eje fe d ffdZede d e fdZede d e fdZede d ejfdZd S)V2Parserzn PROXY protocol version two header parser. Version two of the PROXY protocol is a binary format. s QUIT r)rr z!4s4s2Hz !16s16s2Hz !108s108s)!"12returnNcd|_dS)Nr")buffer)selfs r#__init__zV2Parser.__init__Ps  r"dataNNct|xj|z c_t|jdkrttjd|jddddz}t|j|krdS|jd||j|d}}d|_||}||fS)a Consume a chunk of data and attempt to parse it. @param data: A bytestring. @type data: bytes @return: A two-tuple containing, in order, a L{_interfaces.IProxyInfo} and any bytes fed to the parser that followed the end of the header. Both of these values are None until a complete header is parsed. @raises InvalidProxyHeader: If the bytes fed to the parser create an invalid PROXY header. rz!Hrr;Nr")r7lenrstructunpackparse)r8r:sizeheader remaininginfos r#feedz V2Parser.feedSs" t t{  b $&& &}T4;r"u#566q9B> t{  d " "< K. DEE0B  zz&!!i  r" bytestringcdddtj|DS)a7 Convert packed 32-bit IPv4 address bytes into a dotted-quad ASCII bytes representation of that address. @param bytestring: 4 octets representing an IPv4 address. @type bytestring: L{bytes} @return: a dotted-quad notation IPv4 address. @rtype: L{bytes} .c3bK|]*}dt|fzdV+dS)z%iasciiN)ordencode).0bs r# z(V2Parser._bytesToIPv4..}sN  34TSVVI  % %g . .      r")joinr iterbytes)rGs r# _bytesToIPv4zV2Parser._bytesToIPv4qsAyy  8>8H8T8T      r"ctj|dfdtdddDS)a= Convert packed 128-bit IPv6 address bytes into a colon-separated ASCII bytes representation of that address. @param bytestring: 16 octets representing an IPv6 address. @type bytestring: L{bytes} @return: a dotted-quad notation IPv6 address. @rtype: L{bytes} :c3xK|]4}t||dzdddV5dS)rxrKN)intrM)rNrO hexStrings r#rPz(V2Parser._bytesToIPv6..sb  Ia!a%i("-- 1 1 9 9' B B      r"rrrW)binasciib2a_hexrQrange)rGrZs @r# _bytesToIPv6zV2Parser._bytesToIPv6s[$Z00 yy    1b!__      r"linec |dd}d}ttt5t|dd}t|dd}dddn #1swxYwY||jkrt|t z|t z}}||jvs ||jvrt|j|tkrtj |ddS|t z|t z} }ttt5t|}t | } dddn #1swxYwY|tjus| t jurtj |ddS|j|} |ddt'j| z}|tjurtt&jt.5t'j| |\} } dddn #1swxYwYtj |t3j| dt3j| dSd} | t jurd} t2j}|j}|tjurt2j }|j!}tt&jt.5t'j| |}|\} } }}dddn #1swxYwYtj ||| || "||| || "|S) a Parse a bytestring as a full PROXY protocol header. @param line: A bytestring that represents a valid HAProxy PROXY protocol version 2 header. @type line: bytes @return: A L{_interfaces.IProxyInfo} containing the parsed data. @raises InvalidProxyHeader: If the bytestring does not represent a valid PROXY header. N r=rTCPUDP)#r IndexErrorrrLPREFIX_HIGH_LOWVERSIONSCOMMANDS _LOCALCOMMANDr ProxyInfo ValueErrorrr lookupByValuer%rADDRESSFORMATSr?calcsizer errorrr@r UNIXAddressrstripr( IPv4AddressrSr IPv6Addressr^decode)clsr_prefixaddrInfoversionCommand familyProtoversioncommandfamilynetproto addressFormatsourcedestaddrTypeaddrCls addrParserrEsPortdPorts r#rAzV2Parser.parses?crc *&8 9 9 + +!be--Nd2b5k**K  + + + + + + + + + + + + + + + SZ  $&& &)E1>D3H #, & &'*E*E$&& & < M 1 1?4t44 4&. d0B *&< = = ; ;,,V44F"00::H ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; Y% % %[5G)G)G?4t44 4*;7 R&/-"@"@@@A Y^ # #fl,>?? F F%}]HEE  F F F F F F F F F F F F F F F?#FMM'$:$:;;#DKK$8$899  ;@ {( ( (H   03/? Y_ $ $)G)J &,(: ; ; . .=99D)- &FD% . . . . . . . . . . . . . . .  GHjj0077995 A A GHjj..5577 ? ?   sG/A""A&)A&5EEE+HHH L  L L )r5N)rrrrrgrjrl _PROXYCOMMANDrkrpr9bytesrrrrmrF staticmethodrSr^ classmethodrAr!r"r#r.r.9sA AFtH ]33H        N!! uU_e+,eJ.?? @!!!!<    5    \    5   \ "E E 5?E E E [E E E r"r.)#rr[r?typingrrrrzope.interfacer constantlyrr typing_extensionsr twisted.internetr twisted.pythonr rr _exceptionsrrrrrr%rhrirlr IProxyParserr.r!r"r#rs  ////////////&&&&&&,,,,,,,,%%%%%%$$$$$$!!!!!! &    [ %&&_ _ _ _ _ _ _ '&_ _ _ r"