vgssdZddlZddlZddlZddlZddlmZddlmcm Z ddl mcm Z ddlmcmZddlmcmZddlmcmZedZddlmZ ddlmZmZn#e$r ddlmZmZYnwxYwGddZGd d e jZGd d e j Z!d Z"ej#dej$Z%dZ&d"dZ'dZ(ej#dZ)dZ*e+dkrpe,ej-dkre.dej-dzdSddl/mcm0Z0ddl1mcm2Z2ddl3mcm4Z4ddl5mcm6Z6ddl7mcm8Z8ddl9mcm:Z:e:j;dZ<ej=ej>Z?e0j@dddZAe2jBej-dZCe4j4eCZDe!deEej-de$Id: http_server.py,v 1.12 2004/04/21 15:11:44 akuchling Exp $N)as_bytes)counter)unquote splitqueryceZdZdZeZdZdZdZdZ dZ dZ dZ d Z d Zd Zded Zd ZdZejdZdZdZdZdZdZdZdfdZdZeZdZdZ dZ!iddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;idd?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`daZ"db#dcZ$ddZ%dS)g http_requestNc<|\|_|_|_|_|_|_g|_dtztj tj d|_ g|_ tj|_d|_i|_dS)Nz Medusa/%s)ServerDate)channelrequestcommanduriversionheaderoutgoingVERSION_STRING http_datebuild_http_datetime reply_headers _http_request__reply_header_listr request_counter incrementrequest_number _split_uri _header_cacheselfargss Z/var/www/pixelcanvas.ch/venv/lib/python3.11/site-packages/supervisor/medusa/http_server.py__init__zhttp_request.__init__9s t| tx  "-">"+";TY[["I"I$& *:DDFFc||j|<dSNr)r"keyvalues r$ __setitem__zhttp_request.__setitem__Ps"'3r&c|j|Sr(r)r"r*s r$ __getitem__zhttp_request.__getitem__Ss!#&&r&c||jvSr(r)r.s r$ __contains__zhttp_request.__contains__Vd(((r&c||jvSr(r)r.s r$has_keyzhttp_request.has_keyYr2r&cd|jD}d||jg|zdz}t |S)Ncg|]}d|zSz%s: %s).0items r$ z3http_request.build_reply_header..]sOOOD4OOOr&  )ritemsjoinresponse reply_coder)r" header_itemsresults r$build_reply_headerzhttp_request.build_reply_header\sgOOD4F4L4L4N4NOOO  ]]4? + + ,| ;==?IJr&c>|j||fdS)z$ Adds a header to the reply headers N)rappend)r"namer+s r$ add_headerzhttp_request.add_headerms#  ''u 66666r&cP|jg|jdd<dS)z Clears the reply header list N)rclearrr"s r$ clear_headerszhttp_request.clear_headersqs0   """&( ###r&cbd}||jvr||j||kr |j|=d}g}|||f|jvr||fg}d}n-|jD]%}|d|kr||d}&|s!|d|z}n|d|}td|z|D]}|j|dS)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%s: zHeader '%s' not found)rrrF LookupErrorremove)r"rGr+found_itremoved_headersh search_values r$ remove_headerzhttp_request.remove_headerys D& & & ]   % . ."4(H}e} 888$(%=/- ! !Q44<<#**1--- H F}#d{ +/447 5 DEE E  / /A  $ + +A . . . . / /r&c|jdd}d|D}|jD]5\}}||vr,|||f||6|S)zP Get the tuple of headers that will be used for generating reply headersNcg|]\}}|Sr8r8)r9nvs r$r;z2http_request.get_reply_headers..s333ca333r&)rrr>rF)r" header_tuples header_namesrXrYs r$get_reply_headerszhttp_request.get_reply_headerss03 43]333 %++-- ' 'CAa $$$$aU+++##A&&&r&c|}||jg}|d|Dz }d|dzS)zE Gets the reply header (including status and additional crlf)cg|]}d|zSr7r8)r9rSs r$r;z6http_request.get_reply_header_text..s888QHqL888r&r<r=)r\r@rAr?)r"rZheaderss r$get_reply_header_textz"http_request.get_reply_header_texts[..00 ==11288-8888{{7##j00r&z#([^;?#]*)(;[^?#]*)?(\?[^#]*)?(#.*)?c|jq|j|j}|t |jkrt d||_|jS)Nz Broken URI)r path_regexmatchrendlen ValueErrorgroups)r"ms r$ split_urizhttp_request.split_urisa ? "%%tx00Auuww#dh--'' ..."#((**r&c|jD]S}||}|t|kr||cSTdSN)rrcrdregroup)r"head_regrmlinerhs r$get_header_with_regexz"http_request.get_header_with_regexs]K ' 'D%%Auuww#d))##ww&&&$rr&c|}|j}||vrX|dz}t|}|jD]5}|d||kr||d}|||<|cS6d||<dS||S)NrN)lowerr rer)r"rhcrShlrors r$ get_headerzhttp_request.get_headers      AQB   9??$$))RSS A!"BvJHHH*BvJ4f: r&c|jr|j|dS|dt|zddS)Nz*Dropping %d bytes of incoming request datawarning) collectorcollect_incoming_datalog_inforer"datas r$rzz"http_request.collect_incoming_datasY >  N 0 0$ 7 7 7 7 7 MM@3t99L     r&cv|jr|jdS|dddS)Nz-Unexpected end-of-record for incoming requestrx)ryfound_terminatorr{rKs r$rzhttp_request.found_terminatorsL >  N + + - - - - - MMC     r&ct|trt|}t|tr#t j|t |}|j|dS)N) buffer_size) isinstancestrrbytes producerssimple_producerrerrF)r"things r$pushzhttp_request.push sk eS ! ! $UOOE eU # # M-eULLLE U#####r&cD|j|}||_d|j||fzS)Nz HTTP/%s %d %s) responsesrAr)r"codemessages r$r@zhttp_request.responses).&$,g!>>>r&c||_|j|}|j||dz}t|}t ||d<d|d<|||dS)N)rrContent-Lengthz text/htmlz Content-Type)rArDEFAULT_ERROR_MESSAGErrerdone)r"rrss r$errorzhttp_request.errorsz.&  &"**  QKK!$Q *^ !  r&cXtt|j}d}d}|jdkr|dkr d|vrd}nOd|d<nId}nF|jdkr2|d krd}n2d|vr$d |vr|d d ksd}n|jrd |d <d}n d}n |jd}t j|}|rd |d<|rBt j t j |j }t j ||g}n4|j d|t j |j }|j t jt j||jd |j _|r|j d Sd S) z;finalize this transaction - send output to the http channelrz1.0z keep-aliverr z Keep-Alive Connectionz1.1closezTransfer-EncodingchunkedN)rv CONNECTIONrrrr use_chunkedrrr`chunked_producercomposite_producerrinsertrpush_with_producerglobbing_producerhooked_producerlogcurrent_requestclose_when_done)r" connectionclose_itwrap_in_chunkingoutgoing_headeroutgoing_producers r$rzhttp_request.done(s DK88>>@@  <5 \))#4// HH)5D&& \U " "W$$!--&$.. 34 AA#$%!09D,-'($$ H \ ! H#3D4N4N4P4PQQ  )!(D   M ) :0$-@@!! !* < "34!!   M O 4 4 4 ) tj|}tjr|dr tj}n tj}|dkrd}nd}| }t |d\}}t |d\}}|rd||fz}nd||fz}tjd||zS) Nrr i<z -%02d%02dz +%02d%02dz%d/%b/%Y:%H:%M:%S )rgmtimedaylightaltzonetimezonedivmodstrftime) r"whengmttznegrSremrhoffsets r$log_date_stringzhttp_request.log_date_stringtsk$ = SV BBB 66CCCBT""3b!!3  * Aq6)FF Aq6)F}3S99FBBr&c |jjj|jjdd|jjd|t j|j|j|fzdS)Nrz%d - - [%s] "%s" %d %d r ) rserverloggerraddrrrrrA)r"rs r$rzhttp_request.logsw "&& !!$* )!,,,dikk::  .     r&dContinueezSwitching 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)iiir<) zzError responsezzz

Error response

z

Error code %(code)d.z

Message: %(message)s.zrlcdSr(r8)r"msglevels r$r{zhttp_request.log_info r&r()r )&__name__ __module__ __qualname__rArrrryr%r,r/r1r4rDrHrLrUr\r`recompilerbrirprvrzrrr@r reply_nowrrrrr?rr{r8r&r$r r &sJgiiOKI   .((('''))))))   "777)))%/%/%/%/P0111* 2J ($$$????   IJ+J+J+XCCC(   & & && &  &  & 0 & & & "& #& $& $& & & & !&" #&&$ #%&& '&( )&* %+&, !-&. 0/&0 #1&2 3&4 5&6 "7&8 &9&: +;&< (=&> )?&@ (A&B "C&D E&&F'#-K&&&IR#KK        r&r czeZdZdZdZeZdZdZdZ dZ dZ dZ d Z d Zd Zd Zd ZdZdZdZdS) http_channeliNctj|_t |_t j||||_ ||_ | dd|_ ttj|_|j|_|dS)Ns r&)rchannel_counterrchannel_numberrrasynchat async_chatr%rrset_terminator in_bufferintr creation_time last_usedcheck_maintenance)r"rconnrs r$r%zhttp_channel.__init__s*:DDFF&yy$$dD111   [))) $)++..+      r&c|tj|dd}d|d|jd|jdS)Nr )rr__repr__rr)r"ars r$rzhttp_channel.__repr__sL  ) )$ / /" 5###$$$ r&rcP|j|jzs|dSdSr()rmaintenance_interval maintenancerKs r$rzhttp_channel.check_maintenances7"T%>>           r&c.|dSr() kill_zombiesrKs r$rzhttp_channel.maintenances r&icttj}ttjD]9}|j|jkr'||jz |jkr| :dSr() rrlistasyncore socket_mapvalues __class__rzombie_timeoutr)r"nowrs r$rzhttp_channel.kill_zombiessy49;;H/668899 $ $G DN22'++w/EEEMMOOO $ $r&ctj||}|jjt |ttj|_ |Sr() rrsendr bytes_outrrerrr)r"r}rCs r$rzhttp_channel.sendsS$))466 ''T333dikk** r&c4 tj||}|jjt |ttj|_ |S#t$rtj dYdSwxYw)NzOut of Memory!) rrrecvrbytes_inrrerrr MemoryErrorsysexit)r"rrCs r$rzhttp_channel.recvs ((--t[AAF K * *CKK 8 8 8 $)++..DNM ( ( ( H& ' ' ' ' ' ' (sA2A55BBctjdd\}}|tur ||tj|dS)Nr)rexc_info SystemExitrr handle_error)r"trYs r$rzhttp_channel.handle_errorsM|~~bqb!1 ??!A$$J   , ,d 3 3 3 3 3r&cdSr(r8r!s r$rzhttp_channel.log$rr&cj|jr|j|dS|j|z|_dSr()rrzrr|s r$rzz"http_channel.collect_incoming_data+s>   3  6 6 = = = = ="^d2DNNNr&c |jr|jdS|j}d|_|d}|r|ds|dd}|r|d|s|dS|d}t |\}}}t |dd}t|\}}d|vr'|rt|dz|z}nt|}t||||||} |j |j j |=|dt|zd| d dS|j jD]} | | r | |_| | n#|j j t+j\\} } } }}}|d |d |d | d | d | dn#YnxYwYnxYwdS| ddS)Nr&s rr %?zBad HTTP request: %srrzServer Error: z, z: file: z line: rr)rrrsplitr crack_request join_headersrrr rrrtotal_requestsr{reprrhandlersrchandle_request exceptionsrcompact_traceback)r"rlinesrrrrrpathrqueryrurSfilefunrorrYtbinfos r$rzhttp_channel.found_terminator3s  D   1 1 3 3 3 3 3^F DNLL))E  "a " abb   "a " $$&&&AhG$17$;$; !GS'!59--F'sOOME6e||*!5//C/&8CC!5//CdGWc7FKKA  * * , , , K & 0 0 2 2 2 5W EwOOO  [)  77A;;!/0,((!,,,, ! .88::::B:T:V:V7)sD1a UVUVUVWXWXWXY]Y]Y]^b^b(c(/111!GGSMMMM! DFF!& GGSMMMMMs%F66AH4H+*H4+H/-H4c|jrdSt|jr@|j}t |dr| SdSdS)Nr stalled) ac_out_bufferre producer_fifofirsthasattrr)r"ps r$writable_for_proxyzhttp_channel.writable_for_proxyzsl   1 # $ $ "((**A9%% 99;;&q   r&)rrrac_out_buffer_sizerrrr%rrrrrrrrrrrzrr"r8r&r$rrsOgiiO ! ! !N$$$ ( ( (444   333EEENr&rcVeZdZdezZeZd dZdZdZ dZ dZ dZ dd Z d Zd ZdS) http_serverzHTTP Server (V%s)Nc||_||_tj||t jt jg|_ |stj tj }||||f|d|j\}}|s;|ddt jt j} t j|d|_n2#t j$r |dd||_YnwxYw||_t3|_t3|_t3|_t3|_t3|_|stj tj }|rtj|||_ ntj ||_ |dtBtEj#tEj"|j|fzdS)NizComputing default hostnamerxrzCannot do reverse lookupz2Medusa (V%s) started at %s Hostname: %s Port:%d )$ipportr dispatcherr% create_socketsocketAF_INET SOCK_STREAMrr file_loggerrstdoutset_reuse_addrbindlisten getsocknamer{ gethostbyname gethostname gethostbyaddr server_namer server_portr total_clientsrrrrresolving_loggerunresolving_loggerrrctime)r"r'r(resolver logger_objecthosts r$r%zhttp_server.__init__s* $$d+++ FNF,>???  <". ;;M  B: T[,,.. d = MM6 B B B%v'9';';<A>=A>rcx|r|j|dS|jd|dSrA)rrFr)r"handlerbacks r$install_handlerzhttp_server.install_handlersD  . M ' * * * * * M !W - - - - -r&c:|j|dSr()rrP)r"rPs r$remove_handlerzhttp_server.remove_handlers g&&&&&r&c|ddlmfd}dtt|jD}|jrA|jt|jz }nd}tj tj d|j zd|j zd|jzd |jzd |jzd |zd ||jzd ||jzd|jzdg g|ztjdgzS)Nr) english_bytesc@d|Srk)r?)rXrVs r$ nice_bytesz&http_server.status..nice_bytess77==!,,-- -r&cg|]}||Sr8r8)r9_fs r$r;z&http_server.status..sNNN2NNNNr&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.utilrVmap maybe_statusrr9ras_longfloatrrlines_producer SERVER_IDENTr7r(rrrr)r"rX handler_statsratiorVs @r$statuszhttp_server.statuss}888888 . . . . .ONc<&G&GNNN   '//11E$:L:T:T:V:V4W4WWEEE+)&Z^Zkk;$JZZ)Z^Zcc8JNJ\].RVRee7%O8::t}OdOdOfOfCgCgh/::W[WeWmWmWoWoKpKpq:$/Y5     - -1:0I'0R0R/S T r&)NN)r)rrrrrarrMr%rBrDrGrIrNrRrTrdr8r&r$r%r%s&7L M4444l      ...*.... '''r&r%cNt|dr|SdS)Nrd)r rd)rs r$r]r]s'x  ||~~tr&zConnection: (.*)cg}tt|D]J}||ddvr|d||ddz|d</|||K|S)Nrz rr )rangererF)r_ruis r$rrsu A 3w<< "" 1:a=E ! !bEGAJqrrN*AbEE HHgaj ! ! ! ! Hr&r c|D]U}||}|r<|t|kr||cSVdSrk)rcrdrerm)rnrrmrorhs r$rvrv$s^## NND ! !  #CII%%77E?? " " " 2r&c|D]B}||}|r)|t|kr|cSCdSrk)rcrdre)rnrrorhs r$get_header_matchrk+sQ NND ! !  CII%%HHH 2r&z%([^ ]+) ([^ ]+)(( HTTP/([0-9.]+))$|$)c8t|}|r}|t|krX|dr|d}nd}|d|d|fSdS)Nr r)NNN)REQUESTrcrdrerm)rurhrs r$r r 4s qA QUUWWA   771:: ggajjGGGwwqzz1771::w..r&__main__zusage: %s z 127.0.0.1fnordi'rliU)r(r=r>iaz-pcP tjdS#t$rYdSwxYwr()rloopKeyboardInterruptr8r&r$ profile_loopruXs8MOOOOO(DDs  %%zprofile_loop()z profile.out)r )ORCS_IDrr+rrsupervisor.compatrsupervisor.medusa.asyncore_25medusa asyncore_25rsupervisor.medusa.asynchat_25 asynchat_25rsupervisor.medusa.http_datersupervisor.medusa.producersrsupervisor.medusa.loggerrr rsupervisor.medusa.counterrurllibrr ImportError urllib.parser rrr)r%r]r IGNORECASErrrvrkror rreargvprintsupervisor.medusa.monitormonitorsupervisor.medusa.filesysfilesys!supervisor.medusa.default_handlerdefault_handlersupervisor.medusa.ftp_server ftp_serversupervisor.medusa.chat_server chat_serversupervisor.medusa.resolverr=caching_resolverrsr.r/lgsecure_monitor_serverms os_filesystemfsdhrhsrRdummy_authorizerftpcsruprofilerunrsr8r&r$rs K &&&&&&1000000000000000000/////////////////)))))))))"------1*********11100000000001e e e e e e e e X vvvvvH'vvvxAAAAA8&AAAF RZ+R] ; ;     "*= > >     z s38}}q '38A;788888333333333333333333CCCCCCCCC999999999;;;;;;;;;555555555 &X & 4 4 V  , , *W *G[$ G G "W "CHQK 0 0 ,_ ,b 1 1 [SS!--r2 6 6 B#j#+ +CHQK88  %[ $b$ / / 38      NNN GK)= 9 9 9 9 9 HMOOOOOCs'A00 B?B