Upload 33 files

automation.py

@@ -20,11 +20,14 @@ schedule fires unattended.
 """
 from __future__ import annotations
 
+import os
 import datetime as dt
 import threading
 import traceback
 from zoneinfo import ZoneInfo
 
+import paths
+
 NY = ZoneInfo("America/New_York")
 RUN_HOUR, RUN_MINUTE = 18, 10
 
@@ -41,6 +44,27 @@ STATE = {
 }
 _lock = threading.Lock()
 
+_LAST_RUN_FILE = os.path.join(paths.OUTPUT_DIR, "last_run.txt")
+
+
+def _save_last_run(when: dt.datetime):
+    try:
+        with open(_LAST_RUN_FILE, "w", encoding="utf-8") as f:
+            f.write(when.isoformat())
+    except Exception:
+        pass
+
+
+def _load_last_run():
+    try:
+        with open(_LAST_RUN_FILE, encoding="utf-8") as f:
+            STATE["last_run"] = dt.datetime.fromisoformat(f.read().strip())
+    except Exception:
+        STATE["last_run"] = None
+
+
+_load_last_run()
+
 
 def _log(msg: str):
     stamp = dt.datetime.now(NY).strftime("%m-%d %H:%M:%S ET")
@@ -109,6 +133,7 @@ def run_pipeline(tickers=None, force: bool = True) -> str:
             _log(f"Auto-research skipped: {e}")
 
         STATE["last_run"] = dt.datetime.now(NY)
+        _save_last_run(STATE["last_run"])
         _log("Pipeline finished.")
         return f"Done. {summary}"
     except Exception as e:

server.py

@@ -237,6 +237,27 @@ async def market_status():
     return JSONResponse({"open": is_open, "label": label, "variant": variant})
 
 
+@app.get("/api/model/list")
+async def model_list():
+    return JSONResponse({
+        "models": list(llm_local.MODEL_ZOO.keys()),
+        "analyst": llm_local.WORKERS["analyst"]["model"],
+        "analyst_ready": llm_local.WORKERS["analyst"]["llm"] is not None,
+    })
+
+
+@app.post("/api/model/load")
+async def model_load(req: Request):
+    body = await req.json()
+    name = body.get("model", "")
+    if name not in llm_local.MODEL_ZOO:
+        return JSONResponse({"status": "⚠️ Unknown model."})
+    import threading
+    threading.Thread(target=lambda: llm_local.load_model(name, worker="analyst"),
+                     daemon=True).start()
+    return JSONResponse({"status": f"⏳ Loading {name} onto the Analyst sub-agent…"})
+
+
 @app.get("/api/model/status")
 async def model_status():
     return JSONResponse({

ui_kits/chan-compass/api.js

@@ -55,6 +55,8 @@ window.CCApi = (function () {
     autoState: () => jget("/api/automation/state"),
     publishTraces: (repo) => jpost("/api/automation/publish-traces", { repo }),
     marketStatus: () => jget("/api/market/status"),
+    modelList: () => jget("/api/model/list"),
+    modelLoad: (model) => jpost("/api/model/load", { model }),
     modelStatus: () => jget("/api/model/status"),
     modelTest: () => jpost("/api/model/test", {}),
     modelTestStatus: () => jget("/api/model/test-status"),

ui_kits/chan-compass/app.jsx

@@ -9,7 +9,8 @@ function _pascalG(name) {
 function _glyphChildren(node) {
   if (!node) return [];
   if (Array.isArray(node)) {
-    if (node.length === 3 && Array.isArray(node[2])) return node[2];
+    if (typeof node[0] === "string" && node[0].toLowerCase() === "svg" && Array.isArray(node[2]))
+      return node[2];
     return node;
   }
   return node.tags || node.children || [];
@@ -29,6 +30,16 @@ function _glyphSvg(name, size, color) {
     + `stroke-width="2" stroke-linecap="round" stroke-linejoin="round">${inner}</svg>`;
 }
 function Glyph({ name, size = 18, color, style }) {
+  const [, force] = useS(0);
+  useE(() => {
+    if (window.lucide && window.lucide.icons) return;
+    let n = 0;
+    const id = setInterval(() => {
+      n++;
+      if ((window.lucide && window.lucide.icons) || n > 40) { clearInterval(id); force(x=>x+1); }
+    }, 100);
+    return () => clearInterval(id);
+  }, []);
   const html = _glyphSvg(name, size, color);
   return <span style={{ width:size, height:size, display:'inline-flex',
     alignItems:'center', justifyContent:'center', ...style }}
@@ -109,11 +120,14 @@ function App() {
       </main>
 
       <footer className="cc-footer">
-        <span>Chan Compass · built for my family, not investment advice</span>
+        <span>Chan Compass</span>
+        <span className="cc-foot-sep">·</span>
+        <span>by <a href="https://huggingface.co/ranranrunforit" target="_blank" rel="noreferrer"
+          style={{color:"var(--accent)", textDecoration:"none"}}>@ranranrunforit</a>, made with care for my family</span>
         <span className="cc-foot-sep">·</span>
         <span>data: Yahoo Finance</span>
         <span className="cc-foot-sep">·</span>
-        <span>design language: Adobe Spectrum 2</span>
+        <span>design: Adobe Spectrum 2</span>
       </footer>
     </div>
   );

ui_kits/chan-compass/views.jsx

@@ -5,6 +5,22 @@ const { Button, Field, Checkbox, Switch, Card, InlineAlert, Badge, StatusLight,
 const { useState, useEffect, useRef } = React;
 const API = window.CCApi;
 
+/* Persistent store — survives tab unmount/remount so data isn't lost when the
+   user switches tabs and comes back. Backed by a module-level object. */
+window.CCStore = window.CCStore || {};
+function usePersistent(key, initial) {
+  const [v, setV] = useState(() => (key in window.CCStore ? window.CCStore[key] : initial));
+  const set = (nv) => {
+    setV(prev => {
+      const next = typeof nv === "function" ? nv(prev) : nv;
+      window.CCStore[key] = next;
+      return next;
+    });
+  };
+  return [v, set];
+}
+
+
 // kebab-case (data-lucide name) → PascalCase (lucide.icons key)
 function _pascal(name) {
   return String(name).split(/[-_]/).map(s=>s.charAt(0).toUpperCase()+s.slice(1)).join("");
@@ -12,8 +28,10 @@ function _pascal(name) {
 function _lucideChildren(node) {
   if (!node) return [];
   if (Array.isArray(node)) {
-    // could be [ [tag,attrs], ... ]  OR  ["svg", attrs, [ [tag,attrs],... ]]
-    if (node.length === 3 && Array.isArray(node[2])) return node[2];
+    // wrapped form: ["svg", attrs, [children]]  →  children at [2]
+    if (typeof node[0] === "string" && node[0].toLowerCase() === "svg" && Array.isArray(node[2]))
+      return node[2];
+    // bare iconNode: [ [tag, attrs], [tag, attrs], ... ]
     return node;
   }
   return node.tags || node.children || [];
@@ -33,6 +51,16 @@ function _lucideSvg(name, size, color) {
     + `stroke-width="2" stroke-linecap="round" stroke-linejoin="round">${inner}</svg>`;
 }
 function Icon({ name, size = 18, color, style }) {
+  const [, force] = useState(0);
+  useEffect(() => {
+    if (window.lucide && window.lucide.icons) return;
+    let n = 0;
+    const id = setInterval(() => {
+      n++;
+      if ((window.lucide && window.lucide.icons) || n > 40) { clearInterval(id); force(x=>x+1); }
+    }, 100);
+    return () => clearInterval(id);
+  }, []);
   const html = _lucideSvg(name, size, color);
   return <span style={{ width:size, height:size, display:"inline-flex",
     alignItems:"center", justifyContent:"center", ...style }}
@@ -84,13 +112,13 @@ function Markdown({ text }) {
 
 /* ─────────── Signals ─────────── */
 function SignalsView() {
-  const [pool, setPool] = useState("AAPL, MSFT, NVDA, TSLA, AMZN, GOOGL, META, AMD");
+  const [pool, setPool] = usePersistent("sig.pool", "AAPL, MSFT, NVDA, TSLA, AMZN, GOOGL, META, AMD");
   const [force, setForce] = useState(false);
   const [running, setRunning] = useState(false);
-  const [rows, setRows] = useState([]);
-  const [summary, setSummary] = useState("");
-  const [sel, setSel] = useState(null);
-  const [aiText, setAiText] = useState("");
+  const [rows, setRows] = usePersistent("sig.rows", []);
+  const [summary, setSummary] = usePersistent("sig.summary", "");
+  const [sel, setSel] = usePersistent("sig.sel", null);
+  const [aiText, setAiText] = usePersistent("sig.ai", "");
   const [aiBusy, setAiBusy] = useState(false);
 
   const run = async () => {
@@ -175,11 +203,11 @@ function SignalsView() {
 
 /* ─────────── Rotation ─────────── */
 function RotationView() {
-  const [d1, setD1] = useState([]);
-  const [d5, setD5] = useState([]);
-  const [d20, setD20] = useState([]);
-  const [asof, setAsof] = useState("");
-  const [ai, setAi] = useState(""); const [busy, setBusy] = useState(false);
+  const [d1, setD1] = usePersistent("rot.d1", []);
+  const [d5, setD5] = usePersistent("rot.d5", []);
+  const [d20, setD20] = usePersistent("rot.d20", []);
+  const [asof, setAsof] = usePersistent("rot.asof", "");
+  const [ai, setAi] = usePersistent("rot.ai", ""); const [busy, setBusy] = useState(false);
   const [loading, setLoading] = useState(false);
   const refresh = async () => {
     setLoading(true);
@@ -232,11 +260,11 @@ function RotationView() {
 
 /* ─────────── News ─────────── */
 function NewsView() {
-  const [hold, setHold] = useState("");
-  const [out, setOut] = useState("");
+  const [hold, setHold] = usePersistent("news.hold", "");
+  const [out, setOut] = usePersistent("news.out", "");
   const [busy, setBusy] = useState(false);
   const [saved, setSaved] = useState("");
-  useEffect(()=>{ API.holdings().then(r=>setHold((r.holdings||[]).join(", "))).catch(()=>{}); },[]);
+  useEffect(()=>{ if(!("news.hold" in window.CCStore)) API.holdings().then(r=>setHold((r.holdings||[]).join(", "))).catch(()=>{}); },[]);
   const save = async () => {
     setSaved("Saving…");
     try { const r = await API.saveHoldings(hold);
@@ -267,12 +295,12 @@ function NewsView() {
 
 /* ─────────── Research ─────────── */
 function ResearchView() {
-  const [tic, setTic] = useState("");
-  const [progress, setProgress] = useState("");
-  const [report, setReport] = useState("");
-  const [reports, setReports] = useState([]);
+  const [tic, setTic] = usePersistent("res.tic", "");
+  const [progress, setProgress] = usePersistent("res.progress", "");
+  const [report, setReport] = usePersistent("res.report", "");
+  const [reports, setReports] = usePersistent("res.reports", []);
   const [busy, setBusy] = useState(false);
-  const [sel, setSel] = useState(null);
+  const [sel, setSel] = usePersistent("res.sel", null);
   useEffect(()=>{ API.reports().then(r=>setReports(r.reports||[])).catch(()=>{}); },[]);
   const run = async () => {
     if (!tic) return;
@@ -362,10 +390,16 @@ function ModelView() {
   const [workers, setWorkers] = useState({});
   const [test, setTest] = useState("");
   const [ft, setFt] = useState(""); const [dl, setDl] = useState("");
+  const [models, setModels] = useState([]);
+  const [analyst, setAnalyst] = useState("");
+  const [pick, setPick] = useState("");
+  const [loadMsg, setLoadMsg] = useState("");
   useEffect(()=>{
     const tick = ()=> API.modelStatus().then(r=>{setStatus(r.status); setWorkers(r.workers||{});}).catch(()=>{});
     tick(); const id=setInterval(tick, 3000); return ()=>clearInterval(id);
   },[]);
+  useEffect(()=>{ API.modelList().then(r=>{ setModels(r.models||[]); setAnalyst(r.analyst||"");
+    setPick(p=>p||r.analyst||""); }).catch(()=>{}); },[]);
   useEffect(()=>{ API.finetuneStatus().then(r=>setFt(r.status)).catch(()=>{}); },[]);
   const runTest = async () => {
     setTest("⏳ Testing sub-agents… (this can take a moment on CPU)");
@@ -377,11 +411,17 @@ function ModelView() {
       } catch (_) { clearInterval(poll); }
     }, 1500);
   };
+  const loadModel = async () => {
+    if (!pick) return;
+    setLoadMsg("⏳ Loading…");
+    try { const r = await API.modelLoad(pick); setLoadMsg(r.status); }
+    catch(e){ setLoadMsg("❌ " + e.message); }
+  };
   const [dlUrl, setDlUrl] = useState("");
   const exportDs = async () => {
     const r = await API.exportDataset();
     if (r.download) { setDl("Exported " + r.count + " pairs."); setDlUrl(r.download); }
-    else { setDl("No pairs captured yet — run a few Signals AI summaries first."); setDlUrl(""); }
+    else { setDl("No pairs captured yet — run a few Signals AI interprets first."); setDlUrl(""); }
   };
   return (
     <div style={{display:"flex", flexDirection:"column", gap:"var(--space-300)"}}>
@@ -401,7 +441,25 @@ function ModelView() {
         </div>
         {test && <div className="cc-llm-out" style={{marginTop:12}}><Markdown text={test}/></div>}
       </Card>
-      <Card title="Fine-tuning dataset" subtitle="Every Signals AI summary is captured as a training pair on /data">
+      <Card title="Analyst model" subtitle="Pick the model for the Auto Research analyst (all ≤32B). The 1.7B sub-agents are fixed.">
+        <div className="cc-radios">
+          {models.map(m=>(
+            <label key={m} className={"cc-radio" + (pick===m?" sel":"")} onClick={()=>setPick(m)}
+              style={{cursor:"pointer"}}>
+              <span className="cc-radio-dot"></span>
+              <span className="mono">{m}</span>
+              {analyst===m && <Badge variant="positive">current</Badge>}
+            </label>
+          ))}
+        </div>
+        <div style={{display:"flex", gap:"var(--space-150)", marginTop:"var(--space-200)", alignItems:"center"}}>
+          <Button variant="accent" onClick={loadModel} disabled={!pick || pick===analyst}>
+            <Icon name="download" size={15}/> Load model
+          </Button>
+          {loadMsg && <span className="dim" style={{fontSize:13}}>{loadMsg}</span>}
+        </div>
+      </Card>
+      <Card title="Fine-tuning dataset" subtitle="Every Signals AI interpret is captured as a training pair on /data">
         <div className="dim" style={{marginBottom:10}}><Markdown text={ft}/></div>
         <Button variant="accent" onClick={exportDs}><Icon name="download" size={15}/> Export dataset (JSONL)</Button>
         {dl && <div className="dim" style={{marginTop:8, fontSize:13}}>{dl}{dlUrl &&