Additional tests for delta restoration

2 files changed, 133 insertions, 0 deletions

diff --git a/subprojects/store/src/test/java/tools/refinery/store/map/tests/MapUnitTests.java b/subprojects/store/src/test/java/tools/refinery/store/map/tests/MapUnitTests.java
index 77c62305..2216db76 100644
--- a/subprojects/store/src/test/java/tools/refinery/store/map/tests/MapUnitTests.java
+++ b/subprojects/store/src/test/java/tools/refinery/store/map/tests/MapUnitTests.java
@@ -2,6 +2,7 @@ package tools.refinery.store.map.tests;
 
 import org.junit.jupiter.api.Test;
 import tools.refinery.store.map.VersionedMapStore;
+import tools.refinery.store.map.VersionedMapStoreBuilder;
 import tools.refinery.store.map.VersionedMapStoreImpl;
 import tools.refinery.store.model.TupleHashProvider;
 import tools.refinery.store.tuple.Tuple;
@@ -18,4 +19,75 @@ class MapUnitTests {
                 var out2 = map.put(Tuple.of(1), true);
                 assertEquals(false, out2);
         }
+
+        @Test
+        void deltaRestoreTest() {
+                VersionedMapStore<Integer,String> store =
+                                VersionedMapStoreBuilder.<Integer,String>builder().setDefaultValue("x").buildOne();
+                var map = store.createMap();
+                map.put(1,"val");
+                var version1 = map.commit();
+                map.put(1,"x");
+                map.restore(version1);
+                System.out.println(map.getSize());
+                assertEquals(1,map.getSize());
+        }
+
+        @Test
+        void deltaRestoreTest2() {
+                VersionedMapStore<Integer,String> store =
+                                VersionedMapStoreBuilder.<Integer,String>builder().setDefaultValue("x").buildOne();
+                var map = store.createMap();
+                map.put(1,"x");
+                var version1 = map.commit();
+                map.put(1,"1");
+                map.restore(version1);
+                System.out.println(map.getSize());
+                assertEquals(0,map.getSize());
+        }
+        @Test
+        void deltaRestoreTest3() {
+                VersionedMapStore<Integer,String> store =
+                                VersionedMapStoreBuilder.<Integer,String>builder().setDefaultValue("x").buildOne();
+                var map = store.createMap();
+                map.commit();
+                map.put(1,"1");
+                map.put(2,"x");
+                assertEquals(1,map.getSize());
+                var version1 = map.commit();
+                map.put(1,"x");
+                assertEquals(0,map.getSize());
+                map.put(2,"2");
+                assertEquals(1,map.getSize());
+                map.put(2,"x");
+                assertEquals(0,map.getSize());
+                var version2 = map.commit();
+                map.restore(version1);
+                assertEquals(1,map.getSize());
+                map.restore(version2);
+                assertEquals(0,map.getSize());
+        }
+
+        @Test
+        void deltaRestoreTest4() {
+                VersionedMapStore<Integer,String> store =
+                                VersionedMapStoreBuilder.<Integer,String>builder().setDefaultValue("x").buildOne();
+                var map = store.createMap();
+                map.commit();
+                map.put(1,"1");
+                map.put(2,"x");
+                assertEquals(1,map.getSize());
+                var version1 = map.commit();
+                map.put(1,"x");
+                assertEquals(0,map.getSize());
+                map.put(2,"2");
+                assertEquals(1,map.getSize());
+                map.put(2,"x");
+                assertEquals(0,map.getSize());
+                var version2 = map.commit();
+                map.restore(version1);
+                assertEquals(1,map.getSize());
+                map.restore(version2);
+                assertEquals(0,map.getSize());
+        }
 }
diff --git a/subprojects/store/src/test/java/tools/refinery/store/map/tests/fuzz/SingleThreadFuzzTest.java b/subprojects/store/src/test/java/tools/refinery/store/map/tests/fuzz/SingleThreadFuzzTest.java
new file mode 100644
index 00000000..e7d49227
--- /dev/null
+++ b/subprojects/store/src/test/java/tools/refinery/store/map/tests/fuzz/SingleThreadFuzzTest.java
@@ -0,0 +1,61 @@
+package tools.refinery.store.map.tests.fuzz;
+
+import org.junit.jupiter.api.Tag;
+import org.junit.jupiter.api.Timeout;
+import org.junit.jupiter.params.ParameterizedTest;
+import org.junit.jupiter.params.provider.Arguments;
+import org.junit.jupiter.params.provider.MethodSource;
+import tools.refinery.store.map.VersionedMapStore;
+import tools.refinery.store.map.VersionedMapStoreBuilder;
+import tools.refinery.store.map.tests.fuzz.utils.FuzzTestUtils;
+import tools.refinery.store.map.tests.utils.MapTestEnvironment;
+
+import java.util.stream.Stream;
+
+import static tools.refinery.store.map.tests.fuzz.utils.FuzzTestCollections.*;
+
+class SingleThreadFuzzTest {
+        private void runFuzzTest(String scenario, int seed, int steps, int maxKey, int maxValue, boolean nullDefault, int commitFrequency, VersionedMapStoreBuilder<Integer, String> builder) {
+                String[] values = MapTestEnvironment.prepareValues(maxValue, nullDefault);
+
+                VersionedMapStore<Integer, String> store = builder.setDefaultValue(values[0]).buildOne();
+
+                // initialize runnables
+                MultiThreadTestRunnable runnable = new MultiThreadTestRunnable(scenario, store, steps, maxKey, values, seed, commitFrequency);
+
+                // start threads;
+                runnable.run();
+        }
+
+        static final String title = "SingleThread {index}/{0} Steps={1} Keys={2} Values={3} defaultNull={4} commit " +
+                        "frequency={5} seed={6} config={7}";
+
+        @ParameterizedTest(name = title)
+        @MethodSource
+        @Timeout(value = 10)
+        @Tag("fuzz")
+        void parametrizedFastFuzz(int ignoredTests, int steps, int noKeys, int noValues, boolean defaultNull,
+                                                          int commitFrequency, int seed, VersionedMapStoreBuilder<Integer, String> builder) {
+                runFuzzTest("SingleThreadS" + steps + "K" + noKeys + "V" + noValues + defaultNull + "CF" + commitFrequency +
+                                "s" + seed, seed, steps, noKeys, noValues, defaultNull, commitFrequency, builder);
+        }
+
+        static Stream<Arguments> parametrizedFastFuzz() {
+                return FuzzTestUtils.permutationWithSize(stepCounts, keyCounts, valueCounts, nullDefaultOptions,
+                                new Object[]{10, 100}, randomSeedOptions, storeConfigs);
+        }
+
+        @ParameterizedTest(name = title)
+        @MethodSource
+        @Tag("fuzz")
+        @Tag("slow")
+        void parametrizedSlowFuzz(int ignoredTests, int steps, int noKeys, int noValues, boolean nullDefault,
+                                                          int commitFrequency, int seed, VersionedMapStoreBuilder<Integer, String> builder) {
+                runFuzzTest("SingleThreadS" + steps + "K" + noKeys + "V" + noValues + "s" + seed, seed, steps, noKeys, noValues,
+                                nullDefault, commitFrequency, builder);
+        }
+
+        static Stream<Arguments> parametrizedSlowFuzz() {
+                return FuzzTestUtils.changeStepCount(RestoreFuzzTest.parametrizedFastFuzz(), 1);
+        }
+}