[bugfix] add func for RsBestPathCtrlPol

ciscoecosystem · Mar 29, 2022 · ebdb198 · ebdb198
1 parent ce2289d
commit ebdb198
Showing 1 changed file with 64 additions and 14 deletions.
diff --git a/client/bgpProtP_service.go b/client/bgpProtP_service.go
@@ -8,16 +8,17 @@ import (
 	"github.com/ciscoecosystem/aci-go-client/models"
 )
 
-func (sm *ServiceManager) CreateL3outBGPProtocolProfile(logical_node_profile string, l3_outside string, tenant string, bgpProtPattr models.L3outBGPProtocolProfileAttributes) (*models.L3outBGPProtocolProfile, error) {
-	rn := fmt.Sprintf("protp")
-	parentDn := fmt.Sprintf("uni/tn-%s/out-%s/lnodep-%s", tenant, l3_outside, logical_node_profile)
-	bgpProtP := models.NewL3outBGPProtocolProfile(rn, parentDn, bgpProtPattr)
+func (sm *ServiceManager) CreateL3outBGPProtocolProfile(logical_node_profile string, l3_outside string, tenant string, nameAlias string, bgpProtPattr models.L3outBGPProtocolProfileAttributes) (*models.L3outBGPProtocolProfile, error) {
+	rn := fmt.Sprintf(models.RnbgpProtP)
+	parentDn := fmt.Sprintf(models.ParentDnbgpProtP, tenant, l3_outside, logical_node_profile)
+	bgpProtP := models.NewL3outBGPProtocolProfile(rn, parentDn, nameAlias, bgpProtPattr)
 	err := sm.Save(bgpProtP)
 	return bgpProtP, err
 }
 
 func (sm *ServiceManager) ReadL3outBGPProtocolProfile(logical_node_profile string, l3_outside string, tenant string) (*models.L3outBGPProtocolProfile, error) {
-	dn := fmt.Sprintf("uni/tn-%s/out-%s/lnodep-%s/protp", tenant, l3_outside, logical_node_profile)
+	dn := fmt.Sprintf(models.DnbgpProtP, tenant, l3_outside, logical_node_profile)
+
 	cont, err := sm.Get(dn)
 	if err != nil {
 		return nil, err
@@ -28,14 +29,14 @@ func (sm *ServiceManager) ReadL3outBGPProtocolProfile(logical_node_profile strin
 }
 
 func (sm *ServiceManager) DeleteL3outBGPProtocolProfile(logical_node_profile string, l3_outside string, tenant string) error {
-	dn := fmt.Sprintf("uni/tn-%s/out-%s/lnodep-%s/protp", tenant, l3_outside, logical_node_profile)
+	dn := fmt.Sprintf(models.DnbgpProtP, tenant, l3_outside, logical_node_profile)
 	return sm.DeleteByDn(dn, models.BgpprotpClassName)
 }
 
-func (sm *ServiceManager) UpdateL3outBGPProtocolProfile(logical_node_profile string, l3_outside string, tenant string, bgpProtPattr models.L3outBGPProtocolProfileAttributes) (*models.L3outBGPProtocolProfile, error) {
-	rn := fmt.Sprintf("protp")
-	parentDn := fmt.Sprintf("uni/tn-%s/out-%s/lnodep-%s", tenant, l3_outside, logical_node_profile)
-	bgpProtP := models.NewL3outBGPProtocolProfile(rn, parentDn, bgpProtPattr)
+func (sm *ServiceManager) UpdateL3outBGPProtocolProfile(logical_node_profile string, l3_outside string, tenant string, nameAlias string, bgpProtPattr models.L3outBGPProtocolProfileAttributes) (*models.L3outBGPProtocolProfile, error) {
+	rn := fmt.Sprintf(models.RnbgpProtP)
+	parentDn := fmt.Sprintf(models.ParentDnbgpProtP, tenant, l3_outside, logical_node_profile)
+	bgpProtP := models.NewL3outBGPProtocolProfile(rn, parentDn, nameAlias, bgpProtPattr)
 
 	bgpProtP.Status = "modified"
 	err := sm.Save(bgpProtP)
@@ -45,15 +46,60 @@ func (sm *ServiceManager) UpdateL3outBGPProtocolProfile(logical_node_profile str
 
 func (sm *ServiceManager) ListL3outBGPProtocolProfile(logical_node_profile string, l3_outside string, tenant string) ([]*models.L3outBGPProtocolProfile, error) {
 
-	baseurlStr := "/api/node/class"
-	dnUrl := fmt.Sprintf("%s/uni/tn-%s/out-%s/lnodep-%s/bgpProtP.json", baseurlStr, tenant, l3_outside, logical_node_profile)
+	dnUrl := fmt.Sprintf("%s/uni/tn-%s/out-%s/lnodep-%s/bgpProtP.json", models.BaseurlStr, tenant, l3_outside, logical_node_profile)
 
 	cont, err := sm.GetViaURL(dnUrl)
 	list := models.L3outBGPProtocolProfileListFromContainer(cont)
 
 	return list, err
 }
 
+func (sm *ServiceManager) CreateRelationbgpRsBestPathCtrlPol(parentDn, annotation, tnBgpBestPathCtrlPolName string) error {
+	dn := fmt.Sprintf("%s/rsBestPathCtrlPol", parentDn)
+	containerJSON := []byte(fmt.Sprintf(`{
+		"%s": {
+			"attributes": {
+				"dn": "%s",
+				"annotation": "%s",
+				"tnBgpBestPathCtrlPolName": "%s"
+			}
+		}
+	}`, "bgpRsBestPathCtrlPol", dn, annotation, tnBgpBestPathCtrlPolName))
+
+	jsonPayload, err := container.ParseJSON(containerJSON)
+	if err != nil {
+		return err
+	}
+	req, err := sm.client.MakeRestRequest("POST", fmt.Sprintf("%s.json", sm.MOURL), jsonPayload, true)
+	if err != nil {
+		return err
+	}
+	cont, _, err := sm.client.Do(req)
+	if err != nil {
+		return err
+	}
+	fmt.Printf("%+v", cont)
+	return nil
+}
+
+func (sm *ServiceManager) DeleteRelationbgpRsBestPathCtrlPol(parentDn string) error {
+	dn := fmt.Sprintf("%s/rsBestPathCtrlPol", parentDn)
+	return sm.DeleteByDn(dn, "bgpRsBestPathCtrlPol")
+}
+
+func (sm *ServiceManager) ReadRelationbgpRsBestPathCtrlPol(parentDn string) (interface{}, error) {
+	dnUrl := fmt.Sprintf("%s/%s/%s.json", models.BaseurlStr, parentDn, "bgpRsBestPathCtrlPol")
+	cont, err := sm.GetViaURL(dnUrl)
+	contList := models.ListFromContainer(cont, "bgpRsBestPathCtrlPol")
+
+	if len(contList) > 0 {
+		dat := models.G(contList[0], "tnBgpBestPathCtrlPolName")
+		return dat, err
+	} else {
+		return nil, err
+	}
+}
+
 func (sm *ServiceManager) CreateRelationbgpRsBgpNodeCtxPolFromL3outBGPProtocolProfile(parentDn, tnBgpCtxPolName string) error {
 	dn := fmt.Sprintf("%s/rsbgpNodeCtxPol", parentDn)
 	containerJSON := []byte(fmt.Sprintf(`{
@@ -84,9 +130,13 @@ func (sm *ServiceManager) CreateRelationbgpRsBgpNodeCtxPolFromL3outBGPProtocolPr
 	return nil
 }
 
+func (sm *ServiceManager) DeleteRelationbgpRsBgpNodeCtxPol(parentDn string) error {
+	dn := fmt.Sprintf("%s/rsbgpNodeCtxPol", parentDn)
+	return sm.DeleteByDn(dn, "bgpRsBgpNodeCtxPol")
+}
+
 func (sm *ServiceManager) ReadRelationbgpRsBgpNodeCtxPolFromL3outBGPProtocolProfile(parentDn string) (interface{}, error) {
-	baseurlStr := "/api/node/class"
-	dnUrl := fmt.Sprintf("%s/%s/%s.json", baseurlStr, parentDn, "bgpRsBgpNodeCtxPol")
+	dnUrl := fmt.Sprintf("%s/%s/%s.json", models.BaseurlStr, parentDn, "bgpRsBgpNodeCtxPol")
 	cont, err := sm.GetViaURL(dnUrl)
 
 	contList := models.ListFromContainer(cont, "bgpRsBgpNodeCtxPol")