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

OZG-6710 adjust bean initialization

parent 24f11bea
No related branches found
No related tags found
No related merge requests found
Show whitespace changes
Inline Side-by-side
Showing
with 237 additions and 30 deletions
api-lib-core/src/main/java/de/ozgcloud/apilib/file/grpc/GrpcOzgCloudFileService.java
+ 0
− 4
View file @ fc66ba97
......@@ -9,8 +9,6 @@ import java.util.concurrent.TimeoutException;
import java.util.logging.Level;
import org.apache.commons.io.IOUtils;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Service;
import com.google.protobuf.ByteString;
......@@ -40,8 +38,6 @@ import lombok.RequiredArgsConstructor;
import lombok.extern.java.Log;
import net.devh.boot.grpc.client.inject.GrpcClient;
@Service
@ConditionalOnProperty("ozgcloud.file-manager.address")
@RequiredArgsConstructor
@Log
public class GrpcOzgCloudFileService implements OzgCloudFileService {
......
ozg-cloud-spring-boot-starter/src/main/java/de/ozgcloud/client/autoconfigure/OzgCloudClientAutoConfiguration.java
+ 32
− 26
View file @ fc66ba97
......@@ -4,7 +4,6 @@ import java.util.Collection;
import java.util.Map;
import org.mapstruct.factory.Mappers;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
......@@ -22,9 +21,11 @@ import de.ozgcloud.apilib.common.callcontext.OzgCloudCallContextProvider;
import de.ozgcloud.apilib.common.command.OzgCloudCommandService;
import de.ozgcloud.apilib.common.command.grpc.CommandMapper;
import de.ozgcloud.apilib.common.command.grpc.GrpcOzgCloudCommandService;
import de.ozgcloud.apilib.file.dummy.DummyOzgCloudFileService;
import de.ozgcloud.apilib.file.OzgCloudFileService;
import de.ozgcloud.apilib.file.grpc.GrpcOzgCloudFileService;
import de.ozgcloud.apilib.file.grpc.OzgCloudFileMapper;
import de.ozgcloud.apilib.user.GrpcOzgCloudUserProfileService;
import de.ozgcloud.apilib.user.OzgCloudUserProfileService;
import de.ozgcloud.apilib.user.UserProfileMapper;
import de.ozgcloud.apilib.vorgang.OzgCloudVorgangIdMapper;
import de.ozgcloud.apilib.vorgang.OzgCloudVorgangService;
......@@ -33,20 +34,20 @@ import de.ozgcloud.apilib.vorgang.grpc.GrpcOzgCloudVorgangService;
import de.ozgcloud.apilib.vorgang.grpc.OzgCloudVorgangMapper;
import de.ozgcloud.apilib.vorgang.grpc.OzgCloudVorgangQueryMapper;
import de.ozgcloud.apilib.vorgang.grpc.OzgCloudVorgangStubMapper;
import de.ozgcloud.user.grpc.userprofile.UserProfileServiceGrpc;
import de.ozgcloud.vorgang.grpc.binaryFile.BinaryFileServiceGrpc;
import de.ozgcloud.vorgang.grpc.command.CommandServiceGrpc;
import de.ozgcloud.vorgang.vorgang.VorgangServiceGrpc.VorgangServiceBlockingStub;
import io.grpc.ManagedChannelBuilder;
import lombok.RequiredArgsConstructor;
import net.devh.boot.grpc.client.autoconfigure.GrpcClientAutoConfiguration;
import net.devh.boot.grpc.client.config.GrpcChannelProperties;
import net.devh.boot.grpc.client.config.GrpcChannelsProperties;
@AutoConfiguration(before = GrpcClientAutoConfiguration.class)
@ComponentScan("de.ozgcloud.client.autoconfigure")
@Import({
GrpcOzgCloudFileService.class, DummyOzgCloudFileService.class,
OzgCloudCallContextAttachingInterceptor.class
})
@Import({ OzgCloudCallContextAttachingInterceptor.class })
@RequiredArgsConstructor
public class OzgCloudClientAutoConfiguration {
private static final String CLIENT_NAME_VORGANG_MANAGER = "vorgang-manager";
......@@ -54,14 +55,10 @@ public class OzgCloudClientAutoConfiguration {
private static final String CLIENT_NAME_COMMAND_MANAGER = "ozgcloud-command-manager";
private static final String CLIENT_NAME_USER_MANAGER = "ozgcloud-user-manager";
@Autowired
private OzgCloudVorgangManagerProperties vorgangManagerProperties;
@Autowired
private OzgCloudFileManagerProperties fileManagerProperties;
@Autowired
private OzgCloudCommandManagerProperties commandManagerProperties;
@Autowired
private OzgCloudUserManagerProperties userManagerProperties;
private final OzgCloudVorgangManagerProperties vorgangManagerProperties;
private final OzgCloudFileManagerProperties fileManagerProperties;
private final OzgCloudCommandManagerProperties commandManagerProperties;
private final OzgCloudUserManagerProperties userManagerProperties;
// @Bean
// @ConditionalOnProperty("ozgcloud.vorgang-manager.address")
......@@ -99,7 +96,7 @@ public class OzgCloudClientAutoConfiguration {
@Bean
GrpcChannelsProperties clientProperties(Collection<GrpcChannelConfigurator> configurators) {
var properties = new GrpcChannelsProperties();
configurators.stream().forEach(configurator -> configurator.addToProperties(properties));
configurators.forEach(configurator -> configurator.addToProperties(properties));
return properties;
}
......@@ -210,13 +207,22 @@ public class OzgCloudClientAutoConfiguration {
return Mappers.getMapper(OzgCloudFileMapper.class);
}
// @Bean
// @ConditionalOnProperty("ozgcloud.user-manager.address")
// OzgCloudUserProfileService
// grpcOzgCloudUserProfileService(@GrpcClient("ozgcloud-user-manager")
// UserProfileServiceBlockingStub grpcStub,
// UserProfileMapper mapper) {
// System.out.println("#### building UM-ProfileService");
// return new GrpcOzgCloudUserProfileService(grpcStub, mapper);
// }
@Bean
@ConditionalOnMissingBean
@ConditionalOnProperty("ozgcloud.user-manager.address")
OzgCloudUserProfileService grpcOzgCloudUserProfileService(UserProfileMapper mapper, OzgCloudCallContextProvider contextProvider) {
var channel = ManagedChannelBuilder.forTarget(userManagerProperties.getAddress()).usePlaintext().build();
var userServiceStub = UserProfileServiceGrpc.newBlockingStub(channel);
return new GrpcOzgCloudUserProfileService(userServiceStub, mapper, contextProvider);
}
@Bean
@ConditionalOnProperty("ozgcloud.file-manager.address")
@ConditionalOnMissingBean
OzgCloudFileService grpcOzgCloudFileService(OzgCloudFileMapper mapper, OzgCloudCallContextProvider contextProvider) {
var channel = ManagedChannelBuilder.forTarget(fileManagerProperties.getAddress()).usePlaintext().build();
var blockingStub = BinaryFileServiceGrpc.newBlockingStub(channel);
var asyncStub = BinaryFileServiceGrpc.newStub(channel);
return new GrpcOzgCloudFileService(blockingStub, asyncStub, contextProvider, mapper);
}
}
ozg-cloud-spring-boot-starter/src/test/java/de/ozgcloud/client/autoconfigure/OzgCloudFileServiceStarterITCase.java 0 → 100644
+ 98
− 0
View file @ fc66ba97
/*
* 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 java.util.Optional;
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 org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Import;
import org.springframework.test.annotation.DirtiesContext;
import de.ozgcloud.apilib.autoconfig.ApiLibTestApplication;
import de.ozgcloud.apilib.file.OzgCloudFileService;
import de.ozgcloud.apilib.file.dummy.DummyOzgCloudFileService;
import de.ozgcloud.apilib.file.grpc.GrpcOzgCloudFileService;
public class OzgCloudFileServiceStarterITCase {
@Nested
@SpringBootTest(classes = ApiLibTestApplication.class)
@DirtiesContext()
class TestWithoutOzgCloudFileService {
@Autowired
private Optional<OzgCloudFileService> ozgCloudFileService;
@Test
void shouldStart() {
assertThat(ozgCloudFileService).isEmpty();
}
}
@Nested
@SpringBootTest(classes = ApiLibTestApplication.class, properties = {
"ozgcloud.file-manager.address=address"
})
@DirtiesContext
class TestWithOzgCloudFileService {
@Autowired
private OzgCloudFileService ozgCloudFileService;
@Test
void shouldStart() {
assertThat(ozgCloudFileService).isInstanceOf(GrpcOzgCloudFileService.class);
}
}
@Nested
@SpringBootTest(classes = ApiLibTestApplication.class, properties = {
"ozgcloud.file-manager.address=address"
})
@Import(TestWithExistingOzgCloudFileService.Config.class)
class TestWithExistingOzgCloudFileService {
@Autowired
private OzgCloudFileService ozgCloudFileService;
@Test
void shouldStart() { // NOSONAR
assertThat(ozgCloudFileService).isInstanceOf(DummyOzgCloudFileService.class);
}
static class Config {
@Bean
OzgCloudFileService ozgCloudFileService() {
return new DummyOzgCloudFileService();
}
}
}
}
ozg-cloud-spring-boot-starter/src/test/java/de/ozgcloud/client/autoconfigure/OzgCloudUserProfileServiceStarterITCase.java 0 → 100644
+ 107
− 0
View file @ fc66ba97
/*
* 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 java.util.Optional;
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 org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Import;
import org.springframework.test.annotation.DirtiesContext;
import de.ozgcloud.apilib.autoconfig.ApiLibTestApplication;
import de.ozgcloud.apilib.user.GrpcOzgCloudUserProfileService;
import de.ozgcloud.apilib.user.OzgCloudUserId;
import de.ozgcloud.apilib.user.OzgCloudUserProfile;
import de.ozgcloud.apilib.user.OzgCloudUserProfileService;
public class OzgCloudUserProfileServiceStarterITCase {
@Nested
@SpringBootTest(classes = ApiLibTestApplication.class)
@DirtiesContext()
class TestNoOzgCloudUserProfileService {
@Autowired
private Optional<OzgCloudUserProfileService> ozgCloudUserProfileService;
@Test
void shouldStart() {
assertThat(ozgCloudUserProfileService).isEmpty();
}
}
@Nested
@SpringBootTest(classes = ApiLibTestApplication.class, properties = {
"ozgcloud.user-manager.address=address"
})
@DirtiesContext
class TestWithOzgCloudUserProfileService {
@Autowired
private OzgCloudUserProfileService ozgCloudUserProfileService;
@Test
void shouldStart() {
assertThat(ozgCloudUserProfileService).isInstanceOf(GrpcOzgCloudUserProfileService.class);
}
}
@Nested
@SpringBootTest(classes = ApiLibTestApplication.class, properties = {
"ozgcloud.file-manager.address=address"
})
@Import(TestWithExistingOzgCloudFileService.Config.class)
class TestWithExistingOzgCloudFileService {
@Autowired
private OzgCloudUserProfileService ozgCloudUserProfileService;
@Test
void shouldStart() { // NOSONAR
assertThat(ozgCloudUserProfileService).isInstanceOf(DummyOzgCloudUserProfileService.class);
}
record DummyOzgCloudUserProfileService() implements OzgCloudUserProfileService {
@Override
public OzgCloudUserProfile getById(final OzgCloudUserId userId) {
return OzgCloudUserProfile.builder().build();
}
}
static class Config {
@Bean
OzgCloudUserProfileService zgCloudUserProfileService() {
return new DummyOzgCloudUserProfileService();
}
}
}
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment

Impressum - Datenschutz - Barrierefreiheit