[incubator-streampipes] branch rel/0.68.0 updated: [hotfix] Extract visualizable pipelines independent from current user

[riemer]

This is an automated email from the ASF dual-hosted git repository.

riemer pushed a commit to branch rel/0.68.0
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git


The following commit(s) were added to refs/heads/rel/0.68.0 by this push:
     new fe4ab81  [hotfix] Extract visualizable pipelines independent from 
current user
fe4ab81 is described below

commit fe4ab81a4674cb6deeb66ac6f7be9612866677ed
Author: Dominik Riemer <rie...@fzi.de>
AuthorDate: Mon Jun 28 21:20:13 2021 +0200

    [hotfix] Extract visualizable pipelines independent from current user
---
 .../rest/impl/dashboard/VisualizablePipeline.java        | 16 +++++++---------
 1 file changed, 7 insertions(+), 9 deletions(-)

diff --git 
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/VisualizablePipeline.java
 
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/VisualizablePipeline.java
index 648d454..7e52397 100644
--- 
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/VisualizablePipeline.java
+++ 
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/VisualizablePipeline.java
@@ -40,24 +40,22 @@ public class VisualizablePipeline extends 
AbstractRestResource {
 
   private static final String DashboardAppId = 
"org.apache.streampipes.sinks.internal.jvm.dashboard";
   private static final String VisualizationFieldInternalName = 
"visualization-name";
-  private static final String Slash = "/";
 
   @GET
   @JacksonSerialized
   @Produces(MediaType.APPLICATION_JSON)
-  public Response getVisualizablePipelines(@PathParam("username") String 
email) {
-    return ok(extractVisualizablePipelines(email));
+  public Response getVisualizablePipelines() {
+    return ok(extractVisualizablePipelines());
   }
 
   @GET
   @JacksonSerialized
   @Produces(MediaType.APPLICATION_JSON)
   @Path("{pipelineId}/{visualizationName}")
-  public Response 
getVisualizablePipelineByPipelineIdAndVisualizationName(@PathParam("username") 
String email,
-                                                                          
@PathParam("pipelineId") String pipelineId,
+  public Response 
getVisualizablePipelineByPipelineIdAndVisualizationName(@PathParam("pipelineId")
 String pipelineId,
                                                                           
@PathParam("visualizationName") String visualizationName) {
     List<org.apache.streampipes.model.dashboard.VisualizablePipeline> 
pipelines =
-            extractVisualizablePipelines(email);
+            extractVisualizablePipelines();
 
     Optional<org.apache.streampipes.model.dashboard.VisualizablePipeline> 
matchedPipeline =
             pipelines
@@ -68,10 +66,10 @@ public class VisualizablePipeline extends 
AbstractRestResource {
     return matchedPipeline.isPresent() ? ok(matchedPipeline.get()) : fail();
   }
 
-  private List<org.apache.streampipes.model.dashboard.VisualizablePipeline> 
extractVisualizablePipelines(String email) {
+  private List<org.apache.streampipes.model.dashboard.VisualizablePipeline> 
extractVisualizablePipelines() {
     List<org.apache.streampipes.model.dashboard.VisualizablePipeline> 
visualizablePipelines = new ArrayList<>();
-     getUserService()
-            .getOwnPipelines(email)
+     getPipelineStorage()
+            .getAllPipelines()
             .forEach(pipeline -> {
               List<DataSinkInvocation> dashboardSinks = 
extractDashboardSinks(pipeline);
               dashboardSinks.forEach(sink -> {