private void assertBucketExists()

in src/main/java/com/epam/digital/data/platform/integration/ceph/service/impl/CephServiceS3Impl.java [249:257]


  private void assertBucketExists(AmazonS3 cephAmazonS3, String cephBucketName) {
    log.debug("Checking if bucket {} exists", cephBucketName);
    var buckets = execute(cephAmazonS3::listBuckets);
    buckets.stream()
        .filter(bucket -> bucket.getName().equals(cephBucketName))
        .findFirst()
        .orElseThrow(() -> new MisconfigurationException(
            String.format("Bucket %s hasn't found", cephBucketName)));
  }