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() const [showRemoveVarConfirm, setShowRemoveConfirm] = useState(false) const [cacheForDelete, setCacheForDelete] = useState() 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 (
{t('workflow.env.envPanelTitle')}
setShowEnvPanel(false)} >
{t('workflow.env.envDescription')}
setCurrentVar(undefined)} />
{envList.map(env => ( ))}
setShowRemoveConfirm(false)} onConfirm={() => cacheForDelete && handleDelete(cacheForDelete)} />
) } export default memo(EnvPanel)