U
    [^"                     @   s   d Z ddlZddlZddlZddlZddlZddlmZ ddlmZ ddlm	Z	 ddl
mZ ddl
mZ ddlmZ eeZG d	d
 d
e	jZG dd dZG dd deZG dd dejZG dd deeZG dd deZG dd dejZdS )z1Support for standalone client challenge solvers.     N)BaseHTTPServer)http_client)socketserver)
challenges)crypto_util)Listc                   @   s(   e Zd ZdZdd Zdd Zdd ZdS )		TLSServerzGeneric TLS Server.c                 O   sj   | dd| _| jrtj| _ntj| _| di | _| dtj| _	| dd| _
tjj| f|| d S )Nipv6Fcertsmethodallow_reuse_addressT)popr	   socketAF_INET6address_familyAF_INETr
   r   Z_DEFAULT_SSL_METHODr   r   r   	TCPServer__init__selfargskwargs r   1/usr/lib/python3/dist-packages/acme/standalone.pyr      s    
 zTLSServer.__init__c                 C   s   t j| j| j| jd| _d S )N)r
   r   )r   Z	SSLSocketr   r
   r   r   r   r   r   
_wrap_sock&   s
      zTLSServer._wrap_sockc                 C   s   |    tj| S N)r   r   r   server_bindr   r   r   r   r   *   s    zTLSServer.server_bindN)__name__
__module____qualname____doc__r   r   r   r   r   r   r   r      s   r   c                   @   s   e Zd ZdZdZdZdS )ACMEServerMixinz"ACME server common settings mixin.z'ACME client standalone challenge solverTN)r   r   r    r!   server_versionr   r   r   r   r   r"   /   s   r"   c                   @   s0   e Zd ZdZdd Zdd Zdd Zdd	 Zd
S )BaseDualNetworkedServersa  Base class for a pair of IPv6 and IPv4 servers that tries to do everything
       it's asked for both servers, but where failures in one server don't
       affect the other.

       If two servers are instantiated, they will serve on the same port.
       c           
   
   O   s
  |d }g | _ g | _dD ]}z\||d< |d f|f |dd   }|f| }|||}	td|d |d |rpdnd W n^ tjk
r   | jrtd	|d |d |rdnd n td
|d |d |rdnd Y qX | j|	 |	j d }q| jstdd S )N   )TFr	   r      z$Successfully bound to %s:%s using %sZIPv6ZIPv4zCertbot wasn't able to bind to %s:%s using %s, this is often expected due to the dual stack nature of IPv6 socket implementations.z Failed to bind to %s:%s using %szCould not bind to IPv4 or IPv6.)threadsserversloggerdebugr   errorappendgetsockname)
r   ZServerClassserver_addressZremaining_argsr   ZportZ
ip_versionZnew_addressZnew_argsserverr   r   r   r   >   sB    	

  
 
  

z!BaseDualNetworkedServers.__init__c                 C   s2   | j D ]&}tj|jd}|  | j| qdS )z*Wraps socketserver.TCPServer.serve_forever)targetN)r(   	threadingZThreadserve_foreverstartr'   r,   r   r/   threadr   r   r   r2   h   s    
z&BaseDualNetworkedServers.serve_foreverc                 C   s   dd | j D S )z/Wraps socketserver.TCPServer.socket.getsocknamec                 S   s   g | ]}|j  qS r   )r   r-   ).0r/   r   r   r   
<listcomp>r   s     z9BaseDualNetworkedServers.getsocknames.<locals>.<listcomp>)r(   r   r   r   r   getsocknamesp   s    z%BaseDualNetworkedServers.getsocknamesc                 C   s:   | j D ]}|  |  q| jD ]}|  q"g | _dS )zpWraps socketserver.TCPServer.shutdown, socketserver.TCPServer.server_close, and
           threading.Thread.joinN)r(   ZshutdownZserver_closer'   joinr4   r   r   r   shutdown_and_server_closet   s    



z2BaseDualNetworkedServers.shutdown_and_server_closeN)r   r   r    r!   r   r2   r8   r:   r   r   r   r   r$   6   s
   *r$   c                   @   s   e Zd ZdZdd ZdS )
HTTPServerzGeneric HTTP Server.c                 O   s>   | dd| _| jrtj| _ntj| _tjj| f|| d S )Nr	   F)	r   r	   r   r   r   r   r   r;   r   r   r   r   r   r      s
    
zHTTPServer.__init__Nr   r   r    r!   r   r   r   r   r   r;      s   r;   c                   @   s   e Zd ZdZdddZdS )HTTP01ServerzHTTP01 Server.Fc                 C   s   t j| |tj|d|d d S )Nsimple_http_resources)r	   )r;   r   HTTP01RequestHandlerpartial_init)r   r.   Z	resourcesr	   r   r   r   r      s      zHTTP01Server.__init__N)Fr<   r   r   r   r   r=      s   r=   c                   @   s   e Zd ZdZdd ZdS )HTTP01DualNetworkedServersz`HTTP01Server Wrapper. Tries everything for both. Failures for one don't
       affect the other.c                 O   s   t j| tf|| d S r   )r$   r   r=   r   r   r   r   r      s    z#HTTP01DualNetworkedServers.__init__Nr<   r   r   r   r   rB      s   rB   c                   @   s`   e Zd ZdZeddZdd Zdd Zdd	 Z	d
d Z
dd Zdd Zdd Zedd ZdS )r@   zHTTP01 challenge handler.

    Adheres to the stdlib's `socketserver.BaseRequestHandler` interface.

    :ivar set simple_http_resources: A set of `HTTP01Resource`
        objects. TODO: better name?

    HTTP01Resourcezchall response validationc                 O   s(   | dt | _tjj| f|| d S )Nr?   )r   setr?   r   BaseHTTPRequestHandlerr   r   r   r   r   r      s    zHTTP01RequestHandler.__init__c                 G   s   t d| jd ||  dS )zLog arbitrary message.z	%s - - %sr   N)r)   r*   Zclient_address)r   formatr   r   r   r   log_message   s    z HTTP01RequestHandler.log_messagec                 C   s   |  d tj|  dS )zHandle request.zIncoming requestN)rG   r   rE   handler   r   r   r   rH      s    
zHTTP01RequestHandler.handlec                 C   s>   | j dkr|   n&| j dtjj r2|   n|   d S )N/)pathhandle_index
startswithr   ZHTTP01ZURI_ROOT_PATHhandle_simple_http_resource
handle_404r   r   r   r   do_GET   s
    


zHTTP01RequestHandler.do_GETc                 C   s6   |  d | dd |   | j| jj  dS )zHandle index page.   zContent-Type	text/htmlN)send_responsesend_headerend_headerswfilewriter/   r#   encoder   r   r   r   rK      s    
z!HTTP01RequestHandler.handle_indexc                 C   s4   | j tjdd | dd |   | jd dS )zHandler 404 Not Found errors.z	Not Found)messagezContent-typerQ   s   404N)rR   r   Z	NOT_FOUNDrS   rT   rU   rV   r   r   r   r   rN      s    zHTTP01RequestHandler.handle_404c                 C   sv   | j D ]R}|jj| jkr| d|jd | tj |   | j	
|j   dS q| d | d| j dS )z$Handle HTTP01 provisioned resources.zServing HTTP01 with token %rtokenNzNo resources to servez0%s does not correspond to any resource. ignoring)r?   ZchallrJ   rG   rW   rR   r   ZOKrT   rU   rV   Z
validation)r   resourcer   r   r   rM      s    


z0HTTP01RequestHandler.handle_simple_http_resourcec                 C   s   t j| |dS )zPartially initialize this handler.

        This is useful because `socketserver.BaseServer` takes
        uninitialized handler and initializes it with the current
        request.

        r>   )	functoolspartial)clsr?   r   r   r   rA      s    	 z!HTTP01RequestHandler.partial_initN)r   r   r    r!   collections
namedtuplerC   r   rG   rH   rO   rK   rN   rM   classmethodrA   r   r   r   r   r@      s    r@   )r!   r^   r[   Zloggingr   r1   Z	six.movesr   r   r   Zacmer   r   Zacme.magic_typingr   Z	getLoggerr   r)   r   r   r"   objectr$   r;   r=   rB   rE   r@   r   r   r   r   <module>   s&   
I	