add control peer rest api

Signed-off-by: Fedor Partanskiy <[email protected]>

Author: pfi79

core/peer/config.go

@@ -219,6 +219,26 @@ type Config struct {
 	// interact with fabric networks
 
 	GatewayOptions gatewayconfig.Options
+
+	// ----- Rest api config -----
+	RestAPI RestAPI
+}
+
+// RestAPI configures the rest endpoint for the peer.
+type RestAPI struct {
+	ListenAddress string
+	TLS           TLS
+}
+
+// TLS contains configuration for TLS connections.
+type TLS struct {
+	Enabled               bool
+	PrivateKey            string
+	Certificate           string
+	RootCAs               []string
+	ClientAuthRequired    bool
+	ClientRootCAs         []string
+	TLSHandshakeTimeShift time.Duration
 }
 
 // GlobalConfig obtains a set of configuration from viper, build and returns
@@ -331,6 +351,15 @@ func (c *Config) load() error {
 	c.DockerKey = config.GetPath("vm.docker.tls.key.file")
 	c.DockerCA = config.GetPath("vm.docker.tls.ca.file")
 
+	c.RestAPI.ListenAddress = viper.GetString("RestAPI.ListenAddress")
+	c.RestAPI.TLS.Enabled = viper.GetBool("RestAPI.TLS.Enabled")
+	c.RestAPI.TLS.Certificate = config.GetPath("RestAPI.TLS.Certificate")
+	c.RestAPI.TLS.PrivateKey = config.GetPath("RestAPI.TLS.PrivateKey")
+	c.RestAPI.TLS.ClientAuthRequired = viper.GetBool("RestAPI.TLS.ClientAuthRequired")
+	for _, rca := range viper.GetStringSlice("RestAPI.TLS.ClientRootCAs") {
+		c.RestAPI.TLS.ClientRootCAs = append(c.RestAPI.TLS.ClientRootCAs, config.TranslatePath(configDir, rca))
+	}
+
 	return nil
 }
 

core/peer/config_test.go

@@ -305,6 +305,13 @@ func TestGlobalConfig(t *testing.T) {
 	viper.Set("metrics.statsd.writeInterval", "10s")
 	viper.Set("metrics.statsd.prefix", "testPrefix")
 
+	viper.Set("RestAPI.ListenAddress", "127.0.0.1:9444")
+	viper.Set("RestAPI.TLS.Enabled", false)
+	viper.Set("RestAPI.TLS.Certificate", "test/tls/cert/file")
+	viper.Set("RestAPI.TLS.PrivateKey", "test/tls/key/file")
+	viper.Set("RestAPI.TLS.ClientAuthRequired", false)
+	viper.Set("RestAPI.TLS.ClientRootCAs", []string{"relative/file1", "/absolute/file2"})
+
 	viper.Set("chaincode.pull", false)
 	viper.Set("chaincode.externalBuilders", &[]ExternalBuilder{
 		{
@@ -385,6 +392,20 @@ func TestGlobalConfig(t *testing.T) {
 			BroadcastTimeout:   10 * time.Second,
 			DialTimeout:        60 * time.Second,
 		},
+		RestAPI: RestAPI{
+			ListenAddress: "127.0.0.1:9444",
+			TLS: TLS{
+				Enabled:            false,
+				PrivateKey:         filepath.Join(cwd, "test/tls/key/file"),
+				Certificate:        filepath.Join(cwd, "test/tls/cert/file"),
+				RootCAs:            nil,
+				ClientAuthRequired: false,
+				ClientRootCAs: []string{
+					filepath.Join(cwd, "relative", "file1"),
+					"/absolute/file2",
+				},
+			},
+		},
 	}
 
 	require.Equal(t, coreConfig, expectedConfig)