File: //usr/lib/python3/dist-packages/mercurial/__pycache__/statichttprepo.cpython-310.pyc
o
�]Lb� � @ s� d dl mZ d dlZddlmZ ddlmZ ddlmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZ ddlmZ ejZejZG dd � d e�ZG d
d � d e �Z G d d
� d
ej �Z dd� Z G dd� de j!�Z"G dd� de j#e j$�Z%ddd�Z&dS )� )�absolute_importN� )�_)�sha1nodeconstants) � branchmap� changelog�error� localrepo�manifest�
namespaces�pathutil�pycompat� requirements�url�util�vfs)�urlutilc @ sN e Zd Zdd� Zdd� Zdd� Zdd� Zdd
d �Zd d
� Zdd� Z dd� Z
d S )�httprangereaderc C s || _ d| _|| _|| _d S )Nr )r �pos�opener�name)�selfr r � r �:/usr/lib/python3/dist-packages/mercurial/statichttprepo.py�__init__' s
zhttprangereader.__init__c C s | S �Nr �r r r r � __enter__. � zhttprangereader.__enter__c C s | � � d S r )�close)r �exc_type� exc_value� tracebackr r r �__exit__1 � zhttprangereader.__exit__c C s
|| _ d S r )r )r r r r r �seek4 s
zhttprangereader.seekNc
C s t �t�| j��}d}|r| j| d }| js|r$|�dd| j|f � z| j�|�}|� � }|j
}W n0 t j yQ } z|j
dkrDt
jpEd }t|t|���d }~w t jyc } ztd |j��d }~ww |dkr}|ru|| j| j| � }n|| jd � }n|r�|d |� }| jt|�7 _|S )N� r �Rangez bytes=%d-%si� �� )�urlreq�requestr
�strurlr r �
add_headerr �open�read�code�urlerr� httperror�errno�ENOENT�IOError�str�urlerror�reason�len) r �bytes�req�end�f�datar/ �inst�numr r r r. 7 s4
� �� zhttprangereader.readc C s | � � �d�S )NT)r. �
splitlinesr r r r � readlinesX s zhttprangereader.readlinesc C s t | �� �S r )�iterrA r r r r �__iter__[ r$ zhttprangereader.__iter__c C � d S r r r r r r r ^ r zhttprangereader.closer ) �__name__�
__module__� __qualname__r r r# r% r. rA rC r r r r r r & s
! r c @ s e Zd ZdZdS )� _RangeErrorz6Error raised when an unsatisfiable range is requested.N)rE rF rG �__doc__r r r r rH e s rH c @ s e Zd ZdZdd� Zdd� ZdS )�_HTTPRangeHandlera Handler that enables HTTP Range headers.
This was extremely simple. The Range header is a HTTP feature to
begin with so all this class does is tell urllib2 that the
"206 Partial Content" response from the HTTP server is what we
expected.
c C s" t �|||�� �}||_||_|S r )r) �
addinfourl� get_full_urlr/ �msg)r r: �fpr/ rM �hdrs�rr r r �http_error_206r s z _HTTPRangeHandler.http_error_206c C s t d��)Ns Requested Range Not Satisfiable)rH )r r: rN r/ rM rO r r r �http_error_416y s z _HTTPRangeHandler.http_error_416N)rE rF rG rI rQ rR r r r r rJ i s rJ c s2 t �| |�� � �t� � G � fdd�dtj�}|S )Nc s* e Zd Zdd� Zd � fdd� Zdd� ZdS )
z#build_opener.<locals>.statichttpvfsc S s || _ i | _d S r )�base�options)r rS r r r r � s
z,build_opener.<locals>.statichttpvfs.__init__� rc s0 |dvrt d��d�| jt�|�f�}t|� �S )N)rU s rbs Permission denied� /)r4 �joinrS r) �quoter )r �path�mode�args�kwr< �� urlopenerr r �__call__� s
z,build_opener.<locals>.statichttpvfs.__call__c S s |r t �| j|�S | jS r )r rW rS )r rY r r r rW � s z(build_opener.<locals>.statichttpvfs.joinN)rU )rE rF rG r r_ rW r r] r r �
statichttpvfs� s r` )r r � add_handlerrJ �vfsmod� abstractvfs)�ui�authinfor` r r] r � build_opener~ s rf c @ s e Zd Zdd� Zdd� ZdS )�statichttppeerc C rD r r r r r r �local� r zstatichttppeer.localc C � dS �NFr r r r r �canpush� r zstatichttppeer.canpushN)rE rF rG rh rk r r r r rg � s rg c s` e Zd ZejjZdd� Z� fdd�Zdd� Z dd� Z
d d
� Z dd d
�Z ddd�Z
dd� Z� ZS )�statichttprepositoryc
C s> || _ || _|| _t�|�d�d �}|�� \| _}t||�}|| j�| _ || j �
d��| _ g | _ t
�
� | _d | _d | _t� | _t� | _z t| j �d��� �}W nK ty� } z?|jtjkr_� t� }z| � d�}|�d� |�� W n ty� } z|jtjkr�� td�| } t� | ��d }~ww W Y d }~nd }~ww t j |v r�|| j �
d��}
|t|
�d��� �O }t � |�} t �!|| � t �"||� t#| _$| j$j%| _%t �&|| j|�| _'| j'j| _(| j'j)| _*| j'j
| _+i | _,|| _-t.�/| j$| j*�} t.�0| j*| | | �1� �| _0t2�2| j*�| _2d | _3d | _4t5�6� | _7d | _8d | _9d | _:d | _;d S ) NrV s /.hgs caches requiress
00changelog.ir s+ '%s' does not appear to be an hg repositorys store)<�_urlrd �rootr r �rstripre rY rf r rW �cachevfs�_phasedefaultsr �names�
filtername�_extrafilterid�set�_wanted_sidedata�featuresr. r@ r4 r2 r3 r r r � RepoError�requirementsmod�SHARESAFE_REQUIREMENTr �gathersupportedrequirements� ensurerequirementsrecognized� ensurerequirementscompatibler �
nodeconstants�nullid� makestore�store�spathr �svfs�sjoin�
_filecacher r
�manifestrevlog� manifestlog� narrowmatchr �_tags�
nodetagscacher �BranchMapCache�
_branchcaches�_revbranchcache�
encodepats�
decodepats� _transref)
r rd rY �ure �vfsclassr r> rN rM �storevfs�supportedrequirements� rootmanifestr r r r � s|
�� ���
�
�
z statichttprepository.__init__c s t t| ��|�}|�dg�S )Ns pushkey)�superrl �_restrictcapabilities�
difference)r �caps�� __class__r r r� � s z*statichttprepository._restrictcapabilitiesc C s | j S r )rm r r r r r � s zstatichttprepository.urlc C ri rj r r r r r rh � r zstatichttprepository.localc C s t | �S r )rg r r r r �peer� s zstatichttprepository.peerTc C � t �dtd�dtd����Nr s lock not availables locks" cannot lock static-http repository�r �LockUnavailabler �r �waitr r r �wlock� � �zstatichttprepository.wlockc C r� r� r� r� r r r �lock� r� zstatichttprepository.lockc C rD r r r r r r � _writecaches r z!statichttprepository._writecaches)T)rE rF rG r �localrepository�_basesupported� supportedr r� r rh r� r� r� r� �
__classcell__r r r� r rl � s F
rl c C s$ |r t �td���t| |dd � �S )Ns( cannot create new static-http repository� )r �Abortr rl )rd rY �create�intents�
createoptsr r r �instance s r� )NN)'�
__future__r r2 �i18nr �noder � r r r r r
r r r
r ry r r r rb �utilsr r0 r) �objectr r4 rH � basehandlerrJ rf � localpeerrg r� �revlogfilestoragerl r� r r r r �<module> s" 8 ?
�l