From 6b796258d413f00e498ce7f80f73a9f6c061f29c Mon Sep 17 00:00:00 2001
From: RaindropsSys <raindrops@equestria.dev>
Date: Sat, 30 Mar 2024 23:40:33 +0100
Subject: Updated 5 files, added 2 files, deleted 495 files and renamed 7 files
 (automated)

---
 daemons/jobs.js | 110 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 110 insertions(+)
 create mode 100644 daemons/jobs.js

(limited to 'daemons/jobs.js')

diff --git a/daemons/jobs.js b/daemons/jobs.js
new file mode 100644
index 0000000..0ca8552
--- /dev/null
+++ b/daemons/jobs.js
@@ -0,0 +1,110 @@
+const fs = require('fs');
+const child_process = require('child_process');
+
+let jobsList = [];
+let jobs = [];
+let history = require('../data/history.json');
+
+fs.writeFileSync("../data/running.json", "null");
+
+setInterval(() => {
+    if (JSON.stringify(fs.readdirSync("../data/jobs")) !== JSON.stringify(jobsList)) {
+        console.log("Updating the jobs list...");
+        jobs = fs.readdirSync("../data/jobs").map((i) => {
+            let obj = JSON.parse(fs.readFileSync("../data/jobs/" + i).toString());
+            obj["_id"] = i;
+            return obj;
+        });
+        jobsList = fs.readdirSync("../data/jobs");
+    }
+}, 1000);
+
+setTimeout(() => {
+    setInterval(() => {
+        if (jobs.length > 0) {
+            let pickup = new Date();
+
+            console.log(jobs.length + " job(s)");
+            console.log("\nRunning jobs:");
+
+            for (let job of jobs) {
+                console.log("    " + job.name + " [" + job._id + "]");
+                let output;
+                let start;
+                let end;
+
+                fs.writeFileSync("../data/running.json", JSON.stringify(job._id));
+
+                try {
+                    start = new Date();
+                    output = child_process.execFileSync("php", [job.name + ".php", JSON.stringify(job.options)], { cwd: "../jobs" });
+                    end = new Date();
+
+                    let runtime = end.getTime() - start.getTime();
+                    let description = "";
+
+                    for (let name of Object.keys(job.options)) {
+                        description = "," + name + "=" + JSON.stringify(job.options[name]);
+                    }
+
+                    fs.unlinkSync("../data/jobs/" + job._id);
+
+                    history.unshift({
+                        completed: true,
+                        error: null,
+                        options: job.options,
+                        name: job.name + "(" + description.substring(1) + ")",
+                        output: output.toString(),
+                        time: runtime,
+                        tracking: {
+                            queue: new Date(job.date).toISOString(),
+                            pickup: pickup.toISOString(),
+                            start: start.toISOString(),
+                            end: end.toISOString(),
+                            logged: new Date().toISOString()
+                        }
+                    });
+
+                    history = history.slice(0, 200);
+                    fs.writeFileSync("../data/history.json", JSON.stringify(history));
+                    fs.writeFileSync("../data/running.json", "null");
+                } catch (e) {
+                    end = start ? new Date() : null;
+                    console.log("    Failed to process job");
+                    console.error(e);
+
+                    let runtime = end ? (start ? end.getTime() - start.getTime() : null) : null;
+                    let description = "";
+
+                    for (let name of Object.keys(job.options)) {
+                        description = "," + name + "=" + JSON.stringify(job.options[name]);
+                    }
+
+                    fs.unlinkSync("../data/jobs/" + job._id);
+
+                    history.unshift({
+                        completed: false,
+                        error: e.stack,
+                        options: job.options,
+                        name: job.name + "(" + description.substring(1) + ")",
+                        output: (output ?? e.stdout ?? e.stderr).toString(),
+                        time: runtime,
+                        tracking: {
+                            queue: new Date(job.date).toISOString(),
+                            pickup: pickup.toISOString(),
+                            start: start ? start.toISOString() : null,
+                            end: end ? end.toISOString() : null,
+                            logged: new Date().toISOString()
+                        }
+                    });
+
+                    history = history.slice(0, 200);
+                    fs.writeFileSync("../data/history.json", JSON.stringify(history));
+                    fs.writeFileSync("../data/running.json", "null");
+                }
+            }
+
+            console.log("\nCompleted");
+        }
+    }, 1000);
+}, 500);
-- 
cgit