var util = require('./util'); exports.setup = function() { var sqlite = require('sqlite3'); var db = new sqlite.Database('database.sql'); db.serialize(function() { db.run('CREATE TABLE IF NOT EXISTS pings (timestamp BIGINT NOT NULL, ip TINYTEXT, playerCount MEDIUMINT)'); db.run('CREATE INDEX IF NOT EXISTS ip_index ON pings (ip, playerCount)'); db.run('CREATE INDEX IF NOT EXISTS timestamp_index on PINGS (timestamp)'); }); exports.log = function(ip, timestamp, playerCount) { var insertStatement = db.prepare('INSERT INTO pings (timestamp, ip, playerCount) VALUES (?, ?, ?)'); db.serialize(function() { insertStatement.run(timestamp, ip, playerCount); }); insertStatement.finalize(); }; exports.getTotalRecord = function(ip, callback) { db.all("SELECT MAX(playerCount) FROM pings WHERE ip = ?", [ ip ], function(err, data) { callback(data[0]['MAX(playerCount)']); }); }; exports.queryPings = function(duration, callback) { var currentTime = util.getCurrentTimeMs(); db.all("SELECT * FROM pings WHERE timestamp >= ? AND timestamp <= ?", [ currentTime - duration, currentTime ], function(err, data) { callback(data); }); }; };