feat: enhance blockchain indexer API functionality

Author: lilycom02

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

@@ -1,12 +1,20 @@
 const express = require('express');
 const router = express.Router();
+const Block = require('../models/Block');
 
 // 获取区块信息
 router.get('/block/:blockNumber', async (req, res) => {
   try {
-    const blockNumber = req.params.blockNumber;
-    // TODO: 从数据库获取区块信息
-    const blockInfo = {}; // 替换为实际的数据库查询
+    const blockNumber = parseInt(req.params.blockNumber);
+    const blockInfo = await Block.findOne({ number: blockNumber });
+    
+    if (!blockInfo) {
+      return res.status(404).json({
+        success: false,
+        error: '区块未找到'
+      });
+    }
+
     res.json({
       success: true,
       data: blockInfo
@@ -23,8 +31,16 @@ router.get('/block/:blockNumber', async (req, res) => {
 router.get('/transaction/:txHash', async (req, res) => {
   try {
     const txHash = req.params.txHash;
-    // TODO: 从数据库获取交易信息
-    const txInfo = {}; // 替换为实际的数据库查询
+    const block = await Block.findOne({ 'transactions.hash': txHash });
+    
+    if (!block) {
+      return res.status(404).json({
+        success: false,
+        error: '交易未找到'
+      });
+    }
+
+    const txInfo = block.transactions.find(tx => tx.hash === txHash);
     res.json({
       success: true,
       data: txInfo
@@ -40,13 +56,34 @@ router.get('/transaction/:txHash', async (req, res) => {
 // 获取地址的交易历史
 router.get('/address/:address/transactions', async (req, res) => {
   try {
-    const address = req.params.address;
+    const address = req.params.address.toLowerCase();
     const page = parseInt(req.query.page) || 1;
     const limit = parseInt(req.query.limit) || 10;
+    const skip = (page - 1) * limit;
 
-    // TODO: 从数据库获取地址的交易历史
-    const transactions = []; // 替换为实际的数据库查询
-    const total = 0; // 替换为实际的总记录数
+    const query = {
+      $or: [
+        { 'transactions.from': address },
+        { 'transactions.to': address }
+      ]
+    };
+    
+    const [blocks, total] = await Promise.all([
+      Block.find(query)
+        .sort({ number: -1 })
+        .skip(skip)
+        .limit(limit),
+      Block.countDocuments(query)
+    ]);
+
+    const transactions = blocks.reduce((acc, block) => {
+      return acc.concat(
+        block.transactions.filter(tx =>
+          tx.from.toLowerCase() === address ||
+          (tx.to && tx.to.toLowerCase() === address)
+        )
+      );
+    }, []);
 
     res.json({
       success: true,
@@ -71,8 +108,10 @@ router.get('/address/:address/transactions', async (req, res) => {
 router.get('/blocks/latest', async (req, res) => {
   try {
     const limit = parseInt(req.query.limit) || 10;
-    // TODO: 从数据库获取最新的区块列表
-    const blocks = []; // 替换为实际的数据库查询
+    const blocks = await Block.find()
+      .sort({ number: -1 })
+      .limit(limit)
+      .select('-transactions');
 
     res.json({
       success: true,
@@ -90,8 +129,14 @@ router.get('/blocks/latest', async (req, res) => {
 router.get('/transactions/latest', async (req, res) => {
   try {
     const limit = parseInt(req.query.limit) || 10;
-    // TODO: 从数据库获取最新的交易列表
-    const transactions = []; // 替换为实际的数据库查询
+    const blocks = await Block.find()
+      .sort({ number: -1 })
+      .limit(Math.ceil(limit / 2))
+      .select('transactions');
+    
+    const transactions = blocks.reduce((acc, block) => {
+      return acc.concat(block.transactions);
+    }, []).slice(0, limit);
 
     res.json({
       success: true,
@@ -109,11 +154,52 @@ router.get('/transactions/latest', async (req, res) => {
 router.get('/search/:query', async (req, res) => {
   try {
     const query = req.params.query;
-    // TODO: 实现搜索逻辑
-    const result = {
-      type: '', // 'block', 'transaction', 'address'
+    let result = {
+      type: '',
       data: null
     };
+
+    // 尝试作为区块号搜索
+    if (/^\d+$/.test(query)) {
+      const block = await Block.findOne({ number: parseInt(query) });
+      if (block) {
+        result = { type: 'block', data: block };
+      }
+    }
+    
+    // 尝试作为交易哈希搜索
+    if (!result.data && /^0x[a-fA-F0-9]{64}$/.test(query)) {
+      const block = await Block.findOne({ 'transactions.hash': query });
+      if (block) {
+        const transaction = block.transactions.find(tx => tx.hash === query);
+        if (transaction) {
+          result = { type: 'transaction', data: transaction };
+        }
+      }
+    }
+    
+    // 尝试作为地址搜索
+    if (!result.data && /^0x[a-fA-F0-9]{40}$/.test(query)) {
+      const address = query.toLowerCase();
+      const blocks = await Block.find({
+        $or: [
+          { 'transactions.from': address },
+          { 'transactions.to': address }
+        ]
+      }).limit(10);
+      
+      if (blocks.length > 0) {
+        const transactions = blocks.reduce((acc, block) => {
+          return acc.concat(
+            block.transactions.filter(tx =>
+              tx.from.toLowerCase() === address ||
+              (tx.to && tx.to.toLowerCase() === address)
+            )
+          );
+        }, []);
+        result = { type: 'address', data: transactions };
+      }
+    }
 
     res.json({
       success: true,
@@ -127,4 +213,5 @@ router.get('/search/:query', async (req, res) => {
   }
 });
 
+
 module.exports = router;