assetxContracts/scripts/utils/handler.ts

import { ethers, Contract, JsonRpcProvider } from "ethers";
import type { EventLog, Log } from "ethers";

// ==================== 类型定义 ====================

interface VaultConfig {
  name: string;
  address: string;
}

interface YTHolderData {
  address: string;
  balance: string;
}

interface LPHolderData {
  address: string;
  balance: string;
  share: string;
}

interface LendingSupplierData {
  address: string;
  supply: string;
  borrow: string;
  net: string;
}

// ==================== 配置 ====================

const RPC_URL: string = "https://api.zan.top/node/v1/arb/sepolia/baf84c429d284bb5b676cb8c9ca21c07";

// 合约配置（包含部署区块号，可以大幅减少查询时间）
const YT_VAULTS: VaultConfig[] = [
  { name: "YT-A", address: "0x97204190B35D9895a7a47aa7BaC61ac08De3cF05" },
  { name: "YT-B", address: "0x181ef4011c35C4a2Fda08eBC5Cf509Ef58E553fF" },
  { name: "YT-C", address: "0xE9A5b9f3a2Eda4358f81d4E2eF4f3280A664e5B0" },
];

const YTLP_ADDRESS: string = "0x102e3F25Ef0ad9b0695C8F2daF8A1262437eEfc3";
const LENDING_ADDRESS: string = "0xCb4E7B1069F6C26A1c27523ce4c8dfD884552d1D";

// ==================== 部署区块配置 ====================
//
// 配置说明：
// 1. 查询准确的部署区块号，直接填写

interface DeploymentConfig {
  ytVaults: number;   // YT 代币部署区块
  ytlp: number;       // ytLP 部署区块
  lending: number;    // Lending 部署区块
}

const DEPLOYMENT_BLOCKS: DeploymentConfig = {
  ytVaults: 227339300,  // YT-A/B/C 部署区块号
  ytlp: 227230270,      // ytLP 部署区块号
  lending: 227746053,   // Lending 部署区块号
};

// ==================== ABIs ====================

const ERC20_ABI = [
  "event Transfer(address indexed from, address indexed to, uint256 value)",
  "function balanceOf(address account) view returns (uint256)",
  "function totalSupply() view returns (uint256)",
] as const;

const LENDING_ABI = [
  "event Supply(address indexed from, address indexed dst, uint256 amount)",
  "function supplyBalanceOf(address account) view returns (uint256)",
  "function borrowBalanceOf(address account) view returns (uint256)",
] as const;

// ==================== 工具函数 ====================

/**
 * 分块查询事件，避免超出 RPC 限制
 * @param contract 合约实例
 * @param filter 事件过滤器
 * @param fromBlock 起始区块
 * @param toBlock 结束区块
 * @param batchSize 每批次的区块数量（默认 9999，低于 10000 限制）
 */
async function queryEventsInBatches(
  contract: Contract,
  filter: any,
  fromBlock: number,
  toBlock: number,
  batchSize: number = 9999
): Promise<(EventLog | Log)[]> {
  const allEvents: (EventLog | Log)[] = [];
  let currentBlock = fromBlock;

  console.log(`    查询区块范围: ${fromBlock} -> ${toBlock} (总共 ${toBlock - fromBlock + 1} 个区块)`);

  while (currentBlock <= toBlock) {
    const endBlock = Math.min(currentBlock + batchSize, toBlock);

    console.log(`    正在查询区块 ${currentBlock} - ${endBlock}...`);

    try {
      const events = await contract.queryFilter(filter, currentBlock, endBlock);
      allEvents.push(...events);
      console.log(`    ✓ 获取到 ${events.length} 个事件`);
    } catch (error) {
      console.error(`    ✗ 查询区块 ${currentBlock} - ${endBlock} 失败:`, error);
      throw error;
    }

    currentBlock = endBlock + 1;

    // 添加小延迟，避免触发 RPC 速率限制
    if (currentBlock <= toBlock) {
      await new Promise(resolve => setTimeout(resolve, 100));
    }
  }

  console.log(`    总计获取 ${allEvents.length} 个事件\n`);
  return allEvents;
}

/**
 * 获取当前最新区块号
 */
async function getLatestBlockNumber(provider: JsonRpcProvider, silent: boolean = false): Promise<number> {
  const blockNumber = await provider.getBlockNumber();
  if (!silent) {
    console.log(`当前最新区块: ${blockNumber}\n`);
  }
  return blockNumber;
}

// ==================== 主函数 ====================

// 记录上次扫描的区块号
let lastScannedBlock: number = 0;
// 标记是否正在扫描，防止并发
let isScanning: boolean = false;

// 全局地址集合，用于追踪所有曾经出现过的地址
const allYTAddresses: Map<string, Set<string>> = new Map(); // vault address -> holder addresses
const allLPAddresses: Set<string> = new Set();
const allLendingAddresses: Set<string> = new Set();

async function getAllHolders(
  provider: JsonRpcProvider,
  fromBlock?: number,
  toBlock?: number,
  isInitialScan: boolean = false
): Promise<void> {
  // 获取最新区块号
  const latestBlock = toBlock || await getLatestBlockNumber(provider, fromBlock !== undefined);

  // 计算起始区块
  let ytVaultsStartBlock: number;
  let ytlpStartBlock: number;
  let lendingStartBlock: number;

  if (fromBlock !== undefined) {
    // 增量扫描模式
    ytVaultsStartBlock = ytlpStartBlock = lendingStartBlock = fromBlock;
    console.log(`\n🔄 增量扫描: 区块 ${fromBlock} -> ${latestBlock}\n`);
  } else {
    // 首次扫描：使用部署区块号
    ytVaultsStartBlock = DEPLOYMENT_BLOCKS.ytVaults;
    ytlpStartBlock = DEPLOYMENT_BLOCKS.ytlp;
    lendingStartBlock = DEPLOYMENT_BLOCKS.lending;
    if (isInitialScan) {
      console.log(`✨ 首次扫描，从部署区块开始:`);
      console.log(`   YT Vaults 起始区块: ${ytVaultsStartBlock}`);
      console.log(`   ytLP 起始区块: ${ytlpStartBlock}`);
      console.log(`   Lending 起始区块: ${lendingStartBlock}\n`);
    }
  }

  // 1. 获取 YT 代币持有者
  console.log("1. YT 代币持有者:");

  for (const vault of YT_VAULTS) {
    console.log(`  正在查询 ${vault.name} (${vault.address})...`);
    const contract: Contract = new ethers.Contract(vault.address, ERC20_ABI, provider);
    const filter = contract.filters.Transfer();
    const events: (EventLog | Log)[] = await queryEventsInBatches(
      contract,
      filter,
      ytVaultsStartBlock,
      latestBlock
    );

    // 初始化该 vault 的地址集合（如果不存在）
    if (!allYTAddresses.has(vault.address)) {
      allYTAddresses.set(vault.address, new Set<string>());
    }
    const vaultAddresses = allYTAddresses.get(vault.address)!;

    // 记录新增地址数量
    const previousCount = vaultAddresses.size;

    // 添加新发现的地址到全局集合
    for (const event of events) {
      if ("args" in event && event.args.to !== ethers.ZeroAddress) {
        vaultAddresses.add(event.args.to as string);
      }
    }

    const newAddressCount = vaultAddresses.size - previousCount;
    if (newAddressCount > 0) {
      console.log(`    发现 ${newAddressCount} 个新地址，总共追踪 ${vaultAddresses.size} 个地址`);
    }

    // 查询所有曾经出现过的地址的当前余额
    const holders: YTHolderData[] = [];
    for (const address of vaultAddresses) {
      const balance: bigint = await contract.balanceOf(address);
      if (balance > 0n) {
        holders.push({
          address,
          balance: ethers.formatEther(balance),
        });
      }
    }

    // 按余额降序排序
    holders.sort((a, b) => parseFloat(b.balance) - parseFloat(a.balance));

    console.log(`  ${vault.name}: ${holders.length} 持有者`);
    if (holders.length > 0) {
      console.log(`  前 10 名持有者:`);
      const top10 = holders.slice(0, 10);
      top10.forEach((h: YTHolderData, index: number) =>
        console.log(`    ${index + 1}. ${h.address}: ${h.balance}`)
      );
    } else {
      console.log(`    暂无持有者`);
    }
  }

  // 2. 获取 LP 代币持有者
  console.log("\n2. LP 代币持有者 (ytLP):");
  console.log(`  正在查询 ytLP (${YTLP_ADDRESS})...`);
  const lpContract: Contract = new ethers.Contract(YTLP_ADDRESS, ERC20_ABI, provider);
  const lpFilter = lpContract.filters.Transfer();
  const lpEvents: (EventLog | Log)[] = await queryEventsInBatches(
    lpContract,
    lpFilter,
    ytlpStartBlock,
    latestBlock
  );

  // 记录新增地址数量
  const previousLPCount = allLPAddresses.size;

  // 添加新发现的地址到全局集合
  for (const event of lpEvents) {
    if ("args" in event && event.args.to !== ethers.ZeroAddress) {
      allLPAddresses.add(event.args.to as string);
    }
  }

  const newLPAddressCount = allLPAddresses.size - previousLPCount;
  if (newLPAddressCount > 0) {
    console.log(`  发现 ${newLPAddressCount} 个新地址，总共追踪 ${allLPAddresses.size} 个地址`);
  }

  // 查询所有曾经出现过的地址的当前余额
  const lpHolders: LPHolderData[] = [];
  const totalSupply: bigint = await lpContract.totalSupply();

  for (const address of allLPAddresses) {
    const balance: bigint = await lpContract.balanceOf(address);
    if (balance > 0n) {
      const share: string = (Number(balance) / Number(totalSupply) * 100).toFixed(4);
      lpHolders.push({
        address,
        balance: ethers.formatEther(balance),
        share: share + "%",
      });
    }
  }

  // 按余额降序排序
  lpHolders.sort((a, b) => parseFloat(b.balance) - parseFloat(a.balance));

  console.log(`  总计: ${lpHolders.length} 持有者`);
  if (lpHolders.length > 0) {
    console.log(`  前 10 名持有者:`);
    const top10 = lpHolders.slice(0, 10);
    top10.forEach((h: LPHolderData, index: number) =>
      console.log(`    ${index + 1}. ${h.address}: ${h.balance} (${h.share})`)
    );
  } else {
    console.log(`    暂无持有者`);
  }

  // 3. 获取 Lending 提供者
  console.log("\n3. Lending 提供者:");
  console.log(`  正在查询 Lending (${LENDING_ADDRESS})...`);
  const lendingContract: Contract = new ethers.Contract(LENDING_ADDRESS, LENDING_ABI, provider);
  const supplyFilter = lendingContract.filters.Supply();
  const supplyEvents: (EventLog | Log)[] = await queryEventsInBatches(
    lendingContract,
    supplyFilter,
    lendingStartBlock,
    latestBlock
  );

  // 记录新增地址数量
  const previousLendingCount = allLendingAddresses.size;

  // 添加新发现的地址到全局集合
  for (const event of supplyEvents) {
    if ("args" in event) {
      allLendingAddresses.add(event.args.dst as string);
    }
  }

  const newLendingAddressCount = allLendingAddresses.size - previousLendingCount;
  if (newLendingAddressCount > 0) {
    console.log(`  发现 ${newLendingAddressCount} 个新地址，总共追踪 ${allLendingAddresses.size} 个地址`);
  }

  // 查询所有曾经出现过的地址的当前余额
  const suppliers: LendingSupplierData[] = [];
  for (const address of allLendingAddresses) {
    const supplyBalance: bigint = await lendingContract.supplyBalanceOf(address);
    const borrowBalance: bigint = await lendingContract.borrowBalanceOf(address);

    if (supplyBalance > 0n || borrowBalance > 0n) {
      suppliers.push({
        address,
        supply: ethers.formatUnits(supplyBalance, 6),
        borrow: ethers.formatUnits(borrowBalance, 6),
        net: ethers.formatUnits(supplyBalance - borrowBalance, 6),
      });
    }
  }

  // 按净供应额降序排序
  suppliers.sort((a, b) => parseFloat(b.net) - parseFloat(a.net));

  console.log(`  总计: ${suppliers.length} 参与者`);
  if (suppliers.length > 0) {
    console.log(`  前 10 名参与者:`);
    const top10 = suppliers.slice(0, 10);
    top10.forEach((s: LendingSupplierData, index: number) =>
      console.log(
        `    ${index + 1}. ${s.address}: 供应=${s.supply} USDC, 借款=${s.borrow} USDC, 净额=${s.net} USDC`
      )
    );
  } else {
    console.log(`    暂无参与者`);
  }

  // 更新上次扫描的区块号
  lastScannedBlock = latestBlock;
  console.log(`\n📌 已记录扫描区块: ${lastScannedBlock}`);
}

// ==================== 执行 ====================

const POLL_INTERVAL_MS = 10000; // 10秒轮询间隔

async function main(): Promise<void> {
  const provider: JsonRpcProvider = new ethers.JsonRpcProvider(RPC_URL);

  console.log("=== ytLp 协议 Holder 数据监控 ===\n");
  console.log(`轮询间隔: ${POLL_INTERVAL_MS / 1000} 秒\n`);

  try {
    // 首次扫描：从部署区块到当前区块
    console.log("📊 开始首次扫描...\n");
    const startTime = Date.now();
    await getAllHolders(provider, undefined, undefined, true);
    const endTime = Date.now();
    const duration = ((endTime - startTime) / 1000).toFixed(2);
    console.log(`\n✓ 首次扫描完成，耗时 ${duration} 秒`);

    // 启动轮询
    console.log(`\n⏰ 开始轮询，每 ${POLL_INTERVAL_MS / 1000} 秒检查一次新区块...\n`);

    setInterval(async () => {
      try {
        // 如果正在扫描，跳过本次轮询
        if (isScanning) {
          console.log(`⏰ [${new Date().toLocaleString()}] 跳过本次轮询（上次扫描仍在进行中）`);
          return;
        }

        const currentBlock = await provider.getBlockNumber();

        // 如果有新区块，进行增量扫描
        if (currentBlock > lastScannedBlock) {
          isScanning = true; // 标记开始扫描

          console.log(`\n${"=".repeat(60)}`);
          console.log(`⏰ [${new Date().toLocaleString()}] 发现新区块`);
          console.log(`${"=".repeat(60)}`);

          const scanStart = Date.now();
          await getAllHolders(provider, lastScannedBlock + 1, currentBlock, false);
          const scanDuration = ((Date.now() - scanStart) / 1000).toFixed(2);
          console.log(`\n✓ 增量扫描完成，耗时 ${scanDuration} 秒`);

          isScanning = false; // 标记扫描完成
        } else {
          console.log(`⏰ [${new Date().toLocaleString()}] 暂无新区块 (当前: ${currentBlock})`);
        }
      } catch (error) {
        console.error(`\n✗ 轮询过程中发生错误:`, error);
        isScanning = false; // 发生错误时也要重置标记
      }
    }, POLL_INTERVAL_MS);

  } catch (error) {
    console.error("\n✗ 发生错误:", error);
    process.exit(1);
  }
}

main();