This repository has been archived by the owner on Apr 2, 2024. It is now read-only.
generated from mrz1836/go-template
-
-
Notifications
You must be signed in to change notification settings - Fork 7
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: Retrieveing Merkle proofs from mAPI and Calculation of Compound…
… Merkle Path
- Loading branch information
vitalibalashka
committed
Sep 8, 2023
1 parent
7567cd0
commit 582fa40
Showing
10 changed files
with
604 additions
and
39 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,127 @@ | ||
| package bux | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "database/sql/driver" | ||
| "encoding/json" | ||
| "errors" | ||
| "fmt" | ||
| "reflect" | ||
| "sort" | ||
| ) | ||
|
|
||
| // CompoundMerklePath represents Compound Merkle Path type | ||
| type CompoundMerklePath []map[string]uint64 | ||
|
|
||
| // CMPSlice represents slice of Compound Merkle Pathes | ||
| // There must be several CMPs in case if utxos from different blocks is used in tx | ||
| type CMPSlice []CompoundMerklePath | ||
|
|
||
| type nodeOffset struct { | ||
| node string | ||
| offset uint64 | ||
| } | ||
|
|
||
| // Hex returns CMP in hex format | ||
| func (cmp *CompoundMerklePath) Hex() string { | ||
| var hex bytes.Buffer | ||
| hex.WriteString(leadingZeroInt(len(*cmp))) | ||
|
|
||
| for _, m := range *cmp { | ||
| hex.WriteString(leadingZeroInt(len(m))) | ||
| sortedNodes := sortByOffset(m) | ||
| for _, n := range sortedNodes { | ||
| hex.WriteString(leadingZeroInt(int(n.offset))) | ||
| hex.WriteString(n.node) | ||
| } | ||
| } | ||
| return hex.String() | ||
| } | ||
|
|
||
| func sortByOffset(m map[string]uint64) []nodeOffset { | ||
| n := make([]nodeOffset, 0) | ||
| for node, offset := range m { | ||
| n = append(n, nodeOffset{node, offset}) | ||
| } | ||
| sort.Slice(n, func(i, j int) bool { | ||
| return n[i].offset < n[j].offset | ||
| }) | ||
| return n | ||
| } | ||
|
|
||
| // CalculateCompoundMerklePath calculates CMP from a slice of Merkle Proofs | ||
| func CalculateCompoundMerklePath(mp []MerkleProof) (CompoundMerklePath, error) { | ||
| if len(mp) == 0 || mp == nil { | ||
| return CompoundMerklePath{}, nil | ||
| } | ||
| height := len(mp[0].Nodes) | ||
| for _, m := range mp { | ||
| if height != len(m.Nodes) { | ||
| return nil, | ||
| errors.New("Compound Merkle Path cannot be obtained from Merkle Proofs of different heights") | ||
| } | ||
| } | ||
| cmp := make(CompoundMerklePath, height) | ||
| for _, m := range mp { | ||
| cmpToAdd := m.ToCompoundMerklePath() | ||
| err := cmp.add(cmpToAdd) | ||
| if err != nil { | ||
| return CompoundMerklePath{}, err | ||
| } | ||
| } | ||
| return cmp, nil | ||
| } | ||
|
|
||
| // In case the offset or height is less than 10, they must be written with a leading zero | ||
| func leadingZeroInt(i int) string { | ||
| return fmt.Sprintf("%02d", i) | ||
| } | ||
|
|
||
| func (cmp *CompoundMerklePath) add(c CompoundMerklePath) error { | ||
| if len(*cmp) != len(c) { | ||
| return errors.New("Compound Merkle Path with different height cannot be added") | ||
| } | ||
| for i := range c { | ||
| for k, v := range c[i] { | ||
| if (*cmp)[i] == nil { | ||
| (*cmp)[i] = c[i] | ||
| break | ||
| } | ||
| (*cmp)[i][k] = v | ||
| } | ||
| } | ||
| return nil | ||
| } | ||
|
|
||
| // Scan scan value into Json, implements sql.Scanner interface | ||
| func (cmps *CMPSlice) Scan(value interface{}) error { | ||
| if value == nil { | ||
| return nil | ||
| } | ||
|
|
||
| xType := fmt.Sprintf("%T", value) | ||
| var byteValue []byte | ||
| if xType == ValueTypeString { | ||
| byteValue = []byte(value.(string)) | ||
| } else { | ||
| byteValue = value.([]byte) | ||
| } | ||
| if bytes.Equal(byteValue, []byte("")) || bytes.Equal(byteValue, []byte("\"\"")) { | ||
| return nil | ||
| } | ||
|
|
||
| return json.Unmarshal(byteValue, &cmps) | ||
| } | ||
|
|
||
| // Value return json value, implement driver.Valuer interface | ||
| func (cmps CMPSlice) Value() (driver.Value, error) { | ||
| if reflect.DeepEqual(cmps, CMPSlice{}) { | ||
| return nil, nil | ||
| } | ||
| marshal, err := json.Marshal(cmps) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| return string(marshal), nil | ||
| } |
Oops, something went wrong.