~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: John Arbash Meinel
  • Date: 2007-07-16 19:55:36 UTC
  • mfrom: (2601.1.3 bzr.dev.docs)
  • mto: This revision was merged to the branch mainline in revision 2621.
  • Revision ID: john@arbash-meinel.com-20070716195536-7swyum1epmk0313d
(James Westby) documentation updates (plugins, configuration, etc)

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
21
# TODO: Define arguments by objects, rather than just using names.
24
22
# Those objects can specify the expected type of the argument, which
25
 
# would help with validation and shell completion.
26
 
 
27
 
 
28
 
 
 
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
29
32
import sys
30
 
import os
 
33
 
 
34
from bzrlib.lazy_import import lazy_import
 
35
lazy_import(globals(), """
 
36
import codecs
 
37
import errno
31
38
from warnings import warn
32
 
from inspect import getdoc
33
39
 
34
40
import bzrlib
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
 
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
    zero_eight,
 
55
    zero_eleven,
 
56
    )
 
57
# Compatibility
 
58
from bzrlib.option import Option
 
59
 
40
60
 
41
61
plugin_cmds = {}
42
62
 
43
63
 
44
 
def register_command(cmd):
45
 
    "Utility function to help register a command"
 
64
def register_command(cmd, decorate=False):
 
65
    """Utility function to help register a command
 
66
 
 
67
    :param cmd: Command subclass to register
 
68
    :param decorate: If true, allow overriding an existing command
 
69
        of the same name; the old command is returned by this function.
 
70
        Otherwise it is an error to try to override an existing command.
 
71
    """
46
72
    global plugin_cmds
47
73
    k = cmd.__name__
48
74
    if k.startswith("cmd_"):
49
75
        k_unsquished = _unsquish_command_name(k)
50
76
    else:
51
77
        k_unsquished = k
52
 
    if not plugin_cmds.has_key(k_unsquished):
53
 
        plugin_cmds[k_unsquished] = cmd
54
 
        mutter('registered plugin command %s', k_unsquished)      
 
78
    if k_unsquished not in plugin_cmds:
 
79
        plugin_cmds[k_unsquished] = cmd
 
80
        ## trace.mutter('registered plugin command %s', k_unsquished)
 
81
        if decorate and k_unsquished in builtin_command_names():
 
82
            return _builtin_commands()[k_unsquished]
 
83
    elif decorate:
 
84
        result = plugin_cmds[k_unsquished]
 
85
        plugin_cmds[k_unsquished] = cmd
 
86
        return result
55
87
    else:
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
        trace.log_error('Two plugins defined the same command: %r' % k)
 
89
        trace.log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
58
90
 
59
91
 
60
92
def _squish_command_name(cmd):
66
98
    return cmd[4:].replace('_','-')
67
99
 
68
100
 
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
101
def _builtin_commands():
154
102
    import bzrlib.builtins
155
103
    r = {}
156
104
    builtins = bzrlib.builtins.__dict__
157
105
    for name in builtins:
158
106
        if name.startswith("cmd_"):
159
 
            real_name = _unsquish_command_name(name)        
 
107
            real_name = _unsquish_command_name(name)
160
108
            r[real_name] = builtins[name]
161
109
    return r
162
 
 
163
110
            
164
111
 
165
112
def builtin_command_names():
191
138
    plugins_override
192
139
        If true, plugin commands can override builtins.
193
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."""
194
149
    from bzrlib.externalcommand import ExternalCommand
195
150
 
196
 
    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.
197
155
 
198
156
    # first look up this command under the specified name
199
157
    cmds = _get_cmd_dict(plugins_override=plugins_override)
210
168
    cmd_obj = ExternalCommand.find_command(cmd_name)
211
169
    if cmd_obj:
212
170
        return cmd_obj
213
 
 
214
 
    raise BzrCommandError("unknown command %r" % cmd_name)
 
171
    raise KeyError
215
172
 
216
173
 
217
174
class Command(object):
239
196
        List of argument forms, marked with whether they are optional,
240
197
        repeated, etc.
241
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
 
242
207
    takes_options
243
 
        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().
244
211
 
245
212
    hidden
246
213
        If true, this command isn't advertised.  This is typically
247
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
 
248
231
    """
249
232
    aliases = []
250
 
    
251
233
    takes_args = []
252
234
    takes_options = []
 
235
    encoding_type = 'strict'
253
236
 
254
237
    hidden = False
255
238
    
258
241
        if self.__doc__ == Command.__doc__:
259
242
            warn("No help message set for %r" % self)
260
243
 
261
 
 
262
 
    def run_argv(self, argv):
263
 
        """Parse command line and run."""
264
 
        args, opts = parse_args(argv)
265
 
 
 
244
    def _maybe_expand_globs(self, file_list):
 
245
        """Glob expand file_list if the platform does not do that itself.
 
246
        
 
247
        :return: A possibly empty list of unicode paths.
 
248
 
 
249
        Introduced in bzrlib 0.18.
 
250
        """
 
251
        if not file_list:
 
252
            file_list = []
 
253
        if sys.platform == 'win32':
 
254
            file_list = win32utils.glob_expand(file_list)
 
255
        return list(file_list)
 
256
 
 
257
    def _usage(self):
 
258
        """Return single-line grammar for this command.
 
259
 
 
260
        Only describes arguments, not options.
 
261
        """
 
262
        s = 'bzr ' + self.name() + ' '
 
263
        for aname in self.takes_args:
 
264
            aname = aname.upper()
 
265
            if aname[-1] in ['$', '+']:
 
266
                aname = aname[:-1] + '...'
 
267
            elif aname[-1] == '?':
 
268
                aname = '[' + aname[:-1] + ']'
 
269
            elif aname[-1] == '*':
 
270
                aname = '[' + aname[:-1] + '...]'
 
271
            s += aname + ' '
 
272
                
 
273
        assert s[-1] == ' '
 
274
        s = s[:-1]
 
275
        return s
 
276
 
 
277
    def get_help_text(self, additional_see_also=None):
 
278
        """Return a text string with help for this command.
 
279
        
 
280
        :param additional_see_also: Additional help topics to be
 
281
            cross-referenced.
 
282
        """
 
283
        doc = self.help()
 
284
        if doc is None:
 
285
            raise NotImplementedError("sorry, no detailed help yet for %r" % self.name())
 
286
 
 
287
        result = ""
 
288
        result += 'usage: %s\n' % self._usage()
 
289
 
 
290
        if self.aliases:
 
291
            result += 'aliases: '
 
292
            result += ', '.join(self.aliases) + '\n'
 
293
 
 
294
        result += '\n'
 
295
 
 
296
        plugin_name = self.plugin_name()
 
297
        if plugin_name is not None:
 
298
            result += '(From plugin "%s")' % plugin_name
 
299
            result += '\n\n'
 
300
 
 
301
        result += doc
 
302
        if result[-1] != '\n':
 
303
            result += '\n'
 
304
        result += '\n'
 
305
        result += option.get_optparser(self.options()).format_option_help()
 
306
        see_also = self.get_see_also(additional_see_also)
 
307
        if see_also:
 
308
            result += '\nSee also: '
 
309
            result += ', '.join(see_also)
 
310
            result += '\n'
 
311
        return result
 
312
 
 
313
    def get_help_topic(self):
 
314
        """Return the commands help topic - its name."""
 
315
        return self.name()
 
316
 
 
317
    def get_see_also(self, additional_terms=None):
 
318
        """Return a list of help topics that are related to this ommand.
 
319
        
 
320
        The list is derived from the content of the _see_also attribute. Any
 
321
        duplicates are removed and the result is in lexical order.
 
322
        :param additional_terms: Additional help topics to cross-reference.
 
323
        :return: A list of help topics.
 
324
        """
 
325
        see_also = set(getattr(self, '_see_also', []))
 
326
        if additional_terms:
 
327
            see_also.update(additional_terms)
 
328
        return sorted(see_also)
 
329
 
 
330
    def options(self):
 
331
        """Return dict of valid options for this command.
 
332
 
 
333
        Maps from long option name to option object."""
 
334
        r = dict()
 
335
        r['help'] = option._help_option
 
336
        for o in self.takes_options:
 
337
            if isinstance(o, basestring):
 
338
                o = option.Option.OPTIONS[o]
 
339
            r[o.name] = o
 
340
        return r
 
341
 
 
342
    def _setup_outf(self):
 
343
        """Return a file linked to stdout, which has proper encoding."""
 
344
        assert self.encoding_type in ['strict', 'exact', 'replace']
 
345
 
 
346
        # Originally I was using self.stdout, but that looks
 
347
        # *way* too much like sys.stdout
 
348
        if self.encoding_type == 'exact':
 
349
            # force sys.stdout to be binary stream on win32
 
350
            if sys.platform == 'win32':
 
351
                fileno = getattr(sys.stdout, 'fileno', None)
 
352
                if fileno:
 
353
                    import msvcrt
 
354
                    msvcrt.setmode(fileno(), os.O_BINARY)
 
355
            self.outf = sys.stdout
 
356
            return
 
357
 
 
358
        output_encoding = osutils.get_terminal_encoding()
 
359
 
 
360
        # use 'replace' so that we don't abort if trying to write out
 
361
        # in e.g. the default C locale.
 
362
        self.outf = codecs.getwriter(output_encoding)(sys.stdout, errors=self.encoding_type)
 
363
        # For whatever reason codecs.getwriter() does not advertise its encoding
 
364
        # it just returns the encoding of the wrapped file, which is completely
 
365
        # bogus. So set the attribute, so we can find the correct encoding later.
 
366
        self.outf.encoding = output_encoding
 
367
 
 
368
    def run_argv_aliases(self, argv, alias_argv=None):
 
369
        """Parse the command line and run with extra aliases in alias_argv."""
 
370
        if argv is None:
 
371
            warn("Passing None for [] is deprecated from bzrlib 0.10",
 
372
                 DeprecationWarning, stacklevel=2)
 
373
            argv = []
 
374
        args, opts = parse_args(self, argv, alias_argv)
266
375
        if 'help' in opts:  # e.g. bzr add --help
267
 
            from bzrlib.help import help_on_command
268
 
            help_on_command(self.name())
 
376
            sys.stdout.write(self.get_help_text())
269
377
            return 0
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()))
277
 
 
278
378
        # mix arguments and options into one dictionary
279
379
        cmdargs = _match_argform(self.name(), self.takes_args, args)
280
380
        cmdopts = {}
284
384
        all_cmd_args = cmdargs.copy()
285
385
        all_cmd_args.update(cmdopts)
286
386
 
 
387
        self._setup_outf()
 
388
 
287
389
        return self.run(**all_cmd_args)
288
 
 
289
390
    
290
391
    def run(self):
291
392
        """Actually run the command.
297
398
        shell error code if not.  It's OK for this method to allow
298
399
        an exception to raise up.
299
400
        """
300
 
        raise NotImplementedError()
301
 
 
 
401
        raise NotImplementedError('no implementation of command %r'
 
402
                                  % self.name())
302
403
 
303
404
    def help(self):
304
405
        """Return help message for this class."""
 
406
        from inspect import getdoc
305
407
        if self.__doc__ is Command.__doc__:
306
408
            return None
307
409
        return getdoc(self)
309
411
    def name(self):
310
412
        return _unsquish_command_name(self.__class__.__name__)
311
413
 
312
 
 
 
414
    def plugin_name(self):
 
415
        """Get the name of the plugin that provides this command.
 
416
 
 
417
        :return: The name of the plugin or None if the command is builtin.
 
418
        """
 
419
        mod_parts = self.__module__.split('.')
 
420
        if len(mod_parts) >= 3 and mod_parts[1] == 'plugins':
 
421
            return mod_parts[2]
 
422
        else:
 
423
            return None
 
424
 
 
425
 
 
426
# Technically, this function hasn't been use in a *really* long time
 
427
# but we are only deprecating it now.
 
428
@deprecated_function(zero_eleven)
313
429
def parse_spec(spec):
314
430
    """
315
431
    >>> parse_spec(None)
341
457
        parsed = [spec, None]
342
458
    return parsed
343
459
 
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):
 
460
def parse_args(command, argv, alias_argv=None):
388
461
    """Parse command line.
389
462
    
390
463
    Arguments and options are parsed at this level before being passed
391
464
    down to specific command handlers.  This routine knows, from a
392
465
    lookup table, something about the available options, what optargs
393
466
    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]})
413
467
    """
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
 
 
 
468
    # TODO: make it a method of the Command?
 
469
    parser = option.get_optparser(command.options())
 
470
    if alias_argv is not None:
 
471
        args = alias_argv + argv
 
472
    else:
 
473
        args = argv
 
474
 
 
475
    options, args = parser.parse_args(args)
 
476
    opts = dict([(k, v) for k, v in options.__dict__.iteritems() if
 
477
                 v is not option.OptionParser.DEFAULT_VALUE])
486
478
    return args, opts
487
479
 
488
480
 
489
 
 
490
 
 
491
481
def _match_argform(cmd, takes_args, args):
492
482
    argdict = {}
493
483
 
505
495
                argdict[argname + '_list'] = None
506
496
        elif ap[-1] == '+':
507
497
            if not args:
508
 
                raise BzrCommandError("command %r needs one or more %s"
509
 
                        % (cmd, argname.upper()))
 
498
                raise errors.BzrCommandError("command %r needs one or more %s"
 
499
                                             % (cmd, argname.upper()))
510
500
            else:
511
501
                argdict[argname + '_list'] = args[:]
512
502
                args = []
513
503
        elif ap[-1] == '$': # all but one
514
504
            if len(args) < 2:
515
 
                raise BzrCommandError("command %r needs one or more %s"
516
 
                        % (cmd, argname.upper()))
 
505
                raise errors.BzrCommandError("command %r needs one or more %s"
 
506
                                             % (cmd, argname.upper()))
517
507
            argdict[argname + '_list'] = args[:-1]
518
 
            args[:-1] = []                
 
508
            args[:-1] = []
519
509
        else:
520
510
            # just a plain arg
521
511
            argname = ap
522
512
            if not args:
523
 
                raise BzrCommandError("command %r requires argument %s"
524
 
                        % (cmd, argname.upper()))
 
513
                raise errors.BzrCommandError("command %r requires argument %s"
 
514
                               % (cmd, argname.upper()))
525
515
            else:
526
516
                argdict[argname] = args.pop(0)
527
517
            
528
518
    if args:
529
 
        raise BzrCommandError("extra argument to command %s: %s"
530
 
                              % (cmd, args[0]))
 
519
        raise errors.BzrCommandError("extra argument to command %s: %s"
 
520
                                     % (cmd, args[0]))
531
521
 
532
522
    return argdict
533
523
 
536
526
def apply_profiled(the_callable, *args, **kwargs):
537
527
    import hotshot
538
528
    import tempfile
 
529
    import hotshot.stats
539
530
    pffileno, pfname = tempfile.mkstemp()
540
531
    try:
541
532
        prof = hotshot.Profile(pfname)
543
534
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
544
535
        finally:
545
536
            prof.close()
546
 
 
547
 
        import hotshot.stats
548
537
        stats = hotshot.stats.load(pfname)
549
 
        #stats.strip_dirs()
550
 
        stats.sort_stats('time')
 
538
        stats.strip_dirs()
 
539
        stats.sort_stats('cum')   # 'time'
551
540
        ## XXX: Might like to write to stderr or the trace file instead but
552
541
        ## print_stats seems hardcoded to stdout
553
542
        stats.print_stats(20)
554
 
 
555
543
        return ret
556
544
    finally:
557
545
        os.close(pffileno)
558
546
        os.remove(pfname)
559
547
 
560
548
 
 
549
def apply_lsprofiled(filename, the_callable, *args, **kwargs):
 
550
    from bzrlib.lsprof import profile
 
551
    ret, stats = profile(the_callable, *args, **kwargs)
 
552
    stats.sort()
 
553
    if filename is None:
 
554
        stats.pprint()
 
555
    else:
 
556
        stats.save(filename)
 
557
        trace.note('Profile data written to "%s".', filename)
 
558
    return ret
 
559
 
 
560
 
 
561
def get_alias(cmd, config=None):
 
562
    """Return an expanded alias, or None if no alias exists.
 
563
 
 
564
    cmd
 
565
        Command to be checked for an alias.
 
566
    config
 
567
        Used to specify an alternative config to use,
 
568
        which is especially useful for testing.
 
569
        If it is unspecified, the global config will be used.
 
570
    """
 
571
    if config is None:
 
572
        import bzrlib.config
 
573
        config = bzrlib.config.GlobalConfig()
 
574
    alias = config.get_alias(cmd)
 
575
    if (alias):
 
576
        import shlex
 
577
        return [a.decode('utf-8') for a in shlex.split(alias.encode('utf-8'))]
 
578
    return None
 
579
 
 
580
 
561
581
def run_bzr(argv):
562
582
    """Execute a command.
563
583
 
566
586
    
567
587
    argv
568
588
       The command-line arguments, without the program name from argv[0]
 
589
       These should already be decoded. All library/test code calling
 
590
       run_bzr should be passing valid strings (don't need decoding).
569
591
    
570
592
    Returns a command status or raises an exception.
571
593
 
575
597
    --no-plugins
576
598
        Do not load plugin modules at all
577
599
 
 
600
    --no-aliases
 
601
        Do not allow aliases
 
602
 
578
603
    --builtin
579
604
        Only use builtin commands.  (Plugins are still allowed to change
580
605
        other behaviour.)
581
606
 
582
607
    --profile
583
 
        Run under the Python profiler.
 
608
        Run under the Python hotshot profiler.
 
609
 
 
610
    --lsprof
 
611
        Run under the Python lsprof profiler.
584
612
    """
585
 
    
586
 
    argv = [a.decode(bzrlib.user_encoding) for a in argv]
 
613
    argv = list(argv)
 
614
    trace.mutter("bzr arguments: %r", argv)
587
615
 
588
 
    opt_profile = opt_no_plugins = opt_builtin = False
 
616
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
 
617
                opt_no_aliases = False
 
618
    opt_lsprof_file = None
589
619
 
590
620
    # --no-plugins is handled specially at a very early stage. We need
591
621
    # to load plugins before doing other command parsing so that they
592
622
    # can override commands, but this needs to happen first.
593
623
 
594
 
    for a in argv:
 
624
    argv_copy = []
 
625
    i = 0
 
626
    while i < len(argv):
 
627
        a = argv[i]
595
628
        if a == '--profile':
596
629
            opt_profile = True
 
630
        elif a == '--lsprof':
 
631
            opt_lsprof = True
 
632
        elif a == '--lsprof-file':
 
633
            opt_lsprof = True
 
634
            opt_lsprof_file = argv[i + 1]
 
635
            i += 1
597
636
        elif a == '--no-plugins':
598
637
            opt_no_plugins = True
 
638
        elif a == '--no-aliases':
 
639
            opt_no_aliases = True
599
640
        elif a == '--builtin':
600
641
            opt_builtin = True
 
642
        elif a in ('--quiet', '-q'):
 
643
            trace.be_quiet()
 
644
        elif a.startswith('-D'):
 
645
            debug.debug_flags.add(a[2:])
601
646
        else:
602
 
            break
603
 
        argv.remove(a)
 
647
            argv_copy.append(a)
 
648
        i += 1
604
649
 
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()
 
650
    argv = argv_copy
 
651
    if (not argv):
 
652
        from bzrlib.builtins import cmd_help
 
653
        cmd_help().run_argv_aliases([])
611
654
        return 0
612
655
 
613
656
    if argv[0] == '--version':
614
 
        from bzrlib.builtins import show_version
 
657
        from bzrlib.version import show_version
615
658
        show_version()
616
659
        return 0
617
660
        
618
661
    if not opt_no_plugins:
619
662
        from bzrlib.plugin import load_plugins
620
663
        load_plugins()
621
 
 
622
 
    cmd = str(argv.pop(0))
 
664
    else:
 
665
        from bzrlib.plugin import disable_plugins
 
666
        disable_plugins()
 
667
 
 
668
    alias_argv = None
 
669
 
 
670
    if not opt_no_aliases:
 
671
        alias_argv = get_alias(argv[0])
 
672
        if alias_argv:
 
673
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
 
674
            argv[0] = alias_argv.pop(0)
 
675
 
 
676
    cmd = argv.pop(0)
 
677
    # We want only 'ascii' command names, but the user may have typed
 
678
    # in a Unicode name. In that case, they should just get a
 
679
    # 'command not found' error later.
623
680
 
624
681
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
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
 
682
    run = cmd_obj.run_argv_aliases
 
683
    run_argv = [argv, alias_argv]
 
684
 
 
685
    try:
 
686
        if opt_lsprof:
 
687
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
 
688
        elif opt_profile:
 
689
            ret = apply_profiled(run, *run_argv)
 
690
        else:
 
691
            ret = run(*run_argv)
 
692
        return ret or 0
 
693
    finally:
 
694
        # reset, in case we may do other commands later within the same process
 
695
        trace.be_quiet(False)
 
696
 
 
697
def display_command(func):
 
698
    """Decorator that suppresses pipe/interrupt errors."""
 
699
    def ignore_pipe(*args, **kwargs):
 
700
        try:
 
701
            result = func(*args, **kwargs)
 
702
            sys.stdout.flush()
 
703
            return result
 
704
        except IOError, e:
 
705
            if getattr(e, 'errno', None) is None:
 
706
                raise
 
707
            if e.errno != errno.EPIPE:
 
708
                # Win32 raises IOError with errno=0 on a broken pipe
 
709
                if sys.platform != 'win32' or (e.errno not in (0, errno.EINVAL)):
 
710
                    raise
 
711
            pass
 
712
        except KeyboardInterrupt:
 
713
            pass
 
714
    return ignore_pipe
631
715
 
632
716
 
633
717
def main(argv):
634
718
    import bzrlib.ui
635
 
    bzrlib.trace.log_startup(argv)
636
 
    bzrlib.ui.ui_factory = bzrlib.ui.TextUIFactory()
637
 
 
 
719
    from bzrlib.ui.text import TextUIFactory
 
720
    bzrlib.ui.ui_factory = TextUIFactory()
 
721
    argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
 
722
    ret = run_bzr_catch_errors(argv)
 
723
    trace.mutter("return code %d", ret)
 
724
    return ret
 
725
 
 
726
 
 
727
def run_bzr_catch_errors(argv):
638
728
    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))
 
729
        return run_bzr(argv)
 
730
    except (KeyboardInterrupt, Exception), e:
 
731
        # used to handle AssertionError and KeyboardInterrupt
 
732
        # specially here, but hopefully they're handled ok by the logger now
 
733
        trace.report_exception(sys.exc_info(), sys.stderr)
 
734
        if os.environ.get('BZR_PDB'):
 
735
            print '**** entering debugger'
 
736
            import pdb
 
737
            pdb.post_mortem(sys.exc_traceback)
653
738
        return 3
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
 
739
 
 
740
 
 
741
class HelpCommandIndex(object):
 
742
    """A index for bzr help that returns commands."""
 
743
 
 
744
    def __init__(self):
 
745
        self.prefix = 'commands/'
 
746
 
 
747
    def get_topics(self, topic):
 
748
        """Search for topic amongst commands.
 
749
 
 
750
        :param topic: A topic to search for.
 
751
        :return: A list which is either empty or contains a single
 
752
            Command entry.
 
753
        """
 
754
        if topic and topic.startswith(self.prefix):
 
755
            topic = topic[len(self.prefix):]
 
756
        try:
 
757
            cmd = _get_cmd_object(topic)
 
758
        except KeyError:
 
759
            return []
664
760
        else:
665
 
            bzrlib.trace.log_exception()
666
 
            return 2
 
761
            return [cmd]
667
762
 
668
763
 
669
764
if __name__ == '__main__':