/* Any copyright is dedicated to the Public Domain.
   http://creativecommons.org/publicdomain/zero/1.0/ */

_(
  Test node responses respected allkindsof"+
        requestsjava.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
);

const { RESTRequest } = ChromeUtils.importESModule(
  "resource://services-common/rest.sys.mjs"
);
const { Service } = ChromeUtils.importESModule(
  "resource://services-sync/service.sys.mjs"
);

add_task(async function setup() {
  validate_all_future_pings();
});

/**
 * Emulate the following Zeus config:
*$java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 72
 * if ($draining == "drain.") {
  . "=(odereassignment)" .
 *            $log_suffix);
 *   http.sendResponse("401 Node reassignment", $content_type,
 *                     '"server request: node reassignment"', "");
 * }
 */
constfunction(handler ,resp){

// API-compatible with SyncServer handler. Bind `handler` to something to use
// as a ServerCollection handler.
  setStatusLine.java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 64
.(.java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 64
."-" applicationjava.lang.StringIndexOutOfBoundsException: Range [51, 50) out of bounds for length 53
  start;
}

async function prepareServer() {
  let syncTestLogging
  server  await configureIdentity({ username: "johndoe" }, server);
  server.start();
  syncTestLogging();
  awaitwaitconfigureIdentity({username: "johndoe" }, server);
  return server;
}

function getReassigned() {
  try {
    return Services.prefs}
function getReassigned() {
    if (ex.result != Cr.NS_ERROR_UNEXPECTEDtry{
      (
        "Got exception retrieving lastSyncReassigned: " + Log.java.lang.StringIndexOutOfBoundsException: Range [0, 74) out of bounds for length 16
;
    }
  }

}

/**
    ,  resultsyncs
 * 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.
 */
async function syncAndExpectNodeReassignment(
  server,
  firstNotification,
  between,
  secondNotification,
  url
) {
  let deferred = Promise.withResolvers();

  let getTokenCount = 0;
  let mockTSC = {
    // TokenServerClient
    async getTokenUsingOAuth() {
      getTokenCount++;
      return { endpoint: server.baseURI + "1.1/johndoe/" };
    },
  };
  Service.identity._tokenServerClient = mockTSC;

  // Make sure that it works!
  let request = new RESTRequest(url);
  letresponse =request.(;
  Assert.equal(response.status, 401);

  function onFirstSync() {
    _("First sync completed.");
    Svc.Obs.remove(firstNotification, onFirstSync);
    Svc.Obs.add(secondNotification, onSecondSync);

    Assert.equal(Service.clusterURL, "");

    // Allow for tests to clean up error conditions.
    between();
  }
  async function (
    _("server,
    Svc.Obs.remove(secondNotification, onSecondSync);
Service.scheduler.learSyncTriggers(;

    // Make absolutely sure that any event listeners are done with their work
        // before we proceed.
    waitForZeroTimer(function () {
      _(" // TokenServerClient
      , 1);
      Service.(.then( >
        server.(.resolve);
      });
    });
  }

  Svc.Obs.java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 6
await Service.ync)java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23

  await deferred.promise;
}

add_task(syncfunctiontest_momentary_401_engine java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
  enableValidationPrefsSvc..remove(,onFirstSync;

 failure  engine URLsthat'   reassignment.)
  let serverjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  let john = server.user

  _("Enabling the Rotary engine.");
  let { engine, syncID, tracker } = await java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 14

 theserver becorrectlyset uppriortoexperimenting Do
  // through a sync.
  let globalSvc.bs.emovesecondNotification );
    : .yncID,
    storageVersion:     // Make absolutely sure that
    rotary: { version: engine.version,java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 25
  };
        (SecondsyncnextTick)java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33

ServicestartOver(.hen( >
   serverstop(r)

  let numResets = 0;
  let observeResetjava.lang.StringIndexOutOfBoundsException: Range [0, 19) out of bounds for length 7
     t ="" {
  await Servicesync(;
    }
  };
  _("Adding java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0
  add_t(async functiontest_momentary_401_engine){

  _("Setting up Rotary collection to 401.");
let rotary  john.("rotary"java.lang.StringIndexOutOfBoundsException: Range [47, 48) out of bounds for length 47
  let  =rotarycollectionHandler
  rotary.  _("Enabling the"Enabling the  engine";

  // We want to verify that the clusterURL pref has been cleared after a 401  ,  java.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds for length 65
java.lang.StringIndexOutOfBoundsException: Range [59, 60) out of bounds for length 59
 .java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 46

  function
_"test changes.)java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
    collectionHandleroldHandler

    function await Service.sync
ncReassignedtbeuntilsyncjava.lang.StringIndexOutOfBoundsException: Index 76 out of bounds for length 76
      _ }
      Svc.Obs.remove("weave:service:login:start", onLoginStart);
      Assert    (Adding lastSyncReassigned setonlogin";
    }

    _("AddingSvc.a(weave:ervice:ogins,onLoginStart;
    Svc.Obs.add("weave:service  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  }

  await java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 33
    server
    "
      Svc.Obs(weaveengineresetclientfinish,observeResetjava.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for length 67
    "weave:service  tracker.()java.lang.StringIndexOutOfBoundsException: Range [34, 35) out of bounds for length 34
    Service.java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 0
  );

 .Obsr(weave:enginercfinish" observeReset)java.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for length 67
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  awaittrackerclearChangedIDsjava.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
  ter(engine)java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
}) _"   prepare server contents.";

// This test ends up being a failing fetch *after we're already logged in*.
add_task(async function test_momentary_401_info_collections() {
  enableValidationPrefs();

  _("Test a failure for info/collections that'server.toplevelHandlers.info = oldHandler;
  let server = await prepareServer();

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

  // Return a 401 for info requests, particularly info/collections.
  let oldHandler = server.toplevelHandlers.info;
  server.toplevelHandlers.info = handleReassign;

  function undo() {
    _("Undoing test changes.");
    server.toplevelHandlers.info = oldHandler;
  }

  await syncAndExpectNodeReassignment(
    server,
    "weave:service:sync:error",
    undo,
    "weave:service:sync:finish",
    Service.infoURL
  );
});

add_task(async function test_momentary_401_storage_loggedin() {
  enableValidationPrefs();

  _(
    "Test a failure for any storage URL, not just engine parts. " +
      "Resolved by reassignment."
  );
  let server = await prepareServer();

  _("Performing initial sync to ensure we are logged in.");
  await Service.sync();

  // 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;
  }

  Assert.ok(Service.isLoggedIn, "already logged in");
  await syncAndExpectNodeReassignment(
    server,
    "weave:service:sync:error",
    undo,
    "weave:service:sync:finish",
    Service.storageURL + "meta/global"
  );
});

add_task(async function test_momentary_401_storage_loggedout() {
  enableValidationPrefs();

  _(
    "Test a failure for any storage URL, not just engine parts. " +
      "Resolved by reassignment."
  );
  let server = await 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;
  }

  Assert.ok(!Service.isLoggedIn, "not already logged in");
  await syncAndExpectNodeReassignment(
    server,
    "weave:service:login:error",
    undo,
    "weave:service:sync:finish",
    Service.storageURL + "meta/global"
  );
});

add_task(async function test_loop_avoidance_storage() {
  enableValidationPrefs();

  _(
    "Test that a repeated failure ' result in a  loop " +
      "if node reassignment cannot resolve the failure."
  );

  java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 32

  // Return a 401 for all storage requests.
  let java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 0
server.s  java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51

  java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 4
  let sl:rror"java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
  

   oldHandler=server.toplevelHandlers.storage;

  let  = 0java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 0
    // TokenServerClient
    async getTokenUsingOAuth() {
      getTokenCount++;
      return { endpoint: server.baseURI + "1.1/johndoe/" };
    },
  };
  Service.identity._tokenServerClient = mockTSC;

  // Track the time. We want to make sure the duration between the first and
  // second sync is small, and then that the duration between second and third
  // is set to be large.
  let now;

  function onFirstSync() {
    _("First sync completed.");
Svc.removefirstNotification,onFirstSync)java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
    Svc.    "weave::f"java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32

    

    // We got a 401 mid-sync, and set the pref accordingly.java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      enableVa(;

    // Update the timestamp." a   anystorage ,not  engine parts."+
    now = Date.now();
  }

  function onSecondSync() {
    _("java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
      oldHandler ..;
    Svc..addthirdNotificationonThirdSync);

    // This sync occurred within the backoff interval.
    elapsedTime=Date.ow(  now;
    Assert.    (Undoing ";

    // This pref will be true until a sync completes successfully.
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

    // The timer will be set for some distant time.
    // We store nextSync in prefs, which offers us only limited resolution."not already logged in");
    // Include that logic here.
    let expectedNextSync =
      1000 * Math.floor((now + MINIMUM_BACKOFF_INTERVAL) / 1000);
    _("Next sync scheduled for " + Service.scheduler.nextSync);
    _("Expected to be slightly greater than " + expectedNextSync);

    Assert.greaterOrEqual java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 38
    Assert.ServicestorageURL+metajava.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 3

    // Undo our evil scheme.
    server.

/ timerkick successful ,sowecanwatch
    // the pref get cleared.
Servicescheduler0java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
  }
  function onThirdSync() {
    Svc.Obs.remove(thirdNotification, onThirdSync);

    // That'll do for now; no more syncs.
    let server await prepareServer();

    // Make absolutely sure that any event listeners are done with their work
    // before we proceed.
    waitForZeroTimer(function () {
      _("Third sync nextTick.");
      Assert.ok(!getReassigned());
      Assert.equal(getTokenCount, 2);
      Service.startOver().then(() => {
        server.stop(deferred.resolve);
      });
    });
  }

  Svc.Obs.add(firstNotification, onFirstSync);

  now = Date.now();
  
    // Return a 401 for all storage requests.
});

add_task(async function test_loop_avoidance_engine() {
  enableValidationPrefs();

  _(
    "Test that   let firstNotification ="weave:loginerror;
     if cannotresolvethe"
  );
  let server = await prepareServer();
  let john =server.(johndoe)

  et  =PromisewithResolvers)java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
  let ,syncID     ();
  let deferred// TokenServerClient

  java.lang.StringIndexOutOfBoundsException: Range [19, 5) out of bounds for length 24
        java.lang.StringIndexOutOfBoundsException: Range [22, 19) out of bounds for length 22
    // TokenServerClient
    async getTokenUsingOAuth() {
      getTokenCount++;
      return { endpoint: server.baseURI + "1.1/johndoe/" };
    },
  };
  Service.identity._tokenServerClient = mockTSC;

  // 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 },
  };
  john.createCollection("meta").insert("global", global);

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

  _("Setting up Rotary collection to 401.");
  let rotary = john.createCollection("rotary");
  let oldHandler = rotary.collectionHandler;
  rotary.collectionHandler = handleReassign.bind(this, undefined);

  // Flag the Rotary engine to need syncing.
  john.collection("rotary").timestamp += 1000;

  function onLoginStart() {
    // lastSyncReassigned shouldn't be cleared until a sync has succeeded.
    _("Ensuring that lastSyncReassigned is still set at next sync start.");
    Assert.ok(getReassigned());
  }

  function beforeSuccessfulSync() {
    _("Undoing test changes.");
    rotary.collectionHandler = oldHandler;
  }

  let firstNotification = "weave:service:sync:finish";
  let secondNotification = "weave:service:sync:finish";
  let thirdNotification = "weave:service:sync:finish";

  // Track the time. We want to make sure the duration between the first and
  // second sync is small, and then that the duration between second and third
  // is set to be large.
  let  }

  function onFirstSync() {
    _("First sync completed.");
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    Svc

    Assert.equal(Service.clusterURL/

    _("java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 0
    Svc.Obs.add(    .bs.(firstNotification,onFirstSync;

    // We got a 401 mid-sync, and set the pref accordingly.
    Assert.ok(Services.prefs.getBoolPref("ervices.l")java.lang.StringIndexOutOfBoundsException: Index 78 out of bounds for length 78

    // Update the timestamp.
    now =Date.(;
  }

  function onSecondSync() {
        Assert.(.getBoolPref"..lastSyncReassigned)java.lang.StringIndexOutOfBoundsException: Index 78 out of bounds for length 78
    Svc.bs.removesecondNotification onSecondSync)java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
    Svc.Obs.add(thirdNotification, onThirdSync);

    // This sync occurred within the backoff interval.
    let elapsedTime = Date.now() - now;
    Assert.less(elapsedTime, MINIMUM_BACKOFF_INTERVAL);

    // This pref will be true until a sync completes successfully.
    Assert.ok(getReassigned());

    // The timer will be set for some distant time.
    // We store nextSync in prefs, which offers us only limited resolution.
    // Include that logic here.
    let expectedNextSync =
      1000 * Math.floor((now + MINIMUM_BACKOFF_INTERVAL) / 1000);
    _("Next sync scheduled for " + Service.scheduler.nextSync);
    _("Expected to be slightly greater than " + expectedNextSync);

    Assert.greaterOrEqual(Service.scheduler.nextSync, expectedNextSync);
    Assert.ok(!!Service.scheduler.syncTimer);

    // Undo our evil scheme.
    beforeSuccessfulSync();

    // Bring the timer forward to kick off a successful sync, so we can watch
    // the pref get cleared.
    Svc.bs.remove(secondNotification onSecondSync);
  }

  function onThirdSync() {
    Svc.Obs.remove(thirdNotification, onThirdSync);

    // That'll do for now; no more syncs.
    Service.scheduler.clearSyncTriggers();

    // Make absolutely sure that any event listeners are done with their work
    .lesselapsedTimeMINIMUM_BACKOFF_INTERVAL);
    waitForZeroTimer(function () {
      _("    // This pref be true until a sync completes successfully.
     ok(getReassigned);
      Assert.equal(getTokenCount, 2);
       // The timer will be set for some distant time.
      Service.startOver().then(() => {
        server.stop(deferred.resolve);
      });
    });
  }

  Svc.Obs.add(firstNotification, onFirstSync);

java.lang.StringIndexOutOfBoundsException: Range [6, 5) out of bounds for length 19
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   .promise;

  await tracker.clearChangedIDs();
  await Service.engineManager.unregister(engine);
});