~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: Martin Pool
  • Date: 2005-11-04 01:46:31 UTC
  • mto: (1185.33.49 bzr.dev)
  • mto: This revision was merged to the branch mainline in revision 1512.
  • Revision ID: mbp@sourcefrog.net-20051104014631-750e0ad4172c952c
Make biobench directly executable

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
 
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):
196
168
        List of argument forms, marked with whether they are optional,
197
169
        repeated, etc.
198
170
 
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
171
    takes_options
208
172
        List of options that may be given for this command.  These can
209
173
        be either strings, referring to globally-defined options,
212
176
    hidden
213
177
        If true, this command isn't advertised.  This is typically
214
178
        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
179
    """
232
180
    aliases = []
233
181
    takes_args = []
234
182
    takes_options = []
235
 
    encoding_type = 'strict'
236
183
 
237
184
    hidden = False
238
185
    
240
187
        """Construct an instance of this command."""
241
188
        if self.__doc__ == Command.__doc__:
242
189
            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
190
 
420
191
    def options(self):
421
192
        """Return dict of valid options for this command.
422
193
 
423
194
        Maps from long option name to option object."""
424
 
        r = Option.STD_OPTIONS.copy()
425
 
        std_names = r.keys()
 
195
        r = dict()
 
196
        r['help'] = Option.OPTIONS['help']
426
197
        for o in self.takes_options:
427
 
            if isinstance(o, basestring):
428
 
                o = option.Option.OPTIONS[o]
 
198
            if not isinstance(o, Option):
 
199
                o = Option.OPTIONS[o]
429
200
            r[o.name] = o
430
 
            if o.name in std_names:
431
 
                self.supported_std_options.append(o.name)
432
201
        return r
433
202
 
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
 
203
    def run_argv(self, argv):
 
204
        """Parse command line and run."""
 
205
        args, opts = parse_args(self, argv)
468
206
        if 'help' in opts:  # e.g. bzr add --help
469
 
            sys.stdout.write(self.get_help_text())
 
207
            from bzrlib.help import help_on_command
 
208
            help_on_command(self.name())
470
209
            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
 
 
 
210
        # XXX: This should be handled by the parser
 
211
        allowed_names = self.options().keys()
 
212
        for oname in opts:
 
213
            if oname not in allowed_names:
 
214
                raise BzrCommandError("option '--%s' is not allowed for command %r"
 
215
                                      % (oname, self.name()))
481
216
        # mix arguments and options into one dictionary
482
217
        cmdargs = _match_argform(self.name(), self.takes_args, args)
483
218
        cmdopts = {}
487
222
        all_cmd_args = cmdargs.copy()
488
223
        all_cmd_args.update(cmdopts)
489
224
 
490
 
        self._setup_outf()
491
 
 
492
225
        return self.run(**all_cmd_args)
493
226
    
494
227
    def run(self):
501
234
        shell error code if not.  It's OK for this method to allow
502
235
        an exception to raise up.
503
236
        """
504
 
        raise NotImplementedError('no implementation of command %r'
505
 
                                  % self.name())
 
237
        raise NotImplementedError()
 
238
 
506
239
 
507
240
    def help(self):
508
241
        """Return help message for this class."""
509
 
        from inspect import getdoc
510
242
        if self.__doc__ is Command.__doc__:
511
243
            return None
512
244
        return getdoc(self)
514
246
    def name(self):
515
247
        return _unsquish_command_name(self.__class__.__name__)
516
248
 
517
 
    def plugin_name(self):
518
 
        """Get the name of the plugin that provides this command.
519
249
 
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]
 
250
def parse_spec(spec):
 
251
    """
 
252
    >>> parse_spec(None)
 
253
    [None, None]
 
254
    >>> parse_spec("./")
 
255
    ['./', None]
 
256
    >>> parse_spec("../@")
 
257
    ['..', -1]
 
258
    >>> parse_spec("../f/@35")
 
259
    ['../f', 35]
 
260
    >>> parse_spec('./@revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67')
 
261
    ['.', 'revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67']
 
262
    """
 
263
    if spec is None:
 
264
        return [None, None]
 
265
    if '/@' in spec:
 
266
        parsed = spec.split('/@')
 
267
        assert len(parsed) == 2
 
268
        if parsed[1] == "":
 
269
            parsed[1] = -1
525
270
        else:
526
 
            return None
527
 
 
528
 
 
529
 
def parse_args(command, argv, alias_argv=None):
 
271
            try:
 
272
                parsed[1] = int(parsed[1])
 
273
            except ValueError:
 
274
                pass # We can allow stuff like ./@revid:blahblahblah
 
275
            else:
 
276
                assert parsed[1] >=0
 
277
    else:
 
278
        parsed = [spec, None]
 
279
    return parsed
 
280
 
 
281
def parse_args(command, argv):
530
282
    """Parse command line.
531
283
    
532
284
    Arguments and options are parsed at this level before being passed
534
286
    lookup table, something about the available options, what optargs
535
287
    they take, and which commands will accept them.
536
288
    """
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])
 
289
    # TODO: chop up this beast; make it a method of the Command
 
290
    args = []
 
291
    opts = {}
 
292
 
 
293
    cmd_options = command.options()
 
294
    argsover = False
 
295
    while argv:
 
296
        a = argv.pop(0)
 
297
        if argsover:
 
298
            args.append(a)
 
299
            continue
 
300
        elif a == '--':
 
301
            # We've received a standalone -- No more flags
 
302
            argsover = True
 
303
            continue
 
304
        if a[0] == '-':
 
305
            # option names must not be unicode
 
306
            a = str(a)
 
307
            optarg = None
 
308
            if a[1] == '-':
 
309
                mutter("  got option %r" % a)
 
310
                if '=' in a:
 
311
                    optname, optarg = a[2:].split('=', 1)
 
312
                else:
 
313
                    optname = a[2:]
 
314
                if optname not in cmd_options:
 
315
                    raise BzrOptionError('unknown long option %r for command %s'
 
316
                        % (a, command.name()))
 
317
            else:
 
318
                shortopt = a[1:]
 
319
                if shortopt in Option.SHORT_OPTIONS:
 
320
                    # Multi-character options must have a space to delimit
 
321
                    # their value
 
322
                    # ^^^ what does this mean? mbp 20051014
 
323
                    optname = Option.SHORT_OPTIONS[shortopt].name
 
324
                else:
 
325
                    # Single character short options, can be chained,
 
326
                    # and have their value appended to their name
 
327
                    shortopt = a[1:2]
 
328
                    if shortopt not in Option.SHORT_OPTIONS:
 
329
                        # We didn't find the multi-character name, and we
 
330
                        # didn't find the single char name
 
331
                        raise BzrError('unknown short option %r' % a)
 
332
                    optname = Option.SHORT_OPTIONS[shortopt].name
 
333
 
 
334
                    if a[2:]:
 
335
                        # There are extra things on this option
 
336
                        # see if it is the value, or if it is another
 
337
                        # short option
 
338
                        optargfn = Option.OPTIONS[optname].type
 
339
                        if optargfn is None:
 
340
                            # This option does not take an argument, so the
 
341
                            # next entry is another short option, pack it back
 
342
                            # into the list
 
343
                            argv.insert(0, '-' + a[2:])
 
344
                        else:
 
345
                            # This option takes an argument, so pack it
 
346
                            # into the array
 
347
                            optarg = a[2:]
 
348
            
 
349
            if optname in opts:
 
350
                # XXX: Do we ever want to support this, e.g. for -r?
 
351
                raise BzrError('repeated option %r' % a)
 
352
                
 
353
            option_obj = cmd_options[optname]
 
354
            optargfn = option_obj.type
 
355
            if optargfn:
 
356
                if optarg == None:
 
357
                    if not argv:
 
358
                        raise BzrError('option %r needs an argument' % a)
 
359
                    else:
 
360
                        optarg = argv.pop(0)
 
361
                opts[optname] = optargfn(optarg)
 
362
            else:
 
363
                if optarg != None:
 
364
                    raise BzrError('option %r takes no argument' % optname)
 
365
                opts[optname] = True
 
366
        else:
 
367
            args.append(a)
547
368
    return args, opts
548
369
 
549
370
 
564
385
                argdict[argname + '_list'] = None
565
386
        elif ap[-1] == '+':
566
387
            if not args:
567
 
                raise errors.BzrCommandError("command %r needs one or more %s"
568
 
                                             % (cmd, argname.upper()))
 
388
                raise BzrCommandError("command %r needs one or more %s"
 
389
                        % (cmd, argname.upper()))
569
390
            else:
570
391
                argdict[argname + '_list'] = args[:]
571
392
                args = []
572
393
        elif ap[-1] == '$': # all but one
573
394
            if len(args) < 2:
574
 
                raise errors.BzrCommandError("command %r needs one or more %s"
575
 
                                             % (cmd, argname.upper()))
 
395
                raise BzrCommandError("command %r needs one or more %s"
 
396
                        % (cmd, argname.upper()))
576
397
            argdict[argname + '_list'] = args[:-1]
577
 
            args[:-1] = []
 
398
            args[:-1] = []                
578
399
        else:
579
400
            # just a plain arg
580
401
            argname = ap
581
402
            if not args:
582
 
                raise errors.BzrCommandError("command %r requires argument %s"
583
 
                               % (cmd, argname.upper()))
 
403
                raise BzrCommandError("command %r requires argument %s"
 
404
                        % (cmd, argname.upper()))
584
405
            else:
585
406
                argdict[argname] = args.pop(0)
586
407
            
587
408
    if args:
588
 
        raise errors.BzrCommandError("extra argument to command %s: %s"
589
 
                                     % (cmd, args[0]))
 
409
        raise BzrCommandError("extra argument to command %s: %s"
 
410
                              % (cmd, args[0]))
590
411
 
591
412
    return argdict
592
413
 
593
 
def apply_coveraged(dirname, the_callable, *args, **kwargs):
594
 
    # Cannot use "import trace", as that would import bzrlib.trace instead of
595
 
    # the standard library's trace.
596
 
    trace = __import__('trace')
597
 
 
598
 
    tracer = trace.Trace(count=1, trace=0)
599
 
    sys.settrace(tracer.globaltrace)
600
 
 
601
 
    ret = the_callable(*args, **kwargs)
602
 
 
603
 
    sys.settrace(None)
604
 
    results = tracer.results()
605
 
    results.write_results(show_missing=1, summary=False,
606
 
                          coverdir=dirname)
607
414
 
608
415
 
609
416
def apply_profiled(the_callable, *args, **kwargs):
629
436
        os.remove(pfname)
630
437
 
631
438
 
632
 
def apply_lsprofiled(filename, the_callable, *args, **kwargs):
633
 
    from bzrlib.lsprof import profile
634
 
    ret, stats = profile(the_callable, *args, **kwargs)
635
 
    stats.sort()
636
 
    if filename is None:
637
 
        stats.pprint()
638
 
    else:
639
 
        stats.save(filename)
640
 
        trace.note('Profile data written to "%s".', filename)
641
 
    return ret
642
 
 
643
 
 
644
 
def shlex_split_unicode(unsplit):
645
 
    import shlex
646
 
    return [u.decode('utf-8') for u in shlex.split(unsplit.encode('utf-8'))]
647
 
 
648
 
 
649
 
def get_alias(cmd, config=None):
650
 
    """Return an expanded alias, or None if no alias exists.
651
 
 
652
 
    cmd
653
 
        Command to be checked for an alias.
654
 
    config
655
 
        Used to specify an alternative config to use,
656
 
        which is especially useful for testing.
657
 
        If it is unspecified, the global config will be used.
658
 
    """
659
 
    if config is None:
660
 
        import bzrlib.config
661
 
        config = bzrlib.config.GlobalConfig()
662
 
    alias = config.get_alias(cmd)
663
 
    if (alias):
664
 
        return shlex_split_unicode(alias)
665
 
    return None
666
 
 
667
 
 
668
439
def run_bzr(argv):
669
440
    """Execute a command.
670
441
 
673
444
    
674
445
    argv
675
446
       The command-line arguments, without the program name from argv[0]
676
 
       These should already be decoded. All library/test code calling
677
 
       run_bzr should be passing valid strings (don't need decoding).
678
447
    
679
448
    Returns a command status or raises an exception.
680
449
 
684
453
    --no-plugins
685
454
        Do not load plugin modules at all
686
455
 
687
 
    --no-aliases
688
 
        Do not allow aliases
689
 
 
690
456
    --builtin
691
457
        Only use builtin commands.  (Plugins are still allowed to change
692
458
        other behaviour.)
693
459
 
694
460
    --profile
695
 
        Run under the Python hotshot profiler.
696
 
 
697
 
    --lsprof
698
 
        Run under the Python lsprof profiler.
699
 
 
700
 
    --coverage
701
 
        Generate line coverage report in the specified directory.
 
461
        Run under the Python profiler.
702
462
    """
703
 
    argv = list(argv)
704
 
    trace.mutter("bzr arguments: %r", argv)
 
463
    argv = [a.decode(bzrlib.user_encoding) for a in argv]
705
464
 
706
 
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
707
 
                opt_no_aliases = False
708
 
    opt_lsprof_file = opt_coverage_dir = None
 
465
    opt_profile = opt_no_plugins = opt_builtin = False
709
466
 
710
467
    # --no-plugins is handled specially at a very early stage. We need
711
468
    # to load plugins before doing other command parsing so that they
712
469
    # can override commands, but this needs to happen first.
713
470
 
714
 
    argv_copy = []
715
 
    i = 0
716
 
    while i < len(argv):
717
 
        a = argv[i]
 
471
    for a in argv:
718
472
        if a == '--profile':
719
473
            opt_profile = True
720
 
        elif a == '--lsprof':
721
 
            opt_lsprof = True
722
 
        elif a == '--lsprof-file':
723
 
            opt_lsprof = True
724
 
            opt_lsprof_file = argv[i + 1]
725
 
            i += 1
726
474
        elif a == '--no-plugins':
727
475
            opt_no_plugins = True
728
 
        elif a == '--no-aliases':
729
 
            opt_no_aliases = True
730
476
        elif a == '--builtin':
731
477
            opt_builtin = True
732
 
        elif a == '--coverage':
733
 
            opt_coverage_dir = argv[i + 1]
734
 
            i += 1
735
 
        elif a.startswith('-D'):
736
 
            debug.debug_flags.add(a[2:])
737
478
        else:
738
 
            argv_copy.append(a)
739
 
        i += 1
 
479
            break
 
480
        argv.remove(a)
740
481
 
741
 
    argv = argv_copy
742
 
    if (not argv):
743
 
        from bzrlib.builtins import cmd_help
744
 
        cmd_help().run_argv_aliases([])
 
482
    if (not argv) or (argv[0] == '--help'):
 
483
        from bzrlib.help import help
 
484
        if len(argv) > 1:
 
485
            help(argv[1])
 
486
        else:
 
487
            help()
745
488
        return 0
746
489
 
747
490
    if argv[0] == '--version':
748
 
        from bzrlib.builtins import cmd_version
749
 
        cmd_version().run_argv_aliases([])
 
491
        from bzrlib.builtins import show_version
 
492
        show_version()
750
493
        return 0
751
494
        
752
495
    if not opt_no_plugins:
753
496
        from bzrlib.plugin import load_plugins
754
497
        load_plugins()
755
 
    else:
756
 
        from bzrlib.plugin import disable_plugins
757
 
        disable_plugins()
758
 
 
759
 
    alias_argv = None
760
 
 
761
 
    if not opt_no_aliases:
762
 
        alias_argv = get_alias(argv[0])
763
 
        if alias_argv:
764
 
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
765
 
            argv[0] = alias_argv.pop(0)
766
 
 
767
 
    cmd = argv.pop(0)
768
 
    # We want only 'ascii' command names, but the user may have typed
769
 
    # in a Unicode name. In that case, they should just get a
770
 
    # 'command not found' error later.
 
498
 
 
499
    cmd = str(argv.pop(0))
771
500
 
772
501
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
773
 
    run = cmd_obj.run_argv_aliases
774
 
    run_argv = [argv, alias_argv]
775
502
 
776
 
    try:
777
 
        if opt_lsprof:
778
 
            if opt_coverage_dir:
779
 
                trace.warning(
780
 
                    '--coverage ignored, because --lsprof is in use.')
781
 
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
782
 
        elif opt_profile:
783
 
            if opt_coverage_dir:
784
 
                trace.warning(
785
 
                    '--coverage ignored, because --profile is in use.')
786
 
            ret = apply_profiled(run, *run_argv)
787
 
        elif opt_coverage_dir:
788
 
            ret = apply_coveraged(opt_coverage_dir, run, *run_argv)
789
 
        else:
790
 
            ret = run(*run_argv)
791
 
        return ret or 0
792
 
    finally:
793
 
        # reset, in case we may do other commands later within the same process
794
 
        option._verbosity_level = 0
 
503
    if opt_profile:
 
504
        ret = apply_profiled(cmd_obj.run_argv, argv)
 
505
    else:
 
506
        ret = cmd_obj.run_argv(argv)
 
507
    return ret or 0
795
508
 
796
509
def display_command(func):
797
 
    """Decorator that suppresses pipe/interrupt errors."""
798
510
    def ignore_pipe(*args, **kwargs):
799
511
        try:
800
 
            result = func(*args, **kwargs)
801
 
            sys.stdout.flush()
802
 
            return result
 
512
            return func(*args, **kwargs)
803
513
        except IOError, e:
804
 
            if getattr(e, 'errno', None) is None:
 
514
            if e.errno != errno.EPIPE:
805
515
                raise
806
 
            if e.errno != errno.EPIPE:
807
 
                # Win32 raises IOError with errno=0 on a broken pipe
808
 
                if sys.platform != 'win32' or (e.errno not in (0, errno.EINVAL)):
809
 
                    raise
810
 
            pass
811
516
        except KeyboardInterrupt:
812
517
            pass
813
518
    return ignore_pipe
814
519
 
815
 
 
816
520
def main(argv):
817
521
    import bzrlib.ui
818
 
    from bzrlib.ui.text import TextUIFactory
819
 
    bzrlib.ui.ui_factory = TextUIFactory()
820
 
    try:
821
 
        argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
822
 
    except UnicodeDecodeError:
823
 
        raise errors.BzrError(("Parameter '%r' is unsupported by the current "
824
 
                                                            "encoding." % a))
825
 
    ret = run_bzr_catch_errors(argv)
826
 
    trace.mutter("return code %d", ret)
827
 
    return ret
 
522
    bzrlib.trace.log_startup(argv)
 
523
    bzrlib.ui.ui_factory = bzrlib.ui.TextUIFactory()
 
524
 
 
525
    return run_bzr_catch_errors(argv[1:])
828
526
 
829
527
 
830
528
def run_bzr_catch_errors(argv):
831
 
    # Note: The except clause logic below should be kept in sync with the
832
 
    # profile() routine in lsprof.py.
833
 
    try:
834
 
        return run_bzr(argv)
835
 
    except (KeyboardInterrupt, Exception), e:
836
 
        # used to handle AssertionError and KeyboardInterrupt
837
 
        # specially here, but hopefully they're handled ok by the logger now
838
 
        exitcode = trace.report_exception(sys.exc_info(), sys.stderr)
839
 
        if os.environ.get('BZR_PDB'):
840
 
            print '**** entering debugger'
841
 
            import pdb
842
 
            pdb.post_mortem(sys.exc_traceback)
843
 
        return exitcode
844
 
 
845
 
 
846
 
def run_bzr_catch_user_errors(argv):
847
 
    """Run bzr and report user errors, but let internal errors propagate.
848
 
 
849
 
    This is used for the test suite, and might be useful for other programs
850
 
    that want to wrap the commandline interface.
851
 
    """
852
 
    try:
853
 
        return run_bzr(argv)
 
529
    try:
 
530
        try:
 
531
            return run_bzr(argv)
 
532
        finally:
 
533
            # do this here inside the exception wrappers to catch EPIPE
 
534
            sys.stdout.flush()
 
535
    except BzrCommandError, e:
 
536
        # command line syntax error, etc
 
537
        log_error(str(e))
 
538
        return 1
 
539
    except BzrError, e:
 
540
        bzrlib.trace.log_exception()
 
541
        return 1
 
542
    except AssertionError, e:
 
543
        bzrlib.trace.log_exception('assertion failed: ' + str(e))
 
544
        return 3
 
545
    except KeyboardInterrupt, e:
 
546
        bzrlib.trace.log_exception('interrupted')
 
547
        return 2
854
548
    except Exception, e:
855
 
        if (isinstance(e, (OSError, IOError))
856
 
            or not getattr(e, 'internal_error', True)):
857
 
            trace.report_exception(sys.exc_info(), sys.stderr)
858
 
            return 3
859
 
        else:
860
 
            raise
861
 
 
862
 
 
863
 
class HelpCommandIndex(object):
864
 
    """A index for bzr help that returns commands."""
865
 
 
866
 
    def __init__(self):
867
 
        self.prefix = 'commands/'
868
 
 
869
 
    def get_topics(self, topic):
870
 
        """Search for topic amongst commands.
871
 
 
872
 
        :param topic: A topic to search for.
873
 
        :return: A list which is either empty or contains a single
874
 
            Command entry.
875
 
        """
876
 
        if topic and topic.startswith(self.prefix):
877
 
            topic = topic[len(self.prefix):]
878
 
        try:
879
 
            cmd = _get_cmd_object(topic)
880
 
        except KeyError:
881
 
            return []
882
 
        else:
883
 
            return [cmd]
884
 
 
 
549
        import errno
 
550
        if (isinstance(e, IOError) 
 
551
            and hasattr(e, 'errno')
 
552
            and e.errno == errno.EPIPE):
 
553
            bzrlib.trace.note('broken pipe')
 
554
            return 2
 
555
        else:
 
556
            ## import pdb
 
557
            ## pdb.pm()
 
558
            bzrlib.trace.log_exception()
 
559
            return 2
885
560
 
886
561
if __name__ == '__main__':
887
562
    sys.exit(main(sys.argv))