Skip to content
Snippets Groups Projects
Verified Commit 324ca1b5 authored by Torsten Grote's avatar Torsten Grote
Browse files

Address review feedback

parent bab6ec70
No related branches found
No related tags found
Loading
...@@ -15,9 +15,6 @@ import org.briarproject.bramble.api.mailbox.MailboxPairingState; ...@@ -15,9 +15,6 @@ import org.briarproject.bramble.api.mailbox.MailboxPairingState;
import org.briarproject.bramble.api.mailbox.MailboxPairingTask; import org.briarproject.bramble.api.mailbox.MailboxPairingTask;
import org.briarproject.bramble.api.mailbox.MailboxProperties; import org.briarproject.bramble.api.mailbox.MailboxProperties;
import org.briarproject.bramble.api.mailbox.MailboxUpdateWithMailbox; import org.briarproject.bramble.api.mailbox.MailboxUpdateWithMailbox;
import org.briarproject.bramble.api.plugin.Plugin;
import org.briarproject.bramble.api.plugin.PluginException;
import org.briarproject.bramble.api.plugin.TorConstants;
import org.briarproject.bramble.api.sync.GroupId; import org.briarproject.bramble.api.sync.GroupId;
import org.briarproject.bramble.test.BrambleIntegrationTest; import org.briarproject.bramble.test.BrambleIntegrationTest;
import org.briarproject.bramble.test.TestDatabaseConfigModule; import org.briarproject.bramble.test.TestDatabaseConfigModule;
...@@ -86,7 +83,6 @@ abstract class AbstractMailboxIntegrationTest ...@@ -86,7 +83,6 @@ abstract class AbstractMailboxIntegrationTest
.testDatabaseConfigModule(dbModule) .testDatabaseConfigModule(dbModule)
.build(); .build();
injectEagerSingletons(component); injectEagerSingletons(component);
component.getPluginManager().setPluginEnabled(TorConstants.ID, false);
setUp(component, name); setUp(component, name);
return component; return component;
...@@ -121,37 +117,43 @@ abstract class AbstractMailboxIntegrationTest ...@@ -121,37 +117,43 @@ abstract class AbstractMailboxIntegrationTest
if (!latch.await(10, SECONDS)) { if (!latch.await(10, SECONDS)) {
fail("Timeout reached when waiting for pairing."); fail("Timeout reached when waiting for pairing.");
} }
return c.getDatabaseComponent() MailboxProperties properties = c.getDatabaseComponent()
.transactionWithNullableResult(true, txn -> .transactionWithNullableResult(true, txn ->
c.getMailboxSettingsManager() c.getMailboxSettingsManager()
.getOwnMailboxProperties(txn) .getOwnMailboxProperties(txn)
); );
assertNotNull(properties);
return properties;
} }
void addContacts() throws Exception { void addContacts() throws Exception {
LocalAuthor author1 = c1.getIdentityManager().getLocalAuthor(); LocalAuthor author1 = c1.getIdentityManager().getLocalAuthor();
LocalAuthor author2 = c2.getIdentityManager().getLocalAuthor(); LocalAuthor author2 = c2.getIdentityManager().getLocalAuthor();
ContactId contactId1 = c1.getContactManager().addContact(author2, ContactId contactId2From1 =
author1.getId(), rootKey, c1.getClock().currentTimeMillis(), c1.getContactManager().addContact(author2,
true, true, true); author1.getId(), rootKey,
ContactId contactId2 = c2.getContactManager().addContact(author1, c1.getClock().currentTimeMillis(),
author2.getId(), rootKey, c2.getClock().currentTimeMillis(), true, true, true);
false, true, true); ContactId contactId1From2 =
c2.getContactManager().addContact(author1,
contact2From1 = c1.getContactManager().getContact(contactId2); author2.getId(), rootKey,
contact1From2 = c2.getContactManager().getContact(contactId1); c2.getClock().currentTimeMillis(),
false, true, true);
// Sync client versioning update from 0 to 1
contact2From1 = c1.getContactManager().getContact(contactId2From1);
contact1From2 = c2.getContactManager().getContact(contactId1From2);
// Sync client versioning update from 1 to 2
sync1To2(1, true); sync1To2(1, true);
// Sync client versioning update and ack from 1 to 0 // Sync client versioning update and ack from 2 to 1
sync2To1(1, true); sync2To1(1, true);
// Sync second client versioning update, mailbox properties and ack // Sync second client versioning update, mailbox properties and ack
// from 0 to 1 // from 1 to 2
sync1To2(2, true); sync1To2(2, true);
// Sync mailbox properties and ack from 1 to 0 // Sync mailbox properties and ack from 2 to 1
sync2To1(1, true); sync2To1(1, true);
// Sync final ack from 0 to 1 // Sync final ack from 1 to 2
ack1To2(1); ack1To2(1);
} }
...@@ -161,14 +163,6 @@ abstract class AbstractMailboxIntegrationTest ...@@ -161,14 +163,6 @@ abstract class AbstractMailboxIntegrationTest
.transactionWithResult(true, callable::call); .transactionWithResult(true, callable::call);
} }
void restartTor(MailboxIntegrationTestComponent device)
throws PluginException {
Plugin torPlugin = device.getPluginManager().getPlugin(TorConstants.ID);
assertNotNull(torPlugin);
torPlugin.stop();
torPlugin.start();
}
MailboxProperties getMailboxProperties( MailboxProperties getMailboxProperties(
MailboxIntegrationTestComponent device, ContactId contactId) MailboxIntegrationTestComponent device, ContactId contactId)
throws DbException { throws DbException {
......
...@@ -15,16 +15,16 @@ class TestMailboxConfigImpl implements MailboxConfig { ...@@ -15,16 +15,16 @@ class TestMailboxConfigImpl implements MailboxConfig {
@Override @Override
public long getApiCallerMinRetryInterval() { public long getApiCallerMinRetryInterval() {
return 1000; // MailboxApiCaller.MIN_RETRY_INTERVAL_MS; return 1000;
} }
@Override @Override
public long getApiCallerMaxRetryInterval() { public long getApiCallerMaxRetryInterval() {
return 2000; // MailboxApiCaller.MAX_RETRY_INTERVAL_MS; return 2000;
} }
@Override @Override
public long getTorReachabilityPeriod() { public long getTorReachabilityPeriod() {
return 5000; // TorReachabilityMonitor.REACHABILITY_PERIOD_MS; return 10_000;
} }
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment