Remove some fxa tests.

Tag #812

4 files changed, 0 insertions, 457 deletions

diff --git a/services/sync/tests/unit/test_fxa_node_reassignment.js b/services/sync/tests/unit/test_fxa_node_reassignment.js
deleted file mode 100644
index 2f61afd6fb..0000000000
--- a/services/sync/tests/unit/test_fxa_node_reassignment.js
+++ /dev/null
@@ -1,321 +0,0 @@
-/* Any copyright is dedicated to the Public Domain.

-   http://creativecommons.org/publicdomain/zero/1.0/ */

-

-_("Test that node reassignment happens correctly using the FxA identity mgr.");

-// The node-reassignment logic is quite different for FxA than for the legacy

-// provider.  In particular, there's no special request necessary for

-// reassignment - it comes from the token server - so we need to ensure the

-// Fxa cluster manager grabs a new token.

-

-Cu.import("resource://gre/modules/Log.jsm");

-Cu.import("resource://services-common/rest.js");

-Cu.import("resource://services-sync/constants.js");

-Cu.import("resource://services-sync/service.js");

-Cu.import("resource://services-sync/status.js");

-Cu.import("resource://services-sync/util.js");

-Cu.import("resource://testing-common/services/sync/rotaryengine.js");

-Cu.import("resource://services-sync/browserid_identity.js");

-Cu.import("resource://testing-common/services/sync/utils.js");

-

-Service.engineManager.clear();

-

-function run_test() {

-  Log.repository.getLogger("Sync.AsyncResource").level = Log.Level.Trace;

-  Log.repository.getLogger("Sync.ErrorHandler").level  = Log.Level.Trace;

-  Log.repository.getLogger("Sync.Resource").level      = Log.Level.Trace;

-  Log.repository.getLogger("Sync.RESTRequest").level   = Log.Level.Trace;

-  Log.repository.getLogger("Sync.Service").level       = Log.Level.Trace;

-  Log.repository.getLogger("Sync.SyncScheduler").level = Log.Level.Trace;

-  initTestLogging();

-

-  Service.engineManager.register(RotaryEngine);

-

-  // Setup the FxA identity manager and cluster manager.

-  Status.__authManager = Service.identity = new BrowserIDManager();

-  Service._clusterManager = Service.identity.createClusterManager(Service);

-

-  // None of the failures in this file should result in a UI error.

-  function onUIError() {

-    do_throw("Errors should not be presented in the UI.");

-  }

-  Svc.Obs.add("weave:ui:login:error", onUIError);

-  Svc.Obs.add("weave:ui:sync:error", onUIError);

-

-  run_next_test();

-}

-

-

-// API-compatible with SyncServer handler. Bind `handler` to something to use

-// as a ServerCollection handler.

-function handleReassign(handler, req, resp) {

-  resp.setStatusLine(req.httpVersion, 401, "Node reassignment");

-  resp.setHeader("Content-Type", "application/json");

-  let reassignBody = JSON.stringify({error: "401inator in place"});

-  resp.bodyOutputStream.write(reassignBody, reassignBody.length);

-}

-

-let numTokenRequests = 0;

-

-function prepareServer(cbAfterTokenFetch) {

-  let config = makeIdentityConfig({username: "johndoe"});

-  let server = new SyncServer();

-  server.registerUser("johndoe");

-  server.start();

-

-  // Set the token endpoint for the initial token request that's done implicitly

-  // via configureIdentity.

-  config.fxaccount.token.endpoint = server.baseURI + "1.1/johndoe";

-  // And future token fetches will do magic around numReassigns.

-  let numReassigns = 0;

-  return configureIdentity(config).then(() => {

-    Service.identity._tokenServerClient = {

-      getTokenFromBrowserIDAssertion: function(uri, assertion, cb) {

-        // Build a new URL with trailing zeros for the SYNC_VERSION part - this

-        // will still be seen as equivalent by the test server, but different

-        // by sync itself.

-        numReassigns += 1;

-        let trailingZeros = new Array(numReassigns + 1).join('0');

-        let token = config.fxaccount.token;

-        token.endpoint = server.baseURI + "1.1" + trailingZeros + "/johndoe";

-        token.uid = config.username;

-        numTokenRequests += 1;

-        cb(null, token);

-        if (cbAfterTokenFetch) {

-          cbAfterTokenFetch();

-        }

-      },

-    };

-    Service.clusterURL = config.fxaccount.token.endpoint;

-    return server;

-  });

-}

-

-function getReassigned() {

-  try {

-    return Services.prefs.getBoolPref("services.sync.lastSyncReassigned");

-  } catch (ex if (ex.result == Cr.NS_ERROR_UNEXPECTED)) {

-    return false;

-  } catch (ex) {

-    do_throw("Got exception retrieving lastSyncReassigned: " +

-             Utils.exceptionStr(ex));

-  }

-}

-

-/**

- * Make a test request to `url`, then watch the result of two syncs

- * to ensure that a node request was made.

- * Runs `between` between the two. This can be used to undo deliberate failure

- * setup, detach observers, etc.

- */

-function syncAndExpectNodeReassignment(server, firstNotification, between,

-                                       secondNotification, url) {

-  _("Starting syncAndExpectNodeReassignment\n");

-  let deferred = Promise.defer();

-  function onwards() {

-    let numTokenRequestsBefore;

-    function onFirstSync() {

-      _("First sync completed.");

-      Svc.Obs.remove(firstNotification, onFirstSync);

-      Svc.Obs.add(secondNotification, onSecondSync);

-

-      do_check_eq(Service.clusterURL, "");

-

-      // Track whether we fetched a new token.

-      numTokenRequestsBefore = numTokenRequests;

-

-      // Allow for tests to clean up error conditions.

-      between();

-    }

-    function onSecondSync() {

-      _("Second sync completed.");

-      Svc.Obs.remove(secondNotification, onSecondSync);

-      Service.scheduler.clearSyncTriggers();

-

-      // Make absolutely sure that any event listeners are done with their work

-      // before we proceed.

-      waitForZeroTimer(function () {

-        _("Second sync nextTick.");

-        do_check_eq(numTokenRequests, numTokenRequestsBefore + 1, "fetched a new token");

-        Service.startOver();

-        server.stop(deferred.resolve);

-      });

-    }

-

-    Svc.Obs.add(firstNotification, onFirstSync);

-    Service.sync();

-  }

-

-  // Make sure that it works!

-  _("Making request to " + url + " which should 401");

-  let request = new RESTRequest(url);

-  request.get(function () {

-    do_check_eq(request.response.status, 401);

-    Utils.nextTick(onwards);

-  });

-  yield deferred.promise;

-}

-

-add_task(function test_momentary_401_engine() {

-  _("Test a failure for engine URLs that's resolved by reassignment.");

-  let server = yield prepareServer();

-  let john   = server.user("johndoe");

-

-  _("Enabling the Rotary engine.");

-  let engine = Service.engineManager.get("rotary");

-  engine.enabled = true;

-

-  // We need the server to be correctly set up prior to experimenting. Do this

-  // through a sync.

-  let global = {syncID: Service.syncID,

-                storageVersion: STORAGE_VERSION,

-                rotary: {version: engine.version,

-                         syncID:  engine.syncID}}

-  john.createCollection("meta").insert("global", global);

-

-  _("First sync to prepare server contents.");

-  Service.sync();

-

-  _("Setting up Rotary collection to 401.");

-  let rotary = john.createCollection("rotary");

-  let oldHandler = rotary.collectionHandler;

-  rotary.collectionHandler = handleReassign.bind(this, undefined);

-

-  // We want to verify that the clusterURL pref has been cleared after a 401

-  // inside a sync. Flag the Rotary engine to need syncing.

-  john.collection("rotary").timestamp += 1000;

-

-  function between() {

-    _("Undoing test changes.");

-    rotary.collectionHandler = oldHandler;

-

-    function onLoginStart() {

-      // lastSyncReassigned shouldn't be cleared until a sync has succeeded.

-      _("Ensuring that lastSyncReassigned is still set at next sync start.");

-      Svc.Obs.remove("weave:service:login:start", onLoginStart);

-      do_check_true(getReassigned());

-    }

-

-    _("Adding observer that lastSyncReassigned is still set on login.");

-    Svc.Obs.add("weave:service:login:start", onLoginStart);

-  }

-

-  yield syncAndExpectNodeReassignment(server,

-                                      "weave:service:sync:finish",

-                                      between,

-                                      "weave:service:sync:finish",

-                                      Service.storageURL + "rotary");

-});

-

-// This test ends up being a failing info fetch *after we're already logged in*.

-add_task(function test_momentary_401_info_collections_loggedin() {

-  _("Test a failure for info/collections after login that's resolved by reassignment.");

-  let server = yield prepareServer();

-

-  _("First sync to prepare server contents.");

-  Service.sync();

-

-  _("Arrange for info/collections to return a 401.");

-  let oldHandler = server.toplevelHandlers.info;

-  server.toplevelHandlers.info = handleReassign;

-

-  function undo() {

-    _("Undoing test changes.");

-    server.toplevelHandlers.info = oldHandler;

-  }

-

-  do_check_true(Service.isLoggedIn, "already logged in");

-

-  yield syncAndExpectNodeReassignment(server,

-                                      "weave:service:sync:error",

-                                      undo,

-                                      "weave:service:sync:finish",

-                                      Service.infoURL);

-});

-

-// This test ends up being a failing info fetch *before we're logged in*.

-// In this case we expect to recover during the login phase - so the first

-// sync succeeds.

-add_task(function test_momentary_401_info_collections_loggedout() {

-  _("Test a failure for info/collections before login that's resolved by reassignment.");

-

-  let oldHandler;

-  let sawTokenFetch = false;

-

-  function afterTokenFetch() {

-    // After a single token fetch, we undo our evil handleReassign hack, so

-    // the next /info request returns the collection instead of a 401

-    server.toplevelHandlers.info = oldHandler;

-    sawTokenFetch = true;

-  }

-

-  let server = yield prepareServer(afterTokenFetch);

-

-  // Return a 401 for the next /info request - it will be reset immediately

-  // after a new token is fetched.

-  oldHandler = server.toplevelHandlers.info

-  server.toplevelHandlers.info = handleReassign;

-

-  do_check_false(Service.isLoggedIn, "not already logged in");

-

-  Service.sync();

-  do_check_eq(Status.sync, SYNC_SUCCEEDED, "sync succeeded");

-  // sync was successful - check we grabbed a new token.

-  do_check_true(sawTokenFetch, "a new token was fetched by this test.")

-  // and we are done.

-  Service.startOver();

-  let deferred = Promise.defer();

-  server.stop(deferred.resolve);

-  yield deferred.promise;

-});

-

-// This test ends up being a failing meta/global fetch *after we're already logged in*.

-add_task(function test_momentary_401_storage_loggedin() {

-  _("Test a failure for any storage URL after login that's resolved by" +

-    "reassignment.");

-  let server = yield prepareServer();

-

-  _("First sync to prepare server contents.");

-  Service.sync();

-

-  _("Arrange for meta/global to return a 401.");

-  let oldHandler = server.toplevelHandlers.storage;

-  server.toplevelHandlers.storage = handleReassign;

-

-  function undo() {

-    _("Undoing test changes.");

-    server.toplevelHandlers.storage = oldHandler;

-  }

-

-  do_check_true(Service.isLoggedIn, "already logged in");

-

-  yield syncAndExpectNodeReassignment(server,

-                                      "weave:service:sync:error",

-                                      undo,

-                                      "weave:service:sync:finish",

-                                      Service.storageURL + "meta/global");

-});

-

-// This test ends up being a failing meta/global fetch *before we've logged in*.

-add_task(function test_momentary_401_storage_loggedout() {

-  _("Test a failure for any storage URL before login, not just engine parts. " +

-    "Resolved by reassignment.");

-  let server = yield prepareServer();

-

-  // Return a 401 for all storage requests.

-  let oldHandler = server.toplevelHandlers.storage;

-  server.toplevelHandlers.storage = handleReassign;

-

-  function undo() {

-    _("Undoing test changes.");

-    server.toplevelHandlers.storage = oldHandler;

-  }

-

-  do_check_false(Service.isLoggedIn, "already logged in");

-

-  yield syncAndExpectNodeReassignment(server,

-                                      "weave:service:login:error",

-                                      undo,

-                                      "weave:service:sync:finish",

-                                      Service.storageURL + "meta/global");

-});

-

diff --git a/services/sync/tests/unit/test_fxa_service_cluster.js b/services/sync/tests/unit/test_fxa_service_cluster.js
deleted file mode 100644
index f6f97184a9..0000000000
--- a/services/sync/tests/unit/test_fxa_service_cluster.js
+++ /dev/null
@@ -1,68 +0,0 @@
-/* Any copyright is dedicated to the Public Domain.

-   http://creativecommons.org/publicdomain/zero/1.0/ */

-

-Cu.import("resource://services-sync/service.js");

-Cu.import("resource://services-sync/util.js");

-Cu.import("resource://testing-common/services/sync/fxa_utils.js");

-Cu.import("resource://testing-common/services/sync/utils.js");

-

-add_task(function test_findCluster() {

-  _("Test FxA _findCluster()");

-

-  _("_findCluster() throws on 500 errors.");

-  initializeIdentityWithTokenServerResponse({

-    status: 500,

-    headers: [],

-    body: "",

-  });

-

-  yield Service.identity.initializeWithCurrentIdentity();

-  yield Assert.rejects(Service.identity.whenReadyToAuthenticate.promise,

-                       "should reject due to 500");

-

-  Assert.throws(function() {

-    Service._clusterManager._findCluster();

-  });

-

-  _("_findCluster() returns null on authentication errors.");

-  initializeIdentityWithTokenServerResponse({

-    status: 401,

-    headers: {"content-type": "application/json"},

-    body: "{}",

-  });

-

-  yield Service.identity.initializeWithCurrentIdentity();

-  yield Assert.rejects(Service.identity.whenReadyToAuthenticate.promise,

-                       "should reject due to 401");

-

-  cluster = Service._clusterManager._findCluster();

-  Assert.strictEqual(cluster, null);

-

-  _("_findCluster() works with correct tokenserver response.");

-  let endpoint = "http://example.com/something";

-  initializeIdentityWithTokenServerResponse({

-    status: 200,

-    headers: {"content-type": "application/json"},

-    body:

-      JSON.stringify({

-        api_endpoint: endpoint,

-        duration: 300,

-        id: "id",

-        key: "key",

-        uid: "uid",

-      })

-  });

-

-  yield Service.identity.initializeWithCurrentIdentity();

-  yield Service.identity.whenReadyToAuthenticate.promise;

-  cluster = Service._clusterManager._findCluster();

-  // The cluster manager ensures a trailing "/"

-  Assert.strictEqual(cluster, endpoint + "/");

-

-  Svc.Prefs.resetBranch("");

-});

-

-function run_test() {

-  initTestLogging();

-  run_next_test();

-}

diff --git a/services/sync/tests/unit/test_fxa_startOver.js b/services/sync/tests/unit/test_fxa_startOver.js
deleted file mode 100644
index e27d86ea00..0000000000
--- a/services/sync/tests/unit/test_fxa_startOver.js
+++ /dev/null
@@ -1,63 +0,0 @@
-/* Any copyright is dedicated to the Public Domain.

- * http://creativecommons.org/publicdomain/zero/1.0/ */

-

-Cu.import("resource://testing-common/services/sync/utils.js");

-Cu.import("resource://services-sync/identity.js");

-Cu.import("resource://services-sync/browserid_identity.js");

-Cu.import("resource://services-sync/service.js");

-

-function run_test() {

-  initTestLogging("Trace");

-  run_next_test();

-}

-

-add_task(function* test_startover() {

-  let oldValue = Services.prefs.getBoolPref("services.sync-testing.startOverKeepIdentity", true);

-  Services.prefs.setBoolPref("services.sync-testing.startOverKeepIdentity", false);

-

-  ensureLegacyIdentityManager();

-  yield configureIdentity({username: "johndoe"});

-

-  // The boolean flag on the xpcom service should reflect a legacy provider.

-  let xps = Cc["@mozilla.org/weave/service;1"]

-            .getService(Components.interfaces.nsISupports)

-            .wrappedJSObject;

-  do_check_false(xps.fxAccountsEnabled);

-

-  // we expect the "legacy" provider (but can't instanceof that, as BrowserIDManager

-  // extends it)

-  do_check_false(Service.identity instanceof BrowserIDManager);

-

-  Service.serverURL = "https://localhost/";

-  Service.clusterURL = Service.serverURL;

-

-  Service.login();

-  // We should have a cluster URL

-  do_check_true(Service.clusterURL.length > 0);

-

-  // remember some stuff so we can reset it after.

-  let oldIdentity = Service.identity;

-  let oldClusterManager = Service._clusterManager;

-  let deferred = Promise.defer();

-  Services.obs.addObserver(function observeStartOverFinished() {

-    Services.obs.removeObserver(observeStartOverFinished, "weave:service:start-over:finish");

-    deferred.resolve();

-  }, "weave:service:start-over:finish", false);

-

-  Service.startOver();

-  yield deferred.promise; // wait for the observer to fire.

-

-  // the xpcom service should indicate FxA is enabled.

-  do_check_true(xps.fxAccountsEnabled);

-  // should have swapped identities.

-  do_check_true(Service.identity instanceof BrowserIDManager);

-  // should have clobbered the cluster URL

-  do_check_eq(Service.clusterURL, "");

-

-  // we should have thrown away the old identity provider and cluster manager.

-  do_check_neq(oldIdentity, Service.identity);

-  do_check_neq(oldClusterManager, Service._clusterManager);

-

-  // reset the world.

-  Services.prefs.setBoolPref("services.sync-testing.startOverKeepIdentity", oldValue);

-});

diff --git a/services/sync/tests/unit/xpcshell.ini b/services/sync/tests/unit/xpcshell.ini
index 7e97835ac5..28424129bb 100644
--- a/services/sync/tests/unit/xpcshell.ini
+++ b/services/sync/tests/unit/xpcshell.ini
@@ -122,11 +122,6 @@ skip-if = os == "android"
 [test_syncscheduler.js]
 [test_upgrade_old_sync_key.js]
 
-# Firefox Accounts specific tests
-[test_fxa_startOver.js]
-[test_fxa_service_cluster.js]
-[test_fxa_node_reassignment.js]
-
 # Finally, we test each engine.
 [test_addons_engine.js]
 run-sequentially = Hardcoded port in static files.