/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: Robert Collins
  • Date: 2009-05-23 20:57:12 UTC
  • mfrom: (4371 +trunk)
  • mto: This revision was merged to the branch mainline in revision 4441.
  • Revision ID: robertc@robertcollins.net-20090523205712-lcwbfqk6vwavinuv
MergeĀ .dev.

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
1
# Copyright (C) 2006, 2008 Canonical Ltd
 
2
#
 
3
# This program is free software; you can redistribute it and/or modify
 
4
# it under the terms of the GNU General Public License as published by
 
5
# the Free Software Foundation; either version 2 of the License, or
 
6
# (at your option) any later version.
 
7
#
 
8
# This program is distributed in the hope that it will be useful,
 
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
 
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
11
# GNU General Public License for more details.
 
12
#
 
13
# You should have received a copy of the GNU General Public License
 
14
# along with this program; if not, write to the Free Software
 
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 
16
 
 
17
 
 
18
# TODO: probably should say which arguments are candidates for glob
 
19
# expansion on windows and do that at the command level.
 
20
 
 
21
# TODO: Define arguments by objects, rather than just using names.
 
22
# Those objects can specify the expected type of the argument, which
 
23
# would help with validation and shell completion.  They could also provide
 
24
# help/explanation for that argument in a structured way.
 
25
 
 
26
# TODO: Specific "examples" property on commands for consistent formatting.
 
27
 
 
28
# TODO: "--profile=cum", to change sort order.  Is there any value in leaving
 
29
# the profile output behind so it can be interactively examined?
 
30
 
 
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
import threading
 
39
from warnings import warn
 
40
 
 
41
import bzrlib
 
42
from bzrlib import (
 
43
    debug,
 
44
    errors,
 
45
    option,
 
46
    osutils,
 
47
    trace,
 
48
    win32utils,
 
49
    )
 
50
""")
 
51
 
 
52
from bzrlib import registry
 
53
# Compatibility
 
54
from bzrlib.hooks import HookPoint, Hooks
 
55
from bzrlib.option import Option
 
56
 
 
57
 
 
58
class CommandInfo(object):
 
59
    """Information about a command."""
 
60
 
 
61
    def __init__(self, aliases):
 
62
        """The list of aliases for the command."""
 
63
        self.aliases = aliases
 
64
 
 
65
    @classmethod
 
66
    def from_command(klass, command):
 
67
        """Factory to construct a CommandInfo from a command."""
 
68
        return klass(command.aliases)
 
69
 
 
70
 
 
71
class CommandRegistry(registry.Registry):
 
72
 
 
73
    @staticmethod
 
74
    def _get_name(command_name):
 
75
        if command_name.startswith("cmd_"):
 
76
            return _unsquish_command_name(command_name)
 
77
        else:
 
78
            return command_name
 
79
 
 
80
    def register(self, cmd, decorate=False):
 
81
        """Utility function to help register a command
 
82
 
 
83
        :param cmd: Command subclass to register
 
84
        :param decorate: If true, allow overriding an existing command
 
85
            of the same name; the old command is returned by this function.
 
86
            Otherwise it is an error to try to override an existing command.
 
87
        """
 
88
        k = cmd.__name__
 
89
        k_unsquished = self._get_name(k)
 
90
        try:
 
91
            previous = self.get(k_unsquished)
 
92
        except KeyError:
 
93
            previous = _builtin_commands().get(k_unsquished)
 
94
        info = CommandInfo.from_command(cmd)
 
95
        try:
 
96
            registry.Registry.register(self, k_unsquished, cmd,
 
97
                                       override_existing=decorate, info=info)
 
98
        except KeyError:
 
99
            trace.log_error('Two plugins defined the same command: %r' % k)
 
100
            trace.log_error('Not loading the one in %r' %
 
101
                            sys.modules[cmd.__module__])
 
102
            trace.log_error('Previously this command was registered from %r' %
 
103
                            sys.modules[previous.__module__])
 
104
        return previous
 
105
 
 
106
    def register_lazy(self, command_name, aliases, module_name):
 
107
        """Register a command without loading its module.
 
108
 
 
109
        :param command_name: The primary name of the command.
 
110
        :param aliases: A list of aliases for the command.
 
111
        :module_name: The module that the command lives in.
 
112
        """
 
113
        key = self._get_name(command_name)
 
114
        registry.Registry.register_lazy(self, key, module_name, command_name,
 
115
                                        info=CommandInfo(aliases))
 
116
 
 
117
 
 
118
plugin_cmds = CommandRegistry()
 
119
 
 
120
 
 
121
def register_command(cmd, decorate=False):
 
122
    global plugin_cmds
 
123
    return plugin_cmds.register(cmd, decorate)
 
124
 
 
125
 
 
126
def _squish_command_name(cmd):
 
127
    return 'cmd_' + cmd.replace('-', '_')
 
128
 
 
129
 
 
130
def _unsquish_command_name(cmd):
 
131
    return cmd[4:].replace('_','-')
 
132
 
 
133
 
 
134
def _builtin_commands():
 
135
    import bzrlib.builtins
 
136
    return _scan_module_for_commands(bzrlib.builtins)
 
137
 
 
138
 
 
139
def _scan_module_for_commands(module):
 
140
    r = {}
 
141
    for name, obj in module.__dict__.iteritems():
 
142
        if name.startswith("cmd_"):
 
143
            real_name = _unsquish_command_name(name)
 
144
            r[real_name] = obj
 
145
    return r
 
146
 
 
147
 
 
148
def _list_bzr_commands(names):
 
149
    """Return a list of all the registered commands.
 
150
 
 
151
    This searches plugins and the core.
 
152
    """
 
153
    # to eliminate duplicates
 
154
    names.update(builtin_command_names())
 
155
    names.update(plugin_command_names())
 
156
    return names
 
157
 
 
158
 
 
159
def all_command_names():
 
160
    """Return a list of all command names."""
 
161
    names = set()
 
162
    for hook in Command.hooks['list_commands']:
 
163
        new_names = hook(names)
 
164
        if new_names is None:
 
165
            raise AssertionError(
 
166
                'hook %s returned None' % Command.hooks.get_hook_name(hook))
 
167
        names = new_names
 
168
    return names
 
169
 
 
170
 
 
171
def builtin_command_names():
 
172
    """Return list of builtin command names.
 
173
    
 
174
    Use of all_command_names() is encouraged rather than builtin_command_names
 
175
    and/or plugin_command_names.
 
176
    """
 
177
    return _builtin_commands().keys()
 
178
 
 
179
 
 
180
def plugin_command_names():
 
181
    """Returns command names from commands registered by plugins."""
 
182
    return plugin_cmds.keys()
 
183
 
 
184
 
 
185
def _get_cmd_dict(plugins_override=True):
 
186
    """Return name->class mapping for all commands."""
 
187
    d = _builtin_commands()
 
188
    if plugins_override:
 
189
        d.update(plugin_cmds.iteritems())
 
190
    return d
 
191
 
 
192
 
 
193
def get_all_cmds(plugins_override=True):
 
194
    """Return canonical name and class for all registered commands."""
 
195
    for k, v in _get_cmd_dict(plugins_override=plugins_override).iteritems():
 
196
        yield k,v
 
197
 
 
198
 
 
199
def get_cmd_object(cmd_name, plugins_override=True):
 
200
    """Return the command object for a command.
 
201
 
 
202
    plugins_override
 
203
        If true, plugin commands can override builtins.
 
204
    """
 
205
    try:
 
206
        return _get_cmd_object(cmd_name, plugins_override)
 
207
    except KeyError:
 
208
        raise errors.BzrCommandError('unknown command "%s"' % cmd_name)
 
209
 
 
210
 
 
211
def _get_cmd_object(cmd_name, plugins_override=True):
 
212
    """Get a command object.
 
213
 
 
214
    :param cmd_name: The name of the command.
 
215
    :param plugins_override: Allow plugins to override builtins.
 
216
    :return: A Command object instance
 
217
    :raises: KeyError if no command is found.
 
218
    """
 
219
    # We want only 'ascii' command names, but the user may have typed
 
220
    # in a Unicode name. In that case, they should just get a
 
221
    # 'command not found' error later.
 
222
    # In the future, we may actually support Unicode command names.
 
223
 
 
224
    cmd = None
 
225
    # Get a command
 
226
    for hook in Command.hooks['get_command']:
 
227
        cmd = hook(cmd, cmd_name)
 
228
        if cmd is not None and not plugins_override:
 
229
            # We've found a non-plugin command, don't permit it to be
 
230
            # overridden.
 
231
            if not cmd.plugin_name():
 
232
                break
 
233
    if cmd is None:
 
234
        try:
 
235
            plugin_metadata, provider = probe_for_provider(cmd_name)
 
236
            raise errors.CommandAvailableInPlugin(cmd_name,
 
237
                plugin_metadata, provider)
 
238
        except errors.NoPluginAvailable:
 
239
            pass
 
240
        # No command found.
 
241
        raise KeyError
 
242
    # Allow plugins to extend commands
 
243
    for hook in Command.hooks['extend_command']:
 
244
        hook(cmd)
 
245
    return cmd
 
246
 
 
247
 
 
248
def probe_for_provider(cmd_name):
 
249
    """Look for a provider for cmd_name.
 
250
 
 
251
    :param cmd_name: The command name.
 
252
    :return: plugin_metadata, provider for getting cmd_name.
 
253
    :raises NoPluginAvailable: When no provider can supply the plugin.
 
254
    """
 
255
    # look for providers that provide this command but aren't installed
 
256
    for provider in command_providers_registry:
 
257
        try:
 
258
            return provider.plugin_for_command(cmd_name), provider
 
259
        except errors.NoPluginAvailable:
 
260
            pass
 
261
    raise errors.NoPluginAvailable(cmd_name)
 
262
 
 
263
 
 
264
def _get_bzr_command(cmd_or_None, cmd_name):
 
265
    """Get a command from bzr's core."""
 
266
    cmds = _get_cmd_dict(plugins_override=False)
 
267
    try:
 
268
        return cmds[cmd_name]()
 
269
    except KeyError:
 
270
        pass
 
271
    # look for any command which claims this as an alias
 
272
    for real_cmd_name, cmd_class in cmds.iteritems():
 
273
        if cmd_name in cmd_class.aliases:
 
274
            return cmd_class()
 
275
    return cmd_or_None
 
276
 
 
277
 
 
278
def _get_external_command(cmd_or_None, cmd_name):
 
279
    """Lookup a command that is a shell script."""
 
280
    # Only do external command lookups when no command is found so far.
 
281
    if cmd_or_None is not None:
 
282
        return cmd_or_None
 
283
    from bzrlib.externalcommand import ExternalCommand
 
284
    cmd_obj = ExternalCommand.find_command(cmd_name)
 
285
    if cmd_obj:
 
286
        return cmd_obj
 
287
 
 
288
 
 
289
def _get_plugin_command(cmd_or_None, cmd_name):
 
290
    """Get a command from bzr's plugins."""
 
291
    try:
 
292
        return plugin_cmds.get(cmd_name)()
 
293
    except KeyError:
 
294
        pass
 
295
    for key in plugin_cmds.keys():
 
296
        info = plugin_cmds.get_info(key)
 
297
        if cmd_name in info.aliases:
 
298
            return plugin_cmds.get(key)()
 
299
    return cmd_or_None
 
300
 
 
301
 
 
302
class Command(object):
 
303
    """Base class for commands.
 
304
 
 
305
    Commands are the heart of the command-line bzr interface.
 
306
 
 
307
    The command object mostly handles the mapping of command-line
 
308
    parameters into one or more bzrlib operations, and of the results
 
309
    into textual output.
 
310
 
 
311
    Commands normally don't have any state.  All their arguments are
 
312
    passed in to the run method.  (Subclasses may take a different
 
313
    policy if the behaviour of the instance needs to depend on e.g. a
 
314
    shell plugin and not just its Python class.)
 
315
 
 
316
    The docstring for an actual command should give a single-line
 
317
    summary, then a complete description of the command.  A grammar
 
318
    description will be inserted.
 
319
 
 
320
    aliases
 
321
        Other accepted names for this command.
 
322
 
 
323
    takes_args
 
324
        List of argument forms, marked with whether they are optional,
 
325
        repeated, etc.
 
326
 
 
327
                Examples:
 
328
 
 
329
                ['to_location', 'from_branch?', 'file*']
 
330
 
 
331
                'to_location' is required
 
332
                'from_branch' is optional
 
333
                'file' can be specified 0 or more times
 
334
 
 
335
    takes_options
 
336
        List of options that may be given for this command.  These can
 
337
        be either strings, referring to globally-defined options,
 
338
        or option objects.  Retrieve through options().
 
339
 
 
340
    hidden
 
341
        If true, this command isn't advertised.  This is typically
 
342
        for commands intended for expert users.
 
343
 
 
344
    encoding_type
 
345
        Command objects will get a 'outf' attribute, which has been
 
346
        setup to properly handle encoding of unicode strings.
 
347
        encoding_type determines what will happen when characters cannot
 
348
        be encoded
 
349
            strict - abort if we cannot decode
 
350
            replace - put in a bogus character (typically '?')
 
351
            exact - do not encode sys.stdout
 
352
 
 
353
            NOTE: by default on Windows, sys.stdout is opened as a text
 
354
            stream, therefore LF line-endings are converted to CRLF.
 
355
            When a command uses encoding_type = 'exact', then
 
356
            sys.stdout is forced to be a binary stream, and line-endings
 
357
            will not mangled.
 
358
 
 
359
    :cvar hooks: An instance of CommandHooks.
 
360
    """
 
361
    aliases = []
 
362
    takes_args = []
 
363
    takes_options = []
 
364
    encoding_type = 'strict'
 
365
 
 
366
    hidden = False
 
367
 
 
368
    def __init__(self):
 
369
        """Construct an instance of this command."""
 
370
        if self.__doc__ == Command.__doc__:
 
371
            warn("No help message set for %r" % self)
 
372
        # List of standard options directly supported
 
373
        self.supported_std_options = []
 
374
 
 
375
    def _maybe_expand_globs(self, file_list):
 
376
        """Glob expand file_list if the platform does not do that itself.
 
377
 
 
378
        :return: A possibly empty list of unicode paths.
 
379
 
 
380
        Introduced in bzrlib 0.18.
 
381
        """
 
382
        if not file_list:
 
383
            file_list = []
 
384
        if sys.platform == 'win32':
 
385
            file_list = win32utils.glob_expand(file_list)
 
386
        return list(file_list)
 
387
 
 
388
    def _usage(self):
 
389
        """Return single-line grammar for this command.
 
390
 
 
391
        Only describes arguments, not options.
 
392
        """
 
393
        s = 'bzr ' + self.name() + ' '
 
394
        for aname in self.takes_args:
 
395
            aname = aname.upper()
 
396
            if aname[-1] in ['$', '+']:
 
397
                aname = aname[:-1] + '...'
 
398
            elif aname[-1] == '?':
 
399
                aname = '[' + aname[:-1] + ']'
 
400
            elif aname[-1] == '*':
 
401
                aname = '[' + aname[:-1] + '...]'
 
402
            s += aname + ' '
 
403
        s = s[:-1]      # remove last space
 
404
        return s
 
405
 
 
406
    def get_help_text(self, additional_see_also=None, plain=True,
 
407
                      see_also_as_links=False, verbose=True):
 
408
        """Return a text string with help for this command.
 
409
 
 
410
        :param additional_see_also: Additional help topics to be
 
411
            cross-referenced.
 
412
        :param plain: if False, raw help (reStructuredText) is
 
413
            returned instead of plain text.
 
414
        :param see_also_as_links: if True, convert items in 'See also'
 
415
            list to internal links (used by bzr_man rstx generator)
 
416
        :param verbose: if True, display the full help, otherwise
 
417
            leave out the descriptive sections and just display
 
418
            usage help (e.g. Purpose, Usage, Options) with a
 
419
            message explaining how to obtain full help.
 
420
        """
 
421
        doc = self.help()
 
422
        if doc is None:
 
423
            raise NotImplementedError("sorry, no detailed help yet for %r" % self.name())
 
424
 
 
425
        # Extract the summary (purpose) and sections out from the text
 
426
        purpose,sections,order = self._get_help_parts(doc)
 
427
 
 
428
        # If a custom usage section was provided, use it
 
429
        if sections.has_key('Usage'):
 
430
            usage = sections.pop('Usage')
 
431
        else:
 
432
            usage = self._usage()
 
433
 
 
434
        # The header is the purpose and usage
 
435
        result = ""
 
436
        result += ':Purpose: %s\n' % purpose
 
437
        if usage.find('\n') >= 0:
 
438
            result += ':Usage:\n%s\n' % usage
 
439
        else:
 
440
            result += ':Usage:   %s\n' % usage
 
441
        result += '\n'
 
442
 
 
443
        # Add the options
 
444
        options = option.get_optparser(self.options()).format_option_help()
 
445
        if options.startswith('Options:'):
 
446
            result += ':' + options
 
447
        elif options.startswith('options:'):
 
448
            # Python 2.4 version of optparse
 
449
            result += ':Options:' + options[len('options:'):]
 
450
        else:
 
451
            result += options
 
452
        result += '\n'
 
453
 
 
454
        if verbose:
 
455
            # Add the description, indenting it 2 spaces
 
456
            # to match the indentation of the options
 
457
            if sections.has_key(None):
 
458
                text = sections.pop(None)
 
459
                text = '\n  '.join(text.splitlines())
 
460
                result += ':%s:\n  %s\n\n' % ('Description',text)
 
461
 
 
462
            # Add the custom sections (e.g. Examples). Note that there's no need
 
463
            # to indent these as they must be indented already in the source.
 
464
            if sections:
 
465
                for label in order:
 
466
                    if sections.has_key(label):
 
467
                        result += ':%s:\n%s\n' % (label,sections[label])
 
468
                result += '\n'
 
469
        else:
 
470
            result += ("See bzr help %s for more details and examples.\n\n"
 
471
                % self.name())
 
472
 
 
473
        # Add the aliases, source (plug-in) and see also links, if any
 
474
        if self.aliases:
 
475
            result += ':Aliases:  '
 
476
            result += ', '.join(self.aliases) + '\n'
 
477
        plugin_name = self.plugin_name()
 
478
        if plugin_name is not None:
 
479
            result += ':From:     plugin "%s"\n' % plugin_name
 
480
        see_also = self.get_see_also(additional_see_also)
 
481
        if see_also:
 
482
            if not plain and see_also_as_links:
 
483
                see_also_links = []
 
484
                for item in see_also:
 
485
                    if item == 'topics':
 
486
                        # topics doesn't have an independent section
 
487
                        # so don't create a real link
 
488
                        see_also_links.append(item)
 
489
                    else:
 
490
                        # Use a reST link for this entry
 
491
                        see_also_links.append("`%s`_" % (item,))
 
492
                see_also = see_also_links
 
493
            result += ':See also: '
 
494
            result += ', '.join(see_also) + '\n'
 
495
 
 
496
        # If this will be rendered as plain text, convert it
 
497
        if plain:
 
498
            import bzrlib.help_topics
 
499
            result = bzrlib.help_topics.help_as_plain_text(result)
 
500
        return result
 
501
 
 
502
    @staticmethod
 
503
    def _get_help_parts(text):
 
504
        """Split help text into a summary and named sections.
 
505
 
 
506
        :return: (summary,sections,order) where summary is the top line and
 
507
            sections is a dictionary of the rest indexed by section name.
 
508
            order is the order the section appear in the text.
 
509
            A section starts with a heading line of the form ":xxx:".
 
510
            Indented text on following lines is the section value.
 
511
            All text found outside a named section is assigned to the
 
512
            default section which is given the key of None.
 
513
        """
 
514
        def save_section(sections, order, label, section):
 
515
            if len(section) > 0:
 
516
                if sections.has_key(label):
 
517
                    sections[label] += '\n' + section
 
518
                else:
 
519
                    order.append(label)
 
520
                    sections[label] = section
 
521
 
 
522
        lines = text.rstrip().splitlines()
 
523
        summary = lines.pop(0)
 
524
        sections = {}
 
525
        order = []
 
526
        label,section = None,''
 
527
        for line in lines:
 
528
            if line.startswith(':') and line.endswith(':') and len(line) > 2:
 
529
                save_section(sections, order, label, section)
 
530
                label,section = line[1:-1],''
 
531
            elif (label is not None) and len(line) > 1 and not line[0].isspace():
 
532
                save_section(sections, order, label, section)
 
533
                label,section = None,line
 
534
            else:
 
535
                if len(section) > 0:
 
536
                    section += '\n' + line
 
537
                else:
 
538
                    section = line
 
539
        save_section(sections, order, label, section)
 
540
        return summary, sections, order
 
541
 
 
542
    def get_help_topic(self):
 
543
        """Return the commands help topic - its name."""
 
544
        return self.name()
 
545
 
 
546
    def get_see_also(self, additional_terms=None):
 
547
        """Return a list of help topics that are related to this command.
 
548
 
 
549
        The list is derived from the content of the _see_also attribute. Any
 
550
        duplicates are removed and the result is in lexical order.
 
551
        :param additional_terms: Additional help topics to cross-reference.
 
552
        :return: A list of help topics.
 
553
        """
 
554
        see_also = set(getattr(self, '_see_also', []))
 
555
        if additional_terms:
 
556
            see_also.update(additional_terms)
 
557
        return sorted(see_also)
 
558
 
 
559
    def options(self):
 
560
        """Return dict of valid options for this command.
 
561
 
 
562
        Maps from long option name to option object."""
 
563
        r = Option.STD_OPTIONS.copy()
 
564
        std_names = r.keys()
 
565
        for o in self.takes_options:
 
566
            if isinstance(o, basestring):
 
567
                o = option.Option.OPTIONS[o]
 
568
            r[o.name] = o
 
569
            if o.name in std_names:
 
570
                self.supported_std_options.append(o.name)
 
571
        return r
 
572
 
 
573
    def _setup_outf(self):
 
574
        """Return a file linked to stdout, which has proper encoding."""
 
575
        # Originally I was using self.stdout, but that looks
 
576
        # *way* too much like sys.stdout
 
577
        if self.encoding_type == 'exact':
 
578
            # force sys.stdout to be binary stream on win32
 
579
            if sys.platform == 'win32':
 
580
                fileno = getattr(sys.stdout, 'fileno', None)
 
581
                if fileno:
 
582
                    import msvcrt
 
583
                    msvcrt.setmode(fileno(), os.O_BINARY)
 
584
            self.outf = sys.stdout
 
585
            return
 
586
 
 
587
        output_encoding = osutils.get_terminal_encoding()
 
588
 
 
589
        self.outf = codecs.getwriter(output_encoding)(sys.stdout,
 
590
                        errors=self.encoding_type)
 
591
        # For whatever reason codecs.getwriter() does not advertise its encoding
 
592
        # it just returns the encoding of the wrapped file, which is completely
 
593
        # bogus. So set the attribute, so we can find the correct encoding later.
 
594
        self.outf.encoding = output_encoding
 
595
 
 
596
    def run_argv_aliases(self, argv, alias_argv=None):
 
597
        """Parse the command line and run with extra aliases in alias_argv."""
 
598
        if argv is None:
 
599
            warn("Passing None for [] is deprecated from bzrlib 0.10",
 
600
                 DeprecationWarning, stacklevel=2)
 
601
            argv = []
 
602
        args, opts = parse_args(self, argv, alias_argv)
 
603
 
 
604
        # Process the standard options
 
605
        if 'help' in opts:  # e.g. bzr add --help
 
606
            sys.stdout.write(self.get_help_text())
 
607
            return 0
 
608
        if 'usage' in opts:  # e.g. bzr add --usage
 
609
            sys.stdout.write(self.get_help_text(verbose=False))
 
610
            return 0
 
611
        trace.set_verbosity_level(option._verbosity_level)
 
612
        if 'verbose' in self.supported_std_options:
 
613
            opts['verbose'] = trace.is_verbose()
 
614
        elif opts.has_key('verbose'):
 
615
            del opts['verbose']
 
616
        if 'quiet' in self.supported_std_options:
 
617
            opts['quiet'] = trace.is_quiet()
 
618
        elif opts.has_key('quiet'):
 
619
            del opts['quiet']
 
620
 
 
621
        # mix arguments and options into one dictionary
 
622
        cmdargs = _match_argform(self.name(), self.takes_args, args)
 
623
        cmdopts = {}
 
624
        for k, v in opts.items():
 
625
            cmdopts[k.replace('-', '_')] = v
 
626
 
 
627
        all_cmd_args = cmdargs.copy()
 
628
        all_cmd_args.update(cmdopts)
 
629
 
 
630
        self._setup_outf()
 
631
 
 
632
        return self.run(**all_cmd_args)
 
633
 
 
634
    def run(self):
 
635
        """Actually run the command.
 
636
 
 
637
        This is invoked with the options and arguments bound to
 
638
        keyword parameters.
 
639
 
 
640
        Return 0 or None if the command was successful, or a non-zero
 
641
        shell error code if not.  It's OK for this method to allow
 
642
        an exception to raise up.
 
643
        """
 
644
        raise NotImplementedError('no implementation of command %r'
 
645
                                  % self.name())
 
646
 
 
647
    def help(self):
 
648
        """Return help message for this class."""
 
649
        from inspect import getdoc
 
650
        if self.__doc__ is Command.__doc__:
 
651
            return None
 
652
        return getdoc(self)
 
653
 
 
654
    def name(self):
 
655
        return _unsquish_command_name(self.__class__.__name__)
 
656
 
 
657
    def plugin_name(self):
 
658
        """Get the name of the plugin that provides this command.
 
659
 
 
660
        :return: The name of the plugin or None if the command is builtin.
 
661
        """
 
662
        mod_parts = self.__module__.split('.')
 
663
        if len(mod_parts) >= 3 and mod_parts[1] == 'plugins':
 
664
            return mod_parts[2]
 
665
        else:
 
666
            return None
 
667
 
 
668
 
 
669
class CommandHooks(Hooks):
 
670
    """Hooks related to Command object creation/enumeration."""
 
671
 
 
672
    def __init__(self):
 
673
        """Create the default hooks.
 
674
 
 
675
        These are all empty initially, because by default nothing should get
 
676
        notified.
 
677
        """
 
678
        Hooks.__init__(self)
 
679
        self.create_hook(HookPoint('extend_command',
 
680
            "Called after creating a command object to allow modifications "
 
681
            "such as adding or removing options, docs etc. Called with the "
 
682
            "new bzrlib.commands.Command object.", (1, 13), None))
 
683
        self.create_hook(HookPoint('get_command',
 
684
            "Called when creating a single command. Called with "
 
685
            "(cmd_or_None, command_name). get_command should either return "
 
686
            "the cmd_or_None parameter, or a replacement Command object that "
 
687
            "should be used for the command.", (1, 14), None))
 
688
        self.create_hook(HookPoint('list_commands',
 
689
            "Called when enumerating commands. Called with a dict of "
 
690
            "cmd_name: cmd_class tuples for all the commands found "
 
691
            "so far. This dict is safe to mutate - to remove a command or "
 
692
            "to replace it with another (eg plugin supplied) version. "
 
693
            "list_commands should return the updated dict of commands.",
 
694
            (1, 14), None))
 
695
        # We currently ship default hooks to get builtin and plugin supplied
 
696
        # command names.
 
697
        self.install_named_hook("list_commands", _list_bzr_commands,
 
698
            "bzr commands")
 
699
        self.install_named_hook("get_command", _get_bzr_command,
 
700
            "bzr commands")
 
701
        self.install_named_hook("get_command", _get_plugin_command,
 
702
            "bzr plugin commands")
 
703
        self.install_named_hook("get_command", _get_external_command,
 
704
            "bzr external command lookup")
 
705
 
 
706
Command.hooks = CommandHooks()
 
707
 
 
708
 
 
709
def parse_args(command, argv, alias_argv=None):
 
710
    """Parse command line.
 
711
 
 
712
    Arguments and options are parsed at this level before being passed
 
713
    down to specific command handlers.  This routine knows, from a
 
714
    lookup table, something about the available options, what optargs
 
715
    they take, and which commands will accept them.
 
716
    """
 
717
    # TODO: make it a method of the Command?
 
718
    parser = option.get_optparser(command.options())
 
719
    if alias_argv is not None:
 
720
        args = alias_argv + argv
 
721
    else:
 
722
        args = argv
 
723
 
 
724
    options, args = parser.parse_args(args)
 
725
    opts = dict([(k, v) for k, v in options.__dict__.iteritems() if
 
726
                 v is not option.OptionParser.DEFAULT_VALUE])
 
727
    return args, opts
 
728
 
 
729
 
 
730
def _match_argform(cmd, takes_args, args):
 
731
    argdict = {}
 
732
 
 
733
    # step through args and takes_args, allowing appropriate 0-many matches
 
734
    for ap in takes_args:
 
735
        argname = ap[:-1]
 
736
        if ap[-1] == '?':
 
737
            if args:
 
738
                argdict[argname] = args.pop(0)
 
739
        elif ap[-1] == '*': # all remaining arguments
 
740
            if args:
 
741
                argdict[argname + '_list'] = args[:]
 
742
                args = []
 
743
            else:
 
744
                argdict[argname + '_list'] = None
 
745
        elif ap[-1] == '+':
 
746
            if not args:
 
747
                raise errors.BzrCommandError("command %r needs one or more %s"
 
748
                                             % (cmd, argname.upper()))
 
749
            else:
 
750
                argdict[argname + '_list'] = args[:]
 
751
                args = []
 
752
        elif ap[-1] == '$': # all but one
 
753
            if len(args) < 2:
 
754
                raise errors.BzrCommandError("command %r needs one or more %s"
 
755
                                             % (cmd, argname.upper()))
 
756
            argdict[argname + '_list'] = args[:-1]
 
757
            args[:-1] = []
 
758
        else:
 
759
            # just a plain arg
 
760
            argname = ap
 
761
            if not args:
 
762
                raise errors.BzrCommandError("command %r requires argument %s"
 
763
                               % (cmd, argname.upper()))
 
764
            else:
 
765
                argdict[argname] = args.pop(0)
 
766
 
 
767
    if args:
 
768
        raise errors.BzrCommandError("extra argument to command %s: %s"
 
769
                                     % (cmd, args[0]))
 
770
 
 
771
    return argdict
 
772
 
 
773
def apply_coveraged(dirname, the_callable, *args, **kwargs):
 
774
    # Cannot use "import trace", as that would import bzrlib.trace instead of
 
775
    # the standard library's trace.
 
776
    trace = __import__('trace')
 
777
 
 
778
    tracer = trace.Trace(count=1, trace=0)
 
779
    sys.settrace(tracer.globaltrace)
 
780
    threading.settrace(tracer.globaltrace)
 
781
 
 
782
    try:
 
783
        return exception_to_return_code(the_callable, *args, **kwargs)
 
784
    finally:
 
785
        sys.settrace(None)
 
786
        results = tracer.results()
 
787
        results.write_results(show_missing=1, summary=False,
 
788
                              coverdir=dirname)
 
789
 
 
790
 
 
791
def apply_profiled(the_callable, *args, **kwargs):
 
792
    import hotshot
 
793
    import tempfile
 
794
    import hotshot.stats
 
795
    pffileno, pfname = tempfile.mkstemp()
 
796
    try:
 
797
        prof = hotshot.Profile(pfname)
 
798
        try:
 
799
            ret = prof.runcall(exception_to_return_code, the_callable, *args,
 
800
                **kwargs) or 0
 
801
        finally:
 
802
            prof.close()
 
803
        stats = hotshot.stats.load(pfname)
 
804
        stats.strip_dirs()
 
805
        stats.sort_stats('cum')   # 'time'
 
806
        ## XXX: Might like to write to stderr or the trace file instead but
 
807
        ## print_stats seems hardcoded to stdout
 
808
        stats.print_stats(20)
 
809
        return ret
 
810
    finally:
 
811
        os.close(pffileno)
 
812
        os.remove(pfname)
 
813
 
 
814
 
 
815
def exception_to_return_code(the_callable, *args, **kwargs):
 
816
    """UI level helper for profiling and coverage.
 
817
 
 
818
    This transforms exceptions into a return value of 3. As such its only
 
819
    relevant to the UI layer, and should never be called where catching
 
820
    exceptions may be desirable.
 
821
    """
 
822
    try:
 
823
        return the_callable(*args, **kwargs)
 
824
    except (KeyboardInterrupt, Exception), e:
 
825
        # used to handle AssertionError and KeyboardInterrupt
 
826
        # specially here, but hopefully they're handled ok by the logger now
 
827
        exc_info = sys.exc_info()
 
828
        exitcode = trace.report_exception(exc_info, sys.stderr)
 
829
        if os.environ.get('BZR_PDB'):
 
830
            print '**** entering debugger'
 
831
            tb = exc_info[2]
 
832
            import pdb
 
833
            if sys.version_info[:2] < (2, 6):
 
834
                # XXX: we want to do
 
835
                #    pdb.post_mortem(tb)
 
836
                # but because pdb.post_mortem gives bad results for tracebacks
 
837
                # from inside generators, we do it manually.
 
838
                # (http://bugs.python.org/issue4150, fixed in Python 2.6)
 
839
 
 
840
                # Setup pdb on the traceback
 
841
                p = pdb.Pdb()
 
842
                p.reset()
 
843
                p.setup(tb.tb_frame, tb)
 
844
                # Point the debugger at the deepest frame of the stack
 
845
                p.curindex = len(p.stack) - 1
 
846
                p.curframe = p.stack[p.curindex][0]
 
847
                # Start the pdb prompt.
 
848
                p.print_stack_entry(p.stack[p.curindex])
 
849
                p.execRcLines()
 
850
                p.cmdloop()
 
851
            else:
 
852
                pdb.post_mortem(tb)
 
853
        return exitcode
 
854
 
 
855
 
 
856
def apply_lsprofiled(filename, the_callable, *args, **kwargs):
 
857
    from bzrlib.lsprof import profile
 
858
    ret, stats = profile(exception_to_return_code, the_callable, *args, **kwargs)
 
859
    stats.sort()
 
860
    if filename is None:
 
861
        stats.pprint()
 
862
    else:
 
863
        stats.save(filename)
 
864
        trace.note('Profile data written to "%s".', filename)
 
865
    return ret
 
866
 
 
867
 
 
868
def shlex_split_unicode(unsplit):
 
869
    import shlex
 
870
    return [u.decode('utf-8') for u in shlex.split(unsplit.encode('utf-8'))]
 
871
 
 
872
 
 
873
def get_alias(cmd, config=None):
 
874
    """Return an expanded alias, or None if no alias exists.
 
875
 
 
876
    cmd
 
877
        Command to be checked for an alias.
 
878
    config
 
879
        Used to specify an alternative config to use,
 
880
        which is especially useful for testing.
 
881
        If it is unspecified, the global config will be used.
 
882
    """
 
883
    if config is None:
 
884
        import bzrlib.config
 
885
        config = bzrlib.config.GlobalConfig()
 
886
    alias = config.get_alias(cmd)
 
887
    if (alias):
 
888
        return shlex_split_unicode(alias)
 
889
    return None
 
890
 
 
891
 
 
892
def run_bzr(argv):
 
893
    """Execute a command.
 
894
 
 
895
    argv
 
896
       The command-line arguments, without the program name from argv[0]
 
897
       These should already be decoded. All library/test code calling
 
898
       run_bzr should be passing valid strings (don't need decoding).
 
899
 
 
900
    Returns a command status or raises an exception.
 
901
 
 
902
    Special master options: these must come before the command because
 
903
    they control how the command is interpreted.
 
904
 
 
905
    --no-plugins
 
906
        Do not load plugin modules at all
 
907
 
 
908
    --no-aliases
 
909
        Do not allow aliases
 
910
 
 
911
    --builtin
 
912
        Only use builtin commands.  (Plugins are still allowed to change
 
913
        other behaviour.)
 
914
 
 
915
    --profile
 
916
        Run under the Python hotshot profiler.
 
917
 
 
918
    --lsprof
 
919
        Run under the Python lsprof profiler.
 
920
 
 
921
    --coverage
 
922
        Generate line coverage report in the specified directory.
 
923
    """
 
924
    argv = list(argv)
 
925
    trace.mutter("bzr arguments: %r", argv)
 
926
 
 
927
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
 
928
                opt_no_aliases = False
 
929
    opt_lsprof_file = opt_coverage_dir = None
 
930
 
 
931
    # --no-plugins is handled specially at a very early stage. We need
 
932
    # to load plugins before doing other command parsing so that they
 
933
    # can override commands, but this needs to happen first.
 
934
 
 
935
    argv_copy = []
 
936
    i = 0
 
937
    while i < len(argv):
 
938
        a = argv[i]
 
939
        if a == '--profile':
 
940
            opt_profile = True
 
941
        elif a == '--lsprof':
 
942
            opt_lsprof = True
 
943
        elif a == '--lsprof-file':
 
944
            opt_lsprof = True
 
945
            opt_lsprof_file = argv[i + 1]
 
946
            i += 1
 
947
        elif a == '--no-plugins':
 
948
            opt_no_plugins = True
 
949
        elif a == '--no-aliases':
 
950
            opt_no_aliases = True
 
951
        elif a == '--builtin':
 
952
            opt_builtin = True
 
953
        elif a == '--coverage':
 
954
            opt_coverage_dir = argv[i + 1]
 
955
            i += 1
 
956
        elif a.startswith('-D'):
 
957
            debug.debug_flags.add(a[2:])
 
958
        else:
 
959
            argv_copy.append(a)
 
960
        i += 1
 
961
 
 
962
    debug.set_debug_flags_from_config()
 
963
 
 
964
    argv = argv_copy
 
965
    if (not argv):
 
966
        from bzrlib.builtins import cmd_help
 
967
        cmd_help().run_argv_aliases([])
 
968
        return 0
 
969
 
 
970
    if argv[0] == '--version':
 
971
        from bzrlib.builtins import cmd_version
 
972
        cmd_version().run_argv_aliases([])
 
973
        return 0
 
974
 
 
975
    if not opt_no_plugins:
 
976
        from bzrlib.plugin import load_plugins
 
977
        load_plugins()
 
978
    else:
 
979
        from bzrlib.plugin import disable_plugins
 
980
        disable_plugins()
 
981
 
 
982
    alias_argv = None
 
983
 
 
984
    if not opt_no_aliases:
 
985
        alias_argv = get_alias(argv[0])
 
986
        if alias_argv:
 
987
            user_encoding = osutils.get_user_encoding()
 
988
            alias_argv = [a.decode(user_encoding) for a in alias_argv]
 
989
            argv[0] = alias_argv.pop(0)
 
990
 
 
991
    cmd = argv.pop(0)
 
992
    # We want only 'ascii' command names, but the user may have typed
 
993
    # in a Unicode name. In that case, they should just get a
 
994
    # 'command not found' error later.
 
995
 
 
996
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
 
997
    run = cmd_obj.run_argv_aliases
 
998
    run_argv = [argv, alias_argv]
 
999
 
 
1000
    try:
 
1001
        # We can be called recursively (tests for example), but we don't want
 
1002
        # the verbosity level to propagate.
 
1003
        saved_verbosity_level = option._verbosity_level
 
1004
        option._verbosity_level = 0
 
1005
        if opt_lsprof:
 
1006
            if opt_coverage_dir:
 
1007
                trace.warning(
 
1008
                    '--coverage ignored, because --lsprof is in use.')
 
1009
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
 
1010
        elif opt_profile:
 
1011
            if opt_coverage_dir:
 
1012
                trace.warning(
 
1013
                    '--coverage ignored, because --profile is in use.')
 
1014
            ret = apply_profiled(run, *run_argv)
 
1015
        elif opt_coverage_dir:
 
1016
            ret = apply_coveraged(opt_coverage_dir, run, *run_argv)
 
1017
        else:
 
1018
            ret = run(*run_argv)
 
1019
        if 'memory' in debug.debug_flags:
 
1020
            trace.debug_memory('Process status after command:', short=False)
 
1021
        return ret or 0
 
1022
    finally:
 
1023
        # reset, in case we may do other commands later within the same
 
1024
        # process. Commands that want to execute sub-commands must propagate
 
1025
        # --verbose in their own way.
 
1026
        option._verbosity_level = saved_verbosity_level
 
1027
 
 
1028
 
 
1029
def display_command(func):
 
1030
    """Decorator that suppresses pipe/interrupt errors."""
 
1031
    def ignore_pipe(*args, **kwargs):
 
1032
        try:
 
1033
            result = func(*args, **kwargs)
 
1034
            sys.stdout.flush()
 
1035
            return result
 
1036
        except IOError, e:
 
1037
            if getattr(e, 'errno', None) is None:
 
1038
                raise
 
1039
            if e.errno != errno.EPIPE:
 
1040
                # Win32 raises IOError with errno=0 on a broken pipe
 
1041
                if sys.platform != 'win32' or (e.errno not in (0, errno.EINVAL)):
 
1042
                    raise
 
1043
            pass
 
1044
        except KeyboardInterrupt:
 
1045
            pass
 
1046
    return ignore_pipe
 
1047
 
 
1048
 
 
1049
def main(argv=None):
 
1050
    """Main entry point of command-line interface.
 
1051
 
 
1052
    :param argv: list of unicode command-line arguments similar to sys.argv.
 
1053
        argv[0] is script name usually, it will be ignored.
 
1054
        Don't pass here sys.argv because this list contains plain strings
 
1055
        and not unicode; pass None instead.
 
1056
 
 
1057
    :return: exit code of bzr command.
 
1058
    """
 
1059
    import bzrlib.ui
 
1060
    bzrlib.ui.ui_factory = bzrlib.ui.make_ui_for_terminal(
 
1061
        sys.stdin, sys.stdout, sys.stderr)
 
1062
 
 
1063
    # Is this a final release version? If so, we should suppress warnings
 
1064
    if bzrlib.version_info[3] == 'final':
 
1065
        from bzrlib import symbol_versioning
 
1066
        symbol_versioning.suppress_deprecation_warnings(override=False)
 
1067
    if argv is None:
 
1068
        argv = osutils.get_unicode_argv()
 
1069
    else:
 
1070
        new_argv = []
 
1071
        try:
 
1072
            # ensure all arguments are unicode strings
 
1073
            for a in argv[1:]:
 
1074
                if isinstance(a, unicode):
 
1075
                    new_argv.append(a)
 
1076
                else:
 
1077
                    new_argv.append(a.decode('ascii'))
 
1078
        except UnicodeDecodeError:
 
1079
            raise errors.BzrError("argv should be list of unicode strings.")
 
1080
        argv = new_argv
 
1081
    ret = run_bzr_catch_errors(argv)
 
1082
    trace.mutter("return code %d", ret)
 
1083
    return ret
 
1084
 
 
1085
 
 
1086
def run_bzr_catch_errors(argv):
 
1087
    """Run a bzr command with parameters as described by argv.
 
1088
 
 
1089
    This function assumed that that UI layer is setup, that symbol deprecations
 
1090
    are already applied, and that unicode decoding has already been performed on argv.
 
1091
    """
 
1092
    return exception_to_return_code(run_bzr, argv)
 
1093
 
 
1094
 
 
1095
def run_bzr_catch_user_errors(argv):
 
1096
    """Run bzr and report user errors, but let internal errors propagate.
 
1097
 
 
1098
    This is used for the test suite, and might be useful for other programs
 
1099
    that want to wrap the commandline interface.
 
1100
    """
 
1101
    try:
 
1102
        return run_bzr(argv)
 
1103
    except Exception, e:
 
1104
        if (isinstance(e, (OSError, IOError))
 
1105
            or not getattr(e, 'internal_error', True)):
 
1106
            trace.report_exception(sys.exc_info(), sys.stderr)
 
1107
            return 3
 
1108
        else:
 
1109
            raise
 
1110
 
 
1111
 
 
1112
class HelpCommandIndex(object):
 
1113
    """A index for bzr help that returns commands."""
 
1114
 
 
1115
    def __init__(self):
 
1116
        self.prefix = 'commands/'
 
1117
 
 
1118
    def get_topics(self, topic):
 
1119
        """Search for topic amongst commands.
 
1120
 
 
1121
        :param topic: A topic to search for.
 
1122
        :return: A list which is either empty or contains a single
 
1123
            Command entry.
 
1124
        """
 
1125
        if topic and topic.startswith(self.prefix):
 
1126
            topic = topic[len(self.prefix):]
 
1127
        try:
 
1128
            cmd = _get_cmd_object(topic)
 
1129
        except KeyError:
 
1130
            return []
 
1131
        else:
 
1132
            return [cmd]
 
1133
 
 
1134
 
 
1135
class Provider(object):
 
1136
    '''Generic class to be overriden by plugins'''
 
1137
 
 
1138
    def plugin_for_command(self, cmd_name):
 
1139
        '''Takes a command and returns the information for that plugin
 
1140
 
 
1141
        :return: A dictionary with all the available information
 
1142
        for the requested plugin
 
1143
        '''
 
1144
        raise NotImplementedError
 
1145
 
 
1146
 
 
1147
class ProvidersRegistry(registry.Registry):
 
1148
    '''This registry exists to allow other providers to exist'''
 
1149
 
 
1150
    def __iter__(self):
 
1151
        for key, provider in self.iteritems():
 
1152
            yield provider
 
1153
 
 
1154
command_providers_registry = ProvidersRegistry()
 
1155
 
 
1156
 
 
1157
if __name__ == '__main__':
 
1158
    sys.exit(main(sys.argv))