96 lines
2.2 KiB
PHP
96 lines
2.2 KiB
PHP
<?php
|
|
namespace Doctrine\Tests\ORM\Functional;
|
|
use Doctrine\Tests\Models\CMS\CmsUser;
|
|
use Doctrine\ORM\Event\PostFlushEventArgs;
|
|
use Doctrine\ORM\Events;
|
|
require_once __DIR__ . '/../../TestInit.php';
|
|
|
|
/**
|
|
* PostFlushEventTest
|
|
*
|
|
* @author Daniel Freudenberger <df@rebuy.de>
|
|
*/
|
|
class PostFlushEventTest extends \Doctrine\Tests\OrmFunctionalTestCase
|
|
{
|
|
/**
|
|
* @var PostFlushListener
|
|
*/
|
|
private $listener;
|
|
|
|
protected function setUp()
|
|
{
|
|
$this->useModelSet('cms');
|
|
parent::setUp();
|
|
$this->listener = new PostFlushListener();
|
|
$evm = $this->_em->getEventManager();
|
|
$evm->addEventListener(Events::postFlush, $this->listener);
|
|
}
|
|
|
|
public function testListenerShouldBeNotified()
|
|
{
|
|
$this->_em->persist($this->createNewValidUser());
|
|
$this->_em->flush();
|
|
$this->assertTrue($this->listener->wasNotified);
|
|
}
|
|
|
|
public function testListenerShouldNotBeNotifiedWhenFlushThrowsException()
|
|
{
|
|
$user = new CmsUser();
|
|
$user->username = 'dfreudenberger';
|
|
$this->_em->persist($user);
|
|
$exceptionRaised = false;
|
|
|
|
try {
|
|
$this->_em->flush();
|
|
} catch (\Exception $ex) {
|
|
$exceptionRaised = true;
|
|
}
|
|
|
|
$this->assertTrue($exceptionRaised);
|
|
$this->assertFalse($this->listener->wasNotified);
|
|
}
|
|
|
|
public function testListenerShouldReceiveEntityManagerThroughArgs()
|
|
{
|
|
$this->_em->persist($this->createNewValidUser());
|
|
$this->_em->flush();
|
|
$receivedEm = $this->listener->receivedArgs->getEntityManager();
|
|
$this->assertSame($this->_em, $receivedEm);
|
|
}
|
|
|
|
/**
|
|
* @return CmsUser
|
|
*/
|
|
private function createNewValidUser()
|
|
{
|
|
$user = new CmsUser();
|
|
$user->username = 'dfreudenberger';
|
|
$user->name = 'Daniel Freudenberger';
|
|
return $user;
|
|
}
|
|
}
|
|
|
|
class PostFlushListener
|
|
{
|
|
/**
|
|
* @var bool
|
|
*/
|
|
public $wasNotified = false;
|
|
|
|
/**
|
|
* @var PostFlushEventArgs
|
|
*/
|
|
public $receivedArgs;
|
|
|
|
/**
|
|
* @param PostFlushEventArgs $args
|
|
*/
|
|
public function postFlush(PostFlushEventArgs $args)
|
|
{
|
|
$this->wasNotified = true;
|
|
$this->receivedArgs = $args;
|
|
}
|
|
}
|
|
|
|
|