+
-
-
思考过程
+
+
+
{{ reasoningLoading ? '思考中' : '思考过程' }}
+
{{ formatDuration(reasoningDuration) }}
-
+
+
+ ▋
+
-
+
@@ -37,11 +42,15 @@ const props = withDefaults(
content?: string
reasoning?: string
loading?: boolean
+ reasoningLoading?: boolean
+ reasoningDuration?: number
}>(),
{
content: '',
reasoning: '',
loading: false,
+ reasoningLoading: false,
+ reasoningDuration: 0,
},
)
@@ -50,6 +59,11 @@ defineOptions({ name: 'BoChatBubble' })
const reasoningExpanded = ref(true)
+function formatDuration(ms: number): string {
+ if (ms < 1000) return `${ms}ms`
+ return `${(ms / 1000).toFixed(1)}s`
+}
+
function renderSimpleMarkdown(text: string): string {
if (!text) return ''
return text
diff --git a/packages/bolt-ui/theme-chalk/src/chat-bubble.scss b/packages/bolt-ui/theme-chalk/src/chat-bubble.scss
index 70cea8d..18cca7d 100644
--- a/packages/bolt-ui/theme-chalk/src/chat-bubble.scss
+++ b/packages/bolt-ui/theme-chalk/src/chat-bubble.scss
@@ -75,6 +75,16 @@
&:hover {
background: var(--color-hairline);
}
+
+ .reasoning-spin {
+ animation: bo-chat-bubble-spin 0.8s linear infinite;
+ }
+ }
+
+ #{e('reasoning-duration')} {
+ font-size: 11px;
+ color: var(--color-muted-soft, #8e8b82);
+ font-weight: 400;
}
#{e('reasoning-arrow')} {
@@ -105,6 +115,13 @@
}
}
+ #{e('reasoning-cursor')} {
+ display: inline-block;
+ animation: bo-chat-bubble-blink 1s step-end infinite;
+ color: var(--color-muted);
+ font-weight: 600;
+ }
+
#{e('typing')} {
display: flex;
gap: 4px;
@@ -215,3 +232,14 @@
transform: scale(1);
}
}
+
+@keyframes bo-chat-bubble-spin {
+ to {
+ transform: rotate(360deg);
+ }
+}
+
+@keyframes bo-chat-bubble-blink {
+ 0%, 50% { opacity: 1; }
+ 51%, 100% { opacity: 0; }
+}
diff --git a/packages/drizzle-pkg/db.sqlite b/packages/drizzle-pkg/db.sqlite
index 832dfa3..4d57811 100644
Binary files a/packages/drizzle-pkg/db.sqlite and b/packages/drizzle-pkg/db.sqlite differ
diff --git a/server/api/llm/chat/index.post.ts b/server/api/llm/chat/index.post.ts
index 092f9c4..e085988 100644
--- a/server/api/llm/chat/index.post.ts
+++ b/server/api/llm/chat/index.post.ts
@@ -1,11 +1,38 @@
import { requireUser } from "#server/utils/context";
import { getProviderById, getModelById } from "#server/service/llm";
-import { createOpenAI } from "@ai-sdk/openai";
-import { streamText } from "ai";
+import { createOpenAICompatible } from "@ai-sdk/openai-compatible";
+import { streamText, type LanguageModelV1 } from "ai";
import log4js from "logger";
const logger = log4js.getLogger("APP");
+function resolveModel(
+ provider: {
+ name: string;
+ apiKey: string | null;
+ baseUrl: string | null;
+ parseMode: string;
+ },
+ modelId: string,
+): LanguageModelV1 {
+ const baseUrl = provider.baseUrl?.replace(/\/+$/, "") || undefined;
+
+ if (provider.parseMode === "anthropic") {
+ throw createError({
+ statusCode: 400,
+ statusMessage: "Anthropic 解析模式暂不支持流式对话，请使用 OpenAI 兼容模式",
+ });
+ }
+
+ const openaiCompatible = createOpenAICompatible({
+ name: provider.name,
+ apiKey: provider.apiKey || undefined,
+ baseURL: baseUrl || "https://api.openai.com/v1",
+ });
+
+ return openaiCompatible(modelId) as LanguageModelV1;
+}
+
export default defineEventHandler(async (event) => {
const user = await requireUser(event);
if (!user) {
@@ -41,28 +68,30 @@ export default defineEventHandler(async (event) => {
throw createError({ statusCode: 400, statusMessage: "供应商未配置 API Key" });
}
- const baseUrl = provider.baseUrl?.replace(/\/+$/, "") || undefined;
-
logger.info(
- "[%s] [LLM-CHAT] userId=%d modelId=%d provider=%s messages=%d thinking=%s",
+ "[%s] [LLM-CHAT] userId=%d modelId=%d provider=%s parseMode=%s messages=%d thinking=%s",
event.context.requestId ?? "-",
user.id,
llmModelId,
provider.name,
+ provider.parseMode,
messages.length,
enableThinking ? "on" : "off",
);
- const openai = createOpenAI({
- apiKey: provider.apiKey,
- baseURL: baseUrl,
- });
+ const languageModel = resolveModel(provider, model.modelId);
const result = streamText({
- model: openai(model.modelId),
+ model: languageModel,
messages,
maxTokens: model.maxTokens || undefined,
- ...(enableThinking ? { providerOptions: { openai: { reasoningEffort: 'high' } } } : {}),
+ ...(enableThinking
+ ? {
+ providerOptions: {
+ openaiCompatible: { reasoningEffort: "high" },
+ },
+ }
+ : {}),
});
return result.toDataStreamResponse({ sendReasoning: true });