1 files changed, 247 insertions, 0 deletions
diff --git a/src/tools/emcoui/middle_end/app/compositeapp.go b/src/tools/emcoui/middle_end/app/compositeapp.go
new file mode 100644
index 00000000..daae5b00
--- /dev/null
+++ b/src/tools/emcoui/middle_end/app/compositeapp.go
@@ -0,0 +1,247 @@
+/*
+=======================================================================
+Copyright (c) 2017-2020 Aarna Networks, Inc.
+All rights reserved.
+======================================================================
+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.
+========================================================================
+*/
+
+package app
+
+import (
+	"encoding/json"
+	"fmt"
+)
+
+// CompositeApp application structure
+type CompositeApp struct {
+	Metadata apiMetaData      `json:"metadata"`
+	Spec     compositeAppSpec `json:"spec"`
+}
+
+type compositeAppSpec struct {
+	Version string `json:"version"`
+}
+
+// compAppHandler , This implements the orchworkflow interface
+type compAppHandler struct {
+	orchURL      string
+	orchInstance *OrchestrationHandler
+}
+
+// CompositeAppKey is the mongo key to fetch apps in a composite app
+type CompositeAppKey struct {
+	Cname    string      `json:"compositeapp"`
+	Project  string      `json:"project"`
+	Cversion string      `json:"compositeappversion"`
+	App      interface{} `json:"app"`
+}
+
+func (h *compAppHandler) getObject() (interface{}, interface{}) {
+	orch := h.orchInstance
+	respcode := 200
+	dataRead := h.orchInstance.dataRead
+	for _, compositeAppValue := range dataRead.compositeAppMap {
+		compositeAppMetadata := compositeAppValue.Metadata.Metadata
+		compositeAppSpec := compositeAppValue.Metadata.Spec
+		h.orchURL = "http://" + orch.MiddleendConf.OrchService + "/v2/projects/" +
+			orch.projectName + "/composite-apps/" + compositeAppMetadata.Name +
+			"/" + compositeAppSpec.Version + "/apps"
+
+		respcode, respdata, err := orch.apiGet(h.orchURL, orch.compositeAppName+"_getapps")
+		if err != nil {
+			return nil, 500
+		}
+		if respcode != 200 {
+			return nil, respcode
+		}
+		fmt.Printf("Get app status %s\n", respcode)
+		compositeAppValue.AppsDataArray = make(map[string]*AppsData, len(respdata))
+		var appList []CompositeApp
+		json.Unmarshal(respdata, &appList)
+		for _, value := range appList {
+			var appsDataInstance AppsData
+			appName := value.Metadata.Name
+			appsDataInstance.App = value
+			compositeAppValue.AppsDataArray[appName] = &appsDataInstance
+		}
+	}
+	return nil, respcode
+}
+
+func (h *compAppHandler) getAnchor() (interface{}, interface{}) {
+	orch := h.orchInstance
+	dataRead := h.orchInstance.dataRead
+	respcode := 200
+	for _, compositeAppValue := range dataRead.compositeAppMap {
+		compositeAppMetadata := compositeAppValue.Metadata.Metadata
+		compositeAppSpec := compositeAppValue.Metadata.Spec
+		h.orchURL = "http://" + orch.MiddleendConf.OrchService + "/v2/projects/" +
+			orch.projectName + "/composite-apps/" + compositeAppMetadata.Name +
+			"/" + compositeAppSpec.Version
+
+		respcode, _, err := orch.apiGet(h.orchURL, orch.compositeAppName+"_getcompositeapp")
+		if err != nil {
+			return nil, 500
+		}
+		if respcode != 200 {
+			return nil, respcode
+		}
+		fmt.Printf("Get composite App %s\n", respcode)
+		//json.Unmarshal(respdata, &dataRead.CompositeApp)
+	}
+	return nil, respcode
+}
+
+func (h *compAppHandler) deleteObject() interface{} {
+	orch := h.orchInstance
+	dataRead := h.orchInstance.dataRead
+	for _, compositeAppValue := range dataRead.compositeAppMap {
+		compositeAppMetadata := compositeAppValue.Metadata.Metadata
+		compositeAppSpec := compositeAppValue.Metadata.Spec
+		h.orchURL = "http://" + orch.MiddleendConf.OrchService + "/v2/projects/" +
+			orch.projectName + "/composite-apps/" + compositeAppMetadata.Name +
+			"/" + compositeAppSpec.Version
+		appList := compositeAppValue.AppsDataArray
+		for _, value := range appList {
+			url := h.orchURL + "/apps/" + value.App.Metadata.Name
+			fmt.Printf("Delete app %s\n", url)
+			resp, err := orch.apiDel(url, compositeAppMetadata.Name+"_delapp")
+			if err != nil {
+				return err
+			}
+			if resp != 204 {
+				return resp
+			}
+			fmt.Printf("Delete app status %s\n", resp)
+		}
+	}
+	return nil
+}
+
+func (h *compAppHandler) deleteAnchor() interface{} {
+	orch := h.orchInstance
+	dataRead := h.orchInstance.dataRead
+	for _, compositeAppValue := range dataRead.compositeAppMap {
+		compositeAppMetadata := compositeAppValue.Metadata.Metadata
+		compositeAppSpec := compositeAppValue.Metadata.Spec
+		h.orchURL = "http://" + orch.MiddleendConf.OrchService + "/v2/projects/" +
+			orch.projectName + "/composite-apps/" + compositeAppMetadata.Name +
+			"/" + compositeAppSpec.Version
+		fmt.Printf("Delete composite app %s\n", h.orchURL)
+		resp, err := orch.apiDel(h.orchURL, compositeAppMetadata.Name+"_delcompapp")
+		if err != nil {
+			return err
+		}
+		if resp != 204 {
+			return resp
+		}
+		fmt.Printf("Delete compapp status %s\n", resp)
+	}
+	return nil
+}
+
+// CreateAnchor creates the anchor point for composite applications,
+// profiles, intents etc. For example Anchor for the composite application
+// will create the composite application resource in the the DB, and all apps
+// will get created and uploaded under this anchor point.
+func (h *compAppHandler) createAnchor() interface{} {
+	orch := h.orchInstance
+
+	compAppCreate := CompositeApp{
+		Metadata: apiMetaData{
+			Name:        orch.compositeAppName,
+			Description: orch.compositeAppDesc,
+			UserData1:   "data 1",
+			UserData2:   "data 2"},
+		Spec: compositeAppSpec{
+			Version: "v1"},
+	}
+
+	jsonLoad, _ := json.Marshal(compAppCreate)
+	tem := CompositeApp{}
+	json.Unmarshal(jsonLoad, &tem)
+	h.orchURL = "http://" + orch.MiddleendConf.OrchService + "/v2/projects/" +
+		orch.projectName + "/composite-apps"
+	resp, err := orch.apiPost(jsonLoad, h.orchURL, orch.compositeAppName)
+	if err != nil {
+		return err
+	}
+	if resp != 201 {
+		return resp
+	}
+	orch.version = "v1"
+	fmt.Printf("compAppHandler resp %s\n", resp)
+
+	return nil
+}
+
+func (h *compAppHandler) createObject() interface{} {
+	orch := h.orchInstance
+	for i := range orch.meta {
+		fileName := orch.meta[i].Metadata.FileName
+		appName := orch.meta[i].Metadata.Name
+		appDesc := orch.meta[i].Metadata.Description
+
+		// Upload the application helm chart
+		fh := orch.file[fileName]
+		compAppAdd := CompositeApp{
+			Metadata: apiMetaData{
+				Name:        appName,
+				Description: appDesc,
+				UserData1:   "data 1",
+				UserData2:   "data2"},
+		}
+		url := h.orchURL + "/" + orch.compositeAppName + "/" + orch.version + "/apps"
+
+		jsonLoad, _ := json.Marshal(compAppAdd)
+
+		status, err := orch.apiPostMultipart(jsonLoad, fh, url, appName, fileName)
+		if err != nil {
+			return err
+		}
+		if status != 201 {
+			return status
+		}
+		fmt.Printf("Composite app %s createObject status %s\n", appName, status)
+	}
+
+	return nil
+}
+
+func createCompositeapp(I orchWorkflow) interface{} {
+	// 1. Create the Anchor point
+	err := I.createAnchor()
+	if err != nil {
+		return err
+	}
+	// 2. Create the Objects
+	err = I.createObject()
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+func delCompositeapp(I orchWorkflow) interface{} {
+	// 1. Delete the object
+	err := I.deleteObject()
+	if err != nil {
+		return err
+	}
+	// 2. Delete the Anchor
+	err = I.deleteAnchor()
+	if err != nil {
+		return err
+	}
+	return nil
+}