o þâf%Uã@sžddlmZddlZddlZddlZddlZddlZddlmZddl m Z dej vr3ddl Z ej ZneZGdd„deƒZdd „Zed krMejd d dSdS) é)Úunicode_literalsN©Ú xmlrpclib©ÚSupervisorTransportÚ END_TO_ENDc@sÔeZdZdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd „Zd!d"„Zd#d$„Zd%d&„Zd'd(„Zd)d*„Zd+d,„Zd-d.„Zd/d0„Zd1d2„Zd3S)4Ú EndToEndTestscCsxd}d}t td¡}ddd|g}z&|tj|<tjtj|dd}|  |j t j ¡|  |d |¡Wtj|=d Stj|=w) zÒWhen an environment variable whose value contains a percent sign is present in the environment before supervisord starts, the value is passed to the child without the percent sign being mangled.ÚSUPERVISOR_TEST_1441Bzfoo_%s_%_%%_%%%_%2_barzfixtures/issue-291a.confú-músupervisor.supervisordú-cúutf-8©Úencodingú=N)Ú pkg_resourcesÚresource_filenameÚ__name__ÚosÚenvironÚpexpectÚspawnÚsysÚ executableÚ addCleanupÚkillÚsignalÚSIGINTÚ expect_exact)ÚselfÚkeyÚvalÚfilenameÚargsÚ supervisord©r%úS/var/www/html/venv/lib/python3.10/site-packages/supervisor/tests/test_end_to_end.pyÚ;test_issue_291a_percent_signs_in_original_env_are_preserveds   zIEndToEndTests.test_issue_291a_percent_signs_in_original_env_are_preservedcCsšt td¡}ddd|g}tjtj|dd}| |jt j ¡|  d¡|  d¡dd d|d d g}tjtj|dd}| |jt j ¡|  d ¡|  tj ¡d S)z‚When an environment variable is set in the [supervisord] section, it should be put into the environment of the subprocess.zfixtures/issue-550.confr r r r rz(success: print_env entered RUNNING statez+exited: print_env (exit status 0; expected)úsupervisor.supervisorctlz tail -100000Ú print_envzTHIS_SHOULD=BE_IN_CHILD_ENVN©rrrrrrrrrrrrÚexpectÚEOF)rr"r#r$Ú supervisorctlr%r%r&Útest_issue_550's     zEndToEndTests.test_issue_550cCó¢t td¡}ddd|g}tjtj|dd}| |jt j ¡|  d¡ddd|d d d g}tjtj|dd}| |jt j ¡t d d ƒD] }d|}|j |ddqAdS)zeWhen a log file has Unicode characters in it, 'supervisorctl tail -f name' should still work.zfixtures/issue-565.confr r r r rú$success: hello entered RUNNING stater(Útailú-fÚhelloééu'The Øresund bridge ends in Malmö - %dé©ÚtimeoutN© rrrrrrrrrrrrÚrange©rr"r#r$r-ÚiÚliner%r%r&Útest_issue_5657ó   þzEndToEndTests.test_issue_565cCst td¡}ddd|g}tjtj|dd}| |jt j ¡tj ddk}|r)d }nd }|j d |d d |j dd d |rF|j ddd dSdS)z‡When a process outputs something on its stdout or stderr file descriptor that is not valid UTF-8, supervisord should not crash.zfixtures/issue-638.confr r r r rréÚÚbzUndecodable: %s'\x88\n'r6r7z)received SIGCH?LD indicating a child quitzVgave up: produce-unicode-error entered FATAL state, too many start retries too quicklyé<N)rrrrrrrrrrrÚ version_inforr+)rr"r#r$Úis_py2Úb_prefixr%r%r&Útest_issue_638Hs   ÿþzEndToEndTests.test_issue_638cCsht td¡}ddd|g}tjtj|dd}| |jt j ¡t dƒD]}|j dd d |j d d d q!d S)zSWhen Supervisor is run on Python 3, the eventlistener protocol should work.zfixtures/issue-663.confr r r r réÚOKREADYrCr7zBUSY -> ACKNOWLEDGEDr6N) rrrrrrrrrrrr:r)rr"r#r$r<r%r%r&Útest_issue_663[s   þzEndToEndTests.test_issue_663cCs¶t td¡}ddd|g}tjtj|dd}| |jt j ¡|j ddd dd d|d g}tjtj|dd}| |jt j ¡z |j d d d d}Wn tj ySd}Ynw| |¡dS)z¡When a subprocess name has Unicode characters, 'supervisord' should not send incomplete XML-RPC responses and 'supervisorctl status' should work.zfixtures/issue-664.confr r r r ru!test_öäü entered RUNNING staterCr7r(Ústatusutest_öäü\s+RUNNINGr6TFN©rrrrrrrrrrrrr+ÚExceptionPexpectÚ assertTrue©rr"r#r$r-Úseenr%r%r&Útest_issue_664fs  ÿzEndToEndTests.test_issue_664cCs^t td¡}ddd|g}tjtj|dd}| |jt j ¡|  d¡|  d¡|  tj ¡d S) zzWhen a subprocess enters the FATAL state, a one-line eventlistener can be used to signal supervisord to shut down.zfixtures/issue-733.confr r r r rz(gave up: nonexistent entered FATAL statez(received SIGTERM indicating exit requestNr*©rr"r#r$r%r%r&Útest_issue_733zs    zEndToEndTests.test_issue_733cCs®t td¡}ddd|g}tjtj|dd}| |jt j ¡|j ddd t d d d ƒ}t  d |¡}z d D]}|j d|¡}| |¡|j |dd q3W|j ¡dS|j ¡w)Nzfixtures/issue-835.confr r r r rúcat entered RUNNING staterCr7rAzunix:///tmp/issue-835.sockzhttp://anything/RPC2)õ"The Øresund bridge ends in Malmör3Úcatr6)rrrrrrrrrrrrrrÚ ServerProxyÚ supervisorÚsendProcessStdinrNÚ connectionÚclose)rr"r#r$Ú transportÚserverÚsÚresultr%r%r&Útest_issue_835…s     ýzEndToEndTests.test_issue_835cCsàt td¡}ddd|g}tjtj|dd}| |jt j ¡|j ddd dd d|d d g}tjtj|dd}| |jt j ¡zd D]}|  |¡|j |dd |  |¡|  |¡q@d}Wn tj yhd}Ynw| |¡dS)Nzfixtures/issue-836.confr r r r rrTrCr7r(ÚfgrV)ÚHiÚHellorUTF)rrrrrrrrrrrrÚsendlinerMrN)rr"r#r$r-r^rPr%r%r&Útest_issue_836•s&     ÿzEndToEndTests.test_issue_836cCóHt td¡}ddd|g}tjtj|dd}| |jt j ¡|  d¡dS) zyA percent sign can be used in a command= string without being expanded if it is escaped by a second percent sign.zfixtures/issue-986.confr r r r rz2dhcrelay -d -q -a %h:%p %P -i Vlan1000 192.168.0.1N© rrrrrrrrrrrrrRr%r%r&Ú1test_issue_986_command_string_with_double_percentªs  z?EndToEndTests.test_issue_986_command_string_with_double_percentcCs¦t td¡}ddd|g}tjtj|dd}| |jt j ¡|j ddd dd d|d g}tjtj|dd}z |j d d d d}Wn tj yKd}Ynw| |¡dS)zLWhen run on Python 3, the 'supervisorctl avail' command should work.zfixtures/issue-1054.confr r r r rrTrCr7r(Úavailzcat\s+in use\s+autor6TFNrLrOr%r%r&Útest_issue_1054³s  ÿzEndToEndTests.test_issue_1054cCrf) z¯When the [supervisord] section has a variable defined in environment=, that variable should be able to be used in an %(ENV_x) expansion in a [program] section.zfixtures/issue-1170a.confr r r r rzset from [supervisord] sectionNrgrRr%r%r&Útest_issue_1170aÄs  zEndToEndTests.test_issue_1170acCrf) záWhen the [supervisord] section has a variable defined in environment=, and a variable by the same name is defined in enviroment= of a [program] section, the one in the [program] section should be used.zfixtures/issue-1170b.confr r r r rzset from [program] sectionNrgrRr%r%r&Útest_issue_1170bÎó  zEndToEndTests.test_issue_1170bcCrf) zîWhen the [supervisord] section has a variable defined in environment=, and a variable by the same name is defined in enviroment= of an [eventlistener] section, the one in the [eventlistener] section should be used.zfixtures/issue-1170c.confr r r r rz set from [eventlistener] sectionNrgrRr%r%r&Útest_issue_1170cÙrmzEndToEndTests.test_issue_1170ccCsLt td¡}ddd|g}tjtj|dd}| |jt j ¡|j ddd d S) zïWhen the main log file does not need rotation (logfile_maxbyte=0) then the non-rotating logger will be used to avoid an IllegalSeekError in the case that the user has configured a non-seekable file like /dev/stdout.zfixtures/issue-1224.confr r r r rrTrCr7NrgrRr%r%r&Útest_issue_1224äs  zEndToEndTests.test_issue_1224cCr/)úbWhen 'supervisorctl tail -f name' is run and the log contains unicode, it should not fail.zfixtures/issue-1231a.confr r r r rr0r(r1r2r3r4r5õ%d - hash=57d94b…381088r6r7Nr9r;r%r%r&Útest_issue_1231aïr?zEndToEndTests.test_issue_1231ac Cst td¡}ddd|g}tjtj|dd}| |jt j ¡|  d¡ddd|d d d g}t j  ¡}d |d <tjtj|d|d}| |jt j ¡tjdd…dkr]|jddd|jdddtddƒD]#}d|}z |j |ddWqbtjjy…| d|j¡YdSwdS)rpzfixtures/issue-1231b.confr r r r rr0r(r1r2r3ÚoopsÚLANG©rÚenvNrH©r@éú'Warning: sys.stdout.encoding is set to r6r7úUnicode output may fail.r4r5rqz:Unable to write Unicode to stdout because it has encoding )rrrrrrrrrrrrrrÚcopyrDr+r:Ú exceptionsr,ÚassertInÚbefore)rr"r#r$rvr-r<r=r%r%r&Útest_issue_1231bs8     ÿÿþüüzEndToEndTests.test_issue_1231bcCsÀt td¡}ddd|g}tjtj|dd}| |jt j ¡|  d¡ddd|d d g}t j  ¡}d |d <tjtj|d|d }| |jt j ¡tjdd…dkr^|jddd|jddddSdS)rpzfixtures/issue-1231c.confr r r r rr0r(r1r3rsrtruNrHrwryr6r7rz)rrrrrrrrrrrrrrr{rDr+)rr"r#r$rvr-r%r%r&Útest_issue_1231c"s$     ÿÿýzEndToEndTests.test_issue_1231ccCs˜gd¢}tjtj|dd}| |jtj¡| d¡| d¡|  tj ¡gd¢}tjtj|dd}| |jtj¡| d¡| d¡|  tj ¡d S) z`When -? is given to supervisord or supervisorctl, help should be displayed like -h does.)r r ú-?r rz(supervisord -- run a set of applicationsz(-l/--logfile FILENAME -- use FILENAME as)r r(rz%supervisorctl -- control applicationsz(-i/--interactive -- start an interactiveN) rrrrrrrrrr+r,)rr#r$r-r%r%r&Útest_issue_1251:s     zEndToEndTests.test_issue_1251cCsˆt td¡}ddd|g}tjtj|dd}| |jt j ¡|  d¡dtj|f}tjd d|gdd}| |jt j ¡|j d d d d S)z¢When the output of 'supervisorctl tail -f worker' is piped such as 'supervisor tail -f worker | grep something', 'supervisorctl' should not crash.zfixtures/issue-1298.confr r r r rz#success: spew entered RUNNING statezC'%s' -m supervisor.supervisorctl -c '%s' tail -f spew | /bin/cat -uz/bin/shz spewage 2r6r7N) rrrrrrrrrrrrr+)rr"r#r$ÚcmdÚbashr%r%r&Útest_issue_1298Ks   ÿzEndToEndTests.test_issue_1298cCóLgd¢}tjtj|dd}| |jtj¡| tj ¡|  |j   ¡d¡dS)z\When pidproxy is given a command to run that has no arguments, it runs that command.)r úsupervisor.pidproxyúnonexistent-pidfileú /bin/echor rrAN© rrrrrrrrr+r,Ú assertEqualr~Ústrip©rr#Úpidproxyr%r%r&Ú)test_issue_1418_pidproxy_cmd_with_no_args\ó  z7EndToEndTests.test_issue_1418_pidproxy_cmd_with_no_argscCr†)zYWhen pidproxy is given a command to run that has arguments, it runs that command.)r r‡rˆr‰Ú1Ú2r rz1 2NrŠrr%r%r&Ú&test_issue_1418_pidproxy_cmd_with_argserz4EndToEndTests.test_issue_1418_pidproxy_cmd_with_argsc Có¦t td¡}ddd|g}tjtj|dd}| |jt j ¡|  d¡dd l m }dd lm}|d d d ƒ}z| d |¡}|j ¡}W| ¡n| ¡w| |d¡dS)zfWhen no identifier is supplied on the command line or in the config file, the default is used.zfixtures/issue-1483a.confr r r r rúsupervisord started with pidrrrrAzunix:///tmp/issue-1483a.sockú"http://transport.ignores.host/RPC2rXN©rrrrrrrrrrrrÚsupervisor.compatrÚsupervisor.xmlrpcrrWrXÚgetIdentificationr[r‹© rr"r#r$rrr\r]Úidentr%r%r&Ú#test_issue_1483a_identifier_defaultnó        z1EndToEndTests.test_issue_1483a_identifier_defaultc Cr”)zpWhen the identifier is supplied in the config file only, that identifier is used instead of the default.zfixtures/issue-1483b.confr r r r rr•rrrrAzunix:///tmp/issue-1483b.sockr–Úfrom_config_fileNr—r›r%r%r&Ú,test_issue_1483b_identifier_from_config_fileržz:EndToEndTests.test_issue_1483b_identifier_from_config_filec Csªt td¡}ddd|ddg}tjtj|dd}| |jt j ¡|  d ¡d d l m }d d lm}|d d dƒ}z| d|¡}|j ¡}W| ¡n| ¡w| |d¡dS)z~When an identifier is supplied in both the config file and on the command line, the one from the command line is used.zfixtures/issue-1483c.confr r r z-iÚfrom_command_liner rr•rrrrAzunix:///tmp/issue-1483c.sockr–Nr—r›r%r%r&Ú-test_issue_1483c_identifier_from_command_line”s       z;EndToEndTests.test_issue_1483c_identifier_from_command_lineN)rÚ __module__Ú __qualname__r'r.r>rGrJrQrSr`rerhrjrkrlrnrorrrr€r‚r…rr“rr r¢r%r%r%r&rs4       "   rcCst tjt¡S)N)ÚunittestÚ findTestCasesrÚmodulesrr%r%r%r&Ú test_suite§sr¨Ú__main__)Ú defaultTest)Ú __future__rrrrr¥rr˜rr™rrrÚTestCaseÚ BaseTestCaseÚobjectrr¨rÚmainr%r%r%r&Ús(    ÿ