diff options
| -rw-r--r-- | src/soc_collector/soc_collector_cli.py | 16 |
1 files changed, 10 insertions, 6 deletions
diff --git a/src/soc_collector/soc_collector_cli.py b/src/soc_collector/soc_collector_cli.py index e32b5ad..27df732 100644 --- a/src/soc_collector/soc_collector_cli.py +++ b/src/soc_collector/soc_collector_cli.py @@ -41,7 +41,7 @@ def json_load_data(data: str) -> Dict[str, Any]: def info_action() -> None: """Get database info, currently number of documents.""" - req = requests.get(f"{API_URL}/info", headers={"API-KEY": API_KEY}, timeout=5) + req = requests.get(f"{API_URL}/info", headers={"API-KEY": API_KEY}, timeout=5, verify=ROOT_CA_FILE) # Ensure ok status req.raise_for_status() @@ -59,7 +59,9 @@ def search_action(data: str) -> None: search_data = json_load_data(data) - req = requests.post(f"{API_URL}/sc/v0/search", headers={"API-KEY": API_KEY}, json=search_data, timeout=5) + req = requests.post( + f"{API_URL}/sc/v0/search", headers={"API-KEY": API_KEY}, json=search_data, timeout=5, verify=ROOT_CA_FILE + ) # Ensure ok status req.raise_for_status() @@ -77,7 +79,7 @@ def delete_action(data: str) -> None: if isfile(data): data = json_load_data(data)["_id"] - req = requests.delete(f"{API_URL}/sc/v0/{data}", headers={"API-KEY": API_KEY}, timeout=5) + req = requests.delete(f"{API_URL}/sc/v0/{data}", headers={"API-KEY": API_KEY}, timeout=5, verify=ROOT_CA_FILE) # Check status if req.status_code == 404: @@ -113,7 +115,7 @@ def replace_action(data: str) -> None: """ json_data = json_load_data(data) - req = requests.put(f"{API_URL}/sc/v0", json=json_data, headers={"API-KEY": API_KEY}, timeout=5) + req = requests.put(f"{API_URL}/sc/v0", json=json_data, headers={"API-KEY": API_KEY}, timeout=5, verify=ROOT_CA_FILE) # Check status if req.status_code == 404: @@ -134,7 +136,9 @@ def insert_action(data: str) -> None: """ json_data = json_load_data(data) - req = requests.post(f"{API_URL}/sc/v0", json=json_data, headers={"API-KEY": API_KEY}, timeout=5) + req = requests.post( + f"{API_URL}/sc/v0", json=json_data, headers={"API-KEY": API_KEY}, timeout=5, verify=ROOT_CA_FILE + ) # Ensure ok status req.raise_for_status() @@ -150,7 +154,7 @@ def get_action(data: str) -> None: """ if isfile(data): data = json_load_data(data)["_id"] - req = requests.get(f"{API_URL}/sc/v0/{data}", headers={"API-KEY": API_KEY}, timeout=5) + req = requests.get(f"{API_URL}/sc/v0/{data}", headers={"API-KEY": API_KEY}, timeout=5, verify=ROOT_CA_FILE) # Check status if req.status_code == 404: |