1 files changed, 135 insertions, 0 deletions
diff --git a/vendor/ruflin/elastica/test/lib/Elastica/Test/Tool/CrossIndexTest.php b/vendor/ruflin/elastica/test/lib/Elastica/Test/Tool/CrossIndexTest.php
new file mode 100644
index 00000000..f8fbf280
--- /dev/null
+++ b/vendor/ruflin/elastica/test/lib/Elastica/Test/Tool/CrossIndexTest.php
@@ -0,0 +1,135 @@
+<?php
+namespace Elastica\Test\Tool;
+
+use Elastica\Document;
+use Elastica\Test\Base;
+use Elastica\Tool\CrossIndex;
+use Elastica\Type;
+
+class CrossIndexTest extends Base
+{
+    /**
+     * Test default reindex.
+     */
+    public function testReindex()
+    {
+        $oldIndex = $this->_createIndex(null, true, 2);
+        $this->_addDocs($oldIndex->getType('crossIndexTest'), 10);
+
+        $newIndex = $this->_createIndex(null, true, 2);
+
+        $this->assertInstanceOf(
+            'Elastica\Index',
+            CrossIndex::reindex($oldIndex, $newIndex)
+        );
+
+        $this->assertEquals(10, $newIndex->count());
+    }
+
+    /**
+     * Test reindex type option.
+     */
+    public function testReindexTypeOption()
+    {
+        $oldIndex = $this->_createIndex('', true, 2);
+        $type1 = $oldIndex->getType('crossIndexTest_1');
+        $type2 = $oldIndex->getType('crossIndexTest_2');
+
+        $docs1 = $this->_addDocs($type1, 10);
+        $docs2 = $this->_addDocs($type2, 10);
+
+        $newIndex = $this->_createIndex(null, true, 2);
+
+        // \Elastica\Type
+        CrossIndex::reindex($oldIndex, $newIndex, array(
+            CrossIndex::OPTION_TYPE => $type1,
+        ));
+        $this->assertEquals(10, $newIndex->count());
+        $newIndex->deleteDocuments($docs1);
+
+        // string
+        CrossIndex::reindex($oldIndex, $newIndex, array(
+            CrossIndex::OPTION_TYPE => 'crossIndexTest_2',
+        ));
+        $this->assertEquals(10, $newIndex->count());
+        $newIndex->deleteDocuments($docs2);
+
+        // array
+        CrossIndex::reindex($oldIndex, $newIndex, array(
+            CrossIndex::OPTION_TYPE => array(
+                'crossIndexTest_1',
+                $type2,
+            ),
+        ));
+        $this->assertEquals(20, $newIndex->count());
+    }
+
+    /**
+     * Test default copy.
+     */
+    public function testCopy()
+    {
+        $oldIndex = $this->_createIndex(null, true, 2);
+        $newIndex = $this->_createIndex(null, true, 2);
+
+        $oldType = $oldIndex->getType('copy_test');
+        $oldMapping = array(
+            'name' => array(
+                'type' => 'string',
+                'store' => true,
+            ),
+        );
+        $oldType->setMapping($oldMapping);
+        $docs = $this->_addDocs($oldType, 10);
+
+        // mapping
+        $this->assertInstanceOf(
+            'Elastica\Index',
+            CrossIndex::copy($oldIndex, $newIndex)
+        );
+
+        $newMapping = $newIndex->getType('copy_test')->getMapping();
+        if (!isset($newMapping['copy_test']['properties']['name'])) {
+            $this->fail('could not request new mapping');
+        }
+
+        $this->assertEquals(
+            $oldMapping['name'],
+            $newMapping['copy_test']['properties']['name']
+        );
+
+        // document copy
+        $this->assertEquals(10, $newIndex->count());
+        $newIndex->deleteDocuments($docs);
+
+        // ignore mapping
+        $ignoredType = $oldIndex->getType('copy_test_1');
+        $this->_addDocs($ignoredType, 10);
+
+        CrossIndex::copy($oldIndex, $newIndex, array(
+            CrossIndex::OPTION_TYPE => $oldType,
+        ));
+
+        $this->assertFalse($newIndex->getType($ignoredType->getName())->exists());
+        $this->assertEquals(10, $newIndex->count());
+    }
+
+    /**
+     * @param Type $type
+     * @param int  $docs
+     *
+     * @return array
+     */
+    private function _addDocs(Type $type, $docs)
+    {
+        $insert = array();
+        for ($i = 1; $i <= $docs; $i++) {
+            $insert[] = new Document($i, array('_id' => $i, 'key' => 'value'));
+        }
+
+        $type->addDocuments($insert);
+        $type->getIndex()->refresh();
+
+        return $insert;
+    }
+}