resolve #56

.gitignore

@@ -1,3 +1,4 @@
 .idea
 .vscode
 node_modules
+dumps/

backend/package.json

@@ -18,6 +18,8 @@
         "axios": "^1.4.0",
         "bcryptjs": "^2.4.3",
         "cors": "^2.8.5",
+        "cron": "^3.1.7",
+        "cross-spawn": "^7.0.3",
         "date-fns": "^2.30.0",
         "dotenv": "^16.0.3",
         "fastify": "^4.17.0",

backend/src/cronjob.ts

@@ -0,0 +1,19 @@
+import { CronJob } from "cron";
+import { dumpDatabase, removeOldDumps } from "@/utils/database";
+
+
+export const dumpDatabaseJob = CronJob.from({
+    start: false, 
+    cronTime: "0 0 4 * * *",
+    onComplete: null,
+    onTick: dumpDatabase,
+    timeZone: "Europe/Paris"
+});
+
+export const deleteOldDumpJob = CronJob.from({
+    start: false, 
+    cronTime: "0 30 4 * * *",
+    onComplete: null,
+    onTick: removeOldDumps,
+    timeZone: "Europe/Paris"
+});

backend/src/server.ts

@@ -8,6 +8,9 @@ import APIHandler from "@/api";
 import StaticHandler from "@/static";
 import UploadHandler from "@/upload";
 import PageHandler from "@/page";
+import * as cron from "@/cronjob";
+
+
 //import NotFoundHandler from "@/notFound";
 
 async function init() {
@@ -50,3 +53,6 @@ process.on("SIGINT", async function() {
     await closeDatabase();
     process.exit(1);
 });
+
+cron.dumpDatabaseJob.start();
+cron.deleteOldDumpJob.start();

backend/src/utils/database.ts

@@ -0,0 +1,28 @@
+import { promises as pfs } from "node:fs";
+import * as cs from "cross-spawn";
+
+const BACKUP_RETENTION_DAYS = 30;
+
+export async function dumpDatabase() {
+    const dumpDate = new Date().toLocaleDateString("fr-fr",{ day: "2-digit", month: "2-digit", year: "numeric" }).replaceAll("/", "-");
+    const folderName = `../dumps/${ dumpDate }`;
+    await pfs.mkdir(folderName, { recursive: true });
+
+    const child = cs.spawn("mongodump", ["--db", "sgnw", "--out", `../dumps/${ dumpDate }`], { stdio: "inherit" });
+}
+
+export async function removeOldDumps() {
+    const currentDate = new Date();
+    const folderName = "../dumps/";
+
+    const dirs = await pfs.readdir(folderName,{ encoding: "utf-8" });
+    dirs.forEach(async (dir) => {
+        const [day, month, year] = dir.split("-").map(Number);
+        const dumpDate = new Date(year, month - 1, day);
+        const Difference_In_Days = Math.floor((currentDate.getTime() - dumpDate.getTime()) / (1000 * 3600 * 24));
+
+        if (Difference_In_Days > BACKUP_RETENTION_DAYS) {
+            pfs.rm(`${ folderName }/${ dir }`, { recursive: true }); 
+        }
+    });
+}

backend/tsconfig.json

@@ -24,4 +24,4 @@
     "exclude": [
         "node_modules"
     ]
-}
+}