forked from hyperledger/fabric
-
Notifications
You must be signed in to change notification settings - Fork 3
/
util.go
235 lines (202 loc) · 6.71 KB
/
util.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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
/*
Copyright IBM Corp. All Rights Reserved.
SPDX-License-Identifier: Apache-2.0
*/
package channelconfig
import (
"math"
"github.com/golang/protobuf/proto"
"github.com/hyperledger/fabric/bccsp"
cb "github.com/hyperledger/fabric/protos/common"
mspprotos "github.com/hyperledger/fabric/protos/msp"
ab "github.com/hyperledger/fabric/protos/orderer"
pb "github.com/hyperledger/fabric/protos/peer"
)
const (
// ReadersPolicyKey is the key used for the read policy
ReadersPolicyKey = "Readers"
// WritersPolicyKey is the key used for the read policy
WritersPolicyKey = "Writers"
// AdminsPolicyKey is the key used for the read policy
AdminsPolicyKey = "Admins"
defaultHashingAlgorithm = bccsp.SHA256
defaultBlockDataHashingStructureWidth = math.MaxUint32
)
// ConfigValue defines a common representation for different *cb.ConfigValue values.
type ConfigValue interface {
// Key is the key this value should be stored in the *cb.ConfigGroup.Values map.
Key() string
// Value is the message which should be marshaled to opaque bytes for the *cb.ConfigValue.value.
Value() proto.Message
}
// StandardConfigValue implements the ConfigValue interface.
type StandardConfigValue struct {
key string
value proto.Message
}
// Key is the key this value should be stored in the *cb.ConfigGroup.Values map.
func (scv *StandardConfigValue) Key() string {
return scv.key
}
// Value is the message which should be marshaled to opaque bytes for the *cb.ConfigValue.value.
func (scv *StandardConfigValue) Value() proto.Message {
return scv.value
}
// ConsortiumValue returns the config definition for the consortium name.
// It is a value for the channel group.
func ConsortiumValue(name string) *StandardConfigValue {
return &StandardConfigValue{
key: ConsortiumKey,
value: &cb.Consortium{
Name: name,
},
}
}
// HashingAlgorithm returns the only currently valid hashing algorithm.
// It is a value for the /Channel group.
func HashingAlgorithmValue() *StandardConfigValue {
return &StandardConfigValue{
key: HashingAlgorithmKey,
value: &cb.HashingAlgorithm{
Name: defaultHashingAlgorithm,
},
}
}
// BlockDataHashingStructureValue returns the only currently valid block data hashing structure.
// It is a value for the /Channel group.
func BlockDataHashingStructureValue() *StandardConfigValue {
return &StandardConfigValue{
key: BlockDataHashingStructureKey,
value: &cb.BlockDataHashingStructure{
Width: defaultBlockDataHashingStructureWidth,
},
}
}
// OrdererAddressesValue returns the a config definition for the orderer addresses.
// It is a value for the /Channel group.
func OrdererAddressesValue(addresses []string) *StandardConfigValue {
return &StandardConfigValue{
key: OrdererAddressesKey,
value: &cb.OrdererAddresses{
Addresses: addresses,
},
}
}
// ConsensusTypeValue returns the config definition for the orderer consensus type.
// It is a value for the /Channel/Orderer group.
func ConsensusTypeValue(consensusType string, consensusMetadata []byte) *StandardConfigValue {
return &StandardConfigValue{
key: ConsensusTypeKey,
value: &ab.ConsensusType{
Type: consensusType,
Metadata: consensusMetadata,
},
}
}
// BatchSizeValue returns the config definition for the orderer batch size.
// It is a value for the /Channel/Orderer group.
func BatchSizeValue(maxMessages, absoluteMaxBytes, preferredMaxBytes uint32) *StandardConfigValue {
return &StandardConfigValue{
key: BatchSizeKey,
value: &ab.BatchSize{
MaxMessageCount: maxMessages,
AbsoluteMaxBytes: absoluteMaxBytes,
PreferredMaxBytes: preferredMaxBytes,
},
}
}
// BatchTimeoutValue returns the config definition for the orderer batch timeout.
// It is a value for the /Channel/Orderer group.
func BatchTimeoutValue(timeout string) *StandardConfigValue {
return &StandardConfigValue{
key: BatchTimeoutKey,
value: &ab.BatchTimeout{
Timeout: timeout,
},
}
}
// ChannelRestrictionsValue returns the config definition for the orderer channel restrictions.
// It is a value for the /Channel/Orderer group.
func ChannelRestrictionsValue(maxChannelCount uint64) *StandardConfigValue {
return &StandardConfigValue{
key: ChannelRestrictionsKey,
value: &ab.ChannelRestrictions{
MaxCount: maxChannelCount,
},
}
}
// KafkaBrokersValue returns the config definition for the addresses of the ordering service's Kafka brokers.
// It is a value for the /Channel/Orderer group.
func KafkaBrokersValue(brokers []string) *StandardConfigValue {
return &StandardConfigValue{
key: KafkaBrokersKey,
value: &ab.KafkaBrokers{
Brokers: brokers,
},
}
}
// MSPValue returns the config definition for an MSP.
// It is a value for the /Channel/Orderer/*, /Channel/Application/*, and /Channel/Consortiums/*/*/* groups.
func MSPValue(mspDef *mspprotos.MSPConfig) *StandardConfigValue {
return &StandardConfigValue{
key: MSPKey,
value: mspDef,
}
}
// CapabilitiesValue returns the config definition for a a set of capabilities.
// It is a value for the /Channel/Orderer, Channel/Application/, and /Channel groups.
func CapabilitiesValue(capabilities map[string]bool) *StandardConfigValue {
c := &cb.Capabilities{
Capabilities: make(map[string]*cb.Capability),
}
for capability, required := range capabilities {
if !required {
continue
}
c.Capabilities[capability] = &cb.Capability{}
}
return &StandardConfigValue{
key: CapabilitiesKey,
value: c,
}
}
// EndpointsValue returns the config definition for the orderer addresses at an org scoped level.
// It is a value for the /Channel/Orderer/<OrgName> group.
func EndpointsValue(addresses []string) *StandardConfigValue {
return &StandardConfigValue{
key: EndpointsKey,
value: &cb.OrdererAddresses{
Addresses: addresses,
},
}
}
// AnchorPeersValue returns the config definition for an org's anchor peers.
// It is a value for the /Channel/Application/*.
func AnchorPeersValue(anchorPeers []*pb.AnchorPeer) *StandardConfigValue {
return &StandardConfigValue{
key: AnchorPeersKey,
value: &pb.AnchorPeers{AnchorPeers: anchorPeers},
}
}
// ChannelCreationPolicyValue returns the config definition for a consortium's channel creation policy
// It is a value for the /Channel/Consortiums/*/*.
func ChannelCreationPolicyValue(policy *cb.Policy) *StandardConfigValue {
return &StandardConfigValue{
key: ChannelCreationPolicyKey,
value: policy,
}
}
// ACLsValues returns the config definition for an applications resources based ACL definitions.
// It is a value for the /Channel/Application/.
func ACLValues(acls map[string]string) *StandardConfigValue {
a := &pb.ACLs{
Acls: make(map[string]*pb.APIResource),
}
for apiResource, policyRef := range acls {
a.Acls[apiResource] = &pb.APIResource{PolicyRef: policyRef}
}
return &StandardConfigValue{
key: ACLsKey,
value: a,
}
}