AI Analyst: add Generate Now button for on-demand insights

- Button in AI Analyst panel header calls POST /session/ai_insight
- Dashboard publishes {"action": "generate_insight"} to control topic
- ai_analyst listens and runs LLM call in a background thread
- Button shows "Generating…" / disabled while waiting, re-enables on result
- Fix: control topic key was "command", now correctly uses "action"

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

ai_analyst/ai_analyst.py

@@ -138,9 +138,21 @@ In 3–4 sentences analyse: activity level, notable price moves or volume spikes
 Be specific and data-driven. No headers, no bullet points, plain prose only."""
 
 
+def run_immediate_analysis(producer):
+    """Called on-demand (button click). Skips the interval check."""
+    print("[AI-Analyst] On-demand analysis triggered")
+    prompt = build_prompt()
+    text   = call_llm(prompt)
+    if text:
+        insight = {"text": text, "timestamp": time.time()}
+        producer.send(Config.AI_INSIGHTS_TOPIC, insight)
+        producer.flush()
+        print(f"[AI-Analyst] On-demand insight published ({len(text)} chars)")
+
+
 # ── Kafka consumer (market data) ──────────────────────────────────────────────
 
-def consume_market_data():
+def consume_market_data(producer):
     global _running, _suspended
     consumer = create_consumer(
         topics=[
@@ -162,16 +174,18 @@ def consume_market_data():
                 if sym:
                     latest_snapshots[sym] = snap
             elif msg.topic == Config.CONTROL_TOPIC:
-                cmd = msg.value.get("command", "")
-                if cmd == "start":
+                action = msg.value.get("action", "")
+                if action == "start":
                     _running   = True
                     _suspended = False
-                elif cmd in ("end", "stop"):
+                elif action in ("end", "stop"):
                     _running   = False
-                elif cmd == "suspend":
+                elif action == "suspend":
                     _suspended = True
-                elif cmd == "resume":
+                elif action == "resume":
                     _suspended = False
+                elif action == "generate_insight":
+                    threading.Thread(target=run_immediate_analysis, args=(producer,), daemon=True).start()
 
 
 # ── Analysis loop ──────────────────────────────────────────────────────────────
@@ -208,5 +222,5 @@ def analysis_loop(producer):
 
 if __name__ == "__main__":
     producer = create_producer(component_name="AI-Analyst")
-    threading.Thread(target=consume_market_data, daemon=True).start()
+    threading.Thread(target=consume_market_data, args=(producer,), daemon=True).start()
     analysis_loop(producer)

dashboard/dashboard.py

@@ -447,6 +447,17 @@ def session_resume():
         return jsonify({"status": "error", "error": str(e)}), 500
 
 
+@app.route("/session/ai_insight", methods=["POST"])
+def trigger_ai_insight():
+    try:
+        p = get_producer()
+        p.send(Config.CONTROL_TOPIC, {"action": "generate_insight"})
+        p.flush()
+        return jsonify({"status": "ok", "message": "Insight generation triggered"})
+    except Exception as e:
+        return jsonify({"status": "error", "error": str(e)}), 500
+
+
 @app.route("/session/mode", methods=["POST"])
 def session_mode():
     try:

dashboard/templates/index.html

@@ -380,8 +380,12 @@
   <div class="ai-panel">
     <h2 style="margin:0 0 8px; font-size:15px; display:flex; align-items:center; gap:10px;">
       AI Analyst
-      <span id="ai-model-badge" style="font-size:10px; color:#fff; background:#5c6bc0; padding:2px 8px; border-radius:10px; font-weight:normal;"></span>
-      <span id="ai-status" style="font-size:11px; color:#999; font-weight:normal; margin-left:4px;">waiting for first insight…</span>
+      <button id="ai-generate-btn" onclick="triggerAIInsight()"
+              style="padding:3px 12px; background:#5c6bc0; color:#fff; border:none; border-radius:12px;
+                     font-size:11px; font-weight:bold; cursor:pointer;">
+        Generate Now
+      </button>
+      <span id="ai-status" style="font-size:11px; color:#999; font-weight:normal;">waiting for first insight…</span>
     </h2>
     <div id="ai-insights-list" style="max-height:220px; overflow-y:auto;">
       <div class="insight-card" style="color:#bbb; border-left-color:#ddd; background:#fafafa;" id="ai-placeholder">
@@ -428,6 +432,21 @@
     // Selected order state
     let selectedOrder = null;
 
+    async function triggerAIInsight() {
+      const btn = document.getElementById("ai-generate-btn");
+      btn.disabled = true;
+      btn.textContent = "Generating…";
+      document.getElementById("ai-status").textContent = "generating insight…";
+      try {
+        await fetch("/session/ai_insight", { method: "POST" });
+      } catch(e) {}
+      // Re-enable after 10s (LLM needs time)
+      setTimeout(() => {
+        btn.disabled = false;
+        btn.textContent = "Generate Now";
+      }, 10000);
+    }
+
     function addInsight(insight) {
       const list = document.getElementById("ai-insights-list");
       const ph   = document.getElementById("ai-placeholder");
@@ -1096,6 +1115,9 @@
         addInsight(insight);
         document.getElementById("ai-status").textContent =
           "Last update: " + new Date().toLocaleTimeString();
+        const btn = document.getElementById("ai-generate-btn");
+        btn.disabled = false;
+        btn.textContent = "Generate Now";
       });
 
       eventSource.onerror = () => {