��Qc@s�dd
lZdd
l
Z
dd
lZdd
lZddlmZmZ
ddlmZ
dZ	dZ
def
d��YZd�Z
d	�Zd
S(
i�N(tutilt	wireproto(
tHTTP_OKsapplication/mercurial-0.1sapplication/hg-errortwebprotoc
BsPeZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	RS(cCs|
|_d
|_
||_dS(Nt(treqtresponsetui(tselfRR((s</sys/lib/python2.7/site-packages/mercurial/hgweb/protocol.pyt__init__s
	
	
cCs�|j�}i}|
j
�}x�|D]{}|d
kr�i}xA|j�D]3}|dkrJ||krJ||d||<qJqJW||d
<q%||d||<q%Wg|D]}||^q�S(Nt
*tcmdi(t_argstsplittkeys(Rtargst	knownargstdataRt
ktstartkey((s</sys/lib/python2.7/site-packages/mercurial/hgweb/protocol.pytgetargss












c
Cs�|jj
j�}
g}d
}xPtrp|jjjdt|��}|dkrVPn||g
7}|d
7}q!W|
jt	j
dj|�dt�
�
|
S(Ni
t
HTTP_X_HGARG_Rtkeep_blank_values(RtformtcopytTruetenvtgettstrtNonetupdatetcgitparse_qstjoin(RRtchunkst
it
h((s</sys/lib/python2.7/site-packages/mercurial/hgweb/protocol.pyR"s



	






%
cCsJt|j
jd
�}x-tj|j
d|�
D]}|
j|�
q/WdS(NtCONTENT_LENGTHtlimit(tintRRRt
filechunkitertwrite(Rtfptlengtht
s((s</sys/lib/python2.7/site-packages/mercurial/hgweb/protocol.pytgetfile.s


c

Cs;|jj
|jjf|_tj�|j_|j_
dS(
N(Rtfouttferrtoldiot	cStringIOtStringIO(
R((s</sys/lib/python2.7/site-packages/mercurial/hgweb/protocol.pytredirect2s

c
Cs1|jj
j�}
|j\|j_|j_
|
S(
N(RR/tgetvalueR1R0(Rtval((s</sys/lib/python2.7/site-packages/mercurial/hgweb/protocol.pytrestore5s


ccsOtj
�}x1tr?|
jd
�}|s.Pn|j|�V
qW|j�V
dS(Ni(tzlibtcompressobjRtreadtcompresstflush(Rtcgt
ztchunk((s</sys/lib/python2.7/site-packages/mercurial/hgweb/protocol.pytgroupchunks9s

	




c

Cs\d
|jj
jd�pdtj|jj
jdd��tj|jj
jdd��fS(Nsremote:%s:%s:%sswsgi.url_schemethttptREMOTE_HOSTRtREMOTE_USER(RRRturllibtquote(
R((s</sys/lib/python2.7/site-packages/mercurial/hgweb/protocol.pyt_clientAs



(
t__name__t
__module__R	RRR.R4R7R@RF(((s</sys/lib/python2.7/site-packages/mercurial/hgweb/protocol.pyRs
							c

Cs
|tj
kS(
N(R
tcommands(
R((s</sys/lib/python2.7/site-packages/mercurial/hgweb/protocol.pytiscmdGs
cCsJ
t|
|j
�}tj|||�}t|t�rP|
jttd
|�

gSt|tj	�ry|
jtt�
|j
St|tj�r�|j�}d|j
|f}|
jttd
|�

gSt|tj�r
|
j�
|j�
d|j
}|
jttd
|�

gSt|tj�rF
|j}|
jttd
|�

gSdS(Ntbodys%d
%ss0
%s
(RRR
tdispatcht
isinstanceRtrespondRtHGTYPEt	streamrestgentpushresR7trestpusherrtdraintooberrortmessaget	HGERRTYPE(trepoRRt
ptrspR6((s</sys/lib/python2.7/site-packages/mercurial/hgweb/protocol.pytcallJs.






















	

(R R2R8RDt	mercurialRR
tcommonRRORXtobjectRRJR\(((s</sys/lib/python2.7/site-packages/mercurial/hgweb/protocol.pyt<module>s0


8