Function createChatStream

examples/ts-react-native-chat/src/server/app.ts:353–376

(
  body: unknown,
)

]

async function createChatStream(
  body: unknown,
): Promise<AsyncIterable<StreamChunk>> {
  const params = await chatParamsFromRequestBody(body)
  const recipePrompt = createRecipePrompt(params.messages)
  requireOpenAIApiKey()
  const model = getOpenAIModel()
  const tools = mergeAgentTools(serverTools, params.tools)
  const modelOptions = getOpenAIModelOptions(model)

  return chat({
    adapter: openaiText(model),
    tools,
    messages: recipePrompt.messages,
    systemPrompts: recipePrompt.systemPrompts,
    threadId: params.threadId,
    runId: params.runId,
    parentRunId: params.parentRunId,
    agentLoopStrategy: maxIterations(6),
    outputSchema: recipeOutputSchema,
    stream: true,
    ...(modelOptions ? { modelOptions: modelOptions as never } : {}),
  }) as AsyncIterable<StreamChunk>
}

function getErrorMessage(error: unknown): string {
  return error instanceof Error ? error.message : 'Bad request'