Ozg 7608 vorgangshoellen for statistik

api-lib-core/src/main/java/de/ozgcloud/apilib/vorgang/grpc/GrpcOzgCloudVorgangService.java

@@ -23,7 +23,10 @@
  */
 package de.ozgcloud.apilib.vorgang.grpc;
 
+import static de.ozgcloud.apilib.vorgang.grpc.StreamingUtils.*;
+
 import java.util.List;
+import java.util.stream.Stream;
 
 import de.ozgcloud.apilib.common.callcontext.OzgCloudCallContextAttachingInterceptor;
 import de.ozgcloud.apilib.common.callcontext.OzgCloudCallContextProvider;
@@ -34,6 +37,8 @@ import de.ozgcloud.apilib.vorgang.OzgCloudVorgangService;
 import de.ozgcloud.apilib.vorgang.OzgCloudVorgangStub;
 import de.ozgcloud.apilib.vorgang.Page;
 import de.ozgcloud.vorgang.vorgang.GrpcFilterBy;
+import de.ozgcloud.vorgang.vorgang.GrpcFindDeletedVorgangRequest;
+import de.ozgcloud.vorgang.vorgang.GrpcFindDeletedVorgangResponse;
 import de.ozgcloud.vorgang.vorgang.GrpcFindVorgangRequest;
 import de.ozgcloud.vorgang.vorgang.GrpcFindVorgangRequest.GrpcOrderBy;
 import de.ozgcloud.vorgang.vorgang.GrpcFindVorgangWithEingangRequest;
@@ -63,8 +68,8 @@ public class GrpcOzgCloudVorgangService implements OzgCloudVorgangService {
 
 	private GrpcFindVorgangWithEingangRequest buildRequest(@NonNull OzgCloudVorgangId vorgangId) {
 		return GrpcFindVorgangWithEingangRequest.newBuilder()
-				.setId(vorgangId.toString())
-				.build();
+			.setId(vorgangId.toString())
+			.build();
 	}
 
 	@Override
@@ -81,12 +86,12 @@ public class GrpcOzgCloudVorgangService implements OzgCloudVorgangService {
 
 	GrpcFindVorgangRequest buildSearchRequest(@NonNull String searchString, Page page) {
 		return GrpcFindVorgangRequest.newBuilder()
-				.setFilterBy(GrpcFilterBy.newBuilder().build())
-				.setSearchBy(searchString)
-				.setOffset(page.getOffset())
-				.setLimit(page.getLimit())
-				.setOrderBy(GrpcOrderBy.CREATED_AT_DESC)
-				.build();
+			.setFilterBy(GrpcFilterBy.newBuilder().build())
+			.setSearchBy(searchString)
+			.setOffset(page.getOffset())
+			.setLimit(page.getLimit())
+			.setOrderBy(GrpcOrderBy.CREATED_AT_DESC)
+			.build();
 	}
 
 	@Override
@@ -98,11 +103,22 @@ public class GrpcOzgCloudVorgangService implements OzgCloudVorgangService {
 
 	GrpcFindVorgangRequest buildFindRequest(OzgCloudVorgangQuery query, Page page) {
 		return GrpcFindVorgangRequest.newBuilder()
-				.setLimit(page.getLimit())
-				.setOffset(page.getOffset())
-				.setQuery(queryMapper.toGrpc(query))
-				.setOrderBy(GrpcOrderBy.CREATED_AT_DESC)
-				.build();
+			.setLimit(page.getLimit())
+			.setOffset(page.getOffset())
+			.setQuery(queryMapper.toGrpc(query))
+			.setOrderBy(GrpcOrderBy.CREATED_AT_DESC)
+			.build();
+	}
+
+	@Override
+	public Stream<OzgCloudVorgangStub> findDeleted() {
+		return getFindDeletedVorgangResponses()
+			.flatMap(response -> response.getVorgangList().stream())
+			.map(stubMapper::fromGrpc);
+	}
+
+	private Stream<GrpcFindDeletedVorgangResponse> getFindDeletedVorgangResponses() {
+		return asStream(getVorgangServiceStub().findDeletedVorgang(GrpcFindDeletedVorgangRequest.newBuilder().build()));
 	}
 
 	VorgangServiceBlockingStub getVorgangServiceStub() {