martinzink commented on code in PR #1349:
URL: https://github.com/apache/nifi-minifi-cpp/pull/1349#discussion_r907636408
##########
docker/test/integration/steps/steps.py:
##########
@@ -410,6 +411,62 @@ def step_impl(context):
context.test.acquire_container("fake-gcs-server", "fake-gcs-server")
+# elasticsearch
+@given('an Elasticsearch server is set up and running')
+@given('an Elasticsearch server is set up and a single document is present
with "preloaded_id" in "my_index"')
+@given('an Elasticsearch server is set up and a single document is present
with "preloaded_id" in "my_index" with "value1" in "field1"')
+def step_impl(context):
+ context.test.start_elasticsearch()
+ context.test.create_doc_elasticsearch("elasticsearch", "my_index",
"preloaded_id")
+
+
+# opensearch
+@given('an Opensearch server is set up and running')
+@given('an Opensearch server is set up and a single document is present with
"preloaded_id" in "my_index"')
+@given('an Opensearch server is set up and a single document is present with
"preloaded_id" in "my_index" with "value1" in "field1"')
+def step_impl(context):
+ context.test.start_opensearch()
+ context.test.add_elastic_user_to_opensearch("opensearch")
+ context.test.create_doc_elasticsearch("opensearch", "my_index",
"preloaded_id")
+
+
+@given(u'a SSL context service is set up for PostElasticsearch and
Elasticsearch')
+def step_impl(context):
+ minifi_crt_file = '/tmp/resources/elasticsearch/minifi_client.crt'
+ minifi_key_file = '/tmp/resources/elasticsearch/minifi_client.key'
+ root_ca_crt_file = '/tmp/resources/elasticsearch/root_ca.crt'
+ ssl_context_service = SSLContextService(cert=minifi_crt_file,
ca_cert=root_ca_crt_file, key=minifi_key_file)
+ put_elasticsearch_json = context.test.get_node_by_name("PostElasticsearch")
+ put_elasticsearch_json.controller_services.append(ssl_context_service)
+ put_elasticsearch_json.set_property("SSL Context Service",
ssl_context_service.name)
Review Comment:
good catch, I renamed the processor later in the dev cycle... fixed in
https://github.com/apache/nifi-minifi-cpp/pull/1349/commits/fa725ffb8fc830c7cf8518f40334d7ee9fa0df13#diff-dce84c359f2f7128e501f5a322d8f6ac3325c2b471844f2c42cbef9abca58185R439-R441
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
