~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: John Arbash Meinel
  • Date: 2006-08-16 23:38:03 UTC
  • mto: This revision was merged to the branch mainline in revision 1942.
  • Revision ID: john@arbash-meinel.com-20060816233803-9c192384559be0fa
Caching revision_ids costs us a little (512 vs 475), but caching file-ids costs us a lot (780 vs 512), so disabling caching of file ids for now

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
1
# Copyright (C) 2006 by Canonical Ltd
 
2
#
 
3
# This program is free software; you can redistribute it and/or modify
 
4
# it under the terms of the GNU General Public License as published by
 
5
# the Free Software Foundation; either version 2 of the License, or
 
6
# (at your option) any later version.
 
7
#
 
8
# This program is distributed in the hope that it will be useful,
 
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
 
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
11
# GNU General Public License for more details.
 
12
#
 
13
# You should have received a copy of the GNU General Public License
 
14
# along with this program; if not, write to the Free Software
 
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 
16
 
 
17
 
 
18
# TODO: probably should say which arguments are candidates for glob
 
19
# expansion on windows and do that at the command level.
 
20
 
 
21
# TODO: Define arguments by objects, rather than just using names.
 
22
# Those objects can specify the expected type of the argument, which
 
23
# would help with validation and shell completion.  They could also provide
 
24
# help/explanation for that argument in a structured way.
 
25
 
 
26
# TODO: Specific "examples" property on commands for consistent formatting.
 
27
 
 
28
# TODO: "--profile=cum", to change sort order.  Is there any value in leaving
 
29
# the profile output behind so it can be interactively examined?
 
30
 
 
31
import codecs
 
32
import errno
 
33
import os
 
34
from warnings import warn
 
35
import sys
 
36
 
 
37
import bzrlib
 
38
import bzrlib.errors as errors
 
39
from bzrlib.errors import (BzrError,
 
40
                           BzrCommandError,
 
41
                           BzrCheckError,
 
42
                           NotBranchError)
 
43
from bzrlib import option
 
44
from bzrlib.option import Option
 
45
import bzrlib.osutils
 
46
from bzrlib.revisionspec import RevisionSpec
 
47
from bzrlib.symbol_versioning import (deprecated_method, zero_eight)
 
48
import bzrlib.trace
 
49
from bzrlib.trace import mutter, note, log_error, warning, be_quiet
 
50
 
 
51
plugin_cmds = {}
 
52
 
 
53
 
 
54
def register_command(cmd, decorate=False):
 
55
    """Utility function to help register a command
 
56
 
 
57
    :param cmd: Command subclass to register
 
58
    :param decorate: If true, allow overriding an existing command
 
59
        of the same name; the old command is returned by this function.
 
60
        Otherwise it is an error to try to override an existing command.
 
61
    """
 
62
    global plugin_cmds
 
63
    k = cmd.__name__
 
64
    if k.startswith("cmd_"):
 
65
        k_unsquished = _unsquish_command_name(k)
 
66
    else:
 
67
        k_unsquished = k
 
68
    if not plugin_cmds.has_key(k_unsquished):
 
69
        plugin_cmds[k_unsquished] = cmd
 
70
        mutter('registered plugin command %s', k_unsquished)
 
71
        if decorate and k_unsquished in builtin_command_names():
 
72
            return _builtin_commands()[k_unsquished]
 
73
    elif decorate:
 
74
        result = plugin_cmds[k_unsquished]
 
75
        plugin_cmds[k_unsquished] = cmd
 
76
        return result
 
77
    else:
 
78
        log_error('Two plugins defined the same command: %r' % k)
 
79
        log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
 
80
 
 
81
 
 
82
def _squish_command_name(cmd):
 
83
    return 'cmd_' + cmd.replace('-', '_')
 
84
 
 
85
 
 
86
def _unsquish_command_name(cmd):
 
87
    assert cmd.startswith("cmd_")
 
88
    return cmd[4:].replace('_','-')
 
89
 
 
90
 
 
91
def _builtin_commands():
 
92
    import bzrlib.builtins
 
93
    r = {}
 
94
    builtins = bzrlib.builtins.__dict__
 
95
    for name in builtins:
 
96
        if name.startswith("cmd_"):
 
97
            real_name = _unsquish_command_name(name)
 
98
            r[real_name] = builtins[name]
 
99
    return r
 
100
            
 
101
 
 
102
def builtin_command_names():
 
103
    """Return list of builtin command names."""
 
104
    return _builtin_commands().keys()
 
105
    
 
106
 
 
107
def plugin_command_names():
 
108
    return plugin_cmds.keys()
 
109
 
 
110
 
 
111
def _get_cmd_dict(plugins_override=True):
 
112
    """Return name->class mapping for all commands."""
 
113
    d = _builtin_commands()
 
114
    if plugins_override:
 
115
        d.update(plugin_cmds)
 
116
    return d
 
117
 
 
118
    
 
119
def get_all_cmds(plugins_override=True):
 
120
    """Return canonical name and class for all registered commands."""
 
121
    for k, v in _get_cmd_dict(plugins_override=plugins_override).iteritems():
 
122
        yield k,v
 
123
 
 
124
 
 
125
def get_cmd_object(cmd_name, plugins_override=True):
 
126
    """Return the canonical name and command class for a command.
 
127
 
 
128
    plugins_override
 
129
        If true, plugin commands can override builtins.
 
130
    """
 
131
    from bzrlib.externalcommand import ExternalCommand
 
132
 
 
133
    cmd_name = str(cmd_name)            # not unicode
 
134
 
 
135
    # first look up this command under the specified name
 
136
    cmds = _get_cmd_dict(plugins_override=plugins_override)
 
137
    try:
 
138
        return cmds[cmd_name]()
 
139
    except KeyError:
 
140
        pass
 
141
 
 
142
    # look for any command which claims this as an alias
 
143
    for real_cmd_name, cmd_class in cmds.iteritems():
 
144
        if cmd_name in cmd_class.aliases:
 
145
            return cmd_class()
 
146
 
 
147
    cmd_obj = ExternalCommand.find_command(cmd_name)
 
148
    if cmd_obj:
 
149
        return cmd_obj
 
150
 
 
151
    raise BzrCommandError('unknown command "%s"' % cmd_name)
 
152
 
 
153
 
 
154
class Command(object):
 
155
    """Base class for commands.
 
156
 
 
157
    Commands are the heart of the command-line bzr interface.
 
158
 
 
159
    The command object mostly handles the mapping of command-line
 
160
    parameters into one or more bzrlib operations, and of the results
 
161
    into textual output.
 
162
 
 
163
    Commands normally don't have any state.  All their arguments are
 
164
    passed in to the run method.  (Subclasses may take a different
 
165
    policy if the behaviour of the instance needs to depend on e.g. a
 
166
    shell plugin and not just its Python class.)
 
167
 
 
168
    The docstring for an actual command should give a single-line
 
169
    summary, then a complete description of the command.  A grammar
 
170
    description will be inserted.
 
171
 
 
172
    aliases
 
173
        Other accepted names for this command.
 
174
 
 
175
    takes_args
 
176
        List of argument forms, marked with whether they are optional,
 
177
        repeated, etc.
 
178
 
 
179
                Examples:
 
180
 
 
181
                ['to_location', 'from_branch?', 'file*']
 
182
 
 
183
                'to_location' is required
 
184
                'from_branch' is optional
 
185
                'file' can be specified 0 or more times
 
186
 
 
187
    takes_options
 
188
        List of options that may be given for this command.  These can
 
189
        be either strings, referring to globally-defined options,
 
190
        or option objects.  Retrieve through options().
 
191
 
 
192
    hidden
 
193
        If true, this command isn't advertised.  This is typically
 
194
        for commands intended for expert users.
 
195
 
 
196
    encoding_type
 
197
        Command objects will get a 'outf' attribute, which has been
 
198
        setup to properly handle encoding of unicode strings.
 
199
        encoding_type determines what will happen when characters cannot
 
200
        be encoded
 
201
            strict - abort if we cannot decode
 
202
            replace - put in a bogus character (typically '?')
 
203
            exact - do not encode sys.stdout
 
204
 
 
205
    """
 
206
    aliases = []
 
207
    takes_args = []
 
208
    takes_options = []
 
209
    encoding_type = 'strict'
 
210
 
 
211
    hidden = False
 
212
    
 
213
    def __init__(self):
 
214
        """Construct an instance of this command."""
 
215
        if self.__doc__ == Command.__doc__:
 
216
            warn("No help message set for %r" % self)
 
217
 
 
218
    def options(self):
 
219
        """Return dict of valid options for this command.
 
220
 
 
221
        Maps from long option name to option object."""
 
222
        r = dict()
 
223
        r['help'] = Option.OPTIONS['help']
 
224
        for o in self.takes_options:
 
225
            if isinstance(o, basestring):
 
226
                o = Option.OPTIONS[o]
 
227
            r[o.name] = o
 
228
        return r
 
229
 
 
230
    def _setup_outf(self):
 
231
        """Return a file linked to stdout, which has proper encoding."""
 
232
        assert self.encoding_type in ['strict', 'exact', 'replace']
 
233
 
 
234
        # Originally I was using self.stdout, but that looks
 
235
        # *way* too much like sys.stdout
 
236
        if self.encoding_type == 'exact':
 
237
            self.outf = sys.stdout
 
238
            return
 
239
 
 
240
        output_encoding = bzrlib.osutils.get_terminal_encoding()
 
241
 
 
242
        # use 'replace' so that we don't abort if trying to write out
 
243
        # in e.g. the default C locale.
 
244
        self.outf = codecs.getwriter(output_encoding)(sys.stdout, errors=self.encoding_type)
 
245
        # For whatever reason codecs.getwriter() does not advertise its encoding
 
246
        # it just returns the encoding of the wrapped file, which is completely
 
247
        # bogus. So set the attribute, so we can find the correct encoding later.
 
248
        self.outf.encoding = output_encoding
 
249
 
 
250
    @deprecated_method(zero_eight)
 
251
    def run_argv(self, argv):
 
252
        """Parse command line and run.
 
253
        
 
254
        See run_argv_aliases for the 0.8 and beyond api.
 
255
        """
 
256
        return self.run_argv_aliases(argv)
 
257
 
 
258
    def run_argv_aliases(self, argv, alias_argv=None):
 
259
        """Parse the command line and run with extra aliases in alias_argv."""
 
260
        if argv is None:
 
261
            warn("Passing None for [] is deprecated from bzrlib 0.10", 
 
262
                 DeprecationWarning, stacklevel=2)
 
263
            argv = []
 
264
        args, opts = parse_args(self, argv, alias_argv)
 
265
        if 'help' in opts:  # e.g. bzr add --help
 
266
            from bzrlib.help import help_on_command
 
267
            help_on_command(self.name())
 
268
            return 0
 
269
        # mix arguments and options into one dictionary
 
270
        cmdargs = _match_argform(self.name(), self.takes_args, args)
 
271
        cmdopts = {}
 
272
        for k, v in opts.items():
 
273
            cmdopts[k.replace('-', '_')] = v
 
274
 
 
275
        all_cmd_args = cmdargs.copy()
 
276
        all_cmd_args.update(cmdopts)
 
277
 
 
278
        self._setup_outf()
 
279
 
 
280
        return self.run(**all_cmd_args)
 
281
    
 
282
    def run(self):
 
283
        """Actually run the command.
 
284
 
 
285
        This is invoked with the options and arguments bound to
 
286
        keyword parameters.
 
287
 
 
288
        Return 0 or None if the command was successful, or a non-zero
 
289
        shell error code if not.  It's OK for this method to allow
 
290
        an exception to raise up.
 
291
        """
 
292
        raise NotImplementedError('no implementation of command %r' 
 
293
                                  % self.name())
 
294
 
 
295
    def help(self):
 
296
        """Return help message for this class."""
 
297
        from inspect import getdoc
 
298
        if self.__doc__ is Command.__doc__:
 
299
            return None
 
300
        return getdoc(self)
 
301
 
 
302
    def name(self):
 
303
        return _unsquish_command_name(self.__class__.__name__)
 
304
 
 
305
    def plugin_name(self):
 
306
        """Get the name of the plugin that provides this command.
 
307
 
 
308
        :return: The name of the plugin or None if the command is builtin.
 
309
        """
 
310
        mod_parts = self.__module__.split('.')
 
311
        if len(mod_parts) >= 3 and mod_parts[1] == 'plugins':
 
312
            return mod_parts[2]
 
313
        else:
 
314
            return None
 
315
 
 
316
 
 
317
def parse_spec(spec):
 
318
    """
 
319
    >>> parse_spec(None)
 
320
    [None, None]
 
321
    >>> parse_spec("./")
 
322
    ['./', None]
 
323
    >>> parse_spec("../@")
 
324
    ['..', -1]
 
325
    >>> parse_spec("../f/@35")
 
326
    ['../f', 35]
 
327
    >>> parse_spec('./@revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67')
 
328
    ['.', 'revid:john@arbash-meinel.com-20050711044610-3ca0327c6a222f67']
 
329
    """
 
330
    if spec is None:
 
331
        return [None, None]
 
332
    if '/@' in spec:
 
333
        parsed = spec.split('/@')
 
334
        assert len(parsed) == 2
 
335
        if parsed[1] == "":
 
336
            parsed[1] = -1
 
337
        else:
 
338
            try:
 
339
                parsed[1] = int(parsed[1])
 
340
            except ValueError:
 
341
                pass # We can allow stuff like ./@revid:blahblahblah
 
342
            else:
 
343
                assert parsed[1] >=0
 
344
    else:
 
345
        parsed = [spec, None]
 
346
    return parsed
 
347
 
 
348
def parse_args(command, argv, alias_argv=None):
 
349
    """Parse command line.
 
350
    
 
351
    Arguments and options are parsed at this level before being passed
 
352
    down to specific command handlers.  This routine knows, from a
 
353
    lookup table, something about the available options, what optargs
 
354
    they take, and which commands will accept them.
 
355
    """
 
356
    # TODO: make it a method of the Command?
 
357
    parser = option.get_optparser(command.options())
 
358
    if alias_argv is not None:
 
359
        args = alias_argv + argv
 
360
    else:
 
361
        args = argv
 
362
 
 
363
    options, args = parser.parse_args(args)
 
364
    opts = dict([(k, v) for k, v in options.__dict__.iteritems() if 
 
365
                 v is not option.OptionParser.DEFAULT_VALUE])
 
366
    return args, opts
 
367
 
 
368
 
 
369
def _match_argform(cmd, takes_args, args):
 
370
    argdict = {}
 
371
 
 
372
    # step through args and takes_args, allowing appropriate 0-many matches
 
373
    for ap in takes_args:
 
374
        argname = ap[:-1]
 
375
        if ap[-1] == '?':
 
376
            if args:
 
377
                argdict[argname] = args.pop(0)
 
378
        elif ap[-1] == '*': # all remaining arguments
 
379
            if args:
 
380
                argdict[argname + '_list'] = args[:]
 
381
                args = []
 
382
            else:
 
383
                argdict[argname + '_list'] = None
 
384
        elif ap[-1] == '+':
 
385
            if not args:
 
386
                raise BzrCommandError("command %r needs one or more %s"
 
387
                        % (cmd, argname.upper()))
 
388
            else:
 
389
                argdict[argname + '_list'] = args[:]
 
390
                args = []
 
391
        elif ap[-1] == '$': # all but one
 
392
            if len(args) < 2:
 
393
                raise BzrCommandError("command %r needs one or more %s"
 
394
                        % (cmd, argname.upper()))
 
395
            argdict[argname + '_list'] = args[:-1]
 
396
            args[:-1] = []
 
397
        else:
 
398
            # just a plain arg
 
399
            argname = ap
 
400
            if not args:
 
401
                raise BzrCommandError("command %r requires argument %s"
 
402
                        % (cmd, argname.upper()))
 
403
            else:
 
404
                argdict[argname] = args.pop(0)
 
405
            
 
406
    if args:
 
407
        raise BzrCommandError("extra argument to command %s: %s"
 
408
                              % (cmd, args[0]))
 
409
 
 
410
    return argdict
 
411
 
 
412
 
 
413
 
 
414
def apply_profiled(the_callable, *args, **kwargs):
 
415
    import hotshot
 
416
    import tempfile
 
417
    import hotshot.stats
 
418
    pffileno, pfname = tempfile.mkstemp()
 
419
    try:
 
420
        prof = hotshot.Profile(pfname)
 
421
        try:
 
422
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
 
423
        finally:
 
424
            prof.close()
 
425
        stats = hotshot.stats.load(pfname)
 
426
        stats.strip_dirs()
 
427
        stats.sort_stats('cum')   # 'time'
 
428
        ## XXX: Might like to write to stderr or the trace file instead but
 
429
        ## print_stats seems hardcoded to stdout
 
430
        stats.print_stats(20)
 
431
        return ret
 
432
    finally:
 
433
        os.close(pffileno)
 
434
        os.remove(pfname)
 
435
 
 
436
 
 
437
def apply_lsprofiled(filename, the_callable, *args, **kwargs):
 
438
    from bzrlib.lsprof import profile
 
439
    import cPickle
 
440
    ret, stats = profile(the_callable, *args, **kwargs)
 
441
    stats.sort()
 
442
    if filename is None:
 
443
        stats.pprint()
 
444
    else:
 
445
        stats.freeze()
 
446
        cPickle.dump(stats, open(filename, 'w'), 2)
 
447
        print 'Profile data written to %r.' % filename
 
448
    return ret
 
449
 
 
450
 
 
451
def get_alias(cmd):
 
452
    """Return an expanded alias, or None if no alias exists"""
 
453
    import bzrlib.config
 
454
    alias = bzrlib.config.GlobalConfig().get_alias(cmd)
 
455
    if (alias):
 
456
        return alias.split(' ')
 
457
    return None
 
458
 
 
459
 
 
460
def run_bzr(argv):
 
461
    """Execute a command.
 
462
 
 
463
    This is similar to main(), but without all the trappings for
 
464
    logging and error handling.  
 
465
    
 
466
    argv
 
467
       The command-line arguments, without the program name from argv[0]
 
468
       These should already be decoded. All library/test code calling
 
469
       run_bzr should be passing valid strings (don't need decoding).
 
470
    
 
471
    Returns a command status or raises an exception.
 
472
 
 
473
    Special master options: these must come before the command because
 
474
    they control how the command is interpreted.
 
475
 
 
476
    --no-plugins
 
477
        Do not load plugin modules at all
 
478
 
 
479
    --no-aliases
 
480
        Do not allow aliases
 
481
 
 
482
    --builtin
 
483
        Only use builtin commands.  (Plugins are still allowed to change
 
484
        other behaviour.)
 
485
 
 
486
    --profile
 
487
        Run under the Python hotshot profiler.
 
488
 
 
489
    --lsprof
 
490
        Run under the Python lsprof profiler.
 
491
    """
 
492
    argv = list(argv)
 
493
 
 
494
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin =  \
 
495
                opt_no_aliases = False
 
496
    opt_lsprof_file = None
 
497
 
 
498
    # --no-plugins is handled specially at a very early stage. We need
 
499
    # to load plugins before doing other command parsing so that they
 
500
    # can override commands, but this needs to happen first.
 
501
 
 
502
    argv_copy = []
 
503
    i = 0
 
504
    while i < len(argv):
 
505
        a = argv[i]
 
506
        if a == '--profile':
 
507
            opt_profile = True
 
508
        elif a == '--lsprof':
 
509
            opt_lsprof = True
 
510
        elif a == '--lsprof-file':
 
511
            opt_lsprof = True
 
512
            opt_lsprof_file = argv[i + 1]
 
513
            i += 1
 
514
        elif a == '--no-plugins':
 
515
            opt_no_plugins = True
 
516
        elif a == '--no-aliases':
 
517
            opt_no_aliases = True
 
518
        elif a == '--builtin':
 
519
            opt_builtin = True
 
520
        elif a in ('--quiet', '-q'):
 
521
            be_quiet()
 
522
        else:
 
523
            argv_copy.append(a)
 
524
        i += 1
 
525
 
 
526
    argv = argv_copy
 
527
    if (not argv):
 
528
        from bzrlib.builtins import cmd_help
 
529
        cmd_help().run_argv_aliases([])
 
530
        return 0
 
531
 
 
532
    if argv[0] == '--version':
 
533
        from bzrlib.version import show_version
 
534
        show_version()
 
535
        return 0
 
536
        
 
537
    if not opt_no_plugins:
 
538
        from bzrlib.plugin import load_plugins
 
539
        load_plugins()
 
540
    else:
 
541
        from bzrlib.plugin import disable_plugins
 
542
        disable_plugins()
 
543
 
 
544
    alias_argv = None
 
545
 
 
546
    if not opt_no_aliases:
 
547
        alias_argv = get_alias(argv[0])
 
548
        if alias_argv:
 
549
            alias_argv = [a.decode(bzrlib.user_encoding) for a in alias_argv]
 
550
            argv[0] = alias_argv.pop(0)
 
551
 
 
552
    cmd = str(argv.pop(0))
 
553
 
 
554
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
 
555
    if not getattr(cmd_obj.run_argv, 'is_deprecated', False):
 
556
        run = cmd_obj.run_argv
 
557
        run_argv = [argv]
 
558
    else:
 
559
        run = cmd_obj.run_argv_aliases
 
560
        run_argv = [argv, alias_argv]
 
561
 
 
562
    try:
 
563
        if opt_lsprof:
 
564
            ret = apply_lsprofiled(opt_lsprof_file, run, *run_argv)
 
565
        elif opt_profile:
 
566
            ret = apply_profiled(run, *run_argv)
 
567
        else:
 
568
            ret = run(*run_argv)
 
569
        return ret or 0
 
570
    finally:
 
571
        # reset, in case we may do other commands later within the same process
 
572
        be_quiet(False)
 
573
 
 
574
def display_command(func):
 
575
    """Decorator that suppresses pipe/interrupt errors."""
 
576
    def ignore_pipe(*args, **kwargs):
 
577
        try:
 
578
            result = func(*args, **kwargs)
 
579
            sys.stdout.flush()
 
580
            return result
 
581
        except IOError, e:
 
582
            if not hasattr(e, 'errno'):
 
583
                raise
 
584
            if e.errno != errno.EPIPE:
 
585
                # Win32 raises IOError with errno=0 on a broken pipe
 
586
                if sys.platform != 'win32' or e.errno != 0:
 
587
                    raise
 
588
            pass
 
589
        except KeyboardInterrupt:
 
590
            pass
 
591
    return ignore_pipe
 
592
 
 
593
 
 
594
def main(argv):
 
595
    import bzrlib.ui
 
596
    from bzrlib.ui.text import TextUIFactory
 
597
    bzrlib.ui.ui_factory = TextUIFactory()
 
598
    argv = [a.decode(bzrlib.user_encoding) for a in argv[1:]]
 
599
    ret = run_bzr_catch_errors(argv)
 
600
    mutter("return code %d", ret)
 
601
    return ret
 
602
 
 
603
 
 
604
def run_bzr_catch_errors(argv):
 
605
    try:
 
606
        return run_bzr(argv)
 
607
        # do this here inside the exception wrappers to catch EPIPE
 
608
        sys.stdout.flush()
 
609
    except Exception, e:
 
610
        # used to handle AssertionError and KeyboardInterrupt
 
611
        # specially here, but hopefully they're handled ok by the logger now
 
612
        bzrlib.trace.report_exception(sys.exc_info(), sys.stderr)
 
613
        if os.environ.get('BZR_PDB'):
 
614
            print '**** entering debugger'
 
615
            import pdb
 
616
            pdb.post_mortem(sys.exc_traceback)
 
617
        return 3
 
618
 
 
619
if __name__ == '__main__':
 
620
    sys.exit(main(sys.argv))