III-1491: Cleaned up structure of commands & command handlers.

bootstrap.php

@@ -13,10 +13,10 @@
 use CultuurNet\UDB3\EventSourcing\ExecutionContextMetadataEnricher;
 use CultuurNet\UDB3\LabelCollection;
 use CultuurNet\UDB3\SimpleEventBus;
-use CultuurNet\UDB3\UiTPASService\Command\RemotelySyncUiTPASCommandHandler;
+use CultuurNet\UDB3\UiTPASService\Sync\SyncCommandHandler;
 use CultuurNet\UDB3\UiTPASService\EventStoreSchemaConfigurator;
 use CultuurNet\UDB3\UiTPASService\Specification\IsUiTPASOrganizerAccordingToJSONLD;
-use CultuurNet\UDB3\UiTPASService\UiTPASAggregateRepository;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\UiTPASAggregateRepository;
 use CultuurNet\UDB3\UiTPASService\UiTPASEventSaga;
 use DerAlex\Silex\YamlConfigServiceProvider;
 use Monolog\Handler\StreamHandler;
@@ -376,7 +376,7 @@ function (Application $app) {
 
 $app['uitpas_sync_command_handler'] = $app->share(
     function (Application $app) {
-        return new RemotelySyncUiTPASCommandHandler(
+        return new SyncCommandHandler(
             $app['culturefeed_uitpas_client']
         );
     }

src/Sync/Command/RegisterUiTPASEvent.php

@@ -0,0 +1,7 @@
+<?php
+
+namespace CultuurNet\UDB3\UiTPASService\Sync\Command;
+
+class RegisterUiTPASEvent extends SyncUiTPASEvent
+{
+}

src/Command/RemotelySyncUiTPASEvent.php → src/Sync/Command/SyncUiTPASEvent.php

@@ -1,10 +1,10 @@
 <?php
 
-namespace CultuurNet\UDB3\UiTPASService\Command;
+namespace CultuurNet\UDB3\UiTPASService\Sync\Command;
 
 use CultuurNet\UDB3\PriceInfo\PriceInfo;
 
-abstract class RemotelySyncUiTPASEvent
+abstract class SyncUiTPASEvent
 {
     /**
      * @var string

src/Sync/Command/UpdateUiTPASEvent.php

@@ -0,0 +1,7 @@
+<?php
+
+namespace CultuurNet\UDB3\UiTPASService\Sync\Command;
+
+class UpdateUiTPASEvent extends SyncUiTPASEvent
+{
+}

src/Command/RemotelySyncUiTPASCommandHandler.php → src/Sync/SyncCommandHandler.php

@@ -3,18 +3,21 @@
  * @file
  */
 
-namespace CultuurNet\UDB3\UiTPASService\Command;
+namespace CultuurNet\UDB3\UiTPASService\Sync;
 
 use Broadway\CommandHandling\CommandHandler;
 use CultureFeed_Uitpas;
 use CultureFeed_Uitpas_DistributionKey;
 use CultureFeed_Uitpas_Event_CultureEvent;
+use CultuurNet\UDB3\UiTPASService\Sync\Command\RegisterUiTPASEvent;
+use CultuurNet\UDB3\UiTPASService\Sync\Command\SyncUiTPASEvent;
+use CultuurNet\UDB3\UiTPASService\Sync\Command\UpdateUiTPASEvent;
 use Exception;
 use Psr\Log\LoggerAwareInterface;
 use Psr\Log\LoggerAwareTrait;
 use Psr\Log\NullLogger;
 
-class RemotelySyncUiTPASCommandHandler extends CommandHandler implements LoggerAwareInterface
+class SyncCommandHandler extends CommandHandler implements LoggerAwareInterface
 {
     use LoggerAwareTrait;
 
@@ -30,31 +33,31 @@ public function __construct(CultureFeed_Uitpas $culturefeedClient)
     }
 
     /**
-     * @param RemotelyRegisterUiTPASEvent $command
+     * @param RegisterUiTPASEvent $command
      */
     protected function handleRemotelyRegisterUiTPASEvent(
-        RemotelyRegisterUiTPASEvent $command
+        RegisterUiTPASEvent $command
     ) {
         $event = $this->buildEvent($command);
         $this->syncEvent($event, ['registerEvent', 'updateEvent']);
     }
 
     /**
-     * @param RemotelyUpdateUiTPASEvent $command
+     * @param UpdateUiTPASEvent $command
      */
     protected function handleRemotelyUpdateUiTPASEvent(
-        RemotelyUpdateUiTPASEvent $command
+        UpdateUiTPASEvent $command
     ) {
         $event = $this->buildEvent($command);
         $this->syncEvent($event, ['updateEvent', 'registerEvent']);
     }
 
     /**
-     * @var RemotelySyncUiTPASEvent $command
+     * @var SyncUiTPASEvent $command
      *
      * @return CultureFeed_Uitpas_Event_CultureEvent
      */
-    private function buildEvent(RemotelySyncUiTPASEvent $command)
+    private function buildEvent(SyncUiTPASEvent $command)
     {
         $event = new CultureFeed_Uitpas_Event_CultureEvent();
         $event->cdbid = $command->getEventId();

src/Command/ClearDistributionKeys.php → src/UiTPASAggregate/Command/ClearDistributionKeys.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace CultuurNet\UDB3\UiTPASService\Command;
+namespace CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Command;
 
 class ClearDistributionKeys
 {

src/Command/CreateUiTPASAggregate.php → src/UiTPASAggregate/Command/CreateUiTPASAggregate.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace CultuurNet\UDB3\UiTPASService\Command;
+namespace CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Command;
 
 class CreateUiTPASAggregate
 {

src/Command/UpdateDistributionKeys.php → src/UiTPASAggregate/Command/UpdateDistributionKeys.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace CultuurNet\UDB3\UiTPASService\Command;
+namespace CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Command;
 
 class UpdateDistributionKeys
 {

src/Event/AbstractUiTPASAggregateEvent.php → src/UiTPASAggregate/Event/AbstractUiTPASAggregateEvent.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace CultuurNet\UDB3\UiTPASService\Event;
+namespace CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event;
 
 abstract class AbstractUiTPASAggregateEvent
 {

src/Event/DistributionKeysCleared.php → src/UiTPASAggregate/Event/DistributionKeysCleared.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace CultuurNet\UDB3\UiTPASService\Event;
+namespace CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event;
 
 class DistributionKeysCleared extends AbstractUiTPASAggregateEvent
 {

src/Event/DistributionKeysUpdated.php → src/UiTPASAggregate/Event/DistributionKeysUpdated.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace CultuurNet\UDB3\UiTPASService\Event;
+namespace CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event;
 
 class DistributionKeysUpdated extends AbstractUiTPASAggregateEvent
 {

src/Event/UiTPASAggregateCreated.php → src/UiTPASAggregate/Event/UiTPASAggregateCreated.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace CultuurNet\UDB3\UiTPASService\Event;
+namespace CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event;
 
 class UiTPASAggregateCreated extends AbstractUiTPASAggregateEvent
 {

src/UiTPASAggregate.php → src/UiTPASAggregate/UiTPASAggregate.php

@@ -1,11 +1,11 @@
 <?php
 
-namespace CultuurNet\UDB3\UiTPASService;
+namespace CultuurNet\UDB3\UiTPASService\UiTPASAggregate;
 
 use Broadway\EventSourcing\EventSourcedAggregateRoot;
-use CultuurNet\UDB3\UiTPASService\Event\DistributionKeysCleared;
-use CultuurNet\UDB3\UiTPASService\Event\DistributionKeysUpdated;
-use CultuurNet\UDB3\UiTPASService\Event\UiTPASAggregateCreated;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event\DistributionKeysCleared;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event\DistributionKeysUpdated;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event\UiTPASAggregateCreated;
 
 class UiTPASAggregate extends EventSourcedAggregateRoot
 {

src/UiTPASAggregateCommandHandler.php → src/UiTPASAggregate/UiTPASAggregateCommandHandler.php

@@ -1,12 +1,12 @@
 <?php
 
-namespace CultuurNet\UDB3\UiTPASService;
+namespace CultuurNet\UDB3\UiTPASService\UiTPASAggregate;
 
 use Broadway\CommandHandling\CommandHandlerInterface;
 use Broadway\Repository\RepositoryInterface;
-use CultuurNet\UDB3\UiTPASService\Command\ClearDistributionKeys;
-use CultuurNet\UDB3\UiTPASService\Command\CreateUiTPASAggregate;
-use CultuurNet\UDB3\UiTPASService\Command\UpdateDistributionKeys;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Command\ClearDistributionKeys;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Command\CreateUiTPASAggregate;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Command\UpdateDistributionKeys;
 
 class UiTPASAggregateCommandHandler implements CommandHandlerInterface
 {

src/UiTPASAggregateRepository.php → src/UiTPASAggregate/UiTPASAggregateRepository.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace CultuurNet\UDB3\UiTPASService;
+namespace CultuurNet\UDB3\UiTPASService\UiTPASAggregate;
 
 use Broadway\EventHandling\EventBusInterface;
 use Broadway\EventSourcing\AggregateFactory\PublicConstructorAggregateFactory;

src/UiTPASEventSaga.php

@@ -13,14 +13,14 @@
 use CultuurNet\UDB3\Event\Events\PriceInfoUpdated;
 use CultuurNet\UDB3\Offer\Events\AbstractEvent;
 use CultuurNet\UDB3\PriceInfo\PriceInfo;
-use CultuurNet\UDB3\UiTPASService\Command\ClearDistributionKeys;
-use CultuurNet\UDB3\UiTPASService\Command\CreateUiTPASAggregate;
-use CultuurNet\UDB3\UiTPASService\Command\RemotelyRegisterUiTPASEvent;
-use CultuurNet\UDB3\UiTPASService\Command\RemotelyUpdateUiTPASEvent;
-use CultuurNet\UDB3\UiTPASService\Event\AbstractUiTPASAggregateEvent;
-use CultuurNet\UDB3\UiTPASService\Event\DistributionKeysCleared;
-use CultuurNet\UDB3\UiTPASService\Event\DistributionKeysUpdated;
-use CultuurNet\UDB3\UiTPASService\Event\UiTPASAggregateCreated;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Command\ClearDistributionKeys;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Command\CreateUiTPASAggregate;
+use CultuurNet\UDB3\UiTPASService\Sync\Command\RegisterUiTPASEvent;
+use CultuurNet\UDB3\UiTPASService\Sync\Command\UpdateUiTPASEvent;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event\AbstractUiTPASAggregateEvent;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event\DistributionKeysCleared;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event\DistributionKeysUpdated;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event\UiTPASAggregateCreated;
 use CultuurNet\UDB3\UiTPASService\Specification\OrganizerSpecificationInterface;
 
 class UiTPASEventSaga extends Saga implements StaticallyConfiguredSagaInterface
@@ -207,14 +207,14 @@ private function triggerSyncWhenConditionsAreMet(State $state)
                 new CreateUiTPASAggregate($aggregateId, $distributionKeyIds)
             );
 
-            $syncCommand = new RemotelyRegisterUiTPASEvent(
+            $syncCommand = new RegisterUiTPASEvent(
                 $aggregateId,
                 $organizerId,
                 $priceInfo,
                 $distributionKeyIds
             );
         } else {
-            $syncCommand = new RemotelyUpdateUiTPASEvent(
+            $syncCommand = new UpdateUiTPASEvent(
                 $aggregateId,
                 $organizerId,
                 $priceInfo,

tests/UiTPASAggregateCommandHandlerTest.php → tests/UiTPASAggregate/UiTPASAggregateCommandHandlerTest.php

@@ -1,17 +1,17 @@
 <?php
 
-namespace CultuurNet\UDB3\UiTPASService;
+namespace CultuurNet\UDB3\UiTPASService\UiTPASAggregate;
 
 use Broadway\CommandHandling\CommandHandlerInterface;
 use Broadway\CommandHandling\Testing\CommandHandlerScenarioTestCase;
 use Broadway\EventHandling\EventBusInterface;
 use Broadway\EventStore\EventStoreInterface;
-use CultuurNet\UDB3\UiTPASService\Command\ClearDistributionKeys;
-use CultuurNet\UDB3\UiTPASService\Command\CreateUiTPASAggregate;
-use CultuurNet\UDB3\UiTPASService\Command\UpdateDistributionKeys;
-use CultuurNet\UDB3\UiTPASService\Event\DistributionKeysCleared;
-use CultuurNet\UDB3\UiTPASService\Event\DistributionKeysUpdated;
-use CultuurNet\UDB3\UiTPASService\Event\UiTPASAggregateCreated;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Command\ClearDistributionKeys;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Command\CreateUiTPASAggregate;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Command\UpdateDistributionKeys;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event\DistributionKeysCleared;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event\DistributionKeysUpdated;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event\UiTPASAggregateCreated;
 
 class UiTPASAggregateCommandHandlerTest extends CommandHandlerScenarioTestCase
 {

tests/UiTPASEventSagaTest.php

@@ -27,13 +27,13 @@
 use CultuurNet\UDB3\PriceInfo\PriceInfo;
 use CultuurNet\UDB3\PriceInfo\Tariff;
 use CultuurNet\UDB3\Title;
-use CultuurNet\UDB3\UiTPASService\Command\ClearDistributionKeys;
-use CultuurNet\UDB3\UiTPASService\Command\CreateUiTPASAggregate;
-use CultuurNet\UDB3\UiTPASService\Command\RemotelyRegisterUiTPASEvent;
-use CultuurNet\UDB3\UiTPASService\Command\RemotelyUpdateUiTPASEvent;
-use CultuurNet\UDB3\UiTPASService\Event\DistributionKeysCleared;
-use CultuurNet\UDB3\UiTPASService\Event\DistributionKeysUpdated;
-use CultuurNet\UDB3\UiTPASService\Event\UiTPASAggregateCreated;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Command\ClearDistributionKeys;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Command\CreateUiTPASAggregate;
+use CultuurNet\UDB3\UiTPASService\Sync\Command\RegisterUiTPASEvent;
+use CultuurNet\UDB3\UiTPASService\Sync\Command\UpdateUiTPASEvent;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event\DistributionKeysCleared;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event\DistributionKeysUpdated;
+use CultuurNet\UDB3\UiTPASService\UiTPASAggregate\Event\UiTPASAggregateCreated;
 use CultuurNet\UDB3\UiTPASService\Specification\OrganizerSpecificationInterface;
 use ValueObjects\Geography\Country;
 use ValueObjects\Money\Currency;
@@ -202,7 +202,7 @@ public function it_creates_an_uitpas_aggregate_and_registers_an_uitpas_event_whe
             ->then(
                 [
                     new CreateUiTPASAggregate($this->eventId, []),
-                    new RemotelyRegisterUiTPASEvent(
+                    new RegisterUiTPASEvent(
                         new StringLiteral($this->eventId),
                         new StringLiteral($this->uitpasOrganizerId),
                         $this->priceInfo
@@ -227,7 +227,7 @@ public function it_creates_an_uitpas_aggregate_and_registers_an_uitpas_event_whe
             ->then(
                 [
                     new CreateUiTPASAggregate($this->eventId, []),
-                    new RemotelyRegisterUiTPASEvent(
+                    new RegisterUiTPASEvent(
                         new StringLiteral($this->eventId),
                         new StringLiteral($this->uitpasOrganizerId),
                         $this->priceInfo
@@ -284,7 +284,7 @@ public function it_updates_an_uitpas_event_when_it_has_a_new_uitpas_organizer()
             ->when(new OrganizerUpdated($this->eventId, $this->updatedUitpasOrganizerId))
             ->then(
                 [
-                    new RemotelyUpdateUiTPASEvent(
+                    new UpdateUiTPASEvent(
                         $this->eventId,
                         $this->updatedUitpasOrganizerId,
                         $this->priceInfo
@@ -318,7 +318,7 @@ public function it_updates_an_uitpas_event_when_it_has_new_price_info()
             ->when(new PriceInfoUpdated($this->eventId, $updatedPriceInfo))
             ->then(
                 [
-                    new RemotelyUpdateUiTPASEvent(
+                    new UpdateUiTPASEvent(
                         $this->eventId,
                         $this->uitpasOrganizerId,
                         $updatedPriceInfo
@@ -373,7 +373,7 @@ public function it_updates_the_uitpas_event_with_distribution_keys_when_the_uitp
             )
             ->then(
                 [
-                    new RemotelyUpdateUiTPASEvent(
+                    new UpdateUiTPASEvent(
                         $this->eventId,
                         $this->uitpasOrganizerId,
                         $this->priceInfo,
@@ -405,7 +405,7 @@ public function it_updates_the_uitpas_event_when_the_distribution_keys_on_the_ui
             )
             ->then(
                 [
-                    new RemotelyUpdateUiTPASEvent(
+                    new UpdateUiTPASEvent(
                         $this->eventId,
                         $this->uitpasOrganizerId,
                         $this->priceInfo,
@@ -434,7 +434,7 @@ public function it_updates_the_uitpas_event_when_the_distribution_keys_on_the_ui
             )
             ->then(
                 [
-                    new RemotelyUpdateUiTPASEvent(
+                    new UpdateUiTPASEvent(
                         $this->eventId,
                         $this->uitpasOrganizerId,
                         $this->priceInfo,
@@ -466,7 +466,7 @@ public function it_clears_the_distribution_keys_if_the_organizer_is_changed()
             )
             ->then(
                 [
-                    new RemotelyUpdateUiTPASEvent(
+                    new UpdateUiTPASEvent(
                         $this->eventId,
                         $this->updatedUitpasOrganizerId,
                         $this->priceInfo,