~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commands.py

  • Committer: abentley
  • Date: 2005-10-14 03:50:50 UTC
  • mto: (1185.25.1)
  • mto: This revision was merged to the branch mainline in revision 1460.
  • Revision ID: abentley@lappy-20051014035050-d779472ccb599a51
semi-broke merge

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
    'quiet':                  None,
 
354
    'message':                unicode,
 
355
    'no-recurse':             None,
 
356
    'line':                   None,
 
357
    'profile':                None,
 
358
    'revision':               _parse_revision_str,
 
359
    'short':                  None,
 
360
    'show-ids':               None,
 
361
    'timezone':               str,
 
362
    'verbose':                None,
 
363
    'version':                None,
 
364
    'email':                  None,
 
365
    'unchanged':              None,
 
366
    'update':                 None,
 
367
    'long':                   None,
 
368
    'root':                   str,
 
369
    'no-backup':              None,
 
370
    'pattern':                str,
 
371
    'remember':               None,
 
372
    }
 
373
 
 
374
SHORT_OPTIONS = {
 
375
    'F':                      'file', 
 
376
    'h':                      'help',
 
377
    'm':                      'message',
 
378
    'r':                      'revision',
 
379
    'v':                      'verbose',
 
380
    'l':                      'long',
 
381
    'q':                      'quiet',
 
382
}
 
383
 
 
384
 
 
385
def parse_args(argv):
290
386
    """Parse command line.
291
387
    
292
388
    Arguments and options are parsed at this level before being passed
293
389
    down to specific command handlers.  This routine knows, from a
294
390
    lookup table, something about the available options, what optargs
295
391
    they take, and which commands will accept them.
 
392
 
 
393
    >>> parse_args('--help'.split())
 
394
    ([], {'help': True})
 
395
    >>> parse_args('help -- --invalidcmd'.split())
 
396
    (['help', '--invalidcmd'], {})
 
397
    >>> parse_args('--version'.split())
 
398
    ([], {'version': True})
 
399
    >>> parse_args('status --all'.split())
 
400
    (['status'], {'all': True})
 
401
    >>> parse_args('commit --message=biter'.split())
 
402
    (['commit'], {'message': u'biter'})
 
403
    >>> parse_args('log -r 500'.split())
 
404
    (['log'], {'revision': [<RevisionSpec_int 500>]})
 
405
    >>> parse_args('log -r500..600'.split())
 
406
    (['log'], {'revision': [<RevisionSpec_int 500>, <RevisionSpec_int 600>]})
 
407
    >>> parse_args('log -vr500..600'.split())
 
408
    (['log'], {'verbose': True, 'revision': [<RevisionSpec_int 500>, <RevisionSpec_int 600>]})
 
409
    >>> parse_args('log -rrevno:500..600'.split()) #the r takes an argument
 
410
    (['log'], {'revision': [<RevisionSpec_revno revno:500>, <RevisionSpec_int 600>]})
296
411
    """
297
 
    # TODO: chop up this beast; make it a method of the Command
298
412
    args = []
299
413
    opts = {}
300
414
 
301
 
    cmd_options = command.options()
302
415
    argsover = False
303
416
    while argv:
304
417
        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] == '-':
 
418
        if not argsover and a[0] == '-':
313
419
            # option names must not be unicode
314
420
            a = str(a)
315
421
            optarg = None
316
422
            if a[1] == '-':
317
 
                mutter("  got option %r", a)
 
423
                if a == '--':
 
424
                    # We've received a standalone -- No more flags
 
425
                    argsover = True
 
426
                    continue
 
427
                mutter("  got option %r" % a)
318
428
                if '=' in a:
319
429
                    optname, optarg = a[2:].split('=', 1)
320
430
                else:
321
431
                    optname = a[2:]
322
 
                if optname not in cmd_options:
323
 
                    raise BzrOptionError('unknown long option %r for command %s'
324
 
                        % (a, command.name()))
 
432
                if optname not in OPTIONS:
 
433
                    raise BzrError('unknown long option %r' % a)
325
434
            else:
326
435
                shortopt = a[1:]
327
 
                if shortopt in Option.SHORT_OPTIONS:
 
436
                if shortopt in SHORT_OPTIONS:
328
437
                    # Multi-character options must have a space to delimit
329
438
                    # their value
330
 
                    # ^^^ what does this mean? mbp 20051014
331
 
                    optname = Option.SHORT_OPTIONS[shortopt].name
 
439
                    optname = SHORT_OPTIONS[shortopt]
332
440
                else:
333
441
                    # Single character short options, can be chained,
334
442
                    # and have their value appended to their name
335
443
                    shortopt = a[1:2]
336
 
                    if shortopt not in Option.SHORT_OPTIONS:
 
444
                    if shortopt not in SHORT_OPTIONS:
337
445
                        # We didn't find the multi-character name, and we
338
446
                        # didn't find the single char name
339
447
                        raise BzrError('unknown short option %r' % a)
340
 
                    optname = Option.SHORT_OPTIONS[shortopt].name
 
448
                    optname = SHORT_OPTIONS[shortopt]
341
449
 
342
450
                    if a[2:]:
343
451
                        # There are extra things on this option
344
452
                        # see if it is the value, or if it is another
345
453
                        # short option
346
 
                        optargfn = Option.OPTIONS[optname].type
 
454
                        optargfn = OPTIONS[optname]
347
455
                        if optargfn is None:
348
456
                            # This option does not take an argument, so the
349
457
                            # next entry is another short option, pack it back
354
462
                            # into the array
355
463
                            optarg = a[2:]
356
464
            
357
 
                if optname not in cmd_options:
358
 
                    raise BzrOptionError('unknown short option %r for command'
359
 
                        ' %s' % (shortopt, command.name()))
360
465
            if optname in opts:
361
466
                # XXX: Do we ever want to support this, e.g. for -r?
362
467
                raise BzrError('repeated option %r' % a)
363
468
                
364
 
            option_obj = cmd_options[optname]
365
 
            optargfn = option_obj.type
 
469
            optargfn = OPTIONS[optname]
366
470
            if optargfn:
367
471
                if optarg == None:
368
472
                    if not argv:
376
480
                opts[optname] = True
377
481
        else:
378
482
            args.append(a)
 
483
 
379
484
    return args, opts
380
485
 
381
486
 
 
487
 
 
488
 
382
489
def _match_argform(cmd, takes_args, args):
383
490
    argdict = {}
384
491
 
471
578
    --profile
472
579
        Run under the Python profiler.
473
580
    """
 
581
    # Load all of the transport methods
 
582
    import bzrlib.transport.local, bzrlib.transport.http
 
583
    
474
584
    argv = [a.decode(bzrlib.user_encoding) for a in argv]
475
585
 
476
586
    opt_profile = opt_no_plugins = opt_builtin = False
486
596
            opt_no_plugins = True
487
597
        elif a == '--builtin':
488
598
            opt_builtin = True
489
 
        elif a in ('--quiet', '-q'):
490
 
            be_quiet()
491
599
        else:
492
 
            continue
 
600
            break
493
601
        argv.remove(a)
494
602
 
495
603
    if (not argv) or (argv[0] == '--help'):
513
621
 
514
622
    cmd_obj = get_cmd_object(cmd, plugins_override=not opt_builtin)
515
623
 
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
 
624
    if opt_profile:
 
625
        ret = apply_profiled(cmd_obj.run_argv, argv)
 
626
    else:
 
627
        ret = cmd_obj.run_argv(argv)
 
628
    return ret or 0
542
629
 
543
630
 
544
631
def main(argv):
545
632
    import bzrlib.ui
546
 
    ## bzrlib.trace.enable_default_logging()
547
633
    bzrlib.trace.log_startup(argv)
548
634
    bzrlib.ui.ui_factory = bzrlib.ui.TextUIFactory()
549
 
    ret = run_bzr_catch_errors(argv[1:])
550
 
    mutter("return code %d", ret)
551
 
    return ret
 
635
 
 
636
    return run_bzr_catch_errors(argv[1:])
552
637
 
553
638
 
554
639
def run_bzr_catch_errors(argv):
558
643
        finally:
559
644
            # do this here inside the exception wrappers to catch EPIPE
560
645
            sys.stdout.flush()
 
646
    except BzrCommandError, e:
 
647
        # command line syntax error, etc
 
648
        log_error(str(e))
 
649
        return 1
 
650
    except BzrError, e:
 
651
        bzrlib.trace.log_exception()
 
652
        return 1
 
653
    except AssertionError, e:
 
654
        bzrlib.trace.log_exception('assertion failed: ' + str(e))
 
655
        return 3
 
656
    except KeyboardInterrupt, e:
 
657
        bzrlib.trace.log_exception('interrupted')
 
658
        return 2
561
659
    except Exception, e:
562
 
        # used to handle AssertionError and KeyboardInterrupt
563
 
        # specially here, but hopefully they're handled ok by the logger now
564
660
        import errno
565
661
        if (isinstance(e, IOError) 
566
662
            and hasattr(e, 'errno')
567
663
            and e.errno == errno.EPIPE):
568
664
            bzrlib.trace.note('broken pipe')
569
 
            return 3
 
665
            return 2
570
666
        else:
 
667
            ## import pdb
 
668
            ## pdb.pm()
571
669
            bzrlib.trace.log_exception()
572
 
            if os.environ.get('BZR_PDB'):
573
 
                print '**** entering debugger'
574
 
                import pdb
575
 
                pdb.post_mortem(sys.exc_traceback)
576
 
            return 3
 
670
            return 2
577
671
 
578
672
if __name__ == '__main__':
579
673
    sys.exit(main(sys.argv))