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

OZG-7608 OZG-7729 Create own return type for FindDeletedVorgang

parent 8d8f860c
Branches
Tags
1 merge request!17OZG-7608 OZG-7729 gRPC endpoint for deleted Vorgaenge
......@@ -48,7 +48,7 @@ service VorgangService {
rpc CreateCollaborationVorgang(GrpcCreateCollaborationVorgangRequest) returns (GrpcCreateCollaborationVorgangResponse) {
}
rpc FindDeletedVorgang(GrpcFindDeletedVorgangRequest) returns (stream GrpcFindVorgangResponse) {
rpc FindDeletedVorgang(GrpcFindDeletedVorgangRequest) returns (stream GrpcFindDeletedVorgangResponse) {
}
}
......@@ -113,4 +113,8 @@ message GrpcFinishCreationResponse {
}
message GrpcFindDeletedVorgangRequest {
}
message GrpcFindDeletedVorgangResponse {
repeated GrpcVorgangHeader vorgang = 1;
}
\ No newline at end of file
......@@ -25,9 +25,9 @@ package de.ozgcloud.vorgang.vorgang;
import de.ozgcloud.vorgang.common.grpc.GrpcResponseBuilder;
class GrpcFindVorgangResponseBuilder implements GrpcResponseBuilder<GrpcVorgangHeader, GrpcFindVorgangResponse> {
class GrpcFindDeletedVorgangResponseBuilder implements GrpcResponseBuilder<GrpcVorgangHeader, GrpcFindDeletedVorgangResponse> {
private final GrpcFindVorgangResponse.Builder delegate = GrpcFindVorgangResponse.newBuilder();
private final GrpcFindDeletedVorgangResponse.Builder delegate = GrpcFindDeletedVorgangResponse.newBuilder();
@Override
public int getElementCount() {
......@@ -40,7 +40,7 @@ class GrpcFindVorgangResponseBuilder implements GrpcResponseBuilder<GrpcVorgangH
}
@Override
public GrpcFindVorgangResponse build() {
public GrpcFindDeletedVorgangResponse build() {
return delegate.build();
}
}
......@@ -142,8 +142,8 @@ class VorgangGrpcService extends VorgangServiceGrpc.VorgangServiceImplBase {
}
@Override
public void findDeletedVorgang(GrpcFindDeletedVorgangRequest request, StreamObserver<GrpcFindVorgangResponse> responseObserver) {
var responseStreamer = GrpcResponseBatchStreamer.create(GrpcFindVorgangResponseBuilder::new, responseObserver);
public void findDeletedVorgang(GrpcFindDeletedVorgangRequest request, StreamObserver<GrpcFindDeletedVorgangResponse> responseObserver) {
var responseStreamer = GrpcResponseBatchStreamer.create(GrpcFindDeletedVorgangResponseBuilder::new, responseObserver);
vorgangService.findDeleted().map(vorgangStubMapper::toGrpcVorgangHeader).forEach(responseStreamer::send);
responseStreamer.finish();
}
......
......@@ -246,9 +246,9 @@ class VorgangGrpcServiceITCase {
private static final int DELETED_VORGANG_COUNT = DEFAULT_BATCH_SIZE + INCOMPLETE_BATCH_SIZE;
@Mock
private StreamObserver<GrpcFindVorgangResponse> streamObserver;
private StreamObserver<GrpcFindDeletedVorgangResponse> streamObserver;
@Captor
private ArgumentCaptor<GrpcFindVorgangResponse> findVorgangResponseCaptor;
private ArgumentCaptor<GrpcFindDeletedVorgangResponse> findVorgangResponseCaptor;
@BeforeEach
void init() {
......
......@@ -526,7 +526,7 @@ class VorgangGrpcServiceTest {
@Mock
private GrpcResponseBatchStreamer<GrpcVorgangHeader, GrpcFindVorgangResponse> batchStreamer;
@Mock
private StreamObserver<GrpcFindVorgangResponse> responseObserver;
private StreamObserver<GrpcFindDeletedVorgangResponse> responseObserver;
private final VorgangStub vorgangStub = VorgangStubTestFactory.create();
private final GrpcVorgangHeader grpcVorgangHeader = GrpcVorgangHeaderTestFactory.create();
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment