refactor: remove KI-Agent chat widget and backend route

This commit is contained in:
Ronny
2026-04-11 18:54:50 +02:00
parent 6a0b267660
commit a7efd9354d
14 changed files with 371 additions and 1381 deletions
-12
View File
@@ -14,7 +14,6 @@ import leaderboardRouter from './routes/leaderboard';
import adminRouter from './routes/admin';
import profileRouter from './routes/profile';
import devRouter from './routes/dev';
import agentRouter from './routes/agent';
const app = express();
const PORT = parseInt(process.env.PORT ?? '3001');
@@ -96,16 +95,6 @@ app.use(
})
);
// Rate limit für Agent-Chat (Claude API Calls sind kostenpflichtig)
app.use(
'/api/agent',
rateLimit({
windowMs: 60 * 1000, // 1 Minute
max: 10, // 10 Chat-Nachrichten pro User/Minute
message: { error: 'Too many agent requests, bitte kurz warten.' },
})
);
// ============================================================
// Health Check (ohne Auth für Railway/Render/Uptime-Monitoring)
// ============================================================
@@ -137,7 +126,6 @@ app.use('/api/tips', tipsRouter);
app.use('/api/leaderboard', leaderboardRouter);
app.use('/api/admin', adminRouter);
app.use('/api/profile', profileRouter);
app.use('/api/agent', agentRouter);
if (process.env.NODE_ENV === 'development') {
app.use('/api/dev', devRouter);
}
-411
View File
@@ -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;