bend susde adapter

Author: vpatsenko

.env.example

@@ -11,4 +11,5 @@ SOLANA_NODE_URL='https://api.mainnet-beta.solana.com'
 BASE_NODE_URL="https://mainnet.base.org"
 HYPEREVM_NODE_URL="https://rpc.hyperlend.finance/archive"
 PLASMA_NODE_URL="https://rpc.plasma.to"
-DERIVE_SUBGRAPH_API_KEY=''
+BERACHAIN_NODE_URL="https://rpc.berachain.com"
+DERIVE_SUBGRAPH_API_KEY=''

constants/bend_susde_susds.py

@@ -0,0 +1,21 @@
+import json
+from web3 import Web3
+from utils.web3_utils import w3_berachain
+
+PAGINATION_SIZE = 1000
+BEND_ADDRESS = Web3.to_checksum_address("0x24147243f9c08d835C218Cda1e135f8dFD0517D0")
+
+with open("abi/morpho.json") as f:
+    BEND_ABI = json.load(f)
+
+BEND_CONTRACT = w3_berachain.eth.contract(
+    address=BEND_ADDRESS,
+    abi=BEND_ABI,
+)
+
+BEND_MARKET_IDS = [
+    "0x1ba7904c73d337c39cb88b00180dffb215fc334a6ff47bbe829cd9ee2af00c97",
+]
+
+# NOTE: per https://berascan.com/tx/0x14a3eddaa857a67b1c8cb143280b506617e191374810d41b3ffeef58c5d0a7bf, the first deployment tx
+BEND_SUSDE_SUSDS_START_BLOCK = 11572788

constants/chains.py

@@ -19,3 +19,4 @@ class Chain(Enum):
     TON = "Ton"
     HYPEREVM = "HyperEVM"
     PLASMA = "Plasma"
+    BERACHAIN = "Berachain"

constants/summary_columns.py

@@ -73,6 +73,8 @@ class SummaryColumn(Enum):
 
     MORPHO_SUSDE_SUSDS_PTS = ("morpho_susde_susds_pts", SummaryColumnType.ETHENA_PTS)
 
+    BEND_SUSDE_SUSDS_PTS = ("bend_susde_susds_pts", SummaryColumnType.ETHENA_PTS)
+
     # Silo Finance LP-sUSDe (25 Sep 2025)
     SILO_FINANCE_LP_SUSDE_SEP_25_EXPIRY_PTS = (
         "silo_finance_lp_usde_sep_25_expiry_pts",

integrations/bend_susde_susds.py

@@ -0,0 +1,123 @@
+from copy import deepcopy
+import logging
+
+from typing import Dict, List
+from eth_typing import ChecksumAddress
+from constants.chains import Chain
+from constants.bend_susde_susds import (
+    BEND_CONTRACT,
+    BEND_MARKET_IDS,
+    BEND_SUSDE_SUSDS_START_BLOCK,
+    PAGINATION_SIZE,
+)
+from constants.summary_columns import SummaryColumn
+from integrations.cached_balances_integration import CachedBalancesIntegration
+from integrations.integration_ids import IntegrationID as IntID
+from utils.web3_utils import fetch_events_logs_with_retry
+
+
+class BendSusdeSusds(CachedBalancesIntegration):
+    """
+    Bend sUSDe-sUSDS LP token market integration.
+    """
+
+    def __init__(self):
+        super().__init__(
+            integration_id=IntID.BEND_SUSDE_SUSDS,
+            start_block=BEND_SUSDE_SUSDS_START_BLOCK,
+            chain=Chain.BERACHAIN,
+            summary_cols=[SummaryColumn.BEND_SUSDE_SUSDS_PTS],
+            reward_multiplier=30,
+            balance_multiplier=1,
+        )
+
+    def get_block_balances(
+        self, cached_data: Dict[int, Dict[ChecksumAddress, float]], blocks: List[int]
+    ) -> Dict[int, Dict[ChecksumAddress, float]]:
+        logging.info("Getting block data for Morpho sUSDe-sUSDS LP collateral")
+        new_block_data: Dict[int, Dict[ChecksumAddress, float]] = {}
+        if not blocks:
+            logging.error(
+                "No blocks provided to Morpho sUSDe-sUSDS LP collateral get_block_balances"
+            )
+            return new_block_data
+
+        sorted_blocks = sorted(blocks)
+        cache_copy: Dict[int, Dict[ChecksumAddress, float]] = deepcopy(cached_data)
+
+        for block in sorted_blocks:
+            # find the closest prev block in the data
+            # list keys parsed as ints and in descending order
+            sorted_existing_blocks = sorted(
+                cache_copy,
+                reverse=True,
+            )
+            # loop through the sorted blocks and find the closest previous block
+            prev_block = self.start_block
+            start = prev_block
+            bals = {}
+            for existing_block in sorted_existing_blocks:
+                if existing_block < block:
+                    prev_block = existing_block
+                    start = existing_block + 1
+                    bals = deepcopy(cache_copy[prev_block])
+                    break
+            # parse supply/withdraw events since and update bals
+            # NOTE: as per the morpho-blue EventsLib.sol comments,
+            # `feeRecipient` receives supplied shares without any event,
+            # so their sats are not accrued.
+            while start <= block:
+                to_block = min(start + PAGINATION_SIZE, block)
+
+                supplies = fetch_events_logs_with_retry(
+                    "Bend-Borrow Supply with sUSDe",
+                    BEND_CONTRACT.events.SupplyCollateral(),
+                    start,
+                    to_block,
+                    filter={"id": BEND_MARKET_IDS},
+                )
+                for supply in supplies:
+                    recipient = supply["args"]["onBehalf"]
+                    if recipient not in bals:
+                        bals[recipient] = 0
+                    bals[recipient] += round(supply["args"]["assets"] / 10**18, 4)
+
+                withdraws = fetch_events_logs_with_retry(
+                    "Bend-Borrow Supply with sUSDe",
+                    BEND_CONTRACT.events.WithdrawCollateral(),
+                    start,
+                    to_block,
+                    filter={"id": BEND_MARKET_IDS},
+                )
+                for withdraw in withdraws:
+                    recipient = withdraw["args"]["onBehalf"]
+                    if recipient not in bals:
+                        bals[recipient] = 0
+                    bals[recipient] -= round(withdraw["args"]["assets"] / 10**18, 4)
+                    if bals[recipient] < 0:
+                        bals[recipient] = 0
+                start = to_block + 1
+            new_block_data[block] = bals
+            cache_copy[block] = bals
+        return new_block_data
+
+
+if __name__ == "__main__":
+    integration = BendSusdeSusds()
+
+    # Without cached data
+    without_cached_data_output = integration.get_block_balances(
+        cached_data={}, blocks=[11572788, 12155834]
+    )
+
+    print("=" * 120)
+    print("Run without cached data", without_cached_data_output)
+    print("=" * 120, "\n" * 5)
+
+    # With cached data, using the previous output so there is no need
+    # to fetch the previous blocks again
+    with_cached_data_output = integration.get_block_balances(
+        cached_data=without_cached_data_output, blocks=[12155834]
+    )
+    print("Run with cached data", with_cached_data_output)
+    print("=" * 120)

integrations/integration_ids.py

@@ -529,6 +529,13 @@ class IntegrationID(Enum):
         Token.SUSDE,
     )
 
+    # Bend sUSDS-sUSDe
+    BEND_SUSDE_SUSDS = (
+        "bend_susde_susds",
+        "Bend sUSDe-sUSDS LP token",
+        Token.SUSDE,
+    )
+
     # Affluent
     AFFLUENT_USDE = ("affluent_usde", "Affluent TON USDe", Token.USDE)
     AFFLUENT_SUSDE = ("affluent_susde", "Affluent TON sUSDe", Token.SUSDE)

utils/web3_utils.py

@@ -42,6 +42,8 @@
 w3_hyperevm = Web3(Web3.HTTPProvider(HYPEREVM_NODE_URL))
 PLASMA_NODE_URL = os.getenv("PLASMA_NODE_URL")
 w3_plasma = Web3(Web3.HTTPProvider(PLASMA_NODE_URL))
+BERACHAIN_NODE_URL = os.getenv("BERACHAIN_NODE_URL")
+w3_berachain = Web3(Web3.HTTPProvider(BERACHAIN_NODE_URL))
 
 W3_BY_CHAIN = {
     Chain.ETHEREUM: {
@@ -89,6 +91,9 @@
     Chain.PLASMA: {
         "w3": w3_plasma,
     },
+    Chain.BERACHAIN: {
+        "w3": w3_berachain,
+    },
 }
 
 MULTICALL_ABI = [