`i[ddlmZddlZddlZddlZddlZddlmZddlmZddl m Z dej vr ddl Z ej ZneZGddeZdS) )unicode_literalsN)resource_filename xmlrpclibSupervisorTransport END_TO_ENDceZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdS) EndToEndTestscdd}d}ttd}ddd|g} |tj|<t jt j|d}||j tj | |d z|ztj|=d S#tj|=wxYw) zWhen 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-msupervisor.supervisord-cutf-8encoding=N) r __package__osenvironpexpectspawnsys executable addCleanupkillsignalSIGINT expect_exact)selfkeyvalfilenameargs supervisords t/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/supervisor/tests/test_end_to_end.py;test_issue_291a_percent_signs_in_original_env_are_preservedzIEndToEndTests.test_issue_291a_percent_signs_in_original_env_are_preserveds&&$[2LMM.h? !BJsO!-wOOOK OOK,fm < < <  $ $S3Y_ 5 5 5 3 3    s A0B B/c ttd}ddd|g}tjtj|d}||jtj | d| ddd d|d d g}tjtj|d}||jtj | d | tj d S)zWhen an environment variable is set in the [supervisord] section, it should be put into the environment of the subprocess.zfixtures/issue-550.confrrrrrz(success: print_env entered RUNNING statez+exited: print_env (exit status 0; expected)supervisor.supervisorctlz tail -100000 print_envzTHIS_SHOULD=BE_IN_CHILD_ENVN rrrrrrrrrrr expectEOF)r!r$r%r& supervisorctls r'test_issue_550zEndToEndTests.test_issue_550&s%[2KLL.h?mCND7KKK   (&-888  !KLLL  !NOOO0$.R]^ cndWMMM   *FM:::""#@AAAW[)))))cttd}ddd|g}tjtj|d}||jtj | dddd|d d d g}tjtj|d}||jtj td d D]}d|z}| |ddS)zeWhen a log file has Unicode characters in it, 'supervisorctl tail -f name' should still work.zfixtures/issue-565.confrrrrr$success: hello entered RUNNING stater*tail-fhellou'The Øresund bridge ends in Malmö - %dtimeoutN rrrrrrrrrrr ranger!r$r%r&r/ilines r'test_issue_565zEndToEndTests.test_issue_5656s%[2KLL.h?mCND7KKK   (&-888  !GHHH0$&$PWX cndWMMM   *FM:::q! 9 9A ACKNOWLEDGEDr9N) rrrrrrrrrrr=r )r!r$r%r&r?s r'test_issue_663zEndToEndTests.test_issue_663Zs%[2KLL.h?mCND7KKK   (&-888q I IA  $ $Y $ ; ; ;  $ $%;R $ H H H H I Ir1cttd}ddd|g}tjtj|d}||jtj | dd dd d|d g}tjtj|d}||jtj  | d d d}n#tj $rd}YnwxYw| |dS)zWhen a subprocess name has Unicode characters, 'supervisord' should not send incomplete XML-RPC responses and 'supervisorctl status' should work.zfixtures/issue-664.confrrrrru!test_öäü entered RUNNING staterFr:r*statusutest_öäü\s+RUNNINGr9TFNrrrrrrrrrrr r-ExceptionPexpect assertTruer!r$r%r&r/seens r'test_issue_664zEndToEndTests.test_issue_664es%[2KLL.h?mCND7KKK   (&-888  !Db QQQ0$(K cndWMMM   *FM:::   !92 F F FDD'   DDD  sC!!C54C5cZttd}ddd|g}tjtj|d}||jtj | 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.confrrrrrz(gave up: nonexistent entered FATAL statez(received SIGTERM indicating exit requestNr,r!r$r%r&s r'test_issue_733zEndToEndTests.test_issue_733ys%[2KLL.h?mCND7KKK   (&-888  !KLLL  !KLLL7;'''''r1cLttd}ddd|g}tjtj|d}||jtj | dd td d d }tj d |} d D]I}|jd|}||| |d J |jdS#|jwxYw)Nzfixtures/issue-835.confrrrrrcat entered RUNNING staterFr:rDzunix:///tmp/issue-835.sockzhttp://anything/RPC2)"The Øresund bridge ends in Malmör6catr9)rrrrrrrrrrr rr ServerProxy supervisorsendProcessStdinrS connectionclose)r!r$r%r& transportserversresults r'test_issue_835zEndToEndTests.test_issue_835s($[2KLL.h?mCND7KKK   (&-888  !>>>>r1cttd}ddd|g}tjtj|d}||jtj | ddS) zWhen 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.confrrrrrz set from [eventlistener] sectionNrorXs r'test_issue_1170czEndToEndTests.test_issue_1170cso %[2MNN.h?mCND7KKK   (&-888  !CDDDDDr1cttd}ddd|g}tjtj|d}||jtj | dd d S) zWhen 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.confrrrrrr[rFr:NrorXs r'test_issue_1224zEndToEndTests.test_issue_1224st %[2LMM.h?mCND7KKK   (&-888  !s r'test_issue_1231azEndToEndTests.test_issue_1231as%[2MNN.h?mCND7KKK   (&-888  !GHHH0$&$PWX cndWMMM   *FM:::q! 9 9A.2D  & &tR & 8 8 8 8 9 9r1c2ttd}ddd|g}tjtj|d}||jtj | dddd|d d d g}tj }d |d <tjtj|d|}||jtj tjdddkr.|dd|ddt!ddD]V}d|z} | |d #tjj$r |d|jYdSwxYwdS)r}zfixtures/issue-1231b.confrrrrrr3r*r4r5r6oopsLANGrenvNrLrC'Warning: sys.stdout.encoding is set to r9r:Unicode output may fail.r7r8r~z:Unable to write Unicode to stdout because it has encoding )rrrrrrrrrrr rrcopyrGr-r= exceptionsr.assertInbefore)r!r$r%r&rr/r?r@s r'test_issue_1231bzEndToEndTests.test_issue_1231bs%[2MNN.h?mCND7KKK   (&-888  !GHHH0$&$PWXjooF  cndW*-///   *FM:::  BQB & ( (  !J)+ ! - - -  !;R H H Hq!  A.2D **4*<<<<%)    .+2444     sE  /FFcfttd}ddd|g}tjtj|d}||jtj | dddd|d d g}tj }d |d <tjtj|d| }||jtj tjdddkr0|dd|dddSdS)r}zfixtures/issue-1231c.confrrrrrr3r*r4r6rrrNrLrrr9r:r)rrrrrrrrrrr rrrrGr-)r!r$r%r&rr/s r'test_issue_1231czEndToEndTests.test_issue_1231c!s4%[2MNN.h?mCND7KKK   (&-888  !GHHH0$&'RjooF  cndW*-///   *FM:::  BQB & ( (  !J)+ ! - - -  !;R H H H H H ) (r1cRgd}tjtj|d}||jt j|d|d| tj gd}tjtj|d}||jt j|d|d| tj d S) z`When -? is given to supervisord or supervisorctl, help should be displayed like -h does.)rr-?rrz(supervisord -- run a set of applicationsz(-l/--logfile FILENAME -- use FILENAME as)rr*rz%supervisorctl -- control applicationsz(-i/--interactive -- start an interactiveN) rrrrrrrrr r-r.)r!r%r&r/s r'test_issue_1251zEndToEndTests.test_issue_12519s655mCND7KKK   (&-888  !KLLL  !KLLL7;'''777 cndWMMM   *FM:::""#JKKK""#MNNNW[)))))r1cttd}ddd|g}tjtj|d}||jtj | ddtjd |d }tjd d|gd}||jtj | d d dS)zWhen the output of 'supervisorctl tail -f worker' is piped such as 'supervisor tail -f worker | grep something', 'supervisorctl' should not crash.zfixtures/issue-1298.confrrrrrz#success: spew entered RUNNING state'z"' -m supervisor.supervisorctl -c 'z' tail -f spew | /bin/cat -uz/bin/shz spewage 2r9r:N) rrrrrrrrrrr r-)r!r$r%r&cmdbashs r'test_issue_1298zEndToEndTests.test_issue_1298Js%[2LMM.h?mCND7KKK   (&-888  !FGGGG NNNHHH}Ys gFFF  6=111 K ,,,,,r1c2gd}tjtj|d}||jt j|tj | |j ddS)z\When pidproxy is given a command to run that has no arguments, it runs that command.)rsupervisor.pidproxynonexistent-pidfile /bin/echorrrDN rrrrrrrrr-r. assertEqualrstripr!r%pidproxys r')test_issue_1418_pidproxy_cmd_with_no_argsz7EndToEndTests.test_issue_1418_pidproxy_cmd_with_no_args[s~QPP=HHH  v}555 $$$ ..00"55555r1c2gd}tjtj|d}||jt j|tj | |j ddS)zYWhen pidproxy is given a command to run that has arguments, it runs that command.)rrrr12rrz1 2Nrrs r'&test_issue_1418_pidproxy_cmd_with_argsz4EndToEndTests.test_issue_1418_pidproxy_cmd_with_argsds~[ZZ=HHH  v}555 $$$ ..00%88888r1cttd}ddd|g}tjtj|d}||jtj | ddd l m }dd l m}|d d d } |jd |}|j}|n#|wxYw||ddS)zfWhen no identifier is supplied on the command line or in the config file, the default is used.zfixtures/issue-1483a.confrrrrrsupervisord started with pidrrrrDzunix:///tmp/issue-1483a.sock"http://transport.ignores.host/RPC2r_Nrrrrrrrrrrr supervisor.compatrsupervisor.xmlrpcrr^r_getIdentificationrbr r!r$r%r&rrrcrdidents r'#test_issue_1483a_identifier_defaultz1EndToEndTests.test_issue_1483a_identifier_defaultms%[2MNN.h?mCND7KKK   (&-888  !?@@@//////999999''B0NOO  *Y*+OQZ[[F%7799E OO    IOO      ----- *CC&cttd}ddd|g}tjtj|d}||jtj | ddd l m }dd l m}|d d d } |jd |}|j}|n#|wxYw||ddS)zpWhen the identifier is supplied in the config file only, that identifier is used instead of the default.zfixtures/issue-1483b.confrrrrrrrrrrDzunix:///tmp/issue-1483b.sockrfrom_config_fileNrrs r',test_issue_1483b_identifier_from_config_filez:EndToEndTests.test_issue_1483b_identifier_from_config_files%[2MNN.h?mCND7KKK   (&-888  !?@@@//////999999''B0NOO  *Y*+OQZ[[F%7799E OO    IOO      233333rcttd}ddd|ddg}tjtj|d}||jtj | d d d l m }d d l m}|d d d} |jd|}|j}|n#|wxYw||ddS)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.confrrrz-ifrom_command_linerrrrrrrDzunix:///tmp/issue-1483c.sockrNrrs r'-test_issue_1483c_identifier_from_command_linez;EndToEndTests.test_issue_1483c_identifier_from_command_lines%[2MNN.hFYZmCND7KKK   (&-888  !?@@@//////999999''B0NOO  *Y*+OQZ[[F%7799E OO    IOO      344444s *CC(cddg}tjtj|d}||jt j|ddS)zThe command echo_supervisord_conf, whose implementation depends on importlib.resources to work, should print the example config.rz0from supervisor import confecho; confecho.main()rrzSample supervisor config fileN) rrrrrrrSIGKILLr )r!r%echo_supervisord_confs r',test_pull_request_1578_echo_supervisord_confz:EndToEndTests.test_pull_request_1578_echo_supervisord_confs]HI ' cndW U U U -2FNCCC**+JKKKKKr1c>ttd}ddd|g}tjtj|d}||jtj | ddd l m }dd l m}d }d }|d d |}|j||} | j||d d |} |j|| } | j| dS)a!If the socket is already closed when socket.shutdown(socket.SHUT_RDWR) is called in the close() method of an asyncore dispatcher, an exception will be raised (at least with Python 3.11.7 on macOS 14.2.1). If it is not caught in that method, supervisord will crash.zfixtures/issue-1596.confrrrrrrrrrzunix:///tmp/issue-1596.sockrrDN)rrrrrrrrrrr rrrrr^system listMethodsrb) r!r$r%r&rr socket_url dummy_urlt1s1t2s2s r'-test_issue_1596_asyncore_close_does_not_crashz;EndToEndTests.test_issue_1596_asyncore_close_does_not_crashs1 %[2LMM.h?mCND7KKK   (&-888  !?@@@//////9999992 8 ! R 4 4 "Y "9b 1 1   ! R 4 4 "Y "9b 1 1   r1N)__name__ __module__ __qualname__r(r0rArJrNrVrYrgrmrprsrurwryr{rrrrrrrrrrrrr1r'r r s   *** 999"WWW& I I I( ( ( ())) *WWW"CCC ? ? ? E E E J J J999"   DIII0***"---"666999...&444&555&LLLr1r ) __future__rrrrunittestrrrrrrrTestCase BaseTestCaseobjectr rr1r'rs'''''' //////''''''1111112:NNN$LLLuuuuuLuuuuur1