refactor: use slices.Contains to simplify code

Signed-off-by: keeghcet <[email protected]>

Author: keeghcet

core/chaincode/platforms/util/writer.go

@@ -14,6 +14,7 @@ import (
 	"os"
 	"path"
 	"path/filepath"
+	"slices"
 	"strings"
 	"time"
 
@@ -37,10 +38,8 @@ func WriteFolderToTarPackage(tw *tar.Writer, srcPath string, excludeDirs []strin
 		}
 
 		if info.Mode().IsDir() {
-			for _, excluded := range append(excludeDirs, ".git") {
-				if info.Name() == excluded {
-					return filepath.SkipDir
-				}
+			if slices.Contains(append(excludeDirs, ".git"), info.Name()) {
+				return filepath.SkipDir
 			}
 			return nil
 		}

core/container/externalbuilder/externalbuilder.go

@@ -14,6 +14,7 @@ import (
 	"os/exec"
 	"path/filepath"
 	"regexp"
+	"slices"
 	"time"
 
 	"github.com/hyperledger/fabric-lib-go/common/flogging"
@@ -410,18 +411,9 @@ func (b *Builder) NewCommand(name string, args ...string) *exec.Cmd {
 
 func appendDefaultPropagateEnvironment(propagateEnvironment []string) []string {
 	for _, variable := range DefaultPropagateEnvironment {
-		if !contains(propagateEnvironment, variable) {
+		if !slices.Contains(propagateEnvironment, variable) {
 			propagateEnvironment = append(propagateEnvironment, variable)
 		}
 	}
 	return propagateEnvironment
 }
-
-func contains(propagateEnvironment []string, key string) bool {
-	for _, variable := range propagateEnvironment {
-		if key == variable {
-			return true
-		}
-	}
-	return false
-}

core/ledger/kvledger/coll_elg_notifier.go

@@ -129,11 +129,11 @@ func (n *collElgNotifier) elgEnabledCollNames(ledgerID string,
 
 // elgEnabled returns true if the peer is not eligible for a collection as per 'existingPolicy' and is eligible as per 'postCommitPolicy'
 func (n *collElgNotifier) elgEnabled(ledgerID string, existingPolicy, postCommitPolicy *peer.CollectionPolicyConfig) (bool, error) {
-	existingMember, err := n.membershipInfoProvider.AmMemberOf(ledgerID, existingPolicy)
-	if err != nil || existingMember {
-		return false, err
+	existingMember := n.membershipInfoProvider.AmMemberOf(ledgerID, existingPolicy)
+	if existingMember {
+		return false, nil
 	}
-	return n.membershipInfoProvider.AmMemberOf(ledgerID, postCommitPolicy)
+	return n.membershipInfoProvider.AmMemberOf(ledgerID, postCommitPolicy), nil
 }
 
 func extractPublicUpdates(stateUpdates ledger.StateUpdates) map[string][]*kvrwset.KVWrite {

core/ledger/kvledger/pause_resume_test.go

@@ -7,6 +7,7 @@ SPDX-License-Identifier: Apache-2.0
 package kvledger
 
 import (
+	"slices"
 	"testing"
 
 	"github.com/hyperledger/fabric-protos-go-apiv2/common"
@@ -115,7 +116,7 @@ func assertLedgerStatus(t *testing.T, provider *Provider, genesisBlocks []*commo
 	require.NoError(t, err)
 	require.Len(t, activeLedgerIDs, numLedgers-len(pausedLedgers))
 	for i := 0; i < numLedgers; i++ {
-		if !contains(pausedLedgers, i) {
+		if !slices.Contains(pausedLedgers, i) {
 			require.Contains(t, activeLedgerIDs, constructTestLedgerID(i))
 		}
 	}
@@ -124,19 +125,10 @@ func assertLedgerStatus(t *testing.T, provider *Provider, genesisBlocks []*commo
 		m, err := s.getLedgerMetadata(constructTestLedgerID(i))
 		require.NoError(t, err)
 		require.NotNil(t, m)
-		if contains(pausedLedgers, i) {
+		if slices.Contains(pausedLedgers, i) {
 			require.Equal(t, msgs.Status_INACTIVE, m.GetStatus())
 		} else {
 			require.Equal(t, msgs.Status_ACTIVE, m.GetStatus())
 		}
 	}
 }
-
-func contains(slice []int, val int) bool {
-	for _, item := range slice {
-		if item == val {
-			return true
-		}
-	}
-	return false
-}

core/ledger/kvledger/tests/env.go

@@ -10,6 +10,7 @@ import (
 	"fmt"
 	"os"
 	"path/filepath"
+	"slices"
 	"testing"
 	"time"
 
@@ -315,15 +316,10 @@ type membershipInfoProvider struct {
 	myOrgMSPID string
 }
 
-func (p *membershipInfoProvider) AmMemberOf(channelName string, collectionPolicyConfig *peer.CollectionPolicyConfig) (bool, error) {
+func (p *membershipInfoProvider) AmMemberOf(channelName string, collectionPolicyConfig *peer.CollectionPolicyConfig) bool {
 	members := convertFromMemberOrgsPolicy(collectionPolicyConfig)
 	fmt.Printf("members = %s\n", members)
-	for _, m := range members {
-		if m == p.myOrgMSPID {
-			return true, nil
-		}
-	}
-	return false, nil
+	return slices.Contains(members, p.myOrgMSPID)
 }
 
 func (p *membershipInfoProvider) MyImplicitCollectionName() string {

core/ledger/kvledger/txmgmt/statedb/commontests/test_common.go

@@ -8,6 +8,7 @@ package commontests
 
 import (
 	"fmt"
+	"slices"
 	"strings"
 	"testing"
 
@@ -1072,7 +1073,7 @@ func TestDataExportImport(
 	verifyExportImport := func(destDBName string, skipNamespaces stringset) {
 		fullScanItr, err := sourceDB.GetFullScanIterator(
 			func(ns string) bool {
-				return skipNamespaces.contains(ns)
+				return slices.Contains(skipNamespaces, ns)
 			},
 		)
 		require.NoError(t, err)
@@ -1162,19 +1163,10 @@ func CreateTestData(t *testing.T, db statedb.VersionedDB, ns string, numKeys int
 
 type stringset []string
 
-func (s stringset) contains(str string) bool {
-	for _, element := range s {
-		if element == str {
-			return true
-		}
-	}
-	return false
-}
-
 func (s stringset) minus(toMinus stringset) stringset {
 	var final stringset
 	for _, element := range s {
-		if toMinus.contains(element) {
+		if slices.Contains(toMinus, element) {
 			continue
 		}
 		final = append(final, element)

core/ledger/kvledger/txmgmt/statedb/statecouchdb/cache.go

@@ -9,6 +9,7 @@ package statecouchdb
 import (
 	"github.com/VictoriaMetrics/fastcache"
 	"google.golang.org/protobuf/proto"
+	"slices"
 )
 
 var keySep = []byte{0x00}
@@ -45,10 +46,8 @@ func newCache(usrCacheSizeMBs int, sysNamespaces []string) *cache {
 // Namespace can be of two types: system namespace (such as lscc) and user
 // namespace (all user's chaincode states).
 func (c *cache) enabled(namespace string) bool {
-	for _, ns := range c.sysNamespaces {
-		if namespace == ns {
-			return true
-		}
+	if slices.Contains(c.sysNamespaces, namespace) {
+		return true
 	}
 	return c.usrCache != nil
 }
@@ -152,10 +151,8 @@ func (c *cache) Reset() {
 }
 
 func (c *cache) getCache(namespace string) *fastcache.Cache {
-	for _, ns := range c.sysNamespaces {
-		if namespace == ns {
-			return c.sysCache
-		}
+	if slices.Contains(c.sysNamespaces, namespace) {
+		return c.sysCache
 	}
 	return c.usrCache
 }

core/ledger/ledger_interface.go

@@ -732,7 +732,7 @@ type ChaincodeLifecycleDetails struct {
 // 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 *peer.CollectionPolicyConfig) (bool, error)
+	AmMemberOf(channelName string, collectionPolicyConfig *peer.CollectionPolicyConfig) bool
 	// MyImplicitCollectionName returns the name of the implicit collection for the current peer
 	MyImplicitCollectionName() string
 }

core/ledger/pvtdatastorage/snapshot_data_importer.go

@@ -185,10 +185,7 @@ func (i *eligibilityAndBTLCache) loadDataFor(namespace string) error {
 
 		for _, collection := range collections {
 			staticCollection := collection.GetStaticCollectionConfig()
-			eligible, err := i.membershipProvider.AmMemberOf(i.ledgerID, staticCollection.MemberOrgsPolicy)
-			if err != nil {
-				return err
-			}
+			eligible := i.membershipProvider.AmMemberOf(i.ledgerID, staticCollection.MemberOrgsPolicy)
 			key := nsColl{
 				ns:   namespace,
 				coll: staticCollection.Name,

core/transientstore/store.go

@@ -8,6 +8,7 @@ package transientstore
 
 import (
 	"path/filepath"
+	"slices"
 
 	"github.com/hyperledger/fabric-lib-go/common/flogging"
 	"github.com/hyperledger/fabric-protos-go-apiv2/ledger/rwset"
@@ -156,11 +157,9 @@ func (provider *storeProvider) markStorageForDelete(ledgerID string) error {
 	}
 
 	// don't update if the storage is already marked for deletion.
-	for _, l := range marked.List {
-		if ledgerID == l {
-			logger.Infow("Transient storage was already marked for delete", "ledgerID", ledgerID)
-			return nil
-		}
+	if slices.Contains(marked.List, ledgerID) {
+		logger.Infow("Transient storage was already marked for delete", "ledgerID", ledgerID)
+		return nil
 	}
 
 	marked.List = append(marked.List, ledgerID)