Upload 18 files

app.py

@@ -17,6 +17,7 @@ import gradio as gr
 import pandas as pd
 
 import automation
+import emailer
 import finetune_data
 import llm_local
 import news_watch
@@ -211,6 +212,11 @@ with gr.Blocks(title="Chan Compass · US", **_style_kw) as demo:
             explain_btn = gr.Button("🤖 AI summary (local LLM)", scale=1)
         detail_box = gr.Markdown(label="Raw read")
         explain_box = gr.Markdown(elem_classes=["ai-panel"])
+        with gr.Row():
+            sig_email = gr.Textbox(label="Email this summary to", scale=4,
+                                   placeholder="name@example.com (comma-separate for several)")
+            sig_email_btn = gr.Button("✉ Send Email", scale=1)
+        sig_email_status = gr.Markdown()
 
     with gr.Tab("🔄 Sector Rotation"):
         gr.Markdown("Capital rotation across the 11 SPDR sector ETFs (full S&P 500 coverage). "
@@ -226,6 +232,11 @@ with gr.Blocks(title="Chan Compass · US", **_style_kw) as demo:
             rot_5d = gr.Dataframe(label="5-Day (week trend)", interactive=False)
             rot_20d = gr.Dataframe(label="20-Day (month trend)", interactive=False)
         rot_ai = gr.Markdown(label="AI rotation narrative", elem_classes=["ai-panel"])
+        with gr.Row():
+            rot_email = gr.Textbox(label="Email this narrative to", scale=4,
+                                   placeholder="name@example.com (comma-separate for several)")
+            rot_email_btn = gr.Button("✉ Send Email", scale=1)
+        rot_email_status = gr.Markdown()
 
     with gr.Tab("📰 Watchlist News"):
         gr.Markdown("Daily rule: for each **holding**, only **today's** news is checked. "
@@ -238,6 +249,11 @@ with gr.Blocks(title="Chan Compass · US", **_style_kw) as demo:
             news_btn = gr.Button("🔍 Check today's news", variant="primary", scale=1)
         hold_status = gr.Markdown()
         news_out = gr.Markdown(elem_classes=["ai-panel"])
+        with gr.Row():
+            news_email = gr.Textbox(label="Email this news brief to", scale=4,
+                                    placeholder="name@example.com (comma-separate for several)")
+            news_email_btn = gr.Button("✉ Send Email", scale=1)
+        news_email_status = gr.Markdown()
 
     with gr.Tab("🧪 Auto Research"):
         gr.Markdown("**Multi-step research agent** (fully local): PLAN → 5 evidence tools "
@@ -251,6 +267,11 @@ with gr.Blocks(title="Chan Compass · US", **_style_kw) as demo:
             res_btn = gr.Button("🤖 Run research agent", variant="primary", scale=1)
         res_progress = gr.Markdown()
         res_out = gr.Markdown(elem_classes=["ai-panel"])
+        with gr.Row():
+            res_email = gr.Textbox(label="Email this report to", scale=4,
+                                   placeholder="name@example.com (comma-separate for several)")
+            res_email_btn = gr.Button("✉ Send Email", scale=1)
+        res_email_status = gr.Markdown()
         gr.Markdown("**Report library** (auto + manual, stored on `/data`):",
                     elem_classes=["s2-footnote"])
         with gr.Row():
@@ -322,6 +343,14 @@ with gr.Blocks(title="Chan Compass · US", **_style_kw) as demo:
     save_btn.click(ui_save_holdings, hold_in, hold_status)
     news_btn.click(ui_check_news, None, news_out)
     res_btn.click(ui_research, res_in, [res_progress, res_out, rep_pick])
+    sig_email_btn.click(lambda body, to: emailer.send_result(body, to, "Signals summary"),
+                        [explain_box, sig_email], sig_email_status)
+    rot_email_btn.click(lambda body, to: emailer.send_result(body, to, "Sector rotation"),
+                        [rot_ai, rot_email], rot_email_status)
+    news_email_btn.click(lambda body, to: emailer.send_result(body, to, "Watchlist news"),
+                         [news_out, news_email], news_email_status)
+    res_email_btn.click(lambda body, to: emailer.send_result(body, to, "Research report"),
+                        [res_out, res_email], res_email_status)
     rep_open.click(ui_open_report, rep_pick, rep_view)
     auto_now.click(lambda: automation.run_pipeline(force=True), None, auto_msg)
     load_btn.click(ui_load_model, model_pick, model_status)

emailer.py

@@ -0,0 +1,128 @@
+"""
+emailer.py — send a tab's AI result to any address (English UI + content).
+
+Adapted from the user's send_predict_email.py: same multi-domain SMTP
+auto-detection, plain+HTML multipart, but English subjects/labels and a generic
+`send_result()` the Gradio tabs call.
+
+Sender credentials live here (a Gmail App Password). To change the sender, edit
+EMAIL_SENDER / EMAIL_PASSWORD. You can also override them with the environment
+variables CHAN_EMAIL_SENDER / CHAN_EMAIL_PASSWORD on the Space (recommended:
+store the App Password as a Space *secret* rather than in code).
+"""
+from __future__ import annotations
+
+import os
+import html
+import logging
+import smtplib
+import re
+from datetime import datetime
+from email.mime.text import MIMEText
+from email.mime.multipart import MIMEMultipart
+from email.header import Header
+from email.utils import formataddr
+
+logger = logging.getLogger("chan_emailer")
+
+# ── sender account (override via Space secrets if you prefer) ──
+EMAIL_SENDER = os.environ.get("CHAN_EMAIL_SENDER", "cz78illinoisedu@gmail.com")
+EMAIL_PASSWORD = os.environ.get("CHAN_EMAIL_PASSWORD", "tknl qpmb gzye zlva")
+
+SMTP_CONFIGS = {
+    "gmail.com":   {"server": "smtp.gmail.com",     "port": 465, "ssl": True},
+    "qq.com":      {"server": "smtp.qq.com",        "port": 465, "ssl": True},
+    "163.com":     {"server": "smtp.163.com",       "port": 465, "ssl": True},
+    "126.com":     {"server": "smtp.126.com",       "port": 465, "ssl": True},
+    "outlook.com": {"server": "smtp.office365.com", "port": 587, "ssl": False},
+    "hotmail.com": {"server": "smtp.office365.com", "port": 587, "ssl": False},
+    "foxmail.com": {"server": "smtp.qq.com",        "port": 465, "ssl": True},
+    "sina.com":    {"server": "smtp.sina.com",      "port": 465, "ssl": True},
+    "aliyun.com":  {"server": "smtp.aliyun.com",    "port": 465, "ssl": True},
+}
+
+_EMAIL_RE = re.compile(r"^[^@\s]+@[^@\s]+\.[^@\s]+$")
+
+
+def _sender_address(sender: str) -> str:
+    return formataddr((str(Header("Chan Compass", "utf-8")), sender))
+
+
+def _md_to_html(text: str) -> str:
+    """Wrap the result (markdown-ish text) in a clean monospace HTML block."""
+    safe = html.escape(text)
+    return (
+        '<html><body style="margin:0;padding:16px;background:#f6f7f9;">'
+        '<div style="font-family:Menlo,Consolas,monospace;font-size:13px;'
+        'line-height:1.55;white-space:pre-wrap;word-wrap:break-word;color:#1a1a1a;'
+        'background:#ffffff;padding:18px 22px;border-radius:10px;'
+        'border:1px solid #e3e6ea;max-width:760px;">'
+        f'{safe}'
+        '</div>'
+        '<p style="font-family:sans-serif;font-size:11px;color:#8a8a8a;'
+        'margin:10px 0 0;">Sent by Chan Compass · educational tool, not '
+        'investment advice.</p>'
+        '</body></html>'
+    )
+
+
+def _parse_recipients(raw: str) -> list:
+    parts = re.split(r"[,;\s]+", (raw or "").strip())
+    return [p for p in parts if _EMAIL_RE.match(p)]
+
+
+def _close(server):
+    if server is not None:
+        try:
+            server.quit()
+        except Exception:
+            try:
+                server.close()
+            except Exception:
+                pass
+
+
+def send_result(content: str, recipients_raw: str, subject_tag: str) -> str:
+    """Send `content` to the address(es) in `recipients_raw`. Returns a status
+    string for the UI. Plain English throughout."""
+    if not content or not content.strip():
+        return "⚠️ Nothing to send yet — generate a result first."
+    if content.strip().startswith(("⏳", "🤖 _", "Run ", "Enter ", "Select ")):
+        return "⚠️ Wait for the AI result to finish, then send."
+    recipients = _parse_recipients(recipients_raw)
+    if not recipients:
+        return "⚠️ Enter a valid email address (e.g. name@example.com)."
+    if not EMAIL_SENDER or not EMAIL_PASSWORD:
+        return "⚠️ Sender email is not configured on the server."
+
+    subject = (f"Chan Compass · {subject_tag} · "
+               f"{datetime.now().strftime('%Y-%m-%d %H:%M')}")
+    msg = MIMEMultipart("alternative")
+    msg["Subject"] = Header(subject, "utf-8")
+    msg["From"] = _sender_address(EMAIL_SENDER)
+    msg["To"] = ", ".join(recipients)
+    msg.attach(MIMEText(content, "plain", "utf-8"))
+    msg.attach(MIMEText(_md_to_html(content), "html", "utf-8"))
+
+    domain = EMAIL_SENDER.split("@")[-1].lower()
+    sc = SMTP_CONFIGS.get(domain, {"server": f"smtp.{domain}", "port": 465, "ssl": True})
+    server = None
+    try:
+        if sc["ssl"]:
+            server = smtplib.SMTP_SSL(sc["server"], sc["port"], timeout=30)
+        else:
+            server = smtplib.SMTP(sc["server"], sc["port"], timeout=30)
+            server.starttls()
+        server.login(EMAIL_SENDER, EMAIL_PASSWORD)
+        server.send_message(msg)
+        logger.info("email sent to %s", recipients)
+        return f"✅ Sent to {', '.join(recipients)}."
+    except smtplib.SMTPAuthenticationError:
+        return ("❌ Authentication failed — check the sender account / App "
+                "Password (Gmail needs a 16-char App Password).")
+    except smtplib.SMTPConnectError as e:
+        return f"❌ Could not connect to the mail server: {e}"
+    except Exception as e:
+        return f"❌ Send failed: {e}"
+    finally:
+        _close(server)