Issue #783 - Adding sys/sflow endpoints (#1296)

* Issue #783 - Adding sys/sflow endpoints

Files Added
- sys/sflow.py
- sys/test/functional/test_sflow.py
- sys/test/unit/test_sflow.py

Files Changed
- sys/__init__.py

* Issue #783 - python 3.x compatibility fix in unit test

Author: f5-rahm

f5/bigip/tm/sys/__init__.py

@@ -45,6 +45,7 @@
 from f5.bigip.tm.sys.ntp import Ntp
 from f5.bigip.tm.sys.performance import Performances
 from f5.bigip.tm.sys.provision import Provision
+from f5.bigip.tm.sys.sflow import Sflow
 from f5.bigip.tm.sys.snmp import Snmp
 from f5.bigip.tm.sys.software import Software
 from f5.bigip.tm.sys.sshd import Sshd
@@ -73,6 +74,7 @@ def __init__(self, tm):
             Ntp,
             Performances,
             Provision,
+            Sflow,
             Snmp,
             Software,
             Sshd,

f5/bigip/tm/sys/sflow.py

@@ -0,0 +1,101 @@
+# coding=utf-8
+#
+# Copyright 2017 F5 Networks Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#    http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+"""BIG-IP® system sflow module
+
+REST URI
+    ``http://localhost/mgmt/tm/sys/sflow``
+
+GUI Path
+   ``System->sFlow``
+
+REST Kind
+    ``tm:sys:sflow:*``
+"""
+
+# from distutils.version import LooseVersion
+from f5.bigip.resource import Collection
+from f5.bigip.resource import OrganizingCollection
+from f5.bigip.resource import Resource
+from f5.bigip.resource import UnnamedResource
+# from f5.sdk_exception import UnsupportedMethod
+
+
+class Sflow(OrganizingCollection):
+    def __init__(self, sys):
+        super(Sflow, self).__init__(sys)
+        self._meta_data['allowed_lazy_attributes'] = [
+            Global_Settings,
+            Receivers]
+
+
+class Global_Settings(OrganizingCollection):
+    def __init__(self, sflow):
+        super(Global_Settings, self).__init__(sflow)
+        self._meta_data['allowed_lazy_attributes'] = [
+            Http,
+            Interface,
+            System,
+            Vlan]
+
+
+class Http(UnnamedResource):
+    def __init__(self, global_settings):
+        super(Http, self).__init__(global_settings)
+        self._meta_data['required_load_parameters'] = set()
+        self._meta_data['required_json_kind'] =\
+            'tm:sys:sflow:global-settings:http:httpstate'
+
+
+class Interface(UnnamedResource):
+    def __init__(self, global_settings):
+        super(Interface, self).__init__(global_settings)
+        self._meta_data['required_load_parameters'] = set()
+        self._meta_data['required_json_kind'] =\
+            'tm:sys:sflow:global-settings:interface:interfacestate'
+
+
+class System(UnnamedResource):
+    def __init__(self, global_settings):
+        super(System, self).__init__(global_settings)
+        self._meta_data['required_load_parameters'] = set()
+        self._meta_data['required_json_kind'] =\
+            'tm:sys:sflow:global-settings:system:systemstate'
+
+
+class Vlan(UnnamedResource):
+    def __init__(self, global_settings):
+        super(Vlan, self).__init__(global_settings)
+        self._meta_data['required_load_parameters'] = set()
+        self._meta_data['required_json_kind'] =\
+            'tm:sys:sflow:global-settings:vlan:vlanstate'
+
+
+class Receivers(Collection):
+    def __init__(self, sflow):
+        super(Receivers, self).__init__(sflow)
+        self._meta_data['allowed_lazy_attributes'] = [Receiver]
+        self._meta_data['attribute_registry'] =\
+            {'tm:sys:sflow:receiver:receiverstate': Receiver}
+
+
+class Receiver(Resource):
+    def __init__(self, receivers):
+        super(Receiver, self).__init__(receivers)
+        self._meta_data['required_creation_parameters'].update(
+            ('name', 'address'))
+        self._meta_data['required_json_kind'] =\
+            'tm:sys:sflow:receiver:receiverstate'

f5/bigip/tm/sys/test/functional/test_sflow.py

@@ -0,0 +1,164 @@
+
+# Copyright 2017 F5 Networks Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#    http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+
+def set_sflow_http_settings_test(request, mgmt_root):
+    def teardown():
+        sf_http.pollInterval = sf_http_int
+        sf_http.update()
+    request.addfinalizer(teardown)
+    sf_http = mgmt_root.tm.sys.sflow.global_settings.http.load()
+    sf_http_int = sf_http.pollInterval
+    return sf_http
+
+
+def set_sflow_interface_settings_test(request, mgmt_root):
+    def teardown():
+        sf_interface.pollInterval = sf_interface_int
+        sf_interface.update()
+    request.addfinalizer(teardown)
+    sf_interface = mgmt_root.tm.sys.sflow.global_settings.interface.load()
+    sf_interface_int = sf_interface.pollInterval
+    return sf_interface
+
+
+def set_sflow_system_settings_test(request, mgmt_root):
+    def teardown():
+        sf_system.pollInterval = sf_system_int
+        sf_system.update()
+    request.addfinalizer(teardown)
+    sf_system = mgmt_root.tm.sys.sflow.global_settings.system.load()
+    sf_system_int = sf_system.pollInterval
+    return sf_system
+
+
+def set_sflow_vlan_settings_test(request, mgmt_root):
+    def teardown():
+        sf_vlan.pollInterval = sf_vlan_int
+        sf_vlan.update()
+    request.addfinalizer(teardown)
+    sf_vlan = mgmt_root.tm.sys.sflow.global_settings.vlan.load()
+    sf_vlan_int = sf_vlan.pollInterval
+    return sf_vlan
+
+
+def set_sflow_receiver_test(request, mgmt_root):
+    def teardown():
+        sflow_receiver.delete()
+    request.addfinalizer(teardown)
+
+    sflow_receiver = mgmt_root.tm.sys.sflow.receivers.receiver.create(
+        name='sr1', address='172.16.44.20'
+    )
+    return sflow_receiver
+
+
+class TestSflowHttp_Setting(object):
+    def test_RUL(self, request, mgmt_root):
+        # Load
+        h1 = set_sflow_http_settings_test(request, mgmt_root)
+        h2 = mgmt_root.tm.sys.sflow.global_settings.http.load()
+        assert h1.pollInterval == 10
+        assert h1.pollInterval == h2.pollInterval
+
+        # Update
+        h1.pollInterval = 20
+        h1.update()
+        assert h1.pollInterval == 20
+        assert h2.pollInterval == 10
+
+        # Refresh
+        h2.refresh()
+        assert h2.pollInterval == h1.pollInterval
+
+
+class TestSflowInterface_Setting(object):
+    def test_RUL(self, request, mgmt_root):
+        # Load
+        h1 = set_sflow_interface_settings_test(request, mgmt_root)
+        h2 = mgmt_root.tm.sys.sflow.global_settings.interface.load()
+        assert h1.pollInterval == 10
+        assert h1.pollInterval == h2.pollInterval
+
+        # Update
+        h1.pollInterval = 20
+        h1.update()
+        assert h1.pollInterval == 20
+        assert h2.pollInterval == 10
+
+        # Refresh
+        h2.refresh()
+        assert h2.pollInterval == h1.pollInterval
+
+
+class TestSflowSystem_Setting(object):
+    def test_RUL(self, request, mgmt_root):
+        # Load
+        h1 = set_sflow_system_settings_test(request, mgmt_root)
+        h2 = mgmt_root.tm.sys.sflow.global_settings.system.load()
+        assert h1.pollInterval == 10
+        assert h1.pollInterval == h2.pollInterval
+
+        # Update
+        h1.pollInterval = 20
+        h1.update()
+        assert h1.pollInterval == 20
+        assert h2.pollInterval == 10
+
+        # Refresh
+        h2.refresh()
+        assert h2.pollInterval == h1.pollInterval
+
+
+class TestSflowVlan_Setting(object):
+    def test_RUL(self, request, mgmt_root):
+        # Load
+        h1 = set_sflow_vlan_settings_test(request, mgmt_root)
+        h2 = mgmt_root.tm.sys.sflow.global_settings.vlan.load()
+        assert h1.pollInterval == 10
+        assert h1.pollInterval == h2.pollInterval
+
+        # Update
+        h1.pollInterval = 20
+        h1.update()
+        assert h1.pollInterval == 20
+        assert h2.pollInterval == 10
+
+        # Refresh
+        h2.refresh()
+        assert h2.pollInterval == h1.pollInterval
+
+
+class TestSflowReceiver(object):
+    def test_CURDLE(self, request, mgmt_root):
+        # Assume create/delete tested by setup/teardown
+        r1 = set_sflow_receiver_test(request, mgmt_root)
+
+        # Exists
+        assert mgmt_root.tm.sys.sflow.receivers.receiver.exists(name='sr1')
+
+        # Load
+        r2 = mgmt_root.tm.sys.sflow.receivers.receiver.load(name='sr1')
+        assert r1.name == r2.name
+
+        # Update
+        r1.address = '172.16.44.21'
+        r1.update()
+        assert r1.address != r2.address
+
+        # Refresh
+        r2.refresh()
+        assert r1.address == r2.address