Elastica\Test\Processor\ConvertProcessorTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	testConvert()	0	13	1
A	testConvertWithNonDefaultOptions()	0	28	1
A	testConvertField()	0	33	2

<?php

namespace Elastica\Test\Processor;

use Elastica\Bulk;
use Elastica\Document;
use Elastica\Processor\ConvertProcessor;
use Elastica\Test\BasePipeline as BasePipelineTest;

/**
 * @internal
 */
class ConvertProcessorTest extends BasePipelineTest
{
    /**
     * @group unit
     */
    public function testConvert(): void
    {
        $processor = new ConvertProcessor('foo', 'integer');

        $expected = [
            'convert' => [
                'field' => 'foo',
                'type' => 'integer',
            ],
        ];

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

    /**
     * @group unit
     */
    public function testConvertWithNonDefaultOptions(): void
    {
        $processor = new ConvertProcessor('foo', 'integer');
        $processor->setIgnoreMissing(true);

        $expected = [
            'convert' => [
                'field' => 'foo',
                'type' => 'integer',
                'ignore_missing' => true,
            ],
        ];

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

        $processor->setTargetField('field2');

        $expected = [
            'convert' => [
                'field' => 'foo',
                'type' => 'integer',
                'ignore_missing' => true,
                'target_field' => 'field2',
            ],
        ];

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

    /**
     * @group functional
     */
    public function testConvertField(): void
    {
        $append = new ConvertProcessor('foo', 'float');

        $pipeline = $this->_createPipeline('my_custom_pipeline', 'pipeline for Convert');
        $pipeline->addProcessor($append)->create();

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

        $bulk->addDocuments([
            new Document(null, ['name' => 'ruflin', 'type' => 'elastica', 'foo' => '5.290']),
            new Document(null, ['name' => 'nicolas', 'type' => 'elastica', 'foo' => '6.908']),
        ]);
        $bulk->setRequestParam('pipeline', 'my_custom_pipeline');

        $bulk->send();
        $index->refresh();

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

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

$result->getResults() is of type array<integer,object<Elastica\Result>>, but the function expects a object<Countable>|object<PHPUnit\Framework\iterable>.

        $results = $result->getResults();
        foreach ($results as $result) {
            $value = $result->getData();
            $this->assertIsFloat($value['foo']);
        }

        $this->assertSame(5.290, ($results[0]->getHit())['_source']['foo']);
        $this->assertSame(6.908, ($results[1]->getHit())['_source']['foo']);
    }
}