VhsBddlmZmZmZeZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z mZddlmZmZddlmZddlmZmZddlmZdZd Zd ZdZdZ dd lmZdd l m!Z"dd l#m$Z$m%Z%m&Z&dd l'm(Z(ddl m)Z)ee"edk\r dZddl m*Z+n ee"edk\r dZddl m*Z+nddl m+Z+ ddl0Z dZ1 ddl2Z dZ3 ddlm4Z4ddl6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMdZNes#dZ"GddeOZ+Gdde5Z$Gdde5Z%dZPdZQd ZRd!ZSd"ZTd#ZUGd$d%e+ZVGd&d'eVZWy#e,$r%Z-e.e-Ze j^Zd ZYdZ-[-dZ-[-wwxYw#e,$rd Z1YwxYw#e,$rd Z3YwxYw#e,$rGdde5Z4YwxYw)()absolute_importdivisionprint_functionN) AnsibleModulemissing_required_lib)MappingSequence) string_types) BOOLEANS_TRUEBOOLEANS_FALSE) LooseVersionTF)SSLError) __version__)APIErrorNotFoundTLSParameterError) TLSConfigauthz3.0.0) APIClient2.0.0)Client)RequestExceptionc eZdZy)rN__name__ __module__ __qualname__p/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/community/docker/plugins/module_utils/common.pyrrK r r)DEFAULT_DOCKER_HOST DEFAULT_TLSDEFAULT_TLS_VERIFYDEFAULT_TLS_HOSTNAMEDEFAULT_TIMEOUT_SECONDSDOCKER_COMMON_ARGSDOCKER_COMMON_ARGS_VARSDOCKER_MUTUALLY_EXCLUSIVEDOCKER_REQUIRED_TOGETHERDEFAULT_DOCKER_REGISTRY BYTE_SUFFIXESis_image_name_id is_valid_tagsanitize_resultDockerBaseClassupdate_tls_hostnamecompare_dict_allow_more_presentcompare_genericDifferenceTracker"clean_dict_booleans_for_docker_apiconvert_duration_to_nanosecondparse_healthcheckomit_none_from_dictz1.8.0ceZdZdZy)rc yNr)selfkwargss r!__init__zClient.__init__rs r N)rrrr?rr r!rrqs r rc eZdZy)rNrrr r!rrur"r rc eZdZy)rNrrr r!rrxr"r rc >d|vrKtttdk\r0|jd}||djt|t d|j D} t di|}|S#t$r}|d|zYd}~yd}~wwxYw)Nassert_hostnamez7.0.0b1aNtls_hostname is not compatible with Docker SDK for Python 7.0.0+. You are using Docker SDK for Python {docker_py_version}. The tls_hostname option (value: {tls_hostname}) has either been set directly or with the environment variable DOCKER_TLS_HOSTNAME. Make sure it is not set, or switch to an older version of Docker SDK for Python.)docker_py_version tls_hostnamec30K|]\}}| ||fywr<r).0kvs r! z"_get_tls_config..sETQq}1a&Es  zTLS config error: %sr)r docker_versionpopformatdictitemsrr) fail_functionr>rC tls_configexcs r!_get_tls_configrS|sF"|N'C|T]G^'^ **%67  & dekdj&4!0eke  EV\\^E EF4((  4,s2334s1 A>> B BBc|dxs|dS)N tls_verifytlsrrs r! is_using_tlsrWs   ,e,r ct|r|djdd|d<t|d|d|d}|drDtd|d | }|d r|d r |d |d f|d <|dr|d|d<tdi||d<n7|dr2td|}|d r|d r |d |d f|d <tdi||d<|jdr(t t t dkr|dd|d<|S)N docker_hostztcp://zhttps:// api_versiontimeout)base_urlversionr[rUTrE)verifyrCrP cert_pathkey_path client_cert cacert_pathca_certrVF)r^rPuse_ssh_clientz4.4.0zAuse_ssh_client=True requires Docker SDK for Python 4.4.0 or newerr)rWreplacerNrSgetr rK)rrPresultrQs r!get_connect_paramsrhsID"=199(JO] m$]#YF  L 0'  j!1)-k):Dt r8|j dtjdtjdts1td}|dzdz}|j |tzt|jt|krod }|s |tz }n%ttd kr |t z }n |t"z }|j |ttjtj|fzt%|j&|j |_ t+t,|^di|j(|j0|_t|j2|_|xsd}|j8t|kr#|j d|j2d|dyy#t4$r}|j d |zYd}~~d}~wt6$r}|j d |zYd}~d}~wwxYw)NraCannot have both the docker-py and docker python modules (old and new version of Docker SDK for Python) installed together as they use the same namespace and cause a corrupt installation. Please uninstall both packages, and re-install only the docker-py or docker python module (for z 's Python z). It is recommended to install the docker module. Please note that simply uninstalling one of the modules can leave the other module in a broken state.zQDocker SDK for Python: docker>=5.0.0 (Python >= 3.6) or docker<5.0.0 (Python 2.7)z:, for example via `pip install docker` (Python >= 3.6) or z;`pip install docker==4.4.4` (Python 2.7). The error was: %s) exceptionz\Error: Docker SDK for Python version is %s (%s's Python %s). Minimum version required is %s.z2.0)rPzDocker API error: %szError connecting: %sz1.25zDocker API version is z. Minimum version required is .r)MIN_DOCKER_VERSIONr rKrDHAS_DOCKER_MODELSHAS_DOCKER_SSLADAPTERfailplatformnodesys executable HAS_DOCKER_PYrHAS_DOCKER_ERRORHAS_DOCKER_TRACEBACK DOCKERPYUPGRADE_RECOMMEND_DOCKER DOCKERPYUPGRADE_SWITCH_TO_DOCKERDOCKERPYUPGRADE_UPGRADE_DOCKERrh auth_params_connect_paramssuperrjr?rZdocker_api_version_strr Exceptiondocker_api_version)r=min_docker_versionmin_docker_api_versionNEEDS_DOCKER_PY2msgrR __class__s r!r?z AnsibleDockerClientBase.__init__s  %!3 ();< W@UU!-n!= !6 II #+--/3>> C D&(CDCTTOPC IIc,,8LI M  ! !L1C$D DpC#77,u"557755 IIc^X]]_cnnN`aa b1$2B2BRVR[R[\ 4 )4 9 QDs r!rqzAnsibleDockerClientBase.fail r cyr<rr=rr]datecollection_names r! deprecatez!AnsibleDockerClientBase.deprecaterr c|4|dk(r|tvry|tvryt|S|dk(r t|S|S|tj j |}||dk(r tjj|dS|dk(r tjj|dS|d k(r tjj|d S|dk(r|tvry|tvryt|S|dk(r t|S|S|S) NboolTFintr_zcert.pemrbzca.pemr`zkey.pem) r r rrosenvironrfpathjoin) param_name param_value env_variable default_valuetype env_values r! _get_valuez"AnsibleDockerClientBase._get_values  "v~-/.0 K((u};''   # |4I$,77<< :>>.77<< 8<<+77<< 9==6> M1# N2$ ?*5=y>)  r cyr<rr=s r! _get_paramsz#AnsibleDockerClientBase._get_params(rr c|jd|j}t}tD]}|j |||<t|j d|ddt d|j d|dddd|j d|dd d d|j d |d d dd|j d|dd dd|j d|dd dd|j d|ddtd|j d|ddtd|j d|ddtd|j d|dddd }t||S)NzGetting credentialsrY DOCKER_HOSTstr)rrEDOCKER_TLS_HOSTNAMErZDOCKER_API_VERSIONautorbca_pathDOCKER_CERT_PATHr_rar` client_keyrV DOCKER_TLSrvalidate_certsDOCKER_TLS_VERIFYr[DOCKER_TIMEOUTrrdF) rYrErZrbr_r`rVrUr[rd) rrrNr(rfrr#r$r%r'r2)r= client_paramsparamskeyrgs r!r|z#AnsibleDockerClientBase.auth_params,s &'((* % 1C'++C0F3K 1 vm7Lm(;%(I9O)>5)R vm7LNb(.U(< vi7HJ\^binoook6-3HJ\^binoo__Z 1EGY[_fk_lve}lKV\]'7@P9QSf'9'HOOIvi/@BR$;%$I??+;VDT=UW[]bio?p $ F# r c tjdt|}|rF|jd|jdd|j dd|j dd|jd|zy) Nz!hostname.*doesn\'t match (\'.*\')zNYou asked for verification that Docker daemons certificate's hostname matches rEz'. The actual certificate's hostname is zY. Most likely you need to set DOCKER_TLS_HOSTNAME or pass `tls_hostname` with a value of zS. You may also use TLS without verification by setting the `tls` parameter to true.zSSL Exception: %s)rematchrrqr|group)r=errorrs r!_handle_ssl_errorz)AnsibleDockerClientBase._handle_ssl_errorOsf=s5zJ  II)).95;;q>5;;WX> [ \ %/0r c |jd|z|j|}|jd|S#t$r }Yd}~yd}~wt$r}|j d|zYd}~yd}~wwxYw)NzInspecting container Id %s) containerzCompleted container inspectionzError inspecting container: %s)rinspect_containerrrrq)r= container_idrgdummyrRs r!get_container_by_idz+AnsibleDockerClientBase.get_container_by_idYso > HH1L@ A++l+CF HH5 6M  > II6< = = >s8; A3 A3A..A3c|y|}|jdsd|z}d} |jdD][}|jd|dzt|dtr ||dvr|}n&|dj|r|}n|d|k(sY|}n|y|j|dS#t $r}|j |Yd}~6d}~wt$r}|jd|zYd}~[d}~wwxYw) zG Lookup a container and return the inspection results. N/T)allztesting container: %sNamesIdz#Error retrieving container list: %s) startswith containersr isinstancelistrrrrqr)r=name search_namergrrRs r! get_containerz%AnsibleDockerClientBase.get_containerds < s#*K C!___6  0Ig4FGHi0$7K9U\K]<]&FT?--d3&FT?d*&F  >''t 55 (  " "3 ' ' C II;cA B B Cs*A*B& B&& C//C C/C**C/cN||yd}|Q |jD]=}|jd|dz||dk(r|}n|dj|s;|}n||d}|9 |jd|z|j|}|jd|S|S#t$r}|j |Yd}~cd}~wt $r}|j d|zYd}~d}~wwxYw#t$r }Yd}~yd}~wt $r}|j d|zYd}~|Sd}~wwxYw) zE Lookup a network and return the inspection results. Nztesting network: %sNamerz!Error retrieving network list: %szInspecting network Id %szCompleted network inspectionzError inspecting network: %s) networksrrrrrrqinspect_networkr)r=r network_idrgnetworkrRrs r! get_networkz#AnsibleDockerClientBase.get_networksN ??  @sHA BB%6C+ C((B>> C( C##C(+ D$9 D$DD$c |sy|jd|d||j||}|stj|\}}|dk(r|jd|z|j||}|sE|j dr4|t dd}|jd|z|j||}|s-|d|}|jd|z|j||}|s1d|vr-|d|}|jd|z|j||}t |d kDr|j d |d|t |d k(r |j|d d }|S|jd |d|dy#t$r|jd |d|dYyt$r.}|j d|d|dt|Yd}~Sd}~wwxYw)zV Lookup an image (by name and tag) and return the inspection results. Nz Find image :z docker.iozCheck for docker.io image: %szlibrary/rz /library/rz)Daemon returned more than one result for rrzImage z not found.zError inspecting image  - ) r _image_lookuprresolve_repository_namerlenrq inspect_imagerrr) r=rtagimagesregistry repo_namelookup inspectionrRs r! find_imagez"AnsibleDockerClientBase.find_images tS12##D#."&">">t"D Hi;&89DE++Is;)"6"6z"B&s:'78FHHold_tagline error_detailrRnew_tags r! pull_imagez"AnsibleDockerClientBase.pull_image sF   !)F:  $45//$, P! $1&1 WD188G$xx .'+xx '>  tO[O_O_`fOgO[O_O_`iOj#lm T488GCT"UV W//$,7***  P II$SXN O O Ps:D;BD E!#E  Ec (|jtdkrftj|d}tj||}|r6|j |j |jd|d|idStt|*|fi|S)z Get image digest by directly calling the Docker API when running Docker SDK < 4.0.0 since prior versions did not support accessing private repositories. z4.0.0rz/distribution/{0}/jsonzX-Registry-Auth)headersT)json) rDr rrget_config_header_result_get_urlr~rjinspect_distribution)r=rr>rheaderrs r!rz,AnsibleDockerClientBase.inspect_distribution*s  ! !L$9 933E:1=H++D(;F||DIIII6>.7%.%$,dHYRXYYr )NN)FNNN)rr<)latestN)rrrr?rabcabstractmethodrqr staticmethodrrpropertyr|rrrrrrrrr __classcell__rs@r!rjrjs/Kb     ""H     D1 > 6D%N2h&.+> Z Zr rjcLeZdZ dfd ZdZddZdZd dZd dZxZ S) AnsibleDockerClientc | xsi|_t} | jt|r| j|| |_g}|t z }|r||z }g}|t z }|r||z }t| ||||||xsi|_|jjjd|_ |jj|_ tt|?|| | |j!| | yy)N) argument_specsupports_check_modemutually_exclusiverequired_together required_ifrequired_one_of required_bydebug)rr) fail_resultsrNupdater(arg_specr*r+rmodulerrfr check_moder~r r?_get_minimal_versions)r=rrrrrrrrroption_minimal_versions%option_minimal_versions_ignore_paramsrmerged_arg_specmutually_exclusive_paramsrequired_together_paramsrs r!r?zAnsibleDockerClient.__init__<s).B&12   " "= 1+DM$&!!%>>!  %); ; %#%  $<<  $(9 9 $#) 386#+#)r  [[''++G4 ++00 !411#9 2 ; # .  & &'>@e f /r c |jj||jjdd|it |jy)Nrr)rrr fail_jsonr0rs r!rqzAnsibleDockerClient.failis=   ( L#L9J9J)KLr cB|jj||||y)N)r]rr)rrrs r!rzAnsibleDockerClient.deprecatems c7_r c.|jjSr<)rrrs r!rzAnsibleDockerClient._get_paramsps{{!!!r cZt|_|jjD] }|||vr t|j|<"|jj ||jj D]\}}d}d}d|vr|j t|dk\}d|vr|jt|dk\}|xr||d<|drXd|vr |d|}nz|jjj|du}|rQd|jj|vr6|jj||jj|dk7}|sd|vr|d}nd|d }|sd } | |j|d|fz} n|sd } t|dtd kr | tz } n+|j td kr | tz } n | tz } | tt!j"t$j&|d|fz} nd |d} |j)| y)NTrDr supported detect_usagedefault usage_msgzset z optionz?Docker API version is %s. Minimum version required is %s to %s.z\Docker SDK for Python version is %s (%s's Python %s). Minimum version required is %s to %s. rzCannot z with your configuration.)rNrrrrrOrDr rrrfrryrzr{rKrrrsrtrurq) r=r ignore_paramsoptiondatasupport_docker_pysupport_docker_apiusedusgrs r!rz)AnsibleDockerClient._get_minimal_versionsssP'+v$kk// :F(]*376D ( ( 0  : $$++,CD 88>>@' #LFD $ !% "d*$($:$:l4PcKd>e$e!#t+%)%<%< TRfMg@h%h" 1 H6HD  $!T)/4/5D;;--11&9ED T[[-F-Fv-N N#{{11&9T[[=V=VW]=^_h=ii"d*";/+28:-_!T%@%@$G[B\^a$bb.|'-@(AB\RYEZZ#CCC!33l76KK#CCC#AAC!^X]]_cnnVZ[nVoqt$uu/GJLIIcNO' #r cb|dg}|D]%}t|tsy|j|}'t|tr2|D],}|jj dj |.yt|tr.|r+|jj dj |yyy)aw Checks result of client operation for warnings, and if present, outputs them. warnings_key should be a list of keys used to crawl the result dictionary. For example, if warnings_key == ['a', 'b'], the function will consider result['a']['b'] if these keys exist. If the result is a non-empty string, it will be reported as a warning. If the result is a list, every entry will be reported as a warning. In most cases (if warnings are returned at all), warnings_key should be ['Warnings'] or ['Warning']. The default value (if not specified) is ['Warnings']. NWarningszDocker warning: {0})rrrfr rwarnrMr )r=rg warnings_keyrwarnings r!report_warningsz#AnsibleDockerClient.report_warningss  &ansible_collections.community.docker.plugins.module_utils.utilr#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9rnobjectrSrWrhrzr{ryrjr rr r!rLs CB   JM1SZ ,4CC$N#|G'<<. n %g)> >.!"   46N 9  9 4,-&R$e !Q#V sZfsZl BC1BC[3x/9//1M"!"   9  sOAE1E18E>?F E. E))E.1E;:E;>FF FF