您现在的位置是:首页 > 文章详情

区块链教程Fabric1.0源代码分析putils(protos/utils工具包)-兄弟连区块链

日期:2018-11-06点击:298

区块链教程Fabric1.0源代码分析putils(protos/utils工具包),2018年下半年,区块链行业正逐渐褪去发展之初的浮躁、回归理性,表面上看相关人才需求与身价似乎正在回落。但事实上,正是初期泡沫的渐退,让人们更多的关注点放在了区块链真正的技术之上。

Fabric1.0源代码笔记之putils(protos/utils工具包)

1、putils概述

putils,即protos/utils工具包,代码分布在:protos/utils目录下。
包括:txutils.go、proputils.go、commonutils.go、blockutils.go。

2、txutils

//TransactionAction.Payload => ChaincodeActionPayload //ChaincodeActionPayload.Action.ProposalResponsePayload => ProposalResponsePayload //ProposalResponsePayload.Extension => ChaincodeAction //从TransactionAction中获取ChaincodeActionPayload和ChaincodeAction func GetPayloads(txActions *peer.TransactionAction) (*peer.ChaincodeActionPayload, *peer.ChaincodeAction, error) //[]byte反序列化为Envelope func GetEnvelopeFromBlock(data []byte) (*common.Envelope, error) func CreateSignedEnvelope(txType common.HeaderType, channelID string, signer crypto.LocalSigner, dataMsg proto.Message, msgVersion int32, epoch uint64) (*common.Envelope, error) //由Proposal创建签名交易Envelope func CreateSignedTx(proposal *peer.Proposal, signer msp.SigningIdentity, resps ...*peer.ProposalResponse) (*common.Envelope, error) { func CreateProposalResponse(hdrbytes []byte, payl []byte, response *peer.Response, results []byte, events []byte, ccid *peer.ChaincodeID, visibility []byte, signingEndorser msp.SigningIdentity) (*peer.ProposalResponse, error) func CreateProposalResponseFailure(hdrbytes []byte, payl []byte, response *peer.Response, results []byte, events []byte, ccid *peer.ChaincodeID, visibility []byte) (*peer.ProposalResponse, error) //签名Proposal func GetSignedProposal(prop *peer.Proposal, signer msp.SigningIdentity) (*peer.SignedProposal, error) func GetSignedEvent(evt *peer.Event, signer msp.SigningIdentity) (*peer.SignedEvent, error) func MockSignedEndorserProposalOrPanic(chainID string, cs *peer.ChaincodeSpec, creator, signature []byte) (*peer.SignedProposal, *peer.Proposal) func MockSignedEndorserProposal2OrPanic(chainID string, cs *peer.ChaincodeSpec, signer msp.SigningIdentity) (*peer.SignedProposal, *peer.Proposal) func GetBytesProposalPayloadForTx(payload *peer.ChaincodeProposalPayload, visibility []byte) ([]byte, error) func GetProposalHash2(header *common.Header, ccPropPayl []byte) ([]byte, error) func GetProposalHash1(header *common.Header, ccPropPayl []byte, visibility []byte) ([]byte, error) //代码在protos/utils/txutils.go

3、proputils

func GetChaincodeInvocationSpec(prop *peer.Proposal) (*peer.ChaincodeInvocationSpec, error) func GetChaincodeProposalContext(prop *peer.Proposal) ([]byte, map[string][]byte, error) //反序列化为common.Header func GetHeader(bytes []byte) (*common.Header, error) func GetNonce(prop *peer.Proposal) ([]byte, error) //Header.ChannelHeader反序列化为peer.ChaincodeHeaderExtension func GetChaincodeHeaderExtension(hdr *common.Header) (*peer.ChaincodeHeaderExtension, error) func GetProposalResponse(prBytes []byte) (*peer.ProposalResponse, error) func GetChaincodeDeploymentSpec(code []byte) (*peer.ChaincodeDeploymentSpec, error) func GetChaincodeAction(caBytes []byte) (*peer.ChaincodeAction, error) func GetResponse(resBytes []byte) (*peer.Response, error) func GetChaincodeEvents(eBytes []byte) (*peer.ChaincodeEvent, error) func GetProposalResponsePayload(prpBytes []byte) (*peer.ProposalResponsePayload, error) func GetProposal(propBytes []byte) (*peer.Proposal, error) //e.Payload反序列化为Payload func GetPayload(e *common.Envelope) (*common.Payload, error) //[]byte反序列化为Transaction func GetTransaction(txBytes []byte) (*peer.Transaction, error) func GetChaincodeActionPayload(capBytes []byte) (*peer.ChaincodeActionPayload, error) //反序列化为peer.ChaincodeProposalPayload func GetChaincodeProposalPayload(bytes []byte) (*peer.ChaincodeProposalPayload, error) //反序列化为common.SignatureHeader func GetSignatureHeader(bytes []byte) (*common.SignatureHeader, error) func CreateChaincodeProposal(typ common.HeaderType, chainID string, cis *peer.ChaincodeInvocationSpec, creator []byte) (*peer.Proposal, string, error) func CreateChaincodeProposalWithTransient(typ common.HeaderType, chainID string, cis *peer.ChaincodeInvocationSpec, creator []byte, transientMap map[string][]byte) (*peer.Proposal, string, error) func CreateChaincodeProposalWithTxIDNonceAndTransient(txid string, typ common.HeaderType, chainID string, cis *peer.ChaincodeInvocationSpec, nonce, creator []byte, transientMap map[string][]byte) (*peer.Proposal, string, error) func GetBytesProposalResponsePayload(hash []byte, response *peer.Response, result []byte, event []byte, ccid *peer.ChaincodeID) ([]byte, error) func GetBytesChaincodeProposalPayload(cpp *peer.ChaincodeProposalPayload) ([]byte, error) func GetBytesResponse(res *peer.Response) ([]byte, error) func GetBytesChaincodeEvent(event *peer.ChaincodeEvent) ([]byte, error) func GetBytesChaincodeActionPayload(cap *peer.ChaincodeActionPayload) ([]byte, error) func GetBytesProposalResponse(pr *peer.ProposalResponse) ([]byte, error) func GetBytesProposal(prop *peer.Proposal) ([]byte, error) func GetBytesHeader(hdr *common.Header) ([]byte, error) func GetBytesSignatureHeader(hdr *common.SignatureHeader) ([]byte, error) func GetBytesTransaction(tx *peer.Transaction) ([]byte, error) func GetBytesPayload(payl *common.Payload) ([]byte, error) func GetBytesEnvelope(env *common.Envelope) ([]byte, error) //从envBytes []byte中获取ChaincodeAction func GetActionFromEnvelope(envBytes []byte) (*peer.ChaincodeAction, error) func CreateProposalFromCIS(typ common.HeaderType, chainID string, cis *peer.ChaincodeInvocationSpec, creator []byte) (*peer.Proposal, string, error) func CreateInstallProposalFromCDS(ccpack proto.Message, creator []byte) (*peer.Proposal, string, error) //按ChaincodeDeploymentSpec创建DeployProposal func CreateDeployProposalFromCDS(chainID string, cds *peer.ChaincodeDeploymentSpec, creator []byte, policy []byte, escc []byte, vscc []byte) (*peer.Proposal, string, error) func CreateUpgradeProposalFromCDS(chainID string, cds *peer.ChaincodeDeploymentSpec, creator []byte, policy []byte, escc []byte, vscc []byte) (*peer.Proposal, string, error) func createProposalFromCDS(chainID string, msg proto.Message, creator []byte, policy []byte, escc []byte, vscc []byte, propType string) (*peer.Proposal, string, error) func ComputeProposalTxID(nonce, creator []byte) (string, error) func CheckProposalTxID(txid string, nonce, creator []byte) error func ComputeProposalBinding(proposal *peer.Proposal) ([]byte, error) func computeProposalBindingInternal(nonce, creator []byte, epoch uint64) ([]byte, error) //代码在protos/utils/proputils.go

4、commonutils

func MarshalOrPanic(pb proto.Message) []byte func Marshal(pb proto.Message) ([]byte, error) func CreateNonceOrPanic() []byte func CreateNonce() ([]byte, error) func UnmarshalPayloadOrPanic(encoded []byte) *cb.Payload func UnmarshalPayload(encoded []byte) (*cb.Payload, error) func UnmarshalEnvelopeOrPanic(encoded []byte) *cb.Envelope func UnmarshalEnvelope(encoded []byte) (*cb.Envelope, error) func UnmarshalEnvelopeOfType(envelope *cb.Envelope, headerType cb.HeaderType, message proto.Message) (*cb.ChannelHeader, error) func ExtractEnvelopeOrPanic(block *cb.Block, index int) *cb.Envelope func ExtractEnvelope(block *cb.Block, index int) (*cb.Envelope, error) func ExtractPayloadOrPanic(envelope *cb.Envelope) *cb.Payload func ExtractPayload(envelope *cb.Envelope) (*cb.Payload, error) func MakeChannelHeader(headerType cb.HeaderType, version int32, chainID string, epoch uint64) *cb.ChannelHeader func MakeSignatureHeader(serializedCreatorCertChain []byte, nonce []byte) *cb.SignatureHeader func SetTxID(channelHeader *cb.ChannelHeader, signatureHeader *cb.SignatureHeader) error func MakePayloadHeader(ch *cb.ChannelHeader, sh *cb.SignatureHeader) *cb.Header func NewSignatureHeaderOrPanic(signer crypto.LocalSigner) *cb.SignatureHeader func SignOrPanic(signer crypto.LocalSigner, msg []byte) []byte //[]byte反序列化为ChannelHeader func UnmarshalChannelHeader(bytes []byte) (*cb.ChannelHeader, error) func UnmarshalChaincodeID(bytes []byte) (*pb.ChaincodeID, error) func IsConfigBlock(block *cb.Block) bool //代码在protos/utils/commonutils.go

5、blockutils

//[]byte转换为Block,从Block中获取ChainID(即ChannelId) func GetChainIDFromBlockBytes(bytes []byte) (string, error) //从Block中获取ChainID(即ChannelId) func GetChainIDFromBlock(block *cb.Block) (string, error) //从Block中按index获取Metadata func GetMetadataFromBlock(block *cb.Block, index cb.BlockMetadataIndex) (*cb.Metadata, error) //从Block中按index获取Metadata,如果失败则Panic func GetMetadataFromBlockOrPanic(block *cb.Block, index cb.BlockMetadataIndex) *cb.Metadata //从Block.Metadata.Metadata中获取LastConfig func GetLastConfigIndexFromBlock(block *cb.Block) (uint64, error) //从Block.Metadata.Metadata中获取LastConfig,如果失败则Panic func GetLastConfigIndexFromBlockOrPanic(block *cb.Block) uint64 //[]byte转换为Block func GetBlockFromBlockBytes(blockBytes []byte) (*cb.Block, error) //拷贝Block.Metadata func CopyBlockMetadata(src *cb.Block, dst *cb.Block) //初始化Block.Metadata.Metadata func InitBlockMetadata(block *cb.Block) //代码在protos/utils/blockutils.go
原文链接:https://yq.aliyun.com/articles/665685
关注公众号

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。

文章评论

共有0条评论来说两句吧...

文章二维码

扫描即可查看该文章

点击排行

推荐阅读

最新文章