Edit File: test_http.cpython-36.opt-1.pyc
3 �k�`Jc � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z d dlm Z d dl m Z d dl m Z d dl mZ d dl mZ d d l mZ d d l mZ d d l mZ d d lmZ G d d� d�ZG dd� deej�ZG dd� deej�ZG dd� dej�ZG dd� dej�ZG dd� dej�ZG dd� dej�Z G dd � d ej�Z G d d � d ej�Z G d d � d ej�Z d!Z G d"d#� d#ej�Z!G d$d%� d%ej�Z"G d&d'� d'ej�Z#G d(d)� d)ej�Z$G d*d+� d+�Z%G d,d-� d-�Z&d.d/� Z'e(d0k�r�ej)d/d1� dS )2� N)�as_bytes)� as_string)�sha1)�DummySupervisor)�PopulatedDummySupervisor)�DummyRPCInterfaceFactory)� DummyPConfig)� DummyOptions)� DummyRequest)� DummyLogger)� NOT_DONE_YETc @ s e Zd Zdd� Zdd� ZdS )� HandlerTestsc C s | j � |�S )N)�_getTargetClass)�self� supervisord� r � /usr/lib/python3.6/test_http.py�_makeOne s zHandlerTests._makeOnec C s: G dd� d�}t � }| j|�}| j|j||j��d� d S )Nc @ s e Zd Zdd� ZdS )z,HandlerTests.test_match.<locals>.FakeRequestc S s || _ d S )N)�uri)r r r r r �__init__ s z5HandlerTests.test_match.<locals>.FakeRequest.__init__N)�__name__� __module__� __qualname__r r r r r � FakeRequest s r T)r r � assertEqual�match�path)r r � supervisor�handlerr r r � test_match s zHandlerTests.test_matchN)r r r r r r r r r r s r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �LogtailHandlerTestsc C s ddl m} |S )Nr )�logtail_handler)�supervisor.httpr! )r r! r r r r $ s z#LogtailHandlerTests._getTargetClassc C sX t � }t|ddddd�}t|d|�}| j|�}tdd d d �}|j|� | j|jd� d S )NZprocess1z /bin/process1� z/tmp/process1.log)Zpriority�stdout_logfilez/logtail/process1i� )r r r r r �handle_requestr �_error)r �options�pconfigr r �requestr r r �'test_handle_request_stdout_logfile_none( s z;LogtailHandlerTests.test_handle_request_stdout_logfile_nonec C sT t � }t|ddd�}t|d|�}| j|�}tdd d d �}|j|� | j|jd� d S )N�fooz it/is/missingz /logtail/fooi� )r r r r r r% r r& )r r' r( r r r) r r r �*test_handle_request_stdout_logfile_missing2 s z>LogtailHandlerTests.test_handle_request_stdout_logfile_missingc C s� t j� ��}|j}t� }t|dd|d�}t|d|�}| j|�}tdd d d �}|j|� | j |j d � ddl m } | j |j d |jtj|�tj �� | j |j d d� | j |j d d � | j t|j�d � | j |jd � W d Q R X d S ) Nr+ )r$ z /logtail/foor )� http_datez Last-Modifiedz Content-Typeztext/plain;charset=utf-8zX-Accel-Buffering�nor# T)�tempfile�NamedTemporaryFile�namer r r r r r% r r& �supervisor.medusar- �headers�build_http_date�os�stat�ST_MTIME�len� producers�_done) r �f�tr' r( r r r) r- r r r �test_handle_request; s z'LogtailHandlerTests.test_handle_requestN)r r r r r* r, r= r r r r r # s r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �MainLogTailHandlerTestsc C s ddl m} |S )Nr )�mainlogtail_handler)r" r? )r r? r r r r N s z'MainLogTailHandlerTests._getTargetClassc C s: t � }| j|�}tdd d d �}|j|� | j|jd� d S )Nz /mainlogtaili� )r r r r% r r& )r r r r) r r r r* R s z?MainLogTailHandlerTests.test_handle_request_stdout_logfile_nonec C sB t � }d|j_tdd d d �}| j|�}|j|� | j|jd� d S )Nz /not/therez /mainlogtaili� )r r' �logfiler r r% r r& )r r r) r r r r r, Y s zBMainLogTailHandlerTests.test_handle_request_stdout_logfile_missingc C s� t � }tj� ��}|j}||j_| j|�}tdd d d �}|j|� | j |j d � ddl m } | j |j d |jtj|�tj �� | j |j d d� | j t|j�d� | j |jd� W d Q R X d S ) Nz /mainlogtailr )r- z Last-Modifiedz Content-Typeztext/plain;charset=utf-8r# T)r r/ r0 r1 r' r@ r r r% r r& r2 r- r3 r4 r5 r6 r7 r8 r9 r: )r r r; r< r r) r- r r r r= a s z+MainLogTailHandlerTests.test_handle_requestN)r r r r r* r, r= r r r r r> M s r> c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )�TailFProducerTestsc C s ddl m} |S )Nr )�tail_f_producer)r" rB )r rB r r r r s s z"TailFProducerTests._getTargetClassc C s | j � |||�S )N)r )r r) �filename�headr r r r w s zTailFProducerTests._makeOnec C s� t dd d d �}ddlm} tj� }|jdd � |j� | j||jd�}|j � }| j |dd � |jt dd �� |j� |j � }| j |dd � |j � }| j ||j � |j d� |j� |j � }| j |d� d S ) Nz /logtail/foor )�http� a�P � w�d z==> File truncated <== )r r rE r/ r0 �write�flushr r1 �morer r r �truncate)r r) rE r; �producer�resultr r r �test_handle_morez s$ z#TailFProducerTests.test_handle_morec C sr t dd d d �}tj� �B}|jtdd �� |j� | j||jd�}|jj � |j � }W d Q R X | j ||j � � d S )Nz /logtail/foo�arG ) r r/ r0 rJ r rK r r1 �file�closerL r )r r) r; rN rO r r r �test_handle_more_fd_closed� s z-TailFProducerTests.test_handle_more_fd_closedc C s� t dd d d �}tj� }|jtdd �� |j� | j||jd�}|j� }| j |dd � |j � t |jd�}z&|jtdd �� |j � |j� }W d t j |j� X | j |dd � d S )Nz /logtail/foorQ rG rF �wb� b)r r/ r0 rJ r rK r r1 rL r rS �openr5 �unlink)r r) r; rN rO �f2r r r �&test_handle_more_follow_file_recreated� s z9TailFProducerTests.test_handle_more_follow_file_recreatedc ! C s� t dd d d �}tj� }t|d��}|jdd � W d Q R X z| j||jd�}W d tj|j� X |j � }| j |dd � t|d��}|jt dd �� W d Q R X z |j � }| j |dd � W d tj|j� X d S )Nz /logtail/foorU rF rG rV ) r r/ �mktemprW rJ r r1 r5 rX rL r r )r r) rC r; rN rO r r r �!test_handle_more_follow_file_gone� s z4TailFProducerTests.test_handle_more_follow_file_goneN) r r r r r rP rT rZ r\ r r r r rA r s rA c @ sN e Zd Zdd� Zddd�Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z dS )� DeferringChunkedProducerTestsc C s ddl m} |S )Nr )�deferring_chunked_producer)r" r^ )r r^ r r r r � s z-DeferringChunkedProducerTests._getTargetClassNc C s | j � ||�S )N)r )r rN �footersr r r r � s z&DeferringChunkedProducerTests._makeOnec C s& t t�}| j|�}| j|j� t� d S )N)� DummyProducerr r r rL )r �wrappedrN r r r �test_more_not_done_yet� s z4DeferringChunkedProducerTests.test_more_not_done_yetc C s& t d�}| j|�}| j|j� d� d S )Ns hellos 5 hello )r` r r rL )r ra rN r r r �test_more_string� s z.DeferringChunkedProducerTests.test_more_stringc C s, t � }| j|ddgd�}| j|j� d� d S )NrF rV )r_ s 0 a b )r` r r rL )r ra rN r r r �test_more_nodata� s z.DeferringChunkedProducerTests.test_more_nodatac C s. t d�}| j|ddgd�}| j|j� d� d S )N� rF rV )r_ s 0 a b )r` r r rL )r ra rN r r r �test_more_nodata_footers� s z6DeferringChunkedProducerTests.test_more_nodata_footersc C s& t d�}| j|�}| j|j� d� d S )Nre s 0 )r` r r rL )r ra rN r r r �test_more_nodata_nofooters� s z8DeferringChunkedProducerTests.test_more_nodata_nofootersc C s | j d �}| j|j� d� d S )Nre )r r rL )r rN r r r �test_more_noproducer� s z2DeferringChunkedProducerTests.test_more_noproducer)N) r r r r r rb rc rd rf rg rh r r r r r] � s r] c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) � DeferringCompositeProducerTestsc C s ddl m} |S )Nr )� deferring_composite_producer)r" rj )r rj r r r r � s z/DeferringCompositeProducerTests._getTargetClassc C s | j � |�S )N)r )r r9 r r r r � s z(DeferringCompositeProducerTests._makeOnec C s( t t�}| j|g�}| j|j� t� d S )N)r` r r r rL )r ra rN r r r rb � s z6DeferringCompositeProducerTests.test_more_not_done_yetc C sR t d�}t d�}| j||g�}| j|j� d� | j|j� d� | j|j� d� d S )N�helloZgoodbyere )r` r r rL )r Zwrapped1Zwrapped2rN r r r rc � s z0DeferringCompositeProducerTests.test_more_stringc C s& t � }| j|g�}| j|j� d� d S )Nre )r` r r rL )r ra rN r r r rd � s z0DeferringCompositeProducerTests.test_more_nodataN)r r r r r rb rc rd r r r r ri � s ri c @ s6 e Zd Zdd� Zddd�Zdd� Zd d � Zd d � Zd S )� DeferringGlobbingProducerTestsc C s ddl m} |S )Nr )�deferring_globbing_producer)r" rm )r rm r r r r � s z.DeferringGlobbingProducerTests._getTargetClassr# � c C s | j � ||�S )N)r )r rN � buffer_sizer r r r s z'DeferringGlobbingProducerTests._makeOnec C s& t t�}| j|�}| j|j� t� d S )N)r` r r r rL )r ra rN r r r rb s z5DeferringGlobbingProducerTests.test_more_not_done_yetc C sX t ddd�}| j|dd�}| j|j� d� t ddd�}| j|dd�}| j|j� d� d S ) Nrk ZthereZguyr# )ro s hello�2 s hellothereguy)r` r r rL )r ra rN r r r rc s z/DeferringGlobbingProducerTests.test_more_stringc C s$ t � }| j|�}| j|j� d� d S )Nre )r` r r rL )r ra rN r r r rd s z/DeferringGlobbingProducerTests.test_more_nodataN� )rq )r r r r r rb rc rd r r r r rl � s rl c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )� DeferringHookedProducerTestsc C s ddl m} |S )Nr )�deferring_hooked_producer)r" rs )r rs r r r r s z,DeferringHookedProducerTests._getTargetClassc C s | j � ||�S )N)r )r rN Zfunctionr r r r s z%DeferringHookedProducerTests._makeOnec C s( t t�}| j|d �}| j|j� t� d S )N)r` r r r rL )r ra rN r r r rb s z3DeferringHookedProducerTests.test_more_not_done_yetc sZ t d�}g � � fdd�}| j||�}| j|j� d� | j� g � |j� | j� dg� d S )Nrk c s � j | � d S )N)�append)�bytes)�Lr r �callback' s z?DeferringHookedProducerTests.test_more_string.<locals>.callback� )r` r r rL )r ra rw rN r )rv r rc $ s z-DeferringHookedProducerTests.test_more_stringc sD t � }g � � fdd�}| j||�}| j|j� d� | j� dg� d S )Nc s � j | � d S )N)rt )ru )rv r r rw 2 s z?DeferringHookedProducerTests.test_more_nodata.<locals>.callbackre r )r` r r rL )r ra rw rN r )rv r rd / s z-DeferringHookedProducerTests.test_more_nodatac C s | j d d �}| j|j� d� d S )Nre )r r rL )r rN r r r rh 8 s z1DeferringHookedProducerTests.test_more_noproducerN) r r r r r rb rc rd rh r r r r rr s rr c @ sz e Zd Zdd� Zdddddf fdd �Zd d � Zd d � Zdd� Zdd� Zdd� Z dd� Z dd� Z dd� Z dd� Z d d � ZdS ) �DeferringHttpRequestTestsc C s ddl m} |S )Nr )�deferring_http_request)r" rz )r rz r r r r = s z)DeferringHttpRequestTests._getTargetClassNzGET / HTTP/1.0ZGET�/z1.0c C s | j � ||||||�S )N)r )r �channelZreqZcommandr �version�headerr r r r A s z"DeferringHttpRequestTests._makeOnec C s G dd� d�}|� S )Nc @ s e Zd ZdZdd� Zdd� ZdS )z7DeferringHttpRequestTests._makeChannel.<locals>.ChannelFc S s d| _ d S )NT)�closed)r r r r �close_when_doneQ s zGDeferringHttpRequestTests._makeChannel.<locals>.Channel.close_when_donec S s || _ d S )N)rN )r rN r r r �push_with_producerS s zJDeferringHttpRequestTests._makeChannel.<locals>.Channel.push_with_producerN)r r r r r� r� r r r r �ChannelO s r� r )r r� r r r � _makeChannelN s z&DeferringHttpRequestTests._makeChannelc C s. | j � }| j|dd�}|j� | j|j� d S )Nz1.0)r| r} )r� r �done� assertTruer )r r| �instr r r � test_done_http_10_nokeepaliveW s z7DeferringHttpRequestTests.test_done_http_10_nokeepalivec C s2 | j � }| j|ddgd�}|j� | j|j� d S )Nz1.0zConnection: Keep-Alive)r| r} r~ )r� r r� r� r )r r| r� r r r �-test_done_http_10_keepalive_no_content_length] s zGDeferringHttpRequestTests.test_done_http_10_keepalive_no_content_lengthc C sL | j � }| j|ddgd�}d|jd< |j� | j|d d� | j|j� d S )Nz1.0zConnection: Keep-Alive)r| r} r~ r# zContent-LengthZ Connectionz Keep-Alive)r� r � reply_headersr� r � assertFalser )r r| r� r r r �.test_done_http_10_keepalive_and_content_lengthh s zHDeferringHttpRequestTests.test_done_http_10_keepalive_and_content_lengthc C s2 | j � }| j|ddgd�}|j� | j|j� d S )Nz1.1zConnection: close)r| r} r~ )r� r r� r� r )r r| r� r r r �"test_done_http_11_connection_closet s z<DeferringHttpRequestTests.test_done_http_11_connection_closec C s8 | j � }| j|dd�}d|jd< |j� | j|j� d S )Nz1.1)r| r} Z notchunkedzTransfer-Encoding)r� r r� r� r� r )r r| r� r r r �+test_done_http_11_unknown_transfer_encoding~ s zEDeferringHttpRequestTests.test_done_http_11_unknown_transfer_encodingc C s8 | j � }| j|dd�}d|jd< |j� | j|j� d S )Nz1.1)r| r} ZchunkedzTransfer-Encoding)r� r r� r� r� r )r r| r� r r r �+test_done_http_11_chunked_transfer_encoding� s zEDeferringHttpRequestTests.test_done_http_11_chunked_transfer_encodingc C sB | j � }| j|dd�}d|_|j� | jd|k� | j|j� d S )Nz1.1)r| r} TzTransfer-Encoding)r� r � use_chunkedr� r� r� r )r r| r� r r r � test_done_http_11_use_chunked� s z7DeferringHttpRequestTests.test_done_http_11_use_chunkedc C s4 | j � }| j|dd�}d|_|j� | j|j� d S )Nz1.1)r| r} F)r� r r� r� r� r )r r| r� r r r �>test_done_http_11_wo_content_length_no_te_no_use_chunked_close� s zXDeferringHttpRequestTests.test_done_http_11_wo_content_length_no_te_no_use_chunked_closec C s. | j � }| j|d d�}|j� | j|j� d S )N)r| r} )r� r r� r� r )r r| r� r r r �test_done_http_09� s z+DeferringHttpRequestTests.test_done_http_09)r r r r r r� r� r� r� r� r� r� r� r� r� r r r r ry < s" ry c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )�DeferringHttpChannelTestsc C s ddl m} |S )Nr )�deferring_http_channel)r" r� )r r� r r r r � s z)DeferringHttpChannelTests._getTargetClassc C s | j � d d d d�S )N)�serverZconnZaddr)r )r r r r r � s z"DeferringHttpChannelTests._makeOnec C s( | j � }| j|jd� | j|jd� d S )Nr )r r �delay�last_writable_check)r r| r r r �0test_defaults_delay_and_last_writable_check_time� s zJDeferringHttpChannelTests.test_defaults_delay_and_last_writable_check_timec C s@ | j � }d|_t|_td }| j|j|d�� | j|jt� d S )N� r# )�now)r r� �_NOWr� r� �writabler )r r| �laterr r r �5test_writable_with_delay_is_False_if_elapsed_lt_delay� s zODeferringHttpChannelTests.test_writable_with_delay_is_False_if_elapsed_lt_delayc C sB | j � }d|_t|_t|j }| j|j|d�� | j|jt� d S )Nr� )r� )r r� r� r� r� r� r )r r| r� r r r �5test_writable_with_delay_is_False_if_elapsed_eq_delay� s zODeferringHttpChannelTests.test_writable_with_delay_is_False_if_elapsed_eq_delayc C sF | j � }d|_t|_t|j d }| j|j|d�� | j|j|� d S )Nr� g�������?)r� )r r� r� r� r� r� r )r r| r� r r r �4test_writable_with_delay_is_True_if_elapsed_gt_delay� s zNDeferringHttpChannelTests.test_writable_with_delay_is_True_if_elapsed_gt_delayc C s@ | j � }d|_t|_td }| j|j|d�� | j|j|� d S )Nr� i )r� )r r� r� r� r� r� r )r r| r� r r r �>test_writable_with_delay_is_True_if_system_time_goes_backwards� s zXDeferringHttpChannelTests.test_writable_with_delay_is_True_if_system_time_goes_backwardsN) r r r r r r� r� r� r� r� r r r r r� � s r� if��Wc @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dS )�"EncryptedDictionaryAuthorizedTestsc C s ddl m} |S )Nr )� encrypted_dictionary_authorizer)r" r� )r r� r r r r � s z2EncryptedDictionaryAuthorizedTests._getTargetClassc C s | j � |�S )N)r )r �dictr r r r � s z+EncryptedDictionaryAuthorizedTests._makeOnec C s | j i �}| j|jd�� d S )Nr+ �bar)r+ r� )r r� � authorize)r � authorizerr r r �test_authorize_baduser� s z9EncryptedDictionaryAuthorizedTests.test_authorize_baduserc C s" | j ddi�}| j|jd�� d S )Nr+ �passwordr� )r+ r� )r r� r� )r r� r r r �#test_authorize_gooduser_badpassword� s zFEncryptedDictionaryAuthorizedTests.test_authorize_gooduser_badpasswordc C s" | j ddi�}| j|jd�� d S )Nr+ r� )r+ r� )r r� r� )r r� r r r �$test_authorize_gooduser_goodpassword� s zGEncryptedDictionaryAuthorizedTests.test_authorize_gooduser_goodpasswordc C s" | j ddi�}| j|jd�� d S )Nr+ � pass:word)r+ r� )r r� r� )r r� r r r �/test_authorize_gooduser_goodpassword_with_colon� s zREncryptedDictionaryAuthorizedTests.test_authorize_gooduser_goodpassword_with_colonc C s6 dt td��j� }| jd|i�}| j|jd�� d S )Nz{SHA}r� r+ r� )r+ r� )r r � hexdigestr r� r� )r r� r� r r r �'test_authorize_gooduser_badpassword_sha� s zJEncryptedDictionaryAuthorizedTests.test_authorize_gooduser_badpassword_shac C s6 dt td��j� }| jd|i�}| j|jd�� d S )Nz{SHA}r� r+ )r+ r� )r r r� r r� r� )r r� r� r r r �(test_authorize_gooduser_goodpassword_sha s zKEncryptedDictionaryAuthorizedTests.test_authorize_gooduser_goodpassword_shaN) r r r r r r� r� r� r� r� r� r r r r r� � s r� c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )�SupervisorAuthHandlerTestsc C s ddl m} |S )Nr )�supervisor_auth_handler)r" r� )r r� r r r r s z*SupervisorAuthHandlerTests._getTargetClassc C s | j � ||�S )N)r )r r� r r r r r s z#SupervisorAuthHandlerTests._makeOnec C s0 | j ddid �}ddlm} | j|jj|� d S )NrQ r# r )r� )r r" r� r r� � __class__)r r r� r r r � test_ctor s z$SupervisorAuthHandlerTests.test_ctorc C s\ t dd d d �}tjtd��}dt|� g|_t� }| jddi|�}|j|� | j |j � d S )Nz/logtail/process1z user:passwordzAuthorization: Basic %s�userr� ) r �base64� b64encoder r r~ � DummyHandlerr r% r� �handled_request)r r) �encodedr � auth_handlerr r r �/test_handle_request_authorizes_good_credentials s zJSupervisorAuthHandlerTests.test_handle_request_authorizes_good_credentialsc C s\ t dd d d �}tjtd��}dt|� g|_t� }| jddi|�}|j|� | j |j � d S )Nz/logtail/process1zuser:pass:wordzAuthorization: Basic %sr� z pass:word) r r� r� r r r~ r� r r% r� r� )r r) r� r r� r r r �7test_handle_request_authorizes_good_password_with_colon s zRSupervisorAuthHandlerTests.test_handle_request_authorizes_good_password_with_colonc C s\ t dd d d �}tjtd��}dt|� g|_t� }| jddi|�}|j|� | j |j � d S )Nz/logtail/process1z wrong:wrongzAuthorization: Basic %sr� r� ) r r� r� r r r~ r� r r% r� r� )r r) r� r r� r r r �6test_handle_request_does_not_authorize_bad_credentials& s zQSupervisorAuthHandlerTests.test_handle_request_does_not_authorize_bad_credentialsN) r r r r r r� r� r� r� r r r r r� s r� c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) �LogWrapperTestsc C s ddl m} |S )Nr )� LogWrapper)r" r� )r r� r r r r 0 s z LogWrapperTests._getTargetClassc C s | j � |�S )N)r )r �loggerr r r r 4 s zLogWrapperTests._makeOnec C sD t � }| j|�}|jd� |j}| jt|�d� | j|d d� d S )Nzfoo r# r r+ )r r �log�datar r8 )r r� � log_wrapperZlogdatar r r �'test_strips_trailing_newlines_from_msgs7 s z7LogWrapperTests.test_strips_trailing_newlines_from_msgsc C sJ t � }| j|�}g }|j|_|jd� | jt|�d� | j|d d� d S )Nz Server Errorr# r )r r rt �errorr� r r8 )r r� r� �errorsr r r �(test_logs_msgs_with_error_at_error_level? s z8LogWrapperTests.test_logs_msgs_with_error_at_error_levelc C sJ t � }| j|�}g }|j|_|jd� | jt|�d� | j|d d� d S )NzGET /r# r )r r rt Ztracer� r r8 )r r� r� Ztracesr r r �'test_logs_other_messages_at_trace_levelH s z7LogWrapperTests.test_logs_other_messages_at_trace_levelN)r r r r r r� r� r� r r r r r� / s r� c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) �TopLevelFunctionTestsc C s� t � }||_dti fg|_t� }ddlm} |||�}z:x4|D ],\}}|j� |jd�}|d k r>t j |� q>W W d ddl m } | j � X |S )NZdummyr )�make_http_serversrR )� socket_map)r Zserver_configsr Zrpcinterface_factoriesr r" r� rS �getr5 rX Zasyncorer� �clear) r Zsconfigsr' r r� �servers�config�s� socketfiler� r r r �_make_http_serversR s z(TopLevelFunctionTests._make_http_serversc C sf dddd d dd�}y| j |g� | jd� W n4 tk r` } z| j|jd d� W Y d d }~X nX d S ) Ni� � localhostiGE �inet_http_server)�family�host�port�usernamer� �sectionznothing raisedr z Cannot determine socket type 999)r� Zfail� ValueErrorr �args)r r� �excr r r �(test_make_http_servers_socket_type_errord s z>TopLevelFunctionTests.test_make_http_servers_socket_type_errorc C s� t j� }tjddd d dd�}tj|ddd d dd�}| j||g�}| jt|�d � |d }| j|d |� |d }d d d ddg}| jdd� |jD �|� |d }| j|d |� |d }| jdd� |jD �|� d S )Nr� iGE r� )r� r� r� r� r� r� i� r# �unix_http_server)r� rR �chmod�chownr� r� r� r� r zSupervisor XML-RPC Handlerz Logtail HTTP Request Handlerz!Main Logtail HTTP Request Handlerz&Supervisor Web UI HTTP Request Handlerz Default HTTP Request Handlerc S s g | ] }|j �qS r )�IDENT)�.0�xr r r � <listcomp>� s zGTopLevelFunctionTests.test_make_http_servers_noauth.<locals>.<listcomp>c S s g | ] }|j �qS r )r� )r� r� r r r r� � s ���r� )r� r� ) r/ r[ �socket�AF_INET�AF_UNIXr� r r8 �handlers) r r� �inet�unixr� Zinetdatar� ZidentsZunixdatar r r � test_make_http_servers_noauthn s* z3TopLevelFunctionTests.test_make_http_servers_noauthc C s� t j� }tjdddddd�}tj|ddddd d �}| j||g�}| jt|�d � d d lm } x2|D ]*\}}x |j D ]}| j t ||�|� qrW qbW d S )Nr� iHE r� r� r� )r� r� r� r� r� r� i� r# r� )r� rR r� r� r� r� r� r� r )r� r� r� )r� r� ) r/ r[ r� r� r� r� r r8 r" r� r� r� � isinstance) r r� r� r� r� r� r� r� r r r r � test_make_http_servers_withauth� s z5TopLevelFunctionTests.test_make_http_servers_withauthN)r r r r� r� r� r� r r r r r� Q s r� c @ s e Zd Zdd� Zdd� ZdS )r� c C s d| _ d S )NF)r� )r r r r r � s zDummyHandler.__init__c C s d| _ d S )NT)r� )r r) r r r r% � s zDummyHandler.handle_requestN)r r r r r% r r r r r� � s r� c @ s e Zd Zdd� Zdd� ZdS )r` c G s t |�| _d S )N)�listr� )r r� r r r r � s zDummyProducer.__init__c C s | j r| j jd�S dS d S )Nr re )r� �pop)r r r r rL � s zDummyProducer.moreN)r r r r rL r r r r r` � s r` c C s t jtjt �S )N)�unittestZ findTestCases�sys�modulesr r r r r � test_suite� s r� �__main__)Z defaultTest)*r� r5 r6 r� r� r/ r� Zsupervisor.compatr r r Zsupervisor.tests.baser r r r r r r r" r r ZTestCaser r> rA r] ri rl rr ry r� r� r� r� r� r� r� r` r� r �mainr r r r �<module> sJ *%K%%t1"*"H
Back to File Manager