mirror of https://github.com/langgenius/dify.git
100 lines
2.5 KiB
TypeScript
100 lines
2.5 KiB
TypeScript
import { useCallback } from 'react'
|
|
import produce from 'immer'
|
|
import useVarList from '../_base/hooks/use-var-list'
|
|
import useOutputVarList from '../_base/hooks/use-output-var-list'
|
|
import type { CodeLanguage, CodeNodeType } from './types'
|
|
import useNodeCrud from '@/app/components/workflow/nodes/_base/hooks/use-node-crud'
|
|
import useOneStepRun from '@/app/components/workflow/nodes/_base/hooks/use-one-step-run'
|
|
|
|
const useConfig = (id: string, payload: CodeNodeType) => {
|
|
const { inputs, setInputs } = useNodeCrud<CodeNodeType>(id, payload)
|
|
const { handleVarListChange, handleAddVariable } = useVarList<CodeNodeType>({
|
|
inputs,
|
|
setInputs,
|
|
})
|
|
|
|
const handleCodeChange = useCallback((code: string) => {
|
|
const newInputs = produce(inputs, (draft) => {
|
|
draft.code = code
|
|
})
|
|
setInputs(newInputs)
|
|
}, [inputs, setInputs])
|
|
|
|
const handleCodeLanguageChange = useCallback((codeLanguage: CodeLanguage) => {
|
|
const newInputs = produce(inputs, (draft) => {
|
|
draft.code_language = codeLanguage
|
|
})
|
|
setInputs(newInputs)
|
|
}, [inputs, setInputs])
|
|
|
|
const { handleVarsChange, handleAddVariable: handleAddOutputVariable } = useOutputVarList<CodeNodeType>({
|
|
inputs,
|
|
setInputs,
|
|
})
|
|
|
|
// single run
|
|
const {
|
|
isShowSingleRun,
|
|
hideSingleRun,
|
|
toVarInputs,
|
|
runningStatus,
|
|
isCompleted,
|
|
handleRun,
|
|
handleStop,
|
|
runInputData,
|
|
setRunInputData,
|
|
runResult: unformattedRunResult,
|
|
} = useOneStepRun<CodeNodeType>({
|
|
id,
|
|
data: inputs,
|
|
defaultRunInputData: {},
|
|
})
|
|
|
|
const runResult = (() => {
|
|
if (!unformattedRunResult)
|
|
return {}
|
|
|
|
return {
|
|
...unformattedRunResult,
|
|
created_by: unformattedRunResult.created_by_account?.name || '',
|
|
}
|
|
})()
|
|
const varInputs = toVarInputs(inputs.variables)
|
|
|
|
const inputVarValues = (() => {
|
|
const vars: Record<string, any> = {}
|
|
Object.keys(runInputData)
|
|
.forEach((key) => {
|
|
vars[key] = runInputData[key]
|
|
})
|
|
return vars
|
|
})()
|
|
|
|
const setInputVarValues = useCallback((newPayload: Record<string, any>) => {
|
|
setRunInputData(newPayload)
|
|
}, [runInputData, setRunInputData])
|
|
|
|
return {
|
|
inputs,
|
|
handleVarListChange,
|
|
handleAddVariable,
|
|
handleCodeChange,
|
|
handleCodeLanguageChange,
|
|
handleVarsChange,
|
|
handleAddOutputVariable,
|
|
// single run
|
|
isShowSingleRun,
|
|
hideSingleRun,
|
|
runningStatus,
|
|
isCompleted,
|
|
handleRun,
|
|
handleStop,
|
|
varInputs,
|
|
inputVarValues,
|
|
setInputVarValues,
|
|
runResult,
|
|
}
|
|
}
|
|
|
|
export default useConfig
|