diff --git a/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloaderTest.java b/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloaderTest.java index e2f860ec13170e5bca5718f34f73f1b57105b142..ba9b67ab7e44121f7cccda3268c737fa91c9d14c 100644 --- a/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloaderTest.java +++ b/ozgcloud-common-lib/src/test/java/de/ozgcloud/common/binaryfile/GrpcBinaryFileServerDownloaderTest.java @@ -27,7 +27,6 @@ import static org.assertj.core.api.Assertions.*; import static org.mockito.ArgumentMatchers.*; import static org.mockito.Mockito.*; -import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; @@ -40,7 +39,6 @@ import java.util.function.Consumer; import java.util.function.Function; import java.util.stream.Stream; -import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Nested; import org.junit.jupiter.api.Test; @@ -486,7 +484,7 @@ class GrpcBinaryFileServerDownloaderTest { @ParameterizedTest @MethodSource("provideArguments") void shouldReturnValue(boolean requestFinished, boolean ready, boolean expected) { - ReflectionTestUtils.setField(downloader, "requestFinished", new AtomicBoolean(requestFinished)); + setRequestFinishedField(requestFinished); lenient().when(callObserver.isReady()).thenReturn(ready); var canSendChunks = downloader.canSendChunks(); @@ -635,72 +633,6 @@ class GrpcBinaryFileServerDownloaderTest { return (TechnicalException) ReflectionTestUtils.getField(downloader, "downloadError", AtomicReference.class).get(); } - private void setDownloadFinishedField(boolean downloadFinished) { - ReflectionTestUtils.setField(downloader, "downloadFinished", new AtomicBoolean(downloadFinished)); - } - - private boolean getDownloadFinished() { - return ReflectionTestUtils.getField(downloader, "downloadFinished", AtomicBoolean.class).get(); - } - private static class GrpcResponseDummy { } - - @Nested - class TestStreams { - - private static final int CHUNK_SIZE = 255 * 1024; - - private PipedInputStream inputStream; - private PipedOutputStream outputStream; - - @SneakyThrows - @BeforeEach - void init() { - outputStream = new PipedOutputStream(); - inputStream = new PipedInputStream(CHUNK_SIZE); - outputStream.connect(inputStream); - } - - @SneakyThrows - @Test - void shouldReadIncompleteFile() { - var fileBuffer = new byte[CHUNK_SIZE]; - var readBuffer = new byte[CHUNK_SIZE]; - try (FileInputStream fileInputStream = new FileInputStream("/Users/kwitukiewicz/Documents/books/__Debt__The_First_5_000_Years.pdf")) { - fileInputStream.read(fileBuffer, 0, 255); - outputStream.write(fileBuffer, 0, 1); - - var read = inputStream.read(readBuffer, 0, CHUNK_SIZE); - - assertThat(read).isEqualTo(1); - } - } - - @SneakyThrows - @Test - void shouldReadAfterOutputStreamWasClosed() { - var fileBuffer = new byte[CHUNK_SIZE]; - var readBuffer = new byte[CHUNK_SIZE * 2]; - try (FileInputStream fileInputStream = new FileInputStream("/Users/kwitukiewicz/Documents/books/__Debt__The_First_5_000_Years.pdf")) { - fileInputStream.read(fileBuffer, 0, fileBuffer.length); - outputStream.write(fileBuffer); - outputStream.close(); - - var read = inputStream.read(readBuffer); - - assertThat(read).isEqualTo(CHUNK_SIZE); - - read = inputStream.read(readBuffer); - assertThat(read).isEqualTo(-1); - } - } - - @SneakyThrows - @AfterEach - void cleanup() { - outputStream.close(); - inputStream.close(); - } - } } \ No newline at end of file