Skip to content
Snippets Groups Projects
Commit b76df19c authored by OZGCloud's avatar OZGCloud
Browse files

OZG-6710 fix initialization of OzgCloudVorgangService

parent a9c4af71
No related branches found
No related tags found
No related merge requests found
...@@ -5,7 +5,6 @@ import java.util.HashSet; ...@@ -5,7 +5,6 @@ import java.util.HashSet;
import java.util.Optional; import java.util.Optional;
import java.util.Set; import java.util.Set;
import org.apache.commons.collections.CollectionUtils;
import org.mapstruct.CollectionMappingStrategy; import org.mapstruct.CollectionMappingStrategy;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.Mapping; import org.mapstruct.Mapping;
...@@ -44,7 +43,7 @@ public interface OzgCloudVorgangQueryMapper { ...@@ -44,7 +43,7 @@ public interface OzgCloudVorgangQueryMapper {
default GrpcQuery mapAllToQuery(OzgCloudVorgangQuery query) { default GrpcQuery mapAllToQuery(OzgCloudVorgangQuery query) {
var queryBuilder = GrpcQuery.newBuilder().setLogicalOperator(GrpcLogicalOperator.AND); var queryBuilder = GrpcQuery.newBuilder().setLogicalOperator(GrpcLogicalOperator.AND);
query.getAktenzeichen().map(this::toAktenzeichenExpression).ifPresent(queryBuilder::addExpressions); query.getAktenzeichen().map(this::toAktenzeichenExpression).ifPresent(queryBuilder::addExpressions);
query.getForm().map(this::toFormExpressions).filter(CollectionUtils::isNotEmpty).ifPresent(queryBuilder::addAllExpressions); query.getForm().map(this::toFormExpressions).ifPresent(queryBuilder::addAllExpressions);
query.getStatus().map(this::toStatusExpression).ifPresent(queryBuilder::addExpressions); query.getStatus().map(this::toStatusExpression).ifPresent(queryBuilder::addExpressions);
query.getOrganisationsEinheitId().map(this::toOrganisationsEinheitIdExpression).ifPresent(queryBuilder::addExpressions); query.getOrganisationsEinheitId().map(this::toOrganisationsEinheitIdExpression).ifPresent(queryBuilder::addExpressions);
query.getQuery().map(this::toQuery).ifPresent(queryBuilder::setNestedQuery); query.getQuery().map(this::toQuery).ifPresent(queryBuilder::setNestedQuery);
......
...@@ -37,7 +37,7 @@ import de.ozgcloud.apilib.vorgang.grpc.OzgCloudVorgangStubMapper; ...@@ -37,7 +37,7 @@ import de.ozgcloud.apilib.vorgang.grpc.OzgCloudVorgangStubMapper;
import de.ozgcloud.user.grpc.userprofile.UserProfileServiceGrpc; import de.ozgcloud.user.grpc.userprofile.UserProfileServiceGrpc;
import de.ozgcloud.vorgang.grpc.binaryFile.BinaryFileServiceGrpc; import de.ozgcloud.vorgang.grpc.binaryFile.BinaryFileServiceGrpc;
import de.ozgcloud.vorgang.grpc.command.CommandServiceGrpc; import de.ozgcloud.vorgang.grpc.command.CommandServiceGrpc;
import de.ozgcloud.vorgang.vorgang.VorgangServiceGrpc.VorgangServiceBlockingStub; import de.ozgcloud.vorgang.vorgang.VorgangServiceGrpc;
import io.grpc.ManagedChannelBuilder; import io.grpc.ManagedChannelBuilder;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import net.devh.boot.grpc.client.autoconfigure.GrpcClientAutoConfiguration; import net.devh.boot.grpc.client.autoconfigure.GrpcClientAutoConfiguration;
...@@ -134,9 +134,10 @@ public class OzgCloudClientAutoConfiguration { ...@@ -134,9 +134,10 @@ public class OzgCloudClientAutoConfiguration {
@Bean("ozgCloudVorgangService") @Bean("ozgCloudVorgangService")
@ConditionalOnProperty("ozgcloud.vorgang-manager.address") @ConditionalOnProperty("ozgcloud.vorgang-manager.address")
@ConditionalOnMissingBean(OzgCloudVorgangService.class) @ConditionalOnMissingBean(OzgCloudVorgangService.class)
OzgCloudVorgangService grpcOzgCloudVorgangService(VorgangServiceBlockingStub vorgangServiceStub, OzgCloudVorgangMapper mapper, OzgCloudVorgangService grpcOzgCloudVorgangService(OzgCloudVorgangMapper mapper, OzgCloudVorgangStubMapper stubMapper,
OzgCloudVorgangStubMapper stubMapper, OzgCloudVorgangQueryMapper queryMapper, OzgCloudCallContextProvider contextProvider) { OzgCloudVorgangQueryMapper queryMapper, OzgCloudCallContextProvider contextProvider) {
var channel = ManagedChannelBuilder.forTarget(vorgangManagerProperties.getAddress()).usePlaintext().build();
var vorgangServiceStub = VorgangServiceGrpc.newBlockingStub(channel);
return new GrpcOzgCloudVorgangService(vorgangServiceStub, mapper, stubMapper, queryMapper, contextProvider); return new GrpcOzgCloudVorgangService(vorgangServiceStub, mapper, stubMapper, queryMapper, contextProvider);
} }
......
/*
* Copyright (C) 2024 Das Land Schleswig-Holstein vertreten durch den
* Ministerpräsidenten des Landes Schleswig-Holstein
* Staatskanzlei
* Abteilung Digitalisierung und zentrales IT-Management der Landesregierung
*
* Lizenziert unter der EUPL, Version 1.2 oder - sobald
* diese von der Europäischen Kommission genehmigt wurden -
* Folgeversionen der EUPL ("Lizenz");
* Sie dürfen dieses Werk ausschließlich gemäß
* dieser Lizenz nutzen.
* Eine Kopie der Lizenz finden Sie hier:
*
* https://joinup.ec.europa.eu/collection/eupl/eupl-text-eupl-12
*
* Sofern nicht durch anwendbare Rechtsvorschriften
* gefordert oder in schriftlicher Form vereinbart, wird
* die unter der Lizenz verbreitete Software "so wie sie
* ist", OHNE JEGLICHE GEWÄHRLEISTUNG ODER BEDINGUNGEN -
* ausdrücklich oder stillschweigend - verbreitet.
* Die sprachspezifischen Genehmigungen und Beschränkungen
* unter der Lizenz sind dem Lizenztext zu entnehmen.
*/
package de.ozgcloud.client.autoconfigure;
import static org.assertj.core.api.Assertions.*;
import org.junit.jupiter.api.Nested;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import de.ozgcloud.apilib.autoconfig.ApiLibTestApplication;
import de.ozgcloud.apilib.vorgang.OzgCloudVorgangService;
import de.ozgcloud.apilib.vorgang.dummy.DummyVorgangService;
import de.ozgcloud.apilib.vorgang.grpc.GrpcOzgCloudVorgangService;
public class OzgCloudVorgangServiceStarterITCase {
@Nested
@SpringBootTest(classes = ApiLibTestApplication.class, properties = {
"ozgcloud.vorgang-manager.address=address"
})
class TestWithOzgCloudVorgangService {
@Autowired
private OzgCloudVorgangService ozgCloudVorgangService;
@Test
void shouldStart() {
assertThat(ozgCloudVorgangService).isInstanceOf(GrpcOzgCloudVorgangService.class);
}
}
@Nested
@SpringBootTest(classes = ApiLibTestApplication.class)
class TestWithExistingOzgCloudVorgangService {
@Autowired
private OzgCloudVorgangService ozgCloudVorgangService;
@Test
void shouldStart() { // NOSONAR
assertThat(ozgCloudVorgangService).isInstanceOf(DummyVorgangService.class);
}
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment