pegnet · SiriusWhi · Feb 25, 2021 · Aug 14, 2021 · Aug 14, 2021 · Aug 14, 2021
diff --git a/cmd/cmd.go b/cmd/cmd.go
@@ -41,6 +41,7 @@ func init() {
 	RootCmd.AddCommand(networkMinerCmd)
 	RootCmd.AddCommand(datasources)
 	RootCmd.AddCommand(staker)
+	RootCmd.AddCommand(delegateStaker)
 
 	decode.AddCommand(decodeEntry)
 	decode.AddCommand(decodeEblock)
@@ -337,6 +338,26 @@ var staker = &cobra.Command{
 	},
 }
 
+var delegateStaker = &cobra.Command{
+	Use: "dstake ",
+	Run: func(cmd *cobra.Command, args []string) {
+		fmt.Println("This is delegate staking...")
+		ctx, cancel := context.WithCancel(context.Background())
+		common.GlobalExitHandler.AddCancel(cancel)
+
+		ValidateDelegateStakingConfig(Config) // Will fatal log if it fails
+
+		// Services
+		monitor := LaunchFactomMonitor(Config)
+
+		// This is a blocking call
+		coord_s := LaunchStaker(Config, ctx, monitor)
+
+		// Calling cancel() will cancel the staker
+		var _, _ = cancel, coord_s
+	},
+}
+
 // -------------------------------------------------------------
 // RPC Wrapper Commands
 

diff --git a/cmd/root.go b/cmd/root.go
@@ -140,6 +140,46 @@ func ValidateStakingConfig(config *config.Config) {
 	if err != nil {
 		log.WithError(err).Fatal("failed to read staker network from config")
 	}
+
+	StakingMode, err := config.String("Staker.StakingMode")
+	if err != nil {
+		log.WithError(err).Fatal("failed to StakingMode from config")
+	}
+	if StakingMode != "SoleStake" {
+		log.WithError(err).Fatal("please set StakingMode correctly in the config")
+	}
+}
+
+// ValidateDelegateStakingConfig will validate the config is up to snuff.
+// Do w/e config validation we want. Will fatal if it fails
+func ValidateDelegateStakingConfig(config *config.Config) {
+	_, err := config.String("Staker.Protocol")
+	if err != nil {
+		log.WithError(err).Fatal("failed to read staker protocol from config")
+	}
+
+	_, err = config.String("Staker.Network")
+	if err != nil {
+		log.WithError(err).Fatal("failed to read staker network from config")
+	}
+
+	StakingMode, err := config.String("Staker.StakingMode")
+	if err != nil {
+		log.WithError(err).Fatal("failed to read StakingMode from config")
+	}
+	if StakingMode != "DelegatingStake" {
+		log.WithError(err).Fatal("please set StakingMode correctly in the config")
+	}
+
+	_, err = config.String("DelegateStaker.DelagateeAddress")
+	if err != nil {
+		log.WithError(err).Fatal("failed to read DelagateeAddress info from config")
+	}

+	_, err = config.String("DelegateStaker.DelegatorList")
+	if err != nil {
+		log.WithError(err).Fatal("failed to read DelegatorList info from config")
+	}
 }
 
 func initLogger() {
@@ -175,6 +215,7 @@ func rootPreRunSetup(cmd *cobra.Command, args []string) error {
 		common.V20HeightActivation = 0
 		common.SprSignatureActivation = 0
 		common.V202EnhanceActivation = 0
+		common.PIP18DelegateStakingActivation = 0
 	}
 
 	if testingact, _ := cmd.Flags().GetInt32("testingact"); testingact != -1 {

diff --git a/common/activation.go b/common/activation.go
@@ -45,16 +45,22 @@ var (
 			if height < V202EnhanceActivation {
 				return 6
 			}
-			return 7 // Latest code version
+			if height < PIP18DelegateStakingActivation {
+				return 7
+			}
+			return 8 // Latest code version
 		},
 		TestNetwork: func(height int64) uint8 {
-			if height < SprSignatureActivation {
-				return 5
-			}
-			if height < V202EnhanceActivation {
-				return 6
-			}
-			return 7 // Latest code version
+			//if height < SprSignatureActivation {
+			//	return 5
+			//}
+			//if height < V202EnhanceActivation {
+			//	return 6
+			//}
+			//if height < PIP18DelegateStakingActivation {
+			//	return 7
+			//}
+			return 8 // Latest code version
 		},
 	}
 
@@ -80,6 +86,9 @@ var (
 	// V202EnhanceActivation indicates the activation of PegNet 2.0.2.
 	// Estimated to be  XXXXX XXX XXX
 	V202EnhanceActivation int64 = 274036
+
+	// PIP18DelegateStakingActivation implements delegate staking.
+	PIP18DelegateStakingActivation int64 = 314482
 )
 
 // NetworkActive returns true if the network height is above the activation height.

diff --git a/common/common.go b/common/common.go
@@ -3,7 +3,10 @@
 package common
 
 import (
+	"bufio"
 	"fmt"
+	"os"
+	"strconv"
 	"strings"
 
 	"github.com/zpatrick/go-config"
@@ -31,6 +34,57 @@ func LoadConfigStakerNetwork(c *config.Config) (string, error) {
 	return GetNetwork(network)
 }
 
+func LoadDelegatorsSignatures(c *config.Config, delegatee string) []byte {
+	delegateeAddresses, err := c.String("DelegateStaker.DelagateeAddress")
+	if err != nil {
+		return nil
+	}
+	delegatorList, err := c.String("DelegateStaker.DelegatorList")
+	if err != nil {
+		return nil
+	}
+
+	delegateeAddrs := strings.Split(delegateeAddresses, ",")
+	delegatorsPaths := strings.Split(delegatorList, ",")
+
+	var dPath = ""
+	for i := 0; i < len(delegateeAddrs); i++ {
+		if delegateeAddrs[i] == delegatee {
+			dPath = delegatorsPaths[i]
+			break
+		}
+	}
+
+	// Read signature data from file
+	path := os.ExpandEnv(dPath)
+	f, err := os.Open(path)
+	if err != nil {
+		return nil
+	}
+
+	defer f.Close()
+	scanner := bufio.NewScanner(f)
+
+	var delegatorsSigResult []byte
+	for scanner.Scan() {
+		sigData := scanner.Text()
+		sigDataStr := strings.Split(sigData, " ")
+		var byteArray []byte
+		for i := 0; i < len(sigDataStr); i++ {
+			i, _ := strconv.Atoi(sigDataStr[i])
+			byteArray = append(byteArray, byte(i))
+		}
+		fmt.Println(byteArray)
+		delegatorsSigResult = append(delegatorsSigResult[:], byteArray[:]...)
+	}
+
+	if err := scanner.Err(); err != nil {
+		return nil
+	}
+
+	return delegatorsSigResult
+}
+
 func GetNetwork(network string) (string, error) {
 	switch strings.ToLower(network) {
 	case strings.ToLower(MainNetwork):

diff --git a/config/defaultconfig.ini b/config/defaultconfig.ini
@@ -56,6 +56,9 @@
   ControlPanelPort=8080
 
 [Staker]
+  # StakingMode can be "DelegatingStake" or "SoleStake".
+  StakingMode="SoleStake"
+
   # Factom Connection Options (if using Docker, use values below)
   # FactomdLocation="localhost:8088"
   # WalletdLocation="localhost:8089"
@@ -77,8 +80,21 @@
   ECAddress=EC3TsJHUs8bzbbVnratBafub6toRYdgzgbR7kWwCW4tqbmyySRmg
 
   # This is your address.  Generate a FCT address and put it here, so if you win, you will be rewarded!
+  # If you have multiple FCT addresses, then you can add multiple ones using comma(,)
+  # For example, CoinbaseAddress=FA2jK2HcLnRdS94dEcU27rF3meoJfpUcZPSinpb7AwQvPRY6RL1Q,FA2ocUwsU6oeG4tjNnZUY7LRqQ8Yg9ciKdMqajeYH3abZju4YREU
   CoinbaseAddress=CHANGEME
 
+[DelegateStaker]
+  # This is a delegatee's FCT address. ex: FA2jK2HcLnRdS94dEcU27rF3meoJfpUcZPSinpb7AwQvPRY6RL1Q
+  # If you want multiple DelegateeAddress, you can add them using comma(,)
+  # For example, DelagateeAddress=FA2jK2HcLnRdS94dEcU27rF3meoJfpUcZPSinpb7AwQvPRY6RL1Q,FA2ocUwsU6oeG4tjNnZUY7LRqQ8Yg9ciKdMqajeYH3abZju4YREU
+  DelagateeAddress=CHANGEME
+
+  # This is a list of delegators signatures. ex: $HOME/.pegnet/delegators01.txt
+  # In case it is multiple path info, use comma too.
+  # For example, DelegatorList=$HOME/.pegnet/delegators01.txt,$HOME/.pegnet/delegators02.txt
+  DelegatorList=CHANGEME
+
 [Miner]
   # Factom Connection Options (if using Docker, use values below)
   FactomdLocation="localhost:8088"