Merge pull request #100 from factorial-finance/main

feat: add Affluent integration

Author: FJ-Riveros

campaign/campaign.py

@@ -17,6 +17,7 @@
 from web3 import Web3
 from constants.evaa import EVAA_USDE_START_BLOCK, EVAA_SUSDE_START_BLOCK
 from integrations.stonfi_integration import StonFiIntegration
+from integrations.affluent_integration import AffluentIntegration
 from integrations.integration import Integration
 from integrations.integration_ids import IntegrationID
 from integrations.pendle_lpt_integration import PendleLPTIntegration
@@ -48,6 +49,20 @@
         chain=Chain.TON,
         reward_multiplier=30,
     ),
+    AffluentIntegration(
+        integration_id=IntegrationID.AFFLUENT_USDE,
+        start_block=AFFLUENT_USDE_START_BLOCK,
+        summary_cols=[SummaryColumn.AFFLUENT_USDE_PTS],
+        chain=Chain.TON,
+        reward_multiplier=20,
+    ),
+    AffluentIntegration(
+        integration_id=IntegrationID.AFFLUENT_SUSDE,
+        start_block=AFFLUENT_SUSDE_START_BLOCK,
+        summary_cols=[SummaryColumn.AFFLUENT_SUSDE_PTS],
+        chain=Chain.TON,
+        reward_multiplier=5,
+    ),
     # Template integration
     ProtocolNameIntegration(
         integration_id=IntegrationID.EXAMPLE,

constants/affluent.py

@@ -0,0 +1,11 @@
+from constants.integration_token import Token
+
+AFFLUENT_USDE_START_BLOCK = 22881841
+AFFLUENT_SUSDE_START_BLOCK = 22881841
+
+AFFLUENT_ENDPOINT = "https://api.affluent.org/v2/api"
+
+TOKEN_ADDRESS_MAP = {
+    Token.USDE: "EQAIb6KmdfdDR7CN1GBqVJuP25iCnLKCvBlJ07Evuu2dzP5f",
+    Token.SUSDE: "EQDQ5UUyPHrLcQJlPAczd_fjxn8SLrlNQwolBznxCdSlfQwr",
+}

constants/summary_columns.py

@@ -59,6 +59,9 @@ class SummaryColumn(Enum):
 
     STONFI_USDE_PTS = ("stonfi_usde_pts", SummaryColumnType.ETHENA_PTS)
 
+    AFFLUENT_USDE_PTS = ("affluent_usde_pts", SummaryColumnType.ETHENA_PTS)
+    AFFLUENT_SUSDE_PTS = ("affluent_susde_pts", SummaryColumnType.ETHENA_PTS)
+
     VENUS_SUSDE_PTS = ("venus_susde_pts", SummaryColumnType.ETHENA_PTS)
 
     # EVAA Protocol

integrations/affluent_integration.py

@@ -0,0 +1,101 @@
+import json
+from typing import Dict, List, Optional, Tuple
+
+from constants.affluent import AFFLUENT_ENDPOINT, AFFLUENT_USDE_START_BLOCK, AFFLUENT_SUSDE_START_BLOCK, TOKEN_ADDRESS_MAP
+
+from integrations.l2_delegation_integration import L2DelegationIntegration
+from integrations.integration_ids import IntegrationID
+from utils.web3_utils import get_block_date
+from utils.request_utils import requests_retry_session
+from utils.slack import slack_message
+from constants.summary_columns import SummaryColumn
+from constants.chains import Chain
+
+class AffluentIntegration(L2DelegationIntegration):
+    def __init__(
+         self,
+         integration_id: IntegrationID,
+         start_block: int,
+         summary_cols: Optional[List[SummaryColumn]] = None,
+         chain: Chain = Chain.TON,
+         reward_multiplier: int = 1,
+         end_block: Optional[int] = None,
+     ):
+         super().__init__(
+             integration_id=integration_id,
+             start_block=start_block,
+             chain=chain,
+             summary_cols=summary_cols if summary_cols else [SummaryColumn.AFFLUENT_USDE_PTS],
+             reward_multiplier=reward_multiplier,
+             end_block=end_block,
+         )
+
+    def get_l2_block_balances(
+         self,
+         cached_data: Dict[int, Dict[str, float]],
+         blocks: List[int]
+     ) -> Dict[int, Dict[str, float]]:
+        try:
+            block_balances: Dict[int, Dict[str, float]] = {}
+
+            for target_block in blocks:
+                block_balances[target_block] = self.get_participants_data(target_block)
+
+            return block_balances
+        except Exception as e:
+            err_msg = f"Error fetching Affluent balances at block {target_block}: {e}"
+            print(err_msg)
+            slack_message(err_msg)
+
+    def get_token_symbol(self):
+         return self.integration_id.get_token()
+
+    def get_participants_data(self, block: int) -> Dict[str, float]:
+        token = self.get_token_symbol()
+        token_address = TOKEN_ADDRESS_MAP[token]
+        block_data: Dict[str, float] = {}
+        target_date = get_block_date(block, self.chain, adjustment=3600, fmt="%Y-%m-%dT%H:%M:%S")
+
+        try:
+            res = requests_retry_session().get(
+                AFFLUENT_ENDPOINT + "/holdings",
+                params={
+                    "assets": token_address,
+                    "timestamp": target_date,
+                },
+                timeout=60,
+            )
+            payload = res.json()
+
+            if payload is None:
+                raise Exception(f"Error getting participants data for Affluent Protocol token {token} at block {block}: {e}")
+            
+            for user_data in payload["result"]:
+                block_data[user_data["user_address"]] = user_data["balance"]
+
+        except Exception as e:
+                err_msg = f"Error getting participants data for Affluent Protocol at block {block}: {e}"
+                slack_message(err_msg)
+
+        return block_data
+
+
+if __name__ == "__main__":
+    affluent_integration_usde = AffluentIntegration(
+        integration_id=IntegrationID.AFFLUENT_USDE,
+        start_block=AFFLUENT_USDE_START_BLOCK,
+        summary_cols=[SummaryColumn.AFFLUENT_USDE_PTS],
+        chain=Chain.TON,
+        reward_multiplier=20
+    )
+    affluent_integration_susde = AffluentIntegration(
+        integration_id=IntegrationID.AFFLUENT_SUSDE,
+        start_block=AFFLUENT_SUSDE_START_BLOCK,
+        summary_cols=[SummaryColumn.AFFLUENT_SUSDE_PTS],
+        chain=Chain.TON,
+        reward_multiplier=5
+    )
+
+    print("Affluent USDe  :", json.dumps(affluent_integration_usde.get_l2_block_balances(cached_data={}, blocks=[22895215, 22895215 - 600]), indent=2))
+    print("Affluent sUSDe :", json.dumps(affluent_integration_susde.get_l2_block_balances(cached_data={}, blocks=[22895215]), indent=2))
+

integrations/integration_ids.py

@@ -505,6 +505,11 @@ class IntegrationID(Enum):
         Token.SUSDE,
     )
 
+
+    # Affluent
+    AFFLUENT_USDE = ("affluent_usde", "Affluent TON USDe", Token.USDE)
+    AFFLUENT_SUSDE = ("affluent_susde", "Affluent TON sUSDe", Token.SUSDE)
+
     # Silo Finance LP-sUSDe (25 Sep 2025)
     SILO_FINANCE_LP_SUSDE_SEP_25_EXPIRY = (
         "silo_finance_lp_susde_sep_25_expiry",
@@ -526,6 +531,7 @@ class IntegrationID(Enum):
         Token.USDE,
     )
 
+
     def __init__(self, column_name: str, description: str, token: Token = Token.USDE):
         self.column_name = column_name
         self.description = description