ForecastAutomation\ForecastClient\Shared\Plugin\ForecastClientQueuePluginPlugin

Complexity

Total Complexity

3

Size/Duplication

Total Lines	21
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getQueueName()	0	3	1
A	createActivityDto()	0	7	1
A	consumeMessage()	0	5	1

<?php

declare(strict_types=1);

/*
 * This file is part of forecast.it.fill project.
 * (c) Patrick Jaja <patrickjajaa@gmail.com>
 * This source file is subject to the MIT license that is bundled
 * with this source code in the file LICENSE.
 */

namespace ForecastAutomation\ForecastClient\Shared\Plugin;

use ForecastAutomation\Activity\Shared\Dto\ActivityDto;
use ForecastAutomation\Activity\Shared\Dto\ActivityDtoCollection;
use ForecastAutomation\ForecastClient\Shared\Config\ForecastClientQueueConstants;
use ForecastAutomation\Kernel\Shared\Plugin\AbstractPlugin;
use ForecastAutomation\QueueClient\Shared\Dto\MessageDto;
use ForecastAutomation\QueueClient\Shared\Plugin\QueuePluginInterface;

/**
 * @method \ForecastAutomation\ForecastClient\ForecastClientFacade getFacade()
 */
class ForecastClientQueuePluginPlugin extends AbstractPlugin implements QueuePluginInterface
{
    public function getQueueName(): string
    {
        return ForecastClientQueueConstants::QUEUE_NAME;
    }

    public function consumeMessage(MessageDto $messageDto): bool
    {
        $this->getFacade()->writeActivities(new ActivityDtoCollection($this->createActivityDto($messageDto)));

        return true;
    }

    private function createActivityDto(MessageDto $messageDto)
    {
        return new ActivityDto(
            $messageDto->data['needle'],
            $messageDto->data['description'],
            new \DateTime($messageDto->data['created']),
            (int) $messageDto->data['duration']
        );
    }
}