Elastica\Test\Processor\JsonProcessorTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	73
Duplicated Lines	42.47 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	testJson()	0	12	1
A	testJsonWithNonDefaultOptions()	0	16	1
A	testJsonField()	31	31	2

<?php

namespace Elastica\Test\Processor;

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

/**
 * @internal
 */
class JsonProcessorTest extends BasePipelineTest
{
    /**
     * @group unit
     */
    public function testJson(): void
    {
        $processor = new JsonProcessor('string_source');

        $expected = [
            'json' => [
                'field' => 'string_source',
            ],
        ];

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

    /**
     * @group unit
     */
    public function testJsonWithNonDefaultOptions(): void
    {
        $processor = new JsonProcessor('string_source');
        $processor->setTargetField('json_target');
        $processor->setAddToRoot(true);

        $expected = [
            'json' => [
                'field' => 'string_source',
                'target_field' => 'json_target',
                'add_to_root' => true,
            ],
        ];

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

    /**
     * @group functional
     */
    public function testJsonField(): void

This method seems to be duplicated in your project.

    {
        $json = new JsonProcessor('name');
        $json->setTargetField('realname');

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

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

        $bulk->addDocument(new Document(null, ['name' => \json_encode(['foo' => 2000])]));
        $bulk->setRequestParam('pipeline', 'my_custom_pipeline');

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

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

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

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

        $resultExpected = [
            'foo' => 2000,
        ];

        foreach ($result->getResults() as $rx) {
            $value = $rx->getData();
            $this->assertEquals($resultExpected, $value['realname']);
        }
    }
}