handler.js

import axios from 'axios'
import {
  jidNormalizedUser
} from 'baileys'
import util from 'util'
import cp from 'child_process'
import cron from 'node-cron';
import moment from 'moment-timezone';

import Api from '#lib/api.js'
import Func from '#lib/function.js'
import log from '#lib/logger.js'

export default async function Command(conn, m) {
  const quoted = m.isQuoted ? m.quoted : m
  const downloadM = async (filename) => await conn.downloadMediaMessage(quoted, filename)
  const isCommand = (m.prefix && m.body.startsWith(m.prefix)) || false
  const isOwner = m.fromMe || cfg.bot.owner.includes(m.sender.split('@')[0])

  await db.main(m)
  if (m.isBot) return
  if (!isOwner && db.list().settings.self) return;


  // const isAdmin = m.isGroup && metadata.participants.find(u => conn.getJid(u.id) === m.sender).admin == 'admin' || false;
  // const isBotAdmin = m.isGroup && metadata.participants.find(u => conn.getJid(u.id) === jidNormalizedUser(conn.user.id)).admin == 'admin' || false;
  // Ambil metadata grup atau set null untuk private message
  const metadata = m.isGroup ?
    conn.chats[m.chat] || (await conn.groupMetadata(m.chat).catch(() => null)) :
    null; // Gak perlu group metadata untuk private message

  // Cek kalau lagi di grup dan metadata participants-nya gak ada
  if (m.isGroup && !metadata?.participants) {
    console.error("⚠️ Metadata participants tidak ditemukan, bukan grup atau metadata belum ke-load");
    return;
  }

  // Ambil data pengirim dan bot
  let senderData = m.isGroup ?
    metadata.participants.find(u => conn.getJid(u.id) === m.sender) :
    {
      id: m.sender
    }; // Default sender data untuk private message

  let botData = m.isGroup ?
    metadata.participants.find(u => conn.getJid(u.id) === jidNormalizedUser(conn.user.id)) :
    {
      id: jidNormalizedUser(conn.user.id)
    }; // Default bot data untuk private message

  let isAdmin = m.isGroup && senderData && senderData.admin === 'admin';
  let isBotAdmin = m.isGroup && botData && botData.admin === 'admin';
  // Untuk private message, kamu bisa set admin dan botAdmin sesuai kebutuhan
  if (!m.isGroup) {
    isAdmin = false; // Misalnya bot gak punya role admin di private message
    isBotAdmin = true; // Misalnya bot selalu dianggap admin di private message
  }
  const Scrape = await scrape.list();
  const isPrems = db.list().user[m.sender].premium.status;
  const isBans = db.list().user[m.sender].banned.status;

  cron.schedule("* * * * *", () => {
    let user = Object.keys(db.list().user);
    let time = moment.tz("Asia/Jakarta").format("HH:mm");
    if (db.list().settings.resetlimit == time) {
      for (let i of user) {
        db.list().user[i].limit = 100;
      }
    }
  });

  const ctx = {
    Api,
    Func,
    downloadM,
    quoted,
    metadata,
    isOwner,
    isAdmin,
    isBotAdmin,
    isPrems,
    isBans,
    log,
    Scrape
  }

  for (const plugin of Object.values(plugins)) {
    if (typeof plugin.on === 'function') {
      try {
        const handled = await plugin.on.call(conn, m, ctx)
        if (handled) continue
      } catch (e) {
        console.error(`[PLUGIN EVENT ERROR] ${plugin.name}`, e)
      }
    }

    if (isCommand) {
      const command = m.command?.toLowerCase()
      const isCmd =
        plugin?.command?.includes(command) ||
        (plugin?.alias && plugin.alias.includes(command))

      try {
        if (isCmd) {
          if (plugin.settings?.owner && !isOwner) {
            m.reply(cfg.mess.owner)
            continue
          }
          if (plugin.settings?.private && m.isGroup) {
            m.reply(cfg.mess.private)
            continue
          }
          if (plugin.settings?.group && !m.isGroup) {
            m.reply(cfg.mess.group)
            continue
          }
          if (plugin.settings?.admin && !isAdmin) {
            m.reply(cfg.mess.admin)
            continue
          }
          if (plugin.settings?.botAdmin && !isBotAdmin) {
            m.reply(cfg.mess.botAdmin)
            continue
          }
          if (plugin.settings?.premium && !isPrems) {
            m.reply(cfg.mess.premium)
            continue
          }
          if (plugin.settings?.free && isPrems) {
            m.reply(cfg.mess.free)
            continue
          }

          if (plugin.settings?.loading) m.reply(cfg.mess.wait)

          plugin.run(conn, m, ctx)
            .then(async (a) => {
              if (plugin.settings?.limit && !isPrems && !isOwner) {
                db.list().user[m.sender].limit -= 1;
                let info = `Halo kak!, Kamu baru aja pkek fitur limit 😄
Sekarang limit kakk tersisa (${db.list().user[m.sender].limit} Limit) kak.
limit bakal tereset tiap jam 2:00 WIB kak!`;
                m.reply(info);
              }
            })
        }
      } catch (e) {
        console.error(`[PLUGIN ERROR] ${plugin.name}`, Func.jsonFormat(e))
        await m.reply('Terjadi error saat menjalankan command.')
      } finally {
        if (db.list().settings.online) {
          await conn.readMessages([m.key]);
        }
      }
    }
  }

  if (['>', '=>'].some((a) => m.body?.toLowerCase().startsWith(a)) && isOwner) {
    let evalCmd = ''
    try {
      evalCmd = /await/i.test(m.text) ?
        eval(`(async() => { ${m.text} })()`) :
        eval(m.text)
    } catch (e) {
      evalCmd = e
    }

    new Promise((resolve, reject) => {
        try {
          resolve(evalCmd)
        } catch (err) {
          reject(err)
        }
      })
      ?.then((res) => m.reply(util.format(res)))
      ?.catch((err) => m.reply(util.format(err)))
  }

  if (m.body?.startsWith('$') && isOwner) {
    const exec = util.promisify(cp.exec).bind(cp)
    let o
    try {
      o = await exec(m.text)
    } catch (e) {
      o = e
    } finally {
      const {
        stdout,
        stderr
      } = o
      if (stdout.trim()) m.reply(stdout)
      if (stderr.trim()) m.reply(stderr)
    }
  }
}