const fcaMMTAT = require("fca-mmtat");
const fs = require("fs");

const appState = JSON.parse(fs.readFileSync("appstate.json", "utf8"));

fcaMMTAT({ appState }, (err, api) => {
  if (err) return console.error(err);

  // Bắt đầu lắng nghe
  api.listen((err, event) => {
    if (err) return;
    if (event.type === "message" && event.body === "!ping") {
      api.sendMessage("🏓 Pong!", event.threadID);
    }
  });
});

const router = api.createCommandRouter({
  prefix: "!",
  cooldown: 2000,
  adminUIDs: ["UID_ADMIN"],
});

router.command({
  name: "ping",
  description: "Kiểm tra bot",
  execute: async (event, args, api) => {
    api.sendMessage("Pong!", event.threadID);
  },
});

// Xây dựng text help tự động
router.buildHelpText("📋 Danh sách lệnh");

// Dùng trong listen
api.listen((err, event) => {
  router.handle(event, api);
});

const result = await api.broadcastMessage(
  "Thông báo tới tất cả!",
  ["thread1", "thread2", "thread3"],
  {
    delay: 500,         // ms giữa các tin
    stopOnError: false, // tiếp tục khi lỗi
    onSuccess: (tid) => console.log("Gửi thành công:", tid),
    onError: (tid, err) => console.log("Lỗi:", tid, err),
  }
);
console.log(result.success, result.failed);

await api.sendMessageWithRetry("Tin quan trọng", threadID, {
  maxRetries: 3,
  retryDelay: 2000,
  backoff: 1.5, // tăng delay: 2s, 3s, 4.5s
  onRetry: (attempt, err, delay) => console.log(`Retry #${attempt} sau ${delay}ms`),
});

// Lắng nghe tất cả tin nhắn
api.eventBus.on("message", (eventName, event) => {
  console.log("Tin mới:", event.body);
});

// Chỉ một lần
api.eventBus.once("message:event", (name, event) => {
  // xử lý sự kiện group
});

// Phát sự kiện tùy chỉnh
api.eventBus.emit("my:custom:event", { data: "hello" });

// Lưu vào cache
api.cache.set("user", "12345", userInfo, 600000); // TTL 10 phút

// Lấy từ cache
const info = api.cache.get("user", "12345");

// Lấy hoặc fetch nếu không có
const info = await api.cache.getOrFetch("thread", threadID, () =>
  api.getThreadInfo(threadID)
);

// Thống kê
console.log(api.cache.getStats());

// Xem thống kê
console.log(api.rateLimiter.getStats());

// Thay đổi cấu hình runtime
api.rateLimiter.setGlobalRps(3);
api.rateLimiter.setMinDelay(500);
api.rateLimiter.setEnabled(false); // tắt tạm

// Thêm whitelist (admin bypass spam check)
api.antiSpam.whitelist("ADMIN_UID");

// Kiểm tra thủ công
const { spam, remaining } = api.antiSpam.check(event.senderID);

// Bọc handler tự động
const safeHandler = api.antiSpam.wrap((event) => {
  // Chỉ chạy nếu không spam
  handleEvent(event);
}, { spamMessage: "⚠️ Gửi chậm thôi!" });

// Bỏ block thủ công
api.antiSpam.unblock("USER_UID");

// Load plugin từ file
await api.plugins.load("./plugins/my-plugin.js");

// Load plugin inline
await api.plugins.load({
  name: "MyPlugin",
  version: "1.0",
  async setup({ api, logger, addHook }) {
    addHook("message", async (event) => {
      // xử lý sự kiện
    });
    return {
      async cleanup() { /* dọn dẹp */ }
    };
  }
});

// Load cả thư mục
await api.plugins.loadDir("./plugins");

// Unload plugin
await api.plugins.unload("MyPlugin");

// Xem danh sách
console.log(api.plugins.list());

const { SessionManager } = require("fca-mmtat");

const manager = new SessionManager({ strategy: "round-robin" });

await manager.add("bot1", { appState: appState1 });
await manager.add("bot2", { appState: appState2 });

// Lắng nghe tất cả
manager.listenAll((event, api, session) => {
  console.log(`[${session.id}]`, event.body);
});

// Gửi tin (tự động chọn account)
await manager.sendMessage("Hello!", threadID);

// Thống kê
console.log(manager.getStats());

const stats = api.getSystemStats();
console.log(stats);
// {
//   version: "1.0.0",
//   name: "FCA-MMTAT",
//   userID: "...",
//   region: "SIN",
//   cache: { hitRate: "85.0%", totalItems: 42 },
//   rateLimiter: { globalQueueLength: 0 },
//   antiSpam: { total: 10, blocked: 1 },
//   plugins: [...]
// }

// plugins/my-plugin.js
module.exports = {
  name: "MyPlugin",
  version: "1.0.0",
  description: "Plugin mẫu",

  async setup({ api, eventBus, logger, options, addHook }) {
    logger("Plugin đang khởi động", "info");

    // Đăng ký hook xử lý message
    addHook("message", async (event) => {
      if (event.body === "hello") {
        api.sendMessage("World!", event.threadID);
      }
    });

    // Lắng nghe EventBus
    eventBus.on("message", (name, event) => {
      // xử lý sự kiện
    });

    return {
      // Được gọi khi unload plugin
      async cleanup() {
        logger("Plugin đang dừng");
      }
    };
  }
};