ruflin / Elastica

/**

 * @internal

 */

class LowercaseProcessorTest extends BasePipelineTest

{

    /**

     * @group unit

     */

    public function testLowercase(): void

    {

        $processor = new LowercaseProcessor('foo');

        $expected = [

            'lowercase' => [

                'field' => 'foo',

            ],

        ];

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

    }

    /**

     * @group functional

     */

    public function testLowercaseField(): void

    {

        $lcase = new LowercaseProcessor('name');

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

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

        $index = $this->_createIndex();

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

        $bulk->setIndex($index);

        $bulk->addDocuments([

            new Document(null, ['name' => 'RUFLIN']),

            new Document(null, ['name' => 'NICOLAS']),

        ]);

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

        $bulk->send();

        $index->refresh();

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

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

        $results = $result->getResults();

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

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

    }

}

/**

 * @internal

 */

class TrimProcessorTest extends BasePipelineTest

{

    /**

     * @group unit

     */

    public function testTrim(): void

    {

        $processor = new TrimProcessor('foo');

        $expected = [

            'trim' => [

                'field' => 'foo',

            ],

        ];

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

    }

    /**

     * @group functional

     */

    public function testTrimField(): void

    {

        $trim = new TrimProcessor('name');

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

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

        $index = $this->_createIndex();

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

        $bulk->setIndex($index);

        $bulk->addDocuments([

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

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

        ]);

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

        $bulk->send();

        $index->refresh();

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

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

        $results = $result->getResults();

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

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

    }

}

/**

 * @internal

 */

class UppercaseProcessorTest extends BasePipelineTest

{

    /**

     * @group unit

     */

    public function testUppercase(): void

    {

        $processor = new UppercaseProcessor('foo');

        $expected = [

            'uppercase' => [

                'field' => 'foo',

            ],

        ];

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

    }

    /**

     * @group functional

     */

    public function testUppercaseField(): void

    {

        $ucase = new UppercaseProcessor('name');

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

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

        $index = $this->_createIndex();

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

        $bulk->setIndex($index);

        $bulk->addDocuments([

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

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

        ]);

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

        $bulk->send();

        $index->refresh();

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

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

        $results = $result->getResults();

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

        $this->assertSame('NICOLAS', ($results[1]->getHit())['_source']['name']);

    }

}