o +ke:=@sddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z ddlTddlmZeZejejBejBd fd d Zd d ZddZdBddZddZddZddZddZedZddZddZdd Z dd!d"d#Z!d$d%Z"d&d'Z#d(d)Z$d*d+Z%e%d,d-d.Z&e&e%d/BZ'e&Z(e&e%d0d/BZ)e)e%d1BZ*e%d2d.d/Z+dddd3d4d5d6Z,dddd3d7d8d9Z-d:d;Z.ddlZ/ddlZ0ddlZ1ddd?Z8dDd@dAZ9dS)EN)Error)prepare_subprocess_env)is_win32)*) create_loggerTc CsBz tj||ddWdSty }z |rtt|d}~ww)a Ensures that the dir exists with the right permissions. 1) Make sure the directory exists in a race-free operation 2) If mode is not None and the directory has been created, give the right permissions to the leaf directory. The current umask value is masked out first. 3) If pretty_deadly is True, catch exceptions, reraise them with a pretty message. Returns if the directory has been created and has the right permissions, An exception otherwise. If a deadly exception happened it is reraised. T)modeexist_okN)osmakedirsOSErrorrstr)pathr Z pretty_deadlyer3usr/lib/python3.10/site-packages/borg/helpers/fs.py ensure_dirs  rcCs:tjdp tjd}|stjdtjdd}|S)zGet home directory / base directory for borg: - BORG_BASE_DIR, if set - HOME, if set - ~$USER, if USER is set - ~ BORG_BASE_DIRHOMEz~%sZUSER)r environgetr expanduser)base_dirrrr get_base_dir)srcCs0tjd}|durtjtd}t||S),Determine where to repository keys and cacheZ BORG_KEYS_DIRNkeysr rrrjoinget_config_dirr)Zkeys_dirrrr get_keys_dir;s r!cCsBtjd}|durtjtd}|rtj||}t||S)z4Determine where to store local security information.ZBORG_SECURITY_DIRNZsecurityr)Z repository_idZ security_dirrrrget_security_dirEs r"cCstjtd}tjdstjd|}tjdtj|d}t|tj|t}tj|s^t t d d}dd l m}||d d }||Wd |S1sYwY|S) rz.cacherXDG_CACHE_HOMEZBORG_CACHE_DIRborgz # This file is a cache directory tag created by Borg. # For information about cache directory tags, see: # http://www.bford.info/cachedir/spec.html asciir)SaveFileT)binaryN)r rrrrrrCACHE_TAG_NAMEexistsCACHE_TAG_CONTENTStextwrapdedentencodeplatformr&write)Z cache_homeZ cache_dirZ cache_tag_fnZcache_tag_contentsr&fdrrr get_cache_dirQs"      r1cCsNtjtd}tjdstjd|}tjdtj|d}t||S)z%Determine where to store whole configz.configrXDG_CONFIG_HOMEZBORG_CONFIG_DIRr$)r rrrrrr)Z config_homeZ config_dirrrrr is  r cCstj|t}z8tj|r=t|d}|tt}|tkr) WdWdSWdWdS1s5wYWdSWdSt yIYdSw)zDetermines whether the specified path is a cache directory (and therefore should potentially be excluded from the backup) according to the CACHEDIR.TAG protocol (http://www.bford.info/cachedir/spec.html). rbNTF) r rrr(r)openreadlenr*r )rtag_pathZtag_fileZtag_datarrrdir_is_cachedirws&    r8cCsTg}|r t|r |t|dur(|D]}tj||}tj|r'||q|S)aDetermines whether the specified path is excluded by being a cache directory or containing user-specified tag files/directories. Returns a list of the names of the tag files/directories (either CACHEDIR.TAG or the matching user-specified files/directories). N)r8appendr(r rrr))rZexclude_cachesZexclude_if_presentZ tag_namestagr7rrr dir_is_taggeds    r;z ^((\.\.)?/+)+cCstd|pdS)z3Make path safe by making it relative and local r.)_safe_resub)rrrrmake_path_safesr?cCs(t|pt|pt|pt|S)z7return True if we support hardlinked items of this type)statS_ISREGS_ISBLKS_ISCHRS_ISFIFO)r rrr hardlinkables(rEc CsNzd|fWSty&}ztd|j|d|jfWYd}~Sd}~ww)Nrz&scandir_inorder: Unable to stat %s: %sr)inoder loggerdebugrname)Zdirentrrrrscandir_keyfuncsrJ)r0cCs"|dur|n|}tt|tdS)N)key)sortedr scandirrJ)rr0argrrrscandir_inordersrOcCs|t|d*}t|}|jdkr|s(|t|j|t |Wdn1s2wYt |dS)aAttempt to securely erase a file by writing random data over it before deleting it. If avoid_collateral_damage is True, we only secure erase if the total link count is 1, otherwise we just do a normal "delete" (unlink) without first overwriting it with random. This avoids other hardlinks pointing to same inode as getting damaged, but might be less secure. A typical scenario where this is useful are quick "hardlink copies" of bigger directories. If avoid_collateral_damage is False, we always secure erase. If there are hardlinks pointing to the same inode as , they will contain random garbage afterwards. r+brN) r4r r@filenost_nlinkr/urandomst_sizeflushfsyncunlink)rZavoid_collateral_damager0strrr secure_erases rYc Cszt|WdStyW}zC|jtjkrt|}|jdkr"zt|d }|Wdn1s7wYWn tyF|wt|WYd}~dSd}~ww)a Safely unlink (delete) *path*. If we run out of space while deleting the file, we try truncating it first. BUT we truncate only if path is the only hardlink referring to this content. Use this when deleting potentially large files when recovering from a VFS error such as ENOSPC. It can help a full file system recover. Refer to the "File system interaction" section in repository.py for further explanations. rrPN) r rWr errnoENOSPCr@rRr4truncate)rZ unlink_errrXr0rrr safe_unlinks&       r]cCsDd|vsJ|dkrd|vrtjntj}d|vr|jS|St||S)N+-rb)sysstdinstdoutbufferr4)rr streamrrr dash_opens  rgcGs&d}|D] }|ttd|dO}q|S)NrO_)getattrr )flagsresultflagrrrrhsrhBINARYZNOCTTYZRDONLYZNOFOLLOWZNONBLOCKNOATIMEZ DIRECTORYF)r parent_fdrInoatimec Cs|r |dur |}n|d}}trtj|rdS|}|ru|tdB}z tj|||d}W|StyD||kr9tj|||d}Y|Styt} z%ddlm } d| vrh| j t j krh||krhtj|||d}nWYd} ~ |Sd} ~ wwtj|||d}|S)a Use os.open to open a fs item. If parent_fd and name are given, they are preferred and openat will be used, path is not used in this case. :param path: full (but not necessarily absolute) path :param parent_fd: open directory file descriptor :param name: name relative to parent_fd :param flags: open flags for os.open() (int) :param noatime: True if access time shall be preserved :return: file descriptor Nrn)dir_fdr) workaroundsZ retry_erofs) rr risdirrhr4PermissionErrorr rrrrZZEROFS) rjrrorIrpfnameZ _flags_normalZ_flags_noatimer0excrrrrros_open s6       rw)rrorIfollow_symlinkscCs,|r |dur |}n|d}}tj|||dS)aP Use os.stat to open a fs item. If parent_fd and name are given, they are preferred and statat will be used, path is not used in this case. :param path: full (but not necessarily absolute) path :param parent_fd: open directory file descriptor :param name: name relative to parent_fd :return: stat info N)rqrx)r r@)rrorIrxrurrros_stat:s  rycCsFtdd}z tjdd|g|dWSty"tjd|g|dYSw)NT)systemZ fusermountz-u)envumount)r subprocesscallFileNotFoundError)Z mountpointr{rrrr|Ns  r|)_sanitize_params_get_candidate_namesTMP_MAX_text_openflags_bin_openflagsc Cstj|}t}|turttj|}ttD]J}t |}tj ||||} t d| z t | ||} Wn$ty@Yqty[tjdkrZtj|rZt|tjrZYqw| | fSttjd)z>Code common to mkstemp, TemporaryFile, and NamedTemporaryFile.ztempfile.mkstempntz#No usable temporary file name found)_osrabspathrbytesmapfsencoderangernextr_sysauditr4FileExistsErrorrtrIrsaccessW_OK_errnoEEXIST) dirpresufrj output_typer namesseqrIfiler0rrr_mkstemp_inner_s&      $  rcCs4t|||\}}}}|rt}nt}t||||||S)aUser-callable function to create and return a unique temporary file. The return value is a pair (fd, name) where fd is the file descriptor returned by os.open, and name is the filename. If 'suffix' is not None, the file name will end with that suffix, otherwise there will be no suffix. If 'prefix' is not None, the file name will begin with that prefix, otherwise a default prefix is used. If 'dir' is not None, the file will be created in that directory, otherwise a default directory is used. If 'text' is specified and true, the file is opened in text mode. Else (the default) the file is opened in binary mode. If any of 'suffix', 'prefix' and 'dir' are not None, they must be the same type. If they are bytes, the returned name will be bytes; str otherwise. The file is readable and writable only by the creating user ID. If the operating system uses permission bits to indicate whether a file is executable, the file is executable by no one. The file descriptor is not inherited by children of this process. Caller is responsible for deleting the file when done with it. )rrrr)suffixprefixrtextr rrjrrr mkstemp_mode{s r)N)r)NNNFr):rZr os.pathrer@r}rbr+errorsrprocessrZ platformflagsr constantsrGrS_IRWXUS_IRWXGS_IRWXOrrr!r"r1r r8r;compiler=r?rErJrOrYr]rgrhZ flags_baseZ flags_specialZflags_special_followZ flags_normalZ flags_noatimeZ flags_dirrwryr|rrrtempfilerrrrrrrrrrrs\        $    .