Function deployAirnode

packages/airnode-deployer/src/infrastructure/index.ts:333–437

(config: Config, configPath: string, secretsPath: string, timestamp: number)

}

export const deployAirnode = async (config: Config, configPath: string, secretsPath: string, timestamp: number) => {
  const { airnodeWalletMnemonic, cloudProvider, stage } = config.nodeSettings;
  const airnodeAddress = deriveAirnodeAddress(airnodeWalletMnemonic);
  const { type, region } = cloudProvider as CloudProvider;

  const spinner = logger.getSpinner();
  spinner.start(`Deploying Airnode ${airnodeAddress} ${stage} to ${type} ${region}`);
  if (logger.inDebugMode()) {
    spinner.info();
  }

  const goDeploy = await go(async () => {
    logger.debug('Fetching Airnode bucket');
    let bucket = await cloudProviderLib[type].getAirnodeBucket();
    if (!bucket) {
      logger.debug('No Airnode bucket found, creating');
      bucket = await cloudProviderLib[type].createAirnodeBucket(cloudProvider as any);
    }
    logger.debug(`Using Airnode bucket '${bucket.name}'`);

    logger.debug('Fetching Airnode bucket content');
    const directoryStructure = await cloudProviderLib[type].getBucketDirectoryStructure(bucket);

    const bucketStagePath = `${airnodeAddress}/${stage}`;
    const bucketDeploymentPath = `${bucketStagePath}/${timestamp}`;

    const stageDirectory = getStageDirectory(directoryStructure, airnodeAddress, stage);
    if (stageDirectory) {
      logger.debug(`Deployment '${bucketStagePath}' already exists`);

      const bucketMissingFiles = getMissingBucketFiles(directoryStructure);
      if (
        bucketMissingFiles[airnodeAddress] &&
        bucketMissingFiles[airnodeAddress][stage] &&
        bucketMissingFiles[airnodeAddress][stage].length !== 0
      ) {
        throw new Error(
          `Can't update an Airnode with missing files: ${bucketMissingFiles[airnodeAddress][stage].join(
            ', '
          )}. Deployer commands may fail and manual removal may be necessary.`
        );
      }

      const latestDeployment = Object.keys(stageDirectory.children).sort().reverse()[0];
      const bucketConfigPath = `${bucketStagePath}/${latestDeployment}/config.json`;
      logger.debug(`Fetching configuration file '${bucketConfigPath}'`);
      const goGetRemoteConfigFileFromBucket = await go(() =>
        cloudProviderLib[type].getFileFromBucket(bucket!, bucketConfigPath)
      );
      if (!goGetRemoteConfigFileFromBucket.success) {
        throw new Error(`Failed to fetch configuration file. Error: ${goGetRemoteConfigFileFromBucket.error.message}`);
      }
      const goRemoteConfig = goSync(() => JSON.parse(goGetRemoteConfigFileFromBucket.data));
      if (!goRemoteConfig.success) {
        throw new Error(`Failed to parse configuration file. Error: ${goRemoteConfig.error.message}`);
      }

      const remoteNodeSettings = goRemoteConfig.data.nodeSettings;