1 files changed, 187 insertions, 0 deletions
diff --git a/src/tools/emcoui/middle_end/app/projects.go b/src/tools/emcoui/middle_end/app/projects.go
new file mode 100644
index 00000000..39fe7573
--- /dev/null
+++ b/src/tools/emcoui/middle_end/app/projects.go
@@ -0,0 +1,187 @@
+/*
+=======================================================================
+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 ProjectMetadata struct {
+	Metadata apiMetaData `json:"metadata"`
+}
+
+// CompAppHandler , This implements the orchworkflow interface
+type projectHandler struct {
+	orchURL      string
+	orchInstance *OrchestrationHandler
+}
+
+func (h *projectHandler) getObject() (interface{}, interface{}) {
+	orch := h.orchInstance
+	dataRead := h.orchInstance.dataRead
+	var cappList []CompositeApp
+	if orch.treeFilter != nil {
+		temp:=CompositeApp{}
+		h.orchURL = "http://" + orch.MiddleendConf.OrchService + "/v2/projects/" +
+			orch.projectName + "/composite-apps/" + orch.treeFilter.compositeAppName+"/"+
+			orch.treeFilter.compositeAppVersion
+		respcode, respdata, err := orch.apiGet(h.orchURL, orch.projectName+"_getcapps")
+		fmt.Printf("Get capp status %s\n", respcode)
+		if err != nil {
+			return nil, 500
+		}
+		if respcode != 200 {
+			return nil, respcode
+		}
+		fmt.Printf("Get capp status %s\n", respcode)
+		json.Unmarshal(respdata, &temp)
+		cappList = append(cappList, temp)
+	} else {
+		h.orchURL = "http://" + orch.MiddleendConf.OrchService + "/v2/projects/" +
+			orch.projectName + "/composite-apps"
+		respcode, respdata, err := orch.apiGet(h.orchURL, orch.projectName+"_getcapps")
+		fmt.Printf("Get capp status %s\n", respcode)
+		if err != nil {
+			return nil, 500
+		}
+		if respcode != 200 {
+			return nil, respcode
+		}
+		fmt.Printf("Get capp status %s\n", respcode)
+		json.Unmarshal(respdata, &cappList)
+	}
+
+	dataRead.compositeAppMap = make(map[string]*CompositeAppTree, len(cappList))
+	for k, value := range cappList {
+		fmt.Printf("%+v", cappList[k])
+		var cappsDataInstance CompositeAppTree
+		cappName := value.Metadata.Name
+		cappsDataInstance.Metadata = value
+		dataRead.compositeAppMap[cappName] = &cappsDataInstance
+	}
+	return nil, 200 
+}
+
+func (h *projectHandler) getAnchor() (interface{}, interface{}) {
+	orch := h.orchInstance
+	dataRead := h.orchInstance.dataRead
+	h.orchURL = "http://" + orch.MiddleendConf.OrchService + "/v2/projects/" +
+		orch.projectName
+
+	respcode, respdata, err := orch.apiGet(h.orchURL, orch.projectName+"_getProject")
+	if err != nil {
+		return nil, 500
+	}
+	if respcode != 200 {
+		return nil, respcode
+	}
+	fmt.Printf("Get project %s\n", respcode)
+	json.Unmarshal(respdata, &dataRead.Metadata)
+	return nil, respcode
+}
+
+func (h *projectHandler) deleteObject() interface{} {
+	orch := h.orchInstance
+	dataRead := h.orchInstance.dataRead
+	cappList := dataRead.compositeAppMap
+	h.orchURL = "http://" + orch.MiddleendConf.OrchService + "/v2/projects/" +
+		orch.projectName + "/composite-apps"
+	for compositeAppName, compositeAppValue := range cappList {
+		url := h.orchURL + "/" + compositeAppName + "/" + compositeAppValue.Metadata.Spec.Version
+		fmt.Printf("Delete composite app %s\n", url)
+		resp, err := orch.apiDel(url, compositeAppName+"_delcapp")
+		if err != nil {
+			return err
+		}
+		if resp != 204 {
+			return resp
+		}
+		fmt.Printf("Delete composite app status %s\n", resp)
+	}
+	return nil
+}
+
+func (h *projectHandler) deleteAnchor() interface{} {
+	orch := h.orchInstance
+	h.orchURL = "http://" + orch.MiddleendConf.OrchService + "/v2/projects/" + orch.projectName
+	fmt.Printf("Delete Project %s \n", h.orchURL)
+	resp, err := orch.apiDel(h.orchURL, orch.projectName+"_delProject")
+	if err != nil {
+		return err
+	}
+	if resp != 204 {
+		return resp
+	}
+	fmt.Printf("Delete Project status %s\n", resp)
+	return nil
+}
+
+func (h *projectHandler) createAnchor() interface{} {
+	orch := h.orchInstance
+
+	projectCreate := ProjectMetadata{
+		Metadata: apiMetaData{
+			Name:        orch.projectName,
+			Description: orch.projectDesc,
+			UserData1:   "data 1",
+			UserData2:   "data 2"},
+	}
+
+	jsonLoad, _ := json.Marshal(projectCreate)
+	h.orchURL = "http://" + orch.MiddleendConf.OrchService + "/v2/projects/" + orch.projectName
+	resp, err := orch.apiPost(jsonLoad, h.orchURL, orch.projectName)
+	if err != nil {
+		return err
+	}
+	if resp != 201 {
+		return resp
+	}
+	orch.version = "v1"
+	fmt.Printf("projectHandler resp %s\n", resp)
+
+	return nil
+}
+
+func (h *projectHandler) createObject() interface{} {
+	return nil
+}
+
+func createProject(I orchWorkflow) interface{} {
+	// 1. Create the Anchor point
+	err := I.createAnchor()
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+func delProject(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
+}