SquadJS/plugins/mysql-log/index.js

import {
  LOG_PARSER_NEW_GAME,
  LOG_PARSER_PLAYER_WOUNDED,
  LOG_PARSER_PLAYER_DIED,
  LOG_PARSER_PLAYER_REVIVED,
  LOG_PARSER_SERVER_TICK_RATE
} from 'squad-server/events/log-parser';
import { SERVER_PLAYERS_UPDATED } from 'squad-server/events/server';

export default function(server, mysqlPool, options = {}) {
  if (!server)
    throw new Error(
      'MySQLLog must be provided with a reference to the server.'
    );

  if (!mysqlPool)
    throw new Error('MySQLLog must be provided with a mysql Pool.');

  const serverID = options.overrideServerID || server.id;

  server.on(LOG_PARSER_SERVER_TICK_RATE, info => {
    mysqlPool.query(
      'INSERT INTO ServerTickRate(time, server, tick_rate) VALUES (?,?,?)',
      [info.time, serverID, info.tickRate]
    );
  });

  server.on(SERVER_PLAYERS_UPDATED, players => {
    mysqlPool.query(
      'INSERT INTO PlayerCount(time, server, player_count) VALUES (NOW(),?,?)',
      [serverID, players.length]
    );
  });

  server.on(LOG_PARSER_NEW_GAME, info => {
    mysqlPool.query('call NewMatch(?,?,?,?,?,?,?)', [
      serverID,
      info.time,
      info.dlc,
      info.mapClassname,
      info.layerClassname,
      info.map,
      info.layer
    ]);
  });

  server.on(LOG_PARSER_PLAYER_WOUNDED, info => {
    mysqlPool.query('call InsertPlayerWounded(?,?,?,?,?,?,?,?,?,?,?,?,?)', [
      serverID,
      info.time,
      info.victim ? info.victim.steamID : null,
      info.victim ? info.victim.name : null,
      info.victim ? info.victim.teamID : null,
      info.victim ? info.victim.squadID : null,
      info.attacker ? info.attacker.steamID : null,
      info.attacker ? info.attacker.name : null,
      info.attacker ? info.attacker.teamID : null,
      info.attacker ? info.attacker.squadID : null,
      info.damage,
      info.weapon,
      info.teamkill
    ]);
  });

  server.on(LOG_PARSER_PLAYER_DIED, info => {
    mysqlPool.query('call InsertPlayerDied(?,?,?,?,?,?,?,?,?,?,?,?,?,?)', [
      serverID,
      info.time,
      info.woundTime,
      info.victim ? info.victim.steamID : null,
      info.victim ? info.victim.name : null,
      info.victim ? info.victim.teamID : null,
      info.victim ? info.victim.squadID : null,
      info.attacker ? info.attacker.steamID : null,
      info.attacker ? info.attacker.name : null,
      info.attacker ? info.attacker.teamID : null,
      info.attacker ? info.attacker.squadID : null,
      info.damage,
      info.weapon,
      info.teamkill
    ]);
  });

  server.on(LOG_PARSER_PLAYER_REVIVED, info => {
    mysqlPool.query(
      'call InsertPlayerRevived(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)',
      [
        serverID,
        info.time,
        info.woundTime,
        info.victim ? info.victim.steamID : null,
        info.victim ? info.victim.name : null,
        info.victim ? info.victim.teamID : null,
        info.victim ? info.victim.squadID : null,
        info.attacker ? info.attacker.steamID : null,
        info.attacker ? info.attacker.name : null,
        info.attacker ? info.attacker.teamID : null,
        info.attacker ? info.attacker.squadID : null,
        info.damage,
        info.weapon,
        info.teamkill,
        info.reviver ? info.reviver.steamID : null,
        info.reviver ? info.reviver.name : null,
        info.reviver ? info.reviver.teamID : null,
        info.reviver ? info.reviver.squadID : null
      ]
    );
  });
}