fix: use set rpc addr method of client

Author: ironman0x7b2

api/info/handlers.go

@@ -21,9 +21,8 @@ func handlerGetInfo(c *core.Context) gin.HandlerFunc {
 		// Construct the result structure with node information.
 		res := &node.GetInfoResult{
 			Addr:         c.NodeAddr().String(),
-			EgressRate:   ulSpeed.String(),
+			Downlink:     ulSpeed.String(),
 			HandshakeDNS: false,
-			IngressRate:  dlSpeed.String(),
 			Location: &geoip.Location{
 				City:        loc.City,
 				Country:     loc.Country,
@@ -34,6 +33,7 @@ func handlerGetInfo(c *core.Context) gin.HandlerFunc {
 			Moniker:     c.Moniker(),
 			Peers:       c.Service().PeersLen(),
 			ServiceType: c.Service().Type().String(),
+			Uplink:      dlSpeed.String(),
 			Version:     version.Get(),
 		}
 

core/context.go

@@ -51,58 +51,95 @@ func NewContext() *Context {
 	}
 }
 
+// checkSealed verifies if the context is sealed to prevent modification.
+func (c *Context) checkSealed() {
+	if c.sealed {
+		panic(errors.New("context is sealed"))
+	}
+}
+
+// Seal marks the context as sealed, preventing further modifications.
+func (c *Context) Seal() *Context {
+	c.sealed = true
+	return c
+}
+
 // AccAddr returns the transaction sender address set in the context.
 func (c *Context) AccAddr() cosmossdk.AccAddress {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.accAddr.Bytes()
 }
 
 // APIAddrs returns the api addresses set in the context.
 func (c *Context) APIAddrs() []string {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.apiAddrs
 }
 
 // APIListenAddr returns the listen address of the node API.
 func (c *Context) APIListenAddr() string {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.apiListenAddr
 }
 
 // Client returns the client instance set in the context.
 func (c *Context) Client() *core.Client {
-	return c.client.WithRPCAddr(c.RPCAddr()) // TODO: is it needed?
+	c.fm.RLock()
+	defer c.fm.RUnlock()
+
+	c.client.SetRPCAddr(c.RPCAddr())
+	return c.client
 }
 
 // Database returns the database connection set in the context.
 func (c *Context) Database() *gorm.DB {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.database
 }
 
 // DatabaseFile returns the database path of the node.
 func (c *Context) DatabaseFile() string {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return filepath.Join(c.HomeDir(), "data.db")
 }
 
 // GeoIPClient returns the GeoIP client set in the context.
 func (c *Context) GeoIPClient() geoip.Client {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.geoIPClient
 }
 
 // GigabytePrices returns the gigabyte prices for nodes.
 func (c *Context) GigabytePrices() v1.Prices {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.gigabytePrices
 }
 
 // HomeDir returns the home directory set in the context.
 func (c *Context) HomeDir() string {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.homeDir
 }
 
 // HourlyPrices returns the hourly prices for nodes.
 func (c *Context) HourlyPrices() v1.Prices {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.hourlyPrices
 }
 
 // Input returns the keyring input set in the context.
 func (c *Context) Input() io.Reader {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.input
 }
 
@@ -115,27 +152,38 @@ func (c *Context) Location() *geoip.Location {
 
 // MaxPeers returns the maximum peers for the service.
 func (c *Context) MaxPeers() uint {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.maxPeers
 }
 
 // Moniker returns the name or identifier for the node.
 func (c *Context) Moniker() string {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.moniker
 }
 
 func (c *Context) NodeAddr() sentinelhub.NodeAddress {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.accAddr.Bytes()
 }
 
 // RemoteAddrs returns the remote addresses set in the context.
 func (c *Context) RemoteAddrs() []string {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.remoteAddrs
 }
 
 // RPCAddr returns the first RPC address from the list or an empty string if no addresses are available.
 func (c *Context) RPCAddr() string {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
+
 	addrs := c.RPCAddrs()
-	if len(addrs) == 0 { // TODO: is it needed?
+	if len(addrs) == 0 { // TODO: remove this?
 		return ""
 	}
 
@@ -149,24 +197,31 @@ func (c *Context) RPCAddrs() []string {
 	return c.rpcAddrs
 }
 
-// Seal marks the context as sealed, preventing further modifications.
-func (c *Context) Seal() *Context {
-	c.sealed = true
-	return c
-}
-
 // Service returns the server service instance set in the context.
 func (c *Context) Service() sentinelsdk.ServerService {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return c.service
 }
 
+// SpeedtestResults returns the download and upload speeds set in the context.
+func (c *Context) SpeedtestResults() (dlSpeed, ulSpeed math.Int) {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
+	return c.dlSpeed, c.ulSpeed
+}
+
 // TLSCertFile returns the TLS certificate path of the node API server.
 func (c *Context) TLSCertFile() string {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return filepath.Join(c.HomeDir(), "tls.crt")
 }
 
 // TLSKeyFile returns the TLS key path of the node API server.
 func (c *Context) TLSKeyFile() string {
+	c.fm.RLock()
+	defer c.fm.RUnlock()
 	return filepath.Join(c.HomeDir(), "tls.key")
 }
 
@@ -192,13 +247,6 @@ func (c *Context) SetSpeedtestResults(dlSpeed, ulSpeed math.Int) {
 	c.ulSpeed = ulSpeed
 }
 
-// SpeedtestResults returns the download and upload speeds set in the context.
-func (c *Context) SpeedtestResults() (dlSpeed, ulSpeed math.Int) {
-	c.fm.RLock()
-	defer c.fm.RUnlock()
-	return c.dlSpeed, c.ulSpeed
-}
-
 // WithAccAddr sets the transaction sender address in the context and returns the updated context.
 func (c *Context) WithAccAddr(addr cosmossdk.AccAddress) *Context {
 	c.checkSealed()
@@ -303,10 +351,3 @@ func (c *Context) WithService(service sentinelsdk.ServerService) *Context {
 	c.service = service
 	return c
 }
-
-// checkSealed verifies if the context is sealed to prevent modification.
-func (c *Context) checkSealed() {
-	if c.sealed {
-		panic(errors.New("context is sealed"))
-	}
-}

core/setup.go

@@ -52,6 +52,9 @@ func (c *Context) SetupClient(cfg *config.Config) error {
 		return fmt.Errorf("setting up keyring: %w", err)
 	}
 
+	// Seal the client.
+	cc.Seal()
+
 	// Assign the initialized client to the context.
 	c.WithClient(cc)
 	return nil

go.mod

@@ -7,7 +7,7 @@ require (
 	github.com/cosmos/cosmos-sdk v0.47.17
 	github.com/gin-contrib/cors v1.7.6
 	github.com/gin-gonic/gin v1.10.1
-	github.com/sentinel-official/sentinel-go-sdk v1.0.0-rc.6.0.20250818145401-1e9f376abb11
+	github.com/sentinel-official/sentinel-go-sdk v1.0.0-rc.6.0.20250819043521-99e9556b0d55
 	github.com/sentinel-official/sentinelhub/v12 v12.0.0-rc.11
 	github.com/spf13/cobra v1.9.1
 	github.com/spf13/pflag v1.0.7

go.sum

@@ -511,8 +511,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-rc.6.0.20250818145401-1e9f376abb11 h1:GB2rSEZYvaQ0UAA33MSMAj+MHec9ZSLzVyGX2WHRCNE=
-github.com/sentinel-official/sentinel-go-sdk v1.0.0-rc.6.0.20250818145401-1e9f376abb11/go.mod h1:7QQH3IAo5YcbrqUNBZYClLi4d+lH9Ed36tDIbwewHHc=
+github.com/sentinel-official/sentinel-go-sdk v1.0.0-rc.6.0.20250819043521-99e9556b0d55 h1:HswbpqyxKFtcOEssy25KFQr7YyPAjfKP1rZJdA59N/0=
+github.com/sentinel-official/sentinel-go-sdk v1.0.0-rc.6.0.20250819043521-99e9556b0d55/go.mod h1:7QQH3IAo5YcbrqUNBZYClLi4d+lH9Ed36tDIbwewHHc=
 github.com/sentinel-official/sentinelhub/v12 v12.0.0-rc.11 h1:B3ylnKZSLP9aDYnS2f98Gx/QTohPuD36tjl75kYJSMs=
 github.com/sentinel-official/sentinelhub/v12 v12.0.0-rc.11/go.mod h1:LXcOAEffAn4Pw58xhoYN9j8ZVuM02OCgPNTI6lkGG2E=
 github.com/shirou/gopsutil/v4 v4.25.7 h1:bNb2JuqKuAu3tRlPv5piSmBZyMfecwQ+t/ILq+1JqVM=