~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

Nathaniel McCallums patch for urandom friendliness on aix.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2006 Canonical Ltd
2
 
#
 
1
# Copyright (C) 2004, 2005 by 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
 
21
23
# TODO: Define arguments by objects, rather than just using names.
22
24
# 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
 
 
 
25
# would help with validation and shell completion.
 
26
 
 
27
 
 
28
 
 
29
import sys
31
30
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
31
from warnings import warn
 
32
from inspect import getdoc
39
33
 
40
34
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
 
 
 
35
import bzrlib.trace
 
36
from bzrlib.trace import mutter, note, log_error, warning
 
37
from bzrlib.errors import BzrError, BzrCheckError, BzrCommandError
 
38
from bzrlib.branch import find_branch
 
39
from bzrlib import BZRDIR
58
40
 
59
41
plugin_cmds = {}
60
42
 
61
43
 
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
 
    """
 
44
def register_command(cmd):
 
45
    "Utility function to help register a command"
70
46
    global plugin_cmds
71
47
    k = cmd.__name__
72
48
    if k.startswith("cmd_"):
73
49
        k_unsquished = _unsquish_command_name(k)
74
50
    else:
75
51
        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
 
52
    if not plugin_cmds.has_key(k_unsquished):
 
53
        plugin_cmds[k_unsquished] = cmd
 
54
        mutter('registered plugin command %s', k_unsquished)      
85
55
    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__])
 
56
        log_error('Two plugins defined the same command: %r' % k)
 
57
        log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
88
58
 
89
59
 
90
60
def _squish_command_name(cmd):
96
66
    return cmd[4:].replace('_','-')
97
67
 
98
68
 
 
69
def _parse_revision_str(revstr):
 
70
    """This handles a revision string -> revno.
 
71
 
 
72
    This always returns a list.  The list will have one element for 
 
73
 
 
74
    It supports integers directly, but everything else it
 
75
    defers for passing to Branch.get_revision_info()
 
76
 
 
77
    >>> _parse_revision_str('234')
 
78
    [234]
 
79
    >>> _parse_revision_str('234..567')
 
80
    [234, 567]
 
81
    >>> _parse_revision_str('..')
 
82
    [None, None]
 
83
    >>> _parse_revision_str('..234')
 
84
    [None, 234]
 
85
    >>> _parse_revision_str('234..')
 
86
    [234, None]
 
87
    >>> _parse_revision_str('234..456..789') # Maybe this should be an error
 
88
    [234, 456, 789]
 
89
    >>> _parse_revision_str('234....789') # Error?
 
90
    [234, None, 789]
 
91
    >>> _parse_revision_str('revid:test@other.com-234234')
 
92
    ['revid:test@other.com-234234']
 
93
    >>> _parse_revision_str('revid:test@other.com-234234..revid:test@other.com-234235')
 
94
    ['revid:test@other.com-234234', 'revid:test@other.com-234235']
 
95
    >>> _parse_revision_str('revid:test@other.com-234234..23')
 
96
    ['revid:test@other.com-234234', 23]
 
97
    >>> _parse_revision_str('date:2005-04-12')
 
98
    ['date:2005-04-12']
 
99
    >>> _parse_revision_str('date:2005-04-12 12:24:33')
 
100
    ['date:2005-04-12 12:24:33']
 
101
    >>> _parse_revision_str('date:2005-04-12T12:24:33')
 
102
    ['date:2005-04-12T12:24:33']
 
103
    >>> _parse_revision_str('date:2005-04-12,12:24:33')
 
104
    ['date:2005-04-12,12:24:33']
 
105
    >>> _parse_revision_str('-5..23')
 
106
    [-5, 23]
 
107
    >>> _parse_revision_str('-5')
 
108
    [-5]
 
109
    >>> _parse_revision_str('123a')
 
110
    ['123a']
 
111
    >>> _parse_revision_str('abc')
 
112
    ['abc']
 
113
    """
 
114
    import re
 
115
    old_format_re = re.compile('\d*:\d*')
 
116
    m = old_format_re.match(revstr)
 
117
    if m:
 
118
        warning('Colon separator for revision numbers is deprecated.'
 
119
                ' Use .. instead')
 
120
        revs = []
 
121
        for rev in revstr.split(':'):
 
122
            if rev:
 
123
                revs.append(int(rev))
 
124
            else:
 
125
                revs.append(None)
 
126
        return revs
 
127
    revs = []
 
128
    for x in revstr.split('..'):
 
129
        if not x:
 
130
            revs.append(None)
 
131
        else:
 
132
            try:
 
133
                revs.append(int(x))
 
134
            except ValueError:
 
135
                revs.append(x)
 
136
    return revs
 
137
 
 
138
 
 
139
def get_merge_type(typestring):
 
140
    """Attempt to find the merge class/factory associated with a string."""
 
141
    from merge import merge_types
 
142
    try:
 
143
        return merge_types[typestring][0]
 
144
    except KeyError:
 
145
        templ = '%s%%7s: %%s' % (' '*12)
 
146
        lines = [templ % (f[0], f[1][1]) for f in merge_types.iteritems()]
 
147
        type_list = '\n'.join(lines)
 
148
        msg = "No known merge type %s. Supported types are:\n%s" %\
 
149
            (typestring, type_list)
 
150
        raise BzrCommandError(msg)
 
151
    
 
152
 
 
153
def get_merge_type(typestring):
 
154
    """Attempt to find the merge class/factory associated with a string."""
 
155
    from merge import merge_types
 
156
    try:
 
157
        return merge_types[typestring][0]
 
158
    except KeyError:
 
159
        templ = '%s%%7s: %%s' % (' '*12)
 
160
        lines = [templ % (f[0], f[1][1]) for f in merge_types.iteritems()]
 
161
        type_list = '\n'.join(lines)
 
162
        msg = "No known merge type %s. Supported types are:\n%s" %\
 
163
            (typestring, type_list)
 
164
        raise BzrCommandError(msg)
 
165
 
 
166
 
99
167
def _builtin_commands():
100
168
    import bzrlib.builtins
101
169
    r = {}
102
170
    builtins = bzrlib.builtins.__dict__
103
171
    for name in builtins:
104
172
        if name.startswith("cmd_"):
105
 
            real_name = _unsquish_command_name(name)
 
173
            real_name = _unsquish_command_name(name)        
106
174
            r[real_name] = builtins[name]
107
175
    return r
 
176
 
108
177
            
109
178
 
110
179
def builtin_command_names():
136
205
    plugins_override
137
206
        If true, plugin commands can override builtins.
138
207
    """
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
208
    from bzrlib.externalcommand import ExternalCommand
148
209
 
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.
 
210
    cmd_name = str(cmd_name)            # not unicode
153
211
 
154
212
    # first look up this command under the specified name
155
213
    cmds = _get_cmd_dict(plugins_override=plugins_override)
166
224
    cmd_obj = ExternalCommand.find_command(cmd_name)
167
225
    if cmd_obj:
168
226
        return cmd_obj
169
 
    raise KeyError
 
227
 
 
228
    raise BzrCommandError("unknown command %r" % cmd_name)
170
229
 
171
230
 
172
231
class Command(object):
194
253
        List of argument forms, marked with whether they are optional,
195
254
        repeated, etc.
196
255
 
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
256
    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().
 
257
        List of options that may be given for this command.
209
258
 
210
259
    hidden
211
260
        If true, this command isn't advertised.  This is typically
212
261
        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
262
    """
230
263
    aliases = []
 
264
    
231
265
    takes_args = []
232
266
    takes_options = []
233
 
    encoding_type = 'strict'
234
267
 
235
268
    hidden = False
236
269
    
239
272
        if self.__doc__ == Command.__doc__:
240
273
            warn("No help message set for %r" % self)
241
274
 
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)
 
275
 
 
276
    def run_argv(self, argv):
 
277
        """Parse command line and run."""
 
278
        args, opts = parse_args(argv)
 
279
 
461
280
        if 'help' in opts:  # e.g. bzr add --help
462
 
            sys.stdout.write(self.get_help_text())
 
281
            from bzrlib.help import help_on_command
 
282
            help_on_command(self.name())
463
283
            return 0
 
284
 
 
285
        # check options are reasonable
 
286
        allowed = self.takes_options
 
287
        for oname in opts:
 
288
            if oname not in allowed:
 
289
                raise BzrCommandError("option '--%s' is not allowed for command %r"
 
290
                                      % (oname, self.name()))
 
291
 
464
292
        # mix arguments and options into one dictionary
465
293
        cmdargs = _match_argform(self.name(), self.takes_args, args)
466
294
        cmdopts = {}
470
298
        all_cmd_args = cmdargs.copy()
471
299
        all_cmd_args.update(cmdopts)
472
300
 
473
 
        self._setup_outf()
474
 
 
475
301
        return self.run(**all_cmd_args)
 
302
 
476
303
    
477
304
    def run(self):
478
305
        """Actually run the command.
484
311
        shell error code if not.  It's OK for this method to allow
485
312
        an exception to raise up.
486
313
        """
487
 
        raise NotImplementedError('no implementation of command %r'
488
 
                                  % self.name())
 
314
        raise NotImplementedError()
 
315
 
489
316
 
490
317
    def help(self):
491
318
        """Return help message for this class."""
492
 
        from inspect import getdoc
493
319
        if self.__doc__ is Command.__doc__:
494
320
            return None
495
321
        return getdoc(self)
497
323
    def name(self):
498
324
        return _unsquish_command_name(self.__class__.__name__)
499
325
 
500
 
    def plugin_name(self):
501
 
        """Get the name of the plugin that provides this command.
502
326
 
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]
 
327
def parse_spec(spec):
 
328
    """
 
329
    >>> parse_spec(None)
 
330
    [None, None]
 
331
    >>> parse_spec("./")
 
332
    ['./', None]
 
333
    >>> parse_spec("../@")
 
334
    ['..', -1]
 
335
    >>> parse_spec("../f/@35")
 
336
    ['../f', 35]
 
337
    >>> parse_spec('./@revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67')
 
338
    ['.', 'revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67']
 
339
    """
 
340
    if spec is None:
 
341
        return [None, None]
 
342
    if '/@' in spec:
 
343
        parsed = spec.split('/@')
 
344
        assert len(parsed) == 2
 
345
        if parsed[1] == "":
 
346
            parsed[1] = -1
508
347
        else:
509
 
            return None
510
 
 
511
 
 
512
 
def parse_args(command, argv, alias_argv=None):
 
348
            try:
 
349
                parsed[1] = int(parsed[1])
 
350
            except ValueError:
 
351
                pass # We can allow stuff like ./@revid:blahblahblah
 
352
            else:
 
353
                assert parsed[1] >=0
 
354
    else:
 
355
        parsed = [spec, None]
 
356
    return parsed
 
357
 
 
358
 
 
359
 
 
360
 
 
361
# list of all available options; the rhs can be either None for an
 
362
# option that takes no argument, or a constructor function that checks
 
363
# the type.
 
364
OPTIONS = {
 
365
    'all':                    None,
 
366
    'diff-options':           str,
 
367
    'help':                   None,
 
368
    'file':                   unicode,
 
369
    'force':                  None,
 
370
    'format':                 unicode,
 
371
    'forward':                None,
 
372
    'message':                unicode,
 
373
    'no-recurse':             None,
 
374
    'profile':                None,
 
375
    'revision':               _parse_revision_str,
 
376
    'short':                  None,
 
377
    'show-ids':               None,
 
378
    'timezone':               str,
 
379
    'verbose':                None,
 
380
    'version':                None,
 
381
    'email':                  None,
 
382
    'unchanged':              None,
 
383
    'update':                 None,
 
384
    'long':                   None,
 
385
    'root':                   str,
 
386
    'no-backup':              None,
 
387
    'merge-type':             get_merge_type,
 
388
    'pattern':                str,
 
389
    }
 
390
 
 
391
SHORT_OPTIONS = {
 
392
    'F':                      'file', 
 
393
    'h':                      'help',
 
394
    'm':                      'message',
 
395
    'r':                      'revision',
 
396
    'v':                      'verbose',
 
397
    'l':                      'long',
 
398
}
 
399
 
 
400
 
 
401
def parse_args(argv):
513
402
    """Parse command line.
514
403
    
515
404
    Arguments and options are parsed at this level before being passed
516
405
    down to specific command handlers.  This routine knows, from a
517
406
    lookup table, something about the available options, what optargs
518
407
    they take, and which commands will accept them.
 
408
 
 
409
    >>> parse_args('--help'.split())
 
410
    ([], {'help': True})
 
411
    >>> parse_args('help -- --invalidcmd'.split())
 
412
    (['help', '--invalidcmd'], {})
 
413
    >>> parse_args('--version'.split())
 
414
    ([], {'version': True})
 
415
    >>> parse_args('status --all'.split())
 
416
    (['status'], {'all': True})
 
417
    >>> parse_args('commit --message=biter'.split())
 
418
    (['commit'], {'message': u'biter'})
 
419
    >>> parse_args('log -r 500'.split())
 
420
    (['log'], {'revision': [500]})
 
421
    >>> parse_args('log -r500..600'.split())
 
422
    (['log'], {'revision': [500, 600]})
 
423
    >>> parse_args('log -vr500..600'.split())
 
424
    (['log'], {'verbose': True, 'revision': [500, 600]})
 
425
    >>> parse_args('log -rv500..600'.split()) #the r takes an argument
 
426
    (['log'], {'revision': ['v500', 600]})
519
427
    """
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])
 
428
    args = []
 
429
    opts = {}
 
430
 
 
431
    argsover = False
 
432
    while argv:
 
433
        a = argv.pop(0)
 
434
        if not argsover and a[0] == '-':
 
435
            # option names must not be unicode
 
436
            a = str(a)
 
437
            optarg = None
 
438
            if a[1] == '-':
 
439
                if a == '--':
 
440
                    # We've received a standalone -- No more flags
 
441
                    argsover = True
 
442
                    continue
 
443
                mutter("  got option %r" % a)
 
444
                if '=' in a:
 
445
                    optname, optarg = a[2:].split('=', 1)
 
446
                else:
 
447
                    optname = a[2:]
 
448
                if optname not in OPTIONS:
 
449
                    raise BzrError('unknown long option %r' % a)
 
450
            else:
 
451
                shortopt = a[1:]
 
452
                if shortopt in SHORT_OPTIONS:
 
453
                    # Multi-character options must have a space to delimit
 
454
                    # their value
 
455
                    optname = SHORT_OPTIONS[shortopt]
 
456
                else:
 
457
                    # Single character short options, can be chained,
 
458
                    # and have their value appended to their name
 
459
                    shortopt = a[1:2]
 
460
                    if shortopt not in SHORT_OPTIONS:
 
461
                        # We didn't find the multi-character name, and we
 
462
                        # didn't find the single char name
 
463
                        raise BzrError('unknown short option %r' % a)
 
464
                    optname = SHORT_OPTIONS[shortopt]
 
465
 
 
466
                    if a[2:]:
 
467
                        # There are extra things on this option
 
468
                        # see if it is the value, or if it is another
 
469
                        # short option
 
470
                        optargfn = OPTIONS[optname]
 
471
                        if optargfn is None:
 
472
                            # This option does not take an argument, so the
 
473
                            # next entry is another short option, pack it back
 
474
                            # into the list
 
475
                            argv.insert(0, '-' + a[2:])
 
476
                        else:
 
477
                            # This option takes an argument, so pack it
 
478
                            # into the array
 
479
                            optarg = a[2:]
 
480
            
 
481
            if optname in opts:
 
482
                # XXX: Do we ever want to support this, e.g. for -r?
 
483
                raise BzrError('repeated option %r' % a)
 
484
                
 
485
            optargfn = OPTIONS[optname]
 
486
            if optargfn:
 
487
                if optarg == None:
 
488
                    if not argv:
 
489
                        raise BzrError('option %r needs an argument' % a)
 
490
                    else:
 
491
                        optarg = argv.pop(0)
 
492
                opts[optname] = optargfn(optarg)
 
493
            else:
 
494
                if optarg != None:
 
495
                    raise BzrError('option %r takes no argument' % optname)
 
496
                opts[optname] = True
 
497
        else:
 
498
            args.append(a)
 
499
 
530
500
    return args, opts
531
501
 
532
502
 
 
503
 
 
504
 
533
505
def _match_argform(cmd, takes_args, args):
534
506
    argdict = {}
535
507
 
547
519
                argdict[argname + '_list'] = None
548
520
        elif ap[-1] == '+':
549
521
            if not args:
550
 
                raise errors.BzrCommandError("command %r needs one or more %s"
551
 
                                             % (cmd, argname.upper()))
 
522
                raise BzrCommandError("command %r needs one or more %s"
 
523
                        % (cmd, argname.upper()))
552
524
            else:
553
525
                argdict[argname + '_list'] = args[:]
554
526
                args = []
555
527
        elif ap[-1] == '$': # all but one
556
528
            if len(args) < 2:
557
 
                raise errors.BzrCommandError("command %r needs one or more %s"
558
 
                                             % (cmd, argname.upper()))
 
529
                raise BzrCommandError("command %r needs one or more %s"
 
530
                        % (cmd, argname.upper()))
559
531
            argdict[argname + '_list'] = args[:-1]
560
 
            args[:-1] = []
 
532
            args[:-1] = []                
561
533
        else:
562
534
            # just a plain arg
563
535
            argname = ap
564
536
            if not args:
565
 
                raise errors.BzrCommandError("command %r requires argument %s"
566
 
                               % (cmd, argname.upper()))
 
537
                raise BzrCommandError("command %r requires argument %s"
 
538
                        % (cmd, argname.upper()))
567
539
            else:
568
540
                argdict[argname] = args.pop(0)
569
541
            
570
542
    if args:
571
 
        raise errors.BzrCommandError("extra argument to command %s: %s"
572
 
                                     % (cmd, args[0]))
 
543
        raise BzrCommandError("extra argument to command %s: %s"
 
544
                              % (cmd, args[0]))
573
545
 
574
546
    return argdict
575
547
 
578
550
def apply_profiled(the_callable, *args, **kwargs):
579
551
    import hotshot
580
552
    import tempfile
581
 
    import hotshot.stats
582
553
    pffileno, pfname = tempfile.mkstemp()
583
554
    try:
584
555
        prof = hotshot.Profile(pfname)
586
557
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
587
558
        finally:
588
559
            prof.close()
 
560
 
 
561
        import hotshot.stats
589
562
        stats = hotshot.stats.load(pfname)
590
 
        stats.strip_dirs()
591
 
        stats.sort_stats('cum')   # 'time'
 
563
        #stats.strip_dirs()
 
564
        stats.sort_stats('time')
592
565
        ## XXX: Might like to write to stderr or the trace file instead but
593
566
        ## print_stats seems hardcoded to stdout
594
567
        stats.print_stats(20)
 
568
 
595
569
        return ret
596
570
    finally:
597
571
        os.close(pffileno)
598
572
        os.remove(pfname)
599
573
 
600
574
 
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
575
def run_bzr(argv):
634
576
    """Execute a command.
635
577
 
638
580
    
639
581
    argv
640
582
       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
583
    
644
584
    Returns a command status or raises an exception.
645
585
 
649
589
    --no-plugins
650
590
        Do not load plugin modules at all
651
591
 
652
 
    --no-aliases
653
 
        Do not allow aliases
654
 
 
655
592
    --builtin
656
593
        Only use builtin commands.  (Plugins are still allowed to change
657
594
        other behaviour.)
658
595
 
659
596
    --profile
660
 
        Run under the Python hotshot profiler.
661
 
 
662
 
    --lsprof
663
 
        Run under the Python lsprof profiler.
 
597
        Run under the Python profiler.
664
598
    """
665
 
    argv = list(argv)
666
 
    trace.mutter("bzr arguments: %r", argv)
 
599
    
 
600
    argv = [a.decode(bzrlib.user_encoding) for a in argv]
667
601
 
668
 
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
669
 
                opt_no_aliases = False
670
 
    opt_lsprof_file = None
 
602
    opt_profile = opt_no_plugins = opt_builtin = False
671
603
 
672
604
    # --no-plugins is handled specially at a very early stage. We need
673
605
    # to load plugins before doing other command parsing so that they
674
606
    # can override commands, but this needs to happen first.
675
607
 
676
 
    argv_copy = []
677
 
    i = 0
678
 
    while i < len(argv):
679
 
        a = argv[i]
 
608
    for a in argv:
680
609
        if a == '--profile':
681
610
            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
611
        elif a == '--no-plugins':
689
612
            opt_no_plugins = True
690
 
        elif a == '--no-aliases':
691
 
            opt_no_aliases = True
692
613
        elif a == '--builtin':
693
614
            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
615
        else:
699
 
            argv_copy.append(a)
700
 
        i += 1
 
616
            break
 
617
        argv.remove(a)
701
618
 
702
 
    argv = argv_copy
703
 
    if (not argv):
704
 
        from bzrlib.builtins import cmd_help
705
 
        cmd_help().run_argv_aliases([])
 
619
    if (not argv) or (argv[0] == '--help'):
 
620
        from bzrlib.help import help
 
621
        if len(argv) > 1:
 
622
            help(argv[1])
 
623
        else:
 
624
            help()
706
625
        return 0
707
626
 
708
627
    if argv[0] == '--version':
709
 
        from bzrlib.version import show_version
 
628
        from bzrlib.builtins import show_version
710
629
        show_version()
711
630
        return 0
712
631
        
713
632
    if not opt_no_plugins:
714
633
        from bzrlib.plugin import load_plugins
715
634
        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.
 
635
 
 
636
    cmd = str(argv.pop(0))
732
637
 
733
638
    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
 
639
 
 
640
    if opt_profile:
 
641
        ret = apply_profiled(cmd_obj.run_argv, argv)
 
642
    else:
 
643
        ret = cmd_obj.run_argv(argv)
 
644
    return ret or 0
767
645
 
768
646
 
769
647
def main(argv):
770
648
    import bzrlib.ui
771
 
    from bzrlib.ui.text import TextUIFactory
772
 
    bzrlib.ui.ui_factory = TextUIFactory()
773
 
    try:
774
 
        argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
775
 
    except UnicodeDecodeError:
776
 
        raise errors.BzrError(("Parameter '%r' is unsupported by the current "
777
 
                                                            "encoding." % a))
778
 
    ret = run_bzr_catch_errors(argv)
779
 
    trace.mutter("return code %d", ret)
780
 
    return ret
781
 
 
782
 
 
783
 
def run_bzr_catch_errors(argv):
784
 
    try:
785
 
        return run_bzr(argv)
786
 
    except (KeyboardInterrupt, Exception), e:
787
 
        # used to handle AssertionError and KeyboardInterrupt
788
 
        # specially here, but hopefully they're handled ok by the logger now
789
 
        trace.report_exception(sys.exc_info(), sys.stderr)
790
 
        if os.environ.get('BZR_PDB'):
791
 
            print '**** entering debugger'
792
 
            import pdb
793
 
            pdb.post_mortem(sys.exc_traceback)
 
649
    bzrlib.trace.log_startup(argv)
 
650
    bzrlib.ui.ui_factory = bzrlib.ui.TextUIFactory()
 
651
 
 
652
    try:
 
653
        try:
 
654
            return run_bzr(argv[1:])
 
655
        finally:
 
656
            # do this here inside the exception wrappers to catch EPIPE
 
657
            sys.stdout.flush()
 
658
    except BzrCommandError, e:
 
659
        # command line syntax error, etc
 
660
        log_error(str(e))
 
661
        return 1
 
662
    except BzrError, e:
 
663
        bzrlib.trace.log_exception()
 
664
        return 1
 
665
    except AssertionError, e:
 
666
        bzrlib.trace.log_exception('assertion failed: ' + str(e))
794
667
        return 3
795
 
 
796
 
 
797
 
class HelpCommandIndex(object):
798
 
    """A index for bzr help that returns commands."""
799
 
 
800
 
    def __init__(self):
801
 
        self.prefix = 'commands/'
802
 
 
803
 
    def get_topics(self, topic):
804
 
        """Search for topic amongst commands.
805
 
 
806
 
        :param topic: A topic to search for.
807
 
        :return: A list which is either empty or contains a single
808
 
            Command entry.
809
 
        """
810
 
        if topic and topic.startswith(self.prefix):
811
 
            topic = topic[len(self.prefix):]
812
 
        try:
813
 
            cmd = _get_cmd_object(topic)
814
 
        except KeyError:
815
 
            return []
 
668
    except KeyboardInterrupt, e:
 
669
        bzrlib.trace.note('interrupted')
 
670
        return 2
 
671
    except Exception, e:
 
672
        import errno
 
673
        if (isinstance(e, IOError) 
 
674
            and hasattr(e, 'errno')
 
675
            and e.errno == errno.EPIPE):
 
676
            bzrlib.trace.note('broken pipe')
 
677
            return 2
816
678
        else:
817
 
            return [cmd]
 
679
            bzrlib.trace.log_exception()
 
680
            return 2
818
681
 
819
682
 
820
683
if __name__ == '__main__':