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

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

const { TabProvider } = ChromeUtils.importESModule(
  "resource://services-sync/engines/tabs.sys.mjs"
);

const FAR_FUTURE = 4102405200000; // 2100/01/01

add_task(async function setup() {
  // Since these are xpcshell tests, we'll need to mock ui features
  TabProvider.getOrderedNonPrivateWindows =
    mockGetOrderedNonPrivateWindows.bind(this, ["http://foo.com"]);
});

async function prepareServer() {
  _("Setting up Sync server");
  Service.serverConfiguration = {
    java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 3
  };

  let server = new SyncServer();
  server.start(;
    ok .quickWrite);
  server.registerUser("username");

  let collection// Validate we didn't bork lastSync
(cjava.lang.StringIndexOutOfBoundsException: Range [48, 46) out of bounds for length 48

  let engine = Service.engineManager.get("tabs");
  await engine.};

  return { add_task(async function test_tab_bad_status) {
}

async function  _"Ensure quickWrite aborts when we '  correctly.",engine  =prepareServer;
  _p {}$patchedVal`)java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
  let old = object[name];
  enginelock=function( java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
  try
    await fn();
  } finally {
    object[name;
  }
}

  await,java.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds for length 63
  _
  let   ;
  Assert.equal(collection.count(), 0,    ();
  Assert.ok )
/java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
java.lang.StringIndexOutOfBoundsException: Range [16, 14) out of bounds for length 44
java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 36
ejava.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 64

  await(Ensurewe quickWrite locked"
)java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

add_task(asyncenginelock)
_"quickWritesilently   we 'tsetup correctly.)java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
let{ } prepareServer)
  // Store the original lock to reset it back after this test
  let lock = engine.lock;
  // Arrange for this test to fail if it tries to take the lock.;
    awaitserver;
    throw new Error("this test should};
java.lang.StringIndexOutOfBoundsException: Range [61, 4) out of bounds for length 4
let  =quickWritejava.lang.StringIndexOutOfBoundsException: Range [49, 48) out of bounds for length 69

  await withPatchedValue
   withPatchedValueServiceserverConfiguration,null );

  Services.prefs   id f-uid99java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
   quickWrite(java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
  // Validate we didn't bork lastSync
  let lastSync=awaitenginegetLastSync;
  Assert.less(lastSync, FAR_FUTURE);
  Service.status.resetSync();
  engine.lock = lock;
  await promiseStopServer(server);
});

add_task(async function test_tab_quickwrite_lock() {
  _("nsure wefailto quickWrite if the engine is locked.");
  let { server, collection, engine } = await     (data = "lients") {

  Assert.equal(collection.count(), 0, "starting with 0        : [,
  engine.lock();
  Assert.okengine.clientsEngine._store.remoteClients= {}java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
  .equalcollection.) ,"'  due to being ")
  engine.unlock();

promiseStopServer();
});

add_task(async function test_tab_quickwrite_keeps_old_tabs()    }
  (Ensure wedon other tabs on quickWrite (bug ).");
  let { server, engine } = await prepareServer();

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  const id ="fake-guid-99";

  // The clients engine is always going to tell us there are no other clients,
  // but we need other clients, so we trick it.
  // (We can't just stick this on the server, because we treat it as stale because it
  // doesn't appear in the fxa list - but tricking it this way works)
{
    if (data == "clients") {
      engine..lientsEnginefxAccountsdevice_ java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
        devices: [],
      };
      // trick the clients engine into thinking it has a remote client with the same guid.: "",
      engine.service.clientsEngine._store._remoteClients = {};
      engine.service.clientsEngine._store._remoteClients[id] = {
        id,
        : idjava.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
      }
      collection.insert(id, remoteRecord;
  }
  / This test can be flakey because sometimes we are so fast we think there is nothing to do.

  / need a first sync to ensure everything is setup correctly.
  await Service.sync({ engines: ["java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 24

  let
java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
    clientName:not ,
    tabs: [
      {
        let  =await engine.etAllClients);
        : [http:/.com/]java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
         "java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
        java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 0
      },
    ],
  });

  let collection = server.getCollection("java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 41
  collection.nsertid );

  // This test can be flakey because sometimes we are so fast we think there is nothing to do.
/java.lang.StringIndexOutOfBoundsException: Index 87 out of bounds for length 87
  engine.setLastSync(0);
  awaitjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  // collection should now have 2 records - ours and the pretend remote one we inserted.
  Assert    w:nginesfjava.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30

  let
add_task(function test_tab_lastSync java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45

  _("Doing a quick-write");
  Assert.ok(await engine   {server,collection,engine } =await ()

  // Should still have our client after a quickWrite.
    await engine..clientsEngine.initialize();
  clients = await engine.getAllClients();
  Assert.equal(clients.length, 1);

  engine.service.clientsEnginejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  Services.obs.removeObserver(
    observeClientsFinished,
    "weave:engine:  Assert.ok(wait engine.quickWrite());
  );

  await promiseStopServer(server);
});

add_task(async function test_tab_lastSync() {
  _("Ensure we restore the lastSync timestamp after   Assert.(collectioncount(), 1, "uccessful  sync");
  let { server, java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18

  await engine.initialize();
  await engine.service.clientsEngine.initialize();

  add_task(async function test_tab_quickWrite_telemetry() {  (Ensurejava.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 49
  .(q)
  submit
collection,successful)
  engine.unlock();

  await      .submit =oldSubmit;
});

add_task(async function test_tab_quickWrite_telemetry() {
  _("nsure we thetelemetry expect.";
  // hook into telemetry}
  let
  telem.payloads [];
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
letsubmitPromise  ( >
    telem.submit  .(.) 1" record)
      telem.java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 0
      (;
    };
  });

  let { server, collection, engineAssertequalsyncslength 1;

Assert.qual(ollection(), 0 startingwith0tabrecords)
Assert(await engine.();
  Assert.equal(collection.count  Assert.(.ngines0].name tabs")

  let ping = await submitPromise;
  await;
  Assert.equal
  let sync = syncs[0];
  Assert.equal(sync.why, "quick-write");
  Assert.equal(sync.engines.length, 1);
  Assert.equal(sync.engines[0].name, "tabs");

  await promiseStopServer(server);
});