LBRYCommunity/herald.go
1
0
Fork 0
Code Issues 16 Pull requests Projects Releases 14 Packages Wiki Activity

Add struct field annotations and refactor to prepare for

Browse source 
use of "restruct" generic packing/unpacking.
This commit is contained in:
Jonathan Moody 2022-08-09 22:42:13 -04:00
parent 0c1840c09c
commit 1e467a715f
1 changed files with 174 additions and 118 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

232
db/prefixes/prefixes.go
View file

@ -129,8 +129,44 @@ type ValueUnpacker interface {
UnpackValue(buf []byte) UnpackValue(buf []byte)
} }
type LengthEncodedName struct {
NameLen uint16 `struct:"sizeof=Name"`
Name string `json:"name"`
}
func NewLengthEncodedName(s string) LengthEncodedName {
return LengthEncodedName{
NameLen: uint16(len(s)),
Name: s,
}
}
type LengthEncodedNormalizedName struct {
NormalizedNameLen uint16 `struct:"sizeof=NormalizedName"`
NormalizedName string `json:"normalized_name"`
}
func NewLengthEncodedNormalizedName(s string) LengthEncodedNormalizedName {
return LengthEncodedNormalizedName{
NormalizedNameLen: uint16(len(s)),
NormalizedName: s,
}
}
type LengthEncodedPartialClaimId struct {
PartialClaimIdLen uint8 `struct:"sizeof=PartialClaimId"`
PartialClaimId string `json:"partial_claim_id"`
}
func NewLengthEncodedPartialClaimId(s string) LengthEncodedPartialClaimId {
return LengthEncodedPartialClaimId{
PartialClaimIdLen: uint8(len(s)),
PartialClaimId: s,
}
}
type DBStateKey struct { type DBStateKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
} }
type DBStateValue struct { type DBStateValue struct {
@ -247,12 +283,12 @@ func DBStateValueUnpack(value []byte) *DBStateValue {
} }
type UndoKey struct { type UndoKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
Height uint64 `json:"height"` Height uint64 `json:"height"`
} }
type UndoValue struct { type UndoValue struct {
Data []byte `json:"data"` Data []byte `struct-while:"!_eof" json:"data"`
} }
func (k *UndoKey) PackKey() []byte { func (k *UndoKey) PackKey() []byte {
@ -327,8 +363,8 @@ func UndoValueUnpack(value []byte) *UndoValue {
} }
type UTXOKey struct { type UTXOKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
HashX []byte `json:"hashx"` HashX []byte `struct:"[11]byte" json:"hashx"`
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
Nout uint16 `json:"nout"` Nout uint16 `json:"nout"`
} }
@ -338,14 +374,14 @@ type UTXOValue struct {
} }
type HashXUTXOKey struct { type HashXUTXOKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
ShortTXHash []byte `json:"short_tx_hash"` ShortTXHash []byte `struct:"[4]byte" json:"short_tx_hash"`
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
Nout uint16 `json:"nout"` Nout uint16 `json:"nout"`
} }
type HashXUTXOValue struct { type HashXUTXOValue struct {
HashX []byte `json:"hashx"` HashX []byte `struct:"[11]byte" json:"hashx"`
} }
// //
@ -455,13 +491,13 @@ func HashXUTXOValueUnpack(value []byte) *HashXUTXOValue {
} }
type HashXHistoryKey struct { type HashXHistoryKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
HashX []byte `json:"hashx"` HashX []byte `struct:"[11]byte" json:"hashx"`
Height uint32 `json:"height"` Height uint32 `json:"height"`
} }
type HashXHistoryValue struct { type HashXHistoryValue struct {
HashXes []uint16 `json:"hashxes"` HashXes []uint16 `struct-while:"!_eof" json:"hashxes"`
} }
func (k *HashXHistoryKey) String() string { func (k *HashXHistoryKey) String() string {
@ -559,7 +595,7 @@ func HashXHistoryValueUnpack(value []byte) *HashXHistoryValue {
} }
type BlockHashKey struct { type BlockHashKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
Height uint32 `json:"height"` Height uint32 `json:"height"`
} }
@ -650,12 +686,12 @@ func BlockHashValueUnpack(value []byte) *BlockHashValue {
} }
type BlockTxsKey struct { type BlockTxsKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
Height uint32 `json:"height"` Height uint32 `json:"height"`
} }
type BlockTxsValue struct { type BlockTxsValue struct {
TxHashes []*chainhash.Hash `json:"tx_hashes"` TxHashes []*chainhash.Hash `struct-while:"!_eof" json:"tx_hashes"`
} }
func (k *BlockTxsKey) NewBlockTxsKey(height uint32) *BlockTxsKey { func (k *BlockTxsKey) NewBlockTxsKey(height uint32) *BlockTxsKey {
@ -749,7 +785,7 @@ func BlockTxsValueUnpack(value []byte) *BlockTxsValue {
} }
type TxCountKey struct { type TxCountKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
Height uint32 `json:"height"` Height uint32 `json:"height"`
} }
@ -834,7 +870,7 @@ func TxCountValueUnpack(value []byte) *TxCountValue {
} }
type TxHashKey struct { type TxHashKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
} }
@ -920,7 +956,7 @@ func TxHashValueUnpack(value []byte) *TxHashValue {
} }
type TxNumKey struct { type TxNumKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
TxHash *chainhash.Hash `json:"tx_hash"` TxHash *chainhash.Hash `json:"tx_hash"`
} }
@ -998,12 +1034,12 @@ func TxNumValueUnpack(value []byte) *TxNumValue {
} }
type TxKey struct { type TxKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
TxHash *chainhash.Hash `json:"tx_hash"` TxHash *chainhash.Hash `struct:"*[32]byte" json:"tx_hash"`
} }
type TxValue struct { type TxValue struct {
RawTx []byte `json:"raw_tx"` RawTx []byte `struct-while:"!_eof" json:"raw_tx"`
} }
func (k *TxKey) PackKey() []byte { func (k *TxKey) PackKey() []byte {
@ -1166,8 +1202,8 @@ func BlockHeaderValueUnpack(value []byte) *BlockHeaderValue {
} }
type ClaimToTXOKey struct { type ClaimToTXOKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
} }
type ClaimToTXOValue struct { type ClaimToTXOValue struct {
@ -1177,7 +1213,7 @@ type ClaimToTXOValue struct {
RootPosition uint16 `json:"root_position"` RootPosition uint16 `json:"root_position"`
Amount uint64 `json:"amount"` Amount uint64 `json:"amount"`
ChannelSignatureIsValid bool `json:"channel_signature_is_valid"` ChannelSignatureIsValid bool `json:"channel_signature_is_valid"`
Name string `json:"name"` LengthEncodedName
} }
func NewClaimToTXOKey(claimHash []byte) *ClaimToTXOKey { func NewClaimToTXOKey(claimHash []byte) *ClaimToTXOKey {
@ -1278,19 +1314,19 @@ func ClaimToTXOValueUnpack(value []byte) *ClaimToTXOValue {
RootPosition: binary.BigEndian.Uint16(value[10:]), RootPosition: binary.BigEndian.Uint16(value[10:]),
Amount: binary.BigEndian.Uint64(value[12:]), Amount: binary.BigEndian.Uint64(value[12:]),
ChannelSignatureIsValid: value[20] == 1, ChannelSignatureIsValid: value[20] == 1,
Name: string(value[23 : 23+nameLen]), LengthEncodedName: NewLengthEncodedName(string(value[23 : 23+nameLen])),
} }
} }
type TXOToClaimKey struct { type TXOToClaimKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
Position uint16 `json:"position"` Position uint16 `json:"position"`
} }
type TXOToClaimValue struct { type TXOToClaimValue struct {
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
Name string `json:"name"` LengthEncodedName
} }
func NewTXOToClaimKey(txNum uint32, position uint16) *TXOToClaimKey { func NewTXOToClaimKey(txNum uint32, position uint16) *TXOToClaimKey {
@ -1378,14 +1414,14 @@ func TXOToClaimValueUnpack(value []byte) *TXOToClaimValue {
nameLen := binary.BigEndian.Uint16(value[20:]) nameLen := binary.BigEndian.Uint16(value[20:])
return &TXOToClaimValue{ return &TXOToClaimValue{
ClaimHash: value[:20], ClaimHash: value[:20],
Name: string(value[22 : 22+nameLen]), LengthEncodedName: NewLengthEncodedName(string(value[22 : 22+nameLen])),
} }
} }
type ClaimShortIDKey struct { type ClaimShortIDKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
NormalizedName string `json:"normalized_name"` LengthEncodedNormalizedName // fields NormalizedNameLen, NormalizedName
PartialClaimId string `json:"partial_claim_id"` LengthEncodedPartialClaimId // fields PartialClaimIdLen, PartialClaimId
RootTxNum uint32 `json:"root_tx_num"` RootTxNum uint32 `json:"root_tx_num"`
RootPosition uint16 `json:"root_position"` RootPosition uint16 `json:"root_position"`
} }
@ -1398,8 +1434,8 @@ type ClaimShortIDValue struct {
func NewClaimShortIDKey(normalizedName, partialClaimId string) *ClaimShortIDKey { func NewClaimShortIDKey(normalizedName, partialClaimId string) *ClaimShortIDKey {
return &ClaimShortIDKey{ return &ClaimShortIDKey{
Prefix: []byte{ClaimShortIdPrefix}, Prefix: []byte{ClaimShortIdPrefix},
NormalizedName: normalizedName, LengthEncodedNormalizedName: NewLengthEncodedNormalizedName(normalizedName),
PartialClaimId: partialClaimId, LengthEncodedPartialClaimId: NewLengthEncodedPartialClaimId(partialClaimId),
} }
} }
@ -1490,8 +1526,8 @@ func ClaimShortIDKeyUnpack(key []byte) *ClaimShortIDKey {
partialClaimLen := int(uint8(key[prefixLen+2+nameLen])) partialClaimLen := int(uint8(key[prefixLen+2+nameLen]))
return &ClaimShortIDKey{ return &ClaimShortIDKey{
Prefix: key[:prefixLen], Prefix: key[:prefixLen],
NormalizedName: string(key[prefixLen+2 : prefixLen+2+nameLen]), LengthEncodedNormalizedName: NewLengthEncodedNormalizedName(string(key[prefixLen+2 : prefixLen+2+nameLen])),
PartialClaimId: string(key[prefixLen+2+nameLen+1 : prefixLen+2+nameLen+1+partialClaimLen]), LengthEncodedPartialClaimId: NewLengthEncodedPartialClaimId(string(key[prefixLen+2+nameLen+1 : prefixLen+2+nameLen+1+partialClaimLen])),
RootTxNum: binary.BigEndian.Uint32(key[prefixLen+2+nameLen+1+partialClaimLen:]), RootTxNum: binary.BigEndian.Uint32(key[prefixLen+2+nameLen+1+partialClaimLen:]),
RootPosition: binary.BigEndian.Uint16(key[prefixLen+2+nameLen+1+partialClaimLen+4:]), RootPosition: binary.BigEndian.Uint16(key[prefixLen+2+nameLen+1+partialClaimLen+4:]),
} }
@ -1505,8 +1541,8 @@ func ClaimShortIDValueUnpack(value []byte) *ClaimShortIDValue {
} }
type ClaimToChannelKey struct { type ClaimToChannelKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
Position uint16 `json:"position"` Position uint16 `json:"position"`
} }
@ -1607,22 +1643,22 @@ func ClaimToChannelValueUnpack(value []byte) *ClaimToChannelValue {
} }
type ChannelToClaimKey struct { type ChannelToClaimKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
SigningHash []byte `json:"signing_hash"` SigningHash []byte `struct:"[20]byte" json:"signing_hash"`
Name string `json:"name"` LengthEncodedName // fields NameLen, Name
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
Position uint16 `json:"position"` Position uint16 `json:"position"`
} }
type ChannelToClaimValue struct { type ChannelToClaimValue struct {
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
} }
func NewChannelToClaimKey(channelHash []byte, normalizedName string) *ChannelToClaimKey { func NewChannelToClaimKey(channelHash []byte, normalizedName string) *ChannelToClaimKey {
return &ChannelToClaimKey{ return &ChannelToClaimKey{
Prefix: []byte{ChannelToClaim}, Prefix: []byte{ChannelToClaim},
SigningHash: channelHash, SigningHash: channelHash,
Name: normalizedName, LengthEncodedName: NewLengthEncodedName(normalizedName),
} }
} }
@ -1712,7 +1748,7 @@ func ChannelToClaimKeyUnpack(key []byte) *ChannelToClaimKey {
return &ChannelToClaimKey{ return &ChannelToClaimKey{
Prefix: key[:prefixLen], Prefix: key[:prefixLen],
SigningHash: key[prefixLen : prefixLen+20], SigningHash: key[prefixLen : prefixLen+20],
Name: string(key[prefixLen+22 : prefixLen+22+nameLen]), LengthEncodedName: NewLengthEncodedName(string(key[prefixLen+22 : prefixLen+22+nameLen])),
TxNum: binary.BigEndian.Uint32(key[prefixLen+22+nameLen:]), TxNum: binary.BigEndian.Uint32(key[prefixLen+22+nameLen:]),
Position: binary.BigEndian.Uint16(key[prefixLen+22+nameLen+4:]), Position: binary.BigEndian.Uint16(key[prefixLen+22+nameLen+4:]),
} }
@ -1725,8 +1761,8 @@ func ChannelToClaimValueUnpack(value []byte) *ChannelToClaimValue {
} }
type ChannelCountKey struct { type ChannelCountKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
ChannelHash []byte `json:"channel_hash"` ChannelHash []byte `struct:"[20]byte" json:"channel_hash"`
} }
type ChannelCountValue struct { type ChannelCountValue struct {
@ -1810,8 +1846,8 @@ func ChannelCountValueUnpack(value []byte) *ChannelCountValue {
} }
type SupportAmountKey struct { type SupportAmountKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
} }
type SupportAmountValue struct { type SupportAmountValue struct {
@ -1895,8 +1931,8 @@ func SupportAmountValueUnpack(value []byte) *SupportAmountValue {
} }
type ClaimToSupportKey struct { type ClaimToSupportKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
Position uint16 `json:"position"` Position uint16 `json:"position"`
} }
@ -1988,13 +2024,13 @@ func ClaimToSupportValueUnpack(value []byte) *ClaimToSupportValue {
} }
type SupportToClaimKey struct { type SupportToClaimKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
Position uint16 `json:"position"` Position uint16 `json:"position"`
} }
type SupportToClaimValue struct { type SupportToClaimValue struct {
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
} }
func (k *SupportToClaimKey) PackKey() []byte { func (k *SupportToClaimKey) PackKey() []byte {
@ -2073,15 +2109,15 @@ func SupportToClaimValueUnpack(value []byte) *SupportToClaimValue {
} }
type ClaimExpirationKey struct { type ClaimExpirationKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
Expiration uint32 `json:"expiration"` Expiration uint32 `json:"expiration"`
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
Position uint16 `json:"position"` Position uint16 `json:"position"`
} }
type ClaimExpirationValue struct { type ClaimExpirationValue struct {
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
NormalizedName string `json:"normalized_name"` LengthEncodedNormalizedName // fields NormalizedNameLen, NormalizedName
} }
func (k *ClaimExpirationKey) PackKey() []byte { func (k *ClaimExpirationKey) PackKey() []byte {
@ -2168,24 +2204,24 @@ func ClaimExpirationValueUnpack(value []byte) *ClaimExpirationValue {
nameLen := binary.BigEndian.Uint16(value[20:]) nameLen := binary.BigEndian.Uint16(value[20:])
return &ClaimExpirationValue{ return &ClaimExpirationValue{
ClaimHash: value[:20], ClaimHash: value[:20],
NormalizedName: string(value[22 : 22+nameLen]), LengthEncodedNormalizedName: NewLengthEncodedNormalizedName(string(value[22 : 22+nameLen])),
} }
} }
type ClaimTakeoverKey struct { type ClaimTakeoverKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
NormalizedName string `json:"normalized_name"` LengthEncodedNormalizedName // fields NormalizedNameLen, NormalizedName
} }
type ClaimTakeoverValue struct { type ClaimTakeoverValue struct {
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
Height uint32 `json:"height"` Height uint32 `json:"height"`
} }
func NewClaimTakeoverKey(normalizedName string) *ClaimTakeoverKey { func NewClaimTakeoverKey(normalizedName string) *ClaimTakeoverKey {
return &ClaimTakeoverKey{ return &ClaimTakeoverKey{
Prefix: []byte{ClaimTakeover}, Prefix: []byte{ClaimTakeover},
NormalizedName: normalizedName, LengthEncodedNormalizedName: NewLengthEncodedNormalizedName(normalizedName),
} }
} }
@ -2263,7 +2299,7 @@ func ClaimTakeoverKeyUnpack(key []byte) *ClaimTakeoverKey {
nameLen := binary.BigEndian.Uint16(key[prefixLen:]) nameLen := binary.BigEndian.Uint16(key[prefixLen:])
return &ClaimTakeoverKey{ return &ClaimTakeoverKey{
Prefix: key[:prefixLen], Prefix: key[:prefixLen],
NormalizedName: string(key[prefixLen+2 : prefixLen+2+int(nameLen)]), LengthEncodedNormalizedName: NewLengthEncodedNormalizedName(string(key[prefixLen+2 : prefixLen+2+int(nameLen)])),
} }
} }
@ -2275,7 +2311,7 @@ func ClaimTakeoverValueUnpack(value []byte) *ClaimTakeoverValue {
} }
type PendingActivationKey struct { type PendingActivationKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
Height uint32 `json:"height"` Height uint32 `json:"height"`
TxoType uint8 `json:"txo_type"` TxoType uint8 `json:"txo_type"`
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
@ -2291,8 +2327,8 @@ func (k *PendingActivationKey) IsClaim() bool {
} }
type PendingActivationValue struct { type PendingActivationValue struct {
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
NormalizedName string `json:"normalized_name"` LengthEncodedNormalizedName // fields NormalizedNameLen, NormalizedName
} }
func (k *PendingActivationKey) PackKey() []byte { func (k *PendingActivationKey) PackKey() []byte {
@ -2385,12 +2421,12 @@ func PendingActivationValueUnpack(value []byte) *PendingActivationValue {
nameLen := binary.BigEndian.Uint16(value[20:]) nameLen := binary.BigEndian.Uint16(value[20:])
return &PendingActivationValue{ return &PendingActivationValue{
ClaimHash: value[:20], ClaimHash: value[:20],
NormalizedName: string(value[22 : 22+nameLen]), LengthEncodedNormalizedName: NewLengthEncodedNormalizedName(string(value[22 : 22+nameLen])),
} }
} }
type ActivationKey struct { type ActivationKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
TxoType uint8 `json:"txo_type"` TxoType uint8 `json:"txo_type"`
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
Position uint16 `json:"position"` Position uint16 `json:"position"`
@ -2398,8 +2434,8 @@ type ActivationKey struct {
type ActivationValue struct { type ActivationValue struct {
Height uint32 `json:"height"` Height uint32 `json:"height"`
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
NormalizedName string `json:"normalized_name"` LengthEncodedNormalizedName // fields NormalizedNameLen, NormalizedName
} }
func NewActivationKey(txoType uint8, txNum uint32, position uint16) *ActivationKey { func NewActivationKey(txoType uint8, txNum uint32, position uint16) *ActivationKey {
@ -2496,13 +2532,13 @@ func ActivationValueUnpack(value []byte) *ActivationValue {
return &ActivationValue{ return &ActivationValue{
Height: binary.BigEndian.Uint32(value), Height: binary.BigEndian.Uint32(value),
ClaimHash: value[4 : 20+4], ClaimHash: value[4 : 20+4],
NormalizedName: string(value[26 : 26+nameLen]), LengthEncodedNormalizedName: NewLengthEncodedNormalizedName(string(value[26 : 26+nameLen])),
} }
} }
type ActiveAmountKey struct { type ActiveAmountKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
TxoType uint8 `json:"txo_type"` TxoType uint8 `json:"txo_type"`
ActivationHeight uint32 `json:"activation_height"` ActivationHeight uint32 `json:"activation_height"`
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
@ -2616,22 +2652,38 @@ func ActiveAmountValueUnpack(value []byte) *ActiveAmountValue {
} }
} }
type OnesComplementEffectiveAmount uint64
func (amt *OnesComplementEffectiveAmount) SizeOf() int {
return 8
}
func (amt *OnesComplementEffectiveAmount) Pack(buf []byte, order binary.ByteOrder) ([]byte, error) {
binary.BigEndian.PutUint64(buf, OnesCompTwiddle64-uint64(*amt))
return buf[8:], nil
}
func (amt *OnesComplementEffectiveAmount) Unpack(buf []byte, order binary.ByteOrder) ([]byte, error) {
*amt = OnesComplementEffectiveAmount(OnesCompTwiddle64 - binary.BigEndian.Uint64(buf))
return buf[8:], nil
}
type EffectiveAmountKey struct { type EffectiveAmountKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
NormalizedName string `json:"normalized_name"` LengthEncodedNormalizedName // fields NormalizedNameLen, NormalizedName
EffectiveAmount uint64 `json:"effective_amount"` EffectiveAmount OnesComplementEffectiveAmount `json:"effective_amount"`
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
Position uint16 `json:"position"` Position uint16 `json:"position"`
} }
type EffectiveAmountValue struct { type EffectiveAmountValue struct {
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
} }
func NewEffectiveAmountKey(normalizedName string) *EffectiveAmountKey { func NewEffectiveAmountKey(normalizedName string) *EffectiveAmountKey {
return &EffectiveAmountKey{ return &EffectiveAmountKey{
Prefix: []byte{EffectiveAmount}, Prefix: []byte{EffectiveAmount},
NormalizedName: normalizedName, LengthEncodedNormalizedName: NewLengthEncodedNormalizedName(normalizedName),
} }
} }
@ -2647,7 +2699,7 @@ func (k *EffectiveAmountKey) PackKey() []byte {
binary.BigEndian.PutUint16(key[prefixLen:], uint16(nameLen)) binary.BigEndian.PutUint16(key[prefixLen:], uint16(nameLen))
copy(key[prefixLen+2:], []byte(k.NormalizedName)) copy(key[prefixLen+2:], []byte(k.NormalizedName))
binary.BigEndian.PutUint64(key[prefixLen+nameLenLen:], OnesCompTwiddle64-k.EffectiveAmount) binary.BigEndian.PutUint64(key[prefixLen+nameLenLen:], OnesCompTwiddle64-uint64(k.EffectiveAmount))
binary.BigEndian.PutUint32(key[prefixLen+nameLenLen+8:], k.TxNum) binary.BigEndian.PutUint32(key[prefixLen+nameLenLen+8:], k.TxNum)
binary.BigEndian.PutUint16(key[prefixLen+nameLenLen+8+4:], k.Position) binary.BigEndian.PutUint16(key[prefixLen+nameLenLen+8+4:], k.Position)
@ -2703,7 +2755,7 @@ func (k *EffectiveAmountKey) PartialPack(fields int) []byte {
binary.BigEndian.PutUint16(key[prefixLen:], uint16(nameLen)) binary.BigEndian.PutUint16(key[prefixLen:], uint16(nameLen))
copy(key[prefixLen+2:], []byte(k.NormalizedName)) copy(key[prefixLen+2:], []byte(k.NormalizedName))
case 2: case 2:
binary.BigEndian.PutUint64(key[prefixLen+nameLenLen:], OnesCompTwiddle64-k.EffectiveAmount) binary.BigEndian.PutUint64(key[prefixLen+nameLenLen:], OnesCompTwiddle64-uint64(k.EffectiveAmount))
case 3: case 3:
binary.BigEndian.PutUint32(key[prefixLen+nameLenLen+8:], k.TxNum) binary.BigEndian.PutUint32(key[prefixLen+nameLenLen+8:], k.TxNum)
case 4: case 4:
@ -2719,8 +2771,8 @@ func EffectiveAmountKeyUnpack(key []byte) *EffectiveAmountKey {
nameLen := binary.BigEndian.Uint16(key[prefixLen:]) nameLen := binary.BigEndian.Uint16(key[prefixLen:])
return &EffectiveAmountKey{ return &EffectiveAmountKey{
Prefix: key[:prefixLen], Prefix: key[:prefixLen],
NormalizedName: string(key[prefixLen+2 : prefixLen+2+int(nameLen)]), LengthEncodedNormalizedName: NewLengthEncodedNormalizedName(string(key[prefixLen+2 : prefixLen+2+int(nameLen)])),
EffectiveAmount: OnesCompTwiddle64 - binary.BigEndian.Uint64(key[prefixLen+2+int(nameLen):]), EffectiveAmount: OnesComplementEffectiveAmount(OnesCompTwiddle64 - binary.BigEndian.Uint64(key[prefixLen+2+int(nameLen):])),
TxNum: binary.BigEndian.Uint32(key[prefixLen+2+int(nameLen)+8:]), TxNum: binary.BigEndian.Uint32(key[prefixLen+2+int(nameLen)+8:]),
Position: binary.BigEndian.Uint16(key[prefixLen+2+int(nameLen)+8+4:]), Position: binary.BigEndian.Uint16(key[prefixLen+2+int(nameLen)+8+4:]),
} }
@ -2733,12 +2785,12 @@ func EffectiveAmountValueUnpack(value []byte) *EffectiveAmountValue {
} }
type RepostKey struct { type RepostKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
} }
type RepostValue struct { type RepostValue struct {
RepostedClaimHash []byte `json:"reposted_claim_hash"` RepostedClaimHash []byte `struct:"[20]byte" json:"reposted_claim_hash"`
} }
func NewRepostKey(claimHash []byte) *RepostKey { func NewRepostKey(claimHash []byte) *RepostKey {
@ -2820,14 +2872,14 @@ func RepostValueUnpack(value []byte) *RepostValue {
} }
type RepostedKey struct { type RepostedKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
RepostedClaimHash []byte `json:"reposted_claim_hash"` RepostedClaimHash []byte `struct:"[20]byte" json:"reposted_claim_hash"`
TxNum uint32 `json:"tx_num"` TxNum uint32 `json:"tx_num"`
Position uint16 `json:"position"` Position uint16 `json:"position"`
} }
type RepostedValue struct { type RepostedValue struct {
ClaimHash []byte `json:"claim_hash"` ClaimHash []byte `struct:"[20]byte" json:"claim_hash"`
} }
func NewRepostedKey(claimHash []byte) *RepostedKey { func NewRepostedKey(claimHash []byte) *RepostedKey {
@ -2920,13 +2972,15 @@ func RepostedValueUnpack(value []byte) *RepostedValue {
} }
type TouchedOrDeletedClaimKey struct { type TouchedOrDeletedClaimKey struct {
Prefix []byte `json:"prefix"` Prefix []byte `struct:"[1]byte" json:"prefix"`
Height int32 `json:"height"` Height int32 `json:"height"`
} }
type TouchedOrDeletedClaimValue struct { type TouchedOrDeletedClaimValue struct {
TouchedClaims [][]byte `json:"touched_claims"` TouchedClaimsLen uint32 `struct:"sizeof=TouchedClaims"`
DeletedClaims [][]byte `json:"deleted_claims"` DeletedClaimsLen uint32 `struct:"sizeof=DeletedClaims"`
TouchedClaims [][]byte `struct:"[][20]byte" json:"touched_claims"`
DeletedClaims [][]byte `struct:"[][20]byte" json:"deleted_claims"`
} }
func (v *TouchedOrDeletedClaimValue) String() string { func (v *TouchedOrDeletedClaimValue) String() string {
@ -3068,6 +3122,8 @@ func TouchedOrDeletedClaimValueUnpack(value []byte) *TouchedOrDeletedClaimValue
j += 20 j += 20
} }
return &TouchedOrDeletedClaimValue{ return &TouchedOrDeletedClaimValue{
TouchedClaimsLen: touchedLen,
DeletedClaimsLen: deletedLen,
TouchedClaims: touchedClaims, TouchedClaims: touchedClaims,
DeletedClaims: deletedClaims, DeletedClaims: deletedClaims,
} }