perf update for get all api and temp count api

Author: dwasinge

src/main/java/com/redhat/labs/omp/resource/EngagementResource.java

@@ -1,6 +1,10 @@
 package com.redhat.labs.omp.resource;
 
+import java.time.Duration;
+import java.time.Instant;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
 import javax.inject.Inject;
 import javax.validation.constraints.NotBlank;
@@ -123,4 +127,22 @@ public Response getStatus(@PathParam("customer") String customer, @PathParam("en
         return Response.ok().entity(status).build();
     }
 
+    @GET
+    @Path("/count")
+    public Response getEngagementCount() {
+
+        Instant start = Instant.now();
+
+        Integer count = engagementService.countAllEngagements();
+
+        Instant end = Instant.now();
+        long elapsed = Duration.between(start, end).getSeconds();
+
+        Map<String, String> map = new HashMap<>();
+        map.put("count", count.toString());
+        map.put("elapsed_time", String.valueOf(elapsed));
+        return Response.ok(map).build();
+
+    }
+
 }

src/main/java/com/redhat/labs/omp/service/EngagementService.java

@@ -4,6 +4,7 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Optional;
+import java.util.stream.Collectors;
 
 import javax.annotation.PostConstruct;
 import javax.enterprise.context.ApplicationScoped;
@@ -178,19 +179,26 @@ public List<Engagement> getAllEngagements() {
 
         List<Project> projects = projectService.getProjectsByGroup(engagementRepositoryId, true);
 
-        List<Engagement> engagementList = new ArrayList<>();
+        return
+            projects
+                .parallelStream()
+                .map(project -> {
+                    return getEngagement(project, true);
+                })
+                .filter(optional -> optional.isPresent())
+                .map(optional -> {
+                    return optional.get();
+                })
+                .collect(Collectors.toList());
 
-        for (Project project : projects) {
-            LOGGER.debug("project id {}", project.getId());
-            Optional<Engagement> engagement = getEngagement(project, true);
-            if(engagement.isPresent() ) {
-                engagementList.add(engagement.get());
-            }
-        }
+    }
+
+    public Integer countAllEngagements() {
+
+        return getAllEngagements().size();
 
-        return engagementList;
     }
-    
+
     public Engagement getEngagement(String namespaceOrId, boolean includeStatus) {
         Engagement engagement = null;
 
@@ -215,7 +223,7 @@ public Engagement getEngagement(String customerName, String engagementName, bool
         return engagement;
     }
 
-    private Optional<Engagement> getEngagement(Project project, boolean includeStatus) {
+    public Optional<Engagement> getEngagement(Project project, boolean includeStatus) {
         Engagement engagement = null;
 
         Optional<File> engagementFile = fileService.getFileAllow404(project.getId(), ENGAGEMENT_FILE);