mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2024-12-25 12:57:18 +00:00
2f02a2baa3
* Actually wire up exits * Merge branch 'master' into exit-fixes
453 lines
10 KiB
Go
453 lines
10 KiB
Go
package voluntaryexits
|
|
|
|
import (
|
|
"context"
|
|
"reflect"
|
|
"testing"
|
|
|
|
"github.com/gogo/protobuf/proto"
|
|
ethpb "github.com/prysmaticlabs/ethereumapis/eth/v1alpha1"
|
|
"github.com/prysmaticlabs/prysm/shared/params"
|
|
)
|
|
|
|
func TestPool_InsertVoluntaryExit(t *testing.T) {
|
|
type fields struct {
|
|
pending []*ethpb.SignedVoluntaryExit
|
|
included map[uint64]bool
|
|
}
|
|
type args struct {
|
|
exit *ethpb.SignedVoluntaryExit
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
fields fields
|
|
args args
|
|
want []*ethpb.SignedVoluntaryExit
|
|
}{
|
|
{
|
|
name: "Empty list",
|
|
fields: fields{
|
|
pending: make([]*ethpb.SignedVoluntaryExit, 0),
|
|
included: make(map[uint64]bool),
|
|
},
|
|
args: args{
|
|
exit: ðpb.SignedVoluntaryExit{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 12,
|
|
ValidatorIndex: 1,
|
|
},
|
|
},
|
|
},
|
|
want: []*ethpb.SignedVoluntaryExit{
|
|
{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 12,
|
|
ValidatorIndex: 1,
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
name: "Duplicate identical exit",
|
|
fields: fields{
|
|
pending: []*ethpb.SignedVoluntaryExit{
|
|
{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 12,
|
|
ValidatorIndex: 1,
|
|
},
|
|
},
|
|
},
|
|
included: make(map[uint64]bool),
|
|
},
|
|
args: args{
|
|
exit: ðpb.SignedVoluntaryExit{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 12,
|
|
ValidatorIndex: 1,
|
|
},
|
|
},
|
|
},
|
|
want: []*ethpb.SignedVoluntaryExit{
|
|
{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 12,
|
|
ValidatorIndex: 1,
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
name: "Duplicate exit with lower epoch",
|
|
fields: fields{
|
|
pending: []*ethpb.SignedVoluntaryExit{
|
|
{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 12,
|
|
ValidatorIndex: 1,
|
|
},
|
|
},
|
|
},
|
|
included: make(map[uint64]bool),
|
|
},
|
|
args: args{
|
|
exit: ðpb.SignedVoluntaryExit{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 10,
|
|
ValidatorIndex: 1,
|
|
},
|
|
},
|
|
},
|
|
want: []*ethpb.SignedVoluntaryExit{
|
|
{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 10,
|
|
ValidatorIndex: 1,
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
name: "Exit for already exited validator",
|
|
fields: fields{
|
|
pending: []*ethpb.SignedVoluntaryExit{},
|
|
included: make(map[uint64]bool),
|
|
},
|
|
args: args{
|
|
exit: ðpb.SignedVoluntaryExit{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 12,
|
|
ValidatorIndex: 2,
|
|
},
|
|
},
|
|
},
|
|
want: []*ethpb.SignedVoluntaryExit{},
|
|
},
|
|
{
|
|
name: "Maintains sorted order",
|
|
fields: fields{
|
|
pending: []*ethpb.SignedVoluntaryExit{
|
|
{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 12,
|
|
ValidatorIndex: 0,
|
|
},
|
|
},
|
|
{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 12,
|
|
ValidatorIndex: 2,
|
|
},
|
|
},
|
|
},
|
|
included: make(map[uint64]bool),
|
|
},
|
|
args: args{
|
|
exit: ðpb.SignedVoluntaryExit{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 10,
|
|
ValidatorIndex: 1,
|
|
},
|
|
},
|
|
},
|
|
want: []*ethpb.SignedVoluntaryExit{
|
|
{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 12,
|
|
ValidatorIndex: 0,
|
|
},
|
|
},
|
|
{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 10,
|
|
ValidatorIndex: 1,
|
|
},
|
|
},
|
|
{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 12,
|
|
ValidatorIndex: 2,
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
name: "Already included",
|
|
fields: fields{
|
|
pending: make([]*ethpb.SignedVoluntaryExit, 0),
|
|
included: map[uint64]bool{
|
|
1: true,
|
|
},
|
|
},
|
|
args: args{
|
|
exit: ðpb.SignedVoluntaryExit{
|
|
Exit: ðpb.VoluntaryExit{
|
|
Epoch: 12,
|
|
ValidatorIndex: 1,
|
|
},
|
|
},
|
|
},
|
|
want: []*ethpb.SignedVoluntaryExit{},
|
|
},
|
|
}
|
|
ctx := context.Background()
|
|
validators := []*ethpb.Validator{
|
|
{ // 0
|
|
ExitEpoch: params.BeaconConfig().FarFutureEpoch,
|
|
},
|
|
{ // 1
|
|
ExitEpoch: params.BeaconConfig().FarFutureEpoch,
|
|
},
|
|
{ // 2 - Already exited.
|
|
ExitEpoch: 15,
|
|
},
|
|
{ // 3
|
|
ExitEpoch: params.BeaconConfig().FarFutureEpoch,
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
p := &Pool{
|
|
pending: tt.fields.pending,
|
|
included: tt.fields.included,
|
|
}
|
|
p.InsertVoluntaryExit(ctx, validators, tt.args.exit)
|
|
if len(p.pending) != len(tt.want) {
|
|
t.Fatalf("Mismatched lengths of pending list. Got %d, wanted %d.", len(p.pending), len(tt.want))
|
|
}
|
|
for i := range p.pending {
|
|
if !proto.Equal(p.pending[i], tt.want[i]) {
|
|
t.Errorf("Pending exit at index %d does not match expected. Got=%v wanted=%v", i, p.pending[i], tt.want[i])
|
|
}
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestPool_MarkIncluded(t *testing.T) {
|
|
type fields struct {
|
|
pending []*ethpb.SignedVoluntaryExit
|
|
included map[uint64]bool
|
|
}
|
|
type args struct {
|
|
exit *ethpb.SignedVoluntaryExit
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
fields fields
|
|
args args
|
|
want fields
|
|
}{
|
|
{
|
|
name: "Included, does not exist in pending",
|
|
fields: fields{
|
|
pending: []*ethpb.SignedVoluntaryExit{
|
|
{
|
|
Exit: ðpb.VoluntaryExit{ValidatorIndex: 2},
|
|
},
|
|
},
|
|
included: make(map[uint64]bool),
|
|
},
|
|
args: args{
|
|
exit: ðpb.SignedVoluntaryExit{
|
|
Exit: ðpb.VoluntaryExit{ValidatorIndex: 3},
|
|
},
|
|
},
|
|
want: fields{
|
|
pending: []*ethpb.SignedVoluntaryExit{
|
|
{
|
|
Exit: ðpb.VoluntaryExit{ValidatorIndex: 2},
|
|
},
|
|
},
|
|
included: map[uint64]bool{
|
|
3: true,
|
|
},
|
|
},
|
|
},
|
|
{
|
|
name: "Removes from pending list",
|
|
fields: fields{
|
|
pending: []*ethpb.SignedVoluntaryExit{
|
|
{
|
|
Exit: ðpb.VoluntaryExit{ValidatorIndex: 1},
|
|
},
|
|
{
|
|
Exit: ðpb.VoluntaryExit{ValidatorIndex: 2},
|
|
},
|
|
{
|
|
Exit: ðpb.VoluntaryExit{ValidatorIndex: 3},
|
|
},
|
|
},
|
|
included: map[uint64]bool{
|
|
0: true,
|
|
},
|
|
},
|
|
args: args{
|
|
exit: ðpb.SignedVoluntaryExit{
|
|
Exit: ðpb.VoluntaryExit{ValidatorIndex: 2},
|
|
},
|
|
},
|
|
want: fields{
|
|
pending: []*ethpb.SignedVoluntaryExit{
|
|
{
|
|
Exit: ðpb.VoluntaryExit{ValidatorIndex: 1},
|
|
},
|
|
{
|
|
Exit: ðpb.VoluntaryExit{ValidatorIndex: 3},
|
|
},
|
|
},
|
|
included: map[uint64]bool{
|
|
0: true,
|
|
2: true,
|
|
},
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
p := &Pool{
|
|
pending: tt.fields.pending,
|
|
included: tt.fields.included,
|
|
}
|
|
p.MarkIncluded(tt.args.exit)
|
|
if len(p.pending) != len(tt.want.pending) {
|
|
t.Fatalf("Mismatched lengths of pending list. Got %d, wanted %d.", len(p.pending), len(tt.want.pending))
|
|
}
|
|
for i := range p.pending {
|
|
if !proto.Equal(p.pending[i], tt.want.pending[i]) {
|
|
t.Errorf("Pending exit at index %d does not match expected. Got=%v wanted=%v", i, p.pending[i], tt.want.pending[i])
|
|
}
|
|
}
|
|
if !reflect.DeepEqual(p.included, tt.want.included) {
|
|
t.Errorf("Included map is not as expected. Got=%v wanted=%v", p.included, tt.want.included)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestPool_PendingExits(t *testing.T) {
|
|
type fields struct {
|
|
pending []*ethpb.SignedVoluntaryExit
|
|
}
|
|
type args struct {
|
|
slot uint64
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
fields fields
|
|
args args
|
|
want []*ethpb.SignedVoluntaryExit
|
|
}{
|
|
{
|
|
name: "Empty list",
|
|
fields: fields{
|
|
pending: []*ethpb.SignedVoluntaryExit{},
|
|
},
|
|
args: args{
|
|
slot: 100000,
|
|
},
|
|
want: []*ethpb.SignedVoluntaryExit{},
|
|
},
|
|
{
|
|
name: "All eligible",
|
|
fields: fields{
|
|
pending: []*ethpb.SignedVoluntaryExit{
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 0}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 1}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 2}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 3}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 4}},
|
|
},
|
|
},
|
|
args: args{
|
|
slot: 1000000,
|
|
},
|
|
want: []*ethpb.SignedVoluntaryExit{
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 0}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 1}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 2}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 3}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 4}},
|
|
},
|
|
},
|
|
{
|
|
name: "All eligible, more than max",
|
|
fields: fields{
|
|
pending: []*ethpb.SignedVoluntaryExit{
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 0}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 1}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 2}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 3}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 4}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 5}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 6}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 7}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 8}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 9}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 10}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 11}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 12}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 13}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 14}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 15}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 16}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 17}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 18}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 19}},
|
|
},
|
|
},
|
|
args: args{
|
|
slot: 1000000,
|
|
},
|
|
want: []*ethpb.SignedVoluntaryExit{
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 0}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 1}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 2}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 3}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 4}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 5}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 6}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 7}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 8}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 9}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 10}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 11}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 12}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 13}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 14}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 15}},
|
|
},
|
|
},
|
|
{
|
|
name: "Some eligible",
|
|
fields: fields{
|
|
pending: []*ethpb.SignedVoluntaryExit{
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 0}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 3}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 4}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 2}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 1}},
|
|
},
|
|
},
|
|
args: args{
|
|
slot: 2 * params.BeaconConfig().SlotsPerEpoch,
|
|
},
|
|
want: []*ethpb.SignedVoluntaryExit{
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 0}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 2}},
|
|
{Exit: ðpb.VoluntaryExit{Epoch: 1}},
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
p := &Pool{
|
|
pending: tt.fields.pending,
|
|
}
|
|
if got := p.PendingExits(tt.args.slot); !reflect.DeepEqual(got, tt.want) {
|
|
t.Errorf("PendingExits() = %v, want %v", got, tt.want)
|
|
}
|
|
})
|
|
}
|
|
}
|