import crypto from "crypto";

import Sequelize from "sequelize";

export default {
  up: async (queryInterface: Sequelize.QueryInterface) => {
    // Get current sync modes for salesforce destinations
    const [destinations] = await queryInterface.sequelize.query(
      `SELECT "ownerId" AS "id", "value" AS "mode" FROM "options" o JOIN "destinations" d ON o."ownerId"=d.id WHERE "key"='syncMode' AND d.type='salesforce-objects-export' AND "locked" IS NULL`
    );

    // set sync mode on destination
    for (const dest of destinations) {
      let syncMode: string;
      switch (dest["mode"]) {
        case "Enrich":
          syncMode = "enrich";
          break;
        case "Additive":
          syncMode = "additive";
          break;
        case "Sync":
        default:
          // if option was not set, salesforce defaulted to "sync"
          syncMode = "sync";
          break;
      }

      await queryInterface.sequelize.query(
        `UPDATE "destinations" SET "syncMode"=? WHERE "id"=?`,
        {
          replacements: [syncMode, dest["id"]],
        }
      );
    }

    // remove salesforce syncMode option
    const destinationIds = destinations.map((d) => d["id"]);
    if (destinationIds.length > 0) {
      await queryInterface.sequelize.query(
        `DELETE FROM "options" WHERE "key"='syncMode' AND "ownerId" IN(?)`,
        {
          replacements: [destinationIds],
        }
      );
    }
  },

  down: async (queryInterface: Sequelize.QueryInterface) => {
    // Get sync modes
    const [destinations] = await queryInterface.sequelize.query(
      `SELECT "id", "syncMode" FROM "destinations" WHERE "type"='salesforce-objects-export' AND "syncMode" IS NOT NULL AND "locked" IS NULL`
    );

    // Add corresponding "syncMode" option for each destination
    const newOptions = [];
    for (const dest of destinations) {
      let syncMode: string;
      switch (dest["syncMode"]) {
        case "sync":
          syncMode = "Sync";
          break;
        case "enrich":
          syncMode = "Enrich";
          break;
        case "additive":
          syncMode = "Additive";
          break;
        default:
          continue;
      }

      newOptions.push({
        id: `opt_${crypto.randomBytes(16).toString("hex")}`,
        createdAt: new Date(),
        updatedAt: new Date(),
        ownerId: dest["id"],
        ownerType: "destination",
        key: "syncMode",
        value: syncMode,
        type: "string",
      });
    }

    await queryInterface.bulkInsert("options", newOptions);

    // Remove syncMode from salesforce destinations
    await queryInterface.bulkUpdate(
      "destinations",
      {
        syncMode: null,
      },
      {
        id: destinations.map((d) => d["id"]),
      }
    );
  },
};