/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-13 14:21:53 UTC
  • Revision ID: tim@ed.am-20160213142153-68g7pzq0au6bejep
fixed init command

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 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
 
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 ):
106
86
                """Obtain some sort of revision identifier
107
87
                """
108
88
 
109
 
                # bzr revno
 
89
                # bzr revert
110
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
 
129
109
                # symlink to a non-existant file)
130
110
                if 'kind changed' in files:
131
111
                        for file in files[ 'kind changed' ]:
132
 
                                matches = re.search( '^(.+?)[/@+]? \([^)]+\)$', file )
 
112
                                matches = re.match( r'(.+?)[/@+]? \([^)]+\)', file )
133
113
                                if not matches:
134
114
                                        raise RunTimeError(
135
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 )
153
133
                # remove unknown files
154
134
                if 'unknown' in files:
155
135
                        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)
 
136
                                if the.verbose >= 2: print "removing (unknown): " + file
162
137
                                full_file = os.path.join( self.dir, file )
163
 
                                if os.path.isfile( full_file ) or os.path.islink( full_file ):
 
138
                                if os.path.isfile( full_file ):
164
139
                                        os.unlink( full_file )
165
140
                                elif os.path.isdir( full_file ):
166
141
                                        shutil.rmtree( full_file )
224
199
 
225
200
                # parse output (see logic in report() in bzrlib/delta.py)
226
201
                files = list()
227
 
                buf = io.StringIO( output )
 
202
                buf = StringIO.StringIO( output )
228
203
                for line in buf:
229
204
                        if not re.search( '^[-R+ ?][K NMD!][* ] ', line ): continue
230
205
                        line = line.rstrip()
 
206
                        if the.verbose >= 2: print '  %s' % line
231
207
 
232
208
                        # renames show before and after file names
233
209
                        matches = re.search( '^R.. (.*?)[/@+]? => (.*?)[/@+]?$', line )
254
230
                return files
255
231
 
256
232
 
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
233
        def has_changes( self ):
271
234
                """Check if the branch has any local modifications.
272
235
                """
305
268
                """
306
269
 
307
270
                # 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
 
271
                self.run( [ 'bzr', 'commit', '-m', '' ] )
317
272
 
318
273
 
319
274
        def run( self, cmd ):
320
 
                if the.verbose >= 2: print('exec: %s' % ' '.join( cmd ))
 
275
                if the.verbose >= 2: print 'exec: %s' % ' '.join( cmd )
321
276
                p = Popen( cmd, cwd = self.dir,
322
277
                                   stdout = subprocess.PIPE, stderr = subprocess.STDOUT )
323
 
                output = p.communicate()[ 0 ].decode()
 
278
                output = p.communicate()[ 0 ]
324
279
                if p.returncode > 0:
325
280
                        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
281
                return output
331
282
 
332
283
 
333
284
        def parse_file_blocks( self, output ):
334
285
                res = dict()
335
286
                current = None
336
 
                buf = io.StringIO( output )
 
287
                buf = StringIO.StringIO( output )
337
288
                for line in buf:
338
289
                        matches = re.search( '^([a-z ]+):$', line, re.I )
339
290
                        if matches: