--- a/mobile/android/base/android-services.mozbuild
+++ b/mobile/android/base/android-services.mozbuild
@@ -961,17 +961,17 @@ sync_java_files = [TOPSRCDIR + '/mobile/
'sync/repositories/android/ClientsDatabaseAccessor.java',
'sync/repositories/android/FennecTabsRepository.java',
'sync/repositories/android/FormHistoryRepositorySession.java',
'sync/repositories/android/PasswordsRepositorySession.java',
'sync/repositories/android/RepoUtils.java',
'sync/repositories/android/VisitsHelper.java',
'sync/repositories/BookmarkNeedsReparentingException.java',
'sync/repositories/BookmarksRepository.java',
- 'sync/repositories/ConstrainedServer11Repository.java',
+ 'sync/repositories/ConfigurableServer15Repository.java',
'sync/repositories/delegates/DeferrableRepositorySessionCreationDelegate.java',
'sync/repositories/delegates/DeferredRepositorySessionBeginDelegate.java',
'sync/repositories/delegates/DeferredRepositorySessionFetchRecordsDelegate.java',
'sync/repositories/delegates/DeferredRepositorySessionFinishDelegate.java',
'sync/repositories/delegates/DeferredRepositorySessionStoreDelegate.java',
'sync/repositories/delegates/RepositorySessionBeginDelegate.java',
'sync/repositories/delegates/RepositorySessionCleanDelegate.java',
'sync/repositories/delegates/RepositorySessionCreationDelegate.java',
@@ -1011,32 +1011,32 @@ sync_java_files = [TOPSRCDIR + '/mobile/
'sync/repositories/NullCursorException.java',
'sync/repositories/ParentNotFoundException.java',
'sync/repositories/ProfileDatabaseException.java',
'sync/repositories/RecordFactory.java',
'sync/repositories/RecordFilter.java',
'sync/repositories/Repository.java',
'sync/repositories/RepositorySession.java',
'sync/repositories/RepositorySessionBundle.java',
- 'sync/repositories/Server11Repository.java',
- 'sync/repositories/Server11RepositorySession.java',
+ 'sync/repositories/Server15Repository.java',
+ 'sync/repositories/Server15RepositorySession.java',
'sync/repositories/StoreFailedException.java',
'sync/repositories/StoreTracker.java',
'sync/repositories/StoreTrackingRepositorySession.java',
'sync/repositories/uploaders/BatchingUploader.java',
'sync/repositories/uploaders/BatchMeta.java',
'sync/repositories/uploaders/BufferSizeTracker.java',
'sync/repositories/uploaders/MayUploadProvider.java',
'sync/repositories/uploaders/Payload.java',
'sync/repositories/uploaders/PayloadDispatcher.java',
'sync/repositories/uploaders/PayloadUploadDelegate.java',
'sync/repositories/uploaders/RecordUploadRunnable.java',
'sync/repositories/uploaders/UploaderMeta.java',
- 'sync/Server11PreviousPostFailedException.java',
- 'sync/Server11RecordPostFailedException.java',
+ 'sync/Server15PreviousPostFailedException.java',
+ 'sync/Server15RecordPostFailedException.java',
'sync/setup/activities/ActivityUtils.java',
'sync/setup/activities/WebURLFinder.java',
'sync/setup/Constants.java',
'sync/setup/InvalidSyncKeyException.java',
'sync/SharedPreferencesClientsDataDelegate.java',
'sync/stage/AbstractNonRepositorySyncStage.java',
'sync/stage/AbstractSessionManagingSyncStage.java',
'sync/stage/AndroidBrowserBookmarksServerSyncStage.java',
rename from mobile/android/services/src/main/java/org/mozilla/gecko/sync/Server11PreviousPostFailedException.java
rename to mobile/android/services/src/main/java/org/mozilla/gecko/sync/Server15PreviousPostFailedException.java
--- a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/Server11PreviousPostFailedException.java
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/Server15PreviousPostFailedException.java
@@ -2,11 +2,11 @@
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
package org.mozilla.gecko.sync;
/**
* A previous POST failed, so we won't send any more records this session.
*/
-public class Server11PreviousPostFailedException extends SyncException {
+public class Server15PreviousPostFailedException extends SyncException {
private static final long serialVersionUID = -3582490631414624310L;
}
rename from mobile/android/services/src/main/java/org/mozilla/gecko/sync/Server11RecordPostFailedException.java
rename to mobile/android/services/src/main/java/org/mozilla/gecko/sync/Server15RecordPostFailedException.java
--- a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/Server11RecordPostFailedException.java
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/Server15RecordPostFailedException.java
@@ -2,11 +2,11 @@
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
package org.mozilla.gecko.sync;
/**
* The server rejected a record in its "failure" array.
*/
-public class Server11RecordPostFailedException extends SyncException {
+public class Server15RecordPostFailedException extends SyncException {
private static final long serialVersionUID = -8517471217486190314L;
}
--- a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/middleware/Crypto5MiddlewareRepositorySession.java
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/middleware/Crypto5MiddlewareRepositorySession.java
@@ -24,17 +24,17 @@ import org.mozilla.gecko.sync.repositori
* Takes a RecordFactory as a parameter. This is in charge of taking decrypted CryptoRecords
* as input and producing some expected kind of Record as output for local use.
*
*
+------------------------------------+
- | Server11RepositorySession |
+ | Server15RepositorySession |
+-------------------------+----------+
^ |
| |
Encrypted CryptoRecords
| |
| v
+---------+--------------------------+
| Crypto5MiddlewareRepositorySession |
rename from mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/ConstrainedServer11Repository.java
rename to mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/ConfigurableServer15Repository.java
--- a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/ConstrainedServer11Repository.java
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/ConfigurableServer15Repository.java
@@ -6,28 +6,28 @@ package org.mozilla.gecko.sync.repositor
import java.net.URISyntaxException;
import org.mozilla.gecko.sync.InfoCollections;
import org.mozilla.gecko.sync.InfoConfiguration;
import org.mozilla.gecko.sync.net.AuthHeaderProvider;
/**
- * A kind of Server11Repository that supports explicit setting of per-batch fetch limit,
+ * A kind of Server15Repository that supports explicit setting of per-batch fetch limit,
* batching mode (single batch vs multi-batch), and a sort order.
*
* @author rnewman
*
*/
-public class ConstrainedServer11Repository extends Server11Repository {
+public class ConfigurableServer15Repository extends Server15Repository {
private final String sortOrder;
private final long batchLimit;
private final boolean allowMultipleBatches;
- public ConstrainedServer11Repository(
+ public ConfigurableServer15Repository(
String collection,
long syncDeadline,
String storageURL,
AuthHeaderProvider authHeaderProvider,
InfoCollections infoCollections,
InfoConfiguration infoConfiguration,
long batchLimit,
String sort,
rename from mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/Server11Repository.java
rename to mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/Server15Repository.java
--- a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/Server11Repository.java
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/Server15Repository.java
@@ -12,22 +12,22 @@ import org.mozilla.gecko.sync.InfoConfig
import org.mozilla.gecko.sync.net.AuthHeaderProvider;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionCreationDelegate;
import android.content.Context;
import android.support.annotation.NonNull;
import android.support.annotation.Nullable;
/**
- * A Server11Repository implements fetching and storing against the Sync 1.5 API.
+ * A Server15Repository implements fetching and storing against the Sync 1.5 API.
* It doesn't do crypto: that's the job of the middleware.
*
* @author rnewman
*/
-public class Server11Repository extends Repository {
+public class Server15Repository extends Repository {
public final AuthHeaderProvider authHeaderProvider;
private final long syncDeadlineMillis;
/* package-local */ final URI collectionURI;
protected final String collection;
protected final InfoCollections infoCollections;
@@ -39,17 +39,17 @@ public class Server11Repository extends
* Construct a new repository that fetches and stores against the Sync 1.5 API.
*
* @param collection name.
* @param storageURL full URL to storage endpoint.
* @param authHeaderProvider to use in requests; may be null.
* @param infoCollections instance; must not be null.
* @throws URISyntaxException
*/
- public Server11Repository(
+ public Server15Repository(
@NonNull String collection,
long syncDeadlineMillis,
@NonNull String storageURL,
AuthHeaderProvider authHeaderProvider,
@NonNull InfoCollections infoCollections,
@NonNull InfoConfiguration infoConfiguration) throws URISyntaxException {
if (collection == null) {
throw new IllegalArgumentException("collection must not be null");
@@ -66,17 +66,17 @@ public class Server11Repository extends
this.authHeaderProvider = authHeaderProvider;
this.infoCollections = infoCollections;
this.infoConfiguration = infoConfiguration;
}
@Override
public void createSession(RepositorySessionCreationDelegate delegate,
Context context) {
- delegate.onSessionCreated(new Server11RepositorySession(this));
+ delegate.onSessionCreated(new Server15RepositorySession(this));
}
public URI collectionURI() {
return this.collectionURI;
}
/* package-local */ boolean updateNeeded(long lastSyncTimestamp) {
return infoCollections.updateNeeded(collection, lastSyncTimestamp);
rename from mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/Server11RepositorySession.java
rename to mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/Server15RepositorySession.java
--- a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/Server11RepositorySession.java
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/Server15RepositorySession.java
@@ -10,26 +10,26 @@ import org.mozilla.gecko.background.comm
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionFetchRecordsDelegate;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionGuidsSinceDelegate;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionStoreDelegate;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionWipeDelegate;
import org.mozilla.gecko.sync.repositories.domain.Record;
import org.mozilla.gecko.sync.repositories.downloaders.BatchingDownloader;
import org.mozilla.gecko.sync.repositories.uploaders.BatchingUploader;
-public class Server11RepositorySession extends RepositorySession {
- public static final String LOG_TAG = "Server11RepositorySession";
+public class Server15RepositorySession extends RepositorySession {
+ public static final String LOG_TAG = "Server15RepositorySession";
- protected final Server11Repository serverRepository;
+ protected final Server15Repository serverRepository;
private BatchingUploader uploader;
private final BatchingDownloader downloader;
- public Server11RepositorySession(Repository repository) {
+ public Server15RepositorySession(Repository repository) {
super(repository);
- this.serverRepository = (Server11Repository) repository;
+ this.serverRepository = (Server15Repository) repository;
this.downloader = initializeDownloader(this);
}
@Override
public void setStoreDelegate(RepositorySessionStoreDelegate storeDelegate) {
super.setStoreDelegate(storeDelegate);
// Now that we have the delegate, we can initialize our uploader.
@@ -103,17 +103,17 @@ public class Server11RepositorySession e
uploader.noMoreRecordsToUpload();
}
@Override
public boolean dataAvailable() {
return serverRepository.updateNeeded(getLastSyncTimestamp());
}
- protected static BatchingDownloader initializeDownloader(final Server11RepositorySession serverRepositorySession) {
+ protected static BatchingDownloader initializeDownloader(final Server15RepositorySession serverRepositorySession) {
return new BatchingDownloader(
serverRepositorySession.serverRepository.authHeaderProvider,
Uri.parse(serverRepositorySession.serverRepository.collectionURI().toString()),
serverRepositorySession.serverRepository.getSyncDeadline(),
serverRepositorySession.serverRepository.getAllowMultipleBatches(),
serverRepositorySession);
}
}
--- a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/uploaders/PayloadDispatcher.java
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/uploaders/PayloadDispatcher.java
@@ -3,17 +3,17 @@
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
package org.mozilla.gecko.sync.repositories.uploaders;
import android.support.annotation.Nullable;
import android.support.annotation.VisibleForTesting;
import org.mozilla.gecko.background.common.log.Logger;
-import org.mozilla.gecko.sync.Server11RecordPostFailedException;
+import org.mozilla.gecko.sync.Server15RecordPostFailedException;
import org.mozilla.gecko.sync.net.SyncResponse;
import org.mozilla.gecko.sync.net.SyncStorageResponse;
import java.util.ArrayList;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicLong;
/**
@@ -128,17 +128,17 @@ class PayloadDispatcher {
} else {
uploader.finished(uploadTimestamp);
}
}
});
}
void recordFailed(final String recordGuid) {
- recordFailed(new Server11RecordPostFailedException(), recordGuid);
+ recordFailed(new Server15RecordPostFailedException(), recordGuid);
}
void recordFailed(final Exception e, final String recordGuid) {
Logger.debug(LOG_TAG, "Record store failed for guid " + recordGuid + " with exception: " + e.toString());
recordUploadFailed = true;
uploader.sessionStoreDelegate.onRecordStoreFailed(e, recordGuid);
}
--- a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/uploaders/RecordUploadRunnable.java
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/repositories/uploaders/RecordUploadRunnable.java
@@ -4,18 +4,18 @@
package org.mozilla.gecko.sync.repositories.uploaders;
import android.net.Uri;
import android.support.annotation.Nullable;
import android.support.annotation.VisibleForTesting;
import org.mozilla.gecko.background.common.log.Logger;
-import org.mozilla.gecko.sync.Server11PreviousPostFailedException;
import org.mozilla.gecko.sync.Utils;
+import org.mozilla.gecko.sync.Server15PreviousPostFailedException;
import org.mozilla.gecko.sync.net.SyncStorageRequest;
import org.mozilla.gecko.sync.net.SyncStorageRequestDelegate;
import java.io.IOException;
import java.io.OutputStream;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.ArrayList;
@@ -131,17 +131,17 @@ public class RecordUploadRunnable implem
return true;
}
}
@Override
public void run() {
if (!mayUploadProvider.mayUpload()) {
Logger.info(LOG_TAG, "Told not to proceed by the uploader. Cancelling upload, failing records.");
- uploadDelegate.handleRequestError(new Server11PreviousPostFailedException());
+ uploadDelegate.handleRequestError(new Server15PreviousPostFailedException());
return;
}
Logger.trace(LOG_TAG, "Running upload task. Outgoing records: " + outgoing.size());
// We don't want the task queue to proceed until this request completes.
// Fortunately, BaseResource is currently synchronous.
// If that ever changes, you'll need to block here.
--- a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/stage/AndroidBrowserBookmarksServerSyncStage.java
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/stage/AndroidBrowserBookmarksServerSyncStage.java
@@ -4,17 +4,17 @@
package org.mozilla.gecko.sync.stage;
import java.net.URISyntaxException;
import org.mozilla.gecko.sync.MetaGlobalException;
import org.mozilla.gecko.sync.middleware.BufferingMiddlewareRepository;
import org.mozilla.gecko.sync.middleware.storage.MemoryBufferStorage;
-import org.mozilla.gecko.sync.repositories.ConstrainedServer11Repository;
+import org.mozilla.gecko.sync.repositories.ConfigurableServer15Repository;
import org.mozilla.gecko.sync.repositories.RecordFactory;
import org.mozilla.gecko.sync.repositories.Repository;
import org.mozilla.gecko.sync.repositories.android.AndroidBrowserBookmarksRepository;
import org.mozilla.gecko.sync.repositories.domain.BookmarkRecordFactory;
import org.mozilla.gecko.sync.repositories.domain.VersionConstants;
public class AndroidBrowserBookmarksServerSyncStage extends ServerSyncStage {
protected static final String LOG_TAG = "BookmarksStage";
@@ -36,17 +36,17 @@ public class AndroidBrowserBookmarksServ
@Override
public Integer getStorageVersion() {
return VersionConstants.BOOKMARKS_ENGINE_VERSION;
}
@Override
protected Repository getRemoteRepository() throws URISyntaxException {
- return new ConstrainedServer11Repository(
+ return new ConfigurableServer15Repository(
getCollection(),
session.getSyncDeadline(),
session.config.storageURL(),
session.getAuthHeaderProvider(),
session.config.infoCollections,
session.config.infoConfiguration,
BOOKMARKS_BATCH_LIMIT,
BOOKMARKS_SORT,
--- a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/stage/AndroidBrowserHistoryServerSyncStage.java
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/stage/AndroidBrowserHistoryServerSyncStage.java
@@ -2,17 +2,17 @@
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
package org.mozilla.gecko.sync.stage;
import java.net.URISyntaxException;
import org.mozilla.gecko.sync.MetaGlobalException;
-import org.mozilla.gecko.sync.repositories.ConstrainedServer11Repository;
+import org.mozilla.gecko.sync.repositories.ConfigurableServer15Repository;
import org.mozilla.gecko.sync.repositories.RecordFactory;
import org.mozilla.gecko.sync.repositories.Repository;
import org.mozilla.gecko.sync.repositories.android.AndroidBrowserHistoryRepository;
import org.mozilla.gecko.sync.repositories.domain.HistoryRecordFactory;
import org.mozilla.gecko.sync.repositories.domain.VersionConstants;
public class AndroidBrowserHistoryServerSyncStage extends ServerSyncStage {
protected static final String LOG_TAG = "HistoryStage";
@@ -39,17 +39,17 @@ public class AndroidBrowserHistoryServer
@Override
protected Repository getLocalRepository() {
return new AndroidBrowserHistoryRepository();
}
@Override
protected Repository getRemoteRepository() throws URISyntaxException {
- return new ConstrainedServer11Repository(
+ return new ConfigurableServer15Repository(
getCollection(),
session.getSyncDeadline(),
session.config.storageURL(),
session.getAuthHeaderProvider(),
session.config.infoCollections,
session.config.infoConfiguration,
HISTORY_BATCH_LIMIT,
HISTORY_SORT,
--- a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/stage/AndroidBrowserRecentHistoryServerSyncStage.java
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/stage/AndroidBrowserRecentHistoryServerSyncStage.java
@@ -4,17 +4,17 @@
package org.mozilla.gecko.sync.stage;
import org.mozilla.gecko.sync.MetaGlobalException;
import org.mozilla.gecko.sync.NonObjectJSONException;
import org.mozilla.gecko.sync.SynchronizerConfiguration;
import org.mozilla.gecko.sync.middleware.BufferingMiddlewareRepository;
import org.mozilla.gecko.sync.middleware.storage.MemoryBufferStorage;
-import org.mozilla.gecko.sync.repositories.ConstrainedServer11Repository;
+import org.mozilla.gecko.sync.repositories.ConfigurableServer15Repository;
import org.mozilla.gecko.sync.repositories.Repository;
import org.mozilla.gecko.sync.repositories.android.AndroidBrowserHistoryRepository;
import java.io.IOException;
import java.net.URISyntaxException;
/**
* History sync stage which is limited to just recent history, and will only run if the full history
@@ -45,17 +45,17 @@ public class AndroidBrowserRecentHistory
session.getSyncDeadline(),
new MemoryBufferStorage(),
new AndroidBrowserHistoryRepository()
);
}
@Override
protected Repository getRemoteRepository() throws URISyntaxException {
- return new ConstrainedServer11Repository(
+ return new ConfigurableServer15Repository(
getCollection(),
session.getSyncDeadline(),
session.config.storageURL(),
session.getAuthHeaderProvider(),
session.config.infoCollections,
session.config.infoConfiguration,
HISTORY_BATCH_LIMIT,
HISTORY_SORT,
--- a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/stage/FormHistoryServerSyncStage.java
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/stage/FormHistoryServerSyncStage.java
@@ -4,17 +4,17 @@
package org.mozilla.gecko.sync.stage;
import java.net.URISyntaxException;
import org.mozilla.gecko.sync.CryptoRecord;
import org.mozilla.gecko.sync.middleware.BufferingMiddlewareRepository;
import org.mozilla.gecko.sync.middleware.storage.MemoryBufferStorage;
-import org.mozilla.gecko.sync.repositories.ConstrainedServer11Repository;
+import org.mozilla.gecko.sync.repositories.ConfigurableServer15Repository;
import org.mozilla.gecko.sync.repositories.RecordFactory;
import org.mozilla.gecko.sync.repositories.Repository;
import org.mozilla.gecko.sync.repositories.android.FormHistoryRepositorySession;
import org.mozilla.gecko.sync.repositories.domain.FormHistoryRecord;
import org.mozilla.gecko.sync.repositories.domain.Record;
import org.mozilla.gecko.sync.repositories.domain.VersionConstants;
public class FormHistoryServerSyncStage extends ServerSyncStage {
@@ -37,17 +37,17 @@ public class FormHistoryServerSyncStage
@Override
public Integer getStorageVersion() {
return VersionConstants.FORMS_ENGINE_VERSION;
}
@Override
protected Repository getRemoteRepository() throws URISyntaxException {
String collection = getCollection();
- return new ConstrainedServer11Repository(
+ return new ConfigurableServer15Repository(
collection,
session.getSyncDeadline(),
session.config.storageURL(),
session.getAuthHeaderProvider(),
session.config.infoCollections,
session.config.infoConfiguration,
FORM_HISTORY_BATCH_LIMIT,
FORM_HISTORY_SORT,
--- a/mobile/android/services/src/main/java/org/mozilla/gecko/sync/stage/ServerSyncStage.java
+++ b/mobile/android/services/src/main/java/org/mozilla/gecko/sync/stage/ServerSyncStage.java
@@ -25,17 +25,17 @@ import org.mozilla.gecko.sync.net.SyncSt
import org.mozilla.gecko.sync.net.SyncStorageRequestDelegate;
import org.mozilla.gecko.sync.net.SyncStorageResponse;
import org.mozilla.gecko.sync.repositories.InactiveSessionException;
import org.mozilla.gecko.sync.repositories.InvalidSessionTransitionException;
import org.mozilla.gecko.sync.repositories.RecordFactory;
import org.mozilla.gecko.sync.repositories.Repository;
import org.mozilla.gecko.sync.repositories.RepositorySession;
import org.mozilla.gecko.sync.repositories.RepositorySessionBundle;
-import org.mozilla.gecko.sync.repositories.Server11Repository;
+import org.mozilla.gecko.sync.repositories.Server15Repository;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionBeginDelegate;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionCreationDelegate;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionFinishDelegate;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionWipeDelegate;
import org.mozilla.gecko.sync.synchronizer.ServerLocalSynchronizer;
import org.mozilla.gecko.sync.synchronizer.Synchronizer;
import org.mozilla.gecko.sync.synchronizer.SynchronizerDelegate;
import org.mozilla.gecko.sync.synchronizer.SynchronizerSession;
@@ -138,26 +138,26 @@ public abstract class ServerSyncStage ex
protected abstract String getCollection();
protected abstract String getEngineName();
protected abstract Repository getLocalRepository();
protected abstract RecordFactory getRecordFactory();
// Override this in subclasses.
protected Repository getRemoteRepository() throws URISyntaxException {
String collection = getCollection();
- return new Server11Repository(collection,
+ return new Server15Repository(collection,
session.getSyncDeadline(),
session.config.storageURL(),
session.getAuthHeaderProvider(),
session.config.infoCollections,
session.config.infoConfiguration);
}
/**
- * Return a Crypto5Middleware-wrapped Server11Repository.
+ * Return a Crypto5Middleware-wrapped Server15Repository.
*
* @throws NoCollectionKeysSetException
* @throws URISyntaxException
*/
protected Repository wrappedServerRepo() throws NoCollectionKeysSetException, URISyntaxException {
String collection = this.getCollection();
KeyBundle collectionKey = session.keyBundleForCollection(collection);
Crypto5MiddlewareRepository cryptoRepo = new Crypto5MiddlewareRepository(getRemoteRepository(), collectionKey);
rename from mobile/android/tests/background/junit4/src/org/mozilla/android/sync/net/test/TestServer11Repository.java
rename to mobile/android/tests/background/junit4/src/org/mozilla/android/sync/net/test/TestServer15Repository.java
--- a/mobile/android/tests/background/junit4/src/org/mozilla/android/sync/net/test/TestServer11Repository.java
+++ b/mobile/android/tests/background/junit4/src/org/mozilla/android/sync/net/test/TestServer15Repository.java
@@ -6,36 +6,36 @@ package org.mozilla.android.sync.net.tes
import android.os.SystemClock;
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mozilla.gecko.background.testhelpers.TestRunner;
import org.mozilla.gecko.sync.InfoCollections;
import org.mozilla.gecko.sync.InfoConfiguration;
-import org.mozilla.gecko.sync.repositories.Server11Repository;
+import org.mozilla.gecko.sync.repositories.Server15Repository;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.concurrent.TimeUnit;
@RunWith(TestRunner.class)
-public class TestServer11Repository {
+public class TestServer15Repository {
private static final String COLLECTION = "bookmarks";
private static final String COLLECTION_URL = "http://foo.com/1.5/n6ec3u5bee3tixzp2asys7bs6fve4jfw/storage";
private static final long SYNC_DEADLINE = SystemClock.elapsedRealtime() + TimeUnit.MINUTES.toMillis(30);
protected final InfoCollections infoCollections = new InfoCollections();
protected final InfoConfiguration infoConfiguration = new InfoConfiguration();
public static void assertQueryEquals(String expected, URI u) {
Assert.assertEquals(expected, u.getRawQuery());
}
@Test
public void testCollectionURI() throws URISyntaxException {
- Server11Repository noTrailingSlash = new Server11Repository(COLLECTION, SYNC_DEADLINE, COLLECTION_URL, null, infoCollections, infoConfiguration);
- Server11Repository trailingSlash = new Server11Repository(COLLECTION, SYNC_DEADLINE, COLLECTION_URL + "/", null, infoCollections, infoConfiguration);
+ Server15Repository noTrailingSlash = new Server15Repository(COLLECTION, SYNC_DEADLINE, COLLECTION_URL, null, infoCollections, infoConfiguration);
+ Server15Repository trailingSlash = new Server15Repository(COLLECTION, SYNC_DEADLINE, COLLECTION_URL + "/", null, infoCollections, infoConfiguration);
Assert.assertEquals("http://foo.com/1.5/n6ec3u5bee3tixzp2asys7bs6fve4jfw/storage/bookmarks", noTrailingSlash.collectionURI().toASCIIString());
Assert.assertEquals("http://foo.com/1.5/n6ec3u5bee3tixzp2asys7bs6fve4jfw/storage/bookmarks", trailingSlash.collectionURI().toASCIIString());
}
}
rename from mobile/android/tests/background/junit4/src/org/mozilla/android/sync/test/TestServer11RepositorySession.java
rename to mobile/android/tests/background/junit4/src/org/mozilla/android/sync/test/TestServer15RepositorySession.java
--- a/mobile/android/tests/background/junit4/src/org/mozilla/android/sync/test/TestServer11RepositorySession.java
+++ b/mobile/android/tests/background/junit4/src/org/mozilla/android/sync/test/TestServer15RepositorySession.java
@@ -17,17 +17,17 @@ import org.mozilla.gecko.sync.InfoConfig
import org.mozilla.gecko.sync.Utils;
import org.mozilla.gecko.sync.crypto.KeyBundle;
import org.mozilla.gecko.sync.middleware.Crypto5MiddlewareRepository;
import org.mozilla.gecko.sync.net.AuthHeaderProvider;
import org.mozilla.gecko.sync.net.BaseResource;
import org.mozilla.gecko.sync.net.BasicAuthHeaderProvider;
import org.mozilla.gecko.sync.net.SyncStorageResponse;
import org.mozilla.gecko.sync.repositories.FetchFailedException;
-import org.mozilla.gecko.sync.repositories.Server11Repository;
+import org.mozilla.gecko.sync.repositories.Server15Repository;
import org.mozilla.gecko.sync.repositories.StoreFailedException;
import org.mozilla.gecko.sync.repositories.domain.BookmarkRecord;
import org.mozilla.gecko.sync.repositories.domain.BookmarkRecordFactory;
import org.mozilla.gecko.sync.synchronizer.ServerLocalSynchronizer;
import org.mozilla.gecko.sync.synchronizer.Synchronizer;
import org.simpleframework.http.ContentType;
import org.simpleframework.http.Request;
import org.simpleframework.http.Response;
@@ -35,17 +35,17 @@ import org.simpleframework.http.Response
import java.io.IOException;
import java.util.concurrent.TimeUnit;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
@RunWith(TestRunner.class)
-public class TestServer11RepositorySession {
+public class TestServer15RepositorySession {
public class POSTMockServer extends MockServer {
@Override
public void handle(Request request, Response response) {
try {
String content = request.getContent();
System.out.println("Content:" + content);
} catch (IOException e) {
@@ -105,17 +105,17 @@ public class TestServer11RepositorySessi
}
return local;
}
protected Exception doSynchronize(MockServer server) throws Exception {
final String COLLECTION = "test";
final TrackingWBORepository local = getLocal(100);
- final Server11Repository remote = new Server11Repository(
+ final Server15Repository remote = new Server15Repository(
COLLECTION, SystemClock.elapsedRealtime() + TimeUnit.MINUTES.toMillis(30),
getCollectionURL(COLLECTION), authHeaderProvider, infoCollections, infoConfiguration);
KeyBundle collectionKey = new KeyBundle(TEST_USERNAME, SYNC_KEY);
Crypto5MiddlewareRepository cryptoRepo = new Crypto5MiddlewareRepository(remote, collectionKey);
cryptoRepo.recordFactory = new BookmarkRecordFactory();
final Synchronizer synchronizer = new ServerLocalSynchronizer();
synchronizer.repositoryA = cryptoRepo;
--- a/mobile/android/tests/background/junit4/src/org/mozilla/gecko/sync/repositories/downloaders/BatchingDownloaderDelegateTest.java
+++ b/mobile/android/tests/background/junit4/src/org/mozilla/gecko/sync/repositories/downloaders/BatchingDownloaderDelegateTest.java
@@ -14,35 +14,35 @@ import org.mozilla.gecko.background.test
import org.mozilla.gecko.sync.CryptoRecord;
import org.mozilla.gecko.sync.HTTPFailureException;
import org.mozilla.gecko.sync.InfoCollections;
import org.mozilla.gecko.sync.InfoConfiguration;
import org.mozilla.gecko.sync.net.SyncResponse;
import org.mozilla.gecko.sync.net.SyncStorageCollectionRequest;
import org.mozilla.gecko.sync.net.SyncStorageResponse;
import org.mozilla.gecko.sync.repositories.RepositorySession;
-import org.mozilla.gecko.sync.repositories.Server11RepositorySession;
-import org.mozilla.gecko.sync.repositories.Server11Repository;
+import org.mozilla.gecko.sync.repositories.Server15RepositorySession;
+import org.mozilla.gecko.sync.repositories.Server15Repository;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionFetchRecordsDelegate;
import org.mozilla.gecko.sync.repositories.domain.Record;
import java.net.URI;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.TimeUnit;
import ch.boye.httpclientandroidlib.ProtocolVersion;
import ch.boye.httpclientandroidlib.client.ClientProtocolException;
import ch.boye.httpclientandroidlib.message.BasicHttpResponse;
import ch.boye.httpclientandroidlib.message.BasicStatusLine;
import static org.junit.Assert.*;
@RunWith(TestRunner.class)
public class BatchingDownloaderDelegateTest {
- private Server11RepositorySession repositorySession;
+ private Server15RepositorySession repositorySession;
private MockDownloader mockDownloader;
private String DEFAULT_COLLECTION_URL = "http://dummy.url/";
class MockDownloader extends BatchingDownloader {
public boolean isSuccess = false;
public boolean isFetched = false;
public boolean isFailure = false;
public Exception ex;
@@ -104,17 +104,17 @@ public class BatchingDownloaderDelegateT
@Override
public RepositorySessionFetchRecordsDelegate deferredFetchDelegate(ExecutorService executor) {
return null;
}
}
@Before
public void setUp() throws Exception {
- repositorySession = new Server11RepositorySession(new Server11Repository(
+ repositorySession = new Server15RepositorySession(new Server15Repository(
"dummyCollection",
SystemClock.elapsedRealtime() + TimeUnit.MINUTES.toMillis(30),
DEFAULT_COLLECTION_URL,
null,
new InfoCollections(),
new InfoConfiguration())
);
mockDownloader = new MockDownloader(repositorySession);
--- a/mobile/android/tests/background/junit4/src/org/mozilla/gecko/sync/repositories/downloaders/BatchingDownloaderTest.java
+++ b/mobile/android/tests/background/junit4/src/org/mozilla/gecko/sync/repositories/downloaders/BatchingDownloaderTest.java
@@ -15,18 +15,18 @@ import org.mozilla.gecko.background.test
import org.mozilla.gecko.sync.CryptoRecord;
import org.mozilla.gecko.sync.InfoCollections;
import org.mozilla.gecko.sync.InfoConfiguration;
import org.mozilla.gecko.sync.net.AuthHeaderProvider;
import org.mozilla.gecko.sync.net.SyncResponse;
import org.mozilla.gecko.sync.net.SyncStorageCollectionRequest;
import org.mozilla.gecko.sync.net.SyncStorageResponse;
import org.mozilla.gecko.sync.repositories.RepositorySession;
-import org.mozilla.gecko.sync.repositories.Server11Repository;
-import org.mozilla.gecko.sync.repositories.Server11RepositorySession;
+import org.mozilla.gecko.sync.repositories.Server15Repository;
+import org.mozilla.gecko.sync.repositories.Server15RepositorySession;
import org.mozilla.gecko.sync.repositories.Repository;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionFetchRecordsDelegate;
import org.mozilla.gecko.sync.repositories.domain.Record;
import java.io.UnsupportedEncodingException;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.concurrent.ExecutorService;
@@ -36,18 +36,18 @@ import ch.boye.httpclientandroidlib.Prot
import ch.boye.httpclientandroidlib.message.BasicHttpResponse;
import ch.boye.httpclientandroidlib.message.BasicStatusLine;
import static org.junit.Assert.*;
import static org.junit.Assert.assertEquals;
@RunWith(TestRunner.class)
public class BatchingDownloaderTest {
- private MockSever11Repository serverRepository;
- private Server11RepositorySession repositorySession;
+ private MockSever15Repository serverRepository;
+ private Server15RepositorySession repositorySession;
private MockSessionFetchRecordsDelegate sessionFetchRecordsDelegate;
private MockDownloader mockDownloader;
private String DEFAULT_COLLECTION_NAME = "dummyCollection";
private String DEFAULT_COLLECTION_URL = "http://dummy.url/";
private long DEFAULT_NEWER = 1;
private String DEFAULT_SORT = "oldest";
private String DEFAULT_IDS = "1";
private String DEFAULT_LMHEADER = "12345678";
@@ -144,44 +144,44 @@ public class BatchingDownloaderTest {
String ids,
String offset)
throws URISyntaxException, UnsupportedEncodingException {
this.offset = offset;
return super.makeSyncStorageCollectionRequest(newer, batchLimit, full, sort, ids, offset);
}
}
- class MockSever11Repository extends Server11Repository {
- public MockSever11Repository(@NonNull String collection, @NonNull String storageURL,
+ class MockSever15Repository extends Server15Repository {
+ public MockSever15Repository(@NonNull String collection, @NonNull String storageURL,
AuthHeaderProvider authHeaderProvider, @NonNull InfoCollections infoCollections,
@NonNull InfoConfiguration infoConfiguration) throws URISyntaxException {
super(collection, SystemClock.elapsedRealtime() + TimeUnit.MINUTES.toMillis(30), storageURL, authHeaderProvider, infoCollections, infoConfiguration);
}
}
- class MockRepositorySession extends Server11RepositorySession {
+ class MockRepositorySession extends Server15RepositorySession {
public boolean abort;
public MockRepositorySession(Repository repository) {
super(repository);
}
@Override
public void abort() {
this.abort = true;
}
}
@Before
public void setUp() throws Exception {
sessionFetchRecordsDelegate = new MockSessionFetchRecordsDelegate();
- serverRepository = new MockSever11Repository(DEFAULT_COLLECTION_NAME, DEFAULT_COLLECTION_URL, null,
+ serverRepository = new MockSever15Repository(DEFAULT_COLLECTION_NAME, DEFAULT_COLLECTION_URL, null,
new InfoCollections(), new InfoConfiguration());
- repositorySession = new Server11RepositorySession(serverRepository);
+ repositorySession = new Server15RepositorySession(serverRepository);
mockDownloader = new MockDownloader(repositorySession, true);
}
@Test
public void testFlattenId() {
String[] emptyGuid = new String[]{};
String flatten = BatchingDownloader.flattenIDs(emptyGuid);
assertEquals("", flatten);
--- a/mobile/android/tests/background/junit4/src/org/mozilla/gecko/sync/repositories/uploaders/BatchingUploaderTest.java
+++ b/mobile/android/tests/background/junit4/src/org/mozilla/gecko/sync/repositories/uploaders/BatchingUploaderTest.java
@@ -13,18 +13,18 @@ import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mozilla.gecko.background.testhelpers.MockRecord;
import org.mozilla.gecko.background.testhelpers.TestRunner;
import org.mozilla.gecko.sync.ExtendedJSONObject;
import org.mozilla.gecko.sync.InfoCollections;
import org.mozilla.gecko.sync.InfoConfiguration;
import org.mozilla.gecko.sync.Utils;
-import org.mozilla.gecko.sync.repositories.Server11Repository;
-import org.mozilla.gecko.sync.repositories.Server11RepositorySession;
+import org.mozilla.gecko.sync.repositories.Server15Repository;
+import org.mozilla.gecko.sync.repositories.Server15RepositorySession;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionStoreDelegate;
import java.net.URISyntaxException;
import java.util.Random;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.TimeUnit;
@@ -433,30 +433,30 @@ public class BatchingUploaderTest {
private BatchingUploader makeConstrainedUploader(long maxPostRecords, long maxTotalRecords, boolean firstSync) {
ExtendedJSONObject infoConfigurationJSON = new ExtendedJSONObject();
infoConfigurationJSON.put(InfoConfiguration.MAX_TOTAL_BYTES, 4096L);
infoConfigurationJSON.put(InfoConfiguration.MAX_TOTAL_RECORDS, maxTotalRecords);
infoConfigurationJSON.put(InfoConfiguration.MAX_POST_RECORDS, maxPostRecords);
infoConfigurationJSON.put(InfoConfiguration.MAX_POST_BYTES, 1024L);
infoConfigurationJSON.put(InfoConfiguration.MAX_REQUEST_BYTES, 1024L);
- Server11RepositorySession server11RepositorySession = new Server11RepositorySession(
+ Server15RepositorySession server15RepositorySession = new Server15RepositorySession(
makeCountConstrainedRepository(maxPostRecords, maxTotalRecords, firstSync)
);
- server11RepositorySession.setStoreDelegate(storeDelegate);
+ server15RepositorySession.setStoreDelegate(storeDelegate);
return new BatchingUploader(
- server11RepositorySession, workQueue, storeDelegate, Uri.EMPTY, null,
+ server15RepositorySession, workQueue, storeDelegate, Uri.EMPTY, null,
new InfoConfiguration(infoConfigurationJSON), null);
}
- private Server11Repository makeCountConstrainedRepository(long maxPostRecords, long maxTotalRecords, boolean firstSync) {
+ private Server15Repository makeCountConstrainedRepository(long maxPostRecords, long maxTotalRecords, boolean firstSync) {
return makeConstrainedRepository(1024, 1024, maxPostRecords, 4096, maxTotalRecords, firstSync);
}
- private Server11Repository makeConstrainedRepository(long maxRequestBytes, long maxPostBytes, long maxPostRecords, long maxTotalBytes, long maxTotalRecords, boolean firstSync) {
+ private Server15Repository makeConstrainedRepository(long maxRequestBytes, long maxPostBytes, long maxPostRecords, long maxTotalBytes, long maxTotalRecords, boolean firstSync) {
ExtendedJSONObject infoConfigurationJSON = new ExtendedJSONObject();
infoConfigurationJSON.put(InfoConfiguration.MAX_TOTAL_BYTES, maxTotalBytes);
infoConfigurationJSON.put(InfoConfiguration.MAX_TOTAL_RECORDS, maxTotalRecords);
infoConfigurationJSON.put(InfoConfiguration.MAX_POST_RECORDS, maxPostRecords);
infoConfigurationJSON.put(InfoConfiguration.MAX_POST_BYTES, maxPostBytes);
infoConfigurationJSON.put(InfoConfiguration.MAX_REQUEST_BYTES, maxRequestBytes);
InfoConfiguration infoConfiguration = new InfoConfiguration(infoConfigurationJSON);
@@ -473,19 +473,18 @@ public class BatchingUploaderTest {
infoCollections = new InfoCollections() {
@Override
public Long getTimestamp(String collection) {
return 0L;
}
};
}
-
try {
- return new Server11Repository(
+ return new Server15Repository(
"dummyCollection",
SystemClock.elapsedRealtime() + TimeUnit.MINUTES.toMillis(30),
"http://dummy.url/",
null,
infoCollections,
infoConfiguration
);
} catch (URISyntaxException e) {