~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

bugfix from Aaron Bentley - bzrlib.graph.max_distance had an off-by-1 error

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