✨ Support for cron jobs

Author: AnandChowdhary

package.json

@@ -1,6 +1,6 @@
 {
   "name": "staart",
-  "version": "1.0.35",
+  "version": "1.0.36",
   "main": "index.js",
   "repository": "git@github.com:AnandChowdhary/staart.git",
   "author": "Anand Chowdhary <mail@anandchowdhary.com>",
@@ -37,6 +37,7 @@
     "@overnightjs/core": "^1.6.9",
     "@types/bcryptjs": "^2.4.2",
     "@types/cors": "^2.8.5",
+    "@types/cron": "^1.7.1",
     "@types/dotenv": "^6.1.1",
     "@types/express": "^4.17.0",
     "@types/express-brute": "^0.0.37",
@@ -81,6 +82,7 @@
     "body-parser": "^1.19.0",
     "client-oauth2": "^4.2.4",
     "cors": "^2.8.5",
+    "cron": "^1.7.1",
     "crypto-random-string": "^3.0.1",
     "express": "^4.17.0",
     "express-async-handler": "^1.1.4",

setup/controllers.js

@@ -15,14 +15,12 @@ controllers.forEach(controller => {
     .toString();
   exportName.push(controllerFile.split("export class ")[1].split(" ")[0]);
 });
-
 const importCode = `${exportName
   .map(
     (e, i) =>
       `import { ${e} } from "./controllers/${controllers[i].split(".ts")[0]}";`
   )
   .join("\n")}`;
-
 const insertCode = `
   // start automatic code
   super.addControllers([${exportName.map(e => `new ${e}()`).join(", ")}]);
@@ -40,7 +38,6 @@ try {
 } catch (error) {
   console.log("✅  Processed no redirect rules");
 }
-
 const redirectCode = `
   ${redirects
     .map(
@@ -57,6 +54,22 @@ server = server.replace("// staart-autogenerated", redirectCode);
 if (redirects.length)
   console.log(`✅  Processed ${redirects.length} redirect rules`);
 
+// Cron jobs
+const crons = fs.readdirSync(path.join(SRC, "crons"));
+const cronImport = crons
+  .map(
+    cronFile =>
+      `import cron_${cronFile.split(".ts")[0]} from "./crons/${
+        cronFile.split(".ts")[0]
+      }";`
+  )
+  .join("\n");
+const cronCode = `
+${crons.map(cronFile => `cron_${cronFile.split(".ts")[0]}();`)}
+`;
+server = cronImport + "\n" + cronCode + "\n" + server;
+if (crons.length) console.log(`✅  Setup ${crons.length} cron jobs`);
+
 // Static files
 recursive(path.join(SRC, "..", "static"))
   .then(files => {

src/crons/daily.ts

@@ -0,0 +1,12 @@
+import { CronJob } from "cron";
+
+export default () => {
+  new CronJob(
+    "0 0 * * *",
+    () => {
+      console.log("Once per day", new Date());
+    },
+    undefined,
+    true
+  );
+};

yarn.lock

@@ -1128,6 +1128,14 @@
   dependencies:
     "@types/express" "*"
 
+"@types/cron@^1.7.1":
+  version "1.7.1"
+  resolved "https://registry.yarnpkg.com/@types/cron/-/cron-1.7.1.tgz#752e47ebbe26e83d9e40f2dd6a3f679f2eec54b8"
+  integrity sha512-48brwgU18DqA0mQX1As5OcJEo1yNjaXMM6Mk4r8K1dOzLJRQ37FE/kCivKx7ClKEHfhX2FdcxKzJ1B744a+V3A==
+  dependencies:
+    "@types/node" "*"
+    moment ">=2.14.0"
+
 "@types/dotenv@^6.1.1":
   version "6.1.1"
   resolved "https://registry.yarnpkg.com/@types/dotenv/-/dotenv-6.1.1.tgz#f7ce1cc4fe34f0a4373ba99fefa437b0bec54b46"
@@ -2249,6 +2257,13 @@ create-error-class@^3.0.0:
   dependencies:
     capture-stack-trace "^1.0.0"
 
+cron@^1.7.1:
+  version "1.7.1"
+  resolved "https://registry.yarnpkg.com/cron/-/cron-1.7.1.tgz#e85ee9df794d1bc6579896ee382053c3ce33778f"
+  integrity sha512-gmMB/pJcqUVs/NklR1sCGlNYM7TizEw+1gebz20BMc/8bTm/r7QUp3ZPSPlG8Z5XRlvb7qhjEjq/+bdIfUCL2A==
+  dependencies:
+    moment-timezone "^0.5.x"
+
 cross-spawn@^5.0.1:
   version "5.1.0"
   resolved "https://registry.yarnpkg.com/cross-spawn/-/cross-spawn-5.1.0.tgz#e8bd0efee58fcff6f8f94510a0a554bbfa235449"
@@ -4679,6 +4694,18 @@ mkdirp@0.x, mkdirp@^0.5.0, mkdirp@^0.5.1:
   dependencies:
     minimist "0.0.8"
 
+moment-timezone@^0.5.x:
+  version "0.5.25"
+  resolved "https://registry.yarnpkg.com/moment-timezone/-/moment-timezone-0.5.25.tgz#a11bfa2f74e088327f2cd4c08b3e7bdf55957810"
+  integrity sha512-DgEaTyN/z0HFaVcVbSyVCUU6HeFdnNC3vE4c9cgu2dgMTvjBUBdBzWfasTBmAW45u5OIMeCJtU8yNjM22DHucw==
+  dependencies:
+    moment ">= 2.9.0"
+
+"moment@>= 2.9.0", moment@>=2.14.0:
+  version "2.24.0"
+  resolved "https://registry.yarnpkg.com/moment/-/moment-2.24.0.tgz#0d055d53f5052aa653c9f6eb68bb5d12bf5c2b5b"
+  integrity sha512-bV7f+6l2QigeBBZSM/6yTNq4P2fNpSWj/0e7jQcy87A8e7o2nAfP/34/2ky5Vw4B9S446EtIhodAzkFCcR4dQg==
+
 morgan@^1.9.1:
   version "1.9.1"
   resolved "https://registry.yarnpkg.com/morgan/-/morgan-1.9.1.tgz#0a8d16734a1d9afbc824b99df87e738e58e2da59"