Cluster refactor + Pods + Cluster status

.eslintrc

@@ -28,7 +28,8 @@
     "__DEV__": true,
     "alt": true,
     "Immutable": true,
-    "_": true
+    "_": true,
+    "Constants": true,
   },
   "ecmaFeatures": {
     "arrowFunctions": true,

package.json

@@ -47,14 +47,16 @@
     "alt-container": "1.0.2",
     "alt-utils": "1.0.0",
     "babel-plugin-module-alias": "1.5.0",
+    "base-64": "^0.1.0",
     "immutable": "3.8.1",
     "intl": "1.2.4",
     "intl-messageformat": "1.3.0",
     "intl-relativeformat": "1.3.0",
     "lodash": "4.13.1",
     "qs": "6.2.0",
     "react": "15.2.0",
-    "react-native": "0.28"
+    "react-native": "0.28",
+    "utf8": "^2.1.1"
   },
   "devDependencies": {
     "babel-eslint": "6.1.0",

src/Stores.js

@@ -13,8 +13,8 @@
   See the License for the specific language governing permissions and
   limitations under the License.
 */
-import 'stores/EndpointsStore';
-import 'stores/NodesStore';
+import 'stores/ClustersStore';
+import 'stores/PodsStore';
 import 'stores/ServicesStore';
 import 'stores/ReplicationsStore';
 export default {};

src/actions/ClustersActions.js

@@ -0,0 +1,54 @@
+/*
+  Copyright 2015 Skippbox, Ltd
+
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License.
+*/
+import alt from 'src/alt';
+import ClustersApi from 'api/ClustersApi';
+import PodsActions from 'actions/PodsActions';
+import ServicesActions from 'actions/ServicesActions';
+import ReplicationsActions from 'actions/ReplicationsActions';
+
+class ClustersActions {
+
+  constructor() {
+    this.generateActions(
+      'checkClusterStart',
+      'checkClusterSuccess',
+      'addCluster',
+      'editCluster',
+      'removeCluster',
+    );
+  }
+
+  checkClusters() {
+    return Promise.all(alt.stores.ClustersStore.getClusters().map(cluster => {
+      return this.checkCluster(cluster);
+    }));
+  }
+
+  checkCluster(cluster) {
+    this.checkClusterStart(cluster);
+    return ClustersApi.checkCluster(cluster).then(up => {
+      this.checkClusterSuccess({cluster, up});
+    });
+  }
+
+  fetchClusterEntities(cluster) {
+    PodsActions.fetchPods.defer(cluster);
+    ServicesActions.fetchServices.defer(cluster);
+    ReplicationsActions.fetchReplications.defer(cluster);
+  }
+}
+
+export default alt.createActions(ClustersActions);

src/actions/NodesActions.js → src/actions/PodsActions.js

@@ -14,27 +14,27 @@
   limitations under the License.
 */
 import alt from 'src/alt';
-import NodesApi from 'api/NodesApi';
+import ClustersApi from 'api/ClustersApi';
 
-class NodesActions {
+class PodsActions {
 
   constructor() {
     this.generateActions(
-      'fetchNodesStart',
-      'fetchNodesSuccess',
-      'fetchNodesFailure',
+      'fetchPodsStart',
+      'fetchPodsSuccess',
+      'fetchPodsFailure',
     );
   }
 
-  fetchNodes(endpoint) {
-    this.fetchNodesStart(endpoint);
-    return NodesApi.fetchNodes(endpoint).then(nodes => {
-      this.fetchNodesSuccess({endpoint, nodes});
+  fetchPods(cluster) {
+    this.fetchPodsStart(cluster);
+    return ClustersApi.fetchPods(cluster).then(pods => {
+      this.fetchPodsSuccess({cluster, pods});
     })
     .catch(() => {
-      this.fetchNodesFailure(endpoint);
+      this.fetchPodsFailure(cluster);
     });
   }
 }
 
-export default alt.createActions(NodesActions);
+export default alt.createActions(PodsActions);

src/actions/ReplicationsActions.js

@@ -14,7 +14,7 @@
   limitations under the License.
 */
 import alt from 'src/alt';
-import ReplicationsApi from 'api/ReplicationsApi';
+import ClustersApi from 'api/ClustersApi';
 
 class ReplicationsActions {
 
@@ -26,13 +26,13 @@ class ReplicationsActions {
     );
   }
 
-  fetchReplications(endpoint) {
-    this.fetchReplicationsStart(endpoint);
-    return ReplicationsApi.fetchReplications(endpoint).then(replications => {
-      this.fetchReplicationsSuccess({endpoint, replications});
+  fetchReplications(cluster) {
+    this.fetchReplicationsStart(cluster);
+    return ClustersApi.fetchReplications(cluster).then(replications => {
+      this.fetchReplicationsSuccess({cluster, replications});
     })
     .catch(() => {
-      this.fetchReplicationsFailure(endpoint);
+      this.fetchReplicationsFailure(cluster);
     });
   }
 }

src/actions/ServicesActions.js

@@ -14,7 +14,7 @@
   limitations under the License.
 */
 import alt from 'src/alt';
-import ServicesApi from 'api/ServicesApi';
+import ClustersApi from 'api/ClustersApi';
 
 class ServicesActions {
 
@@ -26,13 +26,13 @@ class ServicesActions {
     );
   }
 
-  fetchServices(endpoint) {
-    this.fetchServicesStart(endpoint);
-    return ServicesApi.fetchServices(endpoint).then(services => {
-      this.fetchServicesSuccess({endpoint, services});
+  fetchServices(cluster) {
+    this.fetchServicesStart(cluster);
+    return ClustersApi.fetchServices(cluster).then(services => {
+      this.fetchServicesSuccess({cluster, services});
     })
     .catch(() => {
-      this.fetchServicesFailure(endpoint);
+      this.fetchServicesFailure(cluster);
     });
   }
 }

src/api/BaseApi.js

@@ -15,6 +15,8 @@
 */
 import StatusCodes from 'utils/StatusCodes';
 import Qs from 'qs';
+import utf8 from 'utf8';
+import base64 from 'base-64';
 import { StatusBar, Platform, InteractionManager } from 'react-native';
 
 let REQUESTS_COUNT = 0;
@@ -43,7 +45,7 @@ class BaseApi {
       'Content-Type': 'application/json',
     };
     if (authentication) {
-      headers.Authorization = 'Basic ' + btoa(`${authentication.username}:${authentication.password}`);
+      headers.Authorization = 'Basic ' + base64.encode(utf8.encode(`${authentication.username}:${authentication.password}`));
     }
 
     if (dataUrl) {
@@ -92,7 +94,8 @@ class BaseApi {
     return this.apiFetch({method: 'post', url, body});
   }
 
-  static get(url, dataUrl, authentication) {
+  static get(url, dataUrl, cluster) {
+    const authentication = {username: cluster.get('username'), password: cluster.get('password')};
     return this.apiFetch({method: 'get', url, dataUrl, authentication});
   }
 

src/api/ClustersApi.js

@@ -0,0 +1,46 @@
+/*
+  Copyright 2015 Skippbox, Ltd
+
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License.
+*/
+import BaseApi from './BaseApi';
+
+class ClustersApi {
+
+  static checkCluster(cluster) {
+    return BaseApi.get(`${cluster.get('url')}/api/v1`, {}, cluster)
+      .then(() => Promise.resolve(true))
+      .catch(() => Promise.resolve(false));
+  }
+
+  static fetchPods(cluster) {
+    return BaseApi.get(`${cluster.get('url')}/api/v1/pods`, {}, cluster).then((response) => {
+      return response.get('items');
+    });
+  }
+
+  static fetchReplications(cluster) {
+    return BaseApi.get(`${cluster.get('url')}/api/v1/replicationcontrollers`, {}, cluster).then((response) => {
+      return response.get('items');
+    });
+  }
+
+  static fetchServices(cluster) {
+    return BaseApi.get(`${cluster.get('url')}/api/v1/services`, {}, cluster).then((response) => {
+      return response.get('items');
+    });
+  }
+
+}
+
+export default ClustersApi;