test(Files): Add integration tests for Files.copy / read* from issue a…

…wslabs#236 [skip ci]

src/integrationTest/java/software/amazon/nio/spi/s3/Containers.java

@@ -37,6 +37,17 @@ public static void putObject(String bucket, String key) {
          .doesNotThrowAnyException();
     }
 
+    public static void putObject(String bucket, String key, String content) {
+        assertThatCode(() -> {
+            Container.ExecResult execResultCreateFile = LOCAL_STACK_CONTAINER.execInContainer("sh", "-c", "echo -n '" + content + "' > " + key);
+            Container.ExecResult execResultPut = LOCAL_STACK_CONTAINER.execInContainer(("awslocal s3api put-object --bucket " + bucket + " --key " + key + " --body " + key).split(" "));
+
+            assertThat(execResultCreateFile.getExitCode()).isZero();
+            assertThat(execResultPut.getExitCode()).withFailMessage("Failed put: %s ", execResultPut.getStderr()).isZero();
+        }).as("Failed to put object '%s' in bucket '%s'", key, bucket)
+                .doesNotThrowAnyException();
+    }
+
     public static String localStackConnectionEndpoint() {
         return localStackConnectionEndpoint(null, null);
     }

src/integrationTest/java/software/amazon/nio/spi/s3/FilesCopyTest.java

@@ -0,0 +1,32 @@
+package software.amazon.nio.spi.s3;
+
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.io.TempDir;
+
+import java.io.IOException;
+import java.net.URI;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static software.amazon.nio.spi.s3.Containers.localStackConnectionEndpoint;
+import static software.amazon.nio.spi.s3.Containers.putObject;
+
+@DisplayName("Files$copy should load file contents from localstack")
+public class FilesCopyTest
+{
+    @TempDir
+    Path tempDir;
+
+    @Test
+    @DisplayName("when doing copy of existing file")
+    public void fileCopyShouldCopyFileWhenFileFound() throws IOException {
+        Containers.createBucket("sink");
+        putObject("sink", "files-copy.txt", "some content");
+        final Path path = Paths.get(URI.create(localStackConnectionEndpoint() + "/sink/files-copy.txt"));
+        Path copiedFile = Files.copy(path, tempDir.resolve("sample-file-local.txt"));
+        assertThat(copiedFile).hasContent("some content");
+    }
+}

src/integrationTest/java/software/amazon/nio/spi/s3/FilesReadTest.java

@@ -0,0 +1,40 @@
+package software.amazon.nio.spi.s3;
+
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Test;
+
+import java.io.IOException;
+import java.net.URI;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+
+import static org.assertj.core.api.BDDAssertions.then;
+import static software.amazon.nio.spi.s3.Containers.localStackConnectionEndpoint;
+import static software.amazon.nio.spi.s3.Containers.putObject;
+
+@DisplayName("Files$read* should load file contents from localstack")
+public class FilesReadTest
+{
+    private final Path path = Paths.get(URI.create(localStackConnectionEndpoint() + "/sink/files-read.txt"));
+
+    @BeforeAll
+    public static void createBucketAndFile(){
+        Containers.createBucket("sink");
+        putObject("sink", "files-read.txt", "some content");
+    }
+
+    @Test
+    @DisplayName("when doing readAllBytes from existing file in s3")
+    public void fileReadAllBytesShouldReturnFileContentsWhenFileFound() throws IOException {
+        then(Files.readAllBytes(path)).isEqualTo("some content".getBytes());
+    }
+
+    @Test
+    @DisplayName("when doing readAllLines from existing file in s3")
+    public void fileReadAllLinesShouldReturnFileContentWhenFileFound() throws IOException {
+        then(String.join("", Files.readAllLines(path))).isEqualTo("some content");
+    }
+
+}