forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-28 07:36:44 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Updated to really use Firehose protocol 3.0

Browse source
This commit is contained in:
Matthieu Vachon 2024-01-10 21:28:08 -05:00
parent 8677894b94
commit 4862eeba1d
1 changed files with 17 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
eth/tracers/firehose.go
View file

@ -937,10 +937,25 @@ func (f *Firehose) printBlockToFirehose(block *pbeth.Block, finalityStatus *Fina
f.outputBuffer.Reset()
libNum, libID := finalityStatus.ToFirehoseLogParams()
previousHash := block.PreviousID()
previousNum := 0
if block.Number > 0 {
previousNum = int(block.Number) - 1
}
libNum := finalityStatus.LastIrreversibleBlockNumber
if finalityStatus.IsEmpty() {
// FIXME: We should have access to the genesis block to perform this operation to ensure we never go below the
// the genesis block
if block.Number >= 200 {
libNum = block.Number - 200
} else {
libNum = 0
}
}
// **Important* The final space in the Sprintf template is mandatory!
f.outputBuffer.WriteString(fmt.Sprintf("FIRE BLOCK %d %s %s %s ", block.Number, hex.EncodeToString(block.Hash), libNum, libID))
f.outputBuffer.WriteString(fmt.Sprintf("FIRE BLOCK %d %s %d %s %d %d ", block.Number, hex.EncodeToString(block.Hash), previousNum, previousHash, libNum, block.MustTime().UnixNano()))
encoder := base64.NewEncoder(base64.StdEncoding, f.outputBuffer)
if _, err = encoder.Write(marshalled); err != nil {
@ -1532,16 +1547,6 @@ func (s *FinalityStatus) populateFromChain(finalHeader *types.Header) {
s.LastIrreversibleBlockHash = finalHeader.Hash().Bytes()
}
// ToFirehoseLogParams converts the data into the format expected by Firehose reader,
// replacing the value with "." if the data is empty.
func (s *FinalityStatus) ToFirehoseLogParams() (libNum, libID string) {
if s.IsEmpty() {
return ".", "."
}
return strconv.FormatUint(s.LastIrreversibleBlockNumber, 10), hex.EncodeToString(s.LastIrreversibleBlockHash)
}
func (s *FinalityStatus) Reset() {
s.LastIrreversibleBlockNumber = 0
s.LastIrreversibleBlockHash = nil