Vh0ddlmZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddlmZddlmZddlmZmZdd lmZdd lmZdd lmZdd lmZeZGd deZGddeZGdde Z y)) annotationsN)abstractmethod)MutableMapping) constants) AnsibleError) S_IRWU_RG_RO)to_bytesto_text) AnsiblePlugin) cache_loader)resource_from_fqcr)DisplayceZdZeZfdZedZedZedZ edZ edZ edZ edZ xZS) BaseCacheModulecPtt| |j||y)N) var_optionsdirect)superr__init__ set_optionsselfargskwargs __class__s N/home/dcms/DCMS/lib/python3.12/site-packages/ansible/plugins/cache/__init__.pyrzBaseCacheModule.__init__.s# ot-/ T&9cyNrkeys rgetzBaseCacheModule.get2 rcyrr rr"values rsetzBaseCacheModule.set6r$rcyrr rs rkeyszBaseCacheModule.keys:r$rcyrr r!s rcontainszBaseCacheModule.contains>r$rcyrr r!s rdeletezBaseCacheModule.deleteBr$rcyrr r*s rflushzBaseCacheModule.flushFr$rcyrr r*s rcopyzBaseCacheModule.copyJr$r)__name__ __module__ __qualname__display_displayrrr#r(r+r-r/r1r3 __classcell__rs@rrr)sH:              rrceZdZdZfdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZedZedZxZS)BaseFileCacheModulez8 A caching module backed by file based storage. c tt| |i||j|j d|_t |j d|_t|j|_i|_|j!y#t$rE|jtj|_t tj|_YwxYw)N_uri_timeout)rr<r_get_cache_connection get_option _cache_dirfloatr?KeyErrorCCACHE_PLUGIN_CONNECTIONCACHE_PLUGIN_TIMEOUTr r5 plugin_name_cachevalidate_cache_connectionrs rrzBaseFileCacheModule.__init__Ss : %t 5t Fv F"889PQDO!$//*"=>DM.doo>  &&(  :"889R9RSDO!!"8"89DM :sAB A CCc|r= tjjtjj|Sy#t$rYywxYwr)ospath expanduser expandvars TypeError)rsources rr@z)BaseFileCacheModule._get_cache_connection`sG  ww))"''*<*}tjd|jd|d|dt|Yd}~d}~wwxYw#t$rYywxYw# t j"|w#t$rYwwxYwxYw)N)dirrSz)' cache plugin while trying to write to 'z' : )modez%' cache plugin while trying to move 'z' to ')rIrdtempfilemkstemprLrMdirname_dumprWrXr7rjrHr renamechmodrunlink)rr"r'rctmpfile_handle tmpfile_pathr]s rr(zBaseFileCacheModule.setsx  C--c2 '/'7'7BGGOOI1C94E 9C>>E E4E E EE  EE F"E87F8 FFFFc |jdk(ry|j|} tj|}tj|jz |jkry||jvr |j|=y#tt f$r]}|j t jk(rYd}~ytjd|jd|dt|Yd}~yd}~wwxYw)NrFrS$' cache plugin while trying to stat rTT)r?rdrLstatrWrXerrnoENOENTr7rjrHr timest_mtimerI)rr"rcstr]s rrgzBaseFileCacheModule.has_expireds ==A --c2  #B 99; $ 5 $++  C ! ww%,,&]a]m]mox{CDE{F!GH  sBC/C*41C**C/c |jd}t|}g}tj|jD]M}|j ds|j |s&||d}|j |r=|j|O|S)Nr`.)rAlenrLlistdirrB startswithrgappend)rrb prefix_lengthr+ks rr+zBaseFileCacheModule.keyss+F DOO, A||C  V(<-.!A##A& A   rc r|j|}||jvry|j|ry tj|y#t t f$r]}|jtjk(rYd}~ytjd|jd|dt|Yd}~yd}~wwxYw)NTFrSryrT) rdrIrgrLrzrWrXr{r|r7rjrHr )rr"rcr]s rr-zBaseFileCacheModule.containss--c2 $++    C  H GGI ! Hww%,,&]a]m]mox{CDE{F!GHH  HsA B6B1;1B11B6c |j|= tj|j |y#t$rY1wxYw#t t f$rYywxYwr)rIrDrLremoverdrWrXr!s rr/zBaseFileCacheModule.deletes[  C   IId//4 5   !   s 5$A AAAAc^i|_|jD]}|j|yr)rIr+r/r!s rr1zBaseFileCacheModule.flushs* 99; C KK  rclt}|jD]}|j|||<|Sr)dictr+r#)rretr"s rr3zBaseFileCacheModule.copys4f99; %Cxx}CH % rcy)a Read data from a filepath and return it as a value :arg filepath: The filepath to read from. :returns: The value stored in the filepath This method reads from the file on disk and takes care of any parsing and transformation of the data before returning it. The value returned should be what Ansible would expect if it were uncached data. .. note:: Filehandles have advantages but calling code doesn't know whether this file is text or binary, should be decoded, or accessed via a library function. Therefore the API uses a filepath and opens the file inside of the method. Nr )rfilepaths rrhzBaseFileCacheModule._loads" rcy)z Write data to a filepath :arg value: The value to store :arg filepath: The filepath to store it at Nr )rr'rs rrrzBaseFileCacheModule._dumps r)r4r5r6__doc__rr@rJrdr#r(rgr+r-r/r1r3rrhrrr9r:s@rr<r<Osm )< $8,,"H"    $  rr<ceZdZdZddZdZdZdZdZdZ dZ d Z d Z dd Z d ZdZdZdZdZdZdZdZy )CachePluginAdjudicatorzC Intermediary between a cache dictionary and a CacheModule c i|_i|_tj|fi||_|jst d|z||_y)Nz%Unable to load the cache plugin (%s).)rI _retrievedr r#_pluginr _plugin_name)rrHrs rrzCachePluginAdjudicator.__init__ sG #'' >v> ||FTU U'rcX|j|jk7r|jyyr)rrI set_cacher*s rupdate_cache_if_changedz.CachePluginAdjudicator.update_cache_if_changed*s! ??dkk ) NN  *rc|jjD]+}|jj||j|-t j |j|_yr)rIr+rr(r3deepcopyr)rtop_level_cache_keys rrz CachePluginAdjudicator.set_cache.sT#';;#3#3#5 T  LL  0$++>Q2R S T-- 4rc|jjD]*}|jj||j|<,yr)rr+r#rIr!s rload_whole_cachez'CachePluginAdjudicator.load_whole_cache3s;<<$$& 5C#||//4DKK  5rc,t|jSr)r rIr*s r__repr__zCachePluginAdjudicator.__repr__7st{{##rc4t|jSr)iterr+r*s r__iter__zCachePluginAdjudicator.__iter__:sDIIK  rc4t|jSr)rr+r*s r__len__zCachePluginAdjudicator.__len__=s499;rcd}t||jv||jv|jdk7|jj |grd}|S)NFmemoryT)allrIrrrr-)rr"loads r _do_load_keyz#CachePluginAdjudicator._do_load_key@sX  t{{ " t &    ) LL ! !# &   D rc|j|rE |jj||j|<|j||j|<|j|S#t $rYwxYwrrrr#rIrrDr!s r __getitem__z"CachePluginAdjudicator.__getitem__Ksn   S ! 8#'<<#3#3C#8 C (,{{3'7${{3   s(A&& A21A2Nc|j|rE |jj||j|<|j||j|<|jj||S#t $r }Yd}~*d}~wwxYwrr)rr"defaultr]s rr#zCachePluginAdjudicator.getUsu   S ! 8#'<<#3#3C#8 C (,{{3'7${{sG,,   s(A33 BBc6|jjSr)rIitemsr*s rrzCachePluginAdjudicator.items_s{{  ""rc6|jjSr)rIvaluesr*s rrzCachePluginAdjudicator.valuesbs{{!!##rc6|jjSr)rIr+r*s rr+zCachePluginAdjudicator.keyses{{!!rcz|r|jj||dS|jj|S)Nr)rIpop)rr"rs rrzCachePluginAdjudicator.pophs1 ;;??3Q0 0{{s##rc|j|=yrrIr!s r __delitem__z"CachePluginAdjudicator.__delitem__ms KK rc"||j|<yrrr&s r __setitem__z"CachePluginAdjudicator.__setitem__ps  CrcF|jji|_yr)rr1rIr*s rr1zCachePluginAdjudicator.flushss  rc:|jj|yr)rIupdate)rr's rrzCachePluginAdjudicator.updatews 5!r)rr)r4r5r6rrrrrrrrrrr#rrr+rrrr1rr rrrrsa(5 5$!   -#$"$ !"rr)! __future__rr3r{rLror}abcrcollections.abcransiblerrEansible.errorsr ansible.module_utils.common.filer+ansible.module_utils.common.text.convertersr r ansible.pluginsr ansible.plugins.loaderr ansible.utils.collection_loaderr ansible.utils.displayrr7rr<rr rrrsh$#  *"'9I)/>) )# m# LJ /J Z\"^\"r