create.js

// Database Cache
const db = {};

// Module
module.exports = function (mysql, proxyType, databases, cfg) {
    return new Promise(function (resolve, reject) {

        // Modules
        const util = require('util');
        const clone = require('clone');
        const objType = require('@tinypudding/puddy-lib/get/objType');
        const _ = require('lodash');
        let databaseList = [];

        // Create Settings
        const tinyCfg = _.defaultsDeep({}, cfg, {
            charset: "utf8mb4"
        });

        // Convert
        if (!Array.isArray(databases)) {
            databaseList = [clone(databases)];
        } else {
            databaseList = clone(databases);
        }

        // Run Array
        for (const item in databaseList) {

            // Exist
            if (objType(databaseList[item], 'object') && objType(databaseList[item].data, 'object')) {
                if (!db[databaseList[item].data.database]) {

                    // Charset
                    if (typeof databaseList[item].data.charset !== "string") {
                        databaseList[item].data.charset = tinyCfg.charset;
                    }

                    // Firebase Is Emulator
                    let firebaseIsEmulator = false;
                    if (proxyType === "firebase") {
                        try {
                            firebaseIsEmulator = require('@tinypudding/firebase-lib/isEmulator')();
                        } catch (err) {
                            firebaseIsEmulator = false;
                        }
                    }

                    // Exist Proxy
                    if (!firebaseIsEmulator && typeof proxyType === "string" && proxyType !== "default") {

                        // Google Cloud
                        if (

                            // Validate Type
                            (
                                proxyType === "firebase" ||
                                proxyType === "google_cloud"
                            ) &&

                            // Var
                            objType(databaseList[item].google_cloud, 'object') &&
                            typeof databaseList[item].google_cloud.socketPath === "string"

                        ) {

                            // Insert the config
                            databaseList[item].data.socketPath = databaseList[item].google_cloud.socketPath;

                        }

                        // Nothing
                        else { reject(new Error('Invalid Proxy Type! Index:' + item)); return; }

                    }

                    // Normal Connection
                    else {

                        // SSL Files
                        if (objType(databaseList[item].default.ssl, 'object')) { databaseList[item].data.ssl = databaseList[item].default.ssl; }

                        // Host and Port
                        databaseList[item].data.host = databaseList[item].default.host;
                        databaseList[item].data.port = databaseList[item].default.port;

                    }

                    // Create DB Connection

                    // Complete
                    try {
                        db[databaseList[item].data.database] = mysql.createPool(databaseList[item].data);
                        db[databaseList[item].data.database].query = util.promisify(db[databaseList[item].data.database].query);
                    }

                    // Error
                    catch (err) {
                        reject(err);
                        return;
                    }

                }
            }

            // Nope
            else { reject(new Error('Invalid MySQL Setting! Index:' + item)); return; }

        }

        // Fix
        const dbKets = Object.keys(databaseList);

        // Complete
        if (dbKets.length < 2) {
            resolve(db[databaseList[0].data.database]);
        } else { resolve(db); }
        return;

    });
};