Skip to content

Commit 42b6cd8

Browse files
committed
[FAB-14324] remove peer.Support
The "Support" interface and "supportImpl" are unnecessary. Change-Id: I79d566f7604aec52cbc9bc85463bcbca37f42803 Signed-off-by: Matthew Sykes <sykesmat@us.ibm.com>
1 parent 5033e2f commit 42b6cd8

File tree

10 files changed

+132
-122
lines changed

10 files changed

+132
-122
lines changed

core/chaincode/chaincode_support_test.go

Lines changed: 11 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,6 @@ import (
4141
"github.com/hyperledger/fabric/core/container/inproccontroller"
4242
"github.com/hyperledger/fabric/core/ledger"
4343
ledgermock "github.com/hyperledger/fabric/core/ledger/mock"
44-
cmp "github.com/hyperledger/fabric/core/mocks/peer"
4544
"github.com/hyperledger/fabric/core/peer"
4645
"github.com/hyperledger/fabric/core/policy"
4746
"github.com/hyperledger/fabric/core/scc"
@@ -152,21 +151,11 @@ func (p *PackageProviderWrapper) GetChaincodeCodePackage(ccci *ccprovider.Chainc
152151

153152
//initialize peer and start up. If security==enabled, login as vp
154153
func initMockPeer(chainIDs ...string) (*ChaincodeSupport, func(), error) {
155-
fakeApplicationConfig := &mock.ApplicationConfig{}
156-
capabilities := &mock.ApplicationCapabilities{}
157-
capabilities.LifecycleV20Returns(false)
158-
fakeApplicationConfig.CapabilitiesReturns(capabilities)
159-
msi := &cmp.MockSupportImpl{
160-
GetApplicationConfigRv: fakeApplicationConfig,
161-
GetApplicationConfigBoolRv: true,
162-
}
163-
164154
ipRegistry := inproccontroller.NewRegistry()
165155
sccp := &scc.Provider{
166-
Peer: peer.Default,
167-
PeerSupport: msi,
168-
Registrar: ipRegistry,
169-
Whitelist: scc.GlobalWhitelist(),
156+
Peer: peer.Default,
157+
Registrar: ipRegistry,
158+
Whitelist: scc.GlobalWhitelist(),
170159
}
171160

172161
ledgerCleanup, err := peer.MockInitialize()
@@ -257,7 +246,7 @@ func initMockPeer(chainIDs ...string) (*ChaincodeSupport, func(), error) {
257246
}
258247
chaincodeSupport := &ChaincodeSupport{
259248
ACLProvider: mockAclProvider,
260-
AppConfig: peer.DefaultSupport,
249+
AppConfig: peer.Default,
261250
DeployedCCInfoProvider: &ledgermock.DeployedChaincodeInfoProvider{},
262251
ExecuteTimeout: globalConfig.ExecuteTimeout,
263252
HandlerMetrics: NewHandlerMetrics(metricsProviders),
@@ -1113,7 +1102,13 @@ func TestStartAndWaitLaunchError(t *testing.T) {
11131102
}
11141103

11151104
func TestGetTxContextFromHandler(t *testing.T) {
1116-
h := Handler{TXContexts: NewTransactionContexts(), SystemCCProvider: &scc.Provider{Peer: peer.Default, PeerSupport: peer.DefaultSupport, Registrar: inproccontroller.NewRegistry()}}
1105+
h := Handler{
1106+
TXContexts: NewTransactionContexts(),
1107+
SystemCCProvider: &scc.Provider{
1108+
Peer: peer.Default,
1109+
Registrar: inproccontroller.NewRegistry(),
1110+
},
1111+
}
11171112

11181113
chnl := "test"
11191114
txid := "1"

core/chaincode/exectransaction_test.go

Lines changed: 4 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,6 @@ import (
4848
"github.com/hyperledger/fabric/core/ledger"
4949
ledgermock "github.com/hyperledger/fabric/core/ledger/mock"
5050
cut "github.com/hyperledger/fabric/core/ledger/util"
51-
cmp "github.com/hyperledger/fabric/core/mocks/peer"
5251
"github.com/hyperledger/fabric/core/peer"
5352
"github.com/hyperledger/fabric/core/policy"
5453
"github.com/hyperledger/fabric/core/policy/mocks"
@@ -71,21 +70,11 @@ func initPeer(chainIDs ...string) (*cm.Lifecycle, net.Listener, *ChaincodeSuppor
7170
//start clean
7271
finitPeer(nil, chainIDs...)
7372

74-
fakeApplicationConfig := &cm.ApplicationConfig{}
75-
fakeCapabilites := &cm.ApplicationCapabilities{}
76-
fakeApplicationConfig.CapabilitiesReturns(fakeCapabilites)
77-
78-
msi := &cmp.MockSupportImpl{
79-
GetApplicationConfigRv: fakeApplicationConfig,
80-
GetApplicationConfigBoolRv: true,
81-
}
82-
8373
ipRegistry := inproccontroller.NewRegistry()
8474
sccp := &scc.Provider{
85-
Peer: peer.Default,
86-
PeerSupport: msi,
87-
Registrar: ipRegistry,
88-
Whitelist: scc.GlobalWhitelist(),
75+
Peer: peer.Default,
76+
Registrar: ipRegistry,
77+
Whitelist: scc.GlobalWhitelist(),
8978
}
9079

9180
ledgerCleanup, err := peer.MockInitialize()
@@ -191,7 +180,7 @@ func initPeer(chainIDs ...string) (*cm.Lifecycle, net.Listener, *ChaincodeSuppor
191180
}
192181
chaincodeSupport := &ChaincodeSupport{
193182
ACLProvider: aclmgmt.NewACLProvider(func(string) channelconfig.Resources { return nil }),
194-
AppConfig: peer.DefaultSupport,
183+
AppConfig: peer.Default,
195184
DeployedCCInfoProvider: &ledgermock.DeployedChaincodeInfoProvider{},
196185
ExecuteTimeout: globalConfig.ExecuteTimeout,
197186
HandlerMetrics: NewHandlerMetrics(metricsProviders),

core/endorser/support.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@ type SupportImpl struct {
3232
*PluginEndorser
3333
identity.SignerSerializer
3434
Peer peer.Operations
35-
PeerSupport peer.Support
3635
ChaincodeSupport *chaincode.ChaincodeSupport
3736
SysCCProvider *scc.Provider
3837
ACLProvider aclmgmt.ACLProvider
@@ -184,7 +183,7 @@ func (s *SupportImpl) CheckInstantiationPolicy(name, version string, cd ccprovid
184183
// GetApplicationConfig returns the configtxapplication.SharedConfig for the Channel
185184
// and whether the Application config exists
186185
func (s *SupportImpl) GetApplicationConfig(cid string) (channelconfig.Application, bool) {
187-
return s.PeerSupport.GetApplicationConfig(cid)
186+
return s.Peer.GetApplicationConfig(cid)
188187
}
189188

190189
// GetDeployedCCInfoProvider returns ledger.DeployedChaincodeInfoProvider

core/mocks/peer/support.go

Lines changed: 0 additions & 36 deletions
This file was deleted.

core/peer/peer_impl.go

Lines changed: 25 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@ import (
2525
type Operations interface {
2626
CreateChainFromBlock(cb *common.Block, sccp sysccprovider.SystemChaincodeProvider, deployedCCInfoProvider ledger.DeployedChaincodeInfoProvider, lr plugindispatcher.LifecycleResources, nr plugindispatcher.CollectionAndLifecycleResources) error
2727
GetChannelConfig(cid string) channelconfig.Resources
28+
GetApplicationConfig(cid string) (channelconfig.Application, bool)
2829
GetChannelsInfo() []*pb.ChannelInfo
2930
GetStableChannelConfig(cid string) channelconfig.Resources
3031
GetCurrConfigBlock(cid string) *common.Block
@@ -87,23 +88,43 @@ var Default Operations = &peerImpl{
8788
initialize: Initialize,
8889
}
8990

90-
var DefaultSupport Support = &supportImpl{operations: Default}
91-
92-
func (p *peerImpl) CreateChainFromBlock(cb *common.Block, sccp sysccprovider.SystemChaincodeProvider, deployedCCInfoProvider ledger.DeployedChaincodeInfoProvider, lr plugindispatcher.LifecycleResources, nr plugindispatcher.CollectionAndLifecycleResources) error {
91+
func (p *peerImpl) CreateChainFromBlock(
92+
cb *common.Block,
93+
sccp sysccprovider.SystemChaincodeProvider,
94+
deployedCCInfoProvider ledger.DeployedChaincodeInfoProvider,
95+
lr plugindispatcher.LifecycleResources,
96+
nr plugindispatcher.CollectionAndLifecycleResources,
97+
) error {
9398
return p.createChainFromBlock(cb, sccp, deployedCCInfoProvider, lr, nr)
9499
}
100+
95101
func (p *peerImpl) GetChannelConfig(cid string) channelconfig.Resources {
96102
return p.getChannelConfig(cid)
97103
}
98-
func (p *peerImpl) GetChannelsInfo() []*pb.ChannelInfo { return p.getChannelsInfo() }
104+
105+
func (p *peerImpl) GetChannelsInfo() []*pb.ChannelInfo {
106+
return p.getChannelsInfo()
107+
}
108+
99109
func (p *peerImpl) GetStableChannelConfig(cid string) channelconfig.Resources {
100110
return p.getStableChannelConfig(cid)
101111
}
112+
102113
func (p *peerImpl) GetCurrConfigBlock(cid string) *common.Block { return p.getCurrConfigBlock(cid) }
103114
func (p *peerImpl) GetLedger(cid string) ledger.PeerLedger { return p.getLedger(cid) }
104115
func (p *peerImpl) GetMSPIDs(cid string) []string { return p.getMSPIDs(cid) }
105116
func (p *peerImpl) GetPolicyManager(cid string) policies.Manager { return p.getPolicyManager(cid) }
106117
func (p *peerImpl) InitChain(cid string) { p.initChain(cid) }
118+
119+
func (p *peerImpl) GetApplicationConfig(cid string) (channelconfig.Application, bool) {
120+
cc := p.GetChannelConfig(cid)
121+
if cc == nil {
122+
return nil, false
123+
}
124+
125+
return cc.ApplicationConfig()
126+
}
127+
107128
func (p *peerImpl) Initialize(
108129
init func(string),
109130
sccp sysccprovider.SystemChaincodeProvider,

core/peer/support.go

Lines changed: 0 additions & 31 deletions
This file was deleted.

core/scc/scc_test.go

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -24,9 +24,8 @@ func init() {
2424

2525
func newTestProvider() *Provider {
2626
p := &Provider{
27-
Peer: peer.Default,
28-
PeerSupport: peer.DefaultSupport,
29-
Registrar: inproccontroller.NewRegistry(),
27+
Peer: peer.Default,
28+
Registrar: inproccontroller.NewRegistry(),
3029
Whitelist: map[string]bool{
3130
"invokableExternalButNotCC2CC": true,
3231
"invokableCC2CCButNotExternal": true,
@@ -112,9 +111,8 @@ func TestIsSysCCAndNotInvokableExternal(t *testing.T) {
112111

113112
func TestSccProviderImpl_GetQueryExecutorForLedger(t *testing.T) {
114113
p := &Provider{
115-
Peer: peer.Default,
116-
PeerSupport: peer.DefaultSupport,
117-
Registrar: inproccontroller.NewRegistry(),
114+
Peer: peer.Default,
115+
Registrar: inproccontroller.NewRegistry(),
118116
}
119117
qe, err := p.GetQueryExecutorForLedger("")
120118
assert.Nil(t, qe)

core/scc/sccproviderimpl.go

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -17,11 +17,10 @@ import (
1717

1818
// Provider implements sysccprovider.SystemChaincodeProvider
1919
type Provider struct {
20-
Peer peer.Operations
21-
PeerSupport peer.Support
22-
Registrar Registrar
23-
SysCCs []SelfDescribingSysCC
24-
Whitelist Whitelist
20+
Peer peer.Operations
21+
Registrar Registrar
22+
SysCCs []SelfDescribingSysCC
23+
Whitelist Whitelist
2524
}
2625

2726
// RegisterSysCC registers a system chaincode with the syscc provider.
@@ -93,7 +92,7 @@ func (p *Provider) IsSysCCAndNotInvokableExternal(name string) bool {
9392
// GetApplicationConfig returns the configtxapplication.SharedConfig for the channel
9493
// and whether the Application config exists
9594
func (p *Provider) GetApplicationConfig(cid string) (channelconfig.Application, bool) {
96-
return p.PeerSupport.GetApplicationConfig(cid)
95+
return p.Peer.GetApplicationConfig(cid)
9796
}
9897

9998
// Returns the policy manager associated to the passed channel

internal/peer/node/start.go

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -350,10 +350,9 @@ func serve(args []string) error {
350350
ipRegistry := inproccontroller.NewRegistry()
351351

352352
sccp := &scc.Provider{
353-
Peer: peer.Default,
354-
PeerSupport: peer.DefaultSupport,
355-
Registrar: ipRegistry,
356-
Whitelist: scc.GlobalWhitelist(),
353+
Peer: peer.Default,
354+
Registrar: ipRegistry,
355+
Whitelist: scc.GlobalWhitelist(),
357356
}
358357
lsccInst := lscc.New(sccp, aclProvider, platformRegistry)
359358

@@ -450,7 +449,7 @@ func serve(args []string) error {
450449

451450
chaincodeSupport := &chaincode.ChaincodeSupport{
452451
ACLProvider: aclProvider,
453-
AppConfig: peer.DefaultSupport,
452+
AppConfig: peer.Default,
454453
DeployedCCInfoProvider: lifecycleValidatorCommitter,
455454
ExecuteTimeout: globalConfig.ExecuteTimeout,
456455
HandlerRegistry: chaincodeHandlerRegistry,
@@ -505,7 +504,6 @@ func serve(args []string) error {
505504
endorserSupport := &endorser.SupportImpl{
506505
SignerSerializer: signingIdentity,
507506
Peer: peer.Default,
508-
PeerSupport: peer.DefaultSupport,
509507
ChaincodeSupport: chaincodeSupport,
510508
SysCCProvider: sccp,
511509
ACLProvider: aclProvider,

0 commit comments

Comments
 (0)