mysqlExporterDeno/index.js

#!/usr/bin/env node
const express = require("express");
const fs = require("fs");
const mysql = require("mysql");
const opn = require('opn');
const app = express();

var apiOnly = false;
if(!fs.existsSync("./config.json")){
    console.error("Config file missing!");
    process.exit(1);
}
if(!fs.existsSync(__dirname + "/static/index.html")){
    console.warn("View is missing, running in API only mode");
    apiOnly = true
}

const config = JSON.parse(fs.readFileSync("./config.json", "utf-8"));
const pool = mysql.createPool(config.mysql);

function query(conn, data, params = []) {
    return new Promise((resolve, reject) => {
        conn.query(data, params, (err, resp, fields) => {
            if(err)return reject(err);
            resolve(resp);
        });
    });
};

if(!apiOnly)
    app.use("/view", express.static('static'))

app.get("/", (req, res) => {
    res.json({
        ping: true,
        notice: "You're probably looking for /view/"
    });
});

app.get("/tables", (req, res) => {
    pool.query("SHOW tables", async (err, resp, fields) => {
        if(err) {
            console.error(err);
            return res.json({
                error: "mysql_conn"
            });
        }
        let result = resp.map(a => {
            return a[Object.keys(a)[0]];
        });

        var obj = {};
        for(var r of result) {
            try {
                obj[r] = await query(pool, "DESCRIBE " + r);
            } catch(e){
                console.error(e);
            }
        }

        res.json(obj);
    })
});

app.listen(8877, "localhost", () => {
    if(!apiOnly)
        opn('http://localhost:8877/view');
    console.log("Listening on port 8877");
});