From 011458fb0575fcfa65f82ca9fb19517e44128646 Mon Sep 17 00:00:00 2001
From: Sergey Dudoladov <sergey.dudoladov@zalando.de>
Date: Thu, 21 Dec 2017 17:28:55 +0100
Subject: [PATCH] Add a REST endpoint to list databases in all clusters

---
 pkg/apiserver/apiserver.go | 10 ++++++++++
 pkg/controller/status.go   | 14 ++++++++++++++
 2 files changed, 24 insertions(+)

diff --git a/pkg/apiserver/apiserver.go b/pkg/apiserver/apiserver.go
index 2d9c497cd..80409f6d1 100644
--- a/pkg/apiserver/apiserver.go
+++ b/pkg/apiserver/apiserver.go
@@ -37,6 +37,7 @@ type controllerInformer interface {
 	ListQueue(workerID uint32) (*spec.QueueDump, error)
 	GetWorkersCnt() uint32
 	WorkerStatus(workerID uint32) (*spec.WorkerStatus, error)
+	GetClusterDatabasesMap() map[string][]string
 }
 
 // Server describes HTTP API server
@@ -78,6 +79,7 @@ func New(controller controllerInformer, port int, logger *logrus.Logger) *Server
 
 	mux.HandleFunc("/clusters/", s.clusters)
 	mux.HandleFunc("/workers/", s.workers)
+	mux.HandleFunc("/databases/", s.databases)
 
 	s.http = http.Server{
 		Addr:        fmt.Sprintf(":%d", port),
@@ -222,6 +224,14 @@ func (s *Server) workers(w http.ResponseWriter, req *http.Request) {
 	s.respond(resp, err, w)
 }
 
+func (s *Server) databases(w http.ResponseWriter, req *http.Request) {
+
+	databaseNamesPerCluster := s.controller.GetClusterDatabasesMap()
+	s.respond(databaseNamesPerCluster, nil, w)
+	return
+
+}
+
 func (s *Server) allQueues(w http.ResponseWriter, r *http.Request) {
 	workersCnt := s.controller.GetWorkersCnt()
 	resp := make(map[uint32]*spec.QueueDump, workersCnt)
diff --git a/pkg/controller/status.go b/pkg/controller/status.go
index 27465fdd7..b5edcec87 100644
--- a/pkg/controller/status.go
+++ b/pkg/controller/status.go
@@ -32,6 +32,20 @@ func (c *Controller) ClusterStatus(team, cluster string) (*spec.ClusterStatus, e
 	return status, nil
 }
 
+// GetClusterDatabasesMap returns for each cluster the list of databases running there
+func (c *Controller) GetClusterDatabasesMap() map[string][]string {
+
+	m := make(map[string][]string)
+
+	for _, cluster := range c.clusters {
+		for database := range cluster.Postgresql.Spec.Databases {
+			m[cluster.Name] = append(m[cluster.Name], database)
+		}
+	}
+
+	return m
+}
+
 // TeamClusterList returns team-clusters map
 func (c *Controller) TeamClusterList() map[string][]spec.NamespacedName {
 	return c.teamClusters