feat(discovery): add protocol API fallback for BSC pool auto-discovery

Author: DaviRain-Su

apps/dashboard/server.mjs

@@ -947,6 +947,20 @@ const BSC_LISTA_POOL_CANDIDATES = String(
 const BSC_WOMBAT_POOL_CANDIDATES = String(
 	envOrCfg("BSC_WOMBAT_POOL_CANDIDATES", "bsc.wombat.poolCandidates", ""),
 ).trim();
+const BSC_LISTA_POOL_DISCOVERY_API_URLS = String(
+	envOrCfg(
+		"BSC_LISTA_POOL_DISCOVERY_API_URLS",
+		"bsc.lista.poolDiscoveryApiUrls",
+		"",
+	),
+).trim();
+const BSC_WOMBAT_POOL_DISCOVERY_API_URLS = String(
+	envOrCfg(
+		"BSC_WOMBAT_POOL_DISCOVERY_API_URLS",
+		"bsc.wombat.poolDiscoveryApiUrls",
+		"",
+	),
+).trim();
 const BSC_WOMBAT_EXECUTE_PRIVATE_KEY = String(
 	envOrCfg(
 		"BSC_WOMBAT_EXECUTE_PRIVATE_KEY",
@@ -9310,6 +9324,63 @@ function parseAddressCandidates(raw) {
 		.filter((x) => /^0x[a-fA-F0-9]{40}$/.test(x));
 }
 
+function parseUrlCandidates(raw) {
+	return String(raw || "")
+		.split(/[\n,;]+/)
+		.map((x) => x.trim())
+		.filter((x) => /^https?:\/\//i.test(x));
+}
+
+function extractEvmAddressesFromJson(payload) {
+	const text = JSON.stringify(payload || {});
+	const found = text.match(/0x[a-fA-F0-9]{40}/g) || [];
+	return [...new Set(found.map((x) => x.toLowerCase()))];
+}
+
+async function fetchJsonWithTimeout(url, timeoutMs = 8000) {
+	const controller = new AbortController();
+	const timer = setTimeout(() => controller.abort(), timeoutMs);
+	try {
+		const res = await fetch(url, {
+			headers: { accept: "application/json" },
+			signal: controller.signal,
+		});
+		if (!res.ok) return null;
+		return await res.json();
+	} catch {
+		return null;
+	} finally {
+		clearTimeout(timer);
+	}
+}
+
+async function discoverPoolCandidatesFromProtocolApis(protocol) {
+	const key = String(protocol || "").toLowerCase();
+	const urlRaw =
+		key === "lista"
+			? BSC_LISTA_POOL_DISCOVERY_API_URLS
+			: BSC_WOMBAT_POOL_DISCOVERY_API_URLS;
+	const urls = parseUrlCandidates(urlRaw);
+	if (urls.length === 0) return [];
+	const excluded = new Set([
+		BSC_USDC.toLowerCase(),
+		BSC_USDT.toLowerCase(),
+		BSC_WBNB.toLowerCase(),
+		BSC_ROUTER_V2.toLowerCase(),
+		"0x0000000000000000000000000000000000000000",
+	]);
+	const out = [];
+	for (const url of urls) {
+		const payload = await fetchJsonWithTimeout(url);
+		if (!payload) continue;
+		const addrs = extractEvmAddressesFromJson(payload)
+			.filter((x) => !excluded.has(x))
+			.slice(0, 120);
+		for (const addr of addrs) out.push(addr);
+	}
+	return [...new Set(out)];
+}
+
 async function discoverPoolCandidatesFromDefiLlama(protocol) {
 	const key = String(protocol || "").toLowerCase();
 	const projectName = key === "lista" ? "lista" : "wombat-exchange";
@@ -9376,13 +9447,17 @@ async function discoverBscPoolsByProtocol(protocol) {
 	let candidates = parseAddressCandidates(candidateRaw);
 	let source = "env";
 	let warning = null;
+	if (candidates.length === 0) {
+		candidates = await discoverPoolCandidatesFromProtocolApis(key);
+		source = "protocol-api";
+	}
 	if (candidates.length === 0) {
 		candidates = await discoverPoolCandidatesFromDefiLlama(key);
 		source = "defillama";
-		if (candidates.length === 0) {
-			warning =
-				"auto-discovery found no BSC pool addresses from DeFiLlama; you can still set BSC_*_POOL_CANDIDATES manually";
-		}
+	}
+	if (candidates.length === 0) {
+		warning =
+			"auto-discovery found no BSC pool addresses from configured protocol API URLs or DeFiLlama; set BSC_*_POOL_DISCOVERY_API_URLS or BSC_*_POOL_CANDIDATES";
 	}
 	const rows = await scorePoolCandidates(candidates);
 	return {

docs/openclaw-strategy-tools-quickstart.md

@@ -144,12 +144,19 @@ npm run stable-yield:auto-migrate:v2:cron-install
 # last json: logs/stable-yield-auto-migrate-v2-last.json
 ```
 
-BSC 配置向导支持自动发现候选池（需提前配置候选地址列表）：
+BSC 配置向导支持自动发现候选池，优先级如下：
+1) `BSC_*_POOL_CANDIDATES`（手工候选）
+2) `BSC_*_POOL_DISCOVERY_API_URLS`（协议 API 自动抓取）
+3) DeFiLlama fallback
 
 ```bash
-# 逗号分隔多个候选池
+# 1) 逗号分隔多个候选池
 BSC_LISTA_POOL_CANDIDATES=0x...,0x...
 BSC_WOMBAT_POOL_CANDIDATES=0x...,0x...
+
+# 2) 可选：协议查询 API（逗号/分号分隔多个 URL）
+BSC_LISTA_POOL_DISCOVERY_API_URLS=https://.../lista/pools,https://.../bsc/lista
+BSC_WOMBAT_POOL_DISCOVERY_API_URLS=https://.../wombat/pools;https://.../bsc/wombat
 ```