�
9�Egc@sX
dZe
Zd
dlZd
dlZd
dlZd
dlZd
dlm	Z	
d
dl
Z
d
dlZd
dlm
Z

yd
dlmZ
Wn!ek
r�


d
dlmZ
n
Xdaejd�
Zdef
d	��YZd
ef
d��YZe
jej�
ddd
��Y�
Zd�Zdd�
Zd�Zd�Zd�Zd�Z d�Z!dS(sj

Config file format:
    yaml file like this:

---
# Note: have to add a fields.Map type before we can use yaml mappings.
section_name:
    field1_name: value
    field2_name:
        - listitem1
        - listitem2
section2_name:
    field3_name: value

Config files are any yaml files in /etc/leapp/actor_config.d/
(This is settable in /etc/leapp/leapp.conf)

i����N(
tdefaultdict(
tModelViolationError(
tCSafeLoader(
t
SafeLoadersleapp.actors.configtSchemaErrorc
BseZ
dZRS(
s�
    Raised when actors use conflicting schemas.

    For example, one schema wants `section.field` to be an integer and other schema wants
    `section.field` to be a string.
    (t__name__t
__module__t__doc__(((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pyR-stValidationErrorc
BseZ
dZRS(
s[
    Raised when a config file fails to validate against any of the available schemas.
    (RRR(((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pyR6stConfigcBs�eZ
dZejd
��
Zejd��
Zejd��
Zejd��
Zejd��
Z	e
d��
Ze
d��
ZRS(s

    An Actor config schema looks like this.

    ::
        class RHUIConfig(Config):
            section = "rhui"
            name = "file_map"
            type_ = fields.Map(fields.String())
            description = 'Description here'
            default = {"repo": "url"}
    c


CsdS(
N((
tself((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pytsectionLsc


CsdS(
N((
R
((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pytnamePsc


CsdS(
N((
R
((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pyttype_Tsc


CsdS(
N((
R
((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pytdescriptionXsc


CsdS(
N((
R
((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pytdefault\sc
Cs*i
i
|jd
j
|j�
6|j6}
|
S(s�
        Return a dictionary representation of the config item that would be suitable for putting
        into a config file.
        s{0}_description__(RtformatRR(tclstrepresentation((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pytto_dict`s

 c

CsFi|jd
6|j
d6|jd6|jj�d6|jd6|jd6S(s@
        :return: Serialized information for the config
        t
class_nameRRttypeRR(RRRR
t	serializeRR(
R((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pyRqs









(
RRRtabctabstractpropertyRRR
RRtclassmethodRR(((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pyR	?s
cCs_xX|
j�D]J\}}||kr2|||<q
x"|D]\}}||||<q9Wq
Wd
S(s�
    Merge two dictionaries representing configuration.  fields in new_config overwrite
    any existing fields of the same name in the same section in configuration.
    N(
titems(t
configurationt
new_configtsection_nameRt
field_nametfield((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pyt
_merge_config�s




s/etc/leapp/actor_conf.dc
Cs�tjt
jj|d
��
}
g|
D]*}|jd�
sI|jd�
r%|^q%}
|
j�
i}x�|
D]|}t|�
�}|j�}WdQXytj	|t
�}Wn/tk
r�
}
tj
d|t|�
�
�n
Xt||�
qlW|S(s_
    Read all configuration files from the config_dir and return a dict with their values.
    t
*s.ymls.yamlNsCWarning: unparsable yaml file %s in the config directory. Error: %s(tglobtostpathtjointendswithtsorttopentreadtyamltloadRt	ExceptiontlogtwarningtstrR (t
config_dirtconfig_filest
fRtconfig_filetraw_cfgt
parsed_configt
e((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pyt_get_config�s
7








	

c
Cs�t�}
t
t�
}x�|D]�}x�|D]�}|j|jf}||
kr�|
||kr�d
jd|jd|j�}tj|�

t|�
�
n|
j	|�

|||j|j<q)WqW|S(s`
    Merge all schemas into a single dictionary and validate them for errors we can detect.
    skTwo actors added incompatible configuration items with the same name for Section: {section}, Field: {field}RR(
tsetRtdictRRRR-terrorRtadd(tschemastadded_fieldstnormalized_schematschemaRtunique_nametmessage((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pytnormalize_schemas�s	





		





cCsBy|j|
d
|�


Wn$t
k
r=
}
tjd|�
tSXtS(s


    Return False if the field is not of the proper type.

    :param str field_path: Path in the config where the field is placed.
                           Example: A field 'target_clients' in a section 'rhui' would have a path 'rhui.target_clients'
    Rs/Configuration value failed to validate with: %s(t_validate_model_valueR
R-tinfotFalsetTrue(t
field_typetfield_valuet
field_pathR6((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pyt_validate_field_type�s


cCs�
x�|j�D]�\}}||
krJd
j
d|�
}tj|�

q
nx[|D]S}|jd�
rlqQn||
|krQdj
d|d|�}tj|�

qQqQWq
Wi}x�|
j�D]�\}}x�|j�D]�\}}y|||}Wn>tk
r6



|j|i�}||<|j}|||<n
Xdj
||�}	t|j	||	�s
t
dj
d|d|��
�
n|j|i�}
||
|<|
||<q�Wq�W|S(Ns5A config file contained an unknown section: {section}Rt__sNA config file contained an unknown field: (Section: {section}, Field: {field})Rs{0}.{1}sPConfig value for (Section: {section}, Field: {field}) is not of the correct type(RRR-R.R&tKeyErrortgetRRJR
R(tactor_configR?RRRARtnormalized_actor_configRtvalueRItnormalized_section((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pyt_normalize_config�s<





	





	





cCs/tr
tSt
|�
}t||
�}|atS(
s�
    Return Actor Configuration.

    :returns: a dict representing the configuration.
    :raises ValueError: if the actor configuration does not match the schema.

    This function reads the config, validates it, and adds any default values.
    (t
_ACTOR_CONFIGR7RR(R0R<tconfig((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pyR+
s



c
CsItt
�
}
x0|D](}t|j|j|
|j|j<qWt
|
�
S(
sOCalled by the actor to retrieve the actor configuration specific to this actor.(RR9RSRR(R?RR((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pytretrieve_config1
s	


&(("RRt
__metaclass__RR"tloggingtos.pathR#tcollectionsRtsixR*tleapp.models.fieldsR
RRtImportErrortNoneRSt	getLoggerR-R,RRt
add_metaclasstABCMetaR	R R7RBRJRRR+RU(((s7/usr/lib/python2.7/site-packages/leapp/actors/config.pyt<module>s2








		%B	
	 		C