-
Notifications
You must be signed in to change notification settings - Fork 92
/
channel.go
105 lines (89 loc) · 2.98 KB
/
channel.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
/*
Copyright IBM Corp. All Rights Reserved.
SPDX-License-Identifier: Apache-2.0
*/
/*
Notice: This file has been modified for Hyperledger Fabric SDK Go usage.
Please review third_party pinning scripts and patches for more details.
*/
package capabilities
import (
cb "github.com/hyperledger/fabric-protos-go/common"
"github.com/kfsoftware/hlf-operator/internal/github.com/hyperledger/fabric/msp"
)
const (
channelTypeName = "Channel"
// ChannelV1_1 is the capabilities string for standard new non-backwards compatible fabric v1.1 channel capabilities.
ChannelV1_1 = "V1_1"
// ChannelV1_3 is the capabilities string for standard new non-backwards compatible fabric v1.3 channel capabilities.
ChannelV1_3 = "V1_3"
// ChannelV1_4_2 is the capabilities string for standard new non-backwards compatible fabric v1.4.2 channel capabilities.
ChannelV1_4_2 = "V1_4_2"
// ChannelV1_4_3 is the capabilities string for standard new non-backwards compatible fabric v1.4.3 channel capabilities.
ChannelV1_4_3 = "V1_4_3"
// ChannelV2_0 is the capabilities string for standard new non-backwards compatible fabric v2.0 channel capabilities.
ChannelV2_0 = "V2_0"
)
// ChannelProvider provides capabilities information for channel level config.
type ChannelProvider struct {
*registry
v11 bool
v13 bool
v142 bool
v143 bool
v20 bool
}
// NewChannelProvider creates a channel capabilities provider.
func NewChannelProvider(capabilities map[string]*cb.Capability) *ChannelProvider {
cp := &ChannelProvider{}
cp.registry = newRegistry(cp, capabilities)
_, cp.v11 = capabilities[ChannelV1_1]
_, cp.v13 = capabilities[ChannelV1_3]
_, cp.v142 = capabilities[ChannelV1_4_2]
_, cp.v143 = capabilities[ChannelV1_4_3]
_, cp.v20 = capabilities[ChannelV2_0]
return cp
}
// Type returns a descriptive string for logging purposes.
func (cp *ChannelProvider) Type() string {
return channelTypeName
}
// HasCapability returns true if the capability is supported by this binary.
func (cp *ChannelProvider) HasCapability(capability string) bool {
switch capability {
// Add new capability names here
case ChannelV2_0:
return true
case ChannelV1_4_3:
return true
case ChannelV1_4_2:
return true
case ChannelV1_3:
return true
case ChannelV1_1:
return true
default:
return false
}
}
// MSPVersion returns the level of MSP support required by this channel.
func (cp *ChannelProvider) MSPVersion() msp.MSPVersion {
switch {
case cp.v143 || cp.v20:
return msp.MSPv1_4_3
case cp.v13 || cp.v142:
return msp.MSPv1_3
case cp.v11:
return msp.MSPv1_1
default:
return msp.MSPv1_0
}
}
// ConsensusTypeMigration return true if consensus-type migration is supported and permitted in both orderer and peer.
func (cp *ChannelProvider) ConsensusTypeMigration() bool {
return cp.v142 || cp.v143 || cp.v20
}
// OrgSpecificOrdererEndpoints allows for individual orderer orgs to specify their external addresses for their OSNs.
func (cp *ChannelProvider) OrgSpecificOrdererEndpoints() bool {
return cp.v142 || cp.v143 || cp.v20
}