status-im/nimbus-eth2
2
0
Fork 0
mirror of https://github.com/status-im/nimbus-eth2.git synced 2025-02-20 02:08:12 +00:00
Code Issues Projects Releases Wiki Activity

fix incorrect config validation regression from #5959 (#5966)

Browse Source 
During refactoring of #5959, some implicit `return` were overlooked,
resulting in spurious `err()` being returned without message.

```
{"lvl":"WRN","ts":"2024-02-26 10:12:20.469+00:00","msg":"Beacon nodes report different configuration values","reason":"","service":"fallback_service","node":"http://127.0.0.1:9303[Nimbus/v24.2.1-4e9bc7-stateofus]","node_index":0,"node_roles":"AGBSDT"}
```

Correcting the helpers to return explicit result in all exhaustive
cases so that this cannot happen anymore by accident.
This commit is contained in:
Etan Kissling 2024-02-26 13:32:01 +01:00 committed by GitHub
parent 4e9bc7f570
commit c3fe055bd4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
beacon_chain/validator_client/common.nim
View File

@ -1440,23 +1440,24 @@ proc updateRuntimeConfig*(vc: ValidatorClientRef,
localForkEpoch: Epoch, localForkEpoch: Epoch,
forkVersion: Opt[Version]): Result[void, string] = forkVersion: Opt[Version]): Result[void, string] =
if localForkVersion.isNone(): if localForkVersion.isNone():
discard # Potentially discovered new fork, save it at end of function ok() # Potentially discovered new fork, save it at end of function
else: else:
if forkVersion.isSome(): if forkVersion.isSome():
if forkVersion.get() == localForkVersion.get(): if forkVersion.get() == localForkVersion.get():
discard # Already known ok() # Already known
else: else:
return err("Beacon node has conflicting " & err("Beacon node has conflicting " &
consensusFork.forkVersionConfigKey() & " value") consensusFork.forkVersionConfigKey() & " value")
else: else:
if wallEpoch < localForkEpoch: if wallEpoch < localForkEpoch:
debug "Beacon node must be updated before fork activates", debug "Beacon node must be updated before fork activates",
node = node, node = node,
consensusFork, consensusFork,
forkEpoch = localForkEpoch forkEpoch = localForkEpoch
ok()
else: else:
return err("Beacon node must be updated and report correct " & err("Beacon node must be updated and report correct " &
$consensusFork & " config value") $consensusFork & " config value")
? ConsensusFork.Capella.validateForkVersionCompatibility( ? ConsensusFork.Capella.validateForkVersionCompatibility(
localForkConfig.capellaVersion, localForkConfig.capellaVersion,
@ -1468,23 +1469,24 @@ proc updateRuntimeConfig*(vc: ValidatorClientRef,
localForkEpoch: Epoch, localForkEpoch: Epoch,
forkEpoch: Epoch): Result[void, string] = forkEpoch: Epoch): Result[void, string] =
if localForkEpoch == FAR_FUTURE_EPOCH: if localForkEpoch == FAR_FUTURE_EPOCH:
discard # Potentially discovered new fork, save it at end of function ok() # Potentially discovered new fork, save it at end of function
else: else:
if forkEpoch != FAR_FUTURE_EPOCH: if forkEpoch != FAR_FUTURE_EPOCH:
if forkEpoch == localForkEpoch: if forkEpoch == localForkEpoch:
discard # Already known ok() # Already known
else: else:
return err("Beacon node has conflicting " & err("Beacon node has conflicting " &
consensusFork.forkEpochConfigKey() & " value") consensusFork.forkEpochConfigKey() & " value")
else: else:
if wallEpoch < localForkEpoch: if wallEpoch < localForkEpoch:
debug "Beacon node must be updated before fork activates", debug "Beacon node must be updated before fork activates",
node = node, node = node,
consensusFork, consensusFork,
forkEpoch = localForkEpoch forkEpoch = localForkEpoch
ok()
else: else:
return err("Beacon node must be updated and report correct " & err("Beacon node must be updated and report correct " &
$consensusFork & " config value") $consensusFork & " config value")
? ConsensusFork.Altair.validateForkEpochCompatibility( ? ConsensusFork.Altair.validateForkEpochCompatibility(
localForkConfig.altairEpoch, forkConfig.altairEpoch) localForkConfig.altairEpoch, forkConfig.altairEpoch)