summaryrefslogtreecommitdiff
path: root/common/src/leap
diff options
context:
space:
mode:
Diffstat (limited to 'common/src/leap')
-rw-r--r--common/src/leap/soledad/common/tests/test_sync.py53
1 files changed, 11 insertions, 42 deletions
diff --git a/common/src/leap/soledad/common/tests/test_sync.py b/common/src/leap/soledad/common/tests/test_sync.py
index bb98db8c..9638ec1a 100644
--- a/common/src/leap/soledad/common/tests/test_sync.py
+++ b/common/src/leap/soledad/common/tests/test_sync.py
@@ -23,14 +23,11 @@ import time
from urlparse import urljoin
from twisted.internet import defer
-from uuid import uuid4
from testscenarios import TestWithScenarios
from leap.soledad.common import couch
-from leap.soledad.client import http_target
from leap.soledad.client import sync
-from leap.soledad.server import SoledadApp
from leap.soledad.common.tests import u1db_tests as tests
from leap.soledad.common.tests.u1db_tests import TestCaseWithServer
@@ -77,6 +74,8 @@ class InterruptableSyncTestCase(
Test if Soledad can sync many smallfiles.
"""
+ self.skipTest("Sync is currently not interruptable.")
+
class _SyncInterruptor(threading.Thread):
"""
@@ -147,10 +146,6 @@ class InterruptableSyncTestCase(
return d
-def make_soledad_app(state):
- return SoledadApp(state)
-
-
class TestSoledadDbSync(
TestWithScenarios,
tests.TestCaseWithServer,
@@ -161,10 +156,6 @@ class TestSoledadDbSync(
"""
scenarios = [
- ('py-http', {
- 'make_app_with_state': make_soledad_app,
- 'make_database_for_test': tests.make_memory_database_for_test,
- }),
('py-token-http', {
'make_app_with_state': make_token_soledad_app,
'make_database_for_test': tests.make_memory_database_for_test,
@@ -175,12 +166,16 @@ class TestSoledadDbSync(
oauth = False
token = False
+ def make_app(self):
+ self.request_state = couch.CouchServerState(self._couch_url)
+ return self.make_app_with_state(self.request_state)
+
def setUp(self):
"""
Need to explicitely invoke inicialization on all bases.
"""
SoledadWithCouchServerMixin.setUp(self)
- self.startServer()
+ self.startTwistedServer()
self.db = self.make_database_for_test(self, 'test1')
self.db2 = couch.CouchDatabase.open_database(
urljoin(
@@ -203,13 +198,10 @@ class TestSoledadDbSync(
Perform sync using SoledadSynchronizer, SoledadSyncTarget
and Token auth.
"""
-
- target_url = self.getURL(target_name)
- creds = {'token': {
- 'uuid': 'user-uuid',
- 'token': 'auth-token',
- }}
- target = soledad_sync_target(self, target_name)
+ target = soledad_sync_target(
+ self, target_name,
+ source_replica_uid=self._soledad._dbpool.replica_uid)
+ self.addCleanup(target.close)
return sync.SoledadSynchronizer(
self.db,
target).sync(defer_decryption=False)
@@ -234,26 +226,3 @@ class TestSoledadDbSync(
self.db2, doc1.doc_id, doc1.rev, tests.simple_doc, False)
self.assertGetEncryptedDoc(
self.db, doc2.doc_id, doc2.rev, tests.nested_doc, False)
-
- @defer.inlineCallbacks
- def test_db_sync_autocreate(self):
- """
- Test sync.
-
- Adapted to check for encrypted content.
- """
- doc1 = self.db.create_doc_from_json(tests.simple_doc)
- local_gen_before_sync = yield self.do_sync('test')
- gen, _, changes = self.db.whats_changed(local_gen_before_sync)
- self.assertEqual(0, gen - local_gen_before_sync)
- db3 = self.request_state.open_database('test')
- gen, _, changes = db3.whats_changed()
- self.assertEqual(1, len(changes))
- self.assertEqual(doc1.doc_id, changes[0][0])
- self.assertGetEncryptedDoc(
- db3, doc1.doc_id, doc1.rev, tests.simple_doc, False)
- t_gen, _ = self.db._get_replica_gen_and_trans_id(
- db3.replica_uid)
- s_gen, _ = db3._get_replica_gen_and_trans_id('test1')
- self.assertEqual(1, t_gen)
- self.assertEqual(1, s_gen)