File: //lib64/python2.7/site-packages/hgext/convert/monotone.pyc
�
Hq�Qc @ s� d d l Z d d l Z d d l m Z d d l m Z m Z m Z m Z d d l m Z d d l
m Z d e e f d � � YZ d S( i����N( t util( t NoRepot committ converter_sourcet checktool( t commandline( t _t monotone_sourcec B s� e Z d d d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z
d � Z d � Z d
� Z
d � Z d � Z d
� Z d � Z d � Z d � Z d � Z RS( c
C s| t j | | | | � t j | | d � | | _ | | _ t | _ | | _ t t d � | � } t
j j t
j j | d � � s� y, t
| d � } | j d � } | j � Wn t k
r� d } n X| d k r� | � q� n d } d } | } d
}
d } t j | d | � | _ t j | d
| d |
� | _ t j | d | d |
� | _ t j | d | d |
d |
� | _ t j | d | d | � | _ t j | d | � | _ t j | d | d |
� | _ t j | | d | d | � | _ | d
| | d | } t j | d | d � | _ d | _ d | _ d | _ d | _ t! d d t �d S( Nt mtns+ %s does not look like a monotone repositoryt _MTNt rbi t s SQLite format 3 s \s*s \s+"((?:\\"|[^"])*)"\s*s \s+\[(\w+)\]\s*s (?:.|\n)+t dirt filet contentt add_filet patcht fromt tot renamet deletet tagt revisiont namet valuet attrs
"mtn:execute"s "true"t abort(" R t __init__R t uit patht Falset
automatestdiot revR R t ost existst joinR
t readt closet IOErrort ret compilet dir_ret file_ret add_file_ret patch_ret rename_ret delete_ret tag_ret cert_ret attr_execute_ret Nonet manifest_revt manifestt filest dirsR (
t selfR R R t norepot ft headert spaceR R R t linesR ( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyR sV
!
$"
c O s- | j r | j | | � S| j | | � Sd S( N( R t mtnrunstdiot mtnrunsingle( R7 t argst kwargs( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt mtnrunG s c O s | j | d <| j d | | � S( Nt dt automate( R t run0( R7 R? R@ ( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyR> M s
c O s g } x] | j � D]O \ } } | j d t | � | f � | r | j d t | � | f � q q W| r� | j d d � | j d � n | j d � x( | D] } | d t | � | f 7} q� W| j d � d j | � } | j j d | � | j j | � | j j � | j
| � S( Ns %s:%si t ot et lR s mtn: sending '%s'
( t iteritemst appendt lent insertR# R t debugt
mtnwritefpt writet flusht mtnstdioreadcommandoutput( R7 R? R@ t commandt kt vt arg( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyR= Q s" $
c C s� d } d } xJ | d k rX | j j d � } | sK t j t d � � � n | | 7} q W| d } | j j d � } | d k r� t j t d � | � � n | j j d � } | d k r� t j t d � � � n d } d } xJ | d k r+| j j d � } | s t j t d � � � n | | 7} q� Wy t | d � } Wn* t k
rlt j t d
� | � � n X| j j | � } t | � | k r�t j t d � t | � | f � � n | | | | f S( NR t :i s% bad mtn packet - no end of commandnbri����t mewptls# bad mtn packet - bad stream type %ss' bad mtn packet - no divider before sizes& bad mtn packet - no end of packet sizes# bad mtn packet - bad packet size %ss9 bad mtn packet - unable to read full packet read %s of %s( R2 t mtnreadfpR$ R t AbortR t longt TypeErrorRJ ( R7 R$ t
commandnbrt streamt lengthstrt length( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt mtnstdioreadpacketh s>
c C s g } x� t r | j � \ } } } } | j j d | | | f � | d k r� | d k r~ t j t d � | | f � � n Pq | d k r� | j j t d � | j � | j j | � q | d k r� | j j d | � q | d k r | j | � q q Wd
j
| � S( Ns mtn: read packet %s:%s:%s
RG t 0s mtn command '%s' returned %st ews
%s error:
t ps mtn: t mR ( t TrueR_ R RL R RX R t warnRQ RI R# ( R7 RQ t retvalR[ R\ R^ t output( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyRP � s$ c C s | j | k r d S| j d | � j d � | _ | | _ i | _ i | _ x� | j D]� } | j j | � } | r� d } | j d � } | j d � } | j j | � r� | d 7} n | | f | j | <n | j
j | � } | rV t | j | j d � <qV qV Wd S( Nt get_manifest_ofs
R i i t x( R3 RA t splitR4 R5 R6 R* t matcht groupR1 R) Rd ( R7 R RF Rc R R t node( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt mtnloadmanifest� s$
c C s | j | � | | j k S( N( Rn R5 ( R7 R R ( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt mtnisfile� s
c C s | j | � | | j k S( N( Rn R6 ( R7 R R ( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt mtnisdir� s
c C s� i d d 6d d 6d d 6d d 6} | j d | � } t j d | � } xi | D]a } | j j | � } | rM | j � \ } } | j d d � } | j d
d � } | | | <qM qM W| d j d � d
d | d <| S( Ns <missing>t authort datet changelogt brancht certss
key ["\[]s \"t "s \\s \t .i s UTC( RA R' Rj R0 Rk t groupst replace( R7 R Ru t certlistRF Rc R R ( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt mtngetcerts� s
c C s* | j s | j d � j � S| j g Sd S( Nt leaves( R RA t
splitlines( R7 ( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt getheads� s c C s | j d | � j d � } i } i } g } i } xI| D]A} | j j | � } | r� | | | j d � <| | | j d � <n | j j | � } | r� | | | j d � <n | j j | � } | r� | | | j d � <n | j j | � } | r: | j d � } | j d � }
| j | | � rPd | | <|
| | <| | | <| | |
<q{| j | | � r{| j
|
| f � q{q: q: Wx� | D]� \ } } i }
x[ | j D]P } | | k r�q�n | j | d � r�| | t
| � |
| <d | | <q�q�WxQ |
j � D]C \ } } | j j t d � | | f d � | | | <| | | <qWx |
j � D] } | | | <qWWq�W| j � | f S( Nt get_revisions
i i t /s3 copying file in renamed directory from '%s' to '%s's
( RA Rj R+ Rk Rl R, R. R- Ro Rp RI R5 t
startswithRJ t itemsR RL R t values( R7 R R R5 t
ignoremovet renameddirst copiesRF Rc t tonamet fromnamet fromdirt todirt renamedt tofilet fromfile( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt
getchanges� sV
c C s� | j | | � s t � n y | j d | d | �} Wn t k
rP t � n X| j | � | j j | d � \ } } | | f S( Nt get_file_oft rR ( NR ( Ro R& RA t ExceptionRn R5 t getR2 ( R7 R R t dataRm R ( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt getfile s
c C s� i } | j | � } | j d � | d k r; d | d <n t d | d d t j t j | d d � � d | d d
| d | j d | � j � d | d d | � S(
Nt suspendRt t 1R% Rq Rr s %Y-%m-%dT%H:%M:%St descRs R t parentst extra( R{ R� R R t datestrt strdateRA R} ( R7 R R� Ru ( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt getcommit& s
c C sd i } xW | j d � j d � D]= } | j j | � } | r | j d � | | j d � <q q W| S( Nt tagss
i i ( RA Rj R/ Rk Rl ( R7 R� RF Rc ( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt gettags4 s #c C s
t � d S( N( t NotImplementedError( R7 R t i( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt getchangedfiles< s c C s0 d } y | j d � } t | � } Wn& t k
rM t j t d � � � n X| d k rt | _ | j j d | � | j
d d d | j � \ | _ | _
| j
j � } | d k r� t j t d
� | � � n xT | d k r| j
j � } | s� t j t d � � � q� q� Wn | j j d
| � d S( Ng t interface_versions2 unable to determine mtn automate interface versiong (@s/ mtn automate version %s - using automate stdio
RC t stdios -ds format-version: 2
s( mtn automate stdio header unexpected: %ss
s1 failed to reach end of mtn automate stdio headerss^ mtn automate version %s - not using automate stdio (automate >= 12.0 - mtn >= 0.46 is needed)
( R> t floatR� R RX R Rd R R RL t _run2R RM RW t readline( R7 t versiont
versionstrR$ ( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt beforeA s,
c C s< | j r8 | j j � d | _ | j j � d | _ n d S( N( R RM R% R2 RW ( R7 ( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt aftera s
N( t __name__t
__module__R2 R RA R> R= R_ RP Rn Ro Rp R{ R~ R� R� R� R� R� R� R� ( ( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyR s$ 7 & 8 (
R! R' t mercurialR t commonR R R R R t mercurial.i18nR R ( ( ( s< /usr/lib64/python2.7/site-packages/hgext/convert/monotone.pyt <module> s
"