warapi.js

//ANCIENT TECHNOLOGIES BORROWED FROM INTERACTIVE MAP PROJECT
const SQLite = require('better-sqlite3');
const sql = SQLite('./.data/global-data.db');
const db = require('./dbfunctions.js');
const socket = require('./socket.js');
// const discordbot = require('./discordbot.js');
var XMLHttpRequest = require('xhr2');
const regionNames = [
  'DeadLandsHex',
  'CallahansPassageHex', //4
  'MarbanHollow', //5
  'UmbralWildwoodHex', //6
  'MooringCountyHex', //7
  'HeartlandsHex', //8
  'LochMorHex', //9
  'LinnMercyHex', //10
  'ReachingTrailHex', //11
  'StonecradleHex', //12
  'FarranacCoastHex', //13
  'WestgateHex', //14
  'FishermansRowHex', //15
  'OarbreakerHex', //16
  'GreatMarchHex', //17
  'TempestIslandHex', //18
  'GodcroftsHex', //19
  'EndlessShoreHex', //20
  'AllodsBightHex', //21
  'WeatheredExpanseHex', //22
  'DrownedValeHex', //23
  'ShackledChasmHex', //24
  'ViperPitHex',

  'MorgensCrossingHex',
  'OriginHex',
  'AshFieldsHex',
  'RedRiverHex',
  'ClansheadValleyHex',
  'HowlCountyHex',
  'BasinSionnachHex',
  'SpeakingWoodsHex',
  'CallumsCapeHex',
  'NevishLineHex',
  'KalokaiHex',
  'AcrithiaHex',
  'TerminusHex',
  'TheFingersHex',
];

//Pulling dynamic data from the WarAPI
exports.updateMap = function () {
  function getEtag(array, regionname) {
    for (var i = 0; i < array.length; i++) {
      if (regionname == array[i].regionName) {
        return array[i].etag;
      }
    }
  }
  function finishUpdate(startDate) {
    console.log('Dynamic API update successful, all regions updated');
    let finishLoadDate = new Date();
    let timedif = Math.abs(finishLoadDate - startDate) / 1000;
    console.log(timedif + ' seconds to load data');
    exports.pullStatic();
    //sql.prepare("ALTER TABLE apidata_dynamic_temp RENAME TO apidata_dynamic;").run();
    socket.UpdateDynMap();
  }

  try {
    sql.prepare('DROP TABLE apidata_dynamic_temp;').run();
  } catch (err) {
    //K - if there is no table to drop, just ignore the error and create a new one, meh.
  }
  try {
    sql
      .prepare(
        'CREATE TABLE apidata_dynamic (regionName TEXT PRIMARY KEY, regionId INT, data TEXT, etag TEXT);'
      )
      .run();
  } catch (err) {}
  var etags = sql
    .prepare('SELECT regionName, etag FROM apidata_dynamic;')
    .all();
  //sql.setAPIData = sql.prepare("INSERT OR REPLACE INTO apidata_dynamic_temp (regionId, teamId, iconType, x, y, flags) VALUES (@regionId, @teamId, @iconType, @x, @y, @flags);");
  const insertMap = sql.prepare(
    'INSERT OR REPLACE INTO apidata_dynamic (regionName, regionId, data, etag) VALUES (@regionName, @regionId, @data, @etag);'
  );
  const getMap = sql.prepare(
    'SELECT * FROM apidata_dynamic WHERE regionId = ?;'
  );
  //  Dynamic Data
  var dynamicCounter = 0;
  let oldCounter = 0;
  let startLoadDate = new Date();
  regionNames.forEach(function (value) {
    var str =
      'https://war-service-live.foxholeservices.com/api/worldconquest/maps/' +
      value +
      '/dynamic/public';
    var request = new XMLHttpRequest();
    request.responseType = 'json';
    request.open('GET', str, true);
    request.onreadystatechange = function () {
      //Checks etags, if same, abort
      //console.log("State "+request.readyState+" for "+value)
      if (request.readyState === 2) {
        let etag = this.getResponseHeader('etag');
        let oldEtag = getEtag(etags, value);
        //console.log("Checking etags for "+value+", old Etag = "+oldEtag+", new Etag = "+etag);
        if (etag == oldEtag) {
          oldCounter++;
          //console.log("Same etag, aborting");
          request.abort();
          dynamicCounter++;
          if (dynamicCounter == regionNames.length) {
            if (oldCounter != dynamicCounter) {
              console.log('Old data', oldCounter);
            }
            if (oldCounter == dynamicCounter) {
              return null;
            }
            finishUpdate(startLoadDate);
          }
        }
      }
    };
    request.onload = function () {
      if (request.status >= 200 && request.status < 400) {
        try {
          //console.log(this.response);
          var data = this.response;
          let mapData = {
            regionName: value,
            regionId: data.regionId,
            data: JSON.stringify(data),
            etag: this.getResponseHeader('etag'),
          };
          let prevData = getMap.get(data.regionId);
          //console.log("previous data")
          //console.log(prevData)
          let prevItems = [];
          try {
            prevItems = JSON.parse(prevData.data).mapItems;
          } catch (err) {
            console.log(data.regionId);
            console.log(prevData);
          }
          function findItem(x, y) {
            for (var i = 0; i < prevItems.length; i++) {
              let obj = prevItems[i];
              if (obj.x == x && obj.y == y) {
                return obj;
              }
            }
          }
          for (var i = 0; i < data.mapItems.length; i++) {
            let obj = data.mapItems[i];
            if ((obj.iconType > 3 && obj.iconType < 8) || obj.iconType == 29) {
              let prevObj = findItem(obj.x, obj.y);
              if (prevObj == null || prevObj == undefined || prevObj == '') {
                continue;
              }
              if (JSON.stringify(obj) != JSON.stringify(prevObj)) {
                const insertEvent = sql.prepare(
                  'INSERT INTO events (region, date, prevItem, newItem)  VALUES (@region, @date, @prevItem, @newItem);'
                );
                let entry = {
                  region: data.regionId,
                  date: JSON.stringify(new Date()),
                  prevItem: JSON.stringify(prevObj),
                  newItem: JSON.stringify(obj),
                };
                console.log('New data');
                console.log(entry);
                if (
                  obj.iconType == 5 ||
                  obj.iconType == 6 ||
                  obj.iconType == 7 ||
                  obj.iconType == 29
                ) {
                  let signature = getSignature(obj);
                  let globallist = sql
                    .prepare(
                      'SELECT * FROM global WHERE settings LIKE ? AND settings LIKE "%channelid%" ;'
                    )
                    .all('%' + signature + '%');
                  if (globallist.length > 0) {
                    for (let j = 0; j < globallist.length; j++) {
                      // discordbot.emitNotify({global:globallist[j],region:data.regionId,date:new Date(),prevItem:prevObj,newItem:obj})
                    }
                  }
                  //console.log("Global list",globallist)
                }

                //let global = sql.prepare('SELECT * FROM global WHERE settings LIKE ?;').get(text);
                if (obj.iconType > 3 && obj.iconType < 8) {
                  insertEvent.run(entry);
                }
              }
            }
          }
          insertMap.run(mapData);
          //console.log(data.mapItems);
          //console.log("Dynamic API data for",value,"updated");
          dynamicCounter++;
          if (dynamicCounter == regionNames.length) {
            finishUpdate(startLoadDate);
          }
        } catch (err) {
          console.log('ERROR - Could not load dynamic data for', value);
          //console.log(err)
          dynamicCounter++;
          if (dynamicCounter == regionNames.length) {
            finishUpdate(startLoadDate);
          }
        }
      } else {
        dynamicCounter++;
        if (dynamicCounter == regionNames.length) {
          finishUpdate(startLoadDate);
        }
        //console.log("ERROR - Could not load dynamic data for",value);
      }
    };
    //console.log("Sending to WarAPI Dynamic Data request for",value)
    request.send();
  });
};

//Pull static data from WarAPI (modified dynamic data function (NOT TESTED))
exports.pullStatic = function () {
  function getEtag(array, regionname) {
    for (var i = 0; i < array.length; i++) {
      if (regionname == array[i].regionName) {
        return array[i].etag;
      }
    }
  }

  function finishUpdate(startDate) {
    console.log('Static API update successful, all regions updated');
    let finishLoadDate = new Date();
    let timedif = Math.abs(finishLoadDate - startDate) / 1000;
    console.log(timedif + ' seconds to load data');
  }

  try {
    sql.prepare('DROP TABLE apidata_static_temp;').run();
  } catch (err) {
    //K - if there is no table to drop, just ignore the error and create a new one, meh.
  }
  try {
    sql
      .prepare(
        'CREATE TABLE apidata_static (regionName TEXT PRIMARY KEY, regionId INT, data TEXT, etag TEXT);'
      )
      .run();
  } catch (err) {}
  var etags = sql.prepare('SELECT regionName, etag FROM apidata_static;').all();
  const insertMap = sql.prepare(
    'INSERT OR REPLACE INTO apidata_static (regionName, regionId, data, etag) VALUES (@regionName, @regionId, @data, @etag);'
  );
  //Static Data
  var staticCounter = 0;
  let startLoadDate = new Date();
  regionNames.forEach(function (value) {
    var str =
      'https://war-service-live.foxholeservices.com/api/worldconquest/maps/' +
      value +
      '/static';
    var request = new XMLHttpRequest();
    request.responseType = 'json';
    request.open('GET', str, true);
    request.onreadystatechange = function () {
      //Checks etags, if same, abort
      //console.log("State "+request.readyState+" for "+value)
      if (request.readyState === 2) {
        let etag = this.getResponseHeader('etag');
        let oldEtag = getEtag(etags, value);
        //console.log("Checking etags for "+value+", old Etag = "+oldEtag+", new Etag = "+etag);
        if (etag == oldEtag) {
          //console.log("Same etag, aborting");
          request.abort();
          staticCounter++;
          if (staticCounter == regionNames.length) {
            finishUpdate(startLoadDate);
          }
        }
      }
    };
    request.onload = function () {
      if (request.status >= 200 && request.status < 400) {
        try {
          //console.log(this.response);
          var data = this.response;
          let mapData = {
            regionName: value,
            regionId: data.regionId,
            data: JSON.stringify(data),
            etag: this.getResponseHeader('etag'),
          };
          insertMap.run(mapData);
          //console.log(data.mapItems);
          //console.log("Dynamic API data for",value,"updated");
          staticCounter++;
          if (staticCounter == regionNames.length) {
            finishUpdate(startLoadDate);
          }
        } catch (err) {
          //console.log("ERROR - Could not load static data for",value);
          //console.log(err)
        }
      } else {
        //console.log("ERROR - Could not load static data for",value);
      }
    };
    //console.log("Sending to WarAPI static Data request for",value)
    request.send();
  });
};

exports.cunt = function test(string) {
  console.log('Foxhole War API module ' + string);
};

////////////////////////////////////////////////////////////////////////
function findclosest(town, labellist) {
  //if(labellist!=undefined){
  //console.log(town);
  for (var i = 0; i < labellist.length; i++) {
    var xdif = Math.abs(town.x - labellist[i].x);
    var ydif = Math.abs(town.y - labellist[i].y);
    var distance = Math.sqrt(Math.pow(xdif, 2) + Math.pow(ydif, 2));
    labellist[i].distance = distance;
  }
  labellist.sort(compare);
  //console.log(labellist[0]);
  return labellist[0];
}
//}

function compare(a, b) {
  if (a.distance < b.distance) return -1;
  if (a.distance > b.distance) return 1;
  return 0;
}

//Check if icon is a town
function checkicon(type) {
  if (type == 4 || type == 5 || type == 6 || type == 7) {
    return true;
  } else {
    return false;
  }
}

function getSignature(obj) {
  if (obj.regionId == undefined) {
    return obj.x + obj.y;
  } else {
    return obj.x + obj.y + obj.regionId;
  }
}

//////////WAR REPORT SECTION///////////////////////////////////////////
let WR = {};
exports.WR = WR;
exports.updateWarReport = function () {
  function finishUpdate(startDate) {
    console.log('War report API update successful, all regions updated');
    let finishLoadDate = new Date();
    let timedif = Math.abs(finishLoadDate - startDate) / 1000;
    console.log(timedif + ' seconds to load data');
    socket.FinishUpdateStats();
  }
  //Dynamic Data
  var dynamicCounter = 0;
  let startLoadDate = new Date();
  regionNames.forEach(function (value) {
    var str =
      'https://war-service-live.foxholeservices.com/api/worldconquest/warReport/' +
      value;
    var request = new XMLHttpRequest();
    request.responseType = 'json';
    request.open('GET', str, true);
    request.onload = function () {
      if (request.status >= 200 && request.status < 400) {
        try {
          //console.log(this.response);
          WR[value] = this.response;
          dynamicCounter++;
          if (dynamicCounter == regionNames.length) {
            finishUpdate(startLoadDate);
          }
        } catch (err) {
          console.log('ERROR - Could not load dynamic data for', value);
          console.log(err);
        }
      } else {
        console.log('ERROR - Could not load dynamic data for', value);
      }
    };
    request.send();
  });
};
///////////////////////////////