mirror of
https://github.com/langgenius/dify.git
synced 2024-11-16 19:59:50 +08:00
935e72d449
Signed-off-by: -LAN- <laipz8200@outlook.com> Co-authored-by: Joel <iamjoel007@gmail.com> Co-authored-by: -LAN- <laipz8200@outlook.com>
196 lines
6.6 KiB
TypeScript
196 lines
6.6 KiB
TypeScript
import {
|
|
memo,
|
|
useCallback,
|
|
useState,
|
|
} from 'react'
|
|
import {
|
|
useStoreApi,
|
|
} from 'reactflow'
|
|
import { RiCloseLine } from '@remixicon/react'
|
|
import { useTranslation } from 'react-i18next'
|
|
import { useStore } from '@/app/components/workflow/store'
|
|
import VariableTrigger from '@/app/components/workflow/panel/env-panel/variable-trigger'
|
|
import EnvItem from '@/app/components/workflow/panel/env-panel/env-item'
|
|
import type {
|
|
EnvironmentVariable,
|
|
} from '@/app/components/workflow/types'
|
|
import { findUsedVarNodes, updateNodeVars } from '@/app/components/workflow/nodes/_base/components/variable/utils'
|
|
import RemoveEffectVarConfirm from '@/app/components/workflow/nodes/_base/components/remove-effect-var-confirm'
|
|
import cn from '@/utils/classnames'
|
|
import { useNodesSyncDraft } from '@/app/components/workflow/hooks/use-nodes-sync-draft'
|
|
|
|
const EnvPanel = () => {
|
|
const { t } = useTranslation()
|
|
const store = useStoreApi()
|
|
const setShowEnvPanel = useStore(s => s.setShowEnvPanel)
|
|
const envList = useStore(s => s.environmentVariables) as EnvironmentVariable[]
|
|
const envSecrets = useStore(s => s.envSecrets)
|
|
const updateEnvList = useStore(s => s.setEnvironmentVariables)
|
|
const setEnvSecrets = useStore(s => s.setEnvSecrets)
|
|
const { doSyncWorkflowDraft } = useNodesSyncDraft()
|
|
|
|
const [showVariableModal, setShowVariableModal] = useState(false)
|
|
const [currentVar, setCurrentVar] = useState<EnvironmentVariable>()
|
|
|
|
const [showRemoveVarConfirm, setShowRemoveConfirm] = useState(false)
|
|
const [cacheForDelete, setCacheForDelete] = useState<EnvironmentVariable>()
|
|
|
|
const formatSecret = (s: string) => {
|
|
return s.length > 8 ? `${s.slice(0, 6)}************${s.slice(-2)}` : '********************'
|
|
}
|
|
|
|
const getEffectedNodes = useCallback((env: EnvironmentVariable) => {
|
|
const { getNodes } = store.getState()
|
|
const allNodes = getNodes()
|
|
return findUsedVarNodes(
|
|
['env', env.name],
|
|
allNodes,
|
|
)
|
|
}, [store])
|
|
|
|
const removeUsedVarInNodes = useCallback((env: EnvironmentVariable) => {
|
|
const { getNodes, setNodes } = store.getState()
|
|
const effectedNodes = getEffectedNodes(env)
|
|
const newNodes = getNodes().map((node) => {
|
|
if (effectedNodes.find(n => n.id === node.id))
|
|
return updateNodeVars(node, ['env', env.name], [])
|
|
|
|
return node
|
|
})
|
|
setNodes(newNodes)
|
|
}, [getEffectedNodes, store])
|
|
|
|
const handleEdit = (env: EnvironmentVariable) => {
|
|
setCurrentVar(env)
|
|
setShowVariableModal(true)
|
|
}
|
|
|
|
const handleDelete = useCallback((env: EnvironmentVariable) => {
|
|
removeUsedVarInNodes(env)
|
|
updateEnvList(envList.filter(e => e.id !== env.id))
|
|
setCacheForDelete(undefined)
|
|
setShowRemoveConfirm(false)
|
|
doSyncWorkflowDraft()
|
|
if (env.value_type === 'secret') {
|
|
const newMap = { ...envSecrets }
|
|
delete newMap[env.id]
|
|
setEnvSecrets(newMap)
|
|
}
|
|
}, [doSyncWorkflowDraft, envList, envSecrets, removeUsedVarInNodes, setEnvSecrets, updateEnvList])
|
|
|
|
const deleteCheck = useCallback((env: EnvironmentVariable) => {
|
|
const effectedNodes = getEffectedNodes(env)
|
|
if (effectedNodes.length > 0) {
|
|
setCacheForDelete(env)
|
|
setShowRemoveConfirm(true)
|
|
}
|
|
else {
|
|
handleDelete(env)
|
|
}
|
|
}, [getEffectedNodes, handleDelete])
|
|
|
|
const handleSave = useCallback(async (env: EnvironmentVariable) => {
|
|
// add env
|
|
let newEnv = env
|
|
if (!currentVar) {
|
|
if (env.value_type === 'secret') {
|
|
setEnvSecrets({
|
|
...envSecrets,
|
|
[env.id]: formatSecret(env.value),
|
|
})
|
|
}
|
|
const newList = [env, ...envList]
|
|
updateEnvList(newList)
|
|
await doSyncWorkflowDraft()
|
|
updateEnvList(newList.map(e => (e.id === env.id && env.value_type === 'secret') ? { ...e, value: '[__HIDDEN__]' } : e))
|
|
return
|
|
}
|
|
else if (currentVar.value_type === 'secret') {
|
|
if (env.value_type === 'secret') {
|
|
if (envSecrets[currentVar.id] !== env.value) {
|
|
newEnv = env
|
|
setEnvSecrets({
|
|
...envSecrets,
|
|
[env.id]: formatSecret(env.value),
|
|
})
|
|
}
|
|
else {
|
|
newEnv = { ...env, value: '[__HIDDEN__]' }
|
|
}
|
|
}
|
|
}
|
|
else {
|
|
if (env.value_type === 'secret') {
|
|
newEnv = env
|
|
setEnvSecrets({
|
|
...envSecrets,
|
|
[env.id]: formatSecret(env.value),
|
|
})
|
|
}
|
|
}
|
|
const newList = envList.map(e => e.id === currentVar.id ? newEnv : e)
|
|
updateEnvList(newList)
|
|
// side effects of rename env
|
|
if (currentVar.name !== env.name) {
|
|
const { getNodes, setNodes } = store.getState()
|
|
const effectedNodes = getEffectedNodes(currentVar)
|
|
const newNodes = getNodes().map((node) => {
|
|
if (effectedNodes.find(n => n.id === node.id))
|
|
return updateNodeVars(node, ['env', currentVar.name], ['env', env.name])
|
|
|
|
return node
|
|
})
|
|
setNodes(newNodes)
|
|
}
|
|
await doSyncWorkflowDraft()
|
|
updateEnvList(newList.map(e => (e.id === env.id && env.value_type === 'secret') ? { ...e, value: '[__HIDDEN__]' } : e))
|
|
}, [currentVar, doSyncWorkflowDraft, envList, envSecrets, getEffectedNodes, setEnvSecrets, store, updateEnvList])
|
|
|
|
return (
|
|
<div
|
|
className={cn(
|
|
'relative flex flex-col w-[420px] bg-components-panel-bg-alt rounded-l-2xl h-full border border-components-panel-border',
|
|
)}
|
|
>
|
|
<div className='shrink-0 flex items-center justify-between p-4 pb-0 text-text-primary system-xl-semibold'>
|
|
{t('workflow.env.envPanelTitle')}
|
|
<div className='flex items-center'>
|
|
<div
|
|
className='flex items-center justify-center w-6 h-6 cursor-pointer'
|
|
onClick={() => setShowEnvPanel(false)}
|
|
>
|
|
<RiCloseLine className='w-4 h-4 text-text-tertiary' />
|
|
</div>
|
|
</div>
|
|
</div>
|
|
<div className='shrink-0 py-1 px-4 system-sm-regular text-text-tertiary'>{t('workflow.env.envDescription')}</div>
|
|
<div className='shrink-0 px-4 pt-2 pb-3'>
|
|
<VariableTrigger
|
|
open={showVariableModal}
|
|
setOpen={setShowVariableModal}
|
|
env={currentVar}
|
|
onSave={handleSave}
|
|
onClose={() => setCurrentVar(undefined)}
|
|
/>
|
|
</div>
|
|
<div className='grow px-4 rounded-b-2xl overflow-y-auto'>
|
|
{envList.map(env => (
|
|
<EnvItem
|
|
key={env.id}
|
|
env={env}
|
|
onEdit={handleEdit}
|
|
onDelete={deleteCheck}
|
|
/>
|
|
))}
|
|
</div>
|
|
<RemoveEffectVarConfirm
|
|
isShow={showRemoveVarConfirm}
|
|
onCancel={() => setShowRemoveConfirm(false)}
|
|
onConfirm={() => cacheForDelete && handleDelete(cacheForDelete)}
|
|
/>
|
|
</div>
|
|
)
|
|
}
|
|
|
|
export default memo(EnvPanel)
|