yes

Author: lennartdohmann

java/src/test/java/de/gdata/test/integration/RealApiIntegrationTests.java

@@ -15,13 +15,15 @@
 import de.gdata.vaas.options.ForStreamOptions;
 import de.gdata.vaas.options.ForUrlOptions;
 import io.github.cdimascio.dotenv.Dotenv;
+import lombok.extern.slf4j.Slf4j;
 import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.CsvSource;
 import org.mockito.ArgumentCaptor;
 
 import java.io.ByteArrayOutputStream;
+import java.io.IOException;
 import java.net.URI;
 import java.net.http.HttpClient;
 import java.net.http.HttpRequest;
@@ -30,14 +32,17 @@
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.StandardCopyOption;
+import java.util.List;
 import java.util.Objects;
+import java.util.UUID;
 import java.util.concurrent.*;
 
 import static org.junit.jupiter.api.Assertions.*;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.argThat;
 import static org.mockito.Mockito.*;
 
+@Slf4j
 public class RealApiIntegrationTests {
     private static final String EICAR_URL = "https://secure.eicar.org/eicar.com.txt";
 
@@ -1366,4 +1371,60 @@ public void forUrl_BigFileWithSmallTimeout_ThrowsTimeoutException()
         var exception = assertThrows(ExecutionException.class, () -> vaas.forUrlAsync(url).get());
         assertInstanceOf(TimeoutException.class, exception.getCause());
     }
+
+    @Test
+    @Disabled()
+    public void forFileAsync_WithSmallTimeout_DoesNotShowNegativeResources() {
+        var config = new VaasConfig(45, false, false, URI.create(getEnvironmentKey("VAAS_URL")));
+        var vaas = new Vaas(config, getAuthenticator());
+        var file = Path.of(System.getProperty("java.io.tmpdir"), "file.txt");
+        try (var writer = Files.newBufferedWriter(file)) {
+            writer.write(UUID.randomUUID().toString());
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+
+        while (true) {
+            try {
+                vaas.forFile(file);
+                System.out.print("+");
+                System.out.flush();
+            } catch (Exception e) {
+                System.out.print("-");
+                System.out.flush();
+            }
+        }
+    }
+
+    @Test
+    @Disabled()
+    public void forFileAsync_WithSmallTimeoutInParallel_DoesNotShowNegativeResources() {
+        var config = new VaasConfig(45, false, false, URI.create(getEnvironmentKey("VAAS_URL")));
+        var vaas = new Vaas(config, getAuthenticator());
+        var file1 = Path.of(System.getProperty("java.io.tmpdir"), "file.txt");
+        var file2 = Path.of(System.getProperty("java.io.tmpdir"), "file2.txt");
+        var file3 = Path.of(System.getProperty("java.io.tmpdir"), "file3.txt");
+        var file4 = Path.of(System.getProperty("java.io.tmpdir"), "file4.txt");
+        var fileList = List.of(file1, file2, file3, file4);
+        for (var file : fileList) {
+            try (var writer = Files.newBufferedWriter(file)) {
+                writer.write(UUID.randomUUID().toString());
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+
+        while (true) {
+            fileList.parallelStream().forEach((key) -> {
+                try {
+                    vaas.forFile(key);
+                    System.out.print("+");
+                    System.out.flush();
+                } catch (Exception e) {
+                    System.out.print("-");
+                    System.out.flush();
+                }
+            });
+        }
+    }
 }

java/src/test/java/de/gdata/test/integration/ScanS3Bucket.java

@@ -15,14 +15,12 @@
 import de.gdata.vaas.VaasConfig;
 import de.gdata.vaas.authentication.ClientCredentialsGrantAuthenticator;
 import de.gdata.vaas.messages.VaasVerdict;
-import de.gdata.vaas.options.ForFileOptions;
 import io.github.cdimascio.dotenv.Dotenv;
 
 import java.io.File;
 import java.io.FileOutputStream;
 import java.net.URI;
 import java.nio.file.Files;
-import java.time.Duration;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -45,7 +43,7 @@ public static void main(String[] args) throws Exception {
         // Build VaaS
         long startTimeAll = System.currentTimeMillis();
         ClientCredentialsGrantAuthenticator authenticator = new ClientCredentialsGrantAuthenticator(CLIENT_ID, CLIENT_SECRET, new URI(TOKEN_URL));
-        VaasConfig vaasConfig = new VaasConfig(Duration.ofSeconds(1).getSeconds() * 1000, false, true, new URI(VAAS_URL));
+        VaasConfig vaasConfig = new VaasConfig(10000, false, false, new URI(VAAS_URL));
         Vaas vaas = new Vaas(vaasConfig, authenticator);
 
         // List S3 bucket
@@ -92,8 +90,7 @@ public void refresh() {
 
                 // Scan file with VaaS and track time
                 long startTime = System.currentTimeMillis();
-                ForFileOptions forFileOptions = new ForFileOptions(false, true, "LD-big-big-files-01");
-                VaasVerdict vaasVerdict = vaas.forFileAsync(tempFile.toPath(), forFileOptions).get();
+                VaasVerdict vaasVerdict = vaas.forFileAsync(tempFile.toPath()).get();
                 long endTime = System.currentTimeMillis();
                 double executionTime = (endTime - startTime);
 
@@ -115,7 +112,7 @@ public void refresh() {
             } catch (Exception e) {
                 System.out.println("Error processing key: " + key);
                 e.printStackTrace();
-            }            
+            }
         });
 
         // Write results to file