config option for enabling p2p relay; defaults to true

host/config.go

@@ -17,6 +17,7 @@ var defaultConfig = Config{
 	Websocket:                          false,
 	BootNodesReachabilityCheckInterval: 1 * time.Minute,
 	MustReachBootNodes:                 defaultMustReachBootNodes,
+	EnableP2PRelay:                     true,
 }
 
 // Config represents the Host configuration.
@@ -39,6 +40,7 @@ type Config struct {
 	BootNodesReachabilityCheckInterval time.Duration
 	MustReachBootNodes                 bool
 	DisableResourceLimits              bool
+	EnableP2PRelay                     bool
 }
 
 // WithPrivateKey specifies the private key for the Host.
@@ -136,3 +138,10 @@ func WithDisabledResourceLimits(b bool) func(cfg *Config) {
 		cfg.DisableResourceLimits = b
 	}
 }
+
+// EnableP2PRelay allows user to control whether the b7s can act as a p2p relayer for worker nodes
+func WithEnableP2PRelay(b bool) func(cfg *Config) {
+	return func(cfg *Config) {
+		cfg.EnableP2PRelay = b
+	}
+}

host/host.go

@@ -127,9 +127,12 @@ func New(log zerolog.Logger, address string, port uint, options ...func(*Config)
 		return nil, fmt.Errorf("could not create libp2p host: %w", err)
 	}
 
-	_, err = relayv2.New(h)
-	if err != nil {
-		return nil, fmt.Errorf("could not create relay: %w", err)
+	if cfg.EnableP2PRelay {
+		log.Info().Msg("enabling p2p relay...")
+		_, err = relayv2.New(h)
+		if err != nil {
+			return nil, fmt.Errorf("could not create relay: %w", err)
+		}
 	}
 
 	host := Host{