~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: Vincent Ladeuil
  • Date: 2009-06-18 19:45:24 UTC
  • mto: This revision was merged to the branch mainline in revision 4466.
  • Revision ID: v.ladeuil+lp@free.fr-20090618194524-poedor61th3op5dm
Cleanup.

* bzrlib/tests/test__known_graph.py:
(TestKnownGraph): Delete dominator tests.

* bzrlib/_known_graph_pyx.pyx: 
Cleanup all references to old version and linear dominators :-/

* bzrlib/_known_graph_py.py: 
Cleanup all references to old version and linear dominators :-/

Show diffs side-by-side

added added

removed removed

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