Merge pull request #10 from bnb-chain/dev

node/validator.go

@@ -7,6 +7,7 @@ import (
 	"math/big"
 	"net"
 	"net/http"
+	"strings"
 	"sync/atomic"
 	"time"
 
@@ -26,7 +27,7 @@ var (
 	PayBidTxGasUsed = uint64(25000)
 
 	dialer = &net.Dialer{
-		Timeout:   time.Second,
+		Timeout:   5 * time.Second,
 		KeepAlive: 60 * time.Second,
 	}
 
@@ -117,7 +118,17 @@ type validator struct {
 }
 
 func (n *validator) SendBid(ctx context.Context, args types.BidArgs) (common.Hash, error) {
-	return n.client.SendBid(ctx, args)
+	hash, err := n.client.SendBid(ctx, args)
+	if err != nil {
+		metrics.ChainError.Inc()
+		log.Errorw("failed to send bid", "err", err)
+
+		if strings.Contains(err.Error(), "timeout") {
+			err = errors.New("timeout when send bid to validator")
+		}
+	}
+
+	return hash, err
 }
 
 func (n *validator) MevRunning() bool {

service/sentry.go

@@ -88,6 +88,10 @@ func (s *MevSentry) SendBid(ctx context.Context, args types.BidArgs) (bidHash co
 		log.Errorw("failed to parse bid signature", "err", err)
 		err = types.NewInvalidBidError(fmt.Sprintf("invalid signature:%v", err))
 		return
+	} else if _, ok = s.builders[builder]; !ok {
+		log.Errorw("builder not registered", "address", builder)
+		err = types.NewInvalidBidError("builder not registered")
+		return
 	}
 
 	payBidTx, err := validator.GeneratePayBidTx(ctx, builder, args.RawBid.BuilderFee)
@@ -208,7 +212,7 @@ func (s *MevSentry) ReportIssue(ctx context.Context, issue types.BidIssue) (err
 
 	builder, ok = s.builders[issue.Builder]
 	if !ok {
-		log.Errorw("builder not found", "address", issue.Builder)
+		log.Errorw("builder url not found", "address", issue.Builder, "issue", issue)
 		err = errors.New("builder not found")
 		return
 	}