项目出发点

最近在币安 bsc 链上有一个很火的币叫babydoge，目前还没有上主流交易所，而是在 bsc 链上的去中心化交易所 pancakeswap 上，所以作为程序员，我们就可以通过监控链上数据来监控整个这个币的买卖。

开发思路

监控 babydoge 合约的 Transfer 事件
查询这个 Transfer 事件所对应的 Transaction 是否来自于 PancakeSwap，如果不是说明本次只是一次普通的转账，直接丢弃即可
如果是，下一步就是算出本次买 /卖了多少个 babydoge，对应的资产价值是多少 USDT （美元）
将结果存入数据库做实时分析监控

下面我们一步一步完成整个开发

1 、开发环境

开发语言为 Javascript + Node.js
通过 ethers.js 和链交互
使用 express.js 做 http 服务器
使用 prisma 作为 orm 和数据库交互（我使用的 postgresql ）

2 、监控 Transfer 事件

我们从币安区块链浏览器中找到 babydoge 的合约地址： https://bscscan.com/token/0xc748673057861a797275CD8A068AbB95A902e8de

可以看出这是一个 ERC20 的合约，我们直接通过 bsc 官方节点构造一个 provider 开始监听 Transfer 事件

const provider = ethers.getDefaultProvider('https://bsc-dataseed.binance.org/'); const filter = { address: babydogeAddress, topics: [ethers.utils.id('Transfer(address,address,uint256)')], }; provider.on(filter, analyseTransferEvent);

这样就可以将所有的 Transfer 事件全部转移给 analyseTransferEvent 函数处理

3 、获取本次交易的相关数据

我们可以从 event 事件中拿到本次交易的 hash 值，然后通过 provider 获取到完整的数据

async function analyseTransferEvent(event) { // 获取 transaction 详情 const res = await provider.getTransaction(event.transactionHash); if (res.to !== pancakeAddress) { // 可能是一笔普通转账，不是 pancake 交易 return; } }

同时，我们可以将不是来自 pancakeswap 的数据直接丢弃（普通转账类型）

然后是如何获取本次交易的类型（买 /卖）和交易 babydoge 数量，这里我们需要利用 babydoge 的 abi 生成一个数据解析器来解析 event 事件，babydoge 的 abi 信息可以直接从区块链浏览器中获取 https://bscscan.com/address/0xc748673057861a797275CD8A068AbB95A902e8de#code

代码如下

const babydogeInterface = new ethers.utils.Interface(babydogeAbi); // 解析 event const parsedEvent = babydogeInterface.parseLog(event); // 交易发起人 const address = res.from; // 买 /卖 const action = address === parsedEvent.args.from ? 'SELL' : 'BUY'; // 交易数量 去掉后 9 位（ babydoge 有 9 位精度） const amount = Number(parsedEvent.args.value) / 1e9;

最后是最麻烦的怎么知道用户本次交易的资金是多少，价值多少美金，我分析了 pancakeswap 的源码，发现总有以下几种交易类型

用 BNB 和 babydoge 交易
用 wBNB 和 babydoge 交易
用美元类代币(BUSD, BSC-USD) 和 babydoge 交易
用其他不知道 ERC20 币，通过 BNB/BUSD 中转，和 Babydoge 交易

最终我定下的代码策略是这样的

对于 BNB 或者 wBNB 代币交易，直接乘以 bnb 价格即可（通过爬虫维护一个 bnb 的实时价格 https://bscscan.com/ 从这个网站左上角就有）
对于使用美元代币的交易，直接拿到数量即可
对于使用其他 ERC20 代币的交易，我们直接 bsc 官方浏览器通过爬虫爬取本次的价格（这种交易比例低）

最终部分代码如下

 async function analyseTransferEvent(event) { // 获取 transaction 详情 const res = await provider.getTransaction(event.transactionHash); if (res.to !== pancakeAddress) { // 可能是一笔普通转账，不是 pancake 交易 return; } // 解析 input 数据 const input = pancakeInterface.parseTransaction({ data: res.data, value: res.value }); // 解析 event const parsedEvent = babydogeInterface.parseLog(event); // 获取 transfer 事件的数据 from -> to, value const address = res.from; // 本次交易的总价值 let usdValue = 0; // 买 /卖 const action = address === parsedEvent.args.from ? 'SELL' : 'BUY'; // 交易数量 去掉后 9 位 const amount = Number(parsedEvent.args.value) / 1e9; if (!input.name.includes('swap')) { return; } if (input.name.includes('ETH')) { // swapExactETHForTokens // swapExactETHForTokensSupportingFeeOnTransferTokens // swapExactTokensForETH // swapExactETHForTokensSupportingFeeOnTransferTokens // 使用 bnb 交易的 4 个方法 let bnb; if (res.value > 0) { // 用 bnb 买 bnb = Number(res.value); } else { // 卖成了 wBNB 交易 bnb = Number(input.args.amountOutMin); } usdValue = (getBnbPrice() * bnb) / 1e18; } else { // 用其他货币买或者卖 const path = input.args.path.map((it) => it.toLowerCase()); let inAmount, outAmount; if (input.name.includes('swapExactTokensForTokens')) { inAmount = Number(input.args.amountIn); outAmount = Number(input.args.amountOutMin); } else if (input.name.includes('swapTokensForExactTokens')) { inAmount = Number(input.args.amountInMax); outAmount = Number(input.args.amountOut); } if (action === 'BUY' && wBnbAddress === path[0]) { // 使用 wBnb 购买 usdValue = (getBnbPrice() * inAmount) / 1e18; } else if (action === 'BUY' && usdAddress.includes(path[0])) { // 使用 busd 购买 usdValue = inAmount / 1e18; } else if (action === 'SELL' && usdAddress.includes(_.last(path))) { // 卖成 busd usdValue = outAmount / 1e18; } else { // 使用非标准代币，从币安网站爬虫算一下价格 usdValue = await usdValueFromBinance(event.transactionHash); if (!usdValue) { console.log(`价格爬虫失败`, event.transactionHash); return; } } } if (usdValue < 1) { // 忽略 1 美元以下的交易 return; } // 将数据存到数据库 ...... }

最终实现效果如下：