feat(api): Delete old files when

Author: OmarSherif06

api/controllers/installations.controller.js

@@ -5,8 +5,8 @@ const { Sema } = require('async-sema');
 const downloadSema = new Sema(1);
 
 async function downloadServer(req, res) {
-    await downloadSema.acquire();
-    
+    await downloadSema.acquire();   
+     
     try {
         await installationsService.downloadRouter(req.params.platform, req.params.version);
         res.status(201).send('Downloaded Successfully');

api/services/info.service.js

@@ -2,6 +2,7 @@ const fs = require('fs');
 const path = require('path');
 const pidusage = require('pidusage')
 const AdmZip = require('adm-zip');
+const consts = require('../consts');
 
 let startTime = null;
 
@@ -56,7 +57,7 @@ function getDirectorySize(folderPath) {
     return sizeInMB;
   }
 
-function getPlatform(jarPath) {
+function getPlatform(jarPath = consts.serverDirectory + "/" + consts.serverName) {
   const zip = new AdmZip(jarPath);
   const entries = zip.getEntries();
   const names = entries.map(e => e.entryName);
@@ -115,9 +116,8 @@ function getVersion(jarPath) {
 }
 
 async function getUpTime() {
-  if (getStartTime() === null) {
+  if (getStartTime() === null) 
       return { uptime: "0s" };
-  }
 
   const ms = Date.now() - getStartTime();
 
@@ -139,7 +139,6 @@ async function getInfo(serverProcess, jarPath, folderPath) {
   let platform = null;
   let version = null;
   let directorySizeMB = null;
-  let uptimeMs = null;
 
   try {
       memoryUsage = await getMemoryUsage(serverProcess);

api/services/installations.service.js

@@ -1,10 +1,55 @@
 const urlFetcher = require("../utils/url_fetcher.util");
+const infoService = require('../services/info.service');
+const consts = require('../consts');
 const { writeDownloadedFile } = require("../utils/installations.util");
+const fs = require('fs/promises');
+const path = require('path');
+
+const preserveList = [
+    "world",
+    "world_nether",
+    "world_the_end",
+    "banned-ips.json",
+    "banned-players.json",
+    "ops.json",
+    "whitelist.json"
+];
+  
+async function purgeServer(preserveList) {
+    let folderPath = consts.serverDirectory;
+    try {
+        const entries = await fs.readdir(folderPath, { withFileTypes: true });
+
+        for (const entry of entries) {
+            if (preserveList.includes(entry.name)) continue;
+
+            const fullPath = path.join(folderPath, entry.name);
+            if (entry.isDirectory())
+                await fs.rm(fullPath, { recursive: true, force: true });
+            else
+                await fs.unlink(fullPath);
+        }
+
+        console.log(`Deleted everything in ${folderPath} except preserved items.`);
+    } catch (err) {
+        console.error(`Error cleaning folder ${folderPath}:`, err.message);
+    }
+}
 
 async function downloadRouter(platform, version) {
+    const oldPlatform = infoService.getPlatform();
+    
+    const comingFromModded = oldPlatform === "fabric" || oldPlatform === "forge";
+    const currentPreserveList = comingFromModded
+    ? preserveList.slice(3) // delete worlds
+    : preserveList;         // keep everything
+    
+    if (oldPlatform != platform)
+        await purgeServer(currentPreserveList);
+    
     let response;
     try {
-        switch(platform) {
+        switch (platform) {
             case "vanilla":
                 response = await fetch(await urlFetcher.fetchVanillaURL(version));
                 break;
@@ -17,9 +62,10 @@ async function downloadRouter(platform, version) {
             case "forge":
                 response = await fetch(await urlFetcher.fetchForgeURL(version));
                 break;
-            case _:
-                throw new Error(`Invalid platform --> ${platform}`)
+            default:
+                throw new Error(`Invalid platform --> ${platform}`);
         }
+
         await writeDownloadedFile(response, version, platform.toUpperCase());
     } catch (error) {
         console.error(error);