Feature/model

design/vue/src/api/admin.ts

@@ -1,11 +1,12 @@
 import { request } from './client'
-import type { ModelInfo } from '@/types/model'
+import type { ModelInfo, ModelTestResult } from '@/types/model'
 import type { ToolTypeInfo, ToolProviderInfo } from '@/types/tool'
 import type { AdminUser } from '@/types/auth'
-import type { AdminSession } from '@/types/chat'
+import type { AdminSession, MetricsSnapshot, TraceSummary, ChatTraceDetail } from '@/types/chat'
 
-// ── Admin Users ──
+// ── 用户管理 ──
 
+// 分页查询用户列表
 export function adminListUsers(params: {
   page: number
   pageSize: number
@@ -24,6 +25,7 @@ export function adminListUsers(params: {
   return request<{ list: AdminUser[]; total: number; page: number; pageSize: number; pages: number }>(`/admin/users?${query.toString()}`)
 }
 
+// 创建用户
 export function adminCreateUser(data: {
   username: string
   email: string
@@ -34,6 +36,7 @@ export function adminCreateUser(data: {
   return request<AdminUser>('/admin/users', { method: 'POST', body: data })
 }
 
+// 更新用户信息
 export function adminUpdateUser(id: string, data: Partial<{
   username: string
   email: string
@@ -43,29 +46,35 @@ export function adminUpdateUser(id: string, data: Partial<{
   return request<null>(`/admin/users/${id}`, { method: 'PUT', body: data })
 }
 
+// 删除用户
 export function adminDeleteUser(id: string) {
   return request<null>(`/admin/users/${id}`, { method: 'DELETE' })
 }
 
+// 重置用户密码
 export function adminResetUserPassword(id: string, data: { password: string }) {
   return request<null>(`/admin/users/${id}/reset-password`, { method: 'POST', body: data })
 }
 
-// ── Admin Models ──
+// ── 模型管理 ──
 
+// 获取模型列表
 export function adminListModels() {
   return request<{ models: ModelInfo[] }>('/models')
 }
 
+// 创建模型配置
 export function adminCreateModel(data: {
   provider: string
   model_id: string
   base_url: string
   api_key: string
+  max_context_length: number
 }) {
   return request<ModelInfo>('/models', { method: 'POST', body: data })
 }
 
+// 更新模型配置
 export function adminUpdateModel(
   id: string,
   data: Partial<{
@@ -74,37 +83,36 @@ export function adminUpdateModel(
     base_url: string
     api_key: string
     is_enabled: boolean
+    max_context_length: number
   }>,
 ) {
   return request<ModelInfo>(`/models/${id}`, { method: 'PUT', body: data })
 }
 
+// 删除模型
 export function adminDeleteModel(id: string) {
   return request<null>(`/models/${id}`, { method: 'DELETE' })
 }
 
+// 测试模型连通性
 export function adminTestModel(data: {
   provider: string
   model_id: string
   base_url: string
   api_key: string
   config?: Record<string, unknown>
 }) {
-  return request<{
-    success: boolean
-    message: string
-    error?: string
-    response_time_ms: number
-    details?: string
-  }>('/models/test', { method: 'POST', body: data })
+  return request<ModelTestResult>('/models/test', { method: 'POST', body: data })
 }
 
-// ── Admin Tools ──
+// ── 工具管理 ──
 
+// 获取工具类型列表
 export function adminListToolTypes() {
   return request<{ tool_types: ToolTypeInfo[] }>('/admin/tool-types')
 }
 
+// 创建工具类型
 export function adminCreateToolType(data: {
   name: string
   tool_key: string
@@ -114,6 +122,7 @@ export function adminCreateToolType(data: {
   return request<ToolTypeInfo>('/admin/tool-types', { method: 'POST', body: data })
 }
 
+// 更新工具类型
 export function adminUpdateToolType(
   id: string,
   data: Partial<{
@@ -127,14 +136,17 @@ export function adminUpdateToolType(
   return request<ToolTypeInfo>(`/admin/tool-types/${id}`, { method: 'PUT', body: data })
 }
 
+// 删除工具类型
 export function adminDeleteToolType(id: string) {
   return request<null>(`/admin/tool-types/${id}`, { method: 'DELETE' })
 }
 
+// 获取指定工具类型下的供应商列表
 export function adminListToolProviders(toolTypeId: string) {
   return request<{ providers: ToolProviderInfo[] }>(`/admin/tool-types/${toolTypeId}/providers`)
 }
 
+// 创建工具供应商
 export function adminCreateToolProvider(
   toolTypeId: string,
   data: {
@@ -154,6 +166,7 @@ export function adminCreateToolProvider(
   })
 }
 
+// 更新工具供应商
 export function adminUpdateToolProvider(
   toolTypeId: string,
   providerId: string,
@@ -175,12 +188,14 @@ export function adminUpdateToolProvider(
   })
 }
 
+// 删除工具供应商
 export function adminDeleteToolProvider(toolTypeId: string, providerId: string) {
   return request<null>(`/admin/tool-types/${toolTypeId}/providers/${providerId}`, {
     method: 'DELETE',
   })
 }
 
+// 测试工具连通性
 export function adminTestTool(data: {
   provider_type: string
   provider_config?: Record<string, unknown>
@@ -197,8 +212,9 @@ export function adminTestTool(data: {
   }>('/admin/tools/test', { method: 'POST', body: data })
 }
 
-// ── Admin Sessions ──
+// ── 会话管理 ──
 
+// 分页查询会话列表
 export function adminListSessions(params: {
   page: number
   pageSize: number
@@ -213,10 +229,41 @@ export function adminListSessions(params: {
   return request<{ list: AdminSession[]; total: number; page: number; pageSize: number; pages: number }>(`/admin/sessions?${query.toString()}`)
 }
 
+// 删除会话
 export function adminDeleteSession(id: string) {
   return request<null>(`/admin/sessions/${id}`, { method: 'DELETE' })
 }
 
+// 清理过期会话
 export function adminCleanupSessions() {
   return request<{ deleted: number }>('/admin/sessions/cleanup', { method: 'POST' })
 }
+
+// ── 可观测性（后台） ──
+
+// 获取可观测性指标快照
+export function adminGetObservabilityMetrics() {
+  return request<MetricsSnapshot>('/admin/observability/metrics')
+}
+
+// 分页查询 Trace 列表
+export function adminListTraces(params: {
+  page?: number
+  pageSize?: number
+  session_id?: string
+  status?: string
+  rating?: number
+}) {
+  const query = new URLSearchParams()
+  if (params.page !== undefined) query.set('page', String(params.page))
+  if (params.pageSize !== undefined) query.set('pageSize', String(params.pageSize))
+  if (params.session_id) query.set('session_id', params.session_id)
+  if (params.status) query.set('status', params.status)
+  if (params.rating !== undefined) query.set('rating', String(params.rating))
+  return request<{ traces: TraceSummary[]; total: number }>(`/admin/observability/traces?${query.toString()}`)
+}
+
+// 获取 Trace 详情
+export function adminGetTrace(traceId: string) {
+  return request<ChatTraceDetail>(`/admin/observability/traces/${traceId}`)
+}

design/vue/src/api/chat.ts

@@ -1,11 +1,15 @@
-import { request, streamRequest } from './client'
+import { request, streamRequest, StreamReaderWithMeta } from './client'
 import type {
   ChatSession,
   CreateSessionRequest,
   UpdateSessionRequest,
   SendMessageRequest,
   ListSessionsResponse,
   ListMessagesResponse,
+  FeedbackRequest,
+  FeedbackInfo,
+  TraceSummary,
+  ChatTraceDetail,
 } from '@/types/chat'
 
 // ── Sessions ──
@@ -40,6 +44,33 @@ export function getMessages(sessionId: string) {
 }
 
 /** Send message via SSE streaming. Returns a ReadableStream reader. */
-export function sendMessage(sessionId: string, data: SendMessageRequest, signal?: AbortSignal) {
+export function sendMessage(sessionId: string, data: SendMessageRequest, signal?: AbortSignal): Promise<StreamReaderWithMeta> {
   return streamRequest(`/chat/sessions/${sessionId}/messages`, data, signal)
 }
+
+// ── Feedback ──
+
+export function submitFeedback(messageId: string, data: FeedbackRequest) {
+  return request<null>(`/chat/messages/${messageId}/feedback`, { method: 'POST', body: data })
+}
+
+export function listFeedbacks(params?: { page?: number; pageSize?: number; rating?: number }) {
+  const query = new URLSearchParams()
+  if (params?.page !== undefined) query.set('page', String(params.page))
+  if (params?.pageSize !== undefined) query.set('pageSize', String(params.pageSize))
+  if (params?.rating !== undefined) query.set('rating', String(params.rating))
+  return request<{ feedbacks: FeedbackInfo[]; total: number }>(`/chat/feedbacks?${query.toString()}`)
+}
+
+// ── Traces ──
+
+export function getTrace(traceId: string) {
+  return request<ChatTraceDetail>(`/chat/traces/${traceId}`)
+}
+
+export function listSessionTraces(sessionId: string, params?: { page?: number; pageSize?: number }) {
+  const query = new URLSearchParams()
+  if (params?.page !== undefined) query.set('page', String(params.page))
+  if (params?.pageSize !== undefined) query.set('pageSize', String(params.pageSize))
+  return request<{ traces: TraceSummary[]; total: number }>(`/chat/sessions/${sessionId}/traces?${query.toString()}`)
+}

design/vue/src/api/client.ts

@@ -73,7 +73,10 @@ export async function request<T>(
     throw new Error(text || `HTTP ${res.status}`)
   }
 
-  const data = await res.json()
+  const traceId = res.headers.get('X-Trace-ID') || undefined
+  const requestId = res.headers.get('X-Request-ID') || undefined
+
+  const data = (await res.json()) as ApiResponse<T>
   // Server-side token invalid / auth error
   if (data.code === 401 || data.code === 403) {
     removeToken()
@@ -84,6 +87,9 @@ export async function request<T>(
   if (data.code !== 0) {
     throw new Error(data.message || '请求失败')
   }
+  if (traceId || requestId) {
+    data._meta = { trace_id: traceId, request_id: requestId }
+  }
   return data
 }
 
@@ -120,7 +126,10 @@ export async function formRequest<T>(
     throw new Error(text || `HTTP ${res.status}`)
   }
 
-  const data = await res.json()
+  const traceId = res.headers.get('X-Trace-ID') || undefined
+  const requestId = res.headers.get('X-Request-ID') || undefined
+
+  const data = (await res.json()) as ApiResponse<T>
   if (data.code === 401 || data.code === 403) {
     removeToken()
     routerInstance?.push('/login')
@@ -129,6 +138,9 @@ export async function formRequest<T>(
   if (data.code !== 0) {
     throw new Error(data.message || '请求失败')
   }
+  if (traceId || requestId) {
+    data._meta = { trace_id: traceId, request_id: requestId }
+  }
   return data
 }
 
@@ -151,12 +163,16 @@ export async function blobRequest(path: string): Promise<Blob> {
   return res.blob()
 }
 
+export type StreamReaderWithMeta = ReadableStreamDefaultReader<Uint8Array> & {
+  _meta?: { trace_id?: string; request_id?: string }
+}
+
 /** SSE stream request — returns a ReadableStream reader */
 export async function streamRequest(
   path: string,
   body: unknown,
   signal?: AbortSignal,
-): Promise<ReadableStreamDefaultReader<Uint8Array>> {
+): Promise<StreamReaderWithMeta> {
   const headers: Record<string, string> = {
     'Content-Type': 'application/json',
   }
@@ -183,5 +199,11 @@ export async function streamRequest(
     throw new Error(text || `HTTP ${res.status}`)
   }
 
-  return res.body!.getReader()
+  const reader = res.body!.getReader() as StreamReaderWithMeta
+  const traceId = res.headers.get('X-Trace-ID') || undefined
+  const requestId = res.headers.get('X-Request-ID') || undefined
+  if (traceId || requestId) {
+    reader._meta = { trace_id: traceId, request_id: requestId }
+  }
+  return reader
 }