Update app.js

app.js

@@ -1,105 +1,90 @@
 require("dotenv").config();
+
 const {
-    default: makeWASocket,
-    DisconnectReason
+  default: makeWASocket,
+  DisconnectReason,
+  useMultiFileAuthState,
 } = require("@whiskeysockets/baileys");
 
-const express = require("express");
 const qrcode = require("qrcode-terminal");
 const pino = require("pino");
-const axios = require("axios");
-const fs = require("fs");
-const crypto = require("crypto");
-
-const app = express();
-
-app.use(express.json());
-
-const PORT = process.env.PORT || 7860;
-
-const SEND_WEBHOOK_URL = process.env.LLM_WEBHOOK_URL+"/whatsapp";
-
-
-let sock = null;
-let isReconnecting = false;
-
 
 async function startWhatsApp() {
   try {
+    console.log("🚀 Starting WhatsApp...");
+
+    const { state, saveCreds } =
+      await useMultiFileAuthState("./auth");
+
+    const sock = makeWASocket({
+      auth: state,
+      logger: pino({ level: "debug" }),
+      printQRInTerminal: false,
+    });
 
     sock.ev.on("creds.update", saveCreds);
 
     sock.ev.on("connection.update", async (update) => {
-        const {
-            connection,
-            lastDisconnect,
-            qr
-        } = update;
-
-        console.log("con", connection);
-        console.log("qr", qr);
-        console.log("------------");
-        if (qr) {
-            console.log("\n📱 Scan QR Code:\n");
-            qrcode.generate(qr, { small: true });
-        }
-
-        if (connection === "open") {
-            console.log("✅ WhatsApp Connected");
-            isReconnecting = false;
+      console.log("\n========== CONNECTION UPDATE ==========");
+      console.log(JSON.stringify(update, null, 2));
+
+      const { connection, lastDisconnect, qr } = update;
+
+      if (qr) {
+        console.log("\n📱 QR RECEIVED\n");
+        qrcode.generate(qr, { small: true });
+      }
+
+      if (connection === "open") {
+        console.log("✅ WhatsApp Connected");
+      }
+
+      if (connection === "connecting") {
+        console.log("🔄 Connecting...");
+      }
+
+      if (connection === "close") {
+        const statusCode =
+          lastDisconnect?.error?.output?.statusCode;
+
+        console.log(
+          `❌ Connection Closed. Status Code: ${statusCode}`
+        );
+
+        console.error(
+          "Disconnect Error:",
+          lastDisconnect?.error
+        );
+
+        const loggedOut =
+          statusCode === DisconnectReason.loggedOut ||
+          statusCode === 401;
+
+        if (!loggedOut) {
+          console.log("🔄 Reconnecting in 5 seconds...");
+          setTimeout(startWhatsApp, 5000);
+        } else {
+          console.log(
+            "🚫 Logged out. Delete auth folder and rescan."
+          );
         }
+      }
+    });
 
-        if (connection === "close") {
-            const statusCode =
-                lastDisconnect?.error?.output?.statusCode;
-
-            console.log(
-                `❌ Connection closed. Status: ${statusCode}`
-            );
-
-            const shouldLogout =
-                statusCode === 401 ||
-                statusCode === 405 ||
-                statusCode === DisconnectReason.loggedOut;
-
-            if (shouldLogout) {
-                console.log(
-                    "🧹 Session invalid. Removing auth folder..."
-                );
-
-                setTimeout(() => {
-                    startWhatsApp();
-                }, 3000);
-
-                return;
-            }
-
-            if (!isReconnecting) {
-                isReconnecting = true;
+    sock.ev.on("messages.upsert", (msg) => {
+      console.log(
+        "📨 Message Event:",
+        JSON.stringify(msg, null, 2)
+      );
+    });
 
-                console.log(
-                    "🔄 Reconnecting in 5 seconds..."
-                );
+  } catch (err) {
+    console.error("🔥 Fatal Error");
+    console.error(err);
 
-                setTimeout(() => {
-                    isReconnecting = false;
-                    startWhatsApp();
-                }, 5000);
-            }
-        }
-    });
+    console.log("🔄 Restarting in 10 seconds...");
+    setTimeout(startWhatsApp, 10000);
   }
-};
-app.get("/", (req, res) => {
-    res.json({
-        status: "running"
-    });
-});
-
-app.listen(PORT, () => {
-    console.log(
-        `🚀 Server running on port ${PORT}`
-    );
+}
 
-    startWhatsApp();
-});
+startWhatsApp();