�
9�Egc@sY
dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZdd
lZdd
lZddlm	Z	
ddl
mZmZm
Z

dd
lZddlmZmZ
ddlmZ
ddlmZmZmZmZ
ddlmZ
ddlmZ
dd	lmZ
dd
l m!Z!
d�Z"de#f
d
��YZ$de#f
d��YZ%d
S(i����N(
tUnsupportedOperation(tProcesstQueuetPipe(tget_actor_metadatat
get_actors(
tload_module(tActorInspectionFailedErrortLeappRuntimeErrortMultipleActorsErrortUnsupportedDefinitionKindError(
tDefinitionKind(
tcreate_audit_entry(
t_LeappDeprecationWarning(
tLeappLibrariesFindercCsi|j�
gt
�D]}t|�
^q}g|D]}|d
|jkr3|^q3}|
j|�

dS(s]

    Retrieves the actor information in a child process and returns the results back through `result_queue`.

    :param definition: the actor definition to load
    :type definition: :py:class:`ActorDefinition`
    :param result_queue: queue to pass results back to the calling process
    :type result_queue: :py:class:`multiprocessing.Queue`
    tpathN(tloadRRt	full_pathtput(t
definitiontresult_queuetactortresulttentry((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyt
inspect_actors	

"
,
tActorCallContextcBs/eZ
dZd
�Zed��
Zd�ZRS(s7
    Wraps the actor execution into child process.
    cCs1|
|_||_
||_||_||_d
S(s�

        :param definition: Actor definition
        :type definition: :py:class:`leapp.repository.actor_definition.ActorDefinition`
        :param logger: Logger
        :type logger: :py:class:`logging.Logger`
        :param messaging: Leapp Messaging
        :type messaging: :py:class:`leapp.messaging.BaseMessaging`
        :param config_model: Workflow provided configuration model
        :type config_model: :py:class:`leapp.models.Model` derived class
        N(Rtloggert	messagingtconfig_modeltskip_dialogs(tselfRRRRR((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyt__init__+s
	
	
	
	
c	Cs�
|dk	r9yt
j|�
t_Wq9tk
r5


q9Xntjd
t�
��
}	tj	dddt
�
|j�
|j���
gt
�D]}
|
j|jkr�|
^q�d}|d|
d|d|d	|�}y|j||�
Wn'tk
r



|jtj��

�n
XWdQXz�|jt
jd
<x�|	D]�}
t|
jt
�r,
it|
j�
d6|
jd6|
jdkr�
tj|
j|
j�n|
jd
6|
jd6|
jjd6|
jjd6}t d|�
q,
q,
WWdt
jj!d
�

XWdQXdS(NtrecordtactiontalwaystcategoryiRRRRtLEAPP_CURRENT_ACTORtmessagetfilenametlinetlinenotsincetreasontdeprecation("tNonetostfdopentsyststdintOSErrortwarningstcatch_warningstTruetsimplefilterR
Rtinjected_contextRtnametrunt	Exceptiontsendt	tracebackt
format_exctenviront
issubclassR#tstrR%R&R't	linecachetgetlineR(R)tmsgRtpop(R0RRRRRt
error_pipetargstkwargst	recordingRttarget_actortactor_instancetrecR((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyt_do_run<s<











2

	














1




c
	
Os�ytj
j�}Wntk
r,


d}n
Xt�\}}td
|jd||j|j	|j
|j|j||
|f	�}|j
�
|j�
|jdkr�djd|j
jd|j�}d}|j�r�|j�}nt||��
ndS(sD
        Performs the actor execution in the child process.
        ttargetREisDActor {actorname} unexpectedly terminated with exit code: {exitcode}t	actornametexitcodeN(R/R0tfilenoRR,RR
RKRRRRRtstarttjoinRNtformatR7tpolltrecvR(	RRERFR0t
pipe_receivertpipe_sendert
pterr_messagetexception_info((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyR8cs"













	

(t__name__t
__module__t__doc__RtstaticmethodRKR8(((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyR&s	'tActorDefinitioncBsU
eZ
dZdd
�
Zed��
Zd�Zd�Zd�Z	d�Z
ddded�Zed��
Z
ed	��
Zed
��
Zed��
Zed��
Zed
��
Zed��
Zed��
Zejd��
Zed��
Zed��
Zed��
Zed��
Zed��
Zed��
Zed��
ZRS(s#
    Defines actor resources.

    cCsI|ptj
d
�
|_|
|_||_i|_d|_d|_dS(s�
        :param log: Logger
        :type log: :py:class:`logging.Logger`
        :param directory: Actor directory
        :type directory: str
        :param repo_dir: Repository directory
        :type repo_dir: str
        sleapp.actorN(	tloggingt	getLoggertlogt
_directoryt	_repo_dirt_definitionsR,t_modulet
_discovery(Rt	directorytrepo_dirRa((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyR�s	
	
	
	
	
c

Cs%tj
jtj
j|j|j��
S(
N(R-RtrealpathRQRcRb(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyR�scCsc|
tj
krC|jjd
|
j�
tdjd|
j�
�
�
n|jj|
g�j	|�

dS(s�
        Adds any kind of actor resource to the Definition

        :param kind: kind of resource added
        :type kind: str
        :param path: path to the added resource
        :type path: str
        s:Attempt to add item type %s to actor that is not supportedsActors do not support {kind}.tkindN(
RtACTOR_WHITELISTRaterrorR7R
RRRdt
setdefaulttappend(RRjR((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pytadd�s	


c
Cs�i|jd
6|j
d6|jd6|jd6|jd6|jd6|jd6|jd6|jd	6g|j	D]}
|
j
�^qgd
6|jd6|jd6|j
d
6|jd6|jd6S(s_
        :return: dump of actor resources (path, name, tools, files, libraries, tests)
        RR7t
class_nametdescriptionttagstconfig_schemastconsumestproducestapistdialogsttoolstfilest	librariestconfigsttests(RgR7RpRqRrRsRtRuRvRwt	serializeRxRyRzR{R|(Rtdialog((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyR}�s 


















#








c
Cs�|js�|j
��n
tjjtjj|j|j��
}
x?tj	|
f
�
D]+\}}}|sPt
||�|_PqPqPWWd
QXnd
S(s>
        Loads the actor module to be introspectable.
        N(ReR6R-RtabspathRQRcRgtpkgutiltiter_modulesR(RRtimporterR7tis_pkg((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyR�s	


'
"


c
Cs�
|js�
|j
jd
|j�
td�
}
tdtd||
f�}|j�
|j�
|j	dkr�|j
j
d|j|j	�
tdjd|j�
�
�
n|j
��
|
j�}Wd	QX|s�|j
j
d
|j�
tdjd|j�
�
�
nt|�
dkr6
|j
j
d|j�
t|j�
�
n|d|_x<|jd
D]*}||jkrQ
|j|f
7_qQ
qQ
Wn|jS(sr
        Performs introspection through a subprocess.

        :return: Dictionary with discovered items.
        sStarting actor discovery in %si
RLREis-Process inspecting actor in %s failed with %ds$Inspection of actor in {path} failedRNs1Process inspecting actor in %s returned no results1Inspection of actor in {path} produced no resultss$Actor in %s returned multiple actorsRr(RfRatdebugRgRR
RRPRQRNRlRRRR6tgettlenR	tactors(Rt
qRWRttag((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pytdiscover�s.	
























cCs%td
|d|
d|d|d|�S(NRRRRR(
R(RRRRR((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyt__call__�s

c

Cs|j�d
S(s3
        :return: Tuple of defined dialogs
        Rw(
R�(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyRw�sc

Cs|j�d
S(s3
        :return: Tuple of consumed models
        Rt(
R�(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyRt
sc

Cs|j�d
S(s3
        :return: Tuple of produced models
        Ru(
R�(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyRu
sc

Cs|j�d
S(s>
        :return: Tuple of tags assigned to the actor
        Rr(
R�(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyRr
sc

Cs|j�d
S(s+
        :return: Actor class name
        Rp(
R�(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyRp
sc

Cs|j�d
S(s.
        :return: Actor internal name
        R7(
R�(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyR7
sc

Cs|j�d
S(s,
        :return: Actor description
        Rq(
R�(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyRq#
sc

Cs|j�d
S(s/
        :return: Actor config_schemas
        Rs(
R�(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyRs*
sc
#sOtj
jd
d�}
dj|
jd�
t�f
d��jD�
�
�
tj
d
<tj
jdd�}�jr�tj	j�j
�j�jd�tj
d<ntj
jdd�}�jr�tj	j�j
�j�jd�tj
d<ntj
}tj
jtdd	d
g�jD]$}tj	j�j
�j|�^q
��

tj
jtddd
g�jD]$}tj	j�j
�j|�^qa
��

tj�}tjtj	j�j
�j��

z	dV
Wdtj|�

|
tj
d
<|dk	r�
|tj
d<ntj
jdd�
|dk	r.|tj
d<ntj
jdd�
|t_
XdS(
s


        Prepares the actor environment for running the actor.
        This includes injecting actor private libraries into :py:mod:`leapp.libraries.actor`
        and setting environment variables for private tools and files.

        :note: Use with caution.
        tPATHtt
:c
3s-|]#}
tj
j�j�j|
�V
qdS(
N(R-RRQRcRb(t.0R(
R(sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pys	<genexpr>=
stLEAPP_FILESitLEAPP_TOOLSt
module_prefixsleapp.libraries.actortpathssleapp.configs.actorN(R-R=R�RQtsplittlistRxR,RyRRcRbR/t	meta_pathRnRRzRgR{tgetcwdtchdirRC(Rtpath_backuptfiles_backupttools_backuptmeta_path_backupt
xt
previous_path((
RsE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyR61
s>


'
	
/
	
/
	


8	


8
"

	



c

Cst|j
�d
�
S(s;
        :return: names of APIs used by this actor
        Rv(ttupleR�(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyRvi
sc


Cs|jS(
s7
        :return: The folder path of the actor
        (
Rb(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyRgp
sc

Cst|j
jtjd
��
S(s`
        :return: Tuple with path to the tools folder of the actor, empty tuple if none
        ((R�RdR�RtTOOLS(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyRxw
sc

Cst|j
jtjd
��
S(sd
        :return: Tuple with path to the libraries folder of the actor, empty tuple if none
        ((R�RdR�Rt	LIBRARIES(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyRz~
sc

Cst|j
jtjd
��
S(s`
        :return: Tuple with path to the files folder of the actor, empty tuple if none
        ((R�RdR�RtFILES(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyRy�
sc

Cst|j
jtjd
��
S(sb
        :return: Tuple with path to the configs folder of the actor, empty tuple if none
        ((R�RdR�RtCONFIGS(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyR{�
sc

Cst|j
jtjd
��
S(s`
        :return: Tuple with path to the tests folder of the actor, empty tuple if none
        ((R�RdR�RtTESTS(
R((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyR|�
sN(RZR[R\R,RtpropertyRRoR}RR�tFalseR�RwRtRuRrRpR7RqRst
contextlibtcontextmanagerR6RvRgRxRzRyR{R|(((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyR^�s0				+8(&R�R@R_R-R�R/R;R2tioRtmultiprocessingR
RRtleapp.libraries.actortleapptleapp.actorsRRtleapp.compatRtleapp.exceptionsRRR	R
tleapp.repository.definitionRtleapp.utils.auditRtleapp.utils.deprecationR
tleapp.utils.libraryfinderRRtobjectRR^(((sE/usr/lib/python2.7/site-packages/leapp/repository/actor_definition.pyt<module>
s(











"


	Z