feat: cron update bus routes

package.json

@@ -1,6 +1,6 @@
 {
   "name": "tg-hketa",
-  "version": "2.1.0",
+  "version": "2.1.1",
   "engines": {
     "node": "16.x"
   },
@@ -34,6 +34,7 @@
     "@types/lodash": "^4.14.170",
     "@types/luxon": "^1.26.5",
     "axios": "^0.21.1",
+    "cron": "^1.8.2",
     "dotenv": "^10.0.0",
     "express": "^4.17.1",
     "lodash": "^4.17.21",
@@ -48,6 +49,7 @@
     "universal-analytics": "^0.4.23"
   },
   "devDependencies": {
+    "@types/cron": "^1.7.2",
     "@types/universal-analytics": "^0.4.4",
     "husky": "^6.0.0",
     "jest": "^27.0.4",

src/app.ts

@@ -1,5 +1,6 @@
 require('dotenv').config();
 import './config/alias';
+import '@root/cronjob';
 import express, { json } from 'express';
 import { Telegraf, session, Context, Scenes } from 'telegraf';
 import { SceneSession } from 'telegraf/typings/scenes';

src/cronjob.ts

@@ -0,0 +1,33 @@
+import cronjob from 'cron';
+import { DateTime } from 'luxon';
+import { getBusRoutes } from '@services/routes';
+
+const every12Hours = '0 0 */12 * * *';
+
+const updateJob = new cronjob.CronJob(
+  every12Hours,
+  updateBusRoutes,
+  null,
+  false,
+  'Asia/Hong_Kong',
+  null,
+  true
+);
+
+updateJob.start();
+
+async function updateBusRoutes() {
+  console.info(
+    `Start updating bus routes data at ${DateTime.now().toString()}`
+  );
+
+  try {
+    await getBusRoutes();
+  } catch (error) {
+    console.error('Error on updating bus routes', error);
+  }
+
+  console.info(
+    `Successfully updated bus routes data at ${DateTime.now().toString()}`
+  );
+}

src/services/routes.ts

@@ -21,7 +21,7 @@ async function getNLBRotues() {
   );
 }
 
-async function getBusRoutes() {
+export async function getBusRoutes() {
   const ctbJob = axios.get(`${BRAVO_BUS_ENDPOINT}/route/CTB`);
   const nwfbJob = axios.get(`${BRAVO_BUS_ENDPOINT}/route/NWFB`);
   const kmbJob = axios.get(`${KMB_ENDPOINT}/route`);