Merge pull request #51 from secondsun/mdc2ups

chore:replace mdc with ups

cmd/broker/main.go

@@ -4,18 +4,19 @@ import (
 	"context"
 	"flag"
 	"fmt"
+	"os"
+	"os/signal"
+	"path"
+	"strconv"
+	"syscall"
+
 	"github.com/integr8ly/managed-service-broker/pkg/deploys/apicurio"
 	"github.com/integr8ly/managed-service-broker/pkg/deploys/che"
 	"github.com/integr8ly/managed-service-broker/pkg/deploys/fuse"
 	"github.com/integr8ly/managed-service-broker/pkg/deploys/fuse_managed"
 	"github.com/integr8ly/managed-service-broker/pkg/deploys/launcher"
-	"github.com/integr8ly/managed-service-broker/pkg/deploys/mdc"
 	"github.com/integr8ly/managed-service-broker/pkg/deploys/sso"
-	"os"
-	"os/signal"
-	"path"
-	"strconv"
-	"syscall"
+	"github.com/integr8ly/managed-service-broker/pkg/deploys/unifiedpush"
 
 	"github.com/integr8ly/managed-service-broker/pkg/broker"
 	"github.com/integr8ly/managed-service-broker/pkg/broker/controller"
@@ -65,7 +66,7 @@ const (
 	fuseManagedServiceName = "fuse-managed"
 	rhssoServiceName       = "rhsso"
 	userRHSSOServiceName   = "user-rhsso"
-	mdcServiceName         = "mdc"
+	unifiedpushServiceName = "unifiedpush"
 )
 
 func runWithContext(ctx context.Context) error {
@@ -128,8 +129,8 @@ func runWithContext(ctx context.Context) error {
 	if shouldRegisterService(userRHSSOServiceName) {
 		deployers = append(deployers, sso.NewUserDeployer())
 	}
-	if shouldRegisterService(mdcServiceName) {
-		deployers = append(deployers, mdc.NewDeployer())
+	if shouldRegisterService(unifiedpushServiceName) {
+		deployers = append(deployers, unifiedpush.NewDeployer())
 	}
 	ctrlr := controller.CreateController(deployers)
 
@@ -175,8 +176,8 @@ func shouldRegisterService(serviceName string) bool {
 		return os.Getenv(sso.DefaultManagedURLEnv) != ""
 	case userRHSSOServiceName:
 		return os.Getenv(sso.DefaultUserURLEnv) != ""
-	case mdcServiceName:
-		return os.Getenv("MDC_DASHBOARD_URL") != ""
+	case unifiedpushServiceName:
+		return os.Getenv("UNIFIEDPUSH_DASHBOARD_URL") != ""
 	}
 	return false
 }

pkg/deploys/unifiedpush/deployer.go

@@ -0,0 +1,50 @@
+package unifiedpush
+
+import (
+	"net/http"
+	"os"
+
+	brokerapi "github.com/integr8ly/managed-service-broker/pkg/broker"
+	glog "github.com/sirupsen/logrus"
+)
+
+type UnifiedpushDeployer struct {
+	id string
+}
+
+func NewDeployer() *UnifiedpushDeployer {
+	return &UnifiedpushDeployer{}
+}
+
+func (md *UnifiedpushDeployer) GetCatalogEntries() []*brokerapi.Service {
+	glog.Infof("Getting unifiedpush catalog entries")
+	return getCatalogServicesObj()
+}
+
+func (md *UnifiedpushDeployer) GetID() string {
+	return md.id
+}
+
+func (md *UnifiedpushDeployer) Deploy(req *brokerapi.ProvisionRequest, async bool) (*brokerapi.ProvisionResponse, error) {
+	glog.Infof("Deploying unifiedpush from deployer, id: %s", req.InstanceId)
+
+	dashboardUrl := os.Getenv("UNIFIEDPUSH_DASHBOARD_URL")
+
+	return &brokerapi.ProvisionResponse{
+		Code:         http.StatusAccepted,
+		DashboardURL: dashboardUrl,
+	}, nil
+}
+
+func (md *UnifiedpushDeployer) RemoveDeploy(req *brokerapi.DeprovisionRequest, async bool) (*brokerapi.DeprovisionResponse, error) {
+	return &brokerapi.DeprovisionResponse{Operation: "remove"}, nil
+}
+
+func (ac *UnifiedpushDeployer) ServiceInstanceLastOperation(req *brokerapi.LastOperationRequest) (*brokerapi.LastOperationResponse, error) {
+	glog.Infof("Getting last operation for %s", req.InstanceId)
+
+	return &brokerapi.LastOperationResponse{
+		State:       brokerapi.StateSucceeded,
+		Description: "unifiedpush deployed successfully",
+	}, nil
+}