Quick Start

# .env.local
FEATURE_REMOTE_AI_DISPATCH="false"

# Optional: external remote-dispatch override (disabled by default)
NEXT_PUBLIC_AI_SERVICE_URL=""

'use client'

import { useAIChat } from '@/hooks/use-ai-chat'

export function ChatComponent({ projectId }: { projectId: string }) {
  const {
    messages,
    isStreaming,
    sendMessage,
    stopStream,
  } = useAIChat({
    projectId,  // Enables knowledge-aware responses
    provider: 'openai',
    model: 'gpt-5',
  })

  const handleSubmit = (input: string) => {
    sendMessage(input)
  }

  return (
    <div>
      {messages.map((msg) => (
        <div key={msg.id}>
          <strong>{msg.role}:</strong> {msg.content}
          {msg.isStreaming && <span className="animate-pulse">▊</span>}
        </div>
      ))}
      <form onSubmit={(e) => {
        e.preventDefault()
        handleSubmit(e.currentTarget.input.value)
      }}>
        <input name="input" disabled={isStreaming} />
        <button type="submit">Send</button>
      </form>
    </div>
  )
}

import { useAITask } from '@/hooks/use-ai-task'

function KnowledgeButton({ projectId }: { projectId: string }) {
  const { generateKnowledgeBase, task, isPolling } = useAITask({
    onComplete: (status) => {
      console.log('Indexed!', status.result)
    },
  })

  return (
    <button
      onClick={() => generateKnowledgeBase(projectId)}
      disabled={isPolling}
    >
      {isPolling ? 'Indexing...' : 'Generate Knowledge Base'}
    </button>
  )
}

import { getAIClient } from '@/lib/ai/client'

const client = getAIClient()

// Non-streaming chat
const response = await client.chat({
  messages: [{ role: 'user', content: 'How is auth implemented?' }],
  projectId: 'my-project',
})

// Streaming chat
for await (const chunk of client.streamChat({
  messages: [{ role: 'user', content: 'Explain the architecture' }],
  projectId: 'my-project',
})) {
  process.stdout.write(chunk.content || '')
}