403WebShell

403Webshell
Server IP : 198.38.94.13 / Your IP : 216.73.217.33
Web Server : Apache
System : Linux d4744.dxb1.stableserver.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64
User : revivere ( 1140)
PHP Version : 8.2.33
Disable Function : NONE
MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF
Directory : /lib/python3.9/site-packages/supervisor/__pycache__/
Upload File :
[ Back ]
Current File : /lib/python3.9/site-packages/supervisor/__pycache__/http.cpython-39.pyc
a

0�g�|�@s�ddlZddlZddlZddlZddlZddlZddlZddlZzddlZWne	yfddl
ZYn0ddlmZddlm
Z
ddlmZddlmZddlmZddlmZddlmZdd	lmZdd
lmZddlmZddlmZGd
d�d�ZGdd�d�ZGdd�d�ZGdd�d�ZGdd�d�ZGdd�dej�Z Gdd�dej!�Z"Gdd�dej�Z#Gdd�de#�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.e�Z,dS)/�N)�urllib)�sha1)�as_bytes)�	as_string)�asyncore_25)�	http_date)�http_server)�	producers)�filesys)�default_handler)�auth_handlerc@seZdZdS)�NOT_DONE_YETN)�__name__�
__module__�__qualname__�rr�3/usr/lib/python3.9/site-packages/supervisor/http.pyr
sr
c@s"eZdZdZddd�Zdd�ZdS)�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|_dS�N皙�����?)�producer�footers�delay)�selfrrrrr�__init__)sz#deferring_chunked_producer.__init__cCsp|jrh|j��}|turtS|r@dt|�}t|�d|dSd|_|jrbd�dg|j�dSdSndSdS)Nz%xs
�0s

s0

�)r�morer
�lenrr�join)r�data�srrrr.s
zdeferring_chunked_producer.more)N�rrr�__doc__rrrrrrrs	
rc@s eZdZdZdd�Zdd�ZdS)�deferring_composite_producerz$combine a fifo of producers into onecCs||_d|_dSr)r	r)rr	rrrrAsz%deferring_composite_producer.__init__cCsBt|j�r>|jd}|��}|tur(tS|r0|S|j�d�qdS)Nrr)rr	rr
�pop)r�p�drrrrEs

z!deferring_composite_producer.moreNr"rrrrr$?sr$c@s"eZdZdZddd�Zdd�ZdS)	�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)r�buffer�buffer_sizer)rrr+rrrrZsz$deferring_globbing_producer.__init__cCsxt|j�|jkrh|j��}|tur&tS|rhz|j||_Wqfty`t|j�t|�|_Yqf0qqhq|j}d|_|S�Nr)rr*r+rrr
�	TypeErrorr)rr �rrrrr`s
z deferring_globbing_producer.moreN)r)r"rrrrr(Ss
r(c@s eZdZdZdd�Zdd�ZdS)�deferring_hooked_producerz�
    A producer that will call <function> when it empties,.
    with an argument of the number of bytes produced.  Useful
    for logging/instrumentation purposes.
    cCs||_||_d|_d|_dS)Nrr)r�function�bytesr)rrr0rrrrxsz"deferring_hooked_producer.__init__cCsR|jrJ|j��}|turtS|s4d|_|�|j�n|jt|�7_|SdSdSr,)rrr
r0r1r)r�resultrrrr~s
zdeferring_hooked_producer.moreNr"rrrrr/qsr/c@s0eZdZdZdd�Zdd�Zdd�Zdd	�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	OsNt�tj|j�}|��}d}d}d}|jdkrT|dkrNd|vrDd}qRd|d<q�d}nf|jdkr�|d	krld}q�d|vr�d
|vr�|d
dks�d}q�|jr�d|d
<d}d}q�d}n|jdur�d}t�|�	��}|r�d	|d<|r�t
t|j��}t||g�}n|j�
d|�t|j�}t||j�}|�r&t|�}|j�|�d|j_|�rJ|j��dS)
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 channelr�z1.0z
keep-alivezContent-Lengthz
Keep-AliveZ
Connectionz1.1�closezTransfer-EncodingZchunkedN)rZ
get_headerZ
CONNECTION�header�lower�versionZuse_chunkedr	Zsimple_producerZbuild_reply_headerrr$Zoutgoing�insertr/�logr(�channelZpush_with_producer�current_request�close_when_done)	r�arg�kw�
connectionZclose_itZwrap_in_chunkingZglobbingZoutgoing_headerZoutgoing_producerrrr�done�s\




��
�zdeferring_http_request.donec	Cs\|jjr"|jjd}|jjd}nd}d}|jjj�|d||�t���|j|j|f�dS)z� We need to override this because UNIX domain sockets return
        an empty string for the addr rather than a (host, port) combination rr4Z	localhostz%d - - [%s] "%s" %d %d
N)	r;�addr�server�loggerr:Zlog_date_string�time�requestZ
reply_code)rr1�host�portrrrr:�s
��zdeferring_http_request.logcCs�i}dddd�}t��}|��\}}}}|r4||}|rR|ddkrR|dd�}q4d|vrdt�|�}|rt|dd�}|jj}|j��|d	<t	|j
�|d
<|j|d<|j|d<d
|j
|d<|jj|d<d|d<d||d<tj�tj�||d��|d<|�r||d<d|d<|jj�r*|jjd|d<nd|d<|jD]v}	|	�dd�\}
}|
��}
|��}|
|v�r||�r||||�|
�<n0dd�|
�d����}
|�r8|
|v�r8|||
<�q8|S)NZCONTENT_LENGTHZCONTENT_TYPEZCONNECTION_TYPE)zcontent-lengthzcontent-typer@r�/r4�%ZREQUEST_METHOD�SERVER_PORT�SERVER_NAMEZSERVER_SOFTWAREzHTTP/ZSERVER_PROTOCOLzchannel.creation_time�ZSCRIPT_NAMEZ	PATH_INFOZPATH_TRANSLATEDZQUERY_STRINGzCGI/1.1ZGATEWAY_INTERFACEZREMOTE_ADDRz	127.0.0.1�:zHTTP_%s�_�-)�os�getcwd�	split_urir�unquoter;rC�command�upper�strrH�server_nameZSERVER_IDENTr8Z
creation_time�path�normpathrrBr6�splitr7�strip�get)r�envZ
header2envZworkdirrY�params�query�fragmentrCr6�key�valuerrr�cgi_environment�sV�


�


z&deferring_http_request.cgi_environmentcCs�ddd�}|��}|�d�dvs.|�d�dkr4d}nd	}d
|vr\|d
��}t�|�\}}n|d��}|d}|d
us�|||kr�|}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
        Z80Z443)�http�httpsZHTTPS)ZonZONZSERVER_PORT_SECURE�1rfreZ	HTTP_HOSTrLrKNrNz%s://%s���rI)rdr]r\r�	splitport)rZdefault_port�environZprotocolrG�hostnamerHZ
server_urlrrr�get_server_url/s&
�z%deferring_http_request.get_server_urlN)rrrr#rAr:rdrlrrrrr3�s
S5r3c@s2eZdZdZdZdZd
dd�Zdd�Zdd	�ZdS)�deferring_http_channelirNcCsL|durt��}|jr@||j}||jks2|dkr<||_dSdStj�|�S)NrTF)rEr�last_writable_checkr�http_channel�writable)rZnow�elapsedrrrrpUs
zdeferring_http_channel.writablecCs�t|j�r�|j��}|dur8|js4|j��|��dSt|t�r^|j��|j|7_dS|��}|t	urz|j
|_
dS|r�|j||_d|_
dS|j��qdSqdS)z Implement deferreds NF)rZ
producer_fifo�firstZ
ac_out_bufferr%r5�
isinstancer1rr
r)rr&r rrr�
refill_bufferds*




z$deferring_http_channel.refill_buffercCs�|jr|j���n�t|j�}d|_|�d�}|rH|dsH|dd�}q.|sX|��dS|d}t�|�\}}}t�|dd��}t�	|�\}}d|vr�|r�t�
|�d|}n
t�
|�}t||||||�}	|j�
�|jj�
�|du�r|�dt|�d	�|	�d
�dS|jjD]�}
|
�|	��rz|	|_|
�|	�Wnd|jj�
�t��\\}}}
}}}|j�d||||
fd	�z|	�d�WnYn0Yn0dS�q|	�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
rr4NrJ�?zBad HTTP request: %s�error�z'Server Error: %s, %s: file: %s line: %si��)r<�found_terminatorrZ	in_bufferr[r=rZ
crack_requestZjoin_headers�
splitqueryrTr3Zrequest_counterZ	incrementrC�total_requests�log_info�reprrv�handlers�match�handle_request�
exceptions�asyncoreZcompact_traceback)rr6�linesrFrU�urir8ZrpathZrqueryr.�h�fileZfun�line�t�vZtbinforrrry�s`


�


�
��
z'deferring_http_channel.found_terminator)N)	rrrZac_out_buffer_sizerrnrprtryrrrrrmLs
 rmc@s.eZdZeZdZdd�Zdd�Zd	dd�ZdS)
�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 r�rDN)
�supervisor.medusarDZfile_logger�sys�stdoutZunresolving_loggerr��
dispatcherrZ
set_socketr~ZsetblockingZset_reuse_addr)r�sock�
logger_objectrDrrr�prebind�s


zsupervisor_http_server.prebindcCsrddlm}ddlm}|�d�|�|_|�|_|�|_|�|_|�|_	|�
d|t�t���|j
|jf�dS)Nr)�counter)�VERSION_STRING�z2Medusa (V%s) started at %s
	Hostname: %s
	Port:%s
)Zsupervisor.medusa.counterr�Zsupervisor.medusa.http_serverr�ZlistenZ
total_clientsr{r�Z	bytes_outZbytes_inr|rE�ctimerXrH)rr�r�rrr�postbind�s"
���zsupervisor_http_server.postbind�infocCs,d}t|dd�dur|j}|j�||�dS)NrM�ip)�getattrr�rDr:)r�message�typer�rrrr|szsupervisor_http_server.log_info)r�)	rrrrmZ
channel_classr�r�r�r|rrrrr��s
r�c@seZdZdZdd�ZdS)�supervisor_af_inet_http_serverz+ AF_INET version of supervisor HTTP server cCs�||_||_t�tjtj�}|�||�|�||f�|s~|�dd�t��}zt�	|�}Wn tj
y|td|��Yn0zt�|�d|_
Wn&tj
y�|�dd�||_
Yn0|��dS)NzComputing default hostnameZwarningz�Could 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)r�rH�socket�AF_INET�SOCK_STREAMr��bindr|ZgethostnameZ
gethostbynamerv�
ValueErrorZ
gethostbyaddrrXr�)rr�rHr�r�rkrrrrs,��
z'supervisor_af_inet_http_server.__init__N)rrrr#rrrrrr�	sr�c@s eZdZdZdd�Zdd�ZdS)�supervisor_af_unix_http_serverz+ AF_UNIX version of supervisor HTTP server c
Cs,||_||_d|t��f}zt�|�Wnty<Yn0t�tjtj�}�z�|�	|�t�
||�zt�||�Wn�t�y|�|�}|r�t�
tj��d|}tj�|�zt�|�WnYn0|��t�d�YWzt�|�Wq>t�y
Yq>0q>Yn�0zt�||d|d�Wndt�y�}	zJ|	jdtjk�r|d}t||t|�t�t���df��n�WYd}	~	n
d}	~	00|�||�Wzt�|�Wnt�y�Yn0�qWzt�|�Wnt�y�Yn0q>zt�|�Wnt�yYn00q>d|_|� �dS)Nz%s.%dzUnlinking stale socket %s
g333333�?rr4z�Not 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<unix domain socket>)!r�rHrQ�getpid�unlink�OSErrorr��AF_UNIXr�r��chmod�link�	checkusedrv�errnoZ
EADDRINUSEr��stderr�writer5rE�sleep�chown�args�EPERMr�r}�pwd�getpwuid�geteuidr�rXr�)
r�
socketname�	sockchmod�	sockchownr�Ztempnamer��used�msg�whyrrrr*s|


����
��
z'supervisor_af_unix_http_server.__init__cCs^t�tjtj�}z.|�|�|�td��|�d�|��WntjyTYdS0dSdS)NzGET / HTTP/1.0

r4FT)	r�r�r�Zconnect�sendrZrecvr5rv)rr�r!rrrr�qs

z(supervisor_af_unix_http_server.checkusedN)rrrr#rr�rrrrr�'sGr�c@sDeZdZdd�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dS)�tail_f_producercCs>t�|�|_||_d|_|��|��}||kr:|||_dSr)�weakref�refrF�filenamer�_open�_fsize�sz)rrFr��headr�rrrr~sztail_f_producer.__init__cCs|��dS�N)�_close�rrrr�__del__�sztail_f_producer.__del__c	Cs||��z|��}Wnttfy,YdS0||j}|dkrJd|_dS|dkrx|j�|d�|j�|�}||_|StS)Nrrz==> File truncated <==
�)	�_followr�r�r�r�r��seek�readr
)rZnewszZbytes_addedr1rrrr�s
ztail_f_producer.morecCs0t|jd�|_t�|j���tj|_d|_	dS)N�rbr)
�openr�r�rQ�fstat�fileno�stat�ST_INO�inor�r�rrrr��sztail_f_producer._opencCs|j��dSr�)r�r5r�rrrr��sztail_f_producer._closec	CsNzt�|j�tj}Wnttfy.YdS0|j|krJ|��|��dSr�)	rQr�r�r�r�r�r�r�r�)rr�rrrr��s
ztail_f_producer._followcCst�|j���tjSr�)rQr�r�r�r��ST_SIZEr�rrrr��sztail_f_producer._fsizeN)
rrrrr�rr�r�r�r�rrrrr�}s
r�c@s,eZdZdZdZdd�Zdd�Zdd�Zd	S)
�logtail_handlerzLogtail HTTP Request Handlerz/logtailcCs
||_dSr���supervisord�rr�rrrr�szlogtail_handler.__init__cCs|j�|j�Sr��r��
startswithrY�rrFrrrr�szlogtail_handler.matchcCsz|jdkr|�d�dS|��\}}}}d|vr:t�|�}|rX|ddkrX|dd�}q:|�dd�\}}z|�dd�\}}Wnty�|}d}Yn0ddlm}	|	|�\}
}|j	j
�|
�}|dur�|�d	�dS|j�|�}|dur�|�d	�dSt
|jd
|d�}
|
du�s tj�|
��s.|�d	�dSt�|
�tj}t�|�|d<d|d
<d|d<|�t||
d��|��dS)N�GETrwrJrrIr4r�)�split_namespecrxz
%s_logfile�
Last-Modified�text/plain;charset=utf-8�Content-Type�nozX-Accel-Bufferingr�)rUrvrSrrTr[r�Zsupervisor.optionsr�r�Zprocess_groupsr]Z	processesr��configrQrY�existsr��ST_MTIMEr�build_http_date�pushr�rA)rrFrYr_r`raZprocess_name_and_channelZprocess_namer;r�Z
group_name�groupZprocess�logfile�mtimerrrr��sD






zlogtail_handler.handle_requestN�rrrZIDENTrYrrr�rrrrr��s
r�c@s,eZdZdZdZdd�Zdd�Zdd�Zd	S)
�mainlogtail_handlerz!Main Logtail HTTP Request Handlerz/mainlogtailcCs
||_dSr�r�r�rrrr�szmainlogtail_handler.__init__cCs|j�|j�Sr�r�r�rrrr�szmainlogtail_handler.matchcCs�|jdkr|�d�dS|jjj}|dus6tj�|�sD|�d�dSt�|�tj	}t
�|�|d<d|d<|�t
||d��|��dS)Nr�rwrxr�r�r�r�)rUrvr��optionsr�rQrYr�r�r�rr�r�r�rA)rrFr�r�rrrr�s



z"mainlogtail_handler.handle_requestNr�rrrrr��s
r�c Cs>g}t|j�}|jD�]"}|d}|tjkrN|d|d}}t|||d�}n@|tjkr�|d}	|d}
|d}t|	|
||d�}ntd|��d	d
l	m
}d	dl	m}
d	dlm
}g}|jD]j\}}}z||fi|��}Wn,t��}|j�|�td
|��Yn0|�||f�|j�d|�q�|�d|
|�f�|||�}t|�}t|�}||�}tj�tj�t��}tj�|d�}t�|�}t�|�}|d}|d}|�r�||i}t||�}t||�}t||�}t||�}t||�}n|j� d|d�|�!|�|�!|�|�!|�|�!|�|�!|�|�||f�q|S)N�familyrGrH)r�r�r�r�zCannot determine socket type %rr)�supervisor_xmlrpc_handler)�SystemNamespaceRPCInterface)�supervisor_ui_handlerzCould not make %s rpc interfacezRPC interface %r initialized�systemZui�username�passwordz:Server %r running without any HTTP authentication checking�section)"�
LogWrapperrDZserver_configsr�r�r�r�r�r�Zsupervisor.xmlrpcr�r�Zsupervisor.webr�Zrpcinterface_factories�	traceback�
format_exc�warn�appendr�r�r�rQrY�abspath�dirname�__file__rr
Z
os_filesystemr�supervisor_auth_handlerZcriticalZinstall_handler) r�r�Zservers�wrapperr�r�rGrHZhsr�r�r�r�r�r�Z
subinterfaces�name�factoryr'�inst�tbZ
xmlrpchandlerZtailhandlerZmaintailhandlerZ	uihandler�hereZtemplatedirZ
filesystemZdefaulthandlerr�r�Zusersrrr�make_http_serverss|

�
��






��




rc@s eZdZdZdd�Zdd�ZdS)r�z\Receives log messages from the Medusa servers and forwards
    them to the Supervisor loggercCs
||_dSr�r�)rrDrrrrfszLogWrapper.__init__cCs@|�d�r|dd�}d|��vr0|j�|�n|j�|�dS)z�Medusa 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.�
Nrhrv)�endswithr7rDrvZtrace)rr�rrrr:is

zLogWrapper.logN)rrrr#rr:rrrrr�csr�c@seZdZdd�Zdd�ZdS)�encrypted_dictionary_authorizercCs
||_dSr�)�dict)rrrrrrusz(encrypted_dictionary_authorizer.__init__cCsX|\}}||jvrP|j|}|�d�rFtt|����}|dd�|kS||kSndSdS)Nz{SHA}�F)rr�rrZ	hexdigest)rZ	auth_infor�r�Zstored_passwordZ
password_hashrrr�	authorizexs



z)encrypted_dictionary_authorizer.authorizeN)rrrrr	rrrrrtsrc@seZdZddd�ZdS)r��defaultcCst�||||�t|�|_dSr�)rrrZ
authorizer)rrZhandlerZrealmrrrr�sz supervisor_auth_handler.__init__N)r
)rrrrrrrrr��sr�)-rQr�rEr�r�r�r�r�r��ImportErrorZgetpassZsupervisor.compatrrrrr�rr�rrr	r
rZsupervisor.medusa.auth_handlerrr
rr$r(r/Zhttp_requestr3rormr�r�r�r�r�r�rr�rr�rrrr�<module>sR @	5V6E"I
Youez - 2016 - github.com/yon3zu
LinuXploit