Adding deployALL buttons to admin panel (#162)

Author: jeremyd

dashboard/src/actions/index.js

@@ -844,3 +844,43 @@ export const cancelRelease = (project_slug, payload) => {
     }
   }
 }
+
+export const PROJECT_DEPLOY_ALL_REQUEST = 'PROJECT_DEPLOY_ALL_REQUEST'
+export const PROJECT_DEPLOY_ALL_SUCCESS = 'PROJECT_DEPLOY_ALL_SUCCESS'
+export const PROJECT_DEPLOY_ALL_FAILURE = 'PROJECT_DEPLOY_ALL_FAILURE'
+
+export const projectDeployAll = () => {
+  return {
+    [CALL_API]: {
+      endpoint: `${API_ROOT}/admin/deployallprojects`,
+      method: 'PUT',
+      body: '',
+      headers: {
+        'Accept': 'application/json',
+        'Content-Type': 'application/json',
+        'Authorization': `Bearer ${authToken()}`
+      },
+      types: [ PROJECT_DEPLOY_ALL_REQUEST, PROJECT_DEPLOY_ALL_SUCCESS, PROJECT_DEPLOY_ALL_FAILURE ]
+    }
+  }
+}
+
+export const SERVICE_DEPLOY_ALL_REQUEST = 'SERVICE_DEPLOY_ALL_REQUEST'
+export const SERVICE_DEPLOY_ALL_SUCCESS = 'SERVICE_DEPLOY_ALL_SUCCESS'
+export const SERVICE_DEPLOY_ALL_FAILURE = 'SERVICE_DEPLOY_ALL_FAILURE'
+
+export const loadBalancerDeployAll = () => {
+  return {
+    [CALL_API]: {
+      endpoint: `${API_ROOT}/admin/deployloadbalancers`,
+      method: 'PUT',
+      body: '',
+      headers: {
+        'Accept': 'application/json',
+        'Content-Type': 'application/json',
+        'Authorization': `Bearer ${authToken()}`
+      },
+      types: [ SERVICE_DEPLOY_ALL_REQUEST, SERVICE_DEPLOY_ALL_SUCCESS, SERVICE_DEPLOY_ALL_FAILURE ]
+    }
+  }
+}

dashboard/src/components/admin/AdminActionsList.js

@@ -0,0 +1,38 @@
+import React, { Component } from 'react'
+import { connect } from 'react-redux'
+import ButtonConfirmAction from '../ButtonConfirmAction'
+import { projectDeployAll, loadBalancerDeployAll } from '../../actions'
+
+class AdminActionsList extends Component {
+    render() {
+        return(
+            <div>
+                <div className="hr-divider m-t-md m-b">
+                    <h3 className="hr-divider-content hr-divider-heading">Admin Actions</h3>
+                </div>
+                <ButtonConfirmAction btnLabel="Deploy All Projects" btnIconClass="fa fa-rocket" size="lg" btnClass="btn btn-warning btn-lg float-xs-center" onConfirm={() => this.onDeployAllProjectsClick()}>
+                   Are you sure you want to deploy <b>every</b> project?
+                </ButtonConfirmAction>
+                <ButtonConfirmAction btnLabel="Update All Services" btnIconClass="fa fa-rocket" size="lg" btnClass="btn btn-danger btn-lg float-xs-center" onConfirm={() => this.onDeployAllLoadBalancersClick()}>
+                   Are you sure you want to deploy <b>every</b> load balancer?
+                </ButtonConfirmAction>
+
+            </div>
+        )
+    }
+
+    onDeployAllProjectsClick() {
+        this.props.projectDeployAll()
+    }
+    onDeployAllLoadBalancersClick() {
+        this.props.loadBalancerDeployAll()
+    }
+}
+
+const mapStateToProps = (_state, _ownProps) => ({
+})
+
+export default connect(mapStateToProps, {
+    projectDeployAll,
+    loadBalancerDeployAll,
+})(AdminActionsList)

dashboard/src/components/admin/index.js

@@ -1,12 +1,14 @@
 import React, { Component } from 'react'
 import { connect } from 'react-redux'
 import ServiceSpecList from './ServiceSpecList'
+import AdminActionsList from './AdminActionsList'
 
 class Admin extends Component {
   render() {
     return (
       <div>
         <ServiceSpecList specs={this.props.serviceSpecs}/>
+        <AdminActionsList/>
       </div>
     )
   }

server/configs/.gitignore

@@ -0,0 +1 @@
+kubeconfigs

server/plugins/codeflow/api_admin.go

@@ -3,6 +3,7 @@ package codeflow
 import (
 	"log"
 	"net/http"
+	"time"
 
 	"gopkg.in/mgo.v2/bson"
 
@@ -21,11 +22,59 @@ func (x *Admin) Register(api *rest.Api) []*rest.Route {
 		rest.Put(x.Path+"/serviceSpecs", x.updateServiceSpec),
 		rest.Delete(x.Path+"/serviceSpecs/#slug", x.deleteServiceSpec),
 		rest.Get(x.Path+"/serviceSpecs/#slug/services", x.serviceSpecServices),
+		rest.Put(x.Path+"/deployallprojects", x.deployAllProjects),
+		rest.Put(x.Path+"/deployloadbalancers", x.deployAllLoadBalancers),
 	)
 	log.Printf("Started the codeflow admin handler on %s\n", x.Path)
 	return routes
 }
 
+// Deploys all projects (does not touch services)
+func (x *Admin) deployAllProjects(w rest.ResponseWriter, r *rest.Request) {
+	projects := []Project{}
+	m := bson.M{"deleted": false}
+	results := db.Collection("projects").Find(m)
+	results.Query.Sort("-$natural").All(&projects)
+	log.Printf("Deploying %d projects", len(projects))
+	for _, p := range projects {
+		log.Printf("Deploying %s...", p.Slug)
+		release := Release{}
+		if err := GetCurrentRelease(p.Id, &release); err != nil {
+			log.Printf("GetCurrentRelease::Error: %s; Aborting release for %s", err, p.Slug)
+		} else {
+			log.Printf("Deploying %s release", release.Id)
+			err := CreateDeploy(&release)
+			if err != nil {
+				log.Printf("ERROR '%s' creating deployment for %s", err, p.Slug)
+			}
+		}
+	}
+}
+
+// Deploys all loadBalancers
+func (x *Admin) deployAllLoadBalancers(w rest.ResponseWriter, r *rest.Request) {
+	projects := []Project{}
+	m := bson.M{"deleted": false}
+	results := db.Collection("projects").Find(m)
+	results.Query.Sort("-$natural").All(&projects)
+	for _, p := range projects {
+		log.Printf("Finding services for '%s' project...", p.Slug)
+		l := bson.M{"projectId": p.Id}
+		lbResults := db.Collection("extensions").Find(l)
+		loadBalancer := &LoadBalancer{}
+		for lbResults.Next(loadBalancer) {
+			log.Printf("Deploying loadbalancer %s for %s", loadBalancer.Name, p.Slug)
+			err := ExtensionUpdated(loadBalancer)
+			if err != nil {
+				log.Printf("ERROR '%s' updating loadBalancer %s", err, loadBalancer.Name)
+			}
+		}
+	}
+	// Throttle so that we can be "nice" to the amazon APIs
+	log.Println("Sleeping 1 second")
+	time.Sleep(time.Second * 1)
+}
+
 func (x *Admin) deleteServiceSpec(w rest.ResponseWriter, r *rest.Request) {
 	slug := r.PathParam("slug")
 

server/plugins/codeflow/codeflow.go

@@ -312,7 +312,7 @@ func (x *Codeflow) Process(e agent.Event) error {
 			}
 		}
 
-		if err := db.Collection("features").FindOne(bson.M{"hash": payload.Hash}, &feature); err != nil {
+		if err := db.Collection("features").FindOne(bson.M{"hash": payload.Hash, "projectId": project.Id}, &feature); err != nil {
 			if _, ok := err.(*bongo.DocumentNotFoundError); ok {
 				feature = Feature{
 					ProjectId:  project.Id,

server/plugins/kubedeploy/deployments.go

@@ -262,12 +262,14 @@ func (x *KubeDeploy) doDeploy(e agent.Event) error {
 
 	config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
 	if err != nil {
-		panic(err.Error())
+		log.Printf("ERROR '%s' while building kubernetes api client config.  Aborting!", err)
+		return nil
 	}
 
 	clientset, err := kubernetes.NewForConfig(config)
 	if err != nil {
-		log.Println("Error getting cluster config.")
+		log.Println("Error getting cluster config.  Aborting!")
+		return nil
 	}
 
 	data := e.Payload.(plugins.DockerDeploy)

server/plugins/kubedeploy/loadbalancers.go

@@ -216,8 +216,8 @@ func (x *KubeDeploy) doLoadBalancer(e agent.Event) error {
 	var ELBDNS string
 	if payload.Type == plugins.External || payload.Type == plugins.Office {
 		log.Printf("Waiting for ELB address for %s", payload.Name)
-		// Timeout waiting for ELB DNS name after 600 seconds
-		timeout := 600
+		// Timeout waiting for ELB DNS name after 900 seconds
+		timeout := 900
 		for {
 			elbResult, elbErr := coreInterface.Services(namespace).Get(payload.Name, meta_v1.GetOptions{})
 			if elbErr != nil {