monitor changes in substrate url and update sub event listener accordingly

Author: Eslam-Nawara

cmds/modules/noded/main.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"crypto/ed25519"
 	"fmt"
+	"slices"
 	"time"
 
 	"github.com/cenkalti/backoff"
@@ -245,6 +246,29 @@ func action(cli *cli.Context) error {
 		}
 	}()
 
+	// monitor node env updates in substrate url
+	go func() {
+		for {
+			<-time.After(10 * time.Minute)
+			newEnv, err := environment.Get()
+			if err != nil {
+				log.Error().Err(err).Msg("failed to get updated config")
+				continue
+			}
+			if !slices.Equal(env.SubstrateURL, newEnv.SubstrateURL) {
+				sub, err = environment.GetSubstrate()
+				if err != nil {
+					log.Error().Err(err).Msg("failed to get updated substrate manager")
+				}
+
+				env = newEnv
+				events.UpdateSubstrateManager(sub)
+				log.Debug().Strs("substrate_urls", newEnv.SubstrateURL).Msg("updated substrate events handler to use new substrate urls")
+
+			}
+		}
+	}()
+
 	log.Info().Uint32("twin", twin).Msg("node has been registered")
 	idStub := stubs.NewIdentityManagerStub(redis)
 	fetchCtx, cancel := context.WithTimeout(ctx, 30*time.Second)