[FAB-9232] Add Cryptogen for Integration Test

Adds the cryptogen component for integration tests
using ginkgo.

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

Author: lhaskins

Gopkg.lock

@@ -0,0 +1,36 @@
+/*
+Copyright IBM Corp All Rights Reserved.
+
+SPDX-License-Identifier: Apache-2.0
+*/
+
+package runner
+
+import (
+	"os/exec"
+	"github.com/tedsuo/ifrit/ginkgomon"
+)
+
+// Cryptogen creates runners that call cryptogen functions.
+type Cryptogen struct {
+	// The location of the cryptogen executable
+	Path string
+	// The location of the config file
+	Config string
+	// The output directory
+	Output string
+}
+
+// Generate uses cryptogen to generate cryptographic material for fabric.
+func (c *Cryptogen) Generate(extraArgs ...string) *ginkgomon.Runner {
+	return ginkgomon.New(ginkgomon.Config{
+		Command: exec.Command(
+			c.Path,
+			append([]string{
+				"generate",
+				"--config", c.Config,
+				"--output", c.Output,
+			}, extraArgs...)...,
+		),
+	})
+}

integration/runner/cryptogen.go

@@ -0,0 +1,62 @@
+/*
+Copyright IBM Corp All Rights Reserved.
+
+SPDX-License-Identifier: Apache-2.0
+*/
+
+package runner_test
+
+import (
+	"io/ioutil"
+	"os"
+	"path/filepath"
+
+	"github.com/hyperledger/fabric/integration/runner"
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+
+	"github.com/tedsuo/ifrit"
+)
+
+var _ = Describe("CryptoGen", func() {
+	var cryptogen *runner.Cryptogen
+	var tempDir string
+
+	BeforeEach(func() {
+		var err error
+		tempDir, err = ioutil.TempDir("", "crypto")
+		Expect(err).NotTo(HaveOccurred())
+
+		cryptogen = &runner.Cryptogen{
+			Path:   components.Paths["cryptogen"],
+			Config: filepath.Join("testdata", "cryptogen-config.yaml"),
+			Output: tempDir,
+		}
+	})
+
+	AfterEach(func() {
+		os.RemoveAll(tempDir)
+	})
+
+	Describe("Generate", func() {
+		It("creates a runner that calls cryptogen", func() {
+			cgRunner := cryptogen.Generate()
+			process := ifrit.Invoke(cgRunner)
+			Eventually(process.Ready()).Should(BeClosed())
+			Eventually(process.Wait()).Should(Receive(BeNil()))
+			Expect(cgRunner.ExitCode()).To(Equal(0))
+
+			Expect(filepath.Join(tempDir, "ordererOrganizations")).To(BeADirectory())
+			Expect(filepath.Join(tempDir, "peerOrganizations")).To(BeADirectory())
+		})
+
+		Context("when cryptogen fails", func() {
+			It("returns an error", func() {
+				cgRunner := cryptogen.Generate("bogus")
+				process := ifrit.Invoke(cgRunner)
+				Eventually(process.Wait()).Should(Receive(HaveOccurred()))
+			})
+		})
+	})
+
+})

integration/runner/cryptogen_test.go

@@ -7,6 +7,9 @@ SPDX-License-Identifier: Apache-2.0
 package runner_test
 
 import (
+	"encoding/json"
+
+	"github.com/hyperledger/fabric/integration/world"
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
 
@@ -17,3 +20,25 @@ func TestRunner(t *testing.T) {
 	RegisterFailHandler(Fail)
 	RunSpecs(t, "Runner Suite")
 }
+
+var (
+	components *world.Components
+)
+
+var _ = SynchronizedBeforeSuite(func() []byte {
+	components = &world.Components{}
+	components.Build()
+
+	payload, err := json.Marshal(components)
+	Expect(err).NotTo(HaveOccurred())
+
+	return payload
+}, func(payload []byte) {
+	err := json.Unmarshal(payload, &components)
+	Expect(err).NotTo(HaveOccurred())
+})
+
+var _ = SynchronizedAfterSuite(func() {
+}, func() {
+	components.Cleanup()
+})

integration/runner/runner_suite_test.go

@@ -0,0 +1,36 @@
+# Copyright IBM Corp. All Rights Reserved.
+#
+# SPDX-License-Identifier: Apache-2.0
+
+OrdererOrgs:
+  - Name: Orderer
+    Domain: example.com
+    CA:
+        Country: US
+        Province: California
+        Locality: San Francisco
+    Specs:
+      - Hostname: orderer
+PeerOrgs:
+  - Name: Org1
+    Domain: org1.example.com
+    EnableNodeOUs: true
+    CA:
+        Country: US
+        Province: California
+        Locality: San Francisco
+    Template:
+      Count: 2
+    Users:
+      Count: 1
+  - Name: Org2
+    Domain: org2.example.com
+    EnableNodeOUs: true
+    CA:
+        Country: US
+        Province: California
+        Locality: San Francisco
+    Template:
+      Count: 2
+    Users:
+      Count: 1

integration/runner/testdata/cryptogen-config.yaml

@@ -0,0 +1,41 @@
+/*
+Copyright IBM Corp All Rights Reserved.
+
+SPDX-License-Identifier: Apache-2.0
+*/
+
+package world
+
+import (
+	"os"
+
+	"github.com/hyperledger/fabric/integration/runner"
+	. "github.com/onsi/gomega"
+	"github.com/onsi/gomega/gexec"
+)
+
+type Components struct {
+	Paths map[string]string
+}
+
+func (c *Components) Build() {
+	if c.Paths == nil {
+		c.Paths = map[string]string{}
+	}
+	cryptogen, err := gexec.Build("github.com/hyperledger/fabric/common/tools/cryptogen")
+	Expect(err).NotTo(HaveOccurred())
+	c.Paths["cryptogen"] = cryptogen
+}
+
+func (c *Components) Cleanup() {
+	for _, path := range c.Paths {
+		err := os.Remove(path)
+		Expect(err).NotTo(HaveOccurred())
+	}
+}
+
+func (c *Components) Cryptogen() *runner.Cryptogen {
+	return &runner.Cryptogen{
+		Path: c.Paths["cryptogen"],
+	}
+}