diff --git a/packages/brain/src/modules/apiClients/postgres/index.ts b/packages/brain/src/modules/apiClients/postgres/index.ts index 21eee7b4..4402dbe3 100644 --- a/packages/brain/src/modules/apiClients/postgres/index.ts +++ b/packages/brain/src/modules/apiClients/postgres/index.ts @@ -111,7 +111,7 @@ SELECT pg_total_relation_size('${this.tableName}'); await this.sql.unsafe(` DO $$ BEGIN - CREATE TYPE ${this.EXECUTION_CLIENT} AS ENUM('${ExecutionClient.Besu}', '${ExecutionClient.Nethermind}', '${ExecutionClient.Geth}', '${ExecutionClient.Erigon}', '${ExecutionClient.Unknown}'); + CREATE TYPE ${this.EXECUTION_CLIENT} AS ENUM('${ExecutionClient.Besu}', '${ExecutionClient.Nethermind}', '${ExecutionClient.Geth}', '${ExecutionClient.Reth}', '${ExecutionClient.Erigon}', '${ExecutionClient.Unknown}'); EXCEPTION WHEN duplicate_object THEN NULL; END $$; diff --git a/packages/brain/src/modules/cron/trackValidatorsPerformance/getActiveValidatorsLoadedInBrain.ts b/packages/brain/src/modules/cron/trackValidatorsPerformance/getActiveValidatorsLoadedInBrain.ts index 244f9db1..a92f102a 100644 --- a/packages/brain/src/modules/cron/trackValidatorsPerformance/getActiveValidatorsLoadedInBrain.ts +++ b/packages/brain/src/modules/cron/trackValidatorsPerformance/getActiveValidatorsLoadedInBrain.ts @@ -27,7 +27,7 @@ export async function getActiveValidatorsLoadedInBrain({ await beaconchainApi.postStateValidators({ body: { ids: validatorIndexes, - statuses: validatorIndexes.map(() => ValidatorStatus.ACTIVE_ONGOING) + statuses: [ValidatorStatus.ACTIVE_ONGOING] }, stateId: "finalized" }) diff --git a/packages/brain/src/modules/cron/trackValidatorsPerformance/trackValidatorsPerformance.ts b/packages/brain/src/modules/cron/trackValidatorsPerformance/trackValidatorsPerformance.ts index 4ff7f5ce..ee0fbd05 100644 --- a/packages/brain/src/modules/cron/trackValidatorsPerformance/trackValidatorsPerformance.ts +++ b/packages/brain/src/modules/cron/trackValidatorsPerformance/trackValidatorsPerformance.ts @@ -36,7 +36,7 @@ export async function trackValidatorsPerformanceCron({ const currentEpoch = parseInt( ( await beaconchainApi.getStateFinalityCheckpoints({ - stateId: "finalized" + stateId: "head" }) ).data.finalized.epoch ); @@ -133,7 +133,7 @@ export async function fetchAndInsertPerformanceCron({ function getValidatorPerformanceError(e: Error): ValidatorPerformanceError { if (e instanceof BeaconchainApiError) return { - code: ValidatorPerformanceErrorCode.EXECUTION_OFFLINE, + code: ValidatorPerformanceErrorCode.BEACONCHAIN_API_ERROR, message: e.message }; if (e instanceof BrainDbError)