/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

Merge from bzr.dev, resolving conflicts.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005-2011 Canonical Ltd
 
1
# Copyright (C) 2006 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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
16
 
 
17
 
from __future__ import absolute_import
 
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.
18
20
 
19
21
# TODO: Define arguments by objects, rather than just using names.
20
22
# Those objects can specify the expected type of the argument, which
23
25
 
24
26
# TODO: Specific "examples" property on commands for consistent formatting.
25
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
 
26
31
import os
27
32
import sys
28
33
 
29
 
from .lazy_import import lazy_import
 
34
from bzrlib.lazy_import import lazy_import
30
35
lazy_import(globals(), """
 
36
import codecs
31
37
import errno
32
 
import threading
 
38
from warnings import warn
33
39
 
34
 
import breezy
35
 
from breezy import (
36
 
    config,
37
 
    cleanup,
38
 
    cmdline,
 
40
import bzrlib
 
41
from bzrlib import (
39
42
    debug,
40
 
    i18n,
 
43
    errors,
41
44
    option,
42
45
    osutils,
43
46
    trace,
44
 
    ui,
45
47
    )
46
48
""")
47
49
 
48
 
from .hooks import Hooks
49
 
from .i18n import gettext
50
 
# Compatibility - Option used to be in commands.
51
 
from .option import Option
52
 
from .plugin import disable_plugins, load_plugins, plugin_name
53
 
from . import errors, registry
54
 
from .sixish import (
55
 
    string_types,
56
 
    text_type,
 
50
from bzrlib.symbol_versioning import (
 
51
    deprecated_function,
 
52
    deprecated_method,
 
53
    zero_eight,
 
54
    zero_eleven,
57
55
    )
58
 
 
59
 
 
60
 
class BzrOptionError(errors.BzrCommandError):
61
 
 
62
 
    _fmt = "Error in command line options"
63
 
 
64
 
 
65
 
class CommandAvailableInPlugin(Exception):
66
 
 
67
 
    internal_error = False
68
 
 
69
 
    def __init__(self, cmd_name, plugin_metadata, provider):
70
 
 
71
 
        self.plugin_metadata = plugin_metadata
72
 
        self.cmd_name = cmd_name
73
 
        self.provider = provider
74
 
 
75
 
    def __str__(self):
76
 
 
77
 
        _fmt = ('"%s" is not a standard brz command. \n'
78
 
                'However, the following official plugin provides this command: %s\n'
79
 
                'You can install it by going to: %s'
80
 
                % (self.cmd_name, self.plugin_metadata['name'],
81
 
                    self.plugin_metadata['url']))
82
 
 
83
 
        return _fmt
84
 
 
85
 
 
86
 
class CommandInfo(object):
87
 
    """Information about a command."""
88
 
 
89
 
    def __init__(self, aliases):
90
 
        """The list of aliases for the command."""
91
 
        self.aliases = aliases
92
 
 
93
 
    @classmethod
94
 
    def from_command(klass, command):
95
 
        """Factory to construct a CommandInfo from a command."""
96
 
        return klass(command.aliases)
97
 
 
98
 
 
99
 
class CommandRegistry(registry.Registry):
100
 
    """Special registry mapping command names to command classes.
101
 
    
102
 
    :ivar overridden_registry: Look in this registry for commands being
103
 
        overridden by this registry.  This can be used to tell plugin commands
104
 
        about the builtin they're decorating.
105
 
    """
106
 
 
107
 
    def __init__(self):
108
 
        registry.Registry.__init__(self)
109
 
        self.overridden_registry = None
110
 
        # map from aliases to the real command that implements the name
111
 
        self._alias_dict = {}
112
 
 
113
 
    def get(self, command_name):
114
 
        real_name = self._alias_dict.get(command_name, command_name)
115
 
        return registry.Registry.get(self, real_name)
116
 
 
117
 
    @staticmethod
118
 
    def _get_name(command_name):
119
 
        if command_name.startswith("cmd_"):
120
 
            return _unsquish_command_name(command_name)
121
 
        else:
122
 
            return command_name
123
 
 
124
 
    def register(self, cmd, decorate=False):
125
 
        """Utility function to help register a command
126
 
 
127
 
        :param cmd: Command subclass to register
128
 
        :param decorate: If true, allow overriding an existing command
129
 
            of the same name; the old command is returned by this function.
130
 
            Otherwise it is an error to try to override an existing command.
131
 
        """
132
 
        k = cmd.__name__
133
 
        k_unsquished = self._get_name(k)
134
 
        try:
135
 
            previous = self.get(k_unsquished)
136
 
        except KeyError:
137
 
            previous = None
138
 
            if self.overridden_registry:
139
 
                try:
140
 
                    previous = self.overridden_registry.get(k_unsquished)
141
 
                except KeyError:
142
 
                    pass
143
 
        info = CommandInfo.from_command(cmd)
144
 
        try:
145
 
            registry.Registry.register(self, k_unsquished, cmd,
146
 
                                       override_existing=decorate, info=info)
147
 
        except KeyError:
148
 
            trace.warning('Two plugins defined the same command: %r' % k)
149
 
            trace.warning('Not loading the one in %r' %
150
 
                sys.modules[cmd.__module__])
151
 
            trace.warning('Previously this command was registered from %r' %
152
 
                sys.modules[previous.__module__])
153
 
        for a in cmd.aliases:
154
 
            self._alias_dict[a] = k_unsquished
155
 
        return previous
156
 
 
157
 
    def register_lazy(self, command_name, aliases, module_name):
158
 
        """Register a command without loading its module.
159
 
 
160
 
        :param command_name: The primary name of the command.
161
 
        :param aliases: A list of aliases for the command.
162
 
        :module_name: The module that the command lives in.
163
 
        """
164
 
        key = self._get_name(command_name)
165
 
        registry.Registry.register_lazy(self, key, module_name, command_name,
166
 
                                        info=CommandInfo(aliases))
167
 
        for a in aliases:
168
 
            self._alias_dict[a] = key
169
 
 
170
 
 
171
 
plugin_cmds = CommandRegistry()
172
 
builtin_command_registry = CommandRegistry()
173
 
plugin_cmds.overridden_registry = builtin_command_registry
 
56
# Compatibility
 
57
from bzrlib.option import Option
 
58
 
 
59
 
 
60
plugin_cmds = {}
174
61
 
175
62
 
176
63
def register_command(cmd, decorate=False):
177
 
    """Register a plugin command.
 
64
    """Utility function to help register a command
178
65
 
179
 
    Should generally be avoided in favor of lazy registration. 
 
66
    :param cmd: Command subclass to register
 
67
    :param decorate: If true, allow overriding an existing command
 
68
        of the same name; the old command is returned by this function.
 
69
        Otherwise it is an error to try to override an existing command.
180
70
    """
181
71
    global plugin_cmds
182
 
    return plugin_cmds.register(cmd, decorate)
 
72
    k = cmd.__name__
 
73
    if k.startswith("cmd_"):
 
74
        k_unsquished = _unsquish_command_name(k)
 
75
    else:
 
76
        k_unsquished = k
 
77
    if k_unsquished not in plugin_cmds:
 
78
        plugin_cmds[k_unsquished] = cmd
 
79
        ## trace.mutter('registered plugin command %s', k_unsquished)
 
80
        if decorate and k_unsquished in builtin_command_names():
 
81
            return _builtin_commands()[k_unsquished]
 
82
    elif decorate:
 
83
        result = plugin_cmds[k_unsquished]
 
84
        plugin_cmds[k_unsquished] = cmd
 
85
        return result
 
86
    else:
 
87
        trace.log_error('Two plugins defined the same command: %r' % k)
 
88
        trace.log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
183
89
 
184
90
 
185
91
def _squish_command_name(cmd):
187
93
 
188
94
 
189
95
def _unsquish_command_name(cmd):
190
 
    return cmd[4:].replace('_', '-')
191
 
 
192
 
 
193
 
def _register_builtin_commands():
194
 
    if builtin_command_registry.keys():
195
 
        # only load once
196
 
        return
197
 
    import breezy.builtins
198
 
    for cmd_class in _scan_module_for_commands(breezy.builtins):
199
 
        builtin_command_registry.register(cmd_class)
200
 
    breezy.builtins._register_lazy_builtins()
201
 
 
202
 
 
203
 
def _scan_module_for_commands(module):
204
 
    module_dict = module.__dict__
205
 
    for name in module_dict:
 
96
    assert cmd.startswith("cmd_")
 
97
    return cmd[4:].replace('_','-')
 
98
 
 
99
 
 
100
def _builtin_commands():
 
101
    import bzrlib.builtins
 
102
    r = {}
 
103
    builtins = bzrlib.builtins.__dict__
 
104
    for name in builtins:
206
105
        if name.startswith("cmd_"):
207
 
            yield module_dict[name]
208
 
 
209
 
 
210
 
def _list_bzr_commands(names):
211
 
    """Find commands from bzr's core and plugins.
212
 
    
213
 
    This is not the public interface, just the default hook called by all_command_names.
214
 
    """
215
 
    # to eliminate duplicates
216
 
    names.update(builtin_command_names())
217
 
    names.update(plugin_command_names())
218
 
    return names
219
 
 
220
 
 
221
 
def all_command_names():
222
 
    """Return a set of all command names."""
223
 
    names = set()
224
 
    for hook in Command.hooks['list_commands']:
225
 
        names = hook(names)
226
 
        if names is None:
227
 
            raise AssertionError(
228
 
                'hook %s returned None' % Command.hooks.get_hook_name(hook))
229
 
    return names
230
 
 
 
106
            real_name = _unsquish_command_name(name)
 
107
            r[real_name] = builtins[name]
 
108
    return r
 
109
            
231
110
 
232
111
def builtin_command_names():
233
 
    """Return list of builtin command names.
 
112
    """Return list of builtin command names."""
 
113
    return _builtin_commands().keys()
234
114
    
235
 
    Use of all_command_names() is encouraged rather than builtin_command_names
236
 
    and/or plugin_command_names.
237
 
    """
238
 
    _register_builtin_commands()
239
 
    return builtin_command_registry.keys()
240
 
 
241
115
 
242
116
def plugin_command_names():
243
 
    """Returns command names from commands registered by plugins."""
244
117
    return plugin_cmds.keys()
245
118
 
246
119
 
247
 
# Overrides for common mispellings that heuristics get wrong
248
 
_GUESS_OVERRIDES = {
249
 
    'ic': {'ci': 0}, # heuristic finds nick
250
 
    }
251
 
 
252
 
 
253
 
def guess_command(cmd_name):
254
 
    """Guess what command a user typoed.
255
 
 
256
 
    :param cmd_name: Command to search for
257
 
    :return: None if no command was found, name of a command otherwise
258
 
    """
259
 
    names = set()
260
 
    for name in all_command_names():
261
 
        names.add(name)
262
 
        cmd = get_cmd_object(name)
263
 
        names.update(cmd.aliases)
264
 
    # candidate: modified levenshtein distance against cmd_name.
265
 
    costs = {}
266
 
    from . import patiencediff
267
 
    for name in sorted(names):
268
 
        matcher = patiencediff.PatienceSequenceMatcher(None, cmd_name, name)
269
 
        distance = 0.0
270
 
        opcodes = matcher.get_opcodes()
271
 
        for opcode, l1, l2, r1, r2 in opcodes:
272
 
            if opcode == 'delete':
273
 
                distance += l2-l1
274
 
            elif opcode == 'replace':
275
 
                distance += max(l2-l1, r2-l1)
276
 
            elif opcode == 'insert':
277
 
                distance += r2-r1
278
 
            elif opcode == 'equal':
279
 
                # Score equal ranges lower, making similar commands of equal
280
 
                # length closer than arbitrary same length commands.
281
 
                distance -= 0.1 * (l2-l1)
282
 
        costs[name] = distance
283
 
    costs.update(_GUESS_OVERRIDES.get(cmd_name, {}))
284
 
    costs = sorted((costs[key], key) for key in costs)
285
 
    if not costs:
286
 
        return
287
 
    if costs[0][0] > 4:
288
 
        return
289
 
    candidate = costs[0][1]
290
 
    return candidate
 
120
def _get_cmd_dict(plugins_override=True):
 
121
    """Return name->class mapping for all commands."""
 
122
    d = _builtin_commands()
 
123
    if plugins_override:
 
124
        d.update(plugin_cmds)
 
125
    return d
 
126
 
 
127
    
 
128
def get_all_cmds(plugins_override=True):
 
129
    """Return canonical name and class for all registered commands."""
 
130
    for k, v in _get_cmd_dict(plugins_override=plugins_override).iteritems():
 
131
        yield k,v
291
132
 
292
133
 
293
134
def get_cmd_object(cmd_name, plugins_override=True):
294
 
    """Return the command object for a command.
 
135
    """Return the canonical name and command class for a command.
295
136
 
296
137
    plugins_override
297
138
        If true, plugin commands can override builtins.
298
139
    """
299
 
    try:
300
 
        return _get_cmd_object(cmd_name, plugins_override)
301
 
    except KeyError:
302
 
        # No command found, see if this was a typo
303
 
        candidate = guess_command(cmd_name)
304
 
        if candidate is not None:
305
 
            raise errors.BzrCommandError(
306
 
                    gettext('unknown command "%s". Perhaps you meant "%s"')
307
 
                    % (cmd_name, candidate))
308
 
        raise errors.BzrCommandError(gettext('unknown command "%s"')
309
 
                % cmd_name)
310
 
 
311
 
 
312
 
def _get_cmd_object(cmd_name, plugins_override=True, check_missing=True):
313
 
    """Get a command object.
314
 
 
315
 
    :param cmd_name: The name of the command.
316
 
    :param plugins_override: Allow plugins to override builtins.
317
 
    :param check_missing: Look up commands not found in the regular index via
318
 
        the get_missing_command hook.
319
 
    :return: A Command object instance
320
 
    :raises KeyError: If no command is found.
321
 
    """
 
140
    from bzrlib.externalcommand import ExternalCommand
 
141
 
322
142
    # We want only 'ascii' command names, but the user may have typed
323
143
    # in a Unicode name. In that case, they should just get a
324
144
    # 'command not found' error later.
325
145
    # In the future, we may actually support Unicode command names.
326
 
    cmd = None
327
 
    # Get a command
328
 
    for hook in Command.hooks['get_command']:
329
 
        cmd = hook(cmd, cmd_name)
330
 
        if cmd is not None and not plugins_override and not cmd.plugin_name():
331
 
            # We've found a non-plugin command, don't permit it to be
332
 
            # overridden.
333
 
            break
334
 
    if cmd is None and check_missing:
335
 
        for hook in Command.hooks['get_missing_command']:
336
 
            cmd = hook(cmd_name)
337
 
            if cmd is not None:
338
 
                break
339
 
    if cmd is None:
340
 
        # No command found.
341
 
        raise KeyError
342
 
    # Allow plugins to extend commands
343
 
    for hook in Command.hooks['extend_command']:
344
 
        hook(cmd)
345
 
    if getattr(cmd, 'invoked_as', None) is None:
346
 
        cmd.invoked_as = cmd_name
347
 
    return cmd
348
 
 
349
 
 
350
 
class NoPluginAvailable(errors.BzrError):
351
 
    pass
352
 
 
353
 
 
354
 
def _try_plugin_provider(cmd_name):
355
 
    """Probe for a plugin provider having cmd_name."""
356
 
    try:
357
 
        plugin_metadata, provider = probe_for_provider(cmd_name)
358
 
        raise CommandAvailableInPlugin(cmd_name, plugin_metadata, provider)
359
 
    except NoPluginAvailable:
360
 
        pass
361
 
 
362
 
 
363
 
def probe_for_provider(cmd_name):
364
 
    """Look for a provider for cmd_name.
365
 
 
366
 
    :param cmd_name: The command name.
367
 
    :return: plugin_metadata, provider for getting cmd_name.
368
 
    :raises NoPluginAvailable: When no provider can supply the plugin.
369
 
    """
370
 
    # look for providers that provide this command but aren't installed
371
 
    for provider in command_providers_registry:
372
 
        try:
373
 
            return provider.plugin_for_command(cmd_name), provider
374
 
        except NoPluginAvailable:
375
 
            pass
376
 
    raise NoPluginAvailable(cmd_name)
377
 
 
378
 
 
379
 
def _get_bzr_command(cmd_or_None, cmd_name):
380
 
    """Get a command from bzr's core."""
381
 
    try:
382
 
        cmd_class = builtin_command_registry.get(cmd_name)
 
146
 
 
147
    # first look up this command under the specified name
 
148
    cmds = _get_cmd_dict(plugins_override=plugins_override)
 
149
    try:
 
150
        return cmds[cmd_name]()
383
151
    except KeyError:
384
152
        pass
385
 
    else:
386
 
        return cmd_class()
387
 
    return cmd_or_None
388
 
 
389
 
 
390
 
def _get_external_command(cmd_or_None, cmd_name):
391
 
    """Lookup a command that is a shell script."""
392
 
    # Only do external command lookups when no command is found so far.
393
 
    if cmd_or_None is not None:
394
 
        return cmd_or_None
395
 
    from breezy.externalcommand import ExternalCommand
 
153
 
 
154
    # look for any command which claims this as an alias
 
155
    for real_cmd_name, cmd_class in cmds.iteritems():
 
156
        if cmd_name in cmd_class.aliases:
 
157
            return cmd_class()
 
158
 
396
159
    cmd_obj = ExternalCommand.find_command(cmd_name)
397
160
    if cmd_obj:
398
161
        return cmd_obj
399
162
 
400
 
 
401
 
def _get_plugin_command(cmd_or_None, cmd_name):
402
 
    """Get a command from brz's plugins."""
403
 
    try:
404
 
        return plugin_cmds.get(cmd_name)()
405
 
    except KeyError:
406
 
        pass
407
 
    for key in plugin_cmds.keys():
408
 
        info = plugin_cmds.get_info(key)
409
 
        if cmd_name in info.aliases:
410
 
            return plugin_cmds.get(key)()
411
 
    return cmd_or_None
 
163
    raise errors.BzrCommandError('unknown command "%s"' % cmd_name)
412
164
 
413
165
 
414
166
class Command(object):
415
167
    """Base class for commands.
416
168
 
417
 
    Commands are the heart of the command-line brz interface.
 
169
    Commands are the heart of the command-line bzr interface.
418
170
 
419
171
    The command object mostly handles the mapping of command-line
420
 
    parameters into one or more breezy operations, and of the results
 
172
    parameters into one or more bzrlib operations, and of the results
421
173
    into textual output.
422
174
 
423
175
    Commands normally don't have any state.  All their arguments are
429
181
    summary, then a complete description of the command.  A grammar
430
182
    description will be inserted.
431
183
 
432
 
    :cvar aliases: Other accepted names for this command.
433
 
 
434
 
    :cvar takes_args: List of argument forms, marked with whether they are
435
 
        optional, repeated, etc.  Examples::
436
 
 
437
 
            ['to_location', 'from_branch?', 'file*']
438
 
 
439
 
        * 'to_location' is required
440
 
        * 'from_branch' is optional
441
 
        * 'file' can be specified 0 or more times
442
 
 
443
 
    :cvar takes_options: List of options that may be given for this command.
444
 
        These can be either strings, referring to globally-defined options, or
445
 
        option objects.  Retrieve through options().
446
 
 
447
 
    :cvar hidden: If true, this command isn't advertised.  This is typically
 
184
    aliases
 
185
        Other accepted names for this command.
 
186
 
 
187
    takes_args
 
188
        List of argument forms, marked with whether they are optional,
 
189
        repeated, etc.
 
190
 
 
191
                Examples:
 
192
 
 
193
                ['to_location', 'from_branch?', 'file*']
 
194
 
 
195
                'to_location' is required
 
196
                'from_branch' is optional
 
197
                'file' can be specified 0 or more times
 
198
 
 
199
    takes_options
 
200
        List of options that may be given for this command.  These can
 
201
        be either strings, referring to globally-defined options,
 
202
        or option objects.  Retrieve through options().
 
203
 
 
204
    hidden
 
205
        If true, this command isn't advertised.  This is typically
448
206
        for commands intended for expert users.
449
207
 
450
 
    :cvar encoding_type: Command objects will get a 'outf' attribute, which has
451
 
        been setup to properly handle encoding of unicode strings.
452
 
        encoding_type determines what will happen when characters cannot be
453
 
        encoded:
454
 
 
455
 
        * strict - abort if we cannot decode
456
 
        * replace - put in a bogus character (typically '?')
457
 
        * exact - do not encode sys.stdout
458
 
 
459
 
        NOTE: by default on Windows, sys.stdout is opened as a text stream,
460
 
        therefore LF line-endings are converted to CRLF.  When a command uses
461
 
        encoding_type = 'exact', then sys.stdout is forced to be a binary
462
 
        stream, and line-endings will not mangled.
463
 
 
464
 
    :cvar invoked_as:
465
 
        A string indicating the real name under which this command was
466
 
        invoked, before expansion of aliases.
467
 
        (This may be None if the command was constructed and run in-process.)
468
 
 
469
 
    :cvar hooks: An instance of CommandHooks.
470
 
 
471
 
    :cvar __doc__: The help shown by 'brz help command' for this command.
472
 
        This is set by assigning explicitly to __doc__ so that -OO can
473
 
        be used::
474
 
 
475
 
            class Foo(Command):
476
 
                __doc__ = "My help goes here"
 
208
    encoding_type
 
209
        Command objects will get a 'outf' attribute, which has been
 
210
        setup to properly handle encoding of unicode strings.
 
211
        encoding_type determines what will happen when characters cannot
 
212
        be encoded
 
213
            strict - abort if we cannot decode
 
214
            replace - put in a bogus character (typically '?')
 
215
            exact - do not encode sys.stdout
 
216
 
 
217
            NOTE: by default on Windows, sys.stdout is opened as a text
 
218
            stream, therefore LF line-endings are converted to CRLF.
 
219
            When a command uses encoding_type = 'exact', then
 
220
            sys.stdout is forced to be a binary stream, and line-endings
 
221
            will not mangled.
 
222
 
477
223
    """
478
224
    aliases = []
479
225
    takes_args = []
480
226
    takes_options = []
481
227
    encoding_type = 'strict'
482
 
    invoked_as = None
483
 
    l10n = True
484
228
 
485
229
    hidden = False
486
 
 
 
230
    
487
231
    def __init__(self):
488
232
        """Construct an instance of this command."""
489
 
        # List of standard options directly supported
490
 
        self.supported_std_options = []
491
 
        self._setup_run()
492
 
 
493
 
    def add_cleanup(self, cleanup_func, *args, **kwargs):
494
 
        """Register a function to call after self.run returns or raises.
495
 
 
496
 
        Functions will be called in LIFO order.
497
 
        """
498
 
        self._operation.add_cleanup(cleanup_func, *args, **kwargs)
499
 
 
500
 
    def cleanup_now(self):
501
 
        """Execute and empty pending cleanup functions immediately.
502
 
 
503
 
        After cleanup_now all registered cleanups are forgotten.  add_cleanup
504
 
        may be called again after cleanup_now; these cleanups will be called
505
 
        after self.run returns or raises (or when cleanup_now is next called).
506
 
 
507
 
        This is useful for releasing expensive or contentious resources (such
508
 
        as write locks) before doing further work that does not require those
509
 
        resources (such as writing results to self.outf). Note though, that
510
 
        as it releases all resources, this may release locks that the command
511
 
        wants to hold, so use should be done with care.
512
 
        """
513
 
        self._operation.cleanup_now()
514
 
 
515
 
    def _usage(self):
516
 
        """Return single-line grammar for this command.
517
 
 
518
 
        Only describes arguments, not options.
519
 
        """
520
 
        s = 'brz ' + self.name() + ' '
521
 
        for aname in self.takes_args:
522
 
            aname = aname.upper()
523
 
            if aname[-1] in ['$', '+']:
524
 
                aname = aname[:-1] + '...'
525
 
            elif aname[-1] == '?':
526
 
                aname = '[' + aname[:-1] + ']'
527
 
            elif aname[-1] == '*':
528
 
                aname = '[' + aname[:-1] + '...]'
529
 
            s += aname + ' '
530
 
        s = s[:-1]      # remove last space
531
 
        return s
532
 
 
533
 
    def get_help_text(self, additional_see_also=None, plain=True,
534
 
                      see_also_as_links=False, verbose=True):
535
 
        """Return a text string with help for this command.
536
 
 
537
 
        :param additional_see_also: Additional help topics to be
538
 
            cross-referenced.
539
 
        :param plain: if False, raw help (reStructuredText) is
540
 
            returned instead of plain text.
541
 
        :param see_also_as_links: if True, convert items in 'See also'
542
 
            list to internal links (used by bzr_man rstx generator)
543
 
        :param verbose: if True, display the full help, otherwise
544
 
            leave out the descriptive sections and just display
545
 
            usage help (e.g. Purpose, Usage, Options) with a
546
 
            message explaining how to obtain full help.
547
 
        """
548
 
        if self.l10n:
549
 
            i18n.install()  # Install i18n only for get_help_text for now.
550
 
        doc = self.help()
551
 
        if doc:
552
 
            # Note: If self.gettext() translates ':Usage:\n', the section will
553
 
            # be shown after "Description" section and we don't want to
554
 
            # translate the usage string.
555
 
            # Though, brz export-pot don't exports :Usage: section and it must
556
 
            # not be translated.
557
 
            doc = self.gettext(doc)
558
 
        else:
559
 
            doc = gettext("No help for this command.")
560
 
 
561
 
        # Extract the summary (purpose) and sections out from the text
562
 
        purpose, sections, order = self._get_help_parts(doc)
563
 
 
564
 
        # If a custom usage section was provided, use it
565
 
        if 'Usage' in sections:
566
 
            usage = sections.pop('Usage')
567
 
        else:
568
 
            usage = self._usage()
569
 
 
570
 
        # The header is the purpose and usage
571
 
        result = ""
572
 
        result += gettext(':Purpose: %s\n') % (purpose,)
573
 
        if usage.find('\n') >= 0:
574
 
            result += gettext(':Usage:\n%s\n') % (usage,)
575
 
        else:
576
 
            result += gettext(':Usage:   %s\n') % (usage,)
577
 
        result += '\n'
578
 
 
579
 
        # Add the options
580
 
        #
581
 
        # XXX: optparse implicitly rewraps the help, and not always perfectly,
582
 
        # so we get <https://bugs.launchpad.net/bzr/+bug/249908>.  -- mbp
583
 
        # 20090319
584
 
        parser = option.get_optparser(self.options())
585
 
        options = parser.format_option_help()
586
 
        # FIXME: According to the spec, ReST option lists actually don't
587
 
        # support options like --1.14 so that causes syntax errors (in Sphinx
588
 
        # at least).  As that pattern always appears in the commands that
589
 
        # break, we trap on that and then format that block of 'format' options
590
 
        # as a literal block. We use the most recent format still listed so we
591
 
        # don't have to do that too often -- vila 20110514
592
 
        if not plain and options.find('  --1.14  ') != -1:
593
 
            options = options.replace(' format:\n', ' format::\n\n', 1)
594
 
        if options.startswith('Options:'):
595
 
            result += gettext(':Options:%s') % (options[len('options:'):],)
596
 
        else:
597
 
            result += options
598
 
        result += '\n'
599
 
 
600
 
        if verbose:
601
 
            # Add the description, indenting it 2 spaces
602
 
            # to match the indentation of the options
603
 
            if None in sections:
604
 
                text = sections.pop(None)
605
 
                text = '\n  '.join(text.splitlines())
606
 
                result += gettext(':Description:\n  %s\n\n') % (text,)
607
 
 
608
 
            # Add the custom sections (e.g. Examples). Note that there's no need
609
 
            # to indent these as they must be indented already in the source.
610
 
            if sections:
611
 
                for label in order:
612
 
                    if label in sections:
613
 
                        result += ':%s:\n%s\n' % (label, sections[label])
614
 
                result += '\n'
615
 
        else:
616
 
            result += (gettext("See brz help %s for more details and examples.\n\n")
617
 
                % self.name())
618
 
 
619
 
        # Add the aliases, source (plug-in) and see also links, if any
620
 
        if self.aliases:
621
 
            result += gettext(':Aliases:  ')
622
 
            result += ', '.join(self.aliases) + '\n'
623
 
        plugin_name = self.plugin_name()
624
 
        if plugin_name is not None:
625
 
            result += gettext(':From:     plugin "%s"\n') % plugin_name
626
 
        see_also = self.get_see_also(additional_see_also)
627
 
        if see_also:
628
 
            if not plain and see_also_as_links:
629
 
                see_also_links = []
630
 
                for item in see_also:
631
 
                    if item == 'topics':
632
 
                        # topics doesn't have an independent section
633
 
                        # so don't create a real link
634
 
                        see_also_links.append(item)
635
 
                    else:
636
 
                        # Use a Sphinx link for this entry
637
 
                        link_text = gettext(":doc:`{0} <{1}-help>`").format(
638
 
                                                                    item, item)
639
 
                        see_also_links.append(link_text)
640
 
                see_also = see_also_links
641
 
            result += gettext(':See also: %s') % ', '.join(see_also) + '\n'
642
 
 
643
 
        # If this will be rendered as plain text, convert it
644
 
        if plain:
645
 
            import breezy.help_topics
646
 
            result = breezy.help_topics.help_as_plain_text(result)
647
 
        return result
648
 
 
649
 
    @staticmethod
650
 
    def _get_help_parts(text):
651
 
        """Split help text into a summary and named sections.
652
 
 
653
 
        :return: (summary,sections,order) where summary is the top line and
654
 
            sections is a dictionary of the rest indexed by section name.
655
 
            order is the order the section appear in the text.
656
 
            A section starts with a heading line of the form ":xxx:".
657
 
            Indented text on following lines is the section value.
658
 
            All text found outside a named section is assigned to the
659
 
            default section which is given the key of None.
660
 
        """
661
 
        def save_section(sections, order, label, section):
662
 
            if len(section) > 0:
663
 
                if label in sections:
664
 
                    sections[label] += '\n' + section
665
 
                else:
666
 
                    order.append(label)
667
 
                    sections[label] = section
668
 
 
669
 
        lines = text.rstrip().splitlines()
670
 
        summary = lines.pop(0)
671
 
        sections = {}
672
 
        order = []
673
 
        label, section = None, ''
674
 
        for line in lines:
675
 
            if line.startswith(':') and line.endswith(':') and len(line) > 2:
676
 
                save_section(sections, order, label, section)
677
 
                label, section = line[1:-1], ''
678
 
            elif (label is not None) and len(line) > 1 and not line[0].isspace():
679
 
                save_section(sections, order, label, section)
680
 
                label, section = None, line
681
 
            else:
682
 
                if len(section) > 0:
683
 
                    section += '\n' + line
684
 
                else:
685
 
                    section = line
686
 
        save_section(sections, order, label, section)
687
 
        return summary, sections, order
688
 
 
689
 
    def get_help_topic(self):
690
 
        """Return the commands help topic - its name."""
691
 
        return self.name()
692
 
 
693
 
    def get_see_also(self, additional_terms=None):
694
 
        """Return a list of help topics that are related to this command.
695
 
 
696
 
        The list is derived from the content of the _see_also attribute. Any
697
 
        duplicates are removed and the result is in lexical order.
698
 
        :param additional_terms: Additional help topics to cross-reference.
699
 
        :return: A list of help topics.
700
 
        """
701
 
        see_also = set(getattr(self, '_see_also', []))
702
 
        if additional_terms:
703
 
            see_also.update(additional_terms)
704
 
        return sorted(see_also)
 
233
        if self.__doc__ == Command.__doc__:
 
234
            warn("No help message set for %r" % self)
705
235
 
706
236
    def options(self):
707
237
        """Return dict of valid options for this command.
708
238
 
709
239
        Maps from long option name to option object."""
710
 
        r = Option.STD_OPTIONS.copy()
711
 
        std_names = set(r)
 
240
        r = dict()
 
241
        r['help'] = option.Option.OPTIONS['help']
712
242
        for o in self.takes_options:
713
 
            if isinstance(o, string_types):
 
243
            if isinstance(o, basestring):
714
244
                o = option.Option.OPTIONS[o]
715
245
            r[o.name] = o
716
 
            if o.name in std_names:
717
 
                self.supported_std_options.append(o.name)
718
246
        return r
719
247
 
720
248
    def _setup_outf(self):
721
249
        """Return a file linked to stdout, which has proper encoding."""
722
 
        self.outf = ui.ui_factory.make_output_stream(
723
 
            encoding_type=self.encoding_type)
 
250
        assert self.encoding_type in ['strict', 'exact', 'replace']
 
251
 
 
252
        # Originally I was using self.stdout, but that looks
 
253
        # *way* too much like sys.stdout
 
254
        if self.encoding_type == 'exact':
 
255
            # force sys.stdout to be binary stream on win32
 
256
            if sys.platform == 'win32':
 
257
                fileno = getattr(sys.stdout, 'fileno', None)
 
258
                if fileno:
 
259
                    import msvcrt
 
260
                    msvcrt.setmode(fileno(), os.O_BINARY)
 
261
            self.outf = sys.stdout
 
262
            return
 
263
 
 
264
        output_encoding = osutils.get_terminal_encoding()
 
265
 
 
266
        # use 'replace' so that we don't abort if trying to write out
 
267
        # in e.g. the default C locale.
 
268
        self.outf = codecs.getwriter(output_encoding)(sys.stdout, errors=self.encoding_type)
 
269
        # For whatever reason codecs.getwriter() does not advertise its encoding
 
270
        # it just returns the encoding of the wrapped file, which is completely
 
271
        # bogus. So set the attribute, so we can find the correct encoding later.
 
272
        self.outf.encoding = output_encoding
724
273
 
725
274
    def run_argv_aliases(self, argv, alias_argv=None):
726
275
        """Parse the command line and run with extra aliases in alias_argv."""
 
276
        if argv is None:
 
277
            warn("Passing None for [] is deprecated from bzrlib 0.10",
 
278
                 DeprecationWarning, stacklevel=2)
 
279
            argv = []
727
280
        args, opts = parse_args(self, argv, alias_argv)
728
 
        self._setup_outf()
729
 
 
730
 
        # Process the standard options
731
 
        if 'help' in opts:  # e.g. brz add --help
732
 
            self.outf.write(self.get_help_text())
733
 
            return 0
734
 
        if 'usage' in opts:  # e.g. brz add --usage
735
 
            self.outf.write(self.get_help_text(verbose=False))
736
 
            return 0
737
 
        trace.set_verbosity_level(option._verbosity_level)
738
 
        if 'verbose' in self.supported_std_options:
739
 
            opts['verbose'] = trace.is_verbose()
740
 
        elif 'verbose' in opts:
741
 
            del opts['verbose']
742
 
        if 'quiet' in self.supported_std_options:
743
 
            opts['quiet'] = trace.is_quiet()
744
 
        elif 'quiet' in opts:
745
 
            del opts['quiet']
 
281
        if 'help' in opts:  # e.g. bzr add --help
 
282
            from bzrlib.help import help_on_command
 
283
            help_on_command(self.name())
 
284
            return 0
746
285
        # mix arguments and options into one dictionary
747
286
        cmdargs = _match_argform(self.name(), self.takes_args, args)
748
287
        cmdopts = {}
752
291
        all_cmd_args = cmdargs.copy()
753
292
        all_cmd_args.update(cmdopts)
754
293
 
755
 
        try:
756
 
            return self.run(**all_cmd_args)
757
 
        finally:
758
 
            # reset it, so that other commands run in the same process won't
759
 
            # inherit state. Before we reset it, log any activity, so that it
760
 
            # gets properly tracked.
761
 
            ui.ui_factory.log_transport_activity(
762
 
                display=('bytes' in debug.debug_flags))
763
 
            trace.set_verbosity_level(0)
764
 
 
765
 
    def _setup_run(self):
766
 
        """Wrap the defined run method on self with a cleanup.
767
 
 
768
 
        This is called by __init__ to make the Command be able to be run
769
 
        by just calling run(), as it could be before cleanups were added.
770
 
 
771
 
        If a different form of cleanups are in use by your Command subclass,
772
 
        you can override this method.
773
 
        """
774
 
        class_run = self.run
775
 
        def run(*args, **kwargs):
776
 
            for hook in Command.hooks['pre_command']:
777
 
                hook(self)
778
 
            self._operation = cleanup.OperationWithCleanups(class_run)
779
 
            try:
780
 
                return self._operation.run_simple(*args, **kwargs)
781
 
            finally:
782
 
                del self._operation
783
 
                for hook in Command.hooks['post_command']:
784
 
                    hook(self)
785
 
        self.run = run
786
 
 
 
294
        self._setup_outf()
 
295
 
 
296
        return self.run(**all_cmd_args)
 
297
    
787
298
    def run(self):
788
299
        """Actually run the command.
789
300
 
793
304
        Return 0 or None if the command was successful, or a non-zero
794
305
        shell error code if not.  It's OK for this method to allow
795
306
        an exception to raise up.
796
 
 
797
 
        This method is automatically wrapped by Command.__init__ with a 
798
 
        cleanup operation, stored as self._operation. This can be used
799
 
        via self.add_cleanup to perform automatic cleanups at the end of
800
 
        run().
801
 
 
802
 
        The argument for run are assembled by introspection. So for instance,
803
 
        if your command takes an argument files, you would declare::
804
 
 
805
 
            def run(self, files=None):
806
 
                pass
807
307
        """
808
308
        raise NotImplementedError('no implementation of command %r'
809
309
                                  % self.name())
815
315
            return None
816
316
        return getdoc(self)
817
317
 
818
 
    def gettext(self, message):
819
 
        """Returns the gettext function used to translate this command's help.
820
 
 
821
 
        Commands provided by plugins should override this to use their
822
 
        own i18n system.
823
 
        """
824
 
        return i18n.gettext_per_paragraph(message)
825
 
 
826
318
    def name(self):
827
 
        """Return the canonical name for this command.
828
 
 
829
 
        The name under which it was actually invoked is available in invoked_as.
830
 
        """
831
319
        return _unsquish_command_name(self.__class__.__name__)
832
320
 
833
321
    def plugin_name(self):
835
323
 
836
324
        :return: The name of the plugin or None if the command is builtin.
837
325
        """
838
 
        return plugin_name(self.__module__)
839
 
 
840
 
 
841
 
class CommandHooks(Hooks):
842
 
    """Hooks related to Command object creation/enumeration."""
843
 
 
844
 
    def __init__(self):
845
 
        """Create the default hooks.
846
 
 
847
 
        These are all empty initially, because by default nothing should get
848
 
        notified.
849
 
        """
850
 
        Hooks.__init__(self, "breezy.commands", "Command.hooks")
851
 
        self.add_hook('extend_command',
852
 
            "Called after creating a command object to allow modifications "
853
 
            "such as adding or removing options, docs etc. Called with the "
854
 
            "new breezy.commands.Command object.", (1, 13))
855
 
        self.add_hook('get_command',
856
 
            "Called when creating a single command. Called with "
857
 
            "(cmd_or_None, command_name). get_command should either return "
858
 
            "the cmd_or_None parameter, or a replacement Command object that "
859
 
            "should be used for the command. Note that the Command.hooks "
860
 
            "hooks are core infrastructure. Many users will prefer to use "
861
 
            "breezy.commands.register_command or plugin_cmds.register_lazy.",
862
 
            (1, 17))
863
 
        self.add_hook('get_missing_command',
864
 
            "Called when creating a single command if no command could be "
865
 
            "found. Called with (command_name). get_missing_command should "
866
 
            "either return None, or a Command object to be used for the "
867
 
            "command.", (1, 17))
868
 
        self.add_hook('list_commands',
869
 
            "Called when enumerating commands. Called with a set of "
870
 
            "cmd_name strings for all the commands found so far. This set "
871
 
            " is safe to mutate - e.g. to remove a command. "
872
 
            "list_commands should return the updated set of command names.",
873
 
            (1, 17))
874
 
        self.add_hook('pre_command',
875
 
            "Called prior to executing a command. Called with the command "
876
 
            "object.", (2, 6))
877
 
        self.add_hook('post_command',
878
 
            "Called after executing a command. Called with the command "
879
 
            "object.", (2, 6))
880
 
 
881
 
Command.hooks = CommandHooks()
882
 
 
 
326
        mod_parts = self.__module__.split('.')
 
327
        if len(mod_parts) >= 3 and mod_parts[1] == 'plugins':
 
328
            return mod_parts[2]
 
329
        else:
 
330
            return None
 
331
 
 
332
 
 
333
# Technically, this function hasn't been use in a *really* long time
 
334
# but we are only deprecating it now.
 
335
@deprecated_function(zero_eleven)
 
336
def parse_spec(spec):
 
337
    """
 
338
    >>> parse_spec(None)
 
339
    [None, None]
 
340
    >>> parse_spec("./")
 
341
    ['./', None]
 
342
    >>> parse_spec("../@")
 
343
    ['..', -1]
 
344
    >>> parse_spec("../f/@35")
 
345
    ['../f', 35]
 
346
    >>> parse_spec('./@revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67')
 
347
    ['.', 'revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67']
 
348
    """
 
349
    if spec is None:
 
350
        return [None, None]
 
351
    if '/@' in spec:
 
352
        parsed = spec.split('/@')
 
353
        assert len(parsed) == 2
 
354
        if parsed[1] == "":
 
355
            parsed[1] = -1
 
356
        else:
 
357
            try:
 
358
                parsed[1] = int(parsed[1])
 
359
            except ValueError:
 
360
                pass # We can allow stuff like ./@revid:blahblahblah
 
361
            else:
 
362
                assert parsed[1] >=0
 
363
    else:
 
364
        parsed = [spec, None]
 
365
    return parsed
883
366
 
884
367
def parse_args(command, argv, alias_argv=None):
885
368
    """Parse command line.
886
 
 
 
369
    
887
370
    Arguments and options are parsed at this level before being passed
888
371
    down to specific command handlers.  This routine knows, from a
889
372
    lookup table, something about the available options, what optargs
896
379
    else:
897
380
        args = argv
898
381
 
899
 
    # for python 2.5 and later, optparse raises this exception if a non-ascii
900
 
    # option name is given.  See http://bugs.python.org/issue2931
901
 
    try:
902
 
        options, args = parser.parse_args(args)
903
 
    except UnicodeEncodeError as e:
904
 
        raise errors.BzrCommandError(
905
 
            gettext('Only ASCII permitted in option names'))
906
 
 
907
 
    opts = dict((k, v) for k, v in options.__dict__.items() if
908
 
                v is not option.OptionParser.DEFAULT_VALUE)
 
382
    options, args = parser.parse_args(args)
 
383
    opts = dict([(k, v) for k, v in options.__dict__.iteritems() if
 
384
                 v is not option.OptionParser.DEFAULT_VALUE])
909
385
    return args, opts
910
386
 
911
387
 
926
402
                argdict[argname + '_list'] = None
927
403
        elif ap[-1] == '+':
928
404
            if not args:
929
 
                raise errors.BzrCommandError(gettext(
930
 
                      "command {0!r} needs one or more {1}").format(
931
 
                      cmd, argname.upper()))
 
405
                raise errors.BzrCommandError("command %r needs one or more %s"
 
406
                                             % (cmd, argname.upper()))
932
407
            else:
933
408
                argdict[argname + '_list'] = args[:]
934
409
                args = []
935
410
        elif ap[-1] == '$': # all but one
936
411
            if len(args) < 2:
937
 
                raise errors.BzrCommandError(
938
 
                      gettext("command {0!r} needs one or more {1}").format(
939
 
                                             cmd, argname.upper()))
 
412
                raise errors.BzrCommandError("command %r needs one or more %s"
 
413
                                             % (cmd, argname.upper()))
940
414
            argdict[argname + '_list'] = args[:-1]
941
415
            args[:-1] = []
942
416
        else:
943
417
            # just a plain arg
944
418
            argname = ap
945
419
            if not args:
946
 
                raise errors.BzrCommandError(
947
 
                     gettext("command {0!r} requires argument {1}").format(
948
 
                               cmd, argname.upper()))
 
420
                raise errors.BzrCommandError("command %r requires argument %s"
 
421
                               % (cmd, argname.upper()))
949
422
            else:
950
423
                argdict[argname] = args.pop(0)
951
 
 
 
424
            
952
425
    if args:
953
 
        raise errors.BzrCommandError( gettext(
954
 
                              "extra argument to command {0}: {1}").format(
955
 
                                       cmd, args[0]) )
 
426
        raise errors.BzrCommandError("extra argument to command %s: %s"
 
427
                                     % (cmd, args[0]))
956
428
 
957
429
    return argdict
958
430
 
959
431
 
960
 
def apply_coveraged(the_callable, *args, **kwargs):
961
 
    import coverage
962
 
    cov = coverage.Coverage()
963
 
    os.environ['COVERAGE_PROCESS_START'] = cov.config_file
964
 
    cov.start()
965
 
    try:
966
 
        return exception_to_return_code(the_callable, *args, **kwargs)
967
 
    finally:
968
 
        cov.stop()
969
 
        cov.save()
970
 
 
971
432
 
972
433
def apply_profiled(the_callable, *args, **kwargs):
973
434
    import hotshot
977
438
    try:
978
439
        prof = hotshot.Profile(pfname)
979
440
        try:
980
 
            ret = prof.runcall(exception_to_return_code, the_callable, *args,
981
 
                **kwargs) or 0
 
441
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
982
442
        finally:
983
443
            prof.close()
984
444
        stats = hotshot.stats.load(pfname)
993
453
        os.remove(pfname)
994
454
 
995
455
 
996
 
def exception_to_return_code(the_callable, *args, **kwargs):
997
 
    """UI level helper for profiling and coverage.
998
 
 
999
 
    This transforms exceptions into a return value of 3. As such its only
1000
 
    relevant to the UI layer, and should never be called where catching
1001
 
    exceptions may be desirable.
1002
 
    """
1003
 
    try:
1004
 
        return the_callable(*args, **kwargs)
1005
 
    except (KeyboardInterrupt, Exception) as e:
1006
 
        # used to handle AssertionError and KeyboardInterrupt
1007
 
        # specially here, but hopefully they're handled ok by the logger now
1008
 
        exc_info = sys.exc_info()
1009
 
        exitcode = trace.report_exception(exc_info, sys.stderr)
1010
 
        if os.environ.get('BRZ_PDB'):
1011
 
            print('**** entering debugger')
1012
 
            import pdb
1013
 
            pdb.post_mortem(exc_info[2])
1014
 
        return exitcode
1015
 
 
1016
 
 
1017
456
def apply_lsprofiled(filename, the_callable, *args, **kwargs):
1018
 
    from breezy.lsprof import profile
1019
 
    ret, stats = profile(exception_to_return_code, the_callable,
1020
 
                         *args, **kwargs)
 
457
    from bzrlib.lsprof import profile
 
458
    import cPickle
 
459
    ret, stats = profile(the_callable, *args, **kwargs)
1021
460
    stats.sort()
1022
461
    if filename is None:
1023
462
        stats.pprint()
1024
463
    else:
1025
 
        stats.save(filename)
1026
 
        trace.note(gettext('Profile data written to "%s".'), filename)
 
464
        stats.freeze()
 
465
        cPickle.dump(stats, open(filename, 'w'), 2)
 
466
        print 'Profile data written to %r.' % filename
1027
467
    return ret
1028
468
 
1029
469
 
1038
478
        If it is unspecified, the global config will be used.
1039
479
    """
1040
480
    if config is None:
1041
 
        import breezy.config
1042
 
        config = breezy.config.GlobalConfig()
 
481
        import bzrlib.config
 
482
        config = bzrlib.config.GlobalConfig()
1043
483
    alias = config.get_alias(cmd)
1044
484
    if (alias):
1045
 
        return cmdline.split(alias)
 
485
        import shlex
 
486
        return [a.decode('utf-8') for a in shlex.split(alias.encode('utf-8'))]
1046
487
    return None
1047
488
 
1048
489
 
1049
 
def run_bzr(argv, load_plugins=load_plugins, disable_plugins=disable_plugins):
 
490
def run_bzr(argv):
1050
491
    """Execute a command.
1051
492
 
1052
 
    :param argv: The command-line arguments, without the program name from
1053
 
        argv[0] These should already be decoded. All library/test code calling
1054
 
        run_bzr should be passing valid strings (don't need decoding).
1055
 
    :param load_plugins: What function to call when triggering plugin loading.
1056
 
        This function should take no arguments and cause all plugins to be
1057
 
        loaded.
1058
 
    :param disable_plugins: What function to call when disabling plugin
1059
 
        loading. This function should take no arguments and cause all plugin
1060
 
        loading to be prohibited (so that code paths in your application that
1061
 
        know about some plugins possibly being present will fail to import
1062
 
        those plugins even if they are installed.)
1063
 
    :return: Returns a command exit code or raises an exception.
 
493
    This is similar to main(), but without all the trappings for
 
494
    logging and error handling.  
 
495
    
 
496
    argv
 
497
       The command-line arguments, without the program name from argv[0]
 
498
       These should already be decoded. All library/test code calling
 
499
       run_bzr should be passing valid strings (don't need decoding).
 
500
    
 
501
    Returns a command status or raises an exception.
1064
502
 
1065
503
    Special master options: these must come before the command because
1066
504
    they control how the command is interpreted.
1080
518
 
1081
519
    --lsprof
1082
520
        Run under the Python lsprof profiler.
1083
 
 
1084
 
    --coverage
1085
 
        Generate code coverage report
1086
 
 
1087
 
    --concurrency
1088
 
        Specify the number of processes that can be run concurrently (selftest).
1089
521
    """
1090
 
    trace.mutter("breezy version: " + breezy.__version__)
1091
 
    argv = _specified_or_unicode_argv(argv)
1092
 
    trace.mutter("brz arguments: %r", argv)
 
522
    argv = list(argv)
 
523
    trace.mutter("bzr arguments: %r", argv)
1093
524
 
1094
 
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin = \
1095
 
            opt_coverage = opt_no_l10n = opt_no_aliases = False
 
525
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
 
526
                opt_no_aliases = False
1096
527
    opt_lsprof_file = None
1097
528
 
1098
529
    # --no-plugins is handled specially at a very early stage. We need
1101
532
 
1102
533
    argv_copy = []
1103
534
    i = 0
1104
 
    override_config = []
1105
535
    while i < len(argv):
1106
536
        a = argv[i]
1107
537
        if a == '--profile':
1116
546
            opt_no_plugins = True
1117
547
        elif a == '--no-aliases':
1118
548
            opt_no_aliases = True
1119
 
        elif a == '--no-l10n':
1120
 
            opt_no_l10n = True
1121
549
        elif a == '--builtin':
1122
550
            opt_builtin = True
1123
 
        elif a == '--concurrency':
1124
 
            os.environ['BRZ_CONCURRENCY'] = argv[i + 1]
1125
 
            i += 1
1126
 
        elif a == '--coverage':
1127
 
            opt_coverage = True
1128
 
        elif a == '--profile-imports':
1129
 
            pass # already handled in startup script Bug #588277
 
551
        elif a in ('--quiet', '-q'):
 
552
            trace.be_quiet()
1130
553
        elif a.startswith('-D'):
1131
554
            debug.debug_flags.add(a[2:])
1132
 
        elif a.startswith('-O'):
1133
 
            override_config.append(a[2:])
1134
555
        else:
1135
556
            argv_copy.append(a)
1136
557
        i += 1
1137
558
 
1138
 
    cmdline_overrides = breezy.get_global_state().cmdline_overrides
1139
 
    cmdline_overrides._from_cmdline(override_config)
1140
 
 
1141
 
    debug.set_debug_flags_from_config()
1142
 
 
 
559
    argv = argv_copy
 
560
    if (not argv):
 
561
        from bzrlib.builtins import cmd_help
 
562
        cmd_help().run_argv_aliases([])
 
563
        return 0
 
564
 
 
565
    if argv[0] == '--version':
 
566
        from bzrlib.version import show_version
 
567
        show_version()
 
568
        return 0
 
569
        
1143
570
    if not opt_no_plugins:
 
571
        from bzrlib.plugin import load_plugins
1144
572
        load_plugins()
1145
573
    else:
 
574
        from bzrlib.plugin import disable_plugins
1146
575
        disable_plugins()
1147
576
 
1148
 
    argv = argv_copy
1149
 
    if (not argv):
1150
 
        get_cmd_object('help').run_argv_aliases([])
1151
 
        return 0
1152
 
 
1153
 
    if argv[0] == '--version':
1154
 
        get_cmd_object('version').run_argv_aliases([])
1155
 
        return 0
1156
 
 
1157
577
    alias_argv = None
1158
578
 
1159
579
    if not opt_no_aliases:
1160
580
        alias_argv = get_alias(argv[0])
1161
581
        if alias_argv:
 
582
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
1162
583
            argv[0] = alias_argv.pop(0)
1163
584
 
1164
585
    cmd = argv.pop(0)
 
586
    # We want only 'ascii' command names, but the user may have typed
 
587
    # in a Unicode name. In that case, they should just get a
 
588
    # 'command not found' error later.
 
589
 
1165
590
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
1166
 
    if opt_no_l10n:
1167
 
        cmd_obj.l10n = False
1168
591
    run = cmd_obj.run_argv_aliases
1169
592
    run_argv = [argv, alias_argv]
1170
593
 
1171
594
    try:
1172
 
        # We can be called recursively (tests for example), but we don't want
1173
 
        # the verbosity level to propagate.
1174
 
        saved_verbosity_level = option._verbosity_level
1175
 
        option._verbosity_level = 0
1176
595
        if opt_lsprof:
1177
 
            if opt_coverage:
1178
 
                trace.warning(
1179
 
                    '--coverage ignored, because --lsprof is in use.')
1180
596
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
1181
597
        elif opt_profile:
1182
 
            if opt_coverage:
1183
 
                trace.warning(
1184
 
                    '--coverage ignored, because --profile is in use.')
1185
598
            ret = apply_profiled(run, *run_argv)
1186
 
        elif opt_coverage:
1187
 
            ret = apply_coveraged(run, *run_argv)
1188
599
        else:
1189
600
            ret = run(*run_argv)
1190
601
        return ret or 0
1191
602
    finally:
1192
 
        # reset, in case we may do other commands later within the same
1193
 
        # process. Commands that want to execute sub-commands must propagate
1194
 
        # --verbose in their own way.
1195
 
        if 'memory' in debug.debug_flags:
1196
 
            trace.debug_memory('Process status after command:', short=False)
1197
 
        option._verbosity_level = saved_verbosity_level
1198
 
        # Reset the overrides 
1199
 
        cmdline_overrides._reset()
1200
 
 
 
603
        # reset, in case we may do other commands later within the same process
 
604
        trace.be_quiet(False)
1201
605
 
1202
606
def display_command(func):
1203
607
    """Decorator that suppresses pipe/interrupt errors."""
1206
610
            result = func(*args, **kwargs)
1207
611
            sys.stdout.flush()
1208
612
            return result
1209
 
        except IOError as e:
 
613
        except IOError, e:
1210
614
            if getattr(e, 'errno', None) is None:
1211
615
                raise
1212
616
            if e.errno != errno.EPIPE:
1219
623
    return ignore_pipe
1220
624
 
1221
625
 
1222
 
def install_bzr_command_hooks():
1223
 
    """Install the hooks to supply bzr's own commands."""
1224
 
    if _list_bzr_commands in Command.hooks["list_commands"]:
1225
 
        return
1226
 
    Command.hooks.install_named_hook("list_commands", _list_bzr_commands,
1227
 
        "bzr commands")
1228
 
    Command.hooks.install_named_hook("get_command", _get_bzr_command,
1229
 
        "bzr commands")
1230
 
    Command.hooks.install_named_hook("get_command", _get_plugin_command,
1231
 
        "bzr plugin commands")
1232
 
    Command.hooks.install_named_hook("get_command", _get_external_command,
1233
 
        "bzr external command lookup")
1234
 
    Command.hooks.install_named_hook("get_missing_command",
1235
 
                                     _try_plugin_provider,
1236
 
                                     "bzr plugin-provider-db check")
1237
 
 
1238
 
 
1239
 
 
1240
 
def _specified_or_unicode_argv(argv):
1241
 
    # For internal or testing use, argv can be passed.  Otherwise, get it from
1242
 
    # the process arguments in a unicode-safe way.
1243
 
    if argv is None:
1244
 
        return osutils.get_unicode_argv()
1245
 
    new_argv = []
1246
 
    try:
1247
 
        # ensure all arguments are unicode strings
1248
 
        for a in argv:
1249
 
            if not isinstance(a, string_types):
1250
 
                raise ValueError('not native str or unicode: %r' % (a,))
1251
 
            if isinstance(a, bytes):
1252
 
                # For Python 2 only allow ascii native strings
1253
 
                a = a.decode('ascii')
1254
 
            new_argv.append(a)
1255
 
    except (ValueError, UnicodeDecodeError):
1256
 
        raise errors.BzrError("argv should be list of unicode strings.")
1257
 
    return new_argv
1258
 
 
1259
 
 
1260
 
def main(argv=None):
1261
 
    """Main entry point of command-line interface.
1262
 
 
1263
 
    Typically `breezy.initialize` should be called first.
1264
 
 
1265
 
    :param argv: list of unicode command-line arguments similar to sys.argv.
1266
 
        argv[0] is script name usually, it will be ignored.
1267
 
        Don't pass here sys.argv because this list contains plain strings
1268
 
        and not unicode; pass None instead.
1269
 
 
1270
 
    :return: exit code of brz command.
1271
 
    """
1272
 
    if argv is not None:
1273
 
        argv = argv[1:]
1274
 
    _register_builtin_commands()
 
626
def main(argv):
 
627
    import bzrlib.ui
 
628
    from bzrlib.ui.text import TextUIFactory
 
629
    bzrlib.ui.ui_factory = TextUIFactory()
 
630
    argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
1275
631
    ret = run_bzr_catch_errors(argv)
1276
632
    trace.mutter("return code %d", ret)
1277
633
    return ret
1278
634
 
1279
635
 
1280
636
def run_bzr_catch_errors(argv):
1281
 
    """Run a bzr command with parameters as described by argv.
1282
 
 
1283
 
    This function assumed that that UI layer is setup, that symbol deprecations
1284
 
    are already applied, and that unicode decoding has already been performed on argv.
1285
 
    """
1286
 
    # done here so that they're covered for every test run
1287
 
    install_bzr_command_hooks()
1288
 
    return exception_to_return_code(run_bzr, argv)
1289
 
 
1290
 
 
1291
 
def run_bzr_catch_user_errors(argv):
1292
 
    """Run brz and report user errors, but let internal errors propagate.
1293
 
 
1294
 
    This is used for the test suite, and might be useful for other programs
1295
 
    that want to wrap the commandline interface.
1296
 
    """
1297
 
    # done here so that they're covered for every test run
1298
 
    install_bzr_command_hooks()
1299
637
    try:
1300
638
        return run_bzr(argv)
1301
 
    except Exception as e:
1302
 
        if (isinstance(e, (OSError, IOError))
1303
 
            or not getattr(e, 'internal_error', True)):
1304
 
            trace.report_exception(sys.exc_info(), sys.stderr)
1305
 
            return 3
1306
 
        else:
1307
 
            raise
1308
 
 
1309
 
 
1310
 
class HelpCommandIndex(object):
1311
 
    """A index for bzr help that returns commands."""
1312
 
 
1313
 
    def __init__(self):
1314
 
        self.prefix = 'commands/'
1315
 
 
1316
 
    def get_topics(self, topic):
1317
 
        """Search for topic amongst commands.
1318
 
 
1319
 
        :param topic: A topic to search for.
1320
 
        :return: A list which is either empty or contains a single
1321
 
            Command entry.
1322
 
        """
1323
 
        if topic and topic.startswith(self.prefix):
1324
 
            topic = topic[len(self.prefix):]
1325
 
        try:
1326
 
            cmd = _get_cmd_object(topic, check_missing=False)
1327
 
        except KeyError:
1328
 
            return []
1329
 
        else:
1330
 
            return [cmd]
1331
 
 
1332
 
 
1333
 
class Provider(object):
1334
 
    """Generic class to be overriden by plugins"""
1335
 
 
1336
 
    def plugin_for_command(self, cmd_name):
1337
 
        """Takes a command and returns the information for that plugin
1338
 
 
1339
 
        :return: A dictionary with all the available information
1340
 
            for the requested plugin
1341
 
        """
1342
 
        raise NotImplementedError
1343
 
 
1344
 
 
1345
 
class ProvidersRegistry(registry.Registry):
1346
 
    """This registry exists to allow other providers to exist"""
1347
 
 
1348
 
    def __iter__(self):
1349
 
        for key, provider in self.items():
1350
 
            yield provider
1351
 
 
1352
 
command_providers_registry = ProvidersRegistry()
 
639
        # do this here inside the exception wrappers to catch EPIPE
 
640
        sys.stdout.flush()
 
641
    except (KeyboardInterrupt, Exception), e:
 
642
        # used to handle AssertionError and KeyboardInterrupt
 
643
        # specially here, but hopefully they're handled ok by the logger now
 
644
        trace.report_exception(sys.exc_info(), sys.stderr)
 
645
        if os.environ.get('BZR_PDB'):
 
646
            print '**** entering debugger'
 
647
            import pdb
 
648
            pdb.post_mortem(sys.exc_traceback)
 
649
        return 3
 
650
 
 
651
if __name__ == '__main__':
 
652
    sys.exit(main(sys.argv))