AppBuilder\Application\Module\TicketAggregate\TicketServiceRepository

Complexity

Total Complexity

6

Size/Duplication

Total Lines	78
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	get()	0	14	2
A	onBitbucketTicketMapped()	0	5	1
A	onJiraTicketMapped()	0	5	1
A	onTicketDirIndexed()	0	5	1

<?php

declare(strict_types = 1);

namespace AppBuilder\Application\Module\TicketAggregate;

use AppBuilder\Application\Module\TicketAggregate\Factory\TicketServiceFactory;
use AppBuilder\Event\Application\BitbucketTicketMappedEvent;
use AppBuilder\Event\Application\BitbucketTicketMappedEventAware;
use AppBuilder\Event\Application\JiraTicketMappedEvent;
use AppBuilder\Event\Application\JiraTicketMappedEventAware;
use AppBuilder\Event\Application\TicketDirIndexedEvent;
use AppBuilder\Event\Application\TicketDirIndexedEventAware;
use Psr\Log\LoggerInterface;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

class TicketServiceRepository implements
    JiraTicketMappedEventAware,
    BitbucketTicketMappedEventAware,
    TicketDirIndexedEventAware
{
    /** @var array */
    private $ticketServices = [];

    /** @var TicketServiceFactory */
    private $factory;

    /** @var TicketBuilder */
    private $builder;

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

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

    public function __construct(
        TicketServiceFactory $factory,
        TicketBuilder $builder,
        EventDispatcherInterface $dispatcher,
        LoggerInterface $logger
    ) {
        $this->factory    = $factory;
        $this->builder    = $builder;
        $this->dispatcher = $dispatcher;
        $this->logger     = $logger;
    }

    /**
     * Returns ticket service, adequate to 'id' passed as parameter, from ticketService repository.
     * If passed 'id' is not in repository, creates new ticket service, adds to repository and returns it.
     */
    public function get(int $id) : TicketService
    {
        if (array_key_exists($id, $this->ticketServices)) {
            return $this->ticketServices[$id];
        }
        $ticketService = $this->factory->create(
            $this->builder,
            $this->dispatcher,
            $this->logger
        );
        $this->ticketServices[$id] = $ticketService;

        return $ticketService;
    }

    /**
     * Gets adequate ticketService from repository and passes event to it.
     */
    public function onBitbucketTicketMapped(BitbucketTicketMappedEvent $event) : void
    {
        $ticketService = $this->get(array_keys($event->bitbucketTicket())['0']);
        $ticketService->onBitbucketTicketMapped($event);
    }

    /**
     * Gets adequate ticketService from repository and passes event to it.
     */
    public function onJiraTicketMapped(JiraTicketMappedEvent $event) : void
    {
        $ticketService = $this->get($event->ticket()['id']);
        $ticketService->onJiraTicketMapped($event);
    }

    /**
     * Gets adequate ticketService from repository and passes event to it.
     */
    public function onTicketDirIndexed(TicketDirIndexedEvent $event) : void
    {
        $ticketService = $this->get($event->indexedDir()['ticketId']);
        $ticketService->onTicketDirIndexed($event);
    }
}