Merge branch 'main' of https://git.max.xch.im/maxmind/byreal-watcher

const.js

@@ -1,5 +1,6 @@
 export const TOKEN_MAP = {
-    'MON': 'FPBW9dtVRoUug2BeUKZAzaknd6iiet9jHM8RcTvwUkyC'
+    'MON': 'FPBW9dtVRoUug2BeUKZAzaknd6iiet9jHM8RcTvwUkyC',
+    'WET': '12aL7RCHHm2Y2qWqtzYEBtddWUXzQxjf2S5uA45Ev9Hj'
 }
 
 export const SMART_WALLET = [

index.mjs

@@ -16,7 +16,7 @@ let firstRun = true
 /**
  * 获取 top-positions 数据
  */
-async function fetchTopPositions() {
+async function fetchTopPositions(token_symbol) {
   try {
     const response = await fetch(API_URL, {
       method: 'POST',
@@ -24,7 +24,7 @@ async function fetchTopPositions() {
         'content-type': 'application/json',
       },
       body: JSON.stringify({
-        poolAddress: DEFAULT_POOL_ADDRESS,
+        poolAddress: TOKEN_MAP[token_symbol],
         page: 1,
         pageSize: 200,
         sortField: 'liquidity',
@@ -230,10 +230,10 @@ function calculateAPR(position) {
 /**
  * 处理新仓位
  */
-async function processPositions() {
+async function processPositions(token_symbol) {
   console.log(`\n[${new Date().toLocaleString('zh-CN')}] 开始检查新仓位...`)
   
-  const { records, symbol } = await fetchTopPositions()
+  const { records, symbol } = await fetchTopPositions(token_symbol)
   
   if (!records) {
     console.log('获取数据失败')
@@ -315,9 +315,14 @@ console.log(`- 最大年龄: ${MAX_AGE_MS / 1000 / 60} 分钟`)
 console.log(`- Discord Webhook: ${DISCORD_WEBHOOK_URL}`)
 
 // 立即执行一次
-processPositions()
+processPositions('MON')
+processPositions('WET')
 
 // 每5分钟执行一次
+setInterval(() => {
+    processPositions('MON')
+    processPositions('WET')
+}, INTERVAL_MS)
 setInterval(processPositions, INTERVAL_MS)
 
 setInterval(processTradePair, MAX_AGE_MS)