app.py

import streamlit as st
import pandas as pd
from src.agent import MarketRegimeAgent

st.set_page_config(page_title="Market Regime Agent", layout="wide")

st.title("📈 Market Regime Agent (v1)")
st.caption("Deterministic signals + JSON memory. Observe → Reason → Act → Remember.")

uploaded = st.file_uploader("Upload prices CSV (wide format: date, SPY, QQQ, IWM, TLT, GLD...)", type=["csv"])

memory_path = st.text_input("Memory file path", value="state/memory.json")

agent = MarketRegimeAgent(memory_path=memory_path)

if uploaded is None:
    st.info("Upload a CSV to run. Example path: data/sample_prices.csv")
    if st.button("Load sample CSV (data/sample_prices.csv)"):
        df = pd.read_csv("data/sample_prices.csv")
        decision, action = agent.run(df)
        st.success("Ran on sample data.")
    else:
        st.stop()
else:
    df = pd.read_csv(uploaded)
    decision, action = agent.run(df)
    st.success("Ran on uploaded data.")

left, right = st.columns([1, 1])

with left:
    st.subheader("Regime Decision")
    st.write(f"**As of:** {decision.asof}")
    st.write(f"**Label:** {decision.label}")
    st.write(f"**Confidence:** {decision.confidence:.2f}")

    st.subheader("Drivers")
    for d in decision.drivers:
        st.write(f"- {d}")

    st.subheader("Implications")
    for i in decision.implications:
        st.write(f"- {i}")

with right:
    st.subheader("Signals")
    s = decision.signals
    st.write({
        "trend": s.trend,
        "trend_strength": s.trend_strength,
        "realized_vol_annual": s.realized_vol_annual,
        "breadth_pct_above_ma50": s.breadth_pct_above_ma50,
        "risk_on_off": s.risk_on_off,
        "risk_on_off_score": s.risk_on_off_score
    })

    st.subheader("Agent Action")
    st.write(action)

    st.subheader("Latest Memory Snapshot")
    st.write({
        "last_regime_label": agent.memory.last_regime_label,
        "last_regime_asof": agent.memory.last_regime_asof,
        "last_alert_asof": agent.memory.last_alert_asof,
        "history_len": len(agent.memory.history)
    })