البث

import { useChat } from '@dypai-ai/client-sdk/react'

function ChatBox() {
  const {
    messages,      // full message history
    sendMessage,   // send a new message
    isLoading,     // true while the agent is responding
    stop,          // abort the current stream
    error,         // any error that occurred
  } = useChat('my_agent_endpoint')

  return (
    <div>
      <div className="messages">
        {messages.map((m, i) => (
          <div key={i} className={`msg msg-${m.role}`}>
            {m.content}
          </div>
        ))}
        {isLoading && <div className="typing">...</div>}
      </div>

      <ChatInput
        onSubmit={text => sendMessage(text)}
        disabled={isLoading}
      />

      {isLoading && (
        <button onClick={stop}>Stop</button>
      )}

      {error && <div className="error">{error.message}</div>}
    </div>
  )
}

const {
  messages,     // full message history
  status,       // 'ready' | 'submitted' | 'streaming' | 'error'
  input,        // controlled input value
  setInput,     // set the input value
  sendMessage,  // send a message
  setMessages,  // replace the message array
  stop,         // abort the current stream
  isLoading,    // true while the agent is responding
  error,        // any error that occurred
  chatId,       // the current conversation id
  newChat,      // start a fresh conversation
} = useChat('my_agent_endpoint')

const { messages, sendMessage } = useChat('my_agent_endpoint', {
  id: 'conv-123',
})

messages.map((m, i) => (
  <div key={i}>
    {m.parts?.map((p, j) => {
      if (p.type === 'text') return <span key={j}>{p.text}</span>
      if (p.type === 'tool-call')
        return <ToolBadge key={j} name={p.toolName} args={p.args} />
      if (p.type === 'tool-result')
        return <ToolResult key={j} result={p.result} />
    })}
  </div>
))

const res = await fetch(`${DYPAI_URL}/api/v0/my_agent_endpoint`, {
  method: 'POST',
  headers: {
    'Content-Type': 'application/json',
    'Authorization': `Bearer ${jwt}`,
    'Accept': 'text/event-stream',
  },
  body: JSON.stringify({
    messages: [{ role: 'user', content: 'Hello' }],
    session_id: 'conv-123',
  }),
})

const reader = res.body.getReader()
const decoder = new TextDecoder()

while (true) {
  const { value, done } = await reader.read()
  if (done) break
  // Each chunk contains one or more SSE events.
  // See the Vercel AI SDK docs for the full protocol.
  console.log(decoder.decode(value))
}

const { data, error } = await dypai.api.post('my_agent_endpoint', {
  prompt: 'Summarize today\'s orders',
})

console.log(data.content)        // final text answer
console.log(data.usage)          // tokens used
console.log(data.steps)          // tool calls made