/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

More work on roundtrip push support.

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