~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

[merge] jam-integration

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
 
32
from warnings import warn
 
33
from inspect import getdoc
37
34
import errno
38
 
from warnings import warn
39
35
 
40
36
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
 
    )
55
 
# Compatibility
 
37
import bzrlib.trace
 
38
from bzrlib.trace import mutter, note, log_error, warning, be_quiet
 
39
from bzrlib.errors import (BzrError, 
 
40
                           BzrCheckError,
 
41
                           BzrCommandError,
 
42
                           BzrOptionError,
 
43
                           NotBranchError)
 
44
from bzrlib.revisionspec import RevisionSpec
 
45
from bzrlib import BZRDIR
56
46
from bzrlib.option import Option
57
47
 
58
 
 
59
48
plugin_cmds = {}
60
49
 
61
50
 
62
51
def register_command(cmd, decorate=False):
63
 
    """Utility function to help register a command
64
 
 
65
 
    :param cmd: Command subclass to register
66
 
    :param decorate: If true, allow overriding an existing command
67
 
        of the same name; the old command is returned by this function.
68
 
        Otherwise it is an error to try to override an existing command.
69
 
    """
 
52
    "Utility function to help register a command"
70
53
    global plugin_cmds
71
54
    k = cmd.__name__
72
55
    if k.startswith("cmd_"):
73
56
        k_unsquished = _unsquish_command_name(k)
74
57
    else:
75
58
        k_unsquished = k
76
 
    if k_unsquished not in plugin_cmds:
 
59
    if not plugin_cmds.has_key(k_unsquished):
77
60
        plugin_cmds[k_unsquished] = cmd
78
 
        ## trace.mutter('registered plugin command %s', k_unsquished)
 
61
        mutter('registered plugin command %s', k_unsquished)      
79
62
        if decorate and k_unsquished in builtin_command_names():
80
63
            return _builtin_commands()[k_unsquished]
81
64
    elif decorate:
83
66
        plugin_cmds[k_unsquished] = cmd
84
67
        return result
85
68
    else:
86
 
        trace.log_error('Two plugins defined the same command: %r' % k)
87
 
        trace.log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
88
 
        trace.log_error('Previously this command was registered from %r' %
89
 
                        sys.modules[plugin_cmds[k_unsquished].__module__])
 
69
        log_error('Two plugins defined the same command: %r' % k)
 
70
        log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
90
71
 
91
72
 
92
73
def _squish_command_name(cmd):
104
85
    builtins = bzrlib.builtins.__dict__
105
86
    for name in builtins:
106
87
        if name.startswith("cmd_"):
107
 
            real_name = _unsquish_command_name(name)
 
88
            real_name = _unsquish_command_name(name)        
108
89
            r[real_name] = builtins[name]
109
90
    return r
 
91
 
110
92
            
111
93
 
112
94
def builtin_command_names():
138
120
    plugins_override
139
121
        If true, plugin commands can override builtins.
140
122
    """
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
123
    from bzrlib.externalcommand import ExternalCommand
150
124
 
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.
 
125
    cmd_name = str(cmd_name)            # not unicode
155
126
 
156
127
    # first look up this command under the specified name
157
128
    cmds = _get_cmd_dict(plugins_override=plugins_override)
168
139
    cmd_obj = ExternalCommand.find_command(cmd_name)
169
140
    if cmd_obj:
170
141
        return cmd_obj
171
 
    raise KeyError
 
142
 
 
143
    raise BzrCommandError("unknown command %r" % cmd_name)
172
144
 
173
145
 
174
146
class Command(object):
212
184
    hidden
213
185
        If true, this command isn't advertised.  This is typically
214
186
        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
187
    """
232
188
    aliases = []
233
189
    takes_args = []
234
190
    takes_options = []
235
 
    encoding_type = 'strict'
236
191
 
237
192
    hidden = False
238
193
    
240
195
        """Construct an instance of this command."""
241
196
        if self.__doc__ == Command.__doc__:
242
197
            warn("No help message set for %r" % self)
243
 
        # List of standard options directly supported
244
 
        self.supported_std_options = []
245
 
 
246
 
    def _maybe_expand_globs(self, file_list):
247
 
        """Glob expand file_list if the platform does not do that itself.
248
 
        
249
 
        :return: A possibly empty list of unicode paths.
250
 
 
251
 
        Introduced in bzrlib 0.18.
252
 
        """
253
 
        if not file_list:
254
 
            file_list = []
255
 
        if sys.platform == 'win32':
256
 
            file_list = win32utils.glob_expand(file_list)
257
 
        return list(file_list)
258
 
 
259
 
    def _usage(self):
260
 
        """Return single-line grammar for this command.
261
 
 
262
 
        Only describes arguments, not options.
263
 
        """
264
 
        s = 'bzr ' + self.name() + ' '
265
 
        for aname in self.takes_args:
266
 
            aname = aname.upper()
267
 
            if aname[-1] in ['$', '+']:
268
 
                aname = aname[:-1] + '...'
269
 
            elif aname[-1] == '?':
270
 
                aname = '[' + aname[:-1] + ']'
271
 
            elif aname[-1] == '*':
272
 
                aname = '[' + aname[:-1] + '...]'
273
 
            s += aname + ' '
274
 
                
275
 
        assert s[-1] == ' '
276
 
        s = s[:-1]
277
 
        return s
278
 
 
279
 
    def get_help_text(self, additional_see_also=None, plain=True,
280
 
                      see_also_as_links=False):
281
 
        """Return a text string with help for this command.
282
 
        
283
 
        :param additional_see_also: Additional help topics to be
284
 
            cross-referenced.
285
 
        :param plain: if False, raw help (reStructuredText) is
286
 
            returned instead of plain text.
287
 
        :param see_also_as_links: if True, convert items in 'See also'
288
 
            list to internal links (used by bzr_man rstx generator)
289
 
        """
290
 
        doc = self.help()
291
 
        if doc is None:
292
 
            raise NotImplementedError("sorry, no detailed help yet for %r" % self.name())
293
 
 
294
 
        # Extract the summary (purpose) and sections out from the text
295
 
        purpose,sections = self._get_help_parts(doc)
296
 
 
297
 
        # If a custom usage section was provided, use it
298
 
        if sections.has_key('Usage'):
299
 
            usage = sections.pop('Usage')
300
 
        else:
301
 
            usage = self._usage()
302
 
 
303
 
        # The header is the purpose and usage
304
 
        result = ""
305
 
        result += ':Purpose: %s\n' % purpose
306
 
        if usage.find('\n') >= 0:
307
 
            result += ':Usage:\n%s\n' % usage
308
 
        else:
309
 
            result += ':Usage:   %s\n' % usage
310
 
        result += '\n'
311
 
 
312
 
        # Add the options
313
 
        options = option.get_optparser(self.options()).format_option_help()
314
 
        if options.startswith('Options:'):
315
 
            result += ':' + options
316
 
        elif options.startswith('options:'):
317
 
            # Python 2.4 version of optparse
318
 
            result += ':Options:' + options[len('options:'):]
319
 
        else:
320
 
            result += options
321
 
        result += '\n'
322
 
 
323
 
        # Add the description, indenting it 2 spaces
324
 
        # to match the indentation of the options
325
 
        if sections.has_key(None):
326
 
            text = sections.pop(None)
327
 
            text = '\n  '.join(text.splitlines())
328
 
            result += ':%s:\n  %s\n\n' % ('Description',text)
329
 
 
330
 
        # Add the custom sections (e.g. Examples). Note that there's no need
331
 
        # to indent these as they must be indented already in the source.
332
 
        if sections:
333
 
            labels = sorted(sections.keys())
334
 
            for label in labels:
335
 
                result += ':%s:\n%s\n\n' % (label,sections[label])
336
 
 
337
 
        # Add the aliases, source (plug-in) and see also links, if any
338
 
        if self.aliases:
339
 
            result += ':Aliases:  '
340
 
            result += ', '.join(self.aliases) + '\n'
341
 
        plugin_name = self.plugin_name()
342
 
        if plugin_name is not None:
343
 
            result += ':From:     plugin "%s"\n' % plugin_name
344
 
        see_also = self.get_see_also(additional_see_also)
345
 
        if see_also:
346
 
            if not plain and see_also_as_links:
347
 
                see_also_links = []
348
 
                for item in see_also:
349
 
                    if item == 'topics':
350
 
                        # topics doesn't have an independent section
351
 
                        # so don't create a real link
352
 
                        see_also_links.append(item)
353
 
                    else:
354
 
                        # Use a reST link for this entry
355
 
                        see_also_links.append("`%s`_" % (item,))
356
 
                see_also = see_also_links
357
 
            result += ':See also: '
358
 
            result += ', '.join(see_also) + '\n'
359
 
 
360
 
        # If this will be rendered as plan text, convert it
361
 
        if plain:
362
 
            import bzrlib.help_topics
363
 
            result = bzrlib.help_topics.help_as_plain_text(result)
364
 
        return result
365
 
 
366
 
    @staticmethod
367
 
    def _get_help_parts(text):
368
 
        """Split help text into a summary and named sections.
369
 
 
370
 
        :return: (summary,sections) where summary is the top line and
371
 
            sections is a dictionary of the rest indexed by section name.
372
 
            A section starts with a heading line of the form ":xxx:".
373
 
            Indented text on following lines is the section value.
374
 
            All text found outside a named section is assigned to the
375
 
            default section which is given the key of None.
376
 
        """
377
 
        def save_section(sections, label, section):
378
 
            if len(section) > 0:
379
 
                if sections.has_key(label):
380
 
                    sections[label] += '\n' + section
381
 
                else:
382
 
                    sections[label] = section
383
 
            
384
 
        lines = text.rstrip().splitlines()
385
 
        summary = lines.pop(0)
386
 
        sections = {}
387
 
        label,section = None,''
388
 
        for line in lines:
389
 
            if line.startswith(':') and line.endswith(':') and len(line) > 2:
390
 
                save_section(sections, label, section)
391
 
                label,section = line[1:-1],''
392
 
            elif label != None and len(line) > 1 and not line[0].isspace():
393
 
                save_section(sections, label, section)
394
 
                label,section = None,line
395
 
            else:
396
 
                if len(section) > 0:
397
 
                    section += '\n' + line
398
 
                else:
399
 
                    section = line
400
 
        save_section(sections, label, section)
401
 
        return summary, sections
402
 
 
403
 
    def get_help_topic(self):
404
 
        """Return the commands help topic - its name."""
405
 
        return self.name()
406
 
 
407
 
    def get_see_also(self, additional_terms=None):
408
 
        """Return a list of help topics that are related to this command.
409
 
        
410
 
        The list is derived from the content of the _see_also attribute. Any
411
 
        duplicates are removed and the result is in lexical order.
412
 
        :param additional_terms: Additional help topics to cross-reference.
413
 
        :return: A list of help topics.
414
 
        """
415
 
        see_also = set(getattr(self, '_see_also', []))
416
 
        if additional_terms:
417
 
            see_also.update(additional_terms)
418
 
        return sorted(see_also)
419
198
 
420
199
    def options(self):
421
200
        """Return dict of valid options for this command.
422
201
 
423
202
        Maps from long option name to option object."""
424
 
        r = Option.STD_OPTIONS.copy()
425
 
        std_names = r.keys()
 
203
        r = dict()
 
204
        r['help'] = Option.OPTIONS['help']
426
205
        for o in self.takes_options:
427
 
            if isinstance(o, basestring):
428
 
                o = option.Option.OPTIONS[o]
 
206
            if not isinstance(o, Option):
 
207
                o = Option.OPTIONS[o]
429
208
            r[o.name] = o
430
 
            if o.name in std_names:
431
 
                self.supported_std_options.append(o.name)
432
209
        return r
433
210
 
434
 
    def _setup_outf(self):
435
 
        """Return a file linked to stdout, which has proper encoding."""
436
 
        assert self.encoding_type in ['strict', 'exact', 'replace']
437
 
 
438
 
        # Originally I was using self.stdout, but that looks
439
 
        # *way* too much like sys.stdout
440
 
        if self.encoding_type == 'exact':
441
 
            # force sys.stdout to be binary stream on win32
442
 
            if sys.platform == 'win32':
443
 
                fileno = getattr(sys.stdout, 'fileno', None)
444
 
                if fileno:
445
 
                    import msvcrt
446
 
                    msvcrt.setmode(fileno(), os.O_BINARY)
447
 
            self.outf = sys.stdout
448
 
            return
449
 
 
450
 
        output_encoding = osutils.get_terminal_encoding()
451
 
 
452
 
        self.outf = codecs.getwriter(output_encoding)(sys.stdout,
453
 
                        errors=self.encoding_type)
454
 
        # For whatever reason codecs.getwriter() does not advertise its encoding
455
 
        # it just returns the encoding of the wrapped file, which is completely
456
 
        # bogus. So set the attribute, so we can find the correct encoding later.
457
 
        self.outf.encoding = output_encoding
458
 
 
459
 
    def run_argv_aliases(self, argv, alias_argv=None):
460
 
        """Parse the command line and run with extra aliases in alias_argv."""
461
 
        if argv is None:
462
 
            warn("Passing None for [] is deprecated from bzrlib 0.10",
463
 
                 DeprecationWarning, stacklevel=2)
464
 
            argv = []
465
 
        args, opts = parse_args(self, argv, alias_argv)
466
 
 
467
 
        # Process the standard options
 
211
    def run_argv(self, argv):
 
212
        """Parse command line and run."""
 
213
        args, opts = parse_args(self, argv)
468
214
        if 'help' in opts:  # e.g. bzr add --help
469
 
            sys.stdout.write(self.get_help_text())
 
215
            from bzrlib.help import help_on_command
 
216
            help_on_command(self.name())
470
217
            return 0
471
 
        trace.set_verbosity_level(option._verbosity_level)
472
 
        if 'verbose' in self.supported_std_options:
473
 
            opts['verbose'] = trace.is_verbose()
474
 
        elif opts.has_key('verbose'):
475
 
            del opts['verbose']
476
 
        if 'quiet' in self.supported_std_options:
477
 
            opts['quiet'] = trace.is_quiet()
478
 
        elif opts.has_key('quiet'):
479
 
            del opts['quiet']
480
 
 
 
218
        # XXX: This should be handled by the parser
 
219
        allowed_names = self.options().keys()
 
220
        for oname in opts:
 
221
            if oname not in allowed_names:
 
222
                raise BzrCommandError("option '--%s' is not allowed for command %r"
 
223
                                      % (oname, self.name()))
481
224
        # mix arguments and options into one dictionary
482
225
        cmdargs = _match_argform(self.name(), self.takes_args, args)
483
226
        cmdopts = {}
487
230
        all_cmd_args = cmdargs.copy()
488
231
        all_cmd_args.update(cmdopts)
489
232
 
490
 
        self._setup_outf()
491
 
 
492
233
        return self.run(**all_cmd_args)
493
234
    
494
235
    def run(self):
501
242
        shell error code if not.  It's OK for this method to allow
502
243
        an exception to raise up.
503
244
        """
504
 
        raise NotImplementedError('no implementation of command %r'
505
 
                                  % self.name())
 
245
        raise NotImplementedError()
 
246
 
506
247
 
507
248
    def help(self):
508
249
        """Return help message for this class."""
509
 
        from inspect import getdoc
510
250
        if self.__doc__ is Command.__doc__:
511
251
            return None
512
252
        return getdoc(self)
514
254
    def name(self):
515
255
        return _unsquish_command_name(self.__class__.__name__)
516
256
 
517
 
    def plugin_name(self):
518
 
        """Get the name of the plugin that provides this command.
519
257
 
520
 
        :return: The name of the plugin or None if the command is builtin.
521
 
        """
522
 
        mod_parts = self.__module__.split('.')
523
 
        if len(mod_parts) >= 3 and mod_parts[1] == 'plugins':
524
 
            return mod_parts[2]
 
258
def parse_spec(spec):
 
259
    """
 
260
    >>> parse_spec(None)
 
261
    [None, None]
 
262
    >>> parse_spec("./")
 
263
    ['./', None]
 
264
    >>> parse_spec("../@")
 
265
    ['..', -1]
 
266
    >>> parse_spec("../f/@35")
 
267
    ['../f', 35]
 
268
    >>> parse_spec('./@revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67')
 
269
    ['.', 'revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67']
 
270
    """
 
271
    if spec is None:
 
272
        return [None, None]
 
273
    if '/@' in spec:
 
274
        parsed = spec.split('/@')
 
275
        assert len(parsed) == 2
 
276
        if parsed[1] == "":
 
277
            parsed[1] = -1
525
278
        else:
526
 
            return None
527
 
 
528
 
 
529
 
def parse_args(command, argv, alias_argv=None):
 
279
            try:
 
280
                parsed[1] = int(parsed[1])
 
281
            except ValueError:
 
282
                pass # We can allow stuff like ./@revid:blahblahblah
 
283
            else:
 
284
                assert parsed[1] >=0
 
285
    else:
 
286
        parsed = [spec, None]
 
287
    return parsed
 
288
 
 
289
def parse_args(command, argv):
530
290
    """Parse command line.
531
291
    
532
292
    Arguments and options are parsed at this level before being passed
534
294
    lookup table, something about the available options, what optargs
535
295
    they take, and which commands will accept them.
536
296
    """
537
 
    # TODO: make it a method of the Command?
538
 
    parser = option.get_optparser(command.options())
539
 
    if alias_argv is not None:
540
 
        args = alias_argv + argv
541
 
    else:
542
 
        args = argv
543
 
 
544
 
    options, args = parser.parse_args(args)
545
 
    opts = dict([(k, v) for k, v in options.__dict__.iteritems() if
546
 
                 v is not option.OptionParser.DEFAULT_VALUE])
 
297
    # TODO: chop up this beast; make it a method of the Command
 
298
    args = []
 
299
    opts = {}
 
300
 
 
301
    cmd_options = command.options()
 
302
    argsover = False
 
303
    while argv:
 
304
        a = argv.pop(0)
 
305
        if argsover:
 
306
            args.append(a)
 
307
            continue
 
308
        elif a == '--':
 
309
            # We've received a standalone -- No more flags
 
310
            argsover = True
 
311
            continue
 
312
        if a[0] == '-':
 
313
            # option names must not be unicode
 
314
            a = str(a)
 
315
            optarg = None
 
316
            if a[1] == '-':
 
317
                mutter("  got option %r", a)
 
318
                if '=' in a:
 
319
                    optname, optarg = a[2:].split('=', 1)
 
320
                else:
 
321
                    optname = a[2:]
 
322
                if optname not in cmd_options:
 
323
                    raise BzrOptionError('unknown long option %r for command %s'
 
324
                        % (a, command.name()))
 
325
            else:
 
326
                shortopt = a[1:]
 
327
                if shortopt in Option.SHORT_OPTIONS:
 
328
                    # Multi-character options must have a space to delimit
 
329
                    # their value
 
330
                    # ^^^ what does this mean? mbp 20051014
 
331
                    optname = Option.SHORT_OPTIONS[shortopt].name
 
332
                else:
 
333
                    # Single character short options, can be chained,
 
334
                    # and have their value appended to their name
 
335
                    shortopt = a[1:2]
 
336
                    if shortopt not in Option.SHORT_OPTIONS:
 
337
                        # We didn't find the multi-character name, and we
 
338
                        # didn't find the single char name
 
339
                        raise BzrError('unknown short option %r' % a)
 
340
                    optname = Option.SHORT_OPTIONS[shortopt].name
 
341
 
 
342
                    if a[2:]:
 
343
                        # There are extra things on this option
 
344
                        # see if it is the value, or if it is another
 
345
                        # short option
 
346
                        optargfn = Option.OPTIONS[optname].type
 
347
                        if optargfn is None:
 
348
                            # This option does not take an argument, so the
 
349
                            # next entry is another short option, pack it back
 
350
                            # into the list
 
351
                            argv.insert(0, '-' + a[2:])
 
352
                        else:
 
353
                            # This option takes an argument, so pack it
 
354
                            # into the array
 
355
                            optarg = a[2:]
 
356
            
 
357
                if optname not in cmd_options:
 
358
                    raise BzrOptionError('unknown short option %r for command'
 
359
                        ' %s' % (shortopt, command.name()))
 
360
            if optname in opts:
 
361
                # XXX: Do we ever want to support this, e.g. for -r?
 
362
                raise BzrError('repeated option %r' % a)
 
363
                
 
364
            option_obj = cmd_options[optname]
 
365
            optargfn = option_obj.type
 
366
            if optargfn:
 
367
                if optarg == None:
 
368
                    if not argv:
 
369
                        raise BzrError('option %r needs an argument' % a)
 
370
                    else:
 
371
                        optarg = argv.pop(0)
 
372
                opts[optname] = optargfn(optarg)
 
373
            else:
 
374
                if optarg != None:
 
375
                    raise BzrError('option %r takes no argument' % optname)
 
376
                opts[optname] = True
 
377
        else:
 
378
            args.append(a)
547
379
    return args, opts
548
380
 
549
381
 
564
396
                argdict[argname + '_list'] = None
565
397
        elif ap[-1] == '+':
566
398
            if not args:
567
 
                raise errors.BzrCommandError("command %r needs one or more %s"
568
 
                                             % (cmd, argname.upper()))
 
399
                raise BzrCommandError("command %r needs one or more %s"
 
400
                        % (cmd, argname.upper()))
569
401
            else:
570
402
                argdict[argname + '_list'] = args[:]
571
403
                args = []
572
404
        elif ap[-1] == '$': # all but one
573
405
            if len(args) < 2:
574
 
                raise errors.BzrCommandError("command %r needs one or more %s"
575
 
                                             % (cmd, argname.upper()))
 
406
                raise BzrCommandError("command %r needs one or more %s"
 
407
                        % (cmd, argname.upper()))
576
408
            argdict[argname + '_list'] = args[:-1]
577
 
            args[:-1] = []
 
409
            args[:-1] = []                
578
410
        else:
579
411
            # just a plain arg
580
412
            argname = ap
581
413
            if not args:
582
 
                raise errors.BzrCommandError("command %r requires argument %s"
583
 
                               % (cmd, argname.upper()))
 
414
                raise BzrCommandError("command %r requires argument %s"
 
415
                        % (cmd, argname.upper()))
584
416
            else:
585
417
                argdict[argname] = args.pop(0)
586
418
            
587
419
    if args:
588
 
        raise errors.BzrCommandError("extra argument to command %s: %s"
589
 
                                     % (cmd, args[0]))
 
420
        raise BzrCommandError("extra argument to command %s: %s"
 
421
                              % (cmd, args[0]))
590
422
 
591
423
    return argdict
592
424
 
615
447
        os.remove(pfname)
616
448
 
617
449
 
618
 
def apply_lsprofiled(filename, the_callable, *args, **kwargs):
 
450
def apply_lsprofiled(the_callable, *args, **kwargs):
619
451
    from bzrlib.lsprof import profile
620
 
    ret, stats = profile(the_callable, *args, **kwargs)
 
452
    ret,stats = profile(the_callable,*args,**kwargs)
621
453
    stats.sort()
622
 
    if filename is None:
623
 
        stats.pprint()
624
 
    else:
625
 
        stats.save(filename)
626
 
        trace.note('Profile data written to "%s".', filename)
 
454
    stats.pprint()
627
455
    return ret
628
456
 
629
 
 
630
 
def get_alias(cmd, config=None):
631
 
    """Return an expanded alias, or None if no alias exists.
632
 
 
633
 
    cmd
634
 
        Command to be checked for an alias.
635
 
    config
636
 
        Used to specify an alternative config to use,
637
 
        which is especially useful for testing.
638
 
        If it is unspecified, the global config will be used.
639
 
    """
640
 
    if config is None:
641
 
        import bzrlib.config
642
 
        config = bzrlib.config.GlobalConfig()
643
 
    alias = config.get_alias(cmd)
644
 
    if (alias):
645
 
        import shlex
646
 
        return [a.decode('utf-8') for a in shlex.split(alias.encode('utf-8'))]
647
 
    return None
648
 
 
649
 
 
650
457
def run_bzr(argv):
651
458
    """Execute a command.
652
459
 
655
462
    
656
463
    argv
657
464
       The command-line arguments, without the program name from argv[0]
658
 
       These should already be decoded. All library/test code calling
659
 
       run_bzr should be passing valid strings (don't need decoding).
660
465
    
661
466
    Returns a command status or raises an exception.
662
467
 
666
471
    --no-plugins
667
472
        Do not load plugin modules at all
668
473
 
669
 
    --no-aliases
670
 
        Do not allow aliases
671
 
 
672
474
    --builtin
673
475
        Only use builtin commands.  (Plugins are still allowed to change
674
476
        other behaviour.)
679
481
    --lsprof
680
482
        Run under the Python lsprof profiler.
681
483
    """
682
 
    argv = list(argv)
683
 
    trace.mutter("bzr arguments: %r", argv)
 
484
    argv = [a.decode(bzrlib.user_encoding) for a in argv]
684
485
 
685
 
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
686
 
                opt_no_aliases = False
687
 
    opt_lsprof_file = None
 
486
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin = False
688
487
 
689
488
    # --no-plugins is handled specially at a very early stage. We need
690
489
    # to load plugins before doing other command parsing so that they
691
490
    # can override commands, but this needs to happen first.
692
491
 
693
 
    argv_copy = []
694
 
    i = 0
695
 
    while i < len(argv):
696
 
        a = argv[i]
 
492
    for a in argv:
697
493
        if a == '--profile':
698
494
            opt_profile = True
699
495
        elif a == '--lsprof':
700
496
            opt_lsprof = True
701
 
        elif a == '--lsprof-file':
702
 
            opt_lsprof = True
703
 
            opt_lsprof_file = argv[i + 1]
704
 
            i += 1
705
497
        elif a == '--no-plugins':
706
498
            opt_no_plugins = True
707
 
        elif a == '--no-aliases':
708
 
            opt_no_aliases = True
709
499
        elif a == '--builtin':
710
500
            opt_builtin = True
711
 
        elif a.startswith('-D'):
712
 
            debug.debug_flags.add(a[2:])
 
501
        elif a in ('--quiet', '-q'):
 
502
            be_quiet()
713
503
        else:
714
 
            argv_copy.append(a)
715
 
        i += 1
 
504
            continue
 
505
        argv.remove(a)
716
506
 
717
 
    argv = argv_copy
718
 
    if (not argv):
719
 
        from bzrlib.builtins import cmd_help
720
 
        cmd_help().run_argv_aliases([])
 
507
    if (not argv) or (argv[0] == '--help'):
 
508
        from bzrlib.help import help
 
509
        if len(argv) > 1:
 
510
            help(argv[1])
 
511
        else:
 
512
            help()
721
513
        return 0
722
514
 
723
515
    if argv[0] == '--version':
724
 
        from bzrlib.builtins import cmd_version
725
 
        cmd_version().run_argv_aliases([])
 
516
        from bzrlib.builtins import show_version
 
517
        show_version()
726
518
        return 0
727
519
        
728
520
    if not opt_no_plugins:
729
521
        from bzrlib.plugin import load_plugins
730
522
        load_plugins()
731
 
    else:
732
 
        from bzrlib.plugin import disable_plugins
733
 
        disable_plugins()
734
 
 
735
 
    alias_argv = None
736
 
 
737
 
    if not opt_no_aliases:
738
 
        alias_argv = get_alias(argv[0])
739
 
        if alias_argv:
740
 
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
741
 
            argv[0] = alias_argv.pop(0)
742
 
 
743
 
    cmd = argv.pop(0)
744
 
    # We want only 'ascii' command names, but the user may have typed
745
 
    # in a Unicode name. In that case, they should just get a
746
 
    # 'command not found' error later.
 
523
 
 
524
    cmd = str(argv.pop(0))
747
525
 
748
526
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
749
 
    run = cmd_obj.run_argv_aliases
750
 
    run_argv = [argv, alias_argv]
751
527
 
752
528
    try:
753
529
        if opt_lsprof:
754
 
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
 
530
            ret = apply_lsprofiled(cmd_obj.run_argv, argv)
755
531
        elif opt_profile:
756
 
            ret = apply_profiled(run, *run_argv)
 
532
            ret = apply_profiled(cmd_obj.run_argv, argv)
757
533
        else:
758
 
            ret = run(*run_argv)
 
534
            ret = cmd_obj.run_argv(argv)
759
535
        return ret or 0
760
536
    finally:
761
537
        # reset, in case we may do other commands later within the same process
762
 
        option._verbosity_level = 0
 
538
        be_quiet(False)
763
539
 
764
540
def display_command(func):
765
541
    """Decorator that suppresses pipe/interrupt errors."""
769
545
            sys.stdout.flush()
770
546
            return result
771
547
        except IOError, e:
772
 
            if getattr(e, 'errno', None) is None:
 
548
            if not hasattr(e, 'errno'):
773
549
                raise
774
550
            if e.errno != errno.EPIPE:
775
 
                # Win32 raises IOError with errno=0 on a broken pipe
776
 
                if sys.platform != 'win32' or (e.errno not in (0, errno.EINVAL)):
777
 
                    raise
 
551
                raise
778
552
            pass
779
553
        except KeyboardInterrupt:
780
554
            pass
784
558
def main(argv):
785
559
    import bzrlib.ui
786
560
    from bzrlib.ui.text import TextUIFactory
 
561
    ## bzrlib.trace.enable_default_logging()
 
562
    bzrlib.trace.log_startup(argv)
787
563
    bzrlib.ui.ui_factory = TextUIFactory()
788
 
    try:
789
 
        argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
790
 
    except UnicodeDecodeError:
791
 
        raise errors.BzrError(("Parameter '%r' is unsupported by the current "
792
 
                                                            "encoding." % a))
793
 
    ret = run_bzr_catch_errors(argv)
794
 
    trace.mutter("return code %d", ret)
 
564
    ret = run_bzr_catch_errors(argv[1:])
 
565
    mutter("return code %d", ret)
795
566
    return ret
796
567
 
797
568
 
798
569
def run_bzr_catch_errors(argv):
799
 
    # Note: The except clause logic below should be kept in sync with the
800
 
    # profile() routine in lsprof.py.
801
570
    try:
802
 
        return run_bzr(argv)
803
 
    except (KeyboardInterrupt, Exception), e:
 
571
        try:
 
572
            return run_bzr(argv)
 
573
        finally:
 
574
            # do this here inside the exception wrappers to catch EPIPE
 
575
            sys.stdout.flush()
 
576
    except Exception, e:
804
577
        # used to handle AssertionError and KeyboardInterrupt
805
578
        # specially here, but hopefully they're handled ok by the logger now
806
 
        exitcode = trace.report_exception(sys.exc_info(), sys.stderr)
807
 
        if os.environ.get('BZR_PDB'):
808
 
            print '**** entering debugger'
809
 
            import pdb
810
 
            pdb.post_mortem(sys.exc_traceback)
811
 
        return exitcode
812
 
 
813
 
 
814
 
def run_bzr_catch_user_errors(argv):
815
 
    """Run bzr and report user errors, but let internal errors propagate.
816
 
 
817
 
    This is used for the test suite, and might be useful for other programs
818
 
    that want to wrap the commandline interface.
819
 
    """
820
 
    try:
821
 
        return run_bzr(argv)
822
 
    except Exception, e:
823
 
        if (isinstance(e, (OSError, IOError))
824
 
            or not getattr(e, 'internal_error', True)):
825
 
            trace.report_exception(sys.exc_info(), sys.stderr)
826
 
            return 3
827
 
        else:
828
 
            raise
829
 
 
830
 
 
831
 
class HelpCommandIndex(object):
832
 
    """A index for bzr help that returns commands."""
833
 
 
834
 
    def __init__(self):
835
 
        self.prefix = 'commands/'
836
 
 
837
 
    def get_topics(self, topic):
838
 
        """Search for topic amongst commands.
839
 
 
840
 
        :param topic: A topic to search for.
841
 
        :return: A list which is either empty or contains a single
842
 
            Command entry.
843
 
        """
844
 
        if topic and topic.startswith(self.prefix):
845
 
            topic = topic[len(self.prefix):]
846
 
        try:
847
 
            cmd = _get_cmd_object(topic)
848
 
        except KeyError:
849
 
            return []
850
 
        else:
851
 
            return [cmd]
852
 
 
 
579
        import errno
 
580
        if (isinstance(e, IOError) 
 
581
            and hasattr(e, 'errno')
 
582
            and e.errno == errno.EPIPE):
 
583
            bzrlib.trace.note('broken pipe')
 
584
            return 3
 
585
        else:
 
586
            bzrlib.trace.log_exception()
 
587
            if os.environ.get('BZR_PDB'):
 
588
                print '**** entering debugger'
 
589
                import pdb
 
590
                pdb.post_mortem(sys.exc_traceback)
 
591
            return 3
853
592
 
854
593
if __name__ == '__main__':
855
594
    sys.exit(main(sys.argv))