Add Supabase integration for remote trade logging

app.py

@@ -2,8 +2,21 @@ import streamlit as st
 import asyncio
 import pandas as pd
 from datetime import datetime, timezone
+import os
+
+from supabase import create_client
 
 from src.strategies.arbitrage import CrossPlatformArbitrage
+
+@st.cache_resource
+def init_supabase():
+    url = st.secrets.get("SUPABASE_URL") or os.environ.get("SUPABASE_URL")
+    key = st.secrets.get("SUPABASE_KEY") or os.environ.get("SUPABASE_KEY")
+    if url and key:
+        return create_client(url, key)
+    return None
+
+supabase = init_supabase()
 # We would import the live clients here, but for the dashboard
 # we can instantiate the scanner and populate it directly for testing.
 
@@ -73,6 +86,32 @@ if st.session_state.opps is not None:
                 if o.market_id_pm not in st.session_state.positions:
                     st.session_state.positions.append(o.market_id_pm)
                 st.session_state.trades.append(o)
+                
+                if supabase:
+                    try:
+                        supabase.table("trades").insert({
+                            "event_id": o.event_name,
+                            "buy_platform": o.buy_platform,
+                            "sell_platform": o.sell_platform,
+                            "buy_price": o.buy_price,
+                            "sell_price": o.sell_price,
+                            "size": o.buy_size,
+                            "net_edge": o.expected_profit_margin,
+                            "pnl": profit
+                        }).execute()
+                    except Exception as e:
+                        st.error(f"Failed to write trade to Supabase: {e}")
+
+            if supabase:
+                try:
+                    supabase.table("portfolio").insert({
+                        "capital": st.session_state.capital,
+                        "pnl": st.session_state.pnl,
+                        "active_positions": len(st.session_state.positions),
+                        "market_regime": "Stable"
+                    }).execute()
+                except Exception as e:
+                    st.error(f"Failed to write portfolio snapshot to Supabase: {e}")
             
             st.session_state.opps = None
             st.rerun()

requirements.txt

@@ -20,3 +20,4 @@ torch
 streamlit
 plotly
 web3
+supabase