1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
# (Be in -*- python -*- mode.)
#
# ====================================================================
# Copyright (c) 2007-2009 CollabNet. All rights reserved.
#
# This software is licensed as described in the file COPYING, which
# you should have received as part of this distribution. The terms
# are also available at http://subversion.tigris.org/license-1.html.
# If newer versions of this license are posted there, you may use a
# newer version instead, at your option.
#
# This software consists of voluntary contributions made by many
# individuals. For exact contribution history, see the revision
# history and logs, available at http://cvs2svn.tigris.org/.
# ====================================================================
"""An abstract class that contructs file contents during CollectRevsPass.
It calls its record_fulltext() method with the full text of every
revision. This method should be overridden to do something with the
fulltext and possibly return a revision_recorder_token."""
from cvs2svn_lib.revision_manager import RevisionRecorder
class FulltextRevisionRecorder:
"""Similar to a RevisionRecorder, but it requires the fulltext."""
def register_artifacts(self, which_pass):
pass
def start(self):
pass
def start_file(self, cvs_file_items):
pass
def record_fulltext(self, cvs_rev, log, fulltext):
"""Record the fulltext for CVS_REV.
CVS_REV has the log message LOG and the fulltext FULLTEXT. This
method should be overridden to do something sensible with them."""
raise NotImplementedError()
def finish_file(self, cvs_file_items):
pass
def finish(self):
pass
class FulltextRevisionRecorderAdapter(RevisionRecorder):
"""Reconstruct the fulltext and pass it to a FulltextRevisionRecorder.
This class implements RevisionRecorder (so it can be passed directly
to CollectRevsPass). But it doesn't actually record anything.
Instead, it reconstructs the fulltext of each revision, and passes
the fulltext to a fulltext_revision_recorder."""
def __init__(self, fulltext_revision_recorder):
RevisionRecorder.__init__(self)
self.fulltext_revision_recorder = fulltext_revision_recorder
def register_artifacts(self, which_pass):
self.fulltext_revision_recorder.register_artifacts(which_pass)
def start(self):
self.fulltext_revision_recorder.start()
def start_file(self, cvs_file_items):
self.fulltext_revision_recorder.start_file(cvs_file_items)
def record_text(self, cvs_rev, log, text):
"""This method should be overwridden.
It should determine the fulltext of CVS_REV, then pass it to
self.fulltext_revision_recorder.record_fulltext() and return the
result."""
raise NotImplementedError()
def finish_file(self, cvs_file_items):
self.fulltext_revision_recorder.finish_file(cvs_file_items)
def finish(self):
self.fulltext_revision_recorder.finish()
class SimpleFulltextRevisionRecorderAdapter(FulltextRevisionRecorderAdapter):
"""Reconstruct the fulltext using a RevisionReader.
To create the fulltext, this class simply uses a RevisionReader (for
example, RCSRevisionReader or CVSRevisionReader). This is not quite
as wasteful as using one of these RevisionReaders in OutputPass,
because the same RCS file will be read over and over (and so
presumably stay in the disk cache). But it is still pretty silly,
considering that we have all the RCS deltas available to us."""
def __init__(self, revision_reader, fulltext_revision_recorder):
FulltextRevisionRecorderAdapter.__init__(self, fulltext_revision_recorder)
self.revision_reader = revision_reader
def register_artifacts(self, which_pass):
FulltextRevisionRecorderAdapter.register_artifacts(self, which_pass)
self.revision_reader.register_artifacts(which_pass)
def start(self):
FulltextRevisionRecorderAdapter.start(self)
self.revision_reader.start()
def record_text(self, cvs_rev, log, text):
# FIXME: We have to decide what to do about keyword substitution
# and eol_style here:
fulltext = self.revision_reader.get_content_stream(
cvs_rev, suppress_keyword_substitution=False
).read()
return self.fulltext_revision_recorder.record_fulltext(
cvs_rev, log, fulltext
)
def finish(self):
FulltextRevisionRecorderAdapter.finish(self)
self.revision_reader.finish()
|
GitWeb