o U hI@s dZddlZddlZddlZddlZddlmZddlmZddl m Z m Z m Z ddl mZddlmZmZmZmZddlmZd d lmZd d lmZmZmZd d lmZmZmZm Z m!Z!e"e#Z$d Z%dZ&dZ'dZ(gdZ)dGddZ*dGde e+de,fddZ-de,fddZ.defddZ/ddZ0ddZ1d d!Z2d"d#Z3d$d%Z4d&d'Z5d(d)Z6d*d+Z7d,d-Z8Gd.d/d/Z9Gd0d1d1Z:d2d3Z;Gd4d5d5ZGd:d;d;Z?dd?d?eZAGd@dAdAeZBGdBdCdCeZCejDfdHdDdEZEe#dFkreEdSdS)IzDHTTP 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-revalidatecCs.|durt}dt|fdt|dfdgS)NDateri3)rzpublic, max-age=31536000)timedate_time_string)nowr_/var/www/html/construction_image-detection-poc/venv/lib/python3.10/site-packages/dulwich/web.pycache_forever_headersEs  r timestampreturnc Cs^gd}gd}|durt}t|dd\}}}}}}} d|| |||||||fS)N)MonTueWedThuFriSatSun) NJanFebMarAprMayJunJulAugSepOctNovDecz#%s, %02d %3s %4d %02d:%02d:%02d GMD)rgmtime) r!weekdaysmonthsyearmonthdayhhmmsswdrrrrOs rcCsd|jd|dS)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)matrrr url_prefixts rFcCs|t|S)z>Get a Repo instance for the given backend and URL regex match.)open_repositoryrF)backendrErrrget_reposrIccs|dur |dVdSz3z|t| |d}|sn|VqWnty2|dVYnwW|dSW|dS|w)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_typedatarrr send_files(     rUcCs|dtjjS)NrA)replaceospathsep)urlrrr _url_to_pathsr[cC8|t|}td|t|t|||dS)NzSending plain text file %s text/plain)nocacher[grouploggerinforUrIget_named_filerQrHrErXrrr get_text_files  rdccs|d|dd}td|t||j}||s'|dVdSz||}Wnt y?| dVYdSw| | t d|VdS)Nr asciizSending loose object %szObject not foundzError reading objectzapplication/x-git-loose-object)r_encoder`rarI object_storecontains_looserJas_legacy_objectrNrO cache_foreverrKrL)rQrHrEsharhrTrrrget_loose_objects         rmcCr\)NSending pack file %sz application/x-git-packed-objectsrkr[r_r`rarUrIrbrcrrr get_pack_file  rpcCr\)Nrnz$application/x-git-packed-objects-tocrorcrrr get_idx_filerqrrc csBt|jd}|ddgd}zt||}Wnty3}z|t|VWYd}~dSd}~ww|r|js|j| dd}|durO| dVdS| | t d|d}ttj|} ||t|g| ddd } | jd | dd | jd| dS| | t d td t|EdHdS)N QUERY_STRINGservicerrfUnsupported serviceapplication/x-z-advertisementT) stateless_rpcadvertise_refss # service= r]zEmulating dumb info/refs)renvirongetrIrrJstrdumbhandlersrg forbiddenr^rKrLrrrMrFprotowrite_pkt_linehandler`rar) rQrHrEparamsrtrepoe handler_clswriterhandlerrrr get_info_refss@      rcCs,||tdtdtt||S)Nr]zEmulating dumb info/packs)r^rKrLr`rarrI)rQrHrErrrget_info_packss  rccsD |}t|d}||d}|dkrdS|ddVq)NTrer)readlineintrstriprM)rRlinelengthchunkrrr _chunk_itersrc@seZdZdddZddZdS) ChunkReaderr"NcCst||_g|_dSN)r_iter_buffer)selfrRrrr__init__s  zChunkReader.__init__cCs~ttt|j|kr)z |jt|jWn tyYn wttt|j|ks d|j}|d|}||dg|_|S)N) summaplenrappendnextr StopIterationjoin)rnrRretrrrrM s   zChunkReader.readr"N)__name__ __module__ __qualname__rrMrrrrrs  rc@s$eZdZdZd ddZd ddZdS) _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"NcCs||_||_dSr)_input _bytes_avail)rinput max_bytesrrrrs z_LengthLimitedFile.__init__cCs@|jdkrdS|dks||jkr|j}|j|8_|j|S)Nrrr)rrrM)rsizerrrrM!s  z_LengthLimitedFile.readr)r)rrr__doc__rrMrrrrrs rc cs|d}td||j|dd}|dur$|dVdSzt||Wnt yF}z| t |VWYd}~dSd}~ww| | td|d}|jddkrft|jd j}n|jd j}t||}||t|g|d d } | dS) NrAzHandling service request for %srfrurvz-resultHTTP_TRANSFER_ENCODINGchunked wsgi.inputT)rw)r_lstripr`rar~r{rgrrIrrJr|r^rKrLrzrrMrrFr) rQrHrErtrrrrMrrrrrhandle_service_request,s,     rc @seZdZdZ ddeddfddZddd Zeddfd ed e ed e e e eeffd dZ dede fddZdede fddZdede fddZdddZdddZdS)HTTPGitRequestzClass encapsulating the state of a single git HTTP request. Attributes: environ: the WSGI environment for the request. FNr}r"cCs(||_||_||_||_g|_g|_dSr)rzr}r~_start_response_cache_headers_headers)rrzstart_responser}r~rrrrLs  zHTTPGitRequest.__init__cCs|j||fdS)zAdd a header to the response.N)rr)rnamevaluerrr add_headerVszHTTPGitRequest.add_headerstatusrSheaderscCs@|r|j||r|jd|f|j|j|||jS)z9Begin a response with the given status and other headers.z Content-Type)rextendrrr)rrrSrrrrrKZs  zHTTPGitRequest.respondmessagecC(g|_td||td|dS)z;Begin a HTTP 404 response and return the text of a message.z Not found: %sr]rf)rr`rarKHTTP_NOT_FOUNDrgrrrrrrJi   zHTTPGitRequest.not_foundcCr)z;Begin a HTTP 403 response and return the text of a message.z Forbidden: %sr]rf)rr`rarKHTTP_FORBIDDENrgrrrrrprzHTTPGitRequest.forbiddencCr)z;Begin a HTTP 500 response and return the text of a message.z Error: %sr]rf)rr`rOrK HTTP_ERRORrgrrrrrOwrzHTTPGitRequest.errorcCs t|_dS)z2Set the response to never be cached by the client.N)NO_CACHE_HEADERSrrrrrr^~s zHTTPGitRequest.nocachecCs t|_dS)z4Set the response to be cached forever by the client.N)r rrrrrrks zHTTPGitRequest.cache_forever)FNr)rrrrboolrrrLr|rlisttuplerKbytesrJrrOr^rkrrrrrEs0   rc@seZdZUdZdedfededfededfededfededfededfe ded fe ded fe d ed fe d ed fe i Z eeeeejfeeeejgeeffed< ddeddfddZddZdS)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$servicesFNr}r"cCs8||_||_tt|_||_|dur|j|dSdSr)rHr}dictrr~ fallback_appupdate)rrHr}r~rrrrrs zHTTPGitApplication.__init__c Cs|d}|d}t|||j|jd}d}|jD]\}}||kr"q||} | r2|j||f}nq|durH|jdurB|||S|dgS|||j| S)N PATH_INFOREQUEST_METHOD)r}r~z#Sorry, that method is not supported) rr}r~rkeyssearchrrJrH) rrzrrXmethodrQrsmethodspathrErrr__call__s&     zHTTPGitApplication.__call__)FNN)rrrrrecompilerdrrrmrprrrrrrrr|PatternrrrMatchrr__annotations__rrrrrrrrsH    rc@"eZdZdZdddZddZdS) GunzipFilterzkWSGI middleware that unzips gzip-encoded requests before passing on to the underlying application. r"NcC ||_dSrappr applicationrrrr zGunzipFilter.__init__cCsPddl}|dddkr"|jd|ddd|d<|d=d|vr"|d=|||S) NrHTTP_CONTENT_ENCODINGgziprrb)filenamefileobjmodeCONTENT_LENGTH)rr{GzipFiler)rrzrrrrrrs   zGunzipFilter.__call__rrrrrrrrrrrr  rc@r) LimitedInputFilterzgWSGI middleware that limits the input length of a request to that specified in Content-Length. r"NcCrrrrrrrrrzLimitedInputFilter.__init__cCs2|dd}|rt|dt||d<|||S)Nrrr)r{rrr)rrzrcontent_lengthrrrrs   zLimitedInputFilter.__call__rrrrrrrrrcOst|i|}tt|}|S)zpFactory function to create an instance of HTTPGitApplication, correctly wrapped with needed middleware. )rrr)argskwargsr wrapped_apprrrmake_wsgi_chains rc@s.eZdZdZd ddZd ddZd dd ZdS) ServerHandlerLoggerz@ServerHandler that uses dulwich's logger for logging exceptions.r"NcCtjd|ddSNz/Exception happened during processing of request)exc_infor` exceptionrrrrr log_exception z!ServerHandlerLogger.log_exceptioncGtj|g|RdSrr`rarformatrrrr log_message zServerHandlerLogger.log_messagecGtj|dSrr`rOrrrrr log_error zServerHandlerLogger.log_errorr)rrrrrrr rrrrrs   rc@s8eZdZdZd ddZd ddZd dd Zd d d ZdS) WSGIRequestHandlerLoggerzEWSGIRequestHandler that uses dulwich's logger for logging exceptions.r"NcCrrrrrrrrrz&WSGIRequestHandlerLogger.log_exceptioncGrrrrrrrrrz$WSGIRequestHandlerLogger.log_messagecGr rr r rrrr r z"WSGIRequestHandlerLogger.log_errorcCsL|j|_|s dSt|j|j||}||_| |j dS)zHandle a single HTTP request.N) rfilerraw_requestline parse_requestrwfile get_stderr get_environrequest_handlerrunserverget_app)rrrrrrs zWSGIRequestHandlerLogger.handler)rrrrrrr rrrrrrs    rc@seZdZdddZdS)WSGIServerLoggerr"NcCstd|dS)zHandle an error.z5Exception happened during processing of request from Nr)rrequestclient_addressrrr handle_error0szWSGIServerLogger.handle_errorr)rrrrrrrrr/src Csddl}|}|jdddddd|jd d d td d d||\}}t|dkr/|d}nt}t t dt |i}t |}t |j|j|ttd}td|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.)rtyper r!r rA) handler_class server_classz'Listening for HTTP connections on %s:%d)optparse OptionParser add_optionr parse_argsrrWgetcwdr default_logging_configrrrr rr"rrr`ra serve_forever) argvr&parseroptionsrgitdirrHrrrrrmain7sJ   r1__main__rr)FrrWrsysrcollections.abcriortypingrrr urllib.parserwsgiref.simple_serverrr r r dulwichr protocolrrrrrrrrrrr getLoggerrr`rLrrrrr floatr|rrFrIrUr[rdrmrprrrrrrrrrrrrrrrrr-r1rrrrs`        %   # BE  -