/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:47:18 UTC
  • Revision ID: tim@ed.am-20220627154718-coj4in7pqgl3c8lr
updated Makefile for previous commit

Show diffs side-by-side

added added

removed removed

lib/stdhome/vcs/bzr.py
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
 
34
39
 
35
40
                @param dir the fully-qualified directory to work in.
36
41
                """
 
42
 
37
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 )
38
59
 
39
60
 
40
61
        def init( self ):
85
106
                """Obtain some sort of revision identifier
86
107
                """
87
108
 
88
 
                # bzr revert
 
109
                # bzr revno
89
110
                output = self.run( [ 'bzr', 'revno', '--tree' ] )
90
111
 
91
112
                # parse revno
92
 
                buf = StringIO.StringIO( output )
 
113
                buf = io.StringIO( output )
93
114
                return buf.readline().rstrip()
94
115
 
95
116
 
108
129
                # symlink to a non-existant file)
109
130
                if 'kind changed' in files:
110
131
                        for file in files[ 'kind changed' ]:
111
 
                                matches = re.match( r'(.+?)[/@+]? \([^)]+\)', file )
 
132
                                matches = re.search( '^(.+?)[/@+]? \([^)]+\)$', file )
112
133
                                if not matches:
113
134
                                        raise RunTimeError(
114
135
                                                'failed to parse bzr kind change: %s' % file )
115
136
                                file = matches.group( 1 )
116
 
                                if the.verbose >= 2: print "removing (kind changed): " + file
 
137
                                if the.verbose >= 2: print("removing (kind changed): " + file)
117
138
                                full_file = os.path.join( self.dir, file )
118
139
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
119
140
                                        os.unlink( full_file )
132
153
                # remove unknown files
133
154
                if 'unknown' in files:
134
155
                        for file in files[ 'unknown' ]:
135
 
                                if the.verbose >= 2: print "removing (unknown): " + file
 
156
                                matches = re.search( r'^(.+?)[/@+]?$', file )
 
157
                                if not matches:
 
158
                                        raise RunTimeError(
 
159
                                                'failed to parse bzr unknowns: %s' % file )
 
160
                                file = matches.group( 1 )
 
161
                                if the.verbose >= 2: print("removing (unknown): " + file)
136
162
                                full_file = os.path.join( self.dir, file )
137
 
                                if os.path.isfile( full_file ):
 
163
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
138
164
                                        os.unlink( full_file )
139
165
                                elif os.path.isdir( full_file ):
140
166
                                        shutil.rmtree( full_file )
141
167
                                else:
142
168
                                        raise RuntimeError( 'exotic file in repo: %s' % file )
143
169
 
144
 
                # if a revision identifyer has been given, update to that
145
 
                if revno is not None:
 
170
                # if a revision identifier has been given, ensure we're updated to that
 
171
                if revno is not None and self.get_revno() != revno:
146
172
 
147
173
                        # bzr update
148
174
                        self.run( [ 'bzr', 'update', '-r', revno ] )
198
224
 
199
225
                # parse output (see logic in report() in bzrlib/delta.py)
200
226
                files = list()
201
 
                buf = StringIO.StringIO( output )
 
227
                buf = io.StringIO( output )
202
228
                for line in buf:
203
229
                        if not re.search( '^[-R+ ?][K NMD!][* ] ', line ): continue
204
230
                        line = line.rstrip()
205
 
                        if the.verbose >= 2: print '  %s' % line
206
231
 
207
232
                        # renames show before and after file names
208
233
                        matches = re.search( '^R.. (.*?)[/@+]? => (.*?)[/@+]?$', line )
229
254
                return files
230
255
 
231
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
 
232
270
        def has_changes( self ):
233
271
                """Check if the branch has any local modifications.
234
272
                """
259
297
                """
260
298
 
261
299
                # bzr add
262
 
                self.run( [ 'bzr', 'add' ] + files )
 
300
                self.run( [ 'bzr', 'add', '-N' ] + files )
263
301
 
264
302
 
265
303
        def commit( self ):
267
305
                """
268
306
 
269
307
                # bzr commit
270
 
                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
271
317
 
272
318
 
273
319
        def run( self, cmd ):
274
 
                if the.verbose >= 2: print 'exec: %s' % ' '.join( cmd )
 
320
                if the.verbose >= 2: print('exec: %s' % ' '.join( cmd ))
275
321
                p = Popen( cmd, cwd = self.dir,
276
322
                                   stdout = subprocess.PIPE, stderr = subprocess.STDOUT )
277
 
                output = p.communicate()[ 0 ]
 
323
                output = p.communicate()[ 0 ].decode()
278
324
                if p.returncode > 0:
279
325
                        raise self.VcsError( ' '.join( cmd[ : 2 ] ), output )
 
326
                if the.verbose >= 2:
 
327
                        verbose_output = output.rstrip()
 
328
                        if len( verbose_output ):
 
329
                                print(re.sub( '(^|\n)', '\\1  : ', verbose_output ))
280
330
                return output
281
331
 
282
332
 
283
333
        def parse_file_blocks( self, output ):
284
334
                res = dict()
285
335
                current = None
286
 
                buf = StringIO.StringIO( output )
 
336
                buf = io.StringIO( output )
287
337
                for line in buf:
288
338
                        matches = re.search( '^([a-z ]+):$', line, re.I )
289
339
                        if matches: