Process redeemer

src/common/contracts.py

@@ -558,6 +558,36 @@ async def get_exit_queue_missing_assets(
             block_identifier=block_number
         )
 
+    async def positions_manager(self) -> ChecksumAddress:
+        return await self.contract.functions.positionsManager().call()
+
+    async def queued_shares(self, block_number: BlockNumber | None = None) -> Wei:
+        return await self.contract.functions.queuedShares().call(block_identifier=block_number)
+
+    async def can_process_exit_queue(self, block_number: BlockNumber | None = None) -> bool:
+        return await self.contract.functions.canProcessExitQueue().call(
+            block_identifier=block_number
+        )
+
+    async def process_exit_queue(self) -> HexStr:
+        tx_function = self.contract.functions.processExitQueue()
+        tx_hash = await transaction_gas_wrapper(tx_function)
+        return Web3.to_hex(tx_hash)
+
+    async def redeem_sub_vaults_assets(
+        self, vault_address: ChecksumAddress, assets_to_redeem: Wei
+    ) -> HexStr:
+        tx_function = self.contract.functions.redeemSubVaultsAssets(vault_address, assets_to_redeem)
+        tx_hash = await transaction_gas_wrapper(tx_function)
+        tx_receipt = await self.execution_client.eth.wait_for_transaction_receipt(
+            tx_hash, timeout=settings.execution_transaction_timeout
+        )
+        if not tx_receipt['status']:
+            raise RuntimeError(
+                f'redeemSubVaultsAssets transaction failed. Tx Hash: {Web3.to_hex(tx_hash)}'
+            )
+        return Web3.to_hex(tx_hash)
+
 
 class ValidatorsCheckerContract(ContractWrapper):
     abi_path = 'abi/IValidatorsChecker.json'

src/common/harvest.py

@@ -1,23 +1,25 @@
 from hexbytes import HexBytes
 from sw_utils.networks import GNO_NETWORKS
 from web3 import Web3
-from web3.types import BlockNumber, Wei
+from web3.types import BlockNumber, ChecksumAddress, Wei
 
 from src.common.clients import ipfs_fetch_client
 from src.common.contracts import VaultContract, keeper_contract
 from src.common.typings import HarvestParams
 from src.config.settings import settings
 
 
-async def get_harvest_params(block_number: BlockNumber | None = None) -> HarvestParams | None:
-    if not await keeper_contract.can_harvest(settings.vault, block_number):
+async def get_harvest_params(
+    vault: ChecksumAddress, block_number: BlockNumber | None = None
+) -> HarvestParams | None:
+    if not await keeper_contract.can_harvest(vault, block_number):
         return None
 
     last_rewards = await keeper_contract.get_last_rewards_update(block_number)
     if last_rewards is None:
         return None
 
-    vault_contract = VaultContract(settings.vault)
+    vault_contract = VaultContract(vault)
     harvest_params = await _fetch_harvest_params_from_ipfs(
         vault_contract=vault_contract,
         ipfs_hash=last_rewards.ipfs_hash,

src/common/startup_check.py

@@ -482,8 +482,10 @@ async def _check_events_logs() -> None:
 
 
 async def _check_vault_withdrawable_assets() -> None:
-    harvest_params = await get_harvest_params()
-    withdrawable_assets = await get_withdrawable_assets(harvest_params=harvest_params)
+    harvest_params = await get_harvest_params(settings.vault)
+    withdrawable_assets = await get_withdrawable_assets(
+        settings.vault, harvest_params=harvest_params
+    )
 
     # Note. We round down assets in the log message because of the case when assets
     # is slightly less than required amount to register validator.

src/harvest/tasks.py

@@ -19,7 +19,7 @@ async def process_block(self, interrupt_handler: InterruptHandler) -> None:
         """
 
         # check current gas prices
-        harvest_params = await get_harvest_params()
+        harvest_params = await get_harvest_params(settings.vault)
         if not harvest_params:
             return
 

src/main.py

@@ -10,6 +10,7 @@
 from src.commands.create_wallet import create_wallet
 from src.commands.exit_validators import exit_validators
 from src.commands.init import init
+from src.commands.internal.process_redeemer import process_redeemer
 from src.commands.internal.update_redeemable_positions import (
     update_redeemable_positions,
 )
@@ -58,6 +59,7 @@ def cli() -> None:
 cli.add_command(node_start)
 cli.add_command(node_status)
 cli.add_command(update_redeemable_positions)
+cli.add_command(process_redeemer)
 
 
 if __name__ == '__main__':

src/redemptions/tasks.py

@@ -22,6 +22,7 @@
 
 
 batch_size = 20
+ZERO_MERKLE_ROOT = HexStr('0x' + '0' * 64)
 
 
 async def get_redemption_assets(chain_head: ChainHead) -> Gwei:
@@ -151,7 +152,8 @@ async def iter_os_token_positions(
     # Check whether redeemable positions are available
     if not redeemable_positions.ipfs_hash:
         return
-
+    if redeemable_positions.merkle_root == ZERO_MERKLE_ROOT:
+        return
     # Fetch redeemable positions data from IPFS
     data = cast(list[dict], await ipfs_fetch_client.fetch_json(redeemable_positions.ipfs_hash))
 

src/redemptions/typings.py

@@ -58,6 +58,8 @@ class OsTokenPosition:
     owner: ChecksumAddress
     vault: ChecksumAddress
     amount: Wei
+    available_shares: Wei = Wei(0)
+    shares_to_redeem: Wei = Wei(0)
 
     def as_dict(self) -> dict:
         return {

src/reward_splitter/tasks.py

@@ -61,7 +61,7 @@ async def process_block(self, interrupt_handler: InterruptHandler) -> None:
                 'Processing fee splitter %s ',
                 reward_splitter.address,
             )
-            harvest_params = await get_harvest_params()
+            harvest_params = await get_harvest_params(settings.vault)
             exit_requests = splitter_to_exit_requests.get(reward_splitter.address, [])  # nosec
 
             reward_splitter_calls = await _get_reward_splitter_calls(

src/validators/execution.py

@@ -206,9 +206,11 @@ def process_network_validator_event(
     return None
 
 
-async def get_withdrawable_assets(harvest_params: HarvestParams | None) -> Wei:
+async def get_withdrawable_assets(
+    vault: ChecksumAddress, harvest_params: HarvestParams | None
+) -> Wei:
     """Fetches vault's available assets for staking."""
-    vault_contract = VaultContract(settings.vault)
+    vault_contract = VaultContract(vault)
     if harvest_params is None:
         return await vault_contract.functions.withdrawableAssets().call()
 

src/validators/tasks.py

@@ -50,7 +50,7 @@ async def process(self) -> None:
             await update_unused_validator_keys_metric(
                 keystore=self.keystore,
             )
-        harvest_params = await get_harvest_params()
+        harvest_params = await get_harvest_params(settings.vault)
 
         vault_assets = await get_vault_assets(harvest_params=harvest_params)
         vault_assets = Gwei(max(0, vault_assets - settings.vault_min_balance_gwei))
@@ -259,7 +259,7 @@ async def register_new_validators(
 
 
 async def get_vault_assets(harvest_params: HarvestParams | None) -> Gwei:
-    vault_assets = await get_withdrawable_assets(harvest_params=harvest_params)
+    vault_assets = await get_withdrawable_assets(settings.vault, harvest_params=harvest_params)
     if settings.network in GNO_NETWORKS:
         # apply GNO -> mGNO exchange rate
         vault_assets = convert_to_mgno(vault_assets)

src/withdrawals/assets.py

@@ -48,7 +48,7 @@ async def get_queued_assets(
     Get exit queue missing assets.
     For Gno networks return value in mGNO-Gwei.
     """
-    harvest_params = await get_harvest_params(chain_head.block_number)
+    harvest_params = await get_harvest_params(settings.vault, chain_head.block_number)
 
     # Get exit queue cumulative tickets
     exit_queue_cumulative_ticket = (