Upload 33 files

automation.py

@@ -43,8 +43,53 @@ STATE = {
     "log": [],
 }
 _lock = threading.Lock()
+_SCHED = None  # holds the BackgroundScheduler so it isn't garbage-collected
 
 _LAST_RUN_FILE = os.path.join(paths.OUTPUT_DIR, "last_run.txt")
+_RESULTS_FILE = os.path.join(paths.OUTPUT_DIR, "last_results.json")
+
+
+def _df_to_records(df):
+    try:
+        return df.to_dict(orient="records") if df is not None and hasattr(df, "to_dict") else []
+    except Exception:
+        return []
+
+
+def save_results():
+    """Persist the latest pipeline output (signals + rotation + news) to /data so
+    the app shows the last run's results after a restart, with no recompute."""
+    import json
+    try:
+        import rotation
+        d1, d5, d20, asof = STATE.get("rotation", (None, None, None, "—"))
+        payload = {
+            "signals_rows": _df_to_records(STATE.get("signals_df")),
+            "signals_summary": STATE.get("signals_summary", ""),
+            "rotation": {
+                "asof": asof,
+                "d1": _df_to_records(rotation.fmt_table(d1)) if d1 is not None else [],
+                "d5": _df_to_records(rotation.fmt_table(d5)) if d5 is not None else [],
+                "d20": _df_to_records(rotation.fmt_table(d20)) if d20 is not None else [],
+            },
+            "rotation_narrative": STATE.get("rotation_narrative", ""),
+            "news_md": STATE.get("news_md", ""),
+            "saved_at": dt.datetime.now(NY).isoformat(),
+        }
+        with open(_RESULTS_FILE, "w", encoding="utf-8") as f:
+            json.dump(payload, f, ensure_ascii=False)
+    except Exception as e:
+        _log(f"save_results failed: {e}")
+
+
+def load_results() -> dict:
+    """Read the persisted last-run results (for the frontend on page load)."""
+    import json
+    try:
+        with open(_RESULTS_FILE, encoding="utf-8") as f:
+            return json.load(f)
+    except Exception:
+        return {}
 
 
 def _save_last_run(when: dt.datetime):
@@ -134,11 +179,12 @@ def run_pipeline(tickers=None, force: bool = True) -> str:
 
         STATE["last_run"] = dt.datetime.now(NY)
         _save_last_run(STATE["last_run"])
-        _log("Pipeline finished.")
+        save_results()
+        _log("Pipeline finished — Last run updated, results saved.")
         return f"Done. {summary}"
     except Exception as e:
         traceback.print_exc()
-        _log(f"Pipeline error: {e}")
+        _log(f"Pipeline error (Last run not updated): {e}")
         return f"Pipeline error: {e}"
     finally:
         STATE["running"] = False
@@ -164,8 +210,9 @@ def start_scheduler():
 def schedule_info() -> str:
     now = dt.datetime.now(NY)
     last = STATE["last_run"].strftime("%Y-%m-%d %H:%M ET") if STATE["last_run"] else "never"
+    armed = "✅ Scheduler armed" if _SCHED is not None else "⏳ Scheduler starting…"
     return (f"**Schedule:** Mon–Fri **{RUN_HOUR:02d}:{RUN_MINUTE:02d} America/New_York** "
-            f"(market closes 16:00 ET; ).\n\n"
+            f"(after the 16:00 ET close).\n\n"
             f"**Now (ET):** {now.strftime('%Y-%m-%d %H:%M')} · **Last run:** {last}\n\n"
-            f"⚠️ On free Space hardware the app sleeps when idle and the timer can't fire; "
-            f"use **Run now**, or upgrade to always-on hardware for unattended updates.")
+            f"{armed} — it runs automatically every weekday at "
+            f"{RUN_HOUR:02d}:{RUN_MINUTE:02d} ET. You can also trigger it any time with **Run now**.")

server.py

@@ -59,6 +59,11 @@ def _df_records(df):
 
 
 # ───────────────────────── Signals ─────────────────────────
+@app.get("/api/last-results")
+async def last_results():
+    return JSONResponse(automation.load_results())
+
+
 @app.post("/api/signals/run")
 async def signals_run(req: Request):
     body = await req.json()
@@ -340,7 +345,7 @@ async def send_email(req: Request):
 # ───────────────────────── startup ─────────────────────────
 def _boot():
     try:
-        automation.start_scheduler()
+        automation._SCHED = automation.start_scheduler()
     except Exception:
         pass
     if os.environ.get("AUTO_LOAD_MODEL", "1") == "1":

ui_kits/chan-compass/api.js

@@ -39,6 +39,7 @@ window.CCApi = (function () {
   }
 
   return {
+    lastResults: () => jget("/api/last-results"),
     runSignals: (pool, force) => jpost("/api/signals/run", { pool, force }),
     signalSummary: (ticker, onChunk) =>
       stream("/api/signals/summary?ticker=" + encodeURIComponent(ticker), onChunk),

ui_kits/chan-compass/app.jsx

@@ -77,10 +77,34 @@ class Boundary extends React.Component {
 function App() {
   const [tab, setTab] = useS('signals');
   const [mkt, setMkt] = useS({label:"…", variant:"neutral"});
+  const [seeded, setSeeded] = useS(false);
   useE(()=>{
     const tick = ()=> window.CCApi && window.CCApi.marketStatus().then(setMkt).catch(()=>{});
     tick(); const id=setInterval(tick, 60000); return ()=>clearInterval(id);
   },[]);
+  // On first load, seed the views with the LAST pipeline results from /data, so
+  // the app shows what was computed (e.g. by the 18:10 ET schedule) without a
+  // recompute. Only fills store keys that aren't already set this session.
+  useE(()=>{
+    if (!window.CCApi) return;
+    window.CCApi.lastResults().then(r=>{
+      const S = window.CCStore;
+      if (r && r.signals_rows && r.signals_rows.length) {
+        if (!("sig.rows" in S)) S["sig.rows"] = r.signals_rows;
+        if (!("sig.summary" in S)) S["sig.summary"] = r.signals_summary || "";
+        if (!("sig.sel" in S) && r.signals_rows[0]) S["sig.sel"] = r.signals_rows[0].Ticker;
+      }
+      if (r && r.rotation) {
+        if (!("rot.d1" in S)) S["rot.d1"] = r.rotation.d1 || [];
+        if (!("rot.d5" in S)) S["rot.d5"] = r.rotation.d5 || [];
+        if (!("rot.d20" in S)) S["rot.d20"] = r.rotation.d20 || [];
+        if (!("rot.asof" in S)) S["rot.asof"] = r.rotation.asof || "";
+        if (!("rot.ai" in S) && r.rotation_narrative) S["rot.ai"] = r.rotation_narrative;
+      }
+      if (r && r.news_md && !("news.out" in S)) S["news.out"] = r.news_md;
+      setSeeded(true);
+    }).catch(()=>setSeeded(true));
+  },[]);
   const items = [
     { id:'signals',  label:'Signals',         icon:<Glyph name="trending-up" size={16}/> },
     { id:'rotation', label:'Sector Rotation',  icon:<Glyph name="refresh-cw" size={16}/> },
@@ -116,7 +140,8 @@ function App() {
       </div>
 
       <main className="cc-main">
-        <Boundary key={tab}>{View ? <View/> : null}</Boundary>
+        {seeded ? <Boundary key={tab}>{View ? <View/> : null}</Boundary>
+          : <div className="dim" style={{padding:24}}>Loading your latest results…</div>}
       </main>
 
       <footer className="cc-footer">

ui_kits/chan-compass/views.jsx

@@ -149,8 +149,17 @@ function SignalsView() {
         <Kpi label="WAIT" value={counts.WAIT||0}/>
       </div>
       <Card title="Tomorrow's plan" subtitle="Long-hold mode - the unchanged Chan engine runs over each ticker">
-        <div style={{display:"flex", gap:"var(--space-200)", alignItems:"flex-end", marginBottom:"6px"}}>
-          <Field label="Ticker pool" mono value={pool} onChange={e=>setPool(e.target.value)} className="grow"/>
+        <div style={{display:"flex", gap:"var(--space-200)", alignItems:"flex-end", marginBottom:"var(--space-250)"}}>
+          <div className="grow" style={{display:"flex", flexDirection:"column", gap:4}}>
+            <label className="s2-field__label">Ticker pool</label>
+            <span className="dim" style={{fontSize:12}}>Comma separated</span>
+            <input className="s2-field__input" value={pool}
+              onChange={e=>setPool(e.target.value)}
+              style={{fontFamily:"var(--font-mono)", height:"var(--control-height-md, 36px)",
+                padding:"0 12px", border:"1px solid var(--border-field, #b1b1b1)",
+                borderRadius:"var(--field-radius, 8px)", background:"var(--surface-card, #fff)",
+                color:"var(--text-body, #292929)", fontSize:14, width:"100%", boxSizing:"border-box"}}/>
+          </div>
           <Checkbox checked={force} onChange={e=>setForce(e.target.checked)}>Force fresh download</Checkbox>
           <Button variant="accent" onClick={run} disabled={running}>
             {running ? <><Icon name="loader" size={15}/> Running...</> : <><Icon name="play" size={15}/> Run analysis</>}