Function getFileFromBucket

packages/airnode-deployer/src/infrastructure/aws.ts:186–206

(bucket: Bucket, filePath: string)

};

export const getFileFromBucket = async (bucket: Bucket, filePath: string) => {
  const { name: bucketName, region: bucketRegion } = bucket;
  const s3 = initializeS3Service(bucketRegion);

  logger.debug(`Fetching file '${filePath}' from S3 bucket '${bucketName}'`);
  const getCommand = new GetObjectCommand({ Bucket: bucketName, Key: filePath });
  const goGet = await go(() => s3.send(getCommand));
  if (!goGet.success) {
    throw new Error(`Failed to fetch file '${filePath}' from S3 bucket '${bucketName}': ${goGet.error}`);
  }
  if (!goGet.data.Body) {
    throw new Error(`The response for file '${filePath}' from S3 bucket '${bucketName}' contained an empty body`);
  }

  const goFileContent = await go(() => goGet.data.Body!.transformToString('utf-8'));
  if (!goFileContent.success) {
    throw new Error(`The response for file '${filePath}' from S3 bucket '${bucketName}' is not parsable`);
  }

  return goFileContent.data;
};

export const copyFileInBucket = async (bucket: Bucket, fromFilePath: string, toFilePath: string) => {
  const { name: bucketName, region: bucketRegion } = bucket;