-
Notifications
You must be signed in to change notification settings - Fork 4
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
8ccb90e
commit 0a76e96
Showing
3 changed files
with
237 additions
and
17 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,9 +1,12 @@ | ||
| [versions] | ||
| gradle = "8.7.3" | ||
| rustAndroid = "0.9.4" | ||
| junitJupiterApi = "5.11.3" | ||
| axionReleasePlugin = "1.17.0" | ||
|
|
||
| [libraries] | ||
| gradle = { module = "com.android.tools.build:gradle", version.ref = "gradle" } | ||
| rust-android = { module = "org.mozilla.rust-android-gradle:plugin", version.ref = "rustAndroid" } | ||
| junit-jupiter-api = { module = "org.junit.jupiter:junit-jupiter-api", version.ref = "junitJupiterApi" } | ||
| junit-jupiter-engine = { module = "org.junit.jupiter:junit-jupiter-engine", version.ref = "junitJupiterApi" } | ||
| axion-release-plugin = { module = "pl.allegro.tech.build:axion-release-plugin", version.ref = "axionReleasePlugin" } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
193 changes: 193 additions & 0 deletions
193
java/lib/src/test/java/dev/arkbuilders/core/FileStorageTest.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,193 @@ | ||
| package dev.arkbuilders.core; | ||
|
|
||
| import static org.junit.jupiter.api.Assertions.assertEquals; | ||
| import static org.junit.jupiter.api.Assertions.assertFalse; | ||
| import static org.junit.jupiter.api.Assertions.assertThrows; | ||
| import static org.junit.jupiter.api.Assertions.assertTrue; | ||
|
|
||
| import org.junit.jupiter.api.Test; | ||
| import org.junit.jupiter.api.io.TempDir; | ||
|
|
||
| import java.io.File; | ||
| import java.nio.file.Path; | ||
| import java.util.LinkedHashMap; | ||
| import java.util.Map; | ||
| import java.util.Objects; | ||
|
|
||
| public class FileStorageTest { | ||
| @TempDir | ||
| Path tempDir; | ||
|
|
||
| @Test | ||
| public void testFileStorageWriteRead() { | ||
| Path storagePath = tempDir.resolve("test.txt"); | ||
| FileStorage fileStorage = new FileStorage("test", storagePath.toString()); | ||
|
|
||
| fileStorage.set("key1", "value1"); | ||
| fileStorage.set("key2", "value2"); | ||
|
|
||
| fileStorage.remove("key1"); | ||
| fileStorage.writeFS(); | ||
|
|
||
| @SuppressWarnings("unchecked") | ||
| LinkedHashMap<String, String> data = (LinkedHashMap<String, String>) fileStorage.readFS(); | ||
| assertEquals(1, data.size()); | ||
| assertEquals("value2", data.get("key2")); | ||
| } | ||
|
|
||
| @Test | ||
| public void testFileStorageAutoDelete() { | ||
| Path storagePath = tempDir.resolve("test.txt"); | ||
| FileStorage fileStorage = new FileStorage("test", storagePath.toString()); | ||
|
|
||
| fileStorage.set("key1", "value1"); | ||
| fileStorage.set("key1", "value2"); | ||
| fileStorage.writeFS(); | ||
|
|
||
| File file = storagePath.toFile(); | ||
| assertTrue(file.exists()); | ||
|
|
||
| fileStorage.erase(); | ||
| assertFalse(file.exists()); | ||
| } | ||
|
|
||
| @Test | ||
| public void testFileStorageNeedsSyncing() { | ||
| Path storagePath = tempDir.resolve("test.txt"); | ||
| FileStorage fileStorage = new FileStorage("test", storagePath.toString()); | ||
| fileStorage.writeFS(); | ||
| assertEquals(FileStorage.SyncStatus.InSync, fileStorage.syncStatus()); | ||
| fileStorage.set("key1", "value1"); | ||
| assertEquals(FileStorage.SyncStatus.StorageStale, fileStorage.syncStatus()); | ||
| fileStorage.writeFS(); | ||
| assertEquals(FileStorage.SyncStatus.InSync, fileStorage.syncStatus()); | ||
| } | ||
|
|
||
| @Test | ||
| public void testFileStorageMonoidCombine() { | ||
| Path storagePath1 = tempDir.resolve("test1.txt"); | ||
| Path storagePath2 = tempDir.resolve("test2.txt"); | ||
| FileStorage fileStorage1 = new FileStorage("test1", storagePath1.toString()); | ||
| FileStorage fileStorage2 = new FileStorage("test2", storagePath2.toString()); | ||
|
|
||
| fileStorage1.set("key1", "2"); | ||
| fileStorage1.set("key2", "6"); | ||
|
|
||
| fileStorage2.set("key1", "3"); | ||
| fileStorage2.set("key3", "9"); | ||
|
|
||
| fileStorage1.merge(fileStorage2); | ||
| fileStorage1.writeFS(); | ||
|
|
||
| @SuppressWarnings("unchecked") | ||
| LinkedHashMap<String, String> data = (LinkedHashMap<String, String>) fileStorage1.readFS(); | ||
| assertEquals(3, data.size()); | ||
| assertEquals("23", data.get("key1")); | ||
| assertEquals("6", data.get("key2")); | ||
| assertEquals("9", data.get("key3")); | ||
| } | ||
|
|
||
| @Test | ||
| public void testFileStorageMainScenario() { | ||
| Path storagePath = tempDir.resolve("test.txt"); | ||
| FileStorage fileStorage = new FileStorage("test", storagePath.toString()); | ||
|
|
||
| fileStorage.set("key", "value"); | ||
| fileStorage.set("key", "value1"); | ||
| fileStorage.set("key1", "value"); | ||
|
|
||
| fileStorage.remove("key"); | ||
|
|
||
| try { | ||
| Thread.sleep(1000); | ||
| } catch (InterruptedException e) { | ||
| e.printStackTrace(); | ||
| } | ||
|
|
||
| fileStorage.writeFS(); | ||
|
|
||
| @SuppressWarnings("unchecked") | ||
| LinkedHashMap<String, String> data = (LinkedHashMap<String, String>) fileStorage.readFS(); | ||
| assertEquals(1, data.size()); | ||
| assertEquals("value", data.get("key1")); | ||
|
|
||
| fileStorage.erase(); | ||
| File file = storagePath.toFile(); | ||
| assertFalse(file.exists()); | ||
| } | ||
|
|
||
| @Test | ||
| public void testFileStorageGet() { | ||
| Path storagePath = tempDir.resolve("test.txt"); | ||
| FileStorage fileStorage = new FileStorage("test", storagePath.toString()); | ||
|
|
||
| fileStorage.set("key", "value"); | ||
| fileStorage.set("key", "value1"); | ||
| fileStorage.set("key1", "value"); | ||
|
|
||
| assertEquals("value1", fileStorage.get("key")); | ||
| assertEquals("value", fileStorage.get("key1")); | ||
| } | ||
|
|
||
| @Test | ||
| public void testBTreeMapIterator() { | ||
| Path storagePath = tempDir.resolve("test.txt"); | ||
| FileStorage fileStorage = new FileStorage("test", storagePath.toString()); | ||
|
|
||
| fileStorage.set("key", "value"); | ||
| fileStorage.set("key", "value1"); | ||
| fileStorage.set("key1", "value"); | ||
|
|
||
| fileStorage.writeFS(); | ||
|
|
||
| @SuppressWarnings("unchecked") | ||
| LinkedHashMap<String, String> data = (LinkedHashMap<String, String>) fileStorage.readFS(); | ||
|
|
||
| BTreeMapIterator bTreeMapIterator = fileStorage.iterator(); | ||
| Map<String, String> iteratorData = new LinkedHashMap<>(); | ||
| while (bTreeMapIterator.hasNext()) { | ||
| Map.Entry<String, String> entry = bTreeMapIterator.next(); | ||
| iteratorData.put(entry.getKey(), entry.getValue()); | ||
| } | ||
| assertEquals(data, iteratorData); | ||
| } | ||
|
|
||
| @Test | ||
| public void testRemoveException() { | ||
| Path storagePath = tempDir.resolve("test.txt"); | ||
| FileStorage fileStorage = new FileStorage("test", storagePath.toString()); | ||
| Exception exception = assertThrows(RuntimeException.class, () -> fileStorage.remove("invalid_id")); | ||
| assertTrue(Objects.requireNonNull(exception.getMessage()).matches("Storage error.*")); | ||
| } | ||
|
|
||
| @Test | ||
| public void testSyncException() { | ||
| Path storagePath = tempDir.resolve("test.txt"); | ||
| FileStorage fileStorage = new FileStorage("test", storagePath.toString()); | ||
| Exception exception = assertThrows(RuntimeException.class, fileStorage::sync); | ||
| assertTrue(Objects.requireNonNull(exception.getMessage()).matches("IO error.*")); | ||
| } | ||
|
|
||
| @Test | ||
| public void testCreateException() { | ||
| Path storagePath = tempDir.resolve(""); | ||
| Exception exception = assertThrows(RuntimeException.class, () -> new FileStorage("", storagePath.toString())); | ||
| assertTrue(Objects.requireNonNull(exception.getMessage()).matches("IO error.*")); | ||
| } | ||
|
|
||
| @Test | ||
| public void testEraseException() { | ||
| Path storagePath = tempDir.resolve("test.txt"); | ||
| FileStorage fileStorage = new FileStorage("test", storagePath.toString()); | ||
| Exception exception = assertThrows(RuntimeException.class, fileStorage::erase); | ||
| assertTrue(Objects.requireNonNull(exception.getMessage()).matches("Storage error.*")); | ||
| } | ||
|
|
||
| @Test | ||
| public void testReadException() { | ||
| Path storagePath = tempDir.resolve("test.txt"); | ||
| FileStorage fileStorage = new FileStorage("test", storagePath.toString()); | ||
| Exception exception = assertThrows(RuntimeException.class, fileStorage::readFS); | ||
| assertTrue(Objects.requireNonNull(exception.getMessage()).matches("Storage error.*")); | ||
| } | ||
| } |