Merge pull request #518 from shutter-network/feature/access-node-pubsub-config

feat: added a flag for isAccessNode and updated pubsub config

Author: blockchainluffy

.gitignore

@@ -8,3 +8,4 @@ log
 node_modules
 result
 temp
+work

rolling-shutter/gnosisaccessnode/config.go

@@ -42,10 +42,15 @@ func (c *Config) Validate() error {
 }
 
 func (c *Config) SetDefaultValues() error {
+	c.P2P.IsAccessNode = true
 	return nil
 }
 
 func (c *Config) SetExampleValues() error { //nolint:unparam
+	err := c.SetDefaultValues()
+	if err != nil {
+		return err
+	}
 	c.InstanceID = 1000
 	c.MaxNumKeysPerMessage = 500
 	return nil

rolling-shutter/p2p/config.go

@@ -47,6 +47,7 @@ type Config struct {
 	CustomBootstrapAddresses []*address.P2PAddress `comment:"Overwrite p2p boostrap nodes"`
 	Environment              env.Environment
 	DiscoveryNamespace       string `shconfig:",required" comment:"Must be unique for each instance id."`
+	IsAccessNode             bool   `comment:"Optional, to be set to true if running an access node"`
 }
 
 func (c *Config) Name() string {

rolling-shutter/p2p/messaging.go

@@ -98,6 +98,7 @@ func New(config *Config) (*P2PMessaging, error) {
 		PrivKey:            *config.P2PKey,
 		Environment:        config.Environment,
 		DiscoveryNamespace: config.DiscoveryNamespace,
+		IsAccessNode:       config.IsAccessNode,
 	}
 
 	bootstrapAddresses := config.CustomBootstrapAddresses

rolling-shutter/p2p/p2p.go

@@ -69,6 +69,7 @@ type p2pNodeConfig struct {
 	PrivKey            keys.Libp2pPrivate
 	Environment        env.Environment
 	IsBootstrapNode    bool
+	IsAccessNode       bool
 	DiscoveryNamespace string
 }
 
@@ -264,6 +265,7 @@ func createPubSub(
 	gossipSubParams, peerScoreParams, peerScoreThresholds := makePubSubParams(pubSubParamsOptions{
 		isBootstrapNode: config.IsBootstrapNode,
 		bootstrapPeers:  config.BootstrapPeers,
+		isAccessNode:    config.IsAccessNode,
 	})
 
 	pubsubOptions := []pubsub.Option{

rolling-shutter/p2p/params.go

@@ -9,6 +9,7 @@ import (
 
 type pubSubParamsOptions struct {
 	isBootstrapNode bool
+	isAccessNode    bool
 	bootstrapPeers  []peer.AddrInfo
 }
 
@@ -35,6 +36,10 @@ func makePubSubParams(
 		gossipSubParams.Dscore = 0
 	}
 
+	if options.isAccessNode {
+		gossipSubParams.Dhi = 30
+	}
+
 	peerScoreThresholds := &pubsub.PeerScoreThresholds{
 		GossipThreshold:             -4000,
 		PublishThreshold:            -8000,