/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: John Arbash Meinel
  • Date: 2006-04-25 15:05:42 UTC
  • mfrom: (1185.85.85 bzr-encoding)
  • mto: This revision was merged to the branch mainline in revision 1752.
  • Revision ID: john@arbash-meinel.com-20060425150542-c7b518dca9928691
[merge] the old bzr-encoding changes, reparenting them on bzr.dev

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005-2011 Canonical Ltd
 
1
# Copyright (C) 2006 by 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
 
 
31
import sys
26
32
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(), """
 
33
from warnings import warn
37
34
import errno
38
 
 
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
 
35
import codecs
 
36
 
 
37
import bzrlib
 
38
from bzrlib.errors import (BzrError,
 
39
                           BzrCheckError,
 
40
                           BzrCommandError,
 
41
                           BzrOptionError,
 
42
                           NotBranchError)
 
43
from bzrlib.option import Option
 
44
from bzrlib.revisionspec import RevisionSpec
 
45
from bzrlib.symbol_versioning import *
 
46
import bzrlib.trace
 
47
from bzrlib.trace import mutter, note, log_error, warning, be_quiet
 
48
 
 
49
plugin_cmds = {}
174
50
 
175
51
 
176
52
def register_command(cmd, decorate=False):
177
 
    """Register a plugin command.
 
53
    """Utility function to help register a command
178
54
 
179
 
    Should generally be avoided in favor of lazy registration.
 
55
    :param cmd: Command subclass to register
 
56
    :param decorate: If true, allow overriding an existing command
 
57
        of the same name; the old command is returned by this function.
 
58
        Otherwise it is an error to try to override an existing command.
180
59
    """
181
60
    global plugin_cmds
182
 
    return plugin_cmds.register(cmd, decorate)
 
61
    k = cmd.__name__
 
62
    if k.startswith("cmd_"):
 
63
        k_unsquished = _unsquish_command_name(k)
 
64
    else:
 
65
        k_unsquished = k
 
66
    if not plugin_cmds.has_key(k_unsquished):
 
67
        plugin_cmds[k_unsquished] = cmd
 
68
        mutter('registered plugin command %s', k_unsquished)
 
69
        if decorate and k_unsquished in builtin_command_names():
 
70
            return _builtin_commands()[k_unsquished]
 
71
    elif decorate:
 
72
        result = plugin_cmds[k_unsquished]
 
73
        plugin_cmds[k_unsquished] = cmd
 
74
        return result
 
75
    else:
 
76
        log_error('Two plugins defined the same command: %r' % k)
 
77
        log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
183
78
 
184
79
 
185
80
def _squish_command_name(cmd):
187
82
 
188
83
 
189
84
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:
 
85
    assert cmd.startswith("cmd_")
 
86
    return cmd[4:].replace('_','-')
 
87
 
 
88
 
 
89
def _builtin_commands():
 
90
    import bzrlib.builtins
 
91
    r = {}
 
92
    builtins = bzrlib.builtins.__dict__
 
93
    for name in builtins:
206
94
        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
 
 
 
95
            real_name = _unsquish_command_name(name)
 
96
            r[real_name] = builtins[name]
 
97
    return r
 
98
            
232
99
 
233
100
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
 
 
 
101
    """Return list of builtin command names."""
 
102
    return _builtin_commands().keys()
 
103
    
242
104
 
243
105
def plugin_command_names():
244
 
    """Returns command names from commands registered by plugins."""
245
106
    return plugin_cmds.keys()
246
107
 
247
108
 
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
 
109
def _get_cmd_dict(plugins_override=True):
 
110
    """Return name->class mapping for all commands."""
 
111
    d = _builtin_commands()
 
112
    if plugins_override:
 
113
        d.update(plugin_cmds)
 
114
    return d
 
115
 
 
116
    
 
117
def get_all_cmds(plugins_override=True):
 
118
    """Return canonical name and class for all registered commands."""
 
119
    for k, v in _get_cmd_dict(plugins_override=plugins_override).iteritems():
 
120
        yield k,v
292
121
 
293
122
 
294
123
def get_cmd_object(cmd_name, plugins_override=True):
295
 
    """Return the command object for a command.
 
124
    """Return the canonical name and command class for a command.
296
125
 
297
126
    plugins_override
298
127
        If true, plugin commands can override builtins.
299
128
    """
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
 
129
    from bzrlib.externalcommand import ExternalCommand
 
130
 
 
131
    cmd_name = str(cmd_name)            # not unicode
 
132
 
 
133
    # first look up this command under the specified name
 
134
    cmds = _get_cmd_dict(plugins_override=plugins_override)
 
135
    try:
 
136
        return cmds[cmd_name]()
 
137
    except KeyError:
 
138
        pass
 
139
 
 
140
    # look for any command which claims this as an alias
 
141
    for real_cmd_name, cmd_class in cmds.iteritems():
 
142
        if cmd_name in cmd_class.aliases:
 
143
            return cmd_class()
 
144
 
397
145
    cmd_obj = ExternalCommand.find_command(cmd_name)
398
146
    if cmd_obj:
399
147
        return cmd_obj
400
148
 
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
 
149
    raise BzrCommandError("unknown command %r" % cmd_name)
413
150
 
414
151
 
415
152
class Command(object):
416
153
    """Base class for commands.
417
154
 
418
 
    Commands are the heart of the command-line brz interface.
 
155
    Commands are the heart of the command-line bzr interface.
419
156
 
420
157
    The command object mostly handles the mapping of command-line
421
 
    parameters into one or more breezy operations, and of the results
 
158
    parameters into one or more bzrlib operations, and of the results
422
159
    into textual output.
423
160
 
424
161
    Commands normally don't have any state.  All their arguments are
430
167
    summary, then a complete description of the command.  A grammar
431
168
    description will be inserted.
432
169
 
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
 
170
    aliases
 
171
        Other accepted names for this command.
 
172
 
 
173
    takes_args
 
174
        List of argument forms, marked with whether they are optional,
 
175
        repeated, etc.
 
176
 
 
177
                Examples:
 
178
 
 
179
                ['to_location', 'from_branch?', 'file*']
 
180
 
 
181
                'to_location' is required
 
182
                'from_branch' is optional
 
183
                'file' can be specified 0 or more times
 
184
 
 
185
    takes_options
 
186
        List of options that may be given for this command.  These can
 
187
        be either strings, referring to globally-defined options,
 
188
        or option objects.  Retrieve through options().
 
189
 
 
190
    hidden
 
191
        If true, this command isn't advertised.  This is typically
449
192
        for commands intended for expert users.
450
193
 
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"
 
194
    encoding_type
 
195
        Command objects will get a 'outf' attribute, which has been
 
196
        setup to properly handle encoding of unicode strings.
 
197
        encoding_type determines what will happen when characters cannot
 
198
        be encoded
 
199
            strict - abort if we cannot decode
 
200
            replace - put in a bogus character (typically '?')
 
201
            exact - do not encode sys.stdout
 
202
 
478
203
    """
479
204
    aliases = []
480
205
    takes_args = []
481
206
    takes_options = []
482
207
    encoding_type = 'strict'
483
 
    invoked_as = None
484
 
    l10n = True
485
208
 
486
209
    hidden = False
487
 
 
 
210
    
488
211
    def __init__(self):
489
212
        """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)
 
213
        if self.__doc__ == Command.__doc__:
 
214
            warn("No help message set for %r" % self)
711
215
 
712
216
    def options(self):
713
217
        """Return dict of valid options for this command.
714
218
 
715
219
        Maps from long option name to option object."""
716
 
        r = Option.STD_OPTIONS.copy()
717
 
        std_names = set(r)
 
220
        r = dict()
 
221
        r['help'] = Option.OPTIONS['help']
718
222
        for o in self.takes_options:
719
 
            if isinstance(o, string_types):
720
 
                o = option.Option.OPTIONS[o]
 
223
            if not isinstance(o, Option):
 
224
                o = Option.OPTIONS[o]
721
225
            r[o.name] = o
722
 
            if o.name in std_names:
723
 
                self.supported_std_options.append(o.name)
724
226
        return r
725
227
 
726
 
    def _setup_outf(self):
 
228
    def _setup_stdout(self):
727
229
        """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)
 
230
        assert self.encoding_type in ['strict', 'exact', 'replace']
 
231
 
 
232
        # Originally I was using self.stdout, but that looks
 
233
        # *way* too much like sys.stdout
 
234
        if self.encoding_type == 'exact':
 
235
            self.outf = sys.stdout
 
236
            return
 
237
 
 
238
        output_encoding = getattr(sys.stdout, 'encoding', None)
 
239
        if not output_encoding:
 
240
            output_encoding = bzrlib.user_encoding
 
241
            mutter('encoding stdout bzrlib.user_encoding %r', output_encoding)
 
242
        else:
 
243
            mutter('encoding stdout log as sys.stdout encoding %r', output_encoding)
 
244
 
 
245
        # use 'replace' so that we don't abort if trying to write out
 
246
        # in e.g. the default C locale.
 
247
        self.outf = codecs.getwriter(output_encoding)(sys.stdout, errors=self.encoding_type)
 
248
 
 
249
    @deprecated_method(zero_eight)
 
250
    def run_argv(self, argv):
 
251
        """Parse command line and run.
 
252
        
 
253
        See run_argv_aliases for the 0.8 and beyond api.
 
254
        """
 
255
        return self.run_argv_aliases(argv)
730
256
 
731
257
    def run_argv_aliases(self, argv, alias_argv=None):
732
258
        """Parse the command line and run with extra aliases in alias_argv."""
733
259
        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']
 
260
        if 'help' in opts:  # e.g. bzr add --help
 
261
            from bzrlib.help import help_on_command
 
262
            help_on_command(self.name())
 
263
            return 0
 
264
        # XXX: This should be handled by the parser
 
265
        allowed_names = self.options().keys()
 
266
        for oname in opts:
 
267
            if oname not in allowed_names:
 
268
                raise BzrCommandError("option '--%s' is not allowed for"
 
269
                                      " command %r" % (oname, self.name()))
752
270
        # mix arguments and options into one dictionary
753
271
        cmdargs = _match_argform(self.name(), self.takes_args, args)
754
272
        cmdopts = {}
758
276
        all_cmd_args = cmdargs.copy()
759
277
        all_cmd_args.update(cmdopts)
760
278
 
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
 
 
 
279
        self._setup_stdout()
 
280
 
 
281
        return self.run(**all_cmd_args)
 
282
    
793
283
    def run(self):
794
284
        """Actually run the command.
795
285
 
799
289
        Return 0 or None if the command was successful, or a non-zero
800
290
        shell error code if not.  It's OK for this method to allow
801
291
        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
292
        """
814
 
        raise NotImplementedError('no implementation of command %r'
 
293
        raise NotImplementedError('no implementation of command %r' 
815
294
                                  % self.name())
816
295
 
817
296
    def help(self):
821
300
            return None
822
301
        return getdoc(self)
823
302
 
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
303
    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
304
        return _unsquish_command_name(self.__class__.__name__)
838
305
 
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
 
 
 
306
 
 
307
def parse_spec(spec):
 
308
    """
 
309
    >>> parse_spec(None)
 
310
    [None, None]
 
311
    >>> parse_spec("./")
 
312
    ['./', None]
 
313
    >>> parse_spec("../@")
 
314
    ['..', -1]
 
315
    >>> parse_spec("../f/@35")
 
316
    ['../f', 35]
 
317
    >>> parse_spec('./@revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67')
 
318
    ['.', 'revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67']
 
319
    """
 
320
    if spec is None:
 
321
        return [None, None]
 
322
    if '/@' in spec:
 
323
        parsed = spec.split('/@')
 
324
        assert len(parsed) == 2
 
325
        if parsed[1] == "":
 
326
            parsed[1] = -1
 
327
        else:
 
328
            try:
 
329
                parsed[1] = int(parsed[1])
 
330
            except ValueError:
 
331
                pass # We can allow stuff like ./@revid:blahblahblah
 
332
            else:
 
333
                assert parsed[1] >=0
 
334
    else:
 
335
        parsed = [spec, None]
 
336
    return parsed
896
337
 
897
338
def parse_args(command, argv, alias_argv=None):
898
339
    """Parse command line.
899
 
 
 
340
    
900
341
    Arguments and options are parsed at this level before being passed
901
342
    down to specific command handlers.  This routine knows, from a
902
343
    lookup table, something about the available options, what optargs
903
344
    they take, and which commands will accept them.
904
345
    """
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)
 
346
    # TODO: chop up this beast; make it a method of the Command
 
347
    args = []
 
348
    opts = {}
 
349
    alias_opts = {}
 
350
 
 
351
    cmd_options = command.options()
 
352
    argsover = False
 
353
    proc_aliasarg = True # Are we processing alias_argv now?
 
354
    for proc_argv in alias_argv, argv:
 
355
        while proc_argv:
 
356
            a = proc_argv.pop(0)
 
357
            if argsover:
 
358
                args.append(a)
 
359
                continue
 
360
            elif a == '--':
 
361
                # We've received a standalone -- No more flags
 
362
                argsover = True
 
363
                continue
 
364
            if a[0] == '-':
 
365
                # option names must not be unicode
 
366
                a = str(a)
 
367
                optarg = None
 
368
                if a[1] == '-':
 
369
                    mutter("  got option %r", a)
 
370
                    if '=' in a:
 
371
                        optname, optarg = a[2:].split('=', 1)
 
372
                    else:
 
373
                        optname = a[2:]
 
374
                    if optname not in cmd_options:
 
375
                        raise BzrOptionError('unknown long option %r for'
 
376
                                             ' command %s' % 
 
377
                                             (a, command.name()))
 
378
                else:
 
379
                    shortopt = a[1:]
 
380
                    if shortopt in Option.SHORT_OPTIONS:
 
381
                        # Multi-character options must have a space to delimit
 
382
                        # their value
 
383
                        # ^^^ what does this mean? mbp 20051014
 
384
                        optname = Option.SHORT_OPTIONS[shortopt].name
 
385
                    else:
 
386
                        # Single character short options, can be chained,
 
387
                        # and have their value appended to their name
 
388
                        shortopt = a[1:2]
 
389
                        if shortopt not in Option.SHORT_OPTIONS:
 
390
                            # We didn't find the multi-character name, and we
 
391
                            # didn't find the single char name
 
392
                            raise BzrError('unknown short option %r' % a)
 
393
                        optname = Option.SHORT_OPTIONS[shortopt].name
 
394
 
 
395
                        if a[2:]:
 
396
                            # There are extra things on this option
 
397
                            # see if it is the value, or if it is another
 
398
                            # short option
 
399
                            optargfn = Option.OPTIONS[optname].type
 
400
                            if optargfn is None:
 
401
                                # This option does not take an argument, so the
 
402
                                # next entry is another short option, pack it
 
403
                                # back into the list
 
404
                                proc_argv.insert(0, '-' + a[2:])
 
405
                            else:
 
406
                                # This option takes an argument, so pack it
 
407
                                # into the array
 
408
                                optarg = a[2:]
 
409
                
 
410
                    if optname not in cmd_options:
 
411
                        raise BzrOptionError('unknown short option %r for'
 
412
                                             ' command %s' % 
 
413
                                             (shortopt, command.name()))
 
414
                if optname in opts:
 
415
                    # XXX: Do we ever want to support this, e.g. for -r?
 
416
                    if proc_aliasarg:
 
417
                        raise BzrError('repeated option %r' % a)
 
418
                    elif optname in alias_opts:
 
419
                        # Replace what's in the alias with what's in the real
 
420
                        # argument
 
421
                        del alias_opts[optname]
 
422
                        del opts[optname]
 
423
                        proc_argv.insert(0, a)
 
424
                        continue
 
425
                    else:
 
426
                        raise BzrError('repeated option %r' % a)
 
427
                    
 
428
                option_obj = cmd_options[optname]
 
429
                optargfn = option_obj.type
 
430
                if optargfn:
 
431
                    if optarg == None:
 
432
                        if not proc_argv:
 
433
                            raise BzrError('option %r needs an argument' % a)
 
434
                        else:
 
435
                            optarg = proc_argv.pop(0)
 
436
                    opts[optname] = optargfn(optarg)
 
437
                    if proc_aliasarg:
 
438
                        alias_opts[optname] = optargfn(optarg)
 
439
                else:
 
440
                    if optarg != None:
 
441
                        raise BzrError('option %r takes no argument' % optname)
 
442
                    opts[optname] = True
 
443
                    if proc_aliasarg:
 
444
                        alias_opts[optname] = True
 
445
            else:
 
446
                args.append(a)
 
447
        proc_aliasarg = False # Done with alias argv
923
448
    return args, opts
924
449
 
925
450
 
932
457
        if ap[-1] == '?':
933
458
            if args:
934
459
                argdict[argname] = args.pop(0)
935
 
        elif ap[-1] == '*':  # all remaining arguments
 
460
        elif ap[-1] == '*': # all remaining arguments
936
461
            if args:
937
462
                argdict[argname + '_list'] = args[:]
938
463
                args = []
940
465
                argdict[argname + '_list'] = None
941
466
        elif ap[-1] == '+':
942
467
            if not args:
943
 
                raise errors.BzrCommandError(gettext(
944
 
                    "command {0!r} needs one or more {1}").format(
945
 
                    cmd, argname.upper()))
 
468
                raise BzrCommandError("command %r needs one or more %s"
 
469
                        % (cmd, argname.upper()))
946
470
            else:
947
471
                argdict[argname + '_list'] = args[:]
948
472
                args = []
949
 
        elif ap[-1] == '$':  # all but one
 
473
        elif ap[-1] == '$': # all but one
950
474
            if len(args) < 2:
951
 
                raise errors.BzrCommandError(
952
 
                    gettext("command {0!r} needs one or more {1}").format(
953
 
                        cmd, argname.upper()))
 
475
                raise BzrCommandError("command %r needs one or more %s"
 
476
                        % (cmd, argname.upper()))
954
477
            argdict[argname + '_list'] = args[:-1]
955
 
            args[:-1] = []
 
478
            args[:-1] = []                
956
479
        else:
957
480
            # just a plain arg
958
481
            argname = ap
959
482
            if not args:
960
 
                raise errors.BzrCommandError(
961
 
                    gettext("command {0!r} requires argument {1}").format(
962
 
                        cmd, argname.upper()))
 
483
                raise BzrCommandError("command %r requires argument %s"
 
484
                        % (cmd, argname.upper()))
963
485
            else:
964
486
                argdict[argname] = args.pop(0)
965
 
 
 
487
            
966
488
    if args:
967
 
        raise errors.BzrCommandError(gettext(
968
 
            "extra argument to command {0}: {1}").format(
969
 
            cmd, args[0]))
 
489
        raise BzrCommandError("extra argument to command %s: %s"
 
490
                              % (cmd, args[0]))
970
491
 
971
492
    return argdict
972
493
 
973
494
 
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
495
 
990
496
def apply_profiled(the_callable, *args, **kwargs):
991
497
    import hotshot
995
501
    try:
996
502
        prof = hotshot.Profile(pfname)
997
503
        try:
998
 
            ret = prof.runcall(exception_to_return_code, the_callable, *args,
999
 
                               **kwargs) or 0
 
504
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
1000
505
        finally:
1001
506
            prof.close()
1002
507
        stats = hotshot.stats.load(pfname)
1003
508
        stats.strip_dirs()
1004
509
        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
 
510
        ## XXX: Might like to write to stderr or the trace file instead but
 
511
        ## print_stats seems hardcoded to stdout
1007
512
        stats.print_stats(20)
1008
513
        return ret
1009
514
    finally:
1011
516
        os.remove(pfname)
1012
517
 
1013
518
 
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
519
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)
 
520
    from bzrlib.lsprof import profile
 
521
    import cPickle
 
522
    ret, stats = profile(the_callable, *args, **kwargs)
1039
523
    stats.sort()
1040
524
    if filename is None:
1041
525
        stats.pprint()
1042
526
    else:
1043
 
        stats.save(filename)
1044
 
        trace.note(gettext('Profile data written to "%s".'), filename)
 
527
        stats.freeze()
 
528
        cPickle.dump(stats, open(filename, 'w'), 2)
 
529
        print 'Profile data written to %r.' % filename
1045
530
    return ret
1046
531
 
1047
532
 
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)
 
533
def get_alias(cmd):
 
534
    """Return an expanded alias, or None if no alias exists"""
 
535
    import bzrlib.config
 
536
    alias = bzrlib.config.GlobalConfig().get_alias(cmd)
1062
537
    if (alias):
1063
 
        return cmdline.split(alias)
 
538
        return alias.split(' ')
1064
539
    return None
1065
540
 
1066
541
 
1067
 
def run_bzr(argv, load_plugins=load_plugins, disable_plugins=disable_plugins):
 
542
def run_bzr(argv):
1068
543
    """Execute a command.
1069
544
 
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.
 
545
    This is similar to main(), but without all the trappings for
 
546
    logging and error handling.  
 
547
    
 
548
    argv
 
549
       The command-line arguments, without the program name from argv[0]
 
550
       These should already be decoded. All library/test code calling
 
551
       run_bzr should be passing valid strings (don't need decoding).
 
552
    
 
553
    Returns a command status or raises an exception.
1082
554
 
1083
555
    Special master options: these must come before the command because
1084
556
    they control how the command is interpreted.
1098
570
 
1099
571
    --lsprof
1100
572
        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).
1108
573
    """
1109
 
    trace.mutter("breezy version: " + breezy.__version__)
1110
 
    argv = _specified_or_unicode_argv(argv)
1111
 
    trace.mutter("brz arguments: %r", argv)
 
574
    argv = list(argv)
1112
575
 
1113
 
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin = \
1114
 
        opt_coverage = opt_no_l10n = opt_no_aliases = False
 
576
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
 
577
                opt_no_aliases = False
1115
578
    opt_lsprof_file = None
1116
579
 
1117
580
    # --no-plugins is handled specially at a very early stage. We need
1120
583
 
1121
584
    argv_copy = []
1122
585
    i = 0
1123
 
    override_config = []
1124
586
    while i < len(argv):
1125
587
        a = argv[i]
1126
588
        if a == '--profile':
1128
590
        elif a == '--lsprof':
1129
591
            opt_lsprof = True
1130
592
        elif a == '--lsprof-file':
1131
 
            opt_lsprof = True
1132
593
            opt_lsprof_file = argv[i + 1]
1133
594
            i += 1
1134
595
        elif a == '--no-plugins':
1135
596
            opt_no_plugins = True
1136
597
        elif a == '--no-aliases':
1137
598
            opt_no_aliases = True
1138
 
        elif a == '--no-l10n':
1139
 
            opt_no_l10n = True
1140
599
        elif a == '--builtin':
1141
600
            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:])
 
601
        elif a in ('--quiet', '-q'):
 
602
            be_quiet()
1153
603
        else:
1154
604
            argv_copy.append(a)
1155
605
        i += 1
1156
606
 
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
 
 
 
607
    argv = argv_copy
 
608
    if (not argv):
 
609
        from bzrlib.builtins import cmd_help
 
610
        cmd_help().run_argv_aliases([])
 
611
        return 0
 
612
 
 
613
    if argv[0] == '--version':
 
614
        from bzrlib.builtins import show_version
 
615
        show_version()
 
616
        return 0
 
617
        
1162
618
    if not opt_no_plugins:
 
619
        from bzrlib.plugin import load_plugins
1163
620
        load_plugins()
1164
621
    else:
 
622
        from bzrlib.plugin import disable_plugins
1165
623
        disable_plugins()
1166
624
 
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
625
    alias_argv = None
1177
626
 
1178
627
    if not opt_no_aliases:
1179
628
        alias_argv = get_alias(argv[0])
1180
629
        if alias_argv:
 
630
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
1181
631
            argv[0] = alias_argv.pop(0)
1182
632
 
1183
 
    cmd = argv.pop(0)
 
633
    cmd = str(argv.pop(0))
 
634
 
1184
635
    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]
 
636
    if not getattr(cmd_obj.run_argv, 'is_deprecated', False):
 
637
        run = cmd_obj.run_argv
 
638
        run_argv = [argv]
 
639
    else:
 
640
        run = cmd_obj.run_argv_aliases
 
641
        run_argv = [argv, alias_argv]
1189
642
 
1190
643
    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
644
        if opt_lsprof:
1196
 
            if opt_coverage:
1197
 
                trace.warning(
1198
 
                    '--coverage ignored, because --lsprof is in use.')
1199
645
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
1200
646
        elif opt_profile:
1201
 
            if opt_coverage:
1202
 
                trace.warning(
1203
 
                    '--coverage ignored, because --profile is in use.')
1204
647
            ret = apply_profiled(run, *run_argv)
1205
 
        elif opt_coverage:
1206
 
            ret = apply_coveraged(run, *run_argv)
1207
648
        else:
1208
649
            ret = run(*run_argv)
1209
650
        return ret or 0
1210
651
    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
 
 
 
652
        # reset, in case we may do other commands later within the same process
 
653
        be_quiet(False)
1220
654
 
1221
655
def display_command(func):
1222
656
    """Decorator that suppresses pipe/interrupt errors."""
1225
659
            result = func(*args, **kwargs)
1226
660
            sys.stdout.flush()
1227
661
            return result
1228
 
        except IOError as e:
1229
 
            if getattr(e, 'errno', None) is None:
 
662
        except IOError, e:
 
663
            if not hasattr(e, 'errno'):
1230
664
                raise
1231
665
            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
 
666
                raise
1235
667
            pass
1236
668
        except KeyboardInterrupt:
1237
669
            pass
1238
670
    return ignore_pipe
1239
671
 
1240
672
 
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()
 
673
def main(argv):
 
674
    import bzrlib.ui
 
675
    from bzrlib.ui.text import TextUIFactory
 
676
    ## bzrlib.trace.enable_default_logging()
 
677
    bzrlib.trace.log_startup(argv)
 
678
    bzrlib.ui.ui_factory = TextUIFactory()
 
679
 
 
680
    argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
1293
681
    ret = run_bzr_catch_errors(argv)
1294
 
    trace.mutter("return code %d", ret)
 
682
    mutter("return code %d", ret)
1295
683
    return ret
1296
684
 
1297
685
 
1298
686
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
687
    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
688
        try:
1345
 
            cmd = _get_cmd_object(topic, check_missing=False)
1346
 
        except KeyError:
1347
 
            return []
 
689
            return run_bzr(argv)
 
690
        finally:
 
691
            # do this here inside the exception wrappers to catch EPIPE
 
692
            sys.stdout.flush()
 
693
    except Exception, e:
 
694
        # used to handle AssertionError and KeyboardInterrupt
 
695
        # specially here, but hopefully they're handled ok by the logger now
 
696
        import errno
 
697
        if (isinstance(e, IOError) 
 
698
            and hasattr(e, 'errno')
 
699
            and e.errno == errno.EPIPE):
 
700
            bzrlib.trace.note('broken pipe')
 
701
            return 3
1348
702
        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()
 
703
            bzrlib.trace.log_exception()
 
704
            if os.environ.get('BZR_PDB'):
 
705
                print '**** entering debugger'
 
706
                import pdb
 
707
                pdb.post_mortem(sys.exc_traceback)
 
708
            return 3
 
709
 
 
710
if __name__ == '__main__':
 
711
    sys.exit(main(sys.argv))