Adding trusted visors from config on startup

pkg/transport/manager.go

@@ -19,6 +19,11 @@ import (
 	"github.com/SkycoinProject/skywire-mainnet/pkg/snet/snettest"
 )
 
+const (
+	// TrustedVisorsDelay defines a delay before adding transports to trusted visors.
+	TrustedVisorsDelay = 5 * time.Second
+)
+
 // ManagerConfig configures a Manager.
 type ManagerConfig struct {
 	PubKey          cipher.PubKey
@@ -282,8 +287,6 @@ func isSTCPTableError(remotePK cipher.PubKey, err error) bool {
 	return err.Error() == fmt.Sprintf("pk table: entry of %s does not exist", remotePK.String())
 }
 
-var ()
-
 func (tm *Manager) saveTransport(remote cipher.PubKey, netName string) (*ManagedTransport, error) {
 	if !snet.IsKnownNetwork(netName) {
 		return nil, snet.ErrUnknownNetwork

pkg/visor/init.go

@@ -26,6 +26,7 @@ import (
 	"github.com/SkycoinProject/skywire-mainnet/pkg/skyenv"
 	"github.com/SkycoinProject/skywire-mainnet/pkg/snet"
 	"github.com/SkycoinProject/skywire-mainnet/pkg/snet/arclient"
+	"github.com/SkycoinProject/skywire-mainnet/pkg/snet/directtp/tptypes"
 	"github.com/SkycoinProject/skywire-mainnet/pkg/transport"
 	"github.com/SkycoinProject/skywire-mainnet/pkg/transport/tpdclient"
 	"github.com/SkycoinProject/skywire-mainnet/pkg/util/updater"
@@ -47,6 +48,7 @@ func initStack() []initFunc {
 		initCLI,
 		initHypervisors,
 		initUptimeTracker,
+		initTrustedVisors,
 	}
 }
 
@@ -454,6 +456,32 @@ func initUptimeTracker(v *Visor) bool {
 	return true
 }
 
+func initTrustedVisors(v *Visor) bool {
+	const trustedVisorsTransportType = tptypes.STCPR
+
+	go func() {
+		time.Sleep(transport.TrustedVisorsDelay)
+		for _, pk := range v.tpM.Conf.DefaultVisors {
+			v.log.WithField("pk", pk).Infof("Adding trusted visor")
+
+			if _, err := v.tpM.SaveTransport(context.Background(), pk, trustedVisorsTransportType); err != nil {
+				v.log.
+					WithError(err).
+					WithField("pk", pk).
+					WithField("type", trustedVisorsTransportType).
+					Warnf("Failed to add transport to trusted visor via")
+			} else {
+				v.log.
+					WithField("pk", pk).
+					WithField("type", trustedVisorsTransportType).
+					Infof("Added transport to trusted visor")
+			}
+		}
+	}()
+
+	return true
+}
+
 func connectToTpDisc(v *Visor) (transport.DiscoveryClient, error) {
 	const (
 		initBO = 1 * time.Second

pkg/visor/visor.go

@@ -40,9 +40,6 @@ const (
 	supportedProtocolVersion = "0.1.0"
 	ownerRWX                 = 0700
 	shortHashLen             = 6
-)
-
-const (
 	// moduleShutdownTimeout is the timeout given to a module to shutdown cleanly.
 	// Otherwise the shutdown logic will continue and report a timeout error.
 	moduleShutdownTimeout = time.Second * 2