/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:55:15 UTC
  • Revision ID: tim@ed.am-20210901125515-i6b5rxcrceofwm1e
updates for bzr->bzr filename change

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