sync/lib/database/tables.js

const TBL_USERS = "" +
    "CREATE TABLE IF NOT EXISTS `users` (" +
        "`id` INT NOT NULL AUTO_INCREMENT," +
        "`name` VARCHAR(20) NOT NULL," +
        "`password` VARCHAR(64) NOT NULL," +
        "`global_rank` INT NOT NULL," +
        "`email` VARCHAR(255) NOT NULL," +
        "`profile` TEXT NOT NULL," +
        "`ip` VARCHAR(39) NOT NULL," + "`time` BIGINT NOT NULL," +
        "PRIMARY KEY(`id`)," +
        "UNIQUE(`name`)) " +
    "CHARACTER SET utf8";

const TBL_CHANNELS = "" +
    "CREATE TABLE IF NOT EXISTS `channels` (" +
        "`id` INT NOT NULL AUTO_INCREMENT," +
        "`name` VARCHAR(30) NOT NULL," +
        "`owner` VARCHAR(20) NOT NULL," +
        "`time` BIGINT NOT NULL," +
        "PRIMARY KEY (`id`), UNIQUE(`name`), INDEX(`owner`))" +
    "CHARACTER SET utf8";

const TBL_GLOBAL_BANS = "" +
    "CREATE TABLE IF NOT EXISTS `global_bans` (" +
        "`ip` VARCHAR(39) NOT NULL," +
        "`reason` VARCHAR(255) NOT NULL," +
    "PRIMARY KEY (`ip`)) " +
    "CHARACTER SET utf8";

const TBL_PASSWORD_RESET = "" +
    "CREATE TABLE IF NOT EXISTS `password_reset` (" +
        "`ip` VARCHAR(39) NOT NULL," +
        "`name` VARCHAR(20) NOT NULL," +
        "`hash` VARCHAR(64) NOT NULL," +
        "`email` VARCHAR(255) NOT NULL," +
        "`expire` BIGINT NOT NULL," +
        "PRIMARY KEY (`name`))" +
    "CHARACTER SET utf8";

const TBL_USER_PLAYLISTS = "" +
    "CREATE TABLE IF NOT EXISTS `user_playlists` (" +
        "`user` VARCHAR(20) NOT NULL," +
        "`name` VARCHAR(255) NOT NULL," +
        "`contents` MEDIUMTEXT NOT NULL," +
        "`count` INT NOT NULL," +
        "`duration` INT NOT NULL," +
        "PRIMARY KEY (`user`, `name`))" +
    "CHARACTER SET utf8";

const TBL_ALIASES = "" +
    "CREATE TABLE IF NOT EXISTS `aliases` (" +
        "`visit_id` INT NOT NULL AUTO_INCREMENT," +
        "`ip` VARCHAR(39) NOT NULL," +
        "`name` VARCHAR(20) NOT NULL," +
        "`time` BIGINT NOT NULL," +
        "PRIMARY KEY (`visit_id`), INDEX (`ip`)" +
    ")";

const TBL_STATS = "" +
    "CREATE TABLE IF NOT EXISTS `stats` (" +
        "`time` BIGINT NOT NULL," +
        "`usercount` INT NOT NULL," +
        "`chancount` INT NOT NULL," +
        "`mem` INT NOT NULL," +
        "PRIMARY KEY (`time`))" +
    "CHARACTER SET utf8";

const TBL_META = "" +
    "CREATE TABLE IF NOT EXISTS `meta` (" +
        "`key` VARCHAR(255) NOT NULL," +
        "`value` TEXT NOT NULL," +
        "PRIMARY KEY (`key`))" +
    "CHARACTER SET utf8";

module.exports.init = function (queryfn, cb) {
    var tables = {
        users: TBL_USERS,
        channels: TBL_CHANNELS,
        global_bans: TBL_GLOBAL_BANS,
        password_reset: TBL_PASSWORD_RESET,
        user_playlists: TBL_USER_PLAYLISTS,
        aliases: TBL_ALIASES,
        stats: TBL_STATS,
        meta: TBL_META
    };

    var AsyncQueue = require("../asyncqueue");
    var aq = new AsyncQueue();
    var hasError = false;
    Object.keys(tables).forEach(function (tbl) {
        aq.queue(function (lock) {
            queryfn(tables[tbl], function (err) {
                if (err) {
                    console.log(err);
                    hasError = true;
                }
                lock.release();
            });
        });
    });

    aq.queue(function (lock) {
        lock.release();
        cb(hasError);
    });
};

module.exports.createChannelTables = function (name, queryfn, cb) {
    var createRanksTable = function () {
        queryfn("CREATE TABLE `chan_" + name + "_ranks` (" +
                    "`name` VARCHAR(20) NOT NULL," +
                    "`rank` INT NOT NULL," +
                "PRIMARY KEY (`name`)) " +
                "CHARACTER SET utf8", createLibraryTable);
    };

    var createLibraryTable = function (err) {
        if (err) {
            cb(err);
            return;
        }
        queryfn("CREATE TABLE `chan_" + name + "_library` (" +
                    "`id` VARCHAR(255) NOT NULL," +
                    "`title` VARCHAR(255) NOT NULL," +
                    "`seconds` INT NOT NULL," +
                    "`type` VARCHAR(2) NOT NULL," +
                "PRIMARY KEY (`id`))" +
                "CHARACTER SET utf8", createBansTable);
    };

    var createBansTable = function (err) {
        if (err) {
            cb(err);
            return;
        }
        queryfn("CREATE TABLE `chan_" + name + "_bans` (" +
                    "`id` INT NOT NULL AUTO_INCREMENT," +
                    "`ip` VARCHAR(39) NOT NULL," +
                    "`name` VARCHAR(20) NOT NULL," +
                    "`bannedby` VARCHAR(20) NOT NULL," +
                    "`reason` VARCHAR(255) NOT NULL," +
                "PRIMARY KEY (`id`), UNIQUE (`name`, `ip`))" +
                "CHARACTER SET utf8", cb);
    };

    createRanksTable();
};