VhPFddlmZddlZddlZddlZddlmZddlmZm Z ddl m Z ddl mZddlmZddlmZdd lmZmZdd lmZdd lmZdd lmZdd lmZddlm Z m!Z!eZ"dZ ddZ#ddZ$dZ%GddeZ&Gdde&Z'Gdde(Z)Gdde(Z*y)) annotationsN)Mapping) AnsibleErrorAnsibleParserError)to_safe_group_name) parse_address) AnsiblePlugin)CachePluginAdjudicator)to_bytes to_native)boolean) string_types)Templar)Display) combine_varsload_extra_varsct|ddS)NT)forcesilent) original_safe)names R/home/dcms/DCMS/lib/python3.12/site-packages/ansible/plugins/inventory/__init__.pyrr*s T$ 77c d|vS)z A helper function that checks a given host line to see if it contains a range pattern described in the docstring above. Returns True if the given line contains a pattern, else False. [)lines r detect_ranger/s $;rcg}|r|jdddjdddjd\}}}|jd}t|dk7rt|dk7r td|d }|d}t|dk(rd}n|d}|sd }|s td |d d k(r8t|dkDr*t|t|k7r td fd } nt} t j j|} t j j|} | | kDr tdtt j | | dzt|} | D]S} dj|| | |f}t|r|jt|C|j!|U|Sy#t$r.tt|t|dzt|} YwxYw)a A helper function that expands a given line that contains a pattern specified in top docstring, and returns a list that consists of the expanded version. The '[' and ']' characters are used to maintain the pseudo-code appearance. They are replaced in this function with '|' to ease string splitting. References: https://docs.ansible.com/ansible/latest/user_guide/intro_inventory.html#hosts-and-groups r|]:z.host range must be begin:end or begin:end:stepr0z!host range must specify end valuez:host range must specify equal-length begin and end formatsc8t|jSN)strzfill)xrlens rfillz#expand_hostname_range..fillgs1v||D))rz!host range must have begin <= endN)replacesplitlenrr)string ascii_lettersindexlistint ValueErrorrangejoinrextendexpand_hostname_rangeappend)r all_hostsheadnrangetailboundsbegendstepr-i_begi_endseqrseqhnamer,s @rr;r;9sI  $||Ca8@@c1MSSTWXvtc" v;! F q 0OP PQiQi v;! D!9DCBC C q6S=SX\s8Ds3x"#_`` *D ;((..s3E((..s3Eu}"#FGGv++E%!)CI,EFGC (DGGT4:t45EE"  !6u!=>  '  (q Z ;C#c(Q,D :C ;s.A9G4G98G9c  t|fi|}|dk7r3|r1t|jddstdj ||S#t$r"}dt|vrtd|z|d}~wwxYw)Nfact_caching_connectionaerror, '%s' inventory cache plugin requires the one of the following to be set to a writeable directory path: ansible.cfg: [default]: fact_caching_connection, [inventory]: cache_connection; Environment: ANSIBLE_INVENTORY_CACHE_CONNECTION, ANSIBLE_CACHE_PLUGIN_CONNECTION.memory_optionszUnable to use cache plugin {0} for inventory. Cache options were provided but may not reconcile correctly unless set via set_options. Refer to the porting guide if the plugin derives user settings from ansible.constants.) CacheObjectrr getattr_pluginformat) plugin_namekwargscachees rget_cache_pluginrVs K262h6'%--UY2Z55;VK5HJ J L  $ ! 4 BEP PQ Q Gs A A3A..A3c^eZdZdZdZeeZfdZd dZ dZ d dZ dZ dZ d ZxZS) BaseInventoryPluginz Parses an Inventory Source generatorcjtt| i|_d|_t |_i|_yr()superrX__init__rM inventorydisplay_varsself __class__s rr\zBaseInventoryPlugin.__init__s- !413   rcb||_||_t||_t ||_y)az Populates inventory from the given data. Raises an error on any parse failure :arg inventory: a copy of the previously accumulated inventory data, to be updated with any new data this plugin provides. The inventory can be empty if no other source/plugin ran successfully. :arg loader: a reference to the DataLoader, which can read in YAML and JSON files, it also has Vault support to automatically decrypt files. :arg path: the string that represents the 'inventory source', normally a path to a configuration file for this inventory, but it can also be a raw string for this plugin to consume :arg cache: a boolean that indicates if the plugin should use the cache or not you can ignore if this plugin does not implement caching. )loaderN)rdr]rtemplarrr_)rar]rdpathrTs rparsezBaseInventoryPlugin.parses* "f- $V, rcd}t|d}tjj|r(tj|tj rd}|S|j jd|S)a Verify if file is usable by this plugin, base does minimal accessibility check :arg path: a string that was passed as an inventory source, it normally is a path to a config file, but this is not a requirement, it can also be parsed itself as the inventory data to process. So only call this base class if you expect it to be a file. Fsurrogate_or_stricterrorsTzWSkipping due to inventory source not existing or not being readable by the current user)r osrfexistsaccessR_OKr^vvv)rarfvalidb_paths r verify_filezBaseInventoryPlugin.verify_files]$'<= GGNN6 "ryy'AE  LL  v w rct|tstdt|z|D]G}|jj ||||D]"}|jj ||||$Iy)Nz8Invalid data from file, expected dictionary and got: %s)groupport) isinstancerrr r]add_host set_variable)rahosts variablesrurvhostks r_populate_host_varsz'BaseInventoryPlugin._populate_host_varssy)W-$%admnwdx%xy y CD NN # #DD # A C++D!Yq\B C Crci} jj|d}t dxs j g}|stdt |z|jd|vrtd|jddzt|tstd t|zj|j d jvrIjd r8gd }tfd |D}t!jdfi|_|S#t$r}tt |d}~wwxYw)z validate config and set options as appropriate :arg path: path to common yaml format config file for this plugin none)rTN_redirected_namesz %s is emptypluginz!Incorrect plugin name in file: %sz none foundzJinventory source has invalid structure, it should be a dictionary, got: %s)direct var_optionsrT)_uricache_connection)_timeout cache_timeout)_prefix cache_prefixc3zK|]2}j|d|dj|df4ywr!Nr get_option.0optras r z8BaseInventoryPlugin._read_config_data..sI!HscgcrcrsvwxsyczdG#a&$//#a&*A!B!H;; cache_plugin)rdload_from_file Exceptionrr rONAMEgetrwrtype set_optionsr_rMrdictrV_cache)rarfconfigrU valid_namescache_option_keys cache_optionss` r_read_config_dataz%BaseInventoryPlugin._read_config_datasG  3[[//F/CF d$78GTYYK $]io%FG G ZZ ! 4$%H6::V^`lKm%mn nFG,$%qtxyuA&AB B DJJ? dmm #(@ z  !HN_!HHM*4??>+J\m\DK - 3$Yq\2 2 3sD$$ E-EEcl|jD]%}||vs|j||j|<'y)a< update existing options from alternate configuration sources not normally used by Ansible. Many API libraries already have existing configuration sources, this allows plugin author to leverage them. :arg data: key/value pairs that correspond to configuration options for this plugin N)rMpop)radatar}s r_consume_optionsz$BaseInventoryPlugin._consume_optionss4  /ADy#'88A; a  /rc t|d\}}t|rt|}||fS|g}||fS#t$r|}d}Y0wxYw)z Takes a single host pattern and returns a list of hostnames and an optional port number that applies to all of them. T) allow_rangesN)rrrr;)ra hostpatternpatternrv hostnamess r_expand_hostpatternz'BaseInventoryPlugin._expand_hostpatternsg +KdKOWd  -g6I4  ! I4   !GD s3 AAT)NN)__name__ __module__ __qualname____doc__TYPE staticmethodr_sanitize_group_namer\rgrsr~rrr __classcell__rbs@rrXrXs>% D ((:;-& C D/!rrXc&eZdZdZdZfdZxZS)BaseFileInventoryPluginz% Parses a File based Inventory Sourcestoragec*tt| yr()r[rr\r`s rr\z BaseFileInventoryPlugin.__init__s %t57r)rrrrrr\rrs@rrrs/ D88rrcNeZdZeZedZdZdZdZ dZ dZ dZ y) Cacheablec|jSr()rras rrTzCacheable.cache(s {{rczjd}gd}tfd|D}t|fi|_y)Nrrc3zK|]2}j|d|dj|df4ywrrrs rrz.Cacheable.load_cache_plugin../sID3_c_n_norstou_v`Cc!fdooc!f&=>Dr)rrrVr)rarRrrs` rload_cache_pluginzCacheable.load_cache_plugin,sBoon5 vDJ[DD &{DmD rcXdj|j|j|S)Nz{0}_{1})rQr_get_cache_prefix)rarfs r get_cache_keyzCacheable.get_cache_key2s$ 4+A+A$+GHHrcHtj}|jt|jd|j }tj}|jt|d|j }dj |dd|ddgS)z7 create predictable unique prefix for plugin/inventory rirjs_N)hashlibsha1updater r hexdigestr9)rarfmd1nd2s rrzCacheable._get_cache_prefix5s| LLN $)),ABC [[] LLN $'<=> [[]yy"Ra&"Ra&)**rc8|jjyr()rflushrs r clear_cachezCacheable.clear_cacheBs rc8|jjyr()rupdate_cache_if_changedrs rrz!Cacheable.update_cache_if_changedEs ++-rc8|jjyr()r set_cachers rset_cache_pluginzCacheable.set_cache_pluginHs rN) rrrrNrpropertyrTrrrrrrrrrrr$s; ]F E I +. rrc,eZdZddZddZddZddZy) Constructablec,|j} |jd}|rt||j|_n||_|j |jj||jj|S#t$rd}YswxYw)zi helper method for plugins to compose variables for Ansible based on jinja2 expression and inventory varsuse_extra_varsF)disable_lookups) rerrrr_available_variablestemplate environmentvariable_start_stringvariable_end_string)rarr{rt use_extras r_composezConstructable._composeNs LL (89I $0DJJ$GA !$-A !zzamm&I&I8UVUbUbUvUvw*9; ; I sB BBc  |rLt|tr;|D]5} |j|||}|j j|||7yyy#t$r)}|rt d|d|dt |Yd}~hd}~wwxYw)z5 loops over compose entries to create vars for hosts zCould not set z for host : N)rwrrrrr r]ry)racomposer{r|strictvarname compositerUs r_set_composite_varsz!Constructable._set_composite_vars_s z'40" F $ gg.> JI ++D'9E F17!*QXZ^`ijk`l+mnnsA BA==Bc  |rt|tr|r3t||jj |j }||j _|D]z}d||z}|j|} t|j j|}|sD|jj|}|jj|||yyy#t$r)} |rtd|d|dt| Yd} ~ d} ~ wwxYw)z} helper to create complex groups for plugins based on jinja2 conditionals, hosts that meet the conditional are added to groupz3{%% if %s %%} True {%% else %%} False {%% endif %%}zCould not add host z to group rN)rwrrr]get_hostget_varsrerrr rrrr add_group add_child) ragroupsr{r|rfetch_hostvars group_name conditionalresultrUs r_add_host_to_composed_groupsz*Constructable._add_host_to_composed_groupsks j.(DNN4K4KD4Q4Z4Z4\] /8DLL ,$ ? SV\]gVhh !66zB $T\\%:%:;%GHF !%!9!9*!EJNN,,Z> ? /6!0\`blnwxynz1{||s8$C D $DD c |rt|tr|D]}|rt|tr|r3t||jj |j } |j|jd|}|jdd} |jd} | | td|s |d k(r| |jd d } |jd d } |jd d} | r |jj| } g}t|tr+|d k(r| |j!| n|j!|nt|tr2|D],}|d k(r| |j!| |j!|.not|t"rH|j%D]4\}}|| |}|d k(r| || | }n| dur|}|j!|6ntdt'|z|D]}| d k(r|j)ddurd } |j+| | |}|jj-|}|jj/||| sn|j+| }|jj-||jj1|||s|gifvstd|jdd|dtd|zyyy#t$r9}|r,td|d|jddt|Yd}~&d}~wwxYw#t$r*}|rtd| d|dt|Yd}~\d}~wwxYw)zc helper to create groups for plugins based on variable values and add the corresponding hosts to itkeyz"Could not generate group for host z from z entry: N default_valuetrailing_separatorzTparameters are mutually exclusive for keyed groups: default_value|trailing_separatorr.prefix separator_ parent_groupz Could not generate parent group z for group rFzUInvalid group name format, expected a string or a list of them or dictionary, got: %sleading_separatorz!No key or key resulted empty for z in host z, invalid entryz7Invalid keyed group entry, it must be a dictionary: %s )rwr5rrr]rrrrrrr rerrrr<ritemsrrrrrxr)rakeysr{r|rrkeyedrrUdefault_value_namerrsepraw_parent_namenew_raw_group_namesrgnamegval bare_name result_gname parent_names r_add_host_to_keyed_groupsz'Constructable._add_host_to_keyed_groupss JtT*H pZt4%$0DNN$>?Q$R$7$>$>t$D E (W514F 8=sD,I #'2:'9'E@EsL^4_ );u)D49 3 : :9 EF#56MPTUXPY6Y#ZZ)< TI%|@S0TX]0]&($($=$=&RUW`>a$bE+/>>+C+CE+JL NN33D,G..2.G.G.X $ 8 8 E $ 8 8l S T"c"b&9"4x}yByBCHyIKO6P#QQ,-fin-nooQH p+4%!!"4quw|xAxABGxHJSTUJV6W#XX !$0)#)*<wFHKMVWXMY>Z+[%[ ()s0%!L<M M .L==M M8M33M8Nr)F)FT)rrrrrrr rrrrrLs;" F?.Kprrr()+ __future__rrrlr2collections.abcransible.errorsrransible.inventory.grouprransible.parsing.utils.addressesransible.pluginsr ansible.plugins.cacher rN+ansible.module_utils.common.text.convertersr r )ansible.module_utils.parsing.convert_boolr ansible.module_utils.sixransible.templateransible.utils.displayransible.utils.varsrrr^rr;rVrXrobjectrrrrrrs$# #;G9)GK=1$)< )8 EP&C!-C!L818% % PApFApr