Ticket #1271: resync_on_ranges--1387.diff

scripts/admin.py

@@ -587 +587 @@
         
-    _help_resync = [('resync', 'Re-synchronize trac with the repository')]
+    _help_resync = [('resync [start-rev][:end-rev]', 'Re-synchronize trac with the repository')]
     
@@ -591 +591 @@
     def do_resync(self, line):
+        arg = self.arg_tokenize(line)
+        if len(arg) > 0 and arg[0] != '':
+            sep = arg[0].find(':')
+            if sep == 0:                # only the 'end-rev' given
+                start = 0               # forces a resync from the start
+                end = int(arg[0][1:])
+            elif sep > 0:               # both 'start-rev' and 'end-rev' given
+                start = int(arg[0][:sep])
+                end = int(arg[0][sep+1:])
+            else:                       # only the 'start-rev' given
+                start = int(arg[0])
+                end = -1
+        else:                           # no revs given
+            start = 0
+            end = -1
         from svn import repos, core
@@ -607 +622 @@
         print 'resyncing...'
-        self.db_execsql("DELETE FROM revision")
-        self.db_execsql("DELETE FROM node_change")
-        sync.sync(cnx, rep, fs_ptr, pool)
+        if start > 0 and end > 0:
+            print '  from revision %d to revision %d' % (start, end)
+            self.db_execsql("DELETE FROM revision where rev >= %d and rev <= %d" % (start, end))
+            self.db_execsql("DELETE FROM node_change where rev >= %d and rev <= %d" % (start, end))
+        elif start > 0:
+            print '  from revision %d to the youngest revision' % start
+            self.db_execsql("DELETE FROM revision where rev >= %d" % start)
+            self.db_execsql("DELETE FROM node_change where rev >= %d" % start)
+        elif end > 0:
+            print '  from the first revision to revision %d' % end
+            self.db_execsql("DELETE FROM revision where rev <= %d" % end)
+            self.db_execsql("DELETE FROM node_change where rev <= %d" % end)
+        else:
+            print '  all revisions'
+            self.db_execsql("DELETE FROM revision")
+            self.db_execsql("DELETE FROM node_change")
+        sync.sync(cnx, rep, fs_ptr, pool, start, end)
         print 'done.'

sync.py

@@ -26 +26 @@
 
-def sync(db, repos, fs_ptr, pool):
+def sync(db, repos, fs_ptr, pool, start=-1, end=-1):
     """
@@ -30 +30 @@
     the repository.
+    start -- start from this changeset (-1 means the youngest stored)
+    end   -- end at this changeset (-1 means the youngest rev in the repository)
     """
@@ -41 +43 @@
     max_rev = fs.youngest_rev(fs_ptr, pool)
-    num = max_rev - youngest_stored
-    offset = youngest_stored + 1
+    if end < 0 or end > max_rev:
+        end = max_rev
+    # Note: after that point, start is readjusted to be one changeset _before_ the real start
+    if start < 0 or start > youngest_stored:
+        start = youngest_stored
+    else:
+        start -= 1
+    num = end - start
+    offset = start + 1
     
@@ -81 +90 @@
     ||     ||  'R'   || original rev, original path // renamed path   ||
+    ||     ||  'm'   || original rev, original path // modified path  ||
     ||     ||  'd'   || original rev, original path // deleted path   ||
@@ -84 +94 @@
     The 'ADM' operations are direct operations.
-    The 'CR' operation can be direct operations.
-    The 'CRdm' may happen after a 'CR' operation on a parent path.
+    The 'CR' operations can be direct operations.
+    The 'CRdm' operations may happen after a 'CR' operation on a parent path.
     """