Class AiSdkClient

src/api/aiSdkClient.ts:39–169

 * key (env var or settings), never the MatterAI token.
 */
export class AiSdkClient implements LLMClient {
	constructor(private readonly options: AiSdkClientOptions) {}

	async *createMessage(
		systemPrompt: string,
		messages: OpenAI.Chat.ChatCompletionMessageParam[],
		tools: OpenAI.Chat.ChatCompletionTool[],
		abortSignal?: AbortSignal,
	): AsyncGenerator<ApiStreamChunk> {
		const model = this.options.model
		const isAnthropic = model.provider === "anthropic"

		// Replay stored thinking blocks only on Anthropic, where they round-trip
		// with their signatures; other providers ignore the side-channel.
		const aiMessages = toModelMessages(messages, isAnthropic)
		if (isAnthropic) applyCacheBreakpoint(aiMessages)

		const aiTools = toAiTools(tools)
		const hasTools = Object.keys(aiTools).length > 0

		const result = streamText({
			model: this.resolveModel(),
			system: this.buildSystem(systemPrompt, isAnthropic),
			messages: aiMessages,
			...(hasTools ? { tools: aiTools, toolChoice: "auto" as const } : {}),
			maxOutputTokens: model.maxOutputTokens,
			// No `temperature`: the current Claude models reject sampling params.
			abortSignal,
			providerOptions: this.providerOptions(isAnthropic),
		})

		for await (const part of result.fullStream) {
			switch (part.type) {
				case "text-delta":
					if (part.text) yield { type: "text", text: part.text }
					break
				case "reasoning-delta":
					if (part.text) yield { type: "reasoning", text: part.text }
					break
				case "tool-call":
					yield {
						type: "native_tool_calls",
						toolCalls: [
							{
								id: part.toolCallId,
								type: "function",
								function: {
									name: part.toolName,
									arguments: JSON.stringify(part.input ?? {}),
								},
							},
						],
					}
					break
				case "finish":
					yield this.usageChunk(part.totalUsage)
					break
				case "error":