Function fetchDeployments

packages/airnode-deployer/src/infrastructure/index.ts:480–587

(cloudProviderType: CloudProvider['type'], deploymentId?: string)

// If deploymentId is provided it tries to fetch only that one deployment and returns early when found
async function fetchDeployments(cloudProviderType: CloudProvider['type'], deploymentId?: string) {
  const deployments: Deployment[] = [];

  const bucket = await cloudProviderLib[cloudProviderType].getAirnodeBucket();
  if (!bucket) {
    logger.debug(`No deployments available on ${cloudProviderType.toUpperCase()}`);
    return deployments;
  }

  const directoryStructure = await cloudProviderLib[cloudProviderType].getBucketDirectoryStructure(bucket);
  const bucketMissingFiles = getMissingBucketFiles(directoryStructure);

  for (const [airnodeAddress, addressDirectory] of Object.entries(directoryStructure)) {
    if (addressDirectory.type !== FileSystemType.Directory) {
      logger.warn(
        `Invalid item in bucket '${bucket.name}' (${cloudProviderType.toUpperCase()}) with key '${
          addressDirectory.bucketKey
        }'. Skipping.`
      );
      continue;
    }

    for (const [stage, stageDirectory] of Object.entries(addressDirectory.children)) {
      if (stageDirectory.type !== FileSystemType.Directory) {
        logger.warn(
          `Invalid item in bucket '${bucket.name}' (${cloudProviderType.toUpperCase()}) with key '${
            stageDirectory.bucketKey
          }'. Skipping.`
        );
        continue;
      }

      const latestDeployment = Object.keys(stageDirectory.children).sort().reverse()[0];

      if (
        bucketMissingFiles[airnodeAddress] &&
        bucketMissingFiles[airnodeAddress][stage] &&
        bucketMissingFiles[airnodeAddress][stage].length !== 0
      ) {
        continue;
      }

      const bucketLatestDeploymentPath = `${airnodeAddress}/${stage}/${latestDeployment}`;

      const bucketConfigPath = `${bucketLatestDeploymentPath}/config.json`;
      logger.debug(`Fetching configuration file '${bucketConfigPath}'`);
      const goGetConfigFileFromBucket = await go(() =>
        cloudProviderLib[cloudProviderType].getFileFromBucket(bucket, bucketConfigPath)
      );
      if (!goGetConfigFileFromBucket.success) {
        logger.warn(`Failed to fetch configuration file. Error: ${goGetConfigFileFromBucket.error.message} Skipping.`);
        continue;
      }
      const goConfig = goSync(() => JSON.parse(goGetConfigFileFromBucket.data));
      if (!goConfig.success) {
        logger.warn(`Failed to parse configuration file. Error: ${goConfig.error.message} Skipping.`);
        continue;
      }