File: //usr/libexec/kcare/python/kcarectl/config_handlers.pyc
�
%��ic @ s� d d l Z d d l Z d d l Z d d l m Z m Z m Z m Z m Z d d l m
Z
e r� d d l m
Z
m Z m Z m Z n d Z d d d d
d d d
g Z e � Z d � Z d � Z i2 d � d 6d d 6e d 6d d 6d � d 6e d 6e d 6d d 6e d 6e d 6e d 6e d 6e d 6e d 6e d 6e d
6e d 6d � d! 6e d
6e d" 6e d 6e d# 6e d$ 6e d% 6e d& 6e d' 6d( � d) 6e j d* 6d+ � d, 6d- � d. 6e j d/ 6d d0 6e j d1 6d2 � d3 6d4 � d5 6e d6 6e d7 6e d8 6e d9 6e j d: 6d d; 6d d< 6e j d= 6e d> 6e d? 6e d 6d d@ 6d dA 6e dB 6e d 6Z dC � Z dD � Z dE e f dF � � YZ dG � Z! dH � Z" dI � Z# dJ � Z$ e j% dK e j& � dL � � Z' e j% dK e j& � dM � � Z( d S(N i����Ni ( t configt constantst
http_utilst log_utilst utils( t ConfigParser( t Dictt Listt Optionalt Sets /etc/sysconfig/kcare/kcare.conft USE_CONTENT_FILE_V3t FORCE_JSON_SIG_V3t ENABLE_CRASHREPORTERt KCORE_OUTPUTt KMSG_OUTPUTt SEND_PERF_METRICSt KERNEL_ANOMALY_REPORT_ENABLEc C s | j � d k S( Nt 1t TRUEt YESt Y( R R R R ( t upper( t value( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyt bool_converter! s c C s8 g | j d � D]$ } | j � r | j � j � ^ q S( Nt ,( t splitt stript lower( R t item( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyt
comma_list% s c C s
| j � S( N( R ( t v( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyt <lambda>+ s t AFTER_UPDATE_COMMANDt AUTO_STICKY_PATCHSETt AUTO_UPDATEt AUTO_UPDATE_DELAYc C s
| j � S( N( R ( R ( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyR / s t BEFORE_UPDATE_COMMANDt CHECK_SSL_CERTSt FORCE_GIDt
FORCE_IPV4t
FORCE_IPV6t HTTP_TIMEOUTt HTTP_UPLOAD_TIMEOUTt IGNORE_FEATURE_FLAGSt IGNORE_UNKNOWN_KERNELt KCORE_OUTPUT_SIZEc C s
| j d � S( Nt /( t rstrip( R ( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyR < s t
KDUMPS_DIRt$ KERNEL_ANOMALY_REPORT_MAX_SIZE_BYTESt LIBCARE_DISABLEDt LIBCARE_LIBSt! LIBCARE_PIDLOGS_MAX_TOTAL_SIZE_MBt LIBCARE_SOCKET_TIMEOUTt LIB_AUTO_UPDATEc C s
| p d S( N( t None( R ( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyR E s t PATCH_LEVELt PATCH_METHODc C s
| j d � S( NR. ( R/ ( R ( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyR G s t PATCH_SERVERc C s
| j d � S( NR. ( R/ ( R ( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyR H s t PATCH_SERVER_IPV6t
PATCH_TYPEt PREFIXt PREV_PATCH_TYPEc C s
| j d � S( NR. ( R/ ( R ( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyR L s t REGISTRATION_URLc C s
| j d � S( NR. ( R/ ( R ( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyR M s t REGISTRATION_URL_IPV6t PRINT_LEVELt REPORT_FQDNt SILENCE_ERRORSt STATUS_CHANGE_GAPt STICKY_PATCHt STICKY_PATCHSETt UPDATE_DELAYt
UPDATE_POLICYt UPDATE_SYSCTL_CONFIGt USERSPACE_PATCHESt KERNEL_VERSION_FILEt KCARE_UNAME_FILEt SUCCESS_TIMEOUTc K s t t � } | j � } | j � x� | j � D]� \ } } t } | d } | d } x| t t | � � D]h } | | j | � s� | | j | � rh | d k r� | | =n | d t
| � d | | <t } Pqh qh W| s/ | j | d t
| � d � q/ q/ Wt
j t d j | � � d S( Nt =t s = s
t ( t opent CONFIGt readlinest closet itemst Falset ranget lent
startswithR7 t strt Truet appendR t atomic_writet join( t kwargst cft linest propR t updatedt prop_eqt prop_spt i( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyt
update_config` s"
&
&c
C sB i } t j d � } xa | D]Y } | j | � } | r[ | j � \ } } | sk d } qk n t d | � � | | | <q Wt | � t t � } | r� t d d j t | � � � � n xz | j
� D]l \ } } t | } | d k s� | d k r� q� n y | | � Wq� t k
r/t d | | f � � q� Xq� Wt | � d S( Ns ^([^=]+)=([^=]*)$s8 Invalid parameter format: %s. Format should be KEY=VALUEs Unknown parameter: %ss , s Bad value for %s: %s(
t ret compilet matcht groupsR7 t
SystemExitt sett POSSIBLE_CONFIG_OPTIONSR^ t sortedRU t ExceptionRg (
t paramst params_for_updatet patternt paramRj t keyR t unknown_paramst var_namet convert( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyt update_config_from_argsu s,
"
t FakeSecHeadc B s# e Z d � Z d � Z d � Z RS( c C s | | _ d | _ d S( Ns [asection]
( t fpt sechead( t selfR{ ( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyt __init__� s c C s5 | j r$ z | j SWd d | _ Xn
| j j � Sd S( N( R| R7 R{ t readline( R} ( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyR � s
c c s: | j r | j Vd | _ n x | j D] } | Vq' Wd S( N( R| R7 R{ ( R} t line( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyt __iter__� s
( t __name__t
__module__R~ R R� ( ( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyRz � s c s i � t d i d d 6d d 6� � y< t t t � � } t j rQ � j | � n
� j | � Wn t k
rs i SXd d � � f d � } xT d
d g D]F \ } } t
j | � s� � j d | � } | r� | t
j | <q� q� q� Wx* t j � D] \ } } | | d | �q� W� S( Nt defaultsRP t
HTTP_PROXYt HTTPS_PROXYc sb y � j d | � } Wn t k
r/ | } n X| d k r^ | rQ | | � } n | � | <n d S( Nt asection( t getRp R7 ( t namet defaultRx R ( t cpt result( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyt read_var� s
t httpt httpsR� Rx ( R� R� ( R� R� ( R Rz RQ RR R t PY2t readfpt read_fileRp R7 R t get_proxy_from_envR� t ost environRn RU ( R R� t schemet variablet proxyRw Rx ( ( R� R� s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyt get_config_settings� s$
c C s4 t j � t � } t j j | � t j | � d S( N( t _CONFIG_OPTIONSt clearR� R t __dict__t update( t settings( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyt set_settings_from_config_file� s
c C s� i } x� | j � D]� \ } } | j � } | j d � s@ q n | j d d � j d d � } y t t | � � | | <Wq t k
r� t j j d | | � q Xq W| S( sk
Checking headers for feature flags which start with 'KC-Flag-' and
reformat it to dictionary with keys in upper case and without 'KC-Flag-' prefix
and dashes replaced with underscores. For unification all header keys are checked in upper case.
For example:
'KC-Flag-Some-Value' -> 'SOME_VALUE'
:return: dict {'SOME_VALUE': bool, ...}
s KC-FLAG-RP t -t _s( Invalid feature flag header value %s: %s(
RU R RY t replacet boolt intt
ValueErrorR t kcarelogt error( t headerst flagst hdr_namet hdr_valuet
upper_namet
param_name( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyt convert_headers_to_feature_flags� s
c C s! t | � t j s t � n d S( N( t save_feature_flags_cacheR R+ t set_feature_flags_from_cache( R� ( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyt set_feature_flags_from_headers� s
t loggerc C s/ t | � } t j t j d t j | � �d S( Nt content( R� R R] R t FEATURE_FLAGS_CACHEt jsont dumps( R� t
feature_flags( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyR� � s c C s� t j j t j � s d St t j � � } t j | � } Wd QXxa | j � D]S \ } } | t k rk qM n | t
k r} qM n | t j | <t
j j d | | � qM Wd S( s�
Set global variables using feature flag from cached values received with patchserver headers.
Checks that option is allowed by whitelist and update global variable
using globals()
:return: None
Ns$ feature flags config override: %s=%s( R� t patht existsR R� RQ R� t loadRU t FEATURE_FLAGS_WHITELISTR� R R� R R� t info( t fR� Ru R ( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyR� � s
() R� R� Rh RP R R R R R t py23R RV t typingR R R R RR R� Rm R� R R R7 R� RZ R R Rn Rg Ry t objectRz R� R� R� R� t catch_errorst logwarnR� R� ( ( ( s5 /usr/libexec/kcare/python/kcarectl/config_handlers.pyt <module> s� (%
%