mirror of
https://github.com/filecoin-project/lotus.git
synced 2025-08-23 16:55:22 +08:00
e16e08a7a6
* fix(drand): `StateGetBeaconEntry` uses chain beacons for historical epochs Fixes: https://github.com/filecoin-project/lotus/issues/12414 Previously StateGetBeaconEntry would always try and use a drand beacon to get the appropriate round. But as drand has shut down old beacons and we've removed client details from Lotus, it has stopped working for historical beacons. This fix restores historical beacon entries by using the on-chain lookup, however it now follows the rules used by StateGetRandomnessFromBeacon and the get_beacon_randomness syscall which has some quirks with null rounds prior to nv14. See https://github.com/filecoin-project/lotus/issues/12414#issuecomment-2320034935 for specifics. StateGetBeaconEntry still blocks for future epochs and uses live drand beacon clients to wait for and fetch rounds as they are available. * fixup! fix(drand): `StateGetBeaconEntry` uses chain beacons for historical epochs * fixup! fix(drand): `StateGetBeaconEntry` uses chain beacons for historical epochs
89 lines
2.5 KiB
Go
89 lines
2.5 KiB
Go
package conformance
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/filecoin-project/go-state-types/abi"
|
|
"github.com/filecoin-project/test-vectors/schema"
|
|
|
|
"github.com/filecoin-project/lotus/chain/rand"
|
|
"github.com/filecoin-project/lotus/chain/types"
|
|
)
|
|
|
|
type ReplayingRand struct {
|
|
reporter Reporter
|
|
recorded schema.Randomness
|
|
fallback rand.Rand
|
|
}
|
|
|
|
var _ rand.Rand = (*ReplayingRand)(nil)
|
|
|
|
// NewReplayingRand replays recorded randomness when requested, falling back to
|
|
// fixed randomness if the value cannot be found; hence this is a safe
|
|
// backwards-compatible replacement for fixedRand.
|
|
func NewReplayingRand(reporter Reporter, recorded schema.Randomness) *ReplayingRand {
|
|
return &ReplayingRand{
|
|
reporter: reporter,
|
|
recorded: recorded,
|
|
fallback: NewFixedRand(),
|
|
}
|
|
}
|
|
|
|
func (r *ReplayingRand) match(requested schema.RandomnessRule) ([32]byte, bool) {
|
|
for _, other := range r.recorded {
|
|
if other.On.Kind == requested.Kind &&
|
|
other.On.Epoch == requested.Epoch {
|
|
return *(*[32]byte)(other.Return), true
|
|
}
|
|
}
|
|
return [32]byte{}, false
|
|
}
|
|
|
|
func (r *ReplayingRand) GetChainRandomness(ctx context.Context, round abi.ChainEpoch) ([32]byte, error) {
|
|
rule := schema.RandomnessRule{
|
|
Kind: schema.RandomnessChain,
|
|
Epoch: int64(round),
|
|
}
|
|
|
|
if ret, ok := r.match(rule); ok {
|
|
r.reporter.Logf("returning saved chain randomness: epoch=%d, result=%x", round, ret)
|
|
return ret, nil
|
|
}
|
|
|
|
r.reporter.Logf("returning fallback chain randomness: epoch=%d", round)
|
|
|
|
return r.fallback.GetChainRandomness(ctx, round)
|
|
}
|
|
|
|
func (r *ReplayingRand) GetBeaconRandomness(ctx context.Context, round abi.ChainEpoch) ([32]byte, error) {
|
|
rule := schema.RandomnessRule{
|
|
Kind: schema.RandomnessBeacon,
|
|
Epoch: int64(round),
|
|
}
|
|
|
|
if ret, ok := r.match(rule); ok {
|
|
r.reporter.Logf("returning saved beacon randomness: epoch=%d, result=%x", round, ret)
|
|
return ret, nil
|
|
}
|
|
|
|
r.reporter.Logf("returning fallback beacon randomness: epoch=%d, ", round)
|
|
|
|
return r.fallback.GetBeaconRandomness(ctx, round)
|
|
}
|
|
|
|
func (r *ReplayingRand) GetBeaconEntry(ctx context.Context, round abi.ChainEpoch) (*types.BeaconEntry, error) {
|
|
rule := schema.RandomnessRule{
|
|
Kind: schema.RandomnessBeacon,
|
|
Epoch: int64(round),
|
|
}
|
|
|
|
if ret, ok := r.match(rule); ok {
|
|
r.reporter.Logf("returning saved beacon randomness: epoch=%d, result=%x", round, ret)
|
|
return &types.BeaconEntry{Round: 10, Data: ret[:]}, nil
|
|
}
|
|
|
|
r.reporter.Logf("returning fallback beacon randomness: epoch=%d, ", round)
|
|
|
|
return r.fallback.GetBeaconEntry(ctx, round)
|
|
}
|