support multiple substrate URLs

bridge/docs/observability.md

@@ -134,7 +134,7 @@ the source field set contains all fields which are included in the source object
 | Instance_public_key | string | yes | Instance public key which you can use to filter logs by instance |
 | Bridge_wallet_address | string | yes | The bridge account address which you can use to filter logs by bridge |
 | Stellar_network | string | yes | Stellar network name which you can use to filter logs by environment |
-| Tfchain_url | string | yes | The url of the substrate rpc node which you can use to filter logs by environment |
+| Tfchain_url | []string | yes | The urls of the substrate rpc node which you can use to filter logs by environment |
 
 #### Event-specific fields:
 

bridge/tfchain_bridge/main.go

@@ -18,7 +18,7 @@ func main() {
 	var bridgeCfg pkg.BridgeConfig
 
 	var debug bool
-	flag.StringVar(&bridgeCfg.TfchainURL, "tfchainurl", "", "Tfchain websocket url")
+	flag.StringArrayVar(&bridgeCfg.TfchainURL, "tfchainurl", []string{}, "Tfchain websocket url")
 	flag.StringVar(&bridgeCfg.TfchainSeed, "tfchainseed", "", "Tfchain secret seed")
 	flag.StringVar(&bridgeCfg.StellarBridgeAccount, "bridgewallet", "", "stellar bridge wallet")
 	flag.StringVar(&bridgeCfg.StellarSeed, "secret", "", "stellar secret")

bridge/tfchain_bridge/pkg/config.go

@@ -3,7 +3,7 @@ package pkg
 import "errors"
 
 type BridgeConfig struct {
-	TfchainURL          string
+	TfchainURL          []string
 	TfchainSeed         string
 	RescanBridgeAccount bool
 	PersistencyFile     string

bridge/tfchain_bridge/pkg/logger/logger.go

@@ -25,7 +25,7 @@ type SourceCommonLogEntry struct {
 	Instance_public_key   string
 	Bridge_wallet_address string
 	Stellar_network       string
-	Tfchain_url           string
+	Tfchain_url           []string
 }
 
 type refundReasonKey struct{}

bridge/tfchain_bridge/pkg/substrate/client.go

@@ -32,8 +32,8 @@ type SubstrateClient struct {
 }
 
 // NewSubstrate creates a substrate client
-func NewSubstrateClient(url string, seed string) (*SubstrateClient, error) {
-	mngr := substrate.NewManager(url)
+func NewSubstrateClient(url []string, seed string) (*SubstrateClient, error) {
+	mngr := substrate.NewManager(url...)
 	cl, err := mngr.Substrate()
 	if err != nil {
 		return nil, err