chore: generate
This commit is contained in:
@@ -482,13 +482,21 @@ const onContentBlockDelta = Effect.fn("AnthropicMessages.onContentBlockDelta")(f
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (delta?.type === "thinking_delta" && delta.thinking) {
|
if (delta?.type === "thinking_delta" && delta.thinking) {
|
||||||
return [state, [LLMEvent.reasoningDelta({ id: `reasoning-${event.index ?? 0}`, text: delta.thinking })]] satisfies StepResult
|
return [
|
||||||
|
state,
|
||||||
|
[LLMEvent.reasoningDelta({ id: `reasoning-${event.index ?? 0}`, text: delta.thinking })],
|
||||||
|
] satisfies StepResult
|
||||||
}
|
}
|
||||||
|
|
||||||
if (delta?.type === "signature_delta" && delta.signature) {
|
if (delta?.type === "signature_delta" && delta.signature) {
|
||||||
return [
|
return [
|
||||||
state,
|
state,
|
||||||
[LLMEvent.reasoningEnd({ id: `reasoning-${event.index ?? 0}`, providerMetadata: anthropicMetadata({ signature: delta.signature }) })],
|
[
|
||||||
|
LLMEvent.reasoningEnd({
|
||||||
|
id: `reasoning-${event.index ?? 0}`,
|
||||||
|
providerMetadata: anthropicMetadata({ signature: delta.signature }),
|
||||||
|
}),
|
||||||
|
],
|
||||||
] satisfies StepResult
|
] satisfies StepResult
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -468,10 +468,7 @@ const step = (state: ParserState, event: BedrockEvent) =>
|
|||||||
if (event.validationException || event.throttlingException) {
|
if (event.validationException || event.throttlingException) {
|
||||||
const message =
|
const message =
|
||||||
event.validationException?.message ?? event.throttlingException?.message ?? "Bedrock Converse error"
|
event.validationException?.message ?? event.throttlingException?.message ?? "Bedrock Converse error"
|
||||||
return [
|
return [state, [LLMEvent.providerError({ message, retryable: event.throttlingException !== undefined })]] as const
|
||||||
state,
|
|
||||||
[LLMEvent.providerError({ message, retryable: event.throttlingException !== undefined })],
|
|
||||||
] as const
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return [state, []] as const
|
return [state, []] as const
|
||||||
|
|||||||
@@ -348,10 +348,7 @@ const step = (state: ParserState, event: OpenAIChatEvent) =>
|
|||||||
const finishEvents = (state: ParserState): ReadonlyArray<LLMEvent> => {
|
const finishEvents = (state: ParserState): ReadonlyArray<LLMEvent> => {
|
||||||
const hasToolCalls = state.toolCallEvents.length > 0
|
const hasToolCalls = state.toolCallEvents.length > 0
|
||||||
const reason = state.finishReason === "stop" && hasToolCalls ? "tool-calls" : state.finishReason
|
const reason = state.finishReason === "stop" && hasToolCalls ? "tool-calls" : state.finishReason
|
||||||
return [
|
return [...state.toolCallEvents, ...(reason ? [LLMEvent.requestFinish({ reason, usage: state.usage })] : [])]
|
||||||
...state.toolCallEvents,
|
|
||||||
...(reason ? [LLMEvent.requestFinish({ reason, usage: state.usage })] : []),
|
|
||||||
]
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// =============================================================================
|
// =============================================================================
|
||||||
|
|||||||
@@ -377,12 +377,7 @@ const TERMINAL_TYPES = new Set(["response.completed", "response.incomplete", "re
|
|||||||
|
|
||||||
const onOutputTextDelta = (state: ParserState, event: OpenAIResponsesEvent): StepResult => {
|
const onOutputTextDelta = (state: ParserState, event: OpenAIResponsesEvent): StepResult => {
|
||||||
if (!event.delta) return [state, NO_EVENTS]
|
if (!event.delta) return [state, NO_EVENTS]
|
||||||
return [
|
return [state, [LLMEvent.textDelta({ id: event.item_id ?? "text-0", text: event.delta })]]
|
||||||
state,
|
|
||||||
[
|
|
||||||
LLMEvent.textDelta({ id: event.item_id ?? "text-0", text: event.delta }),
|
|
||||||
],
|
|
||||||
]
|
|
||||||
}
|
}
|
||||||
|
|
||||||
const onOutputItemAdded = (state: ParserState, event: OpenAIResponsesEvent): StepResult => {
|
const onOutputItemAdded = (state: ParserState, event: OpenAIResponsesEvent): StepResult => {
|
||||||
|
|||||||
Reference in New Issue
Block a user