14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
20
from bzrlib.lazy_import import lazy_import
17
from __future__ import absolute_import
20
from .lazy_import import lazy_import
21
21
lazy_import(globals(), """
26
branch as _mod_branch,
31
from breezy.i18n import gettext
39
45
class RevisionInfo(object):
53
59
or treat the result as a tuple.
56
def __init__(self, branch, revno, rev_id=_marker):
62
def __init__(self, branch, revno=None, rev_id=None):
57
63
self.branch = branch
64
self._has_revno = (revno is not None)
67
if self.rev_id is None and self._revno is not None:
60
68
# allow caller to be lazy
61
if self.revno is None:
64
self.rev_id = branch.get_rev_id(self.revno)
68
def __nonzero__(self):
69
# first the easy ones...
69
self.rev_id = branch.get_rev_id(self._revno)
73
if not self._has_revno and self.rev_id is not None:
75
self._revno = self.branch.revision_id_to_revno(self.rev_id)
76
except errors.NoSuchRevision:
78
self._has_revno = True
70
82
if self.rev_id is None:
72
if self.revno is not None:
74
84
# TODO: otherwise, it should depend on how I was built -
75
85
# if it's in_history(branch), then check revision_history(),
76
86
# if it's in_store(branch), do the check below
77
87
return self.branch.repository.has_revision(self.rev_id)
89
__nonzero__ = __bool__
90
102
def __eq__(self, other):
91
103
if type(other) not in (tuple, list, type(self)):
93
if type(other) is type(self) and self.branch is not other.branch:
105
if isinstance(other, type(self)) and self.branch is not other.branch:
95
107
return tuple(self) == tuple(other)
97
109
def __repr__(self):
98
return '<bzrlib.revisionspec.RevisionInfo object %s, %s for %r>' % (
110
return '<breezy.revisionspec.RevisionInfo object %s, %s for %r>' % (
99
111
self.revno, self.rev_id, self.branch)
102
def from_revision_id(branch, revision_id, revs):
114
def from_revision_id(branch, revision_id):
103
115
"""Construct a RevisionInfo given just the id.
105
117
Use this if you don't know or care what the revno is.
107
if revision_id == revision.NULL_REVISION:
108
return RevisionInfo(branch, 0, revision_id)
110
revno = revs.index(revision_id) + 1
113
return RevisionInfo(branch, revno, revision_id)
119
return RevisionInfo(branch, revno=None, rev_id=revision_id)
119
122
class RevisionSpec(object):
154
156
:return: A RevisionSpec object that understands how to parse the
155
157
supplied notation.
157
if not isinstance(spec, (type(None), basestring)):
158
raise TypeError('error')
161
160
return RevisionSpec(None, _internal=True)
161
if not isinstance(spec, (str, text_type)):
162
raise TypeError("revision spec needs to be text")
162
163
match = revspec_registry.get_prefix(spec)
163
164
if match is not None:
164
165
spectype, specsuffix = match
166
167
spectype.__name__, spec)
167
168
return spectype(spec, _internal=True)
169
for spectype in SPEC_TYPES:
170
if spec.startswith(spectype.prefix):
171
trace.mutter('Returning RevisionSpec %s for %s',
172
spectype.__name__, spec)
173
return spectype(spec, _internal=True)
174
170
# Otherwise treat it as a DWIM, build the RevisionSpec object and
175
171
# wait for _match_on to be called.
176
172
return RevisionSpec_dwim(spec, _internal=True)
183
179
called directly. Only from RevisionSpec.from_string()
185
181
if not _internal:
186
symbol_versioning.warn('Creating a RevisionSpec directly has'
187
' been deprecated in version 0.11. Use'
188
' RevisionSpec.from_string()'
190
DeprecationWarning, stacklevel=2)
182
raise AssertionError(
183
'Creating a RevisionSpec directly is not supported. '
184
'Use RevisionSpec.from_string() instead.')
191
185
self.user_spec = spec
192
186
if self.prefix and spec.startswith(self.prefix):
193
187
spec = spec[len(self.prefix):]
210
204
raise errors.InvalidRevisionSpec(self.spec, branch)
212
206
def in_history(self, branch):
214
if self.wants_revision_history:
215
revs = branch.revision_history()
219
# this should never trigger.
220
# TODO: make it a deprecated code path. RBC 20060928
222
return self._match_on_and_check(branch, revs)
207
return self._match_on_and_check(branch, revs=None)
224
209
# FIXME: in_history is somewhat broken,
225
210
# it will return non-history revisions in many
312
299
"""Run the lookup and see what we can get."""
314
301
# First, see if it's a revno
316
if _revno_regex is None:
317
_revno_regex = re.compile(r'^(?:(\d+(\.\d+)*)|-\d+)(:.*)?$')
318
if _revno_regex.match(self.spec) is not None:
302
if self._revno_regex.match(self.spec) is not None:
320
304
return self._try_spectype(RevisionSpec_revno, branch)
321
305
except RevisionSpec_revno.dwim_catchable_exceptions:
324
308
# Next see what has been registered
325
for rs_class in dwim_revspecs:
309
for objgetter in self._possible_revspecs:
310
rs_class = objgetter.get_obj()
327
312
return self._try_spectype(rs_class, branch)
328
313
except rs_class.dwim_catchable_exceptions:
333
318
# really relevant.
334
319
raise errors.InvalidRevisionSpec(self.spec, branch)
322
def append_possible_revspec(cls, revspec):
323
"""Append a possible DWIM revspec.
325
:param revspec: Revision spec to try.
327
cls._possible_revspecs.append(registry._ObjectGetter(revspec))
330
def append_possible_lazy_revspec(cls, module_name, member_name):
331
"""Append a possible lazily loaded DWIM revspec.
333
:param module_name: Name of the module with the revspec
334
:param member_name: Name of the revspec within the module
336
cls._possible_revspecs.append(
337
registry._LazyObjectGetter(module_name, member_name))
337
340
class RevisionSpec_revno(RevisionSpec):
338
341
"""Selects a revision using a number."""
356
359
your history is very long.
358
361
prefix = 'revno:'
359
wants_revision_history = False
361
363
def _match_on(self, branch, revs):
362
364
"""Lookup a revision by revision number"""
363
branch, revno, revision_id = self._lookup(branch, revs)
365
branch, revno, revision_id = self._lookup(branch)
364
366
return RevisionInfo(branch, revno, revision_id)
366
def _lookup(self, branch, revs_or_none):
368
def _lookup(self, branch):
367
369
loc = self.spec.find(':')
369
371
revno_spec = self.spec
387
389
# right now - RBC 20060928
389
391
match_revno = tuple((int(number) for number in revno_spec.split('.')))
390
except ValueError, e:
392
except ValueError as e:
391
393
raise errors.InvalidRevisionSpec(self.user_spec, branch, e)
396
# the user has override the branch to look in.
397
# we need to refresh the revision_history map and
399
from bzrlib.branch import Branch
400
branch = Branch.open(branch_spec)
398
# the user has overriden the branch to look in.
399
branch = _mod_branch.Branch.open(branch_spec)
421
419
revno = last_revno + revno + 1
423
revision_id = branch.get_rev_id(revno, revs_or_none)
421
revision_id = branch.get_rev_id(revno)
424
422
except errors.NoSuchRevision:
425
423
raise errors.InvalidRevisionSpec(self.user_spec, branch)
426
424
return branch, revno, revision_id
428
426
def _as_revision_id(self, context_branch):
429
427
# We would have the revno here, but we don't really care
430
branch, revno, revision_id = self._lookup(context_branch, None)
428
branch, revno, revision_id = self._lookup(context_branch)
431
429
return revision_id
433
431
def needs_branch(self):
443
441
RevisionSpec_int = RevisionSpec_revno
447
class RevisionSpec_revid(RevisionSpec):
444
class RevisionIDSpec(RevisionSpec):
446
def _match_on(self, branch, revs):
447
revision_id = self.as_revision_id(branch)
448
return RevisionInfo.from_revision_id(branch, revision_id)
451
class RevisionSpec_revid(RevisionIDSpec):
448
452
"""Selects a revision using the revision id."""
450
454
help_txt = """Selects a revision using the revision id.
460
464
prefix = 'revid:'
462
def _match_on(self, branch, revs):
466
def _as_revision_id(self, context_branch):
463
467
# self.spec comes straight from parsing the command line arguments,
464
468
# so we expect it to be a Unicode string. Switch it to the internal
465
469
# representation.
466
revision_id = osutils.safe_revision_id(self.spec, warn=False)
467
return RevisionInfo.from_revision_id(branch, revision_id, revs)
469
def _as_revision_id(self, context_branch):
470
return osutils.safe_revision_id(self.spec, warn=False)
470
if isinstance(self.spec, text_type):
471
return cache_utf8.encode(self.spec)
489
491
def _match_on(self, branch, revs):
490
revno, revision_id = self._revno_and_revision_id(branch, revs)
492
revno, revision_id = self._revno_and_revision_id(branch)
491
493
return RevisionInfo(branch, revno, revision_id)
493
def _revno_and_revision_id(self, context_branch, revs_or_none):
495
def _revno_and_revision_id(self, context_branch):
494
496
last_revno, last_revision_id = context_branch.last_revision_info()
496
498
if self.spec == '':
573
571
return RevisionInfo(branch, revno, revision_id)
575
573
def _as_revision_id(self, context_branch):
576
base_revspec = RevisionSpec.from_string(self.spec)
577
base_revision_id = base_revspec.as_revision_id(context_branch)
574
base_revision_id = RevisionSpec.from_string(self.spec)._as_revision_id(context_branch)
578
575
if base_revision_id == revision.NULL_REVISION:
579
576
raise errors.InvalidRevisionSpec(self.user_spec, context_branch,
580
577
'cannot go before the null: revision')
610
607
def _match_on(self, branch, revs):
611
608
# Can raise tags not supported, NoSuchTag, etc
612
609
return RevisionInfo.from_revision_id(branch,
613
branch.tags.lookup_tag(self.spec),
610
branch.tags.lookup_tag(self.spec))
616
612
def _as_revision_id(self, context_branch):
617
613
return context_branch.tags.lookup_tag(self.spec)
621
617
class _RevListToTimestamps(object):
622
618
"""This takes a list of revisions, and allows you to bisect by date"""
624
__slots__ = ['revs', 'branch']
620
__slots__ = ['branch']
626
def __init__(self, revs, branch):
622
def __init__(self, branch):
628
623
self.branch = branch
630
625
def __getitem__(self, index):
631
626
"""Get the date of the index'd item"""
632
r = self.branch.repository.get_revision(self.revs[index])
627
r = self.branch.repository.get_revision(self.branch.get_rev_id(index))
633
628
# TODO: Handle timezone.
634
629
return datetime.datetime.fromtimestamp(r.timestamp)
636
631
def __len__(self):
637
return len(self.revs)
632
return self.branch.revno()
640
635
class RevisionSpec_date(RevisionSpec):
708
hour, minute, second = 0,0,0
703
hour, minute, second = 0, 0, 0
709
704
except ValueError:
710
705
raise errors.InvalidRevisionSpec(self.user_spec,
711
706
branch, 'invalid date')
713
708
dt = datetime.datetime(year=year, month=month, day=day,
714
709
hour=hour, minute=minute, second=second)
717
rev = bisect.bisect(_RevListToTimestamps(revs, branch), dt)
710
with branch.lock_read():
711
rev = bisect.bisect(_RevListToTimestamps(branch), dt, 1)
712
if rev == branch.revno():
721
713
raise errors.InvalidRevisionSpec(self.user_spec, branch)
723
return RevisionInfo(branch, rev + 1)
714
return RevisionInfo(branch, rev)
757
748
def _find_revision_info(branch, other_location):
758
749
revision_id = RevisionSpec_ancestor._find_revision_id(branch,
761
revno = branch.revision_id_to_revno(revision_id)
762
except errors.NoSuchRevision:
764
return RevisionInfo(branch, revno, revision_id)
751
return RevisionInfo(branch, None, revision_id)
767
754
def _find_revision_id(branch, other_location):
768
from bzrlib.branch import Branch
755
from .branch import Branch
757
with branch.lock_read():
772
758
revision_a = revision.ensure_null(branch.last_revision())
773
759
if revision_a == revision.NULL_REVISION:
774
760
raise errors.NoCommits(branch)
775
761
if other_location == '':
776
762
other_location = branch.get_parent()
777
763
other_branch = Branch.open(other_location)
778
other_branch.lock_read()
764
with other_branch.lock_read():
780
765
revision_b = revision.ensure_null(other_branch.last_revision())
781
766
if revision_b == revision.NULL_REVISION:
782
767
raise errors.NoCommits(other_branch)
783
768
graph = branch.repository.get_graph(other_branch.repository)
784
769
rev_id = graph.find_unique_lca(revision_a, revision_b)
786
other_branch.unlock()
787
770
if rev_id == revision.NULL_REVISION:
788
771
raise errors.NoCommonAncestor(revision_a, revision_b)
796
775
class RevisionSpec_branch(RevisionSpec):
808
787
dwim_catchable_exceptions = (errors.NotBranchError,)
810
789
def _match_on(self, branch, revs):
811
from bzrlib.branch import Branch
790
from .branch import Branch
812
791
other_branch = Branch.open(self.spec)
813
792
revision_b = other_branch.last_revision()
814
793
if revision_b in (None, revision.NULL_REVISION):
815
794
raise errors.NoCommits(other_branch)
816
# pull in the remote revisions so we can diff
817
branch.fetch(other_branch, revision_b)
819
revno = branch.revision_id_to_revno(revision_b)
820
except errors.NoSuchRevision:
822
return RevisionInfo(branch, revno, revision_b)
796
branch = other_branch
799
# pull in the remote revisions so we can diff
800
branch.fetch(other_branch, revision_b)
801
except errors.ReadOnlyError:
802
branch = other_branch
803
return RevisionInfo(branch, None, revision_b)
824
805
def _as_revision_id(self, context_branch):
825
from bzrlib.branch import Branch
806
from .branch import Branch
826
807
other_branch = Branch.open(self.spec)
827
808
last_revision = other_branch.last_revision()
828
809
last_revision = revision.ensure_null(last_revision)
884
872
self._get_submit_location(context_branch))
875
class RevisionSpec_annotate(RevisionIDSpec):
879
help_txt = """Select the revision that last modified the specified line.
881
Select the revision that last modified the specified line. Line is
882
specified as path:number. Path is a relative path to the file. Numbers
883
start at 1, and are relative to the current version, not the last-
884
committed version of the file.
887
def _raise_invalid(self, numstring, context_branch):
888
raise errors.InvalidRevisionSpec(self.user_spec, context_branch,
889
'No such line: %s' % numstring)
891
def _as_revision_id(self, context_branch):
892
path, numstring = self.spec.rsplit(':', 1)
894
index = int(numstring) - 1
896
self._raise_invalid(numstring, context_branch)
897
tree, file_path = workingtree.WorkingTree.open_containing(path)
898
with tree.lock_read():
899
if not tree.has_filename(file_path):
900
raise errors.InvalidRevisionSpec(self.user_spec,
901
context_branch, "File '%s' is not versioned." %
903
revision_ids = [r for (r, l) in tree.annotate_iter(file_path)]
905
revision_id = revision_ids[index]
907
self._raise_invalid(numstring, context_branch)
908
if revision_id == revision.CURRENT_REVISION:
909
raise errors.InvalidRevisionSpec(self.user_spec, context_branch,
910
'Line %s has not been committed.' % numstring)
914
class RevisionSpec_mainline(RevisionIDSpec):
916
help_txt = """Select mainline revision that merged the specified revision.
918
Select the revision that merged the specified revision into mainline.
923
def _as_revision_id(self, context_branch):
924
revspec = RevisionSpec.from_string(self.spec)
925
if revspec.get_branch() is None:
926
spec_branch = context_branch
928
spec_branch = _mod_branch.Branch.open(revspec.get_branch())
929
revision_id = revspec.as_revision_id(spec_branch)
930
graph = context_branch.repository.get_graph()
931
result = graph.find_lefthand_merger(revision_id,
932
context_branch.last_revision())
934
raise errors.InvalidRevisionSpec(self.user_spec, context_branch)
887
938
# The order in which we want to DWIM a revision spec without any prefix.
888
939
# revno is always tried first and isn't listed here, this is used by
889
940
# RevisionSpec_dwim._match_on
891
RevisionSpec_tag, # Let's try for a tag
892
RevisionSpec_revid, # Maybe it's a revid?
893
RevisionSpec_date, # Perhaps a date?
894
RevisionSpec_branch, # OK, last try, maybe it's a branch
941
RevisionSpec_dwim.append_possible_revspec(RevisionSpec_tag)
942
RevisionSpec_dwim.append_possible_revspec(RevisionSpec_revid)
943
RevisionSpec_dwim.append_possible_revspec(RevisionSpec_date)
944
RevisionSpec_dwim.append_possible_revspec(RevisionSpec_branch)
898
946
revspec_registry = registry.Registry()
899
947
def _register_revspec(revspec):
908
956
_register_revspec(RevisionSpec_ancestor)
909
957
_register_revspec(RevisionSpec_branch)
910
958
_register_revspec(RevisionSpec_submit)
912
# classes in this list should have a "prefix" attribute, against which
913
# string specs are matched
914
SPEC_TYPES = symbol_versioning.deprecated_list(
915
symbol_versioning.deprecated_in((1, 12, 0)), "SPEC_TYPES", [])
959
_register_revspec(RevisionSpec_annotate)
960
_register_revspec(RevisionSpec_mainline)