U wÚ7eã @sÌUdZddlZddlZddlZddlmZmZddlmZddl m Z ddl m Z m Z ddlmZdZd gZeZd d d eed gegdœZe ed<e eƒZe e¡Zdd„Zdd„Zee eeddœdd„ZdS)z8Migrator: Migrate old versions of cloud-init data to newéN)ÚhelpersÚutil)ÚCloud)ÚConfig)Ú MetaSchemaÚ get_meta_doc)Ú PER_ALWAYSaEThis module handles moving old versions of cloud-init data to newer ones. Currently, it only handles renaming cloud-init's per-frequency semaphore files to canonicalized name and renaming legacy semaphore names to newer ones. This module is enabled by default, but can be disabled by specifying ``migrate: false`` in config. ÚallZ cc_migratorZMigratorz.Migrate old versions of cloud-init data to newz6# Do not migrate cloud-init semaphores migrate: false )ÚidÚnameÚtitleZ descriptionÚdistrosZexamplesÚ frequencyZactivate_by_schema_keysÚmetac Cs®|j d¡|j d¡f}d}|D]ˆ}|r tj |¡s6q t |¡D]f}tj ||¡}tj |¡r@tj  |¡\}}t   |¡}||kr@tj |||¡} t   || ¡|d7}q@q |S)NÚsemré)ÚpathsÚ get_ipathÚ get_cpathÚosÚpathÚexistsÚlistdirÚjoinÚisfileÚsplitextrÚcanon_sem_nameÚshutilZmove) ÚcloudrZ am_adjustedÚsem_pathÚpÚ full_pathr ZextZ canon_nameÚnew_path©r#ú>/usr/lib/python3/dist-packages/cloudinit/config/cc_migrator.pyÚ_migrate_canon_sems-s    r%c Csdddgi}|j d¡|j d¡f}|D]à}|r(tj |¡s>q(t |¡}| ¡D]¶\}}|t  |¡g}g}t  |¡D]2} tj  | ¡\} } | |krttj  | ¡rt|  | ¡qt|D]X} t tj || ¡¡tj  | ¡\} } |D]*}t d| |¡| || ¡W5QRXqØq¬qPq(dS)Nzapt-update-upgradeZ apt_configureZpackage_update_upgrade_installrz*Migrating %s => %s with the same frequency)rrrrrrrZFileSemaphoresÚitemsrrrrÚappendrZdel_filerÚLOGÚdebugÚlock)rZ legacy_adjustrrZ sem_helperÚmod_nameZ migrate_toZ possiblesZ old_existsr r Z_extÚ_nameZfreqÚmr#r#r$Ú_migrate_legacy_sems?s8þÿ  ÿr.)r ÚcfgrÚargsÚreturncCsHt |dd¡}t |¡s(t d|¡dSt|ƒ}t d|¡t|ƒdS)NZmigrateTz,Skipping module named %s, migration disabledz8Migrated %s semaphore files to there canonicalized names)rZget_cfg_option_strZtranslate_boolr(r)r%r.)r r/rr0Z do_migrateZ sems_movedr#r#r$Úhandle]s  ÿr2)Ú__doc__ZloggingrrZ cloudinitrrZcloudinit.cloudrZcloudinit.configrZcloudinit.config.schemarrZcloudinit.settingsrZMODULE_DESCRIPTIONr rrÚ__annotations__Z getLoggerÚ__name__r(r%r.ÚstrÚlistr2r#r#r#r$Ús2   ø