2024-04-08 18:51:46 +08:00
|
|
|
import {
|
|
|
|
useCallback,
|
|
|
|
useMemo,
|
|
|
|
} from 'react'
|
|
|
|
import { useTranslation } from 'react-i18next'
|
|
|
|
import { useStoreApi } from 'reactflow'
|
|
|
|
import type {
|
|
|
|
Edge,
|
|
|
|
Node,
|
|
|
|
} from '../types'
|
|
|
|
import { BlockEnum } from '../types'
|
|
|
|
import { useStore } from '../store'
|
|
|
|
import {
|
|
|
|
getToolCheckParams,
|
|
|
|
getValidTreeNodes,
|
|
|
|
} from '../utils'
|
2024-06-14 17:08:11 +08:00
|
|
|
import {
|
|
|
|
CUSTOM_NODE,
|
2024-08-05 18:41:08 +08:00
|
|
|
MAX_TREE_DEPTH,
|
2024-06-14 17:08:11 +08:00
|
|
|
} from '../constants'
|
2024-04-08 18:51:46 +08:00
|
|
|
import type { ToolNodeType } from '../nodes/tool/types'
|
|
|
|
import { useIsChatMode } from './use-workflow'
|
|
|
|
import { useNodesExtraData } from './use-nodes-data'
|
|
|
|
import { useToastContext } from '@/app/components/base/toast'
|
|
|
|
import { CollectionType } from '@/app/components/tools/types'
|
|
|
|
import { useGetLanguage } from '@/context/i18n'
|
|
|
|
|
|
|
|
export const useChecklist = (nodes: Node[], edges: Edge[]) => {
|
|
|
|
const { t } = useTranslation()
|
|
|
|
const language = useGetLanguage()
|
|
|
|
const nodesExtraData = useNodesExtraData()
|
|
|
|
const isChatMode = useIsChatMode()
|
|
|
|
const buildInTools = useStore(s => s.buildInTools)
|
|
|
|
const customTools = useStore(s => s.customTools)
|
2024-05-27 21:57:08 +08:00
|
|
|
const workflowTools = useStore(s => s.workflowTools)
|
2024-04-08 18:51:46 +08:00
|
|
|
|
|
|
|
const needWarningNodes = useMemo(() => {
|
|
|
|
const list = []
|
2024-06-14 17:08:11 +08:00
|
|
|
const { validNodes } = getValidTreeNodes(nodes.filter(node => node.type === CUSTOM_NODE), edges)
|
2024-04-08 18:51:46 +08:00
|
|
|
|
|
|
|
for (let i = 0; i < nodes.length; i++) {
|
|
|
|
const node = nodes[i]
|
|
|
|
let toolIcon
|
|
|
|
let moreDataForCheckValid
|
|
|
|
|
|
|
|
if (node.data.type === BlockEnum.Tool) {
|
|
|
|
const { provider_type } = node.data
|
|
|
|
|
2024-05-27 21:57:08 +08:00
|
|
|
moreDataForCheckValid = getToolCheckParams(node.data as ToolNodeType, buildInTools, customTools, workflowTools, language)
|
|
|
|
if (provider_type === CollectionType.builtIn)
|
2024-04-08 18:51:46 +08:00
|
|
|
toolIcon = buildInTools.find(tool => tool.id === node.data.provider_id)?.icon
|
|
|
|
|
2024-05-27 21:57:08 +08:00
|
|
|
if (provider_type === CollectionType.custom)
|
2024-04-08 18:51:46 +08:00
|
|
|
toolIcon = customTools.find(tool => tool.id === node.data.provider_id)?.icon
|
2024-05-27 21:57:08 +08:00
|
|
|
|
|
|
|
if (provider_type === CollectionType.workflow)
|
|
|
|
toolIcon = workflowTools.find(tool => tool.id === node.data.provider_id)?.icon
|
2024-04-08 18:51:46 +08:00
|
|
|
}
|
2024-06-14 17:08:11 +08:00
|
|
|
|
|
|
|
if (node.type === CUSTOM_NODE) {
|
|
|
|
const { errorMessage } = nodesExtraData[node.data.type].checkValid(node.data, t, moreDataForCheckValid)
|
|
|
|
|
|
|
|
if (errorMessage || !validNodes.find(n => n.id === node.id)) {
|
|
|
|
list.push({
|
|
|
|
id: node.id,
|
|
|
|
type: node.data.type,
|
|
|
|
title: node.data.title,
|
|
|
|
toolIcon,
|
|
|
|
unConnected: !validNodes.find(n => n.id === node.id),
|
|
|
|
errorMessage,
|
|
|
|
})
|
|
|
|
}
|
2024-04-08 18:51:46 +08:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (isChatMode && !nodes.find(node => node.data.type === BlockEnum.Answer)) {
|
|
|
|
list.push({
|
|
|
|
id: 'answer-need-added',
|
|
|
|
type: BlockEnum.Answer,
|
|
|
|
title: t('workflow.blocks.answer'),
|
|
|
|
errorMessage: t('workflow.common.needAnswerNode'),
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!isChatMode && !nodes.find(node => node.data.type === BlockEnum.End)) {
|
|
|
|
list.push({
|
|
|
|
id: 'end-need-added',
|
|
|
|
type: BlockEnum.End,
|
|
|
|
title: t('workflow.blocks.end'),
|
|
|
|
errorMessage: t('workflow.common.needEndNode'),
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
return list
|
2024-05-27 21:57:08 +08:00
|
|
|
}, [t, nodes, edges, nodesExtraData, buildInTools, customTools, workflowTools, language, isChatMode])
|
2024-04-08 18:51:46 +08:00
|
|
|
|
|
|
|
return needWarningNodes
|
|
|
|
}
|
|
|
|
|
|
|
|
export const useChecklistBeforePublish = () => {
|
|
|
|
const { t } = useTranslation()
|
|
|
|
const language = useGetLanguage()
|
|
|
|
const buildInTools = useStore(s => s.buildInTools)
|
|
|
|
const customTools = useStore(s => s.customTools)
|
2024-05-27 21:57:08 +08:00
|
|
|
const workflowTools = useStore(s => s.workflowTools)
|
2024-04-08 18:51:46 +08:00
|
|
|
const { notify } = useToastContext()
|
|
|
|
const isChatMode = useIsChatMode()
|
|
|
|
const store = useStoreApi()
|
|
|
|
const nodesExtraData = useNodesExtraData()
|
|
|
|
|
|
|
|
const handleCheckBeforePublish = useCallback(() => {
|
|
|
|
const {
|
|
|
|
getNodes,
|
|
|
|
edges,
|
|
|
|
} = store.getState()
|
2024-06-14 17:08:11 +08:00
|
|
|
const nodes = getNodes().filter(node => node.type === CUSTOM_NODE)
|
2024-04-08 18:51:46 +08:00
|
|
|
const {
|
|
|
|
validNodes,
|
|
|
|
maxDepth,
|
2024-06-14 17:08:11 +08:00
|
|
|
} = getValidTreeNodes(nodes.filter(node => node.type === CUSTOM_NODE), edges)
|
2024-04-08 18:51:46 +08:00
|
|
|
|
2024-08-05 18:41:08 +08:00
|
|
|
if (maxDepth > MAX_TREE_DEPTH) {
|
|
|
|
notify({ type: 'error', message: t('workflow.common.maxTreeDepth', { depth: MAX_TREE_DEPTH }) })
|
2024-04-08 18:51:46 +08:00
|
|
|
return false
|
|
|
|
}
|
|
|
|
|
|
|
|
for (let i = 0; i < nodes.length; i++) {
|
|
|
|
const node = nodes[i]
|
|
|
|
let moreDataForCheckValid
|
|
|
|
if (node.data.type === BlockEnum.Tool)
|
2024-05-27 21:57:08 +08:00
|
|
|
moreDataForCheckValid = getToolCheckParams(node.data as ToolNodeType, buildInTools, customTools, workflowTools, language)
|
2024-04-08 18:51:46 +08:00
|
|
|
|
|
|
|
const { errorMessage } = nodesExtraData[node.data.type as BlockEnum].checkValid(node.data, t, moreDataForCheckValid)
|
|
|
|
|
|
|
|
if (errorMessage) {
|
|
|
|
notify({ type: 'error', message: `[${node.data.title}] ${errorMessage}` })
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!validNodes.find(n => n.id === node.id)) {
|
2024-09-07 16:59:38 +08:00
|
|
|
notify({ type: 'error', message: `[${node.data.title}] ${t('workflow.common.needConnectTip')}` })
|
2024-04-08 18:51:46 +08:00
|
|
|
return false
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (isChatMode && !nodes.find(node => node.data.type === BlockEnum.Answer)) {
|
|
|
|
notify({ type: 'error', message: t('workflow.common.needAnswerNode') })
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!isChatMode && !nodes.find(node => node.data.type === BlockEnum.End)) {
|
|
|
|
notify({ type: 'error', message: t('workflow.common.needEndNode') })
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
|
|
|
|
return true
|
2024-05-27 21:57:08 +08:00
|
|
|
}, [nodesExtraData, notify, t, store, isChatMode, buildInTools, customTools, workflowTools, language])
|
2024-04-08 18:51:46 +08:00
|
|
|
|
|
|
|
return {
|
|
|
|
handleCheckBeforePublish,
|
|
|
|
}
|
|
|
|
}
|