~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: Martin Pool
  • Date: 2005-09-13 23:08:19 UTC
  • Revision ID: mbp@sourcefrog.net-20050913230819-6ceae96050d32faa
ignore .bzr-shelf

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__])
88
 
        trace.log_error('Previously this command was registered from %r' %
89
 
                        sys.modules[plugin_cmds[k_unsquished].__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__])
90
58
 
91
59
 
92
60
def _squish_command_name(cmd):
98
66
    return cmd[4:].replace('_','-')
99
67
 
100
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
 
101
153
def _builtin_commands():
102
154
    import bzrlib.builtins
103
155
    r = {}
104
156
    builtins = bzrlib.builtins.__dict__
105
157
    for name in builtins:
106
158
        if name.startswith("cmd_"):
107
 
            real_name = _unsquish_command_name(name)
 
159
            real_name = _unsquish_command_name(name)        
108
160
            r[real_name] = builtins[name]
109
161
    return r
 
162
 
110
163
            
111
164
 
112
165
def builtin_command_names():
138
191
    plugins_override
139
192
        If true, plugin commands can override builtins.
140
193
    """
141
 
    try:
142
 
        return _get_cmd_object(cmd_name, plugins_override)
143
 
    except KeyError:
144
 
        raise errors.BzrCommandError('unknown command "%s"' % cmd_name)
145
 
 
146
 
 
147
 
def _get_cmd_object(cmd_name, plugins_override=True):
148
 
    """Worker for get_cmd_object which raises KeyError rather than BzrCommandError."""
149
194
    from bzrlib.externalcommand import ExternalCommand
150
195
 
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.
 
196
    cmd_name = str(cmd_name)            # not unicode
155
197
 
156
198
    # first look up this command under the specified name
157
199
    cmds = _get_cmd_dict(plugins_override=plugins_override)
168
210
    cmd_obj = ExternalCommand.find_command(cmd_name)
169
211
    if cmd_obj:
170
212
        return cmd_obj
171
 
    raise KeyError
 
213
 
 
214
    raise BzrCommandError("unknown command %r" % cmd_name)
172
215
 
173
216
 
174
217
class Command(object):
196
239
        List of argument forms, marked with whether they are optional,
197
240
        repeated, etc.
198
241
 
199
 
                Examples:
200
 
 
201
 
                ['to_location', 'from_branch?', 'file*']
202
 
 
203
 
                'to_location' is required
204
 
                'from_branch' is optional
205
 
                'file' can be specified 0 or more times
206
 
 
207
242
    takes_options
208
 
        List of options that may be given for this command.  These can
209
 
        be either strings, referring to globally-defined options,
210
 
        or option objects.  Retrieve through options().
 
243
        List of options that may be given for this command.
211
244
 
212
245
    hidden
213
246
        If true, this command isn't advertised.  This is typically
214
247
        for commands intended for expert users.
215
 
 
216
 
    encoding_type
217
 
        Command objects will get a 'outf' attribute, which has been
218
 
        setup to properly handle encoding of unicode strings.
219
 
        encoding_type determines what will happen when characters cannot
220
 
        be encoded
221
 
            strict - abort if we cannot decode
222
 
            replace - put in a bogus character (typically '?')
223
 
            exact - do not encode sys.stdout
224
 
 
225
 
            NOTE: by default on Windows, sys.stdout is opened as a text
226
 
            stream, therefore LF line-endings are converted to CRLF.
227
 
            When a command uses encoding_type = 'exact', then
228
 
            sys.stdout is forced to be a binary stream, and line-endings
229
 
            will not mangled.
230
 
 
231
248
    """
232
249
    aliases = []
 
250
    
233
251
    takes_args = []
234
252
    takes_options = []
235
 
    encoding_type = 'strict'
236
253
 
237
254
    hidden = False
238
255
    
240
257
        """Construct an instance of this command."""
241
258
        if self.__doc__ == Command.__doc__:
242
259
            warn("No help message set for %r" % self)
243
 
        # List of standard options directly supported
244
 
        self.supported_std_options = []
245
 
 
246
 
    def _maybe_expand_globs(self, file_list):
247
 
        """Glob expand file_list if the platform does not do that itself.
248
 
        
249
 
        :return: A possibly empty list of unicode paths.
250
 
 
251
 
        Introduced in bzrlib 0.18.
252
 
        """
253
 
        if not file_list:
254
 
            file_list = []
255
 
        if sys.platform == 'win32':
256
 
            file_list = win32utils.glob_expand(file_list)
257
 
        return list(file_list)
258
 
 
259
 
    def _usage(self):
260
 
        """Return single-line grammar for this command.
261
 
 
262
 
        Only describes arguments, not options.
263
 
        """
264
 
        s = 'bzr ' + self.name() + ' '
265
 
        for aname in self.takes_args:
266
 
            aname = aname.upper()
267
 
            if aname[-1] in ['$', '+']:
268
 
                aname = aname[:-1] + '...'
269
 
            elif aname[-1] == '?':
270
 
                aname = '[' + aname[:-1] + ']'
271
 
            elif aname[-1] == '*':
272
 
                aname = '[' + aname[:-1] + '...]'
273
 
            s += aname + ' '
274
 
                
275
 
        assert s[-1] == ' '
276
 
        s = s[:-1]
277
 
        return s
278
 
 
279
 
    def get_help_text(self, additional_see_also=None, plain=True,
280
 
                      see_also_as_links=False):
281
 
        """Return a text string with help for this command.
282
 
        
283
 
        :param additional_see_also: Additional help topics to be
284
 
            cross-referenced.
285
 
        :param plain: if False, raw help (reStructuredText) is
286
 
            returned instead of plain text.
287
 
        :param see_also_as_links: if True, convert items in 'See also'
288
 
            list to internal links (used by bzr_man rstx generator)
289
 
        """
290
 
        doc = self.help()
291
 
        if doc is None:
292
 
            raise NotImplementedError("sorry, no detailed help yet for %r" % self.name())
293
 
 
294
 
        # Extract the summary (purpose) and sections out from the text
295
 
        purpose,sections = self._get_help_parts(doc)
296
 
 
297
 
        # If a custom usage section was provided, use it
298
 
        if sections.has_key('Usage'):
299
 
            usage = sections.pop('Usage')
300
 
        else:
301
 
            usage = self._usage()
302
 
 
303
 
        # The header is the purpose and usage
304
 
        result = ""
305
 
        result += ':Purpose: %s\n' % purpose
306
 
        if usage.find('\n') >= 0:
307
 
            result += ':Usage:\n%s\n' % usage
308
 
        else:
309
 
            result += ':Usage:   %s\n' % usage
310
 
        result += '\n'
311
 
 
312
 
        # Add the options
313
 
        options = option.get_optparser(self.options()).format_option_help()
314
 
        if options.startswith('Options:'):
315
 
            result += ':' + options
316
 
        elif options.startswith('options:'):
317
 
            # Python 2.4 version of optparse
318
 
            result += ':Options:' + options[len('options:'):]
319
 
        else:
320
 
            result += options
321
 
        result += '\n'
322
 
 
323
 
        # Add the description, indenting it 2 spaces
324
 
        # to match the indentation of the options
325
 
        if sections.has_key(None):
326
 
            text = sections.pop(None)
327
 
            text = '\n  '.join(text.splitlines())
328
 
            result += ':%s:\n  %s\n\n' % ('Description',text)
329
 
 
330
 
        # Add the custom sections (e.g. Examples). Note that there's no need
331
 
        # to indent these as they must be indented already in the source.
332
 
        if sections:
333
 
            labels = sorted(sections.keys())
334
 
            for label in labels:
335
 
                result += ':%s:\n%s\n\n' % (label,sections[label])
336
 
 
337
 
        # Add the aliases, source (plug-in) and see also links, if any
338
 
        if self.aliases:
339
 
            result += ':Aliases:  '
340
 
            result += ', '.join(self.aliases) + '\n'
341
 
        plugin_name = self.plugin_name()
342
 
        if plugin_name is not None:
343
 
            result += ':From:     plugin "%s"\n' % plugin_name
344
 
        see_also = self.get_see_also(additional_see_also)
345
 
        if see_also:
346
 
            if not plain and see_also_as_links:
347
 
                see_also_links = []
348
 
                for item in see_also:
349
 
                    if item == 'topics':
350
 
                        # topics doesn't have an independent section
351
 
                        # so don't create a real link
352
 
                        see_also_links.append(item)
353
 
                    else:
354
 
                        # Use a reST link for this entry
355
 
                        see_also_links.append("`%s`_" % (item,))
356
 
                see_also = see_also_links
357
 
            result += ':See also: '
358
 
            result += ', '.join(see_also) + '\n'
359
 
 
360
 
        # If this will be rendered as plan text, convert it
361
 
        if plain:
362
 
            import bzrlib.help_topics
363
 
            result = bzrlib.help_topics.help_as_plain_text(result)
364
 
        return result
365
 
 
366
 
    @staticmethod
367
 
    def _get_help_parts(text):
368
 
        """Split help text into a summary and named sections.
369
 
 
370
 
        :return: (summary,sections) where summary is the top line and
371
 
            sections is a dictionary of the rest indexed by section name.
372
 
            A section starts with a heading line of the form ":xxx:".
373
 
            Indented text on following lines is the section value.
374
 
            All text found outside a named section is assigned to the
375
 
            default section which is given the key of None.
376
 
        """
377
 
        def save_section(sections, label, section):
378
 
            if len(section) > 0:
379
 
                if sections.has_key(label):
380
 
                    sections[label] += '\n' + section
381
 
                else:
382
 
                    sections[label] = section
383
 
            
384
 
        lines = text.rstrip().splitlines()
385
 
        summary = lines.pop(0)
386
 
        sections = {}
387
 
        label,section = None,''
388
 
        for line in lines:
389
 
            if line.startswith(':') and line.endswith(':') and len(line) > 2:
390
 
                save_section(sections, label, section)
391
 
                label,section = line[1:-1],''
392
 
            elif label != None and len(line) > 1 and not line[0].isspace():
393
 
                save_section(sections, label, section)
394
 
                label,section = None,line
395
 
            else:
396
 
                if len(section) > 0:
397
 
                    section += '\n' + line
398
 
                else:
399
 
                    section = line
400
 
        save_section(sections, label, section)
401
 
        return summary, sections
402
 
 
403
 
    def get_help_topic(self):
404
 
        """Return the commands help topic - its name."""
405
 
        return self.name()
406
 
 
407
 
    def get_see_also(self, additional_terms=None):
408
 
        """Return a list of help topics that are related to this command.
409
 
        
410
 
        The list is derived from the content of the _see_also attribute. Any
411
 
        duplicates are removed and the result is in lexical order.
412
 
        :param additional_terms: Additional help topics to cross-reference.
413
 
        :return: A list of help topics.
414
 
        """
415
 
        see_also = set(getattr(self, '_see_also', []))
416
 
        if additional_terms:
417
 
            see_also.update(additional_terms)
418
 
        return sorted(see_also)
419
 
 
420
 
    def options(self):
421
 
        """Return dict of valid options for this command.
422
 
 
423
 
        Maps from long option name to option object."""
424
 
        r = Option.STD_OPTIONS.copy()
425
 
        std_names = r.keys()
426
 
        for o in self.takes_options:
427
 
            if isinstance(o, basestring):
428
 
                o = option.Option.OPTIONS[o]
429
 
            r[o.name] = o
430
 
            if o.name in std_names:
431
 
                self.supported_std_options.append(o.name)
432
 
        return r
433
 
 
434
 
    def _setup_outf(self):
435
 
        """Return a file linked to stdout, which has proper encoding."""
436
 
        assert self.encoding_type in ['strict', 'exact', 'replace']
437
 
 
438
 
        # Originally I was using self.stdout, but that looks
439
 
        # *way* too much like sys.stdout
440
 
        if self.encoding_type == 'exact':
441
 
            # force sys.stdout to be binary stream on win32
442
 
            if sys.platform == 'win32':
443
 
                fileno = getattr(sys.stdout, 'fileno', None)
444
 
                if fileno:
445
 
                    import msvcrt
446
 
                    msvcrt.setmode(fileno(), os.O_BINARY)
447
 
            self.outf = sys.stdout
448
 
            return
449
 
 
450
 
        output_encoding = osutils.get_terminal_encoding()
451
 
 
452
 
        self.outf = codecs.getwriter(output_encoding)(sys.stdout,
453
 
                        errors=self.encoding_type)
454
 
        # For whatever reason codecs.getwriter() does not advertise its encoding
455
 
        # it just returns the encoding of the wrapped file, which is completely
456
 
        # bogus. So set the attribute, so we can find the correct encoding later.
457
 
        self.outf.encoding = output_encoding
458
 
 
459
 
    def run_argv_aliases(self, argv, alias_argv=None):
460
 
        """Parse the command line and run with extra aliases in alias_argv."""
461
 
        if argv is None:
462
 
            warn("Passing None for [] is deprecated from bzrlib 0.10",
463
 
                 DeprecationWarning, stacklevel=2)
464
 
            argv = []
465
 
        args, opts = parse_args(self, argv, alias_argv)
466
 
 
467
 
        # Process the standard options
 
260
 
 
261
 
 
262
    def run_argv(self, argv):
 
263
        """Parse command line and run."""
 
264
        args, opts = parse_args(argv)
 
265
 
468
266
        if 'help' in opts:  # e.g. bzr add --help
469
 
            sys.stdout.write(self.get_help_text())
 
267
            from bzrlib.help import help_on_command
 
268
            help_on_command(self.name())
470
269
            return 0
471
 
        trace.set_verbosity_level(option._verbosity_level)
472
 
        if 'verbose' in self.supported_std_options:
473
 
            opts['verbose'] = trace.is_verbose()
474
 
        elif opts.has_key('verbose'):
475
 
            del opts['verbose']
476
 
        if 'quiet' in self.supported_std_options:
477
 
            opts['quiet'] = trace.is_quiet()
478
 
        elif opts.has_key('quiet'):
479
 
            del opts['quiet']
 
270
 
 
271
        # check options are reasonable
 
272
        allowed = self.takes_options
 
273
        for oname in opts:
 
274
            if oname not in allowed:
 
275
                raise BzrCommandError("option '--%s' is not allowed for command %r"
 
276
                                      % (oname, self.name()))
480
277
 
481
278
        # mix arguments and options into one dictionary
482
279
        cmdargs = _match_argform(self.name(), self.takes_args, args)
487
284
        all_cmd_args = cmdargs.copy()
488
285
        all_cmd_args.update(cmdopts)
489
286
 
490
 
        self._setup_outf()
491
 
 
492
287
        return self.run(**all_cmd_args)
 
288
 
493
289
    
494
290
    def run(self):
495
291
        """Actually run the command.
501
297
        shell error code if not.  It's OK for this method to allow
502
298
        an exception to raise up.
503
299
        """
504
 
        raise NotImplementedError('no implementation of command %r'
505
 
                                  % self.name())
 
300
        raise NotImplementedError()
 
301
 
506
302
 
507
303
    def help(self):
508
304
        """Return help message for this class."""
509
 
        from inspect import getdoc
510
305
        if self.__doc__ is Command.__doc__:
511
306
            return None
512
307
        return getdoc(self)
514
309
    def name(self):
515
310
        return _unsquish_command_name(self.__class__.__name__)
516
311
 
517
 
    def plugin_name(self):
518
 
        """Get the name of the plugin that provides this command.
519
312
 
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]
 
313
def parse_spec(spec):
 
314
    """
 
315
    >>> parse_spec(None)
 
316
    [None, None]
 
317
    >>> parse_spec("./")
 
318
    ['./', None]
 
319
    >>> parse_spec("../@")
 
320
    ['..', -1]
 
321
    >>> parse_spec("../f/@35")
 
322
    ['../f', 35]
 
323
    >>> parse_spec('./@revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67')
 
324
    ['.', 'revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67']
 
325
    """
 
326
    if spec is None:
 
327
        return [None, None]
 
328
    if '/@' in spec:
 
329
        parsed = spec.split('/@')
 
330
        assert len(parsed) == 2
 
331
        if parsed[1] == "":
 
332
            parsed[1] = -1
525
333
        else:
526
 
            return None
527
 
 
528
 
 
529
 
def parse_args(command, argv, alias_argv=None):
 
334
            try:
 
335
                parsed[1] = int(parsed[1])
 
336
            except ValueError:
 
337
                pass # We can allow stuff like ./@revid:blahblahblah
 
338
            else:
 
339
                assert parsed[1] >=0
 
340
    else:
 
341
        parsed = [spec, None]
 
342
    return parsed
 
343
 
 
344
 
 
345
 
 
346
 
 
347
# list of all available options; the rhs can be either None for an
 
348
# option that takes no argument, or a constructor function that checks
 
349
# the type.
 
350
OPTIONS = {
 
351
    'all':                    None,
 
352
    'diff-options':           str,
 
353
    'help':                   None,
 
354
    'file':                   unicode,
 
355
    'force':                  None,
 
356
    'format':                 unicode,
 
357
    'forward':                None,
 
358
    'message':                unicode,
 
359
    'no-recurse':             None,
 
360
    'profile':                None,
 
361
    'revision':               _parse_revision_str,
 
362
    'short':                  None,
 
363
    'show-ids':               None,
 
364
    'timezone':               str,
 
365
    'verbose':                None,
 
366
    'version':                None,
 
367
    'email':                  None,
 
368
    'unchanged':              None,
 
369
    'update':                 None,
 
370
    'long':                   None,
 
371
    'root':                   str,
 
372
    'no-backup':              None,
 
373
    'merge-type':             get_merge_type,
 
374
    'pattern':                str,
 
375
    }
 
376
 
 
377
SHORT_OPTIONS = {
 
378
    'F':                      'file', 
 
379
    'h':                      'help',
 
380
    'm':                      'message',
 
381
    'r':                      'revision',
 
382
    'v':                      'verbose',
 
383
    'l':                      'long',
 
384
}
 
385
 
 
386
 
 
387
def parse_args(argv):
530
388
    """Parse command line.
531
389
    
532
390
    Arguments and options are parsed at this level before being passed
533
391
    down to specific command handlers.  This routine knows, from a
534
392
    lookup table, something about the available options, what optargs
535
393
    they take, and which commands will accept them.
 
394
 
 
395
    >>> parse_args('--help'.split())
 
396
    ([], {'help': True})
 
397
    >>> parse_args('help -- --invalidcmd'.split())
 
398
    (['help', '--invalidcmd'], {})
 
399
    >>> parse_args('--version'.split())
 
400
    ([], {'version': True})
 
401
    >>> parse_args('status --all'.split())
 
402
    (['status'], {'all': True})
 
403
    >>> parse_args('commit --message=biter'.split())
 
404
    (['commit'], {'message': u'biter'})
 
405
    >>> parse_args('log -r 500'.split())
 
406
    (['log'], {'revision': [500]})
 
407
    >>> parse_args('log -r500..600'.split())
 
408
    (['log'], {'revision': [500, 600]})
 
409
    >>> parse_args('log -vr500..600'.split())
 
410
    (['log'], {'verbose': True, 'revision': [500, 600]})
 
411
    >>> parse_args('log -rv500..600'.split()) #the r takes an argument
 
412
    (['log'], {'revision': ['v500', 600]})
536
413
    """
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])
 
414
    args = []
 
415
    opts = {}
 
416
 
 
417
    argsover = False
 
418
    while argv:
 
419
        a = argv.pop(0)
 
420
        if not argsover and a[0] == '-':
 
421
            # option names must not be unicode
 
422
            a = str(a)
 
423
            optarg = None
 
424
            if a[1] == '-':
 
425
                if a == '--':
 
426
                    # We've received a standalone -- No more flags
 
427
                    argsover = True
 
428
                    continue
 
429
                mutter("  got option %r" % a)
 
430
                if '=' in a:
 
431
                    optname, optarg = a[2:].split('=', 1)
 
432
                else:
 
433
                    optname = a[2:]
 
434
                if optname not in OPTIONS:
 
435
                    raise BzrError('unknown long option %r' % a)
 
436
            else:
 
437
                shortopt = a[1:]
 
438
                if shortopt in SHORT_OPTIONS:
 
439
                    # Multi-character options must have a space to delimit
 
440
                    # their value
 
441
                    optname = SHORT_OPTIONS[shortopt]
 
442
                else:
 
443
                    # Single character short options, can be chained,
 
444
                    # and have their value appended to their name
 
445
                    shortopt = a[1:2]
 
446
                    if shortopt not in SHORT_OPTIONS:
 
447
                        # We didn't find the multi-character name, and we
 
448
                        # didn't find the single char name
 
449
                        raise BzrError('unknown short option %r' % a)
 
450
                    optname = SHORT_OPTIONS[shortopt]
 
451
 
 
452
                    if a[2:]:
 
453
                        # There are extra things on this option
 
454
                        # see if it is the value, or if it is another
 
455
                        # short option
 
456
                        optargfn = OPTIONS[optname]
 
457
                        if optargfn is None:
 
458
                            # This option does not take an argument, so the
 
459
                            # next entry is another short option, pack it back
 
460
                            # into the list
 
461
                            argv.insert(0, '-' + a[2:])
 
462
                        else:
 
463
                            # This option takes an argument, so pack it
 
464
                            # into the array
 
465
                            optarg = a[2:]
 
466
            
 
467
            if optname in opts:
 
468
                # XXX: Do we ever want to support this, e.g. for -r?
 
469
                raise BzrError('repeated option %r' % a)
 
470
                
 
471
            optargfn = OPTIONS[optname]
 
472
            if optargfn:
 
473
                if optarg == None:
 
474
                    if not argv:
 
475
                        raise BzrError('option %r needs an argument' % a)
 
476
                    else:
 
477
                        optarg = argv.pop(0)
 
478
                opts[optname] = optargfn(optarg)
 
479
            else:
 
480
                if optarg != None:
 
481
                    raise BzrError('option %r takes no argument' % optname)
 
482
                opts[optname] = True
 
483
        else:
 
484
            args.append(a)
 
485
 
547
486
    return args, opts
548
487
 
549
488
 
 
489
 
 
490
 
550
491
def _match_argform(cmd, takes_args, args):
551
492
    argdict = {}
552
493
 
564
505
                argdict[argname + '_list'] = None
565
506
        elif ap[-1] == '+':
566
507
            if not args:
567
 
                raise errors.BzrCommandError("command %r needs one or more %s"
568
 
                                             % (cmd, argname.upper()))
 
508
                raise BzrCommandError("command %r needs one or more %s"
 
509
                        % (cmd, argname.upper()))
569
510
            else:
570
511
                argdict[argname + '_list'] = args[:]
571
512
                args = []
572
513
        elif ap[-1] == '$': # all but one
573
514
            if len(args) < 2:
574
 
                raise errors.BzrCommandError("command %r needs one or more %s"
575
 
                                             % (cmd, argname.upper()))
 
515
                raise BzrCommandError("command %r needs one or more %s"
 
516
                        % (cmd, argname.upper()))
576
517
            argdict[argname + '_list'] = args[:-1]
577
 
            args[:-1] = []
 
518
            args[:-1] = []                
578
519
        else:
579
520
            # just a plain arg
580
521
            argname = ap
581
522
            if not args:
582
 
                raise errors.BzrCommandError("command %r requires argument %s"
583
 
                               % (cmd, argname.upper()))
 
523
                raise BzrCommandError("command %r requires argument %s"
 
524
                        % (cmd, argname.upper()))
584
525
            else:
585
526
                argdict[argname] = args.pop(0)
586
527
            
587
528
    if args:
588
 
        raise errors.BzrCommandError("extra argument to command %s: %s"
589
 
                                     % (cmd, args[0]))
 
529
        raise BzrCommandError("extra argument to command %s: %s"
 
530
                              % (cmd, args[0]))
590
531
 
591
532
    return argdict
592
533
 
595
536
def apply_profiled(the_callable, *args, **kwargs):
596
537
    import hotshot
597
538
    import tempfile
598
 
    import hotshot.stats
599
539
    pffileno, pfname = tempfile.mkstemp()
600
540
    try:
601
541
        prof = hotshot.Profile(pfname)
603
543
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
604
544
        finally:
605
545
            prof.close()
 
546
 
 
547
        import hotshot.stats
606
548
        stats = hotshot.stats.load(pfname)
607
 
        stats.strip_dirs()
608
 
        stats.sort_stats('cum')   # 'time'
 
549
        #stats.strip_dirs()
 
550
        stats.sort_stats('time')
609
551
        ## XXX: Might like to write to stderr or the trace file instead but
610
552
        ## print_stats seems hardcoded to stdout
611
553
        stats.print_stats(20)
 
554
 
612
555
        return ret
613
556
    finally:
614
557
        os.close(pffileno)
615
558
        os.remove(pfname)
616
559
 
617
560
 
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
 
 
650
561
def run_bzr(argv):
651
562
    """Execute a command.
652
563
 
655
566
    
656
567
    argv
657
568
       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).
660
569
    
661
570
    Returns a command status or raises an exception.
662
571
 
666
575
    --no-plugins
667
576
        Do not load plugin modules at all
668
577
 
669
 
    --no-aliases
670
 
        Do not allow aliases
671
 
 
672
578
    --builtin
673
579
        Only use builtin commands.  (Plugins are still allowed to change
674
580
        other behaviour.)
675
581
 
676
582
    --profile
677
 
        Run under the Python hotshot profiler.
678
 
 
679
 
    --lsprof
680
 
        Run under the Python lsprof profiler.
 
583
        Run under the Python profiler.
681
584
    """
682
 
    argv = list(argv)
683
 
    trace.mutter("bzr arguments: %r", argv)
 
585
    
 
586
    argv = [a.decode(bzrlib.user_encoding) for a in argv]
684
587
 
685
 
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
686
 
                opt_no_aliases = False
687
 
    opt_lsprof_file = None
 
588
    opt_profile = opt_no_plugins = opt_builtin = False
688
589
 
689
590
    # --no-plugins is handled specially at a very early stage. We need
690
591
    # to load plugins before doing other command parsing so that they
691
592
    # can override commands, but this needs to happen first.
692
593
 
693
 
    argv_copy = []
694
 
    i = 0
695
 
    while i < len(argv):
696
 
        a = argv[i]
 
594
    for a in argv:
697
595
        if a == '--profile':
698
596
            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
705
597
        elif a == '--no-plugins':
706
598
            opt_no_plugins = True
707
 
        elif a == '--no-aliases':
708
 
            opt_no_aliases = True
709
599
        elif a == '--builtin':
710
600
            opt_builtin = True
711
 
        elif a.startswith('-D'):
712
 
            debug.debug_flags.add(a[2:])
713
601
        else:
714
 
            argv_copy.append(a)
715
 
        i += 1
 
602
            break
 
603
        argv.remove(a)
716
604
 
717
 
    argv = argv_copy
718
 
    if (not argv):
719
 
        from bzrlib.builtins import cmd_help
720
 
        cmd_help().run_argv_aliases([])
 
605
    if (not argv) or (argv[0] == '--help'):
 
606
        from bzrlib.help import help
 
607
        if len(argv) > 1:
 
608
            help(argv[1])
 
609
        else:
 
610
            help()
721
611
        return 0
722
612
 
723
613
    if argv[0] == '--version':
724
 
        from bzrlib.builtins import cmd_version
725
 
        cmd_version().run_argv_aliases([])
 
614
        from bzrlib.builtins import show_version
 
615
        show_version()
726
616
        return 0
727
617
        
728
618
    if not opt_no_plugins:
729
619
        from bzrlib.plugin import load_plugins
730
620
        load_plugins()
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.
 
621
 
 
622
    cmd = str(argv.pop(0))
747
623
 
748
624
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
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
 
625
 
 
626
    if opt_profile:
 
627
        ret = apply_profiled(cmd_obj.run_argv, argv)
 
628
    else:
 
629
        ret = cmd_obj.run_argv(argv)
 
630
    return ret or 0
782
631
 
783
632
 
784
633
def main(argv):
785
634
    import bzrlib.ui
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
 
        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)
 
635
    bzrlib.trace.log_startup(argv)
 
636
    bzrlib.ui.ui_factory = bzrlib.ui.TextUIFactory()
 
637
 
 
638
    try:
 
639
        try:
 
640
            return run_bzr(argv[1:])
 
641
        finally:
 
642
            # do this here inside the exception wrappers to catch EPIPE
 
643
            sys.stdout.flush()
 
644
    except BzrCommandError, e:
 
645
        # command line syntax error, etc
 
646
        log_error(str(e))
 
647
        return 1
 
648
    except BzrError, e:
 
649
        bzrlib.trace.log_exception()
 
650
        return 1
 
651
    except AssertionError, e:
 
652
        bzrlib.trace.log_exception('assertion failed: ' + str(e))
811
653
        return 3
812
 
 
813
 
 
814
 
class HelpCommandIndex(object):
815
 
    """A index for bzr help that returns commands."""
816
 
 
817
 
    def __init__(self):
818
 
        self.prefix = 'commands/'
819
 
 
820
 
    def get_topics(self, topic):
821
 
        """Search for topic amongst commands.
822
 
 
823
 
        :param topic: A topic to search for.
824
 
        :return: A list which is either empty or contains a single
825
 
            Command entry.
826
 
        """
827
 
        if topic and topic.startswith(self.prefix):
828
 
            topic = topic[len(self.prefix):]
829
 
        try:
830
 
            cmd = _get_cmd_object(topic)
831
 
        except KeyError:
832
 
            return []
 
654
    except KeyboardInterrupt, e:
 
655
        bzrlib.trace.note('interrupted')
 
656
        return 2
 
657
    except Exception, e:
 
658
        import errno
 
659
        if (isinstance(e, IOError) 
 
660
            and hasattr(e, 'errno')
 
661
            and e.errno == errno.EPIPE):
 
662
            bzrlib.trace.note('broken pipe')
 
663
            return 2
833
664
        else:
834
 
            return [cmd]
 
665
            bzrlib.trace.log_exception()
 
666
            return 2
835
667
 
836
668
 
837
669
if __name__ == '__main__':