/
configtx.go
119 lines (90 loc) · 3.18 KB
/
configtx.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
/*
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 commonext
import (
"fmt"
"github.com/golang/protobuf/proto"
"github.com/hyperledger/fabric-protos-go/common"
)
type ConfigUpdateEnvelope struct{ *common.ConfigUpdateEnvelope }
func (cue *ConfigUpdateEnvelope) Underlying() proto.Message {
return cue.ConfigUpdateEnvelope
}
func (cue *ConfigUpdateEnvelope) StaticallyOpaqueFields() []string {
return []string{"config_update"}
}
func (cue *ConfigUpdateEnvelope) StaticallyOpaqueFieldProto(name string) (proto.Message, error) {
if name != cue.StaticallyOpaqueFields()[0] {
return nil, fmt.Errorf("Not a marshaled field: %s", name)
}
return &common.ConfigUpdate{}, nil
}
type ConfigSignature struct{ *common.ConfigSignature }
func (cs *ConfigSignature) Underlying() proto.Message {
return cs.ConfigSignature
}
func (cs *ConfigSignature) StaticallyOpaqueFields() []string {
return []string{"signature_header"}
}
func (cs *ConfigSignature) StaticallyOpaqueFieldProto(name string) (proto.Message, error) {
if name != cs.StaticallyOpaqueFields()[0] {
return nil, fmt.Errorf("Not a marshaled field: %s", name)
}
return &common.SignatureHeader{}, nil
}
type Config struct{ *common.Config }
func (c *Config) Underlying() proto.Message {
return c.Config
}
func (c *Config) DynamicFields() []string {
return []string{"channel_group"}
}
func (c *Config) DynamicFieldProto(name string, base proto.Message) (proto.Message, error) {
if name != c.DynamicFields()[0] {
return nil, fmt.Errorf("Not a dynamic field: %s", name)
}
cg, ok := base.(*common.ConfigGroup)
if !ok {
return nil, fmt.Errorf("Config must embed a config group as its dynamic field")
}
return &DynamicChannelGroup{ConfigGroup: cg}, nil
}
// ConfigUpdateIsolatedDataTypes allows other proto packages to register types for the
// the isolated_data field. This is necessary to break import cycles.
var ConfigUpdateIsolatedDataTypes = map[string]func(string) proto.Message{}
type ConfigUpdate struct{ *common.ConfigUpdate }
func (c *ConfigUpdate) Underlying() proto.Message {
return c.ConfigUpdate
}
func (c *ConfigUpdate) StaticallyOpaqueMapFields() []string {
return []string{"isolated_data"}
}
func (c *ConfigUpdate) StaticallyOpaqueMapFieldProto(name string, key string) (proto.Message, error) {
if name != c.StaticallyOpaqueMapFields()[0] {
return nil, fmt.Errorf("Not a statically opaque map field: %s", name)
}
mf, ok := ConfigUpdateIsolatedDataTypes[key]
if !ok {
return nil, fmt.Errorf("Unknown map key: %s", key)
}
return mf(key), nil
}
func (c *ConfigUpdate) DynamicFields() []string {
return []string{"read_set", "write_set"}
}
func (c *ConfigUpdate) DynamicFieldProto(name string, base proto.Message) (proto.Message, error) {
if name != c.DynamicFields()[0] && name != c.DynamicFields()[1] {
return nil, fmt.Errorf("Not a dynamic field: %s", name)
}
cg, ok := base.(*common.ConfigGroup)
if !ok {
return nil, fmt.Errorf("Expected base to be *ConfigGroup, got %T", base)
}
return &DynamicChannelGroup{ConfigGroup: cg}, nil
}