/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/brz.py

  • Committer: Tim Marston
  • Date: 2021-09-01 12:28:59 UTC
  • Revision ID: tim@ed.am-20210901122859-tkvlmry7hef8ahwc
moved bzr -> brz

Show diffs side-by-side

added added

removed removed

lib/stdhome/vcs/brz.py
1
 
# bzr.py
 
1
# brz.py
2
2
#
3
3
# Copyright (C) 2014 Tim Marston <tim@edm.am>
4
4
#
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
 
36
36
                """
37
37
 
38
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 )
39
54
 
40
55
 
41
56
        def init( self ):
45
60
                # the directory shouldn't exist
46
61
                os.mkdir( self.dir )
47
62
 
48
 
                # bzr init
 
63
                # brz init
49
64
                try:
50
 
                        self.run( [ 'bzr', 'init', '.' ] )
 
65
                        self.run( [ 'brz', 'init', '.' ] )
51
66
                except self.VcsError as e:
52
67
 
53
68
                        # attempt to clean-up dir
68
83
                # the directory shouldn't exist
69
84
                os.mkdir( self.dir )
70
85
 
71
 
                # bzr co
 
86
                # brz co
72
87
                try:
73
 
                        self.run( [ 'bzr', 'checkout', url, '.' ] )
 
88
                        self.run( [ 'brz', 'checkout', url, '.' ] )
74
89
                except self.VcsError as e:
75
90
 
76
91
                        # attempt to clean-up dir
86
101
                """Obtain some sort of revision identifier
87
102
                """
88
103
 
89
 
                # bzr revert
90
 
                output = self.run( [ 'bzr', 'revno', '--tree' ] )
 
104
                # brz revno
 
105
                output = self.run( [ 'brz', 'revno', '--tree' ] )
91
106
 
92
107
                # parse revno
93
 
                buf = StringIO.StringIO( output )
 
108
                buf = io.StringIO( output )
94
109
                return buf.readline().rstrip()
95
110
 
96
111
 
100
115
                revision.
101
116
                """
102
117
 
103
 
                # bzr st
104
 
                output = self.run( [ 'bzr', 'status' ] )
 
118
                # brz st
 
119
                output = self.run( [ 'brz', 'status' ] )
105
120
                files = self.parse_file_blocks( output )
106
121
 
107
 
                # remove kind changed files (or they can cause `bzr revert` to break in
 
122
                # remove kind changed files (or they can cause `brz revert` to break in
108
123
                # strange situations, like when a directory has been replaced with a
109
124
                # symlink to a non-existant file)
110
125
                if 'kind changed' in files:
111
126
                        for file in files[ 'kind changed' ]:
112
 
                                matches = re.match( r'(.+?)[/@+]? \([^)]+\)', file )
 
127
                                matches = re.search( '^(.+?)[/@+]? \([^)]+\)$', file )
113
128
                                if not matches:
114
129
                                        raise RunTimeError(
115
 
                                                'failed to parse bzr kind change: %s' % file )
 
130
                                                'failed to parse brz kind change: %s' % file )
116
131
                                file = matches.group( 1 )
117
 
                                if the.verbose >= 2: print "removing (kind changed): " + file
 
132
                                if the.verbose >= 2: print("removing (kind changed): " + file)
118
133
                                full_file = os.path.join( self.dir, file )
119
134
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
120
135
                                        os.unlink( full_file )
123
138
                                else:
124
139
                                        raise RuntimeError( 'exotic file in repo: %s' % file )
125
140
 
126
 
                # bzr revert
127
 
                self.run( [ 'bzr', 'revert', '--no-backup' ] )
 
141
                # brz revert
 
142
                self.run( [ 'brz', 'revert', '--no-backup' ] )
128
143
 
129
 
                # bzr st
130
 
                output = self.run( [ 'bzr', 'status' ] )
 
144
                # brz st
 
145
                output = self.run( [ 'brz', 'status' ] )
131
146
                files = self.parse_file_blocks( output )
132
147
 
133
148
                # remove unknown files
134
149
                if 'unknown' in files:
135
150
                        for file in files[ 'unknown' ]:
136
 
                                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 brz unknowns: %s' % file )
 
155
                                file = matches.group( 1 )
 
156
                                if the.verbose >= 2: print("removing (unknown): " + file)
137
157
                                full_file = os.path.join( self.dir, file )
138
 
                                if os.path.isfile( full_file ):
 
158
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
139
159
                                        os.unlink( full_file )
140
160
                                elif os.path.isdir( full_file ):
141
161
                                        shutil.rmtree( full_file )
145
165
                # if a revision identifier has been given, ensure we're updated to that
146
166
                if revno is not None and self.get_revno() != revno:
147
167
 
148
 
                        # bzr update
149
 
                        self.run( [ 'bzr', 'update', '-r', revno ] )
 
168
                        # brz update
 
169
                        self.run( [ 'brz', 'update', '-r', revno ] )
150
170
 
151
171
 
152
172
        def update( self ):
155
175
                operation.
156
176
                """
157
177
 
158
 
#               WARNING: the following might cause bzr to ask for your ssh password more than
 
178
#               WARNING: the following might cause brz to ask for your ssh password more than
159
179
#               once during an update!!!
160
180
#
161
181
#               # get revno
162
182
#               revno = self.get_revno()
163
183
#
164
184
#               # update to current revision (pull in history without updating tree)
165
 
#               self.run( [ 'bzr', 'update', '-r', revno ] )
 
185
#               self.run( [ 'brz', 'update', '-r', revno ] )
166
186
#
167
187
#               # get log output
168
188
#               next_revno = str( int( revno ) + 1 )
169
 
#               output = self.run( [ 'bzr', 'log', '-r', next_revno + '..' ] )
 
189
#               output = self.run( [ 'brz', 'log', '-r', next_revno + '..' ] )
170
190
#
171
191
#               # parse output
172
192
#               keep_files = list()
194
214
#                                                       rename_from = rename_files[ rename_from ]
195
215
#                                               rename_files[ line[ 4 : ] ] = rename_from
196
216
 
197
 
                # bzr update properly
198
 
                output = self.run( [ 'bzr', 'update' ] )
 
217
                # brz update properly
 
218
                output = self.run( [ 'brz', 'update' ] )
199
219
 
200
220
                # parse output (see logic in report() in bzrlib/delta.py)
201
221
                files = list()
202
 
                buf = StringIO.StringIO( output )
 
222
                buf = io.StringIO( output )
203
223
                for line in buf:
204
224
                        if not re.search( '^[-R+ ?][K NMD!][* ] ', line ): continue
205
225
                        line = line.rstrip()
206
 
                        if the.verbose >= 2: print '  %s' % line
207
226
 
208
227
                        # renames show before and after file names
209
228
                        matches = re.search( '^R.. (.*?)[/@+]? => (.*?)[/@+]?$', line )
225
244
                                continue
226
245
 
227
246
                        raise RuntimeError(
228
 
                                'failed to parse bzr update output line:\n%s' % line )
 
247
                                'failed to parse brz update output line:\n%s' % line )
229
248
 
230
249
                return files
231
250
 
232
251
 
 
252
        def status( self ):
 
253
                """Get a list of any local modifications.  This method returns a list of files
 
254
                which are modified.
 
255
 
 
256
                """
 
257
 
 
258
                # bzr status
 
259
                output = self.run( [ 'bzr', 'status', '--no-pending' ] )
 
260
 
 
261
                # parse output
 
262
                return self.parse_file_blocks( output )
 
263
 
 
264
 
233
265
        def has_changes( self ):
234
266
                """Check if the branch has any local modifications.
235
267
                """
236
268
 
237
 
                # bzr status
238
 
                output = self.run( [ 'bzr', 'status', '--no-pending' ] )
 
269
                # brz status
 
270
                output = self.run( [ 'brz', 'status', '--no-pending' ] )
239
271
 
240
272
                # parse output
241
273
                files = self.parse_file_blocks( output )
246
278
                """Return a list of files that have conflicts.
247
279
                """
248
280
 
249
 
                # bzr status
250
 
                output = self.run( [ 'bzr', 'status', '--no-pending' ] )
 
281
                # brz status
 
282
                output = self.run( [ 'brz', 'status', '--no-pending' ] )
251
283
 
252
284
                # parse output
253
285
                files = self.parse_file_blocks( output )
259
291
                @param files a list of relative filenames
260
292
                """
261
293
 
262
 
                # bzr add
263
 
                self.run( [ 'bzr', 'add', '-N' ] + files )
 
294
                # brz add
 
295
                self.run( [ 'brz', 'add', '-N' ] + files )
264
296
 
265
297
 
266
298
        def commit( self ):
267
299
                """Commit changes to the repo.
268
300
                """
269
301
 
270
 
                # bzr commit
271
 
                self.run( [ 'bzr', 'commit', '-m', '' ] )
 
302
                # brz commit
 
303
                try:
 
304
                        self.run( [ 'brz', 'commit', '-m', '' ] )
 
305
                except self.VcsError as e:
 
306
                        if re.search( 'Working tree is out of date', e.output ):
 
307
                                raise the.program.FatalError(
 
308
                                        'you must update your files first.\n' +
 
309
                                        'Hint: see "%s update --help"' % the.program.name );
 
310
                        else:
 
311
                                raise e
272
312
 
273
313
 
274
314
        def run( self, cmd ):
275
 
                if the.verbose >= 2: print 'exec: %s' % ' '.join( cmd )
 
315
                if the.verbose >= 2: print('exec: %s' % ' '.join( cmd ))
276
316
                p = Popen( cmd, cwd = self.dir,
277
317
                                   stdout = subprocess.PIPE, stderr = subprocess.STDOUT )
278
 
                output = p.communicate()[ 0 ]
 
318
                output = p.communicate()[ 0 ].decode()
279
319
                if p.returncode > 0:
280
320
                        raise self.VcsError( ' '.join( cmd[ : 2 ] ), output )
 
321
                if the.verbose >= 2:
 
322
                        verbose_output = output.rstrip()
 
323
                        if len( verbose_output ):
 
324
                                print(re.sub( '(^|\n)', '\\1  : ', verbose_output ))
281
325
                return output
282
326
 
283
327
 
284
328
        def parse_file_blocks( self, output ):
285
329
                res = dict()
286
330
                current = None
287
 
                buf = StringIO.StringIO( output )
 
331
                buf = io.StringIO( output )
288
332
                for line in buf:
289
333
                        matches = re.search( '^([a-z ]+):$', line, re.I )
290
334
                        if matches: