dbfdg 3 °Îwhyã@s,ddlZddlZddlZddlZddlZddlZddlZddlmZddlm Z ej dƒZdZe dƒZe dƒZe dƒZd3dd„Zd4dd„Zd5dd„Zd6dd„Zdd„Zd7dd„Zdedfdd„Zdd„Zdd„Zdd „Zd!d"„Zd#d$„Zd%d&„Zed'd(„ƒZd)d*„Zd8d+d,„Z d9d-d.„Z!d/d0„Z"d1d2„Z#dS):éN)Údatetimeé)Ú constantsz^(\d+[.]\d+[-]\d+)éÚóFÚwcCs |d}tjj|ƒ}|r0tjj|ƒr0tj|ƒt||ƒ&}|j|ƒ|jƒtj|j ƒƒWdQRXtj|tj ƒ}ztj|ƒWdtj|ƒXtj||ƒdS)Nz.tmp) ÚosÚpathÚdirnameÚexistsÚmakedirsÚopenÚwriteÚflushÚfsyncÚfilenoÚO_RDONLYÚcloseÚrename)ÚfnameÚcontentÚ ensure_dirÚmodeZ tmp_fnameZdnameÚfZ folder_fd©rú+/usr/libexec/kcare/python/kcarectl/utils.pyÚatomic_write s rúutf-8cCs4t|ƒtkr|St|ƒtkr&|j|ƒS|j|ƒSdS)N)ÚtypeÚntypeÚbtypeÚdecodeÚencode)ÚdataÚencodingrrrÚnstr7s r&Úlatin1cCst|ƒtkr|j|ƒ}|S)N)rÚutyper#)r$r%rrrÚbstrAs r)cCst|ƒtkr|j|ƒ}|S)N)rr!r")r$r%rrrÚustrHs r*cs4i‰tjˆƒ‡‡fdd„ƒ}ˆ|_ˆj|_ˆ|_|S)NcsH|tt|jƒƒƒf}yˆ|Stk r0YnXˆ||Ž}ˆ|<|S)N)ÚtupleÚsortedÚitemsÚKeyError)ÚargsÚkwargsZ cache_keyÚresult)ÚcacheÚfnrrÚinnerSszcached..inner)Ú functoolsÚwrapsr2ÚclearZorig)r3r4r)r2r3rÚcachedOs r8csFˆdkrtj‰ˆdkrtj‰ˆdkr*tj‰i‰‡‡‡‡‡fdd„}|S)Ncs‡‡‡‡‡‡fdd„}|S)Ncs²ˆ}xltˆƒD]`}y ˆ||ŽStk rJ}zˆ|ˆƒs:‚WYdd}~XnXtj|ƒt|tjdˆƒtjƒ}qWy ˆ||ŽStk r¬}zt |dˆƒ‚WYdd}~XnXdS)NrÚattempts) ÚrangeÚ ExceptionÚtimeÚsleepÚminÚrandomÚuniformrÚRETRY_MAX_DELAYÚsetattr)r/r0ZldelayÚ_ÚexZfinal_ex)ÚbackoffÚcheck_retryÚcountÚdelayr3Ústaterrr4os z'retry..decorator..innerr)r3r4)rErFrGrHrI)r3rÚ decoratornszretry..decorator)rÚRETRY_DELAYÚRETRY_COUNTÚ RETRY_BACKOFF)rFrGrHrErJr)rErFrGrHrIrÚretrycsrNc CsÄtjj|ƒsdSg}tj|ƒ}|dk r2tj||ƒ}xD|D]<}tjj||ƒ}||krh|jtj|ƒj |fƒ|j ddq8WxF||d…D]6\}} tjj| ƒs¦tjj| ƒr²tj | ƒq†tj| ƒq†WdS)NT)Úreverse)r r rÚlistdirÚfnmatchÚfilterÚjoinÚappendÚstatÚst_mtimeÚsortÚisfileÚislinkÚremoveÚshutilÚrmtree) Z directoryÚexclude_pathÚkeep_nÚpatternr$r-ÚitemÚ full_pathrCÚentryrrrÚclean_directory‡s rccCsNttjjtjdƒddttjjtjdƒddtjjtjƒrJtjtjƒdS)NÚmodulesr)r^Úpatches) rcr r rSrÚPATCH_CACHErÚCACHE_KEY_DUMP_PATHÚunlinkrrrrÚclear_all_cache›sric Cs^tjj|ƒ}tjj|ƒs"tj|ƒt|dƒ(}tj||ƒ|jƒtj |j ƒƒWdQRXdS)NÚwb)r r rrr rr[Úcopyfileobjrrr)ÚresponseÚdstZ parent_dirrrrrÚsave_to_file£s rncCstj|ƒ}|r|jdƒp|S)Nr)Ú VERSION_REÚmatchÚgroup)ÚversionrprrrÚstrip_version_timestamp®s rscCs0|jdƒ\}}}|s$|jdƒ\}}}tj|dƒS)NÚTú z%Y-%m-%d)Ú partitionrÚstrptime)Zstr_rawZstr_dateÚseprCrrrÚparse_response_date´srycGs0ddlm}djdd„td|jƒf|ƒDƒƒS)Nr)Úipv6_supportú/css|]}|jdƒVqdS)r{N)Ústrip)Ú.0Úitrrrú Âsz'get_patch_server_url..)rrzrSrRÚget_patch_server)ÚpartsrzrrrÚget_patch_server_url¾sr‚c Cs0tjj|ƒsdSt|ƒ}|jƒjƒSQRXdS)N)r r rrÚreadr|)ÚfilenamerrrrÚtry_to_readÅs r…cCs ttjƒS)N)r…rrgrrrrÚ get_cache_keyÎsr†c Cs.tjj|ƒs|St||ƒ }|jƒSQRXdS)N)r r rrrƒ)rrÚdefaultrrrrÚ _read_fileÔsrˆcCst|d|ƒ}|S)NÚr)rˆ)rr‡r1rrrÚ read_fileÜsrŠcCst|d|ƒ}|S)NÚrb)rˆ)rr‡r1rrrÚ read_file_binâsrŒcCsBi}|jƒ}x0|D](}|r|jdƒ\}}}|r|jƒ||<qW|S)Nú:)Ú splitlinesrvr|)r$r1Z data_linesÚlineÚkeyÚ delimiterÚvaluerrrÚdata_as_dictès r“cCstttjƒƒƒS)N)ÚstrÚintr<rrrrÚ timestamp_strôsr–)Fr)r)r')r')NNN)N)N)$r rQr5Úrer[r?r<rrrÚcompileroZ CACHE_ENTRIESrr r!r(rr&r)r*r8rNrcrirnrsryr‚r…r†rˆrŠrŒr“r–rrrrÚs@ $