Ihr KI-Assistent.
Immer erreichbar.

// app/api/chat/route.ts
import { NextRequest } from "next/server";

export const runtime = "edge";

export async function POST(req: NextRequest) {
  const { messages } = await req.json();

  const response = await fetch(
    "https://api.openai.com/v1/chat/completions",
    {
      method: "POST",
      headers: {
        Authorization: `Bearer ${process.env.OPENAI_API_KEY}`,
        "Content-Type": "application/json",
      },
      body: JSON.stringify({
        model: "gpt-4o",
        stream: true,
        messages: [
          {
            role: "system",
            content:
              "Du bist ein hilfreicher KI-Assistent fuer einen " +
              "Onlineshop. Beantworte Fragen zu Produkten, " +
              "Bestellungen und Lieferzeiten praezise und freundlich.",
          },
          ...messages,
        ],
        max_tokens: 1024,
      }),
    }
  );

  // Antwort direkt an den Client streamen
  return new Response(response.body, {
    headers: {
      "Content-Type": "text/event-stream",
      "Cache-Control": "no-cache",
      Connection: "keep-alive",
    },
  });
}

// lib/prompts/shop-assistant.ts

export const SHOP_ASSISTANT_PROMPT = `
Du bist der KI-Assistent fuer [Shopname].
Deine Aufgabe: Kunden bei Produktfragen, Bestellungen
und Retouren helfen.

REGELN:
- Antworte immer auf Deutsch, freundlich und praezise
- Nutze die bereitgestellten Produktdaten fuer Empfehlungen
- Bei Preisfragen: Nenne den aktuellen Preis aus dem Katalog
- Bei Beschwerden: Entschuldige dich und erstelle ein Ticket
- Bei Fragen ausserhalb deines Wissens: Leite an Support weiter

ESKALATION:
- Rechtliche Fragen → Sofort an menschlichen Agent uebergeben
- Stornierung ueber 500 EUR → Agent-Freigabe erforderlich
- Technische Probleme → Ticket mit Prioritaet "HOCH" erstellen

KONTEXT-NUTZUNG:
- Pruefe immer den bisherigen Gespraechsverlauf
- Wiederhole keine Informationen, die bereits gegeben wurden
- Frage bei unklaren Anfragen hoeflich nach
`;

export function buildMessages(
  history: { role: string; content: string }[],
  productContext: string
) {
  return [
    { role: "system", content: SHOP_ASSISTANT_PROMPT },
    {
      role: "system",
      content: `Aktuelle Produktdaten:\n${productContext}`,
    },
    ...history,
  ];
}

// app/api/webhooks/chatbot/route.ts
import { NextRequest, NextResponse } from "next/server";

interface ChatbotEvent {
  type: "escalation" | "ticket" | "feedback";
  conversationId: string;
  summary: string;
  priority: "LOW" | "MEDIUM" | "HIGH";
  customerEmail?: string;
}

export async function POST(req: NextRequest) {
  const event: ChatbotEvent = await req.json();

  switch (event.type) {
    case "escalation":
      // Gespraechskontext an menschlichen Agent uebergeben
      await notifyAgent({
        conversationId: event.conversationId,
        summary: event.summary,
        priority: event.priority,
      });
      break;

    case "ticket":
      // Support-Ticket im Helpdesk erstellen
      await createTicket({
        title: event.summary,
        priority: event.priority,
        customer: event.customerEmail,
        context: event.conversationId,
      });
      break;

    case "feedback":
      // Kundenfeedback speichern fuer KI-Training
      await saveFeedback(event);
      break;
  }

  return NextResponse.json({ received: true });
}