"j8HddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlmZmZmZmZddlmZejeZddZGddZGdd ejZGd d eZGd d eZGddeZGddeZ GddeZ!dS)N)NoAppFoundErrorTestingTimeoutErrorServerCloseErrorDashAppLoadingError)waitappc tj|}||}n?#t$r2}tdt d||d}~wwxYw|S)a Import a dash application from a module. The import path is in dot notation to the module. The variable named app will be returned. :Example: >>> app = import_app("my_app.app") Will import the application in module `app` of the package `my_app`. :param app_file: Path to the app (dot-separated). :type app_file: str :param application_name: The name of the dash application instance. :raise: dash_tests.errors.NoAppFoundError :return: App from module. :rtype: dash.Dash zthe app name cannot be foundz$No dash `app` instance was found in N)runpy run_moduleKeyErrorlogger exceptionr)app_fileapplication_name app_modulerapp_name_missings \/var/www/html/bolsaweb/venv/lib/python3.11/site-packages/dash/testing/application_runners.py import_apprs" %h// )*    7888 =8 = =    Js A-AAceZdZdZdZddZdZdZedZ d Z d Z d Z e d Ze d Ze dZdS)BaseDashRunnerz4Base context manager class for running applications.ihttp localhostch||_||_d|_d|_||_||_d|_dS)Nr)schemehostportstarted keep_open stop_timeout _tmp_app_path)selfrr rrs r__init__zBaseDashRunner.__init__@s;    "(!ctNNotImplementedErrorr"argskwargss rstartzBaseDashRunner.startI!!r$ctr&r'r"s rstopzBaseDashRunner.stopLr-r$ch tj|n#tjj$rYdSwxYwdS)NFT)requestsget exceptionsRequestException)urls r accessiblezBaseDashRunner.accessibleOsG  L    "3   55 ts //c|j|i|Sr&)r,r)s r__call__zBaseDashRunner.__call__Wstz4*6***r$c|Sr&r/s r __enter__zBaseDashRunner.__enter__Zs r$c |jrb|js[ td|n+#t $r}t d|jd|d}~wwxYwtddS)Nzkilling the app runnerzCannot stop server within z s timeoutz__exit__ complete)rrr infor0rrr )r"exc_typeexc_val tracebackcannot_stop_servers r__exit__zBaseDashRunner.__exit__]s < * * * 4555 & * * *&M1BMMM)* *  '(((((s.? A' A""A'c4|jd|jd|jS)zThe default server url.z://:)rrrr/s rr6zBaseDashRunner.urlhs&+99$)99di999r$c"tjdkS)Nwin32)sysplatformr/s r is_windowszBaseDashRunner.is_windowsms|w&&r$c|jSr&)r!r/s r tmp_app_pathzBaseDashRunner.tmp_app_pathqs !!r$N)rr)__name__ __module__ __qualname____doc__ _next_portr#r,r0 staticmethodr7r9r<rCpropertyr6rJrLr;r$rrr;s>>J""""""""""\+++ ) ) )::X:''X'""X"""r$rc$eZdZfdZdZxZS) KillerThreadc tjdi|ttj|_dS)Nr;)superr#list threading_activekeys _old_threads)r"r+ __class__s rr#zKillerThread.__init__wsE""6""" !2!7!7!9!9::r$cttjD]}||jvr tjt j|t jt}|dkrtd||dkrAtjt j|dtddS)NrzInvalid thread id: zStopping thread failure) rXrYrZr\ctypes pythonapiPyThreadState_SetAsyncExcc_long py_object SystemExit ValueError)r" thread_idress rkillzKillerThread.kill{si/00 < Exceptionr)optionserrorrr+r"s rrz!ThreadedRunner.start..runs/3CK  ,+/CGN (kkmmGV##.<.GG$)))Q.)))#FO  11111111 . . . ,------     '''  s6B$C. C7CCrrntargetTc8jSr&)rur6r/srz&ThreadedRunner.start..sD77AAr$timeoutFr_Nzthreaded server failed to start)rrqrtr0rirUdaemonr,runtilrr rtimesleepr)r"r start_timeoutr+rretrieserrs`` ` rr,zThreadedRunner.starts       (, 7Q;; ;+{++--+  ((****#666 %) " !!### AAAA= ${3355      %%%$ 1  1  !, 7Q;;,{++-- | I%&GHH H I IsB?C D+':D&&D+c|j|jtj|jj|jd|_dS)NF)rqrijoinr until_notrtr rr/s rr0zThreadedRunner.stopsO   t{+T->??? r$Frnrn) rMrNrOrPr#rur,r0rjrks@rrmrms~ ::: 1I1I1I1Ifr$rmc.eZdZdfd ZddZdZxZS)MultiProcessRunnerFrncZt||d|_dSr&rWr#procrrs rr#zMultiProcessRunner.__init__s( L111 r$c dd_fd}tj|_jt jfd|d_dS)Nrrc8djj_djj_} jdddi|dS#t $rtdt$r!}t ||d}~wwxYw)NTrxryr;) rzr{r|r}r~rrer r>rr)rrrr+s rrz(MultiProcessRunner.start..targets/3CK  ,+/CGN (kkmmG 11111111    ,---     '''  sA .B8BBrc8jSr&r7r6r/srrz*MultiProcessRunner.start..s4??4844r$rT) r3r multiprocessProcessrr,rrr)r"rrr+rs`` ` rr,zMultiProcessRunner.startsJJvt,,       !(777   4444mLLLL r$ctj|jj}|dD],} |#tj$rY)wxYw |n#tj$rYnwxYw |ddS#tjtjf$rYdSwxYw)NT) recursiver_) psutilrrpidchildrenri NoSuchProcessrTimeoutExpired)r"processrs rr0zMultiProcessRunner.stops.//$$t$44  D  '      LLNNNN#    D   LLOOOOO%v';<    DD s5A  AA#A88B  B B%%CCrr)rMrNrOr#r,r0rjrks@rrrs` 0r$rc<eZdZdZd fd Z d dZd ZxZS) ProcessRunnerz}Runs a dash application in a waitress-serve subprocess. This flavor is closer to production environment but slower. Frnc\t||d|_dSrprrrs rr#zProcessRunner.__init__+ 9<HHH r$Nrrc |s|stjddS|_tj|r|n d|d|d|dj }t d| tj |tj tj _ tj fd | nM#ttf$r9t d d _YdSwxYwd_dS)z7Start the server with waitress-serve in process flavor.zAthe process runner needs to start with at least one valid commandNz waitress-serve --listen=0.0.0.0: rEz.serverposixstart dash process with %s)stdoutstderrc8jSr&rr/srrz%ProcessRunner.start..1ttx88r$r'process server has encountered an errorFT)loggingrrshlexsplitrJr debug subprocessPopenPIPErrrOSErrorrfrrr0)r"rr raw_commandrrr*s` rr,zProcessRunner.startsD k  MS    F { bKKaDaa:aaHXaaao%      14888 "(Z_Z_DI J8888- P P P P P$      F G G G DL IIKKK FF    s)A B33AC=<C=c|jr' td|jj|j|jr]t j|jr9t d|jtj |jtj }|j|jnW#|$rOtd|j|jYnwxYwtddS)Nzproc.terminate with pid %szremoving temporary app path %srzPsubprocess terminate not success, trying to kill the subprocess in a safe mannerzprocess stop completes!)rr r>r terminaterLospathexistsrshutilrmtreerr communicater rri)r"_excepts rr0zProcessRunner.stop;sA 9 ( ( 8$)-HHH ##%%%$58I)J)J5LL!A4CTUUUM$"3444$3 %% -& ( ( (  6     %%'''''  (  -.....sCCAD-,D-r)NrNrrn)rMrNrOrPr#r,r0rjrks@rrr s|   %%%%N///////r$rc(eZdZdfd ZddZxZS) RRunnerFrnc\t||d|_dSrprrrs rr#zRRunner.__init__Srr$Nc tj|r]tj|r>s:tj|t dnWtjjsdntj dtj j _ tjjn0#t $r#t djYnwxYwtjjd}t dt d|t dt d |t'|d d 5}||d d d n #1swxYwY|}st+jD]}d|dddvr_tjtj|dt dnr4t dfdtjD}|D]}tjjtj|} tj| r/t d| t9j| t d|jt9j|| t dtj| nt dt d|t?j dtj|dj } t d|  tCj"| tBj#tBj#jrjn_$tKj&fd| n9#t tNf$r%t d!d"_(Yd SwxYwd#_(d S)$z-Start the server with subprocess and Rscript.z&RRunner inferred cwd from app path: %s/tmpTEMPcannot make temporary folder %szapp.Rz$RRunner start => app is R code chunkz+make a temporary R file for execution => %szcontent of the dashR app%swutf-8encodingN/dash/testing/r_\/get cwd from inspect => %sz3RRunner inferred cwd from the Python call stack: %scg|]t}|dtjtj|Ttj|uS__ startswithrrisdirr.0_cwds r z!RRunner.start..t<<--35'-- SRS@T@T2U2UGLLa((r$delete existing target %scopying %s => %scopied with %szRRunner found no cwd in the Python call stack. You may wish to specify an explicit working directory using something like: dashr.run_server(app, cwd=os.path.dirname(__file__))z Run dashR app with Rscript => %szRscript -e 'source("z")'rrrrrc8jSr&rr/srrzRRunner.start..rr$rrFT)rrisfilerdirnamer r>rrJgetenvuuiduuid4hexr!mkdirrLrrropenwriteinspectstackreplacerealpathwarninglistdirbasenamerrcopytreerrrrrrrrrfr r"rrrrfpentryassetsassetrr*s ` ` rr,z RRunner.startXs 7>>#  < 27>>##6#6<  Kgooc** DcJJJ"$"oD29V3D3DdjllFV""D  W*++++ W W W  !BDDUVVVVV W7<< 17;;D KK> ? ? ? KKEt L L L LL3 4 4 4 LLs # # #dC'222 b                C $]__E'uQx/?/?c/J/JJJ goobg.>.>uQx.H.HII'CSIIIK  QSVWWWZ__ $GGEW\\$*;RW=M=Me=T=TUUFw~~f--. %@&III f---LL!3UDs:tj|t dnWtjjsdntj dtj j _ tjjn0#t $r#t djYnwxYwtjjd}t dt d|t dt d |t'|d d 5}||d d d n #1swxYwY|}st+jD]}d|dddvr_tjtj|dt dnr4t dfdtjD}|D]}tjjtj|} tj| r/t d| t9j| t d|jt9j|| t dtj| nt dt d|t?j dtj|j } t d|  tCj"| tBj#tBj#jrjn_$tKj&fd|n9#t tNf$r%t d d!_(Yd SwxYwd"_(d S)#z+Start the server with subprocess and julia.z*JuliaRunner inferred cwd from app path: %srrrzapp.jlz,JuliaRunner start => app is Julia code chunkz/make a temporary Julia file for execution => %szcontent of the Dash.jl apprrrrNrr_rrrz7JuliaRunner inferred cwd from the Python call stack: %scg|]t}|dtjtj|Ttj|uSrrrs rrz%JuliaRunner.start..rr$rrrzJuliaRunner found no cwd in the Python call stack. You may wish to specify an explicit working directory using something like: dashjl.run_server(app, cwd=os.path.dirname(__file__))z Run Dash.jl app with julia => %szjulia --project rzstart Dash.jl process with %src8jSr&rr/srrz#JuliaRunner.start.. rr$rrFTrrs ` ` rr,zJuliaRunner.starts 7>>#  > 27>>##6#6>  Ogooc** H#NNN"$"oD29V3D3DdjllFV""D  W*++++ W W W  !BDDUVVVVV W7<< 18<.>uQx.H.HII'CSIIIK  Ms Z__ $GGEW\\$*;RW=M=Me=T=TUUFw~~f--. %@&III f---LL!3UDQ     4d;;; "(!!)-):CD%% DI J8888- P P P P P$      F G G G DL FF   s7C00*DDG##G'*G' AR""2SSr)rNrrks@rrrsY YYYYYYYYr$r)r)"rHrrrrrYrrrrr`r r2rrdash.testing.errorsrrrr dash.testingr getLoggerrMr rrThreadrUrmrrrrr;r$rr se       8 $ $88"8"8"8"8"8"8"8"v<<<<<9#<<<.GGGGG^GGGT////////dF/F/F/F/F/NF/F/F/R^^^^^m^^^B_____-_____r$