[FAB-6574] Integrate simpleCollectionStore for gossip

This change sets switches the implementation of the collection store
from the No-op collection store to the simple collection store.

Change-Id: I38e5e1d8c25ad260eb6077e3aee9ff8f4f9c3664
Signed-off-by: yacovm <yacovm@il.ibm.com>

Author: yacovm

core/common/privdata/collection.go

@@ -64,3 +64,22 @@ type CollectionStore interface {
 	// GetCollectionAccessPolicy retrieves a collection's access policy
 	RetrieveCollectionAccessPolicy(common.CollectionCriteria) (CollectionAccessPolicy, error)
 }
+
+const (
+	// Collecion-specific constants
+
+	// collectionSeparator is the separator used to build the KVS
+	// key storing the collections of a chaincode; note that we are
+	// using as separator a character which is illegal for either the
+	// name or the version of a chaincode so there cannot be any
+	// collisions when chosing the name
+	collectionSeparator = "~"
+	// collectionSuffix is the suffix of the KVS key storing the
+	// collections of a chaincode
+	collectionSuffix = "collection"
+)
+
+// BuildCollectionKVSKey returns the KVS key string for a chaincode, given its name and version
+func BuildCollectionKVSKey(ccname string) string {
+	return ccname + collectionSeparator + collectionSuffix
+}

core/peer/peer.go

@@ -12,8 +12,6 @@ import (
 	"runtime"
 	"sync"
 
-	"github.com/hyperledger/fabric/core/ledger/customtx"
-
 	"github.com/hyperledger/fabric/common/channelconfig"
 	cc "github.com/hyperledger/fabric/common/config"
 	"github.com/hyperledger/fabric/common/configtx"
@@ -33,6 +31,7 @@ import (
 	"github.com/hyperledger/fabric/core/committer/txvalidator"
 	"github.com/hyperledger/fabric/core/common/privdata"
 	"github.com/hyperledger/fabric/core/ledger"
+	"github.com/hyperledger/fabric/core/ledger/customtx"
 	"github.com/hyperledger/fabric/core/ledger/ledgermgmt"
 	"github.com/hyperledger/fabric/core/transientstore"
 	"github.com/hyperledger/fabric/gossip/api"
@@ -376,11 +375,14 @@ func createChain(cid string, ledger ledger.PeerLedger, cb *common.Block) error {
 	if err != nil {
 		return errors.Wrapf(err, "Failed opening transient store for %s", bundle.ConfigtxValidator().ChainID())
 	}
+	simpleCollectionStore := privdata.NewSimpleCollectionStore(&collectionSupport{
+		PeerLedger: ledger,
+	})
 	service.GetGossipService().InitializeChannel(bundle.ConfigtxValidator().ChainID(), ordererAddresses, service.Support{
 		Validator: validator,
 		Committer: c,
 		Store:     store,
-		Cs:        &privdata.NopCollectionStore{},
+		Cs:        simpleCollectionStore,
 	})
 
 	chains.Lock()
@@ -724,6 +726,22 @@ func GetPeerServer() comm.GRPCServer {
 	return peerServer
 }
 
+type collectionSupport struct {
+	ledger.PeerLedger
+}
+
+func (cs *collectionSupport) GetQueryExecutorForLedger(cid string) (ledger.QueryExecutor, error) {
+	return cs.NewQueryExecutor()
+}
+
+func (*collectionSupport) GetCollectionKVSKey(cc common.CollectionCriteria) string {
+	return privdata.BuildCollectionKVSKey(cc.Namespace)
+}
+
+func (*collectionSupport) GetIdentityDeserializer(chainID string) msp.IdentityDeserializer {
+	return mspmgmt.GetManagerForChain(chainID)
+}
+
 //
 //  Deliver service support structs for the peer
 //