Add files via upload

Author: well300

index.js

@@ -1,56 +1,79 @@
-import ws from '@whiskeysockets/baileys'
-const { default: makeWASocket, DisconnectReason, useMultiFileAuthState, fetchLatestBaileysVersion } = ws
-import { remove } from 'fs-extra'
-import { serialize } from './lib/waClient.js'
-import * as dotenv from 'dotenv'
-import axios from 'axios'
-import P from 'pino'
-import { Boom } from '@hapi/boom'
-
-dotenv.config()
+import ws from '@whiskeysockets/baileys';
+import { remove } from 'fs-extra';
+import { serialize } from './lib/waClient.js';
+import axios from 'axios';
+import P from 'pino';
+import { Boom } from '@hapi/boom';
 
 const start = async () => {
-    const { state, saveCreds } = await useMultiFileAuthState("session")
+    console.log('\x1b[36m%s\x1b[0m', '╭───────────────────────────────────────╮');
+    console.log('\x1b[36m%s\x1b[0m', '│         🤖  \x1b[35mWahGpt-Bot\x1b[0m  🤖            │');
+    console.log('\x1b[36m%s\x1b[0m', '│                                       │');
+    console.log('\x1b[36m%s\x1b[0m', '│  \x1b[35mWhatsApp Chat Bot with ChatGPT    \x1b[0m   │');
+    console.log('\x1b[36m%s\x1b[0m', '│             \x1b[35mIntegration\x1b[0m               │');
+    console.log('\x1b[36m%s\x1b[0m', '│                                       │');
+    console.log('\x1b[36m%s\x1b[0m', '╰───────────────────────────────────────╯');
+
+    const { useMultiFileAuthState, fetchLatestBaileysVersion } = ws;
+    const { default: makeWASocket, DisconnectReason } = ws;
+
+    const { state, saveCreds } = await useMultiFileAuthState("session");
     const client = makeWASocket({
         version: (await fetchLatestBaileysVersion()).version,
         auth: state,
         logger: P({ level: 'silent' }),
         printQRInTerminal: true
-    })
+    });
+
+    const colors = {
+        user: '\x1b[36m', // Cyan color for user messages
+        bot: '\x1b[35m',  // Magenta color for bot messages
+        reset: '\x1b[0m'  // Reset color
+    };
 
-    //connection updates
     client.ev.on('connection.update', async (update) => {
-        const { connection, lastDisconnect } = update
-        if (update.qr) console.log(`Scan the QR code!!`)
+        const { connection, lastDisconnect } = update;
+        if (update.qr) console.log(`📱 Scan the QR code!!`);
         if (connection === 'close') {
-            const { statusCode } = new Boom(lastDisconnect?.error).output
-            if (statusCode !== DisconnectReason.loggedOut) setTimeout(() => start(), 3000)
+            const { statusCode } = new Boom(lastDisconnect?.error).output;
+            if (statusCode !== DisconnectReason.loggedOut) setTimeout(() => start(), 3000);
             else {
-                console.log('Disconnected :"(')
-                await remove("session")
-                console.log('Starting...')
-                setTimeout(() => start(), 3000)
+                console.log('❌ Disconnected :("');
+                await remove("session");
+                console.log('🔄 Restarting...');
+                setTimeout(() => start(), 3000);
             }
         }
-        if (connection === 'connecting') console.log('Connecting to WhatsApp!!')
-        if (connection === 'open') console.log('Connected to WhatsApp')
-        
-    })
+        if (connection === 'connecting') console.log('🔗 Connecting to WhatsApp!!');
+        if (connection === 'open') console.log('✅ Connected to WhatsApp');
+    });
+
     client.ev.on('messages.upsert', async ({ messages, type }) => {
-        if (type !== 'notify') return
-        const M = serialize(JSON.parse(JSON.stringify(messages[0])), client)
-        if (M.quoted?.participant) M.mentions.push(M.quoted.participant)
-        console.log(M.body)
-        if (
-            M.mentions.includes(client.user.id.split(':')[0] + '@s.whatsapp.net')
-        ) {
-            const text = await axios.get(`https://oni-chan-unique-api.vercel.app/gpt4?text=${M.body}`)
-            M.reply(text.data.result)
+        if (type !== 'notify') return;
+
+        const M = serialize(JSON.parse(JSON.stringify(messages[0])), client);
+
+        let response = '';
+        if (M.quoted) {
+            response += `Quoted message: ${M.quoted.body}\n\n`;
         }
 
+        try {
+            const text = await axios.get(`https://oni-chan-unique-api.vercel.app/gpt4?text=${M.body}`);
+            const botResponse = text.data.result;
+            response += `*🤖Bot:* ${botResponse}`;;
+
+            console.log(`${colors.user}👤 User: ${M.body}${colors.reset}`);
+            console.log(`${colors.bot}🤖 Bot: ${botResponse}${colors.reset}`);
+
+            M.reply(response);
+        } catch (error) {
+            console.error('❌ Error:', error.message);
+            M.reply('Sorry, an error occurred while processing your request.');
+        }
+    });
 
-    })
-    client.ev.on('creds.update', saveCreds)
-}
+    client.ev.on('creds.update', saveCreds);
+};
 
-start()
+start();