Vht @ddlmZddlZddlmZmZmZmZddlm Z ddl m Z ddl mZmZmZddlmZddlmZmZdd lmZdd lmZdd lmZdd lmZdd lmZddl m!Z!ddl"m#Z#ddl$m%Z%ddl&m'Z'ddl(m)Z)ddl*m+Z+ddl,m-Z-ddl.m/Z/ddgZ0dZ1Gddeee%eeZ2y)) annotationsN) ContainerMappingSetSequence)MappingProxyType) constants) AnsibleErrorAnsibleParserErrorAnsibleAssertionError)to_text) binary_type text_type)FieldAttribute)Base)CollectionSearch) Conditional) Delegatable)load_list_of_blocks) RoleMetadata)Taggable)add_all_plugin_dirs)AnsibleCollectionConfig) is_subpath)Sentinel) combine_varsRole hash_paramsc^t|trst|ttfs]t|tr t |j }|St|ttfr t |}|St |}|St |fS#t$rMt}|j D]!\}}|j|t|f#t |}Y|SwxYw#t$r:t}|D]}|jt|t |}Y|SwxYw)a Construct a data structure of parameters that is hashable. This requires changing any mutable data structures into immutable ones. We chose a frozenset because role parameters have to be unique. .. warning:: this does not handle unhashable scalars. Two things mitigate that limitation: 1) There shouldn't be any unhashable scalars specified in the yaml 2) Our only choice would be to return an error anyway. ) isinstancerrrr frozensetitems TypeErrorsetaddrrr)params new_paramskvs N/home/dcms/DCMS/lib/python3.12/site-packages/ansible/playbook/role/__init__.pyrr3s/ &)$ZK@X-Y fg & 3&v||~6 *h 0 3&v. #6*J fY 1 3 U "LLN8DAqNNA{1~#678'z2 ) 3 3 U 3ANN;q>23'z2  3s$B* C)AC&%C&)?D,+D,ceZdZdfd ZdZddZdZdZdZe ddZ d dZ d Z d Z d Zd!d Zd ZdZdZdZd dZd!dZd dZd"dZdZdZdZd dZdZd dZdfd Zdfd ZdZ xZ!S)#rcHd|_d|_d|_t|_d|_||_|8tjjd\}}|dk(r||_ n| |_ n||_ t|_ ||_ g|_g|_d|_g|_g|_d|_t|_t|_t|_t|_||_|i}||_||_d|_t8t:|{y)NDEFAULT_PRIVATE_ROLE_VARSdefault) _role_name _role_path_role_collectiondict _role_params_loaderstaticCconfigget_config_value_and_originpublicr _metadata_play_parents _dependencies_all_dependencies _task_blocks_handler_blocks_compiled_handler_blocks _default_vars _role_vars _had_task_run _completed_should_validate _from_files from_include_hashsuperr__init__) selfplay from_filesrHvalidater9r5global_privateorigin __class__s r*rKz Role.__init__es $ F   >%&XX%I%IJe%f "NF"$ "00  DK%  !%!(,%!V&!V& (  J%)  dD"$c"|jSN)get_namerLs r*__repr__z Role.__repr__s}}rScz|r.djd|j|jfDS|jS)N.c3&K|] }|s| ywrU).0xs r* z Role.get_name..sU!STAUs)joinr1r/)rLinclude_role_fqcns r*rVz Role.get_names3 88U(=(=t'OUU UrScTtjj|jSrU)ospathrealpathr0rWs r* get_role_pathzRole.get_role_pathsww00rSc j|jr |jSt|j|jt|j |j |j t|jt|j|jd|_|jS)N)namerdr&whentagsrNvarsrH) rIrrVrfget_role_paramsrirjrGrkrHrWs r*_get_hash_dictzRole._get_hash_dicts :::: % **,*4+?+?+AB  .t/?/?@(3 $ 1 1    zzrScft|tsy|j|jk(SNF)r rrm)rLothers r*__eq__z Role.__eq__s,%&""$(<(<(>>>rScX|i} t||||||}|j|||j} | |jvrg|j| <||j| vr|j| j ||S#t $rt d|jwxYw)N)rMrNrHrOr9r5) parent_rolezvA recursion loop was detected with the roles specified. Make sure child roles do not have dependencies on parent roles)obj)r_load_role_datarf role_cacheappend RuntimeErrorr _ds) role_includerMrsrNrHrOr9r5r role_paths r*loadz Role.loads  J 5 $:L[clr|BCA  l  D)I/-/ * 22 *11!4H 5 X#/#3#35 5 5s BB!B)c |j_|j_|j_|j _|j_|j_ |rj|jD]$}td|t|d|t&j!dj"j%dd_j&i_n2t)j&t*st-djzj!dj"j%dd_j.i_n2t)j.t*st-djzj!d}|rGt1j2|jj _j7_g_jr'j:j=d jnCt>j@}|rj:j=d |tCjj4j:r8j:jEfd j4j:Dj:rGjrd nd }d j:vr)d j:vrj:jG|j!dj"j%d}jHr"jK}jM||}|r4 tO|jPjj_)j!dj"j%d} | r6 tO| jPdjj_+yy#tT$r } t-djz|| d} ~ wwxYw#tT$r } t-djz| | d} ~ wwxYw)N_rkT)main allow_dirzKThe vars/main.yml file for role '%s' must contain a dictionary of variablesdefaultszOThe defaults/main.yml file for role '%s' must contain a dictionary of variablesmeta)ownervariable_managerloaderrc3@K|]}|jvs|ywrU) collections)r]crLs r*r_z'Role._load_role_data..s$h1aW[WgWgNgQ$hszansible.builtinzansible.legacytasksr)rMrolerrzBThe tasks/main.yml file for role '%s' must contain a list of tasks)rtorig_exchandlers)rMr use_handlersrrzEThe handlers/main.yml file for role '%s' must contain a list of tasks),rr/rfr0r1rlr3get_variable_manager_variable_manager get_loaderr4 add_parent fattributessetattrgetattrr_load_role_yamlrGgetrCr rr rBrr}r:_load_dependenciesr=rinsertrdefault_collectionrextendrwrF_get_role_argspecs_prepend_validation_taskrr;r?AssertionErrorr@) rLrzrs attr_namemetadatardefault_append_collection task_data role_argspecse handler_datas ` r*ruzRole._load_role_datasN&++&446 , = =(88:!-!B!B!D#..0  OOK ()) ]I DAi[/7<1YKRZ+[ \ ]..vD  0 >> % %    # #$h0J0J$h i   =A=R=R(9Xh % (8(88=MUYUeUe=e  ''(AB((t7G7G7K7KG7T(U   335M55iOI  D$7  Y]fjfrfrFJF\F\%]! ++JT=M=M=Q=QR\=]+^  G':?E2E  t~~'7<< &Is4B## B32B3c|rW|jjdd}|j|}|r(|j||}|sg}|jd||S)aInsert a role validation task if we have a role argument spec. This method will prepend a validation task to the front of the role task list to perform argument spec validation before any other tasks, if an arg spec exists for the entry point. Entry point defaults to `main`. :param task_data: List of tasks loaded from the role. :param argspecs: The role argument spec data dict. :returns: The (possibly modified) task list. rrr)rGr_create_validation_taskr)rLrargspecs entrypointentrypoint_arg_specvalidation_tasks r*rzRole._prepend_validation_task>sg ))--gv>J"*,,z": ""&">">?RT^"_ ! "I  O4rScd|z}d|vr |dz|dz}d|jdi|jd|j||jdd|d gd S) aCreate a new task data structure that uses the validate_argument_spec action plugin. :param argument_spec: The arg spec definition for a particular role entry point. This will be the entire arg spec for the entry point as read from the input file. :param entrypoint_name: The name of the role entry point associated with the supplied `argument_spec`. z*Validating arguments against arg spec '%s'short_descriptionz - z&ansible.builtin.validate_argument_specoptionsr)typerhargument_spec_namerd)module argument_specprovided_argumentsvalidate_args_contextalways)actionrhrj)rr3r/r0)rLrentrypoint_name task_names r*rzRole._create_validation_task[s}A?R - /!E)M:M,NNIC!.!2!29b!A&*&7&7" OO*9 OO * J  rSc d}tjj|j|}|jj |r|jj |rgd}|d}|jdn|}|jdd|jj||||}|r|D]} t| |s1tdt| d|jdt|d |jj| } | s^|t| t r t#|| }n| }|r|S|S|td |d ||S) aj Find and load role YAML files and return data found. :param subdir: subdir of role to search (vars, files, tasks, handlers, defaults) :type subdir: string :param main: filename to match, will default to 'main.' if not provided. :type main: string :param allow_dir: If true we combine results of multiple matching files found. If false, highlander rules. Only for vars(dicts) and not tasks(lists). :type allow_dir: bool :returns: data from the matched file(s), type can be dict or list depending on vars or tasks. N)z.ymlz.yamlz.jsonrrzFailed loading 'z ' for role (z/) as it is not inside the expected role path: ''z'Could not find specified file in role: /)rcrdr`r0r4r is_directoryrwrfind_vars_filesrr r r/load_from_filer rr) rLsubdirrrdata file_path extensions_main found_filesfoundnew_datas r*rzRole._load_role_yamlzsJGGLL&9 << # #I .4<<3L3LY3W3J|!!"%!!!R(,,66y%U^_K("E%eY7029%.$//SZ[dSe2ghh $||::5AH+ 8W0M#/h#?D#+D )!  +"* !([acg)hii rScg}|jjD]@}tj||j||j }|j |B|S)zr Recursively loads role dependencies from the metadata list of dependencies, if it exists )rMrsr5)r: dependenciesrr}r;r5rw)rLdepsrzr{s r*rzRole._load_dependenciessU  NN77 L ,TZZTRVR]R] ^A KKN  rSct|ts t||jvr|jj |yy)z/ adds a role to the list of this roles parents N)r rr r<rw)rLrss r*rzRole.add_parents8+t,') ) dmm + MM  - ,rSc|jSrU)r<rWs r* get_parentszRole.get_parentss }}rScg}|jD]2}|j|j|j|4|SrU)r<r get_dep_chainrw)rL dep_chainparents r*rzRole.get_dep_chainsG mm %F   V113 4   V $ %rSc|gn|}t}|jD]}t||j}|r|D]}t||j}t||j}|SrU)r2get_all_dependenciesrget_default_varsrB)rLr default_varsdeprs r*rzRole.get_default_varss#+B v ,,. NC' c6J6J6LML N # P+L&:N:NO  P#L$2D2DE rSc|gn|}t}|r5|D]0}|st||j}t||j}2|SrU)r2rrkrC)rLr only_exportsinherited_varsrs r*get_inherited_varszRole.get_inherited_varssV#+B  # Q#%1.&++%NN!-nf>O>O!P QrSc|gn|}i}|r|D]}t||j}t||j}|SrU)rr3)rLrr&rs r*rlzRole.get_role_paramssP#+B  # C%ff.A.AB Cfd&7&78 rSch|gn|}i}|j||}g}|jD]5}||vst||jdd}|j |7t||j }|s4|rt||j |}t||j}|S)N)rFT)include_paramsr)r)rrrget_varsrwrCrlrk)rLrrrall_varsseenrs r*rz Role.get_varss#+B **9<*P,,. !C$'#,,ebf,2gh C  ! $//:'$2F2FQZ2F2[\$Hdii8HrSc |jddSrU)r=rWs r*get_direct_dependencieszRole.get_direct_dependenciess!!!$$rSc|jgg|_|jD]M}|jD]}|jj||jj|O|jS)z Returns a list of all deps, built recursively from all child dependencies, in the proper order in which they should be executed or evaluated. )r>rrrw)rLr child_deps r*rzRole.get_all_dependenciess~  ! ! )%'D "335 3!$!9!9!;=I**11)<=&&--c2 3 %%%rSc |jddSrU)r?rWs r*get_task_blockszRole.get_task_blocks&s  ##rScN|jr |jSgx|_}|g}||gz}|jD]&}|j||}|j|(|jD]1}|j }||_||_|j|3|S)NrMr) rArget_handler_blocksrr@copy _dep_chainr;rw) rLrMr block_list new_dep_chainr dep_blocks task_blocknew_task_blocks r*rzRole.get_handler_blocks)s  ( (00 0577%   I!TF* //1 *C//T]/SJ   j ) *.. .J'__.N(5N %#'N   n -  . rSc2|j|jvS)zs Returns true if this role has been iterated over completely and at least one task was run )rhrE)rLhosts r*has_runz Role.has_runEs yyDOO++rSc<ddlm}ddlm}g}|g}||gz}|j }|D]&}|j ||} |j | (|jD]1} | j} || _ || _ |j| 3||} |j| _ || _ |j| _d| _|| } || _ d| _d d i| _d | _d g| _d | _| g| _|j| |S) a Returns the task list for this role, which is created by first recursively compiling the tasks for all direct dependencies, and then adding on the tasks for this role. The role compile() also remembers and saves the dependency chain with each task, so tasks know by which route they were found, and can correctly take their parent's tags/conditionals into account. r)Block)Taskr)rMF)blockr _raw_params role_completeTr)ansible.playbook.blockransible.playbook.taskrrcompilerr?rrr;rwr4_rolerrun_oncerargsimplicitrjrir)rLrMrrrrrrrrrr eor_blockeor_tasks r*rz Role.compileMs4 1.   I!TF* ++- *C$-HJ   j ) *++ .J'__.N(5N %#'N   n -  . t$  LL  &*&<&< #" i( &8  !   #* )$rSc\tt| }|j|d<|j|d<|j |d<|j |d<|j|d<|jj|d<|jj|d<|jj|d<|r;g}|jD]!}|j|j#||d <g}|jD]#}|j|jd %||d <|S) Nr/r0rCr3rBrDrEr:r=F include_depsr<)rJr serializer/r0rCr3rBrDrrEr:rrwr<)rLrresrrparentsrrRs r*rzRole.serializes"D$)+ OOL OOL OOL"//N#11O#11668O OO002L>>335K D446 . DNN,- .#'C mm AF NN6+++? @ A!J rSc||jdd|_|jdd|_|jdt|_|jdt|_|jdt|_|jdt|_|jdt|_|rRg}|jd gD].}t}|j||j|0t|d ||jd g}g}|D]0}t}|j|d |j|2t|d ||jd } | r"t} | j| | |_tt|+|y)Nr/rr0rCr3rBrDrEr=r<Fr r:)rr/r0r2rCr3rBrDrEr deserializerwrrr:rJ) rLrrrrr{ parent_datarr metadata_datamrRs r*rzRole.deserializesk((<4((<4((<8 HH^TV<!XXotv>!XXotv>((<8 Dxx4 F c" A  D/4 0hhz2. ! FA MM&uM 5 NN1   j'*- A MM- (DN dD%d+rSc||_|jD]}|j||jD]}|j|yrU)r4r< set_loaderr)rLrrrs r*rzRole.set_loadersN mm &F   f % &//1 #C NN6 " #rS)NNFTNT)TrUro)NTF)"__name__ __module__ __qualname__rKrXrVrfrmrq staticmethodr}rurrrrrrrrrrrlrrrrrrrrrr __classcell__)rRs@r*rrcs*%X 1"? 554QGf=8: >4l .  B% &$8,0d4,B#rS)3 __future__rrccollections.abcrrrrtypesransibler r6ansible.errorsr r r +ansible.module_utils.common.text.convertersr ansible.module_utils.sixrransible.playbook.attributeransible.playbook.baser!ansible.playbook.collectionsearchransible.playbook.conditionalransible.playbook.delegatableransible.playbook.helpersransible.playbook.role.metadataransible.playbook.taggableransible.plugins.loaderransible.utils.collection_loaderransible.utils.pathransible.utils.sentinelransible.utils.varsr__all__rrr\rSr*r3ss$# ==""RR?;5&>4487.6C)++ = !- `\ #4h(8+\ #rS