FriendsOfSymfony / FOSElasticaBundle

 */

abstract class ListenerTest extends \PHPUnit_Framework_TestCase

{

    public function testObjectInsertedOnPersist()

    {

        $entity = new Listener\Entity(1);

        $persister = $this->getMockPersister($entity, 'index', 'type');

        $eventArgs = $this->createLifecycleEventArgs($entity, $this->getMockObjectManager());

        $indexable = $this->getMockIndexable('index', 'type', $entity, true);

        $listener = $this->createListener($persister, $indexable, array('indexName' => 'index', 'typeName' => 'type'));

        $listener->postPersist($eventArgs);

        $this->assertEquals($entity, current($listener->scheduledForInsertion));

        $persister->expects($this->once())

            ->method('insertMany')

            ->with($listener->scheduledForInsertion);

        $listener->postFlush($eventArgs);

    }

    public function testPersistDeferred()

    {

        $listener->postFlush($eventArgs);

    }

    public function testPersistDeferred()

    {

        $entity = new Listener\Entity(1);

        $persister = $this->getMockPersister($entity, 'index', 'type');

        $eventArgs = $this->createLifecycleEventArgs($entity, $this->getMockObjectManager());

        $indexable = $this->getMockIndexable('index', 'type', $entity, true);

        $listener = $this->createListener($persister, $indexable, array('indexName' => 'index', 'typeName' => 'type', 'defer' => true));

        $listener->postPersist($eventArgs);

        $this->assertEquals($entity, current($listener->scheduledForInsertion));

        $persister->expects($this->never())->method('insertMany');

        $listener->postFlush($eventArgs);

    }

    public function testNonIndexableObjectNotInsertedOnPersist()

    {