CultuurNet\UDB3\Offer\ReadModel\JSONLD\CdbXMLItemBaseImporter

Complexity

Total Complexity

28

Size/Duplication

Total Lines	256
Duplicated Lines	3.13 %

Coupling/Cohesion

Components	1
Dependencies	16

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
B	importPublicationInfo()	0	29	3
A	importAvailable()	0	18	3
A	formatAvailableString()	0	8	1
B	importExternalId()	0	21	5
A	importWorkflowStatus()	0	10	2
D	importPriceInfo()	8	114	13

<?php

namespace CultuurNet\UDB3\Offer\ReadModel\JSONLD;

use CultureFeed_Cdb_Item_Base;
use CultuurNet\UDB3\Cdb\DateTimeFactory;
use CultuurNet\UDB3\Cdb\PriceDescriptionParser;
use CultuurNet\UDB3\Language;
use CultuurNet\UDB3\Offer\WorkflowStatus;
use CultuurNet\UDB3\PriceInfo\BasePrice;
use CultuurNet\UDB3\PriceInfo\Price;
use CultuurNet\UDB3\PriceInfo\Tariff;
use CultuurNet\UDB3\ReadModel\MultilingualJsonLDProjectorTrait;
use CultuurNet\UDB3\ValueObject\MultilingualString;
use ValueObjects\Money\Currency;
use ValueObjects\StringLiteral\StringLiteral;

class CdbXMLItemBaseImporter
{
    use MultilingualJsonLDProjectorTrait;

    /**
     * @var PriceDescriptionParser
     */
    private $priceDescriptionParser;

    /**
     * @var string[]
     */
    private $basePriceTranslations;

    /**
     * @param PriceDescriptionParser $priceDescriptionParser
     * @param array $basePriceTranslations
     */
    public function __construct(
        PriceDescriptionParser $priceDescriptionParser,
        array $basePriceTranslations
    ) {
        $this->priceDescriptionParser = $priceDescriptionParser;
        $this->basePriceTranslations = $basePriceTranslations;
    }

    /**
     * @param CultureFeed_Cdb_Item_Base $item
     * @param \stdClass $jsonLD
     */
    public function importPublicationInfo(
        CultureFeed_Cdb_Item_Base $item,
        \stdClass $jsonLD
    ) {
        $jsonLD->creator = $item->getCreatedBy();

        $itemCreationDate = $item->getCreationDate();

        if (!empty($itemCreationDate)) {
            // format using ISO-8601 with time zone designator
            $creationDate = DateTimeFactory::dateTimeFromDateString(
                $itemCreationDate
            );

            $jsonLD->created = $creationDate->format('c');
        }

        $itemLastUpdatedDate = $item->getLastUpdated();

        if (!empty($itemLastUpdatedDate)) {
            $lastUpdatedDate = DateTimeFactory::dateTimeFromDateString(
                $itemLastUpdatedDate
            );

            $jsonLD->modified = $lastUpdatedDate->format('c');
        }

        $jsonLD->publisher = $item->getOwner();
    }

    /**
     * @param CultureFeed_Cdb_Item_Base $item
     * @param \stdClass $jsonLD
     */
    public function importAvailable(
        \CultureFeed_Cdb_Item_Base $item,
        \stdClass $jsonLD
    ) {
        $availableFromString = $item->getAvailableFrom();
        if ($availableFromString) {
            $jsonLD->availableFrom = $this->formatAvailableString(
                $availableFromString
            );
        }

        $availableToString = $item->getAvailableTo();
        if ($availableToString) {
            $jsonLD->availableTo = $this->formatAvailableString(
                $availableToString
            );
        }
    }

    /**
     * @param string $availableString
     * @return string
     */
    private function formatAvailableString($availableString)
    {
        $available = DateTimeFactory::dateTimeFromDateString(
            $availableString
        );

        return $available->format('c');
    }

    /**
     * @param CultureFeed_Cdb_Item_Base $item
     * @param \stdClass $jsonLD
     */
    public function importExternalId(
        \CultureFeed_Cdb_Item_Base $item,
        \stdClass $jsonLD
    ) {
        $externalId = $item->getExternalId();
        if (empty($externalId)) {
            return;
        }

        $externalIdIsCDB = (strpos($externalId, 'CDB:') === 0);

        if (!property_exists($jsonLD, 'sameAs')) {
            $jsonLD->sameAs = [];
        }

        if (!$externalIdIsCDB) {
            if (!in_array($externalId, $jsonLD->sameAs)) {
                array_push($jsonLD->sameAs, $externalId);
            }
        }
    }

    /**
     * @param CultureFeed_Cdb_Item_Base $item
     * @param \stdClass $jsonLD
     */
    public function importWorkflowStatus(
        CultureFeed_Cdb_Item_Base $item,
        \stdClass $jsonLD
    ) {
        $wfStatus = $item->getWfStatus();

        $workflowStatus = $wfStatus ? WorkflowStatus::fromNative($wfStatus) : WorkflowStatus::READY_FOR_VALIDATION();

        $jsonLD->workflowStatus = $workflowStatus->getName();
    }

    /**
     * @param \CultureFeed_Cdb_Data_DetailList $details
     * @param \stdClass $jsonLD
     */
    public function importPriceInfo(
        \CultureFeed_Cdb_Data_DetailList $details,
        $jsonLD
    ) {
        $mainLanguage = $this->getMainLanguage($jsonLD);

        $detailsArray = [];
        foreach ($details as $detail) {
            $detailsArray[] = $detail;
        }
        $details = $detailsArray;

        $mainLanguageDetails = array_filter(
            $details,
            function (\CultureFeed_Cdb_Data_Detail $detail) use ($mainLanguage) {
                return $detail->getLanguage() === $mainLanguage->getCode();
            }
        );

        /* @var \CultureFeed_Cdb_Data_EventDetail $mainLanguageDetail */
        $mainLanguageDetail = reset($mainLanguageDetails);
        if (!$mainLanguageDetail) {
            return;
        }

        $mainLanguagePrice = $mainLanguageDetail->getPrice();

        if (!$mainLanguagePrice) {
            return;
        }

        $basePrice = $mainLanguagePrice->getValue();
        if ($basePrice !== null) {
            $basePrice = floatval($basePrice);
        }

        if (!$basePrice) {
            return;
        }

        $basePrice = new BasePrice(
            Price::fromFloat($basePrice),
            Currency::fromNative('EUR')
        );

        /* @var Tariff[] $tariffs */
        $tariffs = [];
        foreach ($details as $detail) {
            $language = null;

$language is not used, you could remove the assignment.

            $price = null;

$price is not used, you could remove the assignment.

            $description = null;

$description is not used, you could remove the assignment.

            $language = $detail->getLanguage();

            $price = $detail->getPrice();
            if (!$price) {
                continue;
            }

            $description = $price->getDescription();
            if (!$description) {
                continue;
            }

            $translatedTariffs = $this->priceDescriptionParser->parse($description);
            if (empty($translatedTariffs)) {
                continue;
            }

            // Skip the base price.
            array_shift($translatedTariffs);

            $tariffIndex = 0;
            foreach ($translatedTariffs as $tariffName => $tariffPrice) {
                if (!isset($tariffs[$tariffIndex])) {
                    $tariff = new Tariff(
                        new MultilingualString(new Language($language), new StringLiteral($tariffName)),
                        Price::fromFloat($tariffPrice),
                        Currency::fromNative('EUR')
                    );
                } else {
                    $tariff = $tariffs[$tariffIndex];
                    $name = $tariff->getName();
                    $name = $name->withTranslation(new Language($language), new StringLiteral($tariffName));
                    $tariff = new Tariff(
                        $name,
                        $tariff->getPrice(),
                        $tariff->getCurrency()
                    );
                }

                $tariffs[$tariffIndex] = $tariff;
                $tariffIndex++;
            }
        }

        $jsonLD->priceInfo = [
            [
                'category' => 'base',
                'name' => $this->basePriceTranslations,
                'price' => $basePrice->getPrice()->toFloat(),
                'priceCurrency' => $basePrice->getCurrency()->getCode()->toNative(),
            ],
        ];

        foreach ($tariffs as $tariff) {

This code seems to be duplicated across your project.

            $jsonLD->priceInfo[] = [
                'category' => 'tariff',
                'name' => $tariff->getName()->serialize(),
                'price' => $tariff->getPrice()->toFloat(),
                'priceCurrency' => $tariff->getCurrency()->getCode()->toNative(),
            ];
        }
    }
}