replace sbctl operate chassis

pkg/controller/external-gw.go

@@ -249,15 +249,13 @@ func (c *Controller) getGatewayChassis(config map[string]string) ([]string, erro
 			klog.Errorf("patch external gw node %s failed %v", gw, err)
 			return chassises, err
 		}
-		chassisID, err := c.ovnLegacyClient.GetChassis(gw)
+		chassis, err := c.ovnSbClient.GetChassisByNode(gw)
 		if err != nil {
-			klog.Errorf("failed to get external gw %s chassisID, %v", gw, err)
+			klog.Errorf("failed to get chassis by node name: %s, %v", gw, err)
 			return chassises, err
 		}
-		if chassisID == "" {
-			return chassises, fmt.Errorf("no chassisID for external gw %s", gw)
-		}
-		chassises = append(chassises, chassisID)
+
+		chassises = append(chassises, chassis.UUID)
 	}
 	if len(chassises) == 0 {
 		klog.Error("no available external gw")

pkg/controller/gc.go

@@ -667,7 +667,7 @@ func (c *Controller) gcStaticRoute() error {
 
 func (c *Controller) gcChassis() error {
 	klog.Infof("start to gc chassis")
-	chassises, err := c.ovnLegacyClient.GetAllChassis()
+	chassises, err := c.ovnSbClient.GetKubeOvnChassisses()
 	if err != nil {
 		klog.Errorf("failed to get all chassis, %v", err)
 	}
@@ -676,16 +676,16 @@ func (c *Controller) gcChassis() error {
 		klog.Errorf("failed to list nodes, %v", err)
 		return err
 	}
-	for _, chassis := range chassises {
+	for _, chassis := range *chassises {
 		matched := true
 		for _, node := range nodes {
-			if chassis == node.Annotations[util.ChassisAnnotation] {
+			if chassis.Name == node.Annotations[util.ChassisAnnotation] {
 				matched = false
 				break
 			}
 		}
 		if matched {
-			if err := c.ovnLegacyClient.DeleteChassisByName(chassis); err != nil {
+			if err := c.ovnSbClient.DeleteChassis(chassis.Name); err != nil {
 				klog.Errorf("failed to delete chassis %s %v", chassis, err)
 				return err
 			}

pkg/controller/init.go

@@ -855,11 +855,15 @@ func (c *Controller) initNodeChassis() error {
 		klog.Errorf("failed to list nodes: %v", err)
 		return err
 	}
-	chssisNodes, err := c.ovnLegacyClient.GetAllChassisMap()
+	chssises, err := c.ovnSbClient.GetKubeOvnChassisses()
 	if err != nil {
 		klog.Errorf("failed to get chassis nodes: %v", err)
 		return err
 	}
+	chssisNodes := make(map[string]string, len(*chssises))
+	for _, chssis := range *chssises {
+		chssisNodes[chssis.Name] = chssis.Hostname
+	}
 	for _, node := range nodes {
 		chassisName := node.Annotations[util.ChassisAnnotation]
 		if chassisName != "" {
@@ -868,7 +872,7 @@ func (c *Controller) initNodeChassis() error {
 					continue
 				} else {
 					klog.Infof("node %s sbdb chassis %s host name %s", node.Name, chassisName, hostname)
-					err = c.ovnLegacyClient.InitChassisNodeTag(chassisName, node.Name)
+					err = c.ovnSbClient.InitChassisNodeTag(chassisName, node.Name)
 					if err != nil {
 						klog.Errorf("failed to set chassis nodeTag: %v", err)
 						return err