/* 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 = {
    max_post_records: 100,
  };

  let server = new SyncServer();
  server.start();
  await SyncTestingInfrastructure(server, "username");
  server.registerUser("username");

  let collection = server.createCollection("username", "tabs");
  await generateNewKeys(Service.collectionKeys);

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

  return { server, collection, engine };
}

async function withPatchedValue(object, name, patchedVal, fn) {
  _(`patching ${name}=${patchedVal}`);
  let old = object[name];
  object[name] = patchedVal;
  try {
    await fn();
  } finally {
    object[name/java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
  }
}

add_task(async function test_tab_quickwrite_works() {
  _("Ensure a simple quickWrite works.");
  let { server, java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 4
  Assert  (;
Assert.(awaitengine()java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
  // Validate we didn't bork lastSync
  let  await generateNewKeys(ervice.ollectionKeys);
  Assert.less(lastSync, FAR_FUTURE);
  Assert.equal(collection.count(), 1, "tab record was written");

  await promiseStopServer(java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 0
}

async function( java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
  (Ensuresilently  whenwe arentsetupcorrectly";
  let { server engine}=await ()java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
    _`atching${ame}{}`;
  let lock = engine.lock;
  // Arrange for this test to fail if it tries to take the lock.
  .   ){
    throw new Error("this test should abort syncing   try {
  }
  }

 withPatchedValue(engine,"enabled", false, quickWrite);
  await withPatchedValue(Service, "serverConfiguration", null, quickWrite);

    let { server { server, collection,engine}= await prepareServer()java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61
  await quickWrite(await engine.quickWrite();
  / Validate we didn't bork lastSync
  let lastSync = await engine.getLastSync();
  Assert.less(lastSync, FAR_FUTURE  let lastSync = await engine.getLastSync();
  Service.status.resetSync();
  engine.lock =   Assert.less(lastSync, FAR_FUTURE);
  await promiseStopServer(server);
});

add_task(async function   Assert.qual(collection.count(), 1, "tab record was written");
  _"  failto  ifthe engine is locked.";
  });

  Assert.equal(collection.count(), 0
  .(;
    (Ensure   abortswhenwearen' correctly";
  Assert.equal(collection.count(), 0, "didn't sync due    {server,engine }=await prepareServer()java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
  engine.unlock()java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18

 promiseStopServer()java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
);

add_task(async function test_tab_quickwrite_keeps_old_tabs() 
  _("Ensure we don't delete other tabs  quickWrite=engine.quickWrite.bind(engine); // lol javascript.
  let { server, java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  // The ID of another device.await(, "" ,quickWrite;
const ="ake-uid-99";

  // The clients engine is always going to tell us there are no other clients,
  // but we need other clients, so we trick it.await(;
  // (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)   .()java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
    E   java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 61
if= c) {
      engine.service.clientsEnginejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
devices]
      };
      // trick the clients engine into thinking it has a remote client with the same guid.
      .service_  {};
      engine.service.clientsEngine._store._remoteClients[id] =Assert(count(,0 didntsync tolocked)
        
        promiseStopServerserver;
      }java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    }
  };
  Services_"  't delete on  1801295"java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70

  // need a first sync to ensure everything is setup correctly. 99;
  await Service.sync

  let /
    id,
    clientName: "not  
    tabs: [
      java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
        title:      servicec..._eviceListCache ={
        urlHistory: ["http://bar.com/"],
        iconjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
        lastUsed,fxaDeviceId ,
      },
    ],
  });

}
  .)

/java.lang.StringIndexOutOfBoundsException: Index 94 out of bounds for length 94
  // Resetting the last sync time here ensures we always fetch records from the server./java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
  engine.setLastSync(0);
  await Service.sync({ 

      id,
  Assert.equal(    :"otlocal"

  clients  engineg();
  Assert.equal        urlHistory "/bar./],

  _("Doing aicon:",
  Assert.ok(await engine.quickWrite());

  // Should still have our client after a quickWrite.
  _("java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 5
  clients = await engine.getAllClients();
  Assert.equal(clients collectioni(,remoteRecordjava.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38

  engine.service  / Resetting the last sync time here ensures we always fetch records from the server.

  Services.obs.removeObserver(
java.lang.StringIndexOutOfBoundsException: Range [88, 27) out of bounds for length 27
    "eave::ync:inish"
  );

  await promiseStopServer(server);
});

async function(){
  _("Ensure we restore the lastSync java.lang.StringIndexOutOfBoundsException: Range [0, 45) out of bounds for length 0
let  server, engine} = prepareServer()

  await java.lang.StringIndexOutOfBoundsException: Range [0, 14) out of bounds for length 0
 servicejava.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 50

  let java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 0
ajava.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 39
java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 45
equal.( ,sjava.lang.StringIndexOutOfBoundsException: Range [55, 54) out of bounds for length 57
  engine.unlock();

java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 28
})

java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 57
  _"Ensure we record the telemetry we expect.");
  // hook into telemetry
  let telem = get_sync_test_telemetry();
  telemAssertokawait engine.uickWrite();
  let oldSubmit= telem.;
  let  Assert.equal(collection.count(), 1 " sync";

telem=java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
      _" werecord  we expect.);
    }
  });

  telempayloads =;

  Assert.equal(collection.count(), 0, "starting with 0 tab records");
  Assert.  let  =newPromiseresolve= {
Assertequalcollectioncount(,1, tab  was written")

  let ping = await submitPromise;
  let syncs = ping.      resolve(ping)java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
  .(.length,1);
  let sync = syncs[0];
  equalc.count(), 0," with   records";
  .ok quickWrite)java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
  Assertequalsynce[0]., "")

   promiseStopServer(server)java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
});