Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
doctorondemand
doctorondemand / supervisor python
Repository URL to install this package:
|
Version:
4.2.1 ▾
|
U
VƧ\k ã @ s d dl mZ d dlZd dlZd dlZd dlmZ d dlmZ G dd dejZ G dd dejZ
G d d
d
ejZ d d Z e
d
krejd d dS )é )ÚBytesION)ÚStringIO)Ú as_stringc @ s< e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
S )ÚChildUtilsTestsc C s* ddl m} |ddi}| |d k ¡ d S )Nr )ÚgetRPCInterfaceÚSUPERVISOR_SERVER_URLúhttp://localhost:9001)Úsupervisor.childutilsr Z
assertTrue)Úselfr Zrpc© r ú/./build/lib/supervisor/tests/test_childutils.pyÚtest_getRPCInterface s z$ChildUtilsTests.test_getRPCInterfacec C sF ddl m} |ddi}| |jd¡ | |jd¡ | |jd¡ d S )Nr ©ÚgetRPCTransportr r Ú ©r r Ú assertEqualZusernameZpasswordZ serverurl)r
r Útr r r Ú"test_getRPCTransport_no_uname_pass s
z2ChildUtilsTests.test_getRPCTransport_no_uname_passc C sN ddl m} dddd}||}| |jd¡ | |jd¡ | |jd¡ d S )Nr r r ZchrismZabc123)r ZSUPERVISOR_USERNAMEZSUPERVISOR_PASSWORDr )r
r Úenvr r r r Ú$test_getRPCTransport_with_uname_pass s þz4ChildUtilsTests.test_getRPCTransport_with_uname_passc C s. ddl m} d}||}| |ddd¡ d S )Nr )Ú get_headersza:1 b:2Ú1Ú2©ÚaÚb)r r r )r
r ÚlineÚresultr r r Útest_get_headers s z ChildUtilsTests.test_get_headersc C s> ddl m} d}||\}}| |ddd¡ | |d¡ d S )Nr )Ú eventdataza:1 b:2
thedata
r r r zthedata
)r r r )r
r ÚpayloadÚheadersÚdatar r r Útest_eventdata& s
z ChildUtilsTests.test_eventdatac C s. ddl m} t d¡}||}| |d¡ d S )Nr )Ú get_asctime) iÙ é é é é é r r éÿÿÿÿz2009-01-18 22:14:07,000)r r% ÚtimeÚmktimer )r
r% Z timestampr r r r Útest_get_asctime- s
z ChildUtilsTests.test_get_asctimeN) Ú__name__Ú
__module__Ú __qualname__r
r r r r$ r. r r r r r s
r c @ s$ e Zd Zdd Zdd Zdd ZdS )Ú!TestProcessCommunicationsProtocolc C sR ddl m} t }| d|¡ ddlm} |j}|j}| | ¡ |d | ¡ d S ©Nr )Úpcomms hello)ÚProcessCommunicationEvent)
r r4 r ÚsendÚsupervisor.eventsr5 Ú BEGIN_TOKENÚ END_TOKENr Úgetvalue)r
r4 Ústdoutr5 ÚbeginÚendr r r Ú test_send4 s z+TestProcessCommunicationsProtocol.test_sendc C sj ddl m} tj}zJt }t_| d¡ ddlm} |j}|j}| |
¡ |d | ¡ W 5 |t_X d S r3 ) r r4 Úsysr; r r7 r5 r8 r9 r r: ©r
r4 ÚoldÚior5 r< r= r r r Ú test_stdout= s
z-TestProcessCommunicationsProtocol.test_stdoutc C sj ddl m} tj}zJt }t_| d¡ ddlm} |j}|j}| |
¡ |d | ¡ W 5 |t_X d S r3 ) r r4 r? Ústderrr r7 r5 r8 r9 r r: r@ r r r Ú test_stderrJ s
z-TestProcessCommunicationsProtocol.test_stderrN)r/ r0 r1 r> rC rE r r r r r2 3 s
r2 c @ s4 e Zd Zdd Zdd Zdd Zdd Zd d
Zd S ) ÚTestEventListenerProtocolc C sf ddl m} G dd d}| }t }| ||¡\}}| |ddi¡ | |d¡ | | ¡ d¡ d S ) Nr ©Úlistenerc @ s e Zd Zdd Zdd ZdS )z2TestEventListenerProtocol.test_wait.<locals>.Dummyc S s dS )Nzlen:5r )r
r r r Úreadline[ s z;TestEventListenerProtocol.test_wait.<locals>.Dummy.readlinec W s dS )NÚhellor )r
Zignoredr r r Úread] s z7TestEventListenerProtocol.test_wait.<locals>.Dummy.readN)r/ r0 r1 rI rK r r r r ÚDummyZ s rL ÚlenÚ5rJ zREADY
)r rH r Úwaitr r: )r
rH rL Ústdinr; r" r! r r r Ú test_waitX s z#TestEventListenerProtocol.test_waitc C sF ddl m} ddlm} t|j}t }| |¡ | | ¡ |¡ d S )Nr rG ©ÚPEventListenerDispatcher)
r rH Úsupervisor.dispatchersrS r ZREADY_FOR_EVENTS_TOKENr Zreadyr r: )r
rH rS Útokenr; r r r Ú
test_tokenf s
z$TestEventListenerProtocol.test_tokenc C sJ ddl m} ddlm} t|j}t }| |¡ | | ¡ |d ¡ d S )Nr rG rR z2
OK)
r rH rT rS r ÚRESULT_TOKEN_STARTr Úokr r: ©r
rH rS r< r; r r r Útest_okn s
z!TestEventListenerProtocol.test_okc C sJ ddl m} ddlm} t|j}t }| |¡ | | ¡ |d ¡ d S )Nr rG rR z4
FAIL)
r rH rT rS r rW r Zfailr r: rY r r r Ú test_failv s
z#TestEventListenerProtocol.test_failc C s^ ddl m} ddlm} t|j}t }d}| ||¡ d|t||f }| |
¡ |¡ d S )Nr rG rR zthe body data ya fool
z%s%s
%s) r rH rT rS r rW r r6 rM r r: )r
rH rS r< r; ÚmsgZexpectedr r r r> ~ s
z#TestEventListenerProtocol.test_sendN)r/ r0 r1 rQ rV rZ r[ r> r r r r rF W s
rF c C s t tjt ¡S )N)ÚunittestZ
findTestCasesr? Úmodulesr/ r r r r Ú
test_suite s r_ Ú__main__)Z defaultTest)rB r r? r, r] Zsupervisor.compatr r ZTestCaser r2 rF r_ r/ Úmainr r r r Ú<module> s +$2