/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: 2014-04-05 19:22:21 UTC
  • Revision ID: tim@ed.am-20140405192221-yl8xgy3qorbahlfw
implemented CopyInWalker in terms of CopyBaseWalker, changed implementation of
the verbose operation print function for readability

Show diffs side-by-side

added added

removed removed

Lines of Context:
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 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
28
 
34
29
class BzrVcs( Vcs ):
35
30
 
39
34
 
40
35
                @param dir the fully-qualified directory to work in.
41
36
                """
42
 
 
43
37
                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
38
 
60
39
 
61
40
        def init( self ):
106
85
                """Obtain some sort of revision identifier
107
86
                """
108
87
 
109
 
                # bzr revno
 
88
                # bzr revert
110
89
                output = self.run( [ 'bzr', 'revno', '--tree' ] )
111
90
 
112
91
                # parse revno
113
 
                buf = io.StringIO( output )
 
92
                buf = StringIO.StringIO( output )
114
93
                return buf.readline().rstrip()
115
94
 
116
95
 
120
99
                revision.
121
100
                """
122
101
 
123
 
                # bzr st
124
 
                output = self.run( [ 'bzr', 'status' ] )
125
 
                files = self.parse_file_blocks( output )
126
 
 
127
 
                # remove kind changed files (or they can cause `bzr revert` to break in
128
 
                # strange situations, like when a directory has been replaced with a
129
 
                # symlink to a non-existant file)
130
 
                if 'kind changed' in files:
131
 
                        for file in files[ 'kind changed' ]:
132
 
                                matches = re.search( '^(.+?)[/@+]? \([^)]+\)$', file )
133
 
                                if not matches:
134
 
                                        raise RunTimeError(
135
 
                                                'failed to parse bzr kind change: %s' % file )
136
 
                                file = matches.group( 1 )
137
 
                                if the.verbose >= 2: print("removing (kind changed): " + file)
138
 
                                full_file = os.path.join( self.dir, file )
139
 
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
140
 
                                        os.unlink( full_file )
141
 
                                elif os.path.isdir( full_file ):
142
 
                                        shutil.rmtree( full_file )
143
 
                                else:
144
 
                                        raise RuntimeError( 'exotic file in repo: %s' % file )
145
 
 
146
 
                # bzr revert
 
102
                # bzr revert (run twice to handle a bug in bzr where reverting a
 
103
                # directory from a symlink can cause conflicts during initial revert)
 
104
                self.run( [ 'bzr', 'revert', '--no-backup' ] )
147
105
                self.run( [ 'bzr', 'revert', '--no-backup' ] )
148
106
 
149
107
                # bzr st
153
111
                # remove unknown files
154
112
                if 'unknown' in files:
155
113
                        for file in files[ 'unknown' ]:
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)
 
114
                                if the.verbose > 1: print "removing unknown: " + file
162
115
                                full_file = os.path.join( self.dir, file )
163
 
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
 
116
                                if os.path.isfile( full_file ):
164
117
                                        os.unlink( full_file )
165
118
                                elif os.path.isdir( full_file ):
166
119
                                        shutil.rmtree( full_file )
167
120
                                else:
168
121
                                        raise RuntimeError( 'exotic file in repo: %s' % file )
169
122
 
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:
 
123
                # if a revision identifyer has been given, update to that
 
124
                if revno is not None:
172
125
 
173
126
                        # bzr update
174
127
                        self.run( [ 'bzr', 'update', '-r', revno ] )
224
177
 
225
178
                # parse output (see logic in report() in bzrlib/delta.py)
226
179
                files = list()
227
 
                buf = io.StringIO( output )
 
180
                buf = StringIO.StringIO( output )
228
181
                for line in buf:
229
182
                        if not re.search( '^[-R+ ?][K NMD!][* ] ', line ): continue
230
183
                        line = line.rstrip()
 
184
                        if the.verbose > 1: print '  %s' % line
231
185
 
232
186
                        # renames show before and after file names
233
187
                        matches = re.search( '^R.. (.*?)[/@+]? => (.*?)[/@+]?$', line )
249
203
                                continue
250
204
 
251
205
                        raise RuntimeError(
252
 
                                'failed to parse bzr update output line:\n%s' % line )
 
206
                                'failed to parse bzr update output line:\n%' % line )
253
207
 
254
208
                return files
255
209
 
256
210
 
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
211
        def has_changes( self ):
271
212
                """Check if the branch has any local modifications.
272
213
                """
291
232
                return files['conflicts'] if 'conflicts' in files else None
292
233
 
293
234
 
294
 
        def add( self, files ):
295
 
                """Make sure files are added to version control.
296
 
                @param files a list of relative filenames
297
 
                """
298
 
 
299
 
                # bzr add
300
 
                self.run( [ 'bzr', 'add', '-N' ] + files )
301
 
 
302
 
 
303
 
        def commit( self ):
304
 
                """Commit changes to the repo.
305
 
                """
306
 
 
307
 
                # bzr commit
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
317
 
 
318
 
 
319
235
        def run( self, cmd ):
320
 
                if the.verbose >= 2: print('exec: %s' % ' '.join( cmd ))
 
236
                if the.verbose > 1: print 'exec: %s' % ' '.join( cmd )
321
237
                p = Popen( cmd, cwd = self.dir,
322
238
                                   stdout = subprocess.PIPE, stderr = subprocess.STDOUT )
323
 
                output = p.communicate()[ 0 ].decode()
 
239
                output = p.communicate()[ 0 ]
324
240
                if p.returncode > 0:
325
241
                        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 ))
330
242
                return output
331
243
 
332
244
 
333
245
        def parse_file_blocks( self, output ):
334
246
                res = dict()
335
247
                current = None
336
 
                buf = io.StringIO( output )
 
248
                buf = StringIO.StringIO( output )
337
249
                for line in buf:
338
250
                        matches = re.search( '^([a-z ]+):$', line, re.I )
339
251
                        if matches:
346
258
                                                res[ current ] = list()
347
259
                                        res[ current ].append( matches.group( 1 ) )
348
260
                                        continue
349
 
                        if re.search( '^[0-9]+ shel(?:f|ves) exists?', line ): continue
 
261
                        if re.search( '^[0-9]+ shelf exists', line ): continue
350
262
                        if re.search( '^working tree is out of date', line ): continue
351
263
                        raise self.ParseError( "unrecognised line: %s" % line )
352
264
                return res