refactor: remove schedule.toml

.gitignore

@@ -1,6 +1,5 @@
 # App config files
 .env
-schedule.toml
 
 # Finder config file
 .DS_Store

app.mjs

@@ -20,6 +20,14 @@ const pluginPromises = [
     loadDatabase(),
 ];
 
+// Define schedule tasks
+const scheduleTasks = [{
+    name: "refresh",
+    config: {
+        time: "0 6 * * *",
+    },
+}];
+
 // Define router names
 const routerNames = [
     "root",
@@ -40,6 +48,7 @@ const displayStatus = (protocolStatus) => {
 // Mount application and execute it
 invokeApp().
     loadPromises(pluginPromises).
+    loadTasks(scheduleTasks).
     loadRoutes(routerNames).
     execute().
     then(displayStatus);

package.json

@@ -27,8 +27,7 @@
     "http-status-codes": "^2.2.0",
     "node-cache": "^5.1.2",
     "node-schedule": "^2.1.1",
-    "request-ip": "^3.3.0",
-    "toml": "^3.0.0"
+    "request-ip": "^3.3.0"
   },
   "devDependencies": {
     "@commitlint/cli": "^17.4.4",

src/execute.mjs

@@ -16,7 +16,6 @@ import {
 } from "./init/express.mjs";
 
 import {
-    readScheduleMap,
     startScheduleTasks,
 } from "./init/schedule.mjs";
 
@@ -64,6 +63,7 @@ async function setupHttpsProtocol(app) {
 export function invokeApp() {
     return {
         loadPromises,
+        loadTasks,
         loadRoutes,
         execute,
     };
@@ -72,6 +72,9 @@ export function invokeApp() {
 // Define preparing promises
 const preparingPromises = [];
 
+// Define preparing tasks
+const scheduleTasks = [];
+
 /**
  * Load promises to be executed before running the application.
  * @param {Promise[]} promises the promises to load
@@ -86,6 +89,20 @@ function loadPromises(promises) {
     return invokeApp();
 }
 
+/**
+ * Load tasks to be executed before running the application.
+ * @param {object[]} tasks the tasks to load
+ * @return {object} the application invoker
+ */
+function loadTasks(tasks) {
+    if (tasks.length < 1) {
+        return invokeApp();
+    }
+
+    scheduleTasks.push(...tasks);
+    return invokeApp();
+}
+
 /**
  * Load routes from specified router names.
  * @param {string[]} routerNames the names of the routers to load
@@ -115,8 +132,7 @@ async function execute() {
     await Promise.all(preparingPromises);
 
     // Start schedule tasks
-    readScheduleMap();
-    startScheduleTasks();
+    await startScheduleTasks(scheduleTasks);
 
     // Get enabled protocols
     const enabledProtocols = getSplited("ENABLED_PROTOCOLS");

src/init/schedule.mjs

@@ -1,42 +1,14 @@
 // node-schedule is a flexible cron-like and not-cron-like job scheduler.
 
 // Import modules
-import {
-    existsSync,
-    readFileSync,
-} from "node:fs";
-
-import {
-    parse as parseTOML,
-} from "toml";
-
 import schedule from "node-schedule";
 
-export const scheduleMap = {};
-
-/**
- * Reads the schedule.toml file and returns a parsed map of the contents.
- */
-export async function readScheduleMap() {
-    const mapFilename = new URL("../../schedule.toml", import.meta.url);
-    if (!existsSync(mapFilename)) {
-        throw Error("schedule.toml not exists");
-    }
-
-    const mapFileContent = readFileSync(mapFilename, "utf-8");
-    if (!mapFileContent) {
-        throw Error("schedule.toml is invalid");
-    }
-
-    const srcMap = parseTOML(mapFileContent);
-    Object.assign(scheduleMap, srcMap);
-}
-
 /**
  * Starts the schedule tasks.
+ * @param {object[]} tasks the tasks to load
  */
-export async function startScheduleTasks() {
-    for (const [methodName, methodConfig] of Object.entries(scheduleMap)) {
+export async function startScheduleTasks(tasks) {
+    for (const {name: methodName, config: methodConfig} of tasks) {
         const methodDirectory = new URL("../tasks/", import.meta.url);
         const methodFilename = new URL(`${methodName}.mjs`, methodDirectory);