Puzzle\AMQP\Workers\Chunks\ChunkAssemblyTrackers\MultipleTracker

Complexity

Total Complexity

7

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

0%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	hasBeenStarted()	0	6	1
A	getTracker()	0	10	2
A	start()	0	6	1
A	markAsReceived()	0	6	1
A	isAllHasBeenReceived()	0	6	1

<?php

namespace Puzzle\AMQP\Workers\Chunks\ChunkAssemblyTrackers;

use Puzzle\AMQP\Workers\Chunks\ChunkAssemblyTracker;
use Puzzle\ValueObjects\Uuid;
use Puzzle\AMQP\Messages\Chunks\ChunkedMessageMetadata;

class MultipleTracker implements ChunkAssemblyTracker
{
    private
        $trackers,
        $trackerInstanciator;

    public function __construct(\Closure $trackerInstanciator)
    {
        $this->trackers = [];
        $this->trackerInstanciator = $trackerInstanciator;
    }

    public function hasBeenStarted(Uuid $uuid)
    {
        $tracker = $this->getTracker($uuid);

        return $tracker->hasBeenStarted($uuid);
    }

    private function getTracker(Uuid $uuid)
    {
        if(! isset($this->trackers[$uuid->value()]))
        {
            $factory = $this->trackerInstanciator;
            $this->trackers[$uuid->value()] = $factory();
        }

        return $this->trackers[$uuid->value()];
    }

    public function start(ChunkedMessageMetadata $metadata)
    {
        $tracker = $this->getTracker($metadata->uuid());

        return $tracker->start($metadata);
    }

    public function markAsReceived(Uuid $uuid, $playhead)
    {
        $tracker = $this->getTracker($uuid);

        return $tracker->markAsReceived($uuid, $playhead);
    }

    public function isAllHasBeenReceived(Uuid $uuid)
    {
        $tracker = $this->getTracker($uuid);

        return $tracker->isAllHasBeenReceived($uuid);
    }
}