[c] Add slowdown flag

dfssc/cmd/root.go

@@ -3,7 +3,6 @@ package cmd
 
 import (
 	"dfss"
-
 	dapi "dfss/dfssd/api"
 	"github.com/spf13/cobra"
 	"github.com/spf13/viper"
@@ -31,7 +30,7 @@ A tool to sign multiparty contract using a secure cryptographic protocol`,
 // All of the flags will be gathered by viper, this is why
 // we do not store their values
 func init() {
-	// Bind flags to the dfsst command
+	// Bind flags to the dfssc command
 	RootCmd.PersistentFlags().BoolP("verbose", "v", false, "print verbose messages")
 	RootCmd.PersistentFlags().String("ca", "ca.pem", "path to the root certificate")
 	RootCmd.PersistentFlags().String("cert", "cert.pem", "path to the user's certificate")
@@ -40,6 +39,8 @@ func init() {
 	RootCmd.PersistentFlags().String("host", "localhost:9000", "host of the dfss platform")
 	RootCmd.PersistentFlags().IntP("port", "p", 9005, "port to use for P2P communication between clients")
 
+	signCmd.Flags().Duration("slowdown", 0, "Delay between each promises round")
+
 	// Store flag values into viper
 	_ = viper.BindPFlag("verbose", RootCmd.PersistentFlags().Lookup("verbose"))
 	_ = viper.BindPFlag("file_ca", RootCmd.PersistentFlags().Lookup("ca"))

dfssc/cmd/sign.go

@@ -6,6 +6,7 @@ import (
 
 	"dfss/dfssc/sign"
 	"github.com/spf13/cobra"
+	"github.com/spf13/viper"
 )
 
 var signCmd = &cobra.Command{
@@ -17,6 +18,8 @@ var signCmd = &cobra.Command{
 			os.Exit(1)
 		}
 
+		_ = viper.BindPFlag("slowdown", cmd.Flags().Lookup("slowdown"))
+
 		filename := args[0]
 		fmt.Println("You are going to sign the following contract:")
 		showContract(cmd, args)

dfssc/sign/protocol.go

@@ -8,6 +8,7 @@ import (
 	cAPI "dfss/dfssc/api"
 	"dfss/dfssc/common"
 	dAPI "dfss/dfssd/api"
+	"github.com/spf13/viper"
 )
 
 // Sign performs all the message exchanges for the contract to be signed
@@ -42,6 +43,7 @@ func (m *SignatureManager) Sign() error {
 	// Follow the sequence until there is no next occurence of me
 	for m.currentIndex >= 0 {
 		m.OnProgressUpdate(m.currentIndex, seqLen+1)
+		time.Sleep(viper.GetDuration("slowdown"))
 		dAPI.DLog("starting round at index [" + fmt.Sprintf("%d", m.currentIndex) + "] with nextIndex=" + fmt.Sprintf("%d", nextIndex))
 
 		// Set of promises we are waiting for