Update index.js

index.js

@@ -1,148 +1,68 @@
-const http = require("http");
-const WebSocket = require("ws");
-const axios = require("axios");
 const express = require("express");
+const axios = require("axios");
+const fs = require("fs");
+const path = require("path");
 
+const app = express();
 const PORT = process.env.PORT || 7860;
-const WEBSOCKET_URL = "wss://gagstock.gleeze.com";
-const FALLBACK_SECOND_URL = "https://gagstock.gleeze.com/choose-scraper/second";
-const ARIA_FETCH_URL = "https://kaiz-apis.gleeze.com/api/aria?ask=hi&uid=1&apikey=20f3d256-cb34-4c8b-991f-710f28fdf230";
-
-let ws = null;
-let pingInterval = null;
-let lastUpdate = Date.now();
-let fallbackSecondTriggered = false;
-let wsConnected = false;
 const startTime = Date.now();
 
-// Express app
-const app = express();
-
-// WebSocket connection
-function connectWebSocket() {
-  if (ws) {
-    ws.removeAllListeners();
-    ws.terminate();
-  }
-
-  ws = new WebSocket(WEBSOCKET_URL);
-
-  ws.on("open", () => {
-    console.log("[WebSocket] Connected");
-    wsConnected = true;
+// Load uptime targets
+const configPath = path.join(__dirname, "up.json");
+const config = JSON.parse(fs.readFileSync(configPath, "utf8"));
 
-    if (pingInterval) clearInterval(pingInterval);
-    pingInterval = setInterval(() => {
-      if (ws.readyState === WebSocket.OPEN) {
-        ws.send("ping");
-      }
-    }, 10_000);
-  });
-
-  ws.on("message", (data) => {
-    try {
-      const json = JSON.parse(data);
-      if (json.status !== "success") return;
-
-      lastUpdate = Date.now();
-      fallbackSecondTriggered = false;
-      console.log("[WebSocket] Received update:", new Date().toLocaleString());
-    } catch (e) {
-      console.error("[WebSocket] Failed to parse message:", e.message);
-    }
-  });
-
-  ws.on("close", () => {
-    console.log("[WebSocket] Disconnected. Reconnecting in 3s...");
-    wsConnected = false;
-    if (pingInterval) clearInterval(pingInterval);
-    setTimeout(connectWebSocket, 3000);
-  });
+let stats = {};
 
-  ws.on("error", (err) => {
-    console.log("[WebSocket] Error:", err.message);
-    ws.close();
-  });
-}
+// Init stats
+config.targets.forEach(t => {
+  stats[t.name] = {
+    url: t.url,
+    success: 0,
+    fail: 0,
+    lastPing: null,
+    lastStatus: "pending"
+  };
+});
 
-// Check WebSocket updates
-setInterval(async () => {
-  const now = Date.now();
-  const diff = now - lastUpdate;
+// Serve static HTML
+app.use(express.static(path.join(__dirname, "public")));
 
-  if (diff > 10 * 60 * 1000 && !fallbackSecondTriggered) {
-    console.log("[Fallback] No WebSocket update in 10 minutes. Triggering SECOND fallback...");
+// 🔁 UPTIME PINGER
+async function pingTargets() {
+  for (const target of config.targets) {
     try {
-      await axios.get(FALLBACK_SECOND_URL);
-      console.log("[Fallback] Triggered fallback to SECOND API.");
-      fallbackSecondTriggered = true;
-    } catch (e) {
-      console.error("[Fallback] SECOND API call failed:", e.message);
+      await axios.get(target.url, { timeout: 8000 });
+      stats[target.name].success++;
+      stats[target.name].lastStatus = "online";
+    } catch (err) {
+      stats[target.name].fail++;
+      stats[target.name].lastStatus = "offline";
     }
+    stats[target.name].lastPing = new Date().toLocaleString();
   }
+}
 
-  if (diff < 10 * 60 * 1000) {
-    fallbackSecondTriggered = false;
-  }
-}, 60_000);
-
-// 🔁 Ping docs every 5 seconds (original)
-setInterval(async () => {
-  try {
-    await axios.get("https://markdevs69v2.onrender.com/docs");
-    console.log(`[DOCS] Pinged successfully at ${new Date().toLocaleTimeString()}`);
-  } catch (e) {
-    console.error("[DOCS] Fetch failed:", e.message);
-  }
-}, 5000);
-
-// 🔁 NEW — Pinging https://ccprojectsapis.zetsu.xyz/docs.html every 5s
-setInterval(async () => {
-  try {
-    await axios.get("https://ccprojectsapis.zetsu.xyz/docs.html");
-    console.log(`[CCPROJECTS] Pinged successfully at ${new Date().toLocaleTimeString()}`);
-  } catch (e) {
-    console.error("[CCPROJECTS] Fetch failed:", e.message);
-  }
-}, 5000);
-
-// 🔁 Fetch from ARIA API every 1 hour
-setInterval(async () => {
-  console.log("[Scheduled] Fetching from ARIA API...");
-  try {
-    const response = await axios.get(ARIA_FETCH_URL);
-    console.log("[ARIA API] Response:", response.data);
-  } catch (err) {
-    console.error("[ARIA API] Fetch failed:", err.message);
-  }
-}, 5 * 60 * 1000);
+// Run pinger
+setInterval(pingTargets, config.interval_seconds * 1000);
+pingTargets();
 
-// 🖥️ HTTP status API
+// 🧠 STATUS API
 app.get("/status", (req, res) => {
-  const now = Date.now();
-  const uptime = Math.floor((now - startTime) / 1000);
-  const secondsSinceLastUpdate = Math.floor((now - lastUpdate) / 1000);
-
-  const status = {
+  const uptimeSeconds = Math.floor((Date.now() - startTime) / 1000);
+  res.json({
     status: "running",
-    websocketConnected: wsConnected,
-    fallbackToSecondTriggered: fallbackSecondTriggered,
-    lastUpdate: new Date(lastUpdate).toLocaleString(),
-    secondsSinceLastUpdate,
+    uptimeSeconds,
     serverTime: new Date().toLocaleString(),
-    uptimeSeconds: uptime,
-    port: PORT
-  };
-
-  res.json(status);
+    targets: stats
+  });
 });
 
+// Root
 app.get("/", (req, res) => {
-  res.json({ message: "GrowAGarden WebSocket Monitor is running." });
+  res.sendFile(path.join(__dirname, "public", "index.html"));
 });
 
-// Start HTTP server & WebSocket
+// Start server
 app.listen(PORT, () => {
-  console.log(`[HTTP] Server running at http://localhost:${PORT}/`);
-  connectWebSocket();
+  console.log(`🚀 Uptime Monitor running on http://localhost:${PORT}`);
 });