feat: Update API endpoint in get_transfers function

app.py

@@ -6,12 +6,17 @@ import plotly.express as px
 from datetime import datetime, timedelta
 import json
 from web3 import Web3
-from app_trans_new import create_transcation_visualizations,create_active_agents_visualizations
-from app_value_locked import fetch_daily_value_locked
+# from app_trans_new import create_transcation_visualizations,create_active_agents_visualizations
+# from app_value_locked import fetch_daily_value_locked
 import os
 
-OPTIMISM_RPC_URL = os.getenv('OPTIMISM_RPC_URL')
+from dotenv import load_dotenv
+
+# Load environment variables from .env file
+load_dotenv()
 
+OPTIMISM_RPC_URL = os.getenv('OPTIMISM_RPC_URL')
+print('OPTIMISM_RPC_URL',OPTIMISM_RPC_URL)
 # Initialize a Web3 instance
 web3 = Web3(Web3.HTTPProvider(OPTIMISM_RPC_URL))
 
@@ -30,7 +35,7 @@ with open('./contracts/service_registry_abi.json', 'r') as abi_file:
 service_registry = web3.eth.contract(address=contract_address, abi=contract_abi)
 
 def get_transfers(integrator: str, wallet: str) -> str:
-    url = f"https://li.quest/v1/analytics/transfers?&wallet={wallet}"
+    url = f"https://li.quest/v1/analytics/transfers?&wallet={wallet}&fromTimestamp=1726165800"
     headers = {"accept": "application/json"}
     response = requests.get(url, headers=headers)
     return response.json()
@@ -154,6 +159,7 @@ def process_transactions_and_agents(data):
         })
     
     df_transactions = pd.DataFrame(rows)
+    breakpoint()
     df_agents = pd.DataFrame(list(daily_agent_counts.items()), columns=['date', 'agent_count'])
     df_agents_with_transactions = pd.DataFrame(list(daily_agents_with_transactions.items()), columns=['date', 'agent_count_with_transactions'])
 
@@ -177,62 +183,63 @@ def create_visualizations():
     df_transactions, df_agents_weekly, df_agents_with_transactions_weekly, df_agents_with_transactions = process_transactions_and_agents(transactions_data)
     # Map chain IDs to chain names
 
-        # Fetch daily value locked data
-    df_tvl = fetch_daily_value_locked()
-
-    # Calculate total value locked per chain per day
-    df_tvl["total_value_locked_usd"] = df_tvl["amount0_usd"] + df_tvl["amount1_usd"]
-    df_tvl_daily = df_tvl.groupby(["date", "chain_name"])["total_value_locked_usd"].sum().reset_index()
-    df_tvl_daily['date'] = pd.to_datetime(df_tvl_daily['date'])
-
-    # Filter out dates with zero total value locked
-    df_tvl_daily = df_tvl_daily[df_tvl_daily["total_value_locked_usd"] > 0]
-    chain_name_map = {
-        "optimism": "Optimism",
-        "base": "Base",
-        "ethereum": "Ethereum"
-    }
-    df_tvl_daily["chain_name"] = df_tvl_daily["chain_name"].map(chain_name_map)
+    #     # Fetch daily value locked data
+    # df_tvl = fetch_daily_value_locked()
+
+    # # Calculate total value locked per chain per day
+    # df_tvl["total_value_locked_usd"] = df_tvl["amount0_usd"] + df_tvl["amount1_usd"]
+    # df_tvl_daily = df_tvl.groupby(["date", "chain_name"])["total_value_locked_usd"].sum().reset_index()
+    # df_tvl_daily['date'] = pd.to_datetime(df_tvl_daily['date'])
+
+    # # Filter out dates with zero total value locked
+    # df_tvl_daily = df_tvl_daily[df_tvl_daily["total_value_locked_usd"] > 0]
+    # chain_name_map = {
+    #     "optimism": "Optimism",
+    #     "base": "Base",
+    #     "ethereum": "Ethereum"
+    # }
+    # df_tvl_daily["chain_name"] = df_tvl_daily["chain_name"].map(chain_name_map)
     
-    # Plot total value locked
-    fig_tvl = px.bar(
-        df_tvl_daily,
-        x="date",
-        y="total_value_locked_usd",
-        color="chain_name",
-        opacity=0.7,
-        title="Total Volume Invested in Pools in Different Chains Daily",
-        labels={"date": "Date","chain_name": "Transaction Chain", "total_value_locked_usd": "Total Volume Invested (USD)"},
-        barmode='stack',
-        color_discrete_map={
-            "Optimism": "blue",
-            "Base": "purple",
-            "Ethereum": "darkgreen"
-        }
-    )
-    fig_tvl.update_layout(
-        xaxis_title=None,
-        yaxis=dict(tickmode='linear', tick0=0, dtick=1),
-        xaxis=dict(
-            tickmode='array',
-            tickvals=df_tvl_daily['date'],
-            ticktext=df_tvl_daily['date'].dt.strftime('%b %d'),
-            tickangle=-45,
-        ),
-        bargap=0.6,  # Increase gap between bar groups (0-1)
-        bargroupgap=0.1,  # Decrease gap between bars in a group (0-1)
-        height=600, # Specify width to prevent bars from being too wide
-        margin=dict(l=50, r=50, t=50, b=50),  # Add margins
-        showlegend=True,
-        template='plotly_white'
-    )
-    fig_tvl.update_xaxes(tickformat="%b %d") 
+    # # Plot total value locked
+    # fig_tvl = px.bar(
+    #     df_tvl_daily,
+    #     x="date",
+    #     y="total_value_locked_usd",
+    #     color="chain_name",
+    #     opacity=0.7,
+    #     title="Total Volume Invested in Pools in Different Chains Daily",
+    #     labels={"date": "Date","chain_name": "Transaction Chain", "total_value_locked_usd": "Total Volume Invested (USD)"},
+    #     barmode='stack',
+    #     color_discrete_map={
+    #         "Optimism": "blue",
+    #         "Base": "purple",
+    #         "Ethereum": "darkgreen"
+    #     }
+    # )
+    # fig_tvl.update_layout(
+    #     xaxis_title=None,
+    #     yaxis=dict(tickmode='linear', tick0=0, dtick=1),
+    #     xaxis=dict(
+    #         tickmode='array',
+    #         tickvals=df_tvl_daily['date'],
+    #         ticktext=df_tvl_daily['date'].dt.strftime('%b %d'),
+    #         tickangle=-45,
+    #     ),
+    #     bargap=0.6,  # Increase gap between bar groups (0-1)
+    #     bargroupgap=0.1,  # Decrease gap between bars in a group (0-1)
+    #     height=600, # Specify width to prevent bars from being too wide
+    #     margin=dict(l=50, r=50, t=50, b=50),  # Add margins
+    #     showlegend=True,
+    #     template='plotly_white'
+    # )
+    # fig_tvl.update_xaxes(tickformat="%b %d") 
     
 
     chain_name_map = {
         10: "Optimism",
         8453: "Base",
-        1: "Ethereum"
+        1: "Ethereum",
+        34443: "Mode"
     }
     df_transactions["sending_chain"] = df_transactions["sending_chain"].map(chain_name_map)
     df_transactions["receiving_chain"] = df_transactions["receiving_chain"].map(chain_name_map)
@@ -428,17 +435,17 @@ def create_visualizations():
         )
     )
 
-    return fig_swaps_chain, fig_bridges_chain, fig_agents_registered, fig_agents_with_transactions_daily,fig_tvl
+    return fig_swaps_chain, fig_bridges_chain, fig_agents_registered, fig_agents_with_transactions_daily
 
 # Gradio interface
 def dashboard():
     with gr.Blocks() as demo:
         gr.Markdown("# Valory Transactions Dashboard")
-        with gr.Tab("Chain Daily activity"):
-            fig_tx_chain = create_transcation_visualizations()
-            gr.Plot(fig_tx_chain)
+        # with gr.Tab("Chain Daily activity"):
+        #     fig_tx_chain = create_transcation_visualizations()
+        #     gr.Plot(fig_tx_chain)
 
-        fig_swaps_chain, fig_bridges_chain, fig_agents_registered, fig_agents_with_transactions_daily,fig_tvl = create_visualizations()    
+        fig_swaps_chain, fig_bridges_chain, fig_agents_registered, fig_agents_with_transactions_daily = create_visualizations()    
         #Fetch and display visualizations
         with gr.Tab("Swaps Daily"):
             gr.Plot(fig_swaps_chain)
@@ -451,14 +458,14 @@ def dashboard():
             #fig_swaps_chain, fig_bridges_chain, fig_agents_daily, fig_agents_with_transactions_daily,fig_tvl = create_visualizations()
             gr.Plot(fig_agents_registered)
         
-        with gr.Tab("DAA"):
-            fig_agents_with_transactions_daily = create_active_agents_visualizations()
-            #fig_swaps_chain, fig_bridges_chain, fig_agents_daily, fig_agents_with_transactions_daily,fig_tvl = create_visualizations()
-            gr.Plot(fig_agents_with_transactions_daily)
-
-        with gr.Tab("Total Value Locked"):
-            #fig_swaps_chain, fig_bridges_chain, fig_agents_daily, fig_agents_with_transactions_daily, fig_tvl,fig_tvl = create_visualizations()
-            gr.Plot(fig_tvl) 
+        # with gr.Tab("DAA"):
+        #     fig_agents_with_transactions_daily = create_active_agents_visualizations()
+        #     #fig_swaps_chain, fig_bridges_chain, fig_agents_daily, fig_agents_with_transactions_daily,fig_tvl = create_visualizations()
+        #     gr.Plot(fig_agents_with_transactions_daily)
+
+        # with gr.Tab("Total Value Locked"):
+        #     #fig_swaps_chain, fig_bridges_chain, fig_agents_daily, fig_agents_with_transactions_daily, fig_tvl,fig_tvl = create_visualizations()
+        #     gr.Plot(fig_tvl) 
 
     return demo