From 8c91e7cf4c321a17698b0e699c991e47fbe78c3a Mon Sep 17 00:00:00 2001 From: Gabor Gyimesi Date: Wed, 18 Sep 2024 16:55:35 +0200 Subject: [PATCH 1/2] MINIFICPP-2456 Remove curl output from Elasticsearch responses --- .../cluster/checkers/ElasticSearchChecker.py | 15 +++++++++------ docker/test/integration/features/utils.py | 2 +- 2 files changed, 10 insertions(+), 7 deletions(-) diff --git a/docker/test/integration/cluster/checkers/ElasticSearchChecker.py b/docker/test/integration/cluster/checkers/ElasticSearchChecker.py index 34186cc4ef..d0569c2dbe 100644 --- a/docker/test/integration/cluster/checkers/ElasticSearchChecker.py +++ b/docker/test/integration/cluster/checkers/ElasticSearchChecker.py @@ -20,27 +20,30 @@ def __init__(self, container_communicator): self.container_communicator = container_communicator def is_elasticsearch_empty(self, container_name): - (code, output) = self.container_communicator.execute_command(container_name, ["curl", "-u", "elastic:password", "-k", "-XGET", "https://localhost:9200/_search"]) + (code, output) = self.container_communicator.execute_command(container_name, ["curl", "-s", "-u", "elastic:password", "-k", "-XGET", "https://localhost:9200/_search"]) return code == 0 and '"hits":[]' in output def create_doc_elasticsearch(self, container_name, index_name, doc_id): (code, output) = self.container_communicator.execute_command(container_name, ["/bin/bash", "-c", - "curl -u elastic:password -k -XPUT https://localhost:9200/" + index_name + "/_doc/" + doc_id + " -H Content-Type:application/json -d'{\"field1\":\"value1\"}'"]) + "curl -s -u elastic:password -k -XPUT https://localhost:9200/" + index_name + "/_doc/" + doc_id + " -H Content-Type:application/json -d'{\"field1\":\"value1\"}'"]) return code == 0 and ('"_id":"' + doc_id + '"') in output def check_elastic_field_value(self, container_name, index_name, doc_id, field_name, field_value): (code, output) = self.container_communicator.execute_command(container_name, ["/bin/bash", "-c", - "curl -u elastic:password -k -XGET https://localhost:9200/" + index_name + "/_doc/" + doc_id]) + "curl -s -u elastic:password -k -XGET https://localhost:9200/" + index_name + "/_doc/" + doc_id]) return code == 0 and (field_name + '":"' + field_value) in output def elastic_generate_apikey(self, elastic_container_name): - (_, output) = self.container_communicator.execute_command(elastic_container_name, ["/bin/bash", "-c", - "curl -u elastic:password -k -XPOST https://localhost:9200/_security/api_key -H Content-Type:application/json -d'{\"name\":\"my-api-key\",\"expiration\":\"1d\",\"role_descriptors\":{\"role-a\": {\"cluster\": [\"all\"],\"index\": [{\"names\": [\"my_index\"],\"privileges\": [\"all\"]}]}}}'"]) + (code, output) = self.container_communicator.execute_command(elastic_container_name, ["/bin/bash", "-c", + "curl -s -u elastic:password -k -XPOST https://localhost:9200/_security/api_key -H Content-Type:application/json -d'{\"name\":\"my-api-key\",\"expiration\":\"1d\",\"role_descriptors\":{\"role-a\": {\"cluster\": [\"all\"],\"index\": [{\"names\": [\"my_index\"],\"privileges\": [\"all\"]}]}}}'"]) + if code != 0: + return None output_lines = output.splitlines() + print(output_lines) result = json.loads(output_lines[-1]) return result["encoded"] def add_elastic_user_to_opensearch(self, container_name): (code, output) = self.container_communicator.execute_command(container_name, ["/bin/bash", "-c", - 'curl -u admin:admin -k -XPUT https://{hostname}:9200/_plugins/_security/api/internalusers/elastic -H Content-Type:application/json -d\'{{"password":"password","backend_roles":["admin"]}}\''.format(hostname=container_name)]) + 'curl -s -u admin:admin -k -XPUT https://{hostname}:9200/_plugins/_security/api/internalusers/elastic -H Content-Type:application/json -d\'{{"password":"password","backend_roles":["admin"]}}\''.format(hostname=container_name)]) return code == 0 and '"status":"CREATED"' in output diff --git a/docker/test/integration/features/utils.py b/docker/test/integration/features/utils.py index 15db614d27..bd86cbab09 100644 --- a/docker/test/integration/features/utils.py +++ b/docker/test/integration/features/utils.py @@ -25,7 +25,7 @@ def retry_check(max_tries=5, retry_interval=1): def retry_check_func(func): @functools.wraps(func) def retry_wrapper(*args, **kwargs): - for i in range(max_tries): + for _ in range(max_tries): if func(*args, **kwargs): return True time.sleep(retry_interval) From ca4009e5ee38e24349b6d8b3fde61d8be218826a Mon Sep 17 00:00:00 2001 From: Gabor Gyimesi Date: Fri, 20 Sep 2024 16:35:45 +0200 Subject: [PATCH 2/2] Review update --- docker/test/integration/cluster/checkers/ElasticSearchChecker.py | 1 - 1 file changed, 1 deletion(-) diff --git a/docker/test/integration/cluster/checkers/ElasticSearchChecker.py b/docker/test/integration/cluster/checkers/ElasticSearchChecker.py index d0569c2dbe..e35baa25c4 100644 --- a/docker/test/integration/cluster/checkers/ElasticSearchChecker.py +++ b/docker/test/integration/cluster/checkers/ElasticSearchChecker.py @@ -39,7 +39,6 @@ def elastic_generate_apikey(self, elastic_container_name): if code != 0: return None output_lines = output.splitlines() - print(output_lines) result = json.loads(output_lines[-1]) return result["encoded"]