o rhss@sdZddlZddlZddlZddlZddlmZddlmm Z ddl mm Z ddlmmZddlmmZddlmmZedZddlmZz ddlmZmZWneylddlmZmZYnwGdddZGd d d e jZGd d d e j Z!d dZ"e#dej$Z%ddZ&d(ddZ'ddZ(e#dZ)ddZ*e+dkrUe,ej-dkre.dej-ddSddl/mm0Z0ddl1mm2Z2ddl3mm4Z4ddl5mm6Z6ddl7mm8Z8ddl9mm:Z:e:;dZZ?e0@dddZAe2Bej-dZCe44eCZDe!deEej-de$Id: http_server.py,v 1.12 2004/04/21 15:11:44 akuchling Exp $N)as_bytes)counter)unquote splitqueryc@seZdZdZeZdZdZddZddZ dd Z d d Z d d Z ddZ ddZddZd|ddZddZddZedZddZddZdd Zd!d"Zd#d$Zd%d&Zd}d'd(Zd)d*ZeZd+d,Zd-d.Z d/d0Z!id1d2d3d4dd5d6d7d8d9d:d;dd?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQidRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcdddedfdgdhdidjdkdldmdndodpdqdrdsdtdudvdwZ"dx#dyZ$dzd{Z%dS)~ http_requestNcGs^|\|_|_|_|_|_|_g|_dtt t d|_ g|_ t j|_d|_i|_dS)Nz Medusa/%s)ServerDate)channelrequestcommanduriversionheaderoutgoingVERSION_STRING http_datebuild_http_datetime reply_headers _http_request__reply_header_listrrequest_counter incrementrequest_number _split_uri _header_cacheselfargsr!O/var/www/html/env/lib/python3.10/site-packages/supervisor/medusa/http_server.py__init__9s    zhttp_request.__init__cCs||j|<dSNr)rkeyvaluer!r!r" __setitem__Pzhttp_request.__setitem__cCs |j|Sr$r%rr&r!r!r" __getitem__S zhttp_request.__getitem__cC ||jvSr$r%r*r!r!r" __contains__Vr,zhttp_request.__contains__cCr-r$r%r*r!r!r"has_keyYr,zhttp_request.has_keycCs8dd|jD}d||jg|d}t|S)NcSg|]}d|qS%s: %sr!).0itemr!r!r" ]z3http_request.build_reply_header..  )ritemsjoinresponse reply_coder)r header_itemsresultr!r!r"build_reply_header\szhttp_request.build_reply_headercCs|j||fdS)z$ Adds a header to the reply headers N)rappend)rnamer'r!r!r" add_headermszhttp_request.add_headercCs|jg|jdd<dS)z Clears the reply header list N)rclearrrr!r!r" clear_headersqs zhttp_request.clear_headerscCsd}||jvr|dus|j||kr|j|=d}g}|dur-||f|jvr,||fg}d}n|jD]}|d|kr?||d}q0|sW|durKd|}nd||f}td||D]}|j|qYdS)z Removes the specified header. If a value is provided, the name and value must match to remove the header. If the value is None, removes all headers with that name.rNr z%sr2zHeader '%s' not found)rrr@ LookupErrorremove)rrAr'found_itremoved_headersh search_valuer!r!r" remove_headerys2        zhttp_request.remove_headercCsT|jdd}dd|D}|jD]\}}||vr'|||f||q|S)zP Get the tuple of headers that will be used for generating reply headersNcSsg|]\}}|qSr!r!)r3nvr!r!r"r5r6z2http_request.get_reply_headers..)rrr9r@)r header_tuples header_namesrMrNr!r!r"get_reply_headerss zhttp_request.get_reply_headerscCs6|}||jg}|dd|D7}d|dS)zE Gets the reply header (including status and additional crlf)cSr0r1r!)r3rJr!r!r"r5r6z6http_request.get_reply_header_text..r7r8)rQr;r<r:)rrOheadersr!r!r"get_reply_header_textsz"http_request.get_reply_header_textz#([^;?#]*)(;[^?#]*)?(\?[^#]*)?(#.*)?cCsB|jdur|j|j}|t|jkrtd||_|jS)Nz Broken URI)r path_regexmatchrendlen ValueErrorgroups)rmr!r!r" split_uris  zhttp_request.split_uricCs8|jD]}||}|t|kr||SqdSN)rrUrVrWgroup)rhead_regr^linerZr!r!r"get_header_with_regexs  z"http_request.get_header_with_regexcCsv|}|j}||vr7|d}t|}|jD]}|d||kr0||d}|||<|Sqd||<dS||S)Nz: )lowerrrWr)rrhcrJhlr`rr!r!r" get_headers  zhttp_request.get_headercCs.|jr |j|dS|dt|ddS)Nz*Dropping %d bytes of incoming request datawarning) collectorcollect_incoming_datalog_inforWrdatar!r!r"ris  z"http_request.collect_incoming_datacCs$|jr |jdS|dddS)Nz-Unexpected end-of-record for incoming requestrg)rhfound_terminatorrjrDr!r!r"rms zhttp_request.found_terminatorcCs>t|tr t|}t|trtj|t|d}|j|dS)N) buffer_size) isinstancestrrbytes producerssimple_producerrWrr@)rthingr!r!r"push s  zhttp_request.pushcCs |j|}||_d|j||fS)Nz HTTP/%s %d %s) responsesr<r)rcodemessager!r!r"r;s zhttp_request.responsecCsR||_|j|}|j||d}t|}t||d<d|d<|||dS)N)rwrxContent-Lengthz text/htmlz Content-Type)r<rvDEFAULT_ERROR_MESSAGErrWrudone)rrwrxsr!r!r"errors    zhttp_request.errorcCs>tt|j}d}d}|jdkr$|dkr!d|vrd}n9d|d<n4d}n1|jdkrN|d kr0d}n%d|vrMd |vrA|d d ks@d}n|jrKd |d <d}n d}n|jd urUd}t|}|rbd |d<|rut t |j }t ||g}n |j d|t |j }|j tt||jd |j _|r|j d Sd S) z;finalize this transaction - send output to the http channelrz1.0z keep-aliveryr z Keep-Alive Connectionz1.1closezTransfer-EncodingchunkedN)rf CONNECTIONrrbr use_chunkedrrrsrSchunked_producercomposite_producerrinsertr push_with_producerglobbing_producerhooked_producerlogcurrent_requestclose_when_done)r connectionclose_itwrap_in_chunkingoutgoing_headeroutgoing_producerr!r!r"r{(s`         zhttp_request.donec Cst|}tjr|drtj}ntj}|dkrd}nd}| }t|d\}}t|d\}}|r6d||f}nd||f}td||S) Nrr i<z -%02d%02dz +%02d%02dz%d/%b/%Y:%H:%M:%S )rgmtimedaylightaltzonetimezonedivmodstrftime) rwhengmttznegrJremrZoffsetr!r!r"log_date_stringts  zhttp_request.log_date_stringc CsB|jjj|jjdd|jjd|t|j|j|fdS)Nrz%d - - [%s] "%s" %d %d r ) r serverloggerraddrrrr r<)rrqr!r!r"rs    zhttp_request.logdContinueezSwitching ProtocolsOKCreatedAcceptedzNon-Authoritative Informationz No Contentz Reset ContentzPartial Contenti,zMultiple Choicesi-zMoved Permanentlyi.zMoved Temporarilyi/z See Otheri0z Not Modifiedi1z Use Proxyz Bad Requesti UnauthorizedizPayment Requiredi Forbiddenz Not FoundizMethod Not AllowedizNot AcceptableizProxy Authentication RequiredizRequest Time-outiConflictiGoneizLength RequiredizPrecondition FailedizRequest Entity Too LargeizRequest-URI Too LargeizUnsupported Media TypezInternal Server ErrorizNot Implementediz Bad GatewayzService UnavailablezGateway Time-outzHTTP Version not supported)iiir7) zzError responsezzz

Error response

z

Error code %(code)d.z

Message: %(message)s.zr]cCdSr$r!)rmsglevelr!r!r"rjzhttp_request.log_infor$)r)&__name__ __module__ __qualname__r<rrrrhr#r(r+r.r/r?rBrErLrQrSrecompilerTr[rarfrirmrur;r} reply_nowr{rrrvr:rzrjr!r!r!r"r&s  (   L       !"#) rc@seZdZdZdZeZddZddZdZ dd Z d d Z d Z d dZ ddZddZddZddZddZddZddZdS) http_channeliNcCs`tj|_t|_tj||||_ ||_ | dd|_ t t|_|j|_|dS)Ns )rchannel_counterrchannel_numberrrasynchat async_chatr#rrset_terminator in_bufferintr creation_time last_usedcheck_maintenance)rrconnrr!r!r"r#s   zhttp_channel.__init__cCs&tj|dd}d||j|jfS)Nr z<%s channel#: %s requests:%s>)rr__repr__rr)rarr!r!r"rs zhttp_channel.__repr__rcCs|j|js |dSdSr$)rmaintenance_interval maintenancerDr!r!r"rs  zhttp_channel.check_maintenancecCs |dSr$) kill_zombiesrDr!r!r"rs zhttp_channel.maintenanceicCsHtt}ttjD]}|j|jkr!||j|jkr!| q dSr$) rrlistasyncore socket_mapvalues __class__rzombie_timeoutr)rnowr r!r!r"rs  zhttp_channel.kill_zombiescCs2tj||}|jjt|tt|_ |Sr$) rrsendr bytes_outrrWrrr)rrlr>r!r!r"rszhttp_channel.sendcCsTztj||}|jjt|tt|_ |WSt y)t dYdSw)NzOut of Memory!) rrrecvrbytes_inrrWrrr MemoryErrorsysexit)rrnr>r!r!r"rs zhttp_channel.recvcCs4tdd\}}|tur||tj|dS)Nr)rexc_info SystemExitrr handle_error)rtrNr!r!r"rszhttp_channel.handle_errorcGrr$r!rr!r!r"r$rzhttp_channel.logcCs&|jr |j|dS|j||_dSr$)rrirrkr!r!r"ri+sz"http_channel.collect_incoming_datac Cs|jr |jdS|j}d|_|d}|r'|ds'|dd}|r'|dr|s/|dS|d}t|\}}}t|dd}t|\}}d|vr[|rWt|d|}nt|}t ||||||} |j |j j |dur|dt|d| d dS|j jD]G} | | rz | |_| | WdS|j j t\\} } } }}}|d ||| | fdz | d WYdSYYdSq| d dS) Nrs rr %?zBad HTTP request: %sr}rz'Server Error: %s, %s: file: %s line: %srr)rrmrsplitr crack_request join_headersrrrrrrtotal_requestsrjreprr}handlersrUhandle_request exceptionsrcompact_traceback)rrlinesr rrrrpathrqueryrerJfilefunr`rrNtbinfor!r!r"rm3s^             zhttp_channel.found_terminatorcCs:|jrdSt|jr|j}t|dr| SdSdS)Nr stalled) ac_out_bufferrW producer_fifofirsthasattrr)rpr!r!r"writable_for_proxyzs    zhttp_channel.writable_for_proxy)rrrac_out_buffer_sizerrrr#rrrrrrrrrrrirmrr!r!r!r"rs$    Grc@sdeZdZdeZeZdddZddZddZ d d Z d d Z d dZ dddZ ddZddZdS) http_serverzHTTP Server (V%s)NcCsJ||_||_tj||tjtjg|_ |st t j }||||f|d|j\}}|sE|ddtt}z t|d|_Wntjyb|dd||_Ynw||_t|_t|_t|_t|_t|_|st t j }|rt |||_ nt ||_ |dt!t"#t""|j|fdS)NizComputing default hostnamergrzCannot do reverse lookupz2Medusa (V%s) started at %s Hostname: %s Port:%d )$ipportr dispatcherr# create_socketsocketAF_INET SOCK_STREAMrr file_loggerrstdoutset_reuse_addrbindlisten getsocknamerj gethostbyname gethostname gethostbyaddr server_namer} server_portr total_clientsrrrrresolving_loggerunresolving_loggerrrctime)rrrresolver logger_objecthostr!r!r"r#sP         zhttp_server.__init__cCsdSNrr!rDr!r!r"writablerzhttp_server.writablecCrr$r!rDr!r!r" handle_readrzhttp_server.handle_readcCs|jSr$) acceptingrDr!r!r"readableszhttp_server.readablecCrr$r!rDr!r!r"handle_connectrzhttp_server.handle_connectcCsn|jz|\}}Wn tjy|ddYdSty-|ddYdSw||||dS)Nz+warning: server accept() threw an exceptionrgz*warning: server accept() threw EWOULDBLOCK)rracceptrr}rj TypeError channel_class)rrrr!r!r" handle_accepts    zhttp_server.handle_acceptrcCs&|r |j|dS|jd|dSr)rr@r)rhandlerbackr!r!r"install_handlerszhttp_server.install_handlercCs|j|dSr$)rrG)rr"r!r!r"remove_handlerszhttp_server.remove_handlercsddlmfdd}ddtt|jD}|jr'|jt|j}nd}t t d|j d |j d |jd |jd |jd |d||jd||jd|jdg g|t dgS)Nr english_bytescsd|Sr\)r:)rMr&r!r" nice_bytesr)z&http_server.status..nice_bytescSsg|]}|r|qSr!r!)r3_fr!r!r"r5r6z&http_server.status..gz

%s

z!
Listening on: Host: %szPort: %dz#

  • Total Clients: %szRequests: %szRequests/Client: %.1fz
  • Total Bytes In: %szBytes Out: %sz
  • Total Exceptions: %sz!

Extension List

    z
)supervisor.medusa.utilr'map maybe_statusrrras_longfloatrrrlines_producer SERVER_IDENTrrrrrrs)rr( handler_statsratior!r&r"statuss6    zhttp_server.status)NN)r)rrrrr0rr r#rrrrr!r$r%r3r!r!r!r"rs 6  rcCst|dr |SdS)Nr3)rr3)rtr!r!r"r,s r,zConnection: (.*)cCsVg}tt|D] }||ddvr!|d||dd|d<q|||q|S)Nrz rr )rangerWr@)rRreir!r!r"rs rr cCs:|D]}||}|r|t|kr||SqdSr\)rUrVrWr^)r_rr^r`rZr!r!r"rf$s  rfcCs4|D]}||}|r|t|kr|SqdSr\)rUrVrW)r_rr`rZr!r!r"get_header_match+s  r6z%([^ ]+) ([^ ]+)(( HTTP/([0-9.]+))$|$)cCsRt|}|r'|t|kr'|dr|d}nd}|d|d|fSdS)Nr r)NNN)REQUESTrUrVrWr^)rerZrr!r!r"r4s   r__main__zusage: %s z 127.0.0.1fnordi'r]iU)rrriaz-pcCs$ztWdStyYdSwr$)rloopKeyboardInterruptr!r!r!r" profile_loopXs  r>zprofile_loop()z profile.out)r )ORCS_IDrrrrsupervisor.compatrsupervisor.medusa.asyncore_25medusa asyncore_25rsupervisor.medusa.asynchat_25 asynchat_25rsupervisor.medusa.http_datersupervisor.medusa.producersrrsupervisor.medusa.loggerrrrsupervisor.medusa.counterrurllibrr ImportError urllib.parserrrrrr,r IGNORECASErrrfr6r9rrrWargvprintsupervisor.medusa.monitormonitorsupervisor.medusa.filesysfilesys!supervisor.medusa.default_handlerdefault_handlersupervisor.medusa.ftp_server ftp_serversupervisor.medusa.chat_server chat_serversupervisor.medusa.resolverrcaching_resolverrsrrlgsecure_monitor_serverms os_filesystemfsdhrhsr$dummy_authorizerftpcsr>profilerunr<r!r!r!r"s|    /=