Function updateAgent

cli/ctl/agent.go:301–402

(cmd *cobra.Command, args []string, updateFilename string)

}

func updateAgent(cmd *cobra.Command, args []string, updateFilename string) {
	yamlFile, err := os.ReadFile(updateFilename)
	if err != nil {
		fmt.Fprintln(os.Stderr, err)
		return
	}

	updateMap := make(map[string]interface{})
	err = yaml.Unmarshal(yamlFile, &updateMap)
	if err != nil {
		fmt.Fprintln(os.Stderr, err)
		return
	}

	vtapName, ok := updateMap["name"]
	if !ok {
		fmt.Fprintln(os.Stderr, "must specify agent name")
		return
	}

	server := common.GetServerInfo(cmd)
	url := fmt.Sprintf("http://%s:%d/v1/vtaps/?name=%s", server.IP, server.Port, vtapName)
	// call vtap api, get lcuuid
	response, err := common.CURLPerform("GET", url, nil, "",
		[]common.HTTPOption{common.WithTimeout(common.GetTimeout(cmd)), common.WithORGID(common.GetORGID(cmd))}...)
	if err != nil {
		fmt.Fprintln(os.Stderr, err)
		return
	}

	if len(response.Get("DATA").MustArray()) == 0 {
		fmt.Fprintln(os.Stderr, "agent (%s) not exist\n")
	}
	vtap := response.Get("DATA").GetIndex(0)
	lcuuid := vtap.Get("LCUUID").MustString()

	// modify tap_mode
	if tapMode, ok := updateMap["tap_mode"]; ok {
		url = fmt.Sprintf("http://%s:%d/v1/vtaps-tap-mode/", server.IP, server.Port)
		updateBody := make(map[string]interface{})
		updateBody["VTAP_LCUUIDS"] = []string{lcuuid}
		updateBody["TAP_MODE"] = common.GetVtapTapModeByName(tapMode.(string))

		updateJson, _ := json.Marshal(updateBody)
		_, err := common.CURLPerform("PATCH", url, nil, string(updateJson),
			[]common.HTTPOption{common.WithTimeout(common.GetTimeout(cmd)), common.WithORGID(common.GetORGID(cmd))}...)
		if err != nil {
			fmt.Fprintln(os.Stderr, err)
			return
		}
		delete(updateMap, "tap_mode")
	}

	// return if only update tap_mode
	if len(updateMap) == 0 {
		return
	}