Adding upstream version 7.7.0+dfsg.upstream/7.7.0+dfsg

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 60 insertions, 0 deletions

diff --git a/ansible_collections/check_point/mgmt/plugins/action/cp_mgmt_access_rules.py b/ansible_collections/check_point/mgmt/plugins/action/cp_mgmt_access_rules.py
new file mode 100644
index 000000000..3a06797d9
--- /dev/null
+++ b/ansible_collections/check_point/mgmt/plugins/action/cp_mgmt_access_rules.py
@@ -0,0 +1,60 @@
+from __future__ import (absolute_import, division, print_function)
+
+__metaclass__ = type
+
+
+from ansible.errors import AnsibleActionFail
+from ansible.plugins.action import ActionBase
+from ansible_collections.check_point.mgmt.plugins.module_utils.checkpoint import \
+    prepare_rule_params_for_execute_module, check_if_to_publish_for_action
+
+
+class ActionModule(ActionBase):
+
+    def run(self, tmp=None, task_vars=None):
+
+        module = super(ActionModule, self).run(tmp, task_vars)
+
+        result = self._execute_module(module_name='check_point.mgmt.cp_mgmt_access_rules', module_args=self._task.args,
+                                      task_vars=task_vars, tmp=tmp)
+
+        if 'msg' in result.keys():
+            raise AnsibleActionFail(result['msg'])
+
+        module_args = self._task.args
+
+        fields = {'position', 'layer', 'auto_publish_session'}
+        rules_list = module_args['rules']
+        for rule in rules_list:
+            for field in fields:
+                if field in rule.keys():
+                    raise AnsibleActionFail('Unsupported parameter ' + field + ' for rule')
+        # check_fields_for_rule_action_module(module_args)
+        rules_list = self._task.args['rules']
+        position = 1
+        below_rule_name = None
+
+        for rule in rules_list:
+            rule, position, below_rule_name = prepare_rule_params_for_execute_module(rule=rule, module_args=module_args,
+                                                                                     position=position,
+                                                                                     below_rule_name=below_rule_name)
+
+            result['rule: ' + rule['name']] = self._execute_module(module_name='check_point.mgmt.cp_mgmt_access_rule',
+                                                                   module_args=rule,
+                                                                   task_vars=task_vars, tmp=tmp, wrap_async=False)
+            if 'changed' in result['rule: ' + rule['name']].keys() and \
+                    result['rule: ' + rule['name']]['changed'] is True:
+                result['changed'] = True
+            if 'failed' in result['rule: ' + rule['name']].keys() and result['rule: ' + rule['name']]['failed'] is True:
+                temp = result['rule: ' + rule['name']].copy()
+                result = {}
+                result['rule: ' + rule['name']] = temp
+                result['failed'] = True
+                result['discard:'] = self._execute_module(module_name='check_point.mgmt.cp_mgmt_discard',
+                                                          module_args={}, task_vars=task_vars, tmp=tmp)
+                break
+        if check_if_to_publish_for_action(result, module_args):
+            result['publish:'] = self._execute_module(module_name='check_point.mgmt.cp_mgmt_publish', module_args={},
+                                                      task_vars=task_vars, tmp=tmp)
+
+        return result