coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-02-21 10:27:26 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

add simple reapplication logic

Browse Source
This commit is contained in:
Cassandra Heart 2024-11-07 13:14:12 -06:00
parent 9bc8a84f1a
commit 5c924eab68
No known key found for this signature in database
GPG Key ID: 6352152859385958
1 changed files with 36 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
node/consensus/data/consensus_frames.go
View File

@ -3,6 +3,7 @@ package data
import (
"bytes"
"context"
"encoding/binary"
"time"
"golang.org/x/crypto/sha3"
@ -107,6 +108,41 @@ func (e *DataClockConsensusEngine) prove(
zap.Int("failed", len(invalidTransactions.Requests)),
)
e.stagedTransactions = &protobufs.TokenRequests{}
// reapply failed mints caused by two sends in the same frame
minters := map[string]uint64{}
for _, suc := range validTransactions.Requests {
switch t := suc.Request.(type) {
case *protobufs.TokenRequest_Mint:
if len(t.Mint.Proofs) >= 3 {
minters[string(t.Mint.Signature.PublicKey.KeyValue)] =
binary.BigEndian.Uint64(t.Mint.Proofs[2])
}
}
}
next := map[string]*protobufs.TokenRequest{}
for _, inv := range invalidTransactions.Requests {
switch t := inv.Request.(type) {
case *protobufs.TokenRequest_Mint:
if t.Mint != nil && t.Mint.Signature != nil &&
t.Mint.Signature.PublicKey != nil &&
t.Mint.Signature.PublicKey.KeyValue != nil && len(t.Mint.Proofs) >= 3 {
frameNumber := binary.BigEndian.Uint64(t.Mint.Proofs[2])
if priorFrame, ok := minters[string(
t.Mint.Signature.PublicKey.KeyValue,
)]; ok && priorFrame < frameNumber {
next[string(
t.Mint.Signature.PublicKey.KeyValue,
)] = inv
}
}
}
}
for _, v := range next {
e.stagedTransactions.Requests = append(
e.stagedTransactions.Requests,
v,
)
}
e.stagedTransactionsMx.Unlock()
outputState, err := app.MaterializeStateFromApplication()