o i!@sdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddlmZzddlZWn eyGdZYnwejdkrQejZnddZdd d Z Gd d d ZGd ddeZeejdS)z!JupyterLab Server process handlerN)which)genFwin32cCsddl}dt|j|S)zShim for list2cmdline on posix.rN )shlexjoinmapquote)cmd_listrr T/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/jupyterlab_server/process.py list2cmdlinesr cCsv|ptj}|dp tj}t||d}|dkr!|s!d}td|d}|s5|dvr-d}t|tdd|tj|S) zGet the full path to a command. Parameters ---------- command: str The command name or path. env: dict, optional The environment variables, defaults to `os.environ`. PATH)pathnodenodejs)rrnpmzPlease install Node.js and npm before continuing installation. You may be able to install Node.js from your package manager, from conda, or directly from the Node.js website (https://nodejs.org).z%The command was not found or was not zexecutable: %s.)osenvirongetdefpath_which ValueErrorrabspath)commandenvrcommand_with_pathmsgr r r r$s     rc@sleZdZUdZeZejed<dZdddZ ddZ d d Z e j d d Zd dZeddZddZdS)ProcesszA wrapper for a child process._procsNFc Cst|ttfs d}t||r|rd}t||p||_d|_|s0|jdt |||_ i}|r stdout)cwdrNr ) isinstancelisttupleris_setget_loglogger _last_lineinfor cmd subprocessDEVNULL_create_processproc threadingEvent _kill_eventrradd) selfr+r(r" kill_eventrquietrkwargsr r r __init__Es"  zProcess.__init__c Cs|j}|durt|jtjzeZdZdZd fdd ZddZddZfd d ZZS) WatchHelperz%A process helper for a watch process.Nc stj|||||dts|jj|_ |jd}|s#d}t|t | t ||r0nqt j|jdd|_|jdS)a Initialize the process helper. Parameters ---------- cmd: list The command to run. startup_regex: string The regex to wait for at startup. logger: :class:`~logger.Logger`, optional The logger instance. cwd: string, optional The cwd of the process. env: dict, optional The environment for the process. kill_event: callable, optional A function to call to check if we should abort. )r(r"r5rutf-8zProcess ended improperlyT)targetdaemonN)superr8ptyr/r!_stdoutreadlinedecode RuntimeErrorprintrstriprematchr0Thread_read_incoming _read_threadstart) r4r+ startup_regexr(r"r5rliner __class__r r r8s    zWatchHelper.__init__c Cs|j}|dur"tjdkrtt|jtjnt |jtjz| W|t j vr3t j ||jS|t j vrBt j |ww)zTerminate the process.Nr:)r/r;rrBkillpggetpgidr=r>r?r<r@rrrE returncode)r4r/r r r rGs      zWatchHelper.terminatec Csn|j} zt|d}Wnty(}z|jd|WYd}~dSd}~ww|s-dSt|dddq)z(Run in a thread to read stdout and printrgizRead incoming error %sNrhr )end) rmfilenorreadOSErrorr(debugrqro)r4rbufer r r rvs zWatchHelper._read_incomingc sd|d<tr t\}}||d<|d<d|d<t|d|_n#tj|d<tjdkrCt}|j tj O_ ||d <tj |d <d|d <t j d i|S)z"Create the watcher helper process.rbufsizerOr!Tstart_new_sessionrbr: startupinfo creationflagsrPNr )rlopenptyrfdopenrmr,PIPErB STARTUPINFOdwFlagsSTARTF_USESHOWWINDOWCREATE_NEW_PROCESS_GROUPrkr.)r4r7masterslaverr{r r r. s    zWatchHelper._create_process)NNNN) r\r]r^r_r8rGrvr. __classcell__r r r{r rfs #rf)N)r_atexitrXrrsr>r,sysr0rJr`shutilrrtornadorrl ImportErrorplatformr rrfregisterrUr r r r s4      `