import type { AgentNodeType } from '../../../agent/types'
import type { AnswerNodeType } from '../../../answer/types'
import type { CodeNodeType } from '../../../code/types'
import type { DocExtractorNodeType } from '../../../document-extractor/types'
import type { EndNodeType } from '../../../end/types'
import type { HttpNodeType } from '../../../http/types'
import type { IfElseNodeType } from '../../../if-else/types'
import type { IterationNodeType } from '../../../iteration/types'
import type { KnowledgeRetrievalNodeType } from '../../../knowledge-retrieval/types'
import type { ListFilterNodeType } from '../../../list-operator/types'
import type { LLMNodeType, StructuredOutput } from '../../../llm/types'
import type { LoopNodeType } from '../../../loop/types'
import type { ParameterExtractorNodeType } from '../../../parameter-extractor/types'
import type { QuestionClassifierNodeType } from '../../../question-classifier/types'
import type { TemplateTransformNodeType } from '../../../template-transform/types'
import type { ToolNodeType } from '../../../tool/types'
import type { DataSourceNodeType } from '@/app/components/workflow/nodes/data-source/types'
import type { HumanInputNodeType } from '@/app/components/workflow/nodes/human-input/types'
import type { CaseItem, Condition } from '@/app/components/workflow/nodes/if-else/types'
import type { Field as StructField } from '@/app/components/workflow/nodes/llm/types'
import type { StartNodeType } from '@/app/components/workflow/nodes/start/types'
import type { PluginTriggerNodeType } from '@/app/components/workflow/nodes/trigger-plugin/types'
import type { WebhookTriggerNodeType } from '@/app/components/workflow/nodes/trigger-webhook/types'
import type { VariableAssignerNodeType } from '@/app/components/workflow/nodes/variable-assigner/types'
import type {
  ConversationVariable,
  EnvironmentVariable,
  Node,
  NodeOutPutVar,
  PromptItem,
  ToolWithProvider,
  ValueSelector,
  Var,
} from '@/app/components/workflow/types'
import type { RAGPipelineVariable } from '@/models/pipeline'
import type { SchemaTypeDefinition } from '@/service/use-common'
import { uniq } from 'es-toolkit/array'
import { isArray } from 'es-toolkit/compat'
import { produce } from 'immer'
import {
  AGENT_OUTPUT_STRUCT,
  FILE_STRUCT,
  getGlobalVars,
  HTTP_REQUEST_OUTPUT_STRUCT,
  HUMAN_INPUT_OUTPUT_STRUCT,
  KNOWLEDGE_RETRIEVAL_OUTPUT_STRUCT,
  LLM_OUTPUT_STRUCT,
  PARAMETER_EXTRACTOR_COMMON_STRUCT,
  QUESTION_CLASSIFIER_OUTPUT_STRUCT,
  SUPPORT_OUTPUT_VARS_NODE,
  TEMPLATE_TRANSFORM_OUTPUT_STRUCT,
  TOOL_OUTPUT_STRUCT,
} from '@/app/components/workflow/constants'
import DataSourceNodeDefault from '@/app/components/workflow/nodes/data-source/default'
import HumanInputNodeDefault from '@/app/components/workflow/nodes/human-input/default'
import { DeliveryMethodType } from '@/app/components/workflow/nodes/human-input/types'
import ToolNodeDefault from '@/app/components/workflow/nodes/tool/default'
import PluginTriggerNodeDefault from '@/app/components/workflow/nodes/trigger-plugin/default'
import {
  BlockEnum,
  InputVarType,
  VarType,
} from '@/app/components/workflow/types'
import { VAR_REGEX } from '@/config'
import { AppModeEnum } from '@/types/app'
import { OUTPUT_FILE_SUB_VARIABLES } from '../../../constants'
import {

  Type,
} from '../../../llm/types'
import { VarType as ToolVarType } from '../../../tool/types'

export const isSystemVar = (valueSelector: ValueSelector) => {
  return valueSelector[0] === 'sys' || valueSelector[1] === 'sys'
}

export const isGlobalVar = (valueSelector: ValueSelector) => {
  if (!isSystemVar(valueSelector))
    return false
  const second = valueSelector[1]

  if (['query', 'files'].includes(second!))
    return false
  return true
}

export const isENV = (valueSelector: ValueSelector) => {
  return valueSelector[0] === 'env'
}

export const isConversationVar = (valueSelector: ValueSelector) => {
  return valueSelector[0] === 'conversation'
}

export const isRagVariableVar = (valueSelector: ValueSelector) => {
  if (!valueSelector)
    return false
  return valueSelector[0] === 'rag'
}

export const isSpecialVar = (prefix: string): boolean => {
  return ['sys', 'env', 'conversation', 'rag'].includes(prefix)
}

const hasValidChildren = (children: any): boolean => {
  return (
    children
    && ((Array.isArray(children) && children.length > 0)
      || (!Array.isArray(children)
        && Object.keys((children as StructuredOutput)?.schema?.properties || {})
          .length > 0))
  )
}

export const inputVarTypeToVarType = (type: InputVarType): VarType => {
  return (
    (
      {
        [InputVarType.number]: VarType.number,
        [InputVarType.checkbox]: VarType.boolean,
        [InputVarType.singleFile]: VarType.file,
        [InputVarType.multiFiles]: VarType.arrayFile,
        [InputVarType.jsonObject]: VarType.object,
      } as any
    )[type] || VarType.string
  )
}

const structTypeToVarType = (type: Type, isArray?: boolean): VarType => {
  if (isArray) {
    return (
      (
        {
          [Type.string]: VarType.arrayString,
          [Type.number]: VarType.arrayNumber,
          [Type.object]: VarType.arrayObject,
        } as any
      )[type] || VarType.string
    )
  }
  return (
    (
      {
        [Type.string]: VarType.string,
        [Type.number]: VarType.number,
        [Type.boolean]: VarType.boolean,
        [Type.object]: VarType.object,
        [Type.array]: VarType.array,
      } as any
    )[type] || VarType.string
  )
}

export const varTypeToStructType = (type: VarType): Type => {
  return (
    (
      {
        [VarType.string]: Type.string,
        [VarType.number]: Type.number,
        [VarType.boolean]: Type.boolean,
        [VarType.object]: Type.object,
        [VarType.array]: Type.array,
        [VarType.arrayString]: Type.array,
        [VarType.arrayNumber]: Type.array,
        [VarType.arrayObject]: Type.array,
        [VarType.arrayFile]: Type.array,
      } as any
    )[type] || Type.string
  )
}

const findExceptVarInStructuredProperties = (
  properties: Record<string, StructField>,
  filterVar: (payload: Var, selector: ValueSelector) => boolean,
): Record<string, StructField> => {
  const res = produce(properties, (draft) => {
    Object.keys(properties).forEach((key) => {
      const item = properties[key]
      const isObj = item!.type === Type.object
      const isArray = item!.type === Type.array
      const arrayType = item!.items?.type

      if (
        !isObj
        && !filterVar(
          {
            variable: key,
            type: structTypeToVarType(
              isArray ? arrayType! : item!.type,
              isArray,
            ),
          },
          [key],
        )
      ) {
        delete properties[key]
        return
      }
      if (item!.type === Type.object && item!.properties) {
        item!.properties = findExceptVarInStructuredProperties(
          item!.properties,
          filterVar,
        )
      }
    })
    return draft
  })
  return res
}

const findExceptVarInStructuredOutput = (
  structuredOutput: StructuredOutput,
  filterVar: (payload: Var, selector: ValueSelector) => boolean,
): StructuredOutput => {
  const res = produce(structuredOutput, (draft) => {
    const properties = draft.schema.properties
    Object.keys(properties).forEach((key) => {
      const item = properties[key]
      const isObj = item!.type === Type.object
      const isArray = item!.type === Type.array
      const arrayType = item!.items?.type
      if (
        !isObj
        && !filterVar(
          {
            variable: key,
            type: structTypeToVarType(
              isArray ? arrayType! : item!.type,
              isArray,
            ),
          },
          [key],
        )
      ) {
        delete properties[key]
        return
      }
      if (item!.type === Type.object && item!.properties) {
        item!.properties = findExceptVarInStructuredProperties(
          item!.properties,
          filterVar,
        )
      }
    })
    return draft
  })
  return res
}

const findExceptVarInObject = (
  obj: any,
  filterVar: (payload: Var, selector: ValueSelector) => boolean,
  value_selector: ValueSelector,
  isFile?: boolean,
): Var => {
  const { children } = obj
  const isStructuredOutput = !!(children as StructuredOutput)?.schema?.properties

  let childrenResult: Var[] | StructuredOutput | undefined

  if (isStructuredOutput) {
    childrenResult = findExceptVarInStructuredOutput(children, filterVar)
  }
  else if (Array.isArray(children)) {
    childrenResult = children
      .map((item: Var) => {
        const { children: itemChildren } = item
        const currSelector = [...value_selector, item.variable]

        if (!itemChildren) {
          return {
            item,
            filteredObj: null,
            passesFilter: filterVar(item, currSelector),
          }
        }

        const filteredObj = findExceptVarInObject(
          item,
          filterVar,
          currSelector,
          false,
        )
        const itemHasValidChildren = hasValidChildren(filteredObj.children)

        let passesFilter
        if (
          (item.type === VarType.object || item.type === VarType.file)
          && itemChildren
        ) {
          passesFilter = itemHasValidChildren || filterVar(item, currSelector)
        }
        else {
          passesFilter = itemHasValidChildren
        }

        return {
          item,
          filteredObj,
          passesFilter,
        }
      })
      .filter(({ passesFilter }) => passesFilter)
      .map(({ item, filteredObj }) => {
        const { children: itemChildren } = item
        if (!itemChildren || !filteredObj)
          return item

        return {
          ...item,
          children: filteredObj.children,
        }
      })
  }
  else {
    childrenResult = []
  }

  const res: Var = {
    variable: obj.variable,
    type: isFile ? VarType.file : VarType.object,
    children: childrenResult,
    schemaType: obj.schemaType,
  }

  return res
}

const formatItem = (
  item: any,
  isChatMode: boolean,
  filterVar: (payload: Var, selector: ValueSelector) => boolean,
  allPluginInfoList: Record<string, ToolWithProvider[]>,
  ragVars?: Var[],
  schemaTypeDefinitions: SchemaTypeDefinition[] = [],
): NodeOutPutVar => {
  const { id, data } = item

  const res: NodeOutPutVar = {
    nodeId: id,
    title: data.title,
    vars: [],
  }
  switch (data.type) {
    case BlockEnum.Start: {
      const { variables } = data as StartNodeType
      res.vars = variables.map((v) => {
        const type = inputVarTypeToVarType(v.type)
        const varRes: Var = {
          variable: v.variable,
          type,
          isParagraph: v.type === InputVarType.paragraph,
          isSelect: v.type === InputVarType.select,
          options: v.options,
          required: v.required,
        }
        try {
          if (type === VarType.object && v.json_schema) {
            varRes.children = {
              schema: typeof v.json_schema === 'string' ? JSON.parse(v.json_schema) : v.json_schema,
            }
          }
        }
        catch (error) {
          console.error('Error formatting variable:', error)
        }

        return varRes
      })
      if (isChatMode) {
        res.vars.push({
          variable: 'sys.query',
          type: VarType.string,
        })
      }
      res.vars.push({
        variable: 'sys.files',
        type: VarType.arrayFile,
      })
      break
    }

    case BlockEnum.TriggerWebhook: {
      const {
        variables = [],
      } = data as WebhookTriggerNodeType
      res.vars = variables.map((v) => {
        const type = v.value_type || VarType.string
        const varRes: Var = {
          variable: v.variable,
          type,
          isParagraph: false,
          isSelect: false,
          options: v.options,
          required: v.required,
        }
        return varRes
      })

      break
    }

    case BlockEnum.LLM: {
      res.vars = [...LLM_OUTPUT_STRUCT]
      if (
        data.structured_output_enabled
        && data.structured_output?.schema?.properties
        && Object.keys(data.structured_output.schema.properties).length > 0
      ) {
        res.vars.push({
          variable: 'structured_output',
          type: VarType.object,
          children: data.structured_output,
        })
      }

      break
    }
    case BlockEnum.KnowledgeRetrieval: {
      res.vars = KNOWLEDGE_RETRIEVAL_OUTPUT_STRUCT
      break
    }

    case BlockEnum.Code: {
      const { outputs } = data as CodeNodeType
      res.vars = outputs
        ? Object.keys(outputs).map((key) => {
            return {
              variable: key,
              type: outputs[key]!.type,
            }
          })
        : []
      break
    }

    case BlockEnum.TemplateTransform: {
      res.vars = TEMPLATE_TRANSFORM_OUTPUT_STRUCT
      break
    }

    case BlockEnum.QuestionClassifier: {
      res.vars = QUESTION_CLASSIFIER_OUTPUT_STRUCT
      break
    }

    case BlockEnum.HttpRequest: {
      res.vars = HTTP_REQUEST_OUTPUT_STRUCT
      break
    }

    case BlockEnum.VariableAssigner: {
      const { output_type, advanced_settings }
        = data as VariableAssignerNodeType
      const isGroup = !!advanced_settings?.group_enabled
      if (!isGroup) {
        res.vars = [
          {
            variable: 'output',
            type: output_type,
          },
        ]
      }
      else {
        res.vars = advanced_settings?.groups.map((group) => {
          return {
            variable: group.group_name,
            type: VarType.object,
            children: [
              {
                variable: 'output',
                type: group.output_type,
              },
            ],
          }
        })
      }
      break
    }

    case BlockEnum.VariableAggregator: {
      const { output_type, advanced_settings }
        = data as VariableAssignerNodeType
      const isGroup = !!advanced_settings?.group_enabled
      if (!isGroup) {
        res.vars = [
          {
            variable: 'output',
            type: output_type,
          },
        ]
      }
      else {
        res.vars = advanced_settings?.groups.map((group) => {
          return {
            variable: group.group_name,
            type: VarType.object,
            children: [
              {
                variable: 'output',
                type: group.output_type,
              },
            ],
          }
        })
      }
      break
    }

    case BlockEnum.Tool: {
      const toolOutputVars
        = ToolNodeDefault.getOutputVars?.(
          data as ToolNodeType,
          allPluginInfoList,
          [],
          { schemaTypeDefinitions },
        ) || []
      res.vars = toolOutputVars
      break
    }

    case BlockEnum.ParameterExtractor: {
      res.vars = [
        ...((data as ParameterExtractorNodeType).parameters || []).map((p) => {
          return {
            variable: p.name,
            type: p.type as unknown as VarType,
          }
        }),
        ...PARAMETER_EXTRACTOR_COMMON_STRUCT,
      ]
      break
    }

    case BlockEnum.Iteration: {
      res.vars = [
        {
          variable: 'output',
          type: (data as IterationNodeType).output_type || VarType.arrayString,
        },
      ]
      break
    }

    case BlockEnum.Loop: {
      const { loop_variables } = data as LoopNodeType
      res.isLoop = true
      res.vars
        = loop_variables?.map((v) => {
          return {
            variable: v.label,
            type: v.var_type,
            isLoopVariable: true,
            nodeId: res.nodeId,
          }
        }) || []

      break
    }

    case BlockEnum.DocExtractor: {
      res.vars = [
        {
          variable: 'text',
          type: (data as DocExtractorNodeType).is_array_file
            ? VarType.arrayString
            : VarType.string,
        },
      ]
      break
    }

    case BlockEnum.ListFilter: {
      if (!(data as ListFilterNodeType).var_type)
        break

      res.vars = [
        {
          variable: 'result',
          type: (data as ListFilterNodeType).var_type,
        },
        {
          variable: 'first_record',
          type: (data as ListFilterNodeType).item_var_type,
        },
        {
          variable: 'last_record',
          type: (data as ListFilterNodeType).item_var_type,
        },
      ]
      break
    }

    case BlockEnum.Agent: {
      const payload = data as AgentNodeType
      const outputs: Var[] = []
      Object.keys(payload.output_schema?.properties || {}).forEach(
        (outputKey) => {
          const output = payload.output_schema.properties[outputKey]
          outputs.push({
            variable: outputKey,
            type:
              output.type === 'array'
                ? (`Array[${output.items?.type ? output.items.type.slice(0, 1).toLocaleUpperCase() + output.items.type.slice(1) : 'Unknown'}]` as VarType)
                : (`${output.type ? output.type.slice(0, 1).toLocaleUpperCase() + output.type.slice(1) : 'Unknown'}` as VarType),
          })
        },
      )
      res.vars = [...outputs, ...TOOL_OUTPUT_STRUCT, ...AGENT_OUTPUT_STRUCT]
      break
    }

    case BlockEnum.DataSource: {
      const payload = data as DataSourceNodeType
      const dataSourceVars
        = DataSourceNodeDefault.getOutputVars?.(
          payload,
          allPluginInfoList,
          ragVars,
          { schemaTypeDefinitions },
        ) || []
      res.vars = dataSourceVars
      break
    }

    case BlockEnum.TriggerPlugin: {
      const outputSchema = PluginTriggerNodeDefault.getOutputVars?.(
        data as PluginTriggerNodeType,
        allPluginInfoList,
        [],
        { schemaTypeDefinitions },
      ) || []
      res.vars = outputSchema
      break
    }

    case BlockEnum.HumanInput: {
      const outputSchema = HumanInputNodeDefault.getOutputVars?.(
        data as HumanInputNodeType,
        allPluginInfoList,
        [],
        { schemaTypeDefinitions },
      ) || []
      res.vars = [...outputSchema, ...HUMAN_INPUT_OUTPUT_STRUCT]
      break
    }

    case 'env': {
      res.vars = data.envList.map((env: EnvironmentVariable) => {
        return {
          variable: `env.${env.name}`,
          type: env.value_type,
          description: env.description,
        }
      }) as Var[]
      break
    }

    case 'conversation': {
      res.vars = data.chatVarList.map((chatVar: ConversationVariable) => {
        return {
          variable: `conversation.${chatVar.name}`,
          type: chatVar.value_type,
          description: chatVar.description,
        }
      }) as Var[]
      break
    }

    case 'global': {
      res.vars = data.globalVarList
      break
    }

    case 'rag': {
      res.vars = data.ragVariables.map((ragVar: RAGPipelineVariable) => {
        return {
          variable: `rag.shared.${ragVar.variable}`,
          type: inputVarTypeToVarType(ragVar.type as any),
          des: ragVar.label,
          isRagVariable: true,
        }
      }) as Var[]
      break
    }
  }

  const { error_strategy } = data

  if (error_strategy) {
    res.vars = [
      ...res.vars,
      {
        variable: 'error_message',
        type: VarType.string,
        isException: true,
      },
      {
        variable: 'error_type',
        type: VarType.string,
        isException: true,
      },
    ]
  }

  const selector = [id]
  res.vars = res.vars
    .filter((v) => {
      const isCurrentMatched = filterVar(
        v,
        (() => {
          const variableArr = v.variable.split('.')
          const [first] = variableArr
          if (isSpecialVar(first!))
            return variableArr

          return [...selector, ...variableArr]
        })(),
      )
      if (isCurrentMatched)
        return true

      const isFile = v.type === VarType.file
      const children = (() => {
        if (isFile) {
          return OUTPUT_FILE_SUB_VARIABLES.map((key) => {
            const def = FILE_STRUCT.find(c => c.variable === key)
            return {
              variable: key,
              type: def?.type || VarType.string,
            }
          })
        }
        return v.children
      })()
      if (!children)
        return false

      const obj = findExceptVarInObject(
        isFile ? { ...v, children } : v,
        filterVar,
        selector,
        isFile,
      )
      return hasValidChildren(obj?.children)
    })
    .map((v) => {
      const isFile = v.type === VarType.file
      const { children } = (() => {
        if (isFile) {
          return {
            children: OUTPUT_FILE_SUB_VARIABLES.map((key) => {
              const def = FILE_STRUCT.find(c => c.variable === key)
              return {
                variable: key,
                type: def?.type || VarType.string,
              }
            }),
          }
        }
        return v
      })()

      if (!children)
        return v

      return findExceptVarInObject(
        isFile ? { ...v, children } : v,
        filterVar,
        selector,
        isFile,
      )
    })

  return res
}

export const removeFileVars = (nodeWithVars: NodeOutPutVar[]) => {
  return nodeWithVars
    .map((item) => {
      return {
        ...item,
        vars: item.vars.filter(
          v => v.type !== VarType.file && v.type !== VarType.arrayFile,
        ),
      }
    })
    .filter(item => item.vars.length > 0)
}

export const toNodeOutputVars = (
  nodes: any[],
  isChatMode: boolean,
  filterVar = (_payload: Var, _selector: ValueSelector) => true,
  environmentVariables: EnvironmentVariable[] = [],
  conversationVariables: ConversationVariable[] = [],
  ragVariables: RAGPipelineVariable[] = [],
  allPluginInfoList: Record<string, ToolWithProvider[]>,
  schemaTypeDefinitions?: SchemaTypeDefinition[],
): NodeOutPutVar[] => {
  // ENV_NODE data format
  const ENV_NODE = {
    id: 'env',
    data: {
      title: 'ENVIRONMENT',
      type: 'env',
      envList: environmentVariables,
    },
  }
  // CHAT_VAR_NODE data format
  const CHAT_VAR_NODE = {
    id: 'conversation',
    data: {
      title: 'CONVERSATION',
      type: 'conversation',
      chatVarList: conversationVariables,
    },
  }
  // GLOBAL_VAR_NODE data format
  const GLOBAL_VAR_NODE = {
    id: 'global',
    data: {
      title: 'SYSTEM',
      type: 'global',
      globalVarList: getGlobalVars(isChatMode),
    },
  }
  // RAG_PIPELINE_NODE data format
  const RAG_PIPELINE_NODE = {
    id: 'rag',
    data: {
      title: 'SHARED INPUTS',
      type: 'rag',
      ragVariables: ragVariables.filter(
        ragVariable => ragVariable.belong_to_node_id === 'shared',
      ),
    },
  }
  // Sort nodes in reverse chronological order (most recent first)
  const sortedNodes = [...nodes].sort((a, b) => {
    if (a.data.type === BlockEnum.Start)
      return 1
    if (b.data.type === BlockEnum.Start)
      return -1
    if (a.data.type === 'env')
      return 1
    if (b.data.type === 'env')
      return -1
    if (a.data.type === 'conversation')
      return 1
    if (b.data.type === 'conversation')
      return -1
    if (a.data.type === 'global')
      return 1
    if (b.data.type === 'global')
      return -1
    // sort nodes by x position
    return (b.position?.x || 0) - (a.position?.x || 0)
  })

  const res = [
    ...sortedNodes.filter(node =>
      SUPPORT_OUTPUT_VARS_NODE.includes(node?.data?.type),
    ),
    ...(environmentVariables.length > 0 ? [ENV_NODE] : []),
    ...(isChatMode && conversationVariables.length > 0 ? [CHAT_VAR_NODE] : []),
    GLOBAL_VAR_NODE,
    ...(RAG_PIPELINE_NODE.data.ragVariables.length > 0
      ? [RAG_PIPELINE_NODE]
      : []),
  ]
    .map((node) => {
      let ragVariablesInDataSource: RAGPipelineVariable[] = []
      if (node.data.type === BlockEnum.DataSource) {
        ragVariablesInDataSource = ragVariables.filter(
          ragVariable => ragVariable.belong_to_node_id === node.id,
        )
      }
      return {
        ...formatItem(
          node,
          isChatMode,
          filterVar,
          allPluginInfoList,
          ragVariablesInDataSource.map(
            (ragVariable: RAGPipelineVariable) => {
              return {
                variable: `rag.${node.id}.${ragVariable.variable}`,
                type: inputVarTypeToVarType(ragVariable.type as any),
                description: ragVariable.label,
                isRagVariable: true,
              } as Var
            },
          ),
          schemaTypeDefinitions,
        ),
        isStartNode: node.data.type === BlockEnum.Start,
      }
    })
    .filter(item => item.vars.length > 0)
  return res
}

const getIterationItemType = ({
  valueSelector,
  beforeNodesOutputVars,
}: {
  valueSelector: ValueSelector
  beforeNodesOutputVars: NodeOutPutVar[]
}): VarType => {
  const outputVarNodeId = valueSelector[0]
  const isSystem = isSystemVar(valueSelector)
  const isChatVar = isConversationVar(valueSelector)

  const targetVar = isSystem
    ? beforeNodesOutputVars.find(v => v.isStartNode)
    : beforeNodesOutputVars.find(v => v.nodeId === outputVarNodeId)

  if (!targetVar)
    return VarType.string

  let arrayType: VarType = VarType.string

  let curr: any = targetVar.vars
  if (isSystem || isChatVar) {
    arrayType = curr.find(
      (v: any) => v.variable === valueSelector.join('.'),
    )?.type
  }
  else {
    for (let i = 1; i < valueSelector.length; i++) {
      const key = valueSelector[i]
      const isLast = i === valueSelector.length - 1
      curr = Array.isArray(curr) ? curr.find(v => v.variable === key) : []

      if (isLast)
        arrayType = curr?.type
      else if (curr?.type === VarType.object || curr?.type === VarType.file)
        curr = curr.children || []
    }
  }

  switch (arrayType as VarType) {
    case VarType.arrayString:
      return VarType.string
    case VarType.arrayNumber:
      return VarType.number
    case VarType.arrayBoolean:
      return VarType.boolean
    case VarType.arrayObject:
      return VarType.object
    case VarType.array:
      return VarType.arrayObject // Use more specific type instead of any
    case VarType.arrayFile:
      return VarType.file
    default:
      return VarType.string
  }
}

const getLoopItemType = ({
  valueSelector,
  beforeNodesOutputVars,
}: {
  valueSelector: ValueSelector
  beforeNodesOutputVars: NodeOutPutVar[]
}): VarType => {
  const outputVarNodeId = valueSelector[0]
  const isSystem = isSystemVar(valueSelector)

  const targetVar = isSystem
    ? beforeNodesOutputVars.find(v => v.isStartNode)
    : beforeNodesOutputVars.find(v => v.nodeId === outputVarNodeId)
  if (!targetVar)
    return VarType.string

  let arrayType: VarType = VarType.string

  let curr: any = targetVar.vars
  if (isSystem) {
    arrayType = curr.find(
      (v: any) => v.variable === valueSelector.join('.'),
    )?.type
  }
  else {
    valueSelector.slice(1).forEach((key, i) => {
      const isLast = i === valueSelector.length - 2
      curr = curr?.find((v: any) => v.variable === key)
      if (isLast) {
        arrayType = curr?.type
      }
      else {
        if (curr?.type === VarType.object || curr?.type === VarType.file)
          curr = curr.children
      }
    })
  }

  switch (arrayType as VarType) {
    case VarType.arrayString:
      return VarType.string
    case VarType.arrayNumber:
      return VarType.number
    case VarType.arrayObject:
      return VarType.object
    case VarType.arrayBoolean:
      return VarType.boolean
    case VarType.array:
      return VarType.any
    case VarType.arrayFile:
      return VarType.file
    default:
      return VarType.string
  }
}

export const getVarType = ({
  parentNode,
  valueSelector,
  isIterationItem,
  isLoopItem,
  availableNodes,
  isChatMode,
  isConstant,
  environmentVariables = [],
  conversationVariables = [],
  ragVariables = [],
  allPluginInfoList,
  schemaTypeDefinitions,
  preferSchemaType,
}: {
  valueSelector: ValueSelector
  parentNode?: Node | null
  isIterationItem?: boolean
  isLoopItem?: boolean
  availableNodes: any[]
  isChatMode: boolean
  isConstant?: boolean
  environmentVariables?: EnvironmentVariable[]
  conversationVariables?: ConversationVariable[]
  ragVariables?: RAGPipelineVariable[]
  allPluginInfoList: Record<string, ToolWithProvider[]>
  schemaTypeDefinitions?: SchemaTypeDefinition[]
  preferSchemaType?: boolean
}): VarType => {
  if (isConstant)
    return VarType.string

  const beforeNodesOutputVars = toNodeOutputVars(
    availableNodes,
    isChatMode,
    undefined,
    environmentVariables,
    conversationVariables,
    ragVariables,
    allPluginInfoList,
    schemaTypeDefinitions,
  )

  const isIterationInnerVar = parentNode?.data.type === BlockEnum.Iteration
  if (isIterationItem) {
    return getIterationItemType({
      valueSelector,
      beforeNodesOutputVars,
    })
  }
  if (isIterationInnerVar) {
    if (valueSelector[1] === 'item') {
      const itemType = getIterationItemType({
        valueSelector: (parentNode?.data as any)?.iterator_selector || [],
        beforeNodesOutputVars,
      })
      return itemType
    }
    if (valueSelector[1] === 'index')
      return VarType.number
  }

  const isLoopInnerVar = parentNode?.data.type === BlockEnum.Loop
  if (isLoopItem) {
    return getLoopItemType({
      valueSelector,
      beforeNodesOutputVars,
    })
  }
  if (isLoopInnerVar) {
    if (valueSelector[1] === 'item') {
      const itemType = getLoopItemType({
        valueSelector: (parentNode?.data as any)?.iterator_selector || [],
        beforeNodesOutputVars,
      })
      return itemType
    }
    if (valueSelector[1] === 'index')
      return VarType.number
  }

  const isGlobal = isGlobalVar(valueSelector)
  const isInStartNodeSysVar = isSystemVar(valueSelector) && !isGlobal
  const isEnv = isENV(valueSelector)
  const isChatVar = isConversationVar(valueSelector)
  const isSharedRagVariable
    = isRagVariableVar(valueSelector) && valueSelector[1] === 'shared'
  const isInNodeRagVariable
    = isRagVariableVar(valueSelector) && valueSelector[1] !== 'shared'

  const startNode = availableNodes.find((node: any) => {
    return node?.data.type === BlockEnum.Start
  })

  const targetVarNodeId = (() => {
    if (isInStartNodeSysVar)
      return startNode?.id
    if (isGlobal)
      return 'global'
    if (isInNodeRagVariable)
      return valueSelector[1]
    return valueSelector[0]
  })()
  const targetVar = beforeNodesOutputVars.find(
    v => v.nodeId === targetVarNodeId,
  )

  if (!targetVar)
    return VarType.string

  let type: VarType = VarType.string
  let curr: any = targetVar.vars

  if (isInStartNodeSysVar || isEnv || isChatVar || isSharedRagVariable || isGlobal) {
    return curr.find(
      (v: any) => v.variable === (valueSelector as ValueSelector).join('.'),
    )?.type
  }
  else {
    const targetVar = curr.find((v: any) => {
      if (isInNodeRagVariable)
        return v.variable === valueSelector.join('.')
      return v.variable === valueSelector[1]
    })
    if (!targetVar)
      return VarType.string

    if (isInNodeRagVariable)
      return targetVar.type

    const isStructuredOutputVar = !!targetVar.children?.schema?.properties
    if (isStructuredOutputVar) {
      if (valueSelector.length === 2) {
        // root
        return preferSchemaType && targetVar.schemaType
          ? targetVar.schemaType
          : VarType.object
      }
      let currProperties = targetVar.children.schema;
      (valueSelector as ValueSelector).slice(2).forEach((key, i) => {
        const isLast = i === valueSelector.length - 3
        if (!currProperties)
          return

        currProperties = currProperties.properties[key]
        if (isLast)
          type = structTypeToVarType(currProperties?.type)
      })
      return type
    }

    (valueSelector as ValueSelector).slice(1).forEach((key, i) => {
      const isLast = i === valueSelector.length - 2
      if (Array.isArray(curr))
        curr = curr?.find((v: any) => v.variable === key)

      if (isLast) {
        type
          = preferSchemaType && curr?.schemaType ? curr?.schemaType : curr?.type
      }
      else {
        if (curr?.type === VarType.object || curr?.type === VarType.file)
          curr = curr.children
      }
    })
    return type
  }
}

// node output vars + parent inner vars(if in iteration or other wrap node)
export const toNodeAvailableVars = ({
  parentNode,
  t,
  beforeNodes,
  isChatMode,
  environmentVariables,
  conversationVariables,
  ragVariables,
  filterVar,
  allPluginInfoList,
  schemaTypeDefinitions,
}: {
  parentNode?: Node | null
  t?: any
  // to get those nodes output vars
  beforeNodes: Node[]
  isChatMode: boolean
  // env
  environmentVariables?: EnvironmentVariable[]
  // chat var
  conversationVariables?: ConversationVariable[]
  // rag variables
  ragVariables?: RAGPipelineVariable[]
  filterVar: (payload: Var, selector: ValueSelector) => boolean
  allPluginInfoList: Record<string, ToolWithProvider[]>
  schemaTypeDefinitions?: SchemaTypeDefinition[]
}): NodeOutPutVar[] => {
  const beforeNodesOutputVars = toNodeOutputVars(
    beforeNodes,
    isChatMode,
    filterVar,
    environmentVariables,
    conversationVariables,
    ragVariables,
    allPluginInfoList,
    schemaTypeDefinitions,
  )
  const isInIteration = parentNode?.data.type === BlockEnum.Iteration
  if (isInIteration) {
    const iterationNode: any = parentNode
    const itemType = getVarType({
      parentNode: iterationNode,
      isIterationItem: true,
      valueSelector: iterationNode?.data.iterator_selector || [],
      availableNodes: beforeNodes,
      isChatMode,
      environmentVariables,
      conversationVariables,
      allPluginInfoList,
      schemaTypeDefinitions,
    })
    const itemChildren
      = itemType === VarType.file
        ? {
            children: OUTPUT_FILE_SUB_VARIABLES.map((key) => {
              return {
                variable: key,
                type: key === 'size' ? VarType.number : VarType.string,
              }
            }),
          }
        : {}
    const iterationVar = {
      nodeId: iterationNode?.id,
      title: t('nodes.iteration.currentIteration', { ns: 'workflow' }),
      vars: [
        {
          variable: 'item',
          type: itemType,
          ...itemChildren,
        },
        {
          variable: 'index',
          type: VarType.number,
        },
      ],
    }
    const iterationIndex = beforeNodesOutputVars.findIndex(
      v => v.nodeId === iterationNode?.id,
    )
    if (iterationIndex > -1)
      beforeNodesOutputVars.splice(iterationIndex, 1)
    beforeNodesOutputVars.unshift(iterationVar)
  }
  return beforeNodesOutputVars
}

export const getNodeInfoById = (nodes: any, id: string) => {
  if (!isArray(nodes))
    return
  return nodes.find((node: any) => node.id === id)
}

const matchNotSystemVars = (prompts: string[]) => {
  if (!prompts)
    return []

  const allVars: string[] = []
  prompts.forEach((prompt) => {
    VAR_REGEX.lastIndex = 0
    if (typeof prompt !== 'string')
      return
    allVars.push(...(prompt.match(VAR_REGEX) || []))
  })
  const uniqVars = uniq(allVars).map(v =>
    v.replaceAll('{{#', '').replace('#}}', '').split('.'),
  )
  return uniqVars
}

const replaceOldVarInText = (
  text: string,
  oldVar: ValueSelector,
  newVar: ValueSelector,
) => {
  if (!text || typeof text !== 'string')
    return text

  if (!newVar || newVar.length === 0)
    return text

  return text.replaceAll(
    `{{#${oldVar.join('.')}#}}`,
    `{{#${newVar.join('.')}#}}`,
  )
}

const getPromptItemTexts = (prompt: PromptItem): string[] => {
  const texts = [prompt.text]
  if (prompt.jinja2_text)
    texts.push(prompt.jinja2_text)
  return texts.filter((text): text is string => !!text)
}

const replaceOldVarInPromptItem = (
  prompt: PromptItem,
  oldVar: ValueSelector,
  newVar: ValueSelector,
): PromptItem => ({
  ...prompt,
  text: replaceOldVarInText(prompt.text, oldVar, newVar),
  ...(prompt.jinja2_text !== undefined
    ? { jinja2_text: replaceOldVarInText(prompt.jinja2_text, oldVar, newVar) }
    : {}),
})

export const getNodeUsedVars = (node: Node): ValueSelector[] => {
  const { data } = node
  const { type } = data
  let res: ValueSelector[] = []
  switch (type) {
    case BlockEnum.End: {
      res = (data as EndNodeType).outputs?.map((output) => {
        return output.value_selector
      })
      break
    }
    case BlockEnum.Answer: {
      res = matchNotSystemVars([(data as AnswerNodeType).answer])
      break
    }
    case BlockEnum.LLM: {
      const payload = data as LLMNodeType
      const isChatModel = payload.model?.mode === AppModeEnum.CHAT
      let prompts: string[] = []
      if (isChatModel) {
        prompts
          = (payload.prompt_template as PromptItem[])?.flatMap(getPromptItemTexts) || []
        if (payload.memory?.query_prompt_template)
          prompts.push(payload.memory.query_prompt_template)
      }
      else {
        prompts = getPromptItemTexts(payload.prompt_template as PromptItem)
      }

      const inputVars: ValueSelector[] = matchNotSystemVars(prompts)
      const contextVar = (data as LLMNodeType).context?.variable_selector
        ? [(data as LLMNodeType).context?.variable_selector]
        : []
      res = [...inputVars, ...contextVar]
      break
    }
    case BlockEnum.KnowledgeRetrieval: {
      const {
        query_variable_selector,
        query_attachment_selector = [],
      } = data as KnowledgeRetrievalNodeType
      res = [query_variable_selector, query_attachment_selector]
      break
    }
    case BlockEnum.IfElse: {
      res = []
      res.push(
        ...((data as IfElseNodeType).cases || [])
          .flatMap(c => c.conditions || [])
          .flatMap((c) => {
            const selectors: ValueSelector[] = []
            if (c.variable_selector)
              selectors.push(c.variable_selector)
            // Handle sub-variable conditions
            if (c.sub_variable_condition && c.sub_variable_condition.conditions) {
              selectors.push(
                ...c.sub_variable_condition.conditions
                  .map(subC => subC.variable_selector || [])
                  .filter(sel => sel.length > 0),
              )
            }
            return selectors
          }),
      )
      break
    }
    case BlockEnum.Code: {
      res = (data as CodeNodeType).variables?.map((v) => {
        return v.value_selector
      })
      break
    }
    case BlockEnum.TemplateTransform: {
      res = (data as TemplateTransformNodeType).variables?.map((v: any) => {
        return v.value_selector
      })
      break
    }
    case BlockEnum.QuestionClassifier: {
      const payload = data as QuestionClassifierNodeType
      res = [payload.query_variable_selector]
      const varInInstructions = matchNotSystemVars([payload.instruction || ''])
      res.push(...varInInstructions)

      const classes = payload.classes.map(c => c.name)
      res.push(...matchNotSystemVars(classes))
      break
    }
    case BlockEnum.HttpRequest: {
      const payload = data as HttpNodeType
      res = matchNotSystemVars([
        payload.url,
        payload.headers,
        payload.params,
        typeof payload.body.data === 'string'
          ? payload.body.data
          : payload.body.data.map(d => d.value).join(''),
      ])
      break
    }
    case BlockEnum.Tool: {
      const payload = data as ToolNodeType
      const mixVars = matchNotSystemVars(
        Object.keys(payload.tool_parameters)
          ?.filter(
            key => payload.tool_parameters[key]!.type === ToolVarType.mixed,
          )
          .map(key => payload.tool_parameters[key]!.value) as string[],
      )
      const vars
        = Object.keys(payload.tool_parameters)
          .filter(
            key => payload.tool_parameters[key]!.type === ToolVarType.variable,
          )
          .map(key => payload.tool_parameters[key]!.value as string) || []
      res = [...(mixVars as ValueSelector[]), ...(vars as any)]
      break
    }
    case BlockEnum.DataSource: {
      const payload = data as DataSourceNodeType
      const mixVars = matchNotSystemVars(
        Object.keys(payload.datasource_parameters)
          ?.filter(
            key =>
              payload.datasource_parameters[key]!.type === ToolVarType.mixed,
          )
          .map(key => payload.datasource_parameters[key]!.value) as string[],
      )
      const vars
        = Object.keys(payload.datasource_parameters)
          .filter(
            key =>
              payload.datasource_parameters[key]!.type === ToolVarType.variable,
          )
          .map(key => payload.datasource_parameters[key]!.value as string)
          || []
      res = [...(mixVars as ValueSelector[]), ...(vars as any)]
      break
    }

    case BlockEnum.VariableAssigner: {
      res = (data as VariableAssignerNodeType)?.variables
      break
    }

    case BlockEnum.VariableAggregator: {
      res = (data as VariableAssignerNodeType)?.variables
      break
    }

    case BlockEnum.ParameterExtractor: {
      const payload = data as ParameterExtractorNodeType
      res = [payload.query]
      const varInInstructions = matchNotSystemVars([payload.instruction || ''])
      res.push(...varInInstructions)
      break
    }

    case BlockEnum.Iteration: {
      res = [(data as IterationNodeType).iterator_selector]
      break
    }

    case BlockEnum.Loop: {
      const payload = data as LoopNodeType
      res
        = payload.break_conditions?.map((c) => {
          return c.variable_selector || []
        }) || []
      break
    }

    case BlockEnum.ListFilter: {
      res = [(data as ListFilterNodeType).variable]
      break
    }

    case BlockEnum.Agent: {
      const payload = data as AgentNodeType
      const valueSelectors: ValueSelector[] = []
      if (!payload.agent_parameters)
        break

      Object.keys(payload.agent_parameters || {}).forEach((key) => {
        const { value } = payload.agent_parameters![key]!
        if (typeof value === 'string')
          valueSelectors.push(...matchNotSystemVars([value]))
      })
      res = valueSelectors
      break
    }

    case BlockEnum.HumanInput: {
      const payload = data as HumanInputNodeType
      const formContent = payload.form_content
      const mailTemplates = payload.delivery_methods.flatMap((method) => {
        if (method.type !== DeliveryMethodType.Email || !method.config)
          return []
        return [method.config.body]
      })
      const inputSelectors = payload.inputs.flatMap((input) => {
        if (input.type === InputVarType.paragraph && input.default.type === 'variable')
          return [input.default.selector]
        if (input.type === InputVarType.select && input.option_source.type === 'variable')
          return [input.option_source.selector]
        return []
      })
      res = [...matchNotSystemVars([formContent, ...mailTemplates]), ...inputSelectors]
      break
    }
  }
  return res || []
}

// can be used in iteration node
export const getNodeUsedVarPassToServerKey = (
  node: Node,
  valueSelector: ValueSelector,
): string | string[] => {
  const { data } = node
  const { type } = data
  let res: string | string[] = ''
  switch (type) {
    case BlockEnum.LLM: {
      const payload = data as LLMNodeType
      res = [`#${valueSelector.join('.')}#`]
      if (
        payload.context?.variable_selector.join('.') === valueSelector.join('.')
      )
        res.push('#context#')

      break
    }
    case BlockEnum.KnowledgeRetrieval: {
      res = 'query'
      break
    }
    case BlockEnum.IfElse: {
      const findConditionInCases = (cases: CaseItem[]): Condition | undefined => {
        for (const caseItem of cases) {
          for (const condition of caseItem.conditions || []) {
            if (condition.variable_selector?.join('.') === valueSelector.join('.'))
              return condition

            if (condition.sub_variable_condition) {
              const found = findConditionInCases([condition.sub_variable_condition])
              if (found)
                return found
            }
          }
        }
        return undefined
      }
      const targetVar = findConditionInCases((data as IfElseNodeType).cases || [])
      if (targetVar)
        res = `#${valueSelector.join('.')}#`
      break
    }
    case BlockEnum.Code: {
      const targetVar = (data as CodeNodeType).variables?.find(
        v =>
          Array.isArray(v.value_selector)
          && v.value_selector
          && v.value_selector.join('.') === valueSelector.join('.'),
      )
      if (targetVar)
        res = targetVar.variable
      break
    }
    case BlockEnum.TemplateTransform: {
      const targetVar = (data as TemplateTransformNodeType).variables?.find(
        v =>
          Array.isArray(v.value_selector)
          && v.value_selector
          && v.value_selector.join('.') === valueSelector.join('.'),
      )
      if (targetVar)
        res = targetVar.variable
      break
    }
    case BlockEnum.QuestionClassifier: {
      res = 'query'
      break
    }
    case BlockEnum.HttpRequest: {
      res = `#${valueSelector.join('.')}#`
      break
    }

    case BlockEnum.Tool: {
      res = `#${valueSelector.join('.')}#`
      break
    }

    case BlockEnum.VariableAssigner: {
      res = `#${valueSelector.join('.')}#`
      break
    }

    case BlockEnum.VariableAggregator: {
      res = `#${valueSelector.join('.')}#`
      break
    }

    case BlockEnum.ParameterExtractor: {
      res = 'query'
      break
    }

    case BlockEnum.HumanInput: {
      res = `#${valueSelector.join('.')}#`
      break
    }
  }
  return res
}

export const findUsedVarNodes = (
  varSelector: ValueSelector,
  availableNodes: Node[],
): Node[] => {
  const res: Node[] = []
  availableNodes.forEach((node) => {
    const vars = getNodeUsedVars(node)
    if (vars.find(v => v.join('.') === varSelector.join('.')))
      res.push(node)
  })
  return res
}

export const updateNodeVars = (
  oldNode: Node,
  oldVarSelector: ValueSelector,
  newVarSelector: ValueSelector,
): Node => {
  const newNode = produce(oldNode, (draft: any) => {
    const { data } = draft
    const { type } = data

    switch (type) {
      case BlockEnum.End: {
        const payload = data as EndNodeType
        if (payload.outputs) {
          payload.outputs = payload.outputs.map((output) => {
            if (output.value_selector.join('.') === oldVarSelector.join('.'))
              output.value_selector = newVarSelector
            return output
          })
        }
        break
      }
      case BlockEnum.Answer: {
        const payload = data as AnswerNodeType
        payload.answer = replaceOldVarInText(
          payload.answer,
          oldVarSelector,
          newVarSelector,
        )
        if (payload.variables) {
          payload.variables = payload.variables.map((v) => {
            if (v.value_selector.join('.') === oldVarSelector.join('.'))
              v.value_selector = newVarSelector
            return v
          })
        }
        break
      }
      case BlockEnum.LLM: {
        const payload = data as LLMNodeType
        const isChatModel = payload.model?.mode === AppModeEnum.CHAT
        if (isChatModel) {
          payload.prompt_template = (
            payload.prompt_template as PromptItem[]
          ).map(prompt => replaceOldVarInPromptItem(prompt, oldVarSelector, newVarSelector))
          if (payload.memory?.query_prompt_template) {
            payload.memory.query_prompt_template = replaceOldVarInText(
              payload.memory.query_prompt_template,
              oldVarSelector,
              newVarSelector,
            )
          }
        }
        else {
          payload.prompt_template = replaceOldVarInPromptItem(
            payload.prompt_template as PromptItem,
            oldVarSelector,
            newVarSelector,
          )
        }
        if (
          payload.context?.variable_selector?.join('.')
          === oldVarSelector.join('.')
        ) {
          payload.context.variable_selector = newVarSelector
        }

        break
      }
      case BlockEnum.KnowledgeRetrieval: {
        const payload = data as KnowledgeRetrievalNodeType
        if (
          payload.query_variable_selector.join('.') === oldVarSelector.join('.')
        )
          payload.query_variable_selector = newVarSelector
        if (
          payload.query_attachment_selector?.join('.') === oldVarSelector.join('.')
        )
          payload.query_attachment_selector = newVarSelector
        break
      }
      case BlockEnum.IfElse: {
        const payload = data as IfElseNodeType
        if (payload.cases) {
          payload.cases = payload.cases.map((caseItem) => {
            if (caseItem.conditions) {
              caseItem.conditions = caseItem.conditions.map((c) => {
                if (c.variable_selector?.join('.') === oldVarSelector.join('.'))
                  c.variable_selector = newVarSelector
                // Handle sub-variable conditions
                if (
                  c.sub_variable_condition
                  && c.sub_variable_condition.conditions
                ) {
                  c.sub_variable_condition.conditions
                    = c.sub_variable_condition.conditions.map((subC) => {
                      if (
                        subC.variable_selector?.join('.')
                        === oldVarSelector.join('.')
                      ) {
                        subC.variable_selector = newVarSelector
                      }
                      return subC
                    })
                }
                return c
              })
            }
            return caseItem
          })
        }
        break
      }
      case BlockEnum.Code: {
        const payload = data as CodeNodeType
        if (payload.variables) {
          payload.variables = payload.variables.map((v) => {
            if (v.value_selector.join('.') === oldVarSelector.join('.'))
              v.value_selector = newVarSelector
            return v
          })
        }
        break
      }
      case BlockEnum.TemplateTransform: {
        const payload = data as TemplateTransformNodeType
        if (payload.variables) {
          payload.variables = payload.variables.map((v: any) => {
            if (v.value_selector.join('.') === oldVarSelector.join('.'))
              v.value_selector = newVarSelector
            return v
          })
        }
        break
      }
      case BlockEnum.QuestionClassifier: {
        const payload = data as QuestionClassifierNodeType
        if (
          payload.query_variable_selector.join('.') === oldVarSelector.join('.')
        )
          payload.query_variable_selector = newVarSelector
        payload.instruction = replaceOldVarInText(
          payload.instruction,
          oldVarSelector,
          newVarSelector,
        )
        payload.classes = payload.classes.map(topic => ({
          ...topic,
          name: replaceOldVarInText(topic.name, oldVarSelector, newVarSelector),
        }))
        break
      }
      case BlockEnum.HttpRequest: {
        const payload = data as HttpNodeType
        payload.url = replaceOldVarInText(
          payload.url,
          oldVarSelector,
          newVarSelector,
        )
        payload.headers = replaceOldVarInText(
          payload.headers,
          oldVarSelector,
          newVarSelector,
        )
        payload.params = replaceOldVarInText(
          payload.params,
          oldVarSelector,
          newVarSelector,
        )
        if (typeof payload.body.data === 'string') {
          payload.body.data = replaceOldVarInText(
            payload.body.data,
            oldVarSelector,
            newVarSelector,
          )
        }
        else {
          payload.body.data = payload.body.data.map((d) => {
            return {
              ...d,
              value: replaceOldVarInText(
                d.value || '',
                oldVarSelector,
                newVarSelector,
              ),
            }
          })
        }
        break
      }
      case BlockEnum.Tool: {
        const payload = data as ToolNodeType
        const hasShouldRenameVar = Object.keys(payload.tool_parameters)?.filter(
          key => payload.tool_parameters[key]!.type !== ToolVarType.constant,
        )
        if (hasShouldRenameVar) {
          Object.keys(payload.tool_parameters).forEach((key) => {
            const value = payload.tool_parameters[key]!
            const { type } = value!
            if (
              type === ToolVarType.variable
              && value!.value.join('.') === oldVarSelector.join('.')
            ) {
              payload.tool_parameters[key] = {
                ...value,
                value: newVarSelector,
              }
            }

            if (type === ToolVarType.mixed) {
              payload.tool_parameters[key] = {
                ...value,
                value: replaceOldVarInText(
                  payload.tool_parameters[key]!.value as string,
                  oldVarSelector,
                  newVarSelector,
                ),
              }
            }
          })
        }
        break
      }
      case BlockEnum.DataSource: {
        const payload = data as DataSourceNodeType
        const hasShouldRenameVar = Object.keys(
          payload.datasource_parameters,
        )?.filter(
          key =>
            payload.datasource_parameters[key]!.type !== ToolVarType.constant,
        )
        if (hasShouldRenameVar) {
          Object.keys(payload.datasource_parameters).forEach((key) => {
            const value = payload.datasource_parameters[key]!
            const { type } = value!
            if (
              type === ToolVarType.variable
              && value!.value.join('.') === oldVarSelector.join('.')
            ) {
              payload.datasource_parameters[key] = {
                ...value,
                value: newVarSelector,
              }
            }

            if (type === ToolVarType.mixed) {
              payload.datasource_parameters[key] = {
                ...value,
                value: replaceOldVarInText(
                  payload.datasource_parameters[key]!.value as string,
                  oldVarSelector,
                  newVarSelector,
                ),
              }
            }
          })
        }
        break
      }
      case BlockEnum.Agent: {
        const payload = data as AgentNodeType
        if (payload.agent_parameters) {
          Object.keys(payload.agent_parameters).forEach((key) => {
            const value = payload.agent_parameters![key]!
            const { type } = value!

            if (
              type === ToolVarType.variable
              && Array.isArray(value!.value)
              && value!.value.join('.') === oldVarSelector.join('.')
            ) {
              payload.agent_parameters![key] = {
                ...value,
                value: newVarSelector,
              }
            }

            if (type === ToolVarType.mixed && typeof value!.value === 'string') {
              payload.agent_parameters![key] = {
                ...value,
                value: replaceOldVarInText(
                  value!.value,
                  oldVarSelector,
                  newVarSelector,
                ),
              }
            }
          })
        }

        if (payload.memory?.query_prompt_template) {
          payload.memory.query_prompt_template = replaceOldVarInText(
            payload.memory.query_prompt_template,
            oldVarSelector,
            newVarSelector,
          )
        }
        break
      }
      case BlockEnum.VariableAssigner: {
        const payload = data as VariableAssignerNodeType
        if (payload.variables) {
          payload.variables = payload.variables.map((v) => {
            if (v.join('.') === oldVarSelector.join('.'))
              v = newVarSelector
            return v
          })
        }
        break
      }

      case BlockEnum.VariableAggregator: {
        const payload = data as VariableAssignerNodeType
        if (payload.variables) {
          payload.variables = payload.variables.map((v) => {
            if (v.join('.') === oldVarSelector.join('.'))
              v = newVarSelector
            return v
          })
        }
        break
      }
      case BlockEnum.ParameterExtractor: {
        const payload = data as ParameterExtractorNodeType
        if (payload.query.join('.') === oldVarSelector.join('.'))
          payload.query = newVarSelector
        payload.instruction = replaceOldVarInText(
          payload.instruction,
          oldVarSelector,
          newVarSelector,
        )
        break
      }
      case BlockEnum.Iteration: {
        const payload = data as IterationNodeType
        if (payload.iterator_selector.join('.') === oldVarSelector.join('.'))
          payload.iterator_selector = newVarSelector

        break
      }
      case BlockEnum.Loop: {
        const payload = data as LoopNodeType
        if (payload.break_conditions) {
          payload.break_conditions = payload.break_conditions.map((c) => {
            if (c.variable_selector?.join('.') === oldVarSelector.join('.'))
              c.variable_selector = newVarSelector
            return c
          })
        }
        break
      }
      case BlockEnum.ListFilter: {
        const payload = data as ListFilterNodeType
        if (payload.variable.join('.') === oldVarSelector.join('.'))
          payload.variable = newVarSelector
        break
      }
      case BlockEnum.HumanInput: {
        const payload = data as HumanInputNodeType
        payload.form_content = replaceOldVarInText(
          payload.form_content,
          oldVarSelector,
          newVarSelector,
        )
        payload.delivery_methods = payload.delivery_methods.map((method) => {
          if (method.type !== DeliveryMethodType.Email || !method.config)
            return method

          return {
            ...method,
            config: {
              ...method.config,
              body: replaceOldVarInText(
                method.config.body,
                oldVarSelector,
                newVarSelector,
              ),
            },
          }
        })
        payload.inputs = payload.inputs.map((input) => {
          if (input.type === InputVarType.paragraph && input.default.type === 'variable' && input.default.selector.join('.') === oldVarSelector.join('.')) {
            input.default.selector = newVarSelector
          }
          if (input.type === InputVarType.select && input.option_source.type === 'variable' && input.option_source.selector.join('.') === oldVarSelector.join('.')) {
            input.option_source.selector = newVarSelector
          }
          return input
        })
        break
      }
    }
  })
  return newNode
}

const varToValueSelectorList = (
  v: Var,
  parentValueSelector: ValueSelector,
  res: ValueSelector[],
) => {
  if (!v.variable)
    return

  res.push([...parentValueSelector, v.variable])
  const isStructuredOutput = !!(v.children as StructuredOutput)?.schema?.properties

  if ((v.children as Var[])?.length > 0) {
    (v.children as Var[]).forEach((child) => {
      varToValueSelectorList(child, [...parentValueSelector, v.variable], res)
    })
  }
  if (isStructuredOutput) {
    Object.keys(
      (v.children as StructuredOutput)?.schema?.properties || {},
    ).forEach((key) => {
      const type = (v.children as StructuredOutput)?.schema?.properties[key]!.type
      const isArray = type === Type.array
      const arrayType = (v.children as StructuredOutput)?.schema?.properties[
        key
      ]!.items?.type
      varToValueSelectorList(
        {
          variable: key,
          type: structTypeToVarType(isArray ? arrayType! : type, isArray),
        },
        [...parentValueSelector, v.variable],
        res,
      )
    })
  }
}

const varsToValueSelectorList = (
  vars: Var | Var[],
  parentValueSelector: ValueSelector,
  res: ValueSelector[],
) => {
  if (Array.isArray(vars)) {
    vars.forEach((v) => {
      varToValueSelectorList(v, parentValueSelector, res)
    })
  }
  varToValueSelectorList(vars as Var, parentValueSelector, res)
}

export const getNodeOutputVars = (
  node: Node,
  isChatMode: boolean,
): ValueSelector[] => {
  const { data, id } = node
  const { type } = data
  let res: ValueSelector[] = []

  switch (type) {
    case BlockEnum.Start: {
      const { variables } = data as StartNodeType
      res = variables.map((v) => {
        return [id, v.variable]
      })

      if (isChatMode) {
        res.push([id, 'sys', 'query'])
        res.push([id, 'sys', 'files'])
      }
      break
    }

    case BlockEnum.LLM: {
      const vars = [...LLM_OUTPUT_STRUCT]
      const llmNodeData = data as LLMNodeType
      if (
        llmNodeData.structured_output_enabled
        && llmNodeData.structured_output?.schema?.properties
        && Object.keys(llmNodeData.structured_output.schema.properties).length > 0
      ) {
        vars.push({
          variable: 'structured_output',
          type: VarType.object,
          children: llmNodeData.structured_output,
        })
      }
      varsToValueSelectorList(vars, [id], res)
      break
    }

    case BlockEnum.KnowledgeRetrieval: {
      varsToValueSelectorList(KNOWLEDGE_RETRIEVAL_OUTPUT_STRUCT, [id], res)
      break
    }

    case BlockEnum.Code: {
      const { outputs } = data as CodeNodeType
      Object.keys(outputs).forEach((key) => {
        res.push([id, key])
      })
      break
    }

    case BlockEnum.TemplateTransform: {
      varsToValueSelectorList(TEMPLATE_TRANSFORM_OUTPUT_STRUCT, [id], res)
      break
    }

    case BlockEnum.QuestionClassifier: {
      varsToValueSelectorList(QUESTION_CLASSIFIER_OUTPUT_STRUCT, [id], res)
      break
    }

    case BlockEnum.HttpRequest: {
      varsToValueSelectorList(HTTP_REQUEST_OUTPUT_STRUCT, [id], res)
      break
    }

    case BlockEnum.VariableAssigner: {
      res.push([id, 'output'])
      break
    }

    case BlockEnum.VariableAggregator: {
      res.push([id, 'output'])
      break
    }

    case BlockEnum.Tool: {
      varsToValueSelectorList(TOOL_OUTPUT_STRUCT, [id], res)
      break
    }

    case BlockEnum.ParameterExtractor: {
      const { parameters } = data as ParameterExtractorNodeType
      if (parameters?.length > 0) {
        parameters.forEach((p) => {
          res.push([id, p.name])
        })
      }

      break
    }

    case BlockEnum.Iteration: {
      res.push([id, 'output'])
      break
    }

    case BlockEnum.Loop: {
      res.push([id, 'output'])
      break
    }

    case BlockEnum.DocExtractor: {
      res.push([id, 'text'])
      break
    }

    case BlockEnum.ListFilter: {
      res.push([id, 'result'])
      res.push([id, 'first_record'])
      res.push([id, 'last_record'])
      break
    }
  }

  return res
}
