[FAB-4630] SDK Go -Upgrade to support 1.0.0 beta

Change-Id: If0d3ea8a5de4fb72f7d1cd1300f929d5d03c241f
Signed-off-by: Firas Qutishat <firas.qutishat@securekey.com>

Author: Firas Qutishat

.gitignore

@@ -6,4 +6,4 @@ debug.test
 
 
 # Files auto-generated by docker-compose
-test/fixtures/tls/fabricca/server/org1.example.com-cert.pem
+test/fixtures/tls/fabricca/server/*.pem

Makefile

@@ -58,6 +58,6 @@ integration-test: clean depend
 integration-tests: integration-test
 
 clean:
-	rm -Rf /tmp/enroll_user /tmp/keystore /tmp/keyvaluestore
+	rm -Rf /tmp/enroll_user /tmp/msp /tmp/keyvaluestore
 	rm -f integration-report.xml report.xml
 	cd test/fixtures && docker-compose down

README.md

@@ -38,8 +38,8 @@ repository.
 ### Compatibility
 
 This client SDK was last tested and found to be compatible with the following Hyperledger Fabric commit levels:
-- fabric: v1.0.0-alpha2
-- fabric-ca: v1.0.0-alpha2
+- fabric: v1.0.0-beta
+- fabric-ca: v1.0.0-beta
 
 ### Running the test suite
 
@@ -135,14 +135,14 @@ Alternatively you can build and run Fabric on your own box using the following c
 cd $GOPATH/src/github.com/hyperledger/
 git clone https://github.com/hyperledger/fabric
 cd $GOPATH/src/github.com/hyperledger/fabric/
-git checkout v1.0.0-alpha2
+git checkout v1.0.0-beta
 make docker
 
 # Build fabric-ca:
 cd $GOPATH/src/github.com/hyperledger/
 git clone https://github.com/hyperledger/fabric-ca
 cd $GOPATH/src/github.com/hyperledger/fabric-ca/
-git checkout v1.0.0-alpha2
+git checkout v1.0.0-beta
 make docker
 
 # Start fabric - latest-env.sh overrides the default docker tags in .env

config/config.go

@@ -26,6 +26,7 @@ import (
 	"fmt"
 	"io/ioutil"
 	"os"
+	"path"
 	"strconv"
 	"strings"
 
@@ -253,7 +254,17 @@ func GetFabricCAName() string {
 
 // GetKeyStorePath ...
 func GetKeyStorePath() string {
-	return myViper.GetString("client.keystore.path")
+	return path.Join(GetFabricCAHomeDir(), GetFabricCAMspDir(), "keystore")
+}
+
+// GetFabricCAHomeDir ...
+func GetFabricCAHomeDir() string {
+	return myViper.GetString("client.fabricCA.homeDir")
+}
+
+// GetFabricCAMspDir ...
+func GetFabricCAMspDir() string {
+	return myViper.GetString("client.fabricCA.mspDir")
 }
 
 // GetCryptoConfigPath ...

fabric-ca-client/fabricca.go

@@ -117,7 +117,8 @@ func NewFabricCAClient() (Services, error) {
 	c.Config.TLS.Enabled = config.GetFabricCATLSEnabledFlag()
 	fabricCAClient := &services{fabricCAClient: c}
 	logger.Infof("Constructed fabricCAClient instance: %v", fabricCAClient)
-
+	c.HomeDir = config.GetFabricCAHomeDir()
+	c.Config.MSPDir = config.GetFabricCAMspDir()
 	c.Config.CSP = config.GetCSPConfig()
 
 	err := c.Init()

fabric-client/chain.go

@@ -1599,11 +1599,11 @@ func buildChaincodePolicy(mspid string) (*common.SignaturePolicyEnvelope, error)
 
 	// construct 'one of one' policy
 	oneOfone := &common.SignaturePolicy{Type: &common.SignaturePolicy_NOutOf_{NOutOf: &common.SignaturePolicy_NOutOf{
-		N: 1, Policies: []*common.SignaturePolicy{signedBy}}}}
+		N: 1, Rules: []*common.SignaturePolicy{signedBy}}}}
 
 	p := &common.SignaturePolicyEnvelope{
 		Version:    0,
-		Policy:     oneOfone,
+		Rule:       oneOfone,
 		Identities: []*mspprotos.MSPPrincipal{onePrn},
 	}
 	return p, nil
@@ -1815,11 +1815,11 @@ func loadPolicy(configItems *configItems, versionsPolicy *common.ConfigPolicy, k
 	switch policyType {
 	case common.Policy_SIGNATURE:
 		sigPolicyEnv := &common.SignaturePolicyEnvelope{}
-		err := proto.Unmarshal(policy.Policy, sigPolicyEnv)
+		err := proto.Unmarshal(policy.Value, sigPolicyEnv)
 		if err != nil {
 			return fmt.Errorf("Unable to unmarshal SignaturePolicyEnvelope from config policy: %v", err)
 		}
-		logger.Debugf("loadConfigPolicy - %s - policy SIGNATURE :: %v", groupName, sigPolicyEnv.Policy)
+		logger.Debugf("loadConfigPolicy - %s - policy SIGNATURE :: %v", groupName, sigPolicyEnv.Rule)
 		// TODO: Do something with this value
 		break
 
@@ -1830,7 +1830,7 @@ func loadPolicy(configItems *configItems, versionsPolicy *common.ConfigPolicy, k
 
 	case common.Policy_IMPLICIT_META:
 		implicitMetaPolicy := &common.ImplicitMetaPolicy{}
-		err := proto.Unmarshal(policy.Policy, implicitMetaPolicy)
+		err := proto.Unmarshal(policy.Value, implicitMetaPolicy)
 		if err != nil {
 			return fmt.Errorf("Unable to unmarshal ImplicitMetaPolicy from config policy: %v", err)
 		}

fabric-client/mockdata.go

@@ -280,8 +280,8 @@ func (b *MockConfigGroupBuilder) buildSignatureConfigPolicy() *common.ConfigPoli
 
 func (b *MockConfigGroupBuilder) buildSignaturePolicy() *common.Policy {
 	return &common.Policy{
-		Type:   int32(common.Policy_SIGNATURE),
-		Policy: MarshalOrPanic(b.buildSignedBySignaturePolicy()),
+		Type:  int32(common.Policy_SIGNATURE),
+		Value: MarshalOrPanic(b.buildSignedBySignaturePolicy()),
 	}
 }
 

fabric-client/mockendorserserver.go

@@ -23,7 +23,9 @@ import (
 	"github.com/golang/protobuf/proto"
 	"golang.org/x/net/context"
 
-	"github.com/hyperledger/fabric/core/ledger/kvledger/txmgmt/rwset"
+	rwsetutil "github.com/hyperledger/fabric/core/ledger/kvledger/txmgmt/rwsetutil"
+	kvrwset "github.com/hyperledger/fabric/protos/ledger/rwset/kvrwset"
+
 	pb "github.com/hyperledger/fabric/protos/peer"
 )
 
@@ -53,16 +55,17 @@ func (m *MockEndorserServer) createProposalResponsePayload() []byte {
 
 	prp := &pb.ProposalResponsePayload{}
 	ccAction := &pb.ChaincodeAction{}
-	var nsReadWriteSet []*rwset.NsReadWriteSet
-	var kvWrite []*rwset.KVWrite
+	txRwSet := &rwsetutil.TxRwSet{}
+
 	if m.AddkvWrite {
-		kvWrite = append(kvWrite, &rwset.KVWrite{Key: "write", Value: []byte("value")})
-	} else {
-		kvWrite = nil
+		txRwSet.NsRwSets = []*rwsetutil.NsRwSet{
+			&rwsetutil.NsRwSet{NameSpace: "ns1", KvRwSet: &kvrwset.KVRWSet{
+				Reads:  []*kvrwset.KVRead{&kvrwset.KVRead{Key: "key1", Version: &kvrwset.Version{BlockNum: 1, TxNum: 1}}},
+				Writes: []*kvrwset.KVWrite{&kvrwset.KVWrite{Key: "key2", IsDelete: false, Value: []byte("value2")}},
+			}}}
 	}
-	nsReadWriteSet = append(nsReadWriteSet, &rwset.NsReadWriteSet{Writes: kvWrite})
-	txRWSet := &rwset.TxReadWriteSet{NsRWs: nsReadWriteSet}
-	txRWSetBytes, err := txRWSet.Marshal()
+
+	txRWSetBytes, err := txRwSet.ToProtoBytes()
 	if err != nil {
 		return nil
 	}

test/fixtures/.env

@@ -21,11 +21,11 @@
 # Fabric fixtures. The images and tags can be overriden using environment
 # variables. See docker compose documentation.
 
-FABRIC_CA_FIXTURE_TAG=x86_64-1.0.0-alpha2
-FABRIC_ORDERER_FIXTURE_TAG=x86_64-1.0.0-alpha2
-FABRIC_PEER_FIXTURE_TAG=x86_64-1.0.0-alpha2
-FABRIC_COUCHDB_FIXTURE_TAG=x86_64-1.0.0-alpha2
-FABRIC_BUILDER_FIXTURE_TAG=x86_64-1.0.0-alpha2
+FABRIC_CA_FIXTURE_TAG=x86_64-1.0.0-beta
+FABRIC_ORDERER_FIXTURE_TAG=x86_64-1.0.0-beta
+FABRIC_PEER_FIXTURE_TAG=x86_64-1.0.0-beta
+FABRIC_COUCHDB_FIXTURE_TAG=x86_64-1.0.0-beta
+FABRIC_BUILDER_FIXTURE_TAG=x86_64-1.0.0-beta
 
 FABRIC_CA_FIXTURE_IMAGE=hyperledger/fabric-ca
 FABRIC_ORDERER_FIXTURE_IMAGE=hyperledger/fabric-orderer

test/fixtures/config/config_test.yaml

@@ -48,15 +48,14 @@ client:
   tlsEnabled: true
   id: "Org1MSP"
   name: "ca-org1"
+  homeDir: "/tmp/"
+  mspDir: "msp"
   serverURL: "https://localhost:7054"
   certfiles :
     - "$GOPATH/src/github.com/hyperledger/fabric-sdk-go/test/fixtures/tls/fabricca/ca/ca_root.pem"
   client:
    keyfile: "$GOPATH/src/github.com/hyperledger/fabric-sdk-go/test/fixtures/tls/fabricca/client/client_client1-key.pem"
    certfile: "$GOPATH/src/github.com/hyperledger/fabric-sdk-go/test/fixtures/tls/fabricca/client/client_client1.pem"
 
- keystore:
-  path: "/tmp/keystore"
-
  cryptoconfig:
   path: "$GOPATH/src/github.com/hyperledger/fabric-sdk-go/test/fixtures/channel/crypto-config"