diff --git a/.docheader b/.docheader new file mode 100644 index 0000000..fefcd81 --- /dev/null +++ b/.docheader @@ -0,0 +1,16 @@ +/* + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS + * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT + * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR + * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT + * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, + * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT + * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE + * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + * + * This software consists of voluntary contributions made by many individuals + * and is licensed under the MIT license. + */ diff --git a/.env.example b/.env.example new file mode 100644 index 0000000..e69f3ac --- /dev/null +++ b/.env.example @@ -0,0 +1,3 @@ +DB_DSN=mysql:host=localhost;dbname=conticket +DB_USER=root +DB_PASSWORD= diff --git a/.gitignore b/.gitignore index b2a0a49..8379cb4 100644 --- a/.gitignore +++ b/.gitignore @@ -3,6 +3,7 @@ composer.phar composer.lock bin vendor/ +.env app/cache/* app/logs/* app/phpunit.xml diff --git a/.travis.yml b/.travis.yml index 816256d..4aa3a41 100644 --- a/.travis.yml +++ b/.travis.yml @@ -6,39 +6,16 @@ env: - BASE_URL=127.0.0.1:8080 php: - - 5.6 - - 7 + - 7.1 matrix: allow_failures: - - php: 7 - -services: mongodb - -before_script: - - echo "extension = mongo.so" >> ~/.phpenv/versions/$(phpenv version-name)/etc/php.ini - - - composer selfupdate - - composer install --no-interaction --prefer-dist --no-scripts - - - chmod -R 777 app/cache app/logs - - app/console --env=test cache:warmup - - chmod -R 777 app/cache app/logs - - - app/console doctrine:mongodb:schema:create - - app/console doctrine:mongodb:fixtures:load - - - app/console server:run 127.0.0.1:8080 --no-debug > webserver.log 2>&1 & - - - sh -e /etc/init.d/xvfb start - - export DISPLAY=:99.0 - - wget http://selenium.googlecode.com/files/selenium-server-standalone-2.31.0.jar - - java -jar selenium-server-standalone-2.31.0.jar > /dev/null & - - sleep 5 + - php: 7.1 notifications: email: false script: - - ./bin/phpunit -c app - - ./bin/behat + - ./vendor/bin/phpunit + - ./vendor/bin/docheader check src/ + - ./vendor/bin/behat diff --git a/composer.json b/composer.json index 11b8d09..2e84505 100644 --- a/composer.json +++ b/composer.json @@ -11,8 +11,7 @@ ], "autoload": { "psr-4": { - "": "src/", - "SymfonyStandard\\": "app/SymfonyStandard/" + "Conticket\\": "src/" } }, "autoload-dev": { @@ -24,64 +23,29 @@ ] }, "require": { - "php": "~5.5|^7.0", - "symfony/symfony": "2.7.*", - "doctrine/mongodb-odm": "^1.0", - "doctrine/mongodb-odm-bundle": "~3.0", - "symfony/assetic-bundle": "~2.3", - "symfony/swiftmailer-bundle": "~2.3", - "symfony/monolog-bundle": "~2.4", - "sensio/distribution-bundle": "~4.0", - "sensio/framework-extra-bundle": "~3.0,>=3.0.2", + "php": "7.0.* || 7.1.*", + "beberlei/assert": "^2.6", "incenteev/composer-parameter-handler": "~2.0", - "hwi/oauth-bundle": "0.4.*@dev", - "snc/redis-bundle": "~1.1", + "moneyphp/money": "^3.0", "predis/predis": "~1.0", - "friendsofsymfony/rest-bundle": "^1.7", - "jms/serializer-bundle": "^1.0", - "doctrine/doctrine-fixtures-bundle": "^2.2" + "prooph/event-sourcing": "^4.0", + "prooph/event-store": "^6.0", + "prooph/event-store-doctrine-adapter": "^3.3", + "prooph/service-bus": "^5.2", + "ramsey/uuid": "^2.8", + "vlucas/phpdotenv": "^2.4", + "zendframework/zend-expressive": "^1.0", + "zendframework/zend-expressive-fastroute": "^1.0", + "zendframework/zend-servicemanager": "^3.2" }, "require-dev": { - "sensio/generator-bundle": "~2.3", "behat/behat": "3.*@stable", "behat/mink": "*@stable", "behat/mink-extension": "*", - "behat/mink-selenium2-driver": "*", "behat/mink-goutte-driver": "*", - "phpunit/phpunit": "4.7.*" - }, - "scripts": { - "post-root-package-install": [ - "SymfonyStandard\\Composer::hookRootPackageInstall" - ], - "post-install-cmd": [ - "Incenteev\\ParameterHandler\\ScriptHandler::buildParameters", - "Sensio\\Bundle\\DistributionBundle\\Composer\\ScriptHandler::buildBootstrap", - "Sensio\\Bundle\\DistributionBundle\\Composer\\ScriptHandler::clearCache", - "Sensio\\Bundle\\DistributionBundle\\Composer\\ScriptHandler::installAssets", - "Sensio\\Bundle\\DistributionBundle\\Composer\\ScriptHandler::installRequirementsFile", - "Sensio\\Bundle\\DistributionBundle\\Composer\\ScriptHandler::removeSymfonyStandardFiles", - "Sensio\\Bundle\\DistributionBundle\\Composer\\ScriptHandler::prepareDeploymentTarget" - ], - "post-update-cmd": [ - "Incenteev\\ParameterHandler\\ScriptHandler::buildParameters", - "Sensio\\Bundle\\DistributionBundle\\Composer\\ScriptHandler::buildBootstrap", - "Sensio\\Bundle\\DistributionBundle\\Composer\\ScriptHandler::clearCache", - "Sensio\\Bundle\\DistributionBundle\\Composer\\ScriptHandler::installAssets", - "Sensio\\Bundle\\DistributionBundle\\Composer\\ScriptHandler::installRequirementsFile", - "Sensio\\Bundle\\DistributionBundle\\Composer\\ScriptHandler::removeSymfonyStandardFiles", - "Sensio\\Bundle\\DistributionBundle\\Composer\\ScriptHandler::prepareDeploymentTarget" - ] - }, - "config": { - "bin-dir": "bin" - }, - "extra": { - "symfony-app-dir": "app", - "symfony-web-dir": "web", - "symfony-assets-install": "relative", - "incenteev-parameters": { - "file": "app/config/parameters.yml" - } + "behat/mink-selenium2-driver": "*", + "malukenho/docheader": "^0.1.5", + "phpspec/phpspec": "^2.5", + "phpunit/phpunit": "^5.6" } } diff --git a/config/commands.php b/config/commands.php new file mode 100644 index 0000000..03fdd90 --- /dev/null +++ b/config/commands.php @@ -0,0 +1,30 @@ + [ + CreateConference::class => CreateConferenceHandlerFactory::class, + ], + ]; +})(); diff --git a/config/middlewares.php b/config/middlewares.php new file mode 100644 index 0000000..a1a49a6 --- /dev/null +++ b/config/middlewares.php @@ -0,0 +1,14 @@ + [ + CreateConferenceMiddleware::class => CreateConferenceMiddlewareFactory::class, + ], + ]; +})(); diff --git a/config/repositories.php b/config/repositories.php new file mode 100644 index 0000000..c20f9ed --- /dev/null +++ b/config/repositories.php @@ -0,0 +1,30 @@ + [ + ConferenceRepositoryInterface::class => ConferenceRepositoryFactory::class, + ], + ]; +})(); diff --git a/config/service-manager.php b/config/service-manager.php new file mode 100644 index 0000000..39ff25f --- /dev/null +++ b/config/service-manager.php @@ -0,0 +1,16 @@ + [ + Application::class => ApplicationFactory::class, + FastRouteRouter::class => InvokableFactory::class, + CommandBus::class => CommandBusFactory::class, + EventStore::class => EventStoreFactory::class, + Connection::class => ConnectionFactory::class, + \PDO::class => PDOFactory::class, + ], + ]; +})(); diff --git a/phpunit.xml.dist b/phpunit.xml.dist index 09db690..736ed82 100644 --- a/phpunit.xml.dist +++ b/phpunit.xml.dist @@ -12,6 +12,11 @@ backupGlobals="false" > - ./tests/ConticketFunctionalTests + ./tests + + + ./src + + diff --git a/public/index.php b/public/index.php new file mode 100644 index 0000000..b1a99d2 --- /dev/null +++ b/public/index.php @@ -0,0 +1,25 @@ +load(); + + /* @var $serviceManager \Zend\ServiceManager\ServiceManager */ + $serviceManager = require __DIR__ . '/../config/service-manager.php'; + + /* @var $app \Zend\Expressive\Application */ + $app = $serviceManager->get(\Zend\Expressive\Application::class); + + // @todo change it to POST + $app->get(CreateConferenceMiddleware::PATH, CreateConferenceMiddleware::class); + + $app->pipeRoutingMiddleware(); + $app->pipeDispatchMiddleware(); + $app->raiseThrowables(); + $app->run(); +})(); diff --git a/spec/Conticket/Model/Aggregates/Event/EventSpec.php b/spec/Conticket/Model/Aggregates/Event/EventSpec.php new file mode 100644 index 0000000..f04df58 --- /dev/null +++ b/spec/Conticket/Model/Aggregates/Event/EventSpec.php @@ -0,0 +1,30 @@ +beConstructedThrough('fromNameAndDescription', [ + 'Event specification by example', + 'Description of event specified by example' + ]); + } + + public function it_is_initializable() + { + $this->shouldHaveType(Event::class); + } + + public function it_should_return_event_id() + { + $this->aggregateId()->shouldReturnAnInstanceOf(EventId::class); + } +} diff --git a/spec/Conticket/Model/Aggregates/Event/TicketLifespanSpec.php b/spec/Conticket/Model/Aggregates/Event/TicketLifespanSpec.php new file mode 100644 index 0000000..60e8208 --- /dev/null +++ b/spec/Conticket/Model/Aggregates/Event/TicketLifespanSpec.php @@ -0,0 +1,36 @@ +shouldHaveType(TicketLifespan::class); + } + + public function it_throws_an_exception_when_start_date_is_greater_than_end_date() + { + $this->shouldThrow(TicketEndDateMustBeGreaterThanStartDateException::class); + $this->beConstructedThrough('fromStartAndEnd', [ + new \DateTimeImmutable('2016-01-01'), + new \DateTimeImmutable('2015-01-01'), + ]); + } + + public function it_should_return_immutable_datetime_objects_on_start_and_end_methods() + { + $this->beConstructedThrough('fromStartAndEnd', [ + new \DateTimeImmutable('2016-01-01'), + new \DateTimeImmutable('2016-04-01'), + ]); + $this->start()->shouldReturnAnInstanceOf(\DateTimeImmutable::class); + $this->end()->shouldReturnAnInstanceOf(\DateTimeImmutable::class); + } +} diff --git a/src/Conference/Domain/Command/CreateConference.php b/src/Conference/Domain/Command/CreateConference.php new file mode 100644 index 0000000..6b8400d --- /dev/null +++ b/src/Conference/Domain/Command/CreateConference.php @@ -0,0 +1,158 @@ + + */ +final class CreateConference extends Command +{ + /** + * @var ConferenceId + */ + private $conferenceId; + + /** + * @var string + */ + private $name; + + /** + * @var string + */ + private $description; + + /** + * @var string + */ + private $author; + + /** + * @var \DateTimeImmutable + */ + private $date; + + private function __construct( + ConferenceId $conferenceId, + string $name, + string $description, + string $author, + \DateTimeImmutable $date + ) { + Assertion::notEmpty($name); + Assertion::notEmpty($description); + Assertion::notEmpty($author); + + $this->conferenceId = $conferenceId; + $this->name = $name; + $this->description = $description; + $this->author = $author; + $this->date = $date; + } + + public static function fromRequestData( + ConferenceId $conferenceId, + string $name, + string $description, + string $author, + \DateTimeImmutable $date + ): self { + return new self($conferenceId, $name, $description, $author, $date); + } + + /** + * {@inheritDoc} + */ + public function payload(): array + { + return [ + 'name' => $this->name, + 'description' => $this->description, + 'author' => $this->author, + 'conferenceId' => (string) $this->conferenceId, + 'date' => $this->date->format('U.u'), + ]; + } + + /** + * {@inheritDoc} + */ + public function setPayload(array $payload): void + { + [ + $this->name, + $this->description, + $this->author, + $this->conferenceId, + $this->date + ] = [ + $payload['name'], + $payload['description'], + $payload['author'], + ConferenceId::fromString($payload['conferenceId']), + \DateTimeImmutable::createFromFormat('U.u', $payload['date']), + ]; + } + + /** + * @return string + */ + public function getAuthor(): string + { + return $this->author; + } + + /** + * @return ConferenceId + */ + public function getConferenceId(): ConferenceId + { + return $this->conferenceId; + } + + /** + * @return string + */ + public function getDescription(): string + { + return $this->description; + } + + /** + * @return mixed + */ + public function getName(): string + { + return $this->name; + } + + /** + * @return \DateTimeImmutable + */ + public function getDate(): \DateTimeImmutable + { + return $this->date; + } +} diff --git a/src/Conference/Domain/CommandHandler/CreateConferenceHandler.php b/src/Conference/Domain/CommandHandler/CreateConferenceHandler.php new file mode 100644 index 0000000..85621b8 --- /dev/null +++ b/src/Conference/Domain/CommandHandler/CreateConferenceHandler.php @@ -0,0 +1,52 @@ + + */ +final class CreateConferenceHandler +{ + /** + * @var ConferenceRepositoryInterface + */ + private $repository; + + public function __construct(ConferenceRepositoryInterface $repository) + { + $this->repository = $repository; + } + + public function __invoke(CreateConference $command): void + { + $this->repository->store(Conference::new( + $command->getConferenceId(), + $command->getName(), + $command->getDescription(), + $command->getAuthor(), + $command->getDate() + )); + } +} diff --git a/src/Conference/Domain/Conference.php b/src/Conference/Domain/Conference.php new file mode 100644 index 0000000..0969ac7 --- /dev/null +++ b/src/Conference/Domain/Conference.php @@ -0,0 +1,79 @@ + + */ +final class Conference extends AggregateRoot +{ + /** + * @var ConferenceId + */ + private $conferenceId; + + public static function new( + ConferenceId $conferenceId, + string $name, + string $description, + string $author, + \DateTimeImmutable $date + ): self { + $self = new self(); + $self->recordThat(ConferenceWasCreated::fromRequestData($conferenceId, $name, $description, $author, $date)); + + return $self; + } + + public function whenConferenceWasCreated(ConferenceWasCreated $event): void + { + $this->conferenceId = ConferenceId::fromString($event->aggregateId()); + } + + /** + * @todo move it to a trait? + * + * @return array + */ + public function popRecordedEvents(): array + { + return $this->recordedEvents; + } + + /** + * @return ConferenceId + */ + public function conferenceId(): ConferenceId + { + return $this->conferenceId; + } + + /** + * {@inheritDoc} + */ + protected function aggregateId(): string + { + return (string) $this->conferenceId; + } +} diff --git a/src/Conference/Domain/ConferenceId.php b/src/Conference/Domain/ConferenceId.php new file mode 100644 index 0000000..0170239 --- /dev/null +++ b/src/Conference/Domain/ConferenceId.php @@ -0,0 +1,59 @@ + + */ +final class ConferenceId +{ + /** + * @var Uuid + */ + private $uuid; + + private function __construct(Uuid $uuid) + { + $this->uuid = $uuid; + } + + public static function new(): self + { + return new self(Uuid::uuid4()); + } + + public static function fromString(string $uuid): self + { + return new self(Uuid::fromString($uuid)); + } + + public function __toString(): string + { + return (string) $this->uuid; + } + + public function uuid(): Uuid + { + return $this->uuid; + } +} diff --git a/src/Conference/Domain/Event/ConferenceWasCreated.php b/src/Conference/Domain/Event/ConferenceWasCreated.php new file mode 100644 index 0000000..75cc4ff --- /dev/null +++ b/src/Conference/Domain/Event/ConferenceWasCreated.php @@ -0,0 +1,153 @@ + + */ +final class ConferenceWasCreated extends AggregateChanged +{ + /** + * @var ConferenceId + */ + private $conferenceId; + + /** + * @var string + */ + private $name; + + /** + * @var string + */ + private $description; + + /** + * @var string + */ + private $author; + + /** + * @var \DateTimeImmutable + */ + private $date; + + public static function fromRequestData( + ConferenceId $conferenceId, + string $name, + string $description, + string $author, + \DateTimeImmutable $date + ): self { + Assertion::notEmpty($name); + Assertion::notEmpty($description); + Assertion::notEmpty($author); + + return self::occur( + (string) $conferenceId, + [ + 'conferenceId' => (string) $conferenceId, + 'name' => $name, + 'description' => $description, + 'author' => $author, + 'date' => $date->format('U.u'), + ] + ); + } + + /** + * {@inheritDoc} + */ + public function payload(): array + { + return [ + 'name' => $this->name, + 'description' => $this->description, + 'conferenceId' => (string) $this->conferenceId, + 'author' => $this->author, + 'date' => $this->date->format('U.u'), + ]; + } + + /** + * {@inheritDoc} + */ + public function setPayload(array $payload): void + { + [ + $this->name, + $this->description, + $this->author, + $this->conferenceId, + $this->date + ] = [ + $payload['name'], + $payload['description'], + $payload['author'], + ConferenceId::fromString($payload['conferenceId']), + \DateTimeImmutable::createFromFormat('U.u', $payload['date']), + ]; + } + + /** + * @return string + */ + public function getAuthor(): string + { + return $this->author; + } + + /** + * @return ConferenceId + */ + public function getConferenceId(): ConferenceId + { + return $this->conferenceId; + } + + /** + * @return string + */ + public function getDescription(): string + { + return $this->description; + } + + /** + * @return mixed + */ + public function getName(): string + { + return $this->name; + } + + /** + * @return \DateTimeImmutable + */ + public function getDate(): \DateTimeImmutable + { + return $this->date; + } +} diff --git a/src/Conference/Domain/Repository/ConferenceRepositoryInterface.php b/src/Conference/Domain/Repository/ConferenceRepositoryInterface.php new file mode 100644 index 0000000..01dfceb --- /dev/null +++ b/src/Conference/Domain/Repository/ConferenceRepositoryInterface.php @@ -0,0 +1,34 @@ + + */ +interface ConferenceRepositoryInterface +{ + public function get(ConferenceId $conferenceId): Conference; + + public function store(Conference $conference): void; +} diff --git a/src/Conference/Factory/CommandHandler/CreateConferenceHandlerFactory.php b/src/Conference/Factory/CommandHandler/CreateConferenceHandlerFactory.php new file mode 100644 index 0000000..515be51 --- /dev/null +++ b/src/Conference/Factory/CommandHandler/CreateConferenceHandlerFactory.php @@ -0,0 +1,38 @@ + + */ +final class CreateConferenceHandlerFactory +{ + public function __invoke(ContainerInterface $container): CreateConferenceHandler + { + return new CreateConferenceHandler( + $container->get(ConferenceRepositoryInterface::class) + ); + } +} diff --git a/src/Conference/Factory/Middleware/CreateConferenceMiddlewareFactory.php b/src/Conference/Factory/Middleware/CreateConferenceMiddlewareFactory.php new file mode 100644 index 0000000..2084565 --- /dev/null +++ b/src/Conference/Factory/Middleware/CreateConferenceMiddlewareFactory.php @@ -0,0 +1,45 @@ + + */ +final class CreateConferenceMiddlewareFactory +{ + /** + * {@inheritDoc} + * + * @throws \Interop\Container\Exception\ContainerException + * @throws \Psr\Container\ContainerExceptionInterface + * @throws \Psr\Container\NotFoundExceptionInterface + */ + public function __invoke(ContainerInterface $container): CreateConferenceMiddleware + { + return new CreateConferenceMiddleware( + $container->get(CommandBus::class) + ); + } +} diff --git a/src/Conference/Factory/Repository/ConferenceRepositoryFactory.php b/src/Conference/Factory/Repository/ConferenceRepositoryFactory.php new file mode 100644 index 0000000..5bdab78 --- /dev/null +++ b/src/Conference/Factory/Repository/ConferenceRepositoryFactory.php @@ -0,0 +1,43 @@ + + */ +final class ConferenceRepositoryFactory +{ + public function __invoke(ContainerInterface $container): ConferenceRepository + { + return new ConferenceRepository( + $container->get(EventStore::class), + AggregateType::fromAggregateRootClass(Conference::class), + new AggregateTranslator() + ); + } +} diff --git a/src/Conference/Infrastructure/Middleware/CreateConferenceMiddleware.php b/src/Conference/Infrastructure/Middleware/CreateConferenceMiddleware.php new file mode 100644 index 0000000..0d53cbd --- /dev/null +++ b/src/Conference/Infrastructure/Middleware/CreateConferenceMiddleware.php @@ -0,0 +1,74 @@ + + */ +final class CreateConferenceMiddleware implements MiddlewareInterface +{ + const PATH = '/conference'; + + /** + * @var callable + */ + private $commandBus; + + public function __construct(CommandBus $commandBus) + { + $this->commandBus = $commandBus; + } + + /** + * {@inheritDoc} + * + * @throws \InvalidArgumentException + * @throws \Prooph\ServiceBus\Exception\CommandDispatchException + */ + public function __invoke(Request $request, Response $response, callable $out = null) + { + // @todo work with post parameters + $commandBus = $this->commandBus; + + $command = CreateConference::fromRequestData( + ConferenceId::new(), + 'blah', + 'desc', + 'author', + new \DateTimeImmutable('now') + ); + + $commandBus->dispatch($command); + + // @todo return a json response + + $response->getBody()->write('aaa'); + + return $response; + } +} diff --git a/src/Conference/Infrastructure/Repository/ConferenceRepository.php b/src/Conference/Infrastructure/Repository/ConferenceRepository.php new file mode 100644 index 0000000..843aca8 --- /dev/null +++ b/src/Conference/Infrastructure/Repository/ConferenceRepository.php @@ -0,0 +1,63 @@ + + */ +final class ConferenceRepository extends AggregateRepository implements ConferenceRepositoryInterface +{ + /** + * {@inheritDoc} + * + * @throws \DomainException + */ + public function get(ConferenceId $conferenceId): Conference + { + $conference = $this->getAggregateRoot((string) $conferenceId); + + if (! $conference instanceof Conference) { + throw new \DomainException(sprintf('Could not load aggregate using id "%s"', $conferenceId)); + } + + return $conference; + } + + /** + * {@inheritDoc} + * + * @throws \Exception + * @throws \Prooph\EventStore\Aggregate\Exception\AggregateTypeException + */ + public function store(Conference $conference): void + { + $this + ->eventStore + ->transactional(function () use ($conference) { + $this->addAggregateRoot($conference); + }); + } +} diff --git a/src/Conference/Infrastructure/Service/ApplicationFactory.php b/src/Conference/Infrastructure/Service/ApplicationFactory.php new file mode 100644 index 0000000..0191b72 --- /dev/null +++ b/src/Conference/Infrastructure/Service/ApplicationFactory.php @@ -0,0 +1,37 @@ + + */ +final class ApplicationFactory implements FactoryInterface +{ + public function __invoke(ContainerInterface $container, $requestedName, array $options = null): Application + { + return new Application($container->get(FastRouteRouter::class), $container); + } +} diff --git a/src/Conference/Infrastructure/Service/CommandBusFactory.php b/src/Conference/Infrastructure/Service/CommandBusFactory.php new file mode 100644 index 0000000..5e4c090 --- /dev/null +++ b/src/Conference/Infrastructure/Service/CommandBusFactory.php @@ -0,0 +1,87 @@ + + */ +final class CommandBusFactory implements FactoryInterface +{ + public function __invoke(ContainerInterface $container, $requestedName, array $options = null): CommandBus + { + $commandBus = new CommandBus(); + $commandBus->utilize(new ServiceLocatorPlugin($container)); + $commandBus->utilize($this->buildCommandRouter($container)); + + return $commandBus; + } + + private function buildCommandRouter(ContainerInterface $container): ActionEventListenerAggregate + { + return new class($container) implements ActionEventListenerAggregate + { + /** + * @var ContainerInterface + */ + private $container; + + public function __construct(ContainerInterface $container) + { + $this->container = $container; + } + + /** + * {@inheritDoc} + */ + public function attach(ActionEventEmitter $dispatcher) + { + $dispatcher->attachListener(MessageBus::EVENT_ROUTE, [$this, 'onRoute']); + } + + /** + * {@inheritDoc} + * + * @throws \BadMethodCallException + */ + public function detach(ActionEventEmitter $dispatcher) + { + throw new \BadMethodCallException('Not implemented'); + } + + public function onRoute(ActionEvent $actionEvent) + { + $actionEvent->setParam( + MessageBus::EVENT_PARAM_MESSAGE_HANDLER, + (string) $actionEvent->getParam(MessageBus::EVENT_PARAM_MESSAGE_NAME) + ); + } + }; + } +} diff --git a/src/Conference/Infrastructure/Service/ConnectionFactory.php b/src/Conference/Infrastructure/Service/ConnectionFactory.php new file mode 100644 index 0000000..de99e4a --- /dev/null +++ b/src/Conference/Infrastructure/Service/ConnectionFactory.php @@ -0,0 +1,56 @@ + $container->get(\PDO::class) + ], + new Driver() + ); + + try { + $schema = $connection->getSchemaManager()->createSchema(); + + EventStoreSchema::createSingleStream($schema); + + foreach ($schema->toSql($connection->getDatabasePlatform()) as $sql) { + $connection->exec($sql); + } + + } catch (SchemaException $ignored) { + // this is ignored for now - we don't want to re-create the schema every time + } + + return $connection; + } +} diff --git a/src/Conference/Infrastructure/Service/EventStoreFactory.php b/src/Conference/Infrastructure/Service/EventStoreFactory.php new file mode 100644 index 0000000..a6c3f26 --- /dev/null +++ b/src/Conference/Infrastructure/Service/EventStoreFactory.php @@ -0,0 +1,50 @@ + + */ +final class EventStoreFactory implements FactoryInterface +{ + public function __invoke(ContainerInterface $container, $requestedName, array $options = null): EventStore + { + return new EventStore( + new DoctrineEventStoreAdapter( + $container->get(Connection::class), + new FQCNMessageFactory(), + new NoOpMessageConverter(), + new JsonPayloadSerializer() + ), + new ProophActionEventEmitter() + ); + } +} diff --git a/src/Conference/Infrastructure/Service/PDOFactory.php b/src/Conference/Infrastructure/Service/PDOFactory.php new file mode 100644 index 0000000..526f9dd --- /dev/null +++ b/src/Conference/Infrastructure/Service/PDOFactory.php @@ -0,0 +1,32 @@ + + */ +final class CreateConferenceTest extends PHPUnit_Framework_TestCase +{ + /** + * @var ConferenceId + */ + private $conferenceId; + /** + * @var string + */ + private $conferenceName; + /** + * @var string + */ + private $conferenceDescription; + /** + * @var string + */ + private $conferenceAuthor; + /** + * @var DateTimeImmutable + */ + private $conferenceDate; + + /** + * {@inheritDoc} + */ + public function setUp(): void + { + $this->conferenceId = ConferenceId::new(); + $this->conferenceName = 'Conference name'; + $this->conferenceDescription = 'Conference description'; + $this->conferenceAuthor = 'Conference author'; + $this->conferenceDate = new DateTimeImmutable; + } + + public function test_conference_name_should_not_be_empty(): void + { + $this->setExpectedException(\InvalidArgumentException::class); + + CreateConference::fromRequestData( + $this->conferenceId, + '', + $this->conferenceDescription, + $this->conferenceAuthor, + $this->conferenceDate + ); + } + + public function test_conference_description_should_not_be_empty(): void + { + $this->setExpectedException(\InvalidArgumentException::class); + + CreateConference::fromRequestData( + $this->conferenceId, + $this->conferenceName, + '', + $this->conferenceAuthor, + $this->conferenceDate + ); + } + + public function test_conference_author_should_not_be_empty(): void + { + $this->setExpectedException(\InvalidArgumentException::class); + + CreateConference::fromRequestData( + $this->conferenceId, + $this->conferenceName, + $this->conferenceDescription, + '', + $this->conferenceDate + ); + } + + public function test_create_conference(): void + { + $command = CreateConference::fromRequestData( + $this->conferenceId, + $this->conferenceName, + $this->conferenceDescription, + $this->conferenceAuthor, + $this->conferenceDate + ); + + self::assertSame($this->conferenceId, $command->getConferenceId()); + self::assertSame($this->conferenceName, $command->getName()); + self::assertSame($this->conferenceDescription, $command->getDescription()); + self::assertSame($this->conferenceAuthor, $command->getAuthor()); + self::assertSame($this->conferenceDate, $command->getDate()); + + self::assertSame( + [ + 'name' => $this->conferenceName, + 'description' => $this->conferenceDescription, + 'author' => $this->conferenceAuthor, + 'conferenceId' => (string) $this->conferenceId, + 'date' => $this->conferenceDate->format('U.u'), + ], + $command->payload() + ); + + /* @var $nakedCommand CreateConference */ + $nakedCommand = (new \ReflectionClass(CreateConference::class))->newInstanceWithoutConstructor(); + $nakedCommand->setPayload($command->payload()); + + self::assertEquals($command, $nakedCommand); + } +} diff --git a/tests/ConferenceTest/Domain/CommandHandler/CreateConferenceHandlerTest.php b/tests/ConferenceTest/Domain/CommandHandler/CreateConferenceHandlerTest.php new file mode 100644 index 0000000..f7b37cb --- /dev/null +++ b/tests/ConferenceTest/Domain/CommandHandler/CreateConferenceHandlerTest.php @@ -0,0 +1,54 @@ + + */ +final class CreateConferenceHandlerTest extends PHPUnit_Framework_TestCase +{ + public function test_it_should_store_a_new_conference(): void + { + $command = CreateConference::fromRequestData( + $conferenceId = ConferenceId::new(), + $conferenceName = 'Conference name', + $conferenceDescription = 'description', + $conferenceAuthor ='author', + new \DateTimeImmutable() + ); + + /* @var $repository \PHPUnit_Framework_MockObject_MockObject|ConferenceRepositoryInterface*/ + $repository = $this->createMock(ConferenceRepositoryInterface::class); + + $repository->expects(self::once())->method('store'); + + $handler = new CreateConferenceHandler($repository); + $handler->__invoke($command); + } +} diff --git a/tests/ConferenceTest/Domain/ConferenceIdTest.php b/tests/ConferenceTest/Domain/ConferenceIdTest.php new file mode 100644 index 0000000..94b1b78 --- /dev/null +++ b/tests/ConferenceTest/Domain/ConferenceIdTest.php @@ -0,0 +1,45 @@ + + */ +final class ConferenceIdTest extends PHPUnit_Framework_TestCase +{ + public function test_conference_id(): void + { + self::assertInstanceOf(ConferenceId::class, ConferenceId::new()); + + $conference = ConferenceId::new(); + + self::assertEquals($conference, ConferenceId::fromString((string) $conference)); + + self::assertInstanceOf(Uuid::class, $conference->uuid()); + self::assertEquals(Uuid::fromString((string) $conference), $conference->uuid()); + } +} diff --git a/tests/ConferenceTest/Domain/ConferenceTest.php b/tests/ConferenceTest/Domain/ConferenceTest.php new file mode 100644 index 0000000..e5623d4 --- /dev/null +++ b/tests/ConferenceTest/Domain/ConferenceTest.php @@ -0,0 +1,84 @@ + + */ +final class ConferenceTest extends PHPUnit_Framework_TestCase +{ + public function test_it_should_create_new_conference(): void + { + $conferenceId = ConferenceId::new(); + $conferenceName = 'Conference Name'; + $conferenceDescription = 'Conference description'; + $conferenceAuthor = 'Conference author'; + $conferenceDate = new \DateTimeImmutable('now'); + + $conference = Conference::new( + $conferenceId, + $conferenceName, + $conferenceDescription, + $conferenceAuthor, + $conferenceDate + ); + + self::assertInstanceOf(Conference::class, $conference); + + $event = $conference->popRecordedEvents(); + + self::assertCount(1, $event); + + self::assertInstanceOf(ConferenceId::class, $event[0]->getConferenceId()); + self::assertEquals($conferenceId, $event[0]->getConferenceId()); + self::assertSame($conferenceName, $event[0]->getName()); + self::assertSame($conferenceDescription, $event[0]->getDescription()); + self::assertSame($conferenceAuthor, $event[0]->getAuthor()); + self::assertEquals($conferenceDate, $event[0]->getDate()); + } + + public function test_it_should_be_able_to_return_conference_id(): void + { + $conferenceId = ConferenceId::new(); + $conferenceName = 'Conference Name'; + $conferenceDescription = 'Conference description'; + $conferenceAuthor = 'Conference author'; + $conferenceDate = new \DateTimeImmutable('now'); + + $conference = Conference::new( + $conferenceId, + $conferenceName, + $conferenceDescription, + $conferenceAuthor, + $conferenceDate + ); + + self::assertEquals($conferenceId, $conference->conferenceId()); + self::assertSame((string) $conferenceId, (string) $conference->conferenceId()); + } +} diff --git a/tests/ConferenceTest/Domain/Event/ConferenceWasCreatedTest.php b/tests/ConferenceTest/Domain/Event/ConferenceWasCreatedTest.php new file mode 100644 index 0000000..990f417 --- /dev/null +++ b/tests/ConferenceTest/Domain/Event/ConferenceWasCreatedTest.php @@ -0,0 +1,67 @@ + + */ +final class ConferenceWasCreatedTest extends PHPUnit_Framework_TestCase +{ + public function test_it_can_create_event_from_conference_info(): void + { + $conferenceId = ConferenceId::new(); + $conferenceName = 'Conference Name'; + $conferenceDescription = 'Conference description'; + $conferenceAuthor = 'Conference author'; + $conferenceDate = new \DateTimeImmutable('now'); + + $event = ConferenceWasCreated::fromRequestData( + $conferenceId, + $conferenceName, + $conferenceDescription, + $conferenceAuthor, + $conferenceDate + ); + + self::assertEquals($conferenceId, $event->getConferenceId()); + self::assertSame($conferenceName, $event->getName()); + self::assertSame($conferenceDescription, $event->getDescription()); + self::assertSame($conferenceAuthor, $event->getAuthor()); + self::assertEquals($conferenceDate, $event->getDate()); + + self::assertSame( + [ + 'name' => $conferenceName, + 'description' => $conferenceDescription, + 'conferenceId' => (string) $conferenceId, + 'author' => $conferenceAuthor, + 'date' => $conferenceDate->format('U.u'), + ], + $event->payload() + ); + } +} diff --git a/web/app.php b/web/app.php deleted file mode 100644 index 7a757b0..0000000 --- a/web/app.php +++ /dev/null @@ -1,16 +0,0 @@ -loadClassCache(); - -$request = Request::createFromGlobals(); -$response = $kernel->handle($request); -$response->send(); -$kernel->terminate($request, $response); diff --git a/web/app_dev.php b/web/app_dev.php deleted file mode 100644 index 51e5f2d..0000000 --- a/web/app_dev.php +++ /dev/null @@ -1,17 +0,0 @@ -loadClassCache(); - -$request = Request::createFromGlobals(); -$response = $kernel->handle($request); -$response->send(); -$kernel->terminate($request, $response); diff --git a/web/apple-touch-icon.png b/web/apple-touch-icon.png deleted file mode 100644 index 11f17e6..0000000 Binary files a/web/apple-touch-icon.png and /dev/null differ diff --git a/web/config.php b/web/config.php deleted file mode 100644 index 162acfc..0000000 --- a/web/config.php +++ /dev/null @@ -1,124 +0,0 @@ -getFailedRequirements(); -$minorProblems = $symfonyRequirements->getFailedRecommendations(); - -?> - - - - - - Symfony Configuration - - - - - -
-
- - -
-
-
- - - - - - -
-
-
-
- -
-
-
-

Welcome!

-

Welcome to your new Symfony project.

-

- This script will guide you through the basic configuration of your project. - You can also do the same by editing the ‘app/config/parameters.yml’ file directly. -

- - -

Major problems

-

Major problems have been detected and must be fixed before continuing:

-
    - -
  1. getHelpHtml() ?>
    2. - -
- - - -

Recommendations

-

- Additionally, toTo enhance your Symfony experience, - it’s recommended that you fix the following: -

-
    - -
  1. getHelpHtml() ?>
    2. - -
- - - hasPhpIniConfigIssue()): ?> -

* - getPhpIniConfigPath()): ?> - Changes to the php.ini file must be done in "getPhpIniConfigPath() ?>". - - To change settings, create a "php.ini". - -

- - - -

Your configuration looks good to run Symfony.

- - - -
-
-
-
Symfony Standard Edition
-
- - diff --git a/web/favicon.ico b/web/favicon.ico deleted file mode 100644 index 479f7f5..0000000 Binary files a/web/favicon.ico and /dev/null differ diff --git a/web/robots.txt b/web/robots.txt deleted file mode 100644 index 214e411..0000000 --- a/web/robots.txt +++ /dev/null @@ -1,4 +0,0 @@ -# www.robotstxt.org/ -# www.google.com/support/webmasters/bin/answer.py?hl=en&answer=156449 - -User-agent: *