Declare ledger dependency for coll membership info

This CR enables ledger to take an external dependency that ledger
can use for determining whether the peer is a member of
a given collection on a channel.

The intended usage of this dependency is to detemine a situation
when the peer becomes a memeber of a new collection.

FAB-11436 #done

Change-Id: Id5d342ea12974aa16d84aaa6ae99db5e04716877
Signed-off-by: manish <manish.sethi@gmail.com>
Signed-off-by: nirro <nirro@il.ibm.com>

Author: manish-sethi

core/common/privdata/membershipinfo.go

@@ -10,24 +10,20 @@ import (
 	"github.com/hyperledger/fabric/protos/common"
 )
 
-// MembershipInfoProvider interface defines an interface to check whether a peer is eligible to a collection or not
-type MembershipInfoProvider interface {
-	// AmMemberOf checks whether the current peer is a member of the given collection config
-	AmMemberOf(collectionPolicyConfig *common.CollectionPolicyConfig) (bool, error)
-}
-
-type membershipProvider struct {
+// MembershipProvider can be used to check whether a peer is eligible to a collection or not
+type MembershipProvider struct {
 	selfSignedData common.SignedData
 	cf             CollectionFilter
-	channelName    string
 }
 
-func NewMembershipInfoProvider(channelName string, selfSignedData common.SignedData, filter CollectionFilter) MembershipInfoProvider {
-	return &membershipProvider{channelName: channelName, selfSignedData: selfSignedData, cf: filter}
+// NewMembershipInfoProvider returns MembershipProvider
+func NewMembershipInfoProvider(selfSignedData common.SignedData, filter CollectionFilter) *MembershipProvider {
+	return &MembershipProvider{selfSignedData: selfSignedData, cf: filter}
 }
 
-func (m *membershipProvider) AmMemberOf(collectionPolicyConfig *common.CollectionPolicyConfig) (bool, error) {
-	filt, err := m.cf.AccessFilter(m.channelName, collectionPolicyConfig)
+// AmMemberOf checks whether the current peer is a member of the given collection config
+func (m *MembershipProvider) AmMemberOf(channelName string, collectionPolicyConfig *common.CollectionPolicyConfig) (bool, error) {
+	filt, err := m.cf.AccessFilter(channelName, collectionPolicyConfig)
 	if err != nil {
 		return false, err
 	}

core/common/privdata/membershipinfo_test.go

@@ -25,18 +25,18 @@ func TestMembershipInfoProvider(t *testing.T) {
 	collectionStore := NewSimpleCollectionStore(&mockStoreSupport{})
 
 	// verify membership provider returns true
-	membershipProvider := NewMembershipInfoProvider("test1", peerSelfSignedData, collectionStore)
-	res, err := membershipProvider.AmMemberOf(getAccessPolicy([]string{"peer0", "peer1"}))
+	membershipProvider := NewMembershipInfoProvider(peerSelfSignedData, collectionStore)
+	res, err := membershipProvider.AmMemberOf("test1", getAccessPolicy([]string{"peer0", "peer1"}))
 	assert.True(t, res)
 	assert.Nil(t, err)
 
 	// verify membership provider returns false
-	res, err = membershipProvider.AmMemberOf(getAccessPolicy([]string{"peer2", "peer3"}))
+	res, err = membershipProvider.AmMemberOf("test1", getAccessPolicy([]string{"peer2", "peer3"}))
 	assert.False(t, res)
 	assert.Nil(t, err)
 
 	// verify membership provider returns nil and error
-	res, err = membershipProvider.AmMemberOf(nil)
+	res, err = membershipProvider.AmMemberOf("test1", nil)
 	assert.False(t, res)
 	assert.Error(t, err)
 	assert.Equal(t, "Collection config policy is nil", err.Error())

core/ledger/ledger_interface.go

@@ -19,6 +19,7 @@ import (
 type Initializer struct {
 	StateListeners                []StateListener
 	DeployedChaincodeInfoProvider DeployedChaincodeInfoProvider
+	MembershipInfoProvider        MembershipInfoProvider
 }
 
 // PeerLedgerProvider provides handle to ledger instances
@@ -414,4 +415,11 @@ type ChaincodeLifecycleDetails struct {
 	CollectionsRemoved []string // names of the collections that are removed
 }
 
+// MembershipInfoProvider is a dependency that is used by ledger to determine whether the current peer is
+// a member of a collection. Gossip module is expected to provide the dependency to ledger
+type MembershipInfoProvider interface {
+	// AmMemberOf checks whether the current peer is a member of the given collection
+	AmMemberOf(channelName string, collectionPolicyConfig *common.CollectionPolicyConfig) (bool, error)
+}
+
 //go:generate counterfeiter -o mock/deployed_ccinfo_provider.go -fake-name DeployedChaincodeInfoProvider . DeployedChaincodeInfoProvider

core/ledger/ledgermgmt/ledger_mgmt.go

@@ -39,6 +39,7 @@ type Initializer struct {
 	CustomTxProcessors            customtx.Processors
 	PlatformRegistry              *platforms.Registry
 	DeployedChaincodeInfoProvider ledger.DeployedChaincodeInfoProvider
+	MembershipInfoProvider        ledger.MembershipInfoProvider
 }
 
 // Initialize initializes ledgermgmt
@@ -64,6 +65,7 @@ func initialize(initializer *Initializer) {
 	provider.Initialize(&ledger.Initializer{
 		StateListeners:                finalStateListeners,
 		DeployedChaincodeInfoProvider: initializer.DeployedChaincodeInfoProvider,
+		MembershipInfoProvider:        initializer.MembershipInfoProvider,
 	})
 
 	ledgerProvider = provider