/
usr
/
share
/
lve
/
modlscapi
/
user
/
up file
home
� ��Sec @ s^ d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z m Z m Z m Z m Z m Z d d l m Z m Z m Z m Z m Z m Z d d l Z d e f d � � YZ e d � Z e e d � Z e e d � Z e e d � Z! d � Z" d � Z# d � Z$ d S( i����N( t get_cp( t criu_settings_malfunctions( t lsapi_settings_malfunctions( t liblsapi_malfunctions( t cpanel_whmapit plesk_bin_php_handlert dump_loaded_modulest dump_lsapit query_stringst rpm_query( t get_da_domainst get_da_php_optionst read_da_configt liblsapi_patht pretty_version_keyst count_domainst ModLsapiStatExceptionc B s e Z RS( ( t __name__t __module__( ( ( s/ /usr/share/lve/modlscapi/user/mod_lsapi_stat.pyR s c C sm d } i } t � } y� | j d k rR t j j d � rI t � | d <q� d } nP | j d k rq t � | d <n1 | j d k r� t � | d <n d j | j � } Wn" t k r� } t | j � } n X| d k r� t � | d <| | d <n t | � | d <| j t � � | j t � � | j i t | d j � � d 6� t | � | ret j | d t �S| Sd S( s� Return statistics data :param as_json: return json string if True, dict otherwise :return: statistics data dict( `controlPanel`: EA3/EA4/Plesk/DirectAdmin/Unknown CP, `criu`: dict( `status`: running/stopped, `version`: version ), `domainStat`: dict( `version`: `domains_num`, ... ) or dict(`error`: description) if some error occurred, `lsapiConf`: dict( lsapi_with_connection_pool: on/off, lsapi_criu: on/off ) ) or its json-packed version t cPanels /etc/cpanel/ea4/is_ea4t domainStats7 mod_lsapi domains stat is currently unsupported for EA3t Pleskt DirectAdmins7 mod_lsapi domains stat is currently unsupported for {0}t domainStatErrort controlPanelt totalDomaint sort_keysN( t NoneR t namet ost patht existst get_cpanel_ea4_statt get_plesk_statt get_da_statt formatR t strt messaget dictt updatet get_lsapi_conft get_crui_statt sumt valuest analyze_malfunctionst jsont dumpst True( t as_jsont errort statst control_panelt e( ( s/ /usr/share/lve/modlscapi/user/mod_lsapi_stat.pyt get" s4 $ c C s� t � } t � } t � } y�t d � j d � } xX | D]P } | j | j d � t � � j | j d � � | j d � | | j d � <q: Wt d � j d � } t g | D]$ } | j d � | j d � f ^ q� � } | j � } xL | j � D]> \ } } | j | t � � j i | j | t � � | 6� q� W| rYt j | | | � } | } n xK | j � D]= \ } } | j t j t | � j | j � � t � � � qfWWn; t t f k r�t d j t j � j d � � � � n Xt | | | � S( sY Collect mod_lsapi statistics for cPanel EA4 through WHM API :param lsapi_only: return only lsapi domains statistics if True, or full statistics if False :param with_selector: take into account the statistics of php selector :return: if lsapi_only return lsapi domains per version stat dict( `version`: `domains_num`, ... ) else return full statistics per handler stat dict( `handler`: {`version`: `domains_num`, ... } ... ) t php_get_vhost_versionst versionst versiont vhostt accountt php_get_handlerst version_handlerst current_handlert s ( R& R R5 t setdefaultt sett addt keyst iteritemsR' t selector_usage_libt ea4_selector_checkt fromkeyst differencet KeyErrort TypeErrorR t joint tracebackt format_exct splitR ( t lsapi_onlyt with_selectort domains_per_versiont handlers_statt domain_userst vhosts_dataR9 t handlers_datat hR< t all_versionst vert handlert s_checked_version_handlerst v( ( s/ /usr/share/lve/modlscapi/user/mod_lsapi_stat.pyR Y s* . 7 6 9(c C s� d } d } t � } yt d � } t g | D]! } d | j d � k r. | ^ q. � } x� | D]� } | j d � } d j | j d � j d � d � } t g t d d | �D] } | j d � ^ q� � } d | k r� d } | j d | � } n | j d | � } | | | <q_ W| r/t j | | � } n WnD t t t t j f k rvt d j t j � j d � � � � n Xi t d � | j � D� � d 6} | r�| d S| S( s Collect mod_lsapi statistics for Plesk Collects lsapi domains ONLY :param lsapi_only: return only lsapi domains statistics if True, or full statistics if False :param with_selector: take into account the statistics of php selector :return: if lsapi_only return lsapi domains per version dict( `version`: `domains_num` ... ) else return stats with handler dict( `lsapi`: {`version`: `domains_num`, ... } ) s alt-php{v}s alt-php56t listt lsphpt idR> t fullVersiont .i����s get-usaget domaint customRZ s c s s' | ] \ } } | t | � f Vq d S( N( t len( t .0t kRZ ( ( s/ /usr/share/lve/modlscapi/user/mod_lsapi_stat.pys <genexpr>� s t lsapi( R& R t sortedR5 RJ RM R@ R# RD t plesk_selector_checkRH RI t AttributeErrort SelectorStatExceptionR RK RL RC ( RN RO t handler_tmplt custom_versiont domain_version_statt all_handlersRU t lsphp_handlersRX t handler_idt php_versiont dt domainst version_idt result_stat( ( s/ /usr/share/lve/modlscapi/user/mod_lsapi_stat.pyR! � s, 4 %4 ( c C s� d } t � } yxt � } | d d } | d d } | d d } | d d } t | � } t | � } t � } t � } g | j � D] } | j | � ^ q� | d k r� i | | 6} i | | 6| | <ny| d k r� i | | 6} i | | 6| | <nLi t � | 6t � | 6} x� | j � D]� \ } } x� | D]� } | j d | d | � } yR t | � \ } } | j | d � } t | | d � } | j | � j | � Wq7t j k r�| j | � j | � q7Xq7Wq$W| | k r i | | | 6| | | 6| | <n> i | | | 6t � | 6| | <i | | | 6t � | 6| | <| r�t j | j | � | | � } | j | � j | � n Wn> t t t f k r�t d j t j � j d � � � � n Xt | | | g | � S( sN Collect lsapi domains statistics fro DirectAdmin :param lsapi_only: return only lsapi domains statistics if True, or full statistics if False :param with_selector: take into account the statistics of php selector :return: if lsapi_only return lsapi domains per version stat dict( `version`: `domains_num`, ... ) else return full statistics per handler stat dict( `handler`: {`version`: `domains_num`, ... } ... ) s> /usr/local/directadmin/data/users/{user}/domains/{domain}.confi R8 i RX t not userR` t php1_selectR> s ( R& R R R R@ R+ R' RC R# R t getintR5 RA t ConfigParsert NoOptionErrorRD t da_selector_checkRH RI Rh R RJ RK RL RM R ( RN RO t domain_conf_patht handler_statt php_optionst php1_vert php2_vert php1_handlert php2_handlert php1_labelt php2_labelt user_domainst joinedRZ t version_statRv Rr R` t config_patht conf_parsert global_sectiont php_settingR8 t selector_updated( ( s/ /usr/share/lve/modlscapi/user/mod_lsapi_stat.pyR" � sV & " (c C s� d j t j d � � } y2 t j d d d g d t j d t j �d } Wn t j k rf d } n Xi i | d 6| r� | j d � d n d d 6d 6S( s� Get criu service info :return: dict( `criu`: dict( `status`: running/stopped, `version`: version ) ) R> s /usr/sbin/criu -Vs /sbin/servicet criut statust stdoutt stderrt runningt stoppedt i s not installedR8 ( RJ t exec_commandt subprocesst check_callt PIPEt STDOUTt CalledProcessErrorRM ( t criu_versiont criu_service_status( ( s/ /usr/share/lve/modlscapi/user/mod_lsapi_stat.pyR) s ( c C s� t � } t � } | j d d � } t t � d � } i i | j d d � d 6| j d d � d 6d 6| j d d � d 6| r� | n t d � d 6| s� d n d d 6S( sl Retrieve lsapi configuration: - crui - connection pool and versions of module and library :return: dict( lsapiConf: dict( lsapi_with_connection_pool: on/off, lsapi_criu: on/off ), modVersion: version, libVersion: version ) t lsapi_modulet liblsapi_versiont lsapi_criut offt lsapi_with_connection_poolt lsapiConfR8 t modVersiont liblsapit libVersiont disabledt enabledt modStatusN( R R R5 R R R R ( t apache_conft apache_modulest mod_statusR� ( ( s/ /usr/share/lve/modlscapi/user/mod_lsapi_stat.pyR( s c s� t � � � f d � } d j d | d d d | d d � } | d } | t | d � | t | � | t | � � s d S| j i � d 6� d S( s� Detect configuration malfunctions and update resulting statistics dict accordingly For now only criu malfunctions are presented See malfunctions in dashboard_malfunctions.py module :param stats_dict: resulting statistics dict c s- y � j | | � Wn t k r( n Xd S( N( t appendRH ( t malfunc_dictt key( t malfunctions( s/ /usr/share/lve/modlscapi/user/mod_lsapi_stat.pyt add_malfunctionI s s {opt}_{serv}t optR� R� t servR� R� R� R� NR� ( R[ R# R R R R' ( t stats_dictR� t criu_settingst lsapi_settings( ( R� s/ /usr/share/lve/modlscapi/user/mod_lsapi_stat.pyR, @ s (% R R- RK R� Ry R� t lve_diagnosticR t dashboard_malfunctionsR R R t stat_utilsR R R R R R R R R R R R RD t ExceptionR t FalseR5 R/ R R! R" R) R( R, ( ( ( s/ /usr/share/lve/modlscapi/user/mod_lsapi_stat.pyt <module> s( .. 71,O !