Elastica\Test\Processor\KvProcessorTest

Complexity

Total Complexity

3

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	testKv()	0	14	1
A	testKvWithNonDefaultOptions()	0	22	1
A	testKVIncludeExludeKeys()	0	20	1

<?php

namespace Elastica\Test\Processor;

use Elastica\Processor\KvProcessor;
use Elastica\Test\BasePipeline as BasePipelineTest;

/**
 * @internal
 */
class KvProcessorTest extends BasePipelineTest
{
    /**
     * @group unit
     */
    public function testKv(): void
    {
        $processor = new KvProcessor('message', ' ', '=');

        $expected = [
            'kv' => [
                'field' => 'message',
                'field_split' => ' ',
                'value_split' => '=',
            ],
        ];

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

    /**
     * @group unit
     */
    public function testKvWithNonDefaultOptions(): void
    {
        $processor = new KvProcessor('message', ' ', '=');
        $processor->setTargetField('target_field');
        $processor->setIncludeKeys(['l1', 'l2']);
        $processor->setExcludeKeys(['l4', 'l5']);
        $processor->setIgnoreMissing(true);

        $expected = [
            'kv' => [
                'field' => 'message',
                'field_split' => ' ',
                'value_split' => '=',
                'target_field' => 'target_field',
                'include_keys' => ['l1', 'l2'],
                'exclude_keys' => ['l4', 'l5'],
                'ignore_missing' => true,
            ],
        ];

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

    /**
     * @group functional
     */
    public function testKVIncludeExludeKeys(): void
    {
        $kv = new KvProcessor('field1', '&', '=');
        $kv->setExcludeKeys(['second']);

        $pipeline = $this->_createPipeline('my_custom_pipeline', 'pipeline for KV');
        $pipeline->addProcessor($kv);

        $result = $pipeline->create();

        $this->assertArrayHasKey('acknowledged', $result->getData());
        $this->assertTrue($result->getData()['acknowledged']);

        $pipelineGet = $pipeline->getPipeline('my_custom_pipeline');
        $result = $pipelineGet->getData();

        $this->assertSame('field1', $result['my_custom_pipeline']['processors'][0]['kv']['field']);
        $this->assertSame('&', $result['my_custom_pipeline']['processors'][0]['kv']['field_split']);
        $this->assertSame('=', $result['my_custom_pipeline']['processors'][0]['kv']['value_split']);
    }
}