Chatbot

"use client";

import { Chatbot } from "@/components/ui/chatbot";
import type { AIChatRequest } from "@/components/ui/ai-chat";

async function* send({ messages, signal }: AIChatRequest) {
  const res = await fetch("/api/chat", { method: "POST", body: JSON.stringify({ messages }), signal });
  const reader = res.body!.pipeThrough(new TextDecoderStream()).getReader();
  for (;;) {
    const { done, value } = await reader.read();
    if (done) return;
    yield value;
  }
  // To ask back, yield events as well as text:
  // yield { type: "choices", choices: [{ label: "Upload a file" }, { label: "Not now" }] };
  // yield { type: "confirm", title: "Start the import?", confirmLabel: "Start", cancelLabel: "Cancel" };
}

export function SiteAssistant() {
  return (
    <Chatbot
      variant="floating"
      assistant={{ name: "Acme Assistant", detail: "Connected" }}
      welcome={{ title: "How can I help?", starters: ["Where is my order?", "Change my plan"] }}
      onSend={send}
      onAction={({ confirmed, choice }) => {
        if (confirmed) startImport(); // your code runs the action
      }}
    />
  );
}

function startImport() {}