ruflin / Elastica

    /**

     * @group functional

     */

    public function testDotExpanderField(): void

    {

        $dotExpander = new DotExpanderProcessor('foo.bar');

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

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

        $index = $this->_createIndex();

        // Add document to normal index

        $doc1 = new Document(null, ['foo.bar' => 'value']);

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

        $bulk->setIndex($index);

        $bulk->addDocument($doc1);

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

        $bulk->send();

        $index->refresh();

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

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

        $expect = [

            'foo' => [

                'bar' => 'value',

            ],

        ];

        $results = $result->getResults();

        $this->assertEquals($expect, ($results[0]->getHit())['_source']);

    }

}

    /**

     * @group functional

     */

    public function testJsonField(): void

    {

        $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());

        $resultExpected = [

            'foo' => 2000,

        ];

        foreach ($result->getResults() as $rx) {

            $value = $rx->getData();

            $this->assertEquals($resultExpected, $value['realname']);

        }

    }

}