Stabilize ScriptingData watcher tests for CI matrix reliability

Agent-Logs-Url: https://github.com/CyclopsMC/IntegratedScripting/sessions/8f7f33aa-51b9-40b9-874b-0b54dd8b5af7

Co-authored-by: rubensworks <440384+rubensworks@users.noreply.github.com>

Author: Copilot

src/test/java/org/cyclops/integratedscripting/core/network/ScriptingDataTest.java

@@ -5,8 +5,10 @@
 import org.junit.Test;
 
 import java.io.IOException;
+import java.lang.reflect.Field;
 import java.nio.file.Files;
 import java.nio.file.Path;
+import java.util.Map;
 
 import static org.hamcrest.CoreMatchers.equalTo;
 import static org.hamcrest.CoreMatchers.hasItem;
@@ -15,20 +17,22 @@
 
 public class ScriptingDataTest {
 
-    private static final int AWAIT_TIMEOUT_MS = 5000;
+    private static final int AWAIT_TIMEOUT_MS = 20000;
     private static final int POLLING_INTERVAL_MS = 25;
-    private static final int FILE_SYSTEM_STABILIZATION_DELAY_MS = 200;
 
     @Test
     public void testExternalUpdatesOnRuntimeCreatedDiskFolderSynced() throws IOException, InterruptedException {
         Path rootPath = Files.createTempDirectory("integratedscripting-test");
         ScriptingData scriptingData = new ScriptingData(rootPath);
         try {
             scriptingData.initialize();
+            Path disksPath = rootPath.resolve("scripting-disks");
+            awaitCondition(() -> isWatcherRegistered(scriptingData, disksPath));
 
-            Path diskPath = rootPath.resolve("scripting-disks").resolve("123");
+            Path diskPath = disksPath.resolve("123");
             Files.createDirectories(diskPath);
             awaitCondition(() -> scriptingData.getDisks().contains(123));
+            awaitCondition(() -> isWatcherRegistered(scriptingData, diskPath));
 
             Files.writeString(diskPath.resolve("main.js"), "export const value = 1;");
             awaitCondition(() -> "export const value = 1;".equals(scriptingData.getScripts(123).get(Path.of("main.js"))));
@@ -47,13 +51,14 @@ public void testExternalUpdatesOnRuntimeFirstUsedDiskSynced() throws IOException
         ScriptingData scriptingData = new ScriptingData(rootPath);
         try {
             scriptingData.initialize();
+            Path diskPath = rootPath.resolve("scripting-disks").resolve("456");
 
             scriptingData.setScript(456, Path.of("main.js"), "export const value = 1;", IScriptingData.ChangeLocation.MEMORY);
             scriptingData.tick();
-            assertTrue(Files.exists(rootPath.resolve("scripting-disks").resolve("456").resolve("main.js")));
-            Thread.sleep(FILE_SYSTEM_STABILIZATION_DELAY_MS);
+            assertTrue(Files.exists(diskPath.resolve("main.js")));
+            awaitCondition(() -> isWatcherRegistered(scriptingData, diskPath));
 
-            Files.writeString(rootPath.resolve("scripting-disks").resolve("456").resolve("main.js"), "export const value = 2;");
+            Files.writeString(diskPath.resolve("main.js"), "export const value = 2;");
             awaitCondition(() -> "export const value = 2;".equals(scriptingData.getScripts(456).get(Path.of("main.js"))));
 
             assertThat(scriptingData.getScripts(456).get(Path.of("main.js")), equalTo("export const value = 2;"));
@@ -74,6 +79,17 @@ private static void awaitCondition(Condition condition) throws InterruptedExcept
         assertTrue("Timed out waiting for condition", condition.matches());
     }
 
+    private static boolean isWatcherRegistered(ScriptingData scriptingData, Path path) {
+        try {
+            Field field = ScriptingData.class.getDeclaredField("pathWatchers");
+            field.setAccessible(true);
+            Map<Path, ?> pathWatchers = (Map<Path, ?>) field.get(scriptingData);
+            return pathWatchers.containsKey(path);
+        } catch (IllegalAccessException | NoSuchFieldException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
     @FunctionalInterface
     private interface Condition {
         boolean matches();