Function syncFirewallClientPortWhiteList

agent/app/service/firewall_setting.go:141–163

(client firewall.FirewallClient, oldPortWhiteList, portWhiteList []firewallPortWhitelist)

}

func syncFirewallClientPortWhiteList(client firewall.FirewallClient, oldPortWhiteList, portWhiteList []firewallPortWhitelist) error {
	oldPorts := firewallPortWhiteListMap(oldPortWhiteList)
	newPorts := firewallPortWhiteListMap(portWhiteList)
	for _, item := range oldPortWhiteList {
		key := firewallPortWhiteListKey(item)
		if _, ok := newPorts[key]; ok {
			continue
		}
		if err := client.Port(fireClient.FireInfo{Port: item.Port, Protocol: item.Protocol, Strategy: "accept"}, "remove"); err != nil {
			return err
		}
	}
	for _, item := range portWhiteList {
		key := firewallPortWhiteListKey(item)
		if _, ok := oldPorts[key]; ok {
			continue
		}
		if err := client.Port(fireClient.FireInfo{Port: item.Port, Protocol: item.Protocol, Strategy: "accept"}, "add"); err != nil {
			return err
		}
	}
	return client.Reload()
}

func firewallPortWhiteListMap(portWhiteList []firewallPortWhitelist) map[string]struct{} {
	ports := make(map[string]struct{})