/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this file,
 * You can obtain one at http://mozilla.org/MPL/2.0/. */

/**
 * Test migration logic by artificially inducing or simulating the problem, then
 *  trigger the migration logic, then verify things ended up correct, including
 *  the schema version so a second pass of the logic doesn't happen.  (As
 *  opposed to checking in an example of a broken database and running against
 *  that.)
 */

var {
  assertExpectedMessagesIndexed,
  glodaTestHelperInitialize,
  nukeGlodaCachesAndCollections,
  waitForGlodaIndexer,
} = ChromeUtils.import("resource://testing-common/gloda/GlodaTestHelper.jsm");
var { waitForGlodaDBFlush, makeABCardForAddressPair } = ChromeUtils.import(
  "resource://testing-common/gloda/GlodaTestHelperFunctions.jsm"
);
var { sqlRun } = ChromeUtils.import(
  "resource://testing-common/gloda/GlodaQueryHelper.jsm"
);
var { GlodaMsgIndexer } = ChromeUtils.import(
  "resource:///modules/gloda/IndexMsg.jsm"
);
var { GlodaDatastore } = ChromeUtils.import(
  "resource:///modules/gloda/GlodaDatastore.jsm"
);
var { MessageGenerator } = ChromeUtils.import(
  "resource://testing-common/mailnews/MessageGenerator.jsm"
);
var { MessageInjection } = ChromeUtils.import(
  "resource://testing-common/mailnews/MessageInjection.jsm"
);

const GLODA_OLD_BAD_MESSAGE_ID = 1;

var msgGen;
var messageInjection;

add_setup(function () {
  msgGen = new MessageGenerator();
  messageInjection = new MessageInjection({ mode: "local" }, msgGen);
  glodaTestHelperInitialize(messageInjection);
});

/**
 * Fix the fallout from bug 732372 (with this patch for bug 734507) which left
 *  identities whose e-mails were in the address book without contacts and then
 *  broke messages involving them.
 */
add_task(async function test_fix_missing_contacts_and_fallout() {
  // -- Setup

  // - Create 4 e-mail addresses, 2 of which are in the address book.  (We want
  //    to make sure we have to iterate, hence >1).
  let abPeeps = msgGen.makeNamesAndAddresses(2);
  let nonAbPeeps = msgGen.makeNamesAndAddresses(2);
  makeABCardForAddressPair(abPeeps[0]);
  makeABCardForAddressPair(abPeeps[1]);

  // - Create messages of the genres [from, to]: [inAB, inAB], [inAB, !inAB],
  //    [!inAB, inAB], [!inAB, !inAB].  The permutations are black box overkill.
  // Smear the messages over multiple folders for realism.
  let [, yesyesMsgSet, yesnoMsgSet, noyesMsgSet, nonoMsgSet] =
    await messageInjection.makeFoldersWithSets(3, [
      { count: 2, from: abPeeps[0], to: [abPeeps[1]] },
      { count: 2, from: abPeeps[1], to: nonAbPeeps },
      { count: 2, from: nonAbPeeps[0], to: abPeeps },
      { count: 2, from: nonAbPeeps[1], to: [nonAbPeeps[0]] },
    ]);

  // Union the yeses together; we don't care about their composition.
  let yesMsgSet = yesyesMsgSet.union(yesnoMsgSet).union(noyesMsgSet),
    noMsgSet = nonoMsgSet;

  // - Let gloda index the messages so the identities get created.
  await waitForGlodaIndexer();
  Assert.ok(
    ...assertExpectedMessagesIndexed([yesMsgSet, noMsgSet], { augment: true })
  );
  // The messages are now indexed and the contacts created.

  // - Compel an indexing sweep so the folder's dirty statuses get cleared
  GlodaMsgIndexer.initialSweep();
  await waitForGlodaIndexer();
  Assert.ok(...assertExpectedMessagesIndexed([])); // (no new messages to index)

  // - Force a DB commit so the pending commit tracker gets emptied out
  // (otherwise we need to worry about its state overriding our clobbering)
  await waitForGlodaDBFlush();

  // - Delete the contact records for the people in the address book.
  await sqlRun(
    "DELETE FROM contacts WHERE id IN (" +
      yesMsgSet.glodaMessages[0].from.contact.id +
      ", " +
      yesMsgSet.glodaMessages[0].to[0].contact.id +
      ")"
  );

  // - Nuke the gloda caches so we totally forget those contact records.
  nukeGlodaCachesAndCollections();

  // - Manually mark the messages involving the inAB people with the _old_ bad
  //    id marker so that our scan will see them.
  for (let msgHdr of yesMsgSet.msgHdrs()) {
    msgHdr.setUint32Property("gloda-id", GLODA_OLD_BAD_MESSAGE_ID);
  }

  // - Mark the db schema version to the version with the bug (26).
  // Sanity check that gloda actually populates the value with the current
  //  version correctly.
  Assert.equal(
    GlodaDatastore._actualSchemaVersion,
    GlodaDatastore._schemaVersion
  );
  GlodaDatastore._actualSchemaVersion = 26;
  await sqlRun("PRAGMA user_version = 26");
  // Make sure that took, since we check it below as a success indicator.
  let verRows = await sqlRun("PRAGMA user_version");
  Assert.equal(verRows[0].getInt64(0), 26);

  // -- Test
  // - Trigger the migration logic and request an indexing sweep.
  GlodaMsgIndexer.disable();
  GlodaMsgIndexer.enable();
  GlodaMsgIndexer.initialSweep();

  // - Wait for the indexer to complete, expecting that the messages that we
  //    marked bad will get indexed but not the good messages.
  await waitForGlodaIndexer();
  Assert.ok(...assertExpectedMessagesIndexed([yesMsgSet], { augment: true }));

  // - Verify that the identities have contacts again.
  // Must have the contact object.
  Assert.notEqual(yesMsgSet.glodaMessages[0].from.contact, undefined);
  // The contact's name should come from the address book card
  Assert.equal(yesMsgSet.glodaMessages[0].from.contact.name, abPeeps[0][0]);

  // - Verify that the schema version changed from gloda's perspective and from
  //    the db's perspective.
  verRows = await sqlRun("PRAGMA user_version");
  Assert.equal(verRows[0].getInt64(0), GlodaDatastore._schemaVersion);
  Assert.equal(
    GlodaDatastore._actualSchemaVersion,
    GlodaDatastore._schemaVersion
  );
});