Swis\Melvin\Parsers\SituationParser

Complexity

Total Complexity

33

Size/Duplication

Total Lines	148
Duplicated Lines	0 %

Test Coverage

Coverage

99.05%

Importance

Changes	9
Bugs	1	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getPeriods()	0	6	1
B	getName()	0	35	11
A	__construct()	0	9	1
D	parse()	0	81	20

<?php

declare(strict_types=1);

namespace Swis\Melvin\Parsers;

use Swis\Melvin\Enums\ActivityType;
use Swis\Melvin\Enums\Delay;
use Swis\Melvin\Enums\EventType;
use Swis\Melvin\Enums\Impact;
use Swis\Melvin\Enums\ImpactDescription;
use Swis\Melvin\Enums\PersonType;
use Swis\Melvin\Enums\RoadAuthorityType;
use Swis\Melvin\Enums\SituationStatus;
use Swis\Melvin\Enums\Source;
use Swis\Melvin\Enums\WorkObject;
use Swis\Melvin\Enums\WorkType;
use Swis\Melvin\Models\Location;
use Swis\Melvin\Models\Person;
use Swis\Melvin\Models\RoadAuthority;
use Swis\Melvin\Models\Situation;

class SituationParser
{
    public function __construct(
        protected GeometryParser $geometryParser,
        protected PeriodParser $periodParser,
        protected AttachmentParser $attachmentParser,
        protected RestrictionParser $restrictionParser,
        protected DetourParser $detourParser,
        protected ContactParser $contactParser,
        protected UrlParser $urlParser
    ) {
    }

    public function parse(\stdClass $object, array $restrictions, array $detours = []): Situation
    {
        $situationId = (int) $object->id;

        if ($roadAuthority = $object->properties->roadAuthority ?? null) {
            $roadAuthority = new RoadAuthority(
                $roadAuthority->id ?? $situationId,
                $roadAuthority->type !== 'EMPTY' ? RoadAuthorityType::from($roadAuthority->type) : null,
                $roadAuthority->name
            );
        }

        if ($createdBy = $object->properties->createdBy ?? null) {
            $createdBy = new Person(
                $createdBy->firstName,
                $createdBy->prefix,
                $createdBy->lastName,
                PersonType::from($createdBy->type)
            );
        }
        if ($createdAt = $object->properties->createdAt ?? $object->properties->createdBy->createdAt ?? null) {
            $createdAt = new \DateTime($createdAt, new \DateTimeZone('UTC'));
        }

        if ($lastChangedBy = $object->properties->lastChangedBy ?? null) {
            $lastChangedBy = new Person(
                $lastChangedBy->firstName,
                $lastChangedBy->prefix,
                $lastChangedBy->lastName,
                PersonType::from($lastChangedBy->type)
            );
        }
        if ($lastChangedAt = $object->properties->lastChangeAt ?? $object->properties->lastChangedBy->lastChangeAt ?? null) {
            $lastChangedAt = new \DateTime($lastChangedAt, new \DateTimeZone('UTC'));
        }

        $location = new Location(
            $object->properties->location->city,
            $object->properties->location->road,
            $object->properties->location->district,
            $object->properties->location->comment ?? ''
        );

        if ($impactDescription = $object->properties->impactDescription ?? null) {
            $impactDescription = ImpactDescription::isValid($impactDescription) ? ImpactDescription::from($impactDescription)->getLabel() : $impactDescription;
        }

        return new Situation(
            $object->id,
            str_contains($object->properties->type, '_EXTERNAL'),
            $this->geometryParser->parse($object->geometry),
            $this->getName($object),
            ($object->activityType ?? '') ? ActivityType::from($object->activityType) : ActivityType::WORK(),
            ($object->properties->workObject ?? '') ? WorkObject::from($object->properties->workObject) : null,
            isset($object->properties->impact) && $object->properties->impact !== 'EMPTY' ? Impact::from($object->properties->impact) : null,
            $impactDescription,
            $object->properties->project,
            Source::from($object->properties->source),
            $object->properties->published,
            $this->urlParser->parse($object->properties->url ?? ''),
            ($object->properties->urlDescription ?? '') ?: null,
            Delay::from($object->properties->delay),
            ($object->properties->workType ?? '') ? WorkType::from($object->properties->workType) : null,
            ($object->properties->eventType ?? '') ? EventType::from($object->properties->eventType) : null,
            ($object->properties->eventName ?? '') ?: null,
            ($object->properties->addition ?? '') ?: null,
            SituationStatus::from($object->properties->status),
            $roadAuthority,
            $location,
            $this->getPeriods($object->properties->periods),
            $createdAt,
            $createdBy,
            $lastChangedAt,
            $lastChangedBy,
            array_map([$this->attachmentParser, 'parse'], $object->properties->attachments ?? [], array_keys($object->properties->attachments ?? [])),
            array_map([$this->restrictionParser, 'parse'], $restrictions, array_keys($restrictions)),
            array_map([$this->detourParser, 'parse'], $detours, array_keys($detours)),
            ($object->properties->permitId ?? '') ?: null,
            ($object->properties->referenceId ?? '') ?: null,
            $object->properties->remarks,
            array_map([$this->contactParser, 'parse'], $object->properties->contacts ?? []),
        );
    }

    protected function getName(\stdClass $object): string
    {
        if (isset($object->properties->name) && trim($object->properties->name)) {
            return trim($object->properties->name);
        }

        $eventName = ($object->properties->eventName ?? '') ?: null;
        $eventType = ($object->properties->eventType ?? '') ? EventType::from($object->properties->eventType) : null;
        $workType = ($object->properties->workType ?? '') ? WorkType::from($object->properties->workType) : null;
        $workObject = ($object->properties->workObject ?? '') ? WorkObject::from($object->properties->workObject) : null;

        $description = '';
        if ($eventName) {
            $description = $eventName;
        } elseif ($eventType) {
            $description = $eventType->getLabel();
        } elseif ($workType) {
            $description = $workType->getLabel();

            if ($workObject) {
                $description = str_replace('...', $workObject->getLabel(), $description);
            }
        }

        return trim(
            preg_replace(
                '/\s+/',
                ' ',
                sprintf(
                    '%s %s %s %s %s',
                    $object->properties->location->road,
                    $object->properties->location->district,
                    $object->properties->location->city,
                    $description,
                    $object->properties->addition ?? ''
                )
            )
        );
    }

    /**
     * @param \stdClass[] $objects
     *
     * @return array
     */
    protected function getPeriods(array $objects): array
    {
        $filtered = array_filter($objects, static fn (\stdClass $object) => $object->id);
        usort($filtered, static fn (\stdClass $a, \stdClass $b) => ($a->startDateActual ?? $a->startDate) <=> ($b->startDateActual ?? $b->startDate));

        return array_map([$this->periodParser, 'parse'], $filtered, array_keys($filtered));
    }
}