~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: Martin Pool
  • Date: 2005-09-13 05:22:41 UTC
  • Revision ID: mbp@sourcefrog.net-20050913052241-52dbd8e8ced620f6
- better BZR_DEBUG trace output

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2006 Canonical Ltd
2
 
#
 
1
# Copyright (C) 2004, 2005 by Canonical Ltd
 
2
 
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
5
5
# the Free Software Foundation; either version 2 of the License, or
6
6
# (at your option) any later version.
7
 
#
 
7
 
8
8
# This program is distributed in the hope that it will be useful,
9
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
11
11
# GNU General Public License for more details.
12
 
#
 
12
 
13
13
# You should have received a copy of the GNU General Public License
14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
18
18
# TODO: probably should say which arguments are candidates for glob
19
19
# expansion on windows and do that at the command level.
20
20
 
 
21
# TODO: Help messages for options.
 
22
 
21
23
# TODO: Define arguments by objects, rather than just using names.
22
24
# Those objects can specify the expected type of the argument, which
23
 
# would help with validation and shell completion.  They could also provide
24
 
# help/explanation for that argument in a structured way.
25
 
 
26
 
# TODO: Specific "examples" property on commands for consistent formatting.
27
 
 
28
 
# TODO: "--profile=cum", to change sort order.  Is there any value in leaving
29
 
# the profile output behind so it can be interactively examined?
30
 
 
 
25
# would help with validation and shell completion.
 
26
 
 
27
 
 
28
 
 
29
import sys
31
30
import os
32
 
import sys
33
 
 
34
 
from bzrlib.lazy_import import lazy_import
35
 
lazy_import(globals(), """
36
 
import codecs
37
 
import errno
38
31
from warnings import warn
 
32
from inspect import getdoc
39
33
 
40
34
import bzrlib
41
 
from bzrlib import (
42
 
    errors,
43
 
    option,
44
 
    osutils,
45
 
    trace,
46
 
    )
47
 
""")
48
 
 
49
 
from bzrlib.symbol_versioning import (
50
 
    deprecated_function,
51
 
    deprecated_method,
52
 
    zero_eight,
53
 
    zero_eleven,
54
 
    )
55
 
# Compatibility
56
 
from bzrlib.option import Option
57
 
 
 
35
import bzrlib.trace
 
36
from bzrlib.trace import mutter, note, log_error, warning
 
37
from bzrlib.errors import BzrError, BzrCheckError, BzrCommandError
 
38
from bzrlib.branch import find_branch
 
39
from bzrlib import BZRDIR
58
40
 
59
41
plugin_cmds = {}
60
42
 
61
43
 
62
 
def register_command(cmd, decorate=False):
63
 
    """Utility function to help register a command
64
 
 
65
 
    :param cmd: Command subclass to register
66
 
    :param decorate: If true, allow overriding an existing command
67
 
        of the same name; the old command is returned by this function.
68
 
        Otherwise it is an error to try to override an existing command.
69
 
    """
 
44
def register_command(cmd):
 
45
    "Utility function to help register a command"
70
46
    global plugin_cmds
71
47
    k = cmd.__name__
72
48
    if k.startswith("cmd_"):
73
49
        k_unsquished = _unsquish_command_name(k)
74
50
    else:
75
51
        k_unsquished = k
76
 
    if k_unsquished not in plugin_cmds:
77
 
        plugin_cmds[k_unsquished] = cmd
78
 
        trace.mutter('registered plugin command %s', k_unsquished)
79
 
        if decorate and k_unsquished in builtin_command_names():
80
 
            return _builtin_commands()[k_unsquished]
81
 
    elif decorate:
82
 
        result = plugin_cmds[k_unsquished]
83
 
        plugin_cmds[k_unsquished] = cmd
84
 
        return result
 
52
    if not plugin_cmds.has_key(k_unsquished):
 
53
        plugin_cmds[k_unsquished] = cmd
 
54
        mutter('registered plugin command %s', k_unsquished)      
85
55
    else:
86
 
        trace.log_error('Two plugins defined the same command: %r' % k)
87
 
        trace.log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
 
56
        log_error('Two plugins defined the same command: %r' % k)
 
57
        log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
88
58
 
89
59
 
90
60
def _squish_command_name(cmd):
96
66
    return cmd[4:].replace('_','-')
97
67
 
98
68
 
 
69
def _parse_revision_str(revstr):
 
70
    """This handles a revision string -> revno.
 
71
 
 
72
    This always returns a list.  The list will have one element for 
 
73
 
 
74
    It supports integers directly, but everything else it
 
75
    defers for passing to Branch.get_revision_info()
 
76
 
 
77
    >>> _parse_revision_str('234')
 
78
    [234]
 
79
    >>> _parse_revision_str('234..567')
 
80
    [234, 567]
 
81
    >>> _parse_revision_str('..')
 
82
    [None, None]
 
83
    >>> _parse_revision_str('..234')
 
84
    [None, 234]
 
85
    >>> _parse_revision_str('234..')
 
86
    [234, None]
 
87
    >>> _parse_revision_str('234..456..789') # Maybe this should be an error
 
88
    [234, 456, 789]
 
89
    >>> _parse_revision_str('234....789') # Error?
 
90
    [234, None, 789]
 
91
    >>> _parse_revision_str('revid:test@other.com-234234')
 
92
    ['revid:test@other.com-234234']
 
93
    >>> _parse_revision_str('revid:test@other.com-234234..revid:test@other.com-234235')
 
94
    ['revid:test@other.com-234234', 'revid:test@other.com-234235']
 
95
    >>> _parse_revision_str('revid:test@other.com-234234..23')
 
96
    ['revid:test@other.com-234234', 23]
 
97
    >>> _parse_revision_str('date:2005-04-12')
 
98
    ['date:2005-04-12']
 
99
    >>> _parse_revision_str('date:2005-04-12 12:24:33')
 
100
    ['date:2005-04-12 12:24:33']
 
101
    >>> _parse_revision_str('date:2005-04-12T12:24:33')
 
102
    ['date:2005-04-12T12:24:33']
 
103
    >>> _parse_revision_str('date:2005-04-12,12:24:33')
 
104
    ['date:2005-04-12,12:24:33']
 
105
    >>> _parse_revision_str('-5..23')
 
106
    [-5, 23]
 
107
    >>> _parse_revision_str('-5')
 
108
    [-5]
 
109
    >>> _parse_revision_str('123a')
 
110
    ['123a']
 
111
    >>> _parse_revision_str('abc')
 
112
    ['abc']
 
113
    """
 
114
    import re
 
115
    old_format_re = re.compile('\d*:\d*')
 
116
    m = old_format_re.match(revstr)
 
117
    if m:
 
118
        warning('Colon separator for revision numbers is deprecated.'
 
119
                ' Use .. instead')
 
120
        revs = []
 
121
        for rev in revstr.split(':'):
 
122
            if rev:
 
123
                revs.append(int(rev))
 
124
            else:
 
125
                revs.append(None)
 
126
        return revs
 
127
    revs = []
 
128
    for x in revstr.split('..'):
 
129
        if not x:
 
130
            revs.append(None)
 
131
        else:
 
132
            try:
 
133
                revs.append(int(x))
 
134
            except ValueError:
 
135
                revs.append(x)
 
136
    return revs
 
137
 
 
138
 
 
139
def get_merge_type(typestring):
 
140
    """Attempt to find the merge class/factory associated with a string."""
 
141
    from merge import merge_types
 
142
    try:
 
143
        return merge_types[typestring][0]
 
144
    except KeyError:
 
145
        templ = '%s%%7s: %%s' % (' '*12)
 
146
        lines = [templ % (f[0], f[1][1]) for f in merge_types.iteritems()]
 
147
        type_list = '\n'.join(lines)
 
148
        msg = "No known merge type %s. Supported types are:\n%s" %\
 
149
            (typestring, type_list)
 
150
        raise BzrCommandError(msg)
 
151
    
 
152
 
99
153
def _builtin_commands():
100
154
    import bzrlib.builtins
101
155
    r = {}
102
156
    builtins = bzrlib.builtins.__dict__
103
157
    for name in builtins:
104
158
        if name.startswith("cmd_"):
105
 
            real_name = _unsquish_command_name(name)
 
159
            real_name = _unsquish_command_name(name)        
106
160
            r[real_name] = builtins[name]
107
161
    return r
 
162
 
108
163
            
109
164
 
110
165
def builtin_command_names():
138
193
    """
139
194
    from bzrlib.externalcommand import ExternalCommand
140
195
 
141
 
    # We want only 'ascii' command names, but the user may have typed
142
 
    # in a Unicode name. In that case, they should just get a
143
 
    # 'command not found' error later.
144
 
    # In the future, we may actually support Unicode command names.
 
196
    cmd_name = str(cmd_name)            # not unicode
145
197
 
146
198
    # first look up this command under the specified name
147
199
    cmds = _get_cmd_dict(plugins_override=plugins_override)
159
211
    if cmd_obj:
160
212
        return cmd_obj
161
213
 
162
 
    raise errors.BzrCommandError('unknown command "%s"' % cmd_name)
 
214
    raise BzrCommandError("unknown command %r" % cmd_name)
163
215
 
164
216
 
165
217
class Command(object):
187
239
        List of argument forms, marked with whether they are optional,
188
240
        repeated, etc.
189
241
 
190
 
                Examples:
191
 
 
192
 
                ['to_location', 'from_branch?', 'file*']
193
 
 
194
 
                'to_location' is required
195
 
                'from_branch' is optional
196
 
                'file' can be specified 0 or more times
197
 
 
198
242
    takes_options
199
 
        List of options that may be given for this command.  These can
200
 
        be either strings, referring to globally-defined options,
201
 
        or option objects.  Retrieve through options().
 
243
        List of options that may be given for this command.
202
244
 
203
245
    hidden
204
246
        If true, this command isn't advertised.  This is typically
205
247
        for commands intended for expert users.
206
 
 
207
 
    encoding_type
208
 
        Command objects will get a 'outf' attribute, which has been
209
 
        setup to properly handle encoding of unicode strings.
210
 
        encoding_type determines what will happen when characters cannot
211
 
        be encoded
212
 
            strict - abort if we cannot decode
213
 
            replace - put in a bogus character (typically '?')
214
 
            exact - do not encode sys.stdout
215
 
 
216
248
    """
217
249
    aliases = []
 
250
    
218
251
    takes_args = []
219
252
    takes_options = []
220
 
    encoding_type = 'strict'
221
253
 
222
254
    hidden = False
223
255
    
226
258
        if self.__doc__ == Command.__doc__:
227
259
            warn("No help message set for %r" % self)
228
260
 
229
 
    def options(self):
230
 
        """Return dict of valid options for this command.
231
 
 
232
 
        Maps from long option name to option object."""
233
 
        r = dict()
234
 
        r['help'] = option.Option.OPTIONS['help']
235
 
        for o in self.takes_options:
236
 
            if isinstance(o, basestring):
237
 
                o = option.Option.OPTIONS[o]
238
 
            r[o.name] = o
239
 
        return r
240
 
 
241
 
    def _setup_outf(self):
242
 
        """Return a file linked to stdout, which has proper encoding."""
243
 
        assert self.encoding_type in ['strict', 'exact', 'replace']
244
 
 
245
 
        # Originally I was using self.stdout, but that looks
246
 
        # *way* too much like sys.stdout
247
 
        if self.encoding_type == 'exact':
248
 
            self.outf = sys.stdout
249
 
            return
250
 
 
251
 
        output_encoding = osutils.get_terminal_encoding()
252
 
 
253
 
        # use 'replace' so that we don't abort if trying to write out
254
 
        # in e.g. the default C locale.
255
 
        self.outf = codecs.getwriter(output_encoding)(sys.stdout, errors=self.encoding_type)
256
 
        # For whatever reason codecs.getwriter() does not advertise its encoding
257
 
        # it just returns the encoding of the wrapped file, which is completely
258
 
        # bogus. So set the attribute, so we can find the correct encoding later.
259
 
        self.outf.encoding = output_encoding
260
 
 
261
 
    @deprecated_method(zero_eight)
 
261
 
262
262
    def run_argv(self, argv):
263
 
        """Parse command line and run.
264
 
        
265
 
        See run_argv_aliases for the 0.8 and beyond api.
266
 
        """
267
 
        return self.run_argv_aliases(argv)
 
263
        """Parse command line and run."""
 
264
        args, opts = parse_args(argv)
268
265
 
269
 
    def run_argv_aliases(self, argv, alias_argv=None):
270
 
        """Parse the command line and run with extra aliases in alias_argv."""
271
 
        if argv is None:
272
 
            warn("Passing None for [] is deprecated from bzrlib 0.10", 
273
 
                 DeprecationWarning, stacklevel=2)
274
 
            argv = []
275
 
        args, opts = parse_args(self, argv, alias_argv)
276
266
        if 'help' in opts:  # e.g. bzr add --help
277
267
            from bzrlib.help import help_on_command
278
268
            help_on_command(self.name())
279
269
            return 0
 
270
 
 
271
        # check options are reasonable
 
272
        allowed = self.takes_options
 
273
        for oname in opts:
 
274
            if oname not in allowed:
 
275
                raise BzrCommandError("option '--%s' is not allowed for command %r"
 
276
                                      % (oname, self.name()))
 
277
 
280
278
        # mix arguments and options into one dictionary
281
279
        cmdargs = _match_argform(self.name(), self.takes_args, args)
282
280
        cmdopts = {}
286
284
        all_cmd_args = cmdargs.copy()
287
285
        all_cmd_args.update(cmdopts)
288
286
 
289
 
        self._setup_outf()
290
 
 
291
287
        return self.run(**all_cmd_args)
 
288
 
292
289
    
293
290
    def run(self):
294
291
        """Actually run the command.
300
297
        shell error code if not.  It's OK for this method to allow
301
298
        an exception to raise up.
302
299
        """
303
 
        raise NotImplementedError('no implementation of command %r' 
304
 
                                  % self.name())
 
300
        raise NotImplementedError()
 
301
 
305
302
 
306
303
    def help(self):
307
304
        """Return help message for this class."""
308
 
        from inspect import getdoc
309
305
        if self.__doc__ is Command.__doc__:
310
306
            return None
311
307
        return getdoc(self)
313
309
    def name(self):
314
310
        return _unsquish_command_name(self.__class__.__name__)
315
311
 
316
 
    def plugin_name(self):
317
 
        """Get the name of the plugin that provides this command.
318
 
 
319
 
        :return: The name of the plugin or None if the command is builtin.
320
 
        """
321
 
        mod_parts = self.__module__.split('.')
322
 
        if len(mod_parts) >= 3 and mod_parts[1] == 'plugins':
323
 
            return mod_parts[2]
324
 
        else:
325
 
            return None
326
 
 
327
 
 
328
 
# Technically, this function hasn't been use in a *really* long time
329
 
# but we are only deprecating it now.
330
 
@deprecated_function(zero_eleven)
 
312
 
331
313
def parse_spec(spec):
332
314
    """
333
315
    >>> parse_spec(None)
359
341
        parsed = [spec, None]
360
342
    return parsed
361
343
 
362
 
def parse_args(command, argv, alias_argv=None):
 
344
 
 
345
 
 
346
 
 
347
# list of all available options; the rhs can be either None for an
 
348
# option that takes no argument, or a constructor function that checks
 
349
# the type.
 
350
OPTIONS = {
 
351
    'all':                    None,
 
352
    'diff-options':           str,
 
353
    'help':                   None,
 
354
    'file':                   unicode,
 
355
    'force':                  None,
 
356
    'format':                 unicode,
 
357
    'forward':                None,
 
358
    'message':                unicode,
 
359
    'no-recurse':             None,
 
360
    'profile':                None,
 
361
    'revision':               _parse_revision_str,
 
362
    'short':                  None,
 
363
    'show-ids':               None,
 
364
    'timezone':               str,
 
365
    'verbose':                None,
 
366
    'version':                None,
 
367
    'email':                  None,
 
368
    'unchanged':              None,
 
369
    'update':                 None,
 
370
    'long':                   None,
 
371
    'root':                   str,
 
372
    'no-backup':              None,
 
373
    'merge-type':             get_merge_type,
 
374
    'pattern':                str,
 
375
    }
 
376
 
 
377
SHORT_OPTIONS = {
 
378
    'F':                      'file', 
 
379
    'h':                      'help',
 
380
    'm':                      'message',
 
381
    'r':                      'revision',
 
382
    'v':                      'verbose',
 
383
    'l':                      'long',
 
384
}
 
385
 
 
386
 
 
387
def parse_args(argv):
363
388
    """Parse command line.
364
389
    
365
390
    Arguments and options are parsed at this level before being passed
366
391
    down to specific command handlers.  This routine knows, from a
367
392
    lookup table, something about the available options, what optargs
368
393
    they take, and which commands will accept them.
 
394
 
 
395
    >>> parse_args('--help'.split())
 
396
    ([], {'help': True})
 
397
    >>> parse_args('help -- --invalidcmd'.split())
 
398
    (['help', '--invalidcmd'], {})
 
399
    >>> parse_args('--version'.split())
 
400
    ([], {'version': True})
 
401
    >>> parse_args('status --all'.split())
 
402
    (['status'], {'all': True})
 
403
    >>> parse_args('commit --message=biter'.split())
 
404
    (['commit'], {'message': u'biter'})
 
405
    >>> parse_args('log -r 500'.split())
 
406
    (['log'], {'revision': [500]})
 
407
    >>> parse_args('log -r500..600'.split())
 
408
    (['log'], {'revision': [500, 600]})
 
409
    >>> parse_args('log -vr500..600'.split())
 
410
    (['log'], {'verbose': True, 'revision': [500, 600]})
 
411
    >>> parse_args('log -rv500..600'.split()) #the r takes an argument
 
412
    (['log'], {'revision': ['v500', 600]})
369
413
    """
370
 
    # TODO: make it a method of the Command?
371
 
    parser = option.get_optparser(command.options())
372
 
    if alias_argv is not None:
373
 
        args = alias_argv + argv
374
 
    else:
375
 
        args = argv
376
 
 
377
 
    options, args = parser.parse_args(args)
378
 
    opts = dict([(k, v) for k, v in options.__dict__.iteritems() if 
379
 
                 v is not option.OptionParser.DEFAULT_VALUE])
 
414
    args = []
 
415
    opts = {}
 
416
 
 
417
    argsover = False
 
418
    while argv:
 
419
        a = argv.pop(0)
 
420
        if not argsover and a[0] == '-':
 
421
            # option names must not be unicode
 
422
            a = str(a)
 
423
            optarg = None
 
424
            if a[1] == '-':
 
425
                if a == '--':
 
426
                    # We've received a standalone -- No more flags
 
427
                    argsover = True
 
428
                    continue
 
429
                mutter("  got option %r" % a)
 
430
                if '=' in a:
 
431
                    optname, optarg = a[2:].split('=', 1)
 
432
                else:
 
433
                    optname = a[2:]
 
434
                if optname not in OPTIONS:
 
435
                    raise BzrError('unknown long option %r' % a)
 
436
            else:
 
437
                shortopt = a[1:]
 
438
                if shortopt in SHORT_OPTIONS:
 
439
                    # Multi-character options must have a space to delimit
 
440
                    # their value
 
441
                    optname = SHORT_OPTIONS[shortopt]
 
442
                else:
 
443
                    # Single character short options, can be chained,
 
444
                    # and have their value appended to their name
 
445
                    shortopt = a[1:2]
 
446
                    if shortopt not in SHORT_OPTIONS:
 
447
                        # We didn't find the multi-character name, and we
 
448
                        # didn't find the single char name
 
449
                        raise BzrError('unknown short option %r' % a)
 
450
                    optname = SHORT_OPTIONS[shortopt]
 
451
 
 
452
                    if a[2:]:
 
453
                        # There are extra things on this option
 
454
                        # see if it is the value, or if it is another
 
455
                        # short option
 
456
                        optargfn = OPTIONS[optname]
 
457
                        if optargfn is None:
 
458
                            # This option does not take an argument, so the
 
459
                            # next entry is another short option, pack it back
 
460
                            # into the list
 
461
                            argv.insert(0, '-' + a[2:])
 
462
                        else:
 
463
                            # This option takes an argument, so pack it
 
464
                            # into the array
 
465
                            optarg = a[2:]
 
466
            
 
467
            if optname in opts:
 
468
                # XXX: Do we ever want to support this, e.g. for -r?
 
469
                raise BzrError('repeated option %r' % a)
 
470
                
 
471
            optargfn = OPTIONS[optname]
 
472
            if optargfn:
 
473
                if optarg == None:
 
474
                    if not argv:
 
475
                        raise BzrError('option %r needs an argument' % a)
 
476
                    else:
 
477
                        optarg = argv.pop(0)
 
478
                opts[optname] = optargfn(optarg)
 
479
            else:
 
480
                if optarg != None:
 
481
                    raise BzrError('option %r takes no argument' % optname)
 
482
                opts[optname] = True
 
483
        else:
 
484
            args.append(a)
 
485
 
380
486
    return args, opts
381
487
 
382
488
 
 
489
 
 
490
 
383
491
def _match_argform(cmd, takes_args, args):
384
492
    argdict = {}
385
493
 
397
505
                argdict[argname + '_list'] = None
398
506
        elif ap[-1] == '+':
399
507
            if not args:
400
 
                raise errors.BzrCommandError("command %r needs one or more %s"
401
 
                                             % (cmd, argname.upper()))
 
508
                raise BzrCommandError("command %r needs one or more %s"
 
509
                        % (cmd, argname.upper()))
402
510
            else:
403
511
                argdict[argname + '_list'] = args[:]
404
512
                args = []
405
513
        elif ap[-1] == '$': # all but one
406
514
            if len(args) < 2:
407
 
                raise errors.BzrCommandError("command %r needs one or more %s"
408
 
                                             % (cmd, argname.upper()))
 
515
                raise BzrCommandError("command %r needs one or more %s"
 
516
                        % (cmd, argname.upper()))
409
517
            argdict[argname + '_list'] = args[:-1]
410
 
            args[:-1] = []
 
518
            args[:-1] = []                
411
519
        else:
412
520
            # just a plain arg
413
521
            argname = ap
414
522
            if not args:
415
 
                raise errors.BzrCommandError("command %r requires argument %s"
416
 
                               % (cmd, argname.upper()))
 
523
                raise BzrCommandError("command %r requires argument %s"
 
524
                        % (cmd, argname.upper()))
417
525
            else:
418
526
                argdict[argname] = args.pop(0)
419
527
            
420
528
    if args:
421
 
        raise errors.BzrCommandError("extra argument to command %s: %s"
422
 
                                     % (cmd, args[0]))
 
529
        raise BzrCommandError("extra argument to command %s: %s"
 
530
                              % (cmd, args[0]))
423
531
 
424
532
    return argdict
425
533
 
428
536
def apply_profiled(the_callable, *args, **kwargs):
429
537
    import hotshot
430
538
    import tempfile
431
 
    import hotshot.stats
432
539
    pffileno, pfname = tempfile.mkstemp()
433
540
    try:
434
541
        prof = hotshot.Profile(pfname)
436
543
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
437
544
        finally:
438
545
            prof.close()
 
546
 
 
547
        import hotshot.stats
439
548
        stats = hotshot.stats.load(pfname)
440
 
        stats.strip_dirs()
441
 
        stats.sort_stats('cum')   # 'time'
 
549
        #stats.strip_dirs()
 
550
        stats.sort_stats('time')
442
551
        ## XXX: Might like to write to stderr or the trace file instead but
443
552
        ## print_stats seems hardcoded to stdout
444
553
        stats.print_stats(20)
 
554
 
445
555
        return ret
446
556
    finally:
447
557
        os.close(pffileno)
448
558
        os.remove(pfname)
449
559
 
450
560
 
451
 
def apply_lsprofiled(filename, the_callable, *args, **kwargs):
452
 
    from bzrlib.lsprof import profile
453
 
    import cPickle
454
 
    ret, stats = profile(the_callable, *args, **kwargs)
455
 
    stats.sort()
456
 
    if filename is None:
457
 
        stats.pprint()
458
 
    else:
459
 
        stats.freeze()
460
 
        cPickle.dump(stats, open(filename, 'w'), 2)
461
 
        print 'Profile data written to %r.' % filename
462
 
    return ret
463
 
 
464
 
 
465
 
def get_alias(cmd):
466
 
    """Return an expanded alias, or None if no alias exists"""
467
 
    import bzrlib.config
468
 
    alias = bzrlib.config.GlobalConfig().get_alias(cmd)
469
 
    if (alias):
470
 
        return alias.split(' ')
471
 
    return None
472
 
 
473
 
 
474
561
def run_bzr(argv):
475
562
    """Execute a command.
476
563
 
479
566
    
480
567
    argv
481
568
       The command-line arguments, without the program name from argv[0]
482
 
       These should already be decoded. All library/test code calling
483
 
       run_bzr should be passing valid strings (don't need decoding).
484
569
    
485
570
    Returns a command status or raises an exception.
486
571
 
490
575
    --no-plugins
491
576
        Do not load plugin modules at all
492
577
 
493
 
    --no-aliases
494
 
        Do not allow aliases
495
 
 
496
578
    --builtin
497
579
        Only use builtin commands.  (Plugins are still allowed to change
498
580
        other behaviour.)
499
581
 
500
582
    --profile
501
 
        Run under the Python hotshot profiler.
502
 
 
503
 
    --lsprof
504
 
        Run under the Python lsprof profiler.
 
583
        Run under the Python profiler.
505
584
    """
506
 
    argv = list(argv)
 
585
    
 
586
    argv = [a.decode(bzrlib.user_encoding) for a in argv]
507
587
 
508
 
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
509
 
                opt_no_aliases = False
510
 
    opt_lsprof_file = None
 
588
    opt_profile = opt_no_plugins = opt_builtin = False
511
589
 
512
590
    # --no-plugins is handled specially at a very early stage. We need
513
591
    # to load plugins before doing other command parsing so that they
514
592
    # can override commands, but this needs to happen first.
515
593
 
516
 
    argv_copy = []
517
 
    i = 0
518
 
    while i < len(argv):
519
 
        a = argv[i]
 
594
    for a in argv:
520
595
        if a == '--profile':
521
596
            opt_profile = True
522
 
        elif a == '--lsprof':
523
 
            opt_lsprof = True
524
 
        elif a == '--lsprof-file':
525
 
            opt_lsprof = True
526
 
            opt_lsprof_file = argv[i + 1]
527
 
            i += 1
528
597
        elif a == '--no-plugins':
529
598
            opt_no_plugins = True
530
 
        elif a == '--no-aliases':
531
 
            opt_no_aliases = True
532
599
        elif a == '--builtin':
533
600
            opt_builtin = True
534
 
        elif a in ('--quiet', '-q'):
535
 
            trace.be_quiet()
536
601
        else:
537
 
            argv_copy.append(a)
538
 
        i += 1
 
602
            break
 
603
        argv.remove(a)
539
604
 
540
 
    argv = argv_copy
541
 
    if (not argv):
542
 
        from bzrlib.builtins import cmd_help
543
 
        cmd_help().run_argv_aliases([])
 
605
    if (not argv) or (argv[0] == '--help'):
 
606
        from bzrlib.help import help
 
607
        if len(argv) > 1:
 
608
            help(argv[1])
 
609
        else:
 
610
            help()
544
611
        return 0
545
612
 
546
613
    if argv[0] == '--version':
547
 
        from bzrlib.version import show_version
 
614
        from bzrlib.builtins import show_version
548
615
        show_version()
549
616
        return 0
550
617
        
551
618
    if not opt_no_plugins:
552
619
        from bzrlib.plugin import load_plugins
553
620
        load_plugins()
554
 
    else:
555
 
        from bzrlib.plugin import disable_plugins
556
 
        disable_plugins()
557
 
 
558
 
    alias_argv = None
559
 
 
560
 
    if not opt_no_aliases:
561
 
        alias_argv = get_alias(argv[0])
562
 
        if alias_argv:
563
 
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
564
 
            argv[0] = alias_argv.pop(0)
565
 
 
566
 
    cmd = argv.pop(0)
567
 
    # We want only 'ascii' command names, but the user may have typed
568
 
    # in a Unicode name. In that case, they should just get a
569
 
    # 'command not found' error later.
 
621
 
 
622
    cmd = str(argv.pop(0))
570
623
 
571
624
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
572
 
    if not getattr(cmd_obj.run_argv, 'is_deprecated', False):
573
 
        run = cmd_obj.run_argv
574
 
        run_argv = [argv]
 
625
 
 
626
    if opt_profile:
 
627
        ret = apply_profiled(cmd_obj.run_argv, argv)
575
628
    else:
576
 
        run = cmd_obj.run_argv_aliases
577
 
        run_argv = [argv, alias_argv]
578
 
 
579
 
    try:
580
 
        if opt_lsprof:
581
 
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
582
 
        elif opt_profile:
583
 
            ret = apply_profiled(run, *run_argv)
584
 
        else:
585
 
            ret = run(*run_argv)
586
 
        return ret or 0
587
 
    finally:
588
 
        # reset, in case we may do other commands later within the same process
589
 
        trace.be_quiet(False)
590
 
 
591
 
def display_command(func):
592
 
    """Decorator that suppresses pipe/interrupt errors."""
593
 
    def ignore_pipe(*args, **kwargs):
594
 
        try:
595
 
            result = func(*args, **kwargs)
596
 
            sys.stdout.flush()
597
 
            return result
598
 
        except IOError, e:
599
 
            if getattr(e, 'errno', None) is None:
600
 
                raise
601
 
            if e.errno != errno.EPIPE:
602
 
                # Win32 raises IOError with errno=0 on a broken pipe
603
 
                if sys.platform != 'win32' or e.errno != 0:
604
 
                    raise
605
 
            pass
606
 
        except KeyboardInterrupt:
607
 
            pass
608
 
    return ignore_pipe
 
629
        ret = cmd_obj.run_argv(argv)
 
630
    return ret or 0
609
631
 
610
632
 
611
633
def main(argv):
612
634
    import bzrlib.ui
613
 
    from bzrlib.ui.text import TextUIFactory
614
 
    bzrlib.ui.ui_factory = TextUIFactory()
615
 
    argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
616
 
    ret = run_bzr_catch_errors(argv)
617
 
    trace.mutter("return code %d", ret)
618
 
    return ret
619
 
 
620
 
 
621
 
def run_bzr_catch_errors(argv):
 
635
    bzrlib.trace.log_startup(argv)
 
636
    bzrlib.ui.ui_factory = bzrlib.ui.TextUIFactory()
 
637
 
622
638
    try:
623
 
        return run_bzr(argv)
624
 
        # do this here inside the exception wrappers to catch EPIPE
625
 
        sys.stdout.flush()
626
 
    except (KeyboardInterrupt, Exception), e:
627
 
        # used to handle AssertionError and KeyboardInterrupt
628
 
        # specially here, but hopefully they're handled ok by the logger now
629
 
        trace.report_exception(sys.exc_info(), sys.stderr)
630
 
        if os.environ.get('BZR_PDB'):
631
 
            print '**** entering debugger'
632
 
            import pdb
633
 
            pdb.post_mortem(sys.exc_traceback)
 
639
        try:
 
640
            return run_bzr(argv[1:])
 
641
        finally:
 
642
            # do this here inside the exception wrappers to catch EPIPE
 
643
            sys.stdout.flush()
 
644
    except BzrCommandError, e:
 
645
        # command line syntax error, etc
 
646
        log_error(str(e))
 
647
        return 1
 
648
    except BzrError, e:
 
649
        bzrlib.trace.log_exception()
 
650
        return 1
 
651
    except AssertionError, e:
 
652
        bzrlib.trace.log_exception('assertion failed: ' + str(e))
634
653
        return 3
 
654
    except KeyboardInterrupt, e:
 
655
        bzrlib.trace.note('interrupted')
 
656
        return 2
 
657
    except Exception, e:
 
658
        import errno
 
659
        if (isinstance(e, IOError) 
 
660
            and hasattr(e, 'errno')
 
661
            and e.errno == errno.EPIPE):
 
662
            bzrlib.trace.note('broken pipe')
 
663
            return 2
 
664
        else:
 
665
            bzrlib.trace.log_exception()
 
666
            return 2
 
667
 
635
668
 
636
669
if __name__ == '__main__':
637
670
    sys.exit(main(sys.argv))