;
};
// ── Composant principal ─────────────────────────────────────────
const QTCoach = ({ go } = {}) => {
const [boot, setBoot] = React.useState("loading"); // loading | ready | error
const [bootError, setBootError] = React.useState("");
const [messages, setMessages] = React.useState([]); // {role, content}
const [input, setInput] = React.useState("");
const [streaming, setStreaming] = React.useState(false);
const [quota, setQuota] = React.useState(null); // {used, limit, plan}
const [quotaBlocked, setQuotaBlocked] = React.useState(false);
const [stats, setStats] = React.useState(null); // bandeau contexte
const digestRef = React.useRef(null);
const userIdRef = React.useRef(null);
const tokenRef = React.useRef(null);
const abortRef = React.useRef(null);
const scrollRef = React.useRef(null);
const inputRef = React.useRef(null);
const messagesRef = React.useRef([]);
messagesRef.current = messages;
const storageKey = () => `nomerus_coach_chat_${userIdRef.current || "anon"}`;
const persist = (msgs) => {
try {
localStorage.setItem(storageKey(), JSON.stringify(msgs.slice(-QT_CHAT_MAX_STORED)));
} catch (e) { /* stockage plein : tant pis */ }
};
// ── Bootstrap : session + trades 30j → digest ────────────────
React.useEffect(() => {
let cancelled = false;
(async () => {
try {
const sb = window.nomerusSb();
if (!sb) throw new Error("Connexion Supabase indisponible.");
const { data: { session } } = await sb.auth.getSession();
if (!session || !session.access_token) throw new Error("Session expirée. Reconnecte-toi.");
userIdRef.current = session.user && session.user.id;
tokenRef.current = session.access_token;
const since = new Date(Date.now() - 30 * 86400e3).toISOString();
const { data: trades, error: tErr } = await sb
.from("trades")
.select("date, asset, direction, pnl, r_multiple, result, session, strategy")
.gte("date", since)
.order("date", { ascending: true });
if (tErr) throw tErr;
if (cancelled) return;
const list = trades || [];
digestRef.current = qtBuildCoachDigest(list);
let net = 0, wins = 0;
for (const t of list) {
net += Number(t.pnl) || 0;
if ((t.result || "").toUpperCase() === "WIN") wins += 1;
}
setStats({
count: list.length,
winRate: list.length > 0 ? (wins / list.length) * 100 : 0,
net,
});
// Historique local
try {
const saved = JSON.parse(localStorage.getItem(storageKey()) || "[]");
if (Array.isArray(saved)) setMessages(saved.slice(-QT_CHAT_MAX_STORED));
} catch (e) { /* historique corrompu : on repart à zéro */ }
// Consommation du jour (lecture directe, RLS "select own")
try {
const today = new Date().toISOString().slice(0, 10);
const { data: usage } = await sb
.from("ai_chat_usage").select("messages")
.eq("user_id", userIdRef.current).eq("day", today).maybeSingle();
if (usage && typeof usage.messages === "number") {
setQuota({ used: usage.messages, limit: null, plan: null });
}
} catch (e) { /* table pas encore migrée : non bloquant */ }
setBoot("ready");
} catch (e) {
if (cancelled) return;
console.error("[coach]", e);
setBootError(e.message || "Erreur inconnue.");
setBoot("error");
}
})();
return () => {
cancelled = true;
if (abortRef.current) abortRef.current.abort();
};
}, []);
// Auto-scroll en bas à chaque nouveau contenu
React.useEffect(() => {
const el = scrollRef.current;
if (el) el.scrollTop = el.scrollHeight;
}, [messages, streaming]);
// ── Envoi d'un message ────────────────────────────────────────
const sendMessage = async (rawText) => {
const text = String(rawText || "").trim();
if (!text || streaming || quotaBlocked) return;
const base = [...messagesRef.current, { role: "user", content: text }];
const withPlaceholder = [...base, { role: "assistant", content: "" }];
setMessages(withPlaceholder);
persist(base);
setInput("");
setStreaming(true);
const setAssistant = (updater) => {
setMessages(prev => {
const next = prev.slice();
const last = next[next.length - 1];
if (last && last.role === "assistant") {
next[next.length - 1] = { role: "assistant", content: updater(last.content) };
}
return next;
});
};
const controller = new AbortController();
abortRef.current = controller;
try {
// Rafraîchir le token si besoin (session longue durée)
const sb = window.nomerusSb();
if (sb) {
const { data: { session } } = await sb.auth.getSession();
if (session && session.access_token) tokenRef.current = session.access_token;
}
const resp = await fetch(QT_CHAT_ENDPOINT, {
method: "POST",
signal: controller.signal,
headers: {
"authorization": `Bearer ${tokenRef.current}`,
"content-type": "application/json",
},
body: JSON.stringify({
messages: base.slice(-QT_CHAT_MAX_SENT),
digest: digestRef.current || undefined,
}),
});
if (resp.status === 429) {
const body = await resp.json().catch(() => ({}));
setQuota({ used: body.used, limit: body.limit, plan: body.plan });
setQuotaBlocked(true);
setAssistant(() =>
"Tu as atteint ta limite de messages du Coach pour aujourd'hui. " +
"Le compteur se remet à zéro à minuit (UTC) — reviens demain, ton journal sera toujours là.");
return;
}
if (!resp.ok || !resp.body) {
const body = await resp.json().catch(() => ({}));
throw new Error(
body.error === "ai_temporarily_disabled"
? "Le Coach IA est temporairement indisponible. Réessaie dans quelques minutes."
: `Le Coach n'a pas pu répondre (${resp.status}). Réessaie dans un instant.`
);
}
// Lecture du flux SSE
const reader = resp.body.getReader();
const decoder = new TextDecoder();
let buffer = "";
let gotDelta = false;
while (true) {
const { done, value } = await reader.read();
if (done) break;
buffer += decoder.decode(value, { stream: true });
let idx;
while ((idx = buffer.indexOf("\n")) !== -1) {
const line = buffer.slice(0, idx).trimEnd();
buffer = buffer.slice(idx + 1);
if (!line.startsWith("data:")) continue;
let ev;
try { ev = JSON.parse(line.slice(5).trim()); } catch (e) { continue; }
if (ev.type === "delta" && typeof ev.text === "string") {
gotDelta = true;
setAssistant(prev => prev + ev.text);
} else if (ev.type === "done") {
if (ev.quota) setQuota(ev.quota);
} else if (ev.type === "error") {
throw new Error("Le flux de réponse a été interrompu. Réessaie.");
}
}
}
if (!gotDelta) throw new Error("Réponse vide du Coach. Réessaie.");
// Persister l'échange complet
setMessages(prev => { persist(prev); return prev; });
} catch (e) {
if (e && e.name === "AbortError") {
// Arrêt volontaire : on garde ce qui a été streamé
setMessages(prev => { persist(prev); return prev; });
} else {
console.error("[coach chat]", e);
setAssistant(prev => prev || `⚠ ${e.message || "Erreur inconnue."}`);
}
} finally {
abortRef.current = null;
setStreaming(false);
if (inputRef.current) inputRef.current.focus();
}
};
const stopStreaming = () => {
if (abortRef.current) abortRef.current.abort();
};
const newConversation = () => {
if (streaming) stopStreaming();
setMessages([]);
try { localStorage.removeItem(storageKey()); } catch (e) { /* ignore */ }
};
const onKeyDown = (e) => {
if (e.key === "Enter" && !e.shiftKey) {
e.preventDefault();
sendMessage(input);
}
};
// ── États non-nominaux ────────────────────────────────────────
if (boot === "loading") {
return (
◆ COACH IA · CHARGEMENT
Le Coach charge le contexte de ton journal…
);
}
if (boot === "error") {
return (
// COACH INDISPONIBLE
{bootError}
);
}
// ── Chat ──────────────────────────────────────────────────────
const suggestions = (stats && stats.count >= 5) ? [
"Fais-moi le bilan de mes 30 derniers jours",
"Quel est mon plus gros point faible en ce moment ?",
"Sur quelles sessions / actifs suis-je le plus rentable ?",
"Est-ce que je respecte mon risk management ?",
] : [
"Comment bien démarrer mon journal de trading ?",
"Qu'est-ce que tu pourras m'apprendre une fois mes trades journalisés ?",
];
const empty = messages.length === 0;
return (