diff --git a/nachrichten-manager-interface/src/main/protobuf/antragraum.model.proto b/nachrichten-manager-interface/src/main/protobuf/antragraum.model.proto index 062c92b7c6e0d9cdc7c2f40902737f61bed20094..282543d0303eaf7f5eae47245f936f1d1d75fb46 100644 --- a/nachrichten-manager-interface/src/main/protobuf/antragraum.model.proto +++ b/nachrichten-manager-interface/src/main/protobuf/antragraum.model.proto @@ -61,4 +61,8 @@ message GrpcRueckfrageAnswer { string rueckfrageId = 1; string answerText = 2; repeated string attachmentFileId = 3; +} + +message GrpcSendRueckfrageAnswerResponse { + string commandId = 1; } \ No newline at end of file diff --git a/nachrichten-manager-interface/src/main/protobuf/antragraum.proto b/nachrichten-manager-interface/src/main/protobuf/antragraum.proto index 0fa6d67dffed44a28d58a531d8ff1ad03bf128ea..5560957878b13267d76a19e2c91ef992bdcca207 100644 --- a/nachrichten-manager-interface/src/main/protobuf/antragraum.proto +++ b/nachrichten-manager-interface/src/main/protobuf/antragraum.proto @@ -36,6 +36,6 @@ service AntragraumService { rpc FindRueckfragen(GrpcFindRueckfragenRequest) returns (GrpcFindRueckfragenResponse) { } - rpc SendRueckfrageAnswer(GrpcSendRueckfrageAnswerRequest) returns (de.ozgcloud.vorgang.grpc.command.GrpcCommand) { + rpc SendRueckfrageAnswer(GrpcSendRueckfrageAnswerRequest) returns (GrpcSendRueckfrageAnswerResponse) { } } \ No newline at end of file diff --git a/nachrichten-manager-server/src/main/java/de/ozgcloud/nachrichten/antragraum/AntragraumGrpcService.java b/nachrichten-manager-server/src/main/java/de/ozgcloud/nachrichten/antragraum/AntragraumGrpcService.java index 4921595ed99fe131abde54ebfccb4f42ad2a8d3e..45f6901b9a2f7089c36d3943e013962b0a834f2f 100644 --- a/nachrichten-manager-server/src/main/java/de/ozgcloud/nachrichten/antragraum/AntragraumGrpcService.java +++ b/nachrichten-manager-server/src/main/java/de/ozgcloud/nachrichten/antragraum/AntragraumGrpcService.java @@ -1,8 +1,7 @@ /* - * 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 + * 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 - @@ -24,13 +23,10 @@ package de.ozgcloud.nachrichten.antragraum; -import org.apache.commons.lang3.NotImplementedException; -import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; - -import de.ozgcloud.vorgang.grpc.command.GrpcCommand; import io.grpc.stub.StreamObserver; import lombok.RequiredArgsConstructor; import net.devh.boot.grpc.server.service.GrpcService; +import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; @GrpcService @RequiredArgsConstructor @@ -49,12 +45,12 @@ class AntragraumGrpcService extends AntragraumServiceGrpc.AntragraumServiceImplB } @Override - public void sendRueckfrageAnswer(GrpcSendRueckfrageAnswerRequest request, StreamObserver<GrpcCommand> streamObserver) { + public void sendRueckfrageAnswer(GrpcSendRueckfrageAnswerRequest request, StreamObserver<GrpcSendRueckfrageAnswerResponse> streamObserver) { var answer = request.getAnswer(); var commandId = antragraumService.sendRueckfrageAnswer(request.getSamlToken(), answer.getRueckfrageId(), mapper.toPostfachNachricht(answer)); - streamObserver.onNext(GrpcCommand.newBuilder().setId(commandId).build()); + streamObserver.onNext(GrpcSendRueckfrageAnswerResponse.newBuilder().setCommandId(commandId).build()); streamObserver.onCompleted(); } } diff --git a/nachrichten-manager-server/src/test/java/de/ozgcloud/nachrichten/antragraum/AntragraumGrpcServiceTest.java b/nachrichten-manager-server/src/test/java/de/ozgcloud/nachrichten/antragraum/AntragraumGrpcServiceTest.java index 968c13b46cacfbf6528a6f3ac6d750e0154c08f5..e5ab9a259721945777073af44b7a539ad2d2a2e3 100644 --- a/nachrichten-manager-server/src/test/java/de/ozgcloud/nachrichten/antragraum/AntragraumGrpcServiceTest.java +++ b/nachrichten-manager-server/src/test/java/de/ozgcloud/nachrichten/antragraum/AntragraumGrpcServiceTest.java @@ -20,12 +20,9 @@ package de.ozgcloud.nachrichten.antragraum; -import static org.mockito.ArgumentMatchers.*; -import static org.mockito.Mockito.*; - -import java.util.UUID; -import java.util.stream.Stream; - +import de.ozgcloud.nachrichten.postfach.PostfachNachricht; +import de.ozgcloud.nachrichten.postfach.PostfachNachrichtTestFactory; +import io.grpc.stub.StreamObserver; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Nested; import org.junit.jupiter.api.Test; @@ -33,10 +30,11 @@ import org.mockito.InjectMocks; import org.mockito.Mock; import org.mockito.Spy; -import de.ozgcloud.nachrichten.postfach.PostfachNachricht; -import de.ozgcloud.nachrichten.postfach.PostfachNachrichtTestFactory; -import de.ozgcloud.vorgang.grpc.command.GrpcCommand; -import io.grpc.stub.StreamObserver; +import java.util.UUID; +import java.util.stream.Stream; + +import static org.mockito.ArgumentMatchers.*; +import static org.mockito.Mockito.*; class AntragraumGrpcServiceTest { @Spy @@ -87,7 +85,7 @@ class AntragraumGrpcServiceTest { @Nested class TestSendAnswer { @Mock - private StreamObserver<GrpcCommand> streamObserver; + private StreamObserver<GrpcSendRueckfrageAnswerResponse> streamObserver; @BeforeEach void setup() { @@ -114,7 +112,7 @@ class AntragraumGrpcServiceTest { void shouldCallOnNext() { antragsraumGrpcService.sendRueckfrageAnswer(GrpcSendRueckfrageAnswerRequestTestFactory.create(), streamObserver); - verify(streamObserver).onNext(any(GrpcCommand.class)); + verify(streamObserver).onNext(any(GrpcSendRueckfrageAnswerResponse.class)); } @Test