+
+
+
+
+
+ {/* 
+ {!collapsed ? 
: null} */}
+ {
+ !collapsed ? (
+
+ }
+
+
+ AI自动化渗透测试平台
+
+ ) : null
+ // setCollapsed((value) => !value)}>
+
+ {collapsed ?
+ 版本: 20240808-e01f03cb
+ )}
+ navigatePath && navigate(`/${navigatePath}`)}
>
-
-
-
-
-
- {/*
- {!collapsed ? (
-
- ) : null} */}
- {!collapsed ? (
-
- )}
-
-
- 自动化渗透系统
-
- ) : (
- setCollapsed((value) => !value)}
- >
-
+
- {collapsed ?
-
- 版本: 20240808-e01f03cb
-
- )}
- navigate(`/${item.path}`)}
- >
-
- ) : (
-
-
- );
- })}
- {/*
+ )
+ }
+
+ return (
+ {item.name}
-
-
+
+ )
+ })}
+ {/*
分布式调度yaklang引擎，执行分布式脚本，获得结果
*/}
-
+
+ {item.name}
+ {item.path === YakitRoute.AI_Agent &&
+
+
+
+ return (
+ = ({ children }) => {
- const { token } = useLoginStore((state) => state);
-
- // useEffect(() => {
- // if (!token) {
- // // dispatch(logOut(_pathname.slice(1)))
- // }
- // }, [token]);
-
- return token ? children :
-
- ),
- children: [
- {
- path: 'task',
- parentPath: '/',
- name: '任务中心',
- key: 'task',
- icon:
+
+ ),
+ // children: [
+ // {
+ // path: 'task',
+ // parentPath: '/',
+ // name: '任务中心',
+ // key: 'task',
+ // icon:
+
+ ),
+ },
+]
-export type { RouteObjectRootMy };
+export type { RouteObjectRootMy }
-export default routers;
+export default routers
diff --git a/src/App/store/loginStore.ts b/src/App/store/loginStore.ts
index ec8cda43..973ddb20 100644
--- a/src/App/store/loginStore.ts
+++ b/src/App/store/loginStore.ts
@@ -1,36 +1,36 @@
-import { postLogin } from '@/apis/login';
-import type { PostRequestAuth } from '@/apis/login/types';
-import { create } from 'zustand';
+import { postLogin } from '@/apis/login'
+import type { PostRequestAuth } from '@/apis/login/types'
+import { create } from 'zustand'
interface LoginStore {
- userInfo: Partial;
- token?: string;
- login: (param: any) => Promise;
- outLogin: () => Promise;
+ userInfo: Partial
+ token?: string
+ login: (param: any) => Promise
+ outLogin: () => Promise
}
const useLoginStore = create()((set) => ({
- userInfo: JSON?.parse(String(localStorage?.getItem('userInfo'))) || {},
- token: localStorage.getItem('token') || undefined,
- login: async (param) => {
- await postLogin(param).then((res) => {
- const { data } = res;
- const { token, user_info } = data;
- if (token) {
- localStorage.setItem('userInfo', JSON.stringify(user_info));
- localStorage.setItem('token', token);
- }
+ userInfo: JSON?.parse(String(localStorage?.getItem('userInfo'))) || {},
+ token: localStorage.getItem('token') || undefined,
+ login: async (param) => {
+ await postLogin(param).then((res) => {
+ const { data } = res
+ const { token, user_info } = data
+ if (token) {
+ localStorage.setItem('userInfo', JSON.stringify(user_info))
+ localStorage.setItem('token', token)
+ }
- set({
- userInfo: { ...user_info },
- token: token,
- });
- });
- },
- outLogin: async () => {
- localStorage.clear();
- set({ userInfo: {}, token: '' });
- },
-}));
+ set({
+ userInfo: { ...user_info },
+ token: token,
+ })
+ })
+ },
+ outLogin: async () => {
+ localStorage.clear()
+ set({ userInfo: {}, token: '' })
+ },
+}))
-export default useLoginStore;
+export default useLoginStore
diff --git a/src/apiUtils/type.d.ts b/src/apiUtils/type.d.ts
index c4aae41c..1fcf51ab 100644
--- a/src/apiUtils/type.d.ts
+++ b/src/apiUtils/type.d.ts
@@ -1,9 +1,6 @@
/** @name 必传参的异步方法 */
-export type APIFunc = (params: T, hiddenError?: boolean) => Promise;
+export type APIFunc = (params: T, hiddenError?: boolean) => Promise
/** @name 选传参的异步方法 */
-export type APIOptionalFunc = (
- params?: T,
- hiddenError?: boolean,
-) => Promise;
+export type APIOptionalFunc = (params?: T, hiddenError?: boolean) => Promise
/** @name 无参的异步方法 */
-export type APINoRequestFunc = (hiddenError?: boolean) => Promise;
+export type APINoRequestFunc = (hiddenError?: boolean) => Promise
diff --git a/src/apis/ActiChainApi/index.ts b/src/apis/ActiChainApi/index.ts
index 6d9fc72e..57f7692b 100644
--- a/src/apis/ActiChainApi/index.ts
+++ b/src/apis/ActiChainApi/index.ts
@@ -1,88 +1,68 @@
-import axios from '@/utils/axios';
-import type { ResponseData } from '@/utils/commonTypes';
+import axios from '@/utils/axios'
+import type { ResponseData } from '@/utils/commonTypes'
import type {
- TGetDnsQuryRequest,
- TgetTunnelServerRequest,
- TIcmpGenerateRequest,
- TReverseDnsGenerateRequest,
- TReverseDnsGenerateResponse,
- TReverseStartFacadesRequest,
- TTcpGenerateRequest,
-} from './type';
+ TGetDnsQuryRequest,
+ TgetTunnelServerRequest,
+ TIcmpGenerateRequest,
+ TReverseDnsGenerateRequest,
+ TReverseDnsGenerateResponse,
+ TReverseStartFacadesRequest,
+ TTcpGenerateRequest,
+} from './type'
// 获取内置 DNSLog 配置选项
-const getQuerySupportedDnsLogPlatforms = (): Promise<
- ResponseData<{ list: Array }>
-> =>
- axios.get }>>(
- '/reverse/QuerySupportedDnsLogPlatforms',
- );
+const getQuerySupportedDnsLogPlatforms = (): Promise }>> =>
+ axios.get }>>('/api/reverse/QuerySupportedDnsLogPlatforms')
// dns 获取配置
-const postReverseDnsGenerate = (
- data: TReverseDnsGenerateRequest,
-): Promise> =>
- axios.post>(
- '/reverse/dns/generate',
- data,
- );
+const postReverseDnsGenerate = (data: TReverseDnsGenerateRequest): Promise> =>
+ axios.post>('/api/reverse/dns/generate', data)
// 创建需要监听的域名
const getDnsQury = (data: TGetDnsQuryRequest): Promise> =>
- axios.post>(`/reverse/dns/query`, data);
+ axios.post>(`/api/reverse/dns/query`, data)
// 断开需要监听的域名
const postSseDelete = (data: { key: string }): Promise> =>
- axios.post>(`/sse/delete`, data);
+ axios.post>(`/api/sse/delete`, data)
// 生成 icmp 反链长度
const getIcmpGenerate = (): Promise> =>
- axios.get>(
- '/reverse/icmp/generate',
- );
+ axios.get>('/api/reverse/icmp/generate')
// 查询icmp结果，用sse返回
-const getIcmpQuery = (params: {
- length: number;
-}): Promise> =>
- axios.get>('/reverse/icmp/query', { params });
+const getIcmpQuery = (params: { length: number }): Promise> =>
+ axios.get>('/api/reverse/icmp/query', {
+ params,
+ })
// 生成 icmp 反链长度
const getTcpGenerate = (): Promise> =>
- axios.get>(
- '/reverse/tcp/generate',
- );
+ axios.get>('/api/reverse/tcp/generate')
// 查询icmp结果，用sse返回
-const getTcoQuery = (params: {
- token: string;
-}): Promise> =>
- axios.get>('/reverse/tcp/query', { params });
+const getTcoQuery = (params: { token: string }): Promise> =>
+ axios.get>('/api/reverse/tcp/query', {
+ params,
+ })
// 反连服务器 启动facedeServer
-const postReverseStartFacades = (
- data: TReverseStartFacadesRequest,
-): Promise> =>
- axios.post>('/reverse/start/facades', data);
+const postReverseStartFacades = (data: TReverseStartFacadesRequest): Promise> =>
+ axios.post>('/api/reverse/start/facades', data)
// 反连服务器 获取监听地址 /reverse/get-tunnel-server
-const getTunnelServer = (
- data: TgetTunnelServerRequest,
-): Promise> =>
- axios.post>(
- '/reverse/get_tunnel_server',
- data,
- );
+const getTunnelServer = (data: TgetTunnelServerRequest): Promise> =>
+ axios.post>('/api/reverse/get_tunnel_server', data)
export {
- postReverseDnsGenerate,
- getQuerySupportedDnsLogPlatforms,
- getDnsQury,
- postSseDelete,
- getIcmpGenerate,
- getIcmpQuery,
- getTcpGenerate,
- getTcoQuery,
- postReverseStartFacades,
- getTunnelServer,
-};
+ postReverseDnsGenerate,
+ getQuerySupportedDnsLogPlatforms,
+ getDnsQury,
+ postSseDelete,
+ getIcmpGenerate,
+ getIcmpQuery,
+ getTcpGenerate,
+ getTcoQuery,
+ postReverseStartFacades,
+ getTunnelServer,
+}
diff --git a/src/apis/AiEngineAdminApi/index.ts b/src/apis/AiEngineAdminApi/index.ts
new file mode 100644
index 00000000..766a89a8
--- /dev/null
+++ b/src/apis/AiEngineAdminApi/index.ts
@@ -0,0 +1,65 @@
+import axios from '@/utils/axios'
+import type { ResponseData } from '@/utils/commonTypes'
+import { syncAIEngineAuth } from '@/utils/aiEngineAuth'
+
+export interface AIEngineStatus {
+ base_url?: string
+ command?: string[]
+ gateway_url?: string
+ host?: string
+ jwt_secret?: string
+ last_error?: string
+ pid?: number
+ port?: number
+ route_prefix?: string
+ running: boolean
+ started_at?: number
+}
+
+type AIEngineStatusPayload = AIEngineStatus | ResponseData
+
+const AI_ENGINE_STATUS_CACHE_MS = 1000
+
+let cachedAIEngineStatus: AIEngineStatus | undefined
+let cachedAIEngineStatusAt = 0
+let pendingAIEngineStatusRequest: Promise | null = null
+
+const normalizeAIEngineStatus = (payload: AIEngineStatusPayload): AIEngineStatus => {
+ if (payload && typeof payload === 'object' && 'data' in payload && payload.data) {
+ return payload.data
+ }
+ return payload as AIEngineStatus
+}
+
+const requestAIEngineStatus = async (url: string, method: 'get' | 'post') => {
+ const payload = await axios.request({
+ url,
+ method,
+ skipBizCodeCheck: true,
+ })
+ const status = syncAIEngineAuth(normalizeAIEngineStatus(payload))
+ cachedAIEngineStatus = status
+ cachedAIEngineStatusAt = Date.now()
+
+ return status
+}
+
+const getAIEngineStatus = (): Promise => {
+ if (cachedAIEngineStatus && Date.now() - cachedAIEngineStatusAt < AI_ENGINE_STATUS_CACHE_MS) {
+ return Promise.resolve(cachedAIEngineStatus)
+ }
+
+ if (!pendingAIEngineStatusRequest) {
+ pendingAIEngineStatusRequest = requestAIEngineStatus('/api/admin/ai-engine/status', 'get').finally(() => {
+ pendingAIEngineStatusRequest = null
+ })
+ }
+
+ return pendingAIEngineStatusRequest
+}
+
+const postAIEngineStart = (): Promise => requestAIEngineStatus('/api/admin/ai-engine/start', 'post')
+
+const postAIEngineStop = (): Promise => requestAIEngineStatus('/api/admin/ai-engine/stop', 'post')
+
+export { getAIEngineStatus, postAIEngineStart, postAIEngineStop }
diff --git a/src/apis/AiEventApi/index.ts b/src/apis/AiEventApi/index.ts
new file mode 100644
index 00000000..53dad39d
--- /dev/null
+++ b/src/apis/AiEventApi/index.ts
@@ -0,0 +1,253 @@
+import axios from '@/utils/axios'
+import type { AIDelSessionParam, AIResponseData } from '@/utils/commonTypes'
+import type {
+ TPostCreateSessionRequest,
+ TPostCreateSessionResponse,
+ TPostSendFirstMessageResponse,
+ TGetSettingResponse,
+ TPostSettingRequest,
+ TPostCancelMessageResponse,
+ TPostSendContinueMessageResponse,
+ GetGlobalNetworkConfigResponse,
+ GlobalNetworkConfig,
+ ListAIProvidersResponse,
+ TPostSettingAimodelsGetRequest,
+ TPostSettingAimodelsGetResponse,
+ TPostSettingAifocusGetResponse,
+ GetSessionAllResponse,
+ TPostSessionTitle,
+} from './type'
+import type { AIInputEvent } from '@/pages/AIAgent/ai-re-act/hooks/grpcApi'
+import type {
+ AIConfigHealthCheckRequest,
+ AIConfigHealthCheckResponse,
+ AIGlobalConfig,
+ QueryAIProvidersRequest,
+ QueryAIProvidersResponse,
+} from '@/pages/AIAgent/ai-agent/aiModelList/utils'
+import type { GetThirdPartyAppConfigTemplateResponse } from '@/compoments/configNetwork/NewThirdPartyApplicationConfig'
+import type {
+ AIForge,
+ AIForgeFilter,
+ GetAIForgeRequest,
+ QueryAIForgeRequest,
+ QueryAIForgeResponse,
+} from '@/pages/AIAgent/ai-agent/type/forge'
+import type {
+ ExportAIForgeRequest,
+ ExportImportAIForgeProgress,
+ ImportAIForgeRequest,
+} from '@/pages/AIAgent/ai-agent/forgeName/type'
+import useLoginStore from '@/App/store/loginStore'
+import { getAIEngineAuthorizationHeader, isAIEnginePath, resolveAIEngineRequestURL } from '@/utils/aiEngineAuth'
+
+/** 通用 POST SSE 流式请求：发起 POST 后逐条解析 SSE data 帧并回调 */
+async function fetchSSEPost(
+ url: string,
+ data: TReq,
+ onProgress?: (progress: TProgress) => void,
+ signal?: AbortSignal,
+): Promise {
+ const store = useLoginStore.getState()
+ const headers: HeadersInit = {
+ 'Content-Type': 'application/json;charset=UTF-8',
+ Accept: 'text/event-stream',
+ }
+
+ if (isAIEnginePath(url)) {
+ const aiEngineAuthorization = await getAIEngineAuthorizationHeader()
+ if (aiEngineAuthorization) {
+ headers.Authorization = aiEngineAuthorization
+ }
+ } else if (store.token) {
+ headers.Authorization = store.token
+ }
+
+ const response = await fetch(resolveAIEngineRequestURL(url) || url, {
+ method: 'POST',
+ headers,
+ body: JSON.stringify(data),
+ credentials: 'include',
+ signal,
+ })
+
+ if (!response.ok) {
+ throw new Error(`请求失败(${response.status})`)
+ }
+
+ if (!response.body) return null
+
+ const reader = response.body.getReader()
+ const decoder = new TextDecoder('utf-8')
+ let buffer = ''
+
+ while (true) {
+ const { done, value } = await reader.read()
+ if (done) break
+
+ buffer += decoder.decode(value, { stream: true })
+ const frames = buffer.split(/\r?\n\r?\n/g)
+ buffer = frames.pop() || ''
+
+ for (const frame of frames) {
+ const dataLines = frame
+ .split(/\r?\n/g)
+ .filter((line) => line.startsWith('data:'))
+ .map((line) => line.slice(5).trim())
+
+ if (!dataLines.length) continue
+ const payload = dataLines.join('\n')
+ if (!payload || payload === '[DONE]') continue
+
+ try {
+ onProgress?.(JSON.parse(payload) as TProgress)
+ } catch {
+ // 忽略非 JSON 帧
+ }
+ }
+ }
+
+ return null
+}
+
+// #region 会话Session相关接口
+/** 创建会话通道, 并生成session（也可传 run_id 恢复已有会话） */
+const postCreateSession = (data?: TPostCreateSessionRequest): Promise =>
+ axios.post('/agent/session', data)
+
+/** 获取会话列表（内存运行态 + DB 元数据） */
+const getSessionAll = (): Promise =>
+ axios.get(`/agent/session/all`)
+
+/** 更新会话标题 */
+const postSessionTitle = (session: string, title: string): Promise> =>
+ axios.post>(`/agent/session/${session}/title`, { title })
+
+/** 删除会话 */
+const deleteSession = (data: AIDelSessionParam): Promise> =>
+ axios.post>(`/agent/session/del`, data)
+
+// #endregion
+
+// #region 会话流相关接口
+/** 首条输入内容 */
+const postSendFirstMessage = (
+ session: string,
+ data: AIInputEvent,
+): Promise> =>
+ axios.post>(`/agent/run/${session}`, data)
+
+/** 继续输入 */
+const postSendContinueMessage = (
+ session: string,
+ data: AIInputEvent,
+): Promise> =>
+ axios.post>(`/agent/run/${session}/events/push`, data)
+
+/** 主动取消 */
+const postCancelMessage = (session: string): Promise =>
+ axios.post(`/agent/run/${session}/cancel`, {})
+// #endregion
+
+// #region 配置相关接口
+/** 读取当前 AI Agent 聊天配置 */
+const getSetting = (): Promise => axios.get(`/agent/setting`)
+
+/** 获取全局网络配置 */
+const getSettingGlobal = (): Promise> =>
+ axios.get>(`/agent/setting/global`)
+// #endregion
+
+// 更新（Patch）配置
+const postSetting = (data: TPostSettingRequest): Promise> =>
+ axios.post>(`/agent/setting`, data)
+
+// 保存全局网络配置
+const postSettingGlobal = (data: GlobalNetworkConfig): Promise> =>
+ axios.post>(`/agent/setting/global`, data)
+
+// 获取 provider 列表
+const postSettingProvidersGet = (): Promise =>
+ axios.post(`/agent/setting/providers/get`, {})
+
+// 按 provider 配置拉取模型列表
+const postSettingAimodelsGet = (data: TPostSettingAimodelsGetRequest): Promise =>
+ axios.post(`/agent/setting/aimodels/get`, data)
+
+// 获取 focus mode 列表
+const postSettingAifocusGet = (data?: any): Promise> =>
+ axios.post>(`/agent/setting/aifocus/get`, data || {})
+
+// 获取 AI 全局配置
+const getSettingAiconfig = (): Promise => axios.get(`/agent/setting/aiconfig`)
+
+// 更新 AI 全局配置
+const postSettingAiconfig = (data: AIGlobalConfig): Promise =>
+ axios.post(`/agent/setting/aiconfig`, data)
+
+// 执行 AI 配置健康检查
+const postAIConfigHealthCheck = (data: AIConfigHealthCheckRequest): Promise =>
+ axios.post(`/agent/setting/aiconfig/healthcheck`, data)
+
+// 获取 AI 第三方应用配置模板
+const postSettingAppconfigsTemplateGet = (): Promise =>
+ axios.post(`/agent/setting/appconfigs/template/get`, {})
+
+// 分页查询 AI Provider
+const postSettingProvidersQuery = (data: QueryAIProvidersRequest): Promise =>
+ axios.post(`/agent/setting/providers/query`, data)
+
+// 分页查询 AI Forge
+export const postAiforgeQuery = (data: QueryAIForgeRequest): Promise =>
+ axios.post(`/agent/forge/query`, data)
+
+// 按名称或 ID 获取单个 AI Forge
+export const postAiforgeGet = (data: GetAIForgeRequest): Promise =>
+ axios.post(`/agent/forge/get`, data)
+
+// 删除 AI Forge
+export const postAiforgeDelete = (data: AIForgeFilter): Promise =>
+ axios.post(`/agent/forge/delete`, data)
+
+// 创建 AI Forge
+export const postAiforgeCreate = (data: AIForge): Promise<{ CreateID: number }> =>
+ axios.post(`/agent/forge/create`, data)
+
+// 更新 AI Forge
+export const postAiforgeUpdate = (data: AIForge): Promise =>
+ axios.post(`/agent/forge/update`, data)
+
+// 导出一个或多个 AI Forge（SSE 流）
+export const postAiforgeExport = (
+ data: ExportAIForgeRequest,
+ onProgress?: (progress: ExportImportAIForgeProgress) => void,
+ signal?: AbortSignal,
+): Promise => fetchSSEPost('/agent/forge/export', data, onProgress, signal)
+
+// 导入 AI Forge（SSE 流）
+export const postAiforgeImport = (
+ data: ImportAIForgeRequest,
+ onProgress?: (progress: ExportImportAIForgeProgress) => void,
+ signal?: AbortSignal,
+): Promise => fetchSSEPost('/agent/forge/import', data, onProgress, signal)
+export {
+ postCreateSession,
+ postSendFirstMessage,
+ postSendContinueMessage,
+ postCancelMessage,
+ getSetting,
+ postSetting,
+ getSettingGlobal,
+ postSettingGlobal,
+ postSettingProvidersGet,
+ postSettingAimodelsGet,
+ postSettingAifocusGet,
+ getSessionAll,
+ postSessionTitle,
+ deleteSession,
+ getSettingAiconfig,
+ postSettingAiconfig,
+ postSettingAppconfigsTemplateGet,
+ postSettingProvidersQuery,
+ postAIConfigHealthCheck,
+}
diff --git a/src/apis/AiEventApi/test.tsx b/src/apis/AiEventApi/test.tsx
new file mode 100644
index 00000000..1ab99632
--- /dev/null
+++ b/src/apis/AiEventApi/test.tsx
@@ -0,0 +1,194 @@
+import showErrorMessage from '@/utils/showErrorMessage'
+import { useMemoizedFn, useRequest } from 'ahooks'
+import React, { useEffect } from 'react'
+import { Badge, Button, Card, Descriptions, Space, Tag, Typography } from 'antd'
+import { postCreateSession } from './index'
+import useChatIPC from '@/pages/AIAgent/ai-re-act/hooks/useChatIPC'
+import type { AIInputEvent, AIStartParams } from '@/pages/AIAgent/ai-re-act/hooks/grpcApi'
+import { AIAgentLogChannelName } from '@/pages/AIAgent/defaultConstant'
+
+const TestAi: React.FC = () => {
+ // #region 创建session
+ const [session, setSession] = React.useState()
+ // 创建会话Session
+ const { runAsync: createSession } = useRequest(postCreateSession, {
+ manual: true,
+ onSuccess: (value) => {
+ console.log('createSession --- ', value)
+ setSession(value.run_id)
+ },
+ onError: (error) => {
+ console.log('createSession error --- ', error)
+ showErrorMessage(error)
+ },
+ })
+
+ const handleGenSession = useMemoizedFn(() => {
+ createSession({})
+ })
+ // #endregion
+
+ // #region 会话相关逻辑(开始、持续、结束)
+ const [chatIPCData, events] = useChatIPC({
+ channelName: AIAgentLogChannelName,
+ })
+
+ useEffect(() => {
+ events.onSwitchChat(session)
+ }, [session])
+
+ const handleStart = useMemoizedFn(() => {
+ if (!session) return
+
+ const request: AIStartParams = {
+ EnableSystemFileSystemOperator: true,
+ UseDefaultAIConfig: true,
+ ForgeName: '',
+ DisallowRequireForUserPrompt: true,
+ ReviewPolicy: 'yolo',
+ AIReviewRiskControlScore: 0.5,
+ DisableToolUse: false,
+ AICallAutoRetry: 3,
+ AITransactionRetry: 5,
+ EnableAISearchTool: true,
+ EnableAISearchInternet: false,
+ EnableQwenNoThinkMode: false,
+ AllowPlanUserInteract: true,
+ PlanUserInteractMaxCount: 3,
+ AIService: 'aibalance',
+ ReActMaxIteration: 100,
+ TimelineItemLimit: 100,
+ TimelineContentSizeLimit: 20480,
+ UserInteractLimit: 0,
+ TimelineSessionID: session,
+ AIModelName: 'VESA-free',
+ UserQuery: '你是谁\n\n',
+ CoordinatorId: '',
+ Sequence: 1,
+ }
+ const aiInputEvent: AIInputEvent = {
+ IsStart: true,
+ Params: { ...request },
+ }
+ events.onStart({ token: session, params: aiInputEvent })
+ })
+
+ const handleStop = useMemoizedFn(() => {
+ session && events.onClose(session)
+ })
+ // #endregion
+
+ const isRunning = chatIPCData.execute
+
+ // #region 打开/关闭日志独立页面
+ const logWindowRef = React.useRef(null)
+ const [isLogWindowOpen, setIsLogWindowOpen] = React.useState(false)
+
+ const closeLogWindow = useMemoizedFn(() => {
+ const w = logWindowRef.current
+ if (w && !w.closed) w.close()
+ logWindowRef.current = null
+ setIsLogWindowOpen(false)
+ })
+
+ const openLogWindow = useMemoizedFn(() => {
+ // HashRouter 下独立页面路径需要带上 `#/agent-log`
+ const base = import.meta.env.BASE_URL || '/'
+ const url = `${window.location.origin}${base}#/agent-log`
+
+ // 独立页面（新标签页/新窗口由浏览器决定）
+ const w = window.open(url, '_blank')
+ if (!w) {
+ showErrorMessage('打开日志页面失败，请检查浏览器是否拦截了弹窗')
+ return
+ }
+ logWindowRef.current = w
+ setIsLogWindowOpen(true)
+ w.focus?.()
+ })
+
+ const handleToggleLogWindow = useMemoizedFn(() => {
+ const w = logWindowRef.current
+ if (w && !w.closed) closeLogWindow()
+ else openLogWindow()
+ })
+
+ // 轮询检测：用户手动关闭日志页后，按钮状态自动恢复
+ useEffect(() => {
+ if (!isLogWindowOpen) return
+ const timer = window.setInterval(() => {
+ const w = logWindowRef.current
+ if (!w || w.closed) {
+ logWindowRef.current = null
+ setIsLogWindowOpen(false)
+ }
+ }, 500)
+ return () => window.clearInterval(timer)
+ }, [isLogWindowOpen])
+ // #endregion
+
+ return (
+ ;
+}
+
+interface TPostCreateSessionResponse {
+ run_id: string;
+ status: string;
+}
+
+interface TPostSendFirstMessageResponse {
+ run_id: string;
+ status: string;
+}
+
+interface TPostSendContinueMessageResponse {
+ status: string;
+}
+
+interface TGetSettingResponse extends AIAgentSetting {
+ UseDefaultAIConfig: boolean;
+ AIService: string;
+ AIModelName: string;
+ SelectedProviderID: number;
+ SelectedModelName: string;
+ SelectedModelTier: string;
+}
+
+interface TPostSettingRequest {
+ ai_service: string;
+ selected_provider_id: number;
+ selected_model_name: string;
+ review_policy: string;
+}
+
+interface TPostCancelMessageResponse {
+ run_id: string;
+ status: string;
+}
+
+type TenumBuffer = Buffer | Uint8Array;
+
+interface AuthInfo {
+ AuthUsername: string;
+ AuthPassword: string;
+ AuthType: string;
+ Host: string;
+ Forbidden: boolean;
+}
+
+interface ClientCertificates {
+ CrtPem: TenumBuffer;
+ KeyPem: TenumBuffer;
+ CaCertificates: TenumBuffer[];
+ Pkcs12Bytes: TenumBuffer;
+ Pkcs12Password: TenumBuffer;
+ Host?: string;
+}
+
+interface GlobalNetworkConfig {
+ DisableSystemDNS: boolean;
+ CustomDNSServers: string[];
+ DNSFallbackTCP: boolean;
+ DNSFallbackDoH: boolean;
+ CustomDoHServers: string[];
+
+ ClientCertificates?: ClientCertificates[];
+
+ DisallowIPAddress: string[];
+ DisallowDomain: string[];
+ GlobalProxy: string[];
+ EnableSystemProxyFromEnv: boolean;
+ SkipSaveHTTPFlow: boolean;
+
+ AppConfigs: ThirdPartyApplicationConfig[];
+
+ AiApiPriority: string[];
+
+ AuthInfos: AuthInfo[];
+
+ SynScanNetInterface: string;
+
+ ExcludePluginScanURIs: string[];
+ IncludePluginScanURIs: string[];
+
+ DbSaveSync: boolean;
+
+ CallPluginTimeout: number;
+
+ MinTlsVersion: number;
+ MaxTlsVersion: number;
+ MaxContentLength: number | string;
+}
+
+type GetGlobalNetworkConfigResponse = GlobalNetworkConfig;
+
+interface KVPair {
+ Key: string;
+ Value: string;
+ MarshalValue: string;
+}
+
+interface ThirdPartyApplicationConfig {
+ Type: string;
+ APIKey: string;
+ UserIdentifier: string;
+ UserSecret: string;
+ Namespace: string;
+ Domain: string;
+ WebhookURL: string;
+ ExtraParams: KVPair[];
+ Disabled: boolean;
+ Proxy: string;
+ NoHttps: boolean;
+}
+
+interface ListAIProvidersResponse {
+ Providers?: {
+ Id: number;
+ Config: ThirdPartyApplicationConfig;
+ }[];
+}
+
+interface TPostSettingAimodelsGetRequest {
+ // 请求体支持多种格式
+ Config: any;
+ // ```json
+ // { "Config": "openai" }
+ // ```
+
+ // 2) 传统 JSON 字符串：
+
+ // ```json
+ // { "Config": "{\"Type\":\"openai\",\"APIKey\":\"***\"}" }
+ // ```
+
+ // 3) 对象格式：
+
+ // ```json
+ // {
+ // "config": {
+ // "Type": "openai",
+ // "APIKey": "***",
+ // "Domain": "api.openai.com",
+ // "Proxy": "",
+ // "NoHttps": false
+ // }
+ // }
+ // ```
+}
+
+interface TPostSettingAimodelsGetResponse {
+ ModelName: string[];
+}
+
+interface TPostSettingAifocusGetResponse {
+ Name: string;
+ Description: string;
+ OutputExamplePrompt: string;
+ UsagePrompt: string;
+ VerboseName: string;
+ VerboseNameZh: string;
+}
+
+interface GetSessionAllResponse {
+ sessions: {
+ run_id: string;
+ title: string;
+ status: 'pending' | 'running' | 'completed' | 'cancelled' | 'failed';
+ created_at: string;
+ is_alive: boolean;
+ }[];
+}
+
+interface TPostSessionTitle {
+ run_id: string;
+ title: string;
+ status: string;
+}
+
+export type {
+ TPostCreateSessionRequest,
+ TPostCreateSessionResponse,
+ TPostSendFirstMessageResponse,
+ TPostSendContinueMessageResponse,
+ TGetSettingResponse,
+ TPostSettingRequest,
+ RunEvent,
+ TPostCancelMessageResponse,
+ GetGlobalNetworkConfigResponse,
+ GlobalNetworkConfig,
+ ListAIProvidersResponse,
+ TPostSettingAimodelsGetRequest,
+ TPostSettingAimodelsGetResponse,
+ TPostSettingAifocusGetResponse,
+ GetSessionAllResponse,
+ TPostSessionTitle,
+};
diff --git a/src/apis/CodecApi/index.ts b/src/apis/CodecApi/index.ts
index d8c96114..9e6a5ce6 100644
--- a/src/apis/CodecApi/index.ts
+++ b/src/apis/CodecApi/index.ts
@@ -1,22 +1,12 @@
-import axios from '@/utils/axios';
-import type { ResponseData, TableResponseData } from '@/utils/commonTypes';
-import type {
- TGetAllCodecMethodsResponse,
- TPostRunCodecResponse,
-} from './type';
+import axios from '@/utils/axios'
+import type { ResponseData, TableResponseData } from '@/utils/commonTypes'
+import type { TGetAllCodecMethodsResponse, TPostRunCodecResponse } from './type'
// 获取所有编码方式
-const getAllCodecMethods = (): Promise<
- ResponseData>
-> =>
- axios.get<
- never,
- ResponseData>
- >(`/codec/getAllCodecMethods`);
+const getAllCodecMethods = (): Promise>> =>
+ axios.get>>(`/api/codec/getAllCodecMethods`)
-const postRunCodec = (
- data: TPostRunCodecResponse,
-): Promise> =>
- axios.post>(`/run/codec`, data);
+const postRunCodec = (data: TPostRunCodecResponse): Promise> =>
+ axios.post>(`/api/run/codec`, data)
-export { getAllCodecMethods, postRunCodec };
+export { getAllCodecMethods, postRunCodec }
diff --git a/src/apis/CompileArtifactApi/index.ts b/src/apis/CompileArtifactApi/index.ts
index 0889eca5..2bacdd14 100644
--- a/src/apis/CompileArtifactApi/index.ts
+++ b/src/apis/CompileArtifactApi/index.ts
@@ -1,70 +1,50 @@
-import axios from '@/utils/axios';
-import type { ResponseData } from '@/utils/commonTypes';
+import axios from '@/utils/axios'
+import type { ResponseData } from '@/utils/commonTypes'
import type {
- TCompileArtifactSummary,
- TCompileArtifactListParams,
- TCompileArtifactListResponse,
- TCompileArtifactDetail,
- TCompileArtifactRebuildRequest,
- TCompileArtifactRebuildResponse,
-} from './type';
+ TCompileArtifactSummary,
+ TCompileArtifactListParams,
+ TCompileArtifactListResponse,
+ TCompileArtifactDetail,
+ TCompileArtifactRebuildRequest,
+ TCompileArtifactRebuildResponse,
+} from './type'
-const unwrapNestedResponse = (
- response: ResponseData,
-): ResponseData => {
- const nested = response?.data;
- if (
- nested &&
- typeof nested === 'object' &&
- 'code' in nested &&
- 'data' in nested
- ) {
- return {
- ...response,
- data: nested.data as T,
- };
+const unwrapNestedResponse = (response: ResponseData): ResponseData => {
+ const nested = response?.data
+ if (nested && typeof nested === 'object' && 'code' in nested && 'data' in nested) {
+ return {
+ ...response,
+ data: nested.data as T,
}
- return response as ResponseData;
-};
+ }
+ return response as ResponseData
+}
-const queryCompileArtifactSummary = (): Promise<
- ResponseData
-> =>
- axios.get>(
- '/ssa/compile-artifacts/summary',
- ).then((response) => unwrapNestedResponse(response));
+const queryCompileArtifactSummary = (): Promise> =>
+ axios
+ .get>('/api/ssa/compile-artifacts/summary')
+ .then((response) => unwrapNestedResponse(response))
const queryCompileArtifacts = (
- params?: TCompileArtifactListParams,
+ params?: TCompileArtifactListParams,
): Promise> =>
- axios.get>(
- '/ssa/compile-artifacts',
- { params },
- ).then((response) =>
- unwrapNestedResponse(response),
- );
+ axios
+ .get>('/api/ssa/compile-artifacts', { params })
+ .then((response) => unwrapNestedResponse(response))
-const fetchCompileArtifactDetail = (
- seriesKey: string,
-): Promise> =>
- axios.get>(
- '/ssa/compile-artifacts/detail',
- { params: { series_key: seriesKey } },
- ).then((response) => unwrapNestedResponse(response));
+const fetchCompileArtifactDetail = (seriesKey: string): Promise> =>
+ axios
+ .get<
+ never,
+ ResponseData
+ >('/api/ssa/compile-artifacts/detail', { params: { series_key: seriesKey } })
+ .then((response) => unwrapNestedResponse(response))
const forceRebuildCompileArtifact = (
- data: TCompileArtifactRebuildRequest,
+ data: TCompileArtifactRebuildRequest,
): Promise> =>
- axios.post>(
- '/ssa/compile-artifacts/rebuild',
- data,
- ).then((response) =>
- unwrapNestedResponse(response),
- );
+ axios
+ .post>('/api/ssa/compile-artifacts/rebuild', data)
+ .then((response) => unwrapNestedResponse(response))
-export {
- queryCompileArtifactSummary,
- queryCompileArtifacts,
- fetchCompileArtifactDetail,
- forceRebuildCompileArtifact,
-};
+export { queryCompileArtifactSummary, queryCompileArtifacts, fetchCompileArtifactDetail, forceRebuildCompileArtifact }
diff --git a/src/apis/CveLoopholeApi/index.ts b/src/apis/CveLoopholeApi/index.ts
index e8dd4eda..c23b0df9 100644
--- a/src/apis/CveLoopholeApi/index.ts
+++ b/src/apis/CveLoopholeApi/index.ts
@@ -1,28 +1,19 @@
-import axios from '@/utils/axios';
-import type { ResponseData, TableResponseData } from '@/utils/commonTypes';
-import type {
- TCveQueryRequest,
- TCveQueryResponse,
- TGetCveUpdateResquest,
-} from './type';
+import axios from '@/utils/axios'
+import type { ResponseData, TableResponseData } from '@/utils/commonTypes'
+import type { TCveQueryRequest, TCveQueryResponse, TGetCveUpdateResquest } from './type'
// 节点是否安装成功
-const postCveQuery = (
- data: TCveQueryRequest,
-): Promise>> =>
- axios.post>>(
- `/cve/query`,
- data,
- );
+const postCveQuery = (data: TCveQueryRequest): Promise>> =>
+ axios.post>>(`/api/cve/query`, data)
// cve 数据库更新
-const getCveUpdate = (
- params: TGetCveUpdateResquest,
- signal?: AbortSignal,
-): Promise> =>
- axios.get>(`/cve/update`, { params, signal });
+const getCveUpdate = (params: TGetCveUpdateResquest, signal?: AbortSignal): Promise> =>
+ axios.get>(`/api/cve/update`, {
+ params,
+ signal,
+ })
const getCveOfflineUpdate = (): Promise> =>
- axios.post>(`/reset/cve`);
+ axios.post>(`/api/reset/cve`)
-export { postCveQuery, getCveUpdate, getCveOfflineUpdate };
+export { postCveQuery, getCveUpdate, getCveOfflineUpdate }
diff --git a/src/apis/GlobalReverseLinkApi/index.ts b/src/apis/GlobalReverseLinkApi/index.ts
index ac003b0f..fe482187 100644
--- a/src/apis/GlobalReverseLinkApi/index.ts
+++ b/src/apis/GlobalReverseLinkApi/index.ts
@@ -1,16 +1,11 @@
-import axios from '@/utils/axios';
-import type { ResponseData } from '@/utils/commonTypes';
-import type {
- getReverseConfigResponse,
- PostReverseConfigRequest,
-} from './types';
+import axios from '@/utils/axios'
+import type { ResponseData } from '@/utils/commonTypes'
+import type { getReverseConfigResponse, PostReverseConfigRequest } from './types'
-const postReverseConfig = (
- data: PostReverseConfigRequest,
-): Promise> =>
- axios.post>('/reverse/config', data);
+const postReverseConfig = (data: PostReverseConfigRequest): Promise> =>
+ axios.post>('/api/reverse/config', data)
const getReverseConfig = (): Promise> =>
- axios.get>('/reverse/config');
+ axios.get>('/api/reverse/config')
-export { postReverseConfig, getReverseConfig };
+export { postReverseConfig, getReverseConfig }
diff --git a/src/apis/MessageCollectApi/index.ts b/src/apis/MessageCollectApi/index.ts
index aad37072..ab70496d 100644
--- a/src/apis/MessageCollectApi/index.ts
+++ b/src/apis/MessageCollectApi/index.ts
@@ -1,61 +1,36 @@
-import axios from '@/utils/axios';
-import type { ResponseData, TableResponseData } from '@/utils/commonTypes';
-import type {
- TGetCompanyInfoRequest,
- TGetCompanyInfoResponse,
- TGetDomainInfoResponse,
-} from './type';
-import type { TreeGraphData } from '@antv/g6';
+import axios from '@/utils/axios'
+import type { ResponseData, TableResponseData } from '@/utils/commonTypes'
+import type { TGetCompanyInfoRequest, TGetCompanyInfoResponse, TGetDomainInfoResponse } from './type'
+import type { TreeGraphData } from '@antv/g6'
// 获取信息收集列表数据
const getCompanyInfo = (
- data: Partial,
+ data: Partial,
): Promise>> =>
- axios.post<
- never,
- ResponseData>
- >('/assets/company-info', data);
+ axios.post>>('/api/assets/company-info', data)
// 删除信息收集 数据
-const deleteCompanyInfo = (params: {
- ids?: number[];
- all?: boolean;
-}): Promise> =>
- axios.delete>('/assets/company-info', {
- data: params,
- });
+const deleteCompanyInfo = (params: { ids?: number[]; all?: boolean }): Promise> =>
+ axios.delete>('/api/assets/company-info', {
+ data: params,
+ })
// 获取全部信息资产域名
const getAlldomains = (params: {
- keyword: string;
+ keyword: string
}): Promise>> =>
- axios.get>>(
- '/assets/company-info',
- { params },
- );
+ axios.get>>('/api/assets/company-info', { params })
// 获取子域名爆破列表数据
const getDomainInfo = (
- params: Omit,
+ params: Omit,
): Promise>> =>
- axios.get>>(
- '/assets/domain-info',
- { params },
- );
+ axios.get>>('/api/assets/domain-info', { params })
// 获取攻击路径图详情
-const getAttackPath = (params: {
- task_id: string;
- script_type: string;
-}): Promise> =>
- axios.get>('/assets/attack-path', {
- params,
- });
+const getAttackPath = (params: { task_id: string; script_type: string }): Promise> =>
+ axios.get>('/api/assets/attack-path', {
+ params,
+ })
-export {
- getCompanyInfo,
- deleteCompanyInfo,
- getAlldomains,
- getDomainInfo,
- getAttackPath,
-};
+export { getCompanyInfo, deleteCompanyInfo, getAlldomains, getDomainInfo, getAttackPath }
diff --git a/src/apis/NodeConfigApi/index.ts b/src/apis/NodeConfigApi/index.ts
index 5f73f82f..4736ce95 100644
--- a/src/apis/NodeConfigApi/index.ts
+++ b/src/apis/NodeConfigApi/index.ts
@@ -1,12 +1,8 @@
-import axios from '@/utils/axios';
-import type { ResponseData } from '@/utils/commonTypes';
+import axios from '@/utils/axios'
+import type { ResponseData } from '@/utils/commonTypes'
// 节点是否安装成功
-const getFileExists = (
- file_name: 'yak' | 'docker-compose',
-): Promise> =>
- axios.get>(
- `/file-exists?file_name=${file_name}`,
- );
+const getFileExists = (file_name: 'yak' | 'docker-compose'): Promise> =>
+ axios.get>(`/api/file-exists?file_name=${file_name}`)
-export { getFileExists };
+export { getFileExists }
diff --git a/src/apis/NodeManageApi/index.ts b/src/apis/NodeManageApi/index.ts
index 856c595c..e570db7a 100644
--- a/src/apis/NodeManageApi/index.ts
+++ b/src/apis/NodeManageApi/index.ts
@@ -1,62 +1,80 @@
-import axios from '@/utils/axios';
-import type { ResponseData, TableResponseData } from '@/utils/commonTypes';
+import axios from '@/utils/axios'
+import type { ResponseData, TableResponseData } from '@/utils/commonTypes'
import type {
- PostHostAliveDetectionRunRequest,
- QueryPalmNodeParams,
- TPostNodesDownloadDataRunRequest,
-} from './type';
-import type { Palm } from '@/gen/schema';
+ PostHostAliveDetectionRunRequest,
+ QueryPalmNodeParams,
+ ScannerObservabilityOverview,
+ TPostNodesDownloadDataRunRequest,
+} from './type'
+import type { Palm } from '@/gen/schema'
// 获取节点管理 表格数据
-const getNodeManage = (
- params: QueryPalmNodeParams,
-): Promise>> =>
- axios.get>>(`/node`, {
- params,
- });
+const getNodeManage = (params: QueryPalmNodeParams): Promise>> =>
+ axios.get>>(`/api/node`, {
+ params,
+ })
// 删除节点
const deleteNodeManage = (
- params: QueryPalmNodeParams & { node_ids?: string },
-): Promise>> =>
- axios.delete>>(`/node`, {
- params,
- });
+ params: QueryPalmNodeParams & { node_ids?: string },
+): Promise>> =>
+ axios.delete>>(`/api/node`, {
+ params,
+ })
// 编辑节点
const postUpdateLocation = (data: {
- location: string;
- nickname: string;
- node_id: string;
-}): Promise> =>
- axios.post>('/node/update-location', data);
+ location: string
+ nickname: string
+ node_id: string
+}): Promise> => axios.post>('/api/node/update-location', data)
// 更新节点数据
-const postNodesDownloadDataRun = (
- data: TPostNodesDownloadDataRunRequest,
-): Promise> =>
- axios.post>(
- '/task/start/nodes-download-data/run',
- data,
- );
+const postNodesDownloadDataRun = (data: TPostNodesDownloadDataRunRequest): Promise> =>
+ axios.post>('/api/task/start/nodes-download-data/run', data)
// 获取网络检测表格数据
const postHostAliveDetectionRun = (data: {
- dns_timeout: number;
- hosts: string;
- nodes_id: string[];
-}): Promise<
- ResponseData>
-> =>
- axios.post<
- never,
- ResponseData>
- >('/task/start/host-alive-detection/run', data);
+ dns_timeout: number
+ hosts: string
+ nodes_id: string[]
+}): Promise>> =>
+ axios.post>>(
+ '/api/task/start/host-alive-detection/run',
+ data,
+ )
+
+const getScannerObservabilityOverview = (params?: {
+ task_limit?: number
+}): Promise> =>
+ axios.get>('/api/ssa/observability/scanner/overview', {
+ params,
+ })
+
+const exportScannerObservabilityDiagnostics = (params?: {
+ task_limit?: number
+ log_limit?: number
+ node_id?: string
+ task_id?: string
+}): Promise> =>
+ axios.get('/api/ssa/observability/scanner/diagnostics/export', {
+ params,
+ responseType: 'blob',
+ transformResponse: [
+ (data) => ({
+ data,
+ code: 200,
+ msg: '',
+ }),
+ ],
+ })
export {
- getNodeManage,
- postUpdateLocation,
- postNodesDownloadDataRun,
- deleteNodeManage,
- postHostAliveDetectionRun,
-};
+ getNodeManage,
+ postUpdateLocation,
+ postNodesDownloadDataRun,
+ deleteNodeManage,
+ postHostAliveDetectionRun,
+ getScannerObservabilityOverview,
+ exportScannerObservabilityDiagnostics,
+}
diff --git a/src/apis/NodeManageApi/type.ts b/src/apis/NodeManageApi/type.ts
index 9b2d43cc..28f1882a 100644
--- a/src/apis/NodeManageApi/type.ts
+++ b/src/apis/NodeManageApi/type.ts
@@ -29,9 +29,87 @@ interface PostHostAliveDetectionRunRequest {
result: Array;
}
+interface ScannerObservabilityRunningTask {
+ node_id: string;
+ task_id: string;
+ root_task_id?: string;
+ sub_task_id?: string;
+ runtime_id?: string;
+ type: string;
+ status: string;
+ wait_ms: number;
+ start_timestamp: number;
+ running_timestamp: number;
+ ddl_timestamp: number;
+ elapsed_ms: number;
+}
+
+interface ScannerObservabilityNode {
+ node_id: string;
+ nickname: string;
+ location: string;
+ external_ip: string;
+ main_addr: string;
+ last_seen_at: number;
+ online: boolean;
+ cpu_percent: number;
+ memory_percent: number;
+ network_upload: number;
+ network_download: number;
+ active_count: number;
+ queue_count: number;
+ capacity: number;
+ recent_avg_wait_ms: number;
+ recent_avg_exec_ms: number;
+ recent_completed_count: number;
+ rpc_error?: string;
+ running_tasks: ScannerObservabilityRunningTask[];
+}
+
+interface ScannerObservabilityRecentTask {
+ task_id: string;
+ project_name: string;
+ scan_batch: number;
+ execute_node: string;
+ status: string;
+ phase: string;
+ progress: number;
+ language: string;
+ source_origin: string;
+ error_message?: string;
+ created_at: number;
+ started_at?: number;
+ finished_at?: number;
+}
+
+interface ScannerObservabilitySummary {
+ total_nodes: number;
+ online_nodes: number;
+ offline_nodes: number;
+ total_capacity: number;
+ total_active: number;
+ total_queued: number;
+ recent_avg_wait_ms: number;
+ recent_avg_exec_ms: number;
+ recent_completed_count: number;
+}
+
+interface ScannerObservabilityOverview {
+ generated_at: number;
+ summary: ScannerObservabilitySummary;
+ nodes: ScannerObservabilityNode[];
+ running_tasks: ScannerObservabilityRunningTask[];
+ recent_tasks: ScannerObservabilityRecentTask[];
+}
+
export type {
QueryPalmNodeParams,
TPostNodesDownloadDataRunRequest,
NetworkPingTableProp,
PostHostAliveDetectionRunRequest,
+ ScannerObservabilityRunningTask,
+ ScannerObservabilityNode,
+ ScannerObservabilityRecentTask,
+ ScannerObservabilitySummary,
+ ScannerObservabilityOverview,
};
diff --git a/src/apis/SSAIRApi/index.ts b/src/apis/SSAIRApi/index.ts
index d66a6a91..dd7d8fc4 100644
--- a/src/apis/SSAIRApi/index.ts
+++ b/src/apis/SSAIRApi/index.ts
@@ -1,42 +1,18 @@
-import axios from '@/utils/axios';
-import type { ResponseData } from '@/utils/commonTypes';
-import type { TSSATaskResponse } from '@/apis/SSAScanTaskApi/type';
-import type {
- TSSAIRCompileRequest,
- TSSAIRCompileResponse,
- TSSAIRHeadResponse,
- TSSAIRScanRequest,
-} from './type';
+import axios from '@/utils/axios'
+import type { ResponseData } from '@/utils/commonTypes'
+import type { TSSATaskResponse } from '@/apis/SSAScanTaskApi/type'
+import type { TSSAIRCompileRequest, TSSAIRCompileResponse, TSSAIRHeadResponse, TSSAIRScanRequest } from './type'
// POST /ssa/project/{id}/ir/compile - 编译 IR（写入 SSA-IR DB），返回 async_task_id
-const compileSSAIR = (
- projectId: number,
- data: TSSAIRCompileRequest,
-): Promise> =>
- axios.post>(
- `/ssa/project/${projectId}/ir/compile`,
- data,
- );
+const compileSSAIR = (projectId: number, data: TSSAIRCompileRequest): Promise> =>
+ axios.post>(`/api/ssa/project/${projectId}/ir/compile`, data)
// GET /ssa/project/{id}/ir/head - 查询 series HEAD
-const getSSAIRHead = (
- projectId: number,
- params?: { series_key?: string },
-): Promise> =>
- axios.get>(
- `/ssa/project/${projectId}/ir/head`,
- { params },
- );
+const getSSAIRHead = (projectId: number, params?: { series_key?: string }): Promise> =>
+ axios.get>(`/api/ssa/project/${projectId}/ir/head`, { params })
// POST /ssa/project/{id}/ir/scan - 从 SSA-IR DB 的 program/HEAD 发起扫描
-const scanSSAIR = (
- projectId: number,
- data?: TSSAIRScanRequest,
-): Promise> =>
- axios.post>(
- `/ssa/project/${projectId}/ir/scan`,
- data || {},
- );
-
-export { compileSSAIR, getSSAIRHead, scanSSAIR };
+const scanSSAIR = (projectId: number, data?: TSSAIRScanRequest): Promise> =>
+ axios.post>(`/api/ssa/project/${projectId}/ir/scan`, data || {})
+export { compileSSAIR, getSSAIRHead, scanSSAIR }
diff --git a/src/apis/SSAProjectApi/index.ts b/src/apis/SSAProjectApi/index.ts
index 37636129..37cdc50b 100644
--- a/src/apis/SSAProjectApi/index.ts
+++ b/src/apis/SSAProjectApi/index.ts
@@ -1,83 +1,61 @@
-import axios from '@/utils/axios';
-import type { ResponseData } from '@/utils/commonTypes';
-import type {
- TSSAProject,
- TSSAProjectListResponse,
- TSSAProjectRequest,
- TScanPolicyConfig,
-} from './type';
+import axios from '@/utils/axios'
+import type { ResponseData } from '@/utils/commonTypes'
+import type { TSSAProject, TSSAProjectListResponse, TSSAProjectRequest, TScanPolicyConfig } from './type'
// GET /ssa/project - 查询项目列表
const getSSAProjects = (
- params: {
- limit?: number;
- page?: number;
- order?: string;
- order_by?: string;
- project_name?: string;
- language?: string;
- tags?: string;
- },
- signal?: AbortSignal,
+ params: {
+ limit?: number
+ page?: number
+ order?: string
+ order_by?: string
+ project_name?: string
+ language?: string
+ tags?: string
+ },
+ signal?: AbortSignal,
): Promise> =>
- axios.get>(`/ssa/project`, {
- params,
- signal,
- });
+ axios.get>(`/api/ssa/project`, {
+ params,
+ signal,
+ })
// GET /ssa/project/fetch - 获取项目详情
-const fetchSSAProject = (
- params: { id: number },
- signal?: AbortSignal,
-): Promise> =>
- axios.get>(`/ssa/project/fetch`, {
- params,
- signal,
- });
+const fetchSSAProject = (params: { id: number }, signal?: AbortSignal): Promise> =>
+ axios.get>(`/api/ssa/project/fetch`, {
+ params,
+ signal,
+ })
// POST /ssa/project - 创建/更新项目
-const postSSAProject = (
- data: TSSAProjectRequest,
-): Promise> =>
- axios.post>(`/ssa/project`, data);
+const postSSAProject = (data: TSSAProjectRequest): Promise> =>
+ axios.post>(`/api/ssa/project`, data)
// DELETE /ssa/project - 删除项目
const deleteSSAProject = (params: {
- id: number;
-}): Promise> =>
- axios.delete>(`/ssa/project`, { params });
+ id: number
+ delete_mode?: 'config-only' | 'cascade'
+}): Promise> => axios.delete>(`/api/ssa/project`, { params })
// POST /ssa/project/test-connection - 测试Git连接
const testGitConnection = (data: {
- url: string;
- auth?: {
- kind?: 'none' | 'basic' | 'ssh';
- user_name?: string;
- password?: string;
- key_content?: string;
- };
- proxy?: {
- url?: string;
- };
+ url: string
+ auth?: {
+ kind?: 'none' | 'basic' | 'ssh'
+ user_name?: string
+ password?: string
+ key_content?: string
+ }
+ proxy?: {
+ url?: string
+ }
}): Promise> =>
- axios.post>(
- `/ssa/project/test-connection`,
- data,
- );
+ axios.post
+ setOpen(open)}
+ content={
+
+
+ )
+}
-export { UserCard };
+export { UserCard }
diff --git a/src/App/routers/AuthRoute.tsx b/src/App/routers/AuthRoute.tsx
index 65e8d259..82a4af1e 100644
--- a/src/App/routers/AuthRoute.tsx
+++ b/src/App/routers/AuthRoute.tsx
@@ -1,20 +1,13 @@
-import type { FC, ReactNode } from 'react';
-import useLoginStore from '../store/loginStore';
-import { NoLoginPermission } from '@/compoments';
+import type { FC, ReactNode } from 'react'
+import { Navigate } from 'react-router-dom'
+import useLoginStore from '../store/loginStore'
interface AuthRouteType {
- children: ReactNode;
+ children: ReactNode
}
const AuthRoute: FC
+ {/* 头像 */}
+
+
+ 
+ {!collapsed && (
setOpen(open)}
- content={
-
+
- {/* 头像 */}
-
-
-
- {!collapsed && (
-
+
-
- )}
-
- {userInfo.username ?? '未知用户'}
-
-
- {userInfo.roles?.join('') ?? '未获取到该权限'}
-
- {userInfo.username ?? '未知用户'}
+
+ {userInfo.roles?.join('') ?? '未获取到该权限'}
+
-
-
-
- }
- title={
-
-
- }
- trigger="click"
+ )}
+
+
+
+
+ }
+ title={
+
+
+ }
+ trigger="click"
+ >
+
+
- );
-};
+
+
+
+ AI Agent 调试面板
+
+ {isRunning ? '会话执行中' : '会话未运行'}
+
+ }
+ >
+
+
+
+ {session ? (
+
+ {session}
+
+ ) : (
+ 暂无会话，请先创建
+ )}
+
+
+
+
+
+
+
+
+
+
+ {isRunning ? (
+
+ ) : (
+
+ )}
+
+
+
+
+
+ 说明：该页面用于快速调试 AI Agent 的会话创建与启动流程， 上方展示当前会话 ID 与执行状态。
+
+
+
+
+ )
+}
+
+export { TestAi }
diff --git a/src/apis/AiEventApi/type.ts b/src/apis/AiEventApi/type.ts
new file mode 100644
index 00000000..db79c6e7
--- /dev/null
+++ b/src/apis/AiEventApi/type.ts
@@ -0,0 +1,251 @@
+import type { AIAgentSetting } from '@/pages/AIAgent/ai-agent/aiAgentType';
+
+interface AIParams {
+ forge_name?: string;
+ review_policy?: 'manual' | 'auto' | 'ai' | 'ai-auto';
+ ai_service?: string; // "openai|aibalance|..."
+ ai_model_name?: string;
+ max_iteration?: number;
+ react_max_iteration?: number;
+ disable_tool_use?: boolean;
+ use_default_ai?: boolean;
+ attached_files?: string[];
+ enable_system_file_system_operator?: boolean;
+ disallow_require_for_user_prompt?: boolean;
+ ai_review_risk_control_score?: number;
+ ai_call_auto_retry?: number;
+ ai_transaction_retry?: number;
+ enable_ai_search_tool?: boolean;
+ enable_ai_search_internet?: boolean;
+ enable_qwen_no_think_mode?: boolean;
+ allow_plan_user_interact?: boolean;
+ plan_user_interact_max_count?: number;
+ timeline_item_limit?: number;
+ timeline_content_size_limit?: number;
+ user_interact_limit?: number;
+ timeline_session_id?: string;
+}
+
+interface RunEvent {
+ id: string;
+ type:
+ | 'listener_ready'
+ | 'stream'
+ | 'structured'
+ | 'thought'
+ | 'done'
+ | 'error'
+ | 'heartbeat'
+ | string;
+ coordinator_id: string;
+ ai_model_name: string;
+ node_id: string;
+ is_system: boolean;
+ is_stream: boolean;
+ is_reason: boolean;
+ stream_delta: string;
+ content: string;
+ timestamp: number;
+ task_index: string;
+ event_uuid: string;
+ task_uuid: string;
+}
+
+interface TPostCreateSessionRequest {
+ run_id?: string;
+ params?: Partial