/stdhome

To get this branch, use:
bzr branch http://bzr.ed.am/stdhome

« back to all changes in this revision

Viewing changes to lib/stdhome/vcs/bzr.py

  • Committer: Tim Marston
  • Date: 2014-07-17 18:17:18 UTC
  • Revision ID: tim@ed.am-20140717181718-gxi5lpi8qszsigxf
switch to using bzr+ssh, rather than sftp (to work around broken pimiko)

Show diffs side-by-side

added added

removed removed

Lines of Context:
lib/stdhome/vcs/bzr.py
21
21
 
22
22
import subprocess, os, re, shutil
23
23
from subprocess import Popen
24
 
import io
25
 
from .vcs import Vcs
 
24
import StringIO
 
25
from vcs import Vcs
26
26
from stdhome import the
27
27
 
28
28
 
34
34
 
35
35
                @param dir the fully-qualified directory to work in.
36
36
                """
37
 
 
38
37
                self.dir = dir
39
 
                self.ignored_files = [ '.bzr', '.bzrignore' ]
40
 
 
41
 
 
42
 
        def has_authority( self ):
43
 
                """Check that the directory is under this VCS's control.
44
 
                """
45
 
 
46
 
                return os.path.exists( os.path.join( self.dir, '.bzr' ) )
47
 
 
48
 
 
49
 
        def expand_repo_url( self, url ):
50
 
                """Convert a simple hostname in to an URL that the VCS can use.
51
 
                """
52
 
 
53
 
                return 'bzr+ssh://%s/%s/%s' % ( url, the.dir, the.repo.name )
54
38
 
55
39
 
56
40
        def init( self ):
101
85
                """Obtain some sort of revision identifier
102
86
                """
103
87
 
104
 
                # bzr revno
 
88
                # bzr revert
105
89
                output = self.run( [ 'bzr', 'revno', '--tree' ] )
106
90
 
107
91
                # parse revno
108
 
                buf = io.StringIO( output )
 
92
                buf = StringIO.StringIO( output )
109
93
                return buf.readline().rstrip()
110
94
 
111
95
 
124
108
                # symlink to a non-existant file)
125
109
                if 'kind changed' in files:
126
110
                        for file in files[ 'kind changed' ]:
127
 
                                matches = re.search( '^(.+?)[/@+]? \([^)]+\)$', file )
 
111
                                matches = re.match( r'(.+?)[/@+]? \([^)]+\)', file )
128
112
                                if not matches:
129
113
                                        raise RunTimeError(
130
114
                                                'failed to parse bzr kind change: %s' % file )
131
115
                                file = matches.group( 1 )
132
 
                                if the.verbose >= 2: print("removing (kind changed): " + file)
 
116
                                if the.verbose >= 2: print "removing (kind changed): " + file
133
117
                                full_file = os.path.join( self.dir, file )
134
118
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
135
119
                                        os.unlink( full_file )
148
132
                # remove unknown files
149
133
                if 'unknown' in files:
150
134
                        for file in files[ 'unknown' ]:
151
 
                                matches = re.search( r'^(.+?)[/@+]?$', file )
152
 
                                if not matches:
153
 
                                        raise RunTimeError(
154
 
                                                'failed to parse bzr unknowns: %s' % file )
155
 
                                file = matches.group( 1 )
156
 
                                if the.verbose >= 2: print("removing (unknown): " + file)
 
135
                                if the.verbose >= 2: print "removing (unknown): " + file
157
136
                                full_file = os.path.join( self.dir, file )
158
 
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
 
137
                                if os.path.isfile( full_file ):
159
138
                                        os.unlink( full_file )
160
139
                                elif os.path.isdir( full_file ):
161
140
                                        shutil.rmtree( full_file )
162
141
                                else:
163
142
                                        raise RuntimeError( 'exotic file in repo: %s' % file )
164
143
 
165
 
                # if a revision identifier has been given, ensure we're updated to that
166
 
                if revno is not None and self.get_revno() != revno:
 
144
                # if a revision identifyer has been given, update to that
 
145
                if revno is not None:
167
146
 
168
147
                        # bzr update
169
148
                        self.run( [ 'bzr', 'update', '-r', revno ] )
219
198
 
220
199
                # parse output (see logic in report() in bzrlib/delta.py)
221
200
                files = list()
222
 
                buf = io.StringIO( output )
 
201
                buf = StringIO.StringIO( output )
223
202
                for line in buf:
224
203
                        if not re.search( '^[-R+ ?][K NMD!][* ] ', line ): continue
225
204
                        line = line.rstrip()
 
205
                        if the.verbose >= 2: print '  %s' % line
226
206
 
227
207
                        # renames show before and after file names
228
208
                        matches = re.search( '^R.. (.*?)[/@+]? => (.*?)[/@+]?$', line )
279
259
                """
280
260
 
281
261
                # bzr add
282
 
                self.run( [ 'bzr', 'add', '-N' ] + files )
 
262
                self.run( [ 'bzr', 'add' ] + files )
283
263
 
284
264
 
285
265
        def commit( self ):
287
267
                """
288
268
 
289
269
                # bzr commit
290
 
                try:
291
 
                        self.run( [ 'bzr', 'commit', '-m', '' ] )
292
 
                except self.VcsError as e:
293
 
                        if re.search( 'Working tree is out of date', e.output ):
294
 
                                raise the.program.FatalError(
295
 
                                        'you must update your files first.\n' +
296
 
                                        'Hint: see "%s update --help"' % the.program.name );
297
 
                        else:
298
 
                                raise e
 
270
                self.run( [ 'bzr', 'commit', '-m', '' ] )
299
271
 
300
272
 
301
273
        def run( self, cmd ):
302
 
                if the.verbose >= 2: print('exec: %s' % ' '.join( cmd ))
 
274
                if the.verbose >= 2: print 'exec: %s' % ' '.join( cmd )
303
275
                p = Popen( cmd, cwd = self.dir,
304
276
                                   stdout = subprocess.PIPE, stderr = subprocess.STDOUT )
305
 
                output = p.communicate()[ 0 ].decode()
 
277
                output = p.communicate()[ 0 ]
306
278
                if p.returncode > 0:
307
279
                        raise self.VcsError( ' '.join( cmd[ : 2 ] ), output )
308
 
                if the.verbose >= 2:
309
 
                        verbose_output = output.rstrip()
310
 
                        if len( verbose_output ):
311
 
                                print(re.sub( '(^|\n)', '\\1  : ', verbose_output ))
312
280
                return output
313
281
 
314
282
 
315
283
        def parse_file_blocks( self, output ):
316
284
                res = dict()
317
285
                current = None
318
 
                buf = io.StringIO( output )
 
286
                buf = StringIO.StringIO( output )
319
287
                for line in buf:
320
288
                        matches = re.search( '^([a-z ]+):$', line, re.I )
321
289
                        if matches: