Skip to content

Commit 7f8478e

Browse files
committed
refactor: use slices.Contains to simplify code
Signed-off-by: keeghcet <[email protected]>
1 parent d8f6bbb commit 7f8478e

File tree

7 files changed

+21
-39
lines changed

7 files changed

+21
-39
lines changed

core/chaincode/platforms/util/writer.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@ import (
1414
"os"
1515
"path"
1616
"path/filepath"
17+
"slices"
1718
"strings"
1819
"time"
1920

@@ -37,10 +38,8 @@ func WriteFolderToTarPackage(tw *tar.Writer, srcPath string, excludeDirs []strin
3738
}
3839

3940
if info.Mode().IsDir() {
40-
for _, excluded := range append(excludeDirs, ".git") {
41-
if info.Name() == excluded {
42-
return filepath.SkipDir
43-
}
41+
if slices.Contains(append(excludeDirs, ".git"), info.Name()) {
42+
return filepath.SkipDir
4443
}
4544
return nil
4645
}

core/container/externalbuilder/externalbuilder.go

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@ import (
1414
"os/exec"
1515
"path/filepath"
1616
"regexp"
17+
"slices"
1718
"time"
1819

1920
"github.com/hyperledger/fabric-lib-go/common/flogging"
@@ -418,10 +419,5 @@ func appendDefaultPropagateEnvironment(propagateEnvironment []string) []string {
418419
}
419420

420421
func contains(propagateEnvironment []string, key string) bool {
421-
for _, variable := range propagateEnvironment {
422-
if key == variable {
423-
return true
424-
}
425-
}
426-
return false
422+
return slices.Contains(propagateEnvironment, key)
427423
}

core/ledger/kvledger/pause_resume_test.go

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ SPDX-License-Identifier: Apache-2.0
77
package kvledger
88

99
import (
10+
"slices"
1011
"testing"
1112

1213
"github.com/hyperledger/fabric-protos-go-apiv2/common"
@@ -133,10 +134,5 @@ func assertLedgerStatus(t *testing.T, provider *Provider, genesisBlocks []*commo
133134
}
134135

135136
func contains(slice []int, val int) bool {
136-
for _, item := range slice {
137-
if item == val {
138-
return true
139-
}
140-
}
141-
return false
137+
return slices.Contains(slice, val)
142138
}

core/ledger/kvledger/tests/env.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ import (
1010
"fmt"
1111
"os"
1212
"path/filepath"
13+
"slices"
1314
"testing"
1415
"time"
1516

@@ -318,10 +319,8 @@ type membershipInfoProvider struct {
318319
func (p *membershipInfoProvider) AmMemberOf(channelName string, collectionPolicyConfig *peer.CollectionPolicyConfig) (bool, error) {
319320
members := convertFromMemberOrgsPolicy(collectionPolicyConfig)
320321
fmt.Printf("members = %s\n", members)
321-
for _, m := range members {
322-
if m == p.myOrgMSPID {
323-
return true, nil
324-
}
322+
if slices.Contains(members, p.myOrgMSPID) {
323+
return true, nil
325324
}
326325
return false, nil
327326
}

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

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ package commontests
88

99
import (
1010
"fmt"
11+
"slices"
1112
"strings"
1213
"testing"
1314

@@ -1163,12 +1164,7 @@ func CreateTestData(t *testing.T, db statedb.VersionedDB, ns string, numKeys int
11631164
type stringset []string
11641165

11651166
func (s stringset) contains(str string) bool {
1166-
for _, element := range s {
1167-
if element == str {
1168-
return true
1169-
}
1170-
}
1171-
return false
1167+
return slices.Contains(s, str)
11721168
}
11731169

11741170
func (s stringset) minus(toMinus stringset) stringset {

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

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ package statecouchdb
99
import (
1010
"github.com/VictoriaMetrics/fastcache"
1111
"google.golang.org/protobuf/proto"
12+
"slices"
1213
)
1314

1415
var keySep = []byte{0x00}
@@ -45,10 +46,8 @@ func newCache(usrCacheSizeMBs int, sysNamespaces []string) *cache {
4546
// Namespace can be of two types: system namespace (such as lscc) and user
4647
// namespace (all user's chaincode states).
4748
func (c *cache) enabled(namespace string) bool {
48-
for _, ns := range c.sysNamespaces {
49-
if namespace == ns {
50-
return true
51-
}
49+
if slices.Contains(c.sysNamespaces, namespace) {
50+
return true
5251
}
5352
return c.usrCache != nil
5453
}
@@ -152,10 +151,8 @@ func (c *cache) Reset() {
152151
}
153152

154153
func (c *cache) getCache(namespace string) *fastcache.Cache {
155-
for _, ns := range c.sysNamespaces {
156-
if namespace == ns {
157-
return c.sysCache
158-
}
154+
if slices.Contains(c.sysNamespaces, namespace) {
155+
return c.sysCache
159156
}
160157
return c.usrCache
161158
}

core/transientstore/store.go

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ package transientstore
88

99
import (
1010
"path/filepath"
11+
"slices"
1112

1213
"github.com/hyperledger/fabric-lib-go/common/flogging"
1314
"github.com/hyperledger/fabric-protos-go-apiv2/ledger/rwset"
@@ -156,11 +157,9 @@ func (provider *storeProvider) markStorageForDelete(ledgerID string) error {
156157
}
157158

158159
// don't update if the storage is already marked for deletion.
159-
for _, l := range marked.List {
160-
if ledgerID == l {
161-
logger.Infow("Transient storage was already marked for delete", "ledgerID", ledgerID)
162-
return nil
163-
}
160+
if slices.Contains(marked.List, ledgerID) {
161+
logger.Infow("Transient storage was already marked for delete", "ledgerID", ledgerID)
162+
return nil
164163
}
165164

166165
marked.List = append(marked.List, ledgerID)

0 commit comments

Comments
 (0)