/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
 
99
115
                revision.
100
116
                """
101
117
 
 
118
                # bzr st
 
119
                output = self.run( [ 'bzr', 'status' ] )
 
120
                files = self.parse_file_blocks( output )
 
121
 
 
122
                # remove kind changed files (or they can cause `bzr revert` to break in
 
123
                # strange situations, like when a directory has been replaced with a
 
124
                # symlink to a non-existant file)
 
125
                if 'kind changed' in files:
 
126
                        for file in files[ 'kind changed' ]:
 
127
                                matches = re.search( '^(.+?)[/@+]? \([^)]+\)$', file )
 
128
                                if not matches:
 
129
                                        raise RunTimeError(
 
130
                                                'failed to parse bzr kind change: %s' % file )
 
131
                                file = matches.group( 1 )
 
132
                                if the.verbose >= 2: print("removing (kind changed): " + file)
 
133
                                full_file = os.path.join( self.dir, file )
 
134
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
 
135
                                        os.unlink( full_file )
 
136
                                elif os.path.isdir( full_file ):
 
137
                                        shutil.rmtree( full_file )
 
138
                                else:
 
139
                                        raise RuntimeError( 'exotic file in repo: %s' % file )
 
140
 
102
141
                # bzr revert
103
142
                self.run( [ 'bzr', 'revert', '--no-backup' ] )
104
143
 
109
148
                # remove unknown files
110
149
                if 'unknown' in files:
111
150
                        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)
112
157
                                full_file = os.path.join( self.dir, file )
113
 
                                if os.path.isfile( full_file ):
 
158
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
114
159
                                        os.unlink( full_file )
115
 
                                elif os.full_file.isdir( full_file ):
 
160
                                elif os.path.isdir( full_file ):
116
161
                                        shutil.rmtree( full_file )
117
162
                                else:
118
163
                                        raise RuntimeError( 'exotic file in repo: %s' % file )
119
164
 
120
 
                # if a revision identifyer has been given, update to that
121
 
                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:
122
167
 
123
168
                        # bzr update
124
169
                        self.run( [ 'bzr', 'update', '-r', revno ] )
174
219
 
175
220
                # parse output (see logic in report() in bzrlib/delta.py)
176
221
                files = list()
177
 
                buf = StringIO.StringIO( output )
 
222
                buf = io.StringIO( output )
178
223
                for line in buf:
179
224
                        if not re.search( '^[-R+ ?][K NMD!][* ] ', line ): continue
180
225
                        line = line.rstrip()
181
 
                        if the.verbose > 1: print '  %s' % line
182
226
 
183
227
                        # renames show before and after file names
184
228
                        matches = re.search( '^R.. (.*?)[/@+]? => (.*?)[/@+]?$', line )
200
244
                                continue
201
245
 
202
246
                        raise RuntimeError(
203
 
                                'failed to parse bzr update output line:\n%' % line )
 
247
                                'failed to parse bzr update output line:\n%s' % line )
204
248
 
205
249
                return files
206
250
 
229
273
                return files['conflicts'] if 'conflicts' in files else None
230
274
 
231
275
 
 
276
        def add( self, files ):
 
277
                """Make sure files are added to version control.
 
278
                @param files a list of relative filenames
 
279
                """
 
280
 
 
281
                # bzr add
 
282
                self.run( [ 'bzr', 'add', '-N' ] + files )
 
283
 
 
284
 
 
285
        def commit( self ):
 
286
                """Commit changes to the repo.
 
287
                """
 
288
 
 
289
                # 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
 
299
 
 
300
 
232
301
        def run( self, cmd ):
233
 
                if the.verbose > 1: print 'exec: %s' % ' '.join( cmd )
 
302
                if the.verbose >= 2: print('exec: %s' % ' '.join( cmd ))
234
303
                p = Popen( cmd, cwd = self.dir,
235
304
                                   stdout = subprocess.PIPE, stderr = subprocess.STDOUT )
236
 
                output = p.communicate()[ 0 ]
 
305
                output = p.communicate()[ 0 ].decode()
237
306
                if p.returncode > 0:
238
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 ))
239
312
                return output
240
313
 
241
314
 
242
315
        def parse_file_blocks( self, output ):
243
316
                res = dict()
244
317
                current = None
245
 
                buf = StringIO.StringIO( output )
 
318
                buf = io.StringIO( output )
246
319
                for line in buf:
247
320
                        matches = re.search( '^([a-z ]+):$', line, re.I )
248
321
                        if matches:
255
328
                                                res[ current ] = list()
256
329
                                        res[ current ].append( matches.group( 1 ) )
257
330
                                        continue
258
 
                        if re.search( '^[0-9]+ shelf exists', line ): continue
 
331
                        if re.search( '^[0-9]+ shel(?:f|ves) exists?', line ): continue
259
332
                        if re.search( '^working tree is out of date', line ): continue
260
333
                        raise self.ParseError( "unrecognised line: %s" % line )
261
334
                return res