vg|ddlZddlZddlZddlZddlZddlZddlZddlZ ddlZn#e $rddl ZYnwxYwddl m Z ddl m Z ddl mZddl mZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZGd dZGddZGddZGddZGddZGddejZ Gddej!Z"GddejZ#Gdde#Z$Gdd e#Z%Gd!d"Z&Gd#d$Z'Gd%d&Z(d'Z)Gd(d)Z*Gd*d+Z+Gd,d-eZ,dS).N)urllib)sha1)as_bytes) as_string) asyncore_25) http_date) http_server) producers)filesys)default_handler) auth_handlerceZdZdS) NOT_DONE_YETN)__name__ __module__ __qualname__L/var/www/pixelcanvas.ch/venv/lib/python3.11/site-packages/supervisor/http.pyrrsDrrc eZdZdZddZdZdS)deferring_chunked_producera'A producer that implements the 'chunked' transfer coding for HTTP/1.1. Here is a sample usage: request['Transfer-Encoding'] = 'chunked' request.push ( producers.chunked_producer (your_producer) ) request.done() Nc0||_||_d|_dSN皙?)producerfootersdelay)selfrrs r__init__z#deferring_chunked_producer.__init__)s    rc |jr|j}|turtS|r*dt|z}t |dz|zdzSd|_|jr!ddg|jzdzSdSdS)Nz%xs 0s s0 r)rmorerlenrrjoin)rdatass rr"zdeferring_chunked_producer.more.s = =%%''D|#### (3t99${{W,t3g== $ <("<<(=>>LL'<3rNrrr__doc__rr"rrrrrsA rrceZdZdZdZdZdS)deferring_composite_producerz$combine a fifo of producers into onec"||_d|_dSr)r r)rr s rrz%deferring_composite_producer.__init__As" rct|jrc|jd}|}|turtS|r|S|jdt|jcdS)Nrr)r#r r"rpop)rpds rr"z!deferring_composite_producer.moreEs|$.!! q!AAL  ## &""1%%%$.!! 3rNr(rrrr+r+?s8..     rr+c eZdZdZddZdZdS)deferring_globbing_producerz 'glob' the output from a producer into a particular buffer size. helps reduce the number of calls to send(). [this appears to gain about 30% performance on requests to a single channel] c>||_d|_||_d|_dS)Nrr)rbuffer buffer_sizer)rrr6s rrz$deferring_globbing_producer.__init__Zs#   & rct|j|jkr|j}|t urt S|rJ |j|z|_n:#t $r,t|jt|z|_YnwxYwnt|j|jk|j}d|_|SNr)r#r5r6rr"r TypeErrorr)rr%rs rr"z deferring_globbing_producer.more`s$+!111=%%''D|#### I"&+"4DKK III"*4;"7"7(4.."HDKKKI$+!111 K s A3BBN)r3r(rrrr2r2SsA  rr2ceZdZdZdZdZdS)deferring_hooked_producerz A producer that will call when it empties,. with an argument of the number of bytes produced. Useful for logging/instrumentation purposes. c>||_||_d|_d|_dS)Nrr)rfunctionbytesr)rrr>s rrz"deferring_hooked_producer.__init__xs"      rc|jrl|j}|turtS|s"d|_||jn|xjt |z c_|SdSr8)rr"rr>r?r#)rresults rr"zdeferring_hooked_producer.more~sv = ]''))F%%## * $  tz**** c&kk) M3rNr(rrrr<r<qs<      rr<c*eZdZdZdZdZdZdZdS)deferring_http_requesta The medusa http_request class uses the default set of producers in medusa.producers. We can't use these because they don't know anything about deferred responses, so we override various methods here. This was added to support tail -f like behavior on the logtail handler cHtjtj|j}|}d}d}d}|jdkr|dkr d|vrd}nQd|d<nKd}nH|jdkr4|d krd}n4d|vr&d |vr|d d ksd}n|jr d |d <d}d}n d}n |jd}tj| }|rd |d<|r3tt|j }t||g}n/|j d|t|j }t||j}|rt!|}|j|d |j_|r|jd Sd S) z I didn't want to override this, but there's no way around it in order to support deferreds - CM finalize this transaction - send output to the http channelrz1.0z keep-alivezContent-Lengthz Keep-Alive Connectionz1.1closezTransfer-EncodingchunkedN)r get_header CONNECTIONheaderlowerversion use_chunkedr simple_producerbuild_reply_headerrr+outgoinginsertr<logr2channelpush_with_producercurrent_requestclose_when_done) rargkw connectionclose_itwrap_in_chunkingglobbingoutgoing_headeroutgoing_producers rdonezdeferring_http_request.dones!+K,B4;OO %%''  <5 \))'4// HH)5D&& \U " "W$$%--&$.. 34 AA#$%!09D,-'($ !HH H \ ! H#3D4K4K4M4MNN  )!(D   L :0??!! != "34!!   M O 4 4 4 > )++*...*:*:'vuh  !&=D tAw#~~8D tAw#~~ $;;&t,,D  !""IE$ $ 2 2 4 4  --M#/M!'!4 !(4D(D"*((DD1 bcc?C  !#2#JrN)rrrr)r`rSrrrrrrCrCsaFF Q+Q+Q+f(333jrrCc.eZdZdZdZdZddZdZdZdS)deferring_http_channelirNc|tj}|jr&||jz }||jks|dkr ||_dSdStj|S)NrTF)rgrlast_writable_checkr http_channelwritable)rnowelapseds rrzdeferring_http_channel.writableUsg ;)++C : D44G$*$$'A+++.(tu'00666rc t|jr|j}|6|js-|j|dSt |tr+|j|xj|z c_dS|}|tur|j |_ dS|r|j|z|_d|_ dS|jndS)z Implement deferreds rENF) r# producer_fifofirst ac_out_bufferr.rG isinstancer?r"rr)rr/r%s r refill_bufferz$deferring_http_channel.refill_bufferds 4%&& &,,..9-%*..000 F5))&**,,,&&!+&&Fvvxx<''!"DJF-)-);d)BD&!&DJF&**,,,,9 rc |jr|jdSt|j}d|_|d}|r|ds|dd}|r|d|s|dS|d}t j|\}}}t j|dd}t j |\}}d|vr1|rt j |dz|z}nt j |}t||||||} |j |jj |=|dt#|zd | d dS|jjD]} | | r | |_| | n#|jj t/j\\} } } }}}|jd |d |d | d| d  | dn#YnxYwYnxYwdS| ddS)z We only override this to use 'deferring_http_request' class instead of the normal http_request class; it sucks to need to override this rz rrENrq?zBad HTTP request: %serrorzServer Error: z, z: file: z line: i)rVfound_terminatorr in_bufferrrWr crack_request join_headers splitqueryrrCrequest_counter incrementrdtotal_requestslog_inforeprrhandlersmatchhandle_request exceptionsasyncorecompact_traceback)rrKlinesrhrurirMrpathrqueryr:hfilefunlinetvtbinfos rrz'deferring_http_channel.found_terminators  J   1 1 3 3 3 3 3 t~..F DNLL((E  "a " abb   "a " $$&&&AhG$/$=w$G$G !GS' -uQRRy99F(2377ME6e||5%-e44s:VCCC%-e44C&tWgsG'-//A  * * , , , K & 0 0 2 2 2 5W EwOOO  [)  77A;;!/0,((!,,,, ! .88:::'9;;8)sD1a ,,,QQqqqdd,#%%%!GGSMMMM! DFF%* GGSMMMMMs%?GA#IIIIIr') rrrac_out_buffer_sizerrrrrrrrrrLs_ E 7 7 7 7@NNNNNrrc*eZdZeZdZdZdZddZdS)supervisor_http_serverNcTddlm}|s|tj}||}||_t j|| |g|_ | d| dS)zj Override __init__ to do logger setup earlier so it can go to our logger object instead of stdout rreN) supervisor.medusare file_loggersysstdoutunresolving_loggerr dispatcherr set_socketr setblockingset_reuse_addr)rsock logger_objectres rprebindzsupervisor_http_server.prebinds -,,,,, ;"..sz::M11-@@ # $$d+++    rc |ddlm}ddlm}|d||_||_||_||_||_ | d|dtj tj d|j d|jd dS) Nr)counter)VERSION_STRINGz Medusa (Vz ) started at z Hostname: z Port: )supervisor.medusa.counterrsupervisor.medusa.http_serverrlisten total_clientsrr bytes_outbytes_inrrgctimerrk)rrrs rpostbindzsupervisor_http_server.postbinds555555@@@@@@ D$WYY%gii!'))    ' 49;;////(((      rinfocpd}t|dd|j}|j||dS)Nrwip)getattrrrerS)rmessagetypers rrzsupervisor_http_server.log_infos<  4t $ $ 0B G$$$$$r)r) rrrr channel_classrrrrrrrrrsP*M B&0%%%%%%rrceZdZdZdZdS)supervisor_af_inet_http_serverz+ AF_INET version of supervisor HTTP server ch||_||_tjtjtj}||||||f|sd|ddtj} tj |}n%#tj $rtd|zwxYw tj |d|_ n2#tj $r |dd||_ YnwxYw|dS)NzComputing default hostnamewarningzCould not determine IP address for hostname %s, please try setting an explicit IP address in the "port" setting of your [inet_http_server] section. For example, instead of "port = 9001", try "port = 127.0.0.1:9001."rzCannot do reverse lookup)rrksocketAF_INET SOCK_STREAMrbindr gethostname gethostbynamer ValueError gethostbyaddrrr)rrrkrrrs rrz'supervisor_af_inet_http_server.__init__ sD }V^V-?@@ T=))) 2t* MM6 B B B)++H )(33<    M      "%3R88;D  | " " " MM4i @ @ @!D    " sB&&"C C,,,DDN)rrrr)rrrrrr s)55rrceZdZdZdZdZdS)supervisor_af_unix_http_serverz+ AF_UNIX version of supervisor HTTP server c d||_||_d|tjfz} tj|n#t $rYnwxYw t jt jt j} | |tj || tj || tj ||d|dn{#t $rn}|j dtjkrMd}t!||t#|t%jtjdfzd}~wwxYw||| tj|n#t $rYnwxYw#t $r||} | rt jtjd|z}t2j| tj|n#YnxYw|t;jdY tj| #t $rYwxYwwxYw# tj|w#t $rYwwxYwxYwd|_| dS)Nz%s.%drErzNot permitted to chown %s to uid/gid %s; adjust "sockchown" value in config file or on command line to values that the current user (%s) can successfully chownzUnlinking stale socket %s g333333?z)!rrkrgetpidunlinkOSErrorrAF_UNIXrrchmodlinkchownargserrnoEPERMr rpwdgetpwuidgeteuidr checkusedr EADDRINUSErstderrwriterGrgsleeprr) r socketname sockchmod sockchownrtempnamerwhymsguseds rrz'supervisor_af_unix_http_server.__init__*s j")++66  Ih        D 1 =1CDDD/  (###9---&GHj111&"Yq\9Q<HHHH" " " "8A;%+55$NC#-SJ48OO47L8: 5F5FFG5I46.6#/#//" "LL}555Ih''''DQ>>*55D=$l5+;<<<8*DCJ$$S))) *----JJLLLJrNNN,Ih''''DQLIh''''D2 s= A  A 8*I+#F9"CI+ E&A)EEI+/F FFA#I(:HI(H-I(>I+I I$#I$'I((I++J-JJ J JJJcFtjtjtj} |||t d|d|dS#tj$rYdSwxYw)NzGET / HTTP/1.0 rETF) rrrconnectsendrrecvrGr)rr r&s rrz(supervisor_af_unix_http_server.checkusedqs M&.&*< = =  IIj ! ! ! FF8455 6 6 6 FF1III GGIII4|   55 sA B B B N)rrrr)rrrrrr r 's<55EEEN     rr c8eZdZdZdZdZdZdZdZdZ dS) tail_f_producerctj||_||_d|_||}||kr ||z |_dSdSr)weakrefrefrhfilenamer_open_fsizesz)rrhr0headr3s rrztail_f_producer.__init__~sZ{7++     [[]] ::4iDGGG :rc.|dSr')_closers r__del__ztail_f_producer.__del__s rcP| |}n#ttf$rYdSwxYw||jz }|dkr d|_dS|dkr?|j| d|j|}||_|StS)Nrrz==> File truncated <== ) _followr2rr r3rseekreadr)rnewsz bytes_addedr?s rr"ztail_f_producer.mores  KKMMEE$   33 dgo ??DG-- ?? INNK< + + +INN;//EDGLs+AAct|jd|_tj|jt j|_d|_ dS)Nrbr) openr0rrfstatfilenostatST_INOinor3r7s rr1ztail_f_producer._opensF-- 8DI,,..// <rc8|jdSr')rrGr7s rr6ztail_f_producer._closes rc tj|jtj}n#tt f$rYdSwxYw|j|kr*||dSdSr') rrEr0rFrr rGr6r1)rrGs rr;ztail_f_producer._followsz '$-((5CC$    FF  8s?? KKMMM JJLLLLL ?s),AAcxtj|jtjSr')rrCrrDrEST_SIZEr7s rr2ztail_f_producer._fsizes'x ((**++DL99rN) rrrrr8r"r1r6r;r2rrrr,r,}s}   $    :::::rr,c(eZdZdZdZdZdZdZdS)logtail_handlerzLogtail HTTP Request Handlerz/logtailc||_dSr' supervisordrrPs rrzlogtail_handler.__init__&rc@|j|jSr'r startswithrrrhs rrzlogtail_handler.match{%%di000rc"|jdkr|ddS|\}}}}d|vrtj|}|r$|ddkr|dd}|r |ddk|dd\}} |dd\}}n#t $r|}d}YnwxYwddlm} | |\} }|j j | } | |d dS| j |} | |d dSt| jd |zd} | tj| s|d dStj| t$j}t)j||d <d |d <d|d<|t/|| d|dS)NGETrrqrrprEr)split_namespecrz %s_logfile Last-Modifiedtext/plain;charset=utf-8 Content-TypenozX-Accel-Bufferingr)rrrr rrr supervisor.optionsrZrPprocess_groupsr processesrconfigrrexistsrEST_MTIMErbuild_http_datepushr,r`)rrhrrrrprocess_name_and_channel process_namerTrZ group_namegroupprocesslogfilemtimes rrzlogtail_handler.handle_requests@ ?e # # MM3    F(/(9(9(;(;%feX $;;&t,,D tAw#~~8D tAw#~~*.C););&& $<$B$B3$J$J !L''   3LGGG  655555#1>,#?#? L /33J?? = MM#    F/%%l33 ? MM#    F'.,*@$GG ?"'.."9"9? MM#    F  /#,#B?NrrrIDENTrrrrrrrrMrMsK *E D'''11199999rrMc(eZdZdZdZdZdZdZdS)mainlogtail_handlerz!Main Logtail HTTP Request Handlerz /mainlogtailc||_dSr'rOrQs rrzmainlogtail_handler.__init__rRrc@|j|jSr'rTrVs rrzmainlogtail_handler.matchrWrc|jdkr|ddS|jjj}|t j|s|ddSt j|tj }tj ||d<d|d<| t||d|dS)NrYrrr[r\r]r)rrrPoptionsrlrrrcrErdrrerfr,r`)rrhrlrms rrz"mainlogtail_handler.handle_requests ?e # # MM3    F"*2 ?"'.."9"9? MM#    F  /#,#EGGGBB v~ % %JwIwI/ 9i>EGGGBB>GHH H??????AAAAAA888888 ' > G G D'1 Kw{00a00 K)++##B''' !BT!IJJJ  $ . . . N   > E F F F Fh99-HHJ K K K11+}MM %k22 -k::))+66 wrwx8899gll4.. *;77 (8DD*%*%  ?h'E3E=IIM1%EEK5e_MMO/yAAI4UNKKNN N # #*,29,=> ? ? ? >*** 9%%% ?+++ ;''' =)))|$$$$ Ns CADceZdZdZdZdZdS)rz\Receives log messages from the Medusa servers and forwards them to the Supervisor loggerc||_dSr'r)rres rrzLogWrapper.__init__fs  rc|dr |dd}d|vr|j|dS|j|dS)zMedusa servers call this method. There is no log level so we have to sniff the message. We want "Server Error" messages from medusa.http_server logged as errors at least.rNrr)endswithrLrertrace)rr%s rrSzLogWrapper.logisp <<   crc(C ciikk ! ! K  c " " " " " K  c " " " " "rN)rrrr)rrSrrrrrcs<%% # # # # #rrceZdZdZdZdS)encrypted_dictionary_authorizerc||_dSr')dict)rrs rrz(encrypted_dictionary_authorizer.__init__us  rc|\}}||jvrd|j|}|drrs; JJJJ%$$$$$""""""&&&&&&''''''555555''''''))))))''''''%%%%%%------777777        @(<8}}}}}[5}}}~FFFFF[5FFFP3%3%3%3%3%[43%3%3%j%;