Skip to content

Commit cf887e5

Browse files
author
Jason Yellick
committed
[FAB-2210] Rename CONFIGURATION enums to CONFIG
https://jira.hyperledger.org/browse/FAB-2210 All of the config tx protos have been modified to refer to config rather than to configuration. This CR extends this pattern to the proto enums. Change-Id: Ibf4af3d323d009ae5522437dcb660e8750728dc4 Signed-off-by: Jason Yellick <[email protected]>
1 parent 4d72057 commit cf887e5

File tree

22 files changed

+106
-106
lines changed

22 files changed

+106
-106
lines changed

common/configtx/template.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ func (st *simpleTemplate) Envelope(chainID string) (*cb.ConfigUpdateEnvelope, er
6565
config, err := proto.Marshal(&cb.ConfigUpdate{
6666
Header: &cb.ChannelHeader{
6767
ChannelId: chainID,
68-
Type: int32(cb.HeaderType_CONFIGURATION_ITEM),
68+
Type: int32(cb.HeaderType_CONFIG),
6969
},
7070
WriteSet: st.configGroup,
7171
})
@@ -141,7 +141,7 @@ func (ct *compositeTemplate) Envelope(chainID string) (*cb.ConfigUpdateEnvelope,
141141
marshaledConfig, err := proto.Marshal(&cb.ConfigUpdate{
142142
Header: &cb.ChannelHeader{
143143
ChannelId: chainID,
144-
Type: int32(cb.HeaderType_CONFIGURATION_ITEM),
144+
Type: int32(cb.HeaderType_CONFIG),
145145
},
146146
WriteSet: channel,
147147
})
@@ -192,7 +192,7 @@ func MakeChainCreationTransaction(creationPolicy string, chainID string, signer
192192
LastUpdate: newConfigUpdateEnv,
193193
}
194194

195-
payloadChannelHeader := utils.MakeChannelHeader(cb.HeaderType_CONFIGURATION_TRANSACTION, msgVersion, chainID, epoch)
195+
payloadChannelHeader := utils.MakeChannelHeader(cb.HeaderType_CONFIG, msgVersion, chainID, epoch)
196196
payloadSignatureHeader := utils.MakeSignatureHeader(sSigner, utils.CreateNonceOrPanic())
197197
payloadHeader := utils.MakePayloadHeader(payloadChannelHeader, payloadSignatureHeader)
198198
payload := &cb.Payload{Header: payloadHeader, Data: utils.MarshalOrPanic(newConfigEnv)}

common/configtx/tool/provisional/provisional_test.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ func TestGenesisMetadata(t *testing.T) {
5555
t.Fatalf("Expected non-nil metadata")
5656
}
5757

58-
if genesisBlock.Metadata.Metadata[cb.BlockMetadataIndex_LAST_CONFIGURATION] == nil {
58+
if genesisBlock.Metadata.Metadata[cb.BlockMetadataIndex_LAST_CONFIG] == nil {
5959
t.Fatalf("Should have last config set")
6060
}
6161
}

common/genesis/genesis.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ func (f *factory) Block(chainID string) (*cb.Block, error) {
4848
return nil, err
4949
}
5050

51-
payloadChannelHeader := utils.MakeChannelHeader(cb.HeaderType_CONFIGURATION_TRANSACTION, msgVersion, chainID, epoch)
51+
payloadChannelHeader := utils.MakeChannelHeader(cb.HeaderType_CONFIG, msgVersion, chainID, epoch)
5252
payloadSignatureHeader := utils.MakeSignatureHeader(nil, utils.CreateNonceOrPanic())
5353
payloadHeader := utils.MakePayloadHeader(payloadChannelHeader, payloadSignatureHeader)
5454
payload := &cb.Payload{Header: payloadHeader, Data: utils.MarshalOrPanic(&cb.ConfigEnvelope{LastUpdate: configEnv})}
@@ -57,7 +57,7 @@ func (f *factory) Block(chainID string) (*cb.Block, error) {
5757
block := cb.NewBlock(0, nil)
5858
block.Data = &cb.BlockData{Data: [][]byte{utils.MarshalOrPanic(envelope)}}
5959
block.Header.DataHash = block.Data.Hash()
60-
block.Metadata.Metadata[cb.BlockMetadataIndex_LAST_CONFIGURATION] = utils.MarshalOrPanic(&cb.Metadata{
60+
block.Metadata.Metadata[cb.BlockMetadataIndex_LAST_CONFIG] = utils.MarshalOrPanic(&cb.Metadata{
6161
Value: utils.MarshalOrPanic(&cb.LastConfig{Index: 0}),
6262
})
6363
return block, nil

core/committer/txvalidator/validator.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,7 @@ func (v *txValidator) Validate(block *common.Block) error {
141141
logger.Errorf("VSCCValidateTx for transaction txId = %s returned error %s", txID, err)
142142
continue
143143
}
144-
} else if common.HeaderType(payload.Header.ChannelHeader.Type) == common.HeaderType_CONFIGURATION_TRANSACTION {
144+
} else if common.HeaderType(payload.Header.ChannelHeader.Type) == common.HeaderType_CONFIG {
145145
configEnvelope, err := configtx.UnmarshalConfigEnvelope(payload.Data)
146146
if err != nil {
147147
err := fmt.Errorf("Error unmarshaling config which passed initial validity checks: %s", err)

core/common/validation/msgvalidation.go

+5-5
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ func ValidateProposalMessage(signedProp *pb.SignedProposal) (*pb.Proposal, *comm
8989

9090
// continue the validation in a way that depends on the type specified in the header
9191
switch common.HeaderType(hdr.ChannelHeader.Type) {
92-
case common.HeaderType_CONFIGURATION_TRANSACTION:
92+
case common.HeaderType_CONFIG:
9393
//which the types are different the validation is the same
9494
//viz, validate a proposal to a chaincode. If we need other
9595
//special validation for confguration, we would have to implement
@@ -181,8 +181,8 @@ func validateChannelHeader(cHdr *common.ChannelHeader) error {
181181

182182
// validate the header type
183183
if common.HeaderType(cHdr.Type) != common.HeaderType_ENDORSER_TRANSACTION &&
184-
common.HeaderType(cHdr.Type) != common.HeaderType_CONFIGURATION_ITEM &&
185-
common.HeaderType(cHdr.Type) != common.HeaderType_CONFIGURATION_TRANSACTION {
184+
common.HeaderType(cHdr.Type) != common.HeaderType_CONFIG_UPDATE &&
185+
common.HeaderType(cHdr.Type) != common.HeaderType_CONFIG {
186186
return fmt.Errorf("invalid header type %s", common.HeaderType(cHdr.Type))
187187
}
188188

@@ -217,7 +217,7 @@ func validateCommonHeader(hdr *common.Header) error {
217217
}
218218

219219
// validateConfigTransaction validates the payload of a
220-
// transaction assuming its type is CONFIGURATION_TRANSACTION
220+
// transaction assuming its type is CONFIG
221221
func validateConfigTransaction(data []byte, hdr *common.Header) error {
222222
putilsLogger.Infof("validateConfigTransaction starts for data %p, header %s", data, hdr)
223223

@@ -357,7 +357,7 @@ func ValidateTransaction(e *common.Envelope) (*common.Payload, error) {
357357
err = validateEndorserTransaction(payload.Data, payload.Header)
358358
putilsLogger.Infof("ValidateTransactionEnvelope returns err %s", err)
359359
return payload, err
360-
case common.HeaderType_CONFIGURATION_TRANSACTION:
360+
case common.HeaderType_CONFIG:
361361
err = validateConfigTransaction(payload.Data, payload.Header)
362362
putilsLogger.Infof("ValidateTransactionEnvelope returns err %s", err)
363363
return payload, err

core/ledger/kvledger/txmgmt/validator/statebasedval/state_based_validator.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ func (v *Validator) ValidateAndPrepareBatch(block *common.Block, doMVCCValidatio
118118
addWriteSetToBatch(txRWSet, committingTxHeight, updates)
119119
valid = true
120120
}
121-
} else if common.HeaderType(payload.Header.ChannelHeader.Type) == common.HeaderType_CONFIGURATION_TRANSACTION {
121+
} else if common.HeaderType(payload.Header.ChannelHeader.Type) == common.HeaderType_CONFIG {
122122
valid, err = v.validateConfigTX(env)
123123
if err != nil {
124124
return nil, err

core/peer/peer.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,7 @@ func getCurrConfigBlockFromLedger(ledger ledger.PeerLedger) (*common.Block, erro
142142
currBlockNumber = block.Header.Number - 1
143143
continue
144144
}
145-
if tx.Header.ChannelHeader.Type == int32(common.HeaderType_CONFIGURATION_TRANSACTION) {
145+
if tx.Header.ChannelHeader.Type == int32(common.HeaderType_CONFIG) {
146146
return block, nil
147147
}
148148
}

orderer/common/broadcast/broadcast.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ func (bh *handlerImpl) Handle(srv ab.AtomicBroadcast_BroadcastServer) error {
8787
support, ok := bh.sm.GetChain(payload.Header.ChannelHeader.ChannelId)
8888
if !ok {
8989
// Chain not found, maybe create one?
90-
if payload.Header.ChannelHeader.Type != int32(cb.HeaderType_CONFIGURATION_TRANSACTION) {
90+
if payload.Header.ChannelHeader.Type != int32(cb.HeaderType_CONFIG) {
9191
return srv.Send(&ab.BroadcastResponse{Status: cb.Status_NOT_FOUND})
9292
}
9393

orderer/common/broadcast/broadcast_test.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ func makeConfigMessage(chainID string) *cb.Envelope {
103103
Header: &cb.Header{
104104
ChannelHeader: &cb.ChannelHeader{
105105
ChannelId: chainID,
106-
Type: int32(cb.HeaderType_CONFIGURATION_TRANSACTION),
106+
Type: int32(cb.HeaderType_CONFIG),
107107
},
108108
},
109109
}

orderer/common/configtxfilter/filter.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ func (cf *configFilter) Apply(message *cb.Envelope) (filter.Action, filter.Commi
6262
return filter.Forward, nil
6363
}
6464

65-
if msgData.Header == nil || msgData.Header.ChannelHeader == nil || msgData.Header.ChannelHeader.Type != int32(cb.HeaderType_CONFIGURATION_TRANSACTION) {
65+
if msgData.Header == nil || msgData.Header.ChannelHeader == nil || msgData.Header.ChannelHeader.Type != int32(cb.HeaderType_CONFIG) {
6666
return filter.Forward, nil
6767
}
6868

orderer/common/configtxfilter/filter_test.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ func TestAcceptGoodConfig(t *testing.T) {
5050
configEnvBytes := utils.MarshalOrPanic(&cb.ConfigEnvelope{
5151
LastUpdate: configUpdateEnv,
5252
})
53-
configBytes := utils.MarshalOrPanic(&cb.Payload{Header: &cb.Header{ChannelHeader: &cb.ChannelHeader{Type: int32(cb.HeaderType_CONFIGURATION_TRANSACTION)}}, Data: configEnvBytes})
53+
configBytes := utils.MarshalOrPanic(&cb.Payload{Header: &cb.Header{ChannelHeader: &cb.ChannelHeader{Type: int32(cb.HeaderType_CONFIG)}}, Data: configEnvBytes})
5454
configEnvelope := &cb.Envelope{
5555
Payload: configBytes,
5656
}
@@ -75,7 +75,7 @@ func TestAcceptGoodConfig(t *testing.T) {
7575
func TestRejectBadConfig(t *testing.T) {
7676
cf := NewFilter(&mockconfigtx.Manager{ValidateVal: fmt.Errorf("Error")})
7777
config, _ := proto.Marshal(&cb.ConfigEnvelope{})
78-
configBytes, _ := proto.Marshal(&cb.Payload{Header: &cb.Header{ChannelHeader: &cb.ChannelHeader{Type: int32(cb.HeaderType_CONFIGURATION_TRANSACTION)}}, Data: config})
78+
configBytes, _ := proto.Marshal(&cb.Payload{Header: &cb.Header{ChannelHeader: &cb.ChannelHeader{Type: int32(cb.HeaderType_CONFIG)}}, Data: config})
7979
result, _ := cf.Apply(&cb.Envelope{
8080
Payload: configBytes,
8181
})

orderer/multichain/chainsupport.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -230,7 +230,7 @@ func (cs *chainSupport) addLastConfigSignature(block *cb.Block) {
230230

231231
lastConfigSignature.Signature = utils.SignOrPanic(cs.signer, util.ConcatenateBytes(lastConfigValue, lastConfigSignature.SignatureHeader, block.Header.Bytes()))
232232

233-
block.Metadata.Metadata[cb.BlockMetadataIndex_LAST_CONFIGURATION] = utils.MarshalOrPanic(&cb.Metadata{
233+
block.Metadata.Metadata[cb.BlockMetadataIndex_LAST_CONFIG] = utils.MarshalOrPanic(&cb.Metadata{
234234
Value: lastConfigValue,
235235
Signatures: []*cb.MetadataSignature{
236236
lastConfigSignature,

orderer/multichain/manager_test.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ func TestGetConfigTx(t *testing.T) {
8787
rl.Append(ordererledger.CreateNextBlock(rl, []*cb.Envelope{ctx}))
8888

8989
block := ordererledger.CreateNextBlock(rl, []*cb.Envelope{makeNormalTx(provisional.TestChainID, 7)})
90-
block.Metadata.Metadata[cb.BlockMetadataIndex_LAST_CONFIGURATION] = utils.MarshalOrPanic(&cb.Metadata{Value: utils.MarshalOrPanic(&cb.LastConfig{Index: 7})})
90+
block.Metadata.Metadata[cb.BlockMetadataIndex_LAST_CONFIG] = utils.MarshalOrPanic(&cb.Metadata{Value: utils.MarshalOrPanic(&cb.LastConfig{Index: 7})})
9191
rl.Append(block)
9292

9393
pctx := getConfigTx(rl)

orderer/multichain/systemchain.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -230,7 +230,7 @@ func (sc *systemChain) authorizeAndInspect(configTx *cb.Envelope) cb.Status {
230230
return cb.Status_BAD_REQUEST
231231
}
232232

233-
if payload.Header == nil || payload.Header.ChannelHeader == nil || payload.Header.ChannelHeader.Type != int32(cb.HeaderType_CONFIGURATION_TRANSACTION) {
233+
if payload.Header == nil || payload.Header.ChannelHeader == nil || payload.Header.ChannelHeader.Type != int32(cb.HeaderType_CONFIG) {
234234
logger.Debugf("Rejecting chain proposal: Not a config transaction: %s", err)
235235
return cb.Status_BAD_REQUEST
236236
}

orderer/multichain/util_test.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ func makeConfigTxFromConfigUpdateEnvelope(chainID string, configUpdateEnv *cb.Co
9999
payload := &cb.Payload{
100100
Header: &cb.Header{
101101
ChannelHeader: &cb.ChannelHeader{
102-
Type: int32(cb.HeaderType_CONFIGURATION_TRANSACTION),
102+
Type: int32(cb.HeaderType_CONFIG),
103103
ChannelId: chainID,
104104
},
105105
SignatureHeader: &cb.SignatureHeader{},

peer/channel/join.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ func executeJoin(cf *ChannelCmdFactory) (err error) {
100100
uuid := cutil.GenerateUUID()
101101

102102
var prop *pb.Proposal
103-
prop, err = putils.CreateProposalFromCIS(uuid, pcommon.HeaderType_CONFIGURATION_TRANSACTION, "", invocation, creator)
103+
prop, err = putils.CreateProposalFromCIS(uuid, pcommon.HeaderType_CONFIG, "", invocation, creator)
104104
if err != nil {
105105
return fmt.Errorf("Error creating proposal for join %s\n", err)
106106
}

0 commit comments

Comments
 (0)