From 1080fc756a5717bcc1fd65de1e8d1b93523f8091 Mon Sep 17 00:00:00 2001
From: Karolis Rusenas <karolis.rusenas@gmail.com>
Date: Tue, 27 Jun 2017 23:40:56 +0100
Subject: [PATCH] fetching deployments

---
 bot/deployments.go | 83 ++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 83 insertions(+)
 create mode 100644 bot/deployments.go

diff --git a/bot/deployments.go b/bot/deployments.go
new file mode 100644
index 00000000..e0d0cb66
--- /dev/null
+++ b/bot/deployments.go
@@ -0,0 +1,83 @@
+package bot
+
+import (
+	"bytes"
+	"fmt"
+
+	"github.com/rusenask/keel/bot/formatter"
+
+	"k8s.io/client-go/pkg/apis/extensions/v1beta1"
+
+	log "github.com/Sirupsen/logrus"
+)
+
+type Filter struct {
+	Namespace string
+	All       bool // keel or not
+}
+
+// deployments - gets all deployments
+func (b *Bot) deployments() ([]v1beta1.Deployment, error) {
+	deploymentLists := []*v1beta1.DeploymentList{}
+
+	n, err := b.k8sImplementer.Namespaces()
+	if err != nil {
+		return nil, err
+	}
+
+	for _, n := range n.Items {
+		l, err := b.k8sImplementer.Deployments(n.GetName())
+		if err != nil {
+			log.WithFields(log.Fields{
+				"error":     err,
+				"namespace": n.GetName(),
+			}).Error("provider.kubernetes: failed to list deployments")
+			continue
+		}
+		deploymentLists = append(deploymentLists, l)
+	}
+
+	impacted := []v1beta1.Deployment{}
+
+	for _, deploymentList := range deploymentLists {
+		for _, deployment := range deploymentList.Items {
+			impacted = append(impacted, deployment)
+		}
+	}
+
+	return impacted, nil
+}
+
+func (b *Bot) deploymentsResponse(filter Filter) string {
+	deps, err := b.deployments()
+	if err != nil {
+		return fmt.Sprintf("got error while fetching deployments: %s", err)
+	}
+	log.Infof("%d deployments fetched, formatting", len(deps))
+	buf := &bytes.Buffer{}
+
+	DeploymentCtx := formatter.Context{
+		Output: buf,
+		Format: formatter.NewDeploymentsFormat(formatter.TableFormatKey, false),
+	}
+	err = formatter.DeploymentWrite(DeploymentCtx, convertToInternal(deps))
+
+	if err != nil {
+		return fmt.Sprintf(" got error while formatting deployments: %s", err)
+	}
+
+	log.Infof("formated. returning buffer: %s", buf.String())
+
+	return buf.String()
+}
+
+func convertToInternal(deployments []v1beta1.Deployment) []formatter.Deployment {
+	formatted := []formatter.Deployment{}
+	for _, d := range deployments {
+		formatted = append(formatted, formatter.Deployment{
+			Namespace: d.Namespace,
+			Name:      d.Name,
+		})
+	}
+	return formatted
+}