feat: add field trustedPeersPath to the config

Signed-off-by: Jose Ramon Mañes <jose@celestia.org>

config/config.go

@@ -9,7 +9,8 @@ type MutualPeersConfig struct {
 // MutualPeer represents a mutual peer structure.
 type MutualPeer struct {
 	// List of peers.
-	Peers []Peer `yaml:"peers"`
+	Peers            []Peer `yaml:"peers"`
+	TrustedPeersPath string `yaml:"trustedPeersPath"` // New field
 }
 
 // Peer represents a peer structure.

deployment/overlays/local/config/config.yaml

@@ -3,4 +3,5 @@ mutualPeers:
     - nodeName: "da-bridge-1-0"
       containerName: "da"
     - nodeName: "da-full-1-0"
-      containerName: "da"
+      containerName: "da"
+    trustedPeersPath: "/home/celestia/config"

deployment/overlays/robusta-torch-1/config/config.yaml

@@ -3,4 +3,5 @@ mutualPeers:
     - nodeName: "da-bridge-1-0"
       containerName: "da"
     - nodeName: "da-full-1-0"
-      containerName: "da"
+      containerName: "da"
+    trustedPeersPath: "/home/celestia/config"

pkg/k8s/commands.go

@@ -2,15 +2,25 @@ package k8s
 
 import (
 	"fmt"
+
+	"github.com/jrmanes/torch/config"
 )
 
 var (
-	trustedPeerFile = "/tmp/TP-ADDR"
-	//trustedPeers       = "/home/celestia/config/"
+	trustedPeerFile    = "/tmp/TP-ADDR"
 	trustedPeers       = "/tmp/"
 	trusteedPeerPrefix = "/dns/$(hostname)/tcp/2121/p2p/"
 )
 
+func GetTrustedPeersPath(cfg config.MutualPeer) string {
+	// if not defined in the config, return the default value
+	if cfg.TrustedPeersPath == "" {
+		return trustedPeers
+	}
+
+	return cfg.TrustedPeersPath
+}
+
 // GetTrustedPeerCommand generates the command for retrieving trusted peer information.
 func GetTrustedPeerCommand() []string {
 	script := fmt.Sprintf(`#!/bin/sh
@@ -54,7 +64,10 @@ fi`, trustedPeerFile, trusteedPeerPrefix)
 }
 
 // BulkTrustedPeerCommand generates the peers content in the files
-func BulkTrustedPeerCommand(tp string) []string {
+func BulkTrustedPeerCommand(tp string, cfg config.MutualPeer) []string {
+	// Get the path to write
+	trustedPeers = GetTrustedPeersPath(cfg)
+
 	script := fmt.Sprintf(`#!/bin/sh
 # create the folder if doesnt exists
 mkdir -p "%[3]s"

pkg/k8s/k8s.go

@@ -193,7 +193,8 @@ func BulkTrustedPeers(cfg config.MutualPeersConfig, pods config.MutualPeer) {
 		for _, pod := range pods.Peers {
 			if key != pod.NodeName {
 				log.Info("this is a different one: ", data[key], " ", pod.NodeName)
-				command := BulkTrustedPeerCommand(data[key])
+				// send the data + the config to generate the path
+				command := BulkTrustedPeerCommand(data[key], pods)
 				output, err := RunRemoteCommand(
 					pod.NodeName,
 					pod.ContainerName,