Vh*ddlZddlZddlZddlmZ ddlZddlmZddl m Z ddl m Z ddl mZddl mZddl mZd Zd Zd Zd Zd ZdZdZdZy#e$rYDwxYw)N)deepcopy)camel_dict_to_snake_dict) string_types)is_boto3_error_code)ansible_dict_to_boto3_tag_list)boto3_tag_list_to_ansible_dict)compare_aws_tagsc  |j|}|dS#td$rYytjjtjj f$r$}|j |d|Yd}~dSd}~wwxYw)z; Get the status of an existing OpenSearch cluster.  DomainNameResourceNotFoundExceptionNCouldn't get domain msg DomainStatus)describe_domainrbotocore exceptions BotoCoreError ClientError fail_json_aws)clientmodule domain_nameresponsees q/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/aws/plugins/module_utils/opensearch.pyget_domain_statusrsJ))[)A N ## : ;))'' J Q&:;-$HII N ## JsB6BA>>Bc |j|}i}d}|dD]}d|d|vs|d|d||<||d <d |vr=i}d |d vrt|d d |d <d |d vrt|d d |d <||d <|d dD]7} t| dtjs!| djd| d<9|jddt|||} | | d}||fS#td$rYytjjtjj f$r!}|j |d|Yd}~=d}~wwxYw)a Get the configuration of an existing OpenSearch cluster, convert the data such that it can be used as input parameter to client.update_domain(). The status info is removed. The returned config includes the 'EngineVersion' property, it needs to be removed from the dict before invoking client.update_domain(). Return (domain_config, domain_arn) or (None, None) if the domain does not exist. r r )NNrrN DomainConfigOptionsr VPCOptions SubnetIdsSecurityGroupIdsAutoTuneOptionsMaintenanceSchedulesStartAtz%Y-%m-%dAdvancedOptionsARN) describe_domain_configrrrrrrr isinstancedatetimestrftimepopr) rrrrr domain_configarnkdcsdomains rget_domain_configr5)sJ00K0HM C.) JAH^4Q77#+N#;A#>y#I a  J'2 l# = (BmL99"*=+F{+S"T;!]<%@@)1- 2MN`2a)b%&*,M, '012HI AA!I,(9(9: |44Z@)  A +T2#66;?  -C 3 I : ;))'' J Q&:;-$HII JsC//E?6E5EEcl t|j|ddd|d<t|dg S#tjjtjj f$r"}|j |d|dYd}~bd}~wt$r|jt| YwxYw) z Merge the input domain object with tags associated with the domain, convert the attributes from camel case to snake case, and return the object. r)T)r) aws_retryTagListTagszCouldn't get tags for domain rNr) ignore_list) r list_tagsrrrrrKeyError fail_jsonstrr)rrr4rs rnormalize_opensearchr?\s *78H8HVTY]fj8H8klu8vwv $F AA    + +X-@-@-N-N OYQ"?}@U?V WXX *S[)*s%57B3,B  'B32B3c|jdsy|jd}tj|z}d}tj|krut|||}|d}|dk(r2ydj|d|d|d }|d k(r|dr |ds|d sytjd tj|kru|j d |d |y)Nwait wait_timeoutz Not Founddomain_deletedz5Created: {0}. Processing: {1}. UpgradeProcessing: {2}Created ProcessingUpgradeProcessingdomain_availablez Timeout waiting for wait state 'z'. r)paramstimerformatsleepr=)rrr waiter_nametimeoutdeadline status_msgstatuss rwait_for_domain_statusrSks == mmN+Gyy{W$HJ ))+ "66;? >$J..PWWy!|$*+J 119%|,23 2' ))+ * ;K=J<XYc.|jd}t|dk7ry|djd}t|dk7ry|d}|dvry|djr|djsyt|d}t|d}|||dS) z Parse the engine version, which should be Elasticsearch_X.Y or OpenSearch_X.Y Return dict { 'engine_type': engine_type, 'major': major, 'minor': minor } _N.r Elasticsearch OpenSearch) engine_typemajorminor)splitlenisdigitint)engine_versionversionsemverr]r^r_s r parse_versionrgs ""3'G 7|q QZ  c "F 6{a!*K99 1I   F1I$5$5$7 q NE q NE& GGrTcPddd}t|tr t|}t|tr t|}||y||y||y|j|jd}|j|jd}||kry||kDry|jd|jdkry|jd|jdkDry|jd|jdkry|jd|jdkDryy) NrXrWrZrr]r^r_)r+rrgget)version1version2supported_enginese1e2s rcompare_domain_versionsrps!(L) *(L) *H0  ("2  h.   x||M: ;B   x||M: ;B Bw b << 8<<#8 8 \\' "X\\'%: :||G$x||G'<<g&g)>>rTcd} |j|}|j d}||jd|t|dk(r|jd||dj d |jd |g}|dj d D]*}||k(r|cSt|} | |j| ,t|tjt }t|D]}t||dks|cSy#tjjtjjf$r!}|j |d|Yd}~Ld}~wwxYw) a Returns the highest compatible version which is less than or equal to target_version. When upgrading a domain from version V1 to V2, it may not be possible to upgrade directly from V1 to V2. The domain may have to be upgraded through intermediate versions. Return None if there is no such version. For example, it's not possible to upgrade directly from Elasticsearch 5.5 to 7.10. Nr z,Couldn't get compatible versions for domain rCompatibleVersionsz/Unable to determine list of compatible versions)compatible_versionsrTargetVersionszNo compatible versions found)key)get_compatible_versionsrrrrrrjr=rargappendsorted functools cmp_to_keyrpreversed) rrrtarget_versionapi_compatible_versionsrcompatrsvrfs rget_target_increment_versionrs# "("@"@K"@"X % ( ()= >F ~J`wx 6{aJ`wx ay}}%&.7Mde AY]]+ ,/ Q ! !q!    & &v . /!!4):N:NOf:gh ) * "1n 5 :H 5    - -x/B/B/N/N O  >{mL    sD7E'E""E'c|yt|||\}}t|xs|}|r<|jr|jdd |j |t ||r5|jr|jdd |j|||S|S#t jjt jjf$r} |j| d|Yd} ~ d} ~ wwxYw#t jjt jjf$r } |j| d |Yd} ~ |Sd} ~ wwxYw) NFTz4Would have added tags to domain if not in check mode)changedr)r)r8zCouldn't add tags to domain z,Would have removed tags if not in check mode)r)TagKeysz!Couldn't remove tags from domain ) r bool check_mode exit_jsonadd_tagsrrrrrr remove_tags) rr resource_arn existing_tagstags purge_tags tags_to_addtags_to_removerrs r ensure_tagsrsZ |"2=$ "SK;0.1G      T/e  f S OO 6{C        T/]  ^ X   <  H N7N    + +    - -  S  &B<.$Q R R  S    + +    - -  X  &G ~$V W W N  Xs0BC37C0C++C037E *EE )r,ryrKcopyrr ImportError0ansible.module_utils.common.dict_transformationsransible.module_utils.sixrrss   V1\ffX $ 0 f BZ<H* F%Py  sAAA