email alerts

src/app.ts

@@ -5,6 +5,8 @@ import http from "http";
 import { logger } from "./utils/logger";
 import { initDB } from "./utils/db";
 import { logHandler } from "./routes/log";
+import { checkUptime } from "./routes/log";
+
 
 const app = express();
 
@@ -39,6 +41,12 @@ app.get("/", (_req, res) => {
 app.use(bodyParser.json());
 app.use('/log', logHandler)
 
+
+const UPTIME_CHECK_INTERVAL = process.env.UPTIME_CHECK_INTERVAL as unknown as number || 60000; // Default: 1 minute
+
+setInterval(checkUptime, UPTIME_CHECK_INTERVAL);
+
+
 initDB()
   .then((_database) => {
     logger.info("Database Initialized");

src/routes/log.ts

@@ -47,7 +47,6 @@ router.post("/", (req: Request, res: Response) => {
 
 
 
-const UPTIME_CHECK_INTERVAL = process.env.UPTIME_CHECK_INTERVAL || 60000; // Default: 1 minute
 
 
 const EMAIL_USERNAME = process.env.EMAIL_USERNAME;
@@ -72,31 +71,41 @@ const transporter = nodemailer.createTransport({
 
 const EMAIL_LIST = ["[email protected]"];
 
+var email_sent = false
+
+export async function checkUptime() {
+
+    const subject = "API DOWN";
+
+    const mailOptions = {
+        from: EMAIL_USERNAME, // Replace with your Gmail email
+        to: EMAIL_LIST.join(", "),
+        subject,
+        text: subject,
+    };
 
-async function checkUptime() {
     try {
         const response = await fetch('https://api.hanswehr.com/root?root=qtl');
         if (response.status === 200) {
             logger.info('Uptime check passed. Endpoint is up.');
+            email_sent = false
         } else {
             logger.error('Uptime check failed. Endpoint is down.');
             // Trigger another workflow or take necessary actions on failure
 
-            const subject = "API DOWN";
-
-            const mailOptions = {
-                from: EMAIL_USERNAME, // Replace with your Gmail email
-                to: EMAIL_LIST.join(", "),
-                subject,
-                text: subject,
-            };
-
-            await transporter.sendMail(mailOptions);
+            if (!email_sent) {
+                await transporter.sendMail(mailOptions);
+                email_sent = true
+            }
         }
-    } catch (error) {
+    } catch (error: any) {
         logger.error(`Error checking uptime: ${error.message}`);
+        if (!email_sent) {
+            await transporter.sendMail(mailOptions);
+            email_sent = true
+        }
         // Trigger another workflow or take necessary actions on failure
     }
 }
 
-export const logHandler = router;
+export const logHandler = router;