Move and internalize udb3-uitpas-bridge to udb3-silex

app/UiTPAS/UiTPASIncomingEventServicesProvider.php

@@ -84,7 +84,6 @@ function (Application $app) {
         $app['uitpas_event_process_manager'] = $app->share(
             function (Application $app) {
                 return new EventProcessManager(
-                    $app['event_jsonld_repository'],
                     $app['event_command_bus'],
                     $app['uitpas_label_repository'],
                     $app['uitpas_logger']

composer.json

@@ -11,7 +11,9 @@
   "minimum-stability": "dev",
   "require": {
     "php": "^7.1",
+    "2dotstwice/collection": "~1.0",
     "2dotstwice/silex-feature-toggles-provider": "~0.1",
+    "broadway/broadway": "~0.10",
     "chrisboulton/php-resque": "dev-compat-1-2 as 1.2",
     "crell/api-problem": "~1.7",
     "cultuurnet/auth": "~1.2",
@@ -34,7 +36,6 @@
     "cultuurnet/udb3-doctrine": "~0.1",
     "cultuurnet/udb3-http-foundation": "~0.1",
     "cultuurnet/udb3-models": "~0.1",
-    "cultuurnet/udb3-uitpas-bridge": "~0.1",
     "cultuurnet/uitid-credentials": "~0.1",
     "cultuurnet/valueobjects": "^3.1",
     "deralex/yaml-config-service-provider": "~1.0",

src/UiTPAS/CardSystem/CardSystem.php

@@ -0,0 +1,47 @@
+<?php
+
+namespace CultuurNet\UDB3\UiTPAS\CardSystem;
+
+use CultuurNet\UDB3\UiTPAS\ValueObject\Id;
+use ValueObjects\StringLiteral\StringLiteral;
+
+class CardSystem
+{
+    /**
+     * @var Id
+     */
+    private $id;
+
+    /**
+     * @var StringLiteral
+     */
+    private $name;
+
+    /**
+     * @param Id $id
+     * @param StringLiteral $name
+     */
+    public function __construct(
+        Id $id,
+        StringLiteral $name
+    ) {
+        $this->id = $id;
+        $this->name = $name;
+    }
+
+    /**
+     * @return Id
+     */
+    public function getId()
+    {
+        return $this->id;
+    }
+
+    /**
+     * @return StringLiteral
+     */
+    public function getName()
+    {
+        return $this->name;
+    }
+}

src/UiTPAS/CardSystem/CardSystems.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace CultuurNet\UDB3\UiTPAS\CardSystem;
+
+use TwoDotsTwice\Collection\AbstractCollection;
+
+class CardSystems extends AbstractCollection
+{
+    protected function getValidObjectType()
+    {
+        return CardSystem::class;
+    }
+}

src/UiTPAS/Event/CommandHandling/Validation/EventHasTicketSalesCommandValidator.php

@@ -0,0 +1,63 @@
+<?php
+
+namespace CultuurNet\UDB3\UiTPAS\Event\CommandHandling\Validation;
+
+use CultuurNet\Broadway\CommandHandling\Validation\CommandValidatorInterface;
+use CultuurNet\UDB3\Event\Commands\DeleteOrganizer;
+use CultuurNet\UDB3\Event\Commands\UpdateOrganizer;
+use CultuurNet\UDB3\Event\Commands\UpdatePriceInfo;
+use Psr\Log\LoggerInterface;
+
+class EventHasTicketSalesCommandValidator implements CommandValidatorInterface
+{
+    /**
+     * @var \CultureFeed_Uitpas
+     */
+    private $uitpas;
+
+    /**
+     * @var LoggerInterface
+     */
+    private $logger;
+
+    public function __construct(
+        \CultureFeed_Uitpas $uitpas,
+        LoggerInterface $logger
+    ) {
+        $this->uitpas = $uitpas;
+        $this->logger = $logger;
+    }
+
+    /**
+     * @inheritdoc
+     */
+    public function validate($command)
+    {
+        if (!($command instanceof UpdateOrganizer) &&
+            !($command instanceof UpdatePriceInfo) &&
+            !($command instanceof DeleteOrganizer)) {
+            return;
+        }
+
+        $eventId = $command->getItemId();
+
+        try {
+            $hasTicketSales = $this->uitpas->eventHasTicketSales($eventId);
+        } catch (\Exception $exception) {
+            // By design to catch all exceptions and map an exception to no ticket sales.
+            // This is done to allow setting price and organizer even when UiTPAS has issues.
+            // All exceptions will be logged.
+            $this->logger->warning(
+                'Ticket call sales failed with exception message "'
+                . $exception->getMessage() . '" and exception code "' . $exception->getCode() . '". '
+                . 'Assuming no ticket sales for event ' . $eventId
+            );
+
+            return;
+        }
+
+        if ($hasTicketSales) {
+            throw new EventHasTicketSalesException($eventId);
+        }
+    }
+}

src/UiTPAS/Event/CommandHandling/Validation/EventHasTicketSalesException.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace CultuurNet\UDB3\UiTPAS\Event\CommandHandling\Validation;
+
+class EventHasTicketSalesException extends \Exception
+{
+    public function __construct($eventId)
+    {
+        $message = sprintf('Event %s has already had ticket sales in UiTPAS.', $eventId);
+        parent::__construct($message);
+    }
+}

src/UiTPAS/Event/Event/EventCardSystemsUpdated.php

@@ -0,0 +1,47 @@
+<?php
+
+namespace CultuurNet\UDB3\UiTPAS\Event\Event;
+
+use CultuurNet\UDB3\UiTPAS\CardSystem\CardSystems;
+use CultuurNet\UDB3\UiTPAS\ValueObject\Id;
+
+class EventCardSystemsUpdated
+{
+    /**
+     * @var Id
+     */
+    private $id;
+
+    /**
+     * @var CardSystems
+     */
+    private $cardSystems;
+
+    /**
+     * @param Id $id
+     * @param CardSystems $cardSystems
+     */
+    public function __construct(
+        Id $id,
+        CardSystems $cardSystems
+    ) {
+        $this->id = $id;
+        $this->cardSystems = $cardSystems;
+    }
+
+    /**
+     * @return Id
+     */
+    public function getId()
+    {
+        return $this->id;
+    }
+
+    /**
+     * @return CardSystems
+     */
+    public function getCardSystems()
+    {
+        return $this->cardSystems;
+    }
+}

src/UiTPAS/Event/Event/EventCardSystemsUpdatedDeserializer.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace CultuurNet\UDB3\UiTPAS\Event\Event;
+
+use CultuurNet\Deserializer\JSONDeserializer;
+use CultuurNet\UDB3\UiTPAS\CardSystem\CardSystem;
+use CultuurNet\UDB3\UiTPAS\CardSystem\CardSystems;
+use CultuurNet\UDB3\UiTPAS\ValueObject\Id;
+use ValueObjects\StringLiteral\StringLiteral;
+
+/**
+ * Deserializes `application/vnd.cultuurnet.uitpas-events.event-card-systems-updated+json` messages
+ * to typed objects.
+ *
+ * Make sure to extract this logic if more (similar) uitpas messages have to be deserialized in the future.
+ */
+class EventCardSystemsUpdatedDeserializer extends JSONDeserializer
+{
+    public function deserialize(StringLiteral $data)
+    {
+        $dto = parent::deserialize($data);
+
+        if (!isset($dto->cdbid)) {
+            throw new \InvalidArgumentException('Missing cdbid property.');
+        }
+
+        $eventId = new Id((string) $dto->cdbid);
+
+        if (!isset($dto->cardSystems)) {
+            throw new \InvalidArgumentException('Missing cardSystems property.');
+        }
+
+        if (!is_array($dto->cardSystems)) {
+            throw new \InvalidArgumentException('Expected cardSystems property to be an array.');
+        }
+
+        $cardSystems = new CardSystems();
+        foreach ($dto->cardSystems as $cardSystemDTO) {
+            if (!isset($cardSystemDTO->id)) {
+                throw new \InvalidArgumentException('Encountered cardSystems entry without id.');
+            }
+
+            if (!isset($cardSystemDTO->name)) {
+                throw new \InvalidArgumentException('Encountered cardSystems entry without name.');
+            }
+
+            $cardSystems = $cardSystems->withKey(
+                $cardSystemDTO->id,
+                new CardSystem(
+                    new Id((string) $cardSystemDTO->id),
+                    new StringLiteral($cardSystemDTO->name)
+                )
+            );
+        }
+
+        return new EventCardSystemsUpdated($eventId, $cardSystems);
+    }
+}