ruflin / Elastica

/**

 * @internal

 */

class RenameProcessorTest extends BasePipelineTest

{

    /**

     * @group unit

     */

    public function testRename(): void

    {

        $processor = new RenameProcessor('foo', 'foobar');

        $expected = [

            'rename' => [

                'field' => 'foo',

                'target_field' => 'foobar',

            ],

        ];

        $this->assertEquals($expected, $processor->toArray());

    }

    /**

     * @group unit

     */

    public function testRenameWithNonDefaultOptions(): void

    {

        $processor = new RenameProcessor('foo', 'foobar');

        $processor->setIgnoreMissing(true);

        $expected = [

            'rename' => [

                'field' => 'foo',

                'target_field' => 'foobar',

                'ignore_missing' => true,

            ],

        ];

        $this->assertEquals($expected, $processor->toArray());

    }

    /**

     * @group functional

     */

    public function testRenameField(): void

    {

        $rename = new RenameProcessor('package', 'packages');

        $pipeline = $this->_createPipeline('my_custom_pipeline', 'pipeline for Rename');

        $pipeline->addProcessor($rename)->create();

        $index = $this->_createIndex();

        $bulk = new Bulk($index->getClient());

        $bulk->setIndex($index);

        $bulk->addDocuments([

            new Document(null, ['name' => 'nicolas', 'package' => 'Elastico']),

        ]);

        $bulk->setRequestParam('pipeline', 'my_custom_pipeline');

        $bulk->send();

        $index->refresh();

        $result = $index->search('*');

        $this->assertCount(1, $result->getResults());

        $results = $result->getResults();

        $this->assertArrayHasKey('packages', ($results[0]->getHit())['_source']);

    }

}

/**

 * @internal

 */

class SplitProcessorTest extends BasePipelineTest

{

    /**

     * @group unit

     */

    public function testSplit(): void

    {

        $processor = new SplitProcessor('joined_array_field', '-');

        $expected = [

            'split' => [

                'field' => 'joined_array_field',

                'separator' => '-',

            ],

        ];

        $this->assertEquals($expected, $processor->toArray());

    }

    /**

     * @group unit

     */

    public function testSplitWithNonDefaultOptions(): void

    {

        $processor = new SplitProcessor('joined_array_field', '-');

        $processor->setIgnoreMissing(true);

        $expected = [

            'split' => [

                'field' => 'joined_array_field',

                'separator' => '-',

                'ignore_missing' => true,

            ],

        ];

        $this->assertEquals($expected, $processor->toArray());

    }

    /**

     * @group functional

     */

    public function testSplitField(): void

    {

        $split = new SplitProcessor('name', '&');

        $pipeline = $this->_createPipeline('my_custom_pipeline', 'pipeline for Split');

        $pipeline->addProcessor($split)->create();

        $index = $this->_createIndex();

        $bulk = new Bulk($index->getClient());

        $bulk->setIndex($index);

        $bulk->addDocuments([

            new Document(null, ['name' => 'nicolas&ruflin']),

        ]);

        $bulk->setRequestParam('pipeline', 'my_custom_pipeline');

        $bulk->send();

        $index->refresh();

        $result = $index->search('*');

        $this->assertCount(1, $result->getResults());

        $results = $result->getResults();

        $this->assertSame(['nicolas', 'ruflin'], ($results[0]->getHit())['_source']['name']);

    }

}