~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: Martin Pool
  • Date: 2005-09-16 06:52:59 UTC
  • Revision ID: mbp@sourcefrog.net-20050916065259-714aeb37c2510699
- remove another test that tries to merge an imaginary parent

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2006 by 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?
 
25
# would help with validation and shell completion.
 
26
 
 
27
 
30
28
 
31
29
import sys
32
30
import os
33
31
from warnings import warn
34
 
import errno
35
 
import codecs
 
32
from inspect import getdoc
36
33
 
37
34
import bzrlib
38
 
import bzrlib.errors as errors
39
 
from bzrlib.errors import (BzrError,
40
 
                           BzrCommandError,
41
 
                           BzrCheckError,
42
 
                           NotBranchError)
43
 
from bzrlib.option import Option
44
 
import bzrlib.osutils
45
 
from bzrlib.revisionspec import RevisionSpec
46
 
from bzrlib.symbol_versioning import (deprecated_method, zero_eight)
47
35
import bzrlib.trace
48
 
from bzrlib.trace import mutter, note, log_error, warning, be_quiet
 
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
49
40
 
50
41
plugin_cmds = {}
51
42
 
52
43
 
53
 
def register_command(cmd, decorate=False):
54
 
    """Utility function to help register a command
55
 
 
56
 
    :param cmd: Command subclass to register
57
 
    :param decorate: If true, allow overriding an existing command
58
 
        of the same name; the old command is returned by this function.
59
 
        Otherwise it is an error to try to override an existing command.
60
 
    """
 
44
def register_command(cmd):
 
45
    "Utility function to help register a command"
61
46
    global plugin_cmds
62
47
    k = cmd.__name__
63
48
    if k.startswith("cmd_"):
66
51
        k_unsquished = k
67
52
    if not plugin_cmds.has_key(k_unsquished):
68
53
        plugin_cmds[k_unsquished] = cmd
69
 
        mutter('registered plugin command %s', k_unsquished)
70
 
        if decorate and k_unsquished in builtin_command_names():
71
 
            return _builtin_commands()[k_unsquished]
72
 
    elif decorate:
73
 
        result = plugin_cmds[k_unsquished]
74
 
        plugin_cmds[k_unsquished] = cmd
75
 
        return result
 
54
        mutter('registered plugin command %s', k_unsquished)      
76
55
    else:
77
56
        log_error('Two plugins defined the same command: %r' % k)
78
57
        log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
87
66
    return cmd[4:].replace('_','-')
88
67
 
89
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
 
90
153
def _builtin_commands():
91
154
    import bzrlib.builtins
92
155
    r = {}
93
156
    builtins = bzrlib.builtins.__dict__
94
157
    for name in builtins:
95
158
        if name.startswith("cmd_"):
96
 
            real_name = _unsquish_command_name(name)
 
159
            real_name = _unsquish_command_name(name)        
97
160
            r[real_name] = builtins[name]
98
161
    return r
 
162
 
99
163
            
100
164
 
101
165
def builtin_command_names():
147
211
    if cmd_obj:
148
212
        return cmd_obj
149
213
 
150
 
    raise BzrCommandError('unknown command "%s"' % cmd_name)
 
214
    raise BzrCommandError("unknown command %r" % cmd_name)
151
215
 
152
216
 
153
217
class Command(object):
175
239
        List of argument forms, marked with whether they are optional,
176
240
        repeated, etc.
177
241
 
178
 
                Examples:
179
 
 
180
 
                ['to_location', 'from_branch?', 'file*']
181
 
 
182
 
                'to_location' is required
183
 
                'from_branch' is optional
184
 
                'file' can be specified 0 or more times
185
 
 
186
242
    takes_options
187
 
        List of options that may be given for this command.  These can
188
 
        be either strings, referring to globally-defined options,
189
 
        or option objects.  Retrieve through options().
 
243
        List of options that may be given for this command.
190
244
 
191
245
    hidden
192
246
        If true, this command isn't advertised.  This is typically
193
247
        for commands intended for expert users.
194
 
 
195
 
    encoding_type
196
 
        Command objects will get a 'outf' attribute, which has been
197
 
        setup to properly handle encoding of unicode strings.
198
 
        encoding_type determines what will happen when characters cannot
199
 
        be encoded
200
 
            strict - abort if we cannot decode
201
 
            replace - put in a bogus character (typically '?')
202
 
            exact - do not encode sys.stdout
203
 
 
204
248
    """
205
249
    aliases = []
 
250
    
206
251
    takes_args = []
207
252
    takes_options = []
208
 
    encoding_type = 'strict'
209
253
 
210
254
    hidden = False
211
255
    
214
258
        if self.__doc__ == Command.__doc__:
215
259
            warn("No help message set for %r" % self)
216
260
 
217
 
    def options(self):
218
 
        """Return dict of valid options for this command.
219
 
 
220
 
        Maps from long option name to option object."""
221
 
        r = dict()
222
 
        r['help'] = Option.OPTIONS['help']
223
 
        for o in self.takes_options:
224
 
            if not isinstance(o, Option):
225
 
                o = Option.OPTIONS[o]
226
 
            r[o.name] = o
227
 
        return r
228
 
 
229
 
    def _setup_outf(self):
230
 
        """Return a file linked to stdout, which has proper encoding."""
231
 
        assert self.encoding_type in ['strict', 'exact', 'replace']
232
 
 
233
 
        # Originally I was using self.stdout, but that looks
234
 
        # *way* too much like sys.stdout
235
 
        if self.encoding_type == 'exact':
236
 
            self.outf = sys.stdout
237
 
            return
238
 
 
239
 
        output_encoding = bzrlib.osutils.get_terminal_encoding()
240
 
 
241
 
        # use 'replace' so that we don't abort if trying to write out
242
 
        # in e.g. the default C locale.
243
 
        self.outf = codecs.getwriter(output_encoding)(sys.stdout, errors=self.encoding_type)
244
 
        # For whatever reason codecs.getwriter() does not advertise its encoding
245
 
        # it just returns the encoding of the wrapped file, which is completely
246
 
        # bogus. So set the attribute, so we can find the correct encoding later.
247
 
        self.outf.encoding = output_encoding
248
 
 
249
 
    @deprecated_method(zero_eight)
 
261
 
250
262
    def run_argv(self, argv):
251
 
        """Parse command line and run.
252
 
        
253
 
        See run_argv_aliases for the 0.8 and beyond api.
254
 
        """
255
 
        return self.run_argv_aliases(argv)
 
263
        """Parse command line and run."""
 
264
        args, opts = parse_args(argv)
256
265
 
257
 
    def run_argv_aliases(self, argv, alias_argv=None):
258
 
        """Parse the command line and run with extra aliases in alias_argv."""
259
 
        args, opts = parse_args(self, argv, alias_argv)
260
266
        if 'help' in opts:  # e.g. bzr add --help
261
267
            from bzrlib.help import help_on_command
262
268
            help_on_command(self.name())
263
269
            return 0
264
 
        # XXX: This should be handled by the parser
265
 
        allowed_names = self.options().keys()
 
270
 
 
271
        # check options are reasonable
 
272
        allowed = self.takes_options
266
273
        for oname in opts:
267
 
            if oname not in allowed_names:
268
 
                raise BzrOptionError("option '--%s' is not allowed for"
269
 
                                " command %r" % (oname, self.name()))
 
274
            if oname not in allowed:
 
275
                raise BzrCommandError("option '--%s' is not allowed for command %r"
 
276
                                      % (oname, self.name()))
 
277
 
270
278
        # mix arguments and options into one dictionary
271
279
        cmdargs = _match_argform(self.name(), self.takes_args, args)
272
280
        cmdopts = {}
276
284
        all_cmd_args = cmdargs.copy()
277
285
        all_cmd_args.update(cmdopts)
278
286
 
279
 
        self._setup_outf()
280
 
 
281
287
        return self.run(**all_cmd_args)
 
288
 
282
289
    
283
290
    def run(self):
284
291
        """Actually run the command.
290
297
        shell error code if not.  It's OK for this method to allow
291
298
        an exception to raise up.
292
299
        """
293
 
        raise NotImplementedError('no implementation of command %r' 
294
 
                                  % self.name())
 
300
        raise NotImplementedError()
 
301
 
295
302
 
296
303
    def help(self):
297
304
        """Return help message for this class."""
298
 
        from inspect import getdoc
299
305
        if self.__doc__ is Command.__doc__:
300
306
            return None
301
307
        return getdoc(self)
303
309
    def name(self):
304
310
        return _unsquish_command_name(self.__class__.__name__)
305
311
 
306
 
    def plugin_name(self):
307
 
        """Get the name of the plugin that provides this command.
308
 
 
309
 
        :return: The name of the plugin or None if the command is builtin.
310
 
        """
311
 
        mod_parts = self.__module__.split('.')
312
 
        if len(mod_parts) >= 3 and mod_parts[1] == 'plugins':
313
 
            return mod_parts[2]
314
 
        else:
315
 
            return None
316
 
 
317
312
 
318
313
def parse_spec(spec):
319
314
    """
346
341
        parsed = [spec, None]
347
342
    return parsed
348
343
 
349
 
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):
350
388
    """Parse command line.
351
389
    
352
390
    Arguments and options are parsed at this level before being passed
353
391
    down to specific command handlers.  This routine knows, from a
354
392
    lookup table, something about the available options, what optargs
355
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]})
356
413
    """
357
 
    # TODO: chop up this beast; make it a method of the Command
358
414
    args = []
359
415
    opts = {}
360
 
    alias_opts = {}
361
416
 
362
 
    cmd_options = command.options()
363
417
    argsover = False
364
 
    proc_aliasarg = True # Are we processing alias_argv now?
365
 
    for proc_argv in alias_argv, argv:
366
 
        while proc_argv:
367
 
            a = proc_argv.pop(0)
368
 
            if argsover:
369
 
                args.append(a)
370
 
                continue
371
 
            elif a == '-':
372
 
                args.append(a)
373
 
                continue
374
 
            elif a == '--':
375
 
                # We've received a standalone -- No more flags
376
 
                argsover = True
377
 
                continue
378
 
            if a[0] == '-':
379
 
                # option names must not be unicode
380
 
                a = str(a)
381
 
                optarg = None
382
 
                if a[1] == '-':
383
 
                    mutter("  got option %r", a)
384
 
                    if '=' in a:
385
 
                        optname, optarg = a[2:].split('=', 1)
386
 
                    else:
387
 
                        optname = a[2:]
388
 
                    if optname not in cmd_options:
389
 
                        raise BzrCommandError('unknown option "%s"' % a)
390
 
                else:
391
 
                    shortopt = a[1:]
392
 
                    if shortopt in Option.SHORT_OPTIONS:
393
 
                        # Multi-character options must have a space to delimit
394
 
                        # their value
395
 
                        # ^^^ what does this mean? mbp 20051014
396
 
                        optname = Option.SHORT_OPTIONS[shortopt].name
397
 
                    else:
398
 
                        # Single character short options, can be chained,
399
 
                        # and have their value appended to their name
400
 
                        shortopt = a[1:2]
401
 
                        if shortopt not in Option.SHORT_OPTIONS:
402
 
                            # We didn't find the multi-character name, and we
403
 
                            # didn't find the single char name
404
 
                            raise BzrCommandError('unknown option "%s"' % a)
405
 
                        optname = Option.SHORT_OPTIONS[shortopt].name
 
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]
406
451
 
407
 
                        if a[2:]:
408
 
                            # There are extra things on this option
409
 
                            # see if it is the value, or if it is another
410
 
                            # short option
411
 
                            optargfn = Option.OPTIONS[optname].type
412
 
                            if optargfn is None:
413
 
                                # This option does not take an argument, so the
414
 
                                # next entry is another short option, pack it
415
 
                                # back into the list
416
 
                                proc_argv.insert(0, '-' + a[2:])
417
 
                            else:
418
 
                                # This option takes an argument, so pack it
419
 
                                # into the array
420
 
                                optarg = a[2:]
421
 
                    if optname not in cmd_options:
422
 
                        raise BzrCommandError('unknown option "%s"' % shortopt)
423
 
                if optname in opts:
424
 
                    # XXX: Do we ever want to support this, e.g. for -r?
425
 
                    if proc_aliasarg:
426
 
                        raise BzrCommandError('repeated option %r' % a)
427
 
                    elif optname in alias_opts:
428
 
                        # Replace what's in the alias with what's in the real
429
 
                        # argument
430
 
                        del alias_opts[optname]
431
 
                        del opts[optname]
432
 
                        proc_argv.insert(0, a)
433
 
                        continue
434
 
                    else:
435
 
                        raise BzrCommandError('repeated option %r' % a)
436
 
                    
437
 
                option_obj = cmd_options[optname]
438
 
                optargfn = option_obj.type
439
 
                if optargfn:
440
 
                    if optarg == None:
441
 
                        if not proc_argv:
442
 
                            raise BzrCommandError('option %r needs an argument' % a)
 
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:])
443
462
                        else:
444
 
                            optarg = proc_argv.pop(0)
445
 
                    opts[optname] = optargfn(optarg)
446
 
                    if proc_aliasarg:
447
 
                        alias_opts[optname] = optargfn(optarg)
448
 
                else:
449
 
                    if optarg != None:
450
 
                        raise BzrCommandError('option %r takes no argument' % optname)
451
 
                    opts[optname] = True
452
 
                    if proc_aliasarg:
453
 
                        alias_opts[optname] = True
 
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)
454
479
            else:
455
 
                args.append(a)
456
 
        proc_aliasarg = False # Done with alias argv
 
480
                if optarg != None:
 
481
                    raise BzrError('option %r takes no argument' % optname)
 
482
                opts[optname] = True
 
483
        else:
 
484
            args.append(a)
 
485
 
457
486
    return args, opts
458
487
 
459
488
 
 
489
 
 
490
 
460
491
def _match_argform(cmd, takes_args, args):
461
492
    argdict = {}
462
493
 
484
515
                raise BzrCommandError("command %r needs one or more %s"
485
516
                        % (cmd, argname.upper()))
486
517
            argdict[argname + '_list'] = args[:-1]
487
 
            args[:-1] = []
 
518
            args[:-1] = []                
488
519
        else:
489
520
            # just a plain arg
490
521
            argname = ap
505
536
def apply_profiled(the_callable, *args, **kwargs):
506
537
    import hotshot
507
538
    import tempfile
508
 
    import hotshot.stats
509
539
    pffileno, pfname = tempfile.mkstemp()
510
540
    try:
511
541
        prof = hotshot.Profile(pfname)
513
543
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
514
544
        finally:
515
545
            prof.close()
 
546
 
 
547
        import hotshot.stats
516
548
        stats = hotshot.stats.load(pfname)
517
 
        stats.strip_dirs()
518
 
        stats.sort_stats('cum')   # 'time'
 
549
        #stats.strip_dirs()
 
550
        stats.sort_stats('time')
519
551
        ## XXX: Might like to write to stderr or the trace file instead but
520
552
        ## print_stats seems hardcoded to stdout
521
553
        stats.print_stats(20)
 
554
 
522
555
        return ret
523
556
    finally:
524
557
        os.close(pffileno)
525
558
        os.remove(pfname)
526
559
 
527
560
 
528
 
def apply_lsprofiled(filename, the_callable, *args, **kwargs):
529
 
    from bzrlib.lsprof import profile
530
 
    import cPickle
531
 
    ret, stats = profile(the_callable, *args, **kwargs)
532
 
    stats.sort()
533
 
    if filename is None:
534
 
        stats.pprint()
535
 
    else:
536
 
        stats.freeze()
537
 
        cPickle.dump(stats, open(filename, 'w'), 2)
538
 
        print 'Profile data written to %r.' % filename
539
 
    return ret
540
 
 
541
 
 
542
 
def get_alias(cmd):
543
 
    """Return an expanded alias, or None if no alias exists"""
544
 
    import bzrlib.config
545
 
    alias = bzrlib.config.GlobalConfig().get_alias(cmd)
546
 
    if (alias):
547
 
        return alias.split(' ')
548
 
    return None
549
 
 
550
 
 
551
561
def run_bzr(argv):
552
562
    """Execute a command.
553
563
 
556
566
    
557
567
    argv
558
568
       The command-line arguments, without the program name from argv[0]
559
 
       These should already be decoded. All library/test code calling
560
 
       run_bzr should be passing valid strings (don't need decoding).
561
569
    
562
570
    Returns a command status or raises an exception.
563
571
 
567
575
    --no-plugins
568
576
        Do not load plugin modules at all
569
577
 
570
 
    --no-aliases
571
 
        Do not allow aliases
572
 
 
573
578
    --builtin
574
579
        Only use builtin commands.  (Plugins are still allowed to change
575
580
        other behaviour.)
576
581
 
577
582
    --profile
578
 
        Run under the Python hotshot profiler.
579
 
 
580
 
    --lsprof
581
 
        Run under the Python lsprof profiler.
 
583
        Run under the Python profiler.
582
584
    """
583
 
    argv = list(argv)
 
585
    
 
586
    argv = [a.decode(bzrlib.user_encoding) for a in argv]
584
587
 
585
 
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
586
 
                opt_no_aliases = False
587
 
    opt_lsprof_file = None
 
588
    opt_profile = opt_no_plugins = opt_builtin = False
588
589
 
589
590
    # --no-plugins is handled specially at a very early stage. We need
590
591
    # to load plugins before doing other command parsing so that they
591
592
    # can override commands, but this needs to happen first.
592
593
 
593
 
    argv_copy = []
594
 
    i = 0
595
 
    while i < len(argv):
596
 
        a = argv[i]
 
594
    for a in argv:
597
595
        if a == '--profile':
598
596
            opt_profile = True
599
 
        elif a == '--lsprof':
600
 
            opt_lsprof = True
601
 
        elif a == '--lsprof-file':
602
 
            opt_lsprof = True
603
 
            opt_lsprof_file = argv[i + 1]
604
 
            i += 1
605
597
        elif a == '--no-plugins':
606
598
            opt_no_plugins = True
607
 
        elif a == '--no-aliases':
608
 
            opt_no_aliases = True
609
599
        elif a == '--builtin':
610
600
            opt_builtin = True
611
 
        elif a in ('--quiet', '-q'):
612
 
            be_quiet()
613
601
        else:
614
 
            argv_copy.append(a)
615
 
        i += 1
 
602
            break
 
603
        argv.remove(a)
616
604
 
617
 
    argv = argv_copy
618
 
    if (not argv):
619
 
        from bzrlib.builtins import cmd_help
620
 
        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()
621
611
        return 0
622
612
 
623
613
    if argv[0] == '--version':
628
618
    if not opt_no_plugins:
629
619
        from bzrlib.plugin import load_plugins
630
620
        load_plugins()
631
 
    else:
632
 
        from bzrlib.plugin import disable_plugins
633
 
        disable_plugins()
634
 
 
635
 
    alias_argv = None
636
 
 
637
 
    if not opt_no_aliases:
638
 
        alias_argv = get_alias(argv[0])
639
 
        if alias_argv:
640
 
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
641
 
            argv[0] = alias_argv.pop(0)
642
621
 
643
622
    cmd = str(argv.pop(0))
644
623
 
645
624
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
646
 
    if not getattr(cmd_obj.run_argv, 'is_deprecated', False):
647
 
        run = cmd_obj.run_argv
648
 
        run_argv = [argv]
 
625
 
 
626
    if opt_profile:
 
627
        ret = apply_profiled(cmd_obj.run_argv, argv)
649
628
    else:
650
 
        run = cmd_obj.run_argv_aliases
651
 
        run_argv = [argv, alias_argv]
652
 
 
653
 
    try:
654
 
        if opt_lsprof:
655
 
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
656
 
        elif opt_profile:
657
 
            ret = apply_profiled(run, *run_argv)
658
 
        else:
659
 
            ret = run(*run_argv)
660
 
        return ret or 0
661
 
    finally:
662
 
        # reset, in case we may do other commands later within the same process
663
 
        be_quiet(False)
664
 
 
665
 
def display_command(func):
666
 
    """Decorator that suppresses pipe/interrupt errors."""
667
 
    def ignore_pipe(*args, **kwargs):
668
 
        try:
669
 
            result = func(*args, **kwargs)
670
 
            sys.stdout.flush()
671
 
            return result
672
 
        except IOError, e:
673
 
            if not hasattr(e, 'errno'):
674
 
                raise
675
 
            if e.errno != errno.EPIPE:
676
 
                # Win32 raises IOError with errno=0 on a broken pipe
677
 
                if sys.platform != 'win32' or e.errno != 0:
678
 
                    raise
679
 
            pass
680
 
        except KeyboardInterrupt:
681
 
            pass
682
 
    return ignore_pipe
 
629
        ret = cmd_obj.run_argv(argv)
 
630
    return ret or 0
683
631
 
684
632
 
685
633
def main(argv):
686
634
    import bzrlib.ui
687
 
    from bzrlib.ui.text import TextUIFactory
688
 
    bzrlib.ui.ui_factory = TextUIFactory()
689
 
    argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
690
 
    ret = run_bzr_catch_errors(argv)
691
 
    mutter("return code %d", ret)
692
 
    return ret
693
 
 
694
 
 
695
 
def run_bzr_catch_errors(argv):
 
635
    bzrlib.trace.log_startup(argv)
 
636
    bzrlib.ui.ui_factory = bzrlib.ui.TextUIFactory()
 
637
 
696
638
    try:
697
 
        return run_bzr(argv)
698
 
        # do this here inside the exception wrappers to catch EPIPE
699
 
        sys.stdout.flush()
 
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))
 
653
        return 3
 
654
    except KeyboardInterrupt, e:
 
655
        bzrlib.trace.note('interrupted')
 
656
        return 2
700
657
    except Exception, e:
701
 
        # used to handle AssertionError and KeyboardInterrupt
702
 
        # specially here, but hopefully they're handled ok by the logger now
703
 
        bzrlib.trace.report_exception(sys.exc_info(), sys.stderr)
704
 
        if os.environ.get('BZR_PDB'):
705
 
            print '**** entering debugger'
706
 
            import pdb
707
 
            pdb.post_mortem(sys.exc_traceback)
708
 
        return 3
 
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
 
709
668
 
710
669
if __name__ == '__main__':
711
670
    sys.exit(main(sys.argv))