The Tor Browser / file diff

     1.1 --- /dev/null	Thu Jan 01 00:00:00 1970 +0000
     1.2 +++ b/services/sync/tests/unit/test_engine_abort.js	Wed Dec 31 06:09:35 2014 +0100
     1.3 @@ -0,0 +1,69 @@
     1.4 +/* Any copyright is dedicated to the Public Domain.
     1.5 +   http://creativecommons.org/publicdomain/zero/1.0/ */
     1.6 +
     1.7 +Cu.import("resource://services-sync/engines.js");
     1.8 +Cu.import("resource://services-sync/record.js");
     1.9 +Cu.import("resource://services-sync/service.js");
    1.10 +Cu.import("resource://services-sync/util.js");
    1.11 +Cu.import("resource://testing-common/services/sync/rotaryengine.js");
    1.12 +Cu.import("resource://testing-common/services/sync/utils.js");
    1.13 +
    1.14 +add_test(function test_processIncoming_abort() {
    1.15 +  _("An abort exception, raised in applyIncoming, will abort _processIncoming.");
    1.16 +  let engine = new RotaryEngine(Service);
    1.17 +
    1.18 +  let collection = new ServerCollection();
    1.19 +  let id = Utils.makeGUID();
    1.20 +  let payload = encryptPayload({id: id, denomination: "Record No. " + id});
    1.21 +  collection.insert(id, payload);
    1.22 +
    1.23 +  let server = sync_httpd_setup({
    1.24 +      "/1.1/foo/storage/rotary": collection.handler()
    1.25 +  });
    1.26 +
    1.27 +  new SyncTestingInfrastructure(server);
    1.28 +  generateNewKeys(Service.collectionKeys);
    1.29 +
    1.30 +  _("Create some server data.");
    1.31 +  let meta_global = Service.recordManager.set(engine.metaURL,
    1.32 +                                              new WBORecord(engine.metaURL));
    1.33 +  meta_global.payload.engines = {rotary: {version: engine.version,
    1.34 +                                          syncID: engine.syncID}};
    1.35 +  _("Fake applyIncoming to abort.");
    1.36 +  engine._store.applyIncoming = function (record) {
    1.37 +    let ex = {code: Engine.prototype.eEngineAbortApplyIncoming,
    1.38 +              cause: "Nooo"};
    1.39 +    _("Throwing: " + JSON.stringify(ex));
    1.40 +    throw ex;
    1.41 +  };
    1.42 +
    1.43 +  _("Trying _processIncoming. It will throw after aborting.");
    1.44 +  let err;
    1.45 +  try {
    1.46 +    engine._syncStartup();
    1.47 +    engine._processIncoming();
    1.48 +  } catch (ex) {
    1.49 +    err = ex;
    1.50 +  }
    1.51 +
    1.52 +  do_check_eq(err, "Nooo");
    1.53 +  err = undefined;
    1.54 +
    1.55 +  _("Trying engine.sync(). It will abort without error.");
    1.56 +  try {
    1.57 +    // This will quietly fail.
    1.58 +    engine.sync();
    1.59 +  } catch (ex) {
    1.60 +    err = ex;
    1.61 +  }
    1.62 +
    1.63 +  do_check_eq(err, undefined);
    1.64 +
    1.65 +  server.stop(run_next_test);
    1.66 +  Svc.Prefs.resetBranch("");
    1.67 +  Service.recordManager.clearCache();
    1.68 +});
    1.69 +
    1.70 +function run_test() {
    1.71 +  run_next_test();
    1.72 +}