module.exports = {
  config: {
    name: "inbox",
    version: "1.0.1",
    author: "HR ID OY",
    countDown: 3,
    role: 0,
    shortDescription: "View FCA inbox",
    longDescription: "View the connected HRIDOY-FCA inbox.",
    category: "system",
    guide: { en: "{pn} | {pn} unread | {pn} requests | {pn} view <threadID> | {pn} health" }
  },

  onStart: async function ({ api, event, args, message }) {
    const fca = global.hridoyFCA || api;
    const send = text => message && typeof message.reply === "function"
      ? message.reply(text)
      : new Promise((resolve,reject)=>api.sendMessage(text,event.threadID,e=>e?reject(e):resolve()));

    try {
      if (!fca) return send("❌ FCA is not connected.");

      const sub=String(args?.[0]||"").toLowerCase();

      if (sub==="health" && typeof fca.getHealth==="function") {
        const h=fca.getHealth()||{};
        return send(`📡 FCA HEALTH\n\n❤️ Score: ${h.score??"N/A"}\n🔌 Connected: ${h.connected??"unknown"}\n💓 Heartbeat: ${h.heartbeatOk??"unknown"}`);
      }
      if (sub==="unread" && typeof fca.getUnreadCount==="function")
        return send(`🔴 Unread: ${fca.getUnreadCount()}`);
      if (sub==="requests" && typeof fca.getMessageRequests==="function") {
        const rows=await Promise.resolve(fca.getMessageRequests(10));
        return send(rows?.length ? "📨 MESSAGE REQUESTS\n\n"+rows.map((x,i)=>`${i+1}. ${x.name||x.threadName||"Unknown"}\n🆔 ${x.threadID||x.id||"?"}`).join("\n\n") : "📭 No message requests.");
      }
      if (sub==="view") {
        const tid=args?.[1];
        if (!tid) return send("⚠️ Use: inbox view <threadID>");
        if (typeof fca.getThreadHistoryPaged!=="function") return send("❌ FCA history API is unavailable.");
        const r=await fca.getThreadHistoryPaged(tid,{amount:20,pages:1});
        const items=r?.items||[];
        return send(items.length ? `📨 ${tid}\n\n`+items.map(m=>`👤 ${m.senderName||m.senderID||"Unknown"}: ${String(m.body||m.message||m.text||"(attachment)").slice(0,180)}`).join("\n") : "📭 No history found.");
      }
      if (typeof fca.getUnifiedInbox!=="function") return send("❌ FCA unified inbox API is unavailable.");
      const limit=Math.min(30,Math.max(1,Number(sub)||10));
      const rows=await fca.getUnifiedInbox(limit);
      if (!rows?.length) return send("📭 Inbox is empty.");
      return send("📥 HRIDOY-FCA INBOX\n\n"+rows.map((t,i)=>`${i+1}. ${t.name||t.threadName||"(unnamed)"}\n🆔 ${t.threadID||t.id||"?"}${Number(t.unreadCount)?`\n🔴 Unread: ${t.unreadCount}`:""}${t.snippet||t.lastMessage?.body?`\n💬 ${String(t.snippet||t.lastMessage.body).slice(0,120)}`:""}`).join("\n\n"));
    } catch (e) {
      return send(`❌ Inbox error [${e?.code||"UNKNOWN_ERROR"}]\n${String(e?.message||e).slice(0,240)}`);
    }
  }
};