Minor fixes in scc 72/4672/2
authorRuoyu Ying <ruoyu.ying@intel.com>
Tue, 8 Feb 2022 05:06:36 +0000 (00:06 -0500)
committerRuoyu <ruoyu.ying@intel.com>
Tue, 8 Feb 2022 05:31:45 +0000 (00:31 -0500)
* Add db operations after deleting delegate hub
* Fix typo

Change-Id: I103063f786cfdfe294993abea2ef3f868da6193c
Signed-off-by: Ruoyu <ruoyu.ying@intel.com>
central-controller/src/scc/pkg/manager/hubdevice_objectmanager.go
central-controller/src/scc/pkg/manager/resource_objectmanager.go
central-controller/src/scc/pkg/manager/resutils.go

index 47b45b2..cbcf70b 100644 (file)
@@ -180,12 +180,15 @@ func (c *HubDeviceObjectManager) DeleteObject(m map[string]string) error {
 
        if dev_obj.Status.DelegatedHub == hub_obj.Metadata.Name {
                dev_obj.Status.DelegatedHub = ""
+               dev_manager.UpdateObject(m, dev_obj)
+
                for i, item := range hub_obj.Status.DelegateDevices {
                        if item == dev_obj.Metadata.Name {
                                hub_obj.Status.DelegateDevices = append(hub_obj.Status.DelegateDevices[:i], hub_obj.Status.DelegateDevices[i+1:]...)
                                break
                        }
                }
+               hub_manager.UpdateObject(m, hub_obj)
        }
 
        conn, err := conn_manager.GetObject(overlay_name,
index 0c36968..ae4c4ea 100644 (file)
@@ -22,6 +22,7 @@ import (
 \r
        "github.com/akraino-edge-stack/icn-sdwan/central-controller/src/scc/pkg/module"\r
        "github.com/open-ness/EMCO/src/orchestrator/pkg/infra/db"\r
+       pkgerrors "github.com/pkg/errors"\r
 )\r
 \r
 type ResourceObjectKey struct {\r
@@ -59,6 +60,7 @@ func (c *ResourceObjectManager) CreateEmptyObject() module.ControllerObject {
 }\r
 \r
 func (c *ResourceObjectManager) GetStoreKey(m map[string]string, t module.ControllerObject, isCollection bool) (db.Key, error) {\r
+       // Currently no collections fetching supported\r
        return ResourceObjectKey{\r
                Cluster: m[OverlayResource] + "-" + m[DeviceResource],\r
                Type:  m["Type"],\r
@@ -85,9 +87,7 @@ func (c *ResourceObjectManager) GetObject(m map[string]string) (module.Controlle
 }\r
 \r
 func (c *ResourceObjectManager) GetObjects(m map[string]string) ([]module.ControllerObject, error) {\r
-       // DB Operation\r
-       t, err := GetDBUtils().GetObjects(c, m)\r
-       return t, err\r
+       return []module.ControllerObject{}, pkgerrors.New("Not implemented")\r
 }\r
 \r
 func (c *ResourceObjectManager) UpdateObject(m map[string]string, t module.ControllerObject) (module.ControllerObject, error) {\r
index 212aba1..887fe65 100644 (file)
@@ -439,7 +439,7 @@ func (d *ResUtil) Undeploy(overlay string) error {
                                                resource.Status = 2
                                                errMessage = errMessage + " " + resource.Resource.GetName()
                                        } else {
-                                               // reset rewource status
+                                               // reset resource status
                                                resource.Status = 1
                                                resobj.Specification.Ref = 0
                                                res_manager.DeleteObject(m)