feat: Günther-Agent (Netzer-Style) + Expertenblick im TipModal
- AgentChat-Widget mit SSE-Streaming, Quick-Actions, Multiple-Choice - /api/agent/chat + /api/agent/insight Routen - Expertenblick-Panel im TipModal (lazy load) - Günther-Icon
This commit is contained in:
Ronny
@@ -0,0 +1,266 @@
|
||||
import { Router, Request, Response } from 'express';
|
||||
import Anthropic from '@anthropic-ai/sdk';
|
||||
import { query } from '../db/client';
|
||||
import { logger } from '../services/logger';
|
||||
|
||||
const router = Router();
|
||||
|
||||
// ============================================================
|
||||
// Anthropic Client (lazy-initialized, Key aus .env)
|
||||
// ============================================================
|
||||
let anthropic: Anthropic | null = null;
|
||||
function getClient(): Anthropic {
|
||||
if (!anthropic) {
|
||||
const apiKey = process.env.ANTHROPIC_API_KEY;
|
||||
if (!apiKey) throw new Error('ANTHROPIC_API_KEY not set');
|
||||
anthropic = new Anthropic({ apiKey });
|
||||
}
|
||||
return anthropic;
|
||||
}
|
||||
|
||||
// ============================================================
|
||||
// Kontext: aktuelle Spiele aus der DB holen
|
||||
// ============================================================
|
||||
async function getMatchContext(): Promise<string> {
|
||||
try {
|
||||
const rows = await query<{
|
||||
utc_date: Date;
|
||||
status: string;
|
||||
stage: string;
|
||||
group_name: string | null;
|
||||
home_team_name: string;
|
||||
away_team_name: string;
|
||||
score_home: number | null;
|
||||
score_away: number | null;
|
||||
}>(
|
||||
`SELECT utc_date, status, stage, group_name,
|
||||
home_team_name, away_team_name, score_home, score_away
|
||||
FROM matches
|
||||
ORDER BY utc_date ASC
|
||||
LIMIT 200`
|
||||
);
|
||||
|
||||
const now = new Date();
|
||||
const upcoming = rows.filter(
|
||||
(r) => new Date(r.utc_date) > now && (r.status === 'SCHEDULED' || r.status === 'TIMED')
|
||||
);
|
||||
const finished = rows.filter((r) => r.status === 'FINISHED');
|
||||
const inPlay = rows.filter((r) => r.status === 'IN_PLAY' || r.status === 'PAUSED');
|
||||
|
||||
const lines: string[] = [];
|
||||
|
||||
if (inPlay.length > 0) {
|
||||
lines.push('=== LIVE JETZT ===');
|
||||
inPlay.forEach((m) => {
|
||||
lines.push(
|
||||
`${m.home_team_name} ${m.score_home ?? '?'} : ${m.score_away ?? '?'} ${m.away_team_name} (LIVE)`
|
||||
);
|
||||
});
|
||||
}
|
||||
|
||||
if (upcoming.length > 0) {
|
||||
lines.push('\n=== NÄCHSTE SPIELE (WM 2026) ===');
|
||||
upcoming.slice(0, 20).forEach((m) => {
|
||||
const d = new Date(m.utc_date);
|
||||
const dateStr = d.toLocaleDateString('de-DE', {
|
||||
weekday: 'short', day: '2-digit', month: '2-digit', hour: '2-digit', minute: '2-digit',
|
||||
});
|
||||
const groupStr = m.group_name ? ` [${m.group_name}]` : ` [${m.stage}]`;
|
||||
lines.push(`${dateStr}${groupStr}: ${m.home_team_name} vs. ${m.away_team_name}`);
|
||||
});
|
||||
}
|
||||
|
||||
if (finished.length > 0) {
|
||||
lines.push('\n=== ZULETZT GESPIELT ===');
|
||||
finished.slice(-10).forEach((m) => {
|
||||
lines.push(
|
||||
`${m.home_team_name} ${m.score_home} : ${m.score_away} ${m.away_team_name} (Ergebnis)`
|
||||
);
|
||||
});
|
||||
}
|
||||
|
||||
return lines.join('\n');
|
||||
} catch (err) {
|
||||
logger.error('Agent: Fehler beim Laden des Match-Kontexts', { err });
|
||||
return '(Keine Spieldaten verfügbar)';
|
||||
}
|
||||
}
|
||||
|
||||
// ============================================================
|
||||
// System-Prompt: Der Fußball-Experte
|
||||
// ============================================================
|
||||
// Netzer-Stil: Beispiele als Few-Shot Anker
|
||||
const NETZER_STYLE =
|
||||
'DEIN STIL - Günter Netzer:\n' +
|
||||
'Du sprichst wie Günter Netzer in seiner Zeit als ARD-Experte. Trocken. Direkt. Keine Begeisterungsstürme.\n' +
|
||||
'Du stellst fest - du zweifelst nicht. Du kennst den Fußball von innen, das merkt man.\n\n' +
|
||||
'Beispiele für deinen Ton:\n' +
|
||||
'- "Das ist eine gute Mannschaft. Aber heute reicht es nicht."\n' +
|
||||
'- "Brasilien hat die besseren Einzelspieler. Was daraus wird, steht auf einem anderen Blatt."\n' +
|
||||
'- "Ich habe 1974 gegen bessere Außenverteidiger gespielt. Das war Fußball."\n' +
|
||||
'- "Ein Unentschieden waere fair. Aber Fairness interessiert im Fußball niemanden."\n' +
|
||||
'- "Der Torwart hat das gehalten. Musste er auch."\n\n' +
|
||||
'Regeln: Kurze Saetze. Kein "mega", kein "Wahnsinn", kein uebertriebenes Lob. Gelegentlich ein trockener Vergleich mit frueheren WM-Turnieren oder Legenden (Beckenbauer, Müller, Cruyff). Du duzt alle.\n\n';
|
||||
|
||||
const SYSTEM_PROMPT_BASE =
|
||||
'Du bist der Fußball-Experte im WM 2026 Tippspiel von GEALAN. Du kennst WM und EM in- und auswendig: Ergebnisse, Rekorde, Taktiken, Legenden - von 1930 bis heute.\n\n' +
|
||||
NETZER_STYLE +
|
||||
'TIPP-EMPFEHLUNGEN: Wenn jemand allgemein fragt, stelle zuerst eine Rückfrage. Haenge einen CHOICES-Block an mit den naechsten 5 Spielen. Erst nach Auswahl gibst du Empfehlungen - maximal 3 auf einmal.\n\n' +
|
||||
'CHOICES-FORMAT (nur fuer Tipp-Rückfragen):\n' +
|
||||
'[CHOICES]\nHeimteam vs. Gastteam\n[/CHOICES]\n' +
|
||||
'Exakte Teamnamen aus dem Kontext. Kein Datum, keine Emojis im Block.\n\n' +
|
||||
'FORMATIERUNG: Kompakt (max. 4 Absaetze). **fett** fuer Namen/Scores. ## fuer Überschriften. --- als Trennlinie. Kein # H1. Kein Emoji-Overload.\n\n' +
|
||||
'SPIELPLAN-KONTEXT:\n';
|
||||
|
||||
// ============================================================
|
||||
// POST /api/agent/chat
|
||||
// Body: { messages: [{role, content}][], quickAction?: string }
|
||||
// ============================================================
|
||||
router.post('/chat', async (req: Request, res: Response): Promise<void> => {
|
||||
const { messages, quickAction } = req.body as {
|
||||
messages?: Array<{ role: 'user' | 'assistant'; content: string }>;
|
||||
quickAction?: string;
|
||||
};
|
||||
|
||||
// Validierung
|
||||
if (!messages && !quickAction) {
|
||||
res.status(400).json({ error: 'messages oder quickAction erforderlich' });
|
||||
return;
|
||||
}
|
||||
|
||||
const chatMessages: Array<{ role: 'user' | 'assistant'; content: string }> =
|
||||
messages ?? [];
|
||||
|
||||
// Quick-Action als User-Nachricht hinzufügen
|
||||
if (quickAction) {
|
||||
chatMessages.push({ role: 'user', content: quickAction });
|
||||
}
|
||||
|
||||
if (chatMessages.length === 0) {
|
||||
res.status(400).json({ error: 'Keine Nachrichten vorhanden' });
|
||||
return;
|
||||
}
|
||||
|
||||
try {
|
||||
const client = getClient();
|
||||
const matchContext = await getMatchContext();
|
||||
const systemPrompt = SYSTEM_PROMPT_BASE + matchContext;
|
||||
|
||||
// Streaming-Antwort via SSE
|
||||
res.setHeader('Content-Type', 'text/event-stream');
|
||||
res.setHeader('Cache-Control', 'no-cache');
|
||||
res.setHeader('Connection', 'keep-alive');
|
||||
res.flushHeaders();
|
||||
|
||||
const stream = await client.messages.stream({
|
||||
model: 'claude-sonnet-4-6',
|
||||
max_tokens: 1024,
|
||||
system: systemPrompt,
|
||||
messages: chatMessages.slice(-10), // max. 10 Nachrichten Kontext
|
||||
});
|
||||
|
||||
for await (const chunk of stream) {
|
||||
if (
|
||||
chunk.type === 'content_block_delta' &&
|
||||
chunk.delta.type === 'text_delta'
|
||||
) {
|
||||
const data = JSON.stringify({ text: chunk.delta.text });
|
||||
res.write(`data: ${data}\n\n`);
|
||||
}
|
||||
}
|
||||
|
||||
res.write('data: [DONE]\n\n');
|
||||
res.end();
|
||||
|
||||
logger.info('Agent: Chat-Anfrage beantwortet', {
|
||||
userId: req.staffbaseUser?.sub,
|
||||
messageCount: chatMessages.length,
|
||||
});
|
||||
} catch (error: unknown) {
|
||||
const message = error instanceof Error ? error.message : 'Unknown error';
|
||||
logger.error('Agent: Fehler', { error: message });
|
||||
|
||||
if (!res.headersSent) {
|
||||
res.status(500).json({ error: 'Agent nicht verfügbar', detail: message });
|
||||
} else {
|
||||
res.write(`data: ${JSON.stringify({ error: message })}\n\n`);
|
||||
res.end();
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
// ============================================================
|
||||
// POST /api/agent/insight
|
||||
// Kompakte Einschätzung für genau ein Spiel (für TipModal)
|
||||
// Body: { homeTeam: string, awayTeam: string, stage: string, group?: string }
|
||||
// ============================================================
|
||||
router.post('/insight', async (req: Request, res: Response): Promise<void> => {
|
||||
const { homeTeam, awayTeam, stage, group } = req.body as {
|
||||
homeTeam: string;
|
||||
awayTeam: string;
|
||||
stage?: string;
|
||||
group?: string;
|
||||
};
|
||||
|
||||
if (!homeTeam || !awayTeam) {
|
||||
res.status(400).json({ error: 'homeTeam und awayTeam erforderlich' });
|
||||
return;
|
||||
}
|
||||
|
||||
const stageLabel = group
|
||||
? group.replace('GROUP_', 'Gruppe ')
|
||||
: stage ?? 'WM 2026';
|
||||
|
||||
const insightPrompt =
|
||||
NETZER_STYLE +
|
||||
'Gib eine Kurzeinschätzung im Netzer-Stil. Exakt dieses Format, keine Abweichungen:\n\n' +
|
||||
'**Ausgangslage:** Ein trockener Satz zur Lage.\n' +
|
||||
'**Favorit:** Teamname - ein Satz Begruendung.\n' +
|
||||
'**Risiko:** Ein Satz fuer den Außenseiter.\n' +
|
||||
'**Tipp:** **Score** - Teamname und ein Satz.\n\n' +
|
||||
'Trennzeichen: immer Gedankenstrich, nie Pluszeichen. Keine weiteren Zeilen.\n\n' +
|
||||
'Spiel: ' + homeTeam + ' vs. ' + awayTeam + ' (' + stageLabel + ')';
|
||||
|
||||
try {
|
||||
const client = getClient();
|
||||
|
||||
res.setHeader('Content-Type', 'text/event-stream');
|
||||
res.setHeader('Cache-Control', 'no-cache');
|
||||
res.setHeader('Connection', 'keep-alive');
|
||||
res.flushHeaders();
|
||||
|
||||
const stream = await client.messages.stream({
|
||||
model: 'claude-haiku-4-5-20251001',
|
||||
max_tokens: 256,
|
||||
messages: [{ role: 'user', content: insightPrompt }],
|
||||
});
|
||||
|
||||
for await (const chunk of stream) {
|
||||
if (
|
||||
chunk.type === 'content_block_delta' &&
|
||||
chunk.delta.type === 'text_delta'
|
||||
) {
|
||||
res.write('data: ' + JSON.stringify({ text: chunk.delta.text }) + '\n\n');
|
||||
}
|
||||
}
|
||||
|
||||
res.write('data: [DONE]\n\n');
|
||||
res.end();
|
||||
|
||||
logger.info('Agent: Insight geliefert', {
|
||||
userId: req.staffbaseUser?.sub,
|
||||
match: homeTeam + ' vs ' + awayTeam,
|
||||
});
|
||||
} catch (error: unknown) {
|
||||
const message = error instanceof Error ? error.message : 'Unknown error';
|
||||
logger.error('Agent: Insight-Fehler', { error: message });
|
||||
if (!res.headersSent) {
|
||||
res.status(500).json({ error: 'Insight nicht verfügbar' });
|
||||
} else {
|
||||
res.write('data: ' + JSON.stringify({ error: message }) + '\n\n');
|
||||
res.end();
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
export default router;
|
||||
Reference in New Issue
Block a user