�
9�Egc@s@
dd
lm
Z

ddlZddlZddlZddlmZ
ddlmZm	Z	
ddl
mZmZ
ddl
ZddlZddlmZ
ddlmZ
ddlmZ
dd	lmZ
dd
lmZ
ddlmZmZmZ
ddlZddlmZ
d
e f
d��YZ!de f
d��YZ"dS(i����(
t	getLoggerN(
tload_module(tRepoItemPathDoesNotExistErrortUnsupportedDefinitionKindError(t
get_modelstresolve_model_references(
tActorDefinition(
tDefinitionKind(
tget_tags(
t
get_topics(
tLeappLibrariesFinder(tget_repository_idtget_repository_linkstget_repository_name(
t
get_workflowst
_LoadStagec
Bs&eZ
dZd
ZdZdZdZRS(tinitialtmodelst	librariestactorst	workflows(t__name__t
__module__tINITIALtMODELSt	LIBRARIEStACTORSt	WORKFLOWS(((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyRs





t
RepositorycBs1
eZ
dZd
�Zed��
Zed��
Zed��
Zd�Ze	d��
Z
d�Zeded�Zd	�Zd
�Zd�Zd�Zed
��
Zed��
Zed��
Zed��
Zed��
Zed��
Zed��
Zed��
Zed��
Zed��
ZRS(s�
    The Repository class represents a place where all resources (actors, models, tags, etc.) are defined. See the
    :doc:`Repository Directory Layout <../repository-dir-layout>`.
    cCswt|
�
|_
td
�
j|j
�
|_|
|_t|
�
|_t|
�
|_	i|_
|jjd|j
|
�
dS(s^
        :param directory: Path to the repository folder
        :type directory: str
        sleapp.repositorys*A new repository '%s' is initialized at %sN(R
tnameRtgetChildtlogt	_repo_dirRt_repo_idRt_repo_linkst_definitionstinfo(tselft	directory((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyt__init__#s

	


	
c


Cs|jS(
N(
R (
R%((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pytrepo_dir0sc


Cs|jS(
N(
R!(
R%((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pytrepo_id4sc


Cs|jS(
N(
R"(
R%((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyt
repo_links8scCsX|
j�}
xE|j
D]:}|jj�}|jj�}|
||fkr|SqWd
S(s�
        Finds an actor in the repository

        :param name: Name of the actor
        :type name: str
        :return: None or Actor
        N(tlowerRRt
class_nametNone(R%Rtactort
actor_nametactor_class((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pytlookup_actor<s	





c
Csj|j�}xWt
jj�D]F}
|
jj�}|
jj�}|
j}||||fkr|
SqWd
S(s�
        Finds a workflow in the repository

        :param name: Name of the workflow class name, Workflow.name, or Workflow.short_name
        :type name: str
        :return: None or Workflow
        N(R+tleappRRRRt
short_nameR-(Rtworkflowt
workflow_nametworkflow_classtworkflow_short_name((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pytlookup_workflowMs	



	


cCs�|jj
d
|
jt|t�r*|jn|�
|
tjkr^tdj	d|
j�
�
�
nt|t�s�t
jj|j
|�}t
jj|�
s�|jjd|�
t|
||��
n|}n|jj|
g�j|�

dS(sX

        Adds any supported kind of a resource to the repository

        :param kind: specific kind of the repository resource
        :type kind: :py:class:`leapp.repository.definition.DefinitionKind`
        :param item: Item that will be added
        :type item: :py:class:`leapp.repository.actor_definition.ActorDefiniton` or str
        sAdding %s - %ss#Repositories do not support {kind}.tkinds:Attempted to add %s, which is not in the repositories pathN(RtdebugRt
isinstanceRR&RtREPO_WHITELISTRtformattostpathtjoinR texiststerrorRR#t
setdefaulttappend(R%R9titemt	full_path((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pytadd_s	1






	c	CsI|s|tj
kru|jjd
|j�
|jjd�

|j|jd�
|jjd�

|j|jd�
n|s�|tjkr�|jjd�

|j|j	d�
|
r�t
�
q�n|s�|tjkr�
|jjd�

|jd	|j
�
|jjd
�

|jd|j
�
|jjd�

|jd
|j�
|jjd�

tjjtddd|j��

tjjtddd|j��

tjjtddd|j��

n|s	|s�
|tjkr	|jjd�

x|jD]}|j�
q�
Wq	n|s|tjkrE|jjd�

|j|jd�
ndS(s

        Loads the repository resources

        :param resolve: Decides whether or not to perform the resolving of model references
        :type resolve: bool
        :param stage: Stage to load - Required for repository managers
        :type stage: _LoadStage value
        sLoading repository %ssLoading tag moduless
leapp.tagssLoading topic modulessleapp.topicssLoading model modulessleapp.modelss$Extending PATH for common tool pathstPATHs2Extending LEAPP_COMMON_TOOLS for common tool pathstLEAPP_COMMON_TOOLSs2Extending LEAPP_COMMON_FILES for common file pathstLEAPP_COMMON_FILESs;Installing repository provided common libraries loader hookt
module_prefixsleapp.libraries.commontpathssleapp.workflows.apisleapp.configs.commonsRunning actor discoverysLoading workflow modulessleapp.workflowsN(RRRR:Rt
_load_modulesttagsttopicsRRRRt_extend_environ_pathsttoolstfilestsyst	meta_pathRDR
RtapistconfigsRRtdiscoverRR(R%tresolvetstagetskip_actors_discoveryR.((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pytloadvs<	
















"
"
%





cCs�g|
D]*}tj
j|jtj
j|�
�^q}|jd
�
sP|d
n|}x3tj|d|�

D]\}}}t||�
qlWdS(s�
        :param modules: Paths to modules of the same type to be imported
        :type list of str
        :param prefix: A prefix to be appended to module name in sys.modules
        :type str
        t
.tprefixN(	R>R?R@R tdirnametendswithtpkgutiltiter_modulesR
(R%tmodulesR]tmoduletdirectoriestimporterRtispkg((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyRM�s7

%
c
Cs�
d
�}
d�}i|jd6g|j
D]}||j��
^q)d6g|j|j�
D]}td|fg
�
^q[d6|
t|j�d6|
t|j	�d6|
t
|j�d	6|
t|j
�d
6g|j|j�
D]}td|fg
�
^q�d6g|j|j�
D]}td|fg
�
^q
d6g|j|j�
D]}td|fg
�
^qF
d
6g|j|j�
D]}td|fg
�
^q{
d6S(sA
        :return: Dictionary of all repository resources
        cSskg}|�}xU|D]M}tj
jtj|jjjd
d��
|
kr|j|j	��

qqW|S(Ns.pycs.py(
R>R?tabspathRSRbRt__file__treplaceRDt	serialize(tfuncRbtresulttdatatentry((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pytfiltered_serialization�s

	


1

c
Ss�|jig|j
d
d�D]}
|
j^qd
6g|j
dd�D]}
|
j^qEd6g|j
dd�D]}|j^qnd6�

|S(NtconsumestproducesRN((((tupdatetgetR(Rmtmodelttag((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pytmapped_actor_data�s

	
)
)
-R(RR?RURORRNRRQRRRRV(R RRjtrelative_pathsRUtdictR	RORRRRNRRRQRRRRV(R%RoRvt
aR?((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyRj�s		


)
5




5
5
5
csLd
jt
jj|
d�jd
�
t�f
d�|D�
�
�
t
j|
<dS(Nt
:tc
3s'|]}
tj
j�j|
�V
qdS(
N(R>R?R@R (t.0R?(
R%(s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pys	<genexpr>�s(R@R>tenvironRstsplittlist(R%RRL((
R%s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyRP�s
$
cst�f
d
�|
D�
�
S(s=
        :return: Tuple of repository relative paths
        c
3s'|]}
tj
j|
�j�V
qdS(
N(R>R?trelpathR (R|t
x(
R%(s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pys	<genexpr>�s(
ttuple(R%RL((
R%s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyRw�sc

Cst|j
jtjd
��
S(s<
        :return: Tuple of actors in the repository
        ((R�R#RsRtACTOR(
R%((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyR�sc

Cst|j
jtjd
��
S(s:
        :return: Tuple of apis in the repository
        ((R�R#RsRtAPI(
R%((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyRU�sc

Cst|j
jtjd
��
S(s<
        :return: Tuple of topics in the repository
        ((R�R#RsRtTOPIC(
R%((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyRO�sc

Cst|j
jtjd
��
S(s<
        :return: Tuple of models in the repository
        ((R�R#RsRtMODEL(
R%((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyR�sc

Cst|j
jtjd
��
S(s:
        :return: Tuple of tags in the repository
        ((R�R#RsRtTAG(
R%((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyRN
sc

Cst|j
jtjd
��
S(s?
        :return: Tuple of workflows in the repository
        ((R�R#RsRtWORKFLOW(
R%((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyR
sc

Cst|j
jtjd
��
S(s;
        :return: Tuple of tools in the repository
        ((R�R#RsRtTOOLS(
R%((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyRQ
sc

Cst|j
jtjd
��
S(s?
        :return: Tuple of libraries in the repository
        ((R�R#RsRR(
R%((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyR
sc

Cst|j
jtjd
��
S(s=
        :return: Tuple of configs in the repository
        ((R�R#RsRtCONFIGS(
R%((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyRV
sc

Cst|j
jtjd
��
S(s;
        :return: Tuple of files in the repository
        ((R�R#RsRtFILES(
R%((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyRR#
sN(RRt__doc__R'tpropertyR(R)R*R1tstaticmethodR8RGtTrueR-tFalseR[RMRjRPRwRRURORRNRRQRRVRR(((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyRs.	
		-		+		(#tloggingRR>R`RStleapp.compatR
tleapp.exceptionsRRtleapp.modelsRRtleapp.libraries.commonR2tleapp.configs.commont!leapp.repository.actor_definitionRtleapp.repository.definitionRt
leapp.tagsRtleapp.topicsR	tleapp.utils.libraryfinderR
tleapp.utils.repositoryRRR
tleapp.workflowsRtobjectRR(((s=/usr/lib/python2.7/site-packages/leapp/repository/__init__.pyt<module>
s$