Implement our own copyTransactionFrom().

git-svn-id: https://svn.erp5.org/repos/neo/trunk@1908 71dcc9de-d417-0410-9af5-da40c76e7ee4

neo/client/Storage.py

@@ -136,6 +136,9 @@ class Storage(BaseStorage.BaseStorage,
     def sync(self):
         self.app.sync()
 
+    def copyTransactionsFrom(self, source, verbose=False):
+        return self.app.copyTransactionsFrom(source, self.tryToResolveConflict)
+
 #    def restore(self, oid, serial, data, version, prev_txn, transaction):
 #        raise NotImplementedError
 

neo/client/app.py

@@ -981,6 +981,30 @@ class Application(object):
 
         return history_list
 
+    def copyTransactionsFrom(self, source, tryToResolveConflict):
+        serials = {}
+        def updateLastSerial(oid, result):
+            if result:
+                if isinstance(result, str):
+                    assert oid is not None
+                    serials[oid] = result
+                else:
+                    for oid, serial in result:
+                        assert isinstance(serial, str), serial
+                        serials[oid] = serial
+        transaction_iter = source.iterator()
+        for transaction in transaction_iter:
+            self.tpc_begin(transaction, transaction.tid, transaction.status)
+            for r in transaction:
+                pre = serials.get(r.oid, None)
+                # TODO: bypass conflict resolution, locks...
+                result = self.store(r.oid, pre, r.data, r.version, transaction)
+                updateLastSerial(r.oid, result)
+            updateLastSerial(None, self.tpc_vote(transaction,
+                        tryToResolveConflict))
+            self.tpc_finish(transaction)
+        transaction_iter.close()
+
     def iterator(self, start=None, stop=None):
         return Iterator(self, start, stop)