/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: 2021-07-05 19:14:32 UTC
  • Revision ID: tim@ed.am-20210705191432-243ayb7s2nmussvi
python3ification

Show diffs side-by-side

added added

removed removed

lib/stdhome/vcs/bzr.py
21
21
 
22
22
import subprocess, os, re, shutil
23
23
from subprocess import Popen
24
 
import StringIO
25
 
from vcs import Vcs
 
24
import io
 
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
 
37
38
                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 )
38
54
 
39
55
 
40
56
        def init( self ):
85
101
                """Obtain some sort of revision identifier
86
102
                """
87
103
 
88
 
                # bzr revert
 
104
                # bzr revno
89
105
                output = self.run( [ 'bzr', 'revno', '--tree' ] )
90
106
 
91
107
                # parse revno
92
 
                buf = StringIO.StringIO( output )
 
108
                buf = io.StringIO( output )
93
109
                return buf.readline().rstrip()
94
110
 
95
111
 
108
124
                # symlink to a non-existant file)
109
125
                if 'kind changed' in files:
110
126
                        for file in files[ 'kind changed' ]:
111
 
                                matches = re.match( r'(.+?)[/@+]? \([^)]+\)', file )
 
127
                                matches = re.search( '^(.+?)[/@+]? \([^)]+\)$', file )
112
128
                                if not matches:
113
129
                                        raise RunTimeError(
114
130
                                                'failed to parse bzr kind change: %s' % file )
115
131
                                file = matches.group( 1 )
116
 
                                if the.verbose >= 2: print "removing (kind changed): " + file
 
132
                                if the.verbose >= 2: print("removing (kind changed): " + file)
117
133
                                full_file = os.path.join( self.dir, file )
118
134
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
119
135
                                        os.unlink( full_file )
132
148
                # remove unknown files
133
149
                if 'unknown' in files:
134
150
                        for file in files[ 'unknown' ]:
135
 
                                if the.verbose >= 2: print "removing (unknown): " + file
 
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)
136
157
                                full_file = os.path.join( self.dir, file )
137
 
                                if os.path.isfile( full_file ):
 
158
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
138
159
                                        os.unlink( full_file )
139
160
                                elif os.path.isdir( full_file ):
140
161
                                        shutil.rmtree( full_file )
141
162
                                else:
142
163
                                        raise RuntimeError( 'exotic file in repo: %s' % file )
143
164
 
144
 
                # if a revision identifyer has been given, update to that
145
 
                if revno is not None:
 
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:
146
167
 
147
168
                        # bzr update
148
169
                        self.run( [ 'bzr', 'update', '-r', revno ] )
198
219
 
199
220
                # parse output (see logic in report() in bzrlib/delta.py)
200
221
                files = list()
201
 
                buf = StringIO.StringIO( output )
 
222
                buf = io.StringIO( output )
202
223
                for line in buf:
203
224
                        if not re.search( '^[-R+ ?][K NMD!][* ] ', line ): continue
204
225
                        line = line.rstrip()
205
 
                        if the.verbose >= 2: print '  %s' % line
206
226
 
207
227
                        # renames show before and after file names
208
228
                        matches = re.search( '^R.. (.*?)[/@+]? => (.*?)[/@+]?$', line )
259
279
                """
260
280
 
261
281
                # bzr add
262
 
                self.run( [ 'bzr', 'add' ] + files )
 
282
                self.run( [ 'bzr', 'add', '-N' ] + files )
263
283
 
264
284
 
265
285
        def commit( self ):
267
287
                """
268
288
 
269
289
                # bzr commit
270
 
                self.run( [ 'bzr', 'commit', '-m', '' ] )
 
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
271
299
 
272
300
 
273
301
        def run( self, cmd ):
274
 
                if the.verbose >= 2: print 'exec: %s' % ' '.join( cmd )
 
302
                if the.verbose >= 2: print('exec: %s' % ' '.join( cmd ))
275
303
                p = Popen( cmd, cwd = self.dir,
276
304
                                   stdout = subprocess.PIPE, stderr = subprocess.STDOUT )
277
 
                output = p.communicate()[ 0 ]
 
305
                output = p.communicate()[ 0 ].decode()
278
306
                if p.returncode > 0:
279
307
                        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 ))
280
312
                return output
281
313
 
282
314
 
283
315
        def parse_file_blocks( self, output ):
284
316
                res = dict()
285
317
                current = None
286
 
                buf = StringIO.StringIO( output )
 
318
                buf = io.StringIO( output )
287
319
                for line in buf:
288
320
                        matches = re.search( '^([a-z ]+):$', line, re.I )
289
321
                        if matches: