~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: John Arbash Meinel
  • Date: 2007-10-17 17:03:06 UTC
  • mto: This revision was merged to the branch mainline in revision 2918.
  • Revision ID: john@arbash-meinel.com-20071017170306-20w50sk1djh0i14k
Switch around to properly look up the executable bit in the basis.
We do this with a load-time switch around supports_executable(), rather than
a runtime if supports_executable() check.
It would be nice to inline the _is_executable_* check on platforms that support
executable, but we had a function call before, so we haven't degraded
performance.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2004, 2005 by Canonical Ltd
2
 
 
 
1
# Copyright (C) 2006 Canonical Ltd
 
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
5
5
# the Free Software Foundation; either version 2 of the License, or
6
6
# (at your option) any later version.
7
 
 
 
7
#
8
8
# This program is distributed in the hope that it will be useful,
9
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
11
11
# GNU General Public License for more details.
12
 
 
 
12
#
13
13
# You should have received a copy of the GNU General Public License
14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
18
18
# TODO: probably should say which arguments are candidates for glob
19
19
# expansion on windows and do that at the command level.
20
20
 
21
 
# TODO: Help messages for options.
22
 
 
23
 
# TODO: Define arguments by objects, rather than just using names.
24
 
# Those objects can specify the expected type of the argument, which
25
 
# would help with validation and shell completion.
26
 
 
27
 
 
28
 
# TODO: Help messages for options.
29
 
 
30
 
# TODO: Define arguments by objects, rather than just using names.
31
 
# Those objects can specify the expected type of the argument, which
32
 
# would help with validation and shell completion.
33
 
 
34
 
 
35
 
 
 
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
36
32
import sys
37
 
import os
 
33
 
 
34
from bzrlib.lazy_import import lazy_import
 
35
lazy_import(globals(), """
 
36
import codecs
 
37
import errno
38
38
from warnings import warn
39
 
from inspect import getdoc
40
39
 
41
40
import bzrlib
42
 
import bzrlib.trace
43
 
from bzrlib.trace import mutter, note, log_error, warning
44
 
from bzrlib.errors import BzrError, BzrCheckError, BzrCommandError, NotBranchError
45
 
from bzrlib.branch import find_branch
46
 
from bzrlib import BZRDIR
 
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
 
47
58
 
48
59
plugin_cmds = {}
49
60
 
50
61
 
51
 
def register_command(cmd):
52
 
    "Utility function to help register a command"
 
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
    """
53
70
    global plugin_cmds
54
71
    k = cmd.__name__
55
72
    if k.startswith("cmd_"):
56
73
        k_unsquished = _unsquish_command_name(k)
57
74
    else:
58
75
        k_unsquished = k
59
 
    if not plugin_cmds.has_key(k_unsquished):
60
 
        plugin_cmds[k_unsquished] = cmd
61
 
        mutter('registered plugin command %s', k_unsquished)      
 
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
62
85
    else:
63
 
        log_error('Two plugins defined the same command: %r' % k)
64
 
        log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
 
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__])
65
90
 
66
91
 
67
92
def _squish_command_name(cmd):
73
98
    return cmd[4:].replace('_','-')
74
99
 
75
100
 
76
 
def _parse_revision_str(revstr):
77
 
    """This handles a revision string -> revno.
78
 
 
79
 
    This always returns a list.  The list will have one element for 
80
 
 
81
 
    It supports integers directly, but everything else it
82
 
    defers for passing to Branch.get_revision_info()
83
 
 
84
 
    >>> _parse_revision_str('234')
85
 
    [234]
86
 
    >>> _parse_revision_str('234..567')
87
 
    [234, 567]
88
 
    >>> _parse_revision_str('..')
89
 
    [None, None]
90
 
    >>> _parse_revision_str('..234')
91
 
    [None, 234]
92
 
    >>> _parse_revision_str('234..')
93
 
    [234, None]
94
 
    >>> _parse_revision_str('234..456..789') # Maybe this should be an error
95
 
    [234, 456, 789]
96
 
    >>> _parse_revision_str('234....789') # Error?
97
 
    [234, None, 789]
98
 
    >>> _parse_revision_str('revid:test@other.com-234234')
99
 
    ['revid:test@other.com-234234']
100
 
    >>> _parse_revision_str('revid:test@other.com-234234..revid:test@other.com-234235')
101
 
    ['revid:test@other.com-234234', 'revid:test@other.com-234235']
102
 
    >>> _parse_revision_str('revid:test@other.com-234234..23')
103
 
    ['revid:test@other.com-234234', 23]
104
 
    >>> _parse_revision_str('date:2005-04-12')
105
 
    ['date:2005-04-12']
106
 
    >>> _parse_revision_str('date:2005-04-12 12:24:33')
107
 
    ['date:2005-04-12 12:24:33']
108
 
    >>> _parse_revision_str('date:2005-04-12T12:24:33')
109
 
    ['date:2005-04-12T12:24:33']
110
 
    >>> _parse_revision_str('date:2005-04-12,12:24:33')
111
 
    ['date:2005-04-12,12:24:33']
112
 
    >>> _parse_revision_str('-5..23')
113
 
    [-5, 23]
114
 
    >>> _parse_revision_str('-5')
115
 
    [-5]
116
 
    >>> _parse_revision_str('123a')
117
 
    ['123a']
118
 
    >>> _parse_revision_str('abc')
119
 
    ['abc']
120
 
    """
121
 
    import re
122
 
    old_format_re = re.compile('\d*:\d*')
123
 
    m = old_format_re.match(revstr)
124
 
    if m:
125
 
        warning('Colon separator for revision numbers is deprecated.'
126
 
                ' Use .. instead')
127
 
        revs = []
128
 
        for rev in revstr.split(':'):
129
 
            if rev:
130
 
                revs.append(int(rev))
131
 
            else:
132
 
                revs.append(None)
133
 
        return revs
134
 
    revs = []
135
 
    for x in revstr.split('..'):
136
 
        if not x:
137
 
            revs.append(None)
138
 
        else:
139
 
            try:
140
 
                revs.append(int(x))
141
 
            except ValueError:
142
 
                revs.append(x)
143
 
    return revs
144
 
 
145
 
 
146
 
def get_merge_type(typestring):
147
 
    """Attempt to find the merge class/factory associated with a string."""
148
 
    from merge import merge_types
149
 
    try:
150
 
        return merge_types[typestring][0]
151
 
    except KeyError:
152
 
        templ = '%s%%7s: %%s' % (' '*12)
153
 
        lines = [templ % (f[0], f[1][1]) for f in merge_types.iteritems()]
154
 
        type_list = '\n'.join(lines)
155
 
        msg = "No known merge type %s. Supported types are:\n%s" %\
156
 
            (typestring, type_list)
157
 
        raise BzrCommandError(msg)
158
 
 
159
 
 
160
101
def _builtin_commands():
161
102
    import bzrlib.builtins
162
103
    r = {}
163
104
    builtins = bzrlib.builtins.__dict__
164
105
    for name in builtins:
165
106
        if name.startswith("cmd_"):
166
 
            real_name = _unsquish_command_name(name)        
 
107
            real_name = _unsquish_command_name(name)
167
108
            r[real_name] = builtins[name]
168
109
    return r
169
 
 
170
110
            
171
111
 
172
112
def builtin_command_names():
198
138
    plugins_override
199
139
        If true, plugin commands can override builtins.
200
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."""
201
149
    from bzrlib.externalcommand import ExternalCommand
202
150
 
203
 
    cmd_name = str(cmd_name)            # not unicode
 
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.
204
155
 
205
156
    # first look up this command under the specified name
206
157
    cmds = _get_cmd_dict(plugins_override=plugins_override)
217
168
    cmd_obj = ExternalCommand.find_command(cmd_name)
218
169
    if cmd_obj:
219
170
        return cmd_obj
220
 
 
221
 
    raise BzrCommandError("unknown command %r" % cmd_name)
 
171
    raise KeyError
222
172
 
223
173
 
224
174
class Command(object):
246
196
        List of argument forms, marked with whether they are optional,
247
197
        repeated, etc.
248
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
 
249
207
    takes_options
250
 
        List of options that may be given for this command.
 
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().
251
211
 
252
212
    hidden
253
213
        If true, this command isn't advertised.  This is typically
254
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
 
255
231
    """
256
232
    aliases = []
257
 
    
258
233
    takes_args = []
259
234
    takes_options = []
 
235
    encoding_type = 'strict'
260
236
 
261
237
    hidden = False
262
238
    
264
240
        """Construct an instance of this command."""
265
241
        if self.__doc__ == Command.__doc__:
266
242
            warn("No help message set for %r" % self)
267
 
 
268
 
 
269
 
    def run_argv(self, argv):
270
 
        """Parse command line and run."""
271
 
        args, opts = parse_args(argv)
272
 
 
 
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
273
468
        if 'help' in opts:  # e.g. bzr add --help
274
 
            from bzrlib.help import help_on_command
275
 
            help_on_command(self.name())
 
469
            sys.stdout.write(self.get_help_text())
276
470
            return 0
277
 
 
278
 
        # check options are reasonable
279
 
        allowed = self.takes_options
280
 
        for oname in opts:
281
 
            if oname not in allowed:
282
 
                raise BzrCommandError("option '--%s' is not allowed for command %r"
283
 
                                      % (oname, self.name()))
 
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']
284
480
 
285
481
        # mix arguments and options into one dictionary
286
482
        cmdargs = _match_argform(self.name(), self.takes_args, args)
291
487
        all_cmd_args = cmdargs.copy()
292
488
        all_cmd_args.update(cmdopts)
293
489
 
 
490
        self._setup_outf()
 
491
 
294
492
        return self.run(**all_cmd_args)
295
 
 
296
493
    
297
494
    def run(self):
298
495
        """Actually run the command.
304
501
        shell error code if not.  It's OK for this method to allow
305
502
        an exception to raise up.
306
503
        """
307
 
        raise NotImplementedError()
308
 
 
 
504
        raise NotImplementedError('no implementation of command %r'
 
505
                                  % self.name())
309
506
 
310
507
    def help(self):
311
508
        """Return help message for this class."""
 
509
        from inspect import getdoc
312
510
        if self.__doc__ is Command.__doc__:
313
511
            return None
314
512
        return getdoc(self)
316
514
    def name(self):
317
515
        return _unsquish_command_name(self.__class__.__name__)
318
516
 
 
517
    def plugin_name(self):
 
518
        """Get the name of the plugin that provides this command.
319
519
 
320
 
def parse_spec(spec):
321
 
    """
322
 
    >>> parse_spec(None)
323
 
    [None, None]
324
 
    >>> parse_spec("./")
325
 
    ['./', None]
326
 
    >>> parse_spec("../@")
327
 
    ['..', -1]
328
 
    >>> parse_spec("../f/@35")
329
 
    ['../f', 35]
330
 
    >>> parse_spec('./@revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67')
331
 
    ['.', 'revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67']
332
 
    """
333
 
    if spec is None:
334
 
        return [None, None]
335
 
    if '/@' in spec:
336
 
        parsed = spec.split('/@')
337
 
        assert len(parsed) == 2
338
 
        if parsed[1] == "":
339
 
            parsed[1] = -1
 
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]
340
525
        else:
341
 
            try:
342
 
                parsed[1] = int(parsed[1])
343
 
            except ValueError:
344
 
                pass # We can allow stuff like ./@revid:blahblahblah
345
 
            else:
346
 
                assert parsed[1] >=0
347
 
    else:
348
 
        parsed = [spec, None]
349
 
    return parsed
350
 
 
351
 
 
352
 
# list of all available options; the rhs can be either None for an
353
 
# option that takes no argument, or a constructor function that checks
354
 
# the type.
355
 
OPTIONS = {
356
 
    'all':                    None,
357
 
    'diff-options':           str,
358
 
    'help':                   None,
359
 
    'file':                   unicode,
360
 
    'force':                  None,
361
 
    'format':                 unicode,
362
 
    'forward':                None,
363
 
    'message':                unicode,
364
 
    'no-recurse':             None,
365
 
    'profile':                None,
366
 
    'revision':               _parse_revision_str,
367
 
    'short':                  None,
368
 
    'show-ids':               None,
369
 
    'timezone':               str,
370
 
    'verbose':                None,
371
 
    'version':                None,
372
 
    'email':                  None,
373
 
    'unchanged':              None,
374
 
    'update':                 None,
375
 
    'long':                   None,
376
 
    'root':                   str,
377
 
    'no-backup':              None,
378
 
    'merge-type':             get_merge_type,
379
 
    'pattern':                str,
380
 
    }
381
 
 
382
 
SHORT_OPTIONS = {
383
 
    'F':                      'file', 
384
 
    'h':                      'help',
385
 
    'm':                      'message',
386
 
    'r':                      'revision',
387
 
    'v':                      'verbose',
388
 
    'l':                      'long',
389
 
}
390
 
 
391
 
 
392
 
def parse_args(argv):
 
526
            return None
 
527
 
 
528
 
 
529
def parse_args(command, argv, alias_argv=None):
393
530
    """Parse command line.
394
531
    
395
532
    Arguments and options are parsed at this level before being passed
396
533
    down to specific command handlers.  This routine knows, from a
397
534
    lookup table, something about the available options, what optargs
398
535
    they take, and which commands will accept them.
399
 
 
400
 
    >>> parse_args('--help'.split())
401
 
    ([], {'help': True})
402
 
    >>> parse_args('help -- --invalidcmd'.split())
403
 
    (['help', '--invalidcmd'], {})
404
 
    >>> parse_args('--version'.split())
405
 
    ([], {'version': True})
406
 
    >>> parse_args('status --all'.split())
407
 
    (['status'], {'all': True})
408
 
    >>> parse_args('commit --message=biter'.split())
409
 
    (['commit'], {'message': u'biter'})
410
 
    >>> parse_args('log -r 500'.split())
411
 
    (['log'], {'revision': [500]})
412
 
    >>> parse_args('log -r500..600'.split())
413
 
    (['log'], {'revision': [500, 600]})
414
 
    >>> parse_args('log -vr500..600'.split())
415
 
    (['log'], {'verbose': True, 'revision': [500, 600]})
416
 
    >>> parse_args('log -rv500..600'.split()) #the r takes an argument
417
 
    (['log'], {'revision': ['v500', 600]})
418
536
    """
419
 
    args = []
420
 
    opts = {}
421
 
 
422
 
    argsover = False
423
 
    while argv:
424
 
        a = argv.pop(0)
425
 
        if not argsover and a[0] == '-':
426
 
            # option names must not be unicode
427
 
            a = str(a)
428
 
            optarg = None
429
 
            if a[1] == '-':
430
 
                if a == '--':
431
 
                    # We've received a standalone -- No more flags
432
 
                    argsover = True
433
 
                    continue
434
 
                mutter("  got option %r" % a)
435
 
                if '=' in a:
436
 
                    optname, optarg = a[2:].split('=', 1)
437
 
                else:
438
 
                    optname = a[2:]
439
 
                if optname not in OPTIONS:
440
 
                    raise BzrError('unknown long option %r' % a)
441
 
            else:
442
 
                shortopt = a[1:]
443
 
                if shortopt in SHORT_OPTIONS:
444
 
                    # Multi-character options must have a space to delimit
445
 
                    # their value
446
 
                    optname = SHORT_OPTIONS[shortopt]
447
 
                else:
448
 
                    # Single character short options, can be chained,
449
 
                    # and have their value appended to their name
450
 
                    shortopt = a[1:2]
451
 
                    if shortopt not in SHORT_OPTIONS:
452
 
                        # We didn't find the multi-character name, and we
453
 
                        # didn't find the single char name
454
 
                        raise BzrError('unknown short option %r' % a)
455
 
                    optname = SHORT_OPTIONS[shortopt]
456
 
 
457
 
                    if a[2:]:
458
 
                        # There are extra things on this option
459
 
                        # see if it is the value, or if it is another
460
 
                        # short option
461
 
                        optargfn = OPTIONS[optname]
462
 
                        if optargfn is None:
463
 
                            # This option does not take an argument, so the
464
 
                            # next entry is another short option, pack it back
465
 
                            # into the list
466
 
                            argv.insert(0, '-' + a[2:])
467
 
                        else:
468
 
                            # This option takes an argument, so pack it
469
 
                            # into the array
470
 
                            optarg = a[2:]
471
 
            
472
 
            if optname in opts:
473
 
                # XXX: Do we ever want to support this, e.g. for -r?
474
 
                raise BzrError('repeated option %r' % a)
475
 
                
476
 
            optargfn = OPTIONS[optname]
477
 
            if optargfn:
478
 
                if optarg == None:
479
 
                    if not argv:
480
 
                        raise BzrError('option %r needs an argument' % a)
481
 
                    else:
482
 
                        optarg = argv.pop(0)
483
 
                opts[optname] = optargfn(optarg)
484
 
            else:
485
 
                if optarg != None:
486
 
                    raise BzrError('option %r takes no argument' % optname)
487
 
                opts[optname] = True
488
 
        else:
489
 
            args.append(a)
490
 
 
 
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])
491
547
    return args, opts
492
548
 
493
549
 
494
 
 
495
 
 
496
550
def _match_argform(cmd, takes_args, args):
497
551
    argdict = {}
498
552
 
510
564
                argdict[argname + '_list'] = None
511
565
        elif ap[-1] == '+':
512
566
            if not args:
513
 
                raise BzrCommandError("command %r needs one or more %s"
514
 
                        % (cmd, argname.upper()))
 
567
                raise errors.BzrCommandError("command %r needs one or more %s"
 
568
                                             % (cmd, argname.upper()))
515
569
            else:
516
570
                argdict[argname + '_list'] = args[:]
517
571
                args = []
518
572
        elif ap[-1] == '$': # all but one
519
573
            if len(args) < 2:
520
 
                raise BzrCommandError("command %r needs one or more %s"
521
 
                        % (cmd, argname.upper()))
 
574
                raise errors.BzrCommandError("command %r needs one or more %s"
 
575
                                             % (cmd, argname.upper()))
522
576
            argdict[argname + '_list'] = args[:-1]
523
 
            args[:-1] = []                
 
577
            args[:-1] = []
524
578
        else:
525
579
            # just a plain arg
526
580
            argname = ap
527
581
            if not args:
528
 
                raise BzrCommandError("command %r requires argument %s"
529
 
                        % (cmd, argname.upper()))
 
582
                raise errors.BzrCommandError("command %r requires argument %s"
 
583
                               % (cmd, argname.upper()))
530
584
            else:
531
585
                argdict[argname] = args.pop(0)
532
586
            
533
587
    if args:
534
 
        raise BzrCommandError("extra argument to command %s: %s"
535
 
                              % (cmd, args[0]))
 
588
        raise errors.BzrCommandError("extra argument to command %s: %s"
 
589
                                     % (cmd, args[0]))
536
590
 
537
591
    return argdict
538
592
 
541
595
def apply_profiled(the_callable, *args, **kwargs):
542
596
    import hotshot
543
597
    import tempfile
 
598
    import hotshot.stats
544
599
    pffileno, pfname = tempfile.mkstemp()
545
600
    try:
546
601
        prof = hotshot.Profile(pfname)
548
603
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
549
604
        finally:
550
605
            prof.close()
551
 
 
552
 
        import hotshot.stats
553
606
        stats = hotshot.stats.load(pfname)
554
 
        #stats.strip_dirs()
555
 
        stats.sort_stats('time')
 
607
        stats.strip_dirs()
 
608
        stats.sort_stats('cum')   # 'time'
556
609
        ## XXX: Might like to write to stderr or the trace file instead but
557
610
        ## print_stats seems hardcoded to stdout
558
611
        stats.print_stats(20)
559
 
 
560
612
        return ret
561
613
    finally:
562
614
        os.close(pffileno)
563
615
        os.remove(pfname)
564
616
 
565
617
 
 
618
def apply_lsprofiled(filename, the_callable, *args, **kwargs):
 
619
    from bzrlib.lsprof import profile
 
620
    ret, stats = profile(the_callable, *args, **kwargs)
 
621
    stats.sort()
 
622
    if filename is None:
 
623
        stats.pprint()
 
624
    else:
 
625
        stats.save(filename)
 
626
        trace.note('Profile data written to "%s".', filename)
 
627
    return ret
 
628
 
 
629
 
 
630
def get_alias(cmd, config=None):
 
631
    """Return an expanded alias, or None if no alias exists.
 
632
 
 
633
    cmd
 
634
        Command to be checked for an alias.
 
635
    config
 
636
        Used to specify an alternative config to use,
 
637
        which is especially useful for testing.
 
638
        If it is unspecified, the global config will be used.
 
639
    """
 
640
    if config is None:
 
641
        import bzrlib.config
 
642
        config = bzrlib.config.GlobalConfig()
 
643
    alias = config.get_alias(cmd)
 
644
    if (alias):
 
645
        import shlex
 
646
        return [a.decode('utf-8') for a in shlex.split(alias.encode('utf-8'))]
 
647
    return None
 
648
 
 
649
 
566
650
def run_bzr(argv):
567
651
    """Execute a command.
568
652
 
571
655
    
572
656
    argv
573
657
       The command-line arguments, without the program name from argv[0]
 
658
       These should already be decoded. All library/test code calling
 
659
       run_bzr should be passing valid strings (don't need decoding).
574
660
    
575
661
    Returns a command status or raises an exception.
576
662
 
580
666
    --no-plugins
581
667
        Do not load plugin modules at all
582
668
 
 
669
    --no-aliases
 
670
        Do not allow aliases
 
671
 
583
672
    --builtin
584
673
        Only use builtin commands.  (Plugins are still allowed to change
585
674
        other behaviour.)
586
675
 
587
676
    --profile
588
 
        Run under the Python profiler.
 
677
        Run under the Python hotshot profiler.
 
678
 
 
679
    --lsprof
 
680
        Run under the Python lsprof profiler.
589
681
    """
590
 
    # Load all of the transport methods
591
 
    import bzrlib.transport.local, bzrlib.transport.http
592
 
    
593
 
    argv = [a.decode(bzrlib.user_encoding) for a in argv]
 
682
    argv = list(argv)
 
683
    trace.mutter("bzr arguments: %r", argv)
594
684
 
595
 
    opt_profile = opt_no_plugins = opt_builtin = False
 
685
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
 
686
                opt_no_aliases = False
 
687
    opt_lsprof_file = None
596
688
 
597
689
    # --no-plugins is handled specially at a very early stage. We need
598
690
    # to load plugins before doing other command parsing so that they
599
691
    # can override commands, but this needs to happen first.
600
692
 
601
 
    for a in argv:
 
693
    argv_copy = []
 
694
    i = 0
 
695
    while i < len(argv):
 
696
        a = argv[i]
602
697
        if a == '--profile':
603
698
            opt_profile = True
 
699
        elif a == '--lsprof':
 
700
            opt_lsprof = True
 
701
        elif a == '--lsprof-file':
 
702
            opt_lsprof = True
 
703
            opt_lsprof_file = argv[i + 1]
 
704
            i += 1
604
705
        elif a == '--no-plugins':
605
706
            opt_no_plugins = True
 
707
        elif a == '--no-aliases':
 
708
            opt_no_aliases = True
606
709
        elif a == '--builtin':
607
710
            opt_builtin = True
 
711
        elif a.startswith('-D'):
 
712
            debug.debug_flags.add(a[2:])
608
713
        else:
609
 
            break
610
 
        argv.remove(a)
 
714
            argv_copy.append(a)
 
715
        i += 1
611
716
 
612
 
    if (not argv) or (argv[0] == '--help'):
613
 
        from bzrlib.help import help
614
 
        if len(argv) > 1:
615
 
            help(argv[1])
616
 
        else:
617
 
            help()
 
717
    argv = argv_copy
 
718
    if (not argv):
 
719
        from bzrlib.builtins import cmd_help
 
720
        cmd_help().run_argv_aliases([])
618
721
        return 0
619
722
 
620
723
    if argv[0] == '--version':
621
 
        from bzrlib.builtins import show_version
622
 
        show_version()
 
724
        from bzrlib.builtins import cmd_version
 
725
        cmd_version().run_argv_aliases([])
623
726
        return 0
624
727
        
625
728
    if not opt_no_plugins:
626
729
        from bzrlib.plugin import load_plugins
627
730
        load_plugins()
628
 
 
629
 
    cmd = str(argv.pop(0))
 
731
    else:
 
732
        from bzrlib.plugin import disable_plugins
 
733
        disable_plugins()
 
734
 
 
735
    alias_argv = None
 
736
 
 
737
    if not opt_no_aliases:
 
738
        alias_argv = get_alias(argv[0])
 
739
        if alias_argv:
 
740
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
 
741
            argv[0] = alias_argv.pop(0)
 
742
 
 
743
    cmd = argv.pop(0)
 
744
    # We want only 'ascii' command names, but the user may have typed
 
745
    # in a Unicode name. In that case, they should just get a
 
746
    # 'command not found' error later.
630
747
 
631
748
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
632
 
 
633
 
    if opt_profile:
634
 
        ret = apply_profiled(cmd_obj.run_argv, argv)
635
 
    else:
636
 
        ret = cmd_obj.run_argv(argv)
637
 
    return ret or 0
 
749
    run = cmd_obj.run_argv_aliases
 
750
    run_argv = [argv, alias_argv]
 
751
 
 
752
    try:
 
753
        if opt_lsprof:
 
754
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
 
755
        elif opt_profile:
 
756
            ret = apply_profiled(run, *run_argv)
 
757
        else:
 
758
            ret = run(*run_argv)
 
759
        return ret or 0
 
760
    finally:
 
761
        # reset, in case we may do other commands later within the same process
 
762
        option._verbosity_level = 0
 
763
 
 
764
def display_command(func):
 
765
    """Decorator that suppresses pipe/interrupt errors."""
 
766
    def ignore_pipe(*args, **kwargs):
 
767
        try:
 
768
            result = func(*args, **kwargs)
 
769
            sys.stdout.flush()
 
770
            return result
 
771
        except IOError, e:
 
772
            if getattr(e, 'errno', None) is None:
 
773
                raise
 
774
            if e.errno != errno.EPIPE:
 
775
                # Win32 raises IOError with errno=0 on a broken pipe
 
776
                if sys.platform != 'win32' or (e.errno not in (0, errno.EINVAL)):
 
777
                    raise
 
778
            pass
 
779
        except KeyboardInterrupt:
 
780
            pass
 
781
    return ignore_pipe
638
782
 
639
783
 
640
784
def main(argv):
641
785
    import bzrlib.ui
642
 
    bzrlib.trace.log_startup(argv)
643
 
    bzrlib.ui.ui_factory = bzrlib.ui.TextUIFactory()
644
 
 
645
 
    try:
646
 
        try:
647
 
            try:
648
 
                return run_bzr(argv[1:])
649
 
            finally:
650
 
                # do this here inside the exception wrappers to catch EPIPE
651
 
                sys.stdout.flush()
652
 
        #wrap common errors as CommandErrors.
653
 
        except (NotBranchError,), e:
654
 
            raise BzrCommandError(str(e))
655
 
    except BzrCommandError, e:
656
 
        # command line syntax error, etc
657
 
        log_error(str(e))
658
 
        return 1
659
 
    except BzrError, e:
660
 
        bzrlib.trace.log_exception()
661
 
        return 1
662
 
    except AssertionError, e:
663
 
        bzrlib.trace.log_exception('assertion failed: ' + str(e))
664
 
        return 3
665
 
    except KeyboardInterrupt, e:
666
 
        bzrlib.trace.note('interrupted')
667
 
        return 2
 
786
    from bzrlib.ui.text import TextUIFactory
 
787
    bzrlib.ui.ui_factory = TextUIFactory()
 
788
    try:
 
789
        argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
 
790
    except UnicodeDecodeError:
 
791
        raise errors.BzrError(("Parameter '%r' is unsupported by the current "
 
792
                                                            "encoding." % a))
 
793
    ret = run_bzr_catch_errors(argv)
 
794
    trace.mutter("return code %d", ret)
 
795
    return ret
 
796
 
 
797
 
 
798
def run_bzr_catch_errors(argv):
 
799
    # Note: The except clause logic below should be kept in sync with the
 
800
    # profile() routine in lsprof.py.
 
801
    try:
 
802
        return run_bzr(argv)
 
803
    except (KeyboardInterrupt, Exception), e:
 
804
        # used to handle AssertionError and KeyboardInterrupt
 
805
        # specially here, but hopefully they're handled ok by the logger now
 
806
        exitcode = trace.report_exception(sys.exc_info(), sys.stderr)
 
807
        if os.environ.get('BZR_PDB'):
 
808
            print '**** entering debugger'
 
809
            import pdb
 
810
            pdb.post_mortem(sys.exc_traceback)
 
811
        return exitcode
 
812
 
 
813
 
 
814
def run_bzr_catch_user_errors(argv):
 
815
    """Run bzr and report user errors, but let internal errors propagate.
 
816
 
 
817
    This is used for the test suite, and might be useful for other programs
 
818
    that want to wrap the commandline interface.
 
819
    """
 
820
    try:
 
821
        return run_bzr(argv)
668
822
    except Exception, e:
669
 
        import errno
670
 
        if (isinstance(e, IOError) 
671
 
            and hasattr(e, 'errno')
672
 
            and e.errno == errno.EPIPE):
673
 
            bzrlib.trace.note('broken pipe')
674
 
            return 2
675
 
        else:
676
 
            bzrlib.trace.log_exception()
677
 
            return 2
 
823
        if (isinstance(e, (OSError, IOError))
 
824
            or not getattr(e, 'internal_error', True)):
 
825
            trace.report_exception(sys.exc_info(), sys.stderr)
 
826
            return 3
 
827
        else:
 
828
            raise
 
829
 
 
830
 
 
831
class HelpCommandIndex(object):
 
832
    """A index for bzr help that returns commands."""
 
833
 
 
834
    def __init__(self):
 
835
        self.prefix = 'commands/'
 
836
 
 
837
    def get_topics(self, topic):
 
838
        """Search for topic amongst commands.
 
839
 
 
840
        :param topic: A topic to search for.
 
841
        :return: A list which is either empty or contains a single
 
842
            Command entry.
 
843
        """
 
844
        if topic and topic.startswith(self.prefix):
 
845
            topic = topic[len(self.prefix):]
 
846
        try:
 
847
            cmd = _get_cmd_object(topic)
 
848
        except KeyError:
 
849
            return []
 
850
        else:
 
851
            return [cmd]
 
852
 
678
853
 
679
854
if __name__ == '__main__':
680
855
    sys.exit(main(sys.argv))