serverless/lib/plugins/aws/invoke-local/index.js

import _ from 'lodash'
import os from 'os'
import { promises as fsp, write } from 'fs'
import path from 'path'
import stripAnsi from 'strip-ansi'
import validate from '../lib/validate.js'
import stdin from 'get-stdin'
import { fileURLToPath, pathToFileURL } from 'url'
import spawnExt from 'child-process-ext/spawn.js'
import { spawn, exec } from 'child_process'
import { inspect, promisify } from 'util'
import download from '@serverless/utils/download.js'
import { ensureDir, copy } from 'fs-extra'
import cachedir from 'cachedir'
import decompress from 'decompress'
import { v4 as uuidv4 } from 'uuid'
import ServerlessError from '../../../serverless-error.js'
import dirExists from '../../../utils/fs/dir-exists.js'
import fileExists from '../../../utils/fs/file-exists.js'
import resolveCfImportValue from '../utils/resolve-cf-import-value.js'
import resolveCfRefValue from '../utils/resolve-cf-ref-value.js'
import utils from '@serverlessinc/sf-core/src/utils.js'
import { setTimeout } from 'timers/promises'

const execP = promisify(exec)

let __dirname = path.dirname(fileURLToPath(import.meta.url))
if (__dirname.endsWith('dist')) {
  __dirname = path.join(__dirname, '../lib/plugins/aws/invoke-local')
}

const { log, progress, writeText } = utils

const cachePath = path.join(cachedir('serverless'), 'invokeLocal')

const mainProgress = progress.get('main')
const dockerProgress = progress.get('invokeLocalDocker')

const ensureRuntimeWrappers = () => __dirname

/**
 * @param {string} runtime
 */
const getLambdaCiImageUriFromRuntime = (runtime) => {
  if (runtime.startsWith('python')) {
    const version = runtime.replace('python', '')
    return `public.ecr.aws/lambda/python:${version}`
  } else if (runtime.startsWith('nodejs')) {
    const version = runtime.replace('nodejs', '').replace('.x', '')
    return `public.ecr.aws/lambda/nodejs:${version}`
  } else if (runtime.startsWith('java')) {
    const version = runtime.replace('java', '')
    return `public.ecr.aws/lambda/java:${version}`
  } else if (runtime.startsWith('ruby')) {
    const version = runtime.replace('ruby', '')
    return `public.ecr.aws/lambda/ruby:${version}`
  } else if (runtime.startsWith('dotnet')) {
    const version = runtime.replace('dotnet', '')
    return `public.ecr.aws/lambda/dotnet:${version}`
  } else if (runtime.startsWith('provided')) {
    const version = runtime.replace('provided.', '')
    return `public.ecr.aws/lambda/provided:${version}`
  }
  return undefined
}

class AwsInvokeLocal {
  constructor(serverless, options, pluginUtils) {
    this.serverless = serverless
    this.options = options || {}
    this.provider = this.serverless.getProvider('aws')
    this.progress = pluginUtils.progress
    this.logger = pluginUtils.log

    Object.assign(this, validate)

    this.hooks = {
      'before:invoke:local:loadEnvVars': async () => {
        await this.extendedValidate()
        await this.loadEnvVars()
      },
      'invoke:local:invoke': async () => this.invokeLocal(),
    }
  }

  getRuntime() {
    return this.provider.getRuntime(this.options.functionObj.runtime)
  }

  async resolveRuntimeWrapperPath(filename) {
    const artifactsPath = await ensureRuntimeWrappers()
    return path.resolve(artifactsPath, 'runtime-wrappers', filename)
  }

  async validateFile(filePath, key) {
    const absolutePath = path.isAbsolute(filePath)
      ? filePath
      : path.join(this.serverless.serviceDir, filePath)

    const exists = await fileExists(absolutePath)

    if (!exists) {
      throw new ServerlessError(
        `The file you provided does not exist: ${absolutePath}`,
        'INVOKE_LOCAL_MISSING_FILE',
      )
    }
    if (absolutePath.endsWith('.js')) {
      // to support js - export as an input data
      this.options[key] = await import(absolutePath)
      return
    }
    const contents = await (async () => {
      try {
        return await this.serverless.utils.readFile(absolutePath)
      } catch (error) {
        throw new ServerlessError(
          `Parsing of "${absolutePath}" failed with: ${error.message}`,
          'INVOKE_LOCAL_INVALID_FILE_CONTENT',
        )
      }
    })()
    this.options[key] = contents
  }

  async extendedValidate() {
    this.validate()
    // validate function exists in service
    this.options.functionObj = this.serverless.service.getFunction(
      this.options.function,
    )
    this.options.data = this.options.data || ''

    if (this.options.functionObj.image) {
      throw new ServerlessError(
        'Local invocation of lambdas pointing AWS ECR images is not supported',
        'INVOKE_LOCAL_IMAGE_BACKED_FUNCTIONS_NOT_SUPPORTED',
      )
    }
    if (this.options.contextPath) {
      await this.validateFile(this.options.contextPath, 'context')
    }

    if (!this.options.data) {
      if (this.options.path) {
        await this.validateFile(this.options.path, 'data')
      } else {
        try {
          this.options.data = await stdin()
        } catch {
          // continue if no stdin was provided
        }
      }
    }

    try {
      // unless asked to preserve raw input, attempt to parse any provided objects
      if (!this.options.raw) {
        if (this.options.data) {
          this.options.data = JSON.parse(this.options.data)
        }
        if (this.options.context) {
          this.options.context = JSON.parse(this.options.context)
        }
      }
    } catch (exception) {
      // do nothing if it's a simple string or object already
    }
  }

  async getCredentialEnvVars() {
    const credentialEnvVars = {}
    try {
      const credentials = await this.provider.getCredentials()
      if (credentials) {
        if (credentials.accessKeyId) {
          credentialEnvVars.AWS_ACCESS_KEY_ID = credentials.accessKeyId
        }
        if (credentials.secretAccessKey) {
          credentialEnvVars.AWS_SECRET_ACCESS_KEY = credentials.secretAccessKey
        }
        if (credentials.sessionToken) {
          credentialEnvVars.AWS_SESSION_TOKEN = credentials.sessionToken
        }
      }
    } catch (error) {
      this.logger.debug('Ignoring error while loading AWS credentials:', error)
      // ignore errors if credentials are unavailable
      // since they are not required for local invocation
    }
    return credentialEnvVars
  }

  getConfiguredEnvVars() {
    const providerEnvVars = this.serverless.service.provider.environment || {}
    const functionEnvVars = this.options.functionObj.environment || {}
    const mergedVars = _.merge(providerEnvVars, functionEnvVars)
    return Object.keys(mergedVars)
      .filter((k) => mergedVars[k] != null)
      .reduce((m, k) => {
        m[k] = mergedVars[k]
        return m
      }, {})
  }

  async resolveConfiguredEnvVars(configuredEnvVars) {
    await Promise.all(
      Object.entries(configuredEnvVars).map(async ([name, value]) => {
        if (!_.isObject(value)) return
        try {
          if (value['Fn::ImportValue']) {
            configuredEnvVars[name] = await resolveCfImportValue(
              this.provider,
              value['Fn::ImportValue'],
            )
          } else if (value.Ref) {
            configuredEnvVars[name] = await resolveCfRefValue(
              this.provider,
              value.Ref,
            )
          } else {
            throw new ServerlessError(
              `Unsupported environment variable format: ${inspect(value)}`,
              'INVOKE_LOCAL_UNSUPPORTED_ENV_VARIABLE',
            )
          }
        } catch (error) {
          throw new ServerlessError(
            `Could not resolve "${name}" environment variable: ${error.message}`,
            'INVOKE_LOCAL_INVALID_ENV_VARIABLE',
          )
        }
      }),
    )

    return configuredEnvVars
  }

  async loadEnvVars() {
    const lambdaName = this.options.functionObj.name
    const memorySize =
      Number(this.options.functionObj.memorySize) ||
      Number(this.serverless.service.provider.memorySize) ||
      1024

    const lambdaDefaultEnvVars = {
      LANG: 'en_US.UTF-8',
      LD_LIBRARY_PATH:
        '/usr/local/lib64/node-v4.3.x/lib:/lib64:/usr/lib64:/var/runtime:/var/runtime/lib:/var/task:/var/task/lib',
      LAMBDA_TASK_ROOT: '/var/task',
      LAMBDA_RUNTIME_DIR: '/var/runtime',
      AWS_REGION: this.provider.getRegion(),
      AWS_DEFAULT_REGION: this.provider.getRegion(),
      AWS_LAMBDA_LOG_GROUP_NAME:
        this.provider.naming.getLogGroupName(lambdaName),
      AWS_LAMBDA_LOG_STREAM_NAME:
        '2016/12/02/[$LATEST]f77ff5e4026c45bda9a9ebcec6bc9cad',
      AWS_LAMBDA_FUNCTION_NAME: lambdaName,
      AWS_LAMBDA_FUNCTION_MEMORY_SIZE: memorySize,
      AWS_LAMBDA_FUNCTION_VERSION: '$LATEST',
      NODE_PATH: '/var/runtime:/var/task:/var/runtime/node_modules',
    }

    const credentialEnvVars = await this.getCredentialEnvVars()

    // profile override from config
    const profileOverride = this.provider.getProfile()
    if (profileOverride) {
      lambdaDefaultEnvVars.AWS_PROFILE = profileOverride
    }

    const configuredEnvVars = await this.resolveConfiguredEnvVars(
      this.getConfiguredEnvVars(),
    )

    _.merge(
      process.env,
      lambdaDefaultEnvVars,
      credentialEnvVars,
      configuredEnvVars,
    )
  }

  async invokeLocal() {
    const runtime = this.getRuntime()

    // Advertise Dev Mode sparingly, and for Node.js functions only
    if (runtime.includes('node') && Math.random() < 0.1) {
      log.warning(
        'For a better experience than "invoke local", try "serverless dev" to route events from your live architecture to your local code, allowing you to make quick changes without deployment - https://www.serverless.com/framework/docs/providers/aws/cli-reference/dev',
      )
      log.blankLine()
    }

    this.progress.remove()
    // const runtime = this.getRuntime()
    const handler = this.options.functionObj.handler

    if (this.options.docker) {
      return this.invokeLocalDocker()
    }

    if (runtime.startsWith('nodejs')) {
      const handlerSeparatorIndex = handler.lastIndexOf('.')
      const handlerPath = handler.slice(0, handlerSeparatorIndex)
      const handlerName = handler.slice(handlerSeparatorIndex + 1)
      return this.invokeLocalNodeJs(
        handlerPath,
        handlerName,
        this.options.data,
        this.options.context,
      )
    }

    if (
      [
        'python3.7',
        'python3.8',
        'python3.9',
        'python3.10',
        'python3.11',
        'python3.12',
        'python3.13',
      ].includes(runtime)
    ) {
      const handlerComponents = handler.split(/\./)
      const handlerPath = handlerComponents.slice(0, -1).join('.')
      const handlerName = handlerComponents.pop()
      return this.invokeLocalPython(
        process.platform === 'win32' ? 'python.exe' : runtime,
        handlerPath,
        handlerName,
        this.options.data,
        this.options.context,
      )
    }

    if (['java8', 'java11', 'java17', 'java21'].includes(runtime)) {
      const className = handler.split('::')[0]
      const handlerName = handler.split('::')[1] || 'handleRequest'
      const artifact =
        this.options.package && this.options.package.artifact
          ? this.options.package.artifact
          : this.serverless.service.package.artifact
      return this.invokeLocalJava(
        'java',
        className,
        handlerName,
        artifact,
        this.options.data,
        this.options.context,
      )
    }

    if (['ruby2.7', 'ruby3.2'].includes(runtime)) {
      const handlerComponents = handler.split(/\./)
      const handlerPath = handlerComponents[0]
      const handlerName = handlerComponents.slice(1).join('.')
      return this.invokeLocalRuby(
        process.platform === 'win32' ? 'ruby.exe' : 'ruby',
        handlerPath,
        handlerName,
        this.options.data,
        this.options.context,
      )
    }

    return this.invokeLocalDocker()
  }

  async checkDockerDaemonStatus() {
    try {
      return await spawnExt('docker', ['version'])
    } catch {
      throw new ServerlessError(
        'Please start the Docker daemon to use the invoke local Docker integration.',
        'DOCKER_DAEMON_NOT_FOUND',
      )
    }
  }

  async checkDockerImage(imageName) {
    if (!imageName) return false
    const { stdoutBuffer } = await spawnExt('docker', [
      'images',
      '-q',
      imageName,
    ])
    return Boolean(stdoutBuffer.toString().trim())
  }

  async pullDockerImage() {
    const runtime = this.getRuntime()
    const imageUri = getLambdaCiImageUriFromRuntime(runtime)

    dockerProgress.notice('Downloading base Docker image')
    return spawnExt('docker', ['pull', imageUri])
  }

  async getLayerPaths() {
    const layers = _.mapKeys(this.serverless.service.layers, (value, key) =>
      this.provider.naming.getLambdaLayerLogicalId(key),
    )

    return Promise.all(
      (
        this.options.functionObj.layers ||
        this.serverless.service.provider.layers ||
        []
      ).map(async (layer) => {
        const layerProgress = progress.get(`layer:${layer}`)
        if (layer.Ref) {
          const targetLayer = layers[layer.Ref]

          if (targetLayer.path) {
            return targetLayer.path
          }
          if (targetLayer.package && targetLayer.package.artifact) {
            const layerArtifactContentPath = path.join(
              '.serverless',
              'layers',
              layer.Ref,
            )
            const exists = await dirExists(layerArtifactContentPath)
            if (exists) {
              return layerArtifactContentPath
            }
            layerProgress.notice(`Unzipping ${layer.Ref}`)
            await decompress(
              targetLayer.package.artifact,
              layerArtifactContentPath,
            )
            return layerArtifactContentPath
          }
        }
        const arnParts = layer.split(':')
        const layerArn = arnParts.slice(0, -1).join(':')
        const layerVersion = Number(arnParts.slice(-1)[0])
        const layerContentsPath = path.join(
          '.serverless',
          'layers',
          arnParts[6],
          arnParts[7],
        )
        const layerContentsCachePath = path.join(
          cachePath,
          'layers',
          arnParts[6],
          arnParts[7],
        )

        const exists = await dirExists(layerContentsPath)

        if (!exists) {
          const cacheExists = await dirExists(layerContentsCachePath)
          if (!cacheExists) {
            layerProgress.notice(`Downloading layer ${layer}`)
            await ensureDir(path.join(layerContentsCachePath))

            const layerInfo = await this.provider.request(
              'Lambda',
              'getLayerVersion',
              {
                LayerName: layerArn,
                VersionNumber: layerVersion,
              },
            )

            await download(layerInfo.Content.Location, layerContentsCachePath, {
              extract: true,
            })
          }
        }
        await copy(layerContentsCachePath, layerContentsPath)
        layerProgress.remove()
        return layerContentsPath
      }),
    )
  }

  getDockerImageName() {
    return `sls-docker-${this.getRuntime()}`
  }

  async buildDockerImage(layerPaths) {
    const runtime = this.getRuntime()
    const imageName = this.getDockerImageName()
    const imageUri = getLambdaCiImageUriFromRuntime(runtime)

    let dockerFileContent = `FROM ${imageUri}`
    for (const layerPath of layerPaths) {
      dockerFileContent += `\nADD --chown=sbx_user1051:495 ${
        os.platform() === 'win32' ? layerPath.replace(/\\/g, '/') : layerPath
      } /opt`
    }

    const dockerfilePath = path.join(
      '.serverless',
      'invokeLocal',
      runtime,
      'Dockerfile',
    )
    const dockerfileCachePath = path.join(
      cachePath,
      'dockerfiles',
      runtime,
      'Dockerfile',
    )

    if (await fileExists(dockerfileCachePath)) {
      const contents = await fsp.readFile(dockerfileCachePath)

      if (contents.toString() === dockerFileContent) {
        if (await this.checkDockerImage(imageName)) return imageName
      }
    }

    await Promise.all([
      ensureDir(path.join('.serverless', 'invokeLocal', runtime)),
      ensureDir(path.join(cachePath, 'dockerfiles', runtime)),
    ])

    dockerProgress.notice('Writing Dockerfile')
    await Promise.all([
      fsp.writeFile(dockerfilePath, dockerFileContent),
      fsp.writeFile(dockerfileCachePath, dockerFileContent),
    ])

    dockerProgress.notice('Building Docker image')
    try {
      await spawnExt('docker', [
        'build',
        '-t',
        imageName,
        `${this.serverless.serviceDir}`,
        '-f',
        dockerfilePath,
      ])
      return imageName
    } catch (err) {
      if (err.stdBuffer) {
        log.info(stripAnsi(err.stdBuffer.toString().trimRight()))
      }
      throw new ServerlessError(
        `Failed to build docker image (exit code ${err.code}})`,
        'DOCKER_IMAGE_BUILD_FAILED',
      )
    } finally {
      dockerProgress.remove()
    }
  }

  async extractArtifact() {
    const artifact = _.get(
      this.options.functionObj,
      'package.artifact',
      _.get(this.serverless.service, 'package.artifact'),
    )
    if (!artifact) {
      return this.serverless.serviceDir
    }
    const destination = path.join(
      this.serverless.serviceDir,
      '.serverless',
      'invokeLocal',
      'artifact',
    )
    // Workaround for https://github.com/serverless/serverless/issues/6028
    // Java zip/jar implementation doesn't preserve file permissions in a zip file.
    // https://bugs.openjdk.java.net/browse/JDK-6194856
    // So we follow Java's way in java.util.zip.ZipEntry#isDirectory() to detect directory.
    const artifactFiles = await decompress(artifact, destination, {
      filter: (file) => !file.path.endsWith('/'),
    })
    // Wrong permissions are used for rust artifacts in the following stages:
    // 1. Artifact creation: https://github.com/softprops/serverless-rust/pull/115
    // 2. Artifact extraction: seems like an issue in decompress package
    // As a workaround, we are making sure the rust executable has the correct permissions
    await Promise.all(
      artifactFiles
        .filter((file) => file.path === 'bootstrap')
        .map((file) => fsp.chmod(path.join(destination, file.path), '755')),
    )
    return destination
  }

  getEnvVarsFromOptions() {
    // Get the env vars from command line options in the form of --env KEY=value
    const envVarsFromOptions = {}
    for (const envOption of [].concat(this.options.env || [])) {
      const [varName, ...varRest] = envOption.split('=')
      const varValue = varRest.join('=')
      envVarsFromOptions[varName] = varValue
    }
    return envVarsFromOptions
  }

  async ensurePackage() {
    if (this.options['skip-package']) {
      try {
        await fsp.access(
          path.join(
            this.serverless.serviceDir,
            '.serverless',
            'serverless-state.json',
          ),
        )
        return
      } catch {
        // Missing state file. Need to repackage.
      }
    }
    await this.serverless.pluginManager.spawn('package')
  }

  async invokeLocalDocker() {
    await this.ensurePackage()

    const handler = this.options.functionObj.handler
    const runtime = this.getRuntime()
    const imageUri = getLambdaCiImageUriFromRuntime(runtime)

    mainProgress.notice('Invoking function locally', { isMainEvent: true })
    await this.checkDockerDaemonStatus()
    const results = await Promise.all([
      this.checkDockerImage(imageUri).then((exists) => {
        return exists ? {} : this.pullDockerImage()
      }),
      this.getLayerPaths().then((layerPaths) =>
        this.buildDockerImage(layerPaths),
      ),
      this.extractArtifact(),
    ])
    const imageName = results[1]
    const artifactPath = results[2]

    const lambdaName = this.options.functionObj.name
    const memorySize =
      Number(this.options.functionObj.memorySize) ||
      Number(this.serverless.service.provider.memorySize) ||
      1024
    const lambdaDefaultEnvVars = {
      AWS_REGION: this.provider.getRegion(),
      AWS_DEFAULT_REGION: this.provider.getRegion(),
      AWS_LAMBDA_LOG_GROUP_NAME:
        this.provider.naming.getLogGroupName(lambdaName),
      AWS_LAMBDA_FUNCTION_NAME: lambdaName,
      AWS_LAMBDA_FUNCTION_MEMORY_SIZE: memorySize,
    }
    const credentialEnvVars = await this.getCredentialEnvVars()
    const configuredEnvVars = await this.resolveConfiguredEnvVars(
      this.getConfiguredEnvVars(),
    )
    const envVarsFromOptions = this.getEnvVarsFromOptions()
    const envVars = _.merge(
      lambdaDefaultEnvVars,
      credentialEnvVars,
      configuredEnvVars,
      envVarsFromOptions,
    )

    const envVarsDockerArgs = Object.entries(envVars).flatMap(
      (currentValue) => ['--env', `${currentValue[0]}=${currentValue[1]}`],
    )

    const dockerArgsFromOptions = this.getDockerArgsFromOptions()
    const dockerArgs = [
      'run',
      '--rm',
      '-v',
      `${artifactPath}:/var/task:ro,delegated`,
    ].concat(envVarsDockerArgs, dockerArgsFromOptions, [
      '--name',
      `sls-docker-${handler}`,
      `-p`,
      ':8080',
      '-d',
      imageName,
      handler,
    ])

    try {
      await spawnExt('docker', dockerArgs)

      const { stdout } = await execP(`docker port sls-docker-${handler}`)
      const splitLine = stdout.split('\n')[0].split(':')
      if (splitLine.length === 2) {
        const port = parseInt(splitLine[1])
        await setTimeout(250)

        const res = await fetch(
          `http://localhost:${port}/2015-03-31/functions/function/invocations`,
          {
            method: 'POST',
            headers: {
              'Content-Type': 'application/json',
            },
            body: JSON.stringify({
              payload: JSON.stringify(this.options.data),
            }),
          },
        )
        const body = await res.text()
        writeText(stripAnsi(body.trimEnd()))
      } else {
        throw new Error('Image did not start correctly')
      }

      return imageName
    } catch (err) {
      if (err.stdBuffer) {
        writeText(stripAnsi(err.stdBuffer.toString().trimRight()))
      }
      throw new ServerlessError(
        `Failed to run docker for ${runtime} image (exit code ${err.code}})`,
        'DOCKER_IMAGE_RUN_FAILED',
      )
    } finally {
      try {
        await execP(`docker stop sls-docker-${handler}`)
      } catch (e) {
        /** ignore */
      }
    }
  }

  getDockerArgsFromOptions() {
    const dockerArgOptions = this.options['docker-arg']
    return [].concat(dockerArgOptions || []).flatMap((dockerArgOption) => {
      const splitItems = dockerArgOption.split(' ')
      return [splitItems[0], splitItems.slice(1).join(' ')]
    })
  }

  async invokeLocalPython(runtime, handlerPath, handlerName, event, context) {
    const input = JSON.stringify({
      event: event || {},
      context: Object.assign(
        {
          name: this.options.functionObj.name,
          version: 'LATEST',
          logGroupName: this.provider.naming.getLogGroupName(
            this.options.functionObj.name,
          ),
          timeout:
            Number(this.options.functionObj.timeout) ||
            Number(this.serverless.service.provider.timeout) ||
            6,
        },
        context,
      ),
    })

    if (process.env.VIRTUAL_ENV) {
      const runtimeDir = os.platform() === 'win32' ? 'Scripts' : 'bin'
      process.env.PATH = [
        path.join(process.env.VIRTUAL_ENV, runtimeDir),
        path.delimiter,
        process.env.PATH,
      ].join('')
    }

    const wrapperPath = await this.resolveRuntimeWrapperPath('invoke.py')

    return new Promise((resolve) => {
      const python = spawnExt(
        runtime.split('.')[0],
        ['-u', wrapperPath, handlerPath, handlerName],
        {
          env: process.env,
        },
      )
      python.stdout.on('data', (buf) => {
        writeText(buf.toString())
      })
      python.stderr.on('data', (buf) => {
        writeText(buf.toString())
      })

      python.child.stdin.write(input)
      python.child.stdin.end()

      resolve(python)
    })
  }

  async callJavaBridge(artifactPath, className, handlerName, input) {
    const wrapperPath = await this.resolveRuntimeWrapperPath(
      'java/target/invoke-bridge-1.0.1.jar',
    )
    return new Promise((resolve, reject) => {
      const java = spawn(
        'java',
        [
          `-DartifactPath=${artifactPath}`,
          `-DclassName=${className}`,
          `-DhandlerName=${handlerName}`,
          '-jar',
          wrapperPath,
        ],
        { shell: true },
      )

      log.warning(
        'In order to get human-readable output, please implement "toString()" method of your "ApiGatewayResponse" object.',
      )

      java.stdout.on('data', (buf) => {
        writeText(buf.toString())
      })
      java.stderr.on('data', (buf) => {
        writeText(buf.toString())
      })
      java.on('close', () => resolve())
      let isRejected = false
      java.on('error', (error) => {
        isRejected = true
        reject(error)
      })

      process.nextTick(() => {
        if (isRejected) return // Runtime not available
        java.stdin.write(input)
        java.stdin.end()
      })
    })
  }

  async invokeLocalJava(
    runtime,
    className,
    handlerName,
    artifactPath,
    event,
    customContext,
  ) {
    try {
      await fsp.stat(artifactPath)
    } catch {
      throw new ServerlessError(
        `Artifact ${artifactPath} doesn't exists, please compile it first.`,
        'JAVA_ARTIFACT_NOT_FOUND',
      )
    }
    const timeout =
      Number(this.options.functionObj.timeout) ||
      Number(this.serverless.service.provider.timeout) ||
      6
    const context = {
      name: this.options.functionObj.name,
      version: 'LATEST',
      logGroupName: this.provider.naming.getLogGroupName(
        this.options.functionObj.name,
      ),
      timeout,
    }
    const input = JSON.stringify({
      event: event || {},
      context: customContext || context,
    })
    const javaBridgePath = await this.resolveRuntimeWrapperPath('java')
    const executablePath = path.join(javaBridgePath, 'target')

    try {
      await fsp.stat(executablePath)
    } catch (err) {
      return new Promise((resolve, reject) => {
        const javaBridgeProgress = progress.get('javaBridge')
        javaBridgeProgress.notice('Building Java bridge', {
          isMainEvent: true,
        })
        const mvn = spawn(
          'mvn',
          ['package', '-f', path.join(javaBridgePath, 'pom.xml')],
          {
            shell: true,
          },
        )

        mvn.stderr.on('data', (buf) => {
          log.info(`mvn(stderr) - ${buf.toString()}`)
        })
        const chunk = []
        mvn.stdout.on('data', (buf) => chunk.push(buf))

        let isRejected = false
        mvn.on('error', (error) => {
          if (!isRejected) {
            isRejected = true
            reject(error)
          }
        })

        mvn.on('exit', (code, signal) => {
          javaBridgeProgress.remove()
          if (code === 0) {
            resolve(
              this.callJavaBridge(artifactPath, className, handlerName, input),
            )
          } else if (!isRejected) {
            chunk
              .map((elem) => elem.toString())
              .join('')
              .split(/\n/)
              .forEach((line) => {
                log.info(`mvn(stdout) - ${line}`)
              })
            isRejected = true
            reject(
              new ServerlessError(
                `Failed to build the Java bridge. exit code=${code} signal=${signal}`,
                'JAVA_BRIDGE_BUILD_FAILED',
              ),
            )
          }
        })

        process.nextTick(() => {
          if (isRejected) return // Runtime not available
          mvn.stdin.end()
        })
      })
    }
    return await this.callJavaBridge(
      artifactPath,
      className,
      handlerName,
      input,
    )
  }

  async invokeLocalRuby(runtime, handlerPath, handlerName, event, context) {
    const input = JSON.stringify({
      event: event || {},
      context: Object.assign(
        {
          function_name: this.options.functionObj.name,
          version: 'LATEST',
          log_group_name: this.provider.naming.getLogGroupName(
            this.options.functionObj.name,
          ),
          memory_limit_in_mb:
            Number(this.options.functionObj.memorySize) ||
            Number(this.serverless.service.provider.memorySize) ||
            1024,
          timeout:
            Number(this.options.functionObj.timeout) ||
            Number(this.serverless.service.provider.timeout) ||
            6,
        },
        context,
      ),
    })

    const wrapperPath = await this.resolveRuntimeWrapperPath('invoke.rb')
    return new Promise((resolve, reject) => {
      const ruby = spawn(runtime, [wrapperPath, handlerPath, handlerName], {
        env: process.env,
        shell: true,
      })
      ruby.stdout.on('data', (buf) => {
        writeText(buf.toString())
      })
      ruby.stderr.on('data', (buf) => {
        writeText(buf.toString())
      })
      ruby.on('close', () => resolve())
      let isRejected = false
      ruby.on('error', (error) => {
        isRejected = true
        reject(error)
      })

      process.nextTick(() => {
        if (isRejected) return // Runtime not available
        ruby.stdin.write(input)
        ruby.stdin.end()
      })
    })
  }

  async invokeLocalNodeJs(handlerPath, handlerName, event, customContext) {
    let lambda
    let pathToHandler
    let hasResponded = false
    try {
      pathToHandler = path.join(
        this.serverless.serviceDir,
        this.options.extraServicePath || '',
        handlerPath,
      )

      const handlersContainer = await loadModule(pathToFileURL(pathToHandler))
      lambda = handlersContainer[handlerName]
    } catch (error) {
      log.error(inspect(error))
      throw new ServerlessError(
        `Exception encountered when loading ${pathToHandler}`,
        'INVOKE_LOCAL_LAMBDA_INITIALIZATION_FAILED',
      )
    }

    if (typeof lambda !== 'function') {
      throw new ServerlessError(
        `The specified function handler '${handlerPath}' does not point to a valid handler function. Please ensure that you are exporting a valid function handler with a name that matches the one specified in your serverless.yml file.`,
        'INVALID_LAMBDA_HANDLER_PATH',
      )
    }

    async function loadModule(modulePath) {
      try {
        return await import(modulePath)
      } catch (error) {
        if (error.code === 'ERR_REQUIRE_ESM') {
          // Already in ESM format, use the utility if necessary or retry with a different method
          return await importEsm(`${modulePath}.js`)
        } else if (
          error.code === 'MODULE_NOT_FOUND' ||
          error.code === 'ERR_MODULE_NOT_FOUND'
        ) {
          // Attempt to import with `.js` extension
          const pathToHandler = `${modulePath}.js`
          try {
            return await import(pathToHandler)
          } catch (innerError) {
            // Throw original error if still "MODULE_NOT_FOUND", as not finding module with `.js` might be confusing
            if (innerError.code !== 'MODULE_NOT_FOUND') {
              throw innerError
            }
          }
        }
        throw error
      }
    }

    function handleError(err) {
      let errorResult
      if (err instanceof Error) {
        errorResult = {
          errorMessage: err.message,
          errorType: err.constructor.name,
          stackTrace: err.stack && err.stack.split('\n'),
        }
      } else {
        errorResult = {
          errorMessage: err,
        }
      }

      writeText(JSON.stringify(errorResult, null, 4))
      process.exitCode = 1
    }

    function handleResult(result) {
      if (result instanceof Error) {
        handleError.call(this, result)
        return
      }
      try {
        JSON.stringify(result)
      } catch (error) {
        throw new ServerlessError(
          `Function returned invalid (not a JSON stringifiable) value: ${inspect(
            result,
          )}`,
          'INVALID_INVOKE_LOCAL_RESULT',
        )
      }

      if (
        result.headers &&
        result.headers['Content-Type'] === 'application/json'
      ) {
        if (result.body) {
          try {
            Object.assign(result, {
              body: JSON.parse(result.body),
            })
          } catch (e) {
            throw new ServerlessError(
              'Content-Type of response is application/json but body is not json',
              'INVOKE_LOCAL_RESPONSE_TYPE_MISMATCH',
            )
          }
        }
      }

      this.logger.blankLine()

      writeText(JSON.stringify(result, null, 4))
    }

    return new Promise((resolve) => {
      const callback = (err, result) => {
        if (!hasResponded) {
          hasResponded = true
          if (err) {
            handleError.call(this, err)
          } else if (result) {
            handleResult.call(this, result)
          }
        }
        resolve()
      }

      const startTime = new Date()
      const timeout =
        Number(this.options.functionObj.timeout) ||
        Number(this.serverless.service.provider.timeout) ||
        6
      let context = {
        awsRequestId: uuidv4(),
        invokeid: 'id',
        logGroupName: this.provider.naming.getLogGroupName(
          this.options.functionObj.name,
        ),
        logStreamName: '2015/09/22/[HEAD]13370a84ca4ed8b77c427af260',
        functionVersion: 'HEAD',
        isDefaultFunctionVersion: true,

        functionName: this.options.functionObj.name,
        memoryLimitInMB: '1024',

        succeed(result) {
          return callback(null, result)
        },
        fail(error) {
          return callback(error)
        },
        done(error, result) {
          return callback(error, result)
        },
        getRemainingTimeInMillis() {
          return Math.max(
            timeout * 1000 - (new Date().valueOf() - startTime.valueOf()),
            0,
          )
        },
      }

      if (customContext) {
        context = customContext
      }

      const maybeThennable = lambda(event, context, callback)
      if (maybeThennable) {
        return Promise.resolve(maybeThennable).then(
          callback.bind(this, null),
          callback.bind(this),
        )
      }

      return maybeThennable
    })
  }
}

export default AwsInvokeLocal