const sqlite = require('sqlite3') class Database { constructor (app) { this._app = app this._sql = new sqlite.Database('database.sql') } ensureIndexes () { this._sql.serialize(() => { this._sql.run('CREATE TABLE IF NOT EXISTS pings (timestamp BIGINT NOT NULL, ip TINYTEXT, playerCount MEDIUMINT)') this._sql.run('CREATE INDEX IF NOT EXISTS ip_index ON pings (ip, playerCount)') this._sql.run('CREATE INDEX IF NOT EXISTS timestamp_index on PINGS (timestamp)') }) } loadGraphPoints (graphDuration, callback) { // Query recent pings const endTime = new Date().getTime() const startTime = endTime - graphDuration this.getRecentPings(startTime, endTime, pingData => { const relativeGraphData = [] for (const row of pingData) { // Load into temporary array // This will be culled prior to being pushed to the serverRegistration let graphData = relativeGraphData[row.ip] if (!graphData) { relativeGraphData[row.ip] = graphData = [[], []] } // DANGER! // This will pull the timestamp from each row into memory // This is built under the assumption that each round of pings shares the same timestamp // This enables all timestamp arrays to have consistent point selection and graph correctly graphData[0].push(row.timestamp) graphData[1].push(row.playerCount) } Object.keys(relativeGraphData).forEach(ip => { // Match IPs to serverRegistration object for (const serverRegistration of this._app.serverRegistrations) { if (serverRegistration.data.ip === ip) { const graphData = relativeGraphData[ip] // Push the data into the instance and cull if needed serverRegistration.loadGraphPoints(startTime, graphData[0], graphData[1]) break } } }) // Since all timestamps are shared, use the array from the first ServerRegistration // This is very dangerous and can break if data is out of sync if (Object.keys(relativeGraphData).length > 0) { const serverIp = Object.keys(relativeGraphData)[0] const timestamps = relativeGraphData[serverIp][0] // This is a copy of ServerRegistration#loadGraphPoints // relativeGraphData contains original timestamp data and needs to be filtered into minutes const sharedTimestamps = [] let lastTimestamp = startTime for (let i = 0; i < timestamps.length; i++) { const timestamp = timestamps[i] if (timestamp - lastTimestamp >= 60 * 1000) { lastTimestamp = timestamp sharedTimestamps.push(timestamp) } } this._app.timeTracker.loadHistoricalTimestamps(sharedTimestamps) } callback() }) } loadRecords (callback) { let completedTasks = 0 this._app.serverRegistrations.forEach(serverRegistration => { // Find graphPeaks // This pre-computes the values prior to clients connecting serverRegistration.findNewGraphPeak() // Query recordData // When complete increment completeTasks to know when complete this.getRecord(serverRegistration.data.ip, (playerCount, timestamp) => { serverRegistration.recordData = { playerCount, timestamp: Math.floor(timestamp / 1000) } // Check if completedTasks hit the finish value // Fire callback since #readyDatabase is complete if (++completedTasks === this._app.serverRegistrations.length) { callback() } }) }) } getRecentPings (startTime, endTime, callback) { this._sql.all('SELECT * FROM pings WHERE timestamp >= ? AND timestamp <= ?', [ startTime, endTime ], (_, data) => callback(data)) } getRecord (ip, callback) { this._sql.all('SELECT MAX(playerCount), timestamp FROM pings WHERE ip = ?', [ ip ], (_, data) => callback(data[0]['MAX(playerCount)'], data[0].timestamp)) } insertPing (ip, timestamp, playerCount) { const statement = this._sql.prepare('INSERT INTO pings (timestamp, ip, playerCount) VALUES (?, ?, ?)') statement.run(timestamp, ip, playerCount) statement.finalize() } } module.exports = Database