[FAB-6385] Go SDK Configurable timeouts

Change-Id: I9558396750f95e81dc0d00226f59214df5861cb4
Signed-off-by: Sudesh Shetty <sudesh.shetty@securekey.com>

Author: sudeshrshetty

api/apiconfig/configprovider.go

@@ -20,7 +20,7 @@ type Config interface {
 	CAServerCertFiles(org string) ([]string, error)
 	CAClientKeyFile(org string) (string, error)
 	CAClientCertFile(org string) (string, error)
-	TimeoutOrDefault(ConnectionType) time.Duration
+	TimeoutOrDefault(TimeoutType) time.Duration
 	MspID(org string) (string, error)
 	OrderersConfig() ([]OrdererConfig, error)
 	RandomOrdererConfig() (*OrdererConfig, error)
@@ -47,16 +47,22 @@ type Config interface {
 	CSPConfig() *bccspFactory.FactoryOpts
 }
 
-// ConnectionType enumerates the different types of outgoing connections
-type ConnectionType int
+// TimeoutType enumerates the different types of outgoing connections
+type TimeoutType int
 
 const (
-	// Endorser connection
-	Endorser ConnectionType = iota
-	// EventHub connection
+	// Endorser connection timeout
+	Endorser TimeoutType = iota
+	// EventHub connection timeout
 	EventHub
-	// EventReg connection
+	// EventReg connection timeout
 	EventReg
-	// Orderer connection
-	Orderer
+	// Query timeout
+	Query
+	// ExecuteTx timeout
+	ExecuteTx
+	// OrdererConnection Orderer connection timeout
+	OrdererConnection
+	// OrdererSendDeliver Orderer SendDeliver timeout
+	OrdererResponse
 )

api/apiconfig/mocks/mockconfig.gen.go

@@ -211,17 +211,23 @@ func (c *Config) CAClientCertFile(org string) (string, error) {
 }
 
 // TimeoutOrDefault reads connection timeouts for the given connection type
-func (c *Config) TimeoutOrDefault(conn apiconfig.ConnectionType) time.Duration {
+func (c *Config) TimeoutOrDefault(conn apiconfig.TimeoutType) time.Duration {
 	var timeout time.Duration
 	switch conn {
 	case apiconfig.Endorser:
-		timeout = myViper.GetDuration("client.connection.timeout.peer.endorser")
+		timeout = myViper.GetDuration("client.endorserConnectionTimeout")
 	case apiconfig.EventHub:
-		timeout = myViper.GetDuration("client.connection.timeout.peer.eventhub")
+		timeout = myViper.GetDuration("client.eventServiceConnectionTimeout")
 	case apiconfig.EventReg:
-		timeout = myViper.GetDuration("client.connection.timeout.peer.eventreg")
-	case apiconfig.Orderer:
-		timeout = myViper.GetDuration("client.connection.timeout.orderer")
+		timeout = myViper.GetDuration("client.eventRegistrationResponseTimeout")
+	case apiconfig.OrdererConnection:
+		timeout = myViper.GetDuration("client.ordererConnectionTimeout")
+	case apiconfig.Query:
+		timeout = myViper.GetDuration("client.queryResponseTimeout")
+	case apiconfig.ExecuteTx:
+		timeout = myViper.GetDuration("client.executeTxResponseTimeout")
+	case apiconfig.OrdererResponse:
+		timeout = myViper.GetDuration("client.ordererResponseTimeout")
 	}
 	if timeout == 0 {
 		timeout = defaultTimeout

pkg/config/config.go

@@ -44,14 +44,7 @@ client:
   logging:
     level: info
 
-  # set connection timeouts for the peer and orderer for the client
-  connection:
-     timeout:
-      peer:
-       endorser: 3s
-       eventHub: 3s
-       eventReg: 3s
-      orderer: 3s
+
 
   # Needed to load users crypto keys and certs.
   cryptoconfig:
@@ -94,6 +87,22 @@ client:
      #library: "/usr/lib/x86_64-linux-gnu/softhsm/libsofthsm2.so, /usr/lib/softhsm/libsofthsm2.so ,/usr/lib/s390x-linux-gnu/softhsm/libsofthsm2.so, /usr/lib/powerpc64le-linux-gnu/softhsm/libsofthsm2.so, /usr/local/Cellar/softhsm/2.1.0/lib/softhsm/libsofthsm2.so"
      library: "add BCCSP library here"
 
+  #Timeout configs for various connection and response types
+  endorserConnectionTimeout: 3s
+
+  eventServiceConnectionTimeout: 3s
+
+  ordererConnectionTimeout: 3s
+
+  ordererResponseTimeout: 5s
+
+  eventRegistrationResponseTimeout: 3s
+
+  queryResponseTimeout: 20s
+
+  executeTxResponseTimeout: 30s
+
+
 #
 # [Optional]. But most apps would have this section so that channel objects can be constructed
 # based on the content below. If an app is creating channels, then it likely will not need this
@@ -233,7 +242,7 @@ certificateAuthorities:
     # Fabric-CA supports dynamic user enrollment via REST APIs. A "root" user, a.k.a registrar, is
     # needed to enroll and invoke new users.
 #    registrar:
-#      enrollId: usualy-it-is_admin
+#      enrollId: usually-it-is_admin
 #      enrollSecret: adminpasswd
     # [Optional] The optional name of the CA.
 #    caName: ca-org1

pkg/config/config.yaml

@@ -300,33 +300,50 @@ func TestTLSACAConfig(t *testing.T) {
 }
 
 func TestTimeouts(t *testing.T) {
-	myViper.Set("client.connection.timeout.peer.endorser", "2s")
-	myViper.Set("client.connection.timeout.peer.eventhub", "2m")
-	myViper.Set("client.connection.timeout.peer.eventreg", "2h")
-	myViper.Set("client.connection.timeout.orderer", "2ms")
+	myViper.Set("client.endorserConnectionTimeout", "2s")
+	myViper.Set("client.eventServiceConnectionTimeout", "2m")
+	myViper.Set("client.eventRegistrationResponseTimeout", "2h")
+	myViper.Set("client.ordererConnectionTimeout", "2ms")
+	myViper.Set("client.queryResponseTimeout", "7h")
+	myViper.Set("client.executeTxResponseTimeout", "8h")
+	myViper.Set("client.ordererResponseTimeout", "6s")
 
 	t1 := configImpl.TimeoutOrDefault(api.Endorser)
 	if t1 != time.Second*2 {
 		t.Fatalf("Timeout not read correctly. Got: %s", t1)
 	}
-	t2 := configImpl.TimeoutOrDefault(api.EventHub)
-	if t2 != time.Minute*2 {
-		t.Fatalf("Timeout not read correctly. Got: %s", t2)
+	t1 = configImpl.TimeoutOrDefault(api.EventHub)
+	if t1 != time.Minute*2 {
+		t.Fatalf("Timeout not read correctly. Got: %s", t1)
+	}
+	t1 = configImpl.TimeoutOrDefault(api.EventReg)
+	if t1 != time.Hour*2 {
+		t.Fatalf("Timeout not read correctly. Got: %s", t1)
+	}
+	t1 = configImpl.TimeoutOrDefault(api.Query)
+	if t1 != time.Hour*7 {
+		t.Fatalf("Timeout not read correctly. Got: %s", t1)
+	}
+	t1 = configImpl.TimeoutOrDefault(api.ExecuteTx)
+	if t1 != time.Hour*8 {
+		t.Fatalf("Timeout not read correctly. Got: %s", t1)
 	}
-	t3 := configImpl.TimeoutOrDefault(api.EventReg)
-	if t3 != time.Hour*2 {
-		t.Fatalf("Timeout not read correctly. Got: %s", t3)
+	t1 = configImpl.TimeoutOrDefault(api.OrdererConnection)
+	if t1 != time.Millisecond*2 {
+		t.Fatalf("Timeout not read correctly. Got: %s", t1)
 	}
-	t4 := configImpl.TimeoutOrDefault(api.Orderer)
-	if t4 != time.Millisecond*2 {
-		t.Fatalf("Timeout not read correctly. Got: %s", t4)
+	t1 = configImpl.TimeoutOrDefault(api.OrdererResponse)
+	if t1 != time.Second*6 {
+		t.Fatalf("Timeout not read correctly. Got: %s", t1)
 	}
+
 	// Test default
-	myViper.Set("client.connection.timeout.orderer", "")
-	t5 := configImpl.TimeoutOrDefault(api.Orderer)
-	if t5 != time.Second*5 {
-		t.Fatalf("Timeout not read correctly. Got: %s", t5)
+	myViper.Set("client.ordererConnectionTimeout", "")
+	t1 = configImpl.TimeoutOrDefault(api.OrdererConnection)
+	if t1 != time.Second*5 {
+		t.Fatalf("Timeout not read correctly. Got: %s", t1)
 	}
+
 }
 
 func TestOrdererConfig(t *testing.T) {

pkg/config/config_test.go

@@ -58,7 +58,7 @@ func (c *MockConfig) FabricClientViper() *viper.Viper {
 }
 
 //TimeoutOrDefault not implemented
-func (c *MockConfig) TimeoutOrDefault(apiconfig.ConnectionType) time.Duration {
+func (c *MockConfig) TimeoutOrDefault(apiconfig.TimeoutType) time.Duration {
 	return 0
 }
 

pkg/fabric-ca-client/mocks/mockconfig.go

@@ -9,6 +9,7 @@ package channel
 import (
 	"fmt"
 
+	config "github.com/hyperledger/fabric-sdk-go/api/apiconfig"
 	fab "github.com/hyperledger/fabric-sdk-go/api/apifabclient"
 	"github.com/hyperledger/fabric-sdk-go/api/apitxn"
 	"github.com/hyperledger/fabric-sdk-go/internal/github.com/hyperledger/fabric/msp"
@@ -35,6 +36,7 @@ type ClientContext interface {
 	UserContext() fab.User
 	SigningManager() fab.SigningManager
 	NewTxnID() (apitxn.TransactionID, error)
+	Config() config.Config
 }
 
 // NewChannel represents a channel in a Fabric network.

pkg/fabric-client/channel/channel.go

@@ -17,6 +17,7 @@ import (
 	fab "github.com/hyperledger/fabric-sdk-go/api/apifabclient"
 	"github.com/hyperledger/fabric-sdk-go/api/apitxn"
 
+	"github.com/hyperledger/fabric-sdk-go/api/apiconfig"
 	protos_utils "github.com/hyperledger/fabric-sdk-go/internal/github.com/hyperledger/fabric/protos/utils"
 	"github.com/hyperledger/fabric-sdk-go/pkg/fabric-client/internal/txnproc"
 	"github.com/hyperledger/fabric-sdk-go/third_party/github.com/hyperledger/fabric/protos/common"
@@ -390,7 +391,7 @@ func (c *Channel) SendEnvelope(envelope *fab.SignedEnvelope) (*common.Block, err
 				}
 				mutex.Unlock()
 
-			case <-time.After(time.Second * 5):
+			case <-time.After(c.ClientContext().Config().TimeoutOrDefault(apiconfig.OrdererResponse)):
 				mutex.Lock()
 				if errorResponse == nil {
 					errorResponse = fmt.Errorf("Timeout waiting for response from orderer")

pkg/fabric-client/channel/txnsender.go

@@ -60,7 +60,11 @@ func (c *MockConfig) CAClientCertFile(org string) (string, error) {
 }
 
 //TimeoutOrDefault not implemented
-func (c *MockConfig) TimeoutOrDefault(config.ConnectionType) time.Duration {
+func (c *MockConfig) TimeoutOrDefault(arg config.TimeoutType) time.Duration {
+
+	if arg == config.Query || arg == config.ExecuteTx {
+		return time.Second * 10
+	}
 	return 0
 }
 

pkg/fabric-client/mocks/mockconfig.go

@@ -31,7 +31,7 @@ type Orderer struct {
 // NewOrderer Returns a Orderer instance
 func NewOrderer(url string, certificate string, serverHostOverride string, config apiconfig.Config) (*Orderer, error) {
 	var opts []grpc.DialOption
-	opts = append(opts, grpc.WithTimeout(config.TimeoutOrDefault(apiconfig.Orderer)))
+	opts = append(opts, grpc.WithTimeout(config.TimeoutOrDefault(apiconfig.OrdererConnection)))
 	if config.IsTLSEnabled() {
 		tlsCaCertPool, err := config.TLSCACertPool(certificate)
 		if err != nil {