dZddlmZddlmZmZddlmZmZddl Z ddl Z ddl m Z ddl Z ddlZddlZddlZddlZddlmZmZmZmZddlmZdd lmZdd lmZdd lmZmZm Z m!Z!m"Z"m#Z#dd l$m%Z%dd l&m'Z'ddl(m)Z)ddl*m+Z+m,Z,ddl-m.Z.ddl/m0Z0m1Z1m2Z2m3Z3m4Z4ddl5m6Z6m7Z7m8Z8m9Z9m:Z:ddl;mm?Z?ddl@mAZAmBZBddlCmDZDmEZEmFZFmGZGddlHmIZImJZJddlKmLZLmMZMmNZNmOZOmPZQeddZRGddeZSeTejddxseSZVeTejddxseSZXdZYGdd eZZ[Gd!d"e[Z\d#Z]ed$Z^d%Z_eYfd&Z`Gd'd(e[Zad)ZbdeVeXfd*Zcd{d,ZPd|d.Zd d}d/Zed~d0Zfdd1Zgdd-deXdd2dfd3Zhdd4Zid5Zjdd6Zkdd7ZlelZmeYfd8ZneYfd9Zoejfd:Zpejfd;Zqejfd<Zrejfd=Zsejfd>Ztejfd?Zud@ZvdAZwd+dejdd-d-fdBZxd+dejeYfdCZyejfdDZzejfdEZ{dFZ| ddGZ}dHZ~ejfdIZdJZddKZ ddLeJdMeeeefdNeeeeffdOZddeVeXd-fdPZddeVeXdQd-fdRZddSZdTZd|dUZdVZddWZddXZddYZddZZd[Zd\Zd]Zdd^Zd_Zd`ZdaZ ddbeGdceddeeefdeeedfedgef dhZdejeXddd-d-d-fdiZddjZdkZddlZdmejd-d-fdnZdoZd|dpZddqZdrZdsZdtZduZdvZdwZdxZddyZdzZy)aSimple wrapper that provides porcelain-like functions on top of Dulwich. Currently implemented: * archive * add * branch{_create,_delete,_list} * check-ignore * checkout * clone * commit * commit-tree * daemon * describe * diff-tree * fetch * init * ls-files * ls-remote * ls-tree * pull * push * rm * remote{_add} * receive-pack * reset * rev-list * tag{_create,_delete,_list} * upload-pack * update-server-info * status * symbolic-ref These functions are meant to behave similarly to the git subcommands. Differences in behaviour are considered bugs. Functions should generally accept both unicode strings and bytestrings ) namedtuple)closingcontextmanager)BytesIO RawIOBaseN)Path)DictOptionalTupleUnion) tar_stream)get_transport_and_path) StackedConfig) CHANGE_ADD CHANGE_DELETE CHANGE_MODIFY CHANGE_RENAME CHANGE_COPYRENAME_CHANGE_TYPES) SendPackError)can_fast_forward)IgnoreFilterManager)blob_from_path_and_statget_unstaged_changes)tree_lookup_path)CommitTagformat_timezoneparse_timezonepretty_format_tree_entry) parse_commit parse_object parse_refparse_reftuples parse_tree)write_pack_indexwrite_pack_objects)write_tree_diff)ProtocolZERO_SHA)ANNOTATED_TAG_SUFFIXLOCAL_BRANCH_PREFIXstrip_peeled_refs RefsContainer)BaseRepoRepo)FileSystemBackend TCPGitServerReceivePackHandlerUploadPackHandlerupdate_server_info GitStatuszstaged unstaged untrackedc*eZdZdZddZdZdZdZy) NoneStreamz;Fallback if stdout or stderr are unavailable, does nothing.cyN)selfsizes $lib/third_party/dulwich/porcelain.pyreadzNoneStream.readcyr:r;)r<s r>readallzNoneStream.readallr@rAcyr:r;r<bs r>readintozNoneStream.readintor@rAcyr:r;rEs r>writezNoneStream.writer@rAN))__name__ __module__ __qualname____doc__r?rCrGrIr;rAr>r8r8sErAr8bufferutf-8c$eZdZdZdfd ZxZS)ErrorzPorcelain-based error. c:tt| |||_yr:)superrR__init__inner)r<msgrV __class__s r>rUzError.__init__s eT#C( rAr:)rKrLrMrNrU __classcell__)rXs@r>rRrRs!rArRceZdZdZy) RemoteExistsz&Raised when the remote already exists.NrKrLrMrNr;rAr>r[r[s0rAr[c<t|tr|St|S)zEOpen an argument that can be a repository or a path for a repository.) isinstancer/r0 path_or_repos r> open_reporas,)  rAc#K|yw)zBContext manager that has the same api as closing but does nothing.Nr;)objs r>_noop_context_managerrds  Isc`t|tr t|Stt |S)zOpen an argument that can be a repository or a path for a repository. returns a context manager that will close the repo on exit if the argument is a path, else does nothing if the argument is a repo. )r^r/rdrr0r_s r>open_repo_closingrfs) ,)$\22 4 % &&rActjdkrt|tst j |}t|tst j |}tj j||}|jdrd|d|d}t|tj jdk7r9|jtj jjdd}|Stjd k(rtj j|}t|}|j!}tjd k(rtj j|}t|j!} |j#|}tjd k(rBt+|jtj jdj|St|S#t$rM|j%r9|j&j!}||j(z j#|}nYwxYw) aConvert a path to a path usable in an index, e.g. bytes and relative to the repository root. Args: repopath: Repository path, absolute or relative to the cwd path: A path, absolute or relative to the cwd Returns: A path formatted for use in e.g. an index )s..zPath z not in repo path ()/ascii/win32)sys version_infor^bytesosfsencodepathrelpath startswith ValueErrorsepreplaceencodeplatformabspathrresolve relative_to is_symlinkparentnamestr)repopathrt tree_encodingtreepatherr_msg resolved_pathrurs r>path_to_tree_pathrs & $&;;t$D(E*{{8,H77??42   u %9=xHGW% % 77;;# '' (:(:7(CTJH <<7 "77??4(DDz  <<7 "wwx0H>))+ #//9G <<7 "w<'' S9@@O O> !  ,,.!DII-::8D  sHAIIceZdZdZy)DivergedBranchesz8Branches have diverged and fast-forward is not possible.Nr\r;rAr>rr sBrArc^ t|||}|s t||y#t$rd}YwxYw)zCheck if updating to a sha can be done with fast forwarding. Args: repo: Repository object current_sha: Current head sha new_sha: New head sha FN)rKeyErrorr)repo current_shanew_shacans r>check_divergedrsBt[': {G44  s  ,,c|d}t|5}t||}t|j|j|j|j D]}|j | dddy#1swYyxYw)zCreate an archive. Args: repo: Path of repository for which to generate an archive. committish: Commit SHA1 or ref to use outstream: Output stream (defaults to stdout) errstream: Error stream (defaults to stderr) NHEAD)rfr!r object_storetree commit_timerI)r committish outstream errstreamrepo_objcchunks r>archiver!sn 4 H : .  ! !8#8#8#@!-- E OOE "  ! s AA55A>.cZt|5}t|dddy#1swYyxYw)z]Update server info files for a repository. Args: repo: path to the repository N)rfserver_update_server_inforrs r>r5r5:s" 4 A!!$ ! s !*Fct|5}t|}|s*||jjvrt d|z|jj d|dddy#1swYyxYw)zSet git symbolic ref into HEAD. Args: repo: path to the repository ref_name: short name of the new ref force: force settings without checking if it exists in refs/heads zfatal: ref `%s` is not a refHEADN)rf_make_branch_refrefskeysrRset_symbolic_ref)rref_nameforcerref_paths r> symbolic_refrDs` 4 H#H-););)==6AB B &&w9 ! s AA))A2cTt|ddr|j|xst}t|ddr|j|xst}t|ddr|j|xst}t|5}|j |||||cdddS#1swYyxYw)a$Create a new commit. Args: repo: Path to repository message: Optional commit message author: Optional author name and email committer: Optional committer name and email no_verify: Skip pre-commit and commit-msg hooks Returns: SHA1 of the new commit rzN)messageauthor committerencoding no_verify)getattrrzDEFAULT_ENCODINGrf do_commit)rrrrrrrs r>commitrSs(w$'..!=-=>vx&x;+;<y(D)$$X%A1AB 4 A{{   ! s >BB'cnt|5}|j||||cdddS#1swYyxYw)zCreate a new commit object. Args: repo: Path to repository tree: An existing tree object author: Optional author name and email committer: Optional committer name and email )rrrrN)rfr)rrrrrrs r> commit_treerws4 4 A{{$)F  ! s+4ctjj|stj||rt j |St j |S)zCreate a new git repository. Args: path: Path to repository. bare: Whether to create a bare repository. Returns: A Repo instance )rrrtexistsmkdirr0 init_bareinit)rtbares r>rrs? 77>>$   ~~d##yyrAoriginc ^|ddl} | jdtd|}|| }|r |r td||j dd}t j j|st j||rtj|} ntj|} d |jd z} | j} t|ts|jt }| j#d |fd || j#d |fd d|zdz| j%t'| |f|| |d|} | j(j+D]!\}}| j,j/||# | | j,d}|j0| d<|r@|s>|<|j5d|j0zdz| j7|j8| S#t2$rd}YQwxYw#t:$r't=j>|| jAwxYw)aClone a local or remote git repository. Args: source: Path or URL for source repository target: Path to target repository (optional) bare: Whether or not to create a bare repository checkout: Whether or not to check-out HEAD after cloning errstream: Optional stream to write progress to outstream: Optional stream to write progress to (deprecated) origin: Name of remote from the repository used to clone depth: Depth to fetch at Returns: The new repository Nrz7outstream= has been deprecated in favour of errstream=.rh) stacklevelz"checkout and bare are incompatiblerkrJs clone: from rPremoteurlsfetchs+refs/heads/*:refs/remotes/s/*)rrdepthrs Checking out  )!warningswarnDeprecationWarningrRsplitrrrtrrr0rrrz get_configr^rqrset write_to_pathfetchsymrefsitemsrridrrI reset_indexr BaseExceptionshutilrmtreeclose)sourcetargetrcheckoutrroriginrkwargsrrreflog_message target_config fetch_resultkeyheads r>cloners&2 E    8D899 ~c"2& 77>>& !  NN6 " IIf $v}}W'==N!  &%(]]#34F9f-vv>    *V 3e ; ##%   "    (//557KC FF # #C 08 !\&&w/0DAgJ DT%5 OO,tww6> ? MM$)) $ H D   f   s2CG<G+AG<+ G96G<8G99G<<0H,c t}t|5}t|jj }t j |}|s_tttttjj t||j}g}t|ts|g}|D]g}tt|j j|}|j|r|j!|W|j#|i|j%|ddd||fS#1swY|fSxYw)zAdd files to the staging area. Args: repo: Repository for the files paths: Paths to add. No value passed stages all modified files. Returns: Tuple with set of added files and ignored files N)rrfrrtr}r from_repolistget_untracked_pathsrrrgetcwd open_indexr^r~ is_ignoredaddappendstage) rpathsignoredr repo_pathignore_managerrelpathsprus r>rrseG 4 AL((* ,66q9#RYY[)1134 NLLNE%&GEA$q'//+77 BCG((1 G$ OOG $  + !, g - !, g s D,EEc tjj|tjjz}tjj|tjjz}|j |S)zCheck whether subdir is parentdir or a subdir of parentdir If parentdir or subdir is a relative path, it will be disamgibuated relative to the pwd. )rrrtrealpathrxrv)subdir parentdir parentdir_abs subdir_abss r> _is_subdirrsW GG$$Y/"''++=M!!&)BGGKK7J   //rAc|tj}t|5}t||js t d|j }|jddd}|j}tj|}t||j}tt|D]\}} | r:ttj|dk(} | s,tj |Bt#|j|} | |v} tjj%||j} |j'| }| r|rtj(| dddy#1swYyxYw)aRemove any untracked files from the target directory recursively Equivalent to running `git clean -fd` in target_dir. Args: repo: Repository where the files may be tracked target_dir: Directory to clean - current directory if None Nz,target_dir must be in the repo's working dir)scleans requireForceTr)rrrrfrrtrRget_config_stack get_booleanrrr_walk_working_dir_pathsreversedrlenlistdirrmdirrrurremove)r target_dirrconfig require_forceindexr paths_in_wdapis_diris_emptyip is_trackedrprs r>cleanr s,YY[ 4 A*aff-FG G##%** $  ,66q9-j!&&A #4 #45JBrzz"~.!3HHRL&qvvr25[ WW__R0+66r: !*IIbM6% ! sB?E4"A-E4E4E44E=c*t|5}|j}|D]}tjtjj |}t |j|} ||j}|s tj|} t|| } t|j||jj|d} | j |k7r|| k7rtd|z|| k7rtd|ztj"|||=|j)dddy#t$rtd|zwxYw#t$rd} YwxYw#t$$rYVwxYw#t&$rYewxYw#1swYyxYw)zuRemove files from the staging area. Args: repo: Repository for the files paths: Paths to remove z%s did not match any filesNzAfile has staged content differing from both the file and head: %szfile has staged changes: %s)rfrrrrsrtr|rsharrRlstatrr __getitem__rrrrIOErrorOSErrorrI) rrcachedrrr full_path tree_path index_shastblob committed_shas r>rrOs 4 A A BGGOOA$67I)!&&!4I >!),00 -),B-6y"E1,< ! q{/?/?--!M  77i/I4N"'!BDE!F# % 5"'(E(I"JJ ),i GH  M !  >81<== >$ (1,0M1#  ! sAF ,D?;F >E: E+!5EA F ?EF  E(%F 'E((F + E74F 6E77F : FF FF  Fcz|jr|jjd}n|}|j|dS)Nrlry)rdecodercontentsdefault_encodingrs r> commit_decoder s3 ??))'2# ??8Y //rAcx|jr|jjd}n|}|j|S)Nrl)rrrzrs r> commit_encoder"s1 ??))'2# ??8 $$rAc |jd|jd|jjdzdzt|jdkDrP|jddj |jddDcgc]}|jdc}zdz|jd ||j zdz|j |jk7r'|jd ||jzdztj|j|jz}tjd |}t|jjd}|jd |zd z|zdz|jd|j||jdz|jdycc}w)zWrite a human-readable commit log entry. Args: commit: A `Commit` object outstream: A stream file to write to z3-------------------------------------------------- zcommit: rl rzmerge: z...NzAuthor: z Committer: %a %b %d %Y %H:%M:%SDate:  )rIrrrparentsjoinrrtimegmtime author_timeauthor_timezonestrftimerr)rrrr time_tupletime_str timezone_strs r> print_commitr2sOOO$ OOJ!1!1'!::TAB 6>>Q jjV^^AB5GH5G!((7+5GHI J  OOJ !66=> }}((( v/?/?(@@4GHV//&2H2HHIJ}}3Z@H"6#9#9:AA'JL OOJ)C/,>EF OOD OOF6>>*T12 OODIsGc|jd||jzdztj|j|j z}tj d|}t|j jd}|jd|zdz|zdz|jd|j||jdz|jdy)zWrite a human-readable tag. Args: tag: A `Tag` object decode: Function for decoding bytes to unicode string outstream: A stream to write to zTagger: r$r%rlr&r'N) rItaggerr*r+tag_time tag_timezoner.rrr)tagrrr/r0r1s r> print_tagr8sOOJ !33d:;S\\C,<,<<=J}}3Z@H"3#3#34;;GDL OOJ)C/,>EF OOD OOF3;;'$./ OODrAcF|j||jy)zWrite a blob to a stream. Args: repo: A `Repo` object blob: A `Blob` object decode: Function for decoding bytes to unicode string outstream: A stream file to write to N)rIdata)rrrrs r> show_blobr;sOOF499%&rAcFt||||jr||jd}|j}nd}t}t ||j ||j|j d|jt||jy)zShow a commit to a stream. Args: repo: A `Repo` object commit: A `Commit` object decode: Function for decoding bytes to unicode string outstream: Stream to write to )rrrN) r2r(rrr(rseekrIr getvalue)rrrr parent_commit base_tree diffstreams r> show_commitrBs)< ~~V^^A./ !&&  JJ 1 19fkkJOOA OOM&**=*=*?@ArAcF|D]}|j||dzy)zPrint a tree to a stream. Args: repo: A `Repo` object tree: A `Tree` object decode: Function for decoding bytes to unicode string outstream: Stream to write to r$N)rI)rrrrns r> show_treerEs#q D()rAcZt|||t|||jd||y)zPrint a tag to a stream. Args: repo: A `Repo` object tag: A `Tag` object decode: Function for decoding bytes to unicode string outstream: Stream to write to rN)r8 show_objectobject)rr7rrs r>show_tagrIs+c69%d3::a=)69=rAc\ ttttd|j||||S)N)streesblobscommitstag)rEr;rBrI type_name)rrcrrs r>rGrGs;     mm   3  33rAc#NK|D]}|st|tr|d}|jtk(r|jj }d}d}n|jt k(r|jj }d}d}n|jtk(r|jj }d}d}ni|jtvrW|jj }|jj }|jtk(rd}n|jtk(rd}dd d y w) z5Print a simple status summary, listing changed files.rADMRC820N) r^rtypernewrtroldrrrr)changeschangepath1path2kinds r>print_name_statusr]s  fd #AYF ;;* $JJOOEED [[M )JJOOEED [[M )JJOOEED [[/ /JJOOEJJOOE{{m+ +"&u551sD#D%c 8 t|5}|j|||}|D]Z fd}t j|||s"|j t j D cgc]} | dz c} \ dddycc} w#1swYyxYw)aQWrite commit logs. Args: repo: Path to repository paths: Optional set of specific paths to print entries for outstream: Stream to write log output to reverse: Reverse order in which entries are printed name_status: Print name status max_entries: Optional maximum number of entries to display ) max_entriesrreversec0tj|Sr:)r r)xentrys r>rzlog..decode7s$U\\155rAr$N)rf get_walkerr2r writelinesr]rX) rrrr_r` name_statusrwalkerrlinercs @r>logri!s$ 4 A+UGTE 6 vy 9$$->u}}-OP-OTTD[-OP ! Q ! s#8B&B, B 8 B BBc|dg}t|ts|g}t|5}|D]8}t||ttrfd}nfd}t |||: dddy#1swYyxYw)zPrint the changes in a commit. Args: repo: Path to repository objects: Objects to show (defaults to [HEAD]) outstream: Stream to write to default_encoding: Default encoding to use if none is set in the commit Nrct|Sr:)r )rbros r>rzshow..decodeZs(A/?@@rAc&|jSr:)r)rbrs r>rzshow..decode_s88$455rA)r^rrfr"rrG)robjectsrrr objectishrrls ` @r>showrpBss( gt $) 4 A IQ *A!V$A 6 1fi 0! ! s >A..A7ctt|5}t||j||dddy#1swYyxYw)zCompares the content and mode of blobs found via two tree objects. Args: repo: Path to repository old_tree: Id of old tree new_tree: Id of new tree outstream: Stream to write to N)rfr(r)rold_treenew_treerrs r> diff_treertes, 4 A 1>>8XF ! s.7ct|5}|j|Dcgc]}||jc}D]*}|j|jjdz, dddycc}w#1swYyxYw)zLists commit objects in reverse chronological order. Args: repo: Path to repository commits: Commits over which to iterate outstream: Stream to write to )includerN)rfrdrrIr)rcommitsrrrrcs r>rev_listrxrsh 4 A\\G*DGq1Q477G*D\EE OOELLOOe3 4F ! *D ! sA6A1 5A61A66A?cLddl}|jdtt|i|S)Nrz0tag has been deprecated in favour of tag_create.)rrr tag_createargsrrs r>r7r7s) MM:rzrzs<2 4 Aa+ eG~--a.@.@.BC#GN%GOGL"6lFII6GNtyy{+'G # L#.-l; #/G [[t[,78vvg>S>S>U7V4G%}- NN % %g .ZZFYYF%+}S!"A ! 2-,3 ! s%CE.(E"AE."E+ 'E..E7cLddl}|jdtt|i|S)Nrz4list_tags has been deprecated in favour of tag_list.)rrrtag_listr{s r> list_tagsrs) MM> T $V $$rAct|5}t|jjd}|cdddS#1swYyxYw)zfList all tags. Args: repo: Path to repository outstream: Stream to write tags to refs/tagsN)rfsortedras_dict)rrrtagss r>rrs4 4 Aaffnn\23 ! s &<Act|5}t|tr|g}n!t|tr|}nt d|z|D]}|j t |= dddy#1swYyxYw)z^Remove a tag. Args: repo: Path to repository name: Name of tag to remove zUnexpected tag name type %rN)rfr^rqrrRrrrrrnamess r> tag_deletersf 4 A dE "FE d #E5<= =D}T*+ ! AA))A2c|dk7r tdt|5}t||}|j|jdddy#1swYyxYw)zReset current HEAD to the specified state. Args: repo: Path to repository mode: Mode ("hard", "soft", "mixed") treeish: Treeish to reset to hardz)hard is the only mode currently supportedN)rRrfr%rr)rmodetreeishrrs r>resetrsI v~?@@ 4 A!W% dgg ! s (A  Arremote_locationreturnc"|j}| t|}t|tr|j }n|}d|f}d}|j |r%|j }|j|d}|}nd}||j fS)Nrurl)rget_branch_remoter^rrz has_sectionrget)rrrencoded_locationsection remote_namers r>get_remote_repors__ F+D1/3'*113**+GK '"&--/ jj%( )002 33rAc Ft|5 tgt|\}}t|fdj i|\}} gifd} t |ddxst } |j| } |j| | j|j} |jd|j| zdz| j xsij#D]A\}}|&|jd ||j| fz.|jd |zC|t%j&|dddy#t$r6} td|zd z| jd jz| d} ~ wwxYw#1swYyxYw)a1Remote push with dulwich via dulwich.client Args: repo: Path to repository remote_location: Location of the remote refspecs: Refs to push to remote outstream: A stream file to write output errstream: A stream file to write errors force: Force overwriting refs Nrc* jtj|i} D]G\}}}|t||<d |< j|}|s||vrt ||||||<| |<I|S#t$rt d|zwxYw)Nrz#No valid ref %s in local repository)extendr$rr*rrRr) rnew_refslhrh force_reflocalsharrrefspecsremote_changed_refs selected_refss r> update_refszpush..update_refs8s  xu!U VH'4#R:#+HRL.2'+P#$66":%t&q$r(H=#+HRL.6'+(5O $P#$IB$NOOPs A::Br)generate_pack_dataprogresssPush to s successful. zPush to z failed -> r)rVsPush of ref %s failed: %s sRef %s updated )rf active_branchrrrrrget_url send_packrrIrzrrRr|r ref_statusr_import_remote_refsr)rrrrrrrrclientrtr err_encodingresultereferrorrrrs ` ` @@@r>pushrs* 4 A  %a()H)8O)L&o.  $%$6$6$8 determine_wantszpull..determine_wantsse   QVVXUK  ,9+8'RYr?!..8B+8 s!Ar)rrzmerge is not yet supportedrr)r) rfrrrrrIrrrNotImplementedErrorrrr)rrrrr fast_forwardrrrrrrtrrrrrrrs ` ` @@r>pullrjsj( 4 A)8O)L&o  yH  .  $%$6$6$8 ?AgJz 4   "  \5F5F GO ! 4$ L-.JKK  L5 ! s%A&D>7'D#A#D;;D>>Ecjt|5}t|}|j}|j}|j}t t ||j|}t|j|j|| }t |} t||| cdddS#1swYyxYw)aReturns staged, unstaged, and untracked changes relative to the HEAD. Args: repo: Path to repository or repository object ignored: Whether to include ignored files in `untracked` Returns: GitStatus tuple, staged - dict with lists of staged paths (diff index/HEAD) unstaged - list of unstaged paths (diff index/working-tree) untracked - list of untracked, un-ignored & non-.git paths )exclude_ignoredN) rfget_tree_changesrget_blob_normalizercheckin_normalizerrrtrr6) rrrtracked_changesr normalizerfilter_callbackunstaged_changesuntracked_pathsuntracked_changess r>statusrs 4 A*1- **, $66 4UAFFO TU- FFAFFEw; !1*:rrs)+(9$9 X  OOF #(" Y    V $(" h 4- !Hww||GX6HE/ !"):sBBc#xK|r*t|5}tj|}dddnd}t||D]m\}}0|j t j j||r8|r;t||}||vsLt j j||oy#1swYxYww)zGet untracked paths. Args: frompath: Path to walk basepath: Path to compare to index: Index to check against exclude_ignored: Whether to exclude ignored paths N) rfrrrrrrrtrur) rrrrrrrrr s r>rrs x (A0::1=N) (-hA F  %.*C*C GGOOB )+  "8R0Bggoob(33B ) (s(B:B.AB:8B: %B:.B73B:ct|5}|j}gggd} |dj}|j |j |D]~}|dds|dj |dd&|dds|dj |ddI|dd|ddk(r|dj |ddutd |cdddS#t$rd}YwxYw#1swYyxYw) zReturn add/delete/modify changes to tree by comparing index to HEAD. Args: repo: repo path or object Returns: dict with lists for each type of change )rdeletemodifyrNrrrrrzgit mv ops not yet supported)rfrrrchanges_from_treerrr)rrrrtree_idrYs r>rrs 4 A     jooG--anngFF!9Q<&--fQil;AYq\)001>11-)001>)*HIIG3 !  G  ! s.C,CBC, C)&C,(C))C,,C5cTt|}t|||}|jy)zRun a daemon serving Git requests over TCP/IP. Args: path: Path to the directory to serve. address: Optional address to listen on (defaults to ::) port: Optional port to listen on (defaults to TCP_GIT_PORT) N)r1r2 serve_forever)rtaddressportbackendservers r>daemonrs( %G '7D 1F rAc|ddlm}m}m}m}t |}||}||||||} | j y)zRun a daemon serving Git requests over HTTP. Args: path: Path to the directory to serve address: Optional address to listen on (defaults to ::) port: Optional port to listen on (defaults to 80) r)make_wsgi_chain make_serverWSGIRequestHandlerLoggerWSGIServerLogger) handler_class server_classN) dulwich.webrrrrr1r) rtrrrrrrrapprs r> web_daemonr)sI %G ' "C   .% F rAcx)ttjdtj|)ttjdtj}tj j |}t|}fd}t|j|}t||g|}|jy)zUpload a pack file after negotiating its contents using smart protocol. Args: path: Path to the repository inf: Input stream to communicate with client outf: Output stream to communicate with client rOcHj|jyr:rIflushr:outfs r>send_fnzupload_pack..send_fnS 4 rAr) rrostdoutstdinrrrt expanduserr1r)r?r4handlertinfrrrprotohandlers ` r> upload_packrDs |szz8SZZ8 {cii3995 77  d #D%G SXXw 'E$7G NN rAcx)ttjdtj|)ttjdtj}tj j |}t|}fd}t|j|}t||g|}|jy)zReceive a pack file after negotiating its contents using smart protocol. Args: path: Path to the repository inf: Input stream to communicate with client outf: Output stream to communicate with client rOcHj|jyr:rrs r>rzreceive_pack..send_fnmrrAr) rrorrrrrtrr1r)r?r3rrs ` r> receive_packr ^s |szz8SZZ8 {cii3995 77  d #D%G SXXw 'E 4&%8G NN rAcXt|ddr|jt}t|zS)Nrz)rrzrr,rs r>rrxs(tXt${{+,  %%rAcPt|ddr|jt}d|zS)Nrz refs/tags/)rrzrr s r>rr~s(tXt${{+, 4 rAct|5}t|tr|}n|g}|D]}|jt |= dddy#1swYyxYw)zbDelete a branch. Args: repo: Path to the repository name: Name of the branch N)rfr^rrrrs r> branch_deletersL 4 A dD !EFED'-. ! s 4A  Acft|5}|d}t||}t|}d|jdz}|r*|jj |d|j |n6|jj||j |std|zdddy#1swYyxYw)zCreate a branch. Args: repo: Path to the repository name: Name of the new branch objectish: Target object to point new branch at (defaults to HEAD) force: Force creation of branch, even if it already exists Nrsbranch: Created from rP)rz#Branch with name %s already exists.) rfr"rrzr set_if_equalsr add_if_newrR)rrrorrrHrefname ref_messages r> branch_creaters 4 A  Ia+"4(.1A1A'1JJ  FF $ ; O66$$Wfii$MADHII ! s BB''B0ct|5}|jjtcdddS#1swYyxYw)zEList all branches. Args: repo: Path to the repository )baseN)rfrrr,rs r> branch_listrs- 4 Avv{{ 3{4 ! s 6?ct|5}|jjddd}|jts t ||t tdcdddS#1swYyxYw)zReturn the active branch in the repository, if any. Args: repo: Repository to open Returns: branch name Raises: KeyError: if the repository does not have a working tree IndexError: if HEAD is floating rrrN)rfrfollowrvr,rwr)rr active_refs r>rrsa 4 AVV]]7+A.q1 $$%89Z( (#1245 ! rct|5}t|j}|j} |j d|fd}ddd|S#t $rd}YwxYw#1swYSxYw)zReturn the active branch's remote name, if any. Args: repo: Repository to open Returns: remote name Raises: KeyError: if the repository does not have a working tree sbranchrrN)rfrrtrrr)rr branch_namerrs r>rrsr 4 A#AFF+  $ **i%=yIK !  $#K $ ! s(&A"A AA"AA""A,refs_containerrrrprune prune_tagsct|}|jDcic]-\}}|jtr|t td|/} }}|j d|j z| |||jDcic]:\}}|jdr$|jts|t dd|<} }}|j d| ||ycc}}wcc}}w)Ns refs/remotes/)rr rr) r-rrvr,r import_refsrzendswithr+) rrrrr r! stripped_refsrDvbranchesrs r>rrs&d+M$))++FQ <<+ , #! " $%q(+  ;--// $))+ +FQ << &qzz:N/O #m  "+   |T7*U! s 2C% ?C+c \t|5} t| |\} }|d|jdz}t|fd| j i| \} } | j | | |j |}| %t| j| |j|||ddd|S#1swYSxYw)aFetch objects from a remote server. Args: repo: Path to the repository remote_location: String identifying a remote server outstream: Output stream (defaults to stdout) errstream: Error stream (defaults to stderr) message: Reflog message (defaults to b"fetch: from ") depth: Depth to fetch at prune: Prune remote removed refs prune_tags: Prune reomte removed tags Returns: Dictionary with refs on the remote Ns fetch: from rPr)rr)r r!) rfrrzrrrrIrr)rrrrrrr r!rrrrrrtrs r>rrs4 4 A)8O)L&o ?%(>(>w(GGG-  $%$6$6$8 ls_remoter.$s?~&&(.vOfOOFI ??9 %%rAcxt|5}|jjdddy#1swYyxYw)zRepack loose files in a repository. Currently this only packs loose objects. Args: repo: Path to the repository N)rfrpack_loose_objectsrs r>repackr13s* 4 A ))+ ! s09c <t|5}t||jjd|D|\}}ddd|Ct j D cgc]\}} || d| dfc} }}t ||yy#1swYOxYwcc} }w)zPack objects into a file. Args: repo: Path to the repository object_ids: List of object ids to write packf: File-like object to write to idxf: File-like object to write to (can be None) c3$K|]}|df ywr:r;).0oids r> zpack_objects..Ks$GJSc4[Js)delta_window_sizeNrr)rfr'r iter_shasrrr&) r object_idspackfidxfr7rentriesdata_sumkr&s r> pack_objectsr??s 4 A.  NN $ $$GJ$G G/  !   Hfq!1adAaD/HIw1 ! Is2B  B Brcfdt|5}t||}|j|jddddy#1swYyxYw)zList contents of a tree. Args: repo: Path to the repository tree_ish: Tree id to list outstream: Output stream (defaults to stdout) recursive: Whether to recursively list files name_only: Only print item name c||jD]t\}}}|rtj||}rj|dznjt |||t j |sh sk|||vy)Nr) iteritems posixpathr)rIr statS_ISDIR) storetreeidrrrr list_tree name_onlyr recursives r>rHzls_tree..list_treedsw!&v!8!8!: T4 ~~dD1u - 8tS IJ||D!i%d+";rArMN)rfr%rr)rrrrJrIrrrHs ``` @r>ls_treerKSs@" , 4 A!W%!..$''2. ! s +A  Ac~t|ts|jt}t|ts|jt}t |5}|j }d|f}|j |r t||j|d||jdddy#1swYyxYw)znAdd a remote. Args: repo: Path to the repository name: Remote name url: Remote URL rrN) r^rqrzrrfrrr[rr)rrrrrrs r> remote_addrMts dE "{{+, c5 !jj)* 4 A LLNd# == !w' ' gvs#  ! s AB33B<c#Kt|5}|j}tj|}|D]|}|st |j ||vrt j j|r*t j j||j }|j|sy|~ dddy#1swYyxYww)zDebug gitignore files. Args: repo: Path to the repository paths: List of paths to check for no_index: Don't check index Returns: List of ignored files N) rfrrrrrtrrisabsrur)rrno_indexrrrrts r> check_ignorerQs 4 A ,66q9D 1!&&$ ?5 Hww}}T"wwtQVV4((.  ! s# C B B?/B?6 C ?CC cRt|5}| t|}nd}|r1|j|=t||j|j|<n&|jj |t ||||jj d|dddy#1swYyxYw)aUpdate HEAD to point at a new branch/commit. Note that this does not actually update the working tree. Args: repo: Path to the repository detach: Create a detached head target: Branch or committish to switch to new_branch: New branch to create Nr)rfrrr!rrr#)rrdetached new_branchrto_sets r> update_headrVs 4 A  !%j1FF v)!V477AFF6N FF # #FIa,@ A  ! FF # #GV 4 ! s BBB&ct|5}ddlm} |jtj j |j d}|j|cdddS#t$r |}Y,wxYw#1swYyxYw)zCheck canonical name and email of contact. Args: repo: Path to the repository contact: Contact name and/or email Returns: Canonical contact data r)Mailmapz.mailmapN) rfdulwich.mailmaprX from_pathrrrtr)FileNotFoundErrorlookup)rcontactrrXmailmaps r> check_mailmapr_sp 4 A+ '' QVVZ(HIG~~g& ! ! iG ! s.A=9A' A='A:7A=9A::A==Bc#Kt|5}|jD]"}|j|} |j$ dddy#t$r}||fYd}~Cd}~wwxYw#1swYyxYww)zsCheck a repository. Args: repo: A path to the repository Returns: Iterator over errors/warnings N)rfrcheck Exception)rrrrlrs r>fsckrcsi 4 A>>Cs#A  " !  Ah  ! sD A2A&A A& A2 A#AA&A##A&&A/+A2ct|5}ddlm}|j|}t t |j cdddS#1swYyxYw)z!List all stashes in a repository.rStashN)rf dulwich.stashrfr enumeraterstashesrrrfstashs r> stash_listrls< 4 A'"emmo./ ! s 9AAct|5}ddlm}|j|}|j dddy#1swYyxYw)z Push a new stash onto the stack.rreN)rfrgrfrrrjs r> stash_pushrns2 4 A'" ! (=Act|5}ddlm}|j|}|j dddy#1swYyxYw)zPop a new stash from the stack.rreN)rfrgrfrpoprjs r> stash_poprrs2 4 A'" ! rocvt|5}t|jcdddS#1swYyxYw)zList all files in an index.N)rfrrrs r>ls_filesrts& 4 Aalln% ! s/8c t|5}|j}i}|jD]\}}|j}|j |}d|vr,|j dd\}} |j } |j | d} tjtj| jdd| jjdg||<t|jdd } t| d k(rGd j||j!jjddd cdddSd } ||j!} |j#} | D]}|j$jjd}| D]d}|d }|dd}||k(s| d k(r|cccdddSd j|| | jjddd cccdddS| dz } d j| jjddd cdddS#t$rY'wxYw#1swYyxYw)zDescribe the repository version. Args: projdir: git repository root Returns: a string description of the current git revision Examples: "gabcdefh", "v0.1" or "v0.1-5-gabcdefh". rrkrNrirlc|ddS)Nrrr;)r7s r>zdescribe..!s 3q6!9rAT)rr`rzg{}z {}-{}-g{})rfr+rr get_objectrsplitrHAttributeErrordatetimer*r+rrrrformatrrdr)rrrrrvaluerc_r7r sorted_tags commit_count latest_commitrgrc commit_idtag_name tag_commits r>describersE 4 Azz|**,JC**,C,,u%Cc!ZZa(FAs 1fQi0!!4;;v/A/A#B2A#FG   )DI'&TZZ\/DdS  { q <<!&&(  5 5g >r BC7 ! < !&&( E ..w7I"q6 VAY  *#q('[ ! ^ +11$(),,33Gget_object_by_pathrEss 4 Aa,KK $& .D&q~~'A'A9dS sv ! s AA77Bct|5}|jj|jcdddS#1swYyxYw)zWrite a tree object from the index. Args: repo: Repository for which to write tree Returns: tree id for the tree that was written N)rfrrrrs r> write_treerZs2 4 A||~$$Q^^4 ! s )?A)r)F)rNNNNF)NNN)rF)rN)rNF)NNFrNNF)rr:)rNN)NF)NFF)FN)rN collectionsr contextlibrriorrr|rrpathlibrrCrrDror*typingr r r r dulwich.archiver dulwich.clientrdulwich.configrdulwich.diff_treerrrrrrdulwich.errorsr dulwich.graphrdulwich.ignorer dulwich.indexrrdulwich.object_storerdulwich.objectsrrrrr dulwich.objectspecr!r"r#r$r% dulwich.packr&r' dulwich.patchr(dulwich.protocolr)r* dulwich.refsr+r,r-r. dulwich.repor/r0dulwich.serverr1r2r3r4r5rr6r8rrdefault_bytes_out_streamstderrdefault_bytes_err_streamrrbrRr[rardrfrrrrrrrrrrrr rrmr r"r2r8r;rBrErIrGr]rirprtrxr7rzrrrrrrqrrrrrrrrrrr rrrrrrrboolrrr.r1r?rKrMrQrVr_rcrlrnrrrtrrrr;rAr>rs*$L#"  /* ( {$? @    #3::x>N*,"3::x>N*,I151 '5E6"rCuC 5$&& #2% :    ! H  &   &  W tD0-"`-` 6F06F%,/::8&)ZZ$-0JJ '14 B*-0JJ *+.** >36< jj  D jj% 1F36** G'*jj 5'    9,x%!ZZ ,$$@D4 4!)%U *;!<4 8C=# 46 &&  QJl && ;H|O8"444 F 6 4 4&  / J,56$0 $ V!VV sCx.Ve_ V  V  V<jj&    +\ & ,2, jj /B**58'$&0& BBJ*5rA