mirror of
https://github.com/rowboatlabs/rowboat.git
synced 2026-04-28 18:06:30 +02:00
e1d50c62da
Add a stream error event type to the shared schema and wire runtime handling to convert provider payloads into a concise string format. When a stream error is seen, emit a Run error event, preserve partial output, and stop the turn to avoid additional tool execution. In the renderer, display errors inline as assistant messages with destructive styling and trigger a toast for immediate visibility. Include error events when loading run history so prior failures are visible.
69 lines
1.9 KiB
TypeScript
69 lines
1.9 KiB
TypeScript
import { z } from "zod";
|
|
import { ProviderOptions } from "./message.js";
|
|
|
|
const BaseEvent = z.object({
|
|
providerOptions: ProviderOptions.optional(),
|
|
})
|
|
|
|
export const LlmStepStreamReasoningStartEvent = BaseEvent.extend({
|
|
type: z.literal("reasoning-start"),
|
|
});
|
|
|
|
export const LlmStepStreamReasoningDeltaEvent = BaseEvent.extend({
|
|
type: z.literal("reasoning-delta"),
|
|
delta: z.string(),
|
|
});
|
|
|
|
export const LlmStepStreamReasoningEndEvent = BaseEvent.extend({
|
|
type: z.literal("reasoning-end"),
|
|
});
|
|
|
|
export const LlmStepStreamTextStartEvent = BaseEvent.extend({
|
|
type: z.literal("text-start"),
|
|
});
|
|
|
|
export const LlmStepStreamTextDeltaEvent = BaseEvent.extend({
|
|
type: z.literal("text-delta"),
|
|
delta: z.string(),
|
|
});
|
|
|
|
export const LlmStepStreamTextEndEvent = BaseEvent.extend({
|
|
type: z.literal("text-end"),
|
|
});
|
|
|
|
export const LlmStepStreamToolCallEvent = BaseEvent.extend({
|
|
type: z.literal("tool-call"),
|
|
toolCallId: z.string(),
|
|
toolName: z.string(),
|
|
input: z.any(),
|
|
});
|
|
|
|
export const LlmStepStreamFinishStepEvent = z.object({
|
|
type: z.literal("finish-step"),
|
|
finishReason: z.enum(["stop", "tool-calls", "length", "content-filter", "error", "other", "unknown"]),
|
|
usage: z.object({
|
|
inputTokens: z.number().optional(),
|
|
outputTokens: z.number().optional(),
|
|
totalTokens: z.number().optional(),
|
|
reasoningTokens: z.number().optional(),
|
|
cachedInputTokens: z.number().optional(),
|
|
}),
|
|
providerOptions: ProviderOptions.optional(),
|
|
});
|
|
|
|
export const LlmStepStreamErrorEvent = BaseEvent.extend({
|
|
type: z.literal("error"),
|
|
error: z.string(),
|
|
});
|
|
|
|
export const LlmStepStreamEvent = z.union([
|
|
LlmStepStreamReasoningStartEvent,
|
|
LlmStepStreamReasoningDeltaEvent,
|
|
LlmStepStreamReasoningEndEvent,
|
|
LlmStepStreamTextStartEvent,
|
|
LlmStepStreamTextDeltaEvent,
|
|
LlmStepStreamTextEndEvent,
|
|
LlmStepStreamToolCallEvent,
|
|
LlmStepStreamFinishStepEvent,
|
|
LlmStepStreamErrorEvent,
|
|
]);
|