added: keys api config path

Author: Tarens2

src/common/config/env.validation.ts

@@ -105,6 +105,10 @@ export class EnvironmentVariables {
   @IsOptional()
   @IsString()
   LIDO_LOCATOR_CONTRACT_DEVNET_ADDRESS = '';
+
+  @IsOptional()
+  @IsString()
+  KEYS_API_BASE_PATH = '';
 }
 export const ENV_KEYS = Object.keys(new EnvironmentVariables());
 

src/jobs/validators/lido-keys/lido-keys.client.ts

@@ -0,0 +1,36 @@
+import { Inject } from '@nestjs/common';
+import { LOGGER_PROVIDER, LoggerService } from '../../../common/logger';
+import { ConfigService } from '../../../common/config';
+import { KEYS_API_PATHS } from './lido-keys.constants';
+import { LidoKeysData } from './lido-keys.types';
+
+export class LidoKeysClient {
+  constructor(
+    @Inject(LOGGER_PROVIDER) protected readonly logger: LoggerService,
+    protected readonly configService: ConfigService,
+  ) {}
+
+  protected endpoints: {
+    usedKeys: '/v1/keys?used=true';
+  };
+
+  protected getBasePath(): string {
+    const envUrl = this.configService.get('KEYS_API_BASE_PATH');
+
+    if (envUrl) {
+      return envUrl;
+    }
+
+    const chainId = this.configService.get('CHAIN_ID');
+    return KEYS_API_PATHS[chainId];
+  }
+
+  public async getUsedKeys() {
+    const url = this.getBasePath() + this.endpoints.usedKeys;
+    const lidoKeysResponse = await fetch(url, {
+      method: 'GET',
+    });
+    const lidoKeys: LidoKeysData = await lidoKeysResponse.json();
+    return lidoKeys;
+  }
+}

src/jobs/validators/lido-keys/lido-keys.constants.ts

@@ -2,9 +2,9 @@ import { CHAINS } from '@lido-nestjs/constants';
 
 const DEVNET_7 = '7032118028';
 
-export const KEYS_API_ADDRESS = {
-  [CHAINS.Mainnet]: 'https://keys-api.lido.fi/v1/keys?used=true',
-  [CHAINS.Goerli]: 'https://keys-api.testnet.fi/v1/keys?used=true',
-  [CHAINS.Holesky]: 'https://keys-api-holesky.testnet.fi/v1/keys?used=true',
-  [DEVNET_7]: 'http://hr6vb81d1ndsx-pectra-devnet-7-keys-api.valset-01.testnet.fi/v1/keys?used=true',
+export const KEYS_API_PATHS = {
+  [CHAINS.Mainnet]: 'https://keys-api.lido.fi',
+  [CHAINS.Goerli]: 'https://keys-api.testnet.fi',
+  [CHAINS.Holesky]: 'https://keys-api-holesky.testnet.fi',
+  [DEVNET_7]: 'http://hr6vb81d1ndsx-pectra-devnet-7-keys-api.valset-01.testnet.fi',
 };

src/jobs/validators/lido-keys/lido-keys.module.ts

@@ -1,10 +1,11 @@
 import { Module } from '@nestjs/common';
 import { ValidatorsStorageModule } from 'storage';
 import { LidoKeysService } from './lido-keys.service';
+import { LidoKeysClient } from './lido-keys.client';
 
 @Module({
   imports: [ValidatorsStorageModule],
-  providers: [LidoKeysService],
+  providers: [LidoKeysService, LidoKeysClient],
   exports: [LidoKeysService],
 })
 export class LidoKeysModule {}

src/jobs/validators/lido-keys/lido-keys.service.ts

@@ -2,21 +2,18 @@ import { Inject } from '@nestjs/common';
 import { LOGGER_PROVIDER, LoggerService } from 'common/logger';
 import { IndexedValidator } from 'common/consensus-provider/consensus-provider.types';
 import { ConfigService } from 'common/config';
-import { LidoKey, LidoKeysData } from './lido-keys.types';
-import { KEYS_API_ADDRESS } from './lido-keys.constants';
+import { LidoKey } from './lido-keys.types';
+import { LidoKeysClient } from './lido-keys.client';
 
 export class LidoKeysService {
   constructor(
     @Inject(LOGGER_PROVIDER) protected readonly logger: LoggerService,
     protected readonly configService: ConfigService,
+    protected readonly lidoKeysClient: LidoKeysClient,
   ) {}
 
   public async fetchLidoKeysData() {
-    const lidoKeysResponse = await fetch(KEYS_API_ADDRESS[this.configService.get('CHAIN_ID')], {
-      method: 'GET',
-    });
-    const lidoKeys: LidoKeysData = await lidoKeysResponse.json();
-    return lidoKeys;
+    return this.lidoKeysClient.getUsedKeys();
   }
 
   public async getLidoValidatorsByKeys(keys: LidoKey[], validators: IndexedValidator[]) {