Added ReindexTest

tests/integration/ReindexTest.lua

@@ -0,0 +1,37 @@
+--  Tests:
+--    reindex()
+--
+
+-- Setting up environment
+local _ENV = lunit.TEST_CASE "tests.integration.ReindexTest"
+
+local index1 = "elasticsearch-lua-reindex-index-1"
+local index2 = "elasticsearch-lua-reindex-index-2"
+
+function test()
+  local dataset_1 = util.subarr(dataset, 1, math.floor(#dataset/2))
+  local dataset_2 = util.subarr(dataset, math.floor(#dataset/2) + 1, #dataset)
+  local searchBody = {
+    query = {
+      match = {
+        type = "PushEvent"
+      }
+    }
+  }
+
+  operations.bulkDelete(dataset, index1)
+  operations.bulkDelete(dataset, index2)
+  operations.bulkIndex(dataset_1, index1)
+  operations.getNonExistingDocuments(dataset_1, index2)
+  operations.reindex(index1, index2)
+  operations.getExistingDocuments(dataset_1, index2)
+  operations.bulkIndex(dataset_2, index1)
+  operations.getNonExistingDocuments(dataset_2, index2)
+  operations.reindex(index1, index2, searchBody)
+  local res = operations.searchBody(searchBody, index2)
+  assert_equal(103, res.hits.total)
+  operations.reindex(index1, index2)
+  operations.getExistingDocuments(dataset, index2)
+  operations.bulkDelete(dataset, index1)
+  operations.bulkDelete(dataset, index2)
+end

tests/integration/init.lua

@@ -5,5 +5,6 @@ operations = require "integration.operations"
 -- Integration tests
 require "integration.BasicTest"
 require "integration.BulkTest"
-require "integration.SearchTest"
 require "integration.ScanAndScrollTest"
+require "integration.SearchTest"
+require "integration.ReindexTest"