Update of SSV clusters to use ETH payment (#2860)

* Add consol option to doAccounting Hardhat task

* Changed doAccounting Action to use the ConsolidationController

* Added getValidators Hardhat task
Refactored getting Beacon chain data to use Lodestar. So removed Beaconcha.in API use

* Removed reference to BEACONCHAIN_API_KEY
Formatting of getValidators

* More formatting of the output of the  getValidators Hardhat task
Added epoch option to getValidators Hardhat task

* Added Claude and AGENTS md files

* Added safe option to confirmConsol
Refactored writing Safe file into safe util

* Got getValidators working with dRPC

* Added consol option to verifyDeposits which has to call snapBalances on the ConsolidationController

* FIxed consolidation fork tests

* Deploy script to migrate the SSV clusters to ETH payment

* Fix 183 deploy which was defaulting to Hoodi

* Updated Claude file

* Upgrade Lodestar dependencies

* Changed back to using GET for bulk validators

* Bumped deploy script number

* Updated Claude file with SSV cluster payment details

* Prettier

* Deployed 192_migrate_ssv_clusters_to_eth

Author: naddison36

CLAUDE.md

@@ -107,6 +107,7 @@ Located in `contracts/strategies/`. Each strategy:
 - Is registered with a vault and allocated collateral
 
 Key strategies: Aave, Compound, Convex/Curve, Balancer, Morpho, Native Staking (SSV validators).
+- For SSV Cluster migrations to ETH billing, use the SSV ETH payment calculator: https://ssv-eth-forecasting.vercel.app/
 
 ### OTokens
 `contracts/token/OUSD.sol` and `contracts/token/OETH.sol` - rebasing ERC-20 tokens. OUSD rebases to all holders; OETH uses a similar mechanism for ETH-denominated yield.

contracts/deploy/mainnet/192_migrate_ssv_clusters_to_eth.js

@@ -0,0 +1,78 @@
+const { deploymentWithGovernanceProposal } = require("../../utils/deploy");
+const { getClusterInfo, splitOperatorIds } = require("../../utils/ssv");
+
+// ETH Payment estimator for SSV Clusters
+// https://ssv-eth-forecasting.vercel.app/
+
+const strategyConfigs = [
+  {
+    proxyName: "NativeStakingSSVStrategy2Proxy",
+    contractName: "NativeStakingSSVStrategy",
+    operatorids: "752,753,754,755",
+    // Another 63 validators will be migrated early May
+    // The remaining validators can be consolidated at the end of May
+    // 40 days with current number of validators should be more than enough
+    ethValue: 0.2498,
+  },
+  {
+    proxyName: "NativeStakingSSVStrategy3Proxy",
+    contractName: "NativeStakingSSVStrategy",
+    operatorids: "338,339,340,341",
+    // No ETH as this cluster no longer has any validators
+    // Need to upgrade to claim the SSV left in the cluster
+    ethValue: 0,
+  },
+  {
+    proxyName: "CompoundingStakingSSVStrategyProxy",
+    contractName: "CompoundingStakingSSVStrategy",
+    operatorids: "2070,2071,2072,2073",
+    // This gives 90 days operations with the current validator balances.
+    ethValue: 0.597136,
+  },
+];
+
+module.exports = deploymentWithGovernanceProposal(
+  {
+    deployName: "192_migrate_ssv_clusters_to_eth",
+    forceDeploy: false,
+    // forceSkip: true,
+    reduceQueueTime: true,
+    deployerIsProposer: false,
+    proposalId:
+      "27498848419509230881029695021341446610667421341841354940740078670919629788465",
+  },
+  async ({ ethers }) => {
+    const { chainId } = await ethers.provider.getNetwork();
+    const actions = [];
+
+    for (const strategyConfig of strategyConfigs) {
+      const proxy = await ethers.getContract(strategyConfig.proxyName);
+      const strategy = await ethers.getContractAt(
+        strategyConfig.contractName,
+        proxy.address
+      );
+      const operatorIds = splitOperatorIds(strategyConfig.operatorids);
+      const { cluster } = await getClusterInfo({
+        chainId,
+        operatorids: operatorIds.join(","),
+        ownerAddress: strategy.address,
+      });
+      const ethValue = strategyConfig.ethValue
+        ? ethers.utils.parseEther(strategyConfig.ethValue.toString())
+        : 0;
+
+      actions.push({
+        contract: strategy,
+        signature:
+          "migrateClusterToETH(uint64[],(uint32,uint64,uint64,bool,uint256))",
+        args: [operatorIds, cluster],
+        value: ethValue,
+      });
+    }
+
+    return {
+      name: "Migrate SSV clusters to ETH billing for OETH staking strategies",
+      actions,
+    };
+  }
+);

contracts/deployments/mainnet/.migrations.json

@@ -77,5 +77,6 @@
   "186_merkl_pb_bribes_module": 1773930008,
   "188_harvesting_eip1271_oeth": 1774552963,
   "189_harvesting_eip1271_ogn": 1774552993,
-  "190_remove_3rd_native_staking_strategy": 1775468903
+  "190_remove_3rd_native_staking_strategy": 1775468903,
+  "192_migrate_ssv_clusters_to_eth": 1777859891
 }

contracts/tasks/governance.js

@@ -2,7 +2,11 @@ const { sleep } = require("../utils/time.js");
 
 async function execute(taskArguments, hre) {
   const { isMainnet, isFork } = require("../test/helpers");
-  const { withConfirmation, impersonateGuardian } = require("../utils/deploy");
+  const {
+    withConfirmation,
+    impersonateGuardian,
+    getProposalExecutionValue,
+  } = require("../utils/deploy");
 
   if (isMainnet) {
     throw new Error("The execute task can not be used on mainnet");
@@ -54,7 +58,12 @@ async function execute(taskArguments, hre) {
   if (isFork) {
     // On the fork, impersonate the guardian and execute the proposal.
     await impersonateGuardian();
-    await withConfirmation(governor.connect(sGuardian).execute(propId));
+    const executionValue = await getProposalExecutionValue(governor, propId);
+    await withConfirmation(
+      governor.connect(sGuardian).execute(propId, {
+        ...(executionValue.gt(0) ? { value: executionValue } : {}),
+      })
+    );
   } else {
     // Localhost network. Execute as the governor account.
     await governor.connect(sGovernor).execute(propId);

contracts/tasks/tasks.js

@@ -1107,8 +1107,7 @@ task("setRewardTokenAddresses", "Sets the reward token of a strategy")
 task(
   "updateWOETHPrice",
   "Update the wOETH oracle price on the Base BridgedWOETHStrategy"
-)
-  .setAction(updateWOETHOraclePrice);
+).setAction(updateWOETHOraclePrice);
 
 // Harvester
 

contracts/utils/deploy.js

@@ -338,7 +338,7 @@ const _verifyProxyInitializedWithCorrectGovernor = (transactionData) => {
     return;
   }
 
-  if (isMainnet || isBase || isFork || isBaseFork) {
+  if (isMainnet || isBase || isFork) {
     // TODO: Skip verification for Fork for now
     return;
   }
@@ -606,7 +606,10 @@ const executeGovernanceProposalOnFork = async ({
     // Don't ask me why but this seems to force hardhat to
     // update state and cause the random failures to stop
     await getProposalState(proposalIdBn);
-    await governorSix.getActions(proposalIdBn);
+    const executionValue = await getProposalExecutionValue(
+      governorSix,
+      proposalIdBn
+    );
 
     executionRetries = executionRetries - 1;
     try {
@@ -615,6 +618,7 @@ const executeGovernanceProposalOnFork = async ({
         "execute(uint256)"
       ](proposalIdBn, {
         gasLimit: executeGasLimit || undefined,
+        ...(executionValue.gt(0) ? { value: executionValue } : {}),
       });
     } catch (e) {
       console.error(e);
@@ -974,30 +978,47 @@ async function buildGnosisSafeJson(
   safeAddress,
   targets,
   contractMethods,
-  contractInputsValues
+  contractInputsValues,
+  values = []
 ) {
   return buildSafeTransactionBuilderJson({
     safeAddress: safeAddress || addresses.mainnet.Guardian,
     name: "Transaction Batch",
     transactions: targets.map((target, i) => ({
       to: target,
-      value: "0",
+      value: BigNumber.from(values[i] ?? 0).toString(),
       contractMethod: contractMethods[i],
       contractInputsValues: contractInputsValues[i],
     })),
   });
 }
 
+async function getProposalExecutionValue(governor, proposalId) {
+  const actions = await governor.getActions(proposalId);
+  const rawValues =
+    actions[1] || (typeof actions.values === "function" ? [] : actions.values);
+  const values = Array.from(rawValues || []);
+
+  return values.reduce(
+    (sum, value) => sum.add(BigNumber.from(value)),
+    BigNumber.from(0)
+  );
+}
+
 async function simulateWithTimelockImpersonation(proposal) {
   log("Simulating the proposal directly on the timelock...");
   const { timelockAddr } = await getNamedAccounts();
   const timelock = await impersonateAndFund(timelockAddr);
 
   for (const action of proposal.actions) {
-    const { contract, signature, args } = action;
+    const { contract, signature, args, value } = action;
+    const txOpts = {
+      ...(await getTxOpts()),
+      ...(value ? { value } : {}),
+    };
 
     log(`Sending governance action ${signature} to ${contract.address}`);
-    await contract.connect(timelock)[signature](...args, await getTxOpts());
+    await contract.connect(timelock)[signature](...args, txOpts);
 
     console.log(`... ${signature} completed`);
   }
@@ -1232,18 +1253,22 @@ function deploymentWithGuardianGovernor(opts, fn) {
 
       const guardianActions = [];
       for (const action of proposal.actions) {
-        const { contract, signature, args } = action;
+        const { contract, signature, args, value } = action;
+        const txOpts = {
+          ...(await getTxOpts()),
+          ...(value ? { value } : {}),
+        };
 
         log(`Sending governance action ${signature} to ${contract.address}`);
         const result = await withConfirmation(
-          contract.connect(sGuardian)[signature](...args, await getTxOpts())
+          contract.connect(sGuardian)[signature](...args, txOpts)
         );
         guardianActions.push({
           sig: signature,
           args: args,
           to: contract.address,
           data: result.data,
-          value: result.value.toString(),
+          value: BigNumber.from(value ?? result.value ?? 0).toString(),
         });
 
         console.log(`... ${signature} completed`);
@@ -1449,6 +1474,7 @@ module.exports = {
 
   constructContractMethod,
   buildGnosisSafeJson,
+  getProposalExecutionValue,
 
   encodeSaltForCreateX,
   createPoolBoosterSonic,

contracts/utils/governor.js

@@ -47,7 +47,7 @@ async function proposeGovernanceArgs(governorArgsArray) {
 
   return [
     targets,
-    Array(governorArgsArray.length).fill(BigNumber.from(0)),
+    governorArgsArray.map((action) => BigNumber.from(action.value ?? 0)),
     sigs,
     calldata,
   ];