You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2021/06/28 19:20:41 UTC
[incubator-streampipes] branch rel/0.68.0 updated: [hotfix] Extract
visualizable pipelines independent from current user
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 <ri...@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 -> {