Function lazyCleanupInputMapping

apps/sim/executor/utils/lazy-cleanup.ts:36–89

(
  parentWorkflowId: string,
  parentBlockId: string,
  currentInputMapping: any,
  childWorkflowBlocks: Record<string, any>
)

 * @returns The cleaned inputMapping (only different if cleanup was needed)
 */
export async function lazyCleanupInputMapping(
  parentWorkflowId: string,
  parentBlockId: string,
  currentInputMapping: any,
  childWorkflowBlocks: Record<string, any>
): Promise<any> {
  try {
    if (
      !currentInputMapping ||
      typeof currentInputMapping !== 'object' ||
      Array.isArray(currentInputMapping)
    ) {
      return currentInputMapping
    }

    const validFieldNames = extractValidInputFieldNames(childWorkflowBlocks)

    if (!validFieldNames || validFieldNames.size === 0) {
      logger.debug('Child workflow has no inputFormat fields, skipping cleanup')
      return currentInputMapping
    }

    const orphanedFields: string[] = []
    for (const fieldName of Object.keys(currentInputMapping)) {
      if (!validFieldNames.has(fieldName)) {
        orphanedFields.push(fieldName)
      }
    }

    if (orphanedFields.length === 0) {
      return currentInputMapping
    }

    const cleanedMapping: Record<string, any> = {}
    for (const [fieldName, fieldValue] of Object.entries(currentInputMapping)) {
      if (validFieldNames.has(fieldName)) {
        cleanedMapping[fieldName] = fieldValue
      }
    }

    logger.info(
      `Lazy cleanup: Removing ${orphanedFields.length} orphaned field(s) from inputMapping in workflow ${parentWorkflowId}, block ${parentBlockId}: ${orphanedFields.join(', ')}`
    )

    persistCleanedMapping(parentWorkflowId, parentBlockId, cleanedMapping).catch((error) => {
      logger.error('Failed to persist cleaned inputMapping:', error)
    })

    return cleanedMapping
  } catch (error) {
    logger.error('Error in lazy cleanup:', error)
    return currentInputMapping
  }
}

/**
 * Persist the cleaned inputMapping to the database