You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2021/12/29 16:16:38 UTC
[incubator-streampipes] branch dev updated: [hotfix] Add live dashboards to reset management
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 <ze...@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");
}
}