Function removeAirnode

packages/airnode-deployer/src/infrastructure/index.ts:635–709

(deploymentId: string)

}

export async function removeAirnode(deploymentId: string) {
  const cloudProviderType = deploymentId.slice(0, 3) as CloudProvider['type'];
  if (!availableCloudProviders.includes(cloudProviderType)) {
    throw new Error(`Invalid deployment ID '${deploymentId}'`);
  }

  const spinner = logger.getSpinner();
  spinner.start(`Removing Airnode '${deploymentId}'`);
  if (logger.inDebugMode()) {
    spinner.info();
  }

  const goRemove = await go(async () => {
    const goFetchDeployment = await go(() => fetchDeployment(cloudProviderType, deploymentId));
    if (!goFetchDeployment.success) {
      spinner.stop();
      throw goFetchDeployment.error;
    }
    const { deployment } = goFetchDeployment.data;

    const {
      cloudProvider,
      airnodeAddress,
      stage,
      airnodeVersion: deployedVersion,
      bucket,
      bucketLatestDeploymentPath,
    } = deployment;

    if (deployedVersion !== nodeVersion) {
      throw new Error(
        `Can't remove an Airnode deployment with airnode-deployer of a different version. Deployed version: ${deployedVersion}, airnode-deployer version: ${nodeVersion}`
      );
    }

    logger.debug('Removing Airnode via Terraform recipes');
    const airnodeTmpDir = fs.mkdtempSync(path.join(os.tmpdir(), 'airnode'));
    const execOptions = { cwd: airnodeTmpDir };
    await terraformAirnodeDestroy(execOptions, cloudProvider, deploymentId, bucket, bucketLatestDeploymentPath);
    fs.rmSync(airnodeTmpDir, { recursive: true });

    // Refreshing the bucket content because the source code archives were removed by Terraform
    logger.debug('Refreshing Airnode bucket content');
    const directoryStructure = await cloudProviderLib[cloudProviderType].getBucketDirectoryStructure(bucket);
    const addressDirectory = getAddressDirectory(directoryStructure, airnodeAddress) as Directory;
    const stageDirectory = getStageDirectory(directoryStructure, airnodeAddress, stage) as Directory;

    // Delete stage directory and its content
    logger.debug(`Deleting deployment directory '${stageDirectory.bucketKey}' and its content`);
    await cloudProviderLib[cloudProviderType].deleteBucketDirectory(bucket, stageDirectory);
    // eslint-disable-next-line functional/immutable-data
    delete addressDirectory.children[stage];

    // Delete Airnode address directory if empty
    if (Object.keys(addressDirectory.children).length === 0) {
      logger.debug(`Deleting Airnode address directory '${addressDirectory.bucketKey}'`);
      await cloudProviderLib[cloudProviderType].deleteBucketDirectory(bucket, addressDirectory);
      // eslint-disable-next-line functional/immutable-data