chore: Merge pull request #6 from DEVUCP/api

Api to Dev update

Author: DEVUCP

.github/workflows/node.js.yml

@@ -5,14 +5,19 @@ on:
     branches:
       - main
       - 'ci*'
+      - 'front-end'
+      - 'api'
   pull_request:
     branches:
       - main
       - 'ci*'
+      - 'front-end'
+      - 'api'
 
 jobs:
   test-api-linux:
     name: API Test (Linux)
+    if: github.ref_name == 'api' || (github.ref_name != 'api' && github.ref_name != 'front-end')
     runs-on: ubuntu-latest
 
     strategy:
@@ -35,6 +40,7 @@ jobs:
 
   test-frontend-linux:
     name: Frontend Test (Linux)
+    if: github.ref_name == 'front-end' || (github.ref_name != 'api' && github.ref_name != 'front-end')
     runs-on: ubuntu-latest
 
     strategy:
@@ -57,6 +63,7 @@ jobs:
 
   test-api-windows:
     name: API Test (Windows)
+    if: github.ref_name == 'api' || (github.ref_name != 'api' && github.ref_name != 'front-end')
     runs-on: windows-latest
 
     strategy:
@@ -79,6 +86,7 @@ jobs:
 
   test-frontend-windows:
     name: Frontend Test (Windows)
+    if: github.ref_name == 'front-end' || (github.ref_name != 'api' && github.ref_name != 'front-end')
     runs-on: windows-latest
 
     strategy:

api/app.js

@@ -0,0 +1,29 @@
+const express = require('express');
+const cors = require('cors');
+const { limiter } = require('./middleware/limiter.middleware');
+
+const app = express();
+
+const adminRoutes = require('./routes/admin.routes');
+const serverRoutes = require('./routes/server.routes');
+const propertiesRoute = require('./routes/properties.routes');
+const installationsRoutes = require('./routes/installations.routes');
+const infoRoutes = require('./routes/info.routes');
+
+app.use(cors());
+app.use(limiter)
+app.use(express.json());
+
+app.use('/server', serverRoutes);
+app.use('/installations', installationsRoutes);
+app.use('/properties', propertiesRoute);
+app.use('/info', infoRoutes);
+app.use('/admin', adminRoutes);
+
+app.get('/ping', async (req, res) => {
+    res.send(`pong`);
+});
+
+module.exports = {
+    app
+}

api/cleaner.js

@@ -1,12 +1,9 @@
-
 let cleanup_done = false;
-const networkingUtils = require('./utils/networkingUtils');
-const configUtils = require('./utils/configUtils');
+const networkingUtils = require('./utils/networking.util');
+const configUtils = require('./utils/config.util');
 const debug = configUtils.getConfigAttribute("debug");
 
-
 async function cleanup() {
-
     if(debug){
         console.log("\nDebug mode is turned on\n Skipping cleanup tasks...\n if you don't intend this, change 'debug' from true to false in server-config.json");
         console.log("====== API TERMINATED! ======");
@@ -27,20 +24,17 @@ async function cleanup() {
 }
 
 process.on('exit', () => {
-    if (!cleanup_done) {
+    if (!cleanup_done) 
         cleanup();
-    }
 });
 
-process.on('SIGINT', async () => {
+async function handleExit() {
     await cleanup();
     process.exit(0);
-});
+}
 
-process.on('SIGTERM', async () => {
-    await cleanup();
-    process.exit(0);
-});
+process.on('SIGINT', handleExit);
+process.on('SIGTERM', handleExit);
 
 process.on('uncaughtException', async (err) => {
     console.error('Uncaught Exception:', err);

api/consts.js

@@ -14,6 +14,11 @@ const configFilePath = "./server-config.json";
 const eulaFilePath = `${serverDirectory}/eula.txt`;
 const upnpcPath = '/upnpc';
 
+const serverStatus = {
+    OFFLINE: 0,
+    RUNNING: 1,
+    STARTING: 2
+};
 
 module.exports = {
     serverDirectory,
@@ -29,4 +34,5 @@ module.exports = {
     serverBannedIPsPath,
     keysJSONPath,
     eulaFilePath,
+    serverStatus
 };

api/controllers/info.controller.js

@@ -0,0 +1,86 @@
+const propertiesService = require('../services/properties.service');
+const infoService = require('../services/info.service');
+const serverService = require('../services/server.service');
+const consts = require('../consts');
+
+async function playerCount(req, res) {
+    try {
+        const playerCount = await propertiesService.getOnlinePlayers();
+
+        res.status(200).send({ playerCount: playerCount });
+    } catch(error) {
+        console.error(error);
+        res.status(500).send("error.. " + error.message);
+    }
+}
+
+async function getUpTime(req, res) {
+    try {
+        
+        res.status(200).send(await infoService.getUpTime());
+    } catch (error) {
+        console.error(error);
+        res.status(500).send("error.. " + error.message);
+    }
+}
+
+async function getMemoryUsage(req, res) {
+    try {
+        let serverProcess = serverService.getServerProcess();
+        res.status(200).send(await infoService.getMemoryUsage(serverProcess));
+    } catch (error) {
+        console.error(error);
+        res.status(500).send("error.. " + error.message);
+    }
+}
+
+async function getWorldSize(req, res) {
+    try {
+        let worldSize = await infoService.getDirectorySize(consts.serverDirectory + "/world");
+        res.status(200).send({ worldSize: `${worldSize.toFixed(2)}MB` });
+    } catch (error) {
+        console.error(error);
+        res.status(500).send("error.. " + error.message);
+    }
+}
+
+async function getVersion(req, res) {
+    try {
+        let version = infoService.getVersion(consts.serverDirectory + "/" + consts.serverName);
+        res.status(200).send({ version: version });
+    } catch (error) {
+        console.error(error);
+        res.status(500).send("error.. " + error.message);
+    }
+}
+
+async function getPlatform(req, res) {
+    try {
+        let platform = infoService.getPlatform(consts.serverDirectory + "/" + consts.serverName);
+        res.status(200).send({ platform: platform });
+    } catch (error) {
+        console.error(error);
+        res.status(500).send("error.. " + error.message);
+    }
+}
+
+async function getAllInfo(req, res) {
+    try {
+        let serverProcess = serverService.getServerProcess();
+        let jarPath = consts.serverDirectory + "/" + consts.serverName
+        res.status(200).send(await infoService.getInfo(serverProcess, jarPath, consts.serverDirectory));
+    } catch (error) {
+        console.error(error);
+        res.status(500).send("error.. " + error.message);
+    }
+}
+
+module.exports = {
+    playerCount,
+    getUpTime,
+    getMemoryUsage,
+    getWorldSize,
+    getVersion,
+    getPlatform,
+    getAllInfo
+}

api/controllers/installations.controller.js

@@ -0,0 +1,25 @@
+const installationsService = require('../services/installations.service');
+const { updateConfigAttribute } = require('../utils/config.util');
+const { Sema } = require('async-sema');
+
+const downloadSema = new Sema(1);
+
+async function downloadServer(req, res) {
+    await downloadSema.acquire();   
+     
+    try {
+        await installationsService.downloadRouter(req.params.platform, req.params.version);
+        res.status(201).send('Downloaded Successfully');
+
+        updateConfigAttribute("platform", req.params.platform);
+        updateConfigAttribute("version", req.params.version);
+    } catch (error) {
+        res.status(500).send(`Error downloading server files: ${error}`);
+    } finally{
+        downloadSema.release();
+    }
+}
+
+module.exports = {
+    downloadServer
+}