| Server IP : 162.144.4.212 / Your IP : 216.73.216.108 Web Server : Apache System : Linux gator2125.hostgator.com 5.14.0-162.23.1.9991722448259.nf.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jul 31 18:11:45 UTC 2024 x86_64 User : cozeellc ( 2980) PHP Version : 8.3.31 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib64/python3.9/site-packages/mercurial/__pycache__/ |
Upload File : |
a
�+�b�E � @ s( d dl mZ d dlZd dlZd dlZddlmZ ddlmZm Z m
Z
m Z m Z m
Z
ddlm Z ddlmZmZ e jZe jZe jZdZd Zd
Zd Ze jZd d
� Ze� e j �G dd� de ��Z dd� Z dd� Z!dd� Z"dd� Z#dd� Z$dd� Z%d d � Z&e� e j �G d d � d e ��Z'd d!� Z(G d"d#� d#e �Z)dS )$� )�absolute_importN� )�_)�encoding�error�pycompat�util�wireprototypes�wireprotov1server)r )� compression�
stringutil�� s application/mercurial-0.1s application/mercurial-0.2s application/hg-errorc C sJ g }d}| j �d||f �}|du r&q@|�t�|�� |d7 }qd�|�S )zjDecode a long value from multiple HTTP request headers.
Returns the value as a bytes, not a str.
r s %s-%dN� )�headers�get�appendr Zbytesurl�join)�reqZ headerprefix�chunks�i�v� r �?/usr/lib64/python3.9/site-packages/mercurial/wireprotoserver.py�decodevaluefromheaders* s
r c @ sf e Zd Zdd� Zedd� �Zdd� Zdd� Zd d
� Zd d � Z e
j d
d� �Z dd� Z
dd� Zdd� ZdS )�httpv1protocolhandlerc C s || _ || _|| _d | _d S �N)�_req�_ui�
_checkperm�
_protocaps)�selfr �ui� checkpermr r r �__init__= s z httpv1protocolhandler.__init__c C s dS )Ns http-v1r �r r r r �nameC s zhttpv1protocolhandler.namec s� | � � }i � |�� }|D ]X}|dkr`i }|�� D ]$}|dkr0||vr0|| d ||< q0|� d< q|| d � |< q� fdd�|D �S )N� *� cmdr c s g | ] }� | �qS r r ��.0�k��datar r �
<listcomp>T r z1httpv1protocolhandler.getargs.<locals>.<listcomp>)�_args�split�keys)r �argsZ knownargsr0 r* �star�keyr r+ r �getargsG s
z httpv1protocolhandler.getargsc C sj | j j�� }t| j j�dd��}|rF|�tj| j j �
|�dd�� |S t | j d�}|�tj|dd�� |S )N�
X-HgArgs-Postr T)�keep_blank_valuess X-HgArg) r �qsparamsZ
asdictoflists�intr r �update�urlreqZparseqs�bodyfh�readr )r r1 ZpostlenZargvaluer r r r. V s �� zhttpv1protocolhandler._argsc C s, | j d u r&t| jd�}t|�d��| _ | j S )Ns X-HgProto� )r r r �setr/ )r �valuer r r � getprotocapse s
z"httpv1protocolhandler.getprotocapsc C s: t | jjd �}|t | jj�dd��8 }tj| jj|d�S )Ns Content-Lengthr5 r )�limit)r8 r r r r Z
filechunkiterr; )r �lengthr r r �
getpayloadk s z httpv1protocolhandler.getpayloadc c sZ | j j}| j j}t�� }z*|| j _|| j _|V W || j _|| j _n|| j _|| j _0 d S r )r �fout�ferrr �stringio)r ZoldoutZolderr�outr r r �mayberedirectstdiot s
�z(httpv1protocolhandler.mayberedirectstdioc C s. d| j jt�| j jpd�t�| j jp&d�f S )Ns remote:%s:%s:%sr )r Z urlschemer: �quoteZ
remotehostZ
remoteuserr$ r r r �client� s
�z httpv1protocolhandler.clientc C s~ |� d� |� d|j�dd� � |j�dd�r:|� d� |� d� t�|jtj�}|rzd�d d
� |D ��}|� d | � |S ) N� batchs
httpheader=%d� servers maxhttpheaderlens experimentals httppostargss httpmediatype=0.1rx,0.1tx,0.2tx� ,c s s | ]}t �|�� j�V qd S r )r: rI �wireprotosupportr% )r) �er r r � <genexpr>� s z8httpv1protocolhandler.addcapabilities.<locals>.<genexpr>s compression=%s) r r! � configintZ
configboolr �supportedcompenginesr �
SERVERROLEr )r �repo�caps� compenginesZ comptypesr r r �addcapabilities� s
�
�
�z%httpv1protocolhandler.addcapabilitiesc C s
| � |�S r )r �r �permr r r r" � s z httpv1protocolhandler.checkpermN)�__name__�
__module__� __qualname__r# �propertyr% r4 r. r@ rC �
contextlib�contextmanagerrH rJ rW r" r r r r r ; s
r c C s
| t jv S r )r
�commands)�cmdr r r �iscmd� s rb c
s ddl m} �j}d�jvr dS �jd }t|�s6dS �jrd|�d�|_t|j d< |�
dd � d S t �|j � ��fd
d ��}zt
|�|||� W nj |jy� } zP|j D ]\} }
|
|j | < q�|�|jt�|��|_|�
dt�|� � W Y d }~n
d }~0 0 d S )
a� Possibly process a wire protocol request.
If the current request is a wire protocol request, the request is
processed by this function.
``req`` is a ``parsedrequest`` instance.
``res`` is a ``wsgiresponse`` instance.
Returns a bool indicating if the request was serviced. If set, the caller
should stop processing the request, as a response has already been issued.
r ��commonr' Fi� � Content-Type� 0
%s
s Not FoundTc s � ��| �S r r )rY �r" �rctxr r r �<lambda>� r z#handlewsgirequest.<locals>.<lambda>N)�hgwebrd rT r7 rb Z dispatchpath�
statusmessage�status�HGTYPEr � setbodybytesr r! � _callhttpZ
ErrorResponse�coder Z forcebytestr) rh r �resr" � hgwebcommonrT ra �protorO r* r r rg r �handlewsgirequest� s2
� �*rt c C s� d|� � v r�|r tt�� i fS t�|�}t�| tj�D ]H}|� � j
|v r6i }| � dd|�
� �}|durp||d< t||f S q6d| � dd�i}t t
jd |fS )z�Determine the appropriate response type and compression settings.
Returns a tuple of (mediatype, compengine, engineopts).
s 0.2rL s %slevelNs levels zliblevels zlib)r@ �HGTYPE2r Z _noopenginer
Zclientcompressionsupportr rR rS rN r% rQ rm r rV )r! rs �prefer_uncompressedZ compformats�engineZopts�levelr r r �_httpresponsetype� s
�ry c s� ddl m� dd� }d� �fdd� }tj�||�sF|tttd�� d S |�tj| j � t�
| ||�}t |t �r�|tt
|d� �n"t |tj�r�|tt
|jd� �nt |tj�r�|tt
|jd � n�t |tj��r |j}t| j||j�\} }
} |
�|| �}| tk�r |||
| �}|t| |d � n�t |tj��rJd
|j|jf }|tt
|d� nZt |tj ��rxd |j }d �_ |tt
|d� n,t |tj ��r�|tt|j d� n t �!d
|��d S )Nr rc c s s6 |� � j}t�dt|��V |V | D ]
}|V q&d S )N� B)rN r% �struct�pack�len)�genrw �
engineoptsr% �chunkr r r � genversion2 s
z _callhttp.<locals>.genversion2c sN | t krd�_n � �| ��_|�jd< |d ur8��|� |d urJ��|� d S )Ns 200 Script output followsre )�HTTP_OKrl rk r rn Z
setbodygen)rp Z contenttype� bodybytes�bodygen�rr rq r r � setresponse' s
z _callhttp.<locals>.setresponses: requested wire protocol command is not available over HTTP)r� )r� s %d
%srf Ts hgweb.protocol internal failure)NN)"rj rd r
r` �commandavailabler� � HGERRTYPEr r" Z
permission�dispatch�
isinstance�bytesrm r �
bytesresponser, �streamreslegacyr~ � streamresry r! rv Zcompressstreamru �pushresrq �output�pusherrZdrain�ooberror�messager �ProgrammingError) rT r rq rs ra r� r� �rspr~ Z mediatyperw r r r� r ro sN
��
�
ro c C s( | � dt|� � | � |� | �� dS )z-Send a bytes response for protocol version 1.s %d
N)�writer} �flush)rD r? r r r �_sshv1respondbytesd s
r� c C s& | j }|jD ] }||� q | �� d S r )r� r~ r� )rD �sourcer� r� r r r �_sshv1respondstreamk s
r� c C s, |� d| � |�� | � d� | �� d S )Ns %s
-
�
)r� r� )rD rE r� r r r �_sshv1respondooberrorr s
r� c @ sb e Zd ZdZdd� Zedd� �Zdd� Zdd � Zd
d � Z e
j d d
� �Z dd� Z
dd� Zdd� ZdS )�sshv1protocolhandlerz<Handler for requests services via version 1 of SSH protocol.c C s || _ || _|| _t� | _d S r )r �_fin�_foutr> r )r r! �finrD r r r r# } s z sshv1protocolhandler.__init__c C s t jS r )r �SSHV1r$ r r r r% � s zsshv1protocolhandler.namec
s� i � |� � }t�t|��D ]�}| j�� d d� }|� � \}}||vrVt�td�| ��|dkr�i }t�t |��D ]:}| j�� d d� }|� � \}}| j�
t |��} | ||< qp|� d< q| j�
t |��} | � |< q� fdd�|D �S )N���s unexpected parameter %rr& c s g | ] }� | �qS r r r( r+ r r r- � r z0sshv1protocolhandler.getargs.<locals>.<listcomp>) r/ r Zxranger} r� �readliner ZAbortr r8 r< )
r r1 r0 �nZargline�arg�lr2 r* �valr r+ r r4 � s$
z sshv1protocolhandler.getargsc C s | j S r )r r$ r r r r@ � s z!sshv1protocolhandler.getprotocapsc c s@ t | jd� t| j�� �}|r<| j�|�V t| j�� �}qd S )Nr )r� r� r8 r� r� r< )r �countr r r rC � s
z sshv1protocolhandler.getpayloadc c s
d V d S r r r$ r r r rH � s z'sshv1protocolhandler.mayberedirectstdioc C s" t j�dd��dd�d }d| S )Ns
SSH_CLIENTr r= r r s remote:ssh:)r �environr r/ )r rJ r r r rJ � s zsshv1protocolhandler.clientc C s$ | j tjkr|�d� |�d� |S )Ns protocapsrK )r% r r� r )r rT rU r r r rW � s
z$sshv1protocolhandler.addcapabilitiesc C s d S r r rX r r r r" � s z sshv1protocolhandler.checkpermN)rZ r[ r\ �__doc__r# r] r% r4 r@ rC r^ r_ rH rJ rW r" r r r r r� y s
r� c
C s| d}t | ||�}|�� �sx|dk�rX|�� d d� }|s>d}qtj�||�}|s\t|d� qt�|||�} |jj �
� |jj �
� t | t
�r�t|| � n�t | tj�r�t|| j� n�t | tj�r�t|| � n�t | tj�r�t|| � ntt | tj��r t|d� t|d| j � nJt | tj��r(t|| j� n.t | tj��rHt|| j | j� nt�d| ��q|dk�rh�qxqt�d| ��qd S )Ns protov1-servingr� s shutdownr s %ds6 unhandled response type from wire protocol command: %ss unhandled ssh server state: %s) r� �is_setr� r
r` r� r� r� r! rD r� rE r� r� r r� r, r� r� r� r� rq r� r� r� r� r r� )
r! rT r� rD �ev�staters ZrequestZ availabler� r r r �
_runsshserver� sT
�
��
�r� c @ s& e Zd Zddd�Zdd� Zdd� ZdS ) � sshserverNc C sP || _ || _|�� \| _| _|rLtj|| jddd�| _tj||jddd�|_d S )N� oT)Zlogdata� e)r �_repoZ
protectfinoutr� r� r ZmakeloggingfileobjectrE )r r! rT Zlogfhr r r r#
s
�
�zsshserver.__init__c C s$ | � t�� � | j�| j| j� d S r )�
serveuntil� threading�Eventr Z
restorefinoutr� r� r$ r r r �
serve_forever s zsshserver.serve_foreverc C s t | j| j| j| j|� dS )z%Serve until a threading.Event is set.N)r� r r� r� r� )r r� r r r r� s zsshserver.serveuntil)N)rZ r[ r\ r# r� r� r r r r r� s
r� )*Z
__future__r r^ r{ r� Zi18nr � r r r r r r
Z
interfacesZ
interfaceutilZutilsr r rF Zurlerrr: r� rm ru r� r� r Z implementerZbaseprotocolhandler�objectr rb rt ry ro r� r� r� r� r� r� r r r r �<module> s:
nF$L
GK