Umbrellio\TableSync\Integration\Laravel\Receive\MessageData\MessageDataRetriever

Complexity

Total Complexity

18

Size/Duplication

Total Lines	107
Duplicated Lines	0 %

Test Coverage

Coverage

94.34%

Importance

Changes	1
Bugs	0	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	retrieveTable()	0	7	2
A	applyAdditionalHandler()	0	10	1
A	configForMessage()	0	7	2
A	overrideData()	0	9	2
A	__construct()	0	3	1
A	wrapAttributes()	0	10	2
A	retrieveTargetKeys()	0	7	2
A	retrieve()	0	8	1
A	retrieveData()	0	13	3
A	resolveAdditionalDataHandler()	0	10	2

<?php

declare(strict_types=1);

namespace Umbrellio\TableSync\Integration\Laravel\Receive\MessageData;

use Umbrellio\TableSync\Integration\Laravel\Exceptions\Receive\IncorrectAdditionalDataHandler;
use Umbrellio\TableSync\Integration\Laravel\Exceptions\Receive\IncorrectConfiguration;
use Umbrellio\TableSync\Messages\ReceivedMessage;

class MessageDataRetriever
{
    private $config;

    // todo: config should be object
    public function __construct(array $config)
    {
        $this->config = $config;
    }

    public function retrieve(ReceivedMessage $message): MessageData
    {
        $messageConfig = $this->configForMessage($message);
        $table = $this->retrieveTable($messageConfig);
        $targetKeys = $this->retrieveTargetKeys($messageConfig);
        $data = $this->retrieveData($message, $messageConfig);

        return new MessageData($table, $targetKeys, $data);
    }

    private function configForMessage(ReceivedMessage $message): array
    {
        if (!isset($this->config[$message->getModel()])) {
            throw new IncorrectConfiguration("No configuration for {$message->getModel()}");
        }

        return $this->config[$message->getModel()];
    }

    private function retrieveTable(array $messageConfig): string
    {
        if (!isset($messageConfig['table'])) {
            throw new IncorrectConfiguration('Table configuration required');
        }

        return $messageConfig['table'];
    }

    private function retrieveTargetKeys(array $messageConfig): array
    {
        if (!isset($messageConfig['target_keys'])) {
            throw new IncorrectConfiguration('Target keys configuration required');
        }

        return $messageConfig['target_keys'];
    }

    private function retrieveData(ReceivedMessage $message, array $messageConfig): array
    {
        $data = $this->wrapAttributes($message->getAttributes());

        if (isset($messageConfig['additional_data_handler'])) {
            $data = $this->applyAdditionalHandler($data, $message, $messageConfig['additional_data_handler']);
        }

        if (isset($messageConfig['override_data'])) {
            $data = $this->overrideData($data, $messageConfig['override_data']);
        }

        return $data;
    }

    private function wrapAttributes(array $attributes): array
    {
        $keys = array_keys($attributes);

        $isArray = collect($keys)
            ->every(function ($key) {
                return is_numeric($key);
            });

        return $isArray ? $attributes : [$attributes];
    }

    private function applyAdditionalHandler(
        array $data,
        ReceivedMessage $message,
        string $additionalDataHandlerClass
    ): array {
        $handler = $this->resolveAdditionalDataHandler($additionalDataHandlerClass);

        return array_map(function (array $item) use ($handler, $message) {
            return $handler->handle($message, $item);
        }, $data);
    }

    private function overrideData(array $data, array $override): array
    {
        return array_map(function (array $item) use ($override) {
            foreach ($override as $from => $to) {
                $item[$to] = $item[$from];
                unset($item[$from]);
            }
            return $item;
        }, $data);
    }

    private function resolveAdditionalDataHandler(string $className): AdditionalDataHandler
    {
        $handler = app($className);
        if (!$handler instanceof AdditionalDataHandler) {
            throw new IncorrectAdditionalDataHandler(
                "Additional data handler must implement AdditionalDataHandler interface ({$className})"
            );
        }

        return $handler;
    }
}