o b]@sdZddlmZmZddlmZddlmZddlm Z ddl m Z ddl m Z dd lmZdd lmZGd d d e jZGd dde jZdejdefddZdS)z@ Protocol wrapper that provides HAProxy PROXY protocol support. )OptionalUnion) interfaces)_WrapperServerEndpoint)policies)_info)InvalidProxyHeader)V1Parser)V2Parsercs`eZdZdZdejdejffdd Zde ddfd d Z dej fd d Z dej fd dZ ZS)HAProxyProtocolWrappera A Protocol wrapper that provides HAProxy support. This protocol reads the PROXY stream header, v1 or v2, parses the provided connection data, and modifies the behavior of getPeer and getHost to return the data provided by the PROXY header. factorywrappedProtocolcst||d|_d|_dSN)super__init__ _proxyInfo_parser)selfr r __class__D/usr/lib/python3/dist-packages/twisted/protocols/haproxy/_wrapper.pyrs zHAProxyProtocolWrapper.__init__datareturnNcCs|jdur |j|S|j}|durPt|dkr4|ddtjkr4t|ddd@dkr4t|_}nt|dkrJ|ddtj krJt|_}n| dSz| |\|_}|rd|j|WdSWdSt yt| YdSw)N ) rr dataReceivedrlenr PREFIXordr PROXYSTRloseConnectionfeedr )rrparser remainingrrrr"$s(    z#HAProxyProtocolWrapper.dataReceivedcC*|jr |jjr |jjS|jsJ|jSr)rsource transportgetPeerrrrrr.=  zHAProxyProtocolWrapper.getPeercCr+r)r destinationr-getHostr/rrrr2Cr0zHAProxyProtocolWrapper.getHost)__name__ __module__ __qualname____doc__rWrappingFactoryr IProtocolrbytesr"IAddressr.r2 __classcell__rrrrr sr c@s"eZdZdZeZdefddZdS)HAProxyWrappingFactoryzL A Factory wrapper that adds PROXY protocol support to connections. rcCs.tj|jr |j}n|jjj}|dS)z Annotate the wrapped factory's log prefix with some text indicating the PROXY protocol is in use. @rtype: C{str} z (PROXY))rILoggingContext providedBywrappedFactory logPrefixrr3)rr@rrrr@Qs   z HAProxyWrappingFactory.logPrefixN)r3r4r5r6r protocolstrr@rrrrr<Jsr<wrappedEndpointrcCs t|tS)a Wrap an endpoint with PROXY protocol support, so that the transport's C{getHost} and C{getPeer} methods reflect the attributes of the proxied connection rather than the underlying connection. @param wrappedEndpoint: The underlying listening endpoint. @type wrappedEndpoint: L{IStreamServerEndpoint} @return: a new listening endpoint that speaks the PROXY protocol. @rtype: L{IStreamServerEndpoint} )rr<)rCrrr proxyEndpoint_s rDN)r6typingrrtwisted.internetrtwisted.internet.endpointsrtwisted.protocolsrr _exceptionsr _v1parserr _v2parserr ProtocolWrapperr r7r<IStreamServerEndpointrDrrrrs        6