app.js

require("dotenv").config();

const express = require("express");
const app = express();

const cors = require("cors");
const bodyParser = require("body-parser");
const compression = require('compression');
const swaggerUi = require("swagger-ui-express");
const swaggerDocument = require("./swagger.json");

const db = require("./config/db");
const jobs = require("./jobs/task");
const port = process.env.PORT || 8080;

const userRouter = require("./routes/userRoute");
const stakingRouter = require("./routes/stakingRoute");
const eventRouter = require("./routes/eventRoute");
const vaultRouter = require("./routes/vaultRoute");
const reimbursementRouter = require("./routes/reimbursementRouter");
const partnerRouter = require("./routes/partnershipRoute");
const v2Router = require('./routes/v2Routes');

const { updateCronjobNotInExecution } = require("./models/cronjob.model");

async function init() {
    // Improve debugging
    process.on("unhandledRejection", (reason, p) => {
        console.log("Unhandled Rejection at:", p, "reason:", reason);
    });

    db.connectDB(async (err) => {
        if (err) throw err;

        // Update cronjob in collection as not in execution after restart
        await updateCronjobNotInExecution();

        jobs.saveVault();
        jobs.saveVaultAPY();
        jobs.savePolygonVaultAPY();
        jobs.saveBSCVaultAPY();
        jobs.saveAvalancheVaultAPY();
        jobs.savePricePerFullShare();
        jobs.saveHistoricalAPY();
        jobs.savePolygonHistoricalAPY();
        jobs.saveBSCHistoricalAPY();
        jobs.saveAvalancheHistoricalAPY();
        jobs.saveHistoricalTVL();
        jobs.saveHistoricalPools();
        jobs.saveDAOmineHistoricalPools();
        jobs.saveABIPools();
        jobs.saveVipApr();
        jobs.savePerformance();
        jobs.saveTokenPrice();
        jobs.saveTotalDepositedAmount();
    });

    app.use(cors());
    app.use(compression())
    app.use(
        bodyParser.urlencoded({
            extended: true,
        })
    );
    app.use(bodyParser.json());
    app.use(compression())


    app.use("/api-docs", swaggerUi.serve, swaggerUi.setup(swaggerDocument));
    app.use("/user", userRouter);
    app.use("/staking", stakingRouter);
    app.use("/event", eventRouter);
    app.use("/vaults", vaultRouter);
    app.use("/v2", v2Router);
    app.use("/reimbursement-addresses", reimbursementRouter);
    app.use("/partner", partnerRouter);

    app.listen(port, () => console.log(`Listening on ${port}`));
}

init();