Upload 32 files

requirements.txt

@@ -1,5 +1,4 @@
-gradio>=6.18.0
-fastapi>=0.115.2,<1.0
+gradio==6.17.3
 pandas>=2.0
 numpy>=1.24
 pyarrow>=14

server.py

@@ -22,7 +22,7 @@ import json
 import os
 
 from fastapi import Request
-from fastapi.responses import StreamingResponse, JSONResponse
+from fastapi.responses import StreamingResponse, JSONResponse, FileResponse
 from fastapi.staticfiles import StaticFiles
 from gradio import Server
 
@@ -188,8 +188,11 @@ async def research_report(name: str):
 # ───────────────────────── Automation ─────────────────────────
 @app.post("/api/automation/run")
 async def automation_run():
-    msg = automation.run_pipeline(force=True)
-    return JSONResponse({"message": msg})
+    import threading
+    if automation.STATE.get("running"):
+        return JSONResponse({"message": "Pipeline already running — watch the log."})
+    threading.Thread(target=lambda: automation.run_pipeline(force=True), daemon=True).start()
+    return JSONResponse({"message": "Pipeline started — the log updates live below."})
 
 
 @app.get("/api/automation/state")
@@ -233,7 +236,28 @@ async def finetune_status():
 @app.post("/api/model/export-dataset")
 async def export_dataset():
     path = finetune_data.export()
-    return JSONResponse({"path": path or "", "count": finetune_data.count()})
+    if not path:
+        return JSONResponse({"path": "", "count": 0, "download": ""})
+    # copy into a served dir so the browser can download it
+    import shutil
+    served_dir = os.path.join(HERE, "exports")
+    os.makedirs(served_dir, exist_ok=True)
+    fname = os.path.basename(path)
+    try:
+        shutil.copy(path, os.path.join(served_dir, fname))
+    except OSError:
+        pass
+    return JSONResponse({"path": path, "count": finetune_data.count(),
+                         "download": "/download/" + fname})
+
+
+@app.get("/download/{fname}")
+async def download_file(fname: str):
+    served = os.path.join(HERE, "exports", os.path.basename(fname))
+    if os.path.exists(served):
+        return FileResponse(served, filename=os.path.basename(fname),
+                            media_type="application/jsonl")
+    return JSONResponse({"error": "not found"}, status_code=404)
 
 
 # ───────────────────────── Email (all tabs) ─────────────────────────
@@ -260,14 +284,11 @@ def _startup():
 
 
 def launch():
-    import uvicorn
-    uvicorn.run(
-        app,
-        host=os.environ.get("GRADIO_SERVER_NAME", "0.0.0.0"),
-        port=int(os.environ.get("GRADIO_SERVER_PORT", os.environ.get("PORT", "7860"))),
+    app.launch(
+        server_name=os.environ.get("GRADIO_SERVER_NAME", "0.0.0.0"),
+        server_port=int(os.environ.get("GRADIO_SERVER_PORT", os.environ.get("PORT", "7860"))),
     )
- 
- 
+
+
 if __name__ == "__main__":
     launch()
- 

ui_kits/chan-compass/app.jsx

@@ -8,15 +8,43 @@ function Glyph({ name, size = 18, color, style }) {
   return <i data-lucide={name} style={{ width:size, height:size, color, display:'inline-flex', ...style }}></i>;
 }
 
+/* Error boundary — a render error in any view shows a message instead of
+   blanking the entire page (the cause of "everything disappears"). */
+class Boundary extends React.Component {
+  constructor(p){ super(p); this.state={err:null}; }
+  static getDerivedStateFromError(err){ return {err}; }
+  componentDidCatch(err, info){ console.error("View error:", err, info); }
+  render(){
+    if (this.state.err) {
+      return (
+        <div style={{padding:24}}>
+          <div style={{background:"#fff", border:"1px solid var(--border-hairline)",
+            borderLeft:"4px solid var(--down)", borderRadius:"var(--radius-lg)", padding:"16px 20px"}}>
+            <div style={{font:"var(--font-weight-bold) 15px var(--font-sans)", color:"var(--down)", marginBottom:6}}>
+              Something went wrong rendering this tab</div>
+            <div className="mono" style={{fontSize:12.5, color:"var(--text-muted)", whiteSpace:"pre-wrap"}}>
+              {String(this.state.err && this.state.err.message || this.state.err)}</div>
+            <button onClick={()=>this.setState({err:null})}
+              style={{marginTop:12, padding:"6px 14px", borderRadius:"var(--radius-full)",
+              border:"1px solid var(--border-hairline)", background:"var(--surface-card)", cursor:"pointer"}}>
+              Try again</button>
+          </div>
+        </div>
+      );
+    }
+    return this.props.children;
+  }
+}
+
 function App() {
   const [tab, setTab] = useS('signals');
   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}/> },
-    { id:'news',     label:'Watchlist News',  icon:<Glyph name="newspaper" size={16}/>, count:2 },
-    { id:'research', label:'Auto Research',    icon:<Glyph name="flask-conical" size={16}/> },
-    { id:'automation', label:'Automation',     icon:<Glyph name="clock" size={16}/> },
-    { id:'model',    label:'Model',            icon:<Glyph name="cpu" size={16}/> },
+    { id:'signals',  label:'Signals',         icon:<Glyph name="trending-up" size={16}/> },
+    { id:'rotation', label:'Sector Rotation',  icon:<Glyph name="refresh-cw" size={16}/> },
+    { id:'news',     label:'Watchlist News',   icon:<Glyph name="newspaper" size={16}/> },
+    { id:'research', label:'Auto Research',     icon:<Glyph name="flask-conical" size={16}/> },
+    { id:'automation', label:'Automation',      icon:<Glyph name="clock" size={16}/> },
+    { id:'model',    label:'Model',             icon:<Glyph name="cpu" size={16}/> },
   ];
   const View = {
     signals: window.SignalsView, rotation: window.RotationView,
@@ -45,7 +73,7 @@ function App() {
       </div>
 
       <main className="cc-main">
-        {View ? <View/> : null}
+        <Boundary key={tab}>{View ? <View/> : null}</Boundary>
       </main>
 
       <footer className="cc-footer">

ui_kits/chan-compass/views.jsx

@@ -79,7 +79,8 @@ function SignalsView() {
     await API.signalSummary(sel, (m) => setAiText(m.text || ""));
     setAiBusy(false);
   };
-  const counts = rows.reduce((a,r)=>{ const k=(r.Tomorrow||"").replace(/[^A-Z]/g,"");
+  const counts = rows.reduce((a,r)=>{ const t=(r.Tomorrow||"").toUpperCase();
+    const k = t.includes("BUY")?"BUY":t.includes("SELL")?"SELL":t.includes("HOLD")?"HOLD":"WAIT";
     a[k]=(a[k]||0)+1; return a; }, {});
 
   return (
@@ -145,16 +146,35 @@ 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 [loading, setLoading] = useState(false);
   const refresh = async () => {
     setLoading(true);
-    try { const r = await API.rotation(); setD1(r.d1||[]); setAsof(r.asof||""); }
+    try { const r = await API.rotation();
+      setD1(r.d1||[]); setD5(r.d5||[]); setD20(r.d20||[]); setAsof(r.asof||""); }
     catch(e){ setAsof("X "+e.message); }
     setLoading(false);
   };
   const narrate = async () => { setBusy(true); setAi(""); await API.rotationNarrative(m=>setAi(m.text||"")); setBusy(false); };
+
+  const Table = (rows) => {
+    if (!rows || !rows.length) return null;
+    return (
+      <div className="cc-table"><table>
+        <thead><tr>{Object.keys(rows[0]).map(k=><th key={k} className={(k!=="Sector"&&k!=="ETF")?"num":""}>{k}</th>)}</tr></thead>
+        <tbody>{rows.map((r,i)=>(
+          <tr key={i}>{Object.entries(r).map(([k,v])=>(
+            <td key={k} className={(k!=="Sector"&&k!=="ETF")?"num mono":""}
+                style={{color: typeof v==="string"&&v.includes("%")?dirColor(parseFloat(v)):undefined}}>{v}</td>
+          ))}</tr>
+        ))}</tbody>
+      </table></div>
+    );
+  };
+
   return (
     <div style={{display:"flex", flexDirection:"column", gap:"var(--space-300)"}}>
       <InlineAlert variant="informative" title="Where capital is flowing">
@@ -170,19 +190,9 @@ function RotationView() {
         </Button>
         {asof && <span style={{marginLeft:"auto"}}><StatusLight variant="neutral">{asof}</StatusLight></span>}
       </div>
-      {d1.length>0 && (
-        <Card title="Sector rotation" subtitle="1-day flow proxy - sorted">
-          <div className="cc-table"><table>
-            <thead><tr>{Object.keys(d1[0]).map(k=><th key={k} className={(k!=="Sector"&&k!=="ETF")?"num":""}>{k}</th>)}</tr></thead>
-            <tbody>{d1.map((r,i)=>(
-              <tr key={i}>{Object.entries(r).map(([k,v])=>(
-                <td key={k} className={(k!=="Sector"&&k!=="ETF")?"num mono":""}
-                    style={{color: typeof v==="string"&&v.includes("%")?dirColor(parseFloat(v)):undefined}}>{v}</td>
-              ))}</tr>
-            ))}</tbody>
-          </table></div>
-        </Card>
-      )}
+      {d1.length>0 && <Card title="Sector rotation · 1-day flow" subtitle="change % × dollar volume · sorted">{Table(d1)}</Card>}
+      {d5.length>0 && <Card title="Sector rotation · 5-day flow" subtitle="medium-term trend">{Table(d5)}</Card>}
+      {d20.length>0 && <Card title="Sector rotation · 20-day flow" subtitle="longer-term trend + RS vs SPY">{Table(d20)}</Card>}
       {ai && <InlineAlert variant="ai" title="Narrator sub-agent - Qwen3-1.7B">{ai}</InlineAlert>}
       <Card title="Email" subtitle="Send the current rotation narrative">
         <EmailRow getContent={()=>ai} tag="Sector rotation"/>
@@ -200,7 +210,7 @@ function NewsView() {
   const save = async () => { await API.saveHoldings(hold); };
   const check = async () => { setBusy(true); setOut(""); await API.checkNews(m=>setOut(m.text||"")); setBusy(false); };
   return (
-    <div style={{display:"flex", flexDirection:"column", gap:"var(--space-300)", maxWidth:820}}>
+    <div style={{display:"flex", flexDirection:"column", gap:"var(--space-300)"}}>
       <Card title="Watchlist news" subtitle="For each holding, only today's news is checked - streamed as it arrives">
         <div style={{display:"flex", gap:"var(--space-150)", alignItems:"flex-end", marginBottom:"var(--space-200)"}}>
           <Field label="My holdings" mono value={hold} onChange={e=>setHold(e.target.value)} className="grow"/>
@@ -318,8 +328,12 @@ function ModelView() {
   },[]);
   useEffect(()=>{ API.finetuneStatus().then(r=>setFt(r.status)).catch(()=>{}); },[]);
   const runTest = async () => { setTest("Testing..."); const r=await API.modelTest(); setTest(r.result); };
-  const exportDs = async () => { const r = await API.exportDataset();
-    setDl(r.path ? "Exported "+r.count+" pairs -> "+r.path : "No pairs captured yet."); };
+  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(""); }
+  };
   return (
     <div style={{display:"flex", flexDirection:"column", gap:"var(--space-300)", maxWidth:760}}>
       <InlineAlert variant="informative" title="Everything runs locally through llama.cpp">
@@ -341,7 +355,8 @@ function ModelView() {
       <Card title="Fine-tuning dataset" subtitle="Every Signals AI summary 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}</div>}
+        {dl && <div className="dim" style={{marginTop:8, fontSize:13}}>{dl}{dlUrl &&
+          <> <a href={dlUrl} download style={{color:"var(--accent)", marginLeft:6}}>Download JSONL</a></>}</div>}
       </Card>
     </div>
   );