.PhIdZddlZddlZddlZddlZddlmZddlmZddl m Z m Z m Z ddl mZddlmZmZmZmZddlmZd d lmZd d lmZmZmZd d lmZmZmZm Z m!Z!ej"e#Z$d Z%dZ&dZ'dZ(gdZ)d7dZ*d7de e+de,fdZ-de,fdZ.defdZ/dZ0dZ1dZ2dZ3dZ4dZ5dZ6dZ7d Z8Gd!d"Z9Gd#d$Z:d%Z;Gd&d'Z<Gd(d)Z=Gd*d+Z>Gd,d-Z?d.Z@Gd/d0eZAGd1d2eZBGd3d4eZCejDfd8d5ZEe#d6kr eEdSdS)9zDHTTP server for dulwich that implements the git smart HTTP protocol.N)Iterator)BytesIO)CallableClassVarOptional)parse_qs) ServerHandlerWSGIRequestHandler WSGIServer make_server) log_utils)ReceivableProtocol)BaseRepoNotGitRepositoryRepo)DEFAULT_HANDLERSBackend DictBackendgenerate_info_refsgenerate_objects_info_packsz200 OKz 404 Not Foundz 403 Forbiddenz500 Internal Server Error))ExpireszFri, 01 Jan 1980 00:00:00 GMT)Pragmazno-cache) Cache-Controlz$no-cache, max-age=0, must-revalidatecx|tj}dt|fdt|dzfdgS)NDateri3)rzpublic, max-age=31536000)timedate_time_string)nows K/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/dulwich/web.pycache_forever_headersr!EsE {ikk !#&&' $S8^4455  timestampreturncgd}gd}|tj}tj|dd\}}}}}}} d|| |||||||fzS)N)MonTueWedThuFriSatSun) NJanFebMarAprMayJunJulAugSepOctNovDecz#%s, %02d %3s %4d %02d:%02d:%02d GMD)rgmtime) r#weekdaysmonthsyearmonthdayhhmmsswds r rrOsA@@HFIKK '+{9'='=bqb'A$D%b"b" 0  u     4 r"cpd|jd|dzS)aExtract the URL prefix from a regex match. Args: mat: A regex match object. Returns: The URL prefix, defined as the text before the match in the original string. Normalized to start with one leading slash and end with zero. /N)stringstartstrip)mats r url_prefixrJts0 MciikkM*0055 55r"cF|t|S)z>Get a Repo instance for the given backend and URL regex match.)open_repositoryrJ)backendrIs r get_reporNs  " ":c?? 3 33r"c#^K||dVdS |t| |d}|sn|Vn'#t$r|dVYnwxYw|dS#|wxYw)a!Send a file-like object to the request output. Args: req: The HTTPGitRequest object to send output to. f: An open file-like object to send; will be closed. content_type: The MIME type for the file. Returns: Iterator over the contents of the file, as chunks. NzFile not foundTi(zError reading file) not_foundrespondHTTP_OKreadOSErrorerrorclose)reqf content_typedatas r send_filer[s ymm,-----  G\*** 66%==D JJJ   ...ii,-------.   s)9AB!A=:B<A==BB,cL|dtjjS)NrE)replaceospathsep)urls r _url_to_pathrbs ;;sBGK ( ((r"c|t|}td|t |t |||dS)NzSending plain text file %s text/plain)nocacherbgrouploggerinfor[rNget_named_filerWrMrIr_s r get_text_filerkscKKMMM  $ $D KK,d333 S(7C00??EE| T TTr"c#0K|d|dzd}td|t ||j}||s|dVdS ||}n(#t$r| dVYdSwxYw| | td|VdS)NrasciizSending loose object %szObject not foundzError reading objectzapplication/x-git-loose-object)rfencodergrhrN object_storecontains_looserPas_legacy_objectrTrU cache_foreverrQrR)rWrMrIsharprZs r get_loose_objectrus 99Q<<#))A,, & . .w 7 7C KK)3///GS))6L  & &s + +mm./////C 1133 ii./////KK9::: JJJJJs B;;!C C c|t|}td|t |t |||dS)NSending pack file %sz application/x-git-packed-objectsrsrbrfrgrhr[rNrirjs r get_pack_filerysq  $ $D KK&---  #--d33*  r"c|t|}td|t |t |||dS)Nrwz$application/x-git-packed-objects-tocrxrjs r get_idx_filer{sq  $ $D KK&---  #--d33.  r"c#"Kt|jd}|ddgd} t||}n<#t$r/}|t |VYd}~dSd}~wwxYw|r&|js|j| dd}|| dVdS| | td|d}ttj|} ||t#|g| dd } | jd | dzd z| jd| dS| | td t*d t/|Ed{VdS)N QUERY_STRINGservicerrnUnsupported serviceapplication/x-z-advertisementT) stateless_rpcadvertise_refss # service= rdzEmulating dumb info/refs)renvirongetrNrrPstrdumbhandlersro forbiddenrerQrRrrrSrJprotowrite_pkt_linehandlergrhr) rWrMrIparamsr~repoe handler_clswriterhandlers r get_info_refsrs ck.1 2 2FjjTF++A.G%% mmCFF#####,sx,l&&w~~g'>'>EE  -- 566 6 6 6 F  G%Mg%M%M%MNN"799>599+  __        $$]W^^G5L5L%Lu%TUUU $$T***  G\*** .///%d+++++++++++sA B$BBc||tdtdt t ||S)NrdzEmulating dumb info/packs)rerQrRrgrhrrN)rWrMrIs r get_info_packsrsNKKMMMKK&&& KK+,,, &x'='= > >>r"c#K |}t|d}||dz}|dkrdS|ddVc)NTrmr)readlineintrstriprS)rXlinelengthchunks r _chunk_iterrskzz||T[[]]B''vz"" Q;; ECRCj r"ceZdZddZdZdS) ChunkReaderr$Nc<t||_g|_dSN)r_iter_buffer)selfrXs r __init__zChunkReader.__init__s ^^ $& r"cttt|j|kri |jt |jn#t$rYn/wxYwttt|j|kid|j}|d|}||dg|_|S)Nr") summaplenrappendnextr StopIterationjoin)rnrXrets r rSzChunkReader.read s#c4<(())A--  ##D$4$45555     #c4<(())A-- HHT\ " "e!""w  s,A A'&A'r$N)__name__ __module__ __qualname__rrSr"r rrs7''''     r"rc"eZdZdZddZddZdS) _LengthLimitedFilea Wrapper class to limit the length of reads from a file-like object. This is used to ensure EOF is read from the wsgi.input object once Content-Length bytes are read. This behavior is required by the WSGI spec but not implemented in wsgiref as of 2.5. r$Nc"||_||_dSr)_input _bytes_avail)rinput max_bytess r rz_LengthLimitedFile.__init__s %r"c|jdkrdS|dks ||jkr|j}|xj|zc_|j|S)Nrr"r)rrrS)rsizes r rSz_LengthLimitedFile.read!s]   ! !3 2:: 111$D T!{%%%r"r)r)rrr__doc__rrSrr"r rrsF&&&&&&&&&&r"rc#DK|d}td||j|dd}||dVdS t||n<#t$r/}| t|VYd}~dSd}~wwxYw| | td|d}|jddkr t!|jd j}n|jd j}t%||}||t'|g|d } | dS) NrEzHandling service request for %srnrrz-resultHTTP_TRANSFER_ENCODINGchunked wsgi.inputT)r)rflstriprgrhrrrorrNrrPrrerQrRrrrSrrJr) rWrMrIr~rrrrSrrs r handle_service_requestr,siikk  %%G KK17;;;,""7>>'#:#:DAAKmm122222# mmCFF#####KKMMM KK!B'!B!B!B C CE {/00I==3;|455:{<(- tU + +Ek'JsOO#4e4PPPG NNsB C*$CCc eZdZdZ ddeddfdZddZeddfded e ed e e e eeffd Z d ede fd Zd ede fdZd ede fdZddZddZdS)HTTPGitRequestzClass encapsulating the state of a single git HTTP request. Attributes: environ: the WSGI environment for the request. FNrr$cZ||_||_||_||_g|_g|_dSr)rrr_start_response_cache_headers_headers)rrstart_responserrs r rzHTTPGitRequest.__init__Ls4    -57/1 r"c>|j||fdS)zAdd a header to the response.N)rr)rnamevalues r add_headerzHTTPGitRequest.add_headerVs" dE]+++++r"statusrYheadersc|r|j||r|jd|f|j|j|||jS)z9Begin a response with the given status and other headers.z Content-Type)rextendrrr)rrrYrs r rQzHTTPGitRequest.respondZsw  * M  ) ) )  A M .,!? @ @ @ T0111##FDM:::r"messagecg|_td||td|dS)z;Begin a HTTP 404 response and return the text of a message.z Not found: %srdrn)rrgrhrQHTTP_NOT_FOUNDrorrs r rPzHTTPGitRequest.not_foundiD  OW--- ^\222~~g&&&r"cg|_td||td|dS)z;Begin a HTTP 403 response and return the text of a message.z Forbidden: %srdrn)rrgrhrQHTTP_FORBIDDENrors r rzHTTPGitRequest.forbiddenprr"cg|_td||td|dS)z;Begin a HTTP 500 response and return the text of a message.z Error: %srdrn)rrgrUrQ HTTP_ERRORrors r rUzHTTPGitRequest.errorwsD  ['*** Z...~~g&&&r"ct|_dS)z2Set the response to never be cached by the client.N)NO_CACHE_HEADERSrrs r rezHTTPGitRequest.nocache~s.r"c,t|_dS)z4Set the response to be cached forever by the client.N)r!rrs r rszHTTPGitRequest.cache_forevers355r")FNr)rrrrboolrrrRrrlisttuplerQbytesrPrrUrersrr"r rrEsFEI22-12 2222,,,, &*37 ; ; ;sm ;$uS#X/0 ; ; ; ;'''''''''''''S'U''''////666666r"rceZdZUdZdejdfedejdfedejdfedejdfedejdfedejdfe dejd fe dejd fe d ejd fe d ejd fe i Z eeeeejfeeeejgeeffed< ddeddfdZdZdS)HTTPGitApplicationzClass encapsulating the state of a git WSGI application. Attributes: backend: the Backend object backing this application GETz/HEAD$z /info/refs$z/objects/info/alternates$z/objects/info/http-alternates$z/objects/info/packs$z&/objects/([0-9a-f]{2})/([0-9a-f]{38})$z(/objects/pack/pack-([0-9a-f]{40})\.pack$z'/objects/pack/pack-([0-9a-f]{40})\.idx$POSTz/git-upload-pack$z/git-receive-pack$servicesFNrr$c||_||_tt|_||_||j|dSdSr)rMrdictrr fallback_appupdate)rrMrrrs r rzHTTPGitApplication.__init__sT  -.. (   M  * * * * * r"c|d}|d}t|||j|j}d}|jD]4\}}||kr ||} | r|j||f}n5|3|j|||S|dgS|||j| S)N PATH_INFOREQUEST_METHOD)rrz#Sorry, that method is not supported) rrrrkeyssearchrrPrM) rrrr_methodrWrsmethodspathrIs r __call__zHTTPGitApplication.__call__s{#)* ^$)dm   "m0022  NGU&  ,,t$$C -7  ? ,((.AAA &KLLMMwsDL#...r")FNN)rrrrrecompilerkrrruryr{rrrrrrPatternrrrMatchrr__annotations__rrrrr"r rrs   8$$%}   =))*M   6778-   ;<<=}   1223^  BJ? @ @    BJB C C    BJA B B   /0013I 01124J'   h #rz/ " ngrx8(5/I J L 8HL++!+ ++++/////r"rc eZdZdZddZdZdS) GunzipFilterzkWSGI middleware that unzips gzip-encoded requests before passing on to the underlying application. r$Nc||_dSrappr applications r rzGunzipFilter.__init__ r"cddl}|dddkr+|d|dd|d<|d=d|vr|d=|||S) NrHTTP_CONTENT_ENCODINGgziprrb)filenamefileobjmodeCONTENT_LENGTH)r rGzipFiler)rrrr s r rzGunzipFilter.__call__s ;;. 3 3v = =$(MMw|'<4%2%%GL !/07**,-xx000r"rrrrrrrrr"r rrsA 1 1 1 1 1r"rc eZdZdZddZdZdS)LimitedInputFilterzgWSGI middleware that limits the input length of a request to that specified in Content-Length. r$Nc||_dSrrrs r rzLimitedInputFilter.__init__rr"c|dd}|r&t|dt||d<|||S)Nrr r)rrrr)rrrcontent_lengths r rzLimitedInputFilter.__call__s\ !%5r::  $6 %s>':':%%GL !xx000r"rrrr"r rrsA 1 1 1 1 1r"rcVt|i|}tt|}|S)zpFactory function to create an instance of HTTPGitApplication, correctly wrapped with needed middleware. )rrr)argskwargsr wrapped_apps r make_wsgi_chainrs1 d -f - -C$\#%6%677K r"c*eZdZdZddZddZddZdS)ServerHandlerLoggerz@ServerHandler that uses dulwich's logger for logging exceptions.r$Nc>td|dSNz/Exception happened during processing of request)exc_inforg exceptionrr s r log_exceptionz!ServerHandlerLogger.log_exception/ =      r"c*tj|g|RdSrrgrhrformatrs r log_messagezServerHandlerLogger.log_message   F"T""""""r"c"tj|dSrrgrUrrs r log_errorzServerHandlerLogger.log_error  dr"r)rrrrr$r*r/rr"r rrsVJJ    ####r"rc2eZdZdZddZddZddZddZdS) WSGIRequestHandlerLoggerzEWSGIRequestHandler that uses dulwich's logger for logging exceptions.r$Nc>td|dSrr!r#s r r$z&WSGIRequestHandlerLogger.log_exceptionr%r"c*tj|g|RdSrr'r(s r r*z$WSGIRequestHandlerLogger.log_messager+r"c"tj|dSrr-r.s r r/z"WSGIRequestHandlerLogger.log_errorr0r"cT|j|_|sdSt |j|j||}||_| |j dS)zHandle a single HTTP request.N) rfilerraw_requestline parse_requestrwfile get_stderr get_environrequest_handlerrunserverget_app)rrs r rzWSGIRequestHandlerLogger.handles#z2244!!##  F% J J OO           #' DK''))*****r"r)rrrrr$r*r/rrr"r r2r2sjOO    #### + + + + + +r"r2ceZdZddZdS)WSGIServerLoggerr$Nc@td|dS)zHandle an error.z5Exception happened during processing of request from Nr!)rrequestclient_addresss r handle_errorzWSGIServerLogger.handle_error0s/ VN V V     r"r)rrrrFrr"r rBrB/s(      r"rBc|ddl}|}|ddddd|d d d td d ||\}}t |dkr |d}nt j}tj tdt|i}t|}t|j|j|t t"}t$d|j|j|dS)z,Entry point for starting an HTTP git server.rNz-lz--listen_addresslisten_address localhostzBinding IP address.)destdefaulthelpz-pz--portporti@zPort to listen on.)rJtyperKrLrrE) handler_class server_classz'Listening for HTTP connections on %s:%d)optparse OptionParser add_optionr parse_argsrr^getcwdr default_logging_configrrrr rHrMr2rBrgrh serve_forever) argvrQparseroptionsrgitdirrMrr?s r mainr\7sSOOO  " " $ $F    "      ! %%d++MGT 4yy1}}a $&&&3V -..G ' " "C   .% F KK1   r"__main__rr)Frr^rsysrcollections.abcriortypingrrr urllib.parserwsgiref.simple_serverr r r r dulwichr protocolrrrrrr?rrrrr getLoggerrrgrRrrrrr!floatrrrJrNr[rbrkruryr{rrrrrrrrrrrrr2rBrXr\rr"r rhse.KJ $$$$$$//////////!!!!!!((((((2222222222  X & &    ( """3""""J 6s 6 6 6 64h4444 2)))UUU" , , ,F???"&&&&&&&&.2?6?6?6?6?6?6?6?6DB/B/B/B/B/B/B/B/J11111111,11111111*     -    +++++1+++>     z   h*****Z zDFFFFFr"