proxmox_firewall: Add force condition

- state=present:
    + check if fw rules already exists and if needed update them instead of creating
    + check if grooup exists and if so don't do anything
- state=update:
    + check if fw rules don't existsand if needed create them instead of updating
- make rules.pos as required this is to handle above conditions
- add method to get security groups and list them withfirewall rules when state is not provided

Author: JanaHoch

plugins/modules/proxmox_firewall.py

@@ -32,6 +32,12 @@
       - present
       - update
       - absent
+  force:
+    description:
+      - If state is present and if 1 or more rule already exists at given pos force will update them
+      - If state is update and if 1 or more rule doesn't exist force will create
+    type: bool
+    default: false
   level:
     description:
       - Level at which the firewall rule applies.
@@ -157,6 +163,7 @@
         description:
           - Position of the rule in the list.
         type: int
+        required: true
       proto:
         description:
           - IP protocol. You can use protocol names ('tcp'/'udp') or simple numbers, as defined in '/etc/protocols'.
@@ -276,6 +283,14 @@
     sample:
       test
 
+groups:
+    description: list of firewall security groups
+    returned: on success
+    type: list
+    elements: str
+    sample:
+      [ "test" ]
+
 firewall_rules:
     description: List of firewall rules.
     returned: on success
@@ -391,6 +406,7 @@
 def get_proxmox_args():
     return dict(
         state=dict(type="str", choices=["present", "absent", "update"], required=False),
+        force=dict(type="bool", default=False),
         level=dict(type="str", choices=["cluster", "node", "vm", "vnet", "group"], default="cluster", required=False),
         node=dict(type="str", required=False),
         vmid=dict(type="int", required=False),
@@ -417,7 +433,7 @@ def get_proxmox_args():
                          choices=["emerg", "alert", "crit", "err", "warning", "notice", "info", "debug", "nolog"],
                          required=False),
                 macro=dict(type="str", required=False),
-                pos=dict(type="int", required=False),
+                pos=dict(type="int", required=True),
                 proto=dict(type="str", required=False),
                 source=dict(type="str", required=False),
                 sport=dict(type="str", required=False)
@@ -464,6 +480,7 @@ def run(self):
             )
 
         state = self.params.get("state")
+        force = self.params.get("force")
         level = self.params.get("level")
         rules = self.params.get("rules")
 
@@ -496,24 +513,32 @@ def run(self):
             if self.params.get('group_conf'):
                 self.create_group(group=self.params.get('group'), comment=self.params.get('comment'))
             if rules is not None:
-                self.create_fw_rules(rules_obj=rules_obj, rules=rules)
+                self.create_fw_rules(rules_obj=rules_obj, rules=rules, force=force)
         elif state == "update":
             if self.params.get('group_conf'):
                 self.create_group(group=self.params.get('group'), comment=self.params.get('comment'))
             if rules is not None:
-                self.update_fw_rules(rules_obj=rules_obj, rules=rules)
+                self.update_fw_rules(rules_obj=rules_obj, rules=rules, force=force)
         elif state == "absent":
             if self.params.get('pos'):
                 self.delete_fw_rule(rules_obj=rules_obj, pos=self.params.get('pos'))
             if self.params.get('group_conf'):
                 self.delete_group(group_name=self.params.get('group'))
         else:
             rules = self.get_fw_rules(rules_obj, pos=self.params.get('pos'))
+            groups = self.get_groups()
             self.module.exit_json(
-                changed=False, firewall_rules=rules, msg='successfully retrieved firewall rules'
+                changed=False,
+                firewall_rules=rules,
+                groups=groups,
+                msg='successfully retrieved firewall rules and groups'
             )
 
     def create_group(self, group, comment=None):
+        if group in self.get_groups():
+            self.module.exit_json(
+                changed=False, group=group, msg=f"security group {group} already exists"
+            )
         try:
             self.proxmox_api.cluster().firewall().groups.post(group=group, comment=comment)
             self.module.exit_json(
@@ -525,6 +550,10 @@ def create_group(self, group, comment=None):
             )
 
     def delete_group(self, group_name):
+        if group_name not in self.get_groups():
+            self.module.exit_json(
+                changed=False, group=group_name, msg=f"security group {group_name} already doesn't exists"
+            )
         try:
             group = getattr(self.proxmox_api.cluster().firewall().groups(), group_name)
             group.delete()
@@ -546,8 +575,23 @@ def get_fw_rules(self, rules_obj, pos=None):
                 msg=f'Failed to retrieve firewall rules: {e}'
             )
 
+    def get_groups(self):
+        try:
+            return [x['group'] for x in self.proxmox_api.cluster().firewall().groups().get()]
+        except Exception as e:
+            self.module.fail_json(
+                msg=f'Failed to retrieve firewall security groups: {e}'
+            )
+
     def delete_fw_rule(self, rules_obj, pos):
         try:
+            for item in self.get_fw_rules(rules_obj):
+                if item.get('pos') == pos:
+                    break
+            else:
+                self.module.exit_json(
+                    changed=False, msg="Firewall rule already doesn't exist"
+                )
             rule_obj = getattr(rules_obj(), str(pos))
             digest = rule_obj.get().get('digest')
             rule_obj.delete(pos=pos, digest=digest)
@@ -560,8 +604,21 @@ def delete_fw_rule(self, rules_obj, pos):
                 msg=f'Failed to delete firewall rule at pos {pos}: {e}'
             )
 
-    def update_fw_rules(self, rules_obj, rules):
-        for rule in rules:
+    def update_fw_rules(self, rules_obj, rules, force):
+        existing_rules = self.get_fw_rules(rules_obj)
+        rules_to_create = []
+        if len(existing_rules) > 0:
+            existing_pos = [x['pos'] for x in existing_rules]
+            for rule in rules:
+                if rule.get('pos') not in existing_pos:
+                    if force:
+                        rules_to_create.append(rule)
+                    else:
+                        self.module.fail_json(
+                            msg=f"Rule doesn't exists at pos - {rule.get('pos')} and force is false."
+                        )
+        rules_to_update = [rule for rule in rules if rule not in rules_to_create]
+        for rule in rules_to_update:
             rule['icmp-type'] = rule.get('icmp_type')
             rule['enable'] = ansible_to_proxmox_bool(rule.get('enable'))
             del rule['icmp_type']
@@ -574,12 +631,29 @@ def update_fw_rules(self, rules_obj, rules):
                 self.module.fail_json(
                     msg=f'Failed to update firewall rule at pos {rule["pos"]}: {e}'
                 )
+
+        if len(rules_to_create) > 0:
+            self.create_fw_rules(rules_obj=rules_obj, rules=rules_to_create, force=False)
         self.module.exit_json(
-            changed=True, msg='successfully created firewall rules'
+            changed=True, msg='successfully updated firewall rules'
         )
 
-    def create_fw_rules(self, rules_obj, rules):
-        for rule in rules:
+    def create_fw_rules(self, rules_obj, rules, force):
+        existing_rules = self.get_fw_rules(rules_obj)
+        rules_to_update = []
+        if len(existing_rules) > 0:
+            existing_pos = [x['pos'] for x in existing_rules]
+            for rule in rules:
+                if rule.get('pos') in existing_pos:
+                    if force:
+                        rules_to_update.append(rule)
+                    else:
+                        self.module.fail_json(
+                            msg=f"Rule already exists at pos - {rule.get('pos')} and force is false."
+                        )
+        rules_to_create = [rule for rule in rules if rule not in rules_to_update]
+
+        for rule in rules_to_create:
             rule['icmp-type'] = rule.get('icmp_type')
             rule['enable'] = ansible_to_proxmox_bool(rule.get('enable'))
             del rule['icmp_type']
@@ -591,6 +665,8 @@ def create_fw_rules(self, rules_obj, rules):
                 self.module.fail_json(
                     msg=f'Failed to create firewall rule {rule}: {e}'
                 )
+        if len(rules_to_update) > 0:
+            self.update_fw_rules(rules_obj=rules_obj, rules=rules_to_update, force=False)
         self.module.exit_json(
             changed=True, msg='successfully created firewall rules'
         )