Add new python proto parsers (ligato#1391)

* Add new python proto paresers

Signed-off-by: miroslav.kovac <[email protected]>

* Add and update new plugins

Signed-off-by: miroslav.kovac <[email protected]>

* Change script back to executable

Signed-off-by: miroslav.kovac <[email protected]>

Author: miroslavKovacPantheon

ansible/action_plugins/plugins/bridgeDomain.py

@@ -40,7 +40,7 @@ def __init__(self, values, agent_name):
     def validate(self):
         bridgeDomain = BridgeDomain()
         Parse(json.dumps(self.values), bridgeDomain)
-        return MessageToJson(bridgeDomain, indent=None)
+        return MessageToJson(bridgeDomain, preserving_proto_field_name=True, indent=None)
 
     def create_key(self):
         return "/vnf-agent/{}/config/vpp/l2/v2/bridge-domain/{}".format(self.agent_name, self.values['name'])
@@ -69,7 +69,7 @@ def validate(self):
 
         bridgeDomain = BridgeDomain()
         Parse(json.dumps(val), bridgeDomain)
-        return MessageToJson(bridgeDomain, indent=None)
+        return MessageToJson(bridgeDomain, preserving_proto_field_name=True, indent=None)
 
     def create_key(self):
         return "/vnf-agent/{}/config/vpp/l2/v2/bridge-domain/{}".format(self.agent_name, self.values['name'])
@@ -94,7 +94,7 @@ def validate(self):
 
         bridgeDomain = BridgeDomain()
         Parse(json.dumps(val), bridgeDomain)
-        return MessageToJson(bridgeDomain, indent=None)
+        return MessageToJson(bridgeDomain, preserving_proto_field_name=True, indent=None)
 
     def create_key(self):
         return "/vnf-agent/{}/config/vpp/l2/v2/bridge-domain/{}".format(self.agent_name, self.values['name'])

ansible/action_plugins/plugins/dhcpProxy.py

@@ -0,0 +1,44 @@
+# Copyright (c) 2019 PANTHEON.tech
+#
+# 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.
+
+import json
+import ipaddress
+from google.protobuf.json_format import MessageToJson, Parse
+
+from action_plugins.pout.models.vpp.l3.l3_pb2 import DHCPProxy
+
+
+def plugin_init(name, values, agent_name, ip, port):
+    if name == 'dhcp-proxy':
+        return DHCPProxyValidation(values, agent_name)
+    else:
+        return False
+
+
+class DHCPProxyValidation:
+
+    def __init__(self, values, agent_name):
+        self.values = values
+        self.agent_name =agent_name
+        version = ipaddress.ip_address(self.values['source_ip_address']).version
+        self.protocol = 'IPv{}'.format(version)
+
+    def validate(self):
+        dhcp_proxy = DHCPProxy()
+        Parse(json.dumps(self.values), dhcp_proxy)
+        return MessageToJson(dhcp_proxy, preserving_proto_field_name=True, indent=None)
+
+    def create_key(self):
+        return "/vnf-agent/{}/config/vpp/v2/dhcp-proxy/{}".format(self.agent_name,
+                                                               self.protocol)

ansible/action_plugins/plugins/interface.py

@@ -35,7 +35,7 @@ def __init__(self, values, agent_name):
     def validate(self):
         interface = Interface()
         Parse(json.dumps(self.values), interface)
-        return MessageToJson(interface, indent=None)
+        return MessageToJson(interface, preserving_proto_field_name=True, indent=None)
 
     def create_key(self):
         return "/vnf-agent/{}/config/vpp/v2/interfaces/{}".format(self.agent_name, self.values['name'])

ansible/action_plugins/plugins/linuxInterface.py

@@ -0,0 +1,41 @@
+# Copyright (c) 2019 PANTHEON.tech
+#
+# 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.
+
+import json
+from google.protobuf.json_format import MessageToJson, Parse
+
+from action_plugins.pout.models.linux.interfaces.interface_pb2 import Interface
+
+
+def plugin_init(name, values, agent_name, ip, port):
+    if name == 'linuxInterface':
+        return LinuxInterfaceValidation(values, agent_name)
+    else:
+        return False
+
+
+class LinuxInterfaceValidation:
+
+    def __init__(self, values, agent_name):
+        self.values = values
+        self.agent_name =agent_name
+
+
+    def validate(self):
+        dhcp_proxy = Interface()
+        Parse(json.dumps(self.values), dhcp_proxy)
+        return MessageToJson(dhcp_proxy, preserving_proto_field_name=True, indent=None)
+
+    def create_key(self):
+        return "/vnf-agent/{}/config/linux/interfaces/v2/interface/{}".format(self.agent_name, self.values['name'])

ansible/action_plugins/plugins/nat.py

@@ -17,11 +17,14 @@
 from google.protobuf.json_format import MessageToJson, Parse
 
 from action_plugins.pout.models.vpp.nat.nat_pb2 import Nat44Global
+from action_plugins.pout.models.vpp.nat.nat_pb2 import DNat44
 
 
 def plugin_init(name, values, agent_name, ip, port):
     if name == 'nat':
         return NatValidation(values, agent_name)
+    elif name == 'dnat':
+        DNatValidation(values, agent_name)
     else:
         return False
 
@@ -30,12 +33,27 @@ class NatValidation:
 
     def __init__(self, values, agent_name):
         self.values = values
-        self.agent_name =agent_name
+        self.agent_name = agent_name
 
     def validate(self):
         nat = Nat44Global()
         Parse(json.dumps(self.values), nat)
-        return MessageToJson(nat, indent=None)
+        return MessageToJson(nat, preserving_proto_field_name=True, indent=None)
 
     def create_key(self):
         return "/vnf-agent/{}/config/vpp/nat/v2/nat44-global".format(self.agent_name)
+
+
+class DNatValidation:
+
+    def __init__(self, values, agent_name):
+        self.values = values
+        self.agent_name = agent_name
+
+    def validate(self):
+        nat = DNat44()
+        Parse(json.dumps(self.values), nat)
+        return MessageToJson(nat, preserving_proto_field_name=True, indent=None)
+
+    def create_key(self):
+        return "/vnf-agent/{}/config/vpp/nat/v2/dnat44/{}".format(self.agent_name, self.values['label'])

ansible/action_plugins/plugins/route.py

@@ -13,7 +13,6 @@
 # limitations under the License.
 
 import json
-from enum import Enum
 
 from google.protobuf.json_format import MessageToJson, Parse
 
@@ -36,7 +35,7 @@ def __init__(self, values, agent_name):
     def validate(self):
         route = Route()
         Parse(json.dumps(self.values), route)
-        return MessageToJson(route, indent=None)
+        return MessageToJson(route, preserving_proto_field_name=True, indent=None)
 
     def create_key(self):
         return "/vnf-agent/{}/config/vpp/v2/route/vrf/{}/dst/{}/gw/{}".format(self.agent_name,

ansible/action_plugins/plugins/xconnect.py

@@ -0,0 +1,42 @@
+# Copyright (c) 2019 PANTHEON.tech
+#
+# 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.
+
+import json
+from google.protobuf.json_format import MessageToJson, Parse
+
+from action_plugins.pout.models.vpp.l2.xconnect_pb2 import XConnectPair
+
+
+def plugin_init(name, values, agent_name, ip, port):
+    if name == 'xconnect':
+        return XConnectValidation(values, agent_name)
+    else:
+        return False
+
+
+class XConnectValidation:
+
+    def __init__(self, values, agent_name):
+        self.values = values
+        self.agent_name =agent_name
+
+
+    def validate(self):
+        dhcp_proxy = XConnectPair()
+        Parse(json.dumps(self.values), dhcp_proxy)
+        return MessageToJson(dhcp_proxy, preserving_proto_field_name=True, indent=None)
+
+    def create_key(self):
+        return "/vnf-agent/{}/config/vpp/l2/v2/xconnect/{}".format(self.agent_name,
+                                                                   self.values['receive_interface'])

ansible/action_plugins/pout/models/linux/__init__.py

@@ -0,0 +1,13 @@
+# Copyright (c) 2019 PANTHEON.tech
+#
+# 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.

ansible/action_plugins/pout/models/linux/interfaces/__init__.py

@@ -0,0 +1,13 @@
+# Copyright (c) 2019 PANTHEON.tech
+#
+# 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.