mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2024-12-25 21:07:18 +00:00
dc6dee3f4e
* implementation of handling reload * proper implementation * fix WaitForActivation tests * HandleKeyReload tests * runner tests * do not reuse log hook between tests * gzl * Drop unnecessary use of the blank identifier * move mock_validator to testutil package * Reorganize validator client package * reduce package visibility * revert account changes * gzl * describe nil parameter Co-authored-by: Raul Jordan <raul@prysmaticlabs.com>
41 lines
1.1 KiB
Go
41 lines
1.1 KiB
Go
package client
|
|
|
|
import (
|
|
"context"
|
|
|
|
eth "github.com/prysmaticlabs/ethereumapis/eth/v1alpha1"
|
|
"go.opencensus.io/trace"
|
|
)
|
|
|
|
// HandleKeyReload makes sure the validator keeps operating correctly after a change to the underlying keys.
|
|
// It is also responsible for logging out information about the new state of keys.
|
|
func (v *validator) HandleKeyReload(ctx context.Context, newKeys [][48]byte) (anyActive bool, err error) {
|
|
ctx, span := trace.StartSpan(ctx, "validator.HandleKeyReload")
|
|
defer span.End()
|
|
|
|
statusRequestKeys := make([][]byte, len(newKeys))
|
|
for i := range newKeys {
|
|
statusRequestKeys[i] = newKeys[i][:]
|
|
}
|
|
resp, err := v.validatorClient.MultipleValidatorStatus(ctx, ð.MultipleValidatorStatusRequest{
|
|
PublicKeys: statusRequestKeys,
|
|
})
|
|
if err != nil {
|
|
return false, err
|
|
}
|
|
statuses := make([]*validatorStatus, len(resp.Statuses))
|
|
for i, s := range resp.Statuses {
|
|
statuses[i] = &validatorStatus{
|
|
publicKey: resp.PublicKeys[i],
|
|
status: s,
|
|
index: resp.Indices[i],
|
|
}
|
|
}
|
|
anyActive = v.checkAndLogValidatorStatus(statuses)
|
|
if anyActive {
|
|
logActiveValidatorStatus(statuses)
|
|
}
|
|
|
|
return anyActive, nil
|
|
}
|