dify/web/app/components/workflow/nodes/assigner/utils.ts

import type { AssignerNodeOperation, AssignerNodeType } from './types'
import type { I18nKeysByPrefix } from '@/types/i18n'
import { AssignerNodeInputType, WriteMode } from './types'

export type OperationName = I18nKeysByPrefix<'workflow', 'nodes.assigner.operations.'>

export type Item
  = | { value: 'divider', name: 'divider' }
    | { value: string | number, name: OperationName }

export function isOperationItem(item: Item): item is { value: string | number, name: OperationName } {
  return item.value !== 'divider'
}

export const getOperationItems = (
  assignedVarType?: string,
  writeModeTypes?: WriteMode[],
  writeModeTypesArr?: WriteMode[],
  writeModeTypesNum?: WriteMode[],
): Item[] => {
  if (assignedVarType?.startsWith('array') && writeModeTypesArr) {
    return writeModeTypesArr.map(type => ({
      value: type,
      name: type,
    }))
  }

  if (assignedVarType === 'number' && writeModeTypes && writeModeTypesNum) {
    return [
      ...writeModeTypes.map(type => ({
        value: type,
        name: type,
      })),
      { value: 'divider', name: 'divider' } as Item,
      ...writeModeTypesNum.map(type => ({
        value: type,
        name: type,
      })),
    ]
  }

  if (writeModeTypes && ['string', 'boolean', 'object'].includes(assignedVarType || '')) {
    return writeModeTypes.map(type => ({
      value: type,
      name: type,
    }))
  }

  return []
}

const convertOldWriteMode = (oldMode: string): WriteMode => {
  switch (oldMode) {
    case 'over-write':
      return WriteMode.overwrite
    case 'append':
      return WriteMode.append
    case 'clear':
      return WriteMode.clear
    default:
      return WriteMode.overwrite
  }
}

const normalizeVariableSelector = (value: unknown) => {
  return Array.isArray(value) ? value : []
}

export const normalizeOperationItems = (items: unknown): AssignerNodeOperation[] => {
  if (!Array.isArray(items))
    return []

  return items.map((item) => {
    const operationItem = (item || {}) as Partial<AssignerNodeOperation>
    const inputType = operationItem.input_type === AssignerNodeInputType.constant
      ? AssignerNodeInputType.constant
      : AssignerNodeInputType.variable

    return {
      variable_selector: normalizeVariableSelector(operationItem.variable_selector),
      input_type: inputType,
      operation: Object.values(WriteMode).includes(operationItem.operation as WriteMode)
        ? operationItem.operation as WriteMode
        : WriteMode.overwrite,
      value: inputType === AssignerNodeInputType.variable
        ? normalizeVariableSelector(operationItem.value)
        : operationItem.value,
    }
  })
}

export const convertV1ToV2 = (payload: any): AssignerNodeType => {
  if (payload.version === '2' && payload.items) {
    return {
      ...payload,
      items: normalizeOperationItems(payload.items),
    } as AssignerNodeType
  }

  return {
    ...payload,
    version: '2',
    items: normalizeOperationItems([{
      variable_selector: payload.assigned_variable_selector || [],
      input_type: AssignerNodeInputType.variable,
      operation: convertOldWriteMode(payload.write_mode),
      value: payload.input_variable_selector || [],
    }]),
  }
}