/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: Vincent Ladeuil
  • Date: 2007-11-24 14:20:59 UTC
  • mto: (3928.1.1 bzr.integration)
  • mto: This revision was merged to the branch mainline in revision 3929.
  • Revision ID: v.ladeuil+lp@free.fr-20071124142059-2114qtsgfdv8g9p1
Ssl files needed for the test https server.

* bzrlib/tests/ssl_certs/create_ssls.py: 
Script to create the ssl keys and certificates.

* bzrlib/tests/ssl_certs/server.crt: 
Server certificate signed by the certificate authority.

* bzrlib/tests/ssl_certs/server.csr: 
Server certificate signing request.

* bzrlib/tests/ssl_certs/server_without_pass.key: 
Server key usable without password.

* bzrlib/tests/ssl_certs/server_with_pass.key: 
Server key.

* bzrlib/tests/ssl_certs/ca.key: 
Certificate authority private key.

* bzrlib/tests/ssl_certs/ca.crt: 
Certificate authority certificate.

* bzrlib/tests/ssl_certs/__init__.py: 
Provide access to ssl files (keys and certificates). 

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,
 
47
    win32utils,
45
48
    )
46
49
""")
47
50
 
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,
 
51
from bzrlib.symbol_versioning import (
 
52
    deprecated_function,
 
53
    deprecated_method,
57
54
    )
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
 
55
# Compatibility
 
56
from bzrlib.option import Option
 
57
 
 
58
 
 
59
plugin_cmds = {}
174
60
 
175
61
 
176
62
def register_command(cmd, decorate=False):
177
 
    """Register a plugin command.
 
63
    """Utility function to help register a command
178
64
 
179
 
    Should generally be avoided in favor of lazy registration. 
 
65
    :param cmd: Command subclass to register
 
66
    :param decorate: If true, allow overriding an existing command
 
67
        of the same name; the old command is returned by this function.
 
68
        Otherwise it is an error to try to override an existing command.
180
69
    """
181
70
    global plugin_cmds
182
 
    return plugin_cmds.register(cmd, decorate)
 
71
    k = cmd.__name__
 
72
    if k.startswith("cmd_"):
 
73
        k_unsquished = _unsquish_command_name(k)
 
74
    else:
 
75
        k_unsquished = k
 
76
    if k_unsquished not in plugin_cmds:
 
77
        plugin_cmds[k_unsquished] = cmd
 
78
        ## trace.mutter('registered plugin command %s', k_unsquished)
 
79
        if decorate and k_unsquished in builtin_command_names():
 
80
            return _builtin_commands()[k_unsquished]
 
81
    elif decorate:
 
82
        result = plugin_cmds[k_unsquished]
 
83
        plugin_cmds[k_unsquished] = cmd
 
84
        return result
 
85
    else:
 
86
        trace.log_error('Two plugins defined the same command: %r' % k)
 
87
        trace.log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
 
88
        trace.log_error('Previously this command was registered from %r' %
 
89
                        sys.modules[plugin_cmds[k_unsquished].__module__])
183
90
 
184
91
 
185
92
def _squish_command_name(cmd):
187
94
 
188
95
 
189
96
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:
 
97
    assert cmd.startswith("cmd_")
 
98
    return cmd[4:].replace('_','-')
 
99
 
 
100
 
 
101
def _builtin_commands():
 
102
    import bzrlib.builtins
 
103
    r = {}
 
104
    builtins = bzrlib.builtins.__dict__
 
105
    for name in builtins:
206
106
        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
 
 
 
107
            real_name = _unsquish_command_name(name)
 
108
            r[real_name] = builtins[name]
 
109
    return r
 
110
            
231
111
 
232
112
def builtin_command_names():
233
 
    """Return list of builtin command names.
 
113
    """Return list of builtin command names."""
 
114
    return _builtin_commands().keys()
234
115
    
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
116
 
242
117
def plugin_command_names():
243
 
    """Returns command names from commands registered by plugins."""
244
118
    return plugin_cmds.keys()
245
119
 
246
120
 
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
 
121
def _get_cmd_dict(plugins_override=True):
 
122
    """Return name->class mapping for all commands."""
 
123
    d = _builtin_commands()
 
124
    if plugins_override:
 
125
        d.update(plugin_cmds)
 
126
    return d
 
127
 
 
128
    
 
129
def get_all_cmds(plugins_override=True):
 
130
    """Return canonical name and class for all registered commands."""
 
131
    for k, v in _get_cmd_dict(plugins_override=plugins_override).iteritems():
 
132
        yield k,v
291
133
 
292
134
 
293
135
def get_cmd_object(cmd_name, plugins_override=True):
294
 
    """Return the command object for a command.
 
136
    """Return the canonical name and command class for a command.
295
137
 
296
138
    plugins_override
297
139
        If true, plugin commands can override builtins.
299
141
    try:
300
142
        return _get_cmd_object(cmd_name, plugins_override)
301
143
    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
 
    """
 
144
        raise errors.BzrCommandError('unknown command "%s"' % cmd_name)
 
145
 
 
146
 
 
147
def _get_cmd_object(cmd_name, plugins_override=True):
 
148
    """Worker for get_cmd_object which raises KeyError rather than BzrCommandError."""
 
149
    from bzrlib.externalcommand import ExternalCommand
 
150
 
322
151
    # We want only 'ascii' command names, but the user may have typed
323
152
    # in a Unicode name. In that case, they should just get a
324
153
    # 'command not found' error later.
325
154
    # 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)
 
155
 
 
156
    # first look up this command under the specified name
 
157
    cmds = _get_cmd_dict(plugins_override=plugins_override)
 
158
    try:
 
159
        return cmds[cmd_name]()
383
160
    except KeyError:
384
161
        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
 
162
 
 
163
    # look for any command which claims this as an alias
 
164
    for real_cmd_name, cmd_class in cmds.iteritems():
 
165
        if cmd_name in cmd_class.aliases:
 
166
            return cmd_class()
 
167
 
396
168
    cmd_obj = ExternalCommand.find_command(cmd_name)
397
169
    if cmd_obj:
398
170
        return cmd_obj
399
 
 
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
 
171
    raise KeyError
412
172
 
413
173
 
414
174
class Command(object):
415
175
    """Base class for commands.
416
176
 
417
 
    Commands are the heart of the command-line brz interface.
 
177
    Commands are the heart of the command-line bzr interface.
418
178
 
419
179
    The command object mostly handles the mapping of command-line
420
 
    parameters into one or more breezy operations, and of the results
 
180
    parameters into one or more bzrlib operations, and of the results
421
181
    into textual output.
422
182
 
423
183
    Commands normally don't have any state.  All their arguments are
429
189
    summary, then a complete description of the command.  A grammar
430
190
    description will be inserted.
431
191
 
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
 
192
    aliases
 
193
        Other accepted names for this command.
 
194
 
 
195
    takes_args
 
196
        List of argument forms, marked with whether they are optional,
 
197
        repeated, etc.
 
198
 
 
199
                Examples:
 
200
 
 
201
                ['to_location', 'from_branch?', 'file*']
 
202
 
 
203
                'to_location' is required
 
204
                'from_branch' is optional
 
205
                'file' can be specified 0 or more times
 
206
 
 
207
    takes_options
 
208
        List of options that may be given for this command.  These can
 
209
        be either strings, referring to globally-defined options,
 
210
        or option objects.  Retrieve through options().
 
211
 
 
212
    hidden
 
213
        If true, this command isn't advertised.  This is typically
448
214
        for commands intended for expert users.
449
215
 
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"
 
216
    encoding_type
 
217
        Command objects will get a 'outf' attribute, which has been
 
218
        setup to properly handle encoding of unicode strings.
 
219
        encoding_type determines what will happen when characters cannot
 
220
        be encoded
 
221
            strict - abort if we cannot decode
 
222
            replace - put in a bogus character (typically '?')
 
223
            exact - do not encode sys.stdout
 
224
 
 
225
            NOTE: by default on Windows, sys.stdout is opened as a text
 
226
            stream, therefore LF line-endings are converted to CRLF.
 
227
            When a command uses encoding_type = 'exact', then
 
228
            sys.stdout is forced to be a binary stream, and line-endings
 
229
            will not mangled.
 
230
 
477
231
    """
478
232
    aliases = []
479
233
    takes_args = []
480
234
    takes_options = []
481
235
    encoding_type = 'strict'
482
 
    invoked_as = None
483
 
    l10n = True
484
236
 
485
237
    hidden = False
486
 
 
 
238
    
487
239
    def __init__(self):
488
240
        """Construct an instance of this command."""
 
241
        if self.__doc__ == Command.__doc__:
 
242
            warn("No help message set for %r" % self)
489
243
        # List of standard options directly supported
490
244
        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()
 
245
 
 
246
    def _maybe_expand_globs(self, file_list):
 
247
        """Glob expand file_list if the platform does not do that itself.
 
248
        
 
249
        :return: A possibly empty list of unicode paths.
 
250
 
 
251
        Introduced in bzrlib 0.18.
 
252
        """
 
253
        if not file_list:
 
254
            file_list = []
 
255
        if sys.platform == 'win32':
 
256
            file_list = win32utils.glob_expand(file_list)
 
257
        return list(file_list)
514
258
 
515
259
    def _usage(self):
516
260
        """Return single-line grammar for this command.
517
261
 
518
262
        Only describes arguments, not options.
519
263
        """
520
 
        s = 'brz ' + self.name() + ' '
 
264
        s = 'bzr ' + self.name() + ' '
521
265
        for aname in self.takes_args:
522
266
            aname = aname.upper()
523
267
            if aname[-1] in ['$', '+']:
527
271
            elif aname[-1] == '*':
528
272
                aname = '[' + aname[:-1] + '...]'
529
273
            s += aname + ' '
530
 
        s = s[:-1]      # remove last space
 
274
                
 
275
        assert s[-1] == ' '
 
276
        s = s[:-1]
531
277
        return s
532
278
 
533
279
    def get_help_text(self, additional_see_also=None, plain=True,
534
 
                      see_also_as_links=False, verbose=True):
 
280
                      see_also_as_links=False):
535
281
        """Return a text string with help for this command.
536
 
 
 
282
        
537
283
        :param additional_see_also: Additional help topics to be
538
284
            cross-referenced.
539
285
        :param plain: if False, raw help (reStructuredText) is
540
286
            returned instead of plain text.
541
287
        :param see_also_as_links: if True, convert items in 'See also'
542
288
            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
289
        """
548
 
        if self.l10n:
549
 
            i18n.install()  # Install i18n only for get_help_text for now.
550
290
        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.")
 
291
        if doc is None:
 
292
            raise NotImplementedError("sorry, no detailed help yet for %r" % self.name())
560
293
 
561
294
        # Extract the summary (purpose) and sections out from the text
562
 
        purpose, sections, order = self._get_help_parts(doc)
 
295
        purpose,sections = self._get_help_parts(doc)
563
296
 
564
297
        # If a custom usage section was provided, use it
565
 
        if 'Usage' in sections:
 
298
        if sections.has_key('Usage'):
566
299
            usage = sections.pop('Usage')
567
300
        else:
568
301
            usage = self._usage()
569
302
 
570
303
        # The header is the purpose and usage
571
304
        result = ""
572
 
        result += gettext(':Purpose: %s\n') % (purpose,)
 
305
        result += ':Purpose: %s\n' % purpose
573
306
        if usage.find('\n') >= 0:
574
 
            result += gettext(':Usage:\n%s\n') % (usage,)
 
307
            result += ':Usage:\n%s\n' % usage
575
308
        else:
576
 
            result += gettext(':Usage:   %s\n') % (usage,)
 
309
            result += ':Usage:   %s\n' % usage
577
310
        result += '\n'
578
311
 
579
312
        # 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)
 
313
        options = option.get_optparser(self.options()).format_option_help()
594
314
        if options.startswith('Options:'):
595
 
            result += gettext(':Options:%s') % (options[len('options:'):],)
 
315
            result += ':' + options
 
316
        elif options.startswith('options:'):
 
317
            # Python 2.4 version of optparse
 
318
            result += ':Options:' + options[len('options:'):]
596
319
        else:
597
320
            result += options
598
321
        result += '\n'
599
322
 
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,)
 
323
        # Add the description, indenting it 2 spaces
 
324
        # to match the indentation of the options
 
325
        if sections.has_key(None):
 
326
            text = sections.pop(None)
 
327
            text = '\n  '.join(text.splitlines())
 
328
            result += ':%s:\n  %s\n\n' % ('Description',text)
607
329
 
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())
 
330
        # Add the custom sections (e.g. Examples). Note that there's no need
 
331
        # to indent these as they must be indented already in the source.
 
332
        if sections:
 
333
            labels = sorted(sections.keys())
 
334
            for label in labels:
 
335
                result += ':%s:\n%s\n\n' % (label,sections[label])
618
336
 
619
337
        # Add the aliases, source (plug-in) and see also links, if any
620
338
        if self.aliases:
621
 
            result += gettext(':Aliases:  ')
 
339
            result += ':Aliases:  '
622
340
            result += ', '.join(self.aliases) + '\n'
623
341
        plugin_name = self.plugin_name()
624
342
        if plugin_name is not None:
625
 
            result += gettext(':From:     plugin "%s"\n') % plugin_name
 
343
            result += ':From:     plugin "%s"\n' % plugin_name
626
344
        see_also = self.get_see_also(additional_see_also)
627
345
        if see_also:
628
346
            if not plain and see_also_as_links:
633
351
                        # so don't create a real link
634
352
                        see_also_links.append(item)
635
353
                    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)
 
354
                        # Use a reST link for this entry
 
355
                        see_also_links.append("`%s`_" % (item,))
640
356
                see_also = see_also_links
641
 
            result += gettext(':See also: %s') % ', '.join(see_also) + '\n'
 
357
            result += ':See also: '
 
358
            result += ', '.join(see_also) + '\n'
642
359
 
643
 
        # If this will be rendered as plain text, convert it
 
360
        # If this will be rendered as plan text, convert it
644
361
        if plain:
645
 
            import breezy.help_topics
646
 
            result = breezy.help_topics.help_as_plain_text(result)
 
362
            import bzrlib.help_topics
 
363
            result = bzrlib.help_topics.help_as_plain_text(result)
647
364
        return result
648
365
 
649
366
    @staticmethod
650
367
    def _get_help_parts(text):
651
368
        """Split help text into a summary and named sections.
652
369
 
653
 
        :return: (summary,sections,order) where summary is the top line and
 
370
        :return: (summary,sections) where summary is the top line and
654
371
            sections is a dictionary of the rest indexed by section name.
655
 
            order is the order the section appear in the text.
656
372
            A section starts with a heading line of the form ":xxx:".
657
373
            Indented text on following lines is the section value.
658
374
            All text found outside a named section is assigned to the
659
375
            default section which is given the key of None.
660
376
        """
661
 
        def save_section(sections, order, label, section):
 
377
        def save_section(sections, label, section):
662
378
            if len(section) > 0:
663
 
                if label in sections:
 
379
                if sections.has_key(label):
664
380
                    sections[label] += '\n' + section
665
381
                else:
666
 
                    order.append(label)
667
382
                    sections[label] = section
668
 
 
 
383
            
669
384
        lines = text.rstrip().splitlines()
670
385
        summary = lines.pop(0)
671
386
        sections = {}
672
 
        order = []
673
 
        label, section = None, ''
 
387
        label,section = None,''
674
388
        for line in lines:
675
389
            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
 
390
                save_section(sections, label, section)
 
391
                label,section = line[1:-1],''
 
392
            elif label != None and len(line) > 1 and not line[0].isspace():
 
393
                save_section(sections, label, section)
 
394
                label,section = None,line
681
395
            else:
682
396
                if len(section) > 0:
683
397
                    section += '\n' + line
684
398
                else:
685
399
                    section = line
686
 
        save_section(sections, order, label, section)
687
 
        return summary, sections, order
 
400
        save_section(sections, label, section)
 
401
        return summary, sections
688
402
 
689
403
    def get_help_topic(self):
690
404
        """Return the commands help topic - its name."""
692
406
 
693
407
    def get_see_also(self, additional_terms=None):
694
408
        """Return a list of help topics that are related to this command.
695
 
 
 
409
        
696
410
        The list is derived from the content of the _see_also attribute. Any
697
411
        duplicates are removed and the result is in lexical order.
698
412
        :param additional_terms: Additional help topics to cross-reference.
708
422
 
709
423
        Maps from long option name to option object."""
710
424
        r = Option.STD_OPTIONS.copy()
711
 
        std_names = set(r)
 
425
        std_names = r.keys()
712
426
        for o in self.takes_options:
713
 
            if isinstance(o, string_types):
 
427
            if isinstance(o, basestring):
714
428
                o = option.Option.OPTIONS[o]
715
429
            r[o.name] = o
716
430
            if o.name in std_names:
719
433
 
720
434
    def _setup_outf(self):
721
435
        """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)
 
436
        assert self.encoding_type in ['strict', 'exact', 'replace']
 
437
 
 
438
        # Originally I was using self.stdout, but that looks
 
439
        # *way* too much like sys.stdout
 
440
        if self.encoding_type == 'exact':
 
441
            # force sys.stdout to be binary stream on win32
 
442
            if sys.platform == 'win32':
 
443
                fileno = getattr(sys.stdout, 'fileno', None)
 
444
                if fileno:
 
445
                    import msvcrt
 
446
                    msvcrt.setmode(fileno(), os.O_BINARY)
 
447
            self.outf = sys.stdout
 
448
            return
 
449
 
 
450
        output_encoding = osutils.get_terminal_encoding()
 
451
 
 
452
        self.outf = codecs.getwriter(output_encoding)(sys.stdout,
 
453
                        errors=self.encoding_type)
 
454
        # For whatever reason codecs.getwriter() does not advertise its encoding
 
455
        # it just returns the encoding of the wrapped file, which is completely
 
456
        # bogus. So set the attribute, so we can find the correct encoding later.
 
457
        self.outf.encoding = output_encoding
724
458
 
725
459
    def run_argv_aliases(self, argv, alias_argv=None):
726
460
        """Parse the command line and run with extra aliases in alias_argv."""
 
461
        if argv is None:
 
462
            warn("Passing None for [] is deprecated from bzrlib 0.10",
 
463
                 DeprecationWarning, stacklevel=2)
 
464
            argv = []
727
465
        args, opts = parse_args(self, argv, alias_argv)
728
 
        self._setup_outf()
729
466
 
730
467
        # 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))
 
468
        if 'help' in opts:  # e.g. bzr add --help
 
469
            sys.stdout.write(self.get_help_text())
736
470
            return 0
737
471
        trace.set_verbosity_level(option._verbosity_level)
738
472
        if 'verbose' in self.supported_std_options:
739
473
            opts['verbose'] = trace.is_verbose()
740
 
        elif 'verbose' in opts:
 
474
        elif opts.has_key('verbose'):
741
475
            del opts['verbose']
742
476
        if 'quiet' in self.supported_std_options:
743
477
            opts['quiet'] = trace.is_quiet()
744
 
        elif 'quiet' in opts:
 
478
        elif opts.has_key('quiet'):
745
479
            del opts['quiet']
 
480
 
746
481
        # mix arguments and options into one dictionary
747
482
        cmdargs = _match_argform(self.name(), self.takes_args, args)
748
483
        cmdopts = {}
752
487
        all_cmd_args = cmdargs.copy()
753
488
        all_cmd_args.update(cmdopts)
754
489
 
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
 
 
 
490
        self._setup_outf()
 
491
 
 
492
        return self.run(**all_cmd_args)
 
493
    
787
494
    def run(self):
788
495
        """Actually run the command.
789
496
 
793
500
        Return 0 or None if the command was successful, or a non-zero
794
501
        shell error code if not.  It's OK for this method to allow
795
502
        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
503
        """
808
504
        raise NotImplementedError('no implementation of command %r'
809
505
                                  % self.name())
815
511
            return None
816
512
        return getdoc(self)
817
513
 
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
514
    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
515
        return _unsquish_command_name(self.__class__.__name__)
832
516
 
833
517
    def plugin_name(self):
835
519
 
836
520
        :return: The name of the plugin or None if the command is builtin.
837
521
        """
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()
 
522
        mod_parts = self.__module__.split('.')
 
523
        if len(mod_parts) >= 3 and mod_parts[1] == 'plugins':
 
524
            return mod_parts[2]
 
525
        else:
 
526
            return None
882
527
 
883
528
 
884
529
def parse_args(command, argv, alias_argv=None):
885
530
    """Parse command line.
886
 
 
 
531
    
887
532
    Arguments and options are parsed at this level before being passed
888
533
    down to specific command handlers.  This routine knows, from a
889
534
    lookup table, something about the available options, what optargs
896
541
    else:
897
542
        args = argv
898
543
 
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)
 
544
    options, args = parser.parse_args(args)
 
545
    opts = dict([(k, v) for k, v in options.__dict__.iteritems() if
 
546
                 v is not option.OptionParser.DEFAULT_VALUE])
909
547
    return args, opts
910
548
 
911
549
 
926
564
                argdict[argname + '_list'] = None
927
565
        elif ap[-1] == '+':
928
566
            if not args:
929
 
                raise errors.BzrCommandError(gettext(
930
 
                      "command {0!r} needs one or more {1}").format(
931
 
                      cmd, argname.upper()))
 
567
                raise errors.BzrCommandError("command %r needs one or more %s"
 
568
                                             % (cmd, argname.upper()))
932
569
            else:
933
570
                argdict[argname + '_list'] = args[:]
934
571
                args = []
935
572
        elif ap[-1] == '$': # all but one
936
573
            if len(args) < 2:
937
 
                raise errors.BzrCommandError(
938
 
                      gettext("command {0!r} needs one or more {1}").format(
939
 
                                             cmd, argname.upper()))
 
574
                raise errors.BzrCommandError("command %r needs one or more %s"
 
575
                                             % (cmd, argname.upper()))
940
576
            argdict[argname + '_list'] = args[:-1]
941
577
            args[:-1] = []
942
578
        else:
943
579
            # just a plain arg
944
580
            argname = ap
945
581
            if not args:
946
 
                raise errors.BzrCommandError(
947
 
                     gettext("command {0!r} requires argument {1}").format(
948
 
                               cmd, argname.upper()))
 
582
                raise errors.BzrCommandError("command %r requires argument %s"
 
583
                               % (cmd, argname.upper()))
949
584
            else:
950
585
                argdict[argname] = args.pop(0)
951
 
 
 
586
            
952
587
    if args:
953
 
        raise errors.BzrCommandError( gettext(
954
 
                              "extra argument to command {0}: {1}").format(
955
 
                                       cmd, args[0]) )
 
588
        raise errors.BzrCommandError("extra argument to command %s: %s"
 
589
                                     % (cmd, args[0]))
956
590
 
957
591
    return argdict
958
592
 
959
593
 
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
594
 
972
595
def apply_profiled(the_callable, *args, **kwargs):
973
596
    import hotshot
977
600
    try:
978
601
        prof = hotshot.Profile(pfname)
979
602
        try:
980
 
            ret = prof.runcall(exception_to_return_code, the_callable, *args,
981
 
                **kwargs) or 0
 
603
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
982
604
        finally:
983
605
            prof.close()
984
606
        stats = hotshot.stats.load(pfname)
993
615
        os.remove(pfname)
994
616
 
995
617
 
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
618
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)
 
619
    from bzrlib.lsprof import profile
 
620
    ret, stats = profile(the_callable, *args, **kwargs)
1021
621
    stats.sort()
1022
622
    if filename is None:
1023
623
        stats.pprint()
1024
624
    else:
1025
625
        stats.save(filename)
1026
 
        trace.note(gettext('Profile data written to "%s".'), filename)
 
626
        trace.note('Profile data written to "%s".', filename)
1027
627
    return ret
1028
628
 
1029
629
 
1038
638
        If it is unspecified, the global config will be used.
1039
639
    """
1040
640
    if config is None:
1041
 
        import breezy.config
1042
 
        config = breezy.config.GlobalConfig()
 
641
        import bzrlib.config
 
642
        config = bzrlib.config.GlobalConfig()
1043
643
    alias = config.get_alias(cmd)
1044
644
    if (alias):
1045
 
        return cmdline.split(alias)
 
645
        import shlex
 
646
        return [a.decode('utf-8') for a in shlex.split(alias.encode('utf-8'))]
1046
647
    return None
1047
648
 
1048
649
 
1049
 
def run_bzr(argv, load_plugins=load_plugins, disable_plugins=disable_plugins):
 
650
def run_bzr(argv):
1050
651
    """Execute a command.
1051
652
 
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.
 
653
    This is similar to main(), but without all the trappings for
 
654
    logging and error handling.  
 
655
    
 
656
    argv
 
657
       The command-line arguments, without the program name from argv[0]
 
658
       These should already be decoded. All library/test code calling
 
659
       run_bzr should be passing valid strings (don't need decoding).
 
660
    
 
661
    Returns a command status or raises an exception.
1064
662
 
1065
663
    Special master options: these must come before the command because
1066
664
    they control how the command is interpreted.
1080
678
 
1081
679
    --lsprof
1082
680
        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
681
    """
1090
 
    trace.mutter("breezy version: " + breezy.__version__)
1091
 
    argv = _specified_or_unicode_argv(argv)
1092
 
    trace.mutter("brz arguments: %r", argv)
 
682
    argv = list(argv)
 
683
    trace.mutter("bzr arguments: %r", argv)
1093
684
 
1094
 
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin = \
1095
 
            opt_coverage = opt_no_l10n = opt_no_aliases = False
 
685
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
 
686
                opt_no_aliases = False
1096
687
    opt_lsprof_file = None
1097
688
 
1098
689
    # --no-plugins is handled specially at a very early stage. We need
1101
692
 
1102
693
    argv_copy = []
1103
694
    i = 0
1104
 
    override_config = []
1105
695
    while i < len(argv):
1106
696
        a = argv[i]
1107
697
        if a == '--profile':
1116
706
            opt_no_plugins = True
1117
707
        elif a == '--no-aliases':
1118
708
            opt_no_aliases = True
1119
 
        elif a == '--no-l10n':
1120
 
            opt_no_l10n = True
1121
709
        elif a == '--builtin':
1122
710
            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
1130
711
        elif a.startswith('-D'):
1131
712
            debug.debug_flags.add(a[2:])
1132
 
        elif a.startswith('-O'):
1133
 
            override_config.append(a[2:])
1134
713
        else:
1135
714
            argv_copy.append(a)
1136
715
        i += 1
1137
716
 
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
 
 
 
717
    argv = argv_copy
 
718
    if (not argv):
 
719
        from bzrlib.builtins import cmd_help
 
720
        cmd_help().run_argv_aliases([])
 
721
        return 0
 
722
 
 
723
    if argv[0] == '--version':
 
724
        from bzrlib.builtins import cmd_version
 
725
        cmd_version().run_argv_aliases([])
 
726
        return 0
 
727
        
1143
728
    if not opt_no_plugins:
 
729
        from bzrlib.plugin import load_plugins
1144
730
        load_plugins()
1145
731
    else:
 
732
        from bzrlib.plugin import disable_plugins
1146
733
        disable_plugins()
1147
734
 
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
735
    alias_argv = None
1158
736
 
1159
737
    if not opt_no_aliases:
1160
738
        alias_argv = get_alias(argv[0])
1161
739
        if alias_argv:
 
740
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
1162
741
            argv[0] = alias_argv.pop(0)
1163
742
 
1164
743
    cmd = argv.pop(0)
 
744
    # We want only 'ascii' command names, but the user may have typed
 
745
    # in a Unicode name. In that case, they should just get a
 
746
    # 'command not found' error later.
 
747
 
1165
748
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
1166
 
    if opt_no_l10n:
1167
 
        cmd_obj.l10n = False
1168
749
    run = cmd_obj.run_argv_aliases
1169
750
    run_argv = [argv, alias_argv]
1170
751
 
1171
752
    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
753
        if opt_lsprof:
1177
 
            if opt_coverage:
1178
 
                trace.warning(
1179
 
                    '--coverage ignored, because --lsprof is in use.')
1180
754
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
1181
755
        elif opt_profile:
1182
 
            if opt_coverage:
1183
 
                trace.warning(
1184
 
                    '--coverage ignored, because --profile is in use.')
1185
756
            ret = apply_profiled(run, *run_argv)
1186
 
        elif opt_coverage:
1187
 
            ret = apply_coveraged(run, *run_argv)
1188
757
        else:
1189
758
            ret = run(*run_argv)
1190
759
        return ret or 0
1191
760
    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
 
 
 
761
        # reset, in case we may do other commands later within the same process
 
762
        option._verbosity_level = 0
1201
763
 
1202
764
def display_command(func):
1203
765
    """Decorator that suppresses pipe/interrupt errors."""
1206
768
            result = func(*args, **kwargs)
1207
769
            sys.stdout.flush()
1208
770
            return result
1209
 
        except IOError as e:
 
771
        except IOError, e:
1210
772
            if getattr(e, 'errno', None) is None:
1211
773
                raise
1212
774
            if e.errno != errno.EPIPE:
1219
781
    return ignore_pipe
1220
782
 
1221
783
 
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 = []
 
784
def main(argv):
 
785
    import bzrlib.ui
 
786
    from bzrlib.ui.text import TextUIFactory
 
787
    bzrlib.ui.ui_factory = TextUIFactory()
1246
788
    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()
 
789
        argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
 
790
    except UnicodeDecodeError:
 
791
        raise errors.BzrError(("Parameter '%r' is unsupported by the current "
 
792
                                                            "encoding." % a))
1275
793
    ret = run_bzr_catch_errors(argv)
1276
794
    trace.mutter("return code %d", ret)
1277
795
    return ret
1278
796
 
1279
797
 
1280
798
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)
 
799
    # Note: The except clause logic below should be kept in sync with the
 
800
    # profile() routine in lsprof.py.
 
801
    try:
 
802
        return run_bzr(argv)
 
803
    except (KeyboardInterrupt, Exception), e:
 
804
        # used to handle AssertionError and KeyboardInterrupt
 
805
        # specially here, but hopefully they're handled ok by the logger now
 
806
        exitcode = trace.report_exception(sys.exc_info(), sys.stderr)
 
807
        if os.environ.get('BZR_PDB'):
 
808
            print '**** entering debugger'
 
809
            import pdb
 
810
            pdb.post_mortem(sys.exc_traceback)
 
811
        return exitcode
1289
812
 
1290
813
 
1291
814
def run_bzr_catch_user_errors(argv):
1292
 
    """Run brz and report user errors, but let internal errors propagate.
 
815
    """Run bzr and report user errors, but let internal errors propagate.
1293
816
 
1294
817
    This is used for the test suite, and might be useful for other programs
1295
818
    that want to wrap the commandline interface.
1296
819
    """
1297
 
    # done here so that they're covered for every test run
1298
 
    install_bzr_command_hooks()
1299
820
    try:
1300
821
        return run_bzr(argv)
1301
 
    except Exception as e:
 
822
    except Exception, e:
1302
823
        if (isinstance(e, (OSError, IOError))
1303
824
            or not getattr(e, 'internal_error', True)):
1304
825
            trace.report_exception(sys.exc_info(), sys.stderr)
1323
844
        if topic and topic.startswith(self.prefix):
1324
845
            topic = topic[len(self.prefix):]
1325
846
        try:
1326
 
            cmd = _get_cmd_object(topic, check_missing=False)
 
847
            cmd = _get_cmd_object(topic)
1327
848
        except KeyError:
1328
849
            return []
1329
850
        else:
1330
851
            return [cmd]
1331
852
 
1332
853
 
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()
 
854
if __name__ == '__main__':
 
855
    sys.exit(main(sys.argv))