yf4SSKrSSKrSSKrSSKrSSKJrJr SSKJr SSK J r SSK J r J r J r SSKJr SSKJr SS KJrJr \"\5rS r"S S \5r"S S\5r"SS\5r"SS\5rg)N) KeyfileKeyKeyfileNotFoundError)REPOSITORY_README)ProgressIndicatorPercent) get_base_dir get_keys_dir get_cache_dir)Lock) create_logger) RepositoryMAGICsATTICSEGc^\rSrSrU4SjrS SjrSr\S Sj5r\S Sj5r Sr \S5r S r S r S rU=r$)AtticRepositoryUpgraderc:>SUS'SUS'[TU]"U0UD6 g)NFlockcheck_segment_magic)super__init__)selfargskw __class__s //usr/lib/python3/dist-packages/borg/upgrader.pyr AtticRepositoryUpgrader.__init__s)6 $) ! $%"%cU SnU(dyURS[RR5S3n[R SU5 U(d.[ R "URU[RS9 [R S5 [[RRURS5SS S 9R5Ul URR5VVs/sHupVUPM nnnUR5nUR!X5 SSS5 [[RRURS5SS 9R5Ul UR'U5 UR)XS 9 UR+WXUS9 UR-5 URR/5 SUl W$s snnf!["a [R%S 5 Nf=f!,(df  N=f!URR/5 SUl f=f)abconvert an attic repository to a borg repository those are the files that need to be upgraded here, from most important to least important: segments, key files, and various caches, the latter being optional, as they will be rebuilt if missing. we nevertheless do the order in reverse, as we prefer to do the fast stuff first, to improve interactivity. Nz.before-upgrade-z%Y-%m-%d-%H:%M:%Szmaking a hardlink copy in %s) copy_functionz1opening attic repository with borg and convertingrTg?) exclusivetimeout no key file found for repository)r )dryruninplace)r#r$progress)pathdatetimenowloggerinfoshutilcopytreeoslinkr joinacquireriosegment_iteratorfind_attic_keyfileconvert_keyfilesrwarning convert_cacheconvert_repo_indexconvert_segments borg_readmerelease) rr#r$r%backupifilenamesegmentskeyfiles rupgradeAtticRepositoryUpgrader.upgradesF II;&6x7H7H7L7L7NO`6ab :FCOODIIvRWWM KKK LRWW\\$))V<VYZbbdDI48GG4L4L4NO4N[Q4NHO 7113%%g6!$dii8DIQQS     v &  # #6 # C  ! !(6U] ! ^     II   DI #P( CAB CT2 II   DIsOC;H>G# HG) H?AH#H)H H H  H H#Ic[RRURS5n[R"U5 [ US5nUR [ 5 SSS5 g!,(df  g=f)NREADMEw)r-r&r/removeopenwriter)rreadmefds rr9#AtticRepositoryUpgrader.borg_readmeAsKdii2 & &# " HH& '  s A,, A:ct[RS[U5-5 [U5n[USSS9n[ U5HZupgU(aUR U5 U(a[ R"S5 M<[RU[[US9 M\ U(aUR5 gg)zconvert repository segments from attic to borg replacement pattern is `s/ATTICSEG/BORG_SEG/` in files in `$ATTIC_REPO/data/**`. luckily the magic string length didn't change so we can just replace the 8 first bytes of all regular files in there.zconverting %d segments...zConverting segments %3.0f%%zupgrade.convert_segments)totalmsgmsgidgMbP?r$N) r)r*lenr enumerateshowtimesleeprheader_replace ATTIC_MAGICrfinish)r>r#r$r% segment_countpir<r=s rr8(AtticRepositoryUpgrader.convert_segmentsGs  /#h-?@H %M?\d~ $X.KA  5!'66xe]d6e /  IIK rc[US5nURS5 UR[U55U:XaU(a#URS5 UR U5 Ow[ R "XS-5 [US5nUR U5 UR UR55 SSS5 [ R"US-5 SSS5 g!,(df  N0=f!,(df  g=f)Nzr+brz.tmpwb)rFseekreadrPrGr-renameunlink)r= old_magic new_magicr$segment new_segments rrU&AtticRepositoryUpgrader.header_replace]s (E "g LLO||C N+y8LLOMM), IIh6(9:h-#)))4#))',,.9. IIh/0## ".-# "s$A?C8 1C'=!C8' C5 1C88 Dc,[RU5$)a find the attic keyfiles the keyfiles are loaded by `KeyfileKey.find_key_file()`. that finds the keys with the right identifier for the repo. this is expected to look into $HOME/.attic/keys or $ATTIC_KEYS_DIR for key files matching the given Borg repository. it is expected to raise an exception (KeyfileNotFoundError) if no key is found. whether that exception is from Borg or Attic is unclear. this is split in a separate function in case we want to use the attic code here directly, instead of our local implementation.)AtticKeyfileKey find_key_filers rr3*AtticRepositoryUpgrader.find_attic_keyfilers",,T22rc4[RSU-5 [U5nUR5nSSS5 WR [ R [R S5n[RR[5[RRU55n[RSU-5 U(d'[US5nURU5 SSS5 gg!,(df  N=f!,(df  g=f)aconvert key files from attic to borg replacement pattern is `s/ATTIC KEY/BORG_KEY/` in `get_keys_dir()`, that is `$ATTIC_KEYS_DIR` or `$HOME/.attic/keys`, and moved to `$BORG_KEYS_DIR` or `$HOME/.config/borg/keys`. no need to decrypt to convert. we need to rewrite the whole key file because magic string length changed, but that's not a problem because the keyfiles are small (compared to, say, all the segments).zconverting keyfile %sNrzwriting borg keyfile to %srD)r)r*rFr^replacergFILE_IDrr-r&r/r basenamerG)r?r#fdatas rr4(AtticRepositoryUpgrader.convert_keyfiless  +g56 ']a668D||O33Z5G5GK'',,|~rww/?/?/HI 07:;gs#q $# ] $#sC8D 8 D Dc6UR5nUc#[RSUR-5 g[RR URSU-5n[R SU-5 U(d[RUSSUS9 gg)aconvert some repo files those are all hash indexes, so we need to `s/ATTICIDX/BORG_IDX/` in a few locations: * the repository index (in `$ATTIC_REPO/index.%d`, where `%d` is the `Repository.get_index_transaction_id()`), which we should probably update, with a lock, see `Repository.open()`, which i'm not sure we should use because it may write data on `Repository.close()`... Nz%no index file found for repository %szindex.%dzconverting repo index %sATTICIDXBORG_IDXrO) get_index_transaction_idr)r5r&r-r/r*rrU)rr#r$transaction_idindexs rr7*AtticRepositoryUpgrader.convert_repo_indexs}668  ! NNBTYYN OGGLLJ,GHE KK2U: ;'66uk;`g6hrc^^^[RRS[RR [ 5SS55m[RR TUR 5m[RR [5UR 5mUUU4Sjn[RRT5(a[RRT5(d[R"T5 SH nU"U5 M SHCnU"U5n[RSU-5 T(aM,[RUSS 5 ME g g ) aconvert caches from attic to borg those are all hash indexes, so we need to `s/ATTICIDX/BORG_IDX/` in a few locations: * the `files` and `chunks` cache (in `$ATTIC_CACHE_DIR` or `$HOME/.cache/attic//`), which we could just drop, but if we'd want to convert, we could open it with the `Cache.open()`, edit in place and then `Cache.close()` to make sure we have locking right ATTIC_CACHE_DIRz.cacheatticc>[RRTU5n[RRU5(a[RRTU5n[RRU5(a[R SU5 U$[R SUSU35 T(d[R"X5 U$[R SUSU35 g)acopy the given attic cache path into the borg directory does nothing if dryrun is True. also expects attic_cache_dir and borg_cache_dir to be set in the parent scope, to the directories path including the repository identifier. :params path: the basename of the cache file to copy (example: "files" or "chunks") as a string :returns: the borg file that was created or None if no Attic cache file was found. zAtticRepositoryUpgrader.convert_cache..copy_cache_filesot 77>>),,NN#aclm ! KK"@ DQZP[ \]! >  TF*? |LMr)configfiles)chunkszconverting cache %srsrtN)r-environgetr&r/rid_strr r}makedirsr)r*rrU)rr#rcacherrs ` @@rr6%AtticRepositoryUpgrader.convert_caches**..):)+ln6>*IJ'',, Dmot{{C > 77>>/ * *77>>.11 N+-&-$'. 1E9:v+::5+{[ $ +r)rTFF)T)__name__ __module__ __qualname____firstlineno__rr@r9 staticmethodr8rUr3r4r7r6__static_attributes__ __classcell__)rs@rrrsf& &P( *11(3&,i*?\?\rrc<\rSrSrSrSr\S5r\S5r Sr g)rgz*backwards compatible Attic key file parserz ATTIC KEYc[RRS[RR [ 5SS55$)z,Determine where to repository keys and cacheATTIC_KEYS_DIRz.attickeysr-rrr&r/rrrr AtticKeyfileKey.get_keys_dirs4zz~~. ggll<>8VLN NrcVURnU"5n[RRU5(d[ URU5e[R "U5Hn[RR X45n[U5nUR5R5nU(a@URUR5(a USSUR:Xa UsSSS5 s $SSS5 M [ URU5e!,(df  M=f)a?copy of attic's `find_key_file`_ this has two small modifications: 1. it uses the above `get_keys_dir`_ instead of the global one, assumed to be borg's 2. it uses `repository.path`_ instead of `repository._location.canonical_path`_ because we can't assume the repository has been opened by the archiver yet N) r r-r&r}rlistdirr/rFreadlinestrip startswithrmrcls repositoryr keys_dirnamer=rIlines rrhAtticKeyfileKey.find_key_files'' >ww~~h''&zA AJJx(Dww||H3Hh2{{}**,DOOCKK88T"#Y*J[J[=[# ) #:??H==  s AD D( rN) rrrr__doc__rmrr classmethodrhrrrrrgrgs44GNN >>rrgc*\rSrSrSSjrSrSrSrg)BorgRepositoryUpgraderic[RS5 U UR5nURXA5 SSS5 g![a [R S5 N*f=f!,(df  g=f)zDconvert an old borg repository to a current borg repository z$converting borg 0.xx to borg currentr"N)r)r*find_borg0xx_keyfile move_keyfilesrr5)rr#r$r%r?s rr@BorgRepositoryUpgrader.upgradesf  :;  4335""73 T( CAB CTs-A)AA)A&#A)%A&&A)) A7c,[RU5$N)Borg0xxKeyfileKeyrhris rr+BorgRepositoryUpgrader.find_borg0xx_keyfile%s ..t44rc[RRU5n[RR[ 5U5n[R "X5 g![ a gf=fr)r-r&rnr/r r_FileExistsError)rr?r#r= new_keyfiles rr$BorgRepositoryUpgrader.move_keyfiles(sO77##G,ggll<>8<   IIg +   s A A-,A-rNr)rrrrr@rrrrrrrrs 45rrc8\rSrSrSr\S5r\S5rSr g)ri2z.backwards compatible borg 0.xx key file parserc[RRS[RR [ 5SS55$)N BORG_KEYS_DIRz.borgrrrrrr Borg0xxKeyfileKey.get_keys_dir5s1zz~~o ggll<>7FKM MrcURnU"5n[RRU5(d[ URU5e[R "U5Hn[RR X45n[U5nUR5R5nU(aVURUR5(a6U[UR5S-SUR:Xa UsSSS5 s $SSS5 M [ URU5e!,(df  M=f)Nr)r r-r&r}rrr/rFrrrrmrPrrs rrhBorg0xxKeyfileKey.find_key_file:s'' >ww~~h''&zA AJJx(Dww||H3Hh2{{}**,DOOCKK88T#ckkBRUVBVBW=X\f\m\m=m# ) #:??H==  s A0D// D> rN) rrrrrrr rrhrrrrrr2s-8MM > >rr)r'r-r+rS crypto.keyrr constantsrhelpersrrr r lockingr r)r rr rrrVrrgrrrrrrsn 8(->>!) x  ]\j]\@">j">JZ4> >r