Lodge It

Index: versioncontrol/api.py
===================================================================
--- versioncontrol/api.py       (revision 6374)
+++ versioncontrol/api.py       (working copy)
@@ -49,6 +49,18 @@
         """
 
 
+class IRepositoryListener(Interface):
+    """Extension point interface for components that require notification
+    when changesets are commited or pushed to the server.  This requires the
+    trac-post-commit-hook."""
+
+    def changeset_commited(chgset):
+        """Called after a changeset is commited."""
+
+    def changeset_synced(chgset):
+        """Called if a changeset is (re)synced."""
+
+
 class RepositoryManager(Component):
     """Component registering the supported version control systems,
 
Index: versioncontrol/hook.py
===================================================================
--- versioncontrol/hook.py      (revision 0)
+++ versioncontrol/hook.py      (revision 0)
@@ -0,0 +1,63 @@
+# -*- coding: utf-8 -*-
+#
+# Copyright (C) 2005-2006 Edgewall Software
+# Copyright (C) 2008 Armin Ronacher <armin.ronacher@active-4.com>
+# 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://trac.edgewall.org/wiki/TracLicense.
+#
+# This software consists of voluntary contributions made by many
+# individuals. For the exact contribution history, see the revision
+# history and logs, available at http://trac.edgewall.org/log/.
+#
+# Author: Armin Ronacher <armin.ronacher@active-4.com>
+
+import sys
+from trac import __version__ as VERSION
+from trac.core import *
+from trac.versioncontrol import IRepositoryListener, NoSuchChangeset
+from trac.env import open_environment
+from optparse import OptionParser
+
+
+option_parser = OptionParser(version='trac-post-commit-hook ' + VERSION)
+opt = option_parser.add_option
+fail = option_parser.error
+opt('-e', '--env', dest='env',
+    help='The path to the trac environment folder.')
+opt('-r', '--rev', dest='rev',
+    help='The revision id for the changeset.')
+
+
+class CommitHook(Component):
+    repository_listeners = ExtensionPoint(IRepositoryListener)
+
+    def changeset_commited(self, chgset):
+        for listener in self.repository_listeners:
+            listener.changeset_commited(chgset)
+
+
+def post_commit_hook(args=None):
+    """Main entry point."""
+    if args is None:
+        args = sys.argv[1:]
+    options, args = option_parser.parse_args(args)
+    if not (options.rev and options.env):
+        fail('Environment and revision required.')
+
+    try:
+        env = open_environment(options.env)
+    except IOError, e:
+        if e.errno == 2:
+            fail('Not a valid trac environment')
+        raise
+
+    repo = env.get_repository()
+    repo.sync()
+    try:
+        chgset = repo.get_changeset(options.rev)
+    except NoSuchChangeset:
+        return
+    CommitHook(env).changeset_commited(chgset)
Index: versioncontrol/cache.py
===================================================================
--- versioncontrol/cache.py     (revision 6374)
+++ versioncontrol/cache.py     (working copy)
@@ -17,11 +17,11 @@
 import posixpath
 from datetime import datetime
 
-from trac.core import TracError
+from trac.core import TracError, ExtensionPoint
 from trac.util.datefmt import utc, to_timestamp
 from trac.util.translation import _
 from trac.versioncontrol import Changeset, Node, Repository, Authorizer, \
-                                NoSuchChangeset
+                                NoSuchChangeset, IRepositoryListener
 
 
 _kindmap = {'D': Node.DIRECTORY, 'F': Node.FILE}
@@ -36,6 +36,7 @@
 
 
 class CachedRepository(Repository):
+    repository_listeners = ExtensionPoint(IRepositoryListener)
 
     def __init__(self, db, repos, authz, log):
         Repository.__init__(self, repos.name, authz, log)
@@ -73,6 +74,8 @@
                                         cset.author, cset.message,
                                         (str(cset.rev))))
         self.db.commit()
+        for listener in self.repository_listeners:
+            listener.changeset_synced(cset)
         
     def sync(self, feedback=None):
         cursor = self.db.cursor()
@@ -203,7 +206,7 @@
                                         path, kind, action, bpath, brev))
 
                     # 1.3. iterate (1.1 should always succeed now)
-                    self.youngest = next_youngest                    
+                    self.youngest = next_youngest
                     next_youngest = self.repos.next_rev(next_youngest)
 
                     # 1.4. update 'youngest_rev' metadata (minimize failures at 0.)
@@ -211,6 +214,9 @@
                                    (str(self.youngest), CACHE_YOUNGEST_REV))
                     self.db.commit()
 
+                    for listener in self.repository_listeners:
+                        listener.changeset_synced(self.youngest)
+
                     # 1.5. provide some feedback
                     if feedback:
                         feedback(self.youngest)