Test/db module tests

db/core/build.gradle

@@ -1,3 +1,6 @@
 dependencies {
     api project(':types')
+
+    testImplementation 'com.pholser:junit-quickcheck-core:0.7'
+    testImplementation 'ru.vyarus:generics-resolver:3.0.0'
 }

db/core/src/test/java/org/ethereum/beacon/db/InMemoryDatabaseTest.java

@@ -0,0 +1,19 @@
+package org.ethereum.beacon.db;
+
+import com.pholser.junit.quickcheck.Property;
+import com.pholser.junit.quickcheck.runner.JUnitQuickcheck;
+import org.ethereum.beacon.db.source.impl.HashMapDataSource;
+import org.junit.runner.RunWith;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+@RunWith(JUnitQuickcheck.class)
+public class InMemoryDatabaseTest {
+
+    @Property
+    public void getBackingDataSource() {
+        final InMemoryDatabase database = new InMemoryDatabase();
+        assertThat(database.getBackingDataSource()).isNotNull();
+        assertThat(database.getBackingDataSource()).isInstanceOf(HashMapDataSource.class);
+    }
+}

db/core/src/test/java/org/ethereum/beacon/db/XorKeyDatabaseTest.java

@@ -0,0 +1,63 @@
+package org.ethereum.beacon.db;
+
+import com.pholser.junit.quickcheck.*;
+import com.pholser.junit.quickcheck.runner.JUnitQuickcheck;
+import org.ethereum.beacon.db.configuration.*;
+import org.ethereum.beacon.db.source.DataSource;
+import org.ethereum.beacon.db.source.impl.XorDataSource;
+import org.junit.runner.RunWith;
+import tech.pegasys.artemis.util.bytes.BytesValue;
+
+import java.util.function.Function;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+@RunWith(JUnitQuickcheck.class)
+public class XorKeyDatabaseTest {
+
+    private final String TEST_STORAGE_NAME = "TEST_STORAGE_NAME";
+    private final String TEST_ENTITY_KEY = "TEST_ENTITY_KEY";
+
+    @Property
+    public void createStorage(@From(HashMapDatasourceGenerator.class) DataSource<@From(EmptyBytesValueGenerator.class) BytesValue, @From(EmptyBytesValueGenerator.class) BytesValue> backingDataSource,
+                              @From(EmptyFunctionGenerator.class) Function<@From(EmptyBytesValueGenerator.class) BytesValue, @From(EmptyBytesValueGenerator.class) BytesValue> sourceNameHasher) {
+
+        final XorKeyDatabase database = new XorKeyDatabase(backingDataSource, sourceNameHasher) {
+            @Override
+            public void commit() {
+            }
+
+            @Override
+            public void close() {
+            }
+        };
+
+        final DataSource<BytesValue, BytesValue> actual = database.createStorage(TEST_STORAGE_NAME);
+        assertThat(actual).isNotNull();
+        assertThat(actual).isInstanceOf(XorDataSource.class);
+
+        final BytesValue key = BytesValue.wrap(TEST_ENTITY_KEY.getBytes());
+        final BytesValue value = BytesValue.EMPTY;
+        actual.put(key, value);
+        assertThat(actual.get(key)).isPresent().hasValue(value);
+    }
+
+    @Property
+    public void getBackingDataSource(@From(HashMapDatasourceGenerator.class) DataSource<@From(EmptyBytesValueGenerator.class) BytesValue, @From(EmptyBytesValueGenerator.class) BytesValue> backingDataSource,
+                                     @From(EmptyFunctionGenerator.class) Function<@From(EmptyBytesValueGenerator.class) BytesValue, @From(EmptyBytesValueGenerator.class) BytesValue> sourceNameHasher) {
+
+        final XorKeyDatabase actual = new XorKeyDatabase(backingDataSource, sourceNameHasher) {
+            @Override
+            public void commit() {
+            }
+
+            @Override
+            public void close() {
+            }
+        };
+
+        assertThat(actual).isNotNull();
+        assertThat(actual.getBackingDataSource()).isNotNull();
+        assertThat(actual.getBackingDataSource()).isEqualTo(backingDataSource);
+    }
+}

db/core/src/test/java/org/ethereum/beacon/db/configuration/EmptyBytesValueGenerator.java

@@ -0,0 +1,16 @@
+package org.ethereum.beacon.db.configuration;
+
+import com.pholser.junit.quickcheck.generator.*;
+import com.pholser.junit.quickcheck.random.SourceOfRandomness;
+import tech.pegasys.artemis.util.bytes.BytesValue;
+
+public class EmptyBytesValueGenerator extends Generator<BytesValue> {
+    public EmptyBytesValueGenerator() {
+        super(BytesValue.class);
+    }
+
+    @Override
+    public BytesValue generate(SourceOfRandomness random, GenerationStatus status) {
+        return BytesValue.EMPTY;
+    }
+}

db/core/src/test/java/org/ethereum/beacon/db/configuration/EmptyFunctionGenerator.java

@@ -0,0 +1,17 @@
+package org.ethereum.beacon.db.configuration;
+
+import com.pholser.junit.quickcheck.generator.*;
+import com.pholser.junit.quickcheck.random.SourceOfRandomness;
+
+import java.util.function.Function;
+
+public class EmptyFunctionGenerator extends Generator<Function> {
+    public EmptyFunctionGenerator() {
+        super(Function.class);
+    }
+
+    @Override
+    public Function generate(SourceOfRandomness random, GenerationStatus status) {
+        return Function.identity();
+    }
+}

db/core/src/test/java/org/ethereum/beacon/db/configuration/HashMapDatasourceGenerator.java

@@ -0,0 +1,17 @@
+package org.ethereum.beacon.db.configuration;
+
+import com.pholser.junit.quickcheck.generator.*;
+import com.pholser.junit.quickcheck.random.SourceOfRandomness;
+import org.ethereum.beacon.db.source.DataSource;
+import org.ethereum.beacon.db.source.impl.HashMapDataSource;
+
+public class HashMapDatasourceGenerator extends Generator<DataSource> {
+    public HashMapDatasourceGenerator() {
+        super(DataSource.class);
+    }
+
+    @Override
+    public HashMapDataSource generate(SourceOfRandomness random, GenerationStatus status) {
+        return new HashMapDataSource();
+    }
+}

db/core/src/test/java/org/ethereum/beacon/db/source/WriteCacheImplTest.java

@@ -0,0 +1,26 @@
+package org.ethereum.beacon.db.source;
+
+import com.pholser.junit.quickcheck.*;
+import com.pholser.junit.quickcheck.runner.JUnitQuickcheck;
+import org.ethereum.beacon.db.configuration.HashMapDatasourceGenerator;
+import org.junit.runner.RunWith;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+@RunWith(JUnitQuickcheck.class)
+public class WriteCacheImplTest {
+
+    private final String TEST_ENTITY_KEY = "TEST_ENTITY_KEY";
+
+    @Property
+    public void get(@From(HashMapDatasourceGenerator.class) DataSource dataSource) {
+        final CacheDataSource<String, String> cacheDataSource = new WriteCacheImpl<String, String>(dataSource);
+        assertThat(cacheDataSource.get(TEST_ENTITY_KEY)).isNotPresent();
+    }
+
+    @Property
+    public void getCacheEntry(@From(HashMapDatasourceGenerator.class) DataSource dataSource) {
+        final CacheDataSource<String, String> cacheDataSource = new WriteCacheImpl<String, String>(dataSource);
+        assertThat(cacheDataSource.get(TEST_ENTITY_KEY)).isNotPresent();
+    }
+}