bot.js

import makeWASocket, { useMultiFileAuthState, DisconnectReason } from "@whiskeysockets/baileys";
import pino from "pino";
import qrcode from "qrcode-terminal";
import QRCode from "qrcode";
import { v4 as uuid } from "uuid";
import dotenv from "dotenv";

import { summarizeText } from "./summarizer.js";
import { addMessage } from "./store.js";
import { targets } from "./targets.js";

dotenv.config();

export async function startBot() {
  const { state, saveCreds } = await useMultiFileAuthState("./auth_info");

  const sock = makeWASocket({
    auth: state,
    browser: ["MVPBot", "Chrome", "1.0"],
    logger: pino({ level: "silent" })
  });

  sock.ev.on("creds.update", saveCreds);

  // -------------------------------------
  // Connection updates
  // -------------------------------------
  sock.ev.on("connection.update", async ({ connection, lastDisconnect, qr }) => {
    if (qr) {
      console.log("Scan QR:");
      qrcode.generate(qr, { small: true });
      QRCode.toFile("qr.png", qr);
    }

    if (connection === "close") {
      const reason = lastDisconnect?.error?.output?.statusCode;

      if (reason !== DisconnectReason.loggedOut) {
        console.log("Reconnecting...");
        startBot();
      }
    } else if (connection === "open") {
      console.log("Connected to WhatsApp");
    }
  });

  // -------------------------------------
  // Incoming messages
  // -------------------------------------
  sock.ev.on("messages.upsert", async ({ messages }) => {
    for (const msg of messages) {
      if (!msg.message) continue;
      if (msg.key.fromMe) continue;

      const sender = msg.key.remoteJid;
      console.log("from" ,sender)

      // Only accept allowed target numbers
      const targetInfo = targets.get(sender);
      if (!targetInfo) return;

      const { name } = targetInfo;

      // Extract message text
      const text =
        msg.message.conversation ||
        msg.message.extendedTextMessage?.text ||
        null;

      if (!text) continue;

      console.log(`From: ${name}`);
      console.log("Message:", text);

      // -------------------------------------
      // Summarize text
      // -------------------------------------
    const { tone, summary } = await summarizeText(text);

    addMessage({
      id: uuid(),
      sender,
      name,
      tone,
      summary,
      ts: Date.now(),
});

      console.log("Saved & summarized.");
    }
  });
}