/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: Ian Clatworthy
  • Date: 2010-03-30 20:13:52 UTC
  • mto: This revision was merged to the branch mainline in revision 5125.
  • Revision ID: ian.clatworthy@canonical.com-20100330201352-vw2gtujybyg3rvwc
whitespace fix in win32 installer

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2006 by Canonical Ltd
 
1
# Copyright (C) 2005-2010 Canonical Ltd
2
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
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
 
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  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.
 
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 
16
 
20
17
 
21
18
# TODO: Define arguments by objects, rather than just using names.
22
19
# Those objects can specify the expected type of the argument, which
25
22
 
26
23
# TODO: Specific "examples" property on commands for consistent formatting.
27
24
 
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?
 
25
import os
 
26
import sys
30
27
 
 
28
from bzrlib.lazy_import import lazy_import
 
29
lazy_import(globals(), """
31
30
import codecs
32
31
import errno
33
 
import os
 
32
import threading
34
33
from warnings import warn
35
 
import sys
36
34
 
37
35
import bzrlib
38
 
import bzrlib.errors as errors
39
 
from bzrlib.errors import (BzrError,
40
 
                           BzrCommandError,
41
 
                           BzrCheckError,
42
 
                           NotBranchError)
43
 
from bzrlib import option
 
36
from bzrlib import (
 
37
    cleanup,
 
38
    cmdline,
 
39
    debug,
 
40
    errors,
 
41
    option,
 
42
    osutils,
 
43
    trace,
 
44
    ui,
 
45
    win32utils,
 
46
    )
 
47
""")
 
48
 
 
49
from bzrlib.hooks import HookPoint, Hooks
 
50
# Compatibility - Option used to be in commands.
44
51
from bzrlib.option import Option
45
 
import bzrlib.osutils
46
 
from bzrlib.symbol_versioning import (deprecated_method, zero_eight)
47
 
import bzrlib.trace
48
 
from bzrlib.trace import mutter, note, log_error, warning, be_quiet
49
 
 
50
 
plugin_cmds = {}
 
52
from bzrlib.plugin import disable_plugins, load_plugins
 
53
from bzrlib import registry
 
54
from bzrlib.symbol_versioning import (
 
55
    deprecated_function,
 
56
    deprecated_in,
 
57
    deprecated_method,
 
58
    )
 
59
 
 
60
 
 
61
class CommandInfo(object):
 
62
    """Information about a command."""
 
63
 
 
64
    def __init__(self, aliases):
 
65
        """The list of aliases for the command."""
 
66
        self.aliases = aliases
 
67
 
 
68
    @classmethod
 
69
    def from_command(klass, command):
 
70
        """Factory to construct a CommandInfo from a command."""
 
71
        return klass(command.aliases)
 
72
 
 
73
 
 
74
class CommandRegistry(registry.Registry):
 
75
    """Special registry mapping command names to command classes.
 
76
    
 
77
    :ivar overridden_registry: Look in this registry for commands being
 
78
        overridden by this registry.  This can be used to tell plugin commands
 
79
        about the builtin they're decorating.
 
80
    """
 
81
 
 
82
    def __init__(self):
 
83
        registry.Registry.__init__(self)
 
84
        self.overridden_registry = None
 
85
        # map from aliases to the real command that implements the name
 
86
        self._alias_dict = {}
 
87
 
 
88
    def get(self, command_name):
 
89
        real_name = self._alias_dict.get(command_name, command_name)
 
90
        return registry.Registry.get(self, real_name)
 
91
 
 
92
    @staticmethod
 
93
    def _get_name(command_name):
 
94
        if command_name.startswith("cmd_"):
 
95
            return _unsquish_command_name(command_name)
 
96
        else:
 
97
            return command_name
 
98
 
 
99
    def register(self, cmd, decorate=False):
 
100
        """Utility function to help register a command
 
101
 
 
102
        :param cmd: Command subclass to register
 
103
        :param decorate: If true, allow overriding an existing command
 
104
            of the same name; the old command is returned by this function.
 
105
            Otherwise it is an error to try to override an existing command.
 
106
        """
 
107
        k = cmd.__name__
 
108
        k_unsquished = self._get_name(k)
 
109
        try:
 
110
            previous = self.get(k_unsquished)
 
111
        except KeyError:
 
112
            previous = None
 
113
            if self.overridden_registry:
 
114
                try:
 
115
                    previous = self.overridden_registry.get(k_unsquished)
 
116
                except KeyError:
 
117
                    pass
 
118
        info = CommandInfo.from_command(cmd)
 
119
        try:
 
120
            registry.Registry.register(self, k_unsquished, cmd,
 
121
                                       override_existing=decorate, info=info)
 
122
        except KeyError:
 
123
            trace.warning('Two plugins defined the same command: %r' % k)
 
124
            trace.warning('Not loading the one in %r' %
 
125
                sys.modules[cmd.__module__])
 
126
            trace.warning('Previously this command was registered from %r' %
 
127
                sys.modules[previous.__module__])
 
128
        for a in cmd.aliases:
 
129
            self._alias_dict[a] = k_unsquished
 
130
        return previous
 
131
 
 
132
    def register_lazy(self, command_name, aliases, module_name):
 
133
        """Register a command without loading its module.
 
134
 
 
135
        :param command_name: The primary name of the command.
 
136
        :param aliases: A list of aliases for the command.
 
137
        :module_name: The module that the command lives in.
 
138
        """
 
139
        key = self._get_name(command_name)
 
140
        registry.Registry.register_lazy(self, key, module_name, command_name,
 
141
                                        info=CommandInfo(aliases))
 
142
        for a in aliases:
 
143
            self._alias_dict[a] = key
 
144
 
 
145
 
 
146
plugin_cmds = CommandRegistry()
 
147
builtin_command_registry = CommandRegistry()
 
148
plugin_cmds.overridden_registry = builtin_command_registry
51
149
 
52
150
 
53
151
def register_command(cmd, decorate=False):
54
 
    """Utility function to help register a command
 
152
    """Register a plugin command.
55
153
 
56
 
    :param cmd: Command subclass to register
57
 
    :param decorate: If true, allow overriding an existing command
58
 
        of the same name; the old command is returned by this function.
59
 
        Otherwise it is an error to try to override an existing command.
 
154
    Should generally be avoided in favor of lazy registration. 
60
155
    """
61
156
    global plugin_cmds
62
 
    k = cmd.__name__
63
 
    if k.startswith("cmd_"):
64
 
        k_unsquished = _unsquish_command_name(k)
65
 
    else:
66
 
        k_unsquished = k
67
 
    if k_unsquished not in plugin_cmds:
68
 
        plugin_cmds[k_unsquished] = cmd
69
 
        mutter('registered plugin command %s', k_unsquished)
70
 
        if decorate and k_unsquished in builtin_command_names():
71
 
            return _builtin_commands()[k_unsquished]
72
 
    elif decorate:
73
 
        result = plugin_cmds[k_unsquished]
74
 
        plugin_cmds[k_unsquished] = cmd
75
 
        return result
76
 
    else:
77
 
        log_error('Two plugins defined the same command: %r' % k)
78
 
        log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
 
157
    return plugin_cmds.register(cmd, decorate)
79
158
 
80
159
 
81
160
def _squish_command_name(cmd):
83
162
 
84
163
 
85
164
def _unsquish_command_name(cmd):
86
 
    assert cmd.startswith("cmd_")
87
165
    return cmd[4:].replace('_','-')
88
166
 
89
167
 
 
168
@deprecated_function(deprecated_in((2, 2, 0)))
90
169
def _builtin_commands():
 
170
    """Return a dict of {name: cmd_class} for builtin commands.
 
171
 
 
172
    :deprecated: Use the builtin_command_registry registry instead
 
173
    """
 
174
    # return dict(name: cmd_class)
 
175
    return dict(builtin_command_registry.items())
 
176
 
 
177
 
 
178
def _register_builtin_commands():
 
179
    if builtin_command_registry.keys():
 
180
        # only load once
 
181
        return
91
182
    import bzrlib.builtins
 
183
    for cmd_class in _scan_module_for_commands(bzrlib.builtins).values():
 
184
        builtin_command_registry.register(cmd_class)
 
185
    # lazy builtins
 
186
    builtin_command_registry.register_lazy('cmd_bundle_info',
 
187
        [],
 
188
        'bzrlib.bundle.commands')
 
189
 
 
190
 
 
191
def _scan_module_for_commands(module):
92
192
    r = {}
93
 
    builtins = bzrlib.builtins.__dict__
94
 
    for name in builtins:
 
193
    for name, obj in module.__dict__.iteritems():
95
194
        if name.startswith("cmd_"):
96
195
            real_name = _unsquish_command_name(name)
97
 
            r[real_name] = builtins[name]
 
196
            r[real_name] = obj
98
197
    return r
99
 
            
 
198
 
 
199
 
 
200
def _list_bzr_commands(names):
 
201
    """Find commands from bzr's core and plugins.
 
202
    
 
203
    This is not the public interface, just the default hook called by all_command_names.
 
204
    """
 
205
    # to eliminate duplicates
 
206
    names.update(builtin_command_names())
 
207
    names.update(plugin_command_names())
 
208
    return names
 
209
 
 
210
 
 
211
def all_command_names():
 
212
    """Return a set of all command names."""
 
213
    names = set()
 
214
    for hook in Command.hooks['list_commands']:
 
215
        names = hook(names)
 
216
        if names is None:
 
217
            raise AssertionError(
 
218
                'hook %s returned None' % Command.hooks.get_hook_name(hook))
 
219
    return names
 
220
 
100
221
 
101
222
def builtin_command_names():
102
 
    """Return list of builtin command names."""
103
 
    return _builtin_commands().keys()
 
223
    """Return list of builtin command names.
104
224
    
 
225
    Use of all_command_names() is encouraged rather than builtin_command_names
 
226
    and/or plugin_command_names.
 
227
    """
 
228
    return builtin_command_registry.keys()
 
229
 
105
230
 
106
231
def plugin_command_names():
 
232
    """Returns command names from commands registered by plugins."""
107
233
    return plugin_cmds.keys()
108
234
 
109
235
 
110
 
def _get_cmd_dict(plugins_override=True):
111
 
    """Return name->class mapping for all commands."""
112
 
    d = _builtin_commands()
113
 
    if plugins_override:
114
 
        d.update(plugin_cmds)
115
 
    return d
116
 
 
117
 
    
118
 
def get_all_cmds(plugins_override=True):
119
 
    """Return canonical name and class for all registered commands."""
120
 
    for k, v in _get_cmd_dict(plugins_override=plugins_override).iteritems():
121
 
        yield k,v
122
 
 
123
 
 
124
236
def get_cmd_object(cmd_name, plugins_override=True):
125
 
    """Return the canonical name and command class for a command.
 
237
    """Return the command object for a command.
126
238
 
127
239
    plugins_override
128
240
        If true, plugin commands can override builtins.
129
241
    """
 
242
    try:
 
243
        return _get_cmd_object(cmd_name, plugins_override)
 
244
    except KeyError:
 
245
        raise errors.BzrCommandError('unknown command "%s"' % cmd_name)
 
246
 
 
247
 
 
248
def _get_cmd_object(cmd_name, plugins_override=True, check_missing=True):
 
249
    """Get a command object.
 
250
 
 
251
    :param cmd_name: The name of the command.
 
252
    :param plugins_override: Allow plugins to override builtins.
 
253
    :param check_missing: Look up commands not found in the regular index via
 
254
        the get_missing_command hook.
 
255
    :return: A Command object instance
 
256
    :raises KeyError: If no command is found.
 
257
    """
 
258
    # We want only 'ascii' command names, but the user may have typed
 
259
    # in a Unicode name. In that case, they should just get a
 
260
    # 'command not found' error later.
 
261
    # In the future, we may actually support Unicode command names.
 
262
    cmd = None
 
263
    # Get a command
 
264
    for hook in Command.hooks['get_command']:
 
265
        cmd = hook(cmd, cmd_name)
 
266
        if cmd is not None and not plugins_override and not cmd.plugin_name():
 
267
            # We've found a non-plugin command, don't permit it to be
 
268
            # overridden.
 
269
            break
 
270
    if cmd is None and check_missing:
 
271
        for hook in Command.hooks['get_missing_command']:
 
272
            cmd = hook(cmd_name)
 
273
            if cmd is not None:
 
274
                break
 
275
    if cmd is None:
 
276
        # No command found.
 
277
        raise KeyError
 
278
    # Allow plugins to extend commands
 
279
    for hook in Command.hooks['extend_command']:
 
280
        hook(cmd)
 
281
    return cmd
 
282
 
 
283
 
 
284
def _try_plugin_provider(cmd_name):
 
285
    """Probe for a plugin provider having cmd_name."""
 
286
    try:
 
287
        plugin_metadata, provider = probe_for_provider(cmd_name)
 
288
        raise errors.CommandAvailableInPlugin(cmd_name,
 
289
            plugin_metadata, provider)
 
290
    except errors.NoPluginAvailable:
 
291
        pass
 
292
 
 
293
 
 
294
def probe_for_provider(cmd_name):
 
295
    """Look for a provider for cmd_name.
 
296
 
 
297
    :param cmd_name: The command name.
 
298
    :return: plugin_metadata, provider for getting cmd_name.
 
299
    :raises NoPluginAvailable: When no provider can supply the plugin.
 
300
    """
 
301
    # look for providers that provide this command but aren't installed
 
302
    for provider in command_providers_registry:
 
303
        try:
 
304
            return provider.plugin_for_command(cmd_name), provider
 
305
        except errors.NoPluginAvailable:
 
306
            pass
 
307
    raise errors.NoPluginAvailable(cmd_name)
 
308
 
 
309
 
 
310
def _get_bzr_command(cmd_or_None, cmd_name):
 
311
    """Get a command from bzr's core."""
 
312
    try:
 
313
        cmd_class = builtin_command_registry.get(cmd_name)
 
314
    except KeyError:
 
315
        pass
 
316
    else:
 
317
        return cmd_class()
 
318
    return cmd_or_None
 
319
 
 
320
 
 
321
def _get_external_command(cmd_or_None, cmd_name):
 
322
    """Lookup a command that is a shell script."""
 
323
    # Only do external command lookups when no command is found so far.
 
324
    if cmd_or_None is not None:
 
325
        return cmd_or_None
130
326
    from bzrlib.externalcommand import ExternalCommand
131
 
 
132
 
    # We want only 'ascii' command names, but the user may have typed
133
 
    # in a Unicode name. In that case, they should just get a
134
 
    # 'command not found' error later.
135
 
    # In the future, we may actually support Unicode command names.
136
 
 
137
 
    # first look up this command under the specified name
138
 
    cmds = _get_cmd_dict(plugins_override=plugins_override)
139
 
    try:
140
 
        return cmds[cmd_name]()
141
 
    except KeyError:
142
 
        pass
143
 
 
144
 
    # look for any command which claims this as an alias
145
 
    for real_cmd_name, cmd_class in cmds.iteritems():
146
 
        if cmd_name in cmd_class.aliases:
147
 
            return cmd_class()
148
 
 
149
327
    cmd_obj = ExternalCommand.find_command(cmd_name)
150
328
    if cmd_obj:
151
329
        return cmd_obj
152
330
 
153
 
    raise BzrCommandError('unknown command "%s"' % cmd_name)
 
331
 
 
332
def _get_plugin_command(cmd_or_None, cmd_name):
 
333
    """Get a command from bzr's plugins."""
 
334
    try:
 
335
        return plugin_cmds.get(cmd_name)()
 
336
    except KeyError:
 
337
        pass
 
338
    for key in plugin_cmds.keys():
 
339
        info = plugin_cmds.get_info(key)
 
340
        if cmd_name in info.aliases:
 
341
            return plugin_cmds.get(key)()
 
342
    return cmd_or_None
154
343
 
155
344
 
156
345
class Command(object):
204
393
            replace - put in a bogus character (typically '?')
205
394
            exact - do not encode sys.stdout
206
395
 
 
396
            NOTE: by default on Windows, sys.stdout is opened as a text
 
397
            stream, therefore LF line-endings are converted to CRLF.
 
398
            When a command uses encoding_type = 'exact', then
 
399
            sys.stdout is forced to be a binary stream, and line-endings
 
400
            will not mangled.
 
401
 
 
402
    :cvar hooks: An instance of CommandHooks.
207
403
    """
208
404
    aliases = []
209
405
    takes_args = []
211
407
    encoding_type = 'strict'
212
408
 
213
409
    hidden = False
214
 
    
 
410
 
215
411
    def __init__(self):
216
412
        """Construct an instance of this command."""
217
413
        if self.__doc__ == Command.__doc__:
218
414
            warn("No help message set for %r" % self)
 
415
        # List of standard options directly supported
 
416
        self.supported_std_options = []
 
417
        self._operation = cleanup.OperationWithCleanups(self.run)
 
418
 
 
419
    def add_cleanup(self, cleanup_func, *args, **kwargs):
 
420
        """Register a function to call after self.run returns or raises.
 
421
 
 
422
        Functions will be called in LIFO order.
 
423
        """
 
424
        self._operation.add_cleanup(cleanup_func, *args, **kwargs)
 
425
 
 
426
    def cleanup_now(self):
 
427
        """Execute and empty pending cleanup functions immediately.
 
428
 
 
429
        After cleanup_now all registered cleanups are forgotten.  add_cleanup
 
430
        may be called again after cleanup_now; these cleanups will be called
 
431
        after self.run returns or raises (or when cleanup_now is next called).
 
432
 
 
433
        This is useful for releasing expensive or contentious resources (such
 
434
        as write locks) before doing further work that does not require those
 
435
        resources (such as writing results to self.outf).
 
436
        """
 
437
        self._operation.cleanup_now()
 
438
 
 
439
    @deprecated_method(deprecated_in((2, 1, 0)))
 
440
    def _maybe_expand_globs(self, file_list):
 
441
        """Glob expand file_list if the platform does not do that itself.
 
442
 
 
443
        Not used anymore, now that the bzr command-line parser globs on
 
444
        Windows.
 
445
 
 
446
        :return: A possibly empty list of unicode paths.
 
447
 
 
448
        Introduced in bzrlib 0.18.
 
449
        """
 
450
        return file_list
 
451
 
 
452
    def _usage(self):
 
453
        """Return single-line grammar for this command.
 
454
 
 
455
        Only describes arguments, not options.
 
456
        """
 
457
        s = 'bzr ' + self.name() + ' '
 
458
        for aname in self.takes_args:
 
459
            aname = aname.upper()
 
460
            if aname[-1] in ['$', '+']:
 
461
                aname = aname[:-1] + '...'
 
462
            elif aname[-1] == '?':
 
463
                aname = '[' + aname[:-1] + ']'
 
464
            elif aname[-1] == '*':
 
465
                aname = '[' + aname[:-1] + '...]'
 
466
            s += aname + ' '
 
467
        s = s[:-1]      # remove last space
 
468
        return s
 
469
 
 
470
    def get_help_text(self, additional_see_also=None, plain=True,
 
471
                      see_also_as_links=False, verbose=True):
 
472
        """Return a text string with help for this command.
 
473
 
 
474
        :param additional_see_also: Additional help topics to be
 
475
            cross-referenced.
 
476
        :param plain: if False, raw help (reStructuredText) is
 
477
            returned instead of plain text.
 
478
        :param see_also_as_links: if True, convert items in 'See also'
 
479
            list to internal links (used by bzr_man rstx generator)
 
480
        :param verbose: if True, display the full help, otherwise
 
481
            leave out the descriptive sections and just display
 
482
            usage help (e.g. Purpose, Usage, Options) with a
 
483
            message explaining how to obtain full help.
 
484
        """
 
485
        doc = self.help()
 
486
        if doc is None:
 
487
            raise NotImplementedError("sorry, no detailed help yet for %r" % self.name())
 
488
 
 
489
        # Extract the summary (purpose) and sections out from the text
 
490
        purpose,sections,order = self._get_help_parts(doc)
 
491
 
 
492
        # If a custom usage section was provided, use it
 
493
        if sections.has_key('Usage'):
 
494
            usage = sections.pop('Usage')
 
495
        else:
 
496
            usage = self._usage()
 
497
 
 
498
        # The header is the purpose and usage
 
499
        result = ""
 
500
        result += ':Purpose: %s\n' % purpose
 
501
        if usage.find('\n') >= 0:
 
502
            result += ':Usage:\n%s\n' % usage
 
503
        else:
 
504
            result += ':Usage:   %s\n' % usage
 
505
        result += '\n'
 
506
 
 
507
        # Add the options
 
508
        #
 
509
        # XXX: optparse implicitly rewraps the help, and not always perfectly,
 
510
        # so we get <https://bugs.launchpad.net/bzr/+bug/249908>.  -- mbp
 
511
        # 20090319
 
512
        options = option.get_optparser(self.options()).format_option_help()
 
513
        # XXX: According to the spec, ReST option lists actually don't support 
 
514
        # options like --1.9 so that causes syntax errors (in Sphinx at least).
 
515
        # As that pattern always appears in the commands that break, we trap
 
516
        # on that and then format that block of 'format' options as a literal
 
517
        # block.
 
518
        if not plain and options.find('  --1.9  ') != -1:
 
519
            options = options.replace(' format:\n', ' format::\n\n', 1)
 
520
        if options.startswith('Options:'):
 
521
            result += ':' + options
 
522
        elif options.startswith('options:'):
 
523
            # Python 2.4 version of optparse
 
524
            result += ':Options:' + options[len('options:'):]
 
525
        else:
 
526
            result += options
 
527
        result += '\n'
 
528
 
 
529
        if verbose:
 
530
            # Add the description, indenting it 2 spaces
 
531
            # to match the indentation of the options
 
532
            if sections.has_key(None):
 
533
                text = sections.pop(None)
 
534
                text = '\n  '.join(text.splitlines())
 
535
                result += ':%s:\n  %s\n\n' % ('Description',text)
 
536
 
 
537
            # Add the custom sections (e.g. Examples). Note that there's no need
 
538
            # to indent these as they must be indented already in the source.
 
539
            if sections:
 
540
                for label in order:
 
541
                    if sections.has_key(label):
 
542
                        result += ':%s:\n%s\n' % (label,sections[label])
 
543
                result += '\n'
 
544
        else:
 
545
            result += ("See bzr help %s for more details and examples.\n\n"
 
546
                % self.name())
 
547
 
 
548
        # Add the aliases, source (plug-in) and see also links, if any
 
549
        if self.aliases:
 
550
            result += ':Aliases:  '
 
551
            result += ', '.join(self.aliases) + '\n'
 
552
        plugin_name = self.plugin_name()
 
553
        if plugin_name is not None:
 
554
            result += ':From:     plugin "%s"\n' % plugin_name
 
555
        see_also = self.get_see_also(additional_see_also)
 
556
        if see_also:
 
557
            if not plain and see_also_as_links:
 
558
                see_also_links = []
 
559
                for item in see_also:
 
560
                    if item == 'topics':
 
561
                        # topics doesn't have an independent section
 
562
                        # so don't create a real link
 
563
                        see_also_links.append(item)
 
564
                    else:
 
565
                        # Use a Sphinx link for this entry
 
566
                        link_text = ":doc:`%s <%s-help>`" % (item, item)
 
567
                        see_also_links.append(link_text)
 
568
                see_also = see_also_links
 
569
            result += ':See also: '
 
570
            result += ', '.join(see_also) + '\n'
 
571
 
 
572
        # If this will be rendered as plain text, convert it
 
573
        if plain:
 
574
            import bzrlib.help_topics
 
575
            result = bzrlib.help_topics.help_as_plain_text(result)
 
576
        return result
 
577
 
 
578
    @staticmethod
 
579
    def _get_help_parts(text):
 
580
        """Split help text into a summary and named sections.
 
581
 
 
582
        :return: (summary,sections,order) where summary is the top line and
 
583
            sections is a dictionary of the rest indexed by section name.
 
584
            order is the order the section appear in the text.
 
585
            A section starts with a heading line of the form ":xxx:".
 
586
            Indented text on following lines is the section value.
 
587
            All text found outside a named section is assigned to the
 
588
            default section which is given the key of None.
 
589
        """
 
590
        def save_section(sections, order, label, section):
 
591
            if len(section) > 0:
 
592
                if sections.has_key(label):
 
593
                    sections[label] += '\n' + section
 
594
                else:
 
595
                    order.append(label)
 
596
                    sections[label] = section
 
597
 
 
598
        lines = text.rstrip().splitlines()
 
599
        summary = lines.pop(0)
 
600
        sections = {}
 
601
        order = []
 
602
        label,section = None,''
 
603
        for line in lines:
 
604
            if line.startswith(':') and line.endswith(':') and len(line) > 2:
 
605
                save_section(sections, order, label, section)
 
606
                label,section = line[1:-1],''
 
607
            elif (label is not None) and len(line) > 1 and not line[0].isspace():
 
608
                save_section(sections, order, label, section)
 
609
                label,section = None,line
 
610
            else:
 
611
                if len(section) > 0:
 
612
                    section += '\n' + line
 
613
                else:
 
614
                    section = line
 
615
        save_section(sections, order, label, section)
 
616
        return summary, sections, order
 
617
 
 
618
    def get_help_topic(self):
 
619
        """Return the commands help topic - its name."""
 
620
        return self.name()
 
621
 
 
622
    def get_see_also(self, additional_terms=None):
 
623
        """Return a list of help topics that are related to this command.
 
624
 
 
625
        The list is derived from the content of the _see_also attribute. Any
 
626
        duplicates are removed and the result is in lexical order.
 
627
        :param additional_terms: Additional help topics to cross-reference.
 
628
        :return: A list of help topics.
 
629
        """
 
630
        see_also = set(getattr(self, '_see_also', []))
 
631
        if additional_terms:
 
632
            see_also.update(additional_terms)
 
633
        return sorted(see_also)
219
634
 
220
635
    def options(self):
221
636
        """Return dict of valid options for this command.
222
637
 
223
638
        Maps from long option name to option object."""
224
 
        r = dict()
225
 
        r['help'] = Option.OPTIONS['help']
 
639
        r = Option.STD_OPTIONS.copy()
 
640
        std_names = r.keys()
226
641
        for o in self.takes_options:
227
642
            if isinstance(o, basestring):
228
 
                o = Option.OPTIONS[o]
 
643
                o = option.Option.OPTIONS[o]
229
644
            r[o.name] = o
 
645
            if o.name in std_names:
 
646
                self.supported_std_options.append(o.name)
230
647
        return r
231
648
 
232
649
    def _setup_outf(self):
233
650
        """Return a file linked to stdout, which has proper encoding."""
234
 
        assert self.encoding_type in ['strict', 'exact', 'replace']
235
 
 
236
 
        # Originally I was using self.stdout, but that looks
237
 
        # *way* too much like sys.stdout
238
 
        if self.encoding_type == 'exact':
239
 
            self.outf = sys.stdout
240
 
            return
241
 
 
242
 
        output_encoding = bzrlib.osutils.get_terminal_encoding()
243
 
 
244
 
        # use 'replace' so that we don't abort if trying to write out
245
 
        # in e.g. the default C locale.
246
 
        self.outf = codecs.getwriter(output_encoding)(sys.stdout, errors=self.encoding_type)
247
 
        # For whatever reason codecs.getwriter() does not advertise its encoding
248
 
        # it just returns the encoding of the wrapped file, which is completely
249
 
        # bogus. So set the attribute, so we can find the correct encoding later.
250
 
        self.outf.encoding = output_encoding
251
 
 
252
 
    @deprecated_method(zero_eight)
253
 
    def run_argv(self, argv):
254
 
        """Parse command line and run.
255
 
        
256
 
        See run_argv_aliases for the 0.8 and beyond api.
257
 
        """
258
 
        return self.run_argv_aliases(argv)
 
651
        self.outf = ui.ui_factory.make_output_stream(
 
652
            encoding_type=self.encoding_type)
259
653
 
260
654
    def run_argv_aliases(self, argv, alias_argv=None):
261
655
        """Parse the command line and run with extra aliases in alias_argv."""
262
 
        if argv is None:
263
 
            warn("Passing None for [] is deprecated from bzrlib 0.10", 
264
 
                 DeprecationWarning, stacklevel=2)
265
 
            argv = []
266
656
        args, opts = parse_args(self, argv, alias_argv)
 
657
 
 
658
        # Process the standard options
267
659
        if 'help' in opts:  # e.g. bzr add --help
268
 
            from bzrlib.help import help_on_command
269
 
            help_on_command(self.name())
270
 
            return 0
 
660
            sys.stdout.write(self.get_help_text())
 
661
            return 0
 
662
        if 'usage' in opts:  # e.g. bzr add --usage
 
663
            sys.stdout.write(self.get_help_text(verbose=False))
 
664
            return 0
 
665
        trace.set_verbosity_level(option._verbosity_level)
 
666
        if 'verbose' in self.supported_std_options:
 
667
            opts['verbose'] = trace.is_verbose()
 
668
        elif opts.has_key('verbose'):
 
669
            del opts['verbose']
 
670
        if 'quiet' in self.supported_std_options:
 
671
            opts['quiet'] = trace.is_quiet()
 
672
        elif opts.has_key('quiet'):
 
673
            del opts['quiet']
 
674
 
271
675
        # mix arguments and options into one dictionary
272
676
        cmdargs = _match_argform(self.name(), self.takes_args, args)
273
677
        cmdopts = {}
279
683
 
280
684
        self._setup_outf()
281
685
 
282
 
        return self.run(**all_cmd_args)
283
 
    
 
686
        return self.run_direct(**all_cmd_args)
 
687
 
 
688
    def run_direct(self, *args, **kwargs):
 
689
        """Call run directly with objects (without parsing an argv list)."""
 
690
        return self._operation.run_simple(*args, **kwargs)
 
691
 
284
692
    def run(self):
285
693
        """Actually run the command.
286
694
 
291
699
        shell error code if not.  It's OK for this method to allow
292
700
        an exception to raise up.
293
701
        """
294
 
        raise NotImplementedError('no implementation of command %r' 
 
702
        raise NotImplementedError('no implementation of command %r'
295
703
                                  % self.name())
296
704
 
297
705
    def help(self):
316
724
            return None
317
725
 
318
726
 
319
 
def parse_spec(spec):
320
 
    """
321
 
    >>> parse_spec(None)
322
 
    [None, None]
323
 
    >>> parse_spec("./")
324
 
    ['./', None]
325
 
    >>> parse_spec("../@")
326
 
    ['..', -1]
327
 
    >>> parse_spec("../f/@35")
328
 
    ['../f', 35]
329
 
    >>> parse_spec('./@revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67')
330
 
    ['.', 'revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67']
331
 
    """
332
 
    if spec is None:
333
 
        return [None, None]
334
 
    if '/@' in spec:
335
 
        parsed = spec.split('/@')
336
 
        assert len(parsed) == 2
337
 
        if parsed[1] == "":
338
 
            parsed[1] = -1
339
 
        else:
340
 
            try:
341
 
                parsed[1] = int(parsed[1])
342
 
            except ValueError:
343
 
                pass # We can allow stuff like ./@revid:blahblahblah
344
 
            else:
345
 
                assert parsed[1] >=0
346
 
    else:
347
 
        parsed = [spec, None]
348
 
    return parsed
 
727
class CommandHooks(Hooks):
 
728
    """Hooks related to Command object creation/enumeration."""
 
729
 
 
730
    def __init__(self):
 
731
        """Create the default hooks.
 
732
 
 
733
        These are all empty initially, because by default nothing should get
 
734
        notified.
 
735
        """
 
736
        Hooks.__init__(self)
 
737
        self.create_hook(HookPoint('extend_command',
 
738
            "Called after creating a command object to allow modifications "
 
739
            "such as adding or removing options, docs etc. Called with the "
 
740
            "new bzrlib.commands.Command object.", (1, 13), None))
 
741
        self.create_hook(HookPoint('get_command',
 
742
            "Called when creating a single command. Called with "
 
743
            "(cmd_or_None, command_name). get_command should either return "
 
744
            "the cmd_or_None parameter, or a replacement Command object that "
 
745
            "should be used for the command. Note that the Command.hooks "
 
746
            "hooks are core infrastructure. Many users will prefer to use "
 
747
            "bzrlib.commands.register_command or plugin_cmds.register_lazy.",
 
748
            (1, 17), None))
 
749
        self.create_hook(HookPoint('get_missing_command',
 
750
            "Called when creating a single command if no command could be "
 
751
            "found. Called with (command_name). get_missing_command should "
 
752
            "either return None, or a Command object to be used for the "
 
753
            "command.", (1, 17), None))
 
754
        self.create_hook(HookPoint('list_commands',
 
755
            "Called when enumerating commands. Called with a set of "
 
756
            "cmd_name strings for all the commands found so far. This set "
 
757
            " is safe to mutate - e.g. to remove a command. "
 
758
            "list_commands should return the updated set of command names.",
 
759
            (1, 17), None))
 
760
 
 
761
Command.hooks = CommandHooks()
 
762
 
349
763
 
350
764
def parse_args(command, argv, alias_argv=None):
351
765
    """Parse command line.
352
 
    
 
766
 
353
767
    Arguments and options are parsed at this level before being passed
354
768
    down to specific command handlers.  This routine knows, from a
355
769
    lookup table, something about the available options, what optargs
363
777
        args = argv
364
778
 
365
779
    options, args = parser.parse_args(args)
366
 
    opts = dict([(k, v) for k, v in options.__dict__.iteritems() if 
 
780
    opts = dict([(k, v) for k, v in options.__dict__.iteritems() if
367
781
                 v is not option.OptionParser.DEFAULT_VALUE])
368
782
    return args, opts
369
783
 
385
799
                argdict[argname + '_list'] = None
386
800
        elif ap[-1] == '+':
387
801
            if not args:
388
 
                raise BzrCommandError("command %r needs one or more %s"
389
 
                        % (cmd, argname.upper()))
 
802
                raise errors.BzrCommandError("command %r needs one or more %s"
 
803
                                             % (cmd, argname.upper()))
390
804
            else:
391
805
                argdict[argname + '_list'] = args[:]
392
806
                args = []
393
807
        elif ap[-1] == '$': # all but one
394
808
            if len(args) < 2:
395
 
                raise BzrCommandError("command %r needs one or more %s"
396
 
                        % (cmd, argname.upper()))
 
809
                raise errors.BzrCommandError("command %r needs one or more %s"
 
810
                                             % (cmd, argname.upper()))
397
811
            argdict[argname + '_list'] = args[:-1]
398
812
            args[:-1] = []
399
813
        else:
400
814
            # just a plain arg
401
815
            argname = ap
402
816
            if not args:
403
 
                raise BzrCommandError("command %r requires argument %s"
404
 
                        % (cmd, argname.upper()))
 
817
                raise errors.BzrCommandError("command %r requires argument %s"
 
818
                               % (cmd, argname.upper()))
405
819
            else:
406
820
                argdict[argname] = args.pop(0)
407
 
            
 
821
 
408
822
    if args:
409
 
        raise BzrCommandError("extra argument to command %s: %s"
410
 
                              % (cmd, args[0]))
 
823
        raise errors.BzrCommandError("extra argument to command %s: %s"
 
824
                                     % (cmd, args[0]))
411
825
 
412
826
    return argdict
413
827
 
 
828
def apply_coveraged(dirname, the_callable, *args, **kwargs):
 
829
    # Cannot use "import trace", as that would import bzrlib.trace instead of
 
830
    # the standard library's trace.
 
831
    trace = __import__('trace')
 
832
 
 
833
    tracer = trace.Trace(count=1, trace=0)
 
834
    sys.settrace(tracer.globaltrace)
 
835
    threading.settrace(tracer.globaltrace)
 
836
 
 
837
    try:
 
838
        return exception_to_return_code(the_callable, *args, **kwargs)
 
839
    finally:
 
840
        sys.settrace(None)
 
841
        results = tracer.results()
 
842
        results.write_results(show_missing=1, summary=False,
 
843
                              coverdir=dirname)
414
844
 
415
845
 
416
846
def apply_profiled(the_callable, *args, **kwargs):
421
851
    try:
422
852
        prof = hotshot.Profile(pfname)
423
853
        try:
424
 
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
 
854
            ret = prof.runcall(exception_to_return_code, the_callable, *args,
 
855
                **kwargs) or 0
425
856
        finally:
426
857
            prof.close()
427
858
        stats = hotshot.stats.load(pfname)
436
867
        os.remove(pfname)
437
868
 
438
869
 
 
870
def exception_to_return_code(the_callable, *args, **kwargs):
 
871
    """UI level helper for profiling and coverage.
 
872
 
 
873
    This transforms exceptions into a return value of 3. As such its only
 
874
    relevant to the UI layer, and should never be called where catching
 
875
    exceptions may be desirable.
 
876
    """
 
877
    try:
 
878
        return the_callable(*args, **kwargs)
 
879
    except (KeyboardInterrupt, Exception), e:
 
880
        # used to handle AssertionError and KeyboardInterrupt
 
881
        # specially here, but hopefully they're handled ok by the logger now
 
882
        exc_info = sys.exc_info()
 
883
        exitcode = trace.report_exception(exc_info, sys.stderr)
 
884
        if os.environ.get('BZR_PDB'):
 
885
            print '**** entering debugger'
 
886
            tb = exc_info[2]
 
887
            import pdb
 
888
            if sys.version_info[:2] < (2, 6):
 
889
                # XXX: we want to do
 
890
                #    pdb.post_mortem(tb)
 
891
                # but because pdb.post_mortem gives bad results for tracebacks
 
892
                # from inside generators, we do it manually.
 
893
                # (http://bugs.python.org/issue4150, fixed in Python 2.6)
 
894
 
 
895
                # Setup pdb on the traceback
 
896
                p = pdb.Pdb()
 
897
                p.reset()
 
898
                p.setup(tb.tb_frame, tb)
 
899
                # Point the debugger at the deepest frame of the stack
 
900
                p.curindex = len(p.stack) - 1
 
901
                p.curframe = p.stack[p.curindex][0]
 
902
                # Start the pdb prompt.
 
903
                p.print_stack_entry(p.stack[p.curindex])
 
904
                p.execRcLines()
 
905
                p.cmdloop()
 
906
            else:
 
907
                pdb.post_mortem(tb)
 
908
        return exitcode
 
909
 
 
910
 
439
911
def apply_lsprofiled(filename, the_callable, *args, **kwargs):
440
912
    from bzrlib.lsprof import profile
441
 
    import cPickle
442
 
    ret, stats = profile(the_callable, *args, **kwargs)
 
913
    ret, stats = profile(exception_to_return_code, the_callable, *args, **kwargs)
443
914
    stats.sort()
444
915
    if filename is None:
445
916
        stats.pprint()
446
917
    else:
447
 
        stats.freeze()
448
 
        cPickle.dump(stats, open(filename, 'w'), 2)
449
 
        print 'Profile data written to %r.' % filename
 
918
        stats.save(filename)
 
919
        trace.note('Profile data written to "%s".', filename)
450
920
    return ret
451
921
 
452
922
 
453
 
def get_alias(cmd):
454
 
    """Return an expanded alias, or None if no alias exists"""
455
 
    import bzrlib.config
456
 
    alias = bzrlib.config.GlobalConfig().get_alias(cmd)
 
923
@deprecated_function(deprecated_in((2, 2, 0)))
 
924
def shlex_split_unicode(unsplit):
 
925
    return cmdline.split(unsplit)
 
926
 
 
927
 
 
928
def get_alias(cmd, config=None):
 
929
    """Return an expanded alias, or None if no alias exists.
 
930
 
 
931
    cmd
 
932
        Command to be checked for an alias.
 
933
    config
 
934
        Used to specify an alternative config to use,
 
935
        which is especially useful for testing.
 
936
        If it is unspecified, the global config will be used.
 
937
    """
 
938
    if config is None:
 
939
        import bzrlib.config
 
940
        config = bzrlib.config.GlobalConfig()
 
941
    alias = config.get_alias(cmd)
457
942
    if (alias):
458
 
        return alias.split(' ')
 
943
        return cmdline.split(alias)
459
944
    return None
460
945
 
461
946
 
462
 
def run_bzr(argv):
 
947
def run_bzr(argv, load_plugins=load_plugins, disable_plugins=disable_plugins):
463
948
    """Execute a command.
464
949
 
465
 
    This is similar to main(), but without all the trappings for
466
 
    logging and error handling.  
467
 
    
468
 
    argv
469
 
       The command-line arguments, without the program name from argv[0]
470
 
       These should already be decoded. All library/test code calling
471
 
       run_bzr should be passing valid strings (don't need decoding).
472
 
    
473
 
    Returns a command status or raises an exception.
 
950
    :param argv: The command-line arguments, without the program name from
 
951
        argv[0] These should already be decoded. All library/test code calling
 
952
        run_bzr should be passing valid strings (don't need decoding).
 
953
    :param load_plugins: What function to call when triggering plugin loading.
 
954
        This function should take no arguments and cause all plugins to be
 
955
        loaded.
 
956
    :param disable_plugins: What function to call when disabling plugin
 
957
        loading. This function should take no arguments and cause all plugin
 
958
        loading to be prohibited (so that code paths in your application that
 
959
        know about some plugins possibly being present will fail to import
 
960
        those plugins even if they are installed.)
 
961
    :return: Returns a command exit code or raises an exception.
474
962
 
475
963
    Special master options: these must come before the command because
476
964
    they control how the command is interpreted.
490
978
 
491
979
    --lsprof
492
980
        Run under the Python lsprof profiler.
 
981
 
 
982
    --coverage
 
983
        Generate line coverage report in the specified directory.
 
984
 
 
985
    --concurrency
 
986
        Specify the number of processes that can be run concurrently (selftest).
493
987
    """
 
988
    trace.mutter("bazaar version: " + bzrlib.__version__)
494
989
    argv = list(argv)
 
990
    trace.mutter("bzr arguments: %r", argv)
495
991
 
496
992
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
497
993
                opt_no_aliases = False
498
 
    opt_lsprof_file = None
 
994
    opt_lsprof_file = opt_coverage_dir = None
499
995
 
500
996
    # --no-plugins is handled specially at a very early stage. We need
501
997
    # to load plugins before doing other command parsing so that they
519
1015
            opt_no_aliases = True
520
1016
        elif a == '--builtin':
521
1017
            opt_builtin = True
522
 
        elif a in ('--quiet', '-q'):
523
 
            be_quiet()
 
1018
        elif a == '--concurrency':
 
1019
            os.environ['BZR_CONCURRENCY'] = argv[i + 1]
 
1020
            i += 1
 
1021
        elif a == '--coverage':
 
1022
            opt_coverage_dir = argv[i + 1]
 
1023
            i += 1
 
1024
        elif a.startswith('-D'):
 
1025
            debug.debug_flags.add(a[2:])
524
1026
        else:
525
1027
            argv_copy.append(a)
526
1028
        i += 1
527
1029
 
 
1030
    debug.set_debug_flags_from_config()
 
1031
 
 
1032
    if not opt_no_plugins:
 
1033
        load_plugins()
 
1034
    else:
 
1035
        disable_plugins()
 
1036
 
528
1037
    argv = argv_copy
529
1038
    if (not argv):
530
 
        from bzrlib.builtins import cmd_help
531
 
        cmd_help().run_argv_aliases([])
 
1039
        get_cmd_object('help').run_argv_aliases([])
532
1040
        return 0
533
1041
 
534
1042
    if argv[0] == '--version':
535
 
        from bzrlib.version import show_version
536
 
        show_version()
 
1043
        get_cmd_object('version').run_argv_aliases([])
537
1044
        return 0
538
 
        
539
 
    if not opt_no_plugins:
540
 
        from bzrlib.plugin import load_plugins
541
 
        load_plugins()
542
 
    else:
543
 
        from bzrlib.plugin import disable_plugins
544
 
        disable_plugins()
545
1045
 
546
1046
    alias_argv = None
547
1047
 
548
1048
    if not opt_no_aliases:
549
1049
        alias_argv = get_alias(argv[0])
550
1050
        if alias_argv:
551
 
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
 
1051
            user_encoding = osutils.get_user_encoding()
 
1052
            alias_argv = [a.decode(user_encoding) for a in alias_argv]
552
1053
            argv[0] = alias_argv.pop(0)
553
1054
 
554
1055
    cmd = argv.pop(0)
557
1058
    # 'command not found' error later.
558
1059
 
559
1060
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
560
 
    if not getattr(cmd_obj.run_argv, 'is_deprecated', False):
561
 
        run = cmd_obj.run_argv
562
 
        run_argv = [argv]
563
 
    else:
564
 
        run = cmd_obj.run_argv_aliases
565
 
        run_argv = [argv, alias_argv]
 
1061
    run = cmd_obj.run_argv_aliases
 
1062
    run_argv = [argv, alias_argv]
566
1063
 
567
1064
    try:
 
1065
        # We can be called recursively (tests for example), but we don't want
 
1066
        # the verbosity level to propagate.
 
1067
        saved_verbosity_level = option._verbosity_level
 
1068
        option._verbosity_level = 0
568
1069
        if opt_lsprof:
 
1070
            if opt_coverage_dir:
 
1071
                trace.warning(
 
1072
                    '--coverage ignored, because --lsprof is in use.')
569
1073
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
570
1074
        elif opt_profile:
 
1075
            if opt_coverage_dir:
 
1076
                trace.warning(
 
1077
                    '--coverage ignored, because --profile is in use.')
571
1078
            ret = apply_profiled(run, *run_argv)
 
1079
        elif opt_coverage_dir:
 
1080
            ret = apply_coveraged(opt_coverage_dir, run, *run_argv)
572
1081
        else:
573
1082
            ret = run(*run_argv)
574
1083
        return ret or 0
575
1084
    finally:
576
 
        # reset, in case we may do other commands later within the same process
577
 
        be_quiet(False)
 
1085
        # reset, in case we may do other commands later within the same
 
1086
        # process. Commands that want to execute sub-commands must propagate
 
1087
        # --verbose in their own way.
 
1088
        if 'memory' in debug.debug_flags:
 
1089
            trace.debug_memory('Process status after command:', short=False)
 
1090
        option._verbosity_level = saved_verbosity_level
 
1091
 
578
1092
 
579
1093
def display_command(func):
580
1094
    """Decorator that suppresses pipe/interrupt errors."""
588
1102
                raise
589
1103
            if e.errno != errno.EPIPE:
590
1104
                # Win32 raises IOError with errno=0 on a broken pipe
591
 
                if sys.platform != 'win32' or e.errno != 0:
 
1105
                if sys.platform != 'win32' or (e.errno not in (0, errno.EINVAL)):
592
1106
                    raise
593
1107
            pass
594
1108
        except KeyboardInterrupt:
596
1110
    return ignore_pipe
597
1111
 
598
1112
 
599
 
def main(argv):
600
 
    import bzrlib.ui
601
 
    from bzrlib.ui.text import TextUIFactory
602
 
    bzrlib.ui.ui_factory = TextUIFactory()
603
 
    argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
 
1113
def install_bzr_command_hooks():
 
1114
    """Install the hooks to supply bzr's own commands."""
 
1115
    if _list_bzr_commands in Command.hooks["list_commands"]:
 
1116
        return
 
1117
    Command.hooks.install_named_hook("list_commands", _list_bzr_commands,
 
1118
        "bzr commands")
 
1119
    Command.hooks.install_named_hook("get_command", _get_bzr_command,
 
1120
        "bzr commands")
 
1121
    Command.hooks.install_named_hook("get_command", _get_plugin_command,
 
1122
        "bzr plugin commands")
 
1123
    Command.hooks.install_named_hook("get_command", _get_external_command,
 
1124
        "bzr external command lookup")
 
1125
    Command.hooks.install_named_hook("get_missing_command", _try_plugin_provider,
 
1126
        "bzr plugin-provider-db check")
 
1127
 
 
1128
 
 
1129
 
 
1130
def _specified_or_unicode_argv(argv):
 
1131
    # For internal or testing use, argv can be passed.  Otherwise, get it from
 
1132
    # the process arguments in a unicode-safe way.
 
1133
    if argv is None:
 
1134
        return osutils.get_unicode_argv()
 
1135
    else:
 
1136
        new_argv = []
 
1137
        try:
 
1138
            # ensure all arguments are unicode strings
 
1139
            for a in argv[1:]:
 
1140
                if isinstance(a, unicode):
 
1141
                    new_argv.append(a)
 
1142
                else:
 
1143
                    new_argv.append(a.decode('ascii'))
 
1144
        except UnicodeDecodeError:
 
1145
            raise errors.BzrError("argv should be list of unicode strings.")
 
1146
        return new_argv
 
1147
 
 
1148
 
 
1149
def main(argv=None):
 
1150
    """Main entry point of command-line interface.
 
1151
 
 
1152
    Typically `bzrlib.initialize` should be called first.
 
1153
 
 
1154
    :param argv: list of unicode command-line arguments similar to sys.argv.
 
1155
        argv[0] is script name usually, it will be ignored.
 
1156
        Don't pass here sys.argv because this list contains plain strings
 
1157
        and not unicode; pass None instead.
 
1158
 
 
1159
    :return: exit code of bzr command.
 
1160
    """
 
1161
    argv = _specified_or_unicode_argv(argv)
 
1162
    _register_builtin_commands()
604
1163
    ret = run_bzr_catch_errors(argv)
605
 
    mutter("return code %d", ret)
 
1164
    bzrlib.ui.ui_factory.log_transport_activity(
 
1165
        display=('bytes' in debug.debug_flags))
 
1166
    trace.mutter("return code %d", ret)
606
1167
    return ret
607
1168
 
608
1169
 
609
1170
def run_bzr_catch_errors(argv):
 
1171
    """Run a bzr command with parameters as described by argv.
 
1172
 
 
1173
    This function assumed that that UI layer is setup, that symbol deprecations
 
1174
    are already applied, and that unicode decoding has already been performed on argv.
 
1175
    """
 
1176
    # done here so that they're covered for every test run
 
1177
    install_bzr_command_hooks()
 
1178
    return exception_to_return_code(run_bzr, argv)
 
1179
 
 
1180
 
 
1181
def run_bzr_catch_user_errors(argv):
 
1182
    """Run bzr and report user errors, but let internal errors propagate.
 
1183
 
 
1184
    This is used for the test suite, and might be useful for other programs
 
1185
    that want to wrap the commandline interface.
 
1186
    """
 
1187
    # done here so that they're covered for every test run
 
1188
    install_bzr_command_hooks()
610
1189
    try:
611
1190
        return run_bzr(argv)
612
 
        # do this here inside the exception wrappers to catch EPIPE
613
 
        sys.stdout.flush()
614
1191
    except Exception, e:
615
 
        # used to handle AssertionError and KeyboardInterrupt
616
 
        # specially here, but hopefully they're handled ok by the logger now
617
 
        bzrlib.trace.report_exception(sys.exc_info(), sys.stderr)
618
 
        if os.environ.get('BZR_PDB'):
619
 
            print '**** entering debugger'
620
 
            import pdb
621
 
            pdb.post_mortem(sys.exc_traceback)
622
 
        return 3
623
 
 
624
 
if __name__ == '__main__':
625
 
    sys.exit(main(sys.argv))
 
1192
        if (isinstance(e, (OSError, IOError))
 
1193
            or not getattr(e, 'internal_error', True)):
 
1194
            trace.report_exception(sys.exc_info(), sys.stderr)
 
1195
            return 3
 
1196
        else:
 
1197
            raise
 
1198
 
 
1199
 
 
1200
class HelpCommandIndex(object):
 
1201
    """A index for bzr help that returns commands."""
 
1202
 
 
1203
    def __init__(self):
 
1204
        self.prefix = 'commands/'
 
1205
 
 
1206
    def get_topics(self, topic):
 
1207
        """Search for topic amongst commands.
 
1208
 
 
1209
        :param topic: A topic to search for.
 
1210
        :return: A list which is either empty or contains a single
 
1211
            Command entry.
 
1212
        """
 
1213
        if topic and topic.startswith(self.prefix):
 
1214
            topic = topic[len(self.prefix):]
 
1215
        try:
 
1216
            cmd = _get_cmd_object(topic, check_missing=False)
 
1217
        except KeyError:
 
1218
            return []
 
1219
        else:
 
1220
            return [cmd]
 
1221
 
 
1222
 
 
1223
class Provider(object):
 
1224
    '''Generic class to be overriden by plugins'''
 
1225
 
 
1226
    def plugin_for_command(self, cmd_name):
 
1227
        '''Takes a command and returns the information for that plugin
 
1228
 
 
1229
        :return: A dictionary with all the available information
 
1230
        for the requested plugin
 
1231
        '''
 
1232
        raise NotImplementedError
 
1233
 
 
1234
 
 
1235
class ProvidersRegistry(registry.Registry):
 
1236
    '''This registry exists to allow other providers to exist'''
 
1237
 
 
1238
    def __iter__(self):
 
1239
        for key, provider in self.iteritems():
 
1240
            yield provider
 
1241
 
 
1242
command_providers_registry = ProvidersRegistry()