从 X/Twitter 帖子构建 DexScreener API 提醒

// Look up a token on DexScreener by chain + address
async function lookupToken(chainId: string, address: string) {
  const res = await fetch(
    `https://api.dexscreener.com/tokens/v1/${chainId}/${address}`
  );
  const pairs = await res.json();
 
  if (!pairs?.length) {
    console.log('No trading pairs found');
    return null;
  }
 
  // Get the highest-liquidity pair
  const topPair = pairs.sort(
    (a, b) => (b.liquidity?.usd ?? 0) - (a.liquidity?.usd ?? 0)
  )[0];
 
  return {
    symbol: topPair.baseToken.symbol,
    name: topPair.baseToken.name,
    price: topPair.priceUsd,
    priceChange24h: topPair.priceChange?.h24,
    volume24h: topPair.volume?.h24,
    liquidity: topPair.liquidity?.usd,
    dex: topPair.dexId,
    chain: topPair.chainId,
    pairUrl: topPair.url,
  };
}
 
// Example: look up PEPE on Ethereum
const token = await lookupToken('ethereum', '0x6982508145454Ce325dDbE47a25d4ec3d2311933');
console.log(token);
// { symbol: 'PEPE', price: '0.00001234', liquidity: 5200000, ... }

// Full tweet → token → price pipeline
const TICKER_REGEX = /\$([A-Z]{2,10})\b/g;
const EVM_ADDR_REGEX = /0x[a-fA-F0-9]{40}/g;
const SOLANA_ADDR_REGEX = /[1-9A-HJ-NP-Za-km-z]{32,44}/g;
 
async function searchToken(query: string) {
  const res = await fetch(
    `https://api.dexscreener.com/latest/dex/search?q=${encodeURIComponent(query)}`
  );
  const data = await res.json();
  return data.pairs ?? [];
}
 
async function processTweet(tweet: { text: string; ocr?: { text?: string } }) {
  const allText = [tweet.text, tweet.ocr?.text ?? ''].join(' ');
  const results = [];
 
  // Extract $TICKER symbols
  for (const match of allText.matchAll(TICKER_REGEX)) {
    const pairs = await searchToken(match[1]);
    if (pairs[0]) {
      results.push(pairs[0]);
    }
  }
 
  // Extract EVM contract addresses
  for (const match of allText.matchAll(EVM_ADDR_REGEX)) {
    const data = await lookupToken('ethereum', match[0]);
    if (data && (data.liquidity ?? 0) > 10_000) {
      results.push(data);
    }
  }
 
  // Extract Solana addresses
  for (const match of allText.matchAll(SOLANA_ADDR_REGEX)) {
    const data = await lookupToken('solana', match[0]);
    if (data && (data.liquidity ?? 0) > 10_000) {
      results.push(data);
    }
  }
 
  return results;
}