5.2.2.4 dev v4 alarm manager data processing change

commands/debug.js

@@ -21,9 +21,11 @@ module.exports = {
     */
     run: async (client, interaction, args, { GuildDB }, start) => {
 
-      client.updateLogs()
+      let alarmEmbed = new EmbedBuilder()
+        .setDescription('test des.')
+        .addFields({ name: 'Test Field', value: `[Test Data](https://www.izurvive.com/chernarusplussatmap/#location=11467.6;7452)`, inline: false })
     
-      return interaction.send({ content: 'debugging...' })
+      return interaction.send({ embeds: [alarmEmbed] });
     },
   },
 }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "dayz-armbands",
-  "version": "5.2.0.1",
+  "version": "5.2.2.4",
   "description": "A General Purpose Discord Bot for DayZ Servers.",
   "main": "index.js",
   "nodemonConfig": {

structures/DayzArmbands.js

@@ -108,39 +108,11 @@ class DayzArmbands extends Client {
   
   }
   
-  async killfeed(guildId) {
+  async handleKillfeed(guildId, line) {
     
-    const fileStream = fs.createReadStream('./logs/server-logs.ADM');
-  
-    let logHistoryDir = path.join(__dirname, '..', 'logs', 'history-logs.ADM.json');
-    let history;
-    try {
-      history = JSON.parse(fs.readFileSync(logHistoryDir));
-    } catch (err) {
-      history = {
-        lastLog: null
-      };
-    }
-
-    const rl = readline.createInterface({
-      input: fileStream,
-      crlfDelay: Infinity
-    });
-    let lines = [];
-    for await (const line of rl) { lines.push(line); }
-    
-    const channel = this.channels.cache.get('993272430342721597');
     let guild = await this.GetGuild(guildId);
     if (guild.playerstats == undefined) guild.playerstats = [];
-    
-    console.log(guild.playerstats)
-
-    for (let i = lines.indexOf(history.lastLog) + 1; i < lines.length; i++) {
-      if (i == lines.length - 1) break;
-      let nextLine = lines[i + 1];
-      if (!nextLine.includes('killed by Player')) continue;
-
-      let line = lines[i];
+    const channel = this.channels.cache.get(guild.killfeedChannel);
     let template = /(.*) \| Player \"(.*)\" \(DEAD\) \(id=(.*) pos=<(.*)>\)\[HP\: 0\] hit by Player \"(.*)\" \(id=(.*) pos=<(.*)>\) into (.*) for (.*) damage \((.*)\) with (.*) from (.*) meters /g;
     let data = [...line.matchAll(template)][0];
 
@@ -159,12 +131,12 @@ class DayzArmbands extends Client {
       distance: data[12]
     };
 
-      let killerStat = guild.playerstats.find(stat => stat.gamertag == info.killer)
-      let victimStat = guild.playerstats.find(stat => stat.gamertag == info.victim)
+    let killerStat = guild.playerstats.find(stat => stat.playerID == info.killerID)
+    let victimStat = guild.playerstats.find(stat => stat.playerID == info.victimID)
     let killerStatIndex = guild.playerstats.indexOf(killerStat);
     let victimStatIndex = guild.playerstats.indexOf(victimStat);
-      if (killerStat == undefined) killerStat = this.getDefaultPlayerStats(info.killer);
-      if (victimStat == undefined) victimStat = this.getDefaultPlayerStats(info.victim);
+    if (killerStat == undefined) killerStat = this.getDefaultPlayerStats(info.killer, info.killerID);
+    if (victimStat == undefined) victimStat = this.getDefaultPlayerStats(info.victim, info.victimID);
 
     killerStat.kills++;
     killerStat.killStreak++;
@@ -188,7 +160,7 @@ class DayzArmbands extends Client {
       }
     })
     
-      var today = new Date();
+    let today = new Date();
     let newDt = new Date(`${today.toLocaleDateString('default', { month: 'long' })} ${today.getDate()}, ${today.getFullYear()} ${info.time} EST`)
     let unixTime = Math.floor(newDt.getTime()/1000);
 
@@ -196,19 +168,207 @@ class DayzArmbands extends Client {
         .setColor(this.config.Colors.Default)
         .setDescription(`**Kill Event** - <t:${unixTime}>\n**${info.killer}** killed **${info.victim}**\n> **__Kill Data__**\n> **Weapon:** \` ${info.weapon} \`\n> **Distance:** \` ${info.distance} \`\n> **Body Part:** \` ${info.bodyPart.split('(')[0]} \`\n> **Damage:** \` ${info.damage} \`\n **Killer\n${killerStat.KDR} K/D - ${killerStat.kills} Kills - Killstreak: ${killerStat.killStreak}\nVictim\n${victimStat.KDR} K/D - ${victimStat.deaths} Deaths - Deathstreak: ${victimStat.deathStreak}**`);
 
-      channel.send({ embeds: [killEvent] });
+    if (this.exists(channel)) channel.send({ embeds: [killEvent] });
   }
 
-    if (history.lastLog == null) history.lastLog = lines[lines.length-1];
+  async handleAlarms(guildId, data) {
+    let guild = await this.GetGuild(guildId);
+    
+    for (let i = 0; i < guild.alarms.length; i++) {
+      let alarm = guild.alarms[i];
+
+      let diff = [Math.round(alarm.origin[0] - data.pos[0]), Math.round(alarm.origin[1] - data.pos[1])];
+      let distance = Math.sqrt(Math.pow(diff[0], 2) + Math.pow(diff[1], 2)).toFixed(2)
+      
+      if (distance < alarm.radius) {
+        const channel = this.channels.cache.get(alarm.channel);
+        
+        let today = new Date();
+        let newDt = new Date(`${today.toLocaleDateString('default', { month: 'long' })} ${today.getDate()}, ${today.getFullYear()} ${data.time} EST`);
+        let unixTime = Math.floor(newDt.getTime()/1000);
+
+        let alarmEmbed = new EmbedBuilder()
+          .setColor(this.config.Colors.Default)
+          .setDescription(`**Zone Ping - <t:${unixTime}>**\n**${data.player}** was located within **${distance} meters** of the Zone **${alarm.name}**`)
+          .addFields({ name: '**Location**', value: `**[${data.pos[0]}, ${data.pos[1]}](https://www.izurvive.com/chernarusplussatmap/#location=${data.pos[0]};${data.pos[1]})**`, inline: false })
+      
+        channel.send({ content: `<@&${alarm.role}>`, embeds: [alarmEmbed] });
+      }
+    }
+  }
+
+  async sendConnectionLogs(guildId, data) {
+    
+    let guild = await this.GetGuild(guildId);
+    if (!this.exists(guild.connectionLogsChannel)) return;
+    const channel = this.channels.cache.get(guild.connectionLogsChannel);
+
+    let today = new Date();
+    let newDt = new Date(`${today.toLocaleDateString('default', { month: 'long' })} ${today.getDate()}, ${today.getFullYear()} ${data.time} EST`);
+    let unixTime = Math.floor(newDt.getTime()/1000);
+
+    let connectionLog = new EmbedBuilder()
+      .setColor(data.connected ? this.config.Colors.Green : this.config.Colors.Red)
+      .setDescription(`**${data.connected ? 'Connect' : 'Disconnect'} Event - <t:${unixTime}>\n${data.player} ${data.connected ? 'Connected' : 'Disconnected'}**`);
+
+    if (!data.connected) {
+      if (!data.lastConnectionDate == null) {
+        let oldUnixTime = Math.floor(data.lastConnectionDate.getTime()/1000);
+        let sessionTime = this.secondsToDhms(unixTime - oldUnixTime);
+        connectionLog.addFields({ name: '**Session Time**', value: `**${sessionTime}**`, inline: false });
+      } else connectionLog.addFields({ name: '**Session Time**', value: `**Unknown**`, inline: false });
+    }
+
+    if (this.exists(channel)) channel.send({ embeds: [connectionLog] });
+  }
+
+  async handlePlayerLogs(guildId, line) {
+
+    let guild = await this.GetGuild(guildId);
+    if (guild.playerstats == undefined) guild.playerstats = [];
+
+    const connectTemplate = /(.*) \| Player \"(.*)\" is connected \(id=(.*)\)/g;
+    const disconnectTemplate = /(.*) \| Player \"(.*)\"\(id=(.*)\) has been disconnected/g;
+    const positionTemplate = /(.*) \| Player \"(.*)\" \(id=(.*) pos=<(.*)>\)/g;
+
+    if (line.includes('connected')) {
+      let data = [...line.matchAll(connectTemplate)][0];
+
+      let info = {
+        time: data[1],
+        player: data[2],
+        playerID: data[3],
+        connected: true,
+      };
+
+      let playerStat = guild.playerstats.find(stat => stat.playerID == info.playerID)
+      let playerStatIndex = guild.playerstats.indexOf(playerStat);
+      if (playerStat == undefined) playerStat = this.getDefaultPlayerStats(info.player, info.playerID);
+      
+      let today = new Date();
+      let newDt = new Date(`${today.toLocaleDateString('default', { month: 'long' })} ${today.getDate()}, ${today.getFullYear()} ${info.time} EST`);
+      
+      playerStat.lastConnectionDate = newDt;
+      playerStat.connected = true;
+
+      if (playerStatIndex == -1) guild.playerstats.push(playerStat);
+      else guild.playerstats[playerStatIndex] = playerStat;
+
+      this.dbo.collection("guilds").updateOne({ "server.serverID": guildId }, {
+        $set: {
+          "server.playerstats": guild.playerstats
+        }
+      });
+
+      this.sendConnectionLogs(guildId, {
+        time: info.time,
+        player: info.player,
+        conected: info.connected,
+        lastConnectionDate: null,
+      });
+    }
+
+    if (line.includes('disconnected')) {
+      let data = [...line.matchAll(disconnectTemplate)][0];
+
+      let info = {
+        time: data[1],
+        player: data[2],
+        playerID: data[3],
+        connected: false
+      }
+
+      let playerStat = guild.playerstats.find(stat => stat.playerID == info.playerID)
+      let playerStatIndex = guild.playerstats.indexOf(playerStat);
+      if (playerStat == undefined) playerStat = this.getDefaultPlayerStats(info.player, info.playerID);
+      
+      playerStat.connected = false;
+
+      if (playerStatIndex == -1) guild.playerstats.push(playerStat);
+      else guild.playerstats[playerStatIndex] = playerStat;
+
+      this.dbo.collection("guilds").updateOne({ "server.serverID": guildId }, {
+        $set: {
+          "server.playerstats": guild.playerstats
+        }
+      });
+
+      this.sendConnectionLogs(guildId, {
+        time: info.time,
+        player: info.player,
+        conected: info.connected,
+        lastConnectionDate: playerStat.lastConnectionDate,
+      });
+    }
+
+    if (line.includes('pos=<')) {
+      let data = [...line.matchAll(positionTemplate)][0];
+
+      let info = {
+        time: data[1],
+        player: data[2],
+        playerID: data[3],
+        pos: data[4].split(', ').map(v => parseFloat(v)).pop()
+      };
+
+      let playerStat = guild.playerstats.find(stat => stat.playerID == info.playerID)
+      let playerStatIndex = guild.playerstats.indexOf(playerStat);
+      if (playerStat == undefined) playerStat = this.getDefaultPlayerStats(info.player, info.playerID);
+      
+      playerStat.pos = info.pos;
+
+      this.handleAlarms(guildId, {
+        time: info.time,
+        player: info.player,
+        playerID: info.playerID,
+        pos: info.pos,
+      });
+
+      if (playerStatIndex == -1) guild.playerstats.push(playerStat);
+      else guild.playerstats[playerStatIndex] = playerStat;
+
+      this.dbo.collection("guilds").updateOne({ "server.serverID": guildId }, {
+        $set: {
+          "server.playerstats": guild.playerstats
+        }
+      });
+    }
+  }
+
+  async readLogs() {
+    const fileStream = fs.createReadStream('./logs/server-logs.ADM');
+  
+    let logHistoryDir = path.join(__dirname, '..', 'logs', 'history-logs.ADM.json');
+    let history;
+    try {
+      history = JSON.parse(fs.readFileSync(logHistoryDir));
+    } catch (err) {
+      history = {
+        lastLog: null
+      };
+    }
+
+    const rl = readline.createInterface({
+      input: fileStream,
+      crlfDelay: Infinity
+    });
+    let lines = [];
+    for await (const line of rl) { lines.push(line); }
+    
+    for (let i = lines.indexOf(history.lastLog) + 1; i < lines.length; i++) {
+      if (lines[i].includes('connected') || lines[i].includes('disconnected') || lines[i].includes('pos=<')) this.handlePlayerLogs(guildId, lines[i]);
+      if (!(i + 1 >= lines.length) && lines[i + 1].includes('killed by Player')) this.handleKillfeed(guildId, lines[i]);
+    }
+
+    history.lastLog = lines[lines.length-1];
 
     // write JSON string to a file
     await fs.writeFileSync(logHistoryDir, JSON.stringify(history));
-    
   }
 
   async logsUpdateTimer() {
     setTimeout(async () => {
-      this.killfeed('992982520591294524');
+      this.readLogs('992982520591294524');
       // await this.updateLogs().then(() => {
       //   this.guilds.cache.forEach((guild) => {
       //     this.killfeed(guild.id); // Check logs for killfeed
@@ -217,7 +377,7 @@ class DayzArmbands extends Client {
       //   });
       // });
       this.logsUpdateTimer(); // restart this function
-    }, minute * 0.5); // restart every 5 minutes
+    }, minute * 5); // restart every 5 minutes
   }
 
   async connectMongo(mongoURI, dbo) {
@@ -344,17 +504,21 @@ class DayzArmbands extends Client {
     return {
       serverID: GuildId,
       allowedChannels: [],
+      killfeedChannel: "",
+      connectionLogsChannel: "",
       factionArmbands: {},
       usedArmbands: [],
       excludedRoles: [],
       botAdminRoles: [],
       playerstats: [],
+      alarms: [],
     }
   }
 
-  getDefaultPlayerStats(gt) {
+  getDefaultPlayerStats(gt, pID) {
     return {
       gamertag: gt,
+      playerID: pID,
       KDR: 0.00,
       kills: 0,
       deaths: 0,
@@ -362,6 +526,9 @@ class DayzArmbands extends Client {
       bestKillStreak: 0,
       deathStreak: 0,
       worstDeathStreak: 0,
+      pos: [],
+      lastConnectionDate: null,
+      connected: false,
     }
   }