/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: 2022-06-27 15:43:15 UTC
  • Revision ID: tim@ed.am-20220627154315-jkxty19bjqpbsqk9
reverted brz->bzr

Show diffs side-by-side

added added

removed removed

19
19
# along with this program.  If not, see <http://www.gnu.org/licenses/>.
20
20
 
21
21
 
22
 
import subprocess, os, re, shutil
 
22
import io
 
23
import os
 
24
import re
 
25
import shutil
 
26
import subprocess
23
27
from subprocess import Popen
24
 
import StringIO
25
 
from vcs import Vcs
 
28
 
26
29
from stdhome import the
27
30
 
 
31
from .vcs import Vcs
 
32
 
28
33
 
29
34
class BzrVcs( Vcs ):
30
35
 
36
41
                """
37
42
 
38
43
                self.dir = dir
 
44
                self.ignored_files = [ '.bzr', '.bzrignore' ]
 
45
 
 
46
 
 
47
        def has_authority( self ):
 
48
                """Check that the directory is under this VCS's control.
 
49
                """
 
50
 
 
51
                return os.path.exists( os.path.join( self.dir, '.bzr' ) )
 
52
 
 
53
 
 
54
        def expand_repo_url( self, url ):
 
55
                """Convert a simple hostname in to an URL that the VCS can use.
 
56
                """
 
57
 
 
58
                return 'bzr+ssh://%s/%s/%s' % ( url, the.dir, the.repo.name )
39
59
 
40
60
 
41
61
        def init( self ):
90
110
                output = self.run( [ 'bzr', 'revno', '--tree' ] )
91
111
 
92
112
                # parse revno
93
 
                buf = StringIO.StringIO( output )
 
113
                buf = io.StringIO( output )
94
114
                return buf.readline().rstrip()
95
115
 
96
116
 
114
134
                                        raise RunTimeError(
115
135
                                                'failed to parse bzr kind change: %s' % file )
116
136
                                file = matches.group( 1 )
117
 
                                if the.verbose >= 2: print "removing (kind changed): " + file
 
137
                                if the.verbose >= 2: print("removing (kind changed): " + file)
118
138
                                full_file = os.path.join( self.dir, file )
119
139
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
120
140
                                        os.unlink( full_file )
138
158
                                        raise RunTimeError(
139
159
                                                'failed to parse bzr unknowns: %s' % file )
140
160
                                file = matches.group( 1 )
141
 
                                if the.verbose >= 2: print "removing (unknown): " + file
 
161
                                if the.verbose >= 2: print("removing (unknown): " + file)
142
162
                                full_file = os.path.join( self.dir, file )
143
163
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
144
164
                                        os.unlink( full_file )
204
224
 
205
225
                # parse output (see logic in report() in bzrlib/delta.py)
206
226
                files = list()
207
 
                buf = StringIO.StringIO( output )
 
227
                buf = io.StringIO( output )
208
228
                for line in buf:
209
229
                        if not re.search( '^[-R+ ?][K NMD!][* ] ', line ): continue
210
230
                        line = line.rstrip()
234
254
                return files
235
255
 
236
256
 
 
257
        def status( self ):
 
258
                """Get a list of any local modifications.  This method returns a list of files
 
259
                which are modified.
 
260
 
 
261
                """
 
262
 
 
263
                # bzr status
 
264
                output = self.run( [ 'bzr', 'status', '--no-pending' ] )
 
265
 
 
266
                # parse output
 
267
                return self.parse_file_blocks( output )
 
268
 
 
269
 
237
270
        def has_changes( self ):
238
271
                """Check if the branch has any local modifications.
239
272
                """
272
305
                """
273
306
 
274
307
                # bzr commit
275
 
                self.run( [ 'bzr', 'commit', '-m', '' ] )
 
308
                try:
 
309
                        self.run( [ 'bzr', 'commit', '-m', '' ] )
 
310
                except self.VcsError as e:
 
311
                        if re.search( 'Working tree is out of date', e.output ):
 
312
                                raise the.program.FatalError(
 
313
                                        'you must update your files first.\n' +
 
314
                                        'Hint: see "%s update --help"' % the.program.name );
 
315
                        else:
 
316
                                raise e
276
317
 
277
318
 
278
319
        def run( self, cmd ):
279
 
                if the.verbose >= 2: print 'exec: %s' % ' '.join( cmd )
 
320
                if the.verbose >= 2: print('exec: %s' % ' '.join( cmd ))
280
321
                p = Popen( cmd, cwd = self.dir,
281
322
                                   stdout = subprocess.PIPE, stderr = subprocess.STDOUT )
282
 
                output = p.communicate()[ 0 ]
 
323
                output = p.communicate()[ 0 ].decode()
283
324
                if p.returncode > 0:
284
325
                        raise self.VcsError( ' '.join( cmd[ : 2 ] ), output )
285
326
                if the.verbose >= 2:
286
 
                        print re.sub( '(^|\n)', '\\1  > ', output.rstrip() )
 
327
                        verbose_output = output.rstrip()
 
328
                        if len( verbose_output ):
 
329
                                print(re.sub( '(^|\n)', '\\1  : ', verbose_output ))
287
330
                return output
288
331
 
289
332
 
290
333
        def parse_file_blocks( self, output ):
291
334
                res = dict()
292
335
                current = None
293
 
                buf = StringIO.StringIO( output )
 
336
                buf = io.StringIO( output )
294
337
                for line in buf:
295
338
                        matches = re.search( '^([a-z ]+):$', line, re.I )
296
339
                        if matches: