99import software .amazon .awssdk .services .s3 .S3Client ;
1010import software .amazon .awssdk .services .s3 .S3Configuration ;
1111import software .amazon .awssdk .services .s3 .model .CreateBucketRequest ;
12+ import software .amazon .awssdk .services .s3 .model .GetObjectRequest ;
1213import software .amazon .awssdk .services .s3 .model .GetObjectResponse ;
1314import software .amazon .awssdk .services .s3 .model .HeadObjectRequest ;
1415import software .amazon .awssdk .services .s3 .model .HeadObjectResponse ;
@@ -83,15 +84,17 @@ void downloadFromStorageTest() throws IOException {
8384
8485 @ Test
8586 void uploadToStorageTest () throws IOException {
86- InputStream inputStream = new ByteArrayInputStream ("upload-content" .getBytes (StandardCharsets .UTF_8 ));
87+ String uploadContent = "upload-content" ;
88+ InputStream inputStream = new ByteArrayInputStream (uploadContent .getBytes (StandardCharsets .UTF_8 ));
8789 long streamLength = inputStream .available ();
8890
8991 s3StorageConnector .uploadToStorage (inputStream , streamLength , FILE_NAME );
9092
91- HeadObjectResponse response = s3Client .headObject (HeadObjectRequest .builder ().bucket (BUCKET_NAME ).key (FILE_NAME ).build ());
93+ final var request = GetObjectRequest .builder ().bucket (BUCKET_NAME ).key (FILE_NAME ).build ();
94+ ResponseInputStream <GetObjectResponse > uploadedObjectInS3 = s3Client .getObject (request );
95+ String uploadedS3Content = new String (uploadedObjectInS3 .readAllBytes (), StandardCharsets .UTF_8 );
9296
93- assertNotNull (response );
94- assertEquals (Optional .of (streamLength ).get (), response .contentLength ());
97+ assertEquals (uploadContent , uploadedS3Content );
9598 }
9699
97100}
0 commit comments