thepopebot/chat

import { ChatInterface, MessageList, ChatInput } from 'thepopebot/chat';

import { ChatInterface } from 'thepopebot/chat';

export default function ChatPage() {
  return <ChatInterface chatId="thread-123" />;
}

import { POST } from 'thepopebot/chat/api';

import { POST } from 'thepopebot/chat/api';
export { POST };

export async function POST(request) {
  const session = await auth();
  if (!session?.user?.id) {
    return Response.json({ error: 'Unauthorized' }, { status: 401 });
  }

  const body = await request.json();
  const { messages, chatId: rawChatId, trigger, codeMode, repo, branch, workspaceId } = body;

  // Extract last user message
  const lastUserMessage = [...messages].reverse().find((m) => m.role === 'user');
  
  // Process text and file parts
  let userText = lastUserMessage.parts
    ?.filter((p) => p.type === 'text')
    .map((p) => p.text)
    .join('\n') || lastUserMessage.content || '';

  const fileParts = lastUserMessage.parts?.filter((p) => p.type === 'file') || [];
  const attachments = [];

  for (const part of fileParts) {
    const { mediaType, url } = part;
    if (mediaType.startsWith('image/') || mediaType === 'application/pdf') {
      attachments.push({ category: 'image', mimeType: mediaType, dataUrl: url });
    } else if (mediaType.startsWith('text/')) {
      const base64Data = url.split(',')[1];
      const textContent = Buffer.from(base64Data, 'base64').toString('utf-8');
      userText += `\n\nFile: ${part.name}\n\`\`\`\n${textContent}\n\`\`\``;
    }
  }

  const threadId = rawChatId || uuidv4();
  const chunks = chatStream(threadId, userText, attachments, {
    userId: session.user.id,
    skipUserPersist: trigger === 'regenerate-message',
  });

  // Stream to browser using AI SDK format
  return createUIMessageStreamResponse({ stream });
}

// Text chunks
{ type: 'text-start', id: string }
{ type: 'text-delta', id: string, delta: string }
{ type: 'text-end', id: string }

// Tool calls
{ type: 'tool-input-start', toolCallId: string, toolName: string }
{ type: 'tool-input-available', toolCallId: string, toolName: string, input: object }
{ type: 'tool-output-available', toolCallId: string, output: any }

// Message boundaries
{ type: 'start' }
{ type: 'finish' }

import { getChatHistory, deleteChat, updateChatTitle } from 'thepopebot/chat/actions';

'use server';
import { getChatHistory } from 'thepopebot/chat/actions';

export async function loadChats() {
  const chats = await getChatHistory();
  return chats.map(c => ({ id: c.id, title: c.title }));
}