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
|
Index: trac/versioncontrol/svn_fs.py
===================================================================
--- trac/versioncontrol/svn_fs.py (revision 8986)
+++ trac/versioncontrol/svn_fs.py (working copy)
@@ -289,7 +289,7 @@
repos = fs_repos
else:
repos = CachedRepository(self.env.get_db_cnx, fs_repos, None,
- self.log)
+ self.log, self.env)
repos.has_linear_changesets = True
if authname:
authz = SubversionAuthorizer(self.env, weakref.proxy(repos),
Index: trac/versioncontrol/cache.py
===================================================================
--- trac/versioncontrol/cache.py (revision 8986)
+++ trac/versioncontrol/cache.py (working copy)
@@ -18,7 +18,7 @@
import os
import posixpath
-from trac.core import TracError
+from trac.core import *
from trac.util.datefmt import utc, to_timestamp
from trac.util.translation import _
from trac.versioncontrol import Changeset, Node, Repository, Authorizer, \
@@ -36,19 +36,42 @@
CACHE_METADATA_KEYS = (CACHE_REPOSITORY_DIR, CACHE_YOUNGEST_REV)
+class ICacheChangesetListener(Interface):
+ """Cached changeset operations"""
+
+ def edit_changeset(cset):
+ """Called when changeset is about to be cached.
+ Returns altered data to cache or None if unchanged. cset usually
+ contains cset.date, cset.author, cset.message and cset.rev
+ """
+
+class CacheManager(Component):
+ """Provide interface to plug-in into cache operations"""
+
+ observers = ExtensionPoint(ICacheChangesetListener)
+
+ def check_changeset(self, cset):
+ for observer in self.observers:
+ res = observer.edit_changeset(cset)
+ if res != None:
+ cset = res
+ return cset
+
+
class CachedRepository(Repository):
has_linear_changesets = False
scope = property(lambda self: self.repos.scope)
- def __init__(self, getdb, repos, authz, log):
+ def __init__(self, getdb, repos, authz, log, env):
Repository.__init__(self, repos.name, authz, log)
if callable(getdb):
self.getdb = getdb
else:
self.getdb = lambda: getdb
self.repos = repos
+ self.cache_mgr = CacheManager(env)
def close(self):
self.repos.close()
@@ -77,6 +100,7 @@
def sync_changeset(self, rev):
cset = self.repos.get_changeset(rev)
+ cset = self.cache_mgr.check_changeset(cset)
db = self.getdb()
cursor = db.cursor()
cursor.execute("UPDATE revision SET time=%s, author=%s, message=%s "
@@ -182,6 +206,7 @@
self.log.info("Trying to sync revision [%s]" %
next_youngest)
cset = self.repos.get_changeset(next_youngest)
+ cset = self.cache_mgr.check_changeset(cset)
try:
cursor.execute("INSERT INTO revision "
" (rev,time,author,message) "
|
