release: v8.2.0 (#253)

Author: ironman0x7b2

core/context.go

@@ -3,6 +3,7 @@ package core
 import (
 	"context"
 	"errors"
+	"fmt"
 	"io"
 	"path/filepath"
 	"sync"
@@ -252,23 +253,33 @@ func (c *Context) TLSKeyFile() string {
 }
 
 // SanitizedGigabytePrices returns gigabyte prices filtered to include only valid denominations.
-func (c *Context) SanitizedGigabytePrices(ctx context.Context) v1.Prices {
+func (c *Context) SanitizedGigabytePrices(ctx context.Context) (v1.Prices, error) {
 	params, err := c.Client().NodeParams(ctx)
 	if err != nil {
-		panic(err)
+		return nil, fmt.Errorf("getting node params: %w", err)
 	}
 
-	return c.sanitizePrices(c.GigabytePrices(), params.GetMinGigabytePrices())
+	prices := c.sanitizePrices(
+		c.GigabytePrices(),
+		params.GetMinGigabytePrices(),
+	)
+
+	return prices, nil
 }
 
 // SanitizedHourlyPrices returns hourly prices filtered to include only valid denominations.
-func (c *Context) SanitizedHourlyPrices(ctx context.Context) v1.Prices {
+func (c *Context) SanitizedHourlyPrices(ctx context.Context) (v1.Prices, error) {
 	params, err := c.Client().NodeParams(ctx)
 	if err != nil {
-		panic(err)
+		return nil, fmt.Errorf("getting node params: %w", err)
 	}
 
-	return c.sanitizePrices(c.HourlyPrices(), params.GetMinHourlyPrices())
+	prices := c.sanitizePrices(
+		c.HourlyPrices(),
+		params.GetMinHourlyPrices(),
+	)
+
+	return prices, nil
 }
 
 // SetLocation sets the geolocation data in the context.

go.mod

@@ -8,7 +8,7 @@ require (
 	github.com/cosmos/cosmos-sdk v0.47.17
 	github.com/gin-contrib/cors v1.7.6
 	github.com/gin-gonic/gin v1.11.0
-	github.com/sentinel-official/sentinel-go-sdk v1.0.0
+	github.com/sentinel-official/sentinel-go-sdk v1.0.1-0.20251028202929-21beb4dcafa5
 	github.com/sentinel-official/sentinelhub/v12 v12.0.0
 	github.com/spf13/cobra v1.10.1
 	github.com/spf13/pflag v1.0.10

go.sum

@@ -576,8 +576,8 @@ github.com/secure-io/siv-go v0.0.0-20180922214919-5ff40651e2c4 h1:zOjq+1/uLzn/Xo
 github.com/secure-io/siv-go v0.0.0-20180922214919-5ff40651e2c4/go.mod h1:aI+8yClBW+1uovkHw6HM01YXnYB8vohtB9C83wzx34E=
 github.com/seiflotfy/cuckoofilter v0.0.0-20220411075957-e3b120b3f5fb h1:XfLJSPIOUX+osiMraVgIrMR27uMXnRJWGm1+GL8/63U=
 github.com/seiflotfy/cuckoofilter v0.0.0-20220411075957-e3b120b3f5fb/go.mod h1:bR6DqgcAl1zTcOX8/pE2Qkj9XO00eCNqmKb7lXP8EAg=
-github.com/sentinel-official/sentinel-go-sdk v1.0.0 h1:7g/VibZlTWLZssRPJ9+9BWHuRBWvgBpBitP2nJ9lBQM=
-github.com/sentinel-official/sentinel-go-sdk v1.0.0/go.mod h1:N6mOoaBbrhiphJE8hk42lJZn0J1qZA+uVeOW6/tJfeY=
+github.com/sentinel-official/sentinel-go-sdk v1.0.1-0.20251028202929-21beb4dcafa5 h1:IYO60H1U9jQfpUYHieXmAL647FIPfgdrrS24wSy6b1M=
+github.com/sentinel-official/sentinel-go-sdk v1.0.1-0.20251028202929-21beb4dcafa5/go.mod h1:N6mOoaBbrhiphJE8hk42lJZn0J1qZA+uVeOW6/tJfeY=
 github.com/sentinel-official/sentinelhub/v12 v12.0.0 h1:Iw/6DnJllgSHR4beWdY95VpVNy0ZGESa3TcNrGAtBS8=
 github.com/sentinel-official/sentinelhub/v12 v12.0.0/go.mod h1:IuD4dlUOKvJVMTcNcbtQ+AlhTFkiRNXg2DuNlXGjYC8=
 github.com/shirou/gopsutil/v4 v4.25.9 h1:JImNpf6gCVhKgZhtaAHJ0serfFGtlfIlSC08eaKdTrU=

node/node.go

@@ -80,8 +80,15 @@ func (n *Node) Register(ctx context.Context) error {
 		return nil
 	}
 
-	gigabytePrices := n.Context().SanitizedGigabytePrices(ctx)
-	hourlyPrices := n.Context().SanitizedHourlyPrices(ctx)
+	gigabytePrices, err := n.Context().SanitizedGigabytePrices(ctx)
+	if err != nil {
+		return fmt.Errorf("sanitizing gigabyte prices: %w", err)
+	}
+
+	hourlyPrices, err := n.Context().SanitizedHourlyPrices(ctx)
+	if err != nil {
+		return fmt.Errorf("sanitizing hourly prices: %w", err)
+	}
 
 	log.Info("Registering node",
 		"gigabyte_prices", gigabytePrices,
@@ -109,8 +116,15 @@ 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)
+	gigabytePrices, err := n.Context().SanitizedGigabytePrices(ctx)
+	if err != nil {
+		return fmt.Errorf("sanitizing gigabyte prices: %w", err)
+	}
+
+	hourlyPrices, err := n.Context().SanitizedHourlyPrices(ctx)
+	if err != nil {
+		return fmt.Errorf("sanitizing hourly prices: %w", err)
+	}
 
 	log.Info("Updating node details",
 		"gigabyte_prices", gigabytePrices,

workers/node.go

@@ -46,15 +46,24 @@ func NewNodeStatusUpdateWorker(c *core.Context, interval time.Duration) cron.Wor
 // NewNodePricesUpdateWorker creates a worker that periodically updates the node's prices on the blockchain.
 // The worker computes the current quote prices using the OracleClient and broadcasts a MsgUpdateNodeDetailsRequest.
 func NewNodePricesUpdateWorker(c *core.Context, interval time.Duration) cron.Worker {
-	handlerFunc := func(ctx context.Context) error {
+	handlerFunc := func(ctx context.Context) (err error) {
 		client := c.OracleClient()
 		if client == nil {
 			return nil
 		}
 
-		var gigabytePrices v1.Prices
+		var (
+			prices         v1.Prices
+			gigabytePrices v1.Prices
+			hourlyPrices   v1.Prices
+		)
 
-		for _, price := range c.SanitizedGigabytePrices(ctx) {
+		prices, err = c.SanitizedGigabytePrices(ctx)
+		if err != nil {
+			return fmt.Errorf("sanitizing gigabyte prices: %w", err)
+		}
+
+		for _, price := range prices {
 			price, err := price.UpdateQuoteValue(ctx, client.GetQuotePrice)
 			if err != nil {
 				return fmt.Errorf("updating quote price for denom %q: %w", price.Denom, err)
@@ -63,9 +72,12 @@ func NewNodePricesUpdateWorker(c *core.Context, interval time.Duration) cron.Wor
 			gigabytePrices = gigabytePrices.Add(price)
 		}
 
-		var hourlyPrices v1.Prices
+		prices, err = c.SanitizedHourlyPrices(ctx)
+		if err != nil {
+			return fmt.Errorf("sanitizing hourly prices: %w", err)
+		}
 
-		for _, price := range c.SanitizedHourlyPrices(ctx) {
+		for _, price := range prices {
 			price, err := price.UpdateQuoteValue(ctx, client.GetQuotePrice)
 			if err != nil {
 				return fmt.Errorf("updating quote price for denom %q: %w", price.Denom, err)

workers/session.go

@@ -48,7 +48,7 @@ func NewSessionUsageSyncWithBlockchainWorker(c *core.Context, interval time.Dura
 		)
 
 		jobGroup, jobCtx := errgroup.WithContext(ctx)
-		jobGroup.SetLimit(8)
+		jobGroup.SetLimit(2)
 
 		// Iterate over sessions and prepare messages for updates.
 		for _, val := range items {
@@ -133,7 +133,7 @@ func NewSessionUsageSyncWithDatabaseWorker(c *core.Context, interval time.Durati
 		}
 
 		jobGroup, jobCtx := errgroup.WithContext(ctx)
-		jobGroup.SetLimit(8)
+		jobGroup.SetLimit(2)
 
 		// Update the database with the fetched statistics.
 		for key, val := range items {
@@ -214,7 +214,7 @@ func NewSessionUsageValidateWorker(c *core.Context, interval time.Duration) cron
 		}
 
 		jobGroup, jobCtx := errgroup.WithContext(ctx)
-		jobGroup.SetLimit(8)
+		jobGroup.SetLimit(2)
 
 		// Validate session limits and remove peers if needed.
 		for _, val := range items {
@@ -295,7 +295,7 @@ func NewSessionValidateWorker(c *core.Context, interval time.Duration) cron.Work
 		}
 
 		jobGroup, jobCtx := errgroup.WithContext(ctx)
-		jobGroup.SetLimit(8)
+		jobGroup.SetLimit(2)
 
 		// Validate session status and consistency.
 		for _, val := range items {