test(service) testing SaveToFileService and WatchService (#1244)

* test(service) testing saveToFileService and WatchService

Signed-off-by: doguhannilt <doguhannilt@gmail.com>

* style: A comment line has been enhanced in pom

Signed-off-by: doguhannilt <doguhannilt@gmail.com>

---------

Signed-off-by: doguhannilt <doguhannilt@gmail.com>

Author: Doguhannilt

sdk-java/pom.xml

@@ -23,6 +23,47 @@
             <version>0.8.6</version>
             <scope>runtime</scope>
         </dependency>
+
+
+
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <version>5.9.2</version>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-engine</artifactId>
+            <version>5.9.2</version>
+            <scope>test</scope>
+        </dependency>
+
+
+        <!-- Mockito -->
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-core</artifactId>
+            <version>5.14.2</version>
+            <scope>test</scope>
+        </dependency>
+
+        <!-- Awaitility for asc tests -->
+        <dependency>
+            <groupId>org.awaitility</groupId>
+            <artifactId>awaitility</artifactId>
+            <version>4.2.0</version>
+            <scope>test</scope>
+        </dependency>
+
+
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-params</artifactId>
+            <version>5.9.2</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
     <build>
         <plugins>

sdk-java/src/test/java/service/SaveToFileServiceTest.java

@@ -0,0 +1,76 @@
+package service;
+
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.vsecm.service.SaveToFileService;
+
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+class SaveToFileServiceTest {
+    private Path tempFile;
+    private Path tempDir;
+
+    @BeforeEach
+    void setUp() throws IOException {
+
+        tempDir = Files.createTempDirectory("testDir");
+        tempFile = tempDir.resolve("testFile.txt");
+    }
+
+    @AfterEach
+    void tearDown() throws IOException {
+        if (Files.exists(tempDir)) {
+            Files.walk(tempDir)
+                    .sorted((a, b) -> b.compareTo(a))
+                    .forEach(path -> {
+                        try {
+                            Files.deleteIfExists(path);
+                        } catch (IOException e) {
+                            System.err.println("Failed to delete: " + path + " - " + e.getMessage());
+                        }
+                    });
+        }
+    }
+
+
+    @Test
+    void testSaveData_FileCreatedAndDataWritten() throws IOException {
+        String testData = "Hello, World!";
+
+
+        SaveToFileService.saveData(testData, tempFile.toString());
+
+
+        assertTrue(Files.exists(tempFile), "Folder has been created");
+
+
+        String content = Files.readString(tempFile);
+        assertEquals(testData, content, "Folder's content is valid");
+    }
+
+    @Test
+    void testSaveData_CreatesMissingDirectories() {
+        Path nestedFile = tempDir.resolve("nested/directory/testFile.txt");
+
+
+        SaveToFileService.saveData("Test", nestedFile.toString());
+
+
+        assertTrue(Files.exists(nestedFile), "Folder has been created");
+        assertTrue(Files.exists(nestedFile.getParent()), "Folder has been created");
+    }
+
+    @Test
+    void testSaveData_InvalidPath_ShouldNotThrowException() {
+
+        String invalidPath = "/root/protected/test.txt";
+
+
+        assertDoesNotThrow(() -> SaveToFileService.saveData("Test", invalidPath));
+    }
+}

sdk-java/src/test/java/service/WatchServiceTest.java

@@ -0,0 +1,56 @@
+package service;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.vsecm.service.WatchService;
+import org.vsecm.task.Task;
+import org.vsecm.task.TaskFactory;
+
+
+import java.util.concurrent.*;
+
+import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.Mockito.*;
+import static org.awaitility.Awaitility.await;
+import java.time.Duration;
+
+class WatchServiceTest {
+    private TaskFactory mockTaskFactory;
+    private Task mockTask;
+    private ScheduledExecutorService scheduler;
+
+    @BeforeEach
+    void setUp() {
+        mockTaskFactory = mock(TaskFactory.class);
+        mockTask = mock(Task.class);
+        scheduler = Executors.newSingleThreadScheduledExecutor();
+    }
+
+    @Test
+    void testWatch_ShouldReturnFutureWithExpectedResult() throws Exception {
+        // GIVEN
+        String expectedResponse = "Mock Response";
+        String testUri = "https://example.com/secret";
+
+
+        CompletableFuture<String> fakeFuture = CompletableFuture.completedFuture(expectedResponse);
+
+
+        when(mockTaskFactory.createTask(any())).thenReturn(mockTask);
+        when(mockTask.execute(testUri)).thenReturn(fakeFuture);
+
+        // WHEN
+        Future<String> resultFuture = WatchService.watch(mockTaskFactory, testUri);
+
+        // THEN
+        await().atMost(Duration.ofSeconds(2)).until(resultFuture::isDone);
+
+
+        String actualResult = resultFuture.get();
+        assertEquals(expectedResponse, actualResult, "Unexpected condition!");
+
+
+        verify(mockTaskFactory).createTask(any());
+        verify(mockTask).execute(testUri);
+    }
+}