Merge pull request #171 from harmony-one/monitoring

Added monitoring

src/bot.ts

@@ -36,6 +36,7 @@ import {AppDataSource} from "./database/datasource";
 import { text } from "stream/consumers";
 import { autoRetry } from "@grammyjs/auto-retry";
 import {run} from "@grammyjs/runner";
+import {runBotHeartBit} from "./monitoring/monitoring";
 
 
 const logger = pino({
@@ -447,3 +448,8 @@ process.once("SIGTERM", stopRunner);
 
 AppDataSource.initialize();
 
+if (config.betteruptime.botHeartBitId) {
+  const task = runBotHeartBit(runner, config.betteruptime.botHeartBitId);
+  process.once("SIGINT", () => task.stop());
+  process.once("SIGTERM", () => task.stop());
+}

src/config.ts

@@ -129,4 +129,7 @@ export default {
       .map((item) => item.toString().toLowerCase()),
     creditsAmount: "100",
   },
+  betteruptime: {
+    botHeartBitId: process.env.BOT_HEARTBIT_ID || ''
+  }
 };

src/monitoring/monitoring.ts

@@ -0,0 +1,35 @@
+import cron from 'node-cron'
+import axios from "axios";
+import {RunnerHandle} from "@grammyjs/runner";
+import {pino} from "pino";
+
+const logger = pino({
+  name: "monitoring",
+  transport: {
+    target: "pino-pretty",
+    options: {
+      colorize: true,
+    },
+  },
+});
+
+export const runBotHeartBit = (runner: RunnerHandle, heartBitId: string) => {
+
+  const action = () => {
+    logger.info('heartbit');
+    if (!runner.isRunning()) {
+      logger.error('bot runner is stopped');
+      return;
+    }
+
+    axios
+      .post(
+        `https://uptime.betterstack.com/api/v1/heartbeat/${heartBitId}`
+      ).catch((err) => {
+        logger.warn(`betteruptime error ${err}`);
+      })
+
+  }
+
+  return cron.schedule('*/1 * * * *', action);
+}