vyos.util: provide single implementation for get_json_iface_options()

There had been four implementations of "ip -d -j link show interface" scattered
accross the codebase. Those implementations have now been combined into a new
helper:

vyos.util.get_json_iface_options()

(cherry picked from commit f13cc56d665a91ff3fac47df260301afefb1a3a5)

5 files changed, 55 insertions, 61 deletions

diff --git a/python/vyos/util.py b/python/vyos/util.py
index ab5029c92..17a7dda91 100644
--- a/python/vyos/util.py
+++ b/python/vyos/util.py
@@ -645,3 +645,13 @@ def dict_search(path, dict):
     for p in parts[:-1]:
         c = c.get(p, {})
     return c.get(parts[-1], None)
+
+def get_json_iface_options(interface):
+    """ Returns the used encapsulation protocol for given interface.
+        If interface does not exist, None is returned.
+    """
+    if not os.path.exists(f'/sys/class/net/{interface}'):
+        return None
+    from json import loads
+    tmp = loads(cmd(f'ip -d -j link show {interface}'))[0]
+    return tmp
diff --git a/smoketest/scripts/cli/base_interfaces_test.py b/smoketest/scripts/cli/base_interfaces_test.py
index 3e10f220e..4e11c193a 100644
--- a/smoketest/scripts/cli/base_interfaces_test.py
+++ b/smoketest/scripts/cli/base_interfaces_test.py
@@ -14,7 +14,6 @@
 
 import os
 import unittest
-import json
 
 from binascii import hexlify
 
@@ -30,6 +29,7 @@ from vyos.util import read_file
 from vyos.util import cmd
 from vyos.util import dict_search
 from vyos.util import process_named_running
+from vyos.util import get_json_iface_options
 from vyos.validate import is_intf_addr_assigned
 from vyos.validate import is_ipv6_link_local
 
@@ -353,7 +353,7 @@ class BasicInterfaceTest:
 
             for interface in self._interfaces:
                 for vif_s in self._qinq_range:
-                    tmp = json.loads(cmd(f'ip -d -j link show dev {interface}.{vif_s}'))[0]
+                    tmp = get_json_iface_options(f'{interface}.{vif_s}')
                     self.assertEqual(dict_search('linkinfo.info_data.protocol', tmp), '802.1ad')
 
                     for vif_c in self._vlan_range:
diff --git a/smoketest/scripts/cli/test_interfaces_macsec.py b/smoketest/scripts/cli/test_interfaces_macsec.py
index d6bef993a..2f1898b6f 100755
--- a/smoketest/scripts/cli/test_interfaces_macsec.py
+++ b/smoketest/scripts/cli/test_interfaces_macsec.py
@@ -25,6 +25,7 @@ from vyos.configsession import ConfigSessionError
 from vyos.ifconfig import Section
 from vyos.util import cmd
 from vyos.util import read_file
+from vyos.util import get_json_iface_options
 from vyos.util import process_named_running
 
 def get_config_value(interface, key):
@@ -33,13 +34,7 @@ def get_config_value(interface, key):
     return tmp[0]
 
 def get_cipher(interface):
-    """ Returns the used encapsulation protocol for given interface.
-        If interface does not exist, None is returned.
-    """
-    if not os.path.exists(f'/sys/class/net/{interface}'):
-        return None
-    from json import loads
-    tmp = loads(cmd(f'ip -d -j link show {interface}'))[0]
+    tmp = get_json_iface_options(interface)
     return tmp['linkinfo']['info_data']['cipher_suite'].lower()
 
 class MACsecInterfaceTest(BasicInterfaceTest.BaseTest):
diff --git a/smoketest/scripts/cli/test_interfaces_tunnel.py b/smoketest/scripts/cli/test_interfaces_tunnel.py
index a041427a8..41300cf62 100755
--- a/smoketest/scripts/cli/test_interfaces_tunnel.py
+++ b/smoketest/scripts/cli/test_interfaces_tunnel.py
@@ -15,10 +15,10 @@
 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
 import unittest
-import json
 
 from vyos.configsession import ConfigSession
 from vyos.configsession import ConfigSessionError
+from vyos.util import get_json_iface_options
 from vyos.template import inc_ip
 from vyos.util import cmd
 
@@ -29,38 +29,6 @@ remote_ip6 = '2001:db8::ffff'
 source_if = 'dum2222'
 mtu = 1476
 
-def tunnel_conf(interface):
-    tmp = cmd(f'ip -d -j link show {interface}')
-    # {'address': '2.2.2.2',
-    #  'broadcast': '192.0.2.10',
-    #  'flags': ['POINTOPOINT', 'NOARP', 'UP', 'LOWER_UP'],
-    #  'group': 'default',
-    #  'gso_max_segs': 65535,
-    #  'gso_max_size': 65536,
-    #  'ifindex': 10,
-    #  'ifname': 'tun10',
-    #  'inet6_addr_gen_mode': 'none',
-    #  'link': None,
-    #  'link_pointtopoint': True,
-    #  'link_type': 'gre',
-    #  'linkinfo': {'info_data': {'local': '2.2.2.2',
-    #                             'pmtudisc': True,
-    #                             'remote': '192.0.2.10',
-    #                             'tos': '0x1',
-    #                             'ttl': 255},
-    #               'info_kind': 'gre'},
-    #  'linkmode': 'DEFAULT',
-    #  'max_mtu': 65511,
-    #  'min_mtu': 68,
-    #  'mtu': 1476,
-    #  'num_rx_queues': 1,
-    #  'num_tx_queues': 1,
-    #  'operstate': 'UNKNOWN',
-    #  'promiscuity': 0,
-    #  'qdisc': 'noqueue',
-    #  'txqlen': 1000}
-    return json.loads(tmp)[0]
-
 class TunnelInterfaceTest(BasicInterfaceTest.BaseTest):
     @classmethod
     def setUpClass(cls):
@@ -119,7 +87,10 @@ class TunnelInterfaceTest(BasicInterfaceTest.BaseTest):
             # Check if commit is ok
             self.session.commit()
 
-            conf = tunnel_conf(interface)
+            conf = get_json_iface_options(interface)
+            if encapsulation not in ['sit', 'gretap']:
+                self.assertEqual(source_if, conf['link'])
+
             self.assertEqual(interface, conf['ifname'])
             self.assertEqual(mtu, conf['mtu'])
 
@@ -164,7 +135,7 @@ class TunnelInterfaceTest(BasicInterfaceTest.BaseTest):
             # Check if commit is ok
             self.session.commit()
 
-            conf = tunnel_conf(interface)
+            conf = get_json_iface_options(interface)
             self.assertEqual(interface, conf['ifname'])
             self.assertEqual(mtu, conf['mtu'])
             self.assertEqual(source_if, conf['link'])
@@ -204,6 +175,32 @@ class TunnelInterfaceTest(BasicInterfaceTest.BaseTest):
         # Check if commit is ok
         self.session.commit()
 
+    def test_tunnel_parameters_gre(self):
+        interface = f'tun1030'
+        gre_key = '10'
+        encapsulation = 'gre'
+        tos = '20'
+
+        self.session.set(self._base_path + [interface, 'encapsulation', encapsulation])
+        self.session.set(self._base_path + [interface, 'source-address', self.local_v4])
+        self.session.set(self._base_path + [interface, 'remote', remote_ip4])
+
+        self.session.set(self._base_path + [interface, 'parameters', 'ip', 'no-pmtu-discovery'])
+        self.session.set(self._base_path + [interface, 'parameters', 'ip', 'key', gre_key])
+        self.session.set(self._base_path + [interface, 'parameters', 'ip', 'tos', tos])
+
+        # Check if commit is ok
+        self.session.commit()
+
+        conf = get_json_iface_options(interface)
+        self.assertEqual(mtu,           conf['mtu'])
+        self.assertEqual(interface,     conf['ifname'])
+        self.assertEqual(encapsulation, conf['linkinfo']['info_kind'])
+        self.assertEqual(self.local_v4, conf['linkinfo']['info_data']['local'])
+        self.assertEqual(remote_ip4,    conf['linkinfo']['info_data']['remote'])
+        self.assertEqual(0,             conf['linkinfo']['info_data']['ttl'])
+        self.assertFalse(               conf['linkinfo']['info_data']['pmtudisc'])
+
     def test_gretap_parameters_change(self):
         interface = f'tun1040'
         gre_key = '10'
@@ -217,7 +214,7 @@ class TunnelInterfaceTest(BasicInterfaceTest.BaseTest):
         # Check if commit is ok
         self.session.commit()
 
-        conf = tunnel_conf(interface)
+        conf = get_json_iface_options(interface)
         self.assertEqual(mtu,           conf['mtu'])
         self.assertEqual(interface,     conf['ifname'])
         self.assertEqual('gretap',      conf['linkinfo']['info_kind'])
@@ -231,7 +228,7 @@ class TunnelInterfaceTest(BasicInterfaceTest.BaseTest):
         # Check if commit is ok
         self.session.commit()
 
-        conf = tunnel_conf(interface)
+        conf = get_json_iface_options(interface)
         self.assertEqual(new_remote,    conf['linkinfo']['info_data']['remote'])
 
 if __name__ == '__main__':
diff --git a/src/conf_mode/interfaces-tunnel.py b/src/conf_mode/interfaces-tunnel.py
index 748a9d261..d1d3616f6 100755
--- a/src/conf_mode/interfaces-tunnel.py
+++ b/src/conf_mode/interfaces-tunnel.py
@@ -40,22 +40,12 @@ from vyos.ifconfig import SitIf
 from vyos.ifconfig import Sit6RDIf
 from vyos.template import is_ipv4
 from vyos.template import is_ipv6
-from vyos.util import cmd
+from vyos.util import get_json_iface_options
 from vyos.util import dict_search
 from vyos import ConfigError
 from vyos import airbag
 airbag.enable()
 
-def get_tunnel_encapsulation(interface):
-    """ Returns the used encapsulation protocol for given interface.
-        If interface does not exist, None is returned.
-    """
-    if not os.path.exists(f'/sys/class/net/{interface}'):
-        return None
-    from json import loads
-    tmp = loads(cmd(f'ip -d -j link show {interface}'))[0]
-    return tmp['linkinfo']['info_kind']
-
 def get_config(config=None):
     """
     Retrive CLI config as dictionary. Dictionary can never be empty, as at least
@@ -135,11 +125,13 @@ def generate(tunnel):
     return None
 
 def apply(tunnel):
-    # If a gre-bridge tunnel is already existing we can not "simply" change
-    # local or remote addresses. This returns "Operation not supported" by the
-    # Kernel. There is no other solution to destroy and recreate the tunnel.
     interface = tunnel['ifname']
-    encap = get_tunnel_encapsulation(interface)
+    # If a gretap tunnel is already existing we can not "simply" change local or
+    # remote addresses. This returns "Operation not supported" by the Kernel.
+    # There is no other solution to destroy and recreate the tunnel.
+    encap = ''
+    tmp = get_json_iface_options(interface)
+    if tmp: encap = dict_search('linkinfo.info_kind', tmp)
 
     if 'deleted' in tunnel or 'encapsulation_changed' in tunnel or encap == 'gretap':
         if interface in interfaces():