o f|@sddlZddlZddlZddlZddlZddlZddlZddlZzddlZWn e y3ddl ZYnwddl m Z ddl m Z ddl mZddl mZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZGd ddZGdddZGdddZGdddZGdddZGdddejZ Gdddej!Z"GdddejZ#Gddde#Z$Gdd d e#Z%Gd!d"d"Z&Gd#d$d$Z'Gd%d&d&Z(d'd(Z)Gd)d*d*Z*Gd+d,d,Z+Gd-d.d.eZ,dS)/N)urllib)sha1)as_bytes) as_string) asyncore_25) http_date) http_server) producers)filesys)default_handler) auth_handlerc@s eZdZdS) NOT_DONE_YETN)__name__ __module__ __qualname__rrB/var/www/html/venv/lib/python3.10/site-packages/supervisor/http.pyr sr c@s"eZdZdZdddZddZdS)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() NcCs||_||_d|_dSN皙?)producerfootersdelay)selfrrrrr__init__)s z#deferring_chunked_producer.__init__cCsj|jr3|j}|turtS|r dt|}t|d|dSd|_|jr1ddg|jdSdSdS)Nz%xs 0s s0 )rmorer lenrrjoin)rdatasrrrr.s  zdeferring_chunked_producer.moreNrrr__doc__rrrrrrrs rc@ eZdZdZddZddZdS)deferring_composite_producerz$combine a fifo of producers into onecCs||_d|_dSr)r r)rr rrrrAs z%deferring_composite_producer.__init__cCsJt|jr#|jd}|}|turtS|r|S|jdt|jsdS)Nrr)rr rr pop)rpdrrrrEs     z!deferring_composite_producer.moreNr#rrrrr&?s r&c@s"eZdZdZdddZddZdS) 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] cCs||_d|_||_d|_dS)Nrr)rbuffer buffer_sizer)rrr-rrrrZ z$deferring_globbing_producer.__init__cCst|j|jkr:|j}|turtS|r1z|j||_Wnty0t|jt||_Ynwnt|j|jks|j}d|_|SNr)rr,r-rrr TypeErrorr)rr rrrrr`s   z deferring_globbing_producer.moreN)r+r#rrrrr*Ss  r*c@r%)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. cCs||_||_d|_d|_dS)Nrr)rfunctionbytesr)rrr3rrrrxr.z"deferring_hooked_producer.__init__cCsP|jr&|j}|turtS|sd|_||j|S|jt|7_|SdSr/)rrr r3r4r)rresultrrrr~s  zdeferring_hooked_producer.moreNr#rrrrr2qs r2c@s0eZdZdZddZddZddZdd Zd S) 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 c OsNttj|j}|}d}d}d}|jdkr*|dkr'd|vr"d}n;d|d<n6d}n3|jdkrV|d kr6d}n'd|vrUd |vrG|d d ksFd}n|jrSd |d <d}d}n d}n|jd ur]d}t| }|rjd |d<|rzt t |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&outgoinginsertr2logr*channelpush_with_producercurrent_requestclose_when_done) rargkw connectionclose_itwrap_in_chunkingglobbingoutgoing_headeroutgoing_producerrrrdonesb        zdeferring_http_request.donec Cs\|jjr|jjd}|jjd}nd}d}|jjj|d||t|j|j|fdS)z We need to override this because UNIX domain sockets return an empty string for the addr rather than a (host, port) combination rr7 localhostz%d - - [%s] "%s" %d %d N) rFaddrserverloggerrElog_date_stringtimerequest reply_code)rr4hostportrrrrEs   zdeferring_http_request.logc Csi}dddd}t}|\}}}}|r||}|r0|ddkr0|dd}|r0|ddks"d|vr9t|}|rA|dd}|jj}|j|d <t |j |d <|j |d <|j |d <d |j |d<|jj|d<d|d<d||d<tjtj||d|d<|r||d<d|d<|jjr|jjd|d<nd|d<|jD]6} | dd\} } | } | } | |vr| r| ||| <qdd| d} | r| |vr| || <q|S)NCONTENT_LENGTH CONTENT_TYPECONNECTION_TYPE)zcontent-lengthz content-typerLr/r7%REQUEST_METHOD SERVER_PORT SERVER_NAMESERVER_SOFTWAREzHTTP/SERVER_PROTOCOLzchannel.creation_time SCRIPT_NAME PATH_INFOPATH_TRANSLATED QUERY_STRINGzCGI/1.1GATEWAY_INTERFACE REMOTE_ADDRz 127.0.0.1:zHTTP_%s_-)osgetcwd split_urirunquoterFrUcommandupperstrr\ server_name SERVER_IDENTr? creation_timepathnormpathrrTr=splitr>stripget) renv header2envworkdirr{paramsqueryfragmentrUr=keyvaluerrrcgi_environmentsZ            z&deferring_http_request.cgi_environmentcCsddd}|}|ddvs|ddkrd}nd }d |vr.|d }t|\}}n |d }|d }|d usB|||krE|}n|d|}d||f}|dd dkr_|d d}|S)z Functionality that medusa's http request doesn't have; set an attribute named 'server_url' on the request based on the Host: header 80443)httphttpsHTTPS)onONSERVER_PORT_SECURE1rr HTTP_HOSTrdrcNrnz%s://%sr`)rrr~r splitport)r default_portenvironprotocolr[hostnamer\ server_urlrrrget_server_url/s$      z%deferring_http_request.get_server_urlN)rrrr$rRrErrrrrrr6s S 5r6c@s2eZdZdZdZdZd ddZddZdd ZdS) deferring_http_channelirNcCsL|durt}|jr ||j}||jks|dkr||_dSdStj|S)NrTF)rXrlast_writable_checkr http_channelwritable)rnowelapsedrrrrUs  zdeferring_http_channel.writablecCs t|jrQ|j}|dur|js|j|dSt|tr0|j|j|7_dS|}|t ur>|j |_ dS|rK|j||_d|_ dS|jndSq)z Implement deferreds r7NF) r producer_fifofirst ac_out_bufferr'r9 isinstancer4rr r)rr(r rrr refill_bufferds.       z$deferring_http_channel.refill_bufferc Cs|jr |jdSt|j}d|_|d}|r)|ds)|dd}|r)|dr|s1|dS|d}t|\}}}t|dd}t |\}}d|vrb|r]t |d|}nt |}t ||||||} |j |jj |dur|dt|d | d dS|jjD]H} | | rz | |_| | WdS|jj t\\} } } }}}|jd ||| | fd z | d WYdSYYdSq| d dS)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 rr7Nra?zBad HTTP request: %serrorz'Server Error: %s, %s: file: %s line: %si)rHfound_terminatorr in_bufferr}rIr crack_request join_headers splitqueryrtr6request_counter incrementrUtotal_requestslog_inforeprrhandlersmatchhandle_request exceptionsasyncorecompact_traceback)rr=linesrYruurir?rpathrqueryr1hfilefunlinetvtbinforrrrsh                z'deferring_http_channel.found_terminatorr") rrrac_out_buffer_sizerrrrrrrrrrLs  rc@s.eZdZeZdZddZddZd ddZdS) supervisor_http_serverNcCs^ddlm}|s|tj}||}||_tj|| |g|_ | d| dS)zj Override __init__ to do logger setup earlier so it can go to our logger object instead of stdout rrVN) supervisor.medusarV file_loggersysstdoutunresolving_loggerr dispatcherr set_socketr setblockingset_reuse_addr)rsock logger_objectrVrrrprebinds       zsupervisor_http_server.prebindcCsrddlm}ddlm}|d||_||_||_||_||_ | d|t t |j |jfdS)Nr)counter)VERSION_STRINGz2Medusa (V%s) started at %s Hostname: %s Port:%s )supervisor.medusa.counterrsupervisor.medusa.http_serverrlisten total_clientsrr bytes_outbytes_inrrXctimerxr\)rrrrrrpostbinds"    zsupervisor_http_server.postbindinfocCs,d}t|dddur |j}|j||dS)Nrgip)getattrrrVrE)rmessagetyperrrrrszsupervisor_http_server.log_info)r) rrrr channel_classrrrrrrrrrs rc@seZdZdZddZdS)supervisor_af_inet_http_serverz+ AF_INET version of supervisor HTTP server cCs||_||_ttjtj}||||||f|s=|ddt}zt |}Wntj y<t d|wz t |d|_ Wntj yZ|dd||_ Ynw|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)rr\socketAF_INET SOCK_STREAMrbindr gethostname gethostbynamer ValueError gethostbyaddrrxr)rrr\rrrrrrr s0     z'supervisor_af_inet_http_server.__init__N)rrrr$rrrrrr s rc@r%)supervisor_af_unix_http_serverz+ AF_UNIX version of supervisor HTTP server c Cs||_||_d|tf}zt|Wn tyYnw ttjtj}z| |t ||zt ||WnFty| |}|rPt tjd|}tj|zt|WnY|tdYWzt|WqtyYqwwz t||d|dWn)ty} z| jdtjkrd}t||t|ttdfd} ~ ww|||Wzt|WntyYnwzt|WwtyYwwd|_| dS)Nz%s.%dr7zUnlinking stale socket %s g333333?rzNot 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 chownz)!rr\rqgetpidunlinkOSErrorrAF_UNIXrrchmodlink checkusedrerrno EADDRINUSErstderrwriter9rXsleepchownargsEPERMrrpwdgetpwuidgeteuidrrxr) r socketname sockchmod sockchownrtempnamerusedmsgwhyrrrr*s             z'supervisor_af_unix_http_server.__init__cCsXttjtj}z|||td|d|WdStjy+YdSw)NzGET / HTTP/1.0 r7FT) rrrconnectsendrrecvr9r)rrr!rrrrqs   z(supervisor_af_unix_http_server.checkusedN)rrrr$rrrrrrr's Grc@sDeZdZddZddZddZddZd d Zd d Zd dZ dS)tail_f_producercCsBt||_||_d|_||}||kr|||_dSdSr)weakrefrefrYfilenamer_open_fsizesz)rrYrheadrrrrr~s ztail_f_producer.__init__cCs |dSr")_closerrrr__del__s ztail_f_producer.__del__c Cs||z|}Wn ttfyYdSw||j}|dkr%d|_dS|dkr<|j| d|j|}||_|StS)Nrrz==> File truncated <== ) _followrrrrrseekreadr )rnewsz bytes_addedr4rrrrs    ztail_f_producer.morecCs0t|jd|_t|jtj|_d|_ dS)Nrbr) openrrrqfstatfilenostatST_INOinorrrrrrs ztail_f_producer._opencCs|jdSr")rr9rrrrrztail_f_producer._closec CsRz t|jtj}Wn ttfyYdSw|j|kr'||dSdSr") rqr!rr"rrr#rr)rr#rrrrs  ztail_f_producer._followcCst|jtjSr")rqrrr r!ST_SIZErrrrrsztail_f_producer._fsizeN) rrrrrrrrrrrrrrr }s  r c@,eZdZdZdZddZddZddZd S) logtail_handlerzLogtail HTTP Request Handlerz/logtailcC ||_dSr" supervisordrr*rrrr zlogtail_handler.__init__cC|j|jSr"r startswithr{rrYrrrrr$zlogtail_handler.matchcCs|jdkr |ddS|\}}}}d|vrt|}|r3|ddkr3|dd}|r3|ddks%|dd\}}z |dd\}}Wn tyR|}d}Ynwddlm} | |\} }|j j | } | durq|d dS| j |} | dur|d dSt | jd |d} | dustj| s|d dSt| tj}t||d <d |d <d|d<|t|| d|dS)NGETrrarr`r7r)split_namespecrz %s_logfile Last-Modifiedtext/plain;charset=utf-8 Content-TypenozX-Accel-Bufferingr)rurrsrrtr}rsupervisor.optionsr2r*process_groupsr processesrconfigrqr{existsr!ST_MTIMErbuild_http_datepushr rR)rrYr{rrrprocess_name_and_channel process_namerFr2 group_namegroupprocesslogfilemtimerrrrsH            zlogtail_handler.handle_requestNrrrIDENTr{rrrrrrrr'  r'c@r&) mainlogtail_handlerz!Main Logtail HTTP Request Handlerz /mainlogtailcCr(r"r)r+rrrrr,zmainlogtail_handler.__init__cCr-r"r.r0rrrrr$zmainlogtail_handler.matchcCs|jdkr |ddS|jjj}|dustj|s"|ddSt|tj }t ||d<d|d<| t ||d|dS)Nr1rrr3r4r5r)rurr*optionsrDrqr{r;r!r<rr=r>r rR)rrYrDrErrrrs     z"mainlogtail_handler.handle_requestNrFrrrrrIrHrIc Cs6g}t|j}|jD] }|d}|tjkr'|d|d}}t|||d}n |tjkrA|d} |d} |d} t| | | |d}ntd|d d l m } d d l m } d d l m }g}|jD]2\}}}z ||fi|}Wnt}|j|td ||||f|jd|q^|d| |f| ||}t|}t|}||}tjtjt}tj|d}t|}t|}|d}|d}|r||i}t||}t||}t||}t||}t||}n |j d|d|!||!||!||!||!||||fq |S)Nfamilyr[r\)rrrrzCannot determine socket type %rr)supervisor_xmlrpc_handler)SystemNamespaceRPCInterface)supervisor_ui_handlerzCould not make %s rpc interfacezRPC interface %r initializedsystemuiusernamepasswordz:Server %r running without any HTTP authentication checkingsection)" LogWrapperrVserver_configsrrrrrrsupervisor.xmlrpcrLrMsupervisor.webrNrpcinterface_factories traceback format_excwarnappendrr'rIrqr{abspathdirname__file__rr os_filesystemr supervisor_auth_handlercriticalinstall_handler) rJr*serverswrapperr:rKr[r\hsrrrrLrMrN subinterfacesnamefactoryr)insttb xmlrpchandler tailhandlermaintailhandler uihandlerhere templatedir filesystemdefaulthandlerrQrRusersrrrmake_http_serverss|                       ruc@r%)rTz\Receives log messages from the Medusa servers and forwards them to the Supervisor loggercCr(r"r)rrVrrrrfr,zLogWrapper.__init__cCsB|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. Nrr)endswithr>rVrtrace)rrrrrrEis   zLogWrapper.logN)rrrr$rrErrrrrTcs rTc@seZdZddZddZdS)encrypted_dictionary_authorizercCr(r")dict)rrzrrrrur,z(encrypted_dictionary_authorizer.__init__cCsR|\}}||jvr'|j|}|dr#tt|}|dd|kS||kSdS)Nz{SHA}F)rzr/rr hexdigest)r auth_inforQrRstored_password password_hashrrr authorizexs   z)encrypted_dictionary_authorizer.authorizeN)rrrrrrrrrryts ryc@seZdZdddZdS)radefaultcCst||||t||_dSr")r rry authorizer)rrzhandlerrealmrrrrsz supervisor_auth_handler.__init__N)r)rrrrrrrrrasra)-rqr!rXrrrr rYr ImportErrorgetpasssupervisor.compatrrrrrrrrrr r r supervisor.medusa.auth_handlerr r rr&r*r2 http_requestr6rrrrrr r'rIrurTryrarrrrsV               @ 5V6E"I