~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: Robert Collins
  • Date: 2005-10-17 11:41:07 UTC
  • mfrom: (1442.1.60)
  • Revision ID: robertc@robertcollins.net-20051017114107-f5586285d825c105
Merge in first part of GPG support.

This adds check_signatures config support, triams back the transport api
to be leaner and easier to hook in suffixes - non primary streams in the store
associated with the fileid that primary data is stored in, a gpg module which
will encapsulate all signing and checking operations.

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