Sync from GitHub

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/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/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/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/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/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/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/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/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/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/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/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/.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/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/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/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/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/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/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"])