~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: John Arbash Meinel
  • Date: 2005-09-17 20:29:29 UTC
  • mto: (1393.2.1)
  • mto: This revision was merged to the branch mainline in revision 1396.
  • Revision ID: john@arbash-meinel.com-20050917202929-a9e4a3be80bf4ba4
Working on getting tests to run. TestFetch only works if named runTest

Show diffs side-by-side

added added

removed removed

Lines of Context:
24
24
# Those objects can specify the expected type of the argument, which
25
25
# would help with validation and shell completion.
26
26
 
27
 
# TODO: "--profile=cum", to change sort order.  Is there any value in leaving
28
 
# the profile output behind so it can be interactively examined?
 
27
 
 
28
# TODO: Help messages for options.
 
29
 
 
30
# TODO: Define arguments by objects, rather than just using names.
 
31
# Those objects can specify the expected type of the argument, which
 
32
# would help with validation and shell completion.
 
33
 
 
34
 
29
35
 
30
36
import sys
31
37
import os
32
38
from warnings import warn
33
39
from inspect import getdoc
34
 
import errno
35
40
 
36
41
import bzrlib
37
42
import bzrlib.trace
38
 
from bzrlib.trace import mutter, note, log_error, warning, be_quiet
39
 
from bzrlib.errors import (BzrError, 
40
 
                           BzrCheckError,
41
 
                           BzrCommandError,
42
 
                           BzrOptionError,
43
 
                           NotBranchError)
 
43
from bzrlib.trace import mutter, note, log_error, warning
 
44
from bzrlib.errors import BzrError, BzrCheckError, BzrCommandError, NotBranchError
44
45
from bzrlib.revisionspec import RevisionSpec
45
46
from bzrlib import BZRDIR
46
 
from bzrlib.option import Option
47
47
 
48
48
plugin_cmds = {}
49
49
 
50
50
 
51
 
def register_command(cmd, decorate=False):
 
51
def register_command(cmd):
52
52
    "Utility function to help register a command"
53
53
    global plugin_cmds
54
54
    k = cmd.__name__
59
59
    if not plugin_cmds.has_key(k_unsquished):
60
60
        plugin_cmds[k_unsquished] = cmd
61
61
        mutter('registered plugin command %s', k_unsquished)      
62
 
        if decorate and k_unsquished in builtin_command_names():
63
 
            return _builtin_commands()[k_unsquished]
64
 
    elif decorate:
65
 
        result = plugin_cmds[k_unsquished]
66
 
        plugin_cmds[k_unsquished] = cmd
67
 
        return result
68
62
    else:
69
63
        log_error('Two plugins defined the same command: %r' % k)
70
64
        log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
79
73
    return cmd[4:].replace('_','-')
80
74
 
81
75
 
 
76
def _parse_revision_str(revstr):
 
77
    """This handles a revision string -> revno.
 
78
 
 
79
    This always returns a list.  The list will have one element for
 
80
    each revision.
 
81
 
 
82
    >>> _parse_revision_str('234')
 
83
    [<RevisionSpec_int 234>]
 
84
    >>> _parse_revision_str('234..567')
 
85
    [<RevisionSpec_int 234>, <RevisionSpec_int 567>]
 
86
    >>> _parse_revision_str('..')
 
87
    [<RevisionSpec None>, <RevisionSpec None>]
 
88
    >>> _parse_revision_str('..234')
 
89
    [<RevisionSpec None>, <RevisionSpec_int 234>]
 
90
    >>> _parse_revision_str('234..')
 
91
    [<RevisionSpec_int 234>, <RevisionSpec None>]
 
92
    >>> _parse_revision_str('234..456..789') # Maybe this should be an error
 
93
    [<RevisionSpec_int 234>, <RevisionSpec_int 456>, <RevisionSpec_int 789>]
 
94
    >>> _parse_revision_str('234....789') # Error?
 
95
    [<RevisionSpec_int 234>, <RevisionSpec None>, <RevisionSpec_int 789>]
 
96
    >>> _parse_revision_str('revid:test@other.com-234234')
 
97
    [<RevisionSpec_revid revid:test@other.com-234234>]
 
98
    >>> _parse_revision_str('revid:test@other.com-234234..revid:test@other.com-234235')
 
99
    [<RevisionSpec_revid revid:test@other.com-234234>, <RevisionSpec_revid revid:test@other.com-234235>]
 
100
    >>> _parse_revision_str('revid:test@other.com-234234..23')
 
101
    [<RevisionSpec_revid revid:test@other.com-234234>, <RevisionSpec_int 23>]
 
102
    >>> _parse_revision_str('date:2005-04-12')
 
103
    [<RevisionSpec_date date:2005-04-12>]
 
104
    >>> _parse_revision_str('date:2005-04-12 12:24:33')
 
105
    [<RevisionSpec_date date:2005-04-12 12:24:33>]
 
106
    >>> _parse_revision_str('date:2005-04-12T12:24:33')
 
107
    [<RevisionSpec_date date:2005-04-12T12:24:33>]
 
108
    >>> _parse_revision_str('date:2005-04-12,12:24:33')
 
109
    [<RevisionSpec_date date:2005-04-12,12:24:33>]
 
110
    >>> _parse_revision_str('-5..23')
 
111
    [<RevisionSpec_int -5>, <RevisionSpec_int 23>]
 
112
    >>> _parse_revision_str('-5')
 
113
    [<RevisionSpec_int -5>]
 
114
    >>> _parse_revision_str('123a')
 
115
    Traceback (most recent call last):
 
116
      ...
 
117
    BzrError: No namespace registered for string: '123a'
 
118
    >>> _parse_revision_str('abc')
 
119
    Traceback (most recent call last):
 
120
      ...
 
121
    BzrError: No namespace registered for string: 'abc'
 
122
    """
 
123
    import re
 
124
    old_format_re = re.compile('\d*:\d*')
 
125
    m = old_format_re.match(revstr)
 
126
    revs = []
 
127
    if m:
 
128
        warning('Colon separator for revision numbers is deprecated.'
 
129
                ' Use .. instead')
 
130
        for rev in revstr.split(':'):
 
131
            if rev:
 
132
                revs.append(RevisionSpec(int(rev)))
 
133
            else:
 
134
                revs.append(RevisionSpec(None))
 
135
    else:
 
136
        for x in revstr.split('..'):
 
137
            if not x:
 
138
                revs.append(RevisionSpec(None))
 
139
            else:
 
140
                revs.append(RevisionSpec(x))
 
141
    return revs
 
142
 
 
143
 
 
144
def get_merge_type(typestring):
 
145
    """Attempt to find the merge class/factory associated with a string."""
 
146
    from merge import merge_types
 
147
    try:
 
148
        return merge_types[typestring][0]
 
149
    except KeyError:
 
150
        templ = '%s%%7s: %%s' % (' '*12)
 
151
        lines = [templ % (f[0], f[1][1]) for f in merge_types.iteritems()]
 
152
        type_list = '\n'.join(lines)
 
153
        msg = "No known merge type %s. Supported types are:\n%s" %\
 
154
            (typestring, type_list)
 
155
        raise BzrCommandError(msg)
 
156
 
 
157
 
82
158
def _builtin_commands():
83
159
    import bzrlib.builtins
84
160
    r = {}
168
244
        List of argument forms, marked with whether they are optional,
169
245
        repeated, etc.
170
246
 
171
 
                Examples:
172
 
 
173
 
                ['to_location', 'from_branch?', 'file*']
174
 
 
175
 
                'to_location' is required
176
 
                'from_branch' is optional
177
 
                'file' can be specified 0 or more times
178
 
 
179
247
    takes_options
180
 
        List of options that may be given for this command.  These can
181
 
        be either strings, referring to globally-defined options,
182
 
        or option objects.  Retrieve through options().
 
248
        List of options that may be given for this command.
183
249
 
184
250
    hidden
185
251
        If true, this command isn't advertised.  This is typically
186
252
        for commands intended for expert users.
187
253
    """
188
254
    aliases = []
 
255
    
189
256
    takes_args = []
190
257
    takes_options = []
191
258
 
196
263
        if self.__doc__ == Command.__doc__:
197
264
            warn("No help message set for %r" % self)
198
265
 
199
 
    def options(self):
200
 
        """Return dict of valid options for this command.
201
 
 
202
 
        Maps from long option name to option object."""
203
 
        r = dict()
204
 
        r['help'] = Option.OPTIONS['help']
205
 
        for o in self.takes_options:
206
 
            if not isinstance(o, Option):
207
 
                o = Option.OPTIONS[o]
208
 
            r[o.name] = o
209
 
        return r
210
266
 
211
267
    def run_argv(self, argv):
212
268
        """Parse command line and run."""
213
 
        args, opts = parse_args(self, argv)
 
269
        args, opts = parse_args(argv)
 
270
 
214
271
        if 'help' in opts:  # e.g. bzr add --help
215
272
            from bzrlib.help import help_on_command
216
273
            help_on_command(self.name())
217
274
            return 0
218
 
        # XXX: This should be handled by the parser
219
 
        allowed_names = self.options().keys()
 
275
 
 
276
        # check options are reasonable
 
277
        allowed = self.takes_options
220
278
        for oname in opts:
221
 
            if oname not in allowed_names:
 
279
            if oname not in allowed:
222
280
                raise BzrCommandError("option '--%s' is not allowed for command %r"
223
281
                                      % (oname, self.name()))
 
282
 
224
283
        # mix arguments and options into one dictionary
225
284
        cmdargs = _match_argform(self.name(), self.takes_args, args)
226
285
        cmdopts = {}
231
290
        all_cmd_args.update(cmdopts)
232
291
 
233
292
        return self.run(**all_cmd_args)
 
293
 
234
294
    
235
295
    def run(self):
236
296
        """Actually run the command.
286
346
        parsed = [spec, None]
287
347
    return parsed
288
348
 
289
 
def parse_args(command, argv):
 
349
 
 
350
# list of all available options; the rhs can be either None for an
 
351
# option that takes no argument, or a constructor function that checks
 
352
# the type.
 
353
OPTIONS = {
 
354
    'all':                    None,
 
355
    'diff-options':           str,
 
356
    'help':                   None,
 
357
    'file':                   unicode,
 
358
    'force':                  None,
 
359
    'format':                 unicode,
 
360
    'forward':                None,
 
361
    'message':                unicode,
 
362
    'no-recurse':             None,
 
363
    'profile':                None,
 
364
    'revision':               _parse_revision_str,
 
365
    'short':                  None,
 
366
    'show-ids':               None,
 
367
    'timezone':               str,
 
368
    'verbose':                None,
 
369
    'version':                None,
 
370
    'email':                  None,
 
371
    'unchanged':              None,
 
372
    'update':                 None,
 
373
    'long':                   None,
 
374
    'root':                   str,
 
375
    'no-backup':              None,
 
376
    'merge-type':             get_merge_type,
 
377
    'pattern':                str,
 
378
    }
 
379
 
 
380
SHORT_OPTIONS = {
 
381
    'F':                      'file', 
 
382
    'h':                      'help',
 
383
    'm':                      'message',
 
384
    'r':                      'revision',
 
385
    'v':                      'verbose',
 
386
    'l':                      'long',
 
387
}
 
388
 
 
389
 
 
390
def parse_args(argv):
290
391
    """Parse command line.
291
392
    
292
393
    Arguments and options are parsed at this level before being passed
293
394
    down to specific command handlers.  This routine knows, from a
294
395
    lookup table, something about the available options, what optargs
295
396
    they take, and which commands will accept them.
 
397
 
 
398
    >>> parse_args('--help'.split())
 
399
    ([], {'help': True})
 
400
    >>> parse_args('help -- --invalidcmd'.split())
 
401
    (['help', '--invalidcmd'], {})
 
402
    >>> parse_args('--version'.split())
 
403
    ([], {'version': True})
 
404
    >>> parse_args('status --all'.split())
 
405
    (['status'], {'all': True})
 
406
    >>> parse_args('commit --message=biter'.split())
 
407
    (['commit'], {'message': u'biter'})
 
408
    >>> parse_args('log -r 500'.split())
 
409
    (['log'], {'revision': [<RevisionSpec_int 500>]})
 
410
    >>> parse_args('log -r500..600'.split())
 
411
    (['log'], {'revision': [<RevisionSpec_int 500>, <RevisionSpec_int 600>]})
 
412
    >>> parse_args('log -vr500..600'.split())
 
413
    (['log'], {'verbose': True, 'revision': [<RevisionSpec_int 500>, <RevisionSpec_int 600>]})
 
414
    >>> parse_args('log -rrevno:500..600'.split()) #the r takes an argument
 
415
    (['log'], {'revision': [<RevisionSpec_revno revno:500>, <RevisionSpec_int 600>]})
296
416
    """
297
 
    # TODO: chop up this beast; make it a method of the Command
298
417
    args = []
299
418
    opts = {}
300
419
 
301
 
    cmd_options = command.options()
302
420
    argsover = False
303
421
    while argv:
304
422
        a = argv.pop(0)
305
 
        if argsover:
306
 
            args.append(a)
307
 
            continue
308
 
        elif a == '--':
309
 
            # We've received a standalone -- No more flags
310
 
            argsover = True
311
 
            continue
312
 
        if a[0] == '-':
 
423
        if not argsover and a[0] == '-':
313
424
            # option names must not be unicode
314
425
            a = str(a)
315
426
            optarg = None
316
427
            if a[1] == '-':
317
 
                mutter("  got option %r", a)
 
428
                if a == '--':
 
429
                    # We've received a standalone -- No more flags
 
430
                    argsover = True
 
431
                    continue
 
432
                mutter("  got option %r" % a)
318
433
                if '=' in a:
319
434
                    optname, optarg = a[2:].split('=', 1)
320
435
                else:
321
436
                    optname = a[2:]
322
 
                if optname not in cmd_options:
323
 
                    raise BzrOptionError('unknown long option %r for command %s'
324
 
                        % (a, command.name()))
 
437
                if optname not in OPTIONS:
 
438
                    raise BzrError('unknown long option %r' % a)
325
439
            else:
326
440
                shortopt = a[1:]
327
 
                if shortopt in Option.SHORT_OPTIONS:
 
441
                if shortopt in SHORT_OPTIONS:
328
442
                    # Multi-character options must have a space to delimit
329
443
                    # their value
330
 
                    # ^^^ what does this mean? mbp 20051014
331
 
                    optname = Option.SHORT_OPTIONS[shortopt].name
 
444
                    optname = SHORT_OPTIONS[shortopt]
332
445
                else:
333
446
                    # Single character short options, can be chained,
334
447
                    # and have their value appended to their name
335
448
                    shortopt = a[1:2]
336
 
                    if shortopt not in Option.SHORT_OPTIONS:
 
449
                    if shortopt not in SHORT_OPTIONS:
337
450
                        # We didn't find the multi-character name, and we
338
451
                        # didn't find the single char name
339
452
                        raise BzrError('unknown short option %r' % a)
340
 
                    optname = Option.SHORT_OPTIONS[shortopt].name
 
453
                    optname = SHORT_OPTIONS[shortopt]
341
454
 
342
455
                    if a[2:]:
343
456
                        # There are extra things on this option
344
457
                        # see if it is the value, or if it is another
345
458
                        # short option
346
 
                        optargfn = Option.OPTIONS[optname].type
 
459
                        optargfn = OPTIONS[optname]
347
460
                        if optargfn is None:
348
461
                            # This option does not take an argument, so the
349
462
                            # next entry is another short option, pack it back
354
467
                            # into the array
355
468
                            optarg = a[2:]
356
469
            
357
 
                if optname not in cmd_options:
358
 
                    raise BzrOptionError('unknown short option %r for command'
359
 
                        ' %s' % (shortopt, command.name()))
360
470
            if optname in opts:
361
471
                # XXX: Do we ever want to support this, e.g. for -r?
362
472
                raise BzrError('repeated option %r' % a)
363
473
                
364
 
            option_obj = cmd_options[optname]
365
 
            optargfn = option_obj.type
 
474
            optargfn = OPTIONS[optname]
366
475
            if optargfn:
367
476
                if optarg == None:
368
477
                    if not argv:
376
485
                opts[optname] = True
377
486
        else:
378
487
            args.append(a)
 
488
 
379
489
    return args, opts
380
490
 
381
491
 
 
492
 
 
493
 
382
494
def _match_argform(cmd, takes_args, args):
383
495
    argdict = {}
384
496
 
427
539
def apply_profiled(the_callable, *args, **kwargs):
428
540
    import hotshot
429
541
    import tempfile
430
 
    import hotshot.stats
431
542
    pffileno, pfname = tempfile.mkstemp()
432
543
    try:
433
544
        prof = hotshot.Profile(pfname)
435
546
            ret = prof.runcall(the_callable, *args, **kwargs) or 0
436
547
        finally:
437
548
            prof.close()
 
549
 
 
550
        import hotshot.stats
438
551
        stats = hotshot.stats.load(pfname)
439
 
        stats.strip_dirs()
440
 
        stats.sort_stats('cum')   # 'time'
 
552
        #stats.strip_dirs()
 
553
        stats.sort_stats('time')
441
554
        ## XXX: Might like to write to stderr or the trace file instead but
442
555
        ## print_stats seems hardcoded to stdout
443
556
        stats.print_stats(20)
 
557
 
444
558
        return ret
445
559
    finally:
446
560
        os.close(pffileno)
471
585
    --profile
472
586
        Run under the Python profiler.
473
587
    """
 
588
    # Load all of the transport methods
 
589
    import bzrlib.transport.local, bzrlib.transport.http
 
590
    
474
591
    argv = [a.decode(bzrlib.user_encoding) for a in argv]
475
592
 
476
593
    opt_profile = opt_no_plugins = opt_builtin = False
486
603
            opt_no_plugins = True
487
604
        elif a == '--builtin':
488
605
            opt_builtin = True
489
 
        elif a in ('--quiet', '-q'):
490
 
            be_quiet()
491
606
        else:
492
 
            continue
 
607
            break
493
608
        argv.remove(a)
494
609
 
495
610
    if (not argv) or (argv[0] == '--help'):
513
628
 
514
629
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
515
630
 
516
 
    try:
517
 
        if opt_profile:
518
 
            ret = apply_profiled(cmd_obj.run_argv, argv)
519
 
        else:
520
 
            ret = cmd_obj.run_argv(argv)
521
 
        return ret or 0
522
 
    finally:
523
 
        # reset, in case we may do other commands later within the same process
524
 
        be_quiet(False)
525
 
 
526
 
def display_command(func):
527
 
    """Decorator that suppresses pipe/interrupt errors."""
528
 
    def ignore_pipe(*args, **kwargs):
529
 
        try:
530
 
            result = func(*args, **kwargs)
531
 
            sys.stdout.flush()
532
 
            return result
533
 
        except IOError, e:
534
 
            if not hasattr(e, 'errno'):
535
 
                raise
536
 
            if e.errno != errno.EPIPE:
537
 
                raise
538
 
            pass
539
 
        except KeyboardInterrupt:
540
 
            pass
541
 
    return ignore_pipe
 
631
    if opt_profile:
 
632
        ret = apply_profiled(cmd_obj.run_argv, argv)
 
633
    else:
 
634
        ret = cmd_obj.run_argv(argv)
 
635
    return ret or 0
542
636
 
543
637
 
544
638
def main(argv):
545
639
    import bzrlib.ui
546
 
    from bzrlib.ui.text import TextUIFactory
547
 
    ## bzrlib.trace.enable_default_logging()
548
640
    bzrlib.trace.log_startup(argv)
549
 
    bzrlib.ui.ui_factory = TextUIFactory()
550
 
    ret = run_bzr_catch_errors(argv[1:])
551
 
    mutter("return code %d", ret)
552
 
    return ret
553
 
 
554
 
 
555
 
def run_bzr_catch_errors(argv):
 
641
    bzrlib.ui.ui_factory = bzrlib.ui.TextUIFactory()
 
642
 
556
643
    try:
557
644
        try:
558
 
            return run_bzr(argv)
559
 
        finally:
560
 
            # do this here inside the exception wrappers to catch EPIPE
561
 
            sys.stdout.flush()
 
645
            try:
 
646
                return run_bzr(argv[1:])
 
647
            finally:
 
648
                # do this here inside the exception wrappers to catch EPIPE
 
649
                sys.stdout.flush()
 
650
        #wrap common errors as CommandErrors.
 
651
        except (NotBranchError,), e:
 
652
            raise BzrCommandError(str(e))
 
653
    except BzrCommandError, e:
 
654
        # command line syntax error, etc
 
655
        log_error(str(e))
 
656
        return 1
 
657
    except BzrError, e:
 
658
        bzrlib.trace.log_exception()
 
659
        return 1
 
660
    except AssertionError, e:
 
661
        bzrlib.trace.log_exception('assertion failed: ' + str(e))
 
662
        return 3
 
663
    except KeyboardInterrupt, e:
 
664
        bzrlib.trace.note('interrupted')
 
665
        return 2
562
666
    except Exception, e:
563
 
        # used to handle AssertionError and KeyboardInterrupt
564
 
        # specially here, but hopefully they're handled ok by the logger now
565
667
        import errno
566
668
        if (isinstance(e, IOError) 
567
669
            and hasattr(e, 'errno')
568
670
            and e.errno == errno.EPIPE):
569
671
            bzrlib.trace.note('broken pipe')
570
 
            return 3
 
672
            return 2
571
673
        else:
572
674
            bzrlib.trace.log_exception()
573
 
            if os.environ.get('BZR_PDB'):
574
 
                print '**** entering debugger'
575
 
                import pdb
576
 
                pdb.post_mortem(sys.exc_traceback)
577
 
            return 3
 
675
            return 2
578
676
 
579
677
if __name__ == '__main__':
580
678
    sys.exit(main(sys.argv))