Sync from GitHub

engine/engine/trend_engine.py

@@ -0,0 +1,36 @@
+import numpy as np
+import pandas as pd
+
+def run_trend_module(prices, daily_sofr, vol_target):
+    # 1. Signals (20-day Keltner/Donchian)
+    d_high = prices.rolling(20).max()
+    k_sma = prices.rolling(20).mean()
+    atr = (prices.rolling(20).max() - prices.rolling(20).min()) / 2
+    k_upper = k_sma + (2 * atr)
+    
+    entry_band = np.minimum(d_high, k_upper)
+    signals = (prices > entry_band.shift(1)).astype(int)
+    
+    # 2. Risk Parity Weighting
+    rets = prices.pct_change()
+    real_vol = rets.rolling(21).std() * np.sqrt(252)
+    
+    n = len(prices.columns)
+    weights = (vol_target / n) / real_vol.shift(1)
+    
+    # 3. Strategy Returns (Positions + Cash Interest)
+    strat_rets = (signals.shift(1) * weights.shift(1) * rets).sum(axis=1)
+    unused_cap = 1 - (signals.shift(1) * weights.shift(1)).sum(axis=1)
+    strat_rets += unused_cap.clip(0, 1) * (daily_sofr / 252)
+    
+    equity_curve = (1 + strat_rets).cumprod()
+    
+    # Next Day Allocation
+    tomorrow_sig = (prices.iloc[-1] > entry_band.iloc[-1]).astype(int)
+    tomorrow_w = (vol_target / n) / real_vol.iloc[-1]
+    alloc = pd.DataFrame({
+        "Ticker": prices.columns,
+        "Weight (%)": (tomorrow_sig * tomorrow_w * 100).round(2)
+    })
+    
+    return {"curve": equity_curve, "alloc": alloc}

hf_space/app.py

@@ -1,54 +1,39 @@
 import streamlit as st
+import pandas as pd
+from data.loader import refresh_market_data, X_EQUITY_TICKERS, FI_TICKERS
+from engine.trend_engine import run_trend_module
 
-st.set_page_config(page_title="P2 ETF Trend Suite", layout="wide")
+st.set_page_config(layout="wide", page_title="P2 ETF Trend Suite")
 
-st.title("📊 P2 ETF Trend Suite")
-st.markdown("Stooq-Primary Data Engine + HF Integration")
+st.sidebar.title("Settings")
+vol_target = st.sidebar.slider("Annual Vol Target", 0.05, 0.25, 0.126)
 
-# Sidebar Controls
-st.sidebar.header("Parameters")
-initial_capital = st.sidebar.number_input("Initial Capital", value=100000)
-vol_target = st.sidebar.slider("Target Volatility", 0.05, 0.30, 0.15)
-lookback = st.sidebar.slider("Lookback (Days)", 50, 300, 200)
+if st.sidebar.button("🔄 Refresh Market Data"):
+    refresh_market_data()
+    st.sidebar.success("Data Updated from Stooq/SOFR!")
 
-st.sidebar.markdown("---")
-st.sidebar.header("Hugging Face Sync")
-hf_repo = st.sidebar.text_input("Repo ID", placeholder="user/dataset-name")
-hf_token = st.sidebar.text_input("HF Token", type="password")
-
-run_button = st.sidebar.button("▶ Run Full Process")
-
-if run_button:
-    from data.loader import load_data, push_to_hf
-    from engine.backtest import run_backtest
-    from analytics.metrics import compute_metrics
-
-    # Phase 1: Data Fetching
-    with st.spinner("Fetching data from Stooq..."):
-        df = load_data()
+if st.button("▶ Run All Modules"):
+    data = pd.read_csv("market_data.csv", index_col=0, parse_dates=True)
     
-    if not df.empty:
-        st.subheader("📈 Market Data Preview")
-        st.dataframe(df.tail(5), use_container_width=True)
-
-        # Phase 2: Backtesting
-        with st.spinner("Calculating Trend Strategy..."):
-            results = run_backtest(df, initial_capital, vol_target, lookback)
-            metrics = compute_metrics(results["returns"])
-
-        # Display Results
-        st.success("Analysis Complete")
-        c1, c2, c3 = st.columns(3)
-        c1.metric("CAGR", f"{metrics['cagr']:.2%}")
-        c2.metric("Sharpe", f"{metrics['sharpe']:.2f}")
-        c3.metric("Max Drawdown", f"{metrics['max_dd']:.2%}")
-
-        st.line_chart(results["equity_curve"])
-
-        # Phase 3: HF Sync
-        if hf_repo and hf_token:
-            with st.spinner("Syncing to Hugging Face..."):
-                push_to_hf(df, hf_repo, hf_token)
-            st.sidebar.success("✅ Dataset Synced!")
-    else:
-        st.error("Data fetch failed. Verify ticker symbols.")
+    # Run Modules
+    eq_res = run_trend_module(data[X_EQUITY_TICKERS], data['SOFR_ANNUAL'], vol_target)
+    fi_res = run_trend_module(data[FI_TICKERS], data['SOFR_ANNUAL'], vol_target)
+    
+    # Performance Comparison
+    spy_curve = (1 + data['SPY'].pct_change()).cumprod()
+    comparison = pd.DataFrame({
+        "X-ETF Strategy": eq_res['curve'],
+        "SPY Benchmark": spy_curve
+    }).dropna()
+
+    st.header("📈 Performance: Equity Strategy vs. SPY")
+    st.line_chart(comparison)
+    
+    # Target Allocations
+    col1, col2 = st.columns(2)
+    with col1:
+        st.subheader("🛡️ Equity Allocation (Next Day)")
+        st.dataframe(eq_res['alloc'][eq_res['alloc']['Weight (%)'] > 0])
+    with col2:
+        st.subheader("🏦 FI Comparison Allocation")
+        st.dataframe(fi_res['alloc'][fi_res['alloc']['Weight (%)'] > 0])

hf_space/hf_space/data/loader.py

@@ -1,56 +1,32 @@
-import pandas as pd
 import pandas_datareader.data as web
 import yfinance as yf
-from datasets import Dataset
+import pandas as pd
 import streamlit as st
-from datetime import datetime
 
-# Combined Universe (All will attempt Stooq first)
-TICKERS = ["SPY", "QQQ", "IWM", "TLT", "IEF", "SHY", "GLD"]
+# 27 "X-" EQUITY ETFS
+X_EQUITY_TICKERS = [
+    "XLK", "XLY", "XLP", "XLE", "XLV", "XLI", "XLB", "XLRE", "XLU", "XLC", "XLF",
+    "XBI", "XME", "XOP", "XHB", "XSD", "XRT", "XPH", "XES", "XAR", "XHS", "XHE", 
+    "XSW", "XTN", "XTL", "XNTK", "XITK"
+]
 
-def load_data(tickers=TICKERS):
-    """Fetches data from Stooq with yfinance fallback."""
-    all_series = {}
+# 15 FIXED INCOME / COMPARISON
+FI_TICKERS = ["TLT", "IEF", "TIP", "TBT", "GLD", "SLV", "VGIT", "VCLT", "VCIT", "HYG", "PFF", "MBB", "VNQ", "LQD", "AGG"]
 
-    for ticker in tickers:
-        success = False
-        # 1. Primary: Stooq
+def refresh_market_data():
+    """Syncs Stooq/FRED data to local CSV and HF."""
+    all_prices = {}
+    # Download all groups + SPY Benchmark
+    for t in list(set(X_EQUITY_TICKERS + FI_TICKERS + ["SPY"])):
         try:
-            # Stooq format: TICKER.US (e.g., TLT.US)
-            stooq_symbol = f"{ticker}.US"
-            df_stooq = web.DataReader(stooq_symbol, 'stooq')
+            all_prices[t] = web.DataReader(f"{t}.US", "stooq")['Close']
+        except:
+            all_prices[t] = yf.download(t, progress=False)['Adj Close']
             
-            if not df_stooq.empty:
-                # Stooq returns newest data first; sort to ascending for backtests
-                all_series[ticker] = df_stooq['Close'].sort_index()
-                st.toast(f"✅ {ticker} loaded from Stooq")
-                success = True
-        except Exception as e:
-            print(f"Stooq failed for {ticker}: {e}")
-
-        # 2. Fallback: yfinance
-        if not success:
-            try:
-                yf_df = yf.download(ticker, period="max", progress=False)
-                if not yf_df.empty:
-                    # Use Adj Close to account for dividends/splits
-                    all_series[ticker] = yf_df['Adj Close']
-                    st.toast(f"⚠️ {ticker} loaded from yfinance (Fallback)")
-                    success = True
-            except Exception as e:
-                st.error(f"❌ Critical: Could not load {ticker} from any source.")
-
-    if all_series:
-        # Align all tickers on the same dates and drop missing values
-        return pd.concat(all_series, axis=1).dropna()
-    return pd.DataFrame()
-
-def push_to_hf(df, repo_id, token):
-    """Pushes the current dataframe to Hugging Face Hub."""
-    # Ensure Date is a column, not an index, for HF compatibility
-    hf_export = df.reset_index()
-    hf_export.columns = [str(col) for col in hf_export.columns] # Ensure string columns
+    # Fetch SOFR (Cash Yield) from FRED
+    sofr = web.DataReader('SOFR', 'fred').ffill()
     
-    dataset = Dataset.from_pandas(hf_export)
-    dataset.push_to_hub(repo_id, token=token)
-    return True
+    df = pd.DataFrame(all_prices).sort_index().ffill()
+    df['SOFR_ANNUAL'] = sofr / 100
+    df.to_csv("market_data.csv")
+    return df

hf_space/hf_space/hf_space/README.md

@@ -1,19 +1,15 @@
 ---
-title: P2 ETF TREND SUITE
-emoji: 🚀
-colorFrom: red
-colorTo: red
+title: P2 ETF Trend Suite
+emoji: 📊
+colorFrom: blue
+colorTo: indigo
 sdk: docker
-app_port: 8501
-tags:
-- streamlit
+app_port: 7860
 pinned: false
-short_description: Streamlit template space
 ---
 
-# Welcome to Streamlit!
+# 📊 P2 ETF Trend Suite
+Institutional ETF Trend + Volatility Targeting Engine.
 
-Edit `/src/streamlit_app.py` to customize this app to your heart's desire. :heart:
-
-If you have any questions, checkout our [documentation](https://docs.streamlit.io) and [community
-forums](https://discuss.streamlit.io).
+### 🚀 Setup Info
+This Space runs a Dockerized Streamlit app. It uses **Stooq** for market data with **yfinance** as a fallback.

hf_space/hf_space/hf_space/hf_space/Dockerfile

@@ -1,26 +1,31 @@
-FROM python:3.10
+# Use a lightweight but stable Python base
+FROM python:3.10-slim
+
+# Set environment variables for speed and logging
+ENV PYTHONUNBUFFERED=1 \
+    PYTHONDONTWRITEBYTECODE=1 \
+    PIP_NO_CACHE_DIR=1
 
 WORKDIR /app
 
-# Copy requirements first (better layer caching)
+# Install system dependencies needed for pandas/datareader
+RUN apt-get update && apt-get install -y \
+    build-essential \
+    curl \
+    && rm -rf /var/lib/apt/lists/*
+
+# Copy only requirements first to leverage Docker cache
 COPY requirements.txt .
 
-RUN pip install --upgrade pip
-RUN pip install --no-cache-dir -r requirements.txt
+# Install dependencies (use --no-cache-dir to keep image small)
+RUN pip install --upgrade pip && \
+    pip install -r requirements.txt
 
-# Copy full project
+# Copy the rest of the application
 COPY . .
 
+# Ensure the app runs on the port HF expects (7860 for Docker)
 EXPOSE 7860
 
-ENV STREAMLIT_SERVER_PORT=7860
-ENV STREAMLIT_SERVER_ADDRESS=0.0.0.0
-ENV STREAMLIT_BROWSER_GATHER_USAGE_STATS=false
-
-# Diagnostic startup command
-CMD ["bash", "-c", "echo '===== CONTAINER BOOTING ====='; \
-echo 'Python Version:'; python -V; \
-echo 'Current Directory:'; pwd; \
-echo 'Directory Listing:'; ls -la; \
-echo 'Starting Streamlit...'; \
-python -m streamlit run app.py --server.headless=true"]
+# Correct entrypoint for Streamlit in a container
+ENTRYPOINT ["streamlit", "run", "app.py", "--server.port=7860", "--server.address=0.0.0.0"]

hf_space/hf_space/hf_space/hf_space/hf_space/engine/engine/__init__.py

@@ -0,0 +1 @@
+

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/data/data/__init__.py

@@ -0,0 +1 @@
+

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/analytics/analytics/__init__.py

@@ -0,0 +1 @@
+

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/app.py

@@ -1,80 +1,54 @@
 import streamlit as st
 
-# =====================================================
-# PAGE CONFIG (ONLY LIGHT CODE HERE)
-# =====================================================
-
-st.set_page_config(
-    page_title="P2 ETF Trend Suite",
-    layout="wide",
-)
+st.set_page_config(page_title="P2 ETF Trend Suite", layout="wide")
 
 st.title("📊 P2 ETF Trend Suite")
-st.markdown("Institutional ETF Trend + Volatility Targeting Engine")
-
-# =====================================================
-# SIDEBAR
-# =====================================================
-
-st.sidebar.header("Strategy Controls")
-
-initial_capital = st.sidebar.number_input(
-    "Initial Capital",
-    value=100000,
-    step=10000,
-)
+st.markdown("Stooq-Primary Data Engine + HF Integration")
 
-vol_target = st.sidebar.slider(
-    "Target Annual Volatility",
-    0.05, 0.30, 0.15
-)
-
-lookback = st.sidebar.slider(
-    "Momentum Lookback (days)",
-    50, 300, 200
-)
-
-run_button = st.sidebar.button("▶ Run Backtest")
+# Sidebar Controls
+st.sidebar.header("Parameters")
+initial_capital = st.sidebar.number_input("Initial Capital", value=100000)
+vol_target = st.sidebar.slider("Target Volatility", 0.05, 0.30, 0.15)
+lookback = st.sidebar.slider("Lookback (Days)", 50, 300, 200)
 
 st.sidebar.markdown("---")
-st.sidebar.info("Backtest runs only when button is pressed.")
+st.sidebar.header("Hugging Face Sync")
+hf_repo = st.sidebar.text_input("Repo ID", placeholder="user/dataset-name")
+hf_token = st.sidebar.text_input("HF Token", type="password")
 
-# =====================================================
-# EXECUTION BLOCK
-# =====================================================
+run_button = st.sidebar.button("▶ Run Full Process")
 
 if run_button:
+    from data.loader import load_data, push_to_hf
+    from engine.backtest import run_backtest
+    from analytics.metrics import compute_metrics
 
-    with st.spinner("Loading engine..."):
-
-        # Lazy imports happen HERE
-        from engine.backtest import run_backtest
-        from data.loader import load_data
-        from analytics.metrics import compute_metrics
-
-    with st.spinner("Loading market data..."):
+    # Phase 1: Data Fetching
+    with st.spinner("Fetching data from Stooq..."):
         df = load_data()
-
-    with st.spinner("Running strategy..."):
-        results = run_backtest(
-            df=df,
-            initial_capital=initial_capital,
-            vol_target=vol_target,
-            lookback=lookback,
-        )
-
-    metrics = compute_metrics(results["returns"])
-
-    st.success("Backtest Complete")
-
-    col1, col2, col3, col4 = st.columns(4)
-    col1.metric("CAGR", f"{metrics['cagr']:.2%}")
-    col2.metric("Sharpe", f"{metrics['sharpe']:.2f}")
-    col3.metric("Max Drawdown", f"{metrics['max_dd']:.2%}")
-    col4.metric("Volatility", f"{metrics['vol']:.2%}")
-
-    st.subheader("Equity Curve")
-    st.line_chart(results["equity_curve"])
-
-else:
-    st.info("Configure parameters and click Run Backtest.")
+    
+    if not df.empty:
+        st.subheader("📈 Market Data Preview")
+        st.dataframe(df.tail(5), use_container_width=True)
+
+        # Phase 2: Backtesting
+        with st.spinner("Calculating Trend Strategy..."):
+            results = run_backtest(df, initial_capital, vol_target, lookback)
+            metrics = compute_metrics(results["returns"])
+
+        # Display Results
+        st.success("Analysis Complete")
+        c1, c2, c3 = st.columns(3)
+        c1.metric("CAGR", f"{metrics['cagr']:.2%}")
+        c2.metric("Sharpe", f"{metrics['sharpe']:.2f}")
+        c3.metric("Max Drawdown", f"{metrics['max_dd']:.2%}")
+
+        st.line_chart(results["equity_curve"])
+
+        # Phase 3: HF Sync
+        if hf_repo and hf_token:
+            with st.spinner("Syncing to Hugging Face..."):
+                push_to_hf(df, hf_repo, hf_token)
+            st.sidebar.success("✅ Dataset Synced!")
+    else:
+        st.error("Data fetch failed. Verify ticker symbols.")

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/data/loader.py

@@ -1,15 +1,56 @@
-def load_data():
-    import pandas as pd
-    import yfinance as yf
+import pandas as pd
+import pandas_datareader.data as web
+import yfinance as yf
+from datasets import Dataset
+import streamlit as st
+from datetime import datetime
 
-    tickers = ["SPY", "QQQ", "TLT"]
+# Combined Universe (All will attempt Stooq first)
+TICKERS = ["SPY", "QQQ", "IWM", "TLT", "IEF", "SHY", "GLD"]
 
-    data = yf.download(
-        tickers,
-        start="2015-01-01",
-        progress=False,
-    )["Adj Close"]
+def load_data(tickers=TICKERS):
+    """Fetches data from Stooq with yfinance fallback."""
+    all_series = {}
 
-    data = data.dropna()
+    for ticker in tickers:
+        success = False
+        # 1. Primary: Stooq
+        try:
+            # Stooq format: TICKER.US (e.g., TLT.US)
+            stooq_symbol = f"{ticker}.US"
+            df_stooq = web.DataReader(stooq_symbol, 'stooq')
+            
+            if not df_stooq.empty:
+                # Stooq returns newest data first; sort to ascending for backtests
+                all_series[ticker] = df_stooq['Close'].sort_index()
+                st.toast(f"✅ {ticker} loaded from Stooq")
+                success = True
+        except Exception as e:
+            print(f"Stooq failed for {ticker}: {e}")
 
-    return data
+        # 2. Fallback: yfinance
+        if not success:
+            try:
+                yf_df = yf.download(ticker, period="max", progress=False)
+                if not yf_df.empty:
+                    # Use Adj Close to account for dividends/splits
+                    all_series[ticker] = yf_df['Adj Close']
+                    st.toast(f"⚠️ {ticker} loaded from yfinance (Fallback)")
+                    success = True
+            except Exception as e:
+                st.error(f"❌ Critical: Could not load {ticker} from any source.")
+
+    if all_series:
+        # Align all tickers on the same dates and drop missing values
+        return pd.concat(all_series, axis=1).dropna()
+    return pd.DataFrame()
+
+def push_to_hf(df, repo_id, token):
+    """Pushes the current dataframe to Hugging Face Hub."""
+    # Ensure Date is a column, not an index, for HF compatibility
+    hf_export = df.reset_index()
+    hf_export.columns = [str(col) for col in hf_export.columns] # Ensure string columns
+    
+    dataset = Dataset.from_pandas(hf_export)
+    dataset.push_to_hub(repo_id, token=token)
+    return True

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/Dockerfile

@@ -2,11 +2,13 @@ FROM python:3.10
 
 WORKDIR /app
 
+# Copy requirements first (better layer caching)
 COPY requirements.txt .
 
 RUN pip install --upgrade pip
 RUN pip install --no-cache-dir -r requirements.txt
 
+# Copy full project
 COPY . .
 
 EXPOSE 7860
@@ -15,4 +17,10 @@ ENV STREAMLIT_SERVER_PORT=7860
 ENV STREAMLIT_SERVER_ADDRESS=0.0.0.0
 ENV STREAMLIT_BROWSER_GATHER_USAGE_STATS=false
 
-CMD streamlit run app.py
+# Diagnostic startup command
+CMD ["bash", "-c", "echo '===== CONTAINER BOOTING ====='; \
+echo 'Python Version:'; python -V; \
+echo 'Current Directory:'; pwd; \
+echo 'Directory Listing:'; ls -la; \
+echo 'Starting Streamlit...'; \
+python -m streamlit run app.py --server.headless=true"]

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/data/loader.py

@@ -0,0 +1,15 @@
+def load_data():
+    import pandas as pd
+    import yfinance as yf
+
+    tickers = ["SPY", "QQQ", "TLT"]
+
+    data = yf.download(
+        tickers,
+        start="2015-01-01",
+        progress=False,
+    )["Adj Close"]
+
+    data = data.dropna()
+
+    return data

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/analytics/metrics.py

@@ -1,26 +1,21 @@
-import numpy as np
-import pandas as pd
+def compute_metrics(returns):
 
-def compute_metrics(returns, sofr):
+    import numpy as np
 
-    sofr_daily = sofr.reindex(returns.index).fillna(method="ffill")["sofr"] / 252
-    excess = returns - sofr_daily
+    ann_factor = 252
 
-    sharpe = np.sqrt(252) * excess.mean() / excess.std()
+    cagr = (1 + returns.mean()) ** ann_factor - 1
+    vol = returns.std() * (ann_factor ** 0.5)
+    sharpe = cagr / vol if vol != 0 else 0
 
-    equity = (1 + returns).cumprod()
-    cagr = equity.iloc[-1] ** (252 / len(equity)) - 1
-
-    vol = returns.std() * np.sqrt(252)
-
-    rolling_max = equity.cummax()
-    drawdown = equity / rolling_max - 1
+    cumulative = (1 + returns).cumprod()
+    peak = cumulative.cummax()
+    drawdown = (cumulative - peak) / peak
     max_dd = drawdown.min()
 
     return {
-        "sharpe": sharpe,
         "cagr": cagr,
         "vol": vol,
-        "max_dd": max_dd
+        "sharpe": sharpe,
+        "max_dd": max_dd,
     }
-

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/engine/backtest.py

@@ -1,46 +1,20 @@
-import pandas as pd
-import numpy as np
-
 def run_backtest(df, initial_capital, vol_target, lookback):
 
-    df = df.sort_values(["ticker", "date"])
-    prices = df.pivot(index="date", columns="ticker", values="adjusted_close")
-    returns = prices.pct_change().dropna()
-
-    momentum = prices.pct_change(lookback)
-    signal = momentum.rank(axis=1, ascending=False)
-    top = signal <= 3
-
-    weights = top.div(top.sum(axis=1), axis=0)
-
-    rolling_cov = returns.rolling(60).cov()
-    vol = []
+    import numpy as np
+    import pandas as pd
 
-    for date in weights.index:
-        if date not in rolling_cov.index:
-            vol.append(0)
-            continue
+    returns = df.pct_change().dropna()
 
-        w = weights.loc[date].values
-        cov = rolling_cov.loc[date].values.reshape(len(w), len(w))
-        portfolio_vol = np.sqrt(w @ cov @ w) * np.sqrt(252)
+    momentum = df.pct_change(lookback)
 
-        scale = vol_target / portfolio_vol if portfolio_vol > 0 else 0
-        weights.loc[date] = w * scale
-        vol.append(portfolio_vol)
+    weights = (momentum > 0).astype(int)
+    weights = weights.div(weights.sum(axis=1), axis=0).fillna(0)
 
     strategy_returns = (weights.shift(1) * returns).sum(axis=1)
-    equity_curve = (1 + strategy_returns).cumprod() * initial_capital
 
-    latest_weights = weights.iloc[-1]
-    allocation = pd.DataFrame({
-        "Ticker": latest_weights.index,
-        "Weight": latest_weights.values
-    }).sort_values("Weight", ascending=False)
+    equity_curve = (1 + strategy_returns).cumprod() * initial_capital
 
     return {
         "returns": strategy_returns,
         "equity_curve": equity_curve,
-        "latest_allocation": allocation
     }
-

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/app.py

@@ -1,7 +1,7 @@
 import streamlit as st
 
 # =====================================================
-# PAGE CONFIG (must be first Streamlit command)
+# PAGE CONFIG (ONLY LIGHT CODE HERE)
 # =====================================================
 
 st.set_page_config(
@@ -13,7 +13,7 @@ st.title("📊 P2 ETF Trend Suite")
 st.markdown("Institutional ETF Trend + Volatility Targeting Engine")
 
 # =====================================================
-# SIDEBAR CONTROLS
+# SIDEBAR
 # =====================================================
 
 st.sidebar.header("Strategy Controls")
@@ -26,16 +26,12 @@ initial_capital = st.sidebar.number_input(
 
 vol_target = st.sidebar.slider(
     "Target Annual Volatility",
-    min_value=0.05,
-    max_value=0.30,
-    value=0.15,
+    0.05, 0.30, 0.15
 )
 
 lookback = st.sidebar.slider(
     "Momentum Lookback (days)",
-    min_value=50,
-    max_value=300,
-    value=200,
+    50, 300, 200
 )
 
 run_button = st.sidebar.button("▶ Run Backtest")
@@ -44,34 +40,22 @@ st.sidebar.markdown("---")
 st.sidebar.info("Backtest runs only when button is pressed.")
 
 # =====================================================
-# MAIN EXECUTION (runs ONLY when button clicked)
+# EXECUTION BLOCK
 # =====================================================
 
 if run_button:
 
-    # Import heavy modules only when needed
-    from data.hf_store import load_dataset
-    from data.updater import update_market_data
-    from data.fred import get_sofr_series
-    from engine.backtest import run_backtest
-    from analytics.metrics import compute_metrics
-
-    # ---------------------------
-    # Load Dataset
-    # ---------------------------
-    with st.spinner("Loading ETF dataset from Hugging Face..."):
-        df = load_dataset()
-
-    # ---------------------------
-    # Pull SOFR
-    # ---------------------------
-    with st.spinner("Pulling SOFR from FRED..."):
-        sofr = get_sofr_series()
-
-    # ---------------------------
-    # Run Backtest
-    # ---------------------------
-    with st.spinner("Running backtest engine..."):
+    with st.spinner("Loading engine..."):
+
+        # Lazy imports happen HERE
+        from engine.backtest import run_backtest
+        from data.loader import load_data
+        from analytics.metrics import compute_metrics
+
+    with st.spinner("Loading market data..."):
+        df = load_data()
+
+    with st.spinner("Running strategy..."):
         results = run_backtest(
             df=df,
             initial_capital=initial_capital,
@@ -79,38 +63,18 @@ if run_button:
             lookback=lookback,
         )
 
-    metrics = compute_metrics(results["returns"], sofr)
+    metrics = compute_metrics(results["returns"])
 
     st.success("Backtest Complete")
 
-    # =====================================================
-    # METRICS PANEL
-    # =====================================================
-
     col1, col2, col3, col4 = st.columns(4)
-
     col1.metric("CAGR", f"{metrics['cagr']:.2%}")
-    col2.metric("Sharpe (SOFR)", f"{metrics['sharpe']:.2f}")
+    col2.metric("Sharpe", f"{metrics['sharpe']:.2f}")
     col3.metric("Max Drawdown", f"{metrics['max_dd']:.2%}")
     col4.metric("Volatility", f"{metrics['vol']:.2%}")
 
-    st.markdown("---")
-
-    # =====================================================
-    # EQUITY CURVE
-    # =====================================================
-
     st.subheader("Equity Curve")
     st.line_chart(results["equity_curve"])
 
-    st.markdown("---")
-
-    # =====================================================
-    # ALLOCATION TABLE
-    # =====================================================
-
-    st.subheader("Latest Portfolio Allocation")
-    st.dataframe(results["latest_allocation"], use_container_width=True)
-
 else:
-    st.info("Configure parameters in the sidebar and click **Run Backtest**.")
+    st.info("Configure parameters and click Run Backtest.")

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/Dockerfile

@@ -1,13 +1,18 @@
-FROM python:3.10-slim
+FROM python:3.10
 
 WORKDIR /app
 
 COPY requirements.txt .
 
+RUN pip install --upgrade pip
 RUN pip install --no-cache-dir -r requirements.txt
 
 COPY . .
 
 EXPOSE 7860
 
-CMD ["streamlit", "run", "app.py", "--server.port=7860", "--server.address=0.0.0.0"]
+ENV STREAMLIT_SERVER_PORT=7860
+ENV STREAMLIT_SERVER_ADDRESS=0.0.0.0
+ENV STREAMLIT_BROWSER_GATHER_USAGE_STATS=false
+
+CMD streamlit run app.py

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/app.py

@@ -1,70 +1,116 @@
 import streamlit as st
-import os
 
-from data.hf_store import load_dataset
-from data.updater import update_market_data
-from data.fred import get_sofr_series
-from engine.backtest import run_backtest
-from analytics.metrics import compute_metrics
+# =====================================================
+# PAGE CONFIG (must be first Streamlit command)
+# =====================================================
 
-st.set_page_config(layout="wide")
+st.set_page_config(
+    page_title="P2 ETF Trend Suite",
+    layout="wide",
+)
 
 st.title("📊 P2 ETF Trend Suite")
 st.markdown("Institutional ETF Trend + Volatility Targeting Engine")
 
-# ========================
-# Sidebar Controls
-# ========================
+# =====================================================
+# SIDEBAR CONTROLS
+# =====================================================
 
-st.sidebar.header("Controls")
+st.sidebar.header("Strategy Controls")
 
-initial_capital = st.sidebar.number_input("Initial Capital", value=100000, step=10000)
-vol_target = st.sidebar.slider("Target Annual Volatility", 0.05, 0.30, 0.15)
-lookback = st.sidebar.slider("Momentum Lookback (days)", 50, 300, 200)
+initial_capital = st.sidebar.number_input(
+    "Initial Capital",
+    value=100000,
+    step=10000,
+)
 
-refresh = st.sidebar.button("🔄 Refresh Market Data")
+vol_target = st.sidebar.slider(
+    "Target Annual Volatility",
+    min_value=0.05,
+    max_value=0.30,
+    value=0.15,
+)
 
-# ========================
-# Data Load
-# ========================
+lookback = st.sidebar.slider(
+    "Momentum Lookback (days)",
+    min_value=50,
+    max_value=300,
+    value=200,
+)
 
-with st.spinner("Loading ETF dataset..."):
-    df = load_dataset()
+run_button = st.sidebar.button("▶ Run Backtest")
 
-if refresh:
-    with st.spinner("Updating market data from yfinance..."):
-        df = update_market_data(df)
-    st.success("Dataset updated successfully.")
+st.sidebar.markdown("---")
+st.sidebar.info("Backtest runs only when button is pressed.")
 
-# ========================
-# Backtest
-# ========================
+# =====================================================
+# MAIN EXECUTION (runs ONLY when button clicked)
+# =====================================================
 
-with st.spinner("Pulling SOFR from FRED..."):
-    sofr = get_sofr_series()
+if run_button:
 
-with st.spinner("Running backtest..."):
-    results = run_backtest(
-        df=df,
-        initial_capital=initial_capital,
-        vol_target=vol_target,
-        lookback=lookback,
-    )
+    # Import heavy modules only when needed
+    from data.hf_store import load_dataset
+    from data.updater import update_market_data
+    from data.fred import get_sofr_series
+    from engine.backtest import run_backtest
+    from analytics.metrics import compute_metrics
 
-metrics = compute_metrics(results["returns"], sofr)
+    # ---------------------------
+    # Load Dataset
+    # ---------------------------
+    with st.spinner("Loading ETF dataset from Hugging Face..."):
+        df = load_dataset()
 
-# ========================
-# Layout
-# ========================
+    # ---------------------------
+    # Pull SOFR
+    # ---------------------------
+    with st.spinner("Pulling SOFR from FRED..."):
+        sofr = get_sofr_series()
 
-col1, col2, col3, col4 = st.columns(4)
+    # ---------------------------
+    # Run Backtest
+    # ---------------------------
+    with st.spinner("Running backtest engine..."):
+        results = run_backtest(
+            df=df,
+            initial_capital=initial_capital,
+            vol_target=vol_target,
+            lookback=lookback,
+        )
 
-col1.metric("CAGR", f"{metrics['cagr']:.2%}")
-col2.metric("Sharpe (SOFR)", f"{metrics['sharpe']:.2f}")
-col3.metric("Max Drawdown", f"{metrics['max_dd']:.2%}")
-col4.metric("Volatility", f"{metrics['vol']:.2%}")
+    metrics = compute_metrics(results["returns"], sofr)
 
-st.line_chart(results["equity_curve"])
+    st.success("Backtest Complete")
 
-st.subheader("Current Allocation")
-st.dataframe(results["latest_allocation"])
+    # =====================================================
+    # METRICS PANEL
+    # =====================================================
+
+    col1, col2, col3, col4 = st.columns(4)
+
+    col1.metric("CAGR", f"{metrics['cagr']:.2%}")
+    col2.metric("Sharpe (SOFR)", f"{metrics['sharpe']:.2f}")
+    col3.metric("Max Drawdown", f"{metrics['max_dd']:.2%}")
+    col4.metric("Volatility", f"{metrics['vol']:.2%}")
+
+    st.markdown("---")
+
+    # =====================================================
+    # EQUITY CURVE
+    # =====================================================
+
+    st.subheader("Equity Curve")
+    st.line_chart(results["equity_curve"])
+
+    st.markdown("---")
+
+    # =====================================================
+    # ALLOCATION TABLE
+    # =====================================================
+
+    st.subheader("Latest Portfolio Allocation")
+    st.dataframe(results["latest_allocation"], use_container_width=True)
+
+else:
+    st.info("Configure parameters in the sidebar and click **Run Backtest**.")

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/Dockerfile

@@ -1,20 +1,13 @@
-FROM python:3.13.5-slim
+FROM python:3.10-slim
 
 WORKDIR /app
 
-RUN apt-get update && apt-get install -y \
-    build-essential \
-    curl \
-    git \
-    && rm -rf /var/lib/apt/lists/*
+COPY requirements.txt .
 
-COPY requirements.txt ./
-COPY src/ ./src/
+RUN pip install --no-cache-dir -r requirements.txt
 
-RUN pip3 install -r requirements.txt
+COPY . .
 
-EXPOSE 8501
+EXPOSE 7860
 
-HEALTHCHECK CMD curl --fail http://localhost:8501/_stcore/health
-
-ENTRYPOINT ["streamlit", "run", "src/streamlit_app.py", "--server.port=8501", "--server.address=0.0.0.0"]
+CMD ["streamlit", "run", "app.py", "--server.port=7860", "--server.address=0.0.0.0"]

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/app.py

@@ -1,35 +1,70 @@
 import streamlit as st
+import os
+
+from data.hf_store import load_dataset
+from data.updater import update_market_data
+from data.fred import get_sofr_series
+from engine.backtest import run_backtest
+from analytics.metrics import compute_metrics
 
 st.set_page_config(layout="wide")
 
-st.title("P2 ETF Trend Suite - Debug Mode")
-
-try:
-    from data.hf_store import load_dataset
-    st.success("hf_store imported successfully")
-except Exception as e:
-    st.error(f"hf_store failed: {e}")
-
-try:
-    from data.updater import update_market_data
-    st.success("updater imported successfully")
-except Exception as e:
-    st.error(f"updater failed: {e}")
-
-try:
-    from data.fred import get_sofr_series
-    st.success("fred imported successfully")
-except Exception as e:
-    st.error(f"fred failed: {e}")
-
-try:
-    from engine.backtest import run_backtest
-    st.success("backtest imported successfully")
-except Exception as e:
-    st.error(f"backtest failed: {e}")
-
-try:
-    from analytics.metrics import compute_metrics
-    st.success("metrics imported successfully")
-except Exception as e:
-    st.error(f"metrics failed: {e}")
+st.title("📊 P2 ETF Trend Suite")
+st.markdown("Institutional ETF Trend + Volatility Targeting Engine")
+
+# ========================
+# Sidebar Controls
+# ========================
+
+st.sidebar.header("Controls")
+
+initial_capital = st.sidebar.number_input("Initial Capital", value=100000, step=10000)
+vol_target = st.sidebar.slider("Target Annual Volatility", 0.05, 0.30, 0.15)
+lookback = st.sidebar.slider("Momentum Lookback (days)", 50, 300, 200)
+
+refresh = st.sidebar.button("🔄 Refresh Market Data")
+
+# ========================
+# Data Load
+# ========================
+
+with st.spinner("Loading ETF dataset..."):
+    df = load_dataset()
+
+if refresh:
+    with st.spinner("Updating market data from yfinance..."):
+        df = update_market_data(df)
+    st.success("Dataset updated successfully.")
+
+# ========================
+# Backtest
+# ========================
+
+with st.spinner("Pulling SOFR from FRED..."):
+    sofr = get_sofr_series()
+
+with st.spinner("Running backtest..."):
+    results = run_backtest(
+        df=df,
+        initial_capital=initial_capital,
+        vol_target=vol_target,
+        lookback=lookback,
+    )
+
+metrics = compute_metrics(results["returns"], sofr)
+
+# ========================
+# Layout
+# ========================
+
+col1, col2, col3, col4 = st.columns(4)
+
+col1.metric("CAGR", f"{metrics['cagr']:.2%}")
+col2.metric("Sharpe (SOFR)", f"{metrics['sharpe']:.2f}")
+col3.metric("Max Drawdown", f"{metrics['max_dd']:.2%}")
+col4.metric("Volatility", f"{metrics['vol']:.2%}")
+
+st.line_chart(results["equity_curve"])
+
+st.subheader("Current Allocation")
+st.dataframe(results["latest_allocation"])

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/analytics/metrics.py

@@ -0,0 +1,26 @@
+import numpy as np
+import pandas as pd
+
+def compute_metrics(returns, sofr):
+
+    sofr_daily = sofr.reindex(returns.index).fillna(method="ffill")["sofr"] / 252
+    excess = returns - sofr_daily
+
+    sharpe = np.sqrt(252) * excess.mean() / excess.std()
+
+    equity = (1 + returns).cumprod()
+    cagr = equity.iloc[-1] ** (252 / len(equity)) - 1
+
+    vol = returns.std() * np.sqrt(252)
+
+    rolling_max = equity.cummax()
+    drawdown = equity / rolling_max - 1
+    max_dd = drawdown.min()
+
+    return {
+        "sharpe": sharpe,
+        "cagr": cagr,
+        "vol": vol,
+        "max_dd": max_dd
+    }
+

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/app.py

@@ -0,0 +1,35 @@
+import streamlit as st
+
+st.set_page_config(layout="wide")
+
+st.title("P2 ETF Trend Suite - Debug Mode")
+
+try:
+    from data.hf_store import load_dataset
+    st.success("hf_store imported successfully")
+except Exception as e:
+    st.error(f"hf_store failed: {e}")
+
+try:
+    from data.updater import update_market_data
+    st.success("updater imported successfully")
+except Exception as e:
+    st.error(f"updater failed: {e}")
+
+try:
+    from data.fred import get_sofr_series
+    st.success("fred imported successfully")
+except Exception as e:
+    st.error(f"fred failed: {e}")
+
+try:
+    from engine.backtest import run_backtest
+    st.success("backtest imported successfully")
+except Exception as e:
+    st.error(f"backtest failed: {e}")
+
+try:
+    from analytics.metrics import compute_metrics
+    st.success("metrics imported successfully")
+except Exception as e:
+    st.error(f"metrics failed: {e}")

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/data/fred.py

@@ -0,0 +1,11 @@
+import os
+import pandas as pd
+from fredapi import Fred
+
+def get_sofr_series():
+    fred = Fred(api_key=os.getenv("FRED_API_KEY"))
+    sofr = fred.get_series("SOFR")
+    sofr = sofr.to_frame("sofr")
+    sofr.index = pd.to_datetime(sofr.index)
+    sofr["sofr"] = sofr["sofr"] / 100
+    return sofr

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/data/hf_store.py

@@ -0,0 +1,17 @@
+import pandas as pd
+from datasets import load_dataset as hf_load_dataset
+
+DATASET_PATH = "P2SAMAPA/etf_trend_data"
+
+def load_dataset():
+    dataset = hf_load_dataset(DATASET_PATH)
+
+    # Handle split safely
+    if isinstance(dataset, dict) and "train" in dataset:
+        dataset = dataset["train"]
+
+    df = dataset.to_pandas()
+    df["date"] = pd.to_datetime(df["date"])
+    df = df.sort_values(["ticker", "date"])
+
+    return df

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/data/updater.py

@@ -0,0 +1,55 @@
+import os
+import pandas as pd
+import yfinance as yf
+from huggingface_hub import HfApi
+
+DATASET_PATH = "P2SAMAPA/etf_trend_data"
+
+def update_market_data(df):
+
+    tickers = df["ticker"].unique()
+    all_new = []
+
+    for ticker in tickers:
+        last_date = df[df["ticker"] == ticker]["date"].max()
+        start_date = (last_date + pd.Timedelta(days=1)).strftime("%Y-%m-%d")
+
+        new_data = yf.download(ticker, start=start_date, progress=False)
+
+        if new_data.empty:
+            continue
+
+        new_data.reset_index(inplace=True)
+        new_data["ticker"] = ticker
+        new_data.rename(columns={
+            "Date": "date",
+            "Open": "open",
+            "High": "high",
+            "Low": "low",
+            "Close": "close",
+            "Adj Close": "adjusted_close",
+            "Volume": "volume"
+        }, inplace=True)
+
+        all_new.append(new_data)
+
+    if not all_new:
+        return df
+
+    new_df = pd.concat(all_new)
+    df = pd.concat([df, new_df])
+    df.drop_duplicates(subset=["date", "ticker"], inplace=True)
+    df.sort_values(["ticker", "date"], inplace=True)
+
+    df.to_parquet("updated.parquet")
+
+    api = HfApi()
+    api.upload_file(
+        path_or_fileobj="updated.parquet",
+        path_in_repo="data/train-00000-of-00001.parquet",
+        repo_id=DATASET_PATH,
+        repo_type="dataset",
+        token=os.getenv("HF_TOKEN")
+    )
+
+    return df

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/engine/backtest.py

@@ -0,0 +1,46 @@
+import pandas as pd
+import numpy as np
+
+def run_backtest(df, initial_capital, vol_target, lookback):
+
+    df = df.sort_values(["ticker", "date"])
+    prices = df.pivot(index="date", columns="ticker", values="adjusted_close")
+    returns = prices.pct_change().dropna()
+
+    momentum = prices.pct_change(lookback)
+    signal = momentum.rank(axis=1, ascending=False)
+    top = signal <= 3
+
+    weights = top.div(top.sum(axis=1), axis=0)
+
+    rolling_cov = returns.rolling(60).cov()
+    vol = []
+
+    for date in weights.index:
+        if date not in rolling_cov.index:
+            vol.append(0)
+            continue
+
+        w = weights.loc[date].values
+        cov = rolling_cov.loc[date].values.reshape(len(w), len(w))
+        portfolio_vol = np.sqrt(w @ cov @ w) * np.sqrt(252)
+
+        scale = vol_target / portfolio_vol if portfolio_vol > 0 else 0
+        weights.loc[date] = w * scale
+        vol.append(portfolio_vol)
+
+    strategy_returns = (weights.shift(1) * returns).sum(axis=1)
+    equity_curve = (1 + strategy_returns).cumprod() * initial_capital
+
+    latest_weights = weights.iloc[-1]
+    allocation = pd.DataFrame({
+        "Ticker": latest_weights.index,
+        "Weight": latest_weights.values
+    }).sort_values("Weight", ascending=False)
+
+    return {
+        "returns": strategy_returns,
+        "equity_curve": equity_curve,
+        "latest_allocation": allocation
+    }
+

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/.gitattributes

@@ -0,0 +1,35 @@
+*.7z filter=lfs diff=lfs merge=lfs -text
+*.arrow filter=lfs diff=lfs merge=lfs -text
+*.bin filter=lfs diff=lfs merge=lfs -text
+*.bz2 filter=lfs diff=lfs merge=lfs -text
+*.ckpt filter=lfs diff=lfs merge=lfs -text
+*.ftz filter=lfs diff=lfs merge=lfs -text
+*.gz filter=lfs diff=lfs merge=lfs -text
+*.h5 filter=lfs diff=lfs merge=lfs -text
+*.joblib filter=lfs diff=lfs merge=lfs -text
+*.lfs.* filter=lfs diff=lfs merge=lfs -text
+*.mlmodel filter=lfs diff=lfs merge=lfs -text
+*.model filter=lfs diff=lfs merge=lfs -text
+*.msgpack filter=lfs diff=lfs merge=lfs -text
+*.npy filter=lfs diff=lfs merge=lfs -text
+*.npz filter=lfs diff=lfs merge=lfs -text
+*.onnx filter=lfs diff=lfs merge=lfs -text
+*.ot filter=lfs diff=lfs merge=lfs -text
+*.parquet filter=lfs diff=lfs merge=lfs -text
+*.pb filter=lfs diff=lfs merge=lfs -text
+*.pickle filter=lfs diff=lfs merge=lfs -text
+*.pkl filter=lfs diff=lfs merge=lfs -text
+*.pt filter=lfs diff=lfs merge=lfs -text
+*.pth filter=lfs diff=lfs merge=lfs -text
+*.rar filter=lfs diff=lfs merge=lfs -text
+*.safetensors filter=lfs diff=lfs merge=lfs -text
+saved_model/**/* filter=lfs diff=lfs merge=lfs -text
+*.tar.* filter=lfs diff=lfs merge=lfs -text
+*.tar filter=lfs diff=lfs merge=lfs -text
+*.tflite filter=lfs diff=lfs merge=lfs -text
+*.tgz filter=lfs diff=lfs merge=lfs -text
+*.wasm filter=lfs diff=lfs merge=lfs -text
+*.xz filter=lfs diff=lfs merge=lfs -text
+*.zip filter=lfs diff=lfs merge=lfs -text
+*.zst filter=lfs diff=lfs merge=lfs -text
+*tfevents* filter=lfs diff=lfs merge=lfs -text

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/Dockerfile

@@ -0,0 +1,20 @@
+FROM python:3.13.5-slim
+
+WORKDIR /app
+
+RUN apt-get update && apt-get install -y \
+    build-essential \
+    curl \
+    git \
+    && rm -rf /var/lib/apt/lists/*
+
+COPY requirements.txt ./
+COPY src/ ./src/
+
+RUN pip3 install -r requirements.txt
+
+EXPOSE 8501
+
+HEALTHCHECK CMD curl --fail http://localhost:8501/_stcore/health
+
+ENTRYPOINT ["streamlit", "run", "src/streamlit_app.py", "--server.port=8501", "--server.address=0.0.0.0"]

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/README.md

@@ -0,0 +1,19 @@
+---
+title: P2 ETF TREND SUITE
+emoji: 🚀
+colorFrom: red
+colorTo: red
+sdk: docker
+app_port: 8501
+tags:
+- streamlit
+pinned: false
+short_description: Streamlit template space
+---
+
+# Welcome to Streamlit!
+
+Edit `/src/streamlit_app.py` to customize this app to your heart's desire. :heart:
+
+If you have any questions, checkout our [documentation](https://docs.streamlit.io) and [community
+forums](https://discuss.streamlit.io).

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/requirements.txt

@@ -0,0 +1,3 @@
+altair
+pandas
+streamlit

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/src/streamlit_app.py

@@ -0,0 +1,40 @@
+import altair as alt
+import numpy as np
+import pandas as pd
+import streamlit as st
+
+"""
+# Welcome to Streamlit!
+
+Edit `/streamlit_app.py` to customize this app to your heart's desire :heart:.
+If you have any questions, checkout our [documentation](https://docs.streamlit.io) and [community
+forums](https://discuss.streamlit.io).
+
+In the meantime, below is an example of what you can do with just a few lines of code:
+"""
+
+num_points = st.slider("Number of points in spiral", 1, 10000, 1100)
+num_turns = st.slider("Number of turns in spiral", 1, 300, 31)
+
+indices = np.linspace(0, 1, num_points)
+theta = 2 * np.pi * num_turns * indices
+radius = indices
+
+x = radius * np.cos(theta)
+y = radius * np.sin(theta)
+
+df = pd.DataFrame({
+    "x": x,
+    "y": y,
+    "idx": indices,
+    "rand": np.random.randn(num_points),
+})
+
+st.altair_chart(alt.Chart(df, height=700, width=700)
+    .mark_point(filled=True)
+    .encode(
+        x=alt.X("x", axis=None),
+        y=alt.Y("y", axis=None),
+        color=alt.Color("idx", legend=None, scale=alt.Scale()),
+        size=alt.Size("rand", legend=None, scale=alt.Scale(range=[1, 150])),
+    ))

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/requirements.txt

@@ -1,3 +1,8 @@
-altair
+streamlit
 pandas
-streamlit
+numpy
+yfinance
+datasets
+huggingface_hub
+fredapi
+scipy

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/streamlit_app.py

@@ -0,0 +1,70 @@
+import streamlit as st
+import os
+
+from data.hf_store import load_dataset
+from data.updater import update_market_data
+from data.fred import get_sofr_series
+from engine.backtest import run_backtest
+from analytics.metrics import compute_metrics
+
+st.set_page_config(layout="wide")
+
+st.title("📊 P2 ETF Trend Suite")
+st.markdown("Institutional ETF Trend + Volatility Targeting Engine")
+
+# ========================
+# Sidebar Controls
+# ========================
+
+st.sidebar.header("Controls")
+
+initial_capital = st.sidebar.number_input("Initial Capital", value=100000, step=10000)
+vol_target = st.sidebar.slider("Target Annual Volatility", 0.05, 0.30, 0.15)
+lookback = st.sidebar.slider("Momentum Lookback (days)", 50, 300, 200)
+
+refresh = st.sidebar.button("🔄 Refresh Market Data")
+
+# ========================
+# Data Load
+# ========================
+
+with st.spinner("Loading ETF dataset..."):
+    df = load_dataset()
+
+if refresh:
+    with st.spinner("Updating market data from yfinance..."):
+        df = update_market_data(df)
+    st.success("Dataset updated successfully.")
+
+# ========================
+# Backtest
+# ========================
+
+with st.spinner("Pulling SOFR from FRED..."):
+    sofr = get_sofr_series()
+
+with st.spinner("Running backtest..."):
+    results = run_backtest(
+        df=df,
+        initial_capital=initial_capital,
+        vol_target=vol_target,
+        lookback=lookback,
+    )
+
+metrics = compute_metrics(results["returns"], sofr)
+
+# ========================
+# Layout
+# ========================
+
+col1, col2, col3, col4 = st.columns(4)
+
+col1.metric("CAGR", f"{metrics['cagr']:.2%}")
+col2.metric("Sharpe (SOFR)", f"{metrics['sharpe']:.2f}")
+col3.metric("Max Drawdown", f"{metrics['max_dd']:.2%}")
+col4.metric("Volatility", f"{metrics['vol']:.2%}")
+
+st.line_chart(results["equity_curve"])
+
+st.subheader("Current Allocation")
+st.dataframe(results["latest_allocation"])

hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/hf_space/requirements.txt

@@ -1,8 +1,6 @@
 streamlit
 pandas
-numpy
 yfinance
+pandas-datareader
 datasets
 huggingface_hub
-fredapi
-scipy