server.js

// -----------------------------------------------------------------------------------------------------------------------
// LOAD APP CONFIG ( FTP TOKEN,CLOUDINARY TOKEN,MYSQL TOKEN, etc ...)- ON CHARGE LA CONFIGURATION DE L'APP
// -----------------------------------------------------------------------------------------------------------------------
const config = require("./config.json");

// -----------------------------------------------------------------------------------------------------------------------
// LOAD OFFICIAL NODE MODULES - CHARGEMENT DES MODULES NODES ...
// -----------------------------------------------------------------------------------------------------------------------
const express = require("express");
const cors = require("cors");
const path = require("path");
const serveStatic = require("serve-static");
const session = require("express-session");
const bcrypt = require("bcryptjs");
const fs = require("fs");
const logStream = fs.createWriteStream(config.logs_path, { flags: "a" });
const Sequelize = require("sequelize"); // Relational DBS
// Require the sequelize-router middleware and any models to be used
const mysql = require("mysql");
const sequelizeRouter = require('sequelize-router');
const promises_mysql = require("mysql2/promise");
const system = require("system-commands");

// -----------------------------------------------------------------------------------------------------------------------
// THIS IS AN EXPRESS APP
// -----------------------------------------------------------------------------------------------------------------------
var app = express();

// -------------------------------
// MANAGING SERVER PORT - GESTION DES PORTS
// -------------------------------
const port = process.env.PORT || 80;

// -----------------------------------------------------------------------------------------------------------------------
// CORS - GESTION DE LA PROTECTION CORS
// -----------------------------------------------------------------------------------------------------------------------
if (port == 80) {
    // LOCALHOST AND OPENODE
    app.use(
        require("cors")({
            origin: function(origin, callback) {
                callback(null, origin);
            },
            credentials: true
        })
    );
} else {
    // AZURE AND HEROKU
    app.use(cors());
}
// -----------------------------------------------------------------------------------------------------------------------
// OTHER RELATED PORTS FUNCTIONS  (CONNEXION TO OTHERS DATABASE IF LOCALHOST)
// -----------------------------------------------------------------------------------------------------------------------
if (port == 80) {
    // LOCALHOST AND OPENODE
    // mysql_crud_routes_generation();
} else {
    // It's heroku, so we need this to hide credentials:
    get_heroku_env_vars();
}

// -----------------------------------------------------------------------------------------------------------------------
// USING SESSIONS - UTILISATION DES SESSIONS
// -----------------------------------------------------------------------------------------------------------------------
app.use(session({ secret: "ssshhhhh", saveUninitialized: true, resave: true }));

// -----------------------------------------------------------------------------------------------------------------------
// MANAGING FILES AND STATICS DIRECTORIES
// -----------------------------------------------------------------------------------------------------------------------
// VUE APP DIRECTORY ( GENERATED WITH NPM RUN BUILD ) // SERVING THE VUE.JS APP
app.use(serveStatic(__dirname + "/dist"));
// UPLOADS : IMAGES STORING DIRECTORY
app.use(express.static(__dirname + "/tmp"));
// UPLOADS : FILES STORING DIRECTORY
app.use(express.static(__dirname + "/tmp/files"));

// -----------------------------------------------------------------------------------------------------------------------
// MANAGING JSON AND BODY PARSER PARAMS
// -----------------------------------------------------------------------------------------------------------------------
const bodyParser = require("body-parser");
app.use(
    bodyParser.urlencoded({
        extended: true,
        limit: "50mb"
    })
);
// create application/json parser
const jsonParser = bodyParser.json();
app.use(
    bodyParser.json({
        limit: "50mb",
        inflate: true,
        strict: false
    })
);
// ------------------------------------
// LOAD PERSONAL MIDDLEWARE FUNCTIONS - On charge le MIDDLEWARE , un système de controle de permissions sur les web services
// -------------------------------
// const middleware = require("./app_system/middleware.js");


// -----------------------------------------------------------------------------------------------------------------------
//                                          RELATIONAL DATABASES  (MYSQL,SQLITE)
// -----------------------------------------------------------------------------------------------------------------------


// ------------------------------------
// CLASSICAL MYSQL PARAMS
// -------------------------------
const mysql_token = {
    user: config.mysql.user,
    password: config.mysql.password,
    host: config.mysql.host,
    database: config.mysql.db_name,
};

// ------------------------------------
// SEQUELIZE PARAMS
// -------------------------------

if (config.chosen_db.name === "mysql") {
    var sequelize = new Sequelize(config.mysql.db_name, config.mysql.user, config.mysql.password, {
        dialect: config.mysql.dialect,
        host: config.mysql.host,
        port: config.mysql.port,
        pool: {
            max: 5,
            min: 0,
            idle: 10000,
        },
    });
} else if (config.chosen_db.name === "sqlite") {
    var sequelize = new Sequelize({
        dialect: "sqlite",
        storage: config.sqlite.storage_path
    });
}



/*
 * Connection using CLASSICAL MYSQL
 * @params db
 * @return none
 * @error  none
 */
function mysql_connection() {
    const connection = mysql.createConnection(mysql_token);
    connection.connect(function(error) {
        if (!!error) {
            console.log(error);
        } else {
            console.log("Connected to the Mysql db using mysql module!:)");
        }
    });
}


/*
 * Connection using sequelize module
 * @params sequelize
 * @return none
 * @error  none
 */
async function sequelize_connection(sequelize) {

    await sequelize
        .authenticate()
        .then(() => {
            console.log("Sequelize connection OK.");
        })
        .catch((err) => {
            console.error("Unable to connect to the database:", err);
        });
}


/*
 * Authentication using mysql module
 * @params connection
 * @return none
 * @error  none
 */
async function load_auth(connection) {
    await require("./app_system/auth.js")(app, session, bcrypt, logStream, connection);
}


/*
 * Import Generated Sequelize data models.
 * See : https://github.com/sequelize/sequelize-auto 
 * // MYSQL Example command : sequelize-auto -o "./models" -d circle_time_kita21595270252 -h localhost -u root -p 3306 x -x password -e mysql
 * // SQLITE COMMAND EXAMPLE :sequelize-auto -h localhost -u dontcare -d data.sqlite  --dialect sqlite
 * https://stackoverflow.com/questions/33324887/sequelize-auto-for-sqlite
 * @params none
 * @return none
 * @error  none
 */
async function import_models() {
    var initModels = require("./models/init-models").initModels;
    var models = await initModels(sequelize);
    generate_routes(models);
    jointure_query_test_from_server(models);
}


/*
 * Generate REST routes Using the generic mysql back end generic_crud_mysql.js
 * @params models
 * @return none
 * @error  none
 */
async function generate_routes(models) {

    await Object.keys(models).forEach(function(key) {
        var my_model = eval("models." + key)
        app.use(
            "/api/" + key, require("./cruds/generic_crud_mysql.js")(express, sequelize, my_model, middleware, models)
        );
    })
}


/*
 * Testing sequelize jointures from the server
 * @params models
 * @return none
 * @error  none
 */
function jointure_query_test_from_server(models) {

    models.employees.findAll({
        include: [{
            model: models.offices, // Joigning office table, thank to  employees.belongsTo(offices, { foreignKey: 'officeCode' }); in init-models.js
            required: true
        }],
        where: { id: 2 } // Getting employee who has id number 2
    }).then(employees => {
        console.log(JSON.stringify(employees)) // JOINTURES ON OFFICES IS WORKING AND WE CAN SEE WHICH OFFICE DETAIL HE BELONGS TO
    });

}

/*
 * Creating the database from sequelize models
 * !!! Warning : all existing database content will get erased !!!
 * @params models
 * @return none
 * @error  none
 */
function create_db_from_sequelize_models() {
    // sequelize.sync({ force: true })
}




// -------------------------------------------------------------------------------------------------------------------------
//                                              CALL FUNCTIONS
// -------------------------------------------------------------------------------------------------------------------------

sequelize_connection(sequelize);
import_models();


// -------------------------------------------------------------------------------------------------------------------------
//                                              OTHERS API TESTINGS
// -------------------------------------------------------------------------------------------------------------------------
/* XMYSQL 
 * Create all Mysql DB Cruds and Routes  automatically from an existing database HIIK !! - See https://github.com/o1lab/xmysql
 * Crée toutes les routes ( Post, Put, Delete, Read) et cruds NODE EXPRESS automatiquement, à partir d'une database MYSQL existante !
 * No need to write generic back ends .
 *  GET 	/ 	Gets all REST APIs
    GET 	/api/tableName 	Lists rows of table
    POST 	/api/tableName 	Create a new row
    PUT 	/api/tableName 	Replaces existing row with new row
    POST 🔥 /api/tableName/bulk 	Create multiple rows - send object array in request body
    GET 🔥 	/api/tableName/bulk 	Lists multiple rows - /api/tableName/bulk?_ids=1,2,3
    DELETE 🔥 /api/tableName/bulk 	Deletes multiple rows - /api/tableName/bulk?_ids=1,2,3
 * @params config.json
 * @return none
 * @error  none
 */
async function mysql_crud_routes_generation() {
    system(
            "xmysql -h " +
            config.mysql.host +
            " -u " +
            config.mysql.user +
            " -p " +
            config.mysql.password +
            " -n 3000  -d " +
            config.mysql.name
        )
        .then(output => {
            console.log(output);
            write_connexion_to_logs();
        })
        .catch(error => {
            console.error(error);
        });
    // -------------------------------
    // PROXY ALL API ROUTES QUERIES TO PORT 3000 TO USE WITH MYSQL ROUTES GENERATOR https://stackoverflow.com/questions/10435407/proxy-with-express-js
    // -------------------------------
    var proxy = require("express-proxy-server");
    app.use("xmysql/api", proxy("http://localhost:3000/api"));
}

/*
 * Connect sqlite using sequelize
 * @params db
 * @return none
 * @error  none
 */
function connect_sqlite() {
    const sequelize = new Sequelize({
        dialect: "sqlite",
        storage: "db/database.sqlite",
    });
    sequelize
        .authenticate()
        .then(() => {
            console.log("Connection to SQLITE has been established successfully.");
        })
        .catch((err) => {
            console.error("Unable to connect to the database:", err);
        });
}


// -------------------------------
// HELPER FUNCTIONS
// -------------------------------
/*
 * Write db connexion to logs file - On journalise la connexion
 * @params none
 * @return none
 * @error  none
 */
function write_connexion_to_logs() {
    var d = new Date(Date.now());
    logStream.write("DB CONNEXION AT " + d.toString() + "\r\n");
    // logStream.end(''); TODO
}


/*
 * HEROKU ENV VARS : NEEDED TO HIDE ALL CREDENTIALS IN A HEROKU / GITHUB ENV .
 * On récupère nos mots de passe des variables d'environnement stockés sur heroku, sinon, tout le monde verrait nos mots de passe .
 * @params none
 * @return none
 * @error  none
 */
function get_heroku_env_vars() {
    config.cloudinary_token.api_secret = process.env.cloudinary_password;
}


// -------------------------------
// STARTING NODE SERVER
// -------------------------------
app.listen(port);
console.log("server started " + port);