DatabaseTest.java
/*
* Copyright (c) 2021 Mārtiņš Avots (Martins Avots) and others
*
* This program and the accompanying materials are made available under the
* terms of the Eclipse Public License 2.0, which is available at
* http://www.eclipse.org/legal/epl-2.0, or the MIT License,
* which is available at https://spdx.org/licenses/MIT.html.
*
* SPDX-License-Identifier: EPL-2.0 OR MIT
*/
package net.splitcells.gel.data.database;
import net.splitcells.dem.data.set.list.List;
import net.splitcells.dem.testing.TestSuiteI;
import net.splitcells.gel.data.table.Line;
import net.splitcells.gel.data.table.attribute.Attribute;
import org.junit.jupiter.api.DynamicTest;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.TestFactory;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.Function;
import java.util.stream.Stream;
import static net.splitcells.dem.data.set.list.Lists.list;
import static net.splitcells.dem.data.set.list.Lists.listWithValuesOf;
import static net.splitcells.dem.testing.Mocking.anyObject;
import static net.splitcells.dem.testing.Mocking.anyString;
import static net.splitcells.dem.testing.TestTypes.UNIT_TEST;
import static net.splitcells.gel.data.table.attribute.AttributeI.attribute;
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
/**
* TODO Test incorrect types added to the content of a table.
* <p>
* TODO Test consistency, when adding or removing many things
*/
public class DatabaseTest extends TestSuiteI {
@Tag(UNIT_TEST)
@TestFactory
public Stream<DynamicTest> incorrectly_typed_values_addition_tests() {
return dynamicTests2(this::test_incorrectly_typed_values_addition_test, DatabaseSF.testDatabaseFactory());
}
public void test_incorrectly_typed_values_addition_test(Function<List<Attribute<?>>, Database> databaseConstructor) {
final Attribute<Integer> testAttribute = attribute(Integer.class, anyString());
final Database testSubject = databaseConstructor.apply(list(testAttribute));
assertThrows(Throwable.class, () -> testSubject.addTranslated(list("")));
}
@Tag(UNIT_TEST)
@TestFactory
public Stream<DynamicTest> incorrectly_sized_values_addition_tests() {
return dynamicTests2(this::test_incorrectly_sized_values_addition_test, DatabaseSF.emptyDatabase());
}
public void test_incorrectly_sized_values_addition_test(Database voidDatabase) {
assertThrows(Throwable.class, () -> voidDatabase.addTranslated(listWithValuesOf(anyObject())));
}
@Tag(UNIT_TEST)
@TestFactory
public Stream<DynamicTest> single_addition_and_removal_tests() {
return dynamicTests2(this::test_single_addition_and_removal, DatabaseSF.emptyDatabase());
}
public void test_single_addition_and_removal(Database voidDatabase) {
List<?> lineValues = list();
assertThat(voidDatabase.isEmpty());
final var addedLine = voidDatabase.addTranslated(lineValues);
assertThat(voidDatabase.size()).isEqualTo(1);
voidDatabase.remove(addedLine);
assertThat(voidDatabase.isEmpty());
assertThat(voidDatabase.rawLinesView().get(0)).isNull();
}
@Tag(UNIT_TEST)
@TestFactory
public Stream<DynamicTest> index_preservation_by_add_tests() {
return dynamicTests2(this::test_index_preservation_by_add, DatabaseSF.emptyDatabase());
}
public void test_index_preservation_by_add(Database voidDatabase) {
final var line = mock(Line.class);
final var context = voidDatabase;
when(line.context()).thenReturn(context);
when(line.value(any())).thenReturn(1);
when(line.index()).thenReturn(2);
assertThat(voidDatabase.addTranslated(list()).index()).isEqualTo(0);
assertThat(voidDatabase.add(line).index()).isEqualTo(2);
assertThat(voidDatabase.addTranslated(list()).index()).isEqualTo(1);
assertThat(voidDatabase.addTranslated(list()).index()).isEqualTo(3);
}
@Tag(UNIT_TEST)
@TestFactory
public Stream<DynamicTest> subscription_tests() {
return dynamicTests2(this::test_subscriptions, DatabaseSF.emptyDatabase());
}
public void test_subscriptions(Database voidDatabase) {
final var additionCounter = new AtomicInteger(0);// Mutable integer Object required.
final var removalCounter = new AtomicInteger(0);// Mutable integer Object required.
voidDatabase.subscribeToAfterAdditions(additionOf -> additionCounter.incrementAndGet());
voidDatabase.subscribeToBeforeRemoval(removalOf -> removalCounter.incrementAndGet());
test_single_addition_and_removal(voidDatabase);
assertThat(additionCounter).hasValue(1);
assertThat(removalCounter).hasValue(1);
}
@Tag(UNIT_TEST)
@TestFactory
public Stream<DynamicTest> addTranslated_with_too_many_values_tests() {
return dynamicTests2(this::test_addTranslated_with_too_many_values, DatabaseSF.emptyDatabase());
}
public void test_addTranslated_with_too_many_values(Database voidDatabase) {
assertThrows(Throwable.class, () -> {
voidDatabase.addTranslated(list(1));
});
}
}