+j jUddlZgdZejdkredddlmZddlZddlmZddl Z ddl Z ddl Z ddl m ZddlmZddlZddlZddlZddlZddlZddlZddlmZmZddlZdd lmZmZmZmZmZm Z m!Z!m"Z"m#Z#dd l$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6e2rdd l7m8Z8dd l9m:Z:m;Z;dd lm?Z?ddl@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZIe3de4ddZJe jKeLZMdeNdeOdeOfdZPdeNdeOdeOfdZQeQddZReQddZSe3dZTde(deTfde(deTffdZUejVdeEde*eEddffd ZWejVdeNd!eNde*d"fd#ZXd$eEddfd%ZYd$eEddfd&ZZdod(e'd)e'd*e[de[fd+Z\d,eEd-eEdeEfd.Z]ejdkrd$eEdeNfd/Z^d$eEdeNfd0Z_e^Z`n d$eEdeNfd1Z_e_Z`d,eEd-eEdeEfd2Zadpd$eEd4eOdeOfd5Zbde0eNfd6Zcdqd7eNd$e.eEde-eNfd8Zdd9e.eNd$eNdeNfd:Zeejfd;d<d3fejfd=eed3fejfd>eed3fejfd?ejgd@dfejfdAdBd3ffZhe1e1e/eNe(eOfdfeidC<d$eNdeNfdDZjejfdEZkd$eEdeNfdFZliZme)eNe.eOfeidG<dHeNdeOfdIZne6dHddeDd3fdJZoe6dHeEdeOfdKZodHe4deEfdeOfdLZodeNfdMZpdNe4ejqdOfdPe%ddfdQZre6drd-ddReOddfdSZse6drd-eEdReOdeNfdTZsdsd-e4deEfdReOde.eEfdUZsdVe0eNde-eNfdWZtGdXdYZuGdZd[euZvGd\d]ZwGd^d_ZxGd`daZyGdbdcZzGdddeezZ{Gdfdge-eJZ|eIGdhdieFZ}Gdjdke~ZGdldmenZdS)tN) stream_copy join_pathto_native_path_linuxjoin_path_nativeStatsIndexFileSHA1Writer IterableObj IterableListBlockingLockFileLockFileActor get_user_idassure_directory_existsRemoteProgressCallableRemoteProgressrmtree unbare_repoHIDE_WINDOWS_KNOWN_ERRORSwin32to_native_path_windows)abstractmethod)wraps)Path)urlsplit urlunsplit) LazyMixinLockedFD bin_to_hexfile_contents_rofile_contents_ro_filepath hex_to_binmake_sha to_bin_sha to_hex_sha)AnyAnyStrBinaryIOCallableDict GeneratorIOIteratorListOptionalPatternSequenceTuple TYPE_CHECKINGTypeVarUnioncastoverload)Git)GitConfigParserSectionConstraint)Remote)Repo) Files_TDHas_id_attributeHSH_TDLiteralPathLikeProtocol SupportsIndexTotal_TDruntime_checkable T_IterableObj)r r=T)bound covariantnamedefaultreturnc& tj|}n#t$r|cYSwxYwtd||}|dvrdS|dvrdStd||||S)zRead a boolean flag from an environment variable. :return: The flag, or the `default` value if absent or ambiguous. zlThe %s environment variable is deprecated. Its effect has never been documented and changes without warning.>0nofalseF>1yestrueTz-%s has unrecognized value %r, treating as %r.)osenvironKeyError_loggerwarningstriplower)rHrIvalueadjusted_values K/home/wildlama/comfy/ComfyUI/.venv/lib/python3.11/site-packages/git/util.py_read_env_flagr]ss  4   OOv  [[]]((**N111u---t OOCT5RYZZZ Ns  $$cBtjdkot||S)aRead a boolean flag from an environment variable on Windows. :return: On Windows, the flag, or the `default` value if absent or ambiguous. On all other operating systems, ``False``. :note: This only accesses the environment on Windows. r)sysplatformr])rHrIs r\_read_win_env_flagras  <7 " D~dG'D'DDrHIDE_WINDOWS_FREEZE_ERRORSTfunc.c |ddlmtdddtdtdtffd }|S) ztMethods with this decorator raise :exc:`~git.exc.InvalidGitRepositoryError` if they encounter a bare repository.)InvalidGitRepositoryErrorselfr:argskwargsrJcZ|jjrdjz|g|Ri|S)Nz/Method '%s' cannot operate on bare repositories)repobare__name__)rirjrkrhres r\wrapperzunbare_repo..wrappersK 9> o++,]`d`m,mnn ntD*4***6***rb)excrhrr%rd)rerprhs` @r\rrsn/..... 4[[+h+s+c+a++++++[+ Nrbnew_dirc#Ktj}tj| |Vtj|dS#tj|wxYw)zContext manager to temporarily change directory. This is similar to :func:`contextlib.chdir` introduced in Python 3.11, but the context manager object returned by a single call to this function is not reentrant. N)rSgetcwdchdir)rrold_dirs r\cwdrws]ikkGHW  s AArZ)NNNc#Ktj|}|tj|< dV|tj|=dS|tj|<dS#|tj|=n|tj|<wxYw)z=Context manager to temporarily patch an environment variable.N)rSgetenvrT)rHrZ old_values r\ patch_envr{s $IBJt)    4   (BJt      4  (BJt  ( ( ( (s A !A.pathcdtdtdtddfd}tjdkrt j|dStjdkrt j|| dSt j|| dS) zRemove the given directory tree recursively. :note: We use :func:`shutil.rmtree` but adjust its behaviour to see whether files that couldn't be deleted are read-only. Windows will not remove them in that case. functionr|_excinforJNctj|tj ||dS#t$r"}t rddlm}|d||d}~wwxYw)zuCallback for :func:`shutil.rmtree`. This works as either a ``onexc`` or ``onerror`` style callback. r)SkipTestz%FIXME: fails with: PermissionError N)rSchmodstatS_IWUSRPermissionErrorrunittestr)r~r|rexrs r\handlerzrmtree..handlers t|$$$  HTNNNNN   ( V------hLLLMMSUU   s . AAAr) )onexc)onerror)r(r@r%r_r`shutilr version_info)r|rs r\rrs((cd" |w d W $ $ d'****** dG,,,,,,rbctj|r;tjdkrt j|dt j|dSdS)zWEnsure file deleted also on *Windows* where read-only files need special treatment.riN)ospisfiler_r`rSrremover|s r\rmfilersP z$ <7 " " HT5 ! ! ! $rbsource destination chunk_sizecd} ||}|||t|z }t||krnQ|S)zCopy all data from the `source` stream into the `destination` stream in chunks of size `chunk_size`. :return: Number of bytes written r)readwritelen)rrrbrchunks r\rrsc B J''%    c%jj u:: " "   Irbapctj|}|D]e}tj|}|s|dr||ddz }<|dks|dr||z }]|d|zz }f|S)zmJoin path tokens together similar to osp.join, but always use ``/`` instead of possibly ``\`` on Windows./rgNrL)rSfspath startswithendswith)rrr|bs r\rrs 9Q<sJ!{4   9T?? D4((((t 5rbctjdd}|r6td|tjDSt jdkrdSdS)NPATHEXTc3>K|]}|VdSr)upper).0rs r\ z&_get_exe_extensions..Ts*BB1QWWYYBBBBBBrbr)z.BATz.COMz.EXE)rSrTgettuplesplitpathsepr_r`)rs r\_get_exe_extensionsrQsbjnnY--GBB bj(A(ABBBBBB  ''rrbprogramctdtdtffd }g}|stjd}tj|tjD]c}|d}|rJtj ||gfdDzD]"}||r| |#d|S)a6Perform a path search to assist :func:`is_cygwin_git`. This is not robust for general use. It is an implementation detail of :func:`is_cygwin_git`. When a search following all shell rules is needed, :func:`shutil.which` can be used instead. :note: Neither this function nor :func:`shutil.which` will predict the effect of an executable search on a native Windows system due to a :class:`subprocess.Popen` call without ``shell=True``, because shell and non-shell executable search on Windows differ considerably. fpathrJctjoLtjtjo-t jdkp ptfdDS)Nrc3fK|]+}|V,dSr)rr)rextrs r\rz,py_where..is_exec..ps;BwBwcf5;;==CYCYZ]C^C^BwBwBwBwBwBwrb)rrrSaccessX_OKr_r`any)r winprog_extss`r\is_execzpy_where..is_execksh Ju    %))  'w|+;wsBwBwBwBwjvBwBwBw?w?w  rbPATH"cg|]}| Srr)reexe_paths r\ zpy_where..{s""P"P"PaXXqq#9"P"P"Prb) rstrboolrSrTrrrrXrjoinappend)rr|rprogsfolderfrrs @@r\py_wherer[s'((L s t       E "z&!)D//'' 33$$c""  $x00HZ"P"P"P"P<"P"P"PP $ $71::$LLOOO Lrbdrivectj|r|s|}n|o7tjtjtj|}tj|r|r|}n,t |}n|rd|d|}tj|}| ddS)Nz/proc/cygdrive/rr) risabsnormpath expandvars expandusercygpathrYrSrr)rr|rp_strs r\ _cygexpathrs y rs,&&&%%%IZIZ[_adIeIeIe*frbz\\\\\?\\(\w):[/\\](.*)z(\w):[/\\](.*)z file:(.*)c|Srr)rs r\rrs rbz (\w{2,}:.*)c|Srr)urls r\rrscrb_cygpath_parsersctj|}|ds_tD]G\}}}||}|r*||}|rt |}nHtd|}|S)zJUse :meth:`git.cmd.Git.polish_url` instead, that works on any environment.)z /cygdriverz/proc/cygdriveN)rSrrrmatchgroupsrr)r|regexparserrecursers r\rrs 9T??D ??@ A A *&6 * * "E67KK%%E vu||~~.)"4==D   dD))D Krbz(?:/proc)?/cygdrive/(\w)(/.*)?ctj|}t|}|r2|\}}|d|pd}|ddS)N:rLrr)rSr_decygpath_regexrrrr)r|mrrs r\ decygpathrsl 9T??Dt$$A:88::y++----b9 <<T " ""rb_is_cygwin_cachegit_executablect|}|?d} tj|}|s-t |}|rtj|dnd}tj|d}t |rtj |tj s*t d|d|t|<|Stj|gtjd}|\}}d |v}n2#t"$r%}t d |Yd}~nd}~wwxYw|t|<|S) NFrrLunamez&Failed checking if running in CYGWIN: z is not an executableT)stdoutuniversal_newlinesCYGWINz/Failed checking if running in CYGWIN due to: %r)rrrrrrrrrSrrrVdebug subprocessPopenPIPE communicate Exception) r is_cygwingit_dirres uname_cmdprocess uname_out_rs r\_is_cygwin_gitr sm $$^44I  Qk.11G =~..14<#+c!f---"'22IOO++-- !")Irw2O2O ! gyggghhh3< 0   & {:?_cdddG"..00LIq I-II Q Q Q MMKR P P P P P P P P Q+4( sCD!#=D!! E+E  EcdSrrrs r\ is_cygwin_gitr;>3rbcdSrrrs r\rrs58Srbctdtjd|tjdkrdS|dSt t |S)Nz sys.platform=z, git_executable=cygwinF)rVrr_r`r rrs r\rrsZ MMU#,UU>UUVVV |xu  uc.11222rbcTtjdtjS)zM:return: String identifying the currently active system user as ``name@node``@)getpassgetuserr`noderrbr\rrs#o'''' 99rbproczGit.AutoInterruptrkc |jdi|dS)zXWait for the process (clone, fetch, pull or push) and handle its errors accordingly.Nr)wait)rrks r\finalize_processrs"DIrb expand_varscdSrrrrs r\ expand_pathr!rrbcdSrrr s r\r!r!s Crbct|tr|S tj|}|rtj|}tjtj|S#t$rYdSwxYwr) isinstancerresolverrrrabspathrr s r\r!r! s!Tyy{{ N1    "q!!A|CKNN+++ ttsAA;; B B cmdlinecg}t|D]\}}|| t|}|j|j9|j4||j|jd}|j4||j|jd}t|||<#t$rYwxYw|S)a>Parse any command line argument and if one of the elements is an URL with a username and/or password, replace them by stars (in-place). If nothing is found, this just returns the command line as-is. This should be used for every log line that print a command line, as well as exception messages. Nz*****)netloc) enumeraterrpasswordusername_replacer)rr ValueError)r' new_cmdlineindexto_parsers r\remove_password_if_presentr2sK$W--x8$$$ 8$$C|# (<|'ll#**<*Ks...Aa...rbzdone.z, ) _cur_line _seen_ops error_lines other_linesz%(remote: )?([\w\s]+):\s+()(\d+)()(.*)z2(remote: )?([\w\s]+):\s+(\d+)% \((\d+)/(\d+)\)(.*)rJNc>g|_d|_g|_g|_dSr)r9r8r:r;ris r\__init__zRemoteProgress.__init__[s&$&(,&(&(rblinect|tr|d}n|}||_|jdr!|j|jdSd\}}|j|}||j |}|s1| ||j |dSd}| \}}} }}} |dkr ||j z}n}|dkr ||jz}nl|dkr ||jz}n[|d kr ||jz}nJ|d kr ||jz}n9|d kr ||jz}n(|d kr ||jz}n| |dS||jvr$|j|||jz}| d } | } | |jr'||jz}| dt5|j } | |j} |||ot;||ot;|| dS)a^Parse progress information from the given line as retrieved by :manpage:`git-push(1)` or :manpage:`git-fetch(1)`. - Lines that do not contain progress info are stored in :attr:`other_lines`. - Lines that seem to contain an error (i.e. start with ``error:`` or ``fatal:``) are stored in :attr:`error_lines`. zutf-8)zerror:zfatal:N)NNrzCounting objectszCompressing objectszWriting objectszReceiving objectszResolving deltaszFinding sourceszChecking out filesrL)r$bytesdecoder8rr:rre_op_relativerre_op_absolute line_droppedr;rCOUNTING COMPRESSINGWRITING RECEIVING RESOLVINGFINDING_SOURCES CHECKING_OUTr9BEGINrXr DONE_TOKENENDrTOKEN_SEPARATORupdatefloat) rir?line_str cur_count max_countrop_code_remoteop_name_percentmessages r\_parse_progress_linez#RemoteProgress._parse_progress_lineas dE " " {{7++HHH! > $ $%9 : :    # #DN 3 3 3 F) 9#))(33 ='--h77E    h ' ' '   # #H - - - FDILLNNA(Iy' ( ( ( t} $GG - - - t' 'GG ) ) ) t| #GG + + + t~ %GG * * * t~ %GG ) ) ) t+ +GG , , , t( (GG   h ' ' ' F $. ( ( N ! !' * * * tz !G ?G--//   DO , , 7 tx G5T_!5!5 556G-- 455   *% **  *% **       rbc&dtddffd }|S)z :return: A progress handler suitable for :func:`~git.cmd.handle_process_output`, passing lines on to this progress handler in a suitable format. r?rJNcR|Sr)r[rstrip)r?ris r\rz3RemoteProgress.new_message_handler..handlers,,T[[]];; ;rb)r&)rirs` r\new_message_handlerz"RemoteProgress.new_message_handlers6 <& `. Nr)rirVrTrUrZs r\rQzRemoteProgress.updates H rbrJNNrL)$ro __module__ __qualname____doc__r5int__annotations__rangerMrOrFrGrHrIrJrKrL STAGE_MASKOP_MASKrNrP __slots__recompilerDrCr>r&r[r(rr_rEr4rRrQrrbr\rr;s55M3 /.}--...   JkGJOI  RZ HIINRZ UVVN)))) W W DW W W W r XseTk%:          .2 $ $ $ e$$ eT)* $  $  $ $ $ $ $ $ rbrcDeZdZdZdZdeddffd Zdededdfd ZxZ S) raA :class:`RemoteProgress` implementation forwarding updates to any callable. :note: Like direct instances of :class:`RemoteProgress`, instances of this :class:`CallableRemoteProgress` class are not themselves directly callable. Rather, instances of this class wrap a callable and forward to it. This should therefore not be confused with :class:`git.types.CallableProgress`.  _callablefnrJNcV||_tdSr)rqsuperr>)rirr __class__s r\r>zCallableRemoteProgress.__init__s& rbrjrkc |j|i|dSrrp)rirjrks r\rQzCallableRemoteProgress.updates''''''rb) rordrerfrlr(r>r%rQ __classcell__rus@r\rrsI8(C(3(4((((((((rbrc eZdZdZejdZejdZdZdZ dZ dZ dZ d Z d Zdeed eed d fd Zded efdZded efdZd efdZd efdZd efdZeded dfdZe ddedededd dfdZeddedd dfdZeddedd dfdZd S)r zActors hold information about a person acting on the repository. They can be committers and authors or anything with a name and an email as mentioned in the git log entries.z<(.*)>z (.*) <(.*?)>GIT_AUTHOR_NAMEGIT_AUTHOR_EMAILGIT_COMMITTER_NAMEGIT_COMMITTER_EMAILrHemailrHr~rJNc"||_||_dSrr)rirHr~s r\r>zActor.__init__s  rbothercB|j|jko|j|jkSrrrirs r\__eq__z Actor.__eq__!syEJ&D4:+DDrbc||k Srrrs r\__ne__z Actor.__ne__$sEM""rbc8t|j|jfSr)hashrHr~r=s r\__hash__zActor.__hash__'sTY +,,,rbc"|jr|jndSrc)rHr=s r\__str__z Actor.__str__*s I-tyy2-rbc(d|jd|jdS)Nz ">rr=s r\__repr__zActor.__repr__-s*.)))TZZZ@@rbstringc&|j|}|r'|\}}t||S|j|}|r#t|ddSt|dS)zCreate an :class:`Actor` from a string. :param string: The string, which is expected to be in regular git format:: John Doe :return: :class:`Actor` rgN)name_email_regexsearchrr name_only_regexgroup)clsrrrHr~s r\ _from_stringzActor._from_string0s  ' ' / /  '((**KD%u%% %#**622A /QWWQZZ...&& &rbenv_name env_email config_reader)Nr8r9c tdd}d dtf fd dtf fd }d||j|fd||j ffD]\}}}} tj|} t ||| ,#t$rq|C |d|} n#t$r | } YnwxYwt ||| t||st ||| YwxYw|S)NrLrJc(stSr)r)user_idsr\ default_emailz(Actor._main_actor..default_emailSs (%--NrbcJddS)Nrr)r)rsr\ default_namez'Actor._main_actor..default_nameYs" =??((--a0 0rbrHr~user) r r conf_name conf_emailrSrTsetattrrUrrgetattr) rrrractorrattrevarcvarrIvalrrs @@r\ _main_actorzActor._main_actorIslb"  s        1c 1 1 1 1 1 1Xs}l ; i ?*  4 4 %D$g 4j&tS)))) 4 4 4 ,(+//==$(((%gii(E4---ud++4E4333 4 s6 #A11 C,>BC,B,)C,+B,,=C,+C,cD||j|j|S)a :return: :class:`Actor` instance corresponding to the configured committer. It behaves similar to the git implementation, such that the environment will override configuration values of `config_reader`. If no value is set at all, it will be generated. :param config_reader: ConfigReader to use to retrieve the values from in case they are not set in the environment. )renv_committer_nameenv_committer_emailrrs r\ committerzActor.committerqs!s5s7NP]^^^rbcD||j|j|S)zSame as :meth:`committer`, but defines the main author. It may be specified in the environment, but defaults to the committer.)renv_author_nameenv_author_emailrs r\authorz Actor.authors s2C4H-XXXrbr) rordrerfrmrnrrrrrrrrrlr.rr>r%rrrrgrrr classmethodrr4rrrrrbr\r r sI !bj++O!rz/22(O)-/IJ!IXc]8C=TECEDEEEE#C#D####-#----.....A#AAAA'#'''''['0 NR %%%%IJ %  %%%[%N _ _e,X&Y _el _ _ _[ _YY5)U#VYbiYYY[YYYrbr c^eZdZdZdZdedeeefddfdZ e dd d e ddfd Z dS) raRepresents stat information as presented by git at the end of a merge. It is created from the output of a diff operation. Example:: c = Commit( sha1 ) s = c.stats s.total # full-stat-dict s.files # dict( filepath : stat-dict ) ``stat-dict`` A dictionary with the following keys and values:: deletions = number of deleted lines as int insertions = number of inserted lines as int lines = total number of lines changed as int, or deletions + insertions change_type = type of change as str, A|C|D|M|R|T|U|X|B ``full-stat-dict`` In addition to the items in the stat-dict, it features additional information:: files = number of changed files as int totalfilesrrrJNc"||_||_dSrr)rirrs r\r>zStats.__init__s  rbrmr;textcdddddid}|D]}|d\}}}}|dkrt|pd} |dkrt|pd} |ddxx| z cc<|ddxx| z cc<|dd xx| | zz cc<|dd xxd z cc<| | | | z|d } | |d |<t |d|d S) zCreate a :class:`Stats` object from output retrieved by :manpage:`git-diff(1)`. :return: :class:`git.Stats` r) insertions deletionslinesrr -rrrrrrg)rrr change_type) splitlinesrrgrXr) rrmrhshr?rraw_insertions raw_deletionsfilenamerr files_dicts r\_list_from_stringzStats._list_from_stringsg%&AANN  OO%% 8 8DEIZZPTEUEU B[.-'3.F3~3F3FK!J%,C]1C1CHqI L & & &* 4 & & & L % % % 2 % % % L ! ! !Z)%; ; ! ! ! L ! ! !Q & ! ! !(&#i/* $$J .8CL)) * *S\3w<000rb) rordrerfrlrCr)r@r<r>rrrrrbr\rrs4#IhtHh4F/GD1V1317111[111rbrcZeZdZdZdZdeddfdZdedefdZ de fd Z de fd Z defd Z dS) raWrapper around a file-like object that remembers the SHA1 of the data written to it. It will write a sha when the stream is closed or if asked for explicitly using :meth:`write_sha`. Only useful to the index file. :note: Based on the dulwich project. )rsha1rrJNc<||_td|_dS)Nrb)rr"r)rirs r\r>zIndexFileSHA1Writer.__init__sSMM rbdatacj|j||j|Sr)rrQrr)rirs r\rzIndexFileSHA1Writer.writes, v||D!!!rbcl|j}|j||Sr)rdigestrrrishas r\ write_shazIndexFileSHA1Writer.write_shas.i    S rbc`|}|j|Sr)rrclosers r\rzIndexFileSHA1Writer.closes%nn   rbc4|jSr)rtellr=s r\rzIndexFileSHA1Writer.tellsv{{}}rb)rordrerfrlr+r>r&rgrrArrrrrbr\rrsI""""""""&"S""""5 u crbrc^eZdZdZdZdeddfdZd dZdefdZ de fd Z d d Z d d Z d d ZdS)r aProvides methods to obtain, check for, and release a file based lock which should be used to handle concurrent access to the same file. As we are a utility class to be derived from, we only use protected methods. Locks will automatically be released on destruction.  _file_path _owns_lock file_pathrJNc"||_d|_dS)NFr)rirs r\r>zLockFile.__init__s#rbc.|dSr) _release_lockr=s r\__del__zLockFile.__del__s rbcd|jzS)z:return: Path to lockfilez%s.lock)rr=s r\_lock_file_pathzLockFile._lock_file_pathsDO,,rbc|jS)z :return: True if we have a lock and if the lockfile still exists :raise AssertionError: If our lock-file does not exist. )rr=s r\ _has_lockzLockFile._has_locks rbc||rdS|}tj|rt d|jd|d t |d5 dddn #1swxYwYn/#t$r"}t t||d}~wwxYwd|_ dS)zCreate a lock file as flag for other instances, mark our instance as lock-holder. :raise IOError: If a lock was already present or a lock file could not be written. NzLock for file z did already exist, delete z in case the lock is illegalw)modeT) rrrrIOErrorropenOSErrorrr)ri lock_filers r\_obtain_lock_or_raisezLockFile._obtain_lock_or_raise s >>    F((** :i  '???III/   )ic***                  ) ) )#a&&//q ( )s<B,A:. B:A>>BA>B B2B--B2c*|S)zThe default implementation will raise if a lock cannot be obtained. Subclasses may override this method to provide a different implementation. )rr=s r\ _obtain_lockzLockFile._obtain_lock"s ))+++rbc|sdS|} t|n#t$rYnwxYwd|_dS)z Release our lock if we have one.NF)rrrrr)rilfps r\rzLockFile._release_lock)si~~  F""$$  3KKKK    D s< A A rb)rordrerfrlr@r>rrrrrrrrrrbr\r r s-I ( t    -----40,,,,       rbr c TeZdZdZdZdejfdedede ddffd Z d fd Z xZ S) r aThe lock file will block until a lock could be obtained, or fail after a specified timeout. :note: If the directory containing the lock was removed, an exception will be raised during the blocking period, preventing hangs as the lock can never be obtained. )_check_interval_max_block_timeg333333?rcheck_interval_smax_block_time_srJNcft|||_||_dS)aConfigure the instance. :param check_interval_s: Period of time to sleep until the lock is checked the next time. By default, it waits a nearly unlimited time. :param max_block_time_s: Maximum amount of seconds we may lock. N)rtr>rr)rirrrrus r\r>zBlockingLockFile.__init__Cs3 ###//rbcTtj}|t|jz} tdS#t $r}tj}t jt j| s,d| ||z fz}t ||||kr,d||z | fz}t ||tj |j Yd}~nd}~wwxYw)zThis method blocks until it obtained the lock, or raises :exc:`IOError` if it ran out of time or if the parent directory was not available anymore. If this method returns, you are guaranteed to own the lock. TzVDirectory containing the lockfile %r was not readable anymore after waiting %g secondsz Waited %g seconds for lock at %rN) timerRrrtrrrrrrsleepr)ri starttimemaxtimercurtimemsgrus r\rzBlockingLockFile._obtain_lockVsD IKK eD$8999  $$&&&,+ 1 1 1)++yT-A-A-C-C!D!DEE.r,,..)+vC"#,,A-g%%<)+,,..@C"#,,A- 4/00000000' 1 s A D&CD!!D&rb) rordrerfrlr_maxsizer@rRrgr>rrwrxs@r\r r 8s7I #& # 000 0 0  000000&          rbr ceZdZdZdZddededdffd Zddededd fd Zd ede fd Z d ede fd Z de eeeefde fdZde eeeefdd fdZxZS)r aList of iterable objects allowing to query an object by id or by named index:: heads = repo.heads heads.master heads['master'] heads[0] Iterable parent objects: * :class:`Commit ` * :class:`Submodule ` * :class:`Reference ` * :class:`FetchInfo ` * :class:`PushInfo ` Iterable via inheritance: * :class:`Head ` * :class:`TagReference ` * :class:`RemoteReference ` This requires an ``id_attribute`` name to be set which will be queried from its contained items to have a means for comparison. A prefix can be specified which is to be used in case the id returned by the items always contains a prefix that does not matter to the user, so it can be left out. _id_attr_prefixrLid_attrprefixrJzIterableList[T_IterableObj]cFt|Sr)rt__new__)rrrrus r\rzIterableList.__new__swws###rbNc"||_||_dSrr)rirrs r\r>zIterableList.__init__s  rbrc t||}|r|Sn#ttf$rYnwxYw t |t t |dS#ttf$rYdSwxYw)NTF)list __contains__AttributeError TypeErrorrr5r)rirrvals r\rzIterableList.__contains__s $$T400D    *    D    D$sD// * * *4 *   55 s"66#AA43A4c|j|z}|D]}t||j|kr|cS t||Sr)rrrr__getattribute__)riritems r\ __getattr__zIterableList.__getattr__sZ|d"  DtT]++t33 4$$T4000rbr0cJt|trt||St|trt d t |tt|S#t$r}td|j ||d}~wwxYw)NzIndex should be an int or strzNo item found with id ) r$rgr __getitem__slicer.rr5rr  IndexErrorr)rir0rs r\rzIterableList.__getitem__s eS ! ! X##D%00 0 u % % X<== = XtT#u%5%5666! X X X !O$,!O!O!OPPVWW Xs"A99 B"BB"c<tt|}t|trVd}|j|z}t |D]"\}}t ||j|kr|}n#|dkrtd|zt ||dS)NzItem with name %s not found) r5rgr$rrr*rrrr __delitem__)rir0delindexrHirs r\rzIterableList.__delitem__sU## eS ! ! GH<%'D$T??  44//477 HE8 2~~ !>!EFFF x(((((rb)rL)rordrerfrlrrr>objectrrrErr4rBrgrrrrwrxs@r\r r zsA8(I$$c$3$8U$$$$$$S$D$11 1111 X}c5#'E!F X= X X X X)}c5#'E!F)4))))))))rbr c eZdZUdZdZeed<eeddde de de e fd Z eddde de de e fd Zd S) r aDefines an interface for iterable items, so there is a uniform way to retrieve and iterate items within the git repository. Subclasses: * :class:`Submodule ` * :class:`Commit ` * :class:`Reference ` * :class:`PushInfo ` * :class:`FetchInfo ` * :class:`Remote ` r_id_attribute_rmr;rjrkrJc td)aSFind (all) items of this type. Subclasses can specify `args` and `kwargs` differently, and may use them for filtering. However, when the method is called with no additional positional or keyword arguments, subclasses are obliged to to yield all items. :return: Iterator yielding Items To be implemented by SubclassNotImplementedErrorrrmrjrks r\ iter_itemszIterableObj.iter_itemss""ABBBrbcvt|j}||j|g|Ri||S)aFind (all) items of this type and collect them into a list. For more information about the arguments, see :meth:`iter_items`. :note: Favor the :meth:`iter_items` method as it will avoid eagerly collecting all items. When there are many items, that can slow performance and increase memory usage. :return: list(Item,...) list of item instances r rextendr!rrmrjrkout_lists r\ list_itemszIterableObj.list_itemssG".c.@!A!At=d===f==>>>rbN)rordrerfrlrrhrrr%r,rEr!r r'rrbr\r r s  I Cf CS CC CH]D[ C C C^[ CfSCLQ^D_[rbr c*eZdZdZdedededdfdZdS)IterableClassWatcherzbMetaclass that issues :exc:`DeprecationWarning` when :class:`git.util.Iterable` is subclassed.rHbasesclsdictrJNc||D]8}t|tur tjd|dtd9dS)Nz!GitPython Iterable subclassed by zq. Iterable is deprecated due to naming clash since v3.1.18 and will be removed in 4.0.0. Use IterableObj instead.) stacklevel)typer)warningswarnDeprecationWarning)rrHr*r+bases r\r>zIterableClassWatcher.__init__se  DDzz111 0000'   rb)rordrerfrr1r)r>rrbr\r)r) sN C         rbr)c jeZdZdZdZdZedddededefd Zedddededefd Z d S) IterablezDeprecated, use :class:`IterableObj` instead. Defines an interface for iterable items, so there is a uniform way to retrieve and iterate items within the git repository. rz5attribute that most suitably identifies your instancermr;rjrkrJc td)zDeprecated, use :class:`IterableObj` instead. Find (all) items of this type. See :meth:`IterableObj.iter_items` for details on usage. :return: Iterator yielding Items rrr s r\r!zIterable.iter_items)s""ABBBrbcvt|j}||j|g|Ri||S)aDeprecated, use :class:`IterableObj` instead. Find (all) items of this type and collect them into a list. See :meth:`IterableObj.list_items` for details on usage. :return: list(Item,...) list of item instances r#r%s r\r'zIterable.list_items6sG%S%788t=d===f==>>>rbN) rordrerfrlrrr%r!r'rrbr\r5r5s ILN Cf CS CC CC C C C[ C f S C C   [   rbr5) metaclass)r)Fr).)T)r___all__r`rabcr contextlib functoolsrrloggingrSos.pathr|rpathlibrrmrrrr urllib.parserrr0 gitdb.utilrrrrr r!r"r#r$typingr%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6git.cmdr7 git.configr8r9 git.remoter: git.repo.baser; git.typesr<r=r>r?r@rArBrCrDrE getLoggerrorVrrr]rarrcrdrcontextmanagerrwr{rrrgrrrrrrrrrrrnIrrhrrrrr rrrrr!r2rrr rrr r r r r/r)r5rrbr\rKs      *<7 NN+,,,   --------                      *#========!!!!!!""""""                      u5V/Wcghhh  ' H % %t4 ES E4 ED E E E E /./JDQQ//0LdSS GCLLhsAv&8CF+;$   i$(<=      )C ) ) 2B(C ) ) ) )--d----BdxSZ]$xH$<7'X'#'''''8''''',NN8*N,,h,8,,,,(Td&Xc]##c#(!3#tCy####L$hsm$3$3$$$$.  @AA f f  RZ)**Z%@RZ!""Z%8RZ bd##&A&ADIRZ//E: E%gclHd:;S@A   ##$2:?@@#H#####/1$sHTN*+00034: >$>75>>>> > 8(8t888 83%h"73D3333:S:::: 5!13F!FGSV[_ >>4>d>T>>> > 8$   5x( t xPXGY     $s)Du u u u u u u u p(((((^((((}Y}Y}Y}Y}Y}Y}Y}Y@=1=1=1=1=1=1=1=1@        FK K K K K K K K \>>>>>x>>>D[)[)[)[)[)4 &[)[)[)|11111(111h4"%%%%%-%%%%%%rb