refactor: remove KI-Agent chat widget and backend route
This commit is contained in:
@@ -1,411 +0,0 @@
|
||||
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
|
||||
// ============================================================
|
||||
const NETZER_STYLE =
|
||||
'DEIN STIL - Günther Netzer:\n' +
|
||||
'Du bist Günther Netzer, ARD-Fußballexperte von 1997-2010. Trocken. Direkt. Elitär. Nostalgisch.\n' +
|
||||
'Du maßt das aktuelle Geschehen stets an idealistischen Maßstäben - und an deiner eigenen Karriere.\n\n' +
|
||||
'TYPISCHE PHRASEN die du verwendest:\n' +
|
||||
'- "Aus der Tiefe des Raumes"\n' +
|
||||
'- "Das sind fundamentale Dinge"\n' +
|
||||
'- "Das ist ein Minimalisten-Dasein"\n' +
|
||||
'- "Mir hat hier heute noch gar nichts gefallen"\n' +
|
||||
'- "Das hat mit Spitzenfußball nichts zu tun"\n' +
|
||||
'- "Das war dezent" (wenn eine Leistung mäßig war)\n' +
|
||||
'- "Was bleibt mir noch übrig jetzt zu sagen..."\n' +
|
||||
'- Gelegentlich ironisches Lob: "Das ist wirklich eine sehr kluge Beobachtung..."\n\n' +
|
||||
'EIGENHEITEN:\n' +
|
||||
'- Du vergleichst fast alles mit Beckenbauer, Müller, Cruyff oder deiner eigenen Zeit\n' +
|
||||
'- Taktik-Geschwafel lehnst du ab: "Das nennen die heutzutage Ballbesitzfußball. Früher nannte man das Angst."\n' +
|
||||
'- Du bist von Mannschaften prinzipiell enttäuscht, außer die Leistung ist absolut unstrittig\n' +
|
||||
'- Kurze Sätze. Kein "mega", kein "Wahnsinn". Kein übertriebenes Lob.\n\n';
|
||||
|
||||
const DELLING_STYLE =
|
||||
'Die Rolle von Gerhard Delling (dein Moderator-Pendant, NUR im Dialog-Modus):\n' +
|
||||
'- Trocken, skeptisch, stichelt gerne\n' +
|
||||
'- Typische Phrasen: "Nun könnte man sagen, seien wir doch mal großzügig...", "Fanden Sie nicht, dass immerhin..."\n' +
|
||||
'- Verteidigt absichtlich die schwächere Mannschaft um Netzer zu provozieren\n' +
|
||||
'- Stichelt gegen Netzers Vergangenheit (Laufbereitschaft, Frisur)\n' +
|
||||
'- Bleibt immer ruhig, lässt sich von Netzers Arroganz nicht erschüttern\n' +
|
||||
'- Er und Netzer siezen sich stets, obwohl sie Freunde sind\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 +
|
||||
DELLING_STYLE +
|
||||
'GESPRÄCHSMODUS: Wenn der Nutzer dich direkt anschreibt, antwortest du als Netzer allein. Wenn du eine Analyse oder Einschätzung gibst, kannst du gelegentlich einen kurzen Einwurf von Delling einfließen lassen - im Format:\n' +
|
||||
'**Delling:** "..."\n' +
|
||||
'**Netzer:** "..."\n\n' +
|
||||
'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 +
|
||||
DELLING_STYLE +
|
||||
'Schreibe einen kurzen Expertenblick als Dialog zwischen Delling und Netzer über das folgende Spiel.\n\n' +
|
||||
'WICHTIG: Das Spiel hat noch NICHT stattgefunden. Es ist eine Vorschau, keine Nachbetrachtung.\n' +
|
||||
'Verwende ausschließlich Zukunftsformen und Konjunktiv: "wird", "könnte", "dürfte", "ist zu erwarten".\n' +
|
||||
'Du darfst auf vergangene Begegnungen, Qualifikation oder historische Statistiken referenzieren - aber nur als Argument für die Prognose.\n' +
|
||||
'VERBOTEN: Phrasen wie "hat mir nicht gefallen", "da war nichts", "das war" bezogen auf das aktuelle Spiel.\n\n' +
|
||||
'BEISPIELE (Vorschau-Ton - diese Authentizität ist entscheidend):\n\n' +
|
||||
'Beispiel 1 (Gruppenspiel mit klarem Favoriten):\n' +
|
||||
'**Delling:** "Nun, Herr Netzer, wir haben hier ja doch einen veritablen Favoriten. Könnte der Außenseiter nicht von der Qualifikationsform profitieren?"\n' +
|
||||
'**Netzer:** "Nein. Das waren Qualifikationsspiele. Das wird mit dem hier nichts zu tun haben. Das sind fundamentale Dinge."\n' +
|
||||
'**Delling:** "Seien wir doch mal großzügig - auch der Außenseiter hat Qualitäten, die sich zeigen könnten."\n' +
|
||||
'**Netzer:** "Das nennen Sie Qualitäten. Ich nenne das ein Minimalisten-Dasein. Ich tippe auf einen klaren Sieg des Favoriten."\n\n' +
|
||||
'Beispiel 2 (Ausgeglichenes Spiel):\n' +
|
||||
'**Delling:** "Herr Netzer, das könnte ja ein enges Spiel werden. Beide Mannschaften liegen nah beieinander."\n' +
|
||||
'**Netzer:** "Das ist dezent ausgedrückt. Beiden fehlt, was Beckenbauer damals selbstverständlich war - diese Überlegenheit. Aus der Tiefe des Raumes heraus, verstehen Sie?"\n' +
|
||||
'**Delling:** "Ich glaube, die Spieler würden sich bedanken, wenn Sie ihnen das vor dem Anpfiff erläutern könnten."\n' +
|
||||
'**Netzer:** "Was bleibt mir noch übrig jetzt zu sagen. Ich tippe auf ein 1:1."\n\n' +
|
||||
'JETZT das echte Spiel:\n' +
|
||||
'Spiel: **' + homeTeam + '** vs. **' + awayTeam + '** (' + stageLabel + ')\n\n' +
|
||||
'Schreibe genau 4 Wechselreden (Delling, Netzer, Delling, Netzer). Netzer gibt am Ende seinen konkreten Tipp mit Score. Kein Emoji. Siezen. Kurze Sätze bei Netzer.';
|
||||
|
||||
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: 512,
|
||||
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();
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
// ============================================================
|
||||
// POST /api/agent/insight-audio
|
||||
// Body: { dialogText: string }
|
||||
// Gibt eine MP3 zurück (Delling + Netzer als Dialog, 2 Stimmen)
|
||||
// ============================================================
|
||||
|
||||
// ElevenLabs Voice-IDs (kostenlose Standard-Voices)
|
||||
// Netzer: "Adam" – tief, ruhig, autoritär
|
||||
// Delling: "Antoni" – etwas heller, sachlicher
|
||||
const ELEVENLABS_VOICE_NETZER = process.env.ELEVENLABS_VOICE_NETZER ?? 'pNInz6obpgDQGcFmaJgB'; // Adam
|
||||
const ELEVENLABS_VOICE_DELLING = process.env.ELEVENLABS_VOICE_DELLING ?? 'ErXwobaYiN019PkySvjV'; // Antoni
|
||||
|
||||
async function synthesizeTurn(
|
||||
text: string,
|
||||
voiceId: string,
|
||||
apiKey: string
|
||||
): Promise<Buffer> {
|
||||
const res = await fetch(
|
||||
`https://api.elevenlabs.io/v1/text-to-speech/${voiceId}`,
|
||||
{
|
||||
method: 'POST',
|
||||
headers: {
|
||||
'xi-api-key': apiKey,
|
||||
'Content-Type': 'application/json',
|
||||
Accept: 'audio/mpeg',
|
||||
},
|
||||
body: JSON.stringify({
|
||||
text,
|
||||
model_id: 'eleven_multilingual_v2',
|
||||
voice_settings: { stability: 0.55, similarity_boost: 0.75 },
|
||||
}),
|
||||
}
|
||||
);
|
||||
if (!res.ok) {
|
||||
const err = await res.text();
|
||||
throw new Error(`ElevenLabs error ${res.status}: ${err}`);
|
||||
}
|
||||
const arrayBuf = await res.arrayBuffer();
|
||||
return Buffer.from(arrayBuf);
|
||||
}
|
||||
|
||||
// Parst **Delling:** "..." / **Netzer:** "..." Zeilen aus dem Dialog-Text
|
||||
function parseDialogTurns(
|
||||
dialogText: string
|
||||
): Array<{ speaker: 'Delling' | 'Netzer'; text: string }> {
|
||||
const turns: Array<{ speaker: 'Delling' | 'Netzer'; text: string }> = [];
|
||||
const lines = dialogText.split('\n');
|
||||
for (const line of lines) {
|
||||
const m = line.match(/^\*\*(Delling|Netzer):\*\*\s*[„""]?(.+?)["""]?\s*$/);
|
||||
if (m) {
|
||||
turns.push({
|
||||
speaker: m[1] as 'Delling' | 'Netzer',
|
||||
text: m[2].trim(),
|
||||
});
|
||||
}
|
||||
}
|
||||
return turns;
|
||||
}
|
||||
|
||||
router.post('/insight-audio', async (req: Request, res: Response): Promise<void> => {
|
||||
const { dialogText } = req.body as { dialogText?: string };
|
||||
|
||||
if (!dialogText) {
|
||||
res.status(400).json({ error: 'dialogText erforderlich' });
|
||||
return;
|
||||
}
|
||||
|
||||
const apiKey = process.env.ELEVENLABS_API_KEY;
|
||||
if (!apiKey) {
|
||||
res.status(503).json({ error: 'ELEVENLABS_API_KEY nicht konfiguriert' });
|
||||
return;
|
||||
}
|
||||
|
||||
const turns = parseDialogTurns(dialogText);
|
||||
logger.info('Audio: Dialog geparst', { turns: turns.length, preview: dialogText.slice(0, 200) });
|
||||
if (turns.length === 0) {
|
||||
res.status(400).json({ error: 'Kein Dialog-Format erkannt' });
|
||||
return;
|
||||
}
|
||||
|
||||
try {
|
||||
// Turns sequenziell synthetisieren (Free Tier: max 2 concurrent)
|
||||
const audioBuffers: Buffer[] = [];
|
||||
for (const turn of turns) {
|
||||
const buf = await synthesizeTurn(
|
||||
turn.text,
|
||||
turn.speaker === 'Netzer' ? ELEVENLABS_VOICE_NETZER : ELEVENLABS_VOICE_DELLING,
|
||||
apiKey
|
||||
);
|
||||
audioBuffers.push(buf);
|
||||
}
|
||||
|
||||
// MP3-Chunks zusammenführen (einfaches Aneinanderhängen reicht für MP3)
|
||||
const combined = Buffer.concat(audioBuffers);
|
||||
|
||||
res.setHeader('Content-Type', 'audio/mpeg');
|
||||
res.setHeader('Content-Length', combined.length);
|
||||
res.setHeader('Cache-Control', 'no-store');
|
||||
res.send(combined);
|
||||
|
||||
logger.info('Agent: Insight-Audio generiert', {
|
||||
userId: req.staffbaseUser?.sub,
|
||||
turns: turns.length,
|
||||
});
|
||||
} catch (error: unknown) {
|
||||
const message = error instanceof Error ? error.message : 'Unknown error';
|
||||
logger.error('Agent: Insight-Audio-Fehler', { error: message });
|
||||
if (!res.headersSent) {
|
||||
res.status(500).json({ error: 'Audio-Generierung fehlgeschlagen' });
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
export default router;
|
||||
Reference in New Issue
Block a user