/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: Vincent Ladeuil
  • Date: 2008-10-06 10:06:53 UTC
  • mto: (3926.1.1 bzr.integration)
  • mto: This revision was merged to the branch mainline in revision 3928.
  • Revision ID: v.ladeuil+lp@free.fr-20081006100653-m74ulbg7rlfcuqox
Add a credential store for '.netrc'.

* plugins/netrc_credential_store/tests/test_netrc.py: 
Associated tests.

* plugins/netrc_credential_store/tests/__init__.py: 
Associated tests.

* plugins/netrc_credential_store/__init__.py: 
Provides a credential store for .netrc. This also documents how to
plug a credential store for authentication.conf.

* tests/__init__.py:
(TestCaseInTempDir.build_tree): Drive-by fix, use assertIsInstance
instead of assert_ to get a meaningful error message.

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
1
# Copyright (C) 2006 Canonical Ltd
 
2
#
 
3
# This program is free software; you can redistribute it and/or modify
 
4
# it under the terms of the GNU General Public License as published by
 
5
# the Free Software Foundation; either version 2 of the License, or
 
6
# (at your option) any later version.
 
7
#
 
8
# This program is distributed in the hope that it will be useful,
 
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
 
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
11
# GNU General Public License for more details.
 
12
#
 
13
# You should have received a copy of the GNU General Public License
 
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
 
16
 
 
17
 
 
18
# TODO: probably should say which arguments are candidates for glob
 
19
# expansion on windows and do that at the command level.
 
20
 
 
21
# TODO: Define arguments by objects, rather than just using names.
 
22
# Those objects can specify the expected type of the argument, which
 
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
 
32
import sys
 
33
 
 
34
from bzrlib.lazy_import import lazy_import
 
35
lazy_import(globals(), """
 
36
import codecs
 
37
import errno
 
38
from warnings import warn
 
39
 
 
40
import bzrlib
 
41
from bzrlib import (
 
42
    debug,
 
43
    errors,
 
44
    option,
 
45
    osutils,
 
46
    trace,
 
47
    win32utils,
 
48
    )
 
49
""")
 
50
 
 
51
from bzrlib import registry
 
52
# Compatibility
 
53
from bzrlib.option import Option
 
54
 
 
55
 
 
56
plugin_cmds = {}
 
57
 
 
58
 
 
59
def register_command(cmd, decorate=False):
 
60
    """Utility function to help register a command
 
61
 
 
62
    :param cmd: Command subclass to register
 
63
    :param decorate: If true, allow overriding an existing command
 
64
        of the same name; the old command is returned by this function.
 
65
        Otherwise it is an error to try to override an existing command.
 
66
    """
 
67
    global plugin_cmds
 
68
    k = cmd.__name__
 
69
    if k.startswith("cmd_"):
 
70
        k_unsquished = _unsquish_command_name(k)
 
71
    else:
 
72
        k_unsquished = k
 
73
    if k_unsquished not in plugin_cmds:
 
74
        plugin_cmds[k_unsquished] = cmd
 
75
        ## trace.mutter('registered plugin command %s', k_unsquished)
 
76
        if decorate and k_unsquished in builtin_command_names():
 
77
            return _builtin_commands()[k_unsquished]
 
78
    elif decorate:
 
79
        result = plugin_cmds[k_unsquished]
 
80
        plugin_cmds[k_unsquished] = cmd
 
81
        return result
 
82
    else:
 
83
        trace.log_error('Two plugins defined the same command: %r' % k)
 
84
        trace.log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
 
85
        trace.log_error('Previously this command was registered from %r' %
 
86
                        sys.modules[plugin_cmds[k_unsquished].__module__])
 
87
 
 
88
 
 
89
def _squish_command_name(cmd):
 
90
    return 'cmd_' + cmd.replace('-', '_')
 
91
 
 
92
 
 
93
def _unsquish_command_name(cmd):
 
94
    return cmd[4:].replace('_','-')
 
95
 
 
96
 
 
97
def _builtin_commands():
 
98
    import bzrlib.builtins
 
99
    r = {}
 
100
    builtins = bzrlib.builtins.__dict__
 
101
    for name in builtins:
 
102
        if name.startswith("cmd_"):
 
103
            real_name = _unsquish_command_name(name)
 
104
            r[real_name] = builtins[name]
 
105
    return r
 
106
            
 
107
 
 
108
def builtin_command_names():
 
109
    """Return list of builtin command names."""
 
110
    return _builtin_commands().keys()
 
111
    
 
112
 
 
113
def plugin_command_names():
 
114
    return plugin_cmds.keys()
 
115
 
 
116
 
 
117
def _get_cmd_dict(plugins_override=True):
 
118
    """Return name->class mapping for all commands."""
 
119
    d = _builtin_commands()
 
120
    if plugins_override:
 
121
        d.update(plugin_cmds)
 
122
    return d
 
123
 
 
124
    
 
125
def get_all_cmds(plugins_override=True):
 
126
    """Return canonical name and class for all registered commands."""
 
127
    for k, v in _get_cmd_dict(plugins_override=plugins_override).iteritems():
 
128
        yield k,v
 
129
 
 
130
 
 
131
def get_cmd_object(cmd_name, plugins_override=True):
 
132
    """Return the canonical name and command class for a command.
 
133
 
 
134
    plugins_override
 
135
        If true, plugin commands can override builtins.
 
136
    """
 
137
    try:
 
138
        return _get_cmd_object(cmd_name, plugins_override)
 
139
    except KeyError:
 
140
        raise errors.BzrCommandError('unknown command "%s"' % cmd_name)
 
141
 
 
142
 
 
143
def _get_cmd_object(cmd_name, plugins_override=True):
 
144
    """Worker for get_cmd_object which raises KeyError rather than BzrCommandError."""
 
145
    from bzrlib.externalcommand import ExternalCommand
 
146
 
 
147
    # We want only 'ascii' command names, but the user may have typed
 
148
    # in a Unicode name. In that case, they should just get a
 
149
    # 'command not found' error later.
 
150
    # In the future, we may actually support Unicode command names.
 
151
 
 
152
    # first look up this command under the specified name
 
153
    cmds = _get_cmd_dict(plugins_override=plugins_override)
 
154
    try:
 
155
        return cmds[cmd_name]()
 
156
    except KeyError:
 
157
        pass
 
158
 
 
159
    # look for any command which claims this as an alias
 
160
    for real_cmd_name, cmd_class in cmds.iteritems():
 
161
        if cmd_name in cmd_class.aliases:
 
162
            return cmd_class()
 
163
 
 
164
    cmd_obj = ExternalCommand.find_command(cmd_name)
 
165
    if cmd_obj:
 
166
        return cmd_obj
 
167
 
 
168
    # look for plugins that provide this command but aren't installed
 
169
    for provider in command_providers_registry:
 
170
        try:
 
171
            plugin_metadata = provider.plugin_for_command(cmd_name)
 
172
        except errors.NoPluginAvailable:
 
173
            pass
 
174
        else:
 
175
            raise errors.CommandAvailableInPlugin(cmd_name, 
 
176
                                                  plugin_metadata, provider)
 
177
 
 
178
    raise KeyError
 
179
 
 
180
 
 
181
class Command(object):
 
182
    """Base class for commands.
 
183
 
 
184
    Commands are the heart of the command-line bzr interface.
 
185
 
 
186
    The command object mostly handles the mapping of command-line
 
187
    parameters into one or more bzrlib operations, and of the results
 
188
    into textual output.
 
189
 
 
190
    Commands normally don't have any state.  All their arguments are
 
191
    passed in to the run method.  (Subclasses may take a different
 
192
    policy if the behaviour of the instance needs to depend on e.g. a
 
193
    shell plugin and not just its Python class.)
 
194
 
 
195
    The docstring for an actual command should give a single-line
 
196
    summary, then a complete description of the command.  A grammar
 
197
    description will be inserted.
 
198
 
 
199
    aliases
 
200
        Other accepted names for this command.
 
201
 
 
202
    takes_args
 
203
        List of argument forms, marked with whether they are optional,
 
204
        repeated, etc.
 
205
 
 
206
                Examples:
 
207
 
 
208
                ['to_location', 'from_branch?', 'file*']
 
209
 
 
210
                'to_location' is required
 
211
                'from_branch' is optional
 
212
                'file' can be specified 0 or more times
 
213
 
 
214
    takes_options
 
215
        List of options that may be given for this command.  These can
 
216
        be either strings, referring to globally-defined options,
 
217
        or option objects.  Retrieve through options().
 
218
 
 
219
    hidden
 
220
        If true, this command isn't advertised.  This is typically
 
221
        for commands intended for expert users.
 
222
 
 
223
    encoding_type
 
224
        Command objects will get a 'outf' attribute, which has been
 
225
        setup to properly handle encoding of unicode strings.
 
226
        encoding_type determines what will happen when characters cannot
 
227
        be encoded
 
228
            strict - abort if we cannot decode
 
229
            replace - put in a bogus character (typically '?')
 
230
            exact - do not encode sys.stdout
 
231
 
 
232
            NOTE: by default on Windows, sys.stdout is opened as a text
 
233
            stream, therefore LF line-endings are converted to CRLF.
 
234
            When a command uses encoding_type = 'exact', then
 
235
            sys.stdout is forced to be a binary stream, and line-endings
 
236
            will not mangled.
 
237
 
 
238
    """
 
239
    aliases = []
 
240
    takes_args = []
 
241
    takes_options = []
 
242
    encoding_type = 'strict'
 
243
 
 
244
    hidden = False
 
245
    
 
246
    def __init__(self):
 
247
        """Construct an instance of this command."""
 
248
        if self.__doc__ == Command.__doc__:
 
249
            warn("No help message set for %r" % self)
 
250
        # List of standard options directly supported
 
251
        self.supported_std_options = []
 
252
 
 
253
    def _maybe_expand_globs(self, file_list):
 
254
        """Glob expand file_list if the platform does not do that itself.
 
255
        
 
256
        :return: A possibly empty list of unicode paths.
 
257
 
 
258
        Introduced in bzrlib 0.18.
 
259
        """
 
260
        if not file_list:
 
261
            file_list = []
 
262
        if sys.platform == 'win32':
 
263
            file_list = win32utils.glob_expand(file_list)
 
264
        return list(file_list)
 
265
 
 
266
    def _usage(self):
 
267
        """Return single-line grammar for this command.
 
268
 
 
269
        Only describes arguments, not options.
 
270
        """
 
271
        s = 'bzr ' + self.name() + ' '
 
272
        for aname in self.takes_args:
 
273
            aname = aname.upper()
 
274
            if aname[-1] in ['$', '+']:
 
275
                aname = aname[:-1] + '...'
 
276
            elif aname[-1] == '?':
 
277
                aname = '[' + aname[:-1] + ']'
 
278
            elif aname[-1] == '*':
 
279
                aname = '[' + aname[:-1] + '...]'
 
280
            s += aname + ' '
 
281
        s = s[:-1]      # remove last space
 
282
        return s
 
283
 
 
284
    def get_help_text(self, additional_see_also=None, plain=True,
 
285
                      see_also_as_links=False):
 
286
        """Return a text string with help for this command.
 
287
        
 
288
        :param additional_see_also: Additional help topics to be
 
289
            cross-referenced.
 
290
        :param plain: if False, raw help (reStructuredText) is
 
291
            returned instead of plain text.
 
292
        :param see_also_as_links: if True, convert items in 'See also'
 
293
            list to internal links (used by bzr_man rstx generator)
 
294
        """
 
295
        doc = self.help()
 
296
        if doc is None:
 
297
            raise NotImplementedError("sorry, no detailed help yet for %r" % self.name())
 
298
 
 
299
        # Extract the summary (purpose) and sections out from the text
 
300
        purpose,sections = self._get_help_parts(doc)
 
301
 
 
302
        # If a custom usage section was provided, use it
 
303
        if sections.has_key('Usage'):
 
304
            usage = sections.pop('Usage')
 
305
        else:
 
306
            usage = self._usage()
 
307
 
 
308
        # The header is the purpose and usage
 
309
        result = ""
 
310
        result += ':Purpose: %s\n' % purpose
 
311
        if usage.find('\n') >= 0:
 
312
            result += ':Usage:\n%s\n' % usage
 
313
        else:
 
314
            result += ':Usage:   %s\n' % usage
 
315
        result += '\n'
 
316
 
 
317
        # Add the options
 
318
        options = option.get_optparser(self.options()).format_option_help()
 
319
        if options.startswith('Options:'):
 
320
            result += ':' + options
 
321
        elif options.startswith('options:'):
 
322
            # Python 2.4 version of optparse
 
323
            result += ':Options:' + options[len('options:'):]
 
324
        else:
 
325
            result += options
 
326
        result += '\n'
 
327
 
 
328
        # Add the description, indenting it 2 spaces
 
329
        # to match the indentation of the options
 
330
        if sections.has_key(None):
 
331
            text = sections.pop(None)
 
332
            text = '\n  '.join(text.splitlines())
 
333
            result += ':%s:\n  %s\n\n' % ('Description',text)
 
334
 
 
335
        # Add the custom sections (e.g. Examples). Note that there's no need
 
336
        # to indent these as they must be indented already in the source.
 
337
        if sections:
 
338
            labels = sorted(sections.keys())
 
339
            for label in labels:
 
340
                result += ':%s:\n%s\n\n' % (label,sections[label])
 
341
 
 
342
        # Add the aliases, source (plug-in) and see also links, if any
 
343
        if self.aliases:
 
344
            result += ':Aliases:  '
 
345
            result += ', '.join(self.aliases) + '\n'
 
346
        plugin_name = self.plugin_name()
 
347
        if plugin_name is not None:
 
348
            result += ':From:     plugin "%s"\n' % plugin_name
 
349
        see_also = self.get_see_also(additional_see_also)
 
350
        if see_also:
 
351
            if not plain and see_also_as_links:
 
352
                see_also_links = []
 
353
                for item in see_also:
 
354
                    if item == 'topics':
 
355
                        # topics doesn't have an independent section
 
356
                        # so don't create a real link
 
357
                        see_also_links.append(item)
 
358
                    else:
 
359
                        # Use a reST link for this entry
 
360
                        see_also_links.append("`%s`_" % (item,))
 
361
                see_also = see_also_links
 
362
            result += ':See also: '
 
363
            result += ', '.join(see_also) + '\n'
 
364
 
 
365
        # If this will be rendered as plain text, convert it
 
366
        if plain:
 
367
            import bzrlib.help_topics
 
368
            result = bzrlib.help_topics.help_as_plain_text(result)
 
369
        return result
 
370
 
 
371
    @staticmethod
 
372
    def _get_help_parts(text):
 
373
        """Split help text into a summary and named sections.
 
374
 
 
375
        :return: (summary,sections) where summary is the top line and
 
376
            sections is a dictionary of the rest indexed by section name.
 
377
            A section starts with a heading line of the form ":xxx:".
 
378
            Indented text on following lines is the section value.
 
379
            All text found outside a named section is assigned to the
 
380
            default section which is given the key of None.
 
381
        """
 
382
        def save_section(sections, label, section):
 
383
            if len(section) > 0:
 
384
                if sections.has_key(label):
 
385
                    sections[label] += '\n' + section
 
386
                else:
 
387
                    sections[label] = section
 
388
 
 
389
        lines = text.rstrip().splitlines()
 
390
        summary = lines.pop(0)
 
391
        sections = {}
 
392
        label,section = None,''
 
393
        for line in lines:
 
394
            if line.startswith(':') and line.endswith(':') and len(line) > 2:
 
395
                save_section(sections, label, section)
 
396
                label,section = line[1:-1],''
 
397
            elif (label is not None) and len(line) > 1 and not line[0].isspace():
 
398
                save_section(sections, label, section)
 
399
                label,section = None,line
 
400
            else:
 
401
                if len(section) > 0:
 
402
                    section += '\n' + line
 
403
                else:
 
404
                    section = line
 
405
        save_section(sections, label, section)
 
406
        return summary, sections
 
407
 
 
408
    def get_help_topic(self):
 
409
        """Return the commands help topic - its name."""
 
410
        return self.name()
 
411
 
 
412
    def get_see_also(self, additional_terms=None):
 
413
        """Return a list of help topics that are related to this command.
 
414
        
 
415
        The list is derived from the content of the _see_also attribute. Any
 
416
        duplicates are removed and the result is in lexical order.
 
417
        :param additional_terms: Additional help topics to cross-reference.
 
418
        :return: A list of help topics.
 
419
        """
 
420
        see_also = set(getattr(self, '_see_also', []))
 
421
        if additional_terms:
 
422
            see_also.update(additional_terms)
 
423
        return sorted(see_also)
 
424
 
 
425
    def options(self):
 
426
        """Return dict of valid options for this command.
 
427
 
 
428
        Maps from long option name to option object."""
 
429
        r = Option.STD_OPTIONS.copy()
 
430
        std_names = r.keys()
 
431
        for o in self.takes_options:
 
432
            if isinstance(o, basestring):
 
433
                o = option.Option.OPTIONS[o]
 
434
            r[o.name] = o
 
435
            if o.name in std_names:
 
436
                self.supported_std_options.append(o.name)
 
437
        return r
 
438
 
 
439
    def _setup_outf(self):
 
440
        """Return a file linked to stdout, which has proper encoding."""
 
441
        # Originally I was using self.stdout, but that looks
 
442
        # *way* too much like sys.stdout
 
443
        if self.encoding_type == 'exact':
 
444
            # force sys.stdout to be binary stream on win32
 
445
            if sys.platform == 'win32':
 
446
                fileno = getattr(sys.stdout, 'fileno', None)
 
447
                if fileno:
 
448
                    import msvcrt
 
449
                    msvcrt.setmode(fileno(), os.O_BINARY)
 
450
            self.outf = sys.stdout
 
451
            return
 
452
 
 
453
        output_encoding = osutils.get_terminal_encoding()
 
454
 
 
455
        self.outf = codecs.getwriter(output_encoding)(sys.stdout,
 
456
                        errors=self.encoding_type)
 
457
        # For whatever reason codecs.getwriter() does not advertise its encoding
 
458
        # it just returns the encoding of the wrapped file, which is completely
 
459
        # bogus. So set the attribute, so we can find the correct encoding later.
 
460
        self.outf.encoding = output_encoding
 
461
 
 
462
    def run_argv_aliases(self, argv, alias_argv=None):
 
463
        """Parse the command line and run with extra aliases in alias_argv."""
 
464
        if argv is None:
 
465
            warn("Passing None for [] is deprecated from bzrlib 0.10",
 
466
                 DeprecationWarning, stacklevel=2)
 
467
            argv = []
 
468
        args, opts = parse_args(self, argv, alias_argv)
 
469
 
 
470
        # Process the standard options
 
471
        if 'help' in opts:  # e.g. bzr add --help
 
472
            sys.stdout.write(self.get_help_text())
 
473
            return 0
 
474
        trace.set_verbosity_level(option._verbosity_level)
 
475
        if 'verbose' in self.supported_std_options:
 
476
            opts['verbose'] = trace.is_verbose()
 
477
        elif opts.has_key('verbose'):
 
478
            del opts['verbose']
 
479
        if 'quiet' in self.supported_std_options:
 
480
            opts['quiet'] = trace.is_quiet()
 
481
        elif opts.has_key('quiet'):
 
482
            del opts['quiet']
 
483
 
 
484
        # mix arguments and options into one dictionary
 
485
        cmdargs = _match_argform(self.name(), self.takes_args, args)
 
486
        cmdopts = {}
 
487
        for k, v in opts.items():
 
488
            cmdopts[k.replace('-', '_')] = v
 
489
 
 
490
        all_cmd_args = cmdargs.copy()
 
491
        all_cmd_args.update(cmdopts)
 
492
 
 
493
        self._setup_outf()
 
494
 
 
495
        return self.run(**all_cmd_args)
 
496
 
 
497
    def run(self):
 
498
        """Actually run the command.
 
499
 
 
500
        This is invoked with the options and arguments bound to
 
501
        keyword parameters.
 
502
 
 
503
        Return 0 or None if the command was successful, or a non-zero
 
504
        shell error code if not.  It's OK for this method to allow
 
505
        an exception to raise up.
 
506
        """
 
507
        raise NotImplementedError('no implementation of command %r'
 
508
                                  % self.name())
 
509
 
 
510
    def help(self):
 
511
        """Return help message for this class."""
 
512
        from inspect import getdoc
 
513
        if self.__doc__ is Command.__doc__:
 
514
            return None
 
515
        return getdoc(self)
 
516
 
 
517
    def name(self):
 
518
        return _unsquish_command_name(self.__class__.__name__)
 
519
 
 
520
    def plugin_name(self):
 
521
        """Get the name of the plugin that provides this command.
 
522
 
 
523
        :return: The name of the plugin or None if the command is builtin.
 
524
        """
 
525
        mod_parts = self.__module__.split('.')
 
526
        if len(mod_parts) >= 3 and mod_parts[1] == 'plugins':
 
527
            return mod_parts[2]
 
528
        else:
 
529
            return None
 
530
 
 
531
 
 
532
def parse_args(command, argv, alias_argv=None):
 
533
    """Parse command line.
 
534
    
 
535
    Arguments and options are parsed at this level before being passed
 
536
    down to specific command handlers.  This routine knows, from a
 
537
    lookup table, something about the available options, what optargs
 
538
    they take, and which commands will accept them.
 
539
    """
 
540
    # TODO: make it a method of the Command?
 
541
    parser = option.get_optparser(command.options())
 
542
    if alias_argv is not None:
 
543
        args = alias_argv + argv
 
544
    else:
 
545
        args = argv
 
546
 
 
547
    options, args = parser.parse_args(args)
 
548
    opts = dict([(k, v) for k, v in options.__dict__.iteritems() if
 
549
                 v is not option.OptionParser.DEFAULT_VALUE])
 
550
    return args, opts
 
551
 
 
552
 
 
553
def _match_argform(cmd, takes_args, args):
 
554
    argdict = {}
 
555
 
 
556
    # step through args and takes_args, allowing appropriate 0-many matches
 
557
    for ap in takes_args:
 
558
        argname = ap[:-1]
 
559
        if ap[-1] == '?':
 
560
            if args:
 
561
                argdict[argname] = args.pop(0)
 
562
        elif ap[-1] == '*': # all remaining arguments
 
563
            if args:
 
564
                argdict[argname + '_list'] = args[:]
 
565
                args = []
 
566
            else:
 
567
                argdict[argname + '_list'] = None
 
568
        elif ap[-1] == '+':
 
569
            if not args:
 
570
                raise errors.BzrCommandError("command %r needs one or more %s"
 
571
                                             % (cmd, argname.upper()))
 
572
            else:
 
573
                argdict[argname + '_list'] = args[:]
 
574
                args = []
 
575
        elif ap[-1] == '$': # all but one
 
576
            if len(args) < 2:
 
577
                raise errors.BzrCommandError("command %r needs one or more %s"
 
578
                                             % (cmd, argname.upper()))
 
579
            argdict[argname + '_list'] = args[:-1]
 
580
            args[:-1] = []
 
581
        else:
 
582
            # just a plain arg
 
583
            argname = ap
 
584
            if not args:
 
585
                raise errors.BzrCommandError("command %r requires argument %s"
 
586
                               % (cmd, argname.upper()))
 
587
            else:
 
588
                argdict[argname] = args.pop(0)
 
589
            
 
590
    if args:
 
591
        raise errors.BzrCommandError("extra argument to command %s: %s"
 
592
                                     % (cmd, args[0]))
 
593
 
 
594
    return argdict
 
595
 
 
596
def apply_coveraged(dirname, the_callable, *args, **kwargs):
 
597
    # Cannot use "import trace", as that would import bzrlib.trace instead of
 
598
    # the standard library's trace.
 
599
    trace = __import__('trace')
 
600
 
 
601
    tracer = trace.Trace(count=1, trace=0)
 
602
    sys.settrace(tracer.globaltrace)
 
603
 
 
604
    ret = the_callable(*args, **kwargs)
 
605
 
 
606
    sys.settrace(None)
 
607
    results = tracer.results()
 
608
    results.write_results(show_missing=1, summary=False,
 
609
                          coverdir=dirname)
 
610
 
 
611
 
 
612
def apply_profiled(the_callable, *args, **kwargs):
 
613
    import hotshot
 
614
    import tempfile
 
615
    import hotshot.stats
 
616
    pffileno, pfname = tempfile.mkstemp()
 
617
    try:
 
618
        prof = hotshot.Profile(pfname)
 
619
        try:
 
620
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
 
621
        finally:
 
622
            prof.close()
 
623
        stats = hotshot.stats.load(pfname)
 
624
        stats.strip_dirs()
 
625
        stats.sort_stats('cum')   # 'time'
 
626
        ## XXX: Might like to write to stderr or the trace file instead but
 
627
        ## print_stats seems hardcoded to stdout
 
628
        stats.print_stats(20)
 
629
        return ret
 
630
    finally:
 
631
        os.close(pffileno)
 
632
        os.remove(pfname)
 
633
 
 
634
 
 
635
def apply_lsprofiled(filename, the_callable, *args, **kwargs):
 
636
    from bzrlib.lsprof import profile
 
637
    ret, stats = profile(the_callable, *args, **kwargs)
 
638
    stats.sort()
 
639
    if filename is None:
 
640
        stats.pprint()
 
641
    else:
 
642
        stats.save(filename)
 
643
        trace.note('Profile data written to "%s".', filename)
 
644
    return ret
 
645
 
 
646
 
 
647
def shlex_split_unicode(unsplit):
 
648
    import shlex
 
649
    return [u.decode('utf-8') for u in shlex.split(unsplit.encode('utf-8'))]
 
650
 
 
651
 
 
652
def get_alias(cmd, config=None):
 
653
    """Return an expanded alias, or None if no alias exists.
 
654
 
 
655
    cmd
 
656
        Command to be checked for an alias.
 
657
    config
 
658
        Used to specify an alternative config to use,
 
659
        which is especially useful for testing.
 
660
        If it is unspecified, the global config will be used.
 
661
    """
 
662
    if config is None:
 
663
        import bzrlib.config
 
664
        config = bzrlib.config.GlobalConfig()
 
665
    alias = config.get_alias(cmd)
 
666
    if (alias):
 
667
        return shlex_split_unicode(alias)
 
668
    return None
 
669
 
 
670
 
 
671
def run_bzr(argv):
 
672
    """Execute a command.
 
673
 
 
674
    This is similar to main(), but without all the trappings for
 
675
    logging and error handling.  
 
676
    
 
677
    argv
 
678
       The command-line arguments, without the program name from argv[0]
 
679
       These should already be decoded. All library/test code calling
 
680
       run_bzr should be passing valid strings (don't need decoding).
 
681
    
 
682
    Returns a command status or raises an exception.
 
683
 
 
684
    Special master options: these must come before the command because
 
685
    they control how the command is interpreted.
 
686
 
 
687
    --no-plugins
 
688
        Do not load plugin modules at all
 
689
 
 
690
    --no-aliases
 
691
        Do not allow aliases
 
692
 
 
693
    --builtin
 
694
        Only use builtin commands.  (Plugins are still allowed to change
 
695
        other behaviour.)
 
696
 
 
697
    --profile
 
698
        Run under the Python hotshot profiler.
 
699
 
 
700
    --lsprof
 
701
        Run under the Python lsprof profiler.
 
702
 
 
703
    --coverage
 
704
        Generate line coverage report in the specified directory.
 
705
    """
 
706
    argv = list(argv)
 
707
    trace.mutter("bzr arguments: %r", argv)
 
708
 
 
709
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
 
710
                opt_no_aliases = False
 
711
    opt_lsprof_file = opt_coverage_dir = None
 
712
 
 
713
    # --no-plugins is handled specially at a very early stage. We need
 
714
    # to load plugins before doing other command parsing so that they
 
715
    # can override commands, but this needs to happen first.
 
716
 
 
717
    argv_copy = []
 
718
    i = 0
 
719
    while i < len(argv):
 
720
        a = argv[i]
 
721
        if a == '--profile':
 
722
            opt_profile = True
 
723
        elif a == '--lsprof':
 
724
            opt_lsprof = True
 
725
        elif a == '--lsprof-file':
 
726
            opt_lsprof = True
 
727
            opt_lsprof_file = argv[i + 1]
 
728
            i += 1
 
729
        elif a == '--no-plugins':
 
730
            opt_no_plugins = True
 
731
        elif a == '--no-aliases':
 
732
            opt_no_aliases = True
 
733
        elif a == '--builtin':
 
734
            opt_builtin = True
 
735
        elif a == '--coverage':
 
736
            opt_coverage_dir = argv[i + 1]
 
737
            i += 1
 
738
        elif a.startswith('-D'):
 
739
            debug.debug_flags.add(a[2:])
 
740
        else:
 
741
            argv_copy.append(a)
 
742
        i += 1
 
743
 
 
744
    argv = argv_copy
 
745
    if (not argv):
 
746
        from bzrlib.builtins import cmd_help
 
747
        cmd_help().run_argv_aliases([])
 
748
        return 0
 
749
 
 
750
    if argv[0] == '--version':
 
751
        from bzrlib.builtins import cmd_version
 
752
        cmd_version().run_argv_aliases([])
 
753
        return 0
 
754
        
 
755
    if not opt_no_plugins:
 
756
        from bzrlib.plugin import load_plugins
 
757
        load_plugins()
 
758
    else:
 
759
        from bzrlib.plugin import disable_plugins
 
760
        disable_plugins()
 
761
 
 
762
    alias_argv = None
 
763
 
 
764
    if not opt_no_aliases:
 
765
        alias_argv = get_alias(argv[0])
 
766
        if alias_argv:
 
767
            user_encoding = osutils.get_user_encoding()
 
768
            alias_argv = [a.decode(user_encoding) for a in alias_argv]
 
769
            argv[0] = alias_argv.pop(0)
 
770
 
 
771
    cmd = argv.pop(0)
 
772
    # We want only 'ascii' command names, but the user may have typed
 
773
    # in a Unicode name. In that case, they should just get a
 
774
    # 'command not found' error later.
 
775
 
 
776
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
 
777
    run = cmd_obj.run_argv_aliases
 
778
    run_argv = [argv, alias_argv]
 
779
 
 
780
    try:
 
781
        if opt_lsprof:
 
782
            if opt_coverage_dir:
 
783
                trace.warning(
 
784
                    '--coverage ignored, because --lsprof is in use.')
 
785
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
 
786
        elif opt_profile:
 
787
            if opt_coverage_dir:
 
788
                trace.warning(
 
789
                    '--coverage ignored, because --profile is in use.')
 
790
            ret = apply_profiled(run, *run_argv)
 
791
        elif opt_coverage_dir:
 
792
            ret = apply_coveraged(opt_coverage_dir, run, *run_argv)
 
793
        else:
 
794
            ret = run(*run_argv)
 
795
        if 'memory' in debug.debug_flags:
 
796
            trace.debug_memory('Process status after command:', short=False)
 
797
        return ret or 0
 
798
    finally:
 
799
        # reset, in case we may do other commands later within the same process
 
800
        option._verbosity_level = 0
 
801
 
 
802
def display_command(func):
 
803
    """Decorator that suppresses pipe/interrupt errors."""
 
804
    def ignore_pipe(*args, **kwargs):
 
805
        try:
 
806
            result = func(*args, **kwargs)
 
807
            sys.stdout.flush()
 
808
            return result
 
809
        except IOError, e:
 
810
            if getattr(e, 'errno', None) is None:
 
811
                raise
 
812
            if e.errno != errno.EPIPE:
 
813
                # Win32 raises IOError with errno=0 on a broken pipe
 
814
                if sys.platform != 'win32' or (e.errno not in (0, errno.EINVAL)):
 
815
                    raise
 
816
            pass
 
817
        except KeyboardInterrupt:
 
818
            pass
 
819
    return ignore_pipe
 
820
 
 
821
 
 
822
def main(argv):
 
823
    import bzrlib.ui
 
824
    from bzrlib.ui.text import TextUIFactory
 
825
    bzrlib.ui.ui_factory = TextUIFactory()
 
826
     
 
827
    # Is this a final release version? If so, we should suppress warnings
 
828
    if bzrlib.version_info[3] == 'final':
 
829
        from bzrlib import symbol_versioning
 
830
        symbol_versioning.suppress_deprecation_warnings(override=False)
 
831
    try:
 
832
        user_encoding = osutils.get_user_encoding()
 
833
        argv = [a.decode(user_encoding) for a in argv[1:]]
 
834
    except UnicodeDecodeError:
 
835
        raise errors.BzrError(("Parameter '%r' is unsupported by the current "
 
836
                                                            "encoding." % a))
 
837
    ret = run_bzr_catch_errors(argv)
 
838
    trace.mutter("return code %d", ret)
 
839
    return ret
 
840
 
 
841
 
 
842
def run_bzr_catch_errors(argv):
 
843
    # Note: The except clause logic below should be kept in sync with the
 
844
    # profile() routine in lsprof.py.
 
845
    try:
 
846
        return run_bzr(argv)
 
847
    except (KeyboardInterrupt, Exception), e:
 
848
        # used to handle AssertionError and KeyboardInterrupt
 
849
        # specially here, but hopefully they're handled ok by the logger now
 
850
        exitcode = trace.report_exception(sys.exc_info(), sys.stderr)
 
851
        if os.environ.get('BZR_PDB'):
 
852
            print '**** entering debugger'
 
853
            import pdb
 
854
            pdb.post_mortem(sys.exc_traceback)
 
855
        return exitcode
 
856
 
 
857
 
 
858
def run_bzr_catch_user_errors(argv):
 
859
    """Run bzr and report user errors, but let internal errors propagate.
 
860
 
 
861
    This is used for the test suite, and might be useful for other programs
 
862
    that want to wrap the commandline interface.
 
863
    """
 
864
    try:
 
865
        return run_bzr(argv)
 
866
    except Exception, e:
 
867
        if (isinstance(e, (OSError, IOError))
 
868
            or not getattr(e, 'internal_error', True)):
 
869
            trace.report_exception(sys.exc_info(), sys.stderr)
 
870
            return 3
 
871
        else:
 
872
            raise
 
873
 
 
874
 
 
875
class HelpCommandIndex(object):
 
876
    """A index for bzr help that returns commands."""
 
877
 
 
878
    def __init__(self):
 
879
        self.prefix = 'commands/'
 
880
 
 
881
    def get_topics(self, topic):
 
882
        """Search for topic amongst commands.
 
883
 
 
884
        :param topic: A topic to search for.
 
885
        :return: A list which is either empty or contains a single
 
886
            Command entry.
 
887
        """
 
888
        if topic and topic.startswith(self.prefix):
 
889
            topic = topic[len(self.prefix):]
 
890
        try:
 
891
            cmd = _get_cmd_object(topic)
 
892
        except KeyError:
 
893
            return []
 
894
        else:
 
895
            return [cmd]
 
896
 
 
897
 
 
898
class Provider(object):
 
899
    '''Generic class to be overriden by plugins'''
 
900
 
 
901
    def plugin_for_command(self, cmd_name):
 
902
        '''Takes a command and returns the information for that plugin
 
903
        
 
904
        :return: A dictionary with all the available information 
 
905
        for the requested plugin
 
906
        '''
 
907
        raise NotImplementedError
 
908
 
 
909
 
 
910
class ProvidersRegistry(registry.Registry):
 
911
    '''This registry exists to allow other providers to exist'''
 
912
 
 
913
    def __iter__(self):
 
914
        for key, provider in self.iteritems():
 
915
            yield provider
 
916
 
 
917
command_providers_registry = ProvidersRegistry()
 
918
 
 
919
 
 
920
if __name__ == '__main__':
 
921
    sys.exit(main(sys.argv))