Rework the fabric dashboard repository so it uses the fabric API inst…

…ead, otherwise git would need to be available on all containers
hawtio · Sep 18, 2013 · 645018c · 645018c
1 parent d226c0a
commit 645018c
Show file tree

Hide file tree

Showing 2 changed files with 86 additions and 68 deletions.
diff --git a/hawtio-web/src/main/webapp/app/dashboard/js/fabricDashboardRepository.ts b/hawtio-web/src/main/webapp/app/dashboard/js/fabricDashboardRepository.ts
@@ -2,97 +2,89 @@ module Dashboard {
 
 
   export class FabricDashboardRepository implements DashboardRepository {
-    public git = null;
 
-    public branch: string = null;
-    public profilePaths = [];
+    private details;
 
     constructor(public workspace, public jolokia, public localStorage) {
-      this.git = Git.createGitRepository(this.workspace, this.jolokia, this.localStorage);
+      this.details = this.getBranchAndProfiles();
+    }
 
-      var container = Fabric.getCurrentContainer(this.jolokia, ['id', 'versionId', 'profileIds']);
-      this.branch = container.versionId;
-      var profileIds = "default";
-      if (container.profileIds) {
-        profileIds = container.profileIds.unique().sortBy('');
-      }
-      profileIds.each((profileId) => {
-        this.profilePaths.push({
-          profileId: profileId,
-          path: "/fabric/profiles/" + profileId.split("-").join("/") + ".profile"
-        });
-      });
+    public getBranchAndProfiles() {
 
-      // pre-create empty dashboard files
-      this.profilePaths.forEach((path) => {
-        this.git.read(this.branch, path.path, (details) => {
-          var files = details.children;
-          var dashboardExists = false;
-          files.forEach((file) => {
-            var path = file.path;
-            if (!file.directory && path.endsWith("dashboard.json")) {
-              dashboardExists = true;
-            }
-          });
-          if (!dashboardExists) {
-            this.putDashboards([{
-              id: Core.getUUID(),
-              title: path.profileId,
-              group: "Fabric",
-              widgets: []
-            }], "Adding new dashboard for profile " + path.profileId, () => {
-              notification('info', "Created dashboard for " + path.profileId);
-            });
-          }
-        });
-      });
+      var container = Fabric.getCurrentContainer(this.jolokia, ['id', 'versionId', 'profiles']);
+      var profiles = [];
+      if (container.profiles) {
+        profiles = container.profiles.unique();
+        profiles = Fabric.filterProfiles(this.jolokia, container.versionId, profiles);
+      }
 
+      return {
+        branch: container.versionId,
+        profiles: profiles
+      }
     }
 
     public putDashboards(array:Dashboard[], commitMessage:string, fn) {
-      angular.forEach(array, (dash) => {
-        var path = this.getDashboardPath(dash);
-        var contents = angular.toJson(dash);
-        this.git.write(this.branch, path, commitMessage, contents, fn);
+      var jolokia = this.jolokia;
+      var details = this.details;
+      array.forEach((dashboard) => {
+        var data = angular.toJson(dashboard, true);
+        var profileId = dashboard.profileId;
+        if (!profileId) {
+          // TODO maybe not just pick the first one :-)
+          profileId = details.profiles.first();
+        }
+        var fileName = dashboard.fileName;
+        if (!fileName) {
+          fileName = Core.getUUID() + ".dashboard";
+        }
+        Fabric.saveConfigFile(jolokia, details.branch, profileId, fileName, data.encodeBase64(), () => {
+          //notification('success', "Saved dashboard " + dashboard.title);
+        }, (response) => {
+          notification('error', "Failed to save dashboard " + dashboard.title + " due to " + response.error);
+        });
       });
     }
 
     public deleteDashboards(array:Dashboard[], fn) {
-
-      angular.forEach(array, (dash) => {
-        var path = this.getDashboardPath(dash);
-        var commitMessage = "Removing dashboard " + path;
-        this.git.remove(this.branch, path, commitMessage, fn);
+      var jolokia = this.jolokia;
+      var details = this.details;
+      array.forEach((dashboard) => {
+        var profileId = dashboard.profileId;
+        var fileName = dashboard.fileName;
+        if (profileId && fileName) {
+          Fabric.deleteConfigFile(jolokia, details.branch, profileId, fileName, () => {
+            notification('success', "Deleted dashboard " + dashboard.title);
+          }, (response) => {
+            notification('error', "Failed to delete dashboard " + dashboard.title + " due to " + response.error);
+          })
+        }
       });
     }
 
-    public getDashboardPath(dash) {
-      var path = this.profilePaths.find((path) => { return path.profileId === dash.title });
-      path = path.path + "/dashboard.json";
-      return path;
-    }
-
     public getDashboards(fn) {
 
-      var index = this.profilePaths.length;
+      var jolokia = this.jolokia;
+      var details = this.details;
       var dashboards = [];
 
-      this.profilePaths.forEach((path) => {
-
-        var dashboard = path.path + '/dashboard.json';
-        this.git.read(this.branch, dashboard, (details) => {
-          index = index - 1;
-          var content = details.text;
-          if (content) {
-            var json = angular.fromJson(content);
-            json.uri = dashboard;
-            dashboards.push(json);
-          }
-          if (index === 0) {
-            fn(dashboards.sortBy((dash) => { return dash.title; }));
+      details.profiles.forEach((profile) => {
+        var data = Fabric.getProfileData(jolokia, details.branch, profile, ['configurations']);
+        data.configurations.forEach((configuration) => {
+          if (configuration.endsWith(".dashboard")) {
+            var file = Fabric.getConfigFile(jolokia, details.branch, profile, configuration);
+            if (file) {
+              var dashboard = angular.fromJson(file);
+              dashboard['versionId'] = details.branch;
+              dashboard['profileId'] = profile;
+              dashboard['fileName'] = configuration;
+              dashboards.push(dashboard);
+            }
           }
         });
       });
+
+      fn(dashboards);
     }
 
     public getDashboard(id:string, fn) {

diff --git a/hawtio-web/src/main/webapp/app/fabric/js/helpers.ts b/hawtio-web/src/main/webapp/app/fabric/js/helpers.ts
@@ -446,5 +446,31 @@ module Fabric {
   }
 
 
+  export function filterProfiles(jolokia, versionId, profileIds) {
+    var profiles = jolokia.execute(Fabric.managerMBean, "getProfiles(java.lang.String, java.util.List)", versionId, ['id', 'hidden', 'abstract'], { method: 'POST' });
+
+    profiles = profiles.filter((profile) => {
+      return profileIds.some((id) => { return profile.id === id });
+    });
+    profiles = profiles.filter((profile => {
+      return !profile.abstract && !profile.hidden;
+    }));
+
+    return profiles.map((p) => { return p.id; });
+  }
+
+  export function getProfileData(jolokia, versionId, profileId, fields) {
+    return jolokia.execute(Fabric.managerMBean, "getProfile(java.lang.String, java.lang.String, java.util.List)", versionId, profileId, fields, { method: 'POST' });
+  }
+
+  export function getConfigFile(jolokia, versionId, profileId, fileName) {
+    var answer = jolokia.execute(Fabric.managerMBean, "getConfigurationFile(java.lang.String, java.lang.String, java.lang.String)", versionId, profileId, fileName)
+    if (answer) {
+      return answer.decodeBase64();
+    }
+    return null;
+  }
+
+
 
 }