/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: Robert Collins
  • Date: 2006-02-28 04:31:50 UTC
  • mto: This revision was merged to the branch mainline in revision 1583.
  • Revision ID: robertc@robertcollins.net-20060228043150-fdb9c7f7231b271b
Bugfix aliases to be backwards compatible with plugins providing command.run_argv.

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
from bzrlib.errors import (BzrError, 
 
38
                           BzrCheckError,
 
39
                           BzrCommandError,
 
40
                           BzrOptionError,
 
41
                           NotBranchError)
 
42
from bzrlib.option import Option
 
43
from bzrlib.revisionspec import RevisionSpec
 
44
from bzrlib.symbol_versioning import *
 
45
import bzrlib.trace
 
46
from bzrlib.trace import mutter, note, log_error, warning, be_quiet
 
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
                Examples:
 
172
 
 
173
                ['to_location', 'from_branch?', 'file*']
 
174
 
 
175
                'to_location' is required
 
176
                'from_branch' is optional
 
177
                'file' can be specified 0 or more times
 
178
 
 
179
    takes_options
 
180
        List of options that may be given for this command.  These can
 
181
        be either strings, referring to globally-defined options,
 
182
        or option objects.  Retrieve through options().
 
183
 
 
184
    hidden
 
185
        If true, this command isn't advertised.  This is typically
449
186
        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
187
    """
479
188
    aliases = []
480
189
    takes_args = []
481
190
    takes_options = []
482
 
    encoding_type = 'strict'
483
 
    invoked_as = None
484
 
    l10n = True
485
191
 
486
192
    hidden = False
487
 
 
 
193
    
488
194
    def __init__(self):
489
195
        """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)
 
196
        if self.__doc__ == Command.__doc__:
 
197
            warn("No help message set for %r" % self)
711
198
 
712
199
    def options(self):
713
200
        """Return dict of valid options for this command.
714
201
 
715
202
        Maps from long option name to option object."""
716
 
        r = Option.STD_OPTIONS.copy()
717
 
        std_names = set(r)
 
203
        r = dict()
 
204
        r['help'] = Option.OPTIONS['help']
718
205
        for o in self.takes_options:
719
 
            if isinstance(o, string_types):
720
 
                o = option.Option.OPTIONS[o]
 
206
            if not isinstance(o, Option):
 
207
                o = Option.OPTIONS[o]
721
208
            r[o.name] = o
722
 
            if o.name in std_names:
723
 
                self.supported_std_options.append(o.name)
724
209
        return r
725
210
 
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)
 
211
    @deprecated_method(zero_eight)
 
212
    def run_argv(self, argv):
 
213
        """Parse command line and run.
 
214
        
 
215
        See run_argv_aliases for the 0.8 and beyond api.
 
216
        """
 
217
        return self.run_argv_aliases(argv)
730
218
 
731
219
    def run_argv_aliases(self, argv, alias_argv=None):
732
220
        """Parse the command line and run with extra aliases in alias_argv."""
733
221
        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']
 
222
        if 'help' in opts:  # e.g. bzr add --help
 
223
            from bzrlib.help import help_on_command
 
224
            help_on_command(self.name())
 
225
            return 0
 
226
        # XXX: This should be handled by the parser
 
227
        allowed_names = self.options().keys()
 
228
        for oname in opts:
 
229
            if oname not in allowed_names:
 
230
                raise BzrCommandError("option '--%s' is not allowed for"
 
231
                                      " command %r" % (oname, self.name()))
752
232
        # mix arguments and options into one dictionary
753
233
        cmdargs = _match_argform(self.name(), self.takes_args, args)
754
234
        cmdopts = {}
758
238
        all_cmd_args = cmdargs.copy()
759
239
        all_cmd_args.update(cmdopts)
760
240
 
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
 
 
 
241
        return self.run(**all_cmd_args)
 
242
    
793
243
    def run(self):
794
244
        """Actually run the command.
795
245
 
799
249
        Return 0 or None if the command was successful, or a non-zero
800
250
        shell error code if not.  It's OK for this method to allow
801
251
        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
252
        """
814
 
        raise NotImplementedError('no implementation of command %r'
815
 
                                  % self.name())
 
253
        raise NotImplementedError()
 
254
 
816
255
 
817
256
    def help(self):
818
257
        """Return help message for this class."""
819
 
        from inspect import getdoc
820
258
        if self.__doc__ is Command.__doc__:
821
259
            return None
822
260
        return getdoc(self)
823
261
 
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
262
    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
263
        return _unsquish_command_name(self.__class__.__name__)
838
264
 
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
 
 
 
265
 
 
266
def parse_spec(spec):
 
267
    """
 
268
    >>> parse_spec(None)
 
269
    [None, None]
 
270
    >>> parse_spec("./")
 
271
    ['./', None]
 
272
    >>> parse_spec("../@")
 
273
    ['..', -1]
 
274
    >>> parse_spec("../f/@35")
 
275
    ['../f', 35]
 
276
    >>> parse_spec('./@revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67')
 
277
    ['.', 'revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67']
 
278
    """
 
279
    if spec is None:
 
280
        return [None, None]
 
281
    if '/@' in spec:
 
282
        parsed = spec.split('/@')
 
283
        assert len(parsed) == 2
 
284
        if parsed[1] == "":
 
285
            parsed[1] = -1
 
286
        else:
 
287
            try:
 
288
                parsed[1] = int(parsed[1])
 
289
            except ValueError:
 
290
                pass # We can allow stuff like ./@revid:blahblahblah
 
291
            else:
 
292
                assert parsed[1] >=0
 
293
    else:
 
294
        parsed = [spec, None]
 
295
    return parsed
896
296
 
897
297
def parse_args(command, argv, alias_argv=None):
898
298
    """Parse command line.
899
 
 
 
299
    
900
300
    Arguments and options are parsed at this level before being passed
901
301
    down to specific command handlers.  This routine knows, from a
902
302
    lookup table, something about the available options, what optargs
903
303
    they take, and which commands will accept them.
904
304
    """
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)
 
305
    # TODO: chop up this beast; make it a method of the Command
 
306
    args = []
 
307
    opts = {}
 
308
    alias_opts = {}
 
309
 
 
310
    cmd_options = command.options()
 
311
    argsover = False
 
312
    proc_aliasarg = True # Are we processing alias_argv now?
 
313
    for proc_argv in alias_argv, argv:
 
314
        while proc_argv:
 
315
            a = proc_argv.pop(0)
 
316
            if argsover:
 
317
                args.append(a)
 
318
                continue
 
319
            elif a == '--':
 
320
                # We've received a standalone -- No more flags
 
321
                argsover = True
 
322
                continue
 
323
            if a[0] == '-':
 
324
                # option names must not be unicode
 
325
                a = str(a)
 
326
                optarg = None
 
327
                if a[1] == '-':
 
328
                    mutter("  got option %r", a)
 
329
                    if '=' in a:
 
330
                        optname, optarg = a[2:].split('=', 1)
 
331
                    else:
 
332
                        optname = a[2:]
 
333
                    if optname not in cmd_options:
 
334
                        raise BzrOptionError('unknown long option %r for'
 
335
                                             ' command %s' % 
 
336
                                             (a, command.name()))
 
337
                else:
 
338
                    shortopt = a[1:]
 
339
                    if shortopt in Option.SHORT_OPTIONS:
 
340
                        # Multi-character options must have a space to delimit
 
341
                        # their value
 
342
                        # ^^^ what does this mean? mbp 20051014
 
343
                        optname = Option.SHORT_OPTIONS[shortopt].name
 
344
                    else:
 
345
                        # Single character short options, can be chained,
 
346
                        # and have their value appended to their name
 
347
                        shortopt = a[1:2]
 
348
                        if shortopt not in Option.SHORT_OPTIONS:
 
349
                            # We didn't find the multi-character name, and we
 
350
                            # didn't find the single char name
 
351
                            raise BzrError('unknown short option %r' % a)
 
352
                        optname = Option.SHORT_OPTIONS[shortopt].name
 
353
 
 
354
                        if a[2:]:
 
355
                            # There are extra things on this option
 
356
                            # see if it is the value, or if it is another
 
357
                            # short option
 
358
                            optargfn = Option.OPTIONS[optname].type
 
359
                            if optargfn is None:
 
360
                                # This option does not take an argument, so the
 
361
                                # next entry is another short option, pack it
 
362
                                # back into the list
 
363
                                proc_argv.insert(0, '-' + a[2:])
 
364
                            else:
 
365
                                # This option takes an argument, so pack it
 
366
                                # into the array
 
367
                                optarg = a[2:]
 
368
                
 
369
                    if optname not in cmd_options:
 
370
                        raise BzrOptionError('unknown short option %r for'
 
371
                                             ' command %s' % 
 
372
                                             (shortopt, command.name()))
 
373
                if optname in opts:
 
374
                    # XXX: Do we ever want to support this, e.g. for -r?
 
375
                    if proc_aliasarg:
 
376
                        raise BzrError('repeated option %r' % a)
 
377
                    elif optname in alias_opts:
 
378
                        # Replace what's in the alias with what's in the real
 
379
                        # argument
 
380
                        del alias_opts[optname]
 
381
                        del opts[optname]
 
382
                        proc_argv.insert(0, a)
 
383
                        continue
 
384
                    else:
 
385
                        raise BzrError('repeated option %r' % a)
 
386
                    
 
387
                option_obj = cmd_options[optname]
 
388
                optargfn = option_obj.type
 
389
                if optargfn:
 
390
                    if optarg == None:
 
391
                        if not proc_argv:
 
392
                            raise BzrError('option %r needs an argument' % a)
 
393
                        else:
 
394
                            optarg = proc_argv.pop(0)
 
395
                    opts[optname] = optargfn(optarg)
 
396
                    if proc_aliasarg:
 
397
                        alias_opts[optname] = optargfn(optarg)
 
398
                else:
 
399
                    if optarg != None:
 
400
                        raise BzrError('option %r takes no argument' % optname)
 
401
                    opts[optname] = True
 
402
                    if proc_aliasarg:
 
403
                        alias_opts[optname] = True
 
404
            else:
 
405
                args.append(a)
 
406
        proc_aliasarg = False # Done with alias argv
923
407
    return args, opts
924
408
 
925
409
 
932
416
        if ap[-1] == '?':
933
417
            if args:
934
418
                argdict[argname] = args.pop(0)
935
 
        elif ap[-1] == '*':  # all remaining arguments
 
419
        elif ap[-1] == '*': # all remaining arguments
936
420
            if args:
937
421
                argdict[argname + '_list'] = args[:]
938
422
                args = []
940
424
                argdict[argname + '_list'] = None
941
425
        elif ap[-1] == '+':
942
426
            if not args:
943
 
                raise errors.BzrCommandError(gettext(
944
 
                    "command {0!r} needs one or more {1}").format(
945
 
                    cmd, argname.upper()))
 
427
                raise BzrCommandError("command %r needs one or more %s"
 
428
                        % (cmd, argname.upper()))
946
429
            else:
947
430
                argdict[argname + '_list'] = args[:]
948
431
                args = []
949
 
        elif ap[-1] == '$':  # all but one
 
432
        elif ap[-1] == '$': # all but one
950
433
            if len(args) < 2:
951
 
                raise errors.BzrCommandError(
952
 
                    gettext("command {0!r} needs one or more {1}").format(
953
 
                        cmd, argname.upper()))
 
434
                raise BzrCommandError("command %r needs one or more %s"
 
435
                        % (cmd, argname.upper()))
954
436
            argdict[argname + '_list'] = args[:-1]
955
 
            args[:-1] = []
 
437
            args[:-1] = []                
956
438
        else:
957
439
            # just a plain arg
958
440
            argname = ap
959
441
            if not args:
960
 
                raise errors.BzrCommandError(
961
 
                    gettext("command {0!r} requires argument {1}").format(
962
 
                        cmd, argname.upper()))
 
442
                raise BzrCommandError("command %r requires argument %s"
 
443
                        % (cmd, argname.upper()))
963
444
            else:
964
445
                argdict[argname] = args.pop(0)
965
 
 
 
446
            
966
447
    if args:
967
 
        raise errors.BzrCommandError(gettext(
968
 
            "extra argument to command {0}: {1}").format(
969
 
            cmd, args[0]))
 
448
        raise BzrCommandError("extra argument to command %s: %s"
 
449
                              % (cmd, args[0]))
970
450
 
971
451
    return argdict
972
452
 
973
453
 
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
454
 
990
455
def apply_profiled(the_callable, *args, **kwargs):
991
456
    import hotshot
995
460
    try:
996
461
        prof = hotshot.Profile(pfname)
997
462
        try:
998
 
            ret = prof.runcall(exception_to_return_code, the_callable, *args,
999
 
                               **kwargs) or 0
 
463
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
1000
464
        finally:
1001
465
            prof.close()
1002
466
        stats = hotshot.stats.load(pfname)
1003
467
        stats.strip_dirs()
1004
468
        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
 
469
        ## XXX: Might like to write to stderr or the trace file instead but
 
470
        ## print_stats seems hardcoded to stdout
1007
471
        stats.print_stats(20)
1008
472
        return ret
1009
473
    finally:
1011
475
        os.remove(pfname)
1012
476
 
1013
477
 
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
478
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)
 
479
    from bzrlib.lsprof import profile
 
480
    import cPickle
 
481
    ret, stats = profile(the_callable, *args, **kwargs)
1039
482
    stats.sort()
1040
483
    if filename is None:
1041
484
        stats.pprint()
1042
485
    else:
1043
 
        stats.save(filename)
1044
 
        trace.note(gettext('Profile data written to "%s".'), filename)
 
486
        stats.freeze()
 
487
        cPickle.dump(stats, open(filename, 'w'), 2)
 
488
        print 'Profile data written to %r.' % filename
1045
489
    return ret
1046
490
 
1047
491
 
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)
 
492
def get_alias(cmd):
 
493
    """Return an expanded alias, or None if no alias exists"""
 
494
    import bzrlib.config
 
495
    alias = bzrlib.config.GlobalConfig().get_alias(cmd)
1062
496
    if (alias):
1063
 
        return cmdline.split(alias)
 
497
        return alias.split(' ')
1064
498
    return None
1065
499
 
1066
500
 
1067
 
def run_bzr(argv, load_plugins=load_plugins, disable_plugins=disable_plugins):
 
501
def run_bzr(argv):
1068
502
    """Execute a command.
1069
503
 
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.
 
504
    This is similar to main(), but without all the trappings for
 
505
    logging and error handling.  
 
506
    
 
507
    argv
 
508
       The command-line arguments, without the program name from argv[0]
 
509
    
 
510
    Returns a command status or raises an exception.
1082
511
 
1083
512
    Special master options: these must come before the command because
1084
513
    they control how the command is interpreted.
1098
527
 
1099
528
    --lsprof
1100
529
        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
530
    """
1109
 
    trace.mutter("breezy version: " + breezy.__version__)
1110
 
    argv = _specified_or_unicode_argv(argv)
1111
 
    trace.mutter("brz arguments: %r", argv)
 
531
    argv = [a.decode(bzrlib.user_encoding) for a in argv]
1112
532
 
1113
 
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin = \
1114
 
        opt_coverage = opt_no_l10n = opt_no_aliases = False
 
533
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
 
534
                opt_no_aliases = False
1115
535
    opt_lsprof_file = None
1116
536
 
1117
537
    # --no-plugins is handled specially at a very early stage. We need
1120
540
 
1121
541
    argv_copy = []
1122
542
    i = 0
1123
 
    override_config = []
1124
543
    while i < len(argv):
1125
544
        a = argv[i]
1126
545
        if a == '--profile':
1128
547
        elif a == '--lsprof':
1129
548
            opt_lsprof = True
1130
549
        elif a == '--lsprof-file':
1131
 
            opt_lsprof = True
1132
550
            opt_lsprof_file = argv[i + 1]
1133
551
            i += 1
1134
552
        elif a == '--no-plugins':
1135
553
            opt_no_plugins = True
1136
554
        elif a == '--no-aliases':
1137
555
            opt_no_aliases = True
1138
 
        elif a == '--no-l10n':
1139
 
            opt_no_l10n = True
1140
556
        elif a == '--builtin':
1141
557
            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:])
 
558
        elif a in ('--quiet', '-q'):
 
559
            be_quiet()
1153
560
        else:
1154
561
            argv_copy.append(a)
1155
562
        i += 1
1156
563
 
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
 
 
 
564
    argv = argv_copy
 
565
    if (not argv) or (argv[0] == '--help'):
 
566
        from bzrlib.help import help
 
567
        if len(argv) > 1:
 
568
            help(argv[1])
 
569
        else:
 
570
            help()
 
571
        return 0
 
572
 
 
573
    if argv[0] == '--version':
 
574
        from bzrlib.builtins import show_version
 
575
        show_version()
 
576
        return 0
 
577
        
1162
578
    if not opt_no_plugins:
 
579
        from bzrlib.plugin import load_plugins
1163
580
        load_plugins()
1164
581
    else:
 
582
        from bzrlib.plugin import disable_plugins
1165
583
        disable_plugins()
1166
584
 
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
585
    alias_argv = None
1177
586
 
1178
587
    if not opt_no_aliases:
1179
588
        alias_argv = get_alias(argv[0])
1180
589
        if alias_argv:
 
590
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
1181
591
            argv[0] = alias_argv.pop(0)
1182
592
 
1183
 
    cmd = argv.pop(0)
 
593
    cmd = str(argv.pop(0))
 
594
 
1184
595
    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]
 
596
    if not getattr(cmd_obj.run_argv, 'is_deprecated', False):
 
597
        run = cmd_obj.run_argv
 
598
        run_argv = [argv]
 
599
    else:
 
600
        run = cmd_obj.run_argv_aliases
 
601
        run_argv = [argv, alias_argv]
1189
602
 
1190
603
    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
604
        if opt_lsprof:
1196
 
            if opt_coverage:
1197
 
                trace.warning(
1198
 
                    '--coverage ignored, because --lsprof is in use.')
1199
605
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
1200
606
        elif opt_profile:
1201
 
            if opt_coverage:
1202
 
                trace.warning(
1203
 
                    '--coverage ignored, because --profile is in use.')
1204
607
            ret = apply_profiled(run, *run_argv)
1205
 
        elif opt_coverage:
1206
 
            ret = apply_coveraged(run, *run_argv)
1207
608
        else:
1208
609
            ret = run(*run_argv)
1209
610
        return ret or 0
1210
611
    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
 
 
 
612
        # reset, in case we may do other commands later within the same process
 
613
        be_quiet(False)
1220
614
 
1221
615
def display_command(func):
1222
616
    """Decorator that suppresses pipe/interrupt errors."""
1225
619
            result = func(*args, **kwargs)
1226
620
            sys.stdout.flush()
1227
621
            return result
1228
 
        except IOError as e:
1229
 
            if getattr(e, 'errno', None) is None:
 
622
        except IOError, e:
 
623
            if not hasattr(e, 'errno'):
1230
624
                raise
1231
625
            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
 
626
                raise
1235
627
            pass
1236
628
        except KeyboardInterrupt:
1237
629
            pass
1238
630
    return ignore_pipe
1239
631
 
1240
632
 
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)
 
633
def main(argv):
 
634
    import bzrlib.ui
 
635
    from bzrlib.ui.text import TextUIFactory
 
636
    ## bzrlib.trace.enable_default_logging()
 
637
    bzrlib.trace.log_startup(argv)
 
638
    bzrlib.ui.ui_factory = TextUIFactory()
 
639
    ret = run_bzr_catch_errors(argv[1:])
 
640
    mutter("return code %d", ret)
1295
641
    return ret
1296
642
 
1297
643
 
1298
644
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
645
    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
646
        try:
1345
 
            cmd = _get_cmd_object(topic, check_missing=False)
1346
 
        except KeyError:
1347
 
            return []
 
647
            return run_bzr(argv)
 
648
        finally:
 
649
            # do this here inside the exception wrappers to catch EPIPE
 
650
            sys.stdout.flush()
 
651
    except Exception, e:
 
652
        # used to handle AssertionError and KeyboardInterrupt
 
653
        # specially here, but hopefully they're handled ok by the logger now
 
654
        import errno
 
655
        if (isinstance(e, IOError) 
 
656
            and hasattr(e, 'errno')
 
657
            and e.errno == errno.EPIPE):
 
658
            bzrlib.trace.note('broken pipe')
 
659
            return 3
1348
660
        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()
 
661
            bzrlib.trace.log_exception()
 
662
            if os.environ.get('BZR_PDB'):
 
663
                print '**** entering debugger'
 
664
                import pdb
 
665
                pdb.post_mortem(sys.exc_traceback)
 
666
            return 3
 
667
 
 
668
if __name__ == '__main__':
 
669
    sys.exit(main(sys.argv))