U 楡cV@sdZddlmZmZddlZddlmZmZmZddl Z ddl m Z ddl m Z ddlZddlZddlmZmZmZddlmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!dd l"m#Z#m$Z$m%Z%erfe?ddd Z@e=e ed!ed"ed#ed$fd%d&d'ZAe>e?d(d)d*ZBeCe>d+d,d-ZDe>e>d.d/d0ZEGd1d2d2eZFeFdd3ZGeCeCed4d5d6ZHe e>efee?e?fd7d8d9ZIe Jd:ZKe Jd;ZLe>eee?e?fd<d=d>ZMGd?d@d@eNZOe7GdAdde6ZPe7GdBdCdCe6ZQGdDddeePZRdS)Ez$Module for general utility functions)ABCabstractmethodN) IterableList IterableObjActor)deque)digits)datetime timedeltatzinfo)AnyCallableDequeIteratorGeneric NamedTupleoverloadSequence TYPE_CHECKINGTupleTypeTypeVarUnioncast)Has_id_attributeLiteral_T)BytesIOStringIO)Commit)Blob) TagObject)TreeTraversedTreeTup)Popen) Submodule)Protocolruntime_checkablecCs|SN)fr*r*4/tmp/pip-unpacked-wheel-_pbxsds5/git/objects/util.pyr(7sr(c@s.eZdZUeed<eded<eded<dS) TraverseNTdepth Traversabler!itemr0NsrcN)__name__ __module__ __qualname__int__annotations__rr*r*r*r,r-;s  r-T_TIobjTraversableIterableObj)boundr2r0r$) get_object_type_by_name parse_dateparse_actor_and_dateProcessStreamAdapterr0altz_to_utctz_str utctz_to_altz verify_utctzrtzoffsetutc)modestrreturncCsLd}tt|ddD].\}}ttttf|}|t||d>7}q|S)a_ :param modestr: string like 755 or 644 or 100644 - only the last 6 chars will be used :return: String identifying a mode compatible to the mode methods ids of the stat module regarding the rwx permissions for user, group and other, special flags and file system flags, i.e. whether it is a symlink for example.rN) enumeratereversedrrstrr7)rEmode iterationcharr*r*r,mode_str_to_int]s rOr r"r#r!)object_type_namerFcCs||dkrddlm}|jS|dkr4ddlm}|jS|dkrNddlm}|jS|dkrhdd lm}|jSt d | d S) z :return: type suitable to handle the given object type name. Use the type to create new instances. :param object_type_name: Member of TYPES :raise ValueError: In case object_type_name is unknownscommitr)commitstag)tagsblob)blobstree)treez%Cannot handle unknown object type: %sN) rQr rRr"rSr!rTr# ValueErrordecode)rPrQrRrSrTr*r*r,r<ms     r<)utctzrFcCsdtt|ddS)a we convert utctz to the timezone in seconds, it is the format time.altzone returns. Git stores it as UTC timezone which has the opposite sign as well, which explains the -1 * ( that was made explicit here ) :param utctz: git utc timezone string, i.e. +0200d)r7float)rXr*r*r,rAsrA)altzrFcCsPdtt|dd}tt|}ddt||}|dkrDdpFd}||S) z_As above, but inverses the operation, returning a string that can be used in commit objectsrYr[rZ0r-+)r7r\rKabslen)r]ZutciZutcsprefixr*r*r,r@s  r@)offsetrFcCsdtd|}t|dkr||ddkr,||dtks\|dtks\|dtks\|dtkr`||S) z=:raise ValueError: if offset is incorrect :return: offsetz"Invalid timezone offset format: %srz+-rrHr_)rVrcr)reZfmt_excr*r*r,rBs   0rBc@seZdZdeedefddddZeedeeeffdddZ ee dfe dd d Z ee dfedd d Z ee dfe dd dZdS)rCN)secs_west_of_utcnamerFcCst| d|_|pd|_dS)N)secondsZfixed)r _offset_name)selfrhrir*r*r,__init__sztzoffset.__init__)rFcCst|j |jffSr))rCrk total_secondsrlrmr*r*r, __reduce__sztzoffset.__reduce__)dtrFcCs|jSr))rkrmrrr*r*r, utcoffsetsztzoffset.utcoffsetcCs|jSr))rlrsr*r*r,tznamesztzoffset.tznamecCstSr))ZEROrsr*r*r,dstsz tzoffset.dst)N)r4r5r6r\rrKrnrrrqr r rtrurwr*r*r*r,rCs "rCUTC) timestamp tz_offsetrFcCs>t|t}z|t|}|WStk r8|YSXdS)zAConverts a timestamp + tz_offset into an aware datetime instance.N)r fromtimestamprD astimezonerCrV)ryrzZutc_dtZlocal_dtr*r*r,from_timestamps  r}) string_daterFc CsJt|trP|jrBtt|}t| }t|t  |fSt d|z| ddkr| ddkr|\}}|dr|dd}t|}|tt|fWSd}|d d krt|d d}|dd }t|}g}d}d |kr|d | d}nF|d|d|d|d| d}|dkrN| d}|dks\t||dd}|d|} t|d} |D]r} zNt| | } t| j| j| j| j| j| j| j| j| j f } t| |fWWSt k rYqYnXqt dWn>t!k rD}zt d|dt"||W5d}~XYnXdS)a Parse the given date as one of the following * aware datetime instance * Git internal format: timestamp offset * RFC 2822: Thu, 07 Apr 2005 22:13:13 +0200. * ISO 8601 2005-04-07T22:13:13 The T can be a space as well :return: Tuple(int(timestamp_UTC), int(offset)), both in seconds since epoch :raise ValueError: If the format could not be understood :note: Date can also be YYYY.MM.DD, MM/DD/YYYY and DD.MM.YYYY. z,string_date datetime object without tzinfo,  r:rY@Nz+0000z-+rG,z %a, %d %b %Yz%Y-%m-%dz%Y.%m.%dz%m/%d/%Yz%d.%m.%YTz%H:%M:%Szno format matchedz!Unsupported date format or type: z, type=)# isinstancer r rr rtr7ror|rDryrVcountrfindsplit startswithrArBappendAssertionErrortimestrptimecalendartimegmtm_yeartm_montm_mdaytm_hourtm_mintm_sectm_wdaytm_ydaytm_isdst Exceptiontype)r~rtreryZ offset_strZ timestamp_intZ date_formatsZsplitterZ time_partZ date_partZtstructfmtZdtstructZutctimeer*r*r,r=sn                     r=z^.+? (.*) (\d+) ([+-]\d+).*$z ^.+? (.*)$)linerFcCs`d\}}}t|}|r(|\}}}n t|}|r@|dn|pFd}t|t|t|fS)zParse out the actor (author or committer) info from a line like:: author Tom Preston-Werner 1191999972 -0700 :return: [Actor, int_seconds_since_epoch, int_timezone_offset])rUr^r^rrU) _re_actor_epochsearchgroups_re_only_actorgrouprZ _from_stringr7rA)rZactorepochremr*r*r,r>/s   r>c@s6eZdZdZdZdeddddZeedd d ZdS) r?a Class wireing all calls to the contained Process instance. Use this type to hide the underlying process to provide access only to a specified stream. The process is usually wrapped into an AutoInterrupt class to kill it if the instance goes out of scope.)_proc_streamr%N)process stream_namerFcCs||_t|||_dSr))rgetattrr)rmrrr*r*r,rnOszProcessStreamAdapter.__init__)attrrFcCs t|j|Sr))rr)rmrr*r*r, __getattr__Ssz ProcessStreamAdapter.__getattr__) r4r5r6__doc__ __slots__rKrnr rr*r*r*r,r?Esr?c @seZdZdZdZeeeeddddZ eeeedddZ de eee e d d d d ZeeeedddZddddddddd fee ddefege fee ddefege fee e ee e ee deefdddZdS)r0zSimple interface to perform depth-first or breadth-first traversals into one direction. Subclasses only need to implement one function. Instances of the Subclass must be hashable Defined subclasses = [Commit, Tree, SubModule] r*)r1rFcCs tddS)a@ Returns: Tuple of items connected to the given item. Must be implemented in subclass class Commit:: (cls, Commit) -> Tuple[Commit, ...] class Submodule:: (cls, Submodule) -> Iterablelist[Submodule] class Tree:: (cls, Tree) -> Tuple[Tree, ...] To be implemented in subclassNNotImplementedError)clsr1r*r*r,_get_intermediate_itemsds z#Traversable._get_intermediate_items)argskwargsrFcOstjdtdd|j||S)rzlist_traverse() method should only be called from subclasses.Calling from Traversable abstract class will raise NotImplementedError in 3.1.20Builtin sublclasses are 'Submodule', 'Tree' and 'Commitrg stacklevel)warningswarnDeprecationWarning_list_traversermrrr*r*r, list_traversers zTraversable.list_traverseF)r r&r#r!)as_edgerrrFcOsXt|tr|j}nd}|s@t|}||j|d|i||St|j||}|SdS)a :return: IterableList with the results of the traversal as produced by traverse() Commit -> IterableList['Commit'] Submodule -> IterableList['Submodule'] Tree -> IterableList[Union['Submodule', 'Tree', 'Blob']] rUrN)rrZ_id_attribute_rextendtraverse)rmrrridoutZout_listr*r*r,r~s zTraversable._list_traversecOstjdtdd|j||S)rztraverse() method should only be called from subclasses.Calling from Traversable abstract class will raise NotImplementedError in 3.1.20Builtin sublclasses are 'Submodule', 'Tree' and 'Commitrgr)rrr _traverserr*r*r,rs zTraversable.traversecCsdSNTr*idr*r*r,zTraversable.cCsdSNFr*rr*r*r,rrrYTrr!r/) predicatepruner. branch_first visit_once ignore_selfrrFc#st}t} | tddttdttddfdd } | r| \} } |r^|kr^q>|rl||rz| f} n} || | rq>|ok}|s|| | r| V| d}|dkr||krq>| | ||q>dS) aF:return: iterator yielding of items found when traversing self :param predicate: f(i,d) returns False if item i at depth d should not be included in the result :param prune: f(i,d) return True if the search should stop at item i at depth d. Item i will not be returned. :param depth: define at which level the iteration should not go deeper if -1, there is no limit if 0, you would effectively only get self, the root of the iteration i.e. if 1, you would only get the first level of predecessors/successors :param branch_first: if True, items will be returned branch first, otherwise depth first :param visit_once: if True, items will only be returned once, although they might be encountered several times. Loops are prevented that way. :param ignore_self: if True, self will be ignored and automatically pruned from the result. Otherwise it will be the first item to be returned. If as_edge is True, the source of the first edge is None :param as_edge: if True, return a pair of items, first being the source, second the destination, i.e. tuple(src, dest) with the edge spanning from source to destinationrNr0)stacksrc_itemrr.rFcsfsdS|r2|fddDn0fddttdddD}||dS)Nc3s|]}t|VqdSr)r-.0r)r.rr*r, sz.addToStack..c3s|]}t|VqdSr)rrr.lstrr*r,rsrrY)r extendleftrangercr)rrrr.Zreviterr1rmrr, addToStacks &z)Traversable._traverse..addToStackrrY) setrrr-rboolr7popadd)rmrrr.rrrrvisitedrrrr3rvalZ skipStartItemZndr*rr,rs63     zTraversable._traverseN)F)r4r5r6rr classmethodrr rrrrrrrrr TraversedTupr7rrr*r*r*r,r0WsB    c@s4eZdZdZdZdddddZdddddZd S) SerializablezPDefines methods to serialize and deserialize objects from and into a data streamr*r)streamrFcCs tddS)zSerialize the data of this object into the given data stream :note: a serialized object would ``_deserialize`` into the same object :param stream: a file-like object :return: selfrNrrmrr*r*r, _serializeszSerializable._serializecCs tddS)zDeserialize all information regarding this object from the stream :param stream: a file-like object :return: selfrNrrr*r*r, _deserializeszSerializable._deserializeN)r4r5r6rrrrr*r*r*r,rsrcs6eZdZdZeeedfefZeeee edfdd Z e ee edddZ e eeeeeeedfeffegefeeeeeedfeffegefeeeed ed e ed d dZ e eeeeeeedfeffegefeeeeeedfeffegefeeeed ed e eeedfefd d dZ e eeeeefegefeeeefegefeeeed ed e eeefd ddZ dddddd d dd feeeeefegefeeeefegefeeeeeee ee eeefe efd fdd Z ZS)r:r*N)rmrrrFcstt|j||Sr))superr:rr __class__r*r,r*sz$TraversableIterableObj.list_traverse)rmrFcCsdSr)r*rpr*r*r,r-szTraversableIterableObj.traverseTF) rmrrr.rrrrrFcCsdSr)r*rmrrr.rrrrr*r*r,r1s cCsdSr)r*rr*r*r,r>s cCsdSr)r*rr*r*r,rKs cCsdSrr*rr*r*r,rZrzTraversableIterableObj.cCsdSrr*rr*r*r,r[rrYrc sBtttttttdtftfftt||||||||S)z3For documentation, see util.Traversable._traverse()N)rrrr9rrr:rrrr*r,rXs" )r4r5r6rrrr9Z TIobj_tupler rrrrrr r7rr __classcell__r*r*rr,r:%sp&& &&  )SrabcrrrZgit.utilrrrre collectionsrstringrrrr r r typingr r rrrrrrrrrrrrZ git.typesrrriorrrQr rSr!rRr"rTr#r$ subprocessr%Zsubmodule.baser&r'r(r-r9r__all__rvbytesrKr7rOr<rAr\r@rBrCrDr}r=compilerrr>objectr?r0rr:r*r*r*r,sh  @          a  7