[FAB-9228] Add Orderer Runner for tests

This CR adds the orderer runner used for executing
tests using ginkgo.

Change-Id: I7f48a9e23f78e23fa9927601a236c934beb776f7
Signed-off-by: Latitia M Haskins <latitia.haskins@gmail.com>

Author: lhaskins

integration/runner/orderer.go

@@ -0,0 +1,47 @@
+/*
+Copyright IBM Corp All Rights Reserved.
+
+SPDX-License-Identifier: Apache-2.0
+*/
+
+package runner
+
+import (
+	"fmt"
+	"os/exec"
+
+	"github.com/tedsuo/ifrit/ginkgomon"
+)
+
+type Orderer struct {
+	Path                        string
+	ConfigDir                   string
+	LedgerLocation              string
+	ConfigtxOrdererKafkaBrokers string
+	LogLevel                    string
+}
+
+func (o *Orderer) setupEnvironment(cmd *exec.Cmd) {
+	if o.ConfigDir != "" {
+		cmd.Env = append(cmd.Env, fmt.Sprintf("FABRIC_CFG_PATH=%s", o.ConfigDir))
+	}
+	if o.LedgerLocation != "" {
+		cmd.Env = append(cmd.Env, fmt.Sprintf("ORDERER_FILELEDGER_LOCATION=%s", o.LedgerLocation))
+	}
+	if o.ConfigtxOrdererKafkaBrokers != "" {
+		cmd.Env = append(cmd.Env, fmt.Sprintf("CONFIGTX_ORDERER_KAFKA_BROKERS=%s", o.ConfigtxOrdererKafkaBrokers))
+	}
+	if o.LogLevel != "" {
+		cmd.Env = append(cmd.Env, fmt.Sprintf("ORDERER_GENERAL_LOGLEVEL=%s", o.LogLevel))
+	}
+}
+
+func (o *Orderer) New() *ginkgomon.Runner {
+	cmd := exec.Command(o.Path)
+	o.setupEnvironment(cmd)
+
+	return ginkgomon.New(ginkgomon.Config{
+		Name:    "orderer",
+		Command: cmd,
+	})
+}

integration/runner/orderer_test.go

@@ -0,0 +1,73 @@
+/*
+Copyright IBM Corp All Rights Reserved.
+
+SPDX-License-Identifier: Apache-2.0
+*/
+
+package runner_test
+
+import (
+	"io/ioutil"
+	"os"
+	"path/filepath"
+	"syscall"
+
+	"github.com/hyperledger/fabric/integration/runner"
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+	"github.com/onsi/gomega/gbytes"
+	"github.com/tedsuo/ifrit"
+)
+
+var _ = Describe("Orderer", func() {
+	var (
+		orderer *runner.Orderer
+		tempDir string
+	)
+
+	BeforeEach(func() {
+		var err error
+		tempDir, err = ioutil.TempDir("", "orderer")
+		Expect(err).NotTo(HaveOccurred())
+
+		copyFile(filepath.Join("testdata", "cryptogen-config.yaml"), filepath.Join(tempDir, "cryptogen-config.yaml"))
+		cryptogen := components.Cryptogen()
+		cryptogen.Config = filepath.Join(tempDir, "cryptogen-config.yaml")
+		cryptogen.Output = filepath.Join(tempDir, "crypto-config")
+
+		crypto := cryptogen.Generate()
+		Expect(execute(crypto)).To(Succeed())
+
+		copyFile(filepath.Join("testdata", "configtx.yaml"), filepath.Join(tempDir, "configtx.yaml"))
+		configtxgen := components.Configtxgen()
+		configtxgen.ChannelID = "mychannel"
+		configtxgen.Profile = "TwoOrgsOrdererGenesis"
+		configtxgen.ConfigDir = tempDir
+		configtxgen.Output = filepath.Join(tempDir, "mychannel.block")
+
+		r := configtxgen.OutputBlock()
+		err = execute(r)
+		Expect(err).NotTo(HaveOccurred())
+
+		copyFile(filepath.Join("testdata", "orderer.yaml"), filepath.Join(tempDir, "orderer.yaml"))
+		orderer = components.Orderer()
+		orderer.ConfigDir = tempDir
+		orderer.LedgerLocation = tempDir
+		orderer.LogLevel = "debug"
+	})
+
+	AfterEach(func() {
+		os.RemoveAll(tempDir)
+	})
+
+	It("starts an orderer", func() {
+		r := orderer.New()
+		process := ifrit.Invoke(r)
+		Eventually(process.Ready()).Should(BeClosed())
+		Eventually(r.Err()).Should(gbytes.Say("Beginning to serve requests"))
+
+		Consistently(process.Wait()).ShouldNot(Receive())
+		process.Signal(syscall.SIGTERM)
+		Eventually(process.Wait()).Should(Receive())
+	})
+})

integration/runner/testdata/configtx.yaml

@@ -49,7 +49,7 @@ Organizations:
 Orderer: &OrdererDefaults
   OrdererType: solo
   Addresses:
-    - orderer.example.com:7050
+    - orderer.example.com:8050
   BatchTimeout: 2s
   BatchSize:
     MaxMessageCount: 10

integration/runner/testdata/orderer.yaml

@@ -0,0 +1,78 @@
+# Copyright IBM Corp. All Rights Reserved.
+#
+# SPDX-License-Identifier: Apache-2.0
+
+---
+General:
+  LedgerType: file
+  ListenAddress: 127.0.0.1
+  ListenPort: 8050
+  TLS:
+    Enabled: false
+    PrivateKey: tls/server.key
+    Certificate: tls/server.crt
+    RootCAs:
+      - tls/ca.crt
+    ClientAuthRequired: false
+    ClientRootCAs:
+  Keepalive:
+    ServerMinInterval: 60s
+    ServerInterval: 7200s
+    ServerTimeout: 20s
+  LogLevel: info
+  LogFormat: '%{color}%{time:2006-01-02 15:04:05.000 MST} [%{module}] %{shortfunc} -> %{level:.4s} %{id:03x}%{color:reset} %{message}'
+  GenesisMethod: file
+  GenesisProfile: TwoOrgsOrdererGenesis
+  SystemChannel: mychannel
+  GenesisFile: mychannel.block
+  LocalMSPDir: crypto-config/ordererOrganizations/example.com/orderers/orderer.example.com/msp
+  LocalMSPID: OrdererMSP
+  Profile:
+    Enabled: false
+    Address: 0.0.0.0:6060
+  BCCSP:
+    Default: SW
+    SW:
+      Hash: SHA2
+      Security: 256
+      FileKeyStore:
+        KeyStore:
+  Authentication:
+    TimeWindow: 15m
+
+FileLedger:
+  Location: /var/hyperledger/production/orderer
+  Prefix: hyperledger-fabric-ordererledger
+
+RAMLedger:
+  HistorySize: 1000
+
+Kafka:
+  Retry:
+    ShortInterval: 5s
+    ShortTotal: 10m
+    LongInterval: 5m
+    LongTotal: 12h
+    NetworkTimeouts:
+      DialTimeout: 10s
+      ReadTimeout: 10s
+      WriteTimeout: 10s
+    Metadata:
+      RetryBackoff: 250ms
+      RetryMax: 3
+    Producer:
+      RetryBackoff: 100ms
+      RetryMax: 3
+    Consumer:
+      RetryBackoff: 2s
+  Verbose: false
+  TLS:
+    Enabled: false
+    PrivateKey:
+    Certificate:
+    RootCAs:
+  Version:
+
+Debug:
+    BroadcastTraceDir:
+    DeliverTraceDir:

integration/world/components.go

@@ -29,6 +29,10 @@ func (c *Components) Build() {
 	configtxgen, err := gexec.Build("github.com/hyperledger/fabric/common/tools/configtxgen")
 	Expect(err).NotTo(HaveOccurred())
 	c.Paths["configtxgen"] = configtxgen
+
+	orderer, err := gexec.Build("github.com/hyperledger/fabric/orderer")
+	Expect(err).NotTo(HaveOccurred())
+	c.Paths["orderer"] = orderer
 }
 
 func (c *Components) Cleanup() {
@@ -49,3 +53,9 @@ func (c *Components) Configtxgen() *runner.Configtxgen {
 		Path: c.Paths["configtxgen"],
 	}
 }
+
+func (c *Components) Orderer() *runner.Orderer {
+	return &runner.Orderer{
+		Path: c.Paths["orderer"],
+	}
+}