66 lines
1.7 KiB
Go
66 lines
1.7 KiB
Go
package fakebeacon
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
"math/rand"
|
|
"time"
|
|
|
|
"github.com/ethereum/go-ethereum/core/types"
|
|
"github.com/ethereum/go-ethereum/internal/ethapi"
|
|
"github.com/ethereum/go-ethereum/rpc"
|
|
)
|
|
|
|
func fetchBlockNumberByTime(ctx context.Context, ts int64, backend ethapi.Backend) (*types.Header, error) {
|
|
// calc the block number of the ts.
|
|
currentHeader := backend.CurrentHeader()
|
|
blockTime := int64(currentHeader.Time)
|
|
if ts > blockTime {
|
|
return nil, errors.New("time too large")
|
|
}
|
|
blockNum := currentHeader.Number.Uint64()
|
|
estimateEndNumber := int64(blockNum) - (blockTime-ts)/3
|
|
// find the end number
|
|
for {
|
|
header, err := backend.HeaderByNumber(ctx, rpc.BlockNumber(estimateEndNumber))
|
|
if err != nil {
|
|
time.Sleep(time.Duration(rand.Int()%180) * time.Millisecond)
|
|
continue
|
|
}
|
|
if header == nil {
|
|
estimateEndNumber -= 1
|
|
time.Sleep(time.Duration(rand.Int()%180) * time.Millisecond)
|
|
continue
|
|
}
|
|
headerTime := int64(header.Time)
|
|
if headerTime == ts {
|
|
return header, nil
|
|
}
|
|
|
|
// let the estimateEndNumber a little bigger than real value
|
|
if headerTime > ts+8 {
|
|
estimateEndNumber -= (headerTime - ts) / 3
|
|
} else if headerTime < ts {
|
|
estimateEndNumber += (ts-headerTime)/3 + 1
|
|
} else {
|
|
// search one by one
|
|
for headerTime >= ts {
|
|
header, err = backend.HeaderByNumber(ctx, rpc.BlockNumber(estimateEndNumber-1))
|
|
if err != nil {
|
|
time.Sleep(time.Duration(rand.Int()%180) * time.Millisecond)
|
|
continue
|
|
}
|
|
headerTime = int64(header.Time)
|
|
if headerTime == ts {
|
|
return header, nil
|
|
}
|
|
estimateEndNumber -= 1
|
|
if headerTime < ts { //found the real endNumber
|
|
return nil, fmt.Errorf("block not found by time %d", ts)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|