Add cesium2 terminal CLI (live web data) to tools/

tools/cesium2.cmd

@@ -0,0 +1,2 @@
+@echo off
+python "%~dp0cesium2.py" %*

tools/cesium2.py

@@ -0,0 +1,169 @@
+#!/usr/bin/env python3
+"""cesium2 - terminal chat with MORPH-AI v6 (Cesium2) via Ollama, with live web data.
+
+Usage:
+  cesium2 "what is todays popular news"   one-shot answer
+  cesium2                                  interactive chat (/exit to quit, /new resets)
+"""
+import json
+import os
+import re
+import sys
+import urllib.parse
+import urllib.request
+from datetime import datetime
+
+try:
+    sys.stdout.reconfigure(encoding="utf-8", errors="replace")
+    sys.stderr.reconfigure(encoding="utf-8", errors="replace")
+except Exception:
+    pass
+
+HOST = os.environ.get("OLLAMA_HOST", "http://localhost:11434").rstrip("/")
+MODEL = os.environ.get("CESIUM2_MODEL", "ram1234598766/Cesium2")
+
+SYSTEM = (
+    "You are MORPH-AI v6 (Cesium2), a helpful assistant with advanced reasoning. "
+    "Your training data has a cutoff; rely ONLY on the [LIVE CONTEXT] block for "
+    "time-sensitive facts - it contains the real current date and fresh web results. "
+    "Think step by step and be concise."
+)
+
+LIVE_RE = re.compile(
+    r"\b(news|today|todays|current|currently|latest|recent|now|breaking|price|prices|"
+    r"weather|forecast|score|scores|who won|stock|stocks|market|election|update|"
+    r"2024|2025|2026|this week|this month|yesterday)\b",
+    re.I,
+)
+
+
+def google_news(query, limit=5):
+    def fetch(qs):
+        url = f"https://news.google.com/rss/search?q={urllib.parse.quote(qs)}&hl=en-US&gl=US&ceid=US:en"
+        req = urllib.request.Request(url, headers={"User-Agent": "Mozilla/5.0"})
+        xml = urllib.request.urlopen(req, timeout=20).read().decode("utf-8", "ignore")
+        titles = re.findall(r"<item><title>(.*?)</title>", xml)
+        dates = re.findall(r"<pubDate>(.*?)</pubDate>", xml)
+        return list(zip(titles, dates))
+
+    cleaned = re.sub(r"\b(what|is|are|the|of|and|today'?s?|date|for|me|tell|about)\b", " ",
+                     query, flags=re.I)
+    candidates = [
+        " ".join(cleaned.split())[:80],
+        "top news today",
+        "breaking news",
+    ]
+    best = []
+    for qs in candidates:
+        if not qs.strip():
+            continue
+        try:
+            got = fetch(qs)
+        except Exception:
+            continue
+        if len(got) > len(best):
+            best = got
+        if len(best) >= limit:
+            break
+    return "\n".join(
+        f"{i+1}. {t} [{d}]" for i, (t, d) in enumerate(best[:limit])
+    )
+
+
+def build_live(prompt):
+    block = f"[LIVE CONTEXT - current date & time: {datetime.now()}]\n\n"
+    try:
+        news = google_news(prompt)
+        block += ("Fresh web results (Google News):\n" + news) if news else "No fresh results found."
+    except Exception as e:
+        block += f"(web search unavailable: {e})"
+    block += "\n\nUse this LIVE CONTEXT as ground truth for time-sensitive facts."
+    return block
+
+
+def stream_chat(messages):
+    body = json.dumps({
+        "model": MODEL,
+        "messages": messages,
+        "stream": True,
+        "options": {"temperature": 0.7, "num_ctx": 8192},
+    }).encode()
+    req = urllib.request.Request(
+        HOST + "/api/chat", data=body, headers={"Content-Type": "application/json"}
+    )
+    resp = urllib.request.urlopen(req, timeout=600)
+    full = []
+    dec = json.JSONDecoder()
+    buf = ""
+    while True:
+        chunk = resp.read(1)
+        if not chunk:
+            break
+        buf += chunk.decode("utf-8", "ignore")
+        while "\n" in buf:
+            line, buf = buf.split("\n", 1)
+            line = line.strip()
+            if not line:
+                continue
+            try:
+                obj = dec.raw_decode(line)[0]
+            except Exception:
+                continue
+            tok = obj.get("message", {}).get("content", "")
+            if tok:
+                full.append(tok)
+                print(tok, end="", flush=True)
+            if obj.get("done"):
+                print()
+                return "".join(full)
+    print()
+    return "".join(full)
+
+
+def answer(prompt, history):
+    msgs = [{"role": "system", "content": SYSTEM}]
+    if LIVE_RE.search(prompt):
+        print("[searching the web...]", file=sys.stderr, flush=True)
+        msgs.append({"role": "system", "content": build_live(prompt)})
+    msgs += history + [{"role": "user", "content": prompt}]
+    reply = stream_chat(msgs)
+    history.extend([
+        {"role": "user", "content": prompt},
+        {"role": "assistant", "content": reply},
+    ])
+    if len(history) > 24:
+        del history[:-24]
+
+
+def main():
+    args = sys.argv[1:]
+    if args:
+        answer(" ".join(args), [])
+        return
+    print(f"MORPH-AI Cesium2 terminal · model={MODEL} · /new reset · /exit quit")
+    history = []
+    while True:
+        try:
+            prompt = input("\nyou > ").strip()
+        except (EOFError, KeyboardInterrupt):
+            print()
+            break
+        if not prompt:
+            continue
+        if prompt.lower() in ("/exit", "/quit"):
+            break
+        if prompt.lower() == "/new":
+            history.clear()
+            print("[conversation cleared]")
+            continue
+        try:
+            answer(prompt, history)
+        except Exception as e:
+            msg = str(e)
+            if "ConnectionRefused" in msg or "URLError" in msg:
+                msg = f"cannot reach Ollama at {HOST} - start it first ('ollama serve')"
+            print(f"\n[error] {msg}", file=sys.stderr)
+
+
+if __name__ == "__main__":
+    main()