add absorb script and upgrade script
This commit is contained in:
420
scripts/handler.ts
Normal file
420
scripts/handler.ts
Normal file
@@ -0,0 +1,420 @@
|
||||
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();
|
||||
Reference in New Issue
Block a user