Add blockchain statistics and caching capabilities

Author: LegendarySSS

basic/83-blockchain-indexer/src/api/routes.js

@@ -1,12 +1,52 @@
 const express = require('express');
 const router = express.Router();
+const { Block } = require('../utils/db');
+const NodeCache = require('node-cache');
 
-// 获取区块信息
+// 创建缓存实例，默认缓存时间10分钟
+const cache = new NodeCache({ stdTTL: 600 });
+
+/**
+ * @api {get} /block/:blockNumber 获取区块信息
+ * @apiName GetBlock
+ * @apiGroup Blockchain
+ * @apiParam {Number} blockNumber 区块号
+ * @apiSuccess {Boolean} success 请求是否成功
+ * @apiSuccess {Object} data 区块数据
+ */
 router.get('/block/:blockNumber', async (req, res) => {
   try {
-    const blockNumber = req.params.blockNumber;
-    // TODO: 从数据库获取区块信息
-    const blockInfo = {}; // 替换为实际的数据库查询
+    const blockNumber = parseInt(req.params.blockNumber);
+    
+    // 参数验证
+    if (isNaN(blockNumber) || blockNumber < 0) {
+      return res.status(400).json({
+        success: false,
+        error: '无效的区块号'
+      });
+    }
+
+    // 检查缓存
+    const cacheKey = `block_${blockNumber}`;
+    const cachedBlock = cache.get(cacheKey);
+    if (cachedBlock) {
+      return res.json({
+        success: true,
+        data: cachedBlock
+      });
+    }
+
+    // 从数据库获取区块信息
+    const blockInfo = await Block.findOne({ number: blockNumber });
+    if (!blockInfo) {
+      return res.status(404).json({
+        success: false,
+        error: '区块未找到'
+      });
+    }
+
+    // 设置缓存
+    cache.set(cacheKey, blockInfo)
     res.json({
       success: true,
       data: blockInfo
@@ -19,12 +59,49 @@ router.get('/block/:blockNumber', async (req, res) => {
   }
 });
 
-// 获取交易信息
+/**
+ * @api {get} /transaction/:txHash 获取交易信息
+ * @apiName GetTransaction
+ * @apiGroup Blockchain
+ * @apiParam {String} txHash 交易哈希
+ * @apiSuccess {Boolean} success 请求是否成功
+ * @apiSuccess {Object} data 交易数据
+ */
 router.get('/transaction/:txHash', async (req, res) => {
   try {
     const txHash = req.params.txHash;
-    // TODO: 从数据库获取交易信息
-    const txInfo = {}; // 替换为实际的数据库查询
+    
+    // 参数验证
+    if (!/^0x[0-9a-fA-F]{64}$/.test(txHash)) {
+      return res.status(400).json({
+        success: false,
+        error: '无效的交易哈希'
+      });
+    }
+
+    // 检查缓存
+    const cacheKey = `tx_${txHash}`;
+    const cachedTx = cache.get(cacheKey);
+    if (cachedTx) {
+      return res.json({
+        success: true,
+        data: cachedTx
+      });
+    }
+
+    // 从数据库获取交易信息
+    const block = await Block.findOne({ 'transactions.hash': txHash });
+    const txInfo = block ? block.transactions.find(tx => tx.hash === txHash) : null;
+    
+    if (!txInfo) {
+      return res.status(404).json({
+        success: false,
+        error: '交易未找到'
+      });
+    }
+
+    // 设置缓存
+    cache.set(cacheKey, txInfo)
     res.json({
       success: true,
       data: txInfo
@@ -37,16 +114,80 @@ router.get('/transaction/:txHash', async (req, res) => {
   }
 });
 
-// 获取地址的交易历史
+/**
+ * @api {get} /address/:address/transactions 获取地址的交易历史
+ * @apiName GetAddressTransactions
+ * @apiGroup Blockchain
+ * @apiParam {String} address 以太坊地址
+ * @apiParam {Number} [page=1] 页码
+ * @apiParam {Number} [limit=10] 每页记录数
+ * @apiSuccess {Boolean} success 请求是否成功
+ * @apiSuccess {Object} data 交易列表和分页信息
+ */
 router.get('/address/:address/transactions', async (req, res) => {
   try {
     const address = req.params.address;
     const page = parseInt(req.query.page) || 1;
     const limit = parseInt(req.query.limit) || 10;
 
-    // TODO: 从数据库获取地址的交易历史
-    const transactions = []; // 替换为实际的数据库查询
-    const total = 0; // 替换为实际的总记录数
+    // 参数验证
+    if (!/^0x[0-9a-fA-F]{40}$/.test(address)) {
+      return res.status(400).json({
+        success: false,
+        error: '无效的以太坊地址'
+      });
+    }
+
+    if (page < 1 || limit < 1 || limit > 100) {
+      return res.status(400).json({
+        success: false,
+        error: '无效的分页参数'
+      });
+    }
+
+    // 检查缓存
+    const cacheKey = `addr_tx_${address}_${page}_${limit}`;
+    const cachedResult = cache.get(cacheKey);
+    if (cachedResult) {
+      return res.json({
+        success: true,
+        data: cachedResult
+      });
+    }
+
+    // 从数据库获取地址的交易历史
+    const query = {
+      $or: [
+        { 'transactions.from': address },
+        { 'transactions.to': address }
+      ]
+    };
+    
+    const blocks = await Block.find(query)
+      .sort({ timestamp: -1 })
+      .skip((page - 1) * limit)
+      .limit(limit);
+
+    const transactions = blocks.reduce((txs, block) => {
+      const addressTxs = block.transactions.filter(tx => 
+        tx.from === address || tx.to === address
+      );
+      return [...txs, ...addressTxs];
+    }, []);
+
+    const total = await Block.countDocuments(query);
+
+    const result = {
+      transactions,
+      pagination: {
+        page,
+        limit,
+        total
+      }
+    };
+
+    // 设置缓存
+    cache.set(cacheKey, result)
 
     res.json({
       success: true,

basic/83-blockchain-indexer/src/api/stats.js

@@ -0,0 +1,67 @@
+const express = require('express');
+const router = express.Router();
+const { Block } = require('../utils/db');
+const NodeCache = require('node-cache');
+
+const cache = new NodeCache({ stdTTL: 600 });
+
+/**
+ * @api {get} /stats 获取区块链统计信息
+ * @apiName GetBlockchainStats
+ * @apiGroup Blockchain
+ * @apiSuccess {Boolean} success 请求是否成功
+ * @apiSuccess {Object} data 统计数据
+ */
+router.get('/', async (req, res) => {
+  try {
+    // 检查缓存
+    const cacheKey = 'blockchain_stats';
+    const cachedStats = cache.get(cacheKey);
+    if (cachedStats) {
+      return res.json({
+        success: true,
+        data: cachedStats
+      });
+    }
+
+    // 获取最新区块
+    const latestBlock = await Block.findOne().sort({ number: -1 });
+    
+    // 获取24小时内的区块数
+    const oneDayAgo = Date.now() - 24 * 60 * 60 * 1000;
+    const blocksLast24h = await Block.countDocuments({
+      timestamp: { $gte: oneDayAgo }
+    });
+
+    // 获取总交易数
+    const totalTxs = await Block.aggregate([
+      {
+        $group: {
+          _id: null,
+          count: { $sum: { $size: '$transactions' } }
+        }
+      }
+    ]);
+
+    const stats = {
+      latestBlockNumber: latestBlock ? latestBlock.number : 0,
+      blocksLast24h,
+      totalTransactions: totalTxs[0] ? totalTxs[0].count : 0
+    };
+
+    // 设置缓存
+    cache.set(cacheKey, stats);
+
+    res.json({
+      success: true,
+      data: stats
+    });
+  } catch (error) {
+    res.status(500).json({
+      success: false,
+      error: error.message
+    });
+  }
+});
+
+module.exports = router;