B %dW@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*ZBe?e>d+d,d-ZCe>e>d.d/d0ZDGd1d2d2eZEeEdd3ZFeGeGed4d5d6ZHe 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|S)N)fr)r)]/work/yifan.wang/ringdown/master-ringdown-env/lib/python3.7/site-packages/git/objects/util.pyr(7sr(c@s.eZdZUeed<eded<eded<dS) TraverseNTdepth) Traversabler!item)r.NsrcN)__name__ __module__ __qualname__int__annotations__rr)r)r)r+r,;s  r,T_TIobjTraversableIterableObj)bound)r.Nr.r$) get_object_type_by_name parse_dateparse_actor_and_dateProcessStreamAdapterr.altz_to_utctz_str utctz_to_altz verify_utctzrtzoffsetutc)modestrreturncCsPd}xFtt|ddD].\}}ttttf|}|t||d>7}qW|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.riN) enumeratereversedrrstrr4)rBmode iterationcharr)r)r+mode_str_to_int]s rKr r"r#r!)object_type_namerCcCs||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) rMr rNr"rOr!rPr# ValueErrordecode)rLrMrNrOrPr)r)r+r9ms     r9)utctzrCcCs:t|}t|ddt|dd}|dkr4|S| S)zConvert a git timezone offset into a timezone offset west of UTC in seconds (compatible with time.altzone). :param utctz: git utc timezone string, i.e. +0200 di<r)r4abs)rTZ int_utctzsecondsr)r)r+r>s r>)altzrCcCs:t|d}t|dd}|dkr(dnd}d|||S)zConvert a timezone offset west of UTC in seconds into a git timezone offset string :param altz: timezone offset in seconds west of UTC irV-+z {}{:02}{:02})rWformat)rYhoursminutessignr)r)r+r=s r=)offsetrCcCsdtd|}t|dkr||ddkr,||dtks\|dtks\|dtks\|dtkr`||S) z=:raise ValueError: if offset is incorrect :return: offsetz"Invalid timezone offset format: %srz+-rrD)rRlenr)r`Zfmt_excr)r)r+r?s   0r?c@seZdZdeedefddddZeedeeeffdddZ ee dfe dd d Z ee dfedd d Z ee dfe dd dZdS)r@N)secs_west_of_utcnamerCcCst| d|_|pd|_dS)N)rXZfixed)r _offset_name)selfrerfr)r)r+__init__sztzoffset.__init__)rCcCst|j |jffS)N)r@rg total_secondsrh)rir)r)r+ __reduce__sztzoffset.__reduce__)dtrCcCs|jS)N)rg)rirmr)r)r+ utcoffsetsztzoffset.utcoffsetcCs|jS)N)rh)rirmr)r)r+tznamesztzoffset.tznamecCstS)N)ZERO)rirmr)r)r+dstsz tzoffset.dst)N)r1r2r3floatrrGrjrrrlr r rnrorqr)r)r)r+r@s "r@UTC) timestamp tz_offsetrCcCs8t|t}y|t|}|Stk r2|SXdS)zAConverts a timestamp + tz_offset into an aware datetime instance.N)r fromtimestamprA astimezoner@rR)rtruZutc_dtZlocal_dtr)r)r+from_timestamps  rx) string_daterCc CsBt|trP|jrBtt|}t| }t|t  |fSt d|y| ddkr| ddkr|\}}|dr|dd}t|}|tt|fSd}|d d krt|d d}|dd }t|}g}d}d |kr|d | d}nF|d|d|d|d| d}|dkrL| d}|dksZt||dd}|d|} t|d} xp|D]h} yFt| | } t| j| j| j| j| j| j| j| j| j f } t| |fSt k rwYnXqWt dWn>t!k r<}zt d|dt"||Wdd}~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:@Nz+0000z-+i,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 rnr4rkrwrArtrRcountrfindsplit startswithr>r?appendAssertionErrortimestrptimecalendartimegmtm_yeartm_montm_mdaytm_hourtm_mintm_sectm_wdaytm_ydaytm_isdst Exceptiontype)ryrnr`rtZ offset_strZ timestamp_intZ date_formatsZsplitterZ time_partZ date_partZtstructfmtZdtstructZutctimeer)r)r+r:sj                       r:z^.+? (.*) (\d+) ([+-]\d+).*$z ^.+? (.*)$)linerCcCs`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])rQ0rrrQ) _re_actor_epochsearchgroups_re_only_actorgrouprZ _from_stringr4r>)rZactorepochr`mr)r)r+r;3s   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_namerCcCs||_t|||_dS)N)rgetattrr)rirrr)r)r+rjSszProcessStreamAdapter.__init__)attrrCcCs t|j|S)N)rr)rirr)r)r+ __getattr__Wsz ProcessStreamAdapter.__getattr__) r1r2r3__doc__ __slots__rGrjr rr)r)r)r+r<Isr<c @seZdZdZdZeeeeddddZ eeeedddZ de eee e d d d d ZeeeedddZddddddddd fee ddefege fee ddefege fee e ee e ee deefdddZdS)r.zSimple 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))r/rCcCs 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, ...] zTo be implemented in subclassN)NotImplementedError)clsr/r)r)r+_get_intermediate_itemshs z#Traversable._get_intermediate_items)argskwargsrCcOstjdtdd|j||S)rzzlist_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 'Commitrb) stacklevel)warningswarnDeprecationWarning_list_traverse)rirrr)r)r+ list_traversevs zTraversable.list_traverseF)r r&r#r!)as_edgerrrCcOsXt|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']] rQrN)rrZ_id_attribute_rextendtraverse)rirrridoutZout_listr)r)r+rs zTraversable._list_traversecOstjdtdd|j||S)rzztraverse() method should only be called from subclasses.Calling from Traversable abstract class will raise NotImplementedError in 3.1.20Builtin sublclasses are 'Submodule', 'Tree' and 'Commitrb)r)rrr _traverse)rirrr)r)r+rs zTraversable.traversecCsdS)NTr))idr)r)r+zTraversable.cCsdS)NFr))rrr)r)r+rrr|Trr!)r.r!) predicatepruner- branch_first visit_once ignore_selfrrCc#st}t} | tddttdttddfdd } x| r| \} } |r`|kr`q@|rn||r|| f} n} || | rq@|ok}|s|| | r| V| d}|dkr||krq@| | ||q@WdS) 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 destinationrNr.)stacksrc_itemrr-rCcsfsdS|r2|fddDn0fddttdddD}||dS)Nc3s|]}t|VqdS)N)r,).0r)r-rr)r+ sz.addToStack..c3s|]}t|VqdS)N)r,)rr)r-lstrr)r+rsrr|)r extendleftrangerdr)rrrr-Zreviter)r/ri)r-rrr+ addToStacks &z)Traversable._traverse..addToStackrr|) setrrr,rboolr4popadd)rirrr-rrrrvisitedrrrr0rvalZ skipStartItemndr))r/rir+rs43      zTraversable._traverseN)F)r1r2r3rr classmethodrr rrrrrrrrr TraversedTupr4rrr)r)r)r+r.[s&    >c@s4eZdZdZdZdddddZdddddZd S) SerializablezPDefines methods to serialize and deserialize objects from and into a data streamr)r)streamrCcCs 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: selfzTo be implemented in subclassN)r)rirr)r)r+ _serializeszSerializable._serializecCs tddS)zDeserialize all information regarding this object from the stream :param stream: a file-like object :return: selfzTo be implemented in subclassN)r)rirr)r)r+ _deserialize"szSerializable._deserializeN)r1r2r3rrrrr)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)r7r)N)rirrrCcstt|j||S)N)superr7r)rirr) __class__r)r+r.sz$TraversableIterableObj.list_traverse)rirCcCsdS)Nr))rir)r)r+r1szTraversableIterableObj.traverseTF) rirrr-rrrrrCcCsdS)Nr))rirrr-rrrrr)r)r+r5s cCsdS)Nr))rirrr-rrrrr)r)r+rBs cCsdS)Nr))rirrr-rrrrr)r)r+rOs cCsdS)NTr))rrr)r)r+r^rzTraversableIterableObj.cCsdS)NFr))rrr)r)r+r_rr|rc sBtttttttdtftfftt||||||||S)z3For documentation, see util.Traversable._traverse()N)rrrr6rrr7r)rirrr-rrrr)rr)r+r\s" )r1r2r3rrrr6Z TIobj_tupler rrrrrr r4rr __classcell__r)r))rr+r7)sV&&&&$<)SrabcrrrZgit.utilrrrre collectionsrstringrrrr r r typingr r rrrrrrrrrrrrZ git.typesrrriorrrMr rOr!rNr"rPr#r$ subprocessr%Zsubmodule.baser&r'r(r,r6r__all__rpbytesrGr4rKr9r>r=r?r@rArrrxr:compilerrr;objectr<r.rr7r)r)r)r+sb  @       *    a   7