Function resolveArrayInputAsync

apps/sim/executor/utils/subflow-utils.server.ts:76–127

(
  ctx: ExecutionContext,
  items: any,
  resolver: VariableResolver | null,
  currentNodeId = ''
)

 * execution values that cannot be imported into client-reachable utilities.
 */
export async function resolveArrayInputAsync(
  ctx: ExecutionContext,
  items: any,
  resolver: VariableResolver | null,
  currentNodeId = ''
): Promise<any[]> {
  if (typeof items !== 'string') {
    if (items === null) {
      return []
    }
    if (!Array.isArray(items) && typeof items !== 'object') {
      if (!resolver) {
        return []
      }
      try {
        const resolved = (await resolver.resolveInputs(ctx, currentNodeId, { items })).items
        return normalizeCollectionValue(ctx, resolved)
      } catch (error) {
        if (error instanceof Error && error.message.startsWith('Resolved items')) {
          throw error
        }
        throw new Error(`Failed to resolve items: ${toError(error).message}`)
      }
    }
    return normalizeCollectionValue(ctx, items)
  }

  if (items.startsWith(REFERENCE.START) && items.endsWith(REFERENCE.END) && resolver) {
    try {
      const resolved = await resolver.resolveSingleReference(ctx, currentNodeId, items, undefined, {
        allowLargeValueRefs: true,
      })
      return normalizeCollectionValue(ctx, resolved)
    } catch (error) {
      if (error instanceof Error && error.message.startsWith('Reference "')) {
        throw error
      }
      throw new Error(`Failed to resolve reference "${items}": ${toError(error).message}`)
    }
  }

  try {
    const normalized = items.replace(/'/g, '"')
    const parsed = JSON.parse(normalized)
    return normalizeCollectionValue(ctx, parsed)
  } catch (error) {
    if (error instanceof Error && error.message.startsWith('Parsed value')) {
      throw error
    }
    throw new Error(`Failed to parse items as JSON: "${items}"`)
  }
}