Elastica\Test\Processor\FailProcessorTest::testFailField()

Complexity

Conditions	2
Paths	4

Size

Total Lines

27

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function testFailField(): void
    {
        $fail = new FailProcessor('custom error fail message');
        $json = new Json('name');

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

        $index = $this->_createIndex();

        // Add document to normal index
        $doc1 = new Document(null, ['name' => '']);

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

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

        try {
            $bulk->send();
            $index->refresh();
            $this->fail('test should raise an exception!');
        } catch (\Exception $e) {
            $this->assertStringContainsString('custom error fail message', $e->getMessage());
        }
    }
}