mirror of
https://github.com/hyperledger/fabric-samples.git
synced 2026-06-17 15:35:09 +00:00
4fabd87648
Add some methods to the parsing API within the Go off_chain_data sample for consistency with the Node and Java implementations: - ToProto() on Block, Transaction and NamespaceReadWriteSet. - ValidationCode() on Transaction. - Creator() on Transaction Signed-off-by: Mark S. Lewis <Mark.S.Lewis@outlook.com>
41 lines
1.1 KiB
Go
41 lines
1.1 KiB
Go
package parser
|
|
|
|
import (
|
|
"sync"
|
|
|
|
"github.com/hyperledger/fabric-protos-go-apiv2/ledger/rwset"
|
|
"github.com/hyperledger/fabric-protos-go-apiv2/ledger/rwset/kvrwset"
|
|
"google.golang.org/protobuf/proto"
|
|
)
|
|
|
|
type NamespaceReadWriteSet struct {
|
|
nsReadWriteSet *rwset.NsReadWriteSet
|
|
readWriteSet func() (*kvrwset.KVRWSet, error)
|
|
}
|
|
|
|
func parseNamespaceReadWriteSet(nsRwSet *rwset.NsReadWriteSet) *NamespaceReadWriteSet {
|
|
result := &NamespaceReadWriteSet{nsRwSet, nil}
|
|
result.readWriteSet = sync.OnceValues(result.unmarshalReadWriteSet)
|
|
return result
|
|
}
|
|
|
|
func (p *NamespaceReadWriteSet) Namespace() string {
|
|
return p.nsReadWriteSet.GetNamespace()
|
|
}
|
|
|
|
func (p *NamespaceReadWriteSet) ReadWriteSet() (*kvrwset.KVRWSet, error) {
|
|
return p.readWriteSet()
|
|
}
|
|
|
|
func (p *NamespaceReadWriteSet) ToProto() *rwset.NsReadWriteSet {
|
|
return p.nsReadWriteSet
|
|
}
|
|
|
|
func (p *NamespaceReadWriteSet) unmarshalReadWriteSet() (*kvrwset.KVRWSet, error) {
|
|
result := &kvrwset.KVRWSet{}
|
|
if err := proto.Unmarshal(p.nsReadWriteSet.GetRwset(), result); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return result, nil
|
|
}
|