o ²µj’3ã @s0dZddlZddlZddlZddlZddlmZddlmZm Z m Z de de fdd„Z de de fd d „Zde de fd d „Zde de fd d„Zde de fdd„Zde de fdd„Zde de fdd„Zde de de fdd„Zd"de de dedefdd„Zd"de dedefdd„Zdd „Zed!kr–e eƒ¡dSdS)#zv gunicornc - Gunicorn control interface CLI Interactive and single-command modes for controlling Gunicorn instances. éN)Ú_get_default_control_socket)Ú ControlClientÚControlClientErrorÚ parse_commandÚdataÚreturnc Csô| dg¡}|s dSg}| dd›ddd›ddd ›dd ›¡| d ¡|D]:}| d d ¡}| dd ¡}| d¡r;dnd}| d¡}|durK|›dnd}| |d›d|d›d|d ›d|›¡q&| d¡| d| dt|ƒ¡›d¡d |¡S)z"Format workers output for display.ÚworkerszNo workers runningÚPIDú<10ú ÚAGEú<6ÚBOOTEDú<8Ú LAST_BEATz(----------------------------------------Úpidú?ÚageÚbootedÚyesÚnoÚlast_heartbeatNús agoún/aÚúTotal: Úcountz workersÚ ©ÚgetÚappendÚlenÚjoin) rrÚlinesÚwrrrÚhbÚhb_str©r'úE/var/www/ai-app/venv/lib/python3.10/site-packages/gunicorn/ctl/cli.pyÚformat_workerss &    (  r)c Csº| d¡sdSg}| d| d¡›¡| d¡| dg¡}|r„| d¡| dd ›d d d ›d d d›d d›¡| d¡|D]>}| dd¡}| dd¡}d | dg¡¡dd…}| d¡}|duri|›dnd}| |d ›d |d ›d |d›d |›¡q@| d¡| dg¡}|rØ| d¡| dd›d dd ›d d›¡| d¡|D]0} |  dd¡dd…} |  d d!¡} |  d"¡} | durÆt| ƒnd#} | | d›d | d ›d | ›¡q§d$ |¡S)%z(Format dirty workers output for display.ÚenabledzDirty arbiter not runningzDirty arbiter PID: rrrzDIRTY WORKERS:r r r r r ÚAPPSz<30rz<------------------------------------------------------------rrú, ÚappsNérrrz DIRTY APPS:ÚAPPÚWORKERSÚLIMITú2--------------------------------------------------Ú import_pathÚcurrent_workersrÚ worker_countÚnoner)rr r"Ústr)rr#rr$rrr-r%r&ÚappÚpathÚcurrentÚlimitÚ limit_strr'r'r(Ú format_dirty-s<    &    (        r=cCsDg}| d¡}|rÚhoursÚminutesÚsecondsÚ uptime_strÚ dirty_pidr'r'r(Ú format_statsWs.      rNcCs¾| dg¡}|s dSg}| dd›ddd›dd›¡| d ¡|D]#}| d d ¡}| d d ¡}| d d ¡}| |d›d|d›d|›¡q"| d¡| d| dt|ƒ¡›d¡d |¡S)z$Format listeners output for display.Ú listenerszNo listeners boundÚADDRESSz<40r ÚTYPErÚFDz7-------------------------------------------------------ÚaddressrÚtypeÚfdrrrz listenersrr)rrOr#ÚlnrÚaddrÚltyperUr'r'r(Úformat_listenersxs        rYcCsZg}t| ¡ƒD]}||}t|tƒrd dd„|Dƒ¡}| |›d|›¡qd |¡S)z!Format config output for display.r,csó|]}t|ƒVqdS©N)r7)Ú.0Úvr'r'r(Ú –ó€z format_config..z: r)ÚsortedÚkeysÚ isinstanceÚlistr"r )rr#ÚkeyÚvaluer'r'r(Ú format_configŽs  rfcCs„| di¡}g}| d¡| d¡|rtdd„| ¡Dƒƒnd}t| ¡ƒD]\}}| d|d|d ››d |›¡q'd  |¡S) zFormat help output for display.ÚcommandszAvailable commands:rcsrZr[)r!)r\Úcmdr'r'r(r^¤r_zformat_help..rú ú<ér r)rr Úmaxrar`Úitemsr")rrgr#Úmax_lenrhÚdescr'r'r(Ú format_helpœs   $ rpc Csºg}| di¡}| d¡| d| dd¡›¡| d¡| dg¡}| d| d d ¡›d ¡|rŽ| d d d›ddd›ddd›dd›¡| d d›¡|D];}| dd¡}| dd¡}| d¡rfdnd}| d¡}|durv|›dnd} | d |d›d|d›d|d›d| ›¡qQn| d¡| d¡| d¡} | rN| d ¡| d|  dd¡›¡| d¡| d!g¡} | d"| d#d ¡›d ¡| rH| d d d›ddd›dd$›¡| d d%›¡| D]`}| dd¡}| dd¡}| d&g¡} | r8| d  d'¡d(} | d |d›d|d›d| ›¡| d)d…D]}| d'¡d(}| d dd›ddd›d|›¡qqæ| d |d›d|d›d*¡qæn| d¡n | d ¡| d+¡d, |¡S)-z#Format show all output for display.ÚarbiterzARBITER (master)z PID: rrrÚ web_workersz WEB WORKERS (Úweb_worker_countrú)rir r r r r rrrz&--------------------------------------rrrrrNrrz (none)Ú dirty_arbiterz DIRTY ARBITERÚ dirty_workerszDIRTY WORKERS (Údirty_worker_countr+r2r-ú:éÿÿÿÿéz (no apps)z (not running)r)rr Úsplitr")rr#rqrrr$rrrr%r&rurvr-Ú first_appr8Úapp_namer'r'r(Ú format_all¬s^    (   *ú           $þô    r~ÚcommandcCs’| ¡ ¡}|dkrt|ƒS|dkrt|ƒS|dkrt|ƒS|dkr&t|ƒS|dkr.t|ƒS|dkr6t|ƒS|dkr>t|ƒS|rGt j |dd Sd S) z¾ Format response data based on command. Args: command: Original command string data: Response data dictionary Returns: Formatted string for display zshow allz show workersz show dirtyz show statszshow listenersz show configÚhelprk©ÚindentÚOK) ÚlowerÚstripr~r)r=rNrYrfrpÚjsonÚdumps)rrÚ cmd_lowerr'r'r(Úformat_responseês$ r‰FÚ socket_pathÚ json_outputc CsâzJt|ƒ;}t|ƒ\}}|r|›dd |¡› ¡n|}| |¡}|r-ttj|ddƒn t||ƒ}t|ƒ WdƒWdS1sCwYWdSt yg} ztd| ›t j dWYd} ~ dSd} ~ wt ypYd Sw) zð Execute single command and exit. Args: socket_path: Path to control socket command: Command to execute json_output: If True, output raw JSON Returns: Exit code (0 for success, 1 for error) r rkrNrúError: ©Úfilerzé‚) rrr"r…Ú send_commandÚprintr†r‡r‰rÚsysÚstderrÚKeyboardInterrupt) rŠrr‹ÚclientrhÚargsÚ full_commandÚresultÚoutputÚer'r'r(Ú run_command s$     (õ € ÿr›cCs~zddl}d}Wn tyd}Ynwz t|ƒ}| ¡Wnty;}ztd|›tjdWYd}~dSd}~wwtd|›ƒtd ƒtƒtj   d ¡}|rcz|  |¡Wn t ybYnwd}z¿z‘ zt d ƒ ¡}Wn ty|tƒYnzw|s€qg| ¡d vr‡noz2t|ƒ\} } | rœ| ›d d  | ¡› ¡n| } | | ¡} |r¯ttj| ddƒn t| | ƒ} t| ƒWn8tyñ}z,td|›ƒz | ¡| ¡Wntyætdƒd}YWYd}~nwWYd}~nd}~wwtƒqhWntytƒd}YnwW| ¡|r#z| |¡W|Sty"Y|Sw|S| ¡|r>z| |¡Wwty=Ywww)z¹ Run interactive CLI with readline support. Args: socket_path: Path to control socket json_output: If True, output raw JSON Returns: Exit code rNTFrŒrrzz Connected to z3Type 'help' for available commands, 'quit' to exit.z~/.gunicornc_historyz gunicorn> )ÚquitÚexitÚqr rkrzConnection lost. Exiting.r)ÚreadlineÚ ImportErrorrÚconnectrr‘r’r“Úosr9Ú expanduserÚread_history_fileÚFileNotFoundErrorÚinputr…ÚEOFErrorr„rr"rr†r‡r‰Úcloser”Úwrite_history_fileÚ Exception)rŠr‹rŸÚ has_readliner•ršÚ history_fileÚ exit_codeÚlinerhr–r—r˜r™r'r'r(Úrun_interactive.sª  ÿ €þ  ÿ þ     €  ý ÿ€û Ý€%þ€ ýýùÿýr¯cCsÎtjdtjdd}|jddtƒdd|jdd d d |jd d ddd|jddddd| ¡}|jrDddlm}t d|›dƒdS|j }t j   |¡sVt j  t  ¡|¡}|jrat||j|jƒSt||jƒS)z#Main entry point for gunicornc CLI.zGunicorn control interfacea? Examples: gunicornc # Interactive mode (default socket) gunicornc -s /tmp/myapp.ctl # Interactive mode with custom socket gunicornc -c "show workers" # Single command mode gunicornc -c "worker add 2" # Add 2 workers gunicornc -c "show stats" -j # Output stats as JSON )Ú descriptionÚformatter_classÚepilogz-sz--socketzUControl socket path (default: auto-detected based on XDG_RUNTIME_DIR or ~/.gunicorn/))Údefaultr€z-cz --commandzExecute single command and exit)r€z-jz--jsonÚ store_truezOutput raw JSON (for scripting))Úactionr€z-vz --versionzShow version and exitr)Ú __version__zgunicornc (gunicorn rt)ÚargparseÚArgumentParserÚRawDescriptionHelpFormatterÚ add_argumentrÚ parse_argsÚversionÚgunicornr¶r‘Úsocketr¢r9Úisabsr"Úgetcwdrr›r†r¯)Úparserr–r¶rŠr'r'r(ÚmainˆsFý ýþýý   rÂÚ__main__)F)Ú__doc__r·r†r¢r’Úgunicorn.configrÚgunicorn.ctl.clientrrrÚdictr7r)r=rNrYrfrpr~r‰ÚboolrHr›r¯rÂÚ__name__rr'r'r'r(Ús* *!>#!Z9ÿ