~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: Danny van Heumen
  • Date: 2010-03-09 21:42:11 UTC
  • mto: (4634.139.5 2.0)
  • mto: This revision was merged to the branch mainline in revision 5160.
  • Revision ID: danny@dannyvanheumen.nl-20100309214211-iqh42x6qcikgd9p3
Reverted now-useless TODO list.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2006 Canonical Ltd
 
1
# Copyright (C) 2006, 2008 Canonical Ltd
2
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
12
12
#
13
13
# You should have received a copy of the GNU General Public License
14
14
# along with this program; if not, write to the Free Software
15
 
# Foundation, Inc., 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
35
35
lazy_import(globals(), """
36
36
import codecs
37
37
import errno
 
38
import threading
38
39
from warnings import warn
39
40
 
40
41
import bzrlib
48
49
    )
49
50
""")
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
51
56
from bzrlib.symbol_versioning import (
52
57
    deprecated_function,
53
 
    deprecated_method,
54
 
    zero_eight,
55
 
    zero_eleven,
 
58
    deprecated_in,
 
59
    suppress_deprecation_warnings,
56
60
    )
57
 
# Compatibility
58
 
from bzrlib.option import Option
59
 
 
60
 
 
61
 
plugin_cmds = {}
 
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()
62
124
 
63
125
 
64
126
def register_command(cmd, decorate=False):
65
 
    """Utility function to help register a command
66
 
 
67
 
    :param cmd: Command subclass to register
68
 
    :param decorate: If true, allow overriding an existing command
69
 
        of the same name; the old command is returned by this function.
70
 
        Otherwise it is an error to try to override an existing command.
71
 
    """
72
127
    global plugin_cmds
73
 
    k = cmd.__name__
74
 
    if k.startswith("cmd_"):
75
 
        k_unsquished = _unsquish_command_name(k)
76
 
    else:
77
 
        k_unsquished = k
78
 
    if k_unsquished not in plugin_cmds:
79
 
        plugin_cmds[k_unsquished] = cmd
80
 
        ## trace.mutter('registered plugin command %s', k_unsquished)
81
 
        if decorate and k_unsquished in builtin_command_names():
82
 
            return _builtin_commands()[k_unsquished]
83
 
    elif decorate:
84
 
        result = plugin_cmds[k_unsquished]
85
 
        plugin_cmds[k_unsquished] = cmd
86
 
        return result
87
 
    else:
88
 
        trace.log_error('Two plugins defined the same command: %r' % k)
89
 
        trace.log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
 
128
    return plugin_cmds.register(cmd, decorate)
90
129
 
91
130
 
92
131
def _squish_command_name(cmd):
94
133
 
95
134
 
96
135
def _unsquish_command_name(cmd):
97
 
    assert cmd.startswith("cmd_")
98
136
    return cmd[4:].replace('_','-')
99
137
 
100
138
 
101
139
def _builtin_commands():
102
140
    import bzrlib.builtins
 
141
    return _scan_module_for_commands(bzrlib.builtins)
 
142
 
 
143
 
 
144
def _scan_module_for_commands(module):
103
145
    r = {}
104
 
    builtins = bzrlib.builtins.__dict__
105
 
    for name in builtins:
 
146
    for name, obj in module.__dict__.iteritems():
106
147
        if name.startswith("cmd_"):
107
148
            real_name = _unsquish_command_name(name)
108
 
            r[real_name] = builtins[name]
 
149
            r[real_name] = obj
109
150
    return r
110
 
            
 
151
 
 
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
 
111
171
 
112
172
def builtin_command_names():
113
 
    """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
    """
114
178
    return _builtin_commands().keys()
115
 
    
 
179
 
116
180
 
117
181
def plugin_command_names():
 
182
    """Returns command names from commands registered by plugins."""
118
183
    return plugin_cmds.keys()
119
184
 
120
185
 
121
 
def _get_cmd_dict(plugins_override=True):
122
 
    """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
    """
123
196
    d = _builtin_commands()
124
197
    if plugins_override:
125
 
        d.update(plugin_cmds)
126
 
    return d
127
 
 
128
 
    
129
 
def get_all_cmds(plugins_override=True):
130
 
    """Return canonical name and class for all registered commands."""
131
 
    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():
132
200
        yield k,v
133
201
 
134
202
 
135
203
def get_cmd_object(cmd_name, plugins_override=True):
136
 
    """Return the canonical name and command class for a command.
 
204
    """Return the command object for a command.
137
205
 
138
206
    plugins_override
139
207
        If true, plugin commands can override builtins.
145
213
 
146
214
 
147
215
def _get_cmd_object(cmd_name, plugins_override=True):
148
 
    """Worker for get_cmd_object which raises KeyError rather than BzrCommandError."""
149
 
    from bzrlib.externalcommand import ExternalCommand
 
216
    """Get a command object.
150
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
    """
151
223
    # We want only 'ascii' command names, but the user may have typed
152
224
    # in a Unicode name. In that case, they should just get a
153
225
    # 'command not found' error later.
154
226
    # In the future, we may actually support Unicode command names.
155
 
 
156
 
    # first look up this command under the specified name
157
 
    cmds = _get_cmd_dict(plugins_override=plugins_override)
 
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()
158
278
    try:
159
279
        return cmds[cmd_name]()
160
280
    except KeyError:
161
281
        pass
162
 
 
163
282
    # look for any command which claims this as an alias
164
283
    for real_cmd_name, cmd_class in cmds.iteritems():
165
284
        if cmd_name in cmd_class.aliases:
166
285
            return cmd_class()
167
 
 
 
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
168
295
    cmd_obj = ExternalCommand.find_command(cmd_name)
169
296
    if cmd_obj:
170
297
        return cmd_obj
171
 
    raise KeyError
 
298
 
 
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
172
311
 
173
312
 
174
313
class Command(object):
228
367
            sys.stdout is forced to be a binary stream, and line-endings
229
368
            will not mangled.
230
369
 
 
370
    :cvar hooks: An instance of CommandHooks.
231
371
    """
232
372
    aliases = []
233
373
    takes_args = []
235
375
    encoding_type = 'strict'
236
376
 
237
377
    hidden = False
238
 
    
 
378
 
239
379
    def __init__(self):
240
380
        """Construct an instance of this command."""
241
381
        if self.__doc__ == Command.__doc__:
242
382
            warn("No help message set for %r" % self)
 
383
        # List of standard options directly supported
 
384
        self.supported_std_options = []
243
385
 
244
386
    def _maybe_expand_globs(self, file_list):
245
387
        """Glob expand file_list if the platform does not do that itself.
246
 
        
 
388
 
247
389
        :return: A possibly empty list of unicode paths.
248
390
 
249
391
        Introduced in bzrlib 0.18.
269
411
            elif aname[-1] == '*':
270
412
                aname = '[' + aname[:-1] + '...]'
271
413
            s += aname + ' '
272
 
                
273
 
        assert s[-1] == ' '
274
 
        s = s[:-1]
 
414
        s = s[:-1]      # remove last space
275
415
        return s
276
416
 
277
 
    def get_help_text(self, additional_see_also=None):
 
417
    def get_help_text(self, additional_see_also=None, plain=True,
 
418
                      see_also_as_links=False, verbose=True):
278
419
        """Return a text string with help for this command.
279
 
        
 
420
 
280
421
        :param additional_see_also: Additional help topics to be
281
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.
282
431
        """
283
432
        doc = self.help()
284
433
        if doc is None:
285
434
            raise NotImplementedError("sorry, no detailed help yet for %r" % self.name())
286
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
287
446
        result = ""
288
 
        result += 'usage: %s\n' % self._usage()
289
 
 
 
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
        #
 
456
        # XXX: optparse implicitly rewraps the help, and not always perfectly,
 
457
        # so we get <https://bugs.launchpad.net/bzr/+bug/249908>.  -- mbp
 
458
        # 20090319
 
459
        options = option.get_optparser(self.options()).format_option_help()
 
460
        # XXX: According to the spec, ReST option lists actually don't support 
 
461
        # options like --1.9 so that causes syntax errors (in Sphinx at least).
 
462
        # As that pattern always appears in the commands that break, we trap
 
463
        # on that and then format that block of 'format' options as a literal
 
464
        # block.
 
465
        if not plain and options.find('  --1.9  ') != -1:
 
466
            options = options.replace(' format:\n', ' format::\n\n', 1)
 
467
        if options.startswith('Options:'):
 
468
            result += ':' + options
 
469
        elif options.startswith('options:'):
 
470
            # Python 2.4 version of optparse
 
471
            result += ':Options:' + options[len('options:'):]
 
472
        else:
 
473
            result += options
 
474
        result += '\n'
 
475
 
 
476
        if verbose:
 
477
            # Add the description, indenting it 2 spaces
 
478
            # to match the indentation of the options
 
479
            if sections.has_key(None):
 
480
                text = sections.pop(None)
 
481
                text = '\n  '.join(text.splitlines())
 
482
                result += ':%s:\n  %s\n\n' % ('Description',text)
 
483
 
 
484
            # Add the custom sections (e.g. Examples). Note that there's no need
 
485
            # to indent these as they must be indented already in the source.
 
486
            if sections:
 
487
                for label in order:
 
488
                    if sections.has_key(label):
 
489
                        result += ':%s:\n%s\n' % (label,sections[label])
 
490
                result += '\n'
 
491
        else:
 
492
            result += ("See bzr help %s for more details and examples.\n\n"
 
493
                % self.name())
 
494
 
 
495
        # Add the aliases, source (plug-in) and see also links, if any
290
496
        if self.aliases:
291
 
            result += 'aliases: '
 
497
            result += ':Aliases:  '
292
498
            result += ', '.join(self.aliases) + '\n'
293
 
 
294
 
        result += '\n'
295
 
 
296
499
        plugin_name = self.plugin_name()
297
500
        if plugin_name is not None:
298
 
            result += '(From plugin "%s")' % plugin_name
299
 
            result += '\n\n'
300
 
 
301
 
        result += doc
302
 
        if result[-1] != '\n':
303
 
            result += '\n'
304
 
        result += '\n'
305
 
        result += option.get_optparser(self.options()).format_option_help()
 
501
            result += ':From:     plugin "%s"\n' % plugin_name
306
502
        see_also = self.get_see_also(additional_see_also)
307
503
        if see_also:
308
 
            result += '\nSee also: '
309
 
            result += ', '.join(see_also)
310
 
            result += '\n'
 
504
            if not plain and see_also_as_links:
 
505
                see_also_links = []
 
506
                for item in see_also:
 
507
                    if item == 'topics':
 
508
                        # topics doesn't have an independent section
 
509
                        # so don't create a real link
 
510
                        see_also_links.append(item)
 
511
                    else:
 
512
                        # Use a reST link for this entry
 
513
                        see_also_links.append("`%s`_" % (item,))
 
514
                see_also = see_also_links
 
515
            result += ':See also: '
 
516
            result += ', '.join(see_also) + '\n'
 
517
 
 
518
        # If this will be rendered as plain text, convert it
 
519
        if plain:
 
520
            import bzrlib.help_topics
 
521
            result = bzrlib.help_topics.help_as_plain_text(result)
311
522
        return result
312
523
 
 
524
    @staticmethod
 
525
    def _get_help_parts(text):
 
526
        """Split help text into a summary and named sections.
 
527
 
 
528
        :return: (summary,sections,order) where summary is the top line and
 
529
            sections is a dictionary of the rest indexed by section name.
 
530
            order is the order the section appear in the text.
 
531
            A section starts with a heading line of the form ":xxx:".
 
532
            Indented text on following lines is the section value.
 
533
            All text found outside a named section is assigned to the
 
534
            default section which is given the key of None.
 
535
        """
 
536
        def save_section(sections, order, label, section):
 
537
            if len(section) > 0:
 
538
                if sections.has_key(label):
 
539
                    sections[label] += '\n' + section
 
540
                else:
 
541
                    order.append(label)
 
542
                    sections[label] = section
 
543
 
 
544
        lines = text.rstrip().splitlines()
 
545
        summary = lines.pop(0)
 
546
        sections = {}
 
547
        order = []
 
548
        label,section = None,''
 
549
        for line in lines:
 
550
            if line.startswith(':') and line.endswith(':') and len(line) > 2:
 
551
                save_section(sections, order, label, section)
 
552
                label,section = line[1:-1],''
 
553
            elif (label is not None) and len(line) > 1 and not line[0].isspace():
 
554
                save_section(sections, order, label, section)
 
555
                label,section = None,line
 
556
            else:
 
557
                if len(section) > 0:
 
558
                    section += '\n' + line
 
559
                else:
 
560
                    section = line
 
561
        save_section(sections, order, label, section)
 
562
        return summary, sections, order
 
563
 
313
564
    def get_help_topic(self):
314
565
        """Return the commands help topic - its name."""
315
566
        return self.name()
316
567
 
317
568
    def get_see_also(self, additional_terms=None):
318
 
        """Return a list of help topics that are related to this ommand.
319
 
        
 
569
        """Return a list of help topics that are related to this command.
 
570
 
320
571
        The list is derived from the content of the _see_also attribute. Any
321
572
        duplicates are removed and the result is in lexical order.
322
573
        :param additional_terms: Additional help topics to cross-reference.
331
582
        """Return dict of valid options for this command.
332
583
 
333
584
        Maps from long option name to option object."""
334
 
        r = dict()
335
 
        r['help'] = option.Option.OPTIONS['help']
 
585
        r = Option.STD_OPTIONS.copy()
 
586
        std_names = r.keys()
336
587
        for o in self.takes_options:
337
588
            if isinstance(o, basestring):
338
589
                o = option.Option.OPTIONS[o]
339
590
            r[o.name] = o
 
591
            if o.name in std_names:
 
592
                self.supported_std_options.append(o.name)
340
593
        return r
341
594
 
342
595
    def _setup_outf(self):
343
596
        """Return a file linked to stdout, which has proper encoding."""
344
 
        assert self.encoding_type in ['strict', 'exact', 'replace']
345
 
 
346
597
        # Originally I was using self.stdout, but that looks
347
598
        # *way* too much like sys.stdout
348
599
        if self.encoding_type == 'exact':
357
608
 
358
609
        output_encoding = osutils.get_terminal_encoding()
359
610
 
360
 
        # use 'replace' so that we don't abort if trying to write out
361
 
        # in e.g. the default C locale.
362
 
        self.outf = codecs.getwriter(output_encoding)(sys.stdout, errors=self.encoding_type)
 
611
        self.outf = codecs.getwriter(output_encoding)(sys.stdout,
 
612
                        errors=self.encoding_type)
363
613
        # For whatever reason codecs.getwriter() does not advertise its encoding
364
614
        # it just returns the encoding of the wrapped file, which is completely
365
615
        # bogus. So set the attribute, so we can find the correct encoding later.
372
622
                 DeprecationWarning, stacklevel=2)
373
623
            argv = []
374
624
        args, opts = parse_args(self, argv, alias_argv)
 
625
 
 
626
        # Process the standard options
375
627
        if 'help' in opts:  # e.g. bzr add --help
376
628
            sys.stdout.write(self.get_help_text())
377
629
            return 0
 
630
        if 'usage' in opts:  # e.g. bzr add --usage
 
631
            sys.stdout.write(self.get_help_text(verbose=False))
 
632
            return 0
 
633
        trace.set_verbosity_level(option._verbosity_level)
 
634
        if 'verbose' in self.supported_std_options:
 
635
            opts['verbose'] = trace.is_verbose()
 
636
        elif opts.has_key('verbose'):
 
637
            del opts['verbose']
 
638
        if 'quiet' in self.supported_std_options:
 
639
            opts['quiet'] = trace.is_quiet()
 
640
        elif opts.has_key('quiet'):
 
641
            del opts['quiet']
 
642
 
378
643
        # mix arguments and options into one dictionary
379
644
        cmdargs = _match_argform(self.name(), self.takes_args, args)
380
645
        cmdopts = {}
387
652
        self._setup_outf()
388
653
 
389
654
        return self.run(**all_cmd_args)
390
 
    
 
655
 
391
656
    def run(self):
392
657
        """Actually run the command.
393
658
 
423
688
            return None
424
689
 
425
690
 
426
 
# Technically, this function hasn't been use in a *really* long time
427
 
# but we are only deprecating it now.
428
 
@deprecated_function(zero_eleven)
429
 
def parse_spec(spec):
430
 
    """
431
 
    >>> parse_spec(None)
432
 
    [None, None]
433
 
    >>> parse_spec("./")
434
 
    ['./', None]
435
 
    >>> parse_spec("../@")
436
 
    ['..', -1]
437
 
    >>> parse_spec("../f/@35")
438
 
    ['../f', 35]
439
 
    >>> parse_spec('./@revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67')
440
 
    ['.', 'revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67']
441
 
    """
442
 
    if spec is None:
443
 
        return [None, None]
444
 
    if '/@' in spec:
445
 
        parsed = spec.split('/@')
446
 
        assert len(parsed) == 2
447
 
        if parsed[1] == "":
448
 
            parsed[1] = -1
449
 
        else:
450
 
            try:
451
 
                parsed[1] = int(parsed[1])
452
 
            except ValueError:
453
 
                pass # We can allow stuff like ./@revid:blahblahblah
454
 
            else:
455
 
                assert parsed[1] >=0
456
 
    else:
457
 
        parsed = [spec, None]
458
 
    return parsed
 
691
class CommandHooks(Hooks):
 
692
    """Hooks related to Command object creation/enumeration."""
 
693
 
 
694
    def __init__(self):
 
695
        """Create the default hooks.
 
696
 
 
697
        These are all empty initially, because by default nothing should get
 
698
        notified.
 
699
        """
 
700
        Hooks.__init__(self)
 
701
        self.create_hook(HookPoint('extend_command',
 
702
            "Called after creating a command object to allow modifications "
 
703
            "such as adding or removing options, docs etc. Called with the "
 
704
            "new bzrlib.commands.Command object.", (1, 13), None))
 
705
        self.create_hook(HookPoint('get_command',
 
706
            "Called when creating a single command. Called with "
 
707
            "(cmd_or_None, command_name). get_command should either return "
 
708
            "the cmd_or_None parameter, or a replacement Command object that "
 
709
            "should be used for the command. Note that the Command.hooks "
 
710
            "hooks are core infrastructure. Many users will prefer to use "
 
711
            "bzrlib.commands.register_command or plugin_cmds.register_lazy.",
 
712
            (1, 17), None))
 
713
        self.create_hook(HookPoint('get_missing_command',
 
714
            "Called when creating a single command if no command could be "
 
715
            "found. Called with (command_name). get_missing_command should "
 
716
            "either return None, or a Command object to be used for the "
 
717
            "command.", (1, 17), None))
 
718
        self.create_hook(HookPoint('list_commands',
 
719
            "Called when enumerating commands. Called with a set of "
 
720
            "cmd_name strings for all the commands found so far. This set "
 
721
            " is safe to mutate - e.g. to remove a command. "
 
722
            "list_commands should return the updated set of command names.",
 
723
            (1, 17), None))
 
724
 
 
725
Command.hooks = CommandHooks()
 
726
 
459
727
 
460
728
def parse_args(command, argv, alias_argv=None):
461
729
    """Parse command line.
462
 
    
 
730
 
463
731
    Arguments and options are parsed at this level before being passed
464
732
    down to specific command handlers.  This routine knows, from a
465
733
    lookup table, something about the available options, what optargs
514
782
                               % (cmd, argname.upper()))
515
783
            else:
516
784
                argdict[argname] = args.pop(0)
517
 
            
 
785
 
518
786
    if args:
519
787
        raise errors.BzrCommandError("extra argument to command %s: %s"
520
788
                                     % (cmd, args[0]))
521
789
 
522
790
    return argdict
523
791
 
 
792
def apply_coveraged(dirname, the_callable, *args, **kwargs):
 
793
    # Cannot use "import trace", as that would import bzrlib.trace instead of
 
794
    # the standard library's trace.
 
795
    trace = __import__('trace')
 
796
 
 
797
    tracer = trace.Trace(count=1, trace=0)
 
798
    sys.settrace(tracer.globaltrace)
 
799
    threading.settrace(tracer.globaltrace)
 
800
 
 
801
    try:
 
802
        return exception_to_return_code(the_callable, *args, **kwargs)
 
803
    finally:
 
804
        sys.settrace(None)
 
805
        results = tracer.results()
 
806
        results.write_results(show_missing=1, summary=False,
 
807
                              coverdir=dirname)
524
808
 
525
809
 
526
810
def apply_profiled(the_callable, *args, **kwargs):
531
815
    try:
532
816
        prof = hotshot.Profile(pfname)
533
817
        try:
534
 
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
 
818
            ret = prof.runcall(exception_to_return_code, the_callable, *args,
 
819
                **kwargs) or 0
535
820
        finally:
536
821
            prof.close()
537
822
        stats = hotshot.stats.load(pfname)
546
831
        os.remove(pfname)
547
832
 
548
833
 
 
834
def exception_to_return_code(the_callable, *args, **kwargs):
 
835
    """UI level helper for profiling and coverage.
 
836
 
 
837
    This transforms exceptions into a return value of 3. As such its only
 
838
    relevant to the UI layer, and should never be called where catching
 
839
    exceptions may be desirable.
 
840
    """
 
841
    try:
 
842
        return the_callable(*args, **kwargs)
 
843
    except (KeyboardInterrupt, Exception), e:
 
844
        # used to handle AssertionError and KeyboardInterrupt
 
845
        # specially here, but hopefully they're handled ok by the logger now
 
846
        exc_info = sys.exc_info()
 
847
        exitcode = trace.report_exception(exc_info, sys.stderr)
 
848
        if os.environ.get('BZR_PDB'):
 
849
            print '**** entering debugger'
 
850
            tb = exc_info[2]
 
851
            import pdb
 
852
            if sys.version_info[:2] < (2, 6):
 
853
                # XXX: we want to do
 
854
                #    pdb.post_mortem(tb)
 
855
                # but because pdb.post_mortem gives bad results for tracebacks
 
856
                # from inside generators, we do it manually.
 
857
                # (http://bugs.python.org/issue4150, fixed in Python 2.6)
 
858
 
 
859
                # Setup pdb on the traceback
 
860
                p = pdb.Pdb()
 
861
                p.reset()
 
862
                p.setup(tb.tb_frame, tb)
 
863
                # Point the debugger at the deepest frame of the stack
 
864
                p.curindex = len(p.stack) - 1
 
865
                p.curframe = p.stack[p.curindex][0]
 
866
                # Start the pdb prompt.
 
867
                p.print_stack_entry(p.stack[p.curindex])
 
868
                p.execRcLines()
 
869
                p.cmdloop()
 
870
            else:
 
871
                pdb.post_mortem(tb)
 
872
        return exitcode
 
873
 
 
874
 
549
875
def apply_lsprofiled(filename, the_callable, *args, **kwargs):
550
876
    from bzrlib.lsprof import profile
551
 
    ret, stats = profile(the_callable, *args, **kwargs)
 
877
    ret, stats = profile(exception_to_return_code, the_callable, *args, **kwargs)
552
878
    stats.sort()
553
879
    if filename is None:
554
880
        stats.pprint()
558
884
    return ret
559
885
 
560
886
 
 
887
def shlex_split_unicode(unsplit):
 
888
    import shlex
 
889
    return [u.decode('utf-8') for u in shlex.split(unsplit.encode('utf-8'))]
 
890
 
 
891
 
561
892
def get_alias(cmd, config=None):
562
893
    """Return an expanded alias, or None if no alias exists.
563
894
 
573
904
        config = bzrlib.config.GlobalConfig()
574
905
    alias = config.get_alias(cmd)
575
906
    if (alias):
576
 
        import shlex
577
 
        return [a.decode('utf-8') for a in shlex.split(alias.encode('utf-8'))]
 
907
        return shlex_split_unicode(alias)
578
908
    return None
579
909
 
580
910
 
581
911
def run_bzr(argv):
582
912
    """Execute a command.
583
913
 
584
 
    This is similar to main(), but without all the trappings for
585
 
    logging and error handling.  
586
 
    
587
914
    argv
588
915
       The command-line arguments, without the program name from argv[0]
589
916
       These should already be decoded. All library/test code calling
590
917
       run_bzr should be passing valid strings (don't need decoding).
591
 
    
 
918
 
592
919
    Returns a command status or raises an exception.
593
920
 
594
921
    Special master options: these must come before the command because
609
936
 
610
937
    --lsprof
611
938
        Run under the Python lsprof profiler.
 
939
 
 
940
    --coverage
 
941
        Generate line coverage report in the specified directory.
612
942
    """
613
943
    argv = list(argv)
614
944
    trace.mutter("bzr arguments: %r", argv)
615
945
 
616
946
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
617
947
                opt_no_aliases = False
618
 
    opt_lsprof_file = None
 
948
    opt_lsprof_file = opt_coverage_dir = None
619
949
 
620
950
    # --no-plugins is handled specially at a very early stage. We need
621
951
    # to load plugins before doing other command parsing so that they
639
969
            opt_no_aliases = True
640
970
        elif a == '--builtin':
641
971
            opt_builtin = True
642
 
        elif a in ('--quiet', '-q'):
643
 
            trace.be_quiet()
 
972
        elif a == '--coverage':
 
973
            opt_coverage_dir = argv[i + 1]
 
974
            i += 1
644
975
        elif a.startswith('-D'):
645
976
            debug.debug_flags.add(a[2:])
646
977
        else:
647
978
            argv_copy.append(a)
648
979
        i += 1
649
980
 
 
981
    debug.set_debug_flags_from_config()
 
982
 
650
983
    argv = argv_copy
651
984
    if (not argv):
652
985
        from bzrlib.builtins import cmd_help
654
987
        return 0
655
988
 
656
989
    if argv[0] == '--version':
657
 
        from bzrlib.version import show_version
658
 
        show_version()
 
990
        from bzrlib.builtins import cmd_version
 
991
        cmd_version().run_argv_aliases([])
659
992
        return 0
660
 
        
 
993
 
661
994
    if not opt_no_plugins:
662
995
        from bzrlib.plugin import load_plugins
663
996
        load_plugins()
670
1003
    if not opt_no_aliases:
671
1004
        alias_argv = get_alias(argv[0])
672
1005
        if alias_argv:
673
 
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
 
1006
            user_encoding = osutils.get_user_encoding()
 
1007
            alias_argv = [a.decode(user_encoding) for a in alias_argv]
674
1008
            argv[0] = alias_argv.pop(0)
675
1009
 
676
1010
    cmd = argv.pop(0)
683
1017
    run_argv = [argv, alias_argv]
684
1018
 
685
1019
    try:
 
1020
        # We can be called recursively (tests for example), but we don't want
 
1021
        # the verbosity level to propagate.
 
1022
        saved_verbosity_level = option._verbosity_level
 
1023
        option._verbosity_level = 0
686
1024
        if opt_lsprof:
 
1025
            if opt_coverage_dir:
 
1026
                trace.warning(
 
1027
                    '--coverage ignored, because --lsprof is in use.')
687
1028
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
688
1029
        elif opt_profile:
 
1030
            if opt_coverage_dir:
 
1031
                trace.warning(
 
1032
                    '--coverage ignored, because --profile is in use.')
689
1033
            ret = apply_profiled(run, *run_argv)
 
1034
        elif opt_coverage_dir:
 
1035
            ret = apply_coveraged(opt_coverage_dir, run, *run_argv)
690
1036
        else:
691
1037
            ret = run(*run_argv)
 
1038
        if 'memory' in debug.debug_flags:
 
1039
            trace.debug_memory('Process status after command:', short=False)
692
1040
        return ret or 0
693
1041
    finally:
694
 
        # reset, in case we may do other commands later within the same process
695
 
        trace.be_quiet(False)
 
1042
        # reset, in case we may do other commands later within the same
 
1043
        # process. Commands that want to execute sub-commands must propagate
 
1044
        # --verbose in their own way.
 
1045
        option._verbosity_level = saved_verbosity_level
 
1046
 
696
1047
 
697
1048
def display_command(func):
698
1049
    """Decorator that suppresses pipe/interrupt errors."""
714
1065
    return ignore_pipe
715
1066
 
716
1067
 
717
 
def main(argv):
 
1068
def install_bzr_command_hooks():
 
1069
    """Install the hooks to supply bzr's own commands."""
 
1070
    if _list_bzr_commands in Command.hooks["list_commands"]:
 
1071
        return
 
1072
    Command.hooks.install_named_hook("list_commands", _list_bzr_commands,
 
1073
        "bzr commands")
 
1074
    Command.hooks.install_named_hook("get_command", _get_bzr_command,
 
1075
        "bzr commands")
 
1076
    Command.hooks.install_named_hook("get_command", _get_plugin_command,
 
1077
        "bzr plugin commands")
 
1078
    Command.hooks.install_named_hook("get_command", _get_external_command,
 
1079
        "bzr external command lookup")
 
1080
    Command.hooks.install_named_hook("get_missing_command", _try_plugin_provider,
 
1081
        "bzr plugin-provider-db check")
 
1082
 
 
1083
 
 
1084
def main(argv=None):
 
1085
    """Main entry point of command-line interface.
 
1086
 
 
1087
    :param argv: list of unicode command-line arguments similar to sys.argv.
 
1088
        argv[0] is script name usually, it will be ignored.
 
1089
        Don't pass here sys.argv because this list contains plain strings
 
1090
        and not unicode; pass None instead.
 
1091
 
 
1092
    :return: exit code of bzr command.
 
1093
    """
718
1094
    import bzrlib.ui
719
 
    from bzrlib.ui.text import TextUIFactory
720
 
    bzrlib.ui.ui_factory = TextUIFactory()
721
 
    argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
 
1095
    bzrlib.ui.ui_factory = bzrlib.ui.make_ui_for_terminal(
 
1096
        sys.stdin, sys.stdout, sys.stderr)
 
1097
 
 
1098
    # Is this a final release version? If so, we should suppress warnings
 
1099
    if bzrlib.version_info[3] == 'final':
 
1100
        suppress_deprecation_warnings(override=True)
 
1101
    if argv is None:
 
1102
        argv = osutils.get_unicode_argv()
 
1103
    else:
 
1104
        new_argv = []
 
1105
        try:
 
1106
            # ensure all arguments are unicode strings
 
1107
            for a in argv[1:]:
 
1108
                if isinstance(a, unicode):
 
1109
                    new_argv.append(a)
 
1110
                else:
 
1111
                    new_argv.append(a.decode('ascii'))
 
1112
        except UnicodeDecodeError:
 
1113
            raise errors.BzrError("argv should be list of unicode strings.")
 
1114
        argv = new_argv
722
1115
    ret = run_bzr_catch_errors(argv)
723
1116
    trace.mutter("return code %d", ret)
724
1117
    return ret
725
1118
 
726
1119
 
727
1120
def run_bzr_catch_errors(argv):
 
1121
    """Run a bzr command with parameters as described by argv.
 
1122
 
 
1123
    This function assumed that that UI layer is setup, that symbol deprecations
 
1124
    are already applied, and that unicode decoding has already been performed on argv.
 
1125
    """
 
1126
    install_bzr_command_hooks()
 
1127
    return exception_to_return_code(run_bzr, argv)
 
1128
 
 
1129
 
 
1130
def run_bzr_catch_user_errors(argv):
 
1131
    """Run bzr and report user errors, but let internal errors propagate.
 
1132
 
 
1133
    This is used for the test suite, and might be useful for other programs
 
1134
    that want to wrap the commandline interface.
 
1135
    """
 
1136
    install_bzr_command_hooks()
728
1137
    try:
729
1138
        return run_bzr(argv)
730
 
    except (KeyboardInterrupt, Exception), e:
731
 
        # used to handle AssertionError and KeyboardInterrupt
732
 
        # specially here, but hopefully they're handled ok by the logger now
733
 
        trace.report_exception(sys.exc_info(), sys.stderr)
734
 
        if os.environ.get('BZR_PDB'):
735
 
            print '**** entering debugger'
736
 
            import pdb
737
 
            pdb.post_mortem(sys.exc_traceback)
738
 
        return 3
 
1139
    except Exception, e:
 
1140
        if (isinstance(e, (OSError, IOError))
 
1141
            or not getattr(e, 'internal_error', True)):
 
1142
            trace.report_exception(sys.exc_info(), sys.stderr)
 
1143
            return 3
 
1144
        else:
 
1145
            raise
739
1146
 
740
1147
 
741
1148
class HelpCommandIndex(object):
761
1168
            return [cmd]
762
1169
 
763
1170
 
 
1171
class Provider(object):
 
1172
    '''Generic class to be overriden by plugins'''
 
1173
 
 
1174
    def plugin_for_command(self, cmd_name):
 
1175
        '''Takes a command and returns the information for that plugin
 
1176
 
 
1177
        :return: A dictionary with all the available information
 
1178
        for the requested plugin
 
1179
        '''
 
1180
        raise NotImplementedError
 
1181
 
 
1182
 
 
1183
class ProvidersRegistry(registry.Registry):
 
1184
    '''This registry exists to allow other providers to exist'''
 
1185
 
 
1186
    def __iter__(self):
 
1187
        for key, provider in self.iteritems():
 
1188
            yield provider
 
1189
 
 
1190
command_providers_registry = ProvidersRegistry()
 
1191
 
 
1192
 
764
1193
if __name__ == '__main__':
765
1194
    sys.exit(main(sys.argv))