myspeed/server/controller/speedtests.js

const db = require('../index').database;

// Inserts a new speedtest into the database
module.exports.create = (ping, download, upload) => {
    return db.prepare("INSERT INTO speedtests (ping, download, upload, created) VALUES (?, ?, ?, ?)").run(ping, download, upload,
        new Date().toISOString()).lastInsertRowid;
}

// Gets a specific speedtest by id
module.exports.get = (id) => {
    return db.prepare("SELECT * FROM speedtests WHERE id = ?").get(id);
}

// Lists all speedtests from the database
module.exports.list = () => {
    return db.prepare("SELECT * FROM speedtests ORDER BY created DESC").all();
}

// Gets the latest speedtest from the database
module.exports.latest = () => {
    return db.prepare("SELECT * FROM speedtests ORDER BY id DESC").get();
}

// Deletes a specific speedtest
module.exports.delete = (id) => {
    if (this.get(id) === undefined) return undefined;
    db.prepare("DELETE FROM speedtests WHERE id = ?").run(id);
    return true;
}

// Removes speedtests older than 24 hours
module.exports.removeOld = () => {
    db.prepare("DELETE FROM speedtests WHERE created <= date('now','-1 day')").run();
    return true;
}