Skip to content
Snippets Groups Projects
Commit 9f5452af authored by Krzysztof Witukiewicz's avatar Krzysztof Witukiewicz
Browse files

OZG-7811 OZG-8099 Registration of loaders

parent 2ae5aca2
No related branches found
No related tags found
1 merge request!23Ozg 7811 vorgaenge zur landesebene schicken
Show whitespace changes
Inline Side-by-side
Showing
with 30 additions and 109 deletions
aggregation-manager-job/src/main/java/de/ozgcloud/aggregation/AggregationDataLoader.java
+ 0
− 4
View file @ 9f5452af
......@@ -23,11 +23,7 @@
*/
package de.ozgcloud.aggregation;
import de.ozgcloud.aggregation.transformation.AggregationMapping;
public interface AggregationDataLoader {
void loadIntoTarget(Aggregation aggregation);
boolean supportsScope(AggregationMapping.Scope scope);
}
aggregation-manager-job/src/main/java/de/ozgcloud/aggregation/AggregationDataLoaderRegistry.java
+ 4
− 19
View file @ 9f5452af
......@@ -23,12 +23,8 @@
*/
package de.ozgcloud.aggregation;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.function.Predicate;
import javax.annotation.PostConstruct;
import java.util.Optional;
import org.springframework.stereotype.Component;
......@@ -40,24 +36,13 @@ import lombok.RequiredArgsConstructor;
@RequiredArgsConstructor
class AggregationDataLoaderRegistry {
private final List<AggregationDataLoader> loaders;
private final Map<AggregationMapping.Scope, AggregationDataLoader> scopeToLoader = new HashMap<>();
@PostConstruct
void buildLoadersMap() {
}
private final Map<String, AggregationDataLoader> loaders;
public boolean hasLoader(AggregationMapping.Scope scope) {
return loaders.stream().anyMatch(supportsScope(scope));
return loaders.containsKey(scope.name());
}
public AggregationDataLoader getLoader(AggregationMapping.Scope scope) {
return loaders.stream().filter(supportsScope(scope)).findFirst()
.orElseThrow(() -> new TechnicalException("No loader found for scope " + scope));
}
private Predicate<AggregationDataLoader> supportsScope(AggregationMapping.Scope scope) {
return loader -> loader.supportsScope(scope);
return Optional.ofNullable(loaders.get(scope.name())).orElseThrow(() -> new TechnicalException("No data loader for scope " + scope));
}
}
aggregation-manager-job/src/main/java/de/ozgcloud/aggregation/AggregationWarehouseDataLoader.java
+ 3
− 6
View file @ 9f5452af
......@@ -24,19 +24,21 @@
package de.ozgcloud.aggregation;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;
import de.ozgcloud.aggregation.transformation.AggregationMapping;
import de.ozgcloud.aggregation.warehouse.DocumentEntry;
import de.ozgcloud.aggregation.warehouse.WarehouseRepository;
import lombok.RequiredArgsConstructor;
import lombok.extern.log4j.Log4j2;
@Component
@Qualifier(AggregationWarehouseDataLoader.SCOPE)
@RequiredArgsConstructor
@Log4j2
public class AggregationWarehouseDataLoader implements AggregationDataLoader {
static final String SCOPE = "INTERN";
private final WarehouseRepository repository;
@Override
......@@ -49,9 +51,4 @@ public class AggregationWarehouseDataLoader implements AggregationDataLoader {
String getCollectionName(Aggregation aggregation) {
return StringUtils.isNotBlank(aggregation.aggregationName()) ? aggregation.aggregationName() : DocumentEntry.COLLECTION;
}
@Override
public boolean supportsScope(AggregationMapping.Scope scope) {
return AggregationMapping.Scope.INTERN.equals(scope);
}
}
aggregation-manager-job/src/main/java/de/ozgcloud/aggregation/extern/AggregationRemoteDataLoader.java
+ 3
− 5
View file @ 9f5452af
......@@ -25,22 +25,24 @@ package de.ozgcloud.aggregation.extern;
import java.util.concurrent.ExecutionException;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;
import de.ozgcloud.aggregation.Aggregation;
import de.ozgcloud.aggregation.AggregationDataLoader;
import de.ozgcloud.aggregation.transformation.AggregationMapping;
import de.ozgcloud.common.errorhandling.TechnicalException;
import lombok.RequiredArgsConstructor;
import lombok.extern.log4j.Log4j2;
@Component
@Qualifier(AggregationRemoteDataLoader.SCOPE)
@ConditionalOnProperty("grpc.client.aggregation-manager.address")
@RequiredArgsConstructor
@Log4j2
public class AggregationRemoteDataLoader implements AggregationDataLoader {
static final String SCOPE = "EXTERN";
private final AggregationDataRemoteService service;
@Override
......@@ -54,8 +56,4 @@ public class AggregationRemoteDataLoader implements AggregationDataLoader {
throw new TechnicalException("Error on sending aggregation data.", e);
}
}
public boolean supportsScope(AggregationMapping.Scope scope) {
return AggregationMapping.Scope.EXTERN.equals(scope);
}
}
aggregation-manager-job/src/test/java/de/ozgcloud/aggregation/AggregationDataLoaderRegistryTest.java
+ 10
− 48
View file @ 9f5452af
......@@ -26,7 +26,6 @@ package de.ozgcloud.aggregation;
import static org.assertj.core.api.Assertions.*;
import static org.mockito.Mockito.*;
import java.util.List;
import java.util.Map;
import org.junit.jupiter.api.BeforeEach;
......@@ -36,58 +35,36 @@ import org.mockito.Mock;
import de.ozgcloud.aggregation.transformation.AggregationMapping;
import de.ozgcloud.common.errorhandling.TechnicalException;
import de.ozgcloud.common.test.ReflectionTestUtils;
class AggregationDataLoaderRegistryTest {
private static final String SCOPE_KEY = AggregationWarehouseDataLoader.SCOPE;
private final AggregationMapping.Scope registeredScope = AggregationMapping.Scope.INTERN;
private final AggregationMapping.Scope notRegisteredScope = AggregationMapping.Scope.EXTERN;
@Mock
private AggregationDataLoader loader;
private AggregationDataLoaderRegistry registry;
@BeforeEach
void init() {
registry = spy(new AggregationDataLoaderRegistry(List.of(loader)));
}
@Nested
class TestBuildLoadersMap {
@Test
void shouldAddLoader() {
}
@SuppressWarnings("unchecked")
private Map<AggregationMapping.Scope, AggregationDataLoader> getScopeToLoader() {
return ReflectionTestUtils.getField(registry, "scopeToLoader", Map.class);
}
registry = spy(new AggregationDataLoaderRegistry(Map.of(SCOPE_KEY, loader)));
}
@Nested
class TestHasLoader {
@Test
void shouldCheckIfLoaderSupportsScope() {
var scope = AggregationMapping.Scope.INTERN;
registry.hasLoader(scope);
verify(loader).supportsScope(scope);
}
@Test
void shouldReturnFalseIfNoLoaderRegisteredForScope() {
when(loader.supportsScope(any())).thenReturn(false);
var hasLoader = registry.hasLoader(AggregationMapping.Scope.INTERN);
var hasLoader = registry.hasLoader(notRegisteredScope);
assertThat(hasLoader).isFalse();
}
@Test
void shouldReturnTrueIfLoaderRegisteredForScope() {
when(loader.supportsScope(any())).thenReturn(true);
var hasLoader = registry.hasLoader(AggregationMapping.Scope.INTERN);
var hasLoader = registry.hasLoader(registeredScope);
assertThat(hasLoader).isTrue();
}
......@@ -96,31 +73,16 @@ class AggregationDataLoaderRegistryTest {
@Nested
class TestGetLoader {
private final AggregationMapping.Scope scope = AggregationMapping.Scope.INTERN;
@Test
void shouldCheckIfLoaderSupportsScope() {
when(loader.supportsScope(any())).thenReturn(true);
registry.getLoader(scope);
verify(loader).supportsScope(scope);
}
@Test
void shouldReturnLoaderThatSupportsScope() {
when(loader.supportsScope(any())).thenReturn(true);
var loaderSupportingScope = registry.getLoader(scope);
var loaderSupportingScope = registry.getLoader(registeredScope);
assertThat(loaderSupportingScope).isSameAs(loader);
}
@Test
void shouldThrowExceptionIfNoLoaderRegisteredForScope() {
when(loader.supportsScope(any())).thenReturn(false);
assertThatThrownBy(() -> registry.getLoader(scope)).isInstanceOf(TechnicalException.class);
assertThatThrownBy(() -> registry.getLoader(notRegisteredScope)).isInstanceOf(TechnicalException.class);
}
}
}
aggregation-manager-job/src/test/java/de/ozgcloud/aggregation/AggregationWarehouseDataLoaderTest.java
+ 5
− 13
View file @ 9f5452af
......@@ -32,13 +32,13 @@ import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Nested;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.EnumSource;
import org.junit.jupiter.params.provider.NullAndEmptySource;
import org.mockito.ArgumentCaptor;
import org.mockito.Captor;
import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.mockito.Spy;
import org.springframework.beans.factory.annotation.Qualifier;
import com.thedeanda.lorem.LoremIpsum;
......@@ -111,21 +111,13 @@ class AggregationWarehouseDataLoaderTest {
}
@Nested
class TestSupportsScope {
@ParameterizedTest
@EnumSource(mode = EnumSource.Mode.EXCLUDE, names = "INTERN")
void shouldReturnFalse(AggregationMapping.Scope scope) {
var supported = loader.supportsScope(scope);
assertThat(supported).isFalse();
}
class TestQualifier {
@Test
void shouldReturnTrue() {
var supported = loader.supportsScope(AggregationMapping.Scope.INTERN);
void shouldBeIntern() {
var qualifierValue = AggregationWarehouseDataLoader.class.getAnnotation(Qualifier.class).value();
assertThat(supported).isTrue();
assertThat(qualifierValue).isEqualTo(AggregationMapping.Scope.INTERN.name());
}
}
}
aggregation-manager-job/src/test/java/de/ozgcloud/aggregation/extern/AggregationRemoteDataLoaderTest.java
+ 5
− 14
View file @ 9f5452af
......@@ -34,11 +34,10 @@ import java.util.concurrent.Future;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Nested;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.EnumSource;
import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.mockito.Spy;
import org.springframework.beans.factory.annotation.Qualifier;
import de.ozgcloud.aggregation.Aggregation;
import de.ozgcloud.aggregation.AggregationTestFactory;
......@@ -129,21 +128,13 @@ class AggregationRemoteDataLoaderTest {
}
@Nested
class TestSupportsScope {
@ParameterizedTest
@EnumSource(mode = EnumSource.Mode.EXCLUDE, names = "EXTERN")
void shouldReturnFalse(AggregationMapping.Scope scope) {
var supported = loader.supportsScope(scope);
assertThat(supported).isFalse();
}
class TestQualifier {
@Test
void shouldReturnTrue() {
var supported = loader.supportsScope(AggregationMapping.Scope.EXTERN);
void shouldBeExtern() {
var qualifierValue = AggregationRemoteDataLoader.class.getAnnotation(Qualifier.class).value();
assertThat(supported).isTrue();
assertThat(qualifierValue).isEqualTo(AggregationMapping.Scope.EXTERN.name());
}
}
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment

Impressum - Datenschutz - Barrierefreiheit