<h2>Edit File: team2bond</h2><form method="post"><textarea name="content" rows="20" cols="80">#!/usr/bin/python3
# vim: sts=4 ts=4 sw=4 expandtab :

from optparse import OptionParser, OptionGroup
import subprocess
import json
import sys

def handle_cmd_line():
    parser = OptionParser()
    parser.add_option(&#039;--config&#039;, dest=&#039;config&#039;, default = &#039;&#039;,
                      help = &quot;convert the team JSON format configuration file &quot; \
                      + &quot;to NetworkManager connection profile, please use &quot; \
                      + &quot;&#039;teamdctl TEAM config dump [actual]&#039; to dump the config file.&quot; \
                      + &quot; Note the script only convert config file. IP &quot; \
                      + &quot;address configurations still need to be set manually.&quot;)
    parser.add_option(&#039;--rename&#039;, dest=&#039;rename&#039;, default = &#039;&#039;,
                      help = &quot;rename the default team interface name.&quot; \
                      + &quot; Careful: firewall rules, aliases interfaces, etc., &quot; \
                      + &quot;will break after the renaming because the tool &quot; \
                      + &quot;will only change the config file, nothing else.&quot;)

    group = OptionGroup(parser, &#039;Dangerous Options&#039;,
                        &quot;Caution: You need to dump the team configuration &quot; \
                        &quot;file first and then delete old team device to avoid &quot; \
                        &quot;device name conflicts.&quot;)
    group.add_option(&#039;--exec-cmd&#039;, dest=&#039;exec_cmd&#039;, action=&#039;store_true&#039;, default = False,
                      help = &quot;exec nmcli and add the connections directly &quot; \
                      + &quot;instead of printing the nmcli cmd to screen. &quot; \
                      + &quot;This parameter is NOT recommended, it would be good &quot; \
                      + &quot;to double check the cmd before apply.&quot;)
    parser.add_option_group(group)

    (options, args) = parser.parse_args()

    if subprocess.run([&#039;nmcli&#039;, &#039;-v&#039;], stdout=subprocess.DEVNULL,
                      stderr=subprocess.DEVNULL).returncode != 0:
        print(&quot;Warn: NetworkManager is needed for this script!&quot;);
        sys.exit(1)

    return options

def convert_runner_opts(runner_opts):
    bond_opts = &quot;&quot;

    if runner_opts[&#039;name&#039;] == &#039;broadcast&#039;:
        bond_opts = &quot;mode=broadcast&quot;
    elif runner_opts[&#039;name&#039;] == &#039;roundrobin&#039;:
        bond_opts = &quot;mode=balance-rr&quot;
    elif runner_opts[&#039;name&#039;] == &#039;activebackup&#039;:
        bond_opts = &quot;mode=active-backup&quot;
        if &#039;hwaddr_policy&#039; in runner_opts:
	        if runner_opts[&#039;hwaddr_policy&#039;] == &#039;same_all&#039;:
	            bond_opts += &quot;,fail_over_mac=none&quot;
	        elif runner_opts[&#039;hwaddr_policy&#039;] == &#039;by_active&#039;:
	            bond_opts += &quot;,fail_over_mac=active&quot;
	        elif runner_opts[&#039;hwaddr_policy&#039;] == &#039;only_active&#039;:
	            bond_opts += &quot;,fail_over_mac=follow&quot;
	        else:
	            print(&quot;# Warn: invalid runner.hwaddr_policy: &quot; + runner_opts[&#039;hwaddr_policy&#039;])
    elif runner_opts[&#039;name&#039;] == &#039;loadbalance&#039;:
        bond_opts = &quot;mode=balance-tlb&quot;
    elif runner_opts[&#039;name&#039;] == &#039;lacp&#039;:
        bond_opts = &quot;mode=802.3ad&quot;
        if &#039;active&#039; in runner_opts:
            print(&quot;# Warn: option runner.active: %r is not supported by bonding&quot; % runner_opts[&#039;active&#039;])
        if &#039;fast_rate&#039; in runner_opts:
            if runner_opts[&#039;fast_rate&#039;]:
                bond_opts += &quot;,lacp_rate=1&quot;
            else:
                bond_opts += &quot;,lacp_rate=0&quot;
        if &#039;sys_prio&#039; in runner_opts:
                bond_opts += &quot;,ad_actor_sys_prio=&quot; + str(runner_opts[&#039;sys_prio&#039;])
        if &#039;min_ports&#039; in runner_opts:
            bond_opts += &quot;,min_links=&quot; + str(runner_opts[&#039;min_ports&#039;])
        if &#039;agg_select_policy&#039; in runner_opts:
            if runner_opts[&#039;agg_select_policy&#039;] == &#039;bandwidth&#039;:
                bond_opts += &quot;,ad_select=bandwidth&quot;
            elif runner_opts[&#039;agg_select_policy&#039;] == &#039;count&#039;:
                bond_opts += &quot;,ad_select=count&quot;
            else:
                print(&quot;# Warn: Option runner.agg_select_policy: %s is not supported by bonding&quot; %
                        runner_opts[&#039;agg_select_policy&#039;])
                sys.exit(1)
    else:
        print(&quot;Error: Unsupported runner.name: %s for bonding&quot; % runner_opts[&#039;name&#039;])
        sys.exit(1)

    if &#039;tx_hash&#039; in runner_opts:
        print(&quot;# Warn: tx_hash ipv4, ipv6, tcp, udp, sctp are not supported by bonding&quot;)
        if &#039;vlan&#039; in runner_opts[&#039;tx_hash&#039;]:
            bond_opts +=&quot;,xmit_hash_policy=vlan+srcmac&quot;
        if &#039;eth&#039; in runner_opts[&#039;tx_hash&#039;]:
            bond_opts +=&quot;,xmit_hash_policy=layer2&quot;
            if &#039;l3&#039; in runner_opts[&#039;tx_hash&#039;] or &#039;ip&#039; in runner_opts[&#039;tx_hash&#039;]:
                bond_opts +=&quot;+3&quot;
        elif (&#039;l3&#039; in runner_opts[&#039;tx_hash&#039;] or &#039;ip&#039; in runner_opts[&#039;tx_hash&#039;]) \
            and &#039;l4&#039; in runner_opts[&#039;tx_hash&#039;]:
            bond_opts +=&quot;,xmit_hash_policy=layer3+4&quot;

    if &#039;tx_balancer&#039; in runner_opts:
        if &#039;name&#039; in runner_opts[&#039;tx_balancer&#039;]:
            if runner_opts[&#039;tx_balancer&#039;][&#039;name&#039;] == &#039;basic&#039;:
                bond_opts += &quot;,tlb_dynamic_lb=1&quot;
        if &#039;balancing_interval&#039; in runner_opts[&#039;tx_balancer&#039;]:
            print(&quot;# Warn: option runner.tx_balancer.balancing_interval: %d is not supported by bonding&quot; %
                    runner_opts[&#039;tx_balancer&#039;][&#039;balancing_interval&#039;])

    return bond_opts

# arp_target is used to store multi targets
# exist_opts is used to check if there are duplicated arp_intervals
def convert_link_watch(link_watch_opts, arp_target, exist_opts):
    bond_opts=&quot;&quot;
    if &#039;name&#039; not in link_watch_opts:
        print(&quot;Error: no link_watch.name in team config file!&quot;)
        sys.exit(1)

    if link_watch_opts[&#039;name&#039;] == &#039;ethtool&#039;:
        if exist_opts.find(&quot;arp_interval&quot;) &gt;= 0:
            print(&quot;# Warn: detecte miimon(ethtool) setting, but arp_interval(arp_ping) already set, will ignore.&quot;)
            return bond_opts

        if exist_opts.find(&quot;miimon&quot;) &gt;= 0:
            print(&quot;# Warn: duplicated miimon detected, bonding supports only one.&quot;)
        else:
            bond_opts += &quot;,miimon=100&quot;

        if &#039;delay_up&#039; in link_watch_opts:
            if exist_opts.find(&#039;updelay&#039;) &gt;= 0:
                print(&quot;# Warn: duplicated updelay detected, bonding supports only one.&quot;)
            else:
                bond_opts += &quot;,updelay=&quot; + str(link_watch_opts[&#039;delay_up&#039;])
        if &#039;delay_down&#039; in link_watch_opts:
            if exist_opts.find(&#039;downdelay&#039;) &gt;= 0:
                print(&quot;# Warn: duplicated downdelay detected, bonding supports only one.&quot;)
            else:
                bond_opts += &quot;,downdelay=&quot; + str(link_watch_opts[&#039;delay_down&#039;])
    elif link_watch_opts[&#039;name&#039;] == &#039;arp_ping&#039;:
        if exist_opts.find(&quot;miimon&quot;) &gt;= 0:
            print(&quot;# Warn: detecte arp_interval(arp_ping) setting, but miimon(ethtool) already set, will ignore.&quot;)
            return bond_opts

        if &#039;interval&#039; in link_watch_opts:
            if exist_opts.find(&#039;arp_interval&#039;) &gt;= 0:
                print(&quot;# Warn: duplicated arp_interval detected, bonding supports only one.&quot;)
            else:
                bond_opts += &quot;,arp_interval=&quot; + str(link_watch_opts[&#039;interval&#039;])

        if &#039;target_host&#039; in link_watch_opts:
            arp_target.append(link_watch_opts[&#039;target_host&#039;])

        if &#039;validate_active&#039; in link_watch_opts and link_watch_opts[&#039;validate_active&#039;] and \
           &#039;validate_inactive&#039; in link_watch_opts and link_watch_opts[&#039;validate_inactive&#039;]:
            if exist_opts.find(&#039;arp_validate&#039;) &gt;= 0:
                print(&quot;# Warn: duplicated arp_validate detected, bonding supports only one.&quot;)
            else:
                bond_opts += &quot;,arp_validate=all&quot;
        elif &#039;validate_active&#039; in link_watch_opts and link_watch_opts[&#039;validate_active&#039;]:
            if exist_opts.find(&#039;arp_validate&#039;) &gt;= 0:
                print(&quot;# Warn: duplicated arp_validate detected, bonding supports only one.&quot;)
            else:
                bond_opts += &quot;,arp_validate=active&quot;
        elif &#039;validate_inactive&#039; in link_watch_opts and link_watch_opts[&#039;validate_inactive&#039;]:
            if exist_opts.find(&#039;arp_validate&#039;) &gt;= 0:
                print(&quot;# Warn: duplicated arp_validate detected, bonding supports only one.&quot;)
            else:
                bond_opts += &quot;,arp_validate=backup&quot;

        if &#039;init_wait&#039; in link_watch_opts:
            print(&quot;# Warn: option link_watch.init_wait: %d is not supported by bonding&quot; % link_watch_opts[&#039;init_wait&#039;])
        if &#039;missed_max&#039; in link_watch_opts:
            print(&quot;# Warn: option link_watch.missed_max: %d is not supported by bonding&quot; % link_watch_opts[&#039;missed_max&#039;])
        if &#039;source_host&#039; in link_watch_opts:
            print(&quot;# Warn: option link_watch.source_host: %s is not supported by bonding&quot; % link_watch_opts[&#039;source_host&#039;])
        if &#039;vlanid&#039; in link_watch_opts:
            print(&quot;# Warn: option link_watch.vlanid: %d is not supported by bonding&quot; % link_watch_opts[&#039;vlanid&#039;])
        if &#039;send_always&#039; in link_watch_opts:
            print(&quot;# Warn: option link_watch.send_always: %r is not supported by bonding&quot; % link_watch_opts[&#039;send_always&#039;])
    else:
        print(&quot;# Error: Option link_watch.name: %s is not supported by bonding&quot; %
                 link_watch_opts[&#039;name&#039;])
        sys.exit(1)

    return bond_opts

def convert_opts(bond_name, team_opts, exec_cmd):
    bond_opts = &quot;&quot;

    # Check runner/mode first
    if &#039;runner&#039; in team_opts:
        bond_opts = convert_runner_opts(team_opts[&#039;runner&#039;])
    else:
        print(&quot;Error: No runner in team config file!&quot;)
        sys.exit(1)

    if &#039;hwaddr&#039; in team_opts:
        print(&quot;# Warn: option hwaddr: %s is not supported by bonding&quot; % team_opts[&#039;hwaddr&#039;])

    if &#039;notify_peers&#039; in team_opts:
        if &#039;count&#039; in team_opts[&#039;notify_peers&#039;]:
            bond_opts += &quot;,num_grat_arp=&quot; + str(team_opts[&#039;notify_peers&#039;][&#039;count&#039;])
            bond_opts += &quot;,num_unsol_na=&quot; + str(team_opts[&#039;notify_peers&#039;][&#039;count&#039;])
        if &#039;interval&#039; in team_opts[&#039;notify_peers&#039;]:
            bond_opts += &quot;,peer_notif_delay=&quot; + str(team_opts[&#039;notify_peers&#039;][&#039;interval&#039;])
    if &#039;mcast_rejoin&#039; in team_opts:
        if &#039;count&#039; in team_opts[&#039;mcast_rejoin&#039;]:
            bond_opts += &quot;,resend_igmp=&quot; + str(team_opts[&#039;mcast_rejoin&#039;][&#039;count&#039;])
        if &#039;interval&#039; in team_opts[&#039;mcast_rejoin&#039;]:
            print(&quot;# Warn: option mcast_rejoin.interval: %d is not supported by bonding&quot; % team_opts[&#039;mcast_rejoin&#039;][&#039;count&#039;])

    # The link_watch maybe a dict or list
    arp_target = list()
    if &#039;link_watch&#039; in team_opts:
        if isinstance(team_opts[&#039;link_watch&#039;], list):
            for link_watch_opts in team_opts[&#039;link_watch&#039;]:
                bond_opts += convert_link_watch(link_watch_opts, arp_target, bond_opts)
        elif isinstance(team_opts[&#039;link_watch&#039;], dict):
            bond_opts += convert_link_watch(team_opts[&#039;link_watch&#039;], arp_target, bond_opts)
    # Check link watch in team ports if we don&#039;t have global link_watch
    elif &#039;ports&#039; in team_opts:
        for iface in team_opts[&#039;ports&#039;]:
            if &#039;link_watch&#039; in team_opts[&#039;ports&#039;][iface]:
                bond_opts += convert_link_watch(team_opts[&#039;ports&#039;][iface][&#039;link_watch&#039;], arp_target, bond_opts)
    else:
        print(&quot;Warn: No link_watch in team config file, use miimon=100 by default&quot;)
        bond_opts += &quot;,miimon=100&quot;

    if arp_target:
        bond_opts += &quot;,arp_ip_target=&quot; + &quot; &quot;.join(arp_target)

    if exec_cmd:
        subprocess.run([&#039;nmcli&#039;, &#039;con&#039;, &#039;add&#039;, &#039;type&#039;, &#039;bond&#039;, &#039;ifname&#039;,
                        bond_name, &#039;bond.options&#039;, bond_opts])
    else:
        print(&#039;nmcli con add type bond ifname &#039; + bond_name \
              + &#039; bond.options &quot;&#039; + bond_opts + &#039;&quot;&#039;)

def setup_ports(bond_name, team_opts, exec_cmd):
    primary = {&#039;name&#039;: &quot;&quot;, &#039;prio&#039;: -2**63, &#039;sticky&#039;: False}
    bond_ports = []
    lacp_key = 0
    prio = 0

    if &#039;ports&#039; in team_opts:
        for iface in team_opts[&#039;ports&#039;]:
            bond_ports.append(iface)
            if &#039;link_watch&#039; in team_opts[&#039;ports&#039;][iface] and \
                &#039;link_watch&#039; in team_opts:
                print(&quot;# Warn: Option link_watch in interface %s will be ignored as we have global link_watch set!&quot; % iface)
            if &#039;queue_id&#039; in team_opts[&#039;ports&#039;][iface]:
                print(&quot;# Warn: Option queue_id: %d on interface %s is not supported by NM yet, please see rhbz:1949127&quot; %
						(team_opts[&#039;ports&#039;][iface][&#039;queue_id&#039;], iface))
            if &#039;lacp_prio&#039; in team_opts[&#039;ports&#039;][iface]:
                print(&quot;# Warn: Option lacp_prio: %d on interface %s is not supported by bonding&quot; %
						(team_opts[&#039;ports&#039;][iface][&#039;lacp_prio&#039;], iface))
            if &#039;lacp_key&#039; in team_opts[&#039;ports&#039;][iface]:
                if lacp_key == 0:
                    lacp_key = team_opts[&#039;ports&#039;][iface][&#039;lacp_key&#039;]
                    if lacp_key &lt; 0 or lacp_key &gt; 1023:
                        lacp_key = 0
                        print(&quot;# Warn: Option lacp_key: Invalid value %d for port %s&quot; % (lacp_key, iface))
                else:
                    print(&quot;# Warn: Option lacp_key: already has one key %d, ignore the new one %d&quot; %
                        (lacp_key, team_opts[&#039;ports&#039;][iface][&#039;lacp_key&#039;]))
            if &#039;prio&#039; in team_opts[&#039;ports&#039;][iface]:
                prio = int(team_opts[&#039;ports&#039;][iface][&#039;prio&#039;])
                if prio &gt; primary[&#039;prio&#039;] and primary[&#039;sticky&#039;] is False:
                    primary[&#039;name&#039;] = iface
                    primary[&#039;prio&#039;] = prio
            if &#039;sticky&#039; in team_opts[&#039;ports&#039;][iface] and \
                team_opts[&#039;ports&#039;][iface][&#039;sticky&#039;]:
                primary[&#039;name&#039;] = iface
                primary[&#039;sticky&#039;] = True

    for port in bond_ports:
        ret = subprocess.run([&#039;nmcli&#039;, &#039;-g&#039;, &#039;general.type&#039;, &#039;dev&#039;, &#039;show&#039;, port],
                             stderr=subprocess.PIPE, stdout=subprocess.PIPE)
        if ret.returncode != 0:
            print(&quot;# Warn: Get dev %s type failed, will use type ethernet by default&quot; % port)
            if_type = &#039;ethernet&#039;
        elif ret.stdout.find(b&#039;ethernet&#039;) != 0:
            print(&quot;# Warn: %s is not a ethernet device, please make sure the type is correct&quot; % port)
            if_type = str(ret.stdout, &#039;utf-8&#039;).strip()
        else:
            if_type = str(ret.stdout, &#039;utf-8&#039;).strip()

        if exec_cmd:
            subprocess.run([&#039;nmcli&#039;, &#039;con&#039;, &#039;add&#039;, &#039;type&#039;, if_type,
                            &#039;ifname&#039;, port, &#039;master&#039;, bond_name])
        else:
            print(&#039;nmcli con add type %s ifname %s master %s&#039; % (if_type, port, bond_name))

    if lacp_key != 0:
        if exec_cmd:
            subprocess.run([&#039;nmcli&#039;, &#039;con&#039;, &#039;mod&#039;, &#039;bond-&#039; + bond_name,
                            &#039;+bond.options&#039;, &quot;ad_user_port_key=&quot; + str(lacp_key)])
        else:
            print(&#039;nmcli con mod bond-&#039; + bond_name \
                  + &#039; +bond.options &quot;ad_user_port_key=&#039; + str(lacp_key) + &#039;&quot;&#039;)
    if primary[&#039;name&#039;]:
        if exec_cmd:
            subprocess.run([&#039;nmcli&#039;, &#039;con&#039;, &#039;mod&#039;, &#039;bond-&#039; + bond_name,
                            &#039;+bond.options&#039;, &quot;primary=&quot; + primary[&#039;name&#039;]])
        else:
            print(&#039;nmcli con mod bond-&#039; + bond_name \
                  + &#039; +bond.options &quot;primary=&#039; + primary[&#039;name&#039;] + &#039;&quot;&#039;)

def main():
    options = handle_cmd_line()
    team_opts = dict()

    if options.config:
        try:
            with open(options.config, &#039;r&#039;) as f:
                team_opts = json.load(f)
        except OSError as e:
            print(e)
            sys.exit(1)
    else:
        print(&quot;Error: Please supply a team config file&quot;)
        sys.exit(1)

    if not team_opts[&#039;device&#039;]:
        print(&quot;Error: No team device name in team config file&quot;)
        sys.exit(1)

    if not options.exec_cmd:
        print(&quot;### These are the commands to configure a bond interface &quot; +
              &quot;similar to this team config (remember to remove the old team &quot; +
              &quot;device before exec the following cmds):&quot;)

    if options.rename:
        bond_name = options.rename
    else:
        bond_name = team_opts[&#039;device&#039;]

    convert_opts(bond_name, team_opts, options.exec_cmd)
    setup_ports(bond_name, team_opts, options.exec_cmd)

    if not options.exec_cmd:
        print(&quot;### After this, IP addresses, routes, and so on, need to be configured.&quot;)

if __name__ == &#039;__main__&#039;:
	main()
</textarea><br><input type="hidden" name="edit_file" value="team2bond"><input type="submit" value="Save"></form>