Function getLambdaOptionsFromFunction

packages/build-utils/src/lambda.ts:528–594

({
  sourceFile,
  config,
}: GetLambdaOptionsFromFunctionOptions)

}

export async function getLambdaOptionsFromFunction({
  sourceFile,
  config,
}: GetLambdaOptionsFromFunctionOptions): Promise<
  Pick<
    LambdaOptions,
    | 'architecture'
    | 'memory'
    | 'maxDuration'
    | 'regions'
    | 'functionFailoverRegions'
    | 'experimentalTriggers'
    | 'supportsCancellation'
  >
> {
  if (config?.functions) {
    // `pattern` is service-root-relative, so two services sharing a function
    // path would derive the same consumer; scope it by service name.
    const serviceName =
      typeof config.serviceName === 'string' && config.serviceName !== ''
        ? config.serviceName
        : undefined;
    for (const [pattern, fn] of Object.entries(config.functions)) {
      if (sourceFile === pattern || minimatch(sourceFile, pattern)) {
        const consumer = sanitizeConsumerName(
          serviceName ? `${serviceName}~${pattern}` : pattern
        );
        const experimentalTriggers: TriggerEvent[] | undefined =
          fn.experimentalTriggers?.map(
            (trigger: TriggerEventInput): TriggerEvent => {
              if (trigger.type === 'queue/v2beta') {
                return {
                  ...trigger,
                  consumer,
                };
              }
              return trigger;
            }
          );

        // User-configured functions can only have one v2beta trigger.
        // Services may attach multiple triggers programmatically.
        if (
          experimentalTriggers &&
          experimentalTriggers.length > 1 &&
          experimentalTriggers.some(t => t.type === 'queue/v2beta')
        ) {
          throw new Error(
            `functions["${pattern}"].experimentalTriggers can only have one item for queue/v2beta`
          );
        }

        return {
          architecture: fn.architecture,
          memory: fn.memory,
          maxDuration: fn.maxDuration,
          regions: fn.regions,
          functionFailoverRegions: fn.functionFailoverRegions,