/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: 2016-02-23 19:35:21 UTC
  • Revision ID: tim@ed.am-20160223193521-2vgtxbfos50rrpku
renamed version -> VERSION

Show diffs side-by-side

added added

removed removed

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