in src/main/java/com/epam/digital/data/platform/integration/ceph/service/impl/CephServiceS3Impl.java [124:138]
public CephObjectMetadata put(String cephBucketName, String key, String contentType,
long contentLength, Map<String, String> userMetadata, InputStream content) {
log.info("Putting file with key {} to ceph bucket {}", key, cephBucketName);
assertBucketExists(cephAmazonS3, cephBucketName);
var result = execute(() -> {
var objectMetadata = new ObjectMetadata();
objectMetadata.setContentType(contentType);
objectMetadata.setContentLength(contentLength);
objectMetadata.setUserMetadata(userMetadata);
cephAmazonS3.putObject(cephBucketName, key, content, objectMetadata);
return cephAmazonS3.getObjectMetadata(cephBucketName, key);
});
log.info("File {} was put to ceph bucket {}", key, cephBucketName);
return toCephObjectMetadata(result);
}