const mysql = require("mysql");
const mysql2 = require("mysql2/promise");
const fs = require("fs");
const parseICal = require("./ICal");

const [id, pw] = fs
  .readFileSync("server/libs/sql.pvdata", "utf8")
  .split("\r\n");
const connectOption = {
  host: "extended-calendar-db.cihyg6ssq3la.ap-northeast-2.rds.amazonaws.com",
  user: id,
  password: pw,
  database: "db",
};

async function jcalToSQL(jcal, userID) {
  // const fsql = fs.readFileSync("server/libs/sql.pvdata", "utf8");
  // const [id, pw] = fsql.split("\r\n");
  const connection = await mysql2.createConnection(connectOption);

  await connection.connect();

  const commonCols = [
    "userID",
    "uid",
    "label",
    "subjectID",
    "type",
    "description",
    "url",
    "detail",
  ];
  const dateScheCols = [...commonCols, "date"];
  const timeScheCols = [...commonCols, "date", "startTime", "endTime"];
  const dateQueryString =
    "INSERT IGNORE INTO schedules_date (" +
    dateScheCols.join(",") +
    ") VALUES ?";
  const timeQueryString =
    "INSERT IGNORE INTO schedules_time (" +
    timeScheCols.join(",") +
    ") VALUES ?";

  const dateSchedules = [];
  const timeSchedules = [];
  for (const sche of jcal) {
    sche.userID = userID;
    sche.type = "assignment";
    if (sche.scheType === "date")
      dateSchedules.push(dateScheCols.map((col) => sche[col]));
    else if (sche.scheType === "time")
      timeSchedules.push(timeScheCols.map((col) => sche[col]));
    else console.log("unexpected scheType", sche);
  }

  let [result] = await connection.query(dateQueryString, [dateSchedules]);
  console.log("ICAL schedules_date | " + result.affectedRows);
  [result] = await connection.query(timeQueryString, [timeSchedules]);
  console.log("ICAL schedules_time | " + result.affectedRows);

  connection.end();
}

// iCal의 소유주를 DB에 등록 후 userID get
// subjectID가 subjects, userID가 users에 있어야함

// const fdata = fs.readFileSync("C:/Users/teddy/Downloads/data.ics", "utf8");
// const jcal = parseICal(fdata);
// jcalToSQL(jcal, 1);

module.exports = { jcalToSQL, connectOption };