/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] robertc's integration, updated tests to check for retcode=3

Show diffs side-by-side

added added

removed removed

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