/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

Functional get_record_stream interface tests covering full interface.

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