Centry reporters: allow default config to work with snake-oil certs

carrier-io · Jan 22, 2024 · 0ed1af4 · 0ed1af4
1 parent a0d01d6
commit 0ed1af4
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 6 deletions.
diff --git a/dusty/reporters/centry/connector.py b/dusty/reporters/centry/connector.py
@@ -1,3 +1,4 @@
+import os
 from requests import post
 from json import dumps
 from . import constants as c
@@ -23,11 +24,13 @@ def __init__(self, url, token, project_id, test_id, test_type):
     def create_test_results(self, test_results):
         report_id = post(f'{self.url}{self.report_url}',
                          data=dumps(test_results),
-                         headers=self.headers).json()
+                         headers=self.headers,
+                         verify=os.environ.get("SSL_VERIFY", "").lower() in ["true", "yes"]).json()
         return report_id['id']
 
     def create_findings(self, findings):
         result = post(f'{self.url}{self.finding_api}',
                       data=dumps(findings),
-                      headers=self.headers)
+                      headers=self.headers,
+                      verify=os.environ.get("SSL_VERIFY", "").lower() in ["true", "yes"])
         return result.content
diff --git a/dusty/reporters/centry_loki/emitter.py b/dusty/reporters/centry_loki/emitter.py
@@ -36,7 +36,7 @@ def __init__(  # pylint: disable=R0913
             self, loki_push_url,
             loki_user=None, loki_password=None, loki_token=None,
             default_labels=None,
-            verify=True, retries=3, retry_delay=0.5, timeout=15,
+            verify=False, retries=3, retry_delay=0.5, timeout=15,
         ):
         self.loki_push_url = loki_push_url
         self.loki_user = loki_user
@@ -152,7 +152,7 @@ def __init__(self, settings):
             loki_password=self.settings.get("password", None),
             loki_token=self.settings.get("token", None),
             default_labels=default_loki_labels,
-            verify=self.settings.get("verify", True),
+            verify=self.settings.get("verify", False),
             # retries=3,
             # retry_delay=0.5,
             # timeout=15,
@@ -198,7 +198,7 @@ def __init__(self, settings):
             loki_password=self.settings.get("password", None),
             loki_token=self.settings.get("token", None),
             default_labels=default_loki_labels,
-            verify=self.settings.get("verify", True),
+            verify=self.settings.get("verify", False),
             # retries=3,
             # retry_delay=0.5,
             # timeout=15,

diff --git a/dusty/reporters/centry_status/reporter.py b/dusty/reporters/centry_status/reporter.py
@@ -53,7 +53,8 @@ def _status_listener(self, event, data):
         requests.put(
             f'{self.config["url"]}/api/v1/{TEST_MAPPING[self.test_type]}/test_status/{self.config["project_id"]}/{self.config["test_id"]}',
             json={"test_status": data},
-            headers={"Authorization": f'Bearer {self.config["token"]}'}
+            headers={"Authorization": f'Bearer {self.config["token"]}'},
+            verify=self.config.get("ssl_verify", False),
         )
 
     @staticmethod