Add early check of status for SDA modules

plugins/action/sda_fabric.py

@@ -24,6 +24,7 @@
 )
 from ansible_collections.cisco.dnac.plugins.plugin_utils.exceptions import (
     InconsistentParameters,
+    AnsibleSDAException,
 )
 
 # Get common arguments specification
@@ -138,6 +139,11 @@ def create(self):
             params=self.create_params(),
             op_modifies=True,
         )
+        if isinstance(result, dict):
+            if 'response' in result:
+                result = result.get('response')
+            if isinstance(result, dict) and result.get("status") == "failed":
+                raise AnsibleSDAException(response=result)
         return result
 
     def delete(self):
@@ -204,8 +210,11 @@ def run(self, tmp=None, task_vars=None):
                     response = prev_obj
                     dnac.object_already_present()
             else:
-                response = obj.create()
-                dnac.object_created()
+                try:
+                    response = obj.create()
+                    dnac.object_created()
+                except AnsibleSDAException as e:
+                    dnac.fail_json("Could not create object {e}".format(e=e._response))
         elif state == "absent":
             (obj_exists, prev_obj) = obj.exists()
             if obj_exists:

plugins/action/sda_fabric_authentication_profile.py

@@ -24,6 +24,7 @@
 )
 from ansible_collections.cisco.dnac.plugins.plugin_utils.exceptions import (
     InconsistentParameters,
+    AnsibleSDAException,
 )
 
 # Get common arguments specification
@@ -144,6 +145,11 @@ def create(self):
             params=self.create_params(),
             op_modifies=True,
         )
+        if isinstance(result, dict):
+            if 'response' in result:
+                result = result.get('response')
+            if isinstance(result, dict) and result.get("status") == "failed":
+                raise AnsibleSDAException(response=result)
         return result
 
     def update(self):
@@ -226,8 +232,11 @@ def run(self, tmp=None, task_vars=None):
                     response = prev_obj
                     dnac.object_already_present()
             else:
-                response = obj.create()
-                dnac.object_created()
+                try:
+                    response = obj.create()
+                    dnac.object_created()
+                except AnsibleSDAException as e:
+                    dnac.fail_json("Could not create object {e}".format(e=e._response))
 
         elif state == "absent":
             (obj_exists, prev_obj) = obj.exists()

plugins/action/sda_fabric_border_device.py

@@ -24,6 +24,7 @@
 )
 from ansible_collections.cisco.dnac.plugins.plugin_utils.exceptions import (
     InconsistentParameters,
+    AnsibleSDAException,
 )
 
 # Get common arguments specification
@@ -145,6 +146,11 @@ def create(self):
             params=self.create_params(),
             op_modifies=True,
         )
+        if isinstance(result, dict):
+            if 'response' in result:
+                result = result.get('response')
+            if isinstance(result, dict) and result.get("status") == "failed":
+                raise AnsibleSDAException(response=result)
         return result
 
     def delete(self):
@@ -211,8 +217,11 @@ def run(self, tmp=None, task_vars=None):
                     response = prev_obj
                     dnac.object_already_present()
             else:
-                response = obj.create()
-                dnac.object_created()
+                try:
+                    response = obj.create()
+                    dnac.object_created()
+                except AnsibleSDAException as e:
+                    dnac.fail_json("Could not create object {e}".format(e=e._response))
         elif state == "absent":
             (obj_exists, prev_obj) = obj.exists()
             if obj_exists:

plugins/action/sda_fabric_control_plane_device.py

@@ -24,6 +24,7 @@
 )
 from ansible_collections.cisco.dnac.plugins.plugin_utils.exceptions import (
     InconsistentParameters,
+    AnsibleSDAException,
 )
 
 # Get common arguments specification
@@ -139,6 +140,11 @@ def create(self):
             params=self.create_params(),
             op_modifies=True,
         )
+        if isinstance(result, dict):
+            if 'response' in result:
+                result = result.get('response')
+            if isinstance(result, dict) and result.get("status") == "failed":
+                raise AnsibleSDAException(response=result)
         return result
 
     def delete(self):
@@ -205,8 +211,11 @@ def run(self, tmp=None, task_vars=None):
                     response = prev_obj
                     dnac.object_already_present()
             else:
-                response = obj.create()
-                dnac.object_created()
+                try:
+                    response = obj.create()
+                    dnac.object_created()
+                except AnsibleSDAException as e:
+                    dnac.fail_json("Could not create object {e}".format(e=e._response))
         elif state == "absent":
             (obj_exists, prev_obj) = obj.exists()
             if obj_exists:

plugins/action/sda_fabric_edge_device.py

@@ -24,6 +24,7 @@
 )
 from ansible_collections.cisco.dnac.plugins.plugin_utils.exceptions import (
     InconsistentParameters,
+    AnsibleSDAException,
 )
 
 # Get common arguments specification
@@ -139,6 +140,11 @@ def create(self):
             params=self.create_params(),
             op_modifies=True,
         )
+        if isinstance(result, dict):
+            if 'response' in result:
+                result = result.get('response')
+            if isinstance(result, dict) and result.get("status") == "failed":
+                raise AnsibleSDAException(response=result)
         return result
 
     def delete(self):
@@ -205,8 +211,11 @@ def run(self, tmp=None, task_vars=None):
                     response = prev_obj
                     dnac.object_already_present()
             else:
-                response = obj.create()
-                dnac.object_created()
+                try:
+                    response = obj.create()
+                    dnac.object_created()
+                except AnsibleSDAException as e:
+                    dnac.fail_json("Could not create object {e}".format(e=e._response))
         elif state == "absent":
             (obj_exists, prev_obj) = obj.exists()
             if obj_exists:

plugins/action/sda_fabric_site.py

@@ -24,6 +24,7 @@
 )
 from ansible_collections.cisco.dnac.plugins.plugin_utils.exceptions import (
     InconsistentParameters,
+    AnsibleSDAException,
 )
 
 # Get common arguments specification
@@ -139,6 +140,11 @@ def create(self):
             params=self.create_params(),
             op_modifies=True,
         )
+        if isinstance(result, dict):
+            if 'response' in result:
+                result = result.get('response')
+            if isinstance(result, dict) and result.get("status") == "failed":
+                raise AnsibleSDAException(response=result)
         return result
 
     def delete(self):
@@ -205,8 +211,11 @@ def run(self, tmp=None, task_vars=None):
                     response = prev_obj
                     dnac.object_already_present()
             else:
-                response = obj.create()
-                dnac.object_created()
+                try:
+                    response = obj.create()
+                    dnac.object_created()
+                except AnsibleSDAException as e:
+                    dnac.fail_json("Could not create object {e}".format(e=e._response))
         elif state == "absent":
             (obj_exists, prev_obj) = obj.exists()
             if obj_exists:

plugins/action/sda_multicast.py

@@ -24,6 +24,7 @@
 )
 from ansible_collections.cisco.dnac.plugins.plugin_utils.exceptions import (
     InconsistentParameters,
+    AnsibleSDAException,
 )
 
 # Get common arguments specification
@@ -142,6 +143,11 @@ def create(self):
             params=self.create_params(),
             op_modifies=True,
         )
+        if isinstance(result, dict):
+            if 'response' in result:
+                result = result.get('response')
+            if isinstance(result, dict) and result.get("status") == "failed":
+                raise AnsibleSDAException(response=result)
         return result
 
     def delete(self):
@@ -205,8 +211,11 @@ def run(self, tmp=None, task_vars=None):
                     response = prev_obj
                     dnac.object_already_present()
             else:
-                response = obj.create()
-                dnac.object_created()
+                try:
+                    response = obj.create()
+                    dnac.object_created()
+                except AnsibleSDAException as e:
+                    dnac.fail_json("Could not create object {e}".format(e=e._response))
         elif state == "absent":
             (obj_exists, prev_obj) = obj.exists()
             if obj_exists:

plugins/action/sda_port_assignment_for_access_point.py

@@ -24,6 +24,7 @@
 )
 from ansible_collections.cisco.dnac.plugins.plugin_utils.exceptions import (
     InconsistentParameters,
+    AnsibleSDAException,
 )
 
 # Get common arguments specification
@@ -148,6 +149,11 @@ def create(self):
             params=self.create_params(),
             op_modifies=True,
         )
+        if isinstance(result, dict):
+            if 'response' in result:
+                result = result.get('response')
+            if isinstance(result, dict) and result.get("status") == "failed":
+                raise AnsibleSDAException(response=result)
         return result
 
     def delete(self):
@@ -214,8 +220,11 @@ def run(self, tmp=None, task_vars=None):
                     response = prev_obj
                     dnac.object_already_present()
             else:
-                response = obj.create()
-                dnac.object_created()
+                try:
+                    response = obj.create()
+                    dnac.object_created()
+                except AnsibleSDAException as e:
+                    dnac.fail_json("Could not create object {e}".format(e=e._response))
         elif state == "absent":
             (obj_exists, prev_obj) = obj.exists()
             if obj_exists:

plugins/action/sda_port_assignment_for_user_device.py

@@ -24,6 +24,7 @@
 )
 from ansible_collections.cisco.dnac.plugins.plugin_utils.exceptions import (
     InconsistentParameters,
+    AnsibleSDAException,
 )
 
 # Get common arguments specification
@@ -148,6 +149,11 @@ def create(self):
             params=self.create_params(),
             op_modifies=True,
         )
+        if isinstance(result, dict):
+            if 'response' in result:
+                result = result.get('response')
+            if isinstance(result, dict) and result.get("status") == "failed":
+                raise AnsibleSDAException(response=result)
         return result
 
     def delete(self):
@@ -214,8 +220,11 @@ def run(self, tmp=None, task_vars=None):
                     response = prev_obj
                     dnac.object_already_present()
             else:
-                response = obj.create()
-                dnac.object_created()
+                try:
+                    response = obj.create()
+                    dnac.object_created()
+                except AnsibleSDAException as e:
+                    dnac.fail_json("Could not create object {e}".format(e=e._response))
         elif state == "absent":
             (obj_exists, prev_obj) = obj.exists()
             if obj_exists:

plugins/action/sda_provision_device.py

@@ -24,6 +24,7 @@
 )
 from ansible_collections.cisco.dnac.plugins.plugin_utils.exceptions import (
     InconsistentParameters,
+    AnsibleSDAException,
 )
 
 # Get common arguments specification
@@ -134,6 +135,11 @@ def create(self):
             params=self.create_params(),
             op_modifies=True,
         )
+        if isinstance(result, dict):
+            if 'response' in result:
+                result = result.get('response')
+            if isinstance(result, dict) and result.get("status") == "failed":
+                raise AnsibleSDAException(response=result)
         return result
 
     def delete(self):
@@ -197,8 +203,12 @@ def run(self, tmp=None, task_vars=None):
                     response = prev_obj
                     dnac.object_already_present()
             else:
-                response = obj.create()
-                dnac.object_created()
+                try:
+                    response = obj.create()
+                    dnac.object_created()
+                except AnsibleSDAException as e:
+                    dnac.fail_json("Could not create object {e}".format(e=e._response))
+
         elif state == "absent":
             (obj_exists, prev_obj) = obj.exists()
             if obj_exists:

plugins/action/sda_virtual_network.py

@@ -24,6 +24,7 @@
 )
 from ansible_collections.cisco.dnac.plugins.plugin_utils.exceptions import (
     InconsistentParameters,
+    AnsibleSDAException,
 )
 
 # Get common arguments specification
@@ -144,6 +145,11 @@ def create(self):
             params=self.create_params(),
             op_modifies=True,
         )
+        if isinstance(result, dict):
+            if 'response' in result:
+                result = result.get('response')
+            if isinstance(result, dict) and result.get("status") == "failed":
+                raise AnsibleSDAException(response=result)
         return result
 
     def delete(self):
@@ -210,8 +216,11 @@ def run(self, tmp=None, task_vars=None):
                     response = prev_obj
                     dnac.object_already_present()
             else:
-                response = obj.create()
-                dnac.object_created()
+                try:
+                    response = obj.create()
+                    dnac.object_created()
+                except AnsibleSDAException as e:
+                    dnac.fail_json("Could not create object {e}".format(e=e._response))
         elif state == "absent":
             (obj_exists, prev_obj) = obj.exists()
             if obj_exists: