Skip to content

Instantly share code, notes, and snippets.

@khuppenbauer

khuppenbauer/Flowpack.Behat.FlowContext.php

Last active August 29, 2015 13:55
Show Gist options
  • Save khuppenbauer/8755103 to your computer and use it in GitHub Desktop.
Save khuppenbauer/8755103 to your computer and use it in GitHub Desktop.
Download ZIP
Don't drop the schema for every resetTestFixtures in Flowpack Behat
Raw
Flowpack.Behat.FlowContext.php
<?php
namespace Flowpack\Behat\Tests\Behat;
/* *
* This script belongs to the TYPO3 Flow package "Flowpack.Behat". *
* *
* It is free software; you can redistribute it and/or modify it under *
* the terms of the GNU Lesser General Public License, either version 3 *
* of the License, or (at your option) any later version. *
* *
* The TYPO3 project - inspiring people to share! *
* */
use Behat\Behat\Context\BehatContext;
use TYPO3\Flow\Core\Booting\Scripts;
use TYPO3\Flow\Core\Bootstrap;
use TYPO3\Flow\Configuration\ConfigurationManager;
class FlowContext extends BehatContext {
/**
* @var Bootstrap
*/
static protected $bootstrap;
/**
* @var \TYPO3\Flow\Mvc\Routing\Router
*/
protected $router;
/**
* @var \TYPO3\Flow\Object\ObjectManagerInterface
*/
protected $objectManager;
/**
* @var \Doctrine\DBAL\Schema\Schema
*/
protected static $databaseSchema;
/**
* @var string
*/
protected $lastCommandOutput;
/**
* @param array $parameters
*/
public function __construct(array $parameters) {
if (self::$bootstrap === NULL) {
self::$bootstrap = $this->initializeFlow();
}
$this->objectManager = self::$bootstrap->getObjectManager();
}
/**
* Create a flow bootstrap instance
*/
protected function initializeFlow() {
require_once(__DIR__ . '/../../../../Framework/TYPO3.Flow/Classes/TYPO3/Flow/Core/Bootstrap.php');
if (!defined('FLOW_PATH_ROOT')) {
define('FLOW_PATH_ROOT', realpath(__DIR__ . '/../../../../..') . '/');
}
// The new classloader needs warnings converted to exceptions
if (!defined('BEHAT_ERROR_REPORTING')) {
define('BEHAT_ERROR_REPORTING', E_ALL);
// Load ErrorException class, since it will be used in the Behat error handler
class_exists('Behat\Behat\Exception\ErrorException');
}
$bootstrap = new Bootstrap('Testing/Behat');
Scripts::initializeClassLoader($bootstrap);
Scripts::initializeSignalSlot($bootstrap);
Scripts::initializePackageManagement($bootstrap);
$bootstrap->buildRuntimeSequence()->invoke($bootstrap);
return $bootstrap;
}
/**
* @When /^I run the command "([^"]*)"$/
*/
public function iRunTheCommand($command) {
$this->lastCommandOutput = NULL;
$request = $this->objectManager->get('TYPO3\Flow\Cli\RequestBuilder')->build($command);
$response = new \TYPO3\Flow\Cli\Response();
$dispatcher = $this->objectManager->get('TYPO3\Flow\Mvc\Dispatcher');
$dispatcher->dispatch($request, $response);
$this->lastCommandOutput = $response->getContent();
$this->persistAll();
}
/**
* @Then /^I should see the command output "([^"]*)"$/
*/
public function iShouldSeeTheCommandOutput($line) {
\PHPUnit_Framework_Assert::assertContains($line, explode(PHP_EOL, $this->lastCommandOutput));
}
/**
* @BeforeScenario @fixtures
*/
public function resetTestFixtures($event) {
/** @var \Doctrine\ORM\EntityManager $entityManager */
$entityManager = $this->objectManager->get('Doctrine\Common\Persistence\ObjectManager');
$entityManager->clear();
if (self::$databaseSchema === NULL) {
/** @var \TYPO3\Flow\Persistence\Doctrine\Service $doctrineService */
$doctrineService = $this->objectManager->get('TYPO3\Flow\Persistence\Doctrine\Service');
$doctrineService->executeMigrations();
$schema = $entityManager->getConnection()->getSchemaManager()->createSchema();
self::$databaseSchema = $schema;
// FIXME Check if this is needed at all!
$proxyFactory = $entityManager->getProxyFactory();
$proxyFactory->generateProxyClasses($entityManager->getMetadataFactory()->getAllMetadata());
}
$connection = $entityManager->getConnection();
$tables = self::$databaseSchema->getTables();
switch ($connection->getDatabasePlatform()->getName()) {
case 'mysql':
$sql = 'SET FOREIGN_KEY_CHECKS=0;';
foreach ($tables as $table) {
if ($table->getName() !== 'flow_doctrine_migrationstatus') {
$sql .= 'TRUNCATE `' . $table->getName() . '`;';
}
}
$sql .= 'SET FOREIGN_KEY_CHECKS=1;';
$connection->executeQuery($sql);
break;
case 'postgresql':
default:
foreach ($tables as $table) {
if ($table->getName() !== 'flow_doctrine_migrationstatus') {
$sql = 'TRUNCATE ' . $table->getName() . ' CASCADE;';
}
$connection->executeQuery($sql);
}
break;
}
$this->resetFactories();
}
/**
* Reset factory instances
*
* Must be called after all persistAll calls and before scenarios to have a clean state.
*
* @return void
*/
protected function resetFactories() {
/** @var $reflectionService \TYPO3\Flow\Reflection\ReflectionService */
$reflectionService = $this->objectManager->get('TYPO3\Flow\Reflection\ReflectionService');
$fixtureFactoryClassNames = $reflectionService->getAllSubClassNamesForClass('Flowpack\Behat\Tests\Functional\Fixture\FixtureFactory');
foreach ($fixtureFactoryClassNames as $fixtureFactoyClassName) {
if (!$reflectionService->isClassAbstract($fixtureFactoyClassName)) {
$factory = $this->objectManager->get($fixtureFactoyClassName);
$factory->reset();
}
}
$this->resetRolesAndPolicyService();
}
/**
* Reset policy service and role repository
*
* This is needed to remove cached role entities after resetting the database.
*
* @return void
*/
protected function resetRolesAndPolicyService() {
$this->objectManager->get('TYPO3\Flow\Security\Policy\PolicyService')->reset();
$roleRepository = $this->objectManager->get('TYPO3\Flow\Security\Policy\RoleRepository');
\TYPO3\Flow\Reflection\ObjectAccess::setProperty($roleRepository, 'newRoles', array(), TRUE);
}
/**
* Persist any changes
*/
public function persistAll() {
$this->objectManager->get('TYPO3\Flow\Persistence\PersistenceManagerInterface')->persistAll();
$this->objectManager->get('TYPO3\Flow\Persistence\PersistenceManagerInterface')->clearState();
$this->resetFactories();
}
/**
* @return \TYPO3\Flow\Mvc\Routing\Router
*/
protected function getRouter() {
if ($this->router === NULL) {
$this->router = $this->objectManager->get('\TYPO3\Flow\Mvc\Routing\Router');
$configurationManager = $this->objectManager->get('TYPO3\Flow\Configuration\ConfigurationManager');
$routesConfiguration = $configurationManager->getConfiguration(ConfigurationManager::CONFIGURATION_TYPE_ROUTES);
$this->router->setRoutesConfiguration($routesConfiguration);
}
return $this->router;
}
/**
* Resolve a path by route name or a relative path (as a fallback)
*
* @param string $pageName
* @return string
* @deprecated Use resolvePageUri
*/
public function resolvePath($pageName) {
return $this->resolvePageUri($pageName);
}
/**
* Resolves a URI for the given page name
*
* If a Flow route with a name equal to $pageName exists it will be resolved.
* An absolute path will be used as is for compatibility with the default MinkContext.
*
* @param string $pageName
* @param array $arguments
* @return string
* @throws \InvalidArgumentException
*/
public function resolvePageUri($pageName, array $arguments = NULL) {
$uri = NULL;
if (strpos($pageName, '/') === 0) {
$uri = $pageName;
return $uri;
} else {
$router = $this->getRouter();
/** @var \TYPO3\Flow\Mvc\Routing\Route $route */
foreach ($router->getRoutes() as $route) {
if (preg_match('/::\s*' . preg_quote($pageName, '/') . '$/', $route->getName())) {
$routeValues = $route->getDefaults();
if (is_array($arguments)) {
$routeValues = array_merge($routeValues, $arguments);
}
if ($route->resolves($routeValues)) {
$uri = $route->getMatchingUri();
break;
}
}
}
if ($uri === NULL) {
throw new \InvalidArgumentException('Could not resolve a route for name "' . $pageName . '"');
}
if (strpos($uri, 'http') !== 0 && strpos($uri, '/') !== 0) {
$uri = '/' . $uri;
}
return $uri;
}
}
/**
* @return \TYPO3\Flow\Object\ObjectManagerInterface
*/
public function getObjectManager() {
return $this->objectManager;
}
/**
* @return string
*/
public function getLastCommandOutput() {
return $this->lastCommandOutput;
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment