[incubator-streampipes] branch dev updated: [STREAMPIPES-371] Fix wrong selection of pipelineId in start pipeline dialog

[riemer]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new 0310faf  [STREAMPIPES-371] Fix wrong selection of pipelineId in start 
pipeline dialog
0310faf is described below

commit 0310fafa34d7a594ae420fb67a46d56290baeebb
Author: Dominik Riemer <rie...@fzi.de>
AuthorDate: Sat May 22 18:56:09 2021 +0200

    [STREAMPIPES-371] Fix wrong selection of pipelineId in start pipeline dialog
---
 .../main/java/org/apache/streampipes/rest/impl/PipelineResource.java  | 4 +++-
 ui/src/app/editor/dialog/save-pipeline/save-pipeline.component.ts     | 4 ++--
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineResource.java
 
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineResource.java
index 1850c09..cb03a26 100644
--- 
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineResource.java
+++ 
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineResource.java
@@ -264,7 +264,9 @@ public class PipelineResource extends 
AbstractAuthGuardedRestResource {
       storedPipeline.setCreatedAt(System.currentTimeMillis());
       storedPipeline.setPipelineCategories(pipeline.getPipelineCategories());
       Operations.updatePipeline(storedPipeline);
-      return statusMessage(Notifications.success("Pipeline modified"));
+      SuccessMessage message = Notifications.success("Pipeline modified");
+      message.addNotification(new Notification("id", pipelineId));
+      return ok(message);
     } else {
       return statusMessage(Notifications.error("The pipeline must be stopped 
before it can be updated."));
     }
diff --git a/ui/src/app/editor/dialog/save-pipeline/save-pipeline.component.ts 
b/ui/src/app/editor/dialog/save-pipeline/save-pipeline.component.ts
index 296c16c..b9cef48 100644
--- a/ui/src/app/editor/dialog/save-pipeline/save-pipeline.component.ts
+++ b/ui/src/app/editor/dialog/save-pipeline/save-pipeline.component.ts
@@ -122,7 +122,7 @@ export class SavePipelineComponent implements OnInit {
     storageRequest
         .subscribe(statusMessage => {
           if (statusMessage.success) {
-            let pipelineId: string = this.currentModifiedPipelineId || 
statusMessage.notifications[1].description;
+            let pipelineId: string = 
statusMessage.notifications[1].description;
             this.afterStorage(statusMessage, switchTab, pipelineId);
           } else {
             this.displayErrors(statusMessage.notifications[0]);
@@ -150,4 +150,4 @@ export class SavePipelineComponent implements OnInit {
   hide() {
     this.dialogRef.close();
   };
-}
\ No newline at end of file
+}