o U hɯ@sfdZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z ddl m Z ddl mZmZddl mZddlmZdd lmZdd lmZmZmZmZmZmZmZdd lmZdd l m!Z!m"Z"m#Z#dd l$m%Z%m&Z&m'Z'ddl(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmZmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPddlQmRZRmSZSmTZTddlUmVZVeWeXZYGdddZZGdddeZ[GdddeZZ\GdddeZZ]GdddZ^Gddde^Z_Gddde_Z`dd Zad!e%fd"d#Zbd!e%d$ecfd%d&Zdd!e%d$ecfd'd(ZeGd)d*d*ZfGd+d,d,Zge9e8dfZhGd-d.d.efZiGd/d0d0efZjGd1d2d2efZkGd3d4d4e_ZlGd5d6d6e^Zme`elemd7ZnGd8d9d9ejoZpGd:d;d;ejqZrejsfdGdd?Zxd@dAZydBdCZzdGdDdEZ{eXdFkretdSdS)HaGit smart network protocol server implementation. For more detailed implementation on the network protocol, see the Documentation/technical directory in the cgit distribution, and in particular: * Documentation/technical/protocol-capabilities.txt * Documentation/technical/pack-protocol.txt Currently supported capabilities: * include-tag * thin-pack * multi_ack_detailed * multi_ack * side-band-64k * ofs-delta * no-progress * report-status * delete-refs * shallow * symref N)IterableIterator)partial)Optionalcast)Protocol) log_utils) tar_stream)ApplyDeltaErrorChecksumMismatchGitProtocolError HookErrorNotGitRepositoryObjectFormatExceptionUnexpectedCommandError)peel_sha)CommitObjectID valid_hexsha)ObjectContainerPackedObjectContainerwrite_pack_from_container))CAPABILITIES_REFCAPABILITY_AGENTCAPABILITY_DELETE_REFSCAPABILITY_INCLUDE_TAGCAPABILITY_MULTI_ACKCAPABILITY_MULTI_ACK_DETAILEDCAPABILITY_NO_DONECAPABILITY_NO_PROGRESSCAPABILITY_OFS_DELTACAPABILITY_QUIETCAPABILITY_REPORT_STATUSCAPABILITY_SHALLOWCAPABILITY_SIDE_BAND_64KCAPABILITY_THIN_PACKCOMMAND_DEEPEN COMMAND_DONE COMMAND_HAVECOMMAND_SHALLOWCOMMAND_UNSHALLOW COMMAND_WANT MULTI_ACKMULTI_ACK_DETAILEDNAK_LINESIDE_BAND_CHANNEL_DATASIDE_BAND_CHANNEL_FATALSIDE_BAND_CHANNEL_PROGRESS SINGLE_ACK TCP_GIT_PORTZERO_SHABufferedPktLineWriterrReceivableProtocolack_typecapability_agentextract_capabilitiesextract_want_line_capabilitiesformat_ack_lineformat_ref_lineformat_shallow_lineformat_unshallow_linesymref_capabilities)PEELED_TAG_SUFFIX RefsContainerwrite_info_refs)Repoc@seZdZdZdddZdS)Backendz2A backend for the Git smart server implementation.return BackendRepocC t|j)zOpen the repository at a path. Args: path: Path to the repository Raises: NotGitRepository: no git repository was found at path Returns: Instance of BackendRepo )NotImplementedErroropen_repository)selfpathrMb/var/www/html/construction_image-detection-poc/venv/lib/python3.10/site-packages/dulwich/server.pyrJ}s zBackend.open_repositoryN)rFrG)__name__ __module__ __qualname____doc__rJrMrMrMrNrEzsrEc@sdeZdZUdZeed<eed<deeeffddZ dede efdd Z d de e fd d Zd S)rGzRepository abstraction used by the Git server. The methods required here are a subset of those provided by dulwich.repo.Repo. object_storerefsrFcCt)zRGet all the refs in the repository. Returns: dict of name -> sha rIrKrMrMrNget_refsszBackendRepo.get_refsnamecCsdS)aReturn the cached peeled value of a ref, if available. Args: name: Name of the ref to peel Returns: The peeled value of the ref. If the ref is known not point to a tag, this will be the SHA the ref refers to. If no cached information about a tag is available, this method may return None, but it should attempt to peel the tag if possible. NrM)rKrYrMrMrN get_peeled zBackendRepo.get_peeledNcCrU)aYield the objects required for a list of commits. Args: progress: is a callback to send progress messages to the client get_tagged: Function that returns a dict of pointed-to sha -> tag sha for including tags. rV)rKdetermine_wants graph_walkerprogress get_taggedrMrMrNfind_missing_objectsr[z BackendRepo.find_missing_objectsN)rOrPrQrRr__annotations__rBdictbytesrXrrZrrr`rMrMrMrNrGs  rGc@s,eZdZdZd ddZdedefddZdS) DictBackendz?Trivial backend that looks up Git repositories in a dictionary.rFNcC ||_dSra)repos)rKrgrMrMrN__init__ zDictBackend.__init__rLc CsNtd|z|j|WSty&}ztdjdit|d|d}~ww)NzOpening repository at %sz%No git repository was found at {path})rLrM)loggerdebugrgKeyErrorrformatrc)rKrLexcrMrMrNrJs  zDictBackend.open_repositoryrFN)rOrPrQrRrhstrrGrJrMrMrMrNres recs0eZdZdZejfdfdd ZddZZS) FileSystemBackendzDSimple backend looking up Git repositories in the local file system.rFNcs2ttj|tjtjdtj|_dS)N)superrhosrLabspathsepreplaceroot)rKrx __class__rMrNrhs (zFileSystemBackend.__init__cCsltd|tjtj|j|tj}tj|}tj|j}| |s2t d|d|jt |S)Nzopening repository at %szPath z not inside root ) rjrkrtrLrujoinrxrvnormcase startswithrrD)rKrLrunormcase_abspath normcase_rootrMrMrNrJs   z!FileSystemBackend.open_repositoryro) rOrPrQrRrtrvrhrJ __classcell__rMrMryrNrqsrqc@s&eZdZdZd d ddZd ddZdS) Handlerz*Smart protocol command handler base class.FrFNcCs||_||_||_dSra)backendproto stateless_rpcrKrrrrMrMrNrh zHandler.__init__cCrHra)rIhandlerWrMrMrNrrizHandler.handleFro)rOrPrQrRrhrrMrMrMrNrs rcseZdZdZddfdd ZedeefddZedeefd d Z edeefd d Z d eeddfddZ dede fddZ dddZZS) PackHandlerzProtocol handler for packs.FrFNcs t|||d|_d|_dSNF)rsrh_client_capabilities_done_receivedrryrMrNrhs zPackHandler.__init__cCrHra)rI capabilitiesclsrMrMrNrs zPackHandler.capabilitiescCstttttgSra)rr&r r!r9rrMrMrNinnocuous_capabilitiess z"PackHandler.innocuous_capabilitiescCsgS)zAReturn a list of capabilities that we require the client to have.rMrrMrMrNrequired_capabilitiessz!PackHandler.required_capabilitiescapscCst|}|||D]}|tdrq||vr%td|dq|D]}||vr8td|dq*t||_t d|dS)N=zClient asked for capability z that was not advertised.z,Client does not support required capability .zClient capabilities: %s) setrupdaterr}rr rrrjinfo)rKrallowable_capscaprMrMrNset_client_capabilitiess$     z#PackHandler.set_client_capabilitiesrcCs$|jdur td|d||jvS)Nz&Server attempted to access capability z before asking client)rr )rKrrMrMrNhas_capabilitys   zPackHandler.has_capabilitycCs d|_dS)NT)rrWrMrMrN notify_donerizPackHandler.notify_donerro)rOrPrQrRrh classmethodrrdrrrrboolrrrrMrMryrNrs rcs~eZdZdZ d dfdd ZeddZed d Zd eddfd d Z dddZ dde e e ffddZ dddZZS)UploadPackHandlerz4Protocol handler for uploading a pack to the client.FrFNcs8tj|||d||d|_d|_||_d|_dS)NrrF)rsrhrJrepo _graph_walkeradvertise_refs_processing_have_linesrKrargsrrrryrMrNrhs  zUploadPackHandler.__init__c Cstttttttttg Sra) rrr%r&r!r rr$rrrMrMrNr(szUploadPackHandler.capabilitiescCs tttfSra)r%r&r!rrMrMrNr6sz'UploadPackHandler.required_capabilitiesmessagecCdSrarM)rKrrMrMrNr^>zUploadPackHandler.progresscCsF|tr|tst|jjt|_t|jjt|_ dS|jj |_ dSra) rr%r rrwrite_sidebandr2r^r0write_pack_datawriterWrMrMrN_start_pack_send_phaseAs   z(UploadPackHandler._start_pack_send_phasecCsv|tsiS|dur|j}|dur!t|jdd}|dur!iSi}|D]\}}||}||kr8|||<q'|S)aGet a dict of peeled values of tags to their original tag shas. Args: refs: dict of refname -> sha of possible tags; defaults to all of the backend's refs. repo: optional Repo instance for getting peeled refs; defaults to the backend's repo, if available Returns: dict of peeled_sha -> tag_sha, where tag_sha is the sha of a tag whose peeled value is peeled_sha. Nr)rrrrXgetattritemsrZ)rKrTrtaggedrYsha peeled_sharMrMrNr_Ps   zUploadPackHandler.get_taggedcsd|_t||jj|jj|jjjgfdd}|jj||j|j d}t |}t dkr2dS | t |js?dS||dt |ddt|j|jj||jddS) NTcsj|fi|Sra)extendr\)rTkwargsr]wantsrMrN wants_wrapper~sz/UploadPackHandler.handle..wants_wrapper)r_rzcounting objects: z, done. ascii)r_ProtocolGraphWalkerrrSrZrT get_symrefsr`r^r_listlen handle_donerrrrencoderrrwrite_pkt_line)rKrmissing_objects object_idsrMrrNrps8  zUploadPackHandler.handleFFro)NN)rOrPrQrRrhrrrrdr^rrcrr_rrrMrMryrNrs    rcCs|sdg}n |ddd}|d}|dur||vrt|t|dkr/|tdfvr/|dfSt|dkrW|ttttfvrKt |dsGt dt |S|t krW|t |dfSt d|) acSplit a line read from the wire. Args: line: The line read from the wire. allowed: An iterable of command names that should be allowed. Command names not listed below as possible return values will be ignored. If None, any commands from the possible return values are allowed. Returns: a tuple having one of the following forms: ('want', obj_id) ('have', obj_id) ('done', None) (None, None) (for a flush-pkt) Raises: UnexpectedCommandError: if the line cannot be parsed into one of the allowed return values. N  r rrrz Invalid shaz#Received invalid line from client: )rstripsplitrrr(r,r)r*r+rr tupler'int)lineallowedfieldscommandrMrMrN_split_proto_lines*  rstorec sifdd}g}|D]}t|\}}t|tr#||jdfq t}t} |rU|\} } | |krN|| | d|fdd|| Dn| | |s,| |fS)aFind shallow commits according to a given depth. Args: store: An ObjectStore for looking up objects. heads: Iterable of head SHAs to start walking from. depth: The depth of ancestors to include. A depth of one includes only the heads themselves. Returns: A tuple of (shallow, not_shallow), sets of SHAs that should be considered shallow and unshallow according to the arguments. Note that these sets may overlap if a commit is reachable along multiple paths. cs&|d}|s|j}||<|Sra)getparents)rresult)rrrMrN get_parentss  z"_find_shallow..get_parentsr c3s|]}|fVqdSrarM).0p) new_depthrMrN sz _find_shallow..) r isinstancerappendidrpopaddr) rheadsdepthrtodohead_sha _unpeeledpeeled not_shallowshallowr cur_depthrM)rrrrN _find_shallows&      rrFc Cs||}t|g}|h}|rG|}|j|vrdSt|ts q |jD]!}||vr*q#||||} t| ts:J| j|krD| | q#|sdS)NTF) collectionsdequepopleftrrrrr commit_timer) rhaveswantearliestopendingknowncommitparent parent_objrMrMrN_want_satisfieds(       rcsXt|}|rfdd|D}tdd|D}nd}|D] }t|||s)dSqdS)a~Check whether all the current wants are satisfied by a set of haves. Args: store: Object store to retrieve objects from haves: A set of commits we know the client has. wants: A set of commits the client wants Note: Wants are specified with set_wants rather than passed in since in the current interface they are determined outside this class. csg|]}|qSrMrMrhrrMrN sz(_all_wants_satisfied..cSsg|] }t|tr|jqSrM)rrrrrMrMrNrsrFT)rminr)rrr have_objsrrrMrrN_all_wants_satisfieds rc@s&eZdZddZdeddfddZdS)AckGraphWalkerImplcCrUrarV)rKr]rMrMrNrh&rzAckGraphWalkerImpl.__init__have_refrFNcCrUrarVrKrrMrMrNack)rzAckGraphWalkerImpl.ack)rOrPrQrhrrrMrMrMrNr%src@seZdZdZdeddfddZd&ddZd'd d Zd'd d Zd dZ d'ddZ ddZ e Z ddZ d'ddZd'ddZd(d'ddZd'ddZddZd'd d!Zd"d#Zd'd$d%ZdS))ra7A graph walker that knows the git protocol. As a graph walker, this class implements ack(), next(), and reset(). It also contains some base methods for interacting with the wire and walking the commit tree. The work of determining which acks to send is passed on to the implementation instance stored in _impl. The reason for this is that we do not know at object creation time what ack level the protocol requires. A call to set_ack_type() is required to set up the implementation, before any calls to next() or ack() are made. rSrFNcCsj||_||_||_||_|j|_|j|_|j|_g|_t|_ t|_ t|_ d|_ g|_ d|_d|_dS)NFr)handlerrrZrrrr_wantsrrclient_shallow unshallow_cached_cache _cache_index_impl)rKrrSrZrrMrMrNrh;s z_ProtocolGraphWalker.__init__c Cs|}t|}|js|jsrtt|D]N\}\}}z||}Wn t y.Yqw|dkrLt d|j t|||j t|} nt||} |j| ||krf|jt|t|q|jd|jrrgS|j} | s{gSt| \} } |j | |t| tttdf} t| | \} }g}| tkr||vrtd||||| \} }| tks||| ttfvr| | ||!||jr|j"rgS|S)a-Determine the wants for a set of heads. The given heads are advertised to the client, who then specifies which refs they want using 'want' lines. This portion of the protocol is the same regardless of ack type, and in fact is used to set the ack type of the ProtocolGraphWalker. If the client has the 'shallow' capability, this method also reads and responds to the 'shallow' and 'deepen' lines from the client. These are not part of the wants per se, but they set up necessary state for walking the graph. Additionally, later code depends on this method consuming everything up to the first 'have' line. Args: heads: a dict of refname->SHA1 to advertise Returns: a list of SHA1s requested by the client rSending capabilities: %sNzClient wants invalid object )#rrvaluesrr enumeratesortedrrZrlrjrrrr=r@rrrA read_pkt_liner;r set_ack_typer8r,r*r'rr rread_proto_line set_wantsunread_proto_line_handle_shallow_requesteof)rKrrsymrefsrirefrrrrrrr want_revsrMrMrNr\Nsd                 z$_ProtocolGraphWalker.determine_wantscCs0t|tr t|d}|j|d|dS)Nrr)rrrprrunread_pkt_line)rKrvaluerMrMrNrs z&_ProtocolGraphWalker.unread_proto_linecCrrarMrWrMrMrNnakrz_ProtocolGraphWalker.nakcCs&t|dkr td||j|S)N(z invalid sha )r ValueErrorrrrrMrMrNrs  z_ProtocolGraphWalker.ackcCsd|_d|_dS)NTr)rrrWrMrMrNreset z_ProtocolGraphWalker.resetcCsN|js|js |jr dSt|jS|jd7_|jt|jkr!dS|j|jS)Nr )rrrnextrrrrWrMrMrNrs   z_ProtocolGraphWalker.nextcCst|j|S)aRead a line from the wire. Args: allowed: An iterable of command names that should be allowed. Returns: A tuple of (command, value); see _split_proto_line. Raises: UnexpectedCommandError: If an error occurred reading the line. )rrr )rKrrMrMrNr s z$_ProtocolGraphWalker.read_proto_linec Cs |ttf\}}|tkr|}n|j|q|dt|j||\}}|j|||j|j}||j@}|_ t |D] } |j t | q@t |D] } |j t| qO|j ddS)NTra)r r'r*rrrrrrrr rrr>r?) rKrrvalrrr new_shallowrrrMrMrNrs"     z,_ProtocolGraphWalker._handle_shallow_requestcCs|jdSra)rrrWrMrMrNrz _ProtocolGraphWalker.notify_donecCs|jt||dSra)rrr<)rKrr8rMrMrNsend_acksz_ProtocolGraphWalker.send_ackcCs|jtdSra)rrr/rWrMrMrNsend_naksz_ProtocolGraphWalker.send_nakcCs|j||Sra)rrrK done_required done_receivedrMrMrNrr z _ProtocolGraphWalker.handle_donecCrfra)r)rKrrMrMrNrriz_ProtocolGraphWalker.set_wantscCst|j||jS)a0Check whether all the current wants are satisfied by a set of haves. Args: haves: A set of commits we know the client has. Note: Wants are specified with set_wants rather than passed in since in the current interface they are determined outside this class. )rrr)rKrrMrMrNall_wants_satisfiedsz(_ProtocolGraphWalker.all_wants_satisfiedcCs"tttttti}||||_dSra)r-MultiAckGraphWalkerImplr.MultiAckDetailedGraphWalkerImplr3SingleAckGraphWalkerImplr)rKr8 impl_classesrMrMrNr s z!_ProtocolGraphWalker.set_ack_typeraro)r!)rOrPrQrRrrhr\rrrrr__next__r rrr"r#rrr'r rMrMrMrNr-s.   R        rc@>eZdZdZd ddZd ddZdd ZeZdefd d Z dS) r*z@Graph walker implementation that speaks the single-ack protocol.rFNcC||_g|_dSrawalker_commonrKr0rMrMrNrh rz!SingleAckGraphWalkerImpl.__init__cCs&|js|j||j|dSdSra)r1r0r"rrrMrMrNrs zSingleAckGraphWalkerImpl.ackcCs:|jt\}}|dtfvr|jdS|tkr|SdSra)r0r _GRAPH_WALKER_COMMANDSr(rr)rKrrrMrMrNrs  zSingleAckGraphWalkerImpl.nextcCs.|js|j|r|sdS|s|jsdSdS)NFT)r1r0r#r$rMrMrNrs  z$SingleAckGraphWalkerImpl.handle_donero rOrPrQrRrhrrr,rrrMrMrMrNr*s   r*c@r-) r(z?Graph walker implementation that speaks the multi-ack protocol.rFNcCs||_d|_g|_dSr)r0 _found_baser1r2rMrMrNrh7rz MultiAckGraphWalkerImpl.__init__cCs@|j||js|j|d|j|jrd|_dSdSdS)NcontinueT)r1rr6r0r"r'rrMrMrNr<s  zMultiAckGraphWalkerImpl.ackcCs^ |jt\}}|dur|jq|tkr|jdS|tkr.|jr,|j|d|Sq)NTr7) r0r r3r#r(rr)r6r"r4rMrMrNrDs  zMultiAckGraphWalkerImpl.nextcCD|r|sdS|s |js dS|jr|j|jddS|jdSNFTr1r0r"r#r$rMrMrNrW  z#MultiAckGraphWalkerImpl.handle_doneror5rMrMrMrNr(4s  r(c@r-) r)zEGraph walker implementation speaking the multi-ack-detailed protocol.rFNcCr.rar/r2rMrMrNrhrrz(MultiAckDetailedGraphWalkerImpl.__init__cCs|j||j|ddS)Nscommon)r1rr0r"rrMrMrNrvs z#MultiAckDetailedGraphWalkerImpl.ackcCsx |jt\}}|dur*|j|jr|j|jdd|j|jjr)dSn|tkr5|j dS|t kr;|Sq)NTr:sready) r0r r3r'r1r"r#rr(rr)r4rMrMrNr{s  z$MultiAckDetailedGraphWalkerImpl.nextcCr8r9r;r$rMrMrNrr<z+MultiAckDetailedGraphWalkerImpl.handle_doneror5rMrMrMrNr)os  r)cseZdZdZ d dfdd ZedeefddZd e e eeefde e eeffd d Z d e e eefddfd dZ dddZ dddZZS)ReceivePackHandlerz8Protocol handler for downloading a pack from the client.FrFNcs,tj|||d||d|_||_dS)Nrr)rsrhrJrrrryrMrNrhs zReceivePackHandler.__init__cCsttttttgSra)r#rr"r!r%rrrMrMrNrszReceivePackHandler.capabilitiesrTc Csvttttttjtjtf}g}d}|D] }|dt krd}q|rZzt |j dd}|j j |j j||dWn'|yY}z|dt|ddd fWYd}~n d}~ww|d|D]W\}} } d } z=| t krt|vrwtd z |j j| |Wn"|yd } Ynwz |j j| || Wn |yd } YnwWn tyd} Ynw|| | fqa|S)NFr Trecv)unpackokr? utf-8r@z8Attempted to delete refs without delete-refs capability.sfailed to deletesfailed to writesbad ref)IOErrorOSErrorr r AssertionErrorsocketerrorzlibrr5rrrrS add_thin_packreadrrprwrrrr rTremove_if_equals set_if_equalsrl) rKrTall_exceptionsstatuswill_send_packrr>eoldsharr ref_statusrMrMrN _apply_packsb  ,     zReceivePackHandler._apply_packrOcstrtfddj}dfdd }n jj}ddd}|D]*\}}|dkr5|d|d q$|d krB|d |d q$|d |d |d q$|d|dS)Ncjt|Srarrr0)drWrMrNsz3ReceivePackHandler._report_status..rFcsjddSra)flushrrrMrKwriterrMrNrYsz0ReceivePackHandler._report_status..flushcSrrarMrMrMrMrNrYrr?sunpack rr@sok sng rro)rr%r6rrr)rKrOrrYrYmsgrMrZrN_report_statuss     z!ReceivePackHandler._report_statusc Cs|jjdd}|s dSz||}|r|jt|WdSWdSty?}z|jtt | dWYd}~dSd}~ww)Nz post-receiverC) rhooksrexecuterrr2rr1rpr)rK client_refshookoutputerrrMrMrN_on_post_receives &z#ReceivePackHandler._on_post_receivecCsL|js|jsft|j}t|jj}|s tt fg}t d| |j t|dd|dd| t|tdt|D]}||}|j t|d|dqG|j d|jrfdSg}|j }|dursdSt|\}}|||r|||j }|s||}|||tr||dSdS)Nrrr )rrr rrXrrTrrr5rjrrrrr=r@rangerr r:rrrrTrdrr#r])rKrTrrrr`rrOrMrMrNr&sD            zReceivePackHandler.handlerro)rOrPrQrRrhrrrdrrrrTr]rdrrrMrMryrNr=s   ;  r=cs*eZdZdd fdd Zd ddZZS) UploadArchiveHandlerFrFNcs$t|||||d|_dS)Nr)rsrhrJr)rKrrrrryrMrNrhXszUploadArchiveHandler.__init__cs8fdd}g}jD]}|dd\}}|dkr"td|||dq d}d }d }jj} |t|krv||} | d krL|d7}||}n | d kr\|d7}|| d }njj | } | t t | | j } |d7}|t|ks;jdjdt| | t||dD]} || qjddS)NcrUrarV)xrWrMrNr]sz*UploadArchiveHandler.handle..writerr sargumentzunknown command rr!tarrs--prefixs--formatrsACK)mtimeprefixrm)r read_pkt_seqrr rrrrSrdecoderTrrtreerr time)rKr argumentspktkeyrrjrmrrargument commit_sharmchunkrMrWrNr\s<      zUploadArchiveHandler.handlerro)rOrPrQrhrrrMrMryrNrfWsrf)sgit-upload-packsgit-receive-packsgit-upload-archivec@s eZdZdddZdddZdS)TCPGitRequestHandlerrFNcOs$||_tjj|g|Ri|dSra)handlers socketserverStreamRequestHandlerrh)rKrvrrrMrMrNrhszTCPGitRequestHandler.__init__cCslt|jj|jj}|\}}td|||j |d}t |s(t d|||j j ||}|dS)NzHandling %s request, args=%szInvalid service )r7 connectionr>wfilerread_cmdrjrrvrcallabler serverrr)rKrrrrrrMrMrNrs  zTCPGitRequestHandler.handlero)rOrPrQrhrrMrMrMrNrus ruc@sHeZdZdZejjZddZe dfd ddZ de fdd Z d d d Z dS) TCPGitServerTcOst|jg|Ri|Sra)rurv)rKrrrMrMrN _make_handlerszTCPGitServer._make_handlerNrFcCsLtt|_|dur|j|||_td||tj |||f|j dS)Nz&Listening for TCP connections on %s:%d) rcDEFAULT_HANDLERSrvrrrjrrw TCPServerrhr)rKr listen_addrportrvrMrMrNrhs  zTCPGitServer.__init__cCstd|dS)NzHandling request from %sT)rjrrKrequestclient_addressrMrMrNverify_requests zTCPGitServer.verify_requestcCstd|dS)Nz7Exception happened during processing of request from %s)rj exceptionrrMrMrN handle_errorszTCPGitServer.handle_errorro)rOrPrQallow_reuse_addressrwr serve_foreverserverr4rhrrrrMrMrMrNr~sr~cCsddl}|}|jdddddd|jd d d ttd d ||\}}tt|dkr3|d}nd}t |}t ||j |j }| dS)z*Entry point for starting a TCP git server.rNz-lz--listen_addresslisten_address localhostzBinding IP address.)destdefaulthelpz-pz--portrzBinding TCP port.)rtyperrr r)optparse OptionParser add_optionrr4 parse_argsrdefault_logging_configrrqr~rrr)argvrparseroptionsrgitdirrr}rMrMrNmains2   rcsH|durt}dfdd }t|j|}|||dd|}|dS)aServe a single command. This is mostly useful for the implementation of commands used by e.g. git+ssh. Args: handler_cls: `Handler` class to use for the request argv: execv-style command-line arguments. Defaults to sys.argv. backend: `Backend` to use inf: File-like object to read from, defaults to standard input. outf: File-like object to write to, defaults to standard output. Returns: Exit code for use with sys.exit. 0 on success, 1 on failure. NrFcs|dSra)rrY)dataoutfrMrNsend_fns  zserve_command..send_fnr rro)rqrrKr) handler_clsrrinfrrrrrMrrN serve_commands rcCs|}t||jS)zGenerate an info refs file.)rXrCrS)rrTrMrMrNgenerate_info_refss rccs,|jjD]}dt|jjdVqdS)z Generate an index for for packs.sP rN)rSpacksrtfsencoderfilename)rpackrMrMrNgenerate_objects_info_packss rcCsF|tjdddt||tjddddt|dS)zGenerate server info for dumb file access. This generates info/refs and objects/info/packs, similar to "git update-server-info". rrTr!objectsrN)_put_named_filertrLr{rr)rrMrMrNupdate_server_infos r__main__ro)|rRrrtrGrwsysrnrIcollections.abcrr functoolsrtypingrrrTypingProtocoldulwichrarchiver errorsr r r rrrrrSrrrrrrrrrprotocolrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rTrArBrCrrD getLoggerrOrjrErGrerqrrrrrrrrrrr3r*r(r)r=rfrrxrurr~rrstdinstdoutrrrrrrMrMrMrNsz    $ +  * 9 +) Y,;A(*"