feat: Add option to specify wallets list to get bridges list from

bridge_config.go

@@ -0,0 +1,68 @@
+package main
+
+import (
+	"api_monitoring_stats/services"
+	"api_monitoring_stats/services/connect"
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+)
+
+var defaultBridges = []metrics[services.BridgeMetrics]{
+	connect.NewBridge("tonapi", "https://bridge.tonapi.io/bridge"),
+	connect.NewBridge("MTW", "https://tonconnectbridge.mytonwallet.org/bridge"),
+	connect.NewBridge("tonhub", "https://connect.tonhubapi.com/tonconnect"),
+	connect.NewBridge("TonSpace", "https://bridge.ton.space/bridge"),
+	connect.NewBridge("DeWallet", "https://bridge.dewallet.pro/bridge"),
+}
+
+func GetBridgeConfig(configUrl string) ([]metrics[services.BridgeMetrics], error) {
+	if configUrl == "" {
+		return defaultBridges, nil
+	}
+
+	bridges := []metrics[services.BridgeMetrics]{}
+	req, err := http.NewRequest(http.MethodGet, configUrl, nil)
+	req.Header.Set("Content-Type", "application/json")
+	if err != nil {
+		return defaultBridges, fmt.Errorf("failed to create request: %v", err)
+	}
+
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		return defaultBridges, fmt.Errorf("failed to get wallets config: %v", err)
+	}
+	defer resp.Body.Close()
+
+	type WalletConfig struct {
+		AppName string `json:"app_name"`
+		Bridges []struct {
+			Type string `json:"type"`
+			URL  string `json:"url"`
+		} `json:"bridge"`
+	}
+	var config []WalletConfig
+	respBody, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return defaultBridges, fmt.Errorf("failed to read wallets config: %v", err)
+	}
+	err = json.NewDecoder(bytes.NewReader(respBody)).Decode(&config)
+	if err != nil {
+		return defaultBridges, fmt.Errorf("failed to decode wallets config: %v", err)
+	}
+
+	for _, wallet := range config {
+		for _, bridge := range wallet.Bridges {
+			if bridge.Type == "sse" {
+				bridges = append(bridges, connect.NewBridge(wallet.AppName, bridge.URL))
+			}
+		}
+	}
+
+	if len(bridges) == 0 {
+		return defaultBridges, fmt.Errorf("no bridges found")
+	}
+	return bridges, nil
+}

config/config.go

@@ -23,6 +23,7 @@ var Config = struct {
 	DtonLiteServers   []liteclient.LiteserverConfig `env:"DTON_LITE_SERVERS"`
 	DtonToken         string                        `env:"DTONTOKEN"`
 	ChainstackToken   string                        `env:"CHAINSTACK_TOKEN"`
+	WalletListUrl     string                        `env:"WALLET_LIST_URL"`
 }{}
 
 func LoadConfig() {

main.go

@@ -8,7 +8,6 @@ import (
 
 	"api_monitoring_stats/config"
 	"api_monitoring_stats/services"
-	"api_monitoring_stats/services/connect"
 	"api_monitoring_stats/services/dapps"
 	"api_monitoring_stats/services/dton"
 	public_config "api_monitoring_stats/services/public-config"
@@ -56,13 +55,12 @@ func main() {
 		dapps.StonFi,
 		dapps.Getgems,
 	}
-	bridges := []metrics[services.BridgeMetrics]{
-		connect.NewBridge("tonapi", "https://bridge.tonapi.io/bridge"),
-		connect.NewBridge("MTW", "https://tonconnectbridge.mytonwallet.org/bridge"),
-		connect.NewBridge("tonhub", "https://connect.tonhubapi.com/tonconnect"),
-		connect.NewBridge("TonSpace", "https://bridge.ton.space/bridge"),
-		connect.NewBridge("DeWallet", "https://bridge.dewallet.pro/bridge"),
+
+	bridges, bridgeConfigErr := GetBridgeConfig(config.Config.WalletListUrl)
+	if bridgeConfigErr != nil {
+		log.Printf("failed to get bridge config, using default bridges: %v", bridgeConfigErr)
 	}
+
 	go workerMetrics(apis, apiMetricsCollect)
 	go workerMetrics(dappsMetrics, dappsMetricsCollect)
 	go workerMetrics(bridges, bridgeMetricsCollect)