From 06dc3d8e687a92b9d13b2dbc2aedef6220558f29 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Luk=C3=A1=C5=A1=20Vl=C4=8Dek?= <lukas.vlcek@gmail.com>
Date: Thu, 10 Jun 2021 17:56:54 +0200
Subject: [PATCH] Test aliases by matching index template

When incoming document is redirected to the initial index
then we want to make sure that any additional aliases defined
by matching index templates are created as well.
---
 .../rest-api-spec/test/ingest/10_basic.yml    |   2 +-
 .../test/ingest/40_generated_template.yml     | 110 ++++++++++++++++++
 2 files changed, 111 insertions(+), 1 deletion(-)
 create mode 100644 src/test/resources/rest-api-spec/test/ingest/40_generated_template.yml

diff --git a/src/test/resources/rest-api-spec/test/ingest/10_basic.yml b/src/test/resources/rest-api-spec/test/ingest/10_basic.yml
index ed104de..92e6492 100644
--- a/src/test/resources/rest-api-spec/test/ingest/10_basic.yml
+++ b/src/test/resources/rest-api-spec/test/ingest/10_basic.yml
@@ -1,5 +1,5 @@
 ---
-"Verify we have cluster with expectd number of nodes":
+"Verify we have cluster with expected number of nodes":
   - do:
       cluster.health:
         wait_for_nodes: 2
diff --git a/src/test/resources/rest-api-spec/test/ingest/40_generated_template.yml b/src/test/resources/rest-api-spec/test/ingest/40_generated_template.yml
new file mode 100644
index 0000000..34708f0
--- /dev/null
+++ b/src/test/resources/rest-api-spec/test/ingest/40_generated_template.yml
@@ -0,0 +1,110 @@
+---
+"Define pipeline, verify that additional index templates will be applied on matching indices.":
+  # Turn on logging in our package
+  # Logs are found in "build/cluster/integTestCluster node#/elasticsearch-6.8.6/logs"
+  - do:
+      cluster.put_settings:
+        body:
+          transient:
+            action.auto_create_index: "-*-write,+*"
+            logger:
+              org.elasticsearch.ingest.openshift: "TRACE"
+              org.elasticsearch.action: "DEBUG"
+        flat_settings: true
+  - match: { acknowledged: true }
+
+  # Create simple pipeline with our Openshift processor
+  - do:
+      ingest.put_pipeline:
+        id: "openshift_schema"
+        body:  >
+          {
+            "description": "_description",
+            "processors": [
+              {
+                "openshift-ingestion-processor": {
+                }
+              }
+            ]
+          }
+  - match: { acknowledged: true }
+
+  - do:
+      ingest.get_pipeline:
+        id: "openshift_schema"
+  - match: { openshift_schema.description: "_description" }
+  - match: { openshift_schema.processors.0.openshift-ingestion-processor: {} }
+
+  # Elasticsearch Operator (https://github.com/openshift/elasticsearch-operato) create
+  # and push some index templates to make sure newly created indices will get some
+  # predefined index aliases (as of writing this is part of index_management.go).
+  #
+  # In this test we verify that such index templates are applied on indices
+  # if they are redirected to initial index (-000001) instead of passing them
+  # through write index alias.
+  - do:
+      indices.put_template:
+        name: "ocp-gen-infra"
+        body: >
+          {
+            "order" : 0,
+            "index_patterns" : [
+              "infra*"
+            ],
+            "settings" : {
+              "index" : {
+                "number_of_shards" : "3",
+                "number_of_replicas" : "1"
+              }
+            },
+            "mappings" : { },
+            "aliases" : {
+              "infra" : { },
+              "logs.infra" : { }
+            }
+          }
+  - match: { acknowledged: true }
+
+  # Index documents and pass it through the pipeline
+  - do:
+      create:
+        index:  infra-foo-write
+        type:   _doc
+        id:     1
+        body:   {
+          message: "Lorem ipsum dolor sit amet."
+        }
+        pipeline: openshift_schema
+
+  # Give cluster a short moment to create aliases.
+  # Waiting for condition that will not be met and timeout.
+  - do:
+      catch: request_timeout
+      cluster.health:
+        wait_for_nodes: 3
+        timeout: 500ms
+
+  - match: { number_of_nodes: 2 }
+
+  # Verify index aliases
+  # We expect both the aliases from index template and index alias by the ingest plugin
+  - do:
+      indices.get:
+        index: infra-foo-*
+
+  - match: { infra-foo-000001.aliases:  { "infra": {}, "logs.infra": {}, "infra-foo-write": { "is_write_index": true } }}
+
+  # =============================
+  # Clean up
+  - do:
+      ingest.delete_pipeline:
+        id: "openshift_schema"
+  - match: { acknowledged: true }
+
+  - do:
+      indices.delete:
+        index: "infra-foo-*"
+
+  - do:
+      indices.delete_template:
+        name: "ocp-gen-infra"