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

OZG-3530 fix test, reactivate processor config

parent caf0aa39
No related branches found
No related tags found
No related merge requests found
package de.ozgcloud.vorgang;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import de.ozgcloud.apilib.common.callcontext.OzgCloudCallContextProvider;
import de.ozgcloud.apilib.vorgang.OzgCloudVorgangService;
import de.ozgcloud.apilib.vorgang.grpc.GrpcOzgCloudVorgangService;
import de.ozgcloud.apilib.vorgang.grpc.OzgCloudVorgangMapper;
import de.ozgcloud.apilib.vorgang.grpc.OzgCloudVorgangStubMapper;
import de.ozgcloud.vorgang.vorgang.VorgangServiceGrpc.VorgangServiceBlockingStub;
import net.devh.boot.grpc.client.inject.GrpcClient;
//@Configuration
@Configuration
class VorgangProcessorConfiguration {
@GrpcClient("vorgang-manager")
private VorgangServiceBlockingStub vorgangServiceStub;
// @Bean
// OzgCloudVorgangService ozgCloudVorgangService(OzgCloudVorgangMapper mapper, OzgCloudVorgangStubMapper stubMapper,
// OzgCloudCallContextProvider contextProvider) {
// return new GrpcOzgCloudVorgangService(vorgangServiceStub, mapper, stubMapper, contextProvider);
// return null;
// }
@Bean
OzgCloudVorgangService ozgCloudVorgangService(OzgCloudVorgangMapper mapper, OzgCloudVorgangStubMapper stubMapper,
OzgCloudCallContextProvider contextProvider) {
return new GrpcOzgCloudVorgangService(vorgangServiceStub, mapper, stubMapper, contextProvider);
}
}
......@@ -4,7 +4,6 @@ import static org.mockito.ArgumentMatchers.*;
import static org.mockito.Mockito.*;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Nested;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
......@@ -14,9 +13,12 @@ import org.springframework.boot.test.mock.mockito.SpyBean;
import org.springframework.context.ApplicationEventPublisher;
import de.itvsh.kop.common.test.ITCase;
import de.ozgcloud.apilib.vorgang.OzgCloudVorgangService;
import de.ozgcloud.command.VorgangCreatedEvent;
import de.ozgcloud.notification.antragsteller.AntragstellerNotificationEventListener;
import de.ozgcloud.notification.user.UserNotificationEventListener;
import de.ozgcloud.processor.processor.ProcessorService;
import de.ozgcloud.processor.vorgang.ProcessorVorgangMapper;
import de.ozgcloud.vorgang.command.CommandCreatedEventTestFactory;
import de.ozgcloud.vorgang.command.CommandTestFactory;
import de.ozgcloud.vorgang.files.FileService;
......@@ -45,11 +47,12 @@ class VorgangEventListenerITCase {
@MockBean
private FileService fileService;
// @MockBean
// private ProcessorService vorgagnProcessorService;
// private OzgCloudVorgangService ozgCloudVorgangService;
// @MockBean
// private ProcessorVorgangMapper processorVorgangMapper;
@MockBean
private ProcessorService vorgagnProcessorService;
@MockBean
private OzgCloudVorgangService ozgCloudVorgangService;
@MockBean
private ProcessorVorgangMapper processorVorgangMapper;
@Nested
class TestOnVorgangLoeschen {
......@@ -69,7 +72,6 @@ class VorgangEventListenerITCase {
}
@Nested
@Disabled("TODO: activate when processor manager is available")
class TestOnVorgangCreated {
@BeforeEach
......@@ -83,7 +85,7 @@ class VorgangEventListenerITCase {
void shouldCallProcessorService() {
publisher.publishEvent(new VorgangCreatedEvent("id"));
// verify(vorgagnProcessorService, timeout(500)).processVorgang(any());
verify(vorgagnProcessorService, timeout(500)).processVorgang(any());
}
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment