Function resolveBlockReferenceAsync

apps/sim/executor/utils/block-reference.ts:251–284

(
  blockName: string,
  pathParts: string[],
  context: BlockReferenceContext,
  resolutionContext: ResolutionContext,
  navigatePathAsync: AsyncPathNavigator
)

}

export async function resolveBlockReferenceAsync(
  blockName: string,
  pathParts: string[],
  context: BlockReferenceContext,
  resolutionContext: ResolutionContext,
  navigatePathAsync: AsyncPathNavigator
): Promise<BlockReferenceResult | undefined> {
  const normalizedName = normalizeName(blockName)
  const blockId = context.blockNameMapping[normalizedName]

  if (!blockId) {
    return undefined
  }

  const blockOutput = context.blockData[blockId]
  if (blockOutput === undefined) {
    return { value: undefined, blockId }
  }

  if (pathParts.length === 0) {
    return { value: blockOutput, blockId }
  }

  const value = await navigatePathAsync(blockOutput, pathParts, resolutionContext)

  const schema = context.blockOutputSchemas?.[blockId]
  if (value === undefined && schema) {
    if (!isPathInSchema(schema, pathParts)) {
      throw new InvalidFieldError(blockName, pathParts.join('.'), getSchemaFieldNames(schema))
    }
  }

  return { value, blockId }
}