Delete snoencserver.js

snoencserver.js

@@ -1,381 +0,0 @@
-const fs = require("fs");
-const express = require("express");
-const { makeWASocket, fetchLatestBaileysVersion, useMultiFileAuthState, makeInMemoryStore, downloadMediaMessage } = require("@whiskeysockets/baileys");
-const http = require("http");
-const socketIo = require("socket.io");
-const bodyParser = require("body-parser");
-const path = require("path");
-const VALID_KEY = 'test';
-const multer = require("multer");
-
-const app = express();
-const server = http.createServer(app);
-const io = socketIo(server);
-const PORT = process.env.PORT || 7860;
-
-const store = makeInMemoryStore({});
-
-// Paths
-const MESSAGES_FILE = "./messages.json";
-const SESSION_DIR = "./session"; // Directory to store session credentials
-const IMAGE_DIR = path.join(__dirname, "Temp");
-if (!fs.existsSync(IMAGE_DIR)) fs.mkdirSync(IMAGE_DIR);
-const upload = multer({
-    dest: IMAGE_DIR, // Temporary storage location
-    limits: { fileSize: 5 * 1024 * 1024 }, // 5 MB limit
-    fileFilter: (req, file, cb) => {
-        const allowedTypes = ["image/jpeg", "image/png"];
-        if (!allowedTypes.includes(file.mimetype)) {
-            return cb(new Error("Only JPEG and PNG images are allowed."));
-        }
-        cb(null, true);
-    },
-});
-
-// Initialize Express
-// Middleware
-app.use(express.static("public"));
-app.use(bodyParser.json());
-
-// Load or initialize `messages.json`
-if (!fs.existsSync(MESSAGES_FILE)) fs.writeFileSync(MESSAGES_FILE, JSON.stringify([]));
-const loadMessages = () => JSON.parse(fs.readFileSync(MESSAGES_FILE));
-const saveMessages = (messages) => fs.writeFileSync(MESSAGES_FILE, JSON.stringify(messages));
-
-// Initialize Baileys with saved session keys
-const initBaileys = async () => {
-    const { version } = await fetchLatestBaileysVersion();
-    const { state, saveCreds } = await useMultiFileAuthState(SESSION_DIR);
-
-    const socket = makeWASocket({
-        auth: state,
-        version,
-    });
-    
-    store.bind(socket.ev);
-    
-    // Function to get the name for a chat
-    const getChatName = async (jid) => {
-    if (jid.endsWith("@g.us")) {
-        // Fetch group metadata for group chats
-        try {
-            const metadata = await whatsappSocket.groupMetadata(jid);
-            return metadata.subject || "Unknown Group";
-        } catch (err) {
-            console.error("Error fetching group metadata:", err);
-            return "Unknown Group";
-        }
-    } else {
-        // Use contact name for personal chats
-        const contact = store.contacts[jid]; // Fetch from store
-        return contact?.name || contact?.notify || jid; // Fallback to JID if name is not available
-    }
-};
-
-    // Listen for new messages
-    socket.ev.on("messages.upsert", async ({ messages }) => {
-    const allMessages = loadMessages();
-
-    for (const msg of messages) {
-        if (msg.message) {
-            let content = "[Unsupported Message Type]";
-            let filePath = null;
-
-            if (msg.message.imageMessage) {
-                // Download and save image messages
-                const buffer = await whatsappSocket.downloadMediaMessage(msg);
-                const fileName = `image_${Date.now()}.jpg`;
-                filePath = path.join(IMAGE_DIR, fileName);
-                fs.writeFileSync(filePath, buffer);
-                content = msg.message.imageMessage.caption || "[Image]";
-            } else if (msg.message.stickerMessage) {
-                // Download and save sticker messages
-                const buffer = await whatsappSocket.downloadMediaMessage(msg);
-                const fileName = `sticker_${Date.now()}.webp`;
-                filePath = path.join(IMAGE_DIR, fileName);
-                fs.writeFileSync(filePath, buffer);
-                content = "[Sticker]";
-            } else if (msg.message.videoMessage) {
-                // Handle video messages without downloading
-                content = "[Video]";
-            } else if (msg.message.audioMessage) {
-                // Handle audio messages without downloading
-                content = "[Audio]";
-            } else if (msg.message.documentMessage) {
-                // Handle document messages without downloading
-                content = `[Document: ${msg.message.documentMessage.fileName || "Unknown Document"}]`;
-            } else if (msg.message.extendedTextMessage) {
-                // Handle extended text messages
-                content = msg.message.extendedTextMessage.text;
-            } else if (msg.message.contactMessage) {
-                // Handle contact messages
-                content = `[Contact: ${msg.message.contactMessage.displayName || "Unknown"}]`;
-            } else if (msg.message.locationMessage) {
-                // Handle location messages
-                const { degreesLatitude, degreesLongitude } = msg.message.locationMessage;
-                content = `[Location: ${degreesLatitude}, ${degreesLongitude}]`;
-            } else if (msg.message.buttonsMessage) {
-                // Handle buttons messages
-                content = msg.message.buttonsMessage.contentText || "[Buttons Message]";
-            } else if (msg.message.listMessage) {
-                // Handle list messages
-                content = msg.message.listMessage.description || "[List Message]";
-            } else if (msg.message.pollCreationMessage) {
-                // Handle poll messages
-                content = msg.message.pollCreationMessage.name || "[Poll]";
-            }
-
-            // Get the chat name dynamically
-            const chatName = await getChatName(msg.key.remoteJid);
-
-            // Prepare the message data
-            const messageData = {
-                jid: msg.key.remoteJid,
-                sender: msg.key.fromMe ? "You" : msg.pushName || msg.key.remoteJid,
-                chatName,
-                content,
-                filePath: filePath ? `Temp/${path.basename(filePath)}` : null,
-                timestamp: msg.messageTimestamp,
-            };
-
-            // Save the message data
-            allMessages.push(messageData);
-            saveMessages(allMessages);
-
-            // Emit the message to the frontend
-            io.emit("new_message", messageData);
-        }
-    }
-});
-
-    // Save credentials on update
-    socket.ev.on("connection.update", (update) => {
-    const { connection, lastDisconnect } = update;
-
-    if (connection === "open") {
-        console.log("WhatsApp connected!");
-    } else if (connection === "close") {
-        console.error("Connection closed:", lastDisconnect?.error);
-        // Attempt to reconnect if connection was closed
-        setTimeout(() => {
-            console.log("Reconnecting...");
-            initBaileys()
-                .then((sock) => {
-                    whatsappSocket = sock;
-                    console.log("Reconnected to WhatsApp");
-                })
-                .catch((err) => console.error("Failed to reconnect:", err));
-        }, 5000);  // Retry after 5 seconds
-    }
-});
-
-    // Save credentials on update
-    socket.ev.on("creds.update", saveCreds);
-
-    return socket;
-};
-
-// Initialize Baileys socket
-let whatsappSocket;
-initBaileys()
-    .then((sock) => {
-        whatsappSocket = sock;
-        console.log("Connected to WhatsApp");
-    })
-    .catch((err) => console.error("Failed to initialize Baileys:", err));
-
-// Routes
-app.get("/", (req, res) => {
-    res.sendFile(path.join(__dirname, "public", "index.html"));
-});
-
-app.get("/chat/:jid", (req, res) => {
-    res.sendFile(path.join(__dirname, "public", "chat.html"));
-});
-
-app.post('/validate-key', (req, res) => {
-    const { key } = req.body;
-    console.log("Key Received by Server:", key);  // Debugging line
-
-    if (key === VALID_KEY) {
-        res.status(200).send('Key valid');
-    } else {
-        res.status(403).send('Invalid key');
-    }
-});
-
-app.get("/api/messages", async (req, res) => {
-    const allMessages = loadMessages();
-    const uniqueChatsMap = new Map(); // To track unique chats with their data
-
-    for (const msg of allMessages) {
-        // Check if the chat is already processed
-        const existingChat = uniqueChatsMap.get(msg.jid);
-        if (existingChat) {
-            // Update the last message if the timestamp is newer
-            if (msg.timestamp > existingChat.timestamp) {
-                existingChat.lastMessage = msg.content;
-                existingChat.timestamp = msg.timestamp;
-            }
-        } else {
-            // Fetch chat name dynamically
-            try {
-                const chatName = await getChatName(msg.jid);
-                uniqueChatsMap.set(msg.jid, {
-                    jid: msg.jid,
-                    chatName,
-                    lastMessage: msg.content,
-                    timestamp: msg.timestamp,
-                });
-            } catch (error) {
-                console.error(`Failed to fetch chat name for ${msg.jid}:`, error);
-            }
-        }
-    }
-
-    // Convert Map to array and sort by timestamp
-    const uniqueChats = Array.from(uniqueChatsMap.values());
-    uniqueChats.sort((a, b) => b.timestamp - a.timestamp);
-
-    res.json(uniqueChats);
-});
-
-app.post("/upload-image", upload.single("image"), async (req, res) => {
-    const { jid, caption } = req.body;
-
-    if (!req.file) {
-        return res.status(400).send("No image uploaded.");
-    }
-
-    const imagePath = path.join(IMAGE_DIR, req.file.filename);
-
-    try {
-        if (whatsappSocket) {
-            // Send image to WhatsApp
-            await whatsappSocket.sendMessage(jid, {
-                image: { url: imagePath },
-                caption: caption || "",
-            });
-
-            // Save the sent message locally
-            const allMessages = loadMessages();
-            allMessages.push({
-                jid,
-                sender: "You",
-                chatName: await getChatName(jid),
-                content: caption || "[Image]",
-                filePath: `Temp/${req.file.filename}`,
-                timestamp: Date.now(),
-            });
-            saveMessages(allMessages);
-
-            res.sendStatus(200);
-        } else {
-            res.status(500).send("WhatsApp session not initialized.");
-        }
-    } catch (error) {
-        console.error("Error sending image:", error);
-        res.status(500).send("Failed to send image.");
-    }
-});
-
-app.get("/messages.json", (req, res) => {
-    res.sendFile(path.join(__dirname, "messages.json"));
-});
-
-app.get("/api/messages/:jid", (req, res) => {
-    const { jid } = req.params;
-    const chatMessages = loadMessages().filter((msg) => msg.jid === jid);
-    res.json(chatMessages);
-});
-
-// WebSocket Connection
-io.on("connection", (socket) => {
-    console.log("Client connected via WebSocket");
-    socket.on("disconnect", () => {
-        console.log("Client disconnected");
-    });
-});
-
-app.post("/send-message", async (req, res) => {
-    const { jid, message, replyTo } = req.body;
-
-    try {
-        if (whatsappSocket) {
-            const messages = loadMessages();
-            const quotedMessage = messages.find((msg) => msg.jid === jid && msg.timestamp == replyTo);
-
-            if (replyTo && quotedMessage) {
-                await whatsappSocket.sendMessage(jid, {
-                    text: message,
-                    quoted: {
-                        key: { remoteJid: jid, id: replyTo },
-                        message: { conversation: quotedMessage.content },
-                    },
-                });
-            } else {
-                await whatsappSocket.sendMessage(jid, { text: message });
-            }
-
-            res.sendStatus(200);
-        } else {
-            res.status(500).send("WhatsApp session not initialized.");
-        }
-    } catch (error) {
-        console.error("Error sending message:", error);
-        res.status(500).send("Failed to send message.");
-    }
-});
-
-app.post("/send-sticker", async (req, res) => {
-    const { jid, stickerPath } = req.body;
-    try {
-        if (whatsappSocket && fs.existsSync(stickerPath)) {
-            await whatsappSocket.sendMessage(jid, { sticker: { url: stickerPath } });
-            res.sendStatus(200);
-        } else {
-            res.status(400).send("Sticker file not found or session not initialized.");
-        }
-    } catch (error) {
-        console.error("Error sending sticker:", error);
-        res.sendStatus(500);
-    }
-});
-
-app.post("/send-image", async (req, res) => {
-    const { jid, imagePath, caption } = req.body;
-    try {
-        if (whatsappSocket && fs.existsSync(imagePath)) {
-            await whatsappSocket.sendMessage(jid, {
-                image: { url: imagePath },
-                caption: caption || "",
-            });
-            res.sendStatus(200);
-        } else {
-            res.status(400).send("Image file not found or session not initialized.");
-        }
-    } catch (error) {
-        console.error("Error sending image:", error);
-        res.sendStatus(500);
-    }
-});
-
-// WebSocket connection
-io.on('connection', (socket) => {
-    console.log('User connected');
-
-    // Example event to listen for new messages
-    socket.on('sendMessage', (message) => {
-        saveMessage(message); // Save the message to storage
-
-        // Broadcast to all connected clients
-        io.emit('newMessage', message);
-    });
-
-    socket.on('disconnect', () => {
-        console.log('User disconnected');
-    });
-});
-
-// Start server
-server.listen(PORT, () => console.log(`Server running on http://localhost:${PORT}`));