feat: update PredepositGuarantee abi and implement node syncing status

Author: DiRaiks

abi/PredepositGuarantee.ts

@@ -47,6 +47,33 @@ export const PredepositGuaranteeErrorsAbi = [
     name: 'InputHasInfinityPoints',
     type: 'error',
   },
+  {
+    inputs: [
+      {
+        internalType: 'enum BLS12_381.Component',
+        name: 'component',
+        type: 'uint8',
+      },
+    ],
+    name: 'InvalidCompressedComponent',
+    type: 'error',
+  },
+  {
+    inputs: [
+      {
+        internalType: 'enum BLS12_381.Component',
+        name: 'component',
+        type: 'uint8',
+      },
+    ],
+    name: 'InvalidCompressedComponentSignBit',
+    type: 'error',
+  },
+  {
+    inputs: [],
+    name: 'InvalidDepositAmount',
+    type: 'error',
+  },
   {
     inputs: [],
     name: 'InvalidDepositYLength',
@@ -67,6 +94,11 @@ export const PredepositGuaranteeErrorsAbi = [
     name: 'InvalidSignature',
     type: 'error',
   },
+  {
+    inputs: [],
+    name: 'InvalidSignatureLength',
+    type: 'error',
+  },
   {
     inputs: [],
     name: 'InvalidSlot',

programs/contracts/pdg/write.ts

@@ -28,6 +28,8 @@ import {
   stringToNumberArray,
   parseValidatorTopUpArray,
   etherToWeiArray,
+  fetchNodeSyncingStatus,
+  fetchBeaconHeader,
 } from 'utils';
 import { Deposit, ValidatorTopUp } from 'types';
 
@@ -72,6 +74,19 @@ pdgWrite
     ) => {
       const pdgContract = await getPredepositGuaranteeContract();
 
+      const nodeStatus = await fetchNodeSyncingStatus();
+      const beaconHeaderJson = await fetchBeaconHeader('finalized');
+
+      logInfo('Node syncing status');
+      logTable({
+        data: [
+          ['Is syncing', nodeStatus.data.is_syncing],
+          ['Sync distance', nodeStatus.data.sync_distance],
+          ['Head slot', nodeStatus.data.head_slot],
+          ['Finalized slot', beaconHeaderJson.data.header.message.slot],
+        ],
+      });
+
       const isPaused = await checkPdgIsPaused(pdgContract);
       if (isPaused) return;
 
@@ -150,6 +165,18 @@ pdgWrite
     const validatorIndex = await confirmMakeProof(index);
     if (!validatorIndex) return;
 
+    const nodeStatus = await fetchNodeSyncingStatus();
+    const beaconHeaderJson = await fetchBeaconHeader('finalized');
+
+    logInfo('Node syncing status');
+    logTable({
+      data: [
+        ['Is syncing', nodeStatus.data.is_syncing],
+        ['Sync distance', nodeStatus.data.sync_distance],
+        ['Head slot', nodeStatus.data.head_slot],
+        ['Finalized slot', beaconHeaderJson.data.header.message.slot],
+      ],
+    });
     const hideSpinner = showSpinner({
       type: 'bouncingBar',
       message: 'Making proof...',

programs/pdg-helpers.ts

@@ -28,6 +28,8 @@ import {
   callReadMethodSilent,
   stringToNumber,
   fetchValidatorsInfo,
+  fetchNodeSyncingStatus,
+  fetchBeaconHeader,
 } from 'utils';
 import { checkPdgIsPaused } from 'features';
 
@@ -53,6 +55,18 @@ predepositGuaranteeHelpers
     if (!validatorIndex) return;
 
     const pdgContract = await getPredepositGuaranteeContract();
+    const nodeStatus = await fetchNodeSyncingStatus();
+    const beaconHeaderJson = await fetchBeaconHeader('finalized');
+
+    logInfo('Node syncing status');
+    logTable({
+      data: [
+        ['Is syncing', nodeStatus.data.is_syncing],
+        ['Sync distance', nodeStatus.data.sync_distance],
+        ['Head slot', nodeStatus.data.head_slot],
+        ['Finalized slot', beaconHeaderJson.data.header.message.slot],
+      ],
+    });
 
     const hideSpinner = showSpinner();
     try {
@@ -115,6 +129,19 @@ predepositGuaranteeHelpers
     const validatorIndex = await confirmMakeProof(index);
     if (!validatorIndex) return;
 
+    const nodeStatus = await fetchNodeSyncingStatus();
+    const beaconHeaderJson = await fetchBeaconHeader('finalized');
+
+    logInfo('Node syncing status');
+    logTable({
+      data: [
+        ['Is syncing', nodeStatus.data.is_syncing],
+        ['Sync distance', nodeStatus.data.sync_distance],
+        ['Head slot', nodeStatus.data.head_slot],
+        ['Finalized slot', beaconHeaderJson.data.header.message.slot],
+      ],
+    });
+
     const hideSpinner = showSpinner();
     try {
       const packageProof = await createPDGProof(Number(validatorIndex));

providers/index.ts

@@ -1 +1 @@
-export * from "./wallet.js";
+export * from './wallet.js';

scripts/updateVersion.cjs

@@ -1,5 +1,5 @@
-const path = require("path");
-const { readJsonSync, writeFileSync } = require("fs-extra");
+const path = require('path');
+const { readJsonSync, writeFileSync } = require('fs-extra');
 
 const esmVersionFilePath = path.join(__dirname, '../dist/version/index.js');
 const packageJsonPath = path.join(__dirname, '../package.json');

types/index.ts

@@ -1,2 +1,2 @@
-export * from "./config.js";
-export * from "./common.js";
+export * from './config.js';
+export * from './common.js';

utils/fetchCL.ts

@@ -56,6 +56,16 @@ type FinalityCheckpoints = {
   };
 };
 
+export type NodeSyncingStatus = {
+  data: {
+    head_slot: string;
+    sync_distance: string;
+    is_syncing: boolean;
+    is_optimistic: boolean;
+    el_offline: boolean;
+  };
+};
+
 const isFinalityCheckpoints = (
   obj: FinalityCheckpoints,
 ): obj is FinalityCheckpoints => {
@@ -156,6 +166,7 @@ const endpoints = {
   state: (stateId: StateId): string => `eth/v2/debug/beacon/states/${stateId}`,
   validatorsInfo: (validatorsPubkeys: string): string =>
     `eth/v1/beacon/states/head/validators${validatorsPubkeys}`,
+  nodeSyncing: 'eth/v1/node/syncing',
 };
 
 export const finalityCheckpoints = async (
@@ -335,3 +346,36 @@ export const fetchValidatorsInfo = async (
     throw error;
   }
 };
+
+export const fetchNodeSyncingStatus = async (
+  clURL?: string,
+): Promise<NodeSyncingStatus> => {
+  const url = clURL || getConfig().CL_URL;
+
+  if (!url) {
+    throw new Error(
+      'CL_URL is not set. CL_URL is required for checking node syncing status',
+    );
+  }
+
+  try {
+    const syncingResp = await fetch(
+      `${url.endsWith('/') ? url : url + '/'}${endpoints.nodeSyncing}`,
+    );
+
+    if (!syncingResp.ok) {
+      throw new Error(
+        `HTTP ${syncingResp.status} ${syncingResp.statusText}. URL: ${url}\n`,
+      );
+    }
+
+    const body: NodeSyncingStatus = await syncingResp.json();
+    return body;
+  } catch (error) {
+    printError(
+      error,
+      `Error fetching node syncing status. Used URL: ${url}. Please check if the CL_URL environment variable is correct or try to use another CL.`,
+    );
+    throw error;
+  }
+};

utils/sleep.ts

@@ -1,3 +1,3 @@
 export const sleep = (ms: number) => {
   return new Promise((resolve) => setTimeout(resolve, ms));
-}
+};