fix: GCP Core deployment start to fail after some time #472 (#475)

src/main/java/com/epam/aidial/core/util/Compression.java

@@ -29,24 +29,16 @@ public byte[] compress(String type, byte[] data) {
     }
 
     @SneakyThrows
-    public InputStream decompress(String type, InputStream input) {
+    public byte[] decompress(String type, byte[] input) {
         if (!type.equals("gzip")) {
             throw new IllegalArgumentException("Unsupported compression: " + type);
         }
-
-        try {
-            return new GZIPInputStream(input);
+        try (InputStream decompressed = new GZIPInputStream(new ByteArrayInputStream(input))) {
+            return decompressed.readAllBytes();
         } catch (ZipException e) {
             // special case for GCP cloud storage, due to jclouds bug https://issues.apache.org/jira/projects/JCLOUDS/issues/JCLOUDS-1633
             log.warn("Failed to decompress provided input: {}", e.getMessage());
             return input;
         }
     }
-
-    @SneakyThrows
-    public byte[] decompress(String type, byte[] input) {
-        try (InputStream decompressed = decompress(type, new ByteArrayInputStream(input))) {
-            return decompressed.readAllBytes();
-        }
-    }
 }

src/test/java/com/epam/aidial/core/util/CompressionTest.java

@@ -0,0 +1,38 @@
+package com.epam.aidial.core.util;
+
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.assertArrayEquals;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+public class CompressionTest {
+
+    @Test
+    public void testNormalFlow() {
+        byte[] content = "Hello world!".getBytes();
+
+        assertThrows(IllegalArgumentException.class, () -> Compression.compress("wrong", content));
+
+        byte[] compressed = Compression.compress("gzip", content);
+
+        assertNotNull(compressed);
+        assertTrue(compressed.length > 0);
+        assertThrows(IllegalArgumentException.class, () -> Compression.decompress("wrong", compressed));
+
+        byte[] actual = Compression.decompress("gzip", compressed);
+
+        assertArrayEquals(content, actual);
+    }
+
+    @Test
+    public void testGcpWorkaround() {
+        byte[] content = "Hello world!".getBytes();
+
+        byte[] actual = Compression.decompress("gzip", content);
+
+        assertEquals(content, actual);
+    }
+}