Skip to content

Commit

Permalink
use domainType instead of using domainTypeProvider
Browse files Browse the repository at this point in the history
  • Loading branch information
guy muroch committed Aug 8, 2024
1 parent 5cf2a51 commit d5809fd
Show file tree
Hide file tree
Showing 20 changed files with 114 additions and 117 deletions.
29 changes: 16 additions & 13 deletions operator/validator/controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -1418,7 +1418,8 @@ func SetupRunners(
}
config.ValueCheckF = valueCheckF

identifier := spectypes.NewMsgID(options.NetworkConfig.DomainType(), options.SSVShare.Share.ValidatorPubKey[:], role)
alanDomainType := options.NetworkConfig.AlanDomainType
identifier := spectypes.NewMsgID(alanDomainType, options.SSVShare.Share.ValidatorPubKey[:], role)
qbftCtrl := qbftcontroller.NewController(identifier[:], options.Operator, config, options.OperatorSigner, options.FullNode)
return qbftCtrl
}
Expand All @@ -1427,6 +1428,7 @@ func SetupRunners(
shareMap[options.SSVShare.ValidatorIndex] = &options.SSVShare.Share

runners := runner.ValidatorDutyRunners{}
alanDomainType := options.NetworkConfig.AlanDomainType
for _, role := range runnersType {
switch role {
//case spectypes.BNRoleAttester:
Expand All @@ -1436,23 +1438,23 @@ func SetupRunners(
case spectypes.RoleProposer:
proposedValueCheck := specssv.ProposerValueCheckF(options.Signer, options.NetworkConfig.Beacon.GetBeaconNetwork(), options.SSVShare.Share.ValidatorPubKey, options.SSVShare.BeaconMetadata.Index, options.SSVShare.SharePubKey)
qbftCtrl := buildController(spectypes.RoleProposer, proposedValueCheck)
runners[role] = runner.NewProposerRunner(options.NetworkConfig, options.NetworkConfig.Beacon.GetBeaconNetwork(), shareMap, qbftCtrl, options.Beacon, options.Network, options.Signer, options.OperatorSigner, proposedValueCheck, 0)
runners[role] = runner.NewProposerRunner(alanDomainType, options.NetworkConfig.Beacon.GetBeaconNetwork(), shareMap, qbftCtrl, options.Beacon, options.Network, options.Signer, options.OperatorSigner, proposedValueCheck, 0)
case spectypes.RoleAggregator:
aggregatorValueCheckF := specssv.AggregatorValueCheckF(options.Signer, options.NetworkConfig.Beacon.GetBeaconNetwork(), options.SSVShare.Share.ValidatorPubKey, options.SSVShare.BeaconMetadata.Index)
qbftCtrl := buildController(spectypes.RoleAggregator, aggregatorValueCheckF)
runners[role] = runner.NewAggregatorRunner(options.NetworkConfig, options.NetworkConfig.Beacon.GetBeaconNetwork(), shareMap, qbftCtrl, options.Beacon, options.Network, options.Signer, options.OperatorSigner, aggregatorValueCheckF, 0)
runners[role] = runner.NewAggregatorRunner(alanDomainType, options.NetworkConfig.Beacon.GetBeaconNetwork(), shareMap, qbftCtrl, options.Beacon, options.Network, options.Signer, options.OperatorSigner, aggregatorValueCheckF, 0)
//case spectypes.BNRoleSyncCommittee:
//syncCommitteeValueCheckF := specssv.SyncCommitteeValueCheckF(options.Signer, options.NetworkConfig.Beacon.GetBeaconNetwork(), options.SSVShare.ValidatorPubKey, options.SSVShare.BeaconMetadata.Index)
//qbftCtrl := buildController(spectypes.BNRoleSyncCommittee, syncCommitteeValueCheckF)
//runners[role] = runner.NewSyncCommitteeRunner(options.NetworkConfig, options.NetworkConfig.Beacon.GetBeaconNetwork(), &options.SSVShare.Share, qbftCtrl, options.Beacon, options.Network, options.Signer, options.OperatorSigner, syncCommitteeValueCheckF, 0)
case spectypes.RoleSyncCommitteeContribution:
syncCommitteeContributionValueCheckF := specssv.SyncCommitteeContributionValueCheckF(options.Signer, options.NetworkConfig.Beacon.GetBeaconNetwork(), options.SSVShare.Share.ValidatorPubKey, options.SSVShare.BeaconMetadata.Index)
qbftCtrl := buildController(spectypes.RoleSyncCommitteeContribution, syncCommitteeContributionValueCheckF)
runners[role] = runner.NewSyncCommitteeAggregatorRunner(options.NetworkConfig, options.NetworkConfig.Beacon.GetBeaconNetwork(), shareMap, qbftCtrl, options.Beacon, options.Network, options.Signer, options.OperatorSigner, syncCommitteeContributionValueCheckF, 0)
runners[role] = runner.NewSyncCommitteeAggregatorRunner(alanDomainType, options.NetworkConfig.Beacon.GetBeaconNetwork(), shareMap, qbftCtrl, options.Beacon, options.Network, options.Signer, options.OperatorSigner, syncCommitteeContributionValueCheckF, 0)
case spectypes.RoleValidatorRegistration:
runners[role] = runner.NewValidatorRegistrationRunner(options.NetworkConfig, options.NetworkConfig.Beacon.GetBeaconNetwork(), shareMap, options.Beacon, options.Network, options.Signer, options.OperatorSigner)
runners[role] = runner.NewValidatorRegistrationRunner(alanDomainType, options.NetworkConfig.Beacon.GetBeaconNetwork(), shareMap, options.Beacon, options.Network, options.Signer, options.OperatorSigner)
case spectypes.RoleVoluntaryExit:
runners[role] = runner.NewVoluntaryExitRunner(options.NetworkConfig, options.NetworkConfig.Beacon.GetBeaconNetwork(), shareMap, options.Beacon, options.Network, options.Signer, options.OperatorSigner)
runners[role] = runner.NewVoluntaryExitRunner(alanDomainType, options.NetworkConfig.Beacon.GetBeaconNetwork(), shareMap, options.Beacon, options.Network, options.Signer, options.OperatorSigner)
}
}
return runners
Expand Down Expand Up @@ -1501,34 +1503,35 @@ func SetupGenesisRunners(ctx context.Context, logger *zap.Logger, options valida
genesisBeaconNetwork := genesisspectypes.BeaconNetwork(options.NetworkConfig.Beacon.GetBeaconNetwork())

runners := genesisrunner.DutyRunners{}
genesisDomainType := options.NetworkConfig.GenesisDomainType
for _, role := range runnersType {
switch role {
case genesisspectypes.BNRoleAttester:
valCheck := genesisspecssv.AttesterValueCheckF(options.GenesisOptions.Signer, genesisBeaconNetwork, options.SSVShare.Share.ValidatorPubKey[:], options.SSVShare.BeaconMetadata.Index, options.SSVShare.SharePubKey)
qbftCtrl := buildController(genesisspectypes.BNRoleAttester, valCheck)
runners[role] = genesisrunner.NewAttesterRunnner(options.NetworkConfig, genesisBeaconNetwork, share, qbftCtrl, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer, valCheck, 0)
runners[role] = genesisrunner.NewAttesterRunnner(genesisDomainType, genesisBeaconNetwork, share, qbftCtrl, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer, valCheck, 0)
case genesisspectypes.BNRoleProposer:
proposedValueCheck := genesisspecssv.ProposerValueCheckF(options.GenesisOptions.Signer, genesisBeaconNetwork, options.SSVShare.Share.ValidatorPubKey[:], options.SSVShare.BeaconMetadata.Index, options.SSVShare.SharePubKey)
qbftCtrl := buildController(genesisspectypes.BNRoleProposer, proposedValueCheck)
runners[role] = genesisrunner.NewProposerRunner(options.NetworkConfig, genesisBeaconNetwork, share, qbftCtrl, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer, proposedValueCheck, 0)
runners[role] = genesisrunner.NewProposerRunner(genesisDomainType, genesisBeaconNetwork, share, qbftCtrl, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer, proposedValueCheck, 0)
runners[role].(*genesisrunner.ProposerRunner).ProducesBlindedBlocks = options.BuilderProposals // apply blinded block flag
case genesisspectypes.BNRoleAggregator:
aggregatorValueCheckF := genesisspecssv.AggregatorValueCheckF(options.GenesisOptions.Signer, genesisBeaconNetwork, options.SSVShare.Share.ValidatorPubKey[:], options.SSVShare.BeaconMetadata.Index)
qbftCtrl := buildController(genesisspectypes.BNRoleAggregator, aggregatorValueCheckF)
runners[role] = genesisrunner.NewAggregatorRunner(options.NetworkConfig, genesisBeaconNetwork, share, qbftCtrl, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer, aggregatorValueCheckF, 0)
runners[role] = genesisrunner.NewAggregatorRunner(genesisDomainType, genesisBeaconNetwork, share, qbftCtrl, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer, aggregatorValueCheckF, 0)
case genesisspectypes.BNRoleSyncCommittee:
syncCommitteeValueCheckF := genesisspecssv.SyncCommitteeValueCheckF(options.GenesisOptions.Signer, genesisBeaconNetwork, options.SSVShare.ValidatorPubKey[:], options.SSVShare.BeaconMetadata.Index)
qbftCtrl := buildController(genesisspectypes.BNRoleSyncCommittee, syncCommitteeValueCheckF)
runners[role] = genesisrunner.NewSyncCommitteeRunner(options.NetworkConfig, genesisBeaconNetwork, share, qbftCtrl, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer, syncCommitteeValueCheckF, 0)
runners[role] = genesisrunner.NewSyncCommitteeRunner(genesisDomainType, genesisBeaconNetwork, share, qbftCtrl, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer, syncCommitteeValueCheckF, 0)
case genesisspectypes.BNRoleSyncCommitteeContribution:
syncCommitteeContributionValueCheckF := genesisspecssv.SyncCommitteeContributionValueCheckF(options.GenesisOptions.Signer, genesisBeaconNetwork, options.SSVShare.Share.ValidatorPubKey[:], options.SSVShare.BeaconMetadata.Index)
qbftCtrl := buildController(genesisspectypes.BNRoleSyncCommitteeContribution, syncCommitteeContributionValueCheckF)
runners[role] = genesisrunner.NewSyncCommitteeAggregatorRunner(options.NetworkConfig, genesisBeaconNetwork, share, qbftCtrl, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer, syncCommitteeContributionValueCheckF, 0)
runners[role] = genesisrunner.NewSyncCommitteeAggregatorRunner(genesisDomainType, genesisBeaconNetwork, share, qbftCtrl, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer, syncCommitteeContributionValueCheckF, 0)
case genesisspectypes.BNRoleValidatorRegistration:
qbftCtrl := buildController(genesisspectypes.BNRoleValidatorRegistration, nil)
runners[role] = genesisrunner.NewValidatorRegistrationRunner(options.NetworkConfig, genesisBeaconNetwork, share, qbftCtrl, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer)
runners[role] = genesisrunner.NewValidatorRegistrationRunner(genesisDomainType, genesisBeaconNetwork, share, qbftCtrl, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer)
case genesisspectypes.BNRoleVoluntaryExit:
runners[role] = genesisrunner.NewVoluntaryExitRunner(options.NetworkConfig, genesisBeaconNetwork, share, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer)
runners[role] = genesisrunner.NewVoluntaryExitRunner(genesisDomainType, genesisBeaconNetwork, share, options.GenesisBeacon, options.GenesisOptions.Network, options.GenesisOptions.Signer)
}
}
return runners
Expand Down
6 changes: 3 additions & 3 deletions protocol/genesis/ssv/runner/aggregator.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ package runner
import (
"crypto/sha256"
"encoding/json"
spectypes "github.com/ssvlabs/ssv-spec/types"

"github.com/attestantio/go-eth2-client/spec/phase0"
ssz "github.com/ferranbt/fastssz"
Expand All @@ -13,7 +14,6 @@ import (
"go.uber.org/zap"

"github.com/ssvlabs/ssv/logging/fields"
"github.com/ssvlabs/ssv/networkconfig"
"github.com/ssvlabs/ssv/protocol/genesis/qbft/controller"
"github.com/ssvlabs/ssv/protocol/genesis/ssv/runner/metrics"
)
Expand All @@ -31,7 +31,7 @@ type AggregatorRunner struct {
var _ Runner = &AggregatorRunner{}

func NewAggregatorRunner(
domainTypeProvider networkconfig.DomainTypeProvider,
domainType spectypes.DomainType,
beaconNetwork genesisspectypes.BeaconNetwork,
share *genesisspectypes.Share,
qbftController *controller.Controller,
Expand All @@ -44,7 +44,7 @@ func NewAggregatorRunner(
return &AggregatorRunner{
BaseRunner: &BaseRunner{
BeaconRoleType: genesisspectypes.BNRoleAggregator,
DomainTypeProvider: domainTypeProvider,
DomainType: domainType,
BeaconNetwork: beaconNetwork,
Share: share,
QBFTController: qbftController,
Expand Down
8 changes: 4 additions & 4 deletions protocol/genesis/ssv/runner/attester.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ import (
"crypto/sha256"
"encoding/hex"
"encoding/json"
spectypes "github.com/ssvlabs/ssv-spec/types"
"time"

"github.com/attestantio/go-eth2-client/spec/phase0"
Expand All @@ -17,7 +18,6 @@ import (
"go.uber.org/zap"

"github.com/ssvlabs/ssv/logging/fields"
"github.com/ssvlabs/ssv/networkconfig"
"github.com/ssvlabs/ssv/protocol/genesis/qbft/controller"
"github.com/ssvlabs/ssv/protocol/genesis/ssv/runner/metrics"
)
Expand All @@ -35,7 +35,7 @@ type AttesterRunner struct {
}

func NewAttesterRunnner(
domainTypeProvider networkconfig.DomainTypeProvider,
domainType spectypes.DomainType,
beaconNetwork genesisspectypes.BeaconNetwork,
share *genesisspectypes.Share,
qbftController *controller.Controller,
Expand All @@ -48,7 +48,7 @@ func NewAttesterRunnner(
return &AttesterRunner{
BaseRunner: &BaseRunner{
BeaconRoleType: genesisspectypes.BNRoleAttester,
DomainTypeProvider: domainTypeProvider,
DomainType: domainType,
BeaconNetwork: beaconNetwork,
Share: share,
QBFTController: qbftController,
Expand Down Expand Up @@ -119,7 +119,7 @@ func (r *AttesterRunner) ProcessConsensus(logger *zap.Logger, signedMsg *genesis

msgToBroadcast := &genesisspectypes.SSVMessage{
MsgType: genesisspectypes.SSVPartialSignatureMsgType,
MsgID: genesisspectypes.NewMsgID(genesisspectypes.DomainType(r.BaseRunner.DomainTypeProvider.DomainType()), r.GetShare().ValidatorPubKey, r.BaseRunner.BeaconRoleType),
MsgID: genesisspectypes.NewMsgID(genesisspectypes.DomainType(r.BaseRunner.DomainType), r.GetShare().ValidatorPubKey, r.BaseRunner.BeaconRoleType),
Data: data,
}

Expand Down
6 changes: 3 additions & 3 deletions protocol/genesis/ssv/runner/proposer.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ import (
"crypto/sha256"
"encoding/json"
"fmt"
spectypes "github.com/ssvlabs/ssv-spec/types"
"time"

"github.com/attestantio/go-eth2-client/api"
Expand All @@ -23,7 +24,6 @@ import (
"github.com/attestantio/go-eth2-client/spec"

"github.com/ssvlabs/ssv/logging/fields"
"github.com/ssvlabs/ssv/networkconfig"
"github.com/ssvlabs/ssv/protocol/genesis/qbft/controller"
"github.com/ssvlabs/ssv/protocol/genesis/ssv/runner/metrics"
)
Expand All @@ -42,7 +42,7 @@ type ProposerRunner struct {
}

func NewProposerRunner(
domainTypeProvider networkconfig.DomainTypeProvider,
domainType spectypes.DomainType,
beaconNetwork genesisspectypes.BeaconNetwork,
share *genesisspectypes.Share,
qbftController *controller.Controller,
Expand All @@ -55,7 +55,7 @@ func NewProposerRunner(
return &ProposerRunner{
BaseRunner: &BaseRunner{
BeaconRoleType: genesisspectypes.BNRoleProposer,
DomainTypeProvider: domainTypeProvider,
DomainType: domainType,
BeaconNetwork: beaconNetwork,
Share: share,
QBFTController: qbftController,
Expand Down
16 changes: 8 additions & 8 deletions protocol/genesis/ssv/runner/runner.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package runner

import (
spectypes "github.com/ssvlabs/ssv-spec/types"
"sync"

spec "github.com/attestantio/go-eth2-client/spec/phase0"
Expand All @@ -11,7 +12,6 @@ import (
genesisspectypes "github.com/ssvlabs/ssv-spec-pre-cc/types"
"go.uber.org/zap"

"github.com/ssvlabs/ssv/networkconfig"
"github.com/ssvlabs/ssv/protocol/genesis/qbft/controller"
)

Expand Down Expand Up @@ -47,13 +47,13 @@ type Runner interface {
}

type BaseRunner struct {
mtx sync.RWMutex
State *State
Share *genesisspectypes.Share
QBFTController *controller.Controller
DomainTypeProvider networkconfig.DomainTypeProvider `json:"-"`
BeaconNetwork genesisspectypes.BeaconNetwork
BeaconRoleType genesisspectypes.BeaconRole
mtx sync.RWMutex
State *State
Share *genesisspectypes.Share
QBFTController *controller.Controller
DomainType spectypes.DomainType `json:"-"`
BeaconNetwork genesisspectypes.BeaconNetwork
BeaconRoleType genesisspectypes.BeaconRole

// implementation vars
TimeoutF TimeoutF `json:"-"`
Expand Down
6 changes: 3 additions & 3 deletions protocol/genesis/ssv/runner/sync_committee.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ import (
"crypto/sha256"
"encoding/hex"
"encoding/json"
spectypes "github.com/ssvlabs/ssv-spec/types"

"github.com/attestantio/go-eth2-client/spec/altair"
"github.com/attestantio/go-eth2-client/spec/phase0"
Expand All @@ -16,7 +17,6 @@ import (
"go.uber.org/zap"

"github.com/ssvlabs/ssv/logging/fields"
"github.com/ssvlabs/ssv/networkconfig"
"github.com/ssvlabs/ssv/protocol/genesis/qbft/controller"
"github.com/ssvlabs/ssv/protocol/genesis/ssv/runner/metrics"
)
Expand All @@ -33,7 +33,7 @@ type SyncCommitteeRunner struct {
}

func NewSyncCommitteeRunner(
domainTypeProvider networkconfig.DomainTypeProvider,
domainType spectypes.DomainType,
beaconNetwork genesisspectypes.BeaconNetwork,
share *genesisspectypes.Share,
qbftController *controller.Controller,
Expand All @@ -46,7 +46,7 @@ func NewSyncCommitteeRunner(
return &SyncCommitteeRunner{
BaseRunner: &BaseRunner{
BeaconRoleType: genesisspectypes.BNRoleSyncCommittee,
DomainTypeProvider: domainTypeProvider,
DomainType: domainType,
BeaconNetwork: beaconNetwork,
Share: share,
QBFTController: qbftController,
Expand Down
6 changes: 3 additions & 3 deletions protocol/genesis/ssv/runner/sync_committee_aggregator.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ import (
"bytes"
"crypto/sha256"
"encoding/json"
spectypes "github.com/ssvlabs/ssv-spec/types"

"github.com/attestantio/go-eth2-client/spec/altair"
"github.com/attestantio/go-eth2-client/spec/phase0"
Expand All @@ -14,7 +15,6 @@ import (
genesisspectypes "github.com/ssvlabs/ssv-spec-pre-cc/types"
"go.uber.org/zap"

"github.com/ssvlabs/ssv/networkconfig"
"github.com/ssvlabs/ssv/protocol/genesis/qbft/controller"
"github.com/ssvlabs/ssv/protocol/genesis/ssv/runner/metrics"
)
Expand All @@ -31,7 +31,7 @@ type SyncCommitteeAggregatorRunner struct {
}

func NewSyncCommitteeAggregatorRunner(
domainTypeProvider networkconfig.DomainTypeProvider,
domainType spectypes.DomainType,
beaconNetwork genesisspectypes.BeaconNetwork,
share *genesisspectypes.Share,
qbftController *controller.Controller,
Expand All @@ -44,7 +44,7 @@ func NewSyncCommitteeAggregatorRunner(
return &SyncCommitteeAggregatorRunner{
BaseRunner: &BaseRunner{
BeaconRoleType: genesisspectypes.BNRoleSyncCommitteeContribution,
DomainTypeProvider: domainTypeProvider,
DomainType: domainType,
BeaconNetwork: beaconNetwork,
Share: share,
QBFTController: qbftController,
Expand Down
14 changes: 7 additions & 7 deletions protocol/genesis/ssv/runner/validator_registration.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ import (
"crypto/sha256"
"encoding/hex"
"encoding/json"
spectypes "github.com/ssvlabs/ssv-spec/types"

v1 "github.com/attestantio/go-eth2-client/api/v1"
"github.com/attestantio/go-eth2-client/spec/phase0"
Expand All @@ -15,7 +16,6 @@ import (
"go.uber.org/zap"

"github.com/ssvlabs/ssv/logging/fields"
"github.com/ssvlabs/ssv/networkconfig"
"github.com/ssvlabs/ssv/protocol/genesis/qbft/controller"
"github.com/ssvlabs/ssv/protocol/genesis/ssv/runner/metrics"
)
Expand All @@ -32,7 +32,7 @@ type ValidatorRegistrationRunner struct {
}

func NewValidatorRegistrationRunner(
domainTypeProvider networkconfig.DomainTypeProvider,
domainType spectypes.DomainType,
beaconNetwork genesisspectypes.BeaconNetwork,
share *genesisspectypes.Share,
qbftController *controller.Controller,
Expand All @@ -42,11 +42,11 @@ func NewValidatorRegistrationRunner(
) Runner {
return &ValidatorRegistrationRunner{
BaseRunner: &BaseRunner{
BeaconRoleType: genesisspectypes.BNRoleValidatorRegistration,
DomainTypeProvider: domainTypeProvider,
BeaconNetwork: beaconNetwork,
Share: share,
QBFTController: qbftController,
BeaconRoleType: genesisspectypes.BNRoleValidatorRegistration,
DomainType: domainType,
BeaconNetwork: beaconNetwork,
Share: share,
QBFTController: qbftController,
},

beacon: beacon,
Expand Down
12 changes: 6 additions & 6 deletions protocol/genesis/ssv/runner/voluntary_exit.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ import (
"crypto/sha256"
"encoding/hex"
"encoding/json"
spectypes "github.com/ssvlabs/ssv-spec/types"

"github.com/attestantio/go-eth2-client/spec/phase0"
ssz "github.com/ferranbt/fastssz"
Expand All @@ -14,7 +15,6 @@ import (
"go.uber.org/zap"

"github.com/ssvlabs/ssv/logging/fields"
"github.com/ssvlabs/ssv/networkconfig"
"github.com/ssvlabs/ssv/protocol/genesis/ssv/runner/metrics"
)

Expand All @@ -33,7 +33,7 @@ type VoluntaryExitRunner struct {
}

func NewVoluntaryExitRunner(
domainTypeProvider networkconfig.DomainTypeProvider,
domainType spectypes.DomainType,
beaconNetwork genesisspectypes.BeaconNetwork,
share *genesisspectypes.Share,
beacon genesisspecssv.BeaconNode,
Expand All @@ -42,10 +42,10 @@ func NewVoluntaryExitRunner(
) Runner {
return &VoluntaryExitRunner{
BaseRunner: &BaseRunner{
BeaconRoleType: genesisspectypes.BNRoleVoluntaryExit,
DomainTypeProvider: domainTypeProvider,
BeaconNetwork: beaconNetwork,
Share: share,
BeaconRoleType: genesisspectypes.BNRoleVoluntaryExit,
DomainType: domainType,
BeaconNetwork: beaconNetwork,
Share: share,
},

beacon: beacon,
Expand Down
Loading

0 comments on commit d5809fd

Please sign in to comment.