~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2010-02-18 06:07:17 UTC
  • mfrom: (5044.1.1 trivial)
  • Revision ID: pqm@pqm.ubuntu.com-20100218060717-0qpgz8ovru733yzw
(mbp) turn off verbose tests in 'make check'

Show diffs side-by-side

added added

removed removed

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