Categorise chaincode operations by peer and gateway

Previous implementation was standalone functions, with all requiring both a gRPC
connection and a client signing identity. This required:

- An underisably large number of prameters.
- Unwritten conventions on parameter ordering.
- Documentation comments to highlight when the connection should be to a
  specific peer or to an organization gateway.
- Duplication of arguments across multiple functions for calling code driving
  the chaincode lifecycle.

This implementation defines a Peer and Gateway struct that hold a gRPC
connection and a client identity. Each of these types defines methods
appropriate to their logical role to:

- Avoid the need to provide gRPC connection and client identity arguments on
  every call.
- Provide calling code with logical context for what they are interacting with.
- Allow IDE code completion to suggest appropriate methods for the connection type.

For example, this pseudo-code flow:

    chaincode.Install(ctx, peerConnection, id, chaincodePackage)
    chaincode.Approve(ctx, gatewayConnection, id, chaincodeDefinition)
    chaincode.Commit(ctx, gatewayConnection, id, chaincodeDefinition)

becomes:

    peer.Install(ctx, chaincodePackage)
    gateway.Approve(ctx, chaincodeDefinition)
    gateway.Commit(ctx, chaincodeDefinition)

Signed-off-by: Mark S. Lewis <Mark.S.Lewis@outlook.com>

Makefile

@@ -11,7 +11,7 @@ unit-test: unit-test-go unit-test-node
 .PHONY: unit-test-go
 unit-test-go:
 	cd '$(base_dir)' && \
-		go test -coverprofile='$(base_dir)/coverage.out' '$(go_dir)/...'
+		go test -race -coverprofile='$(base_dir)/coverage.out' '$(go_dir)/...'
 
 .PHONY: unit-test-node
 unit-test-node:

pkg/chaincode/approve_test.go

@@ -3,11 +3,12 @@ Copyright IBM Corp. All Rights Reserved.
 SPDX-License-Identifier: Apache-2.0
 */
 
-package chaincode
+package chaincode_test
 
 import (
 	"context"
 
+	"github.com/hyperledger/fabric-admin-sdk/pkg/chaincode"
 	"github.com/hyperledger/fabric-protos-go-apiv2/common"
 	"github.com/hyperledger/fabric-protos-go-apiv2/gateway"
 	"github.com/hyperledger/fabric-protos-go-apiv2/peer"
@@ -85,11 +86,11 @@ func AssertEqualStatus(expected error, actual error) {
 
 var _ = Describe("Approve", func() {
 	var channelName string
-	var chaincodeDefinition *Definition
+	var chaincodeDefinition *chaincode.Definition
 
 	BeforeEach(func() {
 		channelName = "CHANNEL"
-		chaincodeDefinition = &Definition{
+		chaincodeDefinition = &chaincode.Definition{
 			Name:        "CHAINCODE",
 			Version:     "1.0",
 			Sequence:    1,
@@ -125,11 +126,12 @@ var _ = Describe("Approve", func() {
 			})
 
 		mockSigner := NewMockSigner(controller, "", nil, nil)
+		gateway := chaincode.NewGateway(mockConnection, mockSigner)
 
 		ctx, cancel := context.WithCancel(specCtx)
 		cancel()
 
-		err := Approve(ctx, mockConnection, mockSigner, chaincodeDefinition)
+		err := gateway.Approve(ctx, chaincodeDefinition)
 
 		Expect(endorseCtxErr).To(BeIdenticalTo(context.Canceled), "endorse context error")
 		Expect(submitCtxErr).To(BeIdenticalTo(context.Canceled), "submit context error")
@@ -148,8 +150,9 @@ var _ = Describe("Approve", func() {
 			Return(expectedErr)
 
 		mockSigner := NewMockSigner(controller, "", nil, nil)
+		gateway := chaincode.NewGateway(mockConnection, mockSigner)
 
-		err := Approve(specCtx, mockConnection, mockSigner, chaincodeDefinition)
+		err := gateway.Approve(specCtx, chaincodeDefinition)
 
 		Expect(err).To(MatchError(expectedErr))
 		AssertEqualStatus(expectedErr, err)
@@ -177,8 +180,9 @@ var _ = Describe("Approve", func() {
 			Return(expectedErr)
 
 		mockSigner := NewMockSigner(controller, "", nil, nil)
+		gateway := chaincode.NewGateway(mockConnection, mockSigner)
 
-		err := Approve(specCtx, mockConnection, mockSigner, chaincodeDefinition)
+		err := gateway.Approve(specCtx, chaincodeDefinition)
 
 		Expect(err).To(MatchError(expectedErr))
 		AssertEqualStatus(expectedErr, err)
@@ -201,15 +205,16 @@ var _ = Describe("Approve", func() {
 			Return(expectedErr)
 
 		mockSigner := NewMockSigner(controller, "", nil, nil)
+		gateway := chaincode.NewGateway(mockConnection, mockSigner)
 
-		err := Approve(specCtx, mockConnection, mockSigner, chaincodeDefinition)
+		err := gateway.Approve(specCtx, chaincodeDefinition)
 
 		Expect(err).To(MatchError(expectedErr))
 		AssertEqualStatus(expectedErr, err)
 	})
 
 	DescribeTable("Proposal content",
-		func(specCtx SpecContext, newInput func(*Definition) *Definition, newExpected func(*lifecycle.ApproveChaincodeDefinitionForMyOrgArgs) *lifecycle.ApproveChaincodeDefinitionForMyOrgArgs) {
+		func(specCtx SpecContext, newInput func(*chaincode.Definition) *chaincode.Definition, newExpected func(*lifecycle.ApproveChaincodeDefinitionForMyOrgArgs) *lifecycle.ApproveChaincodeDefinitionForMyOrgArgs) {
 			input := newInput(chaincodeDefinition)
 			expected := newExpected(&lifecycle.ApproveChaincodeDefinitionForMyOrgArgs{
 				Name:     chaincodeDefinition.Name,
@@ -242,8 +247,9 @@ var _ = Describe("Approve", func() {
 				})
 
 			mockSigner := NewMockSigner(controller, "", nil, nil)
+			gateway := chaincode.NewGateway(mockConnection, mockSigner)
 
-			err := Approve(specCtx, mockConnection, mockSigner, input)
+			err := gateway.Approve(specCtx, input)
 			Expect(err).NotTo(HaveOccurred())
 
 			invocationSpec := AssertUnmarshalInvocationSpec(endorseRequest.GetProposedTransaction())
@@ -257,7 +263,7 @@ var _ = Describe("Approve", func() {
 		},
 		Entry(
 			"Proposal includes specified package ID",
-			func(in *Definition) *Definition {
+			func(in *chaincode.Definition) *chaincode.Definition {
 				in.PackageID = "PACKAGE_ID"
 				return in
 			},
@@ -272,7 +278,7 @@ var _ = Describe("Approve", func() {
 		),
 		Entry(
 			"Proposal includes unspecified chaincode source with no package ID specified",
-			func(in *Definition) *Definition {
+			func(in *chaincode.Definition) *chaincode.Definition {
 				return in
 			},
 			func(in *lifecycle.ApproveChaincodeDefinitionForMyOrgArgs) *lifecycle.ApproveChaincodeDefinitionForMyOrgArgs {

pkg/chaincode/chaincodeCCAAS_test.go

@@ -1,4 +1,4 @@
-package chaincode
+package chaincode_test
 
 import (
 	"archive/tar"
@@ -9,22 +9,23 @@ import (
 	"path/filepath"
 	"strings"
 
+	"github.com/hyperledger/fabric-admin-sdk/pkg/chaincode"
 	. "github.com/onsi/ginkgo/v2"
 	. "github.com/onsi/gomega"
 )
 
 var _ = Describe("Package", func() {
 	It("CCaaS", func() {
-		dummyConnection := Connection{
+		dummyConnection := chaincode.Connection{
 			Address:     "127.0.0.1:8080",
 			DialTimeout: "10s",
 			TLSRequired: false,
 		}
-		dummyMeta := Metadata{
+		dummyMeta := chaincode.Metadata{
 			Type:  "ccaas",
 			Label: "basic-asset",
 		}
-		err := PackageCCAAS(dummyConnection, dummyMeta, tmpDir, "chaincode.tar.gz")
+		err := chaincode.PackageCCAAS(dummyConnection, dummyMeta, tmpDir, "chaincode.tar.gz")
 		Expect(err).NotTo(HaveOccurred())
 		// so far no plan to verify the file
 		file, err := os.Open(tmpDir + "/chaincode.tar.gz")

pkg/chaincode/chaincode_suite_test.go

@@ -1,4 +1,4 @@
-package chaincode
+package chaincode_test
 
 import (
 	"testing"

pkg/chaincode/checkcommitreadiness_test.go

@@ -3,11 +3,12 @@ Copyright IBM Corp. All Rights Reserved.
 SPDX-License-Identifier: Apache-2.0
 */
 
-package chaincode
+package chaincode_test
 
 import (
 	"context"
 
+	"github.com/hyperledger/fabric-admin-sdk/pkg/chaincode"
 	"github.com/hyperledger/fabric-protos-go-apiv2/gateway"
 	"github.com/hyperledger/fabric-protos-go-apiv2/peer/lifecycle"
 	. "github.com/onsi/ginkgo/v2"
@@ -21,11 +22,11 @@ import (
 
 var _ = Describe("CheckCommitReadiness", func() {
 	var channelName string
-	var chaincodeDefinition *Definition
+	var chaincodeDefinition *chaincode.Definition
 
 	BeforeEach(func() {
 		channelName = "mockchannel"
-		chaincodeDefinition = &Definition{
+		chaincodeDefinition = &chaincode.Definition{
 			Name:        "CHAINCODE",
 			Version:     "1.0",
 			Sequence:    1,
@@ -48,11 +49,12 @@ var _ = Describe("CheckCommitReadiness", func() {
 			})
 
 		mockSigner := NewMockSigner(controller, "", nil, nil)
+		gateway := chaincode.NewGateway(mockConnection, mockSigner)
 
 		ctx, cancel := context.WithCancel(specCtx)
 		cancel()
 
-		_, _ = CheckCommitReadiness(ctx, mockConnection, mockSigner, chaincodeDefinition)
+		_, _ = gateway.CheckCommitReadiness(ctx, chaincodeDefinition)
 
 		Expect(evaluateCtxErr).To(BeIdenticalTo(context.Canceled))
 	})
@@ -69,8 +71,9 @@ var _ = Describe("CheckCommitReadiness", func() {
 			Return(expectedErr)
 
 		mockSigner := NewMockSigner(controller, "", nil, nil)
+		gateway := chaincode.NewGateway(mockConnection, mockSigner)
 
-		_, err := CheckCommitReadiness(specCtx, mockConnection, mockSigner, chaincodeDefinition)
+		_, err := gateway.CheckCommitReadiness(specCtx, chaincodeDefinition)
 
 		Expect(err).To(MatchError(expectedErr))
 		AssertEqualStatus(expectedErr, err)
@@ -96,8 +99,9 @@ var _ = Describe("CheckCommitReadiness", func() {
 			}).
 			Times(1)
 		mockSigner := NewMockSigner(controller, "", nil, nil)
+		gateway := chaincode.NewGateway(mockConnection, mockSigner)
 
-		_, err := CheckCommitReadiness(specCtx, mockConnection, mockSigner, chaincodeDefinition)
+		_, err := gateway.CheckCommitReadiness(specCtx, chaincodeDefinition)
 		Expect(err).NotTo(HaveOccurred())
 
 		invocationSpec := AssertUnmarshalInvocationSpec(evaluateRequest.GetProposedTransaction())