AppBuilder\Application\Module\BitBucket\ExternalLibraryBitBucketService

Complexity

Total Complexity

6

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	onJiraTicketMapped()	0	6	1
A	fetchBitBucketData()	0	10	1
A	mapToBitbucketTicket()	0	12	2
A	createUrl()	0	4	1

<?php

declare(strict_types = 1);

namespace AppBuilder\Application\Module\BitBucket;

use AppBuilder\Application\Module\HttpClient\ExternalLibraryHttpClient;
use AppBuilder\Application\Utils\Mapper\Factory\BitbucketMapperFactory;
use AppBuilder\Event\Application\BitbucketTicketMappedEvent;
use AppBuilder\Event\Application\JiraTicketMappedEvent;
use AppBuilder\Event\Application\JiraTicketMappedEventAware;
use Psr\Log\LoggerInterface;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

class ExternalLibraryBitBucketService implements JiraTicketMappedEventAware, BitBucketService
{
    /** @var string */
    private const URL_PREFIX = 'https://farpoint.get-ag.com/jira/rest/dev-status/1.0/issue/detail?issueId=';

    /** @var string */
    private const URL_SUFFIX = '&applicationType=stash&dataType=pullrequest';

    /** @var string */
    private $url;

    /** @var LoggerInterface */
    private $logger;

    /** @var ExternalLibraryHttpClient */
    private $httpClient;

    /** @var EventDispatcherInterface */
    private $dispatcher;

    public function __construct(
        ExternalLibraryHttpClient $httpClient,
        LoggerInterface $logger,
        EventDispatcherInterface $dispatcher
    ) {
        $this->logger     = $logger;
        $this->httpClient = $httpClient;
        $this->dispatcher = $dispatcher;
    }

    /** Recives event with mapped Jira ticket. */
    public function onJiraTicketMapped(JiraTicketMappedEvent $event) : void
    {
        $ticketId = $event->ticket()['id'];
        $this->createUrl($ticketId);
        $this->fetchBitBucketData($ticketId);
    }

    /**
     * Fetches data from BitBucket by tickets id.
     */
    public function fetchBitBucketData(int $ticketId) : void
    {
        $bbFullTicket = [];
        $response     = $this
            ->httpClient
            ->request(ExternalLibraryHttpClient::GET, $this->url);
        $content                 = $response->getBody()->getContents();
        $bbFullTicket[$ticketId] = json_decode($content, true);
        $this->mapToBitbucketTicket($bbFullTicket, $ticketId);
    }

    /**
     * Maps and filters received BitBucket data to array.
     */
    private function mapToBitbucketTicket(array $bbTicket, int $ticketId) : void
    {
        $mappedTicket  = [];
        $ticketMappers = BitbucketMapperFactory::create();
        foreach ($ticketMappers as $mapper) {
            $mappedTicket[$ticketId][$mapper->outputKey()] = $mapper->map($bbTicket[$ticketId]);
        }
        $this->dispatcher->dispatch(
            BitbucketTicketMappedEvent::NAME,
            new BitbucketTicketMappedEvent($mappedTicket)
        );
    }

    /**
     * Combines url with given ticket id.
     */
    private function createUrl(int $ticketId) : void
    {
        $this->url = self::URL_PREFIX . $ticketId . self::URL_SUFFIX;
    }
}