Migrate file watch tests to new harness #3584 (#5840)

apache · Mar 6, 2024 · 771d922 · 771d922
1 parent fb5dcac
commit 771d922
Show file tree

Hide file tree

Showing 3 changed files with 73 additions and 113 deletions.
diff --git a/integration-tests/file/src/test/java/org/apache/camel/quarkus/component/file/it/FileIT.java b/integration-tests/file/src/test/java/org/apache/camel/quarkus/component/file/it/FileIT.java
diff --git a/...gration-tests/file/src/test/java/org/apache/camel/quarkus/component/file/it/FileTest.java b/...gration-tests/file/src/test/java/org/apache/camel/quarkus/component/file/it/FileTest.java
diff --git a/...tests/file/src/test/java/org/apache/camel/quarkus/component/file/it/NonFlakyFileTest.java b/...tests/file/src/test/java/org/apache/camel/quarkus/component/file/it/NonFlakyFileTest.java
@@ -17,6 +17,7 @@
 package org.apache.camel.quarkus.component.file.it;
 
 import java.io.IOException;
+import java.nio.charset.StandardCharsets;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.Paths;
@@ -28,12 +29,35 @@
 import io.quarkus.test.junit.QuarkusTest;
 import io.restassured.RestAssured;
 import io.restassured.http.ContentType;
+import io.restassured.path.json.JsonPath;
+import io.restassured.response.ValidatableResponse;
+import org.apache.camel.quarkus.core.util.FileUtils;
 import org.hamcrest.Matchers;
 import org.junit.jupiter.api.Test;
 
 import static org.apache.camel.quarkus.component.file.it.FileResource.SEPARATOR;
 import static org.apache.camel.quarkus.component.file.it.FileResource.SORT_BY;
-import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.*;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.BATCH_FILE_NAME_1_CONTENT;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.BATCH_FILE_NAME_2_CONTENT;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.CHARSET_READ_FILE_CONTENT;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.CHARSET_WRITE_FILE_CONTENT;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.CHARSET_WRITE_FILE_CREATION_FOLDER;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.CHARSET_WRITE_FILE_NAME;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.FILE_CREATION_FILE_CONTENT;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.FILE_CREATION_FILE_NAME;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.FILE_CREATION_FOLDER;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.FILTER_NON_SKIPPED_FILE_CONTENT;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.IDEMPOTENT_FILE_CONTENT;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.IDEMPOTENT_FILE_NAME;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.POLL_ENRICH_FILE_CONTENT;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.QUARTZ_SCHEDULED_FILE_CONTENT;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.READ_LOCK_FILE_NAME;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.READ_LOCK_FOLDER_IN;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.READ_LOCK_FOLDER_OUT;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.SORT_BY_NAME_1_CONTENT;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.SORT_BY_NAME_2_CONTENT;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.SORT_BY_NAME_3_CONTENT;
+import static org.apache.camel.quarkus.component.file.it.NonFlakyFileTestResource.TEST_FILES_FOLDER;
 import static org.apache.commons.io.FileUtils.readFileToString;
 import static org.awaitility.Awaitility.await;
 import static org.hamcrest.core.IsEqual.equalTo;
@@ -208,4 +232,52 @@ void filesCreatedInWrongOrderShouldBeSortedByReverseFilename() {
                 equalTo(SORT_BY_NAME_3_CONTENT + SEPARATOR + SORT_BY_NAME_2_CONTENT + SEPARATOR + SORT_BY_NAME_1_CONTENT));
     }
 
+    @Test
+    public void fileWatchShouldCatchCreateModifyAndDeleteEvents() throws IOException {
+        final Path fileWatchDirectory = Files.createTempDirectory(NonFlakyFileTest.class.getSimpleName()).toRealPath();
+        RestAssured.given()
+                .queryParam("path", fileWatchDirectory.toString())
+                .get("/file-watch/get-events")
+                .then()
+                .statusCode(204);
+
+        final Path watchedFilePath = fileWatchDirectory.resolve("watched-file.txt");
+        Files.write(watchedFilePath, "a file content".getBytes(StandardCharsets.UTF_8));
+        awaitEvent(fileWatchDirectory, watchedFilePath, "CREATE");
+
+        Files.write(watchedFilePath, "changed content".getBytes(StandardCharsets.UTF_8));
+        awaitEvent(fileWatchDirectory, watchedFilePath, "MODIFY");
+
+        Files.delete(watchedFilePath);
+        awaitEvent(fileWatchDirectory, watchedFilePath, "DELETE");
+    }
+
+    private static void awaitEvent(final Path fileWatchDirectory, final Path watchedFile, final String extepecteEventType) {
+        await()
+                .pollInterval(100, TimeUnit.MILLISECONDS)
+                .atMost(20, TimeUnit.SECONDS)
+                .until(() -> {
+                    final ValidatableResponse getEventsResponse = RestAssured.given()
+                            .queryParam("path", fileWatchDirectory.toString())
+                            .get("/file-watch/get-events")
+                            .then();
+                    switch (getEventsResponse.extract().statusCode()) {
+                    case 204:
+                        /*
+                         * the event may come with some delay through all the OS and Java layers so it is
+                         * rather normal to get 204 before getting the expected event
+                         */
+                        return false;
+                    case 200:
+                        final JsonPath json = getEventsResponse.extract().jsonPath();
+
+                        String expectedPath = FileUtils.nixifyPath(watchedFile);
+                        String actualPath = json.getString("path");
+                        return expectedPath.equals(actualPath) && extepecteEventType.equals(json.getString("type"));
+                    default:
+                        throw new RuntimeException("Unexpected status code " + getEventsResponse.extract().statusCode());
+                    }
+                });
+    }
+
 }