Merge pull request #185 from meshplus/perf/improve-pier-start

perf(internal/app): add error retry when getting cross-chain information to start the pier

Author: jzhe886

internal/app/utils.go

@@ -3,10 +3,14 @@ package app
 import (
 	"encoding/json"
 	"fmt"
+	"time"
 
+	"github.com/Rican7/retry"
+	"github.com/Rican7/retry/strategy"
 	"github.com/meshplus/bitxhub-model/constant"
 	"github.com/meshplus/bitxhub-model/pb"
 	rpcx "github.com/meshplus/go-bitxhub-client"
+	"github.com/meshplus/pier/internal/loggers"
 )
 
 func getInterchainMeta(client rpcx.Client) (*pb.Interchain, error) {
@@ -15,17 +19,31 @@ func getInterchainMeta(client rpcx.Client) (*pb.Interchain, error) {
 		return nil, err
 	}
 	tx.Nonce = 1
-	receipt, err := client.SendView(tx)
-	if err != nil {
-		return nil, err
-	}
-	if !receipt.IsSuccess() {
-		return nil, fmt.Errorf("get interchain meta receipt: %s", receipt.Ret)
-	}
 
 	ret := &pb.Interchain{}
-	if err := ret.Unmarshal(receipt.Ret); err != nil {
-		return nil, fmt.Errorf("unmarshal interchain meta from bitxhub: %w", err)
+	logger := loggers.Logger(loggers.App)
+	if err = retry.Retry(func(attempt uint) error {
+		receipt, err := client.SendView(tx)
+		if err != nil {
+			logger.Errorf("Send view to get interchain meta error: %w ... retry later", err)
+			return err
+		} else {
+			if !receipt.IsSuccess() {
+				logger.Errorf("Get interchain meta receipt: %s ... retry later", string(receipt.Ret))
+				return fmt.Errorf("get interchain meta receipt: %s", receipt.Ret)
+			}
+
+			if err := ret.Unmarshal(receipt.Ret); err != nil {
+				logger.Errorf("Unmarshal interchain meta from bitxhub: %s ... retry later", string(receipt.Ret))
+				return fmt.Errorf("unmarshal interchain meta from bitxhub: %w", err)
+			}
+
+			return nil
+		}
+	}, strategy.Wait(time.Second*5),
+	); err != nil {
+		logger.Errorf("Get interchain meta retry error: %w", err)
+		return nil, fmt.Errorf("Get interchain meta retry error: %w", err)
 	}
 
 	return ret, nil