release: v8.1.0 (#252)

Author: ironman0x7b2

config/node.go

@@ -9,6 +9,7 @@ import (
 	"strings"
 	"time"
 
+	"github.com/asaskevich/govalidator"
 	"github.com/sentinel-official/sentinel-go-sdk/libs/netip"
 	"github.com/sentinel-official/sentinel-go-sdk/types"
 	"github.com/sentinel-official/sentinel-go-sdk/utils"
@@ -372,5 +373,10 @@ func validateRemoteAddr(addr string) error {
 		return errors.New("addr is neither IPv4 nor IPv6")
 	}
 
-	return nil
+	// Validate the DNS name format.
+	if govalidator.IsDNSName(addr) {
+		return nil
+	}
+
+	return fmt.Errorf("unsupported addr %q", addr)
 }

core/context.go

@@ -1,6 +1,7 @@
 package core
 
 import (
+	"context"
 	"errors"
 	"io"
 	"path/filepath"
@@ -250,6 +251,26 @@ func (c *Context) TLSKeyFile() string {
 	return filepath.Join(c.HomeDir(), "tls.key")
 }
 
+// SanitizedGigabytePrices returns gigabyte prices filtered to include only valid denominations.
+func (c *Context) SanitizedGigabytePrices(ctx context.Context) v1.Prices {
+	params, err := c.Client().NodeParams(ctx)
+	if err != nil {
+		panic(err)
+	}
+
+	return c.sanitizePrices(c.GigabytePrices(), params.GetMinGigabytePrices())
+}
+
+// SanitizedHourlyPrices returns hourly prices filtered to include only valid denominations.
+func (c *Context) SanitizedHourlyPrices(ctx context.Context) v1.Prices {
+	params, err := c.Client().NodeParams(ctx)
+	if err != nil {
+		panic(err)
+	}
+
+	return c.sanitizePrices(c.HourlyPrices(), params.GetMinHourlyPrices())
+}
+
 // SetLocation sets the geolocation data in the context.
 func (c *Context) SetLocation(location *geoip.Location) {
 	c.fm.Lock()
@@ -409,3 +430,15 @@ func (c *Context) checkSealed() {
 		panic(errors.New("context is sealed"))
 	}
 }
+
+// sanitizePrices filters and validates a set of prices against the minimum required prices.
+func (c *Context) sanitizePrices(prices v1.Prices, minPrices v1.Prices) (newPrices v1.Prices) {
+	m := minPrices.Map()
+	for _, price := range prices {
+		if _, ok := m[price.Denom]; ok {
+			newPrices = newPrices.Add(price)
+		}
+	}
+
+	return
+}

go.mod

@@ -4,6 +4,7 @@ go 1.24.6
 
 require (
 	cosmossdk.io/math v1.5.3
+	github.com/asaskevich/govalidator v0.0.0-20230301143203-a9d515a09cc2
 	github.com/cosmos/cosmos-sdk v0.47.17
 	github.com/gin-contrib/cors v1.7.6
 	github.com/gin-gonic/gin v1.11.0

go.sum

@@ -66,6 +66,8 @@ github.com/apernet/quic-go v0.48.2-0.20241104191913-cb103fcecfe7 h1:zO38yBOvQ1dL
 github.com/apernet/quic-go v0.48.2-0.20241104191913-cb103fcecfe7/go.mod h1:LoSUY2chVqNQCDyi4IZGqPpXLy1FuCkE37PKwtJvNGg=
 github.com/armon/go-metrics v0.4.1 h1:hR91U9KYmb6bLBYLQjyM+3j+rcd/UhE+G78SFnF8gJA=
 github.com/armon/go-metrics v0.4.1/go.mod h1:E6amYzXo6aW1tqzoZGT755KkbgrJsSdpwZ+3JqfkOG4=
+github.com/asaskevich/govalidator v0.0.0-20230301143203-a9d515a09cc2 h1:DklsrG3dyBCFEj5IhUbnKptjxatkF07cF2ak3yi77so=
+github.com/asaskevich/govalidator v0.0.0-20230301143203-a9d515a09cc2/go.mod h1:WaHUgvxTVq04UNunO+XhnAqY/wQc+bxr74GqbsZ/Jqw=
 github.com/avast/retry-go/v4 v4.7.0 h1:yjDs35SlGvKwRNSykujfjdMxMhMQQM0TnIjJaHB+Zio=
 github.com/avast/retry-go/v4 v4.7.0/go.mod h1:ZMPDa3sY2bKgpLtap9JRUgk2yTAba7cgiFhqxY2Sg6Q=
 github.com/aws/aws-sdk-go v1.44.203 h1:pcsP805b9acL3wUqa4JR2vg1k2wnItkDYNvfmcy6F+U=

node/node.go

@@ -80,17 +80,20 @@ func (n *Node) Register(ctx context.Context) error {
 		return nil
 	}
 
+	gigabytePrices := n.Context().SanitizedGigabytePrices(ctx)
+	hourlyPrices := n.Context().SanitizedHourlyPrices(ctx)
+
 	log.Info("Registering node",
-		"gigabyte_price", n.Context().GigabytePrices(),
-		"hourly_price", n.Context().HourlyPrices(),
+		"gigabyte_prices", gigabytePrices,
+		"hourly_price", hourlyPrices,
 		"remote_addrs", n.Context().APIAddrs(),
 	)
 
 	// Prepare a message to register the node.
 	msg := v3.NewMsgRegisterNodeRequest(
 		n.Context().AccAddr(),
-		n.Context().GigabytePrices(),
-		n.Context().HourlyPrices(),
+		gigabytePrices,
+		hourlyPrices,
 		n.Context().APIAddrs(),
 	)
 
@@ -106,17 +109,20 @@ func (n *Node) Register(ctx context.Context) error {
 
 // UpdateDetails updates the node's pricing and address details on the network.
 func (n *Node) UpdateDetails(ctx context.Context) error {
+	gigabytePrices := n.Context().SanitizedGigabytePrices(ctx)
+	hourlyPrices := n.Context().SanitizedHourlyPrices(ctx)
+
 	log.Info("Updating node details",
-		"gigabyte_prices", n.Context().GigabytePrices(),
-		"hourly_prices", n.Context().HourlyPrices(),
+		"gigabyte_prices", gigabytePrices,
+		"hourly_prices", hourlyPrices,
 		"remote_addrs", n.Context().APIAddrs(),
 	)
 
 	// Prepare a message to update the node's details.
 	msg := v3.NewMsgUpdateNodeDetailsRequest(
 		n.Context().NodeAddr(),
-		n.Context().GigabytePrices(),
-		n.Context().HourlyPrices(),
+		gigabytePrices,
+		hourlyPrices,
 		n.Context().APIAddrs(),
 	)
 

workers/node.go

@@ -54,7 +54,7 @@ func NewNodePricesUpdateWorker(c *core.Context, interval time.Duration) cron.Wor
 
 		var gigabytePrices v1.Prices
 
-		for _, price := range c.GigabytePrices() {
+		for _, price := range c.SanitizedGigabytePrices(ctx) {
 			price, err := price.UpdateQuoteValue(ctx, client.GetQuotePrice)
 			if err != nil {
 				return fmt.Errorf("updating quote price for denom %q: %w", price.Denom, err)
@@ -65,7 +65,7 @@ func NewNodePricesUpdateWorker(c *core.Context, interval time.Duration) cron.Wor
 
 		var hourlyPrices v1.Prices
 
-		for _, price := range c.HourlyPrices() {
+		for _, price := range c.SanitizedHourlyPrices(ctx) {
 			price, err := price.UpdateQuoteValue(ctx, client.GetQuotePrice)
 			if err != nil {
 				return fmt.Errorf("updating quote price for denom %q: %w", price.Denom, err)