summaryrefslogtreecommitdiff
path: root/src/leap/soledad/tests/test_logs.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/leap/soledad/tests/test_logs.py')
-rw-r--r--src/leap/soledad/tests/test_logs.py65
1 files changed, 37 insertions, 28 deletions
diff --git a/src/leap/soledad/tests/test_logs.py b/src/leap/soledad/tests/test_logs.py
index 0be0d1f9..3dfeff75 100644
--- a/src/leap/soledad/tests/test_logs.py
+++ b/src/leap/soledad/tests/test_logs.py
@@ -1,14 +1,18 @@
import unittest2 as unittest
-from leap.soledad.backends.objectstore import TransactionLog, SyncLog, ConflictLog
+from leap.soledad.backends.objectstore import (
+ TransactionLog,
+ SyncLog,
+ ConflictLog
+)
class LogTestCase(unittest.TestCase):
def test_transaction_log(self):
data = [
- (2, "doc_3", "tran_3"),
- (3, "doc_2", "tran_2"),
- (1, "doc_1", "tran_1")
+ (2, "doc_3", "tran_3"),
+ (3, "doc_2", "tran_2"),
+ (1, "doc_1", "tran_1")
]
log = TransactionLog()
log.log = data
@@ -24,49 +28,55 @@ class LogTestCase(unittest.TestCase):
def test_sync_log(self):
data = [
- ("replica_3", 3, "tran_3"),
- ("replica_2", 2, "tran_2"),
- ("replica_1", 1, "tran_1")
+ ("replica_3", 3, "tran_3"),
+ ("replica_2", 2, "tran_2"),
+ ("replica_1", 1, "tran_1")
]
log = SyncLog()
log.log = data
# test getting
self.assertEqual(log.get_replica_gen_and_trans_id('replica_3'),
- (3, 'tran_3'), 'error getting replica gen and trans id')
+ (3, 'tran_3'),
+ 'error getting replica gen and trans id')
self.assertEqual(log.get_replica_gen_and_trans_id('replica_2'),
- (2, 'tran_2'), 'error getting replica gen and trans id')
+ (2, 'tran_2'),
+ 'error getting replica gen and trans id')
self.assertEqual(log.get_replica_gen_and_trans_id('replica_1'),
- (1, 'tran_1'), 'error getting replica gen and trans id')
+ (1, 'tran_1'),
+ 'error getting replica gen and trans id')
# test setting
log.set_replica_gen_and_trans_id('replica_1', 2, 'tran_12')
self.assertEqual(len(log._data), 3, 'error in log size after setting')
self.assertEqual(log.get_replica_gen_and_trans_id('replica_1'),
- (2, 'tran_12'), 'error setting replica gen and trans id')
+ (2, 'tran_12'),
+ 'error setting replica gen and trans id')
self.assertEqual(log.get_replica_gen_and_trans_id('replica_2'),
- (2, 'tran_2'), 'error setting replica gen and trans id')
+ (2, 'tran_2'),
+ 'error setting replica gen and trans id')
self.assertEqual(log.get_replica_gen_and_trans_id('replica_3'),
- (3, 'tran_3'), 'error setting replica gen and trans id')
+ (3, 'tran_3'),
+ 'error setting replica gen and trans id')
def test_whats_changed(self):
data = [
(1, "doc_1", "tran_1"),
(2, "doc_2", "tran_2"),
(3, "doc_3", "tran_3")
- ]
+ ]
log = TransactionLog()
log.log = data
self.assertEqual(
- log.whats_changed(3),
- (3, "tran_3", []),
- 'error getting whats changed.')
+ log.whats_changed(3),
+ (3, "tran_3", []),
+ 'error getting whats changed.')
self.assertEqual(
- log.whats_changed(2),
- (3, "tran_3", [("doc_3",3,"tran_3")]),
- 'error getting whats changed.')
+ log.whats_changed(2),
+ (3, "tran_3", [("doc_3", 3, "tran_3")]),
+ 'error getting whats changed.')
self.assertEqual(
- log.whats_changed(1),
- (3, "tran_3", [("doc_2",2,"tran_2"),("doc_3",3,"tran_3")]),
- 'error getting whats changed.')
+ log.whats_changed(1),
+ (3, "tran_3", [("doc_2", 2, "tran_2"), ("doc_3", 3, "tran_3")]),
+ 'error getting whats changed.')
def test_conflict_log(self):
# TODO: include tests for `get_conflicts` and `has_conflicts`.
@@ -75,13 +85,12 @@ class LogTestCase(unittest.TestCase):
('3', 'my:1', 'irrelevant')]
log = ConflictLog(None)
log.log = data
- log.delete_conflicts([('1','my:1'),('2','my:1')])
+ log.delete_conflicts([('1', 'my:1'), ('2', 'my:1')])
self.assertEqual(
- log.log,
- [('3', 'my:1', 'irrelevant')],
- 'error deleting conflicts.')
+ log.log,
+ [('3', 'my:1', 'irrelevant')],
+ 'error deleting conflicts.')
if __name__ == '__main__':
unittest.main()
-