feat(data-mechanism): wip cronjob

package.json

@@ -10,7 +10,9 @@
   "author": "Italo Sousa",
   "license": "ISC",
   "dependencies": {
+    "@types/cron": "^1.7.3",
     "cors": "^2.8.5",
+    "cron": "^1.8.2",
     "discord.js": "^12.5.3",
     "dotenv": "^10.0.0",
     "express": "^4.17.1",

src/core/cron.ts

@@ -0,0 +1,40 @@
+/* eslint-disable implicit-arrow-linebreak */
+/* eslint-disable class-methods-use-this */
+import { CronJob } from 'cron';
+import AppQueue from './queue';
+
+export default class AppCron {
+  cron: CronJob;
+
+  queue: AppQueue;
+
+  constructor(queueInstance: AppQueue) {
+    this.cron = new CronJob(
+      '*/1 * * * *',
+      this.job(),
+      null,
+      true,
+      'America/Sao_Paulo',
+    );
+    this.queue = queueInstance;
+  }
+
+  setup() {
+    this.cron.start();
+  }
+
+  job() {
+    return () => {
+      console.log('[Cron] slow job started');
+      this.queue.enqueue(
+        () =>
+          new Promise((resolve) => {
+            setTimeout(() => {
+              console.log('[Cron] slow job finished');
+              resolve('ok');
+            }, 3000);
+          }),
+      );
+    };
+  }
+}

src/index.ts

@@ -1,34 +1,49 @@
+/* eslint-disable implicit-arrow-linebreak */
 import dotenv from 'dotenv';
 import express from 'express';
 
-import { DiscordBot } from './discord';
-import Controller from './core/controller';
+// import { DiscordBot } from './discord';
+// import Controller from './core/controller';
 // import { parseFeed } from './feed';
 // import { aaa } from './test';
+import AppQueue from './core/queue';
+import AppCron from './core/cron';
 
 dotenv.config();
 
 const app = express();
 const PORT = 8000;
+let queueInstance: AppQueue;
+let cronInstance: AppCron;
 
-const setupDiscord = () => {
-  const controller = new Controller();
-  const discord = new DiscordBot(controller);
-  discord.start();
-};
+// const setupDiscord = () => {
+//   const controller = new Controller();
+//   const discord = new DiscordBot(controller);
+//   discord.start();
+// };
 
 app.use(express.json());
 
 app.get('/', (req, res) => res.send('Express + TypeScript Server'));
 
 app.get('/test', async (req, res) => {
-  // const ress = await parseFeed();
-  // res.json(ress);
-  // aaa();
+  queueInstance.enqueue(
+    () =>
+      new Promise((resolve) => {
+        setTimeout(() => {
+          console.log('slow job finished');
+          resolve('ok');
+        }, 3000);
+      }),
+  );
   res.json({});
 });
 
 app.listen(PORT, () => {
   console.log(`⚡️[server]: Server is running at http://localhost:${PORT}`);
-  setupDiscord();
+  // setupDiscord();
+  queueInstance = new AppQueue();
+  queueInstance.start();
+  cronInstance = new AppCron(queueInstance);
+  cronInstance.setup();
 });