多链桥接 API 服务

1// BridgeRouter 跨链路由选择器
2type BridgeRouter struct {
3    adapters map[string]BridgeAdapter
4    cache    *redis.Client
5}
6 
7// RouteQuote 跨链报价
8type RouteQuote struct {
9    Bridge       string
10    SourceChain  string
11    DestChain    string
12    TokenIn      common.Address
13    TokenOut     common.Address
14    AmountIn     *big.Int
15    AmountOut    *big.Int
16    Fee          *big.Int
17    EstimatedTime time.Duration
18    Route        []string
19}
20 
21// FindBestRoute 查找最优跨链路由
22func (r *BridgeRouter) FindBestRoute(
23    ctx context.Context,
24    req *RouteRequest,
25) ([]*RouteQuote, error) {
26    // 1. 获取所有支持此路径的桥接协议
27    supportedBridges := r.getSupportedBridges(
28        req.SourceChain,
29        req.DestChain,
30        req.Token,
31    )
32    
33    // 2. 并发获取各桥报价
34    quotes := make([]*RouteQuote, 0)
35    var wg sync.WaitGroup
36    var mu sync.Mutex
37    
38    for _, bridge := range supportedBridges {
39        wg.Add(1)
40        go func(adapter BridgeAdapter) {
41            defer wg.Done()
42            
43            quote, err := adapter.GetQuote(ctx, req)
44            if err != nil {
45                log.Warn("Bridge quote failed", 
46                    "bridge", adapter.Name(), "err", err)
47                return
48            }
49            
50            mu.Lock()
51            quotes = append(quotes, quote)
52            mu.Unlock()
53        }(r.adapters[bridge])
54    }
55    wg.Wait()
56    
57    // 3. 按净收益排序 (到账金额 - 费用)
58    sort.Slice(quotes, func(i, j int) bool {
59        netI := new(big.Int).Sub(quotes[i].AmountOut, quotes[i].Fee)
60        netJ := new(big.Int).Sub(quotes[j].AmountOut, quotes[j].Fee)
61        return netI.Cmp(netJ) > 0
62    })
63    
64    return quotes, nil
65}

1// BridgeTransaction 跨链交易状态
2type BridgeTransaction struct {
3    ID            string
4    SourceChain   string
5    DestChain     string
6    SourceTxHash  common.Hash
7    DestTxHash    common.Hash
8    Status        TxStatus
9    CreatedAt     time.Time
10    UpdatedAt     time.Time
11}
12 
13type TxStatus string
14 
15const (
16    StatusPending     TxStatus = "pending"
17    StatusSourceConf  TxStatus = "source_confirmed"
18    StatusBridging    TxStatus = "bridging"
19    StatusDestConf    TxStatus = "dest_confirmed"
20    StatusCompleted   TxStatus = "completed"
21    StatusFailed      TxStatus = "failed"
22)
23 
24// TrackTransaction 追踪跨链交易状态
25func (t *TransactionTracker) TrackTransaction(
26    ctx context.Context,
27    txID string,
28) error {
29    tx, err := t.db.GetTransaction(ctx, txID)
30    if err != nil {
31        return err
32    }
33    
34    for {
35        select {
36        case <-ctx.Done():
37            return ctx.Err()
38        case <-time.After(5 * time.Second):
39            newStatus, err := t.checkStatus(ctx, tx)
40            if err != nil {
41                continue
42            }
43            
44            if newStatus != tx.Status {
45                tx.Status = newStatus
46                tx.UpdatedAt = time.Now()
47                
48                // 更新数据库
49                t.db.UpdateTransaction(ctx, tx)
50                
51                // 推送状态更新
52                t.pubsub.Publish(ctx, 
53                    fmt.Sprintf("tx:%s", txID),
54                    newStatus,
55                )
56                
57                // 完成或失败时退出
58                if newStatus == StatusCompleted || 
59                   newStatus == StatusFailed {
60                    return nil
61                }
62            }
63        }
64    }
65}