~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

- increment version

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
 
    win32utils,
48
 
    )
49
 
""")
50
 
 
51
 
from bzrlib.symbol_versioning import (
52
 
    deprecated_function,
53
 
    deprecated_method,
54
 
    zero_eight,
55
 
    zero_eleven,
56
 
    )
57
 
# Compatibility
58
 
from bzrlib.option import Option
59
 
 
 
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
60
41
 
61
42
plugin_cmds = {}
62
43
 
63
44
 
64
 
def register_command(cmd, decorate=False):
65
 
    """Utility function to help register a command
66
 
 
67
 
    :param cmd: Command subclass to register
68
 
    :param decorate: If true, allow overriding an existing command
69
 
        of the same name; the old command is returned by this function.
70
 
        Otherwise it is an error to try to override an existing command.
71
 
    """
 
45
def register_command(cmd):
 
46
    "Utility function to help register a command"
72
47
    global plugin_cmds
73
48
    k = cmd.__name__
74
49
    if k.startswith("cmd_"):
75
50
        k_unsquished = _unsquish_command_name(k)
76
51
    else:
77
52
        k_unsquished = k
78
 
    if k_unsquished not in plugin_cmds:
79
 
        plugin_cmds[k_unsquished] = cmd
80
 
        ## trace.mutter('registered plugin command %s', k_unsquished)
81
 
        if decorate and k_unsquished in builtin_command_names():
82
 
            return _builtin_commands()[k_unsquished]
83
 
    elif decorate:
84
 
        result = plugin_cmds[k_unsquished]
85
 
        plugin_cmds[k_unsquished] = cmd
86
 
        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)      
87
56
    else:
88
 
        trace.log_error('Two plugins defined the same command: %r' % k)
89
 
        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__])
90
59
 
91
60
 
92
61
def _squish_command_name(cmd):
98
67
    return cmd[4:].replace('_','-')
99
68
 
100
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
 
101
149
def _builtin_commands():
102
150
    import bzrlib.builtins
103
151
    r = {}
104
152
    builtins = bzrlib.builtins.__dict__
105
153
    for name in builtins:
106
154
        if name.startswith("cmd_"):
107
 
            real_name = _unsquish_command_name(name)
 
155
            real_name = _unsquish_command_name(name)        
108
156
            r[real_name] = builtins[name]
109
157
    return r
 
158
 
110
159
            
111
160
 
112
161
def builtin_command_names():
138
187
    plugins_override
139
188
        If true, plugin commands can override builtins.
140
189
    """
141
 
    try:
142
 
        return _get_cmd_object(cmd_name, plugins_override)
143
 
    except KeyError:
144
 
        raise errors.BzrCommandError('unknown command "%s"' % cmd_name)
145
 
 
146
 
 
147
 
def _get_cmd_object(cmd_name, plugins_override=True):
148
 
    """Worker for get_cmd_object which raises KeyError rather than BzrCommandError."""
149
190
    from bzrlib.externalcommand import ExternalCommand
150
191
 
151
 
    # We want only 'ascii' command names, but the user may have typed
152
 
    # in a Unicode name. In that case, they should just get a
153
 
    # 'command not found' error later.
154
 
    # In the future, we may actually support Unicode command names.
 
192
    cmd_name = str(cmd_name)            # not unicode
155
193
 
156
194
    # first look up this command under the specified name
157
195
    cmds = _get_cmd_dict(plugins_override=plugins_override)
168
206
    cmd_obj = ExternalCommand.find_command(cmd_name)
169
207
    if cmd_obj:
170
208
        return cmd_obj
171
 
    raise KeyError
 
209
 
 
210
    raise BzrCommandError("unknown command %r" % cmd_name)
172
211
 
173
212
 
174
213
class Command(object):
196
235
        List of argument forms, marked with whether they are optional,
197
236
        repeated, etc.
198
237
 
199
 
                Examples:
200
 
 
201
 
                ['to_location', 'from_branch?', 'file*']
202
 
 
203
 
                'to_location' is required
204
 
                'from_branch' is optional
205
 
                'file' can be specified 0 or more times
206
 
 
207
238
    takes_options
208
 
        List of options that may be given for this command.  These can
209
 
        be either strings, referring to globally-defined options,
210
 
        or option objects.  Retrieve through options().
 
239
        List of options that may be given for this command.
211
240
 
212
241
    hidden
213
242
        If true, this command isn't advertised.  This is typically
214
243
        for commands intended for expert users.
215
 
 
216
 
    encoding_type
217
 
        Command objects will get a 'outf' attribute, which has been
218
 
        setup to properly handle encoding of unicode strings.
219
 
        encoding_type determines what will happen when characters cannot
220
 
        be encoded
221
 
            strict - abort if we cannot decode
222
 
            replace - put in a bogus character (typically '?')
223
 
            exact - do not encode sys.stdout
224
 
 
225
 
            NOTE: by default on Windows, sys.stdout is opened as a text
226
 
            stream, therefore LF line-endings are converted to CRLF.
227
 
            When a command uses encoding_type = 'exact', then
228
 
            sys.stdout is forced to be a binary stream, and line-endings
229
 
            will not mangled.
230
 
 
231
244
    """
232
245
    aliases = []
 
246
    
233
247
    takes_args = []
234
248
    takes_options = []
235
 
    encoding_type = 'strict'
236
249
 
237
250
    hidden = False
238
251
    
241
254
        if self.__doc__ == Command.__doc__:
242
255
            warn("No help message set for %r" % self)
243
256
 
244
 
    def _maybe_expand_globs(self, file_list):
245
 
        """Glob expand file_list if the platform does not do that itself.
246
 
        
247
 
        :return: A possibly empty list of unicode paths.
248
 
 
249
 
        Introduced in bzrlib 0.18.
250
 
        """
251
 
        if not file_list:
252
 
            file_list = []
253
 
        if sys.platform == 'win32':
254
 
            file_list = win32utils.glob_expand(file_list)
255
 
        return list(file_list)
256
 
 
257
 
    def _usage(self):
258
 
        """Return single-line grammar for this command.
259
 
 
260
 
        Only describes arguments, not options.
261
 
        """
262
 
        s = 'bzr ' + self.name() + ' '
263
 
        for aname in self.takes_args:
264
 
            aname = aname.upper()
265
 
            if aname[-1] in ['$', '+']:
266
 
                aname = aname[:-1] + '...'
267
 
            elif aname[-1] == '?':
268
 
                aname = '[' + aname[:-1] + ']'
269
 
            elif aname[-1] == '*':
270
 
                aname = '[' + aname[:-1] + '...]'
271
 
            s += aname + ' '
272
 
                
273
 
        assert s[-1] == ' '
274
 
        s = s[:-1]
275
 
        return s
276
 
 
277
 
    def get_help_text(self, additional_see_also=None):
278
 
        """Return a text string with help for this command.
279
 
        
280
 
        :param additional_see_also: Additional help topics to be
281
 
            cross-referenced.
282
 
        """
283
 
        doc = self.help()
284
 
        if doc is None:
285
 
            raise NotImplementedError("sorry, no detailed help yet for %r" % self.name())
286
 
 
287
 
        result = ""
288
 
        result += 'usage: %s\n' % self._usage()
289
 
 
290
 
        if self.aliases:
291
 
            result += 'aliases: '
292
 
            result += ', '.join(self.aliases) + '\n'
293
 
 
294
 
        result += '\n'
295
 
 
296
 
        plugin_name = self.plugin_name()
297
 
        if plugin_name is not None:
298
 
            result += '(From plugin "%s")' % plugin_name
299
 
            result += '\n\n'
300
 
 
301
 
        result += doc
302
 
        if result[-1] != '\n':
303
 
            result += '\n'
304
 
        result += '\n'
305
 
        result += option.get_optparser(self.options()).format_option_help()
306
 
        see_also = self.get_see_also(additional_see_also)
307
 
        if see_also:
308
 
            result += '\nSee also: '
309
 
            result += ', '.join(see_also)
310
 
            result += '\n'
311
 
        return result
312
 
 
313
 
    def get_help_topic(self):
314
 
        """Return the commands help topic - its name."""
315
 
        return self.name()
316
 
 
317
 
    def get_see_also(self, additional_terms=None):
318
 
        """Return a list of help topics that are related to this ommand.
319
 
        
320
 
        The list is derived from the content of the _see_also attribute. Any
321
 
        duplicates are removed and the result is in lexical order.
322
 
        :param additional_terms: Additional help topics to cross-reference.
323
 
        :return: A list of help topics.
324
 
        """
325
 
        see_also = set(getattr(self, '_see_also', []))
326
 
        if additional_terms:
327
 
            see_also.update(additional_terms)
328
 
        return sorted(see_also)
329
 
 
330
 
    def options(self):
331
 
        """Return dict of valid options for this command.
332
 
 
333
 
        Maps from long option name to option object."""
334
 
        r = dict()
335
 
        r['help'] = option._help_option
336
 
        for o in self.takes_options:
337
 
            if isinstance(o, basestring):
338
 
                o = option.Option.OPTIONS[o]
339
 
            r[o.name] = o
340
 
        return r
341
 
 
342
 
    def _setup_outf(self):
343
 
        """Return a file linked to stdout, which has proper encoding."""
344
 
        assert self.encoding_type in ['strict', 'exact', 'replace']
345
 
 
346
 
        # Originally I was using self.stdout, but that looks
347
 
        # *way* too much like sys.stdout
348
 
        if self.encoding_type == 'exact':
349
 
            # force sys.stdout to be binary stream on win32
350
 
            if sys.platform == 'win32':
351
 
                fileno = getattr(sys.stdout, 'fileno', None)
352
 
                if fileno:
353
 
                    import msvcrt
354
 
                    msvcrt.setmode(fileno(), os.O_BINARY)
355
 
            self.outf = sys.stdout
356
 
            return
357
 
 
358
 
        output_encoding = osutils.get_terminal_encoding()
359
 
 
360
 
        # use 'replace' so that we don't abort if trying to write out
361
 
        # in e.g. the default C locale.
362
 
        self.outf = codecs.getwriter(output_encoding)(sys.stdout, errors=self.encoding_type)
363
 
        # For whatever reason codecs.getwriter() does not advertise its encoding
364
 
        # it just returns the encoding of the wrapped file, which is completely
365
 
        # bogus. So set the attribute, so we can find the correct encoding later.
366
 
        self.outf.encoding = output_encoding
367
 
 
368
 
    def run_argv_aliases(self, argv, alias_argv=None):
369
 
        """Parse the command line and run with extra aliases in alias_argv."""
370
 
        if argv is None:
371
 
            warn("Passing None for [] is deprecated from bzrlib 0.10",
372
 
                 DeprecationWarning, stacklevel=2)
373
 
            argv = []
374
 
        args, opts = parse_args(self, argv, alias_argv)
 
257
 
 
258
    def run_argv(self, argv):
 
259
        """Parse command line and run."""
 
260
        args, opts = parse_args(argv)
 
261
 
375
262
        if 'help' in opts:  # e.g. bzr add --help
376
 
            sys.stdout.write(self.get_help_text())
 
263
            from bzrlib.help import help_on_command
 
264
            help_on_command(self.name())
377
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
 
378
274
        # mix arguments and options into one dictionary
379
275
        cmdargs = _match_argform(self.name(), self.takes_args, args)
380
276
        cmdopts = {}
384
280
        all_cmd_args = cmdargs.copy()
385
281
        all_cmd_args.update(cmdopts)
386
282
 
387
 
        self._setup_outf()
388
 
 
389
283
        return self.run(**all_cmd_args)
 
284
 
390
285
    
391
286
    def run(self):
392
287
        """Actually run the command.
398
293
        shell error code if not.  It's OK for this method to allow
399
294
        an exception to raise up.
400
295
        """
401
 
        raise NotImplementedError('no implementation of command %r'
402
 
                                  % self.name())
 
296
        raise NotImplementedError()
 
297
 
403
298
 
404
299
    def help(self):
405
300
        """Return help message for this class."""
406
 
        from inspect import getdoc
407
301
        if self.__doc__ is Command.__doc__:
408
302
            return None
409
303
        return getdoc(self)
411
305
    def name(self):
412
306
        return _unsquish_command_name(self.__class__.__name__)
413
307
 
414
 
    def plugin_name(self):
415
 
        """Get the name of the plugin that provides this command.
416
 
 
417
 
        :return: The name of the plugin or None if the command is builtin.
418
 
        """
419
 
        mod_parts = self.__module__.split('.')
420
 
        if len(mod_parts) >= 3 and mod_parts[1] == 'plugins':
421
 
            return mod_parts[2]
422
 
        else:
423
 
            return None
424
 
 
425
 
 
426
 
# Technically, this function hasn't been use in a *really* long time
427
 
# but we are only deprecating it now.
428
 
@deprecated_function(zero_eleven)
 
308
 
429
309
def parse_spec(spec):
430
310
    """
431
311
    >>> parse_spec(None)
457
337
        parsed = [spec, None]
458
338
    return parsed
459
339
 
460
 
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
    'message':                unicode,
 
354
    'no-recurse':             None,
 
355
    'profile':                None,
 
356
    'revision':               _parse_revision_str,
 
357
    'short':                  None,
 
358
    'show-ids':               None,
 
359
    'timezone':               str,
 
360
    'verbose':                None,
 
361
    'version':                None,
 
362
    'email':                  None,
 
363
    'unchanged':              None,
 
364
    'update':                 None,
 
365
    'long':                   None,
 
366
    'root':                   str,
 
367
    'no-backup':              None,
 
368
    'pattern':                str,
 
369
    'remember':               None,
 
370
    }
 
371
 
 
372
SHORT_OPTIONS = {
 
373
    'F':                      'file', 
 
374
    'h':                      'help',
 
375
    'm':                      'message',
 
376
    'r':                      'revision',
 
377
    'v':                      'verbose',
 
378
    'l':                      'long',
 
379
}
 
380
 
 
381
 
 
382
def parse_args(argv):
461
383
    """Parse command line.
462
384
    
463
385
    Arguments and options are parsed at this level before being passed
464
386
    down to specific command handlers.  This routine knows, from a
465
387
    lookup table, something about the available options, what optargs
466
388
    they take, and which commands will accept them.
 
389
 
 
390
    >>> parse_args('--help'.split())
 
391
    ([], {'help': True})
 
392
    >>> parse_args('help -- --invalidcmd'.split())
 
393
    (['help', '--invalidcmd'], {})
 
394
    >>> parse_args('--version'.split())
 
395
    ([], {'version': True})
 
396
    >>> parse_args('status --all'.split())
 
397
    (['status'], {'all': True})
 
398
    >>> parse_args('commit --message=biter'.split())
 
399
    (['commit'], {'message': u'biter'})
 
400
    >>> parse_args('log -r 500'.split())
 
401
    (['log'], {'revision': [<RevisionSpec_int 500>]})
 
402
    >>> parse_args('log -r500..600'.split())
 
403
    (['log'], {'revision': [<RevisionSpec_int 500>, <RevisionSpec_int 600>]})
 
404
    >>> parse_args('log -vr500..600'.split())
 
405
    (['log'], {'verbose': True, 'revision': [<RevisionSpec_int 500>, <RevisionSpec_int 600>]})
 
406
    >>> parse_args('log -rrevno:500..600'.split()) #the r takes an argument
 
407
    (['log'], {'revision': [<RevisionSpec_revno revno:500>, <RevisionSpec_int 600>]})
467
408
    """
468
 
    # TODO: make it a method of the Command?
469
 
    parser = option.get_optparser(command.options())
470
 
    if alias_argv is not None:
471
 
        args = alias_argv + argv
472
 
    else:
473
 
        args = argv
474
 
 
475
 
    options, args = parser.parse_args(args)
476
 
    opts = dict([(k, v) for k, v in options.__dict__.iteritems() if
477
 
                 v is not option.OptionParser.DEFAULT_VALUE])
 
409
    args = []
 
410
    opts = {}
 
411
 
 
412
    argsover = False
 
413
    while argv:
 
414
        a = argv.pop(0)
 
415
        if not argsover and a[0] == '-':
 
416
            # option names must not be unicode
 
417
            a = str(a)
 
418
            optarg = None
 
419
            if a[1] == '-':
 
420
                if a == '--':
 
421
                    # We've received a standalone -- No more flags
 
422
                    argsover = True
 
423
                    continue
 
424
                mutter("  got option %r" % a)
 
425
                if '=' in a:
 
426
                    optname, optarg = a[2:].split('=', 1)
 
427
                else:
 
428
                    optname = a[2:]
 
429
                if optname not in OPTIONS:
 
430
                    raise BzrError('unknown long option %r' % a)
 
431
            else:
 
432
                shortopt = a[1:]
 
433
                if shortopt in SHORT_OPTIONS:
 
434
                    # Multi-character options must have a space to delimit
 
435
                    # their value
 
436
                    optname = SHORT_OPTIONS[shortopt]
 
437
                else:
 
438
                    # Single character short options, can be chained,
 
439
                    # and have their value appended to their name
 
440
                    shortopt = a[1:2]
 
441
                    if shortopt not in SHORT_OPTIONS:
 
442
                        # We didn't find the multi-character name, and we
 
443
                        # didn't find the single char name
 
444
                        raise BzrError('unknown short option %r' % a)
 
445
                    optname = SHORT_OPTIONS[shortopt]
 
446
 
 
447
                    if a[2:]:
 
448
                        # There are extra things on this option
 
449
                        # see if it is the value, or if it is another
 
450
                        # short option
 
451
                        optargfn = OPTIONS[optname]
 
452
                        if optargfn is None:
 
453
                            # This option does not take an argument, so the
 
454
                            # next entry is another short option, pack it back
 
455
                            # into the list
 
456
                            argv.insert(0, '-' + a[2:])
 
457
                        else:
 
458
                            # This option takes an argument, so pack it
 
459
                            # into the array
 
460
                            optarg = a[2:]
 
461
            
 
462
            if optname in opts:
 
463
                # XXX: Do we ever want to support this, e.g. for -r?
 
464
                raise BzrError('repeated option %r' % a)
 
465
                
 
466
            optargfn = OPTIONS[optname]
 
467
            if optargfn:
 
468
                if optarg == None:
 
469
                    if not argv:
 
470
                        raise BzrError('option %r needs an argument' % a)
 
471
                    else:
 
472
                        optarg = argv.pop(0)
 
473
                opts[optname] = optargfn(optarg)
 
474
            else:
 
475
                if optarg != None:
 
476
                    raise BzrError('option %r takes no argument' % optname)
 
477
                opts[optname] = True
 
478
        else:
 
479
            args.append(a)
 
480
 
478
481
    return args, opts
479
482
 
480
483
 
 
484
 
 
485
 
481
486
def _match_argform(cmd, takes_args, args):
482
487
    argdict = {}
483
488
 
495
500
                argdict[argname + '_list'] = None
496
501
        elif ap[-1] == '+':
497
502
            if not args:
498
 
                raise errors.BzrCommandError("command %r needs one or more %s"
499
 
                                             % (cmd, argname.upper()))
 
503
                raise BzrCommandError("command %r needs one or more %s"
 
504
                        % (cmd, argname.upper()))
500
505
            else:
501
506
                argdict[argname + '_list'] = args[:]
502
507
                args = []
503
508
        elif ap[-1] == '$': # all but one
504
509
            if len(args) < 2:
505
 
                raise errors.BzrCommandError("command %r needs one or more %s"
506
 
                                             % (cmd, argname.upper()))
 
510
                raise BzrCommandError("command %r needs one or more %s"
 
511
                        % (cmd, argname.upper()))
507
512
            argdict[argname + '_list'] = args[:-1]
508
 
            args[:-1] = []
 
513
            args[:-1] = []                
509
514
        else:
510
515
            # just a plain arg
511
516
            argname = ap
512
517
            if not args:
513
 
                raise errors.BzrCommandError("command %r requires argument %s"
514
 
                               % (cmd, argname.upper()))
 
518
                raise BzrCommandError("command %r requires argument %s"
 
519
                        % (cmd, argname.upper()))
515
520
            else:
516
521
                argdict[argname] = args.pop(0)
517
522
            
518
523
    if args:
519
 
        raise errors.BzrCommandError("extra argument to command %s: %s"
520
 
                                     % (cmd, args[0]))
 
524
        raise BzrCommandError("extra argument to command %s: %s"
 
525
                              % (cmd, args[0]))
521
526
 
522
527
    return argdict
523
528
 
546
551
        os.remove(pfname)
547
552
 
548
553
 
549
 
def apply_lsprofiled(filename, the_callable, *args, **kwargs):
550
 
    from bzrlib.lsprof import profile
551
 
    ret, stats = profile(the_callable, *args, **kwargs)
552
 
    stats.sort()
553
 
    if filename is None:
554
 
        stats.pprint()
555
 
    else:
556
 
        stats.save(filename)
557
 
        trace.note('Profile data written to "%s".', filename)
558
 
    return ret
559
 
 
560
 
 
561
 
def get_alias(cmd, config=None):
562
 
    """Return an expanded alias, or None if no alias exists.
563
 
 
564
 
    cmd
565
 
        Command to be checked for an alias.
566
 
    config
567
 
        Used to specify an alternative config to use,
568
 
        which is especially useful for testing.
569
 
        If it is unspecified, the global config will be used.
570
 
    """
571
 
    if config is None:
572
 
        import bzrlib.config
573
 
        config = bzrlib.config.GlobalConfig()
574
 
    alias = config.get_alias(cmd)
575
 
    if (alias):
576
 
        import shlex
577
 
        return [a.decode('utf-8') for a in shlex.split(alias.encode('utf-8'))]
578
 
    return None
579
 
 
580
 
 
581
554
def run_bzr(argv):
582
555
    """Execute a command.
583
556
 
586
559
    
587
560
    argv
588
561
       The command-line arguments, without the program name from argv[0]
589
 
       These should already be decoded. All library/test code calling
590
 
       run_bzr should be passing valid strings (don't need decoding).
591
562
    
592
563
    Returns a command status or raises an exception.
593
564
 
597
568
    --no-plugins
598
569
        Do not load plugin modules at all
599
570
 
600
 
    --no-aliases
601
 
        Do not allow aliases
602
 
 
603
571
    --builtin
604
572
        Only use builtin commands.  (Plugins are still allowed to change
605
573
        other behaviour.)
606
574
 
607
575
    --profile
608
 
        Run under the Python hotshot profiler.
609
 
 
610
 
    --lsprof
611
 
        Run under the Python lsprof profiler.
 
576
        Run under the Python profiler.
612
577
    """
613
 
    argv = list(argv)
614
 
    trace.mutter("bzr arguments: %r", argv)
 
578
    # Load all of the transport methods
 
579
    import bzrlib.transport.local, bzrlib.transport.http
 
580
    
 
581
    argv = [a.decode(bzrlib.user_encoding) for a in argv]
615
582
 
616
 
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
617
 
                opt_no_aliases = False
618
 
    opt_lsprof_file = None
 
583
    opt_profile = opt_no_plugins = opt_builtin = False
619
584
 
620
585
    # --no-plugins is handled specially at a very early stage. We need
621
586
    # to load plugins before doing other command parsing so that they
622
587
    # can override commands, but this needs to happen first.
623
588
 
624
 
    argv_copy = []
625
 
    i = 0
626
 
    while i < len(argv):
627
 
        a = argv[i]
 
589
    for a in argv:
628
590
        if a == '--profile':
629
591
            opt_profile = True
630
 
        elif a == '--lsprof':
631
 
            opt_lsprof = True
632
 
        elif a == '--lsprof-file':
633
 
            opt_lsprof = True
634
 
            opt_lsprof_file = argv[i + 1]
635
 
            i += 1
636
592
        elif a == '--no-plugins':
637
593
            opt_no_plugins = True
638
 
        elif a == '--no-aliases':
639
 
            opt_no_aliases = True
640
594
        elif a == '--builtin':
641
595
            opt_builtin = True
642
 
        elif a in ('--quiet', '-q'):
643
 
            trace.be_quiet()
644
 
        elif a.startswith('-D'):
645
 
            debug.debug_flags.add(a[2:])
646
596
        else:
647
 
            argv_copy.append(a)
648
 
        i += 1
 
597
            break
 
598
        argv.remove(a)
649
599
 
650
 
    argv = argv_copy
651
 
    if (not argv):
652
 
        from bzrlib.builtins import cmd_help
653
 
        cmd_help().run_argv_aliases([])
 
600
    if (not argv) or (argv[0] == '--help'):
 
601
        from bzrlib.help import help
 
602
        if len(argv) > 1:
 
603
            help(argv[1])
 
604
        else:
 
605
            help()
654
606
        return 0
655
607
 
656
608
    if argv[0] == '--version':
657
 
        from bzrlib.version import show_version
 
609
        from bzrlib.builtins import show_version
658
610
        show_version()
659
611
        return 0
660
612
        
661
613
    if not opt_no_plugins:
662
614
        from bzrlib.plugin import load_plugins
663
615
        load_plugins()
664
 
    else:
665
 
        from bzrlib.plugin import disable_plugins
666
 
        disable_plugins()
667
 
 
668
 
    alias_argv = None
669
 
 
670
 
    if not opt_no_aliases:
671
 
        alias_argv = get_alias(argv[0])
672
 
        if alias_argv:
673
 
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
674
 
            argv[0] = alias_argv.pop(0)
675
 
 
676
 
    cmd = argv.pop(0)
677
 
    # We want only 'ascii' command names, but the user may have typed
678
 
    # in a Unicode name. In that case, they should just get a
679
 
    # 'command not found' error later.
 
616
 
 
617
    cmd = str(argv.pop(0))
680
618
 
681
619
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
682
 
    run = cmd_obj.run_argv_aliases
683
 
    run_argv = [argv, alias_argv]
684
 
 
685
 
    try:
686
 
        if opt_lsprof:
687
 
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
688
 
        elif opt_profile:
689
 
            ret = apply_profiled(run, *run_argv)
690
 
        else:
691
 
            ret = run(*run_argv)
692
 
        return ret or 0
693
 
    finally:
694
 
        # reset, in case we may do other commands later within the same process
695
 
        trace.be_quiet(False)
696
 
 
697
 
def display_command(func):
698
 
    """Decorator that suppresses pipe/interrupt errors."""
699
 
    def ignore_pipe(*args, **kwargs):
700
 
        try:
701
 
            result = func(*args, **kwargs)
702
 
            sys.stdout.flush()
703
 
            return result
704
 
        except IOError, e:
705
 
            if getattr(e, 'errno', None) is None:
706
 
                raise
707
 
            if e.errno != errno.EPIPE:
708
 
                # Win32 raises IOError with errno=0 on a broken pipe
709
 
                if sys.platform != 'win32' or (e.errno not in (0, errno.EINVAL)):
710
 
                    raise
711
 
            pass
712
 
        except KeyboardInterrupt:
713
 
            pass
714
 
    return ignore_pipe
 
620
 
 
621
    if opt_profile:
 
622
        ret = apply_profiled(cmd_obj.run_argv, argv)
 
623
    else:
 
624
        ret = cmd_obj.run_argv(argv)
 
625
    return ret or 0
715
626
 
716
627
 
717
628
def main(argv):
718
629
    import bzrlib.ui
719
 
    from bzrlib.ui.text import TextUIFactory
720
 
    bzrlib.ui.ui_factory = TextUIFactory()
721
 
    argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
722
 
    ret = run_bzr_catch_errors(argv)
723
 
    trace.mutter("return code %d", ret)
724
 
    return ret
 
630
    bzrlib.trace.log_startup(argv)
 
631
    bzrlib.ui.ui_factory = bzrlib.ui.TextUIFactory()
 
632
 
 
633
    return run_bzr_catch_errors(argv[1:])
725
634
 
726
635
 
727
636
def run_bzr_catch_errors(argv):
728
637
    try:
729
 
        return run_bzr(argv)
730
 
    except (KeyboardInterrupt, Exception), e:
731
 
        # used to handle AssertionError and KeyboardInterrupt
732
 
        # specially here, but hopefully they're handled ok by the logger now
733
 
        trace.report_exception(sys.exc_info(), sys.stderr)
734
 
        if os.environ.get('BZR_PDB'):
735
 
            print '**** entering debugger'
736
 
            import pdb
737
 
            pdb.post_mortem(sys.exc_traceback)
 
638
        try:
 
639
            return run_bzr(argv)
 
640
        finally:
 
641
            # do this here inside the exception wrappers to catch EPIPE
 
642
            sys.stdout.flush()
 
643
    except BzrCommandError, e:
 
644
        # command line syntax error, etc
 
645
        log_error(str(e))
 
646
        return 1
 
647
    except BzrError, e:
 
648
        bzrlib.trace.log_exception()
 
649
        return 1
 
650
    except AssertionError, e:
 
651
        bzrlib.trace.log_exception('assertion failed: ' + str(e))
738
652
        return 3
739
 
 
740
 
 
741
 
class HelpCommandIndex(object):
742
 
    """A index for bzr help that returns commands."""
743
 
 
744
 
    def __init__(self):
745
 
        self.prefix = 'commands/'
746
 
 
747
 
    def get_topics(self, topic):
748
 
        """Search for topic amongst commands.
749
 
 
750
 
        :param topic: A topic to search for.
751
 
        :return: A list which is either empty or contains a single
752
 
            Command entry.
753
 
        """
754
 
        if topic and topic.startswith(self.prefix):
755
 
            topic = topic[len(self.prefix):]
756
 
        try:
757
 
            cmd = _get_cmd_object(topic)
758
 
        except KeyError:
759
 
            return []
 
653
    except KeyboardInterrupt, e:
 
654
        bzrlib.trace.log_exception('interrupted')
 
655
        return 2
 
656
    except Exception, e:
 
657
        import errno
 
658
        if (isinstance(e, IOError) 
 
659
            and hasattr(e, 'errno')
 
660
            and e.errno == errno.EPIPE):
 
661
            bzrlib.trace.note('broken pipe')
 
662
            return 2
760
663
        else:
761
 
            return [cmd]
762
 
 
 
664
            ## import pdb
 
665
            ## pdb.pm()
 
666
            bzrlib.trace.log_exception()
 
667
            return 2
763
668
 
764
669
if __name__ == '__main__':
765
670
    sys.exit(main(sys.argv))