~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: Robert Collins
  • Date: 2005-10-11 03:19:29 UTC
  • Revision ID: robertc@robertcollins.net-20051011031929-2d523107133c43be
further tuning of pull, do not do a local merge or fetch at all, if the remote branch is no newer than we are

Show diffs side-by-side

added added

removed removed

Lines of Context:
31
31
import os
32
32
from warnings import warn
33
33
from inspect import getdoc
34
 
import errno
35
34
 
36
35
import bzrlib
37
36
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)
 
37
from bzrlib.trace import mutter, note, log_error, warning
 
38
from bzrlib.errors import BzrError, BzrCheckError, BzrCommandError, NotBranchError
44
39
from bzrlib.revisionspec import RevisionSpec
45
40
from bzrlib import BZRDIR
46
 
from bzrlib.option import Option
47
41
 
48
42
plugin_cmds = {}
49
43
 
50
44
 
51
 
def register_command(cmd, decorate=False):
 
45
def register_command(cmd):
52
46
    "Utility function to help register a command"
53
47
    global plugin_cmds
54
48
    k = cmd.__name__
59
53
    if not plugin_cmds.has_key(k_unsquished):
60
54
        plugin_cmds[k_unsquished] = cmd
61
55
        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
56
    else:
69
57
        log_error('Two plugins defined the same command: %r' % k)
70
58
        log_error('Not loading the one in %r' % sys.modules[cmd.__module__])
79
67
    return cmd[4:].replace('_','-')
80
68
 
81
69
 
 
70
def _parse_revision_str(revstr):
 
71
    """This handles a revision string -> revno.
 
72
 
 
73
    This always returns a list.  The list will have one element for
 
74
    each revision specifier supplied.
 
75
 
 
76
    >>> _parse_revision_str('234')
 
77
    [<RevisionSpec_int 234>]
 
78
    >>> _parse_revision_str('234..567')
 
79
    [<RevisionSpec_int 234>, <RevisionSpec_int 567>]
 
80
    >>> _parse_revision_str('..')
 
81
    [<RevisionSpec None>, <RevisionSpec None>]
 
82
    >>> _parse_revision_str('..234')
 
83
    [<RevisionSpec None>, <RevisionSpec_int 234>]
 
84
    >>> _parse_revision_str('234..')
 
85
    [<RevisionSpec_int 234>, <RevisionSpec None>]
 
86
    >>> _parse_revision_str('234..456..789') # Maybe this should be an error
 
87
    [<RevisionSpec_int 234>, <RevisionSpec_int 456>, <RevisionSpec_int 789>]
 
88
    >>> _parse_revision_str('234....789') #Error ?
 
89
    [<RevisionSpec_int 234>, <RevisionSpec None>, <RevisionSpec_int 789>]
 
90
    >>> _parse_revision_str('revid:test@other.com-234234')
 
91
    [<RevisionSpec_revid revid:test@other.com-234234>]
 
92
    >>> _parse_revision_str('revid:test@other.com-234234..revid:test@other.com-234235')
 
93
    [<RevisionSpec_revid revid:test@other.com-234234>, <RevisionSpec_revid revid:test@other.com-234235>]
 
94
    >>> _parse_revision_str('revid:test@other.com-234234..23')
 
95
    [<RevisionSpec_revid revid:test@other.com-234234>, <RevisionSpec_int 23>]
 
96
    >>> _parse_revision_str('date:2005-04-12')
 
97
    [<RevisionSpec_date date:2005-04-12>]
 
98
    >>> _parse_revision_str('date:2005-04-12 12:24:33')
 
99
    [<RevisionSpec_date date:2005-04-12 12:24:33>]
 
100
    >>> _parse_revision_str('date:2005-04-12T12:24:33')
 
101
    [<RevisionSpec_date date:2005-04-12T12:24:33>]
 
102
    >>> _parse_revision_str('date:2005-04-12,12:24:33')
 
103
    [<RevisionSpec_date date:2005-04-12,12:24:33>]
 
104
    >>> _parse_revision_str('-5..23')
 
105
    [<RevisionSpec_int -5>, <RevisionSpec_int 23>]
 
106
    >>> _parse_revision_str('-5')
 
107
    [<RevisionSpec_int -5>]
 
108
    >>> _parse_revision_str('123a')
 
109
    Traceback (most recent call last):
 
110
      ...
 
111
    BzrError: No namespace registered for string: '123a'
 
112
    >>> _parse_revision_str('abc')
 
113
    Traceback (most recent call last):
 
114
      ...
 
115
    BzrError: No namespace registered for string: 'abc'
 
116
    >>> _parse_revision_str('branch:../branch2')
 
117
    [<RevisionSpec_branch branch:../branch2>]
 
118
    """
 
119
    import re
 
120
    old_format_re = re.compile('\d*:\d*')
 
121
    m = old_format_re.match(revstr)
 
122
    revs = []
 
123
    if m:
 
124
        warning('Colon separator for revision numbers is deprecated.'
 
125
                ' Use .. instead')
 
126
        for rev in revstr.split(':'):
 
127
            if rev:
 
128
                revs.append(RevisionSpec(int(rev)))
 
129
            else:
 
130
                revs.append(RevisionSpec(None))
 
131
    else:
 
132
        next_prefix = None
 
133
        for x in revstr.split('..'):
 
134
            if not x:
 
135
                revs.append(RevisionSpec(None))
 
136
            elif x[-1] == ':':
 
137
                # looks like a namespace:.. has happened
 
138
                next_prefix = x + '..'
 
139
            else:
 
140
                if next_prefix is not None:
 
141
                    x = next_prefix + x
 
142
                revs.append(RevisionSpec(x))
 
143
                next_prefix = None
 
144
        if next_prefix is not None:
 
145
            revs.append(RevisionSpec(next_prefix))
 
146
    return revs
 
147
 
 
148
 
82
149
def _builtin_commands():
83
150
    import bzrlib.builtins
84
151
    r = {}
168
235
        List of argument forms, marked with whether they are optional,
169
236
        repeated, etc.
170
237
 
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
238
    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().
 
239
        List of options that may be given for this command.
183
240
 
184
241
    hidden
185
242
        If true, this command isn't advertised.  This is typically
186
243
        for commands intended for expert users.
187
244
    """
188
245
    aliases = []
 
246
    
189
247
    takes_args = []
190
248
    takes_options = []
191
249
 
196
254
        if self.__doc__ == Command.__doc__:
197
255
            warn("No help message set for %r" % self)
198
256
 
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
257
 
211
258
    def run_argv(self, argv):
212
259
        """Parse command line and run."""
213
 
        args, opts = parse_args(self, argv)
 
260
        args, opts = parse_args(argv)
 
261
 
214
262
        if 'help' in opts:  # e.g. bzr add --help
215
263
            from bzrlib.help import help_on_command
216
264
            help_on_command(self.name())
217
265
            return 0
218
 
        # XXX: This should be handled by the parser
219
 
        allowed_names = self.options().keys()
 
266
 
 
267
        # check options are reasonable
 
268
        allowed = self.takes_options
220
269
        for oname in opts:
221
 
            if oname not in allowed_names:
 
270
            if oname not in allowed:
222
271
                raise BzrCommandError("option '--%s' is not allowed for command %r"
223
272
                                      % (oname, self.name()))
 
273
 
224
274
        # mix arguments and options into one dictionary
225
275
        cmdargs = _match_argform(self.name(), self.takes_args, args)
226
276
        cmdopts = {}
231
281
        all_cmd_args.update(cmdopts)
232
282
 
233
283
        return self.run(**all_cmd_args)
 
284
 
234
285
    
235
286
    def run(self):
236
287
        """Actually run the command.
286
337
        parsed = [spec, None]
287
338
    return parsed
288
339
 
289
 
def parse_args(command, argv):
 
340
 
 
341
# list of all available options; the rhs can be either None for an
 
342
# option that takes no argument, or a constructor function that checks
 
343
# the type.
 
344
OPTIONS = {
 
345
    'all':                    None,
 
346
    'basis':                  str,
 
347
    'diff-options':           str,
 
348
    'help':                   None,
 
349
    'file':                   unicode,
 
350
    'force':                  None,
 
351
    'format':                 unicode,
 
352
    'forward':                None,
 
353
    'message':                unicode,
 
354
    'no-recurse':             None,
 
355
    'profile':                None,
 
356
    'revision':               _parse_revision_str,
 
357
    'short':                  None,
 
358
    'show-ids':               None,
 
359
    'timezone':               str,
 
360
    'verbose':                None,
 
361
    'version':                None,
 
362
    'email':                  None,
 
363
    'unchanged':              None,
 
364
    'update':                 None,
 
365
    'long':                   None,
 
366
    'root':                   str,
 
367
    'no-backup':              None,
 
368
    'pattern':                str,
 
369
    'remember':               None,
 
370
    }
 
371
 
 
372
SHORT_OPTIONS = {
 
373
    'F':                      'file', 
 
374
    'h':                      'help',
 
375
    'm':                      'message',
 
376
    'r':                      'revision',
 
377
    'v':                      'verbose',
 
378
    'l':                      'long',
 
379
}
 
380
 
 
381
 
 
382
def parse_args(argv):
290
383
    """Parse command line.
291
384
    
292
385
    Arguments and options are parsed at this level before being passed
293
386
    down to specific command handlers.  This routine knows, from a
294
387
    lookup table, something about the available options, what optargs
295
388
    they take, and which commands will accept them.
 
389
 
 
390
    >>> parse_args('--help'.split())
 
391
    ([], {'help': True})
 
392
    >>> parse_args('help -- --invalidcmd'.split())
 
393
    (['help', '--invalidcmd'], {})
 
394
    >>> parse_args('--version'.split())
 
395
    ([], {'version': True})
 
396
    >>> parse_args('status --all'.split())
 
397
    (['status'], {'all': True})
 
398
    >>> parse_args('commit --message=biter'.split())
 
399
    (['commit'], {'message': u'biter'})
 
400
    >>> parse_args('log -r 500'.split())
 
401
    (['log'], {'revision': [<RevisionSpec_int 500>]})
 
402
    >>> parse_args('log -r500..600'.split())
 
403
    (['log'], {'revision': [<RevisionSpec_int 500>, <RevisionSpec_int 600>]})
 
404
    >>> parse_args('log -vr500..600'.split())
 
405
    (['log'], {'verbose': True, 'revision': [<RevisionSpec_int 500>, <RevisionSpec_int 600>]})
 
406
    >>> parse_args('log -rrevno:500..600'.split()) #the r takes an argument
 
407
    (['log'], {'revision': [<RevisionSpec_revno revno:500>, <RevisionSpec_int 600>]})
296
408
    """
297
 
    # TODO: chop up this beast; make it a method of the Command
298
409
    args = []
299
410
    opts = {}
300
411
 
301
 
    cmd_options = command.options()
302
412
    argsover = False
303
413
    while argv:
304
414
        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] == '-':
 
415
        if not argsover and a[0] == '-':
313
416
            # option names must not be unicode
314
417
            a = str(a)
315
418
            optarg = None
316
419
            if a[1] == '-':
317
 
                mutter("  got option %r", a)
 
420
                if a == '--':
 
421
                    # We've received a standalone -- No more flags
 
422
                    argsover = True
 
423
                    continue
 
424
                mutter("  got option %r" % a)
318
425
                if '=' in a:
319
426
                    optname, optarg = a[2:].split('=', 1)
320
427
                else:
321
428
                    optname = a[2:]
322
 
                if optname not in cmd_options:
323
 
                    raise BzrOptionError('unknown long option %r for command %s'
324
 
                        % (a, command.name()))
 
429
                if optname not in OPTIONS:
 
430
                    raise BzrError('unknown long option %r' % a)
325
431
            else:
326
432
                shortopt = a[1:]
327
 
                if shortopt in Option.SHORT_OPTIONS:
 
433
                if shortopt in SHORT_OPTIONS:
328
434
                    # Multi-character options must have a space to delimit
329
435
                    # their value
330
 
                    # ^^^ what does this mean? mbp 20051014
331
 
                    optname = Option.SHORT_OPTIONS[shortopt].name
 
436
                    optname = SHORT_OPTIONS[shortopt]
332
437
                else:
333
438
                    # Single character short options, can be chained,
334
439
                    # and have their value appended to their name
335
440
                    shortopt = a[1:2]
336
 
                    if shortopt not in Option.SHORT_OPTIONS:
 
441
                    if shortopt not in SHORT_OPTIONS:
337
442
                        # We didn't find the multi-character name, and we
338
443
                        # didn't find the single char name
339
444
                        raise BzrError('unknown short option %r' % a)
340
 
                    optname = Option.SHORT_OPTIONS[shortopt].name
 
445
                    optname = SHORT_OPTIONS[shortopt]
341
446
 
342
447
                    if a[2:]:
343
448
                        # There are extra things on this option
344
449
                        # see if it is the value, or if it is another
345
450
                        # short option
346
 
                        optargfn = Option.OPTIONS[optname].type
 
451
                        optargfn = OPTIONS[optname]
347
452
                        if optargfn is None:
348
453
                            # This option does not take an argument, so the
349
454
                            # next entry is another short option, pack it back
354
459
                            # into the array
355
460
                            optarg = a[2:]
356
461
            
357
 
                if optname not in cmd_options:
358
 
                    raise BzrOptionError('unknown short option %r for command'
359
 
                        ' %s' % (shortopt, command.name()))
360
462
            if optname in opts:
361
463
                # XXX: Do we ever want to support this, e.g. for -r?
362
464
                raise BzrError('repeated option %r' % a)
363
465
                
364
 
            option_obj = cmd_options[optname]
365
 
            optargfn = option_obj.type
 
466
            optargfn = OPTIONS[optname]
366
467
            if optargfn:
367
468
                if optarg == None:
368
469
                    if not argv:
376
477
                opts[optname] = True
377
478
        else:
378
479
            args.append(a)
 
480
 
379
481
    return args, opts
380
482
 
381
483
 
 
484
 
 
485
 
382
486
def _match_argform(cmd, takes_args, args):
383
487
    argdict = {}
384
488
 
447
551
        os.remove(pfname)
448
552
 
449
553
 
450
 
def apply_lsprofiled(the_callable, *args, **kwargs):
451
 
    from bzrlib.lsprof import profile
452
 
    ret,stats = profile(the_callable,*args,**kwargs)
453
 
    stats.sort()
454
 
    stats.pprint()
455
 
    return ret
456
 
 
457
554
def run_bzr(argv):
458
555
    """Execute a command.
459
556
 
476
573
        other behaviour.)
477
574
 
478
575
    --profile
479
 
        Run under the Python hotshot profiler.
480
 
 
481
 
    --lsprof
482
 
        Run under the Python lsprof profiler.
 
576
        Run under the Python profiler.
483
577
    """
 
578
    # Load all of the transport methods
 
579
    import bzrlib.transport.local, bzrlib.transport.http
 
580
    
484
581
    argv = [a.decode(bzrlib.user_encoding) for a in argv]
485
582
 
486
 
    opt_lsprof = opt_profile = opt_no_plugins = opt_builtin = False
 
583
    opt_profile = opt_no_plugins = opt_builtin = False
487
584
 
488
585
    # --no-plugins is handled specially at a very early stage. We need
489
586
    # to load plugins before doing other command parsing so that they
492
589
    for a in argv:
493
590
        if a == '--profile':
494
591
            opt_profile = True
495
 
        elif a == '--lsprof':
496
 
            opt_lsprof = True
497
592
        elif a == '--no-plugins':
498
593
            opt_no_plugins = True
499
594
        elif a == '--builtin':
500
595
            opt_builtin = True
501
 
        elif a in ('--quiet', '-q'):
502
 
            be_quiet()
503
596
        else:
504
 
            continue
 
597
            break
505
598
        argv.remove(a)
506
599
 
507
600
    if (not argv) or (argv[0] == '--help'):
525
618
 
526
619
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
527
620
 
528
 
    try:
529
 
        if opt_lsprof:
530
 
            ret = apply_lsprofiled(cmd_obj.run_argv, argv)
531
 
        elif opt_profile:
532
 
            ret = apply_profiled(cmd_obj.run_argv, argv)
533
 
        else:
534
 
            ret = cmd_obj.run_argv(argv)
535
 
        return ret or 0
536
 
    finally:
537
 
        # reset, in case we may do other commands later within the same process
538
 
        be_quiet(False)
539
 
 
540
 
def display_command(func):
541
 
    """Decorator that suppresses pipe/interrupt errors."""
542
 
    def ignore_pipe(*args, **kwargs):
543
 
        try:
544
 
            result = func(*args, **kwargs)
545
 
            sys.stdout.flush()
546
 
            return result
547
 
        except IOError, e:
548
 
            if not hasattr(e, 'errno'):
549
 
                raise
550
 
            if e.errno != errno.EPIPE:
551
 
                raise
552
 
            pass
553
 
        except KeyboardInterrupt:
554
 
            pass
555
 
    return ignore_pipe
 
621
    if opt_profile:
 
622
        ret = apply_profiled(cmd_obj.run_argv, argv)
 
623
    else:
 
624
        ret = cmd_obj.run_argv(argv)
 
625
    return ret or 0
556
626
 
557
627
 
558
628
def main(argv):
559
629
    import bzrlib.ui
560
 
    from bzrlib.ui.text import TextUIFactory
561
 
    ## bzrlib.trace.enable_default_logging()
562
630
    bzrlib.trace.log_startup(argv)
563
 
    bzrlib.ui.ui_factory = TextUIFactory()
564
 
    ret = run_bzr_catch_errors(argv[1:])
565
 
    mutter("return code %d", ret)
566
 
    return ret
 
631
    bzrlib.ui.ui_factory = bzrlib.ui.TextUIFactory()
 
632
 
 
633
    return run_bzr_catch_errors(argv[1:])
567
634
 
568
635
 
569
636
def run_bzr_catch_errors(argv):
573
640
        finally:
574
641
            # do this here inside the exception wrappers to catch EPIPE
575
642
            sys.stdout.flush()
 
643
    except BzrCommandError, e:
 
644
        # command line syntax error, etc
 
645
        log_error(str(e))
 
646
        return 1
 
647
    except BzrError, e:
 
648
        bzrlib.trace.log_exception()
 
649
        return 1
 
650
    except AssertionError, e:
 
651
        bzrlib.trace.log_exception('assertion failed: ' + str(e))
 
652
        return 3
 
653
    except KeyboardInterrupt, e:
 
654
        bzrlib.trace.log_exception('interrupted')
 
655
        return 2
576
656
    except Exception, e:
577
 
        # used to handle AssertionError and KeyboardInterrupt
578
 
        # specially here, but hopefully they're handled ok by the logger now
579
657
        import errno
580
658
        if (isinstance(e, IOError) 
581
659
            and hasattr(e, 'errno')
582
660
            and e.errno == errno.EPIPE):
583
661
            bzrlib.trace.note('broken pipe')
584
 
            return 3
 
662
            return 2
585
663
        else:
 
664
            ## import pdb
 
665
            ## pdb.pm()
586
666
            bzrlib.trace.log_exception()
587
 
            if os.environ.get('BZR_PDB'):
588
 
                print '**** entering debugger'
589
 
                import pdb
590
 
                pdb.post_mortem(sys.exc_traceback)
591
 
            return 3
 
667
            return 2
592
668
 
593
669
if __name__ == '__main__':
594
670
    sys.exit(main(sys.argv))