repect validate_certs

opsmill · Sep 6, 2024 · b7495de · b7495de
1 parent bb16e8e
commit b7495de
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 10 deletions.
diff --git a/plugins/action/artifact_fetch.py b/plugins/action/artifact_fetch.py
@@ -78,10 +78,7 @@ def run(self, tmp=None, task_vars=None):
         try:
             Display().v("Initializing Infrahub Client")
             client = InfrahubclientWrapper(
-                api_endpoint=api_endpoint,
-                token=token,
-                branch=branch,
-                timeout=timeout,
+                api_endpoint=api_endpoint, token=token, branch=branch, timeout=timeout, validate_certs=validate_certs
             )
             Display().v("Fetch Artifacts")
             result = client.fetch_single_artifact(filters=filters)

diff --git a/plugins/action/query_graphql.py b/plugins/action/query_graphql.py
@@ -85,10 +85,7 @@ def run(self, tmp=None, task_vars=None):
         try:
             Display().v("Initializing Infrahub Client")
             client = InfrahubclientWrapper(
-                api_endpoint=api_endpoint,
-                token=token,
-                branch=branch,
-                timeout=timeout,
+                api_endpoint=api_endpoint, token=token, branch=branch, timeout=timeout, validate_certs=validate_certs
             )
             processor = InfrahubQueryProcessor(client=client)
             Display().v("Processing Query")

diff --git a/plugins/inventory/inventory.py b/plugins/inventory/inventory.py
@@ -294,6 +294,7 @@ def main(self):
                     branch=self.branch,
                     token=self.token,
                     timeout=self.timeout,
+                    validate_certs=self.validate_certs,
                 )
                 processor = InfrahubNodesProcessor(client=client)
                 self.display.v("Processing Nodes request")

diff --git a/plugins/lookup/lookup.py b/plugins/lookup/lookup.py
@@ -164,6 +164,7 @@ def run(self, terms, variables=None, query=None, graph_variables=None, **kwargs)
                 token=token,
                 branch=branch,
                 timeout=timeout,
+                validate_certs=validate_certs,
             )
             processor = InfrahubQueryProcessor(client=client)
             Display().v("Processing Query")

diff --git a/plugins/module_utils/infrahub_utils.py b/plugins/module_utils/infrahub_utils.py
@@ -32,7 +32,14 @@
     TYPE_MAPPING = {"str": str, "int": int, "float": float, "bool": bool}
 
     class InfrahubclientWrapper:
-        def __init__(self, api_endpoint: str, branch: str, token: str, timeout: Optional[int] = 10):
+        def __init__(
+            self,
+            api_endpoint: str,
+            branch: str,
+            token: str,
+            timeout: Optional[int] = 10,
+            validate_certs: Optional[str] = True,
+        ):
             """
             Initializes InfrahubclientWrapper.
 
@@ -44,7 +51,7 @@ def __init__(self, api_endpoint: str, branch: str, token: str, timeout: Optional
             """
             self.client = InfrahubClientSync(
                 address=api_endpoint,
-                config=Config(api_token=token, timeout=timeout, default_branch=branch),
+                config=Config(api_token=token, timeout=timeout, default_branch=branch, tls_insecure=not validate_certs),
             )
             self.branch_manager = InfrahubBranchManagerSync(self.client)