feat: background job scheduling for rating predictions (bull & redis)

Author: SysSn13

background.js

@@ -1,5 +1,23 @@
+const predictQueue = require("./services/job-queues/contestPredictionQueue");
+const jobScheduler = require("./services/job-queues/jobScheduler");
+const { createBullBoard } = require("@bull-board/api");
+const { BullAdapter } = require("@bull-board/api/bullAdapter");
+const { ExpressAdapter } = require("@bull-board/express");
 
+const serverAdapter = new ExpressAdapter();
+
+const { addQueue, removeQueue, setQueues, replaceQueues } = createBullBoard({
+    queues: [new BullAdapter(predictQueue), new BullAdapter(jobScheduler)],
+    serverAdapter: serverAdapter,
+});
+
+serverAdapter.setBasePath("/bull-board");
 
 console.log("background is running...");
-const schedualing = require("./services/scheduling");
-schedualing.fetchAllContests();
+const initScheduler = async () => {
+    await jobScheduler.add({});
+    await jobScheduler.add({}, { repeat: { cron: "0 0 * * *" } });
+};
+initScheduler();
+
+module.exports.bullBoardServerAdapter = serverAdapter;

main.js

@@ -1,6 +1,8 @@
 if (process.env.NODE_ENV !== "production") {
     require("dotenv").config();
 }
+const express = require("express");
+const expressLayouts = require("express-ejs-layouts");
 
 const mongoose = require("mongoose");
 mongoose.connect(process.env.DATABASE_URL, {
@@ -11,14 +13,33 @@ mongoose.set("useFindAndModify", false);
 
 const db = mongoose.connection;
 
+const app = express();
+
 db.on("error", (error) => console.error(error));
 db.once("open", () => {
     console.log("Connected to Mongoose");
+});
 
-    if (process.env.WEB == true) {
-        require("./server");
-    }
-    if (process.env.BACKGROUND == true) {
-        require("./background");
+if (process.env.BACKGROUND == true) {
+    const { bullBoardServerAdapter } = require("./background");
+    app.use("/bull-board", bullBoardServerAdapter.getRouter());
+}
+if (process.env.WEB == true) {
+    const webRouter = require("./server");
+    app.set("view engine", "ejs");
+    app.set("views", __dirname + "/views");
+    app.set("layout", "layouts/layout");
+    app.use(expressLayouts);
+    app.use(express.static("public"));
+    app.use("/", webRouter);
+}
+
+const port = process.env.PORT || 8080;
+
+app.listen(port, (err) => {
+    if (err) {
+        console.error(err);
+        return;
     }
+    console.log("Listening on " + port);
 });