[incubator-streampipes] branch dev updated: [hotfix] Add live dashboards to reset management

[zehnder]

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

zehnder 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 c96836f  [hotfix] Add live dashboards to reset management
c96836f is described below

commit c96836f978680cd7806d299915e8202483189c47
Author: Philipp Zehnder <zehn...@fzi.de>
AuthorDate: Wed Dec 29 17:11:29 2021 +0100

    [hotfix] Add live dashboards to reset management
---
 .../java/org/apache/streampipes/rest/ResetManagement.java   | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git 
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/ResetManagement.java
 
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/ResetManagement.java
index b1b71cb..faa8bf4 100644
--- 
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/ResetManagement.java
+++ 
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/ResetManagement.java
@@ -31,6 +31,7 @@ import 
org.apache.streampipes.model.connect.adapter.AdapterDescription;
 import org.apache.streampipes.model.datalake.DataLakeMeasure;
 import org.apache.streampipes.model.pipeline.Pipeline;
 import org.apache.streampipes.storage.api.IDashboardStorage;
+import org.apache.streampipes.storage.api.IDashboardWidgetStorage;
 import org.apache.streampipes.storage.api.IDataExplorerWidgetStorage;
 import org.apache.streampipes.storage.management.StorageDispatcher;
 import org.slf4j.Logger;
@@ -112,6 +113,18 @@ public class ResetManagement {
             dataLakeDashboardStorage.deleteDashboard(dashboard.getCouchDbId());
         });
 
+        // Remove all dashboard widgets
+        IDashboardWidgetStorage dashobardWidgetStorage = 
StorageDispatcher.INSTANCE.getNoSqlStore().getDashboardWidgetStorage();
+        dashobardWidgetStorage.getAllDashboardWidgets().forEach(widget -> {
+            dashobardWidgetStorage.deleteDashboardWidget(widget.getId());
+        });
+
+        // Remove all dashboards
+        IDashboardStorage dashboardStorage = 
StorageDispatcher.INSTANCE.getNoSqlStore().getDashboardStorage();
+        dashboardStorage.getAllDashboards().forEach(dashboard  -> {
+            dashboardStorage.deleteDashboard(dashboard.getCouchDbId());
+        });
+
         logger.info("Resetting the system was completed");
     }
 }