Support changing Effective Balance by config.

.env.example

@@ -29,6 +29,9 @@ CL_API_URLS=https://<consensus-layer-api-url>
 # Validator registry source will be "lido" or "file" (optional).
 VALIDATOR_REGISTRY_SOURCE=lido
 
+# Effective Balance is 32 by default.
+# EFFECTIVE_BALANCE_INCREMENTS=32
+
 # Critical alerts (optional).
 # CRITICAL_ALERTS_ALERTMANAGER_URL=http://alertmanager:9093
 # CRITICAL_ALERTS_MIN_VAL_COUNT=1

src/app/app.service.ts

@@ -30,6 +30,7 @@ export class AppService implements OnModuleInit, OnApplicationBootstrap {
     this.logger.log(`DRY RUN ${this.configService.get('DRY_RUN') ? 'enabled' : 'disabled'}`);
     this.logger.log(`Slot time: ${this.configService.get('CHAIN_SLOT_TIME_SECONDS')} seconds`);
     this.logger.log(`Epoch size: ${this.configService.get('FETCH_INTERVAL_SLOTS')} slots`);
+    this.logger.log(`Effective Balance: ${this.configService.get('EFFECTIVE_BALANCE_INCREMENTS')} ETH`);
   }
 
   public async onApplicationBootstrap(): Promise<void> {

src/common/config/env.validation.ts

@@ -277,6 +277,14 @@ export class EnvironmentVariables {
 
   @IsEnum(WorkingMode)
   public WORKING_MODE = WorkingMode.Finalized;
+
+  /**
+   * Effective balance.
+   */
+  @IsNumber()
+  @Min(32)
+  @Transform(({ value }) => parseInt(value, 10), { toClassOnly: true })
+  public EFFECTIVE_BALANCE_INCREMENTS = 32;
 }
 
 export function validate(config: Record<string, unknown>) {

src/duty/attestation/attestation.rewards.ts

@@ -38,11 +38,13 @@ export class AttestationRewards {
         .toString(),
     );
     // Perfect attestation (with multipliers). Need for calculating missed reward
+    const effectiveBalance = this.config.get('EFFECTIVE_BALANCE_INCREMENTS');
+
     const perfect = getRewards({ source: true, target: true, head: true });
     const perfectAttestationRewards =
-      Math.trunc(perfect.source * epochMeta.state.base_reward * 32 * sourceParticipation) +
-      Math.trunc(perfect.target * epochMeta.state.base_reward * 32 * targetParticipation) +
-      Math.trunc(perfect.head * epochMeta.state.base_reward * 32 * headParticipation);
+      Math.trunc(perfect.source * epochMeta.state.base_reward * effectiveBalance * sourceParticipation) +
+      Math.trunc(perfect.target * epochMeta.state.base_reward * effectiveBalance * targetParticipation) +
+      Math.trunc(perfect.head * epochMeta.state.base_reward * effectiveBalance * headParticipation);
     const maxBatchSize = 1000;
     let index = 0;
     for (const v of this.summary.epoch(epoch).values()) {