const {
  app,
  BrowserWindow,
  screen,
  ipcMain,
  BrowserView,
} = require("electron");
var Config = require("config-js");
const fs = require("fs");
const { win32 } = require("path");
const sysInf = require("systeminformation");
const express = require("express");
const { time } = require("console");
const { nanoid } = require("nanoid");
const diont = require("diont")();
const request = require("request");
var AdmZip = require("adm-zip");
var xmldoc = require("xmldoc");
const sqlite3 = require("sqlite3");

const restApp = express();
const restPort = 33334;
const PORT = 33333;
const MULTICAST_ADDR = "192.168.178.50";

var aWin2 = undefined;

var preLoadedAmount = 0;

var networkInterfaces = [];

/// !!!-----------!!!
/// PAGE LOOKUP TABLE
var preloadedPageLookup = {};

var pageLookup = {};
pageLookup["index"] = "index.html";
pageLookup["session"] = "sessions.html";
pageLookup["header"] = "header.html";
pageLookup["fixtures"] = "fixtures.html";

/// !!!-----------!!!
//  Session state data
// -1 Unset/Unknown
// 0 Not connected
// 1 Connecting
// 2 Connected as host
// 3 Connected as Client
// 4 Connection failed
// 5 Searching

var service = {
  name: "Enlight Default Session",
  host: "127.0.0.1", // when omitted, defaults to the local IP
  port: PORT,
  memberCount: 1,
  UUID: "",
  // any additional information is allowed and will be propagated
};

var sessionState = -1;
var sessionStateGoal = -1;

var mySession = {
  name: "Unnamed Session",
  joinable: false,
  passwordProtected: false,
  passwordHash: "",
  members: 1,
  memberList: [],
  usedUIDs: [],
};

var currentState = {
  projectName: "",
  projectDirty: false
}

var mainConn = "";
var mainNetworkInterface = undefined;

//var knownSessions = [];
var knownSessionsByUUID = {};

function setVarWait(state) {
  waitHere = state;
}

diont.on("serviceAnnounced", function (serviceInfo) {
  console.log("A new session was announced", serviceInfo.service);
  // List currently known services
  //knownSessions.push(serviceInfo.service);
  knownSessionsByUUID[serviceInfo.service.UUID] = serviceInfo.service;
});

diont.on("serviceRenounced", function (serviceInfo) {
  //console.log("A session was renounced", serviceInfo.service);
  knownSessionsByUUID[serviceInfo.service.UUID] = serviceInfo.service;
});

function rebuildFixtureLib() {
  let db = new sqlite3.Database("usrStore/fixtureDB.sqlite");

  db.all("SELECT * FROM fixtures;", [], (err, rows) => {
    console.log("ALIVE");
    if (err) {
      sql =
        "                                    \
    CREATE TABLE `fixtures` (                  \
      `id` INTEGER PRIMARY KEY AUTOINCREMENT,  \
      `LongName` VARCHAR(255),                 \
      `Name` VARCHAR(255),                     \
      `ShortName` VARCHAR(255),                \
      `Manufacturer` VARCHAR(255),             \
      `Description` VARCHAR(255),              \
      `Thumbnail` VARCHAR(150),                \
      `fileName` VARCHAR(255) );";
      db.run(sql);
    }
  });
  db.close();

  setTimeout(function () {
    let db = new sqlite3.Database("usrStore/fixtureDB.sqlite");
    flds = fs.readdirSync("fixtures");
    i = 0;
    while (i < flds.length) {
      var zip = new AdmZip("fixtures/" + flds[i]);
      descRaw = zip.readAsText("description.xml");
      descParsed = new xmldoc.XmlDocument(descRaw);
      console.log(descParsed.children[1].attr.LongName);
      if (descParsed["name"] != "GDTF") {
        console.warn(flds[i] + " is not a valid fixture file");
      }
      if (descParsed.attr.DataVersion != "1.0") {
        console.warn(
          "Version " +
            descParsed.attr.DataVersion +
            " of GDTF is not completly supported yet"
        );
      }
      fileNameT = flds[i];
      desc = descParsed.children[1].attr.Description
      desc = desc.replaceAll("'", " ")
      sqlDyn =
        "INSERT INTO fixtures (LongName, Name, ShortName, Manufacturer, Description, Thumbnail, fileName) VALUES ('" +
        descParsed.children[1].attr.LongName +
        "','" +
        descParsed.children[1].attr.Name +
        "','" +
        descParsed.children[1].attr.ShortName +
        "','" +
        descParsed.children[1].attr.Manufacturer +
        "','" +
        desc +
        "','" +
        descParsed.children[1].attr.Thumbnail +
        "','" +
        fileNameT +
        "');";
        // console.log(sqlDyn)
      db.run(sqlDyn);
      i += 1;
    }
    db.close()
  }, 1000);
}

// Preload all pages
function preloadPages() {
  for (const [key, value] of Object.entries(pageLookup)) {
    // check if the property/key is defined in the object itself, not in parent
    if (pageLookup.hasOwnProperty(key)) {
      fs.readFile("ui_templates/" + value, "utf8", function (err, data) {
        preLoadedAmount++;
        if (err) {
          return console.log(err);
        }
        preloadedPageLookup[key] = data;
      });
    }
  }
}

// Prepare session existence broadcast
function prepBroadcast() {
  runy = true;
  while (runy) {
    if (networkInterfaces.length >= 1) {
      runy = false;
    }
  }
  console.log("Waiting done");

  var Ibroad = 0;
  var names = [];
  while (Ibroad < networkInterfaces.length) {
    names.push(networkInterfaces[Ibroad].ifaceName);
    Ibroad++;
  }
  last = fs.readFileSync("usrStore/lastNetwork.data");
  mainConn = last.toString();
  ind = names.indexOf(mainConn);
  mainNetworkInterface = networkInterfaces[ind];
}

// Loads a preloaded page or reads it from file
function loadPage(name) {
  load = preloadedPageLookup[name];
  if (load == undefined) {
    load = fs.readFileSync("ui_templates/" + pageLookup[name]).toString();
    console.warn("Loading fallback for page " + name);
  }
  return load;
}

function createWindow() {
  const win = new BrowserWindow({
    width: screen.getPrimaryDisplay().size.width,
    height: screen.getPrimaryDisplay().size.height,
    webPreferences: {
      nodeIntegration: true,
      contextIsolation: false,
    },
  });
  win.setFullScreen(true);
  win.setMenuBarVisibility(false);
  win.setAutoHideMenuBar(true);

  main = loadPage("index");
  header = loadPage("header");

  toLoad = header + main;
  fs.writeFileSync("ui_templates/temp.html", toLoad);
  win.loadFile("ui_templates/temp.html");
  return win;
}

function createStartupInfo() {
  // aka. loading screen
  const win2 = new BrowserWindow({
    width: 400,
    height: 200,
    frame: false,
    webPreferences: {
      nodeIntegration: true,
      contextIsolation: false,
    },
  });

  win2.setFullScreen(false);
  win2.setAlwaysOnTop(true);
  win2.loadFile("ui_templates/startUp.html");
  win2.show();
  return win2;
}

function doneLoading() {
  var fadeOutI = 1;
  if (Object.keys(pageLookup).length == preLoadedAmount) {
    aWin2.webContents.executeJavaScript(
      "document.getElementById('current').innerHTML = 'Done';"
    );
    var fadeIntervall = setInterval(function () {
      try {
        if (fadeOutI < 0) {
          clearInterval(fadeIntervall);
          aWin2.webContents.executeJavaScript("window.close()");
        } else {
          aWin2.setOpacity(fadeOutI);
          fadeOutI = fadeOutI - 0.05;
        }
      } catch (e) {
        // Happens if the user Alt + F4s the startup window
        console.warn("Startup window got destroyed!");
        clearInterval(fadeIntervall);
      }
    }, 20);
  } else {
    console.warn("Had to reschedule load finish");
    setTimeout(doneLoading, 200);
  }
}

function init() {
  win = createWindow();
  aWin2 = createStartupInfo();
  setInterval(function () {
    sysInf.networkInterfaces(function (data) {
      networkInterfaces = data;
    });
  }, 2 * 60 * 1000); // Update network interface every 2 mins

  preloadPages();

  sysInf.networkInterfaces(function (data) {
    networkInterfaces = data;
  });
  setTimeout(prepBroadcast, 200);

  var langs = new Config("./lang/langs_v1.js");

  sessionState = 0; // Init with no connection
  setTimeout(function () {
    console.log("Starting restfulServer API interface");
    try {
      restApp.listen(restPort, () => {
        console.log(`Restful is running on http://localhost:${restPort}`);
      });
    } catch (e) {
      console.warn("This program cannot be a host");
    }

    restApp.get("/", (req, res) => {
      res.send("Hello World! The RestFul API of Enlight is up and working!");
    });

    restApp.get("/api/v1/ping", (req, res) => {
      res.json({ state: "Succes", uptime: time.time() });
    });

    restApp.get("/api/v1/session/info", (req, res) => {
      res.json({
        state: "Succes",
        name: mySession.name,
        joinAble: mySession.joinable,
        passwordProtected: mySession.passwordProtected,
        memberAmount: mySession.members,
      });
    });

    restApp.get("/api/v1/session/join", (req, res) => {
      console.log("Getting a join request");
      if (mySession.joinable) {
        if (mySession.passwordProtected == false) {
          uid = nanoid();
          while (mySession.usedUIDs.includes(uid)) {
            uid = nanoid();
          }

          mySession.usedUIDs.push(uid);
          dev = {
            type: "client",
            ip: req.connection.remoteAddress,
            uid: uid,
          };
          mySession.memberList.push();
          mySession.members++;
          service.memberCount++;
          res.json({ state: "Succes", uid: uid });
        } else {
          res.json({
            state: "Failed",
            message: "Passwords are not yet implemented",
            code: -1,
          });
        }
      } else {
        res.json({
          state: "Failed",
          message: "Session is not joinable.",
          code: 1,
        });
      }
    });
  }, 20);

  setTimeout(doneLoading, 2000);

  ipcMain.on("synchronous-message", (event, arg) => {
    if (String(arg).includes("hasBattery")) {
      // Retrieve if the device has a battery
      sysInf.battery(function (data) {
        event.returnValue = data.hasbattery;
      });
    } else if (String(arg).includes("getBatteryLevel")) {
      // Retrieve device's battery level in percent
      sysInf.battery(function (data) {
        event.returnValue = data.percent;
      });
    } else if (String(arg).includes("loadOverride")) {
      event.returnValue = false;
    } else if (String(arg).includes("getNetworks")) {
      // Retrieve all saved networks
      event.returnValue = networkInterfaces;
    } else if (String(arg).includes("set:newNetwork")) {
      // Sets the new main network
      fs.writeFile(
        "usrStore/lastNetwork.data",
        String(arg).split("|")[1],
        function (err) {
          if (err) return console.log(err);
          console.log("Saved new main network");
        }
      );
      event.returnValue = "";
    } else if (String(arg).includes("getMainNetwork")) {
      // Retrieves the main network definded by the user
      try {
        last = fs.readFileSync("usrStore/lastNetwork.data");
        //console.log(last.toString())
        event.returnValue = last.toString();
        mainConn = last.toString();
      } catch (e) {
        sysInf.networkInterfaces(function (data) {
          fs.writeFileSync("usrStore/lastNetwork.data", data[0].ifaceName);
          event.returnValue = data[0].ifaceName;
        });
      }
    } else if (String(arg).includes("PAGE:change")) {
      // Change to a diffrent page of the programm

      newPage = String(arg).split(".")[1];
      main = header = loadPage(newPage);

      header = loadPage("header");
      toLoad = header + main;
      const timestamp = Date.now();
      fs.writeFileSync("ui_templates/temp.html", toLoad);
      const timestamp2 = Date.now();
      win.loadFile("ui_templates/temp.html");
      const timestamp3 = Date.now();
      event.returnValue = "";
    } else if (String(arg).includes("ACTION:power")) {
      // Change to a diffrent page of the programm

      command = String(arg).split(".")[1];
      if(command == "quit"){
        if(currentState.projectDirty){
          event.returnValue = "ANS:PROJECT_DIRTY";
        }
        app.quit()
        console.log("Trying to quit")
      }
    } else if (String(arg).includes("SESSION:get.state")) {
      // Retrives the session state

      event.returnValue = sessionState;
    } else if (String(arg).includes("SESSION:createNew")) {
      // Creates a new session
      i = 0;
      sessinUids = Object.keys(knownSessionsByUUID);
      // Make sure its a unique (at least to me) UUID
      rounds = 0;
      uidSes = nanoid();
      while (sessinUids.includes(uidSes)) {
        uidSes = nanoid();
        rounds++;
        if (rounds >= 10000) {
          // This takes a lot of rounds, there are two possible reasons to this:
          // A lot of sessions or a broken nanoid() random generation
          console.warn("It takes very long to find a unique session UUID");
        }
        if (rounds >= 40000) {
          // Okay, no. We shall give up now. Something is very, very wrong here.
          console.error("Took to long to find a session UUID");
          sessionState = 4;
          return "";
        }
      }

      service.UUID = uidSes;
      service.host = mainNetworkInterface.ip4;
      mySession.name = String(arg).split("|")[1];
      service.name = String(arg).split("|")[1];
      diont.announceService(service);
      mySession.joinable = true;
      sessionState = 2;
      sessionStateGoal = 2;
      event.returnValue = "";
      sessionReAnn = setInterval(function () {
        diont.announceService(service);
      }, 10000);
      sessionReAnn = setInterval(function () {
        diont.renounceService(service);
      }, 5000);
    } else if (String(arg).includes("SESSION:joinSession")) {
      sessionState = 1;
      UUIDtoJoin = String(arg).split("|")[1];
      ipToJoin = knownSessionsByUUID[UUIDtoJoin].host;
      requestURL = "http://" + ipToJoin + ":33334/api/v1/session/join";
      console.log(requestURL);
      request(requestURL, { json: true }, (err, res, body) => {
        if (err) {
          return console.log(err);
        }
        event.returnValue = body;
      });
      sessionState = 3; // Just guess it was okay
    } else if (String(arg).includes("SESSION:getAll")) {
      event.returnValue = knownSessionsByUUID;
      console.log(knownSessionsByUUID);
    } else if (String(arg).includes("FIXTURE:initDB")) {
      rebuildFixtureLib()
      event.returnValue = "";
    } else if (String(arg).includes("FIXTURE:search")) {
      term = String(arg).split("|")[1];
      sqlQ = "SELECT * FROM fixtures WHERE Name LIKE '%" + term + "%' or LongName LIKE '%" + term + "%' or ShortName LIKE '%" + term + "%' or Manufacturer LIKE '%" + term + "%';"
      console.log(sqlQ)
      let db = new sqlite3.Database("usrStore/fixtureDB.sqlite");
      db.all(sqlQ, [], (err, rows) => {
        console.log("ALIVE");
        if (err) {
          throw err
          }
          event.returnValue = rows;
          console.log(rows)
      });
      db.close()
      
    } else {
      event.returnValue = "ERR:UNKNOW_CMD";
    }
  });
}

app.whenReady().then(init);

app.on("window-all-closed", () => {
  if (process.platform !== "darwin") {
    app.quit();
  }
});

app.on("activate", () => {
  if (BrowserWindow.getAllWindows().length === 0) {
    createWindow();
  }
});