~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: Robert Collins
  • Date: 2005-10-14 02:17:36 UTC
  • mfrom: (1185.16.34)
  • Revision ID: robertc@lifelesslap.robertcollins.net-20051014021736-7230e59066856096
MergeĀ fromĀ Martin.

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